| | |
|---|
| | | logger.debug("设备通道信息同步API调用，deviceId：" + deviceId); |
|---|
| | | } |
|---|
| | | Device device = storager.queryVideoDevice(deviceId); |
|---|
| | | SyncStatus syncStatus = deviceService.getChannelSyncStatus(deviceId); |
|---|
| | | boolean status = deviceService.isSyncRunning(deviceId); |
|---|
| | | // 已存在则返回进度 |
|---|
| | | if (syncStatus != null && syncStatus.getErrorMsg() == null) { |
|---|
| | | if (status) { |
|---|
| | | WVPResult<SyncStatus> wvpResult = new WVPResult<>(); |
|---|
| | | wvpResult.setCode(0); |
|---|
| | | wvpResult.setData(syncStatus); |
|---|
| | | SyncStatus channelSyncStatus = deviceService.getChannelSyncStatus(deviceId); |
|---|
| | | wvpResult.setData(channelSyncStatus); |
|---|
| | | return wvpResult; |
|---|
| | | } |
|---|
| | | SyncStatus syncStatusReady = new SyncStatus(); |
|---|
| | | deviceService.setChannelSyncReady(deviceId); |
|---|
| | | cmder.catalogQuery(device, event -> { |
|---|
| | | String errorMsg = String.format("同步通道失败，错误码： %s, %s", event.statusCode, event.msg); |
|---|
| | | deviceService.setChannelSyncEnd(deviceId, errorMsg); |
|---|
| | | }); |
|---|
| | | deviceService.sync(device); |
|---|
| | | |
|---|
| | | WVPResult<SyncStatus> wvpResult = new WVPResult<>(); |
|---|
| | | wvpResult.setCode(0); |
|---|
| | | wvpResult.setMsg("开始同步"); |
|---|
| | |
|---|
| | | @ApiImplicitParam(name="page", value = "当前页", required = true, dataTypeClass = Integer.class), |
|---|
| | | @ApiImplicitParam(name="count", value = "每页条数", required = true, dataTypeClass = Integer.class), |
|---|
| | | @ApiImplicitParam(name="query", value = "查询内容", dataTypeClass = String.class), |
|---|
| | | @ApiImplicitParam(name="online", value = "是否在线", dataTypeClass = String.class), |
|---|
| | | @ApiImplicitParam(name="online", value = "是否在线", dataTypeClass = Boolean.class), |
|---|
| | | @ApiImplicitParam(name="channelType", value = "通道类型， 子目录", dataTypeClass = Boolean.class), |
|---|
| | | }) |
|---|
| | | @GetMapping("/sub_channels/{deviceId}/{channelId}/channels") |
|---|
| | |
|---|
| | | int page, |
|---|
| | | int count, |
|---|
| | | @RequestParam(required = false) String query, |
|---|
| | | @RequestParam(required = false) String online, |
|---|
| | | @RequestParam(required = false) Boolean online, |
|---|
| | | @RequestParam(required = false) Boolean channelType){ |
|---|
| | | |
|---|
| | | // if (logger.isDebugEnabled()) { |
|---|
