lkb-stat/AppStart/Helper/TestService.cs

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

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






        // 统计交易额V2
        public void Start()
        {
            Thread th = new Thread(StartDo);
            th.IsBackground = true;
            th.Start();
        }
        public void StartDo()
        {
            StatTradeAmount("2023-09-01");
            StatTradeAmount("2023-09-02");
            StatTradeAmount("2023-09-03");
            StatTradeAmount("2023-09-04");
            StatTradeAmount("2023-09-05");
            StatTradeAmount("2023-09-06");
            StatTradeAmount("2023-09-07");
            StatTradeAmount("2023-09-08");
            StatTradeAmount("2023-09-09");
            StatTradeAmount("2023-09-10");
            StatTradeAmount("2023-09-11");
            StatTradeAmount("2023-09-12");
            StatTradeAmount("2023-09-13");
            StatTradeAmount("2023-09-14");
            StatTradeAmount("2023-09-15");
            StatTradeAmount("2023-09-16");
            StatTradeAmount("2023-09-17");
            StatTradeAmount("2023-09-18");
            StatTradeAmount("2023-09-19");
            StatTradeAmount("2023-09-20");
            StatTradeAmount("2023-09-21");
            StatTradeAmount("2023-09-22");
            StatTradeAmount("2023-09-23");
            StatTradeAmount("2023-09-24");
            StatTradeAmount("2023-09-25");
            StatTradeAmount("2023-09-26");
            StatTradeAmount("2023-09-27");
            StatTradeAmount("2023-09-28");
            StatTradeAmount("2023-09-29");
            StatTradeAmount("2023-09-30");

            StatTradeAmount("2023-10-01");
            StatTradeAmount("2023-10-02");
            StatTradeAmount("2023-10-03");
            StatTradeAmount("2023-10-04");
            StatTradeAmount("2023-10-05");
            StatTradeAmount("2023-10-06");
            StatTradeAmount("2023-10-07");
            StatTradeAmount("2023-10-08");
            StatTradeAmount("2023-10-09");
            StatTradeAmount("2023-10-10");
            StatTradeAmount("2023-10-11");
            StatTradeAmount("2023-10-12");
            StatTradeAmount("2023-10-13");
            StatTradeAmount("2023-10-14");
            StatTradeAmount("2023-10-15");
            StatTradeAmount("2023-10-16");
            StatTradeAmount("2023-10-17");
            StatTradeAmount("2023-10-18");
            StatTradeAmount("2023-10-19");
            StatTradeAmount("2023-10-20");
            StatTradeAmount("2023-10-21");
            StatTradeAmount("2023-10-22");
            StatTradeAmount("2023-10-23");
            StatTradeAmount("2023-10-24");
            StatTradeAmount("2023-10-25");
            StatTradeAmount("2023-10-26");
            StatTradeAmount("2023-10-27");
            StatTradeAmount("2023-10-28");
            StatTradeAmount("2023-10-29");
            StatTradeAmount("2023-10-30");
            StatTradeAmount("2023-10-31");

            StatTradeAmount("2023-11-01");
            StatTradeAmount("2023-11-02");
            StatTradeAmount("2023-11-03");
            StatTradeAmount("2023-11-04");
            StatTradeAmount("2023-11-05");
            StatTradeAmount("2023-11-06");
            StatTradeAmount("2023-11-07");
            StatTradeAmount("2023-11-08");
            StatTradeAmount("2023-11-09");
            StatTradeAmount("2023-11-10");
            StatTradeAmount("2023-11-11");
            StatTradeAmount("2023-11-12");
            StatTradeAmount("2023-11-13");
            StatTradeAmount("2023-11-14");
            StatTradeAmount("2023-11-15");
            StatTradeAmount("2023-11-16");
            StatTradeAmount("2023-11-17");
            StatTradeAmount("2023-11-18");
            StatTradeAmount("2023-11-19");
            StatTradeAmount("2023-11-20");
            StatTradeAmount("2023-11-21");
            StatTradeAmount("2023-11-22");
            StatTradeAmount("2023-11-23");
            StatTradeAmount("2023-11-24");
            StatTradeAmount("2023-11-25");
            StatTradeAmount("2023-11-26");
            StatTradeAmount("2023-11-27");
            StatTradeAmount("2023-11-28");
            StatTradeAmount("2023-11-29");
            StatTradeAmount("2023-11-30");
        }
        public void StatTradeAmount(string date)
        {
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "重置创客交易额日志");
            WebCMSEntities db = new WebCMSEntities();
            KxsMainModels.WebCMSEntities maindb = new KxsMainModels.WebCMSEntities();
            using (var tran = db.Database.BeginTransaction())
            {
                try
                {
                    DataTable idsDt = CustomerSqlConn.dtable("select Id from ConsumerOrders where CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' and Status>0 and version=1", AppConfig.Base.SqlConn);
                    if(idsDt.Rows.Count > 0)
                    {
                        string ids = "";
                        foreach (DataRow idsDr in idsDt.Rows)
                        {
                            ids += idsDr["Id"].ToString() + ",";
                        }
                        DataTable selfDt = CustomerSqlConn.dtable("select UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MaxDivi),sum(MerchantActualAmount) from ConsumerOrders where Id in (" + ids.TrimEnd(',') + ") group by UserId,MerchantId,SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", AppConfig.Base.SqlConn);
                        if (selfDt.Rows.Count > 0)
                        {
                            CustomerSqlConn.dtable("delete from UserAmountSummary where TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.SqlConn);
                            function.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "重置创客交易额日志");
                            foreach (DataRow selfDr in selfDt.Rows)
                            {
                                int UserId = int.Parse(selfDr["UserId"].ToString());
                                KxsMainModels.Users user = maindb.Users.FirstOrDefault(m => m.Id == UserId) ?? new KxsMainModels.Users();
                                string ParentNav = user.ParentNav;
                                int MerchantId = int.Parse(selfDr["MerchantId"].ToString());
                                int PayMode = int.Parse(selfDr["PayMode"].ToString());
                                int IsAct = int.Parse(selfDr["IsAct"].ToString());
                                string SnNo = selfDr["SnNo"].ToString();
                                string TradeDate = selfDr[5].ToString();
                                decimal TradeAmount = decimal.Parse(selfDr[6].ToString());
                                int TradeCount = int.Parse(selfDr[7].ToString());
                                decimal MaxDivi = decimal.Parse(selfDr[8].ToString());
                                decimal ActualAmount = decimal.Parse(selfDr[9].ToString());
                                string TradeMonth = TradeDate.Substring(0, 6);

                                //创客交易额
                                UserAmountSummary selfStat = db.UserAmountSummary.FirstOrDefault(m => m.UserId == UserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "self");
                                if (selfStat == null)
                                {
                                    selfStat = db.UserAmountSummary.Add(new UserAmountSummary()
                                    {
                                        UserId = UserId,
                                        TradeMonth = TradeMonth,
                                        TradeDate = TradeDate,
                                        PayMode = PayMode,
                                        IsAct = IsAct,
                                        SeoTitle = "self",
                                    }).Entity;
                                    db.SaveChanges();
                                }
                                selfStat.TotalAmount += TradeAmount;
                                selfStat.TradeCount += TradeCount;
                                ParentNav += "," + UserId + ",";
                                if (!string.IsNullOrEmpty(ParentNav))
                                {
                                    string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(',');
                                    foreach (string NavUserIdString in ParentNavList)
                                    {
                                        int NavUserId = int.Parse(NavUserIdString);
                                        UserAmountSummary teamStat = db.UserAmountSummary.FirstOrDefault(m => m.UserId == NavUserId && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode && m.SeoTitle == "team");
                                        if (teamStat == null)
                                        {
                                            teamStat = db.UserAmountSummary.Add(new UserAmountSummary()
                                            {
                                                UserId = NavUserId,
                                                TradeMonth = TradeMonth,
                                                TradeDate = TradeDate,
                                                PayMode = PayMode,
                                                IsAct = IsAct,
                                                SeoTitle = "team",
                                            }).Entity;
                                            db.SaveChanges();
                                        }
                                        teamStat.TotalAmount += TradeAmount;
                                        teamStat.TradeCount += TradeCount;
                                    }
                                }
                                db.SaveChanges();
                            }
                        }
                    }
                    tran.Commit();
                }
                catch (Exception ex)
                {
                    tran.Rollback();
                    function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置创客交易额异常");
                }
            }
            db.Dispose();
            maindb.Dispose();
            function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "重置创客交易额日志");
        }
    }
}