MeiRuiAn/HuaiAn.git

			@@ -4,14 +4,19 @@
			using System.Text;
			using System.Threading.Tasks;
			using WIDESEA_Common.OrderEnum;
			using WIDESEA_Common.StockEnum;
			using WIDESEA_Core;
			using WIDESEA_Core.BaseRepository;
			using WIDESEA_Core.BaseServices;
			using WIDESEA_Core.Enums;
			using WIDESEA_Core.Helper;
			using WIDESEA_External.Model;
			using WIDESEA_IApprovalRepository;
			using WIDESEA_ICheckRepository;
			using WIDESEA_ICheckService;
			using WIDESEA_IInboundRepository;
			using WIDESEA_IOutboundRepository;
			using WIDESEA_IStockRepository;
			using WIDESEA_Model.Models;

			namespace WIDESEA_CheckService
			@@ -24,7 +29,9 @@
			private readonly ICheckOrderService _checkOrderService;
			private readonly IPurchaseOrderRepository _purchaseOrderRepository;
			private readonly IPurchaseOrderDetailRepository _purchaseOrderDetailRepository;
			public CheckOrderResultService(ICheckOrderResultRepository BaseDal, IUnitOfWorkManage unitOfWorkManage, ICheckOrderRepository checkOrderRepository, IReceiveOrderRepository receiveOrderRepository, ICheckOrderService checkOrderService, IPurchaseOrderRepository purchaseOrderRepository, IPurchaseOrderDetailRepository purchaseOrderDetailRepository) : base(BaseDal)
			private readonly IOutboundRepository _outboundRepository;
			private readonly IStockRepository _stockRepository;
			public CheckOrderResultService(ICheckOrderResultRepository BaseDal, IUnitOfWorkManage unitOfWorkManage, ICheckOrderRepository checkOrderRepository, IReceiveOrderRepository receiveOrderRepository, ICheckOrderService checkOrderService, IPurchaseOrderRepository purchaseOrderRepository, IPurchaseOrderDetailRepository purchaseOrderDetailRepository, IOutboundRepository outboundRepository, IStockRepository stockRepository) : base(BaseDal)
			{
			_checkOrderRepository = checkOrderRepository;
			_unitOfWorkManage = unitOfWorkManage;
			@@ -32,6 +39,8 @@
			_checkOrderService = checkOrderService;
			_purchaseOrderRepository = purchaseOrderRepository;
			_purchaseOrderDetailRepository = purchaseOrderDetailRepository;
			_outboundRepository = outboundRepository;
			_stockRepository = stockRepository;
			}

			/// <summary>
			@@ -158,6 +167,295 @@
			}
			return content;
			}
			public WebResponseContent CommitCheckResult(ERPCheckModel checkModel)
			{
			WebResponseContent content = new WebResponseContent();
			try
			{
			Dt_CheckOrder checkOrder = _checkOrderRepository.QueryFirst(x => x.CheckOrderNo == checkModel.Code);
			//è·åè´¨æ£åå¯¹åºçæ¶è´§å
			if (checkOrder == null)
			{
			return content.Error($"æªæ¾å°è¯¥è´¨æ£å");
			}
			Dt_ReceiveOrder receiveOrder = _receiveOrderRepository.Db.Queryable<Dt_ReceiveOrder>().Where(x => x.ReceiveOrderNo == checkOrder.ReceiveOrderNo).Includes(x => x.Details).First();
			if (receiveOrder.ReceiveOrderStatus != ReceiveOrderStatusEnum.Completed.ObjToInt())
			{
			return content.Error($"{receiveOrder.ReceiveOrderNo}æ¶è´§åæªå®ææ æ³è´¨æ£");
			}
			if (checkOrder.CheckOrderStatus == CheckOrderStatusEnum.Checked.ObjToInt())
			{
			return content.Error($"è¯¥åæ®å·²ç»æ£éªå®æ");
			}
			Dt_CheckOrderResult? checkOrderResult = null;
			Dt_PurchaseOrder? purchaseOrder = null;
			Dt_PurchaseOrderDetail? purchaseOrderDetail = null;
			if (checkModel.Details.Count>0)
			{

			ERPCheckResult eRPCheckResult = checkModel.Details.FirstOrDefault();
			if (eRPCheckResult.Result == CheckResultEnum.Return.ToString())//éè´§
			{
			checkOrder.DefectedNote = eRPCheckResult.Result;
			checkOrder.ReturnQuantity += (float)Convert.ToDecimal(eRPCheckResult.Quantity);
			}
			else
			{
			return content.Error($"æªæ¾å°ç¼ºé·ç±»å");
			}
			checkOrderResult = new Dt_CheckOrderResult()
			{
			Quantity = (float)Convert.ToDecimal(eRPCheckResult.Quantity),
			CheckOrderId = checkOrder.CheckOrderId,
			DefectCode = eRPCheckResult.DefectCode,
			Result = eRPCheckResult.Result,
			Note = eRPCheckResult.Note,
			SampleCount = 0,
			};
			//è·åå¯¹åºéè´å
			Dt_ReceiveOrderDetail receiveOrderDetail = receiveOrder.Details.First(x => x.RowNo == checkOrder.ReceiveDetailRowNo);
			purchaseOrder = _purchaseOrderRepository.Db.Queryable<Dt_PurchaseOrder>().Where(x => x.PurchaseOrderNo == receiveOrderDetail.PurchaseOrderNo).Includes(x => x.Details).Where(x => x.Details.Any(v => v.RowNo == receiveOrderDetail.PurchaseOrderDetailRowNo)).First();
			if (purchaseOrder == null)
			{
			return content.Error("æªæ¾å°å¯¹åºæ¶è´§éè´å");
			}
			purchaseOrderDetail = purchaseOrder.Details.FirstOrDefault();
			if (purchaseOrderDetail == null)
			{
			return content.Error("æªæ¾å°éè´§å¯¹åºçéè´åæç»");
			}
			purchaseOrderDetail.PurchaseDetailReceiveQty -= (float)Convert.ToDecimal(eRPCheckResult.Quantity);
			}
			if (checkModel.Result == CheckAcceptEnum.Accept.ToString())
			{
			checkOrder.Result = CheckAcceptEnum.Accept.ToString();
			}
			else if (checkModel.Result == CheckAcceptEnum.UnAccept.ToString())
			{
			checkOrder.Result = CheckAcceptEnum.UnAccept.ToString();
			}
			else
			{
			return content.Error("æªæ¾å°æ£éªç±»å");
			}
			checkOrder.CheckOrderStatus = CheckOrderStatusEnum.Checked.ObjToInt();
			if (checkOrderResult != null)
			{
			checkOrder.QualifiedQuantity = checkOrder.ReceivedQuantity - checkOrderResult.Quantity;
			}
			else
			{
			checkOrder.QualifiedQuantity = checkOrder.ReceivedQuantity;
			}
			checkOrder.CheckUserName = App.User.UserName;
			_unitOfWorkManage.BeginTran();

			if (checkOrderResult != null && purchaseOrder != null && purchaseOrderDetail != null)
			{
			BaseDal.AddData(checkOrderResult);
			if (purchaseOrder.PurchaseOrderStatus >= PurchaseOrderStatusEnum.Received.ObjToInt())
			{
			purchaseOrder.PurchaseOrderStatus = PurchaseOrderStatusEnum.Receiving.ObjToInt();
			_purchaseOrderRepository.UpdateData(purchaseOrder);
			}
			if (purchaseOrderDetail.PurchaseDetailStatus == PurchaseOrderDetailStatusEnum.Received.ObjToInt())
			{
			purchaseOrderDetail.PurchaseDetailStatus = PurchaseOrderDetailStatusEnum.Receiving.ObjToInt();
			}
			_purchaseOrderDetailRepository.UpdateData(purchaseOrderDetail);
			}
			if (string.IsNullOrEmpty(checkModel.CreatorCode))
			{
			//ERPä¸æ¥
			WebResponseContent responseContent = _checkOrderService.FeedbackCheckResult(checkOrder, checkOrderResult != null ? new List<Dt_CheckOrderResult> { checkOrderResult } : new List<Dt_CheckOrderResult>());
			if (!responseContent.Status)
			{
			throw new Exception(responseContent.Message);
			}
			}
			checkOrder.UploadStatus = CheckUploadEnum.UploadOk.ObjToInt();
			_checkOrderRepository.UpdateData(checkOrder);
			_unitOfWorkManage.CommitTran();
			content.OK();
			}
			catch (Exception ex)
			{
			_unitOfWorkManage.RollbackTran();
			return content.Error($"{ex.Message}");
			}
			return content;
			}
			/// <summary>
			/// æäº¤éæ£ç¡®è®¤ç»æ
			/// </summary>
			/// <param name="checkOrderId"></param>
			/// <param name="checkResult"></param>
			/// <param name="IsAccept"></param>
			/// <returns></returns>
			public WebResponseContent CommitInspectResult(int checkOrderId, Dt_CheckOrderResult checkResult, int IsAccept = 0)
			{
			WebResponseContent content = new WebResponseContent();
			try
			{
			Dt_CheckOrder checkOrder = _checkOrderRepository.QueryFirst(x => x.CheckOrderId == checkOrderId);
			//è·åè´¨æ£åå¯¹åºçæ¶è´§å
			if (checkOrder == null)
			{
			return content.Error($"æªæ¾å°è¯¥è´¨æ£å");
			}
			Dt_OutboundOrder outboundOrder = _outboundRepository.OutboundOrderRepository.Db.Queryable<Dt_OutboundOrder>().Where(x => x.OrderNo == checkOrder.ReceiveOrderNo).Includes(x => x.Details).First();
			if (outboundOrder.OrderStatus != OutOrderStatusEnum.åºåºå®æ.ObjToInt())
			{
			return content.Error($"{outboundOrder.OrderNo}éæ£ååºåºæªå®ææ æ³è´¨æ£");
			}
			if (checkOrder.CheckOrderStatus == CheckOrderStatusEnum.Checked.ObjToInt())
			{
			return content.Error($"è¯¥åæ®å·²ç»æ£éªå®æ");
			}
			Dt_CheckOrderResult? checkOrderResult = null;
			//è·ååºå
			Dt_OutStockLockInfo outStockLockInfo = _outboundRepository.OutboundStockLockInfoRepository.QueryFirst(x => x.Id == checkOrder.ReceiveDetailRowNo) ?? throw new Exception("æªæ¾å°éæ£åè¯¦æ");
			Dt_StockInfo? stockInfo = _stockRepository.StockInfoRepository.Db.Queryable<Dt_StockInfo>()
			.Where(x => x.PalletCode == outStockLockInfo.PalletCode && x.StockStatus == StockStatusEmun.éæ£å®æ.ObjToInt()).Includes(x => x.Details).First() ?? throw new Exception("æªæ¾å°éæ£åå¯¹åºåºåæ°æ®");
			List<Dt_StockInfoDetail> stockInfoDetails = new List<Dt_StockInfoDetail>();
			List<Dt_StockInfoDetail> DelStockDetails =new List<Dt_StockInfoDetail>();
			if (checkResult.CheckOrderId != 0)
			{
			if (checkResult.Quantity < 0 \|\| checkResult.Quantity > checkOrder.ReceivedQuantity)
			{
			return content.Error($"æ°éè¶åº");
			}
			//å¤ææ£éªç»æ
			if (checkResult.Result == InspectResultEnum.Return.ToString())
			{
			checkOrder.DefectedNote = checkResult.Note;
			checkOrder.ReturnQuantity += checkResult.Quantity;
			}
			else if(checkResult.Result == InspectResultEnum.Defect.ToString())
			{
			checkOrder.DefectedNote = checkResult.Note;
			checkOrder.DefectedQuantity += checkResult.Quantity;
			}
			else if (checkResult.Result == InspectResultEnum.Scrapped.ToString())
			{
			checkOrder.DefectedNote = checkResult.Note;
			checkOrder.ScrappedQuantity += checkResult.Quantity;
			}
			else
			{
			return content.Error($"æªæ¾å°ç¼ºé·ç±»å");
			}
			checkOrderResult = new Dt_CheckOrderResult()
			{
			Quantity = checkResult.Quantity,
			CheckOrderId = checkOrderId,
			DefectCode = checkResult.DefectCode,
			Result = checkResult.Result,
			Note = checkResult.Note,
			SampleCount = checkResult.SampleCount,
			};
			foreach (var item in stockInfo.Details)
			{
			if (checkResult.Quantity == 0)
			{
			break;
			}
			else if (checkResult.Quantity < item.StockQuantity)
			{
			item.StockQuantity -= checkResult.Quantity;
			item.OutboundQuantity = 0;
			checkResult.Quantity = 0;
			stockInfoDetails.Add(item);
			}
			else if (checkResult.Quantity >= item.StockQuantity)
			{
			checkResult.Quantity = (float)Math.Round((checkResult.Quantity - item.StockQuantity), 2);
			DelStockDetails.Add(item);
			}
			}
			}
			if (IsAccept == InspectAcceptEnum.Accept.ObjToInt())
			{
			checkOrder.Result = InspectAcceptEnum.Accept.ToString();
			}
			else if (IsAccept == InspectAcceptEnum.UnAccept.ObjToInt())
			{
			checkOrder.Result = InspectAcceptEnum.UnAccept.ToString();
			}
			else if (IsAccept == InspectAcceptEnum.DefectAccept.ObjToInt())
			{
			checkOrder.Result = InspectAcceptEnum.DefectAccept.ToString();
			}
			else
			{
			return content.Error("æªæ¾å°æ£éªç±»å");
			}
			checkOrder.CheckOrderStatus = CheckOrderStatusEnum.Checked.ObjToInt();
			if (checkOrderResult != null)
			{
			checkOrder.QualifiedQuantity = checkOrder.ReceivedQuantity - checkOrderResult.Quantity;
			}
			else
			{
			checkOrder.QualifiedQuantity = checkOrder.ReceivedQuantity;
			}
			checkOrder.CheckUserName = App.User.UserName;
			List<Dt_StockInfoDetail> initialStockDetails = stockInfo.Details.Where(x=> !(stockInfoDetails.Select(v=>v.Id).ToList()).Contains(x.Id)).ToList();
			_unitOfWorkManage.BeginTran();

			if (checkOrderResult != null)
			{
			BaseDal.AddData(checkOrderResult);
			}
			//æ¸é¤åºåæ°é
			if (stockInfoDetails.Count>0)
			{
			stockInfoDetails.ForEach(x =>
			{
			x.Status = StockStatusEmun.éæ£åºåå®æ.ObjToInt();
			});
			_stockRepository.StockInfoDetailRepository.UpdateData(stockInfoDetails);
			}
			if (initialStockDetails.Count>0)
			{
			initialStockDetails.ForEach(x =>
			{
			x.OutboundQuantity = 0;
			x.Status = StockStatusEmun.éæ£åºåå®æ.ObjToInt();
			});
			_stockRepository.StockInfoDetailRepository.UpdateData(initialStockDetails);
			}
			if (DelStockDetails.Count>0)
			{
			_stockRepository.StockInfoDetailRepository.DeleteAndMoveIntoHty(DelStockDetails, App.User.UserId == 0 ? OperateTypeEnum.èªå¨å®æ : OperateTypeEnum.äººå·¥å®æ);
			}
			if (DelStockDetails.Count==stockInfo.Details.Count)
			{
			_stockRepository.StockInfoRepository.DeleteAndMoveIntoHty(stockInfo, App.User.UserId == 0 ? OperateTypeEnum.èªå¨å®æ : OperateTypeEnum.äººå·¥å®æ);
			}
			else
			{
			stockInfo.StockStatus = StockStatusEmun.éæ£åºåå®æ.ObjToInt();
			_stockRepository.StockInfoRepository.UpdateData(stockInfo);
			}
			//ERPä¸æ¥
			WebResponseContent responseContent = _checkOrderService.FeedbackInspectResult(checkOrder, checkOrderResult != null ? new List<Dt_CheckOrderResult> { checkOrderResult } : new List<Dt_CheckOrderResult>());
			if (!responseContent.Status)
			{
			throw new Exception(responseContent.Message);
			}
			checkOrder.UploadStatus = CheckUploadEnum.UploadOk.ObjToInt();
			_checkOrderRepository.UpdateData(checkOrder);
			_unitOfWorkManage.CommitTran();
			content.OK();
			}
			catch (Exception ex)
			{
			_unitOfWorkManage.RollbackTran();
			return content.Error($"{ex.Message}");
			}
			return content;
			}
			/// <summary>
			/// è·åæ£éªä¿¡æ¯
			/// </summary>