create_text_walenty.py 5.96 KB
#-*- coding:utf-8 -*-

import datetime
import os
import tarfile
from collections import Counter

from django.core.management.base import BaseCommand

from accounts.models import User
from dictionary.ajax_vocabulary_management import create_text_walenty, \
                                                  get_stats, write_stats, \
                                                  update_walenty_stats
from dictionary.ajax_argument_realizations import create_realizations_file
from dictionary.models import Frame_Opinion, Lemma, Vocabulary, POS, \
                              get_checked_statuses, get_ready_statuses
from settings import WALENTY_PATH

class Command(BaseCommand):
    args = 'none'
    
    def handle(self, *args, **options):
        now = datetime.datetime.now().strftime('%Y%m%d')
        filename_base = '%s_%s' % ('walenty', now)
        realizations_path = os.path.join(WALENTY_PATH, 
                                         '%s_%s.txt' % ('phrase_types_expand', now))
        checked_stats_path = os.path.join(WALENTY_PATH, u'%s_%s.txt' % (filename_base.replace('walenty', 'stats'), 
                                                                        'verified'))
        ready_stats_path = os.path.join(WALENTY_PATH, u'%s_%s.txt' % (filename_base.replace('walenty', 'stats'), 
                                                                      'all'))
        try:
            all_stats = Counter({})
            verified_stats = Counter({})
            base_path = os.path.join(WALENTY_PATH, filename_base)
            archive = tarfile.open(base_path + '-text.tar.gz', 'w:gz')
            os.chdir(WALENTY_PATH)
            for pos in POS.objects.exclude(tag=u'unk').order_by('priority'):
                pos_stats = create_pos_archive_and_get_stats(archive, pos, filename_base)
                all_stats = all_stats + Counter(pos_stats['all'])
                verified_stats = verified_stats + Counter(pos_stats['verified'])
            
            create_realizations_file(realizations_path)
            archive.add(os.path.basename(realizations_path))
            write_stats(checked_stats_path, verified_stats)
            archive.add(os.path.basename(checked_stats_path))
            write_stats(ready_stats_path, all_stats)
            archive.add(os.path.basename(ready_stats_path))
            update_walenty_stats(all_stats)
        finally:
            archive.close()
            os.remove(realizations_path)
            os.remove(checked_stats_path)
            os.remove(ready_stats_path)
            
def create_pos_archive_and_get_stats(archive, pos, filename_base):
    all_stats = {}
    checked_stats = {}
    try:
        checked_statuses = get_checked_statuses()
        ready_statuses = get_ready_statuses()
        lemmas = Lemma.objects.filter(old=False, entry_obj__pos=pos).order_by('entry_obj__name')
        checked_lemmas = lemmas.filter(status__in=checked_statuses)
        ready_lemmas = lemmas.filter(status__in=ready_statuses)
        
        all_path = os.path.join(WALENTY_PATH, u'%s_%ss_%s' % (filename_base, pos.tag, 'all'))
        walenty_path_ready = create_text_walenty(file_name=all_path,
                                                 lemmas=ready_lemmas, 
                                                 vocabularies=Vocabulary.objects.none(), 
                                                 frame_opinions=Frame_Opinion.objects.none(),
                                                 lemma_statuses=ready_statuses, 
                                                 owners=User.objects.none(), 
                                                 poss=POS.objects.filter(pk=pos.pk), 
                                                 add_frame_opinions=True)
        all_filename = os.path.basename(walenty_path_ready)
        archive.add(name=all_filename, arcname=os.path.join(u'%ss' % pos.tag, all_filename))
        
        checked_path = os.path.join(WALENTY_PATH, u'%s_%ss_%s' % (filename_base, pos.tag, 'verified'))
        walenty_path_checked = create_text_walenty(file_name=checked_path,
                                                   lemmas=checked_lemmas, 
                                                   vocabularies=Vocabulary.objects.none(), 
                                                   frame_opinions=Frame_Opinion.objects.none(),
                                                   lemma_statuses=checked_statuses, 
                                                   owners=User.objects.none(), 
                                                   poss=POS.objects.filter(pk=pos.pk), 
                                                   add_frame_opinions=True)
        checked_filename = os.path.basename(walenty_path_checked)
        archive.add(name=checked_filename, arcname=os.path.join(u'%ss' % pos.tag, checked_filename))
        
        all_stats = get_stats(ready_statuses, pos.tag)
        all_stats_path = os.path.join(WALENTY_PATH, u'%s_%ss_%s.txt' % (filename_base.replace('walenty', 'stats'), 
                                                                        pos.tag, 'all'))
        write_stats(all_stats_path, all_stats)
        all_stats_filename = os.path.basename(all_stats_path)
        archive.add(name=all_stats_filename, arcname=os.path.join(u'%ss' % pos.tag, all_stats_filename))
        
        checked_stats = get_stats(checked_statuses, pos.tag)
        checked_stats_path = os.path.join(WALENTY_PATH, u'%s_%ss_%s.txt' % (filename_base.replace('walenty', 'stats'), 
                                                                            pos.tag, 'verified'))
        write_stats(checked_stats_path, checked_stats)
        checked_stats_filename = os.path.basename(checked_stats_path)
        archive.add(name=checked_stats_filename, arcname=os.path.join(u'%ss' % pos.tag, checked_stats_filename))
    finally:
        os.remove(walenty_path_ready)
        os.remove(walenty_path_checked)
        os.remove(all_stats_path)
        os.remove(checked_stats_path)
        return {'all': all_stats,
                'verified': checked_stats}