604 void co2meter_mysql_insert(sys_co2meter_list *co2meter) |
604 void co2meter_mysql_insert(sys_co2meter_list *co2meter) |
605 { |
605 { |
606 char *query = malloc(2560); |
606 char *query = malloc(2560); |
607 |
607 |
608 snprintf(query, 2559, |
608 snprintf(query, 2559, |
609 "INSERT INTO mon_co2meters SET uuid='%s', alias='%s', node='%s', online='%d', mode='%s', " \ |
609 "INSERT INTO mon_co2meters SET uuid='%s', alias='%s', node='%s', online='%d', mode='%s', alarm='%d', " \ |
610 "temperature_address='%s', temperature_state='%s', temperature='%.3f', " \ |
610 "temperature_address='%s', temperature_state='%s', temperature='%.3f', " \ |
611 "pressure_state='%s', pressure_channel='%d', pressure_voltage='%.3f', pressure_zero='%.3f', pressure_bar='%.3f'", |
611 "pressure_state='%s', pressure_channel='%d', pressure_voltage='%.3f', pressure_zero='%.3f', pressure_bar='%.3f'", |
612 co2meter->uuid, co2meter->alias, co2meter->node, co2meter->online ? 1:0, co2meter->mode, |
612 co2meter->uuid, co2meter->alias, co2meter->node, co2meter->online ? 1:0, co2meter->mode, co2meter->alarm, |
613 co2meter->temperature_address, co2meter->temperature_state, co2meter->temperature, |
613 co2meter->temperature_address, co2meter->temperature_state, co2meter->temperature, |
614 co2meter->pressure_state, co2meter->pressure_channel, co2meter->pressure_voltage, co2meter->pressure_zero, co2meter->pressure_bar); |
614 co2meter->pressure_state, co2meter->pressure_channel, co2meter->pressure_voltage, co2meter->pressure_zero, co2meter->pressure_bar); |
615 |
615 |
616 if (bms_mysql_query(query) == 0) { |
616 if (bms_mysql_query(query) == 0) { |
617 syslog(LOG_NOTICE, "MySQL: insert new co2meter %s/%s", co2meter->node, co2meter->alias); |
617 syslog(LOG_NOTICE, "MySQL: insert new co2meter %s/%s", co2meter->node, co2meter->alias); |
624 void co2meter_mysql_update(sys_co2meter_list *co2meter) |
624 void co2meter_mysql_update(sys_co2meter_list *co2meter) |
625 { |
625 { |
626 char *query = malloc(2560); |
626 char *query = malloc(2560); |
627 |
627 |
628 snprintf(query, 2559, |
628 snprintf(query, 2559, |
629 "UPDATE mon_co2meters SET online='%d', mode='%s', " \ |
629 "UPDATE mon_co2meters SET online='%d', mode='%s', alarm='%d', " \ |
630 "temperature_address='%s', temperature_state='%s', temperature='%.3f', " \ |
630 "temperature_address='%s', temperature_state='%s', temperature='%.3f', " \ |
631 "pressure_state='%s', pressure_channel='%d', pressure_voltage='%.3f', pressure_zero='%.3f', pressure_bar='%.3f' " \ |
631 "pressure_state='%s', pressure_channel='%d', pressure_voltage='%.3f', pressure_zero='%.3f', pressure_bar='%.3f' " \ |
632 "WHERE uuid='%s'", |
632 "WHERE uuid='%s'", |
633 co2meter->online ? 1:0, co2meter->mode, |
633 co2meter->online ? 1:0, co2meter->mode, co2meter->alarm, |
634 co2meter->temperature_address, co2meter->temperature_state, co2meter->temperature, |
634 co2meter->temperature_address, co2meter->temperature_state, co2meter->temperature, |
635 co2meter->pressure_state, co2meter->pressure_channel, co2meter->pressure_voltage, co2meter->pressure_zero, co2meter->pressure_bar, |
635 co2meter->pressure_state, co2meter->pressure_channel, co2meter->pressure_voltage, co2meter->pressure_zero, co2meter->pressure_bar, |
636 co2meter->uuid); |
636 co2meter->uuid); |
637 |
637 |
638 bms_mysql_query(query); |
638 bms_mysql_query(query); |