之前一直想记录一下在项目中使用到的事务以及支付宝支付功能，自己一直犯懒没有完，趁今天有点兴致，在这记录一下。
商城项目必备的就是支付订单的功能，所以就会涉及到订单的保存以及支付接口的引入。先来看看订单的保存，在数据库模型涉及之初，将订单分成了两个表，一个为订单表，记录订单的基本信息，如订单号，用户信息，运费之类，一个为订单商品表，记录该订单中的商品信息。在保存订单时，肯定会涉及到两个表的新建和保存，其实还有一张表也需要进行一些修改，那就是商品表，当一个订单保存成功，意味着本次交易成功，商品售出，商品的库存应该进行修改。所以，在保存订单这一操作中，涉及到的表有三张。所以在保存订单时，多表数据的修改，要嘛同时成功，要嘛同时失败，这就跟数据库中的事务很像，因此，在这里引入事务，来完成订单保存的功能。
在Django中可以通过 django.db.transaction 模块提供的 atomic 来定义一个事务， atomic 提供两种用法，一种是装饰器，一种是with语句。
from django.db import transaction@transaction.atomicdef viewfunc(request): # 这些代码会在一个事务中执行 ...from django.db import transactiondef viewfunc(request): # 这部分代码不在事务中，会被Django自动提交 ... with transaction.atomic(): # 这部分代码会在事务中执行 ...
在Django中，还提供了保存点的支持，可以在事务中创建保存点来记录数据的特定状态，数据库出现错误时，可以恢复到数据保存点的状态
from django.db import transaction# 创建保存点save_id = transaction.savepoint() # 回滚到保存点transaction.savepoint_rollback(save_id)# 提交从保存点到当前状态的所有数据库事务操作transaction.savepoint_commit(save_id)
所以，可以在序列化器的create方法中，创建一个事务，还进行数据的修改保存还有新建，若有地方出错，则直接回滚，若没有问题则提交事务。代码如下
def create(self, validated_data): """ 保存订单 """ # 获取当前下单用户 user = self.context['request'].user # 组织订单编号 20170903153611+user.id # timezone.now() -> datetime order_id = timezone.now().strftime('%Y%m%d%H%M%S') + ('%09d' % user.id) address = validated_data['address'] pay_method = validated_data['pay_method'] # 生成订单 with transaction.atomic(): # 创建一个保存点 save_id = transaction.savepoint() try: # 创建订单信息 order = OrderInfo.objects.create( order_id=order_id, user=user, address=address, total_count=0, total_amount=Decimal(0), freight=Decimal(10), pay_method=pay_method, status=OrderInfo.ORDER_STATUS_ENUM['UNSEND'] if pay_method == OrderInfo.PAY_METHODS_ENUM['CASH'] else OrderInfo.ORDER_STATUS_ENUM['UNPAID'] ) # 获取购物车信息 redis_conn = get_redis_connection("cart") redis_cart = redis_conn.hgetall("cart_%s" % user.id) cart_selected = redis_conn.smembers('cart_selected_%s' % user.id) # 将bytes类型转换为int类型 cart = {} for sku_id in cart_selected: cart[int(sku_id)] = int(redis_cart[sku_id]) # # 一次查询出所有商品数据 # skus = SKU.objects.filter(id__in=cart.keys()) # 处理订单商品 sku_id_list = cart.keys() for sku_id in sku_id_list: while True: sku = SKU.objects.get(id=sku_id) sku_count = cart[sku.id] # 判断库存 origin_stock = sku.stock # 原始库存 origin_sales = sku.sales # 原始销量 if sku_count > origin_stock: transaction.savepoint_rollback(save_id) raise serializers.ValidationError('商品库存不足') # 用于演示并发下单 # import time # time.sleep(5) # 减少库存 # sku.stock -= sku_count # sku.sales += sku_count # sku.save() new_stock = origin_stock - sku_count new_sales = origin_sales + sku_count # 根据原始库存条件更新，返回更新的条目数，乐观锁 ret = SKU.objects.filter(id=sku.id, stock=origin_stock).update(stock=new_stock, sales=new_sales) if ret == 0: continue # 累计商品的SPU 销量信息 sku.goods.sales += sku_count sku.goods.save() # 累计订单基本信息的数据 order.total_count += sku_count # 累计总金额 order.total_amount += (sku.price * sku_count) # 累计总额 # 保存订单商品 OrderGoods.objects.create( order=order, sku=sku, count=sku_count, price=sku.price, ) # 更新成功 break # 更新订单的金额数量信息 order.total_amount += order.freight order.save() except serializers.ValidationError: raise except Exception as e: logger.error(e) transaction.savepoint_rollback(save_id) raise # 提交事务 transaction.savepoint_commit(save_id) # 更新redis中保存的购物车数据 pl = redis_conn.pipeline() pl.hdel('cart_%s' % user.id, *cart_selected) pl.srem('cart_selected_%s' % user.id, *cart_selected) pl.execute() return order
