diff --git a/cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/java/com/muyu/enterpise/cache/EnterpiseCacheService.java b/cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/java/com/muyu/enterpise/cache/MessageValueCacheService.java similarity index 84% rename from cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/java/com/muyu/enterpise/cache/EnterpiseCacheService.java rename to cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/java/com/muyu/enterpise/cache/MessageValueCacheService.java index 575a974..758cf5d 100644 --- a/cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/java/com/muyu/enterpise/cache/EnterpiseCacheService.java +++ b/cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/java/com/muyu/enterpise/cache/MessageValueCacheService.java @@ -1,7 +1,6 @@ package com.muyu.enterpise.cache; import com.muyu.common.cache.CacheAbsBasic; -import com.muyu.common.cache.CacheBasic; import com.muyu.domain.MessageValue; import org.springframework.stereotype.Component; @@ -12,7 +11,7 @@ import org.springframework.stereotype.Component; * @注释 */ @Component -public class EnterpiseCacheService extends CacheAbsBasic { +public class MessageValueCacheService extends CacheAbsBasic { /** * 前缀 diff --git a/cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports index 6fd26a8..98352f9 100644 --- a/cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports +++ b/cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports @@ -1 +1 @@ -com.muyu.enterpise.cache.EnterpiseCacheService +com.muyu.enterpise.cache.MessageValueCacheService diff --git a/cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/controller/MessageValueController.java b/cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/controller/MessageValueController.java index 6b3e7d7..1af044a 100644 --- a/cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/controller/MessageValueController.java +++ b/cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/controller/MessageValueController.java @@ -6,16 +6,14 @@ import com.muyu.domain.MessageValue; import com.muyu.domain.req.MessageValueAddReq; import com.muyu.domain.req.MessageValueReq; import com.muyu.domain.resp.MessageValueListResp; -import com.muyu.enterpise.cache.EnterpiseCacheService; +import com.muyu.enterpise.cache.MessageValueCacheService; import com.muyu.enterpise.service.MessageValueService; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.*; -import javax.annotation.Resource; import java.util.List; /** @@ -35,7 +33,7 @@ public class MessageValueController extends BaseController { private MessageValueService messageValueService; @Autowired - private EnterpiseCacheService enterpiseCacheService; + private MessageValueCacheService enterpiseCacheService; /** * 报文数据列表查询 diff --git a/cloud-modules/cloud-modules-parse/src/main/java/com/muyu/parse/process/ProcessData.java b/cloud-modules/cloud-modules-parse/src/main/java/com/muyu/parse/process/ProcessData.java index 5fb2359..bfd4a90 100644 --- a/cloud-modules/cloud-modules-parse/src/main/java/com/muyu/parse/process/ProcessData.java +++ b/cloud-modules/cloud-modules-parse/src/main/java/com/muyu/parse/process/ProcessData.java @@ -7,7 +7,7 @@ import com.muyu.common.core.domain.Result; import com.muyu.domain.MessageValue; import com.muyu.domain.req.MessageValueReq; import com.muyu.domain.resp.MessageValueListResp; -import com.muyu.enterpise.cache.EnterpiseCacheService; +import com.muyu.enterpise.cache.MessageValueCacheService; import com.muyu.parse.uitl.DataParseUtil; import com.muyu.remote.RemoteMessageValueService; import lombok.extern.log4j.Log4j2; @@ -29,7 +29,7 @@ public class ProcessData { private static RemoteMessageValueService remoteMessageValueService; @Resource - private static EnterpiseCacheService enterpiseCacheService; + private static MessageValueCacheService enterpiseCacheService; // @Resource // private static KafkaProducerConfig kafkaProducerConfig; @@ -37,6 +37,14 @@ public class ProcessData { public static void DataConversion(String jsonVin ) { String vin = DataParseUtil.dataParsing(jsonVin); System.out.println("车辆转换的vin是:"+vin); + + //从Redis中获取车辆信息 + + //根据车辆信息获取车辆类型 + + + + Result byTemplateId = remoteMessageValueService.findByTemplateId(vin); Long templateId = byTemplateId.getData();