スマートメータとラズパイで通信ができない

Question

ラズベリーパイ3に接続したWi-SUNドングルを用いてスマートメータから電力情報を取得しようと考えています。
「ラズパイ」「スマートメータ」「Wi-SUN」「エコーネット ライト」などのキーワードでヒットする情報を元に通信を試みました。（プログラム作成者は別）

以下の受信用プログラム「re.py」と電力の瞬時値を返すように要求するプログラム「e.py」を用いて
定時の電力積算値と瞬時値を取得しようとしていますが　取得できていない状況にあります。
前回は問題なく取得できていたのですが、測定環境を変えてから安定的に取得できなくなってしまいました。（稀に取得可能）
Bルート開通の申請は済ませてあり、スマートメータとの通信/PANAの認証はできています。
問題点として2点
1.瞬時値を要求するが応答がNot ERXUDP
2.積算値を取得した際「ascii code can't decode byte 0xff in position」のエラーが発生
（おそらく）アップデート後から発生するようになった

ご助言よろしくお願いします

[re.py]

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# coding: UTF-8

from __future__ import print_function

import sys
import serial
import datetime
import locale
import time
from time import sleep
import commands
import ConfigParser

iniFile = ConfigParser.SafeConfigParser()
iniFile.read('config.ini')


serialPortDev = '/dev/ttyUSB0'
ser = serial.Serial(serialPortDev, 115200)

k = 0.1

# url = iniFile.get('server', 'url')
def influxUp(text) :
    d = datetime.datetime.today()
    f = open('power_tmp.txt', 'w')
    f.write(text)
    f.close()
    # commands.getoutput("curl -i XPOST '{0}:8086/write?db=smartmeter' --data-binary @power_tmp.txt".format(url))
    commands.getoutput("cat power_tmp.txt >> power-{0:04d}{1:02d}{2:02d}.csv".format(d.year,d.month,d.day))

def influxUp2(text) :
    d = datetime.datetime.today()
    f = open('power_tmp2.txt', 'w')
    f.write(text)
    f.close()
    # commands.getoutput("curl -i XPOST '{0}:8086/write?db=smartmeter' --data-binary @power_tmp.txt".format(url))
    commands.getoutput("cat power_tmp2.txt >> power2-{0:04d}{1:02d}{2:02d}.csv".format(d.year,d.month,d.day))





def rcv_e1(res) :
    if len(res) < 2+1*2 :
        return 0
    PDC = res[0:0+2]
    EDT = res[2:2+2] 
    if EDT == "00" :
        k = 1
        print("1kWh")
    elif EDT == "01" :
        k = 0.1
        print("0.1kWh")
    elif EDT == "02" :
        k = 0.01
        print("0.01kWh")
    elif EDT == "03" :
        k = 0.001
        print("0.001kWh")
    elif EDT == "04" :
        k = 0.0001
        print("0.0001kWh")
    elif EDT == "0A" :
        k = 10
        print("10kWh")
    elif EDT == "0B" :
        k = 100
        print("100kWh")
    elif EDT == "0C" :
        k = 1000
        print("1000kWh")
    elif EDT == "0D" :
        k = 10000
        print("10000kWh")
    else :
        print(u"unknown: {0}".format(hex))
    return 4

def rcv_e7(res) :
    if len(res) < 2+4*2 :
        return 0
    PDC = res[0:0+2]
    EDT = res[2:]


    hexPower = res[2:2+8] 
    intPower = int(hexPower, 16)
    if intPower > 0x80000000 :
        intPower = intPower - 0x100000000
    print(u"瞬時電力計測値")
    print(u":{0}[W]".format(intPower))
    timestamp = int(time.mktime(d.timetuple())) * 1000000000
    influxUp2("{0:02d}:{1:02d}:{2:02d},{3},{4}\n".format(d.hour,d.minute,d.second,intPower,timestamp))
    return 10

