From 57e25c15314c7219a9370183f54a505e93e70611 Mon Sep 17 00:00:00 2001
From: "1049970895@qniao.cn" <1049970895>
Date: Mon, 30 Jan 2023 09:57:54 +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

---
 .../job/IotMachineEventGeneratorJob.java      | 108 +++++++++---------
 1 file changed, 54 insertions(+), 54 deletions(-)

diff --git a/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java b/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java
index 395d300..ad6b2da 100644
--- a/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java
+++ b/iot-machine-state-event-generator-job/src/main/java/com/qniao/iot/machine/event/generator/job/IotMachineEventGeneratorJob.java
@@ -452,60 +452,60 @@ public class IotMachineEventGeneratorJob {
                 CreateIndexRequest request = new CreateIndexRequest(indicesName);
                 // 字段映射
                 String mappersStr = "{\n" +
-                        "        \"properties\": {\n" +
-                        "          \"countOfThePeriod\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "          \"durationOfThePeriod\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "          \"jobCountOfTheDay\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "          \"jobDurationOfTheDay\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "            \"machineWorkingStat\": {\n" +
-                        "                \"type\": \"integer\"\n" +
-                        "            },\n" +
-                        "            \"machineIotMac\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "            \"machinePwrStat\": {\n" +
-                        "                \"type\": \"integer\"\n" +
-                        "            },\n" +
-                        "            \"currWaitingDuration\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "            \"igStat\": {\n" +
-                        "                \"type\": \"integer\"\n" +
-                        "            },\n" +
-                        "            \"currJobDuration\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "            \"currJobCount\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "            \"receivedTime\": {\n" +
-                        "                \"type\": \"date\"\n" +
-                        "            },\n" +
-                        "            \"currStoppingDuration\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "            \"id\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "            \"accJobCount\": {\n" +
-                        "                \"type\": \"long\"\n" +
-                        "            },\n" +
-                        "            \"dataSource\": {\n" +
-                        "                \"type\": \"integer\"\n" +
-                        "            },\n" +
-                        "            \"reportTime\": {\n" +
-                        "                \"type\": \"date\"\n" +
-                        "            }\n" +
-                        "        }\n" +
-                        "    }";
+                        "    \"properties\": {\n" +
+                        "      \"machineWorkingStat\": {\n" +
+                        "        \"type\": \"integer\"\n" +
+                        "      },\n" +
+                        "      \"jobCountOfTheDay\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"machineIotMac\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"machinePwrStat\": {\n" +
+                        "        \"type\": \"integer\"\n" +
+                        "      },\n" +
+                        "      \"durationOfThePeriod\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"currWaitingDuration\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"igStat\": {\n" +
+                        "        \"type\": \"integer\"\n" +
+                        "      },\n" +
+                        "      \"currJobDuration\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"currJobCount\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"receivedTime\": {\n" +
+                        "        \"type\": \"date\"\n" +
+                        "      },\n" +
+                        "      \"currStoppingDuration\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"countOfThePeriod\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"id\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"jobDurationOfTheDay\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"accJobCount\": {\n" +
+                        "        \"type\": \"long\"\n" +
+                        "      },\n" +
+                        "      \"dataSource\": {\n" +
+                        "        \"type\": \"integer\"\n" +
+                        "      },\n" +
+                        "      \"reportTime\": {\n" +
+                        "        \"type\": \"date\"\n" +
+                        "      }\n" +
+                        "    }\n" +
+                        "  }";
                 request.mapping(mappersStr, XContentType.JSON);
                 // 设置索引别名
                 request.alias(new Alias(ApolloConfig.getStr(ConfigConstant.SINK_ELASTICSEARCH_INDEX)));