diff --git a/src/WMS.Web.Api/Controllers/InStockTaskController.cs b/src/WMS.Web.Api/Controllers/InStockTaskController.cs index abdcbbd1..c4b0d4b7 100644 --- a/src/WMS.Web.Api/Controllers/InStockTaskController.cs +++ b/src/WMS.Web.Api/Controllers/InStockTaskController.cs @@ -115,7 +115,15 @@ namespace WMS.Web.Api.Controllers if (loginInfo == null || loginInfo.UserInfo == null) return ResultList.ReFailure(ResultCodes.Token_Invalid_Error); - return await _inStockTaskService.Adjust(sourceBillNo); + //校准 + var result= await _inStockTaskService.Adjust(sourceBillNo); + if(!result.IsSuccess) + return ResultList.ReFailure(result); + + //再一次查询新的数据:并返回最后的结果 + var request = new InStockTaskBillNoQueryRequest() { SourceBillNo = sourceBillNo }; + var list = await _inStockTaskRepositories.GetListBy(request); + return ResultList.ReSuccess(list); } /// @@ -131,7 +139,15 @@ namespace WMS.Web.Api.Controllers if (loginInfo == null || loginInfo.UserInfo == null) return ResultList.ReFailure(ResultCodes.Token_Invalid_Error); - return await _inStockTaskService.AdjustNoPurchase(sourceBillNo); + //校准 + var result = await _inStockTaskService.Adjust(sourceBillNo); + if (!result.IsSuccess) + return ResultList.ReFailure(result); + + //再一次查询新的数据:并返回最后的结果 + var request = new InStockTaskBillNoQueryRequest() { SourceBillNo = sourceBillNo }; + var list = await _inStockTaskRepositories.GetListInfoBy(request); + return ResultList.ReSuccess(list); } diff --git a/src/WMS.Web.Domain/IService/IInStockTaskService.cs b/src/WMS.Web.Domain/IService/IInStockTaskService.cs index f4f9f2cb..062ec846 100644 --- a/src/WMS.Web.Domain/IService/IInStockTaskService.cs +++ b/src/WMS.Web.Domain/IService/IInStockTaskService.cs @@ -13,18 +13,11 @@ namespace WMS.Web.Domain.IService public interface IInStockTaskService { /// - /// 来源单-与金蝶校准-第二步-pad:这个只针对采购订单 + /// 来源单-与金蝶校准-第二步-pad /// /// /// - Task> Adjust(string sourceBillNo); - - /// - /// 来源单-与金蝶校准-第二步-pad:这个是非采购订单上架使用 - /// - /// - /// - Task> AdjustNoPurchase(string sourceBillNo); + Task Adjust(string sourceBillNo); /// /// 同步:采购入库类型单据 /// diff --git a/src/WMS.Web.Domain/Services/InStockTaskService.cs b/src/WMS.Web.Domain/Services/InStockTaskService.cs index cd4aa729..04183329 100644 --- a/src/WMS.Web.Domain/Services/InStockTaskService.cs +++ b/src/WMS.Web.Domain/Services/InStockTaskService.cs @@ -40,11 +40,11 @@ namespace WMS.Web.Domain.Services } /// - /// 来源单-与金蝶校准-第二步-pad:这个只针对采购订单 + /// 来源单-金蝶校准-实时 /// /// /// - public async Task> Adjust(string sourceBillNo) + public async Task Adjust(string sourceBillNo) { //1.事务 IDbContextTransaction _transaction = _basicsRepositories.GetTransaction(); @@ -54,79 +54,45 @@ namespace WMS.Web.Domain.Services //2.查看是否有入库任务单 var task = await _inStockTaskRepositories.GetBySource(sourceBillNo); if (task == null) - return ResultList.ReFailure(ResultCodes.OrderNoData); + return Result.ReFailure(ResultCodes.OrderNoData); //3.有的话就同步一下金蝶的数据 var billNos = new List(); billNos.Add(sourceBillNo); - //3.1采购订单类型-进去金蝶交互更新 + //3.1订单类型-进去金蝶交互更新 if (task.Type == InstockType.Purchase) { var result = await this.SsynPurchaseInStock(billNos, isTransaction); if (!result.IsSuccess) isRollback = true; - } - - //4.提交事务 - var isSuccess = _basicsRepositories.CommitTransaction(isRollback, _transaction); - if (!isSuccess) - return ResultList.ReFailure(ResultCodes.AdjustError); - - - //5.再一次查询新的数据:并返回最后的结果 - var request = new InStockTaskBillNoQueryRequest() { SourceBillNo = sourceBillNo }; - var list = await _inStockTaskRepositories.GetListBy(request); - return ResultList.ReSuccess(list); - } - - /// - /// 来源单-与金蝶校准-第二步-pad:这个是非采购订单上架使用 - /// - /// - /// - public async Task> AdjustNoPurchase(string sourceBillNo) - { - //1.事务 - IDbContextTransaction _transaction = _basicsRepositories.GetTransaction(); - bool isRollback = false; - bool isTransaction = false; - - //2.查看是否有入库任务单 - var task = await _inStockTaskRepositories.GetBySource(sourceBillNo); - if (task == null) - return ResultList.ReFailure(ResultCodes.OrderNoData); - - //3.有的话就同步一下金蝶的数据 - var billNos = new List(); - billNos.Add(sourceBillNo); - //3.1这里要对入库任务单的类型逐一判断,进行去ErpService找对应的单据类型重新获取;这里只有采购,后面再加其它的 - if (task.Type == InstockType.Miscellaneous) + } + else if (task.Type == InstockType.Miscellaneous) { var result = await this.SysnMiscellaneous(billNos, isTransaction); if (!result.IsSuccess) isRollback = true; } else if (task.Type == InstockType.Assembled) { - + var result = await this.SysnAssembledApp(billNos, isTransaction); + if (!result.IsSuccess) isRollback = true; } else if (task.Type == InstockType.Stkdirecttransfers) { - + var result = await this.SysnTransferDirect(billNos, isTransaction); + if (!result.IsSuccess) isRollback = true; } else if (task.Type == InstockType.StktransferInst) { - + var result = await this.SysnTransferin(billNos, isTransaction); + if (!result.IsSuccess) isRollback = true; } + //4.提交事务 var isSuccess = _basicsRepositories.CommitTransaction(isRollback, _transaction); if (!isSuccess) - return ResultList.ReFailure(ResultCodes.AdjustError); + return Result.ReFailure(ResultCodes.AdjustError); - - //5.再一次查询新的数据:并返回最后的结果 - var request = new InStockTaskBillNoQueryRequest() { SourceBillNo = sourceBillNo }; - var list = await _inStockTaskRepositories.GetListInfoBy(request); - return ResultList.ReSuccess(list); - } + return Result.ReSuccess(); + } /// /// 同步:采购入库类型单据