package cn.iocoder.yudao.module.iot.gateway.protocol.coap.handler.upstream;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.lang.Assert;
|
import cn.hutool.extra.spring.SpringUtil;
|
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
import cn.iocoder.yudao.module.iot.core.biz.IotDeviceCommonApi;
|
import cn.iocoder.yudao.module.iot.core.biz.dto.IotSubDeviceRegisterFullReqDTO;
|
import cn.iocoder.yudao.module.iot.core.topic.auth.IotSubDeviceRegisterReqDTO;
|
import cn.iocoder.yudao.module.iot.core.topic.auth.IotSubDeviceRegisterRespDTO;
|
import lombok.Data;
|
import lombok.extern.slf4j.Slf4j;
|
import org.eclipse.californium.core.server.resources.CoapExchange;
|
|
import java.util.List;
|
|
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
|
|
/**
|
* IoT 网关 CoAP 协议的【子设备动态注册】处理器
|
* <p>
|
* 用于子设备的动态注册，需要网关认证
|
*
|
* @author 芋道源码
|
* @see <a href="https://help.aliyun.com/zh/iot/user-guide/register-devices">阿里云 - 动态注册子设备</a>
|
*/
|
@Slf4j
|
public class IotCoapRegisterSubHandler extends IotCoapAbstractHandler {
|
|
private final IotDeviceCommonApi deviceApi;
|
|
public IotCoapRegisterSubHandler() {
|
this.deviceApi = SpringUtil.getBean(IotDeviceCommonApi.class);
|
}
|
|
@Override
|
@SuppressWarnings("DuplicatedCode")
|
protected CommonResult<Object> handle0(CoapExchange exchange) {
|
// 1.1 解析通用参数（从 URI 路径获取网关设备信息）
|
List<String> uriPath = exchange.getRequestOptions().getUriPath();
|
String productKey = getProductKey(uriPath);
|
String deviceName = getDeviceName(uriPath);
|
// 1.2 解析子设备列表
|
SubDeviceRegisterRequest request = deserializeRequest(exchange, SubDeviceRegisterRequest.class);
|
Assert.notNull(request, "请求参数不能为空");
|
Assert.notEmpty(request.getParams(), "params 不能为空");
|
|
// 2. 调用子设备动态注册
|
IotSubDeviceRegisterFullReqDTO reqDTO = new IotSubDeviceRegisterFullReqDTO()
|
.setGatewayProductKey(productKey)
|
.setGatewayDeviceName(deviceName)
|
.setSubDevices(request.getParams());
|
CommonResult<List<IotSubDeviceRegisterRespDTO>> result = deviceApi.registerSubDevices(reqDTO);
|
result.checkError();
|
|
// 3. 返回结果
|
return success(result.getData());
|
}
|
|
@Override
|
protected boolean requiresAuthentication() {
|
return true;
|
}
|
|
@Override
|
protected String getProductKey(List<String> uriPath) {
|
// 路径格式：/auth/register/sub-device/{productKey}/{deviceName}
|
return CollUtil.get(uriPath, 3);
|
}
|
|
@Override
|
protected String getDeviceName(List<String> uriPath) {
|
// 路径格式：/auth/register/sub-device/{productKey}/{deviceName}
|
return CollUtil.get(uriPath, 4);
|
}
|
|
@Data
|
public static class SubDeviceRegisterRequest {
|
|
private List<IotSubDeviceRegisterReqDTO> params;
|
|
}
|
|
}
|
