Compare commits

..

No commits in common. "cd4e883093fc41a424d0433fa8b921f9343dfca2" and "ffc330485f5ee6b44f3e2cabf8c0c5b739ed2298" have entirely different histories.

3 changed files with 2 additions and 9 deletions

View File

@ -47,8 +47,4 @@ public class TicketingController {
public CommonResult<List<String>> testAlla(){
return CommonResult.success(saleDataService.deleteTwoYearLastMonthAgo());
}
@GetMapping("/testSample")
public void testSample(){
ticketDataMigration.deleteTwoYearOneMonthAgoAndUpdateLastYearTomorrow();
}
}

View File

@ -401,9 +401,6 @@ public class TicketDataMigration {
int currentDay = startDate.get(Calendar.DAY_OF_MONTH);
result.add(String.format("抽数服务:%d年%d月%d日" + methodName + "数据抽数正常结束!总共:%d条数据%d条数据重复%d条数据插入成功", currentYear, currentMonth, currentDay, totalRows, duplicatesCount, successCount));
XxlJobHelper.log("抽数服务:{}年{}月{}日:{}数据抽数正常结束!总共:{}条数据,{}条数据重复,{}条数据插入成功!", currentYear, currentMonth, currentDay, methodName, totalRows, duplicatesCount, successCount);
if (startDate.equals(endDate)){ // 如果日期相等退出循环
break;
}
// 日期递增一天
startDate.add(Calendar.DAY_OF_MONTH, 1);
}

View File

@ -139,8 +139,8 @@ public class CheckTicketServiceImpl implements CheckTicketService {
// TODO 使用这种方法删除会报错暂时使用mongoTemplate进行删除
// checkTicketTodayRepository.deleteByCheckticketdateIn(filteredDate);
Query query = new Query();
query.addCriteria(Criteria.where("checkticketdate").in(filteredDate));
mongoTemplate.remove(query, "check_ticket_today");
query.addCriteria(Criteria.where("sddate").in(filteredDate));
mongoTemplate.remove(query, "sale_data_today");
return filteredDate;
}