备份

AppStart/Helper/AlipayPayBack2Service.cs

@@ -72,12 +72,269 @@ namespace MySystem
                 foreach (string idString in ids)
                 {
                     int OrderId = int.Parse(idString);
-                    DoOrder(db, OrderId);
+                    DoOrderV2(db, OrderId);
                 }
             }
             db.Dispose();
         }
 
+        public void DoOrderV2(WebCMSEntities db, int OrderId)
+        {
+            Orders order = db.Orders.FirstOrDefault(m => m.Id == OrderId && m.Status == 0);
+            if (order != null)
+            {
+                order.Status = 1;
+                order.PayDate = DateTime.Now;
+                order.PayStatus = 1;
+                db.SaveChanges();
+                RedisDbconn.Instance.Set("Orders:" + order.Id, order);
+
+                //机具券逻辑
+                OrderProduct pro = db.OrderProduct.FirstOrDefault(m => m.OrderId == OrderId);
+                if (pro != null)
+                {
+                    if (pro.ProductId == 10 || pro.ProductId == 11 || pro.ProductId == 12 || pro.ProductId == 13)
+                    {
+                        order.Status = 2;
+                        int BuyCount = pro.ProductCount;
+                        int Kind = 0;
+                        if (pro.ProductId == 10)
+                        {
+                            Kind = 1;
+                        }
+                        else if (pro.ProductId == 11)
+                        {
+                            Kind = 2;
+                        }
+                        else if (pro.ProductId == 12)
+                        {
+                            if (pro.NormDetail == "电签POS")
+                            {
+                                Kind = 1;
+                            }
+                            else if (pro.NormDetail == "大POS")
+                            {
+                                Kind = 2;
+                            }
+                            
+                        }
+                        else if (pro.ProductId == 13)
+                        {
+                            if (pro.NormDetail == "300电签POS")
+                            {
+                                Kind = 1;
+                            }
+                            else if (pro.NormDetail == "200大POS")
+                            {
+                                Kind = 2;
+                            }
+                            else if (pro.NormDetail == "50大机券+225电签券")
+                            {
+                                Kind = 3;
+                            }
+                            else if (pro.NormDetail == "100大机券+150电签券")
+                            {
+                                Kind = 4;
+                            }
+                            else if (pro.NormDetail == "150大机券+75电签券")
+                            {
+                                Kind = 5;
+                            }
+                        }
+                        db.SaveChanges();
+                        string Codes = "";
+                        if(Kind > 2)
+                        {
+                            Dictionary<int, int> couponData = new Dictionary<int, int>();
+                            if(Kind == 3)
+                            {
+                                couponData.Add(1, 225); //电签数量
+                                couponData.Add(2, 50); //大机数量
+                            }
+                            else if(Kind == 4)
+                            {
+                                couponData.Add(1, 150); //电签数量
+                                couponData.Add(2, 100); //大机数量
+                            }
+                            else if(Kind == 5)
+                            {
+                                couponData.Add(1, 75); //电签数量
+                                couponData.Add(2, 150); //大机数量
+                            }
+                            foreach(int kindNum in couponData.Keys)
+                            {
+                                int BuyCountByKind = couponData[kindNum];
+                                var coupons = db.PosCoupons.Where(m => m.IsLock == 0 && m.IsUse == 0 && m.UserId == 0 && m.QueryCount == kindNum).OrderBy(m => m.Id).Take(BuyCountByKind).ToList();
+                                foreach (var coupon in coupons)
+                                {
+                                    PosCoupons item = db.PosCoupons.FirstOrDefault(m => m.Id == coupon.Id);
+                                    if (item != null)
+                                    {
+                                        item.CreateDate = DateTime.Now;
+                                        item.UserId = order.UserId;
+                                        item.UpdateDate = DateTime.Now.AddDays(180);
+                                        if (pro.ProductId == 13)
+                                        {
+                                            item.LeaderUserId = order.UserId;
+                                        }
+                                        Codes += item.ExchangeCode + ",";
+                                    }
+                                }
+                            }
+                        }
+                        else
+                        {
+                            var coupons = db.PosCoupons.Where(m => m.IsLock == 0 && m.IsUse == 0 && m.UserId == 0 && m.QueryCount == Kind).OrderBy(m => m.Id).Take(BuyCount).ToList();
+                            foreach (var coupon in coupons)
+                            {
+                                PosCoupons item = db.PosCoupons.FirstOrDefault(m => m.Id == coupon.Id);
+                                if (item != null)
+                                {
+                                    item.CreateDate = DateTime.Now;
+                                    item.UserId = order.UserId;
+                                    item.UpdateDate = DateTime.Now.AddDays(180);
+                                    if (pro.ProductId == 13)
+                                    {
+                                        item.LeaderUserId = order.UserId;
+                                    }
+                                    Codes += item.ExchangeCode + ",";
+                                }
+                            }
+                        }
+                        order.SnNos = Codes.TrimEnd(',');
+                        string ChangeRecordNo = "SC" + DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8);
+                        PosCouponForUser forUser = db.PosCouponForUser.FirstOrDefault(m => m.Id == order.UserId);
+                        if (forUser == null)
+                        {
+                            forUser = db.PosCouponForUser.Add(new PosCouponForUser()
+                            {
+                                Id = order.UserId,
+                            }).Entity;
+                            db.SaveChanges();
+                        }
+                        int BeforeOut = forUser.OutNum;
+                        int BeforeTotal = forUser.TotalNum;
+                        int BeforeStock = forUser.StockNum;
+                        forUser.TotalNum += BuyCount;
+                        forUser.StockNum += BuyCount;
+                        int AfterOut = forUser.OutNum;
+                        int AfterTotal = forUser.TotalNum;
+                        int AfterStock = forUser.StockNum;
+                        PosCouponOrders stat = db.PosCouponOrders.Add(new PosCouponOrders()
+                        {
+                            QueryCount = Kind,
+                            CreateDate = DateTime.Now,
+                            ChangeKind = 1,
+                            ChangeCount = BuyCount,
+                            AfterOut = AfterOut,
+                            AfterTotal = AfterTotal,
+                            AfterStock = AfterStock,
+                            BeforeOut = BeforeOut,
+                            BeforeTotal = BeforeTotal,
+                            BeforeStock = BeforeStock,
+                            OrderNo = ChangeRecordNo,
+                            ToUserId = order.UserId,
+                            FromUserId = 0,
+                        }).Entity;
+                        db.SaveChanges();
+                        RedisDbconn.Instance.Clear("Orders:" + order.Id);
+                    }
+
+                    //推荐下单奖励
+                    if (pro.ProductId == 10 || pro.ProductId == 11)
+                    {
+                        bool checkPrize = db.UserAccountRecord.Any(m => m.QueryCount == OrderId);
+                        int SelfBuy = 0;
+                        OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["Pxc1SqlConnStr"].ToString();
+                        DataTable stat = OtherMySqlConn.dtable("select count(Id) from Orders where Id in (select OrderId from OrderProduct where UserId=" + order.UserId + " and (ProductId=10 or ProductId=11)) and Status>0 and TotalPrice>0");
+                        if (stat.Rows.Count > 0)
+                        {
+                            SelfBuy = int.Parse(function.CheckInt(stat.Rows[0][0].ToString()));
+                        }
+                        // OtherMySqlConn.connstr = ;
+                        function.WriteLog("OrderId:" + OrderId, "推荐下单奖励监控日志");
+                        function.WriteLog("checkPrize:" + checkPrize, "推荐下单奖励监控日志");
+                        function.WriteLog("SelfBuy:" + SelfBuy, "推荐下单奖励监控日志");
+                        if (SelfBuy == 1 && !checkPrize)
+                        {
+                            Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId);
+                            if (user != null)
+                            {
+                                int ParentUserId = user.ParentUserId;
+                                while(ParentUserId > 0)
+                                {
+                                    int machineCount = db.PosMachinesTwo.Count(m => m.UserId == ParentUserId && m.PosSnType == 0); //判断是否拥有3台购买机
+                                    int ActiveCount = db.PosMachinesTwo.Count(m => m.UserId == ParentUserId && m.ActivationState == 1); //判断是否拥有3台激活机（不限购买或赠送）
+                                    int couponCount = db.PosCoupons.Count(m => m.UserId == ParentUserId && m.IsUse == 0); //判断是否拥有3张券
+                                    function.WriteLog("MakerCode:" + user.MakerCode, "推荐下单奖励监控日志");
+                                    function.WriteLog("machineCount:" + machineCount, "推荐下单奖励监控日志");
+                                    function.WriteLog("ActiveCount:" + ActiveCount, "推荐下单奖励监控日志");
+                                    if (machineCount + ActiveCount + couponCount >= 3)
+                                    {
+                                        function.WriteLog("满足条件", "推荐下单奖励监控日志");
+                                        UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == ParentUserId);
+                                        if (account == null)
+                                        {
+                                            account = db.UserAccount.Add(new UserAccount()
+                                            {
+                                                Id = ParentUserId,
+                                                UserId = ParentUserId,
+                                            }).Entity;
+                                            db.SaveChanges();
+                                        }
+                                        decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
+                                        decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
+                                        decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
+                                        account.BalanceAmount += 100;
+                                        account.TotalAmount += 100;
+                                        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 = ParentUserId, //创客
+                                            ChangeType = 112, //变动类型
+                                            ChangeAmount = 100, //变更金额
+                                            BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
+                                            AfterTotalAmount = AfterTotalAmount, //变更后总金额
+                                            BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
+                                            AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
+                                            BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
+                                            AfterBalanceAmount = AfterBalanceAmount, //变更后余额
+                                            QueryCount = OrderId,
+                                        }).Entity;
+                                        db.SaveChanges();
+                                        RedisDbconn.Instance.Set("UserAccount:" + ParentUserId, account);
+
+                                        //推荐下单上级获得30天的机具循环天数
+                                        var posList = db.PosMachinesTwo.Select(m => new { m.Id, m.UserId, m.BindingState, m.RecycEndDate }).Where(m => m.UserId == ParentUserId && m.BindingState == 0 && m.RecycEndDate != null).ToList();
+                                        foreach (var subPos in posList)
+                                        {
+                                            PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == subPos.Id);
+                                            if (pos != null)
+                                            {
+                                                pos.RecycEndDate = pos.RecycEndDate.Value.AddDays(30);
+                                            }
+                                        }
+                                        db.SaveChanges();
+                                        ParentUserId = 0;
+                                    }
+                                    else
+                                    {
+                                        Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
+                                        ParentUserId = puser.ParentUserId;
+                                    }
+                                }
+                            }
+                        }
+                        function.WriteLog("\r\n\r\n", "推荐下单奖励监控日志");
+                    }
+                }
+            }
+        }
+
         public void DoOrder(WebCMSEntities db, int OrderId)
         {
             Orders order = db.Orders.FirstOrDefault(m => m.Id == OrderId && m.Status == 0);

Startup.cs

@@ -90,9 +90,9 @@ namespace MySystem
             // services.AddHostedService<PopService>();
             // services.AddHostedService<SycnSpTimer>(); //同步SP数据
 
-            services.AddHostedService<TimerStatTimer>(); //实时统计创客、激活商户数
-            services.AddHostedService<PosTradeStatTimer>(); // 统计头天的交易额、商户型创客、激活奖励、开机奖励
-            services.AddHostedService<AlipayPayBack2Timer>(); //支付宝回调处理
+            // services.AddHostedService<TimerStatTimer>(); //实时统计创客、激活商户数
+            // services.AddHostedService<PosTradeStatTimer>(); // 统计头天的交易额、商户型创客、激活奖励、开机奖励
+            // services.AddHostedService<AlipayPayBack2Timer>(); //支付宝回调处理
 
             //services.AddHttpContextAccessor();
 
@@ -190,22 +190,22 @@ namespace MySystem
             // TradeStatTimer2.Instance.Start(); //交易统计
 
             //必须打开的
-            ActiveRewardTimer.Instance.Start(); //实时处理激活记录
-            TradeStatTimer.Instance.Start(); //交易统计
-            ChangePosTimer.Instance.Start(); //售后换新执行机具数据转移
-            MakeReferenceQrCodeService.Instance.StartListen(); //生成创客邀请二维码
-            SycnSpBindService.Instance.Start(); //同步SP绑定数据
-            SycnSpMerchantService.Instance.Start(); //同步SP商户数据
-            SycnSpActiveService.Instance.Start(); //同步SP激活数据
-            SycnSpTradeService.Instance.Start(); //同步SP交易数据
-            SycnSpChangeBindService.Instance.Start(); //同步SP换绑数据
-            SycnSpUnBindService.Instance.Start(); //同步SP解绑数据
-            RedPackageHelper.Instance.Start(); //每天生成300个红包
-            RedPackageHelper.Instance.StartStatTop10(); //红包活动统计排行
-            RedPackageHelper.Instance.StartSendPrize(); //红包活动发奖
-            BalancePayBackService.Instance.Start(); //余额支付队列
-            LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
-            MessageCenterService.Instance.Start(); // 消息队列
+            // ActiveRewardTimer.Instance.Start(); //实时处理激活记录
+            // TradeStatTimer.Instance.Start(); //交易统计
+            // ChangePosTimer.Instance.Start(); //售后换新执行机具数据转移
+            // MakeReferenceQrCodeService.Instance.StartListen(); //生成创客邀请二维码
+            // SycnSpBindService.Instance.Start(); //同步SP绑定数据
+            // SycnSpMerchantService.Instance.Start(); //同步SP商户数据
+            // SycnSpActiveService.Instance.Start(); //同步SP激活数据
+            // SycnSpTradeService.Instance.Start(); //同步SP交易数据
+            // SycnSpChangeBindService.Instance.Start(); //同步SP换绑数据
+            // SycnSpUnBindService.Instance.Start(); //同步SP解绑数据
+            // RedPackageHelper.Instance.Start(); //每天生成300个红包
+            // RedPackageHelper.Instance.StartStatTop10(); //红包活动统计排行
+            // RedPackageHelper.Instance.StartSendPrize(); //红包活动发奖
+            // BalancePayBackService.Instance.Start(); //余额支付队列
+            // LeaderPrizeService.Instance.Start(); //大盟主奖励发奖
+            // MessageCenterService.Instance.Start(); // 消息队列
             //必须打开的
 
             // StatService.Instance.StartPosActNum(); //实时统计激活数

appsettings.json

@@ -17,9 +17,9 @@
     "Host": "http://localhost:5047/",
     "SourceHost": "http://bs.kexiaoshuang.com/",
     "Database": "KxsMainServer",
-    "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;",
-    "SpSqlConnStr": "server=47.108.229.115;port=3306;user=KxsSpServer;password=jJ9qKsvwWgQA9xWG;database=KxsSpServer;charset=utf8;",
+    "SqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=Rw2imhXQQt5ODWIF;database=KxsMainServer;charset=utf8;",
+    "Pxc1SqlConnStr": "server=47.109.31.237;port=3306;user=KxsMainServer;password=Rw2imhXQQt5ODWIF;database=KxsMainServer;charset=utf8;",
+    "SpSqlConnStr": "server=47.109.31.237;port=3306;user=KxsSpServer;password=jJ9qKsvwWgQA9xWG;database=KxsSpServer;charset=utf8;",
     "RedisConnStr": "47.109.31.237:6379,password=klm@redis,DefaultDatabase=1,poolsize=500,preheat=50,asyncPipeline=true",
     "TendisConnStr": "47.109.31.237:6379,password=klm@redis,DefaultDatabase=1,poolsize=500,preheat=50,asyncPipeline=true",
     "IOSAppVersion": "1.0.0",