|
@@ -117,80 +117,80 @@ public class ScheduledService {
|
|
}
|
|
}
|
|
|
|
|
|
// 凌晨一点,同步过去一天的月统计
|
|
// 凌晨一点,同步过去一天的月统计
|
|
- @Scheduled(cron = "30 10 1 * * ?")
|
|
|
|
- public void synMonthStatistics() {
|
|
|
|
- // 参数
|
|
|
|
- StatisticsParam param = new StatisticsParam();
|
|
|
|
- // 获取昨天的时间
|
|
|
|
- LocalDate yesterday = LocalDate.now().minusDays(1);
|
|
|
|
-
|
|
|
|
- // 创建DateTimeFormatter对象,用于格式化成 "yyyy-MM"
|
|
|
|
- DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM");
|
|
|
|
-
|
|
|
|
- // 格式化并输出昨天的日期
|
|
|
|
- String statisticsDate = yesterday.format(formatter);
|
|
|
|
- param.setStartDate(statisticsDate + "-01 00:00:00");
|
|
|
|
- param.setEndDate(statisticsDate + "-31 23:59:59");
|
|
|
|
- // 按月统计
|
|
|
|
- param.setDateType("0");
|
|
|
|
- param.setSize(5000);
|
|
|
|
- try {
|
|
|
|
- if(isDo()) {
|
|
|
|
- // 同步国内,按商户统计
|
|
|
|
- param.setIfForeign("0");
|
|
|
|
- param.setPacketType("0");
|
|
|
|
- esTOrderService.getSummaryStatistics(param);
|
|
|
|
- // 同步国内,按设备统计
|
|
|
|
- param.setPacketType("1");
|
|
|
|
- esTOrderService.getSummaryStatistics(param);
|
|
|
|
- // 同步国外,按商户统计
|
|
|
|
- param.setIfForeign("1");
|
|
|
|
- param.setPacketType("0");
|
|
|
|
- esTOrderService.getSummaryStatistics(param);
|
|
|
|
- // 同步国外,按设备统计
|
|
|
|
- param.setPacketType("1");
|
|
|
|
- esTOrderService.getSummaryStatistics(param);
|
|
|
|
-
|
|
|
|
- }
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- }
|
|
|
|
|
|
+// @Scheduled(cron = "30 10 1 * * ?")
|
|
|
|
+// public void synMonthStatistics() {
|
|
|
|
+// // 参数
|
|
|
|
+// StatisticsParam param = new StatisticsParam();
|
|
|
|
+// // 获取昨天的时间
|
|
|
|
+// LocalDate yesterday = LocalDate.now().minusDays(1);
|
|
|
|
+//
|
|
|
|
+// // 创建DateTimeFormatter对象,用于格式化成 "yyyy-MM"
|
|
|
|
+// DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM");
|
|
|
|
+//
|
|
|
|
+// // 格式化并输出昨天的日期
|
|
|
|
+// String statisticsDate = yesterday.format(formatter);
|
|
|
|
+// param.setStartDate(statisticsDate + "-01 00:00:00");
|
|
|
|
+// param.setEndDate(statisticsDate + "-31 23:59:59");
|
|
|
|
+// // 按月统计
|
|
|
|
+// param.setDateType("0");
|
|
|
|
+// param.setSize(5000);
|
|
|
|
+// try {
|
|
|
|
+// if(isDo()) {
|
|
|
|
+// // 同步国内,按商户统计
|
|
|
|
+// param.setIfForeign("0");
|
|
|
|
+// param.setPacketType("0");
|
|
|
|
+// esTOrderService.getSummaryStatistics(param);
|
|
|
|
+// // 同步国内,按设备统计
|
|
|
|
+// param.setPacketType("1");
|
|
|
|
+// esTOrderService.getSummaryStatistics(param);
|
|
|
|
+// // 同步国外,按商户统计
|
|
|
|
+// param.setIfForeign("1");
|
|
|
|
+// param.setPacketType("0");
|
|
|
|
+// esTOrderService.getSummaryStatistics(param);
|
|
|
|
+// // 同步国外,按设备统计
|
|
|
|
+// param.setPacketType("1");
|
|
|
|
+// esTOrderService.getSummaryStatistics(param);
|
|
|
|
+//
|
|
|
|
+// }
|
|
|
|
+// } catch (Exception e) {
|
|
|
|
+// e.printStackTrace();
|
|
|
|
+// }
|
|
|
|
+//
|
|
|
|
+// }
|
|
|
|
|
|
// 每天0点,同步年统计
|
|
// 每天0点,同步年统计
|
|
- @Scheduled(cron = "30 10 0 * * ?")
|
|
|
|
- public void synYearStatistics() {
|
|
|
|
- // 参数
|
|
|
|
- StatisticsParam param = new StatisticsParam();
|
|
|
|
- // 获取昨天的时间
|
|
|
|
- LocalDate yesterday = LocalDate.now().minusDays(1);
|
|
|
|
- String year = yesterday.format(DateTimeFormatter.ofPattern("yyyy"));
|
|
|
|
- param.setStartDate(year + "-01-01 00:00:00");
|
|
|
|
- param.setEndDate(year + "-12-31 23:59:59");
|
|
|
|
- param.setDateType("1");
|
|
|
|
- param.setSize(5000);
|
|
|
|
- try {
|
|
|
|
- if(isDo()) {
|
|
|
|
- // 同步国内,按商户统计
|
|
|
|
- param.setIfForeign("0");
|
|
|
|
- param.setPacketType("0");
|
|
|
|
- esTOrderService.getSummaryStatistics(param);
|
|
|
|
- // 同步国内,按设备统计
|
|
|
|
- param.setPacketType("1");
|
|
|
|
- esTOrderService.getSummaryStatistics(param);
|
|
|
|
- // 同步国外,按商户统计
|
|
|
|
- param.setIfForeign("1");
|
|
|
|
- param.setPacketType("0");
|
|
|
|
- esTOrderService.getSummaryStatistics(param);
|
|
|
|
- // 同步国外,按设备统计
|
|
|
|
- param.setPacketType("1");
|
|
|
|
- esTOrderService.getSummaryStatistics(param);
|
|
|
|
- }
|
|
|
|
- } catch (Exception e) {
|
|
|
|
- e.printStackTrace();
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
|
|
+// @Scheduled(cron = "30 10 0 * * ?")
|
|
|
|
+// public void synYearStatistics() {
|
|
|
|
+// // 参数
|
|
|
|
+// StatisticsParam param = new StatisticsParam();
|
|
|
|
+// // 获取昨天的时间
|
|
|
|
+// LocalDate yesterday = LocalDate.now().minusDays(1);
|
|
|
|
+// String year = yesterday.format(DateTimeFormatter.ofPattern("yyyy"));
|
|
|
|
+// param.setStartDate(year + "-01-01 00:00:00");
|
|
|
|
+// param.setEndDate(year + "-12-31 23:59:59");
|
|
|
|
+// param.setDateType("1");
|
|
|
|
+// param.setSize(5000);
|
|
|
|
+// try {
|
|
|
|
+// if(isDo()) {
|
|
|
|
+// // 同步国内,按商户统计
|
|
|
|
+// param.setIfForeign("0");
|
|
|
|
+// param.setPacketType("0");
|
|
|
|
+// esTOrderService.getSummaryStatistics(param);
|
|
|
|
+// // 同步国内,按设备统计
|
|
|
|
+// param.setPacketType("1");
|
|
|
|
+// esTOrderService.getSummaryStatistics(param);
|
|
|
|
+// // 同步国外,按商户统计
|
|
|
|
+// param.setIfForeign("1");
|
|
|
|
+// param.setPacketType("0");
|
|
|
|
+// esTOrderService.getSummaryStatistics(param);
|
|
|
|
+// // 同步国外,按设备统计
|
|
|
|
+// param.setPacketType("1");
|
|
|
|
+// esTOrderService.getSummaryStatistics(param);
|
|
|
|
+// }
|
|
|
|
+// } catch (Exception e) {
|
|
|
|
+// e.printStackTrace();
|
|
|
|
+// }
|
|
|
|
+// }
|
|
|
|
|
|
|
|
|
|
private Boolean isDo() {
|
|
private Boolean isDo() {
|