删除无用代码

miniapp/src/main/java/com/kym/miniapp/jobs/DynamicTaskService.java

@@ -1,108 +0,0 @@
-package com.kym.miniapp.jobs;
-
-import cn.hutool.core.convert.ConverterRegistry;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
-import org.springframework.stereotype.Component;
-
-import java.time.LocalDateTime;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.CopyOnWriteArrayList;
-import java.util.concurrent.ScheduledFuture;
-
-/**
- * 动态定时任务
- */
-@Component
-@Slf4j
-public class DynamicTaskService {
-
-    private final ThreadPoolTaskScheduler syncScheduler;
-    /**
-     * 以下两个都是线程安全的集合类。
-     */
-    public Map<String, ScheduledFuture<?>> taskMap = new ConcurrentHashMap<>();
-    public List<String> taskList = new CopyOnWriteArrayList<>();
-
-    public DynamicTaskService(ThreadPoolTaskScheduler syncScheduler) {
-        this.syncScheduler = syncScheduler;
-    }
-
-    /**
-     * 查看已开启但还未执行的动态任务
-     *
-     * @return
-     */
-    public List<String> getTaskList() {
-        return taskList;
-    }
-
-
-    /**
-     * 添加一个动态任务
-     *
-     * @param task
-     * @return
-     */
-    public boolean add(Task task) {
-        // 此处的逻辑是 ，如果当前已经有这个名字的任务存在，先删除之前的，再添加现在的。（即重复就覆盖）
-        if (null != taskMap.get(task.getName())) {
-            stop(task.getName());
-        }
-
-        // hutool 工具包下的一个转换类型工具类 好用的很
-        ConverterRegistry converterRegistry = ConverterRegistry.getInstance();
-        Date startTime = converterRegistry.convert(Date.class, task.getStartTime());
-
-        // schedule :调度给定的Runnable ，在指定的执行时间调用它。
-        //一旦调度程序关闭或返回的ScheduledFuture被取消，执行将结束。
-        //参数：
-        //任务 – 触发器触发时执行的 Runnable
-        //startTime – 任务所需的执行时间（如果这是过去，则任务将立即执行，即尽快执行）
-        ScheduledFuture<?> schedule = syncScheduler.schedule(task, startTime);
-        taskMap.put(task.getName(), schedule);
-        taskList.add(task.getName());
-        return true;
-    }
-
-
-    /**
-     * 运行任务
-     *
-     * @param task
-     * @return
-     */
-/*    public Runnable getRunnable(Task task) {
-        return () -> {
-            log.info("---动态定时任务运行---");
-            try {
-                log.debug("此时时间==>" + LocalDateTime.now());
-                log.debug("task中设定的时间==>" + task);
-                Thread.sleep(10);
-            } catch (InterruptedException e) {
-                e.printStackTrace();
-            }
-            log.info("---end--------");
-        };
-    }*/
-
-    /**
-     * 停止任务
-     *
-     * @param name
-     * @return
-     */
-    public boolean stop(String name) {
-        if (null == taskMap.get(name)) {
-            return false;
-        }
-        ScheduledFuture<?> scheduledFuture = taskMap.get(name);
-        scheduledFuture.cancel(true);
-        taskMap.remove(name);
-        taskList.remove(name);
-        return true;
-    }
-}

miniapp/src/main/java/com/kym/miniapp/jobs/OfflineNotice.java

@@ -1,28 +0,0 @@
-package com.kym.miniapp.jobs;
-
-import com.kym.service.admin.MonitorLogService;
-import org.springframework.stereotype.Component;
-
-/**
- * 离线通知
- *
- * @author skyline
- * @date 2023-08-29 15:45
- */
-@Component
-public class OfflineNotice extends Task {
-
-    private final MonitorLogService monitorLogService;
-
-
-    public OfflineNotice(MonitorLogService monitorLogService) {
-        this.monitorLogService = monitorLogService;
-    }
-
-    @Override
-    public void run() {
-        // TODO 查询该设备在线情况，恢复在线则修改记录状态为已恢复，依旧离线则告警通知，修改状态为以告警
-
-
-    }
-}

miniapp/src/main/java/com/kym/miniapp/jobs/Task.java

@@ -1,26 +0,0 @@
-package com.kym.miniapp.jobs;
-
-import lombok.Data;
-import lombok.experimental.Accessors;
-
-import java.time.LocalDateTime;
-
-/**
- * @author skyline
- * @description
- * @date 2023-08-29 14:15
- */
-@Data
-@Accessors(chain = true) // 方便链式编写
-public abstract class Task implements Runnable {
-    /**
-     * 动态任务名称
-     */
-    private String name;
-
-    /**
-     * 设定动态任务开始时间
-     */
-    private LocalDateTime startTime;
-
-}

miniapp/src/main/java/com/kym/miniapp/utils/WxUtil.java

@@ -1,66 +0,0 @@
-package com.kym.miniapp.utils;
-
-import com.alibaba.fastjson2.JSONObject;
-import com.kym.common.constant.ResponseEnum;
-import com.kym.common.exception.BusinessException;
-import com.kym.miniapp.enums.WxApi;
-import lombok.SneakyThrows;
-import okhttp3.HttpUrl;
-import okhttp3.OkHttpClient;
-import okhttp3.Request;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * @author skyline
- * @description
- * @date 2023-07-23 16:26
- */
-public class WxUtil {
-
-    private static final Logger LOGGER = LoggerFactory.getLogger(WxUtil.class);
-
-/*
-    @SneakyThrows
-    String WxLogin(String code) {
-        // 微信登录
-        var appid = "";
-        var secret = "";
-        var js_code = "";
-        var grant_type = "";
-
-        OkHttpClient client = new OkHttpClient();
-        HttpUrl url = HttpUrl.parse(WxApi.WX_MP_LOGIN.getApi()).newBuilder()
-                .addQueryParameter("appid", appid)
-                .addQueryParameter("secret", secret)
-                .addQueryParameter("js_code", js_code)
-                .addQueryParameter("grant_type", grant_type)
-                .build();
-
-        Request request = new Request.Builder()
-                .url(url)
-                .build();
-
-        var response = client.newCall(request).execute().body().string();
-        JSONObject json = JSONObject.parseObject(response);
-        var errorCode = json.getIntValue("errcode");
-        if (200 == errorCode) {
-            // 业务逻辑处理
-            var openid = json.getString("openid");
-            var session_key = json.getString("session_key");
-            var unionid = json.getString("unionid");
-        } else {
-            // 抛出异常
-            LOGGER.error("微信登录异常,错误码{}，异常信息{}", errorCode, json.getString("errMsg"));
-            throw new BusinessException(ResponseEnum.WX_MP_LOGIN_ERROR);
-        }
-
-        return null;
-    }
-*/
-
-
-}
-
-
-