|
@@ -562,11 +562,11 @@ public class FsCourseRedPacketLogServiceImpl implements IFsCourseRedPacketLogSer
|
|
|
public void backupRedPacketLog() {
|
|
public void backupRedPacketLog() {
|
|
|
log.info("开始执行数据迁移任务");
|
|
log.info("开始执行数据迁移任务");
|
|
|
|
|
|
|
|
- /* // 检查是否在凌晨3点之后
|
|
|
|
|
|
|
+ // 检查是否在凌晨3点之后
|
|
|
if (shouldStopAt3AM()) {
|
|
if (shouldStopAt3AM()) {
|
|
|
log.info("已到凌晨3点,停止数据迁移任务");
|
|
log.info("已到凌晨3点,停止数据迁移任务");
|
|
|
return;
|
|
return;
|
|
|
- }*/
|
|
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
// 设置查询条件:获取12月之前的数据
|
|
// 设置查询条件:获取12月之前的数据
|
|
|
FsCourseRedPacketLog queryLog = createQueryCondition();
|
|
FsCourseRedPacketLog queryLog = createQueryCondition();
|
|
@@ -580,10 +580,10 @@ public class FsCourseRedPacketLogServiceImpl implements IFsCourseRedPacketLogSer
|
|
|
try {
|
|
try {
|
|
|
while (hasMoreData) {
|
|
while (hasMoreData) {
|
|
|
// 检查是否到凌晨3点
|
|
// 检查是否到凌晨3点
|
|
|
- /* if (shouldStopAt3AM()) {
|
|
|
|
|
|
|
+ if (shouldStopAt3AM()) {
|
|
|
log.info("已到凌晨3点,停止数据迁移任务,已处理{}条数据", totalProcessed);
|
|
log.info("已到凌晨3点,停止数据迁移任务,已处理{}条数据", totalProcessed);
|
|
|
break;
|
|
break;
|
|
|
- }*/
|
|
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
log.info("开始查询第{}批数据,查询条件:beginTime={}, endTime={}",
|
|
log.info("开始查询第{}批数据,查询条件:beginTime={}, endTime={}",
|
|
|
pageNum, queryLog.getBeginTime(), queryLog.getEndTime());
|
|
pageNum, queryLog.getBeginTime(), queryLog.getEndTime());
|
|
@@ -700,7 +700,7 @@ public class FsCourseRedPacketLogServiceImpl implements IFsCourseRedPacketLogSer
|
|
|
int minute = calendar.get(Calendar.MINUTE);
|
|
int minute = calendar.get(Calendar.MINUTE);
|
|
|
|
|
|
|
|
// 凌晨3点及之后返回true
|
|
// 凌晨3点及之后返回true
|
|
|
- return hour >= 3;
|
|
|
|
|
|
|
+ return hour >= 4;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|