nas/danmaku
1
0
Fork 0
mirror of https://github.com/lyz05/danmaku.git synced 2026-02-02 17:59:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: 更新covidbook检测与频率

Browse Source
This commit is contained in:
lyz05
2022-12-14 01:14:49 +08:00
parent ea9cf2e77e
commit d6a3956905
2 changed files with 64 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

76
schedule/covidbook.js
View File

@@ -2,26 +2,68 @@ const axios = require('axios');
const tgbot = require("../tgbot/tgbot.js");
const rootPath = 'https://eservice.ssm.gov.mo/covidvacbook/'
const url = rootPath + 'Booking/GetLocationQuotaList';
const chatID = 619935997;
if (!module.parent) {
// 引入环境变量
require("dotenv").config('../.env');
}
console.log('covidbook.js loaded')
function main() {
axios.post(url).then((res) => {
const data = res.data;
const mrnalocationquotalist = data.filter(locationquota => (locationquota.rspsrv === 'HC6' || locationquota.rspsrv === 'HC8' || locationquota.rspsrv === 'CHCSJ(MRNA)' || locationquota.rspsrv === 'CHCSJ2(MRNA)' || locationquota.rspsrv === 'SSM1(MRNA)'));
const ret = mrnalocationquotalist.filter(x => x.sum != '0')
if (ret.length != 0) {
console.log('有余量');
const bot = tgbot.hkaliyun;
bot.sendMessage(619935997, "有余量!");
bot.sendMessage(619935997, JSON.stringify(ret));
} else console.log('无余量');
})
async function GetLocationQuotaList() {
const url = rootPath + 'Booking/GetLocationQuotaList';
const res = await axios.post(url, {});
const data = res.data;
const mrnalocationquotalist = data.filter(locationquota => (locationquota.rspsrv === 'HC6' || locationquota.rspsrv === 'HC8' || locationquota.rspsrv === 'CHCSJ(MRNA)' || locationquota.rspsrv === 'CHCSJ2(MRNA)' || locationquota.rspsrv === 'SSM1(MRNA)'));
const ivlocationquotalist = data.filter(locationquota => (locationquota.rspsrv === 'HC1' || locationquota.rspsrv === 'HC2' || locationquota.rspsrv === 'HC3' || locationquota.rspsrv === 'HC4' || locationquota.rspsrv === 'HC5' || locationquota.rspsrv === 'HC7' || locationquota.rspsrv === 'HC9' || locationquota.rspsrv === 'HC11' || locationquota.rspsrv === 'CHCSJ' || locationquota.rspsrv === 'CHCSJ2' || locationquota.rspsrv === 'KW1' || locationquota.rspsrv === 'SSM1' || locationquota.rspsrv === 'MUST1' || locationquota.rspsrv === 'FAOM1' || locationquota.rspsrv === 'FAOM2' || locationquota.rspsrv === 'SSM2'));
return { ivlocationquotalist, mrnalocationquotalist };
}
async function GetLocationPeriodByIdtype(idtype) {
const url = rootPath + 'Booking/GetLocationPeriodByIdtype';
var data = { idtype: idtype };
const res = await axios.post(url, data);
return { periodlist: res.data }
}
async function getlocationbyidtype(idtype) {
var data = { idtype: idtype };
var url = rootPath + 'Booking/GetLocationByIdtype';
const res = await axios.post(url, data);
return { location: res.data }
}
async function main() {
const bot = tgbot.hkaliyun;
const { ivlocationquotalist, mrnalocationquotalist } = await GetLocationQuotaList();
const quotalist = mrnalocationquotalist;
// 筛选出有余量的接种站
const quotalistfilter = quotalist.filter(x => x.sum != '0')
if (quotalistfilter.length != 0) {
console.log('有余量');
const time2 = new Date().toLocaleTimeString();
bot.sendMessage(chatID, `当前时间：${time2}，以下是有余量的接种站:`);
for (const l of quotalistfilter) {
bot.sendMessage(chatID, `${l.name_c} : ${l.sum}`);
}
} else console.log('无余量');
// 遍历每个接种站尚有余额之时段
for (const item of quotalist) {
const { location } = await getlocationbyidtype(item.idtype)
const { periodlist } = await GetLocationPeriodByIdtype(item.idtype)
if (periodlist.length != 0) {
const name = location[0].name_c;
const periodlisttext = periodlist.map(l => `${l.booktime} 餘額 : ${l.ava_quota}`)
bot.sendMessage(chatID, name+'\n'+periodlisttext.join('\n'));
}
}
}
module.exports = main;
if (!module.parent) {
// 引入环境变量
require("dotenv").config('../.env');
main()
}

8
schedule/schedule.js
View File

@@ -3,7 +3,7 @@ const leancloud = require("../utils/leancloud");
const chai = require("chai");
const chaiHttp = require("chai-http");
const cf2dns = require("./cf2dns");
// const covidbook = require("./covidbook");
const covidbook = require("./covidbook");
function subcache(app) {
console.log("Running Cron Job：subcache");
@@ -32,10 +32,12 @@ module.exports = (app) => {
result
});
});
// covidbook();
});
cron.schedule("*/5 * * * *", () => {
covidbook();
});
};
if (!module.parent) {
// covidbook();
covidbook();
}