mirror of https://github.com/jumpserver/jumpserver
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
55 lines
1.7 KiB
55 lines
1.7 KiB
# -*- coding: utf-8 -*-
|
|
#
|
|
from operator import add, sub
|
|
|
|
from django.db.models.signals import m2m_changed
|
|
from django.dispatch import receiver
|
|
|
|
from assets.models import Asset, Node
|
|
from common.const.signals import PRE_CLEAR, POST_ADD, PRE_REMOVE
|
|
from common.decorators import on_transaction_commit, merge_delay_run
|
|
from common.utils import get_logger
|
|
from orgs.utils import tmp_to_org
|
|
from ..tasks import check_node_assets_amount_task
|
|
|
|
logger = get_logger(__file__)
|
|
|
|
|
|
@on_transaction_commit
|
|
@receiver(m2m_changed, sender=Asset.nodes.through)
|
|
def on_node_asset_change(sender, action, instance, reverse, pk_set, **kwargs):
|
|
# 不允许 `pre_clear` ，因为该信号没有 `pk_set`
|
|
# [官网](https://docs.djangoproject.com/en/3.1/ref/signals/#m2m-changed)
|
|
refused = (PRE_CLEAR,)
|
|
if action in refused:
|
|
raise ValueError
|
|
|
|
# 这里监听 post_add, pre_remove, 如果pre_add 和 post_remove, 那么 node_ids 就已经获取不到了
|
|
mapper = {POST_ADD: add, PRE_REMOVE: sub}
|
|
if action not in mapper:
|
|
return
|
|
|
|
with tmp_to_org(instance.org):
|
|
if reverse:
|
|
node_ids = [instance.id]
|
|
else:
|
|
node_ids = list(pk_set)
|
|
update_nodes_assets_amount(node_ids=node_ids)
|
|
|
|
|
|
@merge_delay_run(ttl=5)
|
|
def update_nodes_assets_amount(node_ids=()):
|
|
nodes = Node.objects.filter(id__in=node_ids)
|
|
nodes = Node.get_ancestor_queryset(nodes)
|
|
logger.debug('Recv asset nodes change signal, recompute node assets amount')
|
|
logger.info('Update nodes assets amount: {} nodes'.format(len(node_ids)))
|
|
|
|
if len(node_ids) > 100:
|
|
check_node_assets_amount_task.delay()
|
|
return
|
|
|
|
for node in nodes:
|
|
node.assets_amount = node.get_assets_amount()
|
|
|
|
Node.objects.bulk_update(nodes, ['assets_amount'])
|