comparison: www/includes/db_divides.php
www/includes/db_divides.php
- changeset 835
- ca6b3d4f5a97
- parent 834
- 00e610fc3571
- child 836
- 409f8c497429
equal
deleted
inserted
replaced
| 834:00e610fc3571 | 835:ca6b3d4f5a97 |
|---|---|
| 1 <?php | |
| 2 | |
| 3 require($_SERVER['DOCUMENT_ROOT']."/config.php"); | |
| 4 require($_SERVER['DOCUMENT_ROOT']."/version.php"); | |
| 5 | |
| 6 #Connect to the database | |
| 7 $link = mysqli_connect(DBASE_HOST, DBASE_USER, DBASE_PASS, DBASE_NAME); | |
| 8 if (! $link) { | |
| 9 die('Connect Error (' . mysqli_connect_errno() . ') ' . mysqli_connect_error()); | |
| 10 } | |
| 11 mysqli_set_charset($link, "utf8" ); | |
| 12 | |
| 13 $escapers = array("\\", "/", "\"", "\n", "\r", "\t", "\x08", "\x0c"); | |
| 14 $replacements = array("\\\\", "\\/", "\\\"", "\\n", "\\r", "\\t", "\\f", "\\b"); | |
| 15 $rescapers = array("'"); | |
| 16 $rreplacements = array("\\'"); | |
| 17 $disallowed = array('visibleindex','uniqueid','boundindex','uid','h_weight','m_weight'); | |
| 18 | |
| 19 $response = array( | |
| 20 'error' => false, | |
| 21 'msg' => 'Ok', | |
| 22 ); | |
| 23 | |
| 24 /* | |
| 25 * Server side split batch. Parameters: | |
| 26 * record = original record. | |
| 27 * divide_type = divide moment. | |
| 28 * divide parts = number of divisions | |
| 29 * divide_data = array with { size, factor, part, name, code } where index 0 is original | |
| 30 * | |
| 31 * generate the new records and modify the original record. | |
| 32 * rollback if something goes wrong. | |
| 33 * return ok or error | |
| 34 */ | |
| 35 | |
| 36 if (isset($_POST['record']) && isset($_POST['divide_type']) && isset($_POST['divide_parts']) && isset($_POST['divide_data'])) { | |
| 37 | |
| 38 $record = $_POST['record']; | |
| 39 $divide_parts = $_POST['divide_parts']; | |
| 40 $divide_type = $_POST['divide_type']; | |
| 41 $divide_data = array_reverse($_POST['divide_data'], true); // reverse the array so the master record is last. | |
| 42 | |
| 43 syslog(LOG_NOTICE, "db_divide: record " . $record . " divide_type " . $divide_type . " parts " . $divide_parts); | |
| 44 | |
| 45 foreach ($divide_data as $index => &$split) { | |
| 46 syslog(LOG_NOTICE, "db_divide: index " . $index); | |
| 47 | |
| 48 foreach ($split as $key => &$value) { | |
| 49 syslog(LOG_NOTICE, "db_divide: index " . $index . " key " . $key . " value " . $value); | |
| 50 } | |
| 51 | |
| 52 $result = mysqli_query($link, "SELECT * FROM products WHERE record='" . $record . "'"); | |
| 53 if (! $result) { | |
| 54 syslog(LOG_NOTICE, "db_divide: result: ".mysqli_error($link)); | |
| 55 } | |
| 56 $row = mysqli_fetch_array($result); | |
| 57 $factor = floatval($split['factor']); | |
| 58 | |
| 59 if ($index == 0) { | |
| 60 /* | |
| 61 * Update the main record | |
| 62 */ | |
| 63 $sql = "UPDATE `products` SET "; | |
| 64 $sql .= " brew_sparge_est='" . sprintf("%.1f", $row['brew_sparge_est'] * $factor); | |
| 65 $sql .= "', brew_preboil_volume='" . sprintf("%.1f", $row['brew_preboil_volume'] * $factor); | |
| 66 $sql .= "', brew_aboil_volume='" . sprintf("%.1f", $row['brew_aboil_volume'] * $factor); | |
| 67 $sql .= "', brew_fermenter_volume='" . sprintf("%.1f", $row['brew_fermenter_volume'] * $factor); | |
| 68 $sql .= "', brew_fermenter_extrawater='" . sprintf("%.1f", $row['brew_fermenter_extrawater'] * $factor); | |
| 69 $sql .= "', brew_fermenter_tcloss='" . sprintf("%.1f", $row['brew_fermenter_tcloss'] * $factor); | |
| 70 $sql .= "', package_volume='" . sprintf("%.1f", $row['package_volume'] * $factor); | |
| 71 $sql .= "', package_infuse_amount='" . sprintf("%.1f", $row['package_infuse_amount'] * $factor); | |
| 72 $sql .= "', bottle_amount='" . sprintf("%.1f", $row['bottle_amount'] * $factor); | |
| 73 $sql .= "', bottle_priming_water='" . sprintf("%.3f", $row['bottle_priming_water'] * $factor); | |
| 74 $sql .= "', keg_amount='" . sprintf("%.1f", $row['keg_amount'] * $factor); | |
| 75 $sql .= "', keg_priming_water='" . sprintf("%.3f", $row['keg_priming_water'] * $factor); | |
| 76 $sql .= "', batch_size='" . sprintf("%.2f", $row['batch_size'] * $factor); | |
| 77 $sql .= "', boil_size='" . sprintf("%.2f", $row['boil_size'] * $factor); | |
| 78 $sql .= "', sparge_volume='" . sprintf("%.1f", $row['sparge_volume'] * $factor); | |
| 79 $sql .= "', sparge_acid_amount='" . sprintf("%.5f", $row['sparge_acid_amount'] * $factor); | |
| 80 $sql .= "', w1_amount='" . sprintf("%.2f", $row['w1_amount'] * $factor); | |
| 81 $sql .= "', w2_amount='" . sprintf("%.2f", $row['w2_amount'] * $factor); | |
| 82 $sql .= "', wg_amount='" . sprintf("%.2f", $row['wg_amount'] * $factor); | |
| 83 $sql .= "', prop1_volume='" . sprintf("%.3f", $row['prop1_volume'] * $factor); | |
| 84 $sql .= "', prop2_volume='" . sprintf("%.3f", $row['prop2_volume'] * $factor); | |
| 85 $sql .= "', prop3_volume='" . sprintf("%.3f", $row['prop3_volume'] * $factor); | |
| 86 $sql .= "', prop4_volume='" . sprintf("%.3f", $row['prop4_volume'] * $factor); | |
| 87 $sql .= "', divide_type='" . $divide_type; | |
| 88 $sql .= "', divide_parts='" . $divide_parts; | |
| 89 $sql .= "', divide_part='" . $index; | |
| 90 $sql .= "', divide_size='" . floatval($split['size']); | |
| 91 $sql .= "', divide_factor='". $factor; | |
| 92 // syslog(LOG_NOTICE, "db_divide: index " . $index . " " . $sql); | |
| 93 | |
| 94 } else { | |
| 95 /* | |
| 96 * Insert splitted batches | |
| 97 */ | |
| 98 $uuid = str_replace("\n", "", file_get_contents('/proc/sys/kernel/random/uuid')); | |
| 99 $sql = "INSERT INTO `products` SET "; | |
| 100 $sql .= "name='" . mysqli_real_escape_string($link, $split['name']); | |
| 101 $sql .= "', uuid='" . $uuid; | |
| 102 $sql .= "', code='" . mysqli_real_escape_string($link, $split['code']); | |
| 103 $sql .= "', birth='" . $row['birth']; | |
| 104 $sql .= "', stage='" . $row['stage']; | |
| 105 $sql .= "', notes='" . mysqli_real_escape_string($link, $row['notes']); | |
| 106 $sql .= "', log_brew='" . $row['log_brew']; | |
| 107 $sql .= "', log_fermentation='" . $row['log_fermentation']; | |
| 108 $sql .= "', log_ispindel='" . $row['log_ispindel']; | |
| 109 $sql .= "', log_co2pressure='" . $row['log_co2pressure']; | |
| 110 $sql .= "', inventory_reduced='" . $row['inventory_reduced'];; | |
| 111 $sql .= "', locked='" . $row['locked'];; | |
| 112 // Equipment | |
| 113 $sql .= "', eq_name='" . mysqli_real_escape_string($link, $row['eq_name']); | |
| 114 $sql .= "', eq_boil_size='" . $row['eq_boil_size']; | |
| 115 $sql .= "', eq_batch_size='" . $row['eq_batch_size']; | |
| 116 $sql .= "', eq_tun_volume='" . $row['eq_tun_volume']; | |
| 117 $sql .= "', eq_tun_weight='" . $row['eq_tun_weight']; | |
| 118 $sql .= "', eq_tun_specific_heat='" . $row['eq_tun_specific_heat']; | |
| 119 $sql .= "', eq_tun_material='" . $row['eq_tun_material']; | |
| 120 $sql .= "', eq_tun_height='" . $row['eq_tun_height']; | |
| 121 $sql .= "', eq_top_up_water='" . $row['eq_top_up_water']; | |
| 122 $sql .= "', eq_trub_chiller_loss='" . $row['eq_trub_chiller_loss']; | |
| 123 $sql .= "', eq_evap_rate='" . $row['eq_evap_rate']; | |
| 124 $sql .= "', eq_boil_time='" . $row['eq_boil_time']; | |
| 125 $sql .= "', eq_calc_boil_volume='" . $row['eq_calc_boil_volume']; | |
| 126 $sql .= "', eq_top_up_kettle='" . $row['eq_top_up_kettle']; | |
| 127 $sql .= "', eq_hop_utilization='" . $row['eq_hop_utilization']; | |
| 128 $sql .= "', eq_notes='" . mysqli_real_escape_string($link, $row['eq_notes']); | |
| 129 $sql .= "', eq_lauter_volume='" . $row['eq_lauter_volume']; | |
| 130 $sql .= "', eq_lauter_height='" . $row['eq_lauter_height']; | |
| 131 $sql .= "', eq_lauter_deadspace='" . $row['eq_lauter_deadspace']; | |
| 132 $sql .= "', eq_kettle_volume='" . $row['eq_kettle_volume']; | |
| 133 $sql .= "', eq_kettle_height='" . $row['eq_kettle_height']; | |
| 134 $sql .= "', eq_mash_volume='" . $row['eq_mash_volume']; | |
| 135 $sql .= "', eq_mash_max='" . $row['eq_mash_max']; | |
| 136 $sql .= "', eq_efficiency='" . $row['eq_efficiency']; | |
| 137 // brewdate | |
| 138 if (strlen($row['brew_date_start'])) | |
| 139 $sql .= "', brew_date_start='" . $row['brew_date_start'] . "'"; | |
| 140 else | |
| 141 $sql .= "', brew_date_start=NULL"; | |
| 142 $sql .= ", brew_mash_ph='" . $row['brew_mash_ph']; | |
| 143 $sql .= "', brew_mash_sg='" . $row['brew_mash_sg']; | |
| 144 $sql .= "', brew_mash_efficiency='" . $row['brew_mash_efficiency']; | |
| 145 $sql .= "', brew_sparge_est='" . sprintf("%.1f", $row['brew_sparge_est'] * $factor); | |
| 146 $sql .= "', brew_sparge_ph='" . $row['brew_sparge_ph']; | |
| 147 $sql .= "', brew_preboil_volume='" . sprintf("%.1f", $row['brew_preboil_volume'] * $factor); | |
| 148 $sql .= "', brew_preboil_sg='" . $row['brew_preboil_sg']; | |
| 149 $sql .= "', brew_preboil_ph='" . $row['brew_preboil_ph']; | |
| 150 $sql .= "', brew_preboil_efficiency='" . $row['brew_preboil_efficiency']; | |
| 151 $sql .= "', brew_aboil_volume='" . sprintf("%.1f", $row['brew_aboil_volume'] * $factor); | |
| 152 $sql .= "', brew_aboil_sg='" . $row['brew_aboil_sg']; | |
| 153 $sql .= "', brew_aboil_ph='" . $row['brew_aboil_ph']; | |
| 154 $sql .= "', brew_aboil_efficiency='" . $row['brew_aboil_efficiency']; | |
| 155 $sql .= "', brew_cooling_method='" . $row['brew_cooling_method']; | |
| 156 $sql .= "', brew_cooling_time='" . $row['brew_cooling_time']; | |
| 157 $sql .= "', brew_cooling_to='" . $row['brew_cooling_to']; | |
| 158 $sql .= "', brew_whirlpool9='" . $row['brew_whirlpool9']; | |
| 159 $sql .= "', brew_whirlpool7='" . $row['brew_whirlpool7']; | |
| 160 $sql .= "', brew_whirlpool6='" . $row['brew_whirlpool6']; | |
| 161 $sql .= "', brew_whirlpool2='" . $row['brew_whirlpool2']; | |
| 162 $sql .= "', brew_aeration_time='" . $row['brew_aeration_time']; | |
| 163 $sql .= "', brew_aeration_speed='" . $row['brew_aeration_speed']; | |
| 164 $sql .= "', brew_aeration_type='" . $row['brew_aeration_type']; | |
| 165 $sql .= "', brew_fermenter_volume='" . sprintf("%.1f", $row['brew_fermenter_volume'] * $factor); | |
| 166 $sql .= "', brew_fermenter_extrawater='" . sprintf("%.1f", $row['brew_fermenter_extrawater'] * $factor); | |
| 167 $sql .= "', brew_fermenter_tcloss='" . sprintf("%.1f", $row['brew_fermenter_tcloss'] * $factor); | |
| 168 $sql .= "', brew_fermenter_sg='" . $row['brew_fermenter_sg']; | |
| 169 $sql .= "', brew_fermenter_ibu='" . $row['brew_fermenter_ibu']; | |
| 170 $sql .= "', brew_fermenter_color='" . $row['brew_fermenter_color']; | |
| 171 if (strlen($row['brew_date_end'])) | |
| 172 $sql .= "', brew_date_end='" . $row['brew_date_end'] . "'"; | |
| 173 else | |
| 174 $sql .= "', brew_date_end=NULL"; | |
| 175 $sql .= ", og='" . $row['og']; | |
| 176 $sql .= "', fg='" . $row['fg']; | |
| 177 $sql .= "', primary_start_temp='" . $row['primary_start_temp']; | |
| 178 $sql .= "', primary_max_temp='" . $row['primary_max_temp']; | |
| 179 $sql .= "', primary_end_temp='" . $row['primary_end_temp']; | |
| 180 if (strlen($row['primary_end_date'])) | |
| 181 $sql .= "', primary_end_date='" . $row['primary_end_date'] . "'"; | |
| 182 else | |
| 183 $sql .= "', primary_end_date=NULL"; | |
| 184 $sql .= ", primary_end_sg='" . $row['primary_end_sg']; | |
| 185 $sql .= "', secondary_temp='" . $row['secondary_temp']; | |
| 186 $sql .= "', secondary_end_sg='" . $row['secondary_end_sg']; | |
| 187 if (strlen($row['secondary_end_date'])) | |
| 188 $sql .= "', secondary_end_date='" . $row['secondary_end_date'] . "'"; | |
| 189 else | |
| 190 $sql .= "', secondary_end_date=NULL"; | |
| 191 $sql .= ", tertiary_temp='" . $row['tertiary_temp']; | |
| 192 if (strlen($row['package_date'])) | |
| 193 $sql .= "', package_date='" . $row['package_date'] . "'"; | |
| 194 else | |
| 195 $sql .= "', package_date=NULL"; | |
| 196 $sql .= ", package_volume='" . sprintf("%.1f", $row['package_volume'] * $factor); | |
| 197 $sql .= "', package_infuse_amount='" . sprintf("%.1f", $row['package_infuse_amount'] * $factor); | |
| 198 $sql .= "', package_infuse_abv='" . $row['package_infuse_abv']; | |
| 199 $sql .= "', package_infuse_notes='" . mysqli_real_escape_string($link, $row['package_infuse_notes']); | |
| 200 $sql .= "', package_abv='" . $row['package_abv']; | |
| 201 $sql .= "', package_ph='" . $row['package_ph']; | |
| 202 $sql .= "', bottle_amount='" . sprintf("%.1f", $row['bottle_amount'] * $factor); | |
| 203 $sql .= "', bottle_carbonation='" . $row['bottle_carbonation']; | |
| 204 $sql .= "', bottle_priming_sugar='" . $row['bottle_priming_sugar']; | |
| 205 $sql .= "', bottle_priming_water='" . sprintf("%.3f", $row['bottle_priming_water'] * $factor); | |
| 206 $sql .= "', bottle_priming_amount='" . $row['bottle_priming_amount']; | |
| 207 $sql .= "', bottle_carbonation_temp='" . $row['bottle_carbonation_temp']; | |
| 208 $sql .= "', keg_amount='" . sprintf("%.1f", $row['keg_amount'] * $factor); | |
| 209 $sql .= "', keg_carbonation='" . $row['keg_carbonation']; | |
| 210 $sql .= "', keg_priming_sugar='" . $row['keg_priming_sugar']; | |
| 211 $sql .= "', keg_priming_water='" . sprintf("%.3f", $row['keg_priming_water'] * $factor); | |
| 212 $sql .= "', keg_priming_amount='" . $row['keg_priming_amount']; | |
| 213 $sql .= "', keg_carbonation_temp='" . $row['keg_carbonation_temp']; | |
| 214 $sql .= "', keg_forced_carb='" . $row['keg_forced_carb']; | |
| 215 $sql .= "', keg_pressure='" . $row['keg_pressure']; | |
| 216 $sql .= "', taste_notes='"; | |
| 217 $sql .= "', taste_rate='0"; | |
| 218 $sql .= "', taste_date=NULL"; | |
| 219 $sql .= ", taste_color='"; | |
| 220 $sql .= "', taste_transparency='"; | |
| 221 $sql .= "', taste_head='"; | |
| 222 $sql .= "', taste_aroma='"; | |
| 223 $sql .= "', taste_taste='"; | |
| 224 $sql .= "', taste_mouthfeel='"; | |
| 225 $sql .= "', taste_aftertaste='"; | |
| 226 // Style | |
| 227 $sql .= "', st_name='" . mysqli_real_escape_string($link, $row['st_name']); | |
| 228 $sql .= "', st_letter='" . mysqli_real_escape_string($link, $row['st_letter']); | |
| 229 $sql .= "', st_guide='" . mysqli_real_escape_string($link, $row['st_guide']); | |
| 230 $sql .= "', st_type='" . $row['st_type']; | |
| 231 $sql .= "', st_category='" . mysqli_real_escape_string($link, $row['st_category']); | |
| 232 $sql .= "', st_category_number='" . $row['st_category_number']; | |
| 233 $sql .= "', st_og_min='" . $row['st_og_min']; | |
| 234 $sql .= "', st_og_max='" . $row['st_og_max']; | |
| 235 $sql .= "', st_fg_min='" . $row['st_fg_min']; | |
| 236 $sql .= "', st_fg_max='" . $row['st_fg_max']; | |
| 237 $sql .= "', st_ibu_min='" . $row['st_ibu_min']; | |
| 238 $sql .= "', st_ibu_max='" . $row['st_ibu_max']; | |
| 239 $sql .= "', st_color_min='" . $row['st_color_min']; | |
| 240 $sql .= "', st_color_max='" . $row['st_color_max']; | |
| 241 $sql .= "', st_carb_min='" . $row['st_carb_min']; | |
| 242 $sql .= "', st_carb_max='" . $row['st_carb_max']; | |
| 243 $sql .= "', st_abv_min='" . $row['st_abv_min']; | |
| 244 $sql .= "', st_abv_max='" . $row['st_abv_max']; | |
| 245 $sql .= "', type='" . $row['type']; | |
| 246 $sql .= "', batch_size='" . sprintf("%.2f", $row['batch_size'] * $factor); | |
| 247 $sql .= "', boil_size='" . sprintf("%.2f", $row['boil_size'] * $factor); | |
| 248 $sql .= "', boil_time='" . $row['boil_time']; | |
| 249 $sql .= "', efficiency='" . $row['efficiency']; | |
| 250 $sql .= "', est_og='" . $row['est_og']; | |
| 251 $sql .= "', est_og3='" . $row['est_og3']; | |
| 252 $sql .= "', est_fg='" . $row['est_fg']; | |
| 253 $sql .= "', est_abv='" . $row['est_abv']; | |
| 254 $sql .= "', est_carb='" . $row['est_carb']; | |
| 255 $sql .= "', est_color='" . $row['est_color']; | |
| 256 $sql .= "', color_method='" . $row['color_method']; | |
| 257 $sql .= "', est_ibu='" . $row['est_ibu']; | |
| 258 $sql .= "', ibu_method='" . $row['ibu_method']; | |
| 259 $sql .= "', sparge_volume='" . sprintf("%.1f", $row['sparge_volume'] * $factor); | |
| 260 $sql .= "', sparge_acid_amount='" . sprintf("%.5f", $row['sparge_acid_amount'] * $factor); | |
| 261 $sql .= "', sparge_temp='" . $row['sparge_temp']; | |
| 262 $sql .= "', sparge_ph='" . $row['sparge_ph']; | |
| 263 $sql .= "', sparge_source='" . $row['sparge_source']; | |
| 264 $sql .= "', sparge_acid_type='" . $row['sparge_acid_type']; | |
| 265 $sql .= "', sparge_acid_perc='" . $row['sparge_acid_perc']; | |
| 266 $sql .= "', mash_ph='" . $row['mash_ph']; | |
| 267 $sql .= "', mash_name='" . $row['mash_name']; | |
| 268 $sql .= "', calc_acid='" . $row['calc_acid']; | |
| 269 $sql .= "', w1_name='" . mysqli_real_escape_string($link, $row['w1_name']); | |
| 270 $sql .= "', w1_amount='" . sprintf("%.2f", $row['w1_amount'] * $factor); | |
| 271 $sql .= "', w1_calcium='" . $row['w1_calcium']; | |
| 272 $sql .= "', w1_sulfate='" . $row['w1_sulfate']; | |
| 273 $sql .= "', w1_chloride='" . $row['w1_chloride']; | |
| 274 $sql .= "', w1_sodium='" . $row['w1_sodium']; | |
| 275 $sql .= "', w1_magnesium='" . $row['w1_magnesium']; | |
| 276 $sql .= "', w1_total_alkalinity='" . $row['w1_total_alkalinity']; | |
| 277 $sql .= "', w1_ph='" . $row['w1_ph']; | |
| 278 $sql .= "', w1_cost='" . $row['w1_cost']; | |
| 279 $sql .= "', w2_name='" . mysqli_real_escape_string($link, $row['w2_name']); | |
| 280 $sql .= "', w2_amount='" . sprintf("%.2f", $row['w2_amount'] * $factor); | |
| 281 $sql .= "', w2_calcium='" . $row['w2_calcium']; | |
| 282 $sql .= "', w2_sulfate='" . $row['w2_sulfate']; | |
| 283 $sql .= "', w2_chloride='" . $row['w2_chloride']; | |
| 284 $sql .= "', w2_sodium='" . $row['w2_sodium']; | |
| 285 $sql .= "', w2_magnesium='" . $row['w2_magnesium']; | |
| 286 $sql .= "', w2_total_alkalinity='" . $row['w2_total_alkalinity']; | |
| 287 $sql .= "', w2_ph='" . $row['w2_ph']; | |
| 288 $sql .= "', w2_cost='" . $row['w2_cost']; | |
| 289 $sql .= "', wg_amount='" . sprintf("%.2f", $row['wg_amount'] * $factor); | |
| 290 $sql .= "', wg_calcium='" . $row['wg_calcium']; | |
| 291 $sql .= "', wg_sulfate='" . $row['wg_sulfate']; | |
| 292 $sql .= "', wg_chloride='" . $row['wg_chloride']; | |
| 293 $sql .= "', wg_sodium='" . $row['wg_sodium']; | |
| 294 $sql .= "', wg_magnesium='" . $row['wg_magnesium']; | |
| 295 $sql .= "', wg_total_alkalinity='" . $row['wg_total_alkalinity']; | |
| 296 $sql .= "', wg_ph='" . $row['wg_ph']; | |
| 297 $sql .= "', wb_calcium='" . $row['wb_calcium']; | |
| 298 $sql .= "', wb_sulfate='" . $row['wb_sulfate']; | |
| 299 $sql .= "', wb_chloride='" . $row['wb_chloride']; | |
| 300 $sql .= "', wb_sodium='" . $row['wb_sodium']; | |
| 301 $sql .= "', wb_magnesium='" . $row['wb_magnesium']; | |
| 302 $sql .= "', wb_total_alkalinity='" . $row['wb_total_alkalinity']; | |
| 303 $sql .= "', wb_ph='" . $row['wb_ph']; | |
| 304 $sql .= "', wa_acid_name='" . $row['wa_acid_name']; | |
| 305 $sql .= "', wa_acid_perc='" . $row['wa_acid_perc']; | |
| 306 $sql .= "', wa_base_name='" . $row['wa_base_name']; | |
| 307 $sql .= "', starter_enable='" . $row['starter_enable']; | |
| 308 $sql .= "', starter_type='" . $row['starter_type']; | |
| 309 $sql .= "', starter_sg='" . $row['starter_sg']; | |
| 310 $sql .= "', starter_viability='" . $row['starter_viability']; | |
| 311 $sql .= "', prop1_type='" . $row['prop1_type']; | |
| 312 $sql .= "', prop2_type='" . $row['prop2_type']; | |
| 313 $sql .= "', prop3_type='" . $row['prop3_type']; | |
| 314 $sql .= "', prop4_type='" . $row['prop4_type']; | |
| 315 $sql .= "', prop1_volume='" . sprintf("%.3f", $row['prop1_volume'] * $factor); | |
| 316 $sql .= "', prop2_volume='" . sprintf("%.3f", $row['prop2_volume'] * $factor); | |
| 317 $sql .= "', prop3_volume='" . sprintf("%.3f", $row['prop3_volume'] * $factor); | |
| 318 $sql .= "', prop4_volume='" . sprintf("%.3f", $row['prop4_volume'] * $factor); | |
| 319 $sql .= "', divide_type='" . $divide_type; | |
| 320 $sql .= "', divide_parts='" . $divide_parts; | |
| 321 $sql .= "', divide_part='" . $index; | |
| 322 $sql .= "', divide_size='" . floatval($split['size']); | |
| 323 $sql .= "', divide_factor='". $factor; | |
| 324 // syslog(LOG_NOTICE, "db_divide: index " . $index . " " . $sql); | |
| 325 } | |
| 326 | |
| 327 $fermentables = json_decode($row['json_fermentables'], true); | |
| 328 for ($i = 0; $i < count($fermentables); $i++) { | |
| 329 $fermentables[$i]['f_amount'] = sprintf("%.5f", $fermentables[$i]['f_amount'] * $factor); | |
| 330 } | |
| 331 // syslog(LOG_NOTICE, "db_divide: " . str_replace($rescapers,$rreplacements,json_encode($fermentables, JSON_UNESCAPED_UNICODE))); | |
| 332 $sql .= "', json_fermentables='" . str_replace($rescapers,$rreplacements,json_encode($fermentables, JSON_UNESCAPED_UNICODE)); | |
| 333 | |
| 334 $hops = json_decode($row['json_hops'], true); | |
| 335 for ($i = 0; $i < count($hops); $i++) { | |
| 336 $hops[$i]['h_amount'] = sprintf("%.5f", $hops[$i]['h_amount'] * $factor); | |
| 337 } | |
| 338 // syslog(LOG_NOTICE, "db_divide: " . str_replace($rescapers,$rreplacements,json_encode($hops, JSON_UNESCAPED_UNICODE))); | |
| 339 $sql .= "', json_hops='" . str_replace($rescapers,$rreplacements,json_encode($hops, JSON_UNESCAPED_UNICODE)); | |
| 340 | |
| 341 $miscs = json_decode($row['json_miscs'], true); | |
| 342 for ($i = 0; $i < count($miscs); $i++) { | |
| 343 $miscs[$i]['m_amount'] = sprintf("%.5f", $miscs[$i]['m_amount'] * $factor); | |
| 344 } | |
| 345 // syslog(LOG_NOTICE, "db_divide: " . str_replace($rescapers,$rreplacements,json_encode($miscs, JSON_UNESCAPED_UNICODE))); | |
| 346 $sql .= "', json_miscs='" . str_replace($rescapers,$rreplacements,json_encode($miscs, JSON_UNESCAPED_UNICODE)); | |
| 347 | |
| 348 $yeasts = json_decode($row['json_yeasts'], true); | |
| 349 for ($i = 0; $i < count($yeasts); $i++) { | |
| 350 $yeasts[$i]['y_amount'] = sprintf("%.5f", $yeasts[$i]['y_amount'] * $factor); | |
| 351 } | |
| 352 // syslog(LOG_NOTICE, "db_divide: " . str_replace($rescapers,$rreplacements,json_encode($yeasts, JSON_UNESCAPED_UNICODE))); | |
| 353 $sql .= "', json_yeasts='" . str_replace($rescapers,$rreplacements,json_encode($yeasts, JSON_UNESCAPED_UNICODE)); | |
| 354 | |
| 355 $mashs = json_decode($row['json_mashs'], true); | |
| 356 for ($i = 0; $i < count($mashs); $i++) { | |
| 357 $mashs[$i]['step_volume'] = sprintf("%.5f", $mashs[$i]['step_volume'] * $factor); | |
| 358 $mashs[$i]['step_infuse_amount'] = sprintf("%.5f", $mashs[$i]['step_infuse_amount'] * $factor); | |
| 359 } | |
| 360 // syslog(LOG_NOTICE, "db_divide: " . str_replace($rescapers,$rreplacements,json_encode($mashs, JSON_UNESCAPED_UNICODE))); | |
| 361 $sql .= "', json_mashs='" . str_replace($rescapers,$rreplacements,json_encode($mashs, JSON_UNESCAPED_UNICODE)); | |
| 362 | |
| 363 if ($index == 0) { | |
| 364 $sql .= "' WHERE record='" . $record . "';"; | |
| 365 $result2 = mysqli_query($link, $sql); | |
| 366 if (! $result2) { | |
| 367 syslog(LOG_NOTICE, "db_divide: result: ".mysqli_error($link)); | |
| 368 $response['error'] = true; | |
| 369 $response['msg'] = "Update master result: ".mysqli_error($link); | |
| 370 break; | |
| 371 } else { | |
| 372 syslog(LOG_NOTICE, "db_divide: updated record ".$record." code ".$split['code']); | |
| 373 } | |
| 374 } else { | |
| 375 $sql .= "';"; | |
| 376 $result2 = mysqli_query($link, $sql); | |
| 377 if (! $result2) { | |
| 378 $response['error'] = true; | |
| 379 $response['msg'] = "Insert split record result: ".mysqli_error($link); | |
| 380 syslog(LOG_NOTICE, "db_divide: result: ".mysqli_error($link)); | |
| 381 break; | |
| 382 } else { | |
| 383 $lastid = mysqli_insert_id($link); | |
| 384 syslog(LOG_NOTICE, "db_divide: inserted record ".$lastid." code ".$split['code']); | |
| 385 /* Copy brew log records */ | |
| 386 if ($row['log_brew'] == '1') { | |
| 387 $result3 = mysqli_query($link, "SELECT * FROM log_brews WHERE code='" . $row['code'] . "'"); | |
| 388 if (! $result3) { | |
| 389 syslog(LOG_NOTICE, "db_divide: result3: ".mysqli_error($link)); | |
| 390 } | |
| 391 while ($row3 = mysqli_fetch_array($result3)) { | |
| 392 $sql3 = "INSERT INTO log_brews SET datetime='" . $row3['datetime']; | |
| 393 $sql3 .= "', version='" . $row3['version']; | |
| 394 $sql3 .= "', uuid='" . $uuid; | |
| 395 $sql3 .= "', code='" . mysqli_real_escape_string($link, $split['code']); | |
| 396 $sql3 .= "', name='" . mysqli_real_escape_string($link, $split['name']); | |
| 397 $sql3 .= "', pv_mlt='" . $row3['pv_mlt']; | |
| 398 if (strlen($row3['pv_hlt'])) | |
| 399 $sql3 .= "', pv_hlt='" . $row3['pv_hlt']; | |
| 400 if (strlen($row3['pv_room'])) | |
| 401 $sql3 .= "', pv_room='" . $row3['pv_room']; | |
| 402 $sql3 .= "', sp_mlt='" . $row3['sp_mlt']; | |
| 403 if (strlen($row3['sp_hlt'])) | |
| 404 $sql3 .= "', sp_hlt='" . $row3['sp_hlt']; | |
| 405 $sql3 .= "', pwm_mlt='" . $row3['pwm_mlt']; | |
| 406 if (strlen($row3['pwm_hlt'])) | |
| 407 $sql3 .= "', pwm_hlt='" . $row3['pwm_hlt']; | |
| 408 $sql3 .= "', event='" . $row3['event'] . "';"; | |
| 409 $result4 = mysqli_query($link, $sql3); | |
| 410 if (! $result4) { | |
| 411 syslog(LOG_NOTICE, "db_divide: result4: ".mysqli_error($link)." ".$sql3); | |
| 412 } | |
| 413 } | |
| 414 } | |
| 415 } | |
| 416 } | |
| 417 | |
| 418 } | |
| 419 } else { | |
| 420 syslog(LOG_NOTICE, "db_divide: missing arguments"); | |
| 421 $response['error'] = true; | |
| 422 $response['msg'] = "missing arguments"; | |
| 423 } | |
| 424 | |
| 425 echo json_encode($response); | |
| 426 | |
| 427 | |
| 428 ?> |
