seven
/
cloud-vehicle
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(): 修改报文数据的缓存方法

dev.repair.protocol
李东佳 2024-10-04 20:38:00 +08:00
parent 2c5387f048
commit 960d68f72e
2 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/AllMessageValueCacheService.java vendored
View File

@ -1,14 +1,14 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.CacheAbsBacis;
import com.muyu.domain.MessageTemplate;
import com.muyu.domain.MessageValue;
import com.muyu.domain.req.MessageValueReq;
import java.util.List;
/**
* 报文模版缓存
*/
public class AllMessageValueCacheService extends CacheAbsBacis<String, MessageValueReq> {
public class AllMessageValueCacheService extends CacheAbsBacis<String, List<MessageValue>> {
@Override
@ -18,11 +18,11 @@ public class AllMessageValueCacheService extends CacheAbsBacis<String, MessageVa
@Override
public String keyPre() {
return "Allmessagevalue:info:";
return "allmessagevalue:info:";
}
@Override
public String decode(String key) {
return key.replace("Allmessagevalue:info:", "");
return key.replace("allmessagevalue:info:", "");
}
}

9
cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/enterprise/service/impl/MessageValueServiceImpl.java
View File

@ -2,11 +2,12 @@ package com.muyu.enterprise.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.enterprise.mapper.MessageValueMapper;
import com.muyu.enterprise.service.MessageValueService;
import com.muyu.domain.MessageValue;
import com.muyu.domain.req.MessageValueReq;
import com.muyu.domain.resp.MessageValueListResp;
import com.muyu.enterprise.cache.AllMessageValueCacheService;
import com.muyu.enterprise.mapper.MessageValueMapper;
import com.muyu.enterprise.service.MessageValueService;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@ -31,6 +32,9 @@ public class MessageValueServiceImpl
@Autowired
private MessageValueMapper messageValueMapper;
@Autowired
private AllMessageValueCacheService allMessageValueCacheService;
public MessageValueServiceImpl(MessageValueMapper messageValueMapper) {
this.messageValueMapper = messageValueMapper;
}
@ -63,6 +67,7 @@ public class MessageValueServiceImpl
LambdaQueryWrapper<MessageValue> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(MessageValue::getTemplateId, templateId);
List<MessageValue> list = this.list(queryWrapper);
allMessageValueCacheService.put(String.valueOf(templateId), list);
return list.stream()
.map(messageValue -> MessageValueListResp.valueBuild(
messageValue