| | |
| | | public ResponseResult getRealTimeLogs(String deviceSn, List<String> domainList) { |
| | | boolean exist = deviceRedisService.checkDeviceOnline(deviceSn); |
| | | if (!exist) { |
| | | return ResponseResult.error("Device is offline."); |
| | | return ResponseResult.error("设备离线"); |
| | | } |
| | | |
| | | ServiceReply<List<LogsFileUpload>> data = messageSenderService.publishServicesTopic( |
| | |
| | | |
| | | String logsId = this.insertDeviceLogs(bid, username, deviceSn, param); |
| | | if (!bid.equals(logsId)) { |
| | | return ResponseResult.error("Database insert failed."); |
| | | return ResponseResult.error("数据库插入失败"); |
| | | } |
| | | |
| | | // Save the status of the log upload. |
| | |
| | | public ResponseResult pushUpdateFile(String deviceSn, LogsFileUpdateParam param) { |
| | | LogsFileUpdateMethodEnum method = LogsFileUpdateMethodEnum.find(param.getStatus()); |
| | | if (LogsFileUpdateMethodEnum.UNKNOWN == method) { |
| | | return ResponseResult.error("Illegal param"); |
| | | return ResponseResult.error("非法参数"); |
| | | } |
| | | ServiceReply reply = messageSenderService.publishServicesTopic( |
| | | deviceSn, LogsFileMethodEnum.FILE_UPLOAD_UPDATE.getMethod(), param); |
| | | |
| | | if (ResponseResult.CODE_SUCCESS != reply.getResult()) { |
| | | return ResponseResult.error("Error Code : " + reply.getResult()); |
| | | return ResponseResult.error("错误码:" + reply.getResult()); |
| | | } |
| | | |
| | | return ResponseResult.success(); |