空投

application/api/command/Task.php

@@ -29,31 +29,32 @@ class Task extends Command
         $output->writeln('定时任务开始执行：' . date('Y-m-d H:i:s', time()));
 
         /*** 发放分红收益 ***/
-        $begin_usdt = microtime(TRUE);
         $output->writeln("开始发放加权分红:");
-
-        $count = $this->reset_user_pledge();
-
+        $i = 0;
+        $count = $this->reset_user_pledge($i);
         $output->writeln('定时任务执行结束，总执行：' .  $count  . '个');
     }
 
 
 
-    public static function reset_user_pledge(){
+    public  function reset_user_pledge($i){
 
         $productOrder =  new ProductOrder(); //Loader::model('ProductOrder');
-        $count = 0;
-        $num = 6;
-        $ids = 14;
-
-        UserModel::chunk(500, function($items) use ($count,$num , $ids, $productOrder) {
+        $num = 6; //空投数量
+        $ids = 14; //空投产品
+        UserModel::chunk(500, function($items) use ($i,$num , $ids, $productOrder) {
             foreach ($items as $item) {
-                // 处理每个数据项
-                $productOrder::setPopularNoAreaOrder($num, 0, 0, $ids, $item->id, 5);
-                $count ++;
+                // 判断空投是否只够6个
+                $res = $productOrder::where('user_id', $item->id)->where('product_id', $ids)->where('type_id', 5)->count();
+                if($res < 6){
+                    $num = $num -  $res;
+                    $productOrder::setPopularNoAreaOrder($num, 0, 0, $ids, $item->id, 5);
+                    $i ++;
+                }
+             
             }
         });
         
-        return $count;
+        return $i;
     }
 }

application/command.php

@@ -22,5 +22,5 @@ return [
     'app\api\command\RechargeTxHashVerify',
     'app\api\command\SendBonusRewards', //奖金
     'app\api\command\SenAirdrop', //空投
-    'app\admin\command\Task',
+    'app\api\command\Task',
 ];