U
    eA~                    @   sP   d dl Zd dlT d dlmZmZ d dlZd dlT d dlm	Z	 G dd de	Z	dS )    N)*)ROUND_UP
ROUND_DOWN)CmfGanttTaskc                       s  e Zd Zedd ZedddZ fddZedd	 Zed
d Z	edd Z
edd ZdddZdddZdd Zdd Zdd ZdddZdd Zddd Zdd!d"Zdd#d$Zd%d& Zd'd( Zdd)d*Zd+d, Zd-d. Zd/d0 Zd1d2 Zd3d4 Zd5d6 Zdd7d8Zdd9d:Z d;d< Z!d=d> Z"d?d@ Z#ddAdBZ$dCdD Z%ddEdFZ&dGdH Z'dIdJ Z(ddKdLZ)dMdN Z*ddOdPZ+dQdR Z,dSdT Z-dUdV Z.dWdX Z/dYdZ Z0d[d\ Z1d]d^ Z2dd_d`Z3ddadbZ4dcdd Z5dedf Z6dgdh Z7ddidjZ8ddkdlZ9dmdn Z:ddodpZ;dqdr Z<dsdt Z=dudv Z>dwdx Z?dydz Z@d{d| ZAdd}d~ZBdd ZCdd ZDdd ZEdddd fdd
ZFdd fdd
ZG fddZH fddZIdddZJ  ZKS )r   c                 C   s   t  }ddddddddd	d
dddg}t jjd ||d}|rR|D ]}|| ||< q@||_|  t  |jdddd W 5 Q R X |S )Nsched_start_datesched_finish_datesched_duration
sched_cost
sched_workconstrain_start_typeconstrain_start_dateconstrain_finish_typeconstrain_finish_dateprojectgantt_projecttaskparent_task)parentr   fieldsFT)emitnotify	only_data)modelsr   getr   fix_null_variablescmfutildisable_notifysave)clsr   baseline
gantt_taskr   op_gantt_taskZfield r"   (./modules/gantt/models/cmf_gantt_task.py_create_gantt_task_for_baseline   s*          
z,CmfGanttTask._create_gantt_task_for_baselineNc              	   C   sz   t  }|r| ||S |jr4|jjjdkr4|j|_|j  |j|_||_	|j
|_
t  |jddd W 5 Q R X |S )NZ
CmfProjectF)r   r   )r   r   r$   r   value
class_namer   r   loadr   r   r   r   r   )r   r   r   r    r"   r"   r#   create_gantt_task   s    

zCmfGanttTask.create_gantt_taskc              
      s&   ddddddddd	d
g
}t   | S )Nr   r   r   task.logic_prefixztask.parent_task.logic_prefixztask.has_child_tasksztask.plan_start_dateztask.plan_end_dateztask.responsibleztask.executors)supersave_preload_fields)selfr   	__class__r"   r#   r+   1   s    z CmfGanttTask.save_preload_fieldsc                 C   s2   | j jrd S | j | j d }t|jtdtdS )Nd   z1.11Zrounding)r	   is_null_perform_completeDecimalquantizer   r,   resr"   r"   r#   _perform_costB   s    zCmfGanttTask._perform_costc                 C   s:   | j jrd S | j | j d }t|jtdtd}t|S Nr/   1r0   )r   r1   r2   r3   r4   r   intr5   r"   r"   r#   _perform_durationI   s
    zCmfGanttTask._perform_durationc                 C   s:   | j jrd S | j | j d }t|jtdtd}t|S r8   )r
   r1   r2   r3   r4   r   r:   r5   r"   r"   r#   _perform_workQ   s
    zCmfGanttTask._perform_workc                 C   s   | j js| jjrdS |  }ttjt|jp.dd}tj	|}| j |krRdS |
| j j| jj}t|dkr|
| j j|}|| d }nd}|dkrd}t|jtdtd}t|S )Nr   )Zsecondsr/   r9   r0   )r   r1   r   _get_calendardttimezoneZ	timedeltar:   datetimenowZget_work_timedeltar%   r3   r4   r   )r,   calendarZtzrA   Zdelta_finish_time_secZdelta_now_time_secZperform_completer6   r"   r"   r#   r2   Y   s$    
zCmfGanttTask._perform_completeFc                 C   s   |sd S d}|}| j dkr*| jr*d}d}n| jrd}| jj}| jdkrd||krdd}|}d|d}nN| jdkr||krd}|}d	|d}n&| jd
kr||k rd}|}d|d}d| d|d}|r|sd| jj d| jj d| d}t|dd |S )NF0-constTu   невозможно изменить дату начала, если зафиксированы дата окончания и длительность (   Фиксированное начало %d.%m.%Y3-after   Начало не раньше 4-before   Начало не позже    ограничение "uE   " конфликтует с плановой датой начала <   Конфликт планирования: В задаче "" () .abort)	r   const_durationr   r%   r   r   namecode	cmf_alertr,   estimated_datereturn_correct_dateZalertZcorrect_datetext
constraintZconstrain_dater"   r"   r#   check_correct_start_datew   s6     z%CmfGanttTask.check_correct_start_datec                 C   s   |sd S d}|}| j dkr*| jr*d}d}n| jrd}| jj}| jdkrd||krdd}|}d|d}nN| jdkr||krd}|}d	|d}n&| jd
kr||k rd}|}d|d}d| d|d}|r|sd| jj d| jj d| d}t|dd |S )NFrC   Tu   невозможно изменить дату окончания, если зафиксированы дата начала и длительностьrD   .   Фиксированное окончание rF   1-after%   Окончание не раньше 2-before#   Окончание не позже rK   uK   " конфликтует с плановой датой окончания rL   rM   rN   rO   rP   )	r   rR   r   r%   r   r   rS   rT   rU   rV   r"   r"   r#   check_correct_finish_date   s6     z&CmfGanttTask.check_correct_finish_datec                 C   s   d\}}}| j jrH| j jdkrH| j jj }||   | \}}}|}| jdkrx| j	}|rp|rpt
||}n|pv|}|}| jdkr| j}|r|rt||}n|p|}d}| jr| j}n|}|||fS )u  
        Получает из родительской задачи ограничения
        по дате начала, дате окончания и максимальной длительности.

        Returns:
            start_limit: Defaults to None
                левая граница, за которую нельзя уйти влево (_plan_start_limit_min)
            finish_limit: Defaults to None
                правая граница, за которую нельзя уйти вправо (_plan_finish_limit_max)
            duration_limit: Defaults to None
                лимит длительности, нельзя превысить (_plan_duration_limit_max)
        NNNtask.gantt_projectrC   rG   rC   r_   N)r   r   logic_prefixr!   r'   load_fieldsr+   get_parent_plan_limitr   r   maxr   r   minrR   r   )r,   Zparent_start_limitZparent_finish_limitZparent_duration_limitparent_gantt_taskstart_limitfinish_limitduration_limitr"   r"   r#   rh      s,    


