From 1164314b1f0183dadf760171e5a494eda53a1c95 Mon Sep 17 00:00:00 2001
From: 肖洋 <cathay_xy@163.com>
Date: 星期四, 09 一月 2025 19:59:56 +0800
Subject: [PATCH] 更新多个文件,增强请求处理和日志记录

---
 Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs |   36 +++++++++++++++++++++++++++++++++++-
 1 files changed, 35 insertions(+), 1 deletions(-)

diff --git a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs
index d6982b4..5c5bace 100644
--- a/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs
+++ b/Code Management/WCS/WIDESEAWCS_Server/WIDESEAWCS_Core/Helper/HttpHelper.cs
@@ -1,4 +1,6 @@
-锘縰sing System;
+锘縰sing AngleSharp.Dom;
+using Newtonsoft.Json;
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Net.Http.Headers;
@@ -37,10 +39,42 @@
             return null;
         }
 
+
+        // 鐢ㄤ簬杩借釜姣忎釜璇锋眰鐨勮皟鐢ㄦ鏁板拰鏈�鍚庤姹傛椂闂淬��
+        private static readonly Dictionary<string, (int Count, DateTime LastRequestTime)> requestTracker = new();
+
         public static async Task<string> PostAsync(string serviceAddress, string requestJson = null, string contentType = "application/json", Dictionary<string, string>? headers = null)
         {
             try
             {
+                // 灏� JSON 瀛楃涓茶浆鎹负瀛楀吀
+                var parameters = JsonConvert.DeserializeObject<Dictionary<string, object>>(requestJson);
+
+                // 鍒涘缓涓�涓柊鐨勫瓧鍏革紝鎺掗櫎 RequestTime 鍜� SessionId
+                var filteredParameters = parameters.Where(p => p.Key != "RequestTime" && p.Key != "SessionId").ToDictionary(p => p.Key, p => p.Value);
+
+                string requestKey = $"{serviceAddress}:{JsonConvert.SerializeObject(filteredParameters)}";
+
+                // 妫�鏌ヨ姹傛鏁板拰鏃堕棿闄愬埗
+                if (requestTracker.TryGetValue(requestKey, out var requestInfo))
+                {
+                    if (requestInfo.Count >= 5 && DateTime.Now < requestInfo.LastRequestTime.AddMinutes(10))
+                    {
+                        // 濡傛灉璇锋眰娆℃暟瓒呰繃闄愬埗涓旀湭瓒呰繃10鍒嗛挓锛屾姏鍑哄紓甯�
+                        throw new InvalidOperationException("璇锋眰娆℃暟宸茶揪鍒伴檺鍒讹紝璇风◢鍚庡啀璇曘��");
+                    }
+                }
+
+                // 鏇存柊璇锋眰璺熻釜淇℃伅
+                if (requestTracker.ContainsKey(requestKey))
+                {
+                    requestTracker[requestKey] = (requestInfo.Count + 1, DateTime.Now);
+                }
+                else
+                {
+                    requestTracker[requestKey] = (1, DateTime.Now);
+                }
+
                 string result = string.Empty;
                 using (HttpContent httpContent = new StringContent(requestJson))
                 {

--
Gitblit v1.9.3