gx异步执行更新列表页

@@ -9,9 +9,69 @@
 
 namespace App\Http\Controllers\Bside\Ai;
 
+use App\Enums\Common\Code;
 use App\Http\Controllers\Bside\BaseController;
+use App\Http\Logic\Bside\Ai\AiVideoLogic;
+use App\Models\Ai\AiVideo;
 
 class AiVideoController extends BaseController
 {
+    /**
+     * @remark :获取aiVideo列表
+     * @name   :lists
+     * @author :lyh
+     * @method :post
+     * @time   :2025/3/5 14:12
+     */
+    public function lists(AiVideo $aiVideo){
+        $lists = $aiVideo->lists($this->map,$this->page,$this->row,'id',['id','keyword','new_title','route','image','task_id','status','created_at','updated_at']);
+        if(!empty($lists) && !empty($lists['list'])){
+            foreach ($lists['list'] as $k => $v){
+                $v['image'] = getImageUrl($v['image']);
+                if(!empty($v['route'])){
+                    $v['route'] = $this->user['test_domain'] . 'video/' . $v['route'];
+                }
+                $lists['list'][$k] = $v;
+            }
+        }
+        $this->response('success',Code::SUCCESS,$lists);
+    }
+
+    /**
+     * @remark :获取详情
+     * @name   :getInfo
+     * @author :lyh
+     * @method :post
+     * @time   :2025/3/5 14:22
+     */
+    public function getInfo(AiVideo $aiVideo){
+        $this->request->validate([
+            'id'=>['required'],
+        ],[
+            'id.required' => '主键不能为空',
+        ]);
+        $info = $aiVideo->read(['id'=>$this->param['id']]);
+        $info['image'] = getImageUrl($info['image']);
+        $this->response('success',Code::SUCCESS,$info);
+    }
 
+    /**
+     * @remark :发布任务
+     * @name   :sendTask
+     * @author :lyh
+     * @method :post
+     * @time   :2025/3/5 14:29
+     */
+    public function sendTask(AiVideoLogic $aiVideoLogic){
+        $this->request->validate([
+            'keyword'=>['required'],
+            'type'=>['required'],
+        ],[
+            'keyword.required' => '关键字不能为空',
+            'type.required' => '场景不能为空',
+        ]);
+        //获取当前项目的ai_blog设置
+        $result = $aiVideoLogic->sendTask();
+        $this->response('success',Code::SUCCESS,$result);
+    }
 }

