Simjob Platform

O que é o Simjob Platform?

O Simjob Platform é um sistema operacional industrial de ponta a ponta desenhado para conectar equipamentos físicos (máquinas, PLCs, CLPs, sensores IoT) a sistemas de gestão, painéis de análise e agentes de inteligência artificial — tudo em tempo real.

A plataforma opera com filosofia Edge-first: toda a coleta, processamento e persistência de dados acontece localmente na planta industrial, garantindo operação autônoma mesmo sem conectividade com a nuvem. A sincronização com destinos de nuvem (Simjob Cloud, Google BigTable, Alibaba TableStore) ocorre de forma assíncrona, com fila de até 100.000 eventos e retry automático.

Princípios de Design

Arquitetura da Plataforma

A plataforma é composta por múltiplos serviços independentes que se comunicam via REST, WebSocket, gRPC, MQTT e Redis Pub/Sub.

Fluxo de Dados

Coleta e Ingestão IoT

Consumo em Tempo Real

Pipeline de IA

Inspeção Visual

Requisitos de Servidor

Configuração Edge (config.yaml)

server:
  address: ":1870"
storage:
  max_size_gb: 50
  max_days: 30
influxdb:
  enabled: true
  url: "http://localhost:8086"
  bucket: "sensor-data"
timescaledb:
  enabled: true
  host: "localhost"
  port: 5432
sync:
  enabled: true
  interval: 30s
  batch_size: 1000
  max_queue_size: 100000
  retry_interval: 5m

Plugins Edge disponíveis

MES Manager — Manufacturing Execution System

Interface web completa para gestão e monitoramento da produção em tempo real, consumindo the Edge API via REST e WebSocket.

Funcionalidades

Entidades de Dados

WMS Manager — Warehouse Management System

Gestão completa de armazém com suporte a endereçamento, movimentações, inventário rotativo e integração com coletores via MQTT.

Funcionalidades

Entidades de Dados

APS Manager — Advanced Planning & Scheduling

Módulo de planejamento avançado com capacidade finita e três estratégias de otimização: determinística (OR-Tools), genética e via LLM.

APS Solver — Motores de Otimização

Comunicação APS

MCP Server — Agente de IA Industrial

Implementação do Model Context Protocol (MCP) que expõe o ambiente industrial como contexto para modelos de linguagem. Permite que agentes de IA tomem ações e respondam perguntas sobre a planta com base em dados reais.

Capacidades

Dependências Principais

@modelcontextprotocol/sdk  # MCP protocol implementation
openai                     # LLM integration
mongodb                    # Document persistence
redis                      # Cache e sessões
exceljs + pdf-parse        # Processamento de documentos
express + swagger          # HTTP API

Aura — Orquestrador de Agentes de IA

Sistema de orquestração de agentes de IA sobre múltiplas fontes de dados industriais e empresariais, com streaming de respostas via WebSocket.

Conectores de Dados

Vision — Visão Computacional Industrial

Sistema completo de visão computacional para inspeção de qualidade, monitoramento de linhas e análise de câmeras industriais.

Componentes

Dependências Python

fastapi + uvicorn    # REST API
opencv-python        # Computer vision
paho-mqtt            # MQTT integration
minio                # Object storage client
dashscope            # Alibaba AI Vision API
oss2                 # Alibaba OSS
pydantic             # Data validation

ASAP — Comunicação Omnicanal com IA

Plataforma de atendimento omnicanal com agente IA para suporte industrial — integra WhatsApp, Chat Web, e-mail e notificações em tempo real.

Integrações

Outros Módulos

Stack Tecnológica Completa

Portas e Endpoints

Estratégia de Dados

Segurança

Deploy e Operação

Desenvolvimento Local

# Iniciar todos os componentes
.\start-dev-all.ps1

# Componentes específicos
.\start-dev-all.ps1 -Components edge,mes-manager,wms-manager

# Pular Redis (já rodando)
.\start-dev-all.ps1 -SkipRedis

Docker Compose (Edge + Infra)

cd edge
docker-compose up -d
# Inclui: edge-server, postgres, influxdb, redis

Requisitos de Servidor

API de Integração

O módulo de integração expõe um conjunto dedicado de endpoints REST simplificados que permite que sistemas externos (ERPs, MESs legados, sistemas SCADA, portais de clientes) troquem dados com o Edge sem precisar conhecer a estrutura interna da API.

