fix: 修复因数据库死锁导致过滤失效的问题

wzp

2024-09-30 4ae8b1c91036a89f7b8921921826e37e0df1a656

 Rdream.Core/DataHandler/SendMsgByAccessControlRecord.cs

@@ -296,7 +296,7 @@
            sql += SQL_Six + SQL_Seven + SQL_Eight + SQL_Nine;
            //log4netService.Debug("_seconds" + _seconds);
            //log4netService.Debug("sql：" + sql);
            log4netService.Debug($"测试SQL={sql}");
            //log4netService.Debug($"测试SQL={sql}");

            DataSet ds = da.ExecuteDataSet(System.Data.CommandType.Text, sql);
            DataTable dt = ds.Tables[0];
@@ -304,7 +304,7 @@
            AccessControlRecord accessControlRecord = new AccessControlRecord();


            log4netService.Debug($"总共获取{dt.Rows.Count},SQL={sql}");
            //log4netService.Debug($"总共获取{dt.Rows.Count},SQL={sql}");


            //Console.WriteLine("待处理记录数：" + dt.Rows.Count);
@@ -353,10 +353,11 @@
                                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);
                                    dt.Rows[i].Delete();
                                    UpdateDataSycFlag(int.Parse(dt.Rows[i]["id"].ToString()), 2);

                                    continue;
                                }
                                
@@ -374,10 +375,12 @@
                                else
                                {
                                    string str = $"因温度或屏蔽门禁过滤数据ID：{dt.Rows[i]["id"]}";
                                    UpdateDataSycFlag(Convert.ToInt32(dt.Rows[i]["id"]), 3);
                                    log4netService.Debug(str);
                                    Console.WriteLine(str);
                                    dt.Rows[i].Delete();

                                    UpdateDataSycFlag(Convert.ToInt32(dt.Rows[i]["id"]), 3);

                                }
                            }
                        }
@@ -386,8 +389,9 @@
                            //剔除屏蔽的记录
                            Console.WriteLine($"剔除屏蔽门禁{dt.Rows[i]["door_id"]}");
                            log4netService.Debug($"剔除屏蔽门禁{dt.Rows[i]["door_id"]}");
                            UpdateDataSycFlag(int.Parse(dt.Rows[i]["id"].ToString()), 2);
                            
                            dt.Rows[i].Delete();
                            UpdateDataSycFlag(int.Parse(dt.Rows[i]["id"].ToString()), 2);
                        }
                    }
                    catch (Exception ex)