package com.qianwen.smartman.modules.notify.controller;
|
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import io.swagger.annotations.ApiParam;
|
import java.util.Arrays;
|
import java.util.HashMap;
|
import java.util.Map;
|
import java.util.Optional;
|
import com.qianwen.core.boot.ctrl.BladeController;
|
import com.qianwen.core.log.exception.ServiceException;
|
import com.qianwen.core.log.utils.LogTraceUtil;
|
import com.qianwen.core.notify.DefaultNotifyType;
|
import com.qianwen.core.notify.notifier.Notifier;
|
import com.qianwen.core.notify.notifier.NotifierManager;
|
import com.qianwen.core.notify.template.Template;
|
import com.qianwen.core.notify.template.TemplateManager;
|
import com.qianwen.core.scanner.modular.annotation.PostResource;
|
import com.qianwen.core.scanner.modular.stereotype.ApiResource;
|
import com.qianwen.core.tool.api.R;
|
import com.qianwen.core.tool.metadata.Values;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.modules.notify.api.DingTalkApi;
|
import com.qianwen.smartman.modules.notify.dto.SendNotifyRequest;
|
import com.qianwen.smartman.modules.notify.entity.NotifyTemplateEntity;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
@ApiResource({"blade-notify/notifier"})
|
@Api(value = "通知在线调试", tags = {"通知在线调试"})
|
@RestController
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/notify/controller/NotifierController.class */
|
public class NotifierController extends BladeController {
|
private final NotifierManager notifierManager;
|
private final TemplateManager templateManager;
|
private final DingTalkApi dingTalkApi;
|
|
public NotifierController(final NotifierManager notifierManager, final TemplateManager templateManager, final DingTalkApi dingTalkApi) {
|
this.notifierManager = notifierManager;
|
this.templateManager = templateManager;
|
this.dingTalkApi = dingTalkApi;
|
}
|
|
@ApiOperationSupport(order = 1)
|
@PostResource({"/{notifierId}/send"})
|
@ApiOperation("发送消息通知")
|
public R<String> sendNotify(@PathVariable("notifierId") @ApiParam(value = "通知配置ID", required = true) String notifierId, @RequestBody SendNotifyRequest mono) {
|
NotifyTemplateEntity relatedTemplate = new NotifyTemplateEntity();
|
relatedTemplate.setType(mono.getType());
|
relatedTemplate.setTemplate(mono.getTemplate());
|
relatedTemplate.setProvider(mono.getProvider());
|
if (Func.equals(mono.getType(), DefaultNotifyType.dingTalk.name())) {
|
String userId = this.dingTalkApi.getUserIdByMobile(mono.getNotifiedParty());
|
mono.setNotifiedParty(userId);
|
}
|
DefaultNotifyType valueOf = DefaultNotifyType.valueOf(relatedTemplate.getType());
|
try {
|
Notifier notifier = (Notifier) Optional.ofNullable(this.notifierManager.getNotifier(valueOf, notifierId)).orElseThrow(() -> {
|
return new ServiceException("通知器[" + notifierId + "]不存在");
|
});
|
Template template = this.templateManager.createTemplate(valueOf, relatedTemplate.toTemplateProperties());
|
Map context = new HashMap();
|
if (Func.isNotEmpty(mono.getNotifiedParty())) {
|
notifier.send(template, LogTraceUtil.getTraceId(), Values.of(context), Arrays.asList(mono.getNotifiedParty().split(",")));
|
}
|
return R.success("");
|
} catch (NullPointerException e) {
|
return R.fail("通知器[" + notifierId + "]不存在");
|
}
|
}
|
}
|
