From 20ac6b0baa68e93293109d75477b7d7f234b2c42 Mon Sep 17 00:00:00 2001 From: chenyouting <514333061@qq.com> Date: Fri, 27 Feb 2026 18:34:21 +0800 Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E6=94=B94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mqtt/rule/hby100j/FuncType2BaseInfo.java | 92 +++++++++---------- 1 file changed, 46 insertions(+), 46 deletions(-) diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/hby100j/FuncType2BaseInfo.java b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/hby100j/FuncType2BaseInfo.java index 3ef28f29..1ef43c62 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/hby100j/FuncType2BaseInfo.java +++ b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/hby100j/FuncType2BaseInfo.java @@ -1,46 +1,46 @@ -//package com.fuyuanshen.global.mqtt.rule.hby100j; -// -//import com.alibaba.fastjson2.JSONObject; -//import com.fuyuanshen.common.core.constant.GlobalConstants; -//import com.fuyuanshen.common.redis.utils.RedisUtils; -//import com.fuyuanshen.global.mqtt.base.NewMqttMessageRule; -//import com.fuyuanshen.global.mqtt.base.NewMqttRuleContext; -//import lombok.extern.slf4j.Slf4j; -//import org.springframework.stereotype.Component; -// -//import java.util.Map; -// -//import static com.fuyuanshen.global.mqtt.constants.DeviceRedisKeyConstants.DEVICE_KEY_PREFIX; -// -///** -// * 获取设备基础信息 -// */ -//@Slf4j -//@Component -//public class FuncType2BaseInfo implements NewMqttMessageRule { -// -// @Override -// public String getCommandType() { -// return "HBY100_2"; -// } -// -// @Override -// public void execute(NewMqttRuleContext context) { -// log.info("开始处理强制声光报警开关,消息负载:{}", context.getPayloadDict()); -// -// try { -// // 构建强制声光报警开关的Redis键 -// String redisKey = GlobalConstants.GLOBAL_REDIS_KEY + DEVICE_KEY_PREFIX + -// context.getDeviceImei() + ":force_audio_visual_alarm_switch"; -// -// Map payloadDict = context.getPayloadDict(); -// if (payloadDict != null) { -// // 存储强制声光报警开关状态到Redis -// RedisUtils.setCacheObject(redisKey, JSONObject.toJSONString(payloadDict)); -// } -// log.info("强制声光报警开关处理完成,设备ID:{}", context.getDeviceImei()); -// } catch (Exception e) { -// log.error("处理强制声光报警开关失败", e); -// } -// } -//} +package com.fuyuanshen.global.mqtt.rule.hby100j; + +import com.alibaba.fastjson2.JSONObject; +import com.fuyuanshen.common.core.constant.GlobalConstants; +import com.fuyuanshen.common.redis.utils.RedisUtils; +import com.fuyuanshen.global.mqtt.base.NewMqttMessageRule; +import com.fuyuanshen.global.mqtt.base.NewMqttRuleContext; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.Map; + +import static com.fuyuanshen.global.mqtt.constants.DeviceRedisKeyConstants.DEVICE_KEY_PREFIX; + +/** + * 获取设备基础信息 + */ +@Slf4j +@Component +public class FuncType2BaseInfo implements NewMqttMessageRule { + + @Override + public String getCommandType() { + return "HBY100_2"; + } + + @Override + public void execute(NewMqttRuleContext context) { + log.info("开始处理强制声光报警开关,消息负载:{}", context.getPayloadDict()); + + try { + // 构建强制声光报警开关的Redis键 + String redisKey = GlobalConstants.GLOBAL_REDIS_KEY + DEVICE_KEY_PREFIX + + context.getDeviceImei() + ":force_audio_visual_alarm_switch"; + + Map payloadDict = context.getPayloadDict(); + if (payloadDict != null) { + // 存储强制声光报警开关状态到Redis + RedisUtils.setCacheObject(redisKey, JSONObject.toJSONString(payloadDict)); + } + log.info("强制声光报警开关处理完成,设备ID:{}", context.getDeviceImei()); + } catch (Exception e) { + log.error("处理强制声光报警开关失败", e); + } + } +}