更改数据库连接源

统计仓库激活数

AppStart/Helper/StatService.cs

@@ -35,12 +35,12 @@ namespace MySystem
                 {
                     StatTradeAmountEverDayV2();
                 }
-                Thread.Sleep(100);
+                Thread.Sleep(30000);
             }
         }
         public void StatTradeAmountEverDayV2()
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行交易额V2日志");
             WebCMSEntities db = new WebCMSEntities();
             using (var tran = db.Database.BeginTransaction())
@@ -50,7 +50,7 @@ namespace MySystem
                     string startId = function.ReadInstance("/TradeRecord/Id.txt");
                     if(string.IsNullOrEmpty(startId))
                     {
-                        startId = "718574";
+                        startId = "867041";
                     }
                     DataTable idsDt = OtherMySqlConn.dtable("select Id from TradeRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
                     if(idsDt.Rows.Count > 0)
@@ -64,7 +64,7 @@ namespace MySystem
                         DataTable selfDt = OtherMySqlConn.dtable("select UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(TradeAmount),count(Id) from TradeRecord where Id in (" + ids.TrimEnd(',') + ") group by UserId,ParentNav,BrandId,BankCardType,QrPayFlag,MerHelpFlag,CapFlag,VipFlag,PayType,DATE_FORMAT(CreateDate,'%Y%m%d')");
                         if (selfDt.Rows.Count > 0)
                         {
-                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时交易额V2日志");
+                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "实时执行交易额V2日志");
                             foreach (DataRow selfDr in selfDt.Rows)
                             {
                                 int UserId = int.Parse(selfDr["UserId"].ToString());
@@ -208,7 +208,7 @@ namespace MySystem
         // 每天统计头一天的交易额
         public void StartEverDay(string date)
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             // DateTime end = DateTime.Parse("2022-04-19 00:00:00");
             // DateTime check = DateTime.Parse("2022-03-11");
             // while (check <= end)
@@ -367,7 +367,7 @@ namespace MySystem
         public void StatTradeAmountEverDaySum()
         {
             // WebCMSEntities db = new WebCMSEntities();
-            // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             // DataTable dt = OtherMySqlConn.dtable("select UserId,BrandId,QueryCount,TradeDate,TradeMonth,sum(DirectDebitTradeAmt) as DirectDebitTradeAmt,sum(DirectTradeAmt) as DirectTradeAmt,sum(NonDirectDebitTradeAmt) as NonDirectDebitTradeAmt,sum(NonDirectTradeAmt) as NonDirectTradeAmt from UserTradeDaySummary group by UserId,BrandId,QueryCount,TradeDate,TradeMonth order by UserId,BrandId,QueryCount");
             // string html = "<table>";
             // foreach (DataRow dr in dt.Rows)
@@ -480,7 +480,7 @@ namespace MySystem
                 {
                     StartPosActNumEverTime();
                 }
-                Thread.Sleep(100);
+                Thread.Sleep(120000);
             }
         }
         public void StartPosActNumDo(object sender)
@@ -577,12 +577,12 @@ namespace MySystem
         }
         public void StartPosActNumEverTime()
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行创客激活数日志");
             WebCMSEntities db = new WebCMSEntities();
             try
             {
-                DataTable idsDt = OtherMySqlConn.dtable("select Id from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime is not null and BuyUserId>0 limit 50");
+                DataTable idsDt = OtherMySqlConn.dtable("select Id from PosMachinesTwo where QueryCount=0 and ActivationState=1 and ActivationTime is not null and ActivationTime>='2022-06-01 00:00:00' and BuyUserId>0 limit 50");
                 if(idsDt.Rows.Count > 0)
                 {
                     string ids = "";
@@ -590,16 +590,17 @@ namespace MySystem
                     {
                         ids += idsDr["Id"].ToString() + ",";
                     }
-                    DataTable userDt = OtherMySqlConn.dtable("select BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d'),count(Id) from PosMachinesTwo where Id in (" + ids.TrimEnd(',') + ") group by BuyUserId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d')");
+                    DataTable userDt = OtherMySqlConn.dtable("select BuyUserId,StoreId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d'),count(Id) from PosMachinesTwo where Id in (" + ids.TrimEnd(',') + ") group by BuyUserId,StoreId,BrandId,DATE_FORMAT(ActivationTime, '%Y%m%d')");
                     if (userDt.Rows.Count > 0)
                     {
                         function.WriteLog("人数:" + userDt.Rows.Count + "\n\n", "实时执行创客激活数日志");
                         foreach (DataRow userDr in userDt.Rows)
                         {
                             int UserId = int.Parse(userDr["BuyUserId"].ToString());
+                            int StoreId = int.Parse(userDr["StoreId"].ToString());
                             int BrandId = int.Parse(userDr["BrandId"].ToString());
-                            string TradeDate = userDr[2].ToString();
-                            int ActCount = int.Parse(function.CheckInt(userDr[3].ToString()));
+                            string TradeDate = userDr[3].ToString();
+                            int ActCount = int.Parse(function.CheckInt(userDr[4].ToString()));
                             int QrPayFlag = 0;
                             string TradeMonth = TradeDate.Substring(0, 6);
                             string date = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2);
@@ -646,6 +647,21 @@ namespace MySystem
                                     teamStat.ActiveBuddyMerStatus += ActCount;
                                 }
                             }
+
+                            //统计分仓激活数
+                            StoreSnActivateSummary storeStat = db.StoreSnActivateSummary.FirstOrDefault(m => m.StoreId == StoreId && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.BrandId == BrandId);
+                            if (storeStat == null)
+                            {
+                                storeStat = db.StoreSnActivateSummary.Add(new StoreSnActivateSummary()
+                                {
+                                    StoreId = StoreId,
+                                    TradeMonth = TradeMonth,
+                                    TradeDate = TradeDate,
+                                    BrandId = BrandId,
+                                }).Entity;
+                                db.SaveChanges();
+                            }
+                            storeStat.ActivateNum += ActCount;
                         }
                         db.SaveChanges();
                         OtherMySqlConn.op("update PosMachinesTwo set QueryCount=1 where Id in (" + ids.TrimEnd(',') + ")");
