From 76a52dc9d9351d4379729a2458c6a9ccc7dbde44 Mon Sep 17 00:00:00 2001
From: yaooo <272523191@qq.com>
Date: Sat, 14 Oct 2023 17:24:49 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=98=9F=E7=81=AB=E8=AE=A4?=
 =?UTF-8?q?=E7=9F=A5=E6=A8=A1=E5=9E=8B=E5=88=86=E6=9E=90=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/common/model/informationg/UserInformationg.php | 7 +++++--
 app/job/AiAianalyse.php                            | 4 +---
 2 files changed, 6 insertions(+), 5 deletions(-)

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();