90 |
90 |
91 } else { |
91 } else { |
92 /* |
92 /* |
93 * Insert splitted batches |
93 * Insert splitted batches |
94 */ |
94 */ |
|
95 $uuid = str_replace("\n", "", file_get_contents('/proc/sys/kernel/random/uuid')); |
95 $sql = "INSERT INTO `products` SET "; |
96 $sql = "INSERT INTO `products` SET "; |
96 $sql .= "name='" . mysqli_real_escape_string($link, $split['name']); |
97 $sql .= "name='" . mysqli_real_escape_string($link, $split['name']); |
97 $sql .= "', uuid='" . str_replace("\n", "", file_get_contents('/proc/sys/kernel/random/uuid')); |
98 $sql .= "', uuid='" . $uuid; |
98 $sql .= "', code='" . mysqli_real_escape_string($link, $split['code']); |
99 $sql .= "', code='" . mysqli_real_escape_string($link, $split['code']); |
99 $sql .= "', birth='" . $row['birth']; |
100 $sql .= "', birth='" . $row['birth']; |
100 $sql .= "', stage='" . $row['stage']; |
101 $sql .= "', stage='" . $row['stage']; |
101 $sql .= "', notes='" . mysqli_real_escape_string($link, $row['notes']); |
102 $sql .= "', notes='" . mysqli_real_escape_string($link, $row['notes']); |
102 $sql .= "', log_brew='" . $row['log_brew']; |
103 $sql .= "', log_brew='" . $row['log_brew']; |
375 $rc = 1; |
376 $rc = 1; |
376 break; |
377 break; |
377 } else { |
378 } else { |
378 $lastid = mysqli_insert_id($link); |
379 $lastid = mysqli_insert_id($link); |
379 syslog(LOG_NOTICE, "db_divide: inserted record ".$lastid." code ".$split['code']); |
380 syslog(LOG_NOTICE, "db_divide: inserted record ".$lastid." code ".$split['code']); |
|
381 /* Copy brew log records */ |
|
382 if ($row['log_brew'] == '1') { |
|
383 $result3 = mysqli_query($link, "SELECT * FROM log_brews WHERE code='" . $row['code'] . "'"); |
|
384 if (! $result3) { |
|
385 syslog(LOG_NOTICE, "db_divide: result3: ".mysqli_error($link)); |
|
386 } |
|
387 while ($row3 = mysqli_fetch_array($result3)) { |
|
388 $sql3 = "INSERT INTO log_brews SET datetime='" . $row3['datetime']; |
|
389 $sql3 .= "', version='" . $row3['version']; |
|
390 $sql3 .= "', uuid='" . $uuid; |
|
391 $sql3 .= "', code='" . mysqli_real_escape_string($link, $split['code']); |
|
392 $sql3 .= "', name='" . mysqli_real_escape_string($link, $split['name']); |
|
393 $sql3 .= "', pv_mlt='" . $row3['pv_mlt']; |
|
394 $sql3 .= "', pv_hlt='" . $row3['pv_hlt']; |
|
395 $sql3 .= "', pv_room='" . $row3['pv_room']; |
|
396 $sql3 .= "', sp_mlt='" . $row3['sp_mlt']; |
|
397 $sql3 .= "', sp_hlt='" . $row3['sp_hlt']; |
|
398 $sql3 .= "', pwm_mlt='" . $row3['pwm_mlt']; |
|
399 $sql3 .= "', pwm_hlt='" . $row3['pwm_hlt']; |
|
400 $sql3 .= "', event='" . $row3['event'] . "';"; |
|
401 $result4 = mysqli_query($link, $sql3); |
|
402 if (! $result4) { |
|
403 syslog(LOG_NOTICE, "db_divide: result4: ".mysqli_error($link)." ".$sql3); |
|
404 } |
|
405 } |
|
406 } |
380 } |
407 } |
381 } |
408 } |
382 |
409 |
383 } |
410 } |
384 syslog(LOG_NOTICE, "db_divide: rc=".$rc); |
411 syslog(LOG_NOTICE, "db_divide: rc=".$rc); |