diff --git a/os-ems/src/main/java/com/os/ems/base/controller/EmsBaseEnergyTypeController.java b/os-ems/src/main/java/com/os/ems/base/controller/EmsBaseEnergyTypeController.java
index 671ca44..91cdf37 100644
--- a/os-ems/src/main/java/com/os/ems/base/controller/EmsBaseEnergyTypeController.java
+++ b/os-ems/src/main/java/com/os/ems/base/controller/EmsBaseEnergyTypeController.java
@@ -46,6 +46,17 @@ public class EmsBaseEnergyTypeController extends BaseController
         return getDataTable(list);
     }
 
+//    /**
+//     * 根据能源类型id查询能源类型名称
+//     * @param energyTypeId
+//     * @return
+//     */
+//    public AjaxResult queryEnergyNameByEnergyTypeId(int energyTypeId)
+//    {
+//        String energyName = emsBaseEnergyTypeService.queryEnergyNameByEnergyTypeId(energyTypeId);
+//        return success(energyName);
+//    }
+
     /**
      * 查询能源类型信息下拉框列表
      */
diff --git a/os-ems/src/main/java/com/os/ems/base/mapper/EmsBaseEnergyTypeMapper.java b/os-ems/src/main/java/com/os/ems/base/mapper/EmsBaseEnergyTypeMapper.java
index cdeb162..5770a98 100644
--- a/os-ems/src/main/java/com/os/ems/base/mapper/EmsBaseEnergyTypeMapper.java
+++ b/os-ems/src/main/java/com/os/ems/base/mapper/EmsBaseEnergyTypeMapper.java
@@ -58,4 +58,11 @@ public interface EmsBaseEnergyTypeMapper
      * @return 结果
      */
     public int deleteEmsBaseEnergyTypeByObjIds(Long[] objIds);
+
+    /**
+     * 根据能源类型id查询能源类型名称
+     * @param energyTypeId
+     * @return
+     */
+    public String selectEmsBaseEnergyNameByEnergyTypeId(int energyTypeId);
 }
diff --git a/os-ems/src/main/java/com/os/ems/base/mapper/EmsBaseMonitorInfoMapper.java b/os-ems/src/main/java/com/os/ems/base/mapper/EmsBaseMonitorInfoMapper.java
index 02a45fb..5683276 100644
--- a/os-ems/src/main/java/com/os/ems/base/mapper/EmsBaseMonitorInfoMapper.java
+++ b/os-ems/src/main/java/com/os/ems/base/mapper/EmsBaseMonitorInfoMapper.java
@@ -58,4 +58,11 @@ public interface EmsBaseMonitorInfoMapper
      * @return 结果
      */
     public int deleteEmsBaseMonitorInfoByObjIds(Long[] objIds);
+
+    /**
+     * 根据设备编码查询本设备的能源类型
+     * @param monitorCode
+     * @return
+     */
+    public String selectEmsBaseMonitorTypeByMonitorCode(String monitorCode);
 }
diff --git a/os-ems/src/main/java/com/os/ems/base/service/IEmsBaseEnergyTypeService.java b/os-ems/src/main/java/com/os/ems/base/service/IEmsBaseEnergyTypeService.java
index 1be9b4e..bceafc2 100644
--- a/os-ems/src/main/java/com/os/ems/base/service/IEmsBaseEnergyTypeService.java
+++ b/os-ems/src/main/java/com/os/ems/base/service/IEmsBaseEnergyTypeService.java
@@ -58,4 +58,11 @@ public interface IEmsBaseEnergyTypeService
      * @return 结果
      */
     public int deleteEmsBaseEnergyTypeByObjId(Long objId);
+
+    /**
+     * 根据能源类型id查询能源类型名称
+     * @param energyTypeId
+     * @return
+     */
+    String queryEnergyNameByEnergyTypeId(int energyTypeId);
 }
diff --git a/os-ems/src/main/java/com/os/ems/base/service/IEmsBaseMonitorInfoService.java b/os-ems/src/main/java/com/os/ems/base/service/IEmsBaseMonitorInfoService.java
index de4d90d..ebdad4b 100644
--- a/os-ems/src/main/java/com/os/ems/base/service/IEmsBaseMonitorInfoService.java
+++ b/os-ems/src/main/java/com/os/ems/base/service/IEmsBaseMonitorInfoService.java
@@ -22,12 +22,18 @@ public interface IEmsBaseMonitorInfoService
 
     /**
      * 查询计量设备信息列表
-     * 
      * @param emsBaseMonitorInfo 计量设备信息
      * @return 计量设备信息集合
      */
     public List<EmsBaseMonitorInfo> selectEmsBaseMonitorInfoList(EmsBaseMonitorInfo emsBaseMonitorInfo);
 
+    /**
+     * 根据设备编号查询本设备能源类型
+     * @param monitorCode
+     * @return
+     */
+    public String selectEmsBaseMonitorTypeByMonitorCode(String monitorCode);
+
     /**
      * 新增计量设备信息
      * 
diff --git a/os-ems/src/main/java/com/os/ems/base/service/impl/EmsBaseEnergyTypeServiceImpl.java b/os-ems/src/main/java/com/os/ems/base/service/impl/EmsBaseEnergyTypeServiceImpl.java
index 61ffccc..f9ef082 100644
--- a/os-ems/src/main/java/com/os/ems/base/service/impl/EmsBaseEnergyTypeServiceImpl.java
+++ b/os-ems/src/main/java/com/os/ems/base/service/impl/EmsBaseEnergyTypeServiceImpl.java
@@ -93,4 +93,14 @@ public class EmsBaseEnergyTypeServiceImpl implements IEmsBaseEnergyTypeService
     {
         return emsBaseEnergyTypeMapper.deleteEmsBaseEnergyTypeByObjId(objId);
     }
+
+    /**
+     * 根据能源类型id查询能源类型名称
+     * @param energyTypeId
+     * @return
+     */
+    @Override
+    public String queryEnergyNameByEnergyTypeId(int energyTypeId) {
+        return emsBaseEnergyTypeMapper.selectEmsBaseEnergyNameByEnergyTypeId(energyTypeId);
+    }
 }
diff --git a/os-ems/src/main/java/com/os/ems/base/service/impl/EmsBaseMonitorInfoServiceImpl.java b/os-ems/src/main/java/com/os/ems/base/service/impl/EmsBaseMonitorInfoServiceImpl.java
index 250af2f..da1f401 100644
--- a/os-ems/src/main/java/com/os/ems/base/service/impl/EmsBaseMonitorInfoServiceImpl.java
+++ b/os-ems/src/main/java/com/os/ems/base/service/impl/EmsBaseMonitorInfoServiceImpl.java
@@ -50,6 +50,16 @@ public class EmsBaseMonitorInfoServiceImpl implements IEmsBaseMonitorInfoService
         return emsBaseMonitorInfoMapper.selectEmsBaseMonitorInfoList(emsBaseMonitorInfo);
     }
 
+    /**
+     * 根据设备编号查询本设备能源类型
+     * @param monitorCode
+     * @return
+     */
+    @Override
+    public String selectEmsBaseMonitorTypeByMonitorCode(String monitorCode) {
+        return emsBaseMonitorInfoMapper.selectEmsBaseMonitorTypeByMonitorCode(monitorCode);
+    }
+
     /**
      * 新增计量设备信息
      * 
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 30edc8d..5816cff 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
@@ -2,6 +2,10 @@ package com.os.ems.record.controller;
 
 import java.util.List;
 import javax.servlet.http.HttpServletResponse;
+
+import com.os.ems.base.service.IEmsBaseEnergyTypeService;
+import com.os.ems.base.service.IEmsBaseMonitorInfoService;
+import com.os.ems.record.domain.EmsIOTData;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -33,6 +37,10 @@ public class TWTempertureDataController extends BaseController
 {
     @Autowired
     private ITWTempertureDataService tWTempertureDataService;
+    @Autowired
+    private IEmsBaseMonitorInfoService emsBaseMonitorInfoService;
+    @Autowired
+    private IEmsBaseEnergyTypeService emsBaseEnergyTypeService;
 
     /**
      * 查询物联网实时数据列表
@@ -46,6 +54,33 @@ public class TWTempertureDataController extends BaseController
         return getDataTable(list);
     }
 
+    /**
+     * 查询物联网设备实时数据
+     * @param tWTempertureData
+     * @return
+     */
+    @GetMapping("/iotInstantList")
+    public AjaxResult iotInstantList(TWTempertureData tWTempertureData){
+        EmsIOTData emsIOTData = new EmsIOTData();
+        int energyTypeid = Integer.parseInt(emsBaseMonitorInfoService.selectEmsBaseMonitorTypeByMonitorCode(tWTempertureData.getMonitorId()));
+        String energyName = emsBaseEnergyTypeService.queryEnergyNameByEnergyTypeId(energyTypeid);
+        if("温湿度".equals(energyName)){
+            emsIOTData.monitorTypeArr.add("温度");
+            emsIOTData.monitorTypeArr.add("湿度");
+        }
+        else{
+            emsIOTData.monitorTypeArr.add(energyName);
+        }
+        emsIOTData.setType("line");
+        emsIOTData.setSmooth(true);
+        emsIOTData.setShowAllSymbol(true);
+        emsIOTData.setSymbol("circle");
+        emsIOTData.setSymbolSize(2);
+        List<TWTempertureData> list = tWTempertureDataService.selectIotInstantList(tWTempertureData);
+        emsIOTData.setDataList(list);
+        return success(emsIOTData);
+    }
+
     /**
      * 导出物联网实时数据列表
      */
