数据获取实现类

src/main/java/com/ebei/screen/service/EbaSystemService.java

@@ -4,6 +4,7 @@ import com.ebei.screen.common.response.ResponseBean;
 import com.ebei.screen.modules.po.Test;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * EBA系统大屏
@@ -19,4 +20,84 @@ public interface EbaSystemService {
      * 获取项目列表
      */
     void getProjectList();
+
+    /**
+     * 根据项目id获取所有device信息
+     */
+    void getMobjectList(Long projectId);
+
+    /**
+     * 根据项目id获取所有iot信息
+     * @param projectId
+     */
+    void getIotList(Long projectId);
+
+    /**
+     * 获取所有设备信息(deviceSys)
+     */
+    void getDeviceSystemList();
+
+    /**
+     * 获取所有设备类型信息(deviceType)
+     */
+    void getDeviceTypeList();
+
+    /**
+     * 获取所有设备参数信息(deviceParam)
+     */
+    void getDeviceParamList();
+
+    /**
+     * 获取所有设备告警类型信息(alarmType)
+     */
+    void getDeviceAlarmTypeList();
+
+    /**
+     * 获取所有消防设备类型信息(fireDeviceType)
+     */
+    void getFireDeviceTypeList();
+
+    /**
+     * 根据deviceId和deviceParamId获取实时device信息
+     * @param deviceParams
+     */
+    void getMobjectRealDataList(List<Map<String, Integer>> deviceParams);
+
+    /**
+     * 根据projectId获取所有实时device信息
+     * @param projectId
+     */
+    void getMobjectRealDataByProjectIdList(Long projectId);
+
+    /**
+     * 根据deviceId和deviceParamId获取某段时间内设备能耗数据
+     * @param deviceId
+     * @param deviceParameterId
+     * @param beginTime
+     * @param endTime
+     */
+    void getMobjectEnergyList(Long deviceId, Long deviceParameterId, Long beginTime, Long endTime);
+
+    /**
+     * 根据项目id获取实时未恢复告警
+     * @param projectId
+     */
+    void getMobjectRealTimeAlarmList(Long projectId);
+
+    /**
+     * 根据项目id获取历史已恢复告警
+     */
+    void getMobjectHisAlarmPageList(Long projectId, Long beginTime, Long endTime, Integer pageIndex, Integer pageSize);
+
+    /**
+     * 根据iotId获取摄像头地址
+     * @param IotId
+     */
+    void getIotVideoUrl(Long IotId);
+
+    /**
+     * 根据项目id获取iot实时告警列表
+     * @param projectId
+     */
+    void getIotAlarmRealTimeList(Long projectId);
 }

src/main/java/com/ebei/screen/service/impl/EbaSystemServiceImpl.java

@@ -41,6 +41,91 @@ public class EbaSystemServiceImpl implements EbaSystemService {
     public void getProjectList() {
         List<Map> projectList = EbaUtils.getProjectList();
         //mongoTemplate.dropCollection("test");
-        mongoTemplate.insert(projectList, "test");
+        mongoTemplate.insert(projectList, "projectList");
     }
+
+    @Override
+    public void getMobjectList(Long projectId) {
+        List<Map> mobjectList = EbaUtils.getMobjectList(projectId);
+        mongoTemplate.insert(mobjectList,"mobjectList");
+    }
+
+    @Override
+    public void getIotList(Long projectId) {
+        List<Map> iotList = EbaUtils.getIotList(projectId);
+        mongoTemplate.insert(iotList,"iotList");
+    }
+
+    @Override
+    public void getDeviceSystemList() {
+        List<Map> deviceSystemList = EbaUtils.getDeviceSystemList();
+        mongoTemplate.insert(deviceSystemList,"deviceSystemList");
+    }
+
+    @Override
+    public void getDeviceTypeList() {
+        List<Map> deviceTypeList = EbaUtils.getDeviceTypeList();
+        mongoTemplate.insert(deviceTypeList,"deviceTypeList");
+    }
+
+    @Override
+    public void getDeviceParamList() {
+        List<Map> deviceParamList = EbaUtils.getDeviceParamList();
+        mongoTemplate.insert(deviceParamList,"deviceParamList");
+    }
+
+    @Override
+    public void getDeviceAlarmTypeList() {
+        List<Map> deviceAlarmTypeList = EbaUtils.getDeviceAlarmTypeList();
+        mongoTemplate.insert(deviceAlarmTypeList,"deviceAlarmTypeList");
+    }
+
+    @Override
+    public void getFireDeviceTypeList() {
+        List<Map> fireDeviceTypeList = EbaUtils.getFireDeviceTypeList();
+        mongoTemplate.insert(fireDeviceTypeList,"fireDeviceTypeList");
+    }
+
+    @Override
+    public void getMobjectRealDataList(List<Map<String, Integer>> deviceParams) {
+        List<Map> mobjectRealDataList = EbaUtils.getMobjectRealDataList(deviceParams);
+        mongoTemplate.insert(mobjectRealDataList,"mobjectRealDataList");
+    }
+
+    @Override
+    public void getMobjectRealDataByProjectIdList(Long projectId) {
+        List<Map> dataByProjectIdList = EbaUtils.getMobjectRealDataByProjectIdList(projectId);
+        mongoTemplate.insert(dataByProjectIdList,"dataByProjectIdList");
+    }
+
+    @Override
+    public void getMobjectEnergyList(Long deviceId, Long deviceParameterId, Long beginTime, Long endTime) {
+        List<Map> mobjectEnergyList = EbaUtils.getMobjectEnergyList(deviceId, deviceParameterId, beginTime, endTime);
+        mongoTemplate.insert(mobjectEnergyList,"mobjectEnergyList");
+    }
+
+    @Override
+    public void getMobjectRealTimeAlarmList(Long projectId) {
+        List<Map> mobjectRealTimeAlarmList = EbaUtils.getMobjectRealTimeAlarmList(projectId);
+        mongoTemplate.insert(mobjectRealTimeAlarmList,"mobjectRealTimeAlarmList");
+    }
+
+    @Override
+    public void getMobjectHisAlarmPageList(Long projectId, Long beginTime, Long endTime, Integer pageIndex, Integer pageSize) {
+        List<Map> mobjectHisAlarmPageList = EbaUtils.getMobjectHisAlarmPageList(projectId, beginTime, endTime, pageIndex, pageSize);
+        mongoTemplate.insert(mobjectHisAlarmPageList,"mobjectHisAlarmPageList");
+    }
+
+    @Override
+    public void getIotVideoUrl(Long IotId) {
+        List<Map> iotVideoUrl = EbaUtils.getIotVideoUrl(IotId);
+        mongoTemplate.insert(iotVideoUrl,"iotVideoUrl");
+    }
+
+    @Override
+    public void getIotAlarmRealTimeList(Long projectId) {
+        List<Map> iotAlarmRealTimeList = EbaUtils.getIotAlarmRealTimeList(projectId);
+        mongoTemplate.insert(iotAlarmRealTimeList,"iotAlarmRealTimeList");
+    }
+
 }