xufenglei
2019-04-04 35bfe435d09808e451de0f766f7660f91bdd35be
update
5 files modified
19 ■■■■ changed files
src/main/java/com/moral/controller/ScreenController.java 2 ●●●●● patch | view | raw | blame | history
src/main/java/com/moral/service/MonitorPointService.java 2 ●●●●● patch | view | raw | blame | history
src/main/java/com/moral/service/impl/DeviceAdjustValueServiceImpl.java 2 ●●● patch | view | raw | blame | history
src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java 4 ●●● patch | view | raw | blame | history
src/main/java/com/moral/service/impl/MonitorPointServiceImpl.java 9 ●●●●● patch | view | raw | blame | history
src/main/java/com/moral/controller/ScreenController.java
@@ -606,6 +606,7 @@
        parameters.put("monitorPointId", parameters.remove("monitorPoint"));
        Object sensorKey = parameters.remove("sensorKey");
        parameters.put("sensors", Arrays.asList(sensorKey));
        monitorPointService.isCompensateCalculation(parameters);
        List<Map<String, Object>> list = historyMinutelyService.getMonitorPointOrDeviceAvgData(parameters);
        
        for (Map<String, Object> map : list) {
@@ -724,6 +725,7 @@
        parameters.put("monitorPointId", parameters.remove("monitorPoint"));
        String[] sensorKeys = parameters.remove("sensorKey").toString().split(",");
        parameters.put("sensors", Arrays.asList(sensorKeys));
        monitorPointService.isCompensateCalculation(parameters);
        List<Map<String, Object>> list = historyMinutelyService.getMonitorPointOrDeviceAvgData(parameters);
        
        for (Map<String, Object> map : list) {
src/main/java/com/moral/service/MonitorPointService.java
@@ -37,4 +37,6 @@
    List<MonitorPoint> getMonitorPointsAndDevicesByRegion(Map<String, Object> parameters);
    Collection<Object> getDevicesStateByRegion(Map<String, Object> parameters);
    void isCompensateCalculation(Map<String, Object> parameters);
}
src/main/java/com/moral/service/impl/DeviceAdjustValueServiceImpl.java
@@ -58,7 +58,7 @@
            Map<String,Float> adjustMap = new HashMap<>();
            if(adjustValue.getValue()!=null&&!adjustValue.getValue().isEmpty()){
                for(Map.Entry<String,Float> entry:adjustValue.getValue().entrySet()){
                    if(entry.getValue()!=null&&entry.getValue()!=0){
                    if(entry.getValue()!=null){
                        adjustMap.put(entry.getKey(),entry.getValue());
                    }
                }
src/main/java/com/moral/service/impl/HistoryMinutelyServiceImpl.java
@@ -311,7 +311,9 @@
    @Override
    public List<Map<String, Object>> getMonitorPointOrDeviceAvgData(Map<String, Object> parameters) throws Exception {
        convertQueryParam(parameters);
        if (!ObjectUtils.isEmpty(parameters.get("compensate"))) {
            parameters.put("timeUnits", "10min");
        }
        return historyMinutelyMapper.getMonitorPointOrDeviceAvgData(parameters);
    }
src/main/java/com/moral/service/impl/MonitorPointServiceImpl.java
@@ -349,4 +349,13 @@
        
        return result.values();
    }
    @Override
    public void isCompensateCalculation(Map<String, Object> parameters) {
        MonitorPoint monitorPoint = monitorPointMapper.selectByPrimaryKey(Integer.valueOf(parameters.get("monitorPointId").toString()));
        if (Integer.valueOf(320581).equals(monitorPoint.getAreaCode())) {
            parameters.put("compensate", true);
        }
    }
}