测试完成

app/Common/Library/Easemob.php

@@ -62,6 +62,7 @@ class Easemob {
         ];
 
         $rs = $message->push_sync($uid,$pushMessage);
+        return $rs;
         //dump($rs);
     }
 

app/Console/Commands/Plantask.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+
+use App\Common\Library\Easemob;
+use Illuminate\Support\Facades\DB;
+use App\Jobs\EasemobJob;
+
+class Plantask extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'command:Plantask';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Command description';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return int
+     */
+    public function handle()
+    {
+        $list = DB::table('mt_message')->where('dispatch_status',0)->orderBy('id','asc')->get()->toArray();
+        //dd($list);
+        //
+        if(!empty($list)){
+            foreach($list as $key => $val){
+                $msg_id = $val->id;
+                dispatch((new EasemobJob($msg_id))->delay(0));//加入队列
+            }
+        }
+
+        //更新
+        $ids = array_column($list,'id');
+
+        $update = [
+            'dispatch_status' => 1,
+        ];
+
+        DB::table('mt_message')->whereIn('id',$ids)->update($update);
+
+        return 0;
+    }
+}

app/Console/Kernel.php

@@ -25,6 +25,7 @@ class Kernel extends ConsoleKernel
     protected function schedule(Schedule $schedule)
     {
         // $schedule->command('inspire')->hourly();
+        $schedule->command('command:Plantask')->everyMinute();// 每分钟定时处理
     }
 
     /**

app/Http/Controllers/Controller.php

@@ -6,14 +6,45 @@ use Illuminate\Foundation\Auth\Access\AuthorizesRequests;
 use Illuminate\Foundation\Bus\DispatchesJobs;
 use Illuminate\Foundation\Validation\ValidatesRequests;
 use Illuminate\Routing\Controller as BaseController;
+
+//
 use App\Common\Library\Easemob;
+use Illuminate\Support\Facades\DB;
+use App\Jobs\EasemobJob;
+
 class Controller extends BaseController
 {
     use AuthorizesRequests, DispatchesJobs, ValidatesRequests;
 
     public function test(){
-        $easemob = new Easemob();
-        $rs = $easemob->push_text(1018,'标题','内容');
-        dd($rs);
+        /*$easemob = new Easemob();
+        $rs = $easemob->push_text(1009,'标题','内容');
+        dd($rs);*/
+        (new EasemobJob(1))->handle();
+    }
+
+
+
+
+    public function plantask(){
+
+        $list = DB::table('mt_message')->where('dispatch_status',0)->orderBy('id','asc')->get()->toArray();
+        //dd($list);
+        //
+        if(!empty($list)){
+            foreach($list as $key => $val){
+                $msg_id = $val->id;
+                dispatch((new EasemobJob($msg_id))->delay(0));//加入队列
+            }
+        }
+
+        //更新
+        $ids = array_column($list,'id');
+
+        $update = [
+            'dispatch_status' => 1,
+        ];
+
+        DB::table('mt_message')->whereIn('id',$ids)->update($update);
     }
 }

app/Jobs/EasemobJob.php

@@ -0,0 +1,50 @@
+<?php
+
+namespace App\Jobs;
+
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+
+use Illuminate\Support\Facades\DB;
+use App\Common\Library\Easemob;
+use Illuminate\Support\Facades\Log;
+
+class EasemobJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    protected $msgid;
+
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+    public function __construct($msgid)
+    {
+        //
+        $this->msgid = $msgid;
+        Log::info(date('Y-m-d H:i:d').':'.$msgid);
+
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+        //
+        $info = DB::table('mt_message')->where('id',$this->msgid)->first();
+
+        $easemob = new Easemob();
+        $rs = $easemob->push_text($info->user_id,$info->title,$info->content);
+        /*echo '<pre>';
+        var_dump($rs);*/
+
+    }
+}

config/app.php

@@ -67,7 +67,7 @@ return [
     |
     */
 
-    'timezone' => 'UTC',
+    'timezone' => 'Asia/Shanghai',
 
     /*
     |--------------------------------------------------------------------------

routes/web.php

@@ -17,3 +17,4 @@ Route::get('/', function () {
     return view('welcome');
 });
 Route::get('/test', [\App\Http\Controllers\Controller::class,'test']);
+Route::get('/plantask', [\App\Http\Controllers\Controller::class,'plantask']);

vendor/maniac/easemob-php/src/Push.php

@@ -39,7 +39,7 @@ final class Push
         $header['Content-Type'] =  'application/json';
 
         $resp = Http::post($uri, $body, $header);
-dd($resp);
+        //dd($resp);
         if (!$resp->ok()) {
             return \Easemob\error($resp);
         }

vendor/symfony/var-dumper/Resources/functions/dump.php

@@ -45,6 +45,6 @@ if (!function_exists('dd')) {
             VarDumper::dump($v);
         }
 
-        exit(1);
+        //exit(1);
     }
 }