init

cloud-job-api/src/main/java/com/fulan/application/job/domain/VmyJob.java → cloud-job-api/src/main/java/com/yizhi/application/job/domain/VmyJob.java

-package com.yizhi.application.job.domain;
-
-import lombok.Data;
-/**
- * 创建Job实体类
- * @author yinyuyan 2018/06/06
- *
- */
-@Data
-public class VmyJob {
-	/**
-	 * 任务分组
-	 */
-	private String group;
-	/**
-	 * 任务名称
-	 */
-	private String jobName;
-	/**
-	 * 任务job的class名
-	 */
-	private String jobClassName;
-	/**
-	 * 秒
-	 */
-	private String second="0";
-	/**
-	 * 分
-	 */
-	private String minute="*";
-	/**
-	 * 时
-	 */
-	private String hour="*";
-	/**
-	 * 天
-	 */
-	private String day="*";
-	/**
-	 * 月
-	 */
-	private String month="*";
-	/**
-	 * 星期
-	 */
-	private String week="?";
-	/**
-	 * 年
-	 */
-	private String year="2099";
-}
+package com.yizhi.application.job.domain;
+
+import lombok.Data;
+/**
+ * 创建Job实体类
+ * @author yinyuyan 2018/06/06
+ *
+ */
+@Data
+public class VmyJob {
+	/**
+	 * 任务分组
+	 */
+	private String group;
+	/**
+	 * 任务名称
+	 */
+	private String jobName;
+	/**
+	 * 任务job的class名
+	 */
+	private String jobClassName;
+	/**
+	 * 秒
+	 */
+	private String second="0";
+	/**
+	 * 分
+	 */
+	private String minute="*";
+	/**
+	 * 时
+	 */
+	private String hour="*";
+	/**
+	 * 天
+	 */
+	private String day="*";
+	/**
+	 * 月
+	 */
+	private String month="*";
+	/**
+	 * 星期
+	 */
+	private String week="?";
+	/**
+	 * 年
+	 */
+	private String year="2099";
+}

cloud-job-api/src/main/java/com/fulan/application/job/remote/JobClient.java → cloud-job-api/src/main/java/com/yizhi/application/job/remote/JobClient.java

-package com.yizhi.application.job.remote;
-
-import com.yizhi.application.job.domain.VmyJob;
-import org.springframework.cloud.openfeign.FeignClient;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
-
-@FeignClient(value = "job", contextId = "JobClient")
-public interface JobClient {
-    /**
-     * 新增任务
-     *
-     * @param job
-     * @throws Exception
-     */
-    @RequestMapping(value = "/remote/job/insert", method = RequestMethod.POST)
-    void insert(@RequestBody VmyJob job) throws Exception;
-
-    /**
-     * 修改任务
-     *
-     * @param job
-     * @throws Exception
-     */
-    @RequestMapping(value = "/remote/job/update", method = RequestMethod.POST)
-    void update(@RequestBody VmyJob job) throws Exception;
-
-    /**
-     * 删除任务
-     *
-     * @param jobKey
-     * @throws Exception
-     */
-    @RequestMapping(value = "/remote/job/delete", method = RequestMethod.POST)
-    void delete(@RequestParam("jobKey") String jobKey) throws Exception;
-
-}
+package com.yizhi.application.job.remote;
+
+import com.yizhi.application.job.domain.VmyJob;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient(value = "job", contextId = "JobClient")
+public interface JobClient {
+    /**
+     * 新增任务
+     *
+     * @param job
+     * @throws Exception
+     */
+    @RequestMapping(value = "/remote/job/insert", method = RequestMethod.POST)
+    void insert(@RequestBody VmyJob job) throws Exception;
+
+    /**
+     * 修改任务
+     *
+     * @param job
+     * @throws Exception
+     */
+    @RequestMapping(value = "/remote/job/update", method = RequestMethod.POST)
+    void update(@RequestBody VmyJob job) throws Exception;
+
+    /**
+     * 删除任务
+     *
+     * @param jobKey
+     * @throws Exception
+     */
+    @RequestMapping(value = "/remote/job/delete", method = RequestMethod.POST)
+    void delete(@RequestParam("jobKey") String jobKey) throws Exception;
+
+}

