wangxinhui
2025-10-17 ce40df5daffae0d17b4e9fa7cb6d677afaa4d66f
ÏîÄ¿´úÂë/WMS/WMSServices/WIDESEA_BasicService/Base/MaterielInfoService.cs
@@ -5,6 +5,7 @@
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Common.MaterielEnum;
using WIDESEA_Common.WareHouseEnum;
using WIDESEA_Core;
using WIDESEA_Core.BaseRepository;
@@ -102,7 +103,7 @@
                }
                //更新数据
                _unitOfWorkManage.CommitTran();
                _unitOfWorkManage.BeginTran();
                BaseDal.AddData(materielInfosAdd);
                BaseDal.UpdateData(materielInfosUpdate);
                _unitOfWorkManage.CommitTran();
@@ -115,6 +116,78 @@
            }
            return content;
        }
        /// <summary>
        /// æ·»åŠ äºŒæœŸç‰©æ–™
        /// </summary>
        /// <param name="eRPMaterialDTOs"></param>
        /// <returns></returns>
        public WebResponseContent ReceiveMaterial(ERPMaterialDTO eRPMaterialDTO)
        {
            WebResponseContent content = new WebResponseContent();
            try
            {
                if (eRPMaterialDTO==null)
                {
                    return content.Error("物料信息不能传入为空");
                }
                List<Dt_MaterielInfo> OldMaterielInfos = BaseDal.QueryData(x => x.MaterielInvOrgId == MaterielInvOrgEnum.新厂.ObjToInt());
                Dt_Warehouse warehouse=_basicRepository.WarehouseRepository.QueryFirst(x=>x.WarehouseCode== eRPMaterialDTO.WarehouseCode);
                if (warehouse==null)
                {
                    return content.Error($"未找到仓库代号:{eRPMaterialDTO.WarehouseCode}");
                }
                if (eRPMaterialDTO.OperateType==1)
                {
                    //判断重复插入
                    Dt_MaterielInfo? ExistMaterial = OldMaterielInfos.FirstOrDefault(x => x.MaterielCode == eRPMaterialDTO.MaterielNo);
                    if (ExistMaterial != null)
                    {
                        return content.Error($"物料{ExistMaterial.MaterielCode}已存在");
                    }
                    Dt_MaterielInfo materielInfo = _mapper.Map<Dt_MaterielInfo>(eRPMaterialDTO);
                    materielInfo.WarehouseId = warehouse.WarehouseId;
                    BaseDal.AddData(materielInfo);
                }
                else if (eRPMaterialDTO.OperateType == 2)
                {
                    //判断是否存在
                    Dt_MaterielInfo? ExistMaterial = OldMaterielInfos.FirstOrDefault(x => x.MaterielCode == eRPMaterialDTO.MaterielNo);
                    if (ExistMaterial == null)
                    {
                        return content.Error($"更新物料{eRPMaterialDTO.MaterielNo}不存在");
                    }
                    Dt_MaterielInfo materielInfo = _mapper.Map<Dt_MaterielInfo>(eRPMaterialDTO);
                    materielInfo.WarehouseId = warehouse.WarehouseId;
                    materielInfo.Id = ExistMaterial.Id;
                    _unitOfWorkManage.BeginTran();
                    BaseDal.UpdateData(materielInfo);
                    _unitOfWorkManage.CommitTran();
                }
                else if (eRPMaterialDTO.OperateType == 3)
                {
                    //判断是否存在
                    Dt_MaterielInfo? ExistMaterial = OldMaterielInfos.FirstOrDefault(x => x.MaterielCode == eRPMaterialDTO.MaterielNo);
                    if (ExistMaterial == null)
                    {
                        return content.Error($"更新物料{eRPMaterialDTO.MaterielNo}不存在");
                    }
                    _unitOfWorkManage.BeginTran();
                    BaseDal.DeleteData(ExistMaterial);
                    _unitOfWorkManage.CommitTran();
                }
                else
                {
                    return content.Error("未找到操作类型");
                }
                //更新数据
                return content.OK("接收成功");
            }
            catch (Exception ex)
            {
                _unitOfWorkManage.RollbackTran();
                content.Error(ex.Message);
            }
            return content;
        }
    }
}