Merge branch 'feat-激活奖励新规则' into develop

AppStart/Helper/StatService.cs

@@ -358,17 +358,10 @@ namespace MySystem
             }
             foreach (PosMachinesTwo pos in posList.ToList())
             {
-                // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && !string.IsNullOrEmpty(m.MerIdcardNo));
-                // PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId && m.Sort == 1);
                 PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
                 if (merchant != null && pos.ActivationTime.Value <= pos.BindingTime.Value.AddDays(30))
                 {
                     function.WriteLog("机具号:" + pos.PosSn + ";奖励标记:" + pos.Detail + ";", "实时处理激活奖励");
-                    // PosMerchantOtherInfo otherInfo = db.PosMerchantOtherInfo.FirstOrDefault(m => m.CertId == merchant.MerIdcardNo && m.PrizeFlag1 == 0);
-                    // if (otherInfo != null)
-                    // {
-                    //     otherInfo.PrizeFlag1 = 1;
-                    //     db.SaveChanges();
                     string ParentNav = "";
                     Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
                     if (user != null)
@@ -388,22 +381,23 @@ namespace MySystem
                         }
                         if (ActPrize > 0)
                         {
-                            if (ActPrize == 99)
-                            {
-                                ActPrize = 100;
-                            }
-                            else if (ActPrize == 199)
-                            {
-                                ActPrize = 200;
-                            }
-                            else if (ActPrize == 299)
-                            {
-                                ActPrize = 300;
-                            }
-                            else if (ActPrize == 249)
-                            {
-                                ActPrize = 260;
-                            }
+                            // if (ActPrize == 99)
+                            // {
+                            //     ActPrize = 100;
+                            // }
+                            // else if (ActPrize == 199)
+                            // {
+                            //     ActPrize = 200;
+                            // }
+                            // else if (ActPrize == 299)
+                            // {
+                            //     ActPrize = 300;
+                            // }
+                            // else if (ActPrize == 249)
+                            // {
+                            //     ActPrize = 260;
+                            // }
+                            ActPrize = 100;
                             if (GetUserId > 0)
                             {
                                 doActiveReward(db, merchant, pos, GetUserId, ParentNav, TopUserId, ActPrize);
@@ -1217,7 +1211,7 @@ namespace MySystem
                                                     {
                                                         function.WriteLog("上级:" + puser.MakerCode, "开机奖励发放日志");
                                                         function.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "开机奖励发放日志");
-                                                        if(puser.LeaderLevel > 0 || puser.UserType > 0)
+                                                        if(puser.UserType > 0)
                                                         {
                                                             bool leaderOp = true;
                                                             if(puser.LeaderLevel > 0 && puser.UserType == 0)
@@ -1234,117 +1228,105 @@ namespace MySystem
                                                                 {
                                                                     pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                                                                 }
-                                                                Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
-                                                                OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
-                                                                {
-                                                                    CreateDate = DateTime.Now,
-                                                                    UpdateDate = DateTime.Now,
-                                                                    TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月
-                                                                    TradeDate = DateTime.Now, //达标日期
-                                                                    UserId = puser.Id, //创客
-                                                                    BrandId = pos.BrandId, //品牌
-                                                                    ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
-                                                                    MerchantId = pos.BindMerchantId, //商户
-                                                                    DirectUserId = merchant.UserId, //商户直属人
-                                                                    SnNo = pos.PosSn, //SN号
-                                                                    MerNo = merchant.KqMerNo, //渠道商户号
-                                                                    SnType = pos.PosSnType, //机具类型
-                                                                    StandardDate = pos.ActivationTime, //商户的激活日期
-                                                                    SnStoreId = pos.StoreId, //SN仓库
-                                                                    MerBuddyType = puser.MerchantType, //商户创客类型
-                                                                    RewardType = 1, //奖励类型 1-开机直接奖励，2-开机间接奖励
-                                                                    RewardTips = "开机奖励", //奖励描述
-                                                                    CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
-                                                                    DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
-                                                                    CreditRewardAmount = Prize, //贷记卡交易奖励金额
-                                                                    RewardDesc = "开机奖励", //奖励描述
-                                                                    TopUserId = pTopUserId, //顶级创客
-                                                                    SeoTitle = machineUser.RealName,
-                                                                }).Entity;
-                                                                db.OpenReward.Add(new OpenReward()
-                                                                {
-                                                                    CreateDate = DateTime.Now,
-                                                                    UpdateDate = DateTime.Now,
-                                                                    TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月
-                                                                    TradeDate = DateTime.Now, //达标日期
-                                                                    UserId = puser.Id, //创客
-                                                                    BrandId = pos.BrandId, //品牌
-                                                                    RewardType = 2, //奖励类型
-                                                                    CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
-                                                                    DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
-                                                                    CreditRewardAmount = Prize, //贷记卡交易奖励金额
-                                                                    RewardDesc = "开机奖励", //奖励描述
-                                                                    TopUserId = pTopUserId, //顶级创客
-                                                                });
-                                                                string IdBrand = puser.Id + "_" + pos.BrandId;
-                                                                UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
-                                                                if (userData == null)
-                                                                {
-                                                                    userData = db.UserMachineData.Add(new UserMachineData()
-                                                                    {
-                                                                        IdBrand = IdBrand,
-                                                                    }).Entity;
-                                                                    db.SaveChanges();
-                                                                }
-                                                                userData.OpenProfit += Prize;
-                                                                db.SaveChanges();
-                                                                //账户入库
-                                                                UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
-                                                                if (account == null)
-                                                                {
-                                                                    account = db.UserAccount.Add(new UserAccount()
-                                                                    {
-                                                                        Id = puser.Id,
-                                                                        UserId = puser.Id,
-                                                                    }).Entity;
-                                                                    db.SaveChanges();
-                                                                }
-                                                                //收支明细入库
-                                                                decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
-                                                                decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
-                                                                decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
-                                                                account.BalanceAmount += Prize;
-                                                                account.TotalAmount += Prize;
-                                                                decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
-                                                                decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
-                                                                decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
-                                                                UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
-                                                                {
-                                                                    CreateDate = DateTime.Now,
-                                                                    UpdateDate = DateTime.Now,
-                                                                    UserId = puser.Id, //创客
-                                                                    ChangeType = 50, //变动类型
-                                                                    ProductType = pos.BrandId, //产品类型
-                                                                    ChangeAmount = Prize, //变更金额
-                                                                    BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
-                                                                    AfterTotalAmount = AfterTotalAmount, //变更后总金额
-                                                                    BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
-                                                                    AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
-                                                                    BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
-                                                                    AfterBalanceAmount = AfterBalanceAmount, //变更后余额
-                                                                }).Entity;
-                                                                db.SaveChanges();
-
-                                                                string dateString = DateTime.Now.ToString("yyyyMMdd");
-                                                                string monthString = DateTime.Now.ToString("yyyyMM");
-                                                                // 开机奖励列表
-                                                                List<string> dates = RedisDbconn.Instance.GetList<string>("OpenRewardDay:" + puser.Id + ":" + pos.BrandId);
-                                                                if (!dates.Contains(dateString))
-                                                                {
-                                                                    RedisDbconn.Instance.AddList("OpenRewardDay:" + puser.Id + ":" + pos.BrandId, dateString);
-                                                                }
-                                                                RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + dateString, Prize);
+                                                                PostOpenReward(db, pos, merchant, puser, Prize);
+                                                                
+                                                                Prize = 0;
+                                                            }
+                                                        }
+                                                    }
+                                                }
+                                            }
+                                        }
+                                        // }
+                                    }
+                                }
+                            }
+                        }
+                        db.Dispose();
+                    }
+                    catch(Exception ex)
+                    {
+                        function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "实时获取开机奖励异常");
+                    }
+                }
+                else
+                {
+                    Thread.Sleep(5000);
+                }
+            }
+        }
 
-                                                                List<string> months = RedisDbconn.Instance.GetList<string>("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId);
-                                                                if (!months.Contains(monthString))
+        public void StartLeaderReward()
+        {
+            Thread th = new Thread(StartLeaderRewardDo);
+            th.IsBackground = true;
+            th.Start();
+        }
+        public void StartLeaderRewardDo()
+        {
+            while(true)
+            {
+                string content = RedisDbconn.Instance.RPop<string>("LeaderRewardQueue");
+                if(!string.IsNullOrEmpty(content))
+                {
+                    try
+                    {
+                        function.WriteLog("\n\n" + DateTime.Now.ToString() + "\nposid:" + content, "盟主开机奖励发放日志");
+                        int PosId = int.Parse(content);
+                        Thread.Sleep(1000);
+                        WebCMSEntities db = new WebCMSEntities();
+                        PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == PosId && m.ActivationState == 1 && ((!string.IsNullOrEmpty(m.SeoKeyword) && m.SeoKeyword != "0" && m.CreditTrade >= 1000) || m.BrandId == 14));
+                        if (pos != null)
+                        {
+                            function.WriteLog("sn:" + pos.PosSn, "盟主开机奖励发放日志");
+                            bool IsGet = db.OpenRewardDetail.Any(m => m.SnNo == pos.PosSn);
+                            if (pos.BindingTime > DateTime.Now.AddDays(-30) && !IsGet)
+                            {
+                                decimal ActPrize = decimal.Parse(function.CheckNum(pos.SeoKeyword));
+                                function.WriteLog("押金:" + pos.SeoKeyword, "盟主开机奖励发放日志");
+                                if (ActPrize > 0 || pos.BrandId == 14)
+                                {
+                                    PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
+                                    if (merchant != null)
+                                    {
+                                        function.WriteLog("商户:" + merchant.KqMerNo, "盟主开机奖励发放日志");
+                                        Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
+                                        if (user != null)
+                                        {
+                                            function.WriteLog("所属人:" + user.MakerCode, "盟主开机奖励发放日志");
+                                            string ParentNav = function.CheckNull(user.ParentNav) + "," + user.Id + ",";
+                                            if (!string.IsNullOrEmpty(ParentNav))
+                                            {
+                                                decimal Prize = 50;
+                                                string[] ParentNavs = ParentNav.Trim(',').Replace(",,", ",").Split(',');
+                                                for (int i = ParentNavs.Length - 1; i >= 0; i--)
+                                                {
+                                                    int UserId = int.Parse(ParentNavs[i]);
+                                                    // Users puser = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1 && m.Status > -1);
+                                                    UserRankItem puser = PosCouponPrizeService.Instance.GetUserLevel(db, UserId);
+                                                    if (puser.Id > 0 && Prize > 0)
+                                                    {
+                                                        function.WriteLog("上级:" + puser.MakerCode, "盟主开机奖励发放日志");
+                                                        function.WriteLog("条件:LeaderLevel:" + puser.LeaderLevel + ",UserType:" + puser.UserType, "盟主开机奖励发放日志");
+                                                        if(puser.LeaderLevel > 0)
+                                                        {
+                                                            bool leaderOp = true;
+                                                            if(puser.LeaderLevel > 0 && puser.UserType == 0)
+                                                            {
+                                                                DateTime now = DateTime.Now;
+                                                                leaderOp = db.Leaders.Any(m => m.Id == puser.Id && m.ExpiredDate >= now);
+                                                                function.WriteLog("条件:leaderOp:" + leaderOp, "盟主开机奖励发放日志");
+                                                            }
+                                                            if(leaderOp)
+                                                            {
+                                                                function.WriteLog("满足条件", "盟主开机奖励发放日志");
+                                                                int pTopUserId = 0;
+                                                                if (!string.IsNullOrEmpty(puser.ParentNav))
                                                                 {
-                                                                    RedisDbconn.Instance.AddList("OpenRewardMonth:" + puser.Id + ":" + pos.BrandId, monthString);
+                                                                    pTopUserId = int.Parse(puser.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
                                                                 }
-                                                                RedisDbconn.Instance.AddNumber("OpenRewardAmt:" + puser.Id + ":" + pos.BrandId + ":" + monthString, Prize);
-
-                                                                // 开机奖励详情
-                                                                RedisDbconn.Instance.AddList("OpenRewardDetail:" + puser.Id + ":" + pos.BrandId + ":" + dateString, detail);
-
+                                                                PostOpenReward(db, pos, merchant, puser, Prize);
+                                                                
                                                                 Prize = 0;
                                                             }
                                                         }
@@ -1361,7 +1343,7 @@ namespace MySystem
                     }
                     catch(Exception ex)
                     {
-                        function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "实时获取开机奖励异常");
+                        function.WriteLog(DateTime.Now.ToString() + "\r\n" + ex.ToString(), "盟主开机奖励发放异常");
                     }
                 }
                 else
@@ -3115,6 +3097,36 @@ namespace MySystem
 
 
 
+        //退押金时发放剩余激活奖励
+        public void PreActPrize(WebCMSEntities db, PosMachinesTwo pos, PosMerchantInfo merchant, string Deposit)
+        {
+            decimal DepositNumber = decimal.Parse(function.CheckNum(Deposit));
+            if(DepositNumber > 0)
+            {
+                decimal ActPrize = 0;
+                if(DepositNumber > 1000)
+                {
+                    DepositNumber = DepositNumber / 100;
+                }
+                if(DepositNumber == 199) ActPrize = 100;
+                if(DepositNumber == 299) ActPrize = 200;
+                if(ActPrize > 0)
+                {
+                    Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
+                    int GetUserId = user.Id;
+                    string ParentNav = user.ParentNav;
+                    int TopUserId = 0;
+                    if (!string.IsNullOrEmpty(ParentNav))
+                    {
+                        TopUserId = int.Parse(ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
+                    }
+                    doActiveReward(db, merchant, pos, GetUserId, user.ParentNav, TopUserId, ActPrize);
+                }
+            }
+        }
+
+
+
 
 
 
@@ -3129,5 +3141,101 @@ namespace MySystem
 
         #endregion
 
+        #region 开机奖励
+
+        public void PostOpenReward(WebCMSEntities db, PosMachinesTwo pos, PosMerchantInfo merchant, UserRankItem puser, decimal Prize)
+        {
+            Users machineUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new Users();
+            OpenRewardDetail detail = db.OpenRewardDetail.Add(new OpenRewardDetail()
+            {
+                CreateDate = DateTime.Now,
+                UpdateDate = DateTime.Now,
+                TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月
+                TradeDate = DateTime.Now, //达标日期
+                UserId = puser.Id, //创客
+                BrandId = pos.BrandId, //品牌
+                ProductName = RelationClass.GetKqProductsInfo(pos.BrandId), //产品名称
+                MerchantId = pos.BindMerchantId, //商户
+                DirectUserId = merchant.UserId, //商户直属人
+                SnNo = pos.PosSn, //SN号
+                MerNo = merchant.KqMerNo, //渠道商户号
+                SnType = pos.PosSnType, //机具类型
+                StandardDate = pos.ActivationTime, //商户的激活日期
+                SnStoreId = pos.StoreId, //SN仓库
+                MerBuddyType = puser.MerchantType, //商户创客类型
+                RewardType = 1, //奖励类型 1-开机直接奖励，2-开机间接奖励
+                RewardTips = "开机奖励", //奖励描述
+                CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
+                DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
+                CreditRewardAmount = Prize, //贷记卡交易奖励金额
+                RewardDesc = "开机奖励", //奖励描述
+                SeoTitle = machineUser.RealName,
+            }).Entity;
+            db.OpenReward.Add(new OpenReward()
+            {
+                CreateDate = DateTime.Now,
+                UpdateDate = DateTime.Now,
+                TradeMonth = DateTime.Now.ToString("yyyyMM"), //交易月
+                TradeDate = DateTime.Now, //达标日期
+                UserId = puser.Id, //创客
+                BrandId = pos.BrandId, //品牌
+                RewardType = 2, //奖励类型
+                CreditTradeAmt = pos.CreditTrade, //贷记卡交易总金额
+                DebitTradeAmt = pos.DebitCardTrade, //借记卡交易总金额
+                CreditRewardAmount = Prize, //贷记卡交易奖励金额
+                RewardDesc = "开机奖励", //奖励描述
+            });
+            string IdBrand = puser.Id + "_" + pos.BrandId;
+            UserMachineData userData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
+            if (userData == null)
+            {
+                userData = db.UserMachineData.Add(new UserMachineData()
+                {
+                    IdBrand = IdBrand,
+                }).Entity;
+                db.SaveChanges();
+            }
+            userData.OpenProfit += Prize;
+            db.SaveChanges();
+            //账户入库
+            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id);
+            if (account == null)
+            {
+                account = db.UserAccount.Add(new UserAccount()
+                {
+                    Id = puser.Id,
+                    UserId = puser.Id,
+                }).Entity;
+                db.SaveChanges();
+            }
+            //收支明细入库
+            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
+            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
+            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
+            account.BalanceAmount += Prize;
+            account.TotalAmount += Prize;
+            decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
+            decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
+            decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
+            UserAccountRecord userAccountRecord = db.UserAccountRecord.Add(new UserAccountRecord()
+            {
+                CreateDate = DateTime.Now,
+                UpdateDate = DateTime.Now,
+                UserId = puser.Id, //创客
+                ChangeType = 50, //变动类型
+                ProductType = pos.BrandId, //产品类型
+                ChangeAmount = Prize, //变更金额
+                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
+                AfterTotalAmount = AfterTotalAmount, //变更后总金额
+                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
+                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
+                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
+                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
+            }).Entity;
+            db.SaveChanges();
+        }
+
+        #endregion
+
     }
 }

AppStart/Helper/SycnSpServer/SycnSpActiveService.cs

@@ -50,6 +50,8 @@ namespace MySystem
                                     RedisDbconn.Instance.AddList("OpenRewardQueue", pos.Id.ToString()); //发开机奖励
                                 }
                                 db.SaveChanges();
+                                PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo();
+                                StatService.Instance.PreActPrize(db, pos, merchant, act.SeoTitle);
                             }
 
                             ActivateRecord edit = spdb.ActivateRecord.FirstOrDefault(m => m.Id == act.Id);

AppStart/Helper/SycnSpServer/SycnSpTradeService.cs

@@ -35,6 +35,7 @@ namespace MySystem
                     foreach (TradeRecord trade in trades.ToList())
                     {
                         bool op = true;
+                        bool isDeposit = false;
                         if (trade.SerEntryMode == "N" && trade.ProductType == "1") //金控押金获取
                         {
                             if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900)
@@ -45,8 +46,8 @@ namespace MySystem
                                 if (pos != null)
                                 {
                                     pos.SeoKeyword = trade.TradeAmount.ToString("f2");
-                                    // pos.IsPurchase = 0;
                                     db.SaveChanges();
+                                    isDeposit = true;
                                 }
                                 TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
                                 if (edit != null)
@@ -77,6 +78,7 @@ namespace MySystem
                                 {
                                     pos.SeoKeyword = trade.TradeAmount.ToString("f2");
                                     db.SaveChanges();
+                                    isDeposit = true;
                                 }
                                 TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
                                 if (edit != null)
@@ -108,6 +110,7 @@ namespace MySystem
                                         OrderId = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8),
                                     });
                                     db.SaveChanges();
+                                    isDeposit = true;
                                 }
                                 TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
                                 if (edit != null)
@@ -139,6 +142,7 @@ namespace MySystem
                                         OrderId = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8),
                                     });
                                     db.SaveChanges();