A filosofia é uma chamada resolve tudo: ao enviar uma Ordem de Produção, por exemplo, o produto já pode vir embutido na mesma requisição — o Edge cria o produto se não existir e vincula à ordem automaticamente.

Fluxo Geral de Integração

Entrada de Dados

Todos os endpoints de entrada aceitam Content-Type: application/json e retornam o objeto criado com status 201 Created (ou 207 Multi-Status para operações em lote).

Ordens de Produção

Ao enviar uma ordem, o produto pode vir embutido no campo product. O Edge faz upsert do produto por código antes de criar a ordem — eliminando a necessidade de chamadas separadas.

{
  "code": "OP-2026-001",
  "machine_code": "MACH-01",
  "planned_quantity": 500,
  "priority": 1,
  "scheduled_start": "2026-02-24T06:00:00Z",
  "scheduled_end":   "2026-02-24T14:00:00Z",
  "notes": "Produção urgente — cliente XYZ",
  "product": {
    "code": "PROD-XYZ",
    "name": "Peça Injetada XYZ",
    "unit": "pcs",
    "cycle_time": 1.2
  }
}

{
  "status": "in_progress",
  "notes": "Iniciado no turno da manhã"
}

Produtos

{
  "code": "PROD-ABC",
  "name": "Componente ABC",
  "description": "Componente usinado em alumínio",
  "unit": "pcs",
  "cycle_time": 2.5
}

Ficha Técnica (Especificação)

Envia a ficha técnica completa de um produto — características e normas podem ser passadas inline no mesmo JSON.

{
  "product_code": "PROD-XYZ",
  "version": "v2.1",
  "technical_description": "Peça injetada em PP com 20% fibra de vidro",
  "measurement_unit": "mm",
  "characteristics": [
    { "name": "Comprimento",   "value": "120",  "unit": "mm" },
    { "name": "Largura",       "value": "45",   "unit": "mm" },
    { "name": "Espessura",     "value": "3.5",  "unit": "mm" },
    { "name": "Peso nominal",  "value": "85.2", "unit": "g"  }
  ],
  "norms": [
    { "norm_code": "ABNT NBR 15600", "description": "Plásticos — tensão de tração", "norm_type": "dimensional" }
  ]
}

Estrutura de Materiais (BOM)

{
  "parent_product_code": "PROD-MONTADO",
  "child_product_code":  "PROD-XYZ",
  "quantity": 2,
  "unit": "pcs",
  "relation_type": "consumes",
  "level": 1
}

Processos de Fabricação

{
  "product_code": "PROD-XYZ",
  "name": "Injeção",
  "step_sequence": 1,
  "machine_code": "INJ-01",
  "description": "Ciclo de injeção em PP",
  "cycle_time": 1.2
}

Documentação / Instrução de Trabalho

{
  "product_code": "PROD-XYZ",
  "process_code": "Injeção",
  "name": "IT-001 — Instrução de Injeção PP",
  "type": "procedure",
  "version": "Rev. 3",
  "file_url": "https://bucket.simjob.com.br/docs/IT-001-Rev3.pdf",
  "description": "Parâmetros operacionais e sequência de setup da injetora"
}

Especificações de Qualidade

{
  "product_code": "PROD-XYZ",
  "criterion": "Dimensional — comprimento",
  "test_method": "Paquímetro digital 0.01mm",
  "acceptance_limit": "120 ± 0.3 mm",
  "frequency": "1 a cada 50 peças"
}

Capacidade de Equipamento

{
  "machine_code": "INJ-01",
  "parameter": "Pressão de injeção",
  "default_value": 800,
  "min_range": 500,
  "max_range": 1200,
  "unit": "bar"
}

Rotas de Fabricação

Uma rota agrupa operações sequenciais que um produto percorre — com máquina, tempo de ciclo e setup por operação, tudo em uma única chamada.

{
  "product_code": "PROD-XYZ",
  "code": "ROTA-XYZ-V1",
  "name": "Rota Padrão — Peça XYZ",
  "version": "v1",
  "operations": [
    { "sequence": 1, "code": "OP-01", "name": "Injeção",    "machine_code": "INJ-01", "cycle_time": 1.2, "setup_time": 15 },
    { "sequence": 2, "code": "OP-02", "name": "Rebarbação", "machine_code": "REB-01", "cycle_time": 0.5, "setup_time": 5  },
    { "sequence": 3, "code": "OP-03", "name": "Inspeção",   "machine_code": "INS-01", "cycle_time": 0.3, "setup_time": 0  }
  ]
}

