补充营销中心接口测试工具类

HttpClient.py

+# -*- coding: utf-8 -*-
+
+import time
+import requests
+import json
+import uuid
+import random
+from config import config, env
+
+def _post(url, data, **headers):
+    print(url, headers)
+    input_json_data = json.dumps(data, ensure_ascii=False, indent=2)
+    print("="*60)
+    print(input_json_data)
+    print("-"*60)
+    response = requests.post(config.get(env).get("url") + url, json=data, headers=headers)
+    rspText = json.loads(response.text.encode("utf-8").decode("utf-8"))
+    json_data = json.dumps(rspText, ensure_ascii=False, indent=2)
+    print(json_data)
+    print("="*60)
+    return response.status_code
+
+def _get(url, data, headers):
+    print(url, headers)
+    input_json_data = json.dumps(data, ensure_ascii=False, indent=2)
+    print("="*60)
+    print(input_json_data)
+    print("-"*60)
+    response = requests.get(config.get(env).get("url") + url, json=data, headers=headers)
+    rspText = json.loads(response.text.encode("utf-8").decode("utf-8"))
+    json_data = json.dumps(rspText, ensure_ascii=False, indent=2)
+    print(json_data)
+    print("="*60)
+    return response.status_code
+
+def post(method, data, **headers):
+    return _post(method, data, **headers)
+
+def get(method, data, **headers):
+    return _get(method, data, **headers)

config.py

@@ -4,13 +4,13 @@
 # @Email   : guowj@bigaka.com
 
 # 启用某环境参数
-env = "local"
+env = "test"
 
 config = {
 	"local": {
 		"url": "http://127.0.0.1",
-		"tunnel-token": "aa8a1bfb7f6c5031d172d94b6574293ef954a6f2d4e16657da008e0cc15588feD",
-		"#tunnel-token": "3999eee",
+		"#tunnel-token": "aa8a1bfb7f6c5031d172d94b6574293ef954a6f2d4e16657da008e0cc15588feD",
+		"tunnel-token": "3999eee",
         "#seller-token": "f80d09122733517ea4a0c2628c4eb0e9",
 		"#buyer-token": "a3a2fcbac46b6a82a4a55d24835c5590"
 	},

seller/SellerConfig.py

+# -*- coding: utf-8 -*-
+
+env = "test"
+
+config = {
+	"local": {
+        "seller-token": "f80d09122733517ea4a0c2628c4eb0e9"
+	},
+	"dev": {
+		"seller-token": "aa8a1bfb7f6c5031d172d94b6574293ef954a6f2d4e16657da008e0cc15588fe"
+	},
+	"test": {
+		"seller-token": "a3bd3969e6677f4bbb33fe01ecb96c7533a91e86da1477328c63705aff35efe7"
+	},
+	"prod": {
+		"seller-token": ""
+	}
+}
\ No newline at end of file

seller/SellerHttpClient.py

+# -*- coding: utf-8 -*-
+
+from SellerConfig import config, env
+import sys
+sys.path.insert(0, '..')
+from HttpClient import post,get
+
+def sellerPost(method, data):
+    headers = {'seller-token': config.get(env).get("seller-token")}
+    return post(method, data, **headers)
+
+def sellerGet(method, data):
+    headers["seller-token"] = config.get(env).get("seller-token");
+    return get(method, data, **headers)

seller/login.py → seller/account/login.py

 # -*- coding: utf-8 -*-
 import sys
 sys.path.insert(0, '..')
-from utils import post_data
+from SellerHttpClient import post, get
 
 def login():
 	method = "/platform/account/login"
 	data = {}
-	data["acc"] = "WXTESTACC_7001001"
-	data["pwd"] = "354a3f27ecf1cf48c3b79e3034b4bc59b39f000c4ed7f2e138ec6eb1d97c557f"
+	data["acc"] = "TESTACC_110110000"
+	data["pwd"] = "3873eb629c3923dcf4b2c14b2e17d2480c197e1675cadc2f2c0f24eaa880fed4"
 
-	post_data(method, data)
+	sellerPost(method, data)
 
 if __name__ == '__main__':
 	login()
\ No newline at end of file

营销中心接口测试/账号修改密码.py → seller/account/账号修改密码.py

-# -*- coding: utf-8 -*-
+# -*- coding: utf-8 -*-
 # -*- coding: utf-8 -*-
 import sys
 sys.path.insert(0, '..')
-from utils import post_data
+from SellerHttpClient import post, get
 
 def get_member():
 	method = ":8087/account/updatePwd"
@@ -9,7 +9,7 @@ def get_member():
 
 	data["pwd"] = "3873eb629c3923dcf4b2c14b2e17d2480c197e1675cadc2f2c0f24eaa880fed4"
 	data["pwdForUpdate"] = "aa8a1bfb7f6c5031d172d94b6574293ef954a6f2d4e16657da008e0cc15588feD"
-	post_data(method, data)
+	sellerPost(method, data)
 
 if __name__ == '__main__':
 	get_member()
\ No newline at end of file

seller/coupon/point2coupon.py

 # -*- coding: utf-8 -*-
 import sys
 sys.path.insert(0, '../..')
-from utils import post_data
+from SellerHttpClient import post, get
 
 def login():
 	method = "/coupon/pointsRedemptionCouponSetting/exchange"
 	data = 2211
 
-	post_data(method, data)
+	sellerPost(method, data)
 
 if __name__ == '__main__':
 	login()
\ No newline at end of file

seller/memberFilter.py

 # -*- coding: utf-8 -*-
-import sys
-sys.path.insert(0, '..')
-from utils import post_data
+from SellerHttpClient import sellerPost
 
 def login():
 	method = "/platform/account/login"
@@ -9,7 +7,7 @@ def login():
 	data["acc"] = "WXTESTACC_7001001"
 	data["pwd"] = "354a3f27ecf1cf48c3b79e3034b4bc59b39f000c4ed7f2e138ec6eb1d97c557f"
 
-	post_data(method, data)
+	sellerPost(method, data)
 
 if __name__ == '__main__':
 	login()
\ No newline at end of file

seller/memberUpdate.py

 # -*- coding: utf-8 -*-
-import sys
-sys.path.insert(0, '..')
-from utils import post_data
+from SellerHttpClient import post, get
 
 def memberUpdate():
 	method = "/member/update"
@@ -10,7 +8,7 @@ def memberUpdate():
 	data["email"] = "abc@qq.com"
 	data["sex"] = "男"
 
-	post_data(method, data)
+	sellerPost(method, data)
 
 if __name__ == '__main__':
 	memberUpdate()
\ No newline at end of file

utils.py

@@ -14,13 +14,18 @@ from config import config, env
 def get_base_url():
 	if env in config.keys():
 		url = config.get(env).get("url")
-		token = config.get(env).get("tunnel-token")
+		tunnelToken = config.get(env).get("tunnel-token")
+		sellerToken = config.get(env).get("seller-token")
+		buyerToken = config.get(env).get("buyer-token")
 		headers = {
-			"Content-Type": "application/json",
-			"tunnel-token": config.get(env).get("tunnel-token"),
-            "#seller-token": config.get(env).get("seller-token"),
-            "#buyer-token": config.get(env).get("buyer-token")
+			"Content-Type": "application/json"
 		}
+		if tunnelToken:
+			headers["tunnel-token"] = tunnelToken
+		if sellerToken:
+			headers["seller-token"] = sellerToken
+		if buyerToken:
+			headers["buyer-token"] = buyerToken
 		if url and headers:
 			return url, headers
 		else:
@@ -36,25 +41,20 @@ def post_data(method, data, md="POST", **headers):
 		print(url, headers)
 		input_json_data = json.dumps(data, ensure_ascii=False, indent=2)
 		print("="*60)
-		print((input_json_data))
-		print("="*60)
+		print(input_json_data)
+		print("-"*60)
 		if md == "POST":
 			response = requests.post(url, json=data, headers=headers)
 		elif md == "GET":
 			response = requests.get(url, json=data, headers=headers)
-		if response.status_code == 200:
-			# 直接输出
-			# print (response.text.encode("utf-8").decode("utf-8"))
-			# 美化输出
-			response = json.loads(response.text.encode("utf-8").decode("utf-8"))
-			json_data = json.dumps(response, ensure_ascii=False, indent=2)
-			print(json_data)
-		else:
-			print("Error: " + response.text)
+		rspText = json.loads(response.text.encode("utf-8").decode("utf-8"))
+		json_data = json.dumps(rspText, ensure_ascii=False, indent=2)
+		print(json_data)
+		print("="*60)
+		return response.status_code
 	else:
 		print("Error: config")
 
-
 def generateRandomstr(length=8):
 	randomData = str(int(uuid.uuid4()))
 	s = int(random.uniform(1, 9))

营销中心接口测试/品牌库查询.py

-# -*- coding: utf-8 -*-
-# -*- coding: utf-8 -*-
-import sys
-sys.path.insert(0, '..')
-from utils import post_data
-
-def get_member():
-	method = "/platform/brand/getBrandDbByToken?token=aa8a1bfb7f6c5031d172d94b6574293ef954a6f2d4e16657da008e0cc15588feD"
-	data = {}
-
-	post_data(method, data, "GET")
-
-if __name__ == '__main__':
-	get_member()
+++ /dev/null
\ No newline at end of file