package com.mes.ui; import com.alibaba.fastjson2.JSONObject; 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.MesWebView; import com.mes.netty.NettyClient; import com.mes.netty.ProtocolParam; import com.mes.util.DateLocalUtils; import com.mes.util.ErrorMsg; import com.mes.util.HttpUtils; 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.*; import java.nio.channels.FileChannel; import java.nio.channels.FileLock; import java.nio.channels.OverlappingFileLockException; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.time.LocalDateTime; import java.util.List; import java.util.Properties; import java.util.Timer; import java.util.TimerTask; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class MesClient extends JFrame { public static final Logger log = LoggerFactory.getLogger(MesClient.class); public static int mes_auth = 0; // 权限级别 0=无权限 1=操作工人 2=管理员 public static String mes_gw = ""; // 工位号 public static String mes_gw_des = ""; // 工位名称 public static String mes_server_ip = ""; // 服务器IP地址 public static int mes_tcp_port = 3000; // TCP服务端口 public static int mes_heart_beat_cycle = 10; // 心跳周期 public static int mes_heart_icon_cycle = 1; public static String mes_line_sn = ""; // 产线编号 //TCP连接 public static NettyClient nettyClient; //TCP连接状态 public static boolean tcp_connect_flag = false; //TCP连接请求 public static boolean connect_request_flag = false; //session public static String sessionid = ""; public static JPanel contentPane; public static MesClient mesClientFrame; public static JTabbedPane tabbedPane; public static JScrollPane indexScrollPaneA; public static JScrollPane searchScrollPane; public static JScrollPane searchScrollPaneDj; public static JScrollPane searchScrollPaneC; public static JScrollPane searchScrollPaneD; public static Boolean check_quality_result = false; public static Integer work_status = 0; public static Boolean bind_lb_result = false; 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 finish_ok_bt; public static JButton finish_ng_bt; public static JTextField product_sn; public static JTextField product_sn_LB; public static JButton f_scan_data_bt_1; public static JButton f_scan_data_bt_2; public static String user20 = ""; public static JFrame welcomeWin; public static JPanel indexPanelB; public static MesWebView jfxPanel = null; public static JPanel indexPanelC; public static MesWebView jfxPanel2 = null; public static MesRadio mesRadioHj; public static JPanel indexPanelD; public static JPanel indexPanelE; public static MesWebView jfxPanel3 = null; public static MesWebView jfxPanel4 = null; public static JTable table; public static Object[] columnNames = { "物料名称", "绑定批次", "剩余次数", "操作" }; public static Object[][] rowData = null; public static JLabel fxlabel; public static JLabel timer_label; // 倒计时显示 public static boolean timer_flag = false; // 开始计时标志 false=非工作开始计时 true=工件开始计时 public static long timer_nums = 0; // 秒数 public static S7PLC s7PLC = new S7PLC(EPlcType.S1200,"10.88.10.80"); public static void main(String[] args) { try{ //读文件配置 readProperty(); }catch (Exception e){ e.printStackTrace(); } if (LockUtil.getInstance().isAppActive() == true){ JOptionPane.showMessageDialog(null, "已有一个程序在运行,程序退出"); return; }else{ EventQueue.invokeLater(new Runnable() { @Override public void run() { try{ s7PLC.setConnectTimeout(800); s7PLC.setReceiveTimeout(800); // 显示界面 mesClientFrame = new MesClient(); mesClientFrame.setVisible(false); JdbcUtils.getConn(); welcomeWin = new LoginFarme(); welcomeWin.setVisible(true); getMaterailData(); startPlcTimer(); }catch (Exception e){ e.printStackTrace(); } } }); } } //读配置文件 private static void readProperty() throws IOException{ String enconding = "UTF-8"; InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties"); Properties pro = new Properties(); BufferedReader br = new BufferedReader(new InputStreamReader(is, enconding)); pro.load(br); mes_gw = pro.getProperty("mes.gw"); 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); log.info(mes_gw + ";" + mes_gw_des + ";" + mes_server_ip + ";" + mes_tcp_port + ";" + mes_heart_beat_cycle); } // 初始化TCP public static void initTcpConnection() { try { if(nettyClient==null) { //初始化TCP连接 nettyClient = new NettyClient(); //TCP连接状态 tcp_connect_flag = false; //设置TCP请求状态 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 boolean iconREDFlag = true; // 心跳程序包 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(); //若未连接则尝试连接 if(nettyClient!=null&&!tcp_connect_flag){ System.out.println("TCP已断开"); //TCP重新同步连接 if(!connect_request_flag) { //System.out.println("TCP重新同步连接"); //设置TCP请求状态,只重新同步连接一次 connect_request_flag = true; DataUtil.synrTcp(nettyClient,mes_gw); } } } } }, 100,mes_heart_icon_cycle*1000); } //设置tcp连接状态显示 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(){ resetScanA(); } public static void resetScanA() { MesClient.fxlabel.setVisible(false); // 信号重置 RobotUtil.setAllowFeeding(s7PLC,false); RobotUtil.setAllowBlanking(s7PLC,false); MesClient.status_menu.setText("请扫工件码"); MesClient.product_sn.setText(""); MesClient.product_sn_LB.setText(""); MesClient.bind_lb_result = false; MesClient.work_status = 0; MesClient.check_quality_result = false; MesClient.index = 0; updateMaterailData(); // shiftUserCheck(); } public static int userLoginHours;//用户登录所处小时 //换班用户信息检查 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(); } } } //获取用户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; } //获取barcode内容36位 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 scanBarcode() { if(work_status == 1){ JOptionPane.showMessageDialog(mesClientFrame,"工作中，勿扫码","提示窗口", JOptionPane.INFORMATION_MESSAGE); return; } String scanBarcodeTitle = ""; switch(scan_type) { case 1: product_sn.setText(""); scanBarcodeTitle = "请扫工件码"; break; } //弹窗扫工件码 String scanBarcode = JOptionPane.showInputDialog(null, scanBarcodeTitle); if(scanBarcode!=null&&!scanBarcode.equalsIgnoreCase("")) { //获取用户 getUser(); //获取扫码内容36位 String barcode36 = getBarcode(scanBarcode);//处理36为码 //工位号 String gw = ""; switch(scan_type) { case 1: product_sn.setText(scanBarcode); break; } //刷新界面 mesClientFrame.repaint(); if(!tcp_connect_flag) { MesClient.setMenuStatus("设备未连接Mes服务器",-1); // JOptionPane.showMessageDialog(mesClientFrame,"设备未连接Mes服务器","提示窗口", JOptionPane.INFORMATION_MESSAGE); return; } // 查询工件质量 Boolean sendret = DataUtil.checkQuality(nettyClient,barcode36,user20); if(!sendret){ MesClient.setMenuStatus("消息发送失败，请重试",-1); return; } }else { MesClient.setMenuStatus("请扫工件码，请重试",-1); return; } } // public static void scanBarcode2() { // 判断工件码是不是空的 if(work_status != 1) { setMenuStatus("未扫工件码!", 1); return; } // 绑定冷板 //弹窗扫工件码 String scanBarcode = JOptionPane.showInputDialog(null, "冷板码"); if(scanBarcode!=null&&!scanBarcode.equalsIgnoreCase("")) { JSONObject retObj = DataUtil.bindWarehouseApi(product_sn.getText(),"400006",scanBarcode,user20); if(retObj.get("result")!=null&&retObj.get("result").toString().equalsIgnoreCase("true")) { bind_lb_result = true; product_sn_LB.setText(scanBarcode); log.info("bind_lb_result2:"+bind_lb_result); Boolean reg = DataUtil.sendQuality(MesClient.nettyClient, MesClient.product_sn.getText(), "OK",MesClient.user20); if (!reg){ setMenuStatus("报文发送异常", -1); return; } }else{ setMenuStatus("绑定失败!", 1); return; } } } public static void logoff() { welcomeWin.setVisible(true); mesClientFrame.setVisible(false); nettyClient = null; // if(heartBeatTimer!=null) { // heartBeatTimer.cancel(); // } // if(heartBeatIconTimer!=null) { // heartBeatIconTimer.cancel(); // } tcp_connect_flag = false; connect_request_flag = false; } public static ImageIcon imageGreen; public static ImageIcon imageGray; public static JLabel feedinglabel; public static JLabel feedinglabel2; public static JLabel feedingmeslabel; public static JLabel runlabel; //运行反馈， public static JLabel blankinglabel; // 下料反馈 public static JLabel blankingmeslabel; // 下料MES反馈 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("用户"); fileMenu.setIcon(new ImageIcon(MesClient.class.getResource("/bg/user.png"))); fileMenu.setFont(new Font("微软雅黑", Font.PLAIN, 20)); menuBar.add(fileMenu); JMenuItem exitMenuItem = new JMenuItem("退出"); exitMenuItem.setIcon(new ImageIcon(MesClient.class.getResource("/bg/logoff.png"))); exitMenuItem.setFont(new Font("微软雅黑", 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("微软雅黑", 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("微软雅黑", Font.PLAIN, 20)); resetTcpMenu.addMouseListener(new MouseAdapter() { @Override public void mousePressed(MouseEvent e) { super.mouseClicked(e); //重连mes nettyClient.future.channel().close(); } }); settingMenu.add(resetTcpMenu); JMenuItem resetTcpMenu2 = new JMenuItem("刷新工件"); resetTcpMenu2.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png"))); resetTcpMenu2.setFont(new Font("微软雅黑", Font.PLAIN, 20)); resetTcpMenu2.addMouseListener(new MouseAdapter() { @Override public void mousePressed(MouseEvent e) { super.mouseClicked(e); resetScanA(); } }); settingMenu.add(resetTcpMenu2); JMenuItem resetTcpMenu_1 = new JMenuItem("重新读码"); resetTcpMenu_1.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png"))); resetTcpMenu_1.setFont(new Font("微软雅黑", Font.PLAIN, 20)); resetTcpMenu_1.addMouseListener(new MouseAdapter() { @Override public void mousePressed(MouseEvent e) { super.mouseClicked(e); try { String sn = ""; boolean hgA = RobotUtil.getFeedingA(s7PLC); boolean hgB = RobotUtil.getFeedingB(s7PLC); if (!hgA && !hgB) { sn = ""; } if (hgA) { sn = RobotUtil.getProductSnA(s7PLC); }else if (hgB) { sn = RobotUtil.getProductSnB(s7PLC); }else { sn = RobotUtil.getProductSn(s7PLC); } log.info("工件码："+sn); if (sn == null || sn.trim().isEmpty() || "".equals(sn)) { setMenuStatus("扫码结果为空", -1); return; }else{ sn = sn.trim(); product_sn.setText(sn); String barcode36 = getBarcode(sn); Boolean checkQualityResult = DataUtil.checkQuality(MesClient.nettyClient, barcode36,MesClient.user20); if (!checkQualityResult){ setMenuStatus("消息发送失败，请重试",-1); } } } catch (Exception e2) { log.error("读取 PLC 工件码失败", e2); setMenuStatus("读取 PLC 失败", -1); } } }); settingMenu.add(resetTcpMenu_1); //允许上料 JMenuItem allow_up_material = new JMenuItem("允许上料"); allow_up_material.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png"))); allow_up_material.setFont(new Font("微软雅黑", Font.PLAIN, 20)); allow_up_material.addMouseListener(new MouseAdapter() { @Override public void mousePressed(MouseEvent e) { super.mouseClicked(e); // 弹框输入密码，如果输入的为”503833“即可允许上料 String input = JOptionPane.showInputDialog(null, "请输入密码"); if (!input.equalsIgnoreCase("503833")) { JOptionPane.showMessageDialog(mesClientFrame, "密码错误", "提示窗口", JOptionPane.INFORMATION_MESSAGE); return; } // 允许上料 MesClient.s7PLC.writeBoolean("DB503.0.2", true); } }); // settingMenu.add(allow_up_material); // 允许下料 JMenuItem allow_down_material = new JMenuItem("允许下料"); allow_down_material.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png"))); allow_down_material.setFont(new Font("微软雅黑", Font.PLAIN, 20)); allow_down_material.addMouseListener(new MouseAdapter() { @Override public void mousePressed(MouseEvent e) { super.mouseClicked(e); // 弹框输入密码，如果输入的为”503833“即可允许下料 String input = JOptionPane.showInputDialog(null, "请输入密码"); if (!input.equalsIgnoreCase("503833")) { JOptionPane.showMessageDialog(mesClientFrame, "密码错误", "提示窗口", JOptionPane.INFORMATION_MESSAGE); return; } MesClient.s7PLC.writeBoolean("DB503.0.5", true); } }); // settingMenu.add(allow_down_material); // 重置信号 JMenuItem reset_signal = new JMenuItem("重置信号"); reset_signal.setIcon(new ImageIcon(MesClient.class.getResource("/bg/reset_logo.png"))); reset_signal.setFont(new Font("微软雅黑", Font.PLAIN, 20)); reset_signal.addMouseListener(new MouseAdapter() { @Override public void mousePressed(MouseEvent e) { super.mouseClicked(e); // 弹框输入密码，如果输入的为”503833“即可允许下料 String input = JOptionPane.showInputDialog(null, "请输入密码"); if (!input.equalsIgnoreCase("503833")) { JOptionPane.showMessageDialog(mesClientFrame, "密码错误", "提示窗口", JOptionPane.INFORMATION_MESSAGE); return; } MesClient.s7PLC.writeBoolean("DB503.0.2", false); MesClient.s7PLC.writeBoolean("DB503.0.5", false); } }); // settingMenu.add(reset_signal); 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("状态："); equipment_statu_label.setHorizontalAlignment(SwingConstants.CENTER); equipment_statu_label.setForeground(Color.BLACK); equipment_statu_label.setFont(new Font("微软雅黑", 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("微软雅黑", 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("心跳："); heart_beat_status_label.setHorizontalAlignment(SwingConstants.CENTER); heart_beat_status_label.setForeground(Color.BLACK); heart_beat_status_label.setFont(new Font("微软雅黑", 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("微软雅黑", 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("登录用户："); user_status_label.setHorizontalAlignment(SwingConstants.CENTER); user_status_label.setForeground(Color.BLACK); user_status_label.setFont(new Font("微软雅黑", 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("微软雅黑", 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.setMinimumSize(new Dimension(400, 50)); tabbedPane.setFont(new Font("宋体", Font.BOLD, 22)); contentPane.add(tabbedPane); //首页 JPanel indexPanelA = new JPanel(); indexScrollPaneA = new JScrollPane(indexPanelA); indexPanelA.setLayout(null); //前方加入提示词 JLabel index_label = new JLabel("工件码："); index_label.setHorizontalAlignment(SwingConstants.CENTER); index_label.setForeground(Color.BLACK); index_label.setFont(new Font("微软雅黑", Font.PLAIN, 20)); index_label.setBounds(81, 10, 100, 50); indexPanelA.add(index_label); product_sn = new JTextField(); product_sn.setHorizontalAlignment(SwingConstants.CENTER); product_sn.setEditable(false); product_sn.setFont(new Font("微软雅黑", Font.PLAIN, 28)); product_sn.setBounds(81, 70, 602, 70); indexPanelA.add(product_sn); product_sn.setColumns(10); //冷板码提示词 JLabel index_label_LB = new JLabel("冷板码："); index_label_LB.setHorizontalAlignment(SwingConstants.CENTER); index_label_LB.setForeground(Color.BLACK); index_label_LB.setFont(new Font("微软雅黑", Font.PLAIN, 20)); index_label_LB.setBounds(81, 150, 100, 50); indexPanelA.add(index_label_LB); //下方增加一个绑定冷板的输入框 product_sn_LB = new JTextField(); product_sn_LB.setHorizontalAlignment(SwingConstants.CENTER); product_sn_LB.setEditable(false); product_sn_LB.setFont(new Font("微软雅黑", Font.PLAIN, 28)); product_sn_LB.setBounds(81, 200, 602, 70); indexPanelA.add(product_sn_LB); product_sn_LB.setColumns(10); f_scan_data_bt_1 = new JButton("扫码"); f_scan_data_bt_1.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { scan_type = 1; scanBarcode(); } }); f_scan_data_bt_1.setIcon(new ImageIcon(MesClient.class.getResource("/bg/scan_barcode.png"))); f_scan_data_bt_1.setFont(new Font("微软雅黑", Font.PLAIN, 32)); f_scan_data_bt_1.setBounds(693, 70, 198, 70); // 绑定冷板按钮 f_scan_data_bt_2 = new JButton("绑定"); f_scan_data_bt_2.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { scan_type = 2; scanBarcode2(); } }); f_scan_data_bt_2.setIcon(new ImageIcon(MesClient.class.getResource("/bg/scan_barcode.png"))); f_scan_data_bt_2.setFont(new Font("微软雅黑", Font.PLAIN, 32)); f_scan_data_bt_2.setBounds(693, 200, 198, 70); indexPanelA.add(f_scan_data_bt_2); // indexPanelA.add(f_scan_data_bt_1); // 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); fxlabel = new JLabel("该工件为返修件，请仔细检查"); fxlabel.setFont(new Font("微软雅黑", Font.PLAIN, 38)); fxlabel.setBounds(81, 170, 810, 70); fxlabel.setForeground(Color.RED); fxlabel.setHorizontalAlignment(SwingConstants.CENTER); fxlabel.setVisible(false); indexPanelA.add(fxlabel); finish_ok_bt = new JButton("OK"); finish_ok_bt.setEnabled(false); finish_ok_bt.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { if(work_status == 1 && check_quality_result){ String sn = getBarcode(product_sn.getText()); if(sn.isEmpty()){ MesClient.setMenuStatus("工件码为空，请重试",-1); return; } getUser(); String qret = "OK"; Boolean sendret = DataUtil.sendQuality(nettyClient,sn,qret,user20); if(!sendret){ MesClient.setMenuStatus("消息发送失败，请重试",-1); return; }else{ // MesClient.resetScanA(); // MesClient.scan_type = 1; // MesClient.scanBarcode(); // MesClient.setMenuStatus("结果提交成功，请扫下一件",0); } } } }); finish_ok_bt.setIcon(new ImageIcon(MesClient.class.getResource("/bg/ok_bg.png"))); finish_ok_bt.setFont(new Font("微软雅黑", Font.PLAIN, 32)); finish_ok_bt.setBounds(185, 291, 240, 80); finish_ok_bt.setEnabled(false); // indexPanelA.add(finish_ok_bt); finish_ng_bt = new JButton("NG"); finish_ng_bt.setEnabled(false); finish_ng_bt.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { if(work_status == 1 && check_quality_result){ String sn = getBarcode(product_sn.getText()); if(sn.isEmpty()){ MesClient.setMenuStatus("工件码为空，请重试",-1); return; } getUser(); String qret = "NG"; Boolean sendret = DataUtil.sendQuality(nettyClient,sn,qret,user20); if(!sendret){ MesClient.setMenuStatus("消息发送失败，请重试",-1); return; }else{ // MesClient.resetScanA(); // MesClient.scan_type = 1; // MesClient.scanBarcode(); // MesClient.setMenuStatus("结果提交成功，请扫下一件",0); } } } }); finish_ng_bt.setIcon(new ImageIcon(MesClient.class.getResource("/bg/ng_bg.png"))); finish_ng_bt.setFont(new Font("微软雅黑", Font.PLAIN, 32)); finish_ng_bt.setBounds(508, 291, 240, 80); finish_ng_bt.setEnabled(false); // indexPanelA.add(finish_ng_bt); imageGreen = new ImageIcon(MesClient.class.getResource("/bg/green_dot.png")); imageGreen.setImage(imageGreen.getImage().getScaledInstance(20, 20, Image.SCALE_SMOOTH)); imageGray = new ImageIcon(MesClient.class.getResource("/bg/grey_dot.png")); imageGray.setImage(imageGray.getImage().getScaledInstance(20, 20, Image.SCALE_SMOOTH)); feedingmeslabel = new JLabel("MES允许上料"); feedingmeslabel.setHorizontalAlignment(SwingConstants.LEFT); feedingmeslabel.setIcon(imageGreen); feedingmeslabel.setForeground(Color.BLACK); feedingmeslabel.setBounds(30, 440, 200, 30); feedingmeslabel.addMouseListener(new MouseAdapter() { public void mouseClicked(MouseEvent e) { // 弹框输入密码，如果输入的为”503833“即可允许上料 String input = JOptionPane.showInputDialog(null, "请输入密码"); if (!input.equalsIgnoreCase("503833")) { JOptionPane.showMessageDialog(mesClientFrame, "密码错误", "提示窗口", JOptionPane.INFORMATION_MESSAGE); return; } boolean ret = RobotUtil.getAllowFeeding(s7PLC); int choice = JOptionPane.showConfirmDialog(null, "确定修改MES允许上料结果为"+(ret?"false":"true")+"吗？", "操作确认", JOptionPane.YES_NO_OPTION, JOptionPane.QUESTION_MESSAGE); if (choice == JOptionPane.YES_OPTION) { RobotUtil.setAllowFeeding(s7PLC,!ret); } } }); indexPanelA.add(feedingmeslabel); blankingmeslabel = new JLabel("MES下料反馈"); blankingmeslabel.setHorizontalAlignment(SwingConstants.LEFT); blankingmeslabel.setIcon(imageGreen); blankingmeslabel.setForeground(Color.BLACK); blankingmeslabel.setBounds(240, 440, 200, 30); indexPanelA.add(blankingmeslabel); blankingmeslabel.addMouseListener(new MouseAdapter() { public void mouseClicked(MouseEvent e) { // 弹框输入密码，如果输入的为”503833“即可允许上料 String input = JOptionPane.showInputDialog(null, "请输入密码"); if (!input.equalsIgnoreCase("503833")) { JOptionPane.showMessageDialog(mesClientFrame, "密码错误", "提示窗口", JOptionPane.INFORMATION_MESSAGE); return; } boolean ret = RobotUtil.getAllowBlanking(s7PLC); int choice = JOptionPane.showConfirmDialog(null, "确定修改MES下料反馈结果为"+(ret?"false":"true")+"吗？", "操作确认", JOptionPane.YES_NO_OPTION, JOptionPane.QUESTION_MESSAGE); if (choice == JOptionPane.YES_OPTION) { RobotUtil.setAllowBlanking(s7PLC,!ret); } } }); feedinglabel = new JLabel("抓手A上料"); feedinglabel.setHorizontalAlignment(SwingConstants.LEFT); feedinglabel.setIcon(imageGreen); feedinglabel.setForeground(Color.BLACK); feedinglabel.setBounds(30, 480, 200, 30); indexPanelA.add(feedinglabel); feedinglabel2 = new JLabel("抓手B上料"); feedinglabel2.setHorizontalAlignment(SwingConstants.LEFT); feedinglabel2.setIcon(imageGreen); feedinglabel2.setForeground(Color.BLACK); feedinglabel2.setBounds(240, 480, 200, 30); indexPanelA.add(feedinglabel2); runlabel = new JLabel("上料完成"); runlabel.setHorizontalAlignment(SwingConstants.LEFT); runlabel.setIcon(imageGreen); runlabel.setForeground(Color.BLACK); runlabel.setBounds(450, 480, 200, 30); indexPanelA.add(runlabel); blankinglabel = new JLabel("加工完成"); blankinglabel.setHorizontalAlignment(SwingConstants.LEFT); blankinglabel.setIcon(imageGreen); blankinglabel.setForeground(Color.BLACK); blankinglabel.setBounds(660, 480, 200, 30); indexPanelA.add(blankinglabel); tabbedPane.addTab("工作面板", new ImageIcon(MesClient.class.getResource("/bg/a_side.png")), indexScrollPaneA, null); tabbedPane.setEnabledAt(0, true); // searchScrollPane = new JScrollPane((Component) null); indexPanelC = new JPanel(); searchScrollPaneDj = new JScrollPane(indexPanelC); indexPanelC.setLayout(null); tabbedPane.addTab("开班点检", new ImageIcon(MesClient.class.getResource("/bg/menu_data_preprocess.png")), searchScrollPaneDj, 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); indexPanelE = new JPanel(); searchScrollPaneC = new JScrollPane(indexPanelE); indexPanelE.setLayout(null); tabbedPane.addTab("胶水寿命", new ImageIcon(MesClient.class.getResource("/bg/menu_data_preprocess.png")), searchScrollPaneC, null); 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){ } } }); } //页面菜单状态 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); } public static void getMaterailData(){ try{ JSONObject retObj = DataUtil.getBindMaterail(); if(retObj.get("result")!=null&&retObj.get("result").toString().equalsIgnoreCase("true")) { java.util.List arrs = retObj.getList("data",BindMaterialResp.class); int i = 0; rowData = new Object[arrs.size()][7]; for (BindMaterialResp bindMaterialResp:arrs){ rowData[i][0] = bindMaterialResp.getMaterialTitle(); rowData[i][1] = bindMaterialResp.getBatchSn(); rowData[i][2] = bindMaterialResp.getLastTimes(); rowData[i][3] = ""; rowData[i][4] = bindMaterialResp.getCraft(); rowData[i][5] = bindMaterialResp.getMaterialId(); rowData[i][6] = bindMaterialResp.getType(); i++; } bindBatchPanel(); } }catch (Exception e){ log.info(e.getMessage()); } } public static void updateMaterailData(){ try{ JSONObject retObj = DataUtil.getBindMaterail(); if(retObj.get("result")!=null&&retObj.get("result").toString().equalsIgnoreCase("true")) { List arrs = retObj.getList("data",BindMaterialResp.class); int i = 0; for (BindMaterialResp bindMaterialResp:arrs){ rowData[i][0] = bindMaterialResp.getMaterialTitle(); rowData[i][1] = bindMaterialResp.getBatchSn(); rowData[i][2] = bindMaterialResp.getLastTimes(); rowData[i][3] = ""; rowData[i][4] = bindMaterialResp.getCraft(); rowData[i][5] = bindMaterialResp.getMaterialId(); rowData[i][6] = bindMaterialResp.getType(); i++; } MesClient.table.repaint(); } }catch (Exception e){ log.info(e.getMessage()); } } // 绑定物料批次码 public static void scanBatchSn(BindMaterialResp bindMaterialResp) { //弹窗扫工件码 String scanBarcodeTitle = "请扫物料:"+bindMaterialResp.getMaterialTitle(); String scanBarcode = JOptionPane.showInputDialog(null, scanBarcodeTitle); if(scanBarcode!=null&&!scanBarcode.equalsIgnoreCase("")) { JSONObject retObj = DataUtil.saveBindMaterail(scanBarcode,bindMaterialResp.getCraft(),bindMaterialResp.getMaterialId(),bindMaterialResp.getType()); if(retObj.get("result")!=null&&retObj.get("result").toString().equalsIgnoreCase("true")) { MesClient.setMenuStatus("扫物料:"+bindMaterialResp.getMaterialTitle()+"成功",0); updateMaterailData(); }else{ if(retObj.get("result")==null){ MesClient.setMenuStatus("请求失败，请重试",-1); }else{ if(retObj.get("result").toString().equalsIgnoreCase("false")){ MesClient.setMenuStatus(retObj.getString("message"),-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); JScrollPane 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(){ // 创建异步线程池 ExecutorService executorService = Executors.newSingleThreadExecutor(); // 提交任务 executorService.submit(() -> { log.info("异步任务执行中..."); // 模拟耗时操作 try { while (true){ try { // 确保连接已经打开 if (JdbcUtils.conn == null || JdbcUtils.conn.isClosed()) { JdbcUtils.openConnection(); } 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"; log.info("质量："+bw); String s = HttpUtils.sendPostRequestJson(url, bw ); log.info("结果："+s); Boolean result = JSONObject.parseObject(s).getBoolean("result"); if(result) { // 更改状态为 1 statement.executeUpdate(updateSql + id); } } rs.close(); statement.close(); } catch (Exception e) { log.info(e.getMessage()); } try { Thread.sleep(2000); }catch (Exception e){ log.info(e.getMessage()); } } } catch (Exception e) { log.info(e.getMessage()); } log.info("异步任务执行完毕"); }); } // plc交互定时任务 public static java.util.Timer plcTimer; // 程序逻辑流程：0：等待扫码信号 public static Integer index = 0; public static void startPlcTimer(){ if (plcTimer != null){ plcTimer.cancel(); plcTimer = null; } plcTimer = new java.util.Timer(); plcTimer.schedule(new TimerTask() { @Override public void run() { if(!MesClient.sessionid.isEmpty()) { // 必须先登录 Boolean feedingRetA = RobotUtil.getFeedingA(s7PLC); Boolean feedingRetB = RobotUtil.getFeedingB(s7PLC); Boolean feedingFinish = RobotUtil.getFeedingFinish(s7PLC); Boolean workFinish = RobotUtil.getWorkFinish(s7PLC); Boolean allowFeeding = RobotUtil.getAllowFeeding(s7PLC); Boolean allowBlanking = RobotUtil.getAllowBlanking(s7PLC); feedinglabel.setIcon(feedingRetA ? imageGreen : imageGray); feedinglabel2.setIcon(feedingRetB ? imageGreen : imageGray); runlabel.setIcon(feedingFinish ? imageGreen : imageGray); blankinglabel.setIcon(workFinish ? imageGreen : imageGray); feedingmeslabel.setIcon(allowFeeding ? imageGreen : imageGray); blankingmeslabel.setIcon(allowBlanking ? imageGreen : imageGray); log.info("index:"+index); log.info("feedingRetA:"+feedingRetA); log.info("feedingRetB:"+feedingRetB); log.info("feedingFinish:"+feedingFinish); log.info("workFinish:"+workFinish); log.info("allowFeeding:"+allowFeeding); log.info("allowBlanking:"+allowBlanking); if (index == 0){ if(allowFeeding){ RobotUtil.setAllowFeeding(s7PLC, false); } if(workFinish){ RobotUtil.setAllowBlanking(s7PLC,true); }else{ RobotUtil.setAllowBlanking(s7PLC,false); } if(feedingRetA || feedingRetB){ String sn = ""; if(feedingRetA){ sn = RobotUtil.getProductSnA(s7PLC); } if(feedingRetB){ sn = RobotUtil.getProductSnB(s7PLC); } if (sn == null || sn.trim().isEmpty() || "".equals(sn)) { setMenuStatus("读码结果为空", -1); return; }else{ product_sn.setText(sn); String barcode36 = getBarcode(sn); Boolean checkQualityResult = DataUtil.checkQuality(MesClient.nettyClient, barcode36,MesClient.user20); if (!checkQualityResult){ setMenuStatus("消息发送失败，请重试",-1); } } }else{ setMenuStatus("等待上料信号",0); } }else if(index == 1){ if(feedingFinish || workFinish || feedingRetA || feedingRetB){ setMenuStatus("上料完成，开始加工",0); index = 2; RobotUtil.setAllowFeeding(s7PLC, false); }else{ RobotUtil.setAllowFeeding(s7PLC, true); } }else if(index == 2){ if(workFinish || feedingRetA || feedingRetB){ // 提交结果 // 冷板为空不允许提交 if (!bind_lb_result){ setMenuStatus("请先绑定冷板", -1); return; } Boolean reg = DataUtil.sendQuality(MesClient.nettyClient, MesClient.product_sn.getText(), "OK",MesClient.user20); if (!reg){ setMenuStatus("报文发送异常", -1); return; } } } } } }, 0, 2500); } }