Fix a bug

修复空房太多会造成卡死的问题

Author: hyperzlib

HousingCheck/HousingCheck.cs

@@ -144,10 +144,8 @@ string HousingListToJson()
                 );
         }
 
-        void NetworkReceived(string connection, long epoch, byte[] message)
+        void NetworkReceivedSync(byte[] message)
         {
-            var opcode = BitConverter.ToUInt16(message, 18);
-            if (opcode != 0x164 && message.Length != 2440) return;
             HousingSlotSnapshot snapshot;
             try
             {
@@ -161,23 +159,22 @@ void NetworkReceived(string connection, long epoch, byte[] message)
                 //存入存储
                 SnapshotStorage.Insert(snapshot);
                 AutoUploadSnapshot[new Tuple<HouseArea, int>(snapshot.Area, snapshot.Slot)] = snapshot;
-                
-                foreach(HousingOnSaleItem item in HousingList)
+
+                foreach (HousingOnSaleItem item in HousingList)
                 {
-                    if(item.Area == snapshot.Area && item.Slot == snapshot.Slot)
+                    if (item.Area == snapshot.Area && item.Slot == snapshot.Slot)
                     {
                         item.CurrentStatus = false;
                     }
                 }
 
                 HousingItem[] onSaleList = snapshot.GetOnSale();
 
-                Monitor.Enter(this);
                 foreach (var item in HousingList)
                 {
                     if (item.Area == snapshot.Area && item.Slot == snapshot.Slot)
                     {
-                        if(onSaleList.Where(x => x.Slot == item.Slot && x.IsEmpty)
+                        if (onSaleList.Where(x => x.Slot == item.Slot && x.IsEmpty)
                             .ToArray().Length == 0)
                         {
                             //空房已消失
@@ -187,7 +184,7 @@ void NetworkReceived(string connection, long epoch, byte[] message)
                             {
                                 bindingSource1.ResetItem(HousingList.IndexOf(item));
                             }
-                            catch(Exception ex)
+                            catch (Exception ex)
                             {
                                 Log("Error", ex, "刷新列表出错：");
                             }
@@ -197,7 +194,7 @@ void NetworkReceived(string connection, long epoch, byte[] message)
 
                 int listIndex;
                 //更新空房列表
-                foreach(HousingItem house in onSaleList)
+                foreach (HousingItem house in onSaleList)
                 {
                     HousingOnSaleItem onSaleItem = new HousingOnSaleItem(house);
                     Log("Info", string.Format("{0} 第{1}区 {2}号 {3}房在售 当前价格: {4}",
@@ -225,7 +222,6 @@ void NetworkReceived(string connection, long epoch, byte[] message)
                 Log("Info", string.Format("{0} 第{1}区查询完成",
                     HousingItem.GetHouseAreaStr(snapshot.Area),
                     snapshot.Slot + 1));     //输出翻页日志
-                Monitor.Exit(this);
             }
             catch (Exception ex)
             {
@@ -234,6 +230,14 @@ void NetworkReceived(string connection, long epoch, byte[] message)
             }
         }
 
+        void NetworkReceived(string connection, long epoch, byte[] message)
+        {
+            var opcode = BitConverter.ToUInt16(message, 18);
+            if (opcode != 0x164 && message.Length != 2440) return;
+
+            control.Invoke(new Action<byte[]>(NetworkReceivedSync), message);
+        }
+
         private void ButtonUploadOnce_Click(object sender, EventArgs e)
         {
             Log("Info", $"准备上报");

HousingCheck/Properties/AssemblyInfo.cs

@@ -32,5 +32,5 @@
 // You can specify all the values or you can default the Build and Revision Numbers
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("1.3.5.0")]
-[assembly: AssemblyFileVersion("1.3.5.0")]
+[assembly: AssemblyVersion("1.3.7.0")]
+[assembly: AssemblyFileVersion("1.3.7.0")]