Comment annuler une commande en php ?

Comment implémenter l'annulation de commande en PHP : D'abord, lorsque [order_status] vaut 1, il représente la confirmation de commande du client ; puis, lorsqu'il vaut 2, il représente le paiement du client enfin, lorsqu'il vaut 0, cela signifie que la commande a été annulée, en utilisant le dispositif de synchronisation asynchrone en millisecondes de Swoole.

Comment annuler une commande en PHP :

1. Scénario métier : Lorsqu'un client passe une commande chez une heure spécifiée S'il n'y a pas de paiement dans le délai, 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. Ici, nous utilisons swoole en utilisant la minuterie asynchrone en millisecondes. n'affecte pas le déroulement du programme en cours.

2. Description, quand order_status vaut 1, cela signifie que le client a passé une commande, quand il vaut 2, cela signifie que le client a payé, lorsqu'il vaut 0, cela signifie que la commande a été annulée. (c'est ce que fait swoole), ce qui suit me représente Il n'y a pas de framework, et le PHP relativement pur représente une compréhension et une application faciles

3. Par exemple, dans la table d'inventaire csdn_product_stock, la quantité en stock du produit avec l'ID de produit 1 est de 20, et la quantité d'inventaire avec l'ID de produit 2 est de 40, puis le client Lors de la passation d'une commande, l'ID de produit1 sera réduit de 10 et l'ID de produit2 sera réduit de 20, donc le tableau d'inventaire n'est que suffisant pour 2 commandes. Dans l'exemple, l'inventaire sera automatiquement restauré au bout de 10 secondes, comme indiqué ci-dessous :

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

2. Après avoir passé la commande pour la deuxième fois, l'inventaire du produit ID était de 0 et le l'inventaire du produit ID2 a été réduit à 0. L'inventaire est également à 0

3. Lors de la troisième commande, le programme affiche En rupture de stock

4. secondes (retrait après chaque commande) 10 secondes), le client passe commande deux fois. Puisqu'il n'y a pas de paiement (le order_status de la table csdn_order est 1), l'inventaire du produit 1 et du produit 2 est restauré (le order_status de. la table csdn_order devient 0), et le client peut continuer à passer des commandes

Table de base de données SQL obligatoire

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');

2. config.php

<?php
$dbHost = "192.168.0.110";
$dbUser = "root";
$dbPassword = "123";
$dbName = "test";
?>

3, <code><strong>order_submit.php</strong>order_submit.php

<?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(
&#39;order_amount&#39; => 10.92,
&#39;user_name&#39; => &#39;yusan&#39;,
&#39;order_status&#39; => 1,
&#39;date_created&#39; => &#39;now()&#39;,
&#39;product_lit&#39; => array(
0 => array(
&#39;product_id&#39; => 1,
&#39;product_price&#39; => 5.00,
&#39;product_number&#39; => 10,
&#39;date_created&#39; => &#39;now()&#39;
),
1 => array(
&#39;product_id&#39; => 2,
&#39;product_price&#39; => 5.92,
&#39;product_number&#39; => 20,
&#39;date_created&#39; => &#39;now()&#39;
)
)
);
 
try{
$pdo->beginTransaction();//开启事务处理
 
$sql = &#39;insert into csdn_order (order_amount, user_name, order_status, date_created) values (:orderAmount, :userName, :orderStatus, now())&#39;;
$stmt = $pdo->prepare($sql);  
$affectedRows = $stmt->execute(array(&#39;:orderAmount&#39; => $orderInfo[&#39;order_amount&#39;], &#39;:userName&#39; => $orderInfo[&#39;user_name&#39;], &#39;:orderStatus&#39; => $orderInfo[&#39;order_status&#39;]));
$orderId = $pdo->lastInsertId();
if(!$affectedRows) {
throw new PDOException("Failure to submit order!");
}
foreach($orderInfo[&#39;product_lit&#39;] as $productInfo) {
 
$sqlProductDetail = &#39;insert into csdn_order_detail (order_id, product_id, product_price, product_number, date_created) values (:orderId, :productId, :productPrice, :productNumber, now())&#39;;
$stmtProductDetail = $pdo->prepare($sqlProductDetail);  
$stmtProductDetail->execute(array(&#39;:orderId&#39; => $orderId, &#39;:productId&#39; =>  $productInfo[&#39;product_id&#39;], &#39;:productPrice&#39; => $productInfo[&#39;product_price&#39;], &#39;:productNumber&#39; => $productInfo[&#39;product_number&#39;]));
 
$sqlCheck = "select product_stock_number from csdn_product_stock where product_id=:productId";  
$stmtCheck = $pdo->prepare($sqlCheck);  
$stmtCheck->execute(array(&#39;:productId&#39; => $productInfo[&#39;product_id&#39;]));  
$rowCheck = $stmtCheck->fetch(PDO::FETCH_ASSOC);
if($rowCheck[&#39;product_stock_number&#39;] < $productInfo[&#39;product_number&#39;]) {
throw new PDOException("Out of stock, Failure to submit order!");
}
 
 
$sqlProductStock = &#39;update csdn_product_stock set product_stock_number=product_stock_number-:productNumber, date_modified=now() where product_id=:productId&#39;;
$stmtProductStock = $pdo->prepare($sqlProductStock);  
$stmtProductStock->execute(array(&#39;:productNumber&#39; => $productInfo[&#39;product_number&#39;], &#39;:productId&#39; => $productInfo[&#39;product_id&#39;]));
$affectedRowsProductStock = $stmtProductStock->rowCount();
 
//库存没有正常扣除，失败，库存表里的product_stock_number设置了为非负数
//如果库存不足时，sql异常：SQLSTATE[22003]: Numeric value out of range: 1690 BIGINT UNSIGNED value is out of range in &#39;(`test`.`csdn_product_stock`.`product_stock_number` - 20)&#39;
if($affectedRowsProductStock <= 0) {
throw new PDOException("Out of stock, Failure to submit order!");
}
}
echo "Successful, Order Id is：" . $orderId ."，Order Amount is：" . $orderInfo[&#39;order_amount&#39;] . "。";
$pdo->commit();//提交事务
//exec("php order_cancel.php -a" . $orderId . " &");
pclose(popen(&#39;php order_cancel.php -a &#39; . $orderId . &#39; &&#39;, &#39;w&#39;));
//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();
}
?>

4, <strong>order_cancel.php</strong> </p>order_cancel.php<blockquote>

<?php
require("config.php");
$queryString = getopt(&#39;a:&#39;);
$userParams = array($queryString);
appendLog(date("Y-m-d H:i:s") . "\t" . $queryString[&#39;a&#39;] . "\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[&#39;a&#39;];  
$sql = "select order_status from csdn_order where order_id=:orderId";  
$stmt = $pdo->prepare($sql);  
$stmt->execute(array(&#39;:orderId&#39; => $orderId));  
$row = $stmt->fetch(PDO::FETCH_ASSOC);
//$row[&#39;order_status&#39;] === "1"代表已下单，但未付款，我们还原库存只针对未付款的订单
if(isset($row[&#39;order_status&#39;]) && $row[&#39;order_status&#39;] === "1") {
$sqlOrderDetail = "select product_id, product_number from csdn_order_detail where order_id=:orderId";  
$stmtOrderDetail = $pdo->prepare($sqlOrderDetail);  
$stmtOrderDetail->execute(array(&#39;:orderId&#39; => $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(&#39;:productNumber&#39; => $rowOrderDetail[&#39;product_number&#39;], &#39;:productId&#39; => $rowOrderDetail[&#39;product_id&#39;]));
}
 
$sqlRestoreOrder = "update csdn_order set order_status=:orderStatus where order_id=:orderId";  
$stmtRestoreOrder = $pdo->prepare($sqlRestoreOrder);
$stmtRestoreOrder->execute(array(&#39;:orderStatus&#39; => 0, &#39;:orderId&#39; => $orderId));
}
 
$pdo->commit();//提交事务
}catch(PDOException $e){
echo $e->getMessage();
$pdo->rollback();
}
$pdo = null;
 
appendLog(date("Y-m-d H:i:s") . "\t" . $queryString[&#39;a&#39;] . "\t" . "end\t" . json_encode($queryString));
}, $pdo);
 
} catch (PDOException $e) {
echo $e->getMessage();
}
function appendLog($str) {
$dir = &#39;log.txt&#39;;
$fh = fopen($dir, "a");
fwrite($fh, $str . "\n");
fclose($fh);
}
?>

Recommandations d'apprentissage associées : Programmation PHP de l'entrée à compétence

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!