Integração de dados com o RadPrice

CREATE VIEW radprice_ofertas AS
SELECT p.codigo || '-' || l.codigo        AS id_externo,
       p.descricao                         AS nome,
       p.marca, p.ean                      AS gtin,
       p.unidade_venda                     AS unidade,
       pr.preco_vista                      AS preco,
       pr.preco_cheio                      AS preco_de,
       CASE WHEN e.saldo > 0 THEN 'em_estoque' ELSE 'sob_encomenda' END AS estoque,
       'https://www.suaempresa.com.br/p/' || p.slug AS link_produto,
       l.nome AS loja, l.endereco, l.cidade, l.uf,
       pr.alterado_em                      AS atualizado_em,
       (p.ativo AND pr.preco_vista > 0)    AS ativo,
       lower(unaccent(p.descricao || ' ' || coalesce(p.marca, ''))) AS busca
FROM prata.produtos p
JOIN prata.precos pr ON pr.produto_id = p.id
JOIN prata.lojas  l  ON l.id = pr.loja_id
LEFT JOIN prata.estoque e ON e.produto_id = p.id AND e.loja_id = l.id;

CREATE ROLE radprice_leitor LOGIN PASSWORD '<senha forte>';
GRANT USAGE ON SCHEMA public TO radprice_leitor;
GRANT SELECT ON radprice_ofertas TO radprice_leitor;

CREATE VIEW dbo.radprice_ofertas AS
SELECT CONCAT(p.codigo, '-', l.codigo) AS id_externo, p.descricao AS nome, p.marca, p.ean AS gtin,
       p.unidade_venda AS unidade, pr.preco_vista AS preco, l.nome AS loja, l.cidade, l.uf,
       CONCAT('https://www.suaempresa.com.br/p/', p.slug) AS link_produto,
       pr.alterado_em AS atualizado_em, CASE WHEN p.ativo = 1 THEN 1 ELSE 0 END AS ativo
FROM prata.produtos p JOIN prata.precos pr ON pr.produto_id = p.id JOIN prata.lojas l ON l.id = pr.loja_id;

CREATE LOGIN radprice_leitor WITH PASSWORD = '<senha forte>';
CREATE USER radprice_leitor FOR LOGIN radprice_leitor;
GRANT SELECT ON dbo.radprice_ofertas TO radprice_leitor;

CREATE VIEW radprice_ofertas AS
SELECT CONCAT(p.codigo, '-', l.codigo) AS id_externo, p.descricao AS nome, p.marca, p.ean AS gtin,
       pr.preco_vista AS preco, l.nome AS loja, l.cidade, l.uf, pr.alterado_em AS atualizado_em, p.ativo
FROM produtos p JOIN precos pr ON pr.produto_id = p.id JOIN lojas l ON l.id = pr.loja_id;

CREATE USER 'radprice_leitor'@'%' IDENTIFIED BY '<senha forte>';
GRANT SELECT ON dw.radprice_ofertas TO 'radprice_leitor'@'%';

python -m venv .venv
# Linux:   source .venv/bin/activate      Windows:  .venv\Scripts\activate
pip install -r requirements.txt
pip install "psycopg[binary]"     # PostgreSQL (ou pyodbc / PyMySQL / oracledb)
cp radprice.env.exemplo .env      # Windows: copy radprice.env.exemplo .env

RADPRICE_CHAVE=rpk_XXXXXXXX_...           # enviada pela Datatoms
DW_URL=postgresql+psycopg://radprice_leitor:[email protected]:5432/dw
DW_VIEW=radprice_ofertas
RADPRICE_INTERVALO_MIN=60

[Unit]
Description=RadPrice sync
After=network-online.target

[Service]
WorkingDirectory=/opt/radprice
ExecStart=/opt/radprice/.venv/bin/python radprice_sync.py watch
Restart=always
RestartSec=30
User=radprice

[Install]
WantedBy=multi-user.target

# sudo systemctl enable --now radprice && journalctl -u radprice -f

schtasks /Create /TN "RadPrice sync" /SC HOURLY /RU SYSTEM ^
  /TR "C:\radprice\.venv\Scripts\python.exe C:\radprice\radprice_sync.py sync --incremental"
schtasks /Create /TN "RadPrice completo" /SC DAILY /ST 03:00 /RU SYSTEM ^
  /TR "C:\radprice\.venv\Scripts\python.exe C:\radprice\radprice_sync.py sync"

FROM python:3.12-slim
WORKDIR /app
COPY requirements.txt radprice_sync.py ./
RUN pip install --no-cache-dir -r requirements.txt "psycopg[binary]"
CMD ["python", "radprice_sync.py", "watch"]
# docker run -d --restart=always --env-file .env radprice-sync

GET /radprice/buscar?q=cimento+cp+ii+32&uf=CE&limit=5
x-radprice-timestamp: 1793102400
x-radprice-signature: <Ed25519 em base64 de "1793102400\n/radprice/buscar?q=cimento+cp+ii+32&uf=CE&limit=5">
x-radprice-key-id: <id da chave pública>

{"items": [{"externalId": "1001-ALDEOTA", "name": "Cimento CP II-E-32 saco 50kg",
            "price": "38.90", "city": "Fortaleza", "uf": "CE", "store": "Loja Aldeota",
            "url": "https://www.suaempresa.com.br/p/cimento-cp2"}]}

GET  /integrations/me                         situação, plano, itens e último envio
POST /integrations/sync          {"kind":"full"|"incremental"}   -> {"runId"}
POST /integrations/sync/{runId}/items  {"items":[…até 1000], "remove":["id_externo", …]}
                                                  -> {"accepted", "removed", "rejected":[{"index","externalId","error"}]}
POST /integrations/sync/{runId}/finish  {}        -> {"upserted", "removed", "total"}