z"CmfGanttTask.get_parent_plan_limitc           
      C   sb  d } }}| j jsdS tjjdd| j gdd| jgg|  dD ]}|jdkrr|s^|jj	}n|jrrt
||jj	}|jdkr|s|jj	}|jr|jrtj| |jj	t|j }|}nD|jrt
||jj	}|jrtj| |jj	t|j }t
||}|jd	kr0|s|jj	}n|jr0t||jj	}|jd
kr|s~|jj	}|jr|jrtj| |jj	t|j}|}nF|jrt||jj	}|jrtj| |jj	t|j}t||}|jr|s|j}n|jrt||j}|j jr@| \}}}	|s|}n|r t
||}|s,|}n|r<t||}|sH|	}q@|	r@t||	}q@|||fS )u~  
        !!! Очень тяжелый метод

        Получает из дочерних задач ограничения
        по дате начала, дате окончания и максимальной длительности.

        Returns:
            start_limit: Defaults to None
                левая граница, за которую нельзя уйти вправо (_plan_start_limit_max)
            finish_limit: Defaults to None
                правая граница, за которую нельзя уйти влево (_plan_finish_limit_min)
            duration_limit: Defaults to None
                самая большая фикс. длительность или фикс. трудозатраты (пока нет поддержки ресурсов),
                нельзя меньше (_plan_duration_limit_min)
        Nrb   task.parent_task=r   filterr   )rC   rI   re   )rC   r]   rd   )r   has_child_tasksr   r   listr   r+   r   r   r%   rj   r   r   r   CmfCalendarget_date_by_durationr=   r:   ri   rR   get_childrens_plan_limit)
r,   rl   rm   rn   r    r   r   Zch_start_limitZch_finish_limitZch_duration_limitr"   r"   r#   rw      s    









z%CmfGanttTask.get_childrens_plan_limitc                 C   sB   t | ddrd S d| _|  \| _| _| _|  \| _| _| _	d S )N_calc_plan_limits_cache_doneFT)
getattrrx   rh   _plan_start_limit_min_plan_finish_limit_max_plan_duration_limit_maxrw   _plan_start_limit_max_plan_finish_limit_min_plan_duration_limit_minr,   r"   r"   r#   _calc_plan_limits_cacheO  s    z$CmfGanttTask._calc_plan_limits_cachec                 C   sv   | j rD| jrDtjj| jdpd}tj|  | j j	| jj	| | _
n| j jrZ| jjrZd| _
| j
jrr| jd||d d S )N)r      r   T)from_calc_sched_durationfrom_child_changesfrom_sched_dates_changed)r   r   r   CmfTaskResAssigncountr   ru   get_duration_minutesr=   r%   r   old
is_changed_do_sched_duration_is_changed)r,   r   r   Znumber_of_recourcesr"   r"   r#   _calc_sched_durationY  s       z!CmfGanttTask._calc_sched_durationc                 C   sF   | j r,| jr,tj|  | j j| jj| _n| j jrB| jjrBd| _d S Nr   )	actual_start_dateactual_finish_dater   ru   r   r=   r%   actual_durationr   r   r"   r"   r#   _calc_actual_durationv  s      z"CmfGanttTask._calc_actual_durationc                 C   sR   t j|  | jjt| j }| j||d}| j	dkrN| j
rN| j
|krN| j
}|S )u  
        Расчитывает дату начала.
        При возникновении конфликтов ограничений, откатывает на дату ограничения при rollback=True

        Args:
            rollback (bool, optional): Defaults to False
                при конфликте откатить на дату ограничения

        Returns:
            sched_start_date:
                плановая дата начала
        rW   rX   r]   )r   ru   rv   r=   r   r%   r:   r   r[   r   rz   )r,   rollbackrW   r   r"   r"   r#   _calc_sched_start_date  s      

z#CmfGanttTask._calc_sched_start_datec                 C   s0   t j|  | jjt| j}| j||d}|S )u  
        Расчитывает дату окончания.
        При возникновении конфликтов ограничений, откатывает на дату ограничения при rollback=True

        Args:
            rollback (bool, optional): Defaults to False
                при конфликте откатить на дату ограничения

        Returns:
            sched_finish_date:
                плановая дата окончания
        r   )	r   ru   rv   r=   r   r%   r:   r   ra   )r,   r   rW   r   r"   r"   r#   _calc_sched_finish_date  s      z$CmfGanttTask._calc_sched_finish_datec                 C   s   | j js| j dkrd | _d S | jjr0| jjr0d S | jrZ| jsZ| j|d| _|rVd | _nd S | jr| js|  | _| jdkr|  | _d S | jdkr| jdkr| jrt	d d S )Nr   r   r]   rC   u   Плановый период может не соответствовать плановой длительности, т.к. все переменные зафиксированы)
