OP080-el/src/com/mes/ui/ModbusUtil.java

package com.mes.ui;

import com.github.xingshuangs.iot.protocol.modbus.service.ModbusTcp;
import com.mes.util.JdbcUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.nio.charset.Charset;

public class ModbusUtil {
    public static final Logger log =  LoggerFactory.getLogger(ModbusUtil.class);
    public static void getDataA(ModbusTcp plc){
        try {
            // 检查PLC连接是否已初始化
            if (plc == null) {
                log.warn("PLC A 还未连接，跳过数据读取");
                return;
            }

            Short cur = plc.readInt16(66);//已打数量

            if(MesClient.aMax <= 0){
                MesClient.aMax = plc.readInt32(4534); // 任务数量/预设数量
                MesClient.param1.setText(String.valueOf(MesClient.aMax));
                log.info("从PLC读取预设数量：" + MesClient.aMax);
            }

            if(MesClient.sortA < cur){
                MesClient.sortA = cur;
                MesClient.aFinish = plc.readInt16(68);//合格数量
                String fout = plc.readInt32(386)+"";
                String sout = (float)plc.readInt32(376)/1000+"";

                String fmin = plc.readInt32(4116)/10+"";
                String smin = (float)plc.readInt32(4126)/1000+"";  // 修正：4126是S-min

                String fmax = plc.readInt32(4114)/10+"";
                String smax = (float)plc.readInt32(4124)/1000+"";  // 修正：4124是S-max

                MesClient.param2.setText(cur+"");
                log.info("A工位数量更新 - 当前数量：" + cur + ", 预设数量：" + MesClient.aMax);
                if(!MesClient.product_sn.getText().isEmpty()){
                    String qty = String.valueOf(plc.readInt16(4));
                    if ("3".equals(qty)){
                        qty = "1";
                    }else {
                        qty = "0";
                    }
                    JdbcUtils.insertProdData(MesClient.mes_gw, MesClient.mes_line_sn, MesClient.product_sn.getText(),"A",fout,sout,fmin,smin,fmax,smax,qty,cur+"", MesClient.user_menu.getText());
                }

                //预设数量等于已打数量,就关机
                if (MesClient.sortA >= MesClient.aMax && MesClient.aMax > 0){
                    setPowerOff(MesClient.plcA);
                }
            }
        } catch (Exception e){
            log.error("PLC A读取失败：" + e.getMessage());
            // 使用触发按钮设置的参数值继续执行
            upResult();
        }
        upResult();
    }

    public static void getDataB(ModbusTcp plc){

        // 41065=F-out  41066=S-out
        // 41069=F-min  41071=S-min 41070=F-max  41072=S-max
        // 预设数量=41129  完成数=41137

        Short cur = plc.readInt16(1136);
//        System.out.println("F-out:"+plc.readInt16(1064));
//        System.out.println("S-out:"+plc.readInt16(1065));
//        System.out.println("F-min:"+plc.readInt16(1068));
//        System.out.println("S-min:"+plc.readInt16(1070));
//        System.out.println("F-max:"+plc.readInt16(1069));
//        System.out.println("S-max:"+plc.readInt16(1071));
//        System.out.println("set:"+plc.readInt16(1128));
//        System.out.println("cur:"+cur);
//        System.out.println("cur2:"+MesClient.sortB);

        if(MesClient.bMax <= 0){
            MesClient.bMax = plc.readInt16(1128);
            MesClient.param3.setText(String.valueOf(MesClient.bMax));
        }

        if(MesClient.sortB == cur - 1){
            MesClient.sortB = cur;
            String fout = plc.readInt16(1064)+"";
            String sout = (float)plc.readInt16(1065)/1000+"";

            String fmin = plc.readInt16(1068)+"";
            String smin = (float)plc.readInt16(1070)/1000+"";

            String fmax = plc.readInt16(1069)+"";
            String smax = (float)plc.readInt16(1071)/1000+"";

            if(MesClient.sortB == 32){
                setTask2S(plc);
            }

            MesClient.param4.setText(cur+"");

            System.out.println("cur:"+cur);
            if(!MesClient.product_sn.getText().isEmpty()){
                JdbcUtils.insertProdData(MesClient.mes_gw, MesClient.mes_line_sn, MesClient.product_sn.getText(),"B",fout,sout,fmin,smin,fmax,smax,"1",cur+"", MesClient.user_menu.getText());
            }
        }

        upResult();

    }

    // 上传总结果
    public static void upResult(){
        if(!MesClient.curSn.isEmpty() && MesClient.aMax > 0 && MesClient.aMax == MesClient.sortA){
            MesClient.finish_ok_bt.setEnabled(true);
            MesClient.finish_ng_bt.setEnabled(true);

            if(MesClient.tjStatus == 0 && MesClient.check_quality_result){
                MesClient.tjStatus = 1;
                MesClient.getUser();
                String retf = "OK";
                if(MesClient.aFinish != MesClient.aMax){
                    retf = "NG";
                }
                Boolean ret = DataUtil.sendQuality(MesClient.nettyClient, MesClient.product_sn.getText(),retf, MesClient.user20);
                if(!ret){
                    MesClient.setMenuStatus(MesClient.tjFlagTextErr,-1);
                }
            }

        }
    }

