notify模块代码整理

yangys

2024-04-23 fe1a8b44747f355c5f3d293a0b8034d01d553b45

notify模块代码整理

 smart-starter-notify/src/main/java/com/qianwen/core/notify/DefaultNotifyType.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/DefaultNotifyType.class */
public enum DefaultNotifyType implements NotifyType {
    sms("短信"),
    email("邮件"),

 smart-starter-notify/src/main/java/com/qianwen/core/notify/NotifierProvidersMapManager.java

@@ -10,7 +10,6 @@
import org.springframework.stereotype.Component;

@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/NotifierProvidersMapManager.class */
public class NotifierProvidersMapManager implements BeanPostProcessor {
    private static final Logger log = LoggerFactory.getLogger(NotifierProvidersMapManager.class);
    private final Map<String, Map<String, NotifierProvider>> providers = new ConcurrentHashMap();

 smart-starter-notify/src/main/java/com/qianwen/core/notify/NotifyConstants.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/NotifyConstants.class */
public class NotifyConstants {
    public static final String NOTIFY_CACHE = "blade:notify";
    public static final String NOTIFIER_CODE = "notifier:id:";

 smart-starter-notify/src/main/java/com/qianwen/core/notify/NotifyQueueProducer.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.executor.NotifyExecutionContext;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/NotifyQueueProducer.class */
public interface NotifyQueueProducer {
    boolean syncSend(NotifyExecutionContext object);


 smart-starter-notify/src/main/java/com/qianwen/core/notify/NotifyResultProducer.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.event.SerializableNotifierEvent;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/NotifyResultProducer.class */
public interface NotifyResultProducer {
    boolean syncSend(SerializableNotifierEvent object);


 smart-starter-notify/src/main/java/com/qianwen/core/notify/NotifyType.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/NotifyType.class */
public interface NotifyType {
    String getId();


 smart-starter-notify/src/main/java/com/qianwen/core/notify/Provider.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/Provider.class */
public interface Provider {
    String getId();


 smart-starter-notify/src/main/java/com/qianwen/core/notify/event/NotifierEvent.java

@@ -7,7 +7,6 @@
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.tool.utils.StringUtil;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/event/NotifierEvent.class */
public class NotifierEvent {
    private boolean success;
    @Nullable

 smart-starter-notify/src/main/java/com/qianwen/core/notify/event/SerializableNotifierEvent.java

@@ -3,7 +3,6 @@
import java.io.Serializable;
import java.util.Map;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/event/SerializableNotifierEvent.class */
public class SerializableNotifierEvent implements Serializable {
    private boolean success;
    private String errorType;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/executor/INotifyTaskService.java

@@ -4,7 +4,6 @@
import com.qianwen.core.context.task.TaskExecutionContext;
import com.qianwen.core.context.task.TaskExecutorTypeEnum;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/executor/INotifyTaskService.class */
public interface INotifyTaskService {
    List<String> getNotifiedPartyList(String tenantId, String businessKey, String defaultNotifyType, List<String> relatedPartyIds, TaskExecutorTypeEnum taskExecutorTypeEnum);


 smart-starter-notify/src/main/java/com/qianwen/core/notify/executor/NotifyDirectSendInfo.java

@@ -3,7 +3,6 @@
import java.util.List;
import com.qianwen.core.notify.DefaultNotifyType;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/executor/NotifyDirectSendInfo.class */
public class NotifyDirectSendInfo {
    private DefaultNotifyType notifyType;
    private List<String> directSendAddress;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/executor/NotifyExecutionContext.java

@@ -5,7 +5,6 @@
import java.util.List;
import java.util.Map;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/executor/NotifyExecutionContext.class */
public class NotifyExecutionContext implements Serializable {
    private String contextId;
    private String tenantId;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/executor/NotifyExecutorProvider.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify.executor;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/executor/NotifyExecutorProvider.class */
public interface NotifyExecutorProvider {
    String getExecutor();


