修复消息队列死循环bug

修复每天统计交易额bug
盛通交易记录入库过滤不成功的

AppStart/Helper/LeaderPrizeService.cs

@@ -82,7 +82,7 @@ namespace MySystem
                 }
                 else
                 {
-                    Thread.Sleep(5000);
+                    Thread.Sleep(60000);
                 }
             }
         }

AppStart/Helper/MessageCenterService.cs

@@ -4,6 +4,7 @@ using Library;
 using LitJson;
 using System.Linq;
 using System.Data;
+using System.Threading;
 using MySystem.PxcModels;
 
 namespace MySystem
@@ -16,14 +17,9 @@ namespace MySystem
 
         public void Start()
         {
-            try
-            {
-                dosomething();
-            }
-            catch (Exception ex)
-            {
-                function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "消息中心队列异常");
-            }
+            Thread th = new Thread(dosomething);
+            th.IsBackground = true;
+            th.Start();
         }
 
         public void dosomething()
@@ -47,6 +43,10 @@ namespace MySystem
                         function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "消息中心队列异常");
                     }
                 }
+                else
+                {
+                    Thread.Sleep(60000);
+                }
             }
         }
     }

AppStart/Helper/StatService.cs

@@ -1456,11 +1456,11 @@ namespace MySystem
                             }).Entity;
                             db.SaveChanges();
                         }
-                        if (BankCardType == 0 && selfStat.DirectDebitTradeAmt == 0)
+                        if (BankCardType == 0)
                         {
                             selfStat.DirectDebitTradeAmt += TradeAmount;
                         }
-                        else if (BankCardType != 0 && selfStat.DirectTradeAmt == 0)
+                        else if (BankCardType != 0)
                         {
                             selfStat.DirectTradeAmt += TradeAmount;
                         }
@@ -1499,11 +1499,11 @@ namespace MySystem
                                         }).Entity;
                                         db.SaveChanges();
                                     }
-                                    if (BankCardType == 0 && teamStat.NonDirectDebitTradeAmt == 0)
+                                    if (BankCardType == 0)
                                     {
                                         teamStat.NonDirectDebitTradeAmt += TradeAmount;
                                     }
-                                    else if (BankCardType != 0 && teamStat.NonDirectTradeAmt == 0)
+                                    else if (BankCardType != 0)
                                     {
                                         teamStat.NonDirectTradeAmt += TradeAmount;
                                     }
@@ -1725,9 +1725,6 @@ namespace MySystem
                 function.WriteLog(ex.ToString(), "创客升级异常");
             }
             db.Dispose();
-
-
-            ProfitHelper.Instance.StatProfit("202204");
         }
 
 

AppStart/Helper/SycnSpServer/SycnSpTradeService.cs

@@ -70,6 +70,16 @@ namespace MySystem
                             }
                             spdb.SaveChanges();
                         }
+                        if(trade.ProductType == "7" && trade.TradeStatus != "00")
+                        {
+                            op = false;
+                            TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
+                            if (edit != null)
+                            {
+                                edit.Status = 2;
+                            }
+                            spdb.SaveChanges();
+                        }
                         if (op)
                         {
                             PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();

Startup.cs

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