const schedule = require('node-schedule');
|
const axios = require('axios');
|
const mysql = require("../utils/mysql_db");
|
|
|
var jsonData = '';//存储天气信息
|
// 定义规则
|
let rule = new schedule.RecurrenceRule();
|
rule.minute = [15, 30, 45, 55]
|
//rule.second = [30, 60]; // 每隔 10 秒执行一次
|
|
let rule_dealdata = new schedule.RecurrenceRule();
|
// rule_dealdata.minute = [04]
|
|
|
|
module.exports = {
|
async job_ () {
|
// schedule.scheduleJob('5 * * * * *', async () => {
|
|
// });
|
},
|
|
};
|
function repair(i){
|
if (i >= 0 && i <= 9) {
|
return "0" + i;
|
} else {
|
return i;
|
}
|
}
|
|
// schedule.scheduleJob(rule_dealdata, async () => {//每小时处理车载指标数据
|
// //http://192.168.1.4:5000/api
|
// // Exemplary payload
|
// let nowtime = new Date();//当前时间
|
// let date=new Date(nowtime.getTime()- 1*60*60*1000);
|
// let year = date.getFullYear() //返回指定日期的年份
|
// let month = repair(date.getMonth() + 1);//月
|
// let day = repair(date.getDate());//日
|
// let hour = repair(date.getHours());//时
|
// let minute = repair(date.getMinutes());//分
|
// let second = repair(date.getSeconds());//秒
|
|
// //当前时间
|
// let curTime = year + "-" + month + "-" + day
|
// + " " + hour + ":" + minute + ":" + second;
|
// if(hour == '01') {
|
// date=new Date(nowtime.getTime()- 24*60*60*1000);
|
// year = date.getFullYear() //前一天的时间
|
// month = repair(date.getMonth() + 1);//月
|
// day = repair(date.getDate());//日
|
// hour = repair(date.getHours());//时
|
// minute = repair(date.getMinutes());//分
|
// second = repair(date.getSeconds());//秒
|
// curTime = year + "-" + month + "-" + day
|
// + " " + hour + ":" + minute + ":" + second;
|
// mysql.query_data(`call proc_reset_taxi_data('${curTime}')`, 'master', null);
|
// }
|
|
// });
|
|
|
|
|
// https://devapi.heweather.net/v7/weather/now?location=101021700&key=495b433d21c84986a99c4ac52d42fd3b
|
|
|
function httpGet (uri) {
|
console.log(uri);
|
axios.get(uri).then(response => {
|
console.log(response.data);
|
return response.data;
|
}).catch(error => {
|
console.log(error);
|
});
|
}
|
|
function httpPost (uri, postdata) {
|
// let data = {
|
// name: 'John Doe',
|
// job: 'Content Writer'
|
// };
|
axios.post(uri, postdata).then((res) => {
|
return res.data;
|
console.log(`Status: ${res.status}`);
|
console.log('Body: ', res.data);
|
}).catch((err) => {
|
console.error(err);
|
});
|
}
|
