//package com.beanit.test;
|
//
|
//import com.alibaba.fastjson.JSON;
|
//import com.beanit.openiec61850.*;
|
//import com.beanit.rabbitmq.Producer;
|
//import com.beanit.socket.Client;
|
//import com.beanit.test.utils.*;
|
//import com.beanit.test.view.MyTableRenderer;
|
//import org.slf4j.Logger;
|
//import org.slf4j.LoggerFactory;
|
//import sun.misc.BASE64Encoder;
|
//
|
//import javax.swing.*;
|
//import javax.swing.event.TableModelEvent;
|
//import javax.swing.event.TableModelListener;
|
//import javax.swing.table.DefaultTableModel;
|
//import java.awt.*;
|
//import java.awt.event.ActionEvent;
|
//import java.awt.event.ActionListener;
|
//import java.awt.event.WindowAdapter;
|
//import java.awt.event.WindowEvent;
|
//import java.io.IOException;
|
//import java.net.InetAddress;
|
//import java.net.UnknownHostException;
|
//import java.util.*;
|
//import java.util.List;
|
//import java.util.Timer;
|
////电科院送检测试类
|
///**
|
// * @author LiBiChao
|
// * @create 2019-08-06
|
// * @update 2020-10-20
|
// */
|
//public class MyClient {
|
//
|
// private static final Logger logger = LoggerFactory.getLogger(MyClient.class);
|
//
|
// private Producer producer;
|
//
|
// private JTable mainTable;
|
// private DefaultTableModel tableModel;
|
// private String[] columnTitles = { "变电站", "IP地址", "端口", "上次采集时间"};
|
// private JScrollPane jsPane;
|
// private Thread threads[];
|
// private Timer timers[];
|
// private Timer monitorTimer;
|
// private Timer wakeUpTimer;
|
// private Timer networkReviewTimer;
|
// private JLabel labelTips;
|
// private JTextField txtCollectDelay;
|
// private JTextField txtSubstationDelay;
|
// private JTextField txtSubstationList;
|
// private JRadioButton radioCollectData = new JRadioButton("是");
|
// private JRadioButton radioNotCollectData = new JRadioButton("否");
|
// private JRadioButton radioCollectFile = new JRadioButton("是");
|
// private JRadioButton radioNotCollectFile = new JRadioButton("否");
|
// private JRadioButton radioDeleteRemote = new JRadioButton("是");
|
// private JRadioButton radioNotDeleteRemote = new JRadioButton("否");
|
// private boolean isCollectRemoteData = true;
|
// private boolean isCollectRemoteFile = false;
|
// private boolean isDeleteRemoteFile = false;
|
// private static int CollectIntervalTimes = 1000 * 60 * 60 * 2; //同一站点采集两个小时
|
// private static int SubstaionIntervalTimes = 1000 * 60 * 3; //站点间采集间隔3分钟
|
// private JButton btnSetting;
|
// private JButton btnStart;
|
// private JButton btnDetail;
|
// private boolean isRunning = false;
|
//
|
// private static String sendMessageMethod = "mq"; //可选mq和areaIII
|
// private static Client client;
|
//
|
// public void ClientMain(){
|
//
|
// logger.debug("ClientMain init...");
|
//
|
// JFrame frm = new JFrame();
|
// frm.setLocation(100, 100);
|
// frm.setSize(680, 610);
|
// //frm.setBounds(100, 100, 300, 300); // 功能与上面相同
|
// frm.setTitle("云南电网变电在线监测采集系统 -【二区主站】");
|
// Container c = frm.getContentPane(); // frm中包含一个内容窗格， 需要获取内容窗格，再设置背景颜色，直接设置frm的背景颜色会被内容窗格挡住
|
// c.setBackground(new Color(230, 230, 230));
|
// frm.setLayout(null); // 如过不设置为null默认，按钮会充满整个内容框，挡住背景颜色
|
//
|
// //配置信息-采集间隔
|
// JLabel labelCollect = new JLabel("采集间隔：");
|
// labelCollect.setLocation(50, 10);
|
// labelCollect.setSize(70, 25);
|
// frm.add(labelCollect);
|
// txtCollectDelay = new JTextField();
|
// txtCollectDelay.setLocation(120, 10);
|
// txtCollectDelay.setSize(50, 25);
|
// txtCollectDelay.setText("120");
|
// txtCollectDelay.setEditable(false);
|
// frm.add(txtCollectDelay);
|
// JLabel collectUnit = new JLabel("分钟");
|
// collectUnit.setLocation(170, 10);
|
// collectUnit.setSize(80, 25);
|
// frm.add(collectUnit);
|
// //配置信息-站点间隔
|
// JLabel labelSubstation = new JLabel("站点间隔：");
|
// labelSubstation.setLocation(220, 10);
|
// labelSubstation.setSize(70, 25);
|
// frm.add(labelSubstation);
|
// txtSubstationDelay = new JTextField();
|
// txtSubstationDelay.setLocation(290, 10);
|
// txtSubstationDelay.setSize(50, 25);
|
// txtSubstationDelay.setText("5");
|
// txtSubstationDelay.setEditable(false);
|
// frm.add(txtSubstationDelay);
|
// JLabel substationUnit = new JLabel("分钟");
|
// substationUnit.setLocation(340, 10);
|
// substationUnit.setSize(80, 25);
|
// frm.add(substationUnit);
|
// //配置信息-采集列表
|
// JLabel labelSubstationList = new JLabel("列表配置：");
|
// labelSubstationList.setLocation(390, 10);
|
// labelSubstationList.setSize(70, 25);
|
// frm.add(labelSubstationList);
|
// txtSubstationList = new JTextField();
|
// txtSubstationList.setLocation(460, 10);
|
// txtSubstationList.setSize(120, 25);
|
// txtSubstationList.setText("substation_list.txt");
|
// txtSubstationList.setEditable(false);
|
// frm.add(txtSubstationList);
|
// //配置信息-采集数据
|
// JLabel labelCollectData = new JLabel("采集数据：");
|
// labelCollectData.setLocation(50, 40);
|
// labelCollectData.setSize(70, 25);
|
// frm.add(labelCollectData);
|
// ButtonGroup collectDataBtnGroup = new ButtonGroup();
|
// collectDataBtnGroup.add(radioCollectData);
|
// radioCollectData.setLocation(120, 40);
|
// radioCollectData.setSize(40, 25);
|
// radioCollectData.setSelected(true);
|
// radioCollectData.setEnabled(false);
|
// frm.add(radioCollectData);
|
// collectDataBtnGroup.add(radioNotCollectData);
|
// radioNotCollectData.setLocation(160, 40);
|
// radioNotCollectData.setSize(40, 25);
|
// radioNotCollectData.setEnabled(false);
|
// frm.add(radioNotCollectData);
|
// //配置信息-采集文件
|
// JLabel labelCollectFile = new JLabel("采集谱图：");
|
// labelCollectFile.setLocation(220, 40);
|
// labelCollectFile.setSize(70, 25);
|
// frm.add(labelCollectFile);
|
// ButtonGroup collectFileBtnGroup = new ButtonGroup();
|
// collectFileBtnGroup.add(radioCollectFile);
|
// radioCollectFile.setLocation(290, 40);
|
// radioCollectFile.setSize(40, 25);
|
// radioCollectFile.setEnabled(false);
|
// frm.add(radioCollectFile);
|
// collectFileBtnGroup.add(radioNotCollectFile);
|
// radioNotCollectFile.setLocation(330, 40);
|
// radioNotCollectFile.setSize(40, 25);
|
// radioNotCollectFile.setSelected(true);
|
// radioNotCollectFile.setEnabled(false);
|
// frm.add(radioNotCollectFile);
|
// //配置信息-删除远端文件
|
// JLabel labelDeleteRemote = new JLabel("采完删除：");
|
// labelDeleteRemote.setLocation(390, 40);
|
// labelDeleteRemote.setSize(70, 25);
|
// frm.add(labelDeleteRemote);
|
// ButtonGroup deleteBtnGroup = new ButtonGroup();
|
// deleteBtnGroup.add(radioDeleteRemote);
|
// radioDeleteRemote.setLocation(460, 40);
|
// radioDeleteRemote.setSize(40, 25);
|
// radioDeleteRemote.setEnabled(false);
|
// frm.add(radioDeleteRemote);
|
// deleteBtnGroup.add(radioNotDeleteRemote);
|
// radioNotDeleteRemote.setLocation(500, 40);
|
// radioNotDeleteRemote.setSize(40, 25);
|
// radioNotDeleteRemote.setSelected(true);
|
// radioNotDeleteRemote.setEnabled(false);
|
// frm.add(radioNotDeleteRemote);
|
//
|
// //配置按钮
|
// btnSetting = new JButton("配置");
|
// btnSetting.setLocation(550, 80);
|
// btnSetting.setSize(90, 30);
|
// btnSetting.setBackground(new Color(224, 234, 244));
|
// btnSetting.addActionListener(new ActionListener() {
|
// @Override
|
// public void actionPerformed(ActionEvent e) {
|
// //logger.debug(e.getActionCommand());
|
// if(isRunning){
|
// //logger.debug("请先停止采集再进行配置！#_#");
|
// labelTips("请先停止采集再进行配置！", "warning");
|
// return;
|
// }
|
// if(txtCollectDelay.isEditable()){
|
// int intCollectIntervalMinute = Integer.valueOf(txtCollectDelay.getText());
|
// CollectIntervalTimes = intCollectIntervalMinute * 60 * 1000;
|
// int intSubstationIntervalMinute = Integer.valueOf(txtSubstationDelay.getText());
|
// SubstaionIntervalTimes = intSubstationIntervalMinute * 60 * 1000;
|
// if(radioCollectData.isSelected()){
|
// isCollectRemoteData = true;
|
// }else {
|
// isCollectRemoteData = false;
|
// }
|
// if(radioCollectFile.isSelected()){
|
// isCollectRemoteFile = true;
|
// }else {
|
// isCollectRemoteFile = false;
|
// }
|
// if(radioDeleteRemote.isSelected()){
|
// isDeleteRemoteFile = true;
|
// }else{
|
// isDeleteRemoteFile = false;
|
// }
|
// txtCollectDelay.setEditable(false);
|
// txtSubstationDelay.setEditable(false);
|
// txtSubstationList.setEditable(false);
|
// radioCollectData.setEnabled(false);
|
// radioNotCollectData.setEnabled(false);
|
// radioCollectFile.setEnabled(false);
|
// radioNotCollectFile.setEnabled(false);
|
// radioDeleteRemote.setEnabled(false);
|
// radioNotDeleteRemote.setEnabled(false);
|
// //重新加载站点列表
|
// dataLoad();
|
// btnSetting.setText("配置");
|
// labelTips("配置保存成功！", "");
|
// }else {
|
// txtCollectDelay.setEditable(true);
|
// txtSubstationDelay.setEditable(true);
|
// txtSubstationList.setEditable(true);
|
// radioCollectData.setEnabled(true);
|
// radioNotCollectData.setEnabled(true);
|
// radioCollectFile.setEnabled(true);
|
// radioNotCollectFile.setEnabled(true);
|
// radioDeleteRemote.setEnabled(true);
|
// radioNotDeleteRemote.setEnabled(true);
|
// btnSetting.setText("保存");
|
// txtCollectDelay.requestFocus();
|
// labelTips("编辑配置...", "");
|
// }
|
// }
|
// });
|
// frm.add(btnSetting);
|
// //采集详情
|
// btnDetail = new JButton("采集详情");
|
// btnDetail.setLocation(150, 80);
|
// btnDetail.setSize(90, 30);
|
// btnDetail.setBackground(new Color(224, 234, 244));
|
// btnDetail.addActionListener(new ActionListener() {
|
// @Override
|
// public void actionPerformed(ActionEvent e) {
|
// logger.debug(e.getActionCommand());
|
// int rowIndex = mainTable.getSelectedRow();
|
// if(rowIndex < 0){
|
// //logger.debug("未选择站点！#_#");
|
// labelTips("未选择站点！", "warning");
|
// return;
|
// }
|
// MyClientGui myClientGui = new MyClientGui();
|
// myClientGui.setIpTextField(tableModel.getValueAt(rowIndex, 1).toString());
|
// myClientGui.setPortTextField(tableModel.getValueAt(rowIndex, 2).toString());
|
// //myClientGui.dispose();
|
// }
|
// });
|
// frm.add(btnDetail);
|
//
|
// //确定按钮
|
// btnStart = new JButton("开始采集");
|
// btnStart.setLocation(50, 80);
|
// btnStart.setSize(90, 30);
|
// btnStart.setBackground(new Color(224, 234, 244));
|
// btnStart.addActionListener(new ActionListener() {
|
// @Override
|
// public void actionPerformed(ActionEvent e) {
|
// if(tableModel.getRowCount() <= 0){
|
// //logger.warn("采集列表为空！");
|
// labelTips("采集列表为空！", "warning");
|
// return;
|
// }
|
// if(txtCollectDelay.isEditable()){
|
// //logger.warn("请先保存配置！");
|
// labelTips("请先保存配置！", "warning");
|
// return;
|
// }
|
//
|
// if (ConfigUtil.isNetworkReview){
|
// if (!isRunning) {
|
// startNetworkReview();
|
// isRunning = true;
|
// btnStart.setText("停止检查");
|
// }else{
|
// networkReviewTimer.cancel();
|
// isRunning = false;
|
// btnStart.setText("开始检查");
|
// }
|
// return;
|
// }
|
//
|
// if(!isRunning) {
|
// //启动状态监视器
|
// monitorSchedule();
|
// //重连定时器
|
// wakeUpSchedule();
|
// isRunning = true;
|
// btnStart.setText("停止采集");
|
// collectStart();
|
// }else{
|
// collectStop();
|
// //停止监视器
|
// monitorTimer.cancel();
|
// logger.debug("状态监视器已停止。");
|
// //停止重连器
|
// wakeUpTimer.cancel();
|
// logger.debug("重连定时器已停止。");
|
// isRunning = false;
|
// btnStart.setText("开始采集");
|
// }
|
// }
|
// });
|
// frm.add(btnStart);
|
// //站点增加按钮
|
// JButton btnAddRow = new JButton("增加站点");
|
// btnAddRow.setLocation(250, 80);
|
// btnAddRow.setSize(90, 30);
|
// btnAddRow.setBackground(new Color(224, 234, 244));
|
// btnAddRow.addActionListener(new ActionListener() {
|
// @Override
|
// public void actionPerformed(ActionEvent e) {
|
// if(isRunning){
|
// logger.warn("采集中不能增加站点！");
|
// return;
|
// }
|
// //tableModel.setRowCount(tableModel.getDataVector().size() + 1);
|
// tableModel.setRowCount(tableModel.getRowCount() + 1);
|
// tableModel.setValueAt("null", tableModel.getRowCount() - 1, 0);
|
// mainTable.changeSelection(tableModel.getRowCount() - 1, 0, true, false);
|
// }
|
// });
|
// frm.add(btnAddRow);
|
//
|
// //删除增加按钮
|
// JButton btnDelRow = new JButton("删除站点");
|
// btnDelRow.setLocation(350, 80);
|
// btnDelRow.setSize(90, 30);
|
// btnDelRow.setBackground(new Color(224, 234, 244));
|
// btnDelRow.addActionListener(new ActionListener() {
|
// @Override
|
// public void actionPerformed(ActionEvent e) {
|
// if(isRunning){
|
// logger.warn("采集中不能删除站点！");
|
// labelTips("采集中不能删除站点！", "warning");
|
// return;
|
// }
|
// int rowIndex = mainTable.getSelectedRow();
|
// if(rowIndex < 0){
|
// logger.debug("未选择站点！#_#");
|
// labelTips("未选择站点#_#！", "warning");
|
// return;
|
// }
|
// boolean flag = ConfigUtil.delSubstation(txtSubstationList.getText(), rowIndex);
|
// if (flag) {
|
// tableModel.removeRow(rowIndex);
|
// }
|
// logger.debug("--------------- 删除：" + flag + "--------------------");
|
// }
|
// });
|
// frm.add(btnDelRow);
|
//
|
// //JTable
|
// tableModel = new DefaultTableModel(columnTitles, 0);
|
// tableModel.addTableModelListener(new TableModelListener() {
|
// @Override
|
// public void tableChanged(TableModelEvent e) {
|
//
|
// if(e.getType() == TableModelEvent.UPDATE){
|
// if(e.getLastRow() >= 0){
|
// int rowIndex = e.getLastRow();
|
// int colIndex = e.getColumn();
|
// String strValue = tableModel.getValueAt(rowIndex, colIndex).toString();
|
// //System.out.println(" setSubstationValue: [" + rowIndex + ", " + colIndex + "]=>" + strValue);
|
// boolean flag = ConfigUtil.setSubstationValue(txtSubstationList.getText(), rowIndex, colIndex, strValue);
|
// //System.out.println(flag + " setSubstationValue: [" + rowIndex + ", " + colIndex + "]=>" + strValue);
|
// }
|
// }
|
// }
|
// });
|
//
|
// mainTable = new JTable(tableModel);
|
// //mainTable.getColumnModel().getColumn(1).setCellEditor(new MyRender());//设置编辑器
|
// //mainTable.getColumnModel().getColumn(1).setCellRenderer(new MyRender() );
|
// jsPane = new JScrollPane(mainTable);
|
// jsPane.setSize(600, 400);
|
// jsPane.setLocation(30, 130);
|
// frm.add(jsPane);
|
// mainTable.setDefaultRenderer(Object.class, new MyTableRenderer());
|
//
|
// //底部提示信息
|
// JLabel labelTipsTitle = new JLabel("提示信息：");
|
// labelTipsTitle.setLocation(50, 530);
|
// labelTipsTitle.setSize(70, 25);
|
// frm.add(labelTipsTitle);
|
// labelTips = new JLabel("welcome！");
|
// labelTips.setLocation(120, 530);
|
// labelTips.setSize(500, 25);
|
// frm.add(labelTips);
|
//
|
// dataLoad();
|
//
|
// //frm.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
|
// frm.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
|
// frm.addWindowListener(new WindowAdapter() {
|
// @Override
|
// public void windowClosing(WindowEvent e) {
|
// super.windowClosing(e);
|
// int result = JOptionPane.showConfirmDialog(null, "确认退出?", "确认",JOptionPane.OK_CANCEL_OPTION,JOptionPane.INFORMATION_MESSAGE);
|
// if (result == JOptionPane.OK_OPTION) {
|
// // 退出
|
// System.exit(0);
|
// }
|
// }
|
// });
|
//
|
// if (ConfigUtil.isNetworkReview){
|
// btnStart.setText("开始检查");
|
// btnAddRow.setEnabled(false);
|
// btnDelRow.setEnabled(false);
|
// btnDetail.setEnabled(false);
|
// btnSetting.setEnabled(false);
|
// }
|
//
|
// frm.setVisible(true);
|
//
|
// // 三区服务连接
|
// //client = new Client();
|
// //client.init();
|
// //client.conn();
|
//
|
//
|
// //初始化消息队列
|
// if(ConfigUtil.isDebug){
|
// return;
|
// }
|
// try {
|
// producer = new Producer("ztjc");
|
// logger.debug("消息队列初始化完成！^_^");
|
// } catch (IOException e) {
|
// System.out.println("消息队列初始化失败！@_@");
|
// e.printStackTrace();
|
// }
|
// }
|
//
|
// /**
|
// * 状态监视器
|
// */
|
// private void monitorSchedule(){
|
// monitorTimer = new Timer();
|
// monitorTimer.schedule(new TimerTask() {
|
// @Override
|
// public void run() {
|
// //刷新mainTabled的数据状态，可发送心跳
|
// //System.out.print("*");
|
// int rowIndex = mainTable.getSelectedRow();
|
// int colIndex = mainTable.getSelectedColumn();
|
// //logger.debug(rowIndex + " - " + colIndex);
|
// mainTable.changeSelection(rowIndex, colIndex, true, false);
|
// mainTable.changeSelection(rowIndex, colIndex, true, false);
|
// }
|
// }, 1000, 3000);
|
// logger.debug("状态监视器已启动。");
|
// }
|
//
|
// /**
|
// * 定时唤醒任务
|
// */
|
// private void wakeUpSchedule(){
|
// wakeUpTimer = new Timer();
|
// int substationCount = mainTable.getRowCount();
|
// long startTime = substationCount * SubstaionIntervalTimes;
|
// wakeUpTimer.schedule(new TimerTask() {
|
// @Override
|
// public void run() {
|
// logger.debug("重连定时器开始执行...");
|
// for (int i = 0; i < substationCount; i++){
|
// String name = tableModel.getValueAt(i,0).toString();
|
// String ip = tableModel.getValueAt(i,1).toString();
|
// int port = Integer.valueOf(tableModel.getValueAt(i,2).toString());
|
// String lastTime = tableModel.getValueAt(i,3).toString();
|
// if(lastTime != null && lastTime.length() == 19){
|
// long millisTime = SimpleUtils.DateTimeToMillisTime(lastTime);
|
// if((System.currentTimeMillis() - 3 * 60 * 60 * 1000) > millisTime){
|
// logger.debug("重连定时器【" + (i + 1) + " - " + name + "】 开始连接至变电站 => " + ip + ":" + port
|
// + " [" + SimpleUtils.CurrentDateTime() + "]");
|
// collectToSubstation(ip, port, i);
|
// }else{
|
// continue;
|
// }
|
// }else{
|
// logger.debug("重连定时器【" + (i + 1) + " - " + name + "】 开始连接至变电站 => " + ip + ":" + port
|
// + " [" + SimpleUtils.CurrentDateTime() + "]");
|
// collectToSubstation(ip, port, i);
|
// }
|
// }
|
// }
|
// }, startTime, 5 * 60 * 1000);
|
// logger.debug("重连定时器" + Math.floor((startTime/60)/1000) + "分钟后启动。");
|
// }
|
//
|
// protected void collectToSubstation(String ip, int port, int rowIndex){
|
// String subStationName = mainTable.getValueAt(rowIndex, 0).toString();
|
// ClientSap clientSap = new ClientSap();
|
// //clientSap.setMaxMmsPduSize(6500000);
|
// //logger.debug("MaxMmsPduSize: " + clientSap.getMaxMmsPduSize());
|
// InetAddress address;
|
// try {
|
// address = InetAddress.getByName(ip);
|
// } catch (UnknownHostException e1) {
|
// logger.error("【" + subStationName + "】 IP地址错误: " + "ip Address ERROR" );
|
// labelTips("【" + subStationName + "】 IP地址错误！", "error");
|
// e1.printStackTrace();
|
// return;
|
// }
|
// try {
|
// if (port < 1 || port > 0xFFFF) {
|
// throw new NumberFormatException("端口超出范围: " + "port must be in range [1, 65535]");
|
// }
|
// } catch (NumberFormatException e) {
|
// logger.error("【" + subStationName + "】 端口异常: " + "port ERROR");
|
// labelTips("【" + subStationName + "】 端口异常！", "error");
|
// e.printStackTrace();
|
// return;
|
// }
|
//
|
// //clientSap.setTSelLocal(settingsFrame.getTselLocal());
|
// //clientSap.setTSelRemote(settingsFrame.getTselRemote());
|
//
|
// ClientAssociation association;
|
// try {
|
// association = clientSap.associate(address, port, null, null);
|
// } catch (IOException e) {
|
// logger.debug("【" + subStationName + "】 连接失败: " + e.getMessage());
|
// labelTips("【" + subStationName + "】 连接失败！", "error");
|
//// if(ConfigUtil.isNetworkReview) {
|
//// checkNet(ip, port);
|
//// }
|
// sendErrorLog(subStationName, ip, e.getMessage());
|
// checkNet(subStationName, ip, port);
|
// return;
|
// }
|
//
|
// //数据读取
|
// if(isCollectRemoteData) {
|
// boolean flag = readData(association, ip, subStationName);
|
// if(flag){
|
// String strDate = SimpleUtils.CurrentDateTime();
|
// tableModel.setValueAt(strDate, rowIndex, 3);
|
// boolean flag2 = ConfigUtil.setSubstationValue(txtSubstationList.getText(), rowIndex, 3, strDate);
|
// logger.debug("【" + subStationName + "】 本次采集任务完成！");
|
// labelTips("【" + subStationName + "】 完成一次采集任务！", "");
|
// }else{
|
// logger.debug("【" + subStationName + "】 本次采集任务结束，但存在异常*_*！");
|
// labelTips("【" + subStationName + "】 采集任务结束，存在异常！", "error");
|
// checkNet(subStationName, ip, port);
|
// }
|
// }
|
//
|
// if(!isCollectRemoteFile){
|
// association.disconnect();
|
// association.close();
|
// //logger.debug(association.isOpen() + "");
|
// return;
|
// }
|
// //文件读取
|
// String dirName = "";
|
// List fileList = null;
|
// try {
|
// fileList = association.getFileDirectory(dirName);
|
// } catch (ServiceError serviceError) {
|
// serviceError.printStackTrace();
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// }
|
// for(int i = 0; i < fileList.size(); i++){
|
// FileInformation remoteFile = (FileInformation)fileList.get(i);
|
// String fileName = remoteFile.getFilename();
|
// if(fileName.contains("COMTRADE")){
|
// dirName = fileName;
|
// try {
|
// fileList = association.getFileDirectory(dirName);
|
// } catch (ServiceError serviceError) {
|
// serviceError.printStackTrace();
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// }
|
// break;
|
// }
|
// }
|
// if(fileList == null){
|
// logger.debug("【" + subStationName + "】 远程文件目录读取失败");
|
// labelTips("【" + subStationName + "】 远程文件目录读取失败！", "error");
|
// }
|
// //定义文件临时存储目录
|
// final String tempSavePath = "temp/tempSavePath/" + ip;
|
// FileOption.creatDir(tempSavePath); //创建目录
|
// //定义文件采集日志目录
|
// final String tempLogFile = "log.txt";
|
// String lastLog = FileOption.readFileLastLine(tempSavePath, tempLogFile);
|
// if(!FileOption.fileExist(tempSavePath + "/" + tempLogFile)){
|
// FileOption.createFile(tempSavePath, tempLogFile); //创建文件
|
// lastLog = "[sendCount:0, deleteCount:0]-Time " + "2019-09-01 00:00:00";
|
// FileOption.writeFile(lastLog, tempSavePath, tempLogFile);
|
// }
|
// logger.debug("【" + subStationName + "】 读取上次谱图采集日志: " + lastLog);
|
// logger.debug("【" + subStationName + "】 读取远程文件数量: " + fileList.size());
|
// labelTips("【" + subStationName + "】 读取远程文件数量: " + fileList.size(), "");
|
// int sendCount = 0;
|
// List<String> deleteList = new ArrayList();
|
// for(int i = 0; i < fileList.size(); i++){
|
// //if(i > 2) continue;
|
// //限制单次采集不超过5000个文件
|
// if(sendCount >= 5000){
|
// continue;
|
// }
|
// sendCount ++;
|
// FileInformation remoteFile = (FileInformation)fileList.get(i);
|
//// long fileMillisTime = remoteFile.getLastModified().getTimeInMillis();
|
//// //文件时间小于上次采集的时间则忽略
|
//// if(fileMillisTime < startDate){
|
//// continue;
|
//// }
|
// final String fileName = remoteFile.getFilename();
|
// //清理已存在的临时文件
|
// FileOption.deleteFile(tempSavePath, fileName);
|
// logger.debug("\n开始采集文件：" + System.currentTimeMillis() + " => file-" + (i + 1) + ": " + fileName
|
// + " Size: " + remoteFile.getFileSize());
|
// try {
|
// association.getFile(fileName, new GetFileListener() {
|
// @Override
|
// public boolean dataReceived(byte[] fileData, boolean moreFollows) {
|
// //logger.debug("开始写入临时文件前时间：" + System.currentTimeMillis());
|
// boolean isSaved = FileOption.writeBinaryFile(tempSavePath, fileName, fileData, true);
|
// //logger.debug("完成写入临时文件后时间：" + System.currentTimeMillis());
|
// //logger.debug(tempSavePath + fileName + " save: " + isSaved);
|
// //logger.debug("moreFollows:" + moreFollows);
|
// while (moreFollows){
|
// return true;
|
// }
|
// //文件传输完成，打包文件
|
// //logger.debug("单个文件传输完成时间：" + System.currentTimeMillis());
|
// String strData = getFileCompressBase64(tempSavePath, fileName);
|
// //logger.debug("生成数据时间：" + System.currentTimeMillis());
|
// //logger.debug("temp file temp saved: " + fileName);
|
// //打包完成，删除文件
|
// boolean deleteFlag = FileOption.deleteFile(tempSavePath, fileName);
|
// //boolean deleteFlag = false;
|
// if(!deleteFlag){
|
// logger.debug("temp file delete: " + "failure");
|
// }
|
// boolean complete = sendFileDate(ip, fileName, strData);
|
// if(complete){
|
// deleteList.add(fileName);
|
// }
|
// return false;
|
// }
|
// });
|
// } catch (ServiceError serviceError) {
|
// serviceError.printStackTrace();
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// }
|
// }
|
// //记录执行日志
|
// String newLogStr = "\n" + "[sendCount:" + sendCount + ", deleteCount:" + deleteList.size() + "]-Time "
|
// + SimpleUtils.MillisToDateTime(System.currentTimeMillis());
|
// //更新采集时间
|
// String strDate = SimpleUtils.CurrentDateTime();
|
// tableModel.setValueAt(strDate, rowIndex, 3);
|
// //记录采集日志
|
// FileOption.writeFile(newLogStr, tempSavePath, tempLogFile, true);
|
// logger.debug("【" + subStationName + "】 谱图采集完成！");
|
// labelTips("【" + subStationName + "】 本次谱图采集完成！", "");
|
// if(!isDeleteRemoteFile){
|
// association.disconnect();
|
// association.close();
|
// return;
|
// }
|
// //删除远程文件
|
// for(int i = 0; i < deleteList.size(); i++){
|
// try {
|
// association.deleteFile(deleteList.get(i));
|
// logger.debug("remote file delete: " + deleteList.get(i));
|
// } catch (ServiceError serviceError) {
|
// serviceError.printStackTrace();
|
// logger.debug("remote file delete: " + "failure");
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// logger.debug("remote file delete: " + "failure");
|
// }
|
// }
|
// logger.debug("【" + subStationName + "】 远程谱图文件删除完成！");
|
// association.disconnect();
|
// association.close();
|
// //logger.debug(association.isOpen() + "");
|
// //logger.debug("恭喜你！本次采集完成了！！！");
|
// }
|
//
|
// private boolean readData(ClientAssociation association, String ipAddress, String subStationName){
|
// ServerModel serverModel;
|
// try {
|
// logger.debug("【" + subStationName + "】 开始读取数据模型...");
|
// labelTips("【" + subStationName + "】 开始读取数据模型...", "");
|
// serverModel = association.retrieveModel();
|
// logger.debug("【" + subStationName + "】 数据模型读取成功^_^");
|
// logger.debug("【" + subStationName + "】 开始采集数据...");
|
// labelTips("【" + subStationName + "】 开始采集数据^_^...", "");
|
// association.getAllDataValues();
|
//
|
// for(ModelNode modelNodeLD : serverModel.getChildren()) {
|
// LogicalDevice logicalDevice = (LogicalDevice)modelNodeLD;
|
// if (logicalDevice.getReference().toString().contains("_LD0")) {//过滤综合数据处理单元LD0
|
// continue;
|
// }
|
// for (ModelNode modelNodeLN : logicalDevice.getChildren()) {
|
// LogicalNode logicalNode = (LogicalNode)modelNodeLN;
|
// int start = logicalNode.getReference().toString().indexOf('/');
|
// String lnReference = logicalNode.getReference().toString().substring(start);
|
// if(lnReference.contains("LLN0")// 综合数据处理单元LD下面LLN0
|
// | lnReference.contains("GGIO")// 综合数据处理单元LD下面GGIO
|
// | lnReference.contains("LPHD")// 综合数据处理单元LD下面LPHD
|
// | lnReference.contains("RDRE")) {// 综合数据处理单元LD下面RDRE
|
// continue;
|
// }
|
//
|
// logger.debug(logicalNode.getName());
|
// List<String> doKeyList = new ArrayList<>();
|
// for (ModelNode modelNodeDO : logicalNode.getChildren()) {
|
// if (!doKeyList.contains(modelNodeDO.getName())) {
|
// doKeyList.add(modelNodeDO.getName());
|
// } else {
|
// continue;
|
// }
|
// }
|
//
|
// if(!doKeyList.contains("NamPlt")){
|
// String errorMsg = "【" + subStationName + "】 " + logicalNode.getReference().toString() + "配置文件铭牌定义错误";
|
// logger.error(logicalNode.getReference().toString() + " not contain NamPlt!!!!");
|
// labelTips(errorMsg, "error");
|
// sendErrorLog(subStationName, ipAddress, errorMsg);
|
// continue;
|
// }
|
// doKeyList.remove("NamPlt");
|
//
|
// //Map<String, Object> mapId = new HashMap<>();
|
// ModelNode modelNodeId = logicalNode.getChild("NamPlt", Fc.DC);
|
// Map<String, Object> mapId = getChildrenData(modelNodeId);
|
// String strNamPltValue = ((Map<String, Object>)mapId.get("dU")).get("value").toString();
|
// //byte[] byteNamPltValue = strNamPltValue.getBytes();
|
// //String packageType = "Linux";
|
// //packageType = "Windows";
|
// //if(packageType.equals("Windows")){
|
// //strNamPltValue = new String(byteNamPltValue, "UTF-8");
|
// //}
|
// String[] strNamPltValues = strNamPltValue.split("\\|");
|
// //logger.debug("" + NamPltValues.length);
|
//
|
// if(strNamPltValues.length < 5){
|
// String errorMsg = "【" + subStationName + "】 NamPlt:dU=>" + strNamPltValue + " ；描述错误！";
|
// logger.error(errorMsg);
|
// labelTips("【" + subStationName + "】 配置文件铭牌dU值定义错误", "error");
|
// sendErrorLog(subStationName, ipAddress, errorMsg);
|
// //continue;
|
// }
|
// //logger.debug(strNamPltValues[4].length() + "");
|
// if(strNamPltValues.length >= 5 && strNamPltValues[4].length() < 2){
|
// String errorMsg = "【" + subStationName + "】 NamPlt:dU=>" + strNamPltValue + " ；相位描述不完整！";
|
// logger.error(errorMsg);
|
// labelTips("【" + subStationName + "】 配置文件铭牌dU值相位描述不完整", "error");
|
// sendErrorLog(subStationName, ipAddress, errorMsg);
|
// //continue;
|
// }
|
// //logger.debug(JSON.toJSONString(mapId));
|
// logger.debug("【" + subStationName + "】 ------ [" + strNamPltValue + "] " + logicalNode.getReference().toString() + " 开始打包发送数据: " + doKeyList.size() +" 条 ------");
|
// for (String doKey : doKeyList){
|
// Map<String, Object> mapDo = new HashMap<>();
|
// for (Fc fc: SimpleUtils.FcList()){
|
// ModelNode modelNodeDo = logicalNode.getChild(doKey, fc);
|
// if(modelNodeDo == null){
|
// continue;
|
// }
|
// Map<String, Object> mapDataChildren = getChildrenData(modelNodeDo);
|
// if(mapDataChildren.get("t") != null){
|
// Map<String, Object> mapDataTime = (HashMap)mapDataChildren.get("t");
|
// long dataTime = SimpleUtils.DateTimeToMillisTime(mapDataTime.get("value").toString(), "yyyyMMddHHmmss");
|
// if(System.currentTimeMillis() - dataTime > 2 * 24 * 60 * 60 * 1000){
|
// //logger.debug(mapDataTime.get("value").toString());
|
// sendErrorLog(subStationName, ipAddress, logicalNode.getChild(doKey).getReference().toString() + ":" + mapDataTime.get("value").toString());
|
// }
|
// }
|
// mapDo.put(fc.toString(), getChildrenData(modelNodeDo));
|
// }
|
// mapDo.put("ID", mapId);
|
// Map<String, Object> mapData = new HashMap<>();
|
// mapData.put("type", "GC");
|
// if (ConfigUtil.isDebug) {
|
// logger.debug(doKey);
|
// logger.debug(logicalNode.getChild(doKey).getReference().toString());
|
// }
|
// mapData.put(ipAddress + "$" + logicalNode.getChild(doKey).getReference().toString(), mapDo);
|
// String data = JSON.toJSONString(mapData);
|
// //logger.debug(data);
|
// sendDataToMQ(data);
|
// //sendDataToIII(data);
|
// System.out.println(data);
|
// }
|
// }
|
// }
|
// } catch (ServiceError e) {
|
// System.out.println("Service Error requesting model." + e.getMessage());
|
// String errorMsg = "Service Error requesting model." + e.getMessage().toString();
|
// sendErrorLog(subStationName, ipAddress, errorMsg);
|
// association.close();
|
// return false;
|
// } catch (IOException e) {
|
// System.out.println("Fatal IOException requesting model." + e.getMessage());
|
// String errorMsg = "Fatal IOException requesting model." + e.getMessage().toString();
|
// sendErrorLog(subStationName, ipAddress, errorMsg);
|
// return false;
|
// }
|
//
|
// //ServerModelParser parser = new ServerModelParser(serverModel);
|
// return true;
|
// }
|
//
|
// private Map<String, Object> getChildrenData(ModelNode modelNode){
|
// //logger.debug(modelNode.getName());
|
// Map<String, Object> mapData = new HashMap<>();
|
// if(modelNode.getChildren() == null){
|
// try{
|
// mapData = getBasicData(modelNode);
|
// }catch (Exception e){
|
// logger.error("数据解析出错！");
|
// e.printStackTrace();
|
// }
|
// return mapData;
|
// }
|
// for (ModelNode modelNodeChild : modelNode.getChildren()) {
|
// mapData.put(modelNodeChild.getName(), getChildrenData(modelNodeChild));
|
// }
|
// return mapData;
|
// }
|
//
|
// private Map<String, Object> getBasicData(ModelNode modelNode){
|
// Map<String, Object> map = new HashMap<>();
|
// BasicDataAttribute dataAttribute = (BasicDataAttribute)modelNode;
|
// String dataReference = dataAttribute.getReference().toString();
|
// map.put("basicType", dataAttribute.getBasicType().toString());
|
// map.put("dchg", dataAttribute.getDchg());
|
// map.put("qchg", dataAttribute.getQchg());
|
// map.put("dupd", dataAttribute.getDupd());
|
// //logger.debug((dataAttribute).toString());
|
//// if((dataReference.length() + 2) == dataAttribute.toString().length()){
|
//// map.put("value", null);
|
//// return map;
|
//// }
|
// switch (dataAttribute.getBasicType()) {
|
// case BOOLEAN:
|
// map.put("value", ((BdaBoolean)dataAttribute).getValue());
|
// break;
|
// case ENTRY_TIME:
|
// map.put("value", SimpleUtils.DataTimeParse(((BdaEntryTime)dataAttribute).getValueString()));
|
// break;
|
// case FLOAT32:
|
// map.put("value", ((BdaFloat32)dataAttribute).getFloat().toString());
|
// break;
|
// case FLOAT64:
|
// map.put("value", ((BdaFloat64)dataAttribute).getDouble().toString());
|
// break;
|
// case INT16:
|
// map.put("value", ((BdaInt16)dataAttribute).getValue());
|
// break;
|
// case INT16U:
|
// map.put("value", ((BdaInt16U)dataAttribute).getValue());
|
// break;
|
// case INT32:
|
// map.put("value", ((BdaInt32)dataAttribute).getValue());
|
// break;
|
// case INT32U:
|
// map.put("value", ((BdaInt32U)dataAttribute).getValue());
|
// break;
|
// case INT64:
|
// map.put("value", ((BdaInt64)dataAttribute).getValue());
|
// break;
|
// case INT8:
|
// map.put("value", ((BdaInt8)dataAttribute).getValue());
|
// break;
|
// case INT8U:
|
// map.put("value", ((BdaInt8U)dataAttribute).getValue());
|
// break;
|
// case OCTET_STRING:
|
// map.put("maxLength", ((BdaOctetString)dataAttribute).getMaxLength());
|
// map.put("value", new String(((BdaOctetString)dataAttribute).getValue()));
|
// break;
|
// case TIMESTAMP:
|
// map.put("value", SimpleUtils.DataTimeParse(((BdaTimestamp)dataAttribute).getValueString()));
|
// break;
|
// case UNICODE_STRING:
|
// //logger.debug(((BdaUnicodeString)dataAttribute).toString());
|
// //logger.debug(new String(((BdaUnicodeString)dataAttribute).getValue()));
|
// map.put("maxLength", ((BdaUnicodeString)dataAttribute).getMaxLength());
|
// map.put("value", new String(((BdaUnicodeString)dataAttribute).getValue()));
|
// break;
|
// case VISIBLE_STRING:
|
// map.put("maxLength", ((BdaVisibleString)dataAttribute).getMaxLength());
|
// map.put("value", new String(((BdaVisibleString)dataAttribute).getValue()));
|
// break;
|
// case CHECK:
|
// map.put("maxNumBits", ((BdaCheck)dataAttribute).getMaxNumBits());
|
// map.put("value", ((BdaCheck)dataAttribute).getValueString());
|
// break;
|
// case DOUBLE_BIT_POS:
|
// map.put("maxNumBits", ((BdaOptFlds)dataAttribute).getMaxNumBits());
|
// map.put("value", ((BdaDoubleBitPos)dataAttribute).getDoubleBitPos().toString());
|
// break;
|
// case OPTFLDS:
|
// map.put("maxNumBits", ((BdaOptFlds)dataAttribute).getMaxNumBits());
|
// map.put("value", ((BdaOptFlds)dataAttribute).getValueString());
|
// break;
|
// case QUALITY:
|
// //logger.debug(((BdaQuality)dataAttribute).toString());
|
// //logger.debug(((BdaQuality)dataAttribute).getValue().toString());
|
// //logger.debug(((BdaQuality)dataAttribute).getValidity().toString());
|
// //logger.debug(((BdaQuality)dataAttribute).getValidity().getIntValue() + "");
|
// map.put("maxNumBits", ((BdaQuality)dataAttribute).getMaxNumBits());
|
// if((dataReference.length() + 2) == dataAttribute.toString().length()) {
|
// map.put("value", BdaQuality.Validity.GOOD);
|
// break;
|
// }
|
// map.put("value", ((BdaQuality)dataAttribute).getValidity().toString());
|
// break;
|
// case REASON_FOR_INCLUSION:
|
// map.put("maxNumBits", ((BdaReasonForInclusion)dataAttribute).getMaxNumBits());
|
// map.put("value", ((BdaReasonForInclusion)dataAttribute).getValueString());
|
// break;
|
// case TAP_COMMAND:
|
// map.put("maxNumBits", ((BdaTapCommand)dataAttribute).getMaxNumBits());
|
// map.put("value", ((BdaTapCommand)dataAttribute).getTapCommand().toString());
|
// break;
|
// case TRIGGER_CONDITIONS:
|
// map.put("maxNumBits", ((BdaTriggerConditions)dataAttribute).getMaxNumBits());
|
// map.put("value", ((BdaTriggerConditions)dataAttribute).getValueString());
|
// break;
|
// default:
|
// logger.debug("BasicType " + dataAttribute.getBasicType() + " unknown");
|
// //map.put("value", ((BdaEntryTime)dataAttribute).getValue());
|
// //throw new IllegalArgumentException("BasicType " + dataAttribute.getBasicType() + " unknown");
|
// }
|
// return map;
|
// }
|
//
|
// private boolean sendDataToMQ(String data){
|
// if (ConfigUtil.isDebug) {
|
// logger.debug("发送数据：" + data);
|
// }
|
// if(producer == null){
|
// if(!ConfigUtil.isDebug) {
|
// //logger.error("消息队列初始化未完成");
|
// }
|
// return false;
|
// }
|
// try {
|
// producer.sendMessage(data);
|
// } catch (IOException e) {
|
// e.printStackTrace();
|
// return false;
|
// }
|
// return true;
|
// }
|
//
|
// private boolean sendDataToIII(String data){
|
// // 检查/唤醒连接
|
// client.conn();
|
// try {
|
// System.out.println("try socket client send");
|
// client.sendData(data);
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// return false;
|
// }
|
// return true;
|
// }
|
//
|
// private boolean sendErrorLog(String substationName, String ipAddress, String data){
|
// Map<String, Object> errorMsgMap = new HashMap<>();
|
// if(ipAddress == null || ipAddress.length() < 7){
|
// return false;
|
// }
|
// errorMsgMap.put("type", "ERR_MSG");
|
// errorMsgMap.put("name", substationName);
|
// errorMsgMap.put("ip", ipAddress);
|
// errorMsgMap.put("data", data);
|
// errorMsgMap.put("datetime", SimpleUtils.CurrentDateTime());
|
// sendDataToMQ(JSON.toJSONString(errorMsgMap));
|
// return true;
|
// }
|
//
|
// private boolean sendFileDate(String ip, String fileName, String fileData) {
|
// //logger.debug(fileName);
|
// Map<String, Object> mapData = new HashMap<>();
|
// mapData.put("type", "WF");//type目前有GC、ZT、ZH，增加一个WF标记为谱图
|
// Map<String, Object> mapSubData = new HashMap<>();
|
// Map<String, Object> mapSubSubData = new HashMap<>();
|
// mapSubSubData.put("fileName", FileOption.trimPath(fileName));
|
// mapSubData.put("ID", mapSubSubData);
|
// mapSubData.put("FD", fileData);
|
// //mapData.put(ip + "$" + "BSCYB01HNZF2_ZT2202/PTRSIML1" + "." + "WaveFileNum", mapSubData);
|
// mapData.put(ip + "$" + "WaveFileNum", mapSubData);
|
// String data = JSON.toJSONString(mapData);
|
// //logger.debug(jsonObject.toString());
|
// return sendDataToMQ(data);
|
// }
|
//
|
// /**
|
// * 读取文件进行压缩并编码
|
// * @param filePath
|
// * @param fileName
|
// * @return
|
// */
|
// private String getFileCompressBase64(String filePath, String fileName) {
|
// byte[] fileBytes = FileOption.readFileByByte(filePath, fileName);
|
// //logger.debug("二进制长度 = " + fileBytes.length);
|
// //压缩
|
// //logger.debug("压缩前时间：" + System.currentTimeMillis());
|
// byte[] compressBytes = GZIPUtils.compress(fileBytes);
|
// //logger.debug("压缩后时间：" + System.currentTimeMillis());
|
// //logger.debug("二进制压缩后长度 = " + compressBytes.length);
|
// //编码
|
// final BASE64Encoder encoder = new BASE64Encoder();
|
// //logger.debug("编码前时间：" + System.currentTimeMillis());
|
// final String encodedStr = encoder.encode(compressBytes);
|
// //logger.debug("编码后时间：" + System.currentTimeMillis());
|
// //logger.debug("编码后字符串长度 = " + encodedStr.length());
|
// return encodedStr;
|
// }
|
//
|
// protected void collectStart() {
|
// threads = new Thread[tableModel.getRowCount()];
|
// timers = new Timer[tableModel.getRowCount()];
|
// logger.debug("初始化 " + tableModel.getRowCount() + " 个站点！");
|
// for(int i = 0; i < tableModel.getRowCount(); i++){
|
//// if(i != 0){
|
//// continue;
|
//// }
|
// final String name = tableModel.getValueAt(i,0).toString();
|
// final String ip = tableModel.getValueAt(i,1).toString();
|
// final int port = Integer.valueOf(tableModel.getValueAt(i,2).toString());
|
// final int threadIndex = i;
|
// threads[i] = new Thread(new Runnable() {
|
// @Override
|
// public void run() {
|
// timers[threadIndex] = new Timer();
|
//
|
// TimerTask timerTask = new TimerTask() {
|
// @Override
|
// public void run() {
|
// logger.debug("定时任务【" + (threadIndex + 1) + " - " + name + "】 开始连接至变电站 => " + ip + ":" + port
|
// + " [" + SimpleUtils.CurrentDateTime() + "]");
|
// collectToSubstation(ip, port, threadIndex);
|
// }
|
// };
|
// timers[threadIndex].schedule(timerTask, threadIndex * SubstaionIntervalTimes, CollectIntervalTimes);
|
// }
|
// });
|
// threads[i].start();
|
// }
|
// }
|
//
|
// protected void collectStop(){
|
// for(int i = 0; i < timers.length; i++){
|
// //logger.debug(threads[i].isAlive() + "");
|
// timers[i].cancel();
|
// }
|
// logger.debug("停止 " + timers.length + " 个采集任务！");
|
// labelTips("停止 " + timers.length + " 个采集任务！", "");
|
// }
|
//
|
// protected void dataLoad(){
|
// tableModel.setDataVector(ConfigUtil.readSubstation(txtSubstationList.getText()), columnTitles);
|
// //logger.debug("-- 站点列表加载完成 --");
|
// labelTips("站点列表加载完成^_^！", "");
|
// }
|
//
|
// private void labelTips(String msg, String msgType){
|
// msg = msg + "[" + SimpleUtils.CurrentDateTime() + "]";
|
// switch (msgType){
|
// case "error":
|
// labelTips.setText(msg);
|
// labelTips.setForeground(Color.RED);
|
// break;
|
// case "warning":
|
// labelTips.setText(msg);
|
// labelTips.setForeground(Color.PINK);
|
// break;
|
// default:
|
// labelTips.setText(msg);
|
// labelTips.setForeground(Color.BLACK);
|
// }
|
// }
|
//
|
// public void checkNet(String substationName, String ipAddress, int port){
|
// Map<String, Object> networkMsg = new HashMap<>();
|
// boolean pingResult = NetworkUtils.pingByLinuxCmd(ipAddress, 5 * 1000);
|
// boolean telnetResult = NetworkUtils.telnet(ipAddress, port, 5 * 1000);
|
// networkMsg.put("type", "NET");
|
// networkMsg.put("name", substationName);
|
// networkMsg.put("ip", ipAddress);
|
// networkMsg.put("port", 102);
|
// networkMsg.put("ping", pingResult);
|
// networkMsg.put("telnet", telnetResult);
|
// networkMsg.put("datetime", SimpleUtils.CurrentDateTime());
|
// sendDataToMQ(JSON.toJSONString(networkMsg));
|
// }
|
//
|
// public void startNetworkReview(){
|
// networkReviewTimer = new Timer();
|
// networkReviewTimer.schedule(new TimerTask() {
|
// @Override
|
// public void run() {
|
// logger.debug("开始检测网络...");
|
// String ipListFileStr = FileOption.readFileByString("myconfig/ip_list.txt", "UTF-8");
|
// String newIpListFileStr = "";
|
// String[] ipList = ipListFileStr.split("\n");
|
// for (String ip: ipList) {
|
// logger.debug(ip);
|
// Map<String, Object> networkMsg = new HashMap<>();
|
// if(ip == null || ip.length() < 7){
|
// continue;
|
// }
|
// String[] ipInfo = ip.split("-");
|
// if(ipInfo[1] == null){
|
// continue;
|
// }
|
// boolean pingResult = NetworkUtils.pingByLinuxCmd(ipInfo[1], 5 * 1000);
|
// boolean telnetResult = NetworkUtils.telnet(ipInfo[1], 102, 5 * 1000);
|
// //newIpListFileStr += ipInfo[0] + "-" + ipInfo[1] + "-" + pingResult + "-" + telnetResult + "-" + SimpleUtils.CurrentDateTime() + "\n";
|
// newIpListFileStr += ipInfo[1] + "-" + pingResult + "-" + telnetResult + "-" + SimpleUtils.CurrentDateTime() + "\n";
|
// networkMsg.put("type", "NET");
|
// networkMsg.put("name", ipInfo[0]);
|
// networkMsg.put("ip", ipInfo[1]);
|
// networkMsg.put("port", 102);
|
// networkMsg.put("ping", pingResult);
|
// networkMsg.put("telnet", telnetResult);
|
// networkMsg.put("datetime", SimpleUtils.CurrentDateTime());
|
// sendDataToMQ(JSON.toJSONString(networkMsg));
|
// logger.debug(JSON.toJSONString(networkMsg));
|
// FileOption.writeFile(newIpListFileStr, "myconfig", "ip_list_result.txt");
|
// }
|
// //FileOption.writeFile(newIpListFileStr, "myconfig", "ip_list_result.txt");
|
// logger.debug("检测完成！");
|
// }
|
// }, 1000, 10 * 60 * 1000);
|
// }
|
//
|
// public static void main(String[] args) {
|
//
|
// logger.debug("System starting...");
|
// MyClient clientGui = new MyClient();
|
// clientGui.ClientMain();
|
// }
|
//}
|
