src/Controller/PersonalController.php line 773

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 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\Entity\AppPersonalAccount;
  18. use App\Entity\MediaObject;
  19. use App\Entity\AppCounterReading;
  20. use App\Entity\ServiceOrderHistory;
  21. use App\Entity\Accounts;
  22. use Symfony\Component\HttpKernel\KernelInterface; 
  27. class PersonalController extends AbstractController
  28. {
  29.     public $datetime;
  30.     public $entityManager;
  31.     public $passwordEncoder;
  32.     public $appApiService;
  33.     private $kernel;
  35.     public function __construct( ?\DateTimeInterface $datetime, EntityManagerInterface $entityManager, AppApiService $appApiService, KernelInterface $kernel ){
  36.         $this->datetime = $datetime;
  37.         $this->entityManager = $entityManager;
  38.         $this->appApiService = $appApiService;
  39.         $this->kernel = $kernel;
  40.     }
  42.     public function valid($requestFilds, $requiredFilds){
  43.         $errors = '';
  44.         foreach($requiredFilds as $f){
  45.             if(!isset($requestFilds[$f]))
  46.                 $errors .= " $f"; 
  47.         }
  49.         return $errors;
  50.     }
  52.     public function logHistory($id, $method, $data){
  53.         if(!$id){
  54.             $LogHistoryRequest = new LogHistoryRequest();
  55.             $LogHistoryRequest->setMethod($method);
  56.             $LogHistoryRequest->setRequest($data);
  57.             $LogHistoryRequest->setDate($this->datetime);
  58.             $LogHistoryRequest->setStatus('start');
  59.             $this->entityManager->persist($LogHistoryRequest);
  60.             $this->entityManager->flush();
  62.             return $LogHistoryRequest->getId();
  63.         }else{
  64.             $LogHistoryRequest = $this->entityManager->getRepository(LogHistoryRequest::class)->findOneBy(['id' => $id]);
  65.             if($LogHistoryRequest){
  66.                 $LogHistoryRequest->setStatus('finish');
  67.                 $LogHistoryRequest->setResponseAnswer($data);
  68.                 $this->entityManager->persist($LogHistoryRequest);
  69.                 $this->entityManager->flush();
  70.             }
  71.             return true;
  72.         }
  74.         
  75.     }
  77.     
  78.     #[Route('/api/create-personal-account-bot', name: 'createPersonalAccountBot')]
  79.     public function createPersonalAccountBot(Request $request)
  80.     {
  81.         $data = json_decode($request->getContent(), true);
  82.         $logId = $this->logHistory(false, 'createPersonalAccountBot', $data);
  83.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  85.         $valid = $this->valid( $data, ['accounts', 'method', 'owner'] );
  86.         if( empty($valid) ){
  87.             file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "1111111111111\n", FILE_APPEND);
  88.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['owner']]);
  89.             if($find){
  90.                 file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "2222222222222\n", FILE_APPEND);
  91.                 $resultAccounts = [];
  92.                 foreach($data['accounts'] as $value){
  93.                     $number = array_key_first($value);
  94.                     $name = $value[$number];
  95.                     file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "\n\n\n" .  print_r($name, true) . "\n", FILE_APPEND);
  96.                     $resultAccounts[$number] = false;
  97.                     $data = [
  98.                         'account' => $number
  99.                     ];
  100.                     $res = json_decode( $this->appApiService->account_all_data($data) , true );  
  101.                     if(isset($res['rez']) AND $res['rez'] == 1){
  102.                         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',   print_r($res, true)  . "\n", FILE_APPEND);
  103.                         if(isset($res['data']) AND count($res['data']) > 0){
  104.                             $name = (!empty($name)) ? $name : $number;
  105.                             $accounts = $this->entityManager->getRepository(Accounts::class)->findOneBy(['number' => $number]);
  106.                             if(!$accounts){
  107.                                 $accounts = new Accounts();
  108.                                 $accounts->setNumber($number);
  109.                                 $accounts->setEic($res['data'][0]['eic_kod']);
  110.                                 $this->entityManager->persist($accounts);
  111.                                 $this->entityManager->flush();
  112.                             }
  113.                             $personal = new AppPersonalAccount();
  114.                             $personal->setOwner($find);
  115.                             $personal->setNumber($number);
  116.                             $personal->setName($name);
  117.                             $personal->setNumberOfScale((int) $res['data'][0]['number_of_scale']);
  118.                             $personal->setActive(true);
  119.                             $personal->setIsMain(true);
  120.                             $personal->setFullAddress($res['data'][0]['name']);
  121.                             $personal->setCity($res['data'][0]['city_name']);
  122.                             $personal->setStreet($res['data'][0]['street_name']);
  123.                             $personal->setBuilding($res['data'][0]['building_name']);
  124.                             // $personal->setRoom($res['room']);
  125.                             $personal->setMainFullAddress($res['data'][0]['name']);
  126.                             $personal->setEic($res['data'][0]['eic_kod']);
  127.                             $personal->setDateEntered($this->datetime);
  128.                             $personal->setType('person');
  129.                             $personal->setAccounts($accounts);
  130.                             $personal->setCounter($res['data'][0]['counter']);
  131.                             $this->entityManager->persist($personal);
  132.                             $this->entityManager->flush();
  134.                             $resultAccounts[$number] = true;
  136.                         }
  137.                     }  
  138.                     $rez = [
  139.                         'registered' => true,
  140.                         'registerAccounts' => $resultAccounts
  141.                     ];
  142.                 }
  143.             }else{
  144.                 $rez = ['registered' => false];
  145.             }
  147.         }else{
  148.             $rez = ['registered' => false, 'error' => "Не задано поля: $valid"];
  149.         }
  150.         $response = new JsonResponse();
  151.         $response->setData($rez);
  153.         $this->logHistory($logId, 'check-user', $rez);
  154.         return $response;
  155.     }
  157.     #[Route('/api/create-personal-account', name: 'createPersonalAccount')]
  158.     public function createPersonalAccount(Request $request)
  159.     {
  160.         $data = json_decode($request->getContent(), true);
  161.         $logId = $this->logHistory(false, 'createPersonalAccount', $data);
  162.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  164.         $valid = $this->valid( $data, ['account', 'method', 'value'] );
  165.         if( empty($valid) ){
  166.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['owner']]);
  167.             if($find){
  168.                 $data = ['account' => $data['account'], 'app_user_id' => $find->getId(), 'check_method' => $data['method'], 'check_value' => $data['value'], 'name' => $data['name']];
  169.                 file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  print_r($data, true) . "\n", FILE_APPEND);
  170.                 $res = json_decode( $this->appApiService->checkPersonalAccount($data) , true );
  171.                 file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  print_r($res, true) . "\n", FILE_APPEND);
  172.                 $name = (!empty($data['name'])) ? $data['name'] : $data['account'];
  173.                 // var_dump($res); die;
  174.                 if(isset($res['account_ok']) AND $res['account_ok'] ){
  175.                     $accounts = $this->entityManager->getRepository(Accounts::class)->findOneBy(['number' => $data['account']]);
  176.                     if(!$accounts){
  177.                         $accounts = new Accounts();
  178.                         $accounts->setNumber($data['account']);
  179.                         $accounts->setEic($res['eic']);
  180.                         $this->entityManager->persist($accounts);
  181.                         $this->entityManager->flush();
  182.                     }
  184.                     $personal = new AppPersonalAccount();
  185.                     $personal->setOwner($find);
  186.                     $personal->setNumber($data['account']);
  187.                     $personal->setName($name);
  188.                     $personal->setNumberOfScale((int) $res['number_of_scale']);
  189.                     $personal->setActive(true);
  190.                     $personal->setIsMain(true);
  191.                     $personal->setFullAddress($res['full_address']);
  192.                     $personal->setCity($res['city']);
  193.                     $personal->setStreet($res['street']);
  194.                     $personal->setBuilding($res['building']);
  195.                     $personal->setRoom($res['room']);
  196.                     $personal->setMainFullAddress($res['full_address']);
  197.                     $personal->setEic($res['eic']);
  198.                     $personal->setDateEntered($this->datetime);
  199.                     $personal->setType('person');
  200.                     $personal->setAccounts($accounts);
  201.                     $personal->setCounter($res['counter']);
  202.                     $this->entityManager->persist($personal);
  203.                     $this->entityManager->flush();
  204.                     $rez = [
  205.                         'registered' => true,
  206.                         'id' => $personal->getId(),
  207.                         'name' => $personal->getName(),
  208.                         'number' => $personal->getNumber(),
  209.                         'numberOfScale' => $personal->getNumberOfScale(),
  210.                         'fullAddress' => $personal->getFullAddress(),
  211.                         'city' => $personal->getCity(),
  212.                         'street' => $personal->getStreet(),
  213.                         'building' => $personal->getBuilding(),
  214.                         'room' => $personal->getRoom(),
  215.                         'mainFullAddress' => $personal->getMainFullAddress(),
  216.                         'account' => [
  217.                             'statusLight' => $accounts->getStatusLight(),
  218.                             'statusPlanning' => $accounts->getStatusPlanning(),
  219.                         ]
  220.                     ];
  221.                 }else{
  222.                     $rez = ['registered' => false, $res];
  223.                 }
  224.             }else{
  225.                 $rez = ['registered' => false];
  226.             }
  228.         }else{
  229.             $rez = ['registered' => false, 'error' => "Не задано поля: $valid"];
  230.         }
  234.         
  235.         
  236.     
  237.         $response = new JsonResponse();
  238.         $response->setData($rez);
  240.         $this->logHistory($logId, 'check-user', $rez);
  244.         return $response;
  245.     }
  247.     #[Route('/api/create-personal-account_test', name: 'createPersonalAccountTest')]
  248.     public function createPersonalAccountTest(Request $request)
  249.     {
  250.         $data = json_decode($request->getContent(), true);
  253.         // $data = ['account' => '0900015104', 'check_method' => 'by_name', 'check_value' => 'Подолюк'];
  254.         $res = json_decode( $this->appApiService->checkPersonalAccount($data) , true );
  255.         var_dump($res); die;
  256.         
  257.     }
  259.     #[Route('/api/check-light', name: 'check_light')]
  260.     public function check_light(Request $request)
  261.     {
  263.         $data = json_decode($request->getContent(), true);
  264.         $logId = $this->logHistory(false, 'check_light', $data);
  265.         $valid = $this->valid( $data, ['account', 'user'] );
  266.         if( empty($valid) ){
  267.             $data =  [
  268.                     'method' => 'check-light',
  269.                     'data' => [
  270.                         'account' => $data['account'],
  271.                         // 'eic'     => '36457',
  272.                 ],
  273.             ];
  274.             $rezult = json_decode( $this->appApiService->get($data) , true );
  275.             file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  print_r($rezult, true) . "\n", FILE_APPEND);
  276.             if($rezult['rez']){
  277.                 $rez = [
  278.                     'rezult' => true, 
  279.                     'іs_included_disconnection_task' => (isset( $rezult['іs_included_disconnection_task']) ) ? $rezult['іs_included_disconnection_task'] : 0,
  280.                     'reazon' => (isset( $rezult['reazon']) ) ? $rezult['reazon'] : '', 
  281.                     'reazon_yur' => (isset( $rezult['reazon_yur']) ) ? $rezult['reazon_yur']: ''    ,
  282.                     'owner_adress' => $rezult['owner_adress'],
  283.                     'light' => $rezult['light'],
  284.                     'date' => $rezult['date'],
  285.                     'diff_eic_count' => $rezult['diff_eic_count'],
  286.                     'eic' => $rezult['eic'],
  287.                     'dno_id' => $rezult['dno_id'],
  288.                     'disconnect_warning_guid' =>  (isset( $rezult['disconnect_warning_guid']))?$rezult['disconnect_warning_guid'] : '',
  289.                 ];   
  290.             }else{
  291.                 $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  292.             }
  293.         }else{
  294.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  295.         }
  297.         $response = new JsonResponse();
  298.         $response->setData($rez);
  300.         $this->logHistory($logId, 'check-user', $rez);
  304.         return $response;
  307.     }
  311.     #[Route('/api/get-group-gpv', name: 'get_group_gpv')]
  312.     public function get_group_gpv(Request $request)
  313.     {
  315.         $data = json_decode($request->getContent(), true);
  316.         $logId = $this->logHistory(false, 'get_group_gpv', $data);
  317.         $valid = $this->valid( $data, ['account', 'user'] );
  318.         if( empty($valid) ){
  319.             $data =  [
  320.                     'method' => 'get-group-gpv',
  321.                     'data' => [
  322.                         'account' => $data['account'],
  323.                         // 'eic'     => '36457',
  324.                 ],
  325.             ];
  326.             $rezult = json_decode( $this->appApiService->get($data) , true );
  327.             if($rezult['rez']){
  328.                 $rez = [
  329.                     'rezult' => true, 
  330.                     'rem_name' => $rezult['rem_name'],
  331.                     'odg_name' => $rezult['odg_name'],
  332.                     'cherg_gav' => $rezult['cherg_gav'],
  333.                     'cherg_achr' => $rezult['cherg_achr'],
  334.                     'cherg_gvsp' => $rezult['cherg_gvsp'],
  335.                     'cherg_sgav' => $rezult['cherg_sgav'],
  336.                     'cherg_gpv' => $rezult['cherg_gpv'],
  337.                 ];   
  338.             }else{
  339.                 $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  340.             }
  341.         }else{
  342.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  343.         }
  345.         $response = new JsonResponse();
  346.         $response->setData($rez);
  348.         $this->logHistory($logId, 'check-user', $rez);
  352.         return $response;
  355.     }
  357.     #[Route('/api/get-scheduled-works', name: 'get_scheduled_works')]
  358.     public function get_scheduled_works(Request $request)
  359.     {
  361.         $data = json_decode($request->getContent(), true);
  362.         $logId = $this->logHistory(false, 'get_group_gpv', $data);
  363.         $valid = $this->valid( $data, ['account', 'user'] );
  364.         if( empty($valid) ){
  365.             $data =  [
  366.                     'method' => 'get-scheduled-works',
  367.                     'data' => [
  368.                         'account' => $data['account'],
  369.                         // 'eic'     => '36457',
  370.                 ],
  371.             ];
  372.             $rezult = json_decode( $this->appApiService->get($data) , true );
  373.             if($rezult['rez']){
  374.                 $rez = [
  375.                     'rezult' => true, 
  376.                     'message' => $rezult['message'],
  377.                     'works' => $rezult['works'],
  378.                 ];   
  379.             }else{
  380.                 $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  381.             }
  382.         }else{
  383.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  384.         }
  386.         $response = new JsonResponse();
  387.         $response->setData($rez);
  389.         $this->logHistory($logId, 'check-user', $rez);
  393.         return $response;
  396.     }
  398.     #[Route('/api/set-low-quality-voltage', name: 'set_low_quality_voltage')]
  399.     public function set_low_quality_voltage(Request $request)
  400.     {
  401.         // echo '<pre>';
  402.         $data = json_decode($request->getContent(), true);
  403.         // $data = [
  404.         //     'user' => 31,
  405.         //     'account' => '0900015104',
  406.         //     'phone' => '380xxxxxxxxx',
  407.         //     'voltage' => '123',
  408.         //     'voltage_susidy' => 'Так',
  409.         //     'media' => 2
  410.         //     // 'imageFile' => new CURLFile(realpath(__DIR__) . '/11.png'),
  411.         // ];
  412.         $logId = $this->logHistory(false, 'set_low_quality_voltage', $data);
  413.         
  414.         
  415.         $valid = $this->valid( $data, ['account', 'user', 'phone', 'voltage', 'voltage_susidy', 'media'] );
  418.         if( empty($valid) ){
  419.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  420.             if($find){
  421.                 $mediaObject = $this->entityManager->getRepository(MediaObject::class)->findOneBy(['id' => $data['media']]);
  423.                 if (!$mediaObject) {
  424.                     return new JsonResponse(['rezult' => false,'error' => 'MediaObject not found'], 404);
  425.                 }
  426.                 // Отримуємо шлях до файлу
  427.                 // $filePath = 'https://api-app.de-svitlo.com.ua' .$mediaObject->getFullPath() ;
  428.                 $filePath = $this->kernel->getProjectDir() . '/public' .$mediaObject->getFullPath() ;
  429.                 // echo "<br> $filePath <br>";
  430.                 $permission = json_decode( $this->appApiService->check_allow_for_low_quality_voltage($data['account']) , true); 
  431.                 if(!$permission['rez'] AND $permission['dozvil'] !== true){
  432.                     // print_r( $permission); die;
  433.                     return new JsonResponse(['rezult' => false,'error' => $permission['err_msg']], 404);
  434.                 }
  435.                 // var_dump( $permission);
  436.                 // die;
  437.                 $data =  [
  438.                     'app_user_id' => $find->getId(),
  439.                     'account' => $data['account'],
  440.                     'phone' => $data['phone'],
  441.                     'voltage' => $data['voltage'],
  442.                     'voltage_susidy' => $data['voltage_susidy'],
  443.                     'imageFile' => new \CURLFile( $filePath ),
  444.                 ];
  446.                 $rezult = json_decode( $this->appApiService->set_low_quality_voltage($data) , true );
  447.                 if($rezult['rez']){
  448.                     $rez = [
  449.                         'rezult' => true, 
  450.                         'message' => 'Дані відправлено!',
  451.                         // 'account' => $rezult['account'],
  452.                     ];   
  453.                 }else{
  454.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  455.                 }
  456.             }else{
  457.                 $rez = ['rezult' => false, 'error' => "Користувача не знайдено!"];   
  458.             }
  459.         }else{
  460.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  461.         }
  463.         $response = new JsonResponse();
  464.         $response->setData($rez);
  466.         $this->logHistory($logId, 'check-user', $rez);
  470.         return $response;
  473.     }
  475.     #[Route('/api/service-order', name: 'service_order')]
  476.     public function service_order(Request $request)
  477.     {
  478.         // echo '<pre>';
  479.         $data = json_decode($request->getContent(), true);
  480.         // $data = [
  481.         //     'user' => 31,
  482.         //     'account' => '0900015104',
  483.         //     'phone' => '380xxxxxxxxx',
  484.         //     'service_code' => '9',
  485.         //     'description' => 'Так',
  486.         //     'media' => [4,5,6]
  487.         //     // 'imageFile' => new CURLFile(realpath(__DIR__) . '/11.png'),
  488.         // ];
  489.         $logId = $this->logHistory(false, 'service-order', $data);
  490.         
  491.         if(isset($data['service_code']) AND (  $data['service_code'] == 63  OR $data['service_code'] == 10 ))
  492.             $valid = $this->valid( $data, ['account', 'user', 'phone', 'service_code', 'description', 'pdf'] );
  493.         else 
  494.             $valid = $this->valid( $data, ['account', 'user', 'phone', 'service_code', 'description', 'media', 'pdf'] );
  496.         if( empty($valid) ){
  497.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  498.             if($find){
  499.                 if($data['service_code'] != 63 AND $data['service_code'] != 10){
  500.                 // $mediaObject = $this->entityManager->getRepository(MediaObject::class)->findOneBy(['id' => $data['media']]);
  501.                     $mediaObjects = $this->entityManager->getRepository(MediaObject::class)->findBy(['id' => $data['media']]);
  502.                     if (!$mediaObjects) {
  503.                         return new JsonResponse(['rezult' => false,'error' => 'MediaObject not found'], 404);
  504.                     }
  505.                 }
  506.                 $pdf = (!empty($data['pdf'])) ? $data['pdf']: false;
  507.                 $data =  [
  508.                     'account' => $data['account'],
  509.                     'app_user_id' => $find->getId(),
  510.                     'phone' => $data['phone'],
  511.                     'service_code' => $data['service_code'],
  512.                     'description' => $data['description'],
  513.                     // 'imageFile' => new \CURLFile( $filePath ),
  514.                 ];
  515.                 $i = 1;
  516.                 if($data['service_code'] != 63 AND $data['service_code'] != 10)
  517.                     foreach($mediaObjects as $k => $mediaObject){
  518.                         $i = $k + 1;
  519.                         $filePath = $this->kernel->getProjectDir() . '/public' .$mediaObject->getFullPath() ;
  520.                         $data["imageFile$i"] = new \CURLFile( $filePath );
  521.                     }
  523.                 if($pdf){
  524.                     if(isset($data["imageFile$i"]))
  525.                         ++$i;
  527.                     $data["imageFile$i"] = new \CURLFile( $this->kernel->getProjectDir() . '/public' . $pdf );
  528.                 }
  531.                 // $filePath = $this->kernel->getProjectDir() . '/public' .$mediaObject->getFullPath() ;
  532.                 // echo "<br> $filePath <br>";
  533.                 // $permission = json_decode( $this->appApiService->check_allow_for_low_quality_voltage($data['account']) , true); 
  534.                 // if(!$permission['rez'] AND $permission['dozvil'] !== true){
  535.                 //     // print_r( $permission); die;
  536.                 //     return new JsonResponse(['rezult' => false,'error' => $permission['err_msg']], 404);
  537.                 // }
  538.                 // var_dump( $permission);
  539.                 // die;
  540.                 // $data =  [
  541.                 //     'account' => $data['account'],
  542.                 //     'phone' => $data['phone'],
  543.                 //     'voltage' => $data['voltage'],
  544.                 //     'voltage_susidy' => $data['voltage_susidy'],
  545.                 //     'imageFile' => new \CURLFile( $filePath ),
  546.                 // ];
  547. /*
  548. const serviceCodesArr = [
  549.       { service_code: 9, label: "Встановлення зонного лічильника" },
  550.       { service_code: 10, label: "Лічильник не працює" },
  551.       { service_code: 21, label: "Неправильний показ" },
  552.       { service_code: 32, label: "Зміна власника" },
  553.       { service_code: 35, label: "Підключення електроустановок замовника після виконання ТУ" },
  554.       { service_code: 63, label: "Звернення щодо підозри на крадіжку" },
  555.       { service_code: 79, label: "Заміна автоматичного вимикача, який опломбований ОСР" },
  556.       { service_code: 85, label: "Відсутність пломб на засобі обліку" },
  557.       { service_code: 86, label: "Закриття особового рахунку" },
  558.    ];
  561. */
  562.                 $orderNames = [
  563.                     9 =>  "Встановлення зонного лічильника",
  564.                     10 =>  "Лічильник не працює",
  565.                     21 =>  "Неправильний показ",
  566.                     32 =>  "Зміна власника",
  567.                     35 =>  "Підключення електроустановок замовника після виконання ТУ",
  568.                     63 =>  "Звернення щодо підозри на крадіжку",
  569.                     79 =>  "Заміна автоматичного вимикача, який опломбований ОСР",
  570.                     85 =>  "Відсутність пломб на засобі обліку",
  571.                     86 =>  "Закриття особового рахунку",
  572.                 ];
  574.                 foreach($find->getAppPersonalAccounts() as $acc){
  575.                     if($acc->getNumber() == $data['account'])
  576.                         $account = $acc;
  577.                 }
  578.                 if($account){
  580.                     $ServiceOrderHistory = new ServiceOrderHistory();
  581.                     $ServiceOrderHistory->setName($orderNames[$data['service_code']]);
  582.                     // $ServiceOrderHistory->setRequest($data);
  583.                     $ServiceOrderHistory->setDateEntered( new \DateTime() );
  584.                     $ServiceOrderHistory->setType($data['service_code']);
  585.                     $ServiceOrderHistory->setStatus('new');
  586.                     $ServiceOrderHistory->setPersonalAccount($account);
  587.                     if($pdf)
  588.                         $ServiceOrderHistory->setPdf(  $pdf );
  589.                     $ServiceOrderHistory->setPersonalAccount($account);
  590.                     $this->entityManager->persist($ServiceOrderHistory);
  591.                     $this->entityManager->flush();
  593.                     $data["id"] = $ServiceOrderHistory->getId();
  594.                 }
  598.                 $rezult = json_decode( $this->appApiService->service_order($data) , true );
  599.                 if($rezult['rez']){
  600.                     $account = false;
  601.                     
  602.                     $rez = [
  603.                         'rezult' => true, 
  604.                         'message' => 'Дані відправлено!',
  605.                         // 'account' => $rezult['account'],
  606.                     ];   
  607.                 }else{
  608.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  609.                 }
  610.             }else{
  611.                 $rez = ['rezult' => false, 'error' => "Користувача не знайдено!"];   
  612.             }
  613.         }else{
  614.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  615.         }
  617.         $response = new JsonResponse();
  618.         $response->setData($rez);
  620.         $this->logHistory($logId, 'check-user', $rez);
  624.         return $response;
  627.     }
  630.     #[Route('/api/set-broken-lines', name: 'set_broken_lines')]
  631.     public function set_broken_lines(Request $request)
  632.     {
  633.         // echo '<pre>';
  634.         $data = json_decode($request->getContent(), true);
  635.         // $data = [
  636.         //     'user' => 31,
  637.         //     'account' => '0900015104',
  638.         //     'phone' => '380xxxxxxxxx',
  639.         //     'voltage' => '123',
  640.         //     'voltage_susidy' => 'Так',
  641.         //     'media' => 2,
  642.         //     'lat' => '1111',
  643.         //     'lon' => '2222',
  644.         //     'reason_type' => '22',
  645.         //     'address' => '222',
  646.         //     // 'imageFile' => new CURLFile(realpath(__DIR__) . '/11.png'),
  647.         // ];
  648.         $logId = $this->logHistory(false, 'set_broken_lines', $data);
  649.         
  650.         
  651.         $valid = $this->valid( $data, ['reason_type', 'user', 'phone', 'address', 'lat', 'lon'] );
  654.         if( empty($valid) ){
  655.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  656.             if($find){
  657.                 if(isset($data['media'])){
  658.                     $mediaObject = $this->entityManager->getRepository(MediaObject::class)->findOneBy(['id' => $data['media']]);
  660.                     if (!$mediaObject) {
  661.                         return new JsonResponse(['rezult' => false,'error' => 'MediaObject not found'], 404);
  662.                     }
  663.                     // Отримуємо шлях до файлу
  664.                     // $filePath = 'https://api-app.de-svitlo.com.ua' .$mediaObject->getFullPath() ;
  665.                     $filePath = $this->kernel->getProjectDir() . '/public' .$mediaObject->getFullPath() ;
  666.                 }
  667.                 // echo "<br> $filePath <br>";
  668.                 $permission = json_decode( $this->appApiService->check_allow_for_low_quality_voltage($data['account']) , true); 
  669.                 if(!$permission['rez'] AND $permission['dozvil'] !== true){
  670.                     // print_r( $permission); die;
  671.                     return new JsonResponse(['rezult' => false,'error' => $permission['err_msg']], 404);
  672.                 }
  673.                 // var_dump( $permission);
  674.                 // die;
  675.                 $data =  [
  676.                     'phone' => $data['phone'],
  677.                     'app_user_id' => $find->getId(),
  678.                     'reason_type' => $data['reason_type'],
  679.                     'address' => $data['address'],
  680.                     'lat' => $data['lat'],
  681.                     'lon' => $data['lon'],
  682.                     // 'imageFile' => new \CURLFile( $filePath ),
  683.                 ];
  684.                 if(isset($filePath))
  685.                     $data['imageFile'] = new \CURLFile( $filePath );
  687.                 $rezult = json_decode( $this->appApiService->set_broken_lines($data) , true );
  688.                 
  689.                 if($rezult['rez']){
  690.                     $rez = [
  691.                         'rezult' => true, 
  692.                         'message' => 'Дані відправлено!',
  693.                         // 'account' => $rezult['account'],
  694.                     ];   
  695.                 }else{
  696.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  697.                 }
  698.             }else{
  699.                 $rez = ['rezult' => false, 'error' => "Користувача не знайдено!"];   
  700.             }
  701.         }else{
  702.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  703.         }
  705.         $response = new JsonResponse();
  706.         $response->setData($rez);
  708.         $this->logHistory($logId, 'check-user', $rez);
  712.         return $response;
  715.     }
  717.     #[Route('/api/get-last-meter-readings', name: 'get_last_meter_readings')]
  718.     public function get_last_meter_readings(Request $request)
  719.     {
  720.         // echo '<pre>';
  721.         $data = json_decode($request->getContent(), true);
  722.         // $data = [
  723.         //     'user' => 31,
  724.         //     'account' => '0900015104',
  725.         // ];
  726.         $logId = $this->logHistory(false, 'get_last_meter_readings', $data);
  727.         
  728.         
  729.         $valid = $this->valid( $data, ['account', 'user'] );
  732.         if( empty($valid) ){
  734.            
  735.             $data = [
  736.                 'method' => 'get-last-meter-readings',
  737.                 'data' => [
  738.                     'account' => $data['account'],
  739.                 ],
  740.             ]; 
  742.             $rezult = json_decode( $this->appApiService->get($data) , true );
  743.             if($rezult['rez']){
  744.                 $rez = [
  745.                     'rezult' => true, 
  746.                     'date_on' => $rezult['date_on'],
  747.                     'reading1' => $rezult['reading1'],
  748.                     'reading2' => $rezult['reading2'],
  749.                     'reading3' => $rezult['reading3'],
  750.                     // 'account' => $rezult['account'],
  751.                 ];   
  752.             }else{
  753.                 $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  754.             }
  755.         }else{
  756.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  757.         }
  759.         $response = new JsonResponse();
  760.         $response->setData($rez);
  762.         $this->logHistory($logId, 'check-user', $rez);
  766.         return $response;
  769.     }
  772.     #[Route('/api/cron-set-meter-readings', name: 'cron_set_meter_readings')]
  773.     public function cron_set_meter_readings(Request $request)
  774.     {
  775.         $AppCounterReading = $this->entityManager->getRepository(AppCounterReading::class)->findBy(['status' => 'new']);
  776.         $i = 0;
  777.         foreach($AppCounterReading as $counterReding){
  778.             $p =  $counterReding->getPersonal()->getOwner()->getPhone();
  779.             $p = str_replace('+', '', $p);
  780.             $data =  [
  781.                 'method' => 'set-meter-readings',
  782.                 'data' => [
  783.                     'phone' => $p,
  784.                     'app_user_id' => $counterReding->getPersonal()->getOwner()->getId(),
  785.                     'account' => $counterReding->getPersonal()->getNumber(),
  786.                     'number_of_scale' => $counterReding->getPersonal()->getNumberOfScale(),
  787.                     'reading1' => $counterReding->getValue(),
  788.                     'reading2' => $counterReding->getValue2(),
  789.                     'reading3' => $counterReding->getValue3(),
  790.                 ]
  791.             ];
  793.             $rezult = json_decode( $this->appApiService->get($data) , true );
  794.             file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log', print_r($rezult, true) . "\n", FILE_APPEND);
  795.             if($rezult['rez']){
  797.                 $counterReding->setStatus('complate');
  799.                 $this->entityManager->persist($counterReding);
  800.                 $this->entityManager->flush();
  802.                 $i++;  
  803.             }else{
  804.                 $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  805.             }
  806.         }
  807.        
  808.        
  809.        
  810.        
  811.         $rez = ['count' => count($AppCounterReading)];
  812.         $response = new JsonResponse();
  813.         $response->setData($rez);
  815.         return $response;
  817.     }
  821.     #[Route('/api/set-meter-readings', name: 'set_meter_readings')]
  822.     public function set_meter_readings(Request $request)
  823.     {
  824.    
  825.         $data = json_decode($request->getContent(), true);
  827.         $logId = $this->logHistory(false, 'set_meter_readings', $data);
  828.         
  829.         
  830.         $valid = $this->valid( $data, ['account', 'user', 'number_of_scale', 'reading1', 'reading2', 'reading3'] );
  831.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log', "************set-meter-readings****************\n", FILE_APPEND);
  832.         if( empty($valid)  ){
  833.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  834.             if($find){
  835.                 $data =  [
  836.                     'method' => 'set-meter-readings',
  837.                     'data' => [
  838.                         'phone' => $find->getPhone(),
  839.                         'app_user_id' => $find->getId(),
  840.                         'account' => $data['account'],
  841.                         'number_of_scale' => $data['number_of_scale'],
  842.                         'reading1' => $data['reading1'],
  843.                         'reading2' => $data['reading2'],
  844.                         'reading3' => $data['reading3'],
  845.                     ]
  846.                 ];
  848.                 $rezult = json_decode( $this->appApiService->get($data) , true );
  849.                 file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log', print_r($rezult, true) . "\n", FILE_APPEND);
  850.                 if($rezult['rez']){
  851.                     $rez = [
  852.                         'rezult' => true, 
  853.                         'message' => 'Дані відправлено!',
  854.                     ];   
  855.                 }else{
  856.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  857.                 }
  858.             }else{
  859.                 $rez = ['rezult' => false, 'error' => 'Користувача не знайдено!'];   
  860.             }
  861.         }else{
  862.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  863.         }
  865.         $response = new JsonResponse();
  866.         $response->setData($rez);
  868.         $this->logHistory($logId, 'check-user', $rez);
  870.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log', "************set-meter-readings END ****************\n", FILE_APPEND);
  872.         return $response;
  875.     }
  878.     #[Route('/api/set-no-light-request', name: 'set_no_light_request')]
  879.     public function set_no_light_request(Request $request)
  880.     {
  881.         // echo '<pre>';
  882.         $data = json_decode($request->getContent(), true);
  883.         // $data = [
  884.         //     'user' => 31,
  885.         //     'account' => '0900015104',
  886.         //     'phone' => '380xxxxxxxxx',
  887.         //     'voltage' => '123',
  888.         //     'voltage_susidy' => 'Так',
  889.         //     'media' => 2
  890.         //     // 'imageFile' => new CURLFile(realpath(__DIR__) . '/11.png'),
  891.         // ];
  892.         $logId = $this->logHistory(false, 'set_no_light_request', $data);
  893.         
  894.         
  895.         $valid = $this->valid( $data, ['account', 'eic', 'user', 'dno_id', 'when_off', 'pib', 'phone', 'eic_count'] );
  898.         if( empty($valid) ){
  899.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['user']]);
  900.             if($find){
  901.                 $permission = json_decode( $this->appApiService->check_last_register_no_power($data['account']) , true); 
  902.                 if(!$permission['rez'] AND $permission['dozvil'] !== true){
  903.                     // print_r( $permission); die;
  904.                     return new JsonResponse(['rezult' => false,'error' => $permission['err_msg']], 404);
  905.                 }
  906.                 // var_dump( $permission);
  907.                 // die;
  908.                 $data =  [
  909.                     'method' => 'set-no-light-request',
  910.                     'data' => [
  911.                         'account' => $data['account'],
  912.                         'app_user_id' => $find->getId(),
  913.                         'eic' => $data['eic'],
  914.                         'dno_id' => $data['dno_id'],
  915.                         'when_off' => $data['when_off'],
  916.                         'pib' => $data['pib'],
  917.                         'phone' => $data['phone'],
  918.                         'eic_count' => $data['eic_count'],
  919.                     ],
  920.                 ];
  922.                 $rezult = json_decode( $this->appApiService->get($data) , true );
  923.                 if($rezult['rez']){
  924.                     $rez = [
  925.                         'rezult' => true, 
  926.                         'message' => 'Дані відправлено!',
  927.                         // 'account' => $rezult['account'],
  928.                     ];   
  929.                 }else{
  930.                     $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  931.                 }
  932.             }else{
  933.                 $rez = ['rezult' => false, 'error' => 'Користувача не знайдено!'];   
  934.             }
  935.         }else{
  936.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  937.         }
  939.         $response = new JsonResponse();
  940.         $response->setData($rez);
  942.         $this->logHistory($logId, 'check-user', $rez);
  946.         return $response;
  949.     }
  952.     #[Route('/api/get-all-accounts-by-phone', name: 'get_all_accounts_by_phone')]
  953.     public function get_all_accounts_by_phone(Request $request)
  954.     {
  955.         $data = json_decode($request->getContent(), true);
  956.       
  957.         $logId = $this->logHistory(false, 'get_all_accounts_by_phone', $data);
  958.         
  959.         
  960.         $valid = $this->valid( $data, ['phone', 'bot_type'] );
  963.         if( empty($valid) ){
  964.             
  965.             $data =  [
  966.                 'method' => 'get-all-accounts-by-phone',
  967.                 'data' => [
  968.                     'phone' => $data['phone'],
  969.                     'bot_type' => $data['bot_type'],
  970.                 ],
  971.             ];
  973.             $rezult = json_decode( $this->appApiService->get($data) , true );
  974.             
  975.             if($rezult['rez']){
  976.                 $rez = [
  977.                     'rezult' => true, 
  978.                     'accounts' => $rezult['accounts']
  979.                 ];   
  980.             }else{
  981.                 $rez = ['rezult' => false, 'error' => $rezult['err_msg']];   
  982.             }
  983.             
  984.         }else{
  985.             $rez = ['rezult' => false, 'error' => "Не задано поля: $valid"];   
  986.         }
  988.         $response = new JsonResponse();
  989.         $response->setData($rez);
  991.         $this->logHistory($logId, 'check-user', $rez);
  995.         return $response;
  998.     }
  1000.     #[Route('/api/yur-create-personal-account', name: 'yurCreatePersonalAccount')]
  1001.     public function yurCreatePersonalAccount(Request $request)
  1002.     {
  1003.         $data = json_decode($request->getContent(), true);
  1004.         $logId = $this->logHistory(false, 'createPersonalAccount', $data);
  1005.         file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  "\n\n\n" .  print_r($data, true) . "\n", FILE_APPEND);
  1007.         $valid = $this->valid( $data, ['eic', 'edrpou', 'name', 'owner'] );
  1008.         if( empty($valid) ){
  1009.             $find = $this->entityManager->getRepository(User::class)->findOneBy(['id' => $data['owner']]);
  1010.             if($find){
  1011.                 $data = ['eic' => $data['eic'], 'app_user_id' => $find->getId(), 'edrpou' => $data['edrpou'],'name' => $data['name']];
  1014.                 file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  print_r($data, true) . "\n", FILE_APPEND);
  1015.                 
  1016.                 $res = json_decode( $this->appApiService->YurCheckPersonalAccount($data) , true );
  1017.                 file_put_contents('/var/www/symfony_docker/public/errorrrrrr.log',  print_r($res, true) . "\n", FILE_APPEND);
  1018.                 $name = (!empty($data['name'])) ? $data['name'] : $data['eic'];
  1019.                 // var_dump($res); die;
  1020.                 if(isset($res['rez']) AND $res['rez']  AND $res['correct_data']){
  1021.                     $personal = new AppPersonalAccount();
  1022.                     $personal->setOwner($find);
  1023.                     $personal->setNumber($data['eic']);
  1024.                     $personal->setName($name);
  1025.                     $personal->setNumberOfScale(0);
  1026.                     $personal->setActive(true);
  1027.                     $personal->setIsMain(true);
  1028.                     $personal->setDateEntered($this->datetime);
  1029.                     $personal->setType('factory');
  1030.                     $personal->setEic($data['eic']);
  1031.                     $this->entityManager->persist($personal);
  1032.                     $this->entityManager->flush();
  1034.                     foreach($res['data'] as $res_data){
  1035.                         $accounts = $this->entityManager->getRepository(Accounts::class)->findOneBy(['number' => $res_data['acc'], 'eic' => $res_data['eic_kod']]);
  1036.                         if(!$accounts){
  1037.                             $accounts = new Accounts();
  1038.                             $accounts->setNumber($res_data['acc']);
  1039.                             $accounts->setEic($res_data['eic_kod']);
  1040.                             $accounts->setEicParent($res_data['eic_kod_place']);
  1041.                             $this->entityManager->persist($accounts);
  1042.                             $this->entityManager->flush();
  1043.                         }
  1045.                         $personalChild = new AppPersonalAccount();
  1046.                         $personalChild->setOwner($find);
  1047.                         $personalChild->setNumber($res_data['acc']);
  1048.                         $personalChild->setName($res_data['name']);
  1049.                         $personalChild->setCounter($res_data['counter']);
  1050.                         $personalChild->setNumberOfScale(0);
  1051.                         $personalChild->setActive(true);
  1052.                         $personalChild->setIsMain(false);
  1053.                         $personalChild->setDateEntered($this->datetime);
  1054.                         $personalChild->setType('factory');
  1055.                         $personalChild->setEic($res_data['eic_kod']);
  1056.                         $personalChild->setParent($personal);
  1058.                         $fullAdresses = $res_data['city_name'] . ' ' . $res_data['street_name'] . ' ' . $res_data['building_name'];
  1059.                         $personalChild->setFullAddress($fullAdresses);
  1060.                         $personalChild->setCity($res_data['city_name']);
  1061.                         $personalChild->setStreet($res_data['street_name']);
  1062.                         $personalChild->setBuilding($res_data['building_name']);
  1063.                         $personalChild->setMainFullAddress($fullAdresses);
  1066.                         $this->entityManager->persist($personalChild);
  1067.                         $this->entityManager->flush();
  1068.                     }
  1072.                     
  1074.                     $rez = [
  1075.                         'registered' => true,
  1076.                         'id' => $personal->getId(),
  1077.                         
  1078.                     ];
  1079.                 }else{
  1080.                     $rez = ['registered' => false];
  1081.                 }
  1082.             }else{
  1083.                 $rez = ['registered' => false];
  1084.             }
  1086.         }else{
  1087.             $rez = ['registered' => false, 'error' => "Не задано поля: $valid"];
  1088.         }
  1092.         
  1093.         
  1094.     
  1095.         $response = new JsonResponse();
  1096.         $response->setData($rez);
  1098.         $this->logHistory($logId, 'check-user', $rez);
  1102.         return $response;
  1103.     }
  1106. }