package com.ard.gb28181.api;
|
|
import com.ard.common.core.constant.Constants;
|
import com.ard.common.core.constant.SecurityConstants;
|
import com.ard.common.core.domain.R;
|
import com.ard.common.core.domain.RtpServerParam;
|
import com.ard.common.core.exception.ServiceException;
|
import com.ard.gb28181.api.domain.*;
|
import com.ard.gb28181.config.UserSetting;
|
import com.ard.gb28181.domain.GbChannel;
|
import com.ard.gb28181.domain.GbDevice;
|
import com.ard.gb28181.service.IDeviceService;
|
import com.ard.gb28181.service.IGbChannelService;
|
import com.ard.gb28181.service.IGbDeviceService;
|
import com.ard.gb28181.service.ISIPCommander;
|
import com.ard.gb28181.session.SipInviteSessionManager;
|
import com.ard.zlm.api.RemoteZlmService;
|
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Parameter;
|
import io.swagger.v3.oas.annotations.security.SecurityRequirement;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.util.Assert;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.context.request.async.DeferredResult;
|
|
import javax.sip.ResponseEvent;
|
import java.util.ArrayList;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Set;
|
import java.util.concurrent.CompletableFuture;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* gb28181 Controller
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/api/gb28181")
|
public class Gb28181ApiController {
|
|
@Autowired
|
private IDeviceService deviceService;
|
|
@Autowired
|
private ISIPCommander sipCommander;
|
|
@Autowired
|
private UserSetting userSetting;
|
|
@Autowired
|
private SipInviteSessionManager sessionManager;
|
|
@Autowired
|
private RemoteZlmService remoteZlmService;
|
|
@Autowired
|
private IGbDeviceService gbDeviceService;
|
|
@Autowired
|
private IGbChannelService gbChannelService;
|
|
/**
|
* 根据设备id获取设备
|
*
|
* @param gbDeviceId
|
* @return
|
*/
|
@GetMapping("/getDeviceByDeviceId/{gbDeviceId}")
|
R<Device> getDeviceByDeviceId(@PathVariable String gbDeviceId) {
|
return R.ok(deviceService.getDeviceByDeviceId(gbDeviceId));
|
}
|
|
/**
|
* 请求预览视频流
|
*
|
* @param rtpServer
|
* @return
|
*/
|
@PostMapping("/playStreamCmd")
|
R<Boolean> playStreamCmd(@RequestBody RtpServerParam rtpServer) throws Exception {
|
Device device = deviceService.getDeviceByDeviceId(rtpServer.getGbDeviceId());
|
|
if (device == null) {
|
throw new RuntimeException("国标设备不存在 deviceId:" + rtpServer.getGbDeviceId());
|
}
|
CompletableFuture<R<Boolean>> future = new CompletableFuture<>();
|
|
try {
|
sipCommander.playStreamCmd(device, rtpServer, (eventResult) -> {
|
ResponseEvent responseEvent = (ResponseEvent) eventResult.event;
|
String contentString = new String(responseEvent.getResponse().getRawContent());
|
|
if (device.getStreamMode().equalsIgnoreCase("TCP-ACTIVE")) {
|
String substring = contentString.indexOf("y=") > 0
|
? contentString.substring(0, contentString.indexOf("y="))
|
: contentString;
|
|
log.info("[TCP主动连接对方] deviceId: {}, channelId: {}, 连接对方的地址", rtpServer.getGbDeviceId(), rtpServer.getGbChannelId());
|
R<Boolean> r = remoteZlmService.connectRtpServer(rtpServer.getMediaServerId(), "", 0, rtpServer.getStream(), SecurityConstants.INNER);
|
|
if (r.getCode() != Constants.SUCCESS) {
|
sessionManager.removeByStream(rtpServer.getApp(), rtpServer.getStream());
|
remoteZlmService.releaseSsrc(rtpServer.getMediaServerId(), rtpServer.getSsrc(), SecurityConstants.INNER);
|
remoteZlmService.closeRTPServer(rtpServer.getMediaServerId(), rtpServer, SecurityConstants.INNER);
|
future.complete(R.ok(false, "[TCP主动连接对方] deviceId:" + rtpServer.getGbDeviceId() + ", channelId:" + rtpServer.getGbChannelId()));
|
return;
|
}
|
|
Boolean result = r.getData();
|
log.info("[TCP主动连接对方] 结果: {}", result);
|
if (!result) {
|
sessionManager.removeByStream(rtpServer.getApp(), rtpServer.getStream());
|
remoteZlmService.releaseSsrc(rtpServer.getMediaServerId(), rtpServer.getSsrc(), SecurityConstants.INNER);
|
remoteZlmService.closeRTPServer(rtpServer.getMediaServerId(), rtpServer, SecurityConstants.INNER);
|
future.complete(R.ok(false, "[TCP主动连接对方] deviceId:" + rtpServer.getGbDeviceId() + ", channelId:" + rtpServer.getGbChannelId()));
|
}
|
}
|
|
future.complete(R.ok(true, "国标28181请求预览视频流成功"));
|
}, (event) -> {
|
sessionManager.removeByStream(rtpServer.getApp(), rtpServer.getStream());
|
remoteZlmService.releaseSsrc(rtpServer.getMediaServerId(), rtpServer.getSsrc(), SecurityConstants.INNER);
|
remoteZlmService.closeRTPServer(rtpServer.getMediaServerId(), rtpServer, SecurityConstants.INNER);
|
future.complete(R.fail("国标28181请求预览视频流失败"));
|
}, userSetting.getPlayTimeout().longValue());
|
} catch (Exception e) {
|
log.error("发送国标播放sip错误 deviceId:{}", rtpServer.getGbDeviceId(), e);
|
future.complete(R.fail(false, "国标28181请求预览视频流失败"));
|
remoteZlmService.releaseSsrc(rtpServer.getMediaServerId(), rtpServer.getSsrc(), SecurityConstants.INNER);
|
remoteZlmService.closeRTPServer(rtpServer.getMediaServerId(), rtpServer, SecurityConstants.INNER);
|
sessionManager.removeByStream(rtpServer.getApp(), rtpServer.getStream());
|
}
|
|
try {
|
return future.get(userSetting.getPlayTimeout().longValue(), TimeUnit.SECONDS);
|
} catch (Exception e) {
|
log.error("等待播放响应超时或出错 deviceId:{}", rtpServer.getGbDeviceId(), e);
|
remoteZlmService.releaseSsrc(rtpServer.getMediaServerId(), rtpServer.getSsrc(), SecurityConstants.INNER);
|
remoteZlmService.closeRTPServer(rtpServer.getMediaServerId(), rtpServer, SecurityConstants.INNER);
|
sessionManager.removeByStream(rtpServer.getApp(), rtpServer.getStream());
|
return R.fail(false, "国标28181请求预览视频流超时或出错");
|
}
|
}
|
|
/**
|
* 根据设备id和通道获取设备通道
|
*
|
* @param gbDeviceId
|
* @param gbChannelId
|
* @return
|
*/
|
@GetMapping("/getDeviceChannelByChannelId/{gbDeviceId}/{gbChannelId}")
|
R<DeviceChannel> getDeviceChannelByChannelId(@PathVariable String gbDeviceId, @PathVariable String gbChannelId) {
|
Device device = deviceService.getDeviceByDeviceId(gbDeviceId);
|
if (device == null) {
|
return R.fail("gb28181 设备不存在 deviceId:" + gbDeviceId);
|
}
|
|
DeviceChannel deviceChannel = deviceService.getDeviceChannelByChannelId(gbDeviceId, gbChannelId);
|
|
return R.ok(deviceChannel);
|
}
|
|
/**
|
* 停止视频流
|
*
|
* @param rtpServer
|
* @return
|
*/
|
@PostMapping("/streamByeCmd")
|
R<Void> streamByeCmd(@RequestBody RtpServerParam rtpServer) {
|
Device device = deviceService.getDeviceByDeviceId(rtpServer.getGbDeviceId());
|
|
if (device == null) {
|
return R.fail("gb28181 设备不存在 deviceId:" + rtpServer.getGbDeviceId());
|
}
|
|
try {
|
sipCommander.stopStreamCmd(device, rtpServer);
|
return R.ok();
|
} catch (Exception e) {
|
log.error("停止播放失败 deviceId:" + rtpServer.getGbDeviceId(), e);
|
return R.fail("停止播放失败:" + e.getMessage());
|
}
|
}
|
|
/**
|
* 获取全部设备
|
*
|
* @return
|
*/
|
@GetMapping("/getAllDevices")
|
R<List<Device>> getAllDevices() {
|
return R.ok(deviceService.getAllDevices());
|
}
|
|
/**
|
* 通用前端控制命令(参考国标文档A.3.1指令格式)
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param cmdCode 指令码(对应国标文档指令格式中的字节4)
|
* @param parameter1 数据一(对应国标文档指令格式中的字节5, 范围0-255)
|
* @param parameter2 数据二(对应国标文档指令格式中的字节6, 范围0-255)
|
* @param combindCode2 组合码二(对应国标文档指令格式中的字节7, 范围0-15)
|
*/
|
@GetMapping("/common/ptz/{deviceId}/{channelId}")
|
public void frontEndCommand(@PathVariable String deviceId, @PathVariable String channelId, Integer cmdCode, Integer parameter1, Integer parameter2, Integer combindCode2) {
|
|
if (log.isDebugEnabled()) {
|
log.debug(String.format("设备云台控制 API调用，deviceId：%s ，channelId：%s ，cmdCode：%d parameter1：%d parameter2：%d", deviceId, channelId, cmdCode, parameter1, parameter2));
|
}
|
|
if (parameter1 == null || parameter1 < 0 || parameter1 > 255) {
|
throw new ServiceException("parameter1 为 0-255的数字");
|
}
|
if (parameter2 == null || parameter2 < 0 || parameter2 > 255) {
|
throw new ServiceException("parameter2 为 0-255的数字");
|
}
|
if (combindCode2 == null || combindCode2 < 0 || combindCode2 > 15) {
|
throw new ServiceException("combindCode2 为 0-15的数字");
|
}
|
|
Device device = deviceService.getDeviceByDeviceId(deviceId);
|
|
Assert.notNull(device, "设备[" + deviceId + "]不存在");
|
|
deviceService.frontEndCommand(device, channelId, cmdCode, parameter1, parameter2, combindCode2);
|
}
|
|
/**
|
* 云台控制
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param command 控制指令,允许值: left, right, up, down, upleft, upright, downleft, downright, zoomin, zoomout, stop
|
* @param horizonSpeed 水平速度(0-255)
|
* @param verticalSpeed 垂直速度(0-255)
|
* @param zoomSpeed 缩放速度(0-15)
|
*/
|
@GetMapping("/ptz/{deviceId}/{channelId}")
|
public void ptz(@PathVariable String deviceId, @PathVariable String channelId, String command, Integer horizonSpeed, Integer verticalSpeed, Integer zoomSpeed) {
|
if (log.isDebugEnabled()) {
|
log.debug(String.format("设备云台控制 API调用，deviceId：%s ，channelId：%s ，command：%s ，horizonSpeed：%d ，verticalSpeed：%d ，zoomSpeed：%d", deviceId, channelId, command, horizonSpeed, verticalSpeed, zoomSpeed));
|
}
|
if (horizonSpeed == null) {
|
horizonSpeed = 100;
|
} else if (horizonSpeed < 0 || horizonSpeed > 255) {
|
throw new ServiceException("horizonSpeed 为 0-255的数字");
|
}
|
if (verticalSpeed == null) {
|
verticalSpeed = 100;
|
} else if (verticalSpeed < 0 || verticalSpeed > 255) {
|
throw new ServiceException("verticalSpeed 为 0-255的数字");
|
}
|
if (zoomSpeed == null) {
|
zoomSpeed = 16;
|
} else if (zoomSpeed < 0 || zoomSpeed > 15) {
|
throw new ServiceException("zoomSpeed 为 0-15的数字");
|
}
|
|
int cmdCode = 0;
|
switch (command) {
|
case "left":
|
cmdCode = 2;
|
break;
|
case "right":
|
cmdCode = 1;
|
break;
|
case "up":
|
cmdCode = 8;
|
break;
|
case "down":
|
cmdCode = 4;
|
break;
|
case "upleft":
|
cmdCode = 10;
|
break;
|
case "upright":
|
cmdCode = 9;
|
break;
|
case "downleft":
|
cmdCode = 6;
|
break;
|
case "downright":
|
cmdCode = 5;
|
break;
|
case "zoomin":
|
cmdCode = 16;
|
break;
|
case "zoomout":
|
cmdCode = 32;
|
break;
|
case "stop":
|
horizonSpeed = 0;
|
verticalSpeed = 0;
|
zoomSpeed = 0;
|
break;
|
default:
|
break;
|
}
|
frontEndCommand(deviceId, channelId, cmdCode, horizonSpeed, verticalSpeed, zoomSpeed);
|
}
|
|
/**
|
* 光圈控制
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param command 控制指令,允许值: in, out, stop
|
* @param speed 光圈速度(0-255)
|
*/
|
@GetMapping("/fi/iris/{deviceId}/{channelId}")
|
public void iris(@PathVariable String deviceId, @PathVariable String channelId, String command, Integer speed) {
|
|
if (log.isDebugEnabled()) {
|
log.debug("设备光圈控制 API调用，deviceId：{} ，channelId：{} ，command：{} ，speed：{} ", deviceId, channelId, command, speed);
|
}
|
|
if (speed == null) {
|
speed = 100;
|
} else if (speed < 0 || speed > 255) {
|
throw new ServiceException("speed 为 0-255的数字");
|
}
|
|
int cmdCode = 0x40;
|
switch (command) {
|
case "in":
|
cmdCode = 0x44;
|
break;
|
case "out":
|
cmdCode = 0x48;
|
break;
|
case "stop":
|
speed = 0;
|
break;
|
default:
|
break;
|
}
|
frontEndCommand(deviceId, channelId, cmdCode, 0, speed, 0);
|
}
|
|
/**
|
* 聚焦控制
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param command 控制指令,允许值: near, far, stop
|
* @param speed 聚焦速度(0-255)
|
*/
|
@GetMapping("/fi/focus/{deviceId}/{channelId}")
|
public void focus(@PathVariable String deviceId, @PathVariable String channelId, String command, Integer speed) {
|
|
if (log.isDebugEnabled()) {
|
log.debug("设备聚焦控制 API调用，deviceId：{} ，channelId：{} ，command：{} ，speed：{} ", deviceId, channelId, command, speed);
|
}
|
|
if (speed == null) {
|
speed = 100;
|
} else if (speed < 0 || speed > 255) {
|
throw new ServiceException("speed 为 0-255的数字");
|
}
|
|
int cmdCode = 0x40;
|
switch (command) {
|
case "near":
|
cmdCode = 0x42;
|
break;
|
case "far":
|
cmdCode = 0x41;
|
break;
|
case "stop":
|
speed = 0;
|
break;
|
default:
|
break;
|
}
|
frontEndCommand(deviceId, channelId, cmdCode, speed, 0, 0);
|
}
|
|
/**
|
* 查询预置位
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @return
|
*/
|
@GetMapping("/preset/query/{deviceId}/{channelId}")
|
public DeferredResult<R<Object>> queryPreset(@PathVariable String deviceId, @PathVariable String channelId) {
|
if (log.isDebugEnabled()) {
|
log.debug("设备预置位查询API调用");
|
}
|
Device device = deviceService.getDeviceByDeviceId(deviceId);
|
Assert.notNull(device, "设备不存在");
|
DeferredResult<R<Object>> deferredResult = new DeferredResult<>(3 * 1000L);
|
deviceService.queryPreset(device, channelId, (code, msg, data) -> {
|
deferredResult.setResult(R.ok(data));
|
});
|
|
deferredResult.onTimeout(() -> {
|
log.warn("[获取设备预置位] 超时, {}", device.getDeviceId());
|
deferredResult.setResult(R.fail("获取设备预置位超时"));
|
});
|
return deferredResult;
|
}
|
|
/**
|
* 预置位指令-设置预置位
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param presetId 预置位编号(1-255)
|
*/
|
@GetMapping("/preset/add/{deviceId}/{channelId}")
|
public void addPreset(@PathVariable String deviceId, @PathVariable String channelId, Integer presetId) {
|
if (presetId == null || presetId < 1 || presetId > 255) {
|
throw new ServiceException("预置位编号必须为1-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x81, 1, presetId, 0);
|
}
|
|
/**
|
* 预置位指令-调用预置位
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param presetId 预置位编号(1-255)
|
*/
|
@GetMapping("/preset/call/{deviceId}/{channelId}")
|
public void callPreset(@PathVariable String deviceId, @PathVariable String channelId, Integer presetId) {
|
if (presetId == null || presetId < 1 || presetId > 255) {
|
throw new ServiceException("预置位编号必须为1-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x82, 1, presetId, 0);
|
}
|
|
/**
|
* 预置位指令-删除预置位
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param presetId 预置位编号(1-255)
|
*/
|
@Parameter(name = "deviceId", description = "设备国标编号", required = true)
|
@Parameter(name = "channelId", description = "通道国标编号", required = true)
|
@Parameter(name = "presetId", description = "预置位编号(1-255)", required = true)
|
@GetMapping("/preset/delete/{deviceId}/{channelId}")
|
public void deletePreset(@PathVariable String deviceId, @PathVariable String channelId, Integer presetId) {
|
if (presetId == null || presetId < 1 || presetId > 255) {
|
throw new ServiceException("预置位编号必须为1-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x83, 1, presetId, 0);
|
}
|
|
/**
|
* 巡航指令-加入巡航点
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param cruiseId 巡航组号(0-255)
|
* @param presetId 预置位编号(1-255)
|
*/
|
@GetMapping("/cruise/point/add/{deviceId}/{channelId}")
|
public void addCruisePoint(@PathVariable String deviceId, @PathVariable String channelId, Integer cruiseId, Integer presetId) {
|
if (presetId == null || cruiseId == null || presetId < 1 || presetId > 255 || cruiseId < 0 || cruiseId > 255) {
|
throw new ServiceException("编号必须为1-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x84, cruiseId, presetId, 0);
|
}
|
|
/**
|
* 巡航指令-删除一个巡航点
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param cruiseId 巡航组号(1-255)
|
* @param presetId 预置位编号(0-255, 为0时删除整个巡航)
|
*/
|
@GetMapping("/cruise/point/delete/{deviceId}/{channelId}")
|
public void deleteCruisePoint(@PathVariable String deviceId, @PathVariable String channelId, Integer cruiseId, Integer presetId) {
|
if (presetId == null || presetId < 0 || presetId > 255) {
|
throw new ServiceException("预置位编号必须为0-255之间的数字, 为0时删除整个巡航");
|
}
|
if (cruiseId == null || cruiseId < 0 || cruiseId > 255) {
|
throw new ServiceException("巡航组号必须为0-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x85, cruiseId, presetId, 0);
|
}
|
|
/**
|
* 巡航指令-设置巡航速度
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param cruiseId 巡航组号(0-255)
|
* @param speed 巡航速度(1-4095)
|
*/
|
@GetMapping("/cruise/speed/{deviceId}/{channelId}")
|
public void setCruiseSpeed(@PathVariable String deviceId, @PathVariable String channelId, Integer cruiseId, Integer speed) {
|
if (cruiseId == null || cruiseId < 0 || cruiseId > 255) {
|
throw new ServiceException("巡航组号必须为0-255之间的数字");
|
}
|
if (speed == null || speed < 1 || speed > 4095) {
|
throw new ServiceException("巡航速度必须为1-4095之间的数字");
|
}
|
int parameter2 = speed & 0xFF;
|
int combindCode2 = speed >> 8;
|
frontEndCommand(deviceId, channelId, 0x86, cruiseId, parameter2, combindCode2);
|
}
|
|
/**
|
* 巡航指令-设置巡航停留时间
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param cruiseId 巡航组号
|
* @param time 巡航停留时间(1-4095)
|
*/
|
@GetMapping("/cruise/time/{deviceId}/{channelId}")
|
public void setCruiseTime(@PathVariable String deviceId, @PathVariable String channelId, Integer cruiseId, Integer time) {
|
if (cruiseId == null || cruiseId < 0 || cruiseId > 255) {
|
throw new ServiceException("巡航组号必须为0-255之间的数字");
|
}
|
if (time == null || time < 1 || time > 4095) {
|
throw new ServiceException("巡航停留时间必须为1-4095之间的数字");
|
}
|
int parameter2 = time & 0xFF;
|
int combindCode2 = time >> 8;
|
frontEndCommand(deviceId, channelId, 0x87, cruiseId, parameter2, combindCode2);
|
}
|
|
/**
|
* 巡航指令-开始巡航
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param cruiseId 巡航组号
|
*/
|
@GetMapping("/cruise/start/{deviceId}/{channelId}")
|
public void startCruise(@PathVariable String deviceId, @PathVariable String channelId, Integer cruiseId) {
|
if (cruiseId == null || cruiseId < 0 || cruiseId > 255) {
|
throw new ServiceException("巡航组号必须为0-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x88, cruiseId, 0, 0);
|
}
|
|
/**
|
* 巡航指令-停止巡航
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param cruiseId 巡航组号
|
*/
|
@GetMapping("/cruise/stop/{deviceId}/{channelId}")
|
public void stopCruise(@PathVariable String deviceId, @PathVariable String channelId, Integer cruiseId) {
|
if (cruiseId == null || cruiseId < 0 || cruiseId > 255) {
|
throw new ServiceException("巡航组号必须为0-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0, 0, 0, 0);
|
}
|
|
/**
|
* 扫描指令-开始自动扫描
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param scanId 扫描组号(0-255)
|
*/
|
@GetMapping("/scan/start/{deviceId}/{channelId}")
|
public void startScan(@PathVariable String deviceId, @PathVariable String channelId, Integer scanId) {
|
if (scanId == null || scanId < 0 || scanId > 255) {
|
throw new ServiceException("扫描组号必须为0-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x89, scanId, 0, 0);
|
}
|
|
/**
|
* 扫描指令-停止自动扫描
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param scanId 扫描组号(0-255)
|
*/
|
@GetMapping("/scan/stop/{deviceId}/{channelId}")
|
public void stopScan(@PathVariable String deviceId, @PathVariable String channelId, Integer scanId) {
|
if (scanId == null || scanId < 0 || scanId > 255) {
|
throw new ServiceException("扫描组号必须为0-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0, 0, 0, 0);
|
}
|
|
/**
|
* 扫描指令-设置自动扫描左边界
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param scanId 扫描组号(0-255)
|
*/
|
@GetMapping("/scan/set/left/{deviceId}/{channelId}")
|
public void setScanLeft(@PathVariable String deviceId, @PathVariable String channelId, Integer scanId) {
|
if (scanId == null || scanId < 0 || scanId > 255) {
|
throw new ServiceException("扫描组号必须为0-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x89, scanId, 1, 0);
|
}
|
|
/**
|
* 扫描指令-设置自动扫描右边界
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param scanId 扫描组号(0-255)
|
*/
|
@GetMapping("/scan/set/right/{deviceId}/{channelId}")
|
public void setScanRight(@PathVariable String deviceId, @PathVariable String channelId, Integer scanId) {
|
if (scanId == null || scanId < 0 || scanId > 255) {
|
throw new ServiceException("扫描组号必须为0-255之间的数字");
|
}
|
frontEndCommand(deviceId, channelId, 0x89, scanId, 2, 0);
|
}
|
|
/**
|
* 扫描指令-设置自动扫描速度
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param scanId 扫描组号(0-255)
|
* @param speed 自动扫描速度(1-4095)
|
*/
|
@GetMapping("/scan/set/speed/{deviceId}/{channelId}")
|
public void setScanSpeed(@PathVariable String deviceId, @PathVariable String channelId, Integer scanId, Integer speed) {
|
if (scanId == null || scanId < 0 || scanId > 255) {
|
throw new ServiceException("扫描组号必须为0-255之间的数字");
|
}
|
if (speed == null || speed < 1 || speed > 4095) {
|
throw new ServiceException("自动扫描速度必须为1-4095之间的数字");
|
}
|
int parameter2 = speed & 0xFF;
|
int combindCode2 = speed >> 8;
|
frontEndCommand(deviceId, channelId, 0x8A, scanId, parameter2, combindCode2);
|
}
|
|
/**
|
* 辅助开关控制指令-雨刷控制
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param command 控制指令,允许值: on, off
|
*/
|
@GetMapping("/wiper/{deviceId}/{channelId}")
|
public void wiper(@PathVariable String deviceId, @PathVariable String channelId, String command) {
|
|
if (log.isDebugEnabled()) {
|
log.debug("辅助开关控制指令-雨刷控制 API调用，deviceId：{} ，channelId：{} ，command：{}", deviceId, channelId, command);
|
}
|
|
int cmdCode = 0;
|
switch (command) {
|
case "on":
|
cmdCode = 0x8c;
|
break;
|
case "off":
|
cmdCode = 0x8d;
|
break;
|
default:
|
break;
|
}
|
frontEndCommand(deviceId, channelId, cmdCode, 1, 0, 0);
|
}
|
|
/**
|
* 辅助开关控制指令
|
*
|
* @param deviceId 设备国标编号
|
* @param channelId 通道国标编号
|
* @param command 控制指令,允许值: on, off
|
* @param switchId 开关编号
|
*/
|
@GetMapping("/auxiliary/{deviceId}/{channelId}")
|
public void auxiliarySwitch(@PathVariable String deviceId, @PathVariable String channelId, String command, Integer switchId) {
|
|
if (log.isDebugEnabled()) {
|
log.debug("辅助开关控制指令-雨刷控制 API调用，deviceId：{} ，channelId：{} ，command：{}, switchId: {}", deviceId, channelId, command, switchId);
|
}
|
|
int cmdCode = 0;
|
switch (command) {
|
case "on":
|
cmdCode = 0x8c;
|
break;
|
case "off":
|
cmdCode = 0x8d;
|
break;
|
default:
|
break;
|
}
|
frontEndCommand(deviceId, channelId, cmdCode, switchId, 0, 0);
|
}
|
|
// ==================== GbDevice / GbChannel 管理接口 ====================
|
|
/**
|
* 根据国标设备ID获取GbDevice
|
*/
|
@GetMapping("/getGbDevice/{gbDeviceId}")
|
public R<GbDeviceDTO> getGbDevice(@PathVariable String gbDeviceId) {
|
GbDevice gbDevice = gbDeviceService.selectGbDeviceByGbDeviceId(gbDeviceId);
|
if (gbDevice == null) {
|
return R.fail("GbDevice不存在 gbDeviceId:" + gbDeviceId);
|
}
|
return R.ok(toGbDeviceDTO(gbDevice));
|
}
|
|
/**
|
* 获取所有GbDevice列表
|
*/
|
@GetMapping("/getAllGbDevices")
|
public R<List<GbDeviceDTO>> getAllGbDevices() {
|
List<GbDevice> list = gbDeviceService.selectGbDeviceList(new GbDevice());
|
List<GbDeviceDTO> dtoList = new ArrayList<>();
|
for (GbDevice d : list) {
|
dtoList.add(toGbDeviceDTO(d));
|
}
|
return R.ok(dtoList);
|
}
|
|
/**
|
* 根据主键ID获取GbChannel
|
*/
|
@GetMapping("/getGbChannelById/{id}")
|
public R<GbChannelDTO> getGbChannelById(@PathVariable Long id) {
|
GbChannel gbChannel = gbChannelService.selectGbChannelById(id);
|
if (gbChannel == null) {
|
return R.fail("GbChannel不存在 id:" + id);
|
}
|
return R.ok(toGbChannelDTO(gbChannel));
|
}
|
|
/**
|
* 根据国标设备ID和通道ID获取GbChannel
|
*/
|
@GetMapping("/getGbChannel/{gbDeviceId}/{gbChannelId}")
|
public R<GbChannelDTO> getGbChannel(@PathVariable String gbDeviceId, @PathVariable String gbChannelId) {
|
GbChannel gbChannel = gbChannelService.selectByGbDeviceIdAndGbChannelId(gbDeviceId, gbChannelId);
|
if (gbChannel == null) {
|
return R.fail("GbChannel不存在 gbDeviceId:" + gbDeviceId + " gbChannelId:" + gbChannelId);
|
}
|
return R.ok(toGbChannelDTO(gbChannel));
|
}
|
|
/**
|
* 根据国标设备ID获取所有通道
|
*/
|
@GetMapping("/getGbChannelsByDeviceId/{gbDeviceId}")
|
public R<List<GbChannelDTO>> getGbChannelsByDeviceId(@PathVariable String gbDeviceId) {
|
List<GbChannel> list = gbChannelService.selectGbChannelByGbDeviceId(gbDeviceId);
|
List<GbChannelDTO> dtoList = new ArrayList<>();
|
for (GbChannel c : list) {
|
dtoList.add(toGbChannelDTO(c));
|
}
|
return R.ok(dtoList);
|
}
|
|
/**
|
* 更新GbChannel流状态
|
*/
|
@PostMapping("/updateGbChannelStream")
|
R<Boolean> updateGbChannelStream(@RequestBody GbChannelDTO dto) {
|
GbChannel gbChannel = new GbChannel();
|
gbChannel.setId(dto.getId());
|
gbChannel.setStreamStatus(dto.getStreamStatus());
|
gbChannel.setStreamKey(dto.getStreamKey());
|
gbChannel.setMediaServerId(dto.getMediaServerId());
|
gbChannel.setSnap(dto.getSnap());
|
gbChannelService.updateGbChannelStream(gbChannel);
|
return R.ok(true);
|
}
|
|
private GbDeviceDTO toGbDeviceDTO(GbDevice d) {
|
GbDeviceDTO dto = new GbDeviceDTO();
|
dto.setId(d.getId());
|
dto.setGbDeviceId(d.getGbDeviceId());
|
dto.setDeviceName(d.getDeviceName());
|
dto.setDeviceCode(d.getDeviceCode());
|
dto.setIp(d.getIp());
|
dto.setPort(d.getPort());
|
dto.setManufacturer(d.getManufacturer());
|
dto.setModel(d.getModel());
|
dto.setFirmware(d.getFirmware());
|
dto.setOnLine(d.getOnLine());
|
return dto;
|
}
|
|
private GbChannelDTO toGbChannelDTO(GbChannel c) {
|
GbChannelDTO dto = new GbChannelDTO();
|
dto.setId(c.getId());
|
dto.setGbDeviceId(c.getGbDeviceId());
|
dto.setGbChannelId(c.getGbChannelId());
|
dto.setChannelName(c.getChannelName());
|
dto.setDeviceCode(c.getDeviceCode());
|
dto.setStreamMode(c.getStreamMode());
|
dto.setEnableMp4(c.getEnableMp4());
|
dto.setStreamStatus(c.getStreamStatus());
|
dto.setMediaServerId(c.getMediaServerId());
|
dto.setStreamKey(c.getStreamKey());
|
dto.setSnap(c.getSnap());
|
return dto;
|
}
|
|
/**
|
* 一键迁移：将 Redis 中已注册的国标设备同步到 MySQL（供首次执行 SQL 后使用）
|
*/
|
@Operation(summary = "迁移Redis国标设备到MySQL")
|
@PostMapping("/migrateGbDevices")
|
public R<String> migrateGbDevices() {
|
List<Device> allDevices = deviceService.getAllDevices();
|
int deviceCount = 0;
|
int channelCount = 0;
|
|
for (Device device : allDevices) {
|
try {
|
// 创建设备记录
|
GbDevice existingDevice = gbDeviceService.selectGbDeviceByGbDeviceId(device.getDeviceId());
|
if (existingDevice == null) {
|
GbDevice gbDevice = new GbDevice();
|
gbDevice.setGbDeviceId(device.getDeviceId());
|
gbDevice.setDeviceName(StringUtils.hasText(device.getName()) ? device.getName() : device.getDeviceId());
|
gbDevice.setDeviceCode(device.getDeviceId());
|
gbDevice.setIp(device.getIp());
|
gbDevice.setPort(device.getPort());
|
gbDevice.setManufacturer(device.getManufacturer());
|
gbDevice.setModel(device.getModel());
|
gbDevice.setFirmware(device.getFirmware());
|
gbDevice.setOnLine(device.isOnLine());
|
gbDeviceService.insertGbDevice(gbDevice);
|
deviceCount++;
|
log.info("[迁移] 创建设备: {}", device.getDeviceId());
|
}
|
|
// 创建默认通道（设备自身）
|
GbChannel existingDefaultChannel = gbChannelService.selectByGbDeviceIdAndGbChannelId(
|
device.getDeviceId(), device.getDeviceId());
|
if (existingDefaultChannel == null) {
|
GbChannel gbChannel = new GbChannel();
|
gbChannel.setGbDeviceId(device.getDeviceId());
|
gbChannel.setGbChannelId(device.getDeviceId());
|
gbChannel.setChannelName(StringUtils.hasText(device.getName()) ? device.getName() : device.getDeviceId());
|
gbChannel.setDeviceCode(device.getDeviceId());
|
gbChannel.setStreamMode(device.getStreamMode() != null ? device.getStreamMode() : "TCP-PASSIVE");
|
gbChannel.setEnableMp4("0");
|
gbChannelService.insertGbChannel(gbChannel);
|
channelCount++;
|
}
|
|
// 创建所有通道
|
List<DeviceChannel> channels = deviceService.getChannelsByDeviceId(device.getDeviceId());
|
if (channels != null) {
|
for (DeviceChannel channel : channels) {
|
String channelId = channel.getDeviceId();
|
if (channelId == null || channelId.length() <= 8) {
|
continue;
|
}
|
if (channelId.length() == 20) {
|
try {
|
com.ard.gb28181.api.domain.GbCode gbCode = com.ard.gb28181.api.domain.GbCode.decode(channelId);
|
if (gbCode != null && ("215".equals(gbCode.getTypeCode()) || "216".equals(gbCode.getTypeCode()))) {
|
continue;
|
}
|
} catch (Exception ignored) {}
|
}
|
GbChannel existing = gbChannelService.selectByGbDeviceIdAndGbChannelId(device.getDeviceId(), channelId);
|
if (existing == null) {
|
GbChannel gbChannel = new GbChannel();
|
gbChannel.setGbDeviceId(device.getDeviceId());
|
gbChannel.setGbChannelId(channelId);
|
gbChannel.setChannelName(StringUtils.hasText(channel.getName()) ? channel.getName() : channelId);
|
gbChannel.setDeviceCode(channelId);
|
gbChannel.setStreamMode(device.getStreamMode() != null ? device.getStreamMode() : "TCP-PASSIVE");
|
gbChannel.setEnableMp4("0");
|
gbChannelService.insertGbChannel(gbChannel);
|
channelCount++;
|
}
|
}
|
}
|
} catch (Exception e) {
|
log.error("[迁移] 处理设备失败: {}", device.getDeviceId(), e);
|
}
|
}
|
|
return R.ok("迁移完成: 设备 " + deviceCount + " 条, 通道 " + channelCount + " 条");
|
}
|
|
/**
|
* 从 Redis 同步通道数据到 MySQL，使 ard_gb_channel 与 Redis 一致
|
*/
|
@Operation(summary = "从Redis同步通道到MySQL")
|
@PostMapping("/syncGbChannelsFromRedis")
|
public R<String> syncGbChannelsFromRedis() {
|
List<Device> allDevices = deviceService.getAllRedisDevices();
|
int createdCount = 0;
|
int deletedCount = 0;
|
int skippedCount = 0;
|
|
for (Device device : allDevices) {
|
try {
|
String deviceId = device.getDeviceId();
|
List<DeviceChannel> redisChannels = deviceService.getChannelsByDeviceId(deviceId);
|
if (redisChannels == null) {
|
redisChannels = new ArrayList<>();
|
}
|
|
Set<String> redisChannelIds = new HashSet<>();
|
boolean hasRealSubChannel = false;
|
|
for (DeviceChannel ch : redisChannels) {
|
String channelId = ch.getDeviceId();
|
if (channelId == null || channelId.length() <= 8) {
|
continue;
|
}
|
if (channelId.length() == 20) {
|
try {
|
GbCode gbCode = GbCode.decode(channelId);
|
if (gbCode != null && ("215".equals(gbCode.getTypeCode()) || "216".equals(gbCode.getTypeCode()))) {
|
continue;
|
}
|
} catch (Exception ignored) {}
|
}
|
redisChannelIds.add(channelId);
|
if (!channelId.equals(deviceId)) {
|
hasRealSubChannel = true;
|
}
|
|
GbChannel existing = gbChannelService.selectByGbDeviceIdAndGbChannelId(deviceId, channelId);
|
if (existing == null) {
|
GbChannel gbChannel = new GbChannel();
|
gbChannel.setGbDeviceId(deviceId);
|
gbChannel.setGbChannelId(channelId);
|
gbChannel.setChannelName(StringUtils.hasText(ch.getName()) ? ch.getName() : channelId);
|
gbChannel.setDeviceCode(channelId);
|
gbChannel.setStreamMode(device.getStreamMode() != null ? device.getStreamMode() : "TCP-PASSIVE");
|
gbChannel.setEnableMp4("0");
|
gbChannelService.insertGbChannel(gbChannel);
|
createdCount++;
|
log.info("[同步] 创建通道: deviceId={}, channelId={}", deviceId, channelId);
|
} else if (StringUtils.hasText(ch.getName())
|
&& !ch.getName().equals(existing.getChannelName())) {
|
existing.setChannelName(ch.getName());
|
gbChannelService.updateGbChannel(existing);
|
log.info("[同步] 更新通道名称: deviceId={}, channelId={}, {} -> {}",
|
deviceId, channelId, existing.getChannelName(), ch.getName());
|
}
|
}
|
|
List<GbChannel> mysqlChannels = gbChannelService.selectGbChannelByGbDeviceId(deviceId);
|
for (GbChannel mysqlCh : mysqlChannels) {
|
if (!redisChannelIds.contains(mysqlCh.getGbChannelId())) {
|
if ("1".equals(mysqlCh.getStreamStatus())) {
|
skippedCount++;
|
continue;
|
}
|
gbChannelService.deleteGbChannelById(mysqlCh.getId());
|
deletedCount++;
|
}
|
}
|
|
if (hasRealSubChannel) {
|
GbChannel defaultChannel = gbChannelService.selectByGbDeviceIdAndGbChannelId(deviceId, deviceId);
|
if (defaultChannel != null && !redisChannelIds.contains(deviceId)) {
|
if (!"1".equals(defaultChannel.getStreamStatus())) {
|
gbChannelService.deleteGbChannelById(defaultChannel.getId());
|
deletedCount++;
|
} else {
|
skippedCount++;
|
}
|
}
|
}
|
|
} catch (Exception e) {
|
log.error("[同步] 处理设备失败: {}", device.getDeviceId(), e);
|
}
|
}
|
|
return R.ok(String.format("同步完成: 创建 %d 条, 删除 %d 条, 跳过 %d 条(推流中)",
|
createdCount, deletedCount, skippedCount));
|
}
|
}
|
