# coding=utf-8
# Copyright (c) 2016-2018 The Ulord Core Developers
# @File : user.py
# @Author: Ulord_PuJi
# @Date : 2018/5/18 0018
import inspect, logging, os, time
from uuid import uuid1
from ulordapi import utils, up
from ulordapi.udfs import udfs
from ulordapi.config import config, ulordconfig, webconfig, dbconfig, ROOTPATH
from ulordapi.manage import db, User, Resource, Tag, create
from ulordapi.errcode import _errcodes, return_result
[docs]class Developer(up.UlordHelper):
"""
basic develoer class to execute some functions
"""
def __init__(self, appkey, secret):
"""
init the developer. create a udfs helper, a ulord-helper, add a logger
:param appkey: application key
:type appkey: str
:param secret: application secret
:type secret: str
"""
up.UlordHelper.__init__(self, appkey, secret)
utils.Update(ulordconfig,
utils._byteify({
'ulord_appkey': appkey,
'ulord_secret': secret
})
)
config.save()
self.udfs = udfs.UdfsHelper()
self.ulord = up.UlordHelper()
if webconfig.get('privkeypath'):
self.pripath = webconfig.get('privkeypath')
else:
self.pripath = os.path.join(ROOTPATH, 'private.pem')
if webconfig.get('pubkeypath'):
self.pubpath = webconfig.get('pubkeypath')
else:
self.pubpath = os.path.join(ROOTPATH, 'public.pem')
self.rsahelper = utils.RSAHelper(self.pubpath, self.pripath)
[docs] def decrypt(self, args):
"""
check if the arg is encrypted.If encrypted return decrypted arg,else return None.
:param args: arg need to be checked,
:type args: str/str list
:return: decrypted arg or arg(unicode)
"""
result = None
try:
if isinstance(args, list):
result = []
for arg in args:
if arg:
temp_arg = self.rsahelper._decrypt(arg)
if not isinstance(temp_arg, unicode):
temp_arg = temp_arg.decode('utf-8')
result.append(temp_arg)
else:
result.append(arg)
else:
result = self.rsahelper._decrypt(args)
if not isinstance(result, unicode):
result = result.decode('utf-8')
except:
# todo need to think twice
try:
self.log.warning("{0} cann't decrypt,using {0}".format(str(args)))
except:
self.log.debug("args is unicode")
if result:
return result
else:
return None
[docs] def config_edit(self, args=None):
"""
config operations
:param args: a list or a dict.Update config
:type args: list/dict
:return: args dict
"""
# args is a list or a dict
if isinstance(args, list):
args = utils.ListToDict(args)
if not isinstance(args, dict):
return None
if args:
utils.Update(config, utils._byteify(args))
# write to the config file
config.save()
return args
[docs] def config_show(self, args=None):
"""
show config.Default show all.
:param args: keys
:type args: list/dict
:return: config according to the keys
"""
result = config
if args and isinstance(args, list):
for arg in args:
if result is None:
return None
result = result.get(arg)
return result
# def config_init(self):
# """
# init config
# """
# udfs operations
[docs] def udfs_download(self, udfshashs):
"""
download file from ulord.udfses is a udfs list
:param udfshashs: udfs hashes
:type udfshashs: list
:return: udfshash - True/False
"""
result = {}
for udfshash in udfshashs:
# TODO multi threading
if utils.isUdfsHash(udfshash):
filehash = self.udfs.downloadhash(udfshash)
result.update({
udfshash: filehash
})
else:
result.update({
udfshash: 0 # "not a udfshash"
})
return result
[docs] def udfs_upload(self, fileinfos):
"""
upload file into ulord.fileinfo is a file list
:param fileinfos: file need to upload to the ulord-platform
:type fileinfos: list/str
:return: dict fileinfo - True/False
"""
result = {}
error = {}
if isinstance(fileinfos, list):
for fileinfo in fileinfos:
# TODO multi threading
if os.path.isfile(fileinfo):
filehash = self.udfs.upload_file(fileinfo)
else:
filehash = self.udfs.upload_stream(fileinfo)
if filehash:
result.update({
fileinfo: filehash
})
else:
self.log.error("Failed update:{}".format(fileinfo))
error.update({
fileinfo: filehash
})
else:
if os.path.isfile(fileinfos):
filehash = self.udfs.upload_file(fileinfos)
else:
filehash = self.udfs.upload_stream(fileinfos)
if filehash:
result.update({
fileinfos: filehash
})
else:
self.log.error("Failed update:{}".format(fileinfos))
error.update({
fileinfos: filehash
})
return result
[docs] def udfs_cat(self, udfshashs):
"""
view the udfs hash comment
:param udfshashs: udfs hashes
:type udfshashs: list
:return: dict udfshash - True/False
"""
result = {}
for udfshash in udfshashs:
if utils.isUdfsHash(udfshash):
file_context = self.udfs.cat(udfshash)
result.update({
udfshash: file_context
})
else:
result.update({
udfshash: 0 # "not a udfshash"
})
return result
# Advanced command
[docs] def request(self, method, url, data=None):
"""
advanced command. request to the ulord-platform
:param method: request method,like post,get and so on.
:type method: str
:param url: request url
:type url: str
:param data: request data
:type data: dict
:return: return result.you can query the errcode
"""
if method.lower() == 'post':
return self.post(url=url, data=data)
if method.lower() == 'get':
return self.get(url=url)
# def help(self):
# """
# :return: dict.self method
# """
# # todo create self help
# return inspect.getmembers(self, predicate=inspect.ismethod)
[docs]class Senior(Developer):
"""
Senior programmer to develop his application.
"""
def __init__(self, appkey, secret):
"""
:param appkey:application app key, you can get it when you regist from the ulord-platform.
:type appkey: str
:param secret: application app secret, you can get it when you regist from the ulord-platform.
:type secret: str
"""
Developer.__init__(self, appkey, secret)
self.log = logging.getLogger("Senior:")
self.log.debug("Senior init")
[docs]class Junior(Developer):
"""
Junior programmer to develop his application.Using default database.
"""
def __init__(self, appkey, secret):
"""
init a junior programmer to use functions
:param appkey: application app key, you can get it when you regist from the ulord-platform.
:type appkey: str
:param secret: application app secret, you can get it when you regist from the ulord-platform.
:type secret: str
"""
Developer.__init__(self, appkey, secret)
self.log = logging.getLogger("Junior:")
self.log.debug("Junior init")
# up functions
[docs] def user_regist(self, username, password, cellphone=None, email=None, wallet=None, pay_password=None, encrypted=False):
"""
user regist
:param username: user name
:type username: str
:param password: user password
:type password: str
:param cellphone: user cellphone.Default is None.
:type cellphone: str
:param email: user email.Default is None.
:type email: str
:param wallet: user wallet name.Default is username.
:type wallet: str
:param pay_password: user wallet password.Default is hash password.
:type pay_password: str
:param encrypted: check if the password encrypted
:type encrypted: bool
:return: user token
"""
# encrypt
if encrypted:
password = self.decrypt(password)
# check arg
if User.query.filter_by(username=username).first() is not None:
return _errcodes.get(60000)
if email and not utils.isMail(email):
return _errcodes.get(60105)
if cellphone and not utils.isCellphone(cellphone):
return _errcodes.get(60106)
user = User(username=username)
user.hash_password(password)
if pay_password:
if encrypted:
pay_password = self.decrypt(pay_password)
user.pay_password = pay_password
else:
user.pay_password = user.password_hash
if wallet:
user.wallet = wallet
else:
user.wallet = username
user.cellphone = cellphone
user.email = email
regist_result = self.regist(user.wallet, user.pay_password)
if regist_result.get("errcode") != 0:
return regist_result
user.token = str(uuid1())
user.timestamp = int(time.time()) + webconfig.get('token_expired')
user.id = str(uuid1())
db.session.add(user)
db.session.commit()
return return_result(0, result={"token": user.token})
# return user.token
[docs] def user_login(self, username, password, encrypted=False):
"""
user login
:param username: user name
:type username: str
:param password: user password
:type password: str
:param encrypted: check if the password is encrypted
:type encrypted: bool
:return: user token
"""
if encrypted:
password = self.decrypt(password)
login_user = User.query.filter_by(username=username).first()
if not login_user:
return _errcodes.get(60002)
if not login_user.verify_password(password):
return _errcodes.get(60003)
login_user.token = str(uuid1())
login_user.timestamp = int(time.time()) + webconfig.get('token_expired')
db.session.commit()
return return_result(0, result={"token": login_user.token})
# return login_user.token
[docs] def user_logout(self, token=None, username=None):
"""
user logout.Change user's timestamp
:param token: user token
:type token: str
:param username: user name
:type username: str
:return: username or errcode.You can query the errcode dict.
"""
login_user = None
if token:
login_user = User.query.filter_by(token=token).first()
if int(login_user.timestamp) < time.time():
return _errcodes.get(60104)
elif username:
login_user = User.query.filter_by(username=username).first()
if login_user:
login_user.timestamp = int(time.time()) - 1
return return_result(0, result={'username':login_user.username})
else:
return _errcodes.get(60002)
[docs] def user_activity(self, token=None, username=None):
"""
activity.App developer send some ulords to the user.
:param token: user token
:type token: str
:param username: user name
:type username: str
:return: True or False.
"""
login_user = None
if token:
login_user = User.query.filter_by(token=token).first()
if int(login_user.timestamp) < time.time():
return _errcodes.get(60104)
elif username:
login_user = User.query.filter_by(username=username).first()
if login_user:
if login_user.activity == webconfig.get('amount'):
return return_result(60301)
credit_result = self.paytouser(login_user.wallet)
if credit_result.get('errcode') != 0:
return credit_result
else:
login_user.activity = webconfig.get('amount')
return return_result(0,result={"amount": webconfig.get('amount')})
else:
return _errcodes.get(60002)
[docs] def resource_publish(self, title, udfshash, amount, tags, des, usercondition):
"""
user publish resource
:param title: resource title
:type title: str
:param udfshash: resource uplorded to the UDFS hash
:type udfshash: str
:param amount: resource price
:type amount: float
:param tags: resource tag
:type tags: list
:param des: resource description
:type des: str
:param usercondition: a condition which need to query user
:type usercondition: dict
:return: errcode.You can query from the errcode.
"""
# body is a file
# check udfshash
if not utils.isUdfsHash(udfshash):
return _errcodes.get(60107)
if 'userid' in usercondition:
userid = usercondition.get('userid')
current_user = User.query.filter_by(id=userid).first()
elif 'username' in usercondition:
username = usercondition.get('username')
current_user = User.query.filter_by(username=username).first()
elif 'usertoken' in usercondition:
token = usercondition.get('usertoken')
current_user = User.query.filter_by(token=token).first()
else:
return return_result(60100) # missing user info argument
# save to the localDB
# change demand:title can be repeatedly.
# if Resource.query.filter_by(title=title, userid=current_user.id).first() is not None:
# # existing title
# return _errcodes.get(60007)
# TODO check balance
if not isinstance(amount, float):
try:
amount = float(amount)
except:
amount = 0
# publish to the ulord-platform
data = {
'author': current_user.wallet,
'title': title,
'tags': tags,
'udfs_hash': udfshash,
'price': amount,
'pay_password': current_user.pay_password,
'des': des,
'content_type': '.txt'
}
# key_dict = ['author', 'title','tags','udfs_hash','price','content_type','des']
# for key in key_dict:
# data.update({
# key:
# })
# data['author'] = current_user.wallet
# data['title'] = title
# data['tags'] = tags
# data['udfs_hash'] = udfshash
# data['price'] = amount
# data['pay_password'] = current_user.pay_password
# data['des'] = des
publish_result = self.publish(data)
if publish_result and publish_result.get('errcode') == 0:
new_resource = Resource(id=str(uuid1()), title=title, userid=current_user.id, body=udfshash, amount=amount,
description=des, views=0, date=int(time.time()))
if tags:
for tag in tags:
current_tag = Tag.query.filter_by(tagname=tag).first()
if current_tag is None:
new_resource.tags.append(Tag(tag))
else:
new_resource.tags.append(current_tag)
if publish_result.get('result'):
if 'id' in publish_result.get('result'):
new_resource.UPID = publish_result.get('result').get('id')
if 'claim_id' in publish_result.get('result'):
new_resource.claimID = publish_result.get('result').get('claim_id')
db.session.add(new_resource)
db.session.commit()
# return new_resource.claimID
# else:
# return publish_result
return publish_result
# def resource_update(self, id, pay_password, encrypted=True, **kwargs):
# """
# user update data to the ulord-platform
#
# :param id: data id
# :type id: str
# :param pay_password: auther wallet pay password
# :type pay_password: str
# :param encrypted: if encrypt password
# :type encrypted: bool
# :param kwargs: key-value
# :type kwargs:
# :return: errcode.You can query from the errcode.
# """
# current_resource = Resource.query.filter_by(UPID=id).first()
# if encrypted:
# pay_password = self.decrypt(pay_password)
# current_user = User.query.filter_by(id=current_resource.userid).first()
# if not current_user:
# return return_result(60002)
# if not current_user.verify_password(pay_password):
# return return_result(60003)
# data = {
# 'id': id,
# 'pay_password': current_user.pay_password
# }
# # upload data to the udfs
# if 'body' in kwargs and kwargs.get('body'):
# body = kwargs.get('body')
# udfs_hash_dict = self.udfs_upload(body)
# data.update({
# 'udfs_hash':udfs_hash_dict.get(body)
# })
# key_dict = ["title","content_type", "des"]
#
# for key in key_dict:
# value = kwargs.get(key)
# if value:
# # value = value.encode('utf-8')
# data.update({
# key: value
# })
# try:
# setattr(current_resource, key, value)
# except Exception as e:
# print e
# print key
# print value
# if "tags" in kwargs:
# tags = kwargs.get("tags")
# for tag in tags:
# current_tag = Tag.query.filter_by(tagname=tag).first()
# if current_tag is None:
# current_resource.tags.append(Tag(tag))
# else:
# current_resource.tags.append(current_tag)
# data.update({
# 'tags':tags
# })
# result = self.update(data)
# if result and result.get('errcode') == 0:
# db.session.commit()
# return result
[docs] def resource_update(self, id, pay_password, encrypted=True, title=None, body=None, price=None, tags=None, des=None):
"""
user update data to the ulord-platform
:param id: data id
:type id: str
:param pay_password: auther wallet pay password
:type pay_password: str
:param encrypted: if encrypt password
:type encrypted: bool
:param title: resource title
:type title: str
:param body: resource
:type body: str
:param price: resource price
:type price: float
:param tags: resource tags
:type tags: list
:param des: resource description
:type des: str
:return: errcode.You can query from the errcode.
"""
current_resource = Resource.query.filter_by(UPID=id).first()
if encrypted:
pay_password = self.decrypt(pay_password)
current_user = User.query.filter_by(id=current_resource.userid).first()
if not current_user:
return return_result(60002)
if not current_user.verify_password(pay_password):
return return_result(60003)
data = {
'id': id,
'pay_password': current_user.pay_password
}
if title:
data.update({
'title': title
})
current_resource.title = title
if body:
udfs_hash_dict = self.udfs_upload(body)
if not udfs_hash_dict or not udfs_hash_dict.get(body):
return return_result(60200)
data.update({
'udfs_hash': udfs_hash_dict.get(body)
})
current_resource.body = udfs_hash_dict.get(body)
if price:
data.update({
'price': price
})
current_resource.amount = price
if des:
data.update({
'des': des
})
current_resource.description = des
if tags:
for tag in tags:
current_tag = Tag.query.filter_by(tagname=tag).first()
if current_tag is None:
current_resource.tags.append(Tag(tag))
else:
current_resource.tags.append(current_tag)
data.update({
'tags':tags
})
result = self.update(data)
if result and result.get('errcode') == 0:
db.session.commit()
return result
[docs] def resouce_views(self, claim_id):
"""
add resource view
:param claim_id: resource claim_id
:type claim_id: str
:return: resource current view
"""
resources = Resource.query.filter_by(claimID=claim_id).first()
resources.views += 1
db.commit()
return resources.views
[docs] def pay_resources(self, payer, claim_id, password, encrypted=False):
"""
user pay resource
:param payer: payer
:type payer: User
:param claim_id: resource claim id
:type claim_id: str
:param password: payer password
:type password: str
:return: errcode.You can query from the errcode.
"""
if encrypted:
password = self.decrypt(password)
# check password
if not payer.verify_password(password):
return return_result(60003)
return self.transaction(payer.wallet, claim_id, payer.pay_password)
[docs] def pay_ads(self, wallet, claim_id, authername):
"""
user view ads
:param wallet: user wallet name
:type wallet: str
:param claim_id: resource claim id
:type claim_id: str
:param authername: resource auther name
:type authername: str
:return: errcode.You can query from the errcode.
"""
auther = User.query.filter_by(username=authername).first()
if not auther:
return return_result(60108)
return self.transaction(wallet, claim_id, auther.pay_password, isads=True)
[docs] def user_info_query(self, username=None, token=None):
"""
user information
:param username: username.Default is none.
:type username: str
:param token: user token.Default is none.
:type token: str
:return: dict.User info
"""
login_user = None
if token:
login_user = User.query.filter_by(token=token).first()
if int(login_user.timestamp) < time.time():
return return_result(60104)
elif username:
login_user = User.query.filter_by(username=username).first()
if login_user:
result = {
'username': login_user.username,
"cellphone": login_user.cellphone,
"Email": login_user.email
}
return return_result(result=result)
else:
return return_result(60002)
[docs] def user_infor_modify(self, password, username=None, token=None, encrypted=False, cellphone=None, email=None, new_password=None):
"""
user information
:param username: username.Default is none.
:type username: str
:param token: user token.Default is none.
:type token: str
:param encrypted: if encrypted password.If ture,all password will be decrypted.
:type encrypted: bool
:param password: user passowrd to confirm account
:type password: str
:param cellphone: user new cellphone
:type cellphone: str
:param email: user new email
:type email: str
:param new_password: user new password
:type new_password: str
:return: dict.User info
"""
login_user = None
if token:
login_user = User.query.filter_by(token=token).first()
if int(login_user.timestamp) < time.time():
return return_result(60104)
elif username:
login_user = User.query.filter_by(username=username).first()
if login_user:
if password:
if encrypted:
password = self.decrypt(password)
# check password .It's maybe a none.
if password and login_user.verify_password(password):
pass
else:
return _errcodes.get(60003)
else:
return return_result(60100)
if email:
if utils.isMail(email):
login_user.email = email
else:
return return_result(60105)
if cellphone:
if utils.isCellphone(cellphone):
login_user.cellphone = cellphone
else:
return return_result(60106)
if new_password:
if encrypted:
new_password = self.decrypt(new_password)
if new_password:
login_user.hash_password(new_password)
db.session.commit()
result = {
'username': login_user.username,
"cellphone": login_user.cellphone,
"Email": login_user.email
}
return return_result(result=result)
else:
return return_result(60002)
[docs] def create_database(self, path=None):
"""
create database
:param path: database path.Warining:It'a a dir
:type path: str
:return: True/False
"""
# check if the database is exited
if dbconfig.get('IsCreated'):
self.log.warning("DB has created!")
else:
self.log.info("Creating DB...")
if path:
try:
os.stat(path)
except:
os.mkdir(path)
utils.Update(dbconfig,
utils._byteify({
'SQLALCHEMY_DATABASE_URI':'sqlite:///{}'.format(os.path.join(path,'sqlite.db'))
})
)
config.save()
create()
dbconfig.update({
'IsCreated': True
})
config.save()
# web command
[docs] def start_web(self):
"""
start web server
"""
import webServer
webServer.start()
webconfig.update({
"start": True
})
# advanced command
[docs] def query(self, sql):
"""
advanced command self query
:param sql: sql sentence
:type sql: str
:return: query result
"""
try:
result = db.engine.execute(sql)
except Exception as e:
self.log.error("Execute sql({0}) failed! Exception is{1}".format(sql, e))
result = None
return result
if __name__ == '__main__':
# ************************中级开发者接口测试***************************************************
# develop = Senior(
# appkey='8326648868ad11e8b894fa163e37b4c3',
# secret='8326648968ad11e8b894fa163e37b4c3'
# )
# test = develop.rsahelper._encry("test")
# print(test)
# result = develop.decrypt(args='I9FrluvSwrtmmd7MIZgvfNlbwHU2g4R/v88eoU28cfHXt0x/wWWHNeEAJenFPEc76fmDgcvASHPMUXYAkeJlzqsq5MhleFQMRaxR6dpsVL3rCAd9feOQbl3kMg4oaJqpAKcJ71v8J2EGAOf4suTnGEmj2kYshrR1PdxSsThRLc8=')
# print(result)
# result = develop.config_edit(['dbconfig','JSON_AS_ASCII', True])
# print(result)
# result = develop.config_show(['dbconfig'])
# print(result)
# result = develop.udfs_download(['QmQng3FX98mSe34z3jM1QFQ7XVsoEDWPbKg25ygPaWzgv4'])
# print(result)
# result = develop.udfs_upload('E:\ulord\py-ulord-api\ulordapi\udfs\upapi.log')
# print(result)
# result = develop.udfs_cat(['QmRtvbkn8sa47rhxf6ujUYJFxhinNVkh5LH2iCsgvNJVKe'])
# print(result)
# result = develop.request(method='get',url='http://114.67.37.2:10583/v1/content/list/1/1')
# print(result)
# result = develop.regist(username='tests',password='123')
# print(result)
# result = develop.publish(data={
# "author": "tests",
# 'pay_password': '123',
# "title": "第一篇技术博客",
# "tags": ["blockchain", "UDFS"],
# "udfs_hash": "QmVcVaHhMeWNNetSLTZArmqaHMpu5ycqntx7mFZaci63VF",
# "price": 0.1,
# "content_type": ".txt",
# "des": "这是使用UDFS和区块链生成的第一篇博客的描述信息"
# })
# print(result)
# result = develop.update(data={
# "id": "38", # 资源在db中的id
# "pay_password": "123", # 支付密码
# "tags": ["update"],
# "price": 1.2,
# "content_type": ".exe",
# "des": "update blog description"
# })
# print(result)
# result = develop.delete(id=38, password='123')
# print(result)
# result = develop.transaction(
# payer='tests',
# claim_id='6af5772b0887ce1a92b0123d4c8e098b2d73ad55',
# pay_password='123',
# isads=False
# )
# print(result)
# result = develop.paytouser('3')
# print(result)
# result = develop.queryresource(page=1,num=1)
# print(result)
# result = develop.querybalance(payer='tests', pay_password='123')
# print(result)
# result = develop.checkisbought(payer='tests', claim_ids=['6af5772b0887ce1a92b0123d4c8e098b2d73ad55','b357caf6f6de4ab68334ea8ebc661323d3dc8e2a'])
# print(result)
# result = develop.queryuserpublished(wallet_username='tests',page=1,num=1)
# print(result)
# result = develop.query_resourc_by_ID(ids=["1","2"])
# print(result)
# result = develop.queryBillingDetailByID(claim_id='6af5772b0887ce1a92b0123d4c8e098b2d73ad55', page=1,num=1)
# print(result)
# result = develop.queryincomebillings(
# author='tests',
# start='2018-03-29',
# end='2018-07-21'
# )
# print(result)
# result = develop.queryoutgobillings(
# author='tests',
# start='2018-03-29',
# end='2018-07-21'
# )
# print(result)
# result = develop.querybillingsdetail(
# author='tests'
# )
# print(result)
# result = develop.querybillings(
# username='tests',
# start='2018-03-29',
# end='2018-07-21'
# )
# print(result)
# result = develop.querypublishnum(
# author='tests',
# start='2018-03-29',
# end='2018-07-21'
# )
# print(result)
# ************************初级开发者接口测试***************************************************
junior = Junior(
appkey='8326648868ad11e8b894fa163e37b4c3',
secret='8326648968ad11e8b894fa163e37b4c3'
)
# result = junior.create_database()
# print(result)
# result = junior.user_regist(
# username='3',
# password='1'
# )
# print(result)
# result = junior.user_login(
# username='3',
# password='1'
# )
# print(result)
# result = junior.user_logout(
# token='2b94fd00-8c8a-11e8-920b-f48e388c65be'
# )
# print(result)
# result = junior.user_activity(
# token='7fa38b00-8c8a-11e8-8085-f48e388c65be'
# )
# print(result)
# result = junior.resource_publish(
# title = "第一篇技术博客",
# tags = ["blockchain", "UDFS"],
# udfshash = "QmVcVaHhMeWNNetSLTZArmqaHMpu5ycqntx7mFZaci63VF",
# amount = 0.1,
# des ="这是使用UDFS和区块链生成的第一篇博客的描述信息",
# usercondition={
# "username" : "3",
# # "userid":1,
# # 'usertoken':"7fa38b00-8c8a-11e8-8085-f48e388c65be"
# })
# print(result)
result = junior.paytouser(username='3')
print(result)
# result = junior.querybalance(
# payer='as',
# pay_password='123'
# )
# print(result)
# result = junior.querybalance(
# payer='3',
# pay_password='$5$rounds=535000$BVxw4KDybwsFKIjW$AvOv7D1QCogO5G7ZD04cb3sIn4t3Jz5oDR4HDUkUy9B'
# )
# print(result)
# result = junior.user_activity(
# token='7fa38b00-8c8a-11e8-8085-f48e388c65be'
# )
# print(result)
# result = junior.resource_update(
# id='',
# pay_password='',
# title=''
# )
# print(result)
# result = junior.resouce_views(
# claim_id=''
# )
# print(result)
# user = User.
# result = junior.pay_resources(
# payer=user,
# claim_id='',
# password='1'
# )
# print(result)
# result = junior.pay_ads(
# wallet='3',
# claim_id='',
# authername='3'
# )
# print(result)
# result = junior.user_info_query(
# username='3'
# )
# print(result)
# result = junior.user_infor_modify(
# username='3',
# password='1',
# cellphone='15237548624'
# )
# print(result)
# result = junior.query("select * from users ")
# for i in result:
# print(i)
# junior.start_web()