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