diff --git a/sensor_to_local.py b/sensor_to_local.py index a38468b..8832157 100644 --- a/sensor_to_local.py +++ b/sensor_to_local.py @@ -31,154 +31,158 @@ if __name__ == '__main__': 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) - add(t) + try: + # 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) + add(t) + except Exception as e: + print(e) + pass