src/Controller/NotificationController.php line 505

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\LogHistoryRequest;
  10. use App\Entity\User;
  11. use App\Entity\UserToken;
  12. use App\Entity\Notification;
  13. use Symfony\Component\HttpFoundation\JsonResponse;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Doctrine\ORM\EntityManagerInterface;
  16. use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
  17. use App\Service\AppApiService;
  18. use App\Entity\AppPersonalAccount;
  19. use App\Entity\MediaObject;
  20. use App\Entity\AppCounterReading;
  21. use App\Entity\DataReception;
  22. use App\Entity\Accounts;
  23. use App\Entity\ServiceOrderHistory;
  24. use Symfony\Component\HttpKernel\KernelInterface; 
  33. class NotificationController extends AbstractController
  34. {
  35.     public $datetime;
  36.     public $entityManager;
  37.     public $passwordEncoder;
  38.     public $appApiService;
  39.     private $kernel;
  41.     public function __construct( ?\DateTimeInterface $datetime, EntityManagerInterface $entityManager, AppApiService $appApiService, KernelInterface $kernel ){
  42.         $this->datetime = $datetime;
  43.         $this->entityManager = $entityManager;
  44.         $this->appApiService = $appApiService;
  45.         $this->kernel = $kernel;
  46.     }
  48.     public function valid($requestFilds, $requiredFilds){
  49.         $errors = '';
  50.         foreach($requiredFilds as $f){
  51.             if(!isset($requestFilds[$f]))
  52.                 $errors .= " $f"; 
  53.         }
  55.         return $errors;
  56.     }
  58.     public function logHistory($id, $method, $data){
  59.         if(!$id){
  60.             $LogHistoryRequest = new LogHistoryRequest();
  61.             $LogHistoryRequest->setMethod($method);
  62.             $LogHistoryRequest->setRequest($data);
  63.             $LogHistoryRequest->setDate(new \DateTime());
  64.             $LogHistoryRequest->setStatus('start');
  65.             $this->entityManager->persist($LogHistoryRequest);
  66.             $this->entityManager->flush();
  68.             return $LogHistoryRequest->getId();
  69.         }else{
  70.             $LogHistoryRequest = $this->entityManager->getRepository(LogHistoryRequest::class)->findOneBy(['id' => $id]);
  71.             if($LogHistoryRequest){
  72.                 $LogHistoryRequest->setStatus('finish');
  73.                 $LogHistoryRequest->setResponseAnswer($data);
  74.                 $this->entityManager->persist($LogHistoryRequest);
  75.                 $this->entityManager->flush();
  76.             }
  77.             return true;
  78.         }
  80.         
  81.     }
  82.     
  83.     private function customAuth($request){
  84.         $validUser = 'loe';
  85.         $validPassword = 'GE2666Mh4maRa79iMs5igRPD';
  87.         $login = $request->server->get('PHP_AUTH_USER');
  88.         $password = $request->server->get('PHP_AUTH_PW');
  89.         if ($login !== $validUser || $password !== $validPassword) {
  90.             return false;
  91.         }
  93.         return true;
  94.     }
  96.     #[Route('/api/create-notfication', name: 'create_notfication', methods: ['POST'])]
  97.     public function create_notfication(Request $request)
  98.     {
  101.         if (!$this->customAuth($request)) {
  102.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  103.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  104.             ]);
  105.         }
  109.         $data = json_decode($request->getContent(), true);
  110.         // $logId = $this->logHistory(false, 'createPersonalAccount', $data);
  111.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  113.         $valid = $this->valid( $data, ['user', 'title', 'body'] );
  114.         if( empty($valid) ){
  115.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  116.             if($find){
  117.                     $notification = new Notification();
  118.                     $notification->setUsers($find);
  119.                     $notification->setTitle( $data['title']);
  120.                     $notification->setBody( $data['body']);
  122.                     if(!empty($data['type']))
  123.                         $notification->setType( $data['type']);
  124.                     else
  125.                         $notification->setType('text');
  127.                     $notification->setDateEntered( new \DateTime() );
  128.                     $notification->setStatus('new');
  130.                     $this->entityManager->persist($notification);
  131.                     $this->entityManager->flush();
  132.                     $rez = ['rez' => true, 'id' => $notification->getId()];
  133.                  
  134.                 // }else{
  135.                 //     $rez = ['registered' => false, $res];
  136.                 // }
  137.             }else{
  138.                 $rez = ['rez' => false, 'error' => "Користувача не знайдено"];
  139.             }
  141.         }else{
  142.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  143.         }
  144.     
  145.         $response = new JsonResponse();
  146.         $response->setData($rez);
  148.         return $response;
  149.     }
  152.     public function sendCurl ($data){
  153.         /**
  154.          * admin
  155.          * w2mWOf5Q0hX8UX6H9h37hZk6RzBtnIBMqEfU173VKIsOmPzgEp
  156.          * if (preg_match('/<[^>]+>/', $html)) {
  157.          */
  159.         $json = json_encode(
  160.             [
  161.                 'token' => $data['token'],
  162.                 // 'notification' => [
  163.                 //     'title' => $data['title'],
  164.                 //     'body' => strip_tags($data['body']),
  165.                 //     // 'type_text' => $data['type'],
  166.                 //     // 'text' => $data['body'],
  167.                 //     // 'text' => "",
  168.                 //     // 'image' => ''
  169.                 // ],
  170.                 'data' => [
  171.                     'title' => $data['title'],
  172.                     'body' => strip_tags( $data['body'] ),
  173.                     'type_text' => (preg_match('/<[^>]+>/', $data['body'] ))? 'html':'text',
  174.                     'text' => $data['body'],
  175.                     // 'text' => "",
  176.                     // 'image' => ''
  177.                 ],
  178.                 'apns' => [
  179.                     'payload' => [
  180.                         'aps' => [
  181.                             'content-available' => 1,                            
  182.                             "alert" => [
  183.                                 'title' => $data['title'],
  184.                                 'body' => strip_tags($data['body']),
  185.                                 // "image": "https://api-app.de-svitlo.com.ua/media/66ea934b9674c_lightbulb_red.png"
  186.                             ],
  188.                         ]
  189.                     ]
  190.                     
  191.                 ],
  192.                 'topic' => '',
  193.                 'condition' => ''
  194.                     
  195.             ]
  196.         );
  197.         // file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "st - " .  date('H:i:s') . "\n", FILE_APPEND);
  198.         // file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  print_r($json, true) . "\n", FILE_APPEND);
  199.         $ch = curl_init();
  200.         curl_setopt($ch, CURLOPT_URL, 'https://dev-firebase-proxy.inneti.net/api/message/notify');
  201.         curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_BASIC);
  202.         curl_setopt($ch, CURLOPT_USERPWD, "admin:w2mWOf5Q0hX8UX6H9h37hZk6RzBtnIBMqEfU173VKIsOmPzgEp");
  203.         curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
  204.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  205.         curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
  206.         curl_setopt($ch, CURLOPT_TIMEOUT, 5);
  207.         curl_setopt(
  208.           $ch,
  209.           CURLOPT_POSTFIELDS,
  210.           $json
  211.         );
  212.         $answer = curl_exec($ch);
  213.         curl_close($ch);
  215.        return $answer; 
  216.     }
  218.     #[Route('/api/send-notfication', name: 'send_notfication', methods: ['GET'])]
  219.     public function send_notfication(Request $request)
  220.     {
  221.         $send = 0;
  222.         $err = 0;
  223.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "************************" .  date('H:i:s') . "\n", FILE_APPEND);
  225.         $notifications = $this->entityManager->getRepository(Notification::class)->findBy(['status' => 'new']);
  226.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "1111111" .  date('H:i:s') . "\n", FILE_APPEND);
  227.             if($notifications){
  228.                     
  229.                 foreach($notifications as $notification){
  230.                     $send = 0;
  231.                     $user = $notification->getUsers();
  232.                     // $tokensArr = [];
  233.                     if($user){
  234.                         $tokens = $user->getUserTokens();
  235.                         if(!empty($tokens) AND count($tokens) > 0){
  236.                             
  237.                         }else{
  238.                             $device_id = $user->getDeviceId();
  239.                             $tokens = $this->entityManager->getRepository(UserToken::class)->findBy(['device_id' => $device_id, 'active' => true]);
  241.                         }
  243.                         foreach($tokens as $token){
  244.                             if(!$token->isActive())
  245.                                 continue;
  247.                             // file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "st - " .  date('H:i:s') . "\n", FILE_APPEND);
  248.                             $resultJson = $this->sendCurl([
  249.                                 'token' => $token->getTokenFcm(),
  250.                                 'title' => $notification->getTitle(),
  251.                                 'body' => $notification->getBody(),
  252.                                 'type' => $notification->getType(),
  253.                             ]);
  254.                             // file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',   $resultJson  . "\n", FILE_APPEND);
  255.                             // file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',   "   - " . date('H:i:s') . "\n", FILE_APPEND);
  257.                             $notification->setDateSend( new \DateTime() );
  259.                             $result = json_decode($resultJson, true);
  261.                             if(!empty( $result['res'] )){
  262.                                 $send = 1;
  263.                                 $notification->setStatus('send');
  264.                                 $send++;
  265.                             }elseif(!empty( $result['err'] )){
  266.                                 $send = 2;
  267.                                 $token->setActive(false);
  268.                                 $notification->setStatus('error');
  269.                                 $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') . $token->getTokenFcm() . "\n" . $resultJson);
  270.                                 $err++;
  271.                             }else{
  272.                                 $send = 3;
  273.                                 $token->setActive(false);
  274.                                 $notification->setStatus('error');
  275.                                 $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') . $token->getTokenFcm() . "\n" . $resultJson);
  276.                                 $err++;
  277.                             }
  278.                             $this->entityManager->persist($token);
  279.                             $this->entityManager->persist($notification);
  280.                             $this->entityManager->flush();
  283.                         }
  284.                         
  286.                     }
  287.                     
  288.                     /** Якщо ключа нема */
  289.                     if($send == 0){
  290.                         $notification->setStatus('not_token');
  291.                         $notification->setError($notification->getError() .  "\n" . date('Y-m-d H:i:s') .  " Ключ не знайдено \n");
  292.                         $this->entityManager->persist($notification);
  293.                         $this->entityManager->flush();
  294.                     }
  295.                     // echo '222'; 
  296.                     // die('1111');
  297.                 }
  299.                     // $this->entityManager->persist($notification);
  300.                     // $this->entityManager->flush();
  301.                     // $rez = ['rez' => true, 'id' => $notification->getId()];
  302.                  
  303.                 // }else{
  304.                 //     $rez = ['registered' => false, $res];
  305.                 // }
  306.             }else{
  307.                 $rez = ['rez' => false, 'error' => "Незнайдено нових сповіщень!"];
  308.             }
  310.    
  311.     
  312.         $response = new JsonResponse();
  313.         $response->setData(['send' => $send, 'err' => $err]);
  314.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "***********END*************" .  date('H:i:s') . "\n", FILE_APPEND);
  315.         return $response;
  316.     }
  318.     #[Route('/api/create-notfication-actions', name: 'create_notfication_account', methods: ['POST'])]
  319.     public function create_notfication_account(Request $request)
  320.     {
  323.         if (!$this->customAuth($request)) {
  324.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  325.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  326.             ]);
  327.         }
  328.         // { "sender": "loe", "msg-type": "from-ns", "msg-data": { "priority": 0, "ns_msg_id": 123, "title": "шапка повідомлення", "receivers": { "account1": "текст повідомлення", "account2": "текст повідомлення", "account3": "текст повідомлення" } } }
  329.         // $arr = [
  330.         //     'sender'     => 'loe',        // від кого прийшло (ЛОЕ, вооканал і т.д.)    
  331.         //     'msg-type'     => 'from-ns',    // будуть інші типи з іншими наборами даних
  332.         //     'msg-data'     => [
  333.         //         'priority' => 0,     // пріоритет (ціле додатнє число типу tinyint)
  334.         //         'ns_msg_id' => 123, // моя ідешка (тип int)
  335.         //         'title' => 'шапка повідомлення',
  336.         //         'receivers' => [ // для даного типу повідомлення це масив, де ключ - номер особового рахунку, значення - текст повідомлення
  337.         //             'account1' => 'текст повідомлення',  
  338.         //             'account2' => 'текст повідомлення',
  339.         //             'account3' => 'текст повідомлення'
  340.         //             // ...
  341.         //         ],
  342.         //     ],
  343.         // ];
  344.       
  346.         // echo json_encode($arr, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT);
  347.         // die;
  348.         $data = json_decode($request->getContent(), true);
  349.         
  350.         // if(isset($data['msg-type']) AND $data['msg-type'] == 'number-phone') 
  351.         //     file_put_contents('/var/www/symfony_docker/public/media/notification-sms.log', date('Y-m-d H:i:s') . ' ' . $request->getContent() . "\n", FILE_APPEND);
  352.         // echo '<pre>';
  353.         // print_r($data);
  354.         // die;
  357.         // $logId = $this->logHistory(false, 'createPersonalAccount', $data);
  358.         // file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  360.         $send = [];
  361.         $err = '';
  362.         $valid = $this->valid( $data, ['sender', 'msg-data'] );
  363.         if( empty($valid) ){
  364.             $title = $data['msg-data']['title'];
  365.             if(isset($data['msg-data']['receivers']) AND count($data['msg-data']['receivers']) > 0){
  366.                 
  367.                 
  368.                 if($data['msg-type'] == 'from-ns'){
  369.                     $i = 0;
  370.                     foreach($data['msg-data']['receivers'] as $number => $receivers){
  371.                         $AccountUser = [];
  372.                         /** Шукаю Всі особові за номером */
  373.                         $findAccounts = $this->entityManager->getRepository(AppPersonalAccount::class)->findBy(['number' => $number]);
  374.                         if($findAccounts){
  375.                             foreach($findAccounts as $account){
  376.                                 $user_id = $account->getOwner()->getId();
  377.                                 if(!isset( $AccountUser[ $user_id]  ))
  378.                                     $AccountUser[$user_id] = [];
  379.     
  380.                                 /** Перевірка якщо в користувача додано декілька однакових особових */
  381.                                 if(!isset( $AccountUser[$user_id][ $number ] )){
  382.                                     $AccountUser[$user_id][ $number ] = true;
  383.                                 
  384.                                     $notification = new Notification();
  385.                                     $notification->setUsers($account->getOwner());
  386.                                     $notification->setTitle( $title );
  387.                                     $notification->setBody($receivers);
  388.     
  389.                                     if(!empty($data['msg-data']['type']))
  390.                                         $notification->setType( $data['msg-data']['type']);
  391.                                     else
  392.                                         $notification->setType('text');
  393.     
  394.                                     $notification->setDateEntered( new \DateTime() );
  395.                                     $notification->setStatus('new');
  396.                                     if(!empty($data['msg-data']['priority']))
  397.                                         $notification->setPriority($data['msg-data']['priority']);
  398.     
  399.                                     if(!empty($data['msg-data']['ns_msg_id']))
  400.                                         $notification->setNsMsgId($data['msg-data']['ns_msg_id']);
  401.     
  402.                                     $this->entityManager->persist($notification);
  403.                                     // $this->entityManager->flush();
  404.                                     if(!isset($send[$number]))
  405.                                         $send[$number] = 1;
  406.                                     else
  407.                                         ++$send[$number];
  408.     
  409.     
  410.                                     $i++;
  411.                                 }
  412.     
  413.                                 if($i == 100){
  414.                                     $this->entityManager->flush();
  415.                                     $i = 0;
  416.                                 }    
  417.                             }
  418.                         }   
  419.                     }
  420.                 }elseif($data['msg-type'] == 'number-phone'){
  421.                     $i = 0;
  422.                     foreach($data['msg-data']['receivers'] as $number => $receivers){
  423.                         $find = $this->entityManager->getRepository(User::class)->findOneBy(['phone' => $number]);
  424.                         if($find){
  425.                                 $notification = new Notification();
  426.                                 $notification->setUsers($find);
  427.                                 $notification->setTitle( $title);
  428.                                 $notification->setBody( $receivers );
  429.             
  430.                                 if(!empty($data['msg-data']['type']))
  431.                                     $notification->setType( $data['msg-data']['type']);
  432.                                 else
  433.                                     $notification->setType('text');
  434.             
  435.                                 $notification->setDateEntered( new \DateTime() );
  436.                                 $notification->setStatus('new');
  437.                                 if(!empty($data['msg-data']['priority']))
  438.                                         $notification->setPriority($data['msg-data']['priority']);
  439.     
  440.                                 if(!empty($data['msg-data']['ns_msg_id']))
  441.                                     $notification->setNsMsgId($data['msg-data']['ns_msg_id']);
  442.             
  443.                                 $this->entityManager->persist($notification);
  444.                                 $i++;
  445.                         }
  446.                         if($i == 100){
  447.                             $this->entityManager->flush();
  448.                             $i = 0;
  449.                         }
  450.                     }
  451.                 }
  452.                 
  453.                 $this->entityManager->flush();
  454.             }
  455.             $rez = ['rez' => true, 'send' => $send , 'error' => ""];
  456.         }else{
  457.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  458.         }
  461.         $response = new JsonResponse();
  462.         $response->setData($rez);
  464.         return $response;
  465.     }
  468.     #[Route('/api/create-data-reception', name: 'create_notfication_data_reception', methods: ['POST'])]
  469.     public function create_notfication_data_reception(Request $request)
  470.     {
  473.         if (!$this->customAuth($request)) {
  474.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  475.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  476.             ]);
  477.         }
  481.         $data = json_decode($request->getContent(), true);
  482.         // $logId = $this->logHistory(false, 'createPersonalAccount', $data);
  483.         // file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  485.         $valid = $this->valid( $data, ['method', 'data'] );
  486.         if( empty($valid) ){
  487.             
  488.             $DataReception = new DataReception();
  489.             $DataReception->setType( $data['method']);
  490.             $DataReception->setData( $data['data']);
  493.             $DataReception->setDateEntered( new \DateTime() );
  494.             $DataReception->setStatus('new');
  496.             $this->entityManager->persist($DataReception);
  497.             $this->entityManager->flush();
  498.             $rez = ['rez' => true, 'id' => $DataReception->getId()];
  499.                  
  500.         }else{
  501.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  502.         }
  503.     
  504.         $response = new JsonResponse();
  505.         $response->setData($rez);
  507.         return $response;
  508.     }
  510.     public function updateStatus($inf){
  511.         $query = $this->entityManager->createQuery(
  512.             'UPDATE App\Entity\Accounts d 
  513.              SET d.statusPlanning = :new_status 
  514.              WHERE d.eic IN (:ids)'
  515.         );
  516.         $query->setParameter('new_status', 'planned');
  517.         $query->setParameter('ids', $inf); // Масив ID
  518.         $query->execute();
  519.     }
  521.     #[Route('/cron-get-planned', name: 'cron_get_pllanned', methods: ['GET'])]
  522.     public function cron_get_pllanned(Request $request)
  523.     {
  524.         $query = $this->entityManager->createQuery(
  525.             'UPDATE App\Entity\Accounts d SET d.statusPlanning = :new_status'
  526.         );
  527.         $query->setParameter('new_status', 'not_pllaned');
  528.         // $query->setParameter('old_status', 'new');
  529.         // echo '<pre>';
  530.         $query->execute();
  531.         $this->entityManager->clear();
  532.         $DataReception = $this->entityManager->getRepository(DataReception::class)->findBy(['status' => 'new']);
  533.         $eic = [];
  534.         foreach($DataReception as $data){
  536.             $infos = json_decode($data->getData(), true);
  537.             foreach($infos as $acc_id =>  $inf){
  538.                 array_push($eic, $inf);
  540.                 if(count($eic) == 500){
  541.                     $this->updateStatus($eic);
  542.                     $eic = [];
  543.                 }
  544.             }
  545.             if(count($eic) > 0)
  546.                 $this->updateStatus($eic);
  547.             $this->entityManager->clear();
  548.             $data->setStatus('complate');
  549.             $this->entityManager->persist($data);
  550.             $this->entityManager->flush();
  551.             // print_r($infos);
  552.         }
  554.         echo count($DataReception); die;
  555.     }
  557.     #[Route('/api/get-account-all-data', name: 'get_account_all_data', methods: ['GET'])]
  558.     public function get_account_all_data(Request $request):Response
  559.     {   
  560.         set_time_limit(0);
  562.         // echo '<pre>';
  563.         $i = 0;
  564.         $AppPersonalAccount = $this->entityManager->getRepository(AppPersonalAccount::class)->findBy(['counter' => null]);
  565.         foreach($AppPersonalAccount as $account){
  566.             // if(!empty( $account->getEic() ))
  567.             //     continue;
  568.             $i++;
  569.             $data = [
  570.                 'account' => $account->getNumber()
  571.             ];
  572.             // echo $account->getId() . "<br>";
  573.             // echo $account->getNumber() . "<br>";
  574.             $res = json_decode( $this->appApiService->account_all_data($data) , true );  
  575.             
  576.             // print_r( $res ); 
  577.             
  578.             // if($i > 5)
  579.             //     die;
  580.             if(isset($res['rez']) AND $res['rez'] == 1 AND isset($res['data'][0])){
  581.                 file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',   print_r($res, true)  . "\n", FILE_APPEND);
  582.                 $account->setEic($res['data'][0]['eic_kod']);  
  583.                 $account->setCounter($res['data'][0]['counter']);  
  584.                 
  585.                 $this->entityManager->persist($account);
  586.                 $this->entityManager->flush();
  587.                 // continue;
  590.                 // $accounts = $this->entityManager->getRepository(Accounts::class)->findOneBy(['number' => $account->getNumber()]);
  591.                 // if(!$accounts){
  592.                 //     $accounts = new Accounts();
  593.                 //     $accounts->setNumber($account->getNumber());
  594.                 //     $accounts->setEic($account->getEic());
  595.                 //     // $accounts->setEicParent($res_data['eic_kod_place']);
  596.                 //     $this->entityManager->persist($accounts);
  597.                 //     $this->entityManager->flush();
  598.                 //     $account->setAccounts($accounts);
  599.                 // }
  600.                 // $account->setCounter($accounts);
  601.                 // $this->entityManager->persist($account);
  602.                 // $this->entityManager->flush();
  605.             }
  606.             // print_r($res); die;
  607.         }
  608.         // echo count( $AppPersonalAccount ); die;
  615.         return new Response('1');
  616.         
  617.     }
  620.     /** Додавання id crm LOE */
  621.     #[Route('/api/update-service-id', name: 'update_service_id', methods: ['POST'])]
  622.     public function update_service_id(Request $request)
  623.     {
  626.         if (!$this->customAuth($request)) {
  627.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  628.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  629.             ]);
  630.         }
  634.         $data = json_decode($request->getContent(), true);
  635.         // $logId = $this->logHistory(false, 'createPersonalAccount', $data);
  636.         // file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  638.         $valid = $this->valid( $data, ['id', 'id_crm'] );
  639.         if( empty($valid) ){
  640.             
  641.             $ServiceOrderHistory = $this->entityManager->getRepository(ServiceOrderHistory::class)->findOneBy(['id' => $data['id']]);
  642.             if($ServiceOrderHistory){
  643.                 $ServiceOrderHistory->setIdCrm( $data['id_crm']);
  644.                 if(!empty( $data['status'] ))
  645.                     $ServiceOrderHistory->setStatus(  $data['status'] );
  646.                 else
  647.                     $ServiceOrderHistory->setStatus( 'in_process' );
  648.                 if(!empty( $data['description'] ))
  649.                     $ServiceOrderHistory->setDescription(  $data['description'] );
  650.     
  651.                 $ServiceOrderHistory->setDateModified( new \DateTime() );
  652.                 // $ServiceOrderHistory->setStatus('new');
  653.     
  654.                 $this->entityManager->persist($ServiceOrderHistory);
  655.                 $this->entityManager->flush();
  656.             }
  658.             $rez = ['rez' => true, 'id' => $ServiceOrderHistory->getId()];
  659.                  
  660.         }else{
  661.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  662.         }
  663.     
  664.         $response = new JsonResponse();
  665.         $response->setData($rez);
  667.         return $response;
  668.     }
  670.     /** Додавання id crm LOE */
  671.     #[Route('/api/get-service-id', name: 'get_service_id', methods: ['GET'])]
  672.     public function get_service_id(Request $request)
  673.     {
  676.         if (!$this->customAuth($request)) {
  677.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  678.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  679.             ]);
  680.         }
  681.         $arr = [];
  683.         $ServiceOrderHistory = $this->entityManager->getRepository(ServiceOrderHistory::class)->findBy(['status' => 'in_process']);
  684.         
  685.         foreach($ServiceOrderHistory as $service){
  686.             $arr[] = [
  687.                 'id' => $service->getId(),
  688.                 'id_crm' => $service->getIdCrm(),
  689.             ];
  690.         }
  691.         
  692.         
  693.         $rez = ['rez' => true, 'data' => $arr];
  694.     
  695.         $response = new JsonResponse();
  696.         $response->setData($rez);
  698.         return $response;
  699.     }
  702.     /** Історія заявок з сторонніх систем */
  703.     #[Route('/api/create-order-history', name: 'create_order_history', methods: ['POST'])]
  704.     public function create_order_history(Request $request)
  705.     {
  708.         if (!$this->customAuth($request)) {
  709.             return new JsonResponse(['message' => 'Unauthorized'], 401, [
  710.                 'WWW-Authenticate' => 'Basic realm="API Access"',
  711.             ]);
  712.         }
  713.         $data = json_decode($request->getContent(), true);
  715.         $valid = $this->valid( $data, ['phone', 'account', 'service_code', 'status', 'id_crm'] );
  716.         if( empty($valid) ){
  717.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['phone' => $data['phone']]);
  718.             if($find){
  719.                 $arr = [];
  720.                 
  721.                 $orderNames = [
  722.                     9 =>  "Встановлення зонного лічильника",
  723.                     10 =>  "Лічильник не працює",
  724.                     21 =>  "Неправильний показ",
  725.                     32 =>  "Зміна власника",
  726.                     35 =>  "Підключення електроустановок замовника після виконання ТУ",
  727.                     63 =>  "Звернення щодо підозри на крадіжку",
  728.                     79 =>  "Заміна автоматичного вимикача, який опломбований ОСР",
  729.                     85 =>  "Відсутність пломб на засобі обліку",
  730.                     86 =>  "Закриття особового рахунку",
  731.                     200 =>  "Попередній запис в електронну чергу",
  732.                 ];
  733.                 $account = false;
  734.                 foreach($find->getAppPersonalAccounts() as $acc){
  735.                     if($acc->getNumber() == $data['account'])
  736.                         $account = $acc;
  737.                 }
  738.                 
  739.                 if(!$account AND count($find->getAppPersonalAccounts()) > 0){
  740.                     $account = $find->getAppPersonalAccounts()[0];
  741.                 }
  743.                 if($account){
  745.                     $ServiceOrderHistory = new ServiceOrderHistory();
  746.                     $ServiceOrderHistory->setName($orderNames[$data['service_code']]);
  747.                     // $ServiceOrderHistory->setRequest($data);
  748.                     $ServiceOrderHistory->setDateEntered( new \DateTime() );
  749.                     $ServiceOrderHistory->setType($data['service_code']);
  750.                     $ServiceOrderHistory->setStatus('new');
  751.                     $ServiceOrderHistory->setPersonalAccount($account);
  752.                     if(!empty( $data['id_crm'] ))
  753.                         $ServiceOrderHistory->setIdCrm( $data['id_crm']);
  754.                     if(!empty( $data['status'] ))
  755.                         $ServiceOrderHistory->setStatus(  $data['status'] );
  756.                     else
  757.                         $ServiceOrderHistory->setStatus( 'in_process' );
  758.                     if(!empty( $data['description'] ))
  759.                         $ServiceOrderHistory->setDescription(  $data['description'] );
  760.         
  761.                     if($data['service_code'] == 200){
  762.                         $ServiceOrderHistory->setStatus('-100');
  763.                         $ServiceOrderHistory->setDescription('Виконано');
  764.                     }
  766.                     $ServiceOrderHistory->setPersonalAccount($account);
  767.                     $this->entityManager->persist($ServiceOrderHistory);
  768.                     $this->entityManager->flush();
  770.                     $data["id"] = $ServiceOrderHistory->getId();
  771.                     
  772.                     
  773.                     $rez = ['rez' => true, 'data' => [
  774.                         'id' => $ServiceOrderHistory->getId()
  775.                     ]];
  776.                 }else{
  777.                     $rez = ['rezult' => false, 'error' => "Нема жодного особового рахунку"];   
  778.                 }
  780.             }else{
  781.                 $rez = ['rezult' => false, 'error' => "Користувача не знайдено!"];   
  782.             }
  783.         
  784.         }else{
  785.             $rez = ['rez' => false, 'error' => "Не задано поля: $valid"];
  786.         }
  787.     
  788.         $response = new JsonResponse();
  789.         $response->setData($rez);
  791.         return $response;
  792.     }
  799. }