// +---------------------------------------------------------------------- namespace app\jobs; use app\services\activity\live\LiveGoodsServices; use app\services\activity\live\LiveRoomServices; use crmeb\basic\BaseJobs; use crmeb\traits\QueueTrait; use think\facade\Log; class LiveJob extends BaseJobs { use QueueTrait; /** * 执行同步数据后 * @param $order * @return bool */ public function doJob() { //更新直播商品状态 try { /** @var LiveGoodsServices $liveGoods */ $liveGoods = app()->make(LiveGoodsServices::class); $liveGoods->syncGoodStatus(true); } catch (\Throwable $e) { Log::error('更新直播商品状态失败,失败原因:' . $e->getMessage()); } //更新直播间状态 try { /** @var LiveRoomServices $liveRoom */ $liveRoom = app()->make(LiveRoomServices::class); $liveRoom->syncRoomStatus(true); } catch (\Throwable $e) { Log::error('更新直播间状态失败,失败原因:' . $e->getMessage()); } return true; } }