fix(): 修改报文数据的缓存方法
parent
960d68f72e
commit
a834f9d1bd
|
@ -1,14 +1,14 @@
|
||||||
package com.muyu.enterprise.cache;
|
package com.muyu.enterprise.cache;
|
||||||
|
|
||||||
import com.muyu.common.cache.CacheAbsBacis;
|
import com.muyu.common.cache.CacheAbsBacis;
|
||||||
import com.muyu.domain.MessageValue;
|
import com.muyu.domain.resp.MessageValueListResp;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 报文模版缓存
|
* 报文模版缓存
|
||||||
*/
|
*/
|
||||||
public class AllMessageValueCacheService extends CacheAbsBacis<String, List<MessageValue>> {
|
public class AllMessageValueCacheService extends CacheAbsBacis<String, List<MessageValueListResp>> {
|
||||||
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
@ -67,12 +67,13 @@ public class MessageValueServiceImpl
|
||||||
LambdaQueryWrapper<MessageValue> queryWrapper = new LambdaQueryWrapper<>();
|
LambdaQueryWrapper<MessageValue> queryWrapper = new LambdaQueryWrapper<>();
|
||||||
queryWrapper.eq(MessageValue::getTemplateId, templateId);
|
queryWrapper.eq(MessageValue::getTemplateId, templateId);
|
||||||
List<MessageValue> list = this.list(queryWrapper);
|
List<MessageValue> list = this.list(queryWrapper);
|
||||||
allMessageValueCacheService.put(String.valueOf(templateId), list);
|
List<MessageValueListResp> collect = list.stream()
|
||||||
return list.stream()
|
|
||||||
.map(messageValue -> MessageValueListResp.valueBuild(
|
.map(messageValue -> MessageValueListResp.valueBuild(
|
||||||
messageValue
|
messageValue
|
||||||
)
|
)
|
||||||
).collect(Collectors.toList());
|
).collect(Collectors.toList());
|
||||||
|
allMessageValueCacheService.put(String.valueOf(templateId), collect);
|
||||||
|
return collect;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue