Pr:部品(Parts) Sf:ソフトウェア(Software) Pw:発電装置(PowerGeneration) Md:模型(Model) Ms:計測器(Measuring) Tl:工具(Tools) Ad:オーディオ(Audio) Ec:電子回路(ElectronicCircuit) Cr:車(Car) Ot:その他(Others)  膠原病経験(collagen disease) HobbyLab(About HobbyLab) 履歴(りれき)

1.概要
 (1)目的
2.I/Oの変数
 (1)MODBUS
 (2)GPIO
 (3)I²C
3.MySQLの変数
 (1)概要
 (2)データベース内容
4.１分周期実行方法
 (1)概要
5.メインプログラムの概要
 (1)メインルーチン
 (2)サブルーチン一覧
6.サブルーチン内容
 (1)RaspberryPi I/O
 (1-1)init()
 (1-2)RxIo()
 (2)MODBUS
 (2-1)CrcGen()
 (2-2)class UART:共通
 (2-21)__init__
 (2-22)mb_rx() スレーブ受信
 (2-23)mb_rxrs() ｽﾚｰﾌﾞﾘｾｯﾄ受信
 (2-24)mb_tx() マスター送信
 (2-3)class UART:充電器
 (2-31)RBZ60A_rx() 情報取得
 (2-32)RBZ60A_reset_now()
 (2-33)RBZ60A_reset_all()
 (2-4)class UART:測定器
 (2-41)PZEM017c_rx()
 (2-42)PZEM017i_rx()
 (2-43)PZEM_reset()
 (2-5)class UART:負荷電力計
 (2-51)AC301_rx()
 (2-52)AC301_reset()
 (3)MySQL
 (3-1)1分更新DB
 (3-11)db_re 読込
 (3-12)db_in 追加
 (3-13)db_up 修正
 (3-14)db_de 削除
 (3-2)10分更新DB
 (3-21)db_m_re 読込
 (3-22)db_m_in 追加
 (3-23)db_m_up 修正
 (3-24)db_m_de 削除
 (3-3)1日更新DB
 (3-31)db_d_re 読込
 (3-32)db_d_in 追加
 (3-33)db_d_up 修正
 (3-34)db_d_de 削除
 (4)db_prs()

---

Pw:Monitor 太陽光監視

PwMn:太陽光モニター

PwMn:全般

PwMn:ハード

　システム図
　ラズパイ周辺回路

PwMn:プログラム

　Local1分周期プログラム
　Local状態表示プログラム
　遠隔情報伝送プログラム
　遠隔状態表示プログラム

Pw:Solar 太陽光関係

PwS:装置

前置き

ソーラパネル

　ソーラーパネル
　ｿｰﾗｰﾊﾟﾈﾙ用ｻｰｷｯﾄﾌﾞﾚｰｶ

充電器

　充電器
　充電器用ｻｰｷｯﾄﾌﾞﾚｰｶ
　充電器用電流計

蓄電池

　蓄電池用ｻｰｷｯﾄﾌﾞﾚｰｶ
　蓄電池用電流計
　蓄電池

インバータ

　ｲﾝﾊﾞｰﾀ用ｻｰｷｯﾄﾌﾞﾚｰｶ
　ｲﾝﾊﾞｰﾀ用電流計
　インバータ

電力量計

電源切替器

配線

収納箱

PwS:保守

　パネルを洗う

PwS:旧品

　旧充電器
　旧充電器(ModBus)

Pw:MicroHydro 関係

PwMh:装置

前置き

①水車　①発電機

②速度調整装置

③抵抗器

⑤力率改善装置

Pw:Exciter 励磁器関係

PwEx:装置

　前置き
　自動電圧調整器概要1
　自動電圧調整器概要2
　ハードウェアー
　発電試験装置の製作試験
　サイリスタ制御他
　部品表

PwEx:プログラム

　プログラミング（準備）
　プログラミング（詳細）
　プログラム(ソース)

1.概要

 (1)目的

情報取得用ModBus関係のMppt充電器の取替えや直流電流、電圧検出の追加に伴いプログラムを見直しました。 このプログラムは太陽光発電装置の状態を取得して、データベースに記録するプログラムです。 このプログラムの周期は１分周期で実行されます。 この他に１分周期で実行するプログラムはインターネット上のレンタルサーバーへ情報を伝送するプログラムが有ります。 別のプログラムにしたのは、共に動作しなくなる事を防ぐためです。

---

2.I/Oの変数

 (1)Modbus

ModBusの共通情報 シリアル通信の使用方法 ModBusを使用しているものは２つ有り a.充電器　DeviceAddress=0x01 FunctionNo=0x04 ・太陽光パネルの発電出力とバッテリー入力の間に設置している充電器の各情報 　充電器ModBusデータ 新用途名 アドレス 変数名 倍率 単位 データ型 長さ・値 旧用途名 ステータス 0x0003 fg1->cstts --- -- binary 2 フラグ１ 太陽光パネル電圧 0x000B pvv->cpvv 0.1 V decimal 4,1 太陽光パネル電圧 母線電圧 0x000C bsv->cbsv 0.1 V decimal 4,1 母線電圧 出力電流 0x000D opc->copc 0.1 A decimal 4,1 出力電流 蓄電池電圧 0x000E xx2->cbtv 0.1 ->V decimal 5,1->4,1 不明２ DC Load電流 0x000F ot1->cldc 1->0.1 ℃->A decimal 3,0->4,1 屋外温度 装置温度 0x0010 ut1->cut1 1 ℃ decimal 3,0 装置温度 総発電量 0x0012,13 opw->calwh 0.1->0.001 W->kW decimal 5,1->7,3 出力有効電力 今日の発電量 0x0014,15 xx1->ctowh 0.1->0.001 ->kW decimal 5,1->7,3 不明１ xx3 0.1 decimal 5,1 不明３ -- -- fg2 --- -- binary 2 フラグ２ ステータス 0x0003 用途 bit 変数名 備考 内部温度が高すぎる b0000 0000 0000 0001 $scstts_itr 障害 バッテリーの温度が高すぎる b0000 0000 0000 0010 $scstts_btr 障害 DC出力過電流 b0000 0000 0000 0100 $scstts_dcco 障害 PV過電圧 b0000 0000 0000 1000 $scstts_svo 故障 PV電圧が低すぎる b0000 0000 0001 0000 $scstts_svl 障害 充電電圧が高すぎる b0000 0000 0010 0000 $scstts_cvth 故障 急速充電 b0000 0000 0100 0000 $scstts_fsc 状変変化 均等化 b0000 0000 1000 0000 $scstts_eqc 状態変化 フロートチャージ b0000 0001 0000 0000 $scstts_flc 状態変化 最大追跡力 b0000 0010 0000 0000 $scstts_mppt 状態変化 1-DC出力オン、0-オフ b0001 0000 0000 0000 $scstts_dc 状態変化 1-充電オン 0-充電オフ b0010 0000 0000 0000 $scstts_ch 状態変化 待機する b1000 0000 0000 0000 $scstts_sb b.電力計　DeviceAddress=0x02 FunctionNo=0x03 ・太陽光発電装置に接続している交流電源の電力計 　電力計ModBusデータ 用途名 アドレス 変数名 倍率 単位 データ型 長さ・値 負荷電圧 0x000E ldv 0.1 V decimal 4,1 負荷電流 0x000F ldc 0.001 A decimal 5,3 負荷有効電力 0x0011 ldw 0.1 W decimal 5,1 負荷電力量 0x0017 ldwh 0.001 kWh decimal 5,3 動作時間 0x0019 opt->ldt 1 分 decimal 5,0 室温 0x001A ut2->ldlmt 1 ℃ decimal 3,0 負荷力率 0x001D pf1->ldpf 1 % decimal 3,0 周波数 0x001E f1->ldf 0.1 Hz decimal 4,1 c.電流・電圧検出器(充電器)　DeviceAddress=0x12 FunctionNo=0x04 ・充電器出力、インバータ入力の直流電流・電圧の検出 　pzem-017 Modbusデータ 用途名 アドレス 変数名 倍率 単位 データ型 長さ・値 母線電圧2 0x0000 pbsv2 0.01 V decimal 4,2 充電器出力電流 0x0001 pcopc 0.01 A decimal 5,2 充電器出力電力 0x0002,3 pcopw 0.1 W decimal 7,1 充電器出力電力量 0x0004,5 pcopwh 1 Wh decimal 7,0 d.電流・電圧検出器(インバータ)　DeviceAddress=0x13 FunctionNo=0x04 ・充電器出力、インバータ入力の直流電流・電圧の検出 　pzem-017 Modbusデータ 用途名 アドレス 変数名 倍率 単位 データ型 長さ・値 母線電圧3 0x0000 pbsv3 0.01 V decimal 4,2 インバータ入力電流 0x0001 pivinc 0.01 A decimal 5,2 インバータ入力電力 0x0002,3 pivinw 0.1 W decimal 7,1 インバータ入力電力量 0x0004,5 pivinwh 1 Wh decimal 7,0

 (2)GPIO

電力の切り替え信号を取得して ・電源切替器の状態をMySQLへ記録します。※ ・交流電源の電力計の『電力量』、『動作時間』の値を読み込みMysqlに記録、値をリッセットします。 a.母線電圧電流計 ・外部I/Oにより、負荷電源供給箇所判定、インーバータ・電源切替器動作制御。 　GPIOの使用方法 　Ryドライバー(2SC1815)の使用方法 出力:SW=OFFで商用 用途名 個別変数名 状態説明 変数名 データ型 長さ・値 電源供給箇所 fgi_pwl 入力:R=L(Ω):V=H(V)で商用 fgi binary 1 電源供給切り替え fgo_pwsw fgo binary 1 インバータ電源 fgo_invsw 出力:SW=OFFで電源切り fgo binary 1

 (3)I²C

a.蓄電池電圧電流計 ・シャントCTによる蓄電池の電流測定と電圧を測定します。 　I2C使用方法 　INA226 用途名 変数名 倍率 単位 データ型 長さ・値 蓄電池電圧 btv 1 V decimal 5,3 蓄電池電流 btc 1 A decimal 5,3 b.非接触直流電流計 ・非接触直流CTを使用し蓄電池の直流電流を測定する。 　非接触直流CT[ホール素子WCS] 　増幅回路[オペアンプ全般] 　I2C使用方法 　16bit A/D[ADS1115] 用途名 変数名 倍率 単位 データ型 長さ・値 蓄電池１電流 bt1c 1 A decimal 4,2 蓄電池２電流 bt2c 1 A decimal 4,2 c.温度計 ・1-Wireによる蓄電池の温度測定。 　温度センサー 1-Wire[DS18B20] 　使用方法 用途名 変数名 倍率 単位 データ型 長さ・値 蓄電池１温度 bt1t 1 ℃ decimal 3,0 蓄電池２温度 bt2t 1 ℃ decimal 3,0 インバータ温度 ivt 1 ℃ decimal 3,0 d.湿度、気圧計 ・湿度、気圧計 　温度センサー 1-Wire[DS18B20] 　使用方法 用途名 変数名 倍率 単位 データ型 長さ・値 温度 tmp 1 ℃ decimal 3,0 湿度 hum 1 % decimal 3,0 気圧 prs 1 hpa decimal 4,0 e.照度計 ・照度計 　温度センサー 1-Wire[DS18B20] 　使用方法 用途名 変数名 倍率 単位 データ型 長さ・値 照度 lx1 1 lx decimal 5,0

---

3.MySQLの変数

 (1)概要

MySQLでは太陽光発電に伴う記録を蓄積し、表示器へそのデータを渡すために使用する。 現在は太陽光発電の状態表示用としてのデータの受け渡しをしている。 記録の周期は現在は1分としているが、出来だけ早い変化を確認したいので10秒程度にならないか確認をしていく。 将来的には、各報告（日報・月報・年報）を行う。 データベース名:sumstm

 (2)データベース内容

テーブル 　テーブル名:　1mincycl 　カラム数:　　45

4.１分周期実行方法

 (1)概要

時間周期的にプログラム実行する場合は cron と言う デーモンを使用する。 crontab ファイルに1分ごとに実行するプログラムのコマンドを記述する。 * * * * * /usr/bin/python3 /home/hobbylab/www/scpt/Local1MinuteCycleProgram.py hobbylab@raspberrypi:~ $ crontab -e GNU nano 5.4　　　　　　　　　　　　/tmp/crontab.fBBlyh/crontab # Edit this file to introduce tasks to be run by cron. # # Each task to run has to be defined through a single line # indicating with different fields when the task will be run # and what command to run for the task # # To define the time you can provide concrete values for # minute (m), hour (h), day of month (dom), month (mon), # and day of week (dow) or use '*' in these fields (for 'any'). # # Notice that tasks will be started based on the cron's system # daemon's notion of time and timezones. # # Output of the crontab jobs (including errors) is sent through # email to the user the crontab file belongs to (unless redirected). # # For example, you can run a backup of all your user accounts # at 5 a.m every week with: # 0 5 * * 1 tar -zcf /var/backups/home.tgz /home/ # # For more information see the manual pages of crontab(5) and cron(8) # # m h dom mon dow command * * * * * /usr/bin/python3 /home/hobbylab/www/scpt/Local1MinuteCycleProgram.py ^G ^X Help Exit ^O ^R Write Out Read File ^W ^\ Where Is Replace ^K ^U Cut Paste ^T ^J Execute Justify ^C ^_ Location Go To Line M-U M-E Undo Redo 記載後、コントロール＋Oで書き込み、コントール＋Xでエディタを終了する。

---

5.メインプログラムの概要

　(1)メインルーチン

if __name__ == '__main__': init() db_re() RxIo() uart = UART() RBZ60A_rx() PZEM017c_rx() PZEM017i_rx() AC301_rx() db_prs() uart.uartport.close()

プログラムはPythonを使用します。

　(2)サブルーチン一覧

関係 サブルーチン名 No 概要 I/O init() (1-1) RaspberryPi I/Oの初期化 RxIo() (1-2) 電源切替器の状態取得 MODBUS CrcGen() (2-1) MODBUS crc生成 class 　UART __init__() (2-21) RaspberryPiのMODBUS接続用シリアル通信の初期化 mb_rx() (2-22) スレーブデータ取得 mb_rxrs() (2-23) Whリセット後のスレーブデータ取得処理 mb_tx() (2-24) マスターからの信号を送信 RBZ60A_rx() (2-31) 充電器情報を取得 RBZ60A_reset_now() (2-32) 充電器今日の電力量リセット RBZ60A_reset_all() (2-33) 充電器総合電力量リセット PZEM017c_rx() (2-41) 母線情報を取得 PZEM017i_rx() (2-42) インバータ入力情報を取得 PZEM_reset() (2-43) 母線及びインバータ入力電力量リセット AC301_rx() (2-51) 負荷の電力情報を取得 AC301_reset() (2-52) 負荷の電力量のリセット MySQL db_re() (3-11) 1分毎DBの最新情報取得 db_in() (3-12) 1分毎DBへ情報追加 db_up() (3-13) 1分毎DBへ情報更新 db_de() (3-14) 1分毎DBの情報削除 db_m_re() (3-21) 10分毎DBの最新情報取得 db_m_in() (3-22) 10分毎DBへ情報追加 db_m_up() (3-23) 10分毎DBへ情報更新 db_m_de() (3-24) 10分毎DBの情報削除 db_d_re() (3-31) 1日毎DBの最新情報取得 db_d_in() (3-32) 1日毎DBへ情報追加 db_d_up() (3-33) 1日毎DBへ情報更新 db_d_de() (3-34) 1日毎DBの情報削除 all db_prs() (4) 時間処理

---

6.サブルーチン内容

　(1)RaspberryPi I/O

RaspberryPi I/O関係のサブルーチンです。

　(1-1)init()

def init(): #インターフェースの初期化 global pwsw_pin GPIO.setmode(GPIO.BCM) iov=GPIO.setup(pwsw_pin,GPIO.IN,pull_up_down=GPIO.PUD_UP)

　(1-2)RxIo()

def RxIo(): #インターフェースの状態記録 この前に MysqlReceive()で前の状態を取得すること #pwsw,fgi_pwl 0=#太陽光 1=#商用 global fgi,pwsw_pin,FgChang,fg_pwl GPIO.setmode(GPIO.BCM) pwsw=GPIO.input(pwsw_pin) fg_pwl = fgi & 0x01 FgChang = (fg_pwl ^ pwsw) if pwsw ==0: fgi = fgi & 0xFE else: fgi = fgi | 0x01

　(2)MODBUS

MODBUS関係のサブルーチンです。

　(2-1)CrcGen()

def CrcGen(FrameArray): #ModBus CRC生成 crc = 0xFFFF for FeameCell in FrameArray : crc = crc ^ FeameCell ShiftV = 0 while(ShiftV < 8): if crc & 0x0001 : crc = crc >> 1 crc = crc ^ 0xA001 else: crc = crc >> 1 ShiftV += 1 CrcGenArray = [0x00,0x00] CrcGenArray[1] = crc >> 8 CrcGenArray[0] = crc & 0x00FF return CrcGenArray

　(2-2)class UART:共通

class UART:共通関係のサブルーチンです。

　(2-21)__init__()

timeout=2は .read() 及び .readline()に入って2秒以上受信がなければその関数に値が無くても抜ける。 class UART: def __init__(self): try: self.uartport = serial.Serial( port=SerialComPort, baudrate=SerialCombaud , bytesize=serial.EIGHTBITS, parity=serial.PARITY_NONE, stopbits=serial.STOPBITS_ONE, timeout=2 ) except serial.SerialException: print("Serial_ModBus_Err") print(traceback.format_exc()) self.uartport.close() self.uartport.reset_input_buffer() self.uartport.reset_output_buffer() time.sleep(0.1)

　(2-22)mb_rx()

最初の2byteはマスター信号のオウム返し、3番めがデータの長さを示している。 def mb_rx(self): try: ByFrmDataArray1 = self.uartport.read(2) ByDataLenArray = self.uartport.read(1) DataLen = int.from_bytes(ByDataLenArray,'big') ByFrmDataArray2 = self.uartport.read(DataLen) ByCRC = self.uartport.read(2) except: print("Serial_ModBus_RX_Err") print(traceback.format_exc()) FrmDataArray2 = list(ByFrmDataArray2) FrmDataArray =list(ByFrmDataArray1) FrmDataArray.extend(list(ByDataLenArray )) FrmDataArray.extend(FrmDataArray2) return FrmDataArray2

　(2-23)mb_rxrs()

リセット信号を受信したスレーブ信号は全てがマスターのオウム返しとなるため、mb_rx()が使用できないので、このサブルーチンを設けた。 また、AC301の後にPZEMをリセットした場合、タイムアウトする事が有ったので、この処理(ここではタイムアウトで 1 を返す事にした)を追加した。 def mb_rxrs(self): #リセット Len=0 f1=0 data = self.uartport.readline() # タイムアウトするまで待つ if not data: self.uartport.reset_input_buffer() f1=1 return f1

　(2-24)mb_tx()

def mb_tx(self,FrmDataArray): CrcGenArray =CrcGen(FrmDataArray) FrmDataArray.extend(CrcGenArray) try: self.uartport.write(FrmDataArray) except: print("Serial_ModBus_TX1_Err") print(traceback.format_exc())

　(2-3)class UART:充電器

class UART:充電器関係のサブルーチンです。

　(2-31)RBZ60A_rx()

def RBZ60A_rx(): #蓄電池充電器情報 RBZ60Aは最大転送量0x14 global cstts,cpvv,cbsv,copc,cbtv,cldc,cut1,calwh,ctowh uart.mb_tx([0x01,0x03,0x00,0x03,0x00,0x13]) FrmDataArray2=uart.mb_rx() cstts=FrmDataArray2[0]*256+FrmDataArray2[1] cpvv=(FrmDataArray2[16]*256+FrmDataArray2[17])/10 cbsv=(FrmDataArray2[18]*256+FrmDataArray2[19])/10 copc=(FrmDataArray2[20]*256+FrmDataArray2[21])/10 cbtv=(FrmDataArray2[22]*256+FrmDataArray2[23])/10 cldc=(FrmDataArray2[24]*256+FrmDataArray2[25])/10 cut1=(FrmDataArray2[26]*256+FrmDataArray2[27]) calwh=(FrmDataArray2[30]*16777216+FrmDataArray2[31]*65536+FrmDataArray2[32]*256+FrmDataArray2[33])/1000 ctowh=(FrmDataArray2[34]*16777216+FrmDataArray2[35]*65536+FrmDataArray2[36]*256+FrmDataArray2[37])/1000 time.sleep(0.1)

　(2-32)RBZ60A_reset_now()

リセットの動作は出来ない。※ただし自動的に1日1回リセットされる。 def RBZ60A_reset_now(): uart.mb_tx([0x1,0x06,0x00,0x2,0xaa,0x55]) uart.mb_rxrs() time.sleep(0.2)

　(2-33)RBZ60A_reset_all()

def RBZ60A_reset_all(): #RBZ60A 総電力量のリセット uart.mb_tx([0x1,0x06,0x00,0x3,0xaa,0x55]) uart.mb_rxrs() time.sleep(0.2)

　(2-4)class UART:測定器

class UART:測定器関係のサブルーチンです。

　(2-41)PZEM017c_rx()

def PZEM017c_rx(): #蓄電池充電器出力情報 global pbsv2,pcopc,pcopw,pcopwh uart.mb_tx([0x12,0x04,0x00,0x00,0x00,0x06]) FrmDataArray2=uart.mb_rx() pbsv2=(FrmDataArray2[0]*256+FrmDataArray2[1])/100 pcopc=(FrmDataArray2[2]*256+FrmDataArray2[3])/100 pcopw=(FrmDataArray2[6]*16777216+FrmDataArray2[7]*65536+FrmDataArray2[4]*256+FrmDataArray2[5])/10 pcopwh=(FrmDataArray2[10]*16777216+FrmDataArray2[11]*65536+FrmDataArray2[8]*256+FrmDataArray2[9])/1000 time.sleep(0.1)

　(2-42)PZEM017i_rx()

def PZEM017i_rx(): global pbsv3,pivinc,pivinw,pivinwh #インバータ入力情報 uart.mb_tx([0x11,0x04,0x00,0x00,0x00,0x06]) FrmDataArray2=uart.mb_rx() pbsv3=(FrmDataArray2[0]*256+FrmDataArray2[1])/100 pivinc=(FrmDataArray2[2]*256+FrmDataArray2[3])/100 pivinw=(FrmDataArray2[6]*16777216+FrmDataArray2[7]*65536+FrmDataArray2[4]*256+FrmDataArray2[5])/10 pivinwh=(FrmDataArray2[10]*16777216+FrmDataArray2[11]*65536+FrmDataArray2[8]*256+FrmDataArray2[9])/1000 time.sleep(0.1)

2回もタイムアウトが出れば、errfile.log に記録する。

　(2-43)PZEM_reset()

def PZEM_reset(): msg="" uart.mb_tx([0x11,0x42]) #PZEM_017c rf = uart.mb_rxrs() if rf : msg = msg + "0x11 time_OUT " uart.mb_tx([0x11,0x42]) #PZEM_017c rf = uart.mb_rxrs() if rf : msg = msg + "0x11 2time_OUT " uart.mb_tx([0x12,0x42]) #PZEM_017i rf = uart.mb_rxrs() if rf : msg = msg + "0x12 time_OUT " uart.mb_tx([0x12,0x42]) #PZEM_017c rf = uart.mb_rxrs() if rf : msg = msg + "0x12 2time_OUT" if msg != "": dt = datetime.datetime.now() today = dt.strftime('%Y/%m/%d %H:%M:%S') msg = today + " MODBUS Err " + msg # print("err:",msg) with open('errfile.log', 'a') as f: print(msg, file=f)

　(2-5)class UART:負荷電力計

class UART:負荷電力計関係のサブルーチンです。

　(2-51)AC301_rx()

def AC301_rx(): #電力量計情報 global FgChang,ldv,ldc,ldw,ldwh,ldcowh,ldsuwh,ldt,ldcot,ldsut,ldlmt,ldpf,ldf,fgi,fg_pwl,ac301wh,wh301 uart.mb_tx([0x02,0x03,0x00,0x0e,0x00,0x11]) FrmDataArray2=uart.mb_rx() ldv =(FrmDataArray2[0] *256+FrmDataArray2[1])/10 ldc =(FrmDataArray2[2] *256+FrmDataArray2[3])/1000 ldw =(FrmDataArray2[6] *256+FrmDataArray2[7])/10 wh301 =(FrmDataArray2[18]*256+FrmDataArray2[19])/1000 ldwh = round(wh301 - float(ac301wh),3) #AC301 LDWH resetNG #ldt =(FrmDataArray2[22]*256+FrmDataArray2[23]) #reset NGのためロック ldlmt=FrmDataArray2[24]*256+FrmDataArray2[25] ldpf =FrmDataArray2[30]*256+FrmDataArray2[31] ldf =(FrmDataArray2[32]*256+FrmDataArray2[33])/10 if FgChang == True: AC301_reset() #print("電力計リセット処理") time.sleep(0.1)

　(2-52)AC301_reset()

AC301のリセットが出来ないため、ロックしてソフトで対応することにした。 def AC301_reset(): global fg_pwl,ldwh,ldt,ldcowh,ldcot,ldsuwh,ldsut,ac301wh,wh301 #リセット前に現在の電源供給状態によるデータ加算 if fg_pwl == True: #商用の場合 wh = float(ldcowh) ldcowh = round(wh + float(ldwh),3) ldcot = ldcot+ ldt else: #太陽光の場合 wh = float(ldsuwh) ldsuwh = round(wh + float(ldwh),3) ldsut = ldsut+ ldt # uart.mb_tx([0x02,0x10,0x01,0x54,0x00,0x02,0x04,0x00,0x00,0x00,0x00]) #LoWh # rf = uart.mb_rxrs() # if rf : # uart.mb_tx([0x02,0x10,0x01,0x54,0x00,0x02,0x04,0x00,0x00,0x00,0x00]) # rf = uart.mb_rxrs() # if rf : # print("AC301_0x54 2time_OUT") # uart.mb_tx([0x02,0x10,0x01,0x56,0x00,0x02,0x04,0x00,0x00,0x00,0x00]) #HiWh # rf = uart.mb_rxrs() # if rf : # uart.mb_tx([0x02,0x10,0x01,0x56,0x00,0x02,0x04,0x00,0x00,0x00,0x00]) # rf = uart.mb_rxrs() # if rf : # print("AC301_0x56 2time_OUT") #uart.mb_tx([0x02,0x10,0x01,0x58,0x00,0x01,0x02,0x00,0x00]) #time #uart.mb_rxrs() # uart.mb_tx([0x02,0x03,0x00,0x17,0x00,0x02]) # FrmDataArray2=uart.mb_rx() # wh301 =(FrmDataArray2[0]*256+FrmDataArray2[1])/1000 ac301wh = wh301 ldwh =0 ldt =0

　(3)MySQL

MySQL関係のサブルーチンです。

　(3-1)1分更新DB

1分更新DB関係のサブルーチンです。

　(3-11)db_re()

def db_re(): global sum_id,sum_dtime,cstts,cpvv,cbsv,copc,cbtv,cldc,cut1,calwh,ctowh,ldv,ldc,ldw,ldwh,ldcowh,ldsuwh,ldt,ldcot,ldsut,ldlmt,ldpf,ldf,pbsv2,pcopc,pcopw,pcopwh,pbsv3,pivinc,pivinw,pivinwh,fgi,fgo,btv,btc,bt1c,bt2c,bt1t,bt2t,ivt,tmp,hum,prs,lx1,ri1,ac301wh,HostAddress,UserName,UsPssword,DBName,TBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: sql="SELECT * FROM "+TBName+" ORDER BY sum_id DESC LIMIT 1" cursor.execute(sql) recd = cursor.fetchone() if not recd: # print("テーブルが無いので追加します") with connection.cursor() as cursor: sql =f"INSERT INTO `{TBName}` (`sum_id`, `sum_dtime`, `cstts`, `cpvv`, `cbsv`, `copc`, `cbtv`, `cldc`, `cut1`, `calwh`, `ctowh`, `ldv`, `ldc`, `ldw`, `ldwh`, `ldcowh`, `ldsuwh`, `ldt`, `ldcot`, `ldsut`, `ldlmt`, `ldpf`, `ldf`, `pbsv2`, `pcopc`, `pcopw`, `pcopwh`, `pbsv3`, `pivinc`, `pivinw`, `pivinwh`, `fgi`, `fgo`, `btv`, `btc`, `bt1c`, `bt2c`, `bt1t`, `bt2t`, `ivt`, `tmp`, `hum`, `prs`, `lx1`, `ri1`, `ac301wh`) VALUES (NULL, current_timestamp(),{cstts},'{cpvv}','{cbsv}','{copc}','{cbtv}','{cldc}','{cut1}','{calwh}','{ctowh}','{ldv}','{ldc}','{ldw}','{ldwh}','{ldcowh}','{ldsuwh}','{ldt}','{ldcot}','{ldsut}','{ldlmt}','{ldpf}','{ldf}','{pbsv2}','{pcopc}','{pcopw}','{pcopwh}','{pbsv3}','{pivinc}','{pivinw}','{pivinwh}',{fgi},{fgo},'{btv}','{btc}','{bt1c}','{bt2c}','{bt1t}','{bt2t}','{ivt}','{tmp}','{hum}','{prs}','{lx1}','{ri1}','{ac301wh});" cursor.execute(sql) # print("1mincyclを追加しました。") connection.commit() else: #取得したレコードデータからフィールド値を各変数へ入力する。 fields =list(recd.values()) sum_id,sum_dtime,cstts,cpvv,cbsv,copc,cbtv,cldc,cut1,calwh,ctowh,ldv,ldc,ldw,ldwh,ldcowh,ldsuwh,ldt,ldcot,ldsut,ldlmt,ldpf,ldf,pbsv2,pcopc,pcopw,pcopwh,pbsv3,pivinc,pivinw,pivinwh,fgi,fgo,btv,btc,bt1c,bt2c,bt1t,bt2t,ivt,tmp,hum,prs,lx1,ri1,ac301wh, = fields cstts=int.from_bytes(cstts,'big') fgi=int.from_bytes(fgi,'big') fgo=int.from_bytes(fgo,'big') ldt=ldt + 1 # print("1mincyclのデータを取得しました、")

　(3-12)db_in()

def db_in(): global sum_id,sum_dtime,cstts,cpvv,cbsv,copc,cbtv,cldc,cut1,calwh,ctowh,ldv,ldc,ldw,ldwh,ldcowh,ldsuwh,ldt,ldcot,ldsut,ldlmt,ldpf,ldf,pbsv2,pcopc,pcopw,pcopwh,pbsv3,pivinc,pivinw,pivinwh,fgi,fgo,btv,btc,bt1c,bt2c,bt1t,bt2t,ivt,tmp,hum,prs,lx1,ri1,ac301wh,HostAddress,UserName,UsPssword,DBName,TBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: sql =f"INSERT INTO `{TBName}` (`sum_id`, `sum_dtime`, `cstts`, `cpvv`, `cbsv`, `copc`, `cbtv`, `cldc`, `cut1`, `calwh`, `ctowh`, `ldv`, `ldc`, `ldw`, `ldwh`, `ldcowh`, `ldsuwh`, `ldt`, `ldcot`, `ldsut`, `ldlmt`, `ldpf`, `ldf`, `pbsv2`, `pcopc`, `pcopw`, `pcopwh`, `pbsv3`, `pivinc`, `pivinw`, `pivinwh`, `fgi`, `fgo`, `btv`, `btc`, `bt1c`, `bt2c`, `bt1t`, `bt2t`, `ivt`, `tmp`, `hum`, `prs`, `lx1`, `ri1`, `ac301wh`) VALUES (NULL, current_timestamp(),{cstts},'{cpvv}','{cbsv}','{copc}','{cbtv}','{cldc}','{cut1}','{calwh}','{ctowh}','{ldv}','{ldc}','{ldw}','{ldwh}','{ldcowh}','{ldsuwh}','{ldt}','{ldcot}','{ldsut}','{ldlmt}','{ldpf}','{ldf}','{pbsv2}','{pcopc}','{pcopw}','{pcopwh}','{pbsv3}','{pivinc}','{pivinw}','{pivinwh}',{fgi},{fgo},'{btv}','{btc}','{bt1c}','{bt2c}','{bt1t}','{bt2t}','{ivt}','{tmp}','{hum}','{prs}','{lx1}','{ri1}','{ac301wh}');" cursor.execute(sql) # print("1mincyclを追加しました。") connection.commit()

　(3-13)db_up()

def db_up(): global sum_id,sum_dtime,cstts,cpvv,cbsv,copc,cbtv,cldc,cut1,calwh,ctowh,ldv,ldc,ldw,ldwh,ldcowh,ldsuwh,ldt,ldcot,ldsut,ldlmt,ldpf,ldf,pbsv2,pcopc,pcopw,pcopwh,pbsv3,pivinc,pivinw,pivinwh,fgi,fgo,btv,btc,bt1c,bt2c,bt1t,bt2t,ivt,tmp,hum,prs,lx1,ri1,ac301wh,HostAddress,UserName,UsPssword,DBName,TBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: # sum_id='{sum_id}' sum_id DESC LIMIT 1 sql =f"UPDATE `{TBName}` SET sum_dtime=current_timestamp(),cstts={cstts}, cpvv='{cpvv}',cbsv='{cbsv}',copc='{copc}',cbtv='{cbtv}',cldc='{cldc}',cut1='{cut1}',calwh='{calwh}',ctowh='{ctowh}',ldv='{ldv}',ldc='{ldc}',ldw='{ldw}',ldwh='{ldwh}',ldcowh='{ldcowh}',ldsuwh='{ldsuwh}',ldt='{ldt}',ldcot='{ldcot}',ldsut='{ldsut}',ldlmt='{ldlmt}',ldpf='{ldpf}',ldf='{ldf}',pbsv2='{pbsv2}',pcopc='{pcopc}',pcopw='{pcopw}',pcopwh='{pcopwh}',pbsv3='{pbsv3}',pivinc='{pivinc}',pivinw='{pivinw}',pivinwh='{pivinwh}',fgi={fgi},fgo={fgo},btv='{btv}',btc='{btc}',bt1c='{bt1c}',bt2c='{bt2c}',bt1t='{bt1t}',bt2t='{bt2t}',ivt='{ivt}',tmp='{tmp}',hum='{hum}',prs='{prs}',lx1='{lx1}',ri1='{ri1}',ac301wh='{ac301wh}' WHERE sum_id='{sum_id}';" cursor.execute(sql) # print("daycyclを修正しました。") connection.commit()

　(3-14)db_de()

def db_de(): global sum_id,sum_dtime,cstts,cpvv,cbsv,copc,cbtv,cldc,cut1,calwh,ctowh,ldv,ldc,ldw,ldwh,ldcowh,ldsuwh,ldt,ldcot,ldsut,ldlmt,ldpf,ldf,pbsv2,pcopc,pcopw,pcopwh,pbsv3,pivinc,pivinw,pivinwh,fgi,fgo,btv,btc,bt1c,bt2c,bt1t,bt2t,ivt,tmp,hum,prs,lx1,ri1,ac301wh,HostAddress,UserName,UsPssword,DBName,TBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: #全レコード削除 sql="TRUNCATE TABLE `"+TBName+"`;" #"DELETE FROM `1mincycl`;"+"ALTER TABLE `1mincycl` AUTO_INCREMENT = 1" cursor.execute(sql) # print("1mincyclを削除しました。") with connection.cursor() as cursor: sql =f"INSERT INTO `{TBName}` (`sum_id`, `sum_dtime`, `cstts`, `cpvv`, `cbsv`, `copc`, `cbtv`, `cldc`, `cut1`, `calwh`, `ctowh`, `ldv`, `ldc`, `ldw`, `ldwh`, `ldcowh`, `ldsuwh`, `ldt`, `ldcot`, `ldsut`, `ldlmt`, `ldpf`, `ldf`, `pbsv2`, `pcopc`, `pcopw`, `pcopwh`, `pbsv3`, `pivinc`, `pivinw`, `pivinwh`, `fgi`, `fgo`, `btv`, `btc`, `bt1c`, `bt2c`, `bt1t`, `bt2t`, `ivt`, `tmp`, `hum`, `prs`, `lx1`, `ri1`, `ac301wh`) VALUES (NULL, current_timestamp(),{cstts},'{cpvv}','{cbsv}','{copc}','{cbtv}','{cldc}','{cut1}','{calwh}','{ctowh}','{ldv}','{ldc}','{ldw}','{ldwh}','{ldcowh}','{ldsuwh}','{ldt}','{ldcot}','{ldsut}','{ldlmt}','{ldpf}','{ldf}','{pbsv2}','{pcopc}','{pcopw}','{pcopwh}','{pbsv3}','{pivinc}','{pivinw}','{pivinwh}',{fgi},{fgo},'{btv}','{btc}','{bt1c}','{bt2c}','{bt1t}','{bt2t}','{ivt}','{tmp}','{hum}','{prs}','{lx1}','{ri1}','{ac301wh}');" cursor.execute(sql) # print("1mincyclを追加しました。") connection.commit()

　(3-2)10分更新DB

10分更新DB関係のサブルーチンです。

　(3-21)db_m_re()

def db_m_re(): global msum_id,msum_dtime,cpvv,ldv,ldc,pbsv2,pcopc,pbsv3,pivinc,fgi,fgo,HostAddress,UserName,UsPssword,DBName,mTBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: sql="SELECT * FROM "+mTBName+" ORDER BY msum_id DESC LIMIT 1" cursor.execute(sql) recd = cursor.fetchone() if not recd: # print("テーブルが無いので追加します") with connection.cursor() as cursor: sql =f"INSERT INTO `{mTBName}` (`msum_id`, `msum_dtime`, `cpvv`, `ldv`, `ldc`, `pbsv2`, `pcopc`, `pbsv3`, `pivinc`,`fgi`,`fgo`) VALUES (NULL, current_timestamp(), '{cpvv}','{ldv}','{ldc}','{pbsv2}','{pcopc}','{pbsv3}','{pivinc}',{fgi},{fgo});" cursor.execute(sql) # print("mcyclを追加しました。") connection.commit() else: # 取得したレコードデータからフィールド値を各変数へ入力する。 fields =list(recd.values()) msum_id,msum_dtime,cpvv,ldv,ldc,pbsv2,pcopc,pbsv3,pivinc,fgi,fgo = fields fgi=int.from_bytes(fgi,'big') fgo=int.from_bytes(fgo,'big') # print("mcyclのデータを取得しました、")

　(3-22)db_m_in()

def db_m_in(): global msum_id,msum_dtime,cpvv,ldv,ldc,pbsv2,pcopc,pbsv3,pivinc,fgi,fgo,HostAddress,UserName,UsPssword,DBName,mTBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: sql =f"INSERT INTO `{mTBName}` (`msum_id`, `msum_dtime`, `cpvv`, `ldv`, `ldc`, `pbsv2`, `pcopc`, `pbsv3`, `pivinc`,`fgi`,`fgo`) VALUES (NULL, current_timestamp(), '{cpvv}','{ldv}','{ldc}','{pbsv2}','{pcopc}','{pbsv3}','{pivinc}',{fgi},{fgo});" cursor.execute(sql) # print("mcyclを追加しました。") connection.commit()

　(3-23)db_m_up()

def db_m_up(): global msum_id,msum_dtime,cpvv,ldv,ldc,pbsv2,pcopc,pbsv3,pivinc,fgi,fgo,HostAddress,UserName,UsPssword,DBName,mTBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: sql =f"UPDATE `{mTBName}` SET msum_dtime=current_timestamp(),cpvv='{cpvv}',ldv='{ldv}',ldc='{ldc}',pbsv2='{pbsv2}',pcopc='{pcopc}',pbsv3='{pbsv3}',pivinc='{pivinc}',fgi={fgi},fgo={fgo} WHERE msum_id='{msum_id}';" cursor.execute(sql) # print("mcyclを修正しました。") connection.commit()

　(3-24)db_m_de()

def db_m_de(): global msum_id,msum_dtime,cpvv,ldv,ldc,pbsv2,pcopc,pbsv3,pivinc,fgi,fgo,HostAddress,UserName,UsPssword,DBName,mTBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: #全レコード削除 sql="TRUNCATE TABLE `"+mTBName+"`;" cursor.execute(sql) # print("mcyclを削除しました。") with connection.cursor() as cursor: sql =f"INSERT INTO `{mTBName}` (`msum_id`, `msum_dtime`, `cpvv`, `ldv`, `ldc`, `pbsv2`, `pcopc`, `pbsv3`, `pivinc`,`fgi`,`fgo`) VALUES (NULL, current_timestamp(), '{cpvv}','{ldv}','{ldc}','{pbsv2}','{pcopc}','{pbsv3}','{pivinc}',{fgi},{fgo});" cursor.execute(sql) # print("mcyclを追加しました。") connection.commit()

　(3-3)1日更新DB

1日更新DB関係のサブルーチンです。

　(3-31)db_d_re()

def db_d_re(): global dsum_id,dsum_dtime,ctowh,ldcowh,ldsuwh,ldsut,pcopwh,pivinwh,ldwh,ldt,ldcot,HostAddress,UserName,UsPssword,DBName,dTBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: sql="SELECT * FROM "+dTBName+" ORDER BY dsum_id DESC LIMIT 1" cursor.execute(sql) recd = cursor.fetchone() if not recd: # print("テーブルが無いので追加します") with connection.cursor() as cursor: sql =f"INSERT INTO `{dTBName}` (`dsum_id`, `dsum_dtime`, `ctowh`, `ldcowh`, `ldsuwh`, `ldsut`, `pcopwh`, `pivinwh`) VALUES (NULL, current_timestamp(),'{ctowh}','{ldcowh}','{ldsuwh}','{ldsut}','{pcopwh}','{pivinwh}');" cursor.execute(sql) # print("dcyclを追加しました。") connection.commit() else: # 取得したレコードデータからフィールド値を各変数へ入力する。 fields =list(recd.values()) dsum_id,dsum_dtime,ctowh,ldcowh,ldsuwh,ldsut,pcopwh,pivinwh = fields

　(3-32)db_d_in()

def db_d_in(): global dsum_id,dsum_dtime,ctowh,ldcowh,ldsuwh,ldsut,pcopwh,pivinwh,ldwh,ldt,ldcot,HostAddress,UserName,UsPssword,DBName,dTBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: sql =f"INSERT INTO `{dTBName}` (`dsum_id`, `dsum_dtime`, `ctowh`, `ldcowh`, `ldsuwh`, `ldsut`, `pcopwh`, `pivinwh`) VALUES (NULL, current_timestamp(),'{ctowh}','{ldcowh}','{ldsuwh}','{ldsut}','{pcopwh}','{pivinwh}');" cursor.execute(sql) # print("dcyclを追加しました。") connection.commit()

　(3-33)db_d_up()

def db_d_up(): global dsum_id,dsum_dtime,ctowh,ldcowh,ldsuwh,ldsut,pcopwh,pivinwh,ldwh,ldt,ldcot,HostAddress,UserName,UsPssword,DBName,dTBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: sql =f"UPDATE `{dTBName}` SET dsum_dtime=current_timestamp(),ctowh='{ctowh}',ldcowh='{ldcowh}',ldsuwh='{ldsuwh}',ldsut='{ldsut}',pcopwh='{pcopwh}',pivinwh='{pivinwh}' WHERE dsum_id='{dsum_id}';" cursor.execute(sql) # print("dcyclを修正しました。") connection.commit()

　(3-34)db_d_de()

def db_d_de(): global dsum_id,dsum_dtime,ctowh,ldcowh,ldsuwh,ldsut,pcopwh,pivinwh,ldwh,ldt,ldcot,HostAddress,UserName,UsPssword,DBName,dTBName connection=pymysql.connect( host=HostAddress, user=UserName, password=UsPssword, database=DBName, cursorclass=pymysql.cursors.DictCursor) with connection.cursor() as cursor: #全レコード削除 sql="TRUNCATE TABLE `"+dTBName+"`;" cursor.execute(sql) # print("dcyclを削除しました。") with connection.cursor() as cursor: sql =f"INSERT INTO `{dTBName}` (`dsum_id`, `dsum_dtime`, `ctowh`, `ldcowh`, `ldsuwh`, `ldsut`, `pcopwh`, `pivinwh`) VALUES (NULL, current_timestamp(),'{ctowh}','{ldcowh}','{ldsuwh}','{ldsut}','{pcopwh}','{pivinwh}');" cursor.execute(sql) # print("dcyclを追加しました。") connection.commit()

　(4)db_prs()

def db_prs(): global sum_id,sum_dtime,cstts,cpvv,cbsv,copc,cbtv,cldc,cut1,calwh,ctowh,ldv,ldc,ldw,ldwh,ldcowh,ldsuwh,ldt,ldcot,ldsut,ldlmt,ldpf,ldf,pbsv2,pcopc,pcopw,pcopwh,pbsv3,pivinc,pivinw,pivinwh,fgi,fgo,btv,btc,bt1c,bt2c,bt1t,bt2t,ivt,tmp,hum,prs,lx1,ri1,HostAddress,UserName,UsPssword,DBName,TBName,TBNamem,TBNameh,TBNamed dt = datetime.datetime.now() d_minute= dt.minute d_hour = dt.hour #d_day = dt.day #d_month = dt.month m_hour = sum_dtime.hour #m_day = sum_dtime.day #m_month = sum_dtime.month #d_minute= 0 #d_hour=0 #print("minute=",d_minute,end=" ") #print("hour=", d_hour) #print("") dint=int(d_minute/10)*10 if d_minute==dint :#10minに1回の処理 db_m_in() if (d_hour == 0) and (d_minute == 0) :#1dayに1回の処理 #ldwh=0 #AC301リセット模擬 #ldt=0 AC301_reset() db_d_in() #RBZ60A_reset_now() AUTO Rest PZEM_reset() ldcowh=0 ldsuwh=0 ldcot =0 ldsut =0 db_m_de() db_up()