commands/management/commands/once_refresh_user_coupon_expired_time.py

@@ -1,16 +1,12 @@

                 # -*- coding: utf-8 -*-
              

                 
              

                 import logging
              

                -import time
              

                 
              

                -from django_six import CompatibilityBaseCommand, close_old_connections
              

                -from TimeConvert import TimeConvert as tc
              

                +from django_six import CompatibilityBaseCommand
              

                 
              

                 from account.models import UserInfo
              

                 from coupon.models import CouponInfo, UserCouponInfo
              

                 from member.models import RightInfo
              

                -from utils.redis.connect import r
              

                -from utils.redis.rkeys import MEMBER_SEND_COUPON_LIST
              

                 
              

                 
              

                 logger = logging.getLogger('console')
              
@@ -18,6 +14,8 @@ logger = logging.getLogger('console')

                 
              

                 class Command(CompatibilityBaseCommand):
              

                     def handle(self, *args, **options):
              

                +        UserInfo.objects.all().update(coupon_expire_at=None)
              

                +
              

                         coupon_ids = []
              

                 
              

                         rights = RightInfo.objects.filter(is_send_coupon=True, status=True)
              
@@ -35,7 +33,7 @@ class Command(CompatibilityBaseCommand):

                 
              

                         users = UserInfo.objects.all()
              

                         for user in users:
              

                -            coupons = UserCouponInfo.objects.filter(coupon_id__in=coupon_ids, status=True).order_by('-expire_at')
              

                +            coupons = UserCouponInfo.objects.filter(user_id=user.user_id, coupon_id__in=coupon_ids, status=True).order_by('-expire_at')
              

                             if not coupons:
              

                                 continue