r   r1   r   r   r   r   r   r   rR   rU   )r,   r   r"   r"   r#   _calc_sched_period  s"    


zCmfGanttTask._calc_sched_periodc                 C   s   | j js| j dkrd | _d S | jjr0| jjr0d S | jrZtj|  | jjt	| j | _d S | jrtj|  | jjt	| j  | _d S d S r   )
r   r1   r   r   r   ru   rv   r=   r%   r:   r   r"   r"   r#   _calc_actual_period  s&        
z CmfGanttTask._calc_actual_periodc                 C   sh   | j dkrd| jjrd| jjrd| jdkrdt| j| j d }t|d}| jjsV|| jkrd|| _| 	  dS )uR   
        Вычисляет фактический % завершения
        0-workr   r/   N)
actual_complete_typeactual_workis_not_nullr
   mathfloorrj   actual_completer1   $notify_parent_update_actual_complete)r,   tmp_completer"   r"   r#   _calc_actual_complete  s    

z"CmfGanttTask._calc_actual_completec           
      C   s  | j jsdS | jdkrdS | jdkrtjjdd| j gdd| jggdgd}|sRdS t|}d	}|D ]6}|r|j|jkr||j	j
pd	7 }qb||j	j
pd	7 }qb|| }n | jd
krtjjdd| j gddgd}|sdS d	}d	}	|D ]}|rF|j|j jkrF|j ddg ||j jj
pd	7 }|j jjdkrv|	|j jj
p@d	7 }	q||jj
pTd	7 }|jjdkr|	|jj
prd	7 }	q|	| d }n | jdkrdS | jdkrdS | j	|k r|| _	dS )uB   
        updated_ch_gantt_task - указан, когда
        Nr   
1-completero   rp   r   r   rq   r   2-story_pointsr   agile_story_pointszstatus.status_typeCLOSEDr/   3-costz4-fixed)r   rs   r   r   r   rt   r   lenidr   r%   CmfTaskrg   r   statusstatus_type)
r,   updated_ch_gantt_taskZch_gantt_task_listZtotal_countZsum_actual_completecZres_actual_completeZch_task_listZtotal_story_pointsZfinished_story_pointsr"   r"   r#   _calc_summarry_actual_complete  sR    

z+CmfGanttTask._calc_summarry_actual_completec                 C   s  |    | jdkr(| js.| jr.| j| _nd | _| jdkrB| j| _n| jdkr| j}| jrl| jrlt| j| j}|r| jr| j|k r|| _nb| jdkr| j}| jr| jrt| j| j}|r| jr| j|kr|| _n| jr| j| _| jr| j| _| jr| jr| j| jkrtddd | jr>| jr>| j| jk r>tddd | j	j
r| jr`| j	j
| jk r| jrx| j	j
| jkr| js| j	j
| _n\| jdkrnN| jd	kr| j	j
| jk r| j	j
| _n&| jd
kr| j	j
| jkr| j	j
| _| jdk| _| jr| jjr|   | jdd d S )N)rC   rG   rI   rC   rG   rI   u~   Нельзя указать Дату начала больше зафиксированной у дочерней задачиTrP   u   Нельзя указать Дату начала меньше зафиксированной у родительской задачи)1-earlyrI   )z2-latterrG   r   )r   r   r   r   rz   ri   r}   rj   rU   r   Zplan_start_datelock_sched_start_dater   _do_sched_start_date_is_changedr   )r,   r   r"   r"   r#   #_do_constrain_start_date_is_changed-  sd    







z0CmfGanttTask._do_constrain_start_date_is_changedc           	      C   s   g }| j  }| jjrT| jjdkrTdd|gdd| jgdddgg}tjj|| 	 d}dd| jgd	dd
gg}tj
j|dgd}ttdd |}dd|gdd|gg}tjj|| 	 d}|| S )Nrc   r   rp   Ztask_idr)   !=rq   out_linkrelation_type.codezsystem.additional_parentin_linkc                 S   s
   | j jjS N)r   r   r%   )Zrelr"   r"   r#   <lambda>~      z6CmfGanttTask._get_parent_gantt_tasks.<locals>.<lambda>IN)r   r'   r   r   rf   parent_task_idr   r   rt   r+   CmfRelationOptionmap)	r,   Znormal_parentsr   rr   Zadditional_filterZadditional_parents_relationsZadditional_parents_tasks_idsZadditional_parents_filterZadditional_parentsr"   r"   r#   _get_parent_gantt_tasksk  s0    


z$CmfGanttTask._get_parent_gantt_tasksc                 C   s6   d }|  ddg | jr | jj}|p4tjjddgdS )Nzproject.calendarzproject.calendar.timezonezsystem:defaultr?   )rT   r   )rg   r   rB   r   ru   r   )r,   rB   r"   r"   r#   r=     s
    zCmfGanttTask._get_calendarc                 C   s   d }d }t jjdd| jgdd| jgg|  d}|D ]}|  |j| jj	dd|_d |_
|jjrl|  n|jdd |jdd |s|jj}nt||jj}|j
r|s|j
j}nt||j
j}| j|d	 | j|d	 q4|r|| _|r|| _
| jdd
 d S )Nr   rp   r   rq   Tr   r   r   rW   r   )r   r   rt   r   r   r+   r   r[   r   newr   rs   "_calc_sched_period_for_child_tasksr   r   r%   rj   ri   ra   r   )r,   r   r   Zchild_tasks
child_taskr"   r"   r#   r     s>    


z/CmfGanttTask._calc_sched_period_for_child_tasksc                 C   s   | j | jjd |   | jjrt| jjrt| jrj| j| jk rj| j| _td| jj d| jj	 d| jdd | 
  n:| jr| jr| jsd | _|   n| jdd | jd	d
 d S )Nr   u/   Предупреждение: В задаче "rM   u2   ) дата начала перемещена на rF   ub   , так как была позже даты ограничения дочерней задачи.Tr   
start_datechanged_field)r[   r   r   r   r   rs   r}   rU   rS   rT   r   r   lock_sched_finish_dater   r   r   _calc_resourcesr   r"   r"   r#   r     s    (

z,CmfGanttTask._do_sched_start_date_is_changedc                 C   s   | j | jjd |   | jjrT| jjrTtj| 	 | jjt
| j | _|   n4| jrp| jrf| jrp|   n| jdd | jdd d S )Nr   Tr   Zfinish_dater   )ra   r   r   r   r   rs   r   ru   rv   r=   r:   r   r   r   rR   r   r   r   r   r"   r"   r#    _do_sched_finish_date_is_changed  s      


z-CmfGanttTask._do_sched_finish_date_is_changedc              
   C   s  d}d}|s|nd}|s|nd}t jjdd| jgdd| jgddddgdddggg|  d	}|D ]n}|rv|j|jkrvq`|jr|s|}n|js|}n|j|jkr|}|jr`|s|}q`|js|}q`|j|jk r`|}q`|r|j}|r|j}|s|r|jr|js|j|k r|j}|s@|r@|jr@|js@|j|kr@|j}d}	d}
| j	r|rd
|jj
 d|jj d}
| j	j}| jdkr||krd|d}	nL| jdkr||k rd|d}	n(| jdkr||krd|d}	nd}
d}| jr|rd
|jj
 d|jj d}| jj}| jdkr@||kr@d|d}	nL| jdkrd||k rdd|d}	n(| jdkr||krd|d}	nd}|	r|
p|}td| jj
 d| jj d|	 d| d	dd || _|| _| jjs| jjr| jdd |s$|r$| j|jk r$|j| _| jdd | jjr| jjd krt > | jjj }||   |j||d! |jd"dd# W 5 Q R X dS )$u  
        Обновляет плановые даты родительской задачи.
        Плановая дата начала = самая ранняя плановая дата начала всех подзадач
        Плановая дата окончания = самая поздняя плановая дата окончания всех подзадач

        Args:
            child_task (optional): Defaults to None
                измененная дочерняя задача, которая еще не сохранена.
            ignore_child_task (bool, optional): Defaults to False
                игнорировать дочернюю задачу при обновлении дат родительской задачи.
        Nr   rp   r   ORr   r   r   rq   "rM   )rC   rE   rF   rG   rH   rI   rJ   r\   r]   r^   r_   r`   uU   Конфликт планирования: В родительской задаче "u   ) ограничение "u<   " конфликтует с дочерней задачей rO   TrP   r   rc   ignore_child_taskF
