Django中如何在更新数据库字段n秒后自动将其重置为默认值

以下是几种不同复杂度的实现方式，可根据你的项目规模选择：

方案1：新增过期时间字段 + 业务逻辑校验（最轻量，无需额外服务） #

这是最推荐的低成本方案，不需要引入额外的定时任务中间件：

1. 先修改models.py的Item模型，新增过期时间字段：

from django.utils import timezone
from datetime import timedelta

class Item(models.Model):
    title = models.CharField(max_length=100)
    price = models.FloatField()
    bargainprice = models.FloatField(default=0)
    # 新增字段：砍价生效截止时间
    bargain_expire_at = models.DateTimeField(null=True, blank=True)
    
    # 封装获取砍价价格的方法，自动判断是否过期
    def get_bargain_price(self):
        if self.bargain_expire_at and timezone.now() < self.bargain_expire_at:
            return self.bargainprice
        # 过期直接返回默认值，也可以在这里主动触发数据库更新重置
        self.bargainprice = 0
        self.bargain_expire_at = None
        self.save(update_fields=['bargainprice', 'bargain_expire_at'])
        return 0

2. 修改Bargain视图，更新时设置过期时间：

def Bargain(request, uid):
    N = 60 # 这里替换为你需要的n秒数
    if request.method == 'POST':
        item = Item.objects.get(id=uid)
        item.bargainprice = request.POST['input']
        # 设置n秒后过期
        item.bargain_expire_at = timezone.now() + timedelta(seconds=N)
        item.save()
        message = 'update successful'
        return HttpResponse(message)
    else:
        return HttpResponse("this is not working..")

后续所有需要用到bargainprice的位置，直接调用item.get_bargain_price()即可自动获取正确的数值。

方案2：异步延迟任务（适合已使用Celery的项目） #

如果你的项目已经接入了Celery异步任务框架，可以直接用延迟任务实现自动重置：

1. 编写重置任务：

# 你的celery任务文件比如tasks.py
from celery import shared_task
from .models import Item

@shared_task
def reset_bargain_price(item_id):
    try:
        item = Item.objects.get(id=item_id)
        item.bargainprice = 0
        item.save(update_fields=['bargainprice'])
    except Item.DoesNotExist:
        pass

2. 修改视图，更新后提交延迟任务：

def Bargain(request, uid):
    N = 60 # 自定义n秒
    if request.method == 'POST':
        item = Item.objects.get(id=uid)
        item.bargainprice = request.POST['input']
        item.save()
        # 延迟n秒执行重置任务
        reset_bargain_price.apply_async(args=(uid,), countdown=N)
        message = 'update successful'
        return HttpResponse(message)
    else:
        return HttpResponse("this is not working..")

注意：如果用户短时间内多次提交砍价，需要额外逻辑取消之前未执行的延迟任务，避免提前重置。

方案3：轻量定时任务库（适合中小型项目，不想用Celery） #

可以用Django-Q、APScheduler这类更轻量的定时任务库，配置比Celery简单，不需要依赖消息队列，功能和Celery延迟任务类似，用法和上述Celery方案基本一致。

内容的提问来源于stack exchange，提问作者Rahul Sahni