alxarafe /
alixar
| Conditions | 107 |
| Paths | > 20000 |
| Total Lines | 467 |
| Code Lines | 311 |
| Lines | 0 |
| Ratio | 0 % |
| Changes | 0 | ||
Small methods make your code easier to understand, in particular if combined with a good name. Besides, if your method is small, finding a good name is usually much easier.
For example, if you find yourself adding comments to a method's body, this is usually a good sign to extract the commented part to a new method, and use the comment as a starting point when coming up with a good name for this new method.
Commonly applied refactorings include:
If many parameters/temporary variables are present:
Methods with many parameters are not only hard to understand, but their parameters also often become inconsistent when you need more, or different data.
There are several approaches to avoid long parameter lists:
| 1 | <?php |
||
| 197 | public function _create($user, $fk_product, $entrepot_id, $qty, $type, $price = 0, $label = '', $inventorycode = '', $datem = '', $eatby = '', $sellby = '', $batch = '', $skip_batch = false, $id_product_batch = 0, $disablestockchangeforsubproduct = 0, $donotcleanemptylines = 0, $force_update_batch = false) |
||
| 198 | { |
||
| 199 | // phpcs:enable |
||
| 200 | global $conf, $langs; |
||
| 201 | |||
| 202 | require_once constant('DOL_DOCUMENT_ROOT') . '/product/class/product.class.php'; |
||
| 203 | require_once constant('DOL_DOCUMENT_ROOT') . '/product/stock/class/productlot.class.php'; |
||
| 204 | |||
| 205 | $error = 0; |
||
| 206 | dol_syslog(get_class($this) . "::_create start userid=$user->id, fk_product=$fk_product, warehouse_id=$entrepot_id, qty=$qty, type=$type, price=$price, label=$label, inventorycode=$inventorycode, datem=" . $datem . ", eatby=" . $eatby . ", sellby=" . $sellby . ", batch=" . $batch . ", skip_batch=" . json_encode($skip_batch)); |
||
| 207 | |||
| 208 | // Call hook at beginning |
||
| 209 | global $action, $hookmanager; |
||
| 210 | $hookmanager->initHooks(array('mouvementstock')); |
||
| 211 | |||
| 212 | if (is_object($hookmanager)) { |
||
| 213 | $parameters = array( |
||
| 214 | 'currentcontext' => 'mouvementstock', |
||
| 215 | 'user' => &$user, |
||
| 216 | 'fk_product' => &$fk_product, |
||
| 217 | 'entrepot_id' => &$entrepot_id, |
||
| 218 | 'qty' => &$qty, |
||
| 219 | 'type' => &$type, |
||
| 220 | 'price' => &$price, |
||
| 221 | 'label' => &$label, |
||
| 222 | 'inventorycode' => &$inventorycode, |
||
| 223 | 'datem' => &$datem, |
||
| 224 | 'eatby' => &$eatby, |
||
| 225 | 'sellby' => &$sellby, |
||
| 226 | 'batch' => &$batch, |
||
| 227 | 'skip_batch' => &$skip_batch, |
||
| 228 | 'id_product_batch' => &$id_product_batch |
||
| 229 | ); |
||
| 230 | $reshook = $hookmanager->executeHooks('stockMovementCreate', $parameters, $this, $action); // Note that $action and $object may have been modified by some hooks |
||
| 231 | |||
| 232 | if ($reshook < 0) { |
||
| 233 | if (!empty($hookmanager->resPrint)) { |
||
| 234 | dol_print_error(null, $hookmanager->resPrint); |
||
| 235 | } |
||
| 236 | return $reshook; |
||
| 237 | } elseif ($reshook > 0) { |
||
| 238 | return $hookmanager->resPrint; |
||
| 239 | } |
||
| 240 | } |
||
| 241 | // end hook at beginning |
||
| 242 | |||
| 243 | // Clean parameters |
||
| 244 | $price = price2num($price, 'MU'); // Clean value for the casse we receive a float zero value, to have it a real zero value. |
||
| 245 | if (empty($price)) { |
||
| 246 | $price = 0; |
||
| 247 | } |
||
| 248 | $now = (!empty($datem) ? $datem : dol_now()); |
||
| 249 | |||
| 250 | // Check parameters |
||
| 251 | if (!($fk_product > 0)) { |
||
| 252 | return 0; |
||
| 253 | } |
||
| 254 | if (!($entrepot_id > 0)) { |
||
| 255 | return 0; |
||
| 256 | } |
||
| 257 | |||
| 258 | if (is_numeric($eatby) && $eatby < 0) { |
||
| 259 | dol_syslog(get_class($this) . "::_create start ErrorBadValueForParameterEatBy eatby = " . $eatby); |
||
| 260 | $this->errors[] = 'ErrorBadValueForParameterEatBy'; |
||
| 261 | return -1; |
||
| 262 | } |
||
| 263 | if (is_numeric($sellby) && $sellby < 0) { |
||
| 264 | dol_syslog(get_class($this) . "::_create start ErrorBadValueForParameterSellBy sellby = " . $sellby); |
||
| 265 | $this->errors[] = 'ErrorBadValueForParameterSellBy'; |
||
| 266 | return -1; |
||
| 267 | } |
||
| 268 | |||
| 269 | // Set properties of movement |
||
| 270 | $this->product_id = $fk_product; |
||
| 271 | $this->entrepot_id = $entrepot_id; // deprecated |
||
| 272 | $this->warehouse_id = $entrepot_id; |
||
| 273 | $this->qty = $qty; |
||
| 274 | $this->type = $type; |
||
| 275 | $this->price = price2num($price); |
||
| 276 | $this->label = $label; |
||
| 277 | $this->inventorycode = $inventorycode; |
||
| 278 | $this->datem = $now; |
||
| 279 | $this->batch = $batch; |
||
| 280 | |||
| 281 | $mvid = 0; |
||
| 282 | |||
| 283 | $product = new Product($this->db); |
||
| 284 | |||
| 285 | $result = $product->fetch($fk_product); |
||
| 286 | if ($result < 0) { |
||
| 287 | $this->error = $product->error; |
||
| 288 | $this->errors = $product->errors; |
||
| 289 | dol_print_error(null, "Failed to fetch product"); |
||
| 290 | return -1; |
||
| 291 | } |
||
| 292 | if ($product->id <= 0) { // Can happen if database is corrupted (a product id exist in stock with product that has been removed) |
||
| 293 | return 0; |
||
| 294 | } |
||
| 295 | |||
| 296 | // Define if we must make the stock change (If product type is a service or if stock is used also for services) |
||
| 297 | // Only record into stock tables will be disabled by this (the rest like writing into lot table or movement of subproucts are done) |
||
| 298 | $movestock = 0; |
||
| 299 | if ($product->type != Product::TYPE_SERVICE || getDolGlobalString('STOCK_SUPPORTS_SERVICES')) { |
||
| 300 | $movestock = 1; |
||
| 301 | } |
||
| 302 | |||
| 303 | $this->db->begin(); |
||
| 304 | |||
| 305 | // Set value $product->stock_reel and detail per warehouse into $product->stock_warehouse array |
||
| 306 | if ($movestock) { |
||
| 307 | $product->load_stock('novirtual'); |
||
| 308 | } |
||
| 309 | |||
| 310 | // Test if product require batch data. If yes, and there is not or values are not correct, we throw an error. |
||
| 311 | if (isModEnabled('productbatch') && $product->hasbatch() && !$skip_batch) { |
||
| 312 | if (empty($batch)) { |
||
| 313 | $langs->load("errors"); |
||
| 314 | $this->errors[] = $langs->transnoentitiesnoconv("ErrorTryToMakeMoveOnProductRequiringBatchData", $product->ref); |
||
| 315 | dol_syslog("Try to make a movement of a product with status_batch on without any batch data", LOG_ERR); |
||
| 316 | |||
| 317 | $this->db->rollback(); |
||
| 318 | return -2; |
||
| 319 | } |
||
| 320 | |||
| 321 | // Check table llx_product_lot from batchnumber for same product |
||
| 322 | // If found and eatby/sellby defined into table and provided and differs, return error |
||
| 323 | // If found and eatby/sellby defined into table and not provided, we take value from table |
||
| 324 | // If found and eatby/sellby not defined into table and provided, we update table |
||
| 325 | // If found and eatby/sellby not defined into table and not provided, we do nothing |
||
| 326 | // If not found, we add record |
||
| 327 | $sql = "SELECT pb.rowid, pb.batch, pb.eatby, pb.sellby FROM " . $this->db->prefix() . "product_lot as pb"; |
||
| 328 | $sql .= " WHERE pb.fk_product = " . ((int) $fk_product) . " AND pb.batch = '" . $this->db->escape($batch) . "'"; |
||
| 329 | |||
| 330 | dol_syslog(get_class($this) . "::_create scan serial for this product to check if eatby and sellby match", LOG_DEBUG); |
||
| 331 | |||
| 332 | $resql = $this->db->query($sql); |
||
| 333 | if ($resql) { |
||
| 334 | $num = $this->db->num_rows($resql); |
||
| 335 | $i = 0; |
||
| 336 | if ($num > 0) { |
||
| 337 | while ($i < $num) { |
||
| 338 | $obj = $this->db->fetch_object($resql); |
||
| 339 | if ($obj->eatby) { |
||
| 340 | if ($eatby) { |
||
| 341 | $tmparray = dol_getdate($eatby, true); |
||
| 342 | $eatbywithouthour = dol_mktime(0, 0, 0, $tmparray['mon'], $tmparray['mday'], $tmparray['year']); |
||
| 343 | if ($this->db->jdate($obj->eatby) != $eatby && $this->db->jdate($obj->eatby) != $eatbywithouthour) { // We test date without hours and with hours for backward compatibility |
||
| 344 | // If found and eatby/sellby defined into table and provided and differs, return error |
||
| 345 | $langs->load("stocks"); |
||
| 346 | $this->errors[] = $langs->transnoentitiesnoconv("ThisSerialAlreadyExistWithDifferentDate", $batch, dol_print_date($this->db->jdate($obj->eatby), 'dayhour'), dol_print_date($eatbywithouthour, 'dayhour')); |
||
| 347 | dol_syslog("ThisSerialAlreadyExistWithDifferentDate batch=" . $batch . ", eatby found into product_lot = " . $obj->eatby . " = " . dol_print_date($this->db->jdate($obj->eatby), 'dayhourrfc') . " so eatbywithouthour = " . $eatbywithouthour . " = " . dol_print_date($eatbywithouthour) . " - eatby provided = " . $eatby . " = " . dol_print_date($eatby, 'dayhourrfc'), LOG_ERR); |
||
| 348 | $this->db->rollback(); |
||
| 349 | return -3; |
||
| 350 | } |
||
| 351 | } else { |
||
| 352 | $eatby = $obj->eatby; // If found and eatby/sellby defined into table and not provided, we take value from table |
||
| 353 | } |
||
| 354 | } else { |
||
| 355 | if ($eatby) { // If found and eatby/sellby not defined into table and provided, we update table |
||
| 356 | $productlot = new Productlot($this->db); |
||
| 357 | $result = $productlot->fetch($obj->rowid); |
||
| 358 | $productlot->eatby = $eatby; |
||
| 359 | $result = $productlot->update($user); |
||
| 360 | if ($result <= 0) { |
||
| 361 | $this->error = $productlot->error; |
||
| 362 | $this->errors = $productlot->errors; |
||
| 363 | $this->db->rollback(); |
||
| 364 | return -5; |
||
| 365 | } |
||
| 366 | } |
||
| 367 | } |
||
| 368 | if ($obj->sellby) { |
||
| 369 | if ($sellby) { |
||
| 370 | $tmparray = dol_getdate($sellby, true); |
||
| 371 | $sellbywithouthour = dol_mktime(0, 0, 0, $tmparray['mon'], $tmparray['mday'], $tmparray['year']); |
||
| 372 | if ($this->db->jdate($obj->sellby) != $sellby && $this->db->jdate($obj->sellby) != $sellbywithouthour) { // We test date without hours and with hours for backward compatibility |
||
| 373 | // If found and eatby/sellby defined into table and provided and differs, return error |
||
| 374 | $this->errors[] = $langs->transnoentitiesnoconv("ThisSerialAlreadyExistWithDifferentDate", $batch, dol_print_date($this->db->jdate($obj->sellby)), dol_print_date($sellby)); |
||
| 375 | dol_syslog($langs->transnoentities("ThisSerialAlreadyExistWithDifferentDate", $batch, dol_print_date($this->db->jdate($obj->sellby)), dol_print_date($sellby)), LOG_ERR); |
||
| 376 | $this->db->rollback(); |
||
| 377 | return -3; |
||
| 378 | } |
||
| 379 | } else { |
||
| 380 | $sellby = $obj->sellby; // If found and eatby/sellby defined into table and not provided, we take value from table |
||
| 381 | } |
||
| 382 | } else { |
||
| 383 | if ($sellby) { // If found and eatby/sellby not defined into table and provided, we update table |
||
| 384 | $productlot = new Productlot($this->db); |
||
| 385 | $result = $productlot->fetch($obj->rowid); |
||
| 386 | $productlot->sellby = $sellby; |
||
| 387 | $result = $productlot->update($user); |
||
| 388 | if ($result <= 0) { |
||
| 389 | $this->error = $productlot->error; |
||
| 390 | $this->errors = $productlot->errors; |
||
| 391 | $this->db->rollback(); |
||
| 392 | return -5; |
||
| 393 | } |
||
| 394 | } |
||
| 395 | } |
||
| 396 | |||
| 397 | $i++; |
||
| 398 | } |
||
| 399 | } else { // If not found, we add record |
||
| 400 | $productlot = new Productlot($this->db); |
||
| 401 | $productlot->origin = !empty($this->origin_type) ? $this->origin_type : ''; |
||
| 402 | $productlot->origin_id = !empty($this->origin_id) ? $this->origin_id : 0; |
||
| 403 | $productlot->entity = $conf->entity; |
||
| 404 | $productlot->fk_product = $fk_product; |
||
| 405 | $productlot->batch = $batch; |
||
| 406 | // If we are here = first time we manage this batch, so we used dates provided by users to create lot |
||
| 407 | $productlot->eatby = $eatby; |
||
| 408 | $productlot->sellby = $sellby; |
||
| 409 | $result = $productlot->create($user); |
||
| 410 | if ($result <= 0) { |
||
| 411 | $this->error = $productlot->error; |
||
| 412 | $this->errors = $productlot->errors; |
||
| 413 | $this->db->rollback(); |
||
| 414 | return -4; |
||
| 415 | } |
||
| 416 | } |
||
| 417 | } else { |
||
| 418 | dol_print_error($this->db); |
||
| 419 | $this->db->rollback(); |
||
| 420 | return -1; |
||
| 421 | } |
||
| 422 | } |
||
| 423 | |||
| 424 | // Check if stock is enough when qty is < 0 |
||
| 425 | // Note that qty should be > 0 with type 0 or 3, < 0 with type 1 or 2. |
||
| 426 | if ($movestock && $qty < 0 && !getDolGlobalInt('STOCK_ALLOW_NEGATIVE_TRANSFER')) { |
||
| 427 | if (isModEnabled('productbatch') && $product->hasbatch() && !$skip_batch) { |
||
| 428 | $foundforbatch = 0; |
||
| 429 | $qtyisnotenough = 0; |
||
| 430 | if (isset($product->stock_warehouse[$entrepot_id])) { |
||
| 431 | foreach ($product->stock_warehouse[$entrepot_id]->detail_batch as $batchcursor => $prodbatch) { |
||
| 432 | if ((string) $batch != (string) $batchcursor) { // Lot '59' must be different than lot '59c' |
||
| 433 | continue; |
||
| 434 | } |
||
| 435 | |||
| 436 | $foundforbatch = 1; |
||
| 437 | if ($prodbatch->qty < abs($qty)) { |
||
| 438 | $qtyisnotenough = $prodbatch->qty; |
||
| 439 | } |
||
| 440 | break; |
||
| 441 | } |
||
| 442 | } |
||
| 443 | if (!$foundforbatch || $qtyisnotenough) { |
||
| 444 | $langs->load("stocks"); |
||
| 445 | include_once DOL_DOCUMENT_ROOT . '/product/stock/class/entrepot.class.php'; |
||
| 446 | $tmpwarehouse = new Entrepot($this->db); |
||
| 447 | $tmpwarehouse->fetch($entrepot_id); |
||
| 448 | |||
| 449 | $this->error = $langs->trans('qtyToTranferLotIsNotEnough', $product->ref, $batch, $qtyisnotenough, $tmpwarehouse->ref); |
||
| 450 | $this->errors[] = $langs->trans('qtyToTranferLotIsNotEnough', $product->ref, $batch, $qtyisnotenough, $tmpwarehouse->ref); |
||
| 451 | $this->db->rollback(); |
||
| 452 | return -8; |
||
| 453 | } |
||
| 454 | } else { |
||
| 455 | if (isset($product->stock_warehouse[$entrepot_id]) && (empty($product->stock_warehouse[$entrepot_id]->real) || $product->stock_warehouse[$entrepot_id]->real < abs($qty))) { |
||
| 456 | $langs->load("stocks"); |
||
| 457 | $this->error = $langs->trans('qtyToTranferIsNotEnough') . ' : ' . $product->ref; |
||
| 458 | $this->errors[] = $langs->trans('qtyToTranferIsNotEnough') . ' : ' . $product->ref; |
||
| 459 | $this->db->rollback(); |
||
| 460 | return -8; |
||
| 461 | } |
||
| 462 | } |
||
| 463 | } |
||
| 464 | |||
| 465 | if ($movestock) { // Change stock for current product, change for subproduct is done after |
||
| 466 | // Set $origin_type, origin_id and fk_project |
||
| 467 | $fk_project = $this->fk_project; |
||
| 468 | if (!empty($this->origin_type)) { // This is set by caller for tracking reason |
||
| 469 | $origin_type = $this->origin_type; |
||
| 470 | $origin_id = $this->origin_id; |
||
| 471 | if (empty($fk_project) && $origin_type == 'project') { |
||
| 472 | $fk_project = $origin_id; |
||
| 473 | $origin_type = ''; |
||
| 474 | $origin_id = 0; |
||
| 475 | } |
||
| 476 | } else { |
||
| 477 | $fk_project = 0; |
||
| 478 | $origin_type = ''; |
||
| 479 | $origin_id = 0; |
||
| 480 | } |
||
| 481 | |||
| 482 | $sql = "INSERT INTO " . $this->db->prefix() . "stock_mouvement("; |
||
| 483 | $sql .= " datem, fk_product, batch, eatby, sellby,"; |
||
| 484 | $sql .= " fk_entrepot, value, type_mouvement, fk_user_author, label, inventorycode, price, fk_origin, origintype, fk_projet"; |
||
| 485 | $sql .= ")"; |
||
| 486 | $sql .= " VALUES ('" . $this->db->idate($this->datem) . "', " . ((int) $this->product_id) . ", "; |
||
| 487 | $sql .= " " . ($batch ? "'" . $this->db->escape($batch) . "'" : "null") . ", "; |
||
| 488 | $sql .= " " . ($eatby ? "'" . $this->db->idate($eatby) . "'" : "null") . ", "; |
||
| 489 | $sql .= " " . ($sellby ? "'" . $this->db->idate($sellby) . "'" : "null") . ", "; |
||
| 490 | $sql .= " " . ((int) $this->entrepot_id) . ", " . ((float) $this->qty) . ", " . ((int) $this->type) . ","; |
||
| 491 | $sql .= " " . ((int) $user->id) . ","; |
||
| 492 | $sql .= " '" . $this->db->escape($label) . "',"; |
||
| 493 | $sql .= " " . ($inventorycode ? "'" . $this->db->escape($inventorycode) . "'" : "null") . ","; |
||
| 494 | $sql .= " " . ((float) price2num($price)) . ","; |
||
| 495 | $sql .= " " . ((int) $origin_id) . ","; |
||
| 496 | $sql .= " '" . $this->db->escape($origin_type) . "',"; |
||
| 497 | $sql .= " " . ((int) $fk_project); |
||
| 498 | $sql .= ")"; |
||
| 499 | |||
| 500 | dol_syslog(get_class($this) . "::_create insert record into stock_mouvement", LOG_DEBUG); |
||
| 501 | $resql = $this->db->query($sql); |
||
| 502 | |||
| 503 | if ($resql) { |
||
| 504 | $mvid = $this->db->last_insert_id($this->db->prefix() . "stock_mouvement"); |
||
| 505 | $this->id = $mvid; |
||
| 506 | } else { |
||
| 507 | $this->error = $this->db->lasterror(); |
||
| 508 | $this->errors[] = $this->error; |
||
| 509 | $error = -1; |
||
| 510 | } |
||
| 511 | |||
| 512 | // Define current values for qty and pmp |
||
| 513 | $oldqty = $product->stock_reel; |
||
| 514 | $oldpmp = $product->pmp; |
||
| 515 | $oldqtywarehouse = 0; |
||
| 516 | |||
| 517 | // Test if there is already a record for couple (warehouse / product), so later we will make an update or create. |
||
| 518 | $alreadyarecord = 0; |
||
| 519 | if (!$error) { |
||
| 520 | $sql = "SELECT rowid, reel FROM " . $this->db->prefix() . "product_stock"; |
||
| 521 | $sql .= " WHERE fk_entrepot = " . ((int) $entrepot_id) . " AND fk_product = " . ((int) $fk_product); // This is a unique key |
||
| 522 | |||
| 523 | dol_syslog(get_class($this) . "::_create check if a record already exists in product_stock", LOG_DEBUG); |
||
| 524 | $resql = $this->db->query($sql); |
||
| 525 | if ($resql) { |
||
| 526 | $obj = $this->db->fetch_object($resql); |
||
| 527 | if ($obj) { |
||
| 528 | $alreadyarecord = 1; |
||
| 529 | $oldqtywarehouse = $obj->reel; |
||
| 530 | $fk_product_stock = $obj->rowid; |
||
| 531 | } |
||
| 532 | $this->db->free($resql); |
||
| 533 | } else { |
||
| 534 | $this->errors[] = $this->db->lasterror(); |
||
| 535 | $error = -2; |
||
| 536 | } |
||
| 537 | } |
||
| 538 | |||
| 539 | // Calculate new AWP (PMP) |
||
| 540 | $newpmp = 0; |
||
| 541 | if (!$error) { |
||
| 542 | if ($type == 0 || $type == 3) { |
||
| 543 | // After a stock increase |
||
| 544 | // Note: PMP is calculated on stock input only (type of movement = 0 or 3). If type == 0 or 3, qty should be > 0. |
||
| 545 | // Note: Price should always be >0 or 0. PMP should be always >0 (calculated on input) |
||
| 546 | if ($price > 0 || (getDolGlobalString('STOCK_UPDATE_AWP_EVEN_WHEN_ENTRY_PRICE_IS_NULL') && $price == 0 && in_array($this->origin_type, array('order_supplier', 'invoice_supplier')))) { |
||
| 547 | $oldqtytouse = ($oldqty >= 0 ? $oldqty : 0); |
||
| 548 | // We make a test on oldpmp>0 to avoid to use normal rule on old data with no pmp field defined |
||
| 549 | if ($oldpmp > 0) { |
||
| 550 | $newpmp = price2num((($oldqtytouse * $oldpmp) + ($qty * $price)) / ($oldqtytouse + $qty), 'MU'); |
||
| 551 | } else { |
||
| 552 | $newpmp = $price; // For this product, PMP was not yet set. We set it to input price. |
||
| 553 | } |
||
| 554 | //print "oldqtytouse=".$oldqtytouse." oldpmp=".$oldpmp." oldqtywarehousetouse=".$oldqtywarehousetouse." "; |
||
| 555 | //print "qty=".$qty." newpmp=".$newpmp; |
||
| 556 | //exit; |
||
| 557 | } else { |
||
| 558 | $newpmp = $oldpmp; |
||
| 559 | } |
||
| 560 | } else { |
||
| 561 | // ($type == 1 || $type == 2) |
||
| 562 | // -> After a stock decrease, we don't change value of the AWP/PMP of a product. |
||
| 563 | // else |
||
| 564 | // Type of movement unknown |
||
| 565 | $newpmp = $oldpmp; |
||
| 566 | } |
||
| 567 | } |
||
| 568 | // Update stock quantity |
||
| 569 | if (!$error) { |
||
| 570 | if ($alreadyarecord > 0) { |
||
| 571 | $sql = "UPDATE " . $this->db->prefix() . "product_stock SET reel = " . ((float) $oldqtywarehouse + (float) $qty); |
||
| 572 | $sql .= " WHERE fk_entrepot = " . ((int) $entrepot_id) . " AND fk_product = " . ((int) $fk_product); |
||
| 573 | } else { |
||
| 574 | $sql = "INSERT INTO " . $this->db->prefix() . "product_stock"; |
||
| 575 | $sql .= " (reel, fk_entrepot, fk_product) VALUES "; |
||
| 576 | $sql .= " (" . ((float) $qty) . ", " . ((int) $entrepot_id) . ", " . ((int) $fk_product) . ")"; |
||
| 577 | } |
||
| 578 | |||
| 579 | dol_syslog(get_class($this) . "::_create update stock value", LOG_DEBUG); |
||
| 580 | $resql = $this->db->query($sql); |
||
| 581 | if (!$resql) { |
||
| 582 | $this->errors[] = $this->db->lasterror(); |
||
| 583 | $error = -3; |
||
| 584 | } elseif (empty($fk_product_stock)) { |
||
| 585 | $fk_product_stock = $this->db->last_insert_id($this->db->prefix() . "product_stock"); |
||
| 586 | } |
||
| 587 | } |
||
| 588 | |||
| 589 | // Update detail of stock for the lot. |
||
| 590 | if (!$error && isModEnabled('productbatch') && (($product->hasbatch() && !$skip_batch) || $force_update_batch)) { |
||
| 591 | if ($id_product_batch > 0) { |
||
| 592 | $result = $this->createBatch($id_product_batch, $qty); |
||
| 593 | if ($result == -2 && $fk_product_stock > 0) { // The entry for this product batch does not exists anymore, bu we already have a llx_product_stock, so we recreate the batch entry in product_batch |
||
| 594 | $param_batch = array('fk_product_stock' => $fk_product_stock, 'batchnumber' => $batch); |
||
| 595 | $result = $this->createBatch($param_batch, $qty); |
||
| 596 | } |
||
| 597 | } else { |
||
| 598 | $param_batch = array('fk_product_stock' => $fk_product_stock, 'batchnumber' => $batch); |
||
| 599 | $result = $this->createBatch($param_batch, $qty); |
||
| 600 | } |
||
| 601 | if ($result < 0) { |
||
| 602 | $error++; |
||
| 603 | } |
||
| 604 | } |
||
| 605 | |||
| 606 | // Update PMP and denormalized value of stock qty at product level |
||
| 607 | if (!$error) { |
||
| 608 | $newpmp = price2num($newpmp, 'MU'); |
||
| 609 | |||
| 610 | // $sql = "UPDATE ".$this->db->prefix()."product SET pmp = ".$newpmp.", stock = ".$this->db->ifsql("stock IS NULL", 0, "stock") . " + ".$qty; |
||
| 611 | // $sql.= " WHERE rowid = ".((int) $fk_product); |
||
| 612 | // Update pmp + denormalized fields because we change content of produt_stock. Warning: Do not use "SET p.stock", does not works with pgsql |
||
| 613 | $sql = "UPDATE " . $this->db->prefix() . "product as p SET pmp = " . ((float) $newpmp) . ","; |
||
| 614 | $sql .= " stock=(SELECT SUM(ps.reel) FROM " . $this->db->prefix() . "product_stock as ps WHERE ps.fk_product = p.rowid)"; |
||
| 615 | $sql .= " WHERE rowid = " . ((int) $fk_product); |
||
| 616 | |||
| 617 | dol_syslog(get_class($this) . "::_create update AWP", LOG_DEBUG); |
||
| 618 | $resql = $this->db->query($sql); |
||
| 619 | if (!$resql) { |
||
| 620 | $this->errors[] = $this->db->lasterror(); |
||
| 621 | $error = -4; |
||
| 622 | } |
||
| 623 | } |
||
| 624 | |||
| 625 | if (empty($donotcleanemptylines)) { |
||
| 626 | // If stock is now 0, we can remove entry into llx_product_stock, but only if there is no child lines into llx_product_batch (detail of batch, because we can imagine |
||
| 627 | // having a lot1/qty=X and lot2/qty=-X, so 0 but we must not loose repartition of different lot. |
||
| 628 | $sql = "DELETE FROM " . $this->db->prefix() . "product_stock WHERE reel = 0 AND rowid NOT IN (SELECT fk_product_stock FROM " . $this->db->prefix() . "product_batch as pb)"; |
||
| 629 | $resql = $this->db->query($sql); |
||
| 630 | // We do not test error, it can fails if there is child in batch details |
||
| 631 | } |
||
| 632 | } |
||
| 633 | |||
| 634 | // Add movement for sub products (recursive call) |
||
| 635 | if (!$error && getDolGlobalString('PRODUIT_SOUSPRODUITS') && !getDolGlobalString('INDEPENDANT_SUBPRODUCT_STOCK') && empty($disablestockchangeforsubproduct)) { |
||
| 636 | $error = $this->_createSubProduct($user, $fk_product, $entrepot_id, $qty, $type, 0, $label, $inventorycode, $datem); // we use 0 as price, because AWP must not change for subproduct |
||
| 637 | } |
||
| 638 | |||
| 639 | if ($movestock && !$error) { |
||
| 640 | // Call trigger |
||
| 641 | $result = $this->call_trigger('STOCK_MOVEMENT', $user); |
||
| 642 | if ($result < 0) { |
||
| 643 | $error++; |
||
| 644 | } |
||
| 645 | // End call triggers |
||
| 646 | // Check unicity for serial numbered equipment once all movement were done. |
||
| 647 | if (!$error && isModEnabled('productbatch') && $product->hasbatch() && !$skip_batch) { |
||
| 648 | if ($product->status_batch == 2 && $qty > 0) { // We check only if we increased qty |
||
| 649 | if ($this->getBatchCount($fk_product, $batch) > 1) { |
||
| 650 | $error++; |
||
| 651 | $this->errors[] = $langs->trans("TooManyQtyForSerialNumber", $product->ref, $batch); |
||
| 652 | } |
||
| 653 | } |
||
| 654 | } |
||
| 655 | } |
||
| 656 | |||
| 657 | if (!$error) { |
||
| 658 | $this->db->commit(); |
||
| 659 | return $mvid; |
||
| 660 | } else { |
||
| 661 | $this->db->rollback(); |
||
| 662 | dol_syslog(get_class($this) . "::_create error code=" . $error, LOG_ERR); |
||
| 663 | return -6; |
||
| 664 | } |
||
| 1331 |
Loading history...