Revision e941ddaf
Recherche sur les HLS impactés dans VigiBoard (#726)
git-svn-id: https://vigilo-dev.si.c-s.fr/svn@7320 b22e2e97-25c9-44ff-b637-2e5ceca36478
vigiboard/controllers/plugins/hls.py | ||
---|---|---|
23 | 23 |
niveau (L{HighLevelService}) impactés par un événement. |
24 | 24 |
""" |
25 | 25 |
|
26 |
from vigiboard.controllers.plugins import VigiboardRequestPlugin |
|
26 |
import tw.forms as twf |
|
27 |
from pylons.i18n import lazy_ugettext as l_ |
|
28 |
|
|
29 |
from vigiboard.controllers.plugins import VigiboardRequestPlugin, INNER |
|
27 | 30 |
from vigilo.models.session import DBSession |
28 |
from vigilo.models.tables import HighLevelService, CorrEvent, Event, SupItem, \
|
|
29 |
ImpactedHLS, ImpactedPath
|
|
31 |
from vigilo.models.functions import sql_escape_like
|
|
32 |
from vigilo.models import tables
|
|
30 | 33 |
from sqlalchemy.orm import aliased |
31 | 34 |
from sqlalchemy.sql import functions |
32 | 35 |
|
... | ... | |
35 | 38 |
Plugin qui permet de voir les services de haut niveau impactés par |
36 | 39 |
les événements affichés sur la page principale de VigiBoard. |
37 | 40 |
""" |
41 |
def get_search_fields(self): |
|
42 |
return [ |
|
43 |
twf.TextField( |
|
44 |
'hls', |
|
45 |
label_text=l_('High-Level Service'), |
|
46 |
validator=twf.validators.String(if_missing=None), |
|
47 |
) |
|
48 |
] |
|
49 |
|
|
50 |
def handle_search_fields(self, query, search, state, subqueries): |
|
51 |
if state != INNER or not search.get('hls'): |
|
52 |
return |
|
53 |
hls = sql_escape_like(search['hls']) |
|
54 |
|
|
55 |
# Il s'agit d'un manager. On applique le filtre |
|
56 |
# indépendamment aux 2 sous-requêtes. |
|
57 |
if len(subqueries) == 2: |
|
58 |
subqueries[0] = subqueries[0].join( |
|
59 |
(tables.ImpactedPath, tables.ImpactedPath.idsupitem == \ |
|
60 |
tables.LowLevelService.idservice), |
|
61 |
(tables.ImpactedHLS, tables.ImpactedHLS.idpath == \ |
|
62 |
tables.ImpactedPath.idpath), |
|
63 |
(tables.HighLevelService, \ |
|
64 |
tables.HighLevelService.idservice == \ |
|
65 |
tables.ImpactedHLS.idhls), |
|
66 |
).filter(tables.HighLevelService.servicename.ilike(hls)) |
|
67 |
|
|
68 |
subqueries[1] = subqueries[1].join( |
|
69 |
(tables.ImpactedPath, tables.ImpactedPath.idsupitem == \ |
|
70 |
tables.Host.idhost), |
|
71 |
(tables.ImpactedHLS, tables.ImpactedHLS.idpath == \ |
|
72 |
tables.ImpactedPath.idpath), |
|
73 |
(tables.HighLevelService, |
|
74 |
tables.HighLevelService.idservice == \ |
|
75 |
tables.ImpactedHLS.idhls), |
|
76 |
).filter(tables.HighLevelService.servicename.ilike(hls)) |
|
77 |
|
|
78 |
# Il s'agit d'un utilisateur normal. |
|
79 |
else: |
|
80 |
subqueries[0] = subqueries[0].join( |
|
81 |
(tables.ImpactedPath, tables.ImpactedPath.idsupitem == \ |
|
82 |
tables.UserSupItem.idsupitem), |
|
83 |
(tables.ImpactedHLS, tables.ImpactedHLS.idpath == \ |
|
84 |
tables.ImpactedPath.idpath), |
|
85 |
(tables.HighLevelService, |
|
86 |
tables.HighLevelService.idservice == \ |
|
87 |
tables.ImpactedHLS.idhls), |
|
88 |
).filter(tables.HighLevelService.servicename.ilike(hls)) |
|
38 | 89 |
|
39 | 90 |
def get_bulk_data(self, events_ids): |
40 | 91 |
""" |
... | ... | |
49 | 100 |
@rtype: C{dict} |
50 | 101 |
""" |
51 | 102 |
|
52 |
imp_hls1 = aliased(ImpactedHLS) |
|
53 |
imp_hls2 = aliased(ImpactedHLS) |
|
103 |
imp_hls1 = aliased(tables.ImpactedHLS)
|
|
104 |
imp_hls2 = aliased(tables.ImpactedHLS)
|
|
54 | 105 |
|
55 | 106 |
# Sous-requête récupérant les identifiants des supitems |
56 | 107 |
# impactés par les évènements passés en paramètre. |
57 | 108 |
subquery = DBSession.query( |
58 |
SupItem.idsupitem, |
|
59 |
CorrEvent.idcorrevent |
|
109 |
tables.SupItem.idsupitem,
|
|
110 |
tables.CorrEvent.idcorrevent
|
|
60 | 111 |
).join( |
61 |
(Event, Event.idsupitem == SupItem.idsupitem), |
|
62 |
(CorrEvent, CorrEvent.idcause == Event.idevent), |
|
63 |
).filter(CorrEvent.idcorrevent.in_(events_ids) |
|
112 |
(tables.Event, tables.Event.idsupitem == \ |
|
113 |
tables.SupItem.idsupitem), |
|
114 |
(tables.CorrEvent, tables.CorrEvent.idcause == \ |
|
115 |
tables.Event.idevent), |
|
116 |
).filter(tables.CorrEvent.idcorrevent.in_(events_ids) |
|
64 | 117 |
).subquery() |
65 | 118 |
|
66 | 119 |
# Sous-requête récupérant les identifiants des SHN de plus |
... | ... | |
71 | 124 |
imp_hls1.idpath, |
72 | 125 |
subquery.c.idcorrevent |
73 | 126 |
).join( |
74 |
(ImpactedPath, ImpactedPath.idpath == imp_hls1.idpath)
|
|
127 |
(tables.ImpactedPath, tables.ImpactedPath.idpath == imp_hls1.idpath)
|
|
75 | 128 |
).join( |
76 |
(subquery, ImpactedPath.idsupitem == subquery.c.idsupitem) |
|
129 |
(subquery, tables.ImpactedPath.idsupitem == subquery.c.idsupitem)
|
|
77 | 130 |
).group_by(imp_hls1.idpath, subquery.c.idcorrevent |
78 | 131 |
).subquery() |
79 | 132 |
|
... | ... | |
81 | 134 |
# impactés par chacun des évènements passés en paramètre. |
82 | 135 |
# Fait appel à la sous-requête précédente (subquery2). |
83 | 136 |
services = DBSession.query( |
84 |
HighLevelService.servicename, |
|
137 |
tables.HighLevelService.servicename,
|
|
85 | 138 |
subquery2.c.idcorrevent |
86 | 139 |
).distinct( |
87 | 140 |
).join( |
88 |
(imp_hls2, HighLevelService.idservice == imp_hls2.idhls), |
|
141 |
(imp_hls2, tables.HighLevelService.idservice == imp_hls2.idhls),
|
|
89 | 142 |
(subquery2, subquery2.c.idpath == imp_hls2.idpath), |
90 | 143 |
).filter(imp_hls2.distance == subquery2.c.distance |
91 | 144 |
).order_by( |
92 |
HighLevelService.servicename.asc() |
|
145 |
tables.HighLevelService.servicename.asc()
|
|
93 | 146 |
).all() |
94 | 147 |
|
95 | 148 |
# Construction d'un dictionnaire associant à chaque évènement |
Also available in: Unified diff