controllers/WalletTokensController.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace Controllers;
+
+use Libs\ResponseLib;
+use Models\TokenModel;
+use Psr\Http\Message\ServerRequestInterface;
+
+class WalletTokensController
+{
+    private TokenModel $tokenModel;
+
+    public function __construct()
+    {
+        $this->tokenModel = new TokenModel();
+    }
+
+    public function __invoke(ServerRequestInterface $request)
+    {
+        $companyId = (int)($request->getAttribute('api_company_id') ?? 0);
+        if ($companyId <= 0) {
+            return ResponseLib::sendFail('Authenticated company not found', [], 'E_VALIDATE')->withStatus(401);
+        }
+
+        try {
+            $tokens = $this->tokenModel->getByCompanyId($companyId);
+        } catch (\Throwable $e) {
+            return ResponseLib::sendFail('Failed to fetch wallet tokens: ' . $e->getMessage(), [], 'E_DATABASE')->withStatus(500);
+        }
+
+        return ResponseLib::sendOk([
+            'company_id' => $companyId,
+            'tokens' => $tokens,
+        ], 'S_WALLET_TOKENS');
+    }
+}

models/TokenModel.php

@@ -33,5 +33,30 @@ class TokenModel
         $stmt->execute(['uf' => $uf, 'name' => $commoditiesName]);
         return $stmt->fetchAll(\PDO::FETCH_ASSOC);
     }
+
+    public function getByCompanyId(int $companyId): array
+    {
+        $sql = 'SELECT t.token_id,
+                       t.token_external_id,
+                       t.token_commodities_amount,
+                       t.token_commodities_value,
+                       t.token_uf,
+                       t.token_city,
+                       t.token_content,
+                       t.token_flag,
+                       t.wallet_id,
+                       t.chain_id,
+                       t.commodities_id,
+                       t.cpr_id,
+                       t.user_id
+                FROM "token" t
+                INNER JOIN "wallet" w ON w.wallet_id = t.wallet_id
+                WHERE w.company_id = :company_id
+                ORDER BY t.token_id';
+        $stmt = $this->pdo->prepare($sql);
+        $stmt->execute(['company_id' => $companyId]);
+
+        return $stmt->fetchAll(\PDO::FETCH_ASSOC);
+    }
 }
 

public/index.php

@@ -68,6 +68,7 @@ $app->post('/cpr/create', $authJwt, \Controllers\RegisterCprController::class);
 // CPR history
 $app->post('/cpr/history', $authJwt, \Controllers\CprQueryController::class);
 
+$app->post('/wallet/tokens', $authJwt, \Controllers\WalletTokensController::class);
 $app->post('/token/get', $authJwt, \Controllers\TokenGetController::class);
 
 $app->post('/b3/token', \Controllers\B3TokenController::class);