添加控制 保证aps release和feedback不同时执行

task/ApsRelease.go

@@ -1,12 +1,17 @@
 package task
 
 import (
+	omServices "LAPP_GAAS_GFrame_BACKEND/services/om"
 	services "LAPP_GAAS_GFrame_BACKEND/services/schedule"
 )
 
 var ApsReleaseStatus int
+var feedbackFromMesTaskStatus int
 
-func StartApsRelease()  {
+func StartApsRelease() {
+	if feedbackFromMesTaskStatus == 1 {
+		return
+	}
 	if ApsReleaseStatus == 0 {
 		ApsReleaseStatus = 1
 		defer func() {
@@ -18,3 +23,32 @@ func StartApsRelease()  {
 	plantNr := 100
 	services.ApsRelease(plantNr)
 }
+
+/******************************************************************************
+ *
+ * @Struct Name              : FeedbackFromMes
+ *-----------------------------------------------------------------------------
+ *
+ * @Description              : 从mes系统回写状态 时间等数据
+ *
+ * @Author                   : zhangxin
+ *
+ * @Date                     : 2021-05-13
+ *
+ ******************************************************************************/
+func FeedbackFromMes() {
+	if ApsReleaseStatus == 1 {
+		return
+	}
+	if feedbackFromMesTaskStatus == 0 {
+		feedbackFromMesTaskStatus = 1
+		defer func() {
+			feedbackFromMesTaskStatus = 0
+		}()
+	} else {
+		return
+	}
+	plantNr := 100
+	omServicesImpl := omServices.NewOmToMesService()
+	omServicesImpl.FeedbackFromMes(plantNr)
+}

task/TrasnferToMes.go

@@ -4,7 +4,7 @@ import services "LAPP_GAAS_GFrame_BACKEND/services/om"
 
 var transferWorkOrderToMesTaskStatus int
 var transferSerialOrderToMesTaskStatus int
-var feedbackFromMesTaskStatus int
+
 /******************************************************************************
  *
  * @Struct Name              : TransferWorkOrderToMes
@@ -57,28 +57,3 @@ func TransferSerialOrderToMes()  {
 	omServices.TransferSerialOrderToMes(plantNr)
 }
 
-/******************************************************************************
- *
- * @Struct Name              : FeedbackFromMes
- *-----------------------------------------------------------------------------
- *
- * @Description              : 从mes系统回写状态 时间等数据
- *
- * @Author                   : zhangxin
- *
- * @Date                     : 2021-05-13
- *
- ******************************************************************************/
-func FeedbackFromMes()  {
-	if feedbackFromMesTaskStatus == 0 {
-		feedbackFromMesTaskStatus = 1
-		defer func() {
-			feedbackFromMesTaskStatus = 0
-		}()
-	} else {
-		return
-	}
-	plantNr := 100
-	omServices := services.NewOmToMesService()
-	omServices.FeedbackFromMes(plantNr)
-}

task/scheduler.go

@@ -47,7 +47,7 @@ func Start() error {
 
 
 	// 添加派工
-	err = c.AddFunc("*/2 * * * * ?", StartApsRelease)
+	err = c.AddFunc("*/3 * * * * ?", StartApsRelease)
 	if err != nil {
 		return err
 	}
@@ -69,7 +69,7 @@ func Start() error {
 	if err != nil {
 		return err
 	}
-	err = c.AddFunc("*/2 * * * * ?",  FeedbackFromMes)
+	err = c.AddFunc("*/5 * * * * ?",  FeedbackFromMes)
 	if err != nil {
 		return err
 	}