美瑞安淮安立体仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
wangxinhui
2025-07-30 88676143aeceaeec3bd108f9cd609c4f3470ba96 
 ´úÂë¹ÜÀí/WMS/WIDESEA_WMSServer/WIDESEA_InboundService/ReceiveOrderDetailService.cs


@@ -1,5 +1,6 @@





using AutoMapper;


using Newtonsoft.Json;


using System;


using System.Collections.Generic;


using System.Globalization;


@@ -15,6 +16,9 @@


using WIDESEA_Core.Helper;


using WIDESEA_DTO;


using WIDESEA_DTO.Basic;


using WIDESEA_DTO.QMS;


using WIDESEA_External.Model;


using WIDESEA_External.QMSService;


using WIDESEA_IBasicRepository;


using WIDESEA_ICheckRepository;


using WIDESEA_IInboundRepository;


@@ -32,8 +36,10 @@


        private readonly IBasicRepository _basicRepository;


        private readonly ICheckOrderRepository _checkOrderRepository;


        private readonly IStockRepository _stockRepository;


        private readonly ISupplierInfoRepository _supplierInfoRepository;


        private readonly IInvokeQMSService _invokeQMSService;




        public ReceiveOrderDetailService(IReceiveOrderDetailRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IInboundRepository inboundRepository, IBasicRepository basicRepository, ICheckOrderRepository checkOrderRepository, IStockRepository stockRepository) : base(BaseDal)


        public ReceiveOrderDetailService(IReceiveOrderDetailRepository BaseDal, IMapper mapper, IUnitOfWorkManage unitOfWorkManage, IInboundRepository inboundRepository, IBasicRepository basicRepository, ICheckOrderRepository checkOrderRepository, IStockRepository stockRepository,ISupplierInfoRepository supplierInfoRepository,IInvokeQMSService invokeQMSService) : base(BaseDal)


        {


            _mapper = mapper;


            _unitOfWorkManage = unitOfWorkManage;


@@ -41,6 +47,8 @@


            _basicRepository = basicRepository;


            _checkOrderRepository = checkOrderRepository;


            _stockRepository = stockRepository;


            _supplierInfoRepository = supplierInfoRepository;


            _invokeQMSService = invokeQMSService;


        }




        private static object _rowNoLocker = new object();


@@ -64,10 +72,10 @@


                {


                    return WebResponseContent.Instance.Error($"该单据已收货完成");


                }




                Dt_Warehouse warehouse = _basicRepository.WarehouseRepository.QueryFirst(x => x.WarehouseId == receiveOrder.WarehouseId);


                MatSerNumAnalysisModel model = CodeAnalysisHelper.CodeAnalysis<MatSerNumAnalysisModel>(AnalysisCodeEnum.MatSerNumAnalysis, serNum);


                //收货增加批次卡控


                //查询收货明细是否有存在同一个批次


                Dt_SupplierInfo supplierInfo = _supplierInfoRepository.QueryFirst(x => x.SupplierCode == receiveOrder.SuppliersId);


                //收货增加批次卡控,查询收货明细是否有存在同一个批次


                Dt_ReceiveOrderDetail receiveOrderDetailOld = _inboundRepository.ReceiveOrderDetailRepository.QueryFirst(x => x.LotNo == model.LotNo && x.MaterielCode == model.MaterielCode);


                Dt_ReceiveOrder? receiveOrderOld = null;


                if (receiveOrderDetailOld!=null)


@@ -174,6 +182,7 @@


                            if (materielInfo.IsCheck == WhetherEnum.True)


                            {


                                Dt_CheckOrder checkOrder = _mapper.Map<Dt_CheckOrder>(receiveOrderDetail);


                                checkOrder.OrderType = CheckTypeEnum.ReceiveCheck.ObjToInt();


                                checkOrder.ReceiveOrderNo = receiveOrder.ReceiveOrderNo;


                                checkOrder.QualifiedQuantity = receiveOrderDetail.ReceivedQuantity;


                                checkOrder.ReceiveDetailRowNo = receiveOrderDetail.RowNo;


@@ -320,21 +329,53 @@


                        }


                        _inboundRepository.ReceiveOrderRepository.UpdateData(receiveOrder);


                        _inboundRepository.PurchaseOrderDetailRepository.UpdateData(purchaseOrderDetail);


                        #region æ³¨é‡Š


                        if (materielInfo.IsCheck == WhetherEnum.True)


                        {


                            Dt_CheckOrder checkOrder = _mapper.Map<Dt_CheckOrder>(receiveOrderDetail);


                            checkOrder.OrderType = CheckTypeEnum.ReceiveCheck.ObjToInt();


                            checkOrder.ReceiveOrderNo = receiveOrder.ReceiveOrderNo;


                            checkOrder.Result = CheckAcceptEnum.NotCheckAccept.ToString();


                            checkOrder.QualifiedQuantity = 0;


                            checkOrder.ReceiveDetailRowNo = receiveOrderDetail.RowNo;


                            checkOrder.WarehouseId = receiveOrder.WarehouseId;


                            checkOrder.ScrappedQuantity = 0;


                            checkOrder.MaterielSpec = materielInfo.MaterielSpec;


                            checkOrder.ReturnQuantity = 0;


                            checkOrder.DefectedQuantity = 0;


                            _checkOrderRepository.AddData(checkOrder);


                            int id = _checkOrderRepository.AddData(checkOrder);


                            QMSReceiveCheckModel qMSReceiveCheck = new QMSReceiveCheckModel()


                            {


                                UniqueTag = id.ToString(),


                                EntryNumber = receiveOrder.ReceiveOrderNo,


                                MaterialCode = receiveOrderDetail.MaterielCode,


                                MaterialName = receiveOrderDetail.MaterielName,


                                Quantity = (decimal)receiveOrderDetail.ReceivedQuantity,


                                SupplierCode = receiveOrder.SuppliersId,


                                SupplierName = supplierInfo.SupplierName,


                                BatchNumber = receiveOrderDetail.LotNo,


                                DeliveryNumber = receiveOrder.DeliveryCode,


                                PurchaseNumber = receiveOrderDetail.PurchaseOrderNo,


                                RowNumber = receiveOrderDetail.RowNo,


                                WarehouseCode = warehouse.WarehouseCode,


                                ReceiptDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),


                                Remark = " "


                            };


                            //调用QMS来料检验接口


                            string response = _invokeQMSService.InvokeReceiveCheckApi(qMSReceiveCheck);


                            MesResponseContent mesResponseContent = response.DeserializeObject<MesResponseContent>();


                            if (!mesResponseContent.BSucc)


                            {


                                throw new Exception(mesResponseContent.StrMsg);


                            }


                            ReceiveResultDTO? receiveResult = JsonConvert.DeserializeObject<ReceiveResultDTO>(mesResponseContent.Content.ToString());


                            if (receiveResult == null)


                            {


                                throw new Exception("接收QMS结果失败");


                            }


                            Dt_CheckOrder _CheckOrder = _checkOrderRepository.QueryFirst(x => x.CheckOrderId == id);


                            _CheckOrder.CheckOrderNo = receiveResult.InspectionNumber;


                            _checkOrderRepository.UpdateData(_CheckOrder);


                        }


                        #endregion


                        _unitOfWorkManage.CommitTran();


                    }