补机具券奖励队列

AppStart/AddPosCouponPrizeHelper.cs

@@ -0,0 +1,202 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Linq;
+using System.Data;
+using MySystem;
+using MySystem.PxcModels;
+using Library;
+using LitJson;
+
+public class AddPosCouponPrizeHelper
+{
+    public readonly static AddPosCouponPrizeHelper Instance = new AddPosCouponPrizeHelper();
+    private AddPosCouponPrizeHelper()
+    {
+    }
+
+    public void Start()
+    {
+        Thread th = new Thread(DoWorks);
+        th.IsBackground = true;
+        th.Start();
+    }
+
+    private void DoWorks()
+    {
+        while (true)
+        {
+            try
+            {
+                string content = RedisDbconn.Instance.RPop<string>("AddPosCouponPrizeQueue");
+                if(!string.IsNullOrEmpty(content))
+                {
+                    int oid = int.Parse(content);
+                    WebCMSEntities db = new WebCMSEntities();
+                    DoSomething(db, oid);
+                    db.Dispose();
+                }
+                else
+                {
+                    Thread.Sleep(60000);
+                }
+            }
+            catch (Exception ex)
+            {
+                function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "补下单机具券奖励异常");
+            }
+            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "补下单机具券奖励日志");
+        }
+    }
+
+    public void DoSomething(WebCMSEntities db, int OrderId)
+    {
+        List<int> ids = new List<int>();
+        ids.Add(10);
+        ids.Add(11);
+        ids.Add(77);
+        ids.Add(78);
+        ids.Add(79);
+        Orders order = db.Orders.FirstOrDefault(m => m.Status > 0 && m.Id == OrderId && ids.Contains(m.ProductId));
+        if(order != null)
+        {
+            OrderProduct pro = db.OrderProduct.FirstOrDefault(m => m.OrderId == order.Id) ?? new OrderProduct();
+            Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId) ?? new Users();
+            List<int> prizeChk = new List<int>();
+            if(!db.UserAccountRecord.Any(m => m.ChangeType == 112 && m.QueryCount == order.Id))
+            {
+                prizeChk.Add(1);
+            }
+            if(!db.UserAccountRecord.Any(m => m.ChangeType == 118 && m.QueryCount == order.Id))
+            {
+                prizeChk.Add(2);
+            }
+            if(!db.LeaderAccountRecord.Any(m => m.QueryCount == order.Id))
+            {
+                prizeChk.Add(3);
+            }
+            int ParentUserId = user.ParentUserId;
+            bool buyPrize = false;
+            bool OncePrizeFlag4 = true;
+            int leaderFlag = 0;
+            bool DirectPrizeFlag = true;
+            bool PosCouponFlag = true;
+            bool OperateFlag = true;
+            if(user.LeaderLevel > 0 || user.UserType == 1) //盟主或运营中心
+            {
+                //推荐奖励
+                if(prizeChk.Contains(1))
+                {
+                    AlipayPayBack2Service.Instance.DirectPrize(db, order.Id, order.UserId, pro.ProductCount);
+                }
+                DirectPrizeFlag = false;
+                UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == order.UserId) ?? new UserAccount();
+                if (acccount.LeaderReserve >= 400 * pro.ProductCount && !buyPrize)
+                {
+                    //购机奖励
+                    if(prizeChk.Contains(2))
+                    {
+                        AlipayPayBack2Service.Instance.OpAccount(db, order, order.UserId, 100, 1);
+                    }
+                    buyPrize = true;
+                }
+                if(user.LeaderLevel == 2 && PosCouponFlag)
+                {
+                    if(PosCouponLeader(db, user.Id, pro.ProductCount, order.SnNos.Split(',')))
+                    {
+                        PosCouponFlag = false;
+                    }
+                }
+                if(user.UserType == 1 && OperateFlag)
+                {
+                    PosCouponOp(db, user.Id, order.SnNos.Split(','));
+                    OperateFlag = false;
+                }
+            }
+            while (ParentUserId > 0)
+            {
+                Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
+                if(DirectPrizeFlag)
+                {
+                    if(prizeChk.Contains(1))
+                    {
+                        AlipayPayBack2Service.Instance.DirectPrize(db, order.Id, ParentUserId, pro.ProductCount);
+                    }
+                    DirectPrizeFlag = false;
+                }
+                if (puser.LeaderLevel > 0)
+                {
+                    UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id) ?? new UserAccount();
+                    if (acccount.LeaderReserve >= 400 * pro.ProductCount && !buyPrize)
+                    {
+                        //购机奖励
+                        if(prizeChk.Contains(2))
+                        {
+                            AlipayPayBack2Service.Instance.OpAccount(db, order, puser.Id, 100, 1);
+                        }
+                        buyPrize = true;
+                    }
+
+                    if (acccount.LeaderReserve >= 400 * pro.ProductCount && puser.LeaderLevel > leaderFlag && leaderFlag < 2 && OncePrizeFlag4)
+                    {
+                        if(prizeChk.Contains(3))
+                        {
+                            //扣减备用金
+                            AlipayPayBack2Service.Instance.OpReserve(db, order, puser.Id, 400 * pro.ProductCount, 2, order.UserId, "购机奖励");
+                            //返回到余额
+                            AlipayPayBack2Service.Instance.OpLeaderAccount(db, order, puser.Id, 400, pro.ProductCount);
+                        }
+                        leaderFlag = puser.LeaderLevel;
+                        OncePrizeFlag4 = false;
+                    }
+                }
+                if(puser.LeaderLevel == 2 && PosCouponFlag)
+                {
+                    if(PosCouponLeader(db, puser.Id, pro.ProductCount, order.SnNos.Split(',')))
+                    {
+                        PosCouponFlag = false;
+                    }
+                }
+                if(puser.UserType == 1 && OperateFlag)
+                {
+                    PosCouponOp(db, puser.Id, order.SnNos.Split(','));
+                    OperateFlag = false;
+                }
+                ParentUserId = puser.ParentUserId;
+            }            
+        }
+        db.Dispose();
+    }
+
+    public bool PosCouponLeader(WebCMSEntities db, int Id, int ProductCount, string[] Codes)
+    {
+        UserAccount pacccount = db.UserAccount.FirstOrDefault(m => m.Id == Id) ?? new UserAccount();
+        foreach(string Code in Codes)
+        {
+            PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.ExchangeCode == Code);
+            if(coupon != null && pacccount.LeaderReserve >= 400 * ProductCount)
+            {
+                coupon.LeaderUserId = Id;
+            }
+            else
+            {
+                return false;
+            }
+        }
+        db.SaveChanges();
+        return true;
+    }
+
+    public void PosCouponOp(WebCMSEntities db, int Id, string[] Codes)
+    {
+        foreach(string Code in Codes)
+        {
+            PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.ExchangeCode == Code);
+            if(coupon != null)
+            {
+                coupon.OpId = Id;
+            }
+        }
+        db.SaveChanges();
+    }
+}

