在日常的业务逻辑中,订单通常为一对多的形式,即一个订单表对应着多个商品或数据,在设计数据库的时候会将划分两个表:订单表和订单详情表;
????????然而在大部分的业务逻辑中也可能不会涉及到订单的事务操作,但是并不排除一小部分的业务逻辑会用到,比如:(1)门票购买,一人一种票一个活动只能购买一张门票? (2)特定商品,一人一天一个商品只能购买一次;
????????在这种情况下我们需要在生成订单前先去判断是否符合条件,如果符合条件就插入数据,如果不符合就进行回滚;
? ? ? ? 本次模拟业务场景:优惠券购买,一人 一种类型券 只能购买一次,用户在购买时可以以手机号为准为他人购买优惠券;
订单表(order):
id | order_sn(订单编号) | num(数量) | price(价格) | status(状态) | create_time | 1 | 2021080715402395715 | 2 | 20 | 1 | 1628322066 | 2 | 2021080715402557765 | 3 | 100 | 2 | 1628322068 |
订单详情表(order_info):
id | order_id(订单表ID) | u_id(用户ID) | g_id(劵id) | num(数量) | price(价格) | create_time | 1 | 1 | 1 | 1 | 1 | 5 | 1628322066 | 2 | 1 | 2 | 1 | 1 | 15 | 1628322068 |
? ? ? ? 插入的业务流程通常为:先插入订单表,拿到插入后的ID 然后在插入订单详情表,但是在需要预生成插入数据或者在插入一半发生了错误应该怎么办呢?
解决思路一:
? ? ? ? 在预生成“订单详情表”数据的时候可以先查询一遍该表的自增ID是多少,然后进行写入,可以使用数据库自带语句,返回的数组中Auto_increment字段便是下一个主键ID;
SHOW TABLE STATUS FROM ?库名 WHERE Name = "表名"
????????但是这种办法我觉得并不太可取,在较大并发的情况下可能会出现订单ID错乱的情况,是较大并发不是高并发!!!
解决思路二:
? ? ? ? 在进行事务操作时,使用函数 array_walk 进行数组组合,把订单表插入后的ID合并到订单详情表的二维数组中,注意是二维数组!下面代码就是用的这种方式
项目实例,进行了部分删减,复制出去肯定用不了 不要在意细节!
<?php
namespace app\home\controller;
use app\common\model\Order;
use app\common\model\OrderInfo;
use app\common\model\User;
class Coupon extends Base{
/**
* 优惠券购买业务流程
* 注意;代码中只写业务逻辑,部分代码已经省略,直接复制粘贴用不了!
*/
public function add(){
// 接收请求的数据
$data = input("data/a");
// 查询优惠券是否正常,防止非法提交
$event_charge = 【假装在查询了】;
if(empty($event_charge)){
return error_json('没有找到相应的优惠券信息!');
}
// 根据提交的信息查询用户信息
$check = User::check(['mobile'=>$data['mobile']]);
// 判断这个人有没有订单
$is_ticket_info = 【假装在查询了】;
if(!empty($is_ticket_info)){
return error_json('购买人已购买过这个类型的优惠券了!');
}
// 写入订单表数据
$insert_one = [
'order_sn'=> date("YmdHis").rand(10000,99999), //订单编号
'num' => '', //商品数量,留空后期补
'price' => '', //订单总价,留空后期补
'status' => 1,//订单状态 -1取消 1待付款 2已付款
'create_time' => time(), //订单创建时间
];
// 写入订单详情表数据
$insert_info = [
'num' => 1, //目前只能买一个所以写死了
'status' => 1,//订单状态 -1取消 1待付款 2已付款 3已核销
'create_time' => time(), //订单创建时间
];
$ticket_info = [
'u_id'=>$check['id'], //用户ID
'g_id'=>$event_charge['id'],//优惠券ID
];
// 重要一步!先存到一个数组中,后期一起插入数据!!!
$ticket_info_insert[] = array_merge($insert_info, $ticket_info);
// 判断有没有为他人买优惠券
if(!empty($data['for_others'])){
$total_number = 1; //因为主订单最少有一个商品
$total_price = $event_charge['amount']; //主订单的价格
// 循环遍历为他人购票的数组
foreach ($data['for_others'] as $v){
// 查询优惠券是否正常,防止非法提交【同上】
// 根据提交的信息查询用户信息【同上】
// 判断这个人有没有订单【同上】
// 查询这个人的信息【同上】
// 写入到订单详情表
$ticket_info = [
'u_id'=>$exist['id'], //用户ID
'g_id'=>$event_charge['id'],//优惠券ID
];
// 重要一步!继续存到数组中,后期一起插入数据!!!
$ticket_info_insert[] = array_merge($insert_info, $ticket_info);
}
}
// 启动事务
Db::startTrans();
try {
// 写入订单表
$order = Order::create($insert_one);
// 把订单表ID合并到订单详情表
$arr = ['order_id' => $order->id];
array_walk($ticket_info_insert, function(&$value,$key,$arr){
$value = array_merge($value, $arr);
},$arr);
// 写入订单详情表
(new OrderInfo)->saveAll($ticket_info_insert);
// 修改订单表的商品数量和价格信息
if(!empty($data['for_others'])){
Order::update(['num'=>$total_number,'price'=>$total_price],['id'=>$order->id]);
}
// 提交事务
Db::commit();
} catch (\Exception $e) {
// 回滚事务
Db::rollback();
}
// 成功返回订单id
return success_json(['id'=>$order->id]);
}
}
|