summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorFrédéric Péters <fpeters@entrouvert.com>2012-05-04 09:29:54 (GMT)
committerFrédéric Péters <fpeters@entrouvert.com>2012-05-04 09:29:54 (GMT)
commit4b4f9204c3884c97b474ec2e3451c3fafec0ce51 (patch)
tree4783b6bd666e1a5f6f3d4d554799ea7c3ad283f9
parentb3090851dae0ef4217162d30a2049906f47d6dfc (diff)
downloadtabellio.pcfdb-4b4f9204c3884c97b474ec2e3451c3fafec0ce51.zip
tabellio.pcfdb-4b4f9204c3884c97b474ec2e3451c3fafec0ce51.tar.gz
tabellio.pcfdb-4b4f9204c3884c97b474ec2e3451c3fafec0ce51.tar.bz2
add logging
-rw-r--r--tabellio/pcfdb/sync.py34
1 files changed, 20 insertions, 14 deletions
diff --git a/tabellio/pcfdb/sync.py b/tabellio/pcfdb/sync.py
index 20b7d7e..988b1ca 100644
--- a/tabellio/pcfdb/sync.py
+++ b/tabellio/pcfdb/sync.py
@@ -3,6 +3,7 @@
import datetime
import re
import time
+import logging
from DateTime.DateTime import DateTime
@@ -28,6 +29,7 @@ from plone.registry.interfaces import IRegistry
from tabellio.config.interfaces import ITabellioSettings
+log = logging.getLogger('Plone')
class SyncFromPcfDbView(BrowserView):
def setup(self):
@@ -179,11 +181,11 @@ class SyncFromPcfDbView(BrowserView):
elif st in ('S_CREATED', 'S_DEAD'):
obj = getattr(self.persons_folder, new_id)
else:
- print 'unhandled type', st, author_id, new_id
+ log.debug('unhandled type: %s %s %s' % (st, author_id, new_id))
self._author_intids[author_id] = None
return None
except AttributeError:
- print 'missing author:', fullname
+ log.debug('missing author: %s', fullname)
self._author_intids[author_id] = None
return None
author_intid = self.intids.getId(obj)
@@ -208,7 +210,7 @@ class SyncFromPcfDbView(BrowserView):
try:
obj = getattr(folder, doc_id)
except AttributeError:
- print 'missing doc', doc_id
+ log.debug('missing doc: %s', doc_id)
return None, None
try:
return obj, self.intids.getId(obj)
@@ -323,6 +325,7 @@ class SyncFromPcfDbView(BrowserView):
timestamp = self.request.form.get('timestamp')
objects = self.request.form.get('objects', '').split(',')
+ log.info('sync: start [%r] [%r]' % (timestamp, objects))
report = []
for object in ('polgroups', 'sessions', 'deputies', 'ministries', 'persons', 'commissions',
'documents', 'dossiers', 'questions', 'reunions', 'deptables', 'thesaurus'):
@@ -332,7 +335,8 @@ class SyncFromPcfDbView(BrowserView):
t0 = time.time()
result = getattr(self, 'sync_'+object)(timestamp)
duration = time.time() - t0
- report.append('%-14s: %6s [%s]' % (object, result, format_duration(duration)))
+ report.append('%-14s: %6s [%s]' % (object, result, format_duration(duration))
+ log.info('sync: %-14s: %6s [%s]' % (object, result, format_duration(duration)))
transaction.commit()
print '\n'.join(report)
@@ -582,7 +586,7 @@ class SyncFromPcfDbView(BrowserView):
elif type in ('M_MINT', 'M_CMPT'):
continue
else:
- print 'unknown type:', type
+ log.debug('unknown person type: %s', type)
continue
start_str = debut.strftime('%d/%m/%Y')
@@ -863,10 +867,10 @@ class SyncFromPcfDbView(BrowserView):
}.get(doctype)
if intit is None:
- print 'missing intit, skipping', doc_id, ' (type was %s)' % doctype
+ log.debug('missing intit, skipping %s (type was %s)', doc_id, doctype)
continue
- print 'doc id:', doc_id
+ log.debug('doc id: %s', doc_id)
new_one = False
if not hasattr(self.documents_folder, doc_id):
@@ -896,7 +900,7 @@ class SyncFromPcfDbView(BrowserView):
authors = [self.get_author_intid(x) for x in authors]
object.authors = [RelationValue(x) for x in authors if x]
if len(object.authors) != len(authors):
- print ' different number of authors'
+ log.debug('different number of authors')
else:
object.authors = []
if polgroups:
@@ -969,12 +973,14 @@ class SyncFromPcfDbView(BrowserView):
row = meeting_cursor.fetchone()
if row:
meeting_id = row[0]
- print ' going to update meeting:', meeting_id
+ log.debug('going to update meeting %s with doc %s', meeting_id, object.no)
if hasattr(self.parlevents_folder, meeting_id):
meeting = getattr(self.parlevents_folder, meeting_id)
if meeting.cri is None:
doc_intid = self.intids.getId(object)
meeting.cri = RelationValue(doc_intid)
+ else:
+ log.debug('not meeting found for %s', object.no)
meeting_cursor.close()
if count % 100 == 0:
@@ -1014,7 +1020,7 @@ class SyncFromPcfDbView(BrowserView):
count += 1
dos_id, state, dostype, sess, no, intit, authors, curcom, polgroups, topics = row
- print 'dos id:', dos_id
+ logging.debug('dos id: %s', dos_id)
new_one = False
if not hasattr(self.dossiers_folder, dos_id):
@@ -1030,7 +1036,7 @@ class SyncFromPcfDbView(BrowserView):
authors = [self.get_author_intid(x) for x in authors]
object.authors = [RelationValue(x) for x in authors if x]
if len(object.authors) != len(authors):
- print ' different number of authors'
+ log.debug('different number of authors')
else:
object.authors = []
@@ -1083,7 +1089,7 @@ class SyncFromPcfDbView(BrowserView):
break
count += 1
dos_id, state, dostype, sess, no, intit, authors, polgroups, topics = row
- print 't_qx/dos id:', dos_id
+ log.debug('t_qx/dos id: %s', dos_id)
if not hasattr(self.questions_folder, dos_id):
self.questions_folder.invokeFactory('tabellio.documents.question', dos_id)
object = getattr(self.questions_folder, dos_id)
@@ -1100,7 +1106,7 @@ class SyncFromPcfDbView(BrowserView):
authors = [self.get_author_intid(x) for x in authors]
object.authors = [RelationValue(x) for x in authors if x]
if len(object.authors) != len(authors):
- print ' different number of authors'
+ log.debug('different number of authors')
else:
object.authors = []
@@ -1321,7 +1327,7 @@ class SyncFromPcfDbView(BrowserView):
row = doc_cursor.fetchone()
doc_cursor.close()
if row is None:
- print 'failed to get document', sess, doctype, docno
+ log.debug('failed to get document, %s %s %s', sess, doctype, docno)
else:
doc_id, docsess = row
doc, doc_intid = self.get_document_and_intid(doc_id)