|
|
|
@ -121,27 +121,21 @@ namespace DS.WMS.Core.Op.Method
|
|
|
|
|
var info = await tenantDb.Queryable<SeaExport>().Where(x => x.Id == callback.BusinessId).FirstAsync();
|
|
|
|
|
if (info.IsNull())
|
|
|
|
|
return await Task.FromResult(DataResult.Failed("不存在的海运出口信息!", MultiLanguageConst.SeaExportExist));
|
|
|
|
|
|
|
|
|
|
if (callback.FlowStatus == FlowStatusEnum.Approve)
|
|
|
|
|
{
|
|
|
|
|
await seaComService.SetGoodsStatus("YSTC", callback.BusinessId, tenantDb);
|
|
|
|
|
//是否发起退舱确认任务
|
|
|
|
|
|
|
|
|
|
var oldOrder = info.Adapt<SeaExport>();
|
|
|
|
|
|
|
|
|
|
info.IsRefund = callback.FlowStatus == FlowStatusEnum.Approve ? true : false;
|
|
|
|
|
int rows = await tenantDb.Updateable(info).UpdateColumns(x => new
|
|
|
|
|
{
|
|
|
|
|
x.IsRefund,
|
|
|
|
|
}).ExecuteCommandAsync();
|
|
|
|
|
|
|
|
|
|
await seaComService.SetGoodsStatus("YTC", callback.BusinessId, tenantDb);
|
|
|
|
|
|
|
|
|
|
await seaComService.SaveSeaExportLogAsync(new SeaExportSaveLog()
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
OperateType = "Update",
|
|
|
|
|
OldOrder = oldOrder,
|
|
|
|
|
NewOrder = info,
|
|
|
|
|
SourceCode = "RefundAuditCallbackAsync",
|
|
|
|
|
SourceName = "退仓审核完成回调",
|
|
|
|
|
}, tenantDb);
|
|
|
|
|
await seaComService.SetGoodsStatus("TCBH", callback.BusinessId, tenantDb);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return DataResult.Success;
|
|
|
|
|
|
|
|
|
|
return rows > 0 ? DataResult.Success : DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed));
|
|
|
|
|
//return rows > 0 ? DataResult.Success : DataResult.FailedWithDesc(nameof(MultiLanguageConst.Operation_Failed));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|