动态表格

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/java/com/yeejoin/amos/boot/module/jxiop/api/dto/IndexDto.java

@@ -17,6 +17,7 @@ public class IndexDto {
     private String address;//  指标地址
     private String createdTime;// '上报时间',
     private String equipmentSpecificName;//
+    private String equipmentNumber;
     private String  value;
     private int  count;
     private String equipmentsIdx;

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/DeviceController.java

@@ -2,10 +2,10 @@ package com.yeejoin.amos.boot.module.jxiop.biz.controller;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
-import com.yeejoin.amos.boot.module.jxiop.api.dto.DeviceDto;
 import com.yeejoin.amos.boot.module.jxiop.api.dto.IndexDto;
-import com.yeejoin.amos.boot.module.jxiop.api.dto.PersonAccountDto;
-import com.yeejoin.amos.boot.module.jxiop.biz.dto.RegionNationWideDto;
+import com.yeejoin.amos.boot.module.jxiop.biz.dto.ColModel;
+import com.yeejoin.amos.boot.module.jxiop.biz.dto.DataGridMock;
+import com.yeejoin.amos.boot.module.jxiop.biz.dto.ResultsData;
 import com.yeejoin.amos.boot.module.jxiop.biz.utils.InfluxDButils;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -20,6 +20,7 @@ import org.typroject.tyboot.core.restful.doc.TycloudOperation;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -40,33 +41,44 @@ public class DeviceController extends BaseController {
     @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "获取告警数据")
     @GetMapping("/nationwide")
-    public ResponseModel<Page<IndexDto>> getNationWideInfo(@RequestParam(value = "current") int current,@RequestParam
-                    (value = "size") int size,@RequestParam(value = "gateway") String gateway,@RequestParam(value = "equipmentNumber") String equipmentNumber) {
+    public ResponseModel<ResultsData> getNationWideInfo(@RequestParam(value = "current") int current,@RequestParam
+                    (value = "size") int size,@RequestParam(value = "gateway") String gateway,@RequestParam(value = "equipmentNumber" , required = false ) String equipmentNumber) {
         Page<IndexDto> page = new Page<IndexDto>();
         page.setCurrent(current);
         page.setSize(size);
-        StringBuffer querysql = new StringBuffer("SELECT createdTime ,gatewayId,address,valueLabel,equipmentSpecificName,value FROM ");
-        querysql.append("indicators_").append(gateway);
-        querysql.append(" WHERE isAlarm='1'   and value!='0.0'  and  gatewayId=");
-        querysql.append(gateway);
-        StringBuffer querysqlcount = new StringBuffer("SELECT count(value) FROM ");
-        querysqlcount.append("indicators_").append(gateway);
-        querysqlcount.append(" WHERE isAlarm='1'    and value!='0.0'  and  gatewayId=");
-        querysqlcount.append(gateway);
-        if(StringUtils.isNotEmpty(querysqlcount)){
-            querysqlcount.append(" and equipmentNumber =").append(equipmentNumber);
-            querysql.append(" and equipmentNumber =").append(equipmentNumber);
+        String table=gateway;
+        StringBuffer querysql = new StringBuffer("SELECT createdTime ,equipmentNumber,gatewayId,address,valueLabel,equipmentSpecificName,value FROM indicators_%s  WHERE isAlarm='1'   and value!='0.0'  and  gatewayId=  %s ORDER BY time  desc   LIMIT %d OFFSET %d  ");
+        StringBuffer querysqlcount = new StringBuffer("SELECT count(value) FROM indicators_%s  WHERE isAlarm='1'   and value!='0.0'  and  gatewayId=   %s ");
+        if(StringUtils.isNotEmpty(equipmentNumber)){
+            String date ="'%s'  and equipmentNumber = '%s' ";
+            gateway= String.format(date,gateway,equipmentNumber);
+        }else{
+            gateway=String.format("'%s'",gateway);
         }
 
-        querysql.append(" ORDER BY time  desc   LIMIT ").append(page.getSize()).append(" OFFSET ").append((page.getCurrent() - 1)*page.getSize());
+        String  querysqln= String.format(querysql.toString(),table,gateway, (int)page.getSize(),(int)(page.getCurrent() - 1)*page.getSize());
+
+        String  querysqlcountn= String.format(querysqlcount.toString(),table,gateway);
         //每个分机的指标数据
-        List<IndexDto> list = influxDButils.getListData(querysql.toString(),IndexDto.class);
-        List<IndexDto> list1 = influxDButils.getListData(querysqlcount.toString(),IndexDto.class);
+        List<IndexDto> list = influxDButils.getListData(querysqln,IndexDto.class);
+        List<IndexDto> list1 = influxDButils.getListData(querysqlcountn,IndexDto.class);
         page.setRecords(list);
-        if(list1!=null&&list1.size()>0){
-            page.setTotal(list1.get(0).getCount());
-        }
-        return ResponseHelper.buildResponse(page);
+
+
+        //构建平台数据
+        DataGridMock DataGridMock=new DataGridMock(current, list1.get(0).getCount(),  false,  current, list);
+        ColModel colModelequipmentNumber=new ColModel("equipmentNumber", "equipmentNumber", "风机号", "风机号", "dataGrid",  "equipmentNumber");
+        ColModel colModelvalueLabel=new ColModel("valueLabel", "valueLabel", "事件描述", "事件描述", "dataGrid",  "valueLabel");
+        ColModel colModelcreatedTime=new ColModel("createdTime", "createdTime", "发生时间", "发生时间", "dataGrid",  "createdTime");
+        ColModel colModelvalue=new ColModel("value", "value", "告警值", "告警值", "dataGrid",  "value");
+        List<ColModel> listColModel=new ArrayList<>();
+        listColModel.add(colModelequipmentNumber);
+        listColModel.add(colModelvalueLabel);
+        listColModel.add(colModelcreatedTime);
+        listColModel.add(colModelvalue);
+        ResultsData resultsData=new ResultsData(DataGridMock,listColModel);
+
+        return ResponseHelper.buildResponse(resultsData);
     }
 
 

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/dto/ColModel.java

+package com.yeejoin.amos.boot.module.jxiop.biz.dto;
+
+import lombok.Data;
+
+/**
+ * @description:
+ * @author: tw
+ * @createDate: 2023/7/6
+ */
+@Data
+public class ColModel {
+
+    private String  fid;
+    private String dataIndex;
+    private String name;
+    private String title;
+    private String type;
+    private String  key;
+
+    public ColModel(String fid, String dataIndex, String name, String title, String type, String key) {
+        this.fid = fid;
+        this.dataIndex = dataIndex;
+        this.name = name;
+        this.title = title;
+        this.type = type;
+        this.key = key;
+    }
+}

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/dto/DataGridMock.java

+package com.yeejoin.amos.boot.module.jxiop.biz.dto;
+
+import lombok.Data;
+import org.apache.poi.ss.formula.functions.T;
+
+import java.util.List;
+
+/**
+ * @description:
+ * @author: tw
+ * @createDate: 2023/7/6
+ */
+@Data
+public class DataGridMock {
+
+    private int current;
+    private int total;
+    private boolean  pagination;
+    private int  totalPage;
+    private List   dataList;
+
+    public DataGridMock(int current, int total, boolean pagination, int totalPage, List dataList) {
+        this.current = current;
+        this.total = total;
+        this.pagination = pagination;
+        this.totalPage = totalPage;
+        this.dataList = dataList;
+    }
+}
+
+

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/dto/ResultsData.java

+package com.yeejoin.amos.boot.module.jxiop.biz.dto;
+
+import lombok.Data;
+import org.apache.poi.ss.formula.functions.T;
+
+import java.util.List;
+
+/**
+ * @description:
+ * @author: tw
+ * @createDate: 2023/7/6
+ */
+@Data
+public class ResultsData {
+
+
+     private   DataGridMock  dataGridMock;
+
+     private List<ColModel>   colModel;
+
+
+    public ResultsData(DataGridMock dataGridMock, List<ColModel> colModel) {
+        this.dataGridMock = dataGridMock;
+        this.colModel = colModel;
+    }
+}