admin.py 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832
  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. ordering = ('-start',)
  157. def get_queryset(self, request):
  158. qs = super().get_queryset(request)
  159. qs = qs.select_related('resource')
  160. return qs
  161. def get_formset(self, request, obj=None, **kwargs):
  162. formset = super().get_formset(request, obj, **kwargs)
  163. formset.request = request
  164. return formset
  165. def has_delete_permission(self, request, obj=None):
  166. return False
  167. class NewAllocationMixin:
  168. verbose_name_plural = 'Nouvelle allocation'
  169. max_num = 1
  170. def get_queryset(self, request):
  171. return super().get_queryset(request).model.objects.none()
  172. class ActiveAllocationMixin:
  173. verbose_name_plural = 'Allocations actives'
  174. max_num = 0
  175. def get_queryset(self, request):
  176. return super().get_queryset(request).filter(get_active_filter())
  177. class InactiveAllocationMixin:
  178. verbose_name_plural = 'Anciennes allocations'
  179. max_num = 0
  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. def has_delete_permission(self, request, obj=None):
  297. # Interdiction de supprimer le préfix s’il est assigné à un tunnel
  298. return obj and obj.tunnel_set.exists()
  299. def has_change_permission(self, request, obj=None):
  300. if obj:
  301. return False
  302. else:
  303. return True
  304. # pour embêcher de by-passer le check has_delete_permission, on désactive l’action delete
  305. def get_actions(self, request):
  306. actions = super().get_actions(request)
  307. if 'delete_selected' in actions:
  308. del actions['delete_selected']
  309. return actions
  310. class IPResourceAdmin(admin.ModelAdmin):
  311. list_display = ('__str__', 'available_display', 'route', 'last_use', 'ping',)
  312. list_filter = (
  313. 'category',
  314. ResourceInUseFilter,
  315. ResourcePingFilter,
  316. 'reserved',
  317. ('prefixes', admin.RelatedOnlyFieldListFilter),
  318. RouteFilter,
  319. )
  320. search_fields = ('=ip', 'notes',)
  321. actions = ['contact_ip_owners']
  322. ordering = ['ip']
  323. inlines = [ IPResourceStateInline ]
  324. def get_fields(self, request, obj=None):
  325. return self.get_readonly_fields(request, obj)
  326. def get_readonly_fields(self, request, obj=None):
  327. fields = ['ip']
  328. if obj:
  329. if obj.reserved:
  330. fields += ['reserved']
  331. if not obj.in_use:
  332. fields += ['last_use']
  333. fields += ['last_state']
  334. if obj.last_state.state != IPResourceState.STATE_UP:
  335. fields += ['last_time_up']
  336. if obj.category == IPResource.CATEGORY_PUBLIC:
  337. fields += ['password']
  338. if obj.checkmk_label:
  339. fields += ['checkmk']
  340. if obj.notes:
  341. fields += ['notes']
  342. return fields
  343. def get_inline_instances(self, request, obj=None):
  344. super_inlines = super().get_inline_instances(request, obj)
  345. inlines = []
  346. if obj and obj.category == IPResource.CATEGORY_PUBLIC:
  347. if obj.allocations.filter(get_active_filter()).exists():
  348. inlines += [ActiveServiceAllocationInline]
  349. else:
  350. inlines += [NewServiceAllocationInline]
  351. if obj.allocations.exclude(get_active_filter()).exists():
  352. inlines += [InactiveServiceAllocationInline]
  353. return [inline(self.model, self.admin_site) for inline in inlines] + super_inlines
  354. def get_queryset(self, request):
  355. qs = super().get_queryset(request)
  356. now = timezone.now()
  357. qs = qs.annotate(
  358. last_use=models.Case(
  359. models.When(in_use=True, then=now),
  360. models.When(category=0, then=models.Max('service_allocation__end')),
  361. models.When(category=1, then=models.Max('antenna_allocation__end')),
  362. default=None,
  363. ))
  364. qs = qs.annotate(
  365. downtime=models.Case(
  366. models.When(last_state__state=IPResourceState.STATE_UP, then=models.F('last_state__date')-models.Value(now)),
  367. models.When(last_state__state=IPResourceState.STATE_DOWN, then=models.Value(now)-models.F('last_time_up')),
  368. default=None,
  369. output_field=models.DurationField(),
  370. ))
  371. qs = qs.annotate(
  372. route=models.Case(
  373. models.When(
  374. in_use_by_service=True,
  375. then=models.Subquery(
  376. ServiceAllocation.objects.filter(
  377. Q(resource=models.OuterRef('pk')) & get_active_filter()
  378. ).values('route__name')[:1]
  379. ),
  380. ),
  381. output_field=models.CharField(),
  382. ))
  383. return qs
  384. def available_display(self, obj):
  385. return not obj.reserved and not obj.in_use
  386. available_display.short_description = 'Disponible'
  387. available_display.boolean = True
  388. def last_use(self, obj):
  389. if obj.last_use:
  390. return naturaltime(obj.last_use)
  391. else:
  392. return '-'
  393. last_use.short_description = 'Dernière utilisation'
  394. last_use.admin_order_field = 'last_use'
  395. def ping(self, obj):
  396. if obj.last_state.state == IPResourceState.STATE_UP:
  397. label = 'UP'
  398. else:
  399. if obj.last_time_up:
  400. label = 'dernier ping : ' + naturaltime(obj.last_time_up)
  401. else:
  402. label = 'DOWN'
  403. if obj.checkmk_url:
  404. return format_html('<a href="{}">{}</a>', obj.checkmk_url, label)
  405. else:
  406. return label
  407. ping.short_description = 'ping'
  408. #ping.admin_order_field = 'last_state__date'
  409. ping.admin_order_field = 'downtime'
  410. def route(self, obj):
  411. return obj.route
  412. route.short_description = 'route'
  413. route.admin_order_field = 'route'
  414. def checkmk(self, obj):
  415. return format_html('<a href="{}">{}</a>', obj.checkmk_url, 'voir')
  416. checkmk.short_description = 'CheckMK'
  417. def contact_ip_owners(self, request, queryset):
  418. selected = request.POST.getlist(admin.ACTION_CHECKBOX_NAME)
  419. services = ServiceAllocation.objects.filter(resource__ip__in=selected) \
  420. .filter(get_active_filter()) \
  421. .values_list('service__adhesion', flat=True)
  422. antennas = AntennaAllocation.objects.filter(resource__ip__in=selected) \
  423. .filter(get_active_filter()) \
  424. .values_list('antenna__contact', flat=True)
  425. pk = ",".join(map(str, set(services) | set(antennas)))
  426. return HttpResponseRedirect(reverse('admin:contact-adherents') + "?pk=%s" % pk)
  427. contact_ip_owners.short_description = 'Contacter les adhérents'
  428. def stop_allocation(self, request, resource):
  429. resource = self.get_object(request, resource)
  430. allocation = resource.allocations.filter(get_active_filter()).first()
  431. if not allocation: # L’IP n’est pas allouée
  432. return HttpResponseRedirect(reverse('admin:services_ipresource_change', args=[resource.pk]))
  433. form = StopAllocationForm(request.POST or None)
  434. if request.method == 'POST' and form.is_valid():
  435. self.message_user(request, 'Allocation stoppée.')
  436. allocation.end = timezone.now()
  437. allocation.save()
  438. notify_allocation(request, allocation)
  439. # Il faudrait rajouter un redirect dans l’URL pour rediriger vers l’IP ou le Service
  440. return HttpResponseRedirect(reverse('admin:services_ipresource_change', args=[resource.pk]))
  441. context = self.admin_site.each_context(request)
  442. context.update({
  443. 'opts': self.model._meta,
  444. 'title': 'Stopper une allocation',
  445. 'object': resource,
  446. 'media': self.media,
  447. 'form': form,
  448. })
  449. return TemplateResponse(request, "admin/services/ipresource/stop_allocation.html", context)
  450. def get_urls(self):
  451. my_urls = [
  452. path('<resource>/stop/', self.admin_site.admin_view(self.stop_allocation), name='stop-allocation'),
  453. ]
  454. return my_urls + super().get_urls()
  455. def get_actions(self, request):
  456. actions = super().get_actions(request)
  457. if 'delete_selected' in actions:
  458. del actions['delete_selected']
  459. return actions
  460. def has_add_permission(self, request, obj=None):
  461. return False
  462. def has_delete_permission(self, request, obj=None):
  463. return False
  464. class IPResourceStateAdmin(admin.ModelAdmin):
  465. list_display = ('ip', 'date', 'state',)
  466. def get_actions(self, request):
  467. actions = super().get_actions(request)
  468. if 'delete_selected' in actions:
  469. del actions['delete_selected']
  470. return actions
  471. def has_add_permission(self, request, obj=None):
  472. return False
  473. def has_change_permission(self, request, obj=None):
  474. return False
  475. def has_delete_permission(self, request, obj=None):
  476. return False
  477. class RouteAdmin(admin.ModelAdmin):
  478. list_display = ('name',)
  479. search_fields = ('name',)
  480. def get_fieldsets(self, request, obj=None):
  481. if obj:
  482. return (
  483. (None, {'fields': ['name']}),
  484. ('Adhérent·e·s', {'fields': ['get_adh'], 'classes': ['collapse']}),
  485. ('E-mails', {'fields': ['get_email'], 'classes': ['collapse']}),
  486. ('SMS', {'fields': ['get_sms'], 'classes': ['collapse']}),
  487. ('IP', {'fields': ['get_ip'], 'classes': ['collapse']}),
  488. )
  489. else:
  490. return (
  491. (None, {'fields': ['name']}),
  492. )
  493. def get_readonly_fields(self, request, obj=None):
  494. if obj:
  495. return ('get_email', 'get_sms', 'get_ip', 'get_adh',)
  496. else:
  497. return ()
  498. def get_email(self, route):
  499. return '\n'.join(route.get_email())
  500. get_email.short_description = 'E-mails'
  501. def get_sms(self, route):
  502. sms_filter = lambda x: x[:2] == '06' or x[:2] == '07' or x[:3] == '+336' or x[:3] == '+337'
  503. return '\n'.join(filter(sms_filter, route.get_tel()))
  504. get_sms.short_description = 'SMS'
  505. def get_ip(self, route):
  506. return '\n'.join(route.get_ip())
  507. get_ip.short_description = 'IP'
  508. def get_adh(self, route):
  509. return '\n'.join(map(lambda adh: '%s %s' % (adh, adh.adherent), route.get_adh()))
  510. get_adh.short_description = 'Adhérent·e·s'
  511. def get_actions(self, request):
  512. actions = super().get_actions(request)
  513. if 'delete_selected' in actions:
  514. del actions['delete_selected']
  515. return actions
  516. def has_delete_permission(self, request, obj=None):
  517. return False
  518. class TunnelAdmin(admin.ModelAdmin):
  519. list_display = ('name', 'description', 'created', 'active')
  520. list_filter = (
  521. ActiveTunnelFilter,
  522. )
  523. def active(self, obj):
  524. return not obj.ended
  525. active.short_description = 'Actif'
  526. active.boolean = True
  527. class ServiceTypeAdmin(admin.ModelAdmin):
  528. fields = ('name', 'contact')
  529. def get_actions(self, request):
  530. actions = super().get_actions(request)
  531. if 'delete_selected' in actions:
  532. del actions['delete_selected']
  533. return actions
  534. def has_delete_permission(self, request, obj=None):
  535. return False
  536. class ActiveAntennaLayer(GeoJSONLayerView):
  537. def get_queryset(self):
  538. return Antenna.objects.filter(get_active_filter('allocation'))
  539. class AntennaAdmin(admin.ModelAdmin):
  540. #inlines = (ActiveAntennaAllocationInline, InactiveAntennaAllocationInline,)
  541. list_filter = (
  542. AntennaPrefixFilter,
  543. AntennaPositionFilter,
  544. 'mode',
  545. 'ssid',
  546. )
  547. list_display_links = ('id', 'label')
  548. search_fields = ('=id', 'label', 'notes', 'ssid')
  549. raw_id_fields = ('contact',)
  550. form = AntennaForm
  551. def get_queryset(self, request):
  552. qs = super().get_queryset(request)
  553. if connection.vendor == 'postgresql':
  554. qs = qs.annotate(
  555. ip=StringAgg( # concaténation des IP avec des virgules directement par postgresql
  556. Cast( # casting en TextField car StringApp oppère sur des string mais les ip sont des inet
  557. models.Case( # seulement les IP des allocations actives
  558. models.When(
  559. get_active_filter('allocation'),
  560. then='allocation__resource__ip'
  561. ),
  562. ),
  563. models.TextField()
  564. ),
  565. delimiter=', '
  566. )
  567. )
  568. return qs
  569. def get_list_display(self, request):
  570. # ssid_display needs request to access query string and preserve filters
  571. ssid_display = partial(self.ssid_display, request=request)
  572. update_wrapper(ssid_display, self.ssid_display)
  573. return ('id', 'label', 'mode', ssid_display, 'position_display', 'ip_display')
  574. def position_display(self, obj):
  575. return obj.position is not None
  576. position_display.short_description = 'Géolocalisé'
  577. position_display.boolean = True
  578. def ip_display(self, obj):
  579. if connection.vendor == 'postgresql':
  580. return obj.ip
  581. else:
  582. # peu efficace car génère une requête par ligne
  583. allocations = obj.allocations.filter(active=True)
  584. return ', '.join(allocations.values_list('resource__ip', flat=True)) or '-'
  585. ip_display.short_description = 'IP'
  586. def ssid_display(self, obj, request):
  587. if obj.ssid:
  588. qs = request.GET.copy()
  589. qs.update({'ssid': obj.ssid})
  590. ssid_url = reverse('admin:services_antenna_changelist') + '?' + urlencode(qs)
  591. return format_html(u'<a href="{}">{}</a>', ssid_url, obj.ssid)
  592. else:
  593. return None
  594. ssid_display.short_description = 'SSID'
  595. def get_actions(self, request):
  596. actions = super().get_actions(request)
  597. if 'delete_selected' in actions:
  598. del actions['delete_selected']
  599. return actions
  600. def has_delete_permission(self, request, obj=None):
  601. return False
  602. def get_urls(self):
  603. my_urls = [
  604. url(r'^map/$', self.admin_site.admin_view(self.map_view, cacheable=True), name='antenna-map'),
  605. url(r'^map/data.json$', self.admin_site.admin_view(ActiveAntennaLayer.as_view(
  606. model=Antenna,
  607. geometry_field='position',
  608. properties=('label', 'mode', 'ssid', 'orientation', 'absolute_url',),
  609. )), name='antenna-map-data'),
  610. ]
  611. return my_urls + super().get_urls()
  612. def map_view(self, request):
  613. return TemplateResponse(request, 'services/antenna_map.html', dict(
  614. self.admin_site.each_context(request),
  615. opts=self.model._meta,
  616. json_url=reverse('admin:antenna-map-data'),
  617. ))
  618. def map_data_view(self, request):
  619. geojson = serialize('geojson', Antenna.objects.all(), geometry_field='point', fields=('position',))
  620. return HttpResponse(geojson, content_type='application/json')
  621. class SwitchAdmin(admin.ModelAdmin):
  622. list_display = ('name', 'ports_count', 'active_ports_count', 'inactive_ports_count', 'unknown_ports_count',)
  623. fields = ('name', 'first_port', 'last_port', 'notes',)
  624. search_fields = ('name', 'notes', 'ports__notes', 'ports__service__label',)
  625. def get_queryset(self, request):
  626. qs = super().get_queryset(request)
  627. qs = qs.annotate(
  628. active_ports_count=models.Count(models.Case(models.When(ports__up=True, then=models.Value('1')))),
  629. unknown_ports_count=models.Count(models.Case(models.When(ports__up__isnull=True, then=models.Value('1')))),
  630. inactive_ports_count=models.Count(models.Case(models.When(ports__up=False, then=models.Value('1')))),
  631. )
  632. return qs
  633. def ports_count(self, switch):
  634. return switch.last_port - switch.first_port + 1
  635. ports_count.short_description = 'Nombre de ports'
  636. def active_ports_count(self, switch):
  637. return switch.active_ports_count
  638. active_ports_count.short_description = 'up'
  639. active_ports_count.admin_order_field = 'active_ports_count'
  640. def inactive_ports_count(self, switch):
  641. return switch.inactive_ports_count
  642. inactive_ports_count.short_description = 'down'
  643. inactive_ports_count.admin_order_field = 'inactive_ports_count'
  644. def unknown_ports_count(self, switch):
  645. return switch.unknown_ports_count
  646. unknown_ports_count.short_description = 'inconnus'
  647. unknown_ports_count.admin_order_field = 'unknown_ports_count'
  648. def get_inline_instances(self, request, obj=None):
  649. if obj:
  650. return [ SwitchPortInline(self.model, self.admin_site) ]
  651. else:
  652. return []
  653. def get_readonly_fields(self, request, obj=None):
  654. if obj:
  655. return ('first_port', 'last_port',)
  656. else:
  657. return ()
  658. def get_actions(self, request):
  659. actions = super().get_actions(request)
  660. if 'delete_selected' in actions:
  661. del actions['delete_selected']
  662. return actions
  663. def has_delete_permission(self, request, obj=None):
  664. return False
  665. admin.site.register(ServiceType, ServiceTypeAdmin)
  666. admin.site.register(Service, ServiceAdmin)
  667. admin.site.register(IPPrefix, IPPrefixAdmin)
  668. admin.site.register(IPResource, IPResourceAdmin)
  669. admin.site.register(Route, RouteAdmin)
  670. admin.site.register(Tunnel, TunnelAdmin)
  671. admin.site.register(Antenna, AntennaAdmin)
  672. admin.site.register(Switch, SwitchAdmin)