Resumo de Endpoints de Entrada

Consulta de Dados (Outbound)

Para obter dados produzidos no sistema — especialmente apontamentos realizados — use os endpoints de consulta. Todos suportam paginação e filtros por período, máquina, ordem ou tipo.

Apontamentos Realizados

{
  "total": 127,
  "page": 1,
  "limit": 50,
  "items": [
    {
      "id": 1042,
      "type_code": "PROD",
      "type_name": "Apontamento de Produção",
      "node_type": "machine",
      "node_id": 5,
      "node_name": "Injetora 01",
      "order_code": "OP-2026-001",
      "occurred_at": "2026-02-15T08:32:00Z",
      "registered_at": "2026-02-15T08:32:05Z",
      "status": "active",
      "variables": {
        "quantidade_produzida": 120,
        "quantidade_refugo": 3,
        "tempo_ciclo_real": 1.18
      },
      "form_data": { "turno": "Manhã", "operador": "João Silva" }
    }
  ]
}

Resumo de Ordem

{
  "code": "OP-2026-001",
  "status": "in_progress",
  "product_code": "PROD-XYZ",
  "product_name": "Peça Injetada XYZ",
  "planned_quantity": 500,
  "produced_quantity": 320,
  "scrapped_quantity": 8,
  "scheduled_start": "2026-02-24T06:00:00Z",
  "scheduled_end":   "2026-02-24T14:00:00Z",
  "actual_start":    "2026-02-24T06:08:00Z",
  "actual_end":       null,
  "completion_pct": 64.0
}

Webhooks

Os webhooks permitem que o Edge notifique proativamente o sistema externo quando eventos ocorrem — eliminando a necessidade de polling periódico. O Edge realiza um POST com o payload do evento para a URL cadastrada no momento do ocorrido.

Eventos Disponíveis

Gerenciamento de Webhooks

{
  "url": "https://erp.empresa.com.br/simjob/events",
  "events": ["occurrence.created", "order.completed"],
  "secret": "minha-chave-secreta-hmac"
}

Payload Enviado ao Webhook

POST https://erp.empresa.com.br/simjob/events
Content-Type: application/json
X-Simjob-Signature: sha256=a3f5...d901

{
  "event": "occurrence.created",
  "timestamp": "2026-02-24T08:15:00Z",
  "data": {
    "id": 1043,
    "type_code": "PROD",
    "type_name": "Apontamento de Produção",
    "node_type": "machine",
    "node_name": "Injetora 01",
    "order_code": "OP-2026-001",
    "occurred_at": "2026-02-24T08:14:55Z",
    "status": "active",
    "variables": { "quantidade_produzida": 80, "quantidade_refugo": 1 }
  }
}

Verificação de Assinatura (HMAC-SHA256)

Quando um secret é configurado no webhook, cada requisição enviada pelo Edge inclui o header X-Simjob-Signature com o formato sha256=<hex>. O receptor deve calcular o HMAC do corpo da requisição usando o mesmo secret e comparar com o header para garantir autenticidade.

import hmac, hashlib

def verify(body: bytes, secret: str, signature_header: str) -> bool:
    expected = "sha256=" + hmac.new(
        secret.encode(), body, hashlib.sha256
    ).hexdigest()
    return hmac.compare_digest(expected, signature_header)

const crypto = require('crypto');

function verify(body, secret, signatureHeader) {
  const expected = 'sha256=' + crypto
    .createHmac('sha256', secret)
    .update(body)
    .digest('hex');
  return crypto.timingSafeEqual(
    Buffer.from(expected), Buffer.from(signatureHeader)
  );
}

Autenticação da API de Integração

A API de integração segue o mesmo mecanismo de autenticação do Edge. Por padrão, se a autenticação estiver habilitada (auth.enabled: true), as requisições precisam de um dos mecanismos abaixo:

Configuração Recomendada para Integração

Para sistemas de integração (ERPs, scripts automáticos), o método preferido é API Key estática configurada no config.yaml do Edge:

auth:
  enabled: true
  jwt_secret: "sua-chave-jwt-secreta"
  api_keys:
    - "api-key-do-seu-erp-123456"

curl -X POST https://edge.empresa.com.br/api/v1/integration/orders \
  -H "Content-Type: application/json" \
  -H "X-API-Key: api-key-do-seu-erp-123456" \
  -d '{ "code": "OP-001", "machine_code": "MACH-01", ... }'

Erros Comuns