结算脚本开发

app/command/PensionTasks.php

@@ -46,19 +46,24 @@ class PensionTasks extends Command
         $nowTime = time();
         try {
             //线下符合条件的养老金收集（线下交易后第8天）
-            $this->doOfflineOrderGzc($nowTime, $timeLimit = 1);
-            //在线订单符合条件的养老金收集（线上收货后第30天）
-            $this->doOnlineOrderGzc($timeLimit = 30);
-            //在线订单符合条件的话费养老金收集（话费到账后第1天）
-            $this->doOnlineHuuafeiOrderGzc($timeLimit = 1);
-            //第三方订单符合条件的养老金收集（三方结算后第2天）
-            $this->doThridPddOrderGzc($nowTime, $timeLimit = 2);
-            $this->doThridJdOrderGzc($nowTime, $timeLimit = 2);
-            $this->doThridSnOrderGzc($nowTime, $timeLimit = 2);
-            $this->doThridTaobaoOrderGzc($nowTime, $timeLimit = 2);
-            $this->doThridVipOrderGzc($nowTime, $timeLimit = 2);
-            $this->doThridDyOrderGzc($nowTime, $timeLimit = 2);
-            $this->doThridHfOrderGzc($nowTime, $timeLimit = 2);
+//            $this->doOfflineOrderGzc($nowTime, $timeLimit = 1);
+//            $this->doOnlineOrderGzc($timeLimit = 30);
+//            $this->doOnlineHuuafeiOrderGzc($timeLimit = 30);
+            $this->onlineOrderNew($timeLimit = 30);
+            $this->huafeiOrderNew($timeLimit = 30);
+            $this->pddOrderNew($timeLimit = 30);
+            $this->jdOrderNew($timeLimit = 30);
+            $this->suOrderNew($timeLimit = 30);
+            $this->taobaoOrderNew($timeLimit = 30);
+            $this->vipOrderNew($timeLimit = 30);
+            $this->dyOrderNew($timeLimit = 30);
+//            $this->doThridPddOrderGzc($nowTime, $timeLimit = 30);
+//            $this->doThridJdOrderGzc($nowTime, $timeLimit = 30);
+//            $this->doThridSnOrderGzc($nowTime, $timeLimit = 30);
+//            $this->doThridTaobaoOrderGzc($nowTime, $timeLimit = 30);
+//            $this->doThridVipOrderGzc($nowTime, $timeLimit = 30);
+//            $this->doThridDyOrderGzc($nowTime, $timeLimit = 30);
+//            $this->doThridHfOrderGzc($nowTime, $timeLimit = 30);
             $this->billGzcAdd($nowTime);
             //升级
 //            $this -> doUpgrade();
@@ -87,88 +92,89 @@ class PensionTasks extends Command
         ->where('is_gzc', 0)
         ->where('commission_type', 5)
         ->select()->toArray();
-        foreach ($cursor as $bill) {
-            $type_shop = $bill['type_shop'] ?? 0;
-
-            switch ($type_shop){
-                case "0":
-                    $online = $cursor = Db::table('rrx_store_order')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->where('paid', 1)->find();
-                    break;
-                case "1":
-                    $online = Db::table('rrx_order_pdd')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
-                    break;
-                case "2":
-                    $online =  Db::table('rrx_order_vip')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
-                    break;
-                case "3":
-                    $online = Db::table('rrx_order_su')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
-                    break;
-                case "4":
-                    $online = '';
-                    break;
-                case "5":
-                    $online = Db::table('rrx_order_tb')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
-                    break;
-                case "6":
-                    $online = Db::table('rrx_order_jd')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
-                    break;
-                case "7":
-                    $online = '';
-                    break;
-                case "8":
-                    $online = '';
-                    break;
-                case "9":
-                    $online = Db::table('rrx_order_huafei')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
-                    break;
-                default:
-                    $online = Db::table('rrx_store_order')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->where('paid', 1)->find();
-            }
+        if($cursor) {
+            foreach ($cursor as $bill) {
+                $type_shop = $bill['type_shop'] ?? 0;
+
+                switch ($type_shop){
+                    case "0":
+                        $online = $cursor = Db::table('rrx_store_order')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->where('paid', 1)->find();
+                        break;
+                    case "1":
+                        $online = Db::table('rrx_order_pdd')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
+                        break;
+                    case "2":
+                        $online =  Db::table('rrx_order_vip')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
+                        break;
+                    case "3":
+                        $online = Db::table('rrx_order_su')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
+                        break;
+                    case "4":
+                        $online = '';
+                        break;
+                    case "5":
+                        $online = Db::table('rrx_order_tb')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
+                        break;
+                    case "6":
+                        $online = Db::table('rrx_order_jd')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
+                        break;
+                    case "7":
+                        $online = '';
+                        break;
+                    case "8":
+                        $online = '';
+                        break;
+                    case "9":
+                        $online = Db::table('rrx_order_huafei')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
+                        break;
+                    default:
+                        $online = Db::table('rrx_store_order')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->where('paid', 1)->find();
+                }
 
-            if (!$online) {
-                Log::info($bill['uid'] . '查询不到订单');
-                continue;
-            }   
+                if (!$online) {
+                    Log::info($bill['uid'] . '查询不到订单');
+                    continue;
+                }
 
-            $certification = UserCertification::getInstance()->where('uid', $bill['uid'])->find();
-            if (!$certification) {
-                Log::info($online['uid'] . '没有实名认证');
-                continue;
-            }   
+                $certification = UserCertification::getInstance()->where('uid', $bill['uid'])->find();
+                if (!$certification) {
+                    Log::info($online['uid'] . '没有实名认证');
+                    continue;
+                }
 
-            $pension = $bill['number'] ?? 0;
-            if ($pension <= 0) {
-                Log::info($online['order_sn'] . 'pension' . $pension);
-                continue;
-            }
+                $pension = $bill['number'] ?? 0;
+                if ($pension <= 0) {
+                    Log::info($online['order_sn'] . 'pension' . $pension);
+                    continue;
+                }
 
-            //新增入账明细记录
-            $orderId   = $OrderMerchantRepository->getNewOrderId('IN10');
-            $create    = [
-                'uid'          => $online['uid'],
-                'platform_no'  => $orderId,
-                'account_type' => $online['pay_type'] == 1 ? 3 : 2,
-                'user_name'    => $certification['user_name'],
-                'mobile'       => $certification['mobile'],
-                'user_card'    => $certification['user_card'],
-                'pension'      => $pension,
-                'order_type'   => 2,
-                'out_trade_no' => $online['order_sn'],
-                'link_id'=> $bill['bill_id']
-            ];
-            $test_user = Db::name('user')->where('uid', $online['uid'])->value('test_user');
-            $check     = Db::name("gzc_logs")->where("link_id", $bill['id'])->where("order_type", 2)->count();
-            if ($test_user == 0 && $check <= 0) {
-                $OrderGzcRepository->create($create);
-                Db::name('user_bill')
-                ->where('bill_id', $bill['bill_id'])
-                ->where('commission_type', 5)
-                ->update([
-                    'is_gzc'          => 1
-                ]);
+                //新增入账明细记录
+                $orderId   = $OrderMerchantRepository->getNewOrderId('IN10');
+                $create    = [
+                    'uid'          => $online['uid'],
+                    'platform_no'  => $orderId,
+                    'account_type' => $online['pay_type'] == 1 ? 3 : 2,
+                    'user_name'    => $certification['user_name'],
+                    'mobile'       => $certification['mobile'],
+                    'user_card'    => $certification['user_card'],
+                    'pension'      => $pension,
+                    'order_type'   => 2,
+                    'out_trade_no' => $online['order_sn'],
+                    'link_id'=> $bill['bill_id']
+                ];
+                $test_user = Db::name('user')->where('uid', $online['uid'])->value('test_user');
+                $check     = Db::name("gzc_logs")->where("link_id", $bill['id'])->where("order_type", 2)->count();
+                if ($test_user == 0 && $check <= 0) {
+                    $OrderGzcRepository->create($create);
+                    Db::name('user_bill')
+                        ->where('bill_id', $bill['bill_id'])
+                        ->where('commission_type', 5)
+                        ->update([
+                            'is_gzc'          => 1
+                        ]);
+                }
             }
         }
-
     }
 
 
@@ -577,7 +583,7 @@ class PensionTasks extends Command
             // if (!$certification) {
             //     Log::info($online['uid'] . '没有实名认证');
             //     continue;
-            // }   
+            // }
             //查询养老金金额
             $UserBillRepository = app()->make(UserBillRepository::class);
             $bill               = $UserBillRepository->getWhere(['uid' => $online['uid'], 'link_id' => $online['order_id'], 'order_sn' => $online['order_sn'], 'commission_type' => 5]);
@@ -616,9 +622,9 @@ class PensionTasks extends Command
                 $order->gzc             = 1;
                 $order->save();
                 Db::name('user_bill')
-                ->where('order_sn', $online['order_sn'])
-                ->where('commission_type', 5)
-                ->update(['status'=> 1]);
+                    ->where('order_sn', $online['order_sn'])
+                    ->where('commission_type', 5)
+                    ->update(['status'=> 1]);
 
                 // 养老金区域奖励
 //                $order_data = [
@@ -708,7 +714,7 @@ class PensionTasks extends Command
                         ]);
                 }
 
