gx创建作者

@@ -12,6 +12,7 @@ namespace App\Console\Commands\AiBlog;
 use App\Models\Ai\AiBlog;
 use App\Models\Ai\AiBlog;
 use App\Models\Ai\AiBlogAuthor;
 use App\Models\Ai\AiBlogAuthor;
 use App\Models\Project\ProjectAiSetting;
 use App\Models\Project\ProjectAiSetting;
+use App\Models\RouteMap\RouteMap;
 use App\Services\AiBlogService;
 use App\Services\AiBlogService;
 use App\Services\ProjectServer;
 use App\Services\ProjectServer;
 use Illuminate\Console\Command;
 use Illuminate\Console\Command;
@@ -63,7 +64,17 @@ class AiBlogTask extends Command
             //保存当前项目ai_blog数据
             //保存当前项目ai_blog数据
             ProjectServer::useProject($info['project_id']);
             ProjectServer::useProject($info['project_id']);
             $aiBlogModel = new AiBlog();
             $aiBlogModel = new AiBlog();
-            $aiBlogModel->edit(['new_title'=>$result['data']['title'], 'image'=>$result['data']['thumb'], 'text'=>$result['data']['section'], 'author_id'=>$result['data']['author_id'], 'status'=>2], ['task_id'=>$info['task_id']]);
+            $aiBlogInfo = $aiBlogModel->read(['task_id'=>$info['task_id']],['id']);
+            if($aiBlogInfo === false){
+                $aiBlogTaskModel->edit(['status'=>2],['id'=>$info['id']]);
+                continue;
+            }
+            //拿到返回的路由查看是否重复
+            $route = RouteMap::setRoute($result['data']['url'], RouteMap::SOURCE_AI_BLOG, $aiBlogInfo['id'], $this->user['project_id']);
+            if($route != $result['data']['url']){
+                $aiBlogService->updateDetail(['route'=>$this->param['route']]);
+            }
+            $aiBlogModel->edit(['new_title'=>$result['data']['title'], 'image'=>$result['data']['thumb'], 'text'=>$result['data']['section'], 'author_id'=>$result['data']['author_id'], 'route'=>$route ,'status'=>2], ['task_id'=>$info['task_id']]);
             $this->updateAiBlogAuthor($aiSettingInfo,$result['data']['author_id']);
             $this->updateAiBlogAuthor($aiSettingInfo,$result['data']['author_id']);
             DB::disconnect('custom_mysql');
             DB::disconnect('custom_mysql');
             //修改任务状态
             //修改任务状态

@@ -92,11 +92,9 @@ class AiBlogController extends BaseController
         $this->request->validate([
         $this->request->validate([
             'keyword'=>['required'],
             'keyword'=>['required'],
             'type'=>['required'],
             'type'=>['required'],
-            'route'=>['required']
         ],[
         ],[
             'keyword.required' => '关键字不能为空',
             'keyword.required' => '关键字不能为空',
             'type.required' => '场景不能为空',
             'type.required' => '场景不能为空',
-            'route.required' => '路由不能为空',
         ]);
         ]);
         //获取当前项目的ai_blog设置
         //获取当前项目的ai_blog设置
         $result = $aiBlogLogic->sendTask();
         $result = $aiBlogLogic->sendTask();
@@ -135,8 +133,8 @@ class AiBlogController extends BaseController
     }
     }
 
 
     /**
     /**
-     * @remark :获取详情数据
-     * @name   :getAuthorInfo
+     * @remark :编辑详情数据
+     * @name   :saveBlogAuthor
      * @author :lyh
      * @author :lyh
      * @method :post
      * @method :post
      * @time   :2025/2/21 13:54
      * @time   :2025/2/21 13:54

@@ -38,9 +38,8 @@ class AiBlogLogic extends BaseLogic
             $aiBlogService = new AiBlogService();
             $aiBlogService = new AiBlogService();
             $aiBlogService->mch_id = $aiSettingInfo['mch_id'];
             $aiBlogService->mch_id = $aiSettingInfo['mch_id'];
             $aiBlogService->key = $aiSettingInfo['key'];
             $aiBlogService->key = $aiSettingInfo['key'];
-            $aiBlogService->route = $this->param['route'];
             $aiBlogService->author_id = $this->param['author_id'];
             $aiBlogService->author_id = $this->param['author_id'];
-            $aiBlogService->updateDetail($this->param['title'],$this->param['image']);
+            $aiBlogService->updateDetail(['title'=>$this->param['title'],'thumb'=>$this->param['image'],'route'=>$this->param['route'],'author_id'=>$this->param['author_id']]);
         }catch (\Exception $e){
         }catch (\Exception $e){
             $this->fail('保存失败，请联系管理员');
             $this->fail('保存失败，请联系管理员');
         }
         }
@@ -101,10 +100,8 @@ class AiBlogLogic extends BaseLogic
             $aiBlogTaskModel = new AiBlogTask();
             $aiBlogTaskModel = new AiBlogTask();
             $aiBlogTaskModel->addReturnId(['project_id'=>$this->user['project_id'],'task_id'=>$result['data']['task_id'],'status'=>$result['data']['status']]);
             $aiBlogTaskModel->addReturnId(['project_id'=>$this->user['project_id'],'task_id'=>$result['data']['task_id'],'status'=>$result['data']['status']]);
             $aiBlogModel = new AiBlog();
             $aiBlogModel = new AiBlog();
-            $aiBlogId = $aiBlogModel->addReturnId(['keyword'=>$this->param['keyword'], 'status'=>$result['data']['status'], 'task_id'=>$result['data']['task_id'],'project_id'=>$this->user['project_id'],
+            $aiBlogModel->addReturnId(['keyword'=>$this->param['keyword'], 'status'=>$result['data']['status'], 'task_id'=>$result['data']['task_id'],'project_id'=>$this->user['project_id'],
             ]);
             ]);
-            $route = RouteMap::setRoute($aiBlogService->route, RouteMap::SOURCE_AI_BLOG, $aiBlogId, $this->user['project_id']);
-            $aiBlogModel->edit(['route'=>$route],['id'=>$aiBlogId]);
         }
         }
         return $this->success();
         return $this->success();
     }
     }

@@ -20,7 +20,6 @@ class AiBlogService
     public $route = '';//回调地址
     public $route = '';//回调地址
 
 
     public $task_id = '';//任务id
     public $task_id = '';//任务id
-
     public $author_id = '';//作者id
     public $author_id = '';//作者id
     /**
     /**
      * @remark :创建项目
      * @remark :创建项目
@@ -189,17 +188,11 @@ class AiBlogService
      * @author :lyh
      * @author :lyh
      * @method :post
      * @method :post
      * @time   :2025/2/21 14:38
      * @time   :2025/2/21 14:38
+     * @param  :title , thumb , route , task_id
      */
      */
-    public function updateDetail($title,$image){
+    public function updateDetail($param){
         $request_url = $this->url.'api/result/save';
         $request_url = $this->url.'api/result/save';
-        $param = [
-            'mch_id'=>$this->mch_id,
-            'author_id'=>$this->author_id,
-            'route'=>$this->route,
-            'author_id'=>$this->author_id,
-            'title'=>$title,
-            'thumb'=>$image,
-        ];
+        $param['mch_id'] = $this->mch_id;
         $this->sign = $this->generateSign($param,$this->key);
         $this->sign = $this->generateSign($param,$this->key);
         $param['sign'] = $this->sign;
         $param['sign'] = $this->sign;
         $result = http_post($request_url,json_encode($param,true));
         $result = http_post($request_url,json_encode($param,true));