mirror of
https://gitee.com/wangkang/udf.git
synced 2026-10-29 21:53:49 +00:00
增加元数据
This commit is contained in:
+98
@@ -6,9 +6,15 @@
|
||||
*/
|
||||
package com.egridcloud.udf.scheduler;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
import org.springframework.boot.context.properties.ConfigurationProperties;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import com.egridcloud.udf.scheduler.mate.CronTriggerMate;
|
||||
import com.egridcloud.udf.scheduler.mate.JobDetailMate;
|
||||
import com.egridcloud.udf.scheduler.mate.SimpleTriggerMate;
|
||||
|
||||
/**
|
||||
* 描述 : SchedulerProperties
|
||||
*
|
||||
@@ -19,4 +25,96 @@ import org.springframework.stereotype.Component;
|
||||
@ConfigurationProperties(prefix = "com.egridcloud.scheduler.properties")
|
||||
public class SchedulerProperties {
|
||||
|
||||
/**
|
||||
* 描述 : 组别 ( key : 组别代码 , value : 组别描述 )
|
||||
*/
|
||||
private Map<String, String> group;
|
||||
|
||||
/**
|
||||
* 描述 : 作业 ( kety : 作业代码[jobCode] )
|
||||
*/
|
||||
private Map<String, JobDetailMate> jobDetail;
|
||||
|
||||
/**
|
||||
* 描述 : 简单触发器 ( key: 触发器代码[simpleTriggerCode] )
|
||||
*/
|
||||
private Map<String, SimpleTriggerMate> simpleTrigger;
|
||||
|
||||
/**
|
||||
* 描述 : cron触发器 (key : 触发器代码[cronTriggerCode])
|
||||
*/
|
||||
private Map<String, CronTriggerMate> cronTrigger;
|
||||
|
||||
/**
|
||||
* 描述 : 获取cronTrigger
|
||||
*
|
||||
* @return the cronTrigger
|
||||
*/
|
||||
public Map<String, CronTriggerMate> getCronTrigger() {
|
||||
return cronTrigger;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置cronTrigger
|
||||
*
|
||||
* @param cronTrigger the cronTrigger to set
|
||||
*/
|
||||
public void setCronTrigger(Map<String, CronTriggerMate> cronTrigger) {
|
||||
this.cronTrigger = cronTrigger;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取simpleTrigger
|
||||
*
|
||||
* @return the simpleTrigger
|
||||
*/
|
||||
public Map<String, SimpleTriggerMate> getSimpleTrigger() {
|
||||
return simpleTrigger;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置simpleTrigger
|
||||
*
|
||||
* @param simpleTrigger the simpleTrigger to set
|
||||
*/
|
||||
public void setSimpleTrigger(Map<String, SimpleTriggerMate> simpleTrigger) {
|
||||
this.simpleTrigger = simpleTrigger;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取group
|
||||
*
|
||||
* @return the group
|
||||
*/
|
||||
public Map<String, String> getGroup() {
|
||||
return group;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置group
|
||||
*
|
||||
* @param group the group to set
|
||||
*/
|
||||
public void setGroup(Map<String, String> group) {
|
||||
this.group = group;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取jobDetail
|
||||
*
|
||||
* @return the jobDetail
|
||||
*/
|
||||
public Map<String, JobDetailMate> getJobDetail() {
|
||||
return jobDetail;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置jobDetail
|
||||
*
|
||||
* @param jobDetail the jobDetail to set
|
||||
*/
|
||||
public void setJobDetail(Map<String, JobDetailMate> jobDetail) {
|
||||
this.jobDetail = jobDetail;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
+70
@@ -0,0 +1,70 @@
|
||||
/**
|
||||
* CronTriggerMate.java
|
||||
* Created at 2017-06-02
|
||||
* Created by Administrator
|
||||
* Copyright (C) 2016 egridcloud.com, All rights reserved.
|
||||
*/
|
||||
package com.egridcloud.udf.scheduler.mate;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 描述 : CronTriggerMate.java
|
||||
*
|
||||
* @author Administrator
|
||||
*
|
||||
*/
|
||||
public class CronTriggerMate extends TriggerMate implements Serializable {
|
||||
|
||||
/**
|
||||
* 描述 : ID
|
||||
*/
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
/**
|
||||
* 描述 : cron表达式
|
||||
*/
|
||||
private String cron;
|
||||
|
||||
/**
|
||||
* 描述 : 时区ID
|
||||
*/
|
||||
private String timeZoneId;
|
||||
|
||||
/**
|
||||
* 描述 : 获取cron
|
||||
*
|
||||
* @return the cron
|
||||
*/
|
||||
public String getCron() {
|
||||
return cron;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置cron
|
||||
*
|
||||
* @param cron the cron to set
|
||||
*/
|
||||
public void setCron(String cron) {
|
||||
this.cron = cron;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取timeZoneId
|
||||
*
|
||||
* @return the timeZoneId
|
||||
*/
|
||||
public String getTimeZoneId() {
|
||||
return timeZoneId;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置timeZoneId
|
||||
*
|
||||
* @param timeZoneId the timeZoneId to set
|
||||
*/
|
||||
public void setTimeZoneId(String timeZoneId) {
|
||||
this.timeZoneId = timeZoneId;
|
||||
}
|
||||
|
||||
}
|
||||
+186
@@ -0,0 +1,186 @@
|
||||
/**
|
||||
* JobDetailMate.java
|
||||
* Created at 2017-06-02
|
||||
* Created by Administrator
|
||||
* Copyright (C) 2016 egridcloud.com, All rights reserved.
|
||||
*/
|
||||
package com.egridcloud.udf.scheduler.mate;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.util.Map;
|
||||
|
||||
/**
|
||||
* 描述 : JobDetailMate
|
||||
*
|
||||
* @author Administrator
|
||||
*
|
||||
*/
|
||||
public class JobDetailMate implements Serializable {
|
||||
|
||||
/**
|
||||
* 描述 : ID
|
||||
*/
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
/**
|
||||
* 描述 : 名称
|
||||
*/
|
||||
private String name;
|
||||
|
||||
/**
|
||||
* 描述 : 组别
|
||||
*/
|
||||
private String group;
|
||||
|
||||
/**
|
||||
* 描述 : 类型
|
||||
*/
|
||||
private String className;
|
||||
|
||||
/**
|
||||
* 描述 : 描述
|
||||
*/
|
||||
private String description;
|
||||
|
||||
/**
|
||||
* 描述 : 是否可恢复
|
||||
*/
|
||||
private Boolean recovery = false;
|
||||
|
||||
/**
|
||||
* 描述 : 是否持久化
|
||||
*/
|
||||
private Boolean durability = true;
|
||||
|
||||
/**
|
||||
* 描述 : 数据
|
||||
*/
|
||||
private Map<String, String> dataMap;
|
||||
|
||||
/**
|
||||
* 描述 : 获取name
|
||||
*
|
||||
* @return the name
|
||||
*/
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置name
|
||||
*
|
||||
* @param name the name to set
|
||||
*/
|
||||
public void setName(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取group
|
||||
*
|
||||
* @return the group
|
||||
*/
|
||||
public String getGroup() {
|
||||
return group;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置group
|
||||
*
|
||||
* @param group the group to set
|
||||
*/
|
||||
public void setGroup(String group) {
|
||||
this.group = group;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取className
|
||||
*
|
||||
* @return the className
|
||||
*/
|
||||
public String getClassName() {
|
||||
return className;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置className
|
||||
*
|
||||
* @param className the className to set
|
||||
*/
|
||||
public void setClassName(String className) {
|
||||
this.className = className;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取description
|
||||
*
|
||||
* @return the description
|
||||
*/
|
||||
public String getDescription() {
|
||||
return description;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置description
|
||||
*
|
||||
* @param description the description to set
|
||||
*/
|
||||
public void setDescription(String description) {
|
||||
this.description = description;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取recovery
|
||||
*
|
||||
* @return the recovery
|
||||
*/
|
||||
public Boolean getRecovery() {
|
||||
return recovery;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置recovery
|
||||
*
|
||||
* @param recovery the recovery to set
|
||||
*/
|
||||
public void setRecovery(Boolean recovery) {
|
||||
this.recovery = recovery;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取durability
|
||||
*
|
||||
* @return the durability
|
||||
*/
|
||||
public Boolean getDurability() {
|
||||
return durability;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置durability
|
||||
*
|
||||
* @param durability the durability to set
|
||||
*/
|
||||
public void setDurability(Boolean durability) {
|
||||
this.durability = durability;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取dataMap
|
||||
*
|
||||
* @return the dataMap
|
||||
*/
|
||||
public Map<String, String> getDataMap() {
|
||||
return dataMap;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置dataMap
|
||||
*
|
||||
* @param dataMap the dataMap to set
|
||||
*/
|
||||
public void setDataMap(Map<String, String> dataMap) {
|
||||
this.dataMap = dataMap;
|
||||
}
|
||||
|
||||
}
|
||||
+72
@@ -0,0 +1,72 @@
|
||||
/**
|
||||
* SimpleTriggerMate.java
|
||||
* Created at 2017-06-02
|
||||
* Created by Administrator
|
||||
* Copyright (C) 2016 egridcloud.com, All rights reserved.
|
||||
*/
|
||||
package com.egridcloud.udf.scheduler.mate;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
import org.quartz.SimpleTrigger;
|
||||
|
||||
/**
|
||||
* 描述 : SimpleTriggerMate.java
|
||||
*
|
||||
* @author Administrator
|
||||
*
|
||||
*/
|
||||
public class SimpleTriggerMate extends TriggerMate implements Serializable {
|
||||
|
||||
/**
|
||||
* 描述 : ID
|
||||
*/
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
/**
|
||||
* 描述 : 重复次数
|
||||
*/
|
||||
private Integer repeatCount = SimpleTrigger.REPEAT_INDEFINITELY;
|
||||
|
||||
/**
|
||||
* 描述 : 执行间隔
|
||||
*/
|
||||
private Long intervalInMilliseconds;
|
||||
|
||||
/**
|
||||
* 描述 : 获取repeatCount
|
||||
*
|
||||
* @return the repeatCount
|
||||
*/
|
||||
public Integer getRepeatCount() {
|
||||
return repeatCount;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置repeatCount
|
||||
*
|
||||
* @param repeatCount the repeatCount to set
|
||||
*/
|
||||
public void setRepeatCount(Integer repeatCount) {
|
||||
this.repeatCount = repeatCount;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取intervalInMilliseconds
|
||||
*
|
||||
* @return the intervalInMilliseconds
|
||||
*/
|
||||
public Long getIntervalInMilliseconds() {
|
||||
return intervalInMilliseconds;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置intervalInMilliseconds
|
||||
*
|
||||
* @param intervalInMilliseconds the intervalInMilliseconds to set
|
||||
*/
|
||||
public void setIntervalInMilliseconds(Long intervalInMilliseconds) {
|
||||
this.intervalInMilliseconds = intervalInMilliseconds;
|
||||
}
|
||||
|
||||
}
|
||||
+258
@@ -0,0 +1,258 @@
|
||||
/**
|
||||
* SimpleTriggerMate.java
|
||||
* Created at 2017-06-02
|
||||
* Created by Administrator
|
||||
* Copyright (C) 2016 egridcloud.com, All rights reserved.
|
||||
*/
|
||||
package com.egridcloud.udf.scheduler.mate;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.util.Date;
|
||||
import java.util.Map;
|
||||
|
||||
import org.quartz.Trigger;
|
||||
|
||||
/**
|
||||
* 描述 : SimpleTriggerMate.java
|
||||
*
|
||||
* @author Administrator
|
||||
*
|
||||
*/
|
||||
public class TriggerMate implements Serializable {
|
||||
|
||||
/**
|
||||
* 描述 : ID
|
||||
*/
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
/**
|
||||
* 描述 : 作业代码
|
||||
*/
|
||||
private String jobCode;
|
||||
|
||||
/**
|
||||
* 描述 : 名称
|
||||
*/
|
||||
private String name;
|
||||
|
||||
/**
|
||||
* 描述 : 组别
|
||||
*/
|
||||
private String group;
|
||||
|
||||
/**
|
||||
* 描述 : 描述
|
||||
*/
|
||||
private String description;
|
||||
|
||||
/**
|
||||
* 描述 : 开始时间
|
||||
*/
|
||||
private Date startTime = new Date();
|
||||
|
||||
/**
|
||||
* 描述 : 结束时间
|
||||
*/
|
||||
private Date endTime;
|
||||
|
||||
/**
|
||||
* 描述 : 优先级
|
||||
*/
|
||||
private Integer priority = 0;
|
||||
|
||||
/**
|
||||
* 描述 : 日历
|
||||
*/
|
||||
private String calendar;
|
||||
|
||||
/**
|
||||
* 描述 : 遗漏对应的策略
|
||||
*/
|
||||
private Integer misfireInstruction = Trigger.MISFIRE_INSTRUCTION_SMART_POLICY;
|
||||
|
||||
/**
|
||||
* 描述 : 数据
|
||||
*/
|
||||
private Map<String, String> dataMap;
|
||||
|
||||
/**
|
||||
* 描述 : 获取misfireInstruction
|
||||
*
|
||||
* @return the misfireInstruction
|
||||
*/
|
||||
public Integer getMisfireInstruction() {
|
||||
return misfireInstruction;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置misfireInstruction
|
||||
*
|
||||
* @param misfireInstruction the misfireInstruction to set
|
||||
*/
|
||||
public void setMisfireInstruction(Integer misfireInstruction) {
|
||||
this.misfireInstruction = misfireInstruction;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取jobCode
|
||||
*
|
||||
* @return the jobCode
|
||||
*/
|
||||
public String getJobCode() {
|
||||
return jobCode;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置jobCode
|
||||
*
|
||||
* @param jobCode the jobCode to set
|
||||
*/
|
||||
public void setJobCode(String jobCode) {
|
||||
this.jobCode = jobCode;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取name
|
||||
*
|
||||
* @return the name
|
||||
*/
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置name
|
||||
*
|
||||
* @param name the name to set
|
||||
*/
|
||||
public void setName(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取group
|
||||
*
|
||||
* @return the group
|
||||
*/
|
||||
public String getGroup() {
|
||||
return group;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置group
|
||||
*
|
||||
* @param group the group to set
|
||||
*/
|
||||
public void setGroup(String group) {
|
||||
this.group = group;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取description
|
||||
*
|
||||
* @return the description
|
||||
*/
|
||||
public String getDescription() {
|
||||
return description;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置description
|
||||
*
|
||||
* @param description the description to set
|
||||
*/
|
||||
public void setDescription(String description) {
|
||||
this.description = description;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取startTime
|
||||
*
|
||||
* @return the startTime
|
||||
*/
|
||||
public Date getStartTime() {
|
||||
return startTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置startTime
|
||||
*
|
||||
* @param startTime the startTime to set
|
||||
*/
|
||||
public void setStartTime(Date startTime) {
|
||||
this.startTime = startTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取endTime
|
||||
*
|
||||
* @return the endTime
|
||||
*/
|
||||
public Date getEndTime() {
|
||||
return endTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置endTime
|
||||
*
|
||||
* @param endTime the endTime to set
|
||||
*/
|
||||
public void setEndTime(Date endTime) {
|
||||
this.endTime = endTime;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取priority
|
||||
*
|
||||
* @return the priority
|
||||
*/
|
||||
public Integer getPriority() {
|
||||
return priority;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置priority
|
||||
*
|
||||
* @param priority the priority to set
|
||||
*/
|
||||
public void setPriority(Integer priority) {
|
||||
this.priority = priority;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取calendar
|
||||
*
|
||||
* @return the calendar
|
||||
*/
|
||||
public String getCalendar() {
|
||||
return calendar;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置calendar
|
||||
*
|
||||
* @param calendar the calendar to set
|
||||
*/
|
||||
public void setCalendar(String calendar) {
|
||||
this.calendar = calendar;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 获取dataMap
|
||||
*
|
||||
* @return the dataMap
|
||||
*/
|
||||
public Map<String, String> getDataMap() {
|
||||
return dataMap;
|
||||
}
|
||||
|
||||
/**
|
||||
* 描述 : 设置dataMap
|
||||
*
|
||||
* @param dataMap the dataMap to set
|
||||
*/
|
||||
public void setDataMap(Map<String, String> dataMap) {
|
||||
this.dataMap = dataMap;
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user