diff --git a/os-admin/src/main/resources/application-druid.yml b/os-admin/src/main/resources/application-druid.yml index 08ce39b..17a29de 100644 --- a/os-admin/src/main/resources/application-druid.yml +++ b/os-admin/src/main/resources/application-druid.yml @@ -6,9 +6,9 @@ spring: # 主库数据源 master: driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver - url: jdbc:sqlserver://175.27.215.92:1433;SelectMethod=cursor;DatabaseName=jdap_ems + url: jdbc:sqlserver://119.45.202.115:1433;SelectMethod=cursor;DatabaseName=jdap_ems username: sa - password: Hawei@123 + password: haiwei@123 # 从库数据源 slave: driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver diff --git a/os-ems/src/main/java/com/os/ems/record/controller/TWTempertureDataController.java b/os-ems/src/main/java/com/os/ems/record/controller/TWTempertureDataController.java index 5816cff..4d78e06 100644 --- a/os-ems/src/main/java/com/os/ems/record/controller/TWTempertureDataController.java +++ b/os-ems/src/main/java/com/os/ems/record/controller/TWTempertureDataController.java @@ -1,11 +1,15 @@ package com.os.ems.record.controller; -import java.util.List; +import java.text.SimpleDateFormat; +import java.util.*; import javax.servlet.http.HttpServletResponse; +import com.alibaba.fastjson2.JSONArray; +import com.os.common.utils.StringUtils; import com.os.ems.base.service.IEmsBaseEnergyTypeService; import com.os.ems.base.service.IEmsBaseMonitorInfoService; import com.os.ems.record.domain.EmsIOTData; +import com.os.ems.record.domain.EmsIOTInstantMonitorData; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; @@ -42,6 +46,8 @@ public class TWTempertureDataController extends BaseController @Autowired private IEmsBaseEnergyTypeService emsBaseEnergyTypeService; + private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + /** * 查询物联网实时数据列表 */ @@ -81,6 +87,44 @@ public class TWTempertureDataController extends BaseController return success(emsIOTData); } + /** + * 查询物联网设备实时监控数据 + * @param monitorCodeList + * @return + */ + @GetMapping("/iotInstantMonitoring") + public AjaxResult iotInstantMonitoring(String monitorCodeList){ + List list = new ArrayList(); + if(StringUtils.isNotEmpty(monitorCodeList)){ + String[] split = monitorCodeList.split(","); + for (String monitorId : split) { + + TWTempertureData tWTempertureData = new TWTempertureData(); + tWTempertureData.setMonitorId(monitorId); + Map params = new HashMap<>(); + + Calendar calendar = Calendar.getInstance(); + calendar.add(Calendar.MINUTE,-5); + Calendar startTime = (Calendar) calendar.clone(); + params.put("beginRecordTime",sdf.format(startTime.getTime())); + params.put("endRecordTime",sdf.format(new Date())); + tWTempertureData.setParams(params); + + List twTempertureData = tWTempertureDataService.selectIotInstantList(tWTempertureData); + if(twTempertureData.size()>0){ + Optional first = twTempertureData.stream().sorted(Comparator.comparing(TWTempertureData::getRecodeTime)).findFirst(); + + list.add(first.get()); + } + + + } + } + + System.out.println(JSONArray.toJSONString(list)); + return success(list); + } + /** * 导出物联网实时数据列表 */ diff --git a/os-ems/src/main/java/com/os/ems/record/domain/EmsIOTInstantMonitorData.java b/os-ems/src/main/java/com/os/ems/record/domain/EmsIOTInstantMonitorData.java new file mode 100644 index 0000000..7394ee3 --- /dev/null +++ b/os-ems/src/main/java/com/os/ems/record/domain/EmsIOTInstantMonitorData.java @@ -0,0 +1,28 @@ +package com.os.ems.record.domain; + +import java.util.List; + +public class EmsIOTInstantMonitorData { + private String monitorId; + private TWTempertureData data; + + public EmsIOTInstantMonitorData() { + + } + + public String getMonitorId() { + return monitorId; + } + + public void setMonitorId(String monitorId) { + this.monitorId = monitorId; + } + + public TWTempertureData getData() { + return data; + } + + public void setData(TWTempertureData data) { + this.data = data; + } +} diff --git a/os-ems/src/main/java/com/os/ems/record/mapper/TWTempertureDataMapper.java b/os-ems/src/main/java/com/os/ems/record/mapper/TWTempertureDataMapper.java index 1ca63e1..241ee83 100644 --- a/os-ems/src/main/java/com/os/ems/record/mapper/TWTempertureDataMapper.java +++ b/os-ems/src/main/java/com/os/ems/record/mapper/TWTempertureDataMapper.java @@ -65,4 +65,11 @@ public interface TWTempertureDataMapper * @return */ List selectIotInstantList(TWTempertureData tWTempertureData); + + /** + * 根据设备编号查询实时物联网设备监控数据 + * @param monitorId + * @return + */ + TWTempertureData selectIotInstantMinitoringData(String monitorId); } diff --git a/os-ems/src/main/java/com/os/ems/record/service/ITWTempertureDataService.java b/os-ems/src/main/java/com/os/ems/record/service/ITWTempertureDataService.java index 6ea431d..2ec9b04 100644 --- a/os-ems/src/main/java/com/os/ems/record/service/ITWTempertureDataService.java +++ b/os-ems/src/main/java/com/os/ems/record/service/ITWTempertureDataService.java @@ -65,4 +65,11 @@ public interface ITWTempertureDataService * @return */ List selectIotInstantList(TWTempertureData tWTempertureData); + + /** + * 根据设备编号查询实时物联网设备监控数据 + * @param monitorId + * @return + */ + TWTempertureData selectIotInstantMinitoringData(String monitorId); } diff --git a/os-ems/src/main/java/com/os/ems/record/service/impl/TWTempertureDataServiceImpl.java b/os-ems/src/main/java/com/os/ems/record/service/impl/TWTempertureDataServiceImpl.java index fde8b91..0790537 100644 --- a/os-ems/src/main/java/com/os/ems/record/service/impl/TWTempertureDataServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/record/service/impl/TWTempertureDataServiceImpl.java @@ -100,4 +100,14 @@ public class TWTempertureDataServiceImpl implements ITWTempertureDataService public List selectIotInstantList(TWTempertureData tWTempertureData) { return tWTempertureDataMapper.selectIotInstantList(tWTempertureData); } + + /** + * 根据设备编号查询实时物联网设备监控数据 + * @param monitorId + * @return + */ + @Override + public TWTempertureData selectIotInstantMinitoringData(String monitorId) { + return tWTempertureDataMapper.selectIotInstantMinitoringData(monitorId); + } } diff --git a/os-ems/src/main/resources/mapper/ems/record/TWTempertureDataMapper.xml b/os-ems/src/main/resources/mapper/ems/record/TWTempertureDataMapper.xml index 981573e..440e751 100644 --- a/os-ems/src/main/resources/mapper/ems/record/TWTempertureDataMapper.xml +++ b/os-ems/src/main/resources/mapper/ems/record/TWTempertureDataMapper.xml @@ -79,6 +79,14 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" order by twtd.collectTime + + insert into T_W_TempertureData