This commit is contained in:
zc
2026-02-27 10:50:07 +08:00
parent 0ee56404c2
commit 86527b9c21
611 changed files with 2741 additions and 2752 deletions

View File

@@ -3,11 +3,11 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>top.ysoft</groupId>
<artifactId>ysoft-plugin</artifactId>
<groupId>top.wms</groupId>
<artifactId>wms-plugin</artifactId>
<version>3.6.0-SNAPSHOT</version>
</parent>
<artifactId>ysoft-plugin-schedule</artifactId>
<artifactId>wms-plugin-schedule</artifactId>
<version>3.6.0-SNAPSHOT</version>
<description>任务调度插件</description>
<licenses>

View File

@@ -2,13 +2,13 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>top.ysoft</groupId>
<artifactId>ysoft-plugin</artifactId>
<groupId>top.wms</groupId>
<artifactId>wms-plugin</artifactId>
<version>${revision}</version>
</parent>
<artifactId>ysoft-plugin-schedule</artifactId>
<artifactId>wms-plugin-schedule</artifactId>
<description>任务调度插件</description>
<dependencies>

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.api;
package top.wms.admin.schedule.api;
import com.aizuda.snailjob.common.core.model.Result;
import org.springframework.http.MediaType;
@@ -7,10 +7,10 @@ import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.service.annotation.*;
import top.ysoft.admin.schedule.model.JobPageResult;
import top.ysoft.admin.schedule.model.req.JobReq;
import top.ysoft.admin.schedule.model.req.JobStatusReq;
import top.ysoft.admin.schedule.model.resp.JobResp;
import top.wms.admin.schedule.model.JobPageResult;
import top.wms.admin.schedule.model.req.JobReq;
import top.wms.admin.schedule.model.req.JobStatusReq;
import top.wms.admin.schedule.model.resp.JobResp;
import java.util.List;
import java.util.Set;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.api;
package top.wms.admin.schedule.api;
import com.aizuda.snailjob.common.core.model.Result;
import org.springframework.http.MediaType;
@@ -8,10 +8,10 @@ import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.service.annotation.GetExchange;
import org.springframework.web.service.annotation.HttpExchange;
import org.springframework.web.service.annotation.PostExchange;
import top.ysoft.admin.schedule.model.JobInstanceLogPageResult;
import top.ysoft.admin.schedule.model.JobPageResult;
import top.ysoft.admin.schedule.model.resp.JobInstanceResp;
import top.ysoft.admin.schedule.model.resp.JobLogResp;
import top.wms.admin.schedule.model.JobInstanceLogPageResult;
import top.wms.admin.schedule.model.JobPageResult;
import top.wms.admin.schedule.model.resp.JobInstanceResp;
import top.wms.admin.schedule.model.resp.JobLogResp;
import java.util.List;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.api;
package top.wms.admin.schedule.api;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil;
@@ -16,8 +16,8 @@ import com.aizuda.snailjob.common.core.model.Result;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.ResponseEntity;
import top.ysoft.admin.schedule.constant.JobConstants;
import top.ysoft.admin.schedule.model.JobPageResult;
import top.wms.admin.schedule.constant.JobConstants;
import top.wms.admin.schedule.model.JobPageResult;
import top.continew.starter.cache.redisson.util.RedisUtils;
import top.continew.starter.extension.crud.model.resp.PageResp;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.config;
package top.wms.admin.schedule.config;
import com.fasterxml.jackson.databind.ObjectMapper;
import io.netty.channel.ChannelOption;
@@ -20,10 +20,10 @@ import org.springframework.web.reactive.function.client.support.WebClientAdapter
import org.springframework.web.service.invoker.HttpServiceProxyFactory;
import reactor.core.publisher.Mono;
import reactor.netty.http.client.HttpClient;
import top.ysoft.admin.schedule.api.JobApi;
import top.ysoft.admin.schedule.api.JobBatchApi;
import top.ysoft.admin.schedule.api.JobClient;
import top.ysoft.admin.schedule.constant.JobConstants;
import top.wms.admin.schedule.api.JobApi;
import top.wms.admin.schedule.api.JobBatchApi;
import top.wms.admin.schedule.api.JobClient;
import top.wms.admin.schedule.constant.JobConstants;
/**
* HTTP Exchange 配置

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.config;
package top.wms.admin.schedule.config;
import ch.qos.logback.classic.Logger;
import ch.qos.logback.classic.LoggerContext;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.constant;
package top.wms.admin.schedule.constant;
/**
* 任务调度常量

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.enums;
package top.wms.admin.schedule.enums;
import lombok.Getter;
import lombok.RequiredArgsConstructor;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.enums;
package top.wms.admin.schedule.enums;
import lombok.Getter;
import lombok.RequiredArgsConstructor;

View File

@@ -1,8 +1,8 @@
package top.ysoft.admin.schedule.enums;
package top.wms.admin.schedule.enums;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import top.ysoft.admin.common.constant.UiConstants;
import top.wms.admin.common.constant.UiConstants;
import top.continew.starter.core.enums.BaseEnum;
/**

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.enums;
package top.wms.admin.schedule.enums;
import lombok.Getter;
import lombok.RequiredArgsConstructor;

View File

@@ -1,8 +1,8 @@
package top.ysoft.admin.schedule.enums;
package top.wms.admin.schedule.enums;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import top.ysoft.admin.common.constant.UiConstants;
import top.wms.admin.common.constant.UiConstants;
import top.continew.starter.core.enums.BaseEnum;
/**

View File

@@ -1,8 +1,8 @@
package top.ysoft.admin.schedule.enums;
package top.wms.admin.schedule.enums;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import top.ysoft.admin.common.constant.UiConstants;
import top.wms.admin.common.constant.UiConstants;
import top.continew.starter.core.enums.BaseEnum;
/**

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.enums;
package top.wms.admin.schedule.enums;
import lombok.Getter;
import lombok.RequiredArgsConstructor;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.model;
package top.wms.admin.schedule.model;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.model;
package top.wms.admin.schedule.model;
import com.aizuda.snailjob.common.core.model.Result;
import lombok.Data;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.model.query;
package top.wms.admin.schedule.model.query;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.Min;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.model.query;
package top.wms.admin.schedule.model.query;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.model.query;
package top.wms.admin.schedule.model.query;
import cn.hutool.core.date.DatePattern;
import io.swagger.v3.oas.annotations.media.Schema;
@@ -7,7 +7,7 @@ import jakarta.validation.constraints.Size;
import lombok.Data;
import org.hibernate.validator.constraints.Range;
import org.springframework.format.annotation.DateTimeFormat;
import top.ysoft.admin.schedule.enums.JobExecuteStatusEnum;
import top.wms.admin.schedule.enums.JobExecuteStatusEnum;
import java.io.Serial;
import java.io.Serializable;
@@ -35,7 +35,7 @@ public class JobLogQuery implements Serializable {
/**
* 任务组
*/
@Schema(description = "任务组", example = "ysoft-admin")
@Schema(description = "任务组", example = "wms-admin")
private String groupName;
/**

View File

@@ -1,10 +1,10 @@
package top.ysoft.admin.schedule.model.query;
package top.wms.admin.schedule.model.query;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.Min;
import lombok.Data;
import org.hibernate.validator.constraints.Range;
import top.ysoft.admin.schedule.enums.JobStatusEnum;
import top.wms.admin.schedule.enums.JobStatusEnum;
import java.io.Serial;
import java.io.Serializable;
@@ -25,7 +25,7 @@ public class JobQuery implements Serializable {
/**
* 任务组
*/
@Schema(description = "任务组", example = "ysoft-admin")
@Schema(description = "任务组", example = "wms-admin")
private String groupName;
/**

View File

@@ -1,11 +1,11 @@
package top.ysoft.admin.schedule.model.req;
package top.wms.admin.schedule.model.req;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull;
import lombok.Data;
import org.hibernate.validator.constraints.Length;
import top.ysoft.admin.schedule.enums.*;
import top.wms.admin.schedule.enums.*;
import java.io.Serial;
import java.io.Serializable;
@@ -27,7 +27,7 @@ public class JobReq implements Serializable {
/**
* 任务组
*/
@Schema(description = "任务组", example = "ysoft-admin")
@Schema(description = "任务组", example = "wms-admin")
@NotBlank(message = "任务组不能为空")
private String groupName;

