|
|
@@ -25,29 +25,32 @@ public class TmpHelper
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
- WebCMSEntities db = new WebCMSEntities();
|
|
|
- DoSomething(db);
|
|
|
- db.Dispose();
|
|
|
+ DoSomething();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
- function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "tmp重推金控交易数据异常");
|
|
|
+ function.WriteLog(DateTime.Now.ToString() + "\n" + ex.ToString(), "tmp重推交易数据异常");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public void DoSomething(WebCMSEntities db)
|
|
|
+ public void DoSomething()
|
|
|
{
|
|
|
- List<string> orderNos = new List<string>();
|
|
|
- DateTime start = DateTime.Parse("2025-10-17 10:21:15");
|
|
|
- DateTime end = DateTime.Parse("2025-10-27 11:25:10");
|
|
|
- List<TradeRecord> trades = db.TradeRecord.Where(m => m.Id >= 142418748 && m.Id <= 142676302 && m.ProductType == "27" && m.CreateDate >= start && m.CreateDate <= end && m.ErrorCode == "0.007").OrderBy(m => m.Id).ToList();
|
|
|
- foreach (TradeRecord trade in trades.ToList())
|
|
|
+ Dictionary<string, string> dic = new Dictionary<string, string>();
|
|
|
+ string[] data = function.ReadInstance("/tmpdata/mer.txt").Split('\n');
|
|
|
+ foreach(string sub in data)
|
|
|
{
|
|
|
- if(!orderNos.Contains(trade.TradeSerialNo))
|
|
|
+ string[] item = sub.Split('|');
|
|
|
+ dic.Add(item[0], item[1]);
|
|
|
+ }
|
|
|
+ List<TradeRecord> list = Newtonsoft.Json.JsonConvert.DeserializeObject<List<TradeRecord>>(function.ReadInstance("/tmpdata/trade.json"));
|
|
|
+ foreach (TradeRecord trade in list)
|
|
|
+ {
|
|
|
+ if (dic.ContainsKey(trade.MerNo))
|
|
|
{
|
|
|
+ trade.MerNo = dic[trade.MerNo];
|
|
|
+ trade.TradeSerialNo = trade.TradeSerialNo + "a";
|
|
|
PosPushDataNewHelper.Trade(trade);
|
|
|
- function.WriteLog(trade.TradeSnNo + "--" + trade.TradeSerialNo, "tmp重推金控交易数据");
|
|
|
- orderNos.Add(trade.TradeSerialNo);
|
|
|
+ Thread.Sleep(500);
|
|
|
}
|
|
|
}
|
|
|
}
|