From 2fdf959ac739edd6de84aa8053b8b9683dce8e8b Mon Sep 17 00:00:00 2001
From: zhao
Date: 星期三, 07 七月 2021 14:53:24 +0800
Subject: [PATCH] 中策下任务接口

---
 HH.WMS.WebApi/Extension/ExecTransferTask.cs |   22 +++++++++++++++++++---
 1 files changed, 19 insertions(+), 3 deletions(-)

diff --git a/HH.WMS.WebApi/Extension/ExecTransferTask.cs b/HH.WMS.WebApi/Extension/ExecTransferTask.cs
index e70a607..e9ba4c6 100644
--- a/HH.WMS.WebApi/Extension/ExecTransferTask.cs
+++ b/HH.WMS.WebApi/Extension/ExecTransferTask.cs
@@ -25,11 +25,27 @@
         public void Run(object source, ElapsedEventArgs elapsedEventArgs)
         {
             try
-            {  //闃叉Timer閲嶅叆
+            {
+                //闃叉Timer閲嶅叆
                 lock (locko)
                 {
-                    // 浣跨敤TN_MES_TASK涓存椂琛ㄤ腑鎺ユ敹鐨凪ES浠诲姟锛屽垱寤篧MS浠诲姟
-                    BLLCreator.Create<ZCBLL>().ExecTransferTask();                    
+                    var transportReqs = BLLCreator.CreateDapper<TN_MES_TASK>().GetList(new
+                    {
+                        NeedTrig = Constants.Y
+                    }).OrderBy(o => o.CreateDate).ToList();
+
+                    var serviceExecs = BLLCreator.CreateDapper<TN_WM_SERVICE_EXECEntity>().GetList(new
+                    {
+                        CN_C_COMPLETE = Constants.N,
+                        CN_S_TASK_TYPE = "绉婚�"
+                    });
+
+                    transportReqs = transportReqs.FindAll(f => !serviceExecs.Exists(e => e.CN_S_TASK_NO == f.task_no));
+
+                    if (transportReqs.Any())
+                    {
+                        BLLCreator.Create<ZCBLL>().ExecTransferTask(transportReqs);
+                    }
                 }
             }
             catch (Exception ex)

--
Gitblit v1.9.1