add top

top/__init__.py

@@ -0,0 +1,29 @@
+'''
+Created on 2012-6-29
+
+@author: lihao
+'''
+from top.api.base import sign
+
+
+
+class appinfo(object):
+    def __init__(self,appkey,secret):
+        self.appkey = appkey
+        self.secret = secret
+
+def getDefaultAppInfo():
+    pass
+
+
+def setDefaultAppInfo(appkey,secret):
+    default = appinfo(appkey,secret)
+    global getDefaultAppInfo 
+    getDefaultAppInfo = lambda: default
+
+
+
+
+
+
+

top/api/__init__.py

@@ -0,0 +1,2 @@
+from top.api.rest import *
+from top.api.base import FileItem

top/api/base.py

@@ -0,0 +1,297 @@
+# -*- coding: utf-8 -*-
+'''
+Created on 2012-7-3
+
+@author: lihao
+'''
+
+try:
+	import httplib
+except ImportError:
+	import http.client as httplib
+import urllib
+import time
+import hashlib
+import json
+import top
+import itertools
+import mimetypes
+
+'''
+定义一些系统变量
+'''
+
+SYSTEM_GENERATE_VERSION = "taobao-sdk-python-20210816"
+
+P_APPKEY = "app_key"
+P_API = "method"
+P_SESSION = "session"
+P_ACCESS_TOKEN = "access_token"
+P_VERSION = "v"
+P_FORMAT = "format"
+P_TIMESTAMP = "timestamp"
+P_SIGN = "sign"
+P_SIGN_METHOD = "sign_method"
+P_PARTNER_ID = "partner_id"
+
+P_CODE = 'code'
+P_SUB_CODE = 'sub_code'
+P_MSG = 'msg'
+P_SUB_MSG = 'sub_msg'
+
+N_REST = '/router/rest'
+
+
+def sign(secret, parameters):
+	# ===========================================================================
+	# '''签名方法
+	# @param secret: 签名需要的密钥
+	# @param parameters: 支持字典和string两种
+	# '''
+	# ===========================================================================
+	# 如果parameters 是字典类的话
+	if hasattr(parameters, "items"):
+		keys = sorted(parameters.keys())
+
+		parameters = "%s%s%s" % (secret,
+		                         str().join('%s%s' % (key, parameters[key]) for key in keys),
+		                         secret)
+	sign = hashlib.md5(parameters.encode('utf-8')).hexdigest().upper()
+	return sign
+
+
+def mixStr(pstr):
+	if (isinstance(pstr, str)):
+		return pstr
+	elif (isinstance(pstr, bytes)):
+		return pstr.encode('utf-8')
+	else:
+		return str(pstr)
+
+
+class FileItem(object):
+	def __init__(self, filename=None, content=None):
+		self.filename = filename
+		self.content = content
+
+
+class MultiPartForm(object):
+	"""Accumulate the data to be used when posting a form."""
+
+	def __init__(self):
+		self.form_fields = []
+		self.files = []
+		self.boundary = "PYTHON_SDK_BOUNDARY"
+		return
+
+	def get_content_type(self):
+		return 'multipart/form-data; boundary=%s' % self.boundary
+
+	def add_field(self, name, value):
+		"""Add a simple field to the form data."""
+		self.form_fields.append((name, str(value)))
+		return
+
+	def add_file(self, fieldname, filename, fileHandle, mimetype=None):
+		"""Add a file to be uploaded."""
+		body = fileHandle.read()
+		if mimetype is None:
+			mimetype = mimetypes.guess_type(filename)[0] or 'application/octet-stream'
+		self.files.append((mixStr(fieldname), mixStr(filename), mixStr(mimetype), mixStr(body)))
+		return
+
+	def __str__(self):
+		"""Return a string representing the form data, including attached files."""
+		# Build a list of lists, each containing "lines" of the
+		# request.  Each part is separated by a boundary string.
+		# Once the list is built, return a string where each
+		# line is separated by '\r\n'.
+		parts = []
+		part_boundary = '--' + self.boundary
+
+		# Add the form fields
+		parts.extend(
+			[part_boundary,
+			 'Content-Disposition: form-data; name="%s"' % name,
+			 'Content-Type: text/plain; charset=UTF-8',
+			 '',
+			 value,
+			 ]
+			for name, value in self.form_fields
+			)
+
+		# Add the files to upload
+		parts.extend(
+			[part_boundary,
+			 'Content-Disposition: file; name="%s"; filename="%s"' % \
+			 (field_name, filename),
+			 'Content-Type: %s' % content_type,
+			 'Content-Transfer-Encoding: binary',
+			 '',
+			 body,
+			 ]
+			for field_name, filename, content_type, body in self.files
+			)
+
+		# Flatten the list and add closing boundary marker,
+		# then return CR+LF separated data
+		flattened = list(itertools.chain(*parts))
+		flattened.append('--' + self.boundary + '--')
+		flattened.append('')
+		return '\r\n'.join(flattened)
+
+
+class TopException(Exception):
+	# ===========================================================================
+	# 业务异常类
+	# ===========================================================================
+	def __init__(self):
+		self.errorcode = None
+		self.message = None
+		self.subcode = None
+		self.submsg = None
+		self.application_host = None
+		self.service_host = None
+
+	def __str__(self, *args, **kwargs):
+		sb = "errorcode=" + mixStr(self.errorcode) + \
+		     " message=" + mixStr(self.message) + \
+		     " subcode=" + mixStr(self.subcode) + \
+		     " submsg=" + mixStr(self.submsg) + \
+		     " application_host=" + mixStr(self.application_host) + \
+		     " service_host=" + mixStr(self.service_host)
+		return sb
+
+
+class RequestException(Exception):
+	# ===========================================================================
+	# 请求连接异常类
+	# ===========================================================================
+	pass
+
+
+class RestApi(object):
+	# ===========================================================================
+	# Rest api的基类
+	# ===========================================================================
+
+	def __init__(self, domain='gw.api.taobao.com', port=80):
+		# =======================================================================
+		# 初始化基类
+		# Args @param domain: 请求的域名或者ip
+		#      @param port: 请求的端口
+		# =======================================================================
+		self.__domain = domain
+		self.__port = port
+		self.__httpmethod = "POST"
+		if (top.getDefaultAppInfo()):
+			self.__app_key = top.getDefaultAppInfo().appkey
+			self.__secret = top.getDefaultAppInfo().secret
+
+	def get_request_header(self):
+		return {
+			'Content-type': 'application/x-www-form-urlencoded;charset=UTF-8',
+			"Cache-Control": "no-cache",
+			"Connection": "Keep-Alive",
+			}
+
+	def set_app_info(self, appinfo):
+		# =======================================================================
+		# 设置请求的app信息
+		# @param appinfo: import top
+		#                 appinfo top.appinfo(appkey,secret)
+		# =======================================================================
+		self.__app_key = appinfo.appkey
+		self.__secret = appinfo.secret
+
+	def getapiname(self):
+		return ""
+
+	def getMultipartParas(self):
+		return [];
+
+	def getTranslateParas(self):
+		return {};
+
+	def _check_requst(self):
+		pass
+
+	def getResponse(self, authrize=None, timeout=30):
+		# =======================================================================
+		# 获取response结果
+		# =======================================================================
+		if (self.__port == 443):
+			connection = httplib.HTTPSConnection(self.__domain, self.__port, None, None, False, timeout)
+		else:
+			connection = httplib.HTTPConnection(self.__domain, self.__port, timeout)
+		sys_parameters = {
+			P_FORMAT: 'json',
+			P_APPKEY: self.__app_key,
+			P_SIGN_METHOD: "md5",
+			P_VERSION: '2.0',
+			P_TIMESTAMP: str(int(time.time() * 1000)),
+			P_PARTNER_ID: SYSTEM_GENERATE_VERSION,
+			P_API: self.getapiname(),
+			}
+		if authrize is not None:
+			sys_parameters[P_SESSION] = authrize
+		application_parameter = self.getApplicationParameters()
+		sign_parameter = sys_parameters.copy()
+		sign_parameter.update(application_parameter)
+		sys_parameters[P_SIGN] = sign(self.__secret, sign_parameter)
+		connection.connect()
+
+		header = self.get_request_header();
+		if (self.getMultipartParas()):
+			form = MultiPartForm()
+			for key, value in application_parameter.items():
+				form.add_field(key, value)
+			for key in self.getMultipartParas():
+				fileitem = getattr(self, key)
+				if (fileitem and isinstance(fileitem, FileItem)):
+					form.add_file(key, fileitem.filename, fileitem.content)
+			body = str(form)
+			header['Content-type'] = form.get_content_type()
+		else:
+			body = urllib.parse.urlencode(application_parameter)
+
+		url = N_REST + "?" + urllib.parse.urlencode(sys_parameters)
+		connection.request(self.__httpmethod, url, body=body, headers=header)
+		response = connection.getresponse();
+		if response.status != 200:
+			raise RequestException('invalid http status ' + str(response.status) + ',detail body:' + response.read())
+		result = response.read()
+		jsonobj = json.loads(result)
+		if "error_response" in jsonobj:
+			error = TopException()
+			if P_CODE in jsonobj["error_response"]:
+				error.errorcode = jsonobj["error_response"][P_CODE]
+			if P_MSG in jsonobj["error_response"]:
+				error.message = jsonobj["error_response"][P_MSG]
+			if P_SUB_CODE in jsonobj["error_response"]:
+				error.subcode = jsonobj["error_response"][P_SUB_CODE]
+			if P_SUB_MSG in jsonobj["error_response"]:
+				error.submsg = jsonobj["error_response"][P_SUB_MSG]
+			error.application_host = response.getheader("Application-Host", "")
+			error.service_host = response.getheader("Location-Host", "")
+			raise error
+		return jsonobj
+
+
+	def getApplicationParameters(self):
+		application_parameter = {}
+		for key, value in self.__dict__.items():
+			if not key.startswith("__") and not key in self.getMultipartParas() and not key.startswith(
+				"_RestApi__"
+				) and value is not None:
+				if (key.startswith("_")):
+					application_parameter[key[1:]] = value
+				else:
+					application_parameter[key] = value
+		# 查询翻译字典来规避一些关键字属性
+		translate_parameter = self.getTranslateParas()
+		for key, value in application_parameter.items():
+			if key in translate_parameter:
+				application_parameter[translate_parameter[key]] = application_parameter[key]
+				del application_parameter[key]
+		return application_parameter

