index.js 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127
  1. const puppeteer = require('puppeteer');
  2. const fs = require('fs');
  3. //need: reply_info, sign
  4. //from url: https://testmis.ssti.net.cn/xswxcs/?reply_info=******&sign=******
  5. const info = [
  6. ['reply_info', 'sign']
  7. ];
  8. let infoOK = [];
  9. function getDate() {
  10. const now = new Date();
  11. return now.getFullYear() + "-" +
  12. ((now.getMonth() + 1 < 10) ? "0" + (now.getMonth() + 1) : (now.getMonth() + 1)) + "-" +
  13. ((now.getDate() < 10) ? "0" + now.getDate() : now.getDate());
  14. }
  15. async function interval() {
  16. const browser = await puppeteer.launch({
  17. // headless: false, // 是否隐藏窗口(默认true)
  18. // defaultViewport: {width: 800, height: 600} // 截图大小
  19. });
  20. let lastDay = null; // 记录上一秒的日期
  21. setInterval(async function () {
  22. const now = new Date();
  23. const day = now.getDate();
  24. const hour = now.getHours();
  25. const min = now.getMinutes();
  26. const sec = now.getSeconds();
  27. if (lastDay === null) {
  28. lastDay = day;
  29. } else if (lastDay !== day) {
  30. // 日期变动,清空数组
  31. infoOK = [];
  32. }
  33. if ((hour === 0 && min < 30 && sec < 30) || hour >= 16) {
  34. return;
  35. }
  36. for (let i = 0, j = info.length; i < j; i++) {
  37. if (info[i] && info[i][0] && info[i][1] && !infoOK[i]) {
  38. infoOK[i] = true;
  39. try {
  40. await run(browser, info[i][0], info[i][1]);
  41. } catch (e) {
  42. console.log(i, e);
  43. setTimeout(function () {
  44. infoOK[i] = false; // 出错,一分钟后重试
  45. }, 60000);
  46. return;
  47. }
  48. }
  49. }
  50. }, 1000);
  51. }
  52. async function run(browser, replyInfo, sign) {
  53. return new Promise(async function (resolve, reject) {
  54. const page = await browser.newPage();
  55. try {
  56. await page.goto("https://testmis.ssti.net.cn/xswxcs/?reply_info=" + replyInfo + "&sign=" + sign);
  57. } catch (e) {
  58. reject(e);
  59. return;
  60. }
  61. if (page.url().indexOf("https://open.weixin.qq.com/") !== -1) {
  62. await page.close();
  63. reject("URL Error");
  64. return;
  65. }
  66. try {
  67. await page.goto("https://testmis.ssti.net.cn/xswxcs/pages/Epidemic/EpidemicApply.aspx", {waitUntil: 'networkidle2'});
  68. } catch (e) {
  69. reject(e);
  70. return;
  71. }
  72. if (page.url().indexOf("https://open.weixin.qq.com/") !== -1) {
  73. await page.close();
  74. reject("URL Error");
  75. return;
  76. }
  77. try {
  78. const msg = await page.$eval("#layui-m-layer0 .layui-m-layercont", el => el.innerText);
  79. if (msg.indexOf("每日开放时间为") !== -1) {
  80. await page.close();
  81. reject("Time Error");
  82. return;
  83. }
  84. } catch (e) {
  85. // 捕捉可能的eval错误
  86. }
  87. const name = await page.$eval("#div2 input", el => el.value);
  88. console.log(name);
  89. await page.click("#Apply_Epidemic");
  90. try {
  91. await page.screenshot({path: "img/" + name + "-" + getDate() + '.png'});
  92. } catch (e) {
  93. // 捕捉可能的截图错误
  94. }
  95. await page.close();
  96. resolve();
  97. });
  98. }
  99. // 新建文件夹
  100. function mkdir() {
  101. return new Promise(function (resolve, reject) {
  102. fs.mkdir("./img", (err) => {
  103. if (err && err.code !== 'EEXIST') {
  104. reject(err);
  105. } else {
  106. resolve();
  107. }
  108. });
  109. });
  110. }
  111. // 初始化
  112. async function init() {
  113. await mkdir();
  114. interval();
  115. }
  116. init();