<td class="b">
<span>這里為日期</span>
<span>如果有余票則顯示余票數(shù)量</span>
</td>

const axios = require('axios')
const querystring = require("querystring"); //序列化對象，用qs也行，都一樣
var QcloudSms = require("qcloudsms_js");
var cheerio = require('cheerio');
var schedule = require('node-schedule');

var obj = {
 data: {
  lineId: 111130, //路線id
  vehTime: 0722, //發(fā)車時(shí)間，
  startTime: 0751, //預(yù)計(jì)上車時(shí)間
  onStationId: 564492, //預(yù)定的站點(diǎn)id
  offStationId: 17990,//到站id
  onStationName: '寶安交通運(yùn)輸局③', //預(yù)定的站點(diǎn)名稱
  offStationName: "深港產(chǎn)學(xué)研基地",//預(yù)定到站名稱
  tradePrice: 0,//總金額
  saleDates: '17',//車票日期
  beginDate: '',//訂票時(shí)間，滯空，用于抓取到余票后填入數(shù)據(jù)
 },
 phoneNumber: 123123123, //用戶手機(jī)號，接收短信的手機(jī)號
 cookie: 'JSESSIONID=TESTCOOKIE', // 抓取到的cookie
 day: "17" //定17號的票，這個(gè)主要是用于搶指定日期的票，滯空則為搶當(dāng)月所有余票
}

class QueryTicket{
 /**
  *Creates an instance of QueryTicket.
  * @param {Object} { data, phoneNumber, cookie, day }
  * @param data {Object} 請求余票接口的requery參數(shù)
  * @param phoneNumber {Number} 用戶手機(jī)號，短信需要用到
  * @param cookie {String} cookie信息
  * @params day {String} 某日的票，如'18'
  * @memberof QueryTicket 請求余票接口
  */
 constructor({ data, phoneNumber, cookie, day }) {
  this.data = data 
  this.cookie = cookie
  this.day = day
  this.phoneNumber = phoneNumber
  this.postData = querystring.stringify(data)
  this.times = 0;  //記錄次數(shù)
  var stop = false //通過特定接口才能修改stop值，防止外部隨意串改
  this.getStop = function () { //獲取是否停止
   return stop 
  }
  this.setStop = function (ifStop) { //設(shè)置是否停止
   stop = ifStop
  }
 }
}

class QueryTicket{
 constructor({ data, phoneNumber, cookie, day }) {
 //constructor代碼... 
 }
  init(){}//初始化
  handleQueryTicket(){}//查詢余票的邏輯
  requestTicket(){} //調(diào)用查詢余票接口
  handleBuyTicket(){} //購票相關(guān)邏輯
  requestOrder(){}//調(diào)用購票接口
  handleInfoUser(){}//通知用戶的邏輯
  sendMSg(){} //發(fā)短信接口
}

class QueryTicket{
 constructor({ data, phoneNumber, cookie, day }) {
 //constructor代碼... 
 }
 //初始化,因?yàn)樯婕暗疆惒秸埱?，所以我們使用`async await`
  async init(){
     let ticketList = await this.handleQueryTicket() //返回查詢到的余票數(shù)組
  }
  //查詢余票的邏輯
  handleQueryTicket(){ 
  let ticketList = [] //余票數(shù)組
  let res = await this.requestTicket()
  this.times++ //計(jì)數(shù)器，記錄請求查詢多少次
  var str = res.data.replace(/\\/g, "") //格式化返回值
  var $ = cheerio.load(`<div class="main">${str}</div>`) // cheerio載入查詢接口response的html節(jié)點(diǎn)數(shù)據(jù)
  let list = $(".main").find(".b") //查找是否有余票的dom節(jié)點(diǎn)
  // 如果沒有余票，打印出請求多少次,然后返回，不執(zhí)行下面的代碼
  if (!list.length) {
   console.log(`用戶${this.phoneNumber}：無票，已進(jìn)行${this.times}次`)
   return
  }

  // 如果有余票
  list.each((idx, item) => {
   var str = $(item).html() //str這時(shí)格式是<span>21</span><span>&$x4F59;0</span>
   //最后一個(gè)span 的內(nèi)容其實(shí)"余0"，也就是無票，只不過是被轉(zhuǎn)碼了而已
   //因此要在下一步對其進(jìn)行格式化
   var arr = str.split(/<span>|<\/span>|\&\#x4F59\;/).filter(item => !!item === true) 
   let data = {
    day: arr[0],
    ticketLeft: arr[1]
   }
   
   //如果是要搶指定日期的票
   if (this.day) {
   //如果有指定日期的余票
    if (parseInt(data.day) === parseInt(data.day)) {
     ticketList.push(data)
    }
   } else {
   //如果不是，則返回查詢到的所有余票
    ticketList.push(data)
   }
  })
  return ticketList
  }
   //調(diào)用查詢余票接口
  requestTicket(){
  return axios.post('http://weixin.xxxx.net/ebus/front/wxQueryController.do?BcTicketCalendar', this.postData, {
   headers: {
    'Content-Type': 'application/x-www-form-urlencoded',
    'User-Agent': "Mozilla/5.0 (iPhone; CPU iPhone OS 8_0 like Mac OS X) AppleWebKit/600.1.4 (KHTML, like Gecko) Mobile/12A365 MicroMessenger/5.4.1 NetType/WIFI",
    "Cookie": this.cookie
   }
  })  
  }
  handleBuyTicket(){} //購票相關(guān)邏輯
  requestOrder(){}//調(diào)用購票接口
  handleInfoUser(){}//通知用戶的邏輯
  sendMSg(){} //發(fā)短信接口
}

class QueryTicket{
 constructor({ data, phoneNumber, cookie, day }) {
 //constructor代碼... 
 }
 //初始化
  async init(){
  let ticketList = await this.handleQueryTicket()
  //如果有余票
  if (ticketList.length) {
  //把余票傳入購票邏輯方法，返回短信通知所需要的數(shù)據(jù)
   let resParse = await this.handleBuyTicket(ticketList)
  }
  }
  //查詢余票的邏輯
  async handleQueryTicket(){
  // 查詢余票代碼...
  }
  //調(diào)用查詢余票接口
  requestTicket(){
  //調(diào)用查詢余票接口代碼...  
  } 
  //購票相關(guān)邏輯
  async handleBuyTicket(ticketList){
  let year = new Date().getFullYear() //年份，
  let month = new Date().getMonth() + 1 //月份，拼接購票日期用得上，因?yàn)橛嗥苯涌谥环祷貛滋?
  let {
   onStationName,//起始站點(diǎn)名
   offStationName,//結(jié)束站點(diǎn)名
   lineId,//線路id
   vehTime,//發(fā)車時(shí)間
   startTime,//預(yù)計(jì)上車時(shí)間
   onStationId,//上車的站臺id
   offStationId //到站的站臺id
   } = this.data // 初始化的數(shù)據(jù)
  let station = `${onStationName}-${offStationName}` //站點(diǎn)，發(fā)短信時(shí)候用到:"寶安交通局-深港產(chǎn)學(xué)研基地"
  let dateStr = ""; //車票日期
  let tickAmount = "" //總張數(shù)
  ticketList.forEach(item => {
   dateStr = dateStr + `${year}-${month}-${item.day},`
   tickAmount = tickAmount + `${item.ticketLeft}張,`
  })
  var buyTicket = {
   lineId,//線路id
   vehTime,//發(fā)車時(shí)間
   startTime,//預(yù)計(jì)上車時(shí)間
   onStationId,//上車的站點(diǎn)id
   offStationId,//目標(biāo)站點(diǎn)id
   tradePrice: '5', //金額
   saleDates: dateStr.slice(0, -1),
   payType: '2' //支付方式，微信支付
  }
  // 調(diào)用購票接口
   let data = querystring.stringify(buyTicket)
   let res = await this.requestOrder(data) //返回json數(shù)據(jù)，是否購票成功等等
   //把發(fā)短信所需要數(shù)據(jù)都要傳入
  return Object.assign({}, JSON.parse(res.data), { queryParam: { dateStr, tickAmount, startTime, station } })
  }//購票相關(guān)邏輯
  //調(diào)用購票接口
  requestOrder(obj){
  return axios.post('http://weixin.xxxx.net/ebus/front/wxQueryController.do?BcTicketBuy', obj, {
   headers: {
    'Content-Type': 'application/x-www-form-urlencoded',
    'User-Agent': "Mozilla/5.0 (iPhone; CPU iPhone OS 8_0 like Mac OS X) AppleWebKit/600.1.4 (KHTML, like Gecko) Mobile/12A365 MicroMessenger/5.4.1 NetType/WIFI",
    "Cookie": this.cookie
   }
  })
  }
  handleInfoUser(){}//通知用戶的邏輯
  sendMSg(){} //發(fā)短信接口
}

class QueryTicket{
 constructor({ data, phoneNumber, cookie, day }) {
 //constructor代碼... 
 }
 //初始化
  async init(){
  let ticketList = await this.handleQueryTicket()
  //如果有余票
  if (ticketList.length) {
  //把余票傳入購票邏輯方法，返回短信通知所需要的數(shù)據(jù)
   let resParse = await this.handleBuyTicket(ticketList)
  //執(zhí)行通知邏輯
   this.handleInfoUser(resParse)
  }
  }
  
