From 3a330c260072dd73c460431e24548e3cb2f98247 Mon Sep 17 00:00:00 2001 From: wulin Date: Wed, 18 Oct 2023 17:45:26 +0800 Subject: [PATCH] =?UTF-8?q?=E7=AE=97=E6=B3=95=E9=9F=B3=E9=A2=91=E5=90=88?= =?UTF-8?q?=E6=88=90=E8=B0=83=E7=94=A8=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../box/websocket/api/handler/BaseWebSocketProcess.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java b/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java index f03b892..3a0a6a6 100644 --- a/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java +++ b/iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java @@ -42,6 +42,7 @@ import org.hswebframework.web.api.crud.entity.PagerResult; import org.slf4j.MDC; import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.reactive.socket.WebSocketSession; import reactor.core.publisher.Mono; @@ -713,8 +714,10 @@ public class BaseWebSocketProcess { if(this instanceof BoxWebSocketHandler){ audioService.getAudioUrl(baseMessageResp.getText()).map(s ->{ log.info("音频地址：{}", s); - ((BoxMessageResp)baseMessageResp).setAudio(s); - baseSession.getSink().next(baseSession.getSession().textMessage(JSONObject.toJSONString(baseMessageResp))); + BoxMessageResp boxMessageResp = new BoxMessageResp(); + BeanUtils.copyProperties(baseMessageResp, boxMessageResp); + boxMessageResp.setAudio(s); + baseSession.getSink().next(baseSession.getSession().textMessage(JSONObject.toJSONString(boxMessageResp))); return s; }).subscribe(); }else{