|
|
|
<?php
|
|
|
|
|
|
|
|
namespace App\Console\Commands\Tdk;
|
|
|
|
|
|
|
|
use App\Helper\Arr;
|
|
|
|
use App\Helper\Common;
|
|
|
|
use App\Helper\Gpt;
|
|
|
|
use App\Models\Ai\AiCommand;
|
|
|
|
use App\Models\Domain\DomainInfo;
|
|
|
|
use App\Models\Mail\Mail;
|
|
|
|
use App\Models\Project\DeployBuild;
|
|
|
|
use App\Models\Project\DeployOptimize;
|
|
|
|
use App\Models\Project\ProjectKeyword;
|
|
|
|
use App\Models\Project\ProjectUpdateTdk;
|
|
|
|
use App\Models\User\User;
|
|
|
|
use App\Models\WebSetting\WebLanguage;
|
|
|
|
use App\Services\ProjectServer;
|
|
|
|
use Illuminate\Console\Command;
|
|
|
|
use Illuminate\Support\Facades\Cache;
|
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
use Illuminate\Support\Facades\Redis;
|
|
|
|
use Illuminate\Support\Str;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 指定跑某个项目
|
|
|
|
* Class InitProject
|
|
|
|
* @package App\Console\Commands
|
|
|
|
* @author zbj
|
|
|
|
* @date 2023/10/8
|
|
|
|
*/
|
|
|
|
class UpdateSeoTdkByTaskId extends Command
|
|
|
|
{
|
|
|
|
/**
|
|
|
|
* The name and signature of the console command.
|
|
|
|
*
|
|
|
|
* @var string
|
|
|
|
*/
|
|
|
|
protected $signature = 'update_seo_tdk_by {task_id}';
|
|
|
|
|
|
|
|
/**
|
|
|
|
* The console command description.
|
|
|
|
*
|
|
|
|
* @var string
|
|
|
|
*/
|
|
|
|
protected $description = '一键生成tdk';
|
|
|
|
|
|
|
|
protected $project;
|
|
|
|
|
|
|
|
/**
|
|
|
|
* Create a new command instance.
|
|
|
|
*
|
|
|
|
* @return void
|
|
|
|
*/
|
|
|
|
public function __construct()
|
|
|
|
{
|
|
|
|
parent::__construct();
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* '表' => [
|
|
|
|
* '指令key' => '表字段'
|
|
|
|
* ]
|
|
|
|
* @return array
|
|
|
|
* @author zbj
|
|
|
|
* @date 2023/11/3
|
|
|
|
*/
|
|
|
|
protected $maps = [
|
|
|
|
'gl_web_custom_template' => [
|
|
|
|
'page_title' => 'title',
|
|
|
|
'page_meta_keywords' => 'keywords',
|
|
|
|
'page_meta_description' => 'description',
|
|
|
|
],
|
|
|
|
'gl_product' => [
|
|
|
|
'product_title' => 'seo_mate.title',
|
|
|
|
'product_meta_keywords' => 'seo_mate.keyword',
|
|
|
|
'product_meta_description' => 'seo_mate.description',
|
|
|
|
],
|
|
|
|
'gl_product_category' => [
|
|
|
|
'product_cat_title' => 'seo_title',
|
|
|
|
'product_cat_meta_keywords' => 'seo_keywords',
|
|
|
|
'product_cat_meta_description' => 'seo_des',
|
|
|
|
],
|
|
|
|
'gl_blog' => [
|
|
|
|
'blog_title' => 'seo_title',
|
|
|
|
'blog_meta_keywords' => 'seo_keywords',
|
|
|
|
'blog_meta_description' => 'seo_description',
|
|
|
|
],
|
|
|
|
'gl_blog_category' => [
|
|
|
|
'blog_cat_title' => 'seo_title',
|
|
|
|
'blog_cat_meta_keywords' => 'seo_keywords',
|
|
|
|
'blog_cat_meta_description' => 'seo_des',
|
|
|
|
],
|
|
|
|
'gl_news' => [
|
|
|
|
'news_title' => 'seo_title',
|
|
|
|
'news_meta_keywords' => 'seo_keywords',
|
|
|
|
'news_meta_description' => 'seo_description',
|
|
|
|
],
|
|
|
|
'gl_news_category' => [
|
|
|
|
'news_cat_title' => 'seo_title',
|
|
|
|
'news_cat_meta_keywords' => 'seo_keywords',
|
|
|
|
'news_cat_meta_description' => 'seo_des',
|
|
|
|
],
|
|
|
|
'gl_product_keyword' => [
|
|
|
|
'tags_title' => 'seo_title',
|
|
|
|
'tags_meta_keywords' => 'seo_keywords',
|
|
|
|
'tags_meta_description' => 'seo_description',
|
|
|
|
'tags_content_title' => 'keyword_title',
|
|
|
|
'tags_content_description' => 'keyword_content',
|
|
|
|
]
|
|
|
|
];
|
|
|
|
|
|
|
|
/**
|
|
|
|
* topic-对相应字段
|
|
|
|
* @var array
|
|
|
|
*/
|
|
|
|
protected $topic_fields = [
|
|
|
|
'gl_web_custom_template' => 'name',
|
|
|
|
'gl_product' => 'title',
|
|
|
|
'gl_product_category' => 'title',
|
|
|
|
'gl_blog' => 'name',
|
|
|
|
'gl_blog_category' => 'name',
|
|
|
|
'gl_news' => 'name',
|
|
|
|
'gl_news_category' => 'name',
|
|
|
|
'gl_product_keyword' => 'title'
|
|
|
|
];
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 使用核心关键词的key 数量
|
|
|
|
* @var array
|
|
|
|
*/
|
|
|
|
protected $core_keyword_keys = [
|
|
|
|
'page_meta_keywords' => 1,
|
|
|
|
'blog_cat_meta_keywords' => 8,
|
|
|
|
'news_cat_meta_keywords' => 8,
|
|
|
|
];
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @return bool
|
|
|
|
*/
|
|
|
|
public function handle()
|
|
|
|
{
|
|
|
|
$task_id = $this->argument('task_id');
|
|
|
|
$task = ProjectUpdateTdk::where('status', ProjectUpdateTdk::STATUS_PENDING)->where('id', $task_id)->first();
|
|
|
|
if (!$task) {
|
|
|
|
echo date('Y-m-d H:i:s') . ' 任务不存在: ' . $task_id . PHP_EOL;
|
|
|
|
}
|
|
|
|
$project_id = $task->project_id;
|
|
|
|
|
|
|
|
echo date('Y-m-d H:i:s') . ' start project_id: ' . $project_id . PHP_EOL;
|
|
|
|
try {
|
|
|
|
$this->project = ProjectServer::useProject($project_id);
|
|
|
|
$this->seo_tdk($project_id, $task->id);
|
|
|
|
DB::disconnect('custom_mysql');
|
|
|
|
}catch (\Exception $e){
|
|
|
|
echo date('Y-m-d H:i:s') . 'line: '. $e->getLine() .' error: ' . $project_id . '->' . $e->getMessage() . PHP_EOL;
|
|
|
|
ProjectUpdateTdk::retry($task->id, $e->getMessage());
|
|
|
|
}
|
|
|
|
Cache::forget('project_deploy_optimize_info_' . $project_id);
|
|
|
|
echo date('Y-m-d H:i:s') . ' end project_id: ' . $project_id . PHP_EOL;
|
|
|
|
}
|
|
|
|
public function sendNotify($project_id, $route)
|
|
|
|
{
|
|
|
|
//获取当前项目的域名
|
|
|
|
$domainModel = new DomainInfo();
|
|
|
|
$domainInfo = $domainModel->read(['project_id'=>$project_id]);
|
|
|
|
if($domainInfo === false){
|
|
|
|
//获取测试域名
|
|
|
|
$deployBuildModel = new DeployBuild();
|
|
|
|
$buildInfo = $deployBuildModel->read(['project_id'=>$project_id]);
|
|
|
|
$this->param['domain'] = $buildInfo['test_domain'];
|
|
|
|
}else{
|
|
|
|
$this->param['domain'] = 'https://'.$domainInfo['domain'].'/';
|
|
|
|
}
|
|
|
|
$url = $this->param['domain'].'api/update_page/';
|
|
|
|
$param = [
|
|
|
|
'project_id' => $project_id,
|
|
|
|
'type' => 1,
|
|
|
|
'route' => $route,
|
|
|
|
'url' => [],
|
|
|
|
'language'=> [],
|
|
|
|
];
|
|
|
|
http_post($url, json_encode($param));
|
|
|
|
echo '更新中请稍后, 更新完成将会发送站内信通知更新结果！'. PHP_EOL;
|
|
|
|
}
|
|
|
|
public function seo_tdk($project_id, $task_id)
|
|
|
|
{
|
|
|
|
$notify_master = $notify_keyword = false;
|
|
|
|
//更新统计
|
|
|
|
$update = [];
|
|
|
|
$ai_commands = AiCommand::where('is_batch', 1)->select('key', 'scene', 'ai')->get()->toArray();
|
|
|
|
$ai_commands = Arr::setValueToKey($ai_commands, 'key');
|
|
|
|
foreach ($this->maps as $table => $map) {
|
|
|
|
$total_page = DB::connection('custom_mysql')->table($table)->count();
|
|
|
|
$update[$table] = ['total_page'=>$total_page, 'title'=>0, 'keyword'=>0, 'des'=>0,'keyword_title'=>0,'keyword_content'=>0];
|
|
|
|
echo date('Y-m-d H:i:s') . '更新--' . $table . ': 项目id' . $project_id . PHP_EOL;
|
|
|
|
$list = DB::connection('custom_mysql')->table($table)
|
|
|
|
->where(function ($query) use ($table, $map){
|
|
|
|
if($table == 'gl_product'){
|
|
|
|
foreach ($map as $field){
|
|
|
|
$field_arr = explode('.', $field);
|
|
|
|
$query->orWhereRaw('JSON_CONTAINS('.$field_arr[0].', "null", "$.'.$field_arr[1].'") OR JSON_EXTRACT('.$field_arr[0].', "$.'.$field_arr[1].'") = ""');
|
|
|
|
}
|
|
|
|
}else{
|
|
|
|
foreach ($map as $field){
|
|
|
|
$query->orWhereRaw($field . " IS NULL OR ".$field." = ''");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
})->select('id')->get();
|
|
|
|
if (!empty($list)) {
|
|
|
|
$list = $list->toArray();
|
|
|
|
foreach ($list as $v) {
|
|
|
|
$v = (array)$v;
|
|
|
|
|
|
|
|
//缓存 在处理的项目数据 id
|
|
|
|
$cache_key = "seo_tdk_{$project_id}_{$table}_{$v['id']}";
|
|
|
|
if(!Redis::setnx($cache_key, 1)){
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
Redis::expire($cache_key, 120);
|
|
|
|
|
|
|
|
echo date('Y-m-d H:i:s') . '更新--' . $table . ': 项目id' . $project_id . ':id' . $v['id'] . PHP_EOL;
|
|
|
|
$v = DB::connection('custom_mysql')->table($table)->where('id', $v['id'])->first();
|
|
|
|
$v = (array)$v;
|
|
|
|
$data = [];
|
|
|
|
$json_field = '';
|
|
|
|
foreach ($map as $ai_key => $field) {
|
|
|
|
$field_arr = explode('.', $field);
|
|
|
|
if (count($field_arr) > 1) {
|
|
|
|
$json_field = $field_arr[0];
|
|
|
|
$value = json_decode($v[$field_arr[0]], true)[$field_arr[1]] ?? '';
|
|
|
|
} else {
|
|
|
|
$value = $v[$field] ?? '';
|
|
|
|
}
|
|
|
|
//已有值的 跳过
|
|
|
|
if ($value) {
|
|
|
|
echo $field.'已有值 跳过' . PHP_EOL;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
//AI生成
|
|
|
|
if (!empty($ai_commands[$ai_key]['ai'])) {
|
|
|
|
$prompt = $this->getPrompt($project_id, $ai_commands[$ai_key]['ai'], $table, $v);
|
|
|
|
if(!$prompt){
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if (count($field_arr) > 1) {
|
|
|
|
if($field_arr[1] == 'title'){
|
|
|
|
$update[$table]['title']++;
|
|
|
|
}elseif ($field_arr[1] == 'keyword'){
|
|
|
|
$update[$table]['keyword']++;
|
|
|
|
}elseif ($field_arr[1] == 'description'){
|
|
|
|
$update[$table]['des']++;
|
|
|
|
}
|
|
|
|
$data[$field_arr[0]][$field_arr[1]] = $this->ai_send($prompt);
|
|
|
|
}else{
|
|
|
|
if($field == 'title' || $field == 'seo_title'){
|
|
|
|
$update[$table]['title']++;
|
|
|
|
}
|
|
|
|
if($field == 'keywords' || $field == 'seo_keywords'){
|
|
|
|
$update[$table]['keyword']++;
|
|
|
|
}
|
|
|
|
if($field == 'seo_description' || $field == 'description' || $field == 'seo_des'){
|
|
|
|
$update[$table]['des']++;
|
|
|
|
}
|
|
|
|
if($field == 'keyword_title'){
|
|
|
|
$update[$table]['keyword_title']++;
|
|
|
|
}
|
|
|
|
if($field == 'keyword_content'){
|
|
|
|
$update[$table]['keyword_content']++;
|
|
|
|
}
|
|
|
|
$data[$field] = $this->ai_send($prompt);
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
//直接使用topic
|
|
|
|
if (count($field_arr) > 1) {
|
|
|
|
$data[$field_arr[0]][$field_arr[1]] = $v[$this->topic_fields[$table]] ?? '';
|
|
|
|
//使用核心关键词
|
|
|
|
if(in_array($ai_key, array_keys($this->core_keyword_keys))){
|
|
|
|
$data[$field_arr[0]][$field_arr[1]] = $this->mainKeywords($project_id, $this->core_keyword_keys[$ai_key]);
|
|
|
|
if(!empty($data[$field_arr[0]][$field_arr[1]])){
|
|
|
|
if($field_arr[1] == 'title'){
|
|
|
|
$data[$table]['title']++;
|
|
|
|
}elseif ($field_arr[1] == 'keyword'){
|
|
|
|
$data[$table]['keyword']++;
|
|
|
|
}elseif ($field_arr[1] == 'description'){
|
|
|
|
$data[$table]['des']++;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}else{
|
|
|
|
$data[$field] = $v[$this->topic_fields[$table]] ?? '';
|
|
|
|
//使用核心关键词
|
|
|
|
if(in_array($ai_key, array_keys($this->core_keyword_keys))){
|
|
|
|
$data[$field] = $this->mainKeywords($project_id, $this->core_keyword_keys[$ai_key]);
|
|
|
|
if(!empty($data[$field])){
|
|
|
|
if($field == 'title' || $field == 'seo_title'){
|
|
|
|
$update[$table]['title']++;
|
|
|
|
}
|
|
|
|
if($field == 'keywords' || $field == 'seo_keywords'){
|
|
|
|
$update[$table]['keyword']++;
|
|
|
|
}
|
|
|
|
if($field == 'seo_description' || $field == 'description' || $field == 'seo_des'){
|
|
|
|
$update[$table]['des']++;
|
|
|
|
}
|
|
|
|
if($field == 'keyword_title'){
|
|
|
|
$update[$table]['keyword_title']++;
|
|
|
|
}
|
|
|
|
if($field == 'keyword_content'){
|
|
|
|
$update[$table]['keyword_content']++;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if(!$data){
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
if($json_field){
|
|
|
|
$old_data = json_decode($v[$field_arr[0]], true);
|
|
|
|
foreach ($old_data ?: [] as $kk=>$vv){
|
|
|
|
empty($data[$json_field][$kk]) && $data[$json_field][$kk] = $vv;
|
|
|
|
}
|
|
|
|
$data[$json_field] = json_encode($data[$json_field]);
|
|
|
|
}
|
|
|
|
DB::connection('custom_mysql')->table($table)->where(['id' => $v['id']])->update($data);
|
|
|
|
if($table == 'gl_product_keyword'){
|
|
|
|
$notify_keyword = true;
|
|
|
|
}else{
|
|
|
|
$notify_master = true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ProjectUpdateTdk::finish($task_id, $update);
|
|
|
|
|
|
|
|
//通知C端更新界面
|
|
|
|
$notify_master && $this->sendNotify($project_id, 1); //通知主站更新
|
|
|
|
$notify_keyword && $this->sendNotify($project_id, 4); //通知聚合页更新
|
|
|
|
}
|
|
|
|
|
|
|
|
public function getPrompt($project_id, $prompt, $table, $data){
|
|
|
|
if(strpos($prompt, '{topic}') !== false){
|
|
|
|
$topic = $data[$this->topic_fields[$table]] ?? '';
|
|
|
|
if(!$topic){
|
|
|
|
echo 'topic为空 跳过' . PHP_EOL;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
$prompt = str_replace('{topic}', $topic, $prompt);
|
|
|
|
}
|
|
|
|
if(strpos($prompt, '{keyword}') !== false) {
|
|
|
|
$keyword = $this->mainKeywords($project_id, 1);
|
|
|
|
if(!$keyword){
|
|
|
|
echo '核心关键词为空 跳过' . PHP_EOL;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
$prompt = str_replace('{keyword}', $keyword, $prompt);
|
|
|
|
}
|
|
|
|
if(strpos($prompt, '{company name}') !== false) {
|
|
|
|
$company_name = $this->companyName($project_id);
|
|
|
|
if(!$company_name){
|
|
|
|
echo '公司英文全称为空 跳过' . PHP_EOL;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
$prompt = str_replace('{company name}', $company_name, $prompt);
|
|
|
|
}
|
|
|
|
$prompt .= '.Please answer in ' . $this->getLang();
|
|
|
|
return $prompt;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public function getDeployOptimize($project_id){
|
|
|
|
$cache_key = 'project_deploy_optimize_info_' . $project_id;
|
|
|
|
$info = Cache::get($cache_key);
|
|
|
|
if(!$info){
|
|
|
|
$projectOptimizeModel = new DeployOptimize();
|
|
|
|
$info = $projectOptimizeModel->read(['project_id' => $project_id], ['id', 'company_en_name', 'company_en_description']);
|
|
|
|
$projectKeywordModel = new ProjectKeyword();
|
|
|
|
$keywordInfo = $projectKeywordModel->read(['project_id'=>$project_id]);
|
|
|
|
$info['main_keyword'] = '';
|
|
|
|
if($keywordInfo === false){
|
|
|
|
$info['main_keyword'] = $keywordInfo['main_keyword'];
|
|
|
|
}
|
|
|
|
Cache::put($cache_key, $info, 600);
|
|
|
|
}
|
|
|
|
return $info;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @remark :获取公司英文名称
|
|
|
|
* @name :companyName
|
|
|
|
* @author :lyh
|
|
|
|
* @method :post
|
|
|
|
* @time :2023/10/30 11:22
|
|
|
|
*/
|
|
|
|
public function companyName($project_id, $key = '')
|
|
|
|
{
|
|
|
|
$data = [
|
|
|
|
'product_long_description',
|
|
|
|
];
|
|
|
|
$info = $this->getDeployOptimize($project_id);
|
|
|
|
if (in_array($key, $data)) {
|
|
|
|
return $info['company_en_description'];
|
|
|
|
} else {
|
|
|
|
return $info['company_en_name'];
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @remark :获取公司核心关键词
|
|
|
|
* @name :mainKeywords
|
|
|
|
* @author :lyh
|
|
|
|
* @method :post
|
|
|
|
* @time :2023/10/30 11:22
|
|
|
|
*/
|
|
|
|
public function mainKeywords($project_id, $num)
|
|
|
|
{
|
|
|
|
$str = '';
|
|
|
|
$info = $this->getDeployOptimize($project_id);
|
|
|
|
if (!empty($info['main_keyword'])) {
|
|
|
|
$main_keyword = explode("\r\n", $info['main_keyword']);
|
|
|
|
//随机取
|
|
|
|
shuffle($main_keyword);
|
|
|
|
$main_keyword = array_slice($main_keyword, 0, $num);
|
|
|
|
$str = implode(", ", $main_keyword);
|
|
|
|
}
|
|
|
|
return $str;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function getLang(){
|
|
|
|
$lang = WebLanguage::getLangById($this->project['main_lang_id']??1);
|
|
|
|
return $lang['english'] ?? 'English';
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @remark :AI发送
|
|
|
|
* @name :ai_send
|
|
|
|
* @author :lyh
|
|
|
|
* @method :post
|
|
|
|
* @time :2023/8/19 10:40
|
|
|
|
*/
|
|
|
|
public function ai_send($prompt)
|
|
|
|
{
|
|
|
|
$text = Gpt::instance()->openai_chat_qqs($prompt);
|
|
|
|
$text = Common::deal_keywords($text);
|
|
|
|
$text = Common::deal_str($text);
|
|
|
|
|
|
|
|
//包含这写字 重新生成
|
|
|
|
if(Str::contains(Str::lower($text), ['[your brand]', '[brand name]'])){
|
|
|
|
return $this->ai_send($prompt);
|
|
|
|
}
|
|
|
|
|
|
|
|
return $text;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @remark :发送站内信
|
|
|
|
* @name :send_message
|
|
|
|
* @author :lyh
|
|
|
|
* @method :post
|
|
|
|
* @time :2023/11/4 10:22
|
|
|
|
*/
|
|
|
|
public function send_message($project_id){
|
|
|
|
$user = new User();
|
|
|
|
$userInfo = $user->read(['project_id'=>$project_id,'role_id'=>0]);
|
|
|
|
$data["title"] = "seo更新通知---完成";
|
|
|
|
$data["user_list"] = $userInfo['id'];
|
|
|
|
$data["content"] = "seo更新成功,更新完成时间".date('Y-m-d H:i:s');
|
|
|
|
$mail = new Mail();
|
|
|
|
return $mail->add($data);
|
|
|
|
}
|
|
|
|
} |
...
|
...
|
|
