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

import logging

from django_six import CompatibilityBaseCommand
from TimeConvert import TimeConvert as tc

from account.models import UserInfo
from utils.redis.connect import r
from utils.redis.rkeys import MEMBER_SEND_COUPON_LIST2


logger = logging.getLogger('console')


class Command(CompatibilityBaseCommand):
    def handle(self, *args, **options):
        users = UserInfo.objects.filter(coupon_expire_at__lte=tc.utc_datetime(), status=True)
        # 发放会员权益
        for user in users:
            r.rpushjson(MEMBER_SEND_COUPON_LIST2, {
                'user_id': user.user_id,
            })