1693797146990.sdtresearch
/
cnt_collector_485
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 6 Wiki Activity

Compare commits

base: 1693797146990.sdtresearch:main
Branches Tags
1693797146990.sdtresearch:main
1693797146990.sdtresearch:Version_1.5
1693797146990.sdtresearch:Version_1.4
1693797146990.sdtresearch:Version_1.3
1693797146990.sdtresearch:Version_1.2
1693797146990.sdtresearch:Version_1.1
1693797146990.sdtresearch:Version_1.0
..
compare: 1693797146990.sdtresearch:Version_1.4
Branches Tags
1693797146990.sdtresearch:main
1693797146990.sdtresearch:Version_1.5
1693797146990.sdtresearch:Version_1.4
1693797146990.sdtresearch:Version_1.3
1693797146990.sdtresearch:Version_1.2
1693797146990.sdtresearch:Version_1.1
1693797146990.sdtresearch:Version_1.0

No commits in common. "main" and "Version_1.4" have entirely different histories.
main ... Version_1.

1 changed files with 15 additions and 63 deletions
Show Stats Expand all files Collapse all files

78
cnt_collector_485.py
View File

@ -91,7 +91,7 @@ def Read_Temperature(client, ch_num):
data = {
"assetCode": info['mqtt']['assetCode'],
"timestamp": int(time.time() * 1000),
"timestamp": int(time.time()),
"dataType": "DATA",
"data": {
name: value
@ -109,67 +109,19 @@ def Set_Temperature(client, ch_num, order, val=None):
id = 2
else: # ch_num == 3
id = 3
if order == 'start':
client.write_register(address=2336, value=val, slave=id) # H.SP_L1
client.write_register(address=2338, value=val, slave=id) # H.TSP_L1
client.write_register(address=2340, value=1440, slave=id) # H.TM
if not val == None:
val *= 10
val = int(val)
try:
if order == 'start':
# Patten 1
client.write_register(address=8000, value=1, slave=id) # PTNO._C
client.write_register(address=8004, value=1, slave=id) # STC
# SEG 0
client.write_register(address=8001, value=0, slave=id) # SEGNO._C
client.write_register(address=8002, value=0, slave=id) # SSP_L1
# SEG 1
client.write_register(address=8001, value=1, slave=id) # SEGNO._C
client.write_register(address=8102, value=val, slave=id) # TSP_L1
client.write_register(address=8104, value=180, slave=id) # TIME
# SEG 2
client.write_register(address=8001, value=2, slave=id) # SEGNO._C
client.write_register(address=8102, value=val, slave=id) # TSP_L1
client.write_register(address=8104, value=1440, slave=id) # TIME
# Power On
client.write_register(address=2321, value=1, slave=id) # PTNO.
client.write_register(address=2315, value=1, slave=id) # MODE
elif order == 'change':
# Power Off
client.write_register(address=2315, value=0, slave=id) # MODE
# Patten 1
client.write_register(address=8000, value=1, slave=id) # PTNO._C
client.write_register(address=8004, value=1, slave=id) # STC
# SEG 0
client.write_register(address=8001, value=0, slave=id) # SEGNO._C
client.write_register(address=8002, value=0, slave=id) # SSP_L1
# SEG 1
client.write_register(address=8001, value=1, slave=id) # SEGNO._C
client.write_register(address=8102, value=val, slave=id) # TSP_L1
client.write_register(address=8104, value=180, slave=id) # TIME
# SEG 2
client.write_register(address=8001, value=2, slave=id) # SEGNO._C
client.write_register(address=8102, value=val, slave=id) # TSP_L1
client.write_register(address=8104, value=1440, slave=id) # TIME
client.write_register(address=2321, value=1, slave=id) # PTNO.
client.write_register(address=2315, value=1, slave=id) # MODE
else: # order == 'stop'
# Power Off
client.write_register(address=2315, value=0, slave=id) # MODE
except Exception as e:
print(e)
client.write_register(address=2315, value=1, slave=id) # MODE
elif order == 'change':
client.write_register(address=2336, value=val, slave=id) # H.SP_L1
client.write_register(address=2338, value=val, slave=id) # H.TSP_L1
client.write_register(address=2340, value=1440, slave=id) # H.TM
else: # order == 'stop'
client.write_register(address=2315, value=0, slave=id) # MODE
def Read_Power(client, ch_num):
if ch_num == 1:
@ -199,7 +151,7 @@ def Read_Power(client, ch_num):
data = {
"assetCode": info['mqtt']['assetCode'],
"timestamp": int(time.time() * 1000),
"timestamp": int(time.time()),
"dataType": "DATA",
"data": {
name: value
@ -265,7 +217,7 @@ def Read_GasDetector(client, ch_num):
data = {
"assetCode": info['mqtt']['assetCode'],
"timestamp": int(time.time() * 1000),
"timestamp": int(time.time()),
"dataType": "DATA",
"data": {
name_1: oxygen_value,