package cn.stylefeng.guns.modular.opcua.cert;


import cn.stylefeng.guns.modular.cm.passingStationCollection.entity.PassingStationCollection;
import cn.stylefeng.guns.modular.cm.passingStationCollection.service.PassingStationCollectionService;
import cn.stylefeng.guns.modular.om.productionOrdeInfo.model.params.ProductionOrdeInfoParam;
import cn.stylefeng.guns.modular.om.productionOrdeInfo.model.result.ProductionOrdeInfoResult;
import cn.stylefeng.guns.modular.om.productionOrdeInfo.service.ProductionOrdeInfoService;
import cn.stylefeng.guns.modular.opcua.client.ClientHandler;
import cn.stylefeng.guns.modular.opcua.config.BeanUtils;
import cn.stylefeng.guns.modular.opcua.entity.NodeEntity;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.SneakyThrows;
import org.apache.poi.ss.formula.functions.T;

import java.util.List;
import java.util.Timer;
import java.util.TimerTask;

public class Heartbeat {
    ClientHandler clientHandler=new ClientHandler();
    Timer timer1 = new Timer();


    private ProductionOrdeInfoService orderService = BeanUtils.getBean(ProductionOrdeInfoService.class);

    private PassingStationCollectionService stationCollectionService = BeanUtils.getBean(PassingStationCollectionService.class);


    public void snIsItIssued(String Node, String value) throws Exception  {
        timer1.schedule(timerTask,0,5000);
        System.out.println("五秒执行一次定时任务-----------------------");
    }

    TimerTask timerTask = new TimerTask() {
        @Override
        public void run() {
            ProductionOrdeInfoParam param = new ProductionOrdeInfoParam();
            param.setOrderStatus("3");
            ProductionOrdeInfoResult bySpec = orderService.findBySpec(param);
            if(bySpec!=null){
                List<PassingStationCollection> list = stationCollectionService.list(new QueryWrapper<PassingStationCollection>()
                        .eq("location_code", "OP1010")
                        .eq("work_order_no",bySpec.getWorkOrderNo())
                );
                if(list.size()==bySpec.getPlanQty()){
                    NodeEntity over1= NodeEntity.builder().index(2).identifier("nbu01.OP1010.Spare")
                            .value("2").type("short").build();
                    try {
                        Boolean out1=clientHandler.write(over1);
                    } catch (Exception e) {
                        throw new RuntimeException(e);
                    }
                }else {
                    NodeEntity over2 = NodeEntity.builder().index(2).identifier("nbu01.OP1010.Spare")
                            .value("1").type("short").build();
                    try {
                        Boolean out2 = clientHandler.write(over2);
                    } catch (Exception e) {
                        throw new RuntimeException(e);
                    }
                }
            }else {
                NodeEntity over1= NodeEntity.builder().index(2).identifier("nbu01.OP1010.Spare")
                        .value("2").type("short").build();
                try {
                    Boolean out1=clientHandler.write(over1);
                } catch (Exception e) {
                    throw new RuntimeException(e);
                }
            }
        }
    };





    public void mesPreparationOk(String Node, String value) throws Exception {
        NodeEntity node = NodeEntity.builder().index(2).identifier(Node)
                .value("true").type("boolean").build();
        Boolean out = clientHandler.write(node);
        System.out.println("111111111mes准备好:---------------------"+out);
    }

    public void mesPulseWidth(String Node, String value) throws Exception  {
        while (true) {
            NodeEntity node = NodeEntity.builder().index(2).identifier(Node)
                    .value("true").type("boolean").build();
            Boolean out = clientHandler.write(node);
            try {
                Thread.sleep(2000);  // 暂停两秒钟
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            NodeEntity node1 = NodeEntity.builder().index(2).identifier(Node)
                    .value("false").type("boolean").build();
            Boolean out1 = clientHandler.write(node1);
            try {
                Thread.sleep(2000);  // 暂停两秒钟
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void mesPreparationOk1(String Node, String value) throws Exception {
        NodeEntity node = NodeEntity.builder().index(2).identifier(Node)
                .value("true").type("boolean").build();
        Boolean out = clientHandler.write(node);
        System.out.println("mes准备好:---------------------"+out);
    }

    public void mesPulseWidth1(String Node, String value) throws Exception  {
        while (true) {
            NodeEntity node = NodeEntity.builder().index(2).identifier(Node)
                    .value("true").type("boolean").build();
            Boolean out = clientHandler.write(node);
            try {
                Thread.sleep(2000);  // 暂停两秒钟
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            NodeEntity node1 = NodeEntity.builder().index(2).identifier(Node)
                    .value("false").type("boolean").build();
            Boolean out1 = clientHandler.write(node1);
            try {
                Thread.sleep(2000);  // 暂停两秒钟
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void plcPreparationOk(String Node, String value) throws Exception {
        while (true) {
            NodeEntity plcNode = NodeEntity.builder().index(2).identifier(Node).build();
            String read = clientHandler.read(plcNode);
            if(read.equals("1")){
                System.out.println("plc系统准备好！！！");
            }
            try {
                Thread.sleep(2000);  // 暂停两秒钟
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void plcPulseWidth(String Node, String value) throws Exception  {
        timer = new Timer();
        timer.schedule(new HeartbeatTask(), 0, 2000); // 每2秒钟执行一次HeartbeatTask
    }

    private Timer timer;
    private static int lastSignal = 3;

    class HeartbeatTask extends TimerTask {
        @SneakyThrows
        public void run() {
            int currentSignal = getCurrentSignal(); // 获取当前的信号值，这里假设通过一个函数获取
            if (currentSignal != lastSignal) {
                System.out.println("Signal changed from " + lastSignal + " to " + currentSignal);
                lastSignal = currentSignal;
            }
        }
    }

    // 假设这是一个函数，用于获取对方的心跳信号值
    private int getCurrentSignal() throws Exception {
        NodeEntity plcNode = NodeEntity.builder().index(2).identifier("nbu01.system.PLC_Server_lifebeat").build();
        String read = clientHandler.read(plcNode);
        return Integer.valueOf(read); // 这里只是随机返回一个0到9之间的整数作为信号值，仅作示例使用
    }

    public ProductionOrdeInfoResult getOrder(){
        ProductionOrdeInfoParam param = new ProductionOrdeInfoParam();
        param.setOrderStatus("3");
        return orderService.findBySpec(param);
    }

}