Skip to content

S
site-project
Commit 22539a7e by lilingye
Options

init

parent 5a0f67c4
Showing with 68 additions and 68 deletions
cloud-site-service/src/main/java/com/yizhi/site/application/service/impl/InformationServiceImpl.java
......@@ -3,11 +3,11 @@ package com.yizhi.site.application.service.impl;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.yizhi.application.job.remote.vo.VmyJobVO;
//import com.yizhi.application.job.remote.vo.VmyJobVO;
import com.yizhi.site.application.domain.DataClassification;
import com.yizhi.site.application.domain.Information;
import com.yizhi.site.application.domain.ProtalPlate;
import com.yizhi.application.job.remote.JobClient;
//import com.yizhi.application.job.remote.JobClient;
import com.yizhi.site.application.mapper.HomeAnnouncementMapper;
import com.yizhi.site.application.mapper.InformationMapper;
import com.yizhi.site.application.mapper.PortalTerminalMapper;
......@@ -77,8 +77,8 @@ public class InformationServiceImpl extends ServiceImpl<InformationMapper, Infor
private PdfPagesClient pdfPagesClient;
@Autowired
private ITrInformationReadNumberService informationReadNumberService;
@Autowired
JobClient jobClient;
// @Autowired
// JobClient jobClient;
// @Override
// public InformationListVO informationPageList(InfoVO vo) {
......@@ -1143,31 +1143,31 @@ public class InformationServiceImpl extends ServiceImpl<InformationMapper, Infor
@Override
public boolean timeUpInfomation(Long id) {
Information information = this.selectById(id);
// 批处理时间要在当前时间前十分钟哦
Calendar nowTime = Calendar.getInstance();
nowTime.add(Calendar.MINUTE, -10);
try {
VmyJobVO job = new VmyJobVO();
job.setGroup(jobGroup);
job.setJobName(id.toString());
job.setJobClassName("com.yizhi.application.handle.quartz.job.InformationUpJob");
String cron = DateUtil.getCron(information.getReleaseTime());
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) {
log.error("创建任务失败,id=" + id + "错误消息={}", e);
}
// Information information = this.selectById(id);
//
// // 批处理时间要在当前时间前十分钟哦
// Calendar nowTime = Calendar.getInstance();
// nowTime.add(Calendar.MINUTE, -10);
//
//
// try {
// VmyJobVO job = new VmyJobVO();
// job.setGroup(jobGroup);
// job.setJobName(id.toString());
// job.setJobClassName("com.yizhi.application.handle.quartz.job.InformationUpJob");
// String cron = DateUtil.getCron(information.getReleaseTime());
// 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) {
// log.error("创建任务失败,id=" + id + "错误消息={}", e);
// }
return true;
}
......
cloud-site-service/src/main/java/com/yizhi/site/application/service/impl/PortalBannerServiceImpl.java
......@@ -2,8 +2,8 @@ package com.yizhi.site.application.service.impl;
import com.baomidou.mybatisplus.plugins.Page;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.yizhi.application.job.remote.JobClient;
import com.yizhi.application.job.remote.vo.VmyJobVO;
//import com.yizhi.application.job.remote.JobClient;
//import com.yizhi.application.job.remote.vo.VmyJobVO;
import com.yizhi.site.application.mapper.PortalBannerMapper;
import com.yizhi.site.application.mapper.PortalImageMapper;
import com.yizhi.site.application.constant.SiteConstant;
......@@ -56,8 +56,8 @@ public class PortalBannerServiceImpl extends ServiceImpl<PortalBannerMapper, Por
@Autowired
private PointFeignClients pointFeignClients;
@Autowired
JobClient jobClient;
// @Autowired
// JobClient jobClient;
private static final String jobGroup = "banner";
......@@ -176,32 +176,32 @@ public class PortalBannerServiceImpl extends ServiceImpl<PortalBannerMapper, Por
*/
@Override
public boolean timeUpBanner(Long id) {
PortalImage portalImage = portalImageMapper.selectById(id);
// 批处理时间要在当前时间前十分钟哦
Calendar nowTime = Calendar.getInstance();
nowTime.add(Calendar.MINUTE, -10);
try {
VmyJobVO job = new VmyJobVO();
job.setGroup(jobGroup);
job.setJobName(id.toString());
job.setJobClassName("com.yizhi.application.handle.quartz.job.BannerUpJob");
String cron = DateUtil.getCron(portalImage.getAddTime());
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) {
log.error("创建任务失败,id=" + id + "错误消息={}", e);
}
//
// PortalImage portalImage = portalImageMapper.selectById(id);
//
// // 批处理时间要在当前时间前十分钟哦
// Calendar nowTime = Calendar.getInstance();
// nowTime.add(Calendar.MINUTE, -10);
//
//
// try {
// VmyJobVO job = new VmyJobVO();
// job.setGroup(jobGroup);
// job.setJobName(id.toString());
// job.setJobClassName("com.yizhi.application.handle.quartz.job.BannerUpJob");
// String cron = DateUtil.getCron(portalImage.getAddTime());
// 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) {
// log.error("创建任务失败,id=" + id + "错误消息={}", e);
// }
return false;
}
......@@ -209,15 +209,15 @@ public class PortalBannerServiceImpl extends ServiceImpl<PortalBannerMapper, Por
@Override
public boolean delete(Long id) {
log.info("删除job");
//删除自定义消息实体信息
try {
jobClient.delete(jobGroup + "." + id.toString());
} catch (Exception e) {
log.error("删除job失败", e);
// throw new BizException(MessageError.DELETE_JOB_ERROR,MessageError.DELETE_JOB_ERROR_MSG);
}
// log.info("删除job");
// //删除自定义消息实体信息
//
// try {
// jobClient.delete(jobGroup + "." + id.toString());
// } catch (Exception e) {
// log.error("删除job失败", e);
//// throw new BizException(MessageError.DELETE_JOB_ERROR,MessageError.DELETE_JOB_ERROR_MSG);
// }
return true;
}
......
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