Skip to content

C
cloud-xxljobexecutor
Commit f3d08024 by lilingye
Options

init

parent f377afd0
Showing with 52 additions and 52 deletions
pom.xml
...@@ -60,7 +60,7 @@ ...@@ -60,7 +60,7 @@
<!-- 学习日志api 依赖 --> <!-- 学习日志api 依赖 -->
<dependency> <dependency>
<groupId>com.yizhi</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-course-studyLog-api</artifactId> <artifactId>cloud-course-study-log-api</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
...@@ -115,11 +115,11 @@ ...@@ -115,11 +115,11 @@
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
<dependency> <!-- <dependency>-->
<groupId>com.yizhi</groupId> <!-- <groupId>com.yizhi</groupId>-->
<artifactId>cloud-suyinbean-api</artifactId> <!-- <artifactId>cloud-suyinbean-api</artifactId>-->
<version>1.0-SNAPSHOT</version> <!-- <version>1.0-SNAPSHOT</version>-->
</dependency> <!-- </dependency>-->
<dependency> <dependency>
<groupId>com.yizhi</groupId> <groupId>com.yizhi</groupId>
<artifactId>cloud-live-api</artifactId> <artifactId>cloud-live-api</artifactId>
......
src/main/java/com/yizhi/xxl/job/executor/service/job/HttpSetjob.java
...@@ -11,8 +11,8 @@ package com.yizhi.xxl.job.executor.service.job; ...@@ -11,8 +11,8 @@ package com.yizhi.xxl.job.executor.service.job;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.xxl.job.core.log.XxlJobLogger; import com.xxl.job.core.log.XxlJobLogger;
import com.yizhi.application.feign.StudyLogClient; import com.yizhi.studylog.application.feign.StudyLogClient;
import com.yizhi.application.vo.StudyLogVo; import com.yizhi.studylog.application.vo.StudyLogVo;
import com.yizhi.core.application.cache.RedisCache; import com.yizhi.core.application.cache.RedisCache;
import com.yizhi.core.application.cache.distributedlock.impl.RedisDistributedLock; import com.yizhi.core.application.cache.distributedlock.impl.RedisDistributedLock;
import com.yizhi.course.application.feign.CourseClient; import com.yizhi.course.application.feign.CourseClient;
......
src/main/java/com/yizhi/xxl/job/executor/service/job/SydPointAcctranJob.java
package com.yizhi.xxl.job.executor.service.job; //package com.yizhi.xxl.job.executor.service.job;
//
import com.xxl.job.core.log.XxlJobLogger; //import com.xxl.job.core.log.XxlJobLogger;
import com.yizhi.suyinbean.application.feign.SydPointAcctranClient; //import com.yizhi.suyinbean.application.feign.SydPointAcctranClient;
import org.springframework.beans.factory.annotation.Autowired; //import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; //import org.springframework.stereotype.Component;
//
import java.text.SimpleDateFormat; //import java.text.SimpleDateFormat;
import java.util.Date; //import java.util.Date;
//
@Component //@Component
public class SydPointAcctranJob implements BaseJob { //public class SydPointAcctranJob implements BaseJob {
//
private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//
@Autowired // @Autowired
private SydPointAcctranClient sydPointAcctranClient; // private SydPointAcctranClient sydPointAcctranClient;
//
@Override // @Override
public void execute() throws Exception { // public void execute() throws Exception {
XxlJobLogger.log("定时任务开始处理江苏银行苏银豆积分，当前时间：" + format.format(new Date())); // XxlJobLogger.log("定时任务开始处理江苏银行苏银豆积分，当前时间：" + format.format(new Date()));
try { // try {
sydPointAcctranClient.AsynchronousPointAcctran(null, null, null, null); // sydPointAcctranClient.AsynchronousPointAcctran(null, null, null, null);
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
XxlJobLogger.log("处理江苏银行苏银豆积分异常！！！", e); // XxlJobLogger.log("处理江苏银行苏银豆积分异常！！！", e);
throw e; // throw e;
} // }
} // }
//
} //}
src/main/java/com/yizhi/xxl/job/executor/service/jobhandler/BeanJobCenter.java
...@@ -5,7 +5,7 @@ import com.xxl.job.core.handler.annotation.XxlJob; ...@@ -5,7 +5,7 @@ import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger; import com.xxl.job.core.log.XxlJobLogger;
import com.yizhi.xxl.job.executor.service.job.*; import com.yizhi.xxl.job.executor.service.job.*;
import io.swagger.models.auth.In; import io.swagger.models.auth.In;
import org.apache.axis.utils.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
...@@ -35,8 +35,8 @@ public class BeanJobCenter { ...@@ -35,8 +35,8 @@ public class BeanJobCenter {
private CourseStudyHourRankingJob courseStudyHourRankingJob; private CourseStudyHourRankingJob courseStudyHourRankingJob;
@Autowired @Autowired
private CourseIntoTableJob courseIntoTableJob; private CourseIntoTableJob courseIntoTableJob;
@Autowired // @Autowired
private SydPointAcctranJob sydPointAcctranJob; // private SydPointAcctranJob sydPointAcctranJob;
@Autowired @Autowired
private AlbumUnLockJob albumUnLockJob; private AlbumUnLockJob albumUnLockJob;
@Autowired @Autowired
...@@ -167,16 +167,16 @@ public class BeanJobCenter { ...@@ -167,16 +167,16 @@ public class BeanJobCenter {
} }
// 0 0 2 1/1 * ? * // 0 0 2 1/1 * ? *
@XxlJob("sydPointAcctranJob") // @XxlJob("sydPointAcctranJob")
public ReturnT<String> sydPointAcctranJob(String param) { // public ReturnT<String> sydPointAcctranJob(String param) {
try { // try {
sydPointAcctranJob.execute(); // sydPointAcctranJob.execute();
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
return new ReturnT<>(ReturnT.FAIL_CODE, e.getMessage()); // return new ReturnT<>(ReturnT.FAIL_CODE, e.getMessage());
} // }
return ReturnT.SUCCESS; // return ReturnT.SUCCESS;
} // }
// 0 0 0/5 * * ? * // 0 0 0/5 * * ? *
@XxlJob("albumUnLockJob") @XxlJob("albumUnLockJob")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment