瀏覽代碼

提交统计激活数,统计商户交易额队列

lcl 2 年之前
父節點
當前提交
932e85d405

+ 3 - 0
AppStart/Helper/AddActService.cs

@@ -79,6 +79,9 @@ namespace MySystem
 
 
                                 //补激活前的交易
                                 //补激活前的交易
                                 RedisDbconn.Instance.AddList("AddTradeRecordByPosIdQueue", pos.Id.ToString());
                                 RedisDbconn.Instance.AddList("AddTradeRecordByPosIdQueue", pos.Id.ToString());
+
+                                //统计激活数
+                                RedisDbconn.Instance.AddList("StatActQueue", "{\"TradeDate\":\"" + DateTime.Now.ToString("yyyyMMdd") + "\",\"UserId\":\"" + pos.BuyUserId + "\",\"BrandId\":\"" + pos.BrandId + "\"}");
                             }
                             }
                             db.Dispose();
                             db.Dispose();
                         }
                         }

+ 1 - 1
AppStart/Helper/DepositReturnStatService.cs

@@ -27,7 +27,7 @@ namespace MySystem
         {
         {
             while(true)
             while(true)
             {
             {
-                if(DateTime.Now.Day <= 5 && DateTime.Now.Hour > 1 && DateTime.Now.Hour < 13)
+                if(DateTime.Now.Day <= 15 && DateTime.Now.Hour > 1 && DateTime.Now.Hour < 13)
                 {
                 {
                     try
                     try
                     {
                     {

+ 7 - 0
AppStart/Helper/SycnSpServer/SycnSpTradeService.cs

@@ -367,6 +367,9 @@ namespace MySystem
 
 
                                             //补激活前的交易
                                             //补激活前的交易
                                             RedisDbconn.Instance.AddList("AddTradeRecordByPosIdQueue", pos.Id.ToString());
                                             RedisDbconn.Instance.AddList("AddTradeRecordByPosIdQueue", pos.Id.ToString());
+
+                                            //统计激活数
+                                            RedisDbconn.Instance.AddList("StatActQueue", "{\"TradeDate\":\"" + DateTime.Now.ToString("yyyyMMdd") + "\",\"UserId\":\"" + pos.BuyUserId + "\",\"BrandId\":\"" + pos.BrandId + "\"}");
                                         }
                                         }
                                         if (TradeAmount > 0)
                                         if (TradeAmount > 0)
                                         {
                                         {
@@ -436,6 +439,10 @@ namespace MySystem
                                                 Version = MerHelpFlag == 2 ? 1 : 0,
                                                 Version = MerHelpFlag == 2 ? 1 : 0,
                                                 ActStatus = ActStatus,
                                                 ActStatus = ActStatus,
                                             });
                                             });
+
+                                            //统计商户交易额
+                                            string TradeDate = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMMdd") : trade.CreateDate.Value.ToString("yyyyMMdd");
+                                            RedisDbconn.Instance.AddList("StatMerTradeAmountQueue", "{\"TradeDate\":\"" + TradeDate + "\",\"TradeAmount\":\"" + TradeAmount + "\",\"MerchantId\":\"" + pos.BindMerchantId + "\",\"BrandId\":\"" + BrandId + "\"}");
                                         }
                                         }
                                         // 立刷30天内刷满5000,无服务费机具,返50
                                         // 立刷30天内刷满5000,无服务费机具,返50
                                         if (pos.BrandId == 6 && decimal.Parse(function.CheckNum(pos.SeoKeyword)) == 0 && pos.CreditTrade >= 5000 && pos.ActivationState == 1 && pos.BindingTime > DateTime.Now.AddDays(-30))
                                         if (pos.BrandId == 6 && decimal.Parse(function.CheckNum(pos.SeoKeyword)) == 0 && pos.CreditTrade >= 5000 && pos.ActivationState == 1 && pos.BindingTime > DateTime.Now.AddDays(-30))