|
@@ -318,157 +318,5 @@ namespace MySystem
|
|
|
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<TradeRecord> 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异常");
|
|
|
- }
|
|
|
- }
|
|
|
}
|
|
|
}
|