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-21 17:38:12 +08:00
parent ebe6390d80
commit a1564150df
1 changed files with 28 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
application/api/controller/Monitor.php
View File

@@ -470,22 +470,6 @@ class Monitor extends Base
$program = []; $program = [];
$program['issn'] = $data['issn']; $program['issn'] = $data['issn'];
$res = object_to_array(json_decode(myPost($url,$program))); $res = object_to_array(json_decode(myPost($url,$program)));
return jsonSuccess($res['data']);
}
public function getCiteListForEditorPMonth(){
$data = $this->request->post();
$rule = new Validate([
"issn"=>"require"
]);
if(!$rule->check($data)){
return jsonError($rule->getError());
}
$url = "http://journalapi.tmrjournals.com/public/index.php/master/Journal/getCiteListPForSubmission";
$program = [];
$program['issn'] = $data['issn'];
$res = object_to_array(json_decode(myPost($url,$program)));
//新增邮件发送数量 chengxiaoling 20250520 start //新增邮件发送数量 chengxiaoling 20250520 start
$aData = empty($res['data']) ? [] : $res['data']; $aData = empty($res['data']) ? [] : $res['data'];
if(!empty($aData['list'])){ if(!empty($aData['list'])){
@@ -510,7 +494,49 @@ class Monitor extends Base
} }
$aData['list'][$key] += $aEmail; $aData['list'][$key] += $aEmail;
} }
$res['data']['list'] = $aData; $res['data'] = $aData;
}
//新增邮件发送数量 chengxiaoling 20250520 end
return jsonSuccess($res['data']);
}
public function getCiteListForEditorPMonth(){
$data = $this->request->post();
$rule = new Validate([
"issn"=>"require"
]);
if(!$rule->check($data)){
return jsonError($rule->getError());
}
$url = "http://journalapi.tmrjournals.com/public/index.php/master/Journal/getCiteListPForSubmission";
$program = [];
$program['issn'] = $data['issn'];
$res = object_to_array(json_decode(myPost($url,$program)));
//新增邮件发送数量 chengxiaoling 20250520 start
$aData = empty($res['data']) ? [] : $res['data'];
if(!empty($aData['list'])){
$aArticleCiteId = array_column($aData['list'], 'article_cite_id');
//查询邮件发送数量
$aWhere = ['article_cite_id' => ['in',$aArticleCiteId]];
$aEmail = Db::name('email_article_cite')->field('article_cite_id,count(article_cite_id) as num,is_success')->where($aWhere)->group('article_cite_id,is_success')->select();
if(!empty($aEmail)){
$aEmailLog = [];
foreach ($aEmail as $key => $value) {
$aEmailLog[$value['article_cite_id']][$value['is_success']] = $value['num'];
}
}
//数据处理
foreach ($aData['list'] as $key => $value) {
$aEmail = ['email_success' => 0,'email_fail' => 0];
//邮件发送数量
$aEmailInfo = empty($aEmailLog[$value['article_cite_id']]) ? [] : $aEmailLog[$value['article_cite_id']];
if(!empty($aEmailInfo)){
$aEmail['email_success'] = empty($aEmailInfo[1]) ? $aEmail['email_success'] : $aEmailInfo[1];
$aEmail['email_fail'] = empty($aEmailInfo[2]) ? $aEmail['email_fail'] : $aEmailInfo[2];
}
$aData['list'][$key] += $aEmail;
}
$res['data'] = $aData;
} }
//新增邮件发送数量 chengxiaoling 20250520 end //新增邮件发送数量 chengxiaoling 20250520 end
return jsonSuccess($res['data']); return jsonSuccess($res['data']);