恢复降级逻辑

AppStart/Helper/StatService.cs

@@ -1831,7 +1831,7 @@ namespace MySystem
         // 5. 创客升级
         public void StatUserLevel()
         {
-            Thread th = new Thread(StatUserLevelDo);
+            Thread th = new Thread(StatUserLevelStart);
             th.IsBackground = true;
             th.Start();
         }
@@ -1960,29 +1960,42 @@ namespace MySystem
                                     }
                                 }
                                 // 降级逻辑
-                                // if(!upFlag && AfterLevel > 5)
-                                // {
-                                //     AfterLevel = 5;
-                                // }
-                                // if (AfterLevel < BeforeLevel && BeforeLevel > 1)
-                                // {
-                                //     function.WriteLog("降级：" + user.Id.ToString() + AfterLevel + "->" + BeforeLevel, "创客升级日志");
-                                //     user.UserLevel = AfterLevel;
-                                //     db.UserRank.Add(new UserRank()
-                                //     {
-                                //         CreateDate = DateTime.Now,
-                                //         UpdateDate = DateTime.Now,
-                                //         UserId = user.Id, //创客
-                                //         WhiteRank = BeforeLevel,
-                                //         Rank = AfterLevel, //当前等级
-                                //         StatYear = DateTime.Now.Year, //统计年份
-                                //         StatMonth = DateTime.Now.Month, //统计月份
-                                //         TradeAmt = TradeAmount, //团队交易总额
-                                //         UpgradeFlag = 0, //升级标识
-                                //         OperateDate = DateTime.Now, //操作时间
-                                //     });
-                                //     db.SaveChanges();
-                                // }
+                                if(!upFlag && AfterLevel > 5)
+                                {
+                                    AfterLevel = 5;
+                                }
+                                if (AfterLevel < BeforeLevel && BeforeLevel > 1)
+                                {
+                                    function.WriteLog(user.MakerCode + "-" + user.RealName + ":K" + BeforeLevel + "->K" + AfterLevel, "创客降级日志");
+                                    user.UserLevel = AfterLevel;
+                                    DateTime checkTime = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00");
+                                    UserRank rank = db.UserRank.FirstOrDefault(m => m.CreateDate >= checkTime && m.UserId == user.Id);
+                                    if(rank == null)
+                                    {
+                                        db.UserRank.Add(new UserRank()
+                                        {
+                                            CreateDate = DateTime.Now,
+                                            UpdateDate = DateTime.Now,
+                                            UserId = user.Id, //创客
+                                            WhiteRank = BeforeLevel,
+                                            Rank = AfterLevel, //当前等级
+                                            StatYear = DateTime.Now.Year, //统计年份
+                                            StatMonth = DateTime.Now.Month, //统计月份
+                                            TradeAmt = TradeAmount, //团队交易总额
+                                            UpgradeFlag = 0, //升级标识
+                                            OperateDate = DateTime.Now, //操作时间
+                                            Status = 1,
+                                        });
+                                        db.SaveChanges();
+                                    }
+                                    else
+                                    {
+                                        rank.TradeAmt = TradeAmount;
+                                        rank.Rank = AfterLevel;
+                                        rank.Status = 1;
+                                        db.SaveChanges();
+                                    }
+                                }
                             }
                             startid = subuser.Id;
                         }
@@ -2004,7 +2017,6 @@ namespace MySystem
             RedisDbconn.Instance.AddList("DoTableEveryMonthQueue", "1");
         }
 
-
         public void StatUserLevelStartTest()
         {
             Thread th = new Thread(StatUserLevelStartTestDo);

appsettings.json

@@ -17,12 +17,12 @@
     "Host": "http://localhost:5047/",
     "SourceHost": "http://bs.kexiaoshuang.com/",
     "Database": "KxsMainServer",
-    "SqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer2;password=FrW8ZfxlcaVdm1r0;database=KxsMainServer2;charset=utf8;",
-    "Pxc1SqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer2;password=FrW8ZfxlcaVdm1r0;database=KxsMainServer2;charset=utf8;",
-    "MainSqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer2;password=FrW8ZfxlcaVdm1r0;database=KxsStatServer2;charset=utf8;",
-    "SpSqlConnStr": "server=47.109.31.237;port=3306;user=KxsSpServer;password=jJ9qKsvwWgQA9xWG;database=KxsSpServer;charset=utf8;",
-    "OpSqlConnStr": "server=47.109.31.237;port=3306;user=KxsOpServer;password=r7jwZ8ydLoeswDR4;database=KxsOpServer;charset=utf8;",
-    "RedisConnStr": "47.109.31.237:6379,password=klm@redis,DefaultDatabase=1,poolsize=500,preheat=50,asyncPipeline=true",
+    "SqlConnStr": "server=47.108.231.170;port=3306;user=KxsMain;password=mzeqjriUWore0dwT;database=KxsMainServer;charset=utf8;",
+    "Pxc1SqlConnStr": "server=47.108.231.170;port=3306;user=KxsMain;password=mzeqjriUWore0dwT;database=KxsMainServer;charset=utf8;",
+    "MainSqlConnStr": "server=47.108.231.170;port=3306;user=KxsMain;password=mzeqjriUWore0dwT;database=KxsStatServer;charset=utf8;",
+    "SpSqlConnStr": "server=47.108.229.115;port=3306;user=KxsSpServer;password=jJ9qKsvwWgQA9xWG;database=KxsSpServer;charset=utf8;",
+    "OpSqlConnStr": "server=47.108.231.170;port=3306;user=KxsOpServer;password=r7jwZ8ydLoeswDR4;database=KxsOpServer;charset=utf8;",
+    "RedisConnStr": "47.108.207.184:6379,password=skb@redis2022,DefaultDatabase=0,poolsize=500,preheat=50,asyncPipeline=true",
     "IOSAppVersion": "1.0.0",
     "AndroidAppVersion": "1.0.0",
     "OSSKey": "iL9dWgBunZRwGbHQ",