微调
This commit is contained in:
@@ -60,7 +60,7 @@ public class CsDeviceController extends BaseController {
|
||||
@ApiOperation("直连设备注册")
|
||||
@ApiImplicitParam(name = "devAccessParam", value = "接入参数", required = true)
|
||||
public HttpResult<String> devAccess(@RequestBody @Validated DevAccessParam devAccessParam){
|
||||
String methodDescribe = getMethodDescribe("getModel");
|
||||
String methodDescribe = getMethodDescribe("devAccess");
|
||||
csDeviceService.devAccess(devAccessParam);
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
|
||||
}
|
||||
|
||||
@@ -298,6 +298,7 @@ public class MqttMessageHandler {
|
||||
if (Objects.equals(res.getCode(),AccessEnum.SUCCESS.getCode())){
|
||||
log.info("接入应答成功--->" + nDid);
|
||||
//修改装置状态
|
||||
csEquipmentDeliveryService.updateStatusBynDid(nDid,AccessEnum.ACCESS.getCode());
|
||||
csEquipmentDeliveryService.updateRunStatusBynDid(nDid,AccessEnum.ONLINE.getCode());
|
||||
} else {
|
||||
log.info(AccessResponseEnum.ACCESS_RESPONSE_ERROR.getMessage());
|
||||
|
||||
Reference in New Issue
Block a user