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

接口调整

Browse Source
This commit is contained in:
chengxl
2025-05-18 00:03:20 +08:00
parent da215d6dd0
commit ed84ad7477
1 changed files with 48 additions and 175 deletions
Download Patch File Download Diff File Expand all files Collapse all files

223
application/common/Wechat.php
View File

@@ -220,34 +220,12 @@ class Wechat
'articles' => [$aParam] 'articles' => [$aParam]
], JSON_UNESCAPED_UNICODE); ], JSON_UNESCAPED_UNICODE);
$aCurlResult = $this->curlWechatApi($sUrl,$sJsonData); $aCurlResult = $this->curlWechatApi($sUrl,$sJsonData);
if($aCurlResult['status'] != 1){
return json_encode($aCurlResult);
}
$response = empty($aCurlResult['data']) ? [] : $aCurlResult['data']; $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data'];
//判断是否推送成功 //判断是否推送成功
if(empty($response['media_id'])){ if(empty($response['media_id'])){
return json_encode(['status' => 5,'msg' => "Unable to obtain the uploaded draft"]); return json_encode(['status' => 5,'msg' => "Unable to obtain the uploaded draft"]);
} }
return json_encode(['status' => 1,'msg' => 'Upload draft box successfully','data' => $response]);
//判断文章类型
$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' => []]);
} }
/** /**
@@ -255,21 +233,20 @@ class Wechat
* @param $sToken Token * @param $sToken Token
* @param media_id string 微信公众号media_id * @param media_id string 微信公众号media_id
*/ */
public function getDraft($sMediaId = ''){ public function getDraft($aParam = []){
//返回结果数组
$aResult = ['status' => 1,'msg' => 'Successfully obtained draft','data' => []];
//获取参数 //获取参数
$aParam = $this->request->post(); $aParam = empty($aParam) ? $this->request->post() : $aParam;
$sMediaId = empty($sMediaId) ? $aParam['media_id'] : $sMediaId; $sMediaId = empty($sMediaId) ? $aParam['media_id'] : $sMediaId;
if(empty($sMediaId)){ if(empty($sMediaId)){
return json_encode(['status' => 2, 'msg' => 'Parameter: media_id cannot be empty']); return json_encode(['status' => 2, 'msg' => 'Parameter: media_id cannot be empty']);
} }
//查询关联文章信息 //获取微信公众号APPID和APPKEY
$aArticle = Db::name('ai_wechat_article')->field('media_id')->where(['media_id'=>$sMediaId])->find(); $this->sAppID = empty($aParam['wechat_app_id']) ? '' : $aParam['wechat_app_id'];
if(empty($aArticle)){ $this->sAppSecret = empty($aParam['wechat_app_secret']) ? '' : $aParam['wechat_app_secret'];
return json_encode(['status' => 3,'msg' => 'The article does not exist']); if(empty($this->sAppID) || empty($this->sAppSecret)){
return json_encode(['status' => 2,'msg' => 'Please configure the AppID and AppSecret']);
} }
//获取Token //获取Token
@@ -282,17 +259,17 @@ class Wechat
$sUrl = "https://api.weixin.qq.com/cgi-bin/draft/get?access_token={$sToken}"; $sUrl = "https://api.weixin.qq.com/cgi-bin/draft/get?access_token={$sToken}";
//参数组装 //参数组装
$sJsonData = json_encode([ $sJsonData = json_encode([
'media_id' => $aArticle['media_id'] 'media_id' => $sMediaId
], JSON_UNESCAPED_UNICODE); ], JSON_UNESCAPED_UNICODE);
//发送CURL请求 //发送CURL请求
$aCurlResult = $this->curlWechatApi($sUrl,$sJsonData); $aCurlResult = $this->curlWechatApi($sUrl,$sJsonData);
if($aCurlResult['status'] != 1){ $iStatus = empty($aCurlResult['status']) ? 0 : $aCurlResult['status'];
return json_encode(['status' => 5,'msg' => 'Acquisition failed']); $sMsg = empty($aCurlResult['msg']) ? 'Acquisition failed': $aCurlResult['msg'];
if($iStatus != 1){
return json_encode(['status' => 5,'msg' => $sMsg]);
} }
$response = empty($aCurlResult['data']) ? [] : $aCurlResult['data']; $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data'];
$aResult['data'] = $response['news_item'] ?? []; return json_encode(['status' => 1,'msg' => 'Successfully obtained draft','data' => $response['news_item'] ?? []]);
return json_encode($aResult);
} }
/** /**
@@ -300,56 +277,20 @@ class Wechat
* @param $sToken Token * @param $sToken Token
* @param article_id int 文章ID * @param article_id int 文章ID
*/ */
public function publishDraft($sMediaId = ''){ public function publishDraft($aParam = []){
//返回结果数组
$aResult = ['status' => 1,'msg' => 'Draft box article successfully published','data' => []];
//获取参数 //获取参数
$aParam = $this->request->post(); $aParam = empty($aParam) ? $this->request->post() : $aParam;
//必填参数验证
$sMediaId = empty($sMediaId) ? $aParam['media_id'] : $sMediaId; $sMediaId = empty($aParam['media_id']) ? '' : $aParam['media_id'];
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)){ 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); return json_encode(['status' => 2, 'msg' => 'Please select the WeChat official account to push']);
}
//获取微信公众号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 //获取Token
@@ -357,10 +298,10 @@ class Wechat
if (empty($sToken)) { if (empty($sToken)) {
return json_encode(['status' => 6, 'msg' => 'Failed to obtain access_token']); return json_encode(['status' => 6, 'msg' => 'Failed to obtain access_token']);
} }
//验证公众号是否存在该文章 //验证公众号是否存在该文章
$aInfo = json_decode($this->getDraft($sMediaId),true); $aInfo = json_decode($this->getDraft($aParam),true);
if($aInfo['status'] != 1){ $iStatus = empty($aInfo['status']) ? 0 : $aInfo['status'];
if($iStatus != 1){
return json_encode($aInfo); return json_encode($aInfo);
} }
@@ -376,19 +317,12 @@ class Wechat
// return $aCurlResult; // return $aCurlResult;
// } // }
// $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data']; // $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data'];
$response['publish_id'] = '100000001';
// //判断是否推送成功 //判断是否推送成功
// if(empty($response['publish_id'])){ if(empty($response['publish_id'])){
// return json_encode(['status' => 9,'msg' => "未获取到发布草稿的publish_id"]); return json_encode(['status' => 9,'msg' => "The publish_id of the published draft was not obtained"]);
// }
$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); return json_encode(['status' => 1,'msg' => 'Draft box article successfully published','data' => $response]);
} }
/** /**
@@ -396,66 +330,21 @@ class Wechat
* @param $sToken Token * @param $sToken Token
* @param article_id array 文章ID * @param article_id array 文章ID
*/ */
public function freePublish(){ public function queryStatus($aParam =[]){
//返回结果数组
$aResult = ['status' => 1,'msg' => 'Successfully synchronized the publishing status of the article','data' => []];
//获取参数 //获取参数
$aParam = $this->request->post(); $aParam = empty($aParam) ? $this->request->post() : $aParam;
$aWhere = ['is_publish' => 1,'publish_id' => ['<>',''],'publish_status' => 1,'is_delete' => 2]; $sPublishId = empty($aParam['publish_id']) ? '' : $aParam['publish_id'];
if(!empty($aParam['article_id'])){ if(empty($sPublishId)){
$aWhere['id'] = $aParam['article_id']; return json_encode(['status' => 2, 'msg' => 'Publish_id cannot be empty']);
} }
//查询文章发布ID //获取微信公众号APPID和APPKEY
$aArticlePublishId = Db::name('ai_wechat_article')->where($aWhere)->column('publish_id'); $this->sAppID = empty($aParam['wechat_app_id']) ? '' : $aParam['wechat_app_id'];
if(empty($aArticlePublishId)){ $this->sAppSecret = empty($aParam['wechat_app_secret']) ? '' : $aParam['wechat_app_secret'];
return json_encode(['status' => 2,'msg' => 'No articles requiring synchronization status were found'],true); if(empty($this->sAppID) || empty($this->sAppSecret)){
return json_encode(['status' => 2,'msg' => 'Please configure the AppID and AppSecret']);
} }
//循环查询
$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 // //获取Token
// $sToken = $this->getAccessToken(); // $sToken = $this->getAccessToken();
// if (empty($sToken)) { // if (empty($sToken)) {
@@ -470,27 +359,11 @@ class Wechat
// ], JSON_UNESCAPED_UNICODE); // ], JSON_UNESCAPED_UNICODE);
// //发送CURL请求 // //发送CURL请求
// $aCurlResult = $this->curlWechatApi($sUrl,$sJsonData); // $aCurlResult = $this->curlWechatApi($sUrl,$sJsonData);
// if($aCurlResult['status'] != 1){
// return $aCurlResult;
// }
// $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data']; // $response = empty($aCurlResult['data']) ? [] : $aCurlResult['data'];
// if(empty($response)){
// return json_encode(['status' => 4,'msg' => 'Query failed']);
// }
$response = ['publish_id' => '1000001','publish_status' => 2,'article_id'=> '','article_detail','fail_idx' => [1,2]]; $response = ['publish_id' => '1000001','publish_status' => 2,'article_id'=> '','article_detail','fail_idx' => [1,2]];
//log日志需要参数 return json_encode(['status' => 1,'msg' => 'query was successful','data' => $response]);
$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);
} }
} }