diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/EquipmentDeliveryController.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/EquipmentDeliveryController.java index f259d58..458bce6 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/EquipmentDeliveryController.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/EquipmentDeliveryController.java @@ -107,6 +107,14 @@ public class EquipmentDeliveryController extends BaseController { public HttpResult updateEquipmentDelivery(@RequestBody @Validated CsEquipmentDeliveryAuditParm csEquipmentDeliveryAuditParm ){ String methodDescribe = getMethodDescribe("updateEquipmentDelivery"); Boolean flag = csEquipmentDeliveryService.updateEquipmentDelivery(csEquipmentDeliveryAuditParm); + if (flag){ + //查询mqtt用户名和密码是否存在 + boolean result = mqttUserService.findMqttUser(csEquipmentDeliveryAuditParm.getNdid()); + if (result){ + //初始化装置mqtt连接信息(使用sha256加密) + mqttUserService.insertMqttUser(csEquipmentDeliveryAuditParm.getNdid()); + } + } return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, flag, methodDescribe); }