jd.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288
  1. using dodohold.core;
  2. using CSRedis;
  3. using System.Data;
  4. using YunhuiKit;
  5. using static dodohold.core.ZTOExpress.CreateOrderArgs;
  6. using System.Xml.Linq;
  7. namespace molilian.core
  8. {
  9. public partial class TkLogCore
  10. {
  11. static string queue_parse_jd_key = "queue:parse_logs:jd";
  12. public static async Task<int> InsertParseJDLogAsync(int limit, YunhuiKit.RedisClient redis)
  13. {
  14. int total = 0;
  15. using var connection = DBContext.GetOpenConnection();
  16. connection.Open();
  17. using var transaction = connection.BeginTransaction();
  18. try
  19. {
  20. for (int i = 0; i < limit; i++)
  21. {
  22. var data = await redis.LPopAsync<JdDataDTO>(queue_parse_jd_key);
  23. if (data == null) break;
  24. if (TestParseCore.InWhitelist(data.ip, data.oaid))
  25. {
  26. save_jd_parse_logs(data, "jd_parse_logs_test", connection, transaction);
  27. }
  28. else
  29. {
  30. if ("dp".Equals(data.parse_type))
  31. {
  32. string daily_table = $"jd_dp_logs_{data.create_time:yyyyMMdd}";
  33. save_jd_parse_logs(data, daily_table, connection, transaction);
  34. if (data.success)
  35. {
  36. save_jd_parse_logs(data, "jd_dp_logs_success", connection, transaction);
  37. }
  38. }
  39. //save_jd_parse_logs(data, "jd_parse_logs", connection, transaction);
  40. //if (save_dailys_log)
  41. {
  42. string daily_table = $"jd_parse_logs_{data.create_time:yyyyMMdd}";
  43. save_jd_parse_logs(data, daily_table, connection, transaction);
  44. }
  45. if (data.elapsedTime > 1000)
  46. {
  47. save_jd_parse_logs(data, "jd_parse_logs_test", connection, transaction);
  48. }
  49. if (data.success)
  50. {
  51. save_jd_parse_logs(data, "jd_parse_logs_success", connection, transaction);
  52. }
  53. }
  54. total++;
  55. }
  56. transaction.Commit();
  57. }
  58. catch (Exception ex)
  59. {
  60. transaction.Rollback();
  61. new LoggerLibrary("TkLogCore_error", "task_insert_parse_jd_logs")
  62. .Info(ex.Message, ex.StackTrace)
  63. .SaveAsync();
  64. throw;
  65. }
  66. finally
  67. {
  68. connection.Close();
  69. }
  70. return total;
  71. }
  72. public static int task_insert_parse_jd_logs(int limit, CSRedisClient redis)
  73. {
  74. int total = 0;
  75. using var connection = DBContext.GetOpenConnection();
  76. connection.Open();
  77. using var transaction = connection.BeginTransaction();
  78. try
  79. {
  80. for (int i = 0; i < limit; i++)
  81. {
  82. var data = redis.LPop<JdDataDTO>(queue_parse_jd_key);
  83. if (data == null) break;
  84. if (TestParseCore.InWhitelist(data.ip, data.oaid))
  85. {
  86. save_jd_parse_logs(data, "jd_parse_logs_test", connection, transaction);
  87. }
  88. else
  89. {
  90. //save_jd_parse_logs(data, "jd_parse_logs", connection, transaction);
  91. //if (save_dailys_log)
  92. {
  93. string daily_table = $"jd_parse_logs_{data.create_time:yyyyMMdd}";
  94. save_jd_parse_logs(data, daily_table, connection, transaction);
  95. }
  96. if (data.elapsedTime > 1000)
  97. {
  98. save_jd_parse_logs(data, "jd_parse_logs_test", connection, transaction);
  99. }
  100. if (data.success)
  101. {
  102. save_jd_parse_logs(data, "jd_parse_logs_success", connection, transaction);
  103. }
  104. }
  105. total++;
  106. }
  107. transaction.Commit();
  108. }
  109. catch (Exception ex)
  110. {
  111. transaction.Rollback();
  112. new LoggerLibrary("TkLogCore_error", "task_insert_parse_jd_logs")
  113. .Info(ex.Message, ex.StackTrace)
  114. .SaveAsync();
  115. throw;
  116. }
  117. finally
  118. {
  119. connection.Close();
  120. }
  121. return total;
  122. }
  123. public static async Task ParseLogAsync(JdDataDTO response, bool is_hide)
  124. {
  125. try
  126. {
  127. var ts = DateTime.Now - response.create_time;
  128. response.elapsedTime = (int)ts.TotalMilliseconds;
  129. _ = RedisKit.RPushAsync(queue_parse_jd_key, response);
  130. if (!TestParseCore.InWhitelist(response.ip, response.oaid))
  131. {
  132. await RecordParseMetricsAsync(
  133. response.channel.ToString(), response.accountId, response.accountName,
  134. response.success, response.message, response.reason, response.deeplink_url,
  135. response.riskStrategy, response.launchScene);
  136. }
  137. if (response.success) await saveClientRequestTotalAsync(response.channel, response.ip, response.oaid);
  138. if (response.success || response.message.Equals("转链失败"))
  139. {
  140. await RiskControlCore.CallsIncrByAsync(response.channel, response.accountId);
  141. //saveClientRequestTotal(response.channel, response.ip, response.oaid);
  142. }
  143. //if (!response.success && ("nologin".Equals(response.reason) ||
  144. // "方法不存在".Equals(response.reason) ||
  145. // "未登录".Equals(response.reason)))
  146. //{
  147. // await JdPoolCore.DisabledAsync(response.accountId, response.accountName, $"{response.rawContent}\n{response.rawContent2}");
  148. //}
  149. if ("没有匹配账号".Equals(response.reason))
  150. {
  151. await JdPoolCore.AccountExhaustedAsync();
  152. }
  153. string failure_key = $":total:continuous_failure:{response.accountId}";
  154. string failure_lock_key = $":lock:continuous_failure:{response.accountId}";
  155. if (response.success) await RedisKit.DelAsync(failure_key);
  156. //连续错误发送报警
  157. if ("签名失败".Equals(response.reason) || "网络异常".Equals(response.reason))
  158. {
  159. var total = await RedisKit.IncrByAsync(failure_key);
  160. await RedisKit.ExpireAsync(failure_key, 3600);
  161. if (total > 30)
  162. {
  163. //没有锁定记录才发送,
  164. string lockfFlag = await RedisKit.GetAsync<string>(failure_lock_key);
  165. if (string.IsNullOrEmpty(lockfFlag))
  166. {
  167. //发送锁,保存半小时(半小时内只发送1次)
  168. await RedisKit.SetAsync(failure_lock_key, 1, 1800);
  169. string message = $"【京东{response.accountName}】{EndPointCore.CurrentEndPoint},连续的{response.reason}";
  170. await RedisKit.ExpireAsync(failure_key, 3600);
  171. NotifyCore.Notify(new NifyMessage
  172. {
  173. message = message,
  174. priority = NifyMessagePriority.high,
  175. tags = ["red_circle"]
  176. });
  177. if (!is_hide)
  178. {
  179. _ = NotifyCore.QYWeixinPushNotifyAsync(response.reason, message);
  180. }
  181. }
  182. }
  183. }
  184. string nologin_key = $":total:continuous_nologin:{response.accountId}";
  185. string nologin_lock_key = $":lock:continuous_nologin:{response.accountId}";
  186. //连续错误发送报警
  187. if (!response.success && ("nologin".Equals(response.reason) ||
  188. "方法不存在".Equals(response.reason) ||
  189. "未登录".Equals(response.reason)))
  190. {
  191. var total = await RedisKit.IncrByAsync(nologin_key);
  192. await RedisKit.ExpireAsync(nologin_key, 3600);
  193. if (total > 3)
  194. {
  195. //没有锁定记录才发送,
  196. string lockfFlag = await RedisKit.GetAsync<string>(nologin_lock_key);
  197. if (string.IsNullOrEmpty(lockfFlag))
  198. {
  199. await JdPoolCore.DisabledAsync(response.accountId, response.accountName, $"{response.rawContent}\n{response.rawContent2}");
  200. await RedisKit.SetAsync(nologin_lock_key, 1, 60);
  201. await RedisKit.ExpireAsync(nologin_key, 86400);
  202. }
  203. }
  204. else
  205. {
  206. NotifyCore.Notify(new NifyMessage
  207. {
  208. message = $"【京东联盟{response.accountId}:{response.accountName}】cookie 掉线({total})\n\n{response.rawContent}",
  209. priority = NifyMessagePriority.high,
  210. tags = ["red_circle"]
  211. });
  212. }
  213. }
  214. else
  215. {
  216. await RedisKit.DelAsync(nologin_key);
  217. }
  218. }
  219. catch (Exception ex) { }
  220. }
  221. private static int save_jd_parse_logs(JdDataDTO data, string tablename, IDbConnection connection, IDbTransaction transaction)
  222. {
  223. return new DBContext.Table(connection, tablename)
  224. .Add("end_point", data.end_point)
  225. .Add("channel", (int)data.channel)
  226. .Add("accountId", data.accountId)
  227. .Add("accountName", data.accountName)
  228. .Add("proxy_name", data.proxy_name)
  229. .Add("proxy_node", data.proxy_node)
  230. .Add("curl_proxy", data.curl_proxy)
  231. .Add("rawContent", TruncateMySqlText(data.rawContent))
  232. .Add("success", data.success)
  233. .Add("message", data.message)
  234. .Add("reason", data.reason)
  235. .Add("content", TruncateMySqlText(data.content))
  236. .Add("itemId", data.itemId)
  237. .Add("itemName", data.itemName)
  238. .Add("pic", data.pic)
  239. .Add("couponAmount", data.couponAmount)
  240. .Add("promotionPrice", data.promotionPrice)
  241. .Add("taoToken", data.taoToken)
  242. .Add("shortLinkurl", data.shortLinkurl)
  243. .Add("deeplink_url", data.deeplink_url)
  244. .Add("elapsedTime", data.elapsedTime)
  245. .Add("subCode", data.subCode)
  246. .Add("ip", data.ip)
  247. .Add("oaid", data.oaid)
  248. .Add("riskStrategy", data.riskStrategy)
  249. .Add("launchScene", data.launchScene)
  250. .Add("create_time", data.create_time)
  251. .Add("parse_type", data.parse_type)
  252. .Create(DBContext.InsertType.NORMAL, transaction);
  253. }
  254. }
  255. }