干燥机配套车间生产管理系统/云平台服务端
blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
bsw215583320
2024-04-16 c2fccb01b972176dc3da5a497b5e904025e9e98d 
 jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/controller/OpcController.java


¶Ô±ÈÐÂÎļþ


@@ -0,0 +1,66 @@


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();


    }


}