CommonHelper.cs 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Reflection;
  6. using System.Xml;
  7. using System.Net;
  8. using System.Net.Mail;
  9. using SCC.Models;
  10. using Quartz;
  11. namespace SCC.Common
  12. {
  13. /// <summary>
  14. /// 公用帮助类
  15. /// </summary>
  16. public static class CommonHelper
  17. {
  18. /// <summary>
  19. /// 本系统当前时间
  20. /// (早上8点之前为昨天,8点之后为今天)
  21. /// </summary>
  22. public static DateTime SCCSysDateTime
  23. {
  24. get
  25. {
  26. return DateTime.Now.AddHours(-8);
  27. }
  28. }
  29. /// <summary>
  30. /// 将XML内容转换成目标对象实体集合
  31. /// </summary>
  32. /// <typeparam name="T">目标对象实体</typeparam>
  33. /// <param name="FileName">完整文件名(根目录下只需文件名称)</param>
  34. /// <param name="WrapperNodeName"></param>
  35. /// <returns></returns>
  36. public static List<T> ConvertXMLToObject<T>(string FileName, string WrapperNodeName)
  37. {
  38. XmlDocument doc = new XmlDocument();
  39. doc.Load(FileName);
  40. List<T> result = new List<T>();
  41. var TType = typeof(T);
  42. XmlNodeList nodeList = doc.ChildNodes;
  43. if (!string.IsNullOrEmpty(WrapperNodeName))
  44. {
  45. foreach (XmlNode node in doc.ChildNodes)
  46. {
  47. if (node.Name == WrapperNodeName)
  48. {
  49. nodeList = node.ChildNodes;
  50. break;
  51. }
  52. }
  53. }
  54. object oneT = null;
  55. foreach (XmlNode node in nodeList)
  56. {
  57. if (node.NodeType == XmlNodeType.Comment || node.NodeType == XmlNodeType.XmlDeclaration) continue;
  58. oneT = TType.Assembly.CreateInstance(TType.FullName);
  59. foreach (XmlNode item in node.ChildNodes)
  60. {
  61. if (item.NodeType == XmlNodeType.Comment) continue;
  62. var property = TType.GetProperty(item.Name);
  63. if (property != null)
  64. property.SetValue(oneT, Convert.ChangeType(item.InnerText, property.PropertyType), null);
  65. }
  66. result.Add((T)oneT);
  67. }
  68. return result;
  69. }
  70. /// <summary>
  71. /// 从作业数据地图中获取配置信息
  72. /// </summary>
  73. /// <param name="datamap">作业数据地图</param>
  74. /// <returns></returns>
  75. public static SCCConfig GetConfigFromDataMap(JobDataMap datamap)
  76. {
  77. SCCConfig config = new SCCConfig();
  78. var properties = typeof(SCCConfig).GetProperties();
  79. foreach (PropertyInfo info in properties)
  80. {
  81. if (info.PropertyType == typeof(string))
  82. info.SetValue(config, datamap.GetString(info.Name), null);
  83. else if (info.PropertyType == typeof(Int32))
  84. info.SetValue(config, datamap.GetInt(info.Name), null);
  85. }
  86. return config;
  87. }
  88. #region 生成期号
  89. /// <summary>
  90. /// 通过期号编号生成形如YYMMDDQQ的期号
  91. /// </summary>
  92. /// <param name="QNum">期号编号</param>
  93. /// <returns></returns>
  94. public static string GenerateTodayQiHaoYYMMDDQQ(int QNum)
  95. {
  96. return GenerateQiHaoYYMMDDQQ(SCCSysDateTime, QNum);
  97. }
  98. /// <summary>
  99. /// 通过期号编号生成形如YYMMDDQQQ的期号
  100. /// </summary>
  101. /// <param name="QNum">期号编号</param>
  102. /// <returns></returns>
  103. public static string GenerateTodayQiHaoYYMMDDQQQ(int QNum)
  104. {
  105. return GenerateQiHaoYYMMDDQQQ(SCCSysDateTime, QNum);
  106. }
  107. /// <summary>
  108. /// 通过期号编号生成昨天形如YYMMDDQQ的期号
  109. /// </summary>
  110. /// <param name="QNum">期号编号</param>
  111. /// <returns></returns>
  112. public static string GenerateYesterdayQiHaoYYMMDDQQ(int QNum)
  113. {
  114. return GenerateQiHaoYYMMDDQQ(SCCSysDateTime.AddDays(-1), QNum);
  115. }
  116. /// <summary>
  117. /// 通过期号编号生成昨天形如YYMMDDQQ的期号
  118. /// </summary>
  119. /// <param name="QNum">期号编号</param>
  120. /// <returns></returns>
  121. public static string GenerateYesterdayQiHaoYYMMDDQQQ(int QNum)
  122. {
  123. return GenerateQiHaoYYMMDDQQQ(SCCSysDateTime.AddDays(-1), QNum);
  124. }
  125. /// <summary>
  126. /// 通过时间和编号生成当天形如YYMMDDQQ的期号
  127. /// </summary>
  128. /// <param name="dt">时间</param>
  129. /// <param name="QNum">期号编号</param>
  130. /// <returns></returns>
  131. private static string GenerateQiHaoYYMMDDQQ(DateTime dt, int QNum)
  132. {
  133. return dt.ToString("yyMMdd") + (QNum).ToString().PadLeft(2, '0');
  134. }
  135. /// <summary>
  136. /// 通过时间和编号生成当天形如YYMMDDQQQ的期号
  137. /// </summary>
  138. /// <param name="dt">时间</param>
  139. /// <param name="QNum">期号编号</param>
  140. /// <returns></returns>
  141. private static string GenerateQiHaoYYMMDDQQQ(DateTime dt, int QNum)
  142. {
  143. return dt.ToString("yyMMdd") + (QNum).ToString().PadLeft(3, '0');
  144. }
  145. /// <summary>
  146. /// 生成广西快乐十分指定日期指定编号的期号
  147. /// </summary>
  148. /// <param name="dt">时间</param>
  149. /// <param name="SkipDate">配置的跳过时间</param>
  150. /// <param name="QNum">期号编号</param>
  151. /// <returns></returns>
  152. public static string GenerateGXKL10FQiHao(DateTime dt, string SkipDate, int QNum)
  153. {
  154. TimeSpan datepart = dt - new DateTime(dt.Year, 1, 1);
  155. var t = SkipDate.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
  156. var beforeDTSkipDates = t.Where(R => Convert.ToInt32(R) < Convert.ToInt32(dt.ToString("yyyyMMdd"))).ToList();
  157. return dt.Year.ToString() + (datepart.Days - beforeDTSkipDates.Count + 1).ToString().PadLeft(3, '0') + QNum.ToString().PadLeft(2, '0');
  158. }
  159. #endregion
  160. #region 生成开奖时间
  161. /// <summary>
  162. /// 获取昨天对应期号的开奖时间
  163. /// 期号需形如YYMMDDQQ或YYMMDDQQQ
  164. /// </summary>
  165. /// <param name="config">配置项</param>
  166. /// <param name="QiHao">开奖期号</param>
  167. /// <returns></returns>
  168. public static DateTime GenerateYesterdayOpenTime(SCCConfig config, string QiHao)
  169. {
  170. var openDay = SCCSysDateTime.AddDays(-1);
  171. var StartTime = new DateTime(openDay.Year, openDay.Month, openDay.Day, config.StartHour, config.StartMinute, 0);
  172. return StartTime.AddMinutes((Convert.ToInt32(QiHao.Substring(6)) - 1) * config.Interval);
  173. }
  174. /// <summary>
  175. /// 获取今日对应期号的开奖时间
  176. /// 期号需形如YYMMDDQQ或YYMMDDQQQ
  177. /// </summary>
  178. /// <param name="config">配置项</param>
  179. /// <param name="QiHao">开奖期号</param>
  180. /// <returns></returns>
  181. public static DateTime GenerateTodayOpenTime(SCCConfig config, string QiHao)
  182. {
  183. var StartTime = new DateTime(SCCSysDateTime.Year, SCCSysDateTime.Month, SCCSysDateTime.Day, config.StartHour, config.StartMinute, 0);
  184. return StartTime.AddMinutes((Convert.ToInt32(QiHao.Substring(6)) - 1) * config.Interval);
  185. }
  186. public static DateTime GenerateGXKL10FYesterdayOpenTime(SCCConfig config, string QiHao)
  187. {
  188. var openDay = SCCSysDateTime.AddDays(-1);
  189. var StartTime = new DateTime(openDay.Year, openDay.Month, openDay.Day, config.StartHour, config.StartMinute, 0);
  190. return StartTime.AddMinutes((Convert.ToInt32(QiHao.Substring(7)) - 1) * config.Interval);
  191. }
  192. public static DateTime GenerateGXKL10FTodayOpenTime(SCCConfig config, string QiHao)
  193. {
  194. var StartTime = new DateTime(SCCSysDateTime.Year, SCCSysDateTime.Month, SCCSysDateTime.Day, config.StartHour, config.StartMinute, 0);
  195. return StartTime.AddMinutes((Convert.ToInt32(QiHao.Substring(7)) - 1) * config.Interval);
  196. }
  197. #endregion
  198. #region 日志信息
  199. public static string GetJobMainLogInfo(SCCConfig config, string QiHao)
  200. {
  201. return string.Format("【{0}】通过主站地址抓取{1}期开奖数据成功", config.Area + config.LotteryName, QiHao);
  202. }
  203. public static string GetJobBackLogInfo(SCCConfig config, string QiHao)
  204. {
  205. return string.Format("【{0}】通过备用地址抓取{1}期开奖数据成功", config.Area + config.LotteryName, QiHao);
  206. }
  207. public static string GetJobLogError(SCCConfig config, string QiHao)
  208. {
  209. return string.Format("【{0}】抓取{1}期开奖数据失败", config.Area + config.LotteryName, QiHao);
  210. }
  211. #endregion
  212. #region 地方彩
  213. /// <summary>
  214. /// 通过编号生成当天形如YYQQQ的期号
  215. /// (目前只有地方彩使用)
  216. /// </summary>
  217. /// <param name="QNum">期号编号</param>
  218. /// <returns></returns>
  219. public static int GenerateQiHaoYYQQQ(int QNum)
  220. {
  221. return Convert.ToInt32(SCCSysDateTime.ToString("yy") + (QNum).ToString().PadLeft(3, '0'));
  222. }
  223. /// <summary>
  224. /// 通过编号生成当天形如YYYYQQQ的期号
  225. /// (目前只有地方彩使用)
  226. /// </summary>
  227. /// <param name="QNum">期号编号</param>
  228. /// <returns></returns>
  229. public static int GenerateQiHaoYYYYQQQ(int QNum)
  230. {
  231. return Convert.ToInt32(SCCSysDateTime.ToString("yyyy") + (QNum).ToString().PadLeft(3, '0'));
  232. }
  233. /// <summary>
  234. /// 核实该地方彩程序运行时间是否应该获取到数据
  235. /// 开奖第二天检查时应该抓取到开奖数据才正确
  236. /// </summary>
  237. /// <param name="config">配置信息</param>
  238. /// <returns></returns>
  239. public static bool CheckDTIsNeedGetData(SCCConfig config)
  240. {
  241. var week = SCCSysDateTime.AddDays(-1).DayOfWeek.ToString("d");
  242. if (config.KJTime.Contains(week))//第二天只检查1次//&& SCCSysDateTime.Hour < 1
  243. return true;
  244. return false;
  245. }
  246. /// <summary>
  247. /// 检查今天该地方彩是否应该开奖
  248. /// 是则进行爬取工作
  249. /// </summary>
  250. /// <param name="config">配置信息</param>
  251. /// <returns></returns>
  252. public static bool CheckTodayIsOpenDay(SCCConfig config)
  253. {
  254. var week = SCCSysDateTime.DayOfWeek.ToString("d");
  255. if (config.KJTime.Contains(week))
  256. return true;
  257. return false;
  258. }
  259. /// <summary>
  260. /// 生成地方彩昨天的开奖时间
  261. /// </summary>
  262. /// <param name="config">配置信息</param>
  263. /// <returns></returns>
  264. public static DateTime GenerateDTOpenTime(SCCConfig config)
  265. {
  266. var openday = SCCSysDateTime.AddDays(-1);
  267. return new DateTime(openday.Year, openday.Month, openday.Day, config.StartHour, config.StartMinute, 0);
  268. }
  269. #endregion
  270. /// <summary>
  271. /// 将值转换为T类型数据
  272. /// </summary>
  273. /// <typeparam name="T">目标类型</typeparam>
  274. /// <param name="value">数据值</param>
  275. /// <returns></returns>
  276. public static T ChangeType<T>(object value)
  277. {
  278. return ChangeType<T>(value, default(T));
  279. }
  280. /// <summary>
  281. /// 将值转换为T类型数据,失败则返回T类型默认值
  282. /// </summary>
  283. /// <typeparam name="T">目标类型</typeparam>
  284. /// <param name="value">数据值</param>
  285. /// <param name="defaultValue">T类型默认值</param>
  286. /// <returns></returns>
  287. public static T ChangeType<T>(object value, T defaultValue)
  288. {
  289. if (value != null)
  290. {
  291. Type nullableType = typeof(T);
  292. if (!nullableType.IsInterface && (!nullableType.IsClass || (nullableType == typeof(string))))
  293. {
  294. if (nullableType.IsGenericType && (nullableType.GetGenericTypeDefinition() == typeof(Nullable<>)))
  295. {
  296. return (T)Convert.ChangeType(value, Nullable.GetUnderlyingType(nullableType));
  297. }
  298. if (nullableType.IsEnum)
  299. {
  300. return (T)Enum.Parse(nullableType, value.ToString());
  301. }
  302. return (T)Convert.ChangeType(value, nullableType);
  303. }
  304. if (value is T)
  305. {
  306. return (T)value;
  307. }
  308. }
  309. return defaultValue;
  310. }
  311. /// <summary>
  312. /// 将值转换为type类型的值
  313. /// </summary>
  314. /// <param name="value">值</param>
  315. /// <param name="type">目标类型</param>
  316. /// <returns></returns>
  317. public static object ChangeType(object value, Type type)
  318. {
  319. if (value != null)
  320. {
  321. var nullableType = Nullable.GetUnderlyingType(type);
  322. if (nullableType != null)//可空
  323. {
  324. return Convert.ChangeType(value, nullableType);
  325. }
  326. if (Convert.IsDBNull(value))//特殊处理,由于数据库类型与项目中的类型定义不匹配
  327. return type.IsValueType ? Activator.CreateInstance(type) : null;
  328. return Convert.ChangeType(value, type);
  329. }
  330. return null;
  331. }
  332. #region 邮件功能
  333. /// <summary>
  334. /// 收件人
  335. /// </summary>
  336. private static readonly string MailTo = ConfigHelper.GetConfigValue<string>("MailTo");
  337. /// <summary>
  338. /// 发自
  339. /// </summary>
  340. private static readonly string MailFrom = ConfigHelper.GetConfigValue<string>("MailFrom");
  341. /// <summary>
  342. /// 抄送
  343. /// </summary>
  344. private static readonly string MailCC = ConfigHelper.GetConfigValue<string>("MailCC");
  345. /// <summary>
  346. /// 发件名称
  347. /// </summary>
  348. private static readonly string SenderUserName = ConfigHelper.GetConfigValue<string>("SenderUserName");
  349. /// <summary>
  350. /// 密码
  351. /// </summary>
  352. private static readonly string SenderPassWord = ConfigHelper.GetConfigValue<string>("SenderPassWord");
  353. /// <summary>
  354. /// 主机
  355. /// </summary>
  356. private static readonly string SMTPHost = ConfigHelper.GetConfigValue<string>("SMTPHost");
  357. /// <summary>
  358. /// 发送邮件
  359. /// </summary>
  360. /// <param name="subject">邮件标题</param>
  361. /// <param name="body">邮件正文</param>
  362. /// <returns></returns>
  363. public static bool SendEmail(string subject, string body)
  364. {
  365. try
  366. {
  367. if (string.IsNullOrEmpty(MailTo))
  368. return false;
  369. MailMessage message = new MailMessage
  370. {
  371. Subject = subject,
  372. SubjectEncoding = Encoding.UTF8,
  373. Body = body,
  374. BodyEncoding = Encoding.UTF8,
  375. IsBodyHtml = true,
  376. Priority = MailPriority.High,
  377. From = new MailAddress(MailFrom, SenderUserName)
  378. };
  379. string[] toList = MailTo.Trim().Split(new char[] { ';' });
  380. //添加收件人
  381. foreach (string to in toList)
  382. {
  383. if (!string.IsNullOrWhiteSpace(to))
  384. message.To.Add(new MailAddress(to));
  385. }
  386. //抄送人
  387. string[] ccList = MailCC.Trim().Split(new char[] { ';' });
  388. foreach (string cc in ccList)
  389. {
  390. if (!string.IsNullOrWhiteSpace(cc))
  391. message.CC.Add(new MailAddress(cc));
  392. }
  393. SmtpClient client = new SmtpClient(SMTPHost, 25)
  394. {
  395. UseDefaultCredentials = false,
  396. DeliveryMethod = SmtpDeliveryMethod.Network,
  397. Credentials = new System.Net.NetworkCredential(SenderUserName, SenderPassWord),
  398. EnableSsl = true
  399. };
  400. client.Send(message);
  401. return true;
  402. }
  403. catch
  404. {
  405. }
  406. return false;
  407. }
  408. #endregion
  409. #region
  410. /// <summary>
  411. /// 从unix时间戳转时间
  412. /// </summary>
  413. /// <param name="TimeStamp"></param>
  414. /// <returns></returns>
  415. public static DateTime UnixTimeStamp(long TimeStamp)
  416. {
  417. DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new System.DateTime(1970, 1, 1)); // 当地时区
  418. DateTime dt = startTime.AddSeconds(TimeStamp);
  419. return dt;
  420. }
  421. /// <summary>
  422. /// 从时间转换成unix时间戳
  423. /// </summary>
  424. /// <param name="DateTime"></param>
  425. /// <returns></returns>
  426. public static long UnixTimeStamp(DateTime DateTime)
  427. {
  428. DateTime startTime = TimeZone.CurrentTimeZone.ToLocalTime(new System.DateTime(1970, 1, 1)); // 当地时区
  429. long timeStamp = (long)(DateTime - startTime).TotalSeconds; // 相差秒数
  430. return timeStamp;
  431. }
  432. /// <summary>
  433. /// 如果是"01,02,03"就转为"1,2,3"
  434. /// </summary>
  435. /// <param name="opcoede"></param>
  436. /// <returns></returns>
  437. public static string TRHandleCode(string opencode)
  438. {
  439. string[] ary= opencode.Split(',');
  440. List<int> list = new List<int>();
  441. foreach (var item in ary)
  442. {
  443. list.Add(int.Parse(item));
  444. }
  445. return string.Join(",", list);
  446. }
  447. /// <summary>
  448. /// 把广东好彩1和广东36选7的期号转换
  449. /// </summary>
  450. /// <param name="term">yyyyqqq格式</param>
  451. /// <returns></returns>
  452. public static DateTime GetGDHC1orGD367Opentime(string term)
  453. {
  454. try
  455. {
  456. if (term.Length!=7)
  457. {
  458. return DateTime.Now;
  459. }
  460. string year = term.Substring(0, 4);
  461. int qihao = int.Parse(term.Substring(4, 3));
  462. DateTime time = new DateTime(int.Parse(year),1,1);
  463. return time.AddDays(qihao+6);
  464. }
  465. catch (Exception ee)
  466. {
  467. return DateTime.Now;
  468. }
  469. }
  470. #endregion
  471. }
  472. }