1.添加登录模块

influx-data/influx-target/pom.xml

@@ -38,8 +38,16 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
+
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-security</artifactId>
+        </dependency>
     </dependencies>
 
+
+
     <build>
         <finalName>influx-target</finalName>
         <plugins>

influx-data/influx-target/src/main/java/com/njcn/influx/job/OracleToInfluxDBJob.java

@@ -47,6 +47,7 @@ public class OracleToInfluxDBJob {
     }*/
 
     //每小时03分钟时执行上一个小时的数据同步
+    //河北这边比较特殊，
     @Scheduled(cron="0 3 * * * ?")
     public void executeHours() {
         DataAsynParam dataAsynParam = new DataAsynParam();

influx-data/influx-target/src/main/resources/application.yml

@@ -5,6 +5,10 @@ business:
 server:
   port: 8090
 spring:
+  security:
+    user:
+      name: njcn
+      password: dnzl@#002
   #influxDB内容配置
   influx:
     url: http://192.168.1.102:8086

manufact_influx_data/src/test/java/com/njcn/DataTest.java

@@ -78,7 +78,7 @@ public class DataTest extends BaseJunitTest {
         System.out.println(2222);
         System.out.println(2222);
         List<DataV> list = resultMapper.toPOJO(sqlResult, DataV.class);
-        Map<String, List<DataV>> stringListMap = list.stream().collect(Collectors.groupingBy(obj -> obj.getPhasicType().concat(StrPool.UNDERLINE).concat(obj.getValueType())));
+        Map<String, List<DataV>> stringListMap = list.stream().collect(Collectors.groupingBy(obj -> obj.getPhaseType().concat(StrPool.UNDERLINE).concat(obj.getValueType())));
 
         influxQueryWrapper = new InfluxQueryWrapper(DataInHarmRateV.class);
         influxQueryWrapper.between(DataInHarmRateV::getTime, startTime, endTime).regular(DataInHarmRateV::getLineId, lineList);