diff --git a/app/modules/choco.js b/app/modules/choco.js index 4befe1515..2c67acbcf 100644 --- a/app/modules/choco.js +++ b/app/modules/choco.js @@ -307,11 +307,20 @@ class Choco extends BaseModule { * @param {*} handler */ requestRemoteData(handler) { + //sensor데이터는 상태가 바뀔때 전송한다. + if ( + _.isEmpty(this.previousSensorData) || + !_.isEqual(this.previousSensorData, this.sensorData) + ) { + handler.write('sensorData', this.sensorData); + this.previousSensorData = _.cloneDeep(this.sensorData); + } + if (this.executeCmd.processing === 'done') { this.log('requestRemoteData done', this.executeCmd.id); handler.write('msg_id', this.executeCmd.id); - handler.write('sensorData', this.sensorData); + //handler.write('sensorData', this.sensorData); this.executeCmd.id = ''; this.executeCmd.processing = 'none'; diff --git a/app/modules/choco2.js b/app/modules/choco2.js index 4befe1515..4806e93ea 100644 --- a/app/modules/choco2.js +++ b/app/modules/choco2.js @@ -307,17 +307,26 @@ class Choco extends BaseModule { * @param {*} handler */ requestRemoteData(handler) { + //sensor데이터는 상태가 바뀔때 전송한다. + if ( + _.isEmpty(this.previousSensorData) || + !_.isEqual(this.previousSensorData, this.sensorData) + ) { + handler.write('sensorData', this.sensorData); + this.previousSensorData = _.cloneDeep(this.sensorData); + } + if (this.executeCmd.processing === 'done') { this.log('requestRemoteData done', this.executeCmd.id); handler.write('msg_id', this.executeCmd.id); - handler.write('sensorData', this.sensorData); + //handler.write('sensorData', this.sensorData); this.executeCmd.id = ''; this.executeCmd.processing = 'none'; } }; - + /** * 엔트리에서 받은 데이터에 대한 처리 * @param {*} handler