From f511b31ab0db0c9fa3d242e99a24e784bb6b602e Mon Sep 17 00:00:00 2001 From: ZY <zc857179121@qq.com> Date: 星期二, 18 三月 2025 16:38:26 +0800 Subject: [PATCH] 1 --- src/main/java/com/zy/core/MainProcess.java | 46 +++++++++++++++++++++++++++------------------- 1 files changed, 27 insertions(+), 19 deletions(-) diff --git a/src/main/java/com/zy/core/MainProcess.java b/src/main/java/com/zy/core/MainProcess.java index 379343e..ce0cd92 100644 --- a/src/main/java/com/zy/core/MainProcess.java +++ b/src/main/java/com/zy/core/MainProcess.java @@ -22,37 +22,45 @@ private MainServiceImpl mainService; // 鎵�灞炵嚎绋� private Thread thread; + // 棰戠巼 + private int i = 0; /** * =====>> 寮�濮嬪伐浣� */ - public void start(){ + public void start() { thread = new Thread(() -> { while (!Thread.currentThread().isInterrupted()) { try { + // 闂撮殧 + Thread.sleep(1000); + // 绯荤粺杩愯鐘舵�佸垽鏂� - if (SystemProperties.WCS_RUNNING_STATUS.get()) { + if (!SystemProperties.WCS_RUNNING_STATUS.get()) { continue; } - // 鍏ュ簱绔欙紝鏍规嵁鏉$爜鎵弿鐢熸垚鍏ュ簱宸ヤ綔妗o紝宸ヤ綔鐘舵��2锛屾棤璁惧鍛戒护涓嬪彂 - mainService.generateStoreWrkFile(); - // 鎷f枡銆佸苟鏉裤�佺洏鐐瑰啀鍏ュ簱 - mainService.stnToCrnStnPick(); - // 鍫嗗灈鏈哄嚭搴撶珯鍒板嚭搴撶珯 + + + // 鍏ュ簱 ===>> 鍏ュ簱绔欏埌鍫嗗灈鏈虹珯锛屾牴鎹潯鐮佹壂鎻忕敓鎴愬叆搴撳伐浣滄。 + mainService.generateStoreWrkFile1(); // 缁勬墭 + // 鍑哄簱 ===>> 鍫嗗灈鏈哄嚭搴撶珯鍒板嚭搴撶珯 mainService.crnStnToOutStn(); + // 鍏ュ嚭搴� ===>> 鍫嗗灈鏈哄叆鍑哄簱浣滀笟涓嬪彂 + mainService.crnIoExecute(); + // 鍏ュ簱 ===>> 鎵ц瀵瑰伐浣滄。鐨勫畬鎴愭搷浣� + mainService.storeFinished(); + + // 鍫嗗灈鏈哄紓甯镐俊鎭褰� + mainService.recCrnErr(); + + // 鍏朵粬 ===>> // 鍏ュ嚭搴撴ā寮忓垏鎹㈠嚱鏁� + i++; + if (i > 1) { + mainService.ioConvert(); + i = 0; + } - - - - - - - - - // 闂撮殧 - Thread.sleep(1500); - log.info("WCS 宸ヤ綔涓� ....................."); } catch (Exception e) { e.printStackTrace(); } @@ -62,7 +70,7 @@ } @PreDestroy - public void shutDown(){ + public void shutDown() { if (thread != null) thread.interrupt(); } -- Gitblit v1.9.1