fix: must be restarted to take effect after modify server url (#253)

Signed-off-by: BobDu <i@bobdu.cc>

Author: BobDu

src/main/java/io/jenkins/plugins/DingTalkGlobalConfig.java

@@ -12,6 +12,7 @@
 import java.util.Optional;
 import java.util.Set;
 import java.util.stream.Collectors;
+import io.jenkins.plugins.service.DingTalkService;
 import jenkins.model.Jenkins;
 import lombok.Getter;
 import lombok.ToString;
@@ -86,6 +87,7 @@ public void setProxyConfig(DingTalkProxyConfig proxyConfig) {
 
   @DataBoundSetter
   public void setRobotConfigs(ArrayList<DingTalkRobotConfig> robotConfigs) {
+    DingTalkService.getInstance().resetSenders();
     this.robotConfigs = robotConfigs;
   }
 

src/main/java/io/jenkins/plugins/DingTalkRunListener.java

@@ -21,7 +21,7 @@
 import io.jenkins.plugins.model.BuildJobModel;
 import io.jenkins.plugins.model.ButtonModel;
 import io.jenkins.plugins.model.MessageModel;
-import io.jenkins.plugins.service.impl.DingTalkServiceImpl;
+import io.jenkins.plugins.service.DingTalkService;
 import io.jenkins.plugins.tools.DingTalkUtils;
 import io.jenkins.plugins.tools.Logger;
 import io.jenkins.plugins.tools.Utils;
@@ -43,8 +43,6 @@
 @Extension
 public class DingTalkRunListener extends RunListener<Run<?, ?>> {
 
-	private final DingTalkServiceImpl service = new DingTalkServiceImpl();
-
 	@Override
 	public void onStarted(Run<?, ?> run, TaskListener listener) {
 		DingTalkGlobalConfig globalConfig = DingTalkGlobalConfig.getInstance();
@@ -329,7 +327,7 @@ private void send(Run<?, ?> run, TaskListener listener, NoticeOccasionEnum notic
 			DingTalkUtils.log(listener, "当前机器人信息，%s", Utils.toJson(item));
 			DingTalkUtils.log(listener, "发送的消息详情，%s", Utils.toJson(message));
 
-			String msg = service.send(robotId, msgModel);
+			String msg = DingTalkService.getInstance().send(robotId, msgModel);
 
 			if (msg != null) {
 				result.add(msg);

src/main/java/io/jenkins/plugins/DingTalkStep.java

@@ -9,7 +9,7 @@
 import io.jenkins.plugins.enums.MsgTypeEnum;
 import io.jenkins.plugins.model.ButtonModel;
 import io.jenkins.plugins.model.MessageModel;
-import io.jenkins.plugins.service.impl.DingTalkServiceImpl;
+import io.jenkins.plugins.service.DingTalkService;
 import io.jenkins.plugins.tools.DingTalkUtils;
 import io.jenkins.plugins.tools.Logger;
 import io.jenkins.plugins.tools.Utils;
@@ -74,8 +74,6 @@ public class DingTalkStep extends Step {
 
   private String rootPath = Jenkins.get().getRootUrl();
 
-  private DingTalkServiceImpl service = new DingTalkServiceImpl();
-
   @DataBoundConstructor
   public DingTalkStep(String robot) {
     this.robot = robot;
@@ -200,7 +198,7 @@ public String send(Run<?, ?> run, EnvVars envVars, TaskListener listener) {
         Utils.toJson(DingTalkGlobalConfig.getRobot(robot)));
     DingTalkUtils.log(listener, "发送的消息详情，%s", Utils.toJson(message));
 
-    return service.send(envVars.expand(robot), message);
+    return DingTalkService.getInstance().send(envVars.expand(robot), message);
   }
 
   @Override

src/main/java/io/jenkins/plugins/service/DingTalkService.java

@@ -1,13 +1,84 @@
 package io.jenkins.plugins.service;
 
+import io.jenkins.plugins.DingTalkGlobalConfig;
+import io.jenkins.plugins.DingTalkRobotConfig;
+import io.jenkins.plugins.enums.MsgTypeEnum;
 import io.jenkins.plugins.model.MessageModel;
+import io.jenkins.plugins.sdk.DingTalkSender;
+import java.net.Proxy;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.Optional;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * 发送消息
  *
  * @author liuwei
  */
-public interface DingTalkService {
+public class DingTalkService {
 
-  String send(String robot, MessageModel msg);
+    private static volatile DingTalkService instance;
+    private final Map<String, DingTalkSender> senders = new ConcurrentHashMap<>();
+
+    public static DingTalkService getInstance() {
+        if (instance == null) {
+            synchronized (DingTalkService.class) {
+                if (instance == null) {
+                    instance = new DingTalkService();
+                }
+            }
+        }
+        return instance;
+    }
+
+    private DingTalkSender getSender(String robotId) {
+        DingTalkSender sender = senders.get(robotId);
+        if (sender == null) {
+            synchronized (senders) {
+                sender = senders.get(robotId);
+                if (sender == null) {
+                    DingTalkGlobalConfig globalConfig = DingTalkGlobalConfig.getInstance();
+                    Proxy proxy = globalConfig.getProxy();
+                    ArrayList<DingTalkRobotConfig> robotConfigs = globalConfig.getRobotConfigs();
+                    Optional<DingTalkRobotConfig> robotConfigOptional = robotConfigs.stream()
+                            .filter(item -> robotId.equals(item.getId()))
+                            .findAny();
+                    if (robotConfigOptional.isPresent()) {
+                        DingTalkRobotConfig robotConfig = robotConfigOptional.get();
+                        sender = new DingTalkSender(robotConfig, proxy);
+                        senders.put(robotId, sender);
+                    }
+                }
+            }
+        }
+        return sender;
+    }
+
+    public void resetSenders() {
+        senders.clear();
+    }
+
+    public String send(String robotId, MessageModel msg) {
+        MsgTypeEnum type = msg.getType();
+        DingTalkSender sender = getSender(robotId);
+        if (sender == null) {
+            return String.format("ID 为 %s 的机器人不存在。", robotId);
+        }
+        if (type == null) {
+            return "消息类型【type】不能为空";
+        }
+        switch (type) {
+            case TEXT:
+                return sender.sendText(msg);
+            case LINK:
+                return sender.sendLink(msg);
+            case MARKDOWN:
+                return sender.sendMarkdown(msg);
+            case ACTION_CARD:
+                return sender.sendActionCard(msg);
+            default:
+                return String.format("错误的消息类型：%s", type.name());
+        }
+    }
 }