dyf/fys-Multi-tenant
1
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bug修改4

Browse Source
This commit is contained in:
chenyouting
2026-02-27 18:34:21 +08:00
parent 4d5292cebc
commit 20ac6b0baa
1 changed files with 46 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

92
fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/hby100j/FuncType2BaseInfo.java
View File

@ -1,46 +1,46 @@
//package com.fuyuanshen.global.mqtt.rule.hby100j; package com.fuyuanshen.global.mqtt.rule.hby100j;
//
//import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
//import com.fuyuanshen.common.core.constant.GlobalConstants; import com.fuyuanshen.common.core.constant.GlobalConstants;
//import com.fuyuanshen.common.redis.utils.RedisUtils; import com.fuyuanshen.common.redis.utils.RedisUtils;
//import com.fuyuanshen.global.mqtt.base.NewMqttMessageRule; import com.fuyuanshen.global.mqtt.base.NewMqttMessageRule;
//import com.fuyuanshen.global.mqtt.base.NewMqttRuleContext; import com.fuyuanshen.global.mqtt.base.NewMqttRuleContext;
//import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//import java.util.Map; import java.util.Map;
//
//import static com.fuyuanshen.global.mqtt.constants.DeviceRedisKeyConstants.DEVICE_KEY_PREFIX; import static com.fuyuanshen.global.mqtt.constants.DeviceRedisKeyConstants.DEVICE_KEY_PREFIX;
//
///** /**
// * 获取设备基础信息 * 获取设备基础信息
// */ */
//@Slf4j @Slf4j
//@Component @Component
//public class FuncType2BaseInfo implements NewMqttMessageRule { public class FuncType2BaseInfo implements NewMqttMessageRule {
//
// @Override @Override
// public String getCommandType() { public String getCommandType() {
// return "HBY100_2"; return "HBY100_2";
// } }
//
// @Override @Override
// public void execute(NewMqttRuleContext context) { public void execute(NewMqttRuleContext context) {
// log.info("开始处理强制声光报警开关，消息负载：{}", context.getPayloadDict()); log.info("开始处理强制声光报警开关，消息负载：{}", context.getPayloadDict());
//
// try { try {
// // 构建强制声光报警开关的Redis键 // 构建强制声光报警开关的Redis键
// String redisKey = GlobalConstants.GLOBAL_REDIS_KEY + DEVICE_KEY_PREFIX + String redisKey = GlobalConstants.GLOBAL_REDIS_KEY + DEVICE_KEY_PREFIX +
// context.getDeviceImei() + ":force_audio_visual_alarm_switch"; context.getDeviceImei() + ":force_audio_visual_alarm_switch";
//
// Map<String, Object> payloadDict = context.getPayloadDict(); Map<String, Object> payloadDict = context.getPayloadDict();
// if (payloadDict != null) { if (payloadDict != null) {
// // 存储强制声光报警开关状态到Redis // 存储强制声光报警开关状态到Redis
// RedisUtils.setCacheObject(redisKey, JSONObject.toJSONString(payloadDict)); RedisUtils.setCacheObject(redisKey, JSONObject.toJSONString(payloadDict));
// } }
// log.info("强制声光报警开关处理完成，设备ID：{}", context.getDeviceImei()); log.info("强制声光报警开关处理完成，设备ID：{}", context.getDeviceImei());
// } catch (Exception e) { } catch (Exception e) {
// log.error("处理强制声光报警开关失败", e); log.error("处理强制声光报警开关失败", e);
// } }
// } }
//} }