From cb880d510f0b01bbd0b6a5b21a5436d93f983db9 Mon Sep 17 00:00:00 2001 From: jianjun Date: Sat, 16 Jul 2022 18:40:09 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E6=8E=89=E6=9B=B4=E6=96=B0=E6=88=BF?= =?UTF-8?q?=E5=B1=8B=E5=86=85=E7=9A=84=E5=B1=85=E6=B0=91=E6=95=B0=20?= =?UTF-8?q?=E8=BF=99=E4=B8=AA=E5=8E=8B=E5=8A=9B=E5=A4=AA=E5=A4=A7=20?= =?UTF-8?q?=E5=BE=85=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/epmet/mq/listener/ICWarnStatsEventListener.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/mq/listener/ICWarnStatsEventListener.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/mq/listener/ICWarnStatsEventListener.java index e74c011246..6feab639a7 100644 --- a/epmet-user/epmet-user-server/src/main/java/com/epmet/mq/listener/ICWarnStatsEventListener.java +++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/mq/listener/ICWarnStatsEventListener.java @@ -70,7 +70,9 @@ public class ICWarnStatsEventListener implements MessageListenerConcurrently { IcResiUserAddMQMsg obj = JSON.parseObject(msg, IcResiUserAddMQMsg.class); log.info("obj is {}", JSON.toJSONString(obj)); try { - if (!resiWarnStats(obj)||!updateIcNatResiFlag(tags, obj)||!updateIcHouseResiNumber(obj)){ + //todo 统计预警人数和 更新屋内居民数 用定时任务跑吧 这样太费劲 + //||!updateIcHouseResiNumber(obj) + if (!resiWarnStats(obj)||!updateIcNatResiFlag(tags, obj)){ throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(),"消费失败,等待重新消费"); } } catch (RenException e) {