From f3ad86fe50a0d2ba81b203517184264eea7bf0c0 Mon Sep 17 00:00:00 2001
From: hudong <Administrator@PC-20250329JZUF>
Date: 星期四, 05 六月 2025 17:04:44 +0800
Subject: [PATCH] 入库审核逻辑更改 代码修改

---
 models/TN_DPRECORD.cs   |    1 
 Program.cs              |    1 
 api/WmsSpaHelper.cs     |  158 +++++++++++++++++++++++++++++----------
 models/DAPING.cs        |    1 
 api/ApiModel.cs         |    6 +
 process/TaskProcess.cs  |   20 +++++
 core/WCSCore.cs         |   19 ++++
 core/WMSCore.cs         |    1 
 api/WmsSapController.cs |    1 
 9 files changed, 168 insertions(+), 40 deletions(-)

diff --git a/Program.cs b/Program.cs
index 29cd936..01502e7 100644
--- a/Program.cs
+++ b/Program.cs
@@ -111,6 +111,7 @@
             public void Start() {
                 List<Task> tasks = new List<Task>();
                 //娣诲姞浠诲姟鎺ㄩ�绾跨▼
+                //tasks.Add(GetTask(() => RunAtSpecificTime(WMSCore.Start, "14:00")));
                 tasks.Add(GetTask(WMSCore.Start));
                 tasks.Add(GetTask(WMSCore.CheckDistributionCNTROrder));
                 //tasks.Add(GetTask(WMSCore.TransportTask));
diff --git a/api/ApiModel.cs b/api/ApiModel.cs
index 6617e7e..0c80903 100644
--- a/api/ApiModel.cs
+++ b/api/ApiModel.cs
@@ -659,8 +659,14 @@
     public class WcRkDto {
         public string GZRY { get;set;}
         public string S_NO { get;set;}
+       public List<Wl> Wlist { get; set; }
     }
 
+    public class Wl {
+        public string S_ITEM_CODE{ get; set; }
+        public string N_ROW_NO{ get; set; }
 
+
+    }
     #endregion
 }
diff --git a/api/WmsSapController.cs b/api/WmsSapController.cs
index 36d464b..b2cd950 100644
--- a/api/WmsSapController.cs
+++ b/api/WmsSapController.cs
@@ -46,6 +46,7 @@
             {
                 S_NO = t.S_NO,
                 S_WLBM = t.S_WLBM,
+                S_WLMC = t.S_WLMC,
                 N_COUNT = t.N_COUNT,
                 S_LOCATION = t.S_LOCATION
             }).ToList();
diff --git a/api/WmsSpaHelper.cs b/api/WmsSpaHelper.cs
index db48e3c..ca8958c 100644
--- a/api/WmsSpaHelper.cs
+++ b/api/WmsSpaHelper.cs
@@ -3292,7 +3292,7 @@
                                         lLDReturnRoots.MSGDESP = $"鐗╂枡{a.WLBM}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�;
                                         iTEMs.Add(lLDReturnRoots);
 
-                                        break ;
+                                        continue;
                                     }
                                     po.Details.Add(new TN_Ll_detail
                                     {
@@ -3300,7 +3300,7 @@
                                         S_AREA_CODE = "HJQ",
                                         N_ROW_NO = "",
                                         S_ITEM_CODE = a.WLBM,
-                                        S_ITEM_NAME = item.S_ITEM_NAME,
+                                        S_ITEM_NAME = item?.S_ITEM_NAME,
                                         F_QTY = a.XQSL,
                                         S_ZJBM = a.ZJBM,
                                         S_YLBH = a.YLBH,
@@ -3320,8 +3320,23 @@
                                 }
                                 if (po.Details.Count()>0)
                                 {
+                                    LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
+                                    lLDReturnRoot1.GC = itemscddll.GC;
+                                    lLDReturnRoot1.LLDH = itemscddll.LLDH;
+                                    lLDReturnRoot1.MSGCODE = 0;
+                                    lLDReturnRoot1.MSGDESP = $"鎴愬姛";
+                                    iTEMs.Add(lLDReturnRoot1);
                                     var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0;
                                     db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand();
+                                }
+                                else
+                                {
+                                    LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
+                                    lLDReturnRoot1.GC = itemscddll.GC;
+                                    lLDReturnRoot1.LLDH = itemscddll.LLDH;
+                                    lLDReturnRoot1.MSGCODE = 0;
+                                    lLDReturnRoot1.MSGDESP = $"鎴愬姛,鏃犳暟鎹坊鍔�;
+                                    iTEMs.Add(lLDReturnRoot1);
                                 }
 
                             }
@@ -3344,7 +3359,7 @@
                                         lLDReturnRoots.MSGCODE = 1;
                                         lLDReturnRoots.MSGDESP = $"鎵ц涓鏂欏崟锛岀墿鏂檣a.WLBM}鐗╂枡涓嶅厑璁稿垹闄�;
                                         iTEMs.Add(lLDReturnRoots);
-                                        break;
+                                        continue;
                                     }
                                     var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList();
                                     if (po1.Count() == 0)  //鏃犲垯鏂板鐗╂枡鏄庣粏
@@ -3360,7 +3375,7 @@
                                             lLDReturnRoots.MSGCODE = 1;
                                             lLDReturnRoots.MSGDESP = $"鐗╂枡{a.WLBM}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�;
                                             iTEMs.Add(lLDReturnRoots);
-                                            break;
+                                            continue;
                                         }
                                         TN_Ll_detail tN_Outbound_Detail = new TN_Ll_detail
                                         {
@@ -3404,7 +3419,7 @@
                                             lLDReturnRoots.MSGCODE = 1;
                                             lLDReturnRoots.MSGDESP = $"鏇存柊澶辫触锛屾洿鏂版暟閲忓繀椤诲ぇ浜庡綋鍓嶇墿鏂欐暟閲弡a.WLBM}";
                                             iTEMs.Add(lLDReturnRoots);
-                                            break;
+                                            continue;
                                         }
                                     }
                                 }
@@ -3489,16 +3504,26 @@
                             //娣诲姞鏁版嵁
                             if (listtn.Count() > 0)
                             {
+                                LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
+                                lLDReturnRoot1.GC = itemscddll.GC;
+                                lLDReturnRoot1.LLDH = itemscddll.LLDH;
+                                lLDReturnRoot1.MSGCODE = 0;
+                                lLDReturnRoot1.MSGDESP = $"鎴愬姛";
+                                iTEMs.Add(lLDReturnRoot1);
                                 db.Insertable<TN_Ll_detail>(listtn).ExecuteCommand();
+                            }
+                            else
+                            {
+                                LLDReturnRoot.ITEM lLDReturnRoot1 = new LLDReturnRoot.ITEM();
+                                lLDReturnRoot1.GC = itemscddll.GC;
+                                lLDReturnRoot1.LLDH = itemscddll.LLDH;
+                                lLDReturnRoot1.MSGCODE = 0;
+                                lLDReturnRoot1.MSGDESP = $"鎴愬姛,鏃犳暟鎹坊鍔�;
+                                iTEMs.Add(lLDReturnRoot1);
                             }
                         }
 
-
-                        lLDReturnRoots.GC = itemscddll.GC;
-                        lLDReturnRoots.LLDH = itemscddll.LLDH;
-                        lLDReturnRoots.MSGCODE = 0;
-                        lLDReturnRoots.MSGDESP = $"鎴愬姛";
-                        iTEMs.Add(lLDReturnRoots);
+                    
                         db.CommitTran();
                     }
 
@@ -4056,6 +4081,10 @@
                         result.resultMsg = "鏁版嵁涓嶅瓨鍦�;
                         return result;
                     }
+                    po.Details= po.Details.Where(d => model.Wlist.Any(w =>
+                                w.S_ITEM_CODE == d.S_ITEM_CODE &&
+                                w.N_ROW_NO == d.N_ROW_NO))
+                            .ToList();
                     if (po.S_IN_TYPE == "鍐呴噰鍏ュ簱")
                     {
                         List<NcRkDto.ITEM> listitem = new List<NcRkDto.ITEM>();
@@ -4177,22 +4206,39 @@
                         //娣诲姞鍑瘉璁板綍琛�                         result.resultMsg = data.ROOT.ITEM.MSGDESP;
                         result.resultCode = data.ROOT.ITEM.MSGCODE;
-                        MaterialVoucher materialVoucher = new MaterialVoucher();
+                        //MaterialVoucher materialVoucher = new MaterialVoucher();
                         if (data.ROOT.ITEM.MSGCODE == 0)
                         {
-                            materialVoucher.S_NO = model.S_NO;
-                            materialVoucher.S_TYPE = po.S_IN_TYPE;
-                            materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
-                            materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
-                            materialVoucher.STATUS = 0;
-                            db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
+                            //materialVoucher.S_NO = model.S_NO;
+                            //materialVoucher.S_TYPE = po.S_IN_TYPE;
+                            //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
+                            //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
+                            //materialVoucher.STATUS = 0;
+                            //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
+                            List<MaterialVoucher> materials = new List<MaterialVoucher>();
+                            foreach (var item in model.Wlist)
+                            {
+                                MaterialVoucher materialVoucher = new MaterialVoucher();
+                                materialVoucher.S_NO = po.S_NO;
+                                materialVoucher.S_WLBM = item.S_ITEM_CODE;
+                                materialVoucher.S_WLH = item.N_ROW_NO;
+                                materialVoucher.S_TYPE = po.S_IN_TYPE;
+                                materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
+                                materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
+                                materialVoucher.STATUS = 0;
+                                materials.Add(materialVoucher);
+                            }
+
+                            if (materials.Count() > 0)
+                            {
+
+                                db.Insertable<MaterialVoucher>(materials).ExecuteCommand();
+                            }
                         }
 
 
                     }
-                    else
-
-                    if (po.S_IN_TYPE == "璁″垝澶栭�鏂欏叆搴�)
+                    else if (po.S_IN_TYPE == "璁″垝澶栭�鏂欏叆搴�)
                     {
                         DateTime dateTime;
                         DateTime dateTime1;
@@ -4317,13 +4363,25 @@
                         result.resultCode = data.ROOT.ITEM.MSGCODE;
                         if (data.ROOT.ITEM.MSGCODE == 0)
                         {
-                            MaterialVoucher materialVoucher = new MaterialVoucher();
-                            materialVoucher.S_NO = po.S_NO;
-                            materialVoucher.S_TYPE = po.S_IN_TYPE;
-                            materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
-                            materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
-                            materialVoucher.STATUS = 0;
-                            db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
+                            List< MaterialVoucher > materials = new List< MaterialVoucher >();
+                            foreach (var item in model.Wlist)
+                            {
+                                MaterialVoucher materialVoucher = new MaterialVoucher();
+                                materialVoucher.S_NO = po.S_NO;
+                                materialVoucher.S_WLBM = item.S_ITEM_CODE;
+                                materialVoucher.S_WLH = item.N_ROW_NO;
+                                materialVoucher.S_TYPE = po.S_IN_TYPE;
+                                materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
+                                materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
+                                materialVoucher.STATUS = 0;
+                                materials.Add( materialVoucher );
+                            }
+
+                            if (materials.Count() > 0)
+                            {
+
+                                db.Insertable<MaterialVoucher>(materials).ExecuteCommand();
+                            }
                         }
                         #endregion
 
@@ -4448,15 +4506,34 @@
                         result.resultCode = data.ROOT.ITEM.MSGCODE;
                         if (data.ROOT.ITEM.MSGCODE == 0)
                         {
-                            MaterialVoucher materialVoucher = new MaterialVoucher();
-                            materialVoucher.S_NO = model.S_NO;
-                            materialVoucher.S_TYPE = po.S_IN_TYPE;
-                            materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZH;
-                            LogHelper.Info("鍊�: " + data.ROOT.ITEM?.WLPZH);
-                            LogHelper.Info("鍊�: " + materialVoucher.S_WLPZBH);
-                            materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND;
-                            materialVoucher.STATUS = 0;
-                            db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
+                            //MaterialVoucher materialVoucher = new MaterialVoucher();
+                            //materialVoucher.S_NO = model.S_NO;
+                            //materialVoucher.S_TYPE = po.S_IN_TYPE;
+                            //materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZH;
+                            //LogHelper.Info("鍊�: " + data.ROOT.ITEM?.WLPZH);
+                            //LogHelper.Info("鍊�: " + materialVoucher.S_WLPZBH);
+                            //materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND;
+                            //materialVoucher.STATUS = 0;
+                            //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
+                            List<MaterialVoucher> materials = new List<MaterialVoucher>();
+                            foreach (var item in model.Wlist)
+                            {
+                                MaterialVoucher materialVoucher = new MaterialVoucher();
+                                materialVoucher.S_NO = po.S_NO;
+                                materialVoucher.S_WLBM = item.S_ITEM_CODE;
+                                materialVoucher.S_WLH = item.N_ROW_NO;
+                                materialVoucher.S_TYPE = po.S_IN_TYPE;
+                                materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
+                                materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
+                                materialVoucher.STATUS = 0;
+                                materials.Add(materialVoucher);
+                            }
+                            if (materials.Count() > 0)
+                            {
+
+                                db.Insertable<MaterialVoucher>(materials).ExecuteCommand();
+                            }
+                           
                         }
                         //else
                         //{
@@ -4669,17 +4746,18 @@
 
                     var po = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == S_CNTR_CODE && a.S_BS_NO == taskno).ToList();
                     LogHelper.Info("娣诲姞鍏ュ簱璁板綍琛╬o" + po.Count());
-                    var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == taskno).First();
-                    var ass = pz == null;
+                    var pzs = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == taskno).ToList();
+                    var ass = pzs == null;
                     LogHelper.Info("娣诲姞鍏ュ簱璁板綍琛╬z" + ass);
                     List<OutboundRecord> records = new List<OutboundRecord>();
                     foreach (var item in po)
                     {
+                        var pz= pzs.Where(s=>s.S_WLBM==item.S_ITEM_CODE&&s.S_WLH==item.N_BS_ROW_NO).First();
 
                         OutboundRecord outboundRecord = new OutboundRecord();
                         outboundRecord.S_NO = item.S_BS_NO;
                         outboundRecord.S_TYPE = pz?.S_TYPE;
-                        outboundRecord.S_WLPZBH = pz?.S_WLPZBH;
+                        outboundRecord.S_WLPZBH = pz?.S_WLBM;
                         outboundRecord.S_WLPZND = pz?.S_WLPZND;
                         outboundRecord.S_WLBM = item.S_ITEM_CODE;
                         outboundRecord.S_SL = item.F_QTY;
diff --git a/core/WCSCore.cs b/core/WCSCore.cs
index 4bcd182..40004fc 100644
--- a/core/WCSCore.cs
+++ b/core/WCSCore.cs
@@ -101,7 +101,26 @@
                 WMSHelper.UpdateTaskState(optask);
             }
         }
