|
|
@@ -87,19 +87,23 @@ public class SDKControlService extends AbstractControlService {
|
|
|
@Override
|
|
|
public TopicEventsResponse<MqttReply> drcStatusNotify(TopicEventsRequest<DrcStatusNotify> request, MessageHeaders headers) {
|
|
|
String dockSn = request.getGateway();
|
|
|
-
|
|
|
+ log.info("==============进入DRC链路状态通知,dockSn:" + dockSn);
|
|
|
Optional<DeviceDTO> deviceOpt = deviceRedisService.getDeviceOnline(dockSn);
|
|
|
if (deviceOpt.isEmpty()) {
|
|
|
+ log.info("===========DRC链路状态通知,dockSn:" + dockSn + ",设备不在线");
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
DrcStatusNotify eventsReceiver = request.getData();
|
|
|
if (DrcStatusErrorEnum.SUCCESS != eventsReceiver.getResult()) {
|
|
|
+ log.info("===========DRC链路状态通知,dockSn:" + dockSn + ",成功,通知前端");
|
|
|
webSocketMessageService.sendBatch(
|
|
|
deviceOpt.get().getWorkspaceId(), UserTypeEnum.WEB.getVal(), BizCodeEnum.DRC_STATUS_NOTIFY.getCode(),
|
|
|
ResultNotifyDTO.builder().sn(dockSn)
|
|
|
.message(eventsReceiver.getResult().getMessage())
|
|
|
.result(eventsReceiver.getResult().getCode()).build());
|
|
|
+ } else {
|
|
|
+ log.info("===========DRC链路状态通知,dockSn:" + dockSn + ",失败:" + eventsReceiver.getResult().getMessage());
|
|
|
}
|
|
|
return new TopicEventsResponse<MqttReply>().setData(MqttReply.success());
|
|
|
}
|