thermferm/mqtt.c

changeset 579
7032693272f1
parent 578
d694abd9d809
child 582
ba340e00aab2
equal deleted inserted replaced
578:d694abd9d809 579:7032693272f1
368 free(unit->product_uuid); 368 free(unit->product_uuid);
369 unit->product_uuid = xstrcpy((char *)json_object_get_string(val)); 369 unit->product_uuid = xstrcpy((char *)json_object_get_string(val));
370 unit->mqtt_flag |= MQTT_FLAG_DATA; 370 unit->mqtt_flag |= MQTT_FLAG_DATA;
371 syslog(LOG_NOTICE, "DCMD change fermenter %s: product_uuid to `%s'", message_alias, unit->product_uuid); 371 syslog(LOG_NOTICE, "DCMD change fermenter %s: product_uuid to `%s'", message_alias, unit->product_uuid);
372 } 372 }
373 }
374 if (json_object_object_get_ex(setpoint, "yeast_lo", &val)) {
375 unit->yeast_lo = json_object_get_double(val);
376 unit->mqtt_flag |= MQTT_FLAG_DATA;
377 syslog(LOG_NOTICE, "DCMD change fermenter %s: yeast_lo to `%.1f'", message_alias, unit->yeast_lo);
378 }
379 if (json_object_object_get_ex(setpoint, "yeast_hi", &val)) {
380 unit->yeast_hi = json_object_get_double(val);
381 unit->mqtt_flag |= MQTT_FLAG_DATA;
382 syslog(LOG_NOTICE, "DCMD change fermenter %s: yeast_lo to `%.1f'", message_alias, unit->yeast_hi);
373 } 383 }
374 } 384 }
375 385
376 if (json_object_object_get_ex(metric, "profile", &profile)) { 386 if (json_object_object_get_ex(metric, "profile", &profile)) {
377 if (json_object_object_get_ex(profile, "command", &profile1)) { 387 if (json_object_object_get_ex(profile, "command", &profile1)) {
685 payload = xstrcat(payload, (char *)","); 695 payload = xstrcat(payload, (char *)",");
686 payload = xstrcat(payload, (char *)"\"name\":\""); 696 payload = xstrcat(payload, (char *)"\"name\":\"");
687 payload = xstrcat(payload, unit->product_name); 697 payload = xstrcat(payload, unit->product_name);
688 payload = xstrcat(payload, (char *)"\""); 698 payload = xstrcat(payload, (char *)"\"");
689 } 699 }
700 sprintf(buf, "%.1f", unit->yeast_lo);
701 payload = xstrcat(payload, (char *)",\"yeast_lo\":");
702 payload = xstrcat(payload, buf);
703 sprintf(buf, "%.1f", unit->yeast_hi);
704 payload = xstrcat(payload, (char *)",\"yeast_hi\":");
705 payload = xstrcat(payload, buf);
690 payload = xstrcat(payload, (char *)"}"); 706 payload = xstrcat(payload, (char *)"}");
691 } 707 }
692 708
693 /* 709 /*
694 * Air temperature sensor 710 * Air temperature sensor

mercurial