ZhiHuiQiCe/FangCangZhiNeng.git

			@@ -1,12 +1,7 @@
			ï»¿using HslCommunication;
			using MailKit.Search;
			using Newtonsoft.Json;
			using System;
			using System.Collections.Generic;
			using System.Linq;
			using System.Reflection.Metadata;
			using System.Text;
			using System.Threading.Tasks;
			using SqlSugar;
			using WIDESEA_Common;
			using WIDESEA_Common.OrderEnum;
			using WIDESEA_Common.StockEnum;
			using WIDESEA_Common.TaskEnum;
			@@ -28,12 +23,19 @@
			{
			public class InventoryServices : ServiceBase<Dt_Inventory, IRepository<Dt_Inventory>>, IInventoryServices
			{
			private readonly ICabinOrderServices _cabinOrderServices;
			private readonly IDeliveryOrderServices _deliveryOrderServices;
			public InventoryServices(IRepository<Dt_Inventory> BaseDal, IDeliveryOrderServices deliveryOrderServices) : base(BaseDal)
			private readonly ISupplyTaskService _supplyTaskService;
			private readonly IInventory_BatchServices _inventoryBatchServices;
			private readonly IMessageInfoService _infoService;
			public InventoryServices(IRepository<Dt_Inventory> BaseDal, ICabinOrderServices cabinOrderServices, IDeliveryOrderServices deliveryOrderServices, ISupplyTaskService supplyTaskService, IInventory_BatchServices inventoryBatchServices, IMessageInfoService infoService) : base(BaseDal)
			{
			_cabinOrderServices = cabinOrderServices;
			_deliveryOrderServices = deliveryOrderServices;
			_supplyTaskService = supplyTaskService;
			_inventoryBatchServices = inventoryBatchServices;
			_infoService = infoService;
			}


			/// <summary>
			/// è·åä¸æ¸¸åºåä¿¡æ¯
			@@ -42,59 +44,121 @@
			/// <param name="batch_num">æ¹å·</param>
			/// <returns></returns>
			/// <exception cref="NotImplementedException"></exception>
			public WebResponseContent GetInventoryList(string goods_no, string batch_num)
			public WebResponseContent GetInventoryList(int[] keys)
			{
			var responseContent = new WebResponseContent();
			try
			{
			var url = "http://121.37.118.63/GYZ2/95fck/repositoryInfo";
			var result = HttpHelper.Post(url, new { goods_no, batch_num }.ToJsonString());
			//æ ¹æ®idæ¥è¯¢åºåæ¹æ¬¡ä¿¡æ¯è¡¨ï¼è·åå°ä»ä»¬çååç¼ç åæ¹æ¬¡å·
			var inventoryBatches = _inventoryBatchServices.Repository.QueryData(x => keys.Contains(x.Id)); //æ¥å¨é¨

			var response = JsonConvert.DeserializeObject<UpstreamResponse<InventoryInfo>>(result);

			if (response.resultCode != "0")
			var url = "http://121.37.118.63:80/GYZ2/95fck/repositoryInfo";
			foreach (var item in inventoryBatches)
			{
			SendErrorToUpstream(8, "", response.resultMsg ?? "ä¸æ¸¸æ¥å£è¿åå¤±è´¥", "");
			return responseContent.Error(response.resultMsg ?? "ä¸æ¸¸æ¥å£è¿åå¤±è´¥");
			}
			var result = HttpHelper.Post(url, new { goods_no = item.MaterielCode, batch_num = item.BatchNo }.ToJsonString());

			if (response.data == null \|\| !response.data.Any())
			{
			return responseContent.OK("æ æ°åºåæ°æ®");
			var response = JsonConvert.DeserializeObject<UpstreamResponse<InventoryInfo>>(result);
			if (response == null) continue;
			var data = response.data.FirstOrDefault();
			if (data != null)
			item.ERPStockQuantity = data.business_qty;
			}

			Db.Ado.BeginTran();
			foreach (var item in response.data)
			{
			// ä½¿ç¨ FirstOrDefault é¿åæ¾ä¸å°è®°å½æ¶æåºå¼å¸¸
			var Inver = Db.Queryable<Dt_Inventory_Batch>()
			.First(x => x.MaterielCode == item.goods_no && x.BatchNo == item.batch_num);

			if (Inver != null)
			{
			Inver.ERPStockQuantity = item.business_qty;
			Db.Updateable(Inver).ExecuteCommand();
			}
			}
			Db.Ado.CommitTran();
			_inventoryBatchServices.UpdateData(inventoryBatches);
			return responseContent.OK("åºåä¿¡æ¯åæ¥å®æ");

			}
			catch (Exception ex)
			{
			Db.Ado.RollbackTran();
			SendErrorToUpstream(8, "", ex.Message, "");
			return responseContent.Error("åæ¥å¤±è´¥: " + ex.Message);
			}
			}


			/// <summary>
			/// wcsåä¼ ç»æè°ç¨æçæ¹æ³ ä¸ç®¡æ¯å¥åº åºåº çç¹é½ä¼è°ç¨è¿ä¸ªæ¥å£(ç°å¨ç¨è¿ä¸ª)
			/// </summary>
			/// <param name="request"></param>
			/// <returns></returns>

			public ApiResponse<Dt_InventoryInfo> OrderFeedback(EdiOrderCallbackRequest request)
			{
			try
			{
			if (request == null \|\| request.details == null \|\| request.details.Count < 1) throw new Exception("è¯·æ±åæ°æ æ");
			var Warecode = WarehouseEnum.ç«åº.ObjToInt().ToString("000");
			switch (request.orderType)
			{
			case "1": //å¥åº
			{
			Dt_CabinOrder cabinOrder = _cabinOrderServices.Db.Queryable<Dt_CabinOrder>().Where(x => x.Order_no == request.externalOrderNo && x.Warehouse_no == Warecode).Includes(x => x.Details).First();
			if (cabinOrder == null) throw new Exception($"æªæ¾å°å¥åºåå·ã{request.externalOrderNo}ãçå¥åºåä¿¡æ¯");
			if (cabinOrder.OdrderStatus == "å·²å®æ")
			return new ApiResponse<Dt_InventoryInfo> { code = "0", msg = $"æå" };
			WebResponseContent content = _cabinOrderServices.CompleteLKInOrder(cabinOrder, request);
			if (!content.Status) throw new Exception(content.Message);
			}
			break;
			case "2":
			{
			Dt_DeliveryOrder deliveryOrder = _deliveryOrderServices.Db.Queryable<Dt_DeliveryOrder>().Where(x => x.Out_no == request.externalOrderNo && x.Warehouse_no == Warecode).Includes(x => x.Details).First();
			if (deliveryOrder == null) throw new Exception($"æªæ¾å°åºåºåå·ã{request.externalOrderNo}ãçåºåºåä¿¡æ¯");
			if (deliveryOrder.OutStatus == "å·²å®æ")
			return new ApiResponse<Dt_InventoryInfo> { code = "0", msg = $"æå" };
			WebResponseContent content = _deliveryOrderServices.CompleteLKOutOrder(deliveryOrder, request);
			if (!content.Status) throw new Exception(content.Message);
			}
			break;
			case "3":
			{
			#region æ¾çç¹ä»»å¡
			List<Dt_SupplyTask> supplyTasks = _supplyTaskService.Repository.QueryData(x => x.OrderNo == request.externalOrderNo && x.WarehouseCode == Warecode && x.TaskStatus == SupplyStatusEnum.NewCheck.ObjToInt());
			foreach (var detail in request.details)
			{
			Dt_SupplyTask? supplyTask = supplyTasks.Where(x => x.MaterielCode == detail.productCode && x.BatchNo == detail.batchNo).FirstOrDefault();
			if (supplyTask == null) throw new Exception($"æªæ¾å°è®¢åå·ã{request.externalOrderNo}ãç©æç¼å·ã{detail.productCode}ãççç¹ä»»å¡");
			if (detail.isLossOrProfit == 1) // çäº
			{
			supplyTask.SupplyQuantity = supplyTask.StockQuantity - detail.ea;
			}
			else if (detail.isLossOrProfit == 2) // çç
			{
			supplyTask.SupplyQuantity = supplyTask.StockQuantity + detail.ea;
			}
			else // çä¸
			{
			supplyTask.SupplyQuantity = supplyTask.StockQuantity;
			}
			var content = _deliveryOrderServices.CheckTaskFinish(supplyTask);
			if (!content.Status) throw new Exception(content.Message);
			}
			#endregion
			}
			break;
			default:
			throw new Exception($"æªå®ä¹çç±»åã{request.orderType}ã");
			}
			return new ApiResponse<Dt_InventoryInfo>
			{
			code = "0",
			msg = $"æå"
			};
			}
			catch (Exception ex)
			{
			return new ApiResponse<Dt_InventoryInfo>
			{
			code = "500",
			msg = $"å¤çå¤±è´¥: {ex.Message}"
			};
			}
			}

			/// <summary>
			/// wcsåä¼ ç»æè°ç¨æçæ¹æ³ ä¸ç®¡æ¯å¥åº åºåº çç¹é½ä¼è°ç¨è¿ä¸ªæ¥å£
			/// </summary>
			/// <param name="request"></param>
			/// <returns></returns>
			public ApiResponse<Dt_InventoryInfo> OrderFeedback(EdiOrderCallbackRequest request)
			public ApiResponse<Dt_InventoryInfo> OrderFeedback1(EdiOrderCallbackRequest request)
			{
			try
			{
			@@ -105,7 +169,7 @@
			}
			var reslut = WarehouseEnum.ç«åº.ObjToInt().ToString("000");
			// 2ï¸â£ å¼å¯äºå¡
			BaseDal.Db.Ado.BeginTran();
			//BaseDal.Db.Ado.BeginTran();
			foreach (var detail in request.details)
			{
			#region æ¥è¯¢ç©æä¿¡æ¯ãè®¡ç®æ»å
			@@ -179,8 +243,12 @@
			#endregion
			else
			{
			if (cabinOrder == null \|\| cabinOrder.OdrderStatus == "å·²å®æ")
			throw new Exception($"å¥åºåå·²å®æ");
			if (cabinOrder.OdrderStatus == "å·²å®æ")
			return new ApiResponse<Dt_InventoryInfo>
			{
			code = "0",
			msg = "æå"
			};
			Dt_CabinOrderDetail cabinOrderDetail = cabinOrder.Details.Where(x => x.Goods_no == detail.productCode && x.Batch_num == detail.batchNo && x.Status == 1).First();
			if (cabinOrderDetail == null \|\| cabinOrderDetail.OrderDetailStatus == "å·²å®æ")
			throw new Exception($"å¥åºåæç»å·²å®æ");
			@@ -229,7 +297,7 @@
			ProductionDate = detail.finishDate.ToString("yyyy-MM-dd"),
			ShelfLife = 0,
			ValidityPeriod = cabinOrderDetail.Exp_date,
			Remark = "WCSåä¼ åå»º"
			Remark = "æºè½ç«åº"
			};
			BaseDal.Db.Insertable(inventoryInfo).ExecuteCommand();
			}
			@@ -302,7 +370,7 @@
			case "2":
			{
			Dt_DeliveryOrder cabinOrder = Db.Queryable<Dt_DeliveryOrder>().Where(x => x.Out_no == request.externalOrderNo && x.Warehouse_no == reslut).Includes(x => x.Details).First();
			if (cabinOrder == null) throw new Exception($"æªæ¾å°åºåºåå·ã{request.externalOrderNo}ãçå¥åºåä¿¡æ¯");
			if (cabinOrder == null) throw new Exception($"æªæ¾å°åºåºåå·ã{request.externalOrderNo}ãçåºåºåä¿¡æ¯");

			if (cabinOrder.Out_type == "6")
			{
			@@ -394,7 +462,7 @@
			}

			// 9ï¸â£ æäº¤äºå¡
			BaseDal.Db.Ado.CommitTran();
			//BaseDal.Db.Ado.CommitTran();

			return new ApiResponse<Dt_InventoryInfo>
			{
			@@ -405,13 +473,15 @@
			catch (Exception ex)
			{
			// ð åæ»äºå¡
			BaseDal.Db.Ado.RollbackTran();
			//BaseDal.Db.Ado.RollbackTran();

			return new ApiResponse<Dt_InventoryInfo>
			{
			code = "500",
			msg = $"å¤çå¤±è´¥: {ex.Message}"
			};

			//Console.WriteLine(ex.Message);
			}
			}