+<?php
+
+namespace App\Http\Logic\Bside\Ai;
+
+use App\Helper\Translate;
+use App\Http\Logic\Bside\BaseLogic;
+use App\Models\Ai\AiBlogAuthor;
+use App\Models\Ai\AiVideo;
+use App\Models\Project\AiBlogTask;
+use App\Models\Project\ProjectAiSetting;
+use App\Models\RouteMap\RouteMap;
+use App\Services\AiBlogService;
+
+/**
+ * @remark :视频模块
+ * @name   :AiVideoLogic
+ * @author :lyh
+ * @method :post
+ * @time   :2025/3/5 14:11
+ */
+class AiVideoLogic extends BaseLogic
+{
+    public function __construct()
+    {
+        parent::__construct();
+        $this->param = $this->requestAll;
+        $this->model = new AiVideo();
+    }
+
+    /**
+     * @remark :获取配置信息
+     * @name   :getProjectAiSetting
+     * @author :lyh
+     * @method :post
+     * @time   :2025/2/21 14:51
+     */
+    public function getProjectAiSetting(){
+        $projectAiSettingModel = new ProjectAiSetting();
+        $aiSettingInfo = $projectAiSettingModel->read(['project_id'=>$this->user['project_id']]);
+        if($aiSettingInfo === false){
+            $this->fail('请先联系管理员开启Ai配置');
+        }
+        return $aiSettingInfo;
+    }
+
+    /**
+     * @remark :ai发布博客
+     * @name   :blogSave
+     * @author :lyh
+     * @method :post
+     * @time   :2023/7/5 14:46
+     */
+    public function blogSave(){
+        try {
+            if(!empty($this->param['image'])){
+                $this->param['image'] = str_replace_url($this->param['image']);
+            }
+            $this->param['route'] = RouteMap::setRoute($this->param['route'], RouteMap::SOURCE_AI_BLOG, $this->param['id'], $this->user['project_id']);
+            $this->model->edit($this->param,['id'=>$this->param['id']]);
+            $aiSettingInfo = $this->getProjectAiSetting();
+            $aiBlogService = new AiBlogService();
+            $aiBlogService->mch_id = $aiSettingInfo['mch_id'];
+            $aiBlogService->key = $aiSettingInfo['key'];
+            $aiBlogService->updateDetail(['title'=>$this->param['new_title'],'thumb'=>$this->param['image'],'route'=>$this->param['route'],'author_id'=>$this->param['author_id']]);
+        }catch (\Exception $e){
+            $this->fail('保存失败，请联系管理员');
+        }
+        return $this->success();
+    }
+
+    /**
+     * @remark :编辑作者
+     * @name   :saveAuthor
+     * @author :lyh
+     * @method :post
+     * @time   :2025/2/21 14:46
+     */
+    public function saveBlogAuthor(){
+        try {
+            $aiAuthorModel = new AiBlogAuthor();
+            if(!empty($this->param['image'])){
+                $this->param['image'] = str_replace_url($this->param['image']);
+            }
+            $this->param['route'] = RouteMap::setRoute($this->param['route'], RouteMap::SOURCE_AI_BLOG_AUTHOR, $this->param['id'], $this->user['project_id']);
+            $aiAuthorModel->edit($this->param,['id'=>$this->param['id']]);
+            $aiBlogService = new AiBlogService();
+            $aiBlogService->updateAuthorInfo(['author_id'=>$this->param['author_id'],'title'=>$this->param['title'],'picture'=>$this->param['image'],'description'=>$this->param['description']]);
+        }catch (\Exception $e){
+            $this->fail('保存失败，请联系管理员');
+        }
+        return $this->success();
+    }
+
+    /**
+     * @remark :发布任务
+     * @name   :sendTask
+     * @author :lyh
+     * @method :post
+     * @time   :2025/2/14 10:28
+     * @detail :type=2/生成文章 type=3/更新列表页记录
+     * @detail :status=1/待执行
+     */
+    public function sendTask(){
+        $aiSettingInfo = $this->getProjectAiSetting();
+        $aiBlogService = new AiBlogService();
+        $aiBlogService->mch_id = $aiSettingInfo['mch_id'];
+        $aiBlogService->key = $aiSettingInfo['key'];
+        $aiBlogService->route = generateRoute(Translate::tran($this->param['keyword'], 'en'));
+        $result = $aiBlogService->createTask($this->param['keyword'],$this->param['type'],'video');
+        if($result['status'] == 200){
+            $aiBlogTaskModel = new AiBlogTask();
+            $aiBlogTaskModel->addReturnId(['project_id'=>$this->user['project_id'],'type'=>3,'task_id'=>$result['data']['task_id'],'status'=>1]);
+            $this->model->addReturnId(['keyword'=>$this->param['keyword'],'status'=>1,'task_id'=>$result['data']['task_id'],'project_id'=>$this->user['project_id']]);
+        }
+        return $this->success();
+    }
+
+    /**
+     * @remark :删除
+     * @name   :blogDelete
+     * @author :lyh
+     * @method :post
+     * @time   :2025/2/20 18:21
+     */
+    public function blogDelete(){
+        try {
+            $aiSettingInfo = $this->getProjectAiSetting();
+            $aiBlogService = new AiBlogService();
+            foreach ($this->param['ids'] as $id) {
+                $info = $this->model->read(['id'=>$id],['task_id']);
+                $aiBlogService->mch_id = $aiSettingInfo['mch_id'];
+                $aiBlogService->key = $aiSettingInfo['key'];
+                $aiBlogService->delDetail($info['task_id']);
+                //删除路由映射
+                RouteMap::delRoute(RouteMap::SOURCE_AI_BLOG, $id, $this->user['project_id']);
+                $this->model->del(['id'=>$id]);
+            }
+            shell_exec('php artisan save_ai_blog_list '.$this->user['project_id'].' > /dev/null 2>&1 &');
+        }catch (\Exception $e){
+            $this->fail('删除失败');
+        }
+        return $this->success();
+    }
+
+
+}