OrderArousePayAbstract.php 3.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798
  1. <?php
  2. namespace App\Modules\Trade\Pay;
  3. use App\Modules\Subscribe\Models\Order;
  4. use App\Modules\User\Models\QappPackage;
  5. use DB;
  6. abstract class OrderArousePayAbstract
  7. {
  8. /**
  9. * 唤起支付
  10. */
  11. abstract public function arouse(array $data);
  12. protected $uid;
  13. public function __construct(int $uid)
  14. {
  15. $this->uid = $uid;
  16. }
  17. public function handle(array $data)
  18. {
  19. $this->createOrder($data);
  20. return $this->arouse($data);
  21. }
  22. public function createOrder(array $data)
  23. {
  24. $params = [
  25. 'uid' => $this->uid,
  26. 'product_id' => $data['product_id'],
  27. 'distribution_channel_id' => $data['distribution_channel_id'],
  28. 'trade_no' => $data['trade_no'],
  29. 'pay_merchant_id' => isset($data['pay_merchant_id']) ? $data['pay_merchant_id'] : 0,
  30. 'order_type' => $data['order_type'],
  31. 'create_ip' => $data['create_ip'],
  32. 'send_order_id' => $data['send_order_id'],
  33. 'from_type' => $data['from_type'],
  34. 'price' => $data['price'] / 100,
  35. 'status' => 'UNPAID',
  36. 'transaction_id' => '',
  37. 'pay_end_at' => '0000-00-00 00:00:00',
  38. 'pay_merchant_source' => '',
  39. 'send_order_name' => isset($data['send_order_name']) ? $data['send_order_name'] : '',
  40. 'pay_type' => isset($data['pay_type']) ? $data['pay_type'] : 1,
  41. 'from_bid' => isset($data['from_bid']) ? $data['from_bid'] : 0,
  42. 'activity_id' => isset($data['activity_id']) ? $data['activity_id'] : 0,
  43. 'inner_send_order_id' => isset($data['inner_send_order_id']) ? $data['inner_send_order_id'] : '',
  44. ];
  45. $order = Order::firstOrCreate($params);
  46. if (!empty($data['send_order_id'])) {
  47. try {
  48. $account = DB::table('qapp_send_orders')->where('send_order_id',$data['send_order_id'])->value('account');
  49. if ($account) {
  50. $company_id = DB::table('qapp_channel_accounts')->where('account',$account)->value('company_id');
  51. }else{
  52. return ;
  53. }
  54. if (empty($company_id)) {
  55. $company_id = 0;
  56. }
  57. $qapp_order = [
  58. 'order_id' => $order->id,
  59. 'order_created_at' => $order->created_at,
  60. 'distribution_channel_id' => $data['distribution_channel_id'],
  61. 'book_id'=>$order->from_bid,
  62. 'account'=>$account,
  63. 'company_id'=>$company_id,
  64. ];
  65. $res = DB::table('qapp_orders')->insertGetID($qapp_order);
  66. if (!$res) {
  67. sendNotice('报警:'.$order->id.':此订单插入 qapp_orders 失败');
  68. }
  69. } catch (Exception $e) {
  70. sendNotice('报错:'.$e->getMessage().'-order:id'.$order->id);
  71. }
  72. }
  73. }
  74. protected function getSubjectName(int $channel_id)
  75. {
  76. $package = QappPackage::where('channel_id', $channel_id)->select('name')->first();
  77. $name = $package ? $package->name : '';
  78. return "搜索快应用({$name})继续阅读,人工客服:真真阅读(搜公众号),投诉电话:19106559711";
  79. }
  80. protected function getSubjectNameByPackage(string $package)
  81. {
  82. $package = QappPackage::where('package', $package)->select('name')->first();
  83. $name = $package ? $package->name : '';
  84. return "搜索快应用({$name})继续阅读,人工客服:真真阅读(搜公众号),投诉电话:19106559711";
  85. }
  86. }