diff --git a/das/src/main/java/com/das/modules/equipment/mapper/SysEquipmentMapper.java b/das/src/main/java/com/das/modules/equipment/mapper/SysEquipmentMapper.java index 95ee6a35..6ce4ec1c 100644 --- a/das/src/main/java/com/das/modules/equipment/mapper/SysEquipmentMapper.java +++ b/das/src/main/java/com/das/modules/equipment/mapper/SysEquipmentMapper.java @@ -37,5 +37,5 @@ public interface SysEquipmentMapper extends BaseMapperPlus queryBelongLines(@Param("objectType") Long objectType); - List queryAllWindList(@Param("objectType") Long objectType); + List querySysEquipmentList(@Param("info") SysEquipmentDto sysEquipmentDto); } diff --git a/das/src/main/java/com/das/modules/page/service/WindTurbinesPageService.java b/das/src/main/java/com/das/modules/page/service/WindTurbinesPageService.java index c34048ca..57776dc3 100644 --- a/das/src/main/java/com/das/modules/page/service/WindTurbinesPageService.java +++ b/das/src/main/java/com/das/modules/page/service/WindTurbinesPageService.java @@ -3,6 +3,8 @@ package com.das.modules.page.service; import com.das.common.exceptions.ServiceException; import com.das.modules.data.domain.SnapshotValueQueryParam; import com.das.modules.data.service.DataService; +import com.das.modules.equipment.domain.dto.SysEquipmentDto; +import com.das.modules.equipment.domain.vo.SysEquipmentVo; import com.das.modules.equipment.mapper.SysEquipmentMapper; import com.das.modules.node.domain.dto.DeviceCommandDto; import com.das.modules.node.service.SysNodeService; @@ -20,7 +22,7 @@ import java.util.Map; @Service @Slf4j public class WindTurbinesPageService { - private static final Long OBJECT_TYPE = 10002L; + private static final Integer OBJECT_TYPE = 10002; @Autowired SysEquipmentMapper sysEquipmentMapper; @@ -33,56 +35,87 @@ public class WindTurbinesPageService { /** * 获取风机机组所属线路列表 + * * @return 返回字符串数组 */ - public List queryBelongLines(){ - return sysEquipmentMapper.queryBelongLines(OBJECT_TYPE); + public List queryBelongLines() { + return sysEquipmentMapper.queryBelongLines(Long.valueOf(OBJECT_TYPE)); } /** * 获取风机页面数据 + * * @return 返回风机页面数据 */ - public List queryAllWindTurbinesPages(){ - List windTurbinesPageVos = sysEquipmentMapper.queryAllWindList(OBJECT_TYPE); + public List queryAllWindTurbinesPages() { + SysEquipmentDto sysEquipmentDto = new SysEquipmentDto(); + sysEquipmentDto.setObjectType(OBJECT_TYPE); + List sysEquipmentVos = sysEquipmentMapper.querySysEquipmentList(sysEquipmentDto); + //风机返回数据列表 + List windTurbinesPageVos = new ArrayList<>(); List paramList = new ArrayList<>(); + //构建需要查询的物模型属性 List attributesList = new ArrayList<>(); + //风速 attributesList.add("iwindspeed"); + //风机状态 attributesList.add("iturbineoperationmode"); + //有功功率(MW) attributesList.add("igenpower"); + //日发电量(kwh) attributesList.add("ikwhthisday"); + //总发电量(万kwh) attributesList.add("ikwhoverall"); + //机舱角度 attributesList.add("ivanedirection"); + //叶轮转速(rmp) attributesList.add("irotorspeed"); + //发电机转速(rmp) attributesList.add("igenspeed"); + //机舱温度(℃) attributesList.add("itempnacelle_1sec"); + //主油路压力(kpa) attributesList.add("ihydrpress"); + //变桨角度ipitchangle1,ipitchangle2,ipitchangle3(取最小值) attributesList.add("ipitchangle1"); attributesList.add("ipitchangle2"); attributesList.add("ipitchangle3"); + //解缆状态 attributesList.add("iyplevel"); + //电网故障停机 attributesList.add("gridlostdetected"); - for (WindTurbinesPageVo item : windTurbinesPageVos){ + for (SysEquipmentVo item : sysEquipmentVos) { + //构建查询属性参数 SnapshotValueQueryParam snapshotValueQueryParam = new SnapshotValueQueryParam(); snapshotValueQueryParam.setAttributes(attributesList); - snapshotValueQueryParam.setDeviceId(item.getIrn().toString()); + snapshotValueQueryParam.setDeviceId(item.getId().toString()); paramList.add(snapshotValueQueryParam); + //构建风机数据返回 + WindTurbinesPageVo windTurbinesPageVo = new WindTurbinesPageVo(); + windTurbinesPageVo.setIrn(item.getId()); + windTurbinesPageVo.setName(item.getName()); + windTurbinesPageVo.setModel(item.getModel()); + windTurbinesPageVo.setModelId(item.getIotModelId()); + windTurbinesPageVo.setBelongLine(item.getBelongLine()); + windTurbinesPageVos.add(windTurbinesPageVo); + } + //获取设备测点数据 Map> map = dataService.querySnapshotValues(paramList); - for (WindTurbinesPageVo item : windTurbinesPageVos){ + for (WindTurbinesPageVo item : windTurbinesPageVos) { item.setAttributeMap(map.get(item.getIrn().toString())); } return windTurbinesPageVos; } - public void windTurbinesControl(List controlList){ - for (DeviceCommandDto item : controlList){ + public void windTurbinesControl(List controlList) { + for (DeviceCommandDto item : controlList) { try { sysNodeService.deviceCommand(item); - }catch (Exception e){ - log.error("下控失败",e); - throw new ServiceException("下控失败"+e); + } catch (Exception e) { + log.error("下控失败", e); + throw new ServiceException("下控失败" + e); } }