create_server_async替换为create_aliyun_server
This commit is contained in:
parent
f738913dca
commit
e996d7af82
@ -518,7 +518,7 @@ def create_server_order(**kwargs):
|
|||||||
jingrow.log_error("创建服务器订单失败", str(e))
|
jingrow.log_error("创建服务器订单失败", str(e))
|
||||||
return {"success": False, "message": str(e)}
|
return {"success": False, "message": str(e)}
|
||||||
|
|
||||||
def create_server_async(order_name):
|
def create_aliyun_server(order_name):
|
||||||
"""异步创建服务器"""
|
"""异步创建服务器"""
|
||||||
try:
|
try:
|
||||||
order = jingrow.get_pg("Order", order_name)
|
order = jingrow.get_pg("Order", order_name)
|
||||||
|
|||||||
@ -1091,7 +1091,7 @@ def handle_order_payment_complete(order_id):
|
|||||||
process_site_renew(order_id)
|
process_site_renew(order_id)
|
||||||
elif order.order_type == "新建服务器":
|
elif order.order_type == "新建服务器":
|
||||||
# 异步创建服务器
|
# 异步创建服务器
|
||||||
jingrow.enqueue('jcloud.api.aliyun_server_light.create_server_async', order_name=order.name)
|
jingrow.enqueue('jcloud.api.aliyun_server_light.create_aliyun_server', order_name=order.name)
|
||||||
|
|
||||||
return True
|
return True
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
@ -1622,7 +1622,7 @@ def process_balance_payment_for_server_order(order_id):
|
|||||||
jingrow.db.commit()
|
jingrow.db.commit()
|
||||||
|
|
||||||
# 异步执行服务器创建
|
# 异步执行服务器创建
|
||||||
jingrow.enqueue('jcloud.api.aliyun_server_light.create_server_async', order_name=order.name)
|
jingrow.enqueue('jcloud.api.aliyun_server_light.create_aliyun_server', order_name=order.name)
|
||||||
jingrow.log_error("异步执行创建服务器", f"订单ID: {order_id}")
|
jingrow.log_error("异步执行创建服务器", f"订单ID: {order_id}")
|
||||||
return {
|
return {
|
||||||
"status": "Success",
|
"status": "Success",
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user