重置交易读取从只读

AppStart/Helper/StatResetService.cs

@@ -65,7 +65,7 @@ namespace MySystem
                 while(op)
                 {
                     string sql = "select Id from TradeRecord where Id>" + startId + " and CreateDate>='" + TradeDate + " 00:00:00' and CreateDate<='" + TradeDate + " 23:59:59' and BrandId in (" + BrandId + ") order by Id limit 50";
-                    DataTable idsDt = CustomerSqlConn.dtable(sql, AppConfig.Base.SqlConn);
+                    DataTable idsDt = CustomerSqlConn.dtable(sql, AppConfig.Base.TmpReadSqlConn);
                     if(idsDt.Rows.Count > 0)
                     {
                         string ids = "";
@@ -74,7 +74,7 @@ namespace MySystem
                             ids += idsDr["Id"].ToString() + ",";
                             startId = idsDr["Id"].ToString();
                         }
-                        DataTable selfDt = CustomerSqlConn.dtable("select UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,Version,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount),count(Id),SnNo from TradeRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,Version,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d'),SnNo", AppConfig.Base.SqlConn);
+                        DataTable selfDt = CustomerSqlConn.dtable("select UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,Version,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount),count(Id),SnNo from TradeRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,Version,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d'),SnNo", AppConfig.Base.TmpReadSqlConn);
                         if (selfDt.Rows.Count > 0)
                         {
                             function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "重置创客交易额日志");

Config/Base.cs

@@ -5,7 +5,7 @@ namespace AppConfig
 {
     public class Base
     {
-        public static string TmpReadSqlConn = "server=rr-2vc53lrwpwm1ewscogo.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsProfitServer;charset=utf8;";
+        public static string TmpReadSqlConn = Library.ConfigurationManager.AppSettings["ReadSqlConnStr"].ToString();
         public static string SqlConn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
         public static string SpSqlConn = Library.ConfigurationManager.AppSettings["SpSqlConnStr"].ToString();
         public static string StatSqlConn = Library.ConfigurationManager.AppSettings["StatSqlConnStr"].ToString();

Controllers/HomeController.cs

@@ -67,11 +67,10 @@ namespace MySystem.Controllers
             return result;
         }
 
-        public string test(int UserId, decimal Amount)
+        public string test()
         {
             string result = "ok";
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12\",\"TradeDate\":\"2024-02-01\"}");
-            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"13,15\",\"TradeDate\":\"2024-02-01\"}");
+            RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-01\"}");
             RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-02\"}");
             RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-03\"}");
             RedisDbconn.Instance.AddList("StatResetUserTradeQueue", "{\"BrandId\":\"12,13,15\",\"TradeDate\":\"2024-02-04\"}");

appsettings.Development.json

@@ -18,6 +18,7 @@
     "SourceHost": "http://bs.kexiaoshuang.com/",
     "Database": "KxsMainServer",
     "SqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=FrW8ZfxlcaVdm1r0;database=KxsMainServer;charset=utf8;",
+    "ReadSqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=FrW8ZfxlcaVdm1r0;database=KxsMainServer;charset=utf8;",
     "StatSqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=FrW8ZfxlcaVdm1r0;database=KxsStatServer;charset=utf8;",
     "ProfitSqlConnStr": "server=47.109.31.237;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsProfitServer;charset=utf8;",
     "OpSqlConnStr": "server=47.109.31.237;port=3306;user=KxsOpServer;password=r7jwZ8ydLoeswDR4;database=KxsOpServer;charset=utf8;",

appsettings.json

@@ -18,6 +18,7 @@
     "SourceHost": "http://bs.kexiaoshuang.com/",
     "Database": "KxsMainServer",
     "SqlConnStr": "server=rm-2vcs4j67tla603c9d5o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsProfitServer;charset=utf8;",
+    "ReadSqlConnStr": "server=rr-2vc53lrwpwm1ewscogo.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsProfitServer;charset=utf8;DefaultCommandTimeout=600;",
     "OpSqlConnStr": "server=rm-2vcs4j67tla603c9d5o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsProfitServer;password=FrW8ZfxlcaVdm1r0;database=KxsOpServer;charset=utf8;",
     "SpSqlConnStr": "server=47.108.229.115;port=3306;user=KxsSpServer;password=jJ9qKsvwWgQA9xWG;database=KxsSpServer;charset=utf8;",
     "StatSqlConnStr": "server=rm-2vc27k81v217qs1t55o.mysql.cn-chengdu.rds.aliyuncs.com;port=3306;user=KxsStatServer;password=mzeqjriUWore0dwT;database=KxsStatServer;charset=utf8;",