BC任务调整

usertest
zhangxiaofeng 3 months ago
parent 01e90ad7cd
commit f7900df6e7

@ -37,6 +37,12 @@ namespace DS.Module.Core
/// <remarks>类型DS.WMS.Core.TaskPlat.Entity.TaskBCCTNInfo</remarks> /// <remarks>类型DS.WMS.Core.TaskPlat.Entity.TaskBCCTNInfo</remarks>
public const string TaskBCCtnList = "TaskBCCtnList"; public const string TaskBCCtnList = "TaskBCCtnList";
/// <summary>
/// BC对比订单后是否存在差异
/// </summary>
/// <remarks>类型:<see cref="bool" /></remarks>
public const string BcCompareBcWithSeaExportIsExistsDiff = "BcCompareBcWithSeaExportIsExistsDiff";
/// <summary> /// <summary>
/// BC文件 /// BC文件
/// </summary> /// </summary>

@ -823,10 +823,10 @@ namespace DS.WMS.Core.Op.Method
throw new ArgumentNullException($"缺少参数:{TaskFlowDataNameConst.TaskManageOrderMessageInfo}"); throw new ArgumentNullException($"缺少参数:{TaskFlowDataNameConst.TaskManageOrderMessageInfo}");
} }
var taskBcId = dataContext.Get<long?>(TaskFlowDataNameConst.TaskBCId); var taskBcInfo = dataContext.Get<TaskBCInfo>(TaskFlowDataNameConst.TaskBCInfo);
if (taskBcId == null) if (taskBcInfo == null)
{ {
Logger.Log(NLog.LogLevel.Info, $"执行ApiReceiveTask时未获取到{TaskFlowDataNameConst.TaskBCId}"); Logger.Log(NLog.LogLevel.Info, $"执行ApiReceiveTask时未获取到{TaskFlowDataNameConst.TaskBCInfo}");
} }
DynameFileInfo bcFileInfo = null; DynameFileInfo bcFileInfo = null;
@ -935,10 +935,10 @@ namespace DS.WMS.Core.Op.Method
var rlt = await InnerApiReceive(slotModel, bcFileInfo, bcNoticeFileInfo); var rlt = await InnerApiReceive(slotModel, bcFileInfo, bcNoticeFileInfo);
// 回写舱位主键到BC任务 // 回写舱位主键到BC任务
if (rlt.Succeeded && rlt.Data != null && taskBcId != null) if (rlt.Succeeded && rlt.Data != null && taskBcInfo != null)
{ {
var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var tenantDb = saasService.GetBizDbScopeById(user.TenantId);
var taskBcInfo = await tenantDb.Queryable<TaskBCInfo>().Where(x => x.Id == taskBcId).FirstAsync(); //var taskBcInfo = await tenantDb.Queryable<TaskBCInfo>().Where(x => x.Id == taskBcId).FirstAsync();
if (taskBcInfo != null) if (taskBcInfo != null)
{ {
if(taskBcInfo.BOOKING_SLOT_ID == null) if(taskBcInfo.BOOKING_SLOT_ID == null)

@ -1158,7 +1158,10 @@ namespace DS.WMS.Core.TaskPlat.Method
SeaExport = seaExport, SeaExport = seaExport,
OpCtnList = seaExportCtnList OpCtnList = seaExportCtnList
}; };
var result = await CompareBcWithSeaExport(compareDto); (bool isExistsDiff, List<CompareResultDetailInfo>) result = await CompareBcWithSeaExport(compareDto);
dataContext.Set(TaskFlowDataNameConst.BcCompareBcWithSeaExportIsExistsDiff, result.isExistsDiff);
return DataResult<(bool isExistsDiff, List<CompareResultDetailInfo>)>.Success(result); return DataResult<(bool isExistsDiff, List<CompareResultDetailInfo>)>.Success(result);
} }

@ -953,7 +953,8 @@ namespace DS.WMS.Core.TaskPlat.Method
(TaskFlowDataNameConst.TaskManageOrderMessageInfo, info), (TaskFlowDataNameConst.TaskManageOrderMessageInfo, info),
(TaskFlowDataNameConst.BCFile, file), (TaskFlowDataNameConst.BCFile, file),
(TaskFlowDataNameConst.AmendmentFile, modifyFile), (TaskFlowDataNameConst.AmendmentFile, modifyFile),
(TaskFlowDataNameConst.TaskBCId, bcInfo.Id), (TaskFlowDataNameConst.TaskBaseId, taskInfo.Id),
//(TaskFlowDataNameConst.TaskBCId, bcInfo.Id),
(TaskFlowDataNameConst.TaskBCInfo, bcInfo), (TaskFlowDataNameConst.TaskBCInfo, bcInfo),
(TaskFlowDataNameConst.TaskBCCtnList, ctnList) (TaskFlowDataNameConst.TaskBCCtnList, ctnList)
); );

Loading…
Cancel
Save