打卡触发预警问题处理

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/SignServiceImpl.java

@@ -192,10 +192,9 @@ public class SignServiceImpl extends BaseService<SignDto, Sign, SignMapper> impl
         log.info("开始出勤统计=========");
         List<Map<String, Object>> mapSign = this.baseMapper.querySignInfo();
         List<Map<String, Object>> mapList = new ArrayList<>();
-        for (Map<String, Object> m : mapSign
-        ) {
+        for (Map<String, Object> m : mapSign) {
             // 判断至少8人出勤
-            if (Integer.parseInt(m.get("num").toString()) < 8) {
+            if (Integer.parseInt(m.get("num").toString()) >= 8) {
                 Map<String, Object> map = new HashMap<>();
                 map.put("bizOrgCode", m.get("bizOrgCode"));
                 map.put("bizOrgName", m.get("bizOrgName"));
@@ -209,7 +208,7 @@ public class SignServiceImpl extends BaseService<SignDto, Sign, SignMapper> impl
                 log.info(String.format("发送eqm转kafka消息失败：%s", exp.getMessage()));
             }
         }
-        if (mapSign.size() == 0) {
+        if (mapList.size() == 0) {
             Map<String, Object> map = new HashMap<>();
             map.put("bizOrgCode", "");
             mapList.add(map);