Sat, 11 May 2019 23:13:40 +0200
Added flags for each ingredient group for the supplies state. On the main screen show the state of the supplies if the product stage is not yet packaged. Calculate the state of the supplies for fermentables, hops, yeasts and miscs. In the grids don't show the inventory values after they are used and reduced. On the fermentables tab show the weight of the grains to mash.
0 | 1 | /** |
2 | * @file mysql.c | |
3 | * @brief MySQL/MariaDB access. | |
4 | * @author Michiel Broek <mbroek at mbse dot eu> | |
5 | * | |
192
7f69b43e6084
Implemented beer uuid product in monitor fermenters.
Michiel Broek <mbroek@mbse.eu>
parents:
76
diff
changeset
|
6 | * Copyright (C) 2018-2019 |
0 | 7 | * |
8 | * This file is part of the bms (Brewery Management System) | |
9 | * | |
10 | * This is free software; you can redistribute it and/or modify it | |
11 | * under the terms of the GNU General Public License as published by the | |
12 | * Free Software Foundation; either version 2, or (at your option) any | |
13 | * later version. | |
14 | * | |
15 | * bms is distributed in the hope that it will be useful, but | |
16 | * WITHOUT ANY WARRANTY; without even the implied warranty of | |
17 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | |
18 | * General Public License for more details. | |
19 | * | |
20 | * You should have received a copy of the GNU General Public License | |
21 | * along with ThermFerm; see the file COPYING. If not, write to the Free | |
22 | * Software Foundation, 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. | |
23 | */ | |
24 | ||
25 | #include "bms.h" | |
26 | #include "xutil.h" | |
27 | #include "mysql.h" | |
28 | #include "nodes.h" | |
29 | ||
30 | ||
31 | MYSQL *con = NULL; | |
32 | MYSQL_RES *res_set; | |
33 | MYSQL_ROW row; | |
34 | ||
35 | extern sys_config Config; | |
36 | extern sys_node_list *nodes; | |
37 | extern sys_fermenter_list *fermenters; | |
38 | extern int debug; | |
39 | ||
40 | ||
41 | time_t datetime_to_time_t(char *dt_string) | |
42 | { | |
43 | struct tm tm; | |
44 | ||
45 | memset(&tm, 0, sizeof(struct tm)); | |
46 | tm.tm_year = atoi(strtok(dt_string, "-")) - 1900; | |
47 | tm.tm_mon = atoi(strtok(NULL, "-")) - 1; | |
48 | tm.tm_mday = atoi(strtok(NULL, " ")); | |
49 | tm.tm_hour = atoi(strtok(NULL, ":")); | |
50 | tm.tm_min = atoi(strtok(NULL, ":")); | |
51 | tm.tm_sec = atoi(strtok(NULL, "\0")); | |
52 | tm.tm_isdst = 1; | |
53 | ||
54 | return mktime(&tm); | |
55 | } | |
56 | ||
57 | ||
58 | ||
59 | int bms_mysql_init(void) | |
60 | { | |
61 | sys_node_list *node, *tmpp; | |
62 | sys_fermenter_list *fermenter, *tmpf; | |
63 | int ncnt = 0, fcnt = 0; | |
64 | ||
65 | con = mysql_init(NULL); | |
66 | if (con == NULL) { | |
67 | syslog(LOG_NOTICE, "MySQL: mysql_init() failed"); | |
68 | return 1; | |
69 | } | |
70 | ||
71 | if (mysql_real_connect(con, Config.mysql_host, Config.mysql_user, Config.mysql_pass, Config.mysql_database, Config.mysql_port, NULL, 0) == NULL) { | |
72 | syslog(LOG_NOTICE, "MySQL: mysql_real_connect() %s", mysql_error(con)); | |
73 | return 2; | |
74 | } | |
75 | ||
76 | syslog(LOG_NOTICE, "MySQL: connected to %s:%d database %s", Config.mysql_host, Config.mysql_port, Config.mysql_database); | |
77 | syslog(LOG_NOTICE, "MySQL: %s server info: %s", mysql_get_host_info(con), mysql_get_server_info(con)); | |
78 | if (debug) | |
79 | fprintf(stdout, "MySQL: connected\n"); | |
80 | ||
81 | /* | |
82 | * Restore nodes from the database | |
83 | */ | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
84 | if (mysql_query(con, "SELECT * FROM mon_nodes")) { |
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
85 | syslog(LOG_NOTICE, "MySQL: SELECT * FROM mon_nodes error %u (%s))", mysql_errno(con), mysql_error(con)); |
0 | 86 | } else { |
87 | res_set = mysql_store_result(con); | |
88 | if (res_set == NULL) { | |
89 | syslog(LOG_NOTICE, "MySQL: mysq_store_result error %u (%s))", mysql_errno(con), mysql_error(con)); | |
90 | } else { | |
91 | // Process results | |
92 | while ((row = mysql_fetch_row(res_set)) != NULL) { | |
93 | node = (sys_node_list *)malloc(sizeof(sys_node_list)); | |
94 | memset(node, 0, sizeof(sys_node_list)); | |
95 | node->next = NULL; | |
96 | node->uuid = xstrcpy(row[1]); | |
97 | node->node = xstrcpy(row[2]); | |
98 | node->online = false; // Will be set using MQTT | |
99 | node->group_id = xstrcpy(row[4]); | |
100 | node->hardwaremake = xstrcpy(row[5]); | |
101 | node->hardwaremodel = xstrcpy(row[6]); | |
102 | node->os = xstrcpy(row[7]); | |
103 | node->os_version = xstrcpy(row[8]); | |
104 | node->firmware = xstrcpy(row[9]); | |
105 | node->firstseen = datetime_to_time_t(row[10]); | |
106 | node->lastseen = datetime_to_time_t(row[11]); | |
107 | node->temperature = atof(row[12]); | |
108 | node->humidity = atof(row[13]); | |
109 | node->barometer = atof(row[14]); | |
110 | node->gps_latitude = atof(row[15]); | |
111 | node->gps_longitude = atof(row[16]); | |
112 | node->gps_altitude = atof(row[17]); | |
113 | node->net_address = xstrcpy(row[18]); | |
114 | node->net_ifname = xstrcpy(row[19]); | |
115 | node->net_rssi = atoi(row[20]); | |
116 | ||
117 | if (nodes == NULL) { | |
118 | nodes = node; | |
119 | } else { | |
120 | for (tmpp = nodes; tmpp; tmpp = tmpp->next) { | |
121 | if (tmpp->next == NULL) { | |
122 | tmpp->next = node; | |
123 | break; | |
124 | } | |
125 | } | |
126 | } | |
127 | ncnt++; | |
128 | } | |
129 | mysql_free_result(res_set); | |
130 | } | |
131 | } | |
132 | ||
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
133 | if (mysql_query(con, "SELECT * FROM mon_fermenters")) { |
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
134 | syslog(LOG_NOTICE, "MySQL: SELECT * FROM mon_fermenters error %u (%s))", mysql_errno(con), mysql_error(con)); |
0 | 135 | } else { |
136 | res_set = mysql_store_result(con); | |
137 | if (res_set == NULL) { | |
138 | syslog(LOG_NOTICE, "MySQL: mysq_store_result error %u (%s))", mysql_errno(con), mysql_error(con)); | |
139 | } else { | |
140 | while ((row = mysql_fetch_row(res_set)) != NULL) { | |
141 | fermenter = (sys_fermenter_list *)malloc(sizeof(sys_fermenter_list)); | |
142 | memset(fermenter, 0, sizeof(sys_fermenter_list)); | |
143 | fermenter->next = NULL; | |
144 | fermenter->uuid = xstrcpy(row[1]); | |
145 | fermenter->alias = xstrcpy(row[2]); | |
146 | fermenter->node = xstrcpy(row[3]); | |
147 | fermenter->online = false; // Will be set later | |
148 | fermenter->beercode = xstrcpy(row[5]); | |
149 | fermenter->beername = xstrcpy(row[6]); | |
192
7f69b43e6084
Implemented beer uuid product in monitor fermenters.
Michiel Broek <mbroek@mbse.eu>
parents:
76
diff
changeset
|
150 | fermenter->beeruuid = xstrcpy(row[44]); |
0 | 151 | if (strlen(row[7])) { |
152 | fermenter->air_address = xstrcpy(row[7]); | |
153 | fermenter->air_state = xstrcpy(row[8]); | |
154 | fermenter->air_temperature = atof(row[9]); | |
155 | } | |
156 | if (strlen(row[10])) { | |
157 | fermenter->beer_address = xstrcpy(row[10]); | |
158 | fermenter->beer_state = xstrcpy(row[11]); | |
159 | fermenter->beer_temperature = atof(row[12]); | |
160 | } | |
161 | if (strlen(row[13])) { | |
162 | fermenter->chiller_address = xstrcpy(row[13]); | |
163 | fermenter->chiller_state = xstrcpy(row[14]); | |
164 | fermenter->chiller_temperature = atof(row[15]); | |
165 | } | |
166 | if (strlen(row[16])) { | |
167 | fermenter->heater_address = xstrcpy(row[16]); | |
168 | fermenter->heater_state = atoi(row[17]); | |
169 | fermenter->heater_usage = atoi(row[18]); | |
170 | } | |
171 | if (strlen(row[19])) { | |
172 | fermenter->cooler_address = xstrcpy(row[19]); | |
173 | fermenter->cooler_state = atoi(row[20]); | |
174 | fermenter->cooler_usage = atoi(row[21]); | |
175 | } | |
176 | if (strlen(row[22])) { | |
177 | fermenter->fan_address = xstrcpy(row[22]); | |
178 | fermenter->fan_state = atoi(row[23]); | |
179 | fermenter->fan_usage = atoi(row[24]); | |
180 | } | |
181 | if (strlen(row[25])) { | |
182 | fermenter->light_address = xstrcpy(row[25]); | |
183 | fermenter->light_state = atoi(row[26]); | |
184 | fermenter->light_usage = atoi(row[27]); | |
185 | } | |
186 | if (strlen(row[28])) { | |
187 | fermenter->door_address = xstrcpy(row[28]); | |
188 | fermenter->door_state = atoi(row[29]); | |
189 | } | |
190 | if (strlen(row[30])) { | |
191 | fermenter->psu_address = xstrcpy(row[30]); | |
192 | fermenter->psu_state = atoi(row[31]); | |
193 | } | |
194 | fermenter->mode = xstrcpy(row[32]); | |
195 | fermenter->alarm = atoi(row[33]); | |
196 | fermenter->setpoint_high = atof(row[34]); | |
197 | fermenter->setpoint_low = atof(row[35]); | |
198 | if (strlen(row[36])) { | |
199 | fermenter->profile_uuid = xstrcpy(row[36]); | |
200 | fermenter->profile_name = xstrcpy(row[37]); | |
201 | fermenter->profile_state = xstrcpy(row[38]); | |
202 | fermenter->profile_percent = atoi(row[39]); | |
203 | fermenter->profile_inittemp_high = atof(row[40]); | |
204 | fermenter->profile_inittemp_low = atof(row[41]); | |
205 | fermenter->profile_steps = xstrcpy(row[42]); | |
206 | } | |
207 | fermenter->stage = xstrcpy(row[43]); | |
299
047ead629d4a
Accept yeast temperature limits from thermferm via MQTT. Send yeat temperature ranges to thermferm together with the beer parameters. Store yeast temperature limits in the mon_fermenters database table. The monitor fermenters screen adjusts the temperature color ranges.
Michiel Broek <mbroek@mbse.eu>
parents:
194
diff
changeset
|
208 | fermenter->yeast_lo = atof(row[45]); |
047ead629d4a
Accept yeast temperature limits from thermferm via MQTT. Send yeat temperature ranges to thermferm together with the beer parameters. Store yeast temperature limits in the mon_fermenters database table. The monitor fermenters screen adjusts the temperature color ranges.
Michiel Broek <mbroek@mbse.eu>
parents:
194
diff
changeset
|
209 | fermenter->yeast_hi = atof(row[46]); |
334
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
210 | fermenter->webcam_url = xstrcpy(row[47]); |
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
211 | fermenter->webcam_light = atoi(row[48]); |
0 | 212 | |
213 | if (fermenters == NULL) { | |
214 | fermenters = fermenter; | |
215 | } else { | |
216 | for (tmpf = fermenters; tmpf; tmpf = tmpf->next) { | |
217 | if (tmpf->next == NULL) { | |
218 | tmpf->next = fermenter; | |
219 | break; | |
220 | } | |
221 | } | |
222 | } | |
223 | fcnt++; | |
224 | } | |
225 | mysql_free_result(res_set); | |
226 | } | |
227 | } | |
228 | ||
229 | syslog(LOG_NOTICE, "MySQL: loaded %d nodes, %d fermenters", ncnt, fcnt); | |
230 | return 0; | |
231 | } | |
232 | ||
233 | ||
234 | ||
235 | void bms_mysql_end(void) | |
236 | { | |
237 | sys_fermenter_list *tmpf, *oldtmpf; | |
238 | sys_node_list *tmpn, *oldtmpn; | |
239 | ||
240 | mysql_close(con); | |
241 | ||
242 | syslog(LOG_NOTICE, "MySQL: disconnected"); | |
243 | if (debug) | |
244 | fprintf(stdout, "MySQL: disconnected\n"); | |
245 | ||
246 | for (tmpf = fermenters; tmpf; tmpf = oldtmpf) { | |
247 | oldtmpf = tmpf->next; | |
248 | if (tmpf->uuid) | |
249 | free(tmpf->uuid); | |
250 | if (tmpf->alias) | |
251 | free(tmpf->alias); | |
252 | if (tmpf->node) | |
253 | free(tmpf->node); | |
254 | if (tmpf->beercode) | |
255 | free(tmpf->beercode); | |
256 | if (tmpf->beername) | |
257 | free(tmpf->beername); | |
192
7f69b43e6084
Implemented beer uuid product in monitor fermenters.
Michiel Broek <mbroek@mbse.eu>
parents:
76
diff
changeset
|
258 | if (tmpf->beeruuid) |
7f69b43e6084
Implemented beer uuid product in monitor fermenters.
Michiel Broek <mbroek@mbse.eu>
parents:
76
diff
changeset
|
259 | free(tmpf->beeruuid); |
0 | 260 | if (tmpf->air_address) |
261 | free(tmpf->air_address); | |
262 | if (tmpf->air_state) | |
263 | free(tmpf->air_state); | |
264 | if (tmpf->beer_address) | |
265 | free(tmpf->beer_address); | |
266 | if (tmpf->beer_state) | |
267 | free(tmpf->beer_state); | |
268 | if (tmpf->chiller_address) | |
269 | free(tmpf->chiller_address); | |
270 | if (tmpf->chiller_state) | |
271 | free(tmpf->chiller_state); | |
272 | if (tmpf->heater_address) | |
273 | free(tmpf->heater_address); | |
274 | if (tmpf->cooler_address) | |
275 | free(tmpf->cooler_address); | |
276 | if (tmpf->fan_address) | |
277 | free(tmpf->fan_address); | |
278 | if (tmpf->light_address) | |
279 | free(tmpf->light_address); | |
280 | if (tmpf->door_address) | |
281 | free(tmpf->door_address); | |
282 | if (tmpf->psu_address) | |
283 | free(tmpf->psu_address); | |
284 | if (tmpf->mode) | |
285 | free(tmpf->mode); | |
286 | if (tmpf->stage) | |
287 | free(tmpf->stage); | |
288 | if (tmpf->profile_uuid) | |
289 | free(tmpf->profile_uuid); | |
290 | if (tmpf->profile_name) | |
291 | free(tmpf->profile_name); | |
292 | if (tmpf->profile_state) | |
293 | free(tmpf->profile_state); | |
294 | if (tmpf->profile_steps) | |
295 | free(tmpf->profile_steps); | |
334
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
296 | if (tmpf->webcam_url) |
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
297 | free(tmpf->webcam_url); |
0 | 298 | free(tmpf); |
299 | } | |
300 | for (tmpn = nodes; tmpn; tmpn = oldtmpn) { | |
301 | oldtmpn = tmpn->next; | |
302 | if (tmpn->uuid) | |
303 | free(tmpn->uuid); | |
304 | if (tmpn->node) | |
305 | free(tmpn->node); | |
306 | if (tmpn->group_id) | |
307 | free(tmpn->group_id); | |
308 | if (tmpn->hardwaremake) | |
309 | free(tmpn->hardwaremake); | |
310 | if (tmpn->hardwaremodel) | |
311 | free(tmpn->hardwaremodel); | |
312 | if (tmpn->os) | |
313 | free(tmpn->os); | |
314 | if (tmpn->os_version) | |
315 | free(tmpn->os_version); | |
316 | if (tmpn->firmware) | |
317 | free(tmpn->firmware); | |
318 | if (tmpn->net_address) | |
319 | free(tmpn->net_address); | |
320 | if (tmpn->net_ifname) | |
321 | free(tmpn->net_ifname); | |
322 | free(tmpn); | |
323 | } | |
324 | } | |
325 | ||
326 | ||
327 | ||
328 | void bms_mysql_ping(void) | |
329 | { | |
330 | } | |
331 | ||
332 | ||
333 | ||
334 | void node_mysql_insert(sys_node_list *node) | |
335 | { | |
76
804d45bdaa86
Increased nenory for the nodes query strings.
Michiel Broek <mbroek@mbse.eu>
parents:
43
diff
changeset
|
336 | char *query = malloc(1024), first[21], last[21]; |
0 | 337 | struct tm *mytime; |
338 | ||
339 | mytime = localtime(&node->firstseen); | |
340 | snprintf(first, 20, "%04d-%02d-%02d %02d:%02d:%02d", | |
341 | mytime->tm_year + 1900, mytime->tm_mon + 1, mytime->tm_mday, mytime->tm_hour, mytime->tm_min, mytime->tm_sec); | |
342 | mytime = localtime(&node->lastseen); | |
343 | snprintf(last, 20, "%04d-%02d-%02d %02d:%02d:%02d", | |
344 | mytime->tm_year + 1900, mytime->tm_mon + 1, mytime->tm_mday, mytime->tm_hour, mytime->tm_min, mytime->tm_sec); | |
345 | ||
76
804d45bdaa86
Increased nenory for the nodes query strings.
Michiel Broek <mbroek@mbse.eu>
parents:
43
diff
changeset
|
346 | snprintf(query, 1023, |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
347 | "INSERT INTO mon_nodes SET uuid='%s', node='%s', online='%s', group_id='%s', " \ |
0 | 348 | "hardwaremake='%s', hardwaremodel='%s', os='%s', os_version='%s', firmware='%s', firstseen='%s', lastseen='%s', " \ |
349 | "temperature='%.3f', humidity='%.3f', barometer='%.3f', gps_latitude='%.8f', gps_longitude='%.8f', gps_altitude='%.8f', " \ | |
350 | "net_address='%s', net_ifname='%s', net_rssi='%d'", | |
351 | node->uuid, node->node, node->online ?"Y":"N", node->group_id, | |
352 | node->hardwaremake, node->hardwaremodel, node->os, node->os_version, node->firmware, first, last, | |
353 | node->temperature, node->humidity, node->barometer, node->gps_latitude, node->gps_longitude, node->gps_altitude, | |
354 | node->net_address, node->net_ifname, node->net_rssi); | |
355 | ||
356 | if (mysql_query(con, query)) { | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
357 | syslog(LOG_NOTICE, "MySQL: INSERT INTO mon_nodes error %u (%s))", mysql_errno(con), mysql_error(con)); |
0 | 358 | } else { |
359 | syslog(LOG_NOTICE, "MySQL: insert new node %s", node->node); | |
360 | } | |
361 | ||
362 | free(query); | |
363 | } | |
364 | ||
365 | ||
366 | ||
367 | void node_mysql_update(sys_node_list *node) | |
368 | { | |
76
804d45bdaa86
Increased nenory for the nodes query strings.
Michiel Broek <mbroek@mbse.eu>
parents:
43
diff
changeset
|
369 | char *query = malloc(1024), last[21]; |
0 | 370 | struct tm *mytime; |
371 | ||
372 | mytime = localtime(&node->lastseen); | |
373 | snprintf(last, 20, "%04d-%02d-%02d %02d:%02d:%02d", | |
374 | mytime->tm_year + 1900, mytime->tm_mon + 1, mytime->tm_mday, mytime->tm_hour, mytime->tm_min, mytime->tm_sec); | |
375 | ||
76
804d45bdaa86
Increased nenory for the nodes query strings.
Michiel Broek <mbroek@mbse.eu>
parents:
43
diff
changeset
|
376 | snprintf(query, 1023, |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
377 | "UPDATE mon_nodes SET online='%s', hardwaremake='%s', hardwaremodel='%s', os='%s', os_version='%s', firmware='%s', lastseen='%s', " \ |
0 | 378 | "temperature='%.3f', humidity='%.3f', barometer='%.3f', gps_latitude='%.8f', gps_longitude='%.8f', gps_altitude='%.8f', " \ |
379 | "net_address='%s', net_ifname='%s', net_rssi='%d' WHERE uuid='%s'", | |
380 | node->online ?"Y":"N", node->hardwaremake, node->hardwaremodel, node->os, node->os_version, node->firmware, last, | |
381 | node->temperature, node->humidity, node->barometer, node->gps_latitude, node->gps_longitude, node->gps_altitude, | |
382 | node->net_address, node->net_ifname, node->net_rssi, node->uuid); | |
383 | ||
384 | if (mysql_query(con, query)) { | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
385 | syslog(LOG_NOTICE, "MySQL: UPDATE mon_nodes error %u (%s))", mysql_errno(con), mysql_error(con)); |
0 | 386 | } |
387 | ||
388 | free(query); | |
389 | } | |
390 | ||
391 | ||
392 | ||
393 | void node_mysql_death(char *node) | |
394 | { | |
395 | char *query = malloc(512); | |
396 | ||
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
397 | snprintf(query, 511, "UPDATE mon_nodes SET online='N' WHERE node='%s'", node); |
0 | 398 | // printf("%s\n", query); |
399 | ||
400 | if (mysql_query(con, query)) { | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
401 | syslog(LOG_NOTICE, "MySQL: UPDATE mon_nodes error %u (%s))", mysql_errno(con), mysql_error(con)); |
0 | 402 | } |
403 | ||
404 | free(query); | |
405 | } | |
406 | ||
407 | ||
408 | ||
409 | void fermenter_mysql_insert(sys_fermenter_list *fermenter) | |
410 | { | |
411 | char *query = malloc(2560); | |
412 | ||
413 | snprintf(query, 2559, | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
414 | "INSERT INTO mon_fermenters SET uuid='%s', alias='%s', node='%s', online='%s', " \ |
192
7f69b43e6084
Implemented beer uuid product in monitor fermenters.
Michiel Broek <mbroek@mbse.eu>
parents:
76
diff
changeset
|
415 | "beercode='%s', beername='%s', beeruuid='%s', " \ |
0 | 416 | "air_address='%s', air_state='%s', air_temperature='%.3f', " \ |
417 | "beer_address='%s', beer_state='%s', beer_temperature='%.3f', " \ | |
418 | "chiller_address='%s', chiller_state='%s', chiller_temperature='%.3f', " \ | |
419 | "heater_address='%s', heater_state='%d', heater_usage='%lu', " \ | |
420 | "cooler_address='%s', cooler_state='%d', cooler_usage='%lu', " \ | |
421 | "fan_address='%s', fan_state='%d', fan_usage='%lu', " \ | |
422 | "light_address='%s', light_state='%d', light_usage='%lu', " \ | |
423 | "door_address='%s', door_state='%d', " \ | |
424 | "psu_address='%s', psu_state='%d', " \ | |
425 | "mode='%s', alarm='%d', setpoint_high='%.3f', setpoint_low='%.3f', " \ | |
426 | "profile_uuid='%s', profile_name='%s', profile_state='%s', profile_percent='%d', " \ | |
299
047ead629d4a
Accept yeast temperature limits from thermferm via MQTT. Send yeat temperature ranges to thermferm together with the beer parameters. Store yeast temperature limits in the mon_fermenters database table. The monitor fermenters screen adjusts the temperature color ranges.
Michiel Broek <mbroek@mbse.eu>
parents:
194
diff
changeset
|
427 | "profile_inittemp_high='%.3f', profile_inittemp_low='%.3f', profile_steps='%s', stage='%s', " \ |
334
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
428 | "yeast_lo='%.1f', yeast_hi='%.1f', webcam_url='%s', webcam_light='%d'", |
0 | 429 | fermenter->uuid, fermenter->alias, fermenter->node, fermenter->online ? "Y":"N", |
430 | fermenter->beercode ? fermenter->beercode : "", fermenter->beername ? fermenter->beername : "", | |
192
7f69b43e6084
Implemented beer uuid product in monitor fermenters.
Michiel Broek <mbroek@mbse.eu>
parents:
76
diff
changeset
|
431 | fermenter->beeruuid ? fermenter->beeruuid : "", |
0 | 432 | fermenter->air_address ? fermenter->air_address : "", fermenter->air_state ? fermenter->air_state : "", fermenter->air_temperature, |
433 | fermenter->beer_address ? fermenter->beer_address : "", fermenter->beer_state ? fermenter->beer_state : "", fermenter->beer_temperature, | |
434 | fermenter->chiller_address ? fermenter->chiller_address : "", fermenter->chiller_state ? fermenter->chiller_state : "", fermenter->chiller_temperature, | |
435 | fermenter->heater_address ? fermenter->heater_address : "", fermenter->heater_state, fermenter->heater_usage, | |
436 | fermenter->cooler_address ? fermenter->cooler_address : "", fermenter->cooler_state, fermenter->cooler_usage, | |
437 | fermenter->fan_address ? fermenter->fan_address : "", fermenter->fan_state, fermenter->fan_usage, | |
438 | fermenter->light_address ? fermenter->light_address : "", fermenter->light_state, fermenter->light_usage, | |
439 | fermenter->door_address ? fermenter->door_address : "", fermenter->door_state, | |
440 | fermenter->psu_address ? fermenter->psu_address : "", fermenter->psu_state, | |
441 | fermenter->mode, fermenter->alarm, fermenter->setpoint_high, fermenter->setpoint_low, | |
442 | fermenter->profile_uuid ? fermenter->profile_uuid : "", fermenter->profile_name ? fermenter->profile_name : "", | |
443 | fermenter->profile_state ? fermenter->profile_state : "", fermenter->profile_percent, | |
444 | fermenter->profile_inittemp_high, fermenter->profile_inittemp_low, | |
334
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
445 | fermenter->profile_steps ? fermenter->profile_steps : "", fermenter->stage, fermenter->yeast_lo, fermenter->yeast_hi, |
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
446 | fermenter->webcam_url ? fermenter->webcam_url : "", fermenter->webcam_light); |
0 | 447 | |
448 | // printf("%s\n", query); | |
449 | ||
450 | if (mysql_query(con, query)) { | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
451 | syslog(LOG_NOTICE, "MySQL: INSERT INTO mon_fermenters error %u (%s))", mysql_errno(con), mysql_error(con)); |
0 | 452 | } else { |
453 | syslog(LOG_NOTICE, "MySQL: insert new fermenter %s/%s", fermenter->node, fermenter->alias); | |
454 | } | |
455 | ||
456 | free(query); | |
457 | } | |
458 | ||
459 | ||
460 | void fermenter_mysql_update(sys_fermenter_list *fermenter) | |
461 | { | |
462 | char *query = malloc(2560); | |
463 | ||
464 | snprintf(query, 2559, | |
192
7f69b43e6084
Implemented beer uuid product in monitor fermenters.
Michiel Broek <mbroek@mbse.eu>
parents:
76
diff
changeset
|
465 | "UPDATE mon_fermenters SET online='%s', beercode='%s', beername='%s', beeruuid='%s', " \ |
0 | 466 | "air_address='%s', air_state='%s', air_temperature='%.3f', " \ |
467 | "beer_address='%s', beer_state='%s', beer_temperature='%.3f', " \ | |
468 | "chiller_address='%s', chiller_state='%s', chiller_temperature='%.3f', " \ | |
469 | "heater_address='%s', heater_state='%d', heater_usage='%lu', " \ | |
470 | "cooler_address='%s', cooler_state='%d', cooler_usage='%lu', " \ | |
471 | "fan_address='%s', fan_state='%d', fan_usage='%lu', " \ | |
472 | "light_address='%s', light_state='%d', light_usage='%lu', " \ | |
473 | "door_address='%s', door_state='%d', " \ | |
474 | "psu_address='%s', psu_state='%d', " \ | |
475 | "mode='%s', alarm='%d', setpoint_high='%.3f', setpoint_low='%.3f', " \ | |
476 | "profile_uuid='%s', profile_name='%s', profile_state='%s', profile_percent='%d', " \ | |
299
047ead629d4a
Accept yeast temperature limits from thermferm via MQTT. Send yeat temperature ranges to thermferm together with the beer parameters. Store yeast temperature limits in the mon_fermenters database table. The monitor fermenters screen adjusts the temperature color ranges.
Michiel Broek <mbroek@mbse.eu>
parents:
194
diff
changeset
|
477 | "profile_inittemp_high='%.3f', profile_inittemp_low='%.3f', profile_steps='%s', stage='%s', " \ |
334
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
478 | "yeast_lo='%.1f', yeast_hi='%.1f', webcam_url='%s', webcam_light='%d' WHERE uuid='%s'", |
0 | 479 | fermenter->online ? "Y":"N", fermenter->beercode ? fermenter->beercode : "", fermenter->beername ? fermenter->beername : "", |
192
7f69b43e6084
Implemented beer uuid product in monitor fermenters.
Michiel Broek <mbroek@mbse.eu>
parents:
76
diff
changeset
|
480 | fermenter->beeruuid ? fermenter->beeruuid : "", |
0 | 481 | fermenter->air_address ? fermenter->air_address : "", fermenter->air_state ? fermenter->air_state : "", fermenter->air_temperature, |
482 | fermenter->beer_address ? fermenter->beer_address : "", fermenter->beer_state ? fermenter->beer_state : "", fermenter->beer_temperature, | |
483 | fermenter->chiller_address ? fermenter->chiller_address : "", fermenter->chiller_state ? fermenter->chiller_state : "", fermenter->chiller_temperature, | |
484 | fermenter->heater_address ? fermenter->heater_address : "", fermenter->heater_state, fermenter->heater_usage, | |
485 | fermenter->cooler_address ? fermenter->cooler_address : "", fermenter->cooler_state, fermenter->cooler_usage, | |
486 | fermenter->fan_address ? fermenter->fan_address : "", fermenter->fan_state, fermenter->fan_usage, | |
487 | fermenter->light_address ? fermenter->light_address : "", fermenter->light_state, fermenter->light_usage, | |
488 | fermenter->door_address ? fermenter->door_address : "", fermenter->door_state, | |
489 | fermenter->psu_address ? fermenter->psu_address : "", fermenter->psu_state, | |
490 | fermenter->mode, fermenter->alarm, fermenter->setpoint_high, fermenter->setpoint_low, | |
491 | fermenter->profile_uuid ? fermenter->profile_uuid : "", fermenter->profile_name ? fermenter->profile_name : "", | |
492 | fermenter->profile_state ? fermenter->profile_state : "", fermenter->profile_percent, | |
493 | fermenter->profile_inittemp_high, fermenter->profile_inittemp_low, | |
334
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
494 | fermenter->profile_steps ? fermenter->profile_steps : "", fermenter->stage, fermenter->yeast_lo, fermenter->yeast_hi, |
26c6f8e5d58e
Added webcam_url and webcam_light fields to the mon_fermenters database table. Currently these fields need to be set using phpMyAdmin or another tool. If the webcam_url field is set, then on the mon_fermenter webpage a button is added to show a webcam page.
Michiel Broek <mbroek@mbse.eu>
parents:
299
diff
changeset
|
495 | fermenter->webcam_url ? fermenter->webcam_url : "", fermenter->webcam_light, fermenter->uuid); |
0 | 496 | |
497 | // printf("%s\n", query); | |
498 | ||
499 | if (mysql_query(con, query)) { | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
500 | syslog(LOG_NOTICE, "MySQL: UPDATE mon_fermenters error %u (%s))", mysql_errno(con), mysql_error(con)); |
0 | 501 | } |
502 | ||
503 | free(query); | |
504 | } | |
505 | ||
506 | ||
507 | ||
508 | void fermenter_mysql_death(char *node, char *alias) | |
509 | { | |
510 | char *query = malloc(512); | |
511 | ||
512 | if (alias) | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
513 | snprintf(query, 511, "UPDATE mon_fermenters SET online='N' WHERE node='%s' and alias='%s'", node, alias); |
0 | 514 | else |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
515 | snprintf(query, 511, "UPDATE mon_fermenters SET online='N' WHERE node='%s'", node); |
0 | 516 | |
517 | if (mysql_query(con, query)) { | |
43
dcb9ff8846fa
Renamed monitor database tables
Michiel Broek <mbroek@mbse.eu>
parents:
0
diff
changeset
|
518 | syslog(LOG_NOTICE, "MySQL: UPDATE mon_fermenters error %u (%s))", mysql_errno(con), mysql_error(con)); |
0 | 519 | } |
520 | ||
521 | free(query); | |
522 | } | |
523 | ||
524 |