--no commit message

--no commit message

plugins/dt/dt-gistda-air/index.js

+var util = require('util');
+var DTPlugin = require('../dt-plugin');
+
+function DTTask(context,request){
+  DTPlugin.call(this,context,request);
+  this.name = "noop";
+  this.output_type = "";
+}
+util.inherits(DTTask,DTPlugin);
+
+DTTask.prototype.perform  =  require('./perform');
+
+module.exports = DTTask;

plugins/dt/dt-gistda-air/perform.js

+function perform_function(context,request,response){
+  var job_id = context.jobconfig.job_id;
+  var transaction_id = context.transaction.id;
+  var param = context.jobconfig.data_transform.param;
+  var memstore = context.task.memstore
+
+  var output_type = request.input_type;
+  var data = request.data;
+
+  let result = [];
+
+  var nfiles = data.data.length;
+  var i = 0;
+  while (i < nfiles) {
+    var filename = data.data[i].filename;
+    var filecontent = data.data[i].value;
+    var arr = filecontent.toString().split("\r\n");
+    var arr_type = arr[1].split(",");
+    var arr_unit = arr[2].split(",");
+    var arr_value_type = arr[3].split(",");
+    var ndata = arr_type.length;
+    var col = 1;
+    
+    let _result = {
+      "object_type":"ibitz",
+      "station_id" : filename,
+      "data":[]
+    };
+
+    while (col < ndata) {
+      var row = 4;
+      let values = [];
+      while (row < arr.length-1) {
+        var rdata = arr[row].split(",");
+        values.push({
+          "observeddatetime":rdata[0].replace('"','').replace('"',''),
+          "value":rdata[col]
+        });
+        row++;
+      }   
+      _result.data.push({
+        "type": arr_type[col].replace('"','').replace('"',''),
+        "unit": arr_unit[col].replace('"','').replace('"',''),
+        "value_type" : arr_value_type[col].replace('"','').replace('"',''),
+        "values":values
+      });
+
+      col++;
+    }  
+    result.push(_result);
+    i++;
+  }
+
+  response.success(result,output_type);
+  //response.reject();
+  //response.error("error message")
+
+}
+
+module.exports = perform_function;