diff --git a/application/api/controller/Cronwechat.php b/application/api/controller/Cronwechat.php index e0ee6be..bedd837 100644 --- a/application/api/controller/Cronwechat.php +++ b/application/api/controller/Cronwechat.php @@ -75,9 +75,11 @@ class Cronwechat extends Controller } //插入操作日志 if(!empty($aLog)){ - $result = Db::name('wechat_crontab_log')->insertAll($aLog); - if($result === false){ - $this->showMessage('插入日志记录失败:'.json_encode($aLog)."\n",2); + $result = json_decode($oAiarticle->addWechatLog($aLog)); + $iStatus = empty($result['status']) ? 0 : $result['status']; + $sMsg = empty($result['msg']) ? '插入日志记录失败' : $result['msg']; + if($iStatus != 1){ + $this->showMessage($sMsg,2); } } $this->showMessage('AI生成的文章推送草稿箱完成:'.$sDate."\n",1); @@ -138,9 +140,11 @@ class Cronwechat extends Controller } //插入操作日志 if(!empty($aLog)){ - $result = Db::name('wechat_crontab_log')->insertAll($aLog); - if($result === false){ - $this->showMessage('插入日志记录失败:'.json_encode($aLog)."\n",2); + $result = json_decode($oAiarticle->addWechatLog($aLog)); + $iStatus = empty($result['status']) ? 0 : $result['status']; + $sMsg = empty($result['msg']) ? '插入日志记录失败' : $result['msg']; + if($iStatus != 1){ + $this->showMessage($sMsg,2); } } $this->showMessage('AI生成的文章发布草稿箱完成:'.$sDate."\n",1); @@ -197,9 +201,11 @@ class Cronwechat extends Controller } //插入操作日志 if(!empty($aLog)){ - $result = Db::name('wechat_crontab_log')->insertAll($aLog); - if($result === false){ - $this->showMessage('插入日志记录失败:'.json_encode($aLog)."\n",2); + $result = json_decode($oAiarticle->addWechatLog($aLog)); + $iStatus = empty($result['status']) ? 0 : $result['status']; + $sMsg = empty($result['msg']) ? '插入日志记录失败' : $result['msg']; + if($iStatus != 1){ + $this->showMessage($sMsg,2); } } $this->showMessage('AI生成的文章发布状态查询完成:'.$sDate."\n",1);