From ae6a8a95861a75ee580c75451f57e0504d2c367a Mon Sep 17 00:00:00 2001
From: kazelee <1847801760@qq.com>
Date: 星期一, 09 六月 2025 17:16:49 +0800
Subject: [PATCH] 针对ERP提供的字段,完善部分出库逻辑

---
 api/ApiHelper.cs |  441 ++++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 308 insertions(+), 133 deletions(-)

diff --git a/api/ApiHelper.cs b/api/ApiHelper.cs
index 50eb72a..2bb2e4b 100644
--- a/api/ApiHelper.cs
+++ b/api/ApiHelper.cs
@@ -32,6 +32,13 @@
             var endAreaName = AreaName.M婊$璐ф灦鍖� // 缁堢偣璐у尯
 
             try {
+                // 鍙傛暟鍚堟硶鎬х‘璁ら儴鍒嗭細閿欒缂栫爜锛�00
+                if (model.Num <= 0 ) {
+                    info = $"鐗╂枡鏁伴噺{model.Num}涓嶅悎娉曪細鐗╂枡鏁伴噺搴旇澶т簬 0";
+                    LogHelper.Info(info);
+                    return NewSimpleResult(400, info);
+                }
+
                 // 璐存爣鏈轰細鎻愬墠灏嗙墿鏂欎俊鎭啓鍏G_Detail琛ㄤ腑
                 // 灏哖DA鎻愪緵鐨勭墿鏂欑紪鐮佷笌璐存爣鏈虹殑淇℃伅姣斿
                 var cgDetail = db.Queryable<TN_CG_Detail>()
@@ -70,21 +77,44 @@
                     S_CNTR_TYPE = "濂借繍绠�,
                 };
 
-                // 姣忎釜鏂版彃鍏ュ鍣ㄧ殑閫昏緫锛岄兘闇�鏌ヨ杩欎釜琛ㄦ槸鍚﹀瓨鍦紝濡傛灉涓嶅瓨鍦ㄤ篃鍔犲叆锛屽鏋滃瓨鍦細鏆備笉鏇存柊缁撴灉锛堝緟瀹氾級
-                // 鏇磋缁嗙殑锛屾槸绌虹鍏ュ簱锛屽拰婊℃枡涓嬬嚎杩欎袱涓祦绋嬬殑瀹瑰櫒鍙兘鏄柊鐨勶紝鍏朵綑瀹瑰櫒涓�畾鏄棫鐨勶紝鏃犻渶鍐嶅垽鏂�-                // 涓ユ牸鏉ヨ锛屽鍣ㄧ被鍨嬪簲璇ユ斁鍦–ontainer閲岄潰鐨勶紝Loc_Container琛ㄥ彧鏀惧叧绯伙紝涓嶈繃鏆傛椂鍏堣繖鏍锋敼鍚�-                var cntrItemRel = db.Queryable<TN_Container_ItemType>()
-                    .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
-                var insertContainerItemType = false;
-                if (cntrItemRel == null) {
-                    insertContainerItemType = true;
-                    cntrItemRel = new TN_Container_ItemType {
-                        S_ITEM_CODE = cgDetail.S_ITEM_CODE, // 鐗╂枡绫诲瀷瀵逛簬濂借繍绠辫�瑷�叾瀹炰笉鐢紝涓昏鏄被鍨�-                        S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE,
-                        S_CNTR_CODE = locCntrRel.S_CNTR_CODE,
+                var needInsertContainer = false;
+                var needUpdateContainer = false;
+
+                // 鏌ュ鍣ㄤ俊鎭〃鏄惁宸茬粡鏈夎繖涓鍣�+                var cntr = db.Queryable<TN_Container>()
+                    .Where(c => c.S_CODE == locCntrRel.S_CNTR_CODE).First();
+                // 濡傛灉鎵句笉鍒拌瀹瑰櫒锛岄渶瑕佹坊鍔狅紝骞朵笖灏嗗鍣ㄦ潵婧愯缃负浠诲姟鍚嶇О
+                if (cntr == null) {
+                    needInsertContainer = true;
+                    LogHelper.Info($"璧风偣璐т綅鐨勫鍣細{locCntrRel.S_CNTR_CODE}锛屽湪瀹瑰櫒琛ㄤ腑娌℃湁鐧昏锛岀櫥璁板苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
+
+                    cntr = new TN_Container {
+                        S_CODE = locCntrRel.S_CNTR_CODE,
+                        S_SPEC = cgDetail.S_ITEM_CODE, // 鐧昏瀹瑰櫒瀵瑰簲鐨勭墿鏂欑紪鍙�
+                        S_TYPE = "鏂欑", // 瀹瑰櫒绫诲瀷锛氭枡绠憋紙濂借繍绠憋級
+                        S_SOURCE = taskName,
                     };
                 }
+                else {
+                    // 濡傛灉瀹瑰櫒瀛樺湪锛屼絾娌℃湁绫诲瀷鎴栨病鏈夐�鐢ㄧ殑鐗╂枡缂栧彿锛岄渶瑕佹洿鏂帮紝骞跺皢瀹瑰櫒鏉ユ簮璁剧疆涓轰换鍔″悕绉�+                    if (string.IsNullOrEmpty(cntr.S_TYPE)) {
+                        needUpdateContainer = true;
+                        LogHelper.Info($"璧风偣璐т綅鐨勫鍣細{locCntrRel.S_CNTR_CODE}锛屽湪瀹瑰櫒琛ㄤ腑鐧昏浣嗘病鏈夌被鍨嬶紝" +
+                            $"鏇存柊绫诲瀷涓猴細鏂欑锛屽苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
 
+                        cntr.S_TYPE = "鏂欑"; // 瀹瑰櫒绫诲瀷锛氭枡绠憋紙濂借繍绠憋級
+                        cntr.S_SOURCE = taskName;
+                    }
+                    if (string.IsNullOrEmpty(cntr.S_SPEC)) {
+                        needUpdateContainer = true;
+                        LogHelper.Info($"璧风偣璐т綅鐨勫鍣細{locCntrRel.S_CNTR_CODE}锛屽湪瀹瑰櫒琛ㄤ腑鐧昏浣嗘病鏈夐�鐢ㄧ墿鏂欑紪鐮侊紝" +
+                            $"鏇存柊鐗╂枡缂栫爜涓猴細{cgDetail.S_ITEM_CODE}锛屽苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
+
+                        cntr.S_SPEC = cgDetail.S_ITEM_CODE; // 瑙勬牸锛氱墿鏂欑紪鍙�+                        cntr.S_SOURCE = taskName;
+                    }
+                }
+                
                 // TODO 婊$鍏ュ簱绠楁硶寰呬紭鍖�                 var endLoc = db.Queryable<TN_Location>()
                     .Where(l => Settings.AreaMap[endAreaName].Contains(l.S_AREA_CODE)) // 缁堢偣璐у尯绗﹀悎浠诲姟瑕佹眰
@@ -99,20 +129,29 @@
                     return NewSimpleResult(4, info);
                 }
 
-                // 鏁版嵁搴撴搷浣滈儴鍒�+                
                 var cntId = locCntrRel.S_CNTR_CODE;
                 var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName);
 
                 LocationHelper.LockStartLoc(ref startLoc); // 璧风偣鍑哄簱閿�                 LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� 
+                // 鏁版嵁搴撴搷浣滀簨鍔¢儴鍒嗭細閿欒缂栫爜锛�00
                 using (var tran = db.Ado.UseTran()) {
-                    if (insertContainerItemType) {
-                        if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) {
-                            info = $"鎻掑叆瀹瑰櫒淇℃伅澶辫触锛� + JsonConvert.SerializeObject(cntrItemRel);
+                    if (needInsertContainer) {
+                        if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                            info = $"鎻掑叆瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
                             tran.RollbackTran();
                             LogHelper.Info(info);
-                            return NewSimpleResult(5, info);
+                            return NewSimpleResult(500, info);
+                        }
+                    }
+                    else if (needUpdateContainer) {
+                        if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                            info = $"鏇存柊瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
+                            tran.RollbackTran();
+                            LogHelper.Info(info);
+                            return NewSimpleResult(500, info);
                         }
                     }
 
@@ -120,7 +159,7 @@
                         info = $"鎻掑叆璐т綅瀹瑰櫒鍏崇郴澶辫触锛� + JsonConvert.SerializeObject(locCntrRel);
                         tran.RollbackTran();
                         LogHelper.Info(info);
-                        return NewSimpleResult(5, info);
+                        return NewSimpleResult(500, info);
                     }
 
                     if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
@@ -133,7 +172,7 @@
                         tran.RollbackTran();
                         info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂拌捣鐐硅揣浣峽startLoc.S_CODE}閿佺姸鎬佸け璐�;
                         LogHelper.Info(info);
