From 8547b7c552e1130f8b937e678596c8719ca15def Mon Sep 17 00:00:00 2001 From: chengxl Date: Tue, 20 May 2025 11:50:07 +0800 Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E8=A2=AB=E5=BC=95=E7=94=A8?= =?UTF-8?q?=E7=9A=84=E6=96=87=E7=AB=A0=E9=82=AE=E4=BB=B6=E5=8F=91=E9=80=81?= =?UTF-8?q?=E6=95=B0=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- application/api/controller/Monitor.php | 28 ++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) diff --git a/application/api/controller/Monitor.php b/application/api/controller/Monitor.php index b4b5f3c..08d8905 100644 --- a/application/api/controller/Monitor.php +++ b/application/api/controller/Monitor.php @@ -485,6 +485,34 @@ 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']['list'] = $aData; + } + //新增邮件发送数量 chengxiaoling 20250520 end return jsonSuccess($res['data']); }