feat:()添加报文模版缓存

dev.protocol
sy200 2024-10-02 09:40:38 +08:00
parent d4f942bebc
commit 1d91e51199
4 changed files with 46 additions and 7 deletions

View File

@ -0,0 +1,26 @@
package com.muyu.enterprise.cache;
import com.muyu.common.cache.CacheAbsBacis;
import com.muyu.domain.MessageTemplate;
/**
*
*/
public class MessageTemplateCacheService extends CacheAbsBacis<String, MessageTemplate> {
@Override
public void clear() {
}
@Override
public String keyPre() {
return "messageTemplate:info:";
}
@Override
public String decode(String key) {
return key.replace("messageTemplate:info:", "");
}
}

View File

@ -14,11 +14,11 @@ public class WarnRuleCacheService extends CacheAbsBacis<String, WarnRule> {
@Override @Override
public String keyPre() { public String keyPre() {
return "warn:info:"; return "warnRule:info:";
} }
@Override @Override
public String decode(String key) { public String decode(String key) {
return key.replace("warn:info:", ""); return key.replace("warnRule:info:", "");
} }
} }

View File

@ -5,7 +5,7 @@ import com.muyu.domain.WarnRule;
import com.muyu.domain.WarnStrategy; import com.muyu.domain.WarnStrategy;
/** /**
* *
*/ */
public class WarnStrategyCacheService extends CacheAbsBacis<String, WarnStrategy> { public class WarnStrategyCacheService extends CacheAbsBacis<String, WarnStrategy> {
@Override @Override
@ -15,11 +15,11 @@ public class WarnStrategyCacheService extends CacheAbsBacis<String, WarnStrategy
@Override @Override
public String keyPre() { public String keyPre() {
return "warn:info:"; return "warnStrategy:info:";
} }
@Override @Override
public String decode(String key) { public String decode(String key) {
return key.replace("warn:info:", ""); return key.replace("warnStrategy:info:", "");
} }
} }

View File

@ -1,8 +1,11 @@
package com.muyu.enterprise.controller; package com.muyu.enterprise.controller;
import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.common.system.domain.LoginUser;
import com.muyu.domain.MessageTemplate; import com.muyu.domain.MessageTemplate;
import com.muyu.domain.req.MessageTemplateAddReq; import com.muyu.domain.req.MessageTemplateAddReq;
import com.muyu.domain.resp.MessageTemplateListResp; import com.muyu.domain.resp.MessageTemplateListResp;
import com.muyu.enterprise.cache.MessageTemplateCacheService;
import com.muyu.enterprise.service.MessageTemplateService; import com.muyu.enterprise.service.MessageTemplateService;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
@ -30,6 +33,10 @@ public class MessageTemplateController {
@Autowired @Autowired
private MessageTemplateService messageTemplateService; private MessageTemplateService messageTemplateService;
//缓存
@Autowired
private MessageTemplateCacheService templateCacheService;
/** /**
* *
*1 *1
@ -55,8 +62,14 @@ public class MessageTemplateController {
*/ */
@PostMapping("/") @PostMapping("/")
public Result<String> save(@RequestBody MessageTemplateAddReq messageTemplateAddReq) { public Result<String> save(@RequestBody MessageTemplateAddReq messageTemplateAddReq) {
messageTemplateService.save(MessageTemplate.addBuild(messageTemplateAddReq)); boolean save = messageTemplateService.save(MessageTemplate.addBuild(messageTemplateAddReq));
return Result.success("添加成功"); //获取用户信息
LoginUser loginUser = SecurityUtils.getLoginUser();
//获取租户唯一标识
String databaseName = loginUser.getSysUser().getDatabaseName();
//添加到缓存
templateCacheService.put(databaseName+messageTemplateAddReq.getMessageTemplateName(), MessageTemplate.addBuild(messageTemplateAddReq));
return Result.success(save? "新增成功" : "新增失败");
} }
/** /**