-                        return NewSimpleResult(5, info);
+                        return NewSimpleResult(500, info);
                     }
 
                     if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
@@ -145,14 +184,14 @@
                         tran.RollbackTran();
                         info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛氭洿鏂扮粓鐐硅揣浣峽endLoc.S_CODE}閿佺姸鎬佸け璐�;
                         LogHelper.Info(info);
-                        return NewSimpleResult(5, info);
+                        return NewSimpleResult(500, info);
                     }
                     
                     if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
                         tran.RollbackTran();
                         info = $"鐢熸垚浠诲姟'{taskName}'澶辫触锛屽鍣ㄥ彿{cntId}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐硅揣鏋秢endLoc.S_CODE}";
                         LogHelper.Info(info);
-                        return NewSimpleResult(5, info);
+                        return NewSimpleResult(500, info);
                     }
 
                     tran.CommitTran();
@@ -175,7 +214,7 @@
         /// 浜哄伐灏嗙┖鎵樼洏閫氳繃鎺ラ┏浣嶅叆搴擄紝闇�鏂扮粦瀹氬鍣ㄨ揣浣�br/>
         /// 鐢变簬绌烘墭鐩樹竴鑸槸鍑哄簱鍗歌揣鍚庤幏寰楋紝鑰屽嚭搴撴椂娌℃湁鎵嬪姩鍗歌揣鐨勯�杈戯紝鎵�互闇�鍦ㄥ叆搴撶殑鏃跺�鍐嶅垹闄ゆ棫缁戝畾淇℃伅
         /// </remarks>
