wulin/qiuguo-iot
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

去掉调用算法语音合成

Browse Source
This commit is contained in:
wulin 2023-10-19 15:54:26 +08:00
parent cc48575963
commit 487b1dc823
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
iot-modules/iot-box-websocket-api/src/main/java/com/qiuguo/iot/box/websocket/api/handler/BaseWebSocketProcess.java
View File

@ -709,22 +709,25 @@ public class BaseWebSocketProcess {
}
private void sendMsg(BaseSession baseSession, BaseMessageResp baseMessageResp) {
String msg = JSONObject.toJSONString(baseMessageResp);
log.info("推到终端：{},SN:{},userId:{}，消息内容：{}", baseSession.getSessionType(), baseSession.getSn(), baseSession.getUserId(), msg);
if(this instanceof BoxWebSocketHandler){
sendMsg(baseSession, JSONObject.toJSONString(baseMessageResp));
/* if(this instanceof BoxWebSocketHandler){
audioService.getAudioUrl(baseMessageResp.getText()).map(s ->{
log.info("音频地址：{}", s);
BoxMessageResp boxMessageResp = new BoxMessageResp();
BeanUtils.copyProperties(baseMessageResp, boxMessageResp);
boxMessageResp.setAudio(s);
baseSession.getSink().next(baseSession.getSession().textMessage(JSONObject.toJSONString(boxMessageResp)));
sendMsg(baseSession, JSONObject.toJSONString(boxMessageResp));
return s;
}).subscribe();
}).subscribeOn(Schedulers.single()).subscribe();
}else{
baseSession.getSink().next(baseSession.getSession().textMessage(msg));
}
sendMsg(baseSession, JSONObject.toJSONString(baseMessageResp));
}*/
}
private void sendMsg(BaseSession baseSession, String msg) {
log.info("推到终端：{},SN:{},userId:{}，消息内容：{}", baseSession.getSessionType(), baseSession.getSn(), baseSession.getUserId(), msg);
baseSession.getSink().next(baseSession.getSession().textMessage(msg));
}
public BoxSession getBoxSessionWithSn(String sn) {