diff --git a/application/api/job/RecommendReviewer.php b/application/api/job/RecommendReviewer.php index 7d7d832..96145bf 100644 --- a/application/api/job/RecommendReviewer.php +++ b/application/api/job/RecommendReviewer.php @@ -34,23 +34,35 @@ class RecommendReviewer $oReviewer = new Reviewer; $aResult = json_decode($oReviewer->recommend($aParam),true); $iStatus = empty($aResult['status']) ? 0 : $aResult['status']; - $sMsg = empty($aResult['msg']) ? '获取推荐审稿人信息失败' : $aResult['msg']; - - //插入审稿人记录表 + $sMsg = empty($aResult['msg']) ? '' : $aResult['msg']; + //数量 + $iCount = empty($aResult['data']['total']) ? 0 : $aResult['data']['total']; + //推荐数量 + $iSize = empty($aResult['data']['size']) ? 0 : $aResult['data']['size']; + //判断是否给期刊管理者发邮件【数据库的审稿数量小于推荐数量】 + if($iCount < $iSize){ + $aSendEmailResult = json_decode($oReviewer->emailForEditor($aParam),true); + $sMsg .= ';'; + $sMsg .= empty($aSendEmailResult['msg']) ? '发送邮件入队成功' : $aSendEmailResult['msg']; + } + //推荐审稿人数据 $aResult = empty($aResult['data']['lists']) ? [] : $aResult['data']['lists']; if(empty($aResult)){ - $sMsg = 'No qualified reviewers were selected'; + $sMsg .= ';'; + $sMsg .= 'No qualified reviewers were selected'; } if(!empty($aResult)){ $aParam = ['article_id' => $iArticleId,'reviewer_id' => array_column($aResult, 'reviewer_id')]; $aResult = json_decode($oReviewer->add($aParam),true); - $iStatus = empty($aResult['status']) ? 0 : $aResult['status']; - $sMsg = empty($aResult['msg']) ? 'Reviewer data insertion failed' : $aResult['msg']; + $iStatus = empty($aResult['status']) ? 0 : $aResult['status']; + $sMsg .= ';'; + $sMsg .= empty($aResult['msg']) ? 'Reviewer data insertion failed' : $aResult['msg']; //发送邀请审稿人审稿邮件 if($iStatus == 1){ $aResult = json_decode($oReviewer->email($aParam),true); $iStatus = empty($aResult['status']) ? 0 : $aResult['status']; - $sMsg = empty($aResult['msg']) ? 'Reviewer data insertion failed' : $aResult['msg']; + $sMsg .= ';'; + $sMsg .= empty($aResult['msg']) ? 'Reviewer data insertion failed' : $aResult['msg']; } } }