OP030/src/com/mes/ui/MesClient.java

package com.mes.ui;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.github.s7connector.impl.utils.S7Utils;
import com.github.xingshuangs.iot.protocol.modbus.service.ModbusTcp;
import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
import com.github.xingshuangs.iot.protocol.s7.service.S7PLC;
import com.mes.component.MesRadio;
import com.mes.component.ProductTypePanel;
import com.mes.component.MesWebView;
import com.mes.component.MyDialog;
import com.mes.netty.NettyClient;
import com.mes.util.ClientVersionUtils;
import com.mes.util.ClientUpgrade;
import com.mes.util.ConfigUtil;
import com.mes.util.DateLocalUtils;
import com.mes.util.HttpUtils;
import com.mes.util.IweldCloudUtil;
import com.mes.util.JdbcUtils;
import javafx.embed.swing.JFXPanel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.swing.*;
import javax.swing.border.EmptyBorder;
import javax.swing.event.ChangeEvent;
import javax.swing.event.ChangeListener;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.Timer;
import java.util.TimerTask;

public class MesClient extends JFrame {
    public static final Logger log = LoggerFactory.getLogger(MesClient.class);
    private static String Drivde = "org.sqlite.JDBC";

    public static int mes_auth = 0;
    public static String mes_gw = "";
    public static String mes_gw_des = "";
    public static String mes_server_ip = "";
    public static int mes_tcp_port = 3000;
    public static int mes_heart_beat_cycle = 10;
    public static int mes_heart_icon_cycle = 1;
    public static String mes_line_sn = "";
    public static String client_version = "0.0.0"; // 打包发布版本，需和后台 JAR 管理版本号对齐
    public static String mes_gwflag = ""; // 工位标识

    public static NettyClient nettyClient;
    public static boolean tcp_connect_flag = false;
    public static boolean connect_request_flag = false;
    private static volatile long lastTcpReconnectMs = 0;
    private static final Object tcpReconnectLock = new Object();

    /** 断线后延迟重连，避免报文尚未回包就被 SYNR 新连接打断 */
    public static void scheduleTcpReconnect(){
        synchronized (tcpReconnectLock){
            long now = System.currentTimeMillis();
            if(now - lastTcpReconnectMs < 3000){
                return;
            }
            if(connect_request_flag || nettyClient == null){
                return;
            }
            connect_request_flag = true;
            lastTcpReconnectMs = now;
        }
        new Timer(true).schedule(new TimerTask() {
            @Override
            public void run() {
                try{
                    if(nettyClient != null && !tcp_connect_flag){
                        System.out.println("TCP断线，延迟重连...");
                        DataUtil.synrTcp(nettyClient, mes_gw);
                    }
                }finally {
                    connect_request_flag = false;
                }
            }
        }, 2000);
    }

    //session
    public static String sessionid = "";

    public static JPanel contentPane;
    public static MesClient mesClientFrame;
    public static JTabbedPane tabbedPane;
    public static JScrollPane indexScrollPaneA;
    public static JScrollPane indexScrollPaneB;
    public static JScrollPane searchScrollPane;
    public static JScrollPane searchScrollPaneDj;
    public static JScrollPane searchScrollPaneDjB;
    public static JScrollPane searchScrollPaneGz;

    public static Boolean check_quality_result = false;
    public static Integer work_status = 0;
    public static Integer work_status2 = 0;
    public static Boolean check_quality_result2 = false;

    public static Integer batch_status = 0; //A面 1=已绑定  0=未绑定
    public static Integer batch_status2 = 0; //B面 1=已绑定  0=未绑定

    public static JButton heart_beat_menu;
    public static JButton status_menu;
    public static JButton user_menu;

    public static int scan_type = 0;
    public static JButton batch_scan_1;
    public static JButton batch_scan_2;
    public static JTextField product_sn;
    public static JLabel pxstatus1;
    public static JLabel pxstatus2;

    public static Integer tjFlag = 0; // 0=未开始 1=已扫码，设备未启动 2=设备运行中 3=设备运行结束

    public static Integer tjFlaga = 0; // 0=未开始 1=已扫码，设备未启动 2=设备运行中 3=设备运行结束
    public static Integer tjFlagb = 0; // 0=未开始 1=已扫码，设备未启动 2=设备运行中 3=设备运行结束

    public static Integer tjStatusa = 0; // 1=提交失败
    public static Integer tjStatusb = 0; // 1=提交失败

    public static String curFlag = ""; // 当前工作的面板

    public static String curSna = "";

    public static String curSnb = "";

    public static String curPage = "";

    public static Integer checkA = 0;

    public static Integer checkB = 0;

    public static Integer lastpage = 0;

    public static Boolean mesQualityFlagA = false; // true=可工作

    public static Boolean mesQualityFlagB = false; // true=可工作

    public static Boolean mesErrorFlagA = false; // true=提交MES失败,手动提交

    public static Boolean mesErrorFlagB = false; // true=提交MES失败，手动提交

    public static String user20 = "";

    public static JFrame welcomeWin;

    public static JPanel indexPanelB;
    public static MesWebView jfxPanel = null;
    public static MesRadio mesRadioHj;
    public static ProductTypePanel productTypePanel;
    public static JLabel productTypeCurrentLabel;

    public static final int PRODUCT_SN_LENGTH = 32;
    public static final String PREFIX_ZJ = "000020021815-01000016";  //智界
    public static final String PREFIX_SJ = "000020022029-01000016";  //尚界
    public static final boolean PRODUCT_TYPE_SWITCH_ENABLED = false;
    public static final String PRODUCT_TYPE_SWITCH_PASSWORD = "503833";
    public static final String PRODUCT_TYPE_ZJ = ProductTypePanel.TYPE_ZJ;
    public static final String PRODUCT_TYPE_SJ = ProductTypePanel.TYPE_SJ;
    public static JPanel indexPanelC;
    public static MesWebView jfxPanel2 = null;
    public static JPanel indexPanelDjB;
    public static MesWebView jfxPanelDjB = null;

    // 开班点检（本地UI，不再加载网页）
    public static JLabel[] dj_a_lamps = new JLabel[6];
    public static JLabel[] dj_b_lamps = new JLabel[6];
    public static JButton dj_start_btn;

    public static S7PLC s7PLC = new S7PLC(EPlcType.S1200, "192.168.0.1"); //100 B工位
//    public static S7PLC s7PLC = new S7PLC(EPlcType.S1200, "192.168.7.2"); //2 A工位

    public static List<String> hjparams = new ArrayList<>();

    public static JTable table;
    public static Object[] columnNames = { "物料名称", "绑定批次", "剩余次数", "操作" };
    public static Object[][] rowData = null;
//    public static Object[][] rowData = {
//    };


    public static void main(String[] args) {
        if (ClientUpgrade.handleInstallArgs(args)) {
            return;
        }
        EventQueue.invokeLater(new Runnable() {
            @Override
            public void run() {
                try{
                    //鐠囩粯鏋冩禒鍫曞帳缂冿拷
                    readProperty();
                    if (ClientUpgrade.recoverIncompleteInstall()) {
                        return;
                    }
                    ClientUpgrade.cleanupInstallLeftovers();
                    ClientUpgrade.checkIfConfigured(null);

                    // 閺勫墽銇氶悾宀勬桨
                    mesClientFrame = new MesClient();
                    mesClientFrame.setVisible(false);

                    JdbcUtils.getConn();

                    welcomeWin = new LoginFarme();
                    welcomeWin.setVisible(true);

                    getMaterailData();

                    //获取当前面
                    textFocus();

                    getPlcParam();
//
                    upParams();
//
                    getPlcParams();

                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        });
    }

    public static Timer cjTimerText;
    public static void textFocus() {
        if(cjTimerText!=null) {
            cjTimerText.cancel();
        }
        cjTimerText = new Timer();
        cjTimerText.schedule(new TimerTask() {
            public void run() {
                txtfa.requestFocusInWindow();

                MesClient.curPage = PlcUtil.getCurAside(s7PLC);
                if(MesClient.curPage .equals("A")){
                    page_text.setText("当前：A面");
                }else{
                    page_text.setText("当前：B面");
                }
            }
        }, 1000,1000);
    }

    public static Timer cjTimer3;
    public static void upParams() {
        if(cjTimer3!=null) {
            cjTimer3.cancel();
        }
        cjTimer3 = new Timer();
        cjTimer3.schedule(new TimerTask() {
            public void run() {
                try{
                    List<CmtReq> prods = JdbcUtils.getCmtParams();
                    System.out.println("prods:"+ JSON.toJSONString(prods));
                    if(prods.size() > 0){
                        // 定时上传参数
                        JSONObject retObj = DataUtil.upParams(JSON.toJSONString(prods));
                        if(retObj.get("result")!=null&&retObj.get("result").toString().equalsIgnoreCase("true")) {
                            // 更新sqlite已同步
                            for(CmtReq prodReq:prods){
                                JdbcUtils.updateProdSync(prodReq.getId(),1);
                            }
                        }
                    }
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        }, 1000,30*1000);
    }

    public static Timer cjTimer;
    public static void getPlcParam() {
        if(cjTimer!=null) {
            cjTimer.cancel();
        }
        cjTimer = new Timer();
        cjTimer.schedule(new TimerTask() {
            public void run() {
                try{
                    if(!MesClient.sessionid.isEmpty()){
                        PlcUtil.getStatusA(s7PLC);
                    }
                }catch (Exception e){
                    e.printStackTrace();
                }

                try{
                    if(!MesClient.sessionid.isEmpty()){
                        PlcUtil.getStatusB(s7PLC);
                    }
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        }, 1000,2000);
    }

    public static Timer cjTimer2;
    public static void getPlcParams() {
        if(cjTimer2!=null) {
            cjTimer2.cancel();
        }
        cjTimer2 = new Timer();
        cjTimer2.schedule(new TimerTask() {
            public void run() {
                try{
                    IweldCloudUtil.collectWeldingParams();
                }catch (Exception e){
                    e.printStackTrace();
                }
            }
        }, 1000, IweldCloudUtil.getCollectIntervalMs());
    }

    //鐠囧鍘ょ純顔芥瀮娴狅拷

    private static String parseClientVersion(String value) {
        if (value == null || value.trim().isEmpty()) {
            return "0.0.0";
        }
        return ClientVersionUtils.normalize(value.trim());
    }

    private static void readProperty() throws IOException{
        Properties pro = ConfigUtil.loadProperties();
        ConfigUtil.printStartupInfo();
        mes_gw =  pro.getProperty("mes.gw");
        client_version = parseClientVersion(pro.getProperty("mes.client.version"));

//        mes_gw_des = pro.getProperty("mes.gw_des");
        mes_server_ip = pro.getProperty("mes.server_ip");
        mes_tcp_port = Integer.parseInt(pro.getProperty("mes.tcp_port"));
        mes_heart_beat_cycle = Integer.parseInt(pro.getProperty("mes.heart_beat_cycle"));
        mes_line_sn = pro.getProperty("mes.line_sn");

        mes_gw_des = OprnoUtil.getGwDes(mes_line_sn,mes_gw);

        mes_gwflag = pro.getProperty("mes.gwflag");

        System.out.println(mes_gw + ";" + mes_gw_des + ";" + mes_server_ip + ";" + mes_tcp_port + ";" + mes_heart_beat_cycle);
    }

    // 閸掓繂顫愰崠鏈P
    public static void initTcpConnection() {
        try {
            if(nettyClient==null) {
                //閸掓繂顫愰崠鏈P鏉╃偞甯�
                nettyClient = new NettyClient();
                //TCP鏉╃偞甯撮悩鑸碉拷锟�
                tcp_connect_flag = false;
                //鐠佸墽鐤員CP鐠囬攱鐪伴悩鑸碉拷锟�
                connect_request_flag = true;

                DataUtil.synrTcp(nettyClient,mes_gw);
            }
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    //閸氼垰濮╄箛鍐儲閸栧懐鈻兼惔锟�
    public static java.util.Timer heartBeatTimer;
    public static java.util.Timer heartBeatIconTimer;
    public static java.util.Timer iweldLoginTimer;
    public static boolean iconREDFlag = true;
    public static JTextField param1;
    public static JTextField param2;
    public static JTextField param3;
    public static JTextField param4;
    public static JTextField product_sn2;
    public static JTextField param21;
    public static JTextField param22;
    public static JTextField param23;
    public static JTextField param24;
    public static void startHeartBeatTimer() {
        if(heartBeatTimer!=null) {
            heartBeatTimer.cancel();
        }
        heartBeatTimer = new java.util.Timer();
        heartBeatTimer.schedule(new TimerTask() {
            public void run() {
                if(nettyClient!=null&&tcp_connect_flag) {
                    //System.out.println("閸欐垿锟戒礁绺剧捄铏Г閺傦拷");
                    DataUtil.heartBeat(nettyClient,mes_gw);

                    heart_beat_menu.setText(DateLocalUtils.getCurrentTime());
                }
            }
        }, 100,mes_heart_beat_cycle*1000);

        //韫囧啳鐑﹂弰鍓с仛閸ョ偓鐖�
        if(heartBeatIconTimer!=null) {
            heartBeatIconTimer.cancel();
        }
        heartBeatIconTimer = new Timer();
        heartBeatIconTimer.schedule(new TimerTask() {
            public void run() {
                if(tcp_connect_flag) {
                    if(iconREDFlag) {
                        heart_beat_menu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/grey_dot.png")));
                        iconREDFlag = false;
                    }else {
                        heart_beat_menu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/green_dot.png")));
                        iconREDFlag = true;
                    }
                    heart_beat_menu.setText(DateLocalUtils.getCurrentTime());
                    heart_beat_menu.repaint();
                }else {
                    heart_beat_menu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/grey_dot.png")));
                    heart_beat_menu.setText(DateLocalUtils.getCurrentTime());
                    heart_beat_menu.repaint();

                    // TCP 断线时延迟重连
                    if(nettyClient!=null && !tcp_connect_flag){
                        scheduleTcpReconnect();
                    }
                }
            }
        }, 100,mes_heart_icon_cycle*1000);
    }

    public static void startIweldLoginTimer() {
        if(iweldLoginTimer != null) {
            iweldLoginTimer.cancel();
        }
        iweldLoginTimer = new Timer();
        long twoHoursMs = 2 * 60 * 60 * 1000L;
        iweldLoginTimer.schedule(new TimerTask() {
            public void run() {
                IweldCloudUtil.login();
            }
        }, 0, twoHoursMs);
    }

    //鐠佸墽鐤唗cp鏉╃偞甯撮悩鑸碉拷浣规▔缁�锟�
    public static void setTcpStatus() {
        if(tcp_connect_flag) {
            status_menu.setText("已连接MES服务器");
            heart_beat_menu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/grey_dot.png")));
            heart_beat_menu.repaint();
        }else {
            status_menu.setText("未连接MES服务器");
            heart_beat_menu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/grey_dot.png")));
            heart_beat_menu.repaint();
        }
    }

    public static void initWarehouseData(){
        loadProductTypeFromDb();
        resetScanA();
        resetScanB();

        PlcUtil.changeEnable(s7PLC,false);
    }

    public static void resetScanA() {
        work_status = 0;
        check_quality_result = false;
        MesClient.mesQualityFlagA = false;
        product_sn.setText("");
        MesClient.pxstatus1.setText("A");

        MesClient.param1.setText("");
        MesClient.param2.setText("");
        MesClient.param3.setText("");
        MesClient.param4.setText("");

        MesClient.param21.setText("");
        MesClient.param22.setText("");
        MesClient.param23.setText("");
        MesClient.param24.setText("");

        MesClient.curSna = "";
        MesClient.tjFlaga = 0;
        MesClient.checkA = 0;

//        MesClient.batch_status = 0;
//        MesClient.textField.setText("");
//        MesClient.batch_scan_1.setEnabled(false);
        MesClient.formatScanType(1);
//        PlcUtil.changeEnable(MesClient.s7PLC,false);

        updateMaterailData(); // 更新物料

        shiftUserCheck();
        refreshProductTypeLock();
    }

    public static int userLoginHours;//用户登录所处小时
    public static JTextField textField;
    public static JTextField textField_1;
    public static JTextField txtfa;
    public static JLabel scan_type_text;
    public static JLabel page_text;
    //换班用户信息检查
    private static  void  shiftUserCheck() {
        LocalDateTime now = LocalDateTime.now();
        // 判断时间范围
        if (userLoginHours >= 8 && userLoginHours < 20) {

            int hour = now.getHour();
            if (hour >= 20 || hour < 8) {
                logoff();
            }
        } else {
            int hour = now.getHour();
            if (hour >= 8 && hour < 20) {
                logoff();
            }
        }
    }

    public static void resetScanB() {
        work_status2 = 0;
        check_quality_result2 = false;
        MesClient.mesQualityFlagB = false;
        product_sn2.setText("");

        MesClient.pxstatus2.setText("B");
        MesClient.param1.setText("");
        MesClient.param2.setText("");
        MesClient.param3.setText("");
        MesClient.param4.setText("");

        MesClient.param21.setText("");
        MesClient.param22.setText("");
        MesClient.param23.setText("");
        MesClient.param24.setText("");
        MesClient.curSnb = "";
        MesClient.tjFlagb = 0;
        MesClient.checkB = 0;

//        MesClient.batch_status2 = 0;
//        MesClient.textField_1.setText("");
//        MesClient.batch_scan_2.setEnabled(false);
        MesClient.formatScanType(1);
//        PlcUtil.changeEnable(MesClient.s7PLC,false);

        updateMaterailData(); // 更新物料

//        shiftUserCheck();
        refreshProductTypeLock();
    }

    //閼惧嘲褰囬悽銊﹀煕20娴ｏ拷
    public static void getUser() {
        user20 = user_menu.getText().toString();
        String space_tmp1 = "";
        if(user20.length()<20) {
            for(int i=0;i<20-user20.length();i++) {
                space_tmp1 = space_tmp1 + " ";
            }
        }
        user20 = user20 + space_tmp1;
    }

    /** 提交质量结果，并将焊接实时参数落本地库 */
    public static boolean submitQualityAndFlush(String face, String result) {
        getUser();
        String rawSn = "A".equals(face) ? product_sn.getText() : product_sn2.getText();
        if(rawSn == null || rawSn.trim().isEmpty()){
            return false;
        }
        String sn = getBarcode(rawSn.trim());
        Boolean sendret = DataUtil.sendQuality(nettyClient, sn, result, user20, face);
        IweldCloudUtil.flushWeldingParamsOnFinish(face);
        return sendret != null && sendret;
    }

    /** manualImmediateReset=true 时发送成功后立即复位；自动流程由 MesRevice 等待 MES 回包后复位 */
    public static void handleSubmitResult(String face, String result, boolean manualImmediateReset) {
        if(!tcp_connect_flag){
            setMenuStatus("未连接MES服务器", -1);
            return;
        }
        String label = "A".equals(face) ? "A面" : "B面";
        String rawSn = "A".equals(face) ? product_sn.getText() : product_sn2.getText();
        if(rawSn == null || rawSn.trim().isEmpty()){
            setMenuStatus(label + "无工件码，请先扫码", -1);
            return;
        }

        boolean sendret = submitQualityAndFlush(face, result);
        if(!sendret){
            if("A".equals(face)){
                pxstatus1.setText("A:结果上传MES失败");
                tjStatusa = 1;
            }else{
                pxstatus2.setText("B:结果上传MES失败");
                tjStatusb = 1;
            }
            setMenuStatus(label + "提交失败，请重试", -1);
            return;
        }

        if(manualImmediateReset){
            if("A".equals(face)){
                pxstatus1.setText("OK".equals(result) ? "A:提交成功" : "A:已提交NG");
                status_menu.setText("OK".equals(result) ? "A件提交成功" : "A件已提交NG");
                resetScanA();
            }else{
                pxstatus2.setText("OK".equals(result) ? "B:提交成功" : "B:已提交NG");
                status_menu.setText("OK".equals(result) ? "B件提交成功" : "B件已提交NG");
                resetScanB();
            }
            setMenuStatus(label + ("OK".equals(result) ? "提交成功" : "已提交NG"), 0);
        }
    }

    public static void promptManualSubmit(String face) {
        String label = "A".equals(face) ? "A面" : "B面";
        String rawSn = "A".equals(face) ? product_sn.getText() : product_sn2.getText();
        if(rawSn == null || rawSn.trim().isEmpty()){
            setMenuStatus(label + "无工件码，请先扫码", -1);
            return;
        }

        int choice = JOptionPane.showOptionDialog(
                mesClientFrame,
                label + " 工件: " + rawSn.trim() + "\n请选择提交结果",
                "手动提交-" + label,
                JOptionPane.DEFAULT_OPTION,
                JOptionPane.QUESTION_MESSAGE,
                null,
                new Object[]{"OK", "NG", "取消"},
                "OK"
        );
        if(choice == 0){
            handleSubmitResult(face, "OK", true);
        }else if(choice == 1){
            handleSubmitResult(face, "NG", true);
        }
    }

    public static String getBarcode(String barcodeTmp) {
        String barcodeRet = barcodeTmp;
        if(barcodeTmp.equalsIgnoreCase("")) {
            return "";
        }else {
            if(barcodeTmp.length()<36) {
                String space = "";
                for(int i=0;i<36-barcodeTmp.length();i++) {
                    space = space + " ";
                }
                barcodeRet = barcodeTmp + space;
            }
        }
        return barcodeRet;
    }

    public static void logoff() {
        welcomeWin.setVisible(true);
        mesClientFrame.setVisible(false);

        nettyClient = null;
        if(heartBeatTimer!=null) {
            heartBeatTimer.cancel();
        }
        if(heartBeatIconTimer!=null) {
            heartBeatIconTimer.cancel();
        }
        if(iweldLoginTimer!=null) {
            iweldLoginTimer.cancel();
        }
        tcp_connect_flag = false;
        connect_request_flag = false;
    }

    public MesClient() {
        setIconImage(Toolkit.getDefaultToolkit().getImage(MesClient.class.getResource("/bg/logo.png")));
        setTitle("MES系统客户端:"+mes_gw + "- " + mes_gw_des);
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        setBounds(0, 0, 1024, 768);

        JMenuBar menuBar = new JMenuBar();
        menuBar.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 26));
        setJMenuBar(menuBar);
        JMenu fileMenu = new JMenu("\u7528\u6237");
        fileMenu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/user.png")));
        fileMenu.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        menuBar.add(fileMenu);

        JMenuItem exitMenuItem = new JMenuItem("退出");
        exitMenuItem.setIcon(new ImageIcon(MesClient.class.getResource("/bg/logoff.png")));
        exitMenuItem.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 22));
        fileMenu.add(exitMenuItem);
        exitMenuItem.addMouseListener(new MouseAdapter() {
            @Override
            public void mousePressed(MouseEvent e) {//閸欘亣鍏樺Λ锟藉ù瀣煂mousePressed娴滃娆�
                super.mouseClicked(e);
                //dispose();
                logoff();
            }
        });

        JMenu settingMenu = new JMenu("设置");
        //settingMenu.setVisible(false);
        settingMenu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/menu_setting.png")));
        settingMenu.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        menuBar.add(settingMenu);

        JMenuItem resetTcpMenu = new JMenuItem("\u91CD\u8FDEMES");
        resetTcpMenu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png")));
        resetTcpMenu.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        resetTcpMenu.addMouseListener(new MouseAdapter() {
            @Override
            public void mousePressed(MouseEvent e) {
                super.mouseClicked(e);
                //闁插秷绻沵es
                if(nettyClient != null && nettyClient.isChannelActive()){
                    nettyClient.future.channel().close();
                }
            }
        });
        settingMenu.add(resetTcpMenu);

        JMenuItem resetTcpMenu_1 = new JMenuItem("\u91CD\u65B0\u626B\u7801-A");
        resetTcpMenu_1.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png")));
        resetTcpMenu_1.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        resetTcpMenu_1.addMouseListener(new MouseAdapter() {
            @Override
            public void mousePressed(MouseEvent e) {
                super.mouseClicked(e);
                resetScanA();
            }
        });
        settingMenu.add(resetTcpMenu_1);

        JMenuItem resetTcpMenu_1_1 = new JMenuItem("\u91CD\u65B0\u626B\u7801-B");
        resetTcpMenu_1_1.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png")));
        resetTcpMenu_1_1.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        resetTcpMenu_1_1.addMouseListener(new MouseAdapter() {
            @Override
            public void mousePressed(MouseEvent e) {
                super.mouseClicked(e);
                resetScanB();
            }
        });
        settingMenu.add(resetTcpMenu_1_1);

        JMenuItem resetTcpMenu_1sd = new JMenuItem("手动提交-A");
        resetTcpMenu_1sd.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png")));
        resetTcpMenu_1sd.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        resetTcpMenu_1sd.addMouseListener(new MouseAdapter() {
            @Override
            public void mousePressed(MouseEvent e) {
                super.mouseClicked(e);
                promptManualSubmit("A");
            }
        });
        settingMenu.add(resetTcpMenu_1sd);

        JMenuItem resetTcpMenu_1_1sd = new JMenuItem("手动提交-B");
        resetTcpMenu_1_1sd.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png")));
        resetTcpMenu_1_1sd.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        resetTcpMenu_1_1sd.addMouseListener(new MouseAdapter() {
            @Override
            public void mousePressed(MouseEvent e) {
                super.mouseClicked(e);
                promptManualSubmit("B");
            }
        });
        settingMenu.add(resetTcpMenu_1_1sd);

        contentPane = new JPanel();
        contentPane.setBorder(new EmptyBorder(5, 5, 5, 5));
        setContentPane(contentPane);
        contentPane.setLayout(new BorderLayout(0, 0));

        JToolBar toolBar = new JToolBar();
        contentPane.add(toolBar, BorderLayout.NORTH);

        JLabel equipment_statu_label = new JLabel("\u72B6\u6001\uFF1A");
        equipment_statu_label.setHorizontalAlignment(SwingConstants.CENTER);
        equipment_statu_label.setForeground(Color.BLACK);
        equipment_statu_label.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        equipment_statu_label.setBackground(Color.LIGHT_GRAY);
        toolBar.add(equipment_statu_label);

        status_menu = new JButton("设备未连接MES服务器");
        if(tcp_connect_flag) {
            status_menu.setText("已连接MES服务器");
            status_menu.setForeground(Color.GREEN);
        }else {
            status_menu.setText("未连接MES服务器");
            status_menu.setForeground(Color.DARK_GRAY);
        }
        status_menu.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
            }
        });
        status_menu.setForeground(Color.GREEN);
        status_menu.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        status_menu.setBackground(Color.BLACK);
        toolBar.add(status_menu);

        JLabel space_1 = new JLabel("    ");
        toolBar.add(space_1);

        JLabel heart_beat_status_label = new JLabel("\u5FC3\u8DF3\uFF1A");
        heart_beat_status_label.setHorizontalAlignment(SwingConstants.CENTER);
        heart_beat_status_label.setForeground(Color.BLACK);
        heart_beat_status_label.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        heart_beat_status_label.setBackground(Color.LIGHT_GRAY);
        toolBar.add(heart_beat_status_label);

        heart_beat_menu = new JButton("2024-02-20 23:20:10");
        heart_beat_menu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/green_dot.png")));
        heart_beat_menu.setForeground(Color.GREEN);
        heart_beat_menu.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        heart_beat_menu.setBackground(Color.BLACK);
        toolBar.add(heart_beat_menu);

        JLabel space_2 = new JLabel("    ");
        toolBar.add(space_2);

        JLabel user_status_label = new JLabel("\u767B\u5F55\u7528\u6237\uFF1A");
        user_status_label.setHorizontalAlignment(SwingConstants.CENTER);
        user_status_label.setForeground(Color.BLACK);
        user_status_label.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        user_status_label.setBackground(Color.LIGHT_GRAY);
        toolBar.add(user_status_label);

        user_menu = new JButton("JinJuShi");
        user_menu.setForeground(Color.GREEN);
        user_menu.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 22));
        user_menu.setBackground(Color.BLACK);
        toolBar.add(user_menu);

        JLabel space_3 = new JLabel("    ");
        toolBar.add(space_3);

        JLabel space_4 = new JLabel("    ");
        toolBar.add(space_4);

        tabbedPane = new JTabbedPane(JTabbedPane.TOP);
        tabbedPane.setTabLayoutPolicy(JTabbedPane.SCROLL_TAB_LAYOUT);
        tabbedPane.setMinimumSize(new Dimension(400, 50));
        tabbedPane.setFont(new Font("Microsoft YaHei UI", Font.BOLD, 22));
        contentPane.add(tabbedPane);

        //妫ｆ牠銆�
        JPanel indexPanelA = new JPanel();
        indexPanelA.setLayout(null);
        indexScrollPaneA = new JScrollPane(indexPanelA);
        indexScrollPaneA.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED);
        indexScrollPaneA.setHorizontalScrollBarPolicy(JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);

        product_sn = new JTextField();
        product_sn.setText("");
        product_sn.setHorizontalAlignment(SwingConstants.CENTER);
        product_sn.setEditable(false);
        product_sn.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 22));
        product_sn.setBounds(26, 152, 446, 70);
        indexPanelA.add(product_sn);
        product_sn.setColumns(10);

//        String[] hjtitles = new String[]{"閻掑﹥婧�1","閻掑﹥婧�2","閻掑﹥婧�3"};
//        String[] hjvals = new String[]{"HJ001","HJ002","HJ003"};
//        mesRadioHj = new MesRadio(hjtitles,hjvals);
//        mesRadioHj.setSize(500,50);
//        mesRadioHj.setBounds(190,170,500,50);
//        indexPanelA.add(mesRadioHj);

        product_sn2 = new JTextField();
        product_sn2.setText("");
        product_sn2.setHorizontalAlignment(SwingConstants.CENTER);
        product_sn2.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 22));
        product_sn2.setEditable(false);
        product_sn2.setColumns(10);
        product_sn2.setBounds(517, 152, 446, 70);
        indexPanelA.add(product_sn2);

        JSeparator separator = new JSeparator();
        separator.setBounds(450, 247, 0, 120);
        indexPanelA.add(separator);

        JSeparator separator_1 = new JSeparator();
        separator_1.setOrientation(SwingConstants.VERTICAL);
        separator_1.setBounds(495, 91, 23, 250);
        indexPanelA.add(separator_1);

        pxstatus1 = new JLabel("A");
        pxstatus1.setForeground(new Color(255, 128, 64));
        pxstatus1.setHorizontalAlignment(SwingConstants.CENTER);
        pxstatus1.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        pxstatus1.setBounds(26, 98, 446, 44);
        indexPanelA.add(pxstatus1);

        pxstatus2 = new JLabel("B");
        pxstatus2.setForeground(new Color(255, 128, 64));
        pxstatus2.setHorizontalAlignment(SwingConstants.CENTER);
        pxstatus2.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        pxstatus2.setBounds(517, 98, 446, 44);
        indexPanelA.add(pxstatus2);

        JSeparator separator_2 = new JSeparator();
        separator_2.setBounds(10, 264, 973, 13);
        indexPanelA.add(separator_2);

        JLabel lblNewLabel_4 = new JLabel("焊机1");
        lblNewLabel_4.setHorizontalAlignment(SwingConstants.CENTER);
        lblNewLabel_4.setFont(new Font("微软雅黑", Font.PLAIN, 24));
        lblNewLabel_4.setBounds(170, 290, 156, 40);
        lblNewLabel_4.setVisible(true);
        indexPanelA.add(lblNewLabel_4);

        JLabel lblNewLabel_4_1 = new JLabel("焊机2");
        lblNewLabel_4_1.setHorizontalAlignment(SwingConstants.CENTER);
        lblNewLabel_4_1.setFont(new Font("微软雅黑", Font.PLAIN, 24));
        lblNewLabel_4_1.setBounds(670, 287, 156, 40);
        lblNewLabel_4_1.setVisible(true);
        indexPanelA.add(lblNewLabel_4_1);

        JSeparator separator_1_1 = new JSeparator();
        separator_1_1.setOrientation(SwingConstants.VERTICAL);
        separator_1_1.setBounds(495, 278, 23, 232);
        indexPanelA.add(separator_1_1);

        textField = new JTextField();
        textField.setText("");
        textField.setHorizontalAlignment(SwingConstants.CENTER);
        textField.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 22));
        textField.setEditable(false);
        textField.setColumns(10);
        textField.setBounds(26, 333, 446, 70);
//        indexPanelA.add(textField);

        batch_scan_1 = new JButton("解绑");
        batch_scan_1.setIcon(new ImageIcon(MesClient.class.getResource("/bg/delete.png")));
        batch_scan_1.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 32));
        batch_scan_1.setEnabled(false);
        batch_scan_1.setVisible(false);
        batch_scan_1.setBounds(136, 430, 230, 80);
        batch_scan_1.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                if(MesClient.curPage.equals("B")){
                    MesClient.setMenuStatus("该状态后梁无法解绑",-1);
                }else{
                    String sn = MesClient.product_sn.getText().trim();
                    String wsn = MesClient.textField.getText().trim();
                    JSONObject retObj = DataUtil.unBindWarehouseData(sn,wsn,user_menu.getText().trim(),"400007");
                    if(retObj.get("result")!=null&&retObj.get("result").toString().equalsIgnoreCase("true")) {
                        MesClient.setMenuStatus("后梁码解绑成功",0);
                        MesClient.formatScanType(2);

                        textField.setText("");
                        batch_scan_1.setEnabled(false);
                        PlcUtil.changeEnableA(s7PLC,false);
                    }else{
                        MesClient.formatScanType(2);
                        batch_scan_1.setEnabled(true);
                        if(retObj.get("result")==null){
                            MesClient.setMenuStatus("请求失败，后梁码解绑失败，请重试",-1);
                        }else{
                            if(retObj.get("result").toString().equalsIgnoreCase("false")){
                                MesClient.setMenuStatus(retObj.getString("message"),-1);
                            }
                        }
                    }
                }
            }
        });
        indexPanelA.add(batch_scan_1);

        textField_1 = new JTextField();
        textField_1.setText("");
        textField_1.setHorizontalAlignment(SwingConstants.CENTER);
        textField_1.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 22));
        textField_1.setEditable(false);
        textField_1.setColumns(10);
        textField_1.setBounds(517, 333, 446, 70);
//        indexPanelA.add(textField_1);

        batch_scan_2 = new JButton("解绑");
        batch_scan_2.setIcon(new ImageIcon(MesClient.class.getResource("/bg/delete.png")));
        batch_scan_2.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 32));
        batch_scan_2.setEnabled(false);
        batch_scan_2.setVisible(false);
        batch_scan_2.setBounds(633, 430, 230, 80);
        batch_scan_2.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                if(MesClient.curPage.equals("A")){
                    MesClient.setMenuStatus("该状态后梁无法解绑",-1);
                }else{
                    String sn = MesClient.product_sn2.getText().trim();
                    String wsn = MesClient.textField_1.getText().trim();
                    JSONObject retObj = DataUtil.unBindWarehouseData(sn,wsn,user_menu.getText().trim(),"400007");
                    if(retObj.get("result")!=null&&retObj.get("result").toString().equalsIgnoreCase("true")) {
                        MesClient.setMenuStatus("后梁码解绑成功",0);
                        MesClient.formatScanType(2);
                        textField_1.setText("");
                        batch_scan_2.setEnabled(false);
                        PlcUtil.changeEnableB(s7PLC,false);
                    }else{
                        if(retObj.get("result")==null){
                            MesClient.setMenuStatus("请求失败，前梁码解绑失败，请重试",-1);
                        }else{
                            if(retObj.get("result").toString().equalsIgnoreCase("false")){
                                MesClient.setMenuStatus(retObj.getString("message"),-1);
                            }
                        }
                    }
                }
            }
        });
        indexPanelA.add(batch_scan_2);

        JLabel pxstatus1_1 = new JLabel("A后梁");
        pxstatus1_1.setHorizontalAlignment(SwingConstants.CENTER);
        pxstatus1_1.setForeground(new Color(0, 0, 0));
        pxstatus1_1.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        pxstatus1_1.setBounds(26, 283, 446, 44);
//        indexPanelA.add(pxstatus1_1);

        JLabel pxstatus1_1_1 = new JLabel("B后梁");
        pxstatus1_1_1.setHorizontalAlignment(SwingConstants.CENTER);
        pxstatus1_1_1.setForeground(Color.BLACK);
        pxstatus1_1_1.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 20));
        pxstatus1_1_1.setBounds(517, 283, 446, 44);
//        indexPanelA.add(pxstatus1_1_1);

        txtfa = new JTextField();
        txtfa.setHorizontalAlignment(SwingConstants.LEFT);
        txtfa.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 22));
        txtfa.setColumns(10);
        txtfa.setBounds(239, 10, 503, 60);
        indexPanelA.add(txtfa);
        txtfa.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                scanBarcode();
            }
        });

        page_text = new JLabel("当前:A面");
        page_text.setForeground(new Color(0, 255, 64));
        page_text.setFont(new Font("微软雅黑", Font.PLAIN, 20));
        page_text.setHorizontalAlignment(SwingConstants.RIGHT);
        page_text.setBounds(97, 10, 132, 60);
        indexPanelA.add(page_text);

        scan_type_text = new JLabel("镭雕码");
        scan_type_text.setForeground(new Color(255, 128, 64));
        scan_type_text.setHorizontalAlignment(SwingConstants.LEFT);
        scan_type_text.setFont(new Font("微软雅黑", Font.PLAIN, 20));
        scan_type_text.setBounds(752, 10, 132, 60);
        indexPanelA.add(scan_type_text);

        // 焊机参数：第一行 电压/电流/送丝速度，第二行 程序名（整行）
        int welder1X = 26;
        int welder1W = 446;
        int welder2X = 517;
        int welder2W = 446;
        int metricColW = 140;
        int metricLabelY = 328;
        int metricFieldY = 348;
        int metricFieldH = 28;
        int progLabelY = 386;
        int progFieldY = 406;
        int progFieldH = 28;

        JLabel lblDyA = new JLabel("电压");
        lblDyA.setHorizontalAlignment(SwingConstants.CENTER);
        lblDyA.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        lblDyA.setBounds(welder1X, metricLabelY, metricColW, 20);
        indexPanelA.add(lblDyA);

        param1 = new JTextField();
        param1.setEnabled(false);
        param1.setEditable(false);
        param1.setHorizontalAlignment(SwingConstants.CENTER);
        param1.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        param1.setBounds(welder1X, metricFieldY, metricColW, metricFieldH);
        indexPanelA.add(param1);

        JLabel lblDlA = new JLabel("电流");
        lblDlA.setHorizontalAlignment(SwingConstants.CENTER);
        lblDlA.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        lblDlA.setBounds(welder1X + metricColW + 8, metricLabelY, metricColW, 20);
        indexPanelA.add(lblDlA);

        param2 = new JTextField();
        param2.setEnabled(false);
        param2.setEditable(false);
        param2.setHorizontalAlignment(SwingConstants.CENTER);
        param2.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        param2.setBounds(welder1X + metricColW + 8, metricFieldY, metricColW, metricFieldH);
        indexPanelA.add(param2);

        JLabel lblSsA = new JLabel("送丝速度");
        lblSsA.setHorizontalAlignment(SwingConstants.CENTER);
        lblSsA.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        lblSsA.setBounds(welder1X + (metricColW + 8) * 2, metricLabelY, metricColW, 20);
        indexPanelA.add(lblSsA);

        param3 = new JTextField();
        param3.setEnabled(false);
        param3.setEditable(false);
        param3.setHorizontalAlignment(SwingConstants.CENTER);
        param3.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        param3.setBounds(welder1X + (metricColW + 8) * 2, metricFieldY, metricColW, metricFieldH);
        indexPanelA.add(param3);

        JLabel lblProgA = new JLabel("程序名");
        lblProgA.setHorizontalAlignment(SwingConstants.CENTER);
        lblProgA.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        lblProgA.setBounds(welder1X, progLabelY, welder1W, 20);
        indexPanelA.add(lblProgA);

        param4 = new JTextField();
        param4.setEnabled(false);
        param4.setEditable(false);
        param4.setHorizontalAlignment(SwingConstants.CENTER);
        param4.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        param4.setBounds(welder1X, progFieldY, welder1W, progFieldH);
        indexPanelA.add(param4);

        JLabel lblDyB = new JLabel("电压");
        lblDyB.setHorizontalAlignment(SwingConstants.CENTER);
        lblDyB.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        lblDyB.setBounds(welder2X, metricLabelY, metricColW, 20);
        indexPanelA.add(lblDyB);

        param21 = new JTextField();
        param21.setEnabled(false);
        param21.setEditable(false);
        param21.setHorizontalAlignment(SwingConstants.CENTER);
        param21.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        param21.setBounds(welder2X, metricFieldY, metricColW, metricFieldH);
        indexPanelA.add(param21);

        JLabel lblDlB = new JLabel("电流");
        lblDlB.setHorizontalAlignment(SwingConstants.CENTER);
        lblDlB.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        lblDlB.setBounds(welder2X + metricColW + 8, metricLabelY, metricColW, 20);
        indexPanelA.add(lblDlB);

        param22 = new JTextField();
        param22.setEnabled(false);
        param22.setEditable(false);
        param22.setHorizontalAlignment(SwingConstants.CENTER);
        param22.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        param22.setBounds(welder2X + metricColW + 8, metricFieldY, metricColW, metricFieldH);
        indexPanelA.add(param22);

        JLabel lblSsB = new JLabel("送丝速度");
        lblSsB.setHorizontalAlignment(SwingConstants.CENTER);
        lblSsB.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        lblSsB.setBounds(welder2X + (metricColW + 8) * 2, metricLabelY, metricColW, 20);
        indexPanelA.add(lblSsB);

        param23 = new JTextField();
        param23.setEnabled(false);
        param23.setEditable(false);
        param23.setHorizontalAlignment(SwingConstants.CENTER);
        param23.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        param23.setBounds(welder2X + (metricColW + 8) * 2, metricFieldY, metricColW, metricFieldH);
        indexPanelA.add(param23);

        JLabel lblProgB = new JLabel("程序名");
        lblProgB.setHorizontalAlignment(SwingConstants.CENTER);
        lblProgB.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        lblProgB.setBounds(welder2X, progLabelY, welder2W, 20);
        indexPanelA.add(lblProgB);

        param24 = new JTextField();
        param24.setEnabled(false);
        param24.setEditable(false);
        param24.setHorizontalAlignment(SwingConstants.CENTER);
        param24.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 16));
        param24.setBounds(welder2X, progFieldY, welder2W, progFieldH);
        indexPanelA.add(param24);

        indexPanelA.setPreferredSize(new Dimension(993, 450));
        indexPanelA.revalidate();

        tabbedPane.addTab("工作面板", new ImageIcon(MesClient.class.getResource("/bg/a_side.png")), indexScrollPaneA, null);
        tabbedPane.setEnabledAt(0, true);

        if (PRODUCT_TYPE_SWITCH_ENABLED) {
        JPanel indexPanelProductType = new JPanel();
        indexPanelProductType.setLayout(null);
        JScrollPane productTypeScrollPane = new JScrollPane(indexPanelProductType);

        JLabel productTypeTitle = new JLabel("生产类型设置");
        productTypeTitle.setFont(new Font("微软雅黑", Font.BOLD, 28));
        productTypeTitle.setForeground(new Color(64, 64, 64));
        productTypeTitle.setHorizontalAlignment(SwingConstants.CENTER);
        productTypeTitle.setBounds(81, 80, 810, 50);
        indexPanelProductType.add(productTypeTitle);

        JLabel productTypeHint = new JLabel("请选择当前生产的工件类型，切换后将保存到本地并用于扫码校验");
        productTypeHint.setFont(new Font("微软雅黑", Font.PLAIN, 20));
        productTypeHint.setForeground(new Color(140, 140, 140));
        productTypeHint.setHorizontalAlignment(SwingConstants.CENTER);
        productTypeHint.setBounds(81, 140, 810, 40);
        indexPanelProductType.add(productTypeHint);

        productTypePanel = new ProductTypePanel(PRODUCT_TYPE_SWITCH_PASSWORD);
        productTypePanel.setBounds(276, 210, 420, 72);
        productTypePanel.setOnChangeListener(() -> {
            if (work_status == 0 && work_status2 == 0) {
                saveProductTypeToDb();
                if (PRODUCT_TYPE_SWITCH_ENABLED) {
            setMenuStatus("当前生产类型：" + getProductTypeName() + "，请扫工件码",0);
        } else {
            setMenuStatus("请扫工件码",0);
        }
            }
            refreshProductTypeCurrentLabel();
        });
        indexPanelProductType.add(productTypePanel);

        productTypeCurrentLabel = new JLabel();
        productTypeCurrentLabel.setFont(new Font("微软雅黑", Font.PLAIN, 22));
        productTypeCurrentLabel.setForeground(new Color(64, 64, 64));
        productTypeCurrentLabel.setHorizontalAlignment(SwingConstants.CENTER);
        productTypeCurrentLabel.setBounds(81, 310, 810, 40);
        refreshProductTypeCurrentLabel();
        indexPanelProductType.add(productTypeCurrentLabel);

        tabbedPane.addTab("生产类型", new ImageIcon(MesClient.class.getResource("/bg/menu_setting.png")), productTypeScrollPane, null);
        }



        JPanel indexPanelGz = new JPanel();
        searchScrollPaneGz = new JScrollPane(indexPanelGz);
        indexPanelGz.setLayout(null);


        indexPanelC = new JPanel(new BorderLayout());
