Merge remote-tracking branch 'origin/master'

This commit is contained in:
648540858
2024-10-23 09:58:14 +08:00
4 changed files with 6 additions and 7 deletions

View File

@@ -243,8 +243,6 @@ public class DeviceQuery {
}
@Operation(summary = "修改通道的码流类型", security = @SecurityRequirement(name = JwtUtils.HEADER))
@Parameter(name = "deviceId", description = "设备国标编号", required = true)
@Parameter(name = "channel", description = "通道信息", required = true)
@PostMapping("/channel/stream/identification/update/")
public void updateChannelStreamIdentification(DeviceChannel channel){
deviceChannelService.updateChannelStreamIdentification(channel);
@@ -469,7 +467,7 @@ public class DeviceQuery {
in.close();
outputStream.close();
} catch (IOException e) {
resp.setStatus(HttpServletResponse.SC_NOT_FOUND);
resp.setStatus(HttpServletResponse.SC_NO_CONTENT);
}
}

View File

@@ -327,7 +327,6 @@ public class DeviceChannelServiceImpl implements IDeviceChannelService {
@Override
public void updateChannelStreamIdentification(DeviceChannel channel) {
Assert.isTrue(channel.getId() > 0, "通道ID必须存在");
Assert.hasLength(channel.getStreamIdentification(), "码流标识必须存在");
if (ObjectUtils.isEmpty(channel.getStreamIdentification())) {
log.info("[重置通道码流类型] 设备: {}, 码流: {}", channel.getDeviceId(), channel.getStreamIdentification());

View File

@@ -84,6 +84,7 @@ public class CatalogResponseMessageHandler extends SIPRequestProcessorParent imp
}
@Scheduled(fixedDelay = 200)
@Transactional
public void executeTaskQueue(){
if (taskQueue.isEmpty()) {
return;