| | |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.moral.api.entity.ManageRole; |
| | | import com.moral.api.entity.Sensor; |
| | | import com.moral.api.entity.SysDictData; |
| | | import com.moral.api.entity.VersionSensorUnit; |
| | | import com.moral.api.mapper.SensorMapper; |
| | | import com.moral.api.mapper.SysDictDataMapper; |
| | | import com.moral.api.mapper.VersionSensorUnitMapper; |
| | | import com.moral.api.service.SensorService; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.moral.api.util.LogUtils; |
| | | import com.moral.constant.Constants; |
| | | import com.moral.constant.RedisConstants; |
| | | import com.moral.constant.ResponseCodeEnum; |
| | | import com.moral.util.TokenUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | |
| | | @Autowired(required = false) |
| | | private SensorMapper sensorMapper; |
| | | |
| | | @Autowired(required = false) |
| | | private VersionSensorUnitMapper versionSensorUnitMapper; |
| | | |
| | | @Autowired(required = false) |
| | | private SysDictDataMapper sysDictDataMapper; |
| | | |
| | | @Autowired |
| | | LogUtils logUtils; |
| | |
| | | HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); |
| | | String content = "修改因子:"+oldSensor.getName()+";"; |
| | | for (Object key:updateSensorMap.keySet()) { |
| | | if (key.toString().equals("name")){ |
| | | content = content+"角色名:"+oldSensor.getName()+"->"+updateSensorMap.get(key)+";"; |
| | | if (key.toString().equals("name")&&updateSensorMap.get(key)!=null){ |
| | | content = content+"因子名:"+oldSensor.getName()+"->"+updateSensorMap.get(key)+";"; |
| | | } |
| | | if (key.toString().equals("code")){ |
| | | if (key.toString().equals("code")&&updateSensorMap.get(key)!=null){ |
| | | /*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);*/ |
| | | content = content+"编号:"+oldSensor.getCode()+"->"+updateSensorMap.get(key)+";"; |
| | | } |
| | | if (key.toString().equals("desc")){ |
| | | if (key.toString().equals("desc")&&updateSensorMap.get(key)!=null){ |
| | | content = content+"备注:"+oldSensor.getDesc()+"->"+updateSensorMap.get(key)+";"; |
| | | } |
| | | if (key.toString().equals("upper")&&updateSensorMap.get(key)!=null){ |
| | | content = content+"上限:"+oldSensor.getDesc()+"->"+updateSensorMap.get(key)+";"; |
| | | } |
| | | if (key.toString().equals("lower")&&updateSensorMap.get(key)!=null){ |
| | | content = content+"下限:"+oldSensor.getDesc()+"->"+updateSensorMap.get(key)+";"; |
| | | } |
| | | if (key.toString().equals("default_unit_key")&&updateSensorMap.get(key)!=null){ |
| | | content = content+"默认单位:"+oldSensor.getDesc()+"->"+updateSensorMap.get(key)+";"; |
| | | } |
| | | } |
| | | logUtils.saveOperationForManage(request,content,Constants.UPDATE_OPERATE_TYPE); |
| | |
| | | QueryWrapper<Sensor> wrapper = new QueryWrapper(); |
| | | wrapper.eq("is_delete",0); |
| | | int totleNum = sensorMapper.selectCount(wrapper); |
| | | String orderType = map.get("orderType").toString(); |
| | | if (orderType.equals(Constants.ORDER_ASC)){ |
| | | wrapper.orderByAsc("create_time"); |
| | | }else { |
| | | wrapper.orderByDesc("create_time"); |
| | | if (!ObjectUtils.isEmpty(map.get("orderType"))){ |
| | | String orderType = map.get("orderType").toString(); |
| | | if (orderType.equals(Constants.ORDER_DESC)){ |
| | | wrapper.orderByDesc("update_time"); |
| | | }else { |
| | | wrapper.orderByAsc("update_time"); |
| | | } |
| | | } |
| | | Page resultPage = sensorMapper.selectPage(page,wrapper); |
| | | List<Sensor> sensors = resultPage.getRecords(); |
| | |
| | | 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("manageRoles",sensorList); |
| | | resultMap.put("sensors",sensorList); |
| | | resultMap.put("totalNumber",totleNum); |
| | | resultMap.put("current",current); |
| | | int totalPageNumber = totleNum/size; |
| | |
| | | return resultMap; |
| | | } |
| | | Sensor deleteSensor = new Sensor(); |
| | | deleteSensor.setIsDelete("1"); |
| | | deleteSensor.setIsDelete(Constants.DELETE); |
| | | sensorMapper.update(deleteSensor,wrapper); |
| | | QueryWrapper<VersionSensorUnit> wrapper_Version = new QueryWrapper<>(); |
| | | wrapper_Version.eq("sensor_id",sensor.getId()); |
| | | wrapper_Version.eq("is_delete","0"); |
| | | VersionSensorUnit versionSensorUnit = new VersionSensorUnit(); |
| | | versionSensorUnit.setIsDelete(Constants.DELETE); |
| | | versionSensorUnitMapper.update(versionSensorUnit,wrapper_Version); |
| | | //操作插入日志 |
| | | HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); |
| | | String content = "删除因子:"+sensor.getName()+";"; |
| | |
| | | resultMap.put("msg",ResponseCodeEnum.SUCCESS.getMsg()); |
| | | //刷新缓存 |
| | | refreshCache(); |
| | | //注销token |
| | | TokenUtils.destoryToken(Integer.parseInt(map.get("id").toString())); |
| | | return resultMap; |
| | | } |
| | | |
| | |
| | | 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(); |
| | |
| | | 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); |
| | | sensorMap.put("default_unit_key",sysDictDataMapper.selectOne(wrapper_VSU).getDataValue()); |
| | | } |
| | | sensorList.add(sensorMap); |
| | | } |
| | | resultMap.put("manageRoles",sensorList); |
| | | resultMap.put("sensors",sensorList); |
| | | resultMap.put("totalNumber",totleNum); |
| | | resultMap.put("current",current); |
| | | int totalPageNumber = totleNum/size; |
| | |
| | | public Map<String,Sensor> getAllSensorFromCache(){ |
| | | Map<String,Sensor> sensors = redisTemplate.opsForHash().entries(RedisConstants.SENSOR_KEY); |
| | | if(ObjectUtils.isEmpty(sensors)) |
| | | return getAllSensorFromDB(); |
| | | sensors = getAllSensorFromDB(); |
| | | //刷新缓存 |
| | | refreshCache(sensors); |
| | | return sensors; |
| | | } |
| | | |
| | |
| | | for (Sensor sensor : sensors) { |
| | | result.put(sensor.getCode(),sensor); |
| | | } |
| | | //刷新缓存 |
| | | refreshCache(result); |
| | | return result; |
| | | } |
| | | |