217 lines
9.8 KiB
C#
217 lines
9.8 KiB
C#
using AutoMapper;
|
|
using Microsoft.EntityFrameworkCore.Storage;
|
|
using Microsoft.Extensions.Logging;
|
|
using Newtonsoft.Json;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using WMS.Web.Core.Dto;
|
|
using WMS.Web.Core.Dto.Erp;
|
|
using WMS.Web.Core.Dto.Erp.TakeStock;
|
|
using WMS.Web.Core.Dto.Inventory;
|
|
using WMS.Web.Core.Dto.Login;
|
|
using WMS.Web.Core.Dto.TakeStock;
|
|
using WMS.Web.Core.Internal.Results;
|
|
using WMS.Web.Domain.Entitys;
|
|
using WMS.Web.Domain.Infrastructure;
|
|
using WMS.Web.Domain.IService;
|
|
using WMS.Web.Domain.IService.Public;
|
|
using WMS.Web.Domain.Values;
|
|
using WMS.Web.Domain.Values.Erp;
|
|
using WMS.Web.Domain.Values.Single;
|
|
|
|
namespace WMS.Web.Domain.Services
|
|
{
|
|
/// <summary>
|
|
/// 盘点单服务
|
|
/// </summary>
|
|
public class TakeStockService : ITakeStockService
|
|
{
|
|
private readonly IMapper _mapper;
|
|
private readonly ILoginService _loginService;
|
|
public readonly IBasicsRepositories _transactionRepositories;
|
|
private readonly ITakeStockRepositories _takeStockRepositories;
|
|
private readonly ILoginRepositories _loginRepositories;
|
|
private readonly ISingleDataService _singleDataService;
|
|
private readonly IErpService _erpService;
|
|
private readonly ILogger<TakeStockService> _logger;
|
|
private readonly IBoxInventoryService _boxInventoryService;
|
|
private readonly IErpBasicDataExtendService _erpBasicDataExtendService;
|
|
public TakeStockService(IMapper mapper, ILoginService loginService,
|
|
IBasicsRepositories transactionRepositories,
|
|
ITakeStockRepositories takeStockRepositories, ILoginRepositories loginRepositories,
|
|
ISingleDataService singleDataService, IErpService erpService, ILogger<TakeStockService> logger,
|
|
IBoxInventoryService boxInventoryService, IErpBasicDataExtendService erpBasicDataExtendService)
|
|
{
|
|
_mapper = mapper;
|
|
_loginService = loginService;
|
|
_transactionRepositories = transactionRepositories;
|
|
_takeStockRepositories = takeStockRepositories;
|
|
_loginRepositories = loginRepositories;
|
|
_singleDataService = singleDataService;
|
|
_erpService = erpService;
|
|
_logger = logger;
|
|
_boxInventoryService = boxInventoryService;
|
|
_erpBasicDataExtendService = erpBasicDataExtendService;
|
|
}
|
|
/// <summary>
|
|
/// 保存
|
|
/// </summary>
|
|
/// <param name="dto"></param>
|
|
/// <param name="loginInfo"></param>
|
|
/// <returns></returns>
|
|
public async Task<Result> Save(List<SaveTakeStockRequest> dto, LoginInDto loginInfo)
|
|
{
|
|
List<TakeStock> list = _mapper.Map<List<TakeStock>>(dto);
|
|
foreach (var entity in list)
|
|
{
|
|
var subStock = await _transactionRepositories.GetSubUcStockAsync(entity.SubStockId, loginInfo.UserInfo.CompanyId);
|
|
entity.Create(loginInfo.UserInfo.StaffId);
|
|
entity.OrgCode = subStock?.ErpOrgCode;
|
|
entity.StockCode = subStock?.StockCode;
|
|
}
|
|
|
|
IDbContextTransaction _transaction = _transactionRepositories.GetTransaction();
|
|
Result res_Rollback = Result.ReSuccess();
|
|
bool isSuccess = true;
|
|
|
|
if (res_Rollback.IsSuccess)
|
|
{
|
|
isSuccess = await _takeStockRepositories.AddRange(list, false);
|
|
if (!isSuccess) res_Rollback = Result.ReFailure(ResultCodes.DateWriteError);
|
|
}
|
|
if (res_Rollback.IsSuccess)
|
|
{
|
|
var res_Inventory = await _boxInventoryService.GenerateTakeBox(list, false);
|
|
if (!res_Inventory.IsSuccess) res_Rollback = res_Inventory;
|
|
}
|
|
|
|
//提交事务
|
|
isSuccess = _transactionRepositories.CommitTransaction(res_Rollback.IsSuccess ? false : true, _transaction);
|
|
if (!res_Rollback.IsSuccess) return res_Rollback;
|
|
if (!isSuccess)
|
|
return Result.ReFailure(ResultCodes.DateWriteError);
|
|
|
|
//同步金蝶
|
|
foreach (var entity in list)
|
|
await Loss_Profit(entity);
|
|
|
|
return Result.ReSuccess();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 同步金蝶
|
|
/// </summary>
|
|
/// <param name="dto"></param>
|
|
/// <returns></returns>
|
|
public async Task<Result> Sync(OperateRequest dto)
|
|
{
|
|
var list = await _takeStockRepositories.GetEntityList(dto.Ids);
|
|
list = list.Where(w => w.SuccessSync == SyncStatus.Fail).ToList();
|
|
foreach (var entity in list)
|
|
await Loss_Profit(entity);
|
|
|
|
return Result.ReSuccess();
|
|
}
|
|
/// <summary>
|
|
/// 盘盈盘亏同步金蝶
|
|
/// </summary>
|
|
/// <param name="entity"></param>
|
|
/// <returns></returns>
|
|
public async Task<Result> Loss_Profit(TakeStock entity)
|
|
{
|
|
//获取金蝶仓库仓位编码
|
|
//var stockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, entity.StockId);
|
|
var subStockCode = _singleDataService.GetSingleDataCode(SingleAction.Stocks, _loginRepositories.CompanyId, entity.SubStockId);
|
|
var materials_result = await _erpService.BillQueryForMaterial();
|
|
var materials = materials_result.Data.ToList();
|
|
var unitNumber = _erpBasicDataExtendService.GetMaterialUnitNumber(materials, entity.MaterialId);
|
|
var res = await _erpService.BillQueryForStock();
|
|
var stock = res.Data.FirstOrDefault(f => f.Code == entity.StockCode);//需要根据单点code搜索
|
|
var subStock = res.Data.FirstOrDefault(f => f.Code == subStockCode);//需要根据单点code搜索
|
|
if (stock == null) return Result.ReFailure(ResultCodes.ErpStockNoData);
|
|
//组装dto
|
|
#region 组装dto
|
|
List<ErpTakeStockDetailsSaveDto> detils = new List<ErpTakeStockDetailsSaveDto>();
|
|
detils.Add(new ErpTakeStockDetailsSaveDto()
|
|
{
|
|
FOwnerid = new ErpNumberDto(stock.OrgCode.ToString()),
|
|
FKeeperId = new ErpNumberDto(stock.OrgCode.ToString()),
|
|
MaterialId = new ErpNumberDto(_erpBasicDataExtendService.GetMaterialNumber(materials, entity.MaterialId)),
|
|
UnitId = new ErpNumberDto(unitNumber), //物料带出来
|
|
StockId = new ErpNumberDto(stock.Code),
|
|
SubStockId = subStock?.Id.ToString(),
|
|
BeforeQty = entity.BeforeQty,
|
|
AfterQty = entity.AfterQty,
|
|
FinalQty = entity.FinalQty,
|
|
Fnote = ""
|
|
});
|
|
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);
|
|
await _takeStockRepositories.Edit(entity, true);
|
|
return res;
|
|
}
|
|
/// <summary>
|
|
/// 同步金蝶操作
|
|
/// </summary>
|
|
/// <param name="dto"></param>
|
|
/// <param name="type"></param>
|
|
/// <returns></returns>
|
|
private async Task<(Result result, SyncStatus syncStatus)> ErpOperate(ErpTakeStockSaveDto dto, FormIdParam type)
|
|
{
|
|
string formId = type.ToString();
|
|
_logger.LogInformation($"开始同步金蝶 单号:{dto.BillNo} 数据: {JsonConvert.SerializeObject(dto)}");
|
|
//var res_s = await _erpService.Save<ErpTakeStockSaveDto>(dto, formId);
|
|
//if (!res_s.IsSuccess)
|
|
// return (Result.ReFailure(res_s.Message, res_s.Status), SyncStatus.Fail);
|
|
//提交
|
|
ErpOperateDto o_dto = new ErpOperateDto(formId,"257552");//res_s.Data
|
|
var res = await _erpService.Submit(o_dto, formId);
|
|
if (!res.IsSuccess)
|
|
{
|
|
//如果提交失败
|
|
//1.则调删单接口
|
|
//var del_res = await _erpService.Delete(o_dto, formId);
|
|
//if (!del_res.IsSuccess)
|
|
// _logger.LogError($"盘盈盘亏同步金蝶 单号:{dto.BillNo} 提交失败原因: {res.Message} 删单失败原因:{del_res.Message}");
|
|
return (res, SyncStatus.PortionSuccess);
|
|
}
|
|
//审核
|
|
res = await _erpService.Audit(o_dto, formId);
|
|
if (!res.IsSuccess)
|
|
{
|
|
//如果审核失败
|
|
//1.调反审核接口
|
|
//2.调删除接口
|
|
//var noAudit_res = await _erpService.NoAudit(o_dto, formId);
|
|
//if (!noAudit_res.IsSuccess)
|
|
//{
|
|
// _logger.LogError($"盘盈盘亏同步金蝶 单号:{dto.BillNo} 审核失败原因: {res.Message} 反审核失败原因:{noAudit_res.Message}");
|
|
// return res;
|
|
//}
|
|
|
|
//var del_res = await _erpService.Delete(o_dto, formId);
|
|
//if (!del_res.IsSuccess)
|
|
// _logger.LogError($"盘盈盘亏同步金蝶 单号:{dto.BillNo} 审核失败原因: {res.Message} 删单失败原因:{del_res.Message}");
|
|
return (res, SyncStatus.PortionSuccess);
|
|
}
|
|
_logger.LogInformation($"同步金蝶成功");
|
|
return (Result.ReSuccess(), SyncStatus.Success);
|
|
}
|
|
}
|
|
}
|