您的位置:首页 > 教程 > 开发工具 > sublime > celery异步定时任务订单定时回滚

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

2022-04-12 20:54:30 来源:易采站长站 作者:

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

目录
订单回滚控制执行(多少时间后执行)celery异步定时任务

订单回滚

用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)

以上就是celery异步定时任务订单定时回滚 的详细内容,更多关于celery异步订单定时回滚任务的资料请关注易采站长站其它相关文章!

如有侵权,请联系QQ:279390809 电话:15144810328

相关文章

  • sublime php语法错误提示怎么发现

    sublime php语法错误提示怎么发现

    sublime php语法错误提示的发现方法:首先打开sublime软件;然后在sublime中写入php代码;接着按下快捷键“ctrl+B”,即可在执行过程中显示错误提示。昨晚因为php的某个变量代码写错了,sublime又没有提示语法错误。弄了许久,一段段的调试,最后才知道是取到的变量是空的sublime可以提示php语法错误在sublime写完了php代码后,如果写错了不像eclipse即时
    2020-08-15
  • Sublime Text3简体中文汉化包怎么用

    Sublime Text3简体中文汉化包怎么用

    下面由sublime教程栏目给大家介绍Sublime Text3简体中文汉化包的使用方法,希望对需要的朋友有所帮助!汉化包下载地址:https://github.com/Trojain/sublime-package1、由上面的链接得到的 Default.sublime-package 文件。打开sublime text 3 编辑器,打开菜单 => preferences => Browse Pa
    2020-08-20
  • 关于 Sublime Text 中的 Git

    关于 Sublime Text 中的 Git

    下面由sublime教程栏目给大家介绍Sublime Text 中的 Git,希望对需要的朋友有所帮助!Sublime Text 中的 Git从 3.2 版本开始,Sublime Text 在编辑器内集成了 Git。功能如下:侧边栏将会使用图标来指明文件及文件夹的 Git 状态。被你的 .gitignore 文件所指定忽略的文件以及文件夹会在侧边栏褪色显示。在状态栏,你能够查看当前所在分支以及你做
    2020-08-21
  • Sublime Text3+Markdown配置步骤【图文详解】

    Sublime Text3+Markdown配置步骤【图文详解】

    下面由sublime教程栏目给大家介绍Sublime Text3+Markdown配置步骤【图文详解】,希望对需要的朋友有所帮助!Sublime是一款非常优秀的文本编辑器,可以安装大量的插件,使用Sublime + Markdown更是有一番别样体验,在此只写如何正确配置(以Sublime Text 3为例),使用技巧请参阅相关文章。1.安装Package:Markdown Preview和Ma
    2020-08-22
  • 三步搞定sublime text 3配置

    三步搞定sublime text 3配置

    下面由sublime教程栏目给大家介绍sublime text 3的下载和配置,希望对需要的朋友有所帮助!下载sublime text 3在百度中搜索sublime text 3,进入sublime text官网,官网链接是http://www.sublimetext.com/。下载界面如图所示:点击Download for Windows按钮,下载sublime text 3,需要注意的是这里下
    2020-08-24
  • 分享Sublime Text 3 、WebStorm配置护眼主题(浅绿色)

    分享Sublime Text 3 、WebStorm配置护眼主题(浅绿色)

    下面由sublime教程栏目给大家分享Sublime Text 3 、WebStorm配置护眼主题(浅绿色),希望对需要的朋友有所帮助!本文所用软件版本Sublime Text 3(Build 3143)、WebStorm 2017.2.4(Build #WS-172.4155.35),其他版本软件配置过程可能不一样,请知悉!1.Sublime Text 3护眼主题 (1)下载配置文件 链
    2020-08-26
  • Sublime Merge 是什么

    Sublime Merge 是什么

    下面由sublime教程栏目给大家介绍Sublime Merge,希望对需要的朋友有所帮助!Sublime Merge 是由知名文本编辑器 Sublime Text 开发商打造的 Git 客户端,仅适用于 64 位平台。按开发商的说法,Sublime Merge 融合了 Sublime Text 的 UI 引擎和从零开始的 Git* 实现。所以这一工具继承了 Sublime Text 优雅美观的
    2020-08-27
  • Sublime Text 快捷键列表分享

    Sublime Text 快捷键列表分享

    下面由sublime教程栏目给大家介绍Sublime Text 快捷键,希望对需要的朋友有所帮助!Sublime Text 快捷键列表 快捷键按类型分列如下:1、通用 ↑↓← → 上下左右移动光标 Alt 调出菜单 Ctrl + Shift + P 调出命令板(Command Palette) Ctrl + ` 调出控制台2
    2020-08-29