Commit f9e274a1 authored by xiao-hesheng's avatar xiao-hesheng
Browse files

流程一脚本提交

parent df51ccd5
...@@ -123,7 +123,7 @@ def import_goods(hosGoodsId): ...@@ -123,7 +123,7 @@ def import_goods(hosGoodsId):
while True: while True:
# #请求体 # #请求体
request_body = commonFuc().get_business_data(module, "payload33_1", branch_id,hosGoodsId1) request_body = commonFuc().get_business_data(module, "payload33_1", branch_id,hosGoodsId1)
print(request_body) print('request_body',request_body)
# # # 发送请求 # # # 发送请求
result = commonFuc().http_post(url, request_body, headers) result = commonFuc().http_post(url, request_body, headers)
print('result', result) print('result', result)
...@@ -185,15 +185,16 @@ def check_import_goods(hosGoodsId): ...@@ -185,15 +185,16 @@ def check_import_goods(hosGoodsId):
# print('600秒过去了,导入产品需要停止') # print('600秒过去了,导入产品需要停止')
# break # break
result = commonFuc().http_post(url, request_body, headers) result = commonFuc().http_post(url, request_body, headers)
print('查询院区产品',result)
total=commonFuc().analysis_json('total',commonFuc().analysis_json('data',result)) total=commonFuc().analysis_json('total',commonFuc().analysis_json('data',result))
print('import_goods', total) print('查询院区产品total', total)
if total==0: if total==0:
print('产品暂时没有同步到内网,等待6秒') print('产品暂时没有同步到内网,等待6秒')
# j=j+6 # j=j+6
time.sleep(6) time.sleep(6)
# 再次调用一键导入产品 # 再次调用一键导入产品
# execute_command("python runner_test.py tag id2263-48 debug sit") # execute_command("python runner_test.py tag id2263-48 debug sit")
import_goods(hosGoodsId) # import_goods(hosGoodsId)
else: else:
break break
print('result', result) print('result', result)
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment