<?php
/**
 * @remark :
 * @name   :GeoWritingsTask.php
 * @author :lyh
 * @method :post
 * @time   :2025/10/27 14:12
 */

namespace App\Console\Commands\Geo;

use App\Helper\Gpt;
use App\Models\Geo\GeoWritings;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Redis;
use App\Models\Geo\GeoWritingsTask as GeoWritingsTaskModel;

class GeoWritingsTask extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'geo_writings_task';

    public $porject_id;//记录当时执行的project_id

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'geoAi生成文章';

    public function handle(){
        while (true){
            $geoWritingsTaskModel = new GeoWritingsTaskModel();
            $task_id = $this->getTaskId();
            if(empty($task_id)){
                sleep(60);
                continue;
            }
            echo date("Y-m-d H:i:s").',执行的任务id'.$task_id.PHP_EOL;
            $info = $geoWritingsTaskModel->read(['id'=>$task_id]);
            if($info === false){
                echo date("Y-m-d H:i:s").',任务id数据不存在：'.$task_id.PHP_EOL;
                continue;
            }
            //生成引言
            $aiCommand1 = "请根据这个文章标题:{$info['title']}，并同时参考公司的介绍’{$info['description']}‘以及公司参与的事件内容’{$info['event_content']}‘，给我写一个英文Press Release前言内容，前言内容请参考并引用{$info['keyword']}行业的一些专业数据报告，只需要1个段落，大约150-200字，请一定要出现这个关键词“{$info['prefix']}{$info['keyword']}{$info['suffix']}”，所有内容一定要用英文， 只需要回复我引言内容，不需要别的内容(比如序号、你的提示、寒暄、解释、注释之类的)。";
            $gptHelper = new Gpt();
            $introduction = $gptHelper->openai_chat_qqs($aiCommand1);
            //生成内容
            $aiCommand2 = "请根据这个文章标题:{$info['title']}，并同时参考公司的介绍{$info['description']},以及公司参与的事件内容{$info['event_content']}，给我写一篇英文Press Release内容正文(已经有前言内容了)，内容请参考并引用“{$info['prefix']}{$info['keyword']}{$info['suffix']}”行业的一些专业数据报告，新闻内容需要 5-6 个大纲，每个大纲需要标题和 1-2 段内容，最后1-2个大纲主要介绍企业的核心优势、主营产品应用场景、主要客户案例，并最后附带内容{$info['footer']}，最后只需要回复我新闻稿内容，整个新闻稿内容字数1000字左右，不需要别的内容(比如序号、你的提示、寒暄、解释、注释之类的)。";
            $main = $gptHelper->openai_chat_qqs($aiCommand2);
            $images = explode(',',$info['img']);
            //组装一条数据
            try {
                $geoWritingsModel = new GeoWritings();
                $saveData = [
                    'title'=>$info['title'],
                    'content'=>$introduction.($images[0] ?? '').PHP_EOL.$main.($images[1] ?? ''),
                    'content_length'=>strlen($introduction.PHP_EOL.$main),
                ];
                $id = $geoWritingsModel->edit($saveData,['id'=>$info['writings_id']]);
                $data = [
                    'introduction'=>$introduction,
                    'main'=>$main,
                    'status'=>2,
                    'writings_id'=>$id,
                ];
                $geoWritingsTaskModel->edit($data,['id'=>$task_id]);
            }catch (\Exception $e){
                echo date('Y-m-d H:i:s').'保存失败：'.$task_id.$e->getMessage().PHP_EOL;
                continue;
            }
        }
    }

    /**
     * @remark :获取任务id
     * @name   :getTaskId
     * @author :lyh
     * @method :post
     * @time   :2025/10/27 14:22
     */
    public function getTaskId(){
        $task_id = Redis::rpop('geo_writings_task');
        $geoWritingsTaskModel = new GeoWritingsTaskModel();
        if (empty($task_id)) {
            $ids = $geoWritingsTaskModel->formatQuery(['status'=>0])->limit(100)->pluck('id');
            if(!empty($ids)){
                foreach ($ids as $id) {
                    Redis::lpush('geo_writings_task', $id);
                }
                $task_id = Redis::rpop('geo_writings_task');
            }
        }else{
            $geoWritingsTaskModel->edit(['status'=>GeoWritings::STATUS_AI_RUNNING],['id'=>$task_id]);
        }
        return $task_id;
    }
}