Sfoglia il codice sorgente

修改定时任务处理命令

Devin 1 mese fa
parent
commit
205a94d0b0

+ 1 - 4
application/common/command/BiddingDeal.php

@@ -22,7 +22,7 @@ class BiddingDeal extends Command
     {
         $output->writeln("bidding:deal:");
         //超时确定接单处理
-//        $this->confirmDemandTimeoutDeal($input, $output);
+        $this->confirmDemandTimeoutDeal($input, $output);
         //开标处理
         $this->openBiddingDeal($input, $output);
     }
@@ -42,9 +42,6 @@ class BiddingDeal extends Command
             $query->order('createtime asc');
         }])->where(['status' => DemandService::STATUS_BIDDING])->chunk(100, function ($list) use ($open_bidding_time, $EasyWeChatService) {
             foreach ($list as $item) {
-                if ($item->id != 30) {
-                    continue;
-                }
                 $bidList = $item->demandBiddings;
                 foreach ($bidList as $bid) {
                     //排除掉不符合中标状态的

+ 3 - 6
application/common/command/DemandDeal.php

@@ -24,7 +24,7 @@ class DemandDeal extends Command
     protected function execute(Input $input, Output $output)
     {
         $output->writeln("bidding:deal:");
-//        $this->confirmReceiptTimeoutDeal($input, $output);
+        $this->confirmReceiptTimeoutDeal($input, $output);
         $this->demandProfitUnfreezeDeal($input, $output);
     }
 
@@ -50,12 +50,12 @@ class DemandDeal extends Command
                             $item->status = DemandService::STATUS_FINISHED;
                             $item->settle_status = DemandService::$Common::ONGOING;
                             $saveRes = $item->save();
-                            if(!$saveRes) {
+                            if (!$saveRes) {
                                 exception('更新结算状态失败');
                             }
                             //订单状态改为已完成
                             $upRes = OrderService::where(['parent_order_no' => $item->parent_order_no])->update(['order_status' => OrderService::ORDER_STATUS_FINISHED]);
-                            if(!$upRes) {
+                            if (!$upRes) {
                                 exception('更新订单状态失败');
                             }
                         }
@@ -82,9 +82,6 @@ class DemandDeal extends Command
         DemandService::where($where)->with(['orders', 'winBidding'])->chunk(100, function ($demandList) {
             foreach ($demandList as $item) {
                 try {
-                    if ($item->id != 27) {
-                        continue;
-                    }
                     Db::transaction(function () use ($item) {
                         //根据订单列表查找冻结金额日志,根据冻结日志解冻冻结金额到余额
                         $userId = $item->winBidding->user_id;