diff --git a/os-ems/src/main/java/com/os/ems/record/domain/EmsIOTData.java b/os-ems/src/main/java/com/os/ems/record/domain/EmsIOTData.java
new file mode 100644
index 0000000..1e87d52
--- /dev/null
+++ b/os-ems/src/main/java/com/os/ems/record/domain/EmsIOTData.java
@@ -0,0 +1,102 @@
+package com.os.ems.record.domain;
+
+import org.apache.commons.math3.analysis.function.Add;
+
+import java.lang.reflect.Array;
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+public class EmsIOTData {
+
+    /**
+     * 能源类型
+     */
+    public ArrayList<String> monitorTypeArr;
+    private String name;
+    private String type;
+    private boolean smooth;
+    private boolean showAllSymbol;
+    private String symbol;
+    private int symbolSize;
+    private String symbolType;
+    private List<TWTempertureData> dataList;
+
+    public EmsIOTData() {
+        this.monitorTypeArr = new ArrayList<>();
+    }
+
+    public ArrayList<String> getMonitorTypeArr() {
+        return monitorTypeArr;
+    }
+
+    public void setMonitorTypeArr(ArrayList<String> monitorTypeArr) {
+        this.monitorTypeArr = monitorTypeArr;
+    }
+
+    public List<TWTempertureData> getDataList() {
+        return dataList;
+    }
+
+    public void setDataList(List<TWTempertureData> dataList) {
+        this.dataList = dataList;
+    }
+
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public boolean isSmooth() {
+        return smooth;
+    }
+
+    public void setSmooth(boolean smooth) {
+        this.smooth = smooth;
+    }
+
+    public boolean isShowAllSymbol() {
+        return showAllSymbol;
+    }
+
+    public void setShowAllSymbol(boolean showAllSymbol) {
+        this.showAllSymbol = showAllSymbol;
+    }
+
+    public String getSymbol() {
+        return symbol;
+    }
+
+    public void setSymbol(String symbol) {
+        this.symbol = symbol;
+    }
+
+    public int getSymbolSize() {
+        return symbolSize;
+    }
+
+    public void setSymbolSize(int symbolSize) {
+        this.symbolSize = symbolSize;
+    }
+
+    public String getSymbolType() {
+        return symbolType;
+    }
+
+    public void setSymbolType(String symbolType) {
+        this.symbolType = symbolType;
+    }
+
+}
diff --git a/os-ems/src/main/java/com/os/ems/record/domain/TWTempertureData.java b/os-ems/src/main/java/com/os/ems/record/domain/TWTempertureData.java
index a1d8492..4f49c18 100644
--- a/os-ems/src/main/java/com/os/ems/record/domain/TWTempertureData.java
+++ b/os-ems/src/main/java/com/os/ems/record/domain/TWTempertureData.java
@@ -25,6 +25,10 @@ public class TWTempertureData extends BaseEntity
     @Excel(name = "计量设备编号")
     private String monitorId;
 
+    /**计量设备名称**/
+    @Excel(name = "计量设备名称")
+    private String monitorName;
+
     /** 采集时间 */
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     @Excel(name = "采集时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss")
@@ -122,6 +126,14 @@ public class TWTempertureData extends BaseEntity
         this.illuminance = illuminance;
     }
 
