活码报警通知限制通知次数

src/main/java/com/mokamrp/privates/constant/RedisKey.java

@@ -37,6 +37,8 @@ public class RedisKey {
     public static final String PanWxFosterTaskSync = "pan_wxfoster_task_sync";
     //.盘古 微信养号站点列表
     public static final String PanWxFosterStationInfo = "pan_wxfoster_station_info";
+    //.盘古 活码报警记录
+    public static final String PanPromoteNoticeRecode = "pan_promote_notice_recode:";
 
 }
 

src/main/java/com/mokamrp/privates/task/pangu/CheckPromoteView.java

@@ -25,6 +25,7 @@ import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Set;
+import java.util.concurrent.TimeUnit;
 
 @Component
 public class CheckPromoteView {
@@ -60,7 +61,15 @@ public class CheckPromoteView {
                         resetCustserviceViewTask.addRedis(promoteQrcodePool.getPromoteId(),promoteQrcodePool.getCustserviceId(),promoteQrcodePool.getWeight());
                     }
                 }else{
+                    Integer hour = LocalDateTime.now().getHour();
+                    String key = promoteCode.getId().toString()+"#"+hour.toString();
+                    Long isNotice = stringRedisTemplate.opsForHyperLogLog().size(RedisKey.PanPromoteNoticeRecode+key,key);
+                    if (isNotice != null && isNotice > 0){
+                        continue;
+                    }
                     Cmd.sendFeishuMsg(feishu,"[警告]:活码ID:"+promoteCode.getId()+"|"+promoteCode.getName()+",当前小时所有二维码阈值上限，需要人工添加二维码");
+                    stringRedisTemplate.opsForHyperLogLog().add(RedisKey.PanPromoteNoticeRecode+key,key);
+                    stringRedisTemplate.expire(RedisKey.PanPromoteNoticeRecode+key,4800, TimeUnit.SECONDS);
                 }
             }
         }