完善websocket推送消息数据的数据结构

liurunyu

2025-02-13 3f3402576acd33ad6d43899888684958c19533ea

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/msCenter/CenterMsReceiveCtrl.java

@@ -1,10 +1,12 @@
package com.dy.pipIrrRemote.msCenter;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.dy.common.contant.Constant;
import com.dy.common.multiDataSource.DataSourceContext;
import com.dy.common.util.NumUtil;
import com.dy.common.webUtil.BaseResponse;
import com.dy.common.webUtil.WebSocketMessage;
import com.dy.pipIrrRemote.largeScreen.WebSocketServer;
import io.swagger.v3.oas.annotations.Hidden;
import io.swagger.v3.oas.annotations.tags.Tag;
@@ -64,14 +66,25 @@
                            jo.put("intakeNum", intakeNum) ;
                        }
                    }
                    try {
                        WebSocketServer.sendAllMessage(jo.toJSONString());
                    }catch (Exception e){
                        log.error("推送消息失败", e) ;
                    }
                }
            }
            sendByWebSocket(list) ;
        }
        return null ;
    }

    /**
     * 推送消息
     * @param list
     */
    private void sendByWebSocket(List<JSONObject> list){
        WebSocketMessage vo = new WebSocketMessage() ;
        vo.type = WebSocketMessage.TYPE_JSON ;
        vo.content = list ;
        try {
            WebSocketServer.sendAllMessage(JSON.toJSONString(vo));
        }catch (Exception e){
            log.error("推送消息失败", e) ;
        }
    }
}