From ff58f159796469f2ad7e6922fa5698654bc98c23 Mon Sep 17 00:00:00 2001
From: wells.liu <wells.liu@broconcentric.com>
Date: 星期六, 04 七月 2020 13:51:39 +0800
Subject: [PATCH] 板卡运动配置

---
 src/Bro.Device.GTSCard/GTSCardDriver.cs |   53 ++++++++++++++++++++++++++++++++---------------------
 1 files changed, 32 insertions(+), 21 deletions(-)

diff --git a/src/Bro.Device.GTSCard/GTSCardDriver.cs b/src/Bro.Device.GTSCard/GTSCardDriver.cs
index 3368e83..f2c0343 100644
--- a/src/Bro.Device.GTSCard/GTSCardDriver.cs
+++ b/src/Bro.Device.GTSCard/GTSCardDriver.cs
@@ -76,27 +76,44 @@
         }
 
         /// <summary>
-        /// 璁惧 杩愯
+        /// 璁惧 杩愯锛堟墽琛� 鏉垮崱绯诲垪鐨勬搷浣滅殑 闆嗗悎锛�
         /// </summary>
         /// <param name="config"></param>
         /// <returns></returns>
         public override ResponseMessage Run(IOperationConfig config)
         {
             ResponseMessage responseMessage = new ResponseMessage();
-            var opConfig = config as GTSCardOperationConfig;
+            var motionCardOperationConfig = config as MotionCardOperationConfigBase;
+            foreach (var operationSet in motionCardOperationConfig.OperationCollection)
+            {
+                responseMessage = RunOperationSet(operationSet);
+                if (!responseMessage.Result)
+                {
+                    return responseMessage;
+                }
+            }
+            return responseMessage;
+        }
+
+        /// <summary>
+        /// 鎵ц 涓�涓郴鍒楃殑鎿嶄綔
+        /// </summary>
+        private ResponseMessage RunOperationSet(MotionCardOperationSet operationSet)
+        {
+            ResponseMessage responseMessage = new ResponseMessage();
             // 1.棰勬鏌�
             if (CurrentState == DeviceState.DSOpen)
             {
-                foreach (var preCheck in opConfig.PreCheckIOCollection)
+                foreach (var preCheck in operationSet.PreCheckIOCollection)
                 {
-                    int timeout = opConfig.PreCheckIOTimeout;
-                    int? ioData = null;
+                    int timeout = operationSet.PreCheckIOTimeout;
+                    IOValue? ioData = null;
                     while (CurrentState == DeviceState.DSOpen)
                     {
                         Thread.Sleep(10);
                         ioData = MonitorValues.FirstOrDefault(u => u.IONum == preCheck.IOItem.IONum && u.IOType == preCheck.IOItem.IOType)?.Value;//IO 鏄紑銆佸叧 浠嶮onitorValues 鑾峰彇
                         timeout -= 10;
-                        if (preCheck.CheckValue == ioData || (opConfig.PreCheckIOTimeout > 0 && timeout < 0))
+                        if (preCheck.CheckValue == ioData || (operationSet.PreCheckIOTimeout > 0 && timeout < 0))
                         {
                             break;
                         }
@@ -114,8 +131,7 @@
             // 2.鏉垮崱杩愬姩
             if (CurrentState == DeviceState.DSOpen)
             {
-                responseMessage = MoveToPoint(opConfig);
-
+                responseMessage = MoveToPoint(operationSet.MotionOperationCollection);
                 if (!responseMessage.Result)
                 {
                     return responseMessage;
@@ -126,7 +142,7 @@
             // 3.IO杈撳嚭 涓嶉渶瑕佽秴鏃�
             if (CurrentState == DeviceState.DSOpen)
             {
-                foreach (var ioOutput in opConfig.IOOutputCollection)
+                foreach (var ioOutput in operationSet.IOOutputCollection)
                 {
                     var ioData = MonitorValues.FirstOrDefault(u => u.IONum == ioOutput.IOItem.IONum && u.IOType == ioOutput.IOItem.IOType)?.Value;//IO 鏄紑銆佸叧 浠嶮onitorValues 鑾峰彇
                     if (ioOutput.CheckValue != ioData)
@@ -141,16 +157,16 @@
             // 4.IO纭
             if (CurrentState == DeviceState.DSOpen)
             {
-                foreach (var ioConfirm in opConfig.IOConfirmCollection)
+                foreach (var ioConfirm in operationSet.IOConfirmCollection)
                 {
-                    int timeout = opConfig.IOConfirmTimeout;
-                    int? ioData = null;
+                    int timeout = operationSet.IOConfirmTimeout;
+                    IOValue? ioData = null;
                     while (CurrentState == DeviceState.DSOpen)
                     {
                         Thread.Sleep(10);
                         ioData = MonitorValues.FirstOrDefault(u => u.IONum == ioConfirm.IOItem.IONum && u.IOType == ioConfirm.IOItem.IOType)?.Value;//IO 鏄紑銆佸叧 浠嶮onitorValues 鑾峰彇
                         timeout -= 10;
-                        if (ioConfirm.CheckValue == ioData || (opConfig.IOConfirmTimeout > 0 && timeout < 0))
+                        if (ioConfirm.CheckValue == ioData || (operationSet.IOConfirmTimeout > 0 && timeout < 0))
                         {
                             break;
                         }
@@ -250,19 +266,14 @@
         public override ResponseMessage MoveToPoint(IOperationConfig opConfig)
         {
             ResponseMessage responseMessage = new ResponseMessage();
-            var gtsOperationConfig = opConfig as GTSCardOperationConfig;
+            var gtsOperationCollection = opConfig as MotionOperationCollection;
             List<Task<bool>> taskList = new List<Task<bool>>();
-            //TaskFactory factory = new TaskFactory(TaskCreationOptions.LongRunning, TaskContinuationOptions.None);
-            // 濡傛灉鏄涓酱鐨勮繍鍔� 绛夋瘡涓酱杩愬姩缁撴潫
-            foreach (var movingOp in gtsOperationConfig.MovingOps)
+            foreach (var movingOp in gtsOperationCollection.MovingOps)
             {
-                //var task = factory.StartNew<bool>((op) =>
-                //{
-                //    return SingleAxisMoving(op as MovingOption);
-                //}, movingOp);
                 var task = SingleAxisMoving(movingOp);
                 taskList.Add(task);
             }
+
             Task.WaitAll(taskList.ToArray());
             responseMessage.Result = taskList.All(u => u.GetAwaiter().GetResult());
             if (!responseMessage.Result)

--
Gitblit v1.8.0