213 lines
9.0 KiB
C#
213 lines
9.0 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;
|
|
public TakeStockService(IMapper mapper, ILoginService loginService,
|
|
IBasicsRepositories transactionRepositories,
|
|
ITakeStockRepositories takeStockRepositories, ILoginRepositories loginRepositories,
|
|
ISingleDataService singleDataService, IErpService erpService, ILogger<TakeStockService> logger,
|
|
IBoxInventoryService boxInventoryService)
|
|
{
|
|
_mapper = mapper;
|
|
_loginService = loginService;
|
|
_transactionRepositories = transactionRepositories;
|
|
_takeStockRepositories = takeStockRepositories;
|
|
_loginRepositories = loginRepositories;
|
|
_singleDataService = singleDataService;
|
|
_erpService = erpService;
|
|
_logger = logger;
|
|
_boxInventoryService = boxInventoryService;
|
|
}
|
|
/// <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 == false).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 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 || subStock == null) return Result.ReFailure(ResultCodes.ErpStockNoData);
|
|
//组装dto
|
|
#region 组装dto
|
|
List<ErpTakeStockDetailsSaveDto> detils = new List<ErpTakeStockDetailsSaveDto>();
|
|
detils.Add(new ErpTakeStockDetailsSaveDto()
|
|
{
|
|
FOwnerid = stock.OrgId.ToString(),
|
|
FKeeperId = stock.OrgId.ToString(),
|
|
MaterialId = entity.MaterialId.ToString(),
|
|
UnitId = "", //物料带出来
|
|
StockId = stock.Id.ToString(),
|
|
SubStockId = subStock.Id.ToString(),
|
|
BeforeQty = entity.BeforeQty,
|
|
AfterQty = entity.AfterQty,
|
|
FinalQty = entity.FinalQty,
|
|
Fnote = ""
|
|
});
|
|
ErpTakeStockSaveDto dto = new ErpTakeStockSaveDto()
|
|
{
|
|
BillNo = entity.BillNo,
|
|
StockOrgId = stock.OrgId.ToString(),
|
|
Type = 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.IsSuccess, resSync.Message);
|
|
await _takeStockRepositories.Edit(entity, true);
|
|
return res;
|
|
}
|
|
/// <summary>
|
|
/// 同步金蝶操作
|
|
/// </summary>
|
|
/// <param name="dto"></param>
|
|
/// <param name="type"></param>
|
|
/// <returns></returns>
|
|
private async Task<Result> 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);
|
|
//提交
|
|
ErpOperateDto o_dto = new ErpOperateDto(formId, 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;
|
|
}
|
|
//审核
|
|
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;
|
|
}
|
|
_logger.LogInformation($"同步金蝶成功");
|
|
return Result.ReSuccess();
|
|
}
|
|
}
|
|
}
|