[style]: optimize imports global

iot-common/iot-eventbus/src/main/java/com/zmops/zeus/iot/server/eventbus/core/EventControllerFactory.java

@@ -3,8 +3,6 @@
 import com.google.common.eventbus.AsyncEventBus;
 import com.google.common.eventbus.EventBus;
 import com.google.common.eventbus.SubscriberExceptionHandler;
-
-
 import com.zmops.zeus.iot.server.eventbus.constant.EventConstant;
 import com.zmops.zeus.iot.server.eventbus.thread.ThreadPoolFactory;
 

iot-server/server-bootstrap/src/main/java/com/zmops/zeus/iot/server/starter/IoTServerBootstrap.java

@@ -19,9 +19,9 @@
 package com.zmops.zeus.iot.server.starter;
 
 import com.zmops.zeus.iot.server.core.RunningMode;
-import com.zmops.zeus.iot.server.starter.config.ApplicationConfigLoader;
 import com.zmops.zeus.iot.server.library.module.ApplicationConfiguration;
 import com.zmops.zeus.iot.server.library.module.ModuleManager;
+import com.zmops.zeus.iot.server.starter.config.ApplicationConfigLoader;
 import com.zmops.zeus.iot.server.telemetry.TelemetryModule;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsCreator;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsTag;

iot-server/server-bootstrap/src/main/java/com/zmops/zeus/iot/server/starter/config/ApplicationConfigLoader.java

@@ -18,13 +18,12 @@
 
 package com.zmops.zeus.iot.server.starter.config;
 
-import com.zmops.zeus.iot.server.library.util.CollectionUtils;
-import com.zmops.zeus.iot.server.library.util.ResourceUtils;
 import com.zmops.zeus.iot.server.library.module.ApplicationConfiguration;
 import com.zmops.zeus.iot.server.library.module.ProviderNotFoundException;
+import com.zmops.zeus.iot.server.library.util.CollectionUtils;
+import com.zmops.zeus.iot.server.library.util.ResourceUtils;
 import com.zmops.zeus.iot.server.util.PropertyPlaceholderHelper;
 import lombok.extern.slf4j.Slf4j;
-
 import org.yaml.snakeyaml.Yaml;
 
 import java.io.FileNotFoundException;

iot-server/server-core/src/main/java/com/zmops/zeus/iot/server/core/CoreModule.java

@@ -3,7 +3,6 @@
 import com.zmops.zeus.iot.server.core.camel.CamelContextHolderService;
 import com.zmops.zeus.iot.server.core.eventbus.EventBusService;
 import com.zmops.zeus.iot.server.core.server.JettyHandlerRegister;
-import com.zmops.zeus.iot.server.core.servlet.HttpItemTrapperHandler;
 import com.zmops.zeus.iot.server.library.module.ModuleDefine;
 
 import java.util.ArrayList;

iot-server/server-core/src/main/java/com/zmops/zeus/iot/server/core/analysis/manual/history/History.java

@@ -3,7 +3,6 @@
 import com.zmops.zeus.iot.server.core.analysis.Stream;
 import com.zmops.zeus.iot.server.core.analysis.record.Record;
 import com.zmops.zeus.iot.server.core.analysis.worker.RecordStreamProcessor;
-import com.zmops.zeus.iot.server.core.storage.StorageData;
 import lombok.Getter;
 import lombok.Setter;
 

iot-server/server-core/src/main/java/com/zmops/zeus/iot/server/core/analysis/manual/history/UIntHistory.java

@@ -3,7 +3,6 @@
 import com.zmops.zeus.iot.server.core.analysis.Stream;
 import com.zmops.zeus.iot.server.core.analysis.record.Record;
 import com.zmops.zeus.iot.server.core.analysis.worker.RecordStreamProcessor;
-
 import lombok.Getter;
 import lombok.Setter;
 

iot-server/server-core/src/main/java/com/zmops/zeus/iot/server/core/servlet/DataTransferHandler.java

@@ -15,7 +15,6 @@
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStreamReader;
-import java.util.Arrays;
 import java.util.Map;
 import java.util.zip.GZIPInputStream;
 

