AiBlogLogic.php 5.3 KB
<?php

namespace App\Http\Logic\Bside\Ai;

use App\Helper\Translate;
use App\Http\Logic\Bside\BaseLogic;
use App\Models\Ai\AiBlog;
use App\Models\Ai\AiBlogAuthor;
use App\Models\Ai\AiBlogList;
use App\Models\Project\AiBlogTask;
use App\Models\Project\Project;
use App\Models\Project\ProjectAiSetting;
use App\Models\RouteMap\RouteMap;
use App\Services\AiBlogService;

class AiBlogLogic extends BaseLogic
{
    public function __construct()
    {
        parent::__construct();
        $this->param = $this->requestAll;
        $this->model = new AiBlog();
    }

    /**
     * @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'];
            $res = $aiBlogService->updateDetail(['task_id'=>$this->param['task_id'],'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']);
        if($result['status'] == 200){
            $aiBlogTaskModel = new AiBlogTask();
            $aiBlogTaskModel->addReturnId(['project_id'=>$this->user['project_id'],'type'=>2,'task_id'=>$result['data']['task_id'],'status'=>1]);
            $aiBlogModel = new AiBlog();
            $aiBlogModel->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();
    }


}