const schedule = require('node-schedule');
const http = require("http");
const Dataapi = require("../models/dataapi");
const mysql = require("../utils/mysql_db");

// 定义规则
let rule = new schedule.RecurrenceRule();
// rule.minute = [1,11,21,31,41,51]
rule.second = [30, 60]; // 每隔 10 秒执行一次

var deviceMap = {};

var rule1 = new schedule.RecurrenceRule();
var times1 = [1, 6, 11, 16, 21, 26, 31, 36, 41, 46, 51, 56];
rule1.second = times1;
// schedule.scheduleJob(rule1, function () {
//     httpGet();
// });


module.exports = {
    // http://192.168.119.100:4500/dataapi/recordMonitorOpt?bid=setTempRecord&frequency=648&userid=admin&monitorpointId=22&msg=aaa&recordminitus=10&success=1&requesturl=aa&flvurl=aa
    // 参数:bid:setTempRecord frequency 录制频率 userid  用户id  monitorpointid  当前监测点id   requesturl   向设备端发起api指令   success  msg   flvurl
    async job_() {
        // schedule.scheduleJob(rule, () => {
        //     //待录清单   toRecordList
        //     params = {"bid":"toRecordList","frequencystr":"1557","wdate":"2021-08-17","whour":"21"};
        //     Dataapi.dealData(params).then((result)=> {
        //         //call proc_create_temp_record('#{frequency}','#{userid}','#{requesturl}','#{monitorpointId}','#{success}','#{msg}','#{flvurl}')
        //         for (let index = 0; index < result[0].length; index++) {
        //             let element = result[0][index];
        //             let params_ = {"bid":"setTempRecord","userid":"erupt","requesturl":"system","success":"","msg":"","flvurl":""};
        //             params_['monitorpointId'] = element.monitorpoint_id
        //             params_['frequency'] = element.frequency
        //             Dataapi.autoRecording(params_).then((rs)=> {
        //                 console.log("rs==============");
        //                 console.log(rs);
        //             });

        //         }

        //     });

        // });
    },
    async getDeviceStatus() {
        let sqlstr = `select B.monitorpointId,B.status,i.monitorpointName from (select *
                    from (select * FROM t_monitorpoint_status order by time desc limit 100) A 
                    group by monitorpointId
                    ) B left join t_monitorpoint_info i on B.monitorpointId=i.monitorpointId `;
        let data_rets = await mysql.query_data(sqlstr, 'remote', null);
        return JSON.parse(JSON.stringify(data_rets))
        // let deviceMsgs = [];
        // for (let index = 0; index < data_rets.length; index++) {
        //     let element = data_rets[index];
        //     if(!deviceMap[element.monitorpointId]) {
        //         deviceMap[element.monitorpointId] = element;
        //         continue;
        //     }
        //     // if(deviceMap[element.monitorpointId].status != element.status) {
        //         let msgstr = element.monitorpointName + (element.status>0 ? "恢复在线" : "离线");
        //         deviceMsgs[deviceMsgs.length] = {
        //             "monitorpointId":element.monitorpointId,
        //             "status":element.status,
        //             "msg": msgstr
        //         }
        //         deviceMap[element.monitorpointId] = element;
        //     // }
        // }
        // return deviceMsgs;
    },
    // async deviceChanges() {
    //     await this.getDeviceStatus()
        // var p = new Promise(function (resolve, reject) {
        //     resolve(this.getDeviceStatus());
        // });
        // return p;
    // },


};


// schedule.scheduleJob('5 5 * * * *', function () {
//     httpGet();
// });

function httpGet() {
    var uri = `http://www.baidu.com`;
    http.get(uri, function (res) {
        console.log("访问个人微博状态码: " + res.statusCode);
    }).on('error', function (e) {
        console.log("个人微博 error: " + e.message);
    });
}