电影票支付订单回调

app/common/repositories/movie/MovieRepository.php

@@ -8,6 +8,7 @@
 namespace app\common\repositories\movie;
 
 use app\common\dao\movie\order\MovieOrderDao;
+use app\common\model\movie\order\MovieOrder;
 use app\common\repositories\BaseRepository;
 use app\common\repositories\store\order\StoreOrderRepository;
 use app\traits\HuiPay;
@@ -200,7 +201,7 @@ class MovieRepository extends BaseRepository
                 'mobile' => $userinfo->phone,
                 'order_sn' => $order_sn,
                 'plat_order' => $submitOrder['data']['plat_order'],
-                'price' => $channel_sn['price'],
+                'price' => $order_price,
                 'number' => count($sched_seat),
                 'order_price' => bcadd((string)$order_price, bcmul((string)$order_price, (string)self::premium_ratio, 2), 2),
                 'channel_type' => $channel_sn['channel_type'],
@@ -258,13 +259,14 @@ class MovieRepository extends BaseRepository
             $type = 0;
             if ($pay_type == 'wx') $type = 2;
             if (strtolower($pay_type) == 'ali') $type = 1;
+
             $orderinfo->pay_type = $type;
+            $orderinfo->update_time = time();
             $orderinfo->save();
 
             return app('json')->success($res);
         }
         throw new ValidateException('支付失败');
-//        return DouHuoMallFilmApiRequest::confirmOrder($orderinfo['order_sn'], $orderinfo['order_price']);
     }
 
     /**
@@ -394,4 +396,52 @@ class MovieRepository extends BaseRepository
 
         return compact('premium', 'cost_price', 'pv', 'yanglaojin', 'gongxian', 'score');
     }
+
+    /**
+     * 计算佣金分佣奖励
+     *
+     * @param $pay_type
+     * @param $order_sn
+     * @param $post_data
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function updateMovieOrderAndcalculationCommissionDividendAward($pay_type, $order_sn, $post_data)
+    {
+        $orderinfo = $this->dao->getWhere(['order_sn' => $order_sn])->find();
+        if ($orderinfo) throw new ValidateException('订单不存在');
+        Db::startTrans();
+        $orderinfo->paid = 1;
+        $orderinfo->pay_time = time();
+        $orderinfo->pay_type = $pay_type;
+        $orderinfo->status = 1;
+        $orderinfo->channel_trade_no = $post_data['id'];
+        $orderinfo->pay_open_id = $post_data['expend']['open_id'];
+        $orderinfo->update_time = time();
+        // 支付方式 1支付宝 2微信
+        if ($pay_type == 1) {
+            $orderinfo->alipay_no = $post_data['out_trans_id'];
+        }
+        if ($pay_type == 2) {
+            $orderinfo->weixin_no = $post_data['out_trans_id'];
+        }
+        $res = $orderinfo->save();
+        if ($res) {
+            $confirmOrder = DouHuoMallFilmApiRequest::confirmOrder($orderinfo['order_sn'], $orderinfo['price']);
+            if (!empty($confirmOrder) && isset($confirmOrder['code']) && ($confirmOrder['code'] == ApiResponseService::DEFAULT_SUCCESS_CODE)) {
+                // 提交事务
+                Db::commit();
+            } else {
+                Db::name('log')->insert(['data' => '电影票订单支付回调向【微唯宝】--- 告知电影订单已支付失败，订单编号：' . $order_sn]);
+                // 回滚事务
+                Db::rollback();
+            }
+        } else {
+            Db::name('log')->insert(['data' => '汇付电影票订单支付回调--- 更新电影订单表失败，订单编号：' . $order_sn]);
+            // 回滚事务
+            Db::rollback();
+        }
+    }
 }

app/controller/api/Notify.php

@@ -2,6 +2,7 @@
 namespace app\controller\api;
 
 use AdaPaySdk\AdapayTools;
+use app\common\repositories\movie\MovieRepository;
 use app\common\repositories\store\order\StoreRefundOrderRepository;
 use app\controller\api\merchant\sxy\Access;
 use app\controller\api\store\service\Huafei;
@@ -901,6 +902,11 @@ class Notify
                             }
                             $this -> pay_user_annual($user_pension_account_order['uid'],$requestId[0]);
                             break;
+                        case 'movie': // 电影订单支付回调
+                            /** @var MovieRepository $movieRepository */
+                            $movieRepository = app()->make(MovieRepository::class);
+                            $movieRepository->updateMovieOrderAndcalculationCommissionDividendAward($pay_type, $requestId[0], $post_data_str);
+                            break;
                         default:
                             Db::name("log")->insert(array('data'=>$type));//日志记录
                     }