18923810322/WMS-Api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

增加日志

Browse Source
This commit is contained in:
18942506660
2024-05-13 12:00:28 +08:00
parent 1653c43ae9
commit 5d31f820e0
7 changed files with 121 additions and 87 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/WMS.Web.Domain/Services/InStockTaskService.cs
View File

@@ -110,10 +110,10 @@ namespace WMS.Web.Domain.Services
/// <param name="billNos"></param>
/// <param name="isTransaction"></param>
/// <returns></returns>
public async Task<Result> SsynPurchaseInStock(List<string> billNos = null, bool isTransaction = true)
public async Task<Result> SsynPurchaseInStock(List<string> billNos = null, bool isTransaction = true, DateTime? beginTime = null)
{
//1.获取金蝶数据：采购订单数据
var erp_result = await _erpService.BillQueryForPurchaseInStock(billNos);
var erp_result = await _erpService.BillQueryForPurchaseInStock(billNos, beginTime);
if (!erp_result.IsSuccess)
return Result.ReFailure(erp_result.Message, erp_result.Status);
var erp_list = erp_result.Data;
@@ -127,10 +127,10 @@ namespace WMS.Web.Domain.Services
/// <param name="billNos"></param>
/// <param name="isTransaction"></param>
/// <returns></returns>
public async Task<Result> SysnMiscellaneous(List<string> billNos = null, bool isTransaction = true)
public async Task<Result> SysnMiscellaneous(List<string> billNos = null, bool isTransaction = true, DateTime? beginTime = null)
{
//1.获取金蝶数据：其他入库订单数据
var erp_result = await _erpService.BillQueryForMiscellaneous(billNos);
var erp_result = await _erpService.BillQueryForMiscellaneous(billNos, beginTime);
if (!erp_result.IsSuccess)
return Result.ReFailure(erp_result.Message, erp_result.Status);
var erp_list = erp_result.Data;
@@ -144,10 +144,10 @@ namespace WMS.Web.Domain.Services
/// <param name="billNos"></param>
/// <param name="isTransaction"></param>
/// <returns></returns>
public async Task<Result> SysnTransferDirect(List<string> billNos = null, bool isTransaction = true)
public async Task<Result> SysnTransferDirect(List<string> billNos = null, bool isTransaction = true, DateTime? beginTime = null)
{
//1.获取金蝶数据：直接调拨入库订单数据
var erp_result = await _erpService.BillQueryForTransferDirect(billNos);
var erp_result = await _erpService.BillQueryForTransferDirect(billNos, beginTime);
if (!erp_result.IsSuccess)
return Result.ReFailure(erp_result.Message, erp_result.Status);
var erp_list = erp_result.Data;
@@ -161,10 +161,10 @@ namespace WMS.Web.Domain.Services
/// <param name="billNos"></param>
/// <param name="isTransaction"></param>
/// <returns></returns>
public async Task<Result> SysnTransferin(List<string> billNos = null, bool isTransaction = true)
public async Task<Result> SysnTransferin(List<string> billNos = null, bool isTransaction = true, DateTime? beginTime = null)
{
//1.获取金蝶数据：分步式入库订单数据
var erp_result = await _erpService.BillQueryForTransferin(billNos);
var erp_result = await _erpService.BillQueryForTransferin(billNos, beginTime);
if (!erp_result.IsSuccess)
return Result.ReFailure(erp_result.Message, erp_result.Status);
var erp_list = erp_result.Data;
@@ -177,18 +177,18 @@ namespace WMS.Web.Domain.Services
/// <param name="billNos"></param>
/// <param name="isTransaction"></param>
/// <returns></returns>
public async Task<Result> SysnAssembledApp(List<string> billNos = null, bool isTransaction = true)
public async Task<Result> SysnAssembledApp(List<string> billNos = null, bool isTransaction = true, DateTime? beginTime = null)
{
var erp_list = new List<ErpInStockResultDto>();
//1.获取金蝶数据：组装成品入库订单数据
var erp_result_ass = await _erpService.BillQueryForAssembledApp_Assembly(billNos);
var erp_result_ass = await _erpService.BillQueryForAssembledApp_Assembly(billNos, beginTime);
if (!erp_result_ass.IsSuccess)
return Result.ReFailure(erp_result_ass.Message, erp_result_ass.Status);
var erp_list_ass = erp_result_ass.Data;
erp_list.AddRange(erp_list_ass);
//1.1.获取金蝶数据：拆卸子件入库订单数据
var erp_result_disass = await _erpService.BillQueryForAssembledApp_Disassembly(billNos);
var erp_result_disass = await _erpService.BillQueryForAssembledApp_Disassembly(billNos, beginTime);
if (!erp_result_disass.IsSuccess)
return Result.ReFailure(erp_result_disass.Message, erp_result_disass.Status);
var erp_list_disass = erp_result_disass.Data;
@@ -235,28 +235,29 @@ namespace WMS.Web.Domain.Services
{
if (billNos == null || billNos.Count == 0)
{
var beginTime = DateTime.Now.AddHours(-8);
//1.同步数据:采购订单
var purchase_result = await this.SsynPurchaseInStock(null, isTransaction);
var purchase_result = await this.SsynPurchaseInStock(null, isTransaction, beginTime);
if (!purchase_result.IsSuccess)
return Result.ReFailure(purchase_result.Message, purchase_result.Status);
//2.同步数据：其他入库单
var miscellaneou_result = await this.SysnMiscellaneous(null, isTransaction);
var miscellaneou_result = await this.SysnMiscellaneous(null, isTransaction, beginTime);
if (!miscellaneou_result.IsSuccess)
return Result.ReFailure(miscellaneou_result.Message, miscellaneou_result.Status);
//3.同步数据：直接调拨入库单
var TransferDirect_result = await this.SysnTransferDirect(null, isTransaction);
var TransferDirect_result = await this.SysnTransferDirect(null, isTransaction, beginTime);
if (!TransferDirect_result.IsSuccess)
return Result.ReFailure(TransferDirect_result.Message, TransferDirect_result.Status);
//4.同步数据：分步式入库单
var Transferin_result = await this.SysnTransferin(null, isTransaction);
var Transferin_result = await this.SysnTransferin(null, isTransaction, beginTime);
if (!Transferin_result.IsSuccess)
return Result.ReFailure(Transferin_result.Message, Transferin_result.Status);
//5.同步数据：组装拆卸单
var AssembledApp_result = await this.SysnAssembledApp(null, isTransaction);
var AssembledApp_result = await this.SysnAssembledApp(null, isTransaction, beginTime);
if (!AssembledApp_result.IsSuccess)
return Result.ReFailure(AssembledApp_result.Message, AssembledApp_result.Status);
}