From b183905d45e279eca8a845f532fc2d2edd540edb Mon Sep 17 00:00:00 2001
From: kazelee <1847801760@qq.com>
Date: 星期四, 10 七月 2025 17:27:42 +0800
Subject: [PATCH] 重构盘点单表结构，修复部分盘点逻辑
---
api/ApiHelper.cs | 1107 ++++++++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 885 insertions(+), 222 deletions(-)
diff --git a/api/ApiHelper.cs b/api/ApiHelper.cs
index e01d92b..10aca34 100644
--- a/api/ApiHelper.cs
+++ b/api/ApiHelper.cs
@@ -3,9 +3,15 @@
using System.Linq;
using System.Text;
using System.Threading.Tasks;
+
+using HH.WCS.Mobox3.AnGang.dispatch;
using HH.WCS.Mobox3.AnGang.models;
using HH.WCS.Mobox3.AnGang.util;
using HH.WCS.Mobox3.AnGang.wms;
+
+using Newtonsoft.Json;
+
+using Swashbuckle.Swagger;
using static HH.WCS.Mobox3.AnGang.api.ApiModel;
using static HH.WCS.Mobox3.AnGang.api.OtherModel;
@@ -21,18 +27,31 @@
var taskName = TaskName.浜у搧鍏ュ簱;
var db = new SqlHelper<object>().GetInstance();
+ var startAreas = Settings.Areas[AreaIndex.Q鍙栬揣鍖篯;
+
try {
// 璧风偣浣嶇疆蹇呴』锛氫负绌恒�鏃犻攣銆佸惎鐢ㄣ�灞炰簬鏀跺彂鍖哄煙
var startLoc = db.Queryable<TN_Location>()
.Where(a => a.S_CODE == model.StartLoc)
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y")
.Where(a => a.N_CURRENT_NUM == 0)
- .Where(a => Settings.Areas[0].Contains(a.S_AREA_CODE)) // 鏀跺彂鍖�+ .Where(a => startAreas.Contains(a.S_AREA_CODE))
.First();
if (startLoc == null) {
- return BuildSimpleResult(1, $"璧风偣浣嶇疆{model.StartLoc}涓嶅瓨鍦ㄦ垨涓嶆弧瓒宠姹傦細闇�锛�锛夋病鏈夐攣鐘舵�锛�锛夊綋鍓嶆棤瀹瑰櫒锛�锛夊睘浜庡彇鏀捐揣鍖�);
+ return BuildSimpleResult(1, $"璧风偣浣嶇疆{model.StartLoc}涓嶅瓨鍦ㄦ垨涓嶆弧瓒宠姹傦細(1)娌℃湁閿佺姸鎬�(2)灞炰簬鍙栨斁璐у尯");
}
+
+ //var locCntrRelOld = db.Queryable<TN_Loc_Container>()
+ // .Where(c => c.S_LOC_CODE == model.StartLoc).First();
+
+ //// 浜у搧鍏ュ簱锛氬亣瀹氱敤鎴蜂笉浼氬皢鏂板叆搴撶墿鏂欙紝鏀惧埌宸叉湁鐗╂枡鐨勬敹鍙戣揣鍖哄叆搴�+ //// 鏂颁骇鍝佸叆搴撴椂锛屽鏋滃瓨鍦ㄦ棫鐨勮揣浣嶇粦瀹氭暟鎹紙鍑哄簱閬楃暀椤圭洰锛夌洿鎺ュ垹闄�+ //TN_CG_Detail cgDetailOld = null;
+ //if (locCntrRelOld != null) {
+ // cgDetailOld = db.Queryable<TN_CG_Detail>()
+ // .Where(d => d.S_CNTR_CODE == locCntrRelOld.S_CNTR_CODE).First();
+ //}
// 瀹瑰櫒 ID 鍜�鐗╂枡 ID 鏈寚瀹氾紝鐢辩郴缁熺洿鎺ョ敓鎴� //var cntId = Guid.NewGuid().ToString("D");
@@ -40,7 +59,7 @@
var cntId = GenerateNo("瀹瑰櫒鍙�, "CN");
var cgId = GenerateNo("鐗╂枡鍙�, "CG");
- // 鍒濆鏄病鏈夌粦瀹氫俊鎭殑锛屽厛灏嗚捣鐐逛綅缃笌瀹瑰櫒缁戝畾锛屽鍣ㄤ笌鐗╂枡缁戝畾
+ // 棣栨鍏ュ簱锛氭病鏈夌粦瀹氫俊鎭紝鍏堝皢璧风偣浣嶇疆涓庡鍣ㄧ粦瀹氾紝瀹瑰櫒涓庣墿鏂欑粦瀹� var locCntrRel = new TN_Loc_Container() {
S_LOC_CODE = startLoc.S_CODE,
S_CNTR_CODE = cntId,
@@ -49,7 +68,10 @@
var cgDetail = new TN_CG_Detail() {
S_ITEM_CODE = cgId,
S_CNTR_CODE = cntId,
+ S_LOC_CODE = startLoc.S_CODE, // ADD锛氳ˉ鍏呴拡瀵筆DA鍒嗘嫞
};
+
+ startLoc.N_CURRENT_NUM = 1;
var endLocCode = "0"; // 鍋囩殑榛樿缁堢偣鍦板潃
@@ -59,9 +81,9 @@
if (!int.TryParse(model.Row.Trim(), out int row)) {
return BuildSimpleResult(2, $"{model.Row} 涓嶅悎娉曪細鏃犳硶杞垚鏁存暟绫诲瀷");
}
- // 璐ф灦鎺掑彿鍙兘鏄�0 - 8
- if (row <= 0 || row > 8) {
- return BuildSimpleResult(2, $"璐ф灦鍙�{model.Row} 蹇呴』鏄�-8涔嬮棿鐨勬暣鏁�);
+ // 璐ф灦鎺掑彿鍙兘鏄�0 - 8锛�11-118锛�+ if (row <= 110 || row > 118) {
+ return BuildSimpleResult(2, $"璐ф灦鍙�{model.Row} 蹇呴』鏄�11-118涔嬮棿鐨勬暣鏁�);
}
}
@@ -70,6 +92,21 @@
// 鏃犺鏄惁閫夋嫨缁堢偣璐ф灦锛岄兘绛夊埌绉伴噸涔嬪悗鍐嶈绠楃粓鐐硅揣浣� using (var tran = db.Ado.UseTran()) {
+ //if (locCntrRelOld != null) {
+ // if (db.Deleteable<TN_Loc_Container>(locCntrRelOld).ExecuteCommand() <= 0) {
+ // tran.RollbackTran();
+ // return BuildSimpleResult(500,
+ // $"鍒犻櫎璐т綅瀹瑰櫒鍏崇郴琛ㄥけ璐ワ細璐т綅{locCntrRelOld.S_LOC_CODE}锛屽鍣▄locCntrRelOld.S_CNTR_CODE}");
+ // }
+ //}
+ //if (cgDetailOld != null) {
+ // if (db.Deleteable<TN_CG_Detail>(cgDetailOld).ExecuteCommand() <= 0) {
+ // tran.RollbackTran();
+ // return BuildSimpleResult(500,
+ // $"鍒犻櫎鏃у鍣ㄨ揣鍝佹槑缁嗚〃澶辫触锛氬鍣▄cgDetailOld.S_CNTR_CODE}锛岀墿鏂檣cgDetailOld.S_ITEM_CODE}");
+ // }
+ //}
+
if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) {
tran.RollbackTran();
return BuildSimpleResult(500,
@@ -83,7 +120,134 @@
}
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
- it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
+ it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY, it.N_CURRENT_NUM }).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鏇存柊璧风偣璐т綅閿佺姸鎬佸け璐ワ細璧风偣璐т綅{startLoc.S_CODE}");
+ }
+
+ if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鐢熸垚浠诲姟 {taskName} 澶辫触锛氬鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLocCode} 锛岀粓鐐硅揣浣嶆湭鎸囧畾");
+ }
+
+ tran.CommitTran();
+ return BuildSimpleResult(0,
+ $"鐢熸垚浠诲姟 {taskName} 鎴愬姛锛氬鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLocCode} 锛岀粓鐐硅揣浣嶆湭鎸囧畾");
+ }
+ }
+ catch (Exception ex) {
+ return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+ }
+ }
+
+ public static SimpleResult InboundData(InboundDataInfo model) {
+ var taskName = TaskName.浜у搧鍏ュ簱;
+ var db = new SqlHelper<object>().GetInstance();
+
+ var startAreas = Settings.Areas[AreaIndex.Q鍙栬揣鍖篯;
+
+ try {
+ // 璧风偣浣嶇疆蹇呴』锛氫负绌恒�鏃犻攣銆佸惎鐢ㄣ�灞炰簬鏀跺彂鍖哄煙
+ var startLoc = db.Queryable<TN_Location>()
+ .Where(a => a.S_CODE == model.StartLoc)
+ .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y")
+ .Where(a => a.N_CURRENT_NUM == 0)
+ .Where(a => startAreas.Contains(a.S_AREA_CODE))
+ .First();
+
+ if (startLoc == null) {
+ return BuildSimpleResult(1, $"璧风偣浣嶇疆{model.StartLoc}涓嶅瓨鍦ㄦ垨涓嶆弧瓒宠姹傦細(1)娌℃湁閿佺姸鎬�(2)灞炰簬鍙栨斁璐у尯");
+ }
+
+ //var locCntrRelOld = db.Queryable<TN_Loc_Container>()
+ // .Where(c => c.S_LOC_CODE == model.StartLoc).First();
+
+ //// 浜у搧鍏ュ簱锛氬亣瀹氱敤鎴蜂笉浼氬皢鏂板叆搴撶墿鏂欙紝鏀惧埌宸叉湁鐗╂枡鐨勬敹鍙戣揣鍖哄叆搴�+ //// 鏂颁骇鍝佸叆搴撴椂锛屽鏋滃瓨鍦ㄦ棫鐨勮揣浣嶇粦瀹氭暟鎹紙鍑哄簱閬楃暀椤圭洰锛夌洿鎺ュ垹闄�+ //TN_CG_Detail cgDetailOld = null;
+ //if (locCntrRelOld != null) {
+ // cgDetailOld = db.Queryable<TN_CG_Detail>()
+ // .Where(d => d.S_CNTR_CODE == locCntrRelOld.S_CNTR_CODE).First();
+ //}
+
+ // 瀹瑰櫒 ID 鍜�鐗╂枡 ID 鏈寚瀹氾紝鐢辩郴缁熺洿鎺ョ敓鎴�+ //var cntId = Guid.NewGuid().ToString("D");
+ //var CgId = Guid.NewGuid().ToString("D");
+ var cntId = GenerateNo("瀹瑰櫒鍙�, "CN");
+ //var cgId = GenerateNo("鐗╂枡鍙�, "CG");
+ var cgId = string.IsNullOrEmpty(model.ItemCode) ? GenerateNo("鐗╂枡鍙�, "CG") : model.ItemCode ;
+
+ // 棣栨鍏ュ簱锛氱粦瀹氫俊鎭紝鍏堝皢璧风偣浣嶇疆涓庡鍣ㄧ粦瀹氾紝瀹瑰櫒涓庣墿鏂欑粦瀹�+ var locCntrRel = new TN_Loc_Container() {
+ S_LOC_CODE = startLoc.S_CODE,
+ S_CNTR_CODE = cntId,
+ N_LOCK_STATE = string.IsNullOrEmpty(model.ItemCode) ? 0 : 1,
+ };
+
+ var cgDetail = new TN_CG_Detail() {
+ S_ITEM_CODE = cgId,
+ S_CNTR_CODE = cntId,
+ //S_ITEM_NAME = model.ItemName,
+ S_LOC_CODE = startLoc.S_CODE, // ADD锛氳ˉ鍏呴拡瀵筆DA鍒嗘嫞
+ };
+
+ startLoc.N_CURRENT_NUM = 1;
+
+ var endLocCode = "0"; // 鍋囩殑榛樿缁堢偣鍦板潃
+
+ // 鎸囧畾璐т綅鎺掑彿锛堜笉鑳戒负绌恒�绌哄瓧绗︿覆鎴栫┖鏍硷級
+ if (model.Row != null && model.Row.Trim() != "") {
+ endLocCode = model.Row; // 鐢ㄦ帓鍙峰瓧绗︿覆褰撳仛鍋囧湴鍧�+ if (!int.TryParse(model.Row.Trim(), out int row)) {
+ return BuildSimpleResult(2, $"{model.Row} 涓嶅悎娉曪細鏃犳硶杞垚鏁存暟绫诲瀷");
+ }
+ // 璐ф灦鎺掑彿鍙兘鏄�0 - 8锛�11-118锛�+ if (row <= 110 || row > 118) {
+ return BuildSimpleResult(2, $"璐ф灦鍙�{model.Row} 蹇呴』鏄�11-118涔嬮棿鐨勬暣鏁�);
+ }
+ }
+
+ var task = WCSHelper.BuildInboundTask(startLoc, endLocCode, cntId);
+ LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�+
+ // 鏃犺鏄惁閫夋嫨缁堢偣璐ф灦锛岄兘绛夊埌绉伴噸涔嬪悗鍐嶈绠楃粓鐐硅揣浣�+ using (var tran = db.Ado.UseTran()) {
+ //if (locCntrRelOld != null) {
+ // if (db.Deleteable<TN_Loc_Container>(locCntrRelOld).ExecuteCommand() <= 0) {
+ // tran.RollbackTran();
+ // return BuildSimpleResult(500,
+ // $"鍒犻櫎璐т綅瀹瑰櫒鍏崇郴琛ㄥけ璐ワ細璐т綅{locCntrRelOld.S_LOC_CODE}锛屽鍣▄locCntrRelOld.S_CNTR_CODE}");
+ // }
+ //}
+ //if (cgDetailOld != null) {
+ // if (db.Deleteable<TN_CG_Detail>(cgDetailOld).ExecuteCommand() <= 0) {
+ // tran.RollbackTran();
+ // return BuildSimpleResult(500,
+ // $"鍒犻櫎鏃у鍣ㄨ揣鍝佹槑缁嗚〃澶辫触锛氬鍣▄cgDetailOld.S_CNTR_CODE}锛岀墿鏂檣cgDetailOld.S_ITEM_CODE}");
+ // }
+ //}
+
+ if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鎻掑叆璐т綅瀹瑰櫒鍏崇郴琛ㄥけ璐ワ細璐т綅{locCntrRel.S_LOC_CODE}锛屽鍣▄locCntrRel.S_CNTR_CODE}");
+ }
+
+ if (db.Insertable<TN_CG_Detail>(cgDetail).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鎻掑叆瀹瑰櫒璐у搧鏄庣粏琛ㄥけ璐ワ細瀹瑰櫒{cgDetail.S_CNTR_CODE}锛岀墿鏂檣cgDetail.S_ITEM_CODE}");
+ }
+
+ if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
+ it.N_LOCK_STATE,
+ it.S_LOCK_STATE,
+ it.S_LOCK_OP,
+ it.T_MODIFY,
+ it.N_CURRENT_NUM
+ }).ExecuteCommand() <= 0) {
tran.RollbackTran();
return BuildSimpleResult(500,
$"鏇存柊璧风偣璐т綅閿佺姸鎬佸け璐ワ細璧风偣璐т綅{startLoc.S_CODE}");
@@ -105,11 +269,124 @@
}
}
- //internal static string GenerateNo(string snType, string prefix) {
- // var id = SYSHelper.GetSerialNumber(snType, prefix);
- // var date = DateTime.Now.ToString("yyMMdd");
- // return $"TN{date}{id.ToString().PadLeft(4, '0')}";
- //}
+ internal static string GenerateNo(string snType, string prefix) {
+ var id = SYSHelper.GetSerialNumber(snType, prefix);
+ var date = DateTime.Now.ToString("yyMMdd");
+ return $"{prefix}{date}-{id.ToString().PadLeft(5, '0')}"; // 褰㈠锛欳N250525-00011
+ }
+
+ /// <summary>
+ /// 鍏煎Inbound鍜孭artInbound鐨勫姛鑳斤紝澶囩敤锛堥棶棰橈細鍑哄簱鍚庢棤娉曡嚜鍔ㄦ竻鏁版嵁锛屽鑷村叆搴撳悗鍥炲簱锛�+ /// </summary>
+ /// <param name="model"></param>
+ /// <returns></returns>
+ public static SimpleResult InboundTwoWays(InboundInfo model) {
+ var taskName = TaskName.浜у搧鍏ュ簱;
+ var db = new SqlHelper<object>().GetInstance();
+
+ var startAreas = Settings.Areas[AreaIndex.Q鍙栬揣鍖篯;
+
+ try {
+ // 璧风偣浣嶇疆蹇呴』锛氫负绌恒�鏃犻攣銆佸惎鐢ㄣ�灞炰簬鏀跺彂鍖哄煙
+ var startLoc = db.Queryable<TN_Location>()
+ .Where(a => a.S_CODE == model.StartLoc)
+ .Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y")
+ //.Where(a => a.N_CURRENT_NUM == 0)
+ .Where(a => startAreas.Contains(a.S_AREA_CODE))
+ .First();
+
+ if (startLoc == null) {
+ return BuildSimpleResult(1, $"璧风偣浣嶇疆{model.StartLoc}涓嶅瓨鍦ㄦ垨涓嶆弧瓒宠姹傦細(1)娌℃湁閿佺姸鎬�(2)灞炰簬鍙栨斁璐у尯");
+ }
+
+ // 瀹瑰櫒 ID 鍜�鐗╂枡 ID 鏈寚瀹氾紝鐢辩郴缁熺洿鎺ョ敓鎴�+ //var cntId = Guid.NewGuid().ToString("D");
+ //var CgId = Guid.NewGuid().ToString("D");
+ var cntId = GenerateNo("瀹瑰櫒鍙�, "CN");
+ var cgId = GenerateNo("鐗╂枡鍙�, "CG");
+
+ var locCntrRel = db.Queryable<TN_Loc_Container>()
+ .Where(c => c.S_LOC_CODE == model.StartLoc).First();
+
+ // 鍙湁棣栨鍏ュ簱锛堝綋鍓嶆墭鐩樻湭缁戝畾鍦ㄨ捣鐐硅揣浣嶏級鏃禼gDetail璁剧疆鍊硷紝骞舵彃鍏�+ // 鍚﹀垯锛宑gDetail涓虹┖锛屼唬琛ㄦ槸鍥炲簱浣滀笟锛堟鍓嶆湁缁戝畾杩囪捣鐐癸級
+ TN_CG_Detail cgDetail = null;
+ if (locCntrRel == null) {
+ // 棣栨鍏ュ簱锛氭病鏈夌粦瀹氫俊鎭紝鍏堝皢璧风偣浣嶇疆涓庡鍣ㄧ粦瀹氾紝瀹瑰櫒涓庣墿鏂欑粦瀹�+ locCntrRel = new TN_Loc_Container() {
+ S_LOC_CODE = startLoc.S_CODE,
+ S_CNTR_CODE = cntId,
+ };
+
+ cgDetail = new TN_CG_Detail() {
+ S_ITEM_CODE = cgId,
+ S_CNTR_CODE = cntId,
+ };
+ }
+
+ startLoc.N_CURRENT_NUM = 1;
+
+ var endLocCode = "0"; // 鍋囩殑榛樿缁堢偣鍦板潃
+
+ // 鎸囧畾璐т綅鎺掑彿锛堜笉鑳戒负绌恒�绌哄瓧绗︿覆鎴栫┖鏍硷級
+ if (model.Row != null && model.Row.Trim() != "") {
+ endLocCode = model.Row; // 鐢ㄦ帓鍙峰瓧绗︿覆褰撳仛鍋囧湴鍧�+ if (!int.TryParse(model.Row.Trim(), out int row)) {
+ return BuildSimpleResult(2, $"{model.Row} 涓嶅悎娉曪細鏃犳硶杞垚鏁存暟绫诲瀷");
+ }
+ // 璐ф灦鎺掑彿鍙兘鏄�0 - 8锛�11-118锛�+ if (row <= 110 || row > 118) {
+ return BuildSimpleResult(2, $"璐ф灦鍙�{model.Row} 蹇呴』鏄�11-118涔嬮棿鐨勬暣鏁�);
+ }
+ }
+
+ var task = WCSHelper.BuildInboundTask(startLoc, endLocCode, cntId);
+ LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�+
+ // 鏃犺鏄惁閫夋嫨缁堢偣璐ф灦锛岄兘绛夊埌绉伴噸涔嬪悗鍐嶈绠楃粓鐐硅揣浣�+ using (var tran = db.Ado.UseTran()) {
+ if (cgDetail != null) {
+ if (db.Insertable<TN_Loc_Container>(locCntrRel).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鎻掑叆璐т綅瀹瑰櫒鍏崇郴琛ㄥけ璐ワ細璐т綅{locCntrRel.S_LOC_CODE}锛屽鍣▄locCntrRel.S_CNTR_CODE}");
+ }
+
+ if (db.Insertable<TN_CG_Detail>(cgDetail).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鎻掑叆瀹瑰櫒璐у搧鏄庣粏琛ㄥけ璐ワ細瀹瑰櫒{cgDetail.S_CNTR_CODE}锛岀墿鏂檣cgDetail.S_ITEM_CODE}");
+ }
+ }
+
+ if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
+ it.N_LOCK_STATE,
+ it.S_LOCK_STATE,
+ it.S_LOCK_OP,
+ it.T_MODIFY,
+ it.N_CURRENT_NUM
+ }).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鏇存柊璧风偣璐т綅閿佺姸鎬佸け璐ワ細璧风偣璐т綅{startLoc.S_CODE}");
+ }
+
+ if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鐢熸垚浠诲姟 {taskName} 澶辫触锛氬鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLocCode} 锛岀粓鐐硅揣浣嶆湭鎸囧畾");
+ }
+
+ tran.CommitTran();
+ return BuildSimpleResult(0,
+ $"鐢熸垚浠诲姟 {taskName} 鎴愬姛锛氬鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLocCode} 锛岀粓鐐硅揣浣嶆湭鎸囧畾");
+ }
+ }
+ catch (Exception ex) {
+ return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+ }
+ }
+
/// <summary>
/// PDA閫夋嫨缁堢偣璐т綅
@@ -119,6 +396,8 @@
internal static SimpleResult SelectLocation(SelectLocationInfo model) {
var db = new SqlHelper<object>().GetInstance();
+
+ var endAreas = Settings.Areas[AreaIndex.H璐ф灦鍖篯;
try {
// 浠诲姟鍙峰瓨鍦細缁堢偣璐ф灦鍜岀粓鐐逛綅缃负绌猴紝涓斾换鍔′负浜у搧鍏ュ簱(PDA)
@@ -145,6 +424,25 @@
var endLoc = new TN_Location();
if (cgDetail.F_QTY > 2000) {
// 閲嶉噺瓒呰繃2t锛屾姤閿�+ if (GZRobot.TryGetInteractionInfoId(task.S_CODE, out var id1)) {
+ if (GZRobot.UpdateInteractInfo(new UpdateInteractInfo {
+ type_name = "GET_DST",
+ interaction_info_id = id1,
+ info_status = "error",
+ })) {
+ LogHelper.Info($"鍥借嚜AGV鎺ュ彈瓒呴噸鍙栨秷淇℃伅鎴愬姛", "HosttoagvTask");
+ }
+ else {
+ LogHelper.Info($"鍥借嚜AGV鎺ュ彈瓒呴噸鍙栨秷淇℃伅澶辫触", "HosttoagvTask");
+ //return BuildSimpleResult(7, $"鍥借嚜AGV鎺ュ彈缁堢偣淇℃伅澶辫触");
+ }
+ }
+ else {
+ //return BuildSimpleResult(7, $"鑾峰彇浠诲姟{task.S_CODE}鐨刟gv interaction_info_id澶辫触锛�);
+ LogHelper.Info($"AGV锛氳幏鍙栦换鍔task.S_CODE}鐨刬nteraction_info_id澶辫触锛�, "HosttoagvTask");
+ //return BuildSimpleResult(8, $"鍥借嚜AGV鎺ュ彈缁堢偣淇℃伅澶辫触");
+ }
+
return BuildSimpleResult(8, $"鐗╂枡閲嶉噺{cgDetail.F_QTY}瓒呰繃2t");
}
else if (cgDetail.F_QTY > 1500) {
@@ -153,7 +451,7 @@
.Where(a => a.S_CODE == model.EndLoc)
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y")
.Where(a => a.N_CURRENT_NUM == 0)
- .Where(a => Settings.Areas[1].Contains(a.S_AREA_CODE))
+ .Where(a => endAreas.Contains(a.S_AREA_CODE))
.Where(a => a.N_LAYER <= 2)
.First();
}
@@ -162,7 +460,7 @@
.Where(a => a.S_CODE == model.EndLoc)
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y")
.Where(a => a.N_CURRENT_NUM == 0)
- .Where(a => Settings.Areas[1].Contains(a.S_AREA_CODE))
+ .Where(a => endAreas.Contains(a.S_AREA_CODE))
.OrderBy(a => a.N_LAYER > 2 ? 0 : 1) // 浼樺厛鍙栧ぇ浜�鐨� //.Where(a => a.N_LAYER <= 3)
.First();
@@ -180,16 +478,35 @@
task.S_END_LOC = endLoc.S_CODE;
LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�
+ if (GZRobot.TryGetInteractionInfoId(task.S_CODE, out var id2)) {
+ if (GZRobot.UpdateInteractInfo(new UpdateInteractInfo {
+ type_name = "GET_DST",
+ interaction_info_id = id2,
+ info_status = "invalid",
+ return_value = LocationHelper.GetAgvSite(task.S_END_LOC), // 鐩墠浣跨敤agvsite
+ })) {
+ LogHelper.Info($"鍥借嚜AGV鎺ュ彈缁堢偣淇℃伅鎴愬姛", "HosttoagvTask");
+ }
+ else {
+ LogHelper.Info($"鍥借嚜AGV鎺ュ彈缁堢偣淇℃伅澶辫触", "HosttoagvTask");
+ return BuildSimpleResult(7, $"鍥借嚜AGV鎺ュ彈缁堢偣淇℃伅澶辫触");
+ }
+ }
+ else {
+ LogHelper.Info($"AGV锛氳幏鍙栦换鍔task.S_CODE}鐨刬nteraction_info_id澶辫触锛�, "HosttoagvTask");
+ return BuildSimpleResult(8, $"鍥借嚜AGV鎺ュ彈缁堢偣淇℃伅澶辫触");
+ }
+
using (var tran = db.Ado.UseTran()) {
if (db.Updateable<TN_Task>(task).UpdateColumns(a => a.S_END_LOC).ExecuteCommand() <= 0) {
tran.RollbackTran();
- return BuildSimpleResult(7, $"浠诲姟{task.S_CODE}淇敼澶辫触锛屼慨鏀圭粓鐐逛綅缃负{endLoc.S_CODE}");
+ return BuildSimpleResult(500, $"浠诲姟{task.S_CODE}淇敼澶辫触锛屼慨鏀圭粓鐐逛綅缃负{endLoc.S_CODE}");
}
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
tran.RollbackTran();
- return BuildSimpleResult(7, $"浠诲姟{task.S_CODE}淇敼澶辫触锛屼慨鏀圭粓鐐逛綅缃负{endLoc.S_CODE}");
+ return BuildSimpleResult(500, $"浠诲姟{task.S_CODE}淇敼澶辫触锛屼慨鏀圭粓鐐逛綅缃负{endLoc.S_CODE}");
}
tran.CommitTran();
@@ -202,7 +519,7 @@
}
/// <summary>
- /// 浜у搧閮ㄥ垎鍑哄簱(WMS)
+ /// 浜у搧閮ㄥ垎鍑哄簱
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
@@ -210,25 +527,33 @@
var taskName = TaskName.浜у搧閮ㄥ垎鍑哄簱;
var db = new SqlHelper<object>().GetInstance();
+ var startAreas = Settings.Areas[AreaIndex.H璐ф灦鍖篯;
+ var endAreas = Settings.Areas[AreaIndex.X鍗歌揣鍖篯;
+
try {
// 璧风偣浣嶇疆锛氳揣鏋讹紙鏈夎揣銆佹病鏈夐攣銆佸凡鍚敤锛� var startLoc = db.Queryable<TN_Location>()
.Where(a => a.S_CODE == model.startLoc)
.Where(a => a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y")
+ .Where(a => startAreas.Contains(a.S_AREA_CODE))
.Where(a => a.N_CURRENT_NUM == 1)
.First();
if (startLoc == null) {
- return BuildSimpleResult(2, $"璧风偣浣嶇疆 {model.startLoc} 涓嶅瓨鍦ㄦ垨涓嶅叿澶囧彇璐ц姹�);
+ return BuildSimpleResult(2, $"璧风偣浣嶇疆 {model.startLoc} 涓嶅瓨鍦ㄦ垨涓嶅叿澶囧彇璐ц姹傦紒");
}
var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
if (locCntrRel == null) {
- return BuildSimpleResult(3, $"璧风偣浣嶇疆 {model.startLoc} 娌℃湁缁戝畾瀹瑰櫒锛屾棤鍙嚭搴撶殑鐗╂枡");
+ return BuildSimpleResult(3, $"璧风偣浣嶇疆 {model.startLoc} 娌℃湁缁戝畾瀹瑰櫒锛屾棤鍙嚭搴撶殑鐗╂枡锛�);
}
- var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[0].Contains(a.S_AREA_CODE));
+ if (locCntrRel.N_LOCK_STATE == 0) {
+ return BuildSimpleResult(5, $"璧风偣浣嶇疆'{model.startLoc}'鐨勮揣浣嶏紝璐т綅瀹瑰櫒鍏崇郴涓婇攣锛岀墿鏂欎俊鎭皻鏈紶閫掞紝鏃犳硶鍑哄簱锛�);
+ }
+
+ var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && endAreas.Contains(a.S_AREA_CODE));
if (endLoc == null) {
return BuildSimpleResult(4, $"缁堢偣浣嶇疆 {model.endLoc} 涓嶅叿澶囨斁璐ф潯浠�);
@@ -273,7 +598,7 @@
}
/// <summary>
- /// 浜у搧閮ㄥ垎鍥炲簱(WMS)
+ /// 浜у搧閮ㄥ垎鍥炲簱
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
@@ -281,20 +606,23 @@
var taskName = TaskName.浜у搧閮ㄥ垎鍥炲簱;
var db = new SqlHelper<object>().GetInstance();
+ var startAreas = Settings.Areas[AreaIndex.X鍗歌揣鍖篯;
+ var endAreas = Settings.Areas[AreaIndex.H璐ф灦鍖篯;
+
try {
// 璧风偣浣嶇疆锛氬彇鏀捐揣鍖猴紙鏈夎揣鐗┿�娌℃湁閿併�宸插惎鐢級
- var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[0].Contains(a.S_AREA_CODE));
+ var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && startAreas.Contains(a.S_AREA_CODE));
if (startLoc == null) {
return BuildSimpleResult(2, $"璧风偣浣嶇疆 {model.startLoc} 涓嶇鍚堝洖搴撴潯浠�);
}
-
+
var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
if (locCntrRel == null) {
return BuildSimpleResult(3, $"璧风偣浣嶇疆 {model.startLoc} 娌℃湁缁戝畾瀹瑰櫒锛屾棤鍙洖搴撶殑鐗╂枡");
}
// 缁堢偣浣嶇疆锛氳揣鏋讹紙娌℃湁璐х墿锛屾病鏈夐攣锛�- var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y");
+ var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && endAreas.Contains(a.S_AREA_CODE));
if (endLoc == null) {
return BuildSimpleResult(4, $"缁堢偣浣嶇疆 {model.endLoc} 涓嶅叿澶囨斁璐ф潯浠�);
}
@@ -314,6 +642,80 @@
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+ }
+
+ if (db.Insertable<TN_Task>(task).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+ }
+
+ tran.CommitTran();
+ return BuildSimpleResult(0,
+ $"鐢熸垚 {taskName} 鎴愬姛锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
+ }
+ }
+ catch (Exception ex) {
+ return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+ }
+ }
+
+ /// <summary>
+ /// 浜у搧閮ㄥ垎鍥炲簱锛堜笉鎸囧畾缁堢偣锛屽鐢級
+ /// </summary>
+ /// <param name="model"></param>
+ /// <returns></returns>
+ internal static SimpleResult PartInboundAuto(PartInboundInfo model) {
+ var taskName = TaskName.浜у搧閮ㄥ垎鍥炲簱;
+ var db = new SqlHelper<object>().GetInstance();
+
+ var startAreas = Settings.Areas[AreaIndex.X鍗歌揣鍖篯;
+ var endAreas = Settings.Areas[AreaIndex.H璐ф灦鍖篯;
+
+ try {
+ // 璧风偣浣嶇疆锛氬彇鏀捐揣鍖猴紙鏈夎揣鐗┿�娌℃湁閿併�宸插惎鐢級
+ var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && startAreas.Contains(a.S_AREA_CODE));
+ if (startLoc == null) {
+ return BuildSimpleResult(2, $"璧风偣浣嶇疆 {model.startLoc} 涓嶇鍚堝洖搴撴潯浠�);
+ }
+
+ var locCntrRel = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == model.startLoc);
+ if (locCntrRel == null) {
+ return BuildSimpleResult(3, $"璧风偣浣嶇疆 {model.startLoc} 娌℃湁缁戝畾瀹瑰櫒锛屾棤鍙洖搴撶殑鐗╂枡");
+ }
+
+ // 缁堢偣浣嶇疆锛氳揣鏋讹紙娌℃湁璐х墿锛屾病鏈夐攣锛�+ var endLoc = db.Queryable<TN_Location>().First(a => a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && endAreas.Contains(a.S_AREA_CODE));
+ if (endLoc == null) {
+ return BuildSimpleResult(4, $"娌℃湁鎵惧埌鍚堥�鐨勭粓鐐硅揣浣�);
+ }
+
+ var cntId = locCntrRel.S_CNTR_CODE;
+ var task = WCSHelper.BuildTask(startLoc, endLoc, cntId, taskName);
+ LocationHelper.LockLoc(ref startLoc, 2); // 璧风偣鍑哄簱閿�+ LocationHelper.LockLoc(ref endLoc, 1); // 缁堢偣鍏ュ簱閿�+
+ using (var tran = db.Ado.UseTran()) {
+ if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
+ it.N_LOCK_STATE,
+ it.S_LOCK_STATE,
+ it.S_LOCK_OP,
+ it.T_MODIFY
+ }).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildSimpleResult(500,
+ $"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}");
+ }
+
+ if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
+ it.N_LOCK_STATE,
+ it.S_LOCK_STATE,
+ it.S_LOCK_OP,
+ it.T_MODIFY
+ }).ExecuteCommand() <= 0) {
tran.RollbackTran();
return BuildSimpleResult(500,
$"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntId} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
@@ -347,22 +749,21 @@
return BuildSimpleResult(2, $"浠诲姟鍙穥model.TaskNo}涓嶅瓨鍦�);
}
- if (task.N_B_STATE == 0 && task.S_B_STATE == TN_Task.GetStateStr(0)
- || task.N_B_STATE == 1 && task.S_B_STATE == TN_Task.GetStateStr(1)) {
+ // 绛夊緟 鎴�宸叉帹閫�鏃讹紝鍙互鍙栨秷浠诲姟
+ //if (task.N_B_STATE == 0 && task.S_B_STATE == TN_Task.GetStateStr(0)
+ // || task.N_B_STATE == 1 && task.S_B_STATE == TN_Task.GetStateStr(1)) {
+ if (task.N_B_STATE == 0 || task.N_B_STATE == 1) {
- task.N_B_STATE = 4;
- task.S_B_STATE = "鍙栨秷";
-
- var starloc = db.Queryable<TN_Location>().First(a => a.S_CODE == task.S_START_LOC);
+ var startloc = db.Queryable<TN_Location>().First(a => a.S_CODE == task.S_START_LOC);
var endloc = db.Queryable<TN_Location>().First(a => a.S_CODE == task.S_END_LOC);
//var locCnt = db.Queryable<TN_Loc_Container>().First(a => a.S_CNTR_CODE == task.S_CNTR_CODE);
//var cg = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == task.S_CNTR_CODE);
- if (starloc != null) {
- starloc.N_LOCK_STATE = 0;
- starloc.S_LOCK_STATE = "鏃�;
+ if (startloc != null) {
+ startloc.N_LOCK_STATE = 0;
+ startloc.S_LOCK_STATE = "鏃�;
//starloc.N_CURRENT_NUM = 0;
- starloc.T_MODIFY = System.DateTime.Now;
+ startloc.T_MODIFY = System.DateTime.Now;
}
if (endloc != null) {
@@ -372,45 +773,55 @@
endloc.T_MODIFY = System.DateTime.Now;
}
+ if (task.N_B_STATE == 1) {
+ if (!int.TryParse(task.S_EQ_TASK_CODE, out var code)) {
+ LogHelper.Info($"褰撳墠浠诲姟{task.S_CODE}娌℃湁鎵惧埌瀵瑰簲鐨勫浗鑷狝GV orderId锛�);
+ }
+ else {
+ var res = GZRobot.CancelGZOrder(code);
+ if (!res) {
+ LogHelper.Info($"鍥借嚜AGV鍙栨秷浠诲姟澶辫触锛�, "HosttoagvTask");
+ }
+ else {
+ LogHelper.Info($"鍥借嚜AGV鍙栨秷浠诲姟鎴愬姛锛�, "HosttoagvTask");
+ }
+ }
+ }
+
+ task.N_B_STATE = 4;
+ task.S_B_STATE = "鍙栨秷";
+
using (var tran = db.Ado.UseTran()) {
- if (db.Updateable<TN_Location>(starloc).ExecuteCommand() <= 0) {
+ if (db.Updateable<TN_Location>(startloc).ExecuteCommand() <= 0) {
tran.RollbackTran();
-
- info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触";
-
- return BuildSimpleResult(0, info);
+ info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触锛氫慨鏀硅捣鐐硅揣浣嶉攣鐘舵�澶辫触";
+ return BuildSimpleResult(500, info);
}
if (endloc != null) {
if (db.Updateable<TN_Location>(endloc).ExecuteCommand() <= 0) {
tran.RollbackTran();
-
- info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触";
-
- return BuildSimpleResult(0, info);
+ info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触锛氫慨鏀圭粓鐐硅揣浣嶉攣鐘舵�澶辫触";
+ return BuildSimpleResult(500, info);
}
}
if (db.Updateable<TN_Task>(task).ExecuteCommand() <= 0) {
- if (db.Updateable<TN_Location>(endloc).ExecuteCommand() <= 0) {
- tran.RollbackTran();
-
- info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触";
-
- return BuildSimpleResult(0, info);
- }
+ tran.RollbackTran();
+ info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触";
+ return BuildSimpleResult(500, info);
}
tran.CommitTran();
-
info = $"浠诲姟{task.S_CODE}鍙栨秷鎴愬姛";
-
return BuildSimpleResult(0, info);
}
}
else {
- return BuildSimpleResult(3, $"鍙湁浠诲姟鍙风姸鎬佷负 绛夊緟 鎴�宸叉帹閫�鐨勪换鍔℃墠鑳藉彇娑�);
+ //return BuildSimpleResult(3, $"鍙湁浠诲姟鍙风姸鎬佷负 绛夊緟 鎴�宸叉帹閫�鐨勪换鍔℃墠鑳藉彇娑�);
+
+ return CancelTaskIfForced(model, task); // 澶囩敤鍑芥暟锛屽鏋滅敳鏂硅姹備换鍔℃墽琛屼腑涔熷彇娑堬紝鍐嶈皟鐢� }
}
@@ -419,144 +830,279 @@
}
}
- public static SimpleResult CreateCountPlan(CreateCountPlanInfo model) {
- var db = new SqlHelper<object>().GetInstance();
- try {
+ public static SimpleResult CancelTaskIfForced(CancelTaskInfo model, TN_Task task) {
- var countPlan = new TN_Count_Plan() {
- S_CP_NO = GenerateNo("鐩樼偣璁″垝", "CP"),
- S_TYPE = model.countType,
- };
-
- if (model.countType == "璐т綅") {
- countPlan.S_LOC_CODE = model.targetId;
- }
- else if (model.countType == "鐗╂枡") {
- countPlan.S_ITEM_CODE = model.targetId;
- }
- else {
- return BuildSimpleResult(2, $"鍒涘缓鐩樼偣璁″垝澶辫触锛氫笉鍚堟硶鐨勭洏鐐圭被鍨�'{model.countType}'");
- }
-
- if (db.Insertable<TN_Count_Plan>(countPlan).ExecuteCommand() <= 0) {
- return BuildSimpleResult(2, "鍒涘缓鐩樼偣璁″垝澶辫触");
- }
-
- return BuildSimpleResult(0, "鍒涘缓鐩樼偣璁″垝鎴愬姛");
-
- }
- catch (Exception ex) {
-
- return BuildSimpleResult(1, ex.Message);
- }
- }
-
- public static SimpleResult CreateCountOrder(CreateCountOrderInfo model) {
var db = new SqlHelper<object>().GetInstance();
var info = "";
try {
- var countPlan = db.Queryable<TN_Count_Plan>()
- .Where(a => a.S_CP_NO == model.planId).First();
+ var startloc = db.Queryable<TN_Location>().First(a => a.S_CODE == task.S_START_LOC);
+ var endloc = db.Queryable<TN_Location>().First(a => a.S_CODE == task.S_END_LOC);
+ //var locCnt = db.Queryable<TN_Loc_Container>().First(a => a.S_CNTR_CODE == task.S_CNTR_CODE);
+ //var cg = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == task.S_CNTR_CODE);
- if (countPlan == null) {
- return BuildSimpleResult(2, $"鐩樼偣璁″垝鍗曞彿 '{model.planId}' 涓嶅瓨鍦�);
+ if (startloc != null) {
+ startloc.N_LOCK_STATE = 0;
+ startloc.S_LOCK_STATE = "鏃�;
+ //starloc.N_CURRENT_NUM = 0;
+ startloc.T_MODIFY = System.DateTime.Now;
}
- var countOrder = new TN_Count_Order() {
- S_CP_NO = model.planId,
- S_COUNT_NO = GenerateNo("鐩樼偣鍗�, "CN"),
- };
-
- var countDetailList = new List<TN_Count_CG_Detail>();
- if (countPlan.S_TYPE == "璐т綅") {
- var cgDetail = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail>
- ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE)
- .Where(l => l.S_CODE == countPlan.S_LOC_CODE)
- .Select((l, c, d) => d).First();
-
- var countDetail = new TN_Count_CG_Detail {
- S_COUNT_NO = countOrder.S_COUNT_NO,
- S_CNTR_CODE = cgDetail.S_CNTR_CODE,
- S_ITEM_CODE = cgDetail.S_ITEM_CODE,
- };
-
- countDetailList.Add(countDetail);
+ if (endloc != null) {
+ endloc.N_LOCK_STATE = 0;
+ endloc.S_LOCK_STATE = "鏃�;
+ //endloc.N_CURRENT_NUM = 0;
+ endloc.T_MODIFY = System.DateTime.Now;
}
- else if (countPlan.S_TYPE == "鐗╂枡") {
- var cgDetailList = db.Queryable<TN_CG_Detail>()
- .Where(d => d.S_ITEM_CODE == countPlan.S_ITEM_CODE).ToList();
- foreach (var cgDetail in cgDetailList) {
- var countDetail = new TN_Count_CG_Detail {
- S_COUNT_NO = countOrder.S_COUNT_NO,
- S_CNTR_CODE = cgDetail.S_CNTR_CODE,
- S_ITEM_CODE = cgDetail.S_ITEM_CODE,
- };
-
- countDetailList.Add(countDetail);
+ if (task.N_B_STATE == 1) {
+ if (!int.TryParse(task.S_EQ_TASK_CODE, out var code)) {
+ LogHelper.Info($"褰撳墠浠诲姟{task.S_CODE}娌℃湁鎵惧埌瀵瑰簲鐨勫浗鑷狝GV orderId锛�);
+ }
+ else {
+ var res = GZRobot.CancelGZOrder(code);
+ if (!res) {
+ LogHelper.Info($"鍥借嚜AGV鍙栨秷浠诲姟澶辫触锛�, "HosttoagvTask");
+ }
+ else {
+ LogHelper.Info($"鍥借嚜AGV鍙栨秷浠诲姟鎴愬姛锛�, "HosttoagvTask");
+ }
}
}
- else {
- return BuildSimpleResult(3, $"璁″垝鍗�{model.planId}'鐨勭被鍨媨countPlan.S_TYPE}涓嶅悎娉�);
- }
+
+ task.N_B_STATE = 4;
+ task.S_B_STATE = "鍙栨秷";
+
+ // 鍓嶉潰閿佺姸鎬佺殑閮ㄥ垎涓嶉渶瑕佷慨鏀癸細鏃犺鏈夋病鏈夋仮澶嶏紝閮藉己鍒舵仮澶嶏紝鏈�粓缁撴灉閮芥槸鏃犻攣鐘舵�
+
+ // 宸叉墽琛岋細闇�娣诲姞鐨勯�杈戯細閽堝瑙ｉ攣/缁戝畾鐨勮揣浣嶅鍣ㄨ〃锛堝ソ鍍忎笉闇�鍏冲績锛屽厛涓嶅仛浠讳綍鎿嶄綔锛�
using (var tran = db.Ado.UseTran()) {
- if (db.Insertable<TN_Count_Order>(countOrder).ExecuteCommand() <= 0) {
+ if (db.Updateable<TN_Location>(startloc).ExecuteCommand() <= 0) {
tran.RollbackTran();
- info = "鍒涘缓鐩樼偣鍗曞け璐�;
- return BuildSimpleResult(2, info);
+ info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触锛氫慨鏀硅捣鐐硅揣浣嶉攣鐘舵�澶辫触";
+ return BuildSimpleResult(500, info);
}
- if (db.Insertable<TN_Count_CG_Detail>(countDetailList).ExecuteCommand() <= 0) {
+ if (endloc != null) {
+ if (db.Updateable<TN_Location>(endloc).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触锛氫慨鏀圭粓鐐硅揣浣嶉攣鐘舵�澶辫触";
+ return BuildSimpleResult(500, info);
+ }
+ }
+
+ if (db.Updateable<TN_Task>(task).ExecuteCommand() <= 0) {
tran.RollbackTran();
- info = "鍒涘缓鐩樼偣鍗曟槑缁嗗け璐�;
- return BuildSimpleResult(3, info);
+ info = $"浠诲姟{task.S_CODE}鍙栨秷澶辫触";
+ return BuildSimpleResult(500, info);
}
tran.CommitTran();
+ info = $"浠诲姟{task.S_CODE}鍙栨秷鎴愬姛";
+ return BuildSimpleResult(0, info);
}
-
- return BuildSimpleResult(0, "鍒涘缓鐩樼偣鍗曟垚鍔�);
}
- catch (Exception ex) {
-
- return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+ catch (Exception) {
+ throw; // 澶栭儴catch
}
+
+ //return BuildSimpleResult(3, $"鍙湁浠诲姟鍙风姸鎬佷负 绛夊緟 鎴�宸叉帹閫�鐨勪换鍔℃墠鑳藉彇娑�);
}
- public static SimpleResult CountProduct(CountProductInfo model) {
+ public static ErpResult InboundDataSync(InboundDataSyncInfo model) {
+ //return BuildErpResult(1, "娴嬭瘯");
+
var db = new SqlHelper<object>().GetInstance();
try {
- var cgDetail = db.Queryable<TN_CG_Detail>()
- .Where(d => d.S_CNTR_CODE == model.cntrCode).First();
-
- if (cgDetail == null) {
- return BuildSimpleResult(2, $"鎵句笉鍒板鍣ㄥ彿'{model.cntrCode}'瀵瑰簲鐨勭墿鏂�);
+ if (model.stockTransactions == null && model.stockTransactions.Count == 0) {
+ return BuildErpResult(400, "涓嶈兘浼犲叆绌虹殑鏁版嵁鍒楄〃");
}
- var countDiff = new TN_Count_Diff {
- S_CNTR_CODE = cgDetail.S_CNTR_CODE,
- F_QTY = cgDetail.F_QTY,
- F_ACTUAL_QTY = model.qty
- };
+ //var info = "";
+ //var cgDetailList = new List<TN_CG_Detail>();
+ var insetRecordList = new List<TN_Inbound_DataRecord>();
+ var deleteRecordOldList = new List<TN_Inbound_DataRecord> ();
+ //var errList = new List<TN_Inbound_DataRecord>();
- if (db.Insertable<TN_Count_Diff>(countDiff).ExecuteCommand() <= 0) {
- return BuildSimpleResult(3, $"鎻掑叆鐩樼偣宸紓琛ㄥけ璐�);
+ foreach (var transaction in model.stockTransactions) {
+ var recordOld = db.Queryable<TN_Inbound_DataRecord>()
+ .Where(r => r.S_LOCATION_CODE == "HJQ-" + transaction.locationCode.Trim()).First();
+ if (recordOld != null) {
+ deleteRecordOldList.Add(recordOld);
+ //errList.Add(recordOld);
+ //continue;
+ }
+
+ // 鍐欏叆璁板綍琛�+ var record = new TN_Inbound_DataRecord {
+ S_LOCATION_CODE = "HJQ-" + transaction.locationCode.Trim(),
+ S_STOCK_TRANS = transaction.stockTransactionId,
+ S_ITEM_CODE = transaction.itemCode,
+ S_ITEM_NAME = transaction.itemName,
+ S_ITEM_SHORT_DESC = transaction.itemShortDesc,
+ S_STOCK_QUANTITY = transaction.stockQuantity, // 搴撳瓨鏁伴噺
+ S_IN_QUANTITY = transaction.inQuantity, // 鍏ュ簱鏁伴噺
+ S_TOTAL_PRICE = transaction.totalPrice,
+ S_STOCK_IN_TIME = transaction.stockInTime,
+ S_STORE_KEEPER = transaction.storeKeeper,
+ S_LINE_CODE = transaction.lineCode,
+ S_DELIVERY_ITEM_NO = transaction.deliveryItemNo,
+ S_SUPPLIER_NAME = transaction.supplierName,
+ S_INVENTORY_MAN = transaction.inventoryManager
+ };
+ insetRecordList.Add(record);
+
+ //// 鏌ヨ瀵瑰簲鐗╂枡
+ //var cgDetail = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail>
+ // ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE)
+ // .Where(l => l.S_CODE == transaction.locationCode)
+ // .Select((l, c, d) => d)
+ // .First();
+
+ //if (cgDetail == null) {
+ // err += $"鍌ㄤ綅鐮亄transaction.locationCode}瀵瑰簲鐨勮揣浣嶇墿鏂欎笉瀛樺湪锛�;
+ // continue;
+ //}
+ //cgDetail.S_ITEM_CODE = transaction.itemCode;
+ //cgDetail.S_ITEM_NAME = transaction.itemName;
+
+ //cgDetailList.Add(cgDetail);
+ }
+
+ using (var tran = db.Ado.UseTran()) {
+ if (deleteRecordOldList.Count != 0 && db.Deleteable<TN_Inbound_DataRecord>(deleteRecordOldList).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildErpResult(500, $"鍒犻櫎鏃у叆搴撹褰曟暟鎹け璐ワ細{JsonConvert.SerializeObject(deleteRecordOldList)}");
+ }
+
+ if (db.Insertable<TN_Inbound_DataRecord>(insetRecordList).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildErpResult(500, $"鍐欏叆鍏ュ簱璁板綍琛ㄥけ璐�");
+ }
+
+ //if (db.Updateable<TN_CG_Detail>(cgDetailList).ExecuteCommand() <= 0) {
+ // tran.RollbackTran();
+ // return BuildErpResult(500, $"鏇存敼鐗╂枡淇℃伅澶辫触锛佸緟鏇存柊鐗╂枡淇℃伅鏁伴噺={cgDetailList.Count}");
+ //}
+
+ tran.CommitTran();
+ return BuildErpResult(0, $"鍐欏叆鍏ュ簱璁板綍琛ㄦ垚鍔�");
}
- return BuildSimpleResult(0, "鐩樼偣宸紓瀹屾垚");
+ //if (err != "") {
+ // return BuildErpResult(2, err + "鍏朵粬淇℃伅姝ｅ父宸插啓鍏�);
+ //}
+ //return BuildErpResult(0, $"鏇存敼鐗╂枡淇℃伅鎴愬姛");
+
+ // NOTE锛氭殏鏃朵笉妫�煡锛屼竾涓�RP鍙戦敊浜嗭紝鍙互閫夋嫨閲嶅彂
+
+ //if (errList.Count > 0) {
+ // info = "鏇存敼鐗╂枡淇℃伅閮ㄥ垎鎴愬姛锛岄儴鍒嗗け璐ワ紝鍘熷洜锛氬綋鍓嶈揣浣嶅凡缁忕粰杩囩墿鏂欎俊鎭�;
+ //}
+ //else {
+ // info = "鏇存敼鐗╂枡淇℃伅鎴愬姛!";
+ //}
+ }
+ catch (Exception ex) {
+ return BuildErpResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+ }
+ }
+
+ public static ErpResult OutboundDataSync(OutboundDataSyncInfo model) {
+ //return BuildErpResult(1, "娴嬭瘯");
+
+ var db = new SqlHelper<object>().GetInstance();
+ try {
+ if (model.materialIssues == null || model.materialIssues.Count == 0) {
+ return BuildErpResult(400, "涓嶈兘浼犲叆绌虹殑鏁版嵁鍒楄〃");
+ }
+
+ //var err = "";
+ //var cgDetailList = new List<TN_CG_Detail>();
+ //var recordList = new List<TN_Outbound_DataRecord>();
+ var insetRecordList = new List<TN_Outbound_DataRecord>();
+ var deleteRecordOldList = new List<TN_Outbound_DataRecord>();
+ foreach (var issue in model.materialIssues) {
+ var recordOld = db.Queryable<TN_Outbound_DataRecord>()
+ .Where(r => r.S_LOCATION_CODE == "HJQ-" + issue.locationCode.Trim()).First();
+ if (recordOld != null) {
+ deleteRecordOldList.Add(recordOld);
+ //errList.Add(recordOld);
+ //continue;
+ }
+
+ // 鍐欏叆璁板綍琛�+ var record = new TN_Outbound_DataRecord {
+ S_LOCATION_CODE = "HJQ-" + issue.locationCode.Trim(),
+ S_ORDER_NO = issue.withdrawalOrderNo,
+ S_ITEM_CODE = issue.itemCode,
+ S_ITEM_NAME = issue.itemName,
+ S_SHORT_DESC = issue.itemShortDesc,
+ S_ACTUAL_QTY = issue.actualIssuedQty, // 瀹炲彂鏁伴噺
+ S_ISSUED_AMOUNT = issue.issuedAmount,
+ S_SUPPLIER_NAME = issue.supplierName,
+ S_ISSUER = issue.issuer,
+ S_ISSUE_DATE = issue.issueDate,
+ S_STORE_KEEPER = issue.storeKeeper,
+ S_LINE_CODE = issue.lineCode,
+ S_BATCH_NO = issue.batchNo
+ };
+ insetRecordList.Add(record);
+
+ //// 鏌ヨ瀵瑰簲鐗╂枡
+ //var cgDetail = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail>
+ // ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE)
+ // .Where(l => l.S_CODE == issue.locationCode)
+ // .Select((l, c, d) => d)
+ // .First();
+
+ //if (cgDetail == null) {
+ // err += $"鍌ㄤ綅鐮亄issue.locationCode}瀵瑰簲鐨勮揣浣嶇墿鏂欎笉瀛樺湪锛�;
+ // continue;
+ //}
+
+ //cgDetail.S_ITEM_CODE = issue.itemCode;
+ //cgDetail.S_ITEM_NAME = issue.itemName;
+
+ //cgDetailList.Add(cgDetail);
+ }
+
+ using (var tran = db.Ado.UseTran()) {
+ if (deleteRecordOldList.Count != 0 && db.Deleteable<TN_Outbound_DataRecord>(deleteRecordOldList).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildErpResult(500, $"鍒犻櫎鏃у嚭搴撹褰曟暟鎹け璐ワ細{JsonConvert.SerializeObject(deleteRecordOldList)}");
+ }
+
+ if (db.Insertable<TN_Outbound_DataRecord>(insetRecordList).ExecuteCommand() <= 0) {
+ tran.RollbackTran();
+ return BuildErpResult(500, $"鍐欏叆鍑哄簱璁板綍琛ㄥけ璐�);
+ }
+
+ //if (db.Updateable<TN_CG_Detail>(cgDetailList).ExecuteCommand() <= 0) {
+ // tran.RollbackTran();
+ // return BuildErpResult(500, $"鏇存敼鐗╂枡淇℃伅澶辫触");
+ //}
+
+ tran.CommitTran();
+ return BuildErpResult(0, $"鍐欏叆鍑哄簱璁板綍琛ㄦ垚鍔�");
+ }
+
+ //if (err != "") {
+ // return BuildErpResult(2, err + "鍏朵粬淇℃伅姝ｅ父宸插啓鍏�);
+ //}
+ //return BuildErpResult(0, $"鏇存敼鐗╂枡淇℃伅鎴愬姛");
}
catch (Exception ex) {
- return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+ return BuildErpResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
}
}
- internal static string GenerateNo(string snType, string prefix) {
- var id = SYSHelper.GetSerialNumber(snType, prefix);
- var date = DateTime.Now.ToString("yyMMdd");
- return $"{prefix}{date}{id.ToString().PadLeft(4, '0')}";
- }
+ // 鐩樼偣鍔熻兘锛堟柊锛�+
+
+
+ // 澶囩敤锛氱洏鐐圭浉鍏冲姛鑳斤紙鎭㈠锛�-----------------------------
/// <summary>
/// 鐩樼偣鐞嗚揣鍑哄簱(WMS)
@@ -569,7 +1115,7 @@
try {
// 璧风偣浣嶇疆锛氬彇鏀捐揣鍖猴紙鏈夎揣鐗┿�娌℃湁閿併�宸插惎鐢級
- var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[0].Contains(a.S_AREA_CODE));
+ var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[AreaIndex.H璐ф灦鍖篯.Contains(a.S_AREA_CODE));
if (startLoc == null) {
return BuildSimpleResult(2, $"璧风偣浣嶇疆 {model.startLoc} 涓嶇鍚堝嚭搴撴潯浠�);
}
@@ -592,14 +1138,22 @@
using (var tran = db.Ado.UseTran()) {
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
- it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
+ it.N_LOCK_STATE,
+ it.S_LOCK_STATE,
+ it.S_LOCK_OP,
+ it.T_MODIFY
+ }).ExecuteCommand() <= 0) {
tran.RollbackTran();
return BuildSimpleResult(500,
$"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}");
}
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
- it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
+ it.N_LOCK_STATE,
+ it.S_LOCK_STATE,
+ it.S_LOCK_OP,
+ it.T_MODIFY
+ }).ExecuteCommand() <= 0) {
tran.RollbackTran();
return BuildSimpleResult(500,
$"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
@@ -632,7 +1186,7 @@
try {
// 璧风偣浣嶇疆锛氬彇鏀捐揣鍖猴紙鏈夎揣鐗┿�娌℃湁閿併�宸插惎鐢級
- var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[0].Contains(a.S_AREA_CODE));
+ var startLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.startLoc && a.N_CURRENT_NUM == 1 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[AreaIndex.X鍗歌揣鍖篯.Contains(a.S_AREA_CODE));
if (startLoc == null) {
return BuildSimpleResult(2, $"璧风偣浣嶇疆 {model.startLoc} 涓嶇鍚堝洖搴撴潯浠�);
}
@@ -643,7 +1197,7 @@
}
// 缁堢偣浣嶇疆锛氳揣鏋讹紙娌℃湁璐х墿锛屾病鏈夐攣锛�- var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y");
+ var endLoc = db.Queryable<TN_Location>().First(a => a.S_CODE == model.endLoc && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && Settings.Areas[AreaIndex.H璐ф灦鍖篯.Contains(a.S_AREA_CODE));
if (endLoc == null) {
return BuildSimpleResult(4, $"缁堢偣浣嶇疆 {model.endLoc} 涓嶅叿澶囨斁璐ф潯浠�);
}
@@ -655,14 +1209,22 @@
using (var tran = db.Ado.UseTran()) {
if (db.Updateable<TN_Location>(startLoc).UpdateColumns(it => new {
- it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
+ it.N_LOCK_STATE,
+ it.S_LOCK_STATE,
+ it.S_LOCK_OP,
+ it.T_MODIFY
+ }).ExecuteCommand() <= 0) {
tran.RollbackTran();
return BuildSimpleResult(500,
$"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣浣�{endLoc.S_CODE}");
}
if (db.Updateable<TN_Location>(endLoc).UpdateColumns(it => new {
- it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() <= 0) {
+ it.N_LOCK_STATE,
+ it.S_LOCK_STATE,
+ it.S_LOCK_OP,
+ it.T_MODIFY
+ }).ExecuteCommand() <= 0) {
tran.RollbackTran();
return BuildSimpleResult(500,
$"鐢熸垚 {taskName} 澶辫触锛屽鍣ㄥ彿 {cntID} 锛岃捣鐐�{startLoc.S_CODE} 锛岀粓鐐硅揣鏋�{endLoc.S_CODE}");
@@ -684,80 +1246,181 @@
}
}
- public static ErpResult InboundDataSync(InboundDataSyncInfo model) {
+ //public static SimpleResult CreateCountPlan(CreateCountPlanInfo model) {
+ // var db = new SqlHelper<object>().GetInstance();
+ // try {
+
+ // var countPlan = new TN_Count_Plan() {
+ // S_CP_NO = GenerateNo("鐩樼偣璁″垝", "PDJH"), // CP =銆婸DJH
+ // S_TYPE = model.countType,
+ // };
+
+ // if (model.countType == "璐т綅") {
+ // countPlan.S_LOC_CODE = model.targetId;
+ // }
+ // else if (model.countType == "鐗╂枡") {
+ // countPlan.S_ITEM_CODE = model.targetId;
+ // }
+ // else {
+ // return BuildSimpleResult(2, $"鍒涘缓鐩樼偣璁″垝澶辫触锛氫笉鍚堟硶鐨勭洏鐐圭被鍨�'{model.countType}'");
+ // }
+
+ // if (db.Insertable<TN_Count_Plan>(countPlan).ExecuteCommand() <= 0) {
+ // return BuildSimpleResult(2, "鍒涘缓鐩樼偣璁″垝澶辫触");
+ // }
+
+ // return BuildSimpleResult(0, "鍒涘缓鐩樼偣璁″垝鎴愬姛");
+
+ // }
+ // catch (Exception ex) {
+
+ // return BuildSimpleResult(1, ex.Message);
+ // }
+ //}
+
+ //public static SimpleResult CreateCountOrder(CreateCountOrderInfo model) {
+ // var db = new SqlHelper<object>().GetInstance();
+ // var info = "";
+ // try {
+ // var countPlan = db.Queryable<TN_Count_Plan>()
+ // .Where(a => a.S_CP_NO == model.planId).First();
+
+ // if (countPlan == null) {
+ // return BuildSimpleResult(2, $"鐩樼偣璁″垝鍗曞彿 '{model.planId}' 涓嶅瓨鍦�);
+ // }
+
+ // var countOrder = new TN_Count_Order() {
+ // S_CP_NO = model.planId,
+ // S_COUNT_NO = GenerateNo("鐩樼偣鍗�, "PDD"), // CN =銆婸DD
+ // };
+
+ // var countDetailList = new List<TN_Count_CG_Detail>();
+ // if (countPlan.S_TYPE == "璐т綅") {
+ // var cgDetail = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail>
+ // ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE)
+ // .Where(l => l.S_CODE == countPlan.S_LOC_CODE)
+ // .Select((l, c, d) => d).First();
+
+ // if (cgDetail == null) {
+ // return BuildSimpleResult(3, $"鏈壘鍒版寚瀹氳揣浣峽countPlan.S_LOC_CODE}涓婄殑鐗╂枡");
+ // }
+
+ // var countDetail = new TN_Count_CG_Detail {
+ // S_COUNT_NO = countOrder.S_COUNT_NO,
+ // S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+ // S_ITEM_CODE = cgDetail.S_ITEM_CODE,
+ // };
+
+ // countDetailList.Add(countDetail);
+ // }
+ // else if (countPlan.S_TYPE == "鐗╂枡") {
+ // var cgDetail = db.Queryable<TN_CG_Detail>()
+ // .Where(d => d.S_ITEM_CODE == countPlan.S_ITEM_CODE).First(); // ToList -> First
+
+ // if (cgDetail == null) {
+ // return BuildSimpleResult(3, $"鏈壘鍒版寚瀹氱殑鐗╂枡{countPlan.S_ITEM_CODE}");
+ // }
+
+ // //foreach (var cgDetail in cgDetailList) {
+ // // var countDetail = new TN_Count_CG_Detail {
+ // // S_COUNT_NO = countOrder.S_COUNT_NO,
+ // // S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+ // // S_ITEM_CODE = cgDetail.S_ITEM_CODE,
+ // // };
+
+ // // countDetailList.Add(countDetail);
+ // //}
+
+ // var countDetail = new TN_Count_CG_Detail {
+ // S_COUNT_NO = countOrder.S_COUNT_NO,
+ // S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+ // S_ITEM_CODE = cgDetail.S_ITEM_CODE,
+ // };
+
+ // countDetailList.Add(countDetail);
+ // }
+ // else {
+ // return BuildSimpleResult(3, $"璁″垝鍗�{model.planId}'鐨勭被鍨媨countPlan.S_TYPE}涓嶅悎娉�);
+ // }
+
+ // using (var tran = db.Ado.UseTran()) {
+ // if (db.Insertable<TN_Count_Order>(countOrder).ExecuteCommand() <= 0) {
+ // tran.RollbackTran();
+ // info = "鍒涘缓鐩樼偣鍗曞け璐�;
+ // return BuildSimpleResult(2, info);
+ // }
+
+ // if (db.Insertable<TN_Count_CG_Detail>(countDetailList).ExecuteCommand() <= 0) {
+ // tran.RollbackTran();
+ // info = "鍒涘缓鐩樼偣鍗曟槑缁嗗け璐�;
+ // return BuildSimpleResult(3, info);
+ // }
+
+ // tran.CommitTran();
+ // }
+
+ // return BuildSimpleResult(0, "鍒涘缓鐩樼偣鍗曟垚鍔�);
+ // }
+ // catch (Exception ex) {
+
+ // return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+ // }
+ //}
+
+ public static SimpleResult CountProduct(CountProductInfo model) {
var db = new SqlHelper<object>().GetInstance();
try {
- var err = "";
- var cgDetailList = new List<TN_CG_Detail>();
- foreach (var inboundData in model.stockTransactions) {
- var cgDetail = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail>
- ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE)
- .Where(l => l.S_CODE == inboundData.locationCode)
- .Select((l, c, d) => d)
- .First();
-
- if (cgDetail == null) {
- err += $"鍌ㄤ綅鐮亄inboundData.locationCode}瀵瑰簲鐨勮揣浣嶇墿鏂欎笉瀛樺湪锛�;
- continue;
- }
+ //var cgDetail = db.Queryable<TN_CG_Detail>()
+ // .Where(d => d.S_CNTR_CODE == model.cntrCode).First();
- cgDetail.S_ITEM_CODE = inboundData.itemCode;
- cgDetail.S_ITEM_NAME = inboundData.itemName;
-
- cgDetailList.Add(cgDetail);
- }
-
- if (db.Updateable<TN_CG_Detail>(cgDetailList).ExecuteCommand() <= 0) {
- return BuildErpResult(500, $"鏇存敼鐗╂枡淇℃伅澶辫触");
+ //if (cgDetail == null) {
+ // return BuildSimpleResult(2, $"鎵句笉鍒板鍣ㄥ彿'{model.cntrCode}'瀵瑰簲鐨勭墿鏂�);
+ //}
+
+ var locCntrRel = db.Queryable<TN_Loc_Container>()
+ //.LeftJoin<TN_CG_Detail>((c, d) => c.S_CNTR_CODE == d.S_CNTR_CODE)
+ .Where(c => c.S_LOC_CODE == model.locCode).First();
+ if (locCntrRel == null) {
+ return BuildSimpleResult(2, $"褰撳墠璐т綅{model.locCode}娌℃湁瀹瑰櫒锛�);
}
- if (err != "") {
- return BuildErpResult(2, err);
+ var cgDetail = db.Queryable<TN_CG_Detail>()
+ .Where(d => d.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
+ if (cgDetail == null) {
+ return BuildSimpleResult(3, $"褰撳墠璐т綅{model.locCode}涓婄殑瀹瑰櫒{locCntrRel.S_CNTR_CODE}娌℃湁鐗╁搧锛�);
}
- return BuildErpResult(0, $"鏇存敼鐗╂枡淇℃伅鎴愬姛");
+
+ //var countDiff = new TN_Count_Diff {
+ // S_CNTR_CODE = cgDetail.S_CNTR_CODE,
+ // F_QTY = cgDetail.F_QTY,
+ // F_ACTUAL_QTY = model.qty
+ //};
+
+ var countDiff = db.Queryable<TN_AG_Count_Diff>().Where(d => d.S_CNTR_CODE == locCntrRel.S_CNTR_CODE).First();
+ if (countDiff == null) {
+ return BuildSimpleResult(4, $"褰撳墠鐗╂枡鎵�湪瀹瑰櫒{locCntrRel.S_CNTR_CODE}鐗╂枡淇℃伅娌℃湁鐢熸垚瀵瑰簲鐨勭洏鐐瑰樊寮傝〃锛�);
+ }
+
+ countDiff.F_QTY = cgDetail.F_QTY;
+ countDiff.F_ACTUAL_QTY = model.qty;
+ //countDiff.S_ITEM_CODE = cgDetail.S_ITEM_CODE;
+
+ //if (db.Insertable<TN_Count_Diff>(countDiff).ExecuteCommand() <= 0) {
+ // return BuildSimpleResult(3, $"鎻掑叆鐩樼偣宸紓琛ㄥけ璐�);
+ //}
+
+ if (db.Updateable<TN_AG_Count_Diff>(countDiff).ExecuteCommand() <= 0) {
+ return BuildSimpleResult(5, $"鎻掑叆鐩樼偣宸紓琛ㄥけ璐�);
+ }
+
+ return BuildSimpleResult(0, "鐩樼偣宸紓瀹屾垚");
}
catch (Exception ex) {
- return BuildErpResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
+ return BuildSimpleResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
}
}
- public static ErpResult OutboundDataSync(OutboundDataSyncInfo model) {
- var db = new SqlHelper<object>().GetInstance();
- try {
- var err = "";
- var cgDetailList = new List<TN_CG_Detail>();
- foreach (var inboundData in model.materialIssues) {
- var cgDetail = db.Queryable<TN_Location, TN_Loc_Container, TN_CG_Detail>
- ((l, c, d) => l.S_CODE == c.S_LOC_CODE && c.S_CNTR_CODE == d.S_CNTR_CODE)
- .Where(l => l.S_CODE == inboundData.locationCode)
- .Select((l, c, d) => d)
- .First();
- if (cgDetail == null) {
- err += $"鍌ㄤ綅鐮亄inboundData.locationCode}瀵瑰簲鐨勮揣浣嶇墿鏂欎笉瀛樺湪锛�;
- continue;
- }
-
- cgDetail.S_ITEM_CODE = inboundData.itemCode;
- cgDetail.S_ITEM_NAME = inboundData.itemName;
-
- cgDetailList.Add(cgDetail);
- }
-
- if (db.Updateable<TN_CG_Detail>(cgDetailList).ExecuteCommand() <= 0) {
- return BuildErpResult(500, $"鏇存敼鐗╂枡淇℃伅澶辫触");
- }
-
- if (err != "") {
- return BuildErpResult(2, err);
- }
- return BuildErpResult(0, $"鏇存敼鐗╂枡淇℃伅鎴愬姛");
-
- }
- catch (Exception ex) {
- return BuildErpResult(1, $"鍙戠敓浜嗗紓甯革細{ex.Message}");
- }
- }
}
}
--
Gitblit v1.9.1