user_inputr   )r   r   rt   r   r   r+   r   r   r   r   rS   rT   r%   r   r   r   rU   r   r   r   r   r   rf   r   disable_aclr!   r'   rg   from_sched_dates_of_child_tasksr   )r,   r   r   Zmin_start_dateZmax_finish_datesZchild_task_with_min_startZchild_task_with_max_finishZgantt_tasksr    rZ   Zconflict_child_task_min_startr   Zconflict_child_task_max_finishr   Zconflict_child_taskrk   r"   r"   r#   r     s    

	
&
z,CmfGanttTask.from_sched_dates_of_child_tasksc              	   C   sp   |  dg | jjrl| jjdkrlt > | jjj }| |   |j	| |d |j
ddd W 5 Q R X dS )uC  
        Обновление дат начала и окончания родительской задачи.
        Передает дочернюю задачу (self), так как она еще не сохранена
        и родительская задача не может получить обновленные данные.

        Args:
            ignore_child_task (bool, optional): Defaults to False
                игнорировать дочернюю задачу при обновлении дат родительской задачи.
        z#task.parent_task, task.logic_prefixrc   r   FTr   N)rg   r   r   rf   r   r   r!   r'   r+   r   r   )r,   r   rk   r"   r"   r#   update_parent_task_sched_datesg  s    

z+CmfGanttTask.update_parent_task_sched_datesc                 C   s   |   }|D ]}|jdkr$td q| | r|| rD| | || k r|jdkrt|| rt| | || krttd  d S |jdkr|| r| | || k rtd  d S | | ||< |  |j|d qd S )NrC   ^   Дата родительской задачи является зафиксированнойrI   u   Предупреждение: Плановая дата начала дочерней задачи больше плановой даты начала родительской задачиrG   u   Предупреждение: Плановая дата начала дочерней задачи меньше плановой даты начала родительской задачи)
date_field)r   r   rU   r   _change_parent_start_date)r,   r   parentsrk   r"   r"   r#   r   |  s&    
 z&CmfGanttTask._change_parent_start_datec                 C   s   |   }|D ]}|jdkr$td q| | r|| rD| | || kr|jdkrt|| rt| | || k rttd  d S | | }|jdkr|| r| | || krtd |jr||jkr|j}|||< |  || q| jdk| _d S )NrC   r   r]   u   Предупреждение: Плановая дата окончания дочерней задачи меньше плановой даты окончания родительской задачиr_   u   Предупреждение: Плановая дата окончания дочерней задачи больше плановой даты окончания родительской задачи)r   r   rU   r   r   _change_parent_finish_dater   r   )r,   r   r   rk   Z