cloud-job-api/target/classes/com/fulan/application/job/domain/VmyJob.java

+package com.yizhi.application.job.domain;
+
+import lombok.Data;
+/**
+ * 创建Job实体类
+ * @author yinyuyan 2018/06/06
+ *
+ */
+@Data
+public class VmyJob {
+	/**
+	 * 任务分组
+	 */
+	private String group;
+	/**
+	 * 任务名称
+	 */
+	private String jobName;
+	/**
+	 * 任务job的class名
+	 */
+	private String jobClassName;
+	/**
+	 * 秒
+	 */
+	private String second="0";
+	/**
+	 * 分
+	 */
+	private String minute="*";
+	/**
+	 * 时
+	 */
+	private String hour="*";
+	/**
+	 * 天
+	 */
+	private String day="*";
+	/**
+	 * 月
+	 */
+	private String month="*";
+	/**
+	 * 星期
+	 */
+	private String week="?";
+	/**
+	 * 年
+	 */
+	private String year="2099";
+}

cloud-job-api/target/classes/com/fulan/application/job/remote/JobClient.java

+package com.yizhi.application.job.remote;
+
+import com.yizhi.application.job.domain.VmyJob;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient(value = "job", contextId = "JobClient")
+public interface JobClient {
+    /**
+     * 新增任务
+     *
+     * @param job
+     * @throws Exception
+     */
+    @RequestMapping(value = "/remote/job/insert", method = RequestMethod.POST)
+    void insert(@RequestBody VmyJob job) throws Exception;
+
+    /**
+     * 修改任务
+     *
+     * @param job
+     * @throws Exception
+     */
+    @RequestMapping(value = "/remote/job/update", method = RequestMethod.POST)
+    void update(@RequestBody VmyJob job) throws Exception;
+
+    /**
+     * 删除任务
+     *
+     * @param jobKey
+     * @throws Exception
+     */
+    @RequestMapping(value = "/remote/job/delete", method = RequestMethod.POST)
+    void delete(@RequestParam("jobKey") String jobKey) throws Exception;
+
+}

cloud-job-api/target/maven-archiver/pom.properties

+artifactId=cloud-job-api
+groupId=com.yizhi.job
+version=1.0-SNAPSHOT

cloud-job-api/target/maven-status/maven-compiler-plugin/compile/default-compile/createdFiles.lst

+com\yizhi\application\job\remote\JobClient.class
+com\yizhi\application\job\domain\VmyJob.class

cloud-job-api/target/maven-status/maven-compiler-plugin/compile/default-compile/inputFiles.lst

+D:\深蓝云校\cloud-job\cloud-job-api\src\main\java\com\fulan\application\job\remote\JobClient.java
+D:\深蓝云校\cloud-job\cloud-job-api\src\main\java\com\fulan\application\job\domain\VmyJob.java

cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/AlbumUnLockJob.java → cloud-job-service/src/main/java/com/yizhi/application/handle/quartz/job/AlbumUnLockJob.java

