src/Controller/NotificationController.php line 921

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\Routing\Annotation\Route;
  8. use App\Entity\Menu;
  9. use App\Entity\User;
  10. use App\Entity\UserToken;
  11. use App\Entity\NotificationTokens;
  12. use App\Entity\Notification;
  13. use App\Entity\MassiveNotification;
  14. use Symfony\Component\HttpFoundation\JsonResponse;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
  18. use App\Service\AppApiService;
  19. use App\Service\FirebaseService;
  20. use App\Service\NotificationService;
  21. use App\Entity\AppPersonalAccount;
  22. use App\Entity\MediaObject;
  23. use App\Entity\AppCounterReading;
  24. use App\Entity\DataReception;
  25. use App\Entity\Accounts;
  26. use App\Entity\ServiceOrderHistory;
  27. use Symfony\Component\HttpKernel\KernelInterface; 
  28. use Psr\Log\LoggerInterface;
  29. use Sentry;
  30. use App\Repository\NotificationRepository;
  32. use App\Message\NotificationMessage;
  33. use Symfony\Component\Messenger\MessageBusInterface;
  34. use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpStamp;
  36. use Symfony\Component\Messenger\Stamp\SentStamp;
  37. use Symfony\Component\Messenger\Exception\TransportExceptionInterface;
  39. use Symfony\Component\Security\Core\Security;
  50. class NotificationController extends AbstractController
  51. {
  52.     public $datetime;
  53.     public $entityManager;
  54.     public $passwordEncoder;
  55.     public $appApiService;
  56.     public $firebaseService;
  57.     public $notificationService;
  58.     public $notifications;
  59.     private $kernel;
  60.     private LoggerInterface $logger;
  61.     private $bus;
  62.     private Security $security;
  64.     public function __construct( 
  65.         ?\DateTimeInterface $datetime, 
  66.         EntityManagerInterface $entityManager, 
  67.         AppApiService $appApiService, 
  68.         KernelInterface $kernel, 
  69.         FirebaseService $firebaseService, 
  70.         NotificationService $notificationService, 
  71.         LoggerInterface $logger,  
  72.         NotificationRepository $notifications,
  73.         MessageBusInterface $bus,
  74.         Security $security
  75.     ){
  76.         $this->datetime = $datetime;
  77.         $this->entityManager = $entityManager;
  78.         $this->appApiService = $appApiService;
  79.         $this->firebaseService = $firebaseService;
  80.         $this->notificationService = $notificationService;
  81.         $this->kernel = $kernel;
  82.         $this->logger = $logger;
  83.         $this->notifications = $notifications;
  84.         $this->bus = $bus;
  85.         $this->security = $security;
  86.     }
  88.     public function valid($requestFilds, $requiredFilds){
  89.         $errors = '';
  90.         foreach($requiredFilds as $f){
  91.             if(!isset($requestFilds[$f]))
  92.                 $errors .= " $f"; 
  93.         }
  95.         return $errors;
  96.     }
  97.     
  98.     private function customAuth($request){
  99.         $validUser = 'loe';
  100.         $validPassword = 'GE2666Mh4maRa79iMs5igRPD';
  102.         $login = $request->server->get('PHP_AUTH_USER');
  103.         $password = $request->server->get('PHP_AUTH_PW');
  104.         if ($login !== $validUser || $password !== $validPassword) {
  105.             return false;
  106.         }
  108.         return true;
  109.     }
  111.     #[Route('/api/create-notfication', name: 'create_notfication', methods: ['POST'])]
  112.     public function create_notfication(Request $request)
  113.     {
  115.         
  117.         if (!$this->customAuth($request)) {
  118.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  119.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  120.             ]);
  121.         }
  125.         $data = json_decode($request->getContent(), true);
  126.         
  127.         file_put_contents('/var/www/symfony_docker/var/log/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  129.         $valid = $this->valid( $data, ['user', 'title', 'body'] );
  130.         if( empty($valid) ){
  131.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  132.             if($find){
  133.                     $notification = new Notification();
  134.                     $notification->setUsers($find);
  135.                     $notification->setTitle( $data['title']);
  136.                     $notification->setBody( $data['body']);
  138.                     if(!empty($data['type']))
  139.                         $notification->setType( $data['type']);
  140.                     else
  141.                         $notification->setType('text');
  143.                     $notification->setDateEntered( new \DateTime() );
  144.                     $notification->setStatus('new');
  146.                     $this->entityManager->persist($notification);
  147.                     $this->entityManager->flush();
  148.                     $rez = ['rez' => true, 'id' => $notification->getId()];
  149.                  
  150.                 // }else{
  151.                 //     $rez = ['registered' => false, $res];
  152.                 // }
  153.             }else{
  154.                 $rez = ['rez' => false, 'error' => "Користувача не знайдено"];
  155.             }
  157.         }else{
  158.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  159.         }
  160.     
  161.         $response = new JsonResponse();
  162.         $response->setData($rez);
  164.         return $response;
  165.     }
  167.     #[Route('/api/send-notfication', name: 'send_notfication', methods: ['GET'])]
  168.     public function send_notfication(Request $request)
  169.     {
  170.         $send = 0;
  171.         $err = 0;
  172.         
  173.         $notifications = $this->entityManager->getRepository(Notification::class)->findBy(['status' => 'new']);
  174.         
  175.         if($notifications){
  176.                 file_put_contents('/var/www/symfony_docker/var/log/notification.log',  "NOTIFICATIONS ************************ " .  date('Y-m-d H:i:s') . "\n", FILE_APPEND);
  177.                 // Витягуємо всі ID
  178.                     $notificationIds = array_map(fn($n) => $n->getId(), $notifications);
  180.                     // Масове оновлення статусу та дати
  181.                     $this->entityManager->createQuery(
  182.                         'UPDATE App\Entity\Notification n
  183.                         SET n.status = :newStatus, 
  184.                             n.dateSend = :now 
  185.                         WHERE n.id IN (:ids)'
  186.                     )
  187.                     ->setParameter('newStatus', 'in_progress')
  188.                     ->setParameter('now', new \DateTime())
  189.                     ->setParameter('ids', $notificationIds)
  190.                     ->execute();
  192.                     // file_put_contents('/var/www/symfony_docker/var/log/errorrrrrr.log',  "2222222222" .  date('H:i:s') . "\n", FILE_APPEND);
  193.                     // Тепер можна знову вибрати тільки оновлені
  194.                     // $notifications = $this->entityManager
  195.                     // ->getRepository(Notification::class)
  196.                     // ->findBy(['id' => $notificationIds]);
  197.                     
  198.                 foreach($notifications as $notification){
  199.                     $send = 0;
  200.                     $user = $notification->getUsers();
  201.                     $tokensArr = [];
  202.                     if($user){
  203.                         file_put_contents('/var/www/symfony_docker/var/log/notification.log',  "id:" . $user->getId() . " phone:" . $user->getUsername() .  " notification:" . $notification->getId() . "\n", FILE_APPEND);
  205.                         $tokens = $user->getUserTokens();
  206.                         if(!empty($tokens) AND count($tokens) > 0){
  207.                             
  208.                         }else{
  209.                             $device_id = $user->getDeviceId();
  210.                             $tokens = $this->entityManager->getRepository(UserToken::class)->findBy(['device_id' => $device_id, 'active' => true]);
  212.                         }
  213.                         $search_dublicate_tokens = [];
  214.                         foreach($tokens as $token){
  215.                             if(!$token->isActive())
  216.                                 continue;
  218.                             // if(!isset($search_dublicate_tokens[$token->getTokenFcm()]))
  219.                             //     $search_dublicate_tokens[$token->getTokenFcm()] = true;
  220.                             // else
  221.                             //     continue;
  223.                             if(in_array($token->getTokenFcm(), $tokensArr)){
  224.                                 $token->setDateModified( new \DateTime() );
  225.                                 $token->setErrorDescription( "Дублюючий ключ" );
  226.                                 $token->setActive(false);
  227.                                 
  228.                                 $this->entityManager->persist($token);
  229.                                 // $this->entityManager->persist($notification);
  230.                                 $this->entityManager->flush();
  231.                                 continue;
  232.                             }
  234.                             $tokensArr[] = $token->getTokenFcm();
  236.                             $data = [
  237.                                 'id' => $notification->getId(),
  238.                                 'token' => $token->getTokenFcm(),
  239.                                 'title' => $notification->getTitle(),
  240.                                 'body' => $notification->getBody(),
  241.                                 'type' => $notification->getType(),
  242.                             ];
  243.                             // file_put_contents('/var/www/symfony_docker/var/log/notification.log',  print_r($data, true) . "st - " .  date('H:i:s') . "\n", FILE_APPEND);
  244.                             $resultJson = $this->firebaseService->sendCurl($data);
  245.                             // file_put_contents('/var/www/symfony_docker/var/log/notification.log',   $resultJson  . "\n", FILE_APPEND);
  246.                             // file_put_contents('/var/www/symfony_docker/var/log/errorrrrrr.log',   "   - " . date('H:i:s') . "\n", FILE_APPEND);
  248.                             $notification->setDateSend( new \DateTime() );
  250.                             $result = json_decode($resultJson, true);
  252.                             if(!empty( $result['res'] )){
  253.                                 $send = 1;
  254.                                 $notification->setStatus('send');
  255.                                 $send++;
  256.                             }elseif(!empty( $result['err'] )){
  257.                                 $send = 2;
  258.                                 // $token->setActive(false);
  259.                                 $notification->setStatus('error');
  260.                                 $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') . $token->getTokenFcm() . "\n" . $resultJson);
  261.                                 $err++;
  262.                                 if($result['err'] == 'Requested entity was not found.' OR $result['err'] == 'The registration token is not a valid FCM registration token'){
  263.                                     $token->setDateModified( new \DateTime() );
  264.                                     $token->setErrorDescription( $result['err'] );
  265.                                     $token->setActive(false);
  266.                                 }
  267.                             }else{
  268.                                 $send = 3;
  269.                                 // $token->setActive(false);
  270.                                 $notification->setStatus('error');
  271.                                 $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') . $token->getTokenFcm() . "\n" . $resultJson);
  272.                                 $err++;
  273.                             }
  274.                             $this->entityManager->persist($token);
  275.                             $this->entityManager->persist($notification);
  276.                            
  279.                         }
  280.                         
  282.                     }
  283.                     /** Якщо ключа нема */
  284.                     if($send == 0){
  285.                         $notification->setStatus('not_token');
  286.                         $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') .  " Ключ не знайдено \n");
  287.                         $this->entityManager->persist($notification);
  288.                     }
  289.                     $this->entityManager->flush();
  290.                 }
  291.                 file_put_contents('/var/www/symfony_docker/var/log/notification.log',  "***********END************* " .  date('H:i:s') . "\n", FILE_APPEND);
  292.             }else{
  293.                 $rez = ['rez' => false, 'error' => "Незнайдено нових сповіщень!"];
  294.             }
  295.         $response = new JsonResponse();
  296.         $response->setData(['send' => $send, 'err' => $err]);
  297.         return $response;
  298.     }
  300.     #[Route('/api/create-notfication-actions', name: 'create_notfication_account', methods: ['POST'])]
  301.     public function create_notfication_account(Request $request)
  302.     {
  303.         $user = $this->security->getUser();
  306.         if(!$user OR !in_array('ROLE_ADMIN', $user->getRoles()) ){
  307.             if (!$this->customAuth($request) ) {
  308.                 return new JsonResponse(['message' => 'Unauthorized'], 401, [
  309.                     'WWW-Authenticate' => 'Basic realm="API Access"',
  310.                 ]);
  311.             }
  312.         }
  313.         
  314.   
  315.         $data = json_decode($request->getContent(), true);
  316.         
  317.         $send = [];
  318.         $err = '';
  319.         $valid = $this->valid( $data, ['sender', 'msg-data'] );
  320.         if( empty($valid) ){
  321.             // $title = $data['msg-data']['title'];
  322.             if(isset($data['msg-data']['receivers']) OR isset($data['msg-data']['content'])){
  323.                 
  324.                 switch ($data['msg-type']) {
  325.                     case 'from-ns':
  326.                         $send = $this->notificationService->fromNs($data);
  327.                         break;
  328.                     case 'number-phone':
  329.                         $send = $this->notificationService->numberPhone($data);
  330.                         break;
  331.                     case 'notification-yur':
  332.                         $send = $this->notificationService->notificationYur($data);
  333.                         break;
  334.                     case 'notification-all':
  335.                         $send = $this->notificationService->notificationAll($data);
  336.                         break;
  337.                 
  338.                 }
  341.                 $rez = ['rez' => true, 'send' => $send , 'error' => ""];
  342.             }else{
  344.                 $rez = ['rez' => false, 'error' => "Не задано поля receivers або content"];
  345.             }
  346.         }else{
  347.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  348.         }
  351.         $response = new JsonResponse();
  352.         $response->setData($rez);
  354.         return $response;
  355.     }
  358.     #[Route('/api/create-data-reception', name: 'create_notfication_data_reception', methods: ['POST'])]
  359.     public function create_notfication_data_reception(Request $request)
  360.     {
  363.         if (!$this->customAuth($request)) {
  364.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  365.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  366.             ]);
  367.         }
  371.         $data = json_decode($request->getContent(), true);
  372.         // file_put_contents('/var/www/symfony_docker/var/log/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  374.         $valid = $this->valid( $data, ['method', 'data'] );
  375.         if( empty($valid) ){
  376.             
  377.             $DataReception = new DataReception();
  378.             $DataReception->setType( $data['method']);
  379.             $DataReception->setData( $data['data']);
  382.             $DataReception->setDateEntered( new \DateTime() );
  383.             $DataReception->setStatus('new');
  385.             $this->entityManager->persist($DataReception);
  386.             $this->entityManager->flush();
  387.             $rez = ['rez' => true, 'id' => $DataReception->getId()];
  388.                  
  389.         }else{
  390.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  391.         }
  392.     
  393.         $response = new JsonResponse();
  394.         $response->setData($rez);
  396.         return $response;
  397.     }
  401.     public function updateStatus($inf, $name='statusPlanning', $status = 'planned'){
  402.         $query = $this->entityManager->createQuery(
  403.             'UPDATE App\Entity\Accounts d 
  404.              SET d.'.$name.' = :new_status 
  405.              WHERE d.eic IN (:ids)'
  406.         );
  407.         $query->setParameter('new_status', $status);
  408.         $query->setParameter('ids', $inf); // Масив ID
  409.         $query->execute();
  410.     }
  412.     public function updateClearStatusPlan(){
  413.         $query = $this->entityManager->createQuery(
  414.             'UPDATE App\Entity\Accounts d SET d.statusPlanning = :new_status'
  415.         );
  416.         $query->setParameter('new_status', 'not_pllaned');
  417.        
  418.         $query->execute();
  419.         $this->entityManager->clear();
  420.     }
  422.     #[Route('/cron-get-planned', name: 'cron_get_pllanned', methods: ['GET'])]
  423.     public function cron_get_pllanned(Request $request)
  424.     {
  425.         /** Дивлюся чи є планові на сьогодні */
  426.         $qb = $this->entityManager->createQueryBuilder();
  428.         $qb->select('d.id', 'd.dateEntered', 'd.type', 'd.status')
  429.         ->from(DataReception::class, 'd')
  430.         ->where('d.dateEntered >= :start')
  431.         ->andWhere('d.dateEntered < :end')
  432.         ->setParameter('start', (new \DateTime('today'))->setTime(0, 0, 0))
  433.         ->setParameter('end', (new \DateTime('today'))->setTime(23, 59, 59));
  435.         $result = $qb->getQuery()->getArrayResult();
  436.         /** Якщо плнові на сьогодні відсутні тоді оновлюю всі записи */
  437.         if(count($result) == 0)
  438.             $this->updateClearStatusPlan();
  439.         
  440.         /** Вибираю нові планові дані */
  441.         $DataReception = $this->entityManager->getRepository(DataReception::class)->findBy(['type' => 'planned', 'status' => 'new']);
  442.         /** Якщо відсутні нові дані тоді вихід */
  443.         if(empty($DataReception) AND count($DataReception) == 0)
  444.             die('No data');
  446.         /** Очищаю всі планові статуси щоб задати нові*/
  447.         $this->updateClearStatusPlan();
  450.         $eic = [];
  451.         foreach($DataReception as $data){
  452.             
  453.             $infos = json_decode($data->getData(), true);
  454.             
  455.             if(!is_array($infos))
  456.                 continue;
  458.             foreach($infos as $acc_id =>  $inf){
  459.                
  460.                 if(count($inf) > 0)
  461.                     array_push($eic, $inf[0]);
  463.                 if(count($eic) == 500){
  464.                     $this->updateStatus($eic);
  465.                     $eic = [];
  466.                 }
  467.             }
  468.             if(count($eic) > 0)
  469.                 $this->updateStatus($eic);
  471.             // $this->entityManager->clear();
  473.             $data->setStatus('complate');
  474.             $this->entityManager->persist($data);
  475.             $this->entityManager->flush();
  476.             // print_r($infos);
  477.         }
  479.         echo count($DataReception); die;
  480.     }
  483.     #[Route('/cron-get-planned-status', name: 'cron_get_pllanned_status', methods: ['GET'])]
  484.     public function cron_get_pllanned_status(Request $request)
  485.     {
  486.         // $type = $request->query->get('type');
  487.         // $status = $request->query->get('status');
  488.         $query = $this->entityManager->createQuery(
  489.             'UPDATE App\Entity\Accounts d SET d.statusLight = :new_status'
  490.         );
  491.         $query->setParameter('new_status', 'enabled');
  492.         // disabled
  493.         // $query->setParameter('old_status', 'new');
  494.         // echo '<pre>';
  495.         $query->execute();
  496.         $this->entityManager->clear();
  497.         $DataReception = $this->entityManager->getRepository(DataReception::class)->findBy(['type' => 'all_acounts_light_data', 'status' => 'new']);
  498.         $eic = [];
  499.         foreach($DataReception as $data){
  501.             $infos = json_decode($data->getData(), true);
  502.             foreach($infos as $acc_id =>  $inf){
  503.                 $code = array_keys($inf);
  504.                 print_r($code[0]);
  505.                 var_dump($inf[$code[0]]);
  506.                 print_r($eic);
  507.                 echo "<br>";
  508.                 echo "<br>";
  509.                 echo "<br>";
  510.                 if(count($inf) > 0)
  511.                     if($inf[$code[0]]){
  512.                         array_push($eic, $code[0]);
  513.                     }
  515.                 if(count($eic) == 500){
  516.                     $this->updateStatus($eic, 'statusLight', 'disabled');
  517.                     $eic = [];
  518.                 }
  519.             }
  520.             if(count($eic) > 0)
  521.                 $this->updateStatus($eic, 'statusLight', 'disabled');
  523.             
  524.             $data->setStatus('complate');
  525.             $this->entityManager->persist($data);
  526.             $this->entityManager->flush();
  527.             // print_r($infos);
  528.         }
  530.         echo count($DataReception); die;
  531.     }
  534.     #[Route('/api/get-account-all-data', name: 'get_account_all_data', methods: ['GET'])]
  535.     public function get_account_all_data(Request $request):Response
  536.     {   
  537.         set_time_limit(0);
  539.         // echo '<pre>';
  540.         $i = 0;
  541.         $AppPersonalAccount = $this->entityManager->getRepository(AppPersonalAccount::class)->findBy(['counter' => null]);
  542.         foreach($AppPersonalAccount as $account){
  543.             // if(!empty( $account->getEic() ))
  544.             //     continue;
  545.             $i++;
  546.             $data = [
  547.                 'account' => trim( $account->getNumber() )
  548.             ];
  549.             // echo $account->getId() . "<br>";
  550.             // echo $account->getNumber() . "<br>";
  551.             $res = json_decode( $this->appApiService->account_all_data($data) , true );  
  552.             
  553.             // print_r( $res ); 
  554.             
  555.             // if($i > 5)
  556.             //     die;
  557.             if(isset($res['rez']) AND $res['rez'] == 1 AND isset($res['data'][0])){
  558.                 file_put_contents('/var/www/symfony_docker/var/log/errorrrrrr.log',   print_r($res, true)  . "\n", FILE_APPEND);
  559.                 $account->setEic($res['data'][0]['eic_kod']);  
  560.                 $account->setCounter($res['data'][0]['counter']);  
  561.                 
  562.                 $this->entityManager->persist($account);
  563.                 $this->entityManager->flush();
  565.             }
  566.         }
  568.         return new Response('1');
  569.         
  570.     }
  573.     /** Додавання id crm LOE */
  574.     #[Route('/api/update-service-id', name: 'update_service_id', methods: ['POST'])]
  575.     public function update_service_id(Request $request)
  576.     {
  579.         if (!$this->customAuth($request)) {
  580.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  581.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  582.             ]);
  583.         }
  587.         $data = json_decode($request->getContent(), true);
  588.         // file_put_contents('/var/www/symfony_docker/var/log/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  590.         $valid = $this->valid( $data, ['id', 'id_crm'] );
  591.         if( empty($valid) ){
  592.             $ServiceOrderHistory = false;
  593.             if(is_int($data['id']))
  594.                 $ServiceOrderHistory = $this->entityManager->getRepository(ServiceOrderHistory::class)->findOneBy(['id' => $data['id']]);
  595.             if(!$ServiceOrderHistory AND !empty($data['id_crm']))
  596.                  $ServiceOrderHistory = $this->entityManager->getRepository(ServiceOrderHistory::class)->findOneBy(['idCrm' => $data['id_crm']]);
  598.             if($ServiceOrderHistory){
  599.                 $ServiceOrderHistory->setIdCrm( $data['id_crm']);
  600.                 if(!empty( $data['status'] ))
  601.                     $ServiceOrderHistory->setStatus(  $data['status'] );
  602.                 else
  603.                     $ServiceOrderHistory->setStatus( 'in_process' );
  604.                 if(!empty( $data['description'] ))
  605.                     $ServiceOrderHistory->setDescription(  $data['description'] );
  607.                 if(!empty( $data['message'] ))
  608.                     $ServiceOrderHistory->setMessage(  $data['message'] );
  609.     
  610.                 $ServiceOrderHistory->setDateModified( new \DateTime() );
  611.                 // $ServiceOrderHistory->setStatus('new');
  612.     
  613.                 $this->entityManager->persist($ServiceOrderHistory);
  614.                 $this->entityManager->flush();
  615.                 $rez = ['rez' => true, 'id' => $ServiceOrderHistory->getId()];
  616.             }else{
  617.                 $rez = ['false' => false, 'error' => "Заявку не знайдено id не вірне"];
  618.             }
  620.                  
  621.         }else{
  622.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  623.         }
  624.     
  625.         $response = new JsonResponse();
  626.         $response->setData($rez);
  628.         return $response;
  629.     }
  631.     /** Додавання id crm LOE */
  632.     #[Route('/api/get-service-id', name: 'get_service_id', methods: ['GET', 'POST'])]
  633.     public function get_service_id(Request $request)
  634.     {
  637.         if (!$this->customAuth($request)) {
  638.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  639.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  640.             ]);
  641.         }
  642.         $arr = [];
  644.         $ServiceOrderHistory = $this->entityManager->getRepository(ServiceOrderHistory::class)->findBy(['status' => 'in_process']);
  645.         
  646.         foreach($ServiceOrderHistory as $service){
  647.             $arr[] = [
  648.                 'id' => $service->getId(),
  649.                 'id_crm' => $service->getIdCrm(),
  650.             ];
  651.         }
  652.         
  653.         
  654.         $rez = ['rez' => true, 'data' => $arr];
  655.     
  656.         $response = new JsonResponse();
  657.         $response->setData($rez);
  659.         return $response;
  660.     }
  663.     /** Історія заявок з сторонніх систем */
  664.     #[Route('/api/create-order-history', name: 'create_order_history', methods: ['POST'])]
  665.     public function create_order_history(Request $request)
  666.     {
  669.         if (!$this->customAuth($request)) {
  670.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  671.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  672.             ]);
  673.         }
  674.         $data = json_decode($request->getContent(), true);
  676.         $valid = $this->valid( $data, ['phone', 'account', 'service_code', 'status', 'id_crm'] );
  677.         if( empty($valid) ){
  678.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['phone' => $data['phone']]);
  679.             if($find){
  680.                 $arr = [];
  681.                 
  682.                 $orderNames = [
  683.                     9 =>  "Встановлення зонного лічильника",
  684.                     10 =>  "Лічильник не працює",
  685.                     21 =>  "Неправильний показ",
  686.                     32 =>  "Зміна власника",
  687.                     35 =>  "Підключення електроустановок замовника після виконання ТУ",
  688.                     63 =>  "Звернення щодо підозри на крадіжку",
  689.                     79 =>  "Заміна автоматичного вимикача, який опломбований ОСР",
  690.                     85 =>  "Відсутність пломб на засобі обліку",
  691.                     86 =>  "Закриття особового рахунку",
  692.                     200 =>  "Попередній запис в електронну чергу",
  693.                 ];
  694.                 $account = false;
  695.                 foreach($find->getAppPersonalAccounts() as $acc){
  696.                     if(trim( $acc->getNumber() ) == $data['account'])
  697.                         $account = $acc;
  698.                 }
  699.                 
  700.                 if(!$account AND count($find->getAppPersonalAccounts()) > 0){
  701.                     $account = $find->getAppPersonalAccounts()[0];
  702.                 }
  704.                 if($account){
  706.                     $ServiceOrderHistory = new ServiceOrderHistory();
  707.                     $ServiceOrderHistory->setName($orderNames[$data['service_code']]);
  708.                     $ServiceOrderHistory->setDateEntered( new \DateTime() );
  709.                     $ServiceOrderHistory->setType($data['service_code']);
  710.                     $ServiceOrderHistory->setStatus('new');
  711.                     $ServiceOrderHistory->setPersonalAccount($account);
  712.                     if(!empty( $data['id_crm'] ))
  713.                         $ServiceOrderHistory->setIdCrm( $data['id_crm']);
  714.                     if(!empty( $data['status'] ))
  715.                         $ServiceOrderHistory->setStatus(  $data['status'] );
  716.                     else
  717.                         $ServiceOrderHistory->setStatus( 'in_process' );
  718.                     if(!empty( $data['description'] ))
  719.                         $ServiceOrderHistory->setDescription(  $data['description'] );
  720.         
  721.                     if($data['service_code'] == 200){
  722.                         $ServiceOrderHistory->setStatus('-100');
  723.                         $ServiceOrderHistory->setDescription('Виконано');
  724.                     }
  726.                     $ServiceOrderHistory->setPersonalAccount($account);
  727.                     $this->entityManager->persist($ServiceOrderHistory);
  728.                     $this->entityManager->flush();
  730.                     $data["id"] = $ServiceOrderHistory->getId();
  731.                     
  732.                     
  733.                     $rez = ['rez' => true, 'data' => [
  734.                         'id' => $ServiceOrderHistory->getId()
  735.                     ]];
  736.                 }else{
  737.                     $rez = ['rezult' => false, 'error' => "Нема жодного особового рахунку"];   
  738.                 }
  740.             }else{
  741.                 $rez = ['rezult' => false, 'error' => "Користувача не знайдено!"];   
  742.             }
  743.         
  744.         }else{
  745.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  746.         }
  747.     
  748.         $response = new JsonResponse();
  749.         $response->setData($rez);
  751.         return $response;
  752.     }
  757.     #[Route('/notifications/health', name: 'notifications_health', methods: ['GET'])]
  758.     public function notifications_health(): JsonResponse
  759.     {
  760.         $now = new \DateTimeImmutable('now');
  762.         // За поточний день (з 00:00 локального часу сервера)
  763.         $startOfDay = $now->setTime(0, 0, 0);
  765.         // За останню годину
  766.         $lastHour = $now->modify('-1 hour');
  768.         $dayAgg   = $this->notifications->getTotalsFrom($startOfDay);
  769.         $hourAgg  = $this->notifications->getTotalsFrom($lastHour);
  772.         $makeCheck = static function (int $total, int $errors): array {
  773.             $errorRate = $total > 0 ? $errors / $total : 0.0;
  775.             return [
  776.                 'total'      => $total,
  777.                 'errors'     => $errors,
  778.                 'errorRate'  => round($errorRate, 4),          // 0.3142 => 31.42%
  779.                 'over10'     => $total > 10,
  780.                 'over30pct'  => $errorRate > 0.60,
  781.                 'alert'      => ($total > 10) && ($errorRate > 0.30),
  782.             ];
  783.         };
  786.         $h = $makeCheck($hourAgg['total'], $hourAgg['errors']);
  787.         $d = $makeCheck($hourAgg['total'], $hourAgg['errors']);
  789.         // echo $_ENV['WHATSAPP_CHAT_ID']; die;
  790.         if($h['total'] > 10 AND $h['over30pct'] ){
  791.             $time = date('Y-m-d H:i:s');
  792.             $from = 'instance98373';
  793.             // відправка повідомлення
  794.             $ch = curl_init();
  795.             curl_setopt($ch, CURLOPT_URL, 'https://bot.inneti.com/whatsapp_group/loe_report_2.php');
  796.             curl_setopt($ch, CURLOPT_TIMEOUT, 120);
  797.             curl_setopt($ch, CURLOPT_BUFFERSIZE, 128);
  798.             curl_setopt(
  799.                     $ch,
  800.                     CURLOPT_POSTFIELDS,
  801.                     [
  802.                             "msg_text"                  => 'Увага! В базі знайдено більше 30% ненадісланих сповіщень за останню годину! ('.$h['errors'].' з '.$h['total'].')',
  803.                             "from"                      => $from,
  804.                             "whatsapp_chat_id"          => $_ENV['WHATSAPP_CHAT_ID'],
  805.                             "token"                     =>"pg9n1fef6pkesrsl",
  806.                             "time"                      => $time,
  807.                             "hash"                      => hash_hmac('md5', "$from;$time;", "$time;asdINNasd;$time"),
  808.                             'mm_type'                   => 'text',
  809.                     ]
  810.             );
  811.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  812.             curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  813.             curl_setopt($ch, CURLOPT_PROXY, "");
  814.             $answer = curl_exec($ch);
  815.             $error = curl_error($ch);
  816.             curl_close($ch);
  817.         }
  820.         $result = [
  821.             'now'  => $now->format(DATE_ATOM),
  822.             'day'  => $d,
  823.             'hour' => $h,
  824.             'thresholds' => [
  825.                 'minTotal'    => 10,
  826.                 'maxErrorRate'=> 0.30,
  827.                 'errorStatuses'=> ['error','failed','warning'],
  828.             ],
  829.         ];
  831.         return $this->json($result);
  832.     }
  835.     #[Route('/notification/test', name: 'notification_test', methods: ['GET'])]
  836.     public function notification_test(): JsonResponse
  837.     {
  838.         $userIds = [
  839.             // 42,
  840.             // 31,
  841.             // 33,
  842.             // // 34,
  843.             // 35,
  844.             // 37,
  845.             // 38,
  846.         ];
  848.         $h = date('H');
  849.         if($h < 12){
  850.             $t= " Гарного ранку ❤️";
  851.         }elseif($h < 15){
  852.             $t= " Гарного дня ❤️";
  853.         }elseif($h < 22){
  854.             $t= " Гарного вечора ❤️";
  855.         }else{
  856.             $t= " Спите ? 😊😊😊";
  857.         }
  859.         foreach($userIds as $userId){
  860.             
  861.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $userId]);
  863.             if($find){
  864.                 $notification = new Notification();
  865.                 $notification->setUsers($find);
  866.                 $notification->setTitle('Тестове сповіщення!');
  867.                 $notification->setBody( date('Y-m-d H:i:s') . "\n Тестове сповіщення! \n Система розсилки повідомлень працює коректно. \n Якщо ви це читаєте, значить все добре! \n $t");
  869.         
  870.                 $notification->setType('text');
  872.                 $notification->setDateEntered( new \DateTime() );
  873.                 $notification->setStatus('new');
  875.                 $this->entityManager->persist($notification);
  876.                 $this->entityManager->flush();
  877.             }
  878.         }
  880.         return $this->json(['status' => 'ok']);
  881.     }
  884.     #[Route('/notification/test2', name: 'notification_test_t', methods: ['GET'])]
  885.     public function notification_test_t(): JsonResponse
  886.     {
  887.         $userIds = [
  888.             31,
  889.             
  890.         ];
  894.         foreach($userIds as $userId){
  895.             
  896.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $userId]);
  898.             if($find){
  899.                 $notification = new Notification();
  900.                 $notification->setUsers($find);
  901.                 $notification->setTitle('Тестове сповіщення!');
  902.                 $notification->setBody( date('Y-m-d H:i:s') . "\n TEST 3 ");
  904.         
  905.                 $notification->setType('text');
  907.                 $notification->setDateEntered( new \DateTime() );
  908.                 $notification->setStatus('new');
  910.                 $this->entityManager->persist($notification);
  911.                 $this->entityManager->flush();
  912.             }
  913.         }
  915.         return $this->json(['status' => 'ok']);
  916.     }
  918.     /** Додавання сповіщень в чергу з статусом "new" */
  920.     #[Route('/api/add-notification-in-queue', name: 'add_notification_in_queue', methods: ['GET'])]
  921.     public function add_notification_in_queue(Request $request)
  922.     {
  923.         if(file_exists('/var/www/symfony_docker/var/log/notificationCron.log')){
  924.             $logCron = file_get_contents('/var/www/symfony_docker/var/log/notificationCron.log');
  925.             if(!empty( $logCron )){
  926.                 $fileContents = json_decode($logCron, true);
  927.                 $lastRunTime = isset($fileContents['start']) ? strtotime($fileContents['start']) : 0;
  928.                 $currentTime = time();
  929.                 if( $fileContents['cron'] == 'Start' ){
  930.                 
  931.                     // Якщо останній запуск був менше ніж 5 хвилин тому, завершуємо виконання
  932.                     echo "$currentTime - $lastRunTime = " . ($currentTime - $lastRunTime);
  933.                     if (($currentTime - $lastRunTime) > 300) {
  934.                         $logCron =  json_encode([
  935.                             'cron' => 'Stop',
  936.                             'stop' => date('Y-m-d H:i:s'),
  937.                             'info' => 'The cron job was run less than 5 minutes ago. Exiting to prevent overlap.'
  938.                         ]);
  939.                         file_put_contents('/var/www/symfony_docker/var/log/notificationCron.log',  $logCron);
  942.                     }
  943.                     var_dump($logCron);
  944.                     die;
  945.                 }
  946.             }
  947.             
  948.         }
  950.         file_put_contents('/var/www/symfony_docker/var/log/notificationCron.log',  json_encode([
  951.             'cron' => 'Start',
  952.             'start' => date('Y-m-d H:i:s'),
  953.             'info' => 'Start notification cron'
  954.         ]));
  955.         
  956.         
  957.         // file_put_contents('/var/www/symfony_docker/var/log/notificationCron.log');
  958.         $send = 0;
  959.         $err = 0;
  960.         /** Витягую всі ід сповіщень  */
  962.         
  963.         $notifications = $this->entityManager->createQuery(
  964.                 'SELECT n.id FROM App\Entity\Notification n WHERE n.status = :status'
  965.             )
  966.             ->setParameter('status', 'new')
  967.             ->getScalarResult();    
  968.         $ids = array_map(fn($r) => (int)$r['id'], $notifications);
  969.      
  970.         if($ids AND count($ids) > 0){
  971.             $dateStart = date('Y-m-d H:i:s');
  972.             file_put_contents('/var/www/symfony_docker/var/log/notification.log',  "\n\n\n\nSTART-QUEUE-rabbitmq***************************** " .  $dateStart . "\n", FILE_APPEND);
  973.             file_put_contents('/var/www/symfony_docker/var/log/notification.log',  "new ids - " . implode(',', $ids) . "\n", FILE_APPEND);
  974.             // Масове оновлення статусу та дати
  975.             $this->entityManager->createQuery(
  976.                 'UPDATE App\Entity\Notification n
  977.                 SET n.status = :newStatus, 
  978.                     n.dateSend = :now 
  979.                 WHERE n.id IN (:ids)'
  980.             )
  981.             ->setParameter('newStatus', 'in_progress')
  982.             ->setParameter('now', new \DateTime())
  983.             ->setParameter('ids', $ids)
  984.             ->execute();
  985.                     
  986.             foreach($ids as $id){
  987.                 $send = 0;
  988.                 $priority = 1;
  989.                 file_put_contents('/var/www/symfony_docker/var/log/notification.log', "#{$id} add to rabbitmq - " .  date('H:i:s.u') . "\n", FILE_APPEND);
  991.                 $queued = false;
  992.                 $error  = null;
  994.                 try {
  995.                     $env = $this->bus->dispatch(new NotificationMessage($id, [], 'send-notification', $priority));
  997.                     // Якщо повідомлення надіслано у транспорт — з’являться SentStamp-и
  998.                     $sentStamps = $env->all(SentStamp::class);
  1000.                     if (!empty($sentStamps)) {
  1001.                         $send++;
  1002.                         file_put_contents('/var/www/symfony_docker/var/log/notification.log', "#{$id} rabbitmq-success " .  date('H:i:s.u') . "\n", FILE_APPEND);
  1003.                         $queued = true;
  1004.                         // для логів можна подивитись куди саме:
  1005.                         $targets = array_map(fn(SentStamp $s) => $s->getSenderAlias() ?? $s->getTransportName(), $sentStamps);
  1006.                         file_put_contents('/var/www/symfony_docker/var/log/notification.log',  'Sent to: '.implode(', ', $targets).PHP_EOL, FILE_APPEND);
  1007.                     } else {
  1008.                         $err++;
  1009.                         // це означає, що роутінг не відправив у транспорт (наприклад, sync bus)
  1010.                         $queued = false;
  1011.                         $error  = 'No SentStamp: message was not routed to a transport';
  1012.                         file_put_contents('/var/www/symfony_docker/var/log/notification.log', "#{$id} rabbitmq-error " .  date('H:i:s.u') . " - No SentStamp: message was not routed to a transport\n", FILE_APPEND);
  1013.                     }
  1015.                 } catch (TransportExceptionInterface $e) {
  1016.                     // Помилки транспорту/брокера (у т.ч. коли confirm_publish=true і брокер не підтвердив)
  1017.                     $queued = false;
  1018.                     $error  = $e->getMessage();
  1019.                     $err++;
  1020.                     file_put_contents('/var/www/symfony_docker/var/log/notification.log', "#{$id} rabbitmq-TransportExceptionInterface " .  date('H:i:s.u') . " - " . $e->getMessage() . "\n", FILE_APPEND);
  1021.                 } catch (\Throwable $e) {
  1022.                     // будь-яка інша помилка
  1023.                     $queued = false;
  1024.                     $error  = $e->getMessage();
  1025.                     $err++;
  1026.                     file_put_contents('/var/www/symfony_docker/var/log/notification.log', "#{$id} rabbitmq-Throwable " .  date('H:i:s.u') . " - " . $e->getMessage() . "\n", FILE_APPEND);
  1027.                 }
  1029.             }
  1030.             file_put_contents('/var/www/symfony_docker/var/log/notification.log',  "END-QUEUE-rabbitmq***************************** start-$dateStart  end-" .  date('Y-m-d H:i:s') . "\n", FILE_APPEND);
  1031.             file_put_contents('/var/www/symfony_docker/var/log/notification.log',  "22222222222222222222\n", FILE_APPEND);
  1032.         }else{
  1033.             $rez = ['rez' => false, 'error' => "Незнайдено нових сповіщень!"];
  1034.         }
  1036.         $logCron =  json_encode([
  1037.             'cron' => 'Stop',
  1038.             'stop' => date('Y-m-d H:i:s'),
  1039.             'info' => 'Notification cron complete'
  1040.         ]);
  1041.         file_put_contents('/var/www/symfony_docker/var/log/notificationCron.log',  $logCron);
  1044.         $response = new JsonResponse();
  1045.         $response->setData(['send' => $send, 'err' => $err]);
  1046.         return $response;
  1047.     }
  1050. }