kxs-main/AppStart/Helper/PosCouponPrize/PosCouponPrizeTest.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Data;
using System.Threading;
using MySystem.PxcModels;
using Library;
using LitJson;

namespace MySystem
{
    public class PosCouponPrizeTest
    {
        public readonly static PosCouponPrizeTest Instance = new PosCouponPrizeTest();
        private PosCouponPrizeTest()
        { }

        public void Start()
        {
            Thread th = new Thread(StartDo);
            th.IsBackground = true;
            th.Start();
        }

        public void StartDo()
        {
            List<int> ids = new List<int>();
            ids.Add(513534);
            ids.Add(513546);
            ids.Add(513558);
            ids.Add(513565);
            ids.Add(513572);
            ids.Add(513573);
            ids.Add(513592);
            ids.Add(513611);
            ids.Add(513619);
            ids.Add(513639);
            ids.Add(513649);
            ids.Add(513677);
            ids.Add(513696);
            ids.Add(513700);
            ids.Add(513713);
            ids.Add(513723);
            ids.Add(513742);
            ids.Add(513766);
            ids.Add(513791);
            ids.Add(513794);
            ids.Add(513801);
            ids.Add(513803);
            ids.Add(513808);
            ids.Add(513816);
            ids.Add(513821);
            ids.Add(513832);
            ids.Add(513861);
            ids.Add(513896);
            ids.Add(513907);
            ids.Add(513918);
            ids.Add(513921);
            ids.Add(513982);
            ids.Add(513994);
            ids.Add(513995);
            ids.Add(514008);
            ids.Add(514037);
            ids.Add(514057);
            ids.Add(514068);
            ids.Add(514081);
            ids.Add(514089);
            ids.Add(514097);
            ids.Add(514122);
            ids.Add(514129);
            ids.Add(514136);
            ids.Add(514159);
            ids.Add(514181);
            ids.Add(514191);
            ids.Add(514193);
            ids.Add(514197);
            ids.Add(514201);
            ids.Add(514208);
            ids.Add(514212);
            ids.Add(514218);
            ids.Add(514222);
            ids.Add(514229);
            ids.Add(514234);
            ids.Add(514257);
            ids.Add(514264);
            ids.Add(514265);
            ids.Add(514266);
            ids.Add(514270);
            ids.Add(514272);
            ids.Add(514275);
            ids.Add(514278);
            ids.Add(514313);
            ids.Add(514316);
            ids.Add(514325);
            ids.Add(514335);
            ids.Add(514337);
            ids.Add(514338);
            ids.Add(514365);
            ids.Add(514371);
            ids.Add(514373);
            ids.Add(514386);
            ids.Add(514392);
            ids.Add(514401);
            ids.Add(514412);
            ids.Add(514421);
            ids.Add(514424);
            ids.Add(514427);
            ids.Add(514428);
            ids.Add(514436);
            ids.Add(514448);
            ids.Add(514479);
            ids.Add(514488);
            ids.Add(514498);
            ids.Add(514504);
            ids.Add(514517);
            ids.Add(514522);
            ids.Add(514557);
            ids.Add(514571);
            ids.Add(514584);
            ids.Add(514606);
            ids.Add(514651);
            ids.Add(514698);
            ids.Add(514718);
            ids.Add(514733);
            ids.Add(514789);
            ids.Add(514800);
            ids.Add(514839);
            ids.Add(514864);
            ids.Add(514867);
            ids.Add(514869);
            ids.Add(514931);
            ids.Add(514937);
            ids.Add(514942);
            ids.Add(514990);
            ids.Add(515002);
            ids.Add(515039);
            ids.Add(515082);
            ids.Add(515088);
            ids.Add(515116);
            ids.Add(515120);
            ids.Add(515136);
            ids.Add(515138);
            ids.Add(515160);
            ids.Add(515214);
            ids.Add(515216);
            ids.Add(515220);
            ids.Add(515224);
            ids.Add(515228);
            ids.Add(515234);
            ids.Add(515236);
            ids.Add(515247);
            ids.Add(515253);
            ids.Add(515266);
            ids.Add(515269);
            ids.Add(515273);
            ids.Add(515275);
            ids.Add(515282);
            ids.Add(515301);
            ids.Add(515306);
            ids.Add(515307);
            ids.Add(515352);
            ids.Add(515381);
            ids.Add(515393);
            ids.Add(515409);
            ids.Add(515471);
            ids.Add(515480);
            ids.Add(515488);
            ids.Add(515493);
            ids.Add(515497);
            ids.Add(515500);
            ids.Add(515521);
            ids.Add(515537);
            ids.Add(515550);
            ids.Add(515551);
            ids.Add(515556);
            ids.Add(515569);
            ids.Add(515572);
            ids.Add(515594);
            ids.Add(515667);
            ids.Add(515706);
            ids.Add(515762);
            ids.Add(515781);
            ids.Add(515820);
            ids.Add(515835);
            ids.Add(515841);
            ids.Add(515848);
            ids.Add(515851);
            ids.Add(515867);
            ids.Add(515876);
            ids.Add(515883);
            ids.Add(515898);
            ids.Add(515909);
            ids.Add(515937);
            ids.Add(515942);
            ids.Add(515952);
            ids.Add(515953);
            ids.Add(515959);
            ids.Add(515973);
            ids.Add(515986);
            ids.Add(515996);
            ids.Add(515998);
            ids.Add(515999);
            ids.Add(516002);
            ids.Add(516007);
            ids.Add(516010);
            ids.Add(516013);
            ids.Add(516018);
            ids.Add(516020);
            ids.Add(516023);
            ids.Add(516055);
            ids.Add(516078);
            ids.Add(516095);
            ids.Add(516117);
            ids.Add(516127);
            ids.Add(516143);
            ids.Add(516157);
            ids.Add(516181);
            ids.Add(516214);
            ids.Add(516227);
            ids.Add(516231);
            ids.Add(516234);
            ids.Add(516245);
            ids.Add(516251);
            ids.Add(516258);
            ids.Add(516263);
            ids.Add(516265);
            ids.Add(516268);
            ids.Add(516290);
            ids.Add(516302);
            ids.Add(516305);
            ids.Add(516309);
            ids.Add(516310);
            ids.Add(516311);
            ids.Add(516323);
            ids.Add(516326);
            ids.Add(516332);
            ids.Add(516336);
            ids.Add(516338);
            ids.Add(516343);
            ids.Add(516350);
            ids.Add(516351);
            ids.Add(516354);
            ids.Add(516371);
            ids.Add(516380);
            ids.Add(516389);
            ids.Add(516398);
            ids.Add(516408);
            ids.Add(516412);
            ids.Add(516417);
            ids.Add(516435);
            ids.Add(516445);
            ids.Add(516449);
            ids.Add(516451);
            ids.Add(516452);
            ids.Add(516463);
            ids.Add(516472);
            ids.Add(516493);
            ids.Add(516495);
            ids.Add(516496);
            ids.Add(516497);
            ids.Add(516511);
            ids.Add(516512);
            ids.Add(516520);
            ids.Add(516522);
            ids.Add(516529);
            ids.Add(516534);
            ids.Add(516535);
            ids.Add(516537);
            ids.Add(516543);
            ids.Add(516549);
            ids.Add(516552);
            ids.Add(516557);
            ids.Add(516560);
            ids.Add(516563);
            ids.Add(516566);
            ids.Add(516569);
            ids.Add(516570);
            ids.Add(516586);
            ids.Add(516590);
            ids.Add(516592);
            ids.Add(516604);
            ids.Add(516608);
            ids.Add(516609);
            ids.Add(516616);
            ids.Add(516619);
            ids.Add(516631);
            ids.Add(516632);
            ids.Add(516633);
            ids.Add(516636);
            ids.Add(516637);
            ids.Add(516647);
            ids.Add(516653);
            ids.Add(516654);
            ids.Add(516656);
            ids.Add(516657);
            ids.Add(516665);
            ids.Add(516668);
            ids.Add(516691);
            ids.Add(516699);
            ids.Add(516708);
            ids.Add(516713);
            ids.Add(516719);
            ids.Add(516720);
            ids.Add(516744);
            ids.Add(516746);
            ids.Add(516757);
            ids.Add(516772);
            ids.Add(516777);
            ids.Add(516815);
            ids.Add(516818);
            ids.Add(516844);
            ids.Add(516851);
            ids.Add(516857);
            ids.Add(516862);
            ids.Add(516868);
            ids.Add(516870);
            ids.Add(516883);
            ids.Add(516886);
            ids.Add(516889);
            ids.Add(516892);
            ids.Add(516894);
            ids.Add(516905);
            ids.Add(516909);
            ids.Add(516911);
            ids.Add(516928);
            ids.Add(516929);
            ids.Add(516930);
            ids.Add(516940);
            ids.Add(516945);
            ids.Add(516946);
            ids.Add(516947);
            ids.Add(516948);
            ids.Add(516953);
            ids.Add(516955);
            ids.Add(516956);
            ids.Add(516959);
            ids.Add(516970);
            ids.Add(516978);
            ids.Add(516981);
            ids.Add(516982);
            ids.Add(516983);
            ids.Add(516989);
            ids.Add(516993);
            ids.Add(517001);
            ids.Add(517007);
            ids.Add(517009);
            ids.Add(517023);
            ids.Add(517024);
            ids.Add(517037);
            ids.Add(517045);
            ids.Add(517047);
            ids.Add(517051);
            ids.Add(517052);
            ids.Add(517059);
            ids.Add(517060);
            ids.Add(517079);
            ids.Add(517088);
            ids.Add(517101);
            ids.Add(517102);
            ids.Add(517108);
            ids.Add(517109);
            ids.Add(517111);
            ids.Add(517115);
            ids.Add(517119);
            ids.Add(517121);
            ids.Add(517122);
            ids.Add(517124);
            ids.Add(517129);
            ids.Add(517146);
            ids.Add(517147);
            ids.Add(517152);
            ids.Add(517163);
            ids.Add(517171);
            ids.Add(517191);
            ids.Add(517192);
            ids.Add(517194);
            ids.Add(517205);
            ids.Add(517207);
            ids.Add(517211);
            ids.Add(517212);
            ids.Add(517214);
            ids.Add(517218);
            ids.Add(517220);
            ids.Add(517223);
            ids.Add(517224);
            ids.Add(517230);
            ids.Add(517234);
            ids.Add(517237);
            ids.Add(517238);
            ids.Add(517242);
            ids.Add(517250);
            ids.Add(517252);
            ids.Add(517255);
            ids.Add(517266);
            ids.Add(517268);
            ids.Add(517275);
            ids.Add(517278);
            ids.Add(517281);
            ids.Add(517290);
            ids.Add(517296);
            ids.Add(517297);
            ids.Add(517311);
            ids.Add(517317);
            ids.Add(517340);
            ids.Add(517344);
            ids.Add(517346);
            ids.Add(517348);
            ids.Add(517356);
            ids.Add(517357);
            ids.Add(517363);
            ids.Add(517364);
            ids.Add(517366);
            ids.Add(517379);
            ids.Add(517382);
            ids.Add(517383);
            ids.Add(517386);
            ids.Add(517389);
            ids.Add(517391);
            ids.Add(517396);
            ids.Add(517397);
            ids.Add(517398);
            ids.Add(517401);
            ids.Add(517404);
            ids.Add(517407);
            ids.Add(517408);
            ids.Add(517410);
            ids.Add(517419);
            ids.Add(517427);
            ids.Add(517428);
            ids.Add(517438);
            ids.Add(517439);
            ids.Add(517450);
            ids.Add(517452);
            ids.Add(517454);
            ids.Add(517455);
            ids.Add(517456);
            ids.Add(517463);
            ids.Add(517475);
            ids.Add(517511);
            ids.Add(517516);
            ids.Add(517519);
            ids.Add(517522);
            ids.Add(517524);
            ids.Add(517531);
            ids.Add(517533);
            ids.Add(517535);
            ids.Add(517539);
            ids.Add(517542);
            ids.Add(517544);
            ids.Add(517546);
            ids.Add(517549);
            ids.Add(517551);
            ids.Add(517553);
            ids.Add(517581);
            ids.Add(517588);
            ids.Add(517598);
            ids.Add(517638);
            ids.Add(517642);
            ids.Add(517643);
            ids.Add(517651);
            ids.Add(517656);
            ids.Add(517668);
            ids.Add(517678);
            ids.Add(517691);
            ids.Add(517698);
            ids.Add(517704);
            ids.Add(517708);
            ids.Add(517723);
            ids.Add(517739);
            ids.Add(517746);
            ids.Add(517770);
            ids.Add(517794);
            ids.Add(517817);
            ids.Add(517826);
            ids.Add(517848);
            ids.Add(517867);
            ids.Add(517908);
            ids.Add(517909);
            ids.Add(517930);
            ids.Add(517931);
            ids.Add(517984);
            ids.Add(517986);
            ids.Add(517994);
            ids.Add(518019);
            ids.Add(518020);
            ids.Add(518029);
            ids.Add(518037);
            ids.Add(518061);
            ids.Add(518062);
            ids.Add(518063);
            ids.Add(518082);
            ids.Add(518100);
            ids.Add(518102);
            ids.Add(518109);
            ids.Add(518125);
            ids.Add(518139);
            ids.Add(518164);
            ids.Add(518166);
            ids.Add(518185);
            ids.Add(518189);
            ids.Add(518197);
            ids.Add(518198);
            ids.Add(518201);
            ids.Add(518211);
            ids.Add(518227);
            ids.Add(518229);
            ids.Add(518234);
            ids.Add(518236);
            ids.Add(518239);
            ids.Add(518243);
            ids.Add(518255);
            ids.Add(518263);
            ids.Add(518278);
            ids.Add(518303);
            ids.Add(518312);
            ids.Add(518317);
            ids.Add(518319);
            ids.Add(518323);
            ids.Add(518325);
            ids.Add(518340);
            ids.Add(518341);
            ids.Add(518353);
            ids.Add(518355);
            ids.Add(518357);
            ids.Add(518361);
            ids.Add(518363);
            ids.Add(518380);
            ids.Add(518384);
            ids.Add(518396);
            ids.Add(518437);
            ids.Add(518442);
            ids.Add(518446);
            ids.Add(518452);
            ids.Add(518453);
            ids.Add(518456);
            ids.Add(518462);
            ids.Add(518464);
            ids.Add(518507);
            ids.Add(518597);
            ids.Add(518600);
            ids.Add(518606);
            ids.Add(518626);
            ids.Add(518656);
            ids.Add(518708);
            ids.Add(518738);
            ids.Add(518754);
            ids.Add(518759);
            ids.Add(518762);
            ids.Add(518772);
            ids.Add(518781);
            ids.Add(518790);
            ids.Add(518793);
            ids.Add(518796);
            ids.Add(518808);
            ids.Add(518844);
            ids.Add(518858);
            ids.Add(518887);
            ids.Add(518894);
            ids.Add(518895);
            ids.Add(518901);
            ids.Add(518914);
            ids.Add(518923);
            ids.Add(518935);
            ids.Add(518941);
            ids.Add(518942);
            ids.Add(518967);
            ids.Add(518979);
            ids.Add(518991);
            ids.Add(518992);
            ids.Add(518994);
            ids.Add(518998);
            ids.Add(519002);
            ids.Add(519016);
            ids.Add(519035);
            ids.Add(519036);
            ids.Add(519062);
            ids.Add(519075);
            foreach(int OrderId in ids)
            {
                PosCouponPrizeTest.Instance.dosomething(OrderId);
            }
        }

