|
@@ -11,6 +11,7 @@ import datetime
|
|
import time
|
|
import time
|
|
|
|
|
|
from django.db import connection, connections, transaction
|
|
from django.db import connection, connections, transaction
|
|
|
|
+from django.db.models import Q
|
|
from django.views import View
|
|
from django.views import View
|
|
|
|
|
|
from Model.models import Device_User, Device_Info, UidSetModel, UID_Bucket, Unused_Uid_Meal, Order_Model, StsCrdModel, \
|
|
from Model.models import Device_User, Device_Info, UidSetModel, UID_Bucket, Unused_Uid_Meal, Order_Model, StsCrdModel, \
|
|
@@ -201,8 +202,9 @@ class CronUpdateDataView(View):
|
|
# 定时更新已过期套餐修改状态为2
|
|
# 定时更新已过期套餐修改状态为2
|
|
now_time = int(time.time())
|
|
now_time = int(time.time())
|
|
expired_uid_bucket = UID_Bucket.objects.filter(endTime__lte=now_time)
|
|
expired_uid_bucket = UID_Bucket.objects.filter(endTime__lte=now_time)
|
|
- id_list = expired_uid_bucket.values_list('id', flat=True)
|
|
|
|
- UID_Bucket.objects.filter(id__in=list(id_list)).update(use_status=2)
|
|
|
|
|
|
+ expired_uid_bucket = expired_uid_bucket.filter(~Q(use_status=2)).values('id')
|
|
|
|
+ if expired_uid_bucket.exists():
|
|
|
|
+ expired_uid_bucket.update(use_status=2)
|
|
# 监控有未使用套餐则自动生效
|
|
# 监控有未使用套餐则自动生效
|
|
expired_uid_buckets = \
|
|
expired_uid_buckets = \
|
|
UID_Bucket.objects.filter(endTime__lte=now_time, has_unused=1).values("id", "uid")[0:1000]
|
|
UID_Bucket.objects.filter(endTime__lte=now_time, has_unused=1).values("id", "uid")[0:1000]
|