package com.mes.plcTaskThread;

import com.mes.md.entity.Machine;
import com.mes.md.entity.Tasking;
import com.mes.md.mapper.MachineMapper;
import com.mes.md.service.TaskingService;
import com.mes.service.ModbusTcp;
import com.mes.service.PlcAgreement;
import com.mes.service.PlcParameter;
import com.mes.utils.HexUtil;
import lombok.extern.slf4j.Slf4j;

import java.text.SimpleDateFormat;
import java.util.*;

@Slf4j
public class MachineDispensing extends Thread {


    private MachineMapper machineMapper;
    private TaskingService taskingService;
    public static Long machineId = 16L;
    public List<Map> sendRecords = new ArrayList<>();
    public Machine thisMachine;

    public MachineDispensing(Machine machine, MachineMapper machineMapper, TaskingService taskingService) {
        this.thisMachine = machine;
        this.machineMapper = machineMapper;
        this.taskingService = taskingService;
    }

    public void plcStart() {
        Machine machine = machineMapper.selectById(thisMachine.getId());
        String fileName = machine.getFileName();
        ModbusTcp modbusTcp1 = new ModbusTcp(machine.getIp(), machine.getPort(), fileName);
        modbusTcp1.connect();
        PlcAgreement plcAgreement = modbusTcp1.getPlcAgreement(fileName);
        try {
            if (!modbusTcp1.read(plcAgreement)) {
                log.info("通讯读取新数据失败");
                modbusTcp1.close();
                return;
            }
            PlcParameter plcRequest = plcAgreement.getPlcParameter("plcRequest");//请求字
            PlcParameter plcRequestID = plcAgreement.getPlcParameter("plcRequestID");//请求ID
            PlcParameter mesSend = plcAgreement.getPlcParameter("mesSend");//发送字
            PlcParameter mesSendID = plcAgreement.getPlcParameter("mesSendID");//发送ID
//        PlcParameterInfo drawingMark =plcParameterObject.getPlcParameter("drawingGlue");//点胶图纸地址
            PlcParameter JPZX = plcAgreement.getPlcParameter("JPZX");//类型
            PlcParameter thickness = plcAgreement.getPlcParameter("thickness");//厚
            PlcParameter side1 = plcAgreement.getPlcParameter("side1");//下边
            PlcParameter side2 = plcAgreement.getPlcParameter("side2");//右边
            PlcParameter side3 = plcAgreement.getPlcParameter("side3");//上边
            PlcParameter side4 = plcAgreement.getPlcParameter("side4");//左边
            PlcParameter R_angle1_1 = plcAgreement.getPlcParameter("R_angle1_1");//R角1-1
            PlcParameter R_angle1_2 = plcAgreement.getPlcParameter("R_angle1_2");//R角1-2
            PlcParameter R_angle2_1 = plcAgreement.getPlcParameter("R_angle2_1");//R角2-1
            PlcParameter R_angle2_2 = plcAgreement.getPlcParameter("R_angle2_2");//R角2-2
            PlcParameter R_angle3_1 = plcAgreement.getPlcParameter("R_angle3_1");//R角3-1
            PlcParameter R_angle3_2 = plcAgreement.getPlcParameter("R_angle3_2");//R角3-2
            PlcParameter R_angle4_1 = plcAgreement.getPlcParameter("R_angle4_1");//R角4-1
            PlcParameter R_angle4_2 = plcAgreement.getPlcParameter("R_angle4_2");//R角4-2

            PlcParameter plcReport = plcAgreement.getPlcParameter("plcReport");//汇报字
            PlcParameter plcReportID = plcAgreement.getPlcParameter("plcReportID");//汇报ID
            PlcParameter mesConfirm = plcAgreement.getPlcParameter("mesConfirm");//确认字
            PlcParameter mesConfirmID = plcAgreement.getPlcParameter("mesConfirmID");//确认ID
            PlcParameter machineStatusWord = plcAgreement.getPlcParameter("machineStatusWord");
            if (machine.getIsLog() > 0) {
                modbusTcp1.consoleLogInfo(plcAgreement);
            }

            if (0 == plcRequest.getValueInt() && 1 == mesSend.getValueInt()) {
                log.info("1.发送字置零");
                //发送字置0
                String send = HexUtil.intTo2ByteHex(0);
                modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesSend.getAddressStart() / 2));
                log.info("发送字 清空成功；内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesSend.getAddressStart()));
                modbusTcp1.close();
                return;
            }
            if (0 == plcReport.getValueInt() && 0 != mesConfirm.getValueInt()) {
                log.info("2.确认字置零");
                //发送字置0
                String send = HexUtil.intTo2ByteHex(0);
                modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                log.info("任务完成 清空成功；内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                modbusTcp1.close();
                return;
            }
            if (1 == plcReport.getValueInt() && 0 == mesConfirm.getValueInt()) {
                int finishCount = taskingService.finishMachineTask(machine);
                log.info("3、任务完成");
                if (finishCount > 0) {//有任务
                    String send = HexUtil.intTo2ByteHex(1);
                    modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                    log.info("任务完成 成功 内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                    modbusTcp1.close();
                    return;
                }
                String send = HexUtil.intTo2ByteHex(1);
                modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                log.info("任务完成 异常成功 内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                modbusTcp1.close();
                return;
            }
            if (4 == plcReport.getValueInt() && 0 == mesConfirm.getValueInt()) {
                int finishCount = taskingService.glassDownLineOne(machine);
                if (finishCount > 0) {//有任务
                    log.info("4、人工拿走");
                    String send = HexUtil.intTo2ByteHex(4);
                    modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                    log.info("人工拿走发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                    modbusTcp1.close();
                    return;
                }
                String send = HexUtil.intTo2ByteHex(4);
                modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                log.info("人工拿走异常 发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                modbusTcp1.close();
                return;
            }
            if (2 == plcReport.getValueInt() && 0 == mesConfirm.getValueInt()) {
                int finishCount = taskingService.loseMachineTask(machine);
                if (finishCount > 0) {//有任务
                    log.info("2、重发");
                    String send = HexUtil.intTo2ByteHex(2);
                    modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                    log.info("重发发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                    modbusTcp1.close();
                    return;
                } else {
                    log.info("2、异常重发");
                    String send = HexUtil.intTo2ByteHex(2);
                    modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                    log.info("异常重发发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                    modbusTcp1.close();
                    return;
                }
            }

            if (3 == plcReport.getValueInt() && 0 == mesConfirm.getValueInt()) {
                int finishCount = taskingService.finishMachineTask(machine);
                if (finishCount > 0) {//有任务
                    log.info("3、设备上人工点破损");
                    String send = HexUtil.intTo2ByteHex(3);
                    modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                    log.info("人工点破损发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                    modbusTcp1.close();
                    return;
                } else {
                    //是否自动清除破损
                    log.info("3、无效破损 （没有找到此ID的玻璃）");
                    String send = HexUtil.intTo2ByteHex(3);
                    modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart() / 2));
                    log.info("发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesConfirm.getAddressStart()));
                    modbusTcp1.close();
                    //modbusTcp1.close();
                    return;
                }
            }
            List<Tasking> taskingCount = taskingService.findMachineWorkStateTask(machine, "正在工作");
            if ((1 == plcRequest.getValueInt() && 0 == mesSend.getValueInt())
                    && "开工".equals(machine.getState())
                    && taskingCount.size() < machine.getMaxTaskCount()) {
                Tasking tasking = taskingService.startMachineTask(machine);
                if (tasking != null) {
                    log.info("4、发送任务  任务数据：{}, 设备状态:{}, ", machine, tasking);
                    String send =
                            HexUtil.intTo2ByteHex(1) +
                                    HexUtil.intTo2ByteHex(tasking.getTaskSequence().intValue())+
                                    HexUtil.intTo2ByteHex(tasking.getJPZX()) +
                                    HexUtil.intTo2ByteHex(tasking.getThickness().intValue()) +
                                    HexUtil.intTo2ByteHex(tasking.getWidth().intValue()) +   // side1 下边 = 宽度
                                    HexUtil.intTo2ByteHex(tasking.getLength().intValue()) +  // side2 右边 = 长度
                                    HexUtil.intTo2ByteHex(tasking.getWidth().intValue()) +   // side3 上边 = 宽度
                                    HexUtil.intTo2ByteHex(tasking.getLength().intValue()) +  // side4 左边 = 长度
                                    HexUtil.intTo2ByteHex((int) ((tasking.getR_1_1() != null ? tasking.getR_1_1() : 0.0) * 10))  +
                                    HexUtil.intTo2ByteHex((int) ((tasking.getR_1_2() != null ? tasking.getR_1_2() : 0.0) * 10))  +
                                    HexUtil.intTo2ByteHex((int) ((tasking.getR_2_1() != null ? tasking.getR_2_1() : 0.0) * 10))  +
                                    HexUtil.intTo2ByteHex((int) ((tasking.getR_2_2() != null ? tasking.getR_2_2() : 0.0) * 10))  +
                                    HexUtil.intTo2ByteHex((int) ((tasking.getR_3_1() != null ? tasking.getR_3_1() : 0.0) * 10))  +
                                    HexUtil.intTo2ByteHex((int) ((tasking.getR_3_2() != null ? tasking.getR_3_2() : 0.0) * 10))  +
                                    HexUtil.intTo2ByteHex((int) ((tasking.getR_4_1() != null ? tasking.getR_4_1() : 0.0) * 10))  +
                                    HexUtil.intTo2ByteHex((int) ((tasking.getR_4_2() != null ? tasking.getR_4_2() : 0.0) * 10))  ;
                    modbusTcp1.writeString(send, HexUtil.intTo2ByteHex(mesSend.getAddressStart() / 2));
                    log.info("发送任务发送报文内容：{},发送起始地址:{}", send, HexUtil.intTo2ByteHex(mesSend.getAddressStart()));
                    modbusTcp1.close();
                    SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                    String sendRecord = df.format(new Date()) + "  " +
                            tasking.getGlassId() + "-" +
                            tasking.getLength() + "-" +
                            tasking.getWidth() + "-" +
                            tasking.getThickness() + "-" +
                            tasking.getR_1_1() + "-" +
                            tasking.getR_1_2() + "-" +
                            tasking.getR_2_1() + "-" +
                            tasking.getR_2_2() + "-" +
                            tasking.getR_3_1() + "-" +
                            tasking.getR_3_2() + "-" +
                            tasking.getR_4_1() + "-" +
                            tasking.getR_4_2() + "-" +
                            tasking.getJPZX();
                    if (sendRecords.size() > 7) {
                        sendRecords.remove(0);
                    }
                    Map sendContentMap = new HashMap();
                    sendContentMap.put("sendContent", sendRecord);
                    sendRecords.add(sendContentMap);
                    return;
                }
            }
            //}

        } catch (Exception e) {
            log.info("交互逻辑错误");
        }

        modbusTcp1.close();
        //log.info("无可执行的条件");
    }


    @Override
    public void run() {
        while (this != null) {
            try {
                Thread.sleep(1000);
                plcStart();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}