Блокировка одновременных транзакций SQL из учетной записи в php 5.6 ⇐ Php

[Anonymous]

Недавно я столкнулся с проблемой в своем веб-приложении, которая заставила меня почесать голову. У меня есть веб-приложение, которое использует nginx с PHP 5.6 (я знаю, что оно довольно старое, но, честно говоря, обновление всего веб-приложения требует слишком много работы), интерфейс представляет собой чистый html-css-javascript. Пожалуйста, также извините за плохую практику, которая объединяет значения в запрос sql вместо их привязки, но код по большей части не мой, я взял проект у кого-то другого.

Код: Выделить всё

require ('connection/mysql.php'); // Connects to the database
include ('sessionShared.php');
require ('logger.php');

$intMaterialID = $_POST['intMaterialID'];
$numWeightProc = $_POST['numWeightProc'];
$intnumrows = $_POST['numrows'];
$intCurrentRow = 1;
$companyid = $_SESSION['companyid'];

$conn_wp->begin_transaction();

try {
for ($i = 1; $i  0) {
$query_getlastid = "SELECT PKproductsID, PKproductsUnitID FROM tblwasteproducts WHERE FKUnitID = $companyid ORDER BY PKproductsID DESC";
$resultlastid = $conn_wp->query($query_getlastid);
if (!$resultlastid) {
$newlastid = 1; // When unit has no clients
} else {
$rstlastid = $resultlastid->fetch_assoc();
$newlastid = $rstlastid['PKproductsUnitID'] + 1;
}

if ($arrProductModified[$i] < 1) {
// Add a normal material
$query_rstProductAdd = "INSERT INTO tblwasteproducts (PKproductsUnitID, FKUnitID, FKMaterialID, prod_weight, prod_weightleft, prod_category, ProductDescription) VALUES ($newlastid, $companyid, $intMaterialID, $intProductWeight, $intProductWeight, $arrProductCat[$i], '$arrProductDescription[$i]')";
} else {
// Add a modified material
$query_rstProductAdd = "INSERT INTO tblwasteproducts (PKproductsUnitID, FKUnitID, FKMaterialID, prod_weight, prod_weightleft, prod_category, FKMaterialModifiedID, ProductDescription) VALUES ($newlastid, $companyid, $intMaterialID, $intProductWeight, $intProductWeight, $arrProductCat[$i], $arrProductModified[$i], '$arrProductDescriptionModified[$i]')";
}
if (!$conn_wp->query($query_rstProductAdd)) {
throw new Exception("Error inserting product data: " . $conn_wp->error);
}
}
}

// Update the proc table - remove material
$intTakenLeft = $numWeightProc;
$query_rstProcMaterial = "SELECT PKProcID, PKProcUnitID, FKUnitID, wproc_material, wproc_weight FROM tblwasteprocessing WHERE wproc_material = $intMaterialID AND wproc_weight > 0 AND FKUnitID = $companyid";
$rstProcMaterial = $conn_wp->query($query_rstProcMaterial);

while ($dataProcMaterial = $rstProcMaterial->fetch_assoc()) {
$intTempWeight = $dataProcMaterial["wproc_weight"];

if ($intTempWeight > 0 && $intTakenLeft > 0) {
if ($intTempWeight < $intTakenLeft) {
$intTakenLeft -= $intTempWeight;
$query_rstProductUpdate = "UPDATE tblwasteprocessing SET wproc_weight = 0 WHERE PKProcID = " . $dataProcMaterial["PKProcID"];
} else {
$query_rstProductUpdate = "UPDATE tblwasteprocessing SET wproc_weight = $intTempWeight - $intTakenLeft WHERE PKProcID = " . $dataProcMaterial["PKProcID"];
$intTakenLeft = 0;
}
if (!$conn_wp->query($query_rstProductUpdate)) {
throw new Exception("Error updating processing table: " .  $conn_wp->error);
}
}
}

$query_rstMaterial = "SELECT wm_description FROM tblwastematerials WHERE PKID = $intMaterialID";
$rstMaterial = $conn_wp->query($query_rstMaterial);
$dataMaterial = $rstMaterial->fetch_assoc();

$conn_wp->commit();
} catch (Exception $e) {
$conn_wp->rollback();
error_log("Transaction failed: " . $e->getMessage());
}

// Close connection
$conn_wp->close();
?>

Это пример кода, существующего в веб-приложении. Большинство веб-приложений структурировано на основе этой логики. Все дело в уменьшении некоторого веса в первой таблице (путем UPDATE) и создании строки в другой таблице с тем же весом (путем INSERT INTO). Проблема здесь в том, что если я открываю две вкладки вместо одной, запускаю этот сценарий два раза (по одному на каждой вкладке) с данными, которые включают одни и те же строки, SQL выполняет оба запроса одновременно, он ВСТАВЛЯЕТ в точно вес для обеих вкладок, но это никогда полностью не уменьшает тот же вес из первой таблицы, потому что они уже достигли 0, и я не позволяю ему стать отрицательным при UPDATE. Мне нужно найти способ запретить пользователю выполнять одновременные запросы.
Я пробовал SELECT...FOR UPDATE, но ничего не получалось.
Я пытался использовать флаг, используя сеанс глобальный, но он в основном блокирует пользователя.
У меня возникла идея создать столбец в таблице «учетные записи» (в котором хранится информация о пользователе) с флагом «isProcessing», который станет равным 1, когда транзакция находится в процессе выполнения и 0, когда она завершается.
Заранее спасибо.

Подробнее здесь: https://stackoverflow.com/questions/790 ... in-php-5-6