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

package com.mes.ygsl;

import com.mes.netty.MesMsgUtils;
import com.mes.netty.ProtocolParam;
import com.mes.ui.DataUtil;
import com.mes.ui.MesClient;
import com.mes.ui.MesRevice;
import com.mes.util.JdbcUtils;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufUtil;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

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

public class YgslClientHandler extends ChannelInboundHandlerAdapter {

    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;
        MesClient.initYgslTcpConnection();
    }

    @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("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": // 拧紧数据
//                        System.out.println("YgslA:");
//                        System.out.println("getTorqueControllerName:"+YgslParam.getTorqueControllerName(content));
//                        System.out.println("getTighteningStatus:"+YgslParam.getTighteningStatus(content));
//                        System.out.println("getTorqueStatus:"+YgslParam.getTorqueStatus(content));
//                        System.out.println("getAngleStatus:"+YgslParam.getAngleStatus(content));
//                        System.out.println("getTighteningID:"+YgslParam.getTighteningID(content));
//                        System.out.println("getJobID:"+YgslParam.getJobID(content));
//                        System.out.println("getTorqueMinLimit:"+YgslParam.getTorqueMinLimit(content));
//                        System.out.println("getTorqueMaxLimit:"+YgslParam.getTorqueMaxLimit(content));
//                        System.out.println("getTorqueFinalTarget:"+YgslParam.getTorqueFinalTarget(content));
//                        System.out.println("getTorque:"+YgslParam.getTorque(content));
//                        System.out.println("getAngleMin:"+YgslParam.getAngleMin(content));
//                        System.out.println("getAngleMax:"+YgslParam.getAngleMax(content));
//                        System.out.println("getFinalAngleTarget:"+YgslParam.getFinalAngleTarget(content));
//                        System.out.println("getAngle:"+YgslParam.getAngle(content));
//                        System.out.println("getTimeStamp:"+YgslParam.getTimeStamp(content));
//                        System.out.println("getBatchStatus:"+YgslParam.getBatchStatus(content));
//                        System.out.println("getBatchSize:"+YgslParam.getBatchSize(content));
//                        System.out.println("getBatchCounter:"+YgslParam.getBatchCounter(content));

                        if(MesClient.work_status == 1){
//                        if(MesClient.work_status == 1&&MesClient.lm_result){
                            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);
//                                if(Float.valueOf(torque) > Float.valueOf(torqueMin) && Float.valueOf(torque) < Float.valueOf(torqueMax)){
//                                    torqueStatus = "1";
//                                }else if(Float.valueOf(torque) <= Float.valueOf(torqueMin)){
//                                    torqueStatus = "0";
//                                }else{
//                                    torqueStatus = "2";
//                                }
//                                if(Float.valueOf(angle) > Float.valueOf(angleMin) && Float.valueOf(angle) < Float.valueOf(angleMax)){
//                                    angleStatus = "1";
//                                }else if(Float.valueOf(angle) <= Float.valueOf(angleMin)){
//                                    angleStatus = "0";
//                                }else{
//                                    angleStatus = "2";
//                                }
//
//                                if(angleStatus.equals("1") && torqueStatus.equals("1")){
//                                    tighteningStatus = "1";
//                                }else{
//                                    tighteningStatus = "0";
//                                }

                                String pos = "A";

                                Boolean checkRet = JdbcUtils.checkTighteningById(tighteningID,pos,jobID,MesClient.product_sn.getText());
                                if(!checkRet){

                                    if(tighteningStatus.equals("0")){    // NG
                                        if(torqueStatus.equals("1")){
                                            MesClient.torque1.setForeground(Color.BLACK);
                                        }else{
                                            MesClient.torque1.setForeground(Color.RED);
                                        }
                                        if(angleStatus.equals("1")){
                                            MesClient.angle1.setForeground(Color.BLACK);
                                        }else{
                                            MesClient.angle1.setForeground(Color.RED);
                                        }
                                    }else{
                                        MesClient.torque1.setForeground(Color.BLACK);
                                        MesClient.angle1.setForeground(Color.BLACK);
                                        if(pos.equals("A") && tighteningStatus.equals("1")){
                                            MesClient.ygsl_cura++;
                                        }
                                        if(pos.equals("B") && tighteningStatus.equals("1")){
                                            MesClient.ygsl_curb++;
                                        }
                                    }

                                    String serialNumber =  String.valueOf(MesClient.ygsl_cura);
                                    if(!tighteningStatus.equals("1")){
                                        serialNumber =  String.valueOf(MesClient.ygsl_cura + 1);
                                    }

                                    MesClient.torque1.setText(torque);
                                    MesClient.angle1.setText(angle);

                                    if(MesClient.ygsl_cura >= MesClient.ygsl_maxa){
                                        YgslUtil.disableTool(MesClient.ygslClient);
                                    }

//                                    MesClient.schedulea.setText(MesClient.ygsl_cura+"/"+MesClient.ygsl_maxa);

                                    MesClient.param3.setText(String.valueOf(MesClient.ygsl_maxa));
//                                    MesClient.param3.setText(String.valueOf(MesClient.ygsl_cura));
                                    MesClient.param4.setText(String.valueOf(MesClient.ygsl_cura));

                                    JdbcUtils.insertTighteningData(
                                            MesClient.mes_gw,MesClient.mes_line_sn,MesClient.product_sn.getText(),
                                            tighteningStatus,torqueStatus,angleStatus,torqueMin,torqueMax,torqueFinal,torque,
                                            angleMin,angleMax,angleFinal,angle,tighteningID,jobID,serialNumber,
                                            pos,MesClient.user_menu.getText()
                                    );
                                }
                            }



                            YgslUtil.lastTighteningResultDataAcknowledge(MesClient.ygslClient);

                            if(MesClient.ygslNum == 1){
                                if(MesClient.ygsl_cura >= MesClient.ygsl_maxa && MesClient.lm_result){ // 提交质量
                                    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(sn,qret,MesClient.user20);
                                        if(!sendret){
                                            MesClient.setMenuStatus("结果上传MES失败，请重试",-1);
                                        }
                                    }
                                }
                            }else{
                                if(MesClient.ygsl_cura >= MesClient.ygsl_maxa && MesClient.ygsl_curb >= MesClient.ygsl_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(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();
    }
}