From 28ceaf5bf5c6cb34d21af14d377a8c413af2a8ce Mon Sep 17 00:00:00 2001 From: toannm Date: Fri, 28 Feb 2025 11:27:39 +0700 Subject: [PATCH 1/2] =?UTF-8?q?B=E1=BB=95=20sung=20nodeurl?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- CloudSync/Process/GetKetQuaKCBPubSub.cs | 3 ++- CloudSync/Process/GetPhieuDonTiepPubSub.cs | 8 +++++--- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/CloudSync/Process/GetKetQuaKCBPubSub.cs b/CloudSync/Process/GetKetQuaKCBPubSub.cs index 5274bda..476c5fe 100644 --- a/CloudSync/Process/GetKetQuaKCBPubSub.cs +++ b/CloudSync/Process/GetKetQuaKCBPubSub.cs @@ -77,12 +77,13 @@ protected override async void Scan() logger.Info("0.1. Pulling ketqua kcb..."); var authToken = Config.FindValue("CloudToken"); var vLane = Config.GetValue("Lane"); + var sNodeCQS = Config.GetValue("urlCQSNode", ""); var apiMethodUrl = $"{apiCloudGetUrl}?msgToken={token}"; if (vLane.IsNotNullOrEmpty()) { apiMethodUrl += $"&lane={vLane}"; } - var vListResult = await apiMethodUrl.GetAsJson(authToken); + var vListResult = await apiMethodUrl.GetAsJson(authToken, sNodeCQS); if (vListResult != null) { logger.Info($"1.1. Pulled new result: data={JsonConvert.SerializeObject(vListResult)}"); diff --git a/CloudSync/Process/GetPhieuDonTiepPubSub.cs b/CloudSync/Process/GetPhieuDonTiepPubSub.cs index f1cb6b1..aa67572 100644 --- a/CloudSync/Process/GetPhieuDonTiepPubSub.cs +++ b/CloudSync/Process/GetPhieuDonTiepPubSub.cs @@ -9,7 +9,7 @@ namespace CloudSync.Process { - public class GetPhieuDonTiepPubSub: QueueJobProcess + public class GetPhieuDonTiepPubSub : QueueJobProcess { private string latestMessageToken = string.Empty; @@ -22,8 +22,9 @@ protected override void PostInitialize() // TODO: Cập nhật cấu hình CloudToken vào file cấu hình Config/GetPhieuDonTiepPubSub.json var authCloudToken = Config.FindValue("CloudToken"); var subChannel = Config.GetValue("Channel", "lichkham/pending"); + var sNodeCQS = Config.GetValue("urlCQSNode", ""); var infoToken = authCloudToken?.Substring(0, 6) ?? "NULL"; - if (authCloudToken is null || !PubSubHelper.Initialize(authCloudToken).Wait(10000)) + if (authCloudToken is null || !PubSubHelper.Initialize(authCloudToken, sNodeCQS).Wait(10000)) { logger.Error($"Cannot init Pubsub => Please verify CloudToken, token={infoToken}..."); return; @@ -76,12 +77,13 @@ protected override async void Scan() logger.Info("0.1. Pulling ketqua phieu don tiep..."); var authToken = Config.FindValue("CloudToken"); var vLane = Config.GetValue("Lane"); + var sNodeCQS = Config.GetValue("urlCQSNode", ""); var apiMethodUrl = $"{apiCloudGetUrl}?msgToken={token}"; if (vLane.IsNotNullOrEmpty()) { apiMethodUrl += $"&lane={vLane}"; } - var vListResult = await apiMethodUrl.GetAsJson(authToken); + var vListResult = await apiMethodUrl.GetAsJson(authToken, sNodeCQS); if (vListResult != null) { logger.Info($"1.1. Pulled new result: data={JsonConvert.SerializeObject(vListResult)}"); From fbc64594708568a326fc983d6668049727d43af8 Mon Sep 17 00:00:00 2001 From: toannm Date: Fri, 28 Feb 2025 11:28:01 +0700 Subject: [PATCH 2/2] =?UTF-8?q?B=E1=BB=95=20sung=20nodeurl?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- CloudSync/Config/GetPhieuDonTiepPubSub.json | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/CloudSync/Config/GetPhieuDonTiepPubSub.json b/CloudSync/Config/GetPhieuDonTiepPubSub.json index e843ec8..14c9741 100644 --- a/CloudSync/Config/GetPhieuDonTiepPubSub.json +++ b/CloudSync/Config/GetPhieuDonTiepPubSub.json @@ -6,5 +6,6 @@ "CloudGetUrl": "", "CloudToken": "", "Channel": "lichkham/pending", - "Lane": "" + "Lane": "", + "urlCQSNode": "" }