清除冗余redis代码

AppStart/Helper/MakeReferenceQrCodeService.cs

@@ -62,12 +62,6 @@ namespace MySystem
                             pxcdb.SaveChanges();
                         }
                         pxcdb.Dispose();
-                        PxcModels.Users editUser = RedisDbconn.Instance.Get<PxcModels.Users>("Users:" + UserId);
-                        if (editUser != null)
-                        {
-                            editUser.ReferenceQrCode = user.ReferenceQrCode;
-                            RedisDbconn.Instance.Set("Users:" + UserId, editUser);
-                        }
                     }
                     db.Dispose();
                 }

AppStart/Helper/Profit/DiviService.cs

@@ -88,11 +88,6 @@ namespace MySystem
                         }
                         db.SaveChanges();
 
-                        //首页-快联盟产品-主界面产品数据
-                        UserMachineData MachineData = RedisDbconn.Instance.Get<UserMachineData>("UserMachineData:" + sub.UserId + ":" + sub.ProductType) ?? new UserMachineData();
-                        MachineData.DividendsProfit += sub.ChangeAmount;
-                        RedisDbconn.Instance.Set("UserMachineData:" + sub.UserId + ":" + sub.ProductType, MachineData);
-
                         //首页-快联盟产品-收益查看-分红奖励
                         List<TradeProfitItem> DiviList = RedisDbconn.Instance.GetList<TradeProfitItem>("TradeProfit:Divi:" + sub.UserId + ":" + sub.ProductType, 1, 1000000);
                         TradeProfitItem Check = DiviList.FirstOrDefault(m => m.TradeMonthValue == TradeMonth);

AppStart/Helper/Profit/FluxService.cs

@@ -111,15 +111,6 @@ namespace MySystem
                             }).Entity;
                             db.SaveChanges();
 
-                            //首页-快联盟产品-主界面产品数据
-                            UserMachineData MachineData = RedisDbconn.Instance.Get<UserMachineData>("UserMachineData:" + sub.UserId + ":" + sub.BrandId);
-                            if (MachineData != null)
-                            {
-                                MachineData.FluxProfit = FluxProfitAmt;
-                                RedisDbconn.Instance.Set("UserMachineData:" + sub.UserId + ":" + sub.BrandId, MachineData);
-                                RedisDbconn.Instance.AddList("Pop:UserMachineData", MachineData); // TODO:同步mysql
-                            }
-
                             RedisDbconn.Instance.HAddNumber("TmpFluxProfit", sub.UserId + "_" + sub.BrandId + "_" + StatDate.ToString("yyyy年MM月") + "_" + StatDate.ToString("yyyyMM"), FluxProfitAmt);
                         }
                         else

AppStart/Helper/Profit/ProfitService.cs

@@ -126,15 +126,6 @@ namespace MySystem
                             }).Entity;
                             db.SaveChanges();
 
-                            //首页-快联盟产品-主界面产品数据
-                            UserMachineData MachineData = RedisDbconn.Instance.Get<UserMachineData>("UserMachineData:" + sub.UserId + ":" + BrandId);
-                            if (MachineData != null)
-                            {
-                                MachineData.TradeProfit = ProfitMoney;
-                                RedisDbconn.Instance.Set("UserMachineData:" + sub.UserId + ":" + BrandId, MachineData);
-                                RedisDbconn.Instance.AddList("Pop:UserMachineData", MachineData); // TODO:同步mysql
-                            }
-
                             RedisDbconn.Instance.HAddNumber("TmpTradeProfit", sub.UserId + "_" + BrandId + "_" + StatDate.ToString("yyyy年MM月") + "分润_" + StatDate.ToString("yyyyMM"), ProfitMoney);
                         }
                         else

AppStart/Helper/Profit/StandardService.cs

@@ -56,7 +56,7 @@ namespace MySystem
                     {
                         MachineForMerNo machinefor = RedisDbconn.Instance.Get<MachineForMerNo>("MachineForMerNo:" + sub.SnNo) ?? new MachineForMerNo();
                         PosMachines machine = RedisDbconn.Instance.Get<PosMachines>("PosMachines:" + machinefor.SnId) ?? new PosMachines();
-                        Users user = RedisDbconn.Instance.Get<Users>("Users:" + machine.UserId) ?? new Users();
+                        Users user = db.Users.FirstOrDefault(m => m.Id == machine.UserId) ?? new Users();
                         int TopUserId = 0;
                         if (!string.IsNullOrEmpty(user.ParentNav))
                         {

AppStart/Helper/StatService.cs

@@ -170,10 +170,7 @@ namespace MySystem
                             merchant.UserId = user.Id;
                             merchant.MerUserType = 1;
                             pos.SeoTitle = user.Id.ToString(); // 记录商户型创客的Id
-                            RedisDbconn.Instance.Set("PosMachinesTwo:" + pos.Id, pos);
                             db.SaveChanges();
-                            RedisDbconn.Instance.Set("Users:" + user.Id, user);
-                            RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
                         }
                     }
                 }
@@ -200,7 +197,6 @@ namespace MySystem
                     {
                         edit.MerchantType = 0;
                         db.SaveChanges();
-                        RedisDbconn.Instance.Set("Users:" + user.Id, edit);
                     }
                 }
             }
@@ -426,7 +422,6 @@ namespace MySystem
                 }
                 userData.ActProfit += ActPrize;
                 db.SaveChanges();
-                RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                 UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
                 if (account == null)
                 {
@@ -588,7 +583,6 @@ namespace MySystem
                             }
                             userData.ActProfit += ActPrize;
                             db.SaveChanges();
-                            RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                             UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
                             if (account == null)
                             {
@@ -762,7 +756,6 @@ namespace MySystem
                                                 }
                                                 userData.OpenProfit += Prize;
                                                 db.SaveChanges();
-                                                RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                                                 //账户入库
                                                 UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
                                                 if (account == null)
@@ -935,7 +928,6 @@ namespace MySystem
                                             }
                                             userData.OpenProfit += Prize;
                                             db.SaveChanges();
-                                            RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, userData);
                                             //账户入库
                                             UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
                                             if (account == null)
@@ -1128,7 +1120,6 @@ namespace MySystem
                                 }
                                 userData.FluxProfit += FluxProfit;
                                 db.SaveChanges();
-                                RedisDbconn.Instance.Clear("UserMachineData:" + IdBrand);
                                 UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == GetUserId);
                                 if (account == null)
                                 {

AppStart/Helper/SycnMysql/UserMachineDataHelper.cs

@@ -38,7 +38,6 @@ namespace MySystem
                             checkExist.BindCount = PopData.BindCount;
                             checkExist.UnBindCount = PopData.UnBindCount;
                             checkExist.TotalMachineCount = PopData.TotalMachineCount;
-                            RedisDbconn.Instance.Clear("UserMachineData:" + PopData.IdBrand);
                         }
                         else
                         {

AppStart/Helper/SycnSpServer/SycnSpActiveService.cs

@@ -58,19 +58,8 @@ namespace MySystem
                                     pos.SeoKeyword = act.SeoTitle;
                                     // pos.IsPurchase = 0;
                                     db.SaveChanges();
-                                    RedisDbconn.Instance.Set("PosMachinesTwo:" + pos.Id, pos);
-                                    RedisDbconn.Instance.Set("PosMachinesTwo:" + pos.PosSn, pos);
                                 }
 
-                                // PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
-                                // if (merchant != null)
-                                // {
-                                //     merchant.ActiveStatus = 1;
-                                //     merchant.MerStandardDate = DateTime.Now;
-                                //     db.SaveChanges();
-                                //     RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
-                                // }
-
                                 ActivateRecord edit = spdb.ActivateRecord.FirstOrDefault(m => m.Id == act.Id);
                                 if (edit != null)
                                 {

AppStart/Helper/SycnSpServer/SycnSpBindService.cs

@@ -133,7 +133,6 @@ namespace MySystem
                                         merFor.SnId = pos.Id;
                                     }
                                     db.SaveChanges();
-                                    RedisDbconn.Instance.Set("PosMachinesTwo", pos);
 
                                     BindRecord edit = spdb.BindRecord.FirstOrDefault(m => m.Id == Bind.Id);
                                     if (edit != null)
@@ -155,7 +154,6 @@ namespace MySystem
                                     MachineData.BindCount += 1;
                                     MachineData.UnBindCount -= 1;
                                     db.SaveChanges();
-                                    RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, MachineData);
                                 }
                             }
                             tran.Commit();

AppStart/Helper/SycnSpServer/SycnSpTradeService.cs

