|
@@ -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点,同步年统计
|
|
|
-// @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() {
|