fix(iot): 修复 TrafficThresholdRuleProcessor 编译错误
- 将 StringRedisTemplate 声明移至类顶部字段区域 - 修复变量使用顺序导致的编译错误 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
@@ -1,9 +1,7 @@
|
|||||||
package com.viewsh.module.iot.service.rule.clean.processor;
|
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.constants.CleanOrderTopics;
|
||||||
import com.viewsh.module.iot.core.integration.event.clean.CleanOrderCreateEvent;
|
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.dataobject.integration.clean.TrafficThresholdConfig;
|
||||||
import com.viewsh.module.iot.dal.redis.clean.DeviceCurrentOrderRedisDAO;
|
import com.viewsh.module.iot.dal.redis.clean.DeviceCurrentOrderRedisDAO;
|
||||||
import com.viewsh.module.iot.dal.redis.clean.TrafficCounterBaseRedisDAO;
|
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 jakarta.annotation.Resource;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.apache.rocketmq.spring.core.RocketMQTemplate;
|
import org.apache.rocketmq.spring.core.RocketMQTemplate;
|
||||||
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
||||||
import org.springframework.messaging.support.MessageBuilder;
|
import org.springframework.messaging.support.MessageBuilder;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
@@ -41,6 +40,9 @@ public class TrafficThresholdRuleProcessor {
|
|||||||
@Resource
|
@Resource
|
||||||
private RocketMQTemplate rocketMQTemplate;
|
private RocketMQTemplate rocketMQTemplate;
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private StringRedisTemplate stringRedisTemplate;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 处理客流属性上报
|
* 处理客流属性上报
|
||||||
* <p>
|
* <p>
|
||||||
@@ -182,7 +184,4 @@ public class TrafficThresholdRuleProcessor {
|
|||||||
|
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Resource
|
|
||||||
private org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate;
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user