*

lsh

2025-11-10 ffee4b305f9ab02f828555100d44cba6b3c043fb

 src/main/java/com/zy/core/thread/SiemensDevpThread.java

@@ -86,20 +86,6 @@
    @SuppressWarnings("InfiniteLoopStatement")
    public void run() {
        initSite();
        try{
            Thread.sleep(2000);
        } catch (Exception e){

        }
        connectDev = connect();
        while(!connectDev){
            try {
                connectDev = this.connect();
                Thread.sleep(100);
            } catch (Exception e){

            }
        }

        // 启动线程自动重连
        new Thread(this::devConnect).start();
@@ -320,6 +306,14 @@

                if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
                    staProtocol.setPakMk(true);
                }

                if (!staProtocol.isPakMkRun() && !staProtocol.isLoading()) {
                    staProtocol.setPakMkRun(true);
                }

                if (!staProtocol.isPakMkTask() && !staProtocol.isLoading()) {
                    staProtocol.setPakMkTask(true);
                }
            }
        }
@@ -616,6 +610,29 @@
        }
    }


    /**
     * 设置入库标记
     */
    @Override
    public void setPakMkTask(Integer siteId, boolean pakMk) {
        StaProtocol staProtocol = station.get(siteId);
        if (null != staProtocol) {
            staProtocol.setPakMkTask(pakMk);
        }
    }


    /**
     * 设置入库标记
     */
    @Override
    public void setPakMkRun(Integer siteId, boolean pakMk) {
        StaProtocol staProtocol = station.get(siteId);
        if (null != staProtocol) {
            staProtocol.setPakMkRun(pakMk);
        }
    }
    /**
     * 设置入库标记
     */