janneketack/valveGroupControl
1
0
Fork 0
forked from RnD/valveGroupControl
Code Pull Requests Activity

commit

Browse Source
This commit is contained in:
JannekeTack26
2025-11-17 15:28:55 +01:00
parent 577c7e3de6
commit 12c61114ba
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/specificClass.js
View File

@@ -94,9 +94,10 @@ class ValveGroupControl {
if (child && child.emitter) { if (child && child.emitter) {
child.measurements.emitter.on('change', (data) => { child.measurements.emitter.on('change', (data) => {
const childName = child.config?.general?.name || `${softwareType}_child`; const childName = child.config?.general?.name || `${softwareType}_child`;
console.log('🔔 EVENT RECEIVED!', childName, data); console.log('🔔 EVENT RECEIVED!', childName, data.type);
console.log('🔔 Data', data);
this.logger.info(`Received change event from child ${childName}:`, data); this.logger.info(`Received change event from child ${childName}:`, data);
this.handleChildChange(child, data); this.handleChildChange(child, data, softwareType);
}); });
console.log(`✅ Event listener added for ${softwareType} child`); console.log(`✅ Event listener added for ${softwareType} child`);
} else { } else {
@@ -107,11 +108,14 @@ class ValveGroupControl {
} }
} }
handleChildChange(child, data) { handleChildChange(child, data, softwareType) {
switch(data.type) { switch(data.type) {
case 'flow': case 'flow':
if (child.source === 'mg') { console.log('softwareType', softwareType)
if (softwareType === 'machinegroup') {
this.logger.info("Total flow change from machineGroupControl detected by valveGroupControl"); this.logger.info("Total flow change from machineGroupControl detected by valveGroupControl");
//Opslaan nieuwe total flow
this.measurements.type("flow").variant("predicted").position("atEquipment").value(data.value);
// als totalflow van mg veranderd, bereken dan de nieuwe valve flows // als totalflow van mg veranderd, bereken dan de nieuwe valve flows
this.calcValveFlows(); this.calcValveFlows();
}; };
@@ -400,7 +404,7 @@ updateFlow(variant,value,position) {
//fill in the rest of the output object //fill in the rest of the output object
output["mode"] = this.currentMode; output["mode"] = this.currentMode;
output["maxDeltaP"] = this.maxDeltaP; //output["maxDeltaP"] = this.maxDeltaP;
//this.logger.debug(`Output: ${JSON.stringify(output)}`); //this.logger.debug(`Output: ${JSON.stringify(output)}`);