From a4d06b1354d48d94c8e07d716863bcb7d3876a07 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Wed, 23 Jun 2021 15:18:40 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev_ --- screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java | 45 ++++++++++++++++++++++++++++++++++++++------- 1 files changed, 38 insertions(+), 7 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java index 8e0b503..537ffe4 100644 --- a/screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java +++ b/screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java @@ -138,12 +138,12 @@ content = content+"���������:"+oldSensor.getName()+"->"+updateSensorMap.get(key)+";"; } if (key.toString().equals("code")&&updateSensorMap.get(key)!=null){ - QueryWrapper<VersionSensorUnit> wrapper_Version = new QueryWrapper<>(); + /*QueryWrapper<VersionSensorUnit> wrapper_Version = new QueryWrapper<>(); wrapper_Version.eq("sensor_code",oldSensor.getCode()); wrapper_Version.eq("is_delete","0"); VersionSensorUnit versionSensorUnit = new VersionSensorUnit(); versionSensorUnit.setSensorCode(updateSensorMap.get(key).toString()); - versionSensorUnitMapper.update(versionSensorUnit,wrapper_Version); + versionSensorUnitMapper.update(versionSensorUnit,wrapper_Version);*/ content = content+"������:"+oldSensor.getCode()+"->"+updateSensorMap.get(key)+";"; } if (key.toString().equals("desc")&&updateSensorMap.get(key)!=null){ @@ -179,9 +179,9 @@ if (!ObjectUtils.isEmpty(map.get("orderType"))){ String orderType = map.get("orderType").toString(); if (orderType.equals(Constants.ORDER_DESC)){ - wrapper.orderByDesc("create_time"); + wrapper.orderByDesc("update_time"); }else { - wrapper.orderByAsc("create_time"); + wrapper.orderByAsc("update_time"); } } Page resultPage = sensorMapper.selectPage(page,wrapper); @@ -214,6 +214,36 @@ totalPageNumber += 1; } resultMap.put("totalPageNumber",totalPageNumber); + return resultMap; + } + + @Override + public Map<String, Object> getAllSensorWithoutPage() { + Map<String,Object> resultMap = new HashMap<>(); + QueryWrapper<Sensor> wrapper = new QueryWrapper(); + wrapper.eq("is_delete",0); + List<Sensor> sensors = sensorMapper.selectList(wrapper); + SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + List<Map<String,Object>> sensorList = new ArrayList<>(); + for (Sensor sensor:sensors) { + Map sensorMap = JSON.parseObject(JSON.toJSONString(sensor),Map.class); + String createTime = SDF.format(sensor.getCreateTime()); + String updateTime = SDF.format(sensor.getUpdateTime()); + sensorMap.put("createTime",createTime); + sensorMap.put("updateTime",updateTime); + sensorMap.put("key",sensor.getId()); + if (sensor.getDefaultUnitKey()!=null&&sensor.getDefaultUnitKey()!=""){ + QueryWrapper<SysDictData> wrapper_VSU = new QueryWrapper(); + wrapper_VSU.eq("is_delete",0); + wrapper_VSU.eq("dataKey",sensor.getDefaultUnitKey()); + wrapper_VSU.eq("dict_type_id",14); + if (!ObjectUtils.isEmpty(sysDictDataMapper.selectOne(wrapper_VSU))&&!ObjectUtils.isEmpty(sysDictDataMapper.selectOne(wrapper_VSU).getDataValue())){ + sensorMap.put("default_unit_key",sysDictDataMapper.selectOne(wrapper_VSU).getDataValue()); + } + } + sensorList.add(sensorMap); + } + resultMap.put("sensors",sensorList); return resultMap; } @@ -264,9 +294,9 @@ int totleNum = sensorMapper.selectCount(wrapper); String orderType = map.get("orderType").toString(); if (orderType.equals(Constants.ORDER_ASC)){ - wrapper.orderByAsc("create_time"); + wrapper.orderByAsc("update_time"); }else { - wrapper.orderByDesc("create_time"); + wrapper.orderByDesc("update_time"); } Page resultPage = sensorMapper.selectPage(page,wrapper); List<Sensor> sensors = resultPage.getRecords(); @@ -279,7 +309,7 @@ sensorMap.put("createTime",createTime); sensorMap.put("updateTime",updateTime); sensorMap.put("key",sensor.getId()); - if (sensor.getDefaultUnitKey()!=null&&sensor.getDefaultUnitKey()!=""){ + if (sensor.getDefaultUnitKey()!=null&&!sensor.getDefaultUnitKey().equals("")){ QueryWrapper<SysDictData> wrapper_VSU = new QueryWrapper(); wrapper_VSU.eq("is_delete",0); wrapper_VSU.eq("dataKey",sensor.getDefaultUnitKey()); @@ -299,6 +329,7 @@ return resultMap; } + @Override public Map<String,Sensor> getAllSensorFromCache(){ Map<String,Sensor> sensors = redisTemplate.opsForHash().entries(RedisConstants.SENSOR_KEY); if(ObjectUtils.isEmpty(sensors)) -- Gitblit v1.8.0