统计商户交易额打日志

AppStart/Helper/StatService.cs

@@ -147,6 +147,7 @@ namespace MySystem
                                 db.SaveChanges();
 
                                 //商户交易额
+                                function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\n" + MerchantId + ":" + IsAct + ":" + TradeMonth + ":" + TradeDate + ":" + PayMode + "----" + TradeAmount + ":" + TradeCount + ":" + ActualAmount, "统计商户交易额日志");
                                 MerchantAmountSummay merchantStat = db.MerchantAmountSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode);
                                 if (merchantStat == null)
                                 {

AppStart/Helper/StatService2.cs

@@ -40,7 +40,7 @@ namespace MySystem
         }
         public void StatTradeAmount()
         {
-            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
+            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志");
             WebCMSEntities db = new WebCMSEntities();
             KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
             using (var tran = db.Database.BeginTransaction())
@@ -48,31 +48,26 @@ namespace MySystem
                 try
                 {
                     string start = DateTime.Now.AddDays(-100).ToString("yyyy-MM-dd HH:mm:ss");
-                    function.WriteLog("开始时间:" + start, "统计商户和创客交易额日志2");
-                    DataTable idsDt = CustomerSqlConn.dtable("select Id,UserId from ConsumerOrders where Id>=916515 and CreateDate>='" + start + "' and Status>0 and Version=0 order by Id limit 100", AppConfig.Base.SqlConn2);
-                    function.WriteLog("查询条数:" + idsDt.Rows.Count, "统计商户和创客交易额日志2");
-                    function.WriteLog("1--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
+                    function.WriteLog("开始时间:" + start, "统计商户和创客交易额日志");
+                    DataTable idsDt = CustomerSqlConn.dtable("select Id from ConsumerOrders where Id>=892282 and CreateDate>='" + start + "' and Status>0 and Version=0 order by Id limit 30", AppConfig.Base.SqlConn2);
+                    function.WriteLog("查询条数:" + idsDt.Rows.Count, "统计商户和创客交易额日志");
                     if(idsDt.Rows.Count > 0)
                     {
                         string ids = "";
-                        List<int> idlist = new List<int>();
                         foreach (DataRow idsDr in idsDt.Rows)
                         {
                             ids += idsDr["Id"].ToString() + ",";
-                            idlist.Add(int.Parse(function.CheckInt(idsDr["UserId"].ToString())));
                         }
-                        List<KxsMainModels.Users> users = maindb.Users.Where(m => idlist.Contains(m.Id)).ToList();
-                        function.WriteLog("ids:" + ids, "统计商户和创客交易额日志2");
+                        function.WriteLog("ids:" + ids, "统计商户和创客交易额日志");
                         DataTable selfDt = CustomerSqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount) from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", AppConfig.Base.SqlConn2);
-                        function.WriteLog("统计人数:" + selfDt.Rows.Count, "统计商户和创客交易额日志2");
-                        function.WriteLog("2--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
+                        function.WriteLog("统计人数:" + selfDt.Rows.Count, "统计商户和创客交易额日志");
                         if (selfDt.Rows.Count > 0)
                         {
-                            function.WriteLog("开始循环", "统计商户和创客交易额日志2");
+                            function.WriteLog("开始循环", "统计商户和创客交易额日志");
                             foreach (DataRow selfDr in selfDt.Rows)
                             {
                                 int UserId = int.Parse(selfDr["UserId"].ToString());
-                                KxsMainModels.Users user = users.FirstOrDefault(m => m.Id == UserId) ?? new KxsMainModels.Users();
+                                KxsMainModels.Users user = maindb.Users.FirstOrDefault(m => m.Id == UserId) ?? new KxsMainModels.Users();
                                 string ParentNav = user.ParentNav;
                                 int MerchantId = int.Parse(selfDr["MerchantId"].ToString());
                                 int PayMode = int.Parse(selfDr["PayMode"].ToString());
@@ -85,11 +80,9 @@ namespace MySystem
                                 decimal ActualAmount = decimal.Parse(selfDr[9].ToString());
                                 string TradeMonth = TradeDate.Substring(0, 6);
 
-                                function.WriteLog("21--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
-
-                                function.WriteLog("创客交易额", "统计商户和创客交易额日志2");
+                                function.WriteLog("创客交易额", "统计商户和创客交易额日志");
                                 //创客交易额
-                                UserAmountSummary selfStat = db.UserAmountSummary.FirstOrDefault(m => m.Id > 1190107 && m.UserId == UserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "self");
+                                UserAmountSummary selfStat = db.UserAmountSummary.FirstOrDefault(m => m.UserId == UserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "self");
                                 if (selfStat == null)
                                 {
                                     selfStat = db.UserAmountSummary.Add(new UserAmountSummary()
@@ -112,7 +105,7 @@ namespace MySystem
                                     foreach (string NavUserIdString in ParentNavList)
                                     {
                                         int NavUserId = int.Parse(NavUserIdString);
-                                        UserAmountSummary teamStat = db.UserAmountSummary.FirstOrDefault(m => m.Id > 1190107 && m.UserId == NavUserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "team");
+                                        UserAmountSummary teamStat = db.UserAmountSummary.FirstOrDefault(m => m.UserId == NavUserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "team");
                                         if (teamStat == null)
                                         {
                                             teamStat = db.UserAmountSummary.Add(new UserAmountSummary()
@@ -132,9 +125,8 @@ namespace MySystem
                                 }
                                 db.SaveChanges();
 
-                                function.WriteLog("22--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
-
-                                function.WriteLog("商户交易额", "统计商户和创客交易额日志2");
+                                function.WriteLog("商户交易额", "统计商户和创客交易额日志");
+                                function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\n" + MerchantId + ":" + IsAct + ":" + TradeMonth + ":" + TradeDate + ":" + PayMode + "----" + TradeAmount + ":" + TradeCount + ":" + ActualAmount, "统计商户交易额日志2");
                                 //商户交易额
                                 MerchantAmountSummay merchantStat = db.MerchantAmountSummay.FirstOrDefault(m => m.MerchantId == MerchantId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode);
                                 if (merchantStat == null)
@@ -154,8 +146,6 @@ namespace MySystem
                                 merchantStat.TotalActual += ActualAmount;
                                 db.SaveChanges();
 
-                                function.WriteLog("23--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
-
                                 MerchantInfo merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == MerchantId);
                                 if(merchant != null)
                                 {
@@ -177,9 +167,7 @@ namespace MySystem
                                 }
                                 db.SaveChanges();
 
-                                function.WriteLog("24--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
-
-                                function.WriteLog(str: "码牌交易额", "统计商户和创客交易额日志2");
+                                function.WriteLog(str: "码牌交易额", "统计商户和创客交易额日志");
                                 //码牌交易额
                                 QrCodeAmountSummay qrcode = db.QrCodeAmountSummay.FirstOrDefault(m => m.SnNo == SnNo && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode);
                                 if (qrcode == null)
@@ -199,17 +187,15 @@ namespace MySystem
                                 qrcode.TotalActual += ActualAmount;
                                 db.SaveChanges();
 
-                                function.WriteLog("25--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "统计商户和创客交易额日志2");
-
                                 // string jsonString = "{\"TradeDate\":\"" + TradeDate + "\",\"PayMoney\":\"" + TradeAmount + "\",\"TradeCount\":\"" + TradeCount + "\",\"MerchantActualAmount\":\"" + ActualAmount + "\",\"MerchantId\":\"" + MerchantId + "\",\"PayMode\":\"" + PayMode + "\",\"IsAct\":\"" + IsAct + "\"}";
                                 // RedisDbconn.Instance.AddList("StatMerchantTradeSummaryQueue2", jsonString);
-                                function.WriteLog(str: "----", "统计商户和创客交易额日志2");
+                                function.WriteLog(str: "----", "统计商户和创客交易额日志");
                             }
                             CustomerSqlConn.op("update ConsumerOrders set Version=1 where Id in (" + ids.TrimEnd(',') + ")", AppConfig.Base.SqlConn2);
                         }
                     }
                     tran.Commit();
-                    function.WriteLog(str: "提交", "统计商户和创客交易额日志2");
+                    function.WriteLog(str: "提交", "统计商户和创客交易额日志");
                 }
                 catch (Exception ex)
                 {
@@ -219,7 +205,7 @@ namespace MySystem
             }
             db.Dispose();
             maindb.Dispose();
-            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "统计商户和创客交易额日志2");
+            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "统计商户和创客交易额日志");
         }
 
         // 统计创客激活数