计划任务-测试独立的分红脚本

app/command/GzcAddByBillCommand.php

@@ -4,9 +4,15 @@ namespace app\command;
 
 use app\common\model\user\UserCertification;
 use app\common\repositories\merchant\order\OrderGzcRepository;
+use app\common\repositories\merchant\order\OrderMerchantRepository;
+use app\common\repositories\store\order\StoreOrderRepository;
+use app\common\repositories\user\UserRepository;
 use think\console\Command;
 use think\console\Input;
 use think\console\Output;
+use think\db\exception\DataNotFoundException;
+use think\db\exception\DbException;
+use think\db\exception\ModelNotFoundException;
 use think\facade\Db;
 use think\facade\Log;
 
@@ -38,18 +44,31 @@ class GzcAddByBillCommand extends Command
      */
     public function billGzcAdd($nowTime)
     {
-        /** @var OrderGzcRepository $OrderGzcRepository */
-        $OrderGzcRepository = app()->make(OrderGzcRepository::class);
+        $OrderGzcRepository      = app()->make(OrderGzcRepository::class);
+        $OrderMerchantRepository = app()->make(OrderMerchantRepository::class);
+        $StoreOrderRepository    = app()->make(StoreOrderRepository::class);
+        $testUserIdList = [];
+        /** @var UserRepository $userRepository */
+        $userRepository = app()->make(UserRepository::class);
+        try {
+            $userIdData = $userRepository->selectWhere(['test_user' => 1], 'uid')->toArray();
+            if (!empty($userIdData)) {
+                $testUserIdList = array_column($userIdData, 'uid');
+            }
+        } catch (DataNotFoundException|ModelNotFoundException|DbException $e) {
+
+        }
+
         $cursor = Db::name('user_bill')
             ->where('status', 1)
             ->where('is_gzc', 0)
             ->where('commission_type', 5)
-            ->select()
-            ->toArray();
-        if ($cursor) {
+            ->whereNotIn('uid', $testUserIdList)
+            ->select()->toArray();
+        if($cursor) {
             foreach ($cursor as $bill) {
                 $type_shop = $bill['type_shop'] ?? 0;
-                switch ($type_shop) {
+                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;
@@ -57,7 +76,7 @@ class GzcAddByBillCommand extends Command
                         $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();
+                        $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();
@@ -80,6 +99,14 @@ class GzcAddByBillCommand extends Command
                     case "9":
                         $online = Db::table('rrx_order_huafei')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->find();
                         break;
+                    case "10":
+                        $online = Db::table('rrx_order_merchant')
+                            ->where('uid', $bill['uid'])
+                            ->where('out_trade_no', $bill['order_sn'])
+                            ->where('paid', 1)
+                            ->where('status', 1)
+                            ->find();
+                        break;
                     default:
                         $online = Db::table('rrx_store_order')->where('uid', $bill['uid'])->where('order_sn', $bill['order_sn'])->where('paid', 1)->find();
                 }
@@ -101,31 +128,29 @@ class GzcAddByBillCommand extends Command
                 }
 
                 //新增入账明细记录
-                list($msec, $sec) = explode(' ', microtime());
-                $msectime = number_format((floatval($msec) + floatval($sec)) * 1000, 0, '', '');
-                $orderId = 'IN10' . $msectime . mt_rand(10000, max(intval($msec * 10000) + 10000, 98369));
-                $create = [
-                    'uid' => $online['uid'],
-                    'platform_no' => $orderId,
+                $orderId   = $OrderMerchantRepository->getNewOrderId('IN10');
+                $create    = [
+                    'uid'          => $online['uid'],
+                    'platform_no'  => $orderId,
                     'account_type' => 1,
-                    'user_name' => $certification['user_name'],
-                    'mobile' => $certification['mobile'],
-                    'user_card' => $certification['user_card'],
-                    'pension' => $pension,
-                    'order_type' => $type_shop,
+                    'user_name'    => $certification['user_name'],
+                    'mobile'       => $certification['mobile'],
+                    'user_card'    => $certification['user_card'],
+                    'pension'      => $pension,
+                    'order_type'   => $type_shop,
                     'out_trade_no' => $online['order_sn'],
-                    'link_id' => $bill['bill_id']
+                    '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['bill_id'])->where("order_type", $type_shop)->count();
+                $check     = Db::name("gzc_logs")->where("link_id", $bill['bill_id'])->where("order_type", $type_shop)->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,
-                            'gzc' => 1
+                            'is_gzc'          => 1,
+                            'gzc'             => 1
                         ]);
                 }
             }