account/models.py

@@ -457,6 +457,11 @@ class UserInfo(BaseModelMixin, LensmanTypeBoolMixin):

                             'level': self.level,
              

                         }
              

                 
              

                +    @property
              

                +    def sendcustomwxamessage(self):
              

                +        # 关注公众号 + 未领保修卡 + 已绑定镜头
              

                +        return self.subscribe and not self.has_membercard and self.shots_num
              

                +
              

                 
              

                 class UserLoginLogInfo(BaseModelMixin):
              

                     SUCCESS = 0
              

commands/management/commands/subscribe.py

@@ -12,6 +12,7 @@ from pywe_user import get_user_info

                 
              

                 from account.models import UserInfo
              

                 from mch.models import BrandInfo
              

                +from pre.custom_message import sendcustomwxamessage
              

                 from utils.redis.rkeys import SUBSCRIBE_USERINFO_LIST
              

                 
              

                 
              
@@ -77,6 +78,21 @@ class Command(CompatibilityBaseCommand):

                                     })
              

                                 else:
              

                                     SubscribeUserInfo.objects.filter(extraid=brand_id, openid=openid).update(subscribe=subscribe)
              

                +
              

                                 UserInfo.objects.filter(unionid=unionid).update(openid=openid, subscribe=subscribe)
              

                 
              

                +                try:
              

                +                    user = UserInfo.objects.get(unionid=unionid)
              

                +                except UserInfo.DoesNotExist:
              

                +                    continue
              

                +
              

                +                if user.sendcustomwxamessage:
              

                +                    sendcustomwxamessage(
              

                +                        openid='oK7eEjjqhoE6bTLX3k5Xa2reWzuI',
              

                +                        miniappid='wx02c3038b13008270',
              

                +                        pagepath='/pages/index/index',
              

                +                        thumb_media_id=u'xizg0MLt4x4jSJ38mTpf4dzINBqOMwVbfe3DoNFZ1BoqJ9iVyhGk_dvqwVIHcvlo',
              

                +                        title=u'测试一下'
              

                +                    )
              

                +
              

                             close_old_connections()