Skip to content

C
cust-api
Commit f3f15971 authored by 罗林杰's avatar 罗林杰
Browse files
Options

修改定时任务缓存

parent 4f89e919
Show whitespace changes
Inline Side-by-side
Showing with 387 additions and 289 deletions
src/main/java/org/rcisoft/business/cmsOrder/service/impl/CmsOrderServiceImpl.java
View file @ f3f15971
......@@ -17,6 +17,8 @@ import org.rcisoft.business.memGoldCoinFlow.dao.MemGoldCoinFlowRepository;
import org.rcisoft.business.memGoldCoinFlow.entity.MemGoldCoinFlow;
import org.rcisoft.business.memInfo.dao.MemInfoRepository;
import org.rcisoft.business.memInfo.entity.MemInfo;
import org.rcisoft.business.sysScheduledTaskLog.entity.SysScheduledTaskLog;
import org.rcisoft.business.sysScheduledTaskLog.service.SysScheduledTaskLogService;
import org.rcisoft.core.async.AsyncFactory;
import org.rcisoft.core.exception.CyServiceException;
import org.rcisoft.core.rabbitmq.bean.RabbitMQConfigBean;
......@@ -99,6 +101,8 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
@Autowired
private MemGoldCoinFlowRepository memGoldCoinFlowRepository;
@Autowired
private SysScheduledTaskLogService sysScheduledTaskLogServiceImpl;
/**
* 保存 订单信息表
......@@ -1104,6 +1108,7 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
//redis订单落库
@Transactional
public void executeInsertOrder() throws NoSuchAlgorithmException {
try {
// 查询 【order:activity:${所有}:${所有}】
Set<String> map = redisTemplate.keys("order:*");
if (CollectionUtils.isNotEmpty(map)) {
......@@ -1123,6 +1128,20 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
}
}
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("订单落库定时任务");
sysScheduledTaskLog.setTaskState("成功");
sysScheduledTaskLog.setTaskTime("每1分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
} catch (Exception e) {
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("订单落库定时任务");
sysScheduledTaskLog.setTaskState("失败");
sysScheduledTaskLog.setTaskTime("每1分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
}
}
......@@ -1357,6 +1376,7 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
//redis订单关闭
@Transactional
public void executeCloseOrder() throws NoSuchAlgorithmException {
try {
// 查询 【order:activity:${所有}:${所有}】
Set<String> map = redisTemplate.keys("order:*");
if (CollectionUtils.isNotEmpty(map)) {
......@@ -1374,7 +1394,20 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
closeOrder(key);
}
}
}
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("订单关闭定时任务");
sysScheduledTaskLog.setTaskState("成功");
sysScheduledTaskLog.setTaskTime("每1分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
} catch (Exception e) {
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("订单关闭定时任务");
sysScheduledTaskLog.setTaskState("失败");
sysScheduledTaskLog.setTaskTime("每1分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
}
}
......@@ -1475,6 +1508,7 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
//支付确认补救
@Transactional
public void executePayOrder() throws IOException, JDOMException {
try {
// 查询DB进行中的活动订单，支付中，前50条
QueryWrapper<CmsOrder> wrapper = new QueryWrapper<>();
wrapper.eq("status",8);
......@@ -1606,13 +1640,27 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
}
}
}
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("支付确认补救定时任务");
sysScheduledTaskLog.setTaskState("成功");
sysScheduledTaskLog.setTaskTime("每15分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
} catch (Exception e) {
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("支付确认补救定时任务");
sysScheduledTaskLog.setTaskState("失败");
sysScheduledTaskLog.setTaskTime("每15分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
}
}
//任务：退款接口调用补救
@Transactional
public void executeRefundOrder() {
try {
// 查询DB进行中的活动订单，退款中（3 5），退款接口调用失败1，2，前50条
QueryWrapper<CmsOrder> wrapper = new QueryWrapper<>();
wrapper.in("status",3,5);
......@@ -1665,12 +1713,26 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
log.error("释放成功");
}
}
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("退款接口调用补救定时任务");
sysScheduledTaskLog.setTaskState("成功");
sysScheduledTaskLog.setTaskTime("每30分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
} catch (Exception e) {
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("退款接口调用补救定时任务");
sysScheduledTaskLog.setTaskState("失败");
sysScheduledTaskLog.setTaskTime("每30分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
}
}
//任务：退款确认补救
@Transactional
public void executeRefundConfirmOrder() throws IOException, JDOMException {
try {
// 查询DB进行中的活动订单，退款中（2），前50条
QueryWrapper<CmsOrder> wrapper = new QueryWrapper<>();
wrapper.in("status",2,4);
......@@ -1735,7 +1797,20 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
log.info("订单退款状态查询失败");
}
}
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("退款确认补救定时任务");
sysScheduledTaskLog.setTaskState("成功");
sysScheduledTaskLog.setTaskTime("每30分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
} catch (Exception e) {
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("退款确认补救定时任务");
sysScheduledTaskLog.setTaskState("失败");
sysScheduledTaskLog.setTaskTime("每30分钟执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
}
}
......@@ -1745,6 +1820,7 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
//任务：订单缓存清除
@Transactional
public void executeDeleteOrder() {
try {
// 查询DB，结束时间，近4个月的活动，如今日是2023-5-5，查询 2023-1-5 至2023-4-5 的活动
Date now = new Date();
Date startTime = TimeUtil.getTime(now, Calendar.MONTH,-4);
......@@ -1781,7 +1857,20 @@ public class CmsOrderServiceImpl extends ServiceImpl<CmsOrderRepository,CmsOrder
if (Objects.equals(orderDetail.getState(),1))
redisTemplate.delete(RedisCons.ORDER_GOLD +":"+ order.getGoodsId() + ":" + order.getBusinessId());
}
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("订单缓存清除定时任务");
sysScheduledTaskLog.setTaskState("成功");
sysScheduledTaskLog.setTaskTime("每1小时执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
} catch (Exception e) {
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("订单缓存清除定时任务");
sysScheduledTaskLog.setTaskState("失败");
sysScheduledTaskLog.setTaskTime("每1小时执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
}
}
......
src/main/java/org/rcisoft/business/memInfo/service/impl/MemInfoServiceImpl.java
View file @ f3f15971
......@@ -91,6 +91,9 @@ public class MemInfoServiceImpl extends ServiceImpl<MemInfoRepository,MemInfo>
private MemInfoRepository memInfoRepository;
@Autowired
private MemGoldCoinFlowRepository memGoldCoinFlowRepository;
@Autowired
private SysScheduledTaskLogService sysScheduledTaskLogServiceImpl;
@Value("${cy.init.password}")
private String password;
......@@ -782,6 +785,12 @@ public class MemInfoServiceImpl extends ServiceImpl<MemInfoRepository,MemInfo>
} else {
System.out.println("No keys found.");
}
SysScheduledTaskLog sysScheduledTaskLog = new SysScheduledTaskLog();
sysScheduledTaskLog.setTaskName("用户点赞数据定时任务");
sysScheduledTaskLog.setTaskState("成功");
sysScheduledTaskLog.setTaskTime("每2小时执行一次");
sysScheduledTaskLog.setCreateDate(new Date());
sysScheduledTaskLogServiceImpl.persist(sysScheduledTaskLog);
log.info("用户点赞数据定时任务结束---");
}
......
src/main/java/org/rcisoft/core/schedule/ScheduleTasks.java
View file @ f3f15971
......@@ -82,7 +82,7 @@ public class ScheduleTasks {
/**
* 退款确认补救
*/
@Scheduled(cron = "0 0/30 * * * ?")
@Scheduled(cron = "0 * * * * ?")
public void executeRefundConfirmOrder() throws IOException, JDOMException {
orderService.executeRefundConfirmOrder();
}
......@@ -90,7 +90,7 @@ public class ScheduleTasks {
/**
* 订单缓存清除
*/
@Scheduled(cron = "0 0 1 * * ?")
@Scheduled(cron = "0 * * * * ?")
public void executeDeleteOrder() {
orderService.executeDeleteOrder();
}
......@@ -98,7 +98,7 @@ public class ScheduleTasks {
/**
* 定时更新访问量表
*/
@Scheduled(cron = "0 * * * * ?")
@Scheduled(cron = "0 0/15 * * * ?")
public void memTrafficSchedule() {
memTrafficService.memTrafficSchedule();
}
......
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