jingrow/jcloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除域名解析记录成功后异步删除jingrow系统对应的记录

Browse Source
This commit is contained in:
jingrow 2025-08-05 02:10:59 +08:00
parent 3adac89d89
commit e85bb9bb5a
1 changed files with 38 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
jcloud/api/domain_west.py
View File

@ -1142,6 +1142,25 @@ def west_domain_delete_dns_record(**data):
error_msg = response.get('msg', response.get('message', '未知错误')) error_msg = response.get('msg', response.get('message', '未知错误'))
return {"status": "error", "message": f"删除DNS记录失败: {error_msg}"} return {"status": "error", "message": f"删除DNS记录失败: {error_msg}"}
# 异步删除本地数据库中的对应记录
if record_id:
try:
dns_records = jingrow.get_all(
"Dns Resolution",
{"record_id": record_id},
["name"]
)
if dns_records:
dns_record = dns_records[0]
jingrow.enqueue(
"jingrow.client.delete_pg",
pagetype="Dns Resolution",
name=dns_record.name
)
except Exception as e:
jingrow.log_error(f"域名 {domain} DNS记录异步删除失败", f"错误: {str(e)}")
# 返回成功结果 # 返回成功结果
return { return {
"status": "success", "status": "success",
@ -1205,6 +1224,25 @@ def west_domain_delete_dns_records(**data):
"record_id": record_id, "record_id": record_id,
"status": "success" "status": "success"
}) })
# 异步删除本地数据库中的对应记录
try:
dns_records = jingrow.get_all(
"Dns Resolution",
{"record_id": record_id},
["name"]
)
if dns_records:
dns_record = dns_records[0]
jingrow.enqueue(
"jingrow.client.delete_pg",
pagetype="Dns Resolution",
name=dns_record.name
)
except Exception as e:
jingrow.log_error(f"域名 {domain} DNS记录异步删除失败", f"记录ID: {record_id}, 错误: {str(e)}")
except Exception as e: except Exception as e:
error_count += 1 error_count += 1
results.append({ results.append({