| | |
| | | String deviceSn = receiver.getGateway(); |
| | | if(method.equals("cover_close")){ |
| | | _deviceService.updateWorkType(deviceSn, 2L); |
| | | RedisOpsUtils.setWithExpire(RedisConst.OSD_STATUS_PREFIX + deviceSn, 2, RedisConst.DEVICE_ALIVE_SECOND); |
| | | } |
| | | String sn = RedisOpsUtils.get(key).toString(); |
| | | receiver.setType(MessageType.PROGRESS.getType()); |
| | | EventsReceiver<EventsOutputReceiver> eventsReceiver = mapper.convertValue(receiver.getData(), |
| | | new TypeReference<EventsReceiver<EventsOutputReceiver>>(){}); |
| | | eventsReceiver.setBid(receiver.getBid()); |
| | | eventsReceiver.setSn(sn); |
| | | eventsReceiver.setGateway(sn); |
| | | eventsReceiver.setType(MessageType.PROGRESS.getType()); |
| | | eventsReceiver.setMethod(receiver.getMethod()); |
| | | |
| | |
| | | // 更新设备列表状态--飞行器开机中... |
| | | if(method.equals("drone_open")){ |
| | | _deviceService.updateWorkType(device.getChildDeviceSn(), 7L); |
| | | RedisOpsUtils.setWithExpire(RedisConst.OSD_STATUS_PREFIX + device.getChildDeviceSn(), 7, RedisConst.DEVICE_ALIVE_SECOND); |
| | | } |
| | | |
| | | String dockProgress =""; |