wuzudaniu
/
cloud-plus-server
6
0
Fork 0
Code Issues Pull Requests 4 Packages Projects Releases Wiki Activity

feat():修复Redis #19

Merged
xieyaru070903 merged 1 commits from dev.parse into dev 2024-09-30 10:41:51 +08:00
Conversation 0 Commits 1 Files Changed 4
4 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/java/com/muyu/enterpise/cache/EnterpiseCacheService.java → cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/java/com/muyu/enterpise/cache/MessageValueCacheService.java vendored
View File

@ -1,7 +1,6 @@
package com.muyu.enterpise.cache; package com.muyu.enterpise.cache;
import com.muyu.common.cache.CacheAbsBasic; import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.common.cache.CacheBasic;
import com.muyu.domain.MessageValue; import com.muyu.domain.MessageValue;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -12,7 +11,7 @@ import org.springframework.stereotype.Component;
* @注释 * @注释
*/ */
@Component @Component
public class EnterpiseCacheService extends CacheAbsBasic<String, MessageValue> { public class MessageValueCacheService extends CacheAbsBasic<String, MessageValue> {
/** /**
* 前缀 * 前缀

2
cloud-modules/cloud-modules-enterprise/enterpise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
View File

@ -1 +1 @@
com.muyu.enterpise.cache.EnterpiseCacheService com.muyu.enterpise.cache.MessageValueCacheService

6
cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/controller/MessageValueController.java
View File

@ -6,16 +6,14 @@ import com.muyu.domain.MessageValue;
import com.muyu.domain.req.MessageValueAddReq; import com.muyu.domain.req.MessageValueAddReq;
import com.muyu.domain.req.MessageValueReq; import com.muyu.domain.req.MessageValueReq;
import com.muyu.domain.resp.MessageValueListResp; 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 com.muyu.enterpise.service.MessageValueService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List; import java.util.List;
/** /**
@ -35,7 +33,7 @@ public class MessageValueController extends BaseController {
private MessageValueService messageValueService; private MessageValueService messageValueService;
@Autowired @Autowired
private EnterpiseCacheService enterpiseCacheService; private MessageValueCacheService enterpiseCacheService;
/** /**
* 报文数据列表查询 * 报文数据列表查询

12
cloud-modules/cloud-modules-parse/src/main/java/com/muyu/parse/process/ProcessData.java
View File

@ -7,7 +7,7 @@ import com.muyu.common.core.domain.Result;
import com.muyu.domain.MessageValue; import com.muyu.domain.MessageValue;
import com.muyu.domain.req.MessageValueReq; import com.muyu.domain.req.MessageValueReq;
import com.muyu.domain.resp.MessageValueListResp; 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.parse.uitl.DataParseUtil;
import com.muyu.remote.RemoteMessageValueService; import com.muyu.remote.RemoteMessageValueService;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
@ -29,7 +29,7 @@ public class ProcessData {
private static RemoteMessageValueService remoteMessageValueService; private static RemoteMessageValueService remoteMessageValueService;
@Resource @Resource
private static EnterpiseCacheService enterpiseCacheService; private static MessageValueCacheService enterpiseCacheService;
// @Resource // @Resource
// private static KafkaProducerConfig kafkaProducerConfig; // private static KafkaProducerConfig kafkaProducerConfig;
@ -37,6 +37,14 @@ public class ProcessData {
public static void DataConversion(String jsonVin ) { public static void DataConversion(String jsonVin ) {
String vin = DataParseUtil.dataParsing(jsonVin); String vin = DataParseUtil.dataParsing(jsonVin);
System.out.println("车辆转换的vin是："+vin); System.out.println("车辆转换的vin是："+vin);
//从Redis中获取车辆信息
//根据车辆信息获取车辆类型
Result<Long> byTemplateId = remoteMessageValueService.findByTemplateId(vin); Result<Long> byTemplateId = remoteMessageValueService.findByTemplateId(vin);
Long templateId = byTemplateId.getData(); Long templateId = byTemplateId.getData();