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{