Cette fois, j'ai utilisé swoole pour retarder les commandes et restaurer les stocks !
- 藏色散人avant
- 2021-07-30 14:09:262707parcourir
1. Scénario commercial : lorsqu'un client passe une commande et ne paie pas dans le délai spécifié, nous devons alors annuler la commande. Par exemple, un bon moyen de gérer ce problème est d'utiliser l'annulation différée. , la première chose à laquelle beaucoup de gens pensent est Crontab, c'est également possible, mais ici nous utilisons le minuteur asynchrone en millisecondes de swoole pour l'implémenter, ce qui n'affectera pas non plus le fonctionnement du programme en cours.
2. Explication, quand order_status est à 1, cela signifie que le client a passé une commande, lorsqu'il est à 2, cela signifie que le client a payé, et lorsqu'il est à 0, cela signifie que la commande a été annulée (ce c'est ce que fait swoole)
Trois, par exemple, la table d'inventaire csdn_product_stock product La quantité d'inventaire de l'ID de produit 1 est de 20 et la quantité d'inventaire de l'ID de produit 2 est de 40. Ensuite, lorsque le client passe une commande, l'ID de produit1 est réduit de 10 et l'ID2 du produit est réduit de 20. Par conséquent, le tableau d'inventaire ne suffit que pour 2 commandes. Dans l'exemple, après 10 secondes, restaurez automatiquement l'inventaire.
Comme le montre ci-dessous, l'illustration :
1. Après avoir passé la commande pour la première fois, l'inventaire du produit ID1 a été réduit de 20 à 10, et l'inventaire du produit ID2 a été réduit de 40 à 20. en passant la commande pour la deuxième fois, l'inventaire du produit ID était 0, l'inventaire du produit ID2 est également 0,
3 Lors de la troisième commande, le programme affiche En rupture de stock
4. 10 secondes (chaque commande est repoussée de 10 secondes), Le client a passé commande deux fois Comme il n'y a pas eu de paiement (le order_status de la table csdn_order est 1), l'inventaire du produit 1 et du produit 2 a été restauré (le order_status du csdn_order). la table est devenue 0), et le client peut continuer à passer des commandes
1. La table de base de données SQL requise
DROP TABLE IF EXISTS `csdn_order`; CREATE TABLE `csdn_order` ( `order_id` int(10) unsigned NOT NULL AUTO_INCREMENT, `order_amount` float(10,2) unsigned NOT NULL DEFAULT '0.00', `user_name` varchar(64) CHARACTER SET latin1 NOT NULL DEFAULT '', `order_status` tinyint(2) unsigned NOT NULL DEFAULT '0', `date_created` datetime NOT NULL, PRIMARY KEY (`order_id`) ) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8; DROP TABLE IF EXISTS `csdn_order_detail`; CREATE TABLE `csdn_order_detail` ( `detail_id` int(10) unsigned NOT NULL AUTO_INCREMENT, `order_id` int(10) unsigned NOT NULL, `product_id` int(10) NOT NULL, `product_price` float(10,2) NOT NULL, `product_number` smallint(4) unsigned NOT NULL DEFAULT '0', `date_created` datetime NOT NULL, PRIMARY KEY (`detail_id`), KEY `idx_order_id` (`order_id`) ) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8; DROP TABLE IF EXISTS `csdn_product_stock`; CREATE TABLE `csdn_product_stock` ( `auto_id` int(10) unsigned NOT NULL AUTO_INCREMENT, `product_id` int(10) NOT NULL, `product_stock_number` int(10) unsigned NOT NULL, `date_modified` datetime NOT NULL, PRIMARY KEY (`auto_id`), KEY `idx_product_id` (`product_id`) ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8; INSERT INTO `csdn_product_stock` VALUES ('1', '1', '20', '2018-09-13 19:36:19'); INSERT INTO `csdn_product_stock` VALUES ('2', '2', '40', '2018-09-13 19:36:19');
est publiée ci-dessous avec du PHP purement manuel. De nombreux étudiants utilisent du PHP natif et ne l'appliqueront pas au framework. En fait, ils sont tous pareils, alors ne pensez pas si compliqué. Tant que vous l'utiliserez trop, vous ressentirez cela.
Fichier de configuration config.php, s'il est dans le framework, il est essentiellement configuré.
<?php $dbHost = "192.168.23.110"; $dbUser = "root"; $dbPassword = "123456"; $dbName = "test"; ?>
swoole sont tous utilisés dans les systèmes Linux. Vous pouvez créer votre propre hôte virtuel pour l'hôte ici, ou vous pouvez acheter votre propre serveur en ligne
Le fichier de soumission de commande order_submit.php est généré ici et l'inventaire est déduit A. série d'opérations
<?php
require("config.php");
try {
$pdo = new PDO("mysql:host=" . $dbHost . ";dbname=" . $dbName, $dbUser, $dbPassword, array(PDO::ATTR_PERSISTENT => true));
$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 1);
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$orderInfo = array(
'order_amount' => 10.92,
'user_name' => 'yusan',
'order_status' => 1,
'date_created' => 'now()',
'product_lit' => array(
0 => array(
'product_id' => 1,
'product_price' => 5.00,
'product_number' => 10,
'date_created' => 'now()'
),
1 => array(
'product_id' => 2,
'product_price' => 5.92,
'product_number' => 20,
'date_created' => 'now()'
)
)
);
try{
$pdo->beginTransaction();//开启事务处理
$sql = 'insert into csdn_order (order_amount, user_name, order_status, date_created) values (:orderAmount, :userName, :orderStatus, now())';
$stmt = $pdo->prepare($sql);
$affectedRows = $stmt->execute(array(':orderAmount' => $orderInfo['order_amount'], ':userName' => $orderInfo['user_name'], ':orderStatus' => $orderInfo['order_status']));
$orderId = $pdo->lastInsertId();
if(!$affectedRows) {
throw new PDOException("Failure to submit order!");
}
foreach($orderInfo['product_lit'] as $productInfo) {
$sqlProductDetail = 'insert into csdn_order_detail (order_id, product_id, product_price, product_number, date_created) values (:orderId, :productId, :productPrice, :productNumber, now())';
$stmtProductDetail = $pdo->prepare($sqlProductDetail);
$stmtProductDetail->execute(array(':orderId' => $orderId, ':productId' => $productInfo['product_id'], ':productPrice' => $productInfo['product_price'], ':productNumber' => $productInfo['product_number']));
$sqlCheck = "select product_stock_number from csdn_product_stock where product_id=:productId";
$stmtCheck = $pdo->prepare($sqlCheck);
$stmtCheck->execute(array(':productId' => $productInfo['product_id']));
$rowCheck = $stmtCheck->fetch(PDO::FETCH_ASSOC);
if($rowCheck['product_stock_number'] < $productInfo['product_number']) {
throw new PDOException("Out of stock, Failure to submit order!");
}
$sqlProductStock = 'update csdn_product_stock set product_stock_number=product_stock_number-:productNumber, date_modified=now() where product_id=:productId';
$stmtProductStock = $pdo->prepare($sqlProductStock);
$stmtProductStock->execute(array(':productNumber' => $productInfo['product_number'], ':productId' => $productInfo['product_id']));
$affectedRowsProductStock = $stmtProductStock->rowCount();
//库存没有正常扣除，失败，库存表里的product_stock_number设置了为非负数
//如果库存不足时，sql异常：SQLSTATE[22003]: Numeric value out of range: 1690 BIGINT UNSIGNED value is out of range in '(`test`.`csdn_product_stock`.`product_stock_number` - 20)'
if($affectedRowsProductStock <= 0) {
throw new PDOException("Out of stock, Failure to submit order!");
}
}
echo "Successful, Order Id is：" . $orderId ."，Order Amount is：" . $orderInfo['order_amount'] . "。";
$pdo->commit();//提交事务
//exec("php order_cancel.php -a" . $orderId . " &");
pclose(popen('php order_cancel.php -a ' . $orderId . ' &', 'w'));
//system("php order_cancel.php -a" . $orderId . " &", $phpResult);
//echo $phpResult;
}catch(PDOException $e){
echo $e->getMessage();
$pdo->rollback();
}
$pdo = null;
} catch (PDOException $e) {
echo $e->getMessage();
}
?>Traitement retardé des commandes order_cancel.php
<?php
require("config.php");
$queryString = getopt('a:');
$userParams = array($queryString);
appendLog(date("Y-m-d H:i:s") . "\t" . $queryString['a'] . "\t" . "start");
try {
$pdo = new PDO("mysql:host=" . $dbHost . ";dbname=" . $dbName, $dbUser, $dbPassword, array(PDO::ATTR_PERSISTENT => true));
$pdo->setAttribute(PDO::ATTR_AUTOCOMMIT, 0);
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
swoole_timer_after(10000, function ($queryString) {
global $queryString, $pdo;
try{
$pdo->beginTransaction();//开启事务处理
$orderId = $queryString['a'];
$sql = "select order_status from csdn_order where order_id=:orderId";
$stmt = $pdo->prepare($sql);
$stmt->execute(array(':orderId' => $orderId));
$row = $stmt->fetch(PDO::FETCH_ASSOC);
//$row['order_status'] === "1"代表已下单，但未付款，我们还原库存只针对未付款的订单
if(isset($row['order_status']) && $row['order_status'] === "1") {
$sqlOrderDetail = "select product_id, product_number from csdn_order_detail where order_id=:orderId";
$stmtOrderDetail = $pdo->prepare($sqlOrderDetail);
$stmtOrderDetail->execute(array(':orderId' => $orderId));
while($rowOrderDetail = $stmtOrderDetail->fetch(PDO::FETCH_ASSOC)) {
$sqlRestoreStock = "update csdn_product_stock set product_stock_number=product_stock_number + :productNumber, date_modified=now() where product_id=:productId";
$stmtRestoreStock = $pdo->prepare($sqlRestoreStock);
$stmtRestoreStock->execute(array(':productNumber' => $rowOrderDetail['product_number'], ':productId' => $rowOrderDetail['product_id']));
}
$sqlRestoreOrder = "update csdn_order set order_status=:orderStatus where order_id=:orderId";
$stmtRestoreOrder = $pdo->prepare($sqlRestoreOrder);
$stmtRestoreOrder->execute(array(':orderStatus' => 0, ':orderId' => $orderId));
}
$pdo->commit();//提交事务
}catch(PDOException $e){
echo $e->getMessage();
$pdo->rollback();
}
$pdo = null;
appendLog(date("Y-m-d H:i:s") . "\t" . $queryString['a'] . "\t" . "end\t" . json_encode($queryString));
}, $pdo);
} catch (PDOException $e) {
echo $e->getMessage();
}
function appendLog($str) {
$dir = 'log.txt';
$fh = fopen($dir, "a");
fwrite($fh, $str . "\n");
fclose($fh);
}
?>Pour plus d'articles techniques swoole, veuillez visiter la rubrique tutoriel swoole !
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
Articles Liés
Voir plus- Apprenons ensemble des exemples simples de mise en œuvre de Swoole
- Vous emmène apprendre le framework swoole en trois minutes
- Utiliser Swoole pour améliorer les performances de Laravel (Shadowfax)
- Entretien avec Twosee, contributeur principal de Swoole : Traiter PHP comme premier amour et laisser pousser les cheveux face à l'épidémie