From 1366efbab53c89fdb5fbca271cf4ecf652176e1f Mon Sep 17 00:00:00 2001
From: wzp <2040239371@qq.com>
Date: 星期二, 25 十一月 2025 11:20:55 +0800
Subject: [PATCH] fix:优化了,屏蔽机号不再从数据库获取记录

---
 Rdream.Core/DataHandler/SendMsgByAccessControlRecord.cs |   37 ++++++++++++++++++++++++++++++++-----
 1 files changed, 32 insertions(+), 5 deletions(-)

diff --git a/Rdream.Core/DataHandler/SendMsgByAccessControlRecord.cs b/Rdream.Core/DataHandler/SendMsgByAccessControlRecord.cs
index cc121c0..15dbd8a 100644
--- a/Rdream.Core/DataHandler/SendMsgByAccessControlRecord.cs
+++ b/Rdream.Core/DataHandler/SendMsgByAccessControlRecord.cs
@@ -109,6 +109,7 @@
 
         //鏃堕棿娈靛強灞忚斀鏈哄彿
         public static string[] shieldDoor = System.Configuration.ConfigurationManager.AppSettings["shieldDoor"].Split(',');
+        public static string shieldDoorStr = System.Configuration.ConfigurationManager.AppSettings["shieldDoor"];
         public static string swichTime = System.Configuration.ConfigurationManager.AppSettings["swichTime"];
         //浜鸿劯鍥剧墖绗簩璺緞
         public static string[] FacePathDoor = System.Configuration.ConfigurationManager.AppSettings["FacePathDoor"].Split(',');
@@ -293,7 +294,14 @@
             {
                 sql += SQL_IF_One + timeDelay + SQL_IF_One_a + _seconds + SQL_IF_One_b;
             }
-            sql += SQL_Six + SQL_Seven + SQL_Eight + SQL_Nine;
+
+            //sql += SQL_Six + SQL_Seven + SQL_Eight + SQL_Nine;
+
+            //鐩存帴灞忚斀瀹胯垗鍙凤紝涓嶈幏鍙栧鑸嶇殑璁板綍
+            string sqlWhere = $" where aa.door_id not in({shieldDoorStr})";
+
+            sql += SQL_Six + SQL_Seven + SQL_Eight + sqlWhere + SQL_Nine;
+
             //log4netService.Debug("_seconds" + _seconds);
             //log4netService.Debug("sql锛�" + sql);
             //log4netService.Debug($"娴嬭瘯SQL={sql}");
@@ -353,10 +361,16 @@
                                 if (subDeviceId == dicDoorSwitch[doorIdTemp])
                                 {
                                     //鍓旈櫎灞忚斀鐨勮褰�
-                                    Console.WriteLine($"鍓旈櫎灞忚斀闂ㄧ{dt.Rows[i]["door_id"]}");
+                                    Console.WriteLine($"鍗曞悜闂ㄥ睆钄藉墧闄ゅ睆钄介棬绂亄dt.Rows[i]["door_id"]}");
                                     log4netService.Debug($"鍓旈櫎灞忚斀闂ㄧ{dt.Rows[i]["door_id"]}");
-                                    UpdateDataSycFlag(int.Parse(dt.Rows[i]["id"].ToString()), 2);
+                                    try
+                                    {
+                                        UpdateDataSycFlag(int.Parse(dt.Rows[i]["id"].ToString()), 2);
+
+                                    }
+                                    catch (Exception ex) { }
                                     dt.Rows[i].Delete();
+
                                     continue;
                                 }
                                 
@@ -374,10 +388,17 @@
                                 else
                                 {
                                     string str = $"鍥犳俯搴︽垨灞忚斀闂ㄧ杩囨护鏁版嵁ID锛歿dt.Rows[i]["id"]}";
-                                    UpdateDataSycFlag(Convert.ToInt32(dt.Rows[i]["id"]), 3);
                                     log4netService.Debug(str);
                                     Console.WriteLine(str);
+
+                                    try
+                                    {
+                                        UpdateDataSycFlag(Convert.ToInt32(dt.Rows[i]["id"]), 3);
+                                    }
+                                    catch(Exception ex) { }
                                     dt.Rows[i].Delete();
+
+
                                 }
                             }
                         }
@@ -386,8 +407,14 @@
                             //鍓旈櫎灞忚斀鐨勮褰�
                             Console.WriteLine($"鍓旈櫎灞忚斀闂ㄧ{dt.Rows[i]["door_id"]}");
                             log4netService.Debug($"鍓旈櫎灞忚斀闂ㄧ{dt.Rows[i]["door_id"]}");
-                            UpdateDataSycFlag(int.Parse(dt.Rows[i]["id"].ToString()), 2);
+
+                            try
+                            {
+                                UpdateDataSycFlag(int.Parse(dt.Rows[i]["id"].ToString()), 2);
+                            }
+                            catch (Exception ex) { }
                             dt.Rows[i].Delete();
+
                         }
                     }
                     catch (Exception ex)

--
Gitblit v1.9.1