using AutoMapper;
|
using SqlSugar.Extensions;
|
using System;
|
using System.Collections.Generic;
|
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;
|
using WIDESEA_Core.BaseServices;
|
using WIDESEA_DTO.Basic;
|
using WIDESEA_IBasicRepository;
|
using WIDESEA_IBasicService;
|
using WIDESEA_Model.Models;
|
|
namespace WIDESEA_BasicService
|
{
|
public partial class MaterielInfoService : ServiceBase<Dt_MaterielInfo, IMaterielInfoRepository>, IMaterielInfoService
|
{
|
private readonly IBasicRepository _basicRepository;
|
|
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;
|
}
|
/// <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());
|
//新增
|
List<BSTMaterialDTO> bSTMaterialsDTOAdd = bSTMaterialDTOs.Where(x => x.Way == 1).ToList();
|
//修改
|
List<BSTMaterialDTO> bSTMaterialsDTOUpdate = bSTMaterialDTOs.Where(x => x.Way == 2).ToList();
|
//删除
|
List<BSTMaterialDTO> bSTMaterialsDTODel = bSTMaterialDTOs.Where(x => x.Way == 3).ToList();
|
List<Dt_MaterielInfo> materielInfosAdd = new List<Dt_MaterielInfo>();
|
List<Dt_MaterielInfo> materielInfosUpdate = new List<Dt_MaterielInfo>();
|
//新增
|
if (bSTMaterialsDTOAdd.Count>0)
|
{
|
//判断重复插入
|
Dt_MaterielInfo? ExistMaterial = OldMaterielInfos.FirstOrDefault(x => bSTMaterialsDTOAdd.Select(x => x.MaterialId).Contains(x.MaterialSourceId));
|
if (ExistMaterial != null)
|
{
|
return content.Error($"物料{nameof(BSTMaterialDTO.MaterialId)}:{ExistMaterial.MaterialSourceId}已存在");
|
}
|
|
foreach (var item in bSTMaterialsDTOAdd)
|
{
|
if (bSTMaterialsDTOUpdate.FirstOrDefault(x=>x.MaterialId==item.MaterialId)!=null)
|
{
|
continue;
|
}
|
Dt_MaterielInfo materielInfo = _mapper.Map<Dt_MaterielInfo>(item);
|
materielInfosAdd.Add(materielInfo);
|
}
|
}
|
//更新
|
if (bSTMaterialsDTOUpdate.Count > 0)
|
{
|
//获取已存在的物料
|
List<Dt_MaterielInfo>? ExistbSTMaterialsUpdate = OldMaterielInfos.Where(x => bSTMaterialsDTOUpdate.Select(x => x.MaterialId).Contains(x.MaterialSourceId)).ToList();
|
foreach (var item in bSTMaterialsDTOUpdate)
|
{
|
Dt_MaterielInfo? materielInfoUpdate = ExistbSTMaterialsUpdate.FirstOrDefault(x => x.MaterialSourceId == item.MaterialId);
|
//如果物料已存在则进行更改
|
if (materielInfoUpdate!=null)
|
{
|
materielInfoUpdate.MaterielCode = item.MaterialNo;
|
materielInfoUpdate.MaterielName = item.Name;
|
materielInfoUpdate.MaterielSpec = item.Spec;
|
materielInfoUpdate.MaterielWide = item.MaterielWide;
|
materielInfoUpdate.MaterielThickness = item.MaterielThickness;
|
materielInfoUpdate.MaterielLength = item.MaterielLength;
|
materielInfoUpdate.MaterielWeight = item.Weight;
|
materielInfoUpdate.MaterielUnit = item.Unit;
|
materielInfosUpdate.Add(materielInfoUpdate);
|
}
|
else//如果不存在则进行新增
|
{
|
Dt_MaterielInfo materielInfo = _mapper.Map<Dt_MaterielInfo>(item);
|
materielInfosAdd.Add(materielInfo);
|
}
|
}
|
}
|
//删除
|
if (bSTMaterialsDTODel.Count > 0)
|
{
|
|
}
|
//更新数据
|
_unitOfWorkManage.BeginTran();
|
BaseDal.AddData(materielInfosAdd);
|
BaseDal.UpdateData(materielInfosUpdate);
|
_unitOfWorkManage.CommitTran();
|
return content.OK("接收成功");
|
}
|
catch (Exception ex)
|
{
|
_unitOfWorkManage.RollbackTran();
|
content.Error(ex.Message);
|
}
|
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;
|
}
|
}
|
}
|