-        /// <param name="model"></param>
+        /// <param name="model">鍖呭惈锛氳捣鐐硅揣浣嶃�瀹瑰櫒鍙枫�瀹瑰櫒绫诲瀷銆佺粓鐐硅揣鍖�/param>
         /// <returns></returns>
         public static SimpleResult EmptyInboundPallet(EmptyInboundInfo model) {
             var db = new SqlHelper<object>().GetInstance();
@@ -209,7 +248,6 @@
                 var locCntrRelOld = db.Queryable<TN_Loc_Container>()
                     .Where(c => c.S_CNTR_CODE == model.CntrCode).First();
 
-                //var locOld = new TN_Location();
                 TN_Location locOld = null;
                 if (locCntrRelOld != null) { // 濡傛灉闇�瑙g粦瀹瑰櫒璐т綅锛屼篃闇�淇敼璐т綅淇℃伅
                     locOld = db.Queryable<TN_Location>()
@@ -218,9 +256,6 @@
                         locOld.N_CURRENT_NUM = 0; // 濡傛灉鏃ц揣浣嶅瓨鍦紝灏嗘棫璐т綅鐨勬暟閲忚缃负 0
                     }
                 }
-                //else {
-                //    locOld = null;
-                //}
 
                 // 缁戝畾璐т綅鍜屽鍣ㄥ彿锛圥DA鍦ㄦ帴椹充綅缁戝畾锛�                 var locCntrRel = new TN_Loc_Container {
@@ -229,19 +264,34 @@
                     S_CNTR_TYPE = "鎵樼洏",
                 };
 
