diff --git a/wenshidu.py b/wenshidu.py new file mode 100644 index 0000000..3b0ba70 --- /dev/null +++ b/wenshidu.py @@ -0,0 +1,150 @@ +# 使用方法: 接线 DHT11的三个引脚(如果是四个引脚NC不连接) VCC接5V GND接地 数据D接任意树莓派GPIO口 +# 并将数据D接的树莓派GPIO口BCM编号设置为下面的pin +# 然后你可以直接运行本文件得到数值,也可以使用import dht11_drive导入模块 +# 导入后使用 dht11_drive.dht11() 函数获取湿度与温度 返回值是一个元组 + +import RPi.GPIO as GPIO +import time +import jiqiren as jqr +import MySQL as m + + +def celiang(pin): + GPIO.setup(pin, GPIO.OUT) # 設置引腳輸出 + GPIO.output(pin, True) # 高电平 + + # 树莓派下拉19ms + GPIO.output(pin, False) + time.sleep(0.02) + # GPIO.output(pin,True) + + GPIO.setup(pin, GPIO.IN) # 设置引腳输入 + + time_data_list = [] # 保存数据(高电平持续)时间的列表 + + pan_duan = 1 # 判断数据是否正确 + + end_times = 0 # 数据是否接收完毕 决定是否结束大循环 + start_time = 0 # 防止start_time未定义 + end_time = 0 # 防止end_time未定义 + while 1: + start_time_total = time.time() # 记录每次运行循环开始时间 + + if end_times == 1: # 数据接收完毕 + break + + while GPIO.input(pin) == 0: # 等待电平不为低 + start_time = time.time() # 得到高电平开始时间 + if (start_time - start_time_total) > 0.1: # 判断循环时间过长 电平已经不再变化 + end_times = 1 + break + + while GPIO.input(pin) == 1: # 等待电平不为高 + end_time = time.time() # 得到高电平结束时间 + if (end_time - start_time_total) > 0.1: # 判断循环时间过长 电平已经不再变化 + end_times = 1 + break + + time_data = end_time - start_time # 计算出高电平持续时间 + + time_data_list.append(time_data) # 高电平持续时间数据写入列表 + # print(str(time_data)+', ', end='') + + # print(time_data_list) + # print(len(time_data_list)) + + new_time_data_list = [] # 保存筛选过的时间 + + for i in range(len(time_data_list)): + if (time_data_list[i] > 1.9e-5) and (time_data_list[i] < 7.8e-5): + new_time_data_list.append(time_data_list[i]) + + # print(new_time_data_list) + # print(len(new_time_data_list)) + + if len(new_time_data_list) != 40: + pan_duan = 0 # 判断数据是否正确 + return pan_duan, '接收到的数据位数不足,请重新尝试' + + if pan_duan == 1: # 判断数据是否正确 + Binary_list = [] # 保存二进制数据 + for i in new_time_data_list: + if i > 5.0e-5: + Binary_list.append(1) + elif i < 5.0e-5: + Binary_list.append(0) + if len(Binary_list) != 40: + pan_duan = 0 # 判断数据是否正确 + return pan_duan, '数据位数不足,请重新尝试' + + # print(Binary_list) + # print(len(Binary_list)) + + if pan_duan == 1: # 判断数据是否正确 + # 转字符串格式 + str_Binary_list = [] + for i in Binary_list: + str_Binary_list.append(str(i)) + + if pan_duan == 1: # 判断数据是否正确 + + # 分割数据 并合并成字符串 + # 共40位数据 0-8为湿度整数 9-16为湿度小数 17-24为温度整数 25-32为湿度小数 33-40为校验和(前四个数据直接相加) + str_shidu_zhengshu = ''.join(str_Binary_list[0:8]) + str_shidu_xiaoshu = ''.join(str_Binary_list[8:16]) + str_wendu_zhengshu = ''.join(str_Binary_list[16:24]) + str_wendu_xiaoshu = ''.join(str_Binary_list[24:32]) + str_yanzheng = ''.join(str_Binary_list[32:40]) + + # 转换为十进制 + int_shidu_zhengshu = int(str_shidu_zhengshu, 2) + int_shidu_xiaoshu = int(str_shidu_xiaoshu, 2) + int_wendu_zhengshu = int(str_wendu_zhengshu, 2) + int_wendu_xiaoshu = int(str_wendu_xiaoshu, 2) + int_yanzheng = int(str_yanzheng, 2) + + if int_yanzheng != (int_shidu_zhengshu + int_shidu_xiaoshu + int_wendu_zhengshu + int_wendu_xiaoshu): + pan_duan = 0 # 数据不正确 + return pan_duan, '校验和不匹配,请重新尝试' + + if int_yanzheng == (int_shidu_zhengshu + int_shidu_xiaoshu + int_wendu_zhengshu + int_wendu_xiaoshu): + pan_duan = 1 # 数据正确 + str_shidu = str(int_shidu_zhengshu) + '.' + str(int_shidu_xiaoshu) + str_wendu = str(int_wendu_zhengshu) + '.' + str(int_wendu_xiaoshu) + float_shidu = float(str_shidu) + float_wendu = float(str_wendu) + return pan_duan, (float_shidu, float_wendu) # 返回 湿度 温度 + + +def dht11(pin): # 循环五次 + for i in range(5): + pan_duan_01, return_data = celiang(pin) + if pan_duan_01 == 1: + return return_data + # time.sleep(0.5) + # print('错误') + return 0, 0 + + +def wsd(): + ############################################################# + pin = 4 # 这里填写GPIO号(BCM引脚编号模式) 手动改变此行 + ############################################################# + + GPIO.setmode(GPIO.BCM) # 设置使用BCM引脚编号模式 + + while True: + shidu, wendu = dht11(pin) + if shidu and wendu: + num = m.th_select("max(number)")[0][0]+1 + t = time.strftime('%Y-%m-%d %H:%M:%S') + m.th_insert(str(num), t, str(wendu), str(shidu)) # 将数据保存至数据库 + text = '湿度为' + str(shidu) + '%' + ',温度为' + str(wendu) + '℃。' + print("小溪说:", text) + txt = '湿度为百分之' + str(shidu) + ',温度为' + str(wendu) + '摄氏度。' + jqr.robotSay.say(txt) + GPIO.cleanup(pin) + break + else: + continue + GPIO.cleanup(pin) \ No newline at end of file