feat(新功能): fix(修复bug): : refactor(重构): test(增加测试): 徐佩design测试
This commit is contained in:
@@ -37,7 +37,7 @@ else:
|
|||||||
CHROMADB_PATH = "/chromadb/"
|
CHROMADB_PATH = "/chromadb/"
|
||||||
|
|
||||||
# RABBITMQ_ENV = "" # 生产环境
|
# RABBITMQ_ENV = "" # 生产环境
|
||||||
RABBITMQ_ENV = os.getenv("RABBITMQ_ENV", "-dev")
|
RABBITMQ_ENV = os.getenv("RABBITMQ_ENV", "-prod")
|
||||||
# RABBITMQ_ENV = "-local" # 本地测试环境
|
# RABBITMQ_ENV = "-local" # 本地测试环境
|
||||||
|
|
||||||
if RABBITMQ_ENV == "-dev":
|
if RABBITMQ_ENV == "-dev":
|
||||||
|
|||||||
@@ -201,10 +201,10 @@ def design_generate_v2(request_data):
|
|||||||
# 发送结果给java端
|
# 发送结果给java端
|
||||||
url = JAVA_STREAM_API_URL
|
url = JAVA_STREAM_API_URL
|
||||||
# xu_pei_test_url = "https://cd21b9110505.ngrok-free.app/api/third/party/receiveDesignResults"
|
# xu_pei_test_url = "https://cd21b9110505.ngrok-free.app/api/third/party/receiveDesignResults"
|
||||||
tianxaing_test_url = "https://c2ae520723c9.ngrok-free.app/api/third/party/receiveDesignResults"
|
# tianxaing_test_url = "https://c2ae520723c9.ngrok-free.app/api/third/party/receiveDesignResults"
|
||||||
logger.info(f"java 回调 -> {url}")
|
logger.info(f"java 回调 -> {url}")
|
||||||
# logger.info(f"xupei java 回调 -> {xu_pei_test_url}")
|
# logger.info(f"xupei java 回调 -> {xu_pei_test_url}")
|
||||||
logger.info(f"tianxiang java 回调 -> {tianxaing_test_url}")
|
# logger.info(f"tianxiang java 回调 -> {tianxaing_test_url}")
|
||||||
|
|
||||||
headers = {
|
headers = {
|
||||||
'Accept': "*/*",
|
'Accept': "*/*",
|
||||||
@@ -220,12 +220,12 @@ def design_generate_v2(request_data):
|
|||||||
logger.info(response.text)
|
logger.info(response.text)
|
||||||
|
|
||||||
# test_response = post_request(xu_pei_test_url, json_data=items_response, headers=headers)
|
# test_response = post_request(xu_pei_test_url, json_data=items_response, headers=headers)
|
||||||
test_response = post_request(tianxaing_test_url, json_data=items_response, headers=headers)
|
# test_response = post_request(tianxaing_test_url, json_data=items_response, headers=headers)
|
||||||
|
|
||||||
if test_response:
|
# if test_response:
|
||||||
# 打印结果
|
# 打印结果
|
||||||
# logger.info(f"xupei test response : {test_response.text}")
|
# logger.info(f"xupei test response : {test_response.text}")
|
||||||
logger.info(f"tianxiang test response : {test_response.text}")
|
# logger.info(f"tianxiang test response : {test_response.text}")
|
||||||
|
|
||||||
for step, object in enumerate(objects_data):
|
for step, object in enumerate(objects_data):
|
||||||
t = threading.Thread(target=process_object, args=(step, object))
|
t = threading.Thread(target=process_object, args=(step, object))
|
||||||
|
|||||||
Reference in New Issue
Block a user