src/EventListener/AssignmentFinishedListener.php line 94

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\Assignment;
  6. use App\Entity\AttachmentAssignment;
  7. use App\Entity\Branch;
  8. use App\Entity\Notification;
  9. use App\Entity\Order;
  10. use App\Entity\OrderNumber;
  11. use App\Entity\OrderTimeLine;
  12. use App\Entity\Procedure;
  13. use App\Entity\Task;
  14. use App\Enum\DeadlineType;
  15. use App\Enum\OrderEnum;
  16. use App\Enum\TaskEnum;
  17. use App\Event\AssignmentFinishedEvent;
  18. use App\Manager\TotalDeadlineAssignment;
  19. use App\Message\FinishDesignSendTelegram;
  20. use App\Message\FinishProductOnProductionMessage;
  21. use App\Message\FinishReceiveSendDocumentTelegram;
  22. use App\Message\FinishReceiveSendTelegram;
  23. use App\Message\MessageNotification;
  24. use App\Message\TelegramMessage;
  25. use App\Message\UpdateRelationOrderProductMessage;
  26. use App\Order\ChangeStatusOrderDelivery;
  27. use App\Order\HandleOrderBranch;
  28. use App\Repository\AssignmentRepository;
  29. use App\Repository\AttachmentAssignmentRepository;
  30. use App\Repository\DeadlineGuideRepository;
  31. use App\Repository\OrderRepository;
  32. use App\Repository\TaskRepository;
  33. use App\WareHouse\AutoCreateReceipt;
  34. use Carbon\CarbonImmutable;
  35. use DateTimeImmutable;
  36. use Doctrine\ORM\EntityManagerInterface;
  37. use Symfony\Component\Messenger\MessageBusInterface;
  39. class  AssignmentFinishedListener
  40. {
  41.     const STEP_PRIORITY = 1;
  42.     const STEP_HALF_PART = 0.5;
  44.     private $totalDeadlineAssignment;
  45.     /**
  46.      * @var TaskRepository
  47.      */
  48.     private $taskRepository;
  49.     /**
  50.      * @var DeadlineGuideRepository
  51.      */
  52.     private $deadlineGuideRepository;
  53.     /**
  54.      * @var AssignmentRepository
  55.      */
  56.     private $assignmentRepository;
  57.     /**
  58.      * @var OrderRepository
  59.      */
  60.     private $orderRepository;
  61.     /**
  62.      * @var MessageBusInterface
  63.      */
  64.     private $messageBus;
  65.     /**
  66.      * @var AttachmentAssignmentRepository
  67.      */
  68.     private $attachmentAssignmentRepository;
  70.     /**
  71.      * @var EntityManagerInterface
  72.      */
  73.     private $entityManager;
  75.     public function __construct(TotalDeadlineAssignment $totalDeadlineAssignment,
  76.                                 TaskRepository $taskRepository,
  77.                                 AssignmentRepository $assignmentRepository,
  78.                                 DeadlineGuideRepository $deadlineGuideRepository,
  79.                                 OrderRepository $orderRepository,
  80.                                 MessageBusInterface $messageBus,
  81.                                 AttachmentAssignmentRepository $attachmentAssignmentRepository,
  82.                                 EntityManagerInterface $entityManagerInterface
  83.     ) {
  84.         $this->totalDeadlineAssignment = $totalDeadlineAssignment;
  85.         $this->taskRepository = $taskRepository;
  86.         $this->deadlineGuideRepository = $deadlineGuideRepository;
  87.         $this->assignmentRepository = $assignmentRepository;
  88.         $this->orderRepository = $orderRepository;
  89.         $this->messageBus = $messageBus;
  90.         $this->attachmentAssignmentRepository = $attachmentAssignmentRepository;
  91.         $this->entityManager= $entityManagerInterface;
  92.     }
  94.     public function __invoke(AssignmentFinishedEvent $event)
  95.     {
  96.         $assignment = $event->getAssignment();
  97.         /** @var Order $order */
  98.         $order = $assignment->getOrder();
  100.         if ($this->checkTaskParallelFinished($order)) {
  101.             $this->deActiveAssignment($order);
  103.             $taskReplacement = $assignment->getTask()->getTaskReplacement()->last();
  104.             $mainTask = $this->getMainTask($assignment);
  105.             if ($mainTask) {
  106.                 $this->addLoopTask($assignment, $mainTask);
  107.             } elseif ($taskReplacement) {
  108.                 if ($this->isApproval($event)) {
  109.                     $this->skipTask($assignment);
  110.                 } else {
  111.                     $this->addReason($event);
  112.                     $this->addLoopTask($assignment, $taskReplacement);
  113.                 }
  114.             } else {
  115.                 $this->addTaskNormal($assignment);
  116.             }
  117.         }
  119.     }
  121.     private function addReason(AssignmentFinishedEvent $event)
  122.     {
  123.         $assignment = $event->getAssignment();
  124.         $approve = $event->getOptions()['approve'];
  125.         if (\count($approve) > 0 && !\in_array('1', $approve, true)) {
  126.             $reason = '';
  127.             foreach ($approve as $key => $item) {
  128.                 $item = (int) $item;
  129.                 if ($key > 0) {
  130.                     $reason .= ',';
  131.                 }
  133.                 if (Assignment::REASON_BY_SALE === $item) {
  134.                     $reason .= 'Do sale';
  135.                 } elseif (Assignment::REASON_BY_CUSTOMER === $item) {
  136.                     $reason .= 'Do khách hàng';
  137.                 } elseif (Assignment::REASON_BY_DESIGN === $item) {
  138.                     $reason .= 'Do thiết kế';
  139.                 }
  140.             }
  142.             $assignment->setReasonReject($reason);
  143.         }
  144.     }
  146.     private function getMainTask(Assignment $assignment)
  147.     {
  148.         return $assignment->getTask()->getMainTask()->last();
  149.     }
  151.     private function isApproval(AssignmentFinishedEvent $event)
  152.     {
  153.         return \in_array('1', $event->getOptions()['approve'], true);
  154.     }
  156.     private function addTaskNormal(Assignment $assignment)
  157.     {
  158.         /** @var Order $order */
  159.         $order = $assignment->getOrder();
  160.         /** @var Procedure $procedure */
  161.         $procedure = $order->getProcedure();
  162.         /** @var Assignment $lastAssigment */
  163.         $codes = $this->findCodeWithNextTask($assignment);
  165.         if (\in_array($assignment->getTask()->getCode(), ['thu_coc', 'thu_coc_cus', true], true)) {
  166.             /** @var Order $lastOrder */
  167.             $orderNumber = (new OrderNumber())->setOrderMain($order)->setPriority(0);
  168.             $this->entityManager->persist($orderNumber);
  169.             $this->entityManager->flush();
  170.             $order->setSort($orderNumber->getId());
  172.             (new HandleOrderBranch($this->entityManager,$this->messageBus))->setBranch($assignment);
  173.             $attachmentAssignmentDesign = $this
  174.                 ->attachmentAssignmentRepository
  175.                 ->findLastFileDesign($assignment->getOrder()->getId());
  177.             $attachmentAssignmentReviews = $this
  178.                         ->attachmentAssignmentRepository
  179.                         ->findLastFileDesignPreview($assignment->getOrder()->getId());
  181.             if (\count($attachmentAssignmentReviews) > 0) {
  182.                 $attachmentFileNames = $attachmentPreviews = [];
  184.                 /** @var AttachmentAssignment $attachmentAssignment */
  185.                 foreach ($attachmentAssignmentReviews as $attachmentAssignment) {
  186.                     $attachmentPreviews[$attachmentAssignment->getAssignment()->getId()->toString()][] = $attachmentAssignment;
  187.                 }
  188.                 foreach (array_values($attachmentPreviews)[0] as $attachmentAssignment) {
  189.                     $attachmentFileNames[] = $attachmentAssignment->getAttachment()->getFileName();
  190.                 }
  191.                 $this->messageBus->dispatch(new FinishReceiveSendTelegram(
  192.                     $assignment->getOrder()->getId(),
  193.                     $assignment->getId()->toString(),
  194.                     $attachmentFileNames
  195.                 ));
  196.             }
  198.             if (\count($attachmentAssignmentDesign) > 0) {
  199.                 $this->messageBus->dispatch(new FinishReceiveSendDocumentTelegram(
  200.                     $assignment->getOrder()->getId(),
  201.                     $assignment->getId()->toString(),
  202.                     $attachmentAssignmentDesign[0]->getAttachment()->getFileName()
  203.                 ));
  204.             }
  205.             
  206.             
  207.         }
  209.         $beforeFinishReceive = [
  210.             Task::START_DESIGN,
  211.             Task::START_CUSTOMER_DESIGN_APPROVAL_CODE,
  212.             Task::FIX_DESIGN,
  213.         ];
  214.         $beforeFinishReceiveCus = [
  215.             Task::START_DESIGN_CUS,
  216.             Task::CUS_START_CUSTOMER_DESIGN_APPROVAL_CODE,
  217.             Task::FIX_DESIGN_CUS,
  218.         ];
  220.         if (0 === \count($codes) && \in_array($assignment->getTask()->getCode(), $beforeFinishReceive, true)) {
  221.             $codes[] = Task::FINISH_RECEIVE;
  222.         } elseif (0 === \count($codes) && \in_array($assignment->getTask()->getCode(), $beforeFinishReceiveCus, true)) {
  223.             $codes[] = Task::CUS_FINISH_RECEIVE;
  224.         }
  226.         foreach ($codes as $code) {
  227.             $previousTaskCode = $procedure->getTasks()[$code];
  228.             $nextTask = $this->taskRepository->findOneBy(['code' => $code]);
  229.             $this->addTask($assignment, $nextTask, $previousTaskCode);
  230.         }
  231.     }
  233.     private function findCodeWithNextTask(Assignment $assignment)
  234.     {
  235.         $code = $assignment->getTask()->getCode();
  236.         /** @var Procedure $procedure */
  237.         $procedure = $assignment->getOrder()->getProcedure();
  238.         $codeTasks = [];
  239.         foreach ($procedure->getTasks() as $taskCode => $previousTaskCode) {
  240.             if (\in_array($code, $previousTaskCode, true)) {
  241.                 $codeTasks[] = $taskCode;
  242.             }
  243.         }
  245.         return $codeTasks;
  246.     }
  248.     private function checkTaskParallelFinished(Order $order)
  249.     {
  250.         /** @var Assignment $assignment */
  251.         foreach ($order->getAssignments() as $assignment) {
  252.             if ($assignment->isActive() && !$assignment->isFinished()) {
  253.                 return false;
  254.             }
  255.         }
  257.         return true;
  258.     }
  260.     private function deActiveAssignment(Order $order)
  261.     {
  262.         /** @var Assignment $assignment */
  263.         foreach ($order->getAssignments() as $assignment) {
  264.             $assignment->setActive(false);
  265.         }
  266.     }
  268.     private function skipTask(Assignment $assignment)
  269.     {
  270.         $code = $this->findNextTask($assignment);
  271.         $nextTask = $this->taskRepository->findOneBy(['code' => $code]);
  272.         $previousTaskCode = [$assignment->getTask()->getCode()];
  273.         $this->addTask($assignment, $nextTask, $previousTaskCode);
  274.     }
  276.     private function findNextTask(Assignment $assignment)
  277.     {
  278.         /** @var Procedure $procedure */
  279.         $procedure = $assignment->getOrder()->getProcedure();
  280.         $taskList = array_keys($procedure->getTasks());
  281.         $index = array_search($assignment->getTask()->getCode(), $taskList, true);
  282.         $index += 2;
  284.         return $taskList[$index];
  285.     }
  287.     private function addTask(Assignment $assignment, Task $nextTask, array $previousTaskCode)
  288.     {
  291.         try {
  292.             $this->addEventFinish($assignment);
  293.             /** @var Order $order */
  294.             $order = $assignment->getOrder();
  295.             $assignment = new Assignment($order, $nextTask);
  296.             $assignment->setActive(true)
  297.             ->setState(0);
  299.             $this->sortAssignment($assignment, $assignment->getTask()->getCode());
  301.             /** @var Assignment $assignmentPrevious */
  302.             $assignmentPrevious = $order->getAssignments()->last();
  303.             $deadLinePrevious = $assignmentPrevious->getWorkedAt();
  304.             if (null === $deadLinePrevious) {
  305.                 $deadLinePrevious = new \DateTimeImmutable();
  306.             }
  308.             $deadlineGuide = $this->deadlineGuideRepository->findOneBy(['task' => $assignment->getTask(), 'type' => $order->getType()]);
  309.             $deadLineTime = null === $deadlineGuide ? 600 : $deadlineGuide->getTime();
  310.             $deadLine = $this->totalDeadlineAssignment->total(
  311.                 new DateTimeImmutable(), $deadLineTime);
  312.             $assignment->setDeadline($deadLine);
  314.             if ($previousTaskCode) {
  315.                 $predecessors = $order->getAssignments()->filter(function ($assignment) use ($previousTaskCode) {
  316.                     /* @var Assignment $assignment */
  317.                     return \in_array($assignment->getTask()->getCode(), $previousTaskCode, true);
  318.                 });
  320.                 foreach ($predecessors as $predecessor) {
  321.                     $assignment->addPredecessor($predecessor);
  322.                 }
  323.             }
  325.             if (Task::FINISH_TASK === $assignment->getTask()->getCode()) {
  326.                 $assignment->setState(Assignment::STATE_FINISHED);
  327.                 $assignment->setDeadline(new \DateTimeImmutable());
  328.                 $assignment->setWaitingAt(new \DateTimeImmutable());
  329.                 $assignment->deactivate();
  330.                 $assignment->setFinishedAt(new \DateTimeImmutable());
  331.                 $order->finish();
  332.             }
  333.             
  334.             #TODO ASSIGNEE DESIGN
  335.             if (Task::FIX_DESIGN === $assignment->getTask()->getCode()) {
  336.                 $order = $assignment->getOrder();
  337.                 
  338.                 $lastAssignment = null;
  340.                 foreach ($order->getAssignments() as $oldAssignment) {
  341.                     $task = $oldAssignment->getTask()->getCode();
  343.                     if(Task::START_DESIGN === $task){
  344.                         $lastAssignment = $oldAssignment;
  345.                     }
  347.                     if (Task::FIX_DESIGN === $task) {
  348.                         $finishedAt = $oldAssignment->getFinishedAt();
  349.                         if ($finishedAt !== null  && $finishedAt > $lastAssignment->getFinishedAt()) {
  350.                                 $lastAssignment = $oldAssignment;
  351.                         }
  352.                     }
  353.                     
  354.                 }
  355.                 
  356.                 if ($lastAssignment !== null) {
  357.                     $assignment->assignTo($lastAssignment->getAssignee());
  358.                 }
  359.             }
  361.             if (Task::FIX_DESIGN_CUS === $assignment->getTask()->getCode()) {
  362.                 $order = $assignment->getOrder();
  364.                 foreach ($order->getAssignments() as $oldAssignment) {
  365.                     $task = $oldAssignment->getTask()->getCode();
  366.                     if (Task::START_DESIGN_CUS === $task) {
  367.                         $assignment->assignTo($oldAssignment->getAssignee());
  368.                     }
  369.                 }
  370.             }
  372.             $order->addAssignment($assignment);
  373.         } catch (\Exception $e) {
  374.         }
  375.     }
  377.     private function addLoopTask(Assignment $assignment, Task $taskReplacement)
  378.     {
  379.         $previousTaskCode = [$assignment->getTask()->getCode()];
  380.         $this->addTask($assignment, $taskReplacement, $previousTaskCode);
  381.     }
  383.     private function sortAssignment(Assignment $assignment, $taskCode)
  384.     {
  385.         /** @var array $assignmentLast */
  386.         $assignmentLast = $this->assignmentRepository->findLastPriority($taskCode);
  387.         $sort = 0;
  388.         if ($assignment->getOrder()->getIsNow()) {
  389.             $assignments = $this->assignmentRepository->assignmentFindNowTask([$taskCode]);
  391.             if (\count($assignments) > 0) {
  392.                 $sort += $assignments[0]->getSort() ?? 0;
  393.                 if (\count($assignmentLast) > 0 && $assignmentLast[0]->getSort() === $assignments[0]->getSort()) {
  394.                     $sort += self::STEP_HALF_PART;
  395.                 } else {
  396.                     $sort += self::STEP_PRIORITY;
  397.                 }
  398.             } else {
  399.                 $assignments = $this->assignmentRepository->assignmentAssignedByTask([$taskCode]);
  400.                 $sort = \count($assignments) > 0 ? ($assignments[0]->getSort() ?? 1) : 1 - self::STEP_HALF_PART;
  401.             }
  402.         } else {
  403.             $lastPriority = \count($assignmentLast) > 0 ? ($assignmentLast[0]->getSort() ?? 1) : 1;
  405.             if ($lastPriority > 0 && $lastPriority / floor($lastPriority) > 1) {
  406.                 $sort = ceil($lastPriority);
  407.             } else {
  408.                 $sort = $lastPriority + self::STEP_PRIORITY;
  409.             }
  410.         }
  412.         $assignment->setSort($sort);
  413.     }
  415.     private function addEventFinish(Assignment $assignment)
  416.     {
  417.         $taskDesign = [Task::START_DESIGN,
  418.                         Task::START_DESIGN_CUS,
  419.                         Task::FIX_DESIGN,
  420.                         Task::FIX_DESIGN_CUS,
  421.             ];
  422.             $orderTimeLine = $assignment->getOrder()->getOrderTimeLine();
  423.             if($orderTimeLine === null){
  424.                 $orderTimeLine  = new OrderTimeLine();
  425.             }
  426.             $assignment->getOrder()->setOrderTimeLine($orderTimeLine);
  427.             
  428.         if (\in_array($assignment->getTask()->getCode(), $taskDesign, true)) {
  429.             if(\in_array($assignment->getTask()->getCode(), [Task::START_DESIGN,Task::START_DESIGN_CUS], true)){
  430.                 $orderTimeLine->setStartDesign(new DateTimeImmutable());
  431.             }
  432.             $this->messageBus->dispatch(new FinishDesignSendTelegram($assignment));
  433.             $notification = 
  434.             (new Notification())
  435.             ->setData([
  436.                 'content' => 'Đơn hàng đã hoàn tất '.$assignment->getTask()->getName(),
  437.                 'deep_link' => 'https://amac.ctasolution.com/assignment?search='.$assignment->getOrder()->getId()
  438.             ])
  439.             ->setName('Cập nhật công việc đơn hàng '.$assignment->getOrder()->getId())
  440.             ->setType('maket')
  441.             ->setUser($assignment->getOrder()->getCreator())
  442.             ;
  444.             $this->entityManager->persist($notification);
  445.             $this->entityManager->flush();
  447.             $this->messageBus->dispatch(new MessageNotification($notification));
  448.            
  449.         }
  450.         else if(\in_array($assignment->getTask()->getCode(), ['thu_coc','thu_coc_cus'], true)){
  451.             $orderTimeLine->setDepositCompletionTime(new DateTimeImmutable());
  452.         }
  453.         else if (\in_array($assignment->getTask()->getCode(), ['kiem_thanh_pham'], true)) {
  455.             $orderTimeLine->setQualityAssuranceCompleteAt(new DateTimeImmutable());
  457.             $notification = 
  458.             (new Notification())
  459.             ->setData([
  460.                 'content' => 'Đơn hàng đã hoàn tất '.$assignment->getTask()->getName(),
  461.                 'deep_link' => 'https://amac.ctasolution.com/assignment?search='.$assignment->getOrder()->getId()
  462.             ])
  463.             ->setName('Cập nhật công việc đơn hàng '.$assignment->getOrder()->getId())
  464.             ->setType('kiem_thanh_pham')
  465.             ->setUser($assignment->getOrder()->getCreator())
  466.             ;
  467.             
  468.             $changeStatusOrderDelivery = new ChangeStatusOrderDelivery($this->entityManager);
  469.             $changeStatusOrderDelivery->change($assignment->getOrder());
  470.             
  471.             // $autoCreateReceipt = new AutoCreateReceipt($this->entityManager);
  472.             // $autoCreateReceipt->addReceipt($assignment->getOrder());
  473.             $this->entityManager->persist($notification);
  474.             $this->entityManager->flush();
  475.             $this->messageBus->dispatch(new MessageNotification($notification));
  476.             $this->messageBus->dispatch(new UpdateRelationOrderProductMessage($assignment->getOrder()->getId()));
  477.             $this->messageBus->dispatch(new FinishProductOnProductionMessage($assignment->getOrder()->getId()));
  478.            
  479.         }else if(\in_array($assignment->getTask()->getCode(), ['hoan_tat'], true)){
  480.             $orderTimeLine->setFinishedOrderAt(new DateTimeImmutable());
  481.             $this->entityManager->flush();
  482.         }
  483.     }
  484. }