xyj
/
lot_manager
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
lot_manager/ceshi.py

440 lines
18 KiB
Python
Raw Normal View History

test
2023-12-01 18:00:11 +08:00
# cd demo/ceshi-1/
# python ceshi.py
test
2023-12-01 10:01:20 +08:00
import serial
import time
import struct
import json
test
2023-12-01 18:00:11 +08:00
import paho.mqtt.client as mqtt
from api import add
from db.models.log_data_model import LOT_DATA
test
2023-12-01 10:01:20 +08:00
def hex_to_float(hex_str):
hex_int = int(hex_str, 16)
return struct.unpack('!f', struct.pack('!I', hex_int))[0]
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
def print_json(data):
print(json.dumps(data, sort_keys=True, indent=4, separators=(', ', ': '), ensure_ascii=False))
test
2023-12-01 18:00:11 +08:00
def run_with_client(client):
temp_send = '06 03 01 F4 00 02 85 B2 ' # 温湿度查询指令
co2_send = '06 03 01 F7 00 02 75 B2 ' # 二氧化碳查询指令
pressure_send = '06 03 01 F9 00 02 14 71 ' # 气压查询指令
sun_send = '06 03 01 FA 00 02 E4 71 ' # 光照查询指令
soil_send = '02 03 00 00 00 04 44 3A' # 土壤查询指令
danlinjia_send = '02 03 00 04 00 03 44 39' # 氮磷钾查询指令
rainfall_send = '03 03 00 00 00 01 85 E8' # 雨量查询指令
windspeed_send = '04 03 00 00 00 02 C4 5E' # 风速查询指令
winddirection_send = '05 03 00 00 00 02 C5 8F' # 风向查询指令
ser = serial.Serial("/dev/ttyS2", 9600)
# 发送的数据转为2进制b'\x01\x03\x00\x00\x00\x02\xc4\x0b'
temp_send = bytes.fromhex(temp_send)
co2_send = bytes.fromhex(co2_send)
pressure_send = bytes.fromhex(pressure_send)
sun_send = bytes.fromhex(sun_send)
soil_send = bytes.fromhex(soil_send)
danlinjia_send = bytes.fromhex(danlinjia_send)
rainfall_send = bytes.fromhex(rainfall_send)
windspeed_send = bytes.fromhex(windspeed_send)
winddirection_send = bytes.fromhex(winddirection_send)
while True:
# if ser.is_open:
test
2023-12-01 10:01:20 +08:00
ser.write(temp_send)
time.sleep(1)
test
2023-12-01 18:00:11 +08:00
# 获取返回的缓冲data,获取的是buffer_data的长度 9
test
2023-12-01 10:01:20 +08:00
tempbuffer_data = ser.in_waiting
if tempbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(tempbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# 对返回的数据进行解析，获取温度和湿度数据
test
2023-12-01 18:00:11 +08:00
airtemp_data = int(return_data_hex[6:10], 16) / 10
airhumi_data = int(return_data_hex[10:14], 16) / 10
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
ser.write(co2_send)
time.sleep(1)
test
2023-12-01 18:00:11 +08:00
# 获取返回的缓冲data,获取的是buffer_data的长度 9
test
2023-12-01 10:01:20 +08:00
co2buffer_data = ser.in_waiting
if co2buffer_data:
return_data = ser.read(co2buffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# 对返回的数据进行解析，获取温度和湿度数据
test
2023-12-01 18:00:11 +08:00
co2_data = int(return_data_hex[6:10], 16)
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
ser.write(pressure_send)
time.sleep(1)
test
2023-12-01 18:00:11 +08:00
# 获取返回的缓冲data,获取的是buffer_data的长度 9
test
2023-12-01 10:01:20 +08:00
pressurebuffer_data = ser.in_waiting
if pressurebuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(pressurebuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# 对返回的数据进行解析，获取温度和湿度数据
test
2023-12-01 18:00:11 +08:00
pressure_data = int(return_data_hex[6:10], 16) / 10
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
ser.write(sun_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
sunbuffer_data = ser.in_waiting
if sunbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(sunbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
test
2023-12-01 18:00:11 +08:00
sun_data = int(return_data_hex[6:14], 16)
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
# print('send soil directives')
ser.write(soil_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
soilbuffer_data = ser.in_waiting
# print(buffer_data, 'buffer_data')
if soilbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(soilbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# 对返回的数据进行解析，获取温度和湿度数据
test
2023-12-01 18:00:11 +08:00
humidity_data = int(return_data_hex[6:10], 16) / 10
temperature_data = int(return_data_hex[10:14], 16) / 10
electrical_data = int(return_data_hex[14:18], 16) / 10
PH_data = int(return_data_hex[18:22], 16) / 10
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
# print('send danlinjia directives')
ser.write(danlinjia_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
danlinjiabuffer_data = ser.in_waiting
# print(buffer_data, 'buffer_data')
if danlinjiabuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(danlinjiabuffer_data)
# print('返回的数据2进制:', return_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# # 对返回的数据进行解析，获取温度和湿度数据
test
2023-12-01 18:00:11 +08:00
dan_data = int(return_data_hex[6:10], 16) / 10
lin_data = int(return_data_hex[10:14], 16) / 10
jia_data = int(return_data_hex[14:18], 16) / 10
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
# print('send rainfall directives')
ser.write(rainfall_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
rainfallbuffer_data = ser.in_waiting
# print(buffer_data, 'buffer_data')
if rainfallbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(rainfallbuffer_data)
# print('返回的数据2进制:', return_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# print('返回的数据转换为16进制:', return_data_hex)
# # 对返回的数据进行解析，获取温度和湿度数据
# print("当前雨量值为：", int(return_data_hex[6:10], 16)/10)#单位mm
test
2023-12-01 18:00:11 +08:00
rainfall_data = int(return_data_hex[6:10], 16) / 10
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
ser.write(windspeed_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
windspeedbuffer_data = ser.in_waiting
# print(buffer_data, 'buffer_data')
if windspeedbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(windspeedbuffer_data)
# print('返回的数据2进制:', return_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
test
2023-12-01 18:00:11 +08:00
# print('返回的数据转换为16进制:', return_data_hex)
test
2023-12-01 10:01:20 +08:00
# print("当前风速为：", int(return_data_hex[6:10], 16)/10)#单位mm
test
2023-12-01 18:00:11 +08:00
speedwind_data = int(return_data_hex[6:10], 16) / 10
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 10:01:20 +08:00
# print('send winddirection directives')
ser.write(winddirection_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
winddirectionbuffer_data = ser.in_waiting
# print(buffer_data, 'buffer_data')
if winddirectionbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(winddirectionbuffer_data)
# print('返回的数据2进制:', return_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
test
2023-12-01 18:00:11 +08:00
# print('返回的数据转换为16进制:', return_data_hex)
test
2023-12-01 10:01:20 +08:00
# print("当前风向为：", int(return_data_hex[10:14], 16))#单位mm
test
2023-12-01 18:00:11 +08:00
winddirection_data = int(return_data_hex[10:14], 16)
test
2023-12-01 10:01:20 +08:00
time.sleep(5)
test
2023-12-01 18:00:11 +08:00
# print('{"name":"%d","name1":"%d"}', 123,456)
# data = [{'ngvhgv': airtemp_data}, {'nvjgvjvj':airhumi_data}]
data = {'ambient_temperature': airtemp_data,
test
2023-12-01 10:01:20 +08:00
'ambient_humidity': airhumi_data,
'carbon_dioxide': co2_data,
'ambient_air_pressure': pressure_data,
'ambient_lighting': sun_data,
'soil_moisture': humidity_data,
'soil_temperature': temperature_data,
'soil_conductivity': electrical_data,
'soil_PH': PH_data,
'soil_potassium_phosphate_nitrogen': dan_data,
'soil_potassium_phosphate_phosphorus': lin_data,
'soil_potassium_phosphate_potassium': jia_data,
'rainfall': rainfall_data,
'wind_speed': speedwind_data,
'wind_direction': winddirection_data}
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 20:21:48 +08:00
t = LOT_DATA(**data, create_time=int(time.time()))
test
2023-12-01 18:00:11 +08:00
# TODO 判断数据是否正常
test
2023-12-01 20:21:48 +08:00
add(t)
test
2023-12-01 18:00:11 +08:00
# 发送给服务器
client.publish('lot_data', payload=data, qos=0)
def run_no_client():
temp_send = '06 03 01 F4 00 02 85 B2 ' # 温湿度查询指令
co2_send = '06 03 01 F7 00 02 75 B2 ' # 二氧化碳查询指令
pressure_send = '06 03 01 F9 00 02 14 71 ' # 气压查询指令
sun_send = '06 03 01 FA 00 02 E4 71 ' # 光照查询指令
soil_send = '02 03 00 00 00 04 44 3A' # 土壤查询指令
danlinjia_send = '02 03 00 04 00 03 44 39' # 氮磷钾查询指令
rainfall_send = '03 03 00 00 00 01 85 E8' # 雨量查询指令
windspeed_send = '04 03 00 00 00 02 C4 5E' # 风速查询指令
winddirection_send = '05 03 00 00 00 02 C5 8F' # 风向查询指令
ser = serial.Serial("/dev/ttyS2", 9600)
# 发送的数据转为2进制b'\x01\x03\x00\x00\x00\x02\xc4\x0b'
temp_send = bytes.fromhex(temp_send)
co2_send = bytes.fromhex(co2_send)
pressure_send = bytes.fromhex(pressure_send)
sun_send = bytes.fromhex(sun_send)
soil_send = bytes.fromhex(soil_send)
danlinjia_send = bytes.fromhex(danlinjia_send)
rainfall_send = bytes.fromhex(rainfall_send)
windspeed_send = bytes.fromhex(windspeed_send)
winddirection_send = bytes.fromhex(winddirection_send)
while True:
ser.write(temp_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
tempbuffer_data = ser.in_waiting
if tempbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(tempbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# 对返回的数据进行解析，获取温度和湿度数据
airtemp_data = int(return_data_hex[6:10], 16) / 10
airhumi_data = int(return_data_hex[10:14], 16) / 10
time.sleep(5)
ser.write(co2_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
co2buffer_data = ser.in_waiting
if co2buffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(co2buffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# 对返回的数据进行解析，获取温度和湿度数据
co2_data = int(return_data_hex[6:10], 16)
time.sleep(5)
ser.write(pressure_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
pressurebuffer_data = ser.in_waiting
if pressurebuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(pressurebuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# 对返回的数据进行解析，获取温度和湿度数据
pressure_data = int(return_data_hex[6:10], 16) / 10
time.sleep(5)
ser.write(sun_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
sunbuffer_data = ser.in_waiting
if sunbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(sunbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
sun_data = int(return_data_hex[6:14], 16)
time.sleep(5)
ser.write(soil_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
soilbuffer_data = ser.in_waiting
if soilbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(soilbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# 对返回的数据进行解析，获取温度和湿度数据
humidity_data = int(return_data_hex[6:10], 16) / 10
temperature_data = int(return_data_hex[10:14], 16) / 10
electrical_data = int(return_data_hex[14:18], 16) / 10
PH_data = int(return_data_hex[18:22], 16) / 10
time.sleep(5)
ser.write(danlinjia_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
danlinjiabuffer_data = ser.in_waiting
if danlinjiabuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(danlinjiabuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# # 对返回的数据进行解析，获取温度和湿度数据
dan_data = int(return_data_hex[6:10], 16) / 10
lin_data = int(return_data_hex[10:14], 16) / 10
jia_data = int(return_data_hex[14:18], 16) / 10
time.sleep(5)
ser.write(rainfall_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
rainfallbuffer_data = ser.in_waiting
if rainfallbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(rainfallbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
# # 对返回的数据进行解析，获取温度和湿度数据
rainfall_data = int(return_data_hex[6:10], 16) / 10
time.sleep(5)
ser.write(windspeed_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
windspeedbuffer_data = ser.in_waiting
if windspeedbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(windspeedbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
speedwind_data = int(return_data_hex[6:10], 16) / 10
time.sleep(5)
ser.write(winddirection_send)
time.sleep(1)
# 获取返回的缓冲data,获取的是buffer_data的长度 9
winddirectionbuffer_data = ser.in_waiting
if winddirectionbuffer_data:
# 返回的数据为2进制：b'\x01\x03\x04\x01\x08\x022\xfa\xb8'
return_data = ser.read(winddirectionbuffer_data)
# 二进制转换为16进制：010304010802307b79
return_data_hex = str(return_data.hex())
winddirection_data = int(return_data_hex[10:14], 16)
time.sleep(5)
data = {'ambient_temperature': airtemp_data,
'ambient_humidity': airhumi_data,
'carbon_dioxide': co2_data,
'ambient_air_pressure': pressure_data,
'ambient_lighting': sun_data,
'soil_moisture': humidity_data,
'soil_temperature': temperature_data,
'soil_conductivity': electrical_data,
'soil_PH': PH_data,
'soil_potassium_phosphate_nitrogen': dan_data,
'soil_potassium_phosphate_phosphorus': lin_data,
'soil_potassium_phosphate_potassium': jia_data,
'rainfall': rainfall_data,
'wind_speed': speedwind_data,
'wind_direction': winddirection_data}
data = LOT_DATA(**data, create_time=int(time.time()))
# TODO 判断数据是否正常
add(data)
test
2023-12-01 20:21:48 +08:00
def t1():
import time
for i in range(100):
time.sleep(2)
data = {
"wind_speed": 1,
"wind_direction": 6,
"ambient_temperature": 66,
"ambient_humidity": 78,
"carbon_dioxide": 94,
"ambient_air_pressure": 48,
"rainfall": 3,
"ambient_lighting": 59,
"soil_temperature": 71,
"soil_moisture": 19,
"soil_conductivity": 62,
"soil_PH": 49,
"soil_potassium_phosphate_nitrogen": 5,
"soil_potassium_phosphate_phosphorus": 5,
"soil_potassium_phosphate_potassium": 86,
"create_time": int(time.time())
}
client.publish('lot_data', payload=json.dumps(data, ensure_ascii=False), qos=0)
def t2():
print("1")
time = 3
from threading import Thread
def on_connect(client, userdata, flags, rc):
global time
if rc == 0:
print("连接成功，执行数据推送和本地存储")
nt1 = Thread(target=t1)
nt1.start()
else:
if time != 0:
time -= 1
client.reconnect()
else:
print("3次失败，执行本地存储")
nt2 = Thread(target=t2)
nt2.start()
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 20:21:48 +08:00
client = mqtt.Client(transport="websockets")
client.username_pw_set("demo", "123456")
# Specify callback function
client.on_connect = on_connect
# Establish a connection
client.connect('ceshi-mqtt.lihaink.cn', 8083)
# Publish a message
client.loop_forever()
test
2023-12-01 18:00:11 +08:00
test
2023-12-01 20:21:48 +08:00
# Message receiving callback