top/api/rest/AppipGetRequest.py

@@ -0,0 +1,10 @@
+'''
+Created by auto_sdk on 2020.08.28
+'''
+from top.api.base import RestApi
+class AppipGetRequest(RestApi):
+	def __init__(self,domain='gw.api.taobao.com',port=80):
+		RestApi.__init__(self,domain, port)
+
+	def getapiname(self):
+		return 'taobao.appip.get'

top/api/rest/AppstoreSubscribeGetRequest.py

@@ -0,0 +1,12 @@
+'''
+Created by auto_sdk on 2018.07.25
+'''
+from top.api.base import RestApi
+class AppstoreSubscribeGetRequest(RestApi):
+	def __init__(self,domain='gw.api.taobao.com',port=80):
+		RestApi.__init__(self,domain, port)
+		self.lease_id = None
+		self.nick = None
+
+	def getapiname(self):
+		return 'taobao.appstore.subscribe.get'

top/api/rest/AreasGetRequest.py

@@ -0,0 +1,11 @@
+'''
+Created by auto_sdk on 2020.12.14
+'''
+from top.api.base import RestApi
+class AreasGetRequest(RestApi):
+	def __init__(self,domain='gw.api.taobao.com',port=80):
+		RestApi.__init__(self,domain, port)
+		self.fields = None
+
+	def getapiname(self):
+		return 'taobao.areas.get'

top/api/rest/CainiaoCbossWorkplatformBiztypeQueryallRequest.py

@@ -0,0 +1,12 @@
+'''
+Created by auto_sdk on 2018.07.25
+'''
+from top.api.base import RestApi
+class CainiaoCbossWorkplatformBiztypeQueryallRequest(RestApi):
+	def __init__(self,domain='gw.api.taobao.com',port=80):
+		RestApi.__init__(self,domain, port)
+		self.level = None
+		self.trade_id = None
+
+	def getapiname(self):
+		return 'cainiao.cboss.workplatform.biztype.queryall'

top/api/rest/CainiaoCbossWorkplatformBiztypeQuerybyidRequest.py

@@ -0,0 +1,11 @@
+'''
+Created by auto_sdk on 2018.07.25
+'''
+from top.api.base import RestApi
+class CainiaoCbossWorkplatformBiztypeQuerybyidRequest(RestApi):
+	def __init__(self,domain='gw.api.taobao.com',port=80):
+		RestApi.__init__(self,domain, port)
+		self.biz_type_id = None
+
+	def getapiname(self):
+		return 'cainiao.cboss.workplatform.biztype.querybyid'