From 23b4e7942a8524ed1e89d93c55a470f0dc263d5a Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期五, 06 六月 2025 13:54:01 +0800 Subject: [PATCH] * --- src/main/java/com/zy/core/MainProcess.java | 53 ++++++++++++++++++++++++++++++++++++++++------------- 1 files changed, 40 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/zy/core/MainProcess.java b/src/main/java/com/zy/core/MainProcess.java index 3dbda62..674ed7a 100644 --- a/src/main/java/com/zy/core/MainProcess.java +++ b/src/main/java/com/zy/core/MainProcess.java @@ -1,11 +1,16 @@ package com.zy.core; +import com.zy.asrs.service.impl.MainServiceImpl; import com.zy.core.properties.SystemProperties; import lombok.Data; import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; import javax.annotation.PreDestroy; +import java.util.ArrayList; +import java.util.Date; /** * WCS涓绘祦绋� @@ -16,35 +21,57 @@ @Component public class MainProcess { + @Autowired + private MainServiceImpl mainService; // 鎵�灞炵嚎绋� private Thread thread; + // 棰戠巼 + private int i = 0; + private int j = 0; + private int k = 0; + private int l = 0; + private int[] autoZ = new int[]{0,0,0,0,0,0,0}; /** * =====>> 寮�濮嬪伐浣� */ public void start(){ thread = new Thread(() -> { + try{ + Thread.sleep(200); + log.info("++++++++ 寮�濮嬮獙璇佽鍙瘉 ++++++++"); + if (!mainService.licenseVerify()){ + SystemProperties.WCS_RUNNING_STATUS.set(Boolean.FALSE); + log.info("++++++++ 楠岃瘉璁稿彲璇佸け璐� ++++++++"); + } else { + SystemProperties.WCS_RUNNING_STATUS.set(Boolean.TRUE); + log.info("++++++++ 楠岃瘉璁稿彲璇佹垚鍔� ++++++++"); + } + } catch (Exception e) {} while (!Thread.currentThread().isInterrupted()) { try { + // 闂撮殧 + Thread.sleep(200); + System.out.println("寮�濮嬶細"+new Date().getTime()); + // 绯荤粺杩愯鐘舵�佸垽鏂� - if (SystemProperties.WCS_RUNNING_STATUS.get()) { + if (!SystemProperties.WCS_RUNNING_STATUS.get()) { continue; } + //鏇存柊浣嶇疆淇℃伅 + mainService.updateStePositionNearby(); + //鏇存柊浣嶇疆淇℃伅 + mainService.updateStePosition(); + // 浠诲姟涓嬪彂 + mainService.DevpTaskNoRun(); + // 浠诲姟瀹屾垚 + mainService.rgvCompleteWrkMastSta(autoZ); + //鏇存柊浣嶇疆淇℃伅 + mainService.updateStePosition(); + System.out.println("缁撴潫锛�"+new Date().getTime()); - - - - - - - - - - // 闂撮殧 - Thread.sleep(1500); - log.info("WCS 宸ヤ綔涓� ....................."); } catch (Exception e) { e.printStackTrace(); } -- Gitblit v1.9.1