|
|
|
@ -69,6 +69,8 @@ class CreationTaskService extends BaseService |
|
|
|
try { |
|
|
|
$this->dao->update(['id' => $params['id']], $params); |
|
|
|
Db::commit(); |
|
|
|
//投递消息
|
|
|
|
Redis::send('creation-task', ['task_id' => $params['id']]); |
|
|
|
} catch (\Exception $exception) { |
|
|
|
Db::rollback(); |
|
|
|
throw new ApiException($exception->getMessage()); |
|
|
|
|