-                // 姣忎釜鏂版彃鍏ュ鍣ㄧ殑閫昏緫锛岄兘闇�鏌ヨ杩欎釜琛ㄦ槸鍚﹀瓨鍦紝濡傛灉涓嶅瓨鍦ㄤ篃鍔犲叆锛屽鏋滃瓨鍦細鏆備笉鏇存柊缁撴灉锛堝緟瀹氾級
-                // 鏇磋缁嗙殑锛屾槸绌虹鍏ュ簱锛屽拰婊℃枡涓嬬嚎杩欎袱涓祦绋嬬殑瀹瑰櫒鍙兘鏄柊鐨勶紝鍏朵綑瀹瑰櫒涓�畾鏄棫鐨勶紝鏃犻渶鍐嶅垽鏂�-                // 涓ユ牸鏉ヨ锛屽鍣ㄧ被鍨嬪簲璇ユ斁鍦–ontainer閲岄潰鐨勶紝Loc_Container琛ㄥ彧鏀惧叧绯伙紝涓嶈繃鏆傛椂鍏堣繖鏍锋敼鍚�-                var cntrItemRel = db.Queryable<TN_Container_ItemType>()
-                    .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
-                var insertContainerItemType = false;
-                if (cntrItemRel == null) {
-                    insertContainerItemType = true;
-                    cntrItemRel = new TN_Container_ItemType {
-                        S_ITEM_CODE = "", // 绌烘墭鐩樺垰鍏ュ簱锛屾病鏈夌墿鏂欑被鍨嬶紝灏遍粯璁ゅ厛涓虹┖
-                        S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE,
-                        S_CNTR_CODE = locCntrRel.S_CNTR_CODE,
+                var needInsertContainer = false;
+                var needUpdateContainer = false;
+
+                // 鏌ュ鍣ㄤ俊鎭〃鏄惁宸茬粡鏈夎繖涓鍣�+                var cntr = db.Queryable<TN_Container>()
+                    .Where(c => c.S_CODE == locCntrRel.S_CNTR_CODE).First();
+                // 濡傛灉鎵句笉鍒拌瀹瑰櫒锛岄渶瑕佹坊鍔狅紝骞朵笖灏嗗鍣ㄦ潵婧愯缃负浠诲姟鍚嶇О
+                if (cntr == null) {
+                    needInsertContainer = true;
+                    LogHelper.Info($"璧风偣璐т綅鐨勫鍣細{locCntrRel.S_CNTR_CODE}锛屽湪瀹瑰櫒琛ㄤ腑娌℃湁鐧昏锛岀櫥璁板苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
+
+                    cntr = new TN_Container {
+                        S_CODE = locCntrRel.S_CNTR_CODE,
+                        S_SPEC = "", // 绌烘墭锛岀墿鏂欑紪鐮佸厛璁剧疆涓虹┖
+                        S_TYPE = locCntrRel.S_CNTR_TYPE, // 瀹瑰櫒绫诲瀷锛氭墭鐩�+                        S_SOURCE = taskName,
                     };
+                }
+                else {
+                    // 濡傛灉瀹瑰櫒瀛樺湪锛屼絾娌℃湁绫诲瀷鎴栨病鏈夐�鐢ㄧ殑鐗╂枡缂栧彿锛岄渶瑕佹洿鏂帮紝骞跺皢瀹瑰櫒鏉ユ簮璁剧疆涓轰换鍔″悕绉�+                    if (string.IsNullOrEmpty(cntr.S_TYPE)) {
+                        needUpdateContainer = true;
+                        LogHelper.Info($"璧风偣璐т綅鐨勫鍣細{locCntrRel.S_CNTR_CODE}锛屽湪瀹瑰櫒琛ㄤ腑鐧昏浣嗘病鏈夌被鍨嬶紝" +
+                            $"鏇存柊绫诲瀷涓猴細鎵樼洏锛屽苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
+
+                        cntr.S_TYPE = "鎵樼洏"; // 瀹瑰櫒绫诲瀷锛氭墭鐩�+                    }
+                    // 绌烘墭涓嶆洿鏂扮墿鏂欑紪鐮�                 }
 
                 // TODO 鏆傚畾閫夋嫨鏈�綆灞傛寜鍖轰綅椤哄簭鍏ュ簱锛屽悗闈㈠緟淇敼
@@ -265,12 +315,20 @@
                 LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� 
                 using (var tran = db.Ado.UseTran()) {
-                    if (insertContainerItemType) {
-                        if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) {
-                            info = $"鎻掑叆瀹瑰櫒淇℃伅澶辫触锛� + JsonConvert.SerializeObject(cntrItemRel);
+                    if (needInsertContainer) {
+                        if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                            info = $"鎻掑叆瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
                             tran.RollbackTran();
                             LogHelper.Info(info);
-                            return NewSimpleResult(5, info);
+                            return NewSimpleResult(500, info);
+                        }
+                    }
+                    else if (needUpdateContainer) {
+                        if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                            info = $"鏇存柊瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
+                            tran.RollbackTran();
+                            LogHelper.Info(info);
+                            return NewSimpleResult(500, info);
                         }
                     }
 
@@ -391,7 +449,6 @@
                 var locCntrRelOld = db.Queryable<TN_Loc_Container>()
                     .Where(c => c.S_CNTR_CODE == model.CntrCode).First();
 
-                //var locOld = new TN_Location();
                 TN_Location locOld = null;
                 if (locCntrRelOld != null) { // 濡傛灉闇�瑙g粦瀹瑰櫒璐т綅锛屼篃闇�淇敼璐т綅淇℃伅
                     locOld = db.Queryable<TN_Location>()
@@ -400,9 +457,6 @@
                         locOld.N_CURRENT_NUM = 0; // 濡傛灉鏃ц揣浣嶅瓨鍦紝灏嗘棫璐т綅鐨勬暟閲忚缃负 0
                     }
                 }
-                //else {
-                //    locOld = null;
-                //}
 
                 // 缁戝畾璐т綅鍜屽鍣ㄥ彿
                 var locCntrRel = new TN_Loc_Container {
@@ -411,19 +465,34 @@
                     S_CNTR_TYPE = "濂借繍绠�,
                 };
 
-                // 姣忎釜鏂版彃鍏ュ鍣ㄧ殑閫昏緫锛岄兘闇�鏌ヨ杩欎釜琛ㄦ槸鍚﹀瓨鍦紝濡傛灉涓嶅瓨鍦ㄤ篃鍔犲叆锛屽鏋滃瓨鍦細鏆備笉鏇存柊缁撴灉锛堝緟瀹氾級
-                // 鏇磋缁嗙殑锛屾槸绌虹鍏ュ簱锛屽拰婊℃枡涓嬬嚎杩欎袱涓祦绋嬬殑瀹瑰櫒鍙兘鏄柊鐨勶紝鍏朵綑瀹瑰櫒涓�畾鏄棫鐨勶紝鏃犻渶鍐嶅垽鏂�-                // 涓ユ牸鏉ヨ锛屽鍣ㄧ被鍨嬪簲璇ユ斁鍦–ontainer閲岄潰鐨勶紝Loc_Container琛ㄥ彧鏀惧叧绯伙紝涓嶈繃鏆傛椂鍏堣繖鏍锋敼鍚�-                var cntrItemRel = db.Queryable<TN_Container_ItemType>()
-                    .Where(c => c.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
-                var insertContainerItemType = false;
-                if (cntrItemRel == null) {
-                    insertContainerItemType = true;
-                    cntrItemRel = new TN_Container_ItemType {
-                        S_ITEM_CODE = "", // 绌烘墭鐩樺垰鍏ュ簱锛屾病鏈夌墿鏂欑被鍨嬶紝灏遍粯璁ゅ厛涓虹┖
-                        S_CNTR_TYPE = locCntrRel.S_CNTR_TYPE,
-                        S_CNTR_CODE = locCntrRel.S_CNTR_CODE,
+                var needInsertContainer = false;
+                var needUpdateContainer = false;
+
+                // 鏌ュ鍣ㄤ俊鎭〃鏄惁宸茬粡鏈夎繖涓鍣�+                var cntr = db.Queryable<TN_Container>()
+                    .Where(c => c.S_CODE == locCntrRel.S_CNTR_CODE).First();
+                // 濡傛灉鎵句笉鍒拌瀹瑰櫒锛岄渶瑕佹坊鍔狅紝骞朵笖灏嗗鍣ㄦ潵婧愯缃负浠诲姟鍚嶇О
+                if (cntr == null) {
+                    needInsertContainer = true;
+                    LogHelper.Info($"璧风偣璐т綅鐨勫鍣細{locCntrRel.S_CNTR_CODE}锛屽湪瀹瑰櫒琛ㄤ腑娌℃湁鐧昏锛岀櫥璁板苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
+
+                    cntr = new TN_Container {
+                        S_CODE = locCntrRel.S_CNTR_CODE,
+                        S_SPEC = "", // 绌虹锛岀墿鏂欑紪鐮佸厛璁剧疆涓虹┖
+                        S_TYPE = locCntrRel.S_CNTR_TYPE, // 瀹瑰櫒绫诲瀷锛氭枡绠憋紙濂借繍绠憋級
+                        S_SOURCE = taskName,
                     };
+                }
+                else {
+                    // 濡傛灉瀹瑰櫒瀛樺湪锛屼絾娌℃湁绫诲瀷鎴栨病鏈夐�鐢ㄧ殑鐗╂枡缂栧彿锛岄渶瑕佹洿鏂帮紝骞跺皢瀹瑰櫒鏉ユ簮璁剧疆涓轰换鍔″悕绉�+                    if (string.IsNullOrEmpty(cntr.S_TYPE)) {
+                        needUpdateContainer = true;
+                        LogHelper.Info($"璧风偣璐т綅鐨勫鍣細{locCntrRel.S_CNTR_CODE}锛屽湪瀹瑰櫒琛ㄤ腑鐧昏浣嗘病鏈夌被鍨嬶紝" +
+                            $"鏇存柊绫诲瀷涓猴細鏂欑锛屽苟璁剧疆瀹瑰櫒鏉ユ簮涓猴細{taskName}");
+
+                        cntr.S_TYPE = "鏂欑"; // 瀹瑰櫒绫诲瀷锛氭枡绠憋紙濂借繍绠憋級
+                    }
+                    // 绌虹涓嶆洿鏂扮墿鏂欑紪鐮�                 }
 
                 // TODO 鏆傚畾閫夋嫨鏈�綆灞傞『搴忓叆搴擄紝鍚庨潰寰呬慨鏀�@@ -447,12 +516,20 @@
                 LocationHelper.LockEndLoc(ref endLoc); // 缁堢偣鍏ュ簱閿� 
                 using (var tran = db.Ado.UseTran()) {
-                    if (insertContainerItemType) {
-                        if (db.Insertable<TN_Container_ItemType>(cntrItemRel).ExecuteCommand() <= 0) {
-                            info = $"鎻掑叆瀹瑰櫒淇℃伅澶辫触锛� + JsonConvert.SerializeObject(cntrItemRel);
+                    if (needInsertContainer) {
+                        if (db.Insertable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                            info = $"鎻掑叆瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
                             tran.RollbackTran();
                             LogHelper.Info(info);
-                            return NewSimpleResult(5, info);
+                            return NewSimpleResult(500, info);
+                        }
+                    }
+                    else if (needUpdateContainer) {
+                        if (db.Updateable<TN_Container>(cntr).ExecuteCommand() <= 0) {
+                            info = $"鏇存柊瀹瑰櫒琛ㄥけ璐ワ細" + JsonConvert.SerializeObject(cntr);
+                            tran.RollbackTran();
+                            LogHelper.Info(info);
+                            return NewSimpleResult(500, info);
                         }
                     }
 
@@ -540,7 +617,7 @@
         /// <remarks>
         /// 浜哄伐鏍规嵁褰撳墠鐢熶骇鐗╂枡鎵�渶鐨勫鍣ㄧ被鍨嬶紝鍛煎彨AGV浠庣┖瀹瑰櫒璐ф灦涓彨涓�釜绗﹀悎瑕佹眰鐨勬墭鐩�         /// </remarks>
-        /// <param name="model"></param>
+        /// <param name="model">b鍖呭惈锛氬鍣ㄥ彿銆佺墿鏂欑紪鐮�/param>
         /// <returns></returns>
         public static SimpleResult EmptyOnlinePallet(EmptyOnlinePalletInfo model) {
             var db = new SqlHelper<object>().GetInstance();
@@ -551,16 +628,24 @@
             var endAreaName = AreaName.B鍖呰鍖�
 
             try {
-                // 鏌ュ鍣�鐗╂枡绫诲瀷琛�-                var cntrItemRel = db.Queryable<TN_Container_ItemType>()
-                    .Where(i => i.S_CNTR_CODE == model.CntId && i.S_CNTR_TYPE == "鎵樼洏")
-                    .First();
-                // 濡傛灉琛ㄤ腑瀛樺湪杩欎釜鎵樼洏淇℃伅锛屼笖鐗╂枡绫诲瀷涓庝笂绾挎墍闇�墿鏂欎笉绗︼紝鎶ラ敊
+                // 鏌ュ鍣ㄤ俊鎭〃鏄惁宸茬粡鏈夎繖涓鍣�+                var cntr = db.Queryable<TN_Container>()
+                    .Where(c => c.S_CODE == model.CntId).First();
+                // 濡傛灉琛ㄤ腑瀛樺湪杩欎釜鎵樼洏淇℃伅锛屼絾瀹瑰櫒绫诲瀷銆佺墿鏂欑被鍨嬩笌涓婄嚎鎵�渶鐗╂枡涓嶇锛屾姤閿�                 // 濡傛灉涓嶅瓨鍦紝涓嶄綔闄愬埗锛堣浣滅涓�涓婄嚎锛�-                if (cntrItemRel != null && cntrItemRel.S_ITEM_CODE != model.ItemCode) {
-                    info = $"瀹瑰櫒{model.CntId}宸茬粡涓庣墿鏂欑被鍨媨cntrItemRel.S_ITEM_CODE}缁戝畾锛屾棤娉曠敤浜庤杞界墿鏂檣model.ItemCode}";
-                    LogHelper.Info(info);
-                    return NewSimpleResult(2, info);
+                if (cntr != null) { 
+                    // 濡傛灉瀛樺湪瀹瑰櫒鍙凤紝浣嗙被鍨嬩笉鏄墭鐩橈紝鎶ラ敊
+                    if (!string.IsNullOrEmpty(cntr.S_TYPE) && cntr.S_TYPE != "鎵樼洏") {
+                        info = $"瀹瑰櫒鍦ㄥ鍣ㄨ〃涓壘鍒帮紝浣嗙被鍨嬫槸锛歿cntr.S_TYPE}锛屼笉鏄瘂taskName}鎵�渶鐨勶細鎵樼洏";
+                        LogHelper.Info(info);
+                        return NewSimpleResult(1, info);
+                    }
+                    // 濡傛灉琛ㄤ腑鐗╂枡缂栫爜涓嶄负绌猴紝涓斾笌涓婄嚎鎵�渶鐗╂枡涓嶄竴鑷达紝鎶ラ敊
+                    if (!string.IsNullOrEmpty(cntr.S_SPEC) && cntr.S_SPEC != model.ItemCode) {
+                        info = $"瀹瑰櫒{model.CntId}宸茬粡涓庣墿鏂欑被鍨媨cntr.S_SPEC}缁戝畾锛屾棤娉曠敤浜庤杞界墿鏂檣model.ItemCode}";
+                        LogHelper.Info(info);
+                        return NewSimpleResult(2, info);
+                    }
                 }
 
                 var startLoc = db.Queryable<TN_Location>()
@@ -650,7 +735,7 @@
             var info = "";
 
             var taskName = TaskName.H濂借繍绠盻绌虹涓婄嚎;
-            var startAreaName = AreaName.K绌烘墭瀛樻斁鍖�
+            var startAreaName = AreaName.K绌虹璐ф灦鍖�
             var endAreaName = AreaName.K绌虹鎿嶄綔鍖�
 
             try {
@@ -750,12 +835,20 @@
                     .First();
 
                 if (cgDetail == null) {
-                    return NewSimpleResult(2, "娌℃湁鎵惧埌寰呭洖搴撶殑鎶芥鐗╂枡锛� + JsonConvert.SerializeObject(model));
+                    info = "娌℃湁鎵惧埌寰呭洖搴撶殑鎶芥鐗╂枡锛� + JsonConvert.SerializeObject(model);
+                    LogHelper.Info(info);
+                    return NewSimpleResult(2, info);
                 }
 
                 var locCntrRel = db.Queryable<TN_Loc_Container>()
                     .Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE)
                     .First();
+
+                if (locCntrRel == null) {
+                    info = $"瀹瑰櫒{model.CntrCode}鍦ㄨ揣浣嶅鍣ㄥ叧绯昏〃涓笉瀛樺湪";
+                    LogHelper.Info(info);
+                    return NewSimpleResult(3, info);
+                }
 
                 var startLoc = db.Queryable<TN_Location>()
                     .Where(l => l.S_CODE == locCntrRel.S_LOC_CODE)
@@ -767,7 +860,7 @@
                 if (startLoc == null) {
                     info = $"鍦�{startAreaName}'涓病鏈夋壘鍒板鍣▄model.CntrCode}鐨勮捣鐐硅揣浣嶏紝鎴栦笉鍏峰鍙栬揣瑕佹眰锛氭湭涓婇攣銆佹湁璐х墿";
                     LogHelper.Info(info);
-                    return NewSimpleResult(0, info);
+                    return NewSimpleResult(4, info);
                 }
 
                 var endLoc = new TN_Location();
@@ -786,7 +879,7 @@
                         .First();
                 }
                 else {
-                    return NewSimpleResult(2, $"鎵樼洏绫诲瀷{locCntrRel.S_CNTR_TYPE}涓嶅悎娉曪細鎵樼洏鍙穥locCntrRel.S_CNTR_CODE}");
+                    return NewSimpleResult(-1, $"鎵樼洏绫诲瀷{locCntrRel.S_CNTR_TYPE}涓嶅悎娉曪細鎵樼洏鍙穥locCntrRel.S_CNTR_CODE}");
                 }
 
                 if (endLoc == null) {
@@ -889,11 +982,11 @@
                     .Where(c => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE)
                     .First();
 
-                //var startLoc = db.Queryable<TN_Location>()
-                //    .LeftJoin<TN_Loc_Container>((l, c) => l.S_CODE == c.S_LOC_CODE)
-                //    .Where((l, c) => c.S_CNTR_CODE == cgDetail.S_CNTR_CODE) // 鎸囧畾瀹瑰櫒鍙�-                //    .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y") // 绛涢�锛氭湭涓婇攣
-                //    .First();
+                if (locCntrRel == null) {
+                    info = $"瀹瑰櫒{model.CntrCode}鍦ㄨ揣浣嶅鍣ㄥ叧绯昏〃涓笉瀛樺湪";
+                    LogHelper.Info(info);
+                    return NewSimpleResult(3, info);
+                }
 
                 var startLoc = db.Queryable<TN_Location>()
                     .Where(l => l.S_CODE == locCntrRel.S_LOC_CODE)
@@ -1321,12 +1414,33 @@
             var info = "";
 
             try {
+                if (string.IsNullOrEmpty(model.ItemCode)) {
+                    info = $"鍗氬疄涓嬪彂鐗╂枡淇℃伅锛氬弬鏁颁笉鍚堟硶锛氱墿鏂欑紪鐮侊紙itemCode锛変笉鑳戒负绌�;
+                    LogHelper.Info(info);
+                    return NewMesResult(400, info);
+                }
+                if (string.IsNullOrEmpty(model.CntrCode)) {
+                    info = $"鍗氬疄涓嬪彂鐗╂枡淇℃伅锛氬弬鏁颁笉鍚堟硶锛氬鍣ㄧ紪鐮侊紙CntrCode锛変笉鑳戒负绌�;
+                    LogHelper.Info(info);
+                    return NewMesResult(400, info);
+                }
+                if (string.IsNullOrEmpty(model.BatchNo)) {
+                    info = $"鍗氬疄涓嬪彂鐗╂枡淇℃伅锛氬弬鏁颁笉鍚堟硶锛氭壒娆″彿锛圔atchNo锛変笉鑳戒负绌�;
+                    LogHelper.Info(info);
+                    return NewMesResult(400, info);
+                }
+                if (model.ItemNum <= 0) {
+                    info = $"鍗氬疄涓嬪彂鐗╂枡淇℃伅锛氬弬鏁颁笉鍚堟硶锛氳揣鍝佹暟閲忥紙ItemNum锛夊簲璇ュぇ浜�0";
+                    LogHelper.Info(info);
+                    return NewMesResult(400, info);
+                }
+
                 // 灏嗕笅鍙戠殑淇℃伅鍏堝瓨鍌ㄥ埌CG琛ㄤ腑锛堟鏃舵墭鐩樻病鏈変笌浜х嚎澶勭殑璐т綅缁戝畾锛�                 var detail = new TN_CG_Detail {
-                    S_ITEM_CODE = model.ItemCode,
-                    S_ITEM_NAME = model.ItemName,
-                    S_CNTR_CODE = model.CntrCode, // 鏂欑缂栧彿锛堝緟瀹氾紝鐜板湪鏆傛椂璁惧畾涓哄崥瀹炰笅鍙戯級
-                    S_BATCH_NO = model.BatchNo,
+                    S_ITEM_CODE = model.ItemCode, // NOT NULL
+                    S_ITEM_NAME = model.ItemName, 
+                    S_CNTR_CODE = model.CntrCode, // NOT NULL 鏂欑缂栧彿锛堝緟瀹氾紝鐜板湪鏆傛椂璁惧畾涓哄崥瀹炰笅鍙戯級
+                    S_BATCH_NO = model.BatchNo,   // NOT NULL
                     S_STANDARD = model.Standard,
                     S_NET_WEIGHT = model.NetWeight,
                     S_QUALITY_GRADE = model.QualityGrade,
@@ -1349,7 +1463,7 @@
                     if (db.Insertable<TN_CG_Detail>(detail).ExecuteCommand() <= 0) {
                         tran.RollbackTran();
                         info = "鎻掑叆鐗╂枡淇℃伅澶辫触锛� + JsonConvert.SerializeObject(detail);
-                        return NewMesResult(2, info);
+                        return NewMesResult(500, info);
                     }
 
                     tran.CommitTran();
@@ -1365,7 +1479,7 @@
             }
         }
 
-        public static ErpResult ErpSendOutboundOrder(ErpSendOutboundOrderInfo model) {
+        public static ErpResult ErpSendOutboundPlan(ErpSendOutboundPlanInfo model) {
             var db = new SqlHelper<object>().GetInstance();
             var orderNo = GenerateOrderNo("鍑哄簱鍗曞彿", "ON");
             var info = "";
@@ -1376,59 +1490,120 @@
                     return NewErpResult(2, info);
                 }
 
-                var cgDetailList = SelectCgByTotalQty(new FinishedOutboundInfo {
-                    BatchNo = model.BatchNo,
-                    CntrType= model.CntrType,
-                    ItemCode= model.ItemCode,
-                    EndArea= model.EndArea,
-                    ForcedOut= model.ForcedOut,
-                    Qty= model.Qty,
-                    Spe = model.Spe
-                });
-
-                if (cgDetailList.Count == 0) {
-                    info = "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ュ嚭搴�;
-                    LogHelper.Info(info);
-                    return NewErpResult(3, info);
-                }
-
-                var order = new TN_Outbound_Order {
-                    S_NO = orderNo,
-                    S_ITEM_CODE = model.ItemCode,
-                    S_BATCH = model.BatchNo,
-                    N_END_NUM = model.Qty,
-                    //F_OUT_QTY = cgDetailList.Sum(a => a.N_QTY),
-                    S_END_AREA = model.EndArea,
-                    S_BS_NO = model.ErpNo,
-                    S_BS_TYPE = "ERP",
+                var outboundPlan = new TN_Outbound_Plan {
+                    jhdh = model.jhdh,
+                    ckzt = model.ckzt,
+                    jhlb = model.jhlb,
+                    ckdh = model.ckdh,
+                    cph = model.cph,
+                    ysfs = model.ysfs,
+                    cpzt = model.cpzt,
+                    mddw = model.mddw,
+                    cpdm = model.cpdm,
+                    cplb = model.cplb,
+                    cplbmx = model.cplbmx,
+                    pp = model.pp,
+                    dj = model.dj,
+                    gh = model.gh,
+                    ph = model.ph,
+                    bzlx = model.bzlx,
+                    pzdh = model.pzdh,
+                    pzd_dw = model.pzd_dw,
+                    pzd_dybh = model.pzd_dybh,
+                    pzjs = model.pzjs,
+                    pzsl = model.pzsl,
+                    pz_rq = model.pz_rq,
+                    pz_czrq = model.pz_czrq,
+                    pz_zfbj = model.pz_zfbj,
+                    pz_zfrq = model.pz_zfrq,
+                    pz_bz = model.pz_bz,
+                    ckdbh = model.ckdbh,
+                    sfjs = model.sfjs,
+                    sfsl = model.sfsl,
+                    sfcs = model.sfcs,
+                    zcsj = model.zcsj,
+                    jldw = model.jldw,
+                    fhrq = model.fhrq,
+                    ckdm = model.ckdm,
+                    fhr = model.fhr,
+                    czydm = model.czydm,
+                    shr_username = model.shr_username,
+                    shrq = model.shrq,
+                    zfbj = model.zfbj,
+                    zfrq = model.zfrq,
+                    jsdw = model.jsdw,
+                    shdw = model.shdw,
+                    ysdw = model.ysdw,
+                    lxr = model.lxr,
+                    ry_zxg = model.ry_zxg,
+                    ry_ccsj = model.ry_ccsj,
+                    erphx_jhdh = model.erphx_jhdh,
+                    erphx_wlbm = model.erphx_wlbm,
+                    erphx_wlmc = model.erphx_wlmc,
+                    erphx_cjrq = model.erphx_cjrq,
+                    hw = model.hw,
+                    hwzt = model.hwzt
                 };
 
-                var detailList = new List<TN_Outbound_Detail>();
-                foreach (var cgDetail in cgDetailList) {
-                    var detail = new TN_Outbound_Detail {
-                        S_OO_NO = orderNo,
-                        S_ITEM_CODE = cgDetail.S_ITEM_CODE,
-                        S_BATCH_NO = cgDetail.S_BATCH_NO,
-                        S_CNTR_CODE = cgDetail.S_CNTR_CODE,
-                        N_COUNT = cgDetail.N_ITEM_NUM,
-                        S_END_AREA = model.EndArea
-                    };
-                    detailList.Add(detail);
-                }
+                //var cgDetailList = SelectCgByTotalQty(new FinishedOutboundInfo {
+                //    BatchNo = model.BatchNo,
+                //    CntrType= model.CntrType,
+                //    ItemCode= model.ItemCode,
+                //    EndArea= model.EndArea,
+                //    ForcedOut= model.ForcedOut,
+                //    Qty= model.Qty,
+                //    Spe = model.Spe
+                //});
+
+                //if (cgDetailList.Count == 0) {
+                //    info = "娌℃湁鍚堥�鐨勭墿鏂欏彲浠ュ嚭搴�;
+                //    LogHelper.Info(info);
+                //    return NewErpResult(3, info);
+                //}
+
+                //var order = new TN_Outbound_Order {
+                //    S_NO = orderNo,
+                //    S_ITEM_CODE = model.ItemCode,
+                //    S_BATCH = model.BatchNo,
+                //    N_END_NUM = model.Qty,
+                //    //F_OUT_QTY = cgDetailList.Sum(a => a.N_QTY),
+                //    S_END_AREA = model.EndArea,
+                //    S_BS_NO = model.ErpNo,
+                //    S_BS_TYPE = "ERP",
+                //};
+
+                //var detailList = new List<TN_Outbound_Detail>();
+                //foreach (var cgDetail in cgDetailList) {
+                //    var detail = new TN_Outbound_Detail {
+                //        S_OO_NO = orderNo,
+                //        S_ITEM_CODE = cgDetail.S_ITEM_CODE,
+                //        S_BATCH_NO = cgDetail.S_BATCH_NO,
+                //        S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+                //        N_COUNT = cgDetail.N_ITEM_NUM,
+                //        S_END_AREA = model.EndArea
+                //    };
+                //    detailList.Add(detail);
+                //}
 
                 using (var tran = db.Ado.UseTran()) {
-                    if (db.Insertable<TN_Outbound_Order>(order).ExecuteCommand() <= 0) {
-                        tran.RollbackTran();
-                        info = "鐢熸垚鍑哄簱鍗曞け璐ワ細" + JsonConvert.SerializeObject(order);
-                        LogHelper.Info(info);
-                        return NewErpResult(2, info);
-                    }
+                    //if (db.Insertable<TN_Outbound_Order>(order).ExecuteCommand() <= 0) {
+                    //    tran.RollbackTran();
+                    //    info = "鐢熸垚鍑哄簱鍗曞け璐ワ細" + JsonConvert.SerializeObject(order);
+                    //    LogHelper.Info(info);
+                    //    return NewErpResult(2, info);
+                    //}
 
-                    if (db.Insertable<TN_Outbound_Detail>(detailList).ExecuteCommand() <= 0) {
+                    //if (db.Insertable<TN_Outbound_Detail>(detailList).ExecuteCommand() <= 0) {
+                    //    tran.RollbackTran();
+                    //    info = "鐢熸垚鍑哄簱鍗曟槑缁嗗け璐�;
+                    //    LogHelper.Info(info);
+                    //    return NewErpResult(4, info);
+                    //}
+                    if (db.Insertable<TN_Outbound_Plan>(outboundPlan).ExecuteCommand() <= 0) {
                         tran.RollbackTran();
-                        info = "鐢熸垚鍑哄簱鍗曟槑缁嗗け璐�;
+                        info = "鐢熸垚鍑哄簱鍗曡鍒掕褰曡〃澶辫触";
                         LogHelper.Info(info);
-                        return NewErpResult(4, info);
+                        return NewErpResult(500, info);
                     }
 
                     tran.CommitTran();

--
Gitblit v1.9.1