def rcv_eaeb(res,prefix) :
    if len(res) < 2+11*2 :
        return 0
    PDC = res[0:0+2]
    EDT = res[2:]
    intYear = int(EDT[0:0+4],16)
    intMonth = int(EDT[4:4+2],16)
    intDay = int(EDT[6:6+2],16)
    intHour = int(EDT[8:8+2],16)
    intMin = int(EDT[10:10+2],16)
    intSec = int(EDT[12:12+2],16)
    intValue = int(EDT[14:14+8],16)
    d = time.strptime(u"{0:04d}/{1:02d}/{2:02d} {3:02d}:{4:02d}:{5:02d}".format(intYear,intMonth,intDay,intHour,intMin,intSec), "%Y/%m/%d %H:%M:%S")
    timestamp = int(time.mktime(d)) * 1000000000
    print( u"正方向定時積算電力量")
    print(u":{0:04d}/{1:02d}/{2:02d} {3:02d}:{4:02d}:{5:02d} {6:.1f}[kWh]".format(intYear,intMonth,intDay,intHour,intMin,intSec,float(intValue)*k))
    influxUp("{0}power,{1:02d}:{2:02d}:{3:02d},{4},{5}\n".format(prefix,intHour,intMin,intSec,float(intValue)*k,timestamp))
    return 24



CONNECTION_RETRY = 10
           

for i in range(1, CONNECTION_RETRY + 1):
    try:
        while True:
            line = ser.readline()
            print(line, end="")
            d = datetime.datetime.today()
            print(d)
            if line.startswith("ERXUDP") :
                cols = line.strip().split(' ')
                res = cols[9]   
                ehd1 = res[0:0+2]
                ehd2 = res[2:2+2]
                tid = res[4:4+4]
                EDATA = res[8:]
                seoj = EDATA[0:0+6]
                deoj = EDATA[6:6+6]
                offset = 24
                if seoj == "028801" :
                    ESV = EDATA[12:12+2]
                    if ESV == "72" or ESV == "73" :
                        OPC = EDATA[14:14+2]
                        iOPC = int(OPC, 16)
                        offset = 16
                        step = 0
                        for index in range(iOPC) :
                            EPC = EDATA[offset:offset+2]
                            offset = offset + 2
                            if EPC == "E7" : 
                                step = rcv_e7(EDATA[offset:])
                            elif EPC == "E1" :
                                step = rcv_e1(EDATA[offset:])
                            elif EPC == "EA" :
                                step = rcv_eaeb(EDATA[offset:],"+")
                            elif EPC == "EB" :
                                step = rcv_eaeb(EDATA[offset:],"-")
                            else :
                                print(u"Other EPC: {0}".format(EPC))
                            if step == 0 :
                                break
                            offset = offset + step
                    else :
                        print(u"Other ESV: {0}".format(ESV))
                else :
                    print(u"Other SEOJ: {0}".format(seoj))
            else :
                print(u"Not ERXUDP")
        sleep(3)
        
    except Exception as e:
        print("error:{e} retry:{i}/{max}".format(e=e, i=i, max=CONNECTION_RETRY))
        sleep(i * 10)
    else:
        print("critical")

[e.py]

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from __future__ import print_function

import sys
sys.path.append("/home/pi")
import serial
import time
#import echonet
import ConfigParser

iniFile = ConfigParser.SafeConfigParser()
iniFile.read('/home/pi/pro/bp35c2/config.ini')

# シリアルポート初期化
serialPortDev = '/dev/ttyUSB0'
ser = serial.Serial(serialPortDev, 115200)

# コマンド送信
#command = echonet.generateSmartMeterCommand("\xE7")
address = iniFile.get('smartmeter', 'address')

command = "SKSENDTO 1 {0} 0E1A 1 0 000E \x10\x81\x00\x01\x05\xFF\x01\x02\x88\x01b\x01\xE7\x00".format(address)

ser.write(command)

Comments

[coco_bauer]

「前回は問題なく取得できていたのですが、測定環境を変えてから安定的に取得できなくなってしまいました」というのですから、測定環境を前の状態に戻せば解決するのではないですか？
プログラムで環境を変えることは不可能ですから、まず環境を変える方向で対処すべきだと思います。

[ryu422]

ご対応ありがとうございます。
以前までのスマートメータは一時的に接続させていただいており,現在利用することはできません
接続先をいくつか用意して試しているのですが応答が返ってくるが電力情報として認識できていません
応答の解析を行おうと考えていますが、極力プログラムを変更せずに解決できないかと考えています。
スマートメータ関連で情報収集ができないかと投稿しました。