using System; using System.Collections.Generic; using System.Linq; using MySystem.SpModels; using Library; using LitJson; using System.Threading; namespace MySystem { public class SycnSpTradeService { public readonly static SycnSpTradeService Instance = new SycnSpTradeService(); private SycnSpTradeService() { } public void Start() { Thread th = new Thread(StartDo); th.IsBackground = true; th.Start(); } public void StartDo() { while (true) { try { WebCMSEntities spdb = new WebCMSEntities(); PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities(); DateTime start = DateTime.Now.AddDays(-30); IQueryable trades = spdb.TradeRecord; trades = trades.Where(m => m.CreateDate >= start && m.Status == 1); trades = trades.OrderBy(m => m.CreateDate); foreach (TradeRecord trade in trades.ToList()) { bool op = true; if (trade.SerEntryMode == "N") { if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900) { op = false; PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo(); PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId); if (pos != null) { if (trade.SerEntryMode == "N" && trade.ProductType == "1") { pos.SeoKeyword = trade.TradeAmount.ToString("f2"); pos.IsPurchase = 0; db.SaveChanges(); } } TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id); if (edit != null) { edit.Status = 2; } spdb.SaveChanges(); } } if (trade.DiscountRateFlag == "True") { op = false; TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id); if (edit != null) { edit.Status = 2; } spdb.SaveChanges(); } if (op) { PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo(); PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId); if (pos != null) { if (pos.BindMerchantId > 0) { PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users(); int TopUserId = 0; if (!string.IsNullOrEmpty(user.ParentNav)) { TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } bool check = db.TradeRecord.Any(m => m.RecordNo == trade.TradeSerialNo); if (!check) { decimal TradeAmount = trade.TradeAmount; int BankCardType = -1; int QrPayFlag = 0; if (pos.BrandId == 1 || pos.BrandId == 3) { TradeAmount = TradeAmount / 100; BankCardType = int.Parse(trade.BankCardType); if (trade.TradeType == "02") QrPayFlag = 1; } else if (pos.BrandId == 2) { if (trade.TradeType == "CREDIT_BY_CARD") { BankCardType = 1; } else if (trade.TradeType == "DEBIT_BY_CARD") { BankCardType = 0; } if (trade.TradeType == "CLOUD_PAY") QrPayFlag = 1; } else if (pos.BrandId == 4 || pos.BrandId == 5) { TradeAmount = TradeAmount / 100; if (trade.BankCardType == "100") { BankCardType = 1; } else if (trade.BankCardType == "200") { BankCardType = 0; } if (trade.TradeType == "200") QrPayFlag = 1; } else if (pos.BrandId == 6) { TradeAmount = TradeAmount / 100; if (trade.BankCardType == "01" || trade.BankCardType == "11") { BankCardType = 0; } else { BankCardType = 1; } } int BrandId = int.Parse(trade.ProductType); if (trade.MerNo.StartsWith("M900")) { BrandId = 3; } db.TradeRecord.Add(new PxcModels.TradeRecord() { CreateDate = trade.CreateDate, UpdateDate = trade.UpdateDate, RecordNo = trade.TradeSerialNo, //单号 UserId = pos.UserId, //创客 MerchantId = pos.BindMerchantId, //商户 MerNo = trade.MerNo, //渠道商户编号 MerHelpFlag = 0, //是否属于扶持周期内商户 HelpMonthCount = 0, //扶持第几个月 MerBuddyType = user.MerchantType, //商户创客类型 SnNo = trade.TradeSnNo, //渠道SN号 // TradeDate = DateTime.Parse(trade.TradeTime), //交易日期 TradeSerialNo = trade.ChannelSerial, //交易流水号 TradeAmount = TradeAmount, //交易金额 BankCardType = BankCardType, //银行卡类型 QrPayFlag = QrPayFlag, //云闪付标识 BrandId = BrandId, //品牌 Remark = trade.Remark, //备注 TopUserId = TopUserId, //顶级创客 MerUserId = pos.UserId, //商户直属创客 }); decimal CheckMoney = 1000; int CheckDays = 20; if (pos.BrandId == 6) { CheckMoney = 5000; CheckDays = 30; } if (BankCardType == 1) { pos.CreditTrade += TradeAmount; } else if (BankCardType == 0) { pos.DebitCardTrade += TradeAmount; } if (pos.CreditTrade < CheckMoney) { decimal deposit = decimal.Parse(function.CheckNum(pos.SeoKeyword)); if (deposit > 0) { pos.IsPurchase = 0; } else { pos.IsPurchase = 99; } } else if (pos.CreditTrade >= CheckMoney && pos.ActivationState == 0 && pos.BindingTime > DateTime.Now.AddDays(-CheckDays)) { pos.IsPurchase = 0; pos.ActivationState = 1; pos.ActivationTime = DateTime.Now; PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId); if (merchant != null) { merchant.ActiveStatus = 1; merchant.MerStandardDate = DateTime.Now; db.SaveChanges(); RedisDbconn.Instance.Set("PosMerchantInfo:" + merchant.Id, merchant); } } // 立刷60天内刷满10000，再返40 if (pos.BrandId == 6 && pos.CreditTrade >= 10000 && pos.BindingTime > DateTime.Now.AddDays(-60)) { PxcModels.PosMerchantInfo merchant = db.PosMerchantInfo.FirstOrDefault(m => m.Id == pos.BindMerchantId) ?? new PxcModels.PosMerchantInfo(); PxcModels.Users getUser = db.Users.FirstOrDefault(m => m.Id == pos.BuyUserId) ?? new PxcModels.Users(); int BuyTopUserId = 0; string ParentNav = getUser.ParentNav; if (!string.IsNullOrEmpty(ParentNav)) { string[] ParentNavList = ParentNav.Trim(',').Replace(",,", ",").Split(','); if (ParentNavList.Length > 1) { BuyTopUserId = int.Parse(ParentNavList[1]); } else if (ParentNavList.Length == 1) { BuyTopUserId = int.Parse(ParentNavList[0]); } } StatService.Instance.doActiveReward(db, merchant, pos, getUser.Id, getUser.ParentNav, BuyTopUserId, 40); } db.SaveChanges(); } TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id); if (edit != null) { edit.Status = 2; } spdb.SaveChanges(); } } } } spdb.Dispose(); db.Dispose(); } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常"); } Thread.Sleep(1000); } } public void StartTest() { DateTime today = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00"); DateTime check = DateTime.Parse("2022-04-19"); while (check <= today) { Thread th = new Thread(StartTestDo); th.IsBackground = true; th.Start(check.ToString("yyyy-MM-dd")); check = check.AddDays(1); } } public void StartTestDo(object sender) { string date = sender.ToString(); DateTime start = DateTime.Parse(date); DateTime end = start.AddDays(1); try { WebCMSEntities spdb = new WebCMSEntities(); PxcModels.WebCMSEntities db = new PxcModels.WebCMSEntities(); IQueryable trades = spdb.TradeRecord; trades = trades.Where(m => m.CreateDate >= start && m.CreateDate < end); trades = trades.OrderBy(m => m.Id); foreach (TradeRecord trade in trades.ToList()) { bool op = true; if (trade.SerEntryMode == "N") { if (trade.TradeAmount == 9900 || trade.TradeAmount == 19900 || trade.TradeAmount == 29900) { op = false; TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id); if (edit != null) { edit.Status = 2; } spdb.SaveChanges(); } } if (trade.DiscountRateFlag == "True") { op = false; TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id); if (edit != null) { edit.Status = 2; } spdb.SaveChanges(); } if (op) { PxcModels.MachineForMerNo posFor = db.MachineForMerNo.FirstOrDefault(m => m.MerNo == trade.MerNo) ?? new PxcModels.MachineForMerNo(); PxcModels.PosMachinesTwo pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == posFor.SnId); if (pos != null) { if (pos.BindMerchantId > 0) { PxcModels.Users user = db.Users.FirstOrDefault(m => m.Id == pos.UserId) ?? new PxcModels.Users(); int TopUserId = 0; if (!string.IsNullOrEmpty(user.ParentNav)) { TopUserId = int.Parse(user.ParentNav.Trim(',').Replace(",,", ",").Split(',')[0]); } bool check = db.TradeRecord.Any(m => m.RecordNo == trade.TradeSerialNo); if (!check) { decimal TradeAmount = trade.TradeAmount; int BankCardType = -1; int QrPayFlag = 0; if (pos.BrandId == 1 || pos.BrandId == 3) { TradeAmount = TradeAmount / 100; BankCardType = int.Parse(trade.BankCardType); if (trade.TradeType == "02") QrPayFlag = 1; } else if (pos.BrandId == 2) { if (trade.TradeType == "CREDIT_BY_CARD") { BankCardType = 1; } else if (trade.TradeType == "DEBIT_BY_CARD") { BankCardType = 0; } if (trade.TradeType == "CLOUD_PAY") QrPayFlag = 1; } else if (pos.BrandId == 4 || pos.BrandId == 5) { TradeAmount = TradeAmount / 100; if (trade.BankCardType == "100") { BankCardType = 1; } else if (trade.BankCardType == "200") { BankCardType = 0; } if (trade.TradeType == "200") QrPayFlag = 1; } int BrandId = int.Parse(trade.ProductType); if (trade.MerNo.StartsWith("M900")) { BrandId = 3; } db.TradeRecord.Add(new PxcModels.TradeRecord() { CreateDate = trade.CreateDate, UpdateDate = trade.UpdateDate, RecordNo = trade.TradeSerialNo, //单号 UserId = pos.UserId, //创客 MerchantId = pos.BindMerchantId, //商户 MerNo = trade.MerNo, //渠道商户编号 MerHelpFlag = 0, //是否属于扶持周期内商户 HelpMonthCount = 0, //扶持第几个月 MerBuddyType = user.MerchantType, //商户创客类型 SnNo = trade.TradeSnNo, //渠道SN号 // TradeDate = DateTime.Parse(trade.TradeTime), //交易日期 TradeSerialNo = trade.ChannelSerial, //交易流水号 TradeAmount = TradeAmount, //交易金额 BankCardType = BankCardType, //银行卡类型 QrPayFlag = QrPayFlag, //云闪付标识 BrandId = BrandId, //品牌 Remark = trade.Remark, //备注 TopUserId = TopUserId, //顶级创客 MerUserId = pos.UserId, //商户直属创客 }); db.SaveChanges(); } TradeRecord edit = spdb.TradeRecord.FirstOrDefault(m => m.Id == trade.Id); if (edit != null) { edit.Status = 2; } spdb.SaveChanges(); } } } } spdb.Dispose(); db.Dispose(); } catch (Exception ex) { function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "同步SP交易数据到MAIN异常"); } } } }