OP440/src/com/mes/ygsl/YgslClientHandler.java

package com.mes.ygsl;

import com.mes.ui.DataUtil;
import com.mes.ui.MesClient;
import com.mes.util.JdbcUtils;
import io.netty.buffer.ByteBuf;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.awt.*;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.Date;

public class YgslClientHandler extends ChannelInboundHandlerAdapter {
    public static final Logger log =  LoggerFactory.getLogger(MesClient.class);

    private final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    public static byte[] responseByte;

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        System.out.println("mes connecting：" + sdf.format(new Date()));
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        Channel channel = ctx.channel();
        System.err.println("close ygsl tcp, ip：" + channel.remoteAddress());
        // 关闭通道
        channel.close();

        //初始化TCP连接
        MesClient.ygslClient = null;
        //TCP连接状态
        MesClient.ygsl_tcp_connect_flag = false;
        //设置TCP请求状态
        MesClient.ygsl_connect_request_flag = true;
    }

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        try {
//            System.out.println("msg1111111:"+msg);
            if (msg instanceof ByteBuf) {
                ByteBuf buf = (ByteBuf) msg;
                // 你的处理逻辑
                String content = buf.toString(StandardCharsets.UTF_8);

//                System.out.println("oldmsg:"+content);
                if (content.contains("02310061")){
                    // 找到关键字的位置
                    int index = content.indexOf("02310061");
                    // 截取从关键字开始到末尾的内容
                    content = content.substring(index);
                }
//
//                System.out.println("msg:" + content);
//                System.out.println("msg-size:" + content.length());

                String mid = YgslParam.getMid(content);
//                System.out.println("MID:" + mid);
                switch (mid) {
                    case "0002":
                        YgslUtil.lastTighteningResultSubscribe(MesClient.ygslClient);
//                        YgslUtil.pSet(MesClient.ygslClient);
                        break;
                    case "0011":
                        YgslUtil.selectSet(MesClient.ygslClient);
                        break;
                    case "0031":
                        YgslUtil.selectJob(MesClient.ygslClient);
//                        YgslUtil.restartJob(MesClient.ygslClient);
                        break;
                    case "0004": // 错误信息
//                        System.out.println("MID:" + YgslParam.getReplyMid(content) + ";ErrorCode:" + YgslParam.getErrCode(content));
                        break;
                    case "0005": // 命令被接受
//                        System.out.println("命令被接受:" + YgslParam.getReplyMid(content));
                        break;
                    case "0061": // 拧紧数据

                        if (MesClient.work_status == 1) {
                            String tighteningStatus = YgslParam.getTighteningStatus(content);
                            String torqueStatus = YgslParam.getTorqueStatus(content);
                            String angleStatus = YgslParam.getAngleStatus(content);
                            String torqueMin = YgslParam.getTorqueMinLimit(content);
                            String torqueMax = YgslParam.getTorqueMaxLimit(content);
                            String torqueFinal = YgslParam.getTorqueFinalTarget(content);
                            String torque = YgslParam.getTorque(content);
                            String angleMin = YgslParam.getAngleMin(content);
                            String angleMax = YgslParam.getAngleMax(content);
                            String angleFinal = YgslParam.getFinalAngleTarget(content);
                            String angle = YgslParam.getAngle(content);
                            String jobID = YgslParam.getJobID(content);
                            String tighteningID = YgslParam.getTighteningID(content);
                            if (!tighteningID.isEmpty() && !MesClient.atids.contains(tighteningID)) {
                                MesClient.atids.add(tighteningID);

                                String sn = MesClient.product_sn.getText().trim();
                                //检查数据是否已存在
                                Boolean checkRet = JdbcUtils.checkTighteningById(tighteningID, jobID,sn);

//                                if (!checkRet) {
                                if (true) {

//                                    if(tighteningStatus.equals("0")){ // NG
//                                        if(torqueStatus.equals("1")){
//                                            MesClient.torque.setForeground(Color.BLACK);
//                                        }else{
//                                            MesClient.torque.setForeground(Color.RED);
//                                        }
//                                        if(angleStatus.equals("1")){
//                                            MesClient.torque.setForeground(Color.BLACK);
//                                        }else{
//                                            MesClient.torque.setForeground(Color.RED);
//                                        }
//                                    }else{
//                                        MesClient.torque.setForeground(Color.BLACK);
//                                        if(tighteningStatus.equals("1")){
//                                            MesClient.cur++;
//                                        }
//
//                                    }

//                                    String serialNumber =  String.valueOf(MesClient.cur);
//                                    if(!tighteningStatus.equals("1")){
//                                        serialNumber =  String.valueOf(MesClient.cur + 1);
//                                    }
                                    MesClient.torsionalValue.setText(torque+"N.m");
                                    MesClient.torsionalMaxValue.setText(torqueMin+"-"+torqueMax+"N.m");
                                    //扭力值在范围内数量+1
                                    if( MesClient.cur<MesClient.max&&Double.parseDouble(torque) >= Double.parseDouble(torqueMin) && Double.parseDouble(torque) <= Double.parseDouble(torqueMax)){
                                        MesClient.cur++;
                                        MesClient.torsionalValue.setForeground(Color.BLACK);
//                                        MesClient.monitoring_text.setText(MesClient.max + "/" + MesClient.cur);
                                        MesClient.monitoring_text.setText(MesClient.cur + "/" + MesClient.max);

                                        JdbcUtils.insertProdData(MesClient.mes_gw,MesClient.mes_line_sn,MesClient.product_sn.getText(),torque,"OK",MesClient.user_menu.getText(),tighteningID,jobID);

//                                        if (MesClient.cur==32){
//                                            MesClient.torsionalMaxValue.setText("6.5-7.5N.m");
//                                        }
                                        //只记录合格数据
//                                        JdbcUtils.insertTighteningData(
//                                                MesClient.mes_gw, MesClient.mes_line_sn, MesClient.product_sn.getText()
//                                                , torqueStatus, torqueMin, torqueMax, torqueFinal, torque,
//                                                tighteningID, jobID,String.valueOf(MesClient.cur),
//                                                MesClient.user_menu.getText()
//                                        );
                                    }else{
                                        MesClient.torsionalValue.setForeground(Color.RED);
                                    }


                                    //达到次数才能点击下一件
                                    if (MesClient.cur == MesClient.max){
//                                        MesClient.finish_ok_bt.setEnabled(true);
                                        if(MesClient.fininsh_flag){
                                            MesClient.setMenuStatus("结果已提交!",-1);
                                            return;
                                        }

                                        if(MesClient.connect_request_flag){
                                            MesClient.setMenuStatus("设备未连接Mes服务器!",-1);
                                            return;
                                        }
                                        if(MesClient.product_sn.getText().isEmpty()){
                                            MesClient.setMenuStatus("未扫工件码!",-1);
                                            return;
                                        }

//                                        if(MesClient.work_status == 1 && MesClient.check_quality_result){
//
//                                            String sn1 = MesClient.getBarcode(MesClient.product_sn.getText());
//                                            MesClient.getUser();
//
//                                            String qret = "OK";
//                                            if (MesClient.cur !=MesClient. max) {
//                                                qret = "NG";
//                                            }
//                                            Boolean result = DataUtil.sendQuality(sn1,qret,MesClient.user20);
//                                            if(result) {
//                                                MesClient.resetScanA();
//                                                MesClient.setMenuStatus("结果提交成功，请扫下一件", 0);
//                                                MesClient.scan_type = 1;
////                        MesClient.scanBarcode();
//                                            } else {
//                                                MesClient.setMenuStatus("结果提交失败，请重试",-1);
//                                            }
//                                        }



                                        // 扭力到数后不自动提交；由操作员点击“下一件”提交结果
                                        MesClient.finish_ok_bt.setEnabled(true);
                                        MesClient.setMenuStatus("扭力到数，请点“下一件”提交", 0);
                                        MesClient.result_text.setText("合格");
                                    }


//                                    if (MesClient.cur >= MesClient.max) {
//                                        YgslUtil.disableTool(MesClient.ygslClient);
//                                    }




                                }
                            }


                            YgslUtil.lastTighteningResultDataAcknowledge(MesClient.ygslClient);

//                            if(MesClient.ygslNum == 1){
//                                if(MesClient.cura >= MesClient.maxa){ // 提交质量
//                                    MesClient.finish_ok_bt.setEnabled(true);
//                                    MesClient.finish_ng_bt.setEnabled(true);
//                                    if(MesClient.work_status == 1 && MesClient.check_quality_result){
//
//                                        String sn = MesClient.product_sn.getText();
//                                        MesClient.getUser();
//
//                                        String qret = "OK";
//                                        Boolean sendret = DataUtil.sendQuality(MesClient.nettyClient,sn,qret,MesClient.user20);
//                                        if(!sendret){
//                                            MesClient.setMenuStatus("结果上传MES失败，请重试",-1);
//                                        }
//                                    }
//                                }
//                            }else{
//                                if(MesClient.cura >= MesClient.maxa && MesClient.curb >= MesClient.maxb){ // 提交质量
//                                    MesClient.finish_ok_bt.setEnabled(true);
//                                    MesClient.finish_ng_bt.setEnabled(true);
//                                    if(MesClient.work_status == 1 && MesClient.check_quality_result){
//                                        String sn = MesClient.product_sn.getText();
//                                        MesClient.getUser();
//
//                                        String qret = "OK";
//                                        Boolean sendret = DataUtil.sendQuality(MesClient.nettyClient,sn,qret,MesClient.user20);
//                                        if(!sendret){
//                                            MesClient.setMenuStatus("结果上传MES失败，请重试",-1);
//                                        }
//                                    }
//                                }
//                            }
                        } else {
                            YgslUtil.lastTighteningResultDataAcknowledge(MesClient.ygslClient);
                        }

                        break;
                    default:
                        break;
                }

            } else {

            }
//            System.out.println("msg:"+msg);
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        System.out.println("mes exceptionCaught：" + sdf.format(new Date()));
        ctx.close();

        MesClient.ygslClient = null;
        MesClient.initYgslTcpConnection();
    }

    // 16字符串转Ascii
    private String hexStringToAscii(String hexString) {
        StringBuilder sbuilder = new StringBuilder();
        for (int i = 0; i < hexString.length(); i += 2) {
            String hexByte = hexString.substring(i, i + 2);
            int byteValue = Integer.parseInt(hexByte, 16);
            char c = (char) byteValue;
            sbuilder.append(c);
        }
        return sbuilder.toString();
    }
}