python 调用接口

from app.external.yz.api_util importYzApiUtil


classYzUserApi(YzApiUtil):
    """有赞会员Api
    """

    def get_follower(self, fans_id=None, weixin_openid=None):
        """根据微信粉丝用户的 weixin_openid 或 fans_id 获取用户信息
        :param fans_id:
        :param weixin_openid:
        :return:
        """
        params ={}

        iffans_id:
            params['fans_id'] =fans_id
        elifweixin_openid:
            params['weixin_openid'] =weixin_openid
        else:
            returnNone

        data = self._invoke('youzan.users.weixin.follower.get', '3.0.0', 'GET', params=params)

        if 'response' indata:
            return data['response']['user']
        else:
            returnNone

    def get_customer(self, fans_id=None, mobile=None, youzan_account=None):
        """获取客户详情
        :param fans_id:
        :param mobile:
        :param youzan_account:
        :return:
        """
        params ={}

        iffans_id:
            params['account'] = '{"account_type":"FansID","account_id":"' + str(fans_id) + '"}'
        elifmobile:
            params['account'] = '{"account_type":"Mobile","account_id":"' + str(mobile) + '"}'
        elifyouzan_account:
            params['account'] = '{"account_type":"YouZanAccount","account_id":"' + str(youzan_account) + '"}'
        else:
            returnNone

        data = self._invoke('youzan.scrm.customer.get', '3.1.0', 'GET', params=params)

        if 'response' indata:
            return data['response']
        else:
            returnNone

    defget_openid(self, mobile):
        """使用手机号获取用户openId（获取的商家自有粉丝的openId。fans_type =1时）
        :param mobile: 会员手机号
        :return:
        {
          "open_id": "oTtVis-xiMQjlBME5Xi4Bc_twuqA",
          "union_id": "oqY0-wpXFmBsPI2IrTUYx3DigfjY"
        }
        """
        params ={
            'mobile': mobile,
        }

        data = self._invoke('youzan.user.weixin.openid.get', '3.0.0', 'GET', params=params)

        if 'response' indata:
            return data['response']
        else:
            returnNone

    defimport_user(self):
        """导入三方帐号信息，用于App开店帐号一键授权
        :doc: https://open.youzan.com/v3/apicenter/doc-api-main/1/2/account_import/youzan.user.platform.import
        """
        params ={
            'country_code': '+86',
            'mobile': '17392940060',
            'open_user_id': '17392940060',
        }

        data = self._invoke('youzan.user.platform.import', '1.0.0', 'GET', params=params)

        if 'response' indata:
            return data['response']
        else:
            return None

from app.external.yz.user_api importYzUserApi
from app.model.yz_user importYzUser
from app.utils.x_logger importlogger


classYzUserTestService:
    """有赞用户Test Service
    """
#  这是测试看是否通


    def __init__(self):
        self.yz_api_user =YzUserApi()

    defget_user(self, mobile):
        user = self.yz_api_user.get_customer(mobile=mobile)
        logger.info(user)
        returnuser


#主程序执行，理论上下面的这些不要写在里面。 执行数据保存
if __name__ == '__main__':
    result_user = YzUserTestService().get_user("18874189337")
# 用户传入参数

    yz_user =YzUser()
    yz_user.name = result_user['name']
    yz_user.telephone = result_user['mobile']
    yz_user.save()

    a = 1

from app importdb


classYzUser(db.Model):
    #自定义表名:
    __tablename__ = 'yz_user'id = db.Column(db.BigInteger, primary_key=True)
    name = db.Column(db.String(50), nullable=False, default='')
    telephone = db.Column(db.String(20), default='')

    defsave(self):
        db.session.add(self)
        db.session.commit()


if __name__ == '__main__':
    db.create_all()
    #test = YzUser.query.get(1)
a = 1