SOURCE

function getLocalConnectionAndDisconnection(params) {
    var ne = params.ne;
    var re_ne = params.re_ne;
    var ne_ip = params.ne_ip;
    var re_ne_ip = params.re_ne_ip;
    if (ne && re_ne & ne_ip && re_ne_ip) {
        var result = invoke({
            source_ip: ne_ip,
            source_device_name: ne,
            dest_ip: re_ne_ip,
            dest_device_name: re_ne
        }, "ciomss", "ciomss/getLocalConnectionAndDisconnection");
        if (result.data) {
            result = result.data.result
        } else {
            result = []
        }
    } else {
        var result = [];
    }
    return result;

}

function getSysLogLst(params) {

    var event_time = parseInt(params.event_time);
    var start_time = event_time - 12 * 60 * 60 * 1000;
    start_time = new Date(start_time);
    var end_time = formatDate(new Date(event_time), 'yyyy-MM-dd hh:mm:ss');
    start_time = formatDate(start_time, 'yyyy-MM-dd hh:mm:ss');
    var ne_ip = invoke({


    })
    var operate_log = invoke({
        source_ip: params.ne,
        start_time: start_time,
        end_time: end_time
    }, "ciomss", "ciomss/getSysLogLst");
    if (operate_log.data) {
        operate_log = operate_log.data.attach_list
    } else {
        operate_log = []

    }
    return operate_log;
}



async getNeIp() {
    var query = this.ctx.request.body;
    if (query.a_biz_ne && query.z_biz_ne) {
        var result = await this.ctx.service.api.resource.getObjIp(query.a_biz_ne, query.z_biz_ne);
        var retData = retUtils.retSuccess(result);
        this.ctx.body = retData;
    } else {
        var retData = retUtils.retMissingParam();
        this.ctx.body = retData;
    }
    ;
}


async getObjIp(a_biz_ne, z_biz_ne) {
    // let aBizNe = ne_list[0].a_biz_ne;
    // let zbizNe = ne_list[0].z_biz_ne;
    let sql = ' SELECT * FROM `resource`.`obj_n_ip` WHERE `obj_name` = ?'
    const aBizNe_ip = await this.app.mysql.get("resource").query(sql, [a_biz_ne]);
    const zbizNe_ip = await this.app.mysql.get("resource").query(sql, [z_biz_ne]);
    var ne = {
        aBizNe_ip: aBizNe_ip[0].maintenace_ip,
        zbizNe_ip: zbizNe_ip[0].maintenace_ip

    }
    // let result = dbRes[0].maintenace_ip
    return ne
}

function getNeIp(params) {
    var ne = params.ne;
    if (ne) {
        var ip = invoke({
            ne: ne,
        }, "resource", "resource/getNeIp");
        ip = ip.data;
    } else {
        ip = [];
    };
    return ip;
}



function getPingTestQuality(params) {
    var ne_ip = params.ne_ip;
    var re_ne_ip = params.re_ne_ip;
    if (ne_ip && re_ne_ip) {
        var ping_ip = {
            source_ip: ne_ip,
            destination_ip: re_ne_ip
        }
        var ping_test_quality = invoke(ping_ip, "ciomss", "ciomss/getPingTestQuality").data;
    } else {
        var ping_test_quality = [];
    }
    return ping_test_quality;
}