新增手动触发全量定时任务接口 /triger

src/main/java/com/geedge/common/Code.java

@@ -0,0 +1,28 @@
+package com.geedge.common;
+
+
+public enum Code {
+
+    SUCCESS(200, "success"),
+    ERROR(999, "error");
+
+
+
+
+
+    private Integer code;
+    public Integer getCode() {
+        return code;
+    }
+
+    private String msg;
+    public String getMsg() {
+        return msg;
+    }
+
+
+    private Code(Integer code, String msg) {
+        this.code = code;
+        this.msg = msg;
+    }
+}

src/main/java/com/geedge/common/ResponseData.java

@@ -0,0 +1,21 @@
+package com.geedge.common;
+
+import cn.hutool.json.JSONObject;
+
+import java.util.HashMap;
+
+
+public class ResponseData extends HashMap<String, Object> {
+    private static final long serialVersionUID = 1L;
+
+
+    public ResponseData() {
+        put("code", Code.SUCCESS.getCode());
+        put("msg", Code.SUCCESS.getMsg());
+    }
+
+    public static ResponseData ok() {
+        return new ResponseData();
+    }
+
+}

src/main/java/com/geedge/controller/ArtificialTriggerController.java

@@ -0,0 +1,90 @@
+package com.geedge.controller;
+
+import com.geedge.common.ResponseData;
+import com.geedge.scheduler.FqdnScheduler;
+import com.geedge.scheduler.IpScheduler;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * TODO
+ *
+ * @Classname ArtificialTriggerController
+ * @Date 2024/1/29 14:08
+ * @Author wWei
+ */
+@RestController("/")
+public class ArtificialTriggerController {
+    private FqdnScheduler fqdnScheduler;
+    private IpScheduler ipScheduler;
+
+    @PostMapping("trigger")
+    public ResponseData triggerAll() {
+        fqdnScheduler.updateCyberghostvpn();
+        fqdnScheduler.deleteCyberghostvpn();
+
+        fqdnScheduler.updateIvacyvpn();
+        fqdnScheduler.deleteIvacyvpn();
+
+        fqdnScheduler.updateIpvanishvpn();
+        fqdnScheduler.deleteIpvanishvpn();
+
+        fqdnScheduler.updateVpnunlimited();
+        fqdnScheduler.deleteVpnunlimited();
+
+        fqdnScheduler.updateWindscribevpn();
+        fqdnScheduler.deleteWindscribevpn();
+
+        fqdnScheduler.updateVpn4fame();
+        fqdnScheduler.deleteVpn4fame();
+
+        ipScheduler.updateCyberghostvpn();
+        ipScheduler.deleteCyberghostvpn();
+
+        ipScheduler.updateHotspotvpn();
+        ipScheduler.deleteHotspotvpn();
+
+        ipScheduler.updateIpvanishvpn();
+        ipScheduler.deleteIpvanishvpn();
+
+        ipScheduler.updateGeckovpn();
+        ipScheduler.deleteGeckovpn();
+
+        ipScheduler.updateIvacyvpn();
+        ipScheduler.deleteIvacyvpn();
+
+        ipScheduler.updateTurbovpn();
+        ipScheduler.deleteTurbovpn();
+
+        ipScheduler.updateVpnunlimited();
+        ipScheduler.deleteVpnunlimited();
+
+        ipScheduler.updateWindscribevpn();
+        ipScheduler.deleteWindscribevpn();
+
+        ipScheduler.updateVpn4fame();
+        ipScheduler.deleteVpn4fame();
+
+        ipScheduler.updateProtonvpn();
+        ipScheduler.deleteProtonvpn();
+
+        ipScheduler.updateExpressvpn();
+        ipScheduler.deleteExpressvpn();
+
+        ipScheduler.updatePsiphon3vpn();
+        ipScheduler.deletePsiphon3vpn();
+        return ResponseData.ok();
+    }
+
+    @Autowired
+    private void setFqdnScheduler(FqdnScheduler fqdnScheduler) {
+        this.fqdnScheduler = fqdnScheduler;
+    }
+
+    @Autowired
+    private void setIpScheduler(IpScheduler ipScheduler) {
+        this.ipScheduler = ipScheduler;
+    }
+}

src/main/java/com/geedge/scheduler/FqdnScheduler.java

@@ -175,7 +175,7 @@ public class FqdnScheduler {
     }
 
     @Scheduled(cron = "${tsg.object.fqdn.windscribevpn_servername.delete.cron}")
-    public void deleteVWindscribevpn() {
+    public void deleteWindscribevpn() {
         executeDelete(windscribevpnServernameId, windscribevpnServernameDeleteEnable, windscribevpnServernameOffsetSecond);
     }