-package com.yizhi.application.handle.quartz.job;
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-import org.quartz.InterruptableJob;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
-import org.quartz.UnableToInterruptJobException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-
-import com.yizhi.application.feign.AlbumJobHandleClient;
-import com.yizhi.application.handle.quartz.BaseJob;
-
-public class AlbumUnLockJob implements BaseJob, InterruptableJob  {
-
-    private final Logger LOG = LoggerFactory.getLogger(AlbumUnLockJob.class);
-    private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-    
-    @Autowired
-    private AlbumJobHandleClient albumJobHandleClient;
-    @Override
-    public void execute(JobExecutionContext context) throws JobExecutionException {
-        LOG.info("定时任务开始执行解锁课程，当前时间：" + format.format(new Date()));
-        try {
-			albumJobHandleClient.unLockCourse();
-		} catch (Exception e) {
-			LOG.error("解锁课程失败=====================",e);
-		}
-    }
-
-
-    @Override
-    public void interrupt() throws UnableToInterruptJobException {
-
-    }
-}
+package com.yizhi.application.handle.quartz.job;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import org.quartz.InterruptableJob;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.quartz.UnableToInterruptJobException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import com.yizhi.application.feign.AlbumJobHandleClient;
+import com.yizhi.application.handle.quartz.BaseJob;
+
+public class AlbumUnLockJob implements BaseJob, InterruptableJob  {
+
+    private final Logger LOG = LoggerFactory.getLogger(AlbumUnLockJob.class);
+    private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+    
+    @Autowired
+    private AlbumJobHandleClient albumJobHandleClient;
+    @Override
+    public void execute(JobExecutionContext context) throws JobExecutionException {
+        LOG.info("定时任务开始执行解锁课程，当前时间：" + format.format(new Date()));
+        try {
+			albumJobHandleClient.unLockCourse();
+		} catch (Exception e) {
+			LOG.error("解锁课程失败=====================",e);
+		}
+    }
+
+
+    @Override
+    public void interrupt() throws UnableToInterruptJobException {
+
+    }
+}

cloud-job-service/src/main/java/com/fulan/application/handle/quartz/job/SydPointAcctranJob.java → cloud-job-service/src/main/java/com/yizhi/application/handle/quartz/job/SydPointAcctranJob.java

-package com.yizhi.application.handle.quartz.job;
-
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-import org.quartz.InterruptableJob;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
-import org.quartz.UnableToInterruptJobException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-
-import com.yizhi.application.feign.SydPointAcctranClient;
-import com.yizhi.application.handle.quartz.BaseJob;
-
-public class SydPointAcctranJob implements BaseJob, InterruptableJob  {
-    private final Logger LOG = LoggerFactory.getLogger(AlbumUnLockJob.class);
-    private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-    
-    @Autowired
-    private SydPointAcctranClient sydPointAcctranClient;
-    @Override
-    public void execute(JobExecutionContext context) throws JobExecutionException {
-        LOG.info("定时任务开始处理江苏银行苏银豆积分，当前时间：" + format.format(new Date()));
-        try {
-        	sydPointAcctranClient.AsynchronousPointAcctran(null, null, null, null);
-		} catch (Exception e) {
-			LOG.error("处理江苏银行苏银豆积分异常！！！",e);
-		}
-    }
-
-
-    @Override
-    public void interrupt() throws UnableToInterruptJobException {
-
-    }
-}
+package com.yizhi.application.handle.quartz.job;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import org.quartz.InterruptableJob;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.quartz.UnableToInterruptJobException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import com.yizhi.application.feign.SydPointAcctranClient;
+import com.yizhi.application.handle.quartz.BaseJob;
+
+public class SydPointAcctranJob implements BaseJob, InterruptableJob  {
+    private final Logger LOG = LoggerFactory.getLogger(AlbumUnLockJob.class);
+    private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+    
+    @Autowired
+    private SydPointAcctranClient sydPointAcctranClient;
+    @Override
+    public void execute(JobExecutionContext context) throws JobExecutionException {
+        LOG.info("定时任务开始处理江苏银行苏银豆积分，当前时间：" + format.format(new Date()));
+        try {
+        	sydPointAcctranClient.AsynchronousPointAcctran(null, null, null, null);
+		} catch (Exception e) {
+			LOG.error("处理江苏银行苏银豆积分异常！！！",e);
+		}
+    }
+
+
+    @Override
+    public void interrupt() throws UnableToInterruptJobException {
+
+    }
+}