iot-server/server-core/src/main/java/com/zmops/zeus/iot/server/core/worker/data/ItemValue.java

@@ -1,13 +1,8 @@
 package com.zmops.zeus.iot.server.core.worker.data;
 
-import afu.org.checkerframework.checker.igj.qual.I;
-import com.zmops.zeus.iot.server.core.camel.IOTDeviceValue;
 import lombok.Getter;
 import lombok.Setter;
 
-import java.util.ArrayList;
-import java.util.List;
-
 /**
  * @author nantian created at 2021/8/23 15:15
  */

iot-server/server-health-checker/src/main/java/com/zmops/zeus/iot/server/health/checker/provider/HealthCheckerProvider.java

@@ -21,14 +21,12 @@
 import com.google.common.util.concurrent.AtomicDouble;
 import com.zmops.zeus.iot.server.health.checker.module.HealthCheckerModule;
 import com.zmops.zeus.iot.server.library.module.*;
-
 import com.zmops.zeus.iot.server.telemetry.TelemetryModule;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsCollector;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsCreator;
 import io.vavr.collection.Stream;
 import lombok.extern.slf4j.Slf4j;
 
-
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;

iot-server/server-health-checker/src/main/java/com/zmops/zeus/iot/server/health/checker/provider/HealthQueryService.java

@@ -24,7 +24,6 @@
 import lombok.RequiredArgsConstructor;
 import lombok.Setter;
 
-
 import java.util.concurrent.atomic.AtomicReference;
 
 @RequiredArgsConstructor

iot-server/server-library/library-server/src/main/java/com/zmops/zeus/iot/server/library/server/ssl/AbstractSslContext.java

@@ -25,7 +25,6 @@
 import lombok.AccessLevel;
 import lombok.Setter;
 
-
 import javax.net.ssl.SSLEngine;
 import javax.net.ssl.SSLSessionContext;
 import java.util.List;

iot-server/server-receiver-plugin/tcp-receiver-plugin/src/main/java/com/zmops/zeus/iot/server/receiver/tcp/provider/TcpRouteBuilder.java

@@ -1,6 +1,5 @@
 package com.zmops.zeus.iot.server.receiver.tcp.provider;
 
-import com.zmops.zeus.iot.server.core.camel.process.ByteArrayToItemValueProcess;
 import com.zmops.zeus.iot.server.core.camel.process.StringItemValueProcess;
 import org.apache.camel.builder.RouteBuilder;
 

iot-server/server-sender/src/main/java/com/zmops/zeus/iot/server/sender/provider/ZabbixSenderClient.java

@@ -1,6 +1,5 @@
 package com.zmops.zeus.iot.server.sender.provider;
 
-import com.zmops.zeus.iot.server.sender.provider.ZabbixSenderModuleConfig;
 import lombok.extern.slf4j.Slf4j;
 
 import java.net.InetSocketAddress;

iot-server/server-storage-plugin/server-tdengine-plugin/pom.xml

@@ -20,7 +20,7 @@
         <dependency>
             <groupId>com.taosdata.jdbc</groupId>
             <artifactId>taos-jdbcdriver</artifactId>
-            <version>2.0.31</version>
+            <version>2.0.30</version>
         </dependency>
         <dependency>
             <groupId>com.zmops</groupId>

iot-server/server-storage-plugin/server-tdengine-plugin/src/main/java/com/zmops/zeus/iot/server/storage/plugin/jdbc/SQLExecutor.java

@@ -19,7 +19,6 @@
 package com.zmops.zeus.iot.server.storage.plugin.jdbc;
 
 import com.zmops.zeus.iot.server.library.client.request.InsertRequest;
-
 import lombok.Getter;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

iot-server/server-storage-plugin/server-tdengine-plugin/src/main/java/com/zmops/zeus/iot/server/storage/plugin/jdbc/tdengine/dao/TDEngineSqlExecutor.java

@@ -2,15 +2,13 @@
 
 import com.zmops.zeus.iot.server.core.analysis.manual.history.History;
 import com.zmops.zeus.iot.server.core.analysis.manual.history.UIntHistory;
