';var_dump($aResult);exit;
        $iStatus = empty($aResult['status']) ? 0 : $aResult['status'];
        if($iStatus != 1){
            return json_encode($aResult);
        }
        //处理返回信息
        $aData = empty($aResult['data']) ? [] : $aResult['data'];
        if(empty($aData)){
            return json_encode(['status' => 6,'msg' => 'OPENAI returns empty content']);
        }
        if(empty($aData)){
            return json_encode(array('status' => 10,'msg' => 'OPENAI did not return data'));
        }
        //执行数据入库
        $aData['article_id'] = $iArticleId;
        $aResult = $this->addAiReview($aData);
        return json_encode($aResult);
       

    }

    /**
     * 保留内容中的文字和图片（移除其他HTML标签）
     * @param string $content 原始富文本内容
     * @return string 处理后的内容
     */
    private function keepTextAndImages($content)
    {
        if (empty($content)) {
            return '';
        }
        
        // 步骤1：保留标签和文本，移除其他所有HTML标签
        // 使用strip_tags保留标签，其他标签全部移除
        // $filtered = strip_tags($content, '');
        
        // 步骤2：处理特殊字符和冗余空白
        $filtered = html_entity_decode($content); // 解码HTML实体（如 ）
        $filtered = preg_replace('/\s+/', ' ', $filtered); // 合并连续空白为单个空格
        $filtered = trim($filtered); // 去除首尾空格
        
        // 步骤3：修复可能被破坏的标签格式（如属性缺失引号）
        $filtered = preg_replace('/]+)>/i', '', $filtered);
        $filtered = preg_replace('/src=([^\s>]+)/i', 'src="$1"', $filtered); // 确保src属性带引号
        
        return $filtered;
    }

    /**
     * @title AI审核内容入库
     * @param article_id 文章ID
     * @param content 内容
     */
    protected function addAiReview($aParam = array()){

        //返回数组
        $aResult = ['status' => 1,'msg' => 'AI review successful'];
        //必填参数验证
        $aFields = ['journal_scope','attribute','contradiction','unreasonable','ethics','academic','conclusion','fund_number','hotspot','submit_direction','overall_evaluation','article_id','references_past_three','references_past_five','references_ratio_JCR1','references_ratio_JCR2','registration_assessment','cite_rate'];
        $aInsert = ['create_time' => date('Y-m-d H:i:s')];
        foreach($aFields as $val){
            $aValue = empty($aParam[$val]) ? [] : $aParam[$val];
            if(!isset($aValue)){
                continue;
            }
            if(is_array($aValue)){
                foreach ($aValue as $key => $value) {
                    $sField = $val.'_'.$key;
                    $aInsert[$sField] = empty($value) ? '' : addslashes($value);
                }
            }else{
                $aInsert[$val] = empty($aValue) ? '' : addslashes($aValue);
            }
        }
        //执行入库
        if(empty($aInsert['article_id'])){
            return ['status' => 2,'msg' => 'Please select the article to be reviewed'];
        }
        if(!Db::name('article_ai_review')->insert($aInsert)){
           $aResult =  ['status' => 2,'msg' => 'Failed to add AI audit content'];
        }
        $aResult['data'] = $aInsert;
        return $aResult;
    }

    /**
     * @title 文章AI审核内容查询
     * @param article_id 文章ID
     */
    public function get(){

        //获取参数
        $aParam = $this->request->post();
        if(empty($aParam['article_id'])){
            return json_encode(array('status' => 2,'msg' => 'Please select an article' ));
        }

        //查询文章
        $aArticle = Db::table('t_article')->field('article_id')->where('article_id',$aParam['article_id'])->find();
        if(empty($aArticle)){
            return json_encode(array('status' => 3,'msg' => 'No articles requiring review were found' ));
        }
        //查询文章审核内容
        $aAiReview = Db::table('t_article_ai_review')->where('article_id',$aParam['article_id'])->find();
        return json_encode(array('status' => 1,'msg' => 'Successfully obtained article review content','data' => $aAiReview));
    }

    /**
     * 批量处理待审核的文章自动推荐审稿人
     *
     * @return void
     */
    public function recommendedReviewer(){

         //获取参数
        $aParam = $this->request->post();
        if(empty($aParam['article_id'])){
            return json_encode(array('status' => 2,'msg' => 'Please select an article' ));
        }

        // //查询条件
        // $aWhere = ['article_id' => $aParam['article_id']];
        // $aArticle = Db::name('article')->field('article_id,accept_sn')->where($aWhere)->limit(1)->select();
        // if(empty($aArticle)){
        //     exit('未查询到需要处理的待审核的文章');
        // }
        //数据处理
        $sMsg = '';
        // foreach ($aArticle as $key => $value) {
        //     $iArticleId = empty($value['article_id']) ? 0 : $value['article_id'];
        //     if(empty($iArticleId)){
        //         continue;
        //     }

            // $sQueueId = \think\Queue::push('app\api\job\ArticleAiCreateContent@fire',$aParam, 'ArticleAiCreateContent');
            // $sQueueId = \think\Queue::push('app\api\job\RecommendReviewer@fire',$aParam, 'RecommendReviewer');
            // $sQueueId = \think\Queue::push('app\api\job\RelatedArticle@fire',$aParam, 'RelatedArticle');
            // $sQueueId = \think\Queue::push('app\api\job\ReviewerScore@fire',$aParam, 'ReviewerScore');
            // $sQueueId = \think\Queue::push('app\api\job\RevisionReviewer@fire',$aParam, 'RevisionReviewer');
            // $sQueueId = \think\Queue::push('app\api\job\SendRelatedArticleEmail@fire',$aParam, 'SendRelatedArticleEmail');
            // $sQueueId = \think\Queue::push('app\api\job\SendReviewEmail@fire',$aParam, 'SendReviewEmail');

            // $sQueueId = \think\Queue::push('app\api\job\WechatDraft@fire',$aParam, 'WechatDraft');

            // $sQueueId = \think\Queue::push('app\api\job\WechatDraftPublish@fire',$aParam, 'WechatDraftPublish');
            // $sQueueId = \think\Queue::push('app\api\job\WechatMaterial@fire',$aParam, 'WechatMaterial');
            // $sQueueId = \think\Queue::push('app\api\job\WechatQueryStatus@fire',$aParam, 'WechatQueryStatus');
            
            $sQueueId = \think\Queue::push('app\api\job\RecommendReviewer@fire',$aParam, 'RecommendReviewer');
            var_dump($sQueueId);exit;
            // if($sQueueId === false){
            //     $sMsg .= '文章入队失败,文章ID:'.$value['article_id'].'['.$value['accept_sn']."]\n";
            // }else{
            //     $sMsg .= '文章入队成功,文章ID:'.$value['article_id'].'['.$value['accept_sn']."]\n";
            // }
        // }
        exit($sMsg);
    }

}