1 # -*- encoding: utf-8 -*-
2 import simplejson
, uuid
, datetime
, caldav
, vobject
, uuid
3 from django
.contrib
.auth
.models
import User
4 from django
.db
import models
5 from django
.db
.models
import Q
6 from django
.db
.models
.signals
import pre_delete
7 from timezones
.fields
import TimeZoneField
8 from auf_savoirs_en_partage
.backend_config
import RESOURCES
9 from savoirs
.globals import META
10 from settings
import CALENDRIER_URL
11 from datamaster_modeles
.models
import Thematique
, Pays
, Region
12 from lib
.calendrier
import combine
13 from caldav
.lib
import error
15 class Discipline(models
.Model
):
16 id = models
.IntegerField(primary_key
=True, db_column
='id_discipline')
17 nom
= models
.CharField(max_length
=765, db_column
='nom_discipline')
19 def __unicode__ (self
):
23 db_table
= u
'discipline'
26 class SourceActualite(models
.Model
):
27 nom
= models
.CharField(max_length
=255)
28 url
= models
.CharField(max_length
=255)
30 def __unicode__(self
,):
31 return u
"%s" % self
.nom
33 class ActualiteManager(models
.Manager
):
35 def get_query_set(self
):
36 return ActualiteQuerySet(self
.model
)
38 def search(self
, text
):
39 return self
.get_query_set().search(text
)
41 class ActualiteQuerySet(models
.query
.QuerySet
):
43 def search(self
, text
):
44 return self
.filter(Q(titre__icontains
=text
) |
Q(texte__icontains
=text
))
46 class Actualite(models
.Model
):
47 id = models
.AutoField(primary_key
=True, db_column
='id_actualite')
48 titre
= models
.CharField(max_length
=765, db_column
='titre_actualite')
49 texte
= models
.TextField(db_column
='texte_actualite')
50 url
= models
.CharField(max_length
=765, db_column
='url_actualite')
51 date
= models
.DateField(db_column
='date_actualite')
52 visible
= models
.BooleanField(db_column
='visible_actualite', default
= False)
53 ancienid
= models
.IntegerField(db_column
='ancienId_actualite', blank
= True, null
= True)
54 source
= models
.ForeignKey(SourceActualite
, blank
= True, null
= True)
56 objects
= ActualiteManager()
58 def __unicode__ (self
):
59 return "%s" % (self
.titre
)
62 db_table
= u
'actualite'
65 class EvenementManager(models
.Manager
):
67 def get_query_set(self
):
68 return EvenementQuerySet(self
.model
)
70 def search(self
, text
):
71 return self
.get_query_set().search(text
)
73 class EvenementQuerySet(models
.query
.QuerySet
):
75 def search(self
, text
):
79 qs
= qs
.filter(Q(titre__icontains
=word
) |
80 Q(mots_cles__icontains
=word
) |
81 Q(discipline__nom__icontains
=word
) |
82 Q(discipline_secondaire__nom__icontains
=word
) |
83 Q(type__icontains
=word
) |
84 Q(lieu__icontains
=word
) |
85 Q(description__icontains
=word
) |
86 Q(contact__icontains
=word
))
89 class Evenement(models
.Model
):
90 uid
= models
.CharField(max_length
= 255, default
= str(uuid
.uuid1()))
91 approuve
= models
.BooleanField(default
= False)
92 titre
= models
.CharField(max_length
=255)
93 discipline
= models
.ForeignKey('Discipline', related_name
= "discipline",
94 blank
= True, null
= True)
95 discipline_secondaire
= models
.ForeignKey('Discipline', related_name
= \
96 "discipline_secondaire",
98 "Discipline secondaire",
99 blank
= True, null
= True)
100 mots_cles
= models
.TextField('Mots-Clés', blank
= True, null
= True)
101 type = models
.CharField(max_length
= 255, choices
= \
102 (('Colloque', 'Colloque'),
103 ('Conférence', 'Conférence'),
104 ('Appel à contribution', 'Appel à contribution'),
105 ('Journée d\'étude', 'Journée d\'étude'),
108 fuseau
= TimeZoneField(verbose_name
= 'Fuseau horaire')
109 debut
= models
.DateTimeField(default
= datetime
.datetime
.now
)
110 fin
= models
.DateTimeField(default
= datetime
.datetime
.now
)
111 lieu
= models
.TextField()
112 description
= models
.TextField(blank
= True, null
= True)
114 contact
= models
.TextField(blank
= True, null
= True)
115 url
= models
.CharField(max_length
=255, blank
= True, null
= True)
117 objects
= EvenementManager()
120 ordering
= ['-debut']
122 def __unicode__(self
,):
123 return "[%s] %s" % (self
.uid
, self
.titre
)
125 def save(self
, *args
, **kwargs
):
126 """Sauvegarde l'objet dans django et le synchronise avec caldav s'il a été
129 super(Evenement
, self
).save(*args
, **kwargs
)
131 # methodes de commnunications avec CALDAV
133 """Retourne l'evenement django sous forme d'objet icalendar"""
134 cal
= vobject
.iCalendar()
137 # fournit son propre uid
138 if self
.uid
in [None, ""]:
139 self
.uid
= str(uuid
.uuid1())
141 cal
.vevent
.add('uid').value
= self
.uid
143 cal
.vevent
.add('summary').value
= self
.titre
145 if self
.mots_cles
is None:
148 kw
= self
.mots_cles
.split(",")
151 kw
.append(self
.discipline
.nom
)
152 kw
.append(self
.discipline_secondaire
.nom
)
156 kw
= [x
.strip() for x
in kw
if len(x
.strip()) > 0 and x
is not None]
158 cal
.vevent
.add('x-auf-keywords').value
= k
160 description
= self
.description
162 if len(self
.description
) > 0:
164 description
+= u
"Mots-clés: " + ", ".join(kw
)
166 cal
.vevent
.add('dtstart').value
= combine(self
.debut
, self
.fuseau
)
167 cal
.vevent
.add('dtend').value
= combine(self
.fin
, self
.fuseau
)
168 cal
.vevent
.add('created').value
= combine(datetime
.datetime
.now(), "UTC")
169 cal
.vevent
.add('dtstamp').value
= combine(datetime
.datetime
.now(), "UTC")
170 if len(description
) > 0:
171 cal
.vevent
.add('description').value
= description
172 if len(self
.contact
) > 0:
173 cal
.vevent
.add('contact').value
= self
.contact
174 if len(self
.url
) > 0:
175 cal
.vevent
.add('url').value
= self
.url
176 if len(self
.lieu
) > 0:
177 cal
.vevent
.add('location').value
= self
.lieu
180 def update_vevent(self
,):
181 """Essaie de créer l'évènement sur le serveur ical.
182 En cas de succès, l'évènement local devient donc inactif et approuvé"""
185 event
= self
.as_ical()
186 client
= caldav
.DAVClient(CALENDRIER_URL
)
187 cal
= caldav
.Calendar(client
, url
= CALENDRIER_URL
)
188 e
= caldav
.Event(client
, parent
= cal
, data
= event
.serialize(), id=self
.uid
)
191 self
.approuve
= False
193 def delete_vevent(self
,):
194 """Supprime l'evenement sur le serveur caldav"""
197 event
= self
.as_ical()
198 client
= caldav
.DAVClient(CALENDRIER_URL
)
199 cal
= caldav
.Calendar(client
, url
= CALENDRIER_URL
)
200 e
= cal
.event(self
.uid
)
202 except error
.NotFoundError
:
206 # Surcharge du comportement de suppression
207 # La méthode de connexion par signals est préférable à surcharger la méthode delete()
208 # car dans le cas de la suppression par lots, cell-ci n'est pas invoquée
209 def delete_vevent(sender
, instance
, *args
, **kwargs
):
210 instance
.delete_vevent()
212 pre_delete
.connect(delete_vevent
, sender
= Evenement
)
215 class ListSet(models
.Model
):
216 spec
= models
.CharField(primary_key
= True, max_length
= 255)
217 name
= models
.CharField(max_length
= 255)
218 server
= models
.CharField(max_length
= 255)
219 validated
= models
.BooleanField(default
= True)
221 def __unicode__(self
,):
224 class RecordManager(models
.Manager
):
226 def get_query_set(self
):
227 return RecordQuerySet(self
.model
)
229 def search(self
, text
):
230 return self
.get_query_set().search(text
)
233 return self
.get_query_set().validated()
235 class RecordQuerySet(models
.query
.QuerySet
):
237 def search(self
, text
):
241 # Ne garder que les ressources qui contiennent tous les mots
244 qs
= qs
.filter(Q(title__icontains
=word
) |
Q(description__icontains
=word
) |
245 Q(creator__icontains
=word
) |
Q(contributor__icontains
=word
) |
246 Q(subject__icontains
=word
) |
Q(disciplines__nom__icontains
=word
) |
247 Q(regions__nom__icontains
=word
) |
Q(pays__nom__icontains
=word
) |
248 Q(pays__region__nom__icontains
=word
))
250 # On donne un point pour chaque mot présent dans le titre.
251 score_expr
= ' + '.join(['(title LIKE %s)'] * len(words
))
252 score_params
= ['%' + word
+ '%' for word
in words
]
254 select
={'score': score_expr
},
255 select_params
=score_params
258 def search_auteur(self
, text
):
260 for word
in text
.split():
261 qs
= qs
.filter(Q(creator__icontains
=word
) |
Q(contributor__icontains
=word
))
264 def search_sujet(self
, text
):
266 for word
in text
.split():
267 qs
= qs
.filter(subject__icontains
=word
)
270 def search_titre(self
, text
):
272 for word
in text
.split():
273 qs
= qs
.filter(title__icontains
=word
)
277 """Ne garder que les ressources validées et qui sont soit dans aucun
278 listset ou au moins dans un listset validé."""
279 qs
= self
.filter(validated
=True)
280 qs
= qs
.extra(where
=['''((savoirs_record.id NOT IN (SELECT record_id FROM savoirs_record_listsets)) OR
281 ((SELECT MAX(l.validated) FROM savoirs_listset l
282 INNER JOIN savoirs_record_listsets rl ON rl.listset_id = l.spec
283 WHERE rl.record_id = savoirs_record.id) = TRUE))'''])
286 class Record(models
.Model
):
288 #fonctionnement interne
289 id = models
.AutoField(primary_key
= True)
290 server
= models
.CharField(max_length
= 255)
291 last_update
= models
.CharField(max_length
= 255)
292 last_checksum
= models
.CharField(max_length
= 255)
293 validated
= models
.BooleanField(default
= True)
296 title
= models
.TextField(null
= True, blank
= True)
297 creator
= models
.TextField(null
= True, blank
= True)
298 description
= models
.TextField(null
= True, blank
= True)
299 modified
= models
.CharField(max_length
= 255, null
= True, blank
= True)
300 identifier
= models
.CharField(max_length
= 255, null
= True, blank
= True, unique
= True)
301 uri
= models
.CharField(max_length
= 255, null
= True, blank
= True, unique
= True)
302 source
= models
.TextField(null
= True, blank
= True)
303 contributor
= models
.TextField(null
= True, blank
= True)
304 subject
= models
.TextField(null
= True, blank
= True)
305 publisher
= models
.TextField(null
= True, blank
= True)
306 type = models
.TextField(null
= True, blank
= True)
307 format
= models
.TextField(null
= True, blank
= True)
308 language
= models
.TextField(null
= True, blank
= True)
310 listsets
= models
.ManyToManyField(ListSet
, null
= True, blank
= True)
312 #SEP 2 (aucune données récoltées)
313 alt_title
= models
.TextField(null
= True, blank
= True)
314 abstract
= models
.TextField(null
= True, blank
= True)
315 creation
= models
.CharField(max_length
= 255, null
= True, blank
= True)
316 issued
= models
.CharField(max_length
= 255, null
= True, blank
= True)
317 isbn
= models
.TextField(null
= True, blank
= True)
318 orig_lang
= models
.TextField(null
= True, blank
= True)
320 # Metadata AUF multivaluées
321 disciplines
= models
.ManyToManyField(Discipline
)
322 thematiques
= models
.ManyToManyField(Thematique
)
323 pays
= models
.ManyToManyField(Pays
)
324 regions
= models
.ManyToManyField(Region
)
327 objects
= RecordManager()
329 def est_complet(self
,):
330 """teste si le record à toutes les données obligatoires"""
331 return self
.disciplines
.count() > 0 and \
332 self
.thematiques
.count() > 0 and \
333 self
.pays
.count() > 0 and \
334 self
.regions
.count() > 0
336 def __unicode__(self
):
337 return "[%s] %s" % (self
.server
, self
.title
)
339 class Serveur(models
.Model
):
340 """Identification d'un serveur d'ou proviennent les références"""
341 nom
= models
.CharField(primary_key
= True, max_length
= 255)
343 def __unicode__(self
,):
346 def conf_2_db(self
,):
347 for k
in RESOURCES
.keys():
348 s
, created
= Serveur
.objects
.get_or_create(nom
=k
)
352 class Profile(models
.Model
):
353 user
= models
.ForeignKey(User
, unique
=True)
354 serveurs
= models
.ManyToManyField(Serveur
, null
= True, blank
= True)
356 class HarvestLog(models
.Model
):
357 context
= models
.CharField(max_length
= 255)
358 name
= models
.CharField(max_length
= 255)
359 date
= models
.DateTimeField(auto_now
= True)
360 added
= models
.IntegerField(null
= True, blank
= True)
361 updated
= models
.IntegerField(null
= True, blank
= True)
362 processed
= models
.IntegerField(null
= True, blank
= True)
363 record
= models
.ForeignKey(Record
, null
= True, blank
= True)
367 logger
= HarvestLog()
368 if message
.has_key('record_id'):
369 message
['record'] = Record
.objects
.get(id=message
['record_id'])
370 del(message
['record_id'])
372 for k
,v
in message
.items():
373 setattr(logger
, k
, v
)