From a0a1aa47bb780834c7647640039d8f2c4b9e3882 Mon Sep 17 00:00:00 2001
From: cKey <35512826+colinin@users.noreply.github.com>
Date: Tue, 5 Apr 2022 18:33:51 +0800
Subject: [PATCH] fix: add a node and tenant ID to a storage job

---
 .../LINGYUN/Abp/TaskManagement/BackgroundJobStore.cs          | 4 +++-
 .../Abp/WebhooksManagement/WebhookSendRecordAppService.cs     | 1 +
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/aspnet-core/modules/task-management/LINGYUN.Abp.TaskManagement.Domain/LINGYUN/Abp/TaskManagement/BackgroundJobStore.cs b/aspnet-core/modules/task-management/LINGYUN.Abp.TaskManagement.Domain/LINGYUN/Abp/TaskManagement/BackgroundJobStore.cs
index 8c6df46ab..2eb5ced5b 100644
--- a/aspnet-core/modules/task-management/LINGYUN.Abp.TaskManagement.Domain/LINGYUN/Abp/TaskManagement/BackgroundJobStore.cs
+++ b/aspnet-core/modules/task-management/LINGYUN.Abp.TaskManagement.Domain/LINGYUN/Abp/TaskManagement/BackgroundJobStore.cs
@@ -85,7 +85,9 @@ public class BackgroundJobStore : IJobStore, ITransientDependency
                     jobInfo.Priority,
                     jobInfo.Source,
                     jobInfo.MaxCount,
-                    jobInfo.MaxTryCount)
+                    jobInfo.MaxTryCount,
+                    jobInfo.NodeName,
+                    jobInfo.TenantId)
                 {
                     IsEnabled = true,
                     TriggerCount = jobInfo.TriggerCount,
diff --git a/aspnet-core/modules/webhooks/LINGYUN.Abp.WebhooksManagement.Application/LINGYUN/Abp/WebhooksManagement/WebhookSendRecordAppService.cs b/aspnet-core/modules/webhooks/LINGYUN.Abp.WebhooksManagement.Application/LINGYUN/Abp/WebhooksManagement/WebhookSendRecordAppService.cs
index 7e9dd6673..ce0e09429 100644
--- a/aspnet-core/modules/webhooks/LINGYUN.Abp.WebhooksManagement.Application/LINGYUN/Abp/WebhooksManagement/WebhookSendRecordAppService.cs
+++ b/aspnet-core/modules/webhooks/LINGYUN.Abp.WebhooksManagement.Application/LINGYUN/Abp/WebhooksManagement/WebhookSendRecordAppService.cs
@@ -78,6 +78,7 @@ public class WebhookSendRecordAppService : WebhooksManagementAppServiceBase, IWe
             Data = sendEvent.Data,
             Headers = subscription.GetWebhookHeaders(),
             Secret = subscription.Secret,
+            TryOnce = true,
         });
     }
 }