核对实时统计数据

AppStart/Helper/StatService.cs

@@ -1197,17 +1197,18 @@ namespace MySystem
         {
             OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "实时执行交易额V2日志");
-            try
+            WebCMSEntities db = new WebCMSEntities();
+            using (var tran = db.Database.BeginTransaction())
             {
-                string startId = function.ReadInstance("/TradeRecord/Id.txt");
-                if(string.IsNullOrEmpty(startId))
-                {
-                    startId = "718574";
-                }
-                DataTable idsDt = OtherMySqlConn.dtable("select Id from TradeRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
-                if(idsDt.Rows.Count > 0)
+                try
                 {
-                    using (WebCMSEntities db = new WebCMSEntities())
+                    string startId = function.ReadInstance("/TradeRecord/Id.txt");
+                    if(string.IsNullOrEmpty(startId))
+                    {
+                        startId = "718574";
+                    }
+                    DataTable idsDt = OtherMySqlConn.dtable("select Id from TradeRecord where Id>=" + startId + " and QueryCount=0 order by Id limit 50");
+                    if(idsDt.Rows.Count > 0)
                     {
                         string ids = "";
                         foreach (DataRow idsDr in idsDt.Rows)
@@ -1345,12 +1346,15 @@ namespace MySystem
                         }
                         db.SaveChanges();
                     }
+                    tran.Commit();
+                }
+                catch (Exception ex)
+                {
+                    tran.Rollback();
+                    function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天交易额V2异常");
                 }
             }
-            catch (Exception ex)
-            {
-                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "统计昨天交易额V2异常");
-            }
+            db.Dispose();
             function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "实时执行交易额V2日志");
         }
 
@@ -1514,7 +1518,6 @@ namespace MySystem
 
             StatMerchantTrade(date);
         }
-
         public void StatTradeAmountEverDaySum()
         {
             // WebCMSEntities db = new WebCMSEntities();
@@ -1730,7 +1733,7 @@ namespace MySystem
                 {
                     StartPosActNumEverTime();
                 }
-                Thread.Sleep(120000);
+                Thread.Sleep(100);
             }
         }
         public void StartPosActNumDo(object sender)

AppStart/Helper/SycnSpServer/SycnSpTradeService.cs

@@ -202,6 +202,7 @@ namespace MySystem
                                             }
                                             db.TradeRecord.Add(new PxcModels.TradeRecord()
                                             {
+                                                ParentNav = user.ParentNav,
                                                 CreateDate = trade.CreateDate,
                                                 UpdateDate = trade.UpdateDate,
                                                 RecordNo = trade.TradeSerialNo, //单号
@@ -223,7 +224,6 @@ namespace MySystem
                                                 Remark = trade.Remark, //备注
                                                 TopUserId = TopUserId, //顶级创客
                                                 MerUserId = pos.UserId, //商户直属创客
-                                                ParentNav = user.ParentNav,
                                             });
                                         }
                                         decimal CheckMoney = 1000;

Controllers/HomeController.cs

@@ -379,6 +379,7 @@ namespace MySystem.Controllers
                                     Remark = trade.Remark, //备注
                                     TopUserId = TopUserId, //顶级创客
                                     MerUserId = pos.UserId, //商户直属创客
+                                    ParentNav = user.ParentNav,
                                 });
                                 if (BankCardType == 1)
                                 {

Startup.cs

@@ -205,14 +205,14 @@ namespace MySystem
             // RedPackageHelper.Instance.StartSendPrize(); //红包活动发奖
             //必须打开的
 
-            // StatService.Instance.StartPosActNum(); //实时统计激活数
+            StatService.Instance.StartPosActNum(); //实时统计激活数
             // StatService.Instance.StartNewUserNum(); //实时统计新增创客数
             // StatService.Instance.StatProfit(); //实时统计创客收益
             // LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
             // MessageCenterService.Instance.Start(); // 消息队列
             // StatServiceTmp.Instance.Start();
             // StatService.Instance.StartEverDay("");
-            StatService.Instance.StartEverDayV2();
+            // StatService.Instance.StartEverDayV2();
             // RedPackageHelper.Instance.Start();
             // StatService.Instance.StatUserLevel();
             // ProfitHelper.Instance.StatProfit("202205"); //统计分润