read single, write single and read multiple working

Author: prafull1249

README.md

@@ -0,0 +1,19 @@
+/*	OBencrypt.h	version 0.87	Feb. 13, 2012
+ *
+ *	Written by Daniel Lloyd. 2011-2012.
+ *	Property of OutBack Power Systems Inc.
+ */
+
+#ifndef OutBack_OBencrypt_h
+#define OutBack_OBencrypt_h
+
+#define BIAS			(0x0BCC)
+#define ROTATE_R7(x)	((((x) & 0x007F) << 9) | ((x) >> 7))
+#define ROTATE_L7(x)	((((x) & 0x01FF) << 7) | ((x) >> 9))
+
+#define ENCRYPT(x)		((x) = (ROTATE_R7((x) ^ BIAS) ^ encKey))
+#define DECRYPT(x)		((x) = (ROTATE_L7((x) ^ encKey) ^ BIAS))
+
+#define ENCRYPTION_ENABLED
+
+#endif

outback_C_interface/AllOutput.txt

@@ -25,7 +25,7 @@
 #define DEF_SERV_IP_ADDR	"192.168.2.220"
 #define BUFF_SIZE	128
 
-int debug = 0;-
+int debug = 0;
 int devices	= 0;
 int connected = 0;
 int pflag = 0;
@@ -60,7 +60,7 @@ int string_split(void) {
   printf("%s\n", ch);
   ch = strtok(NULL, " ,");
   }
-  getch();
+  //getch();
   return 0;
 }
 

outback_C_interface/OBencrypt.h

@@ -118,11 +118,11 @@ struct alt_multiple_register system_data[] = {
 	{"OutBack_Measured_System_Voltage",159, OUTBACK_BLOCK},
 };
 
-
+/*
 struct alt_multiple_register system_data[] = {
 	{"OutBack_Error",154, OUTBACK_BLOCK},
 	{"OutBack_Status",155, OUTBACK_BLOCK},
 	{"OutBack_System_Voltage",158, OUTBACK_BLOCK},
 	{"OutBack_Measured_System_Voltage",159, OUTBACK_BLOCK},
 };
-
+*/

outback_C_interface/Outback_p.c

@@ -1 +1 @@
-{"ip": "169.254.64.7", "type": "outback"}
+{"ip": "169.254.7.64", "type": "outback"}

outback_C_interface/blocks.txt

@@ -76,6 +76,23 @@ def read(self, name):
         else:
             logger.error("Invalid Register {}".format(name))
 
