#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
Load data extracted from scrape and raw data snapshot into OCD models.
"""
from django.apps import apps
from django.utils.timezone import now
from django.core.management import call_command
from calaccess_processed.models import ProcessedDataVersion
from calaccess_processed.management.commands import CalAccessCommand


class Command(CalAccessCommand):
    """
    Load data extracted from scrape and raw data snapshot into OCD models.
    """
    help = 'Load data extracted from scrape and raw data snapshot into OCD models'

    def handle(self, *args, **options):
        """
        Make it happen.
        """
        super(Command, self).handle(*args, **options)

        self.processed_version = ProcessedDataVersion.objects.latest()

        self.start_datetime = now()
        self.load()
        self.finish_datetime = now()
        self.archive()

        self.success('Done!')
        self.duration()

    def load(self):
        """
        Load all of the processed models.
        """
        call_command(
            'loadparties',
            verbosity=self.verbosity,
            no_color=self.no_color,
        )
        self.duration()

        call_command(
            'loadballotmeasurecontests',
            verbosity=self.verbosity,
            no_color=self.no_color,
        )
        self.duration()

        call_command(
            'loadretentioncontests',
            verbosity=self.verbosity,
            no_color=self.no_color,
        )
        self.duration()

        call_command(
            'loadcandidatecontests',
            verbosity=self.verbosity,
            no_color=self.no_color,
        )
        self.duration()

        call_command(
            'mergecandidates',
            verbosity=self.verbosity,
            no_color=self.no_color,
        )
        self.duration()

        call_command(
            'loadcandidaciesfrom501s',
            verbosity=self.verbosity,
            no_color=self.no_color,
        )
        self.duration()

        call_command(
            'loadincumbentofficeholders',
            verbosity=self.verbosity,
            no_color=self.no_color,
        )
        self.duration()

    def archive(self):
        """
        Save a csv file for each loaded OCD model.
        """
        ocd_models = [
            m._meta.object_name for m in apps.get_app_config(
                'opencivicdata'
            ).get_models()
            if not m._meta.abstract and
            m.objects.count() > 0
        ]

        for m in ocd_models:
            processed_data_file, created = self.processed_version.files.get_or_create(
                file_name=m,
            )
            processed_data_file.process_start_time = self.start_datetime
            processed_data_file.save()
            call_command(
                'archivecalaccessprocessedfile',
                'opencivicdata',
                m,
            )
            processed_data_file.process_finish_time = self.finish_datetime
            processed_data_file.save()

        self.duration()

Create ProcessedDataModels for OCD models, group loading into one cmd
Create ProcessedDataModels for OCD models, group loading into one cmd
