gx

@@ -2,10 +2,14 @@
 
 namespace App\Http\Controllers\Bside\Ai;
 
+use App\Enums\Common\Code;
 use App\Http\Controllers\Bside\BaseController;
 use App\Http\Logic\Bside\Ai\AiBlogLogic;
 use App\Http\Requests\Bside\Ai\AiBlogRequest;
+use App\Models\Ai\AiBlog;
 use App\Services\AiBlogService;
+use App\Services\ProjectServer;
+use Illuminate\Support\Facades\DB;
 
 class AiBlogController extends BaseController
 {
@@ -22,5 +26,23 @@ class AiBlogController extends BaseController
         $this->response('success');
     }
 
-
+    /**
+     * @remark :发布任务
+     * @name   :sendTask
+     * @author :lyh
+     * @method :post
+     * @time   :2025/2/14 10:25
+     */
+    public function sendTask(AiBlogLogic $aiBlogLogic){
+        $this->request->validate([
+            'keyword'=>['required'],
+            'type'=>['required']
+        ],[
+            'keyword.required' => '关键字不能为空',
+            'type.required' => '场景不能为空',
+        ]);
+        //获取当前项目的ai_blog设置
+        $result = $aiBlogLogic->sendTask();
+        $this->response('success',Code::SUCCESS,$result);
+    }
 }

@@ -4,6 +4,10 @@ namespace App\Http\Logic\Bside\Ai;
 
 use App\Http\Logic\Bside\BaseLogic;
 use App\Models\Ai\AiBlog;
+use App\Models\Project\AiBlogTask;
+use App\Models\Project\Project;
+use App\Models\Project\ProjectAiSetting;
+use App\Services\AiBlogService;
 
 class AiBlogLogic extends BaseLogic
 {
@@ -29,4 +33,35 @@ class AiBlogLogic extends BaseLogic
         }
         return $this->success();
     }
+
+    /**
+     * @remark :发布任务
+     * @name   :sendTask
+     * @author :lyh
+     * @method :post
+     * @time   :2025/2/14 10:28
+     */
+    public function sendTask(){
+        $projectAiSettingModel = new ProjectAiSetting();
+        $aiSettingInfo = $projectAiSettingModel->read(['project_id'=>$this->user['project_id']]);
+        if($aiSettingInfo === false){
+            $this->fail('请先联系管理员开启Ai博客');
+        }
+        $aiBlogService = new AiBlogService();
+        $aiBlogService->mch_id = $aiSettingInfo['mch_id'];
+        $aiBlogService->key = $aiSettingInfo['key'];
+        $result = $aiBlogService->createTask($this->param['keyword'],$this->param['type']);
+        if($result['status'] == 200){
+            try {
+                $aiBlogTaskModel = new AiBlogTask();
+                $aiBlogTaskModel->addReturnId(['project_id'=>$this->user['project_id'],'task_id'=>$result['data']['task_id'],'status'=>$result['data']['status']]);
+                $aiBlogModel = new AiBlog();
+                $aiBlogModel->addReturnId(['keywords'=>$this->param['keyword'], 'status'=>$result['data']['status'], 'task_id'=>$result['data']['task_id'],'project_id'=>$this->user['project_id'],
+                ]);
+            }catch (\Exception $e){
+                $this->fail('请求ai_blog失败，请联系管理员');
+            }
+        }
+        return $this->success();
+    }
 }

+<?php
+/**
+ * @remark :
+ * @name   :AiBlogTask.php
+ * @author :lyh
+ * @method :post
+ * @time   :2025/2/14 11:03
+ */
+
+namespace App\Models\Project;
+
+use App\Models\Base;
+
+class AiBlogTask extends Base
+{
+    protected $table = 'gl_ai_blog_task';
+}

@@ -154,6 +154,7 @@ Route::middleware(['bloginauth'])->group(function () {
         //ai
         Route::any('/news/', [\App\Http\Controllers\Bside\Ai\AiNewsController::class, 'save'])->name('ai_news_save');
         Route::any('/blog/', [\App\Http\Controllers\Bside\Ai\AiBlogController::class, 'save'])->name('ai_blog_save');
+        Route::any('/blog/sendTask', [\App\Http\Controllers\Bside\Ai\AiBlogController::class, 'sendTask'])->name('ai_blog_sendTask');
         Route::any('/product/', [\App\Http\Controllers\Bside\Ai\AiProductController::class, 'save'])->name('ai_product_save');
         Route::any('/product/productList', [\App\Http\Controllers\Bside\Ai\AiProductController::class, 'productList'])->name('ai_product_productList');
         Route::any('/product/productCateList', [\App\Http\Controllers\Bside\Ai\AiProductController::class, 'productCateList'])->name('ai_product_productCateList');