修改websocket推送数据方式，指定钢化的查询不显示已出完玻璃

ZengTao

2024-07-24 9529d01b276743231d3cec48e5293a988c42bd35

修改websocket推送数据方式，指定钢化的查询不显示已出完玻璃

 UI-Project/config.js

@@ -1,7 +1,7 @@
export default {
 serverUrl: "10.153.19.150:88/api",
//  serverUrl: "192.168.1.199:88/api",
  serverUrl2: "10.153.19.150:88"
  // serverUrl2: "192.168.1.199:88"
//  serverUrl: "10.153.19.150:88/api",
 serverUrl: "192.168.1.199:88/api",
  // serverUrl2: "10.153.19.150:88"
  serverUrl2: "192.168.1.199:88"
  //serverUrl:"res.abeim.cn"
}

 UI-Project/src/utils/WebSocketService.js

@@ -1,7 +1,7 @@
// WebSocketService.js



let socket = null;

let messages = '';

let messages='' ;

export const initializeWebSocket = (socketUrl, messageHandler) => {

    if (typeof WebSocket === "undefined") {

      console.log("Your browser does not support WebSocket");

@@ -18,7 +18,6 @@
      if (!msg.data) {

        return;

      }

      
      const isLastChunk = msg.data.endsWith('<END>');

      //是否为最后一块消息

      messages += msg.data;


 UI-Project/src/utils/constants.js

@@ -1,3 +1,3 @@
// export const WebSocketHost = "192.168.1.199";
export const WebSocketHost = "10.153.19.150";
export const WebSocketHost = "192.168.1.199";
// export const WebSocketHost = "10.153.19.150";
export const host = "88";

 UI-Project/src/views/Returns/returns.vue

@@ -594,11 +594,11 @@
    console.error('WebSocket连接异常关闭');  
  }  
};  
  
// 监听WebSocket的消息事件  
ws.onmessage = (event) => {  
  try {  
    const data = JSON.parse(event.data); // 解析消息为JSON  
    
    const data = JSON.parse(event.data.replace('<END>', '')); // 解析消息为JSON  
  
    if (data && Array.isArray(data.InkageStatus) && data.InkageStatus.length > 0) {  
if(data.InkageStatus!=null){
@@ -610,7 +610,7 @@
}
    } else {  
      // 处理错误情况或无效数据  
      console.error('接收到的数据无效', data);  
      // console.error('接收到的数据无效', data);  
    }  
  } catch (error) {  
    console.error('解析WebSocket消息时发生错误', error);  

 hangzhoumesParent/common/servicebase/src/main/java/com/mes/tools/WebSocketServer.java

@@ -122,7 +122,7 @@
            if(this.session.isOpen()){
                int maxChunkSize = 50000; // 定义最大的分块大小
                int length = message.length();
                if(length>50000){
//                if(length>50000){
                    int chunks = (int) Math.ceil((double) length / maxChunkSize);
                    //分块发送消息
                    for (int i = 0; i < chunks; i++) {
@@ -138,9 +138,9 @@
                        // 发送分块消息，并传递是否是最后一块消息的标识
                        this.session.getBasicRemote().sendText(chunk);
                    }
                }else{
                    this.session.getBasicRemote().sendText(message);
                }
//                }else{
//                    this.session.getBasicRemote().sendText(message);
//                }

            }
        } catch (Exception e) {

 hangzhoumesParent/moduleService/CacheVerticalGlassModule/src/main/java/com/mes/bigstorage/service/impl/BigStorageCageDetailsServiceImpl.java

@@ -388,6 +388,7 @@
    public List<Map<String, Object>> selectTemperingGlass(){
        QueryWrapper<BigStorageCageDetails> wrapper = new QueryWrapper<>();
        wrapper.select("engineer_id,tempering_layout_id,count(*) as count")
                .in("state",Const.GLASS_STATE_IN,Const.GLASS_STATE_ARTIFICIAL)
                .groupBy("engineer_id,tempering_layout_id");
        List<Map<String, Object>> TemperingGlass = baseMapper.selectMaps(wrapper);
        return TemperingGlass;

 hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java

@@ -120,7 +120,10 @@
        JSONObject jsonObject = new JSONObject();
        //正在进行的任务
        List<UpPattenUsage> upPattenUsages = upPattenUsageService.prioritylist();
        jsonObject.append("prioritylist", upPattenUsages);
        if(upPattenUsages!=null){
            jsonObject.append("prioritylist", upPattenUsages);
        }

        //工位信息
        List<UpWorkstation> upWorkstations = upWorkstationService.list();
        jsonObject.append("list", upWorkstations);
@@ -145,7 +148,7 @@
        JSONObject jsonObject = new JSONObject();
        //正在进行的任务
        String inkageStatus =plcParameterObject.getPlcParameter("MesToPlc").getValue();
        //String inkageStatus ="1";
//        String inkageStatus ="1";
        jsonObject.append("InkageStatus", inkageStatus);
        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("loadGlass");
        if (sendwServer != null) {