src/core/import_processor.py
author ymh <ymh.work@gmail.com>
Tue, 25 Jun 2013 10:28:25 +0200
changeset 34 b1fd0e0197c8
parent 33 61c3ffd94f11
child 334 169b7cfd1f58
permissions -rw-r--r--
add image field processing; correct csv import
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
     1
# -*- coding: utf-8 -*-
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
     2
'''
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
     3
Created on Jun 10, 2013
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
     4
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
     5
@author: ymh
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
     6
'''
33
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
     7
from .models import TermLabel
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
     8
from dateutil import parser
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
     9
import re
34
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    10
from core.models.notice import NoticeImage
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    11
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    12
class ImportProcessor(object):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    13
    
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    14
    def __init__(self, field):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    15
        self.field = field
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    16
        
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    17
    def process(self, obj,  value):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    18
        return {}
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    19
    
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    20
    
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    21
class CharFieldProcessor(ImportProcessor):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    22
    
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    23
    def process(self, obj, value):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    24
        setattr(obj, self.field, value)
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    25
        return {}
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    26
28
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    27
class TrimCharFieldProcessor(CharFieldProcessor):
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    28
    
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    29
    def process(self, obj, value):
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    30
        return super(TrimCharFieldProcessor, self).process(obj, value.strip())
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    31
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    32
class BooleanFieldProcessor(ImportProcessor):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    33
    
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    34
    def process(self, obj, value):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    35
        setattr(obj, self.field, value and value.strip().lower() in ['oui', '1', 't', 'yes', 'y', 'o'])
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    36
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    37
class DateFieldProcessor(ImportProcessor):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    38
    
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    39
    def process(self, obj, value):
28
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    40
        setattr(obj, self.field, parser.parse(value) if value else None)
34
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    41
        
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    42
class VideoFieldProcessor(ImportProcessor):
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    43
    
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    44
    def process(self, obj, value):
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    45
        res = {}
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    46
        images_str = getattr(obj, self.field, None)
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    47
        if not images_str:
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    48
            return res
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    49
        for image_path in [path.strip() for path in images_str.split(";")]:
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    50
            if not image_path:
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    51
                continue
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    52
            if not NoticeImage.objects.filter(relative_url=image_path, notice=obj).exists():
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    53
                res.setdefault(NoticeImage,[]).append(NoticeImage(relative_url=image_path, notice=obj)) 
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    54
        return res
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    55
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    56
class TermProcessor(ImportProcessor):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    57
    
28
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    58
    def __init__(self, field, context, notice_term_klass, re_split = r"[\;\,\:\(\)]", re_sub = "\(.+?\)"):
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    59
        ImportProcessor.__init__(self, field)
28
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    60
        self.re_split = re.compile(re_split)
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    61
        self.re_sub = re.compile(re_sub) if re_sub else None
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    62
        self.context = context
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    63
        self.notice_term_klass = notice_term_klass
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    64
    
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    65
    def build_notice_term(self, token, obj):
33
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    66
        
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    67
        termlabels = list(TermLabel.objects.filter(label=token, term__thesaurus__uri=self.context).select_related())
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    68
        if termlabels:
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    69
            term_obj = termlabels[0].term
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    70
            if not self.notice_term_klass.objects.filter(notice=obj,term=term_obj).exists():
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    71
                return self.notice_term_klass(notice=obj,term=term_obj)
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    72
            else:
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    73
                return None
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    74
        else:
61c3ffd94f11 - correct imports.
ymh <ymh.work@gmail.com>
parents: 28
diff changeset
    75
            return None            
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    76
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    77
    def process(self, obj, value):
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    78
        res = {}
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    79
        #remove everything between ()
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    80
        value = getattr(obj, self.field)
34
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    81
        if not value :
b1fd0e0197c8 add image field processing; correct csv import
ymh <ymh.work@gmail.com>
parents: 33
diff changeset
    82
            return res
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    83
        if self.re_sub:
28
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    84
            value = self.re_sub.sub("", value)
5918a9d353d0 Correction in importing csv.
ymh <ymh.work@gmail.com>
parents: 0
diff changeset
    85
        for token in self.re_split.split(value):
0
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    86
            token = token.strip()
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    87
            nt = self.build_notice_term(token, obj)
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    88
            if nt is not None:
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    89
                res.setdefault(self.notice_term_klass,[]).append(nt)
4095911a7830 Jocondelab first commit before design
ymh <ymh.work@gmail.com>
parents:
diff changeset
    90
        return res