+    public String getMonitorName() {
+        return monitorName;
+    }
+
+    public void setMonitorName(String monitorName) {
+        this.monitorName = monitorName;
+    }
+
     public BigDecimal getIlluminance() 
     {
         return illuminance;
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 0c08c87..1ca63e1 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
@@ -58,4 +58,11 @@ public interface TWTempertureDataMapper
      * @return 结果
      */
     public int deleteTWTempertureDataByObjids(Long[] objids);
+
+    /**
+     * 查询物联网实时数据
+     * @param tWTempertureData
+     * @return
+     */
+    List<TWTempertureData> selectIotInstantList(TWTempertureData tWTempertureData);
 }
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 5b63223..6ea431d 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
@@ -58,4 +58,11 @@ public interface ITWTempertureDataService
      * @return 结果
      */
     public int deleteTWTempertureDataByObjid(Long objid);
+
+    /**
+     * 查询实时物联网数据
+     * @param tWTempertureData
+     * @return
+     */
+    List<TWTempertureData> selectIotInstantList(TWTempertureData tWTempertureData);
 }
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 840194e..fde8b91 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
@@ -90,4 +90,14 @@ public class TWTempertureDataServiceImpl implements ITWTempertureDataService
     {
         return tWTempertureDataMapper.deleteTWTempertureDataByObjid(objid);
     }
+
+    /**
+     * 查询实时物联网数据
+     * @param tWTempertureData
+     * @return
+     */
+    @Override
+    public List<TWTempertureData> selectIotInstantList(TWTempertureData tWTempertureData) {
+        return tWTempertureDataMapper.selectIotInstantList(tWTempertureData);
+    }
 }
diff --git a/os-ems/src/main/resources/mapper/ems/base/EmsBaseEnergyTypeMapper.xml b/os-ems/src/main/resources/mapper/ems/base/EmsBaseEnergyTypeMapper.xml
index 4b87a8c..374827e 100644
--- a/os-ems/src/main/resources/mapper/ems/base/EmsBaseEnergyTypeMapper.xml
+++ b/os-ems/src/main/resources/mapper/ems/base/EmsBaseEnergyTypeMapper.xml
@@ -45,6 +45,12 @@
         where obj_id = #{objId}
     </select>
 
+    <select id="selectEmsBaseEnergyNameByEnergyTypeId">
+        select energy_name
+        from ems_base_energy_type
+        where energy_type_id = #{energyTypeId}
+    </select>
+
     <insert id="insertEmsBaseEnergyType" parameterType="EmsBaseEnergyType" useGeneratedKeys="true" keyProperty="objId">
         insert into ems_base_energy_type
         <trim prefix="(" suffix=")" suffixOverrides=",">
diff --git a/os-ems/src/main/resources/mapper/ems/base/EmsBaseMonitorInfoMapper.xml b/os-ems/src/main/resources/mapper/ems/base/EmsBaseMonitorInfoMapper.xml
index a08a63b..2f7bd12 100644
--- a/os-ems/src/main/resources/mapper/ems/base/EmsBaseMonitorInfoMapper.xml
+++ b/os-ems/src/main/resources/mapper/ems/base/EmsBaseMonitorInfoMapper.xml
@@ -72,7 +72,14 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <include refid="selectEmsBaseMonitorInfoVo"/>
         where obj_id = #{objId}
     </select>
-        
+
+    <select id="selectEmsBaseMonitorTypeByMonitorCode" parameterType="String">
+        select monitor_type
+        from ems_base_monitor_info
+        where monitor_code = #{monitorType}
+    </select>
+
+
     <insert id="insertEmsBaseMonitorInfo" parameterType="EmsBaseMonitorInfo" useGeneratedKeys="true" keyProperty="objId">
         insert into ems_base_monitor_info
         <trim prefix="(" suffix=")" suffixOverrides=",">
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 cbfa671..f02054f 100644
--- a/os-ems/src/main/resources/mapper/ems/record/TWTempertureDataMapper.xml
+++ b/os-ems/src/main/resources/mapper/ems/record/TWTempertureDataMapper.xml
@@ -18,27 +18,43 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <result property="confirmPersonID"    column="confirmPersonID"    />
         <result property="confirmTime"    column="confirmTime"    />
         <result property="confirmFlag"    column="confirmFlag"    />
+        <result property="monitorName"    column="monitor_name"   />
     </resultMap>
 
     <sql id="selectTWTempertureDataVo">
