REQ-2874: 政务-添加高新区短信渠道

This commit is contained in:
yanglin 2024-08-16 15:16:13 +08:00
parent c686f1a24d
commit d3225dc92d
4 changed files with 47 additions and 1 deletions

View File

@ -24,6 +24,7 @@ import cn.axzo.msg.center.message.service.todo.manage.TodoManager;
import cn.axzo.msg.center.message.xxl.MigrateOldMsgHotDataJob;
import cn.axzo.msg.center.notices.manager.api.MessageChannelRouter;
import cn.axzo.msg.center.notices.manager.api.MessageTemplateManager;
import cn.axzo.msg.center.notices.manager.api.dto.request.plat.AddMnsAppRequest;
import cn.axzo.msg.center.notices.manager.api.dto.request.plat.CreateTemplateRequestDto;
import cn.axzo.msg.center.notices.service.api.PlatService;
import cn.axzo.msg.center.service.pending.request.RevokeByTemplateCodeRequest;
@ -167,9 +168,16 @@ public class PrivateMessageController {
return String.format("updated templates: %d", size);
}
@PostMapping("/addMnsApp")
@EnableResponseAdvice(enable = false)
public Object addMnsApp(@RequestBody @Valid AddMnsAppRequest request) {
platService.addApp(request);
return "ok";
}
@PostMapping("/createMnsTemplate")
@EnableResponseAdvice(enable = false)
public String createMnsTemplate(@RequestBody CreateTemplateRequestDto request){
public String createMnsTemplate(@RequestBody @Valid CreateTemplateRequestDto request){
platService.createTemplate(request);
return "created";
}

View File

@ -0,0 +1,18 @@
package cn.axzo.msg.center.notices.manager.api.dto.request.plat;
import lombok.Getter;
import lombok.Setter;
import javax.validation.constraints.NotBlank;
/**
* @author yanglin
*/
@Setter
@Getter
public class AddMnsAppRequest {
@NotBlank(message = "serviceName不能为空")
private String serviceName;
@NotBlank(message = "remark不能为空")
private String remark;
}

View File

@ -3,6 +3,7 @@ package cn.axzo.msg.center.notices.service.api;
import cn.axzo.msg.center.domain.entity.MNSMessageApp;
import cn.axzo.msg.center.notices.common.lang.Page;
import cn.axzo.msg.center.notices.manager.api.dto.request.plat.AddMnsAppRequest;
import cn.axzo.msg.center.notices.manager.api.dto.request.plat.CreateTemplateRequestDto;
import cn.axzo.msg.center.notices.manager.api.dto.request.plat.QueryTemplateRequestDto;
import cn.axzo.msg.center.notices.manager.api.dto.response.plat.QueryTemplateResponseDto;
@ -34,4 +35,6 @@ public interface PlatService {
void delete(String templateNo);
List<MNSMessageApp> listAllApps();
void addApp(AddMnsAppRequest request);
}

View File

@ -15,6 +15,7 @@ import cn.axzo.msg.center.notices.common.enums.ChannelHandlerEnum;
import cn.axzo.msg.center.notices.common.enums.ReturnCodeEnum;
import cn.axzo.msg.center.notices.common.exception.BizException;
import cn.axzo.msg.center.notices.common.lang.Page;
import cn.axzo.msg.center.notices.manager.api.dto.request.plat.AddMnsAppRequest;
import cn.axzo.msg.center.notices.manager.api.dto.request.plat.CreateTemplateRequestDto;
import cn.axzo.msg.center.notices.manager.api.dto.request.plat.QueryTemplateRequestDto;
import cn.axzo.msg.center.notices.manager.api.dto.response.plat.QueryTemplateResponseDto;
@ -274,4 +275,20 @@ public class PlatServiceImpl implements PlatService {
return mnsMessageAppMapper.selectList(query(MNSMessageApp.class).
eq(MNSMessageApp::getIsDelete, TableIsDeleteEnum.NORMAL.value));
}
@Override
public void addApp(AddMnsAppRequest request) {
LambdaQueryWrapper<MNSMessageApp> query = new LambdaQueryWrapper<>();
query.eq(MNSMessageApp::getAppCode, request.getServiceName());
List<MNSMessageApp> messageApps = mnsMessageAppMapper.selectList(query);
if (CollectionUtils.isNotEmpty(messageApps)) {
return;
}
MNSMessageApp messageApp = new MNSMessageApp();
messageApp.setAppCode(request.getServiceName());
messageApp.setAppName(request.getServiceName());
messageApp.setRemark(request.getRemark());
messageApp.setStatus(1);
mnsMessageAppMapper.insert(messageApp);
}
}