Initial commit - ip 10.0.0.76

flow/helper/DataToTbHandler.js

@@ -0,0 +1,163 @@
+class DataToTbHandler
+{
+  constructor(index) {
+    this.index = index;
+
+    this.previousValues = {};
+    this.debug = false;
+    this.messageCounter = 0;
+
+    this.sender = "";
+  }
+
+  dump()
+  {
+    console.log("----------------------------");
+    console.log("previousValues", this.previousValues);
+    console.log("----------------------------");
+  }
+
+  setSender(sender)
+  {
+    this.sender = sender;
+  }
+
+  isEmptyObject( obj ) {
+    for ( var name in obj ) {
+        return false;
+    }
+    return true;
+  }
+
+  sendToTb(dataToTb, instance)
+  {
+
+    if(!FLOW.OMS_brokerready)
+    {
+      return dataToTb;
+    }
+
+    let keys = Object.keys(dataToTb);
+
+    if(keys.length == 0)
+    {
+      if(this.debug) console.log("sendToTb received epty object", dataToTb);
+      return;
+    }
+
+    
+    let tbname = keys[0];
+    let ts;
+
+    let arrayOfValues = dataToTb[tbname];
+    let arrayOfValuesToSend = [];
+
+    for(let i = 0; i < arrayOfValues.length; i++)
+    {
+      ts = arrayOfValues[i].ts;
+
+      //console.log("sendToTb------------>before", arrayOfValues[i].values, tbname);
+
+      let values = this.prepareValuesForTb(tbname, ts, arrayOfValues[i].values);
+
+      //console.log("sendToTb------------>after", values);
+
+      if(!this.isEmptyObject(values)) 
+      {
+          arrayOfValuesToSend.push({ts: ts, values: values});
+      }
+    }
+
+    if(arrayOfValuesToSend.length == 0)
+    {
+      //if(this.debug) console.log("data not sent - empty array");
+      return;
+    }
+
+    /*
+    let dataToTb = {
+        [tbname]: [
+            { 
+              "ts": Date.now(),
+              "values": values
+            }
+          ]
+        }
+    */
+
+    this.messageCounter++;
+
+    let dataToTbModified = {
+        [tbname]: arrayOfValuesToSend
+    }
+
+    //console.log(this.sender + " DATA SEND TO TB ", tbname, this.messageCounter, new Date(ts), dataToTbModified[tbname][0].values, this.instance);
+    if(this.debug) console.log(this.sender + " DATA SEND TO TB ", this.index, tbname, arrayOfValuesToSend);
+    
+    instance.send(this.index, dataToTbModified);
+  }
+
+  getDiffTimestamp(key)
+  {
+    let seconds = 60*60;//1h
+    //seconds = 1;//for testing
+
+    //TODO set different value for given key!!!
+    //if(key == "status") seconds = 2*60*60;//2h
+
+    let timestampDiffToRemoveKey = seconds*1000;
+
+    return timestampDiffToRemoveKey;
+  }
+
+  prepareValuesForTb(tbname, timestamp, values)
+  {
+    let keys = Object.keys(values);
+    if(!this.previousValues.hasOwnProperty(tbname))
+    {
+      this.previousValues[tbname] = {};
+    }
+
+    //if(this.debug) console.log("prepareValuesForTb", tbname, timestamp, values);
+
+    for(let i = 0; i < keys.length; i++)
+    {
+      let key = keys[i];
+      let value = values[key];
+
+      if(!this.previousValues[tbname].hasOwnProperty(key)) 
+      {
+        this.previousValues[tbname][key] = {ts: timestamp, value: value};
+        continue;
+      }
+
+      if(this.previousValues[tbname][key].value === value)
+      {
+        let diff = timestamp - this.previousValues[tbname][key].ts;
+
+        let timestampDiffToRemoveKey = this.getDiffTimestamp(key);
+        if(diff > timestampDiffToRemoveKey)
+        {
+          this.previousValues[tbname][key].ts = Date.now();
+          //if(this.debug) console.log(this.sender + ": update ts for key", key, "diff is", diff, "messageCounter", this.messageCounter);
+
+        }
+        else
+        {
+          delete values[key];
+          //if(this.debug) console.log(this.sender + ": delete key", key, "diff is", diff, "messageCounter", this.messageCounter, timestampDiffToRemoveKey);
+        }
+      }
+      else
+      {
+        this.previousValues[tbname][key].value = value;
+        this.previousValues[tbname][key].ts = timestamp;
+      }
+
+    }
+
+    return values;
+  }
+}
+
+module.exports =  DataToTbHandler;

flow/helper/energo_streambuilder.js

@@ -150,7 +150,7 @@ const makeStreamsTable = (structure) => {
     
       const modul = structure[ip][item];
       // console.log(modul)  //i-35, i-60A ...
-
+      
       let section = "";
       if(modul == "i-60A")
       {
@@ -169,7 +169,7 @@ const makeStreamsTable = (structure) => {
         const m = multiplier[tb_value];
   
         if(isNaN(item)) item = item.slice(0,-1);
-    
+
         const stream = {
           "unitId": parseInt(item),
           "section": section,
@@ -177,7 +177,7 @@ const makeStreamsTable = (structure) => {
           "tb_value": tb_value,
           "bytes": b,
           "multiplier": m,
-        }
+          }
     
         if(tb_value == "total_energy")
         {
@@ -197,11 +197,14 @@ const makeStreamsTable = (structure) => {
   })
 
   return conversionTable;
-};
+}
+
 
 const getCurrentMonth = () => {
   const date = new Date();
   return date.getMonth();
 };
 
+
+
 exports.makeStreamsTable = makeStreamsTable;