|
|
|
|
@ -2,7 +2,8 @@ var get = (o_params)=>{ |
|
|
|
|
var o = { |
|
|
|
|
province: null, |
|
|
|
|
city: null, |
|
|
|
|
tel: ['18118155257'], |
|
|
|
|
sms: ['18118155257'], |
|
|
|
|
mail: ['i@yimian.xyz'], |
|
|
|
|
success: ()=>{}, |
|
|
|
|
error: ()=>{}, |
|
|
|
|
url: 'https://lab.isaaclin.cn/nCoV/api/area', |
|
|
|
|
@ -13,7 +14,22 @@ var get = (o_params)=>{ |
|
|
|
|
Object.assign(o, o_params); |
|
|
|
|
|
|
|
|
|
const request = require('request'); |
|
|
|
|
const sms = require('ushio-sms').sms('https://api.yimian.xyz/sms/'); |
|
|
|
|
const os = require('os'); |
|
|
|
|
const fs = require('fs'); |
|
|
|
|
const sms = require('ushio-sms')('https://api.yimian.xyz/sms/'); |
|
|
|
|
const mail = require('ushio-mail')('https://api.yimian.xyz/mail/'); |
|
|
|
|
|
|
|
|
|
const fileBck = /*os.tmpdir() + ((os.platform() == 'win32')?'\\':'/') + */__dirname + `/var/${o.province+o.city}.tmp`; |
|
|
|
|
var updateTime = 0; |
|
|
|
|
fs.access(fileBck ,function(err){ |
|
|
|
|
if(err && err.code == "ENOENT"){ |
|
|
|
|
updateTime = 0; |
|
|
|
|
}else{ |
|
|
|
|
updateTime = fs.readFileSync(fileBck, 'utf8'); |
|
|
|
|
} |
|
|
|
|
unit(); |
|
|
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const getInfo = ()=>{ |
|
|
|
|
return new Promise((resolve, reject) => request(o.url + ((o.province)?`?province=${encodeURI(o.province)}`:``), (err, res, body) => { |
|
|
|
|
@ -36,14 +52,55 @@ var get = (o_params)=>{ |
|
|
|
|
|
|
|
|
|
const unit = async () => { |
|
|
|
|
var info = await getInfo(); |
|
|
|
|
console.log(info) |
|
|
|
|
console.log(info); |
|
|
|
|
|
|
|
|
|
if(info.updateTime == updateTime){ |
|
|
|
|
updateTime = info.updateTime; |
|
|
|
|
fs.writeFileSync(fileBck, updateTime); |
|
|
|
|
await push(info); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if(!o.debug){ |
|
|
|
|
setTimeout(unit, o.interval); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
unit(); |
|
|
|
|
|
|
|
|
|
const push = info => new Promise(async resolve => { |
|
|
|
|
await pushMail(info); |
|
|
|
|
setTimeout(pushSms, o.interval/2, info); |
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const pushMail = info => new Promise(async resolve => { |
|
|
|
|
for(var index = 0; index < o.mail.length; index++){ |
|
|
|
|
await mail.send( |
|
|
|
|
o.mail[index], |
|
|
|
|
`冠状病毒 ${o.province} ${(o.city)?o.city:''} 确诊 ${info.confirmedCount}`,
|
|
|
|
|
`截至${new Date(updateTime)}, ${o.province} ${(o.city)?o.city:''} <strong>已确诊${info.confirmedCount}人, 疑似${info.suspectedCount}, 治愈${info.curedCount}, 死亡${info.deadCount}</strong>。
|
|
|
|
|
|
|
|
|
|
\n\r<br><br> |
|
|
|
|
|
|
|
|
|
以上数据自动抓取自丁香医生。 |
|
|
|
|
\n\r<br><br> |
|
|
|
|
|
|
|
|
|
iotcat(https://iotcat.me)`,
|
|
|
|
|
'iotcat-py' |
|
|
|
|
); |
|
|
|
|
} |
|
|
|
|
resolve(); |
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
const pushSms = info => new Promise(async resolve => { |
|
|
|
|
for(var index = 0; index < o.sms.length; index++){ |
|
|
|
|
await sms.send( |
|
|
|
|
o.sms[index], |
|
|
|
|
`${o.province}${(o.city)?o.city:''}确诊${info.confirmedCount}`, |
|
|
|
|
'提醒您' |
|
|
|
|
); |
|
|
|
|
} |
|
|
|
|
resolve(); |
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
return o; |
|
|
|
|
} |
|
|
|
|
|
