Sfoglia il codice sorgente

统计创客当月交易保持和首页一致

lcl 11 mesi fa
parent
commit
66f8c3f165
2 ha cambiato i file con 60 aggiunte e 4 eliminazioni
  1. 58 4
      AppStart/Helper/StatService.cs
  2. 2 0
      Config/MysqlConn.cs

+ 58 - 4
AppStart/Helper/StatService.cs

@@ -1843,9 +1843,11 @@ namespace MySystem
         public void StartEverDay(string date)
         {
             string TradeMonth = DateTime.Now.ToString("yyyyMM");
+            string PreMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
             if(DateTime.Now.Day == 1)
             {
                 TradeMonth = DateTime.Now.AddMonths(-1).ToString("yyyyMM");
+                PreMonth = DateTime.Now.AddMonths(-2).ToString("yyyyMM");
             }
             else if(DateTime.Now.Day == 2)
             {
@@ -1887,6 +1889,62 @@ namespace MySystem
                     dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
                 }
             }
+            list = CustomerSqlConn.dtable("select UserId,sum(TotalAmount) from UserAmountSummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.MpSqlConnStr);
+            foreach (DataRow dr in list.Rows)
+            {
+                string UserId = dr["UserId"].ToString();
+                string ThisMonthTrade = dr[1].ToString();
+                if(dic.ContainsKey(UserId))
+                {
+                    dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
+                }
+                else
+                {
+                    dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
+                }
+            }
+            list = CustomerSqlConn.dtable("select UserId,sum(TotalAmount) from UserAmountSummary where TradeMonth='" + TradeMonth + "' and SeoTitle='team' and UserId>0 group by UserId", MysqlConn.MpSqlConnStr2);
+            foreach (DataRow dr in list.Rows)
+            {
+                string UserId = dr["UserId"].ToString();
+                string ThisMonthTrade = dr[1].ToString();
+                if(dic.ContainsKey(UserId))
+                {
+                    dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
+                }
+                else
+                {
+                    dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
+                }
+            }
+            list = CustomerSqlConn.dtable("select UserId,SimValidActTeamCount*10000 from SimValidAct" + PreMonth + " where UserId>0", MysqlConn.StatSqlConnStr);
+            foreach (DataRow dr in list.Rows)
+            {
+                string UserId = dr["UserId"].ToString();
+                string ThisMonthTrade = dr[1].ToString();
+                if(dic.ContainsKey(UserId))
+                {
+                    dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
+                }
+                else
+                {
+                    dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
+                }
+            }
+            list = CustomerSqlConn.dtable("select UserId,sum(TradeAmount) from HelpProfitUserTradeSummay where UserId>0 and TradeMonth='" + TradeMonth + "' and SeoTitle='team' group by UserId", MysqlConn.ReadSqlConnStr);
+            foreach (DataRow dr in list.Rows)
+            {
+                string UserId = dr["UserId"].ToString();
+                string ThisMonthTrade = dr[1].ToString();
+                if(dic.ContainsKey(UserId))
+                {
+                    dic[UserId] += decimal.Parse(function.CheckNum(ThisMonthTrade));
+                }
+                else
+                {
+                    dic.Add(UserId, decimal.Parse(function.CheckNum(ThisMonthTrade)));
+                }
+            }
 
             int index = 0;
             string sql = "";
@@ -1905,10 +1963,6 @@ namespace MySystem
             {
                 CustomerSqlConn.op(sql, MysqlConn.SqlConnStr);
             }
-
-            // Thread th = new Thread(StatTradeAmountEverDay);
-            // th.IsBackground = true;
-            // th.Start(date);
         }
         public void StatTradeAmountEverDay(object sender)
         {

+ 2 - 0
Config/MysqlConn.cs

@@ -9,6 +9,8 @@ namespace MySystem
         public static string OpSqlConnStr = ConfigurationManager.AppSettings["OpSqlConnStr"].ToString();
         public static string RdsStatSqlConnStr = ConfigurationManager.AppSettings["RdsStatSqlConnStr"].ToString();
         public static string StatSqlConnStr = ConfigurationManager.AppSettings["MainSqlConnStr"].ToString();
+        public static string MpSqlConnStr = ConfigurationManager.AppSettings["MpSqlConnStr"].ToString();
+        public static string MpSqlConnStr2 = ConfigurationManager.AppSettings["MpSqlConnStr2"].ToString();
 
         
     }