zm/tougao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

redis调整

Browse Source
This commit is contained in:
chengxl
2025-08-07 16:14:26 +08:00
parent 104eb43c47
commit c7b4539c49
3 changed files with 172 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

231
application/api/controller/Aiarticle.php
View File

@@ -74,7 +74,6 @@ class Aiarticle extends Base
$aArticleContent = empty($aResult['data']) ? [] : $aResult['data'];
//文章数据
$aArticle = empty($aArticleContent['article']) ? [] : $aArticleContent['article'];
if(empty($aArticle)){
return json_encode(['status' => 3,'msg' => 'The content of the article is empty']);
}
@@ -98,7 +97,6 @@ class Aiarticle extends Base
}
$aAiArticle = array_merge(['ai_article_id' => $iId,'article_id' => $iArticleId,'is_generate' => 2],$aInsert);
}
//判断是否生成
if(!empty($aAiArticle['is_generate']) && $aAiArticle['is_generate'] == 1){
return json_encode(['status' => 5,'msg' => 'The data has been generated, please proceed with the next steps']);
@@ -134,12 +132,10 @@ class Aiarticle extends Base
$aAuthor = empty($aArticleContent['author']) ? [] : $aArticleContent['author'];
//查询文章内容
$aMain = empty($aArticleContent['main']) ? [] : $aArticleContent['main'];;
$sContent = empty($aMain) ? '' : implode(',', $aMain);
$oOpenAi = new OpenAi;
//请求OPENAI生成微信公众号文章内容
$aSearch = [];
$aSearch['{#content#}'] = $this->basic_html_filter($sContent);
$aSearch['main_content'] = empty($aArticleContent) ? [] : $aArticleContent;
$aSearch['{#abstract#}'] = $this->basic_html_filter($aArticle['abstract']);
$aSearch['{#title_chinese#}'] = $this->basic_html_filter($aArticle['title']);
$aSearch['{#journal_content#}'] = $this->basic_html_filter($aJournal['journal_content'] ?? '');
@@ -184,30 +180,60 @@ class Aiarticle extends Base
*/
public function getArticle($iArticleId = ''){
$aParam = $this->request->post();
$iArticleId = empty($iArticleId) ? $aParam['article_id'] : $iArticleId;
//文章ID
$iArticleId = empty($iArticleId) ? 0 : $iArticleId;
if(empty($iArticleId)){
return json_encode(['status' => 2,'msg' => 'article id is null']);
}
//接口请求地址
$sUrl = $this->sJournalUrl.'/wechat/Article/getArticle';
//请求接口
$aParam['article_id'] = $iArticleId;
$aResult = object_to_array(json_decode(myPost($sUrl, $aParam)));
$iStatus = empty($aResult['status']) ? 0 : $aResult['status'];
if($iStatus != 1){
return json_encode(['status' => 0,'msg' => $aResult['msg'] ?? '操作异常']);
return json_encode(['status' => 3,'msg' => $aResult['msg'] ?? '操作异常']);
}
//获取接口内容
$aContent = empty($aResult['data']) ? [] : $aResult['data'];
if(!empty($aContent['journal'])){
$aJournal = $aContent['journal'];
//查询期刊主题
$aWhere['issn'] = $aJournal['issn'];
$aJournalInfo = Db::name('journal')->field('journal_topic')->where($aWhere)->find();
$aContent['journal']+=$aJournalInfo;
//查询生产环境的文章信息
$aParam = ['w_article_id' => $iArticleId,'state' => ['in',[0,2]]];
$aProductionArticle = Db::name('production_article')->field('article_id,title,abstract,journal_id,journal_stage_id,abbr,npp,doi,icon as article_icon,related,type')->where($aParam)->find();
if(empty($aProductionArticle)){
return json_encode(['status' => 4,'msg' => 'The production article data is empty']);
}
//查询文章内容
$iArticleId = empty($aProductionArticle['article_id']) ? 0 : $aProductionArticle['article_id'];
$aParam = ['article_id' => $iArticleId,'state' => 0,'type' => ['in',[0,1]],'content' => ['<>','']];
$aMain = Db::name('article_main')->field('am_id,article_id,content,sort,is_h1,is_h2,type,ami_id,amt_id')->where($aParam)->order('sort asc ')->select();
//查询文章内容里的一级标题
$aParam['is_h1'] = 1;
$aMainH1 = Db::name('article_main')->field('am_id,content,sort')->where($aParam)->order('sort asc ')->select();
if(!empty($aMainH1)){
//数据处理一级标题内容
$aMainH1Info = array_column($aMainH1,'sort', 'am_id');
// 提取纯标题数组（保持原顺序）
$aMainContent = array_column($aMainH1, 'content');
// 提取纯am_id数组（保持原顺序）
$aAmId = array_column($aMainH1, 'am_id');
// 初始化结果数组
$aMainH1 = [];
// 处理前4个标题对应的ID区间
for ($i = 0; $i < count($aMainContent) - 1; $i++) {
$title = $aMainContent[$i];
$currentId = $aAmId[$i];
$nextId = $aAmId[$i + 1];
$aMainH1[$title] = ['range' => "{$aMainH1Info[$currentId]},{$aMainH1Info[$nextId]}"];
}
// 处理最后一个ID（单独添加）
$aMainH1[end($aMainContent)] = ['range' => $aMainH1Info[end($aAmId)]];
}
// 拼接成最终字符串
$aContent += ['main' => $aMain,'main_h1' => $aMainH1];
return json_encode(['status' => 1,'msg' => 'success','data' => $aContent]);
}
@@ -498,7 +524,6 @@ class Aiarticle extends Base
// //上传素材到微信
if($iIsSync == 1){
//查询参数组装
$aQueryParam = ['article_id' => $iArticleId,'journal_id' => $aArticle['journal_id']];
//组装作者数据
@@ -540,7 +565,6 @@ class Aiarticle extends Base
}
}else{
//处理文章图片地址数据
$aAiArticle['article_icon'] = $sArticleIcon;
//处理文章期刊图片地址数据
@@ -552,7 +576,6 @@ class Aiarticle extends Base
if(!empty($aAuthor)){
$aAuthor = $this->_dealAuthor($aAuthor);
}
}
//期刊访问地址
$journal_usx = trim($this->sJournalUsx,'/').'/';
@@ -597,7 +620,7 @@ class Aiarticle extends Base
if(is_array($value)){
continue;
}
$aSearch['{###'.$key.'###}'] = empty($value) ? '' : htmlspecialchars(strip_tags($value));
$aSearch['{###'.$key.'###}'] = empty($value) ? '' : $value;
}
//处理通讯作者信息数据
@@ -646,7 +669,6 @@ class Aiarticle extends Base
if(empty($aSearch)){
return json_encode(['status' => 6, 'msg' => '模版内容不能为空']);
}
$aSearch['{###jabbr###}'] = trim(trim($aSearch['{###jabbr###}'],'.'),'。');
//期刊封面
$aSearch['{###journal_icon_info###}'] = $aSearch['{###journal_icon_details###}'] = '';
@@ -662,10 +684,24 @@ class Aiarticle extends Base
$aSearch['{###journal_icon_details###}'] = str_replace('{###journal_icon###}', $aAiArticle['journal_icon']??'', $sTemplateJournalInfo);
}
}
//涵盖范围
$aSearch['{###covered###}'] = empty($aSearch['{###covered###}']) ? '' : '内容涵盖'.$aSearch['{###covered###}'];
//处理研究结果
$aResearchResults = json_decode($this->dealTemplateResearchResults(['article_id' => $iArticleId,'template_path' => $sTemplatePath,'is_sync' => $iIsSync]),true);
$aSearch['{###discussion_results###}'] = empty($aResearchResults['data']) ? '' : implode('', $aResearchResults['data']);
//处理研究结论
$aSearch['{###research_conclusion###}'] = '';
if(!empty($aAiArticle['conclusion'])){
$sConclusionTemplatePath = $sTemplatePath.'/research_conclusion.html';
if (file_exists($sConclusionTemplatePath) && is_readable($sConclusionTemplatePath)) {
$sConclusionTemplatePath = file_get_contents($sConclusionTemplatePath);
$aSearch['{###research_conclusion###}'] = str_replace('{###conclusion###}', $aAiArticle['conclusion'], $sConclusionTemplatePath);
}
}
$sTemplate = str_replace(array_keys($aSearch), array_values($aSearch), $sTemplate);
// $this->writeFile($sTemplate,ROOT_PATH.'public/template_info.html');
$this->writeFile($sTemplate,ROOT_PATH.'public/template_info.html');
return json_encode(['status' => 1, 'msg' => '模版生成成功','data' => ['template' => $sTemplate]]);
}
@@ -722,12 +758,12 @@ class Aiarticle extends Base
if(!empty($aTranslateAuthorList)){
$aTranslate = array_merge($aTranslateAuthorList,$aTranslate);
}
if(!empty($aTranslate)){
$aSearch['{#content#}'] = json_encode($aTranslate);
$oOpenAi = new OpenAi;
$aTranslate = $oOpenAi->buildTranslatePrompt($aSearch);
$aTranslate = empty($aTranslate['data']) ? [] : $aTranslate['data'];
}
// if(!empty($aTranslate)){
// $aSearch['{#content#}'] = json_encode($aTranslate);
// $oOpenAi = new OpenAi;
// $aTranslate = $oOpenAi->buildTranslatePrompt($aSearch);
// $aTranslate = empty($aTranslate['data']) ? [] : $aTranslate['data'];
// }
//翻译内容处理
if(!empty($aAuthorSerachInfo)){
foreach ($aAuthorSerachInfo as $key => $value) {
@@ -1059,32 +1095,32 @@ class Aiarticle extends Base
if(!empty($aAiArticle)){
$aMsg = [1 => 'The article has been pushed to the draft box',2 => 'Not pushed to the draft box',3 => 'Material upload in progress',4 => 'Material upload completed'];
//获取Redis内容，判断是否上传素材成功
$oMaterial = new Material;
$sUploadInfo = $oMaterial->getStepForRedis($iArticleId);
$sErrorInfo = '';
if(!empty($sUploadInfo) && $sUploadInfo != 'finish'){
$iStatus = 3;//素材上传中
$sErrorInfo = $oMaterial->getErrorForRedis($iArticleId);
if(!empty($sErrorInfo)){
$iStatus = 5;
return json_encode(['status' => 5,'msg' => $sErrorInfo]);
}
//判断是否上传素材
$oMaterial = new Material;
$aLogParam = ['article_id' => $iArticleId,'type' => 1];
$aLog = json_decode($oMaterial->getWechatLog($aLogParam),true);
$aLog = empty($aLog['data']) ? [] : $aLog['data'];
if(empty($aLog)){
$iStatus = 6;//未上传
return json_encode(['status' => $iStatus,'msg' => 'Material not uploaded']);
}
if(!empty($sUploadInfo) && $sUploadInfo == 'finish'){
if(!empty($aLog) && $aLog['status_name'] == 'processing'){
$iStatus = 3;//素材上传中
}
if(!empty($aLog) && $aLog['status_name'] == 'fail'){
$iStatus = 5;//失败
return json_encode(['status' => $iStatus,'msg' => empty($aLog['msg']) ? 'fail' : $aLog['msg']]);
}
if(!empty($aLog) && $aLog['status_name'] == 'finish'){
$iStatus = 4;//素材上传完成
}
//判断是否推送到草稿箱
if(empty($sUploadInfo) || $iStatus == 4){
if(!empty($aParam['template_id'])){
$aWhere['template_id'] = $aParam['template_id'];
}
if(!empty($aLog) && $iStatus == 4){
$aDraft = Db::name('ai_wechat_article')->field('is_publish,publish_status,article_id,template_id,wechat_id')->where($aWhere)->find();
$iStatus = empty($aDraft) ? 2 : 1;
}
$aResult['draft_status'] = $iStatus;
if(!empty($aDraft)){
$aMsg = [0 => 'Article successfully published', 1 => 'Article is being published',2 => 'Original article creation failed', 3 => 'Article conventional failure', 4 => 'WeChat official account platform review failed', 5 => 'After success, the user deletes all articles', 6 => 'After success, the system will ban all articles','-1' => 'Draft box article not published'];
@@ -1396,24 +1432,9 @@ class Aiarticle extends Base
}
//上传微信公众号用到的素材
$aUpload += ['article_id' => $iArticleId,'journal_id' => $aArticle['journal_id'],'wechat_app_id' => $sWechatAppId,'wechat_app_secret' => $sWechatAppSecret];
$aResult = json_decode($oMaterial->uploadMaterial($aUpload),true);
$iStatus = empty($aResult['status']) ? 0 : $aResult['status'];
$sMsg = empty($aResult['msg']) ? '' : $aResult['msg'];
if ($iStatus != 1) {
$iStatus = 2;
$sMsg = empty($sMsg) ? '素材上传失败' : $sMsg;
}
//插入日志记录
$aLogInfo = ['article_id' => $iArticleId,'type' => 1,'msg' =>$sMsg,'status' => $iStatus,'create_time' => time()];
$result = json_decode($oMaterial->addWechatLog($aLogInfo),true);
$aResult = $oMaterial->uploadMaterial($aUpload);
return $aResult;
//素材上传成功调用上传草稿箱的任务
if($iStatus == 1){
//1分钟后推送草稿箱
$iDelaySeconds = 60;//4 * 3600; // 1分钟的秒数
Queue::later($iDelaySeconds,'app\api\job\WechatDraft@fire', ['article_id' => $iArticleId], 'WechatDraft');
}
return json_encode(['status' => $iStatus,'msg' => $sMsg,'data' => $aLogInfo]);
}
/**
@@ -1431,4 +1452,88 @@ class Aiarticle extends Base
fclose($file);
}
/**
* 处理文章研究结果
* @param article_id 文章ID
*/
private function dealTemplateResearchResults($aParam = []){
$sTemplatePath = empty($aParam['template_path']) ? 0 : $aParam['template_path'];
if(empty($sTemplatePath)){
return json_encode(['status' => 2,'msg' => 'template does not exist']);
}
$iArticleId = empty($aParam['article_id']) ? 0 : $aParam['article_id'];
if(empty($iArticleId)){
return json_encode(['status' => 2,'msg' => 'Please select an article']);
}
//是否上传到微信草稿箱
$iIsSync = empty($aParam['is_sync']) ? 2 : $aParam['is_sync'];
//获取主题模版
$sTemplatePathInfo = $sTemplatePath.'/research_results.html';
//获取主题模版-图片
$sTemplateImagePathInfo = $sTemplatePath.'/research_results_image.html';
if (!file_exists($sTemplatePathInfo)) {
return json_encode(['status' => 4, 'msg' => 'Corresponding author template does not exist']);
}
if (!is_readable($sTemplatePathInfo)) {
return json_encode(['status' => 5, 'msg' => 'The corresponding author template is unreadable']);
}
$sTemplate = file_get_contents($sTemplatePathInfo);
$sTemplateImagePathInfo = file_get_contents($sTemplateImagePathInfo);
//查询数据
$aWhere = ['article_id' => $iArticleId];
$aResult = Db::name('ai_article_results')->field('title,content,current_am_id,next_am_id,ami_id')->where($aWhere)->select();
if(empty($aResult)){
return json_encode(['status' => 1,'msg' => 'data is null']);
}
$aAmiId = array_unique(array_column($aResult, 'ami_id'));
$aAmiId = empty($aAmiId) ? [] : explode(',', implode(',', $aAmiId));
if(!empty($aAmiId)){
//查询图片内容
$aParam = ['state' => 0,'ami_id' => ['in',$aAmiId]];
$aMainImage = Db::name('article_main_image')->field('ami_id,url,title,note')->where($aParam)->select();
$aMainImage = empty($aMainImage) ? [] : array_column($aMainImage, null,'ami_id');
}
//查询研究结果相关的微信素材
if($iIsSync == 1){
//获取研究结果图片
$aWhere = ['article_id' => $iArticleId,'is_delete' => 2];
$aResultsMaterial = Db::name('ai_results_material')->field('ami_id,media_id,media_url')->where($aWhere)->select();
$aResultsMaterial = empty($aResultsMaterial) ? [] : array_column($aResultsMaterial, null,'ami_id');
}
//数据处理https://submission.tmrjournals.com/public/articleImage/
foreach ($aResult as $key => $value) {
$aSerach['{###title###}'] = empty($value['title']) ? '' : $value['title'];
$aSerach['{###content###}'] = empty($value['content']) ? '' : $value['content'];
$aSerach['{###image_info###}'] = '';
if(!empty($value['ami_id'])){
$aAmiId = explode(',', $value['ami_id']);
$aImageInfo = [];
foreach ($aAmiId as $k => $val) {
$aMainImageInfo = empty($aMainImage[$val]) ? [] : $aMainImage[$val];
if(empty($aMainImageInfo['url'])){
continue;
}
$aImageSerach['{###image_url###}'] = trim($this->sSubmissionUrl,'/').'/public/articleImage/'.$aMainImageInfo['url'];
if($iIsSync == 1){
$aImageSerach['{###image_url###}'] = empty($aResultsMaterial[$val]['media_url']) ? '' : $aResultsMaterial[$val]['media_url'];
}
$aImageSerach['{###image_url###}'] = trim($this->sSubmissionUrl,'/').'/public/articleImage/'.$aMainImageInfo['url'];
$sTitle = empty($aMainImageInfo['title']) ? strip_tags($aMainImageInfo['note']) : strip_tags($aMainImageInfo['title']);
$aImageSerach['{###image_title###}'] = '';
if(!empty($sTitle)){
$sTitle = preg_replace('/Figure \d+.*?/', '', $sTitle);
$aTitle = explode('.', $sTitle);
$aImageSerach['{###image_title###}'] = empty($aTitle[0]) ? $sTitle : strip_tags($aTitle[0]);
}
$aImageInfo[] = str_replace(array_keys($aImageSerach), array_values($aImageSerach), $sTemplateImagePathInfo);
}
$aSerach['{###image_info###}'] = empty($aImageInfo) ? '' : implode(',', $aImageInfo);
}
$aSearchInfo[] = str_replace(array_keys($aSerach), array_values($aSerach), $sTemplate);
}
return json_encode(['status' => 1,'msg' => 'success','data' => $aSearchInfo]);
}
}

2
application/common/Material.php
View File

@@ -470,7 +470,7 @@ class Material
$aInsert['create_time'] = $iTime;
$response = Db::name('ai_journal_editor_material')->insertGetId($aInsert);
}else{
$aWhere['author_id'] = $aMaterial['author_id'];
$aWhere['author_id'] = $aMaterial['id'];
$aInsert['update_time'] = $iTime;
$response = Db::name('ai_journal_editor_material')->where($aWhere)->limit(1)->update($aInsert);
}

2
application/common/OpenAi.php
View File

@@ -619,7 +619,7 @@ class OpenAi
curl_setopt($this->curl, CURLOPT_PROXY, $this->proxy);
curl_setopt($this->curl, CURLOPT_SSL_VERIFYPEER, true);
curl_setopt($this->curl, CURLOPT_SSL_VERIFYHOST, 2);
curl_setopt($this->curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_TLSv1_2); // 强制TLS版本
// curl_setopt($this->curl, CURLOPT_SSLVERSION, CURL_SSLVERSION_TLSv1_2); // 强制TLS版本
// 核心传输配置 - 解决数据截断
curl_setopt($this->curl, CURLOPT_POST, true);