From cd78554c3da306ed8c866d971bee94457665f80c Mon Sep 17 00:00:00 2001 From: wangxinhui <wangxinhui@hnkhzn.com> Date: 星期六, 30 八月 2025 17:35:51 +0800 Subject: [PATCH] ERP一期接口 --- 项目代码/WMS/WMSServices/WIDESEA_BasicService/Base/MaterielInfoService.cs | 49 +++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 45 insertions(+), 4 deletions(-) diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WMSServices/WIDESEA_BasicService/Base/MaterielInfoService.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WMSServices/WIDESEA_BasicService/Base/MaterielInfoService.cs" index 6f95a6e..2c00040 100644 --- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WMSServices/WIDESEA_BasicService/Base/MaterielInfoService.cs" +++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WMS/WMSServices/WIDESEA_BasicService/Base/MaterielInfoService.cs" @@ -1,10 +1,15 @@ -锘縰sing System; +锘縰sing AutoMapper; +using SqlSugar.Extensions; +using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; +using WIDESEA_Common.WareHouseEnum; using WIDESEA_Core; +using WIDESEA_Core.BaseRepository; using WIDESEA_Core.BaseServices; +using WIDESEA_DTO.Basic; using WIDESEA_IBasicRepository; using WIDESEA_IBasicService; using WIDESEA_Model.Models; @@ -15,12 +20,48 @@ { private readonly IBasicRepository _basicRepository; - public MaterielInfoService(IMaterielInfoRepository BaseDal, IBasicRepository basicRepository) : base(BaseDal) + public IMaterielInfoRepository Repository => BaseDal; + private readonly IUnitOfWorkManage _unitOfWorkManage; + private readonly IMapper _mapper; + + public MaterielInfoService(IMaterielInfoRepository BaseDal, IBasicRepository basicRepository,IUnitOfWorkManage unitOfWorkManage,IMapper mapper) : base(BaseDal) { _basicRepository = basicRepository; + _unitOfWorkManage = unitOfWorkManage; + _mapper = mapper; } - - public IMaterielInfoRepository Repository => BaseDal; + /// <summary> + /// 娣诲姞鑰佸巶鐗╂枡淇℃伅 + /// </summary> + /// <returns></returns> + public WebResponseContent AddMaterial(List<BSTMaterialDTO> bSTMaterialDTOs) + { + WebResponseContent content = new WebResponseContent(); + try + { + List<Dt_MaterielInfo> OldMaterielInfos = BaseDal.QueryData(x => x.WarehouseId == WarehouseEnum.LLDYL.ObjToInt()); + //鍒ゆ柇閲嶅鎻掑叆 + Dt_MaterielInfo? ExistMaterial = OldMaterielInfos.FirstOrDefault(x => bSTMaterialDTOs.Where(x => x.Way == 1).Select(x => x.MaterialId).Contains(x.MaterialSourceId)); + if (ExistMaterial != null) + { + return content.Error($"鐗╂枡Id{nameof(BSTMaterialDTO.MaterialId)}:{ExistMaterial.MaterialSourceId}宸插瓨鍦�"); + } + List<Dt_MaterielInfo> materielInfos = new List<Dt_MaterielInfo>(); + foreach (var item in bSTMaterialDTOs) + { + Dt_MaterielInfo materielInfo = _mapper.Map<Dt_MaterielInfo>(item); + materielInfos.Add(materielInfo); + } + BaseDal.AddData(materielInfos); + return content.OK("鎺ユ敹鎴愬姛"); + } + catch (Exception ex) + { + _unitOfWorkManage.RollbackTran(); + content.Error(ex.Message); + } + return content; + } } } -- Gitblit v1.9.3