智慧园区可视化应用数据源接口问题

function run() {
    var MysqlJdbcAdapter = Java.type("com.uinnova.di.dicom.jdbc.MysqlJdbcAdapter");
    while (true) {
        try {
        var adapter = new MysqlJdbcAdapter("jdbc:mysql://127.0.0.1:3306/database?useUnicode=true&characterEncoding=UTF-8", "root", "root");
        var data = adapter.getDataByTable("select * from ...");
        heartBeat.addInCount(data.size());
        //executes...
        //outs...
        sleep(60000);
        } catch (error) {
        logger.error("脚本执行错误：",error);
        }
    }
} 

function run() {
    var ActivemqReceiver = Java.type("com.uinnova.di.dip.base.receiver.ActivemqReceiver");
    //url, queue, username, password, queue(true) or topic(false)
    var receiver = new ActivemqReceiver("tcp://127.0.0.1:61616", "queue", "admin", "admin", true);
    startReceiver(receiver);
    while (true) {
        try {
        var data = receiver.getData();
        if (data!=null) {
            heartBeat.addInCount(1);
            //executes...
            //outs...
        }
        } catch (error) {
        logger.error("脚本执行错误：",error);
        }
    }
} 

function run() {
    var SyslogReceiver = Java.type("com.uinnova.di.dip.base.receiver.SyslogReceiver");
    //host, port, protocol(TCP or UDP)
    var receiver = new SyslogReceiver("0.0.0.0", 1501, "UDP");
    startReceiver(receiver);
    while (true) {
        try {
        var data = receiver.getData();
        logger.info("[原始数据]" + data);
        if (data != null) {
            heartBeat.addInCount(1);
            //executes...
            //outs...
        }
        } catch (error) {
        logger.error("脚本执行错误：", error);
        }
    }
} 

[
    {
        "id": "1",
        "sceneid": "20170109153114611633853",
        "kpi_key": "temperature",
        "kpi_value": "253"
    }
] 

function run() {
var MysqlJdbcAdapter = Java.type(
    "com.uinnova.di.dicom.jdbc.MysqlJdbcAdapter"
);
while (true) {
    try {
    var adapter = new MysqlJdbcAdapter(
        "jdbc:mysql://192.168.137.128:3306/inputDB?useUnicode=true&characterEncoding=UTF-8",
        "root",
        "root"
    );
    var data = adapter.getDataByTable(
        "SELECT id,sceneid,kpi_key,kpi_value FROM c_in"
    );
    heartBeat.addInCount(data.size());
    //executes...
    //var javaListData = json2JavaList(data);
    var list = new Array();
    for (var i = 0; i < data.size(); i++) {
        var obj = new Object();
        var temp = data.get(i);
        obj.id = temp.get("id");
        obj.sceneid = temp.get("sceneid");
        obj.kpi_key = temp.get("kpi_key");
        obj.kpi_value = temp.get("kpi_value");
        logger.info("obj处理后数据" + obj.toString());
        list.push(obj);
    }
    //logger.info("listlength="+list.length);
    //outs...
    //下列为操作数据库的几个方法，传入参数sql，执行成功返回1，执行失败返回0
    //out.createTable(sql);创建表
    //out.updateTable(sql);   修改表数据
    //out.deleteTable(sql);删除表
    //out.updateTableStructure(sql); 修改表结构
    //out.selectTable(sql); 查询表
    var MysqlOutCustom = Java.type(
        "com.uinnova.di.dip.customoutmysql.MysqlOutCustom"
    );
    //url, username, passowrd
    var out = new MysqlOutCustom(
        "jdbc:mysql://192.168.137.138:3306/outputDB?useUnicode=true&characterEncoding=UTF-8",
        "root",
        "root"
    );

    //传入数据，数据库表名，主键，其他列
    out.out(
        convertJs2Java(list),
        "c_out",
        "id",
        "sceneid,kpi_key,kpi_value"
    );
    heartBeat.addOutCount(list.length);
    sleep(60000);
    } catch (error) {
    logger.error("脚本执行错误：", error);
    }
}
} 

[
    {
        "ciCode": "P211-E1-01",
        "metric": "CPU使用率",
        "instance": "cup0",
        "value": "50",
        "timestamp": "1500790703007"
    }
] 

