소스 검색

关数据,该模型

lichunlei 2 년 전
부모
커밋
3deaa886bb
2개의 변경된 파일4개의 추가작업 그리고 4개의 파일을 삭제
  1. 1 1
      AppStart/Helper/StatService.cs
  2. 3 3
      Startup.cs

+ 1 - 1
AppStart/Helper/StatService.cs

@@ -312,7 +312,7 @@ namespace MySystem
                                 statData.Add("TradeAmount", TradeAmount);
                                 statData.Add("TradeCount", TradeCount);
                                 RedisDbconn.Instance.AddList("StatTradeAmountQueue", Newtonsoft.Json.JsonConvert.SerializeObject(statData));
-                                RedisDbconn.Instance.AddList("ProfitTradeAmountQueue", Newtonsoft.Json.JsonConvert.SerializeObject(statData));
+                                // RedisDbconn.Instance.AddList("ProfitTradeAmountQueue", Newtonsoft.Json.JsonConvert.SerializeObject(statData));
                             }
                             OtherMySqlConn.op("update TradeRecord set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
                             if(Id == 0)

+ 3 - 3
Startup.cs

@@ -58,11 +58,11 @@ namespace MySystem
             MySystemLib.SystemPublicFuction.appcheck = "success";
             string conn = Configuration["Setting:SqlConnStr"];
             Dictionary<string, Dictionary<string, string>> tables = new Dictionary<string, Dictionary<string, string>>();
-            System.Data.DataTable tablecollection = Library.CustomerSqlConn.dtable("select DISTINCT TABLE_NAME from information_schema.columns where table_schema = 'KxsMainServer'", conn);
+            System.Data.DataTable tablecollection = Library.CustomerSqlConn.dtable("select DISTINCT TABLE_NAME from information_schema.columns where table_schema = 'KxsProfitServer'", conn);
             foreach (System.Data.DataRow subtable in tablecollection.Rows)
             {
                 Dictionary<string, string> Columns = new Dictionary<string, string>();
-                System.Data.DataTable columncollection = Library.CustomerSqlConn.dtable("select COLUMN_NAME,DATA_TYPE from information_schema.columns where table_schema = 'KxsMainServer' and TABLE_NAME='" + subtable["TABLE_NAME"].ToString() + "'", conn);
+                System.Data.DataTable columncollection = Library.CustomerSqlConn.dtable("select COLUMN_NAME,DATA_TYPE from information_schema.columns where table_schema = 'KxsProfitServer' and TABLE_NAME='" + subtable["TABLE_NAME"].ToString() + "'", conn);
                 foreach (System.Data.DataRow column in columncollection.Rows)
                 {
                     string datatype = column["DATA_TYPE"].ToString();
@@ -136,7 +136,7 @@ namespace MySystem
 
             StatNewService.Instance.CreateTable(); //创建RDS分表
             
-            ProfitService.Instance.AddRds(); //补RDS数据
+            // ProfitService.Instance.AddRds(); //补RDS数据
             //必须打开的
 
         }