package com.zhitan.controller;

import com.zhitan.model.entity.OpcData;
import com.zhitan.service.IOpcService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * OPC UA控制器
 */
@Slf4j
@RestController
@RequestMapping("/api/opc")
public class OpcController {

    private final IOpcService opcService;

    @Autowired
    public OpcController(IOpcService opcService) {
        this.opcService = opcService;
    }

    /**
     * 获取OPC UA连接状态
     */
    @GetMapping("/status")
    public boolean getConnectionStatus() {
        return opcService.isConnected();
    }

    /**
     * 手动连接OPC UA服务器
     */
    @PostMapping("/connect")
    public boolean connect() {
        return opcService.connect();
    }

    /**
     * 断开OPC UA连接
     */
    @PostMapping("/disconnect")
    public void disconnect() {
        opcService.disconnect();
    }

    /**
     * 启动数据采集
     */
    @PostMapping("/start")
    public void startCollection() {
        opcService.startDataCollection();
    }

    /**
     * 停止数据采集
     */
    @PostMapping("/stop")
    public void stopCollection() {
        opcService.stopDataCollection();
    }

    /**
     * 读取所有节点数据
     */
    @GetMapping("/data")
    public List<OpcData> readAllData() {
        return opcService.readAllNodes();
    }
}