From 076ae2ec06b5d0e6f61e0f70ef61b8af120537ab Mon Sep 17 00:00:00 2001
From: ZhuDongming <773644075@qq.com>
Date: Thu, 02 Apr 2020 16:04:31 +0800
Subject: [PATCH] update实时跑任务判断1号取那张表

---
 src/main/java/com/moral/task/RabbitMQInsertTask.java     |   27 +++++++++++++++++++++++++++
 src/main/java/com/moral/task/HistoryTableInsertTask.java |   18 ++++++++++++++++++
 2 files changed, 45 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/moral/task/HistoryTableInsertTask.java b/src/main/java/com/moral/task/HistoryTableInsertTask.java
index ac2d823..c2437db 100644
--- a/src/main/java/com/moral/task/HistoryTableInsertTask.java
+++ b/src/main/java/com/moral/task/HistoryTableInsertTask.java
@@ -53,6 +53,15 @@
         LocalDateTime time = LocalDateTime.now();
         int year = time.getYear();
         int month = time.getMonthValue();
+        int day = time.getDayOfMonth();
+        if (day == 1) {
+            if (month == 1) {
+                month = 12;
+                year = year - 1;
+            } else {
+                month = month - 1;
+            }
+        }
         String monthStr = month < 10 ? ("0" + month) : month + "";
         String yearAndMonth = year + monthStr;
         LocalDateTime endTime = time.truncatedTo(ChronoUnit.MINUTES);
@@ -492,6 +501,15 @@
         LocalDateTime time = LocalDateTime.now();
         int year = time.getYear();
         int month = time.getMonthValue();
+        int day = time.getDayOfMonth();
+        if (day == 1) {
+            if (month == 1) {
+                month = 12;
+                year = year - 1;
+            } else {
+                month = month - 1;
+            }
+        }
         String monthStr = month < 10 ? ("0" + month) : month + "";
         String yearAndMonth = year + monthStr;
         LocalDateTime endTime = time.truncatedTo(ChronoUnit.HOURS);
diff --git a/src/main/java/com/moral/task/RabbitMQInsertTask.java b/src/main/java/com/moral/task/RabbitMQInsertTask.java
index c87ce5b..52b8836 100644
--- a/src/main/java/com/moral/task/RabbitMQInsertTask.java
+++ b/src/main/java/com/moral/task/RabbitMQInsertTask.java
@@ -66,6 +66,15 @@
         LocalDateTime time = LocalDateTime.now();
         int year = time.getYear();
         int month = time.getMonthValue();
+        int day = time.getDayOfMonth();
+        if (day == 1) {
+            if (month == 1) {
+                month = 12;
+                year = year - 1;
+            } else {
+                month = month - 1;
+            }
+        }
         String monthStr = month < 10 ? ("0" + month) : month + "";
         String yearAndMonth = year + monthStr;
         Map organizationIdMap = JSON.parseObject(params);
@@ -127,6 +136,15 @@
         LocalDateTime time = LocalDateTime.now();
         int year = time.getYear();
         int month = time.getMonthValue();
+        int day = time.getDayOfMonth();
+        if (day == 1) {
+            if (month == 1) {
+                month = 12;
+                year = year - 1;
+            } else {
+                month = month - 1;
+            }
+        }
         String monthStr = month < 10 ? ("0" + month) : month + "";
         String yearAndMonth = year + monthStr;
         Map organizationIdMap = JSON.parseObject(params);
@@ -188,6 +206,15 @@
         LocalDateTime time = LocalDateTime.now();
         int year = time.getYear();
         int month = time.getMonthValue();
+        int day = time.getDayOfMonth();
+        if (day == 1) {
+            if (month == 1) {
+                month = 12;
+                year = year - 1;
+            } else {
+                month = month - 1;
+            }
+        }
         String monthStr = month < 10 ? ("0" + month) : month + "";
         String yearAndMonth = year + monthStr;
         Map organizationIdMap = JSON.parseObject(params);

--
Gitblit v1.8.0