-import com.zmops.zeus.iot.server.core.analysis.record.Record;
 import com.zmops.zeus.iot.server.core.storage.StorageData;
 import com.zmops.zeus.iot.server.storage.plugin.jdbc.SQLBuilder;
 import com.zmops.zeus.iot.server.storage.plugin.jdbc.SQLExecutor;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.ArrayList;
 import java.util.List;
-import java.util.Map;
 
 /**
  * @author nantian created at 2021/9/5 0:29

iot-server/server-telemetry/telemetry-api/src/main/java/com/zmops/zeus/iot/server/telemetry/TelemetryModule.java

@@ -18,9 +18,9 @@
 
 package com.zmops.zeus.iot.server.telemetry;
 
+import com.zmops.zeus.iot.server.library.module.ModuleDefine;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsCollector;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsCreator;
-import com.zmops.zeus.iot.server.library.module.ModuleDefine;
 
 /**
  * Telemetry module definition

iot-server/server-telemetry/telemetry-prometheus/src/main/java/com/zmops/zeus/iot/server/telemetry/prometheus/BaseMetrics.java

@@ -18,9 +18,9 @@
 
 package com.zmops.zeus.iot.server.telemetry.prometheus;
 
-import io.prometheus.client.SimpleCollector;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsTag;
 import com.zmops.zeus.iot.server.telemetry.api.TelemetryRelatedContext;
+import io.prometheus.client.SimpleCollector;
 
 import java.util.HashMap;
 import java.util.Map;

iot-server/server-telemetry/telemetry-prometheus/src/main/java/com/zmops/zeus/iot/server/telemetry/prometheus/PrometheusCounterMetrics.java

@@ -18,9 +18,9 @@
 
 package com.zmops.zeus.iot.server.telemetry.prometheus;
 
-import io.prometheus.client.Counter;
 import com.zmops.zeus.iot.server.telemetry.api.CounterMetrics;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsTag;
+import io.prometheus.client.Counter;
 
 /**
  * Counter metrics in Prometheus implementor.

iot-server/server-telemetry/telemetry-prometheus/src/main/java/com/zmops/zeus/iot/server/telemetry/prometheus/PrometheusGaugeMetrics.java

@@ -18,9 +18,9 @@
 
 package com.zmops.zeus.iot.server.telemetry.prometheus;
 
-import io.prometheus.client.Gauge;
 import com.zmops.zeus.iot.server.telemetry.api.GaugeMetrics;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsTag;
+import io.prometheus.client.Gauge;
 
 import java.util.Optional;
 

iot-server/server-telemetry/telemetry-prometheus/src/main/java/com/zmops/zeus/iot/server/telemetry/prometheus/PrometheusHistogramMetrics.java

@@ -18,9 +18,9 @@
 
 package com.zmops.zeus.iot.server.telemetry.prometheus;
 
-import io.prometheus.client.Histogram;
 import com.zmops.zeus.iot.server.telemetry.api.HistogramMetrics;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsTag;
+import io.prometheus.client.Histogram;
 
 /**
  * HistogramMetrics metrics in Prometheus implementor.

iot-server/server-telemetry/telemetry-prometheus/src/main/java/com/zmops/zeus/iot/server/telemetry/prometheus/PrometheusMetricsCollector.java

@@ -18,10 +18,10 @@
 
 package com.zmops.zeus.iot.server.telemetry.prometheus;
 
-import io.prometheus.client.Collector;
-import io.prometheus.client.CollectorRegistry;
 import com.zmops.zeus.iot.server.telemetry.api.MetricFamily;
 import com.zmops.zeus.iot.server.telemetry.api.MetricsCollector;
+import io.prometheus.client.Collector;
+import io.prometheus.client.CollectorRegistry;
 
 import java.util.ArrayList;
 import java.util.Enumeration;

iot-server/server-telemetry/telemetry-prometheus/src/main/java/com/zmops/zeus/iot/server/telemetry/prometheus/httpserver/HttpServer.java

@@ -20,6 +20,7 @@
 
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import com.zmops.zeus.iot.server.library.server.ssl.HttpDynamicSslContext;
+import com.zmops.zeus.iot.server.telemetry.prometheus.PrometheusConfig;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.EventLoopGroup;
 import io.netty.channel.nio.NioEventLoopGroup;
@@ -29,8 +30,6 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
-import com.zmops.zeus.iot.server.telemetry.prometheus.PrometheusConfig;
-
 import java.util.Optional;
 import java.util.concurrent.ThreadFactory;
 

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/TransferManager.java

@@ -1,10 +1,10 @@
 package com.zmops.zeus.iot.server.transfer.core;
 
+import com.zmops.zeus.iot.server.transfer.common.AbstractDaemon;
 import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.conf.TransferConfiguration;
 import com.zmops.zeus.iot.server.transfer.conf.TransferConstants;
 import com.zmops.zeus.iot.server.transfer.conf.TriggerProfile;
-import com.zmops.zeus.iot.server.transfer.common.AbstractDaemon;
 import com.zmops.zeus.iot.server.transfer.core.db.Db;
 import com.zmops.zeus.iot.server.transfer.core.db.JobProfileDb;
 import com.zmops.zeus.iot.server.transfer.core.db.TriggerProfileDb;

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/channel/MemoryChannel.java

@@ -1,10 +1,10 @@
 package com.zmops.zeus.iot.server.transfer.core.channel;
 
 
-import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
-import com.zmops.zeus.iot.server.transfer.conf.TransferConstants;
 import com.zmops.zeus.iot.server.transfer.api.Channel;
 import com.zmops.zeus.iot.server.transfer.api.Message;
+import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
+import com.zmops.zeus.iot.server.transfer.conf.TransferConstants;
 import com.zmops.zeus.iot.server.transfer.metrics.PluginMetric;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/job/Job.java

@@ -1,12 +1,12 @@
 package com.zmops.zeus.iot.server.transfer.core.job;
 
 
-import com.zmops.zeus.iot.server.transfer.conf.JobConstants;
-import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.api.Channel;
 import com.zmops.zeus.iot.server.transfer.api.Reader;
 import com.zmops.zeus.iot.server.transfer.api.Sink;
 import com.zmops.zeus.iot.server.transfer.api.Source;
+import com.zmops.zeus.iot.server.transfer.conf.JobConstants;
+import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.core.channel.MemoryChannel;
 import com.zmops.zeus.iot.server.transfer.core.sink.NdjsonSink;
 import com.zmops.zeus.iot.server.transfer.core.source.TextFileSource;

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/job/JobManager.java

@@ -1,14 +1,14 @@
 package com.zmops.zeus.iot.server.transfer.core.job;
 
 
+import com.zmops.zeus.iot.server.transfer.common.AbstractDaemon;
+import com.zmops.zeus.iot.server.transfer.common.TransferThreadFactory;
 import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.conf.TransferConfiguration;
 import com.zmops.zeus.iot.server.transfer.conf.TransferConstants;
-import com.zmops.zeus.iot.server.transfer.common.AbstractDaemon;
-import com.zmops.zeus.iot.server.transfer.common.TransferThreadFactory;
+import com.zmops.zeus.iot.server.transfer.core.TransferManager;
 import com.zmops.zeus.iot.server.transfer.core.db.JobProfileDb;
 import com.zmops.zeus.iot.server.transfer.core.db.StateSearchKey;
-import com.zmops.zeus.iot.server.transfer.core.TransferManager;
 import com.zmops.zeus.iot.server.transfer.utils.TransferUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/sink/NdjsonSink.java

@@ -1,10 +1,10 @@
 package com.zmops.zeus.iot.server.transfer.core.sink;
 
-import com.zmops.zeus.iot.server.transfer.conf.CommonConstants;
-import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.api.Message;
 import com.zmops.zeus.iot.server.transfer.api.Sink;
 import com.zmops.zeus.iot.server.transfer.common.TransferThreadFactory;
+import com.zmops.zeus.iot.server.transfer.conf.CommonConstants;
+import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.core.message.EndMessage;
 import com.zmops.zeus.iot.server.transfer.core.message.PackProxyMessage;
 import com.zmops.zeus.iot.server.transfer.core.message.ProxyMessage;

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/source/TextFileSource.java

@@ -1,9 +1,9 @@
 package com.zmops.zeus.iot.server.transfer.core.source;
 
 
-import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.api.Reader;
 import com.zmops.zeus.iot.server.transfer.api.Source;
+import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.core.source.reader.TextFileReader;
 import com.zmops.zeus.iot.server.transfer.utils.FileSearchUtils;
 import org.slf4j.Logger;

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/source/reader/TextFileReader.java

@@ -1,14 +1,14 @@
 package com.zmops.zeus.iot.server.transfer.core.source.reader;
 
-import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.api.Message;
 import com.zmops.zeus.iot.server.transfer.api.Reader;
 import com.zmops.zeus.iot.server.transfer.api.Validator;
+import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.core.FileException;
 import com.zmops.zeus.iot.server.transfer.core.message.DefaultMessage;
+import com.zmops.zeus.iot.server.transfer.core.validator.PatternValidator;
 import com.zmops.zeus.iot.server.transfer.metrics.PluginMetric;
 import com.zmops.zeus.iot.server.transfer.utils.TransferUtils;
-import com.zmops.zeus.iot.server.transfer.core.validator.PatternValidator;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/task/Task.java

@@ -1,9 +1,9 @@
 package com.zmops.zeus.iot.server.transfer.core.task;
 
-import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.api.Channel;
 import com.zmops.zeus.iot.server.transfer.api.Reader;
 import com.zmops.zeus.iot.server.transfer.api.Sink;
+import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 
 
 /**

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/task/TaskManager.java

@@ -1,12 +1,12 @@
 package com.zmops.zeus.iot.server.transfer.core.task;
 
 
-import com.zmops.zeus.iot.server.transfer.conf.TransferConfiguration;
-import com.zmops.zeus.iot.server.transfer.conf.TransferConstants;
 import com.zmops.zeus.iot.server.transfer.common.AbstractDaemon;
 import com.zmops.zeus.iot.server.transfer.common.TransferThreadFactory;
-import com.zmops.zeus.iot.server.transfer.core.job.JobManager;
+import com.zmops.zeus.iot.server.transfer.conf.TransferConfiguration;
+import com.zmops.zeus.iot.server.transfer.conf.TransferConstants;
 import com.zmops.zeus.iot.server.transfer.core.TransferManager;
+import com.zmops.zeus.iot.server.transfer.core.job.JobManager;
 import com.zmops.zeus.iot.server.transfer.utils.TransferUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/task/TaskPositionManager.java

@@ -1,10 +1,10 @@
 package com.zmops.zeus.iot.server.transfer.core.task;
 
 
-import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.common.AbstractDaemon;
-import com.zmops.zeus.iot.server.transfer.core.db.JobProfileDb;
+import com.zmops.zeus.iot.server.transfer.conf.JobProfile;
 import com.zmops.zeus.iot.server.transfer.core.TransferManager;
+import com.zmops.zeus.iot.server.transfer.core.db.JobProfileDb;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

iot-server/server-transfer/src/main/java/com/zmops/zeus/iot/server/transfer/core/task/TaskWrapper.java

@@ -1,10 +1,10 @@
 package com.zmops.zeus.iot.server.transfer.core.task;
 
 
-import com.zmops.zeus.iot.server.transfer.conf.TransferConfiguration;
-import com.zmops.zeus.iot.server.transfer.conf.TransferConstants;
 import com.zmops.zeus.iot.server.transfer.api.Message;
 import com.zmops.zeus.iot.server.transfer.common.TransferThreadFactory;
+import com.zmops.zeus.iot.server.transfer.conf.TransferConfiguration;
+import com.zmops.zeus.iot.server.transfer.conf.TransferConstants;
 import com.zmops.zeus.iot.server.transfer.core.TransferManager;
 import com.zmops.zeus.iot.server.transfer.core.message.EndMessage;
 import com.zmops.zeus.iot.server.transfer.core.state.AbstractStateWrapper;