node.jsで実装したプログラムで取得したデータをinfluxdbに保存する こちらを参考に実装

ライブラリのインストール

$ npm install influx

node.js

const Influx = require('influx')
const influxAircon = new Influx.InfluxDB({
    host: '192.168.***.***',
    database: 'homedata',
    schema: [
        {
            measurement: 'echonet-Aircon',
            tags: [
                'addr',
                'place'
            ],
            fields: {
                status: Influx.FieldType.STRING,
                mode: Influx.FieldType.STRING,
                modeNum: Influx.FieldType.INTEGER,
                setTemp: Influx.FieldType.INTEGER,
                measureHumi: Influx.FieldType.INTEGER,
                measureTemp: Influx.FieldType.INTEGER,
                measureOutdoorTemp: Influx.FieldType.INTEGER
			}
        }
    ]
})

influxAircon.writePoints([
			{
				measurement: 'echonet-aircon',
				tags: { addr: address, place: "aircon" },
				fields: {
					status: vStatus,
					mode: vMode,
					modeNum: vModeNum,
					setTemp: vSetTemp,
					measureHumi: vMeasureHumi,
					measureTemp: vMeasureTemp,
					measureOutdoorTemp: vMeasureOutdoorTemp
				}
			} 
		]).catch(err => {
			console.error(`Error saving data to InfluxDB! ${err.stack}`)
		})

太陽光発電

//Solar
function getOperationStatus_Solar(address, eoj) {
	var esv = 'Get';
	var prop = [
		{ 'epc': 0x80, 'edt': null }, // ON/OFF
		{ 'epc': 0xE0, 'edt': null } // 発電量
	];
	el.send(address, eoj, esv, prop, (err, res) => {
		console.log('[Solar] @' + address);
		console.log('  Err : ' + err);
		console.log('  ESV : ' + res['message']['esv']);
		var vStatus = '';
		var vWatt = '';
		for (let element of res['message']['prop']){
			//console.dir(element);
			var epc = element['epc'];
			var edt = element['edt'];
			if (epc === 0x80) {
				vStatus = (edt['status'] ? 'on' : 'off');
				//saveToFile(dataDIR+"/solar@"+address+"_Power",desc);
				console.log('  Power : ' + vStatus);
			}else if (epc === 0xE0) {
				vWatt = element['buffer'][0]*256 + element['buffer'][1];
				//saveToFile(dataDIR+"/solar@"+address+"_Generate",num);
				console.log('  Electric generate : ' + vWatt + '[W]');
			} else{
				console.dir(element);
			}
		}
	});
	getOperationStatus_Battery(address);
}

蓄電池

//Battery
function getOperationStatus_Battery(address) {
	var esv = 'Get';
	var eoj = new Array(0x2,0x7d,1);
	var prop = [
		{ 'epc': 0x80, 'edt': null }, // ON/OFF
		{ 'epc': 0xA0, 'edt': null }, //
		{ 'epc': 0xA1, 'edt': null }, //
		{ 'epc': 0xA2, 'edt': null }, //
		{ 'epc': 0xA3, 'edt': null }, //
		{ 'epc': 0xA4, 'edt': null }, //
		{ 'epc': 0xA5, 'edt': null }, //
		{ 'epc': 0xCF, 'edt': null }, //
		{ 'epc': 0xD3, 'edt': null }, //
		{ 'epc': 0xE4, 'edt': null }, //
		{ 'epc': 0xE5, 'edt': null }  //
	];
	el.send(address, eoj, esv, prop, (err, res) => {
		console.log('[Battery] @' + address);
		console.log('  Err : ' + err);
		console.log('  ESV : ' + res['message']['esv']);
		var vStatus = "";
		var vEffectiveCapacity_charge = "";
		var vEffectiveCapacity_disCharge = "";
		var vChargeableCapacity = "";
		var vDischargeableCapacity = "";
		var vCapacity_charge = "";
		var vCapacity_discharge = "";
		var vOutput = "";
		var vMode = "";
		var vBatteryLevel = "";
		var vDeterioration = "";
		for (let element of res['message']['prop']){
			//console.dir(element);
			var epc = element['epc'];
			var edt = element['edt'];
			if (epc === 0x80) {
				vStatus = (edt['status'] ? 'on' : 'off');
				//saveToFile(dataDIR+"/battery@"+address+"_Power",desc);
				console.log('  Power : ' + vStatus);
			} else if (epc === 0xA0) {
				var num0 = element['buffer'][0]<<24;
				var num1 = element['buffer'][1]<<16;
				var num2 = element['buffer'][2]<<8;
				var num3 = element['buffer'][3];
				vEffectiveCapacity_charge = num0 + num1 + num2 + num3;
				//saveToFile(dataDIR+"/battery@"+address+"_EffectiveCapacity_charge",num);
				console.log('  AC実効容量（充電） : ' + vEffectiveCapacity_charge + '[Wh]');
			} else if (epc === 0xA1) {
				var num0 = element['buffer'][0]<<24;
				var num1 = element['buffer'][1]<<16;
				var num2 = element['buffer'][2]<<8;
				var num3 = element['buffer'][3];
				vEffectiveCapacity_disCharge = num0 + num1 + num2 + num3;
				//saveToFile(dataDIR+"/battery@"+address+"_EffectiveCapacity_discharge",num);
				console.log('  AC実効容量（放電） : ' + vEffectiveCapacity_disCharge + '[Wh]');
			} else if (epc === 0xA2) {
				var num0 = element['buffer'][0]<<24;
				var num1 = element['buffer'][1]<<16;
				var num2 = element['buffer'][2]<<8;
				var num3 = element['buffer'][3];
				vChargeableCapacity = num0 + num1 + num2 + num3;
				//saveToFile(dataDIR+"/battery@"+address+"_ChargeableCapacity",num);
				console.log('  AC充電可能容量 : ' + vChargeableCapacity + '[Wh]');
			} else if (epc === 0xA3) {
				var num0 = element['buffer'][0]<<24;
				var num1 = element['buffer'][1]<<16;
				var num2 = element['buffer'][2]<<8;
				var num3 = element['buffer'][3];
				vDischargeableCapacity = num0 + num1 + num2 + num3;
				//saveToFile(dataDIR+"/battery@"+address+"_DischargeableCapacity",num);
				console.log('  AC放電可能容量 : ' + vDischargeableCapacity + '[Wh]');
			} else if (epc === 0xA4) {
				var num0 = element['buffer'][0]<<24;
				var num1 = element['buffer'][1]<<16;
				var num2 = element['buffer'][2]<<8;
				var num3 = element['buffer'][3];
				vCapacity_charge = num0 + num1 + num2 + num3;
				//saveToFile(dataDIR+"/battery@"+address+"_Capacity_charge",num);
				console.log('  AC充電可能量（現時点での） : ' + vCapacity_charge + '[Wh]');
			} else if (epc === 0xA5) {
				var num0 = element['buffer'][0]<<24;
				var num1 = element['buffer'][1]<<16;
				var num2 = element['buffer'][2]<<8;
				var num3 = element['buffer'][3];
				vCapacity_discharge = num0 + num1 + num2 + num3;
				//saveToFile(dataDIR+"/battery@"+address+"_Capacity_discharge",num);
				console.log('  AC放電可能量（現時点での） : ' + vCapacity_discharge + '[Wh]');
			} else if (epc === 0xD3) {
				var num0 = element['buffer'][0]<<24;
				var num1 = element['buffer'][1]<<16;
				var num2 = element['buffer'][2]<<8;
				var num3 = element['buffer'][3];
				vOutput = num0 + num1 + num2 + num3;
				if (vOutput > 0xC4653601 ){
					vOutput = vOutput - 0x100000000a;
				}
				//saveToFile(dataDIR+"/battery@"+address+"_Output",num);
				console.log('  瞬間充放電電力計測値 : ' + vOutput + '[W]');
			} else if (epc === 0xCF) {
				vMode = element['buffer'][0];
				switch(vMode){
					case 0x41:
						vMode = "急速充電";
						break;
					case 0x42:
						vMode = "充電";
						break;
					case 0x43:
						vMode = "放電";
						break;
					case 0x44:
						vMode = "待機";
						break;
					case 0x45:
						vMode = "テスト";
						break;
					case 0x46:
						vMode = "自動";
						break;
					case 0x48:
						vMode = "再起動";
						break;
					case 0x49:
						vMode = "実効容量再計算処理";
						break;
					case 0x40:
						vMode = "その他";
						break;
					default:
				}
				//saveToFile(dataDIR+"/battery@"+address+"_Mode",desc);
				console.log('  Mode : ' + vMode);
			} else if (epc === 0xE4) {
				vBatteryLevel = element['buffer'][0];
				//saveToFile(dataDIR+"/battery@"+address+"_BatteryLevel",desc);
				console.log('  蓄電池残量 : ' + vBatteryLevel + "[%]");
			} else if (epc === 0xE5) {
				vDeterioration = element['buffer'][0];
				//saveToFile(dataDIR+"/battery@"+address+"_Deterioration",desc);
				console.log('  劣化状態 : ' + vDeterioration + "[%]");
			} else{
				console.dir(element);
			}
		}
	});
}

エコキュート

//Ecocute
function getOperationStatus_EcoCute(address, eoj) {
	var esv = 'Get';
	var prop = [
		{ 'epc': 0x80, 'edt': null }, // ON/OFF
		{ 'epc': 0xB2, 'edt': null }, // 炊き上げ中
		{ 'epc': 0xC3, 'edt': null }, // 給湯中
		{ 'epc': 0xE1, 'edt': null }  // 残湯量
	];
	el.send(address, eoj, esv, prop, (err, res) => {
		console.log('[EcoCute] @' + address);
		console.log('  Err : ' + err);
		console.log('  ESV : ' + res['message']['esv']);
		var vStatus = "";
		var vHotWaterMake = "";
		var vHotWaterOutput = "";
		var vHotWaterVolume = "";
		for (let element of res['message']['prop']){
			//console.dir(element);
			var epc = element['epc'];
			var edt = element['edt'];
			if (epc === 0x80) {
				vStatus = (edt['status'] ? 'on' : 'off');
				console.log('  Power : ' + vStatus);
				//saveToFile(dataDIR+"/ecocute@"+address+"_Power",desc);
			} else if (epc === 0xB2) {
				hotWaterMake = element['buffer'][0];
				if (vHotWaterMake === 0x41) {
					vHotWaterMake = 1;
					console.log('  Hot water : making (' + vHotWaterMake + ')');
					//saveToFile(dataDIR + "/ecocute@" + address + "_HotWaterMake", "making");
				}else if (hotWaterMake === 0x42){
					vHotWaterMake = 0;
					console.log('  Hot water : not making (' + vHotWaterMake + ')');
					//saveToFile(dataDIR + "/ecocute@" + address + "_HotWaterMake", "not making");
				}
			} else if (epc === 0xC3) {
				vHotWaterOutput = element['buffer'][0];
				if (vHotWaterOutput === 0x41) {
					vHotWaterOutput = 1;
					console.log('  Hot water : output (' + vHotWaterOutput + ')');
					//saveToFile(dataDIR + "/ecocute@" + address + "_HotWaterOutput", "output");
				}else if (vHotWaterOutput === 0x42){
					vHotWaterOutput = 0;
					console.log('  Hot water : no output (' + vHotWaterOutput + ')');
					//saveToFile(dataDIR + "/ecocute@" + address + "_HotWaterOutput", "no output");
				}
			} else if (epc === 0xE1) {
				vHotWaterVolume = element['buffer'][0]*256 + element['buffer'][1];
				console.log('  Hot water volume : ' + vHotWaterVolume + '[l]');
				//saveToFile(dataDIR + "/ecocute@" + address + "_HotWaterVolume", num);
			} else{
				console.dir(element);
			}
		}
	});
}

ライブラリのインストール

$ npm install serialport
$ npm install node-echonet-lite

初期化関係

// reference : https://github.com/futomi/node-echonet-lite

// Load the node-echonet-lite module
var EchonetLite = require('node-echonet-lite');
// Create an EchonetLite object
//   The type of network layer must be passed.
var el = new EchonetLite({ 'type': 'lan' });
el.setLang('ja');

// Initialize the EchonetLite object
el.init((err) => {
	if (err) { // An error was occurred
		showErrorExit(err);
	} else { // Start to discover devices
		discoverDevices();
		setTimeout(timeOutExit, 15000);
	}
});

対応機器の特定

