~zhao/AutoWMS.HCZC.git

			@@ -779,28 +779,84 @@
			}
			#endregion

			// CN_S_EXT1:业务类型
			// CN_S_EXT2:子任务标识
			// CN_S_EXT3:任务执行阶段
			public void SelfManageTask()
			{
			try
			{
			//取未执行的自管任务
			//取未执行、完成一半、完成部分的自管任务
			var tasks = BLLCreator.CreateDapper<TN_WM_TASKEntity>().GetList(new
			{
			CN_S_TASK_FLAG = Constants.TaskFlag_ZG,
			CN_S_STATE = new List<string>() { Constants.TaskState_NoExecuted, Constants.TaskState_CompleteHalf }
			CN_S_STATE = new List<string>() { Constants.TaskState_NoExecuted, Constants.TaskState_CompleteHalf, Constants.TaskState_CompletePart }
			});

			var connectBitStr = JsonHelper.GetValue("connectBit");
			if (string.IsNullOrEmpty(connectBitStr))
			throw new Exception("未找到配置：connectBit");

			var connectBits = JsonConvert.DeserializeObject<List<ConnectBitDto>>(connectBitStr);

			List<OperateResult> ors = new List<OperateResult>();
			foreach (var task in tasks)
			{
			try
			{
			var connectBitStr = JsonHelper.GetValue("connectBit");
			if (string.IsNullOrEmpty(connectBitStr))
			throw new Exception("未找到配置：connectBit");
			var connectBits = JsonConvert.DeserializeObject<List<ConnectBitDto>>(connectBitStr);
			OperateResult or = OperateResult.Error("未知错误");
			if (task.CN_S_EXT1 == BusinessTypeConstants.BCP_MTRK)// 半成品满托入库流程
			{
			// -空托出库阶段
			if (task.CN_S_EXT3 == TaskSectionConstants.KTCK)
			{
			var connectBit = connectBits.Find(f => f.tasktype == ConnectBitConstants.KTCK);
			// 创建两条并行子任务
			if (string.IsNullOrEmpty(task.CN_S_EXT2))
			{
			or = ExecKTCK(task, connectBit);
			}
			// sub_1 -用于向WCS发送空托->接驳位的出库任务
			else if (task.CN_S_EXT2 == "ktck_sub_1")
			{
			or = ExecKTCK_Sub1(task, connectBit);
			}
			// sub_2 - 用于向AMS发送准备点->终点的空托搬运任务
			else if (task.CN_S_EXT2 == "ktck_sub_2")
			{
			or = ExecKTCK_Sub2(task, connectBit);
			}
			}
			else if (task.CN_S_EXT3 == TaskSectionConstants.BCP_MTRK)
			{
			var connectBit = connectBits.Find(f => f.tasktype == ConnectBitConstants.MTRK);
			// 创建第一条子任务
			if (string.IsNullOrEmpty(task.CN_S_EXT2))
			{
			or = ExecBCP_MTRK_AddSub1(task, connectBit);
			}
			// 执行第一条子任务
			else if (task.CN_S_EXT2 == "bcp_mtrk_sub_1")
			{
			or = ExecBCP_MTRK_Sub1(task, connectBit);
			}
			// 创建第二条子任务
			else if (task.CN_S_EXT2 == "bcp_mtrk_sub_1_completed")
			{
			or = ExecBCP_MTRK_AddSub2(task, connectBit);
			}
			// 执行第二条子任务
			else if (task.CN_S_EXT2 == "bcp_mtrk_sub_2")
			{
			or = ExecBCP_MTRK_Sub2(task, connectBit);
			}
			}
			}
			else
			{
			or = OperateResult.Error("未知的业务类型：task.CN_S_EXT1=" + task.CN_S_EXT1);
			}

			continue;

			//未执行表示第一个任务
			if (task.CN_S_STATE == Constants.TaskState_NoExecuted)
			{
			@@ -1043,6 +1099,24 @@
			// 从mongo中获取货位相关的信息 - 终点货位
			AutoBomLocationEntity end_location = CreateDAL<TN_AB_STOCK_LOCATIONDAL>().GetModel(task.Location_To);

			// 主任务执行流程中的起始阶段
			string section = "";
			switch (task.BUSI_TYPE)
			{
			case "1":
			section = TaskSectionConstants.KTCK;
			break;
			case "2":
			break;
			case "3":
			break;
			case "4":
			break;
			case "5":
			break;
			case "6":
			break;
			}
			// 创建WMS主任务
			TN_WM_TASKEntity taskEntity = new TN_WM_TASKEntity()
			{
			@@ -1063,6 +1137,9 @@
			CN_T_MODIFY = DateTime.Now,
			CN_S_REMARK = "",
			CN_S_TASK_FLAG = Constants.TaskFlag_ZG,
			CN_S_EXT1 = task.BUSI_TYPE,
			CN_S_EXT2 = "",
			CN_S_EXT3 = section
			};
			UseTransaction(trans =>
			{
			@@ -1088,5 +1165,463 @@
			Log.DomainInfo("ExecTransferTask", JsonConvert.SerializeObject(ors));
			}
			}

			#region 半成品-满托入库

			#region 空托出库

			/// <summary>
			/// 创建空托出库并行子任务
			/// </summary>
			public OperateResult ExecKTCK(TN_WM_TASKEntity task, ConnectBitDto bit)
			{
			// 空托出库和满托入库是反向的
			var connectBit = BLLCreator.CreateDapper<TN_WM_LOCATION_EXTEntity>().GetSingleEntity(new
			{
			CN_S_LOCATION_CODE = bit.bit
			});
			var readyBit = BLLCreator.CreateDapper<TN_WM_LOCATION_EXTEntity>().GetSingleEntity(new
			{
			CN_S_LOCATION_CODE = bit.readybit
			});
			if (connectBit == null)
			throw new Exception("未找到接驳位货位：" + bit.bit);
			if (connectBit.CN_S_LOCATION_STATE != Constants.Location_State_Normal)
			throw new Exception("接驳位：" + bit.bit + "存在未执行完的任务");

			if (readyBit == null)
			throw new Exception("未找到接驳位货位：" + bit.readybit);
			if (readyBit.CN_S_LOCATION_STATE != Constants.Location_State_Normal)
			throw new Exception("接驳位：" + bit.readybit + "存在未执行完的任务");

			// 立库->接驳位
			TN_WM_TASKEntity taskEntity1 = new TN_WM_TASKEntity()
			{
			CN_S_TASK_NO = task.CN_S_TASK_NO + "_1",
			CN_S_TRAY_CODE = task.CN_S_TRAY_CODE,
			CN_S_STATE = Constants.TaskState_NoExecuted,
			CN_S_BF_TASK_NO = "",
			CN_S_AF_TASK_NO = "",
			CN_S_STOCK_CODE = task.CN_S_STOCK_CODE,
			CN_S_START_AREA = task.CN_S_END_AREA,
			CN_S_START_BIT = task.CN_S_END_BIT,
			CN_S_END_AREA = connectBit.CN_S_AREA_CODE,
			CN_S_END_BIT = connectBit.CN_S_LOCATION_CODE,
			CN_N_PRIORITY = 1,
			CN_S_CREATOR = "sys",
			CN_S_CREATOR_BY = "sys",
			CN_T_CREATE = DateTime.Now,
			CN_T_MODIFY = DateTime.Now,
			CN_S_REMARK = "",
			CN_S_TASK_FLAG = Constants.TaskFlag_ZG,
			CN_S_EXT1 = task.CN_S_EXT1,
			CN_S_EXT2 = "ktck_sub_1"
			};
			// 准备点->工位
			TN_WM_TASKEntity taskEntity2 = new TN_WM_TASKEntity()
			{
			CN_S_TASK_NO = task.CN_S_TASK_NO + "_2",
			CN_S_TRAY_CODE = task.CN_S_TRAY_CODE,
			CN_S_STATE = Constants.TaskState_NoExecuted,
			CN_S_BF_TASK_NO = "",
			CN_S_AF_TASK_NO = "",
			CN_S_STOCK_CODE = task.CN_S_STOCK_CODE,
			CN_S_START_AREA = readyBit.CN_S_AREA_CODE,
			CN_S_START_BIT = readyBit.CN_S_LOCATION_CODE,
			CN_S_END_AREA = task.CN_S_START_AREA,
			CN_S_END_BIT = task.CN_S_START_BIT,
			CN_N_PRIORITY = 1,
			CN_S_CREATOR = "sys",
			CN_S_CREATOR_BY = "sys",
			CN_T_CREATE = DateTime.Now,
			CN_T_MODIFY = DateTime.Now,
			CN_S_REMARK = "",
			CN_S_TASK_FLAG = Constants.TaskFlag_ZG,
			CN_S_EXT1 = task.CN_S_EXT1,
			CN_S_EXT2 = "ktck_sub_2"
			};

			OperateResult re = OperateResult.Error("未知错误");

			try
			{
			UseTransaction(trans =>
			{
			// 创建空托出库子任务1
			re = CreateDapperDAL<TN_WM_TASKEntity>().Add(taskEntity1);
			if (!re.Success)
			throw new Exception(re.Msg);
			// 创建空托出库子任务2
			re = CreateDapperDAL<TN_WM_TASKEntity>().Add(taskEntity2);
			if (!re.Success)
			throw new Exception(re.Msg);

			// 主任务状态置为执行中记录接驳位
			re = CreateDapperDAL<TN_WM_TASKEntity>().Update(new
			{
			CN_S_STATE = Constants.TaskState_Executing,
			CN_S_CONNECT_BIT = bit.bit
			}, new { CN_S_TASK_NO = task.CN_S_TASK_NO }, trans);
			if (!re.Success)
			throw new Exception(re.Msg);
			});
			}
			catch (Exception ex)
			{
			OperateResult.Error("创建空托出库子任务失败，主任务编号=" + task.CN_S_TASK_NO + "，错误信息：" + ex.Message);
			}

			return re;
			}
			/// <summary>
			/// 执行空托出库的第一条子任务
			/// </summary>
			/// <param name="task"></param>
			/// <param name=""></param>
			/// <returns></returns>
			public OperateResult ExecKTCK_Sub1(TN_WM_TASKEntity task1, ConnectBitDto connectBit)
			{
			OperateResult or = OperateResult.Error("未知错误");
			try
			{
			UseTransaction(trans =>
			{
			// 接驳位预入库锁定
			CreateDapperDAL<TN_WM_LOCATION_EXTEntity>().Update(new
			{
			CN_S_LOCATION_STATE = Constants.Location_State_InLock
			}, new { CN_S_LOCATION_CODE = connectBit.bit }, trans);
			// 子任务1状态置为执行中
			or = CreateDapperDAL<TN_WM_TASKEntity>().Update(new
			{
			CN_S_STATE = Constants.TaskState_Executing
			}, new { CN_S_TASK_NO = task1.CN_S_TASK_NO }, trans);
			// 发送Wcs任务
			or = BLLCreator.Create<OtherSysApi>().SendWcsCreateTask(task1, connectBit);
			});
			}
			catch (Exception ex)
			{
			OperateResult.Error("执行空托出库子任务1失败，任务编号=" + task1.CN_S_TASK_NO + "，错误信息：" + ex.Message);
			}
			return or;
			}
			/// <summary>
			/// 执行空托出库的第二条子任务
			/// </summary>
			/// <param name="task"></param>
			/// <param name="connectBit"></param>
			/// <returns></returns>
			public OperateResult ExecKTCK_Sub2(TN_WM_TASKEntity task2, ConnectBitDto connectBit)
			{
			OperateResult or = OperateResult.Error("未知错误");
			try
			{
			UseTransaction(trans =>
			{
			// 准备点预出库锁定
			CreateDapperDAL<TN_WM_LOCATION_EXTEntity>().Update(new
			{
			CN_S_LOCATION_STATE = Constants.Location_State_OutLock
			}, new { CN_S_LOCATION_CODE = connectBit.readybit }, trans);
			// 子任务2状态置为执行中
			or = CreateDapperDAL<TN_WM_TASKEntity>().Update(new
			{
			CN_S_STATE = Constants.TaskState_Executing
			}, new { CN_S_TASK_NO = task2.CN_S_TASK_NO }, trans);
			// 发送Ams任务
			or = BLLCreator.Create<OtherSysApi>().SendAmsTask(task2);
			});
			}
			catch (Exception ex)
			{
			OperateResult.Error("执行空托出库子任务2失败，任务编号=" + task2.CN_S_TASK_NO + "，错误信息：" + ex.Message);
			}
			return or;
			}

			#endregion

			#region 满托入库

			#region 主任务

			/// <summary>
			/// 创建半成品-满托入库子任务1
			/// </summary>
			public OperateResult ExecBCP_MTRK_AddSub1(TN_WM_TASKEntity task, ConnectBitDto bit)
			{
			var connectBit = BLLCreator.CreateDapper<TN_WM_LOCATION_EXTEntity>().GetSingleEntity(new
			{
			CN_S_LOCATION_CODE = bit.bit
			});

			if (connectBit == null)
			throw new Exception("未找到接驳位货位：" + bit.bit);
			if (connectBit.CN_S_LOCATION_STATE != Constants.Location_State_Normal)
			throw new Exception("接驳位：" + bit.bit + "存在未执行完的任务");

			// 工位->接驳位
			TN_WM_TASKEntity taskEntity1 = new TN_WM_TASKEntity()
			{
			CN_S_TASK_NO = task.CN_S_TASK_NO + "_3",
			CN_S_TRAY_CODE = task.CN_S_TRAY_CODE,
			CN_S_STATE = Constants.TaskState_NoExecuted,
			CN_S_BF_TASK_NO = "",
			CN_S_AF_TASK_NO = "",
			CN_S_STOCK_CODE = task.CN_S_STOCK_CODE,
			CN_S_START_AREA = task.CN_S_START_AREA,
			CN_S_START_BIT = task.CN_S_START_BIT,
			CN_S_END_AREA = connectBit.CN_S_AREA_CODE,
			CN_S_END_BIT = connectBit.CN_S_LOCATION_CODE,
			CN_N_PRIORITY = 1,
			CN_S_CREATOR = "sys",
			CN_S_CREATOR_BY = "sys",
			CN_T_CREATE = DateTime.Now,
			CN_T_MODIFY = DateTime.Now,
			CN_S_REMARK = "",
			CN_S_TASK_FLAG = Constants.TaskFlag_ZG,
			CN_S_EXT1 = task.CN_S_EXT1,
			CN_S_EXT2 = "bcp_mtrk_sub_1"
			};
			OperateResult re = OperateResult.Error("未知错误");

			try
			{
			UseTransaction(trans =>
			{
			// 创建满托入库子任务1
			re = CreateDapperDAL<TN_WM_TASKEntity>().Add(taskEntity1);
			if (!re.Success)
			throw new Exception(re.Msg);

			// 主任务状态置为执行中
			re = CreateDapperDAL<TN_WM_TASKEntity>().Update(new
			{
			CN_S_STATE = Constants.TaskState_Executing
			}, new { CN_S_TASK_NO = task.CN_S_TASK_NO }, trans);
			if (!re.Success)
			throw new Exception(re.Msg);
			});
			}
			catch (Exception ex)
			{
			OperateResult.Error("创建满托入库子任务1失败，任务编号=" + task.CN_S_TASK_NO + "，错误信息：" + ex.Message);
			}

			return re;
			}
			/// <summary>
			/// 创建半成品-满托入库子任务2
			/// </summary>
			public OperateResult ExecBCP_MTRK_AddSub2(TN_WM_TASKEntity task, ConnectBitDto bit)
			{
			var connectBit = BLLCreator.CreateDapper<TN_WM_LOCATION_EXTEntity>().GetSingleEntity(new
			{
			CN_S_LOCATION_CODE = bit.bit
			});

			if (connectBit == null)
			throw new Exception("未找到接驳位货位：" + bit.bit);
			if (connectBit.CN_S_LOCATION_STATE != Constants.Location_State_Normal)
			throw new Exception("接驳位：" + bit.bit + "存在未执行完的任务");

			// 接驳位->立库
			TN_WM_TASKEntity taskEntity2 = new TN_WM_TASKEntity()
			{
			CN_S_TASK_NO = task.CN_S_TASK_NO + "_4",
			CN_S_TRAY_CODE = task.CN_S_TRAY_CODE,
			CN_S_STATE = Constants.TaskState_NoExecuted,
			CN_S_BF_TASK_NO = "",
			CN_S_AF_TASK_NO = "",
			CN_S_STOCK_CODE = task.CN_S_STOCK_CODE,
			CN_S_START_AREA = connectBit.CN_S_AREA_CODE,
			CN_S_START_BIT = connectBit.CN_S_LOCATION_CODE,
			CN_S_END_AREA = task.CN_S_END_AREA,
			CN_S_END_BIT = task.CN_S_END_BIT,
			CN_N_PRIORITY = 1,
			CN_S_CREATOR = "sys",
			CN_S_CREATOR_BY = "sys",
			CN_T_CREATE = DateTime.Now,
			CN_T_MODIFY = DateTime.Now,
			CN_S_REMARK = "",
			CN_S_TASK_FLAG = Constants.TaskFlag_ZG,
			CN_S_EXT1 = task.CN_S_EXT1,
			CN_S_EXT2 = "bcp_mtrk_sub_2"
			};
			OperateResult re = OperateResult.Error("未知错误");

			try
			{
			UseTransaction(trans =>
			{
			// 创建满托入库子任务2
			re = CreateDapperDAL<TN_WM_TASKEntity>().Add(taskEntity2);
			if (!re.Success)
			throw new Exception(re.Msg);

			// 主任务状态置为执行中
			re = CreateDapperDAL<TN_WM_TASKEntity>().Update(new
			{
			CN_S_STATE = Constants.TaskState_Executing
			}, new { CN_S_TASK_NO = task.CN_S_TASK_NO }, trans);
			if (!re.Success)
			throw new Exception(re.Msg);
			});
			}
			catch (Exception ex)
			{
			OperateResult.Error("创建满托入库子任务2失败，任务编号=" + task.CN_S_TASK_NO + "，错误信息：" + ex.Message);
			}

			return re;
			}

			/// <summary>
			/// 执行半成品-满托入库的第一条子任务
			/// </summary>
			/// <param name="task"></param>
			/// <param name=""></param>
			/// <returns></returns>
			public OperateResult ExecBCP_MTRK_Sub1(TN_WM_TASKEntity task1, ConnectBitDto connectBit)
			{
			OperateResult or = OperateResult.Error("未知错误");
			try
			{
			UseTransaction(trans =>
			{
			// 接驳位预入库锁定
			CreateDapperDAL<TN_WM_LOCATION_EXTEntity>().Update(new
			{
			CN_S_LOCATION_STATE = Constants.Location_State_InLock
			}, new { CN_S_LOCATION_CODE = connectBit.bit }, trans);
			// 子任务1状态置为执行中
			or = CreateDapperDAL<TN_WM_TASKEntity>().Update(new
			{
			CN_S_STATE = Constants.TaskState_Executing
			}, new { CN_S_TASK_NO = task1.CN_S_TASK_NO }, trans);
			// 发送Ams任务
			or = BLLCreator.Create<OtherSysApi>().SendAmsTask(task1);
			});
			}
			catch (Exception ex)
			{
			OperateResult.Error("执行满托入库子任务1失败，任务编号=" + task1.CN_S_TASK_NO + "，错误信息：" + ex.Message);
			}
			return or;
			}
			/// <summary>
			/// 执行半成品-满托入库的第二条子任务
			/// </summary>
			/// <param name="task"></param>
			/// <param name="connectBit"></param>
			/// <returns></returns>
			public OperateResult ExecBCP_MTRK_Sub2(TN_WM_TASKEntity task2, ConnectBitDto connectBit)
			{
			OperateResult or = OperateResult.Error("未知错误");
			try
			{
			UseTransaction(trans =>
			{
			// 接驳位预出库锁定
			CreateDapperDAL<TN_WM_LOCATION_EXTEntity>().Update(new
			{
			CN_S_LOCATION_STATE = Constants.Location_State_OutLock
			}, new { CN_S_LOCATION_CODE = connectBit.bit }, trans);
			// 子任务2状态置为执行中
			or = CreateDapperDAL<TN_WM_TASKEntity>().Update(new
			{
			CN_S_STATE = Constants.TaskState_Executing
			}, new { CN_S_TASK_NO = task2.CN_S_TASK_NO }, trans);
			// 发送Wcs任务
			or = BLLCreator.Create<OtherSysApi>().SendWcsCreateTask(task2, connectBit);
			});
			}
			catch (Exception ex)
			{
			OperateResult.Error("执行满托入库子任务2失败，任务编号=" + task2.CN_S_TASK_NO + "，错误信息：" + ex.Message);
			}
			return or;
			}

			#endregion

			#endregion

			#endregion
			}

			/// <summary>
			/// 配置文件中的常量定义
			/// </summary>
			public class ConnectBitConstants
			{
			/// <summary>
			/// 带束入库
			/// </summary>
			public static string DSRK = "带束入库";
			/// <summary>
			/// 带束出库
			/// </summary>
			public static string DSCK = "带束出库";
			/// <summary>
			/// 满托入库
			/// </summary>
			public static string MTRK = "满托入库";
			/// <summary>
			/// 空托出库
			/// </summary>
			public static string KTCK = "空托出库";
			/// <summary>
			/// 满托出库
			/// </summary>
			public static string MTCK = "满托出库";
			/// <summary>
			/// 空托入库
			/// </summary>
			public static string KTRK = "空托入库";
			}

			/// <summary>
			/// 接口同步的业务类型定义
			/// </summary>
			public class BusinessTypeConstants
			{
			/// <summary>
			/// 半成品满托入库
			/// </summary>
			public static string BCP_MTRK = "1";
			/// <summary>
			/// 成型机半成品回库
			/// </summary>
			public static string CXJ_BCPHK = "2";
			/// <summary>
			/// 成型机空桶回库
			/// </summary>
			public static string CXJ_KTHK = "3";
			/// <summary>
			/// 成型机满托出库
			/// </summary>
			public static string CXJ_MTCK = "4";
			/// <summary>
			/// 成型机带束回库
			/// </summary>
			public static string CXJ_DSHK = "5";
			/// <summary>
			/// 成型机带束满托出库
			/// </summary>
			public static string CXJ_DSMTCK = "6";
			}

			public class TaskSectionConstants
			{
			/// <summary>
			/// 空托出库
			/// </summary>
			public static string KTCK = "空托出库";
			/// <summary>
			/// 半成品-满托入库
			/// </summary>
			public static string BCP_MTRK = "半成品-满托入库";
			}
			}