@@ -687,7 +703,7 @@ namespace MySystem
         }
         public void StartNewUserNumDo(object sender)
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             string date = sender.ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行新增创客数日志");
             WebCMSEntities db = new WebCMSEntities();
@@ -772,7 +788,7 @@ namespace MySystem
         }
         public void StartNewUserNumEverTime()
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行新增创客数日志");
             WebCMSEntities db = new WebCMSEntities();
             try
@@ -879,7 +895,7 @@ namespace MySystem
         }
         public void StatProfitEverDay(object sender)
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             string date = sender.ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "执行昨天收益日志");
             WebCMSEntities db = new WebCMSEntities();
@@ -978,7 +994,7 @@ namespace MySystem
 
         public void StatProfitEverDayEverTime()
         {
-            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时统计收益日志");
             WebCMSEntities db = new WebCMSEntities();
             try

PxcModels/WebCMSEntities.cs

@@ -217,7 +217,7 @@ namespace MySystem.PxcModels
         {
             if (!optionsBuilder.IsConfigured)
             {
-                optionsBuilder.UseMySql(Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString(), x => x.ServerVersion("5.7.17-mysql"));
+                optionsBuilder.UseMySql(Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString(), x => x.ServerVersion("5.7.17-mysql"));
             }
         }
 

appsettings.json

@@ -17,7 +17,7 @@
     "Host": "http://localhost:5047/",
     "SourceHost": "http://bs.kexiaoshuang.com/",
     "Database": "KxsMainServer",
-    "Pxc1SqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=Rw2imhXQQt5ODWIF;database=KxsMainServer;charset=utf8;",
+    "SqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=Rw2imhXQQt5ODWIF;database=KxsMainServer;charset=utf8;",
     "IOSAppVersion": "1.0.0",
     "AndroidAppVersion": "1.0.0",
     "OSSKey": "iL9dWgBunZRwGbHQ",