| | |
| | | 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"). |
| | | 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.T_MODIFY, OrderByType.Asc).First();//查询合适的终点货位,直接判断当前数量为0即可 |
| | | |
| | | if (endLoc != null) |
| | |
| | | |
| | | 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()) |
| | | { |
| | |
| | | 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) |
| | |
| | | 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) |
| | | { |
| | |
| | | if (startLoc_2 != null) |
| | | { |
| | | var endLoc_2 = db.Queryable<TN_Location>() |
| | | .First(o => o.S_AREA_CODE == Settings.Areas[2] && |
| | | o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "无"); |
| | | .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) |
| | | { |
| | |
| | | if (startLoc_3 != null) |
| | | { |
| | | var endLoc_3 = db.Queryable<TN_Location>() |
| | | .First(o => o.S_AREA_CODE == Settings.Areas[11] && |
| | | o.N_CURRENT_NUM == 0 && o.N_LOCK_STATE == 0 && o.S_LOCK_STATE == "无"); |
| | | .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) |
| | | { |
| | |
| | | SPEC = outTimeCg.S_SPE, |
| | | CARCODE = outTimeCg.S_CAR_CODE, |
| | | WEIGHT = outTimeCg.F_QTY, |
| | | REMELTTIME = DateTime.Now |
| | | REMELTTIME = DateTime.Now, |
| | | SHIFT = "None", |
| | | }; |
| | | SpecHelper.InsertRemeltDetail(target); |
| | | }); |
| | |
| | | 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 != "待检" && i.N_ITEM_STATE != 1).First(); |
| | | |
| | | if (targetEPD != null) |
| | | 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 && i.S_ITEM_STATE == "待检" && i.N_ITEM_STATE == 1).First(); |
| | | |
| | | if (targetEPD != null) |
| | | if (targetEPD != null)//检测出过期的货品 |
| | | { |
| | | targetEPD.ITEMSTATE = "过期"; |
| | | db.Updateable<TN_EquipProDetail>(targetEPD).UpdateColumns(it => new { it.ITEMSTATE }).ExecuteCommand(); |
| | |
| | | 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 != "待检" && i.N_ITEM_STATE != 1).First(); |
| | | |
| | | if (targetInM != null) |
| | | if (targetInM != null)//同步货品状态 |
| | | { |
| | | 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).First(); |
| | | |
| | | if (targetInM != null) |
| | | 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.N_ITEM_STATE = 3; |
| | | db.Updateable<TN_CG_Detail>(cginfo).UpdateColumns(it => new { it.S_ITEM_STATE, it.N_ITEM_STATE }).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).First(); |
| | | |
| | | if (targetInM != null)//检测出快过期的货品 |
| | | { |
| | | targetInM.EXPIRATION_DAY = SpecHelper.CalculateDaysDifference(System.DateTime.Now,targetInM.EXPIRATION).ToString(); |
| | | db.Updateable<TN_InventoryM>(targetInM).UpdateColumns(it => new { it.EXPIRATION_DAY }).ExecuteCommand(); |
| | | } |
| | | |
| | | targetInM = db.Queryable<TN_InventoryM>().First(a => Convert.ToInt32(a.EXPIRATION_DAY) > 0 && a.ITEMSTATE == "过期");//已过期的货品,剩余天数改为0 |
| | | 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 targetDay = db.Queryable<TN_DayProDetail>().First(a => a.DAYTIME == curDay); |
| | | if (targetDay == null) |
| | | { |
| | | targetDay = new TN_DayProDetail() |
| | | { |
| | | 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); |
| | | var specList = targetEPDs.Select(a => a.SPEC).Distinct().ToList();//当天的货品有哪些规格 |
| | | |
| | | if (targetEPDs.Count > 0) |
| | | if (specList.Count>0) |
| | | { |
| | | if (targetDay.WEIGHT != sumWeight) |
| | | foreach (var item in specList) |
| | | { |
| | | targetDay.WEIGHT = sumWeight; |
| | | db.Updateable(targetDay).ExecuteCommand(); |
| | | } |
| | | 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("重量相等,同步TN_DayProDetail跳过"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | else |
| | | { |
| | | LogHelper.Info("当天的货品规格列表为0,同步TN_DayProDetail跳过"); |
| | | } |
| | | |
| | | // 同步 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) |
| | | specList = targetEPDs.Select(a => a.SPEC).Distinct().ToList();//当周的货品有哪些规格 |
| | | if (specList.Count > 0) |
| | | { |
| | | if (targetWeek.WEIGHT != sumWeight) |
| | | foreach (var item in specList) |
| | | { |
| | | targetWeek.WEIGHT = sumWeight; |
| | | db.Updateable(targetWeek).ExecuteCommand(); |
| | | 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("重量相等,同步TN_WeekProSpcDetail跳过"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | else |
| | | { |
| | | LogHelper.Info("当周的货品规格列表为0,同步TN_WeekProSpcDetail跳过"); |
| | | } |
| | | |
| | | // 同步 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) |
| | | specList = targetEPDs.Select(a => a.SPEC).Distinct().ToList();//当月的货品有哪些规格 |
| | | if (specList.Count > 0) |
| | | { |
| | | if (targetMonth.WEIGHT != sumWeight) |
| | | foreach (var item in specList) |
| | | { |
| | | targetMonth.WEIGHT = sumWeight; |
| | | db.Updateable(targetMonth).ExecuteCommand(); |
| | | 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("重量相等,同步TN_MonthProSpcDetail跳过"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | else |
| | | { |
| | | LogHelper.Info("当月的货品规格列表为0,同步TN_MonthProSpcDetail跳过"); |
| | | } |
| | | |
| | | // 同步 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) |
| | | specList = targetEPDs.Select(a => a.SPEC).Distinct().ToList();//当年的货品有哪些规格 |
| | | if (specList.Count > 0) |
| | | { |
| | | if (targetYear.WEIGHT != sumWeight) |
| | | foreach (var item in specList) |
| | | { |
| | | targetYear.WEIGHT = sumWeight; |
| | | db.Updateable(targetYear).ExecuteCommand(); |
| | | 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("重量相等,同步TN_YearProSpcDetail跳过"); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | else |
| | | { |
| | | LogHelper.Info("当年的货品规格列表为0,同步TN_YearProSpcDetail跳过"); |
| | | } |
| | | } |
| | | catch (Exception ex) |
| | |
| | | } |
| | | |
| | | |
| | | 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]); |
| | | 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($"未找到合适的终点货位,要求a.N_CURRENT_NUM == 0 && a.N_LOCK_STATE == 0 && a.S_LOCK_STATE == 无 && a.S_AREA_CODE == Settings.Areas[7]"); |
| | |
| | | } |
| | | |
| | | 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(); |
| | | |