话费订单养老金入账

app/command/PensionTasks.php

@@ -55,6 +55,7 @@ class PensionTasks extends Command
             $this->doThridTaobaoOrderGzc($nowTime, $timeLimit = 2);
             $this->doThridVipOrderGzc($nowTime, $timeLimit = 2);
             $this->doThridDyOrderGzc($nowTime, $timeLimit = 2);
+            $this->doThridHfOrderGzc($nowTime, $timeLimit = 2);
             //升级
 //            $this -> doUpgrade();
         } catch (\Throwable $e) {
@@ -541,6 +542,60 @@ class PensionTasks extends Command
         }
     }
 
+
+
+    /**
+     * 第三方订单话费IN10入账
+     * @param $nowTime
+     * @param $timeLimit
+     * author: php迷途小书童
+     * created: 2021/3/20 9:26
+     */
+    public function doThridHfOrderGzc($nowTime, $timeLimit)
+    {
+        $cursor = Db::table('rrx_order_huafei')
+        ->where('gzc', 0)
+        ->where('bill_status', 1)
+        ->where('commission', '>', 0)
+        ->whereTime('bill_end_time', '<', $nowTime - bcmul((string)$timeLimit, (string)86400))
+        ->cursor();
+        $ProductRepository       = app()->make(ProductRepository::class);
+        $OrderGzcRepository      = app()->make(OrderGzcRepository::class);
+        $OrderMerchantRepository = app()->make(OrderMerchantRepository::class);
+        foreach ($cursor as $thrid) {
+            $uid = $thrid['uid'];
+            if (!$uid)
+                continue;
+            $certification = UserCertification::getInstance()->where('uid', $uid)->find();
+            if (!$certification) {
+                Log::info('用户ID' . $uid . '未实名认证');
+                continue;
+            }
+            $pension = $ProductRepository->yanglaojin(0, sprintf('%.2f', $thrid['commission']));
+            Db::transaction(function () use ($uid, $certification, $thrid, $pension, $OrderGzcRepository, $OrderMerchantRepository) {
+                //新增入账明细记录
+                $orderId   = $OrderMerchantRepository->getNewOrderId('IN10');
+                $create    = [
+                    'uid'          => $uid,
+                    'platform_no'  => $orderId,
+                    'user_name'    => $certification['user_name'],
+                    'mobile'       => $certification['mobile'],
+                    'user_card'    => $certification['user_card'],
+                    'pension'      => $pension,
+                    'order_type'   => 6,
+                    'out_trade_no' => $thrid['order_sn']
+                ];
+                $test_user = Db::name('user')->where('uid', $uid)->value('test_user');
+                if ($test_user == 0) {
+                    $OrderGzcRepository->create($create);
+                }
+                Db::table('rrx_order_huafei')->update(['gzc' => 1, 'order_tb_id' => $thrid['order_tb_id']]);
+            });
+        }
+    }
+
+
+
     /**
      * 第三方订单淘宝IN10入账
      * @param $nowTime