diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/impl/HumidDeviceServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/impl/HumidDeviceServiceImpl.java index 8a78108..634ee98 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/impl/HumidDeviceServiceImpl.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/impl/HumidDeviceServiceImpl.java @@ -55,15 +55,16 @@ public class HumidDeviceServiceImpl extends ServiceImpl findPage(Page page, HumidDevice humidDevice){ - return baseMapper.findPage(page,humidDevice); + + public IPage findPage(Page page, HumidDevice humidDevice) { + return baseMapper.findPage(page, humidDevice); } /** * 添加 */ @Override - public Result insertDevice(HumidDevice humidDevice){ + public Result insertDevice(HumidDevice humidDevice) { Map params = new HashMap<>(); params.put("sn", humidDevice.getSn()); params.put("timeCode", humidDevice.getTimeCode()); @@ -71,54 +72,56 @@ public class HumidDeviceServiceImpl extends ServiceImpl params = getParmas(0,100,humidDevice); - return updateDeviceConfigs(params,humidDevice,type); + public String updateDeviceParameters(HumidDevice humidDevice, String type) { + Map params = getParmas(0, 100, humidDevice); + return updateDeviceConfigs(params, humidDevice, type); } /** * 获取接口请求参数 + * * @param page * @param limit * @param humidDevice * @return */ - private Map getParmas(int page,int limit,HumidDevice humidDevice){ + private Map getParmas(int page, int limit, HumidDevice humidDevice) { Map params = new HashMap<>(); params.put("rows", limit); params.put("page", page); - if(humidDevice.getSn()!=null&&!humidDevice.getSn().equals("")){ + if (humidDevice.getSn() != null && !humidDevice.getSn().equals("")) { params.put("sn", humidDevice.getSn()); } return params; @@ -126,24 +129,25 @@ public class HumidDeviceServiceImpl extends ServiceImpl map,HumidDevice humidDevice,String type){ + private String updateDeviceConfigs(Map map, HumidDevice humidDevice, String type) { String errorMsg = ""; String responseStr = yiweilianApi.getDeviceConfigs(map); JSONObject jsonObject = new JSONObject(responseStr); Integer responseCode = jsonObject.getInt("code"); - if(responseCode.equals(0)){ + if (responseCode.equals(0)) { JSONObject dataObj = jsonObject.getJSONObject("data"); Integer count = dataObj.getInt("count"); Integer limit = dataObj.getInt("rows"); Integer page = dataObj.getInt("page"); JSONArray dataArr = dataObj.getJSONArray("dataList"); - for(int i=0;i params = getParmas(page+1,limit,humidDevice); - errorMsg += updateDeviceConfigs(params,humidDevice,type); + if ((page + 1) * limit < count) { + Map params = getParmas(page + 1, limit, humidDevice); + errorMsg += updateDeviceConfigs(params, humidDevice, type); } - }else{ + } else { errorMsg = jsonObject.getStr("msg"); } return errorMsg; @@ -199,26 +203,29 @@ public class HumidDeviceServiceImpl extends ServiceImpl params = getRealTimeParmas(0,50,humidDevice); - return updateDeviceRealTimeData(params,humidDevice); + public String updateDeviceRealTime(HumidDevice humidDevice) { + Map params = getRealTimeParmas(0, 50, humidDevice); + return updateDeviceRealTimeData(params, humidDevice); } + /** * 获取实时数据接口请求参数 + * * @param page * @param limit * @param humidDevice * @return */ - private Map getRealTimeParmas(int page,int limit,HumidDevice humidDevice){ + private Map getRealTimeParmas(int page, int limit, HumidDevice humidDevice) { Map params = new HashMap<>(); params.put("rows", limit); params.put("page", page); - if(humidDevice.getSn()!=null&&!humidDevice.getSn().equals("")){ + if (humidDevice.getSn() != null && !humidDevice.getSn().equals("")) { String[] str = new String[1]; str[0] = humidDevice.getSn(); params.put("snList", str); @@ -228,25 +235,26 @@ public class HumidDeviceServiceImpl extends ServiceImpl map,HumidDevice humidDevice){ + private String updateDeviceRealTimeData(Map map, HumidDevice humidDevice) { String errorMsg = ""; String responseStr = yiweilianApi.getRealTime(map); JSONObject jsonObject = new JSONObject(responseStr); Integer responseCode = jsonObject.getInt("code"); - if(responseCode.equals(0)){ + if (responseCode.equals(0)) { JSONObject dataObj = jsonObject.getJSONObject("data"); Integer count = dataObj.getInt("count"); Integer limit = dataObj.getInt("rows"); Integer page = dataObj.getInt("page"); JSONArray dataArr = dataObj.getJSONArray("dataList"); - if(dataArr.size()>0){ - for(int i=0;i 0) { + for (int i = 0; i < dataArr.size(); i++) { HumidDevice dh = new HumidDevice(); - JSONObject json = (JSONObject)dataArr.get(i); + JSONObject json = (JSONObject) dataArr.get(i); String sn = json.getStr("sn"); String status = json.getStr("status"); String electricity = json.getStr("electricity"); @@ -254,11 +262,16 @@ public class HumidDeviceServiceImpl extends ServiceImpl params = getParmas(page+1,limit,humidDevice); - errorMsg += updateDeviceRealTimeData(params,humidDevice); + if ((page + 1) * limit < count) { + Map params = getParmas(page + 1, limit, humidDevice); + errorMsg += updateDeviceRealTimeData(params, humidDevice); } - }else{ + } else { errorMsg = jsonObject.getStr("msg"); } return errorMsg; @@ -305,11 +318,12 @@ public class HumidDeviceServiceImpl extends ServiceImpl getUpdateParmas(HumidDevice humidDevice){ + private Map getUpdateParmas(HumidDevice humidDevice) { Map params = new HashMap<>(); params.put("sn", humidDevice.getSn()); params.put("timeCode", humidDevice.getTimeCode()); @@ -353,30 +367,31 @@ public class HumidDeviceServiceImpl extends ServiceImpl updateDevice(HumidDevice humidDevice){ + public Result updateDevice(HumidDevice humidDevice) { Map params = getUpdateParmas(humidDevice); String responseStr = yiweilianApi.updateDeviceConfig(params); JSONObject jsonObject = new JSONObject(responseStr); Integer responseCode = jsonObject.getInt("code"); - if(responseCode.equals(0)){ + if (responseCode.equals(0)) { baseMapper.updateDevice(humidDevice); humidDevice.setOptType("update"); LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); humidDevice.setOptBy(sysUser.getUsername()); baseMapper.insertLog(humidDevice); return Result.OK("修改成功"); - }else{ - String error = "修改失败:"+jsonObject.getStr("msg"); + } else { + String error = "修改失败:" + jsonObject.getStr("msg"); return Result.error(error); } } /** * 更新温湿度值 + * * @param humidDevice */ @Override - public void updateValue(HumidDevice humidDevice){ + public void updateValue(HumidDevice humidDevice) { baseMapper.updateValue(humidDevice); } @@ -384,7 +399,7 @@ public class HumidDeviceServiceImpl extends ServiceImpl delFlagDevice(HumidDevice humidDevice){ + public Result delFlagDevice(HumidDevice humidDevice) { // Map params = new HashMap<>(); // params.put("sn", humidDevice.getSn()); // String responseStr = yiweilianApi.deleteDevice(params); @@ -392,18 +407,18 @@ public class HumidDeviceServiceImpl extends ServiceImpl params = getParmas(0,1,humidDevice); + Map params = getParmas(0, 1, humidDevice); HumidDevice deviceParameters = getDeviceConfigs(params); - if(deviceParameters!=null){ + if (deviceParameters != null) { return Result.OK(deviceParameters); - }else{ + } else { return Result.error("温湿度设备丢失获取配置错误,请联系管理员"); // return Result.error("获取设备配置参数错误"); } @@ -430,20 +445,21 @@ public class HumidDeviceServiceImpl extends ServiceImpl map){ + private HumidDevice getDeviceConfigs(Map map) { HumidDevice dh = new HumidDevice(); String responseStr = yiweilianApi.getDeviceConfigs(map); JSONObject jsonObject = new JSONObject(responseStr); Integer responseCode = jsonObject.getInt("code"); - if(responseCode.equals(0)){ + if (responseCode.equals(0)) { JSONObject dataObj = jsonObject.getJSONObject("data"); JSONArray dataArr = dataObj.getJSONArray("dataList"); - if(dataArr.size()>0){ - for(int i=0;i 0) { + for (int i = 0; i < dataArr.size(); i++) { + JSONObject json = (JSONObject) dataArr.get(i); String sn = json.getStr("sn"); String deviceName = json.getStr("deviceName"); String deviceTypes = json.getStr("deviceTypes"); @@ -481,17 +497,17 @@ public class HumidDeviceServiceImpl extends ServiceImpl findLogPage(Page page, HumidDevice humidDevice){ - return baseMapper.findLogPage(page,humidDevice); + public IPage findLogPage(Page page, HumidDevice humidDevice) { + return baseMapper.findLogPage(page, humidDevice); } @Override @@ -499,12 +515,12 @@ public class HumidDeviceServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("nu_id",nuId); - List allList =baseMapper.selectList(queryWrapper); + queryWrapper.eq("nu_id", nuId); + List allList = baseMapper.selectList(queryWrapper); //先清空掉原来的数据 - for(HumidDevice cameraInfo : allList){ + for (HumidDevice cameraInfo : allList) { baseMapper.updateDepartById(cameraInfo); } - List> list = (List>) humidList.get("list"); + List> list = (List>) humidList.get("list"); for (Map map : list) { HumidDevice humidInfo = new HumidDevice(); String iotId = map.get("id").toString(); - if(StringUtils.isEmpty(iotId)){ + if (StringUtils.isEmpty(iotId)) { return "2";//设备ID为空; } humidInfo = baseMapper.selectById(iotId); String oldNuId = humidInfo.getNuId(); //判断如果新的机构和老的机构不相同则把老的机构删除 String oldDataSourceCode = (String) map.get("oldServerUrl"); - if(!StringUtils.equals(oldDataSourceCode,dataSourceCode) && StringUtils.isNotBlank(oldDataSourceCode)){ - syncImpl.syncElectricityDel(humidInfo.getOldServerUrl(),humidInfo); + if (!StringUtils.equals(oldDataSourceCode, dataSourceCode) && StringUtils.isNotBlank(oldDataSourceCode)) { + syncImpl.syncElectricityDel(humidInfo.getOldServerUrl(), humidInfo); SyncLog nuIotTqElectricitySyncLogDel = new SyncLog(); nuIotTqElectricitySyncLogDel.setId(null); @@ -633,7 +649,7 @@ public class HumidDeviceServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("sn",humidDevice.getSn()); + queryWrapper.eq("sn", humidDevice.getSn()); HumidDevice oldParam = baseMapper.selectOne(queryWrapper);//查询数据库中该表号数据原始数据 - if(oldParam == null){ + if (oldParam == null) { baseMapper.insert(humidDevice); - }else{ + } else { baseMapper.updateById(humidDevice); } } catch (Exception e) { @@ -695,39 +711,40 @@ public class HumidDeviceServiceImpl extends ServiceImpl findSourcePage(Page page, HumidDevice humidDevice){ - return baseMapper.findSourcePage(page,humidDevice); + public IPage findSourcePage(Page page, HumidDevice humidDevice) { + return baseMapper.findSourcePage(page, humidDevice); } @Override - public List findDepartList(HumidDevice humidDevice){ + public List findDepartList(HumidDevice humidDevice) { return baseMapper.findDepartList(humidDevice); } @Override - public List findNuList(HumidDevice humidDevice){ + public List findNuList(HumidDevice humidDevice) { return baseMapper.findNuList(humidDevice); } @Override - public IPage findBusinessPage(Page page, HumidDevice humidDevice){ - return baseMapper.findBusinessPage(page,humidDevice); + public IPage findBusinessPage(Page page, HumidDevice humidDevice) { + return baseMapper.findBusinessPage(page, humidDevice); } /** * 以设备维度同步温湿度到业务 + * * @param list * @return */ @Override - public String syncDevices(List list){ + public String syncDevices(List list) { for (HumidDevice humidDevice : list) { HumidDevice humidInfo = baseMapper.getHumidInfo(humidDevice); String actionType = humidDevice.getActionType();//操作类型 - if(actionType.equals("添加")){ + if (actionType.equals("添加")) { String orgCode = humidDevice.getOrgCode(); - if(!StringUtils.isNotBlank(orgCode)){ + if (!StringUtils.isNotBlank(orgCode)) { return "1"; } humidInfo.setSyncType("1"); @@ -740,7 +757,7 @@ public class HumidDeviceServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("sn",humidDevice.getSn()); + queryWrapper.eq("sn", humidDevice.getSn()); HumidDevice oldParam = baseMapper.selectOne(queryWrapper);//查询数据库中该表号数据原始数据 - if(type.equals("更新")){ - if(oldParam == null){ + if (type.equals("更新")) { + if (oldParam == null) { baseMapper.insert(humidDevice); - }else{ + } else { humidDevice.setId(oldParam.getId()); baseMapper.updateById(humidDevice); } } - if(type.equals("删除")){ + if (type.equals("删除")) { baseMapper.deleteById(oldParam); } } catch (Exception e) { @@ -959,10 +976,10 @@ public class HumidDeviceServiceImpl extends ServiceImpl findSyncLogPage(Page page, HumidDevice humidDevice){ - IPage mainPage = baseMapper.findSyncLogMainPage(page,humidDevice); + public IPage findSyncLogPage(Page page, HumidDevice humidDevice) { + IPage mainPage = baseMapper.findSyncLogMainPage(page, humidDevice); List records = mainPage.getRecords(); - for(int i=0;i seedList = baseMapper.findSyncLogSeedList(record); record.setSeedList(seedList); @@ -971,8 +988,8 @@ public class HumidDeviceServiceImpl extends ServiceImpl findNuSyncPage(Page page, HumidDevice humidDevice){ - return baseMapper.findNuSyncPage(page,humidDevice); + public IPage findNuSyncPage(Page page, HumidDevice humidDevice) { + return baseMapper.findNuSyncPage(page, humidDevice); } @Override @@ -983,10 +1000,11 @@ public class HumidDeviceServiceImpl extends ServiceImpl