From c7b4647fbcebf9a097a948110ca9a195827ac430 Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期一, 13 五月 2024 11:00:43 +0800
Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/HangZhouMes

---
 hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java |   76 ++++++++++++++++++++++++++++++++++++--
 1 files changed, 72 insertions(+), 4 deletions(-)

diff --git a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
index d3c4324..4110f80 100644
--- a/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
+++ b/hangzhoumesParent/moduleService/LoadGlassModule/src/main/java/com/mes/job/PlcLoadGlassTask.java
@@ -1,33 +1,101 @@
 package com.mes.job;
 
-import cn.hutool.json.JSONObject;
+import com.mes.common.S7object;
+import com.mes.device.PlcParameterObject;
+import com.mes.engineering.entity.Engineering;
+import com.mes.engineering.service.EngineeringService;
+import com.mes.uppattenusage.entity.UpPattenUsage;
+import com.mes.uppattenusage.service.UpPattenUsageService;
+import com.mes.workstation.entity.UpWorkstation;
 import com.mes.workstation.service.UpWorkstationService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+/**
+ * @author SNG-010
+ */
 @Component
 @Slf4j
 public class PlcLoadGlassTask {
 
     @Autowired
     private UpWorkstationService upWorkstationService;
+    @Autowired
+    private EngineeringService engineeringService;
+    @Autowired
+    private UpPattenUsageService upPattenUsageService;
 
+    PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
 
     /**
      * fixedRate : 涓婁竴涓皟鐢ㄥ紑濮嬪悗鍐嶆璋冪敤鐨勫欢鏃讹紙涓嶇敤绛夊緟涓婁竴娆¤皟鐢ㄥ畬鎴愶級
      * fixedDelay : 涓婁竴涓皟鐢ㄧ粨鏉熷悗鍐嶆璋冪敤鐨勫欢鏃�
      */
+
     @Scheduled(fixedDelay = 300)
     public void plcLoadGlassTask() throws InterruptedException {
-        JSONObject jsonObject = new JSONObject();
         try {
-            Thread.sleep(300);
-            upWorkstationService.selectPriority();
+            //鑾峰彇鏄惁鏈変笂鐗囪姹�
+            String loadRequest = plcParameterObject.getPlcParameter("loadRequest").getValue();
+            //鍒ゆ柇寮�濮嬩笂鐗囩殑宸ョ▼鍙�
+            Engineering engineering = engineeringService.selectInitiate(1);
+            if ("1".equals(loadRequest) && engineering != null) {
+                log.info("寮�濮嬩笂鐗囦换鍔�");
+                UpPattenUsage upPattenUsage = upWorkstationService.selectPriority(engineering);
+                log.info("褰撴湁璇锋眰鏃舵煡璇㈠綋鍓嶄笂鐗囬『搴忕殑鐜荤拑淇℃伅{}", upPattenUsage);
+                UpWorkstation upwork = upWorkstationService.selectWorkstation(upPattenUsage);
+                log.info("绗﹀悎鐨勫昂瀵哥殑宸ヤ綅鐜荤拑锛歿}", upwork);
+                if (upwork != null) {
+                    int workId = upwork.getWorkstationId();//宸ヤ綅id
+                    double width = upwork.getPatternWidth();//瀹藉害
+                    double height = upwork.getPatternHeight();//楂樺害
+                    S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("WorkId").getAddress(), workId);
+                    S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("GlassWidth").getAddress(), (long) width);
+                    S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("GlassHeight").getAddress(), (long) height);
+                    S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlc").getAddress(), 1);
+                    //鏇存敼涓婄墖琛ㄧ姸鎬�
+                    upPattenUsageService.updateUpPattenUsageState(upPattenUsage, workId);
+
+                }
+            }
+            //鑾峰彇鏄惁鏈夋眹鎶�
+            String loadStatus = plcParameterObject.getPlcParameter("PlcStatus").getValue();
+            if (loadStatus != null) {
+                log.info(loadStatus);
+                if ("1".equals(loadStatus)) {
+                    log.info("鏀跺埌姹囨姤浠诲姟瀹屾垚");
+                    S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlcStatus").getAddress(), 1);
+                } else if ("2".equals(loadStatus)) {
+                    log.info("鏀跺埌姹囨姤鏈畬鎴愪换鍔�");
+                    //鍑忓皯宸ヤ綅鏁伴噺,鎭㈠浠诲姟鐘舵��
+                    overTask(loadStatus,0);
+                } else if ("3".equals(loadStatus)) {
+                    log.info("鏀跺埌姹囨姤鐜荤拑鐮存崯");
+                    overTask(loadStatus,0);
+                } else if("0".equals(loadStatus)){
+                        log.info("鏀跺埌姹囨姤娓�0鐘舵��");
+                        //鍑忓皯宸ヤ綅鏁伴噺,瀹屾垚浠诲姟鐘舵��
+                        overTask(loadStatus,1);
+                }
+            }
+            //鎵ц鍚庝紤鐪�300姣
+            //Thread.sleep(300);
         } catch (Exception e) {
             e.printStackTrace();
         }
     }
+  public  void overTask(String loadStatus,int state) throws InterruptedException {
+      UpPattenUsage upPattenUsage = upPattenUsageService.selectOverTask();
+      if (upPattenUsage != null) {
+          log.info("鏀跺埌姹囨姤娓厈}鐘舵��",loadStatus);
+          //鍑忓皯宸ヤ綅鏁伴噺
+          upWorkstationService.reduceWorkstationNumber(upPattenUsage.getState());
+          //瀹屾垚涓婄墖琛ㄧ姸鎬�
+          upPattenUsageService.updateUpPattenUsageState(upPattenUsage, 100);
+          S7object.getinstance().plccontrol.writetime(plcParameterObject.getPlcParameter("MesToPlcStatus").getAddress(), 0);
+      }
+  }
 
 }
\ No newline at end of file

--
Gitblit v1.8.0