celery异步定时任务订单定时回滚_Python

订单回滚

用celery异步，定时任务。可以设置：如果下单15分钟后没有支付，则取消订单。做反向操作

控制执行(多少时间后执行)

				?

									from datetime import datetime

									from pro_celery.celery import del_order

									def pay_status(order_id,check_time=5):  # 5秒后

									    ctime  = datetime.now()

									    utc_ctime = datetime.utcfromtimestamp(ctime.timestamp())

									    from  datetime import timedelta

									    #seconds参数表示多少秒后执行

									    time_delay = timedelta(seconds=check_time)

									    time_task = utc_ctime+ time_delay

									    #提交任务给del_order,让他多久后执行

									    res = del_order.apply_async(args = [order_id,],eta= time_task)

celery异步定时任务

此任务是如果下单5秒后没有支付，则取消订单。做反向操作。库存再次添加到数据库。

注意：考虑到了并发量一多会出现零界点小概率事件，在执行库存加到数据库中的哪一行代码，用户立马支付了。

出现的后果：用户支付了，库存却加到数据库中了，订单也没有了。

如何避免：在事务里面判断影响的行数，如果影响行数为1，证明取消订单成功，可以commit。

如果没有影响行数，证明用户在这一刻支付成功，回滚数据

				?

									# 一定要判断pay_status，防止途中完成支付

									        row = models.Order.objects.filter(order_id = order_id,pay_status=0).update(status = "dead")

									        if row:

									            transaction.savepoint_commit(sid)

									        else:

									            transaction.savepoint_rollback(sid)

				?

									import celery

									import time

									backend = "redis://127.0.0.1:6379/1"

									broker = "redis://127.0.0.1:6379/2"

									cel = celery.Celery("test",backend=backend,broker = broker)

									import os,sys

									import django

									BASE_DIR = os.path.dirname(os.path.dirname(__file__)) #定位到你django的根目录

									sys.path.append(os.path.abspath(BASE_DIR))

									os.environ.setdefault("DJANGO_SETTINGS_MODULE", "shopapi.settings")

									django.setup()

									from django.db import transaction

									@cel.task

									@transaction.atomic

									def del_order(order_id):

									    #要通过数据库来查当前order_id的订单状态，如果没有支付，我们要操作库存，并且取消订单

									    from  app01 import models

									    # 查询订单

									    data = models.Order.objects.filter(order_id = order_id,pay_status=0).first()

									    #如果data没有，表示以及支付成功，无需操作，反之要回滚库存

									    if data:

									        # 回滚哪些商品的库存，回滚多少？从哪里知道order_item中看

									        item_data = models.Order_items.objects.filter(order_id =order_id).values("product","nums")

									        # item_data-->[{'product':1,'nums":2},{product':2,'nums":1}]

									        all_product_dict = {k["product"] :k["nums"]  for k in item_data}

									        #{1:2,2:2}

									        all_product_id = list(all_product_dict.keys())

									        all_product = models.Product.objects.filter(product_id__in = all_product_id)

									        #开启事务

									        sid = transaction.savepoint()

									        for product in all_product:

									            for i in range(3):

									                stock = product.stock.quantity

									                new_stock = stock + all_product_dict[product.product_id]

									                #用了乐观锁

									                res = models.Stock.objects.filter(quantity=stock,stock_id=product.stock.stock_id).update(quantity=new_stock)

									                if not res:

									                    if i==2:

									                        transaction.savepoint_rollback(sid)

									                        from app01.func import function_tool

									                        function_tool.pay_status(order_id,1)

									                        return

									                    else:

									                        continue

									                else:

									                    break

									            new_buy_cont = product.buy_count-all_product_dict[product.product_id]

									            models.Product.objects.filter(product_id = product.product_id).update(buy_count = new_buy_cont)

									        # 一定要判断pay_status，防止途中完成支付

									        row = models.Order.objects.filter(order_id = order_id,pay_status=0).update(status = "dead")

									        if row:

									            transaction.savepoint_commit(sid)

									        else:

									            transaction.savepoint_rollback(sid)