From d5dd90abc1548d52bf16ad0da53e1a78b02a3217 Mon Sep 17 00:00:00 2001
From: xxyy <cathay_xy@163.com>
Date: 星期五, 28 二月 2025 16:48:49 +0800
Subject: [PATCH] 添加请求跟踪功能和设备过滤条件

---
 Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs |   25 ++++++++++++++++++++++++-
 1 files changed, 24 insertions(+), 1 deletions(-)

diff --git a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
index 9f55a56..1b10faa 100644
--- a/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
+++ b/Code Management/WMS/WIDESEA_WMSServer/WIDESEA_StorageTaskServices/Task/Partial/Dt_TaskService.cs
@@ -975,6 +975,9 @@
 
     #region  甯告俯3鍑哄簱鑷冲寘瑁�
 
+    // 鐢ㄤ簬杩借釜姣忎釜璇锋眰鐨勮皟鐢ㄦ鏁板拰鏈�鍚庤姹傛椂闂淬��
+    private static readonly Dictionary<string, (int Count, DateTime LastRequestTime)> requestTracker = new();
+
     /// <summary>
     /// 甯告俯3鍑哄簱鑷冲寘瑁�
     /// </summary>
@@ -985,6 +988,26 @@
         WebResponseContent content = new WebResponseContent();
         try
         {
+            string requestKey = JsonConvert.SerializeObject(json);
+            // 妫�鏌ヨ姹傛鏁板拰鏃堕棿闄愬埗
+            if (requestTracker.TryGetValue(requestKey, out var requestInfo))
+            {
+                if (requestInfo.Count >= 9 && DateTime.Now < requestInfo.LastRequestTime.AddMinutes(5))
+                {
+                    // 濡傛灉璇锋眰娆℃暟瓒呰繃闄愬埗涓旀湭瓒呰繃10鍒嗛挓锛屾姏鍑哄紓甯�
+                    throw new InvalidOperationException("璇锋眰娆℃暟宸茶揪鍒伴檺鍒讹紝璇风◢鍚庡啀璇曘��");
+                }
+            }
+
+            // 鏇存柊璇锋眰璺熻釜淇℃伅
+            if (requestTracker.ContainsKey(requestKey))
+            {
+                requestTracker[requestKey] = (requestInfo.Count + 1, DateTime.Now);
+            }
+            else
+            {
+                requestTracker[requestKey] = (1, DateTime.Now);
+            }
             //LogFactory.GetLog("甯告俯3鍑哄簱鑷冲寘瑁�").Info(true, $"甯告俯3鍑哄簱鑷冲寘瑁呬紶鍏ュ弬鏁帮細" + JsonConvert.SerializeObject(json, Formatting.Indented));
 
             Dt_StationManager station = _stationManagerRepository.QueryFirst(x => x.stationChildCode == json.Position && x.stationType == 12 && x.stationArea == "Call");
@@ -992,7 +1015,7 @@
 
             var devices = SqlSugarHelper.DbWCS.Queryable<Dt_DeviceInfo>()
                 .Where(x => x.DeviceStatus == "1")
-                .Where(x => x.DeviceCode.Contains("CWSC"))
+                .Where(x => x.DeviceCode.Contains("CWSC")) // 杩囨护鏉′欢
                 .ToList();
             var deviceCode = devices.Select(x => x.DeviceCode).ToList();
 

--
Gitblit v1.9.3