src/Controller/VkApiController.php line 144

  1. <?php
  3. namespace App\Controller;
  5. use App\Entity\AgencyClients;
  6. use App\Entity\AgencyClientsHistoryDiposit;
  7. use App\Entity\User;
  8. use App\Entity\UserPlatform;
  9. use App\Entity\UserProject;
  10. use App\Entity\VkUser;
  11. use App\Form\TransactionFormType;
  12. use App\Service\BillingService;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Doctrine\Persistence\ManagerRegistry;
  15. use Exception;
  16. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use Symfony\Component\HttpFoundation\Response;
  19. use Symfony\Component\Routing\Annotation\Route;
  20. use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
  21. use Symfony\Contracts\HttpClient\Exception\DecodingExceptionInterface;
  22. use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
  23. use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
  24. use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
  25. use Symfony\Contracts\HttpClient\HttpClientInterface;
  27. class VkApiController extends AbstractController
  28. {
  29.     private $client;
  30.     
  31.     private $limit;
  32.     
  33.     private BillingService $billingService;
  34.     
  35.     public function __construct(HttpClientInterface $vkContentClient, private readonly ManagerRegistry $doctrine, BillingService $billingService)
  36.     {
  37.         $this->client = $vkContentClient;
  38.         $this->limit = 50;
  39.         $this->billingService = $billingService;
  40.     }
  41.     
  42.     #[Route(path: '/api/vk/transaction/to/{clientId}/{amount}/{userProject}', name: 'vk_api_transaction')]
  43.     public function transactionToClient(string $clientId, string $amount, UserProject $userProject): Response
  44.     {
  45.         $entityManager = $this->doctrine->getManager();
  46.         $user = $this->getUser();
  47.         
  48.         if (!($user instanceof User)) {
  49.             return $this->json(['error' => 'Авторизуйтесь для выполнения данной операции.'], 500);
  50.         }
  51.         
  52.         if (!$user->isAdmin()) {
  53.             $needBalance = intval($amount) * 100;
  55.             // Add amount
  56.             try {
  57.                 // TODO change $user->getMainUserProject() to required project
  58.                 
  59.                 if ($userProject == null) {
  60.                     $userProject = $user->getMainUserProject();
  61.                 }
  62.                 $this->billingService->updateUserBalance($user, 'vk_transaction_to_client', $needBalance, $userProject, null, null, [
  63.                     'clientId' => $clientId
  64.                 ]);
  65.             } catch (Exception $exception) {
  66.                 //todo log
  67.                 //$exception->getMessage();
  68.                 return $this->json(['error' => $exception->getMessage()], 500);
  69.             }
  71.             $entityManager->persist($user);
  72.             $entityManager->flush();
  73.         }
  74.         
  75.         $response = $this->client->request('POST', "https://ads.vk.com/api/v2/billing/transactions/to/$clientId.json", [
  76.             'json' => [
  77.                 'amount' => ($amount / 1.2)
  78.             ]
  79.         ]);
  80.         
  81.         if ($response->getStatusCode() !== 200) {
  82.             return $this->json(['error' => 'Ошибка'], $response->getStatusCode());
  83.         }
  84.         
  85.         $response = $response->toArray();
  86.         
  87.         $ACHistoryDiposit = new AgencyClientsHistoryDiposit();
  88.         $ACHistoryDiposit->setAmount($response['amount']);
  89.         $ACHistoryDiposit->setCreatedAt($response['created_at']);
  90.         $ACHistoryDiposit->setClientBalance($response['client_balance']);
  91.         $ACHistoryDiposit->setClientUsername($response['client_username']);
  92.         $ACHistoryDiposit->setUserEmail($user->getEmail());
  93.         
  94.         $entityManager->persist($ACHistoryDiposit);
  95.         $entityManager->flush();
  96.         
  97.         
  98.         return $this->json(['data' => $response]);
  99.         
  100.     }
  101.     
  102.     #[Route(path: '/api/vk/getClients', name: 'vk_api_clients')]
  103.     public function getVkApiClients(Request $request, ManagerRegistry $doctrine): Response
  104.     {
  105.         $entityManager = $doctrine->getManager();
  106.         
  107.         $response = $this->client->request('GET', "https://ads.vk.com/api/v2/agency/clients.json?limit=$this->limit");
  108.         $response = $response->toArray();
  109.         
  110.         $responseCount = $response['count'];
  111.         
  112.         if ($responseCount <= $this->limit) {
  113.             return $this->json($response);
  114.         }
  115.         
  116.         for ($offset = 0; $offset <= $responseCount; $offset+=$this->limit) {
  117.             $responseOffset = $this->client->request('GET', "https://ads.vk.com/api/v2/agency/clients.json?limit=$this->limit&offset=$offset");
  118.             foreach ($responseOffset->toArray()['items'] as $item) {
  119.                 
  120.                 $agencyClient = null;
  121.                 $vkUser = $this->doctrine->getRepository(VkUser::class)->findOneBy(['username' => $item['user']['username']]);
  122.                 
  123.                 if ($vkUser instanceof VkUser) {
  124.                     $agencyClient = $this->doctrine->getRepository(AgencyClients::class)->findOneBy(['vkUser' => $vkUser]);
  125.                 } else {
  126.                     $agencyClient = new AgencyClients();
  127.                     $vkUser = new VkUser();
  128.                 }
  129.                 
  130.                 $this->updateVkClientInfo($item, $vkUser, $agencyClient);
  131.             }
  132.         }
  133.         
  134.         $clients = $this->doctrine->getRepository(AgencyClients::class)->findAll();
  135.         
  136.         return $this->json([
  137.             "count" => count($clients),
  138.             "data" => $clients
  139.         ]);
  140.         
  141.     }
  142.     
  143.     #[Route(path: '/api/vk/getVkUserClients', name: 'vk_api_user_clients')]
  144.     public function getVkUserClients(Request $request, ManagerRegistry $doctrine): Response
  145.     {
  146.         $user = $this->getUser();
  147.         
  148.         $userPlatform = $this->doctrine->getRepository(UserPlatform::class)->findOneBy(['user' => $user, 'name' => 'ads.vk']);
  149.         
  150.         if (!($userPlatform instanceof UserPlatform)) {
  151.             return $this->json(['error' => 'Отсутствует токен для VK ADS'], 500);
  152.         }
  153.         
  154.         $token = $userPlatform->getToken();
  155.         
  156.         $response = $this->client->request('GET', "https://ads.vk.com/api/v3/manager/clients.json?limit=$this->limit", [
  157.             'auth_bearer' => $token
  158.         ]);
  159.         
  160.         if ($response->getStatusCode() !== 200) {
  161.             return $this->json(['error' => $response->toArray(false)['error']], $response->getStatusCode());
  162.         }
  163.         $response = $response->toArray();
  164.         
  165.         $responseCount = $response['count'];
  167.         for ($offset = 0; $offset <= $responseCount; $offset+=$this->limit) {
  168.             $responseOffset = $this->client->request('GET', "https://ads.vk.com/api/v3/manager/clients.json?limit=$this->limit&offset=$offset", [
  169.                 'auth_bearer' => $token
  170.             ]);
  171.             foreach ($responseOffset->toArray()['items'] as $item) {
  172.                 
  173.                 $agencyClient = null;
  174.                 $vkUser = $this->doctrine->getRepository(VkUser::class)->findOneBy(['username' => $item['user']['username']]);
  175.                 
  176.                 if ($vkUser instanceof VkUser) {
  177.                     $agencyClient = $this->doctrine->getRepository(AgencyClients::class)->findOneBy(['vkUser' => $vkUser]);
  178.                 } else {
  179.                     $agencyClient = new AgencyClients();
  180.                     $vkUser = new VkUser();
  181.                 }
  182.                 $agencyClient->setUser($user);
  183.                 $clientId = $item['user']['id'];
  184.                 $response = $this->client->request('GET', "https://ads.vk.com/api/v2/agency/clients.json?_user__id=$clientId");
  185.                 
  186.                 if ($response->toArray()['count'] != 0) {
  187.                     $agencyClient->setIsLake(true);
  188.                 }
  189.                 
  190.                 $this->updateVkClientInfo($item, $vkUser, $agencyClient);
  191.             }
  192.         }
  193.         
  194.         $clients = $this->doctrine->getRepository(AgencyClients::class)->findBy(['user' => $this->getUser(), 'isLake' => true]);
  195.         
  196.         return $this->json([
  197.             "count" => count($clients),
  198.             "data" => $clients
  199.         ]);
  200.         
  201.     }
  202.     
  203.     #[Route(path: '/api/getUserClients/{user}', name: 'api_getUserAgencyClients')]
  204.     public function getUserAgencyClients(Request $request, ManagerRegistry $doctrine, User $user): Response
  205.     {
  206.         $clients = $this->doctrine->getRepository(AgencyClients::class)->findBy(['user' => $user]);
  207.         
  208.         return $this->json([
  209.             "count" => count($clients),
  210.             "data" => $clients
  211.         ]);
  212.     }
  213.     
  214.     #[Route(path: '/agencyClients/getHistoryDiposits/{agencyClientUsername}', name: 'api_agencyClients_history_diposits')]
  215.     public function getHistoryDiposits(Request $request, string $agencyClientUsername): Response
  216.     {
  217.         $ACHistoryDiposit = $this->doctrine->getRepository(AgencyClientsHistoryDiposit::class)->findBy(['clientUsername' => $agencyClientUsername]);
  218.         
  219.         return $this->json([
  220.             "data" => $ACHistoryDiposit
  221.         ]);
  222.     }
  223.     
  224.     #[Route(path: '/agencyClients/{agencyClientId}', name: 'app_edit_agency_client')]
  225.     public function editAgencyClient(Request $request, string $agencyClientId): Response
  226.     {
  227.         $user = $this->getUser();
  228.         $isAdmin = false;
  229.         
  230.         if ($user instanceof User && $user->isAdmin()) {
  231.             $isAdmin = true;
  232.         }
  233.         
  234.         $client = $this->doctrine->getRepository(AgencyClients::class)->findOneBy(['id' => $agencyClientId]);
  235.         
  236.         if (!($client instanceof AgencyClients)) {
  237.             return $this->render('error404/index.html.twig');
  238.         }
  239.         
  240.         if ($client->getUser() != $user && !$isAdmin) {
  241.             return $this->render('error404/index.html.twig');
  242.         }
  243.         
  244.         $clientId = $client->getVkUser()->getId();
  245.         $response = $this->client->request('GET', "https://ads.vk.com/api/v2/agency/clients.json?_user__id=$clientId");
  246.         $item = $response->toArray()['items'][0];
  247.         $vkUser = $this->doctrine->getRepository(VkUser::class)->findOneBy(['username' => $item['user']['username']]);
  248.         $agencyClient = $this->doctrine->getRepository(AgencyClients::class)->findOneBy(['vkUser' => $vkUser]);
  249.         
  250.         $this->updateVkClientInfo($item, $vkUser, $agencyClient);
  251.         
  252.         $client = $this->doctrine->getRepository(AgencyClients::class)->findOneBy(['id' => $agencyClientId]);
  253.         
  254.         $form = $this->createForm(TransactionFormType::class, null, ['projects' => $user->getUserProjects()]);
  255.         $form->handleRequest($request);
  256.         
  257.         $error = [];
  258.         
  259.         if ($form->isSubmitted()) {
  260.             if ($form->isValid()) {
  261.                 $response = $this->transactionToClient($client->getVkUser()->getId(), $form->getData()['amount'], $form->get('project')->getData());
  262.                 $response = json_decode($response->getContent(), true);
  263.                 if (array_key_exists('error', $response)) {
  264.                     $error[] = $response['error'];
  265.                 } else {
  266.                     return $this->redirectToRoute('app_edit_agency_client', ['agencyClientId' => $agencyClientId]);
  267.                 }
  268.             } else {
  269.                 $error[] = $form->getErrors();
  270.             }
  271.         }
  272.         
  273.         return $this->render('agency_clients/index.html.twig', [
  274.             'client' => $client,
  275.             'isAdmin' => $isAdmin,
  276.             'form' => $form,
  277.             'errors' => $error
  278.         ]);
  279.     }
  280.     
  281.     public function updateVkClientInfo($item, VkUser $vkUser, AgencyClients $agencyClient) {
  282.         $agencyClient->setStatus($item['status']);
  283.         $agencyClient->setAccessType($item['access_type']);
  284.         
  285.         //account
  286.         $vkUser->setABalance($item['user']['account']['a_balance']);
  287.         $vkUser->setBalance($item['user']['account']['balance']);
  288.         $vkUser->setCurrency($item['user']['account']['currency']);
  289.         $vkUser->setCurrencyBalanceHold($item['user']['account']['currency_balance_hold']);
  290.         $vkUser->setFlags($item['user']['account']['flags']);
  291.         $vkUser->setAccountId($item['user']['account']['id']);
  292.         $vkUser->setIsNonresident($item['user']['account']['is_nonresident']);
  293.         $vkUser->setType($item['user']['account']['type']);
  294.         
  295.         //additional_emails
  296.         $vkUser->setAdditionalEmails($item['user']['additional_emails']);
  297.         
  298.         //additional_info
  299.         if ($item['user']['additional_info'] !== null) {
  300.             $vkUser->setAddress($item['user']['additional_info']['address']);
  301.             $vkUser->setClientInfo($item['user']['additional_info']['client_info']);
  302.             $vkUser->setClientName($item['user']['additional_info']['client_name']);
  303.             $vkUser->setEmail($item['user']['additional_info']['email']);
  304.             $vkUser->setName($item['user']['additional_info']['name']);
  305.             $vkUser->setPhone($item['user']['additional_info']['phone']);
  306.         }
  307.         
  308.         $vkUser->setClientUsername($item['user']['client_username']);
  309.         $vkUser->setId($item['user']['id']);
  310.         $vkUser->setStatus($item['user']['status']);
  311.         $vkUser->setTypes($item['user']['types']);
  312.         $vkUser->setUsername($item['user']['username']);
  313.         
  314.         $this->doctrine->getManager()->persist($vkUser);
  315.         $agencyClient->setVkUser($vkUser);
  316.         
  317.         $this->doctrine->getManager()->persist($agencyClient);
  318.         
  319.         $this->doctrine->getManager()->flush();
  320.     }
  321.     
  322.     #[Route(path: '/panel', name: 'vk_api_getUserToken')]
  323.     public function getVkUserToken(Request $request, EntityManagerInterface $entityManager,): Response
  324.     {
  325.         $code = $request->query->get('code');
  326.         $userId = $request->query->get('user_id');
  327.         
  328.         $response = $this->client->request('POST', "https://ads.vk.com/api/v2/oauth2/token.json", [
  329.             'headers' => [
  330.                 'Content-Type' => 'application/x-www-form-urlencoded',
  331.             ],
  332.             'body' => [
  333.                 'grant_type' => 'authorization_code',
  334.                 'code' => $code,
  335.                 'client_id' => '7XG62PqTbNY8smMK',
  336.                 'permanent' => true
  337.             ]
  338.         ]);
  339.         
  340.         if ($response->getStatusCode() !== 200) {
  341.             try {
  342.                 $response = $response->toArray(false);
  343.                 
  344.                 if ($response['error'] == "token_limit_exceeded") {
  345.                     $this->client->request('POST', "https://ads.vk.com/api/v2/oauth2/token/delete.json", [
  346.                         'headers' => [
  347.                             'Content-Type' => 'application/x-www-form-urlencoded',
  348.                         ],
  349.                         'body' => [
  350.                             'client_id' => '7XG62PqTbNY8smMK',
  351.                             'client_secret' => '0ugLDBgjtj3mLgiOntKrwlcq9nEijUpWFjsiUF3PsWLlKkUUFmRlZvEF4oF68QdFViRZ03eNp4dfhV7UWJUKjmsgdeAbu89W1cHuvtPxXaFAWDbkn5BXMX2Z0S3IFa4msc2ShfocNtr7xUdCMe4lHbD4KI6sk7WiBxqgUyb93YBo5CcWS8GjoC537Tkr16XBp9caIx7Vx0YUF5Wa1FhCr5gHzHvpfFh5',
  352.                             'user_id' => $response['user_id']
  353.                         ]
  354.                     ]);
  355.                     
  356.                     $response = $this->client->request('POST', "https://ads.vk.com/api/v2/oauth2/token.json", [
  357.                         'headers' => [
  358.                             'Content-Type' => 'application/x-www-form-urlencoded',
  359.                         ],
  360.                         'body' => [
  361.                             'grant_type' => 'authorization_code',
  362.                             'code' => $code,
  363.                             'client_id' => '7XG62PqTbNY8smMK',
  364.                             'permanent' => true
  365.                         ]
  366.                     ]);
  367.                 } else {
  368.                     return $this->json(['error' => $response['error']], 500);
  369.                 }
  370.             } catch (Exception $e) {
  371.                 return $this->json(['error' => $e->getMessage()], 500);
  372.             }
  373.         }
  374.         
  375.         $response = $response->toArray(true);
  376.         
  377.         $user = $this->getUser();
  378.         
  379.         $userPlatforms = $this->doctrine->getRepository(UserPlatform::class)->findOneBy(['user' => $user, 'name' => 'ads.vk']);
  380.         
  381.         if (!($userPlatforms instanceof UserPlatform)) {
  382.             $userPlatforms = new UserPlatform();
  383.         }
  384.         
  385.         $userPlatforms->setUser($user);
  386.         $userPlatforms->setName('ads.vk');
  387.         $userPlatforms->setToken($response['access_token']);
  388.         
  389.         $entityManager->persist($userPlatforms);
  390.         
  391.         $entityManager->flush();
  392.         
  393.         return $this->redirectToRoute('app_user_platforms');
  394.         
  395.     }
  396. }