GetHaoDaFTPInfoService.cs 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Data;
  5. using System.Threading;
  6. using Library;
  7. using LitJson;
  8. using System.Net;
  9. using System.IO;
  10. using MySystem.SpModels;
  11. namespace MySystem
  12. {
  13. /// <summary>
  14. /// 获取好哒ftp数据
  15. /// </summary>
  16. public class GetHaoDaFTPInfoService
  17. {
  18. public readonly static GetHaoDaFTPInfoService Instance = new GetHaoDaFTPInfoService();
  19. private GetHaoDaFTPInfoService()
  20. { }
  21. // 47.108.253.46
  22. // 用户名:hdftp
  23. // 密:haodatradeftp2024
  24. // 目录:/haoda-trade
  25. public string ftpServerAddress = "ftp://47.108.253.46";
  26. public string ftpUser = "hdftp";
  27. public string ftpPassword = "haodatradeftp2024";
  28. public void Start()
  29. {
  30. //每天凌晨执行获取好哒FTP昨日交易数据
  31. Thread th2 = new Thread(GetDepositDataReady);
  32. th2.IsBackground = true;
  33. th2.Start();
  34. }
  35. /// <summary>
  36. /// 获取好哒FTP昨日交易数据
  37. /// </summary>
  38. public void GetDepositDataReady()
  39. {
  40. while (true)
  41. {
  42. if (DateTime.Now.Hour > 10 && DateTime.Now.Hour < 22)
  43. {
  44. string check = function.ReadInstance("/GetFTPDepositYesterday/check" + DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + ".txt");
  45. if (string.IsNullOrEmpty(check))
  46. {
  47. function.WritePage("/GetFTPDepositYesterday/", "check" + DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + ".txt", DateTime.Now.ToString());
  48. GetDepositData(DateTime.Now.AddDays(-1).ToString("yyyyMMdd"));
  49. Thread.Sleep(60000);
  50. GetTradeData(DateTime.Now.AddDays(-1).ToString("yyyyMMdd"));
  51. Thread.Sleep(600000);
  52. }
  53. }
  54. if (DateTime.Now.Hour > 10)
  55. {
  56. GetDepositData("d_" + DateTime.Now.ToString("yyyyMMdd"));
  57. }
  58. Thread.Sleep(1800000);
  59. }
  60. }
  61. public void StartListen()
  62. {
  63. //每天凌晨执行获取好哒FTP昨日交易数据
  64. Thread th2 = new Thread(ListenDepositDataReady);
  65. th2.IsBackground = true;
  66. th2.Start();
  67. }
  68. /// <summary>
  69. /// 获取好哒FTP昨日交易数据
  70. /// </summary>
  71. public void ListenDepositDataReady()
  72. {
  73. while (true)
  74. {
  75. string content = RedisDbconn.Instance.RPop<string>("ListenDepositDataQueue2");
  76. if (!string.IsNullOrEmpty(content))
  77. {
  78. GetDepositData2(content);
  79. Thread.Sleep(2000);
  80. }
  81. else
  82. {
  83. Thread.Sleep(60000);
  84. }
  85. }
  86. }
  87. public void GetDepositData(string Date)
  88. {
  89. // 要下载的文件路径
  90. string filePath = "/haoda-deposit/deposit_" + Date + ".csv";
  91. try
  92. {
  93. // 创建FtpWebRequest对象
  94. FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServerAddress + filePath);
  95. request.Method = WebRequestMethods.Ftp.DownloadFile;
  96. request.Credentials = new NetworkCredential(ftpUser, ftpPassword);
  97. // 使用WebResponse获取响应
  98. FtpWebResponse response = (FtpWebResponse)request.GetResponse();
  99. // 打开数据流
  100. Stream responseStream = response.GetResponseStream();
  101. StreamReader reader = new StreamReader(responseStream);
  102. // 读取数据
  103. string fileContents = reader.ReadToEnd();
  104. if (!string.IsNullOrEmpty(fileContents))
  105. {
  106. WebCMSEntities db = new WebCMSEntities();
  107. MpMainModels2.WebCMSEntities mpdb2 = new MpMainModels2.WebCMSEntities();
  108. var DataInfo = fileContents.TrimEnd('\n').Split('\n', 2);
  109. if(DataInfo.Length > 1)
  110. {
  111. var DataList = DataInfo[1].Split('\n');
  112. foreach (var DataListItem in DataList)
  113. {
  114. var DataListInfo = DataListItem.Split(',');
  115. string SnNo = DataListInfo[0]; //sn
  116. string MerNo = DataListInfo[1]; //商户编号
  117. string PosKind = DataListInfo[2]; //机具型号
  118. string ActDate = DataListInfo[3]; //激活时间
  119. string Deposit = DataListInfo[4]; //押金金额
  120. string PrizeAmt = "0"; //奖励金额
  121. string PrizeDate = "None"; //奖励发放时间
  122. string Name = ""; //发放人姓名
  123. string MerName = ""; //商户名称
  124. string PassDate = ""; //审核通过时期
  125. if(Date.StartsWith("d_"))
  126. {
  127. MerName = DataListInfo[5]; //商户名称
  128. PassDate = DataListInfo[6]; //审核通过时期
  129. }
  130. else
  131. {
  132. PrizeAmt = DataListInfo[5]; //奖励金额
  133. PrizeDate = DataListInfo[6]; //奖励发放时间
  134. Name = DataListInfo[7]; //发放人姓名
  135. MerName = DataListInfo[8]; //商户名称
  136. PassDate = DataListInfo[9]; //审核通过时期
  137. }
  138. string ActDateString = ActDate.Substring(0, 4) + "-" + ActDate.Substring(4, 2) + "-" + ActDate.Substring(6, 2);
  139. if(DateTime.Parse(ActDateString) >= DateTime.Parse(DateTime.Now.AddDays(-2).ToString("yyyy-MM-dd")))
  140. {
  141. string PrizeDateString = "";
  142. if(PrizeDate == "None")
  143. {
  144. PrizeDate = Date;
  145. }
  146. else
  147. {
  148. PrizeDateString = PrizeDate.Substring(0, 4) + "-" + PrizeDate.Substring(4, 2) + "-" + PrizeDate.Substring(6, 2);
  149. }
  150. if(!db.BindRecord.Any(m => m.MerSnNo == SnNo))
  151. {
  152. string ProductType = "0";
  153. if(PosKind == "好哒语音王Y512") ProductType = "18";
  154. if(PosKind == "4G收款王M820") ProductType = "19";
  155. if(PosKind == "4G收款王M826") ProductType = "20";
  156. if(PosKind == "好哒S312") ProductType = "21";
  157. if(PosKind == "好哒扫码通M837") ProductType = "29";
  158. db.BindRecord.Add(new BindRecord()
  159. {
  160. CreateDate = DateTime.Now,
  161. UpdateTime = DateTime.Now, //机具绑定、解绑时间
  162. CreateTime = DateTime.Now, //商户操作时间
  163. MerSnNo = SnNo, //序列号
  164. MerNo = MerNo, //商户编号
  165. MerName = MerName,
  166. SeoTitle = PrizeAmt,
  167. SeoKeyword = ActDateString,
  168. ProductType = ProductType,
  169. Field1 = Deposit,
  170. Field2 = PrizeDate,
  171. Field3 = Name,
  172. Field4 = PassDate,
  173. Status = 1,
  174. });
  175. db.Merchants.Add(new Merchants()
  176. {
  177. SnNo = SnNo,
  178. CreateTime = DateTime.Now,
  179. UpdateTime = DateTime.Now,
  180. AgentName = Name,
  181. MerRealName = Name,
  182. MerNo = MerNo,
  183. MerName = Name,
  184. ProductType = ProductType,
  185. Status = 1,
  186. });
  187. db.SaveChanges();
  188. Thread.Sleep(1000);
  189. db.ActivateRecord.Add(new ActivateRecord()
  190. {
  191. SnNo = SnNo,
  192. CreateDate = DateTime.Now,
  193. SeoTitle = Deposit,
  194. ActivateDate = DateTime.Now,
  195. AgentNo = MerNo,
  196. MerRealName = Name,
  197. MerNo = MerNo,
  198. MerName = Name,
  199. ProductType = ProductType,
  200. ChannelSerial = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8),
  201. Status = 1,
  202. Field1 = PassDate,
  203. });
  204. db.SaveChanges();
  205. //推送MQ给创业帮
  206. var merchantAddInfo = mpdb2.MerchantAddInfo.FirstOrDefault(m => m.MchtNo == MerNo) ?? new MpMainModels2.MerchantAddInfo();
  207. if (merchantAddInfo.BrandId == 1 && !string.IsNullOrEmpty(merchantAddInfo.CybMakerCode))
  208. {
  209. SortedList<string, string> obj = new SortedList<string, string>();
  210. obj.Add("create_time", ActDateString);
  211. obj.Add("sn", SnNo);
  212. obj.Add("deposit", Deposit);
  213. obj.Add("subject_type", merchantAddInfo.SubjectType);
  214. obj.Add("merch_no", merchantAddInfo.MchtNo);
  215. obj.Add("maker_code", merchantAddInfo.CybMakerCode);
  216. PushHelper.Instance.Do(obj, "cashNotify");
  217. }
  218. }
  219. }
  220. }
  221. }
  222. db.Dispose();
  223. mpdb2.Dispose();
  224. }
  225. // 关闭响应
  226. reader.Dispose();
  227. responseStream.Dispose();
  228. response.Close();
  229. }
  230. catch (WebException ex)
  231. {
  232. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "获取好哒FTP文件数据异常");
  233. }
  234. }
  235. public void GetDepositData2(string Date)
  236. {
  237. // 要下载的文件路径
  238. string filePath = "/haoda-deposit/deposit_" + Date + ".csv";
  239. try
  240. {
  241. // 创建FtpWebRequest对象
  242. FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServerAddress + filePath);
  243. request.Method = WebRequestMethods.Ftp.DownloadFile;
  244. request.Credentials = new NetworkCredential(ftpUser, ftpPassword);
  245. // 使用WebResponse获取响应
  246. FtpWebResponse response = (FtpWebResponse)request.GetResponse();
  247. // 打开数据流
  248. Stream responseStream = response.GetResponseStream();
  249. StreamReader reader = new StreamReader(responseStream);
  250. // 读取数据
  251. string fileContents = reader.ReadToEnd();
  252. if (!string.IsNullOrEmpty(fileContents))
  253. {
  254. WebCMSEntities db = new WebCMSEntities();
  255. MpMainModels2.WebCMSEntities mpdb2 = new MpMainModels2.WebCMSEntities();
  256. var DataInfo = fileContents.TrimEnd('\n').Split('\n', 2);
  257. if(DataInfo.Length > 1)
  258. {
  259. var DataList = DataInfo[1].Split('\n');
  260. foreach (var DataListItem in DataList)
  261. {
  262. var DataListInfo = DataListItem.Split(',');
  263. string SnNo = DataListInfo[0]; //sn
  264. string MerNo = DataListInfo[1]; //商户编号
  265. string PosKind = DataListInfo[2]; //机具型号
  266. string ActDate = DataListInfo[3]; //激活时间
  267. string Deposit = DataListInfo[4]; //押金金额
  268. string PrizeAmt = DataListInfo[5]; //奖励金额
  269. string PrizeDate = DataListInfo[6]; //奖励发放时间
  270. string Name = DataListInfo[7]; //发放人姓名
  271. string ActDateString = ActDate.Substring(0, 4) + "-" + ActDate.Substring(4, 2) + "-" + ActDate.Substring(6, 2);
  272. string PrizeDateString = "";
  273. if(PrizeDate == "None")
  274. {
  275. PrizeDate = Date;
  276. }
  277. else
  278. {
  279. PrizeDateString = PrizeDate.Substring(0, 4) + "-" + PrizeDate.Substring(4, 2) + "-" + PrizeDate.Substring(6, 2);
  280. }
  281. string ProductType = "0";
  282. if(PosKind == "好哒语音王Y512") ProductType = "18";
  283. if(PosKind == "4G收款王M820") ProductType = "19";
  284. if(PosKind == "4G收款王M826") ProductType = "20";
  285. if(PosKind == "好哒S312") ProductType = "21";
  286. db.BindRecord.Add(new BindRecord()
  287. {
  288. CreateDate = DateTime.Now,
  289. UpdateTime = DateTime.Now, //机具绑定、解绑时间
  290. CreateTime = DateTime.Now, //商户操作时间
  291. MerSnNo = SnNo, //序列号
  292. MerNo = MerNo, //商户编号
  293. MerName = Name,
  294. SeoTitle = PrizeAmt,
  295. SeoKeyword = ActDateString,
  296. ProductType = ProductType,
  297. Field1 = Deposit,
  298. Field2 = PrizeDate,
  299. Status = 1,
  300. });
  301. db.Merchants.Add(new Merchants()
  302. {
  303. SnNo = SnNo,
  304. CreateTime = DateTime.Now,
  305. UpdateTime = DateTime.Now,
  306. AgentName = Name,
  307. MerRealName = Name,
  308. MerNo = MerNo,
  309. MerName = Name,
  310. ProductType = ProductType,
  311. Status = 1,
  312. });
  313. db.SaveChanges();
  314. Thread.Sleep(1000);
  315. db.ActivateRecord.Add(new ActivateRecord()
  316. {
  317. SnNo = SnNo,
  318. CreateDate = DateTime.Now,
  319. SeoTitle = Deposit,
  320. ActivateDate = DateTime.Now,
  321. AgentNo = MerNo,
  322. MerRealName = Name,
  323. MerNo = MerNo,
  324. MerName = Name,
  325. ProductType = ProductType,
  326. ChannelSerial = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8),
  327. Status = 1,
  328. });
  329. db.SaveChanges();
  330. //推送MQ给创业帮
  331. var merchantAddInfo = mpdb2.MerchantAddInfo.FirstOrDefault(m => m.MchtNo == MerNo) ?? new MpMainModels2.MerchantAddInfo();
  332. if (merchantAddInfo.BrandId == 1 && !string.IsNullOrEmpty(merchantAddInfo.CybMakerCode))
  333. {
  334. SortedList<string, string> obj = new SortedList<string, string>();
  335. obj.Add("create_time", ActDateString);
  336. obj.Add("sn", SnNo);
  337. obj.Add("deposit", Deposit);
  338. obj.Add("subject_type", merchantAddInfo.SubjectType);
  339. obj.Add("merch_no", merchantAddInfo.MchtNo);
  340. obj.Add("maker_code", merchantAddInfo.CybMakerCode);
  341. PushHelper.Instance.Do(obj, "cashNotify");
  342. }
  343. }
  344. }
  345. db.Dispose();
  346. mpdb2.Dispose();
  347. }
  348. // 关闭响应
  349. reader.Dispose();
  350. responseStream.Dispose();
  351. response.Close();
  352. }
  353. catch (WebException ex)
  354. {
  355. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "获取好哒FTP文件数据异常");
  356. }
  357. }
  358. public void StartTrade()
  359. {
  360. //每天凌晨执行获取好哒FTP昨日交易数据
  361. Thread th2 = new Thread(GetTradeDataReady);
  362. th2.IsBackground = true;
  363. th2.Start();
  364. }
  365. /// <summary>
  366. /// 获取好哒FTP昨日交易数据
  367. /// </summary>
  368. public void GetTradeDataReady()
  369. {
  370. while (true)
  371. {
  372. if (DateTime.Now.Hour > 10 && DateTime.Now.Hour < 22)
  373. {
  374. string check = function.ReadInstance("/GetFTPTradeYesterday/check" + DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + ".txt");
  375. if (string.IsNullOrEmpty(check))
  376. {
  377. function.WritePage("/GetFTPTradeYesterday/", "check" + DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd") + ".txt", DateTime.Now.ToString());
  378. GetTradeData(DateTime.Now.AddDays(-1).ToString("yyyyMMdd"));
  379. Thread.Sleep(600000);
  380. }
  381. }
  382. else
  383. {
  384. Thread.Sleep(1800000);
  385. }
  386. }
  387. }
  388. public void StartTradeListen()
  389. {
  390. //每天凌晨执行获取好哒FTP昨日交易数据
  391. Thread th2 = new Thread(ListenTradeDataReady);
  392. th2.IsBackground = true;
  393. th2.Start();
  394. }
  395. /// <summary>
  396. /// 获取好哒FTP昨日交易数据
  397. /// </summary>
  398. public void ListenTradeDataReady()
  399. {
  400. while (true)
  401. {
  402. string content = RedisDbconn.Instance.RPop<string>("ListenTradeDataQueue");
  403. if (!string.IsNullOrEmpty(content))
  404. {
  405. GetTradeData(content);
  406. Thread.Sleep(2000);
  407. }
  408. else
  409. {
  410. Thread.Sleep(60000);
  411. }
  412. }
  413. }
  414. public void GetTradeData(string Date)
  415. {
  416. // 要下载的文件路径
  417. string filePath = "/haoda-trade/" + Date + ".csv";
  418. function.WriteLog(DateTime.Now.ToString() + ":" + filePath, "获取好哒FTP文件交易数据");
  419. try
  420. {
  421. // 创建FtpWebRequest对象
  422. FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpServerAddress + filePath);
  423. request.Method = WebRequestMethods.Ftp.DownloadFile;
  424. request.Credentials = new NetworkCredential(ftpUser, ftpPassword);
  425. // 使用WebResponse获取响应
  426. FtpWebResponse response = (FtpWebResponse)request.GetResponse();
  427. // 打开数据流
  428. Stream responseStream = response.GetResponseStream();
  429. StreamReader reader = new StreamReader(responseStream);
  430. // 读取数据
  431. string fileContents = reader.ReadToEnd();
  432. function.WriteLog("fileContents:" + fileContents, "获取好哒FTP文件交易数据");
  433. if (!string.IsNullOrEmpty(fileContents))
  434. {
  435. MpMainModels2.WebCMSEntities db = new MpMainModels2.WebCMSEntities();
  436. var DataInfo = fileContents.TrimEnd('\n').Split('\n', 2);
  437. if(DataInfo.Length > 1)
  438. {
  439. var DataList = DataInfo[1].Split('\n');
  440. foreach (var DataListItem in DataList)
  441. {
  442. var DataListInfo = DataListItem.Split(',');
  443. var MerchantNo = ""; // 商户号
  444. var BaseNo = ""; // 设备号
  445. var OrderNo = ""; // 订单号
  446. var PayWay = ""; // 支付方式(微信 支付宝)
  447. var TradeType = ""; // 交易类型
  448. var TradeAmount = ""; // 交易金额
  449. var TradeFee = ""; // 交易手续费
  450. var TradeDate = ""; // 交易时间
  451. var TradeCycle = ""; // 结算周期
  452. MerchantNo = DataListInfo[0];
  453. BaseNo = DataListInfo[1];
  454. OrderNo = DataListInfo[3];
  455. PayWay = DataListInfo[4];
  456. TradeType = DataListInfo[5];
  457. TradeAmount = DataListInfo[6];
  458. TradeFee = DataListInfo[7];
  459. TradeDate = DataListInfo[8];
  460. TradeCycle = DataListInfo[9];
  461. TradeDate = TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2) + " " + TradeDate.Substring(8, 2) + ":" + TradeDate.Substring(10, 2) + ":" + TradeDate.Substring(12, 2);
  462. function.WriteLog("OrderNo:" + OrderNo, "获取好哒FTP文件交易数据");
  463. function.WriteLog("MerchantNo:" + MerchantNo, "获取好哒FTP文件交易数据");
  464. var PayMode = 0;
  465. if (PayWay.Contains("支付宝")) PayMode = 1;
  466. if (PayWay.Contains("微信")) PayMode = 2;
  467. var merchantAddInfo = db.MerchantAddInfo.FirstOrDefault(m => m.MchtNo == MerchantNo) ?? new MpMainModels2.MerchantAddInfo();
  468. if (merchantAddInfo.Id > 0)
  469. {
  470. function.WriteLog("找到商户", "获取好哒FTP文件交易数据");
  471. var merchantInfo = db.MerchantInfo.FirstOrDefault(m => m.Id == merchantAddInfo.Id) ?? new MpMainModels2.MerchantInfo();
  472. if(merchantInfo.IsAct == 0)
  473. {
  474. merchantInfo.IsAct = 1;
  475. }
  476. var orders = db.ConsumerOrders.FirstOrDefault(m => m.SeoTitle == OrderNo && m.OrderNo == OrderNo) ?? new MpMainModels2.ConsumerOrders();
  477. if (orders.Id == 0)
  478. {
  479. function.WriteLog("订单号不存在,开始入库", "获取好哒FTP文件交易数据");
  480. var query = db.ConsumerOrders.Add(new MpMainModels2.ConsumerOrders()
  481. {
  482. Status = 1,
  483. CreateDate = DateTime.Parse(TradeDate),
  484. UpdateDate = DateTime.Parse(TradeDate),
  485. SnNo = BaseNo,
  486. PayMoney = decimal.Parse(TradeAmount),
  487. PayMode = PayMode,
  488. SeoTitle = OrderNo,
  489. OrderNo = OrderNo,
  490. MerchantId = merchantAddInfo.Id,
  491. UserId = merchantInfo.UserId,
  492. SeoKeyword = merchantAddInfo.CybMakerCode,
  493. }).Entity;
  494. db.SaveChanges();
  495. function.WriteLog("入库完毕", "获取好哒FTP文件交易数据");
  496. //推送MQ给创业帮
  497. if (merchantAddInfo.BrandId == 1)
  498. {
  499. if(!string.IsNullOrEmpty(merchantAddInfo.CybMakerCode))
  500. {
  501. SortedList<string, string> obj = new SortedList<string, string>();
  502. obj.Add("create_time", TradeDate);
  503. obj.Add("sn", BaseNo);
  504. obj.Add("pay_money", TradeAmount);
  505. obj.Add("pay_mode", PayMode.ToString());
  506. obj.Add("order_no", OrderNo);
  507. obj.Add("merch_no", merchantAddInfo.MchtNo);
  508. obj.Add("maker_code", merchantAddInfo.CybMakerCode);
  509. PushHelper.Instance.Do(obj);
  510. }
  511. OrderMessageHelper.SendOrderMsg(query);
  512. }
  513. }
  514. }
  515. }
  516. }
  517. db.Dispose();
  518. }
  519. // 关闭响应
  520. reader.Dispose();
  521. responseStream.Dispose();
  522. response.Close();
  523. function.WriteLog("结束\n\n\n", "获取好哒FTP文件数据异常");
  524. }
  525. catch (WebException ex)
  526. {
  527. function.WriteLog(DateTime.Now.ToString() + ":" + ex.ToString(), "获取好哒FTP文件交易数据异常");
  528. }
  529. }
  530. }
  531. }