//package org.jeecg.modules.dry.controller;
//
//import com.kangaroohy.milo.model.ReadWriteEntity;
//import com.kangaroohy.milo.service.MiloService;
//import io.swagger.annotations.Api;
//import io.swagger.annotations.ApiOperation;
//import lombok.extern.slf4j.Slf4j;
//import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
//import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
//import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
//import org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode;
//import org.eclipse.milo.opcua.stack.core.types.builtin.Variant;
//import org.jeecg.common.api.vo.Result;
//import org.jeecg.modules.dry.entity.DryOpcDevice;
//import org.jeecg.modules.dry.service.IDryOpcDeviceService;
//import org.jeecg.modules.dry.vo.CommandMessageVo;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.RequestBody;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import java.util.List;
//import java.util.concurrent.ExecutionException;
//
///**
// * opc控制器，用于控制现场摄像头电源，灯的开关
// */
//
//@Api(tags="OPC控制器")
//@RestController
//@RequestMapping("/dry/opc")
//@Slf4j
//public class OpcController {
//
//    @Autowired
//    private MiloService miloService;
//
//    @Autowired
//    private IDryOpcDeviceService opcDeviceService;
//
//
//    @ApiOperation(value="发送控制指令", notes="向服务端发送控制指令，由服务端转发给控制模块")
//    @PostMapping("/sendWriteCommand")
//    public Result<?> sendWriteCommand(@RequestBody CommandMessageVo msgVo) throws Exception {
//
//        miloService.writeToOpcUa(ReadWriteEntity.builder()
//                .identifier(msgVo.getCode())
//                //Kep中是Boolean类型
//                .value(Boolean.valueOf(msgVo.getMsg()))
//                .build());
//        return Result.OK();
//    }
//
//    @ApiOperation(value="发送控制指令", notes="向服务端发送控制指令，由服务端转发给控制模块")
//    @PostMapping("/initDevice")
//    public Result<?> initDevice() throws Exception {
//        List<DryOpcDevice> list = opcDeviceService.list();
//
//        list.forEach(item -> {
//
//        });
//
//        return Result.OK();
//    }
//}