date_valuer"   r"   r#   r     s,    
 z'CmfGanttTask._change_parent_finish_datec                 C   s\  |    | jdkr(| js.| jr.| j| _nd | _| jdkrB| j| _n| jdkrx| j}| jrl| jrlt| j| j}|r|| _nb| jdkr| j}| jr| jrt| j| j}|r| jr| j|kr|| _n| jr| j| _| j	r| j	| _| jr&| j
r| j| j
krtddd | jr&| j| jk r&tddd | jjr| j
rH| jj| j
k r| jr`| jj| jkr| jst| jj| _n\| jdkrnN| jdkr| jj| jkr| jj| _n&| jdkr| jj| jk r| jj| _| jdk| _| jr| jjr| jr| jdkr
| jsd | _|   | jrL| jjrL| jdkr>| jsDd | _|   | jdd	 d S )
N)rC   r]   r_   rC   r]   r_   u   Нельзя указать Дату окончания больше зафиксированной у родительской задачиTrP   u   Нельзя указать Дату окончания меньше зафиксированной у дочерней задачиr   )r   r   r   r   r~   ri   rj   rz   r   r}   r{   rU   r   Zplan_end_dater   r   r   r   r   r   r   r   )r,   r   r"   r"   r#   $_do_constrain_finish_date_is_changed  sr    







z1CmfGanttTask._do_constrain_finish_date_is_changedc                 C   s6  | j dkrB| jdkrB| jjsB| jjsB|r6tddd ntddd |   | jrh| j| jkrhtddd | j	r| j| j	k rtddd |s2|s| j
rd | _| jdd |s| jr| js| jr| j| _| jd||d	 | jr| jr| j| jk rtd
| jj d| jj ddd |s2|s2| jdd d S )NrC   u  Конфликт планирования: невозможно изменить трудозатраты, если установлена опция "Фиксированные Ресурсы" и зафиксированы даты начала и окончания.TrP   u   Конфликт планирования: невозможно изменить длительность, если зафиксированы даты начала и окончания.u   Конфликт планирования: невозможно установить длительность больше зафиксированной у родительской задачи.u   Конфликт планирования: невозможно установить длительность меньше зафиксированной у дочерней задачи.r   )from_sched_duration_changedr   r      В задаче "rM   u   ) невозможно указать Длительность меньше чем Трудозатраты, когда установлена опция Фиксированные Ресурсы и Трудозатраты зафиксированы.durationr   )r   r   r   r   r   rU   r   r|   r   r   r   r   r   
const_workconst_resourcer
   _do_sched_work_is_changedr   rS   rT   r   )r,   from_sched_work_changedr   r   r   from_calc_resourcesr"   r"   r#   r     sN    z*CmfGanttTask._do_sched_duration_is_changedc                 C   s   |    d S r   )r   r   r"   r"   r#   _do_actual_duration_is_changed  s    z+CmfGanttTask._do_actual_duration_is_changedc              	   C   s   | j jrd S | j dk r"tddd | jjs2| j | _|   | j jpDd| j jpNd }| jj	r| jj
dkrt 8 | jj	j }||   || |jdd W 5 Q R X |s| jjrtj| j| d S )Nr   uo   "Фактические трудозатраты" стал ниже нуля, выставляем в ноль.TrP   rc   Fr   )r   r1   rU   r   rs   actual_myself_workr   r   r   r   rf   r   r   r!   r'   rg   r+   from_child_add_workr   r   r   ZCmfTimeTrackerZ"_op_gantt_actual_work_changed_hook)r,   from_timetracker
work_deltark   r"   r"   r#   _do_actual_work_is_changed  s     


z'CmfGanttTask._do_actual_work_is_changedc              	   C   s   | j jrd S | j dk r"tddd | jdkr~| jjr~| jdkr~t| j | j d }t|d}| j	jsp|| j	kr~|| _	| 
  | jjr| jjdkr| j jpd| j jpd }t 8 | jjj }||   || |jdd	 W 5 Q R X d S )
Nr   ue   "Фактические Затраты" стал ниже нуля, выставляем в ноль.TrP   r   r/   rc   Fr   )actual_costr1   rU   r   r	   r   r   r   rj   r   r   r   r   rf   r   r   r   r   r!   r'   rg   r+   from_child_add_costr   )r,   r   
cost_deltark   r"   r"   r#   _do_actual_cost_is_changed8  s$    




z'CmfGanttTask._do_actual_cost_is_changedc                 C   s,   | j jrd S | jdkrd S | jdkr(d S d S )Nr   r   )r   r1   r   r   r"   r"   r#   _do_actual_complete_is_changedP  s    

z+CmfGanttTask._do_actual_complete_is_changedc                 C   sH   | j jp
d| j jpd }| jjs*| j | _n|  j|7  _| j|d d S )Nr   r   )r   r   r   r   rs   r   r   )r,   r   r   r"   r"   r#   !_do_actual_myself_work_is_changed`  s
    
z.CmfGanttTask._do_actual_myself_work_is_changedc                 C   sD   | j jp
d| j jpd }| jjs*| j | _n|  j|7  _|   d S r   )actual_myself_costr   r   r   rs   r   r   r,   r   r"   r"   r#   !_do_actual_myself_cost_is_changedj  s
    
z.CmfGanttTask._do_actual_myself_cost_is_changedc           	   	   C   s  | j jrd S | jjr| j | jk r| jd  d| jd  d}| j d  d| j d  d}| jrztd| d| ddd n| j| _ |std	| d
 nt|s| j r|s| js| jr| j | _	| j
