commands/management/commands/qiniuproducer.py

@@ -0,0 +1,25 @@

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

                +
              

                +import logging
              

                +
              

                +from django_six import CompatibilityBaseCommand
              

                +
              

                +from integral.models import SaleclerkSubmitLogInfo
              

                +from utils.redis.connect import r
              

                +
              

                +
              

                +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,
              

                +            })