Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes

严智鑫

2024-04-16 e208aa1ef8e861dba168e8d83ab3066fc9f1e02d

 UnLoadGlassModule/src/main/java/com/mes/service/Plchome.java

@@ -1,18 +1,25 @@
package com.mes.service;



import cn.hutool.json.JSONObject;

import com.mes.tools.WebSocketServer;

import org.springframework.stereotype.Component;



import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import java.util.ArrayList;

import java.util.function.Supplier;



@Component

public class Plchome extends Thread {

    private int i = 1;

    private final Supplier<PlcService> plcServiceSupplier;

    private static final Logger log = LogManager.getLogger(Plchome.class);



    private final Supplier<DownGlassLogic> plcServiceSupplier;



    public Plchome() {

        this.plcServiceSupplier = () -> WebSocketServer.applicationContext.getBean(PlcService.class);

        this.plcServiceSupplier = () -> WebSocketServer.applicationContext.getBean(DownGlassLogic.class);

    }







    @Override

    public void run() {

@@ -20,12 +27,34 @@
            try {

                i++;

                Thread.sleep(100);

                PlcService plcService = plcServiceSupplier.get();

                plcService.performPlcActions();

                DownGlassLogic plcService = plcServiceSupplier.get();

               // plcService.performPlcActions();

                //plcService.unloadpush();



                //当下片任务表状态为1时候将数据插入到下片玻璃信息表

                plcService.insertdownglassinfo();







                //当机械手任务表中状态为1 更新已经落架数量，并且把下片任务表的那条记录删掉 工位表流程卡绑定了架子

                plcService.downWorkstation();





            } catch (InterruptedException e) {

                Thread.currentThread().interrupt();

                e.printStackTrace();

            }



            JSONObject jsonObject = new JSONObject();

            // System.out.println(arraylist6);

            jsonObject.append("data", 1);

            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("unloadglass");

            if (sendwServer != null) {

                for (WebSocketServer webserver : sendwServer) {

                    webserver.sendMessage(jsonObject.toString());

                    log.info("准备向 WebSocket 服务器发送消息: {}", jsonObject.toString());

                }}



        }

    }

}