 smart-starter-notify/src/main/java/com/qianwen/core/notify/executor/NotifyQueueExecutorProvider.java

@@ -11,7 +11,6 @@

@ConditionalOnBean({NotifierManager.class})
@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/executor/NotifyQueueExecutorProvider.class */
public class NotifyQueueExecutorProvider implements NotifyExecutorProvider {
    private static final Logger log = LoggerFactory.getLogger(NotifyQueueExecutorProvider.class);
    private final NotifierManager notifierManager;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/executor/NotifyTaskExecutorProvider.java

@@ -11,7 +11,6 @@

@ConditionalOnBean({INotifyTaskService.class, NotifyQueueProducer.class})
@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/executor/NotifyTaskExecutorProvider.class */
public class NotifyTaskExecutorProvider implements TaskExecutorProvider {
    private static final Logger log = LoggerFactory.getLogger(NotifyTaskExecutorProvider.class);
    private final INotifyTaskService notifyTaskService;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/executor/RuleNotifierProperties.java

@@ -3,7 +3,6 @@
import com.qianwen.core.notify.DefaultNotifyType;
import org.springframework.util.Assert;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/executor/RuleNotifierProperties.class */
public class RuleNotifierProperties {
    private DefaultNotifyType notifyType;
    private String notifierId;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/external/MessagingRequest.java

@@ -2,7 +2,6 @@

import java.util.Map;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/external/MessagingRequest.class */
public class MessagingRequest {
    private String id;
    private Type type;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/external/SubscribeRequest.java

@@ -3,7 +3,6 @@
import java.util.Map;
import com.qianwen.core.tool.metadata.ValueObject;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/external/SubscribeRequest.class */
public class SubscribeRequest implements ValueObject {
    private String id;
    private String topic;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/external/SubscriptionProvider.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify.external;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/external/SubscriptionProvider.class */
public interface SubscriptionProvider {
    String id();


 smart-starter-notify/src/main/java/com/qianwen/core/notify/notifier/AbstractNotifier.java

@@ -7,7 +7,6 @@
import com.qianwen.core.notify.template.TemplateManager;
import com.qianwen.core.tool.metadata.Values;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/notifier/AbstractNotifier.class */
public abstract class AbstractNotifier<T extends Template> implements Notifier<T> {
    private TemplateManager templateManager;


 smart-starter-notify/src/main/java/com/qianwen/core/notify/notifier/Notifier.java

@@ -6,7 +6,6 @@
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.tool.metadata.Values;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/notifier/Notifier.class */
public interface Notifier<T extends Template> {
    String getNotifierId();


 smart-starter-notify/src/main/java/com/qianwen/core/notify/notifier/NotifierEventDispatcher.java

@@ -7,7 +7,6 @@
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.tool.utils.Func;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/notifier/NotifierEventDispatcher.class */
public class NotifierEventDispatcher<T extends Template> extends NotifierProxy<T> {
    private static final Logger log = LoggerFactory.getLogger(NotifierEventDispatcher.class);
    private final NotifyResultProducer notifyResultProducer;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/notifier/NotifierManager.java

@@ -3,7 +3,6 @@
import com.qianwen.core.notify.NotifyType;
import com.qianwen.core.notify.template.Template;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/notifier/NotifierManager.class */
public interface NotifierManager {
    Notifier<? extends Template> getNotifier(NotifyType type, String id);


 smart-starter-notify/src/main/java/com/qianwen/core/notify/notifier/NotifierProperties.java

@@ -3,7 +3,6 @@
import java.io.Serializable;
import java.util.Map;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/notifier/NotifierProperties.class */
public class NotifierProperties implements Serializable {
    private String id;
    private String type;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/notifier/NotifierProvider.java

@@ -5,7 +5,6 @@
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.tool.metadata.ConfigMetadata;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/notifier/NotifierProvider.class */
public interface NotifierProvider {
    NotifyType getType();