        public void dosomething(int OrderId)
        { 
            WebCMSEntities db = new WebCMSEntities();
            OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
            Orders order = db.Orders.FirstOrDefault(m => m.Id == OrderId);
            if(order != null)
            {
                List<int> ChkIds = new List<int>(); //机具券商品Id集合
                ChkIds.Add(10);
                ChkIds.Add(11);
                ChkIds.Add(77);
                ChkIds.Add(78);
                ChkIds.Add(79);
                ChkIds.Add(92);
                // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:商品id是（10,11,77,78,79,91）;当前订单商品Id:" + order.ProductId + "");
                //判断是否是指定商品
                if(ChkIds.Contains(order.ProductId))
                {
                    // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足条件");
                    int Kind = 0;
                    if (order.ProductId == 10)
                    {
                        Kind = 1;
                    }
                    else if (order.ProductId == 11)
                    {
                        Kind = 2;
                    }
                    int CouponCount = 0;
                    if(Kind == 1)
                    {
                        CouponCount = 3 * order.BuyCount;
                    }
                    else if(Kind == 2)
                    {
                        CouponCount = 2 * order.BuyCount;
                    }


                    UserRankItem orderUser = GetUserLevel(order.UserId);
                    if(orderUser.UserLevel == 0) 
                    {
                        PreUserLevel(db, order.UserId, 1, DateTime.Parse("2025-01-01 00:00:00"));
                    }
                    List<string> codes = function.CheckNull(order.SnNos).Split(',').ToList();
                    string ParentNav = orderUser.ParentNav + "," + orderUser.Id + ",";
                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                    Array.Reverse(ParentNavList);
                    int index = 0;
                    bool DirectPrizeFlag = false; //推荐奖励发放标识
                    int BuyPrizeFlag = 0; //购机奖励发放标识
                    bool BackAccountFlag = false; //备用金返余额标识
                    bool BigLeaderFlag = false; //大盟主标记
                    decimal BuyPrize = 0; //购机奖励
                    // Utils.Instance.PrizeRecord(2, order.OrderNo, "开始向上递归查找");
                    foreach(string ParentId in ParentNavList)
                    {
                        UserRankItem parentUser = GetUserLevel(int.Parse(ParentId));
                        if(parentUser.Id > 0)
                        {
                            // Utils.Instance.PrizeRecord(2, order.OrderNo, "创客编号:" + parentUser.MakerCode + ";创客姓名:" + parentUser.RealName + ";");
                            index += 1;
                            if(index == 1)
                            {
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:下单人是盟主;下单人盟主等级:" + orderUser.LeaderLevel + "");
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:下单人是运营中心或合伙人;下单人合伙人等级:" + orderUser.OperateLevel + "");
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:推荐奖励是否已发放;当前状态:" + DirectPrizeFlag + "");
                            }
                            if(index == 1 && (orderUser.LeaderLevel > 0 || orderUser.OperateLevel > 0) && !DirectPrizeFlag)
                            {
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足条件，发放推荐奖励给下单人");
                                // DirectPrize(db, order.Id, order.UserId, order.BuyCount);
                                DirectPrizeFlag = true;
                            }
                            if(index > 1)
                            {
                                bool IsStandardUser = Utils.Instance.IsStandardUser(parentUser.Id);
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:上级是有效创客;是否有效创客:" + IsStandardUser + "");
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:推荐奖励是否已发放;当前状态:" + DirectPrizeFlag + "");
                                if(IsStandardUser && !DirectPrizeFlag)
                                {
                                    // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足条件，发放推荐奖励给上级");
                                    // DirectPrize(db, order.Id, parentUser.Id, order.BuyCount);
                                    DirectPrizeFlag = true;
                                }
                            }
                            // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:创客是盟主;创客盟主等级:" + parentUser.AgoLeaderLevel + "");
                            // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:盟主储备金是否充足;");
                            // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:创客是运营中心或合伙人;合伙人等级:" + parentUser.AgoLeaderLevel + "");
                            // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:合伙人未使用额度是否充足;");
                            if(parentUser.AgoLeaderLevel > 0 && CheckLeaderReserve(db, order.BuyCount, parentUser.Id))
                            {
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足条件，发放购机奖");
                                //购机奖
                                if(parentUser.LeaderLevel > 0)
                                {
                                    decimal CurBuyPrize = GetBuyPrize(parentUser, order);
                                    decimal GetPrize = CurBuyPrize - BuyPrize;
                                    // Utils.Instance.PrizeRecord(2, order.OrderNo, "发放金额:" + GetPrize);
                                    if(GetPrize > 0 && BuyPrizeFlag < 2)
                                    {
                                        bool PrizeFlag = true;
                                        int ChangeType = 118;
                                        if(parentUser.OperateLevel == 1)
                                        {
                                            ChangeType = 120;
                                        }
                                        if(parentUser.OperateLevel > 1)
                                        {
                                            ChangeType = 128;
                                            if(function.CheckNull(RedisDbconn.Instance.Get<string>("YingXunUser")).Contains("," + orderUser.Id + ","))
                                            {
                                                PrizeFlag = false;
                                            }
                                        }
                                        if(PrizeFlag)
                                        {
                                            // OpAccount(db, order.Id, parentUser.Id, CurBuyPrize - BuyPrize, order.BuyCount, ChangeType);
                                            if(GetPrize == 160) BuyPrizeFlag = 2;
                                            else if(GetPrize == 60) BuyPrizeFlag = 2;
                                            else BuyPrizeFlag = 1;
                                        }
                                        BuyPrize = CurBuyPrize;
                                    }
                                    if(parentUser.OperateLevel == 2 && CurBuyPrize == 100) BuyPrizeFlag = 2;
                                }
                                else if(parentUser.OperateLevel > 0 && CheckOpReserve(opdb, order.BuyCount, parentUser.Id) && BuyPrizeFlag < 2)
                                {
                                    // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足条件，发放购机奖");
                                    //购机奖
                                    decimal CurBuyPrize = GetBuyPrize(parentUser, order);
                                    decimal GetPrize = CurBuyPrize - BuyPrize;
                                    // Utils.Instance.PrizeRecord(2, order.OrderNo, "发放金额:" + GetPrize);
                                    if(GetPrize > 0)
                                    {
                                        int ChangeType = 120;
                                        if(parentUser.OperateLevel > 1)
                                        {
                                            ChangeType = 128;
                                        }
                                        // OpAccount(db, order.Id, parentUser.Id, GetPrize, order.BuyCount, ChangeType);
                                        BuyPrize = CurBuyPrize;
                                        if(GetPrize == 160) BuyPrizeFlag = 2;
                                        else if(GetPrize == 60) BuyPrizeFlag = 2;
                                        else BuyPrizeFlag = 1;
                                    }
                                    if(parentUser.OperateLevel == 2 && CurBuyPrize == 100) BuyPrizeFlag = 2; 

                                    if(!BackAccountFlag)
                                    {
                                        BackAccountFlag = true;
                                        decimal GetAmount = GetWithdrawMoney(parentUser) * order.BuyCount;
                                        //扣减备用金
                                        // OperateAmountChange(opdb, parentUser.Id, GetAmount, 2, 1, "商城购机", true, order.Id);
                                        // //返回到余额
                                        // OperateAmountChange(opdb, parentUser.Id, GetAmount, 1, 2, "商城购机", true, order.Id);

                                        // OpAmountItem item = new OpAmountItem()
                                        // {
                                        //     UserId = parentUser.Id,
                                        //     OperateType = 0,
                                        //     ChangeType = 5,
                                        //     Remark = "商城购机",
                                        //     UseAmount = GetAmount,
                                        //     UseValidForGetAmount = GetAmount,
                                        //     UseTotalAmt = GetAmount,
                                        //     DataType = 1,
                                        //     DataId = order.Id,
                                        // };
                                        // RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
                                    }
                                }

                                if(!BackAccountFlag)
                                {
                                    BackAccountFlag = true;
                                    //扣减备用金
                                    // int ReserveRecordId = OpReserve(db, order.Id, parentUser.Id, GetWithdrawMoney(parentUser) * order.BuyCount, 2, order.UserId, "购机奖励");
                                    //返回到余额
                                    // OpLeaderAccount(db, order, parentUser.Id, GetWithdrawMoney(parentUser), order.BuyCount, ReserveRecordId);
                                }

                                //给券打大盟主标记
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:创客是盟主;创客盟主等级:" + parentUser.LeaderLevel + "");
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "条件:盟主储备金是否充足;");
                                if(parentUser.LeaderLevel == 1 && CheckLeaderReserve(db, order.BuyCount, parentUser.Id) && !BigLeaderFlag)
                                {
                                    // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足小盟主条件，开始检查大盟主关联的额度");
                                    // int LeaderId = CheckPosCouponLeaderFlag(db, parentUser.Id, order.BuyCount, codes);
                                    // if(LeaderId > 0)
                                    // {
                                    //     BigLeaderFlag = true;
                                    //     // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足条件，大盟主标记打给" + LeaderId);
                                    // }
                                }
                                else if(parentUser.LeaderLevel == 2 && !BigLeaderFlag)
                                {
                                    // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足大盟主条件，大盟主标记打给" + parentUser.Id + ",对应机具券:" + order.SnNos);
                                    BigLeaderFlag = true;
                                    if(!string.IsNullOrEmpty(order.SnNos))
                                    {
                                        List<int> couponIds = db.PosCoupons.Where(m => codes.Contains(m.ExchangeCode)).OrderBy(m => m.Id).Take(CouponCount).ToList().Select(m => m.Id).ToList();
                                        // Utils.Instance.PrizeRecord(2, order.OrderNo, "开始打标记，数量:" + couponIds.Count);
                                        // SetPosCouponLeaderFlag(db, parentUser.Id, order.BuyCount, couponIds);
                                        // Utils.Instance.PrizeRecord(2, order.OrderNo, "结束打标记");
                                    }
                                }
                            }
                            else if(parentUser.OperateLevel > 0 && CheckOpReserve(opdb, order.BuyCount, parentUser.Id) && BuyPrizeFlag < 2)
                            {
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "满足条件，发放购机奖");
                                //购机奖
                                decimal CurBuyPrize = GetBuyPrize(parentUser, order);
                                decimal GetPrize = CurBuyPrize - BuyPrize;
                                // Utils.Instance.PrizeRecord(2, order.OrderNo, "发放金额:" + GetPrize);
                                if(GetPrize > 0)
                                {
                                    int ChangeType = 120;
                                    if(parentUser.OperateLevel > 1)
                                    {
                                        ChangeType = 128;
                                    }
                                    // OpAccount(db, order.Id, parentUser.Id, GetPrize, order.BuyCount, ChangeType);
                                    BuyPrize = CurBuyPrize;
                                    if(GetPrize == 160) BuyPrizeFlag = 2;
                                    else if(GetPrize == 60) BuyPrizeFlag = 2;
                                    else BuyPrizeFlag = 1;
                                }
                                if(parentUser.OperateLevel == 2 && CurBuyPrize == 100) BuyPrizeFlag = 2; 

                                if(!BackAccountFlag)
                                {
                                    BackAccountFlag = true;
                                    decimal GetAmount = GetWithdrawMoney(parentUser) * order.BuyCount;
                                    //扣减备用金
                                    // OperateAmountChange(opdb, parentUser.Id, GetAmount, 2, 1, "商城购机", true, order.Id);
                                    // //返回到余额
                                    // OperateAmountChange(opdb, parentUser.Id, GetAmount, 1, 2, "商城购机", true, order.Id);

                                    // OpAmountItem item = new OpAmountItem()
                                    // {
                                    //     UserId = parentUser.Id,
                                    //     OperateType = 0,
                                    //     ChangeType = 5,
                                    //     Remark = "商城购机",
                                    //     UseAmount = GetAmount,
                                    //     UseValidForGetAmount = GetAmount,
                                    //     UseTotalAmt = GetAmount,
                                    //     DataType = 1,
                                    //     DataId = order.Id,
                                    // };
                                    // RedisDbconn.Instance.AddList("OperateAmountRecordServiceQueue", item);
                                }
                            }
                        }
                    }
                }
            }
            db.Dispose();
            opdb.Dispose();
        }


        public void StartTmp()
        {
            Thread th = new Thread(tmpuse);
            th.IsBackground = true;
            th.Start();
        }

        public void tmpuse()
        { 
            List<string> OrderNos = new List<string>();
            // OrderNos.Add("BM2024060113545453402672795");

            List<int> ChkIds = new List<int>(); //机具券商品Id集合
            ChkIds.Add(10);
            ChkIds.Add(11);
            ChkIds.Add(77);
            ChkIds.Add(78);
            ChkIds.Add(79);
            ChkIds.Add(92);
            DateTime chkDate = DateTime.Parse("2024-06-01 00:00:00");
            WebCMSEntities db = new WebCMSEntities();
            OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
            List<Orders> orders = db.Orders.Where(m => m.CreateDate >= chkDate && OrderNos.Contains(m.OrderNo) && ChkIds.Contains(m.ProductId) && m.Status > 0).ToList();
            foreach(Orders order in orders)
            {
                int Kind = 0;
                if (order.ProductId == 10)
                {
                    Kind = 1;
                }
                else if (order.ProductId == 11)
                {
                    Kind = 2;
                }
                int CouponCount = 0;
                if(Kind == 1)
                {
                    CouponCount = 3 * order.BuyCount;
                }
                else if(Kind == 2)
                {
                    CouponCount = 2 * order.BuyCount;
                }

                UserAccountRecord record = db.UserAccountRecord.FirstOrDefault(m => m.Id >= 4579675 && m.QueryCount == order.Id && m.ChangeType == 112) ?? new UserAccountRecord();

                UserRankItem orderUser = GetUserLevel2(order.UserId, order.PayDate.Value);
                if(orderUser.UserLevel == 0) 
                {
                    PreUserLevel(db, order.UserId, 1, DateTime.Parse("2025-01-01 00:00:00"));
                }
                string ParentNav = orderUser.ParentNav + "," + orderUser.Id + ",";
                string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                Array.Reverse(ParentNavList);
                int index = 0;
                bool DirectPrizeFlag = false; //推荐奖励发放标识
                foreach(string ParentId in ParentNavList)
                {
                    UserRankItem parentUser = GetUserLevel2(int.Parse(ParentId), order.PayDate.Value);
                    index += 1;
                    if(index == 1 && (orderUser.LeaderLevel > 0 || orderUser.OperateLevel > 0) && !DirectPrizeFlag)
                    {
                        // DirectPrize(db, order.Id, order.UserId, order.BuyCount);
                        if(record.UserId != order.UserId) function.WriteLog("下单人--订单号:" + order.OrderNo + ";应发对象:" + order.UserId + ";实发对象:" + record.UserId + ";发放金额:" + order.BuyCount + "00;", "推荐奖励计算");
                        DirectPrizeFlag = true;
                    }
                    if(index > 1)
                    {
                        if(Utils.Instance.IsStandardUser2(parentUser.Id, order.PayDate.Value) && !DirectPrizeFlag)
                        {
                            // DirectPrize(db, order.Id, parentUser.Id, order.BuyCount);
                            if(record.UserId != parentUser.Id) function.WriteLog("上级--订单号:" + order.OrderNo + ";应发对象:" + parentUser.Id + ";实发对象:" + record.UserId + ";发放金额:" + order.BuyCount + "00;", "推荐奖励计算");
                            DirectPrizeFlag = true;
                        }
                    }
                }
                if(!DirectPrizeFlag && record.Id == 0)
                {
                    function.WriteLog("没发--订单号:" + order.OrderNo + ";发放金额:" + order.BuyCount + "00;", "推荐奖励计算");
                }
            }
            db.Dispose();
            opdb.Dispose();
        }





        public void Start2()
        {
            Thread th = new Thread(ready2);
            th.IsBackground = true;
            th.Start();
        }
        
        private void ready2()
        { 
            bool op = true;
            while (op)
            {
                string content = RedisDbconn.Instance.RPop<string>("PosCouponPrizeQueue2");
                if (!string.IsNullOrEmpty(content))
                {
                    try
                    {
                        dosomething(int.Parse(function.CheckInt(content)));
                    }
                    catch
                    {
                    }
                }
                else
                {
                    Thread.Sleep(5000);
                }
            }
        }

        public void dosomething2(int OrderId)
        { 
            WebCMSEntities db = new WebCMSEntities();
            OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
            Orders order = db.Orders.FirstOrDefault(m => m.Id == OrderId);
            if(order != null)
            {
                List<int> ChkIds = new List<int>(); //机具券商品Id集合
                ChkIds.Add(10);
                ChkIds.Add(11);
                ChkIds.Add(77);
                ChkIds.Add(78);
                ChkIds.Add(79);
                //判断是否是指定商品
                if(ChkIds.Contains(order.ProductId))
                {
                    int Kind = 0;
                    if (order.ProductId == 10)
                    {
                        Kind = 1;
                    }
                    else if (order.ProductId == 11)
                    {
                        Kind = 2;
                    }
                    int CouponCount = 0;
                    if(Kind == 1)
                    {
                        CouponCount = 3 * order.BuyCount;
                    }
                    else if(Kind == 2)
                    {
                        CouponCount = 2 * order.BuyCount;
                    }


                    UserRankItem orderUser = GetUserLevel(order.UserId);
                    if(orderUser.UserLevel == 0) 
                    {
                    }
                    string ParentNav = orderUser.ParentNav + "," + orderUser.Id + ",";
                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                    Array.Reverse(ParentNavList);
                    int index = 0;
                    bool DirectPrizeFlag = false; //推荐奖励发放标识
                    bool BackAccountFlag = false; //备用金返余额标识
                    bool BigLeaderFlag = false; //大盟主标记
                    decimal BuyPrize = 0; //购机奖励
                    foreach(string ParentId in ParentNavList)
                    {
                        UserRankItem parentUser = GetUserLevel(int.Parse(ParentId));
                        index += 1;
                        if(index == 1 && (orderUser.LeaderLevel > 0 || orderUser.OperateLevel > 0) && !DirectPrizeFlag)
                        {
                            DirectPrizeFlag = true;
                        }
                        if(index > 1)
                        {
                            if(Utils.Instance.IsStandardUser(parentUser.Id) && !DirectPrizeFlag)
                            {
                                DirectPrizeFlag = true;
                            }
                        }
                        if(parentUser.AgoLeaderLevel > 0 && CheckLeaderReserve(db, order.BuyCount, parentUser.Id))
                        {
                            //购机奖
                            if(parentUser.LeaderLevel > 0)
                            {
                                decimal CurBuyPrize = GetBuyPrize(parentUser, order);
                                decimal GetPrize = CurBuyPrize - BuyPrize;
                                if(GetPrize > 0) 
                                {
                                    bool PrizeFlag = true;
                                    int ChangeType = 118;
                                    if(parentUser.OperateLevel == 1)
                                    {
                                        ChangeType = 120;
                                    }
                                    if(parentUser.OperateLevel > 1)
                                    {
                                        ChangeType = 128;
                                        if(function.CheckNull(RedisDbconn.Instance.Get<string>("YingXunUser")).Contains("," + orderUser.Id + ","))
                                        {
                                            PrizeFlag = false;
                                        }
                                    }
                                    if(PrizeFlag && !db.UserAccountRecord.Any(m => m.QueryCount == order.Id && m.ChangeType == ChangeType))
                                    {
                                        // OpAccount(db, order.Id, parentUser.Id, GetPrize, order.BuyCount, ChangeType);
                                    }
                                    BuyPrize = CurBuyPrize;
                                }
                            }

                            if(!BackAccountFlag)
                            {
                                BackAccountFlag = true;
                            }

                        }
                        else if(parentUser.OperateLevel > 0 && CheckOpReserve(opdb, order.BuyCount, parentUser.Id))
                        {
                            //购机奖
                            decimal CurBuyPrize = GetBuyPrize(parentUser, order);
                            decimal GetPrize = CurBuyPrize - BuyPrize;
                            if(GetPrize > 0)
                            {
                                int ChangeType = 120;
                                if(parentUser.OperateLevel > 1)
                                {
                                    ChangeType = 128;
                                }
                                BuyPrize = CurBuyPrize;
                            }

                            if(!BackAccountFlag)
                            {
                                BackAccountFlag = true;
                                
                            }
                        }
                    }
                }
            }
            db.Dispose();
            opdb.Dispose();
        }

        /// <summary>
        /// 获取创客各种等级
        /// </summary>
        /// <param name="db"></param>
        /// <param name="UserId"></param>
        /// <returns></returns>
        public UserRankItem GetUserLevel(int UserId)
        {
            WebCMSEntities db = new WebCMSEntities();
            OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
            UserRankItem dic = new UserRankItem();
            DateTime now = DateTime.Now;
            Users user = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1 && m.Status > -1) ?? new Users();
            UserRankWhite userWhite = db.UserRankWhite.FirstOrDefault(m => m.Id == UserId && m.UpdateDate > now) ?? new UserRankWhite();
            Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == UserId) ?? new Leaders();
            dic.UserLevel = userWhite.Rank > user.UserLevel ? userWhite.Rank : user.UserLevel;
            if(leader.ExpiredDate > now)
            {
                dic.LeaderLevel = leader.LeaderLevel;
            }
            dic.AgoLeaderLevel = leader.LeaderLevel;
            OpModels.SysAdmin sys = opdb.SysAdmin.FirstOrDefault(m => m.UserId == UserId) ?? new OpModels.SysAdmin();
            if(sys.ExpireDate > now)
            {
                dic.OperateLevel = user.UserType;
                dic.UserType = user.UserType;
            }
            dic.MerchantType = user.MerchantType;
            dic.Id = user.Id;
            dic.MakerCode = user.MakerCode;
            dic.RealName = user.RealName;
            dic.ParentUserId = user.ParentUserId;
            dic.ParentNav = user.ParentNav;
            db.Dispose();
            opdb.Dispose();
            return dic;
        }

        public UserRankItem GetUserLevel2(int UserId, DateTime OrderTime)
        {
            WebCMSEntities db = new WebCMSEntities();
            OpModels.WebCMSEntities opdb = new OpModels.WebCMSEntities();
            UserRankItem dic = new UserRankItem();
            Users user = db.Users.FirstOrDefault(m => m.Id == UserId && m.AuthFlag == 1 && m.Status > -1) ?? new Users();
            UserRankWhite userWhite = db.UserRankWhite.FirstOrDefault(m => m.Id == UserId && m.UpdateDate > OrderTime) ?? new UserRankWhite();
            Leaders leader = db.Leaders.FirstOrDefault(m => m.Id == UserId) ?? new Leaders();
            dic.UserLevel = userWhite.Rank > user.UserLevel ? userWhite.Rank : user.UserLevel;
            if(leader.ExpiredDate > OrderTime && leader.LastBuyDate < OrderTime)
            {
                dic.LeaderLevel = leader.LeaderLevel;
            }
            dic.AgoLeaderLevel = leader.LeaderLevel;
            OpModels.SysAdmin sys = opdb.SysAdmin.FirstOrDefault(m => m.UserId == UserId) ?? new OpModels.SysAdmin();
            if(sys.ExpireDate > OrderTime && sys.CreateDate < OrderTime)
            {
                dic.OperateLevel = user.UserType;
                dic.UserType = user.UserType;
            }
            dic.MerchantType = user.MerchantType;
            dic.Id = user.Id;
            dic.MakerCode = user.MakerCode;
            dic.RealName = user.RealName;
            dic.ParentUserId = user.ParentUserId;
            dic.ParentNav = user.ParentNav;
            db.Dispose();
            opdb.Dispose();
            return dic;
        }

        /// <summary>
        /// 直推奖励
        /// </summary>
        /// <param name="db"></param>
        /// <param name="OrderId"></param>
        /// <param name="UserId"></param>
        /// <param name="Count"></param>
        public void DirectPrize(WebCMSEntities db, int OrderId, int UserId, int Count = 1)
        {
            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
            if (account == null)
            {
                account = db.UserAccount.Add(new UserAccount()
                {
                    Id = UserId,
                    UserId = UserId,
                }).Entity;
                db.SaveChanges();
            }
            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
            account.BalanceAmount += 100 * Count;
            account.TotalAmount += 100 * Count;
            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 = UserId, //创客
                ChangeType = 112, //变动类型
                ChangeAmount = 100 * Count, //变更金额
                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                AfterTotalAmount = AfterTotalAmount, //变更后总金额
                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                QueryCount = OrderId,
            }).Entity;
            db.SaveChanges();

            //发送APP推送消息
            Utils.Instance.PrizePush(UserId, 100 * Count);
        }
    
        /// <summary>
        /// 判断盟主储蓄金足够
        /// </summary>
        /// <param name="db"></param>
        /// <param name="Count"></param>
        /// <param name="UserId"></param>
        /// <returns></returns>
        public bool CheckLeaderReserve(WebCMSEntities db, int Count, int UserId)
        {
            UserAccount acccount = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new UserAccount();
            if(acccount.LeaderReserve >= 400 * Count)
            {
                return true;
            }
            return false;
        }

        /// <summary>
        /// 判断运营中心/合伙人额度足够
        /// </summary>
        /// <param name="db"></param>
        /// <param name="Count"></param>
        /// <param name="UserId"></param>
        /// <returns></returns>
        public bool CheckOpReserve(OpModels.WebCMSEntities db, int Count, int UserId)
        {
            OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new OpModels.UserAccount();
            if(account.TotalAmt >= 400 * Count)
            {
                return true;
            }
            return false;
        }
        public bool CheckOpReserve(OpModels.WebCMSEntities db, decimal Amt, int UserId)
        {
            OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId) ?? new OpModels.UserAccount();
            if(account.TotalAmt >= Amt)
            {
                return true;
            }
            return false;
        }

        /// <summary>
        /// 扣减/增加盟主储蓄金
        /// </summary>
        /// <param name="db"></param>
        /// <param name="OrderId"></param>
        /// <param name="UserId"></param>
        /// <param name="Money"></param>
        /// <param name="ChangeType"></param>
        /// <param name="SourceUserId"></param>
        /// <param name="Remark"></param>
        public int OpReserve(WebCMSEntities db, int OrderId, int UserId, decimal Money, int ChangeType, int SourceUserId = 0, string Remark = "储备金购买")
        {
            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
            if (account == null)
            {
                account = db.UserAccount.Add(new UserAccount()
                {
                    Id = UserId,
                    UserId = UserId,
                }).Entity;
                db.SaveChanges();
            }
            decimal BeforeAmount = account.LeaderReserve; //变更前总金额
            if(ChangeType == 1)
            {
                account.LeaderReserve += Money;
            }
            else
            {
                account.LeaderReserve -= Money;
            }
            decimal AfterAmount = account.LeaderReserve; //变更后总金额
            LeaderReserveRecord add = db.LeaderReserveRecord.Add(new LeaderReserveRecord()
            {
                CreateDate = DateTime.Now,
                ChangeType = ChangeType,
                OrderId = OrderId,
                Remark = Remark,
                AfterAmt = AfterAmount,
                BeforeAmt = BeforeAmount,
                ChangeAmt = Money,
                TradeDate = DateTime.Now.ToString("yyyyMMdd"),
                TradeMonth = DateTime.Now.ToString("yyyyMM"),
                UserId = UserId,
                SourceUserId = SourceUserId,
                Sort = GetLeaderReserveRecordType(Remark),
            }).Entity;
            db.SaveChanges();
            return add.Id;
        }
        private int GetLeaderReserveRecordType(string Remark)
        {
            Dictionary<int, string> data = new Dictionary<int, string>();
            data.Add(11, "兑换机具券,机具券兑换,系统增加(盟主储蓄金),系统扣减(盟主储蓄金),储备金购买");
            data.Add(12, "系统增加(可提现余额),系统扣减(可提现余额)");
            data.Add(13, "推荐大盟主,推荐小盟主,商城购机,购机奖励");
            var item = data.FirstOrDefault(m => m.Value.Contains(Remark));
            if(item.Key > 0)
            {
                return item.Key;
            }
            return 0;
        }

        /// <summary>
        /// 操作盟主可提现余额
        /// </summary>
        /// <param name="db"></param>
        /// <param name="order"></param>
        /// <param name="UserId"></param>
        /// <param name="Money"></param>
        /// <param name="Count"></param>
        /// <param name="Kind"></param>
        public void OpLeaderAccount(WebCMSEntities db, Orders order, int UserId, decimal Money, int Count = 1, int ReserveRecordId = 0)
        {
            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
            if (account == null)
            {
                account = db.UserAccount.Add(new UserAccount()
                {
                    Id = UserId,
                    UserId = UserId,
                }).Entity;
                db.SaveChanges();
            }
            int ChangeType = 0;
            if(Money == 400)
            {
                ChangeType = 117;
            }
            decimal BeforeLeaderBalanceAmount = account.LeaderBalanceAmount; //变更前余额
            account.LeaderBalanceAmount += Money * Count;
            decimal AfterLeaderBalanceAmount = account.LeaderBalanceAmount; //变更后余额
            LeaderAccountRecord leaderAccountRecord = db.LeaderAccountRecord.Add(new LeaderAccountRecord()
            {
                CreateDate = DateTime.Now,
                UpdateDate = DateTime.Now,
                UserId = UserId, //创客
                ChangeType = ChangeType, //变动类型
                ChangeAmount = Money * Count, //变更金额
                BeforeBalanceAmount = BeforeLeaderBalanceAmount, //变更前余额
                AfterBalanceAmount = AfterLeaderBalanceAmount, //变更后余额
                QueryCount = order.Id,
                Sort = order.UserId,
            }).Entity;
            db.SaveChanges();
            if(ReserveRecordId > 0)
            {
                LeaderReserveRecord edit = db.LeaderReserveRecord.FirstOrDefault(m => m.Id == ReserveRecordId);
                if(edit != null)
                {
                    edit.AccountRecordId = leaderAccountRecord.Id;
                    db.SaveChanges();
                }
            }
        }

        /// <summary>
        /// 操作余额
        /// </summary>
        /// <param name="db"></param>
        /// <param name="order"></param>
        /// <param name="UserId"></param>
        /// <param name="Money"></param>
        /// <param name="Count"></param>
        public void OpAccount(WebCMSEntities db, int OrderId, int UserId, decimal Money, int Count = 1, int ChangeType = 0, int Kind = 0)
        {
            UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
            if (account == null)
            {
                account = db.UserAccount.Add(new UserAccount()
                {
                    Id = UserId,
                    UserId = UserId,
                }).Entity;
                db.SaveChanges();
            }
            decimal BeforeTotalAmount = account.TotalAmount; //变更前总金额
            decimal BeforeFreezeAmount = account.FreezeAmount; //变更前冻结金额
            decimal BeforeBalanceAmount = account.BalanceAmount; //变更前余额
            account.BalanceAmount += Money * Count;
            account.TotalAmount += Money * Count;
            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 = UserId, //创客
                ChangeType = ChangeType, //变动类型
                ChangeAmount = Money * Count, //变更金额
                BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                AfterTotalAmount = AfterTotalAmount, //变更后总金额
                BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                QueryCount = OrderId,
                Kind = Kind,
            }).Entity;
            db.SaveChanges();

            //发送APP推送消息
            Utils.Instance.PrizePush(UserId, Money * Count);
        }

        /// <summary>
        /// 操作运营中心/合伙人额度（TotalAmt未使用额度，ValidForGetAmount可提现额度）
        /// </summary>
        /// <param name="db"></param>
        /// <param name="UserId"></param>
        /// <param name="Money"></param>
        /// <param name="OperateType">（1增加，2减少）</param>
        /// <param name="AmountType">（1未使用额度，2可提现额度）</param>
        /// <param name="Remark"></param>
        /// <param name="record"></param>
        public void OperateAmountChange(OpModels.WebCMSEntities db, int UserId, decimal Money, int OperateType, int AmountType, string Remark = "", bool record = false, int OrderId = 0)
        {
            OpModels.UserAccount account = db.UserAccount.FirstOrDefault(m => m.Id == UserId);
            if (account == null)
            {
                account = db.UserAccount.Add(new OpModels.UserAccount()
                {
                    Id = UserId,
                    UserId = UserId,
                }).Entity;
                db.SaveChanges();
            }
            decimal BeforeAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount; //变更前总金额
            if(OperateType == 1)
            {
                if(AmountType == 1)
                {
                    account.TotalAmt += Money;
                }
                else if(AmountType == 2)
                {
                    account.ValidForGetAmount += Money;
                }
                else
                {
                    account.ValidAmount += Money;
                }
            }
            else
            {
                if(AmountType == 1)
                {
                    account.TotalAmt -= Money;
                }
                else if(AmountType == 2)
                {
                    account.ValidForGetAmount -= Money;
                }
                else
                {
                    account.ValidAmount -= Money;
                }
            }
            decimal AfterAmount = account.ValidAmount + account.TotalAmt + account.ValidForGetAmount; //变更后总金额
            if(record)
            {
                OpModels.AmountRecord add = db.AmountRecord.Add(new OpModels.AmountRecord()
                {
                    CreateDate = DateTime.Now,
                    UpdateDate = DateTime.Now,
                    OperateType = OperateType,
                    AfterAmount = AfterAmount,
                    AfterValidForGetAmount = account.ValidForGetAmount,
                    AfterTotalAmt = account.TotalAmt,
                    AfterValidAmount = account.ValidAmount,
                    BeforeAmount = BeforeAmount,
                    UseAmount = Money,
                    UserId = UserId,
                    SeoDescription = Remark,
                    Version = AmountType,
                    QueryCount = OrderId,
                }).Entity;

                OpModels.AmountChangeRecord amountChangeRecord = db.AmountChangeRecord.Add(new OpModels.AmountChangeRecord()
                {
                    AmountType = 2,//1 未使用额度 2 可提现额度 3 关联分仓额度
                    CreateDate = DateTime.Now,
                    Title = Remark,
                    UserId = UserId, //运营中心Id
                    BeforeAmount = BeforeAmount,//使用前剩余额度
                    AfterAmount = AfterAmount,//使用后剩余额度
                    ChangeAmount = Money,//操作金额
                    OperateType = OperateType,//操作类别
                    Sort = OrderId,
                }).Entity;
            }
            db.SaveChanges();
        }

        /// <summary>
        /// 给券设置大盟主标记
        /// </summary>
        /// <param name="db"></param>
        /// <param name="LeaderUserId"></param>
        /// <param name="Count"></param>
        /// <param name="couponIds"></param>
        public int SetPosCouponLeaderFlag(WebCMSEntities db, int LeaderUserId, int Count, List<int> couponIds)
        {
            int SetCount = 0;
            UserAccount pacccount = db.UserAccount.FirstOrDefault(m => m.Id == LeaderUserId) ?? new UserAccount();
            foreach(int couponId in couponIds)
            {
                PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
                decimal LeaderReserve = pacccount.LeaderReserve;
                decimal CheckReserve = 400 * Count;
                // if(LeaderReserve < CheckReserve)
                // {
                //     LeaderReserveRecord ReserveRecord = db.LeaderReserveRecord.FirstOrDefault(m => m.UserId == LeaderUserId && m.Remark == "推荐小盟主" && m.ChangeAmt - m.UsedReserve > 0);
                //     if(ReserveRecord != null)
                //     {
                //         if(ReserveRecord.ChangeAmt - ReserveRecord.UsedReserve >= CheckReserve)
                //         {
                //             LeaderReserve = CheckReserve;
                //             ReserveRecord.UsedReserve += CheckReserve;
                //         }
                //         else
                //         {
                //             decimal OtherLeaderReserve = ReserveRecord.ChangeAmt - ReserveRecord.UsedReserve;
                //             ReserveRecord.UsedReserve += OtherLeaderReserve;
                //             LeaderReserveRecord ReserveRecord2 = db.LeaderReserveRecord.FirstOrDefault(m => m.Id > ReserveRecord.Id && m.UserId == LeaderUserId && m.Remark == "推荐小盟主" && m.ChangeAmt - m.UsedReserve > 0);
                //             if(ReserveRecord2 != null)
                //             {
                //                 if(ReserveRecord2.ChangeAmt - ReserveRecord2.UsedReserve >= CheckReserve - OtherLeaderReserve)
                //                 {
                //                     LeaderReserve = CheckReserve - OtherLeaderReserve;
                //                     ReserveRecord2.UsedReserve += CheckReserve - OtherLeaderReserve;
                //                 }
                //                 else
                //                 {
                //                     OtherLeaderReserve = ReserveRecord2.ChangeAmt - ReserveRecord2.UsedReserve;
                //                     ReserveRecord2.UsedReserve += OtherLeaderReserve;
                //                 }
                //             }
                //         }
                //     }
                // }
                if(coupon != null && LeaderReserve >= CheckReserve)
                {
                    coupon.LeaderUserId = LeaderUserId;
                    SetCount += 1;
                }
            }
            db.SaveChanges();
            return SetCount;
        }

        public int CheckPosCouponLeaderFlag(WebCMSEntities db, int UserId, int Count, List<string> codes)
        {
            int LeaderUserId = 0;
            decimal CheckReserve = 400 * Count;
            // decimal LeaderReserve = 0;
            LeaderReserveRecord ReserveRecord = db.LeaderReserveRecord.FirstOrDefault(m => m.SourceUserId == UserId && m.Remark == "推荐小盟主" && m.ChangeAmt - m.UsedReserve > CheckReserve);
            if(ReserveRecord != null)
            {
                LeaderUserId = ReserveRecord.UserId;
                // if(ReserveRecord.ChangeAmt - ReserveRecord.UsedReserve >= CheckReserve)
                // {
                    // LeaderReserve = CheckReserve;
                    ReserveRecord.UsedReserve += CheckReserve;
                // }
                // else
                // {
                //     decimal OtherLeaderReserve = ReserveRecord.ChangeAmt - ReserveRecord.UsedReserve;
                //     ReserveRecord.UsedReserve += OtherLeaderReserve;
                //     LeaderReserveRecord ReserveRecord2 = db.LeaderReserveRecord.FirstOrDefault(m => m.Id > ReserveRecord.Id && m.UserId == LeaderUserId && m.Remark == "推荐小盟主" && m.ChangeAmt - m.UsedReserve > 0);
                //     if(ReserveRecord2 != null)
                //     {
                //         if(ReserveRecord2.ChangeAmt - ReserveRecord2.UsedReserve >= CheckReserve - OtherLeaderReserve)
                //         {
                //             LeaderReserve = CheckReserve - OtherLeaderReserve;
                //             ReserveRecord2.UsedReserve += CheckReserve - OtherLeaderReserve;
                //         }
                //         else
                //         {
                //             OtherLeaderReserve = ReserveRecord2.ChangeAmt - ReserveRecord2.UsedReserve;
                //             ReserveRecord2.UsedReserve += OtherLeaderReserve;
                //         }
                //     }
                // }

                List<int> couponIds = db.PosCoupons.Where(m => codes.Contains(m.ExchangeCode)).OrderBy(m => m.Id).ToList().Select(m => m.Id).ToList();
                foreach(int couponId in couponIds)
                {
                    PosCoupons coupon = db.PosCoupons.FirstOrDefault(m => m.Id == couponId);
                    if(coupon != null)
                    {
                        coupon.LeaderUserId = LeaderUserId;
                    }
                }
                db.SaveChanges();
            }
            return LeaderUserId;
        }

        /// <summary>
        /// 获取购机奖金额
        /// </summary>
        /// <param name="user"></param>
        /// <returns></returns>
        public decimal GetBuyPrize(UserRankItem user, Orders order)
        {
            if(user.OperateLevel == 1) return 100;
            if(user.OperateLevel == 2) 
            {
                function.WriteLog("\n\n\n创客Id:" + user.Id, "训练营60拦截日志");
                if(TradeTeamCheck2(user.Id))
                {
                    return 160;
                }
                function.WriteLog("下单人:" + order.UserId, "训练营60拦截日志");
                if(!TradeTeamCheck(order.UserId) && user.Id != order.UserId)
                {
                    function.WriteLog("拦截", "训练营60拦截日志");
                    decimal Amount = order.BuyCount * 60;
                    RedisDbconn.Instance.AddList("TradeFilterQueue", "{\"OrderId\":\"" + order.Id + "\",\"PrizeUserId\":\"" + user.Id + "\",\"Amount\":\"" + Amount + "\",\"Kind\":\"1\"}");
                    function.WriteLog("end", "训练营60拦截日志");
                    return 100;
                }
                return 160;
            }
            if(user.OperateLevel == 3) return 180;
            if(user.OperateLevel == 4) return 200;
            if(user.LeaderLevel > 0) return 100;
            return 0;
        }

        public bool TradeTeamCheck(int UserId)
        {
            bool op = true;
            if(UserId == 0)
            {
                return op;
            }
            function.WriteLog("UserId:" + UserId, "训练营判断参与活动");
            WebCMSEntities maindb = new WebCMSEntities();
            Users muser = maindb.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
            string ParentNav = muser.ParentUserId + "," + UserId;
            string[] ParentNavList = ParentNav.Split(',');
            List<int> UserIds = new List<int>();
            foreach(string IdString in ParentNavList)
            {
                UserIds.Add(int.Parse(function.CheckInt(IdString)));
            } 
            JavaModels.WebCMSEntities db = new JavaModels.WebCMSEntities();
            var users = db.KxsCampUser.Where(m => UserIds.Contains(m.UserId)).ToList();
            foreach(var user in users)
            {
                DateTime now = DateTime.Now;
                // JavaModels.KxsCamp camp = db.KxsCamp.FirstOrDefault(m => m.Id == user.CampId && m.StartTime <= now && m.EndTime >= now);
                JavaModels.KxsCamp camp = db.KxsCamp.FirstOrDefault(m => m.Id == user.CampId && m.Status == 1);
                if(camp != null)
                {
                    function.WriteLog("活动Id:" + camp.Id, "训练营判断参与活动");
                    op = false;
                    break;
                }
            }
            maindb.Dispose();
            db.Dispose();
            function.WriteLog("\n\n\n", "训练营判断参与活动");
            return op;
        }

        public bool TradeTeamCheck2(int UserId)
        {
            bool op = false;
            if(UserId == 0)
            {
                return op;
            }
            function.WriteLog("黄金合伙人-UserId:" + UserId, "训练营判断参与活动");
            JavaModels.WebCMSEntities db = new JavaModels.WebCMSEntities();
            var users = db.KxsCampUser.Where(m => m.UserId == UserId).ToList();
            foreach(var user in users)
            {
                DateTime now = DateTime.Now;
                // JavaModels.KxsCamp camp = db.KxsCamp.FirstOrDefault(m => m.Id == user.CampId && m.StartTime <= now && m.EndTime >= now);
                JavaModels.KxsCamp camp = db.KxsCamp.FirstOrDefault(m => m.Id == user.CampId && m.Status == 1);
                if(camp != null)
                {
                    function.WriteLog("黄金合伙人-活动Id:" + camp.Id, "训练营判断参与活动");
                    op = true;
                    break;
                }
            }
            db.Dispose();
            function.WriteLog("\n\n\n", "训练营判断参与活动");
            return op;
        }

        /// <summary>
        /// 获取可提现金额
        /// </summary>
        /// <param name="user"></param>
        /// <returns></returns>
        public decimal GetWithdrawMoney(UserRankItem user)
        {
            if(user.OperateLevel == 1) return 400;
            // if(user.OperateLevel == 2) return 340;
            // if(user.OperateLevel == 3) return 320;
            // if(user.OperateLevel == 4) return 300;
            if(user.OperateLevel == 2) return 400;
            if(user.OperateLevel == 3) return 400;
            if(user.OperateLevel == 4) return 400;
            if(user.AgoLeaderLevel > 0) return 400;
            return 0;
        }

        /// <summary>
        /// 预设职级
        /// </summary>
        /// <param name="db"></param>
        /// <param name="UserId">创客Id</param>
        /// <param name="Rank">职级</param>
        /// <param name="ExpiredDate">过期时间</param>
        public void PreUserLevel(WebCMSEntities db, int UserId, int Rank, DateTime ExpiredDate)
        {
            UserRankWhite rank = db.UserRankWhite.FirstOrDefault(m => m.Id == UserId);
            if(rank == null)
            {
                rank = db.UserRankWhite.Add(new UserRankWhite()
                {
                    CreateDate = DateTime.Now, //设置时间
                    UserId = UserId, //用户
                    Id = UserId,
                }).Entity;
                db.SaveChanges();
            }
            rank.Rank = Rank;
            rank.UpdateDate = ExpiredDate;
            db.SaveChanges();
        }
    }
}