View File

@@ -1,9 +1,9 @@
package top.ysoft.admin.schedule.model.req;
package top.wms.admin.schedule.model.req;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotNull;
import lombok.Data;
import top.ysoft.admin.schedule.enums.JobStatusEnum;
import top.wms.admin.schedule.enums.JobStatusEnum;
import java.io.Serial;
import java.io.Serializable;

View File

@@ -1,4 +1,4 @@
package top.ysoft.admin.schedule.model.resp;
package top.wms.admin.schedule.model.resp;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@@ -29,7 +29,7 @@ public class JobInstanceResp implements Serializable {
/**
* 任务组
*/
@Schema(description = "任务组", example = "ysoft-admin")
@Schema(description = "任务组", example = "wms-admin")
private String groupName;
/**

View File

@@ -1,9 +1,9 @@
package top.ysoft.admin.schedule.model.resp;
package top.wms.admin.schedule.model.resp;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import top.ysoft.admin.schedule.enums.JobExecuteReasonEnum;
import top.ysoft.admin.schedule.enums.JobExecuteStatusEnum;
import top.wms.admin.schedule.enums.JobExecuteReasonEnum;
import top.wms.admin.schedule.enums.JobExecuteStatusEnum;
import java.io.Serial;
import java.io.Serializable;
@@ -32,7 +32,7 @@ public class JobLogResp implements Serializable {
/**
* 任务组
*/
@Schema(description = "任务组", example = "ysoft-admin")
@Schema(description = "任务组", example = "wms-admin")
private String groupName;
/**

View File

@@ -1,8 +1,8 @@
package top.ysoft.admin.schedule.model.resp;
package top.wms.admin.schedule.model.resp;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import top.ysoft.admin.schedule.enums.*;
import top.wms.admin.schedule.enums.*;
import java.io.Serial;
import java.io.Serializable;
@@ -31,7 +31,7 @@ public class JobResp implements Serializable {
/**
* 任务组
*/
@Schema(description = "任务组", example = "ysoft-admin")
@Schema(description = "任务组", example = "wms-admin")
private String groupName;
/**

View File

@@ -1,11 +1,11 @@
package top.ysoft.admin.schedule.service;
package top.wms.admin.schedule.service;
import top.ysoft.admin.schedule.model.JobInstanceLogPageResult;
import top.ysoft.admin.schedule.model.query.JobInstanceLogQuery;
import top.ysoft.admin.schedule.model.query.JobInstanceQuery;
import top.ysoft.admin.schedule.model.query.JobLogQuery;
import top.ysoft.admin.schedule.model.resp.JobInstanceResp;
import top.ysoft.admin.schedule.model.resp.JobLogResp;
import top.wms.admin.schedule.model.JobInstanceLogPageResult;
import top.wms.admin.schedule.model.query.JobInstanceLogQuery;
import top.wms.admin.schedule.model.query.JobInstanceQuery;
import top.wms.admin.schedule.model.query.JobLogQuery;
import top.wms.admin.schedule.model.resp.JobInstanceResp;
import top.wms.admin.schedule.model.resp.JobLogResp;
import top.continew.starter.extension.crud.model.resp.PageResp;
import java.util.List;

View File

@@ -1,9 +1,9 @@
package top.ysoft.admin.schedule.service;
package top.wms.admin.schedule.service;
import top.ysoft.admin.schedule.model.query.JobQuery;
import top.ysoft.admin.schedule.model.req.JobReq;
import top.ysoft.admin.schedule.model.req.JobStatusReq;
import top.ysoft.admin.schedule.model.resp.JobResp;
import top.wms.admin.schedule.model.query.JobQuery;
import top.wms.admin.schedule.model.req.JobReq;
import top.wms.admin.schedule.model.req.JobStatusReq;
import top.wms.admin.schedule.model.resp.JobResp;
import top.continew.starter.extension.crud.model.resp.PageResp;
import java.util.List;

View File

@@ -1,18 +1,18 @@
package top.ysoft.admin.schedule.service.impl;
package top.wms.admin.schedule.service.impl;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import top.ysoft.admin.schedule.api.JobBatchApi;
import top.ysoft.admin.schedule.api.JobClient;
import top.ysoft.admin.schedule.model.JobInstanceLogPageResult;
import top.ysoft.admin.schedule.model.query.JobInstanceLogQuery;
import top.ysoft.admin.schedule.model.query.JobInstanceQuery;
import top.ysoft.admin.schedule.model.query.JobLogQuery;
import top.ysoft.admin.schedule.model.resp.JobInstanceResp;
import top.ysoft.admin.schedule.model.resp.JobLogResp;
import top.ysoft.admin.schedule.service.JobLogService;
import top.wms.admin.schedule.api.JobBatchApi;
import top.wms.admin.schedule.api.JobClient;
import top.wms.admin.schedule.model.JobInstanceLogPageResult;
import top.wms.admin.schedule.model.query.JobInstanceLogQuery;
import top.wms.admin.schedule.model.query.JobInstanceQuery;
import top.wms.admin.schedule.model.query.JobLogQuery;
import top.wms.admin.schedule.model.resp.JobInstanceResp;
import top.wms.admin.schedule.model.resp.JobLogResp;
import top.wms.admin.schedule.service.JobLogService;
import top.continew.starter.extension.crud.model.resp.PageResp;
import java.time.LocalDateTime;

View File

@@ -1,14 +1,14 @@
package top.ysoft.admin.schedule.service.impl;
package top.wms.admin.schedule.service.impl;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import top.ysoft.admin.schedule.api.JobApi;
import top.ysoft.admin.schedule.api.JobClient;
import top.ysoft.admin.schedule.model.query.JobQuery;
import top.ysoft.admin.schedule.model.req.JobReq;
import top.ysoft.admin.schedule.model.req.JobStatusReq;
import top.ysoft.admin.schedule.model.resp.JobResp;
import top.ysoft.admin.schedule.service.JobService;
import top.wms.admin.schedule.api.JobApi;
import top.wms.admin.schedule.api.JobClient;
import top.wms.admin.schedule.model.query.JobQuery;
import top.wms.admin.schedule.model.req.JobReq;
import top.wms.admin.schedule.model.req.JobStatusReq;
import top.wms.admin.schedule.model.resp.JobResp;
import top.wms.admin.schedule.service.JobService;
import top.continew.starter.extension.crud.model.resp.PageResp;
import java.util.Collections;