add job
This commit is contained in:
parent
9e1a051cd1
commit
8b0c506f7e
|
|
@ -0,0 +1,21 @@
|
|||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0"
|
||||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
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>com.bonus</groupId>
|
||||
<artifactId>bonus-common-biz</artifactId>
|
||||
<version>24.12.0-SNAPSHOT</version>
|
||||
</parent>
|
||||
|
||||
<groupId>org.example</groupId>
|
||||
<artifactId>job</artifactId>
|
||||
|
||||
<properties>
|
||||
<maven.compiler.source>21</maven.compiler.source>
|
||||
<maven.compiler.target>21</maven.compiler.target>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
</properties>
|
||||
|
||||
</project>
|
||||
|
|
@ -0,0 +1,40 @@
|
|||
package net.xnzn.framework.job;
|
||||
|
||||
import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
|
||||
import net.xnzn.framework.job.api.XxlJobApi;
|
||||
import org.springframework.boot.autoconfigure.AutoConfiguration;
|
||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
||||
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
||||
import org.springframework.cloud.commons.util.InetUtils;
|
||||
import org.springframework.cloud.commons.util.UtilAutoConfiguration;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
|
||||
@AutoConfiguration(
|
||||
after = {UtilAutoConfiguration.class}
|
||||
)
|
||||
@EnableConfigurationProperties({XxlJobProperties.class})
|
||||
@ConditionalOnProperty(
|
||||
name = {"xxl.job.enabled"},
|
||||
havingValue = "true",
|
||||
matchIfMissing = true
|
||||
)
|
||||
public class XxlJobConfig {
|
||||
@Bean
|
||||
public XxlJobSpringExecutor xxlJobExecutor(XxlJobProperties xxlJobProperties, InetUtils inetUtils) {
|
||||
XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
|
||||
xxlJobSpringExecutor.setAdminAddresses(xxlJobProperties.getAdmin().getAddresses());
|
||||
xxlJobSpringExecutor.setAppname(xxlJobProperties.getExecutor().getAppName());
|
||||
xxlJobSpringExecutor.setAddress(xxlJobProperties.getExecutor().getAddress());
|
||||
xxlJobSpringExecutor.setIp(inetUtils.findFirstNonLoopbackHostInfo().getIpAddress());
|
||||
xxlJobSpringExecutor.setPort(xxlJobProperties.getExecutor().getPort());
|
||||
xxlJobSpringExecutor.setAccessToken(xxlJobProperties.getAdmin().getAccessToken());
|
||||
xxlJobSpringExecutor.setLogPath(xxlJobProperties.getExecutor().getLogPath());
|
||||
xxlJobSpringExecutor.setLogRetentionDays(xxlJobProperties.getExecutor().getLogRetentionDays());
|
||||
return xxlJobSpringExecutor;
|
||||
}
|
||||
|
||||
@Bean
|
||||
public XxlJobApi xxlJobApi(XxlJobProperties xxlJobProperties) {
|
||||
return new XxlJobApi(xxlJobProperties);
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,353 @@
|
|||
package net.xnzn.framework.job;
|
||||
|
||||
import lombok.Generated;
|
||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
||||
|
||||
@ConfigurationProperties(
|
||||
prefix = "xxl.job"
|
||||
)
|
||||
public class XxlJobProperties {
|
||||
public static final String PREFIX = "xxl.job";
|
||||
private boolean enabled = true;
|
||||
private AdminProperties admin = new AdminProperties();
|
||||
private ExecutorProperties executor = new ExecutorProperties();
|
||||
|
||||
@Generated
|
||||
public boolean isEnabled() {
|
||||
return this.enabled;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public AdminProperties getAdmin() {
|
||||
return this.admin;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public ExecutorProperties getExecutor() {
|
||||
return this.executor;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setEnabled(final boolean enabled) {
|
||||
this.enabled = enabled;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setAdmin(final AdminProperties admin) {
|
||||
this.admin = admin;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setExecutor(final ExecutorProperties executor) {
|
||||
this.executor = executor;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public boolean equals(final Object o) {
|
||||
if (o == this) {
|
||||
return true;
|
||||
} else if (!(o instanceof XxlJobProperties)) {
|
||||
return false;
|
||||
} else {
|
||||
XxlJobProperties other = (XxlJobProperties)o;
|
||||
if (!other.canEqual(this)) {
|
||||
return false;
|
||||
} else if (this.isEnabled() != other.isEnabled()) {
|
||||
return false;
|
||||
} else {
|
||||
Object this$admin = this.getAdmin();
|
||||
Object other$admin = other.getAdmin();
|
||||
if (this$admin == null) {
|
||||
if (other$admin != null) {
|
||||
return false;
|
||||
}
|
||||
} else if (!this$admin.equals(other$admin)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
Object this$executor = this.getExecutor();
|
||||
Object other$executor = other.getExecutor();
|
||||
if (this$executor == null) {
|
||||
if (other$executor != null) {
|
||||
return false;
|
||||
}
|
||||
} else if (!this$executor.equals(other$executor)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@Generated
|
||||
protected boolean canEqual(final Object other) {
|
||||
return other instanceof XxlJobProperties;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int hashCode() {
|
||||
int PRIME = true;
|
||||
int result = 1;
|
||||
result = result * 59 + (this.isEnabled() ? 79 : 97);
|
||||
Object $admin = this.getAdmin();
|
||||
result = result * 59 + ($admin == null ? 43 : $admin.hashCode());
|
||||
Object $executor = this.getExecutor();
|
||||
result = result * 59 + ($executor == null ? 43 : $executor.hashCode());
|
||||
return result;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String toString() {
|
||||
boolean var10000 = this.isEnabled();
|
||||
return "XxlJobProperties(enabled=" + var10000 + ", admin=" + String.valueOf(this.getAdmin()) + ", executor=" + String.valueOf(this.getExecutor()) + ")";
|
||||
}
|
||||
|
||||
public static class AdminProperties {
|
||||
private String addresses = "http://127.0.0.1:8080/xxl-job-admin";
|
||||
private String accessToken;
|
||||
|
||||
@Generated
|
||||
public String getAddresses() {
|
||||
return this.addresses;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getAccessToken() {
|
||||
return this.accessToken;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setAddresses(final String addresses) {
|
||||
this.addresses = addresses;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setAccessToken(final String accessToken) {
|
||||
this.accessToken = accessToken;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public boolean equals(final Object o) {
|
||||
if (o == this) {
|
||||
return true;
|
||||
} else if (!(o instanceof AdminProperties)) {
|
||||
return false;
|
||||
} else {
|
||||
AdminProperties other = (AdminProperties)o;
|
||||
if (!other.canEqual(this)) {
|
||||
return false;
|
||||
} else {
|
||||
Object this$addresses = this.getAddresses();
|
||||
Object other$addresses = other.getAddresses();
|
||||
if (this$addresses == null) {
|
||||
if (other$addresses != null) {
|
||||
return false;
|
||||
}
|
||||
} else if (!this$addresses.equals(other$addresses)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
Object this$accessToken = this.getAccessToken();
|
||||
Object other$accessToken = other.getAccessToken();
|
||||
if (this$accessToken == null) {
|
||||
if (other$accessToken != null) {
|
||||
return false;
|
||||
}
|
||||
} else if (!this$accessToken.equals(other$accessToken)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@Generated
|
||||
protected boolean canEqual(final Object other) {
|
||||
return other instanceof AdminProperties;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int hashCode() {
|
||||
int PRIME = true;
|
||||
int result = 1;
|
||||
Object $addresses = this.getAddresses();
|
||||
result = result * 59 + ($addresses == null ? 43 : $addresses.hashCode());
|
||||
Object $accessToken = this.getAccessToken();
|
||||
result = result * 59 + ($accessToken == null ? 43 : $accessToken.hashCode());
|
||||
return result;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String toString() {
|
||||
String var10000 = this.getAddresses();
|
||||
return "XxlJobProperties.AdminProperties(addresses=" + var10000 + ", accessToken=" + this.getAccessToken() + ")";
|
||||
}
|
||||
}
|
||||
|
||||
public static class ExecutorProperties {
|
||||
private String appName = "xxl-job-executor";
|
||||
private String address;
|
||||
private String ip;
|
||||
private int port = 0;
|
||||
private String logPath = "/var/log/xxl-job";
|
||||
private int logRetentionDays = 7;
|
||||
|
||||
@Generated
|
||||
public String getAppName() {
|
||||
return this.appName;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getAddress() {
|
||||
return this.address;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getIp() {
|
||||
return this.ip;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getPort() {
|
||||
return this.port;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getLogPath() {
|
||||
return this.logPath;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getLogRetentionDays() {
|
||||
return this.logRetentionDays;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setAppName(final String appName) {
|
||||
this.appName = appName;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setAddress(final String address) {
|
||||
this.address = address;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setIp(final String ip) {
|
||||
this.ip = ip;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setPort(final int port) {
|
||||
this.port = port;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setLogPath(final String logPath) {
|
||||
this.logPath = logPath;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setLogRetentionDays(final int logRetentionDays) {
|
||||
this.logRetentionDays = logRetentionDays;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public boolean equals(final Object o) {
|
||||
if (o == this) {
|
||||
return true;
|
||||
} else if (!(o instanceof ExecutorProperties)) {
|
||||
return false;
|
||||
} else {
|
||||
ExecutorProperties other = (ExecutorProperties)o;
|
||||
if (!other.canEqual(this)) {
|
||||
return false;
|
||||
} else if (this.getPort() != other.getPort()) {
|
||||
return false;
|
||||
} else if (this.getLogRetentionDays() != other.getLogRetentionDays()) {
|
||||
return false;
|
||||
} else {
|
||||
label64: {
|
||||
Object this$appName = this.getAppName();
|
||||
Object other$appName = other.getAppName();
|
||||
if (this$appName == null) {
|
||||
if (other$appName == null) {
|
||||
break label64;
|
||||
}
|
||||
} else if (this$appName.equals(other$appName)) {
|
||||
break label64;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
label57: {
|
||||
Object this$address = this.getAddress();
|
||||
Object other$address = other.getAddress();
|
||||
if (this$address == null) {
|
||||
if (other$address == null) {
|
||||
break label57;
|
||||
}
|
||||
} else if (this$address.equals(other$address)) {
|
||||
break label57;
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
Object this$ip = this.getIp();
|
||||
Object other$ip = other.getIp();
|
||||
if (this$ip == null) {
|
||||
if (other$ip != null) {
|
||||
return false;
|
||||
}
|
||||
} else if (!this$ip.equals(other$ip)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
Object this$logPath = this.getLogPath();
|
||||
Object other$logPath = other.getLogPath();
|
||||
if (this$logPath == null) {
|
||||
if (other$logPath != null) {
|
||||
return false;
|
||||
}
|
||||
} else if (!this$logPath.equals(other$logPath)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@Generated
|
||||
protected boolean canEqual(final Object other) {
|
||||
return other instanceof ExecutorProperties;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int hashCode() {
|
||||
int PRIME = true;
|
||||
int result = 1;
|
||||
result = result * 59 + this.getPort();
|
||||
result = result * 59 + this.getLogRetentionDays();
|
||||
Object $appName = this.getAppName();
|
||||
result = result * 59 + ($appName == null ? 43 : $appName.hashCode());
|
||||
Object $address = this.getAddress();
|
||||
result = result * 59 + ($address == null ? 43 : $address.hashCode());
|
||||
Object $ip = this.getIp();
|
||||
result = result * 59 + ($ip == null ? 43 : $ip.hashCode());
|
||||
Object $logPath = this.getLogPath();
|
||||
result = result * 59 + ($logPath == null ? 43 : $logPath.hashCode());
|
||||
return result;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String toString() {
|
||||
String var10000 = this.getAppName();
|
||||
return "XxlJobProperties.ExecutorProperties(appName=" + var10000 + ", address=" + this.getAddress() + ", ip=" + this.getIp() + ", port=" + this.getPort() + ", logPath=" + this.getLogPath() + ", logRetentionDays=" + this.getLogRetentionDays() + ")";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,72 @@
|
|||
package net.xnzn.framework.job.api;
|
||||
|
||||
import cn.hutool.core.bean.BeanUtil;
|
||||
import cn.hutool.core.lang.TypeReference;
|
||||
import com.google.common.collect.Maps;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import net.xnzn.framework.job.XxlJobProperties;
|
||||
|
||||
public class XxlJobApi {
|
||||
private final XxlJobRemoteHelper remoteHelper;
|
||||
|
||||
public XxlJobApi(XxlJobProperties properties) {
|
||||
this.remoteHelper = new XxlJobRemoteHelper(properties);
|
||||
}
|
||||
|
||||
public Map<String, Object> pageList(XxlJobInfo xxlJobInfo) {
|
||||
Map<String, Object> params = BeanUtil.beanToMap(xxlJobInfo, false, false);
|
||||
return (Map)this.remoteHelper.sendPost("/jobinfo/pageList", params, new TypeReference<Map<String, Object>>(this) {
|
||||
});
|
||||
}
|
||||
|
||||
public XxlJobReturn<String> add(XxlJobInfo xxlJobInfo) {
|
||||
Map<String, Object> params = BeanUtil.beanToMap(xxlJobInfo, false, false);
|
||||
return (XxlJobReturn)this.remoteHelper.sendPost("/jobinfo/add", params, new TypeReference<XxlJobReturn<String>>(this) {
|
||||
});
|
||||
}
|
||||
|
||||
public XxlJobReturn<String> update(XxlJobInfo xxlJobInfo) {
|
||||
Map<String, Object> params = BeanUtil.beanToMap(xxlJobInfo, false, false);
|
||||
return (XxlJobReturn)this.remoteHelper.sendPost("/jobinfo/update", params, new TypeReference<XxlJobReturn<String>>(this) {
|
||||
});
|
||||
}
|
||||
|
||||
public XxlJobReturn<String> remove(int id) {
|
||||
Map<String, Object> params = Maps.newHashMap();
|
||||
params.put("id", id);
|
||||
return (XxlJobReturn)this.remoteHelper.sendPost("/jobinfo/remove", params, new TypeReference<XxlJobReturn<String>>(this) {
|
||||
});
|
||||
}
|
||||
|
||||
public XxlJobReturn<String> stop(int id) {
|
||||
Map<String, Object> params = Maps.newHashMap();
|
||||
params.put("id", id);
|
||||
return (XxlJobReturn)this.remoteHelper.sendPost("/jobinfo/stop", params, new TypeReference<XxlJobReturn<String>>(this) {
|
||||
});
|
||||
}
|
||||
|
||||
public XxlJobReturn<String> start(int id) {
|
||||
Map<String, Object> params = Maps.newHashMap();
|
||||
params.put("id", id);
|
||||
return (XxlJobReturn)this.remoteHelper.sendPost("/jobinfo/start", params, new TypeReference<XxlJobReturn<String>>(this) {
|
||||
});
|
||||
}
|
||||
|
||||
public XxlJobReturn<String> triggerJob(int id, String executorParam, String addressList) {
|
||||
Map<String, Object> params = Maps.newHashMap();
|
||||
params.put("id", id);
|
||||
params.put("executorParam", executorParam);
|
||||
params.put("addressList", addressList);
|
||||
return (XxlJobReturn)this.remoteHelper.sendPost("/jobinfo/trigger", params, new TypeReference<XxlJobReturn<String>>(this) {
|
||||
});
|
||||
}
|
||||
|
||||
public XxlJobReturn<List<String>> nextTriggerTime(String scheduleType, String scheduleConf) {
|
||||
Map<String, Object> params = Maps.newHashMap();
|
||||
params.put("scheduleType", scheduleType);
|
||||
params.put("scheduleConf", scheduleConf);
|
||||
return (XxlJobReturn)this.remoteHelper.sendPost("/jobinfo/nextTriggerTime", params, new TypeReference<XxlJobReturn<List<String>>>(this) {
|
||||
});
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,271 @@
|
|||
package net.xnzn.framework.job.api;
|
||||
|
||||
import java.util.Date;
|
||||
import lombok.Generated;
|
||||
|
||||
public class XxlJobInfo {
|
||||
private int id;
|
||||
private int jobGroup;
|
||||
private String jobDesc;
|
||||
private Date addTime;
|
||||
private Date updateTime;
|
||||
private String author;
|
||||
private String alarmEmail;
|
||||
private String scheduleType;
|
||||
private String scheduleConf;
|
||||
private String misfireStrategy;
|
||||
private String executorRouteStrategy;
|
||||
private String executorHandler;
|
||||
private String executorParam;
|
||||
private String executorBlockStrategy;
|
||||
private int executorTimeout;
|
||||
private int executorFailRetryCount;
|
||||
private String glueType;
|
||||
private String glueSource;
|
||||
private String glueRemark;
|
||||
private Date glueUpdatetime;
|
||||
private String childJobId;
|
||||
private int triggerStatus;
|
||||
private long triggerLastTime;
|
||||
private long triggerNextTime;
|
||||
|
||||
@Generated
|
||||
public void setId(final int id) {
|
||||
this.id = id;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setJobGroup(final int jobGroup) {
|
||||
this.jobGroup = jobGroup;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setJobDesc(final String jobDesc) {
|
||||
this.jobDesc = jobDesc;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setAddTime(final Date addTime) {
|
||||
this.addTime = addTime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setUpdateTime(final Date updateTime) {
|
||||
this.updateTime = updateTime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setAuthor(final String author) {
|
||||
this.author = author;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setAlarmEmail(final String alarmEmail) {
|
||||
this.alarmEmail = alarmEmail;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setScheduleType(final String scheduleType) {
|
||||
this.scheduleType = scheduleType;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setScheduleConf(final String scheduleConf) {
|
||||
this.scheduleConf = scheduleConf;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setMisfireStrategy(final String misfireStrategy) {
|
||||
this.misfireStrategy = misfireStrategy;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setExecutorRouteStrategy(final String executorRouteStrategy) {
|
||||
this.executorRouteStrategy = executorRouteStrategy;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setExecutorHandler(final String executorHandler) {
|
||||
this.executorHandler = executorHandler;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setExecutorParam(final String executorParam) {
|
||||
this.executorParam = executorParam;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setExecutorBlockStrategy(final String executorBlockStrategy) {
|
||||
this.executorBlockStrategy = executorBlockStrategy;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setExecutorTimeout(final int executorTimeout) {
|
||||
this.executorTimeout = executorTimeout;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setExecutorFailRetryCount(final int executorFailRetryCount) {
|
||||
this.executorFailRetryCount = executorFailRetryCount;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setGlueType(final String glueType) {
|
||||
this.glueType = glueType;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setGlueSource(final String glueSource) {
|
||||
this.glueSource = glueSource;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setGlueRemark(final String glueRemark) {
|
||||
this.glueRemark = glueRemark;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setGlueUpdatetime(final Date glueUpdatetime) {
|
||||
this.glueUpdatetime = glueUpdatetime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setChildJobId(final String childJobId) {
|
||||
this.childJobId = childJobId;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setTriggerStatus(final int triggerStatus) {
|
||||
this.triggerStatus = triggerStatus;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setTriggerLastTime(final long triggerLastTime) {
|
||||
this.triggerLastTime = triggerLastTime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setTriggerNextTime(final long triggerNextTime) {
|
||||
this.triggerNextTime = triggerNextTime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getId() {
|
||||
return this.id;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getJobGroup() {
|
||||
return this.jobGroup;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getJobDesc() {
|
||||
return this.jobDesc;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public Date getAddTime() {
|
||||
return this.addTime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public Date getUpdateTime() {
|
||||
return this.updateTime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getAuthor() {
|
||||
return this.author;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getAlarmEmail() {
|
||||
return this.alarmEmail;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getScheduleType() {
|
||||
return this.scheduleType;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getScheduleConf() {
|
||||
return this.scheduleConf;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getMisfireStrategy() {
|
||||
return this.misfireStrategy;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getExecutorRouteStrategy() {
|
||||
return this.executorRouteStrategy;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getExecutorHandler() {
|
||||
return this.executorHandler;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getExecutorParam() {
|
||||
return this.executorParam;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getExecutorBlockStrategy() {
|
||||
return this.executorBlockStrategy;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getExecutorTimeout() {
|
||||
return this.executorTimeout;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getExecutorFailRetryCount() {
|
||||
return this.executorFailRetryCount;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getGlueType() {
|
||||
return this.glueType;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getGlueSource() {
|
||||
return this.glueSource;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getGlueRemark() {
|
||||
return this.glueRemark;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public Date getGlueUpdatetime() {
|
||||
return this.glueUpdatetime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getChildJobId() {
|
||||
return this.childJobId;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getTriggerStatus() {
|
||||
return this.triggerStatus;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public long getTriggerLastTime() {
|
||||
return this.triggerLastTime;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public long getTriggerNextTime() {
|
||||
return this.triggerNextTime;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,63 @@
|
|||
package net.xnzn.framework.job.api;
|
||||
|
||||
import cn.hutool.core.lang.TypeReference;
|
||||
import cn.hutool.http.Header;
|
||||
import cn.hutool.http.HttpRequest;
|
||||
import cn.hutool.http.HttpResponse;
|
||||
import cn.hutool.json.JSONObject;
|
||||
import cn.hutool.json.JSONUtil;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Map;
|
||||
import lombok.Generated;
|
||||
import net.xnzn.framework.job.XxlJobProperties;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.util.DigestUtils;
|
||||
|
||||
public class XxlJobRemoteHelper {
|
||||
@Generated
|
||||
private static final Logger log = LoggerFactory.getLogger(XxlJobRemoteHelper.class);
|
||||
private static final String LOGIN_IDENTITY_KEY = "XXL_JOB_LOGIN_IDENTITY";
|
||||
private final XxlJobProperties properties;
|
||||
|
||||
public XxlJobRemoteHelper(XxlJobProperties properties) {
|
||||
this.properties = properties;
|
||||
}
|
||||
|
||||
public <T> T sendPost(String path, Map<String, Object> param, TypeReference<T> clz, Object... uriVariables) {
|
||||
String var10000 = this.properties.getAdmin().getAddresses();
|
||||
HttpRequest req = ((HttpRequest)HttpRequest.post(var10000 + path).header(Header.COOKIE, "XXL_JOB_LOGIN_IDENTITY=" + this.getLoginIdentity())).form(param).timeout(10000);
|
||||
log.info("【xxl-job】发送：{}Form Param:\n{}", req, param);
|
||||
HttpResponse res = req.execute();
|
||||
log.info("【xxl-job】返回：{}", res);
|
||||
return JSONUtil.toBean(res.body(), clz, true);
|
||||
}
|
||||
|
||||
private String getLoginIdentity() {
|
||||
XxlJobUser adminUser = new XxlJobUser();
|
||||
adminUser.setId(1);
|
||||
adminUser.setUsername("admin");
|
||||
String password = this.properties.getAdmin().getAccessToken();
|
||||
String passwordMd5 = DigestUtils.md5DigestAsHex(password.getBytes());
|
||||
adminUser.setPassword(passwordMd5);
|
||||
adminUser.setRole(1);
|
||||
adminUser.setPermission((String)null);
|
||||
return this.makeToken(adminUser);
|
||||
}
|
||||
|
||||
private String makeToken(XxlJobUser xxlJobUser) {
|
||||
String tokenJson = JSONUtil.toJsonStr(xxlJobUser);
|
||||
return (new BigInteger(tokenJson.getBytes())).toString(16);
|
||||
}
|
||||
|
||||
private XxlJobUser parseToken(String tokenHex) {
|
||||
new JSONObject();
|
||||
XxlJobUser xxlJobUser = null;
|
||||
if (tokenHex != null) {
|
||||
String tokenJson = new String((new BigInteger(tokenHex, 16)).toByteArray());
|
||||
xxlJobUser = (XxlJobUser)JSONUtil.toBean(tokenJson, XxlJobUser.class);
|
||||
}
|
||||
|
||||
return xxlJobUser;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,66 @@
|
|||
package net.xnzn.framework.job.api;
|
||||
|
||||
import com.xxl.job.core.biz.model.ReturnT;
|
||||
import lombok.Generated;
|
||||
|
||||
public class XxlJobReturn<T> {
|
||||
public static final int SUCCESS_CODE = 200;
|
||||
public static final int FAIL_CODE = 500;
|
||||
public static final ReturnT<String> SUCCESS = new ReturnT((Object)null);
|
||||
public static final ReturnT<String> FAIL = new ReturnT(500, (String)null);
|
||||
private int code;
|
||||
private String msg;
|
||||
private T content;
|
||||
|
||||
public XxlJobReturn() {
|
||||
}
|
||||
|
||||
public XxlJobReturn(int code, String msg) {
|
||||
this.code = code;
|
||||
this.msg = msg;
|
||||
}
|
||||
|
||||
public XxlJobReturn(T content) {
|
||||
this.code = 200;
|
||||
this.content = content;
|
||||
}
|
||||
|
||||
public boolean isSuccess() {
|
||||
return 200 == this.code;
|
||||
}
|
||||
|
||||
public String toString() {
|
||||
int var10000 = this.code;
|
||||
return "ReturnT [code=" + var10000 + ", msg=" + this.msg + ", content=" + String.valueOf(this.content) + "]";
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setCode(final int code) {
|
||||
this.code = code;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setMsg(final String msg) {
|
||||
this.msg = msg;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setContent(final T content) {
|
||||
this.content = content;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getCode() {
|
||||
return this.code;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getMsg() {
|
||||
return this.msg;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public T getContent() {
|
||||
return this.content;
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,82 @@
|
|||
package net.xnzn.framework.job.api;
|
||||
|
||||
import lombok.Generated;
|
||||
import org.springframework.util.StringUtils;
|
||||
|
||||
public class XxlJobUser {
|
||||
private int id;
|
||||
private String username;
|
||||
private String password;
|
||||
private int role;
|
||||
private String permission;
|
||||
|
||||
public boolean validPermission(int jobGroup) {
|
||||
if (this.role == 1) {
|
||||
return true;
|
||||
} else {
|
||||
if (StringUtils.hasText(this.permission)) {
|
||||
String[] var2 = this.permission.split(",");
|
||||
int var3 = var2.length;
|
||||
|
||||
for(int var4 = 0; var4 < var3; ++var4) {
|
||||
String permissionItem = var2[var4];
|
||||
if (String.valueOf(jobGroup).equals(permissionItem)) {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setId(final int id) {
|
||||
this.id = id;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setUsername(final String username) {
|
||||
this.username = username;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setPassword(final String password) {
|
||||
this.password = password;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setRole(final int role) {
|
||||
this.role = role;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public void setPermission(final String permission) {
|
||||
this.permission = permission;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getId() {
|
||||
return this.id;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getUsername() {
|
||||
return this.username;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getPassword() {
|
||||
return this.password;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public int getRole() {
|
||||
return this.role;
|
||||
}
|
||||
|
||||
@Generated
|
||||
public String getPermission() {
|
||||
return this.permission;
|
||||
}
|
||||
}
|
||||
|
|
@ -19,6 +19,7 @@
|
|||
<module>pigx-common-log</module>
|
||||
<module>pigx-common-oss</module>
|
||||
<module>pigx-common-security</module>
|
||||
<module>job</module>
|
||||
</modules>
|
||||
|
||||
<artifactId>bonus-common-biz</artifactId>
|
||||
|
|
|
|||
Loading…
Reference in New Issue