-        select objid, monitorId, collectTime, tempreture, humidity, illuminance, noise, concentration, recodeTime, alarmType, confirmPersonID, confirmTime, confirmFlag from T_W_TempertureData
+        select twtd.objid,
+               twtd.monitorId,
+               twtd.collectTime,
+               twtd.tempreture,
+               twtd.humidity,
+               twtd.illuminance,
+               twtd.noise,
+               twtd.concentration,
+               twtd.recodeTime,
+               twtd.alarmType,
+               twtd.confirmPersonID,
+               twtd.confirmTime,
+               twtd.confirmFlag,
+               ebmi.monitor_name
+        from T_W_TempertureData twtd
+                left join ems_base_monitor_info ebmi on twtd.monitorId = ebmi.monitor_code
     </sql>
 
     <select id="selectTWTempertureDataList" parameterType="TWTempertureData" resultMap="TWTempertureDataResult">
         <include refid="selectTWTempertureDataVo"/>
         <where>  
-            <if test="monitorId != null  and monitorId != ''"> and monitorId = #{monitorId}</if>
-            <if test="collectTime != null "> and collectTime = #{collectTime}</if>
-            <if test="tempreture != null "> and tempreture = #{tempreture}</if>
-            <if test="humidity != null "> and humidity = #{humidity}</if>
-            <if test="illuminance != null "> and illuminance = #{illuminance}</if>
-            <if test="noise != null "> and noise = #{noise}</if>
-            <if test="concentration != null "> and concentration = #{concentration}</if>
-            <if test="recodeTime != null "> and recodeTime = #{recodeTime}</if>
-            <if test="alarmType != null "> and alarmType = #{alarmType}</if>
-            <if test="confirmPersonID != null "> and confirmPersonID = #{confirmPersonID}</if>
-            <if test="confirmTime != null "> and confirmTime = #{confirmTime}</if>
-            <if test="confirmFlag != null "> and confirmFlag = #{confirmFlag}</if>
+            <if test="monitorId != null  and monitorId != ''"> and twtd.monitorId = #{monitorId}</if>
+            <if test="collectTime != null "> and twtd.collectTime = #{collectTime}</if>
+            <if test="tempreture != null "> and twtd.tempreture = #{tempreture}</if>
+            <if test="humidity != null "> and twtd.humidity = #{humidity}</if>
+            <if test="illuminance != null "> and twtd.illuminance = #{illuminance}</if>
+            <if test="noise != null "> and twtd.noise = #{noise}</if>
+            <if test="concentration != null "> and twtd.concentration = #{concentration}</if>
+            <if test="recodeTime != null "> and twtd.recodeTime = #{recodeTime}</if>
+            <if test="alarmType != null "> and twtd.alarmType = #{alarmType}</if>
+            <if test="confirmPersonID != null "> and twtd.confirmPersonID = #{confirmPersonID}</if>
+            <if test="confirmTime != null "> and twtd.confirmTime = #{confirmTime}</if>
+            <if test="confirmFlag != null "> and twtd.confirmFlag = #{confirmFlag}</if>
         </where>
     </select>
     
@@ -46,7 +62,18 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <include refid="selectTWTempertureDataVo"/>
         where objid = #{objid}
     </select>
-        
+    <select id="selectIotInstantList" parameterType="TWTempertureData" resultMap="TWTempertureDataResult">
+        <include refid="selectTWTempertureDataVo"></include>
+        <where>
+            <if test="monitorId != null  and monitorId != ''">and twtd.monitorId = #{monitorId}</if>
+            <if test="params.beginCollectTime != null and params.beginCollectTime != '' and params.endCollectTime != null and params.endCollectTime != ''">
+                and collectTime between #{params.beginCollectTime} and #{params.endCollectTime}</if>
+            <if test="params.beginRecordTime != null and params.beginRecordTime != '' and params.endRecordTime != null and params.endRecordTime != ''">
+                and recodeTime between #{params.beginRecordTime} and #{params.endRecordTime}</if>
+        </where>
+        order by twtd.collectTime
+    </select>
+
     <insert id="insertTWTempertureData" parameterType="TWTempertureData" useGeneratedKeys="true" keyProperty="objid">
         insert into T_W_TempertureData
         <trim prefix="(" suffix=")" suffixOverrides=",">