问一个队列中SQL插入不成功,大家帮忙看一下什么问题?谢谢
控制器中
// 推送任务到队列
dispatch(new SignData($user));
在队列中dump $user
显示数据
user: {
today_ranking: 25,
user_id: 300824,
day: 14,
point: 5,
extra_point: 1,
sign_date: "2021-10-09 00:00:00",
continuation_date: 1,
sum_point: 2240
测试过此SQL在其它地方是可以写入数据的,麻烦大家帮忙检查一下,谢谢!
<?php
namespace App\Jobs;
use App\Models\Sign;
use App\Services\SignDataService;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use App\Services\SignService;
use Auth;
use Illuminate\Support\Facades\DB;
class SignData implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public $user;
public function __construct($user)
{
$this->user = $user;
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
$user = $this->user;
DB::connection('mysql_wx')->table('yt_user_sign')->insert($user);
}
}
horizon中的执行通过,无错误,
显示
{
user: {
today_ranking: 26,
user_id: 300824,
day: 14,
point: 4,
extra_point: 1,
sign_date: "2021-10-09 00:00:00",
continuation_date: 1,
sum_point: 2239
},
job: null,
connection: null,
queue: null,
chainConnection: null,
chainQueue: null,
delay: null,
middleware: [
],
chained: [
]
}
推荐文章: