From d8c0f4088dd1619279f6f894766a28bb0ecfe0a4 Mon Sep 17 00:00:00 2001
From: pengmn <pmn@HanInfo>
Date: 星期五, 04 七月 2025 17:21:12 +0800
Subject: [PATCH] 1

---
 HH.WCS.Mobox3.HangYang/wms/WMSHelper.cs |  253 +++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 247 insertions(+), 6 deletions(-)

diff --git a/HH.WCS.Mobox3.HangYang/wms/WMSHelper.cs b/HH.WCS.Mobox3.HangYang/wms/WMSHelper.cs
index d86ece3..ee5453d 100644
--- a/HH.WCS.Mobox3.HangYang/wms/WMSHelper.cs
+++ b/HH.WCS.Mobox3.HangYang/wms/WMSHelper.cs
@@ -544,6 +544,50 @@
 
         #region 鏉哀WMS甯姪鏂规硶
         /// <summary>
+        /// 鏂板鐗╂枡涓绘暟鎹�+        /// </summary>
+        /// <param name="materials"></param>
+        /// <returns></returns>
+        internal static bool CreateMaterialData(List<TN_Material> materials)
+        {
+            try
+            {
+                bool res = false;
+                var db = new SqlHelper<object>().GetInstance();
+                db.BeginTran();
+                foreach (var material in materials)
+                {
+                    var _Material = db.Queryable<TN_Material>().Where(c => c.S_ITEM_CODE == material.S_ITEM_CODE).First();
+                    if (_Material != null)
+                    {
+                        db.Updateable<TN_Material>(material).UpdateColumns(a => new { a.S_ITEM_NAME, a.S_AREA_CODE, a.S_ITEM_SPEC, a.S_MATERIAL, a.S_UOM, a.C_CLEAN, a.T_MODIFY }).ExecuteCommand();
+                    }
+                    else
+                    {
+                        db.Insertable(material).ExecuteCommand();
+                    }
+                }
+                db.CommitTran();
+                res = true;
+                return res;
+            }
+            catch (Exception ex)
+            {
+                var sugarEx = ex as SqlSugar.SqlSugarException;
+                if (sugarEx != null)
+                {
+                    LogHelper.Error($"鍒涘缓鍏ュ簱鍗昐QL閿欒: {sugarEx.Sql}", sugarEx, "鏉哀");
+                }
+                else
+                {
+                    LogHelper.Error($"鍒涘缓鍏ュ簱鍗曞け璐�{ex.Message}", ex, "鏉哀");
+                }
+                return false;
+            }
+
+        }
+
+        /// <summary>
         /// 鏂板鍏ュ簱鍗�         /// </summary>
         /// <param name="order"></param>
@@ -557,8 +601,51 @@
                 db.BeginTran();
                 foreach (var orderItem in order)
                 {
-                    db.Insertable(orderItem).ExecuteCommand();
-                    db.Insertable(orderItem.InOrderDetail).ExecuteCommand();
+                    var _inOrder = db.Queryable<InOrder>().Where(c => c.S_NO == orderItem.S_NO).First();
+                    if (_inOrder != null)
+                    {
+                        foreach (var item in orderItem.InOrderDetail)
+                        {
+                            var _orderDetail = db.Queryable<InOrderDetail>().Where(c => c.S_BS_NO == orderItem.S_BS_NO && c.S_ITEM_CODE == item.S_ITEM_CODE).First();
+                            if (_orderDetail != null)
+                            {
+                                var _order = db.Queryable<InOrder>().Where(c => c.S_NO == _orderDetail.S_IO_NO).First();
+                                if (_order.N_B_STATE == 0)
+                                {
+                                    _orderDetail.S_ITEM_NAME = item.S_ITEM_NAME;
+                                    _orderDetail.F_QTY = item.F_QTY;
+                                    _orderDetail.T_MODIFY = DateTime.Now;
+                                    db.Updateable<InOrderDetail>(_orderDetail).UpdateColumns(a => new { a.S_ITEM_NAME, a.F_QTY ,a.T_MODIFY}).ExecuteCommand();
+                                }
+                            }
+                        }
+                    }
+                    else
+                    {
+                        db.Insertable(orderItem).ExecuteCommand();
+                        db.Insertable(orderItem.InOrderDetail).ExecuteCommand();
+                    }
+
+
+
+
+
+
+
+                    //if (_order != null)
+                    //{
+                    //    if (_order.N_B_STATE == 0)
+                    //    {
+                    //        foreach (var item in orderItem.InOrderDetail)
+                    //        {
+                    //        }
+                    //    }
+                    //}
+                    //else
+                    //{
+
+                    //}
+
                 }
                 db.CommitTran();
                 res = true;
