feat: orderbook token sell route

controllers/PaymentConfirmController.php

@@ -83,6 +83,16 @@ class PaymentConfirmController
             )->withStatus(500);
         }
 
+        try {
+            $this->cprModel->updateTokenId((int)$cpr['cpr_id'], (int)$tokenResult['token_id']);
+        } catch (\Throwable $e) {
+            return ResponseLib::sendFail(
+                'Falha ao vincular token à CPR: ' . $e->getMessage(),
+                [],
+                'E_CPR_UPDATE'
+            )->withStatus(500);
+        }
+
         return ResponseLib::sendOk([
             'message' => 'CPR enviada e token criado com sucesso',
             'payment_id' => $paymentId,
@@ -304,4 +314,4 @@ class PaymentConfirmController
 
         return null;
     }
-}
+}

controllers/TokenOrderbookController.php

@@ -0,0 +1,95 @@
+<?php
+
+namespace Controllers;
+
+use Libs\ResponseLib;
+use Models\OrderbookModel;
+use Models\TokenModel;
+use Psr\Http\Message\ServerRequestInterface;
+use Respect\Validation\Exceptions\ValidationException;
+use Respect\Validation\Validator as val;
+
+class TokenOrderbookController
+{
+    private TokenModel $tokenModel;
+    private OrderbookModel $orderbookModel;
+    private \PDO $pdo;
+
+    public function __construct()
+    {
+        if (!isset($GLOBALS['pdo']) || !$GLOBALS['pdo'] instanceof \PDO) {
+            throw new \RuntimeException('Global PDO connection not initialized');
+        }
+
+        $this->pdo = $GLOBALS['pdo'];
+        $this->tokenModel = new TokenModel();
+        $this->orderbookModel = new OrderbookModel();
+    }
+
+    public function __invoke(ServerRequestInterface $request)
+    {
+        $body = json_decode((string)$request->getBody(), true) ?? [];
+
+        try {
+            val::key('cpr_id', val::intType()->positive())
+                ->key('value', val::numericVal())
+                ->assert($body);
+        } catch (ValidationException $e) {
+            return ResponseLib::sendFail(
+                'Validation failed: ' . $e->getFullMessage(),
+                [],
+                'E_VALIDATE'
+            )->withStatus(400);
+        }
+
+        $cprId = (int)$body['cpr_id'];
+        $newValue = (int)round((float)$body['value']);
+
+        try {
+            $this->pdo->beginTransaction();
+
+            $token = $this->tokenModel->findByCprId($cprId, true);
+            if (!$token) {
+                $this->pdo->rollBack();
+                return ResponseLib::sendFail(
+                    'Token não encontrado para a CPR informada',
+                    ['cpr_id' => $cprId],
+                    'E_TOKEN_NOT_FOUND'
+                )->withStatus(404);
+            }
+
+            $this->tokenModel->updateCommoditiesValue((int)$token['token_id'], $newValue);
+
+            $orderbook = $this->orderbookModel->create([
+                'orderbook_flag' => '',
+                'orderbook_ts' => time(),
+                'orderbook_is_token' => true,
+                'orderbook_amount' => (string)($token['token_commodities_amount'] ?? '0'),
+                'status_id' => 1,
+                'user_id' => (int)$token['user_id'],
+                'wallet_id' => (int)$token['wallet_id'],
+                'token_id' => (int)$token['token_id'],
+                'currency_id' => null,
+                'chain_id' => (int)$token['chain_id'],
+            ]);
+
+            $this->pdo->commit();
+        } catch (\Throwable $e) {
+            if ($this->pdo->inTransaction()) {
+                $this->pdo->rollBack();
+            }
+
+            return ResponseLib::sendFail(
+                'Falha ao atualizar token e criar ordem: ' . $e->getMessage(),
+                [],
+                'E_ORDERBOOK'
+            )->withStatus(500);
+        }
+
+        return ResponseLib::sendOk([
+            'message' => 'Token atualizado e ordem registrada com sucesso',
+            'token_id' => (int)$token['token_id'],
+            'orderbook_id' => $orderbook['orderbook_id'],
+        ], 'S_ORDERBOOK_CREATED');
+    }
+}

migrations/migration_user_id.sql

@@ -1,6 +1,7 @@
 BEGIN;
 ALTER TABLE "cpr"
     ADD COLUMN user_id INTEGER,
+    ADD COLUMN token_id INTEGER,
     ADD COLUMN company_id INTEGER;
 ALTER TABLE "cpr"
     ADD CONSTRAINT fk_cpr_user
@@ -12,4 +13,9 @@ ALTER TABLE "cpr"
         FOREIGN KEY (company_id)
         REFERENCES "company"(company_id)
         ON DELETE RESTRICT;
+ALTER TABLE "cpr"
+    ADD CONSTRAINT fk_cpr_token
+        FOREIGN KEY (token_id)
+        REFERENCES "token"(token_id)
+        ON DELETE RESTRICT;
 COMMIT;

models/CprModel.php

@@ -165,6 +165,15 @@ class CprModel
         return $record;
     }
 
+    public function updateTokenId(int $cprId, int $tokenId): void
+    {
+        $stmt = $this->pdo->prepare('UPDATE "cpr" SET token_id = :token_id WHERE cpr_id = :cpr_id');
+        $stmt->execute([
+            'token_id' => $tokenId,
+            'cpr_id' => $cprId,
+        ]);
+    }
+
     private function normalizeChildrenCodes($value): string
     {
         if (is_array($value)) {

models/OrderbookModel.php

@@ -0,0 +1,81 @@
+<?php
+
+namespace Models;
+
+class OrderbookModel
+{
+    private \PDO $pdo;
+
+    public function __construct()
+    {
+        if (isset($GLOBALS['pdo']) && $GLOBALS['pdo'] instanceof \PDO) {
+            $this->pdo = $GLOBALS['pdo'];
+            return;
+        }
+
+        throw new \RuntimeException('Global PDO connection not initialized');
+    }
+
+    /**
+     * @param array{
+     *   orderbook_flag:string,
+     *   orderbook_ts:int,
+     *   orderbook_is_token:bool,
+     *   orderbook_amount:string,
+     *   status_id:int,
+     *   user_id:int,
+     *   wallet_id:int,
+     *   token_id:int,
+     *   currency_id:?int,
+     *   chain_id:int
+     * } $data
+     */
+    public function create(array $data): array
+    {
+        $stmt = $this->pdo->prepare(
+            'INSERT INTO "orderbook" (
+                orderbook_flag,
+                orderbook_ts,
+                orderbook_is_token,
+                orderbook_amount,
+                status_id,
+                user_id,
+                wallet_id,
+                token_id,
+                currency_id,
+                chain_id
+            ) VALUES (
+                :orderbook_flag,
+                :orderbook_ts,
+                :orderbook_is_token,
+                :orderbook_amount,
+                :status_id,
+                :user_id,
+                :wallet_id,
+                :token_id,
+                :currency_id,
+                :chain_id
+            ) RETURNING orderbook_id'
+        );
+
+        $stmt->execute([
+            'orderbook_flag' => $data['orderbook_flag'],
+            'orderbook_ts' => $data['orderbook_ts'],
+            'orderbook_is_token' => $data['orderbook_is_token'],
+            'orderbook_amount' => $data['orderbook_amount'],
+            'status_id' => $data['status_id'],
+            'user_id' => $data['user_id'],
+            'wallet_id' => $data['wallet_id'],
+            'token_id' => $data['token_id'],
+            'currency_id' => $data['currency_id'],
+            'chain_id' => $data['chain_id'],
+        ]);
+
+        $orderbookId = (int)$stmt->fetchColumn();
+
+        return [
+            'orderbook_id' => $orderbookId,
+            'orderbook_ts' => $data['orderbook_ts'],
+        ];
+    }
+}

models/TokenModel.php

@@ -58,5 +58,49 @@ class TokenModel
 
         return $stmt->fetchAll(\PDO::FETCH_ASSOC);
     }
+
+    public function findByCprId(int $cprId, bool $forUpdate = false): ?array
+    {
+        $sql = 'SELECT token_id,
+                    token_external_id,
+                    token_commodities_amount,
+                    token_commodities_value,
+                    token_uf,
+                    token_city,
+                    token_content,
+                    token_flag,
+                    wallet_id,
+                    chain_id,
+                    commodities_id,
+                    cpr_id,
+                    user_id
+             FROM "token"
+             WHERE cpr_id = :cpr_id
+            ORDER BY token_id DESC
+            LIMIT 1';
+
+        if ($forUpdate) {
+            $sql .= ' FOR UPDATE';
+        }
+
+        $stmt = $this->pdo->prepare($sql);
+        $stmt->execute(['cpr_id' => $cprId]);
+        $record = $stmt->fetch(\PDO::FETCH_ASSOC);
+
+        return $record ?: null;
+    }
+
+    public function updateCommoditiesValue(int $tokenId, float $value): void
+    {
+        $stmt = $this->pdo->prepare(
+            'UPDATE "token"
+             SET token_commodities_value = :value
+             WHERE token_id = :token_id'
+        );
+        $stmt->execute([
+            'value' => $value,
+            'token_id' => $tokenId,
+        ]);
+    }
 }
 

public/index.php

@@ -70,6 +70,7 @@ $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('/token/orderbook', $authJwt, \Controllers\TokenOrderbookController::class);
 
 $app->post('/b3/token', \Controllers\B3TokenController::class);
 $app->post('/b3/cpr/register', $authJwt, \Controllers\B3CprRegisterController::class);