  //查詢余票的邏輯
  async handleQueryTicket(){
  // 查詢余票代碼...
  }
  //調(diào)用查詢余票接口
  requestTicket(){
  //調(diào)用查詢余票接口代碼...  
  } 
  //購票相關(guān)邏輯
  async handleBuyTicket(ticketList){
  //購票代碼...
  }
  //調(diào)用購票接口
  requestOrder(obj){
  //購票接口請求代碼...
  }
  //通知用戶的邏輯
  async handleInfoUser(parseData){
  //獲取上一步購票的response數(shù)據(jù)和我們拼接的數(shù)據(jù)
  let { returnCode, returnData: { main: { lineName, tradePrice } }, queryParam: { dateStr, tickAmount, startTime, station } } = parseData
  //如果購票成功，則返回500
  if (returnCode === "500") {
   let res = await this.sendMsg({
    dateStr, //日期
    tickAmount: tickAmount.slice(0, -1), //總張數(shù)
    station, //站點(diǎn)
    lineName, //巴士名稱/路線名稱
    tradePrice,//總價(jià)
    startTime,//出發(fā)時(shí)間
    phoneNumber: this.phoneNumber,//手機(jī)號
   })
   //如果發(fā)信成功，則不再進(jìn)行搶票操作
   if (res.result === 0 && res.errmsg === "OK") {
    this.setStop(true)
   } else {
   //失敗不做任何操作
    console.log(res.errmsg)
   }
  } else {
   //失敗不做任何操作
   console.log(resParse['returnInfo'])
  }    
  }
  //發(fā)短信接口
  sendMSg(){
  let { dateStr, tickAmount, station, lineName, phoneNumber, startTime, tradePrice } = obj
  var appid = 140034324; // SDK AppID 以1400開頭
  // 短信應(yīng)用 SDK AppKey
  var appkey = "asdfdsvajwienin23493nadsnzxc";
  // 短信模板 ID，需要在短信控制臺中申請
  var templateId = 7839; // NOTE: 這里的模板ID`7839`只是示例，真實(shí)的模板 ID 需要在短信控制臺中申請
  // 簽名
  var smsSign = "測試短信"; // NOTE: 簽名參數(shù)使用的是`簽名內(nèi)容`，而不是`簽名ID`。這里的簽名"騰訊云"只是示例，真實(shí)的簽名需要在短信控制臺申請
  // 實(shí)例化 QcloudSms
  var qcloudsms = QcloudSms(appid, appkey);
  var ssender = qcloudsms.SmsSingleSender();
  // 這里的params就是短信里面可以自定義的內(nèi)容，也就是填入{1}{2}..的內(nèi)容
  var params = [dateStr, station, lineName, startTime, tickAmount, tradePrice];
  //用promise來封裝下異步操作
  return new Promise((resolve, reject) => {
   ssender.sendWithParam(86, phoneNumber, templateId, params, smsSign, "", "", function (err, res, resData) {
    if (err) {
     reject(err)
    } else {
     resolve(resData)
    }
   });
  })
  } 
}

// 定時(shí)任務(wù)
class SetInter {
 constructor({ timer, fn }) {
  this.timer = timer // 每幾秒執(zhí)行
  this.fn = fn //執(zhí)行的回調(diào)
  this.rule = new schedule.RecurrenceRule(); //實(shí)例化一個(gè)對象
  this.rule.second = this.setRule() // 調(diào)用原型方法，schedule的語法而已
  this.init()
 }
 setRule() {
  let rule = [];
  let i = 1;
  while (i < 60) {
   rule.push(i)
   i += this.timer
  }
  return rule //假設(shè)傳入的timer為5，則表示定時(shí)任務(wù)每5秒執(zhí)行一次
  // [1, 6, 11, 16, 21, 26, 31, 36, 41, 46, 51, 56] 
 }
 init() {
  schedule.scheduleJob(this.rule, () => {
   this.fn() // 定時(shí)調(diào)用傳入的回調(diào)方法
  });
 }
}

data: { //用戶1
  lineId: 111130,
  vehTime: 0722,
  startTime: 0751,
  onStationId: 564492,
  offStationId: 17990,
  onStationName: '寶安交通運(yùn)輸局③',
  offStationName: "深港產(chǎn)學(xué)研基地",
  tradePrice: 0,
  saleDates: '',
  beginDate: '',
 },
 phoneNumber: 123123123,
 cookie: 'JSESSIONID=TESTCOOKIE',
 day: "17"
}
var obj2 = { //用戶2
 data: {
  lineId: 134423,
  vehTime: 1820,
  startTime: 1855,
  onStationId: 4322,
  offStationId: 53231,
  onStationName: '百度國際大廈',
  offStationName: "裕安路口",
  tradePrice: 0,
  saleDates: '',
  beginDate: '',
 },
 phoneNumber: 175932123124,
 cookie: 'JSESSIONID=TESTCOOKIE',
 day: "" 
}
var ticket = new QueryTicket(obj) //用戶1
var ticket2 = new QueryTicket(obj2) //用戶2

new SetInter({
 timer: 1, //每秒執(zhí)行一次，建議5秒，不然怕被ip拉黑，我這里只是為了方便下面截圖
 fn: function () {
  [ticket,ticket2].map(item => { //同時(shí)進(jìn)行兩個(gè)用戶的搶票
   if (!item.getStop()) { //調(diào)用實(shí)例的原型方法，判斷是否停止搶票，如果沒有則繼續(xù)搶
    item.init()
   } else { // 如果搶到票了，則不繼續(xù)搶票
    console.log('stop')
   }
  })
 }
})