Field & Web componnent (#13)

* add LICENSE (AGPL 3.0)

* add Web part

* Field (#12)

* ModbusAccessor finished and checked

* read and write Field done. pushToField to do

* field not finished, connection works

* read csv file and add some comments

---------

Co-authored-by: Nils Ritler <79571155+Slisls@users.noreply.github.com>

src/main/java/ch/hevs/isi/field/FieldConnector.java

@@ -3,16 +3,29 @@ package ch.hevs.isi.field;
 import ch.hevs.isi.core.DataPoint;
 import ch.hevs.isi.core.DataPointListener;
 
+import java.io.BufferedReader;
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import java.io.IOException;
+import java.util.Timer;
+
 public class FieldConnector implements DataPointListener {
-
     private static FieldConnector mySelf = null;
-
     private FieldConnector(){
 
+        initialize("LocalHost",1502, "C:/Nils/Hesso/4_Semester/SIN/Minecraft_Electrical_Age_Project/ModbusMap.csv");
+
         // Subscribe to the update of DataPoints
         DataPointListener.subscribeUpdate(this);
+
     }
 
+    /**
+     * static method to create a singleton pattern of the class
+     * checks if an instance of the class is already made
+     * if not, it creates an instance of the class FieldConnector
+     * @return instance of FieldConnector
+     */
     public static FieldConnector getMySelf(){
         if (mySelf == null){
             mySelf = new FieldConnector();
@@ -20,16 +33,73 @@ public class FieldConnector implements DataPointListener {
         return mySelf;
     }
 
-    public void initialize(String host, int port){
+    /**
+     * read the csv-file of the ModbusMap
+     * @param pathToFile path to the file of all modbus registers (C:/.../ModbusMap.csv)
+     */
+    public static void createRegister(String pathToFile){
+        try{
+            BufferedReader csvFile = new BufferedReader(new FileReader(pathToFile));
+            csvFile.readLine();
 
+            while(csvFile.ready()){
+                String line = csvFile.readLine();                   // read one line
+                String[] splitLine = line.split(";");         // split line between ";"
+
+                String label = splitLine[0];                        // first split is the label of the register
+                boolean isOutput = splitLine[3].equals("N");        // third split declares if it is an output
+                int address = new Integer((splitLine[4]));          // fourth split is the address of the register
+                float range = new Float(splitLine[5]);              // if it is a floatDatapoint, the fifth split is the range of the data
+                float offset = new Float(splitLine[6]);             // if it is a floatDatapoint, the sixth split is the offset of the data
+
+                /*
+                // create a float or a boolean register
+                if (splitLine[1].equals("B")){
+                    BooleanRegister b = new BooleanRegister(label, isOutput, address);
+                } else if(splitLine[1].equals("F")){
+                    FloatRegister f = new FloatRegister(label, isOutput, address, range, offset);
+                }
+                 */
+            }
+        }
+        catch(FileNotFoundException e){
+            e.printStackTrace();
+        }
+        catch (IOException e){
+            e.printStackTrace();
+        }
     }
 
-    private void pushToField(DataPoint dp){
-        System.out.println(dp.toString() + " -> Field");
+    /**
+     * this method initialize the fieldConnector
+     * it connects the ModbusAccessor, reads the csv-file of the ModbusMap
+     * and starts the periodical polling of the modbus registers
+     * @param host  ip address of the server
+     * @param port  port of the server
+     * @param pathToFile path to the file of all modbus registers (C:/.../ModbusMap.csv)
+     */
+    public void initialize(String host, int port, String pathToFile){
+        ModbusAccessor.getMySelf().connect(host,port);
+        createRegister(pathToFile);
+        startPeriodicalPolling();
+    }
+    private void pushToField(String label, String value){
+        System.out.println("Field: " + label + " " + value);
     }
-
     @Override
     public void onNewValue(DataPoint dp) {
-        pushToField(dp);
+        ModbusRegister mR = ModbusRegister.getRegisterFromDatapoint(dp);
+        mR.write();
+        pushToField(dp.getLabel(),dp.toString());
+    }
+
+    /**
+     * method to start a periodical task
+     * in our case it is the reading of the modbus registers
+     */
+    public void startPeriodicalPolling(){
+        Timer pollTimer = new Timer();
+        PollTask pollTask = new PollTask();
+        pollTimer.scheduleAtFixedRate(pollTask,0,100);
     }
 }