 smart-starter-notify/src/main/java/com/qianwen/core/notify/notifier/NotifierProxy.java

@@ -9,7 +9,6 @@
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.tool.metadata.Values;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/notifier/NotifierProxy.class */
public abstract class NotifierProxy<T extends Template> implements Notifier<T> {
    private static final Logger log = LoggerFactory.getLogger(NotifierProxy.class);
    private Notifier<T> target;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/notifier/NotifyConfigManager.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.NotifyType;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/notifier/NotifyConfigManager.class */
public interface NotifyConfigManager {
    NotifierProperties getNotifyConfig(NotifyType notifyType, String configId);
}

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/dingtalk/DingTalkMessageTemplate.java

@@ -6,7 +6,6 @@
import com.qianwen.core.tool.metadata.Values;
import com.qianwen.core.tool.utils.ExpressionUtils;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/dingtalk/DingTalkMessageTemplate.class */
public class DingTalkMessageTemplate implements Template {
    @NotBlank(message = "[agentId]不能为空")
    private Long agentId;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/dingtalk/DingTalkNotifier.java

@@ -27,7 +27,6 @@
import com.qianwen.core.tool.utils.BeanUtil;
import com.qianwen.core.tool.utils.StringUtil;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/dingtalk/DingTalkNotifier.class */
public class DingTalkNotifier extends AbstractNotifier<DingTalkMessageTemplate> {
    private static final Logger log = LoggerFactory.getLogger(DingTalkNotifier.class);
    private final AtomicReference<String> accessToken;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/dingtalk/DingTalkNotifierProvider.java

@@ -20,7 +20,6 @@
import org.springframework.stereotype.Component;

@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/dingtalk/DingTalkNotifierProvider.class */
public class DingTalkNotifierProvider implements NotifierProvider, TemplateProvider {
    private final TemplateManager templateManager;
    public static final DefaultConfigMetadata notifierConfig = new DefaultConfigMetadata("通知配置", "").add("appKey", "appKey", "", (DataType) new StringType().expand(new ConfigKeyValue[]{ConfigMetadataConstants.required.value(true)})).add("appSecret", "appSecret", "", new StringType());

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/dingtalk/DingTalkProperties.java

@@ -2,7 +2,6 @@

import javax.validation.constraints.NotBlank;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/dingtalk/DingTalkProperties.class */
public class DingTalkProperties {
    @NotBlank(message = "appKey不能为空")
    private String appKey;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/dingtalk/DingTalkProvider.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.Provider;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/dingtalk/DingTalkProvider.class */
public enum DingTalkProvider implements Provider {
    dingTalkMessage("钉钉消息通知");
    

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/email/EmailProvider.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.Provider;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/email/EmailProvider.class */
public enum EmailProvider implements Provider {
    embedded("默认");
    

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/email/embedded/DefaultEmailNotifier.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify.provider.email.embedded;

import com.alibaba.fastjson.JSONObject;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.nio.charset.StandardCharsets;
@@ -8,28 +7,14 @@
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import javax.mail.internet.MimeMessage;

import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qianwen.core.http.HttpRequest;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.notify.DefaultNotifyType;
import com.qianwen.core.notify.NotifyType;
import com.qianwen.core.notify.Provider;
import com.qianwen.core.notify.notifier.AbstractNotifier;
import com.qianwen.core.notify.notifier.NotifierProperties;
import com.qianwen.core.notify.provider.email.EmailProvider;
import com.qianwen.core.notify.provider.email.embedded.EmailTemplate;
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.notify.template.TemplateManager;
import com.qianwen.core.tool.api.ResultCode;
import com.qianwen.core.tool.metadata.Values;
import com.qianwen.core.tool.utils.ExpressionUtils;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.core.tool.utils.StringUtil;
import org.springframework.core.io.ByteArrayResource;
import org.springframework.core.io.InputStreamResource;
import org.springframework.core.io.InputStreamSource;
@@ -38,7 +23,22 @@
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.util.StringUtils;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/email/embedded/DefaultEmailNotifier.class */
import com.alibaba.fastjson.JSONObject;
import com.qianwen.core.http.HttpRequest;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.notify.DefaultNotifyType;
import com.qianwen.core.notify.NotifyType;
import com.qianwen.core.notify.Provider;
import com.qianwen.core.notify.notifier.AbstractNotifier;
import com.qianwen.core.notify.notifier.NotifierProperties;
import com.qianwen.core.notify.provider.email.EmailProvider;
import com.qianwen.core.notify.template.TemplateManager;
import com.qianwen.core.tool.api.ResultCode;
import com.qianwen.core.tool.metadata.Values;
import com.qianwen.core.tool.utils.ExpressionUtils;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.core.tool.utils.StringUtil;

public class DefaultEmailNotifier extends AbstractNotifier<EmailTemplate> {
    private static final Logger log = LoggerFactory.getLogger(DefaultEmailNotifier.class);
    private String sender;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/email/embedded/DefaultEmailNotifierProvider.java

@@ -31,7 +31,6 @@

@ConditionalOnBean({TemplateManager.class})
@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/email/embedded/DefaultEmailNotifierProvider.class */
public class DefaultEmailNotifierProvider implements NotifierProvider, TemplateProvider {
    private static final Logger log = LoggerFactory.getLogger(DefaultEmailNotifierProvider.class);
    private final TemplateManager templateManager;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/email/embedded/DefaultEmailProperties.java

@@ -3,7 +3,6 @@
import java.util.List;
import java.util.Properties;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/email/embedded/DefaultEmailProperties.class */
public class DefaultEmailProperties {
    private String host;
    private int port;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/email/embedded/EmailTemplate.java

@@ -3,7 +3,6 @@
import java.util.List;
import com.qianwen.core.notify.template.Template;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/email/embedded/EmailTemplate.class */
public class EmailTemplate implements Template {
    private String subject;
    private String content;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/email/embedded/ParsedEmailTemplate.java

@@ -2,7 +2,6 @@

import java.util.Map;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/email/embedded/ParsedEmailTemplate.class */
public class ParsedEmailTemplate {
    private String subject;
    private String content;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/internal/message/DefaultInternalMessageTemplate.java

@@ -3,7 +3,6 @@
import java.util.List;
import com.qianwen.core.notify.template.Template;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/internal/message/DefaultInternalMessageTemplate.class */
public class DefaultInternalMessageTemplate implements Template {
    private String subject;
    private String content;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/internal/message/IInternalMessageServer.java

@@ -2,7 +2,6 @@

import java.util.List;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/internal/message/IInternalMessageServer.class */
public interface IInternalMessageServer {
    void submitInternalMessage(ParsedInternalMessageTemplate template, List<String> sendTo);
}

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/internal/message/InternalMessageProvider.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.Provider;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/internal/message/InternalMessageProvider.class */
public enum InternalMessageProvider implements Provider {
    systemDefault("系统站内信");
    

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/internal/message/ParsedInternalMessageTemplate.java

@@ -2,7 +2,6 @@

import java.util.Map;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/internal/message/ParsedInternalMessageTemplate.class */
public class ParsedInternalMessageTemplate {
    private String subject;
    private String content;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/sms/SmsProvider.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.Provider;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/sms/SmsProvider.class */
public enum SmsProvider implements Provider {
    aliyunSms("阿里云短信服务"),
    yunpianSms("云片短信服务");

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/sms/aliyun/AliyunSmsNotifier.java

@@ -27,7 +27,6 @@
import com.qianwen.core.tool.metadata.Values;
import com.qianwen.core.tool.utils.StringUtil;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/sms/aliyun/AliyunSmsNotifier.class */
public class AliyunSmsNotifier extends AbstractNotifier<AliyunSmsTemplate> {
    private static final Logger log = LoggerFactory.getLogger(AliyunSmsNotifier.class);
    private final IAcsClient client;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/sms/aliyun/AliyunSmsNotifierProvider.java

@@ -22,7 +22,6 @@

@ConditionalOnBean({TemplateManager.class})
@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/sms/aliyun/AliyunSmsNotifierProvider.class */
public class AliyunSmsNotifierProvider implements NotifierProvider, TemplateProvider {
    private final TemplateManager templateManager;
    private static final Logger log = LoggerFactory.getLogger(AliyunSmsNotifierProvider.class);

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/sms/aliyun/AliyunSmsTemplate.java

@@ -5,7 +5,6 @@
import javax.validation.constraints.NotBlank;
import com.qianwen.core.notify.template.Template;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/sms/aliyun/AliyunSmsTemplate.class */
public class AliyunSmsTemplate implements Template {
    @NotBlank(message = "[signName]不能为空")
    private String signName;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/sms/yunpian/YunpianNotifierProvider.java

@@ -22,7 +22,6 @@

@ConditionalOnBean({TemplateManager.class})
@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/sms/yunpian/YunpianNotifierProvider.class */
public class YunpianNotifierProvider implements NotifierProvider, TemplateProvider {
    private final TemplateManager templateManager;
    private static final Logger log = LoggerFactory.getLogger(YunpianNotifierProvider.class);

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/sms/yunpian/YunpianSmsNotifier.java

@@ -1,12 +1,11 @@
package com.qianwen.core.notify.provider.sms.yunpian;

import com.yunpian.sdk.YunpianClient;
import com.yunpian.sdk.model.Result;
import com.yunpian.sdk.model.SmsBatchSend;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.qianwen.core.log.exception.BizServiceException;
import com.qianwen.core.notify.DefaultNotifyType;
import com.qianwen.core.notify.NotifyType;
@@ -14,15 +13,16 @@
import com.qianwen.core.notify.notifier.AbstractNotifier;
import com.qianwen.core.notify.notifier.NotifierProperties;
import com.qianwen.core.notify.provider.sms.SmsProvider;
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.notify.template.TemplateManager;
import com.qianwen.core.tool.api.BizMessage;
import com.qianwen.core.tool.metadata.Values;
import com.qianwen.core.tool.support.Kv;
import com.qianwen.core.tool.utils.PlaceholderUtil;
import com.qianwen.core.tool.utils.StringUtil;
import com.yunpian.sdk.YunpianClient;
import com.yunpian.sdk.model.Result;
import com.yunpian.sdk.model.SmsBatchSend;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/sms/yunpian/YunpianSmsNotifier.class */
public class YunpianSmsNotifier extends AbstractNotifier<YunpianSmsTemplate> {
    private static final Logger log = LoggerFactory.getLogger(YunpianSmsNotifier.class);
    private final YunpianClient client;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/sms/yunpian/YunpianSmsTemplate.java

@@ -5,7 +5,6 @@
import javax.validation.constraints.NotBlank;
import com.qianwen.core.notify.template.Template;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/sms/yunpian/YunpianSmsTemplate.class */
public class YunpianSmsTemplate implements Template {
    @NotBlank(message = "[text]短信内容不能为空")
    private String text;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/WechatMiniProvider.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.Provider;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/WechatMiniProvider.class */
public enum WechatMiniProvider implements Provider {
    miniSubMessage("小程序订阅消息"),
    miniDeviceSubMessage("小程序设备订阅消息");

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/WechatProvider.java

@@ -2,7 +2,6 @@

import com.qianwen.core.notify.Provider;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/WechatProvider.class */
public enum WechatProvider implements Provider {
    mpMessage("公众号模板消息");
    

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mini/WechatMiniDeviceNotifierProvider.java

@@ -27,7 +27,6 @@

@ConditionalOnBean({TemplateManager.class})
@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mini/WechatMiniDeviceNotifierProvider.class */
public class WechatMiniDeviceNotifierProvider implements NotifierProvider, TemplateProvider {
    private final TemplateManager templateManager;
    public static final DefaultConfigMetadata templateConfig;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mini/WechatMiniMessageTemplate.java

@@ -5,7 +5,6 @@
import javax.validation.constraints.NotBlank;
import com.qianwen.core.notify.template.Template;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mini/WechatMiniMessageTemplate.class */
public class WechatMiniMessageTemplate implements Template {
    @NotBlank(message = "[templateId]模板Id不能为空")
    private String templateId;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mini/WechatMiniNotifierProvider.java

@@ -27,7 +27,6 @@

@ConditionalOnBean({TemplateManager.class})
@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mini/WechatMiniNotifierProvider.class */
public class WechatMiniNotifierProvider implements NotifierProvider, TemplateProvider {
    private final TemplateManager templateManager;
    public static final DefaultConfigMetadata templateConfig;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mini/WechatMiniProperties.java

@@ -2,7 +2,6 @@

import javax.validation.constraints.NotEmpty;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mini/WechatMiniProperties.class */
public class WechatMiniProperties {
    @NotEmpty(message = "名称不得为空")
    private String name;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mini/WeixinMiniDeviceNotifier.java

@@ -1,16 +1,16 @@
package com.qianwen.core.notify.provider.wechat.mini;

import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage;
import cn.binarywang.wx.miniapp.bean.device.WxMaDeviceSubscribeMessageRequest;
import com.alibaba.fastjson.JSONObject;
import java.time.Duration;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicReference;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.alibaba.fastjson.JSONObject;
import com.qianwen.core.http.HttpRequest;
import com.qianwen.core.log.exception.BizServiceException;
import com.qianwen.core.notify.DefaultNotifyType;
@@ -19,8 +19,6 @@
import com.qianwen.core.notify.notifier.AbstractNotifier;
import com.qianwen.core.notify.notifier.NotifierProperties;
import com.qianwen.core.notify.provider.wechat.WechatMiniProvider;
import com.qianwen.core.notify.provider.wechat.mini.WechatMiniMessageTemplate;
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.notify.template.TemplateManager;
import com.qianwen.core.tool.api.BizMessage;
import com.qianwen.core.tool.metadata.Values;
@@ -28,7 +26,9 @@
import com.qianwen.core.tool.utils.StringFormatUtil;
import com.qianwen.core.tool.utils.StringUtil;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mini/WeixinMiniDeviceNotifier.class */
import cn.binarywang.wx.miniapp.bean.WxMaSubscribeMessage;
import cn.binarywang.wx.miniapp.bean.device.WxMaDeviceSubscribeMessageRequest;

public class WeixinMiniDeviceNotifier extends AbstractNotifier<WechatMiniMessageTemplate> {
    private static final Logger log = LoggerFactory.getLogger(WeixinMiniDeviceNotifier.class);
    private final AtomicReference<String> accessToken;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mini/WeixinMiniNotifier.java

@@ -27,7 +27,6 @@
import com.qianwen.core.tool.utils.StringFormatUtil;
import com.qianwen.core.tool.utils.StringUtil;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mini/WeixinMiniNotifier.class */
public class WeixinMiniNotifier extends AbstractNotifier<WechatMiniMessageTemplate> {
    private static final Logger log = LoggerFactory.getLogger(WeixinMiniNotifier.class);
    private final AtomicReference<String> accessToken;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mp/WechatMpMessageTemplate.java

@@ -4,7 +4,6 @@
import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage;
import com.qianwen.core.notify.template.Template;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mp/WechatMpMessageTemplate.class */
public class WechatMpMessageTemplate implements Template {
    @NotBlank(message = "[templateId]模板Id不能为空")
    private String templateId;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mp/WechatMpNotifierProvider.java

@@ -27,7 +27,6 @@

@ConditionalOnBean({TemplateManager.class})
@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mp/WechatMpNotifierProvider.class */
public class WechatMpNotifierProvider implements NotifierProvider, TemplateProvider {
    private final TemplateManager templateManager;
    public static final DefaultConfigMetadata templateConfig;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mp/WechatMpProperties.java

@@ -3,7 +3,6 @@
import javax.validation.constraints.NotEmpty;
import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mp/WechatMpProperties.class */
public class WechatMpProperties {
    @NotEmpty(message = "名称不得为空")
    private String name;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/mp/WeixinMpNotifier.java

@@ -1,16 +1,16 @@
package com.qianwen.core.notify.provider.wechat.mp;

import com.alibaba.fastjson.JSONObject;
import java.time.Duration;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.atomic.AtomicReference;
import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.alibaba.fastjson.JSONObject;
import com.qianwen.core.http.HttpRequest;
import com.qianwen.core.log.exception.BizServiceException;
import com.qianwen.core.notify.DefaultNotifyType;
@@ -19,14 +19,15 @@
import com.qianwen.core.notify.notifier.AbstractNotifier;
import com.qianwen.core.notify.notifier.NotifierProperties;
import com.qianwen.core.notify.provider.wechat.WechatProvider;
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.notify.template.TemplateManager;
import com.qianwen.core.tool.api.BizMessage;
import com.qianwen.core.tool.metadata.Values;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.core.tool.utils.StringUtil;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/mp/WeixinMpNotifier.class */
import me.chanjar.weixin.mp.bean.template.WxMpTemplateData;
import me.chanjar.weixin.mp.bean.template.WxMpTemplateMessage;

public class WeixinMpNotifier extends AbstractNotifier<WechatMpMessageTemplate> {
    private static final Logger log = LoggerFactory.getLogger(WeixinMpNotifier.class);
    private final AtomicReference<String> accessToken;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/qy/WeixinQyNotifierProvider.java

@@ -20,7 +20,6 @@
import org.springframework.stereotype.Component;

@Component
/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/qy/WeixinQyNotifierProvider.class */
public class WeixinQyNotifierProvider implements NotifierProvider, TemplateProvider {
    private final TemplateManager templateManager;
    public static final DefaultConfigMetadata notifierConfig = new DefaultConfigMetadata("通知配置", "").add("corpid", "公司ID", "", (DataType) new StringType().expand(new ConfigKeyValue[]{ConfigMetadataConstants.required.value(true)})).add("agentid", "应用ID", "", (DataType) new StringType().expand(new ConfigKeyValue[]{ConfigMetadataConstants.required.value(true)})).add("corpsecret", "应用secret", "", (DataType) new StringType().expand(new ConfigKeyValue[]{ConfigMetadataConstants.required.value(true)}));

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/qy/WeixinQyProperties.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify.provider.wechat.qy;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/qy/WeixinQyProperties.class */
public class WeixinQyProperties {
    private String corpid;
    private String corpsecret;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/qy/WeixinQyTextNotifier.java

@@ -1,11 +1,13 @@
package com.qianwen.core.notify.provider.wechat.qy;

import com.alibaba.fastjson.JSONObject;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.alibaba.fastjson.JSONObject;
import com.qianwen.core.http.HttpRequest;
import com.qianwen.core.notify.DefaultNotifyType;
import com.qianwen.core.notify.NotifyType;
@@ -17,13 +19,11 @@
import com.qianwen.core.notify.provider.wechat.qy.entity.WeixinGetUidResult;
import com.qianwen.core.notify.provider.wechat.qy.entity.WeixinQyTextQuery;
import com.qianwen.core.notify.provider.wechat.qy.entity.WeixinQyTokenResult;
import com.qianwen.core.notify.template.Template;
import com.qianwen.core.notify.template.TemplateManager;
import com.qianwen.core.tool.metadata.Values;
import com.qianwen.core.tool.utils.ExpressionUtils;
import com.qianwen.core.tool.utils.StringUtil;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/qy/WeixinQyTextNotifier.class */
public class WeixinQyTextNotifier extends AbstractNotifier<DefaultWeixinQyTemplate> {
    private static final Logger log = LoggerFactory.getLogger(WeixinQyTextNotifier.class);
    private final String notifierId;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/qy/entity/BaseQyResult.java

@@ -4,7 +4,6 @@
import com.qianwen.core.log.exception.BizServiceException;
import com.qianwen.core.tool.api.BizMessage;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/qy/entity/BaseQyResult.class */
public class BaseQyResult implements Serializable {
    private Integer errcode;
    private String errmsg;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/qy/entity/WeixinGetUidQuery.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify.provider.wechat.qy.entity;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/qy/entity/WeixinGetUidQuery.class */
public class WeixinGetUidQuery {
    private String mobile;


 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/qy/entity/WeixinGetUidResult.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify.provider.wechat.qy.entity;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/qy/entity/WeixinGetUidResult.class */
public class WeixinGetUidResult extends BaseQyResult {
    private String userid;


 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/qy/entity/WeixinQyTextQuery.java

@@ -4,7 +4,6 @@
import java.util.List;
import com.qianwen.core.tool.utils.StringUtil;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/qy/entity/WeixinQyTextQuery.class */
public class WeixinQyTextQuery {
    private String touser;
    private String toparty;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/provider/wechat/qy/entity/WeixinQyTokenResult.java

@@ -1,6 +1,5 @@
package com.qianwen.core.notify.provider.wechat.qy.entity;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/provider/wechat/qy/entity/WeixinQyTokenResult.class */
public class WeixinQyTokenResult extends BaseQyResult {
    private String access_token;
    private Integer expires_in;

 smart-starter-notify/src/main/java/com/qianwen/core/notify/template/Template.java

@@ -2,6 +2,5 @@

import java.io.Serializable;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/template/Template.class */
public interface Template extends Serializable {
}

 smart-starter-notify/src/main/java/com/qianwen/core/notify/template/TemplateProperties.java

@@ -2,7 +2,6 @@

import java.io.Serializable;

/* loaded from: blade-starter-notify-9.3.0.0-SNAPSHOT.jar:org/springblade/core/notify/template/TemplateProperties.class */
public class TemplateProperties implements Serializable {
    private String type;
    private String provider;