@@ -286,7 +286,6 @@ namespace MySystem
                                                 merchant.ActiveStatus = 1;
                                                 merchant.MerStandardDate = DateTime.Now;
                                                 db.SaveChanges();
-                                                RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
 
                                                 // 推荐王逻辑(激活)
                                                 string SendData = "{\"Kind\":\"3\",\"Data\":{\"UserId\":\"" + pos.BuyUserId + "\",\"PosId\":\"" + pos.Id + "\",\"TradeMonth\":\"" + DateTime.Now.ToString("yyyyMM") + "\"}}";

AppStart/Timer/ChangePosTimer.cs

@@ -147,10 +147,6 @@ public class ChangePosTimer
                     store.LaveNum += 1;
                 }
                 db.SaveChanges();
-                RedisDbconn.Instance.Clear("StoreHouse:" + store.Id);
-                RedisDbconn.Instance.Clear("PosMachinesTwo:" + oldpos.Id);
-                RedisDbconn.Instance.Clear("PosMachinesTwo:" + newpos.Id);
-                RedisDbconn.Instance.Clear("PosMerchantInfo:" + merchant.Id);
                 db.Dispose();
             }
             else

AppStart/Timer/TestHelper.cs

@@ -21,236 +21,6 @@ public class TestHelper
         th.Start();
     }
 
