风机页面数据查询接口

das/src/main/java/com/das/modules/equipment/mapper/SysEquipmentMapper.java

@@ -8,6 +8,7 @@ import com.das.modules.equipment.domain.excel.SysEquipmentExcel;
 import com.das.modules.equipment.domain.vo.BaseImptabmappingVo;
 import com.das.modules.equipment.domain.vo.SysEquipmentVo;
 import com.das.modules.equipment.entity.SysEquipment;
+import com.das.modules.page.domian.WindTurbinesPageVo;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -40,4 +41,7 @@ public interface SysEquipmentMapper extends BaseMapperPlus<SysEquipment, SysEqui
 
     SysEquipmentVo queryEquipmentInfoByCode(@Param("code")String code);
 
+    List<String> queryBelongLines(@Param("objectType") Long objectType);
+
+    List<WindTurbinesPageVo> queryAllWindList(@Param("objectType") Long objectType);
 }

das/src/main/java/com/das/modules/page/controller/WindTurbinesPageController.java

@@ -1,7 +1,11 @@
 package com.das.modules.page.controller;
 
 import com.das.common.result.R;
+import com.das.modules.page.domian.WindTurbinesPageVo;
+import com.das.modules.page.service.WindTurbinesPageService;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
@@ -17,6 +21,8 @@ import java.util.List;
 @RequestMapping("/api/page/turbines")
 @RestController
 public class WindTurbinesPageController {
+    @Autowired
+    private WindTurbinesPageService windTurbinesPageService;
     /**
      * 获取风机机组所属线路列表
      * @return 返回字符串数组
@@ -24,6 +30,17 @@ public class WindTurbinesPageController {
     @PostMapping("/lines")
     public R<List<String>> queryBelongLines() {
         //TODO: 查询sql: select distinct belong_line as name  from sys_equipment t where t.object_type = 10002 and belong_line !='';
-        return R.success();
+        List<String> lines = windTurbinesPageService.queryBelongLines();
+        return R.success(lines);
+    }
+
+    /**
+     * 获取风机页面数据
+     * @return 返回风机页面数据
+     */
+    @GetMapping ("/queryWindTurbinesPages")
+    public R<List<WindTurbinesPageVo>> queryWindTurbinesPages(){
+        List<WindTurbinesPageVo> windTurbinesPageVos = windTurbinesPageService.queryAllWindTurbinesPages();
+        return R.success(windTurbinesPageVos);
     }
 }

das/src/main/java/com/das/modules/page/domian/WindTurbinesPageVo.java

@@ -0,0 +1,19 @@
+package com.das.modules.page.domian;
+
+import lombok.Data;
+
+import java.util.Map;
+
+@Data
+public class WindTurbinesPageVo {
+
+    private Long irn;
+
+    private String name;
+
+    private String model;
+
+    private String belongLine;
+
+    private Map<String,Object> map;
+}

das/src/main/java/com/das/modules/page/service/WindTurbinesPageService.java

@@ -0,0 +1,67 @@
+package com.das.modules.page.service;
+
+import com.das.modules.data.domain.SnapshotValueQueryParam;
+import com.das.modules.data.service.DataService;
+import com.das.modules.equipment.mapper.SysEquipmentMapper;
+import com.das.modules.page.domian.WindTurbinesPageVo;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+@Transactional(rollbackFor = Exception.class)
+@Service
+@Slf4j
+public class WindTurbinesPageService {
+    private static final Long OBJECT_TYPE = 10002L;
+
+    @Autowired
+    SysEquipmentMapper sysEquipmentMapper;
+
+    @Autowired
+    private DataService dataService;
+
+    /**
+     * 获取风机机组所属线路列表
+     * @return 返回字符串数组
+     */
+    public List<String> queryBelongLines(){
+        return sysEquipmentMapper.queryBelongLines(OBJECT_TYPE);
+    }
+
+    public List<WindTurbinesPageVo> queryAllWindTurbinesPages(){
+        List<WindTurbinesPageVo> windTurbinesPageVos = sysEquipmentMapper.queryAllWindList(OBJECT_TYPE);
+        List<SnapshotValueQueryParam> paramList = new ArrayList<>();
+        List<String> attributesList = new ArrayList<>();
+        attributesList.add("iwindspeed");
+        attributesList.add("iturbineoperationmode");
+        attributesList.add("igenpower");
+        attributesList.add("ikwhthisday");
+        attributesList.add("ikwhoverall");
+        attributesList.add("ivanedirection");
+        attributesList.add("irotorspeed");
+        attributesList.add("igenspeed");
+        attributesList.add("itempnacelle_1sec");
+        attributesList.add("ihydrpress");
+        attributesList.add("ipitchangle1");
+        attributesList.add("ipitchangle2");
+        attributesList.add("ipitchangle3");
+        attributesList.add("iyplevel");
+        attributesList.add("gridlostdetected");
+        for (WindTurbinesPageVo item : windTurbinesPageVos){
+            SnapshotValueQueryParam snapshotValueQueryParam = new SnapshotValueQueryParam();
+            snapshotValueQueryParam.setAttributes(attributesList);
+            snapshotValueQueryParam.setDeviceId(item.getIrn().toString());
+            paramList.add(snapshotValueQueryParam);
+        }
+        Map<String, Map<String, Object>> map = dataService.querySnapshotValues(paramList);
+        for (WindTurbinesPageVo item : windTurbinesPageVos){
+            item.setMap(map.get(item.getIrn().toString()));
+        }
+        return windTurbinesPageVos;
+    }
+}

das/src/main/resources/mapper/SysEquipmentMapper.xml

@@ -162,5 +162,12 @@
     <select id="queryEquipmentInfoByCode" resultMap="SysEquipmentMap">
         select * from sys_equipment where code = #{code}
     </select>
+    <select id="queryBelongLines" resultType="java.lang.String">
+        select distinct belong_line as name  from sys_equipment t where t.object_type = 10002 and belong_line !='';
+    </select>
+    <select id="queryAllWindList" resultType="com.das.modules.page.domian.WindTurbinesPageVo">
+        select se.id as irn,se.name,se.model,se.belong_line as belongLine from sys_equipment se where se.object_type = #{objectType}
+    </select>
+
 
 </mapper>