kxs-admin/AppStart/Helper/SycnProfitServiceV3.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Threading;
using MySystem.Models;
using Library;

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

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

        public void doSomething()
        {
            while (true)
            {
                string content = RedisDbconn.Instance.RPop<string>("SycnProfitQueue2");
                if (!string.IsNullOrEmpty(content))
                {
                    try
                    {
                        function.WriteLog(DateTime.Now.ToString() + "\r\n\r\n", "同步分润数据");
                        string[] data = content.Split(new string[] { "#cut#" }, StringSplitOptions.None);
                        int BrandId = int.Parse(data[0]);
                        string date = data[1];
                        int OpType = int.Parse(data[2]);
                        string SysUserName = data[3];
                        if (OpType == 0)
                        {
                            DoTradeProfit(BrandId, date, SysUserName);
                            DoSubsidyProfit(BrandId, date);
                            RedisDbconn.Instance.Set("ProfitFlag:" + date, 1);
                        }
                        else if (OpType == 1)
                        {
                            DoTradeProfit2(BrandId, date, SysUserName);
                            DoSubsidyProfit2(BrandId, date);
                            if(BrandId == 1)
                            {
                                DoUserProfit(date);
                                DoUserServiceFee();
                                RedisDbconn.Instance.Set("ProfitFlag:" + date, 0);
                                RedisDbconn.Instance.SetExpire("ProfitFlag:" + date, 1);
                            }
                        }
                        function.WriteLog(DateTime.Now.ToString() + "\r\n\r\n", "同步分润数据");
                    }
                    catch (Exception ex)
                    {
                        function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "同步分润数据异常");
                    }
                }
                else
                {
                    Thread.Sleep(60000);
                }
            }
        }

        private void DoTradeProfit(int BrandId, string date, string SysUserName)
        {
            WebCMSEntities db = new WebCMSEntities();
            OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
            string StartId = function.ReadInstance("/PublicParams/ProfitRewardRecordId" + date + ".txt");
            if(string.IsNullOrEmpty(StartId))
            {
                StartId = "0";
            }
            OtherMySqlConn.op("insert into ProfitRecord (CreateDate,CreateMan,SeoTitle,ParentNav,BrandId,UserId,DirectFlag,SeoDescription,ProfitAmount) select now(),'root','" + date + "',(select ParentNav from Users where Id=p.UserId)," + BrandId + ",UserId,ProfitType,(case when Version=1 then '存量' else '新增' end),sum(CreditTradeProfit+DebitNonTradeCapProfit+DebitTradeCapProfit) from ProfitRewardRecord p where Id>=" + StartId + " and CheckStatus=0 and BrandId=" + BrandId + " and UserId>0 and TradeMonth='" + date + "' group by UserId,ProfitType,Version order by UserId");
            DataTable dt = OtherMySqlConn.dtable("select UserId,sum(CreditTradeProfit+DebitNonTradeCapProfit+DebitTradeCapProfit) from ProfitRewardRecord where Id>=" + StartId + " and CheckStatus=0 and BrandId=" + BrandId + " and UserId>0 and TradeMonth='" + date + "' group by UserId");
            function.WriteLog("分润:" + BrandId + ":" + dt.Rows.Count, "同步分润数据");
            int index = 0;
            foreach (DataRow dr in dt.Rows)
            {
                index += 1;
                int UserId = int.Parse(dr["UserId"].ToString());
                decimal ProfitMoney = decimal.Parse(dr[1].ToString());
                try
                {
                    string content = UserId + "|" + BrandId + "|" + ProfitMoney + "|" + index;
                    RedisDbconn.Instance.AddList("DoTradeProfitQueue", content);
                }
                catch (Exception ex)
                {
                    function.WriteLog(DateTime.Now.ToString() + "\n" + UserId + "," + ProfitMoney + "\n" + ex.ToString(), "同步到余额异常");
                }
                function.WriteLog(index.ToString(), "同步分润数据");
            }
            OtherMySqlConn.op("update ProfitRewardRecord set CheckStatus=1 where Id>=" + StartId + " and CheckStatus=0 and BrandId=" + BrandId + " and UserId>0 and TradeMonth='" + date + "'");

            db.Dispose();
            dt.Dispose();

            RedisDbconn.Instance.AddList("DoTradeProfitQueue", "end");
            SycnProfitServiceV2.Instance.StartProfit();
        }
        private void DoTradeProfit2(int BrandId, string date, string SysUserName)
        {
            WebCMSEntities db = new WebCMSEntities();
            string conn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();

            CustomerSqlConn.op("insert into UserAccountRecord (CreateDate,UpdateDate,UserId,ProductType,ChangeType,ChangeAmount,BeforeTotalAmount,AfterTotalAmount,BeforeFreezeAmount,AfterFreezeAmount,BeforeBalanceAmount,AfterBalanceAmount,Remark) select tb.CreateDate,tb.UpdateDate,tb.UserId,ProductType,ChangeType,ProfitAmount,a.TotalAmount BeforeTotalAmount,a.TotalAmount+ProfitAmount AfterTotalAmount,a.FreezeAmount BeforeFreezeAmount,a.FreezeAmount AfterFreezeAmount,a.BalanceAmount BeforeBalanceAmount,a.BalanceAmount+ProfitAmount AfterBalanceAmount,Remark from (select now() CreateDate,now() UpdateDate,UserId," + BrandId + " ProductType,1 ChangeType,ProfitAmount,CONCAT((case when DirectFlag=1 then '直拓商户分润' else '品牌推广服务费' end),'-',SeoDescription) Remark from ProfitRecord where BrandId=" + BrandId + " and SeoTitle='" + date + "' and Version=0 and UserId>0 order by Id) tb left join UserAccount a on tb.UserId=a.Id", conn);

            CustomerSqlConn.op("update ProfitRecord set Version=1 where BrandId=" + BrandId + " and SeoTitle='" + date + "' and Version=0 and UserId>0", conn);
            db.Dispose();
        }


        //分润补贴
        private void DoSubsidyProfit(int BrandId, string date)
        {
            WebCMSEntities db = new WebCMSEntities();
            string conn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();

            string StartId = function.ReadInstance("/PublicParams/ProfitSubsidyDetailId" + date + ".txt");
            if(string.IsNullOrEmpty(StartId))
            {
                StartId = "0";
            }
            
            CustomerSqlConn.op("insert into SubsidyRecord (CreateDate,SeoKeyword,SeoTitle,ParentNav,BrandId,UserId,ProfitAmount) select now(),'root','" + date + "',(select ParentNav from Users where Id=p.SubsidyUserId)," + BrandId + ",SubsidyUserId,sum(SubsidyProfitRate) from ProfitSubsidyDetail p where Id>=" + StartId + " and Status=0 and BrandId=" + BrandId + " and TradeMonth='" + date + "' GROUP BY SubsidyUserId", conn);

            DataTable dt = CustomerSqlConn.dtable("select SubsidyUserId,sum(SubsidyProfitRate) from ProfitSubsidyDetail where Id>=" + StartId + " and Status=0 and BrandId=" + BrandId + " and TradeMonth='" + date + "' GROUP BY SubsidyUserId", conn);
            function.WriteLog("补贴:" + BrandId + ":" + dt.Rows.Count, "同步补贴数据");
            int index = 0;
            foreach (DataRow dr in dt.Rows)
            {
                index += 1;
                int UserId = int.Parse(dr["SubsidyUserId"].ToString());
                decimal ProfitMoney = decimal.Parse(dr[1].ToString());
                try
                {
                    string content = UserId + "|" + BrandId + "|" + ProfitMoney + "|" + index;
                    RedisDbconn.Instance.AddList("DoSubsidyProfitQueue", content);
                }
                catch (Exception ex)
                {
                    function.WriteLog(DateTime.Now.ToString() + "\n" + UserId + "," + ProfitMoney + "\n" + ex.ToString(), "同步到补贴异常");
                }
            }
            CustomerSqlConn.op("update ProfitSubsidyDetail set Status=1 where Id>=" + StartId + " and Status=0 and BrandId=" + BrandId + " and TradeMonth='" + date + "'", conn);
                
            db.Dispose();
            dt.Dispose();
            
            RedisDbconn.Instance.AddList("DoSubsidyProfitQueue", "end");
            SycnProfitServiceV2.Instance.StartSubsidy();
        }

        private void DoSubsidyProfit2(int BrandId, string date)
        {
            WebCMSEntities db = new WebCMSEntities();
            string conn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();

            CustomerSqlConn.op("insert into UserAccountRecord (CreateDate,UpdateDate,UserId,ProductType,ChangeType,ChangeAmount,BeforeTotalAmount,AfterTotalAmount,BeforeFreezeAmount,AfterFreezeAmount,BeforeBalanceAmount,AfterBalanceAmount,Remark) select tb.CreateDate,tb.UpdateDate,tb.UserId,ProductType,ChangeType,ProfitAmount,a.TotalAmount BeforeTotalAmount,a.TotalAmount+ProfitAmount AfterTotalAmount,a.FreezeAmount BeforeFreezeAmount,a.FreezeAmount AfterFreezeAmount,a.BalanceAmount BeforeBalanceAmount,a.BalanceAmount+ProfitAmount AfterBalanceAmount,Remark from (select now() CreateDate,now() UpdateDate,UserId," + BrandId + " ProductType,111 ChangeType,ProfitAmount,'直拓商户补贴' Remark from SubsidyRecord where BrandId=" + BrandId + " and SeoTitle='" + date + "' and Status=0 and UserId>0 order by Id) tb left join UserAccount a on tb.UserId=a.Id", conn);
            
            CustomerSqlConn.op("update SubsidyRecord set Status=1 where BrandId=" + BrandId + " and SeoTitle='" + date + "' and Status=0 and UserId>0", conn);

            db.Dispose();
        }


        #region 助力宝分润展示

        public void DoHelpProfit(string month)
        {
            string conn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
            CustomerSqlConn.dtable("update HelpProfitReward set Status=1 where Status=0 and TradeMonth='" + month + "'", conn);
        }

        #endregion

        #region 助力宝分润到账

        public void DoHelpProfit2(string month)
        {
            WebCMSEntities db = new WebCMSEntities();
            string conn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();
            
            DataTable dt = CustomerSqlConn.dtable("select UserId,RewardType,sum(CreditRewardAmount),sum(CreditTradeAmt) from HelpProfitReward where Status=1 and TradeMonth='" + month + "' GROUP BY UserId,RewardType", conn);
            function.WriteLog("数量:" + dt.Rows.Count, "同步助力宝分润数据");
            int index = 0;
            foreach (DataRow dr in dt.Rows)
            {
                index += 1;
                int UserId = int.Parse(dr["UserId"].ToString());
                int RewardType = int.Parse(dr["RewardType"].ToString());
                decimal ProfitMoney = decimal.Parse(dr[2].ToString());
                decimal TradeAmt = decimal.Parse(dr[3].ToString());
                var tran = db.Database.BeginTransaction();
                try
                {
                    Users user = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
                    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 += ProfitMoney;
                    account.TotalAmount += ProfitMoney;
                    decimal AfterTotalAmount = account.TotalAmount; //变更后总金额
                    decimal AfterFreezeAmount = account.FreezeAmount; //变更后冻结金额
                    decimal AfterBalanceAmount = account.BalanceAmount; //变更后余额
                    UserAccountRecord add = db.UserAccountRecord.Add(new UserAccountRecord()
                    {
                        CreateDate = DateTime.Now,
                        UpdateDate = DateTime.Now,
                        UserId = UserId, //创客
                        ProductType = 101,
                        ChangeType = RewardType, //变动类型
                        ChangeAmount = ProfitMoney, //变更金额
                        BeforeTotalAmount = BeforeTotalAmount, //变更前总金额
                        AfterTotalAmount = AfterTotalAmount, //变更后总金额
                        BeforeFreezeAmount = BeforeFreezeAmount, //变更前冻结金额
                        AfterFreezeAmount = AfterFreezeAmount, //变更后冻结金额
                        BeforeBalanceAmount = BeforeBalanceAmount, //变更前余额
                        AfterBalanceAmount = AfterBalanceAmount, //变更后余额
                        Remark = user.RealName.Substring(0, 1) + "**:" + DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + "交易" + TradeAmt.ToString("f2"),
                    }).Entity;
                    db.SaveChanges();
                    tran.Commit();
                    PublicFunction.SplitUserAccountRecord(add);
                }
                catch (Exception ex)
                {
                    function.WriteLog(DateTime.Now.ToString() + "\n" + UserId + "," + ProfitMoney + "\n" + ex.ToString(), "同步助利宝分润异常");
                    tran.Rollback();
                }
                function.WriteLog(index.ToString(), "同步补贴数据");
            }
            OtherMySqlConn.dtable("update HelpProfitReward set Status=2 where Status=1 and TradeMonth='" + month + "'");
            
            db.Dispose();
        }

        #endregion

        #region 分润结果临时数据

        private void DoUserProfit(string date)
        {
            string conn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();

            CustomerSqlConn.op("delete from UserProfit;insert into UserProfit (Id,UserId,ProfitRate) select UserId,UserId,sum(ProfitAmount) from (select UserId,ProfitAmount from ProfitRecord where SeoTitle='" + date + "' and Version=1 and UserId>0 union all select UserId,ProfitAmount from SubsidyRecord where SeoTitle='" + date + "' and Status=1 and UserId>0) tb group by UserId", conn);
        }
        #endregion

        #region 扣创客服务费

        private void DoUserServiceFee()
        {
            string conn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();

            CustomerSqlConn.op("insert into UserAccount (Id,UserId) select Id,Id from UserProfit where Id not in (select Id from UserAccount)", conn);

            CustomerSqlConn.op("update UserAccount a set BalanceAmount=BalanceAmount+(select ProfitRate from UserProfit where Id=a.Id),TotalAmount=TotalAmount+(select ProfitRate from UserProfit where Id=a.Id) where Id in (select Id from UserProfit)", conn);

            string Month = DateTime.Now.AddDays(-90).ToString("yyyy-MM");
            
            CustomerSqlConn.op("delete from UserFriend", conn);
            
            CustomerSqlConn.op("insert into UserFriend (Id) select Id from Users where AuthFlag=1 and AuthDate<'" + Month + "-01 00:00:00' and Id not in (select UserId from PosMachinesTwo where `Status`>-1 and BuyUserId!=UserId and UserId not in (select UserId from PullnewSummary) and UserId not in (select BuyUserId from PosMachinesTwo where `Status`>-1))", conn);
            
            CustomerSqlConn.op("insert into UserAccountRecord (CreateDate,UpdateDate,UserId,ChangeType,ChangeAmount,BeforeTotalAmount,AfterTotalAmount,BeforeFreezeAmount,AfterFreezeAmount,BeforeBalanceAmount,AfterBalanceAmount) select now(),now(),Id,125,BalanceAmount,TotalAmount BeforeTotalAmount,TotalAmount AfterTotalAmount,FreezeAmount,FreezeAmount,BalanceAmount BeforeBalanceAmount,BalanceAmount-BalanceAmount AfterBalanceAmount from UserAccount where Id in (select Id from UserFriend) and BalanceAmount>0 and BalanceAmount<10", conn);

            CustomerSqlConn.op("insert into UserAccountRecord (CreateDate,UpdateDate,UserId,ChangeType,ChangeAmount,BeforeTotalAmount,AfterTotalAmount,BeforeFreezeAmount,AfterFreezeAmount,BeforeBalanceAmount,AfterBalanceAmount) select now(),now(),Id,125,10,TotalAmount BeforeTotalAmount,TotalAmount AfterTotalAmount,FreezeAmount,FreezeAmount,BalanceAmount BeforeBalanceAmount,BalanceAmount-10 AfterBalanceAmount from UserAccount where Id in (select Id from UserFriend) and BalanceAmount>=10;", conn);

            CustomerSqlConn.op("update UserAccount a set BalanceAmount=0 where Id in (select Id from UserFriend) and BalanceAmount>0 and BalanceAmount<10", conn);

            CustomerSqlConn.op("update UserAccount a set BalanceAmount=BalanceAmount-10 where Id in (select Id from UserFriend) and BalanceAmount>=10", conn);
        }

        #endregion
        
        #region 扣过期机具费

        private void DoExpiredPosFee()
        {
            string conn = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString();

            string checck = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00").AddDays(-60).ToString("yyyy-MM-dd HH:mm:ss");
            
            DataTable dt = CustomerSqlConn.dtable("select DISTINCT BuyUserId from PosMachinesTwo where RecycEndDate<'" + checck + "' and Status>-1 and BindingState=0 and ScanQrTrade<999", conn);
            foreach(DataRow dr in dt.Rows)
            {
                RedisDbconn.Instance.AddList("PosExpiredPayQueue", dr["BuyUserId"].ToString());
            }
        }

        #endregion









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

        public void StartProfitDo()
        {
            WebCMSEntities db = new WebCMSEntities();
            bool op = true;
            while (op)
            {
                string content = RedisDbconn.Instance.RPop<string>("DoTradeProfitQueue");
                if (!string.IsNullOrEmpty(content))
                {
                    if(content == "end")
                    {
                        op = false;
                    }
                    else
                    {
                        try
                        {
                            string[] data = content.Split('|');
                            int UserId = int.Parse(data[0]);
                            int BrandId = int.Parse(data[1]);
                            decimal ProfitMoney = decimal.Parse(data[2]);
                            int index = int.Parse(data[3]);
                            
                            string IdBrand = UserId + "_" + BrandId;
                            UserMachineData MachineData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                            if (MachineData == null)
                            {
                                MachineData = db.UserMachineData.Add(new UserMachineData()
                                {
                                    IdBrand = IdBrand,
                                }).Entity;
                                db.SaveChanges();
                            }
                            MachineData.TradeProfit += ProfitMoney;
                            db.SaveChanges();

                            function.WriteLog(index.ToString() + "--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "同步分润队列数据");
                        }
                        catch (Exception ex)
                        {
                            function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "同步分润队列数据异常");
                        }
                    }
                }
                else
                {
                    Thread.Sleep(1000);
                }
            }
            db.Dispose();
        }

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

        public void StartSubsidyDo()
        {
            WebCMSEntities db = new WebCMSEntities();
            bool op = true;
            while (op)
            {
                string content = RedisDbconn.Instance.RPop<string>("DoSubsidyProfitQueue");
                if (!string.IsNullOrEmpty(content))
                {
                    if(content == "end")
                    {
                        op = false;
                    }
                    else
                    {
                        try
                        {
                            string[] data = content.Split('|');
                            int UserId = int.Parse(data[0]);
                            int BrandId = int.Parse(data[1]);
                            decimal ProfitMoney = decimal.Parse(data[2]);
                            int index = int.Parse(data[3]);

                            string IdBrand = UserId + "_" + BrandId;
                            UserMachineData MachineData = db.UserMachineData.FirstOrDefault(m => m.IdBrand == IdBrand);
                            if (MachineData == null)
                            {
                                MachineData = db.UserMachineData.Add(new UserMachineData()
                                {
                                    IdBrand = IdBrand,
                                }).Entity;
                                db.SaveChanges();
                            }
                            MachineData.OtherProfit += ProfitMoney;
                            db.SaveChanges();

                            function.WriteLog(index.ToString() + "--" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "同步补贴队列数据");
                        }
                        catch (Exception ex)
                        {
                            function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "同步补贴队列数据异常");
                        }
                    }
                }
                else
                {
                    Thread.Sleep(1000);
                }
            }
            db.Dispose();
        }


        #region
        private bool CheckUser(WebCMSEntities db, int Id)
        {
            DateTime ExpireDate = DateTime.Parse(DateTime.Now.ToString("yyyy-MM") + "-01 00:00:00").AddDays(-90); //创客认证超过90天比对时间
            //超过90天创客判断
            return db.Users.Any(m => m.Id == Id && m.AuthFlag == 1 && m.AuthDate < ExpireDate);
        }
        #endregion
    }
}