using System; using System.Collections.Generic; using Library; using LitJson; using System.Linq; using System.Data; using System.Threading; using MySystem.PxcModels2; namespace MySystem { public class StatResetService2 { public readonly static StatResetService2 Instance = new StatResetService2(); private StatResetService2() { } public void StartReset() { Thread th = new Thread(StartResetMerchantDo); th.IsBackground = true; th.Start(); Thread thUser = new Thread(StartResetUserSelfDo); thUser.IsBackground = true; thUser.Start(); Thread thUserTeam = new Thread(StartResetUserTeamDo); thUserTeam.IsBackground = true; thUserTeam.Start(); Thread thSn = new Thread(StartResetSnDo); thSn.IsBackground = true; thSn.Start(); } public void StartResetMerchantDo() { while (true) { string content = RedisDbconn.Instance.RPop("ResetMerchantStatDataQueue2"); if (!string.IsNullOrEmpty(content)) { StatResetMerchantAmount(content); } Thread.Sleep(10000); } // StatResetMerchantAmount("{\"MerchantId\":\"" + 1153 + "\",\"StartDate\":\"" + 20231001 + "\",\"EndDate\":\"" + 20231029 + "\"}"); } public void StatResetMerchantAmount(string content) { JsonData jsonObj = JsonMapper.ToObject(content); string merchantId = jsonObj["MerchantId"].ToString(); string startDate = jsonObj["StartDate"].ToString(); string endDate = jsonObj["EndDate"].ToString(); Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"), "重置商户交易额日志"); WebCMSEntities db = new WebCMSEntities(); MySystem.KxsMainModels.WebCMSEntities kxsdb = new MySystem.KxsMainModels.WebCMSEntities(); var merId = int.Parse(merchantId); var merchant = db.MerchantInfo.FirstOrDefault(m => m.Id == merId) ?? new MerchantInfo(); var order = db.ConsumerOrders.Where(m => m.MerchantId == merchant.Id && m.Status > 0).ToList(); merchant.TotalConsumeCount = order.Count(); merchant.TotalAmount = order.Sum(m => m.PayMoney); merchant.TotalActual = order.Sum(m => m.MerchantActualAmount); merchant.TotalActAmount = order.Where(m => m.IsAct == 1).Sum(m => m.PayMoney); merchant.TotalActActual = order.Where(m => m.IsAct == 1).Sum(m => m.MerchantActualAmount); db.SaveChanges(); var user = kxsdb.Users.FirstOrDefault(m => m.Id == merchant.UserId) ?? new KxsMainModels.Users(); var ParentNavs = user.ParentNav + "," + user.Id; string[] ParentNavList = ParentNavs.Trim(',').Replace(",,", ",").Split(','); var ParentNav = ParentNavs.Trim(',').Replace(",,", ",").TrimEnd(','); var SnNos = ""; DataTable SnNoInfo = CustomerSqlConn.dtable("SELECT SnNo FROM ConsumerOrders WHERE Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + startDate.Substring(0, 4) + "-" + startDate.Substring(4, 2) + "-" + startDate.Substring(6, 2) + " 00:00:00' and CreateDate<='" + endDate.Substring(0, 4) + "-" + endDate.Substring(4, 2) + "-" + endDate.Substring(6, 2) + " 23:59:59' GROUP BY SnNo", AppConfig.Base.SqlConn2); if (SnNoInfo.Rows.Count > 0) { foreach (DataRow selfDr in SnNoInfo.Rows) { SnNos += "'" + selfDr["SnNo"].ToString() + "'" + ","; } SnNos = SnNos.TrimEnd(','); } try { for (DateTime start = DateTime.Parse(startDate.Substring(0, 4) + "-" + startDate.Substring(4, 2) + "-" + startDate.Substring(6, 2)); start <= DateTime.Parse(endDate.Substring(0, 4) + "-" + endDate.Substring(4, 2) + "-" + endDate.Substring(6, 2)); start = start.AddDays(1)) { var date = start.ToString("yyyy-MM-dd"); var smonth = start.ToString("yyyy-MM"); var emonth = start.AddMonths(1).ToString("yyyy-MM"); ResetMerchantTrade(date, merchantId); CustomerSqlConn.op("delete from UserAmountSummary where UserId in(" + ParentNav + ") and TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.SqlConn2); CustomerSqlConn.op("INSERT INTO UserAmountSummary (SeoTitle,PayMode,TotalAmount,TradeMonth,TradeDate,UserId,TradeCount,IsAct) select 'self' SeoTitle,PayMode,SUM(PayMoney) TotalAmount,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth,DATE_FORMAT(CreateDate,'%Y%m%d') TradeDate, " + merchant.UserId + " UserId,count(Id) TradeCount,IsAct from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn2); for (int a = 0; a < ParentNavList.Length; a++) { var UserId = ParentNavList[a]; CustomerSqlConn.op("INSERT INTO UserAmountSummary (SeoTitle,PayMode,TotalAmount,TradeMonth,TradeDate,UserId,TradeCount,IsAct) select 'team' SeoTitle,PayMode,SUM(PayMoney) TotalAmount,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth,DATE_FORMAT(CreateDate,'%Y%m%d') TradeDate, " + UserId + " UserId,count(Id) TradeCount,IsAct from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn2); } CustomerSqlConn.op("delete from QrCodeAmountSummay where SnNo IN (" + SnNos + ") and TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.SqlConn2); CustomerSqlConn.op("INSERT INTO QrCodeAmountSummay (IsAct,TradeCount,PayMode,TotalActual,TradeAmount,TradeDate,TradeMonth,SnNo) SELECT IsAct,TradeCount,PayMode,TotalActual,TradeAmount,TradeDate,TradeMonth,SnNo FROM(SELECT PayMode, sum(MerchantActualAmount) TotalActual, sum(PayMoney) TradeAmount, DATE_FORMAT(CreateDate, '%Y%m%d') TradeDate, DATE_FORMAT(CreateDate, '%Y%m') TradeMonth, MerchantId, count(Id) TradeCount, IsAct, SnNo FROM ConsumerOrders WHERE Status > 0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' GROUP BY MerchantId, PayMode, IsAct, SnNo, DATE_FORMAT(CreateDate, '%Y%m%d'), DATE_FORMAT(CreateDate, '%Y%m'))a", AppConfig.Base.SqlConn2); CustomerSqlConn.op("delete from QrCodePlateStatServer2.MerchantTradeSummary" + date.Replace("-", "").Substring(0, 6) + " where MerchantId=" + merchantId + "", AppConfig.Base.StatSqlConn2); CustomerSqlConn.op("INSERT INTO QrCodePlateStatServer2.MerchantTradeSummary" + date.Replace("-", "").Substring(0, 6) + " (MerchantId,TradeAmount,InFactAmount,OderCount,WeChatInfactAmount,AliPayInFactAmount,ActAmount,NonActAmount,TradeMonth) select MerchantId,sum(PayMoney) TradeAmount,sum(MerchantActualAmount) InFactAmount,count(Id) Count,sum(if(PayMode=2,MerchantActualAmount,0)) WeChatInfactAmount,sum(if(PayMode=1,MerchantActualAmount,0)) AliPayInFactAmount,sum(if(IsAct=1,PayMoney,0)) ActAmount,sum(if(IsAct=0,PayMoney,0)) NonActAmount,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + smonth + "-01" + " 00:00:00' and CreateDate<'" + emonth + "-01" + " 00:00:00' group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn2); CustomerSqlConn.op("delete from QrCodePlateStatServer2.MerchantTradeSummaryList" + date.Replace("-", "").Substring(0, 6) + " where MerchantId=" + merchantId + " and TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.StatSqlConn2); CustomerSqlConn.op("INSERT INTO QrCodePlateStatServer2.MerchantTradeSummaryList" + date.Replace("-", "").Substring(0, 6) + " (MerchantId,TradeDate,TradeMonth,TradeAmount,InFactAmount,OderCount,WeChatInfactAmount,AliPayInFactAmount,ActAmount,NonActAmount) select MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d') Date ,DATE_FORMAT(CreateDate,'%Y%m') Month,sum(PayMoney) TradeAmount,sum(MerchantActualAmount) InFactAmount,count(Id) Count,sum(if(PayMode=2,MerchantActualAmount,0)) WeChatInfactAmount,sum(if(PayMode=1,MerchantActualAmount,0)) AliPayInFactAmount,sum(if(IsAct=1,PayMoney,0)) ActAmount,sum(if(IsAct=0,PayMoney,0)) NonActAmount from ConsumerOrders where Status>0 AND MerchantId=" + merchantId + " AND CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn2); } } catch (Exception ex) { Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置商户交易额异常"); } } public void ResetMerchantTrade(string date, string merchantId = "0") { string MerchantCondition = ""; if(merchantId != "0") { MerchantCondition = "MerchantId=" + merchantId + " and "; } CustomerSqlConn.op("delete from QrCodePlateStatServer2.MerchantTradeSummary" + date.Replace("-", "") + " where " + MerchantCondition + "TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.StatSqlConn2); CustomerSqlConn.op("INSERT INTO QrCodePlateStatServer2.MerchantTradeSummary" + date.Replace("-", "") + " (MerchantId,TradeDate,TradeMonth,TradeAmount,InFactAmount,OderCount,WeChatInfactAmount,AliPayInFactAmount,ActAmount,NonActAmount) select MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d') Date ,DATE_FORMAT(CreateDate,'%Y%m') Month,sum(PayMoney) TradeAmount,sum(MerchantActualAmount) InFactAmount,count(Id) Count,sum(if(PayMode=2,MerchantActualAmount,0)) WeChatInfactAmount,sum(if(PayMode=1,MerchantActualAmount,0)) AliPayInFactAmount,sum(if(IsAct=1,PayMoney,0)) ActAmount,sum(if(IsAct=0,PayMoney,0)) NonActAmount from ConsumerOrders where Status>0 AND " + MerchantCondition + "CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by MerchantId,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn2); CustomerSqlConn.op("delete from MerchantAmountSummay where " + MerchantCondition + "TradeDate='" + date.Replace("-", "") + "'", AppConfig.Base.SqlConn2); CustomerSqlConn.op("INSERT INTO MerchantAmountSummay (PayMode,TotalActual,TradeAmount,TradeDate,TradeMonth,MerchantId,TradeCount,IsAct) select PayMode,sum(MerchantActualAmount) TotalActual,sum(PayMoney) TradeAmount,DATE_FORMAT(CreateDate,'%Y%m%d') TradeDate,DATE_FORMAT(CreateDate,'%Y%m') TradeMonth,MerchantId,count(Id) TradeCount,IsAct from ConsumerOrders where Status>0 AND " + MerchantCondition + "CreateDate>='" + date + " 00:00:00' and CreateDate<='" + date + " 23:59:59' group by MerchantId,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),DATE_FORMAT(CreateDate,'%Y%m')", AppConfig.Base.SqlConn2); } public void StartResetSnDo() { while (true) { string content = RedisDbconn.Instance.RPop("ResetSnStatDataQueue2"); if (!string.IsNullOrEmpty(content)) { StatResetSnAmount(content); } Thread.Sleep(10000); } } public void StatResetSnAmount(string content) { JsonData jsonObj = JsonMapper.ToObject(content); string snNo = jsonObj["SnNo"].ToString(); string startDate = jsonObj["StartDate"].ToString(); string endDate = jsonObj["EndDate"].ToString(); Utils.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 selfDt = CustomerSqlConn.dtable("select SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id),sum(MerchantActualAmount) from ConsumerOrders where SnNo=" + snNo + " and CreateDate>='" + startDate.Substring(0, 4) + "-" + startDate.Substring(4, 2) + "-" + startDate.Substring(6, 2) + " 00:00:00' and CreateDate<='" + endDate.Substring(0, 4) + "-" + endDate.Substring(4, 2) + "-" + endDate.Substring(6, 2) + " 23:59:59' group by SnNo,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", AppConfig.Base.SqlConn2); if (selfDt.Rows.Count > 0) { Utils.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "重置码牌交易额日志"); foreach (DataRow selfDr in selfDt.Rows) { int PayMode = int.Parse(selfDr["PayMode"].ToString()); int IsAct = int.Parse(selfDr["IsAct"].ToString()); string SnNo = selfDr["SnNo"].ToString(); string TradeDate = selfDr[3].ToString(); decimal TradeAmount = decimal.Parse(selfDr[4].ToString()); int TradeCount = int.Parse(selfDr[5].ToString()); decimal ActualAmount = decimal.Parse(selfDr[6].ToString()); string TradeMonth = TradeDate.Substring(0, 6); //码牌交易额 QrCodeAmountSummay qrcode = db.QrCodeAmountSummay.FirstOrDefault(m => m.SnNo == SnNo && m.IsAct == IsAct && m.TradeMonth == TradeMonth && m.TradeDate == TradeDate && m.PayMode == PayMode); if (qrcode == null) { qrcode = db.QrCodeAmountSummay.Add(new QrCodeAmountSummay() { SnNo = SnNo, TradeMonth = TradeMonth, TradeDate = TradeDate, PayMode = PayMode, IsAct = IsAct, }).Entity; db.SaveChanges(); } qrcode.TradeAmount += TradeAmount; qrcode.TradeCount += TradeCount; qrcode.TotalActual += ActualAmount; db.SaveChanges(); } } tran.Commit(); } catch (Exception ex) { tran.Rollback(); Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置码牌交易额异常"); } } db.Dispose(); maindb.Dispose(); Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "重置码牌交易额日志"); } public void StartResetUserSelfDo() { while (true) { string content = RedisDbconn.Instance.RPop("ResetUserSelfStatDataQueue2"); if (!string.IsNullOrEmpty(content)) { StatResetUserSelfAmount(content); } Thread.Sleep(10000); } } public void StatResetUserSelfAmount(string content) { JsonData jsonObj = JsonMapper.ToObject(content); string userId = jsonObj["UserId"].ToString(); string startDate = jsonObj["StartDate"].ToString(); string endDate = jsonObj["EndDate"].ToString(); Utils.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 selfDt = CustomerSqlConn.dtable("select UserId,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d'),sum(PayMoney),count(Id) from ConsumerOrders where UserId=" + userId + " and CreateDate>='" + startDate.Substring(0, 4) + "-" + startDate.Substring(4, 2) + "-" + startDate.Substring(6, 2) + " 00:00:00' and CreateDate<='" + endDate.Substring(0, 4) + "-" + endDate.Substring(4, 2) + "-" + endDate.Substring(6, 2) + " 23:59:59' group by UserId,PayMode,IsAct,DATE_FORMAT(CreateDate,'%Y%m%d')", AppConfig.Base.SqlConn2); if (selfDt.Rows.Count > 0) { Utils.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(); int PayMode = int.Parse(selfDr["PayMode"].ToString()); int IsAct = int.Parse(selfDr["IsAct"].ToString()); string TradeDate = selfDr[3].ToString(); decimal TradeAmount = decimal.Parse(selfDr[4].ToString()); int TradeCount = int.Parse(selfDr[5].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; db.SaveChanges(); string ParentNav = user.ParentNav + "," + userId + ","; if (!string.IsNullOrEmpty(ParentNav)) { string[] ParentNavList = ParentNav.Replace(",,", ",").Trim(',').Split(','); foreach (string id in ParentNavList) { string reqdata = "{\"UserId\":\"" + id + "\",\"StartDate\":\"" + startDate + "\",\"EndDate\":\"" + endDate + "\"}"; RedisDbconn.Instance.AddList("ResetUserTeamStatDataQueue2", reqdata); } } } } tran.Commit(); } catch (Exception ex) { tran.Rollback(); Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置创客个人交易额异常"); } } db.Dispose(); maindb.Dispose(); Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "重置创客个人交易额日志"); } public void StartResetUserTeamDo() { while (true) { string content = RedisDbconn.Instance.RPop("ResetUserTeamStatDataQueue2"); if (!string.IsNullOrEmpty(content)) { StatResetUserTeamAmount(content); } Thread.Sleep(10000); } } public void StatResetUserTeamAmount(string content) { JsonData jsonObj = JsonMapper.ToObject(content); int userId = int.Parse(jsonObj["UserId"].ToString()); string startDate = jsonObj["StartDate"].ToString(); string endDate = jsonObj["EndDate"].ToString(); Utils.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 { string subUserId = "0"; var subusers = maindb.Users.Select(m => new { m.Id, m.ParentUserId }).Where(m => m.ParentUserId == userId).ToList(); foreach (var subuser in subusers) { subUserId += "," + subuser.Id; } DataTable selfDt = CustomerSqlConn.dtable("select PayMode,TotalAmount,TradeMonth,TradeDate,UserId,TradeCount,IsAct from UserAmountSummary where UserId in (" + subUserId + ") and TradeDate>='" + startDate + "' and TradeDate<='" + endDate + "' and SeoTitle='team'", AppConfig.Base.SqlConn2); if (selfDt.Rows.Count > 0) { Utils.WriteLog("统计人数:" + selfDt.Rows.Count + "\n\n", "重置团队创客交易额日志"); foreach (DataRow selfDr in selfDt.Rows) { int UserId = int.Parse(selfDr["UserId"].ToString()); int PayMode = int.Parse(selfDr["PayMode"].ToString()); int IsAct = int.Parse(selfDr["IsAct"].ToString()); string TradeDate = selfDr["TradeDate"].ToString(); decimal TradeAmount = decimal.Parse(selfDr["TotalAmount"].ToString()); int TradeCount = int.Parse(selfDr["TradeCount"].ToString()); string TradeMonth = selfDr["TradeMonth"].ToString(); //创客交易额 UserAmountSummary teamStat = db.UserAmountSummary.FirstOrDefault(m => m.UserId == UserId && 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 = UserId, TradeMonth = TradeMonth, TradeDate = TradeDate, PayMode = PayMode, IsAct = IsAct, SeoTitle = "self", }).Entity; db.SaveChanges(); } teamStat.TotalAmount = TradeAmount; teamStat.TradeCount = TradeCount; db.SaveChanges(); } } tran.Commit(); } catch (Exception ex) { tran.Rollback(); Utils.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "重置团队创客交易额异常"); } } db.Dispose(); maindb.Dispose(); Utils.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "\n\n", "重置团队创客交易额日志"); } } }