package com.vci.client.framework.systemConfig.stafforgmanage.listeners;
|
|
import java.awt.event.ActionEvent;
|
import java.awt.event.ActionListener;
|
import java.io.BufferedInputStream;
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.IOException;
|
import java.util.ArrayList;
|
import java.util.LinkedList;
|
import java.util.List;
|
|
import javax.swing.JPanel;
|
|
import com.vci.client.ClientSession;
|
import com.vci.client.LogonApplication;
|
import com.vci.client.common.objects.UserEntityObject;
|
import com.vci.client.framework.delegate.UserEntityClientDelegate;
|
import com.vci.client.framework.systemConfig.stafforgmanage.MachSecurityImportDialog;
|
import com.vci.client.ui.process.QANProcessBar;
|
import com.vci.client.ui.process.QANProcessBarFrame;
|
import com.vci.client.ui.swing.VCIOptionPane;
|
import com.vci.client.ui.swing.VCISwingUtil;
|
import com.vci.client.ui.swing.components.VCIJOptionPane;
|
import com.vci.client.utils.excel.ExcelDocumentUtils;
|
import com.vci.client.utils.excel.SheetDataSet;
|
import com.vci.common.exception.VciException;
|
import com.vci.common.utility.ObjectUtility;
|
import com.vci.corba.common.VCIError;
|
import com.vci.corba.framework.data.MachSecurityInfo;
|
import com.vci.corba.common.data.UserEntityInfo;
|
|
|
public class MachSecurityImportActionListener extends JPanel implements ActionListener {
|
|
/**
|
*
|
*/
|
private static final long serialVersionUID = 1L;
|
|
/**
|
* 父窗体
|
*/
|
private MachSecurityImportDialog ownerDialog = null;
|
/**
|
* 所有Roles信息。
|
*/
|
private ArrayList<MachSecurityInfo> fileDatas = new ArrayList<MachSecurityInfo>();
|
private String userName = LogonApplication.getUserEntityObject().getUserName();
|
|
public MachSecurityImportActionListener(MachSecurityImportDialog ownerDialog) {
|
this.ownerDialog = ownerDialog;
|
}
|
|
public MachSecurityImportActionListener() {
|
// TODO Auto-generated constructor stub
|
}
|
|
@Override
|
public void actionPerformed(ActionEvent e) {
|
|
String actionCommand = e.getActionCommand();
|
if (actionCommand.equals(ownerDialog.getBtnSave().getActionCommand())) {
|
LinkedList<File> selectedFiles = this.ownerDialog.getSelectedFiles();
|
if (selectedFiles == null || selectedFiles.isEmpty()) {
|
VCIOptionPane.showMessageDialog(LogonApplication.frame, "未选择文件！");
|
return;
|
}
|
fileDatas.clear();
|
save();
|
|
} else if (actionCommand.equals(ownerDialog.getBtnSelect().getActionCommand())) {
|
getFile();
|
}
|
}
|
|
/**
|
* 保存对象
|
*/
|
private void save() {
|
final QANProcessBarFrame frame = new QANProcessBarFrame();
|
Thread t = new Thread() {
|
public void run() {
|
boolean b = false;
|
frame.setContent("正在进行处理数据,请稍等......");
|
try {
|
b = importData(frame);
|
} catch (VCIError e) {
|
frame.setProcessBarCancel(true);
|
VCIOptionPane.showMessageDialog(LogonApplication.frame, e.code);
|
} catch (VciException e) {
|
|
} catch (IOException e) {
|
e.printStackTrace();
|
} finally {
|
frame.setProcessBarCancel(true);
|
if (b) {
|
VCIOptionPane.showMessageDialog(LogonApplication.frame, "导入成功！");
|
ownerDialog.dispose();
|
|
} else {
|
VCIOptionPane.showMessageDialog(LogonApplication.frame, "导入失败！");
|
}
|
}
|
}
|
};
|
QANProcessBar bar = new QANProcessBar(t, frame, frame, "导入机器密级数据......", false);
|
bar.setVisible(true);
|
}
|
|
/**
|
* 导入
|
*
|
* @param sheetDataSet
|
* @return
|
* @throws IOException
|
* @throws VCIError
|
* @throws VciException
|
* @autor caicong
|
* @data 2014-3-12
|
*/
|
private boolean importData(QANProcessBarFrame frame) throws VCIError, VciException, IOException {
|
|
frame.setContent("正在获取机器密级数据......");
|
|
frame.setContent("正在收集表单数据......");
|
boolean isSuccess = collectionDatas();
|
if (!isSuccess)
|
return false;
|
frame.setContent("正在导入表单人员信息......");
|
boolean b = importExcelData();
|
return b;
|
}
|
|
/**
|
* 收集表单信息。
|
*
|
* @throws VCIError
|
* @throws IOException
|
*/
|
// add by caill start 2016.1.20 收集导入文件中的数据
|
private boolean collectionDatas() throws VCIError, IOException {
|
List<File> selectedFiles = this.ownerDialog.getSelectedFiles();
|
MachSecurityInfo[] msInfos = null;
|
|
MachSecurityInfo[] oldInfos = ClientSession.getFrameworkService().getAllMachSecurity();
|
List<String> lstIP = new ArrayList<String>();
|
|
for (MachSecurityInfo info : msInfos) {
|
lstIP.add(info.ipAddress);
|
}
|
|
UserEntityObject user = LogonApplication.getUserEntityObject();
|
|
for (File f : selectedFiles) {
|
List<SheetDataSet> sheetDataSets = this.getFileList(f);
|
if (sheetDataSets == null || sheetDataSets.isEmpty()) {
|
continue;
|
}
|
for (SheetDataSet sheet : sheetDataSets) {
|
// sheet不能为空并且必须有除表头外的一条数据
|
if (sheet != null && sheet.getDataSet() != null && sheet.getDataSet().size() > 1) {
|
List<String[]> dataSet = sheet.getDataSet();
|
for (int i = 1; i < dataSet.size(); i++) {
|
String[] data = dataSet.get(i);
|
|
if (data[0] != null && !data[0].trim().equals(""))
|
continue;
|
// 对于数据库中存在的IP地址，不覆盖不导入
|
if (lstIP.contains(data[0]))
|
continue;
|
|
String id = ObjectUtility.getNewObjectID36();
|
MachSecurityInfo msInfo = new MachSecurityInfo();
|
|
msInfo.id = id;
|
msInfo.ipAddress = data[0];
|
msInfo.name = data[1];
|
msInfo.secretGrade = Short.parseShort(data[2]);
|
msInfo.desc = data[3];
|
msInfo.macAddress = "";
|
msInfo.creator = user.getUserName();
|
msInfo.createTime = System.currentTimeMillis();
|
msInfo.modifier = user.getUserName();
|
msInfo.modifyTime = System.currentTimeMillis();
|
|
fileDatas.add(msInfo);
|
}
|
}
|
}
|
}
|
return true;
|
}
|
|
/**
|
* 导入表单数据
|
*
|
* @throws VciException
|
*/
|
private boolean importExcelData() throws VCIError {
|
UserEntityObject user = LogonApplication.getUserEntityObject();
|
|
UserEntityInfo userInfo = UserEntityClientDelegate.changeUserEntityToInfo(user);
|
|
return ClientSession.getFrameworkService().batchSaveMachSecurity(
|
fileDatas.toArray(new MachSecurityInfo[0]), userInfo);
|
}
|
|
/**
|
* 获取选中的文件
|
*
|
* @return
|
* @autor caicong
|
* @data 2014-3-12
|
*/
|
@SuppressWarnings({ "deprecation", "unused" })
|
private LinkedList<File> getSelectedFiles() {
|
Object[] objs = ownerDialog.getSelectedDatas();
|
LinkedList<File> selectedFiles = new LinkedList<File>();
|
for (Object obj : objs) {
|
selectedFiles.add((File)obj);
|
}
|
|
return selectedFiles;
|
}
|
|
/**
|
* 获取表单数据
|
*
|
* @param f
|
* @return
|
* @throws IOException
|
* @throws VCIError
|
* @autor caicong
|
* @data 2014-3-11
|
*/
|
private List<SheetDataSet> getFileList(File f) throws VCIError, IOException {
|
// 获取流
|
BufferedInputStream fileInputStream = new BufferedInputStream(new FileInputStream(f));
|
String name = f.getName();
|
// 获取表list
|
List<SheetDataSet> sheetDataSets = ExcelDocumentUtils.readExcelDocument(name, fileInputStream);
|
return sheetDataSets;
|
}
|
|
private void getFile() {
|
File f = getRequiredFile(true);
|
if (f == null)
|
return;
|
ArrayList<File> lists = ownerDialog.getLists();
|
/** 判断导入的文件是否被使用的校验，如果文件已经打开，不允许导入 **/
|
if (lists.contains(f)) {
|
VCIOptionPane.showMessageDialog(LogonApplication.frame, "文件重复，请重新选择！");
|
return;
|
}
|
// 将文件保存到table中
|
lists.add(f);
|
ownerDialog.refreshTableData();
|
}
|
|
private File getRequiredFile(boolean isRead) {
|
File files = getExcelFile();
|
// add by xchao 2014.04.15 begin
|
// 有错误数据要输出时，必须选择有效的excel文件
|
while (files == null) {
|
return null;
|
}
|
String fileName = files.getAbsolutePath();
|
// 需要写入时，必须选择一个有效的、可以写入的文件
|
if (!isRead) {
|
// 如果文件被打开着，则必须选择其它的未打开着的文件
|
while (files.exists() && !files.renameTo(new File(fileName))) {
|
VCIJOptionPane.showMessageDialog(null, "另一个程序正在使用此文件，进程无法访问，请重新选择！");
|
// 重新选择文件时，也必须选择有效的excel文件
|
files = null;
|
while (files == null) {
|
files = getExcelFile();
|
while (files == null) {
|
return null;
|
}
|
}
|
fileName = files.getAbsolutePath();
|
}
|
}
|
return files;
|
}
|
|
public String[] getExcel() {
|
return null;
|
}
|
|
private File getExcelFile() {
|
File file = null;
|
String filePath = VCISwingUtil.getExcelFileURL(ownerDialog, true, "");
|
if (filePath != null) {
|
file = new File(filePath);
|
}
|
return file;
|
}
|
}
|