//        initStartShiftCheckPanel(indexPanelC);

        tabbedPane.addTab("A面点检", new ImageIcon(MesClient.class.getResource("/bg/menu_data_preprocess.png")), indexPanelC, null);

        indexPanelDjB = new JPanel(new BorderLayout());
        tabbedPane.addTab("B面点检", new ImageIcon(MesClient.class.getResource("/bg/menu_data_preprocess.png")), indexPanelDjB, null);


        indexPanelB = new JPanel();
        searchScrollPane = new JScrollPane(indexPanelB);
        indexPanelB.setLayout(null);

        tabbedPane.addTab("工作记录", new ImageIcon(MesClient.class.getResource("/bg/menu_data_preprocess.png")), searchScrollPane, null);

//        bindBatchPanel();

        tabbedPane.addChangeListener(new ChangeListener() {
            @Override
            public void stateChanged(ChangeEvent e) {
                JTabbedPane tabbedPane = (JTabbedPane) e.getSource();
                int selectedIndex = tabbedPane.getSelectedIndex();
                System.out.println("selectedIndex:"+selectedIndex);

                if(selectedIndex == 1){

                }
            }
        });
    }

    // 开班点检页面初始化（仿“工作面板”写法：null布局+绝对坐标）
    private static void initStartShiftCheckPanel(JPanel panel) {

        // A面 6 灯
        JLabel aLabel = new JLabel("A面状态");
        aLabel.setFont(new Font("Microsoft YaHei UI", Font.BOLD, 22));
        aLabel.setBounds(20, 50, 150, 40);
        panel.add(aLabel);

        int lampY1 = 110;
        int lampXStart = 80;
        int lampGap = 140;
        for (int i = 0; i < 6; i++) {
            JLabel lamp = new JLabel();
            lamp.setBounds(lampXStart + i * lampGap, lampY1, 40, 40);
            lamp.setIcon(new ImageIcon(MesClient.class.getResource("/bg/grey_dot.png")));
            panel.add(lamp);
            dj_a_lamps[i] = lamp;

            JLabel idx = new JLabel(String.valueOf(i + 1));
            idx.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 18));
            idx.setBounds(lampXStart + i * lampGap + 12, lampY1 + 45, 40, 30);
            panel.add(idx);
        }

        // B面 6 灯
        JLabel bLabel = new JLabel("B面状态");
        bLabel.setFont(new Font("Microsoft YaHei UI", Font.BOLD, 22));
        bLabel.setBounds(20, 230, 150, 40);
        panel.add(bLabel);

        int lampY2 = 290;
        for (int i = 0; i < 6; i++) {
            JLabel lamp = new JLabel();
            lamp.setBounds(lampXStart + i * lampGap, lampY2, 40, 40);
            lamp.setIcon(new ImageIcon(MesClient.class.getResource("/bg/grey_dot.png")));
            panel.add(lamp);
            dj_b_lamps[i] = lamp;

            JLabel idx = new JLabel(String.valueOf(i + 1));
            idx.setFont(new Font("Microsoft YaHei UI", Font.PLAIN, 18));
            idx.setBounds(lampXStart + i * lampGap + 12, lampY2 + 45, 40, 30);
            panel.add(idx);
        }

        // 按钮
        dj_start_btn = new JButton("开班点检");
        dj_start_btn.setFont(new Font("Microsoft YaHei UI", Font.BOLD, 26));
        dj_start_btn.setBounds(380, 450, 260, 70);
        panel.add(dj_start_btn);
        dj_start_btn.addActionListener(new ActionListener() {
            @Override
            public void actionPerformed(ActionEvent e) {
                byte[] djStatus = PlcUtil.getDjStatus(s7PLC);
                if(djStatus == null || djStatus.length < 12){
                    JOptionPane.showMessageDialog(mesClientFrame, "点检信号读取失败", "提示窗口", JOptionPane.INFORMATION_MESSAGE);
                    return;
                }
                updateDjLamps(djStatus);
                boolean allOn = isTwelveLampsAllOn(djStatus);
                if(!allOn){
                    JOptionPane.showMessageDialog(mesClientFrame, "点检项缺失，请检查设备", "提示窗口", JOptionPane.INFORMATION_MESSAGE);
                    return;
                }

                JSONObject retObj = DataUtil.saveDj();
                if (retObj.get("result") != null && retObj.get("result").toString().equalsIgnoreCase("true")){
                    JOptionPane.showMessageDialog(mesClientFrame, "点检成功", "提示窗口", JOptionPane.INFORMATION_MESSAGE);
                }else {
                    JOptionPane.showMessageDialog(mesClientFrame, "点检记录上传失败", "提示窗口", JOptionPane.INFORMATION_MESSAGE);
                }
            }
        });
    }

    // 点检灯状态更新：非0亮绿，0置灰
    public static void updateDjLamps(byte[] djStatus){
        Icon greyIcon = new ImageIcon(MesClient.class.getResource("/bg/grey_dot.png"));
        Icon greenIcon = new ImageIcon(MesClient.class.getResource("/bg/green_dot.png"));
        for (int i = 0; i < 6; i++) {
            if(dj_a_lamps[i] != null){
                dj_a_lamps[i].setIcon(djStatus[i] != 0 ? greenIcon : greyIcon);
            }
            if(dj_b_lamps[i] != null){
                dj_b_lamps[i].setIcon(djStatus[i + 6] != 0 ? greenIcon : greyIcon);
            }
        }
        if(indexPanelC != null){
            indexPanelC.repaint();
        }
    }

    private static boolean isTwelveLampsAllOn(byte[] djStatus){
        for (int i = 0; i < 12; i++) {
            if(djStatus[i] == 0){
                return false;
            }
        }
        return true;
    }
    public static void formatScanType(int st){
        scan_type = st;
        if(scan_type == 1){
            scan_type_text.setText("镭雕码");
        }else if(scan_type == 2){
            scan_type_text.setText("后梁码");
        }else{
            scan_type_text.setText("");
        }
    }

    public static void loadProductTypeFromDb() {
        if (productTypePanel == null) {
            return;
        }
        String savedType = JdbcUtils.getClientConfig(
                JdbcUtils.getProductTypeConfigKey(mes_gw),
                PRODUCT_TYPE_ZJ
        );
        if (PRODUCT_TYPE_SJ.equals(savedType)) {
            productTypePanel.setResult(PRODUCT_TYPE_SJ);
        } else {
            productTypePanel.setResult(PRODUCT_TYPE_ZJ);
        }
        refreshProductTypeCurrentLabel();
    }

    public static void refreshProductTypeCurrentLabel() {
        if (productTypeCurrentLabel != null) {
            productTypeCurrentLabel.setText("当前选择：" + getProductTypeName() + "（前缀 " + getProductSnPrefix() + "）");
        }
    }

    public static void saveProductTypeToDb() {
        if (productTypePanel == null) {
            return;
        }
        JdbcUtils.saveClientConfig(
                JdbcUtils.getProductTypeConfigKey(mes_gw),
                productTypePanel.getResult()
        );
    }

    public static String getProductSnPrefix() {
        if (productTypePanel != null && PRODUCT_TYPE_SJ.equals(productTypePanel.getResult())) {
            return PREFIX_SJ;
        }
        return PREFIX_ZJ;
    }

    public static String getProductTypeName() {
        if (productTypePanel != null) {
            return productTypePanel.getTypeName();
        }
        return "智界";
    }

    private static String getProductTypeNameBySn(String sn) {
        if (sn.startsWith(PREFIX_SJ)) {
            return "尚界";
        }
        if (sn.startsWith(PREFIX_ZJ)) {
            return "智界";
        }
        return "未知";
    }

    private static String validateProductSnMessage(String sn) {
        if (sn == null || sn.isEmpty()) {
            return "工件码为空，请重试";
        }
        if (sn.length() != PRODUCT_SN_LENGTH) {
            return "工件码长度须为32位，当前" + sn.length() + "位";
        }
        if (!PRODUCT_TYPE_SWITCH_ENABLED) {
            return null;
        }
        String prefix = getProductSnPrefix();
        if (!sn.startsWith(prefix)) {
            return "工件码前缀与当前类型(" + getProductTypeName() + ")不匹配，当前工件码为" + getProductTypeNameBySn(sn);
        }
        return null;
    }

    private static void updateProductTypePanelEnabled(boolean enabled) {
        if (productTypePanel != null) {
            productTypePanel.setEnabled(enabled);
        }
    }

    private static void refreshProductTypeLock() {
        boolean busy = (product_sn != null && !product_sn.getText().trim().isEmpty())
                || (product_sn2 != null && !product_sn2.getText().trim().isEmpty())
                || Boolean.TRUE.equals(mesQualityFlagA)
                || Boolean.TRUE.equals(mesQualityFlagB);
        updateProductTypePanelEnabled(!busy);
    }

    public static void scanBarcode() {
        String scanBarcodeSn = txtfa.getText().trim();
        txtfa.setText("");
        System.out.println("scan_type:"+scan_type);
        //刷新界面
        mesClientFrame.repaint();
        System.out.println("456");
        System.out.println("156"+scan_type);
        if(MesClient.scan_type == 1){ // 镭雕码
            System.out.println("type1");
            if(scanBarcodeSn.isEmpty()){
                System.out.println("type2");
                MesClient.setMenuStatus("镭雕码不能为空",1);
                return;
            }
            String validateMsg = validateProductSnMessage(scanBarcodeSn);
            if (validateMsg != null) {
                MesClient.setMenuStatus(validateMsg, 1);
                return;
            }
            if(MesClient.curPage.equals("A")){
                System.out.println("typeA");
                if(!product_sn.getText().isEmpty() && mesQualityFlagA){
                    MesClient.setMenuStatus("A面已存在工件码，勿重复扫码",1);
                    return;
                }
                product_sn.setText(scanBarcodeSn);
            }else{
                System.out.println("typeB");
                if(!product_sn2.getText().isEmpty() && mesQualityFlagB){
                    MesClient.setMenuStatus("B面已存在工件码，勿重复扫码",1);
                    return;
                }
                product_sn2.setText(scanBarcodeSn);
            }
            MesClient.setMenuStatus("扫码成功",0);
            refreshProductTypeLock();

            //刷新界面
            mesClientFrame.repaint();
            System.out.println("123");
            getUser();
            // 查询工件质量
            Boolean sendret = DataUtil.checkQuality(nettyClient,scanBarcodeSn,user20,MesClient.curPage);
            if(!sendret){
                MesClient.setMenuStatus("消息发送失败，请重试",1);
            }
        }
    }

    public static void setMenuStatus(String msg,int error){
        if(error == 0){
            MesClient.status_menu.setForeground(Color.GREEN);
        }else{
            MesClient.status_menu.setForeground(Color.RED);
        }
        MesClient.status_menu.setText(msg);
    }

    /** A/B 面绑定工位：gwflag=A 绑 OP060A/B，gwflag=B 绑 OP060C/D */
    public static String[] getMaterialOprnos(){
        if("A".equals(mes_gwflag)){
            return new String[]{mes_gw + "A", mes_gw + "B"};
        }else if("B".equals(mes_gwflag)){
            return new String[]{mes_gw + "C", mes_gw + "D"};
        }
        return new String[]{mes_gw};
    }

    /** A/B 共用库存：合并各面查询结果，剩余次数取较小值 */
    private static String materialRowKey(BindMaterialResp item){
        return String.valueOf(item.getMaterialId()) + "|" + String.valueOf(item.getCraft()) + "|" + String.valueOf(item.getType());
    }

    private static Integer parseLastTimes(String lastTimes){
        if(lastTimes == null || lastTimes.trim().isEmpty()){
            return null;
        }
        try{
            return Integer.parseInt(lastTimes.trim());
        }catch (NumberFormatException e){
            return null;
        }
    }

    private static String mergeSharedLastTimes(String left, String right){
        Integer leftVal = parseLastTimes(left);
        Integer rightVal = parseLastTimes(right);
        if(leftVal == null){
            return right != null ? right : "";
        }
        if(rightVal == null){
            return left;
        }
        return String.valueOf(Math.min(leftVal, rightVal));
    }

    private static String pickSharedBatchSn(String left, String right){
        if(left != null && !left.trim().isEmpty()){
            return left;
        }
        return right != null ? right : "";
    }

    private static void mergeSharedMaterial(BindMaterialResp target, BindMaterialResp source){
        target.setLastTimes(mergeSharedLastTimes(target.getLastTimes(), source.getLastTimes()));
        target.setBatchSn(pickSharedBatchSn(target.getBatchSn(), source.getBatchSn()));
    }

    private static List<BindMaterialResp> loadSharedMaterialList(){
        Map<String, BindMaterialResp> merged = new LinkedHashMap<>();
        for(String oprno : getMaterialOprnos()){
            JSONObject retObj = DataUtil.getBindMaterail(oprno);
            if(retObj == null || retObj.get("result") == null || !retObj.get("result").toString().equalsIgnoreCase("true")){
                continue;
            }
            List<BindMaterialResp> arrs = retObj.getList("data", BindMaterialResp.class);
            if(arrs == null || arrs.isEmpty()){
                continue;
            }
            for(BindMaterialResp item : arrs){
                String key = materialRowKey(item);
                BindMaterialResp existing = merged.get(key);
                if(existing == null){
                    merged.put(key, item);
                }else{
                    mergeSharedMaterial(existing, item);
                }
            }
        }
        return new ArrayList<>(merged.values());
    }

    private static Object[][] buildMaterialRowData(){
        List<BindMaterialResp> arrs = loadSharedMaterialList();
        if(arrs.isEmpty()){
            return new Object[0][7];
        }
        Object[][] rows = new Object[arrs.size()][7];
        int i = 0;
        for (BindMaterialResp bindMaterialResp : arrs){
            rows[i][0] = bindMaterialResp.getMaterialTitle();
            rows[i][1] = bindMaterialResp.getBatchSn() != null ? bindMaterialResp.getBatchSn() : "";
            rows[i][2] = bindMaterialResp.getLastTimes() != null ? bindMaterialResp.getLastTimes() : "";
            rows[i][3] = "";
            rows[i][4] = bindMaterialResp.getCraft();
            rows[i][5] = bindMaterialResp.getMaterialId();
            rows[i][6] = bindMaterialResp.getType();
            i++;
        }
        return rows;
    }

    public static void getMaterailData(){
        rowData = buildMaterialRowData();
        bindBatchPanel();
    }

    public static void updateMaterailData(){
        rowData = buildMaterialRowData();
        if(MesClient.table != null){
            MesClient.table.setModel(new javax.swing.table.DefaultTableModel(rowData, columnNames){
                public boolean isCellEditable(int row, int column) {
                    return column == 3;
                }
            });
            MesClient.table.getColumnModel().getColumn(3).setCellRenderer(new TableCellRendererButton());
            MesClient.table.getColumnModel().getColumn(3).setCellEditor(new TableCellEditorButton());
            MesClient.table.revalidate();
            MesClient.table.repaint();
        }
    }

    // 绑定物料批次码（A/B 共用，扫码一次同步绑定各面工位）
    public static void scanBatchSn(BindMaterialResp bindMaterialResp) {
        String scanBarcodeTitle = "请扫物料:" + bindMaterialResp.getMaterialTitle();
        String scanBarcode = JOptionPane.showInputDialog(null, scanBarcodeTitle);
        if(scanBarcode!=null&&!scanBarcode.equalsIgnoreCase("")) {
            String[] oprnos = getMaterialOprnos();
            if(oprnos.length == 0){
                MesClient.setMenuStatus("工位配置异常，请检查 config.properties", -1);
                return;
            }

            String failOprno = null;
            String failMsg = null;
            for(String oprno : oprnos){
                JSONObject retObj = DataUtil.saveBindMaterail(
                        scanBarcode,
                        bindMaterialResp.getCraft(),
                        bindMaterialResp.getMaterialId(),
                        bindMaterialResp.getType(),
                        oprno.trim());
                if(retObj == null || retObj.get("result") == null){
                    failOprno = oprno;
                    failMsg = "请求失败，请重试";
                    break;
                }
                if(!retObj.get("result").toString().equalsIgnoreCase("true")){
                    failOprno = oprno;
                    failMsg = retObj.getString("message");
                    if(failMsg == null || failMsg.isEmpty()){
                        failMsg = "绑定失败";
                    }
                    break;
                }
            }

            if(failOprno == null){
                MesClient.setMenuStatus("扫物料:" + bindMaterialResp.getMaterialTitle() + "成功(A/B共用)", 0);
                updateMaterailData();
            }else if(oprnos.length > 1){
                MesClient.setMenuStatus(failOprno + "绑定失败:" + failMsg, -1);
                updateMaterailData();
            }else{
                MesClient.setMenuStatus(failMsg, -1);
            }
        }
    }

    public static void bindBatchPanel(){
        JPanel indexPanelBB = new JPanel();
        JPanel panel = new JPanel();
        panel.setBounds(0, 0, 990, 550);
//        panel.setBounds(81, 50, 810, 479);
        indexPanelBB.add(panel);

        panel.setLayout(new GridLayout(0, 1, 0, 0));
        table = new JTable(rowData, columnNames){
            public boolean isCellEditable(int row, int column) {
                if(column == 3){
                    return true;
                }
                return false;
            }
        };
        table.setRowHeight(40);
        table.setEnabled(true);
        table.setFont(new Font("微软雅黑", Font.PLAIN, 14));

        table.getColumnModel().getColumn(3).setCellRenderer(new TableCellRendererButton());
        table.getColumnModel().getColumn(3).setCellEditor(new TableCellEditorButton());


        JScrollPane scrollPane = new JScrollPane(table);
        panel.add(scrollPane);

        indexScrollPaneB = new JScrollPane(indexPanelBB);
        indexPanelBB.setLayout(null);
        tabbedPane.addTab("绑定物料", new ImageIcon(MesClient.class.getResource("/bg/menu_data_preprocess.png")), indexScrollPaneB, null);
    }

    // 开启发送结果定时任务
    public static void startUpdateQualityTimer(){
        new Timer().schedule(new TimerTask() {
            @Override
            public void run() {
                try {
                    JdbcUtils.getConn();
                    Statement statement = JdbcUtils.conn.createStatement();
                    String selectSql = "SELECT id, bw FROM submit_record\n" +
                            "WHERE state = 0 ORDER BY id DESC LIMIT 10";
                    String updateSql = "UPDATE submit_record \n" +
                            "SET state = '1'\n" +
                            "WHERE id = ";
                    ResultSet rs = statement.executeQuery(selectSql);
                    while(rs.next()){
                        int id = rs.getInt("id");
                        String bw = rs.getString("bw");
                        // 发送请求
                        String url = "http://"+MesClient.mes_server_ip+":8980/js/a/mes/mesProductRecord/updateQualityByTiming";
                        String s = HttpUtils.sendPostRequestJson(url, bw );
                        Boolean result = JSONObject.parseObject(s).getBoolean("result");
                        if(result) {
                            // 更改状态为 1
                            statement.executeUpdate(updateSql + id);
                        }
                    }
                    rs.close();
                    statement.close();
                } catch (SQLException | IOException e) {
//                    throw new RuntimeException(e);
                    e.printStackTrace();
                }

            }
        },1000, 5000);
    }

    public static void formatBatchSn(){
        if(MesClient.batch_status == 1 && MesClient.tjFlaga == 1){
            PlcUtil.changeEnableA(MesClient.s7PLC,true);
        }else{
            PlcUtil.changeEnableA(MesClient.s7PLC,false);
        }
        if(MesClient.batch_status2 == 1 && MesClient.tjFlagb == 1){
            PlcUtil.changeEnableB(MesClient.s7PLC,true);
        }else{
            PlcUtil.changeEnableB(MesClient.s7PLC,false);
        }
    }

    private static String checkSnType(String sn){
        String str = sn.substring(9,12);
        if(str.equals("113")){
            return "MX11-2";
        }else if(str.equals("119")){
            return "MX11-2S";
        }else{
            return "";
        }
    }

    // 检查工件是否匹配
    private static Boolean checkSnAndBatch(String sn,String batchSn){
        String gdStr1 = "151245P000012131001000"; // MX11-2
        String gdStr2 = "151245P000017812001000"; // MX11-2S
        String cate = sn.substring(0,22);
        String ptype = checkSnType(batchSn);
        if(ptype.equals("MX11-2") && cate.equals(gdStr1)){
            return true;
        }
        if(ptype.equals("MX11-2S") && cate.equals(gdStr2)){
            return true;
        }
        return false;
    }
}