new_contents: from __future__ import absolute_import
  from __future__ import unicode_literals
  
  import time
  
  from django.core.management.base import BaseCommand
  from corehq.apps.userreports.tasks import _get_config_by_id, _build_indicators
  from corehq.apps.change_feed.data_sources import get_document_store_for_doc_type
  from custom.icds_reports.models.aggregate import CcsRecordMonthly
  from pillowtop.dao.couch import ID_CHUNK_SIZE
  
  
  class Command(BaseCommand):
      help = "Rebuild ccs record cases ucr for pnc_complete"
  
      def handle(self):
          indicator_config_id = 'static-ccs_record_cases'
          case_type_of_xmlns = 'ccs_record'
          config = _get_config_by_id(indicator_config_id)
          document_store = get_document_store_for_doc_type(
              config.domain, config.referenced_doc_type, case_type_or_xmlns=case_type_of_xmlns
          )
  
          doc_ids = CcsRecordMonthly.objects.filter(pnc_complete=1).values('case_id')
          relevant_ids = list()
          next_event = time.time() + 10
          for doc_id in doc_ids:
              relevant_ids.append(doc_id['case_id'])
              if len(relevant_ids) >= ID_CHUNK_SIZE:
                  _build_indicators(config, document_store, relevant_ids)
                  relevant_ids = []
  
              if time.time() > next_event:
                  print("processed till case %s" % (doc_id['case_id']))
                  next_event = time.time() + 10
  
          if relevant_ids:
              _build_indicators(config, document_store, relevant_ids)
  
  
subject: Add Mgt command to rebuild ccs records rebuild ccs record cases for pnc_complete=1