dd | jr| jr| j	| j k rtd| jj d| jj ddd |   | jjr| jjdkr| j jp8d| j jpDd }t : | jjj }||   || |jddd W 5 Q R X |s|s|s| jdd d S )N<      ч    мu   Нельзя запланировать меньше Трудозатрат, чем запланировано в подзадачах ( < ub   ). Увеличьте Трудозатраты или уменьшите их у подзадач.TrP   u   Указано Трудозатрат меньше, чем запланировано в подзадачах. Выставили uo   . Если нужно уменьшить Трудозатраты, уменьшите их у подзадач.)r   r   rM   u   ) нельзя указать Трудозатраты больше чем Длительность, когда установлена опция Фиксированные Ресурсы и Длительность зафиксирована.rc   r   Fr   workr   )r
   r1   r   rs   agregat_workr   rU   rR   r   r   r   rS   rT   r   r   rf   r   r   r   r   r!   r'   rg   r+   from_child_agregate_workr   r   )	r,   r   r   r   r   r   r
   r   rk   r"   r"   r#   r   t  s>    

z&CmfGanttTask._do_sched_work_is_changedc              	   C   s   | j jrd S | j | jk rX| jr>td| j  d| j ddd n| j| _ td| j d | jjr| jjdkr| j jpvd	| j j	pd	 }t
 : | jjj }||   || |jd
dd W 5 Q R X d S )Nu   Нельзя запланировать меньше Расходов, чем запланировано в подзадачах (r   uX   ). Увеличьте Расходы или уменьшите их у подзадач.TrP   u|   Указано Расходов меньше, чем запланировано в подзадачах. Выставили ue   . Если нужно уменьшить Расходы, уменьшите их у подзадач.rc   r   Fr   )r	   r1   agregat_cost
const_costrU   r   r   rf   r   r   r   r   r!   r'   rg   r+   from_child_agregate_costr   r,   r   rk   r"   r"   r#   _do_sched_cost_is_changed  s     

z&CmfGanttTask._do_sched_cost_is_changedc                 C   s"   | j r| jr|   n|   d S r   )r   r   r   r   r   r"   r"   r#    _do_actual_start_date_is_changed  s    
z-CmfGanttTask._do_actual_start_date_is_changedc                 C   s(   | j s| jr| jr|   n|   d S r   )r   r   r   r   r   r   r"   r"   r#   !_do_actual_finish_date_is_changed  s    
z.CmfGanttTask._do_actual_finish_date_is_changedc                 C   sF   | j dkr|   n.| j dkr0| jjr0|   n| j dkrB|   d S )Nr   r   r   r   )r   r   r   rs   r   r   r   r"   r"   r#   #_do_actual_complete_type_is_changed  s    



z0CmfGanttTask._do_actual_complete_type_is_changedc                 C   s   | j r|   d S r   )rR   r   r   r"   r"   r#   _do_const_duration_is_changed  s    z*CmfGanttTask._do_const_duration_is_changedc                 C   s*   | j rd| _| j| _n| jj| _d | _d S NrC   )r   r   r   r   defaultr   r"   r"   r#   $_do_lock_sched_start_date_is_changed  s
    

z1CmfGanttTask._do_lock_sched_start_date_is_changedc                 C   s*   | j rd| _| j| _n| jj| _d | _d S r  )r   r   r   r   r  r   r"   r"   r#   %_do_lock_sched_finish_date_is_changed  s
    

z2CmfGanttTask._do_lock_sched_finish_date_is_changedc                 C   s|   |sd S |  ddddg |j }| |   || j || j || j	 |
| j ||  |jdd d S )Nr	   r
   r   r   Fr   rg   r!   r'   r+   r   r	   r   r
   r   r   r   r   r   r   r,   r   rk   r"   r"   r#   add_child_task_to_parent_task  s    

z*CmfGanttTask.add_child_task_to_parent_taskc                 C   s   |sd S |  ddddg |j }| |   || j  || j  || j	  |
| j  |j| dd |jdd d S )	Nr	   r
   r   r   Tr   Fr   r  r  r"   r"   r#   "remove_child_task_from_parent_task  s    
z/CmfGanttTask.remove_child_task_from_parent_taskc              	   C   sD   t  2 | jj}|r | | | jj}|r6| | W 5 Q R X d S r   )r   r   r   r   r  r   r  )r,   Z
old_parentZ
new_parentr"   r"   r#   _do_parent_task_is_changed	  s    

z'CmfGanttTask._do_parent_task_is_changedc                 O   s   t jj| df|| d S )Nupdated)r   ZCmfEventZdo_event)r,   argskwargsr"   r"   r#   _do_event_save  s    zCmfGanttTask._do_event_savec                 O   s
   | | j S r   )Z	log_level)r,   Z
