检查静态数据与视图差额

performance/Performance.Services/DapperService.cs

@@ -39,17 +39,36 @@ public void FreezeAllotSync(int allotId)
         /// <returns></returns>
         public void FreezeAllot(int allotId)
         {
-            using (var connection = new MySqlConnection(_options.Value.PerformanceConnectionString))
+            try
             {
-                if (connection.State != ConnectionState.Open) connection.Open();
-                try
+                int i = 0;
+                do
+                {
+                    HanderFreeze(allotId);
+                    i++;
+                } while (QueryDiff(allotId) < -50 && i <= 3);
+            }
+            catch
+            {
+            }
+
+            void HanderFreeze(int allotId)
+            {
+                using (var connection = new MySqlConnection(_options.Value.PerformanceConnectionString))
                 {
+                    if (connection.State != ConnectionState.Open) connection.Open();
                     string sql = $@"call proc_freeze_allot({allotId})";
                     connection.Execute(sql, commandTimeout: 60 * 60);
                 }
-                catch (Exception)
+            }
+
+            decimal QueryDiff(int allotId)
+            {
+                using (var connection = new MySqlConnection(_options.Value.PerformanceConnectionString))
                 {
-                    throw;
+                    if (connection.State != ConnectionState.Open) connection.Open();
+                    string sql = $@"SELECT Diff FROM view_allot_result_diff WHERE AllotID = @allotId LIMIT 1";
+                    return connection.QuerySingle<decimal>(sql, new { allotId }, commandTimeout: 60 * 60);
                 }
             }
         }