diff --git a/app/common/model/informationg/UserInformationg.php b/app/common/model/informationg/UserInformationg.php index 59b4b8926..731ab1c8e 100644 --- a/app/common/model/informationg/UserInformationg.php +++ b/app/common/model/informationg/UserInformationg.php @@ -121,8 +121,11 @@ class UserInformationg extends BaseModel 'status' => 1, 'information_id' => $id, ]; - queue(AiAianalyse::class, $data); - return UserInformationgDemand::create($data); + $res = UserInformationgDemand::create($data); + if ($res) { + queue(AiAianalyse::class, $data); + } + return $res; } public static function details($id) diff --git a/app/job/AiAianalyse.php b/app/job/AiAianalyse.php index 36ca2d21e..78a043885 100644 --- a/app/job/AiAianalyse.php +++ b/app/job/AiAianalyse.php @@ -80,14 +80,12 @@ class AiAianalyse break; } } - $update_data = [ 'ai_aianalyse' => $answer, 'update_time' => time(), ]; unset($data['data'], $data['data_field']); - $id = Db::name('user_informationg_demand')->where($data)->fetchSql(false)->value('id'); - Db::name('user_informationg_demand')->where('id', $id)->fetchSql(false)->update($update_data); + Db::name('user_informationg_demand')->where($data)->fetchSql(false)->update($update_data); } } catch (\Exception $e) {} $job->delete();