From 54f093911928e9bf8644009ac27173cbd8e506f4 Mon Sep 17 00:00:00 2001
From: "support.sampyo" <support.sampyo@sdt.inc>
Date: Tue, 26 Mar 2024 07:35:33 +0000
Subject: [PATCH] Commit message

---
 .config.json.un~      | Bin 0 -> 2230 bytes
 .framework.yaml.un~   | Bin 0 -> 1648 bytes
 .main.py.un~          | Bin 0 -> 523 bytes
 .requirements.txt.un~ | Bin 0 -> 977 bytes
 README.md             |  31 ++++++++++++-
 config.json           |   6 +++
 framework.yaml        |  11 +++++
 framework.yaml~       |  11 +++++
 main.py               | 102 ++++++++++++++++++++++++++++++++++++++++++
 requirements.txt      |   6 +++
 10 files changed, 165 insertions(+), 2 deletions(-)
 create mode 100644 .config.json.un~
 create mode 100644 .framework.yaml.un~
 create mode 100644 .main.py.un~
 create mode 100644 .requirements.txt.un~
 create mode 100644 config.json
 create mode 100644 framework.yaml
 create mode 100644 framework.yaml~
 create mode 100644 main.py
 create mode 100644 requirements.txt

diff --git a/.config.json.un~ b/.config.json.un~
new file mode 100644
index 0000000000000000000000000000000000000000..b43e5616a103edfcfe7378c6eafcd88fc25bc604
GIT binary patch
literal 2230
zcmeHJJx>Bb5ZyaLCB{M<zZ!Bj7KZR4n%J2fQPCC>Ds$l=k_cP?u`t9?*l6QFu(PnW
zvM}){81)|*Vl0dm39-?6b1W<*RA|Q}%g)}sx3|ojSxDyc*NK8zYzY18{^I7bb@|mg
z`<^oO*SE%Y^Z9P)As&D62y-sAE`%7Tq32HNQ&WbAd>CdqL{>jp^SG#kCk_*}J!3*h
z62%W0KT!Z9_b)S$)vF&YhY-#AzKtP^#-i3Z25F=rHtRF?VyTd^={J&F`-xb{Sf!_$
z3syCSKf~Z~2OKuK*fDaYacR_|buJDp)F3uu0MMi2Ko<Vfs5m|c6-SRw(52I~<U_Mb
z8UT%SLK23tP9|v+)vwaphmGk@T^Xbkw+x!t?Qd2DD>8%@{bYvaIJ-7l6OLK6j*c_j
z%Pt2vY4DerQz<&RG&oMClr5I>Rw1pD`rCGzNr%O9g*e^ws8xf#mjQzrmTi|Z<ucx|
z772ud!9X+;2yFzFgL&ntXa;$~r4kwMDOmXo*k!w70LXV3eyOB^;svFKCmf!TF`9cS
tT>U!0;M@$rVssNB3qu$(dEVx$zFOfCu5iuO30TMnIYFR5AJO{z?Jo(}c7*@{

literal 0
HcmV?d00001

diff --git a/.framework.yaml.un~ b/.framework.yaml.un~
new file mode 100644
index 0000000000000000000000000000000000000000..78fe847b8f91a03ebbf4b3e61f634d3f355fb800
GIT binary patch
literal 1648
zcmWH`%$*;a=aT=Ffoa16y*a;^t@gWexXDl><EKDki<DZ4#SYeQr=-JgEqzeMz`(!_
z#6b!QMX3e(eu=rMRtiap#i_a_sksF?i6yBD$_l|HiOJa@L5=jxlGH@aH`6C5yjjrj
zX5P}*6Ba;OZ`yhk-pt+ddRgo1?vB^pOY}IQCQAZoMj&PeVh{k)FwBs~RKdXll4W9u
zzW|a20wxFrCP7kMKr9I2{RaZDQ6SDJpg{<vF_m8gM+YOrR|%l`us8&z5KvUODJYaA
zrb7}*nSq{xo*|CZ@p>6BC9HX~tV7{#^PE@Pcf4NJs_<qWENPfFf+HI_Re(GLig-}U
z5C(BZBO4S7v;@G&{sE3`21sOsf}aJ5VUew?ppaNlfK(y?dBEs?Gj-#exicVny#*sq
ukuxvI@u2tw83-x`M&lF|2s8!2@{}D~o`N$lsO*FRP<Eq1F>l)Vd=&swIkvX|

literal 0
HcmV?d00001

diff --git a/.main.py.un~ b/.main.py.un~
new file mode 100644
index 0000000000000000000000000000000000000000..af1130a31baa6f8513ff901de5350777f37bad1e
GIT binary patch
literal 523
zcmWH`%$*;a=aT=Ffyw_Wf92LiE9du`{txZ@Cd=(8|L?|S_dP#W{__7<*R$w00|P@E
z5F-OdAP0m&0LBLM)0iq}vp_`RFF@o`NSI=<;C~=sU`CN2<xn*QfYC7v8XaFH&`bu$
JmuchkRR9C8BBTHS

literal 0
HcmV?d00001

diff --git a/.requirements.txt.un~ b/.requirements.txt.un~
new file mode 100644
index 0000000000000000000000000000000000000000..8b022ce5f880d28a13e9c388cd62eea85e6169c7
GIT binary patch
literal 977
zcmWH`%$*;a=aT=Ffr<Ce*C+?AC5d6XV?A^B-{J2*xt5o+o&CyzwrLjAmZ|D9FfgzI
zF-JjVZhlHqX)%lsq#1#j35Y=eM8hyc8dLcZ7LY6>L;MAhED*pHg4iG_79i#aasC4V
zSOmlw1vCf&V06@hql1Crs|3(|W+Xd6QNgcVoKljUlV6%rP?}U+nq=Atjx~@JG62OO
yI4OVxM`H~+Xvkp0LlUSLnOz3tyMoLE#@b<MCIZJAD@YIuKv4tFk*1B$R{;RgeKkA)

literal 0
HcmV?d00001

diff --git a/README.md b/README.md
index dce3e2a..20e6c43 100644
--- a/README.md
+++ b/README.md
@@ -1,3 +1,30 @@
-# sampyo-rs232
+# 이 코드 템플릿은 SDT Cloud 환경에서 mqtt 메세지를 발행하는 코드입니다.
 
-Your repository description
\ No newline at end of file
+# 패키지 설치
+- 코드는 sdtcloudpubsub 패키지를 사용합니다. 아래 명령어로 패키지를 다운로드 해야합니다.
+```bash
+$ pip install sdtcloudpubsub
+```
+
+# 코드 작성
+- 코드는 runAction 함수에서 동작하고자 하는 기능을 작성합니다.
+- msg 변수는 발행될 메세지 입니다. 
+- sdtcloudpubsub의 pubMessage 함수는 발행할 메세지 내용인 dictionary 타입 변수를 입력 받아 처리합니다.
+
+# 메세지 발행
+- 다음 변수로 메세지를 발행하는 코드를 작성하면... 
+```bash
+msg = { 
+    "message": "Hello World"
+}
+```
+- 실제로 발행되는 메세지은 다음과 같습니다.
+```bash
+msg = { 
+    "data": {
+        "message": "Hello World"
+    },
+    "timestamp": 12312311...
+}
+
+```
diff --git a/config.json b/config.json
new file mode 100644
index 0000000..50d3a30
--- /dev/null
+++ b/config.json
@@ -0,0 +1,6 @@
+{
+    "modbus-server": {
+        "address": "25.7.55.237",
+        "port": 5020
+    }
+}
diff --git a/framework.yaml b/framework.yaml
new file mode 100644
index 0000000..58b6d26
--- /dev/null
+++ b/framework.yaml
@@ -0,0 +1,11 @@
+version: bwc/v2 # bwc 버전 정보입니다.
+spec: 
+  appName: sampyo-rs232-app # 앱의 이름입니다.
+  runFile: main.py # 앱의 실행 파일입니다.
+  env:
+    bin: python3 # 앱을 실행할 바이너라 파일 종류입니다.(장비에 따라 다르므로 확인 후 정의해야 합니다.)
+    virtualEnv: base # 사용할 가상환경 이름입니다.
+    package: requirements.txt # 설치할 Python 패키지 정보 파일입니다.(기본 값은 requirement.txt 입니다.)
+stackbase:
+  tagName: v0.0.1 # Stackbase(gitea)에 릴리즈 태그명 입니다.
+  repoName: sampyo-rs232 # Stackbase(gitea)에 저장될 저장소 이릅니다.	
diff --git a/framework.yaml~ b/framework.yaml~
new file mode 100644
index 0000000..4b3c1f2
--- /dev/null
+++ b/framework.yaml~
@@ -0,0 +1,11 @@
+version: bwc/v2 # bwc 버전 정보입니다.
+spec: 
+  appName: base-app # 앱의 이름입니다.
+  runFile: main.py # 앱의 실행 파일입니다.
+  env:
+    bin: python3 # 앱을 실행할 바이너라 파일 종류입니다.(장비에 따라 다르므로 확인 후 정의해야 합니다.)
+    virtualEnv: base # 사용할 가상환경 이름입니다.
+    package: requirements.txt # 설치할 Python 패키지 정보 파일입니다.(기본 값은 requirement.txt 입니다.)
+stackbase:
+  tagName: v0.0.1 # Stackbase(gitea)에 릴리즈 태그명 입니다.
+  repoName: base-template # Stackbase(gitea)에 저장될 저장소 이릅니다.	
diff --git a/main.py b/main.py
new file mode 100644
index 0000000..4593afe
--- /dev/null
+++ b/main.py
@@ -0,0 +1,102 @@
+import signal, sys, time, os
+import serial
+import asyncio
+from pymodbus.server.async_io import ModbusTcpServer
+from pymodbus.datastore import ModbusSequentialDataBlock
+from pymodbus.datastore import ModbusSlaveContext, ModbusServerContext
+import argparse
+
+async def measurement_weight(port, data):
+    command_hex = '4430314B570D0A'
+    command_bytes = bytes.fromhex(command_hex)
+
+    while True:
+        try:
+            port.write(command_bytes)
+            time.sleep(0.02)
+            result = port.readline()
+            result = str(result, 'utf-8')
+            result = result.replace(' ', '')
+            result = float(result.replace('\r\n', ''))
+            result *= 1000
+            
+            print(result)
+            
+            if result < 0.0:
+                result = 0.0
+            
+            data.setValues(3, 1, [int(result)])
+        except Exception as e:
+            print(f'measurement_weight: \n{e}')
+            pass
+        
+        await asyncio.sleep(1)
+
+async def set_zero(port, data):
+    command_hex = '4430314B5A0D0A'
+    command_bytes = bytes.fromhex(command_hex)
+    
+    while True:
+        try:
+            val = data.getValues(1, 1, count=1)
+            
+            if val[0] == 1:
+                port.write(command_bytes)
+                result = port.readline()
+                data.setValues(1, 1, [0])
+            else:
+                print(f'set_zero: \n{e}')
+                pass
+        except:
+            pass
+        
+        await asyncio.sleep(1)
+
+def exit_handler(signum, frame):
+    print('Stop')
+    sys.exit(0)
+
+async def run_server(port, data):
+    # TCP 서버 시작
+    server = ModbusTcpServer(context, address=("25.7.55.237", 5020))
+    
+    update_coil_task = asyncio.create_task(measurement_weight(port=port, data=data))
+    update_hr_task = asyncio.create_task(set_zero(port=port, data=data))
+    
+    await server.serve_forever()
+    await asyncio.gather(update_coil_task, update_hr_task)
+    
+if __name__ == '__main__':
+    parser = argparse.ArgumentParser()
+    parser.add_argument('-app',help='')
+    args = parser.parse_args()
+    
+    ROOT_PATH = f'/usr/local/sdt/app/{args.app}'
+    
+    # Define serial port
+    serial_port = serial.Serial('/dev/ttyMAX1', 115200, parity=serial.PARITY_NONE, stopbits=serial.STOPBITS_ONE, bytesize=serial.EIGHTBITS, timeout=1)
+
+    # For detect Ctrl+C
+    signal.signal(signal.SIGINT, exit_handler)
+
+    # Create ModbusTCP server
+    store = ModbusSlaveContext(
+        co=ModbusSequentialDataBlock(0, [0] * 100),  # Coils
+        hr=ModbusSequentialDataBlock(0, [0] * 100)  # Holding Registers
+    )
+
+    context = ModbusServerContext(slaves=store, single=True)
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(run_server(port=serial_port, data=store))
+
+    # while True:
+    #     start = time.time()
+    #     measurement_weight(port=serial_port, data=store)
+    #     print(registers[0])
+        
+    #     end = time.time()
+
+    #     diff = end - start
+
+    #     if diff < 1:
+    #         time.sleep(1 - diff)
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..cb9e8c8
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,6 @@
+# Write package's name that need your app.
+#awsiotsdk
+#pyyaml
+#sdtcloudpubsub
+pyserial
+pymodbus