Controllers/HomeController.cs

@@ -239,65 +239,101 @@ namespace MySystem.Controllers
             //     }
             // }
 
-            List<string> ordernos = new List<string>();
-            ordernos.Add("BM2023121215501796424073091");
-            foreach(string orderno in ordernos)
+            List<int> ids = new List<int>();
+            ids.Add(10);
+            ids.Add(11);
+            ids.Add(77);
+            ids.Add(78);
+            ids.Add(79);
+            DateTime Start = DateTime.Parse("2023-12-10 00:00:00");
+            List<Orders> orders = db.Orders.Where(m => m.Status > 0 && m.CreateDate >= Start && ids.Contains(m.ProductId)).ToList();
+            foreach(Orders order in orders)
             {
-                Orders order = db.Orders.FirstOrDefault(m => m.OrderNo == orderno);
-                if(order != null)
+                OrderProduct pro = db.OrderProduct.FirstOrDefault(m => m.OrderId == order.Id) ?? new OrderProduct();
+                Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId) ?? new Users();
+                List<int> prizeChk = new List<int>();
+                if(!db.UserAccountRecord.Any(m => m.ChangeType == 112 && m.QueryCount == order.Id))
+                {
+                    prizeChk.Add(1);
+                }
+                if(!db.UserAccountRecord.Any(m => m.ChangeType == 118 && m.QueryCount == order.Id))
+                {
+                    prizeChk.Add(2);
+                }
+                if(!db.LeaderAccountRecord.Any(m => m.QueryCount == order.Id))
                 {
-                    OrderProduct pro = db.OrderProduct.FirstOrDefault(m => m.OrderId == order.Id) ?? new OrderProduct();
-                    Users user = db.Users.FirstOrDefault(m => m.Id == order.UserId) ?? new Users();
-                    int ParentUserId = user.ParentUserId;
-                    bool buyPrize = false;
-                    bool OncePrizeFlag4 = true;
-                    int leaderFlag = 0;
-                    bool DirectPrizeFlag = true;
-                    if(user.LeaderLevel > 0 || user.UserType == 1) //盟主或运营中心
+                    prizeChk.Add(3);
+                }
+                int ParentUserId = user.ParentUserId;
+                bool buyPrize = false;
+                bool OncePrizeFlag4 = true;
+                int leaderFlag = 0;
+                bool DirectPrizeFlag = true;
+                if(user.LeaderLevel > 0 || user.UserType == 1) //盟主或运营中心
+                {
+                    //推荐奖励
+                    if(prizeChk.Contains(1))
                     {
-                        //推荐奖励
-                        // AlipayPayBack2Service.Instance.DirectPrize(db, order.Id, order.UserId, pro.ProductCount);
-                        DirectPrizeFlag = false;
+                        AlipayPayBack2Service.Instance.DirectPrize(db, order.Id, order.UserId, pro.ProductCount);
                     }
-                    while (ParentUserId > 0)
+                    DirectPrizeFlag = false;
+                    UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == order.UserId) ?? new UserAccount();
+                    if (acccount.LeaderReserve >= 400 * pro.ProductCount && !buyPrize)
                     {
-                        Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
-                        if(DirectPrizeFlag)
+                        //购机奖励
+                        if(prizeChk.Contains(2))
                         {
-                            // AlipayPayBack2Service.Instance.DirectPrize(db, order.Id, ParentUserId, pro.ProductCount);
-                            DirectPrizeFlag = false;
+                            AlipayPayBack2Service.Instance.OpAccount(db, order, order.UserId, 100, 1);
                         }
-                        if (puser.LeaderLevel > 0)
+                        buyPrize = true;
+                    }
+                }
+                while (ParentUserId > 0)
+                {
+                    Users puser = db.Users.FirstOrDefault(m => m.Id == ParentUserId) ?? new Users();
+                    if(DirectPrizeFlag)
+                    {
+                        if(prizeChk.Contains(1))
                         {
-
-                            UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id) ?? new UserAccount();
-                            if (acccount.LeaderReserve >= 400 * pro.ProductCount && !buyPrize)
+                            AlipayPayBack2Service.Instance.DirectPrize(db, order.Id, ParentUserId, pro.ProductCount);
+                        }
+                        DirectPrizeFlag = false;
+                    }
+                    if (puser.LeaderLevel > 0)
+                    {
+                        UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == puser.Id) ?? new UserAccount();
+                        if (acccount.LeaderReserve >= 400 * pro.ProductCount && !buyPrize)
+                        {
+                            //购机奖励
+                            if(prizeChk.Contains(2))
                             {
-                                //购机奖励
                                 AlipayPayBack2Service.Instance.OpAccount(db, order, puser.Id, 100, 1);
-                                buyPrize = true;
                             }
+                            buyPrize = true;
+                        }
 
