mqtt msgs and topics

master
Eggert Jung 4 years ago
parent a5ff9a0183
commit 10594f2b43

@ -87,14 +87,19 @@ void do_luefter(){
fan_value += STEP_SIZE; fan_value += STEP_SIZE;
#if PLC_MQTT_ENABLED #if PLC_MQTT_ENABLED
char _msg[3]; char _msg[3];
sprintf(_msg, "%d", fan_value); sprintf(_msg, "%d", fan_value * 100 / 40);
mqtt_pub(&mqtt_client, "/Filamentanlage/04_Messmodul/state/Speed", _msg, 3); mqtt_pub(&mqtt_client, "/Filamentanlage/04_Messmodul/state/LuefterSpeed", _msg, 3);
#endif #endif
printf("luefter %d\n\r", fan_value); printf("luefter %d\n\r", fan_value);
} }
if (read_Input(BTN_LUEFTER_MINUS, RISING) && (fan_value-STEP_SIZE >= STEP_SIZE)) { if (read_Input(BTN_LUEFTER_MINUS, RISING) && (fan_value-STEP_SIZE >= STEP_SIZE)) {
fan_value -= STEP_SIZE; fan_value -= STEP_SIZE;
#if PLC_MQTT_ENABLED
char _msg[3];
sprintf(_msg, "%d", fan_value * 100 / 40);
mqtt_pub(&mqtt_client, "/Filamentanlage/04_Messmodul/state/LuefterSpeed", _msg, 3);
#endif
printf("luefter %d\n\r", fan_value); printf("luefter %d\n\r", fan_value);
} }
} }
@ -217,10 +222,16 @@ int main()
OCR3B = 127; OCR3B = 127;
#if PLC_MQTT_ENABLED
mqtt_pub(&mqtt_client, "/Filamentanlage/04_Messmodul/state/Luefter", "aus", 3);
#endif
while(1) while(1)
{ {
wdt_reset(); // WDT reset at least every sec wdt_reset(); // WDT reset at least every sec
//if (flag_refresh_inStates) { //if (flag_refresh_inStates) {
ioHelperReadPins(); ioHelperReadPins();
ioHelperDebounce(); ioHelperDebounce();