// Start to discover devices
function discoverDevices() {
	// Start to discover Echonet Lite devices
	el.startDiscovery((err, res) => {
		// Error handling
		if (err) {
			showErrorExit(err);
		}
		// Determine the type of the found device
		var device = res['device'];
		var address = device['address'];
		var eoj = device['eoj'][0];
		//console.log(eoj);
		var group_code = eoj[0]; // Class group code
		var class_code = eoj[1]; // Class code
		if (group_code === 0x01 && class_code === 0x30) {
			//el.stopDiscovery();
			getOperationStatus_AirCon(address, eoj);
		}else{
			el.getPropertyMaps(address, eoj, (err, res) => {
				console.log(address + " : " + el.getClassGroupName(group_code) + " / " + el.getClassName(group_code, class_code));
				console.log('- IP address: ' + address);
				console.log('- EOJ: ' + JSON.stringify(eoj));
				console.log('- Property Maps:')
				console.dir(res['message']['data']);
			});
		}
	});
}

情報取得

// Get the operation status
function getOperationStatus_AirCon(address, eoj) {
	var esv = 'Get';
	var prop = [
		{ 'epc': 0x80, 'edt': null }, // ON/OFF
		{ 'epc': 0xB0, 'edt': null }, // Mode
		{ 'epc': 0xB3, 'edt': null }, // Set Temperature
		{ 'epc': 0xBA, 'edt': null }, // Room Humidity
		{ 'epc': 0xBB, 'edt': null }, // Room Temperature
		{ 'epc': 0xBE, 'edt': null }  // outdoor Temperature
	];
	el.send(address, eoj, esv, prop, (err, res) => {
		console.log('[Air conditioner] @' + address);
		console.log('  Err : ' + err);
		console.log('  ESV : ' + res['message']['esv']);
		var vStatus = "";
		var vMode = "";
		var vModeNum = "";
		var vSetTemp = "";
		var vMeasureHumi = "";
		var vMeasureTemp = "";
		var vMeasureOutdoorTemp = "";
		for (let element of res['message']['prop']){
			//console.dir(element);
			var epc = element['epc'];
			var edt = element['edt'];
			if (epc === 0x80) {
				vStatus = (edt['status'] ? 'on' : 'off');
				console.log('  Power : ' + vStatus);
				//saveToFile(dataDIR+"/aircon@"+address+"_Power",desc);
			} else if (epc === 0xB0) {
				vModeNum = edt['mode'];
				vMode = edt['desc'];
				console.log('  Mode : ' + vMode + '(' + vModeNum + ')');
				//saveToFile(dataDIR+"/aircon@"+address+"_Mode",desc);
				//saveToFile(dataDIR+"/aircon@"+address+"_ModeNum",num);
			} else if (epc === 0xB3) {
				vSetTemp = edt['temperature'];
				if(vSetTemp === null ){vSetTemp = 253}
				console.log('  Set temp : ' + vSetTemp + "[℃]");
				//saveToFile(dataDIR+"/aircon@"+address+"_setTemp",desc);
			} else if (epc === 0xBA) {
				vMeasureHumi = edt['humidity'];
				//if(vMeasureHumi === 253 ){vMeasureHumi = " "}
				console.log('  Measure Humi : ' + vMeasureHumi + "[%]");
				//saveToFile(dataDIR+"/aircon@"+address+"_measureHumi",desc);
			} else if (epc === 0xBB) {
				vMeasureTemp = edt['temperature'];
				console.log('  Measure temp : ' + vMeasureTemp + "[℃]");
				//saveToFile(dataDIR+"/aircon@"+address+"_measureTemp",desc);
			} else if (epc === 0xBE) {
				vMeasureOutdoorTemp = edt['temperature'];
				if(vMeasureOutdoorTemp === 126 ){vMeasureOutdoorTemp = 253}
				console.log('  Measure Outdoor temp : ' + vMeasureOutdoorTemp + "[℃]");
				//saveToFile(dataDIR+"/aircon@"+address+"_measureOutdoorTemp",desc);
			} else{
				console.dir(element)
			}
		}
		
		//el.close();
	});
}

エラー＆終了処理定

// Print an error then terminate the process of this script
function showErrorExit(err) {
	console.log('[ERROR] ' + err.toString());
	el.close();
	process.exit();
}
function timeOutExit() {
	console.log('[TimeOut]');
	el.close();
	process.exit();
}

実行結果

[Air conditioner] @192.168.***.***
  Err : null
  ESV : Get_Res
  Power : on
  Mode : 送風(5)
  Set temp : 253[℃]
  Measure Humi : 70[%]
  Measure temp : 24[℃]
  Measure Outdoor temp : 19[℃]