design stream流 java地址修改
This commit is contained in:
@@ -139,6 +139,7 @@ def design_generate(request_data):
|
||||
@RunTime
|
||||
def design_generate_v2(request_data):
|
||||
objects_data = request_data.dict()['objects']
|
||||
request_id = request_data.requestId
|
||||
threads = []
|
||||
|
||||
def process_object(step, object):
|
||||
@@ -146,7 +147,7 @@ def design_generate_v2(request_data):
|
||||
items_response = {
|
||||
'layers': [],
|
||||
'objectSign': object['objectSign'] if 'objectSign' in object.keys() else "",
|
||||
'requestId': object['requestId'] if 'requestId' in object.keys() else ""
|
||||
'requestId': request_id
|
||||
}
|
||||
if basic['single_overall'] == "overall":
|
||||
item_results = []
|
||||
@@ -206,11 +207,11 @@ def design_generate_v2(request_data):
|
||||
'Connection': "keep-alive",
|
||||
'Content-Type': "application/json"
|
||||
}
|
||||
logger.info(items_response)
|
||||
response = post_request(url, json_data=items_response, headers=headers)
|
||||
if response:
|
||||
# 打印结果
|
||||
logger.info(response.text)
|
||||
logger.info(items_response)
|
||||
|
||||
for step, object in enumerate(objects_data):
|
||||
t = threading.Thread(target=process_object, args=(step, object))
|
||||
|
||||
Reference in New Issue
Block a user