diff --git a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java index 7ad49ba..c4d1ee7 100644 --- a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java +++ b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java @@ -29,4 +29,12 @@ String TASK_UNSTART= "0"; //任务已完成 String TASK_COMPLETE = "2"; + + + //设备在线 + String STATUS_ONLINE = "1"; + //设备离线 + String STATUS_OFFLINE= "0"; + //设备报警 + String STATUS_ALARM = "2"; } diff --git a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java index 7ad49ba..c4d1ee7 100644 --- a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java +++ b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java @@ -29,4 +29,12 @@ String TASK_UNSTART= "0"; //任务已完成 String TASK_COMPLETE = "2"; + + + //设备在线 + String STATUS_ONLINE = "1"; + //设备离线 + String STATUS_OFFLINE= "0"; + //设备报警 + String STATUS_ALARM = "2"; } diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java index 1b3401d..6d7361c 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java @@ -1291,18 +1291,19 @@ handleGasData(deviceInfo, String.valueOf(chars)); } else { int flag = ires[3]; - if (flag == 0x93) { - // 云台节点地址配置add 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device config 93-->").concat(String.valueOf(ires[4]))); - } else if (flag == 0x97) { - // 云台复位配置 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device reset 97--->").concat(String.valueOf(ires[4]))); - } else if (flag == 0x94) { - // 云台风险点角度配置 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device angle 94--->").concat(String.valueOf(ires[4]))); - } else { - logger.info(deviceInfo.getDeviceIp().concat(" get device msg--->").concat(Arrays.toString(ires))); - } +// if (flag == 0x93) { +// // 云台节点地址配置add 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device config 93-->").concat(String.valueOf(ires[4]))); +// } else if (flag == 0x97) { +// // 云台复位配置 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device reset 97--->").concat(String.valueOf(ires[4]))); +// } else if (flag == 0x94) { +// // 云台风险点角度配置 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device angle 94--->").concat(String.valueOf(ires[4]))); +// } +// else { +// logger.info(deviceInfo.getDeviceIp().concat(" get device msg--->").concat(Arrays.toString(ires))); +// } // if (flag == 0x59) { // // 水平角度 // handleHorizontalAngle(deviceInfo, ires); @@ -1537,6 +1538,8 @@ threshold, Double.valueOf(dataGas.getDirection()), Double.valueOf(dataGas.getPitch()), StatusEnum.ALARM_ON, monitorBaseInfo.getLineNum()); alarmRecordService.save(alarmRecord); + //更新设备状态为报警 +// monipoiInfoService.updateStatus(dataGas) //推送前端 JSONObject msg = new JSONObject(); msg.put("type", "gasAlarm"); diff --git a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java index 7ad49ba..c4d1ee7 100644 --- a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java +++ b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java @@ -29,4 +29,12 @@ String TASK_UNSTART= "0"; //任务已完成 String TASK_COMPLETE = "2"; + + + //设备在线 + String STATUS_ONLINE = "1"; + //设备离线 + String STATUS_OFFLINE= "0"; + //设备报警 + String STATUS_ALARM = "2"; } diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java index 1b3401d..6d7361c 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java @@ -1291,18 +1291,19 @@ handleGasData(deviceInfo, String.valueOf(chars)); } else { int flag = ires[3]; - if (flag == 0x93) { - // 云台节点地址配置add 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device config 93-->").concat(String.valueOf(ires[4]))); - } else if (flag == 0x97) { - // 云台复位配置 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device reset 97--->").concat(String.valueOf(ires[4]))); - } else if (flag == 0x94) { - // 云台风险点角度配置 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device angle 94--->").concat(String.valueOf(ires[4]))); - } else { - logger.info(deviceInfo.getDeviceIp().concat(" get device msg--->").concat(Arrays.toString(ires))); - } +// if (flag == 0x93) { +// // 云台节点地址配置add 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device config 93-->").concat(String.valueOf(ires[4]))); +// } else if (flag == 0x97) { +// // 云台复位配置 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device reset 97--->").concat(String.valueOf(ires[4]))); +// } else if (flag == 0x94) { +// // 云台风险点角度配置 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device angle 94--->").concat(String.valueOf(ires[4]))); +// } +// else { +// logger.info(deviceInfo.getDeviceIp().concat(" get device msg--->").concat(Arrays.toString(ires))); +// } // if (flag == 0x59) { // // 水平角度 // handleHorizontalAngle(deviceInfo, ires); @@ -1537,6 +1538,8 @@ threshold, Double.valueOf(dataGas.getDirection()), Double.valueOf(dataGas.getPitch()), StatusEnum.ALARM_ON, monitorBaseInfo.getLineNum()); alarmRecordService.save(alarmRecord); + //更新设备状态为报警 +// monipoiInfoService.updateStatus(dataGas) //推送前端 JSONObject msg = new JSONObject(); msg.put("type", "gasAlarm"); diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java b/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java index 145cdab..3082500 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java @@ -2,6 +2,7 @@ import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.casic.missiles.enums.StatusEnum; import com.casic.missiles.modular.system.dto.DeviceCommom; import com.casic.missiles.modular.system.dto.DeviceInfo; import com.casic.missiles.modular.system.model.BusMonipoiInfo; @@ -94,7 +95,8 @@ } private Map map = new HashMap<>(); - + //默认离线 + boolean deviceStatus = false; private void sendGasCommand() { DeviceInfo deviceInfo = DeviceCommom.selectByDeviceIp(this.deviceIp); Long serial = deviceInfo.getSerialHandle(); @@ -113,17 +115,26 @@ hcNetService.setTimestampCollcect(System.currentTimeMillis()); boolean res = ihcNetService.serialSend(serial, pointer, size); -// System.out.println("collect**************"+new Date()); + if (!res) { //判断是否掉线，断电重启规则 若同一云台300次（5分钟）获取不到甲烷浓度值，则重启设备 //是否配置重启 if (isOpen == 1) { if (map.get(this.deviceIp) != null) { map.put(this.deviceIp, map.get(this.deviceIp) + 1); - if (map.get(this.deviceIp) == 300L) { + if (map.get(this.deviceIp) % 300L == 0) { + //若在线，更新设备离线 + if (deviceStatus) { + if (monipoiInfoService.updateStatus(this.deviceIp, StatusEnum.STATUS_OFFLINE)) { + deviceStatus = false; + } + } + logger.error(deviceIp.concat("door is opening! ********************* ")); if (ihcNetService.interruptStart(this.deviceIp)) { map.remove(this.deviceIp); logger.error(deviceIp.concat("restart success ********************* ")); + } else { + logger.error(deviceIp.concat("door start fail ********************* ")); } } } else { @@ -132,6 +143,14 @@ } logger.error(deviceIp.concat("fetch gas data error, error code: ").concat(String.valueOf(ihcNetService.getLastError()))); } + else { + //若离线， 更新成在线 + if(!deviceStatus){ + if (monipoiInfoService.updateStatus(this.deviceIp, StatusEnum.STATUS_ONLINE)) { + deviceStatus = true; + } + } + } } @Override diff --git a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java index 7ad49ba..c4d1ee7 100644 --- a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java +++ b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java @@ -29,4 +29,12 @@ String TASK_UNSTART= "0"; //任务已完成 String TASK_COMPLETE = "2"; + + + //设备在线 + String STATUS_ONLINE = "1"; + //设备离线 + String STATUS_OFFLINE= "0"; + //设备报警 + String STATUS_ALARM = "2"; } diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java index 1b3401d..6d7361c 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java @@ -1291,18 +1291,19 @@ handleGasData(deviceInfo, String.valueOf(chars)); } else { int flag = ires[3]; - if (flag == 0x93) { - // 云台节点地址配置add 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device config 93-->").concat(String.valueOf(ires[4]))); - } else if (flag == 0x97) { - // 云台复位配置 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device reset 97--->").concat(String.valueOf(ires[4]))); - } else if (flag == 0x94) { - // 云台风险点角度配置 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device angle 94--->").concat(String.valueOf(ires[4]))); - } else { - logger.info(deviceInfo.getDeviceIp().concat(" get device msg--->").concat(Arrays.toString(ires))); - } +// if (flag == 0x93) { +// // 云台节点地址配置add 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device config 93-->").concat(String.valueOf(ires[4]))); +// } else if (flag == 0x97) { +// // 云台复位配置 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device reset 97--->").concat(String.valueOf(ires[4]))); +// } else if (flag == 0x94) { +// // 云台风险点角度配置 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device angle 94--->").concat(String.valueOf(ires[4]))); +// } +// else { +// logger.info(deviceInfo.getDeviceIp().concat(" get device msg--->").concat(Arrays.toString(ires))); +// } // if (flag == 0x59) { // // 水平角度 // handleHorizontalAngle(deviceInfo, ires); @@ -1537,6 +1538,8 @@ threshold, Double.valueOf(dataGas.getDirection()), Double.valueOf(dataGas.getPitch()), StatusEnum.ALARM_ON, monitorBaseInfo.getLineNum()); alarmRecordService.save(alarmRecord); + //更新设备状态为报警 +// monipoiInfoService.updateStatus(dataGas) //推送前端 JSONObject msg = new JSONObject(); msg.put("type", "gasAlarm"); diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java b/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java index 145cdab..3082500 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java @@ -2,6 +2,7 @@ import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.casic.missiles.enums.StatusEnum; import com.casic.missiles.modular.system.dto.DeviceCommom; import com.casic.missiles.modular.system.dto.DeviceInfo; import com.casic.missiles.modular.system.model.BusMonipoiInfo; @@ -94,7 +95,8 @@ } private Map map = new HashMap<>(); - + //默认离线 + boolean deviceStatus = false; private void sendGasCommand() { DeviceInfo deviceInfo = DeviceCommom.selectByDeviceIp(this.deviceIp); Long serial = deviceInfo.getSerialHandle(); @@ -113,17 +115,26 @@ hcNetService.setTimestampCollcect(System.currentTimeMillis()); boolean res = ihcNetService.serialSend(serial, pointer, size); -// System.out.println("collect**************"+new Date()); + if (!res) { //判断是否掉线，断电重启规则 若同一云台300次（5分钟）获取不到甲烷浓度值，则重启设备 //是否配置重启 if (isOpen == 1) { if (map.get(this.deviceIp) != null) { map.put(this.deviceIp, map.get(this.deviceIp) + 1); - if (map.get(this.deviceIp) == 300L) { + if (map.get(this.deviceIp) % 300L == 0) { + //若在线，更新设备离线 + if (deviceStatus) { + if (monipoiInfoService.updateStatus(this.deviceIp, StatusEnum.STATUS_OFFLINE)) { + deviceStatus = false; + } + } + logger.error(deviceIp.concat("door is opening! ********************* ")); if (ihcNetService.interruptStart(this.deviceIp)) { map.remove(this.deviceIp); logger.error(deviceIp.concat("restart success ********************* ")); + } else { + logger.error(deviceIp.concat("door start fail ********************* ")); } } } else { @@ -132,6 +143,14 @@ } logger.error(deviceIp.concat("fetch gas data error, error code: ").concat(String.valueOf(ihcNetService.getLastError()))); } + else { + //若离线， 更新成在线 + if(!deviceStatus){ + if (monipoiInfoService.updateStatus(this.deviceIp, StatusEnum.STATUS_ONLINE)) { + deviceStatus = true; + } + } + } } @Override diff --git a/casic-station/src/main/java/com/casic/missiles/modular/system/service/IBusMonipoiInfoService.java b/casic-station/src/main/java/com/casic/missiles/modular/system/service/IBusMonipoiInfoService.java index f2a35bb..da4bf5e 100644 --- a/casic-station/src/main/java/com/casic/missiles/modular/system/service/IBusMonipoiInfoService.java +++ b/casic-station/src/main/java/com/casic/missiles/modular/system/service/IBusMonipoiInfoService.java @@ -40,4 +40,5 @@ void updateBusMonipoiInfo(String deviceIp,int lineNum); + boolean updateStatus(String deviceIp,String status); } diff --git a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java index 7ad49ba..c4d1ee7 100644 --- a/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java +++ b/casic-common/src/main/java/com/casic/missiles/enums/StatusEnum.java @@ -29,4 +29,12 @@ String TASK_UNSTART= "0"; //任务已完成 String TASK_COMPLETE = "2"; + + + //设备在线 + String STATUS_ONLINE = "1"; + //设备离线 + String STATUS_OFFLINE= "0"; + //设备报警 + String STATUS_ALARM = "2"; } diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java index 1b3401d..6d7361c 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/service/impl/HCNetServiceImpl.java @@ -1291,18 +1291,19 @@ handleGasData(deviceInfo, String.valueOf(chars)); } else { int flag = ires[3]; - if (flag == 0x93) { - // 云台节点地址配置add 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device config 93-->").concat(String.valueOf(ires[4]))); - } else if (flag == 0x97) { - // 云台复位配置 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device reset 97--->").concat(String.valueOf(ires[4]))); - } else if (flag == 0x94) { - // 云台风险点角度配置 应答 - logger.info(deviceInfo.getDeviceIp().concat(" get device angle 94--->").concat(String.valueOf(ires[4]))); - } else { - logger.info(deviceInfo.getDeviceIp().concat(" get device msg--->").concat(Arrays.toString(ires))); - } +// if (flag == 0x93) { +// // 云台节点地址配置add 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device config 93-->").concat(String.valueOf(ires[4]))); +// } else if (flag == 0x97) { +// // 云台复位配置 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device reset 97--->").concat(String.valueOf(ires[4]))); +// } else if (flag == 0x94) { +// // 云台风险点角度配置 应答 +// logger.info(deviceInfo.getDeviceIp().concat(" get device angle 94--->").concat(String.valueOf(ires[4]))); +// } +// else { +// logger.info(deviceInfo.getDeviceIp().concat(" get device msg--->").concat(Arrays.toString(ires))); +// } // if (flag == 0x59) { // // 水平角度 // handleHorizontalAngle(deviceInfo, ires); @@ -1537,6 +1538,8 @@ threshold, Double.valueOf(dataGas.getDirection()), Double.valueOf(dataGas.getPitch()), StatusEnum.ALARM_ON, monitorBaseInfo.getLineNum()); alarmRecordService.save(alarmRecord); + //更新设备状态为报警 +// monipoiInfoService.updateStatus(dataGas) //推送前端 JSONObject msg = new JSONObject(); msg.put("type", "gasAlarm"); diff --git a/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java b/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java index 145cdab..3082500 100644 --- a/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java +++ b/casic-server/src/main/java/com/casic/missiles/modular/system/task/CollectGasDataTask.java @@ -2,6 +2,7 @@ import cn.hutool.core.util.ObjectUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.casic.missiles.enums.StatusEnum; import com.casic.missiles.modular.system.dto.DeviceCommom; import com.casic.missiles.modular.system.dto.DeviceInfo; import com.casic.missiles.modular.system.model.BusMonipoiInfo; @@ -94,7 +95,8 @@ } private Map map = new HashMap<>(); - + //默认离线 + boolean deviceStatus = false; private void sendGasCommand() { DeviceInfo deviceInfo = DeviceCommom.selectByDeviceIp(this.deviceIp); Long serial = deviceInfo.getSerialHandle(); @@ -113,17 +115,26 @@ hcNetService.setTimestampCollcect(System.currentTimeMillis()); boolean res = ihcNetService.serialSend(serial, pointer, size); -// System.out.println("collect**************"+new Date()); + if (!res) { //判断是否掉线，断电重启规则 若同一云台300次（5分钟）获取不到甲烷浓度值，则重启设备 //是否配置重启 if (isOpen == 1) { if (map.get(this.deviceIp) != null) { map.put(this.deviceIp, map.get(this.deviceIp) + 1); - if (map.get(this.deviceIp) == 300L) { + if (map.get(this.deviceIp) % 300L == 0) { + //若在线，更新设备离线 + if (deviceStatus) { + if (monipoiInfoService.updateStatus(this.deviceIp, StatusEnum.STATUS_OFFLINE)) { + deviceStatus = false; + } + } + logger.error(deviceIp.concat("door is opening! ********************* ")); if (ihcNetService.interruptStart(this.deviceIp)) { map.remove(this.deviceIp); logger.error(deviceIp.concat("restart success ********************* ")); + } else { + logger.error(deviceIp.concat("door start fail ********************* ")); } } } else { @@ -132,6 +143,14 @@ } logger.error(deviceIp.concat("fetch gas data error, error code: ").concat(String.valueOf(ihcNetService.getLastError()))); } + else { + //若离线， 更新成在线 + if(!deviceStatus){ + if (monipoiInfoService.updateStatus(this.deviceIp, StatusEnum.STATUS_ONLINE)) { + deviceStatus = true; + } + } + } } @Override diff --git a/casic-station/src/main/java/com/casic/missiles/modular/system/service/IBusMonipoiInfoService.java b/casic-station/src/main/java/com/casic/missiles/modular/system/service/IBusMonipoiInfoService.java index f2a35bb..da4bf5e 100644 --- a/casic-station/src/main/java/com/casic/missiles/modular/system/service/IBusMonipoiInfoService.java +++ b/casic-station/src/main/java/com/casic/missiles/modular/system/service/IBusMonipoiInfoService.java @@ -40,4 +40,5 @@ void updateBusMonipoiInfo(String deviceIp,int lineNum); + boolean updateStatus(String deviceIp,String status); } diff --git a/casic-station/src/main/java/com/casic/missiles/modular/system/service/impl/BusMonipoiInfoServiceImpl.java b/casic-station/src/main/java/com/casic/missiles/modular/system/service/impl/BusMonipoiInfoServiceImpl.java index 1e15b8a..245902d 100644 --- a/casic-station/src/main/java/com/casic/missiles/modular/system/service/impl/BusMonipoiInfoServiceImpl.java +++ b/casic-station/src/main/java/com/casic/missiles/modular/system/service/impl/BusMonipoiInfoServiceImpl.java @@ -7,6 +7,7 @@ import com.casic.missiles.core.application.context.AbstractPermissionContext; import com.casic.missiles.core.datascope.DataScope; import com.casic.missiles.enums.BusinessExceptionEnum; +import com.casic.missiles.enums.StatusEnum; import com.casic.missiles.exception.BusinessException; import com.casic.missiles.model.response.ResponseData; import com.casic.missiles.modular.system.dto.monitor.MonitorBaseInfo; @@ -112,8 +113,8 @@ @Override public void updateBusMonipoiInfo(String deviceIp, int lineNum) { - BusMonipoiInfo busMonipoiInfo=selectByDeviceIp(deviceIp); - if(null!=busMonipoiInfo){ + BusMonipoiInfo busMonipoiInfo = selectByDeviceIp(deviceIp); + if (null != busMonipoiInfo) { busMonipoiInfo.setLineNum(lineNum); this.baseMapper.updateById(busMonipoiInfo); } @@ -131,4 +132,15 @@ return monitorOverviewMaps; } + @Override + public boolean updateStatus(String deviceIp, String status) { + BusMonipoiInfo busMonipoiInfo = selectByDeviceIp(deviceIp); + if (null != busMonipoiInfo) { + busMonipoiInfo.setDeviceStatus(status); + if(this.baseMapper.updateById(busMonipoiInfo)>0){ + return true; + } + } + return false; + } }