|
| 1 | +#!/usr/bin/env python3 |
| 2 | + |
| 3 | +import sys,os |
| 4 | + |
| 5 | +sys.path.append(os.getenv("HOME") + '/ecomet_i2c_raspberry_tools/ecomet_i2c_sensors') |
| 6 | +from ecomet_i2c_sensors.ecomet.winds01 import winds01, winds01_constant |
| 7 | +import time |
| 8 | +#from hdc1080 import hdc1080 |
| 9 | + |
| 10 | +import logging |
| 11 | +from datetime import datetime |
| 12 | + |
| 13 | +logging.basicConfig(level=logging.INFO, # change level looging to (INFO, DEBUG, ERROR) |
| 14 | + format='%(asctime)s %(name)-12s %(levelname)-8s %(message)s', |
| 15 | + datefmt='%m-%d %H:%M', |
| 16 | + filename='ecomet01.log', |
| 17 | + filemode='a') |
| 18 | +console = logging.StreamHandler() |
| 19 | +console.setLevel(logging.DEBUG) |
| 20 | +formatter = logging.Formatter('%(name)-12s: %(levelname)-8s %(message)s') |
| 21 | +console.setFormatter(formatter) |
| 22 | +logging.getLogger('').addHandler(console) |
| 23 | + |
| 24 | + |
| 25 | +def pad_to_21_left(bytes_list: list[int]) -> list[int]: |
| 26 | + """Strip leading 0x00 then pad left with 0x00 to exactly 21 bytes""" |
| 27 | + # Convert to bytes and strip leading zeros |
| 28 | + data = bytes(bytes_list).lstrip(b'\x00') |
| 29 | + # Pad left |
| 30 | + padding_needed = 21 - len(data) |
| 31 | + if padding_needed < 0: |
| 32 | + raise ValueError("Data longer than 20 bytes after stripping") |
| 33 | + return [0] * padding_needed + list(data) |
| 34 | + |
| 35 | +def int_to_hex_bytes(value: int, min_length: int = None) -> list[int]: |
| 36 | + """ |
| 37 | + Convert large integer to list of bytes (big-endian). |
| 38 | + Optionally pad with leading zeros to reach min_length. |
| 39 | + """ |
| 40 | + hex_str = f"{value:x}" |
| 41 | + |
| 42 | + if len(hex_str) % 2 == 1: |
| 43 | + hex_str = "0" + hex_str |
| 44 | + |
| 45 | + bytes_list = [int(hex_str[i:i+2], 16) for i in range(0, len(hex_str), 2)] |
| 46 | + |
| 47 | + if min_length is not None and len(bytes_list) < min_length: |
| 48 | + bytes_list = [0] * (min_length - len(bytes_list)) + bytes_list |
| 49 | + |
| 50 | + return bytes_list |
| 51 | + |
| 52 | +sens = winds01.WINDS01() |
| 53 | +sens._logger = logging.getLogger('ecomet.ecomet01') |
| 54 | +sens._logger.info('Start logging ...') |
| 55 | + |
| 56 | +value = 0x00 |
| 57 | +stime = 6 |
| 58 | +set = 0 |
| 59 | +start = None |
| 60 | +diff = None |
| 61 | +data = sens.write_register ( register = 'REG_CONF', value = [0b00001110]) |
| 62 | +time.sleep(1) |
| 63 | +while (1): |
| 64 | + #data = sens.read_register ( register = 'REG_SERIAL_NUMBER' ) |
| 65 | + #time.sleep(stime) |
| 66 | + while True: |
| 67 | + data = sens.write_register ( register = 'REG_INIT', value = [0b10000000] ) |
| 68 | + #print(f"{data}") |
| 69 | + if (data & 0b10000000) == 0: |
| 70 | + #print("Bit has changed to 0. Operation complete.") |
| 71 | + break # Exit the loop |
| 72 | + time.sleep(0.2) |
| 73 | + |
| 74 | + #data = sens.read_register ( register = 'REG_CONF' ) |
| 75 | + #time.sleep(stime) |
| 76 | + data = sens.read_register ( register = 'REG_INIT' ) |
| 77 | + time.sleep(2) |
| 78 | + #data_cnt = sens.read_register ( register = 'REG_ValidCnt' ) |
| 79 | + #time.sleep(stime) |
| 80 | + #data_eeprom = int_to_hex_bytes(sens.read_register ( register = 'REG_EEPROM_AVG' )[0]) |
| 81 | + data_bulk = pad_to_21_left(int_to_hex_bytes(sens.read_register ( register = 'REG_BULK' )[0])) |
| 82 | + reg_avg00 = int.from_bytes(data_bulk[0:2], "little") |
| 83 | + reg_avg30 = int.from_bytes(data_bulk[2:5], "little") |
| 84 | + reg_avg60 = int.from_bytes(data_bulk[5:8], "little") |
| 85 | + reg_avg360 = int.from_bytes(data_bulk[8:11], "little") |
| 86 | + reg_gust00 = int.from_bytes(data_bulk[11:13], "little") |
| 87 | + reg_gust30 = int.from_bytes(data_bulk[13:15], "little") |
| 88 | + reg_gust60 = int.from_bytes(data_bulk[15:17], "little") |
| 89 | + reg_gust360 = int.from_bytes(data_bulk[17:19], "little") |
| 90 | + reg_ValidCnt = int.from_bytes(data_bulk[19:20], "little") |
| 91 | + reg_EE_Index = int.from_bytes(data_bulk[20:21], "little") |
| 92 | + if int(reg_ValidCnt) == 0 and set == 0: |
| 93 | + start = datetime.now() |
| 94 | + print(f"Start Counting ...") |
| 95 | + set = 1 |
| 96 | + if int(reg_ValidCnt) != 0 and set == 1: |
| 97 | + set = 2 |
| 98 | + elif int(reg_ValidCnt) == 0 and set == 2: |
| 99 | + if start != None: |
| 100 | + end = datetime.now() |
| 101 | + diff = end - start |
| 102 | + start = end |
| 103 | + set = 3 |
| 104 | + time.sleep(stime) |
| 105 | + gust00 = float(reg_gust00 * 0.10194) |
| 106 | + gust30 = float(reg_gust30 * 0.10194) |
| 107 | + gust60 = float(reg_gust60 * 0.10194) |
| 108 | + gust360 = float(reg_gust360 * 0.10194) |
| 109 | + avg00 = float(reg_avg00 * 0.003403) |
| 110 | + if (reg_avg30 <= 16777200 ): |
| 111 | + avg30 = float(reg_avg30 * 0.0006807) |
| 112 | + else: |
| 113 | + avg00 = None |
| 114 | + if (reg_avg60 <= 16777200 ): |
| 115 | + avg60 = float(reg_avg60 * 0.00034034) |
| 116 | + else: |
| 117 | + avg60 = None |
| 118 | + if (reg_avg360 <= 16777200 ): |
| 119 | + avg360 = float(reg_avg360 * 0.000056723) |
| 120 | + else: |
| 121 | + avg360 = None |
| 122 | + print (f"------------------------------------------------------") |
| 123 | + print (f"Count: {reg_ValidCnt} Index: {reg_EE_Index} SET: {set}") |
| 124 | + print (f"AVG00: {round(avg00,2)} m.s, GUST00: {round(gust00,2)}") |
| 125 | + if avg30 == None: |
| 126 | + print (f"AVG30: N/A m.s, GUST30: {round(gust30,2)}") |
| 127 | + else: |
| 128 | + print (f"AVG30: {round(avg30,2)} m.s, GUST30: {round(gust30,2)}") |
| 129 | + if avg60 == None: |
| 130 | + print (f"AVG60: N/A m.s, GUST60: {round(gust60,2)}") |
| 131 | + else: |
| 132 | + print (f"AVG60: {round(avg60,2)} m.s, GUST60: {round(gust60,2)}") |
| 133 | + if avg360 == None: |
| 134 | + print (f"AVG360: N/A m.s, GUST360: {round(gust360,2)}") |
| 135 | + else: |
| 136 | + print (f"AVG360: {round(avg360,2)} m.s, GUST360: {round(gust360,2)}") |
| 137 | + if set >= 3: |
| 138 | + if set == 3: |
| 139 | + print(f"Time diff: {diff}") |
| 140 | + set = 4 |
| 141 | + if int(reg_ValidCnt) > 0: |
| 142 | + set = 2 |
| 143 | + #print (f"AVG: {data_avg[0]} m.s, GUST: {data_gust[0]} m.s") |
| 144 | + #time.sleep(stime) |
| 145 | + #time.sleep(stime) |
| 146 | + #data = sens.read_register ( register = 'REG_AVG30' ) |
| 147 | + #time.sleep(stime) |
| 148 | + #data = sens.read_register ( register = 'REG_AVG60' ) |
| 149 | + #time.sleep(stime) |
| 150 | + #data = sens.read_register ( register = 'REG_AVG360' ) |
| 151 | + #time.sleep(stime) |
| 152 | + #data = sens.read_register ( register = 'REG_GUST00' ) |
| 153 | + #time.sleep(stime) |
| 154 | + #data = sens.read_register ( register = 'REG_GUST30' ) |
| 155 | + #time.sleep(stime) |
| 156 | + #data = sens.read_register ( register = 'REG_GUST60' ) |
| 157 | + #time.sleep(stime) |
| 158 | + #data = sens.read_register ( register = 'REG_GUST360' ) |
| 159 | + #time.sleep(stime) |
| 160 | + #data = sens.read_register ( register = 'REG_ValidCnt' ) |
| 161 | + #time.sleep(stime) |
0 commit comments