@@ -594,8 +681,51 @@
                 db.BeginTran();
                 foreach (var orderItem in order)
                 {
-                    db.Insertable(orderItem).ExecuteCommand();
-                    db.Insertable(orderItem.OutOrderDetail).ExecuteCommand();
+
+                    var _outOrder = db.Queryable<OutOrder>().Where(c => c.S_NO == orderItem.S_NO).First();
+                    if (_outOrder != null)
+                    {
+                        foreach (var item in orderItem.OutOrderDetail)
+                        {
+                            var _orderDetail = db.Queryable<OutOrderDetail>().Where(c => c.S_BS_NO == orderItem.S_BS_NO && c.S_ITEM_CODE == item.S_ITEM_CODE).First();
+                            if (_orderDetail != null)
+                            {
+                                var _order = db.Queryable<OutOrder>().Where(c => c.S_NO == _orderDetail.S_OO_NO).First();
+                                if (_order.N_B_STATE == 0)
+                                {
+                                    _orderDetail.S_ITEM_NAME = item.S_ITEM_NAME;
+                                    _orderDetail.F_QTY = item.F_QTY;
+                                    _orderDetail.T_MODIFY = DateTime.Now;
+                                    db.Updateable<OutOrderDetail>(_orderDetail).UpdateColumns(a => new { a.S_ITEM_NAME, a.F_QTY,a.T_MODIFY }).ExecuteCommand();
+                                }
+                            }
+                        }
+                    }
+                    else
+                    {
+                        db.Insertable(orderItem).ExecuteCommand();
+                        db.Insertable(orderItem.OutOrderDetail).ExecuteCommand();
+                    }
+
+                    //var _order = db.Queryable<OutOrder>().Where(c => c.S_NO == orderItem.S_NO).First();
+                    //if (_order != null)
+                    //{
+                    //    if (_order.N_B_STATE == 0)
+                    //    {
+                    //        db.Updateable<OutOrder>(orderItem).UpdateColumns(a => new { a.S_OP_TYPE, a.S_BS_TYPE, a.S_NOTE, a.T_MODIFY }).ExecuteCommand();
+                    //        foreach (var item in orderItem.OutOrderDetail)
+                    //        {
+                    //            db.Updateable<InOrderDetail>(item).UpdateColumns(a => new { a.S_ITEM_CODE, a.S_ITEM_NAME, a.F_QTY }).ExecuteCommand();
+                    //        }
+                    //    }
+                    //}
+                    //else
+                    //{
+                    //    db.Insertable(orderItem).ExecuteCommand();
+                    //    db.Insertable(orderItem.OutOrderDetail).ExecuteCommand();
+                    //}
+
+
                 }
                 db.CommitTran();
                 res = true;
@@ -608,6 +738,117 @@
             }
 
         }
+
+        /// <summary>
+        /// 鍏ュ簱鍗曞彇娑�+        /// </summary>
+        /// <param name="order"></param>
+        /// <returns></returns>
+        internal static bool CancelOrderIn(InOrderCancel order)
+        {
+            try
+            {
+                bool res = false;
+                var db = new SqlHelper<object>().GetInstance();
+                db.BeginTran();
+
+                foreach (var item in order.OrderDetail)
+                {
+                    var _orderDetail = db.Queryable<InOrderDetail>().Where(c => c.S_BS_NO == order.S_BS_NO).ToList();
+                    if (_orderDetail.Any())
+                    {
+                        var orderItem = _orderDetail.FirstOrDefault(a => a.S_ITEM_CODE.Trim() == item.S_ITEM_CODE);
+                        if (orderItem != null)
+                        {
+                            var _order = db.Queryable<InOrder>().Where(c => c.S_NO == orderItem.S_IO_NO).First();
+                            if (_order.N_B_STATE == 0)
+                            {
+                                db.Deleteable<InOrderDetail>().Where(it => it.S_ITEM_CODE.Trim() == item.S_ITEM_CODE && it.S_IO_NO == orderItem.S_IO_NO).ExecuteCommand();
+                                _orderDetail.RemoveAll(s => s.S_ITEM_CODE == item.S_ITEM_CODE);
+                                if (!_orderDetail.Any())
+                                {
+                                    db.Deleteable<InOrder>().Where(it => it.S_NO == orderItem.S_IO_NO).ExecuteCommand();
+                                }
+
+                            }
+                        }
+                    }
+                }
+
+                db.CommitTran();
+                res = true;
+                return res;
+            }
+            catch (Exception ex)
+            {
+                var sugarEx = ex as SqlSugar.SqlSugarException;
+                if (sugarEx != null)
+                {
+                    LogHelper.Error($"鍙栨秷鍏ュ簱鍗昐QL閿欒: {sugarEx.Sql}", sugarEx, "鏉哀");
+                }
+                else
+                {
+                    LogHelper.Error($"鍙栨秷鍏ュ簱鍗曞け璐�{ex.Message}", ex, "鏉哀");
+                }
+                return false;
+            }
+
+        }
+
+        /// <summary>
+        /// 鍑哄簱鍗曞彇娑�+        /// </summary>
+        /// <param name="order"></param>
+        /// <returns></returns>
+        internal static bool CancelOrderOut(OutOrderCancel order)
+        {
+            try
+            {
+                bool res = false;
+                var db = new SqlHelper<object>().GetInstance();
+                db.BeginTran();
+                foreach (var item in order.OrderDetail)
+                {
+                    var _orderDetail = db.Queryable<OutOrderDetail>().Where(c => c.S_BS_NO == order.S_BS_NO).ToList();
+                    if (_orderDetail.Any())
+                    {
+                        var orderItem = _orderDetail.FirstOrDefault(a => a.S_ITEM_CODE.Trim() == item.S_ITEM_CODE);
+                        if (orderItem != null)
+                        {
+                            var _order = db.Queryable<OutOrder>().Where(c => c.S_NO == orderItem.S_OO_NO).First();
+                            if (_order.N_B_STATE == 0)
+                            {
+                                db.Deleteable<OutOrderDetail>().Where(it => it.S_ITEM_CODE.Trim() == item.S_ITEM_CODE && it.S_OO_NO == orderItem.S_OO_NO).ExecuteCommand();
+                                _orderDetail.RemoveAll(s => s.S_ITEM_CODE == item.S_ITEM_CODE);
+                                if (!_orderDetail.Any())
+                                {
+                                    db.Deleteable<OutOrder>().Where(it => it.S_NO == orderItem.S_OO_NO).ExecuteCommand();
+                                }
+                            }
+                        }
+                    }
+                }
+
+                db.CommitTran();
+                res = true;
+                return res;
+            }
+            catch (Exception ex)
+            {
+                var sugarEx = ex as SqlSugar.SqlSugarException;
+                if (sugarEx != null)
+                {
+                    LogHelper.Error($"鍙栨秷鍑哄簱鍗昐QL閿欒: {sugarEx.Sql}", sugarEx, "鏉哀");
+                }
+                else
+                {
+                    LogHelper.Error($"鍙栨秷鍑哄簱鍗曞け璐�{ex.Message}", ex, "鏉哀");
+                }
+                return false;
+            }
+
+        }
+
         #endregion
 
         #region 鏉哀鐗规畩甯姪鏂规硶
@@ -1092,7 +1333,7 @@
                                 {
                                     // 鏂规1锛氬悎骞朵换鍔★紙鐩存帴鍑哄簱澶栦晶璐т綅锛�                                     tasks.Add(CreateOutboundTask(outerLoc,
-                                        outbound.First(o => o.locCode == outerLoc.S_CODE),"1"));
+                                        outbound.First(o => o.locCode == outerLoc.S_CODE), "1"));
                                 }
                                 else
                                 {
@@ -1179,7 +1420,7 @@
                       .FirstOrDefault();
             }
 
-            private WCSTask CreateOutboundTask(Location loc, Outbound outbound,string priority = "") =>
+            private WCSTask CreateOutboundTask(Location loc, Outbound outbound, string priority = "") =>
                 new WCSTask
                 {
                     S_CODE = GenerateTaskNo(),

--
Gitblit v1.9.1