# .env — @CanalQb Loop AdSense PJ INTER_CLIENT_ID=seu_client_id_aqui INTER_CLIENT_SECRET=seu_client_secret_aqui INTER_CERT_PATH=./certs/inter_cert.crt INTER_KEY_PATH=./certs/inter_key.key PERCENTUAL_ADS=0.50 VALOR_MINIMO=70 EMAIL_DESTINO=seuemail@gmail.com # Chave Pix do Google Ads (CNPJ do Google Brasil) # Atenção: o Google Ads NÃO aceita Pix programático de entrada. # Use esse script para notificação + registro automático. # O Pix no Ads ainda requer confirmação humana via painel. PIX_DESTINO_GOOGLE_ADS=06990590000123 PLANILHA_LOG=./loop_adsense.csv

// ═══════════════════════════════════════════════════════════ // @CanalQb — Loop AdSense → Google Ads | Pessoa Jurídica // Inter Developer API v2 — Node.js // Instale: npm install axios dotenv node-cron nodemailer fs-extra // Execute: node loop_adsense_pj.js // ═══════════════════════════════════════════════════════════ 'use strict'; require('dotenv').config(); const https = require('https'); const axios = require('axios'); const cron = require('node-cron'); const nodemailer = require('nodemailer'); const fs = require('fs'); // ── Configurações via .env ────────────────────────────────── const CFG = { clientId: process.env.INTER_CLIENT_ID, clientSecret: process.env.INTER_CLIENT_SECRET, cert: fs.readFileSync(process.env.INTER_CERT_PATH), key: fs.readFileSync(process.env.INTER_KEY_PATH), percentual: parseFloat(process.env.PERCENTUAL_ADS) || 0.5, valorMinimo: parseFloat(process.env.VALOR_MINIMO) || 70, emailDestino: process.env.EMAIL_DESTINO, logPath: process.env.PLANILHA_LOG || './loop_adsense.csv' }; // ── HTTPS Agent com mTLS (obrigatório Inter API) ──────────── const tlsAgent = new https.Agent({ cert: CFG.cert, key: CFG.key }); // ── 1. Obtém token OAuth2 do Inter ───────────────────────── async function getToken() { try { const params = new URLSearchParams({ client_id: CFG.clientId, client_secret: CFG.clientSecret, scope: 'extrato.read pagamento-pix.write', grant_type: 'client_credentials' }); const r = await axios.post( 'https://cdpj.partners.bancointer.com.br/oauth/v2/token', params, { httpsAgent: tlsAgent } ); return r.data.access_token; } catch (e) { console.error('@CanalQb getToken erro:', e.message); return null; } } // ── 2. Consulta extrato dos últimos 5 dias ────────────────── async function getExtrato(token) { try { const hoje = new Date(); const inicio = new Date(hoje - 5 * 86400000); const fmt = d => d.toISOString().split('T')[0]; const r = await axios.get( 'https://cdpj.partners.bancointer.com.br/banking/v2/extrato' + `?dataInicio=${fmt(inicio)}&dataFim=${fmt(hoje)}`, { headers: { Authorization: `Bearer ${token}` }, httpsAgent: tlsAgent } ); return r.data.transacoes || []; } catch (e) { console.error('@CanalQb getExtrato erro:', e.message); return []; } } // ── 3. Registra transação no CSV de log fiscal ────────────── function registrarLog(total, ads, reserva) { try { const linha = `${new Date().toLocaleString('pt-BR')},` + `AdSense,R$ ${total.toFixed(2)},` + `R$ ${ads.toFixed(2)},R$ ${reserva.toFixed(2)},` + `Aguardando Pix\n`; if (!fs.existsSync(CFG.logPath)) { fs.writeFileSync(CFG.logPath, 'Data,Origem,Total,Para Ads,Reserva,Status\n'); } fs.appendFileSync(CFG.logPath, linha); console.log('@CanalQb: log registrado —', linha.trim()); } catch (e) { console.error('@CanalQb registrarLog erro:', e.message); } } // ── 4. Envia alerta por e-mail ────────────────────────────── async function enviarAlerta(total, ads, reserva) { try { // Configure seu SMTP (Gmail, SendGrid, etc.) const transporter = nodemailer.createTransport({ service: 'gmail', auth: { user: process.env.EMAIL_DESTINO, pass: process.env.EMAIL_APP_PASSWORD // Senha de app do Gmail } }); await transporter.sendMail({ from: process.env.EMAIL_DESTINO, to: CFG.emailDestino, subject: `📢 AdSense R$ ${total.toFixed(2)} → Reinvista R$ ${ads.toFixed(2)} no Ads`, text: `🚀 @CanalQb — Depósito AdSense detectado!\n\n` + `💰 Total recebido: R$ ${total.toFixed(2)}\n` + `📢 50% Google Ads: R$ ${ads.toFixed(2)}\n` + `🏦 50% Reserva: R$ ${reserva.toFixed(2)}\n\n` + `📲 ACESSE AGORA:\n` + `https://ads.google.com/aw/billing/summary\n` + `→ Adicionar fundos → Pix → R$ ${ads.toFixed(2)}\n\n` + `📊 NOTA FISCAL: lembre-se de emitir NFS-e de exportação\n` + ` para esta receita no portal da sua prefeitura.\n\n` + `@CanalQb — canalqb.com.br` }); console.log('@CanalQb: e-mail enviado para', CFG.emailDestino); } catch (e) { console.error('@CanalQb enviarAlerta erro:', e.message); } } // ── 5. Lógica principal ───────────────────────────────────── async function verificarDepositoAdSense() { console.log('@CanalQb: verificando extrato Inter —', new Date().toLocaleString('pt-BR')); const token = await getToken(); if (!token) return; const transacoes = await getExtrato(token); if (!transacoes.length) { console.log('@CanalQb: nenhuma transação encontrada.'); return; } for (const tx of transacoes) { const descr = (tx.descricao || '').toLowerCase(); const tipo = (tx.tipoTransacao || '').toLowerCase(); const valor = parseFloat(tx.valor) || 0; // Filtra: crédito + origem AdSense/Google + valor mínimo const ehAdSense = descr.includes('adsense') || descr.includes('google ads') || descr.includes('google payment'); if (tipo === 'credito' && ehAdSense && valor >= CFG.valorMinimo) { const ads = valor * CFG.percentual; const reserva = valor - ads; registrarLog(valor, ads, reserva); await enviarAlerta(valor, ads, reserva); console.log(`@CanalQb ✅ Depósito AdSense: R$ ${valor.toFixed(2)}`); break; // Processa apenas o primeiro encontrado } } } // ── 6. Agenda execução diária às 07:00 ───────────────────── cron.schedule('0 7 * * *', () => { verificarDepositoAdSense().catch(e => console.error('@CanalQb cron erro:', e.message) ); }, { timezone: 'America/Sao_Paulo' }); console.log('@CanalQb Loop AdSense PJ iniciado. Próxima execução: 07:00 BRT'); // Execução imediata para teste (remova em produção) // verificarDepositoAdSense();