function run() {
var ActivemqReceiver = Java.type(
    "com.uinnova.di.dip.base.receiver.ActivemqReceiver"
);
//url, queue, username, password, queue(true) or topic(false)
var receiver = new ActivemqReceiver(
    "tcp://192.168.137.128:8094",
    "testIn123",
    "admin",
    "admin",
    true
);
startReceiver(receiver);
while (true) {
    try {
    var data = receiver.getData();
    if (data != null) {
        heartBeat.addInCount(1);
        //executes...
        var listData = JSON.parse(data);
        var list = new Array();
        for (var i = 0; i < listData.length; i++) {
        var obj = new Object();
        var temp = listData[i];
        obj.ciCode = temp["ciCode"];
        obj.metric = temp["metric"];
        obj.value = temp["value"];
        obj.timestamp = temp["timestamp"];
        obj.unit = temp["instance"];
        list.push(obj);
        }
        //logger.info("listlength="+list.length);
        //outs...
        var mqurl =
        "failover://(tcp://192.168.137.138:8094)?randomize=false&timeout=5000&maxReconnectAttempts=-1";
        var ActiveMqOut = Java.type("com.uinnova.di.dicom.amq.AMQProducer");
        //url, 用户名，密码，topic=1或queue=2，Topic或者Queue名称，非持久化=1或持久化=2，最晚提交时间秒
        var out = ActiveMqOut.getInstance(
        mqurl,
        "admin",
        "admin",
        "1",
        "testOut123",
        2,
        1
        );
        out.sendList(convertJs2Java(list), 1);
        heartBeat.addOutCount(list.length);
    }
    } catch (error) {
    logger.error("脚本执行错误：" + error.message);
    }
}
} 

[
    {
        "id": "1",
        "sceneid": "20170109153114611633853",
        "kpi_key": "temperature",
        "kpi_value": "253"
    }
] 

{
    "state": true,
    "data": [
        {
            "kpi_value": "253",
            "sceneid": "20170109153114611633853",
            "kpi_key": "temperature",
            "id": "1"
        }
    ]
} 

//**********---最后保存时间:2018-12-24 13:50:09 保存人:13824---**********//
    // ---------------------------------------------------------
    // 创建牌子，跟踪位置、设置文字、改变颜色、注册事件、显示隐藏
    // ---------------------------------------------------------
    
    var ui = null;
    function init_balloon(res) {
        ui = gui.create(res);
    
        ui.trackPos(0, 2, 0);
        ui.setScale(0.3, 0.3);
        ui.setText("Button/Text", "Hello!");
    
        ui.setImageColor("Button", Color.red);
        ui.setTextColor("Button/Text", Color.yellow);
    
        ui.regButtonEvent("Button", function() {
            console.log("click ui button");
        });
    };
    
    util.download({
        "url": "http://www.3dmomoda.com/mmdclient/script/examples/demos/message_button.bundle", 
        "success": init_balloon
    });
    
    // 测试显示隐藏：
    // util.setInterval(function(){
    //  if (ui != null) {
    //      ui.show(!ui.isShow);
    //  }
    // }, 1000);
        
        
        //设置定时器
    util.setInterval(function(){
            //请求参数
    var requestUrl= "http://192.168.10.67:9090/ajax/getDbData";
    var dburl="jdbc:mysql://192.168.137.138:3306/outputDB";
    var username="root";
    var password="root";
    var sql="SELECT id , sceneid, kpi_key,kpi_value from scene_data WHERE id = 1";
    
    util.download({
            "url": requestUrl+"?dburl="+dburl+"&username="+username+"&password="+password+"&sql="+sql, 
            "type":"text", 
            "success": function(res){
                        ////打印返回结果
                        console.log(res);
                                    //json转换为table类型
                        var tableres = json.decode(res);
                                    // 取得自己需要的值
                        var kpi_value=tableres.data[0].kpi_value;
                        
                        console.log("kpi_value:"+kpi_value);
                        //把结果复制给场景中头顶牌中    
                    ui.setText("Button/Text",kpi_value);
            },
            "error":function(error){
                    console.log(error)
            }
    });
},3000); //每三秒 

[
    {
        "ciCode":"P211-E1-01",
        "metric":"CPU使用率",
        "instance":"cup0",
        "value":"50",
        "timestamp":"1500790703007"
    }
] 

