-
Notifications
You must be signed in to change notification settings - Fork 18
/
InverterData.py
160 lines (139 loc) · 4.98 KB
/
InverterData.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
import sys
import socket
import binascii
import re
import libscrc
import json
import paho.mqtt.client as paho
import os
import configparser
import datetime
def twosComplement_hex(hexval):
bits = 16
val = int(hexval, bits)
if val & (1 << (bits-1)):
val -= 1 << bits
return val
os.chdir(os.path.dirname(sys.argv[0]))
# CONFIG
configParser = configparser.RawConfigParser()
configFilePath = r'./config.cfg'
configParser.read(configFilePath)
inverter_ip=configParser.get('DeyeInverter', 'inverter_ip')
inverter_port=int(configParser.get('DeyeInverter', 'inverter_port'))
inverter_sn=int(configParser.get('DeyeInverter', 'inverter_sn'))
installed_power=int(configParser.get('DeyeInverter', 'installed_power'))
mqtt=int(configParser.get('DeyeInverter', 'mqtt'))
mqtt_server=configParser.get('DeyeInverter', 'mqtt_server')
mqtt_port=int(configParser.get('DeyeInverter', 'mqtt_port'))
mqtt_topic=configParser.get('DeyeInverter', 'mqtt_topic')
mqtt_username=configParser.get('DeyeInverter', 'mqtt_username')
mqtt_passwd=configParser.get('DeyeInverter', 'mqtt_passwd')
# END CONFIG
# PREPARE & SEND DATA TO THE INVERTER
output="{" # initialise json output
pini=59
pfin=112
chunks=0
while chunks<2:
if chunks==-1: # testing initialisation
pini=235
pfin=235
print("Initialise Connection")
start = binascii.unhexlify('A5') #start
length=binascii.unhexlify('1700') # datalength
controlcode= binascii.unhexlify('1045') #controlCode
serial=binascii.unhexlify('0000') # serial
datafield = binascii.unhexlify('020000000000000000000000000000') #com.igen.localmode.dy.instruction.send.SendDataField
pos_ini=str(hex(pini)[2:4].zfill(4))
pos_fin=str(hex(pfin-pini+1)[2:4].zfill(4))
businessfield= binascii.unhexlify('0103' + pos_ini + pos_fin) # sin CRC16MODBUS
crc=binascii.unhexlify(str(hex(libscrc.modbus(businessfield))[4:6])+str(hex(libscrc.modbus(businessfield))[2:4])) # CRC16modbus
checksum=binascii.unhexlify('00') #checksum F2
endCode = binascii.unhexlify('15')
inverter_sn2 = bytearray.fromhex(hex(inverter_sn)[8:10] + hex(inverter_sn)[6:8] + hex(inverter_sn)[4:6] + hex(inverter_sn)[2:4])
frame = bytearray(start + length + controlcode + serial + inverter_sn2 + datafield + businessfield + crc + checksum + endCode)
checksum = 0
frame_bytes = bytearray(frame)
for i in range(1, len(frame_bytes) - 2, 1):
checksum += frame_bytes[i] & 255
frame_bytes[len(frame_bytes) - 2] = int((checksum & 255))
# OPEN SOCKET
for res in socket.getaddrinfo(inverter_ip, inverter_port, socket.AF_INET,
socket.SOCK_STREAM):
family, socktype, proto, canonname, sockadress = res
try:
clientSocket= socket.socket(family,socktype,proto);
clientSocket.settimeout(10);
clientSocket.connect(sockadress);
except socket.error as msg:
print("Could not open socket");
break
# SEND DATA
#print(chunks)
clientSocket.sendall(frame_bytes);
ok=False;
while (not ok):
try:
data = clientSocket.recv(1024);
ok=True
try:
data
except:
print("No data - Die")
sys.exit(1) #die, no data
except socket.timeout as msg:
print("Connection timeout");
sys.exit(1) #die
# PARSE RESPONSE (start position 56, end position 60)
totalpower=0
i=pfin-pini
a=0
while a<=i:
p1=56+(a*4)
p2=60+(a*4)
response=twosComplement_hex(str(''.join(hex(ord(chr(x)))[2:].zfill(2) for x in bytearray(data))+' '+re.sub('[^\x20-\x7f]', '', ''))[p1:p2])
hexpos=str("0x") + str(hex(a+pini)[2:].zfill(4)).upper()
with open("./DYRealTime.txt") as txtfile:
parameters=json.loads(txtfile.read())
for parameter in parameters:
for item in parameter["items"]:
title=item["titleEN"]
ratio=item["ratio"]
unit=item["unit"]
for register in item["registers"]:
if register==hexpos and chunks!=-1:
#print(hexpos+"-"+title+":"+str(response*ratio)+unit)
if title.find("Temperature")!=-1:
response=round(response*ratio-100,2)
else:
response=round(response*ratio,2)
output=output+"\""+ title + "(" + unit + ")" + "\":" + str(response)+","
if hexpos=='0x00BA': totalpower+=response*ratio;
if hexpos=='0x00BB': totalpower+=response*ratio;
a+=1
pini=150
pfin=195
chunks+=1
output=output[:-1]+"}"
if totalpower<installed_power+1000:
if mqtt==1:
# Initialise MQTT if configured
client=paho.Client("inverter")
if mqtt_username!="":
client.tls_set() # <--- even without arguments
client.username_pw_set(username=mqtt_username, password=mqtt_passwd)
client.connect(mqtt_server, mqtt_port)
client.publish(mqtt_topic,totalpower)
client.publish(mqtt_topic+"/attributes",output)
print("Ok")
else:
print(output)
else:
#open text file
text_file = open("picos_potencia.txt", "a")
#write string to file
text_file.write(datetime.datetime.now().strftime('%d/%m/%y %I:%M %S %p')+'\n')
text_file.write(output+'\n'+'\n')
#close file
text_file.close()