Commit 1ed1e0cc by lilingye

Init

parent 3c57292a
......@@ -29,11 +29,11 @@
<artifactId>cloud-site-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.yizhi</groupId>
<artifactId>cloud-job-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.yizhi</groupId>-->
<!-- <artifactId>cloud-job-api</artifactId>-->
<!-- <version>1.0-SNAPSHOT</version>-->
<!-- </dependency>-->
<dependency>
<groupId>com.yizhi</groupId>
......
......@@ -6,10 +6,10 @@ import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import com.yizhi.application.job.remote.vo.VmyJobVO;
//
//import com.yizhi.application.job.remote.vo.VmyJobVO;
import com.yizhi.core.application.vo.AccreditVO;
import com.yizhi.application.job.remote.JobClient;
//import com.yizhi.application.job.remote.JobClient;
import com.yizhi.application.orm.id.IdGenerator;
import com.yizhi.application.orm.util.QueryUtil;
import com.yizhi.core.application.context.ContextHolder;
......@@ -55,8 +55,8 @@ public class AccreditServiceImpl extends ServiceImpl<AccreditMapper, Accredit> i
@Autowired
ICourseService courseService;
@Autowired
JobClient jobClient;
// @Autowired
// JobClient jobClient;
@Autowired
SiteClient siteClient;
......@@ -118,25 +118,25 @@ public class AccreditServiceImpl extends ServiceImpl<AccreditMapper, Accredit> i
nowTime.add(Calendar.MINUTE, -10);
try {
VmyJobVO job=new VmyJobVO();
job.setGroup(jobGroup);
job.setJobName(id.toString());
job.setJobClassName("com.yizhi.course.application.handle.quartz.job.CourseInvalidJob");
String cron= DateUtil.getCron(accredit.getUseDuration());
String[] cronArr=cron.split(" ");
job.setSecond(cronArr[0]);
job.setMinute(cronArr[1]);
job.setHour(cronArr[2]);
job.setDay(cronArr[3]);
job.setMonth(cronArr[4]);
job.setWeek(cronArr[5]);
job.setYear(cronArr[6]);
jobClient.insert(job);
} catch (Exception e) {
LOGGER.error("创建任务失败,id="+id+"错误消息={}",e);
}
// try {
// VmyJobVO job=new VmyJobVO();
// job.setGroup(jobGroup);
// job.setJobName(id.toString());
// job.setJobClassName("com.yizhi.course.application.handle.quartz.job.CourseInvalidJob");
// String cron= DateUtil.getCron(accredit.getUseDuration());
// String[] cronArr=cron.split(" ");
// job.setSecond(cronArr[0]);
// job.setMinute(cronArr[1]);
// job.setHour(cronArr[2]);
// job.setDay(cronArr[3]);
// job.setMonth(cronArr[4]);
// job.setWeek(cronArr[5]);
// job.setYear(cronArr[6]);
// jobClient.insert(job);
//
// } catch (Exception e) {
// LOGGER.error("创建任务失败,id="+id+"错误消息={}",e);
// }
return true;
}
......@@ -506,12 +506,12 @@ public class AccreditServiceImpl extends ServiceImpl<AccreditMapper, Accredit> i
* @param id 任务id
*/
private void delAuthorizeCourse(Long id){
try {
// 删除定时任务
jobClient.delete(jobGroup+"."+id);
} catch (Exception e) {
log.info("删除报错:"+e.getLocalizedMessage());
}
// try {
// // 删除定时任务
// jobClient.delete(jobGroup+"."+id);
// } catch (Exception e) {
// log.info("删除报错:"+e.getLocalizedMessage());
// }
}
}
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