-    private void DoWorks()
-    {
-        // WebCMSEntities db = new WebCMSEntities();
-        // bool op = true;
-        // while (op)
-        // {
-        //     WebCMSEntities db = new WebCMSEntities();
-        //     int StartId = RedisDbconn.Instance.Get<int>("SetCertUserId");
-        //     var list = db.Users.Select(m => new { m.Id, m.CertId }).Where(m => m.Id > StartId && string.IsNullOrEmpty(m.CertId)).OrderBy(m => m.Id).Take(20).ToList();
-        //     if (list.Count > 0)
-        //     {
-        //         foreach (var sub in list)
-        //         {
-        //             Users user = db.Users.FirstOrDefault(m => m.Id == sub.Id && string.IsNullOrEmpty(m.CertId));
-        //             if (user != null)
-        //             {
-        //                 DataTable dt = dbconn.dtable("select CertId from TmpCert where MakerCode='" + user.MakerCode + "'");
-        //                 if (dt.Rows.Count > 0)
-        //                 {
-        //                     string CertId = dt.Rows[0]["CertId"].ToString();
-        //                     user.CertId = CertId;
-        //                 }
-        //                 RedisDbconn.Instance.Set("SetCertUserId", sub.Id);
-        //             }
-        //         }
-        //         db.SaveChanges();
-        //         db.Dispose();
-        //     }
-        //     else
-        //     {
-        //         op = false;
-        //     }
-        //     Thread.Sleep(10);
-        // }
-
-        // IQueryable<Users> users = db.Users.Where(m => m.AuthFlag == 1).OrderBy(m => m.Id);
-        // foreach (Users user in users.ToList())
-        // {
-        //     string path = function.CreateQRCode2(ConfigurationManager.AppSettings["SourceHost"].ToString() + "p/user-inviteregist-1?Id=" + user.Id, function.MD5_16(user.Id.ToString() + "8745"), "/bsserver_com/static/ReferenceQrCode/");
-        //     path = path.Replace("//", "/");
-        //     string resultpath = "/bsserver_com/static/ReferenceQrCode/" + function.MD5_16(user.Id.ToString() + "8745") + "Pic.png";
-        //     MakeReferenceQrCodeService.Instance.MakeQRCode(function.getPath("/static/QrCodeBg.png"), function.getPath(path), function.getPath(resultpath), user);
-        //     resultpath = resultpath.Replace("bsserver_com/", "");
-        //     user.ReferenceQrCode = resultpath;
-        //     db.SaveChanges();
-        //     RedisDbconn.Instance.Set("Users:" + user.Id, user);
-        //     function.WriteLog(user.Id.ToString(), "生成邀请二维码");
-        // }
-        // function.WriteLog("finish", "生成邀请二维码");
-
-        
-        // bool op = true;
-        // while (op)
-        // {
-        //     int startId = RedisDbconn.Instance.Get<int>("RemoveUserId");
-        //     List<int> uids = db.Users.Select(m => m.Id).Where(m => m > startId && m > 1).OrderBy(m => m).Take(100).ToList();
-        //     if (uids.Count > 0)
-        //     {
-        //         foreach (int uid in uids)
-        //         {
-        //             DoUsers(db, uid);
-        //             RedisDbconn.Instance.Set("RemoveUserId", uid);
-        //         }
-        //         Thread.Sleep(200);
-        //     }
-        //     else
-        //     {
-        //         op = false;
-        //     }
-        // }
-
-        // db.Dispose();
-    }
-
-    // public void DoUsers(WebCMSEntities db, int uid)
-    // { 
-    //     Users user = db.Users.FirstOrDefault(m => m.Id == uid);
-    //     if (user != null)
-    //     {
-    //         string Mobile = function.CheckNull(user.Mobile);
-    //         if (!Mobile.Contains("*") && Mobile.Substring(0, 1) == "1" && Mobile.Length == 11)
-    //         {
-    //             string ParentNav = user.ParentNav;
-    //             if (!string.IsNullOrEmpty(ParentNav))
-    //             {
-    //                 string NewParentNav = "";
-    //                 int NewParentUserId = 1;
-    //                 string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
-    //                 Array.Reverse(ParentNavList);
-    //                 int i = 0;
-    //                 foreach (string ParentId in ParentNavList)
-    //                 {
-    //                     int puid = int.Parse(ParentId);
-    //                     Users puser = db.Users.FirstOrDefault(m => m.Id == puid);
-    //                     if (puser != null)
-    //                     {
-    //                         Mobile = function.CheckNull(puser.Mobile);
-    //                         if (!Mobile.Contains("*") && Mobile.Substring(0, 1) == "1" && Mobile.Length == 11)
-    //                         {
-    //                             i += 1;
-    //                             NewParentNav = "," + ParentId + "," + NewParentNav;
-    //                             if (i == 1)
-    //                             {
-    //                                 NewParentUserId = puid;
-    //                             }
-    //                         }
-    //                     }
-    //                 }
-    //                 if (string.IsNullOrEmpty(NewParentNav))
-    //                 {
-    //                     NewParentNav = ",1,";
-    //                 }
-    //                 user.ParentNav = NewParentNav;
-    //                 user.ParentUserId = NewParentUserId;
-    //             }
-    //             else
-    //             {
-    //                 user.ParentNav = ",1,";
-    //                 user.ParentUserId = 1;
-    //             }
-    //             db.SaveChanges();
-    //         }
-    //     }
-    // }
-
-    private void domerchantType()
-    { 
-        // OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
-        // OtherMySqlConn.op("update PosMerchantInfo set MerUserType=0");
-        // OtherMySqlConn.op("update Users set MerchantType=0");
-        // bool op = true;
-        // while (op)
-        // {
-        //     MySystem.SpModels.WebCMSEntities spdb = new MySystem.SpModels.WebCMSEntities();
-        //     WebCMSEntities db = new WebCMSEntities();
-        //     DateTime end = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00");
-        //     int startId = int.Parse(function.CheckInt(RedisDbconn.Instance.Get<string>("BindRecordId")));
-        //     List<MySystem.SpModels.BindRecord> binds = spdb.BindRecord.Where(m => m.Id > startId && m.CreateTime < end).OrderBy(m => m.Id).Take(200).ToList();
-        //     if (binds.Count > 0)
-        //     {
-        //         foreach (MySystem.SpModels.BindRecord bind in binds)
-        //         {
-        //             string Mobile = bind.MerNewSnNo;
-        //             string MerNo = bind.MerNo;
-        //             string BeforeNum = "";
-        //             string AfterNum = "";
-        //             if (Mobile.Contains("****") && Mobile.Length == 11)
-        //             {
-        //                 BeforeNum = Mobile.Substring(0, 3);
-        //                 AfterNum = Mobile.Substring(7);
-        //             }
-        //             string Name = bind.MerName;
-        //             if (bind.ProductType == "2")
-        //             {
-        //                 if (Name.Contains("-"))
-        //                 {
-        //                     Name = Name.Split('-')[1];
-        //                 }
-        //                 else if (Name.Contains("_"))
-        //                 {
-        //                     Name = Name.Split('_')[1];
-        //                 }
-        //             }
-        //             else if (bind.ProductType == "4")
-        //             {
-        //                 Name = bind.SeoTitle;
-        //             }
-        //             Users user = db.Users.FirstOrDefault(m => m.Mobile.StartsWith(BeforeNum) && m.Mobile.EndsWith(AfterNum) && m.RealName == Name && m.AuthFlag == 1 && m.MerchantType == 0);
-        //             if (user != null)
-        //             {
-        //                 PosMachinesTwo checkPos = db.PosMachinesTwo.FirstOrDefault(m => m.UserId == user.Id);
-        //                 if (checkPos == null)
-        //                 {
-        //                     MachineForSnNo forSnNo = db.MachineForSnNo.FirstOrDefault(m => m.SnNo == bind.MerSnNo) ?? new MachineForSnNo();
-        //                     PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == forSnNo.SnId && m.UserId != user.Id);
-        //                     if (pos != null)
-        //                     {
-        //                         pos.UserId = user.Id;
-        //                         user.MerchantType = 1;
-        //                         PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PosMerchantInfo();
-        //                         merchant.UserId = user.Id;
-        //                         merchant.MerUserType = 1;
-        //                         pos.SeoTitle = user.Id.ToString(); // 记录商户型创客的Id
-        //                         RedisDbconn.Instance.Set("PosMachinesTwo:" + pos.Id, pos);
-        //                         db.SaveChanges();
-        //                         RedisDbconn.Instance.Set("Users:" + user.Id, user);
-        //                         RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
-        //                     }
-        //                 }
-        //                 else
-        //                 { 
-        //                     int count = db.PosMachinesTwo.Count(m => m.UserId == user.Id);
-        //                     if (count == 1 && checkPos.UserId != checkPos.BuyUserId)
-        //                     { 
-        //                         user.MerchantType = 1;
-        //                         PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == checkPos.BindMerchantId) ?? new PosMerchantInfo();
-        //                         merchant.UserId = user.Id;
-        //                         merchant.MerUserType = 1;
-        //                         checkPos.SeoTitle = user.Id.ToString(); // 记录商户型创客的Id
-        //                         RedisDbconn.Instance.Set("PosMachinesTwo:" + checkPos.Id, checkPos);
-        //                         db.SaveChanges();
-        //                         RedisDbconn.Instance.Set("Users:" + user.Id, user);
-        //                         RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant);
-        //                     }
-        //                 }
-        //             }
-        //             RedisDbconn.Instance.Set("BindRecordId", bind.Id.ToString());
-        //         }
-        //     }
-        //     else
-        //     {
-        //         op = false;
-        //     }
-        //     spdb.Dispose();
-        //     db.Dispose();
-        // }
-        // RedisDbconn.Instance.Clear("BindRecordId");
-
-        // DataTable dt = OtherMySqlConn.dtable("select PosSn,UserId from PosMachinesTwo where UserId in (select Id from Users where MerchantType=1);");
-        // foreach (DataRow dr in dt.Rows)
-        // {
-        //     string PosSn = dr["PosSn"].ToString();
-        //     string UserId = dr["UserId"].ToString();
-        //     OtherMySqlConn.op("update TradeRecord set UserId=" + UserId + " where SnNo='" + PosSn + "' and CreateDate>='2022-04-01 00:00:00'");
-        // }
-        // // OtherMySqlConn.connstr = ;
-
-        // StatService.Instance.StartEverDay2();
-    }
-
     public void StartEverDay()
     { 
         OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();

Controllers/HomeController.cs

@@ -555,8 +555,6 @@ namespace MySystem.Controllers
             machineData.UnBindCount = db.PosMachinesTwo.Count(m => m.Status > -1 && m.BuyUserId == uid && m.BrandId == kind && m.BindingState == 0);
             machineData.TotalMachineCount = machineData.BindCount + machineData.UnBindCount;
             db.SaveChanges();
-            RedisDbconn.Instance.Set("UserMachineData:" + IdBrand, machineData);
-            RedisDbconn.Instance.SetExpire("UserMachineData:" + IdBrand, function.get_Random(1800, 5400));
             db.Dispose();
             return "finish";
         }
@@ -575,7 +573,6 @@ namespace MySystem.Controllers
                 {
                     store.LaveNum = CurLaveNum;
                     db.SaveChanges();
-                    RedisDbconn.Instance.Set("StoreHouse:" + Id, store);
                 }
             }
             db.Dispose();
@@ -594,7 +591,6 @@ namespace MySystem.Controllers
                 {
                     store.LaveNum = CurLaveNum;
                     db.SaveChanges();
-                    RedisDbconn.Instance.Set("StoreHouse:" + Id, store);
                 }
             }
             db.Dispose();