1.工况分析相关代码提交

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/TestController.java

@@ -47,5 +47,10 @@ public class TestController extends BaseController {
 	public ResponseModel<List<IdxBizHjev>> selectForListPV() {
 		return ResponseHelper.buildResponse(commonServiceImpl.getAllPVstationTestPoint().subList(0,20));
 	}
-
+	@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+	@ApiOperation(httpMethod = "GET",value = "test",   notes = "列表全部数据查询")
+	@GetMapping(value = "/test")
+	public void selectForListTest() {
+		 commonServiceImpl.getGateWayId();
+	}
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/IdxBizC80c.java

@@ -6,6 +6,8 @@ import lombok.Data;
 import lombok.experimental.Accessors;
 import org.joda.time.LocalDateTime;
 
+import java.util.Date;
+
 
 /**
  * 
@@ -16,7 +18,7 @@ import org.joda.time.LocalDateTime;
 @Data
 
 @Accessors(chain = true)
-@TableName("idx_biz_c80c")
+@TableName(value = "idx_biz_c80c",autoResultMap = true)
 public class IdxBizC80c  {
 
     private static final long serialVersionUID = 1L;
@@ -37,7 +39,7 @@ public class IdxBizC80c  {
      * 
      */
 	@TableField("REC_DATE")
-    private LocalDateTime recDate;
+    private Date recDate;
 
     /**
      * 

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/entity/IdxBizHjev.java

@@ -6,6 +6,8 @@ import lombok.Data;
 import lombok.experimental.Accessors;
 import org.joda.time.LocalDateTime;
 
+import java.util.Date;
+
 
 /**
  * 
@@ -15,7 +17,7 @@ import org.joda.time.LocalDateTime;
  */
 @Data
 @Accessors(chain = true)
-@TableName("idx_biz_hjev")
+@TableName(value = "idx_biz_hjev",autoResultMap = true)
 public class IdxBizHjev  {
 
     private static final long serialVersionUID = 1L;
@@ -36,7 +38,7 @@ public class IdxBizHjev  {
      * 
      */
 	@TableField("REC_DATE")
-    private LocalDateTime recDate;
+    private Date  recDate;
 
     /**
      * 

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/IdxBizC80cMapper.java

@@ -3,6 +3,8 @@ package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c;
 
+import java.util.List;
+
 /**
  *  Mapper 接口
  *
@@ -10,5 +12,5 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c;
  * @date 2023-08-11
  */
 public interface IdxBizC80cMapper extends BaseMapper<IdxBizC80c> {
-
+   List<String> gateWayIdListFan();
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/mapper2/IdxBizHjevMapper.java

@@ -3,6 +3,8 @@ package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev;
 
+import java.util.List;
+
 /**
  *  Mapper 接口
  *
@@ -10,5 +12,5 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev;
  * @date 2023-08-11
  */
 public interface IdxBizHjevMapper extends BaseMapper<IdxBizHjev> {
-
+    List<String> gateWayIdListPV();
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/CommonServiceImpl.java

@@ -5,6 +5,7 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev;
 import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizC80cMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizHjevMapper;
+import com.yeejoin.amos.component.influxdb.InfluxdbUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -17,6 +18,9 @@ public class CommonServiceImpl {
     @Autowired
     private IdxBizHjevMapper idxBizHjevMapper;
 
+    @Autowired
+    InfluxdbUtil influxdbUtil;
+
     public List<IdxBizC80c> getAllFanstationTestPoint(){
         List<IdxBizC80c> idxBizC80cList = new ArrayList<>();
         idxBizC80cList = idxBizC80cMapper.selectList(new QueryWrapper<IdxBizC80c>().isNotNull("SEQUENCE_NBR"));
@@ -27,5 +31,8 @@ public class CommonServiceImpl {
         idxBizC80cList = idxBizHjevMapper.selectList(new QueryWrapper<IdxBizHjev>().isNotNull("SEQUENCE_NBR"));
         return idxBizC80cList;
     }
-
+     public List<String> getGateWayId(){
+        List<String> gateWayIdList=idxBizC80cMapper.gateWayIdListFan();
+        return gateWayIdList;
+     }
  }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/utils/InfluxDButils.java

+package com.yeejoin.amos.boot.module.jxiop.biz.utils;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.component.influxdb.InfluxDbConnection;
+import com.yeejoin.amos.component.influxdb.InfluxdbUtil;
+import org.influxdb.dto.QueryResult;
+import org.springframework.beans.BeanWrapperImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+@Component
+public class InfluxDButils {
+    @Autowired
+    InfluxDbConnection influxDbConnection;
+    @Autowired
+    InfluxdbUtil influxdbUtil;
+    public <T> List<T> getListData(String sql, Class<T> clazz) {
+        List<T> list = new ArrayList<>();
+        try {
+            QueryResult query = influxDbConnection.query(sql);
+            List<QueryResult.Result> queryResults = query.getResults();
+            for (QueryResult.Result result : queryResults) {
+                List<QueryResult.Series> series = result.getSeries();
+                if (series == null) {
+                    continue;
+                }
+                for (QueryResult.Series serie : series) {
+                    List<List<Object>> values = serie.getValues();
+                    List<String> columns = serie.getColumns();
+                    for (int i = 0; i < values.size(); ++i) {
+                        T object = clazz.newInstance();
+                        BeanWrapperImpl bean = new BeanWrapperImpl(object);
+                        for (int j = 0; j < columns.size(); ++j) {
+                            String k = columns.get(j);
+                            Object v = values.get(i).get(j);
+                            if ("time".equals(k)) {
+                                continue;
+                            }  else {
+                                bean.setPropertyValue(k, v);
+                            }
+                        }
+                        list.add(object);
+                    }
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return list;
+    }
+
+    public <T> List<T> getListData1(String sql, Class<T> clazz) {
+        List<T> list = new ArrayList<>();
+        try {
+            List<Map<String,Object>> mapList = influxdbUtil.query(sql);
+            list=mapList.stream().map(stringObjectMap -> JSONObject.parseObject(JSON.toJSONString(stringObjectMap),clazz)).collect(Collectors.toList());
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return list;
+    }
+
+    public <T> List<T> getListDataAll(String sql, Class<T> clazz) {
+        List<T> list = new ArrayList<>();
+        try {
+            QueryResult query = influxDbConnection.query(sql);
+            List<QueryResult.Result> queryResults = query.getResults();
+            for (QueryResult.Result result : queryResults) {
+                List<QueryResult.Series> series = result.getSeries();
+                if (series == null) {
+                    continue;
+                }
+                for (QueryResult.Series serie : series) {
+                    List<List<Object>> values = serie.getValues();
+                    List<String> columns = serie.getColumns();
+                    for (int i = 0; i < values.size(); ++i) {
+                        T object = clazz.newInstance();
+                        BeanWrapperImpl bean = new BeanWrapperImpl(object);
+                        for (int j = 0; j < columns.size(); ++j) {
+                            String k = columns.get(j);
+                            Object v = values.get(i).get(j);
+
+                            bean.setPropertyValue(k, v);
+
+                        }
+                        list.add(object);
+                    }
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return list;
+    }
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/cluster/IdxBizC80cMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizC80c">
-
+<mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizC80cMapper">
+    <select id="gateWayIdListFan" resultType="java.lang.String">
+        select ANALYSIS_GATEWAY_ID from idx_biz_c80c group by ANALYSIS_GATEWAY_ID;
+    </select>
 </mapper>

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/cluster/IdxBizHjevMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizHjev">
+<mapper namespace="com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizHjevMapper">
+    <select id="gateWayIdListPV" resultType="java.lang.String">
+        select ANALYSIS_GATEWAY_ID from idx_biz_hjev group by ANALYSIS_GATEWAY_ID;
+    </select>
 </mapper>