field_namer  r  r"   r"   r#   _get_field_log_level  s    z!CmfGanttTask._get_field_log_levelc                 C   s|  | j r`d| _d| _| jjr\| jjj r\| jjjj }|rNt|t	j
 | _d| _|   d S | jjrnd| _| jjr|   d S | jjr|   d S | jjr|   d S | jjs| jjr|   |s|   d S | jjs| jjr|   |s|   d S | jjr|   |s|   d S | jjr4|   d S | jjrJ|   d S | j jr`| !  d S | j"jrv| #  d S | jjr| $  |s|   d S | j%jr| &  d S | j'jr| (  d S | j)jr| *  d S | j+jr| ,  d S | j-jr| .  d S | jjr,| /  |s(|   d S | j0jrP| 1  |sL|   d S | j2jrf| 3  d S | j4jrx| 5  d S )Nr   r   )6is_newr   r
   r   r   r!   r'   r   ri   r>   r@   Zutcnowr   r   r1   r   r  r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r	   r  r   r  r   r  r   r  rR   r  r   r   r   r   r	  r   r
  )r,   from_parent_changesZparent_sched_start_dater"   r"   r#   _save  s    














zCmfGanttTask._savec                 C   s  |sd S | j jrd S | jsd S | jj}| jj}| jj}|}d}|sJ|sJd S |sR|}|sZ|}| jj}| jj}	| jj}
|d krt	j
jdd| j gdddgd}t|}|dkrd S |	r|dkr|| | }nL|
r|d	kr|| | }n|d
ks|dkr|| }n|r|dkr|| }|}d}|dkr4|| }|| }g }g }i }|D ]}dd|jgdd|jgdddgg}t	jj|dD ]}|  qx|}|dkr||7 }d}d }d }|jj| dD ]}|jj}d}|| kr||}|jj| }|dkrqt|| |k rt|| n|}||}||| pF|jddd}t	j|j| j ||d|dd}|  |sv|}||d}||kr|||< ||8 }|dkr|} qq|| || | |_| |_t|d |_|  qDt|| _t || _!tt"|# | | _|| _|	rR|dkr|| jjkr| j$dd nz|
r~|dkr|| jjkr| j%dd nN|r|dkr|| jjkr| j$dd |dkr|| jjkr| j%dd d S )Nr   r   ==personrB   rq   r   r   r   units	cmf_ownerhistory_typeZplanrr   )r      ;   )ZhourZminute)r  r   r   Zend_dater  Z
time_spentremaining_estimater/   )r  r   T)r   )r  r   )&r   rs   r   r%   r   r
   r   r   rR   r   r   rt   r   r  r   ZCmfTimeTrackerHistorydeleterB   Z	work_daysdateZget_work_time_shiftZinterval_total_minutesr:   Zget_shifted_work_timereplacer   r   appendZ
date_startZdate_endr  rj   ri   r   sumvaluesr   r   )r,   r   assignmentsr   r   r   Zinitial_workr  r   r   rR   Znumber_of_resourcesZwork_per_personZwork_remainderZstart_timesZ	end_timesZmax_work_per_dayZ
assignment_filterZtthZ	work_leftZ
start_timeZend_timeZdayZcur_dateZ
time_shiftZ
avail_timeZwork_for_todayZtth_start_dateZtth_end_dateZcur_max_work_for_todayr"   r"   r#   r   x  s    








"
	












zCmfGanttTask._calc_resourcesc                 C   s4   |  |   |   | jd|d | jdd d S )Nr  )r   r'  Tr   )rg   r+   r   r   r   )r,   r'  r"   r"   r#   task_resources_changed_hook  s    z(CmfGanttTask.task_resources_changed_hookc                 C   sl   |  |   |   |  j|7  _| jdd |d kr\| j| j |kr\| j| | _|   | jdd d S )NTr   r   )	rg   r+   r   r   r   r
   r   r   r   )r,   r   r   r"   r"   r#   timetracker_add_work_hook  s    z&CmfGanttTask.timetracker_add_work_hookc                 C   s(  |rL|j dkrL| jsL| |   |   | j  |   | jdd d S |r|j dkr|r|j dkr| |   |   | j  d| _	| 
  |   | jdd |   d S |r$|j dkr$|r$|j dkr$| |   |   d | _d| _	| 
  |   | jdd |   d S d S )NZIN_PROGRESSTr   r   r/   r   )r   r   rg   r+   r   Zset_nowr  r   r   r   r  r   r   )r,   Z
old_statusZ
new_statusr"   r"   r#   task_status_is_changed_hook  sF    

z(CmfGanttTask.task_status_is_changed_hookc                 C   s6   |  |   |   |   |   | jdd dS )u   
        В задаче изменились Agile-плановые даты, пересчитаем свои sched-даты, вдруг новые ограничения повлияют на них
        Tr   N)rg   r+   r   r   r   r   r   r"   r"   r#   task_plan_dates_is_changed_hook<  s
    z,CmfGanttTask.task_plan_dates_is_changed_hookc                 C   s    | j jrd| _ |  j |7  _ d S r   )r   r1   )r,   r   r"   r"   r#   r   G  s    z CmfGanttTask.from_child_add_workc                 C   s    | j jrd| _ |  j |7  _ d S r   )r   r1   r   r"   r"   r#   r   L  s    z CmfGanttTask.from_child_add_costc              	   C   s&  | j jrd| _ |  j |7  _ | jsD| j | _| jjp4d| jjp>d }n~| j | jks| j d  d| j d  d}| jd  d| jd  d}td| d| d| j dd	d
 | j jpd| j jpd }| jjr"| jj	dkr"t
 : | jjj }||   || |jdd	d W 5 Q R X d S )Nr   r   r   r   u;   Превысили План на Трудозатраты ( <= +   ) в родительской задаче ub   . Увеличьте в ней план или введите меньше Трудозатрат.TrP   rc   Fr   )r   r1   r   r
   r   r   rU   r   r   rf   r   r   r!   r'   rg   r+   r   r   )r,   r   r   r
   rk   r"   r"   r#   r   Q  s&    

z%CmfGanttTask.from_child_agregate_workc              	   C   s   | j jrd| _ |  j |7  _ | js,| j | _n2| j | jks^td| j  d| j d| j ddd | jjr| jjdkr| j jp|d| j j	pd }t
 8 | jjj }||   || |jd	d
 W 5 Q R X d S )Nr   u1   Превысили План на Расходы (r-  r.  u[   . Увеличьте в ней план или введите меньше РасходовTrP   rc   Fr   )r   r1   r   r	   rU   r   r   rf   r   r   r   r   r!   r'   rg   r+   r   r   r   r"   r"   r#   r   j  s     


z%CmfGanttTask.from_child_agregate_costc                 C   s   |  | dS )u   
        Оповестить родителя, что ему нужно пересчитать свой агрегат actual_complete
        N)r   )r,   r   r"   r"   r#   !from_child_update_actual_complete~  s    z.CmfGanttTask.from_child_update_actual_completec              	   C   sV   | j jsdS t 8 | j jj }||   ||  |j	dd W 5 Q R X dS )uP  
        Оповещение родителя.
        Передаем себя, т.к. мы еще можем быть не сохранены и родитель не сможет получить наши данные
        Другой вариант: опочещать через отдельный таск в celery
        NFr   )
r   r   r   r   r!   r'   rg   r+   r/  r   )r,   rk   r"   r"   r#   r     s    

z1CmfGanttTask.notify_parent_update_actual_completec                 C   s  | j sp| jrpdd | jddD }|ddddh }|rp| jj  | jjrp| jjjjd	rp| jjj	d
| jd | j
jr| jjrtddd | jjr| jjrtddd | jjs| jjr| jr| jr| j| jk rtddd | jjr| jjs| jdkrtddd d S )Nc                 S   s   h | ]\}}|qS r"   r"   ).0k_r"   r"   r#   	<setcomp>  s     z0CmfGanttTask.check_user_input.<locals>.<setcomp>Tr   r   r   r   Zgantt_project_idzCmfProject:zPPP-TSK-SCHEDULE)obju   Нельзя менять поле "Фактические трудозатраты" у Summary-задач. Используйте поле "Фактические трудозатраты по собственным ресурсам задачи"rP   u   Нельзя менять поле "Фактические Затраты" у Summary-задач. Используйте поле "Фактические Затраты по собственным ресурсам задачи"u\   Нельзя выставить Дату начала позже Даты окончанияr  u   Этот вариант рассчета процента завершения можно использовать только у Summary-задач)r  r   itemsr   Zroot_parentr'   r   r%   
startswithZcheck_project_role_accessr   rs   rU   r   r   r   r   )r,   Zchanged_fieldsr"   r"   r#   check_user_input  s0    
zCmfGanttTask.check_user_inputc                 C   s   | j jrd| _ | jjrd| _| jjr*d| _| jjr8d| _| jjrFd| _| jjrTd| _| jjrbd| _| jjrpd| _| j	jr~d| _	| j
jrd| _
| jjrd| _| jjrd| _d S r   )r   r1   r   r	   r   r   r   r   r
   r   r   Zconstrain_slackZconstrain_slack_pctr   r"   r"   r#   r     s0    zCmfGanttTask.fix_null_variablesT)r   r  from_sort_orderc                   s   |r|    | j|| | j|d | jjr:| jjdd |   t j||}|s| jjrdd| jgdddgg}t	j
j|drtt	j
j| jjgd	 |S )
N)r  Tr   r   r  r   zsystem.finish:startr  )r  )r8  r  r  r   r   r   r   r*   r   r   r   r   Zschedule_deferred_jobZsort_task_by_order_relationsr   )r,   r   r  r9  r  r  r6   r(  r-   r"   r#   r     s    zCmfGanttTask.save)TEXKOM_db_deletec                   s   |  dddg |rVt| j tjj| jddD ] }t| d |_|jdd q2n&| j	r|| j	j| kr|| j	j
s|tddd | j	r| j	j| kr| | j t j|d	|i|S )
Nztask.op_gantt_taskztask.cmf_deletedr   T)r!   Zinclude_deletedr   uY   Нельзя удалять Оперативную гант задачу у задачи!rP   r:  )rg   gdebugr   r   r   rt   r!   r   r   Zcmf_deletedrU   r  r   r*   r!  )r,   r:  r  r  r   r-   r"   r#   r!    s    
zCmfGanttTask.deletec                    sB   t  jf | | jrd S td tj| jdd td d S )N_CmfAutomationCrudTrigger startupdateZbefore_save_CmfAutomationCrudTrigger end)	r*   before_save_hookr  r;  r<  r   CmfAutomationCrudTrigger	crud_hookr   r,   r  r-   r"   r#   r@    s    
zCmfGanttTask.before_save_hookc                    sB   t  jf | | jrd S td tj| jdd td d S )Nr=  r>  Z
after_saver?  )	r*   before_save_data_hookr  r;  r<  r   rA  rB  r   rC  r-   r"   r#   rD    s    
z"CmfGanttTask.before_save_data_hookr>  c              	   C   sv   | j   tjr| j sd S tjtjjjdg|| jj| jddtj| j jjd}t	d|d  ||d |d gd d S )Nproject_notifyTr4  )ZinitiatorSessionTabIdZinitiatorCurrentPersonactionZinitiatorActionZinitiatorObjIdZinitiatorObjChangedFieldsu   initiatorСomponentId	projectIdzproject_notify-rG  )ZroomZevent_persons)
r   r'   r;  Zsession_tab_idZcurrent_personr   r%   keysZcomponent_idZcmf_emit_event)r,   Zinitiator_actionZeventr"   r"   r#   rE    s     

zCmfGanttTask.project_notify)N)NF)NF)FF)F)F)F)N)NF)F)FFFFF)F)F)FFFF)N)N)F)NN)N)N)r>  )L__name__
__module____qualname__classmethodr$   r(   r+   propertyr7   r;   r<   r2   r[   ra   rh   rw   r   r   r   r   r   r   r   r   r   r   r   r=   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r  r  r  r  r	  r
  r  r  r  r  r  r  r   r)  r*  r+  r,  r   r   r   r   r/  r   r8  r   r   r!  r@  rD  rE  __classcell__r"   r"   r-   r#   r   
   s   





&
'+`

	


%
:>	.
 
F     
*



    
5


[
 
'


r   )
r@   r>   Zcmf.includedecimalr   r   r   Z
cmf.fieldsZ#modules.gantt.fields.cmf_gantt_taskr   r"   r"   r"   r#   <module>   s   