修复bug

This commit is contained in:
18942506660
2023-12-19 15:32:57 +08:00
parent 9e1252704b
commit 366e523e49

View File

@@ -164,53 +164,64 @@ namespace WMS.Web.Domain.Services
//获取金蝶仓库仓位编码 //获取金蝶仓库仓位编码
//var stockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, entity.StockId); //var stockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, entity.StockId);
//var subStockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, entity.SubStockId); //var subStockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, entity.SubStockId);
var materials_result = await _erpService.BillQueryForMaterial(); try
var materials = materials_result.Data.ToList(); {
var materials_result = await _erpService.BillQueryForMaterial();
if (!materials_result.IsSuccess) return Result.ReFailure(ResultCodes.ErpMaterialError);
var materials = materials_result.Data.ToList();
var res = await _erpService.BillQueryForStock(); var res = await _erpService.BillQueryForStock();
var resSub = await _erpService.BillQueryForSubStock(); if (!res.IsSuccess) return Result.ReFailure(ResultCodes.ErpStockError);
var stock = res.Data.FirstOrDefault(f => f.Code == entity.Details[0].StockCode);//需要根据单点code搜索 var resSub = await _erpService.BillQueryForSubStock();
if (stock == null) return Result.ReFailure(ResultCodes.ErpStockNoData); if (!resSub.IsSuccess) return Result.ReFailure(ResultCodes.ErpStockError);
//组装dto var stock = res.Data.FirstOrDefault(f => f.Code == entity.Details[0].StockCode);//需要根据单点code搜索
#region dto if (stock == null) return Result.ReFailure(ResultCodes.ErpStockNoData);
//子仓库 ORICO_JD1000008 GD1000005 HD1000007 AD1000004 //组装dto
List<ErpTakeStockDetailsSaveDto> detils = new List<ErpTakeStockDetailsSaveDto>(); #region dto
foreach (var d in entity.Details) //子仓库 ORICO_JD1000008 GD1000005 HD1000007 AD1000004
{ List<ErpTakeStockDetailsSaveDto> detils = new List<ErpTakeStockDetailsSaveDto>();
var subStockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, d.SubStockId); foreach (var d in entity.Details)
var subStock = resSub.Data.FirstOrDefault(f => f.Code == subStockCode);//需要根据单点code搜索
var unitNumber = _erpBasicDataExtendService.GetMaterialUnitNumber(materials, d.MaterialId);
detils.Add(new ErpTakeStockDetailsSaveDto()
{ {
FOwnerid = new ErpNumberDto(stock.OrgCode.ToString()), var subStockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, d.SubStockId);
FKeeperId = new ErpNumberDto(stock.OrgCode.ToString()), //var subStock = resSub.Data.FirstOrDefault(f => f.Code == subStockCode);//需要根据单点code搜索
MaterialId = new ErpNumberDto(_erpBasicDataExtendService.GetMaterialNumber(materials, d.MaterialId)), var unitNumber = _erpBasicDataExtendService.GetMaterialUnitNumber(materials, d.MaterialId);
UnitId = new ErpNumberDto(unitNumber), //物料带出来 detils.Add(new ErpTakeStockDetailsSaveDto()
StockId = new ErpNumberDto(stock.Code), {
SubStockId = new ErpSubStockDto(stock.Code, resSub.Data.FirstOrDefault(f => f.Id == d.Erp_SubStockId)?.Code), FOwnerid = new ErpNumberDto(stock.OrgCode.ToString()),
BeforeQty = d.BeforeQty, FKeeperId = new ErpNumberDto(stock.OrgCode.ToString()),
AfterQty = d.AfterQty, MaterialId = new ErpNumberDto(_erpBasicDataExtendService.GetMaterialNumber(materials, d.MaterialId)),
FinalQty = entity.ResultType == TakeStockType.Profit ? d.FinalQty : 0, UnitId = new ErpNumberDto(unitNumber), //物料带出来
LossQty = entity.ResultType == TakeStockType.Loss ? d.FinalQty : 0, StockId = new ErpNumberDto(stock.Code),
Fnote = d.Remark SubStockId = new ErpSubStockDto(stock.Code, resSub.Data.FirstOrDefault(f => f.Id == d.Erp_SubStockId)?.Code),
}); BeforeQty = d.BeforeQty,
AfterQty = d.AfterQty,
FinalQty = entity.ResultType == TakeStockType.Profit ? d.FinalQty : 0,
LossQty = entity.ResultType == TakeStockType.Loss ? d.FinalQty : 0,
Fnote = d.Remark
});
}
ErpTakeStockSaveDto dto = new ErpTakeStockSaveDto()
{
BillNo = entity.BillNo,
StockOrgId = new ErpNumberDto(stock.OrgCode),
Type = new ErpNumberDto(entity.ResultType == TakeStockType.Loss ? "PK01_SYS" : "PY01_SYS"),
Date = entity.Date,
Details = detils
};
#endregion
//判断盘盈盘亏
FormIdParam type = entity.ResultType == TakeStockType.Loss ? FormIdParam.STK_StockCountLoss : FormIdParam.STK_StockCountGain;
//操作金蝶
var resSync = await ErpOperate(dto, type);
entity.Sync(resSync.result.IsSuccess, resSync.result.Message, resSync.syncStatus, resSync.erpBillNo);
await _takeStockRepositories.Edit(entity, true);
return res;
} }
ErpTakeStockSaveDto dto = new ErpTakeStockSaveDto() catch (Exception ex)
{ {
BillNo = entity.BillNo, _logger.LogError($"盘点同步金蝶: {ex.ToString()}");
StockOrgId = new ErpNumberDto(stock.OrgCode), return Result.ReFailure(ResultCodes.NoDateError);
Type = new ErpNumberDto(entity.ResultType == TakeStockType.Loss ? "PK01_SYS" : "PY01_SYS"), }
Date = entity.Date,
Details = detils
};
#endregion
//判断盘盈盘亏
FormIdParam type = entity.ResultType == TakeStockType.Loss ? FormIdParam.STK_StockCountLoss : FormIdParam.STK_StockCountGain;
//操作金蝶
var resSync = await ErpOperate(dto, type);
entity.Sync(resSync.result.IsSuccess, resSync.result.Message, resSync.syncStatus, resSync.erpBillNo);
await _takeStockRepositories.Edit(entity, true);
return res;
} }
/// <summary> /// <summary>
/// 同步金蝶操作 /// 同步金蝶操作