锁座订单

app/common/repositories/movie/MovieRepository.php

@@ -10,6 +10,7 @@ namespace app\common\repositories\movie;
 use app\common\dao\movie\order\MovieOrderDao;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
+use app\traits\HuiPay;
 use crmeb\services\ApiResponseService;
 use think\exception\ValidateException;
 use think\facade\Db;
@@ -23,6 +24,8 @@ use think\facade\Log;
  */
 class MovieRepository extends BaseRepository
 {
+    use HuiPay;
+
     protected $dao;
 
     /**
@@ -151,9 +154,11 @@ class MovieRepository extends BaseRepository
 
             $group = Db::transaction(function () use ($userinfo, $_order) {
                 $_order = $this->dao->create($_order);
-                if ($_order) return static::pay($_order['pay_type']);
-
-
+                if ($_order) return ['code' => ApiResponseService::DEFAULT_SUCCESS_CODE, 'msg' => '下单成功', 'data' => ['order_sn' => $_order['order_sn']]];
+//                return $this->pay(
+//                    $_order['pay_type'], $userinfo->wechat_user_id, $_order, $_order['film_name'], env('APP_URL') . "/api/hf_notify/movie",
+//                    'delay');
+                throw new ValidateException('下单失败');
             });
             return $group;
         } else {
@@ -161,168 +166,80 @@ class MovieRepository extends BaseRepository
         }
     }
 
-    private static function pay($payType, $code, $groupOrder, $title, $notify_url, $pay_mode = null, $appid = '')
+    /**
+     * 支付
+     *
+     * @param $payType
+     * @param $openid
+     * @param $_order
+     * @param $title
+     * @param $notify_url
+     * @param $pay_mode
+     * @param $appid
+     * @return array|mixed
+     */
+    private function pay($payType, $openid, $_order, $title, $notify_url, $pay_mode = null, $appid = '')
     {
-
-        $order_no = $groupOrder['group_order_sn'] ?? $groupOrder['order_no'];
-
-
-        if ($payType == 'wx') {
-
-            if (!$code || $code == '' || $code == 'undefined')
-                return "授权失败，code为空";
-            if ($appid == '') {
-
-
+        switch ($payType) {
+            case 'wx':
                 $pay_wx = systemConfig('pay_wx');
-
                 if ($pay_wx == 2) {
                     $appid = env('WECHAT_MP.APPID');
                     $new_secret = env('WECHAT_MP.SECRET');
 
                     $app_id = 'app_0827b960-b932-45ec-b800-4e850091b419';
                     $key = 'api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
-
                 } elseif ($pay_wx == 3) {
                     $appid = env('WECHAT_TDYL.APPID');
                     $new_secret = env('WECHAT_TDYL.SECRET');
 
-
-                    Db::name('log')->insert(['data' => 'appid---' . $appid]);
-                    Db::name('log')->insert(['data' => 'new_secret---' . $new_secret]);
                     $app_id = 'app_383a75dd-c03d-44ab-8f58-92c60fe9b9d0';
                     $key = 'api_live_b0a687ec-5450-4ada-a0e4-65bac0f46871';
-
                 }
 
-            } else {
-                $app_id = 'app_0827b960-b932-45ec-b800-4e850091b419';
-                $key = 'api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
-                $new_secret = "c8cbe24fa3b83f77a88b79554b3aeab4";
-            }
-
-            $url = "https://api.weixin.qq.com/sns/jscode2session?appid=" . $appid . "&secret=" . $new_secret . "&js_code=" . $code . "&grant_type=authorization_code";
-            $get = curlGet($url);
-            Db::name('log')->insert(['data' => 'pay_wx---' . $pay_wx]);
-            Db::name('log')->insert(['data' => 'code---' . $code]);
-            Db::name('log')->insert(['data' => 'url---' . $url]);
-            Db::name('log')->insert(['data' => 'open_id---' . json_encode($get)]);
-            if (!isset($get['openid']) || empty($get['openid'])) {
-                return '授权失败';
-            }
-            $openid = $get['openid'];
-
-            $member_id = 0;
-            $type = '2';
-            $pay_channel = 'wx_lite';
-
-            $expend = [
-                'open_id' => $openid,
-                'wx_app_id' => $appid
-            ];
-
-
-            if ($groupOrder['order_type'] = "marketing") {
-
-                db::name("test_log")->insert(["note" => "pay_huifu" . json_encode($groupOrder)]);
-                // 创富宝 分账
-                //创富宝
-                $cfb = sprintf("%01.2f", round(bcmul($groupOrder['pay_price'], '0.094', 5), 2));//9.4%的分账
-
-                $cfb_member = "jsdk_member_1680162243019";
-                //  平台
-                $cxb = sprintf("%01.2f", round(bcsub($groupOrder['pay_price'], $cfb, 5), 2));//剩下的归平台
-
-                $div_members = [
-                    [
-                        'member_id' => $member_id,
-                        'amount' => $cxb,
-                        'fee_flag' => 'Y'
+                $type = '2';
+                $params = [
+                    'order_no' => $_order['order_sn'],
+                    'app_id' => $app_id,
+                    'pay_channel' => 'wx_lite',
+                    'pay_amt' => (string)$_order['order_price'],
+                    'goods_title' => strlen($title) > 64 ? mb_substr($title, 0, 64, 'utf-8') : $title,// 解决因为太长不能支付问题
+                    'goods_desc' => strlen($title) > 42 ? mb_substr($title, 0, 127, 'utf-8') : $title,// 解决因为太长不能支付问题
+                    'device_info' => [
+                        'device_ip' => app('request')->ip()
                     ],
-                    [
-                        'member_id' => $cfb_member,
-                        'amount' => $cfb,
-                        'fee_flag' => 'N'
-                    ]
+                    'expend' => json_encode(['open_id' => $openid, 'wx_app_id' => $appid]),
+                    'fee_mode' => 'I',
+                    'notify_url' => $notify_url,
+                    'pay_mode' => $pay_mode
                 ];
-            } else {
-                $div_members = [
-                    [
-                        'member_id' => $member_id,
-                        'amount' => $groupOrder['pay_price'],
-                        'fee_flag' => 'Y'
-                    ]
+                break;
+            case 'ALI':
+                $type = '1';
+                // 天地博爱科技通道
+                $app_id = 'app_44108546-d27a-48ee-88c1-84b45b75114f';
+                $key = 'api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
+
+                $params = [
+                    'order_no' => $_order['order_sn'],
+                    'app_id' => $app_id,
+                    'pay_channel' => 'alipay_qr',
+                    'pay_amt' => (string)$_order['order_price'],
+                    'goods_title' => strlen($title) > 64 ? mb_substr($title, 0, 64, 'utf-8') : $title,// 解决因为太长不能支付问题
+                    'goods_desc' => strlen($title) > 42 ? mb_substr($title, 0, 127, 'utf-8') : $title,// 解决因为太长不能支付问题
+                    'device_info' => [
+                        'device_ip' => app('request')->ip()
+                    ],
+                    'fee_mode' => 'I',
+                    'notify_url' => $notify_url
                 ];
-            }
-
-            $params = [
-                'order_no' => $order_no . "_" . rand(1000, 9999),
-                'app_id' => $app_id,
-                'pay_channel' => $pay_channel,
-                'pay_amt' => (string)$groupOrder['pay_price'],
-                'goods_title' => strlen($title) > 64 ? mb_substr($title, 0, 64, 'utf-8') : $title,// 解决因为太长不能支付问题
-                'goods_desc' => strlen($title) > 42 ? mb_substr($title, 0, 127, 'utf-8') : $title,// 解决因为太长不能支付问题
-                'device_info' => [
-                    'device_ip' => app('request')->ip()
-//                    'device_ip'=>'115.171.134.68'
-                ],
-
-                'expend' => json_encode($expend),
-                'div_members' => json_encode($div_members),
-                'fee_mode' => 'I',
-                'notify_url' => $notify_url
-            ];
-            if ($pay_mode == 'delay') {
-                $params['pay_mode'] = 'delay';
-                unset($params['div_members']);
-                unset($params['fee_mode']);
-            }
-            return $this->Payment_create_traits_b($params, $type, $key);
-        } elseif ($payType == 'ALI') {
-//            throw new AuthException('支付宝正在升级，请使用微信支付');
-            $member_id = 0;
-            $type = '1';
-            $pay_channel = 'alipay_qr';
-            // 天地博爱科技通道
-            $app_id = 'app_44108546-d27a-48ee-88c1-84b45b75114f';
-            $key = 'api_live_b23537ed-64b8-45d6-832e-fb228aa9e0a9';
-            // 天地博爱通道
-//            $app_id='app_0827b960-b932-45ec-b800-4e850091b419';
-//            $key='api_live_90ef02e4-54ac-41ee-adf1-e4927d23d58f';
-
-            $div_members = [
-                [
-                    'member_id' => $member_id,
-                    'amount' => $groupOrder['pay_price'],
-                    'fee_flag' => 'Y'
-                ]
-            ];
-
-            $params = [
-                'order_no' => $order_no . "_" . rand(1000, 9999),
-                'app_id' => $app_id,
-                'pay_channel' => $pay_channel,
-                'pay_amt' => (string)$groupOrder['pay_price'],
-                'goods_title' => strlen($title) > 64 ? mb_substr($title, 0, 64, 'utf-8') : $title,// 解决因为太长不能支付问题
-                'goods_desc' => strlen($title) > 42 ? mb_substr($title, 0, 127, 'utf-8') : $title,// 解决因为太长不能支付问题
-                'device_info' => [
-                    'device_ip' => app('request')->ip()
-//                    'device_ip'=>'115.171.134.68'
-                ],
-
-//                    'expend'=>json_encode($expend),
-                'div_members' => json_encode($div_members),
-                'fee_mode' => 'I',
-                'notify_url' => $notify_url
-            ];
-            if ($pay_mode == 'delay') {
-                $params['pay_mode'] = 'delay';
-                unset($params['div_members']);
-                unset($params['fee_mode']);
-            }
-            return $this->Payment_create_traits_a($params, $type, $key);
+                break;
+            default:
+                throw new ValidateException('请选择支付方式');
+                break;
         }
 
+        return $this->Payment_create_traits_a($params, $type, $key);
     }
 
     /**