-
-
Save rin-ofumi/29e738d3ae216cae89281c7b39186096 to your computer and use it in GitHub Desktop.
M5StickC「Wi-SUN HAT」用の『チャンネル変更時＆タイムアウト発生時に強制再起動する』テストコード
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from m5stack import * | |
| import machine | |
| import gc | |
| import utime | |
| import ure | |
| import uos | |
| import _thread | |
| import wifiCfg | |
| import ntptime | |
| import wisun_udp | |
| # 固定値 | |
| GET_COEFFICIENT = b'\x10\x81\x00\x01\x05\xFF\x01\x02\x88\x01\x62\x01\xD3\x00' #D3 *積算電力量係数の要求 | |
| GET_TOTAL_POWER_UNIT = b'\x10\x81\x00\x01\x05\xFF\x01\x02\x88\x01\x62\x01\xE1\x00' #E1 *積算電力量単位の要求 | |
| GET_NOW_PA = b'\x10\x81\x00\x01\x05\xFF\x01\x02\x88\x01\x62\x02\xE7\x00\xE8\x00' #E7&E8 *瞬時電力計測値＆瞬時電流計測値（T/R相）の要求 | |
| GET_NOW_P = b'\x10\x81\x00\x01\x05\xFF\x01\x02\x88\x01\x62\x01\xE7\x00' #E7 *瞬時電力計測値の要求 | |
| GET_TOTAL_POWER_30 = b'\x10\x81\x00\x01\x05\xFF\x01\x02\x88\x01\x62\x01\xEA\x00' #EA *30分毎更新の積算電力量の要求 | |
| # 変数宣言 | |
| SCAN_COUNT = 6 # ActiveScan count | |
| channel = '' | |
| panid = '' | |
| macadr = '' | |
| lqi = '' | |
| Am_err = 1 # グローバル Ambientの初回通信が通るまでは時計は赤文字 | |
| Disp_mode = 0 # グローバル | |
| lcd_mute = False # グローバル | |
| data_mute = False # グローバル | |
| m5type = 0 # グローバル [0:M5StickC、1: M5StickCPlus] | |
| np_interval = 5 # 瞬間電力値の要求サイクル（秒）※最短でも5秒以上が望ましい（基本は10秒とする） | |
| am_interval = 30 # Ambientへデータを送るサイクル（秒））※Ambientは3000件/日までなので、丸1日分持たせるには30秒以上にする | |
| AM_ID_1 = None # Ambient設定が不備の場合 | |
| AM_WKEY_1 = None # Ambient設定が不備の場合 | |
| AM_ID_2 = None # Ambient設定が不備の場合 | |
| AM_WKEY_2 = None # Ambient設定が不備の場合 | |
| ESP_NOW_F = False # ESP_NOWを使うかの設定値のデフォルト値 | |
| TIMEOUT = 30 # 何らかの事情で更新が止まった時のタイムアウト（秒）のデフォルト値 | |
| AMPERE_RED = 0.7 # 契約ブレーカー値に対し、どれくらいの使用率で赤文字化させるかのデフォルト値 （力率は無視してます） | |
| AMPERE_LIMIT = 30 # 契約ブレーカー値のデフォルト値 | |
| # @cinimlさんのファーム差分吸収ロジック | |
| class AXPCompat(object): | |
| def __init__(self): | |
| if( hasattr(axp, 'setLDO2Vol') ): | |
| self.setLDO2Vol = axp.setLDO2Vol | |
| else: | |
| self.setLDO2Vol = axp.setLDO2Volt | |
| axp = AXPCompat() | |
| # 時計表示スレッド関数 | |
| def time_count(): | |
| global Disp_mode , m5type | |
| global Am_err | |
| while True: | |
| if Am_err == 0 : # Ambient通信不具合発生時は時計の文字が赤くなる | |
| fc = lcd.WHITE | |
| else : | |
| fc = lcd.RED | |
| if Disp_mode == 1 : # 表示回転処理 | |
| if m5type == 0 : | |
| lcd.rect(67, 0, 80, 160, lcd.BLACK, lcd.BLACK) | |
| lcd.font(lcd.FONT_DefaultSmall, rotate = 90) | |
| lcd.print('{}-{:02d}-{:02d} {:02d}:{:02d}:{:02d}'.format(*utime.localtime()[:6]), 78, 40, fc) | |
| if m5type == 1 : | |
| lcd.rect(113, 0, 135, 240, lcd.BLACK, lcd.BLACK) | |
| lcd.font(lcd.FONT_DejaVu18, rotate = 90) | |
| lcd.print('{}-{:02d}-{:02d} {:02d}:{:02d}:{:02d}'.format(*utime.localtime()[:6]), 131, 30, fc) | |
| else : | |
| if m5type == 0 : | |
| lcd.rect(0 , 0, 13, 160, lcd.BLACK, lcd.BLACK) | |
| lcd.font(lcd.FONT_DefaultSmall, rotate = 270) | |
| lcd.print('{}-{:02d}-{:02d} {:02d}:{:02d}:{:02d}'.format(*utime.localtime()[:6]), 2, 125, fc) | |
| if m5type == 1 : | |
| lcd.rect(0 , 0, 20, 240, lcd.BLACK, lcd.BLACK) | |
| lcd.font(lcd.FONT_DejaVu18, rotate = 270) | |
| lcd.print('{}-{:02d}-{:02d} {:02d}:{:02d}:{:02d}'.format(*utime.localtime()[:6]), 4, 210, fc) | |
| utime.sleep(0.5) | |
| # 表示OFFボタン処理スレッド関数 | |
| def buttonA_wasPressed(): | |
| global lcd_mute | |
| if lcd_mute : | |
| lcd_mute = False | |
| else : | |
| lcd_mute = True | |
| if lcd_mute == True : | |
| axp.setLDO2Vol(0) #バックライト輝度調整（OFF） | |
| else : | |
| axp.setLDO2Vol(2.7) #バックライト輝度調整（中くらい） | |
| # 表示切替ボタン処理スレッド関数 | |
| def buttonB_wasPressed(): | |
| global Disp_mode | |
| if Disp_mode == 1 : | |
| Disp_mode = 0 | |
| else : | |
| Disp_mode = 1 | |
| draw_lcd() | |
| # 表示モード切替時の枠描画処理関数 | |
| def draw_lcd(): | |
| global Disp_mode , m5type | |
| lcd.clear() | |
| if Disp_mode == 1 : | |
| if m5type == 0 : | |
| lcd.line(66, 0, 66, 160, lcd.LIGHTGREY) | |
| if m5type == 1 : | |
| lcd.line(112, 0, 112, 240, lcd.LIGHTGREY) | |
| else : | |
| if m5type == 0 : | |
| lcd.line(14, 0, 14, 160, lcd.LIGHTGREY) | |
| if m5type == 1 : | |
| lcd.line(23, 0, 23, 240, lcd.LIGHTGREY) | |
| draw_w() | |
| # 瞬間電力値表示処理関数 | |
| def draw_w(): | |
| global Disp_mode , m5type | |
| global lcd_mute | |
| global data_mute | |
| global AMPERE_LIMIT | |
| global AMPERE_RED | |
| if data_mute or (u.instant_power[0] == 0) : # タイムアウトで表示ミュートされてるか、初期値のままなら電力値非表示（黒文字化） | |
| fc = lcd.BLACK | |
| else : | |
| if u.instant_power[0] >= (AMPERE_LIMIT * AMPERE_RED * 100) : # 警告閾値超え時は文字が赤くなる | |
| fc = lcd.RED | |
| if lcd_mute == True : # 閾値超え時はLCD ON | |
| axp.setLDO2Vol(2.7) # バックライト輝度調整（中くらい） | |
| else : | |
| fc = lcd.WHITE | |
| if lcd_mute == True : | |
| axp.setLDO2Vol(0) # バックライト輝度調整（中くらい） | |
| if Disp_mode == 1 : # 表示回転処理 | |
| if m5type == 0 : | |
| lcd.rect(0, 0, 65, 160, lcd.BLACK, lcd.BLACK) | |
| lcd.font(lcd.FONT_DejaVu18, rotate = 90) # 単位(W)の表示 | |
| lcd.print('W', 35, 120, fc) | |
| lcd.font(lcd.FONT_DejaVu24, rotate = 90) # 瞬時電力値の表示 | |
| lcd.print(str(u.instant_power[0]), 40, 135 - (len(str(u.instant_power[0]))* 24), fc) | |
| if m5type == 1 : | |
| lcd.rect(0, 0, 111, 240, lcd.BLACK, lcd.BLACK) | |
| lcd.font(lcd.FONT_DejaVu24, rotate = 90) # 単位(W)の表示 | |
| lcd.print('W', 63, 180, fc) | |
| lcd.font(lcd.FONT_DejaVu40, rotate = 90) # 瞬時電力値の表示 | |
| lcd.print(str(u.instant_power[0]), 75, 220 - (len(str(u.instant_power[0]))* 40), fc) | |
| else : | |
| if m5type == 0 : | |
| lcd.rect(15 , 0, 80, 160, lcd.BLACK, lcd.BLACK) | |
| lcd.font(lcd.FONT_DejaVu18, rotate = 270) # 単位(W)の表示 | |
| lcd.print('W', 45, 40, fc) | |
| lcd.font(lcd.FONT_DejaVu24, rotate = 270) # 瞬時電力値の表示 | |
| lcd.print(str(u.instant_power[0]), 40, 25 + (len(str(u.instant_power[0]))* 24), fc) | |
| if m5type == 1 : | |
| lcd.rect(24 , 0, 135, 240, lcd.BLACK, lcd.BLACK) | |
| lcd.font(lcd.FONT_DejaVu24, rotate = 270) # 単位(W)の表示 | |
| lcd.print('W', 72, 60, fc) | |
| lcd.font(lcd.FONT_DejaVu40, rotate = 270) # 瞬時電力値の表示 | |
| lcd.print(str(u.instant_power[0]), 60, 20 + (len(str(u.instant_power[0]))* 40), fc) | |
| # wisun_set_m.txtの存在/中身チェック関数 | |
| def wisun_set_filechk(): | |
| global AMPERE_LIMIT | |
| global AMPERE_RED | |
| global TIMEOUT | |
| global BRID | |
| global BRPSWD | |
| global AM_ID_1 | |
| global AM_WKEY_1 | |
| global AM_ID_2 | |
| global AM_WKEY_2 | |
| global ESP_NOW_F | |
| scanfile_flg = False | |
| for file_name in uos.listdir('/flash') : | |
| if file_name == 'wisun_set_m.txt' : | |
| scanfile_flg = True | |
| if scanfile_flg : | |
| print('>> found [wisun_set_m.txt] !') | |
| with open('/flash/wisun_set_m.txt' , 'r') as f : | |
| for file_line in f : | |
| filetxt = file_line.strip().split(':') | |
| if filetxt[0] == 'AMPERE_RED' : | |
| if float(filetxt[1]) >= 0 and float(filetxt[1]) <= 1 : | |
| AMPERE_RED = float(filetxt[1]) | |
| print('- AMPERE_RED: ' + str(AMPERE_RED)) | |
| elif filetxt[0] == 'AMPERE_LIMIT' : | |
| if int(filetxt[1]) >= 20 : | |
| AMPERE_LIMIT = int(filetxt[1]) | |
| print('- AMPERE_LIMIT: ' + str(AMPERE_LIMIT)) | |
| elif filetxt[0] == 'TIMEOUT' : | |
| if int(filetxt[1]) > 0 : | |
| TIMEOUT = int(filetxt[1]) | |
| print('- TIMEOUT: ' + str(TIMEOUT)) | |
| elif filetxt[0] == 'BRID' : | |
| BRID = str(filetxt[1]) | |
| print('- BRID: ' + str(BRID)) | |
| elif filetxt[0] == 'BRPSWD' : | |
| BRPSWD = str(filetxt[1]) | |
| print('- BRPSWD: ' + str(BRPSWD)) | |
| elif filetxt[0] == 'AM_ID_1' : | |
| AM_ID_1 = str(filetxt[1]) | |
| print('- AM_ID_1: ' + str(AM_ID_1)) | |
| elif filetxt[0] == 'AM_WKEY_1' : | |
| if len(filetxt[1]) == 16 : | |
| AM_WKEY_1 = str(filetxt[1]) | |
| print('- AM_WKEY_1: ' + str(AM_WKEY_1)) | |
| elif filetxt[0] == 'AM_ID_2' : | |
| AM_ID_2 = str(filetxt[1]) | |
| print('- AM_ID_2: ' + str(AM_ID_2)) | |
| elif filetxt[0] == 'AM_WKEY_2' : | |
| if len(filetxt[1]) == 16 : | |
| AM_WKEY_2 = str(filetxt[1]) | |
| print('- AM_WKEY_2: ' + str(AM_WKEY_2)) | |
| elif filetxt[0] == 'ESP_NOW' : | |
| if int(filetxt[1]) == 0 or int(filetxt[1]) == 1 : | |
| ESP_NOW_F = int(filetxt[1]) | |
| print('- ESP_NOW: ' + str(ESP_NOW_F)) | |
| if len(BRID) == 32 and len(BRPSWD) == 12: # BルートIDとパスワードの桁数チェック（NGならプログラム停止） | |
| scanfile_flg = True | |
| else : | |
| print('>> [wisun_set_m.txt] Illegal!!') | |
| scanfile_flg = False | |
| else : | |
| print('>> no [wisun_set_m.txt] !') | |
| return scanfile_flg | |
| # Wi-SUN_SCAN.txtの存在/中身チェック関数 | |
| def wisun_scan_filechk(): | |
| global channel | |
| global panid | |
| global macadr | |
| global lqi | |
| scanfile_flg = False | |
| for file_name in uos.listdir('/flash') : | |
| if file_name == 'Wi-SUN_SCAN.txt' : | |
| scanfile_flg = True | |
| if scanfile_flg : | |
| print('>> found [Wi-SUN_SCAN.txt] !') | |
| with open('/flash/Wi-SUN_SCAN.txt' , 'r') as f : | |
| for file_line in f : | |
| filetxt = file_line.strip().split(':') | |
| if filetxt[0] == 'Channel' : | |
| channel = filetxt[1] | |
| print('- Channel: ' + channel) | |
| elif filetxt[0] == 'Pan_ID' : | |
| panid = filetxt[1] | |
| print('- Pan_ID: ' + panid) | |
| elif filetxt[0] == 'MAC_Addr' : | |
| macadr = filetxt[1] | |
| print('- MAC_Addr: ' + macadr) | |
| elif filetxt[0] == 'LQI' : | |
| lqi = filetxt[1] | |
| print('- LQI: ' + lqi) | |
| elif filetxt[0] == 'COEFFICIENT' : | |
| u.power_coefficient = int(filetxt[1]) | |
| print('- COEFFICIENT: ' + str(u.power_coefficient)) | |
| elif filetxt[0] == 'UNIT' : | |
| u.power_unit = float(filetxt[1]) | |
| print('- UNIT: ' + str(u.power_unit)) | |
| if len(channel) == 2 and len(panid) == 4 and len(macadr) == 16: | |
| scanfile_flg = True | |
| else : | |
| print('>> [Wi-SUN_SCAN.txt] Illegal!!') | |
| scanfile_flg = False | |
| else : | |
| print('>> no [Wi-SUN_SCAN.txt] !') | |
| return scanfile_flg | |
| # メインプログラムはここから（この上はプログラム内関数） | |
| # M5StickC/Plus機種判定 | |
| if lcd.winsize() == (80,160) : | |
| m5type = 0 | |
| print('>> M5Type = M5StickC') | |
| if lcd.winsize() == (136,241) : | |
| m5type = 1 | |
| print('>> M5Type = M5StickCPlus') | |
| # 基本設定ファイル[wisun_set_m.txt]のチェック 無い場合は例外エラー吐いて終了する | |
| if not wisun_set_filechk() : | |
| lcd.print('err!! Check [wisun_set_m.txt] and restart!!', 0, 0, lcd.WHITE) | |
| raise ValueError('err!! Check [wisun_set_m.txt] and restart!!') | |
| # WiFi設定 | |
| wifiCfg.autoConnect(lcdShow=True) | |
| lcd.clear() | |
| lcd.print('*', 0, 0, lcd.WHITE) | |
| print('>> WiFi init OK') | |
| # UDPデータインスタンス生成 | |
| u = wisun_udp.udp_read() | |
| print('>> UDP reader init OK') | |
| # Ambientインスタンス生成 | |
| if (AM_ID_1 is not None) and (AM_WKEY_1 is not None) : # Ambient_1の設定情報があった場合 | |
| import ambient | |
| am_now_power = ambient.Ambient(AM_ID_1, AM_WKEY_1) | |
| print('>> Ambient_1 init OK') | |
| if (AM_ID_2 is not None) and (AM_WKEY_2 is not None) : # Ambient_2の設定情報があった場合 | |
| import ambient | |
| am_total_power = ambient.Ambient(AM_ID_2, AM_WKEY_2) | |
| print('>> Ambient_2 init OK') | |
| lcd.print('**', 0, 0, lcd.WHITE) | |
| # BP35A1 UART設定 | |
| #bp35a1 = machine.UART(1, tx=0, rx=36) # Wi-SUN HAT rev0.1用 | |
| bp35a1 = machine.UART(1, tx=0, rx=26) # Wi-SUN HAT rev0.2用 | |
| bp35a1.init(115200, bits=8, parity=None, stop=1, timeout=2000) | |
| lcd.print('***', 0, 0, lcd.WHITE) | |
| print('>> UART init OK') | |
| # UARTの送受信バッファーの塵データをクリア | |
| utime.sleep(0.5) | |
| if bp35a1.any() != 0 : | |
| dust = bp35a1.read() | |
| bp35a1.write('\r\n') | |
| utime.sleep(1) | |
| if bp35a1.any() != 0 : | |
| dust = bp35a1.read() | |
| bp35a1.write('\r\n') | |
| utime.sleep(0.5) | |
| print('>> UART RX/TX Data Clear!') | |
| # BP35A1の初期設定 - コマンドエコーバックをオンにする | |
| bp35a1.write('SKSREG SFE 1\r\n') | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| print('*') | |
| if line is not None : | |
| if ure.match('OK' , line.strip()) : | |
| break | |
| print('>> BA35A1 Echo back ON set OK') | |
| utime.sleep(0.5) | |
| # BP35A1の初期設定 - ERXUDPデータ部表示形式をASCIIへ変更（デフォはバイナリ） | |
| bp35a1.write('ROPT\r\n') | |
| utime.sleep(0.5) | |
| mode_flg = False | |
| while True : #Echo back & OK wait! | |
| line = bp35a1.readline() | |
| # print(line) | |
| if ure.match("OK" , line) : | |
| print(' - BP35A1 ASCII mode') | |
| break | |
| if ure.match("OK 00" , line) : | |
| print(' - BP35A1 Binary Mode') | |
| mode_flg = True | |
| utime.sleep(0.5) | |
| if mode_flg : | |
| bp35a1.write('WOPT 01\r\n') | |
| print('>> BP35A1 ASCII mode set') | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = bp35a1.readline() | |
| # print(line) | |
| if ure.match("OK" , line) : | |
| print('>> BP35A1 ASCII mode set OK') | |
| break | |
| lcd.print('****', 0, 0, lcd.WHITE) | |
| # 以前のPANAセッションを解除 | |
| # 前セッションが残ってると接続出来ない？場合の対策 前セッション無しでも、ER10が返ってくるだけ | |
| bp35a1.write('SKTERM\r\n') | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = bp35a1.readline() | |
| # print(line) | |
| if ure.match("OK" , line) : | |
| print(' -Old Session Clear!') | |
| break | |
| elif ure.match("FAIL ER10" , line) : | |
| print(' -Non Old Session') | |
| break | |
| lcd.print('*****', 0, 0, lcd.WHITE) | |
| # B-root PASSWORDを送信 | |
| bp35a1.write("SKSETPWD C " + BRPSWD + "\r\n") | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| print('*') | |
| if line is not None : | |
| if ure.match('OK' , line.strip()) : | |
| print('>> BA35A1 B-root PASSWORD set OK') | |
| break | |
| lcd.print('***** *', 0, 0, lcd.WHITE) | |
| utime.sleep(0.5) | |
| # B-root IDを送信 | |
| bp35a1.write("SKSETRBID " + BRID + "\r\n") | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| print('*') | |
| if line is not None : | |
| if ure.match('OK' , line.strip()) : | |
| print('>> BA35A1 B-root ID set OK') | |
| break | |
| lcd.print('***** **', 0, 0, lcd.WHITE) | |
| utime.sleep(1) | |
| gc.collect() | |
| # Wi-SUNチャンネルスキャン（「Wi-SUN_SCAN.txt」の存在しない or 中身が異常値だった場合） | |
| if not wisun_scan_filechk() : | |
| #<Channel Scan> | |
| scanOK = False | |
| print('>> Activescan start!') | |
| while not scanOK : | |
| bp35a1.write("SKSCAN 2 FFFFFFFF " + str(SCAN_COUNT) + "\r\n") | |
| utime.sleep(0.5) | |
| #スキャン1回分のループ処理 | |
| scanEnd = False | |
| while not scanEnd : | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| print('*') | |
| if line is not None : | |
| if ure.match("EVENT 22" , line.strip()) : | |
| print('-') | |
| scanEnd = True | |
| elif ure.match("Channel:" , line.strip()) : | |
| pickuptext = ure.compile(':') | |
| pickt = pickuptext.split(line.strip()) | |
| channel = str(pickt[1].strip(), 'utf-8') | |
| print(" Channel= " + str(channel)) | |
| elif ure.match("Pan ID:" , line.strip()) : | |
| pickuptext = ure.compile(':') | |
| pickt = pickuptext.split(line.strip()) | |
| panid = str(pickt[1].strip(), 'utf-8') | |
| print(" Pan_ID= " + str(panid)) | |
| elif ure.match("Addr:" , line.strip()) : | |
| pickuptext = ure.compile(':') | |
| pickt = pickuptext.split(line.strip()) | |
| macadr = str(pickt[1].strip(), 'utf-8') | |
| print(" MAC_Addr= " + str(macadr)) | |
| elif ure.match("LQI:" , line.strip()) : | |
| pickuptext = ure.compile(':') | |
| pickt = pickuptext.split(line.strip()) | |
| lqi = str(pickt[1].strip(), 'utf-8') | |
| print(" LQI= " + str(lqi)) | |
| print(line.strip()) | |
| utime.sleep(0.5) | |
| gc.collect() | |
| SCAN_COUNT+=1 | |
| if SCAN_COUNT > 10 : | |
| raise ValueError('Scan retry count over! Please Reboot!') | |
| elif len(channel) == 2 and len(panid) == 4 and len(macadr) == 16 and len(lqi) == 2 : | |
| with open('/flash/Wi-SUN_SCAN.txt' , 'w') as f: | |
| f.write('Channel:' + str(channel) + '\r\n') | |
| f.write('Pan_ID:' + str(panid) + '\r\n') | |
| f.write('MAC_Addr:' + str(macadr) + '\r\n') | |
| f.write('LQI:' + str(lqi) + '\r\n') | |
| print('>> [Wi-SUN_SCAN.txt] maked!!') | |
| print('Scan All Clear!') | |
| scanOK = True | |
| lcd.print('***** ***', 0, 0, lcd.WHITE) | |
| # PANA接続処理 | |
| while True : | |
| #<Channel set> | |
| bp35a1.write("SKSREG S2 " + channel + "\r\n") | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| print('*') | |
| if line is not None : | |
| if ure.match('OK' , line.strip()) : | |
| break | |
| #<Pan ID set> | |
| bp35a1.write("SKSREG S3 " + panid + "\r\n") | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| print('*') | |
| if line is not None : | |
| if ure.match('OK' , line.strip()) : | |
| break | |
| #<MACアドレスをIPV6アドレスに変換> | |
| bp35a1.write("SKLL64 " + macadr + "\r\n") | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| print('*') | |
| if line is not None : | |
| if len(line.strip()) == 39 : | |
| ipv6Addr = str(line.strip(), 'utf-8') | |
| print('IPv6 Addr = ' + str(ipv6Addr)) | |
| break | |
| gc.collect() | |
| utime.sleep(1) | |
| #<BP35A1のコマンドエコーバックをオフにする> | |
| bp35a1.write('SKSREG SFE 0\r\n') | |
| utime.sleep(0.5) | |
| while True : #Echo back & OK wait! | |
| line = bp35a1.readline() | |
| print(line) | |
| if ure.match("OK" , line) : | |
| print('>> BA35A1 Echo back OFF set OK') | |
| break | |
| #<PANA接続要求> | |
| print('PANA authentication start!!') | |
| bp35a1.write("SKJOIN " + ipv6Addr + "\r\n") | |
| utime.sleep(0.1) | |
| bConnected = False | |
| while not bConnected : | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| print('*') | |
| if line is not None : | |
| if ure.match("EVENT 24" , line.strip()) : | |
| print(">> PANA authentication NG! ...scan retry") | |
| utime.sleep(1) | |
| for file_name in uos.listdir('/flash') : | |
| if file_name == 'Wi-SUN_SCAN.txt' : | |
| uos.remove('/flash/Wi-SUN_SCAN.txt') #チャンネルが変わった可能性があるので、ファイル削除 | |
| scanfile_flg = False | |
| channel = '' | |
| panid = '' | |
| macadr = '' | |
| u.power_coefficient = 0 | |
| u.power_unit = 0.0 | |
| print(">> Erase Wi-SUN_SCAN.txt! & Reboot!!") | |
| utime.sleep(1) | |
| machine.reset() #ファイル削除の後リブートする | |
| break | |
| elif ure.match("EVENT 25" , line.strip()) : | |
| print(">> PANA authentication OK!") | |
| bConnected = True | |
| utime.sleep(1) | |
| gc.collect() | |
| if bConnected : | |
| break | |
| lcd.print('***** ****', 0, 0, lcd.WHITE) | |
| gc.collect() | |
| # ECHONET Lite 積算電力係数(COEFFICIENT)要求コマンド送信 | |
| if u.power_coefficient == 0 : | |
| command = bytes('SKSENDTO 1 {0} 0E1A 1 {1:04X} '.format(ipv6Addr, len(GET_COEFFICIENT)), 'utf-8') | |
| bp35a1.write(command) | |
| bp35a1.write(GET_COEFFICIENT) | |
| print('>> [GET_COEFFICIENT] cmd send') | |
| utime.sleep(0.5) | |
| while u.power_coefficient == 0 : #D3（積算電力量係数）受信待ち | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| u.read(line) | |
| if u.type == 'D3' : | |
| with open('/flash/Wi-SUN_SCAN.txt' , 'a') as fc: | |
| fc.write('COEFFICIENT:' + str(u.power_coefficient) + '\r\n') | |
| utime.sleep(0.1) | |
| gc.collect() | |
| lcd.print('***** *****', 0, 0, lcd.WHITE) | |
| # ECHONET Lite 積算電力単位(UNIT)要求コマンド送信 | |
| if u.power_unit == 0.0 : | |
| command = bytes('SKSENDTO 1 {0} 0E1A 1 {1:04X} '.format(ipv6Addr, len(GET_TOTAL_POWER_UNIT)), 'utf-8') | |
| bp35a1.write(command) | |
| bp35a1.write(GET_TOTAL_POWER_UNIT) | |
| print('>> [GET_TOTAL_POWER_UNIT] cmd send') | |
| utime.sleep(0.5) | |
| while u.power_unit == 0.0 : #E1（積算電力量単位）受信待ち | |
| line = None | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| u.read(line) | |
| if u.type == 'E1' : | |
| with open('/flash/Wi-SUN_SCAN.txt' , 'a') as fu: | |
| fu.write('UNIT:' + str(u.power_unit) + '\r\n') | |
| utime.sleep(0.1) | |
| gc.collect() | |
| lcd.print('***** ***** *', 0, 0, lcd.WHITE) | |
| # ESP NOW設定 | |
| if ESP_NOW_F : | |
| import espnow | |
| espnow.init() | |
| print('>> ESP NOW init') | |
| lcd.print('***** ***** **', 0, 0, lcd.WHITE) | |
| print('heapmemory= ' + str(gc.mem_free())) | |
| # RTC設定 | |
| ntp = ntptime.client(host='jp.pool.ntp.org', timezone=9) | |
| print('>> RTC init OK') | |
| # 画面初期化 | |
| axp.setLDO2Vol(2.7) #バックライト輝度調整（中くらい） | |
| draw_lcd() | |
| print('>> Disp init OK') | |
| # 時刻表示スレッド起動 | |
| _thread.start_new_thread(time_count, ()) | |
| print('>> Time Count thread ON') | |
| # ボタン検出スレッド起動 | |
| btnA.wasPressed(buttonA_wasPressed) | |
| btnB.wasPressed(buttonB_wasPressed) | |
| print('>> Button Check thread ON') | |
| # タイムカウンタ初期値設定 | |
| np_c = utime.time() | |
| tp_c = utime.time() | |
| am_c = utime.time() | |
| tp_f = False # 積算電力量応答の有無フラグ | |
| # メインループ | |
| while True: | |
| line = None # UDPデータの受信処理 | |
| if bp35a1.any() != 0 : | |
| line = bp35a1.readline() | |
| u.read(line) | |
| # print(line) #全ログ取得デバッグ用 | |
| if u.type == 'E7' : # [E7]なら受信データは瞬時電力計測値 | |
| data_mute = False | |
| draw_w() | |
| if ESP_NOW_F : # ESP NOW一斉同報発信を使う場合 | |
| espnow.broadcast(data=str('NPD=' + str(u.instant_power[0]))) | |
| if (utime.time() - am_c) >= am_interval : | |
| if (AM_ID_1 is not None) and (AM_WKEY_1 is not None) : # Ambient_1が設定されてる場合 | |
| try : # ネットワーク不通発生などで例外エラー終了されない様に try except しとく | |
| rn = am_now_power.send({'d1': u.instant_power[0]}) | |
| print('Ambient send OK! / ' + str(rn.status_code) + ' / ' + str(Am_err)) | |
| Am_err = 0 | |
| am_c = utime.time() | |
| rn.close() | |
| except : | |
| print('Ambient send ERR! / ' + str(Am_err)) | |
| Am_err = Am_err + 1 | |
| elif u.type == 'EA72' : # [EA72]なら受信データは積算電力量 | |
| tp_f = True | |
| if ESP_NOW_F : # ESP NOW一斉同報発信を使う場合 | |
| espnow.broadcast(data=str('TPD=' + str(u.total_power[0]) + '/' + u.total_power[1])) | |
| if (AM_ID_2 is not None) and (AM_WKEY_2 is not None) : # Ambient_2が設定されてる場合 | |
| try : # ネットワーク不通発生などで例外エラー終了されない様に try except しとく | |
| rt = am_total_power.send({'created': u.total_power[1], 'd1': u.total_power[0]}) | |
| print('Ambient send OK! (Total Power) / ' + str(rt.status_code) + ' / ' + str(Am_err)) | |
| Am_err = 0 | |
| rt.close() | |
| except : | |
| print('Ambient send ERR! (Total Power) / ' + str(Am_err)) | |
| Am_err = Am_err + 1 | |
| if ((utime.time() - tp_c) >= (30 * 60)) or ((not tp_f) and ((utime.time() - tp_c) >= 10)) : # 30分毎に積算電力量要求コマンド送信（受信出来ない時のコマンド再送信は10秒開ける） | |
| command = bytes('SKSENDTO 1 {0} 0E1A 1 {1:04X} '.format(ipv6Addr, len(GET_TOTAL_POWER_30)), 'utf-8') | |
| bp35a1.write(command) | |
| bp35a1.write(GET_TOTAL_POWER_30) | |
| print('>> [GET_TOTAL_POWER_30] cmd send') | |
| tp_c = utime.time() | |
| tp_f = False | |
| utime.sleep(0.5) | |
| elif (utime.time() - np_c) >= np_interval : # 瞬時電力計測値要求コマンド送信（コマンド頻度が多くなるので、受信できない時のコマンド再送信処理は無し） | |
| command = bytes('SKSENDTO 1 {0} 0E1A 1 {1:04X} '.format(ipv6Addr, len(GET_NOW_P)), 'utf-8') | |
| bp35a1.write(command) | |
| bp35a1.write(GET_NOW_P) | |
| print('>> [GET_NOW_P] cmd send') | |
| np_c = utime.time() | |
| utime.sleep(0.5) | |
| if not u.instant_power[1] == '' : | |
| if (utime.time() - u.instant_power[1]) >= TIMEOUT : # スマートメーターから瞬時電力計測値の応答が一定時間無い場合は電力値表示のみオフ | |
| data_mute = True | |
| draw_w() | |
| if (utime.time() - u.instant_power[1]) >= (TIMEOUT * 4) : # スマートメーターから瞬時電力計測値の応答が一定時間無い場合（TIMEOUTの4倍）はスマートメーターとの通信異常としてリブートする | |
| print('>> Communication failure?? Reboot!!') | |
| machine.reset() | |
| utime.sleep(0.1) | |
| gc.collect() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment