From 0308077f6a3437c1cba638f6710699f06ce31148 Mon Sep 17 00:00:00 2001
From: "1049970895@qniao.cn" <1049970895>
Date: Sat, 20 Aug 2022 11:50:47 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/qniao/iot/IotMonitoringDataJob.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
index ec5dc96..0a35998 100644
--- a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
+++ b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
@@ -76,7 +76,7 @@ public class IotMonitoringDataJob {
     /**
      * 当前索引日期后缀
      */
-    private static String currIndicsDateSuffix;
+    private static String currIndicesDateSuffix;
 
     public static void main(String[] args) throws Exception {
 
@@ -512,12 +512,12 @@ public class IotMonitoringDataJob {
 
     private static void checkIndicesIsExists(String indexDateSuffix, String indicesName) {
 
-        if(currIndicsDateSuffix == null) {
+        if(currIndicesDateSuffix == null) {
             // 当前月的索引为空
             createIndices(indicesName, indexDateSuffix);
         }else {
             // 校验当前消息能否符合当前索引
-            if(!indexDateSuffix.equals(currIndicsDateSuffix)) {
+            if(!indexDateSuffix.equals(currIndicesDateSuffix)) {
                 // 如果不符合，需要重建索引
                 createIndices(indicesName, indexDateSuffix);
             }
@@ -585,7 +585,7 @@ public class IotMonitoringDataJob {
                 if(!acknowledged || !shardsAcknowledged) {
                     throw new Exception("自定义索引创建失败！！！");
                 }
-                currIndicsDateSuffix = indexDateSuffix;
+                currIndicesDateSuffix = indexDateSuffix;
             }
         } catch (Exception e) {
             e.printStackTrace();