-                            if (acccount.LeaderReserve >= 400 * pro.ProductCount && puser.LeaderLevel > leaderFlag && leaderFlag < 2 && OncePrizeFlag4)
+                        if (acccount.LeaderReserve >= 400 * pro.ProductCount && puser.LeaderLevel > leaderFlag && leaderFlag < 2 && OncePrizeFlag4)
+                        {
+                            if(prizeChk.Contains(3))
                             {
                                 //扣减备用金
                                 AlipayPayBack2Service.Instance.OpReserve(db, order, puser.Id, 400 * pro.ProductCount, 2, order.UserId, "购机奖励");
                                 //返回到余额
                                 AlipayPayBack2Service.Instance.OpLeaderAccount(db, order, puser.Id, 400, pro.ProductCount);
-                                leaderFlag = puser.LeaderLevel;
-                                OncePrizeFlag4 = false;
                             }
+                            leaderFlag = puser.LeaderLevel;
+                            OncePrizeFlag4 = false;
                         }
-                        ParentUserId = puser.ParentUserId;
                     }
-
-                    //购买盟主奖励
-                    // decimal Prize = decimal.Parse(function.CheckNum(PublicFunction.GetPublicParam(db, "BigLeaderPrize")));
-                    // if(Prize > 0)
-                    // {
-                    //     AlipayPayBack2Service.Instance.LeaderRecommendPrize(db, order, 565, Prize, 122);
-                    // }
+                    ParentUserId = puser.ParentUserId;
                 }
+
+                //购买盟主奖励
+                // decimal Prize = decimal.Parse(function.CheckNum(PublicFunction.GetPublicParam(db, "BigLeaderPrize")));
+                // if(Prize > 0)
+                // {
+                //     AlipayPayBack2Service.Instance.LeaderRecommendPrize(db, order, 565, Prize, 122);
+                // }
             }
             db.Dispose();
 

Startup.cs

@@ -223,6 +223,7 @@ namespace MySystem
                 LeaderApplyCouponsHelper.Instance.Start(); //盟主储蓄金申请机具券打标记
                 DepositReturnService.Instance.Start(); //退押金到支付宝余额
                 StoreApplyHelper.Instance.ResetStoreReserve(); //重置分仓额度
+                AddPosCouponPrizeHelper.Instance.Start(); //补机具券奖励
 
                 // TestHelper.Instance.Start();
             }