充值

app/Http/Controllers/Controller.php

@@ -13,6 +13,7 @@ use App\Jobs\AudioJob;
 use App\Jobs\VideoJob;
 use App\Jobs\TypingJob;
 use App\Jobs\GiftJob;
+use App\Jobs\RechargeJob;
 
 class Controller extends BaseController
 {
@@ -22,7 +23,7 @@ class Controller extends BaseController
         /*$easemob = new Easemob();
         $rs = $easemob->push_text(1009,'标题','内容');
         dd($rs);*/
-        (new GiftJob(3))->handle();
+        (new RechargeJob(1))->handle();
     }
 
 
@@ -112,7 +113,7 @@ class Controller extends BaseController
     }*/
 
     //gift
-    public function plantask(){
+    /*public function plantask(){
         $map = [
             ['plantask_status', '=' ,0]
         ];
@@ -135,5 +136,33 @@ class Controller extends BaseController
             DB::table('mt_gift_user_typing')->whereIn('id',$ids)->update($update);
         }
 
+    }*/
+
+    //recharge
+    public function plantask(){
+        $map = [
+            ['table_name'      ,'=', 'gold_recharge'],
+            ['order_status'    ,'=', 1],
+            ['plantask_status' ,'=', 0],
+        ];
+        $list = DB::table('mt_pay_order')->where($map)->orderBy('id','asc')->get()->toArray();
+        //dd($list);
+
+        if(!empty($list)){
+            foreach($list as $key => $val){
+                $msg_id = $val->id;
+                dispatch((new RechargeJob($msg_id))->delay(0));//加入队列
+            }
+
+            //更新
+            $ids = array_column($list,'id');
+
+            $update = [
+                'plantask_status' => 1,
+            ];
+
+            DB::table('mt_pay_order')->whereIn('id',$ids)->update($update);
+        }
+
     }
 }