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

import logging

from django_six import CompatibilityBaseCommand

from integral.models import SaleclerkSubmitLogInfo
from utils.redis.connect import r
from utils.redis.rkeys import QINIU_UPLOAD_LIST


logger = logging.getLogger('console')


class Command(CompatibilityBaseCommand):
    def handle(self, *args, **options):

        logger.info('Upload image qiniu producer is dealing')

        sslis = SaleclerkSubmitLogInfo.objects.filter(is_upload_qiniu=False)

        for ssli in sslis:
            r.rpushjson(QINIU_UPLOAD_LIST, {
                'model': 'SaleclerkSubmitLogInfo',
                'pk': ssli.pk,
            })