Browse Source

排除报警

xueyiming 3 months ago
parent
commit
e0f681802f

+ 8 - 0
common-module/src/main/java/com/tzld/piaoquan/growth/common/common/constant/MessageConstant.java

@@ -1,5 +1,8 @@
 package com.tzld.piaoquan.growth.common.common.constant;
 
+import java.util.ArrayList;
+import java.util.List;
+
 public interface MessageConstant {
 
     //推送保底内容
@@ -9,6 +12,11 @@ public interface MessageConstant {
 
     String specialText = "亲爱的老友好!温水暖胃勤添衣,养生小视频更新啦!点开小程序看看,精彩不断~";
 
+    List<Long> specialStaffIdList = new ArrayList<Long>() {{
+        add(16L);
+        add(17L);
+    }};
+
     //小程序id
     String appid = "wxbdd2a2e93d9a6e25";
 

+ 1 - 4
common-module/src/main/java/com/tzld/piaoquan/growth/common/service/Impl/MessageServiceImpl.java

@@ -21,6 +21,7 @@ import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
 
+import static com.tzld.piaoquan.growth.common.common.constant.MessageConstant.specialStaffIdList;
 import static com.tzld.piaoquan.growth.common.common.constant.WeComConstant.POST_WE_COM_ADD_MSG_TEMPLATE;
 
 
@@ -37,10 +38,6 @@ public class MessageServiceImpl implements MessageService {
     @Autowired
     private PreSpecialSendMessageMapper preSpecialSendMessageMapper;
 
-    private static final List<Long> specialStaffIdList = new ArrayList<Long>() {{
-        add(16L);
-        add(17L);
-    }};
 
     @Override
     public boolean pushWeComMessage(JSONObject jsonObject, Long corpId) {

+ 3 - 1
offline-module/src/main/java/com/tzld/piaoquan/offline/job/WeComHistoryDataJob.java

@@ -3,6 +3,7 @@ package com.tzld.piaoquan.offline.job;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Lists;
+import com.tzld.piaoquan.growth.common.common.constant.MessageConstant;
 import com.tzld.piaoquan.growth.common.common.constant.TimeConstant;
 import com.tzld.piaoquan.growth.common.common.enums.MessageAttachmentTypeEnum;
 import com.tzld.piaoquan.growth.common.component.HttpPoolClient;
@@ -35,6 +36,7 @@ import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 import static com.tzld.piaoquan.growth.common.common.constant.MessageConstant.MAX_VIDEO_NUM;
+import static com.tzld.piaoquan.growth.common.common.constant.MessageConstant.specialStaffIdList;
 import static com.tzld.piaoquan.growth.common.common.constant.WeComConstant.*;
 import static com.tzld.piaoquan.growth.common.common.enums.SourceEnum.HISTORICAL_TOP;
 import static com.tzld.piaoquan.growth.common.common.enums.SourceEnum.MANUAL;
@@ -155,7 +157,7 @@ public class WeComHistoryDataJob {
             long count = sendCountList.get(0) + sendCountList.get(1) + sendCountList.get(2) + sendCountList.get(3);
             allCount += count;
             notSend += sendCountList.get(0);
-            if (count != 0 && sendCountList.get(0) > 0) {
+            if (count != 0 && sendCountList.get(0) > 0 && !specialStaffIdList.contains(sendDetail.getStaffId())) {
                 LarkRobotUtil.sendMessage(sendDetail.getRemark() + "存在未发送记录,请检查");
                 if (sendDetail.getStaffId() == 3) {
                     LarkRobotUtil.sendTipMessage(sendDetail.getRemark() + "存在未发送记录,请检查");