commands/management/commands/membercard.py

@@ -6,6 +6,7 @@ import logging

                 import requests
              

                 from django.conf import settings
              

                 from django.db import transaction
              

                +from django.db.models import Q
              

                 from django_six import CompatibilityBaseCommand, close_old_connections
              

                 from pywe_membercard import get_userinfo
              

                 from pywe_storage import RedisStorage
              
@@ -83,6 +84,12 @@ class Command(CompatibilityBaseCommand):

                                     logger.info(e.message)
              

                                     continue
              

                 
              

                +                logs = ConsumeInfoSubmitLogInfo.objects.filter(Q(user_id=userinfo.user_id) & (Q(phone=None) | Q(phone='')))
              

                +                for log in logs:
              

                +                    log.phone = userinfo.phone
              

                +                    log.save()
              

                +
              

                +
              

                                 try:
              

                                     phoneinfo = requests.get(settings.PHONE_2_ADMINISTRATIVE_DIVISION.format(phone))
              

                                 except Exception as e:
              
@@ -97,6 +104,6 @@ class Command(CompatibilityBaseCommand):

                                 logs = ConsumeInfoSubmitLogInfo.objects.filter(user_id=userinfo.user_id)
              

                                 for log in logs:
              

                                     log.province = log.province if log.lat and log.lon else province_name
              

                -                    log.phone = userinfo.phone
              

                +                    log.save()
              

                 
              

                             close_old_connections()