diff --git a/application/api/controller/Monitor.php b/application/api/controller/Monitor.php index 08d8905..b424233 100644 --- a/application/api/controller/Monitor.php +++ b/application/api/controller/Monitor.php @@ -470,6 +470,33 @@ class Monitor extends Base $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 return jsonSuccess($res['data']); } @@ -485,7 +512,6 @@ class Monitor extends Base $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'])){ @@ -510,7 +536,7 @@ class Monitor extends Base } $aData['list'][$key] += $aEmail; } - $res['data']['list'] = $aData; + $res['data'] = $aData; } //新增邮件发送数量 chengxiaoling 20250520 end return jsonSuccess($res['data']);