~dengjunjie/TaiYuanTaiZhong.git

			@@ -1,93 +1,153 @@
			ï»¿using Newtonsoft.Json;
			ï»¿using Confluent.Kafka;
			using Newtonsoft.Json;
			using OfficeOpenXml.FormulaParsing.Excel.Functions.Text;
			using OfficeOpenXml.FormulaParsing.Excel.Operators;
			using WIDESEA_Comm.LogInfo;
			using WIDESEA_Comm.MES_Info;
			using WIDESEA_Comm.MES_Info.Request;
			using WIDESEA_Common;
			using WIDESEA_Core.EFDbContext;
			using WIDESEA_Core.FreeDB;
			using WIDESEA_Entity.DomainModels;
			using WIDESEA_Entity.ToAGV;
			using WIDESEA_WMS.IRepositories;
			using WIDESEA_WMS.Repositories;
			using static WIDESEA_Comm.MES_Info.BasicSN;

			namespace WIDESEA_WMS.Common.AGVTask
			{
			public class HandleTask_Mes
			{
			public void UploadMESInfo(dt_agvtask task)
			static FreeDB FreeDB = new FreeDB();
			/// <summary>
			/// åMESåé¦åºå¥åºä¿¡æ¯
			/// </summary>
			/// <param name="task"></param>
			/// <exception cref="Exception"></exception>
			public static void UploadMESInfo(dt_agvtask task)
			{
			object obj = new object(); //ä¸ä¼ MESæ°æ®
			string ActionName = ""; //è°ç¨MESæ¹æ³å
			string name = "";
			MES_Response requestMes = new MES_Response();
			try
			{
			object obj = new object(); //ä¸ä¼ MESæ°æ®
			string ActionName = ""; //è°ç¨MESæ¹æ³å
			List<detail> list = new List<detail>(); //è½¦è½®ä¿¡æ¯
			if (task == null)
			{
			throw new Exception("æ ä»»å¡æ°æ®");
			}
			foreach (var item in task.bindSN.Split(","))
			VOLContext context = new VOLContext();
			IVV_Mes_WorkinfoRepository workinfoRepository = new VV_Mes_WorkinfoRepository(context);
			Idt_info_to_mesRepository mesRepository = new dt_info_to_mesRepository(context);
			if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Outbound.ToString() \|\| task.agv_tasktype == AGVTaskTypeEnum.TaskType_OutsourceCarry.ToString())
			{
			detail detail = new detail();
			detail.sn = item;
			list.Add(detail);
			}

			if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Outbound.ToString() \|\| task.agv_tasktype == AGVTaskTypeEnum.TaskType_OutsourceOutbound.ToString())
			{
			agvOutWarehousePara outWarehousePara = new agvOutWarehousePara()
			if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Outbound.ToString())
			{
			JobID = task.jobID,
			details = list
			foreach (var item in task.bindSN.Split(","))
			{
			var work = workinfoRepository.Find(x => x.SN == item && x.processCode == task.agv_worktype.ToString()).FirstOrDefault();
			detail detail = new detail();
			detail.sn = item;
			detail.jobID = work.jobID;
			detail.processCode = work.processCode;
			list.Add(detail);
			}
			}
			else
			{
			foreach (var item in task.bindSN.Split(","))
			{
			detail detail = new detail();
			detail.sn = item;
			detail.jobID = task.jobID;
			detail.processCode = task.agv_worktype.ToString();
			list.Add(detail);
			}
			}

			agvInWarehousePara outWarehousePara = new agvInWarehousePara()
			{
			WorkOrder = task.jobID,
			zoneID = task.agv_fromaddress,
			details = list,
			layerNo = 1,
			stackID = "1",
			warehouseName = "Agvåº",
			Operator = "AGVèªå¨",
			};
			obj = outWarehousePara;
			ActionName = "agvOutWarehouse";
			ActionName = "agvOutWarehouse";//AGV->MESè½¦è½®åºåº
			name = "AGVåæ¥MESè½¦è½®åºåº";
			}
			else if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Inbound.ToString() \|\| task.agv_tasktype == AGVTaskTypeEnum.TaskType_OutsourceInbound.ToString())
			else if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Inbound.ToString())
			{
			foreach (var item in task.bindSN.Split(","))
			{
			var work = workinfoRepository.Find(x => x.SN == item && x.processCode == task.agv_worktype.ToString()).FirstOrDefault();
			detail detail = new detail();
			detail.sn = item;
			detail.jobID = work.jobID;
			detail.processCode = work.processCode;
			list.Add(detail);
			}
			agvInWarehousePara inWarehousePara = new agvInWarehousePara()
			{
			details = list,
			JobID = task.jobID,
			layerNo = 1,
			stackID = task.agv_barcode,
			warehouseName = "Agvåº",
			WorkOrder = task.jobID,
			zoneID = task.agv_toaddress,
			details = list,
			layerNo = 1,
			stackID = "1",
			warehouseName = "Agvåº",
			Operator = "AGVèªå¨",
			};
			obj = inWarehousePara;
			ActionName = "agvInWarehouse";
			ActionName = "agvInWarehouse";//AGV->MESè½¦è½®å¥åº
			name = "AGVåæ¥MESè½¦è½®å¥åº";
			}
			else if (task.agv_tasktype == "Transfer") //ç§»åºåºå åºåç§»åº/å¤åç§»åº
			else if (task.agv_tasktype == AGVTaskTypeEnum.TaskType_Carry.ToString()) //ç§»åºåºå åºåç§»åº
			{
			List<detail1> list1 = new List<detail1>(); //è½¦è½®ä¿¡æ¯
			foreach (var item in task.bindSN.Split(","))
			{
			detail1 detail = new detail1();
			detail.sn = item;
			list1.Add(detail);
			}
			agvMoveWarehousePara moveWarehousePara = new agvMoveWarehousePara()
			{
			details = list,
			fromLayerNo = "1",
			fromStackID = "",
			fromWarehouseName = "Agvåº",
			fromZoneID = task.agv_fromaddress,
			toLayerNo = "1",
			toStackID = "",
			toWarehouseName = "Agvåº",
			toZoneID = task.agv_toaddress,
			details = list1,
			fromLayerNo = "1",
			fromStackID = "1",
			fromWarehouseName = "Agvåº",
			toLayerNo = "1",
			toStackID = "1",
			toWarehouseName = "Agvåº",
			Operator = "AGVèªå¨",
			};
			obj = moveWarehousePara;
			ActionName = "agvMoveWarehouse";
			ActionName = "agvMoveWarehouse";//AGV->MESè½¦è½®ç§»åº
			name = "AGVåæ¥MESè½¦è½®ABåºç§»åº";
			}
			//else if (task.agv_tasktype == "Transfer")
			//{

			//}

			var postJson = JsonConvert.SerializeObject(obj);
			string mesData = Request.RequestData(postJson, MESAPIAddress.IPAddress_MES + ActionName);
			var requestMes = JsonConvert.DeserializeObject<MES_Response>(mesData);

			if (requestMes.code == "200" && requestMes.Type == "success")
			if (!string.IsNullOrEmpty(ActionName))
			{
			//æ¥å¿è®°å½ä¸ä¼ æ°æ®æå
			dt_info_to_mes info_To_Mes = new dt_info_to_mes()
			{
			Info = postJson,
			ActionName = ActionName,
			Createtime = DateTime.Now,
			Remark = name,
			State = false
			};
			mesRepository.Add(info_To_Mes, true);
			}

			}
			catch (Exception ex)
			{
			throw new Exception(ex.Message);

			}
			}
			}