WMSPrjInstance/HH-0126_HeNanPingGao.git

			@@ -1,4 +1,5 @@
			using HH.WCS.Mobox3.pinggao.util;
			using HH.WCS.Mobox3.pinggao.models;
			using HH.WCS.Mobox3.pinggao.util;
			using HH.WCS.Mobox3.pinggao.wms;
			using System;
			using System.Collections.Generic;
			@@ -33,7 +34,8 @@
			//WMSHelper.GetWaitingSortingOrderList();

			}
			internal static void CheckDistributionCNTROrder() {
			internal static void CheckDistributionCNTROrder()
			{
			LogHelper.Info($"配盘生成作业 ");
			var db = new SqlHelper<object>().GetInstance();
			//获取配盘单
			@@ -43,17 +45,17 @@
			foreach (var item in list)
			{
			var lcr = db.Queryable<LocCntrRel>().Where(c => c.S_CNTR_CODE == item.S_CNTR_CODE).First();
			if (lcr!=null)
			if (lcr != null)
			{
			//起始库位
			var startloc = db.Queryable<Location>().Where(it => it.S_CODE == lcr.S_LOC_CODE).First();
			if (startloc != null )//&&
			if (startloc != null)//&&
			{
			//终点货位
			var endloc = db.Queryable<Location>().Where(it => it.S_AREA_CODE == "AGVXHQ" && it.N_LOCK_STATE == 0 && it.N_CURRENT_NUM == 0).First();

			// var endloc = db.Queryable<Location>().Where(it => it.S_CODE == item.S_END_LOC).First();
			if (endloc != null )
			// var endloc = db.Queryable<Location>().Where(it => it.S_CODE == item.S_END_LOC).First();
			if (endloc != null)
			{
			var optask = new WMSTask
			{
			@@ -80,28 +82,140 @@
			LocationHelper.LockLoc(endloc.S_CODE, 1);
			item.N_B_STATE = 2;
			item.S_B_STATE = "作业启动";
			db.Updateable(item).UpdateColumns(it => new { it.S_B_STATE, it.N_B_STATE }).ExecuteCommand();
			item.S_SORT_TYPE = "待分拣";
			db.Updateable(item).UpdateColumns(it => new { it.S_B_STATE, it.N_B_STATE, it.S_SORT_TYPE }).ExecuteCommand();


			}
			}
			else
			{
			LogHelper.Info($"{item.S_BS_NO}配盘库区{item.S_AREA_CODE}货位找不到");
			LogHelper.Info($"{item.S_BS_NO}配盘库区AGVXHQ无空货位");

			}
			}
			else
			{
			LogHelper.Info($"{item.S_BS_NO}配盘库区{item.S_AREA_CODE}货位找不到");
			LogHelper.Info($"{item.S_BS_NO}配盘库区{item.S_AREA_CODE}无货位");
			}

			}



			}
			else
			{
			LogHelper.Info($"配盘生成作业容器未绑定货位");
			}


			}



			}
			catch (Exception ex)
			{
			LogHelper.Info($"配盘生成作业错误 {ex.Message}");
			throw;
			}
			LogHelper.Info($"获取配盘数量 {list.Count}");
			}



			internal static void podetailSend()
			{
			LogHelper.Info($"自动生成出库任务 ");
			var db = new SqlHelper<object>().GetInstance();
			//获取入库明细单

			var list = db.Queryable<TN_Inbound_Detail>().Where(a => a.N_B_STATE == 1).ToList();



			try
			{
			foreach (var item in list)
			{
			var cir2 = db.Queryable<CGRels>().Where(a => a.S_ITEM_CODE == item.S_ITEM_CODE&&a.S_CNTR_TYPE=="半托").First();
			var S_CNTR_CODE = "";
			if (cir2 != null)
			{
			S_CNTR_CODE=cir2.S_CNTR_CODE;

			var lcr = db.Queryable<LocCntrRel>().Where(c => c.S_CNTR_CODE == S_CNTR_CODE).First();
			if (lcr != null)
			{
			//起始库位
			var startloc = db.Queryable<Location>().Where(it => it.S_CODE == lcr.S_LOC_CODE).First();
			var wsc = db.Queryable<WCSTask>().Where(it => it.S_CNTR_CODE == S_CNTR_CODE && it.N_B_STATE < 3).First();
			if (wsc != null)
			{
			item.N_B_STATE = 2;
			db.Updateable(item).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();
			}
			else
			{
			if (startloc != null)//&&
			{
			//终点货位
			var endloc = db.Queryable<Location>().Where(it => it.S_AREA_CODE == "QYQXHQ" && it.N_LOCK_STATE == 0 && it.N_CURRENT_NUM == 0).First();

			// var endloc = db.Queryable<Location>().Where(it => it.S_CODE == item.S_END_LOC).First();
			if (endloc != null)
			{
			var optask = new WMSTask
			{
			S_CODE = WMSHelper.GenerateTaskNo(),
			S_START_LOC = startloc.S_CODE,
			S_START_AREA = startloc.S_AREA_CODE,
			S_START_WH = startloc.S_WH_CODE,
			S_END_LOC = endloc.S_CODE,
			S_END_AREA = endloc.S_AREA_CODE,
			S_END_WH = endloc.S_WH_CODE,
			S_TYPE = "出库区",
			N_TYPE = 2,
			N_B_STATE = 0,
			S_BS_NO = "",
			S_CNTR_CODE = S_CNTR_CODE,
			S_OP_DEF_NAME = item.S_BS_TYPE
			};
			var res = db.Insertable(optask).ExecuteCommand() > 0;
			if (res)
			{
			startloc.N_LOCK_STATE = 2;
			startloc.S_LOCK_STATE = "出库锁";
			db.Updateable(startloc).UpdateColumns(it => new { it.S_LOCK_STATE, it.N_LOCK_STATE }).ExecuteCommand();
			LocationHelper.LockLoc(endloc.S_CODE, 1);
			item.N_B_STATE = 2;
			db.Updateable(item).UpdateColumns(it => new { it.N_B_STATE }).ExecuteCommand();


			}
			}
			else
			{
			LogHelper.Info($"{item.S_BS_NO}配盘库区AGVXHQ无空货位");

			}
			}
			else
			{
			LogHelper.Info($"{item.S_BS_NO}配盘库区无货位");
			}
			}

			}
			else
			{
			LogHelper.Info($"配盘生成作业容器未绑定货位");
			}
			}
			else
			{
			LogHelper.Info($"未找到物料{item.S_ITEM_CODE}对应的容器");
			}

			}


			}
			catch (Exception ex)
			@@ -504,6 +618,23 @@
			a.S_B_STATE = "执行";
			WMSHelper.UpdateTaskState(a);
			}

			var detail = db.Queryable<TN_Distribution_CNTR_Detail>().Where(s => s.S_DC_NO == a.S_BS_NO).ToList();
			List<TN_DPRECORD> listdp=new List<TN_DPRECORD>();
			foreach (var item in detail)
			{
			TN_DPRECORD tN_DPRECORD = new TN_DPRECORD();
			tN_DPRECORD.S_WLBM=item.S_ITEM_CODE;
			tN_DPRECORD.S_WLMC = item.S_ITEM_NAME;
			tN_DPRECORD.S_NO= wcsTask.S_CODE;
			tN_DPRECORD.N_COUNT= item.F_QTY;
			tN_DPRECORD.S_LOCATION= end.S_CODE;
			listdp.Add(tN_DPRECORD);
			}
			if (listdp.Count()>0)
			{
			db.Insertable<TN_DPRECORD>(listdp).ExecuteCommand();
			}
			}
			else
			{