{
    "state": true,
    "data": "[\n {\n \"ciCode\":\"P211-E1-01\",\n \"metric\":\"CPU使用率\",\n \"instance\":\"cup0\",\n \"value\":\"50\",\n \"timestamp\":\"1500790703007\"\n }\n]\n"
} 

// ---------------------------------------------------------
// 创建牌子，跟踪位置、设置文字、改变颜色、注册事件、显示隐藏
// ---------------------------------------------------------

var ui = null;
function init_balloon(res) {
    ui = gui.create(res);
    
    ui.trackPos(0, 2, 0);
    ui.setScale(0.3, 0.3);
    ui.setText("Button/Text", "Hello!");

    ui.setImageColor("Button", Color.red);
    ui.setTextColor("Button/Text", Color.yellow);

    ui.regButtonEvent("Button", function() {
        console.log("click ui button");
    });
};

util.download({
    "url": "http://www.3dmomoda.com/mmdclient/script/examples/demos/message_button.bundle", 
    "success": init_balloon
});
// 测试显示隐藏：
// util.setInterval(function(){
//  if (ui != null) {
//      ui.show(!ui.isShow);
//  }
// }, 1000);
    //设置定时器
util.setInterval(function(){
    
        //请求参数
var requestUrl= "http://192.168.10.67:9090/ajax/getMqData"; //请求url
var mqurl="tcp://192.168.137.138:8094"; //ActiveMq 地址
var username="admin"; // ActiveMq 用户名
var password="admin";//topic=1 queue=2
var chanelMode="1";     //  topic=1 queue=2
var topicOrQueue="testOut123";//待接收 topic 或 queue 
var timeout="3000";     //设置收到下一条消息时间，单位ms，默认3000ms 
util.download({
        "url": requestUrl+"?mqurl="+mqurl+"&username="+username+"&password="+password+"&chanelMode="+chanelMode
            +"&topicOrQueue="+topicOrQueue+"&timeout="+timeout, 
        "type":"text", 
        "success": function(res){
                    ////打印返回结果
                    console.log(res);
                                //json转换为table类型
                    var tableres = json.decode(res);
                    console.log("tableres : "+tableres);
                                // 取得自己需要的值
                    var value=json.decode(tableres.data)[0].value;
            
                    console.log( "value: "+json.decode(tableres.data)[0].value);
                    //把结果复制给场景中头顶牌中    
                ui.setText("Button/Text",json.decode(tableres.data)[0].value);
        },
        "error":function(error){
                console.log(error)
        }
});
},3000); //每三秒

/**
    * 说明：为模拟数据对接，ThingJS平台部署单独部署了一台服务器3dmmd.cn，模拟合作商的后端服务器
    * 端口82 为websoket 接口，优势实时性好，每秒上传一个温度数值（-10 - 30 的随机数）
    * 端口83 为ajax接口，优势服务器压力小，每次读数的时候返回一个温度数值 （-10 - 30 的随机数）
    * 本例子演示如何做ajax 和websoket数据对接
    */
    var app = new THING.App({
        url: 'models/storehouse'
    });
    // 界面组件
    var panel = new THING.widget.Panel({ name: '温度面板', hasTitle: true, });
    var dataObj = {
        t1: '21°C',
        t2: '21°C',
    };
    panel.add(dataObj, 't1').name('水温').isChangeValue(true);
    panel.add(dataObj, 't2').name('气温').isChangeValue(true);
    /********************* 以下为ajax数据对接 ********************/
    // 接收服务端数据时触发事件
    update = function (evt) {
        // ***如设置服务器的CORS，实现跨域访问。会更简单***
        // ***下例采用的不设置CORS的跨域实现方案*** 
        $.ajax({
            type: "get",
            url: "http://192.168.10.67:9090/ajax/getDbData",
            data: {
            "dburl":"jdbc:mysql://192.168.137.138:3306/outputDB?useUnicode=true&characterEncoding=UTF-8", //mysql地址
                "username":"root",  //mysql 用户名
                "password":"root",  //mysql 密码
                "sql":"select id,sceneid,kpi_key,kpi_value from scene_data where id=1",//设置收到下一条消息时间，单位ms，默认3000ms
                },
            dataType: "jsonp",
            jsonpCallback: "callback",
            success: function (d) {
                console.log('拉取数据：' +d);
                console.log('拉取数据：' + JSON.stringify(d));
                
                console.log('拉取数据：' +  d.data[0].kpi_value);
                // ***将获得的数据赋值到场景中***
                dataObj.t2 = d.data[0].kpi_value + '°C';
            }
        });
    };
    //每1秒更新一个数据
    setInterval(update, 5000);

[
    {
        "ciCode": "P211-E1-01",
        "metric": "CPU使用率",
        "instance": "cup0",
        "value": "50",
        "timestamp": "1500790703007"
    }
] 

/**
* 说明：为模拟数据对接，ThingJS平台部署单独部署了一台服务器3dmmd.cn，模拟合作商的后端服务器
* 端口82 为websoket 接口，优势实时性好，每秒上传一个温度数值（-10 - 30 的随机数）
* 端口83 为ajax接口，优势服务器压力小，每次读数的时候返回一个温度数值 （-10 - 30 的随机数）
* 本例子演示如何做ajax 和websoket数据对接
**/
var app = new THING.App({
    url: 'models/storehouse'
});
// 界面组件
var panel = new THING.widget.Panel({ name: '温度面板', hasTitle: true, });
var dataObj = {
    t1: '21°C',
    t2: '21°C',
};
panel.add(dataObj, 't1').name('水温').isChangeValue(true);
panel.add(dataObj, 't2').name('气温').isChangeValue(true);


/********************* 以下为ajax数据对接 ********************/
// 接收服务端数据时触发事件
update = function (evt) {
    // ***如设置服务器的CORS，实现跨域访问。会更简单***
    // ***下例采用的不设置CORS的跨域实现方案*** 
    // 服务器返回的数据格式为 callback({"state":"success","data":29})
    $.ajax({
        type: "get",
        url: "http://192.168.10.67:9090/ajax/getMqData",

        data: {
            "mqurl":"tcp://192.168.137.138:8094", //mq地址
            "username":"admin",  //ActiveMq 用户名
            "password":"admin",  //ActiveMq 密码
            "chanelMode":"1",  //topic=1 queue=2
            "topicOrQueue":"testOut123",// 订阅tppic名字
            "timeout":"3000",//设置收到下一条消息时间，单位ms，默认3000ms
            },
        dataType: "jsonp",
        jsonpCallback: "callback",
        success: function (d) {
            console.log('拉取数据：' +d);
            console.log('拉取数据：' + JSON.stringify(d));
            console.log('拉取数据：' +  JSON.parse(d.data)[0].value);
            // ***将获得的数据赋值到场景中***
            dataObj.t2 =JSON.parse(d.data)[0].value+ '°C';
        }
    });
};
//每1秒更新一个数据
setInterval(update, 6000);

/**
* 说明：为模拟数据对接，ThingJS平台部署单独部署了一台服务器3dmmd.cn，模拟合作商的后端服务器
* 端口82 为websoket 接口，优势实时性好，每秒上传一个温度数值（-10 - 30 的随机数）
* 端口83 为ajax接口，优势服务器压力小，每次读数的时候返回一个温度数值 （-10 - 30 的随机数）
* 本例子演示如何做ajax 和websoket数据对接
*/
var app = new THING.App({
    url: 'models/storehouse'
});
// 界面组件
var panel = new THING.widget.Panel({ name: '温度面板', hasTitle: true, });
var dataObj = {
    t1: '21°C',
    t2: '21°C',
};
panel.add(dataObj, 't1').name('水温').isChangeValue(true);
panel.add(dataObj, 't2').name('气温').isChangeValue(true);
/********************* 以下为websoket数据对接 ********************/
// 对接自有websoket服务器
var ws = new WebSocket('ws://192.168.10.67:9090/ws/testOut789');
// 建立 web socket 连接成功触发事件
ws.onopen = function () {
    console.log("websoket服务器连接成功...");
};
// 接收服务端数据时触发事件
ws.onmessage = function (evt) {
    console.log(evt+'');
    console.log("websoket接收数据：" + toString(evt));
    var s =JSON.stringify(evt.data)
    console.log('拉取数据ss：' + s);
            console.log('拉取数据：' + JSON.parse(evt.data)[0].kpi_value );
    // ***将获得的数据赋值到场景中***
    dataObj.t1 = JSON.parse(evt.data)[0].kpi_value + '°C';
};