diff --git a/MQTT.py b/MQTT.py index b4ef189..adc17ef 100644 --- a/MQTT.py +++ b/MQTT.py @@ -9,7 +9,8 @@ class MQTT: def on_connect(self, client, userdata, flags, rc): if rc == 0: client.subscribe('lot_mqtt') - + def on_connect_fail(self): + pass # Message receiving callback def on_message(self, client, userdata, msg): data = json.loads(msg.payload.decode('utf-8'))["msg"] @@ -33,7 +34,7 @@ class MQTT: get_record(msg, self.client) elif data == "status": # 查看运行状态 - get_status(client) + get_status(self.client) else: # 错误类型 client.publish('success', payload='No Such Type', qos=0) diff --git a/__pycache__/api.cpython-310.pyc b/__pycache__/api.cpython-310.pyc new file mode 100644 index 0000000..a01e94b Binary files /dev/null and b/__pycache__/api.cpython-310.pyc differ diff --git a/ceshi.py b/ceshi.py index cbd7c10..bab7d7f 100644 --- a/ceshi.py +++ b/ceshi.py @@ -7,406 +7,40 @@ import paho.mqtt.client as mqtt from api import add from db.models.log_data_model import LOT_DATA - -def hex_to_float(hex_str): - hex_int = int(hex_str, 16) - return struct.unpack('!f', struct.pack('!I', hex_int))[0] - - -def print_json(data): - print(json.dumps(data, sort_keys=True, indent=4, separators=(', ', ': '), ensure_ascii=False)) - - -def run_with_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: - 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: - 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) - - # 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()) - # 对返回的数据进行解析，获取温度和湿度数据 - 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) - - # 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()) - # # 对返回的数据进行解析，获取温度和湿度数据 - 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) - - # 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 - 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 - # 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()) - # print('返回的数据转换为16进制:', return_data_hex) - # print("当前风速为：", int(return_data_hex[6:10], 16)/10)#单位mm - speedwind_data = int(return_data_hex[6:10], 16) / 10 - time.sleep(5) - - # 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()) - # print('返回的数据转换为16进制:', return_data_hex) - # print("当前风向为：", int(return_data_hex[10:14], 16))#单位mm - winddirection_data = int(return_data_hex[10:14], 16) - time.sleep(5) - # print('{"name":"%d","name1":"%d"}', 123,456) - # data = [{'ngvhgv': airtemp_data}, {'nvjgvjvj':airhumi_data}] - 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, - 'create_time': int(time.time()) - } - t = LOT_DATA(**data) - # TODO 判断数据是否正常 - # 发送给服务器 - client.publish('demo', payload=json.dumps(data, ensure_ascii=False), qos=0) - add(t) - - -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) - - -times = 3 +import subprocess +import time +import paho.mqtt.client as mqtt def on_connect(client, userdata, flags, rc): global times - from threading import Thread if rc == 0: - # print("连接成功，执行数据推送和本地存储") - Thread(target=t1).start() - else: - if times != 0: - times -= 1 - client.reconnect() - else: - # print("3次失败，执行本地存储") - Thread(target=t2).start() + print("连接成功，执行数据推送和本地存储") + subprocess.Popen(["supervisorctl stop sensor_to_local && supervisorctl start sensor_to_server"]) + times = 3 -def t2(): - run_no_client() +def on_connect_fail(client, userdata): + print("失败，执行本地存储") + subprocess.Popen(["supervisorctl stop sensor_to_server && supervisorctl start sensor_to_local"]) -def t1(): - run_with_client() - - -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() +times = 3 +if __name__ == '__main__': + while True: + try: + client = mqtt.Client(transport="websockets") + client.username_pw_set("demo", "123456") + # Specify callback function + client.on_connect = on_connect + client.on_connect_fail = on_connect_fail + # Establish a connection + client.connect('ceshi-mqtt.lihaink.cn', 8083) + # Publish a message + client.loop_forever() + except Exception as e: + print("等待5秒重新连接客户端") + time.sleep(5) + if times != 0: + times -= 1 + on_connect_fail(None, None) diff --git a/ceshi2.py b/ceshi2.py new file mode 100644 index 0000000..95f6a88 --- /dev/null +++ b/ceshi2.py @@ -0,0 +1,38 @@ +import subprocess +import time +import paho.mqtt.client as mqtt + + +def on_connect(client, userdata, flags, rc): + global times + if rc == 0: + print("连接成功，执行数据推送和本地存储") + subprocess.Popen(["supervisorctl stop sensor_to_local && supervisorctl start sensor_to_server"]) + times = 3 + + +def on_connect_fail(): + print("失败，执行本地存储") + subprocess.Popen(["supervisorctl stop sensor_to_server && supervisorctl start sensor_to_local"]) + + +times = 3 +if __name__ == '__main__': + + while True: + try: + client = mqtt.Client() + client.username_pw_set("demo", "123456") + # Specify callback function + client.on_connect = on_connect + client.on_connect_fail = on_connect_fail + # Establish a connection + client.connect('127.0.0.1', 1883) + # Publish a message + client.loop_forever() + except Exception as e: + print("等待5秒重新连接客户端") + time.sleep(5) + if times != 0: + times -= 1 + on_connect_fail() diff --git a/conf/sensor_to_local.conf b/conf/sensor_to_local.conf new file mode 100644 index 0000000..d82049a --- /dev/null +++ b/conf/sensor_to_local.conf @@ -0,0 +1,13 @@ +[program:sensor_to_local] +directory=/home/pi/lot_manager +command=/usr/bin/python sensor_to_local.py +user=pi +;是否随开机自启 或者reload自启动 +autostart=false +;失败重启 +autorestart=true +;重启次数 +restart_times=3 +redirect_stderr=true +stopsignal=TERM +stopasgroup=True diff --git a/conf/sensor_to_server.conf b/conf/sensor_to_server.conf new file mode 100644 index 0000000..e633819 --- /dev/null +++ b/conf/sensor_to_server.conf @@ -0,0 +1,13 @@ +[program:sensor_to_server] +directory=/home/pi/lot_manager +command=/usr/bin/python sensor_to_server.py +user=pi +;是否随开机自启 或者reload自启动 +autostart=false +;失败重启 +autorestart=true +;重启次数 +restart_times=3 +redirect_stderr=true +stopsignal=TERM +stopasgroup=True diff --git a/db/__pycache__/__init__.cpython-310.pyc b/db/__pycache__/__init__.cpython-310.pyc new file mode 100644 index 0000000..371f42c Binary files /dev/null and b/db/__pycache__/__init__.cpython-310.pyc differ diff --git a/db/__pycache__/base.cpython-310.pyc b/db/__pycache__/base.cpython-310.pyc new file mode 100644 index 0000000..8db6a2d Binary files /dev/null and b/db/__pycache__/base.cpython-310.pyc differ diff --git a/db/__pycache__/session.cpython-310.pyc b/db/__pycache__/session.cpython-310.pyc new file mode 100644 index 0000000..431ef68 Binary files /dev/null and b/db/__pycache__/session.cpython-310.pyc differ diff --git a/db/models/__pycache__/__init__.cpython-310.pyc b/db/models/__pycache__/__init__.cpython-310.pyc new file mode 100644 index 0000000..af1de00 Binary files /dev/null and b/db/models/__pycache__/__init__.cpython-310.pyc differ diff --git a/db/models/__pycache__/base.cpython-310.pyc b/db/models/__pycache__/base.cpython-310.pyc new file mode 100644 index 0000000..8da9105 Binary files /dev/null and b/db/models/__pycache__/base.cpython-310.pyc differ diff --git a/db/models/__pycache__/log_data_model.cpython-310.pyc b/db/models/__pycache__/log_data_model.cpython-310.pyc new file mode 100644 index 0000000..57b5a10 Binary files /dev/null and b/db/models/__pycache__/log_data_model.cpython-310.pyc differ diff --git a/db/repository/__pycache__/__init__.cpython-310.pyc b/db/repository/__pycache__/__init__.cpython-310.pyc new file mode 100644 index 0000000..0822d04 Binary files /dev/null and b/db/repository/__pycache__/__init__.cpython-310.pyc differ diff --git a/db/repository/__pycache__/lot_data_repository.cpython-310.pyc b/db/repository/__pycache__/lot_data_repository.cpython-310.pyc new file mode 100644 index 0000000..0fbcd7a Binary files /dev/null and b/db/repository/__pycache__/lot_data_repository.cpython-310.pyc differ diff --git a/sensor_to_local.py b/sensor_to_local.py new file mode 100644 index 0000000..a8ee12b --- /dev/null +++ b/sensor_to_local.py @@ -0,0 +1,204 @@ +import time + +import serial + +from api import add +from db.models.log_data_model import LOT_DATA + + +if __name__ == '__main__': + # 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: + # 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: + # 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) + # # 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()) + # # 对返回的数据进行解析，获取温度和湿度数据 + # 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) + # # 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()) + # # # 对返回的数据进行解析，获取温度和湿度数据 + # 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) + # # 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 + # 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 + # # 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()) + # # print('返回的数据转换为16进制:', return_data_hex) + # # print("当前风速为：", int(return_data_hex[6:10], 16)/10)#单位mm + # speedwind_data = int(return_data_hex[6:10], 16) / 10 + # time.sleep(5) + # # 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()) + # # print('返回的数据转换为16进制:', return_data_hex) + # # print("当前风向为：", int(return_data_hex[10:14], 16))#单位mm + # winddirection_data = int(return_data_hex[10:14], 16) + # time.sleep(5) + # # print('{"name":"%d","name1":"%d"}', 123,456) + # # data = [{'ngvhgv': airtemp_data}, {'nvjgvjvj':airhumi_data}] + # 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, + # 'create_time': int(time.time()) + # } + data = {'ambient_temperature': 1, + 'ambient_humidity': 1, + 'carbon_dioxide': 1, + 'ambient_air_pressure': 1, + 'ambient_lighting': 1, + 'soil_moisture': 1, + 'soil_temperature': 1, + 'soil_conductivity': 1, + 'soil_PH': 1, + 'soil_potassium_phosphate_nitrogen': 1, + 'soil_potassium_phosphate_phosphorus': 1, + 'soil_potassium_phosphate_potassium': 1, + 'rainfall': 1, + 'wind_speed': 1, + 'wind_direction': 1, + 'create_time': int(time.time()) + } + t = LOT_DATA(**data) + # add(t) + print(t) + time.sleep(1) diff --git a/sensor_to_server.py b/sensor_to_server.py new file mode 100644 index 0000000..89eb849 --- /dev/null +++ b/sensor_to_server.py @@ -0,0 +1,50 @@ +import json +import threading +import time + +import serial +import paho.mqtt.client as mqtt + +from api import add +from db.models.log_data_model import LOT_DATA + + +def t(): + while True: + data = {'ambient_temperature': 2, + 'ambient_humidity': 2, + 'carbon_dioxide': 2, + 'ambient_air_pressure': 12, + 'ambient_lighting': 12, + 'soil_moisture': 12, + 'soil_temperature': 12, + 'soil_conductivity': 12, + 'soil_PH': 12, + 'soil_potassium_phosphate_nitrogen': 12, + 'soil_potassium_phosphate_phosphorus': 12, + 'soil_potassium_phosphate_potassium': 12, + 'rainfall': 2, + 'wind_speed': 2, + 'wind_direction': 2, + 'create_time': int(time.time()) + } + t = LOT_DATA(**data) + client.publish('demo', payload=json.dumps(data, ensure_ascii=False), qos=0) + # add(t) + print(t) + time.sleep(1) + + +def on_connect(client, userdata, flags, rc): + threading.Thread(target=t).start() + + +if __name__ == '__main__': + 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() diff --git a/tool.py b/tool.py index 4ab6d9e..4c2b846 100644 --- a/tool.py +++ b/tool.py @@ -62,3 +62,6 @@ def get_record(msg, client): return files = {filename: open(os.path.join(mp4_path, filename), 'rb'), "Content-Type": "application/octet-stream"} requests.post("https://shop.lihaink.cn/api/index/upload", files=files) + +def sensor_data_upload(client): + p = subprocess.Popen(['/bin/bash update.sh'], shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)