diff --git a/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/SchedulerProperties.java b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/SchedulerProperties.java index 8855a52..a5f518f 100644 --- a/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/SchedulerProperties.java +++ b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/SchedulerProperties.java @@ -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 group; + + /** + * 描述 : 作业 ( kety : 作业代码[jobCode] ) + */ + private Map jobDetail; + + /** + * 描述 : 简单触发器 ( key: 触发器代码[simpleTriggerCode] ) + */ + private Map simpleTrigger; + + /** + * 描述 : cron触发器 (key : 触发器代码[cronTriggerCode]) + */ + private Map cronTrigger; + + /** + * 描述 : 获取cronTrigger + * + * @return the cronTrigger + */ + public Map getCronTrigger() { + return cronTrigger; + } + + /** + * 描述 : 设置cronTrigger + * + * @param cronTrigger the cronTrigger to set + */ + public void setCronTrigger(Map cronTrigger) { + this.cronTrigger = cronTrigger; + } + + /** + * 描述 : 获取simpleTrigger + * + * @return the simpleTrigger + */ + public Map getSimpleTrigger() { + return simpleTrigger; + } + + /** + * 描述 : 设置simpleTrigger + * + * @param simpleTrigger the simpleTrigger to set + */ + public void setSimpleTrigger(Map simpleTrigger) { + this.simpleTrigger = simpleTrigger; + } + + /** + * 描述 : 获取group + * + * @return the group + */ + public Map getGroup() { + return group; + } + + /** + * 描述 : 设置group + * + * @param group the group to set + */ + public void setGroup(Map group) { + this.group = group; + } + + /** + * 描述 : 获取jobDetail + * + * @return the jobDetail + */ + public Map getJobDetail() { + return jobDetail; + } + + /** + * 描述 : 设置jobDetail + * + * @param jobDetail the jobDetail to set + */ + public void setJobDetail(Map jobDetail) { + this.jobDetail = jobDetail; + } + } diff --git a/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/CronTriggerMate.java b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/CronTriggerMate.java new file mode 100644 index 0000000..11b4ddb --- /dev/null +++ b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/CronTriggerMate.java @@ -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; + } + +} diff --git a/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/JobDetailMate.java b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/JobDetailMate.java new file mode 100644 index 0000000..5a70438 --- /dev/null +++ b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/JobDetailMate.java @@ -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 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 getDataMap() { + return dataMap; + } + + /** + * 描述 : 设置dataMap + * + * @param dataMap the dataMap to set + */ + public void setDataMap(Map dataMap) { + this.dataMap = dataMap; + } + +} diff --git a/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/SimpleTriggerMate.java b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/SimpleTriggerMate.java new file mode 100644 index 0000000..e908ae3 --- /dev/null +++ b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/SimpleTriggerMate.java @@ -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; + } + +} diff --git a/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/TriggerMate.java b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/TriggerMate.java new file mode 100644 index 0000000..7808225 --- /dev/null +++ b/udf-starter-scheduler/src/main/java/com/egridcloud/udf/scheduler/mate/TriggerMate.java @@ -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 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 getDataMap() { + return dataMap; + } + + /** + * 描述 : 设置dataMap + * + * @param dataMap the dataMap to set + */ + public void setDataMap(Map dataMap) { + this.dataMap = dataMap; + } + +}