# -*- coding: utf-8 -*-

import logging

from django.db import transaction
from django_six import CompatibilityBaseCommand, close_old_connections

from utils.redis.connect import r


logger = logging.getLogger('console')


class Command(CompatibilityBaseCommand):
    def handle(self, *args, **options):

        logger.info('Templet bak cmd is dealing')

        while True:
            # r.rpushjson('TEMPLET_CMD_KEY', {})
            k, v = r.blpopjson('TEMPLET_CMD_KEY', 60)

            if not v:
                continue

            close_old_connections()

            logger.info(v)

            with transaction.atomic():
                pass

            close_old_connections()