接口调整

application/common/Wechat.php

@@ -0,0 +1,496 @@
+<?php
+namespace app\common;
+use think\Cache;
+use think\Db;
+
+class Wechat
+{
+    protected $sAppID; //= 'wx03cb871b66e34e10';
+    protected $sAppSecret; //= 'f59ccaf00383dcfab489292c4697620a';
+    protected $sWechatAccessToken = 'wechat_access_token';
+    protected $timeout;
+    protected $proxy;
+
+
+    public function __construct(\think\Request $request = null) {
+
+    }
+
+    /**
+     * CURL 发送请求获取Token
+     * @param $appid AppID(小程序ID)
+     * @param $secret AppSecret(小程序密钥)
+     */
+
+    private function getAccessToken() {
+        //Token缓存值
+        $sToken = Cache::get($this->sWechatAccessToken.'_'.$this->sAppID);
+        //判断缓存是否存在
+        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;
+            }
+            $result = json_decode($result, true);
+
+            if (!empty($result['access_token'])) {
+                $sToken = $result['access_token'];
+                Cache::set($this->sWechatAccessToken.'_'.$this->sAppID, $sToken, 7000); // 有效期7200秒
+            }
+            curl_close($curl);
+        }
+        return $sToken;
+    }
+
+    /**
+     * CURL 发送请求上传永久素材
+     * @param $sToken Token
+     * @param $sPath 图片地址
+     */
+    public function uploadMaterial($aParam = []) {
+        $aParam = empty($aParam) ? $this->request->post() : $aParam;
+
+        //图片地址
+        $sPath = empty($aParam['image_url']) ? '' : $aParam['image_url'];
+        if(empty($sPath)){
+            return json_encode(['status' => 2,'msg' => 'Please choose to upload materials']);
+        }
+
+        // 获取微信公众号APPID和APPKEY
+        $this->sAppID = empty($aParam['wechat_app_id']) ? '' : $aParam['wechat_app_id'];
+        $this->sAppSecret = empty($aParam['wechat_app_secret']) ? '' : $aParam['wechat_app_secret'];
+        if(empty($this->sAppID) || empty($this->sAppSecret)){
+            return json_encode(['status' => 2,'msg' => 'Please configure the AppID and AppSecret']);
+        }
+
+        $sType = empty($aParam['type']) ? 'image' : $aParam['type'];//文件类型
+
+        // 验证文件有效性
+        if (!file_exists($sPath)) {
+            return json_encode(['status' => 3,'msg' => 'The material does not exist'.$sPath]);
+        }
+        if (!is_readable($sPath)) {
+            return json_encode(['status' => 3,'msg' => 'The material is unreadable']);
+        }
+        if (filesize($sPath) > 10 * 1024 * 1024) {
+            return json_encode(['status' => 4,'msg' => 'The material cannot exceed 10MB']);
+        }
+
+        //获取Token
+        $sToken = $this->getAccessToken();
+        if (empty($sToken)) {
+            return json_encode(['status' => 5, 'msg' => 'Failed to obtain 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' => "Network request failed: " . curl_errno($curl)]);
+        }
+        curl_close($curl);//关闭请求
+
+        //获取返回结果
+        $response = json_decode($response, true);
+        if (!empty($response['errcode']) && $response['errcode'] != 0) {
+            return json_encode(['status' => 7,'msg' => "WeChat interface error: [{$response['errcode']}] {$response['errmsg']}"]);
+        }
+
+        //插入数据库
+        if(empty($response['media_id'])){
+            return json_encode(['status' => 8,'msg' => "Unable to obtain uploaded materials"]);
+        }
+        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' => "Network request failed: " . curl_errno($curl)];
+        }
+        curl_close($curl);//关闭请求
+
+        // 数据处理
+        $response = json_decode($response, true);
+        if (!empty($response['errcode'])) {
+            return ['status' => 3, 'msg' => 'WeChat interface error:'.$response['errmsg'] ?? $response['errcode']];
+        }
+
+        return ['status' => 1,'msg' => 'success','data' => $response];
+    }
+
+    /**
+     * CURL 添加文章到草稿箱
+     * @param $sToken Token
+     * @param $sPath 图片地址
+     */
+    public function addDraft($aParam = []){
+
+        $aParam = empty($aParam) ? $this->request->post() : $aParam;
+
+        //文章ID
+        $iArticleId = empty($aParam['article_id']) ? '' : $aParam['article_id'];
+        if(empty($iArticleId)){
+            return json_encode(['status' => 2,'msg' => 'article_id is empty']);
+        }
+        //模版ID
+        $iTemplateId = empty($aParam['template_id']) ? '' : $aParam['template_id'];
+        if(empty($iTemplateId)){
+            return json_encode(['status' => 2,'msg' => 'Template ID is empty']);
+        }
+        //发布公众号ID
+        $sWechatId = empty($aParam['wechat_id']) ? 0 : $aParam['wechat_id'];
+        if(empty($sWechatId)){
+            return json_encode(['status' => 2,'msg' => 'Please select the official account to be pushed']);
+        }
+        //生成模版内容
+        $sContent = empty($aParam['content']) ? '' : $aParam['content'];
+        if(empty($sContent)){
+            return json_encode(['status' => 2,'msg' => 'The published content is empty']);
+        }
+
+        // 获取微信公众号APPID和APPKEY
+        $this->sAppID = empty($aParam['wechat_app_id']) ? '' : $aParam['wechat_app_id'];
+        $this->sAppSecret = empty($aParam['wechat_app_secret']) ? '' : $aParam['wechat_app_secret'];
+        if(empty($this->sAppID) || empty($this->sAppSecret)){
+            return json_encode(['status' => 2,'msg' => 'Please configure the AppID and AppSecret']);
+        }
+
+        //获取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' => [$aParam]
+        ], 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']) ? 1 : $aParam['need_open_comment'];
+
+        //是否粉丝才可评论，0所有人可评论(默认)，1粉丝才可评论
+        $only_fans_can_comment = empty($aParam['only_fans_can_comment']) ? 1 : $aParam['only_fans_can_comment'];
+
+        //插入文章表
+        $aParam = ['media_id' => $response['media_id'],'update_time' => time(),'template_id' => $iTemplateId,'template_content' => $sContent,'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(),'wechat_id' => $sWechatId];
+        $result = Db::name('ai_wechat_article')->insert($aParam);
+        if($result === false){
+            return json_encode(['status' => 8,'msg' => "Article data insertion failed"]);
+        }
+        return json_encode(['status' => 1,'msg' => 'Upload draft box successfully','data' => []]);
+    }
+
+    /**
+     * 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' => 'Failed to obtain 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' => 'Failed to obtain 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);
+    }
+}