Răsfoiți Sursa

激活奖励延后10分钟发放
创客交易分表数据按月入库

lcl 1 an în urmă
părinte
comite
d33f99519f

+ 3 - 3
AppStart/Helper/StatService.cs

@@ -275,7 +275,7 @@ namespace MySystem
         {
             WebCMSEntities db = new WebCMSEntities();
             DateTime yesterday = DateTime.Now.AddDays(-1);
-            DateTime today = DateTime.Now;
+            DateTime today = DateTime.Now.AddMinutes(-10);
             IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && !string.IsNullOrEmpty(m.SeoKeyword) && m.Detail != "1");
             if (posid > 0)
             {
@@ -380,7 +380,7 @@ namespace MySystem
         {
             WebCMSEntities db = new WebCMSEntities();
             DateTime yesterday = DateTime.Now.AddDays(-1);
-            DateTime today = DateTime.Now.AddMinutes(-5);
+            DateTime today = DateTime.Now.AddMinutes(-10);
             IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && string.IsNullOrEmpty(m.SeoKeyword) && m.BrandId != 12 && m.BrandId != 13 && m.Detail != "1");
             if (posid > 0)
             {
@@ -435,7 +435,7 @@ namespace MySystem
         {
             WebCMSEntities db = new WebCMSEntities();
             DateTime yesterday = DateTime.Now.AddDays(-30);
-            DateTime today = DateTime.Now.AddMinutes(-5);
+            DateTime today = DateTime.Now.AddMinutes(-10);
             IQueryable<PosMachinesTwo> posList = db.PosMachinesTwo.Where(m => m.ActivationState == 1 && m.IsFirst == 1 && m.CreditTrade >= 5000 && string.IsNullOrEmpty(m.SeoKeyword) && (m.BrandId == 12 || m.BrandId == 13) && m.Detail != "1");
             if (posid > 0)
             {

+ 2 - 2
AppStart/Helper/SycnSpServer/SycnSpTradeService.cs

@@ -440,8 +440,8 @@ namespace MySystem
                                                 ActStatus = ActStatus,
                                             }).Entity;
                                             db.SaveChanges();
-                                            string tradeDate = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMMdd") : trade.CreateDate.Value.ToString("yyyyMMdd");
-                                            RedisDbconn.Instance.AddList("AddTradeRecordQueue", Newtonsoft.Json.JsonConvert.SerializeObject(add) + "#cut#" + tradeDate);
+                                            string TradeMonth = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMM") : trade.CreateDate.Value.ToString("yyyyMM");
+                                            PublicFunction.SplitTradeRecord(add, TradeMonth);
 
                                             //统计商户交易额
                                             string TradeDate = trade.CreateDate == null ? DateTime.Now.ToString("yyyyMMdd") : trade.CreateDate.Value.ToString("yyyyMMdd");

+ 15 - 0
AppStart/PublicFunction.cs

@@ -37,5 +37,20 @@ namespace MySystem
             }
             return "";
         }
+
+
+        #region 发送分表数据
+
+        public static void SplitTradeRecord(TradeRecord obj, string TradeMonth)
+        {
+            RedisDbconn.Instance.AddList("AddTradeRecordQueue", Newtonsoft.Json.JsonConvert.SerializeObject(obj) + "#cut#" + TradeMonth);
+        }
+
+        public static void SplitUserAccountRecord(UserAccountRecord obj, string TradeMonth)
+        {
+            RedisDbconn.Instance.AddList("AddUserAccountRecordQueue", Newtonsoft.Json.JsonConvert.SerializeObject(obj) + "#cut#" + TradeMonth);
+        }
+
+        #endregion
     }
 }