删除节点 :param get: ids节点ID :return:
(self, get)
| 77 | |
| 78 | |
| 79 | def del_node(self, get): |
| 80 | """ |
| 81 | 删除节点 |
| 82 | :param get: ids节点ID |
| 83 | :return: |
| 84 | """ |
| 85 | node_ids = get.get('ids', "") |
| 86 | if not node_ids: |
| 87 | return public.returnMsg(False, "节点ID不能为空,至少为一个") |
| 88 | try: |
| 89 | node_ids = json.loads(node_ids) |
| 90 | if not isinstance(node_ids, list) and isinstance(node_ids, int): |
| 91 | node_ids = [node_ids] |
| 92 | except Exception: |
| 93 | return public.returnMsg(False, "传入的节点ID数据格式错误") |
| 94 | |
| 95 | srv_db = ServerNodeDB() |
| 96 | for node_id in node_ids: |
| 97 | if srv_db.is_local_node(node_id): |
| 98 | continue |
| 99 | err = srv_db.delete_node(node_id) |
| 100 | if err: |
| 101 | return json_response(False, msg=err) |
| 102 | return json_response(True, msg="节点删除成功") |
| 103 | |
| 104 | def update_node(self, get): |
| 105 | """ |
nothing calls this directly
no test coverage detected