commands/management/commands/qiniu.py

@@ -20,7 +20,7 @@ class Command(CompatibilityBaseCommand):

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

                 
              

                         while True:
              

                -            # r.rpushjson('QINIU_UPLOAD_LIST', {
              

                +            # r.rpushjson(QINIU_UPLOAD_LIST, {
              

                             #    'model': 'SaleclerkSubmitLogInfo',
              

                             #    'pk': 'pk',
              

                             # })
              

commands/management/commands/qiniuproducer.py

@@ -6,6 +6,7 @@ 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')
              
@@ -19,7 +20,7 @@ class Command(CompatibilityBaseCommand):

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

                 
              

                         for ssli in sslis:
              

                -            r.rpushjson('QINIU_UPLOAD_LIST', {
              

                +            r.rpushjson(QINIU_UPLOAD_LIST, {
              

                                'model': 'SaleclerkSubmitLogInfo',
              

                                'pk': ssli.pk,
              

                             })