From fad1333a599e562c8fa7ee350852fee72b9a6a28 Mon Sep 17 00:00:00 2001
From: 杨张扬 <634643841@qq.com>
Date: 星期三, 02 七月 2025 17:33:25 +0800
Subject: [PATCH] 出库任务取消在4之前不删除库存
---
core/Monitor.cs | 604 +++++++++++++++++++++++++++++++++++++++++-------------
1 files changed, 456 insertions(+), 148 deletions(-)
diff --git a/core/Monitor.cs b/core/Monitor.cs
index 1175125..f79b8a9 100644
--- a/core/Monitor.cs
+++ b/core/Monitor.cs
@@ -133,8 +133,11 @@
else
{
var endLoc = db.Queryable<TN_Location>().
- Where(c => c.S_AREA_CODE == Settings.Areas[1] && c.S_LOCK_STATE == "鏃� && c.N_LOCK_STATE == 0 && c.N_CURRENT_NUM == 0 && c.C_ENABLE == "Y").
- OrderBy(o => o.T_MODIFY, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝鐩存帴鍒ゆ柇褰撳墠鏁伴噺涓�鍗冲彲
+ Where(c => c.S_AREA_CODE == Settings.Areas[1] && c.S_LOCK_STATE == "鏃�
+ && c.N_LOCK_STATE == 0 && c.N_CURRENT_NUM == 0
+ && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == c.S_CODE).NotAny()//涓嶈兘鏈夎揣
+ && c.C_ENABLE == "Y").
+ OrderBy(o => o.N_LAYER, OrderByType.Asc).First();//鏌ヨ鍚堥�鐨勭粓鐐硅揣浣嶏紝鐩存帴鍒ゆ柇褰撳墠鏁伴噺涓�鍗冲彲
if (endLoc != null)
{
@@ -179,7 +182,7 @@
endLoc.N_LOCK_STATE = 1;
endLoc.S_LOCK_STATE = "鍏ュ簱閿�;
- startLoc.T_MODIFY = System.DateTime.Now;
+ endLoc.T_MODIFY = System.DateTime.Now;
using (var tran = db.Ado.UseTran())
{
@@ -197,16 +200,16 @@
var target = new TN_EquipProDetail()
{
S_ID = tN_CG_Detail.S_ID,
- TaskType = "PLC婊℃墭涓嬬嚎鍏ュ簱",
+ TASKTYPE = "PLC婊℃墭涓嬬嚎鍏ュ簱",
RFID = result.RfidData,
- Spec = woInfo.S_ITEM_SPEC,
- CarCode = modelCI.S_CAR_CODE,
- Weight = result.Weight,
- ItemState = "寰呮",
- ItemCode = woInfo.S_ITEM_CODE,
- LoginName = woInfo.S_LINE_NO,
- Shift = "None",
- StartLoc = startLoc.S_CODE,
+ SPEC = woInfo.S_ITEM_SPEC,
+ CARCODE = modelCI.S_CAR_CODE,
+ WEIGHT = result.Weight,
+ ITEMSTATE = "寰呮",
+ ITEMCODE = woInfo.S_ITEM_CODE,
+ LOGINNAME = woInfo.S_LINE_NO,
+ SHIFT = "None",
+ STARTLOC = startLoc.S_CODE,
};
SpecHelper.InsertEquipProDetail(target);
});
@@ -217,12 +220,12 @@
{
S_ID = tN_CG_Detail.S_ID,
RFID = result.RfidData,
- Spec = woInfo.S_ITEM_SPEC,
- Weight = result.Weight,
- ItemState = "寰呮",
- ItemCode = woInfo.S_ITEM_CODE,
- LoginName = woInfo.S_LINE_NO,
- Shift = "None",
+ SPEC = woInfo.S_ITEM_SPEC,
+ WEIGHT = result.Weight,
+ ITEMSTATE = "寰呮",
+ ITEMCODE = woInfo.S_ITEM_CODE,
+ LOGINNAME = woInfo.S_LINE_NO,
+ SHIFT = "None",
};
SpecHelper.InsertInventoryM(target);
});
@@ -278,7 +281,7 @@
return;
}
- var endLoc = db.Queryable<TN_Location>().
+ var endLoc = db.Queryable<TN_Location>().//绌烘墭涓婄嚎鐨勭粓鐐逛笉鏍￠獙鏄惁鏈夎揣
First(a => a.S_CODE == endPoint.PointIn && a.S_LOCK_STATE == "鏃� && a.N_LOCK_STATE == 0 && a.C_ENABLE == "Y");
if (endLoc == null)
@@ -347,7 +350,87 @@
}
/// <summary>
- /// 婊℃墭杩囨湡鍑哄簱 婊℃墭杩囨湡鍥炲簱锛屾弧鎵樿繃鏈熷洖鐐�+ /// 鍦ㄥ妫�尯妫�祴鐗╁搧鍚堟牸锛屽悎鏍肩殑鐗╁搧鑷姩鍥炲簱
+ /// </summary>
+ internal static void CGOkCheck()
+ {
+ var db = new SqlHelper<object>().GetInstance();
+ try
+ {
+ var startLoc = db.Queryable<TN_Location>()
+ .LeftJoin<TN_Loc_Container>((o, i) => o.S_CODE == i.S_LOC_CODE)
+ .LeftJoin<TN_CG_Detail>((o, i, s) => i.S_CNTR_CODE == s.S_CNTR_CODE)
+ .Where((o, i, s) => s.N_ITEM_STATE == 0 && s.S_ITEM_STATE == "鍚堟牸"
+ && o.S_AREA_CODE == Settings.Areas[7] && o.N_CURRENT_NUM > 0
+ && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First();
+
+ if (startLoc== null)
+ {
+ LogHelper.Info("澶嶆鍖烘病鏈夊悎鏍肩殑鐗╁搧锛屾棤闇�嚜鍔ㄨ繑鍥�);
+ return;
+ }
+
+ var endLoc = db.Queryable<TN_Location>()
+ .OrderBy(a => a.N_LAYER, OrderByType.Asc)
+ .First(a => a.S_AREA_CODE == Settings.Areas[1]
+ && a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃�
+ && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny()//涓嶈兘鏈夎揣
+ );
+
+ if (endLoc == null)
+ {
+ LogHelper.Info("缁堢偣搴撳尯宸叉弧鎴栬�宸插叏閮ㄩ攣浣�);
+ return;
+ }
+
+ var cginfo = db.Queryable<TN_CG_Detail>()
+ .LeftJoin<TN_Loc_Container>((o, i) => o.S_CNTR_CODE == i.S_CNTR_CODE)
+ .Where((o, i) => i.S_LOC_CODE == startLoc.S_CODE).First();
+
+ if (WCSHelper.CreateTask(startLoc.S_CODE, endLoc.S_CODE, "澶嶆鍚堟牸鑷姩鍥炲簱", 3, cginfo.S_CNTR_CODE, out string taskNo, cginfo.S_SPE))//鍒涘缓鎼�浠诲姟锛岃捣鐐圭粓鐐瑰鍣�+ {
+ LocationHelper.LockLoc(startLoc.S_CODE, 2);//璧风偣鍑哄簱閿侊紝
+ LocationHelper.LockLoc(endLoc.S_CODE, 1);//缁堢偣鍏ュ簱閿�+ LogHelper.Info($"鐢熸垚澶嶆鍚堟牸鑷姩鍥炲簱浠诲姟鎴愬姛锛屽鍣ㄥ彿{cginfo.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}");
+
+ Task task99 = Task.Run(() =>
+ {
+ WMSHelper.InsertOpInfo("鑷姩杞", "澶嶆鍚堟牸鑷姩鍥炲簱", cginfo.S_CNTR_CODE);
+ });
+
+ Task task27 = Task.Run(() =>
+ {
+ var target = new TN_InventoryM()
+ {
+ S_ID = cginfo.S_ID,
+ RFID = cginfo.S_CNTR_CODE,
+ SPEC = cginfo.S_SPE,
+ WEIGHT = cginfo.F_QTY,
+ ITEMSTATE = cginfo.S_ITEM_STATE,
+ ITEMCODE = cginfo.S_ITEM_CODE,
+ LOGINNAME = "鑷姩杞",
+ SHIFT = "鏃�,
+ };
+ SpecHelper.InsertInventoryM(target);
+ });
+
+ return ;
+ }
+ else
+ {
+ LogHelper.Info($"鐢熸垚澶嶆鍚堟牸鑷姩鍥炲簱浠诲姟澶辫触锛屽鍣ㄥ彿{cginfo.S_CNTR_CODE}锛岃捣鐐箋startLoc.S_CODE}锛岀粓鐐箋endLoc.S_CODE}");
+ return;
+ }
+
+ }
+ catch(Exception ex)
+ {
+ LogHelper.Error("CGOkCheck鍙戠敓浜嗗紓甯�, ex);
+ }
+ }
+
+ /// <summary>
+ /// 婊℃墭杩囨湡鍑哄簱 杩囨湡鍚堟牸鍥炲簱锛岃繃鏈熸鍝佸洖鐐� /// </summary>
internal static void FullOutTime()
{
@@ -366,8 +449,9 @@
if (startLoc_1 != null)
{
var endLoc_1 = db.Queryable<TN_Location>()
- .First(o => o.S_AREA_CODE == Settings.Areas[12] &&
- o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�);
+ .Where(o => o.S_AREA_CODE == Settings.Areas[12]
+ && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()//涓嶈兘鏈夎揣
+ && o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First();
if (endLoc_1 != null)
{
@@ -378,12 +462,17 @@
LocationHelper.LockLoc(startLoc_1.S_CODE, 2);//璧风偣鍑哄簱閿侊紝
LocationHelper.LockLoc(endLoc_1.S_CODE, 1);//缁堢偣鍏ュ簱閿� LogHelper.Info($"鐢熸垚婊℃墭杩囨湡鍑哄簱浠诲姟鎴愬姛锛屽鍣ㄥ彿{outTimeCg.S_CNTR_CODE}锛岃捣鐐箋startLoc_1.S_CODE}锛岀粓鐐箋endLoc_1.S_CODE}");
+
+ Task task27 = Task.Run(() =>
+ {
+ SpecHelper.DeleteInventoryM(outTimeCg.S_ID);
+ });
}
}
}
- //婊℃墭杩囨湡鍥炲簱
+ //杩囨湡鍚堟牸鍥炲簱
var startLoc_2 = db.Queryable<TN_Location>()
.LeftJoin<TN_Loc_Container>((o, i) => o.S_CODE == i.S_LOC_CODE)
.LeftJoin<TN_CG_Detail>((o, i, s) => i.S_CNTR_CODE == s.S_CNTR_CODE)
@@ -391,10 +480,95 @@
&& o.S_AREA_CODE == Settings.Areas[12] && o.N_CURRENT_NUM > 0
&& o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First();
+ if (startLoc_2 != null)
+ {
+ var endLoc_2 = db.Queryable<TN_Location>()
+ .Where(o => o.S_AREA_CODE == Settings.Areas[2]
+ && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()//涓嶈兘鏈夎揣
+ && o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�)
+ .First();
+
+ if (endLoc_2 != null)
+ {
+ var cntCode = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == startLoc_2.S_CODE);
+ var outTimeCg = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == cntCode.S_CNTR_CODE);
+ if (WCSHelper.CreateTask(startLoc_2.S_CODE, endLoc_2.S_CODE, "杩囨湡鍚堟牸鍥炲簱", 3, outTimeCg.S_CNTR_CODE, outTimeCg.S_SPE))
+ {
+ LocationHelper.LockLoc(startLoc_2.S_CODE, 2);//璧风偣鍑哄簱閿侊紝
+ LocationHelper.LockLoc(endLoc_2.S_CODE, 1);//缁堢偣鍏ュ簱閿�+
+ Task task27 = Task.Run(() =>
+ {
+ var target = new TN_InventoryM()
+ {
+ S_ID = outTimeCg.S_ID,
+ RFID = outTimeCg.S_CNTR_CODE,
+ SPEC = outTimeCg.S_SPE,
+ WEIGHT = outTimeCg.F_QTY,
+ ITEMSTATE = outTimeCg.S_ITEM_STATE,
+ ITEMCODE = outTimeCg.S_ITEM_CODE,
+ LOGINNAME = "杩囨湡鍚堟牸鍥炲簱杞",
+ SHIFT = "None",
+ };
+ SpecHelper.InsertInventoryM(target);
+ });
+
+ LogHelper.Info($"鐢熸垚杩囨湡鍚堟牸鍥炲簱浠诲姟鎴愬姛锛屽鍣ㄥ彿{outTimeCg.S_CNTR_CODE}锛岃捣鐐箋startLoc_2.S_CODE}锛岀粓鐐箋endLoc_2.S_CODE}");
+ }
+ }
+ }
+
+ //杩囨湡娆″搧鍥炵倝
+ var startLoc_3 = db.Queryable<TN_Location>()
+ .LeftJoin<TN_Loc_Container>((o, i) => o.S_CODE == i.S_LOC_CODE)
+ .LeftJoin<TN_CG_Detail>((o, i, s) => i.S_CNTR_CODE == s.S_CNTR_CODE)
+ .Where((o, i, s) => s.N_ITEM_STATE == 2 && s.S_ITEM_STATE == "涓嶅悎鏍�
+ && o.S_AREA_CODE == Settings.Areas[12] && o.N_CURRENT_NUM > 0
+ && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First();
+
+ if (startLoc_3 != null)
+ {
+ var endLoc_3 = db.Queryable<TN_Location>()
+ .Where(o => o.S_AREA_CODE == Settings.Areas[11]
+ && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == o.S_CODE).NotAny()//涓嶈兘鏈夎揣
+ && o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃�).First();
+
+ if (endLoc_3 != null)
+ {
+ var cntCode = db.Queryable<TN_Loc_Container>().First(a => a.S_LOC_CODE == startLoc_3.S_CODE);
+ var outTimeCg = db.Queryable<TN_CG_Detail>().First(a => a.S_CNTR_CODE == cntCode.S_CNTR_CODE);
+ if (WCSHelper.CreateTask(startLoc_3.S_CODE, endLoc_3.S_CODE, "杩囨湡娆″搧鍥炵倝", 3, outTimeCg.S_CNTR_CODE,out string taskno, outTimeCg.S_SPE))
+ {
+ LocationHelper.LockLoc(startLoc_3.S_CODE, 2);//璧风偣鍑哄簱閿侊紝
+ LocationHelper.LockLoc(endLoc_3.S_CODE, 1);//缁堢偣鍏ュ簱閿�+
+ Task task2 = Task.Run(() =>
+ {
+ var target = new TN_RemeltDetail()
+ {
+ TASKNO = taskno,
+ CNTCODE = outTimeCg.S_CNTR_CODE,
+ STARTLOC = startLoc_3.S_CODE,
+ LOGINNAME = "杩囨湡娆″搧鍥炵倝杞",
+ ITEMCODE = outTimeCg.S_ITEM_CODE,
+ SPEC = outTimeCg.S_SPE,
+ CARCODE = outTimeCg.S_CAR_CODE,
+ WEIGHT = outTimeCg.F_QTY,
+ REMELTTIME = DateTime.Now,
+ SHIFT = "None",
+ };
+ SpecHelper.InsertRemeltDetail(target);
+ });
+
+ LogHelper.Info($"鐢熸垚杩囨湡娆″搧鍥炵倝浠诲姟鎴愬姛锛屽鍣ㄥ彿{outTimeCg.S_CNTR_CODE}锛岃捣鐐箋startLoc_3.S_CODE}锛岀粓鐐箋endLoc_3.S_CODE}");
+ }
+ }
+ }
+
}
catch (Exception ex)
{
- LogHelper.Error($"鍙戠敓浜嗗紓甯革紝婊℃墭杩囨湡鍑哄簱 婊℃墭杩囨湡鍥炲簱锛屾弧鎵樿繃鏈熷洖鐐�寮傚父锛寋ex.Message}", ex);
+ LogHelper.Error($"鍙戠敓浜嗗紓甯革紝婊℃墭杩囨湡鍑哄簱 杩囨湡鍚堟牸鍥炲簱锛岃繃鏈熸鍝佸洖鐐�寮傚父锛寋ex.Message}", ex);
}
}
@@ -409,142 +583,261 @@
// 鍚屾 TN_EquipProDetail 涓�TN_CG_Detail
var targetEPD = db.Queryable<TN_EquipProDetail>().LeftJoin<TN_CG_Detail>((o, i) => o.S_ID == i.S_ID).
- Where((o, i) => o.ItemState != i.S_ITEM_STATE && i.S_ITEM_STATE != "寰呮").First();
- if (targetEPD != null)
- {
- targetEPD.ItemState = db.Queryable<TN_CG_Detail>().First(a => a.S_ID == targetEPD.S_ID).S_ITEM_STATE;
+ Where((o, i) => o.ITEMSTATE != i.S_ITEM_STATE && i.S_ITEM_STATE != "寰呮" && i.N_ITEM_STATE != 1).First();
- db.Updateable<TN_EquipProDetail>(targetEPD).ExecuteCommand();
+ if (targetEPD != null)//鍚屾璐у搧鐘舵�
+ {
+ targetEPD.ITEMSTATE = db.Queryable<TN_CG_Detail>().First(a => a.S_ID == targetEPD.S_ID).S_ITEM_STATE;
+ db.Updateable<TN_EquipProDetail>(targetEPD).UpdateColumns(it => new { it.ITEMSTATE }).ExecuteCommand();
}
targetEPD = db.Queryable<TN_EquipProDetail>().LeftJoin<TN_CG_Detail>((o, i) => o.S_ID == i.S_ID).
- Where((o, i) => System.DateTime.Now >= o.Expiration).First();
- if (targetEPD != null)
+ Where((o, i) => System.DateTime.Now >= o.EXPIRATION && i.S_ITEM_STATE == "寰呮" && i.N_ITEM_STATE == 1).First();
+
+ if (targetEPD != null)//妫�祴鍑鸿繃鏈熺殑璐у搧
{
- targetEPD.ItemState = "杩囨湡";
- db.Updateable<TN_EquipProDetail>(targetEPD).ExecuteCommand();
+ targetEPD.ITEMSTATE = "杩囨湡";
+ db.Updateable<TN_EquipProDetail>(targetEPD).UpdateColumns(it => new { it.ITEMSTATE }).ExecuteCommand();
var cginfo = db.Queryable<TN_CG_Detail>().First(a => a.S_ID == targetEPD.S_ID);
- cginfo.S_ITEM_STATE = "杩囨湡";
- cginfo.N_ITEM_STATE = 3;
- db.Updateable<TN_CG_Detail>(cginfo).ExecuteCommand();
- }
- // 鍚屾 TN_DayProDetail
- var curDay = System.DateTime.Now.Date;
- var targetDay = db.Queryable<TN_DayProDetail>().First(a => a.DayTime == curDay);
- if (targetDay == null)
- {
- targetDay = new TN_DayProDetail()
+ if (cginfo != null)
{
- DayTime = curDay,
- };
- db.Insertable(targetDay).ExecuteCommand();
- }
-
- var targetEPDs = db.Queryable<TN_EquipProDetail>().Where(a => a.DownLineTime >= curDay && a.DownLineTime <= curDay.AddDays(1)).ToList();
-
- var sumWeight = targetEPDs.Sum(a => a.Weight);
-
- if (targetEPDs.Count > 0)
- {
- if (targetDay.Weight != sumWeight)
- {
- targetDay.Weight = sumWeight;
- db.Updateable(targetDay).ExecuteCommand();
- }
-
- }
-
- // 鍚屾 TN_WeekProSpcDetail
- var curWeek = System.DateTime.Now.Date.AddDays(-(int)System.DateTime.Now.DayOfWeek + 1);
- var targetWeek = db.Queryable<TN_WeekProDetail>().First(a => a.DayTime == curWeek);
- if (targetWeek == null)
- {
- targetWeek = new TN_WeekProDetail()
- {
- DayTime = curWeek,
- };
- db.Insertable(targetWeek).ExecuteCommand();
- }
-
- targetEPDs = db.Queryable<TN_EquipProDetail>().Where(a => a.DownLineTime >= curWeek && a.DownLineTime <= curWeek.AddDays(7)).ToList();
- if (targetEPDs.Count > 0)
- {
- if (targetWeek.Weight != sumWeight)
- {
- targetWeek.Weight = sumWeight;
- db.Updateable(targetWeek).ExecuteCommand();
- }
- }
-
- // 鍚屾 TN_MonthProSpcDetail
- var curMonth = new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1).Date;
- var targetMonth = db.Queryable<TN_MonthProDetail>().First(a => a.DayTime == curMonth);
- if (targetMonth == null)
- {
- targetMonth = new TN_MonthProDetail()
- {
- DayTime = curMonth,
- };
- db.Insertable(targetMonth).ExecuteCommand();
- }
- targetEPDs = db.Queryable<TN_EquipProDetail>().Where(a => a.DownLineTime >= curMonth && a.DownLineTime <= curMonth.AddMonths(1)).ToList();
- if (targetEPDs.Count > 0)
- {
- if (targetMonth.Weight != sumWeight)
- {
- targetMonth.Weight = sumWeight;
- db.Updateable(targetMonth).ExecuteCommand();
- }
- }
-
- // 鍚屾 TN_YearProSpcDetail
- var curYear = new DateTime(DateTime.Now.Year, 1, 1).Date;
- var targetYear = db.Queryable<TN_YearProDetail>().First(a => a.DayTime == curYear);
- if (targetYear == null)
- {
- targetYear = new TN_YearProDetail()
- {
- DayTime = curYear,
- };
- db.Insertable(targetYear).ExecuteCommand();
- }
- targetEPDs = db.Queryable<TN_EquipProDetail>().Where(a => a.DownLineTime >= curYear && a.DownLineTime <= curYear.AddYears(1)).ToList();
- if (targetEPDs.Count > 0)
- {
- if (targetYear.Weight != sumWeight)
- {
- targetYear.Weight = sumWeight;
- db.Updateable(targetYear).ExecuteCommand();
+ cginfo.S_ITEM_STATE = "杩囨湡";
+ cginfo.N_ITEM_STATE = 3;
+ db.Updateable<TN_CG_Detail>(cginfo).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand();
}
}
// 鍚屾 TN_InventoryM 涓�TN_CG_Detail
var targetInM = db.Queryable<TN_InventoryM>().LeftJoin<TN_CG_Detail>((o, i) => o.S_ID == i.S_ID).
- Where((o, i) => o.ItemState != i.S_ITEM_STATE && i.S_ITEM_STATE != "寰呮").First();
- if (targetInM != null)
- {
- targetInM.ItemState = db.Queryable<TN_CG_Detail>().First(a => a.S_ID == targetInM.S_ID).S_ITEM_STATE;
+ Where((o, i) => o.ITEMSTATE != i.S_ITEM_STATE && i.S_ITEM_STATE != "寰呮" && i.N_ITEM_STATE != 1).First();
- db.Updateable<TN_InventoryM>(targetInM).ExecuteCommand();
- }
- targetInM = db.Queryable<TN_InventoryM>().LeftJoin<TN_CG_Detail>((o, i) => o.S_ID == i.S_ID).
- Where((o, i) => System.DateTime.Now >= o.Expiration).First();
- if (targetInM != null)
+ if (targetInM != null)//鍚屾璐у搧鐘舵�
{
- targetInM.ItemState = "杩囨湡";
- db.Updateable<TN_InventoryM>(targetInM).ExecuteCommand();
+ targetInM.ITEMSTATE = db.Queryable<TN_CG_Detail>().First(a => a.S_ID == targetInM.S_ID).S_ITEM_STATE;
+ db.Updateable<TN_InventoryM>(targetInM).UpdateColumns(it => new { it.ITEMSTATE }).ExecuteCommand();
+ }
+
+
+ targetInM = db.Queryable<TN_InventoryM>().LeftJoin<TN_CG_Detail>((o, i) => o.S_ID == i.S_ID).
+ Where((o, i) => System.DateTime.Now >= o.EXPIRATION
+ && ((i.S_ITEM_STATE == "寰呮" && i.N_ITEM_STATE == 1)
+ || (i.S_ITEM_STATE == "鍚堟牸" && i.N_ITEM_STATE == 0))
+ ).First();
+
+ if (targetInM != null)//妫�祴鍑哄凡杩囨湡鐨勮揣鍝�+ {
+ targetInM.ITEMSTATE = "杩囨湡";
+ targetInM.EXPIRATION_DAY = "0";
+ db.Updateable<TN_InventoryM>(targetInM).UpdateColumns(it => new { it.ITEMSTATE }).ExecuteCommand();
var cginfo = db.Queryable<TN_CG_Detail>().First(a => a.S_ID == targetInM.S_ID);
- cginfo.S_ITEM_STATE = "杩囨湡";
- cginfo.N_ITEM_STATE = 3;
- db.Updateable<TN_CG_Detail>(cginfo).ExecuteCommand();
+
+ if (cginfo != null)
+ {
+ cginfo.S_ITEM_STATE = "杩囨湡";
+ cginfo.N_ITEM_STATE = 3;
+ db.Updateable<TN_CG_Detail>(cginfo).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).ExecuteCommand();
+ }
+ }
+
+ var targetInMList = db.Queryable<TN_InventoryM>().LeftJoin<TN_CG_Detail>((o, i) => o.S_ID == i.S_ID).
+ Where((o, i) => System.DateTime.Now < o.EXPIRATION
+ && ((i.S_ITEM_STATE == "寰呮" && i.N_ITEM_STATE == 1)
+ || (i.S_ITEM_STATE == "鍚堟牸" && i.N_ITEM_STATE == 0))
+ ).ToList();
+
+ if (targetInMList.Count > 0)//妫�祴鍑哄揩杩囨湡鐨勮揣鍝�+ {
+ foreach (var item in targetInMList)
+ {
+ item.EXPIRATION_DAY = SpecHelper.CalculateDaysDifference(System.DateTime.Now, item.EXPIRATION).ToString();
+ }
+ db.Updateable<TN_InventoryM>(targetInMList).UpdateColumns(it => new { it.EXPIRATION_DAY }).ExecuteCommand();
+ }
+
+ targetInM = db.Queryable<TN_InventoryM>().First(a => Convert.ToInt32(a.EXPIRATION_DAY) > 0 && a.ITEMSTATE == "杩囨湡");
+ if (targetInM != null)//宸茶繃鏈熺殑璐у搧锛屽墿浣欏ぉ鏁版敼涓�
+ {
+ targetInM.EXPIRATION_DAY = "0";
+ db.Updateable<TN_InventoryM>(targetInM).UpdateColumns(it => new { it.EXPIRATION_DAY }).ExecuteCommand();
+ }
+
+ // 鍚屾 TN_DayProDetail
+ var curDay = System.DateTime.Now.Date;
+ var targetEPDs = db.Queryable<TN_EquipProDetail>().Where(a => a.DOWNLINETIME >= curDay && a.DOWNLINETIME <= curDay.AddDays(1)).ToList();
+
+ var specList = targetEPDs.Select(a => a.SPEC).Distinct().ToList();//褰撳ぉ鐨勮揣鍝佹湁鍝簺瑙勬牸
+
+ if (specList.Count>0)
+ {
+ foreach (var item in specList)
+ {
+ var targetDay = db.Queryable<TN_DayProDetail>().First(a => a.DAYTIME == curDay && a.SPEC == item);
+ if (targetDay == null)
+ {
+ targetDay = new TN_DayProDetail()
+ {
+ DAYTIME = curDay,
+ SPEC = item,
+ };
+ db.Insertable(targetDay).ExecuteCommand();
+ }
+ else
+ {
+ var sumWeight = targetEPDs.Where(b=>b.SPEC == item).Sum(a => a.WEIGHT);
+
+ if (targetDay.WEIGHT != sumWeight)
+ {
+ targetDay.WEIGHT = sumWeight;
+ db.Updateable(targetDay).ExecuteCommand();
+ }
+ else
+ {
+ LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_DayProDetail璺宠繃");
+ }
+ }
+ }
+ }
+ else
+ {
+ LogHelper.Info("褰撳ぉ鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_DayProDetail璺宠繃");
+ }
+
+ // 鍚屾 TN_WeekProSpcDetail
+ var curWeek = System.DateTime.Now.Date.AddDays(-(int)System.DateTime.Now.DayOfWeek + 1);
+ targetEPDs = db.Queryable<TN_EquipProDetail>().Where(a => a.DOWNLINETIME >= curWeek && a.DOWNLINETIME <= curWeek.AddDays(7)).ToList();
+ specList = targetEPDs.Select(a => a.SPEC).Distinct().ToList();//褰撳懆鐨勮揣鍝佹湁鍝簺瑙勬牸
+ if (specList.Count > 0)
+ {
+ foreach (var item in specList)
+ {
+ var targetWeek = db.Queryable<TN_WeekProDetail>().First(a => a.DAYTIME == curWeek && a.SPEC == item);
+ if (targetWeek == null)
+ {
+ targetWeek = new TN_WeekProDetail()
+ {
+ DAYTIME = curWeek,
+ SPEC = item,
+ };
+ db.Insertable(targetWeek).ExecuteCommand();
+ }
+ else
+ {
+ var sumWeight = targetEPDs.Where(b => b.SPEC == item).Sum(a => a.WEIGHT);
+ if (targetWeek.WEIGHT != sumWeight)
+ {
+ targetWeek.WEIGHT = sumWeight;
+ db.Updateable(targetWeek).ExecuteCommand();
+ }
+ else
+ {
+ LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_WeekProSpcDetail璺宠繃");
+ }
+ }
+ }
+ }
+ else
+ {
+ LogHelper.Info("褰撳懆鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_WeekProSpcDetail璺宠繃");
+ }
+
+ // 鍚屾 TN_MonthProSpcDetail
+ var curMonth = new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1).Date;
+ targetEPDs = db.Queryable<TN_EquipProDetail>().Where(a => a.DOWNLINETIME >= curMonth && a.DOWNLINETIME <= curMonth.AddMonths(1)).ToList();
+ specList = targetEPDs.Select(a => a.SPEC).Distinct().ToList();//褰撴湀鐨勮揣鍝佹湁鍝簺瑙勬牸
+ if (specList.Count > 0)
+ {
+ foreach (var item in specList)
+ {
+ var targetMonth = db.Queryable<TN_MonthProDetail>().First(a => a.DAYTIME == curMonth && a.SPEC == item);
+ if (targetMonth == null)
+ {
+ targetMonth = new TN_MonthProDetail()
+ {
+ DAYTIME = curMonth,
+ SPEC = item,
+ };
+ db.Insertable(targetMonth).ExecuteCommand();
+ }
+ else
+ {
+ var sumWeight = targetEPDs.Where(b => b.SPEC == item).Sum(a => a.WEIGHT);
+ if (targetMonth.WEIGHT != sumWeight)
+ {
+ targetMonth.WEIGHT = sumWeight;
+ db.Updateable(targetMonth).ExecuteCommand();
+ }
+ else
+ {
+ LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_MonthProSpcDetail璺宠繃");
+ }
+ }
+ }
+ }
+ else
+ {
+ LogHelper.Info("褰撴湀鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_MonthProSpcDetail璺宠繃");
+ }
+
+ // 鍚屾 TN_YearProSpcDetail
+ var curYear = new DateTime(DateTime.Now.Year, 1, 1).Date;
+
+ targetEPDs = db.Queryable<TN_EquipProDetail>().Where(a => a.DOWNLINETIME >= curYear && a.DOWNLINETIME <= curYear.AddYears(1)).ToList();
+ specList = targetEPDs.Select(a => a.SPEC).Distinct().ToList();//褰撳勾鐨勮揣鍝佹湁鍝簺瑙勬牸
+ if (specList.Count > 0)
+ {
+ foreach (var item in specList)
+ {
+ var targetYear = db.Queryable<TN_YearProDetail>().First(a => a.DAYTIME == curYear && a.SPEC == item);
+ if (targetYear == null)
+ {
+ targetYear = new TN_YearProDetail()
+ {
+ DAYTIME = curYear,
+ SPEC = item,
+ };
+ db.Insertable(targetYear).ExecuteCommand();
+ }
+ else
+ {
+ var sumWeight = targetEPDs.Where(b => b.SPEC == item).Sum(a => a.WEIGHT);
+ if (targetYear.WEIGHT != sumWeight)
+ {
+ targetYear.WEIGHT = sumWeight;
+ db.Updateable(targetYear).ExecuteCommand();
+ }
+ else
+ {
+ LogHelper.Info("閲嶉噺鐩哥瓑锛屽悓姝N_YearProSpcDetail璺宠繃");
+ }
+ }
+ }
+ }
+ else
+ {
+ LogHelper.Info("褰撳勾鐨勮揣鍝佽鏍煎垪琛ㄤ负0锛屽悓姝N_YearProSpcDetail璺宠繃");
}
}
catch (Exception ex)
{
- LogHelper.Error($"鍙戠敓浜嗗紓甯革紝鍚屾TN_EquipProDetail寮傚父锛寋ex.Message}", ex);
+ // 鑾峰彇鏈�唴灞傚紓甯革紙閫氬父鏄疄闄呭紩鍙戦棶棰樼殑寮傚父锛�+ Exception innerEx = ex;
+ while (innerEx.InnerException != null)
+ {
+ innerEx = innerEx.InnerException;
+ }
+
+ // 鑾峰彇鍫嗘爤甯т俊鎭�+ var stackTrace = new System.Diagnostics.StackTrace(innerEx, true);
+ var stackFrame = stackTrace.GetFrame(0); // 鑾峰彇鏈�《灞傜殑鍫嗘爤甯�+
+ // 鑾峰彇鏂囦欢鍚嶅拰琛屽彿
+ string fileName = stackFrame.GetFileName();
+ int lineNumber = stackFrame.GetFileLineNumber();
+
+ LogHelper.Error($"鍙戠敓浜嗗紓甯革紝鍚屾TN_EquipProDetail寮傚父锛屾枃浠�{fileName}, 琛屽彿:{lineNumber}, 閿欒:{ex.Message}\r\n{ex.StackTrace}", ex);
}
}
@@ -610,21 +903,28 @@
var db = new SqlHelper<object>().GetInstance();
try
{
- var endLoc = db.Queryable<TN_Location>().First(a => a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.S_AREA_CODE == Settings.Areas[7]);
- if (endLoc == null)
- {
- LogHelper.Info($"鏈壘鍒板悎閫傜殑缁堢偣璐т綅锛岃姹俛.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == 鏃�&& a.S_AREA_CODE == Settings.Areas[7]");
- return;
- }
+
var startLoc = db.Queryable<TN_Location>().
LeftJoin<TN_Loc_Container>((o, i) => o.S_CODE == i.S_LOC_CODE).
LeftJoin<TN_CG_Detail>((o, i, s) => i.S_CNTR_CODE == s.S_CNTR_CODE).
Where((o, i, s) => o.N_CURRENT_NUM == 1 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "鏃� && o.S_AREA_CODE == Settings.Areas[1]
&& s.N_ITEM_STATE == 2 && s.S_ITEM_STATE == "涓嶅悎鏍�).First();
+
+ if (startLoc == null)
+ {
+ LogHelper.Info($"鏈壘鍒板悎閫傜殑璧风偣璐т綅锛岃姹俹.N_CURRENT_NUM == 1 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == 鏃�&& o.S_AREA_CODE == Settings.Areas[1] && s.N_ITEM_STATE ==2 && s.S_ITEM_STATE==涓嶅悎鏍�);
+ return;
+ }
+
+
+ var endLoc = db.Queryable<TN_Location>()
+ .Where(a => a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃�
+ && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny()//涓嶈兘鏈夎揣
+ && a.S_AREA_CODE == Settings.Areas[7]).First();
if (endLoc == null)
{
- LogHelper.Info($"鏈壘鍒板悎閫傜殑璧风偣璐т綅锛岃姹俹.N_CURRENT_NUM == 1 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == 鏃�&& o.S_AREA_CODE == Settings.Areas[1] && s.N_ITEM_STATE ==2 && s.S_ITEM_STATE==涓嶅悎鏍�);
+ LogHelper.Info($"鏈壘鍒板悎閫傜殑缁堢偣璐т綅锛岃姹俛.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == 鏃�&& a.S_AREA_CODE == Settings.Areas[7]");
return;
}
@@ -642,11 +942,16 @@
LocationHelper.LockLoc(startLoc.S_CODE, 2);//璧风偣鍑哄簱閿侊紝
LocationHelper.LockLoc(endLoc.S_CODE, 1);//缁堢偣鍏ュ簱閿�
- LogHelper.Info($"鐢熸垚婊℃墭鍑哄簱澶嶆浠诲姟鎴愬姛锛屽鍣細{cntId.S_CNTR_CODE}锛岃捣鐐癸細{startLoc.S_CODE}");
+ LogHelper.Info($"鐢熸垚婊℃墭鍑哄簱澶嶆浠诲姟鎴愬姛锛屽鍣細{cntId.S_CNTR_CODE}锛岃捣鐐癸細{startLoc.S_CODE}锛岀粓鐐癸細{endLoc.S_CODE}");
+
+ Task task27 = Task.Run(() =>
+ {
+ SpecHelper.DeleteInventoryM(cgInfo.S_ID);
+ });
}
else
{
- LogHelper.Info($"鐢熸垚婊℃墭鍑哄簱澶嶆浠诲姟澶辫触锛屽鍣細{cntId.S_CNTR_CODE}锛岃捣鐐癸細{startLoc.S_CODE}");
+ LogHelper.Info($"鐢熸垚婊℃墭鍑哄簱澶嶆浠诲姟澶辫触锛屽鍣細{cntId.S_CNTR_CODE}锛岃捣鐐癸細{startLoc.S_CODE}锛岀粓鐐癸細{endLoc.S_CODE}");
}
@@ -677,7 +982,10 @@
}
var endLoc = db.Queryable<TN_Location>().
- Where(a => a.S_AREA_CODE == Settings.Areas[4] && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && a.N_CURRENT_NUM == 0).
+ Where(a => a.S_AREA_CODE == Settings.Areas[4] && a.N_LOCK_STATE == 0
+ && a.S_LOCK_STATE == "鏃� && a.C_ENABLE == "Y" && a.N_CURRENT_NUM == 0
+ && SqlFunc.Subqueryable<TN_Loc_Container>().Where(b => b.S_LOC_CODE == a.S_CODE).NotAny()
+ ).
OrderBy(a => a.N_CURRENT_NUM, OrderByType.Asc).
First();
--
Gitblit v1.9.1