diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/OnLineMonitoringConsumer.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/OnLineMonitoringConsumer.java index 4127ede..b72f7be 100644 --- a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/OnLineMonitoringConsumer.java +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/OnLineMonitoringConsumer.java @@ -4,6 +4,7 @@ import com.muyu.domain.Fence; import com.muyu.domain.Vehicle; import com.muyu.domain.WarnRule; import com.muyu.domain.WarnStrategy; +import com.muyu.domain.resp.WarnRuleResp; import com.muyu.enterprise.cache.*; import com.muyu.processing.utils.CacheUtil; import com.rabbitmq.client.Channel; @@ -55,7 +56,7 @@ public class OnLineMonitoringConsumer { try { log.info("添加本地缓存,车辆vin: {}", vin); WarnRule warnRule = warnRuleCacheService.get(vin); - WarnStrategy warnStrategy = warnStrategyCacheService.get(vin); + WarnRuleResp warnStrategy = warnStrategyCacheService.get(vin); Vehicle vehicle = vehicleCacheService.get(vin); Object breakdown = faultCacheService.get(vin); Fence fence = fenceCahceService.get(vin);