';var_dump($aResult);exit;
        return $aResult;
    }

    /**
     * 添加文章素材
     * @param article_id 文章ID
     * @param media_id 微信公众号素材media_id
     * @param media_url 微信公众号素材地址
     * @param sType select 查询｜add 新增
     * @param $sPath 图片地址
     */
    private function _addArticleMaterial($aParam = []){

        //文章ID
        $iArticleId = empty($aParam['article_id']) ? '' : $aParam['article_id'];
        //文章图片
        $sIcon = empty($aParam['icon']) ? '' : $aParam['icon'];
        //必填验证
        if(empty($iArticleId) || empty($sIcon)){
            return json_encode(['status' => 2,'msg' => 'article_id or article_image is empty']);
        }
        //查询是否添加素材
        $aWhere = ['article_id' => $iArticleId,'is_delete' => 2];
        $aMaterial = Db::name('ai_article_material')->field('media_id,media_url')->where($aWhere)->find();
        if(!empty($aMaterial)){
            return json_encode(['status' => 1,'msg' => 'added','data' => $aMaterial]);
        }
       
        //处理图片地址
        $aImageInfo = pathinfo($sIcon);
        //图片后缀名
        $sExtension = empty($aImageInfo['extension']) ? 'jpg' : $aImageInfo['extension'];
        $sImagePath = 'article/imgae_'.$iArticleId.'.'.$sExtension;
        $sImagePath = ROOT_PATH.'public/qrcode/'.$sImagePath;
        if (!file_exists($sImagePath)) {//下载图片
            $aImageInfo = json_decode($this->getImage($sIcon,$iArticleId,'article'),true);
            if(empty($aImageInfo['data'])){
                return json_encode(['status' => 3,'msg' => 'Image download failed']);
            }
        }

        //调用微信新增素材接口上传
        $aUploadResult = json_decode($this->uploadMaterial($sImagePath),true);
        $iStatus = empty($aUploadResult['status']) ? 0 : $aUploadResult['status'];
        $sMsg = empty($aUploadResult['msg']) ? 'Failed to upload materials' : $aUploadResult['msg'];
        if($iStatus != 1){
             return json_encode(['status' => 4,'msg' => $sMsg]);
        }
        $aData = empty($aUploadResult['data']) ? [] : $aUploadResult['data'];
        if(empty($aData['url'])){
             return json_encode(['status' => 5,'msg' => 'Material not obtained']);
        }

        //处理入库数据
        $sMediaId = empty($aData['media_id']) ? [] : $aData['media_id'];
        $sMediaUrl = empty($aData['url']) ? [] : $aData['url'];
        $iTime = empty($aUploadResult['created_at']) ? time() : $aUploadResult['created_at'];
        //入库数据组装
        $aInsert = ['type' => 'image','media_id' => $sMediaId,'create_time' =>  $iTime,'article_id' => $iArticleId,'media_url' => $sMediaUrl];
        $response = Db::name('ai_article_material')->insert($aInsert);
        if($response === false){
            return json_encode(['status' => 6,'msg' => 'Add fail']);
        }
        return json_encode(['status' => 1,'msg' => 'success','data' => $aInsert]);
    }
    /**
     * 添加期刊素材
     */
    private function _addJournalMaterial($aParam = []){

        //期刊ID
        $iJournalId = empty($aParam['journal_id']) ? '' : $aParam['journal_id'];
        //期刊图片
        $sIcon = empty($aParam['icon']) ? '' : $aParam['icon'];
        if(empty($iJournalId) || empty($sIcon)){
            return json_encode(['status' => 2,'msg' => 'journal_id or image is empty']);
        }
        //查询是否添加素材
        $aWhere = ['journal_id' => $iJournalId,'is_delete' => 2];
        $aMaterial = Db::name('ai_journal_material')->field('media_id,media_url')->where($aWhere)->find();
        if(!empty($aMaterial)){
            return json_encode(['status' => 1,'msg' => 'success','data' => $aMaterial]);
        }

        //处理图片地址
        $aImageInfo = pathinfo($sIcon);
        //图片后缀名
        $sExtension = empty($aImageInfo['extension']) ? 'jpg' : $aImageInfo['extension'];
        $sImagePath = 'journal/imgae_'.$iJournalId.'.'.$sExtension;
        $sImagePath = ROOT_PATH.'public/qrcode/'.$sImagePath;
        if (!file_exists($sImagePath)) {//下载图片
            $aImageInfo = json_decode($this->getImage($sIcon,$iJournalId,'journal'),true);
            if(empty($aImageInfo['data'])){
                return json_encode(['status' => 3,'msg' => 'Image download failed']);
            }
        }

        //调用微信新增素材接口上传
        $aUploadResult = json_decode($this->uploadMaterial($sImagePath),true);
        $iStatus = empty($aUploadResult['status']) ? 0 : $aUploadResult['status'];
        $sMsg = empty($aUploadResult['msg']) ? 'Failed to upload materials' : $aUploadResult['msg'];
        if($iStatus != 1){
             return json_encode(['status' => 4,'msg' => $sMsg]);
        }
        $aData = empty($aUploadResult['data']) ? [] : $aUploadResult['data'];
        if(empty($aData['url'])){
             return json_encode(['status' => 5,'msg' => 'Material not obtained']);
        }

        //处理入库数据
        $sMediaId = empty($aData['media_id']) ? [] : $aData['media_id'];
        $sMediaUrl = empty($aData['url']) ? [] : $aData['url'];
        $iTime = empty($aUploadResult['created_at']) ? time() : $aUploadResult['created_at'];
        //入库数据组装
        $aInsert = ['type' => 'image','media_id' => $sMediaId,'create_time' =>  $iTime,'journal_id' => $iJournalId,'media_url' => $sMediaUrl];
        $response = Db::name('ai_journal_material')->insert($aInsert);
        if($response === false){
            return json_encode(['status' => 6,'msg' => 'Add fail']);
        }
        return json_encode(['status' => 1,'msg' => 'success','data' => $aInsert]);
    }
    /**
     * 更新期刊二维码关联微信公众号素材
     */
    private function _updateJournalQrcode($aParam = []){

        //期刊ID
        $iJournalId = empty($aParam['journal_id']) ? '' : $aParam['journal_id'];
        if(empty($iJournalId)){
            return json_encode(['status' => 2,'msg' => 'journal_id or image is empty']);
        }

        //查询是否生成二维码
        $aWhere = ['journal_id' => $iJournalId,'is_delete' => 2];
        $aMaterial = Db::name('ai_journal_qrcode')->field('qrcode_url,media_id,media_url')->where($aWhere)->find();
        if(empty($aMaterial)){
            return json_encode(['status' => 3,'msg' => 'data is null']);
        }
        if(!empty($aMaterial['media_url'])){
            return json_encode(['status' => 1,'msg' => 'success','data' => $aMaterial]);
        }
        
        //处理图片地址
        $sImagePath = ROOT_PATH.'public/qrcode/'.$aMaterial['qrcode_url'];

        //调用微信新增素材接口上传
        $aUploadResult = json_decode($this->uploadMaterial($sImagePath),true);
        $iStatus = empty($aUploadResult['status']) ? 0 : $aUploadResult['status'];
        $sMsg = empty($aUploadResult['msg']) ? 'Failed to upload materials' : $aUploadResult['msg'];
        if($iStatus != 1){
             return json_encode(['status' => 4,'msg' => $sMsg]);
        }
        $aData = empty($aUploadResult['data']) ? [] : $aUploadResult['data'];
        if(empty($aData['url'])){
             return json_encode(['status' => 5,'msg' => 'Material not obtained']);
        }

        $sMediaId = empty($aData['media_id']) ? [] : $aData['media_id'];
        $sMediaUrl = empty($aData['url']) ? [] : $aData['url'];
        $iTime = empty($aUploadResult['created_at']) ? time() : $aUploadResult['created_at'];
        $aUpdate = ['media_id' => $sMediaId,'media_url' => $sMediaUrl,'update_time' => $iTime];
        $response = Db::name('ai_journal_qrcode')->where('journal_id',$iJournalId)->limit(1)->update($aUpdate);
        if($response === false){
            return json_encode(['status' => 3,'msg' => 'fail']);
        }
        return json_encode(['status' => 1,'msg' => 'success','data' => $aUpdate]);
    }

    /**
     * 更新文章二维码关联微信公众号素材
     */
    private function _updateArticleQrcode($aParam = []){

        $iArticleId = empty($aParam['article_id']) ? '' : $aParam['article_id'];
        if(empty($iArticleId)){
            return json_encode(['status' => 2,'msg' => 'article_id is empty']);
        }
        //查询是否添加素材
        $aWhere = ['article_id' => $iArticleId,'is_delete' => 2];
        $aMaterial = Db::name('ai_article_qrcode')->field('qrcode_url,media_id,media_url')->where($aWhere)->find();
        if(empty($aMaterial)){
            return json_encode(['status' => 3,'msg' => 'data is null']);
        }
        if(!empty($aMaterial['media_url'])){
            return json_encode(['status' => 1,'msg' => 'success','data' => $aMaterial]);
        }

        //处理图片地址
        $sImagePath = ROOT_PATH.'public/qrcode/'.$aMaterial['qrcode_url'];

        //调用微信新增素材接口上传
        $aUploadResult = json_decode($this->uploadMaterial($sImagePath),true);
        $iStatus = empty($aUploadResult['status']) ? 0 : $aUploadResult['status'];
        $sMsg = empty($aUploadResult['msg']) ? 'Failed to upload materials' : $aUploadResult['msg'];
        if($iStatus != 1){
             return json_encode(['status' => 4,'msg' => $sMsg]);
        }
        $aData = empty($aUploadResult['data']) ? [] : $aUploadResult['data'];
        if(empty($aData['url'])){
             return json_encode(['status' => 5,'msg' => 'Material not obtained']);
        }

        //更新
        $sMediaId = empty($aData['media_id']) ? [] : $aData['media_id'];
        $sMediaUrl = empty($aData['url']) ? [] : $aData['url'];
        $iTime = empty($aUploadResult['created_at']) ? time() : $aUploadResult['created_at'];
        $aUpdate = ['media_id' => $sMediaId,'media_url' => $sMediaUrl,'update_time' => $iTime];
        $response = Db::name('ai_article_qrcode')->where('article_id',$iArticleId)->limit(1)->update($aUpdate);
        if($response === false){
            return json_encode(['status' => 3,'msg' => 'update fail']);
        }
        return json_encode(['status' => 1,'msg' => 'success','data' => $aUpdate]);
    }

    /**
     * 更新通讯作者关联微信公众号素材
     */
    private function _updateArticleAuthor($aParam = []){

        $sEmail = empty($aParam['email']) ? '' : $aParam['email'];
        //文章图片
        $sIcon = empty($aParam['icon']) ? '' : $aParam['icon'];

        if(empty($sEmail) || empty($sIcon)){
            return json_encode(['status' => 2,'msg' => 'email is empty']);
        }
        //查询是否添加素材
        $aWhere = ['email' => $sEmail];
        $aMaterial = Db::name('ai_author_material')->field('media_id,media_url')->where($aWhere)->find();
        if(!empty($aMaterial['media_url'])){
            return json_encode(['status' => 1,'msg' => 'success','data' => $aMaterial]);
        }

        //处理图片地址
        $sImagePath = ROOT_PATH.'/public/usericon/'.trim($sIcon,'/');

        if(trim($sIcon) != '/static/img/userImg.f3d9bc3b.jpg'){//非默认头像
            //调用微信新增素材接口上传
            $aUploadResult = json_decode($this->uploadMaterial($sImagePath),true);
            $iStatus = empty($aUploadResult['status']) ? 0 : $aUploadResult['status'];
            $sMsg = empty($aUploadResult['msg']) ? 'Failed to upload materials' : $aUploadResult['msg'];
            if($iStatus != 1){
                 return json_encode(['status' => 4,'msg' => $sMsg]);
            }
            $aData = empty($aUploadResult['data']) ? [] : $aUploadResult['data'];
            if(empty($aData['url'])){
                 return json_encode(['status' => 5,'msg' => 'Material not obtained']);
            }
        }
        if(trim($sIcon) == '/static/img/userImg.f3d9bc3b.jpg'){//默认头像
            $aData = $this->aLogo;
        }
        //更新
        $sMediaId = empty($aData['media_id']) ? [] : $aData['media_id'];
        $sMediaUrl = empty($aData['url']) ? [] : $aData['url'];
        $iTime = empty($aUploadResult['created_at']) ? time() : $aUploadResult['created_at'];
        $aInsert = ['media_id' => $sMediaId,'media_url' => $sMediaUrl,'create_time' => $iTime,'email' => $sEmail,'user_id' => $aParam['user_id']];
        $response = Db::name('ai_author_material')->insert($aInsert);
        if($response === false){
            return json_encode(['status' => 3,'msg' => 'fail']);
        }
        return json_encode(['status' => 1,'msg' => 'success','data' => $aInsert]);
    }

    /**
     * CURL 发送请求获取Token
     * @param $appid AppID(小程序ID)
     * @param $secret AppSecret(小程序密钥)
     */

    private function getAccessToken() {
        //Token缓存值
        $sToken = Cache::get($this->sWechatAccessToken);
        //判断缓存是否存在
        if (!$sToken) { //不存在
            //组装接口地址
            $sUrl = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" 
                 . $this->sAppID . "&secret=" . $this->sAppSecret;

            $curl = curl_init();
            curl_setopt($curl, CURLOPT_URL, $sUrl);
            curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
            curl_setopt($curl, CURLOPT_TIMEOUT, $this->timeout);
            $result = curl_exec($curl);
            //请求失败
            if (curl_errno($curl)){
                $this->sError = curl_errno($curl);
                curl_close($curl);
                return FALSE;
            }
var_dump($this->sError,$result);
            $result = json_decode($result, true);

            if (!empty($result['access_token'])) {
                $sToken = $result['access_token'];
                Cache::set($this->sWechatAccessToken, $sToken, 7000); // 有效期7200秒
            }
            curl_close($curl);
        }
        return $sToken;
    }

    /**
     * CURL 发送请求上传永久素材
     * @param $sToken Token
     * @param $sPath 图片地址
     */
    public function uploadMaterial($sPath = '') {

        $aParam = $this->request->post();

        $sPath = empty($sPath) ? $aParam['path'] : $sPath;
        // $sPath = ROOT_PATH.'static/img/'.$sPath;
        // return json_encode(['status' => 1,'data' => ['media_id' => '1111111','url' => '22222']]);
        //返回结果数组
        $aResult = ['status' => 1,'msg' => '上传素材成功','data' => []];

        $sPath = empty($sPath) ? $aParam['image_path']?? '' : $sPath;//文件地址
        $sType = empty($aParam['type']) ? 'image' : $aParam['type'];//文件类型

        // 验证文件有效性
        if (!file_exists($sPath)) {
            return json_encode(['status' => 2,'msg' => '素材不存在'.$sPath]);
        }
        if (!is_readable($sPath)) {
            return json_encode(['status' => 3,'msg' => '素材不可读']);
        }
        if (filesize($sPath) > 10 * 1024 * 1024) {
            return json_encode(['status' => 4,'msg' => '素材不能超过10MB']);
        }

        //获取Token
        $sToken = $this->getAccessToken();
        if (empty($sToken)) {
            return json_encode(['status' => 5, 'msg' => '获取access_token失败']);
        }

        //CURL 请求接口
        //文件参数
        $data = [
            'media' => new \CURLFile(
                    realpath($sPath),
                    mime_content_type($sPath), // 自动检测MIME类型
                    basename($sPath)           // 上传后的文件名
            ), // 关键：使用CURLFile对象
        ];
        $sUrl = "https://api.weixin.qq.com/cgi-bin/material/add_material?access_token={$sToken}&type={$sType}";
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_URL, $sUrl);
        curl_setopt($curl, CURLOPT_POST, true); //设置为POST方式
        curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, TRUE) ; // 获取数据返回
        curl_setopt($curl, CURLOPT_PROXY,$this->proxy);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER,true);
        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST,false);
        //执行
        $response = curl_exec($curl);
        
        //请求失败
        if (curl_errno($curl)){
            curl_close($curl);
            return json_encode(['status' => 6,'msg' => "网络请求失败: " . curl_errno($curl)]);
        }
        curl_close($curl);//关闭请求

        //获取返回结果
        $response = json_decode($response, true);
        if (!empty($response['errcode']) && $response['errcode'] != 0) {
            return json_encode(['status' => 7,'msg' => "微信接口错误: [{$response['errcode']}] {$response['errmsg']}"]);
        }

        //插入数据库
        if(empty($response['media_id'])){
            return json_encode(['status' => 8,'msg' => "未获取到上传素材"]);
        }
        return json_encode(['status' => 1,'msg' => 'success','data' => $response]);
    }

    /**
     * CURL 发送请求到 微信公众号
     * @param $messages 内容
     * @param $model 模型类型
     */
    private function curlWechatApi($sUrl = '',$sJsonData = ''){

        //发送CURL请求
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_URL, $sUrl);
        curl_setopt($curl, CURLOPT_POST, true);
        curl_setopt($curl, CURLOPT_POSTFIELDS, $sJsonData);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_HTTPHEADER, [
            'Content-Type: application/json',
            'Content-Length: ' . strlen($sJsonData)
        ]);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, true); // 关闭SSL验证（生产环境建议开启）
        $response = curl_exec($curl);
        //请求失败
        if (curl_errno($curl)){
            curl_close($curl);
            return ['status' => 2,'msg' => "网络请求失败: " . curl_errno($curl)];
        }
        curl_close($curl);//关闭请求

        // 数据处理
        $response = json_decode($response, true);
        if (!empty($response['errcode'])) {
            return ['status' => 3, 'msg' => '接口请求异常'.$response['errmsg'] ?? $response['errcode']];
        }

        return ['status' => 1,'msg' => '接口请求成功','data' => $response];
    }

    /**
     * CURL 添加文章到草稿箱
     * @param $sToken Token
     * @param $sPath 图片地址
     */
     public function addDraft($aParam = []){
        //返回结果数组
        $aResult = ['status' => 1,'msg' => 'Upload draft box successfully','data' => []];

        //文章ID
        $iArticleId = empty($aParam['article_id']) ? '' : $aParam['article_id'];

        //模版ID
        $iTemplateId = empty($aParam['template_id']) ? '' : $aParam['template_id'];

        //生成模版内容
        $sContent = empty($aParam['template_content']) ? '' : $aParam['template_content'];
        if(empty($iArticleId) || empty($iTemplateId) || empty($sContent)){
            return json_encode(['status' => 2,'msg' => 'article_id OR template_content is empty']);
        }

        //查询文章是否存在
        $aWhere = ['article_id' => $iArticleId,'is_delete' => 2];
        $aAiArticle = Db::name('ai_article')->field('title_chinese as title,author,journal_id')->where($aWhere)->find();
        if(empty($aAiArticle)){
            return json_encode(['status' => 3, 'msg' => 'The article does not exist']);
        }

        //查询该模版是否推送到微信公众号
        $aWhere['template_id'] = $iTemplateId;
        $aWechatArticle = Db::name('ai_wechat_article')->where($aWhere)->find();
        if(!empty($aWechatArticle)){
            return json_encode(['status' => 4, 'msg' => 'Already uploaded to draft box']);
        }
        //查询文章封面
        $aMaterial = Db::name('ai_article_material')->field('media_id as thumb_media_id')->where('article_id',$iArticleId)->find();
        if(!empty($aMaterial)){
            $aAiArticle += $aMaterial;
        }
        $aAiArticle['content'] = $sContent;
 
        unset($aAiArticle['journal_id']);
        //获取Token
        $sToken = $this->getAccessToken();
        if (empty($sToken)) {
            return json_encode(['status' => 5, 'msg' => 'Failed to obtain access_token']);
        }
        //发送CURL请求
        $sUrl = "https://api.weixin.qq.com/cgi-bin/draft/add?access_token={$sToken}";
        //参数组装
        $sJsonData = json_encode([
            'articles' => [$aAiArticle]
        ], JSON_UNESCAPED_UNICODE);
        $aCurlResult = $this->curlWechatApi($sUrl,$sJsonData);
        if($aCurlResult['status'] != 1){
            return json_encode($aCurlResult);
        }
        $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data'];
        //判断是否推送成功
        if(empty($response['media_id'])){
            return json_encode(['status' => 5,'msg' => "Unable to obtain the uploaded draft"]);
        }

        //判断文章类型
        $article_type = empty($aParam['article_type']) ? 'news' : $aParam['article_type'];
        if(!in_array($article_type, ['news','newspic'])){
            return json_encode(['status' => 6,'msg' => "The article type does not match"]);
        }

        //是否打开评论，0不打开(默认)，1打开
        $need_open_comment = empty($aParam['need_open_comment']) ? 0 : $aParam['need_open_comment'];

        //是否粉丝才可评论，0所有人可评论(默认)，1粉丝才可评论
        $only_fans_can_comment = empty($aParam['only_fans_can_comment']) ? 0 : $aParam['only_fans_can_comment'];

        //插入文章表
        $aParam = ['media_id' => $response['media_id'],'update_time' => time(),'template_id' => $iTemplateId,'template_content' => $aParam['template_content'],'article_id' => $iArticleId,'article_type' => $article_type,'need_open_comment' => $need_open_comment,'only_fans_can_comment' => $only_fans_can_comment,'template_id' => $iTemplateId,'create_time' => time()];
        $result = Db::name('ai_wechat_article')->insert($aParam);
        if($result === false){
            return json_encode(['status' => 8,'msg' => "Article data insertion failed"]);
        }
        return json_encode($aResult);
    }

    /**
     * CURL 获取草稿箱的文章
     * @param $sToken Token
     * @param media_id string 微信公众号media_id
     */
     public function getDraft($sMediaId = ''){
        //返回结果数组
        $aResult = ['status' => 1,'msg' => 'Successfully obtained draft','data' => []];

        //获取参数
        $aParam = $this->request->post();
        $sMediaId = empty($sMediaId) ? $aParam['media_id'] : $sMediaId;
        if(empty($sMediaId)){
            return json_encode(['status' => 2, 'msg' => 'Parameter: media_id cannot be empty']);
        }

        //查询关联文章信息
        $aArticle = Db::name('ai_wechat_article')->field('media_id')->where(['media_id'=>$sMediaId])->find();
        if(empty($aArticle)){
            return json_encode(['status' => 3,'msg' => 'The article does not exist']);
        }

        //获取Token
        $sToken = $this->getAccessToken();
        if (empty($sToken)) {
            return json_encode(['status' => 4, 'msg' => 'Failed to obtain access_token']);
        }

        //CURL请求
        $sUrl = "https://api.weixin.qq.com/cgi-bin/draft/get?access_token={$sToken}";
        //参数组装
        $sJsonData = json_encode([
            'media_id' => $aArticle['media_id']
        ], JSON_UNESCAPED_UNICODE);
        //发送CURL请求
        $aCurlResult = $this->curlWechatApi($sUrl,$sJsonData);
        if($aCurlResult['status'] != 1){
            return json_encode(['status' => 5,'msg' => 'Acquisition failed']);
        }

        $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data'];
        $aResult['data'] = $response['news_item'] ?? [];
        return json_encode($aResult);
    }

    /**
     * CURL 发布草稿箱的文章
     * @param $sToken Token
     * @param article_id int 文章ID
     */
     public function publishDraft($sMediaId = ''){
        //返回结果数组
        $aResult = ['status' => 1,'msg' => 'Draft box article successfully published','data' => []];

        //获取参数
        $aParam = $this->request->post();

        $sMediaId = empty($sMediaId) ? $aParam['media_id'] : $sMediaId;

        if(empty($sMediaId)){//为空
            //必填参数验证
            //文章ID
            $iArticleId = empty($aParam['article_id']) ? '' : $aParam['article_id'];
            //模版ID
            $iTemplateId = empty($aParam['template_id']) ? '' : $aParam['template_id'];
            if(empty($iArticleId) || empty($iTemplateId)){
                return json_encode(['status' => 2,'msg' => 'Please select the article or article template to publish']);
            }

            //获取文章信息
            $aAiContent = json_decode($this->getAiArticle($iArticleId,1),true);
            $aAiContent = empty($aAiContent['data']) ? [] : $aAiContent['data'];
            $aAiArticle = empty($aAiContent['ai_article']) ? [] : $aAiContent['ai_article'];
            //判断是否生成AI内容
            if(empty($aAiArticle)){
                return json_encode(['status' => 3, 'msg' => 'The article content of WeChat official account has not been generated']);
            }

            //查询该模版是否推送到微信公众号
            $aWhere['article_id'] = $iArticleId;
            $aWhere['template_id'] = $iTemplateId;
        }
        if(!empty($sMediaId)){
            $aWhere['media_id'] = $sMediaId;
        }
        
        $aWechatArticle = Db::name('ai_wechat_article')->field('id,is_publish,media_id,publish_status')->where($aWhere)->find();
        if(empty($aWechatArticle)){
            return json_encode(['status' => 4, 'msg' => 'The article was not found in the draft box of WeChat official account']);
        }
        $iId = empty($aWechatArticle['id']) ? 0 : $aWechatArticle['id'];

        //判断是否发布
        if($aWechatArticle['publish_status'] != '-1'){
            return json_encode(['status' => 5, 'msg' => 'The article has been published, please confirm']);
        }
        //判断微信公众号media_id 是否为空
        $sMediaId = empty($aWechatArticle['media_id']) ? '' : $aWechatArticle['media_id'];
        if(empty($sMediaId)){
            return json_encode(['status' => 5,'msg' => 'The article has not been pushed to the draft box of WeChat official account, please confirm'],true);
        }

        //获取Token
        $sToken = $this->getAccessToken();
        if (empty($sToken)) {
            return json_encode(['status' => 6, 'msg' => '获取access_token失败']);
        }

        //验证公众号是否存在该文章
        $aInfo = json_decode($this->getDraft($sMediaId),true);
        if($aInfo['status'] != 1){
            return json_encode($aInfo);
        }

        // //CURL请求
        // $sUrl = "https://api.weixin.qq.com/cgi-bin/freepublish/submit?access_token={$sToken}";
        // //参数组装
        // $sJsonData = json_encode([
        //     'media_id' => $sMediaId
        // ], JSON_UNESCAPED_UNICODE);
        // //发送CURL请求
        // $aCurlResult = $this->curlWechatApi($sUrl,$sJsonData);
        // if($aCurlResult['status'] != 1){
        //     return $aCurlResult;
        // }
        // $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data'];

        // //判断是否推送成功
        // if(empty($response['publish_id'])){
        //     return json_encode(['status' => 9,'msg' => "未获取到发布草稿的publish_id"]);
        // }
$response['publish_id'] = '100000001';
        //更新文章表publish_id
        $aUpdate = ['update_time' => time(),'is_publish' => 1,'publish_id' => $response['publish_id'],'publish_status' => 1];
        $result = Db::name('ai_wechat_article')->where('id',$iId)->limit(1)->update($aUpdate);
        if($result === false){
            return json_encode(['status' => 9,'msg' => "Failed to update the status of the published article"]);
        }
        return json_encode($aResult);
    }

    /**
     * CURL 查询文章的发布状态
     * @param $sToken Token
     * @param article_id array 文章ID
     */
     public function freePublish(){
        //返回结果数组
        $aResult = ['status' => 1,'msg' => 'Successfully synchronized the publishing status of the article','data' => []];

        //获取参数
        $aParam = $this->request->post();
        $aWhere = ['is_publish' => 1,'publish_id' => ['<>',''],'publish_status' => 1,'is_delete' => 2];
        if(!empty($aParam['article_id'])){
            $aWhere['id'] = $aParam['article_id'];
        }
        //查询文章发布ID
        $aArticlePublishId = Db::name('ai_wechat_article')->where($aWhere)->column('publish_id');
        if(empty($aArticlePublishId)){
            return json_encode(['status' => 2,'msg' => 'No articles requiring synchronization status were found'],true);
        }

        //循环查询
        $aInsert = $aUpdate = [];
        foreach ($aArticlePublishId as $key => $value) {
            if(empty($value)){
                continue;
            }
            $aResult = json_decode($this->_freePublish(100000001),true);
            if($aResult['status'] != 1){
                continue;
            }
            $aData = empty($aResult['data']) ? [] : $aResult['data'];

            if(empty($aData)){
                continue;
            }
            $aInsert[] = $aData;
            $aUpdate[$aData['publish_status']][] = $value;
        }
        //插入日志表
        if(!empty($aInsert)){
            $result = Db::name('wechat_article_publish_log')->insertAll($aInsert);
        }
        //更新文章表的发布状态
        if(!empty($aUpdate)){
            Db::startTrans();
            foreach ($aUpdate as $key => $value) {
                if(empty($value)){
                    continue;
                }
                $result = Db::name('ai_wechat_article')->whereIn('publish_id',$value)->limit(count($value))->update(['publish_status' => $key,'update_time' => time()]);
            }
            Db::commit();
        }
        return json_encode($aResult);
    }
    private function _freePublish($sPublishId = '100000001'){

         //获取参数
        // $aParam = $this->request->post();
        // $sPublishId = empty($sPublishId) ? $aParam['publish_id']?? '' : $sPublishId;//文件地址

        // if(empty($sPublishId)){
        //     return json_encode(['status' => 2, 'msg' => '请选择要查询的文章发布ID']);
        // }
        // //获取Token
        // $sToken = $this->getAccessToken();
        // if (empty($sToken)) {
        //     return json_encode(['status' => 3, 'msg' => '获取access_token失败']);
        // }

        // //CURL请求
        // $sUrl = "https://api.weixin.qq.com/cgi-bin/freepublish/get?access_token={$sToken}";
        // //参数组装
        // $sJsonData = json_encode([
        //     'publish_id' => $sPublishId
        // ], JSON_UNESCAPED_UNICODE);
        // //发送CURL请求
        // $aCurlResult = $this->curlWechatApi($sUrl,$sJsonData);
        // if($aCurlResult['status'] != 1){
        //     return $aCurlResult;
        // }
        // $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data'];
        $response = ['publish_id' => '1000001','publish_status' => 2,'article_id'=> '','article_detail','fail_idx' => [1,2]];
        //log日志需要参数
        $aField = ['publish_id','publish_status'  ,'article_id'  ,'article_detail' ,'fail_idx'  ,'create_time'];

        $aInsert = [];
        foreach ($aField as $value) {
            if($value == 'create_time'){
                $aInsert[$value] = time();
                continue;
            }
            $aInsert[$value] =  empty($response[$value]) ? ' ' : $response[$value];
            if(is_array($aInsert[$value])){
                $aInsert[$value] = json_encode($aInsert[$value]);
            }
        }
        $aResult['status'] = 1;
        $aResult['data'] = $aInsert;
        return json_encode($aResult);
    }
}