话费订单结算 原订单结算

app/command/PensionTasks.php

@@ -48,6 +48,8 @@ class PensionTasks extends Command
             $this->doOfflineOrderGzc($nowTime, $timeLimit = 1);
             //在线订单符合条件的养老金收集（线上收货后第8天）
             $this->doOnlineOrderGzc($timeLimit = 8);
+            //在线订单符合条件的话费养老金收集（话费到账后第1天）
+            $this->doOnlineHuuafeiOrderGzc($timeLimit = 1);
             //第三方订单符合条件的养老金收集（三方结算后第2天）
             $this->doThridPddOrderGzc($nowTime, $timeLimit = 2);
             $this->doThridJdOrderGzc($nowTime, $timeLimit = 2);
@@ -161,8 +163,176 @@ class PensionTasks extends Command
         }
     }
 
+
+
+
     /**
-     * 在线支付公证处IN10入账
+     * 话费支付订单公证处IN10入账
+     * @param $nowTime
+     * @param $timeLimit
+     * author: php迷途小书童
+     * created: 2021/3/20 9:26
+     */
+    public function doOnlineHuuafeiOrderGzc($timeLimit)
+    {
+        // 普通订单
+        $cursor = Db::table('rrx_order_huafei')->where('status', 3)->where('gzc', 0)->cursor();
+        $StoreOrderStatusRepository = app()->make(StoreOrderStatusRepository::class);
+        $OrderMerchantRepository    = app()->make(OrderMerchantRepository::class);
+        $OrderGzcRepository         = app()->make(OrderGzcRepository::class);
+        foreach ($cursor as $online) {
+   
+            if (time() < strtotime($online['finish_time']) + 3600 * 24) {
+                Log::info('还没有话费到账后' . $timeLimit . '天');
+                continue;
+            }
+            
+
+            $certification = UserCertification::getInstance()->where('uid', $online['uid'])->find();
+            if (!$certification) {
+                Log::info($online['uid'] . '没有实名认证');
+                continue;
+            }
+            //查询养老金金额
+            $UserBillRepository = app()->make(UserBillRepository::class);
+            $bill = $UserBillRepository->getWhere(['uid' => $online['uid'], 'order_sn' => $online['order_sn'], 'commission_type' => 5]);
+            $pension = $bill->number ?? 0;
+            if ($pension <= 0) {
+                Log::info($online['order_sn'] . 'pension' . $pension);
+                continue;
+            }
+            
+            //首信易分账
+            // $StoreOrderRepository = app()->make(StoreOrderRepository::class);
+            // if ($online['pay_type'] > 0) {
+            //     $StoreOrderRepository->splitOrder($online);
+            // }
+            $StoreOrderRepository = [];
+            Db::transaction(function () use ($certification, $online, $pension, $OrderGzcRepository, $OrderMerchantRepository, $StoreOrderRepository) {
+                //新增入账明细记录
+                $orderId   = $OrderMerchantRepository->getNewOrderId('IN10');
+                $create    = [
+                    'uid'          => $online['uid'],
+                    'platform_no'  => $orderId,
+                    'account_type' => 3,//账号类型1银行卡2支付宝3微信
+                    'user_name'    => $certification['user_name'],
+                    'mobile'       => $certification['mobile'],
+                    'user_card'    => $certification['user_card'],
+                    'pension'      => $pension,
+                    'order_type'   => 2,
+                    'out_trade_no' => $online['order_sn']
+                ];
+                $test_user = Db::name('user')->where('uid', $online['uid'])->value('test_user');
+                $check     = Db::name("gzc_logs")->where("out_trade_no", $online['order_sn'])->where("order_type", 2)->count();
+                if ($test_user == 0 && $check <= 0) {
+                    $OrderGzcRepository->create($create);
+                }
+                $order                  = StoreOrder::getInstance()->find($online['order_id']);
+                $order->gzc             = 1;
+                $order->save();
+            });
+        }
+
+
+
+        // 普通订单（红包，积分，京东，佣金，复购金，养老金，贡献值）
+        $cursor = Db::table('rrx_order_huafei')->where('status', 3)->where('bill_status', 0)->cursor();
+        $StoreOrderStatusRepository = app()->make(StoreOrderStatusRepository::class);
+        $OrderMerchantRepository    = app()->make(OrderMerchantRepository::class);
+        $OrderGzcRepository         = app()->make(OrderGzcRepository::class);
+        foreach ($cursor as $online) {
+            if (time() < strtotime($online['finish_time']) + 3600 * 24) {
+                Log::info('还没有话费到账后' . $timeLimit . '天');
+                continue;
+            }
+            
+            Db::transaction(function () use ($online) {
+                //订单状态改为已结算
+                Db::name('rrx_order_huafei')
+                ->where('status', 3)->where('bill_status', 0)
+                ->where('order_sn', $online['order_sn'])
+                ->update([
+                    'bill_status'=> 1,
+                    'bill_create_time' => time()
+                ]);
+
+                // 结算积分
+                $user_sign_score_list = Db::name('user_sign_score')
+                    ->where('status', -1)
+                    ->where('order_id', $online['order_sn'])
+                    ->whereIn('type', [1, 2])
+                    ->select()
+                    ->toArray();
+                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('status', -1)
+                        ->where('id', $user_sign_score['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_sn'])
+                    ->whereIn('type', [1, 2])
+                    ->select()
+                    ->toArray();
+                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('status', -1)
+                        ->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_sn'])
+                    ->whereIn('type', [1, 2])
+                    ->select()
+                    ->toArray();
+                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('status', -1)
+                        ->where('id', $user_sign_gongxian['id'])
+                        ->update([
+                            'status'          => 1,
+                            'settlement_time' => date('Y-m-d H:i:s')
+                        ]);
+                }
+
+            });
+        }
+
+
+    }
+    
+
+
+    /**
+     * 在线支付公证处IN10入账 （红包，积分，京东，佣金，复购金，养老金，贡献值）
      * @param $nowTime
      * @param $timeLimit
      * author: php迷途小书童
@@ -170,11 +340,8 @@ class PensionTasks extends Command
      */
     public function doOnlineOrderGzc($timeLimit)
     {
-        $cursor                     = Db::table('rrx_store_order')
-            ->where('paid', 1)
-            ->where('gzc', 0)
-            ->where('pay_type', 'in', '0,1,2,4')
-            ->cursor();
+         // 普通订单
+        $cursor = Db::table('rrx_store_order')->where('paid', 1)->where('gzc', 0)->where('pay_type', 'in', '0,1,2,4')->cursor();
         $StoreOrderStatusRepository = app()->make(StoreOrderStatusRepository::class);
         $OrderMerchantRepository    = app()->make(OrderMerchantRepository::class);
         $OrderGzcRepository         = app()->make(OrderGzcRepository::class);
@@ -251,11 +418,9 @@ class PensionTasks extends Command
 
             });
         }
