diff --git a/viewsh-module-iot/viewsh-module-iot-server/src/main/java/com/viewsh/module/iot/service/rule/clean/processor/TrafficThresholdRuleProcessor.java b/viewsh-module-iot/viewsh-module-iot-server/src/main/java/com/viewsh/module/iot/service/rule/clean/processor/TrafficThresholdRuleProcessor.java index f907f66..49b738a 100644 --- a/viewsh-module-iot/viewsh-module-iot-server/src/main/java/com/viewsh/module/iot/service/rule/clean/processor/TrafficThresholdRuleProcessor.java +++ b/viewsh-module-iot/viewsh-module-iot-server/src/main/java/com/viewsh/module/iot/service/rule/clean/processor/TrafficThresholdRuleProcessor.java @@ -1,9 +1,7 @@ package com.viewsh.module.iot.service.rule.clean.processor; -import com.viewsh.framework.common.util.json.JsonUtils; import com.viewsh.module.iot.core.integration.constants.CleanOrderTopics; import com.viewsh.module.iot.core.integration.event.clean.CleanOrderCreateEvent; -import com.viewsh.module.iot.dal.dataobject.integration.clean.CleanOrderIntegrationConfig; import com.viewsh.module.iot.dal.dataobject.integration.clean.TrafficThresholdConfig; import com.viewsh.module.iot.dal.redis.clean.DeviceCurrentOrderRedisDAO; import com.viewsh.module.iot.dal.redis.clean.TrafficCounterBaseRedisDAO; @@ -11,6 +9,7 @@ import com.viewsh.module.iot.service.integration.clean.CleanOrderIntegrationConf import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.spring.core.RocketMQTemplate; +import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.messaging.support.MessageBuilder; import org.springframework.stereotype.Component; @@ -41,6 +40,9 @@ public class TrafficThresholdRuleProcessor { @Resource private RocketMQTemplate rocketMQTemplate; + @Resource + private StringRedisTemplate stringRedisTemplate; + /** * 处理客流属性上报 *

@@ -182,7 +184,4 @@ public class TrafficThresholdRuleProcessor { return null; } - - @Resource - private org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate; }