    // 获取控制模式
    public static short getControlModel(ModbusTcp plc){
        short control = 0;
        try{
            control = plc.readInt16(1090);
        }catch (Exception e){
            e.printStackTrace();
        }

        return control;
    }

    // 获取二维码
    public static String getSn(ModbusTcp plc){
        String sn = "";
        try{
            sn = plc.readString(1216,40, Charset.forName("UTF8"));
        }catch (Exception e){
            e.printStackTrace();
        }

        return splitIntoChunks(sn,2);
    }

    // 每两个字符分割，并反转
    private static String splitIntoChunks(String str, int chunkSize) {
        if (str == null || str.isEmpty() || chunkSize <= 0) {
            return "";
        }

        int length = str.length();
        int arraySize = (length + chunkSize - 1) / chunkSize;
        String[] result = new String[arraySize];

        for (int i = 0, j = 0; i < length; i += chunkSize, j++) {
            int endIndex = Math.min(i + chunkSize, length);
            String sttr = str.substring(i, endIndex);
            StringBuilder sb = new StringBuilder(sttr);
            String reversedStr = sb.reverse().toString(); // 字符串反转
            result[j] = reversedStr;
        }

        return String.join("",result);
    }

    // 远程开机
    public static Boolean setPowerOn(ModbusTcp plc){
        Boolean ret = false;
        try{
            plc.writeCoil(3128,true);
//            plc.writeCoil(3079,false);
//            plc.writeCoil(3328,true); // 必须选关掉关机，开机才起左右
            ret = true;
        }catch (Exception e){
            e.printStackTrace();
            ret = false;
        }

        return ret;
    }

    // 远程关机
    public static Boolean setPowerOff(ModbusTcp plc){
        Boolean ret = false;
        try{
            MesClient.heartBeatFlag = false;
//            plc.writeCoil(3128,false);
//            plc.writeCoil(3328,false);
//            plc.writeCoil(3079,true); // 关机
            // 必须选关掉关机，开机才起左右
            ret = true;
        }catch (Exception e){
            e.printStackTrace();
            ret = false;
        }

        return ret;
    }

    // 重置任务
    public static void setTask(ModbusTcp plc,Short setNum){
        try{
//            // 设置模式 1=标记铆接模式
//            plc.writeInt16(1092,(short) 1);
//            // 设置任务
//            plc.writeInt16(1128,setNum);
//            plc.writeInt16(1136,(short) 0);
//            plc.writeInt16(1138,(short) 0);

            // 设置模式 1=标记铆接模式
            MesClient.plcA.writeInt16(8, (short) 1);
            // 设置任务
            plc.writeInt16(4534,setNum);
            plc.writeInt16(66,(short) 0);
            plc.writeInt16(68,(short) 0);
            plc.writeInt16(70,(short) 0);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    public static void setTask2S(ModbusTcp plc){
        try{
            plc.writeInt16(1070,(short) 3600);
            plc.writeInt16(1071,(short) 4600);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    // 获取在线离线
    public static boolean getOnOff(ModbusTcp plc){
        try{
            plc.readInt16(1090);
            return true;
        }catch (Exception e){
            e.printStackTrace();
            return false;
        }
    }


//        A枪说明 192.168.1.7
//        plc.writeCoil(3079,false);
//        plc.writeCoil(3328,true); // 必须选关掉关机，开机才起左右
////        plc.writeCoil(3128,false);
//        System.out.println("控制模式:"+plc.readInt16(1090)); // 1091 控制模式
//        System.out.println("系统运行中:"+plc.readCoil(3128,1)); // 3129 系统运行中
//        System.out.println("结束暂停:"+plc.readCoil(3132,1)); // 3133 系统运行中
//        System.out.println("远程开机:"+plc.readCoil(3328,1)); // 3329 远程开机
//        System.out.println("远程关机:"+plc.readCoil(3079,1)); // 3080 远程关机
//        System.out.println("作业模式:"+plc.readInt16(1092)); // 1093 作业模式
//        System.out.println("最大拉力:"+plc.readInt16(1064)); // 1065 最大拉力
//        System.out.println("对应位移:"+plc.readInt16(1065)); // 1066 对应位移
//        System.out.println("任务数量:"+plc.readInt16(1128)); // 1129 任务数量
//        System.out.println("合格数量:"+plc.readInt16(1138)); // 1139 合格数量
//        System.out.println("质量状态:"+plc.readInt16(1072)); // 1073 质量状态
//        System.out.println("F-out:"+plc.readInt16(1064));
//        System.out.println("S-out:"+plc.readInt16(1065));
//        System.out.println("F-min:"+plc.readInt16(1068));
//        System.out.println("S-min:"+plc.readInt16(1070));
//        System.out.println("F-max:"+plc.readInt16(1069));
//        System.out.println("S-max:"+plc.readInt16(1071));
}