Zum Hauptinhalt springen

6. OPC-Service

Zugriff erfolgt über client.opc(). OPC repräsentiert eine Quellverbindung (Source Connection). Es ist der Eintrittspunkt für externe Daten wie OPC UA Server, PLC, Modbus-Geräte, Datenbanken, Message Broker, REST API usw.

ID-Regeln: Präfix OPC_ ist erforderlich. Weitere Informationen finden Sie unter Domänen-ID-Regeln.

6.1 Methodenübersicht​

MethodeRückgabetypHTTPEndpunkt
create(OPCRequestV5)OPCResponseV5 oder nullPOST/api/v5/opc
update(opc_id, OPCRequestV5)OPCResponseV5 oder nullPUT/api/v5/opc/{id}
delete(opc_id)booleanDELETE/api/v5/opc/{id}
get(opc_id)OPCResponseV5 oder nullGET/api/v5/opc/{id}
list()List<OPCResponseV5>GET/api/v5/opc
listBySite(site_id)List<OPCResponseV5>GET/api/v5/opc?site_id=...
listByType(opc_source_type)List<OPCResponseV5>GET/api/v5/opc?opc_source_type=...
exists(opc_id)booleanGET/api/v5/opc/{id}/exists
count()longGET/api/v5/opc/count
countBySite(site_id)longGET/api/v5/opc/count?site_id=...

6.2 Protokolle und Quelltypen​

Eine Verbindung besitzt ein Protokoll (opc_protocol, z. B. S7·LS·MELSEC·MODBUS·OPCUA·MQTT_CLIENT·API). Der Quelltyp und die Erfassungsinstanz werden aus dem Protokoll abgeleitet und nicht direkt geschrieben. Die maßgebliche Definition des Protokollvokabulars befindet sich im Protokollkatalog von plantpulse-event.

QuelltypVerwendung
OPCOPC UA Server
PLCDirektverbindung zu PLC (z. B. Siemens, LS, Mitsubishi, Allen-Bradley)
MODBUSModbus TCP/UDP/RTU Geräte
DATABASEPolling externer Datenbanken
MESSAGINGMessage Broker · Push-Protokolle (MQTT, Kafka, HTTP, WebSocket, CoAP, ROS 2)
APIDaten, die über die PlantPulse REST API eingehen
SYSTEMSelbstüberwachung des Edge Gateways (OPC_SYSTEM_<edge_id>, vom Edge deklariert)

6.3 OPCRequestV5 / OPCResponseV5​

FeldTypBeschreibung
opc_idStringOPC ID (PK, OPC_ erforderlich)
opc_nameStringOPC Anzeigename
opc_protocolStringProtokollcode (z. B. S7, LS, OPCUA, API)
opc_source_ipStringIP oder Host der tatsächlichen Quelle (PLC·Gerät·OPC UA Server·DB·Broker)
opc_source_portintPort der tatsächlichen Quelle
opc_edge_idStringEdge, die diese Verbindung erfasst. Leer lassen, wenn die Platform direkt erfasst
opc_source_typeString(Nur Antwort) Aus dem Protokoll abgeleiteter Quelltyp
opc_collected_byString(Nur Antwort) EDGE / PLATFORM — aus Protokoll abgeleitet
site_idStringZugehöriger Standort
descriptionStringBeschreibung

Protokoll und Adresse von Verbindungen, die vom Edge erfasst werden (Verbindungen mit opc_edge_id), werden nur über den Edge Sync (PUT /api/v5/opc/{id}/sync) geschrieben. In der Platform-Oberfläche sind diese schreibgeschützt.

6.4 Anwendungsbeispiele​

OPC erstellen (PLC-Direktverbindung)​

import plantpulse.api.v5.dto.request.OPCRequestV5;
import plantpulse.api.v5.dto.response.OPCResponseV5;

OPCRequestV5 req = new OPCRequestV5();
req.setOpc_id("OPC_PLC_L1_001");
req.setOpc_name("Line1 메인 PLC");
req.setOpc_protocol("S7");
req.setSite_id("SITE_DJ");
req.setOpc_source_ip("192.168.10.50");
req.setOpc_source_port(102);

OPCResponseV5 created = client.opc().create(req);

OPC erstellen (Externe REST API)​

OPCRequestV5 api = new OPCRequestV5();
api.setOpc_id("OPC_API_ERP_001");                          // OPC_ 접두사 필수
api.setOpc_name("ERP 생산 실적 API");
api.setOpc_protocol("API");
api.setSite_id("SITE_DJ");
api.setDescription("매시간 ERP에서 생산 카운트 폴링");
client.opc().create(api);

OPC erstellen (Zum Testen — API-Quelle)​

OPCRequestV5 v = new OPCRequestV5();
v.setOpc_id("OPC_TEST_001");
v.setOpc_name("테스트용 OPC");
v.setOpc_protocol("API");
v.setSite_id("SITE_000001");
client.opc().create(v);

OPC-Abfrage pro Standort​

import java.util.List;

List<OPCResponseV5> djOpcs = client.opc().listBySite("SITE_DJ");
for (OPCResponseV5 opc : djOpcs) {
    System.out.println(opc.getOpc_id() + " (" + opc.getOpc_protocol() + ", " + opc.getOpc_source_type() + ")");
}

OPC-Abfrage pro Quelltyp​

// 사이트를 가리지 않고 PLC 만
List<OPCResponseV5> plcs = client.opc().listByType("PLC");

// 사이트를 가리지 않고 Modbus 만
List<OPCResponseV5> modbus = client.opc().listByType("MODBUS");

Zählung​

long total      = client.opc().count();
long djCount    = client.opc().countBySite("SITE_DJ");
System.out.printf("전체 OPC: %d, 대전공장: %d%n", total, djCount);

CUD-Lebenszyklus​

String opcId = "OPC_PLC_L1_001";

// 생성
OPCRequestV5 req = new OPCRequestV5();
req.setOpc_id(opcId);
req.setOpc_name("초기 이름");
req.setOpc_protocol("S7");
req.setSite_id("SITE_DJ");
client.opc().create(req);

// 존재 여부 확인
assert client.opc().exists(opcId);

// 수정
req.setOpc_name("수정된 이름");
client.opc().update(opcId, req);

// 삭제
boolean deleted = client.opc().delete(opcId);
assert !client.opc().exists(opcId);

6.5 Anwendungsszenarien​

Szenario — Erfassung von Tags nach Registrierung einer PLC in einer neuen Linie​

// 1) OPC 등록
OPCRequestV5 plc = new OPCRequestV5();
plc.setOpc_id("OPC_PLC_L2_001");
plc.setOpc_protocol("S7");
plc.setSite_id("SITE_DJ");
plc.setOpc_source_ip("192.168.10.60");
plc.setOpc_source_port(102);
client.opc().create(plc);

// 2) 수집이 시작되면 — 이후 Tag 서비스에서 확인
List<TagResponseV5> tags = client.tag().listByOpc("OPC_PLC_L2_001");
System.out.println("수집된 태그 수: " + tags.size());

Nächste Schritte​