修复合并问题

usertest
zhangxiaofeng 3 months ago
parent 47e7145e3e
commit 22cc8cacc4

@ -41,7 +41,7 @@ namespace DS.Module.Core
/// BC对比订单后是否存在差异
/// </summary>
/// <remarks>类型:<see cref="bool" /></remarks>
public const string BcCompareBcWithSeaExportIsExistsDiff = "BcCompareBcWithSeaExportIsExistsDiff";
public const string BcCompareWithSeaExportResult = "BcCompareWithSeaExportResult";
/// <summary>
/// BC文件

@ -1136,7 +1136,7 @@ namespace DS.WMS.Core.TaskPlat.Method
/// <summary>
/// 对比BC与海运出口订单任务台使用
/// </summary>
public async Task<DataResult<(bool isExistsDiff, List<CompareResultDetailInfo>)>> CompareBcWithSeaExportTask(TaskFlowDataContext dataContext)
public async Task<DataResult<CompareResultInfo>> CompareBcWithSeaExportTask(TaskFlowDataContext dataContext)
{
var taskBcInfo = dataContext.Get<TaskBCInfo?>(TaskFlowDataNameConst.TaskBCInfo) ?? throw new ArgumentException($"缺少参数:{nameof(TaskFlowDataNameConst.TaskBCInfo)}");
var taskBcCtnList = dataContext.Get<List<TaskBCCTNInfo>?>(TaskFlowDataNameConst.TaskBCCtnList) ?? throw new ArgumentException($"缺少参数:{nameof(TaskFlowDataNameConst.TaskBCCtnList)}");
@ -1174,18 +1174,19 @@ namespace DS.WMS.Core.TaskPlat.Method
SeaExport = seaExport,
OpCtnList = seaExportCtnList
};
(bool isExistsDiff, List<CompareResultDetailInfo>) result = await CompareBcWithSeaExport(compareDto);
var result = await CompareBcWithSeaExport(compareDto);
dataContext.Set(TaskFlowDataNameConst.BcCompareBcWithSeaExportIsExistsDiff, result.isExistsDiff);
dataContext.Set(TaskFlowDataNameConst.BcCompareWithSeaExportResult, result);
return DataResult<(bool isExistsDiff, List<CompareResultDetailInfo>)>.Success(result);
return DataResult<CompareResultInfo>.Success(result);
}
/// <summary>
/// 对比BC与海运出口订单
/// </summary>
public async Task<(bool isExistsDiff, List<CompareResultDetailInfo>)> CompareBcWithSeaExport(CompareBcWithSeaExportDto compareDto)
public async Task<CompareResultInfo> CompareBcWithSeaExport(CompareBcWithSeaExportDto compareDto)
{
var taskBcInfo = compareDto.TaskBCInfo;
var taskBcCtnList = compareDto.TaskBCCtnList;
var seaExport = compareDto.SeaExport;
@ -1257,7 +1258,7 @@ namespace DS.WMS.Core.TaskPlat.Method
logger.LogInformation($"批次={batchNo} taskBcInfo.id={taskBcInfo.Id} seaExport.id={seaExport.Id} 请求BC对比订单结果完成耗时{timeDiff}ms是否成功{(compareResult?.succ == true ? "" : "")} ");
if (compareResult != null)
if (compareResult != null && compareResult?.succ == true)
{
logger.LogInformation($"批次={batchNo} BC对比订单结果={JsonConvert.SerializeObject(compareResult)}");
DateTime nowDate = DateTime.Now;
@ -1303,13 +1304,22 @@ namespace DS.WMS.Core.TaskPlat.Method
it.UpdateUserName
}).ExecuteCommandAsync();
}
return (compareResult.extra.IsExistsDiff, compareResult.extra.ShowDetailList);
return new CompareResultInfo()
{
IsExistsDiff = compareResult.extra.IsExistsDiff,
ShowDetailList = compareResult.extra.ShowDetailList,
DetailList = compareResult.extra.DetailList,
IsSuccess = true
};
//return (compareResult.extra.IsExistsDiff, compareResult.extra.ShowDetailList);
}
else
{
logger.LogError($"批次={batchNo} BC对比订单结果为空");
throw new Exception($"批次={batchNo} BC对比订单结果为空");
return new CompareResultInfo()
{
IsSuccess = false
};
}
}

Loading…
Cancel
Save