-                
+
                 // 结算京豆
                 $user_sign_jingdou_list = Db::name('user_sign_jingdou')
                     ->where('status', -1)
@@ -805,7 +811,7 @@ class PensionTasks extends Command
                     }
                 }
 
-                
+
                 // 结算佣金
                 $user_bill_list = Db::name('user_bill')
                     ->where('status', 0)
@@ -1524,4 +1530,395 @@ class PensionTasks extends Command
             ]);
         return $data;
     }
+
+    /**
+     * 线上订单结算
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function onlineOrderNew($timeLimit)
+    {
+        // 普通订单
+        $order_data = Db::name('store_order')->where('paid', 1)->where('is_settlement', 0)->where('pay_type', 'in', '0,1,2,4')->where([['status','in','2,3']])->select();
+        $StoreOrderStatusRepository = app()->make(StoreOrderStatusRepository::class);
+        if($order_data) {
+            $order_data = $order_data->toArray();
+            foreach ($order_data as $online) {
+                $status = $StoreOrderStatusRepository->getWhere(['order_id' => $online['order_id'], 'change_type' => 'take']);
+                if(!$status) {
+                    continue;
+                }else{
+                    $date = date('Y-m-d H:i:s', strtotime('-' . $timeLimit . ' days'));
+                    if($date < $status['change_time']) continue;
+                }
+                Db::transaction(function () use ($online) {
+                    $this->settleAward($online);
+                    Db::name('store_order')->where('order_id', $online['order_id'])->update(['is_settlement' => 1 ,'settlement_time' => date('Y-m-d H:i:s')]);
+                });
+            }
+        }
+    }
+
+    /**
+     * 话费订单结算
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function huafeiOrderNew($timeLimit)
+    {
+        // 普通订单
+        $order_data = Db::name('order_huafei')->where('status', 3)->where('gzc' , 0)->select();
+        if($order_data) {
+            $order_data = $order_data->toArray();
+            foreach ($order_data as $online) {
+                $date = date('Y-m-d H:i:s', strtotime('-' . $timeLimit . ' days'));
+                if($date < $online['finish_time']) continue;
+                $online['order_id'] = $online['order_huafei_id'];
+                Db::transaction(function () use ($online) {
+                    $this->settleAward($online);
+                    Db::name('order_huafei')->where('order_huafei_id', $online['order_huafei_id'])->update(['gzc' => 1 ,'modify_time' => date('Y-m-d H:i:s')]);
+                });
+            }
+        }
+    }
+
+    /**
+     * 拼多多订单结算
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function pddOrderNew($timeLimit)
+    {
+        // 普通订单
+        $order_data = Db::name('order_pdd')->where('pin_order_status', 5)->where('gzc', 0)->select();
+        if($order_data) {
+            $order_data = $order_data->toArray();
+            foreach ($order_data as $online) {
+                $date = date('Y-m-d H:i:s', strtotime('-' . $timeLimit . ' days'));
+                if($date < date('Y-m-d H:i:s', $online['pay_time'])) continue;
+                $online['order_id'] = $online['order_pdd_id'];
+                Db::transaction(function () use ($online) {
+                    $this->settleAward($online);
+                    Db::name('order_pdd')->where('order_pdd_id', $online['order_pdd_id'])->update(['gzc' => 1 ,'settle_time' => date('Y-m-d H:i:s')]);
+                });
+            }
+        }
+    }
+
+    /**
+     * 京东订单结算
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function jdOrderNew($timeLimit)
+    {
+        // 普通订单
+        $order_data = Db::name('order_jd')->where('status', 17)->where('gzc', 0)->select();
+        if($order_data) {
+            $order_data = $order_data->toArray();
+            foreach ($order_data as $online) {
+                $date = date('Y-m-d H:i:s', strtotime('-' . $timeLimit . ' days'));
+                if($date < $online['finish_time']) continue;
+                $online['order_id'] = $online['order_jd_id'];
+                Db::transaction(function () use ($online) {
+                    $this->settleAward($online);
+                    Db::name('order_jd')->where('order_jd_id', $online['order_jd_id'])->update(['gzc' => 1 ,'modify_time' => date('Y-m-d H:i:s')]);
+                });
+            }
+        }
+    }
+
+    /**
+     * 苏宁订单结算
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function suOrderNew($timeLimit)
+    {
+        // 普通订单
+        $order_data = Db::name('order_su')->where('status', 1)->where('gzc', 0)->select();
+        if($order_data) {
+            $order_data = $order_data->toArray();
+            foreach ($order_data as $online) {
+                $date = date('Y-m-d H:i:s', strtotime('-' . $timeLimit . ' days'));
+                if($date < date('Y-m-d H:i:s',$online['pay_time'])) continue;
+                $online['order_id'] = $online['order_su_id'];
+                Db::transaction(function () use ($online) {
+                    $this->settleAward($online);
+                    Db::name('order_su')->where('order_su_id', $online['order_su_id'])->update(['gzc' => 1 ,'settled_time' => date('Y-m-d H:i:s')]);
+                });
+            }
+        }
+    }
+
+    /**
+     * 淘宝订单结算
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function taobaoOrderNew($timeLimit)
+    {
+        // 普通订单
+        $order_data = Db::name('order_tb')->where('tk_status', 3)->where('gzc', 0)->select();
+        if($order_data) {
+            $order_data = $order_data->toArray();
+            foreach ($order_data as $online) {
+                $date = date('Y-m-d H:i:s', strtotime('-' . $timeLimit . ' days'));
+                if($date < date('Y-m-d H:i:s',$online['tk_earning_time'])) continue;
+                $online['order_id'] = $online['order_tb_id'];
+                Db::transaction(function () use ($online) {
+                    $this->settleAward($online);
+                    Db::name('order_tb')->where('order_tb_id', $online['order_tb_id'])->update(['gzc' => 1]);
+                });
+            }
+        }
+    }
+
+    /**
+     * 唯品会订单结算
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function vipOrderNew($timeLimit)
+    {
+        // 普通订单
+        $order_data = Db::name('order_vip')->where('status', 2)->where('gzc', 0)->select();
+        if($order_data) {
+            $order_data = $order_data->toArray();
+            foreach ($order_data as $online) {
+                $date = date('Y-m-d H:i:s', strtotime('-' . $timeLimit . ' days'));
+                if($date < date('Y-m-d H:i:s',$online['last_update_time'])) continue;
+                $online['order_id'] = $online['order_vip_id'];
+                Db::transaction(function () use ($online) {
+                    $this->settleAward($online);
+                    Db::name('order_vip')->where('order_vip_id', $online['order_vip_id'])->update(['gzc' => 1,'settle_time' => date('Y-m-d H:i:s')]);
+                });
+            }
+        }
+    }
+
+    /**
+     * 抖音订单结算
+     * @param $timeLimit
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function dyOrderNew($timeLimit)
+    {
+        // 普通订单
+        $order_data = Db::name('order_dy')->where('flow_point', 'SETTLE')->where('gzc', 0)->select();
+        if($order_data) {
+            $order_data = $order_data->toArray();
+            foreach ($order_data as $online) {
+                $date = date('Y-m-d H:i:s', strtotime('-' . $timeLimit . ' days'));
+                if($date < date('Y-m-d H:i:s',$online['pay_success_time'])) continue;
+                $online['order_id'] = $online['order_dy_id'];
+                Db::transaction(function () use ($online) {
+                    $this->settleAward($online);
+                    Db::name('order_dy')->where('order_dy_id', $online['order_dy_id'])->update(['gzc' => 1,'settle_time' => date('Y-m-d H:i:s')]);
+                });
+            }
+        }
+    }
+
+    /**
+     * 结算奖励
+     * @param $online
+     * @return void
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function settleAward($online)
+    {
+        // 结算积分
+        $user_sign_score_list = Db::name('user_sign_score')
+            ->where('status', -1)
+            ->where('order_id', $online['order_id'])
+            ->where('pm', 1)
+            ->select()
+            ->toArray();
+        if($user_sign_score_list){
+            foreach ($user_sign_score_list as $user_sign_score) {
+                // 修改积分
+                Db::name('user')
+                    ->where('uid', $user_sign_score['uid'])
+                    ->inc('score', (float)$user_sign_score['reward_socre'])
+                    ->update();
+                Db::name('user_sign_score')
+                    ->where('id', $user_sign_score['id'])
+                    ->update([
+                        'status'          => 1,
+                        'settlement_time' => date('Y-m-d H:i:s')
+                    ]);
+            }
+        }
+
+        // 结算红包
+        $user_sign_hongbao_list = Db::name('user_sign_hongbao')
+            ->where('status', -1)
+            ->where('order_id', $online['order_id'])
+            ->where('type', 1)
+            ->select()
+            ->toArray();
+        if($user_sign_hongbao_list){
+            foreach ($user_sign_hongbao_list as $user_sign_hongbao) {
+                // 修改红包
+                Db::name('user')
+                    ->where('uid', $user_sign_hongbao['uid'])
+                    ->inc('hongbao', (float)$user_sign_hongbao['number'])
+                    ->update();
+                Db::name('user_sign_hongbao')
+                    ->where('id', $user_sign_hongbao['id'])
+                    ->update([
+                        'status'          => 1,
+                        'settlement_time' => date('Y-m-d H:i:s')
+                    ]);
+            }
+        }
+
+
+        // 结算京豆
+        $user_sign_jingdou_list = Db::name('user_sign_jingdou')
+            ->where('status', -1)
+            ->where('order_id', $online['order_id'])
+            ->where('type', 1)
+            ->select()
+            ->toArray();
+        if($user_sign_jingdou_list){
+            foreach ($user_sign_jingdou_list as $user_sign_jingdou) {
+                // 修改京豆
+                Db::name('user')
+                    ->where('uid', $user_sign_jingdou['uid'])
+                    ->inc('jingdou', (float)$user_sign_jingdou['number'])
+                    ->update();
+                Db::name('user_sign_jingdou')
+                    ->where('id', $user_sign_jingdou['id'])
+                    ->update([
+                        'status'          => 1,
+                        'settlement_time' => date('Y-m-d H:i:s')
+                    ]);
+            }
+        }
+
+        // 结算复购金
+        $user_sign_fugou_list = Db::name('user_sign_fugou')
+            ->where('status', -1)
+            ->where('order_id', $online['order_id'])
+            ->where('type', 1)
+            ->select()
+            ->toArray();
+        if($user_sign_fugou_list){
+            foreach ($user_sign_fugou_list as $user_sign_fugou) {
+                // 修改复购金
+                Db::name('user')
+                    ->where('uid', $user_sign_fugou['uid'])
+                    ->inc('fugou', (float)$user_sign_fugou['number'])
+                    ->update();
+                Db::name('user_sign_fugou')
+                    ->where('id', $user_sign_fugou['id'])
+                    ->update([
+                        'status'          => 1,
+                        'settlement_time' => date('Y-m-d H:i:s')
+                    ]);
+            }
+        }
+
+
+        // 结算贡献值
+        $user_sign_gongxian_list = Db::name('user_sign_gongxian')
+            ->where('status', -1)
+            ->where('order_id', $online['order_id'])
+            ->where('type', 1)
+            ->select()
+            ->toArray();
+        if($user_sign_gongxian_list){
+            foreach ($user_sign_gongxian_list as $user_sign_gongxian) {
+                // 修改贡献值
+                Db::name('user')
+                    ->where('uid', $user_sign_gongxian['uid'])
+                    ->inc('contribute', (float)$user_sign_gongxian['number'])
+                    ->update();
+                Db::name('user_sign_gongxian')
+                    ->where('id', $user_sign_gongxian['id'])
+                    ->update([
+                        'status'          => 1,
+                        'settlement_time' => date('Y-m-d H:i:s')
+                    ]);
+                /** @var UserRepository $userRepository */
+                $userRepository = app()->make(UserRepository::class);
+                $userRepository->setUserIdentity($user_sign_gongxian['uid']);
+            }
+        }
+
+        // 结算PV值
+        $user_pv_list = Db::name('user_pv_log')
+            ->where('status', -1)
+            ->where('order_id', $online['order_id'])
+            ->select()
+            ->toArray();
+        if($user_pv_list) {
+            foreach ($user_pv_list as $user_pv) {
+                // 修改pv
+                Db::name('user')
+                    ->where('uid', $user_pv['uid'])
+                    ->inc('pv', (float)$user_pv['pv'])
+                    ->update();
+                Db::name('user_pv_log')
+                    ->where('id', $user_pv['id'])
+                    ->update([
+                        'status'          => 1,
+                        'settlement_time' => date('Y-m-d H:i:s')
+                    ]);
+            }
+        }
+
+
+        // 结算佣金养老金
+        $user_bill_list = Db::name('user_bill')
+            ->where('status', 0)
+            ->where([ 'link_id' => $online['order_id']])
+            ->where([ 'pm' => 1])
+            ->select()
+            ->toArray();
+        if($user_bill_list){
+            foreach ($user_bill_list as $user_bill) {
+                Db::name('user')
+                    ->where('uid', $user_bill['uid'])
+                    ->inc('brokerage_price', (float)$user_bill['number'])
+                    ->update();
+                Db::name('user_bill')
+                    ->where('bill_id', $user_bill['bill_id'])
+                    ->update([
+                        'status'          => 1,
+                        'take_time' => date('Y-m-d H:i:s')
+                    ]);
+            }
+        }
+        //按角色结算
+//        $StoreOrderRepository->close_order($online['order_id']);
+    }
 }

app/common/repositories/store/order/StoreOrderRepository.php

@@ -3848,7 +3848,7 @@ class StoreOrderRepository extends BaseRepository
                 $orderThird->yuguFugou(
                     $tuiguanfugou,
                     $sprerdUser["uid"],
-                    $order_sn,
+                    $order_id,
                     $order["type_shop"]
                 );
             } else {