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.Device;
|
import com.ard.gb28181.api.domain.DeviceChannel;
|
import com.ard.gb28181.config.UserSetting;
|
import com.ard.gb28181.service.IDeviceService;
|
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.web.bind.annotation.*;
|
import org.springframework.web.context.request.async.DeferredResult;
|
|
import javax.sip.ResponseEvent;
|
import java.util.List;
|
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;
|
|
/**
|
* 根据设备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);
|
}
|
}
|
