src/Controller/PersonalController.php line 855

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\Service\LogHistoryService;
  10. use App\Entity\User;
  11. use App\Entity\UserToken;
  12. use Symfony\Component\HttpFoundation\JsonResponse;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
  16. use App\Service\AppApiService;
  17. use App\Service\PowerOn;
  18. use App\Entity\AppPersonalAccount;
  19. use App\Entity\MediaObject;
  20. use App\Entity\AppCounterReading;
  21. use App\Entity\ServiceOrderHistory;
  22. use App\Entity\Accounts;
  23. use Symfony\Component\HttpKernel\KernelInterface; 
  24. use Symfony\Component\Security\Core\Security;
  25. use Symfony\Component\Serializer\SerializerInterface;
  26. use App\Repository\ServiceOrderHistoryRepository;
  32. class PersonalController extends AbstractController
  33. {
  34.     public $datetime;
  35.     public $entityManager;
  36.     public $passwordEncoder;
  37.     public $appApiService;
  38.     private $kernel;
  39.     private $logHistory;
  40.     private $security;
  41.     private $powerOn;
  43.     public function __construct( 
  44.         ?\DateTimeInterface $datetime, 
  45.         EntityManagerInterface $entityManager, 
  46.         PowerOn $powerOn,
  47.         AppApiService $appApiService, 
  48.         KernelInterface $kernel,  
  49.         LogHistoryService $logHistory,
  50.         Security $security
  51.         ){
  52.         $this->datetime = $datetime;
  53.         $this->entityManager = $entityManager;
  54.         $this->appApiService = $appApiService;
  55.         $this->kernel = $kernel;
  56.         $this->logHistory = $logHistory;
  57.         $this->security = $security;
  58.         $this->powerOn = $powerOn;
  59.     }
  61.     public function valid($requestFilds, $requiredFilds){
  62.         $errors = '';
  63.         foreach($requiredFilds as $f){
  64.             if(!isset($requestFilds[$f]))
  65.                 $errors .= " $f"; 
  66.         }
  68.         return $errors;
  69.     }
  71.     
  72.     private function isUserData($userId=false, $accountNumber=false){
  73.         $user = $this->security->getUser();
  75.         if(!$user)
  76.             return ['rezult' => false, 'error' => 'Користувач не авторизований'];
  78.         if(!$userId AND !$accountNumber)
  79.             return ['rezult' => false, 'error' => 'Не вказані всі необхідні параметри'];
  81.         /** Якщо користувач вказаний і він не рівний залогованому */
  82.         if($userId AND $user->getId() != $userId)
  83.             return ['rezult' => false, 'error' => '1) Недостатньо прав для виконання дії'];
  84.         elseif($userId AND $user->getId() == $userId AND !$accountNumber)
  85.             return ['rezult' => true];
  87.         /** якщо є номер особового і він рівний номеру залогованого користувача */
  88.         if($accountNumber)
  89.             foreach($user->getAppPersonalAccounts() as $acc){
  90.                 if( $acc->getNumber() == $accountNumber)
  91.                     return ['rezult' => true];
  92.             }
  94.         return ['rezult' => false, 'error' => '2) Недостатньо прав для виконання дії'];
  95.        
  96.     }
  98.     
  99.     #[Route('/api/create-personal-account-bot', name: 'createPersonalAccountBot')]
  100.     public function createPersonalAccountBot(Request $request)
  101.     {
  102.         $data = json_decode($request->getContent(), true);
  103.         $logId = $this->logHistory->save(false, 'create-personal-account-bot', $data);
  104.         $valid = $this->valid( $data, ['accounts', 'method', 'owner'] );
  105.         if( empty($valid) ){
  106.             $isUserData = $this->isUserData($data['owner']);
  107.             if( $isUserData['rezult'] ){
  108.                 
  110.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['owner']]);
  111.                 if($find){
  112.                     $resultAccounts = [];
  113.                     foreach($data['accounts'] as $value){
  114.                         $number = trim( array_key_first($value) );
  115.                         $name = $value[$number];
  116.                         $resultAccounts[$number] = false;
  117.                         $data = [
  118.                             'account' => $number
  119.                         ];
  120.                         $res = json_decode( $this->appApiService->account_all_data($data) , true );  
  121.                         if(isset($res['rez']) AND $res['rez'] == 1){
  122.                             if(isset($res['data']) AND count($res['data']) > 0){
  123.                                 $name = (!empty($name)) ? $name : $number;
  124.                                 $accounts = $this->entityManager->getRepository(Accounts::class)->findOneBy(['number' => $number]);
  125.                                 if(!$accounts){
  126.                                     $accounts = new Accounts();
  127.                                     $accounts->setNumber($number);
  128.                                     $accounts->setEic($res['data'][0]['eic_kod']);
  129.                                     $this->entityManager->persist($accounts);
  130.                                     $this->entityManager->flush();
  131.                                 }
  132.                                 $personal = new AppPersonalAccount();
  133.                                 $personal->setOwner($find);
  134.                                 $personal->setNumber($number);
  135.                                 $personal->setName($name);
  136.                                 $personal->setNumberOfScale((int) $res['data'][0]['number_of_scale']);
  137.                                 $personal->setActive(true);
  138.                                 $personal->setIsMain(true);
  139.                                 $personal->setFullAddress($res['data'][0]['name']);
  140.                                 $personal->setCity($res['data'][0]['city_name']);
  141.                                 $personal->setStreet($res['data'][0]['street_name']);
  142.                                 $personal->setBuilding($res['data'][0]['building_name']);
  143.                                 // $personal->setRoom($res['room']);
  144.                                 $personal->setMainFullAddress($res['data'][0]['name']);
  145.                                 $personal->setEic($res['data'][0]['eic_kod']);
  146.                                 $personal->setDateEntered($this->datetime);
  147.                                 $personal->setType('person');
  148.                                 $personal->setAccounts($accounts);
  149.                                 $personal->setCounter($res['data'][0]['counter']);
  150.                                 $personal->setNotificationStatus('active');
  151.                                 $this->entityManager->persist($personal);
  152.                                 $this->entityManager->flush();
  154.                                 $resultAccounts[$number] = true;
  156.                             }
  157.                         }  
  158.                         $rez = [
  159.                             'registered' => true,
  160.                             'registerAccounts' => $resultAccounts
  161.                         ];
  162.                     }
  163.                 }else{
  164.                     $rez = ['registered' => false];
  165.                 }
  166.                 
  167.             }else{
  168.                 $rez = ['registered' => false, 'error' => $isUserData['error']];
  169.             }
  170.         }else{
  171.             $rez = ['registered' => false, 'error' => "Не задано поля: $valid"];
  172.         }
  173.         $response = new JsonResponse();
  174.         $response->setData($rez);
  176.         $this->logHistory->save($logId, 'create-personal-account-bot', $rez);
  177.         return $response;
  178.     }
  180.     /** Cтворити рахунок  { "owner": "31", "account":"0900015104", "method":"by_name", "value": "Подолюк", "name": "Test 1" } */
  181.     #[Route('/api/create-personal-account', name: 'createPersonalAccount')]
  182.     public function createPersonalAccount(Request $request)
  183.     {
  184.         $data = json_decode($request->getContent(), true);
  185.         $logId = $this->logHistory->save(false, 'create-personal-account', $data);
  187.         $valid = $this->valid( $data, ['owner', 'account', 'method', 'value'] );
  188.         if( empty($valid) ){
  189.             $isUserData = $this->isUserData($data['owner']);
  190.             if( $isUserData['rezult'] ){
  191.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['owner']]);
  192.                 if($find){
  193.                     $data = ['account' => $data['account'], 'app_user_id' => $find->getId(), 'check_method' => $data['method'], 'check_value' => $data['value'], 'name' => $data['name']];
  194.                     $res = json_decode( $this->appApiService->checkPersonalAccount($data) , true );
  195.                     $name = (!empty($data['name'])) ? $data['name'] : $data['account'];
  196.                     if(isset($res['account_ok']) AND $res['account_ok'] ){
  197.                         $accounts = $this->entityManager->getRepository(Accounts::class)->findOneBy(['number' => $data['account']]);
  198.                         if(!$accounts){
  199.                             $accounts = new Accounts();
  200.                             $accounts->setNumber( trim( $data['account'] ));
  201.                             $accounts->setEic($res['eic']);
  202.                             $this->entityManager->persist($accounts);
  203.                             $this->entityManager->flush();
  204.                         }
  206.                         $personal = new AppPersonalAccount();
  207.                         $personal->setOwner($find);
  208.                         $personal->setNumber(trim( $data['account'] ));
  209.                         $personal->setName($name);
  210.                         $personal->setNumberOfScale((int) $res['number_of_scale']);
  211.                         $personal->setActive(true);
  212.                         $personal->setIsMain(true);
  213.                         $personal->setFullAddress($res['full_address']);
  214.                         $personal->setCity($res['city']);
  215.                         $personal->setStreet($res['street']);
  216.                         $personal->setBuilding($res['building']);
  217.                         $personal->setRoom($res['room']);
  218.                         $personal->setMainFullAddress($res['full_address']);
  219.                         $personal->setEic($res['eic']);
  220.                         $personal->setDateEntered($this->datetime);
  221.                         $personal->setType('person');
  222.                         $personal->setAccounts($accounts);
  223.                         $personal->setCounter($res['counter']);
  224.                         $personal->setNotificationStatus('active');
  225.                         $this->entityManager->persist($personal);
  226.                         $this->entityManager->flush();
  227.                         $rez = [
  228.                             'registered' => true,
  229.                             'id' => $personal->getId(),
  230.                             'name' => $personal->getName(),
  231.                             'number' => trim( $personal->getNumber() ),
  232.                             'numberOfScale' => $personal->getNumberOfScale(),
  233.                             'fullAddress' => $personal->getFullAddress(),
  234.                             'city' => $personal->getCity(),
  235.                             'street' => $personal->getStreet(),
  236.                             'building' => $personal->getBuilding(),
  237.                             'room' => $personal->getRoom(),
  238.                             'mainFullAddress' => $personal->getMainFullAddress(),
  239.                             'account' => [
  240.                                 'statusLight' => $accounts->getStatusLight(),
  241.                                 'statusPlanning' => $accounts->getStatusPlanning(),
  242.                             ]
  243.                         ];
  244.                     }else{
  245.                         $rez = ['registered' => false, $res];
  246.                     }
  247.                 
  248.                 }else{
  249.                     $rez = ['registered' => false];
  250.                 }
  251.             }else{
  252.                 $rez = ['registered' => false, 'error' => $isUserData['error']];
  253.             }
  254.         }else{
  255.             $rez = ['registered' => false, 'error' => "Не задано поля: $valid"];
  256.         }
  260.         
  261.         
  262.     
  263.         $response = new JsonResponse();
  264.         $response->setData($rez);
  266.         $this->logHistory->save($logId, 'create-personal-account', $rez);
  270.         return $response;
  271.     }
  273.     #[Route('/api/create-personal-account_test', name: 'createPersonalAccountTest')]
  274.     public function createPersonalAccountTest(Request $request)
  275.     {
  276.         $data = json_decode($request->getContent(), true);
  279.         // $data = ['account' => '0900015104', 'check_method' => 'by_name', 'check_value' => 'Подолюк'];
  280.         $res = json_decode( $this->appApiService->checkPersonalAccount($data) , true );
  281.         var_dump($res); die;
  282.         
  283.     }
  285.     /** наяність світла { "user": "31", "account":"0900015104" } */
  286.     #[Route('/api/check-light', name: 'check_light')]
  287.     public function check_light(Request $request)
  288.     {
  290.         $data = json_decode($request->getContent(), true);
  291.         $logId = $this->logHistory->save(false, 'check-light', $data);
  292.         $valid = $this->valid( $data, ['account', 'user'] );
  293.         if( empty($valid) ){
  294.             $isUserData = $this->isUserData($data['user'], $data['account']);
  295.             if( $isUserData['rezult'] ){
  297.                 $data =  [
  298.                         'method' => 'check-light',
  299.                         'data' => [
  300.                             'account' => $data['account'],
  301.                             // 'eic'     => '36457',
  302.                     ],
  303.                 ];
  304.                 $rezult = json_decode( $this->appApiService->get($data) , true );
  305.                 if($rezult['rez']){
  306.                     $rez = [
  307.                         'rezult' => true, 
  308.                         'іs_included_disconnection_task' => (isset( $rezult['іs_included_disconnection_task']) ) ? $rezult['іs_included_disconnection_task'] : 0,
  309.                         'reazon' => (isset( $rezult['reazon']) ) ? $rezult['reazon'] : '', 
  310.                         'reazon_yur' => (isset( $rezult['reazon_yur']) ) ? $rezult['reazon_yur']: ''    ,
  311.                         'owner_adress' => $rezult['owner_adress'],
  312.                         'light' => $rezult['light'],
  313.                         'date' => $rezult['date'],
  314.                         'diff_eic_count' => $rezult['diff_eic_count'],
  315.                         'eic' => $rezult['eic'],
  316.                         'dno_id' => $rezult['dno_id'],
  317.                         'disconnect_warning_guid' =>  (isset( $rezult['disconnect_warning_guid']))?$rezult['disconnect_warning_guid'] : '',
  318.                     ];   
  319.                 }else{
  320.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  321.                 }
  322.             }else{
  323.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];
  324.             }
  325.         }else{
  326.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  327.         }
  329.         $response = new JsonResponse();
  330.         $response->setData($rez);
  332.         $this->logHistory->save($logId, 'check-light', $rez);
  336.         return $response;
  339.     }
  342.     /** графік гпв { "user": "31", "account":"0900015104" } */
  343.     #[Route('/api/get-group-gpv', name: 'get_group_gpv')]
  344.     public function get_group_gpv(Request $request)
  345.     {
  347.         $data = json_decode($request->getContent(), true);
  348.         // $logId = $this->logHistory->save(false, 'get_group_gpv', $data);
  349.         $valid = $this->valid( $data, ['account', 'user'] );
  350.         if( empty($valid) ){
  351.             $isUserData = $this->isUserData($data['user'], $data['account']);
  352.             if( $isUserData['rezult'] ){
  354.                 $data =  [
  355.                         'method' => 'get-group-gpv',
  356.                         'data' => [
  357.                             'account' => $data['account'],
  358.                             // 'eic'     => '36457',
  359.                     ],
  360.                 ];
  361.                 $rezult = json_decode( $this->appApiService->get($data) , true );
  362.                 if($rezult['rez']){
  363.                     $rez = [
  364.                         'rezult' => true, 
  365.                         'rem_name' => $rezult['rem_name'],
  366.                         'odg_name' => $rezult['odg_name'],
  367.                         'cherg_gav' => $rezult['cherg_gav'],
  368.                         'cherg_achr' => $rezult['cherg_achr'],
  369.                         'cherg_gvsp' => $rezult['cherg_gvsp'],
  370.                         'cherg_sgav' => $rezult['cherg_sgav'],
  371.                         'cherg_gpv' => $rezult['cherg_gpv'],
  372.                     ];   
  373.                 }else{
  374.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  375.                 }
  376.             }else{
  377.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];
  378.             }
  379.         }else{
  380.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  381.         }
  383.         $response = new JsonResponse();
  384.         $response->setData($rez);
  386.         // $this->logHistory->save($logId, 'get_group_gpv', $rez);
  390.         return $response;
  393.     }
  395.     /** заплановані роботи { "user": "31", "account":"0900015104" } */
  396.     #[Route('/api/get-scheduled-works', name: 'get_scheduled_works')]
  397.     public function get_scheduled_works(Request $request)
  398.     {
  400.         $data = json_decode($request->getContent(), true);
  401.         $logId = $this->logHistory->save(false, 'get_scheduled_works', $data);
  402.         $valid = $this->valid( $data, ['account', 'user'] );
  403.         if( empty($valid) ){
  404.             $data =  [
  405.                     'method' => 'get-scheduled-works',
  406.                     'data' => [
  407.                         'account' => $data['account'],
  408.                         // 'eic'     => '36457',
  409.                 ],
  410.             ];
  411.             $rezult = json_decode( $this->appApiService->get($data) , true );
  412.             if($rezult['rez']){
  413.                 $rez = [
  414.                     'rezult' => true, 
  415.                     'message' => $rezult['message'],
  416.                     'works' => $rezult['works'],
  417.                 ];   
  418.             }else{
  419.                 $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  420.             }
  421.         }else{
  422.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  423.         }
  425.         $response = new JsonResponse();
  426.         $response->setData($rez);
  428.         $this->logHistory->save($logId, 'get_scheduled_works', $rez);
  432.         return $response;
  435.     }
  437.     /** Низька напруга  { "user": "31", "account": "", "phone":"", "voltage":"", "voltage_susidy": "", "media": "111" } */
  438.     #[Route('/api/set-low-quality-voltage', name: 'set_low_quality_voltage')]
  439.     public function set_low_quality_voltage(Request $request)
  440.     {
  441.         // echo '<pre>';
  442.         $data = json_decode($request->getContent(), true);
  443.         // $data = [
  444.         //     'user' => 31,
  445.         //     'account' => '0900015104',
  446.         //     'phone' => '380xxxxxxxxx',
  447.         //     'voltage' => '123',
  448.         //     'voltage_susidy' => 'Так',
  449.         //     'media' => 2
  450.         //     // 'imageFile' => new CURLFile(realpath(__DIR__) . '/11.png'),
  451.         // ];
  452.         $logId = $this->logHistory->save(false, 'set_low_quality_voltage', $data);
  453.         
  454.         
  455.         $valid = $this->valid( $data, ['account', 'user', 'phone', 'voltage', 'voltage_susidy', 'media'] );
  458.         if( empty($valid) ){
  459.             $isUserData = $this->isUserData($data['owner']);
  460.             if( $isUserData['rezult'] ){
  461.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  462.                 if($find){
  463.                     $mediaObject = $this->entityManager->getRepository(MediaObject::class)->findOneBy(['id' => $data['media']]);
  465.                     if (!$mediaObject) {
  466.                         return new JsonResponse(['rezult' => false,'error' => 'MediaObject not found'], 404);
  467.                     }
  468.                     // Отримуємо шлях до файлу
  469.                     $filePath = $this->kernel->getProjectDir() . '/public' .$mediaObject->getFullPath() ;
  470.                     // echo "<br> $filePath <br>";
  471.                     $permission = json_decode( $this->appApiService->check_allow_for_low_quality_voltage($data['account']) , true); 
  472.                     if(!$permission['rez'] AND $permission['dozvil'] !== true){
  473.                         // print_r( $permission); die;
  474.                         return new JsonResponse(['rezult' => false,'error' => $permission['err_msg']], 404);
  475.                     }
  476.                     // var_dump( $permission);
  477.                     // die;
  478.                     $data =  [
  479.                         'app_user_id' => $find->getId(),
  480.                         'account' => $data['account'],
  481.                         'phone' => $data['phone'],
  482.                         'voltage' => $data['voltage'],
  483.                         'voltage_susidy' => $data['voltage_susidy'],
  484.                         'imageFile' => new \CURLFile( $filePath ),
  485.                     ];
  487.                     $rezult = json_decode( $this->appApiService->set_low_quality_voltage($data) , true );
  488.                     if($rezult['rez']){
  489.                         $rez = [
  490.                             'rezult' => true, 
  491.                             'message' => 'Дані відправлено!',
  492.                             // 'account' => $rezult['account'],
  493.                         ];   
  494.                     }else{
  495.                         $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  496.                     }
  497.                 }else{
  498.                     $rez = ['rezult' => false, 'error' => "Користувача не знайдено!"];   
  499.                 }
  500.             }else{
  501.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];
  502.             }
  503.         }else{
  504.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  505.         }
  507.         $response = new JsonResponse();
  508.         $response->setData($rez);
  510.         $this->logHistory->save($logId, 'set_low_quality_voltage', $rez);
  514.         return $response;
  517.     }
  519.     /** Заявка на сервісне обслуговування  { "user": "31", "account": "", "phone":"", "service_code":"", "description":"", "media": [1,2,3], "pdf": "" } */
  520.     #[Route('/api/service-order', name: 'service_order')]
  521.     public function service_order(Request $request)
  522.     {
  523.         // echo '<pre>';
  524.         $data = json_decode($request->getContent(), true);
  525.         // $data = [
  526.         //     'user' => 31,
  527.         //     'account' => '0900015104',
  528.         //     'phone' => '380xxxxxxxxx',
  529.         //     'service_code' => '9',
  530.         //     'description' => 'Так',
  531.         //     'media' => [4,5,6]
  532.         //     // 'imageFile' => new CURLFile(realpath(__DIR__) . '/11.png'),
  533.         // ];
  534.         $logId = $this->logHistory->save(false, 'service-order', $data);
  535.         if(isset($data['service_code']) AND (  $data['service_code'] == 63  OR $data['service_code'] == 10 OR $data['service_code'] == 9 OR $data['service_code'] == 113 OR $data['service_code'] == 26))
  536.             $valid = $this->valid( $data, ['account', 'user', 'phone', 'service_code', 'description', 'pdf'] );
  537.         else 
  538.             $valid = $this->valid( $data, ['account', 'user', 'phone', 'service_code', 'description', 'media', 'pdf'] );
  540.         if( empty($valid) ){
  541.             $isUserData = $this->isUserData($data['user'], $data['account']);
  542.             if($isUserData['rezult'] ){
  543.              
  544.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  545.                 if($find){
  546.                     if($data['service_code'] != 63 AND $data['service_code'] != 10 AND $data['service_code'] != 9 AND $data['service_code'] != 113 AND $data['service_code'] != 26){
  547.                     // $mediaObject = $this->entityManager->getRepository(MediaObject::class)->findOneBy(['id' => $data['media']]);
  548.                         $mediaObjects = $this->entityManager->getRepository(MediaObject::class)->findBy(['id' => $data['media']]);
  549.                         if (!$mediaObjects) {
  550.                             return new JsonResponse(['rezult' => false,'error' => 'MediaObject not found'], 404);
  551.                         }
  552.                     }
  553.                     $pdf = (!empty($data['pdf'])) ? $data['pdf']: false;
  554.                     $data =  [
  555.                         'account' => $data['account'],
  556.                         'app_user_id' => $find->getId(),
  557.                         'phone' => str_replace('+', '',  $find->getPhone() ), ///  $data['phone'] присилають декілька номерів тел через кому
  558.                         'service_code' => $data['service_code'],
  559.                         'description' => $data['description'],
  560.                         // 'imageFile' => new \CURLFile( $filePath ),
  561.                     ];
  562.                     $i = 1;
  563.                     if($data['service_code'] != 63 AND $data['service_code'] != 10 AND $data['service_code'] != 9 AND $data['service_code'] != 113 AND $data['service_code'] != 26)
  564.                         foreach($mediaObjects as $k => $mediaObject){
  565.                             $i = $k + 1;
  566.                             $filePath = $this->kernel->getProjectDir() . '/public' .$mediaObject->getFullPath() ;
  567.                             $data["imageFile$i"] = new \CURLFile( $filePath );
  568.                         }
  570.                     if($pdf){
  571.                         if(isset($data["imageFile$i"]))
  572.                             ++$i;
  574.                         $data["imageFile$i"] = new \CURLFile( $this->kernel->getProjectDir() . '/public' . $pdf );
  575.                     }
  578.                     // $filePath = $this->kernel->getProjectDir() . '/public' .$mediaObject->getFullPath() ;
  579.                     // echo "<br> $filePath <br>";
  580.                     // $permission = json_decode( $this->appApiService->check_allow_for_low_quality_voltage($data['account']) , true); 
  581.                     // if(!$permission['rez'] AND $permission['dozvil'] !== true){
  582.                     //     // print_r( $permission); die;
  583.                     //     return new JsonResponse(['rezult' => false,'error' => $permission['err_msg']], 404);
  584.                     // }
  585.                     // var_dump( $permission);
  586.                     // die;
  587.                     // $data =  [
  588.                     //     'account' => $data['account'],
  589.                     //     'phone' => $data['phone'],
  590.                     //     'voltage' => $data['voltage'],
  591.                     //     'voltage_susidy' => $data['voltage_susidy'],
  592.                     //     'imageFile' => new \CURLFile( $filePath ),
  593.                     // ];
  594.     /*
  595.     const serviceCodesArr = [
  596.         { service_code: 9, label: "Встановлення зонного лічильника" },
  597.         { service_code: 10, label: "Лічильник не працює" },
  598.         { service_code: 21, label: "Неправильний показ" },
  599.         { service_code: 32, label: "Зміна власника" },
  600.         { service_code: 35, label: "Підключення електроустановок замовника після виконання ТУ" },
  601.         { service_code: 63, label: "Звернення щодо підозри на крадіжку" },
  602.         { service_code: 79, label: "Заміна автоматичного вимикача, який опломбований ОСР" },
  603.         { service_code: 85, label: "Відсутність пломб на засобі обліку" },
  604.         { service_code: 86, label: "Закриття особового рахунку" },
  605.     ];
  608.     */
  609.                     $orderNames = [
  610.                         9 =>  "Встановлення зонного лічильника",
  611.                         10 =>  "Лічильник не працює",
  612.                         21 =>  "Неправильний показ",
  613.                         32 =>  "Зміна власника",
  614.                         35 =>  "Підключення електроустановок замовника після виконання ТУ",
  615.                         63 =>  "Звернення щодо підозри на крадіжку",
  616.                         79 =>  "Заміна автоматичного вимикача, який опломбований ОСР",
  617.                         85 =>  "Відсутність пломб на засобі обліку",
  618.                         86 =>  "Закриття особового рахунку",
  619.                         113 =>  "Узгодження дати візиту",
  620.                         26 =>  "Відновити живлення після відключення",
  621.                     ];
  623.                     foreach($find->getAppPersonalAccounts() as $acc){
  624.                         if(trim( $acc->getNumber() ) == $data['account'])
  625.                             $account = $acc;
  626.                     }
  627.                     if($account){
  629.                         $ServiceOrderHistory = new ServiceOrderHistory();
  630.                         $ServiceOrderHistory->setName($orderNames[$data['service_code']]);
  631.                         // $ServiceOrderHistory->setRequest($data);
  632.                         $ServiceOrderHistory->setDateEntered( new \DateTime() );
  633.                         $ServiceOrderHistory->setType($data['service_code']);
  634.                         $ServiceOrderHistory->setDescription($data['description']);
  635.                         $ServiceOrderHistory->setCommentar($data['description']);
  636.                         $ServiceOrderHistory->setStatus('new');
  637.                         $ServiceOrderHistory->setPersonalAccount($account);
  638.                         if($pdf)
  639.                             $ServiceOrderHistory->setPdf(  $pdf );
  640.                         $ServiceOrderHistory->setPersonalAccount($account);
  641.                         $this->entityManager->persist($ServiceOrderHistory);
  642.                         $this->entityManager->flush();
  644.                         $data["id"] = $ServiceOrderHistory->getId();
  645.                     }
  649.                     $rezult = json_decode( $this->appApiService->service_order($data) , true );
  650.                     if($rezult['rez']){
  651.                         $account = false;
  652.                         
  653.                         $rez = [
  654.                             'rezult' => true, 
  655.                             'message' => 'Дані відправлено!',
  656.                             // 'account' => $rezult['account'],
  657.                         ];   
  658.                     }else{
  659.                         $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  660.                     }
  661.                 }else{
  662.                     $rez = ['rezult' => false, 'error' => "Користувача не знайдено!"];   
  663.                 }
  664.             }else{
  665.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];
  666.             }
  667.         }else{
  668.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  669.         }
  671.         $response = new JsonResponse();
  672.         $response->setData($rez);
  674.         $this->logHistory->save($logId, 'service-order', $rez);
  678.         return $response;
  681.     }
  683.     /** Обірваний провід { "user": 31, "account": "0900015104", "reason_type": "brok", "phone": "380xxxxxxxxx", "address": "Тернопільська 75", "lat": "50.067404", "lon": "25.171442", "media": 111 } */
  684.     #[Route('/api/set-broken-lines', name: 'set_broken_lines')]
  685.     public function set_broken_lines(Request $request)
  686.     {
  687.         // echo '<pre>';
  688.         $data = json_decode($request->getContent(), true);
  689.         // $data = [
  690.         //     'user' => 31,
  691.         //     'account' => '0900015104',
  692.         //     'phone' => '380xxxxxxxxx',
  693.         //     'voltage' => '123',
  694.         //     'voltage_susidy' => 'Так',
  695.         //     'media' => 2,
  696.         //     'lat' => '1111',
  697.         //     'lon' => '2222',
  698.         //     'reason_type' => '22',
  699.         //     'address' => '222',
  700.         //     // 'imageFile' => new CURLFile(realpath(__DIR__) . '/11.png'),
  701.         // ];
  702.         $logId = $this->logHistory->save(false, 'set_broken_lines', $data);
  703.         
  704.         
  705.         $valid = $this->valid( $data, ['reason_type', 'user', 'phone', 'address', 'lat', 'lon'] );
  708.         if( empty($valid) ){
  709.             $isUserData = $this->isUserData($data['user'], $data['account']);
  710.             if($isUserData['rezult'] ){
  712.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  713.                 if($find){
  714.                     if(isset($data['media'])){
  715.                         $mediaObject = $this->entityManager->getRepository(MediaObject::class)->findOneBy(['id' => $data['media']]);
  717.                         if (!$mediaObject) {
  718.                             return new JsonResponse(['rezult' => false,'error' => 'MediaObject not found'], 404);
  719.                         }
  720.                         // Отримуємо шлях до файлу
  721.                         $filePath = $this->kernel->getProjectDir() . '/public' .$mediaObject->getFullPath() ;
  722.                     }
  723.                     // echo "<br> $filePath <br>";
  724.                     $permission = json_decode( $this->appApiService->check_allow_for_low_quality_voltage($data['account']) , true); 
  725.                     if(!$permission['rez'] AND $permission['dozvil'] !== true){
  726.                         // print_r( $permission); die;
  727.                         return new JsonResponse(['rezult' => false,'error' => $permission['err_msg']], 404);
  728.                     }
  729.                     // var_dump( $permission);
  730.                     // die;
  731.                     $data =  [
  732.                         'phone' => $data['phone'],
  733.                         'app_user_id' => $find->getId(),
  734.                         'reason_type' => $data['reason_type'],
  735.                         'address' => $data['address'],
  736.                         'lat' => $data['lat'],
  737.                         'lon' => $data['lon'],
  738.                         // 'imageFile' => new \CURLFile( $filePath ),
  739.                     ];
  740.                     if(isset($filePath))
  741.                         $data['imageFile'] = new \CURLFile( $filePath );
  743.                     $rezult = json_decode( $this->appApiService->set_broken_lines($data) , true );
  744.                     
  745.                     if($rezult['rez']){
  746.                         // foreach($find->getAppPersonalAccounts() as $acc){
  747.                         //     if($acc->getNumber() == $data['account'])
  748.                         //         $account = $acc;
  749.                         // }
  751.                         // if($account){
  752.                         //     $ServiceOrderHistory = new ServiceOrderHistory();
  753.                         //     $ServiceOrderHistory->setName('set-broken-lines');
  754.                         //     $ServiceOrderHistory->setDateEntered( new \DateTime() );
  755.                         //     $ServiceOrderHistory->setType('set-broken-lines');
  756.                         //     $ServiceOrderHistory->setStatus('new');
  757.                         //     $ServiceOrderHistory->setPersonalAccount($account);
  758.                         //     $this->entityManager->persist($ServiceOrderHistory);
  759.                         //     $this->entityManager->flush();
  760.                         // }
  761.                         $rez = [
  762.                             'rezult' => true, 
  763.                             'message' => 'Дані відправлено!',
  764.                             // 'account' => $rezult['account'],
  765.                         ];   
  766.                     }else{
  767.                         $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  768.                     }
  769.                 }else{
  770.                     $rez = ['rezult' => false, 'error' => "Користувача не знайдено!"];   
  771.                 }
  772.             }else{
  773.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];
  774.             }
  775.         }else{
  776.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  777.         }
  779.         $response = new JsonResponse();
  780.         $response->setData($rez);
  782.         $this->logHistory->save($logId, 'set_broken_lines', $rez);
  786.         return $response;
  789.     }
  791.     /** Отримати останній показник {} */
  793.     #[Route('/api/get-last-meter-readings', name: 'get_last_meter_readings')]
  794.     public function get_last_meter_readings(Request $request)
  795.     {
  796.         // echo '<pre>';
  797.         $data = json_decode($request->getContent(), true);
  798.         // $data = [
  799.         //     'user' => 31,
  800.         //     'account' => '0900015104',
  801.         // ];
  802.         $logId = $this->logHistory->save(false, 'get_last_meter_readings', $data);
  803.         
  804.         
  805.         $valid = $this->valid( $data, ['account', 'user'] );
  808.         if( empty($valid) ){
  809.             $isUserData = $this->isUserData($data['user'], $data['account']);
  810.             if( $isUserData['rezult'] ){
  812.            
  813.                 $data = [
  814.                     'method' => 'get-last-meter-readings',
  815.                     'data' => [
  816.                         'account' => $data['account'],
  817.                     ],
  818.                 ]; 
  820.                 $rezult = json_decode( $this->appApiService->get($data) , true );
  821.                 if($rezult['rez']){
  822.                     $rez = [
  823.                         'rezult' => true, 
  824.                         'date_on' => $rezult['date_on'],
  825.                         'reading1' => $rezult['reading1'],
  826.                         'reading2' => $rezult['reading2'],
  827.                         'reading3' => $rezult['reading3'],
  828.                         // 'account' => $rezult['account'],
  829.                     ];   
  830.                 }else{
  831.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  832.                 }
  833.             }else{
  834.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];   
  835.             }
  836.         }else{
  837.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  838.         }
  840.         $response = new JsonResponse();
  841.         $response->setData($rez);
  843.         $this->logHistory->save($logId, 'get_last_meter_readings', $rez);
  847.         return $response;
  850.     }
  852.         /** Отримати Історію показників лічильника {} */
  854.     #[Route('/api/get-meter-readings-history', name: 'get_meter_readings_history')]
  855.     public function get_meter_readings_history(Request $request)
  856.     {
  857.         file_put_contents('/var/www/symfony_docker/var/log/log.txt', date('Y-m-d H:i:s') . "get_meter_readings_history: " . $request->getContent() . "\n", FILE_APPEND);
  858.         // echo '<pre>';
  859.         $data = json_decode($request->getContent(), true);
  860.         // $data = [
  861.         //     'user' => 31,
  862.         //     'account' => '0900015104',
  863.         // ];
  864.         $logId = $this->logHistory->save(false, 'get_meter_readings_history', $data);
  865.         
  866.         
  867.         $valid = $this->valid( $data, ['account', 'user'] );
  870.         if( empty($valid) ){
  871.             $isUserData = $this->isUserData($data['user'], $data['account']);
  872.             file_put_contents('/var/www/symfony_docker/var/log/log.txt', date('Y-m-d H:i:s') . "1111\n", FILE_APPEND);
  873.             if( $isUserData['rezult'] ){
  875.                 $accountNumber = $data['account'];
  876.                 $data = [
  877.                     'method' => 'get-meter-readings-history',
  878.                     'data' => [
  879.                         'account' => $data['account'],
  880.                     ],
  881.                 ]; 
  882.                 file_put_contents('/var/www/symfony_docker/var/log/log.txt', date('Y-m-d H:i:s') . "22222\n", FILE_APPEND);
  883.                 $rezult = json_decode( $this->appApiService->get($data) , true );
  884.                 file_put_contents('/var/www/symfony_docker/var/log/log.txt', date('Y-m-d H:i:s') . "33333\n", FILE_APPEND);
  885.                 if($rezult['rez'] AND isset($rezult['data']) ){
  886.                     $user = $this->security->getUser();
  887.                     $rez = json_decode($rezult['data'], true);  
  888.                     $lastAnswerDate = new \DateTime( );
  889.                     file_put_contents('/var/www/symfony_docker/var/log/log.txt', date('Y-m-d H:i:s') . "4444444\n", FILE_APPEND);
  890.                     foreach($user->getAppPersonalAccounts() as $acc){
  891.                         if( $acc->getNumber() == $accountNumber){ 
  892.                             if(!empty($rez)){
  893.                                 $acc->setLastHistoryCounterDate( new \DateTime() );
  894.                                 $acc->setLastHistoryCounter( $rez);
  895.                             }else{
  896.                                 $rez = $acc->getLastHistoryCounter();
  897.                                 $lastAnswerDate = $acc->getLastHistoryCounterDate();
  898.                                 if(empty($rez)){
  899.                                     $rez = [];
  900.                                     $lastAnswerDate = new \DateTime( );
  901.                                 }
  902.                             }
  903.                             // $acc->setLastHistoryCounter()
  905.                         }
  906.                     }
  907.                     file_put_contents('/var/www/symfony_docker/var/log/log.txt', date('Y-m-d H:i:s') . "555555\n", FILE_APPEND);
  908.                     
  909.                     $rez = [
  910.                         'rezult' => true, 
  911.                         'data' => $rez,
  912.                         'lastAnswerDate' => $lastAnswerDate->format('Y-m-d H:i:s'),
  913.                     ]; 
  914.                 }else{
  915.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  916.                 }
  917.             }else{
  918.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];   
  919.             }
  920.         }else{
  921.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  922.         }
  923.         file_put_contents('/var/www/symfony_docker/var/log/log.txt', date('Y-m-d H:i:s') . "666666\n", FILE_APPEND);
  924.         $response = new JsonResponse();
  925.         $response->setData($rez);
  927.         $this->logHistory->save($logId, 'get_meter_readings_history', $rez);
  929.         file_put_contents('/var/www/symfony_docker/var/log/log.txt', date('Y-m-d H:i:s') . "77777\n", FILE_APPEND);
  931.         return $response;
  934.     }
  937.     #[Route('/api/cron-set-meter-readings', name: 'cron_set_meter_readings')]
  938.     public function cron_set_meter_readings(Request $request)
  939.     {
  940.         $AppCounterReading = $this->entityManager->getRepository(AppCounterReading::class)->findBy(['status' => 'new']);
  941.         if(count($AppCounterReading) > 0){
  942.             $Ids = array_map(fn($n) => $n->getId(), $AppCounterReading);
  943.             // Масове оновлення статусу та дати
  944.             $this->entityManager->createQuery(
  945.                 'UPDATE App\Entity\AppCounterReading n
  946.                 SET n.status = :newStatus, 
  947.                     n.date_send = :now 
  948.                 WHERE n.id IN (:ids)'
  949.             )
  950.             ->setParameter('newStatus', 'in_progress')
  951.             ->setParameter('now', new \DateTime())
  952.             ->setParameter('ids', $Ids)
  953.             ->execute();
  954.         }
  955.         $i = 0;
  956.         foreach($AppCounterReading as $counterReding){
  957.             $p =  $counterReding->getPersonal()->getOwner()->getPhone();
  958.             $p = str_replace('+', '', $p);
  959.             $data =  [
  960.                 'method' => 'set-meter-readings',
  961.                 'data' => [
  962.                     'phone' => $p,
  963.                     'app_user_id' => $counterReding->getPersonal()->getOwner()->getId(),
  964.                     'account' => trim($counterReding->getPersonal()->getNumber()),
  965.                     'number_of_scale' => $counterReding->getPersonal()->getNumberOfScale(),
  966.                     'reading1' => $counterReding->getValue(),
  967.                     'reading2' => $counterReding->getValue2(),
  968.                     'reading3' => $counterReding->getValue3(),
  969.                 ]
  970.             ];
  972.             $rezult = json_decode( $this->appApiService->get($data) , true );
  973.             if($rezult['rez']){
  975.                 $counterReding->setDateSend(new \DateTime());
  976.                 $counterReding->setStatus('complate');
  978.                 $this->entityManager->persist($counterReding);
  979.                 $this->entityManager->flush();
  981.                 $i++;  
  982.             }else{
  983.                 $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  984.                 $counterReding->setStatus('error');
  985.                 $counterReding->setDescription($rezult['err_msg']);
  987.                 $this->entityManager->persist($counterReding);
  988.                 $this->entityManager->flush();
  989.             }
  990.         }
  991.        
  992.        
  993.        
  994.        
  995.         $rez = ['count' => count($AppCounterReading)];
  996.         $response = new JsonResponse();
  997.         $response->setData($rez);
  999.         return $response;
  1001.     }
  1004.     /** Відправка показників лічильника { "user": "31", "account":"0900015104", "number_of_scale":"3", "reading1":"1234", "reading2":"0", "reading3":"0" } */   
  1005.     #[Route('/api/set-meter-readings', name: 'set_meter_readings')]
  1006.     public function set_meter_readings(Request $request)
  1007.     {
  1008.    
  1009.         $data = json_decode($request->getContent(), true);
  1011.         $logId = $this->logHistory->save(false, 'set_meter_readings', $data);
  1012.         
  1013.         
  1014.         $valid = $this->valid( $data, ['account', 'user', 'number_of_scale', 'reading1', 'reading2', 'reading3'] );
  1015.         if( empty($valid)  ){
  1016.             $isUserData = $this->isUserData($data['user'], $data['account']);
  1017.             if( $isUserData['rezult'] ){
  1018.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  1019.                 if($find){
  1020.                     $data =  [
  1021.                         'method' => 'set-meter-readings',
  1022.                         'data' => [
  1023.                             'phone' => $find->getPhone(),
  1024.                             'app_user_id' => $find->getId(),
  1025.                             'account' => $data['account'],
  1026.                             'number_of_scale' => $data['number_of_scale'],
  1027.                             'reading1' => $data['reading1'],
  1028.                             'reading2' => $data['reading2'],
  1029.                             'reading3' => $data['reading3'],
  1030.                         ]
  1031.                     ];
  1033.                     $rezult = json_decode( $this->appApiService->get($data) , true );
  1034.                     if($rezult['rez']){
  1035.                         $rez = [
  1036.                             'rezult' => true, 
  1037.                             'message' => 'Дані відправлено!',
  1038.                         ];   
  1039.                     }else{
  1040.                         $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  1041.                     }
  1042.                 }else{
  1043.                     $rez = ['rezult' => false, 'error' => 'Користувача не знайдено!'];   
  1044.                 }
  1045.             }else{
  1046.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];
  1047.             }
  1048.         }else{
  1049.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  1050.         }
  1052.         $response = new JsonResponse();
  1053.         $response->setData($rez);
  1055.         $this->logHistory->save($logId, 'set_meter_readings', $rez);
  1056.         return $response;
  1059.     }
  1061.     /** Заявка на відновлення електропостачання { "user": 31, "account": "0900015104", "eic": "36457", "dno_id": "1", "when_off": "2024-08-01 14:30", "pib": "Іваненко Іван Іванович", "phone": "380xxxxxxxxx", "eic_count": "1" } */
  1062.     #[Route('/api/set-no-light-request', name: 'set_no_light_request')]
  1063.     public function set_no_light_request(Request $request)
  1064.     {
  1065.         // echo '<pre>';
  1066.         $data = json_decode($request->getContent(), true);
  1067.         // $data = [
  1068.         //     'user' => 31,
  1069.         //     'account' => '0900015104',
  1070.         //     'phone' => '380xxxxxxxxx',
  1071.         //     'voltage' => '123',
  1072.         //     'voltage_susidy' => 'Так',
  1073.         //     'media' => 2
  1074.         //     // 'imageFile' => new CURLFile(realpath(__DIR__) . '/11.png'),
  1075.         // ];
  1076.         $logId = $this->logHistory->save(false, 'set_no_light_request', $data);
  1077.         
  1078.         
  1079.         $valid = $this->valid( $data, ['account', 'eic', 'user', 'dno_id', 'when_off', 'pib', 'phone', 'eic_count'] );
  1082.         if( empty($valid) ){
  1083.             $isUserData = $this->isUserData($data['user'], $data['account']);
  1084.             if( $isUserData['rezult'] ){
  1085.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  1086.                 $accountNumber = trim($data['account']);
  1087.                 $account = false;
  1088.                 if($find){
  1089.                     $permission = json_decode( $this->appApiService->check_last_register_no_power($data['account']) , true); 
  1090.                 
  1091.                     if(!$permission['rez'] AND $permission['dozvil'] !== true){
  1092.                         // print_r( $permission); die;
  1093.                         return new JsonResponse(['rezult' => false,'error' => $permission['err_msg']], 404);
  1094.                     }
  1095.                     // var_dump( $permission);
  1096.                     // die;
  1097.                     $data =  [
  1098.                         'method' => 'set-no-light-request',
  1099.                         'data' => [
  1100.                             'account' => $accountNumber,
  1101.                             'app_user_id' => $find->getId(),
  1102.                             'eic' => $data['eic'],
  1103.                             'dno_id' => $data['dno_id'],
  1104.                             'when_off' => $data['when_off'],
  1105.                             'pib' => $data['pib'],
  1106.                             'phone' => $data['phone'],
  1107.                             'eic_count' => $data['eic_count'],
  1108.                         ],
  1109.                     ];
  1111.                     
  1113.                     $rezult = json_decode( $this->appApiService->get($data) , true );
  1114.                     if(isset($rezult['rez']) AND $rezult['rez']){
  1115.                         foreach($find->getAppPersonalAccounts() as $acc){
  1116.                             if(trim( $acc->getNumber() ) == $accountNumber)
  1117.                                 $account = $acc;
  1118.                         }
  1120.                         if($account){
  1121.                             $ServiceOrderHistory = new ServiceOrderHistory();
  1122.                             $ServiceOrderHistory->setName('Заявка про відсутність електроенерії');
  1123.                             $ServiceOrderHistory->setDateEntered( new \DateTime() );
  1124.                             $ServiceOrderHistory->setType('set-no-light-request');
  1125.                             $ServiceOrderHistory->setStatus('new');
  1126.                             $ServiceOrderHistory->setPersonalAccount($account);
  1127.                             $this->entityManager->persist($ServiceOrderHistory);
  1128.                             $this->entityManager->flush();
  1129.                         }
  1130.                         $rez = [
  1131.                             'rezult' => true, 
  1132.                             'message' => 'Дані відправлено!',
  1133.                             // 'account' => $rezult['account'],
  1134.                         ];   
  1135.                     }else{
  1136.                         $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  1137.                     }
  1138.                 }else{
  1139.                     $rez = ['rezult' => false, 'error' => 'Користувача не знайдено!'];   
  1140.                 }
  1141.             }else{  
  1142.                 $rez = ['rezult' => false, 'error' => $isUserData['error']];
  1143.             }
  1144.         }else{
  1145.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  1146.         }
  1148.         $response = new JsonResponse();
  1149.         $response->setData($rez);
  1151.         $this->logHistory->save($logId, 'set_no_light_request', $rez);
  1155.         return $response;
  1158.     }
  1160.     /** Отримати всі акаунти по номеру телефону { "phone": "380xxxxxxxxx", "bot_type": "telegram" } */
  1161.     #[Route('/api/get-all-accounts-by-phone', name: 'get_all_accounts_by_phone')]
  1162.     public function get_all_accounts_by_phone(Request $request)
  1163.     {
  1164.         $data = json_decode($request->getContent(), true);
  1165.       
  1166.         $logId = $this->logHistory->save(false, 'get_all_accounts_by_phone', $data);
  1167.         
  1168.         
  1169.         $valid = $this->valid( $data, ['phone', 'bot_type'] );
  1172.         if( empty($valid) ){
  1174.             $user = $this->security->getUser();
  1175.             if($user and $user->getPhone() == $data['phone']){
  1176.                 // ok
  1177.             
  1178.                 $data =  [
  1179.                     'method' => 'get-all-accounts-by-phone',
  1180.                     'data' => [
  1181.                         'phone' => $data['phone'],
  1182.                         'bot_type' => $data['bot_type'],
  1183.                     ],
  1184.                 ];
  1186.                 $rezult = json_decode( $this->appApiService->get($data) , true );
  1187.                 
  1188.                 if($rezult['rez']){
  1189.                     $rez = [
  1190.                         'rezult' => true, 
  1191.                         'accounts' => $rezult['accounts']
  1192.                     ];   
  1193.                 }else{
  1194.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  1195.                 }
  1196.             }else{
  1197.                 $rez = ['rezult' => false, 'error' => "Користувача не знайдено або номер телефону не співпадає!"];   
  1198.             }
  1199.             
  1200.         }else{
  1201.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  1202.         }
  1204.         $response = new JsonResponse();
  1205.         $response->setData($rez);
  1207.         $this->logHistory->save($logId, 'get_all_accounts_by_phone', $rez);
  1211.         return $response;
  1214.     }
  1217.     /** Створення особового рахунку юридичної особи { "eic": "36457", "edrpou": "12345678", "name": "ТОВ Ромашка", "owner": "31" } */
  1218.     #[Route('/api/yur-create-personal-account', name: 'yurCreatePersonalAccount')]
  1219.     public function yurCreatePersonalAccount(Request $request)
  1220.     {
  1221.         $data = json_decode($request->getContent(), true);
  1222.         $logId = $this->logHistory->save(false, 'yurCreatePersonalAccount', $data);
  1224.         $valid = $this->valid( $data, ['eic', 'edrpou', 'name', 'owner'] );
  1225.         if( empty($valid) ){
  1226.             $isUserData = $this->isUserData($data['owner'], false);
  1227.                 if( $isUserData['rezult'] ){
  1228.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['owner']]);
  1229.                 if($find){
  1230.                     $data = ['eic' => $data['eic'], 'app_user_id' => $find->getId(), 'edrpou' => $data['edrpou'],'name' => $data['name']];                    
  1231.                     $res = json_decode( $this->appApiService->YurCheckPersonalAccount($data) , true );
  1232.                     $name = (!empty($data['name'])) ? $data['name'] : $data['eic'];
  1233.                     if(isset($res['rez']) AND $res['rez']  AND $res['correct_data']){
  1234.                         $personal = new AppPersonalAccount();
  1235.                         $personal->setOwner($find);
  1236.                         $personal->setNumber(trim( $data['eic'] ));
  1237.                         $personal->setName($name);
  1238.                         $personal->setNumberOfScale(0);
  1239.                         $personal->setActive(true);
  1240.                         $personal->setIsMain(true);
  1241.                         $personal->setDateEntered($this->datetime);
  1242.                         $personal->setType('factory');
  1243.                         $personal->setEic($data['eic']);
  1244.                         $personal->setNotificationStatus('disabled');
  1245.                         $this->entityManager->persist($personal);
  1246.                         $this->entityManager->flush();
  1248.                         foreach($res['data'] as $res_data){
  1249.                             $accounts = $this->entityManager->getRepository(Accounts::class)->findOneBy(['number' => $res_data['acc'], 'eic' => $res_data['eic_kod']]);
  1250.                             if(!$accounts){
  1251.                                 $accounts = new Accounts();
  1252.                                 $accounts->setNumber(trim( $res_data['acc'] ));
  1253.                                 $accounts->setEic($res_data['eic_kod']);
  1254.                                 $accounts->setEicParent($res_data['eic_kod_place']);
  1255.                                 $this->entityManager->persist($accounts);
  1256.                                 $this->entityManager->flush();
  1257.                             }
  1259.                             $personalChild = new AppPersonalAccount();
  1260.                             $personalChild->setOwner($find);
  1261.                             $personalChild->setNumber(trim( $res_data['acc'] ));
  1262.                             $personalChild->setName($res_data['name']);
  1263.                             $personalChild->setCounter($res_data['counter']);
  1264.                             $personalChild->setNumberOfScale(0);
  1265.                             $personalChild->setActive(true);
  1266.                             $personalChild->setIsMain(false);
  1267.                             $personalChild->setIsShow(true);
  1268.                             $personalChild->setDateEntered($this->datetime);
  1269.                             $personalChild->setType('factory');
  1270.                             $personalChild->setEic($res_data['eic_kod']);
  1271.                             $personalChild->setParent($personal);
  1273.                             $fullAdresses = $res_data['city_name'] . ' ' . $res_data['street_name'] . ' ' . $res_data['building_name'];
  1274.                             $personalChild->setFullAddress($fullAdresses);
  1275.                             $personalChild->setCity($res_data['city_name']);
  1276.                             $personalChild->setStreet($res_data['street_name']);
  1277.                             $personalChild->setBuilding($res_data['building_name']);
  1278.                             $personalChild->setMainFullAddress($fullAdresses);
  1279.                             $personalChild->setNotificationStatus('active');
  1282.                             $this->entityManager->persist($personalChild);
  1283.                             $this->entityManager->flush();
  1284.                         }
  1288.                         
  1290.                         $rez = [
  1291.                             'registered' => true,
  1292.                             'id' => $personal->getId(),
  1293.                             
  1294.                         ];
  1295.                     }else{
  1296.                         $rez = ['registered' => false, $res];
  1297.                     }
  1298.                 }else{
  1299.                     $rez = ['registered' => false];
  1300.                 }
  1301.             }else{
  1302.                 $rez = ['registered' => false, 'error' => $isUserData['error']];
  1303.             }
  1304.         }else{
  1305.             $rez = ['registered' => false, 'error' => "Не задано поля: $valid"];
  1306.         }
  1310.         
  1311.         
  1312.     
  1313.         $response = new JsonResponse();
  1314.         $response->setData($rez);
  1316.         $this->logHistory->save($logId, 'yurCreatePersonalAccount', $rez);
  1320.         return $response;
  1321.     }
  1324.     #[Route('/api/service_order_histories/last', name: 'service_order_history_last', methods: ['GET'])]
  1325.     public function getLastByFilter(
  1326.         Request $request,
  1327.         ServiceOrderHistoryRepository $repository,
  1328.         SerializerInterface $serializer,
  1329.     ): JsonResponse {
  1330.         $type   = $request->query->get('type');
  1331.         $number = $request->query->get('number');
  1333.         if (!$type || !$number) {
  1334.             return new JsonResponse([
  1335.                 'error' => 'Parameters "type" and "number" are required',
  1336.             ], 400);
  1337.         }
  1339.         $qb = $repository->createQueryBuilder('h')
  1340.             ->leftJoin('h.personalAccount', 'pa')
  1341.             ->andWhere('h.type = :type')
  1342.             ->andWhere('pa.number = :number') // ⚠️ якщо інше поле — зміни тут
  1343.             ->setParameter('type', $type)
  1344.             ->setParameter('number', $number)
  1345.             ->orderBy('h.dateEntered', 'DESC')
  1346.             ->setMaxResults(1);
  1348.         $result = $qb->getQuery()->getOneOrNullResult();
  1350.         if (!$result) {
  1351.             return new JsonResponse([], 200);
  1352.         }
  1354.         return new JsonResponse(
  1355.             $serializer->serialize(
  1356.                 $result,
  1357.                 'json',
  1358.                 ['groups' => ['service_history:read']]
  1359.             ),
  1360.             200,
  1361.             [],
  1362.             true
  1363.         );
  1364.     }
  1367.     #[Route('/api/pw_cities', name: 'pw_cities', methods: ['GET'])]
  1368.     public function pw_cities(
  1369.         Request $request
  1371.     ): JsonResponse {
  1372.         $request = $request->query->all();
  1374.         $result = $this->powerOn->sendCurl($request, '/api/pw_cities');
  1376.         return new JsonResponse(
  1377.             $result,
  1378.             200,
  1379.             [],
  1380.             true
  1381.         );
  1382.     }
  1384.     #[Route('/api/pw_otgs', name: 'pw_otgs', methods: ['GET'])]
  1385.     public function pw_otgs(
  1386.         Request $request
  1388.     ): JsonResponse {
  1390.         $request = $request->query->all();
  1391.         // echo '<pre>';
  1392.         // print_r($request);
  1393.         // die;
  1395.         $result = $this->powerOn->sendCurl($request, '/api/pw_otgs');
  1397.         return new JsonResponse(
  1398.             $result,
  1399.             200,
  1400.             [],
  1401.             true
  1402.         );
  1403.     }
  1406.     /**
  1407.      * pagination:false
  1408.      * city.id: 851
  1409.      */
  1411.     #[Route('/api/pw_streets', name: 'pw_streets', methods: ['GET'])]
  1412.     public function pw_streets(
  1413.         Request $request
  1415.     ): JsonResponse {
  1417.         $request = $request->query->all();
  1418.         
  1420.         $result = $this->powerOn->sendCurl($request, '/api/pw_streets');
  1422.         return new JsonResponse(
  1423.             $result,
  1424.             200,
  1425.             [],
  1426.             true
  1427.         );
  1428.     }
  1429.     /** 
  1430.      * pagination: false
  1431.      * city.id: 851
  1432.      * street.id: 7815
  1433.      * 
  1434.      */
  1436.     #[Route('/api/pw_accounts', name: 'pw_accounts', methods: ['GET'])]
  1437.     public function pw_accounts(
  1438.         Request $request
  1440.     ): JsonResponse {
  1442.         $request = $request->query->all();
  1444.         $result = $this->powerOn->sendCurl($request, '/api/pw_accounts');
  1446.         return new JsonResponse(
  1447.             $result,
  1448.             200,
  1449.             [],
  1450.             true
  1451.         );
  1452.     }
  1455.     // #[Route('/api/pw_accounts', name: 'pw_accounts', methods: ['GET'])]
  1456.     // public function pw_accounts(
  1457.     //     Request $request
  1459.     // ): JsonResponse {
  1460.     //     // /api/pw_accounts_all_data
  1462.     //     $request = $request->query->all();
  1464.     //     $result = $this->powerOn->sendCurl($request, '/api/pw_accounts');
  1466.     //     return new JsonResponse(
  1467.     //         $result,
  1468.     //         200,
  1469.     //         [],
  1470.     //         true
  1471.     //     );
  1472.     // }
  1474.     #[Route('/api/create-personal-account-address', name: 'createPersonalAccountAddress')]
  1475.     public function createPersonalAccountAddress(Request $request)
  1476.     {
  1478.         // 473629
  1479.         $data = json_decode($request->getContent(), true);
  1480.         $logId = $this->logHistory->save(false, 'create-personal-account-address', $data);
  1481.         $valid = $this->valid( $data, ['account',  'owner', 'full_address'] ); 
  1482.         if( empty($valid) ){
  1483.             $isUserData = $this->isUserData($data['owner']);
  1484.             if( $isUserData['rezult'] ){
  1485.                 $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['owner']]);
  1486.                 if($find){
  1487.                     $number = trim( $data['account'] );
  1488.                     $name =  isset($data['name']) ? trim( $data['name'] ) : '';
  1489.                         $d = [
  1490.                             'account' => $number
  1491.                         ];
  1492.                         $res = json_decode( $this->powerOn->sendPost($d, '/api/pw_accounts_all_data') , true );  
  1493.                         if(isset($res['res']) AND $res['res']){
  1495.                             if(isset($res['data'])){
  1497.                                 $personal = $this->entityManager->getRepository(AppPersonalAccount::class)->findOneBy(['number' => $res['data']['acc'], 'owner' => $find]);
  1498.                                 if(!$personal){
  1499.                                     
  1501.                                     $name = (!empty($name)) ? $name : $number;
  1502.                                     $accounts = $this->entityManager->getRepository(Accounts::class)->findOneBy(['number' => $res['data']['acc']]);
  1503.                                     if(!$accounts){
  1504.                                         $accounts = new Accounts();
  1505.                                         $accounts->setNumber($res['data']['acc']);
  1506.                                         $accounts->setEic($res['data']['eicKod']);
  1507.                                         $this->entityManager->persist($accounts);
  1508.                                         $this->entityManager->flush();
  1509.                                     }
  1510.                                     $personal = new AppPersonalAccount();
  1511.                                     $personal->setOwner($find);
  1512.                                     $personal->setNumber($res['data']['acc']);
  1513.                                     $personal->setName($name);
  1514.                                     $personal->setActive(true);
  1515.                                     $personal->setIsMain(true);
  1516.                                     $personal->setFullAddress($data['full_address']);
  1517.                                     $personal->setCity($res['data']['city']);
  1518.                                     $personal->setStreet($res['data']['street']);
  1519.                                     $personal->setBuilding($res['data']['buildingName']);
  1520.                                     $personal->setMainFullAddress($data['full_address']);
  1521.                                     $personal->setEic($res['data']['eicKod']);
  1522.                                     $personal->setDateEntered($this->datetime);
  1523.                                     $personal->setType('address');
  1524.                                     $personal->setAccounts($accounts);
  1525.                                     $personal->setNotificationStatus('active');
  1526.                                     $this->entityManager->persist($personal);
  1527.                                     $this->entityManager->flush();
  1528.                                      $rez = [
  1529.                                         'registered' => true,
  1530.                                         'id' => $personal->getId(),
  1531.                                         'full_address' => $personal->getFullAddress()
  1532.                                     ];
  1533.                                 }else{
  1534.                                     $rez = [
  1535.                                         'registered' => false,
  1536.                                         'error' => 'Особовий рахунок вже існує!'
  1537.                                     ];
  1538.                                 }
  1539.                             }else{
  1540.                                 $rez = ['registered' => false, 'error' => "Не знайдено даних по адресі!"];
  1541.                             }
  1543.                             
  1544.                         }else{
  1546.                             $rez = ['registered' => false, 'error' => "Нема відповіді сервера!"];
  1547.                         }
  1548.                     
  1549.                 }else{
  1550.                     $rez = ['registered' => false];
  1551.                 }
  1552.                 
  1553.             }else{
  1554.                 $rez = ['registered' => false, 'error' => $isUserData['error']];
  1555.             }
  1556.         }else{
  1557.             $rez = ['registered' => false, 'error' => "Не задано поля: $valid"];
  1558.         }
  1559.         $response = new JsonResponse();
  1560.         $response->setData($rez);
  1562.         $this->logHistory->save($logId, 'create-personal-account-address', $rez);
  1563.         return $response;
  1564.     }
  1568.     
  1571. }