From eed0eacab43b4d57a5c4eef5618d5b2b8cddedc6 Mon Sep 17 00:00:00 2001
From: KwanghoKim <kh.kim@sdt.inc>
Date: Thu, 21 Dec 2023 13:53:09 +0900
Subject: [PATCH] =?UTF-8?q?1.=20Read=5FTemperature:=20register=20=EC=A3=BC?=
 =?UTF-8?q?=EC=86=8C=20=EA=B0=92=20=EB=B3=80=EA=B2=BD=202.=20Set=5FTempera?=
 =?UTF-8?q?ture:=20=EC=9E=A5=EB=B9=84=20=EA=B5=AC=EB=8F=99=20=EB=B0=A9?=
 =?UTF-8?q?=EB=B2=95=20=EB=B3=80=EA=B2=BD=203.=20timestamp=20=EA=B0=92=20m?=
 =?UTF-8?q?ilisecond=20=EA=B0=92=EC=9C=BC=EB=A1=9C=20=ED=91=9C=ED=98=84?=
 =?UTF-8?q?=EB=90=98=EB=8F=84=EB=A1=9D=20=EB=B3=80=EA=B2=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cnt_collector_485.py | 78 +++++++++++++++++++++++++++++++++++---------
 1 file changed, 63 insertions(+), 15 deletions(-)

diff --git a/cnt_collector_485.py b/cnt_collector_485.py
index 4153f5c..820f4a1 100644
--- a/cnt_collector_485.py
+++ b/cnt_collector_485.py
@@ -91,7 +91,7 @@ def Read_Temperature(client, ch_num):
 
         data = {
             "assetCode": info['mqtt']['assetCode'],
-            "timestamp": int(time.time()),
+            "timestamp": int(time.time() * 1000),
             "dataType": "DATA",
             "data": {
                 name: value
@@ -109,19 +109,67 @@ 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
 
-        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
+    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)
 
 def Read_Power(client, ch_num):
     if ch_num == 1:
@@ -151,7 +199,7 @@ def Read_Power(client, ch_num):
         
         data = {
             "assetCode": info['mqtt']['assetCode'],
-            "timestamp": int(time.time()),
+            "timestamp": int(time.time() * 1000),
             "dataType": "DATA",
             "data": {
                 name: value
@@ -217,7 +265,7 @@ def Read_GasDetector(client, ch_num):
 
     data = {
         "assetCode": info['mqtt']['assetCode'],
-        "timestamp": int(time.time()),
+        "timestamp": int(time.time() * 1000),
         "dataType": "DATA",
         "data": {
             name_1: oxygen_value,