admin.py 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828
  1. from django.contrib import admin
  2. from django.db import models
  3. from django.db.models import Q
  4. from django.forms import ModelForm, BaseInlineFormSet
  5. from django.utils import timezone
  6. from django.urls import reverse, path
  7. from django.utils.html import format_html
  8. from django.conf.urls import url
  9. from django.template.response import TemplateResponse
  10. from django.core.serializers import serialize
  11. from django.http import HttpResponse
  12. from django.db.models.functions import Cast
  13. from django.contrib.postgres.aggregates import StringAgg
  14. from django.db import connection
  15. from django.core.cache import cache
  16. from django.contrib.humanize.templatetags.humanize import naturaltime
  17. from django.contrib.contenttypes.models import ContentType
  18. from django.http import HttpResponseRedirect
  19. from djgeojson.views import GeoJSONLayerView
  20. from urllib.parse import urlencode
  21. from functools import partial, update_wrapper
  22. from datetime import timedelta
  23. from djadhere.utils import get_active_filter
  24. from adhesions.models import Adhesion
  25. from banking.models import PaymentUpdate
  26. from .models import Service, ServiceType, IPPrefix, IPResource, IPResourceState, \
  27. ServiceAllocation, Antenna, AntennaAllocation, Allocation, \
  28. Route, Tunnel, Switch, Port
  29. from .utils.notifications import notify_allocation
  30. from .forms import AntennaForm, StopAllocationForm
  31. ### Filters
  32. class ResourceInUseFilter(admin.SimpleListFilter):
  33. title = 'disponibilité'
  34. parameter_name = 'available'
  35. def lookups(self, request, model_admin):
  36. return (
  37. (1, 'Disponible'),
  38. (0, 'Non disponible'),
  39. )
  40. def queryset(self, request, queryset):
  41. available_filter = Q(reserved=False, in_use=False)
  42. if self.value() == '0': # non disponible
  43. return queryset.exclude(available_filter)
  44. if self.value() == '1': # disponible
  45. return queryset.filter(available_filter)
  46. class ResourcePingFilter(admin.SimpleListFilter):
  47. title = 'ping'
  48. parameter_name = 'ping'
  49. def lookups(self, request, model_admin):
  50. return (
  51. ('up', 'UP'),
  52. ('down', 'DOWN'),
  53. ('down-since', 'DOWN depuis…'),
  54. ('never-up', 'Jamais vu UP'),
  55. )
  56. def queryset(self, request, queryset):
  57. if self.value() == 'up':
  58. return queryset.filter(last_state__state=IPResourceState.STATE_UP)
  59. if self.value() == 'down':
  60. return queryset.exclude(last_state__state=IPResourceState.STATE_UP) # DOWN + UNKNOWN
  61. if self.value() == 'down-since':
  62. queryset = queryset.exclude(last_state__state=IPResourceState.STATE_UP)
  63. return queryset.filter(last_time_up__isnull=False)
  64. if self.value() == 'never-up':
  65. queryset = queryset.exclude(last_state__state=IPResourceState.STATE_UP) # DOWN + UNKWON
  66. return queryset.filter(last_time_up__isnull=True)
  67. class ActiveServiceFilter(admin.SimpleListFilter):
  68. title = 'actif'
  69. parameter_name = 'active'
  70. def lookups(self, request, model_admin):
  71. return (
  72. (1, 'Actif'),
  73. (0, 'Inactif'),
  74. )
  75. def queryset(self, request, queryset):
  76. if self.value() == '0': # inactif
  77. return queryset.exclude(get_active_filter('allocation'))
  78. if self.value() == '1': # actif
  79. return queryset.filter(get_active_filter('allocation'))
  80. class RouteFilter(admin.SimpleListFilter):
  81. title = 'route'
  82. parameter_name = 'route'
  83. def lookups(self, request, model_admin):
  84. return ServiceAllocation.objects.filter(active=True).values_list('route__pk', 'route__name').distinct()
  85. def queryset(self, request, queryset):
  86. try:
  87. route = int(self.value())
  88. except (TypeError, ValueError):
  89. pass
  90. else:
  91. allocations = ServiceAllocation.objects.filter(active=True, route__pk=route).values_list('pk', flat=True)
  92. queryset = queryset.filter(service_allocation__in=allocations)
  93. return queryset
  94. class AntennaPrefixFilter(admin.SimpleListFilter):
  95. title = 'préfix'
  96. parameter_name = 'prefix'
  97. def lookups(self, request, model_admin):
  98. resources = AntennaAllocation.objects.filter(active=True).values_list('resource__pk', flat=True)
  99. prefixes = IPPrefix.objects.filter(ipresource__in=resources).values_list('pk', 'prefix').distinct()
  100. return prefixes
  101. def queryset(self, request, queryset):
  102. try:
  103. prefix = int(self.value())
  104. except (TypeError, ValueError):
  105. pass
  106. else:
  107. allocations = AntennaAllocation.objects.filter(active=True, resource__prefixes__pk=prefix).values_list('pk', flat=True)
  108. queryset = queryset.filter(allocation__in=allocations)
  109. return queryset
  110. class AntennaPositionFilter(admin.SimpleListFilter):
  111. title = 'géolocalisation'
  112. parameter_name = 'position'
  113. def lookups(self, request, model_admin):
  114. return (
  115. ('1', 'Connue'),
  116. ('0', 'Inconnue'),
  117. )
  118. def queryset(self, request, queryset):
  119. query = Q(position__isnull=True)
  120. if self.value() == '0':
  121. return queryset.filter(query)
  122. if self.value() == '1':
  123. return queryset.exclude(query)
  124. return queryset
  125. class ActiveTunnelFilter(admin.SimpleListFilter):
  126. title = 'status'
  127. parameter_name = 'active'
  128. def lookups(self, request, model_admin):
  129. return (
  130. ('1', 'Actif'),
  131. ('0', 'Désactivé'),
  132. )
  133. def queryset(self, request, queryset):
  134. query = Q(ended__isnull=True)
  135. if self.value() == '0':
  136. return queryset.exclude(query)
  137. if self.value() == '1':
  138. return queryset.filter(query)
  139. return queryset
  140. ### Inlines
  141. class AllocationInlineFormSet(BaseInlineFormSet):
  142. def save_new(self, form, commit=True):
  143. obj = super().save_new(form, commit)
  144. if type(obj) == ServiceAllocation:
  145. notify_allocation(self.request, obj)
  146. return obj
  147. def save_existing(self, form, instance, commit=True):
  148. old = type(instance).objects.get(pk=instance.pk)
  149. if type(instance) == ServiceAllocation:
  150. notify_allocation(self.request, instance, old)
  151. return super().save_existing(form, instance, commit)
  152. class AllocationInline(admin.TabularInline):
  153. formset = AllocationInlineFormSet
  154. extra = 0
  155. show_change_link = True
  156. def get_queryset(self, request):
  157. qs = super().get_queryset(request)
  158. qs = qs.select_related('resource')
  159. return qs
  160. def get_formset(self, request, obj=None, **kwargs):
  161. formset = super().get_formset(request, obj, **kwargs)
  162. formset.request = request
  163. return formset
  164. def has_delete_permission(self, request, obj=None):
  165. return False
  166. class NewAllocationMixin:
  167. verbose_name_plural = 'Nouvelle allocation'
  168. max_num = 1
  169. def get_queryset(self, request):
  170. return super().get_queryset(request).model.objects.none()
  171. class ActiveAllocationMixin:
  172. verbose_name_plural = 'Allocations actives'
  173. max_num = 0
  174. def get_queryset(self, request):
  175. return super().get_queryset(request).filter(get_active_filter())
  176. class InactiveAllocationMixin:
  177. verbose_name_plural = 'Anciennes allocations'
  178. max_num = 0
  179. ordering = ('-start',)
  180. def get_queryset(self, request):
  181. return super().get_queryset(request).exclude(get_active_filter())
  182. class ServiceAllocationMixin:
  183. model = ServiceAllocation
  184. fields = ('id', 'service', 'resource', 'route', 'start', 'end')
  185. raw_id_fields = ('resource',)
  186. autocomplete_fields = ('service',)
  187. def get_queryset(self, request):
  188. qs = super().get_queryset(request)
  189. qs = qs.select_related('route')
  190. return qs
  191. #class AntennaAllocationMixin:
  192. # model = AntennaAllocation
  193. # fields = ('id', 'antenna', 'resource', 'start', 'end')
  194. # raw_id_fields = ('resource',)
  195. # autocomplete_fields = ('antenna',)
  196. #
  197. # def get_queryset(self, request):
  198. # qs = super().get_queryset(request)
  199. # qs = qs.select_related('antenna')
  200. # return qs
  201. class NewServiceAllocationInline(ServiceAllocationMixin, NewAllocationMixin, AllocationInline):
  202. fields = ('id', 'service', 'resource', 'route',)
  203. class ActiveServiceAllocationInline(ServiceAllocationMixin, ActiveAllocationMixin, AllocationInline):
  204. fields = ('id', 'service', 'resource', 'route', 'start', 'stop',)
  205. readonly_fields = ('service', 'start', 'resource', 'stop',)
  206. def stop(self, obj):
  207. return format_html('<a href="{}" class="deletelink">Terminer</a>', reverse('admin:stop-allocation', kwargs={'resource': obj.resource.ip}))
  208. stop.short_description = 'Terminer l’allocation'
  209. class InactiveServiceAllocationInline(ServiceAllocationMixin, InactiveAllocationMixin, AllocationInline):
  210. fields = ('id', 'service', 'resource', 'route', 'start', 'end')
  211. readonly_fields = ('service', 'resource', 'route', 'start', 'end')
  212. #class ActiveAntennaAllocationInline(AntennaAllocationMixin, ActiveAllocationMixin, AllocationInline):
  213. # pass
  214. #class InactiveAntennaAllocationInline(AntennaAllocationMixin, InactiveAllocationMixin, AllocationInline):
  215. # pass
  216. class IPResourceStateInline(admin.TabularInline):
  217. model = IPResourceState
  218. verbose_name_plural = 'Historique des derniers changements d’état'
  219. fields = ['date']
  220. readonly_fields = ['date']
  221. ordering = ['-date']
  222. def has_add_permission(self, request):
  223. return False
  224. def has_delete_permission(self, request, obj=None):
  225. return False
  226. class PortInline(admin.TabularInline):
  227. model = Port
  228. max_num = 0
  229. def has_add_permission(self, request):
  230. return False
  231. def has_delete_permission(self, request, obj=None):
  232. return False
  233. class SwitchPortInline(PortInline):
  234. fields = ('port', 'up', 'reserved', 'service', 'notes',)
  235. readonly_fields = ('port', 'up',)
  236. autocomplete_fields = ('service',)
  237. def get_queryset(self, request):
  238. qs = super().get_queryset(request)
  239. qs = qs.select_related('switch', 'service', 'service__service_type')
  240. return qs
  241. class ServicePortInline(PortInline):
  242. fields = ('switch', 'port', 'up', 'notes',)
  243. readonly_fields = ('switch', 'port', 'up',)
  244. ### ModelAdmin
  245. class ServiceAdmin(admin.ModelAdmin):
  246. list_display = ('id', 'get_adhesion_link', 'get_adherent_link', 'service_type', 'label', 'is_active',)
  247. list_select_related = ('adhesion', 'adhesion__user', 'adhesion__user__profile', 'adhesion__corporation', 'service_type',)
  248. list_filter = (
  249. ActiveServiceFilter,
  250. 'loan_equipment',
  251. ('service_type', admin.RelatedOnlyFieldListFilter),
  252. )
  253. search_fields = ('=id', 'service_type__name', 'label', 'notes',)
  254. fields = ('adhesion', 'service_type', 'label', 'notes', 'loan_equipment', 'get_contribution_link', 'is_active',)
  255. readonly_fields = ('get_contribution_link', 'is_active',)
  256. raw_id_fields = ('adhesion',)
  257. def get_queryset(self, request):
  258. qs = super().get_queryset(request)
  259. qs = qs.prefetch_related('allocations',)
  260. return qs
  261. get_adhesion_link = lambda self, service: service.adhesion.get_adhesion_link()
  262. get_adhesion_link.short_description = Adhesion.get_adhesion_link.short_description
  263. get_adherent_link = lambda self, service: service.adhesion.get_adherent_link()
  264. get_adherent_link.short_description = Adhesion.get_adherent_link.short_description
  265. def get_contribution_link(self, obj):
  266. return format_html(u'<a href="{}">{}</a>', obj.contribution.get_absolute_url(), obj.contribution.get_current_payment_display())
  267. get_contribution_link.short_description = 'Contribution financière'
  268. def get_inline_instances(self, request, obj=None):
  269. inlines = []
  270. if obj and obj.ports.exists():
  271. inlines += [ServicePortInline]
  272. inlines += [NewServiceAllocationInline]
  273. if obj and obj.active_allocations.exists():
  274. inlines += [ActiveServiceAllocationInline]
  275. if obj and obj.inactive_allocations.exists():
  276. inlines += [InactiveServiceAllocationInline]
  277. return [inline(self.model, self.admin_site) for inline in inlines]
  278. def get_actions(self, request):
  279. actions = super().get_actions(request)
  280. if 'delete_selected' in actions:
  281. del actions['delete_selected']
  282. return actions
  283. def has_delete_permission(self, request, obj=None):
  284. if not obj:
  285. return False
  286. one_year_ago = timezone.now() - timedelta(days=365)
  287. contribution = obj.contribution.updates.filter(validated=True).first()
  288. # s’il y avait un paiement actif il y a moins d’un an
  289. if not contribution or contribution.payment_method != PaymentUpdate.STOP or contribution.start > one_year_ago:
  290. return False
  291. # s’il y avait une allocation active il y a moins d’un an
  292. if any(map(lambda a: a.end is None or a.end > one_year_ago, obj.allocations.all())):
  293. return False
  294. return True
  295. class IPPrefixAdmin(admin.ModelAdmin):
  296. readonly_fields = ('prefix',)
  297. def has_delete_permission(self, request, obj=None):
  298. # Interdiction de supprimer le préfix s’il est assigné à une route
  299. return obj and obj.tunnel_set.exists()
  300. # pour embêcher de by-passer le check has_delete_permission, on désactive l’action delete
  301. def get_actions(self, request):
  302. actions = super().get_actions(request)
  303. if 'delete_selected' in actions:
  304. del actions['delete_selected']
  305. return actions
  306. class IPResourceAdmin(admin.ModelAdmin):
  307. list_display = ('__str__', 'available_display', 'route', 'last_use', 'ping',)
  308. list_filter = (
  309. 'category',
  310. ResourceInUseFilter,
  311. ResourcePingFilter,
  312. 'reserved',
  313. ('prefixes', admin.RelatedOnlyFieldListFilter),
  314. RouteFilter,
  315. )
  316. search_fields = ('=ip', 'notes',)
  317. actions = ['contact_ip_owners']
  318. ordering = ['ip']
  319. inlines = [ IPResourceStateInline ]
  320. def get_fields(self, request, obj=None):
  321. return self.get_readonly_fields(request, obj)
  322. def get_readonly_fields(self, request, obj=None):
  323. fields = ['ip']
  324. if obj:
  325. if obj.reserved:
  326. fields += ['reserved']
  327. if not obj.in_use:
  328. fields += ['last_use']
  329. fields += ['last_state']
  330. if obj.last_state.state != IPResourceState.STATE_UP:
  331. fields += ['last_time_up']
  332. if obj.category == IPResource.CATEGORY_PUBLIC:
  333. fields += ['password']
  334. if obj.checkmk_label:
  335. fields += ['checkmk']
  336. if obj.notes:
  337. fields += ['notes']
  338. return fields
  339. def get_inline_instances(self, request, obj=None):
  340. super_inlines = super().get_inline_instances(request, obj)
  341. inlines = []
  342. if obj and obj.category == IPResource.CATEGORY_PUBLIC:
  343. if obj.allocations.filter(get_active_filter()).exists():
  344. inlines += [ActiveServiceAllocationInline]
  345. else:
  346. inlines += [NewServiceAllocationInline]
  347. if obj.allocations.exclude(get_active_filter()).exists():
  348. inlines += [InactiveServiceAllocationInline]
  349. return [inline(self.model, self.admin_site) for inline in inlines] + super_inlines
  350. def get_queryset(self, request):
  351. qs = super().get_queryset(request)
  352. now = timezone.now()
  353. qs = qs.annotate(
  354. last_use=models.Case(
  355. models.When(in_use=True, then=now),
  356. models.When(category=0, then=models.Max('service_allocation__end')),
  357. models.When(category=1, then=models.Max('antenna_allocation__end')),
  358. default=None,
  359. ))
  360. qs = qs.annotate(
  361. downtime=models.Case(
  362. models.When(last_state__state=IPResourceState.STATE_UP, then=models.F('last_state__date')-models.Value(now)),
  363. models.When(last_state__state=IPResourceState.STATE_DOWN, then=models.Value(now)-models.F('last_time_up')),
  364. default=None,
  365. output_field=models.DurationField(),
  366. ))
  367. qs = qs.annotate(
  368. route=models.Case(
  369. models.When(
  370. in_use_by_service=True,
  371. then=models.Subquery(
  372. ServiceAllocation.objects.filter(
  373. Q(resource=models.OuterRef('pk')) & get_active_filter()
  374. ).values('route__name')[:1]
  375. ),
  376. ),
  377. output_field=models.CharField(),
  378. ))
  379. return qs
  380. def available_display(self, obj):
  381. return not obj.reserved and not obj.in_use
  382. available_display.short_description = 'Disponible'
  383. available_display.boolean = True
  384. def last_use(self, obj):
  385. if obj.last_use:
  386. return naturaltime(obj.last_use)
  387. else:
  388. return '-'
  389. last_use.short_description = 'Dernière utilisation'
  390. last_use.admin_order_field = 'last_use'
  391. def ping(self, obj):
  392. if obj.last_state.state == IPResourceState.STATE_UP:
  393. label = 'UP'
  394. else:
  395. if obj.last_time_up:
  396. label = 'dernier ping : ' + naturaltime(obj.last_time_up)
  397. else:
  398. label = 'DOWN'
  399. if obj.checkmk_url:
  400. return format_html('<a href="{}">{}</a>', obj.checkmk_url, label)
  401. else:
  402. return label
  403. ping.short_description = 'ping'
  404. #ping.admin_order_field = 'last_state__date'
  405. ping.admin_order_field = 'downtime'
  406. def route(self, obj):
  407. return obj.route
  408. route.short_description = 'route'
  409. route.admin_order_field = 'route'
  410. def checkmk(self, obj):
  411. return format_html('<a href="{}">{}</a>', obj.checkmk_url, 'voir')
  412. checkmk.short_description = 'CheckMK'
  413. def contact_ip_owners(self, request, queryset):
  414. selected = request.POST.getlist(admin.ACTION_CHECKBOX_NAME)
  415. services = ServiceAllocation.objects.filter(resource__ip__in=selected) \
  416. .filter(get_active_filter()) \
  417. .values_list('service__adhesion', flat=True)
  418. antennas = AntennaAllocation.objects.filter(resource__ip__in=selected) \
  419. .filter(get_active_filter()) \
  420. .values_list('antenna__contact', flat=True)
  421. pk = ",".join(map(str, set(services) | set(antennas)))
  422. return HttpResponseRedirect(reverse('admin:contact-adherents') + "?pk=%s" % pk)
  423. contact_ip_owners.short_description = 'Contacter les adhérents'
  424. def stop_allocation(self, request, resource):
  425. resource = self.get_object(request, resource)
  426. allocation = resource.allocations.filter(get_active_filter()).first()
  427. if not allocation: # L’IP n’est pas allouée
  428. return HttpResponseRedirect(reverse('admin:services_ipresource_change', args=[resource.pk]))
  429. form = StopAllocationForm(request.POST or None)
  430. if request.method == 'POST' and form.is_valid():
  431. self.message_user(request, 'Allocation stoppée.')
  432. allocation.end = timezone.now()
  433. allocation.save()
  434. notify_allocation(request, allocation)
  435. # Il faudrait rajouter un redirect dans l’URL pour rediriger vers l’IP ou le Service
  436. return HttpResponseRedirect(reverse('admin:services_ipresource_change', args=[resource.pk]))
  437. context = self.admin_site.each_context(request)
  438. context.update({
  439. 'opts': self.model._meta,
  440. 'title': 'Stopper une allocation',
  441. 'object': resource,
  442. 'media': self.media,
  443. 'form': form,
  444. })
  445. return TemplateResponse(request, "admin/services/ipresource/stop_allocation.html", context)
  446. def get_urls(self):
  447. my_urls = [
  448. path('<resource>/stop/', self.admin_site.admin_view(self.stop_allocation), name='stop-allocation'),
  449. ]
  450. return my_urls + super().get_urls()
  451. def get_actions(self, request):
  452. actions = super().get_actions(request)
  453. if 'delete_selected' in actions:
  454. del actions['delete_selected']
  455. return actions
  456. def has_add_permission(self, request, obj=None):
  457. return False
  458. def has_delete_permission(self, request, obj=None):
  459. return False
  460. class IPResourceStateAdmin(admin.ModelAdmin):
  461. list_display = ('ip', 'date', 'state',)
  462. def get_actions(self, request):
  463. actions = super().get_actions(request)
  464. if 'delete_selected' in actions:
  465. del actions['delete_selected']
  466. return actions
  467. def has_add_permission(self, request, obj=None):
  468. return False
  469. def has_change_permission(self, request, obj=None):
  470. return False
  471. def has_delete_permission(self, request, obj=None):
  472. return False
  473. class RouteAdmin(admin.ModelAdmin):
  474. list_display = ('name',)
  475. search_fields = ('name',)
  476. def get_fieldsets(self, request, obj=None):
  477. if obj:
  478. return (
  479. (None, {'fields': ['name']}),
  480. ('Adhérent·e·s', {'fields': ['get_adh'], 'classes': ['collapse']}),
  481. ('E-mails', {'fields': ['get_email'], 'classes': ['collapse']}),
  482. ('SMS', {'fields': ['get_sms'], 'classes': ['collapse']}),
  483. ('IP', {'fields': ['get_ip'], 'classes': ['collapse']}),
  484. )
  485. else:
  486. return (
  487. (None, {'fields': ['name']}),
  488. )
  489. def get_readonly_fields(self, request, obj=None):
  490. if obj:
  491. return ('get_email', 'get_sms', 'get_ip', 'get_adh',)
  492. else:
  493. return ()
  494. def get_email(self, route):
  495. return '\n'.join(route.get_email())
  496. get_email.short_description = 'E-mails'
  497. def get_sms(self, route):
  498. sms_filter = lambda x: x[:2] == '06' or x[:2] == '07' or x[:3] == '+336' or x[:3] == '+337'
  499. return '\n'.join(filter(sms_filter, route.get_tel()))
  500. get_sms.short_description = 'SMS'
  501. def get_ip(self, route):
  502. return '\n'.join(route.get_ip())
  503. get_ip.short_description = 'IP'
  504. def get_adh(self, route):
  505. return '\n'.join(map(lambda adh: '%s %s' % (adh, adh.adherent), route.get_adh()))
  506. get_adh.short_description = 'Adhérent·e·s'
  507. def get_actions(self, request):
  508. actions = super().get_actions(request)
  509. if 'delete_selected' in actions:
  510. del actions['delete_selected']
  511. return actions
  512. def has_delete_permission(self, request, obj=None):
  513. return False
  514. class TunnelAdmin(admin.ModelAdmin):
  515. list_display = ('name', 'description', 'created', 'active')
  516. list_filter = (
  517. ActiveTunnelFilter,
  518. )
  519. def active(self, obj):
  520. return not obj.ended
  521. active.short_description = 'Actif'
  522. active.boolean = True
  523. class ServiceTypeAdmin(admin.ModelAdmin):
  524. fields = ('name', 'contact')
  525. def get_actions(self, request):
  526. actions = super().get_actions(request)
  527. if 'delete_selected' in actions:
  528. del actions['delete_selected']
  529. return actions
  530. def has_delete_permission(self, request, obj=None):
  531. return False
  532. class ActiveAntennaLayer(GeoJSONLayerView):
  533. def get_queryset(self):
  534. return Antenna.objects.filter(get_active_filter('allocation'))
  535. class AntennaAdmin(admin.ModelAdmin):
  536. #inlines = (ActiveAntennaAllocationInline, InactiveAntennaAllocationInline,)
  537. list_filter = (
  538. AntennaPrefixFilter,
  539. AntennaPositionFilter,
  540. 'mode',
  541. 'ssid',
  542. )
  543. list_display_links = ('id', 'label')
  544. search_fields = ('=id', 'label', 'notes', 'ssid')
  545. raw_id_fields = ('contact',)
  546. form = AntennaForm
  547. def get_queryset(self, request):
  548. qs = super().get_queryset(request)
  549. if connection.vendor == 'postgresql':
  550. qs = qs.annotate(
  551. ip=StringAgg( # concaténation des IP avec des virgules directement par postgresql
  552. Cast( # casting en TextField car StringApp oppère sur des string mais les ip sont des inet
  553. models.Case( # seulement les IP des allocations actives
  554. models.When(
  555. get_active_filter('allocation'),
  556. then='allocation__resource__ip'
  557. ),
  558. ),
  559. models.TextField()
  560. ),
  561. delimiter=', '
  562. )
  563. )
  564. return qs
  565. def get_list_display(self, request):
  566. # ssid_display needs request to access query string and preserve filters
  567. ssid_display = partial(self.ssid_display, request=request)
  568. update_wrapper(ssid_display, self.ssid_display)
  569. return ('id', 'label', 'mode', ssid_display, 'position_display', 'ip_display')
  570. def position_display(self, obj):
  571. return obj.position is not None
  572. position_display.short_description = 'Géolocalisé'
  573. position_display.boolean = True
  574. def ip_display(self, obj):
  575. if connection.vendor == 'postgresql':
  576. return obj.ip
  577. else:
  578. # peu efficace car génère une requête par ligne
  579. allocations = obj.allocations.filter(active=True)
  580. return ', '.join(allocations.values_list('resource__ip', flat=True)) or '-'
  581. ip_display.short_description = 'IP'
  582. def ssid_display(self, obj, request):
  583. if obj.ssid:
  584. qs = request.GET.copy()
  585. qs.update({'ssid': obj.ssid})
  586. ssid_url = reverse('admin:services_antenna_changelist') + '?' + urlencode(qs)
  587. return format_html(u'<a href="{}">{}</a>', ssid_url, obj.ssid)
  588. else:
  589. return None
  590. ssid_display.short_description = 'SSID'
  591. def get_actions(self, request):
  592. actions = super().get_actions(request)
  593. if 'delete_selected' in actions:
  594. del actions['delete_selected']
  595. return actions
  596. def has_delete_permission(self, request, obj=None):
  597. return False
  598. def get_urls(self):
  599. my_urls = [
  600. url(r'^map/$', self.admin_site.admin_view(self.map_view, cacheable=True), name='antenna-map'),
  601. url(r'^map/data.json$', self.admin_site.admin_view(ActiveAntennaLayer.as_view(
  602. model=Antenna,
  603. geometry_field='position',
  604. properties=('label', 'mode', 'ssid', 'orientation', 'absolute_url',),
  605. )), name='antenna-map-data'),
  606. ]
  607. return my_urls + super().get_urls()
  608. def map_view(self, request):
  609. return TemplateResponse(request, 'services/antenna_map.html', dict(
  610. self.admin_site.each_context(request),
  611. opts=self.model._meta,
  612. json_url=reverse('admin:antenna-map-data'),
  613. ))
  614. def map_data_view(self, request):
  615. geojson = serialize('geojson', Antenna.objects.all(), geometry_field='point', fields=('position',))
  616. return HttpResponse(geojson, content_type='application/json')
  617. class SwitchAdmin(admin.ModelAdmin):
  618. list_display = ('name', 'ports_count', 'active_ports_count', 'inactive_ports_count', 'unknown_ports_count',)
  619. fields = ('name', 'first_port', 'last_port', 'notes',)
  620. search_fields = ('name', 'notes', 'ports__notes', 'ports__service__label',)
  621. def get_queryset(self, request):
  622. qs = super().get_queryset(request)
  623. qs = qs.annotate(
  624. active_ports_count=models.Count(models.Case(models.When(ports__up=True, then=models.Value('1')))),
  625. unknown_ports_count=models.Count(models.Case(models.When(ports__up__isnull=True, then=models.Value('1')))),
  626. inactive_ports_count=models.Count(models.Case(models.When(ports__up=False, then=models.Value('1')))),
  627. )
  628. return qs
  629. def ports_count(self, switch):
  630. return switch.last_port - switch.first_port + 1
  631. ports_count.short_description = 'Nombre de ports'
  632. def active_ports_count(self, switch):
  633. return switch.active_ports_count
  634. active_ports_count.short_description = 'up'
  635. active_ports_count.admin_order_field = 'active_ports_count'
  636. def inactive_ports_count(self, switch):
  637. return switch.inactive_ports_count
  638. inactive_ports_count.short_description = 'down'
  639. inactive_ports_count.admin_order_field = 'inactive_ports_count'
  640. def unknown_ports_count(self, switch):
  641. return switch.unknown_ports_count
  642. unknown_ports_count.short_description = 'inconnus'
  643. unknown_ports_count.admin_order_field = 'unknown_ports_count'
  644. def get_inline_instances(self, request, obj=None):
  645. if obj:
  646. return [ SwitchPortInline(self.model, self.admin_site) ]
  647. else:
  648. return []
  649. def get_readonly_fields(self, request, obj=None):
  650. if obj:
  651. return ('first_port', 'last_port',)
  652. else:
  653. return ()
  654. def get_actions(self, request):
  655. actions = super().get_actions(request)
  656. if 'delete_selected' in actions:
  657. del actions['delete_selected']
  658. return actions
  659. def has_delete_permission(self, request, obj=None):
  660. return False
  661. admin.site.register(ServiceType, ServiceTypeAdmin)
  662. admin.site.register(Service, ServiceAdmin)
  663. admin.site.register(IPPrefix, IPPrefixAdmin)
  664. admin.site.register(IPResource, IPResourceAdmin)
  665. admin.site.register(Route, RouteAdmin)
  666. admin.site.register(Tunnel, TunnelAdmin)
  667. admin.site.register(Antenna, AntennaAdmin)
  668. admin.site.register(Switch, SwitchAdmin)