+    def read_multiple(self, reg_names):
+        """
+        Read multiple register of Outback
+        :param name:
+        :return:
+        """
+	fields = []
+	blocks = []
+	for name in reg_names:
+	        reg = self.get_register(name)
+		if reg is not None:
+	       	 	fields.append(reg.field)
+			blocks.append(reg.block)
+		else:
+			logger.error(name + " not present")
+	return register.read_multiple_reg(self.ip, fields, blocks)
+
     def read_single(self, field, block):
         """
         Read register of Outback
@@ -421,4 +438,4 @@ def write_single_reg(self, dict_fields):
             logger.error("invalid register fields")
             return -1
 
-        return self.write_single(field, block, value)
+        return self.write_single(field, block, value)

outback_C_interface/modbus-data.c

@@ -10,10 +10,10 @@
 PACKET_STATISTICS_BLOCK = 4
 RADIAN_SINGLE_PHASE_INV = 5
 RADIAN_INV_CONF_BLOCK = 6
-BATTERY_MONITOR_BLOCK = 7
-BATTERY_MONITOR_CONF_BLOCK = 8
-FMCHARGE_CONTROLLER_BLOCK = 9
-BASIC_CHARGE_CONTROLLER_BLOCK = 10
+BATTERY_MONITOR_BLOCK = 9
+BATTERY_MONITOR_CONF_BLOCK = 10
+FMCHARGE_CONTROLLER_BLOCK = 8
+BASIC_CHARGE_CONTROLLER_BLOCK = 7
 END_BLOCK = 11
 
 blocks_name = {

outback_C_interface/modbus-private.h

@@ -15,47 +15,45 @@ def __init__(self, name, field, block, unit=""):
         self.unit = unit
 
     def read_reg(self, ip, port=""):
-        result = subprocess.Popen(["outback", "-r", "-c", ip, "-f", self.field, "-b", self.block]
-                                  , stdout=subprocess.PIPE)
+        result = subprocess.Popen(["./program", "-r", "-c", str(ip), "-f", str(self.field), "-b", str(self.block)],stdout=subprocess.PIPE)
         out, err = result.communicate()
-        logger.info("Output " + out +  " error " + err)
+        logger.info("Output " + str(out) +  " error " + str(err))
         #TODO check error handling to check if register read fails.
         return out
 
     def write_reg(self, value, ip, port=""):
-        result = subprocess.Popen(["outback", "-w", "-c", ip, "-f", self.field, "-b", self.block, "-v", value]
-                                  , stdout=subprocess.PIPE)
+        result = subprocess.Popen(["./program", "-w", "-c", str(ip), "-f", str(self.field), "-b", str(self.block), "-v", str(value)], stdout=subprocess.PIPE)
         out, err = result.communicate()
-        logger.info("Output " + out +  " error " + err)
+        logger.info("Output " + str(out) +  " error " + str(err))
         #TODO check error handling to check if register write fails.
         return out
 
     @staticmethod
-    def read_multiple_reg(self, ip, fields, blocks):
+    def read_multiple_reg( ip, fields, blocks):
         """
         Reads multiple registers.
         :param fields: a comma separated string of register field values
         :param blocks: a comma separated string of register block values
         :return:
         """
-        fields_el = fields.split(',')
-        blocks_el = blocks.split(',')
+        fields_el = fields
+        blocks_el = blocks
 
-        if fields_el != blocks_el:
-            logger.debug("{} fields".format(fields))
-            logger.debug("{} blocks".format(blocks))
+        if len(fields_el) != len(blocks_el):
+            logger.debug("{} fields".format(str(fields)))
+            logger.debug("{} blocks".format(str(blocks)))
             logger.error("fields and blocks are of different lengths")
             return None
 
         overall_out = ""
-        for i in range(len(fields_el)):
+        out = None
+	for i in range(len(fields_el)):
             field = fields_el[i]
             block = blocks_el[i]
 
-            result = subprocess.Popen(["outback", "-m", "-c", ip, "-f", field, "-b", block]
-                                      , stdout=subprocess.PIPE)
+            result = subprocess.Popen(["./program", "-r", "-c",str(ip), "-f", str(field), "-b", str(block)], stdout=subprocess.PIPE)
             out, err = result.communicate()
-            logger.info("Output " + out + " error " + err)
+            logger.info("Output " + str(out) + " error " + str(err))
             overall_out = overall_out + out
             #TODO check error handling to check if register write fails.
 

outback_C_interface/modbus-tcp-private.h

@@ -0,0 +1,23 @@
+import InverterFactory
+import InverterFactory as ifact
+ifac = ifact.InverterFactory()
+inv = ifac.factory()
+
+reg_names = ["I_AC_Power", "I_AC_Current", "I_AC_VoltageAN","CC_Charger_State", "CC_Batt_Current", "CC_Watts", "I_AC_Frequency", "I_AC_VAR"]
+#OutBack_Hour        #Clock Hour (0 - 23)
+#Outback_Minute      #Clock Minute (0 - 59)
+#OutBack_Second      #Clock Second (0 - 59)
+
+inv.read_multiple(reg_names)
+
+
+def write_reg(field, block, value):
+
+	print "*" * 80
+	inv.read_single(field, block)
+	inv.write_single(field, block, value)
+	print "*" * 80
+	inv.read_single(field, block)
+
+
+#write_reg(366, 6 , 30)