+        //public static bool SendCd()
+        //{
 
+
+
+        //    var result = false;
+
+        //    var dic = new Dictionary<string, string>();
+        //    var dic1 = new Dictionary<string, string>();
+
+        //    dic.Add("ExtDeviceNo", "1");
+
+        //    //鍒ゆ柇
+        //    var res = NDC.OrderAdd(99, dic, dic1);
+        //    if (res != null && (res.Res.ErrCode == 0 || res.Res.ErrCode == 50009))
+        //    {
+        //        result = true;
+        //    }
+        //    return result;
+        //}
         /// <summary>
         /// 浠诲姟鍒嗗彂锛屾牴鎹皟搴︾被鍨嬪彂缁欎笉鍚岀殑璋冨害绯荤粺
         /// </summary>
diff --git a/core/WMSCore.cs b/core/WMSCore.cs
index ecb6685..0b855db 100644
--- a/core/WMSCore.cs
+++ b/core/WMSCore.cs
@@ -517,6 +517,7 @@
                                 {
                                     TN_DPRECORD tN_DPRECORD = new TN_DPRECORD();
                                     tN_DPRECORD.S_WLBM=item.S_ITEM_CODE;
+                                    tN_DPRECORD.S_WLMC = item.S_ITEM_NAME;
                                     tN_DPRECORD.S_NO= wcsTask.S_CODE;
                                     tN_DPRECORD.N_COUNT= item.F_QTY;
                                     tN_DPRECORD.S_LOCATION= end.S_CODE;
diff --git a/models/DAPING.cs b/models/DAPING.cs
index 9b8e5f6..7b6894d 100644
--- a/models/DAPING.cs
+++ b/models/DAPING.cs
@@ -18,6 +18,7 @@
 
             public string S_NO { get; set; }
             public string S_WLBM { get; set; }
+            public string S_WLMC { get; set; }
             public double N_COUNT { get; set; }
             public string S_LOCATION { get; set; }
         }
diff --git a/models/TN_DPRECORD.cs b/models/TN_DPRECORD.cs
index 6b6f466..a79d258 100644
--- a/models/TN_DPRECORD.cs
+++ b/models/TN_DPRECORD.cs
@@ -12,6 +12,7 @@
    
     {
         public string S_NO { get; set; }
+        public string S_WLMC { get; set; }
         public string S_WLBM { get; set; }
         public double N_COUNT { get; set; }
         public string S_LOCATION { get; set; }
diff --git a/process/TaskProcess.cs b/process/TaskProcess.cs
index 6307977..a777b0d 100644
--- a/process/TaskProcess.cs
+++ b/process/TaskProcess.cs
@@ -567,6 +567,26 @@
 
 
         }
+
+        public static bool SendCd() {
+        
+        
+        
+             var result=false;
+           
+                var dic = new Dictionary<string, string>();
+                var dic1 = new Dictionary<string, string>();
+              
+                dic.Add("ExtDeviceNo", "1");
+               
+                //鍒ゆ柇
+                var res = NDC.OrderAdd(99, dic, dic1);
+                if (res != null && (res.Res.ErrCode == 0 || res.Res.ErrCode == 50009))
+                {
+                result = true;
+                }
+            return result;
+        }
         /// <summary>
         /// 鎺ㄩ�浠诲姟
         /// </summary>

--
Gitblit v1.9.1