
    !g+
                     |    d dl  d dlZ G d dej                  j                  j
                  j                        Zy)    )*Nc                       e Zd ZdZej
                  j                  j                  j                  j                  dgz   Z	e
d        Ze eddd      d               Ze
d	d       Zy)
CmfStatAggregDayTexport2filec           
      8   d }g d}t         j                  j                  d|dgddg      }|D ]g  }|j                  j                  j                         }t         j                  j                  |j                  ||j                  |j                  |j                  |j                  dg	      }|st         j                         }|j                  |_         ||j                        |_        |j                  |_	        ||_        |j                  |_
        |j                  |_        |j                  |_        |j                  |_        |xj                   d
z  c_        |j                  |_        |j%                          d|_        |j%                          j y )Nc                     | j                  d      ry| j                  d      ry| j                  d      ry| j                  d      ryy )	NzCmfDocument:documentzCmfTask:taskzCmfAttachment:
attachmentzCmfComment:comment)
startswith)ids    1./modules/analytics/models/cmf_stat_aggreg_day.pycalc_obj_typez3CmfStatAggregDay.calc_aggreg.<locals>.calc_obj_type   sD    }}^,!z*/0#}-  .    )obj_idactioncmf_created_at	person_id
project_id	parent_id
history_idnumFr   r   i  )
aggregatedfieldsorder_byslicer   )r   dayr   r   r   r   r      T)modelsCmfStatlistr   valuedater   getr   r   r   r   r   obj_typer   r   r   cmf_modified_atsaver   )clsr   r   	stat_liststatr   	stat_aggrs          r   calc_aggregzCmfStatAggregDay.calc_aggreg
   sS   	! uNN''5ScRdmnptlu'v	 	D%%++002C//334;;CX\XcXcoso}o}?C[_[j[jtysz 4 |I"335	#{{I!.t{{!;I#{{IIM"&..I"&..I#'??I #'??I MMQM(,(;(;I%NN"DOIIK+	r   z	@minutely)	only_once
system_jobschedulec                  ,    t         j                          y )N)r   r-    r   r   cron_update_statz!CmfStatAggregDay.cron_update_stat2   s     	$$&r   Nc                 R    ddl m} | j                  }|j                  |||||      S )Nr   )
cmf_export)
class_namefield_namesbqlformat_fileinclude_archived)cmf.utilr5   r6   r   )r)   r7   r8   r9   r:   r5   r6   s          r   r   zCmfStatAggregDay.export2file7   s7    '^^
%%Z]kv  JZ%  [  	[r   )NNcsvF)__name__
__module____qualname__	api_allowmodules	analyticsr   cmf_stat_aggreg_dayr   api_methodsclassmethodr-   staticmethodcmf_deferred_jobr3   r   r2   r   r   r   r      s    I##**>>OO[[_
 
K % %N L' M ' [ [r   r   )cmf.include,modules.analytics.fields.cmf_stat_aggreg_dayrA   rB   r   rC   r   r2   r   r   <module>rJ      s1     38[w((//CCTT 8[r   