+                                    isDeposit = true;
                                 }
                                 TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id);
                                 if (edit != null)
@@ -571,6 +575,13 @@ namespace MySystem
                                 spdb.SaveChanges();
                             }
                         }
+                        if(isDeposit)
+                        {
+                            PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo();
+                            PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId) ?? new PxcModels.PosMachinesTwo();
+                            PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo();
+                            StatService.Instance.PreActPrize(db, pos, merchant, pos.SeoKeyword);
+                        }
                     }
                     spdb.Dispose();
                     db.Dispose();
@@ -861,6 +872,24 @@ namespace MySystem
                 //清理预扣款
                 RedisDbconn.Instance.AddList("PosWithholdQueue", "{\"UserId\":\"" + pos.BuyUserId + "\",\"SnNo\":\"" + pos.PosSn + "\"}");
             }
+            if(pos.ActivationState == 1 && pos.BindingTime.Value.AddDays(30) <= DateTime.Now && pos.BindingTime.Value.AddDays(60) > DateTime.Now && pos.CreditTrade >= 10000)
+            {
+                RedisDbconn.Instance.AddList("LeaderRewardQueue", pos.Id.ToString());
+                // PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId);
+                // if (user != null)
+                // {
+                //     if(user.LeaderLevel > 0 && db.Leaders.Any(m => m.Id == user.Id && m.ExpiredDate >= now))
+                //     {
+                //         int TopUserId = 0;
+                //         if (!string.IsNullOrEmpty(user.ParentNav))
+                //         {
+                //             TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]);
+                //         }
+                //         PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId);
+                //         StatService.Instance.doActiveReward(db, merchant, pos, user.Id, user.ParentNav, TopUserId, 50);
+                //     }
+                // }
+            }
         }
 
         //立刷格外奖励