Forráskód Böngészése

关闭企业健康状态通知

ximinghao 2 hónapja
szülő
commit
3396fa741e
1 módosított fájl, 10 hozzáadás és 10 törlés
  1. 10 10
      src/main/java/com/skyversation/xjcy/Timer.java

+ 10 - 10
src/main/java/com/skyversation/xjcy/Timer.java

@@ -187,15 +187,15 @@ public class Timer {
         }
         List<User> users = dMSService.query(authService.getTokenOfServiceAccount(),DMSQuery.USER_BIND_ENTERPRISE,User.class,actuallyTime.toLocalDate());
         Map<String, List<User>> userMap = users.stream().filter(u->u.getCGlGs()!=null).collect(Collectors.groupingBy(User::getCGlGs));
-
-        enterpriseHealthComputer.getResults().stream().filter(EnterpriseHealth::isPositive).forEach(e->{
-            String enterpriseCode = e.getCEnterpriseCode();
-            List<User> userList = userMap.get(enterpriseCode);
-            if (userList!=null) {
-                for (User user : userList) {
-                    messageService.sendMessageByEnterpriseHealth(e,actuallyTime,user);
-                }
-            }
-        });
+//暂时关闭
+//        enterpriseHealthComputer.getResults().stream().filter(EnterpriseHealth::isPositive).forEach(e->{
+//            String enterpriseCode = e.getCEnterpriseCode();
+//            List<User> userList = userMap.get(enterpriseCode);
+//            if (userList!=null) {
+//                for (User user : userList) {
+//                    messageService.sendMessageByEnterpriseHealth(e,actuallyTime,user);
+//                }
+//            }
+//        });
     }
 }