-        $cursor                     = Db::table('rrx_store_order')
-            ->where('paid', 1)
-            ->where('is_settlement', 0)
-            ->where('pay_type', 'in', '0,1,2,4')
-            ->cursor();
+
+        // 普通订单（红包，积分，京东，佣金，复购金，养老金，贡献值）
+        $cursor = Db::table('rrx_store_order')->where('paid', 1)->where('is_settlement', 0)->where('pay_type', 'in', '0,1,2,4')->cursor();
         $StoreOrderStatusRepository = app()->make(StoreOrderStatusRepository::class);
         $OrderMerchantRepository    = app()->make(OrderMerchantRepository::class);
         $OrderGzcRepository         = app()->make(OrderGzcRepository::class);
@@ -281,7 +446,7 @@ class PensionTasks extends Command
 
             $StoreOrderRepository = app()->make(StoreOrderRepository::class);
             Db::transaction(function () use ($online, $StoreOrderRepository) {
-                $order                  = StoreOrder::getInstance()->find($online['order_id']);
+                $order = StoreOrder::getInstance()->find($online['order_id']);
                 $order->is_settlement   = 1;
                 $order->settlement_time = date('Y-m-d H:i:s');
                 $order->save();
@@ -307,6 +472,101 @@ class PensionTasks extends Command
                             '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'])
+                    ->whereIn('type', [1, 2])
+                    ->select()
+                    ->toArray();
+                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('status', -1)
+                        ->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'])
+                    ->whereIn('type', [1, 2])
+                    ->select()
+                    ->toArray();
+                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('status', -1)
+                        ->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'])
+                    ->whereIn('type', [1, 2])
+                    ->select()
+                    ->toArray();
+                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('status', -1)
+                        ->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'])
+                    ->whereIn('type', [1, 2])
+                    ->select()
+                    ->toArray();
+                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('status', -1)
+                        ->where('id', $user_sign_gongxian['id'])
+                        ->update([
+                            'status'          => 1,
+                            'settlement_time' => date('Y-m-d H:i:s')
+                        ]);
+                }
+
+                
+                // 结算佣金
                 $user_bill_list = Db::name('user_bill')
                     ->where('status', 0)
                     ->where('commission_type','<>', 5)
@@ -350,6 +610,7 @@ class PensionTasks extends Command
                             ]);
                     }
                 }
+                //按角色结算
                 $StoreOrderRepository->close_order($online['order_id']);
             });
         }