admin.py 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827
  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. def get_queryset(self, request):
  180. return super().get_queryset(request).exclude(get_active_filter())
  181. class ServiceAllocationMixin:
  182. model = ServiceAllocation
  183. fields = ('id', 'service', 'resource', 'route', 'start', 'end')
  184. raw_id_fields = ('resource',)
  185. autocomplete_fields = ('service',)
  186. def get_queryset(self, request):
  187. qs = super().get_queryset(request)
  188. qs = qs.select_related('route')
  189. return qs
  190. #class AntennaAllocationMixin:
  191. # model = AntennaAllocation
  192. # fields = ('id', 'antenna', 'resource', 'start', 'end')
  193. # raw_id_fields = ('resource',)
  194. # autocomplete_fields = ('antenna',)
  195. #
  196. # def get_queryset(self, request):
  197. # qs = super().get_queryset(request)
  198. # qs = qs.select_related('antenna')
  199. # return qs
  200. class NewServiceAllocationInline(ServiceAllocationMixin, NewAllocationMixin, AllocationInline):
  201. fields = ('id', 'service', 'resource', 'route',)
  202. class ActiveServiceAllocationInline(ServiceAllocationMixin, ActiveAllocationMixin, AllocationInline):
  203. fields = ('id', 'service', 'resource', 'route', 'start', 'stop',)
  204. readonly_fields = ('service', 'start', 'resource', 'stop',)
  205. def stop(self, obj):
  206. return format_html('<a href="{}" class="deletelink">Terminer</a>', reverse('admin:stop-allocation', kwargs={'resource': obj.resource.ip}))
  207. stop.short_description = 'Terminer l’allocation'
  208. class InactiveServiceAllocationInline(ServiceAllocationMixin, InactiveAllocationMixin, AllocationInline):
  209. fields = ('id', 'service', 'resource', 'route', 'start', 'end')
  210. readonly_fields = ('service', 'resource', 'route', 'start', 'end')
  211. #class ActiveAntennaAllocationInline(AntennaAllocationMixin, ActiveAllocationMixin, AllocationInline):
  212. # pass
  213. #class InactiveAntennaAllocationInline(AntennaAllocationMixin, InactiveAllocationMixin, AllocationInline):
  214. # pass
  215. class IPResourceStateInline(admin.TabularInline):
  216. model = IPResourceState
  217. verbose_name_plural = 'Historique des derniers changements d’état'
  218. fields = ['date']
  219. readonly_fields = ['date']
  220. ordering = ['-date']
  221. def has_add_permission(self, request):
  222. return False
  223. def has_delete_permission(self, request, obj=None):
  224. return False
  225. class PortInline(admin.TabularInline):
  226. model = Port
  227. max_num = 0
  228. def has_add_permission(self, request):
  229. return False
  230. def has_delete_permission(self, request, obj=None):
  231. return False
  232. class SwitchPortInline(PortInline):
  233. fields = ('port', 'up', 'reserved', 'service', 'notes',)
  234. readonly_fields = ('port', 'up',)
  235. autocomplete_fields = ('service',)
  236. def get_queryset(self, request):
  237. qs = super().get_queryset(request)
  238. qs = qs.select_related('switch', 'service', 'service__service_type')
  239. return qs
  240. class ServicePortInline(PortInline):
  241. fields = ('switch', 'port', 'up', 'notes',)
  242. readonly_fields = ('switch', 'port', 'up',)
  243. ### ModelAdmin
  244. class ServiceAdmin(admin.ModelAdmin):
  245. list_display = ('id', 'get_adhesion_link', 'get_adherent_link', 'service_type', 'label', 'is_active',)
  246. list_select_related = ('adhesion', 'adhesion__user', 'adhesion__user__profile', 'adhesion__corporation', 'service_type',)
  247. list_filter = (
  248. ActiveServiceFilter,
  249. 'loan_equipment',
  250. ('service_type', admin.RelatedOnlyFieldListFilter),
  251. )
  252. search_fields = ('=id', 'service_type__name', 'label', 'notes',)
  253. fields = ('adhesion', 'service_type', 'label', 'notes', 'loan_equipment', 'get_contribution_link', 'is_active',)
  254. readonly_fields = ('get_contribution_link', 'is_active',)
  255. raw_id_fields = ('adhesion',)
  256. def get_queryset(self, request):
  257. qs = super().get_queryset(request)
  258. qs = qs.prefetch_related('allocations',)
  259. return qs
  260. get_adhesion_link = lambda self, service: service.adhesion.get_adhesion_link()
  261. get_adhesion_link.short_description = Adhesion.get_adhesion_link.short_description
  262. get_adherent_link = lambda self, service: service.adhesion.get_adherent_link()
  263. get_adherent_link.short_description = Adhesion.get_adherent_link.short_description
  264. def get_contribution_link(self, obj):
  265. return format_html(u'<a href="{}">{}</a>', obj.contribution.get_absolute_url(), obj.contribution.get_current_payment_display())
  266. get_contribution_link.short_description = 'Contribution financière'
  267. def get_inline_instances(self, request, obj=None):
  268. inlines = []
  269. if obj and obj.ports.exists():
  270. inlines += [ServicePortInline]
  271. inlines += [NewServiceAllocationInline]
  272. if obj and obj.active_allocations.exists():
  273. inlines += [ActiveServiceAllocationInline]
  274. if obj and obj.inactive_allocations.exists():
  275. inlines += [InactiveServiceAllocationInline]
  276. return [inline(self.model, self.admin_site) for inline in inlines]
  277. def get_actions(self, request):
  278. actions = super().get_actions(request)
  279. if 'delete_selected' in actions:
  280. del actions['delete_selected']
  281. return actions
  282. def has_delete_permission(self, request, obj=None):
  283. if not obj:
  284. return False
  285. one_year_ago = timezone.now() - timedelta(days=365)
  286. contribution = obj.contribution.updates.filter(validated=True).first()
  287. # s’il y avait un paiement actif il y a moins d’un an
  288. if not contribution or contribution.payment_method != PaymentUpdate.STOP or contribution.start > one_year_ago:
  289. return False
  290. # s’il y avait une allocation active il y a moins d’un an
  291. if any(map(lambda a: a.end is None or a.end > one_year_ago, obj.allocations.all())):
  292. return False
  293. return True
  294. class IPPrefixAdmin(admin.ModelAdmin):
  295. readonly_fields = ('prefix',)
  296. def has_delete_permission(self, request, obj=None):
  297. # Interdiction de supprimer le préfix s’il est assigné à une route
  298. return obj and obj.tunnel_set.exists()
  299. # pour embêcher de by-passer le check has_delete_permission, on désactive l’action delete
  300. def get_actions(self, request):
  301. actions = super().get_actions(request)
  302. if 'delete_selected' in actions:
  303. del actions['delete_selected']
  304. return actions
  305. class IPResourceAdmin(admin.ModelAdmin):
  306. list_display = ('__str__', 'available_display', 'route', 'last_use', 'ping',)
  307. list_filter = (
  308. 'category',
  309. ResourceInUseFilter,
  310. ResourcePingFilter,
  311. 'reserved',
  312. ('prefixes', admin.RelatedOnlyFieldListFilter),
  313. RouteFilter,
  314. )
  315. search_fields = ('=ip', 'notes',)
  316. actions = ['contact_ip_owners']
  317. ordering = ['ip']
  318. inlines = [ IPResourceStateInline ]
  319. def get_fields(self, request, obj=None):
  320. return self.get_readonly_fields(request, obj)
  321. def get_readonly_fields(self, request, obj=None):
  322. fields = ['ip']
  323. if obj:
  324. if obj.reserved:
  325. fields += ['reserved']
  326. if not obj.in_use:
  327. fields += ['last_use']
  328. fields += ['last_state']
  329. if obj.last_state.state != IPResourceState.STATE_UP:
  330. fields += ['last_time_up']
  331. if obj.category == IPResource.CATEGORY_PUBLIC:
  332. fields += ['password']
  333. if obj.checkmk_label:
  334. fields += ['checkmk']
  335. if obj.notes:
  336. fields += ['notes']
  337. return fields
  338. def get_inline_instances(self, request, obj=None):
  339. super_inlines = super().get_inline_instances(request, obj)
  340. inlines = []
  341. if obj and obj.category == IPResource.CATEGORY_PUBLIC:
  342. if obj.allocations.filter(get_active_filter()).exists():
  343. inlines += [ActiveServiceAllocationInline]
  344. else:
  345. inlines += [NewServiceAllocationInline]
  346. if obj.allocations.exclude(get_active_filter()).exists():
  347. inlines += [InactiveServiceAllocationInline]
  348. return [inline(self.model, self.admin_site) for inline in inlines] + super_inlines
  349. def get_queryset(self, request):
  350. qs = super().get_queryset(request)
  351. now = timezone.now()
  352. qs = qs.annotate(
  353. last_use=models.Case(
  354. models.When(in_use=True, then=now),
  355. models.When(category=0, then=models.Max('service_allocation__end')),
  356. models.When(category=1, then=models.Max('antenna_allocation__end')),
  357. default=None,
  358. ))
  359. qs = qs.annotate(
  360. downtime=models.Case(
  361. models.When(last_state__state=IPResourceState.STATE_UP, then=models.F('last_state__date')-models.Value(now)),
  362. models.When(last_state__state=IPResourceState.STATE_DOWN, then=models.Value(now)-models.F('last_time_up')),
  363. default=None,
  364. output_field=models.DurationField(),
  365. ))
  366. qs = qs.annotate(
  367. route=models.Case(
  368. models.When(
  369. in_use_by_service=True,
  370. then=models.Subquery(
  371. ServiceAllocation.objects.filter(
  372. Q(resource=models.OuterRef('pk')) & get_active_filter()
  373. ).values('route__name')[:1]
  374. ),
  375. ),
  376. output_field=models.CharField(),
  377. ))
  378. return qs
  379. def available_display(self, obj):
  380. return not obj.reserved and not obj.in_use
  381. available_display.short_description = 'Disponible'
  382. available_display.boolean = True
  383. def last_use(self, obj):
  384. if obj.last_use:
  385. return naturaltime(obj.last_use)
  386. else:
  387. return '-'
  388. last_use.short_description = 'Dernière utilisation'
  389. last_use.admin_order_field = 'last_use'
  390. def ping(self, obj):
  391. if obj.last_state.state == IPResourceState.STATE_UP:
  392. label = 'UP'
  393. else:
  394. if obj.last_time_up:
  395. label = 'dernier ping : ' + naturaltime(obj.last_time_up)
  396. else:
  397. label = 'DOWN'
  398. if obj.checkmk_url:
  399. return format_html('<a href="{}">{}</a>', obj.checkmk_url, label)
  400. else:
  401. return label
  402. ping.short_description = 'ping'
  403. #ping.admin_order_field = 'last_state__date'
  404. ping.admin_order_field = 'downtime'
  405. def route(self, obj):
  406. return obj.route
  407. route.short_description = 'route'
  408. route.admin_order_field = 'route'
  409. def checkmk(self, obj):
  410. return format_html('<a href="{}">{}</a>', obj.checkmk_url, 'voir')
  411. checkmk.short_description = 'CheckMK'
  412. def contact_ip_owners(self, request, queryset):
  413. selected = request.POST.getlist(admin.ACTION_CHECKBOX_NAME)
  414. services = ServiceAllocation.objects.filter(resource__ip__in=selected) \
  415. .filter(get_active_filter()) \
  416. .values_list('service__adhesion', flat=True)
  417. antennas = AntennaAllocation.objects.filter(resource__ip__in=selected) \
  418. .filter(get_active_filter()) \
  419. .values_list('antenna__contact', flat=True)
  420. pk = ",".join(map(str, set(services) | set(antennas)))
  421. return HttpResponseRedirect(reverse('admin:contact-adherents') + "?pk=%s" % pk)
  422. contact_ip_owners.short_description = 'Contacter les adhérents'
  423. def stop_allocation(self, request, resource):
  424. resource = self.get_object(request, resource)
  425. allocation = resource.allocations.filter(get_active_filter()).first()
  426. if not allocation: # L’IP n’est pas allouée
  427. return HttpResponseRedirect(reverse('admin:services_ipresource_change', args=[resource.pk]))
  428. form = StopAllocationForm(request.POST or None)
  429. if request.method == 'POST' and form.is_valid():
  430. self.message_user(request, 'Allocation stoppée.')
  431. allocation.end = timezone.now()
  432. allocation.save()
  433. notify_allocation(request, allocation)
  434. # Il faudrait rajouter un redirect dans l’URL pour rediriger vers l’IP ou le Service
  435. return HttpResponseRedirect(reverse('admin:services_ipresource_change', args=[resource.pk]))
  436. context = self.admin_site.each_context(request)
  437. context.update({
  438. 'opts': self.model._meta,
  439. 'title': 'Stopper une allocation',
  440. 'object': resource,
  441. 'media': self.media,
  442. 'form': form,
  443. })
  444. return TemplateResponse(request, "admin/services/ipresource/stop_allocation.html", context)
  445. def get_urls(self):
  446. my_urls = [
  447. path('<resource>/stop/', self.admin_site.admin_view(self.stop_allocation), name='stop-allocation'),
  448. ]
  449. return my_urls + super().get_urls()
  450. def get_actions(self, request):
  451. actions = super().get_actions(request)
  452. if 'delete_selected' in actions:
  453. del actions['delete_selected']
  454. return actions
  455. def has_add_permission(self, request, obj=None):
  456. return False
  457. def has_delete_permission(self, request, obj=None):
  458. return False
  459. class IPResourceStateAdmin(admin.ModelAdmin):
  460. list_display = ('ip', 'date', 'state',)
  461. def get_actions(self, request):
  462. actions = super().get_actions(request)
  463. if 'delete_selected' in actions:
  464. del actions['delete_selected']
  465. return actions
  466. def has_add_permission(self, request, obj=None):
  467. return False
  468. def has_change_permission(self, request, obj=None):
  469. return False
  470. def has_delete_permission(self, request, obj=None):
  471. return False
  472. class RouteAdmin(admin.ModelAdmin):
  473. list_display = ('name',)
  474. search_fields = ('name',)
  475. def get_fieldsets(self, request, obj=None):
  476. if obj:
  477. return (
  478. (None, {'fields': ['name']}),
  479. ('Adhérent·e·s', {'fields': ['get_adh'], 'classes': ['collapse']}),
  480. ('E-mails', {'fields': ['get_email'], 'classes': ['collapse']}),
  481. ('SMS', {'fields': ['get_sms'], 'classes': ['collapse']}),
  482. ('IP', {'fields': ['get_ip'], 'classes': ['collapse']}),
  483. )
  484. else:
  485. return (
  486. (None, {'fields': ['name']}),
  487. )
  488. def get_readonly_fields(self, request, obj=None):
  489. if obj:
  490. return ('get_email', 'get_sms', 'get_ip', 'get_adh',)
  491. else:
  492. return ()
  493. def get_email(self, route):
  494. return '\n'.join(route.get_email())
  495. get_email.short_description = 'E-mails'
  496. def get_sms(self, route):
  497. sms_filter = lambda x: x[:2] == '06' or x[:2] == '07' or x[:3] == '+336' or x[:3] == '+337'
  498. return '\n'.join(filter(sms_filter, route.get_tel()))
  499. get_sms.short_description = 'SMS'
  500. def get_ip(self, route):
  501. return '\n'.join(route.get_ip())
  502. get_ip.short_description = 'IP'
  503. def get_adh(self, route):
  504. return '\n'.join(map(lambda adh: '%s %s' % (adh, adh.adherent), route.get_adh()))
  505. get_adh.short_description = 'Adhérent·e·s'
  506. def get_actions(self, request):
  507. actions = super().get_actions(request)
  508. if 'delete_selected' in actions:
  509. del actions['delete_selected']
  510. return actions
  511. def has_delete_permission(self, request, obj=None):
  512. return False
  513. class TunnelAdmin(admin.ModelAdmin):
  514. list_display = ('name', 'description', 'created', 'active')
  515. list_filter = (
  516. ActiveTunnelFilter,
  517. )
  518. def active(self, obj):
  519. return not obj.ended
  520. active.short_description = 'Actif'
  521. active.boolean = True
  522. class ServiceTypeAdmin(admin.ModelAdmin):
  523. fields = ('name', 'contact')
  524. def get_actions(self, request):
  525. actions = super().get_actions(request)
  526. if 'delete_selected' in actions:
  527. del actions['delete_selected']
  528. return actions
  529. def has_delete_permission(self, request, obj=None):
  530. return False
  531. class ActiveAntennaLayer(GeoJSONLayerView):
  532. def get_queryset(self):
  533. return Antenna.objects.filter(get_active_filter('allocation'))
  534. class AntennaAdmin(admin.ModelAdmin):
  535. #inlines = (ActiveAntennaAllocationInline, InactiveAntennaAllocationInline,)
  536. list_filter = (
  537. AntennaPrefixFilter,
  538. AntennaPositionFilter,
  539. 'mode',
  540. 'ssid',
  541. )
  542. list_display_links = ('id', 'label')
  543. search_fields = ('=id', 'label', 'notes', 'ssid')
  544. raw_id_fields = ('contact',)
  545. form = AntennaForm
  546. def get_queryset(self, request):
  547. qs = super().get_queryset(request)
  548. if connection.vendor == 'postgresql':
  549. qs = qs.annotate(
  550. ip=StringAgg( # concaténation des IP avec des virgules directement par postgresql
  551. Cast( # casting en TextField car StringApp oppère sur des string mais les ip sont des inet
  552. models.Case( # seulement les IP des allocations actives
  553. models.When(
  554. get_active_filter('allocation'),
  555. then='allocation__resource__ip'
  556. ),
  557. ),
  558. models.TextField()
  559. ),
  560. delimiter=', '
  561. )
  562. )
  563. return qs
  564. def get_list_display(self, request):
  565. # ssid_display needs request to access query string and preserve filters
  566. ssid_display = partial(self.ssid_display, request=request)
  567. update_wrapper(ssid_display, self.ssid_display)
  568. return ('id', 'label', 'mode', ssid_display, 'position_display', 'ip_display')
  569. def position_display(self, obj):
  570. return obj.position is not None
  571. position_display.short_description = 'Géolocalisé'
  572. position_display.boolean = True
  573. def ip_display(self, obj):
  574. if connection.vendor == 'postgresql':
  575. return obj.ip
  576. else:
  577. # peu efficace car génère une requête par ligne
  578. allocations = obj.allocations.filter(active=True)
  579. return ', '.join(allocations.values_list('resource__ip', flat=True)) or '-'
  580. ip_display.short_description = 'IP'
  581. def ssid_display(self, obj, request):
  582. if obj.ssid:
  583. qs = request.GET.copy()
  584. qs.update({'ssid': obj.ssid})
  585. ssid_url = reverse('admin:services_antenna_changelist') + '?' + urlencode(qs)
  586. return format_html(u'<a href="{}">{}</a>', ssid_url, obj.ssid)
  587. else:
  588. return None
  589. ssid_display.short_description = 'SSID'
  590. def get_actions(self, request):
  591. actions = super().get_actions(request)
  592. if 'delete_selected' in actions:
  593. del actions['delete_selected']
  594. return actions
  595. def has_delete_permission(self, request, obj=None):
  596. return False
  597. def get_urls(self):
  598. my_urls = [
  599. url(r'^map/$', self.admin_site.admin_view(self.map_view, cacheable=True), name='antenna-map'),
  600. url(r'^map/data.json$', self.admin_site.admin_view(ActiveAntennaLayer.as_view(
  601. model=Antenna,
  602. geometry_field='position',
  603. properties=('label', 'mode', 'ssid', 'orientation', 'absolute_url',),
  604. )), name='antenna-map-data'),
  605. ]
  606. return my_urls + super().get_urls()
  607. def map_view(self, request):
  608. return TemplateResponse(request, 'services/antenna_map.html', dict(
  609. self.admin_site.each_context(request),
  610. opts=self.model._meta,
  611. json_url=reverse('admin:antenna-map-data'),
  612. ))
  613. def map_data_view(self, request):
  614. geojson = serialize('geojson', Antenna.objects.all(), geometry_field='point', fields=('position',))
  615. return HttpResponse(geojson, content_type='application/json')
  616. class SwitchAdmin(admin.ModelAdmin):
  617. list_display = ('name', 'ports_count', 'active_ports_count', 'inactive_ports_count', 'unknown_ports_count',)
  618. fields = ('name', 'first_port', 'last_port', 'notes',)
  619. search_fields = ('name', 'notes', 'ports__notes', 'ports__service__label',)
  620. def get_queryset(self, request):
  621. qs = super().get_queryset(request)
  622. qs = qs.annotate(
  623. active_ports_count=models.Count(models.Case(models.When(ports__up=True, then=models.Value('1')))),
  624. unknown_ports_count=models.Count(models.Case(models.When(ports__up__isnull=True, then=models.Value('1')))),
  625. inactive_ports_count=models.Count(models.Case(models.When(ports__up=False, then=models.Value('1')))),
  626. )
  627. return qs
  628. def ports_count(self, switch):
  629. return switch.last_port - switch.first_port + 1
  630. ports_count.short_description = 'Nombre de ports'
  631. def active_ports_count(self, switch):
  632. return switch.active_ports_count
  633. active_ports_count.short_description = 'up'
  634. active_ports_count.admin_order_field = 'active_ports_count'
  635. def inactive_ports_count(self, switch):
  636. return switch.inactive_ports_count
  637. inactive_ports_count.short_description = 'down'
  638. inactive_ports_count.admin_order_field = 'inactive_ports_count'
  639. def unknown_ports_count(self, switch):
  640. return switch.unknown_ports_count
  641. unknown_ports_count.short_description = 'inconnus'
  642. unknown_ports_count.admin_order_field = 'unknown_ports_count'
  643. def get_inline_instances(self, request, obj=None):
  644. if obj:
  645. return [ SwitchPortInline(self.model, self.admin_site) ]
  646. else:
  647. return []
  648. def get_readonly_fields(self, request, obj=None):
  649. if obj:
  650. return ('first_port', 'last_port',)
  651. else:
  652. return ()
  653. def get_actions(self, request):
  654. actions = super().get_actions(request)
  655. if 'delete_selected' in actions:
  656. del actions['delete_selected']
  657. return actions
  658. def has_delete_permission(self, request, obj=None):
  659. return False
  660. admin.site.register(ServiceType, ServiceTypeAdmin)
  661. admin.site.register(Service, ServiceAdmin)
  662. admin.site.register(IPPrefix, IPPrefixAdmin)
  663. admin.site.register(IPResource, IPResourceAdmin)
  664. admin.site.register(Route, RouteAdmin)
  665. admin.site.register(Tunnel, TunnelAdmin)
  666. admin.site.register(Antenna, AntennaAdmin)
  667. admin.site.register(Switch, SwitchAdmin)