From b9fd2657a3d528881e4d1f7cae12ca8e2d63951a Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Wed, 30 Aug 2023 09:33:31 +0800 Subject: [PATCH] fix:补充提交 --- screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java | 8 ++++++++ 1 files changed, 8 insertions(+), 0 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java b/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java index 1f80531..431132d 100644 --- a/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java +++ b/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java @@ -1,5 +1,6 @@ package com.moral.api.kafka.consumer; +import com.alibaba.fastjson.JSONObject; import com.moral.api.service.*; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.consumer.ConsumerRecord; @@ -101,6 +102,13 @@ //������������ // data.remove("time"); data.remove("entryTime"); + Map<String, Object> deviceByMac = deviceService.getDeviceByMac(mac.toString()); + HashMap<String, Object> map = (HashMap<String, Object>) deviceByMac.get("organization"); + String id = map.get("id").toString(); + if (id.equals("71")){ + log.warn(id, msg); + return; + } // SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // String format = dateFormat.format(new Date().getTime()); // //������������ -- Gitblit v1.8.0