Merge remote-tracking branch 'origin/master'

zuoxiao

2025-06-25 d2fc819dc069c7b8d338ae52a90a7f38704fac08

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

@@ -1,21 +1,24 @@
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;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Iterator;
import java.util.List;

/**
@@ -25,15 +28,19 @@
 */

@Slf4j
@Tag(name = "通信中间消息中心推送消息接收方", description = "通信中间消息中心推送消息接收方")
@Hidden //不公开接口，其只有通信中间件调用
@Tag(name = "通信中间件消息中心推送消息接收者", description = "通信中间件消息中心推送消息接收者")
@RestController
@RequestMapping(path="msCenter")
public class CenterMsReceiveCtrl{

    @Autowired
    private CenterMsReceiveSv sv ;

    /**
     * 通信中间消息中心推送消息接收
     * @param list 消息集合
     * @return 操作结果
     * 通信中间件消息中心推送消息接收
     * @param list 消息数据集合
     * @return 无返回结果
     */
    @Hidden //不公开接口，其只有通信中间件调用
    @PostMapping(path = "receive", consumes = MediaType.APPLICATION_JSON_VALUE)
@@ -45,17 +52,40 @@
        if(list != null && list.size() > 0){
            for (JSONObject jo : list) {
                if(jo != null){
                    log.info("----------------start " + token + " 消息数据--------------") ;
                    Iterator<String> it = jo.keySet().iterator() ;
                    String key ;
                    while (it.hasNext()){
                        key = it.next() ;
                        log.info(key + "：" + jo.get(key));
                    if(jo.containsKey("intakeId")){
                        Object intakeIdObj = jo.get("intakeId") ;
                        Long intakeId = null ;
                        if(intakeIdObj != null && intakeIdObj instanceof Long){
                            intakeId = (Long) intakeIdObj ;
                        }else if(intakeIdObj != null && intakeIdObj instanceof String){
                            if(NumUtil.isPlusIntNumber(intakeIdObj.toString())){
                                intakeId = Long.parseLong(intakeIdObj.toString()) ;
                            }
                        }
                        if(intakeId != null){
                            String intakeNum = this.sv.selectIntakeName(intakeId) ;
                            jo.put("intakeNum", intakeNum) ;
                        }
                    }
                    log.info("----------------end " + token + " 消息数据--------------") ;
                }
            }
            sendByWebSocket(list) ;
        }
        return null ;
    }

    /**
     * 通过websocket把消息推送出去，当前接收方是前端的大屏展示模块
     * @param list
     */
    private void sendByWebSocket(List<JSONObject> list){
        WebSocketMessage vo = new WebSocketMessage() ;
        vo.type = WebSocketMessage.TYPE_JSON ;
        vo.content = list ;
        try {
            WebSocketServer.sendMessage2AllClient(JSON.toJSONString(vo));
        }catch (Exception e){
            log.error("推送消息失败", e) ;
        }
    }
}