WMSPrjInstance/HH-0121_DuShanZiShiHua.git

			@@ -23,12 +23,12 @@
			if (load) {
			Console.WriteLine($"任务{mst.S_CODE} 货位{mst.S_START_LOC}取货完成,起点解绑容器{mst.S_CNTR_CODE}");
			LogHelper.Info($"任务{mst.S_CODE} 货位{mst.S_START_LOC}取货完成,起点解绑容器{mst.S_CNTR_CODE}");
			LocationHelper.UnbindLocCntr(mst.S_START_LOC, mst.S_CNTR_CODE.Split(',').ToList());
			UnbindLocCntr(mst.S_START_LOC, mst.S_CNTR_CODE.Split(',').ToList());
			}
			else {
			Console.WriteLine($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成,终点绑定容器{mst.S_CNTR_CODE}");
			LogHelper.Info($"任务{mst.S_CODE} 货位{mst.S_END_LOC}卸货完成,终点绑定容器{mst.S_CNTR_CODE}");
			LocationHelper.BindingLoc(mst.S_END_LOC, mst.S_CNTR_CODE.Split(',').ToList());
			BindingLoc(mst.S_END_LOC, mst.S_CNTR_CODE.Split(',').ToList());
			}
			}

			@@ -42,13 +42,13 @@
			//根据客户现场要求,如果取货完成任务失败人工拉到终点,我们就当卸货完成处理;如果是人工拉走到其它区域,我们就解锁终点,删除托盘。
			//终点绑定
			BufferLocUpdate(mst, false);
			LocationHelper.UnLockLoc(mst.S_END_LOC);
			UnLockLoc(mst.S_END_LOC);
			}
			else {

			//起点终点解锁
			LocationHelper.UnLockLoc(mst.S_START_LOC);
			LocationHelper.UnLockLoc(mst.S_END_LOC);
			UnLockLoc(mst.S_START_LOC);
			UnLockLoc(mst.S_END_LOC);

			}

			@@ -99,6 +99,164 @@
			}
			}

			/// <summary>
			/// 取货完解锁起点,卸货完解锁终点,可检验锁的来源,也可以不校验
			/// </summary>
			/// <param name="loc"></param>
			/// <returns></returns>
			public static bool UnLockLoc(string loc) {
			LogHelper.Info("UnLockLoc:" + loc);
			var res = false;
			var db = new SqlHelper<object>().GetInstance();
			var model = db.Queryable<TN_Location>().Where(a => a.S_CODE == loc).First();
			if (model != null) {
			model.S_LOCK_STATE = "无";
			model.N_LOCK_STATE = 0;
			model.S_LOCK_OP = "";
			model.T_MODIFY = System.DateTime.Now;
			res = db.Updateable(model).UpdateColumns(it => new { it.N_LOCK_STATE, it.S_LOCK_STATE, it.S_LOCK_OP, it.T_MODIFY }).ExecuteCommand() > 0;
			LogHelper.Info("UnLockLoc:解锁结果" + res);
			}
			else {
			LogHelper.Info("UnLockLoc 失败" + loc);
			}
			return res;
			}

			/// <summary>
			/// 货位解绑容器
			/// </summary>
			/// <param name="loc"></param>
			/// <param name="cntrs"></param>
			/// <returns></returns>
			public static string UnbindLocCntr(string loc, List<string> cntrs) {
			var db = new SqlHelper<object>().GetInstance();
			var logs = $"货位:{loc},容器:{JsonConvert.SerializeObject(cntrs)}";
			try {
			var lcrList = db.Queryable<TN_Loc_Container>().Where(a => cntrs.Contains(a.S_CNTR_CODE) && a.S_LOC_CODE == loc).ToList();
			if (lcrList.Count == 0) {
			LogHelper.Info($"货位无需解绑容器,在数据库中未找到{JsonConvert.SerializeObject(cntrs)}相关的货位容器关系表信息");
			}
			cntrs = lcrList.Select(a => a.S_CNTR_CODE).ToList();

			var log = JsonConvert.SerializeObject(cntrs);
			var location = db.Queryable<TN_Location>().First(a => a.S_CODE == loc);
			if (location != null) {
			location.N_CURRENT_NUM = 0;
			location.S_LOCK_STATE = "无";
			location.N_LOCK_STATE = 0;

			using (var tran = db.Ado.UseTran()) {
			if (db.Deleteable<TN_Loc_Container>().Where(it => cntrs.Contains(it.S_CNTR_CODE) && it.S_LOC_CODE == loc).ExecuteCommand() > 0) {
			LogHelper.Info($"删除货位容器关系表成功,{log}");
			}
			else {
			tran.RollbackTran();

			LogHelper.Info($"删除货位容器关系表失败,{log}");

			return "货位解绑容器失败," + logs;
			}

			log = JsonConvert.SerializeObject(location);
			if (db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand() > 0) {
			tran.CommitTran();

			LogHelper.Info($"更新货位表成功,{log}");
			}
			else {
			tran.RollbackTran();

			LogHelper.Info($"更新货位表失败,{log}");

			return "货位解绑容器失败," + logs;
			}
			}
			}
			else {
			LogHelper.Info($"在数据库中未找到该货位,无需更新,货位:{loc}");
			}
			return "货位解绑容器成功," + logs;
			}
			catch (Exception ex) {
			LogHelper.Info($"发生了异常,货位解绑容器失败,{ex.Message}");
			return "货位绑定容器失败," + logs;
			}
			}

			/// <summary>
			/// 货位绑定容器
			/// </summary>
			/// <param name="loc"></param>
			/// <param name="cntrs"></param>
			/// <returns></returns>
			public static string BindingLoc(string loc, List<string> cntrs) {
			var db = new SqlHelper<object>().GetInstance();
			var logs = $"货位:{loc},容器:{JsonConvert.SerializeObject(cntrs)}";
			try {
			// 删除已经绑定过的容器记录
			var lcrList = db.Queryable<TN_Loc_Container>().Where(a => cntrs.Contains(a.S_CNTR_CODE) && a.S_LOC_CODE == loc).ToList();
			if (lcrList.Count > 0) {
			cntrs = cntrs.Except(lcrList.Select(a => a.S_CNTR_CODE).ToList()).ToList();
			}

			var bindLocCntList = new List<TN_Loc_Container>();
			foreach (var item in cntrs) {
			// 针对容器类型添加的新逻辑
			var cntr = db.Queryable<TN_Container>().Where(c => c.S_CODE == item).First();

			if (cntr == null) {
			LogHelper.Info($"货位解绑时,容器{item}没有在容器信息表中查到,不记录容器类型");
			bindLocCntList.Add(new TN_Loc_Container() { S_LOC_CODE = loc, S_CNTR_CODE = item });
			}
			else {
			bindLocCntList.Add(new TN_Loc_Container() { S_LOC_CODE = loc, S_CNTR_CODE = item, S_CNTR_TYPE = cntr.S_TYPE });
			}
			}

			var log = JsonConvert.SerializeObject(bindLocCntList);

			using (var tran = db.Ado.UseTran()) {
			if (db.Insertable(bindLocCntList).ExecuteCommand() <= 0) {
			db.RollbackTran();
			LogHelper.Info($"插入货位容器关系表失败,{log}");
			return "货位绑定容器失败," + logs;
			}
			LogHelper.Info($"插入货位容器关系表成功,{log}");

			var location = db.Queryable<TN_Location>().First(a => a.S_CODE == loc);
			if (location != null) {
			location.N_CURRENT_NUM += cntrs.Count;
			location.S_LOCK_STATE = "无";
			location.N_LOCK_STATE = 0;
			log = JsonConvert.SerializeObject(location);

			if (db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM, it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand() > 0) {
			db.CommitTran();

			LogHelper.Info($"更新货位表成功,{log}");
			}
			else {
			db.RollbackTran();

			LogHelper.Info($"更新货位表失败,{log}");

			return "货位绑定容器失败," + logs;
			}
			}
			else {
			db.RollbackTran();
			LogHelper.Info($"未找到该货位{loc},或者已锁定,{log}");
			}
			}
			return "货位绑定容器成功," + logs;
			}
			catch (Exception ex) {
			LogHelper.Info($"发生了异常,货位绑定容器失败,");
			return "货位绑定容器失败," + ex.Message;
			}
			}

			private static object locLocker = new object();