Nodered Function İle SQLite DB'den Veri Çekip Chart Oluşturma Hk.

[wtrk]

Arkadaşlar herkese merhaba.

PLC olan cihazlarımızdan aldığım çıkışları Raspberry'e bağladım. Sonrasında nodered ile  görselleştirdim. Cihazlar up-down olunca uyarı veriyor, mail atıyor ayrıca bu aktiviteleri SQLite dbye yazıyor. Buraya kadar herşey tamam. Bundan sonra yine birkaç eklenti yapmak istiyorum.

Bir raporlama sistemi yapıp, günlük haftalık aylık ve yıllık olmak üzere DB'den verileri alıp grafisel olarak göstermek istiyorum.

Bunun için db'den veri çağırma kodları gerekiyor, ve bu aldığım kodları grafiğe enjekte edeceğim.
Bu kodlarla ilgili destek olabilir misiniz ?

[tunayk]

Size lazım olan temel SQL komutları. Ufak tefek farklılıklar olmakla beraber birbirine oldukça yakın. Yazılımı geliştirdiğiniz ortamın da buna uygun kütüphaneleri olur.  Örneğin .NET ile çalışıyorsanız ADO.NET diye geçen kütüphane kullanılır. SQLite nin kendi sitesinde .NET kütüphaneleri mevcut .

SQL tarafında temel komut "select" komutu. kullanımı "select tarih, veri, xxx from tablo" seklinde komut cümleciği yazılım geliştirme ortamında kullandığınız nesneye verilir. DB 'ye Yazma işlemi yaptığınıza gör en azında temel var görünüyor. Yazma komutu yerine select komutu işletirseniz veri okumuş olursunuz

[wtrk]

Size lazım olan temel SQL komutları. Ufak tefek farklılıklar olmakla beraber birbirine oldukça yakın. Yazılımı geliştirdiğiniz ortamın da buna uygun kütüphaneleri olur.  Örneğin .NET ile çalışıyorsanız ADO.NET diye geçen kütüphane kullanılır. SQLite nin kendi sitesinde .NET kütüphaneleri mevcut .

SQL tarafında temel komut "select" komutu. kullanımı "select tarih, veri, xxx from tablo" seklinde komut cümleciği yazılım geliştirme ortamında kullandığınız nesneye verilir. DB 'ye Yazma işlemi yaptığınıza gör en azında temel var görünüyor. Yazma komutu yerine select komutu işletirseniz veri okumuş olursunuz

Öncelikle cevabınız için teşekkür ederim ancak fonksiyon içinde fonksiyon olacağı için ( günlük - haftalık ve aylık bazda bazı eklentiler olmasını  istiyorum ) nasıl yapacağımı bilemedim.


Biraz daha açayım, birde görsel ekliyorum..



Test  isminde bir db oluşturup içine  test tablosu ve bu tabloyada 4 tane sütun ekledim...

Date - Status - Name - Value

Aşağıdaki şekilde cihazların kablosunu çekince databaseye verileri yazıyor.

← T →         Date               Status      Name      Value

 Edit Delete 2018-11-15 05:41:43 running Laser 2 Working 0
 Edit Delete 2018-11-15 05:41:55 stopped Laser 3 Error!!! 1
 Edit Delete 2018-11-15 05:41:57 running Laser 3 Working 0
 Edit Delete 2018-11-15 05:42:12 stopped Laser 5 Error!!! 1
 Edit Delete 2018-11-15 05:42:14 running Laser 5 Working 0
 Edit Delete 2018-11-15 05:42:22 stopped Laser 6 Error!!! 1
 Edit Delete 2018-11-15 05:42:23 running Laser 6 Working 0
 Edit Delete 2018-11-15 05:43:05 stopped Laser 4 Error!!! 1
 Edit Delete 2018-11-15 05:43:06 running Laser 4 Working 0
 Edit Delete 2018-11-15 06:12:40 stopped Laser 1 Error!!! 1
 Edit Delete 2018-11-15 06:12:41 running Laser 1 Working 0
 Edit Delete 2018-11-15 09:22:59 stopped Laser 2 Error!!! 1
 Edit Delete 2018-11-15 09:23:01 running Laser 2 Working 0
 Edit Delete 2018-11-15 13:33:11 stopped Laser 1 Error!!! 1
 Edit Delete 2018-11-15 13:33:13 running Laser 1 Working 0
 Edit Delete 2018-11-15 13:46:03 stopped Laser 2 Error!!! 1

Bir örnek kod buldum, aşağıda ekliyorum.
Bu kodlara uygun olarak istediğim zaman aralığında bugün - yarın geçen hafta -geçen ay olmak üzere, bendeki db yapısına uygun hale aşağıdaki kodu nasıl getirebilirim, destek olmanız ricasıyla.

// This will handle any device and any attribute as long as it is in the DB
var p_30d  = 1000*60*60*24*30 ; //30 Days
var p_7d  = 1000*60*60*24*7 ; //7 Days
var p_1d  =  1000*60*60*24 ; // 1 Day
var d = new Date();
var current = d.getTime();
var today0h = d.setHours(0,0,0,0);
var day = d.getDay();
var monday0h = today0h - (day + (day === 0 ? -6:1)) * p_1d;
var fromdate = 0;
var enddate = 0;
var sql = [];
var sourcelist = [];
var aggrlist = [];
var title = "";


// Get the period and the list of data sources 
// also set some default values if one or the other does not exist yet
sourcelist = context.get("sourcelist");
if (sourcelist===undefined) { // if running for the first time
    sourcelist = [];
}
aggrlist = context.get("aggrlist");
if (aggrlist===undefined) { // if running for the first time
    aggrlist = [];
}
fromdate = context.get("fromdate");
if (fromdate===undefined) {
    // set the period to a default if it is not selected yet
    fromdate = current-p_1d;
}
enddate = context.get("enddate");
if (enddate===undefined) {
    // set the period to a default if it is not selected yet
    enddate = current;
}

switch(msg.topic) {
    case "period":
        switch(msg.payload) {
            case "today":
                fromdate = today0h;
                enddate = today0h+p_1d;
                break;
            case "yesterday":
                fromdate = today0h-p_1d;
                enddate = today0h;
                break;
            case "thisweek":
                fromdate = monday0h;
                enddate = monday0h+p_7d;
                break;
            case "lastweek":
                fromdate = monday0h-p_7d;
                enddate = monday0h;
                break;
            case "last24h":
                fromdate = current-p_1d;
                enddate = current;
                break;
            case "last7d":
                fromdate = current-p_7d;
                enddate = current;
                break;
            case "last30d":
                fromdate = current-p_30d;
                enddate = current;
                break;
        }
        context.set("fromdate",fromdate);
        context.set("enddate",enddate);
        break;
    case "datasource":
        if (msg.payload==="delete") {
            // remove all previous data sources
            sourcelist = [];
        } else {
            sourcelist = context.get("sourcelist");
            if (sourcelist===undefined) { // if running for the first time
                sourcelist = [];
            }
            sourcelist.push(msg.payload);
        }
        context.set("sourcelist",sourcelist);
        break;
    case "aggrsource":
        if (msg.payload==="delete") {
            // remove all previous data sources
            aggrlist = [];
        } else {
            aggrlist = context.get("aggrlist");
            if (aggrlist===undefined) { // if running for the first time
                aggrlist = [];
            }
            aggrlist.push(msg.payload);
        }
        context.set("aggrlist",aggrlist);
        break;
    case "minus1w":
        fromdate = fromdate-p_7d;
        enddate = enddate-p_7d;
        context.set("fromdate",fromdate);
        context.set("enddate",enddate);
        break;
    case "plus1w":
        fromdate = fromdate+p_7d;
        enddate = enddate+p_7d;
        context.set("fromdate",fromdate);
        context.set("enddate",enddate);
        break;
    case "minus1d":
        fromdate = fromdate-p_1d;
        enddate = enddate-p_1d;
        context.set("fromdate",fromdate);
        context.set("enddate",enddate);
        break;
    case "plus1d":
        fromdate = fromdate+p_1d;
        enddate = enddate+p_1d;
        context.set("fromdate",fromdate);
        context.set("enddate",enddate);
        break;
}


// Regenerate the SQL statements
// Run through the data source list an generate the SQL statements
sql = [];
if (sourcelist.length>0) {
    for (var i = 0; i < sourcelist.length; i++) {
        var parts = sourcelist[i].split("/");
        sql.push({ topic: "SELECT * FROM sensor_data WHERE device='"+parts[0]+"' AND sensor='"+parts[1]+"' AND epoch >= " + fromdate + " AND epoch <= " + enddate });
    }
} 
if (aggrlist.length>0) {
    for (var i = 0; i < aggrlist.length; i++) {
        var parts = aggrlist[i].split("/");
        sql.push({ topic: "SELECT * FROM sensor_aggr WHERE device='"+parts[0]+"' AND sensor='"+parts[1]+"' AND epoch >= " + fromdate + " AND epoch <= " + enddate });
    }
} 
if (sql.length===0) {    
    // Dummy select that returns nothing to clear the chart
    sql.push({ topic: "SELECT * FROM sensor_data WHERE device='xxxx'" });
}

// set the completed flag for the join node later
sql[sql.length-1].complete=true;
// pass along the email flag to redirect the flow later
if (msg.topic==="email") {
    sql[sql.length-1].email=true;
}

// Generate report title
if (sourcelist.length===0 && aggrlist.length===0) {
    title = "No data source";
} else {
    if (sourcelist.length!==0) {
        title = title + sourcelist.toString()+ ", ";
    }
    if (aggrlist.length!==0) {
        title = title + aggrlist.toString()+ ", ";
    }
    title = title.substring(0,title.length-2);
    title = title + " | ";

    var d = new Date();
    d.setTime(fromdate);
    var yyyy = d.getFullYear();
    var mm = d.getMonth() < 9 ? "0" + (d.getMonth() + 1) : (d.getMonth() + 1); // getMonth() is zero-based
    var dd  = d.getDate() < 10 ? "0" + d.getDate() : d.getDate();
    var hh = d.getHours() < 10 ? "0" + d.getHours() : d.getHours();
    var mmm  = d.getMinutes() < 10 ? "0" + d.getMinutes() : d.getMinutes();
    var ss  = d.getSeconds() < 10 ? "0" + d.getSeconds() : d.getSeconds();
    title = title + dd + "." + mm + "." + yyyy;
    d.setTime(enddate);
    yyyy = d.getFullYear();
    mm = d.getMonth() < 9 ? "0" + (d.getMonth() + 1) : (d.getMonth() + 1); // getMonth() is zero-based
    dd  = d.getDate() < 10 ? "0" + d.getDate() : d.getDate();
    hh = d.getHours() < 10 ? "0" + d.getHours() : d.getHours();
    mmm  = d.getMinutes() < 10 ? "0" + d.getMinutes() : d.getMinutes();
    ss  = d.getSeconds() < 10 ? "0" + d.getSeconds() : d.getSeconds();
    title = title + " - " + dd + "." + mm + "." + yyyy;
}
sql[sql.length-1].title=title;

return [ sql ];