initial commit

1 files changed, 285 insertions, 0 deletions

diff --git a/src/com/nis/nmsclient/util/FileWrUtil.java b/src/com/nis/nmsclient/util/FileWrUtil.java
new file mode 100644
index 0000000..8ebf75c
--- /dev/null
+++ b/src/com/nis/nmsclient/util/FileWrUtil.java
@@ -0,0 +1,285 @@
+package com.nis.nmsclient.util;
+
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.OutputStreamWriter;
+import java.io.Reader;
+import java.nio.charset.Charset;
+import java.util.ArrayList;
+import java.util.List;
+
+import org.apache.log4j.Logger;
+
+import com.Ostermiller.util.ExcelCSVParser;
+import com.Ostermiller.util.ExcelCSVPrinter;
+import com.nis.nmsclient.util.io.UnicodeReader;
+
+public class FileWrUtil {
+	static Logger logger = Logger.getLogger(FileWrUtil.class);
+	
+	/**
+	 * 根据文件编码添加文件内容前缀
+	 * @param file
+	 * @param encoding
+	 */
+	protected static boolean addFileHeadByEncoding(File file, String encoding) throws Exception{
+		FileOutputStream fos = null;
+		boolean flag = false;
+		try{
+			byte[] head = null;
+			if("UTF-8".equalsIgnoreCase(encoding)){
+	    		head = new byte[]{(byte)0xEF,(byte)0xBB,(byte)0xBF};
+	    	}else if("UTF-16BE".equalsIgnoreCase(encoding)){
+	    		head = new byte[]{(byte)0xFE,(byte)0xFF};
+	    	}else if("UTF-16LE".equalsIgnoreCase(encoding)){
+	    		head = new byte[]{(byte)0xFF,(byte)0xFE};
+	    	}else if("UTF-32BE".equalsIgnoreCase(encoding)){
+	    		head = new byte[]{(byte)0x00,(byte)0x00,(byte)0xFE,(byte)0xFF};
+	    	}else if("UTF-32LE".equalsIgnoreCase(encoding)){
+	    		head = new byte[]{(byte)0xFF,(byte)0xFF,(byte)0x00,(byte)0x00};
+	    	}
+			
+			if(head!=null){
+				fos = new FileOutputStream(file);
+		    	fos.write(head);
+		    	fos.flush();
+		    	
+		    	flag = true;
+			}
+		} catch (IOException e) {
+			throw e;
+		}finally {
+			if(fos!=null){
+				try {
+					fos.close();
+				} catch (IOException e) {
+				}
+			}
+		}
+		
+		return flag;
+	}
+	
+	/**
+	 * 写入文件, .cfg\.ini\.txt
+	 *
+	 */
+	public static boolean cfgFilePrinter(File file, String charset, String[] values) throws Exception{
+		OutputStreamWriter fos = null;
+        try {
+        	if(addFileHeadByEncoding(file, charset)){
+	        	fos = new OutputStreamWriter(
+	    				new FileOutputStream(file,true), charset);
+        	}else{
+        		fos = new OutputStreamWriter(
+        				new FileOutputStream(file), charset);
+        	}
+        	for(String val : values){
+        		fos.write(val);
+        		fos.write("\n");
+        	}
+			fos.flush();
+		} catch (IOException e) {
+			throw e;
+		}finally {
+			if(fos!=null){
+				try {
+					fos.close();
+				} catch (IOException e) {
+				}
+			}
+		}
+		
+		return true;
+	}
+	
+	/**
+	 * 追加内容到文件, .cfg\.ini\.txt
+	 *
+	 */
+	public static boolean cfgFileAppender(File file, String charset, String[] values) throws Exception{
+		OutputStreamWriter fos = null;
+        try {
+        	fos = new OutputStreamWriter(
+    				new FileOutputStream(file, true), charset);
+        	for(String val : values){
+        		fos.write(val);
+        		fos.write("\n");
+        	}
+			fos.flush();
+		} catch (IOException e) {
+			throw e;
+		}finally {
+			if(fos!=null){
+				try {
+					fos.close();
+				} catch (IOException e) {
+				}
+			}
+		}
+		
+		return true;
+	}
+	
+	/**
+	 * 根据文件的编码读取文件内容, .cfg\.ini\.txt
+	 *
+	 */
+	public static String[] cfgFileReader(File file) throws Exception{
+		BufferedReader br = null;
+		ArrayList<String> list = new ArrayList<String>();
+        try {
+        	
+        	br = new BufferedReader(new UnicodeReader(new FileInputStream(
+					file), Charset.defaultCharset().name()));
+        	String str = null;
+    		while((str=br.readLine())!=null){
+    			list.add(str);
+    		}
+        } catch (IOException e) {
+        	throw e;
+		}finally {
+			if(br!=null){
+				try {
+					br.close();
+				} catch (IOException e) {
+				}
+			}
+		}
+		
+		String[] values = new String[list.size()];
+		return list.toArray(values);
+	}
+	
+	/**
+	 * 写CSV文件，只写入一行
+	 *
+	 */
+	public static boolean csvFilePrinter(File file, String charset, String[] values) throws Exception{
+		OutputStreamWriter fos = null;
+        try {
+        	fos = new OutputStreamWriter(
+    				new FileOutputStream(file), charset);
+    		
+    		
+    		ExcelCSVPrinter ecsvp = new ExcelCSVPrinter(fos);
+            ecsvp.changeDelimiter(',');
+            ecsvp.setAutoFlush(true);
+			ecsvp.writeln(values);
+			
+			fos.flush();
+		} catch (IOException e) {
+			throw e;
+		}finally {
+			if(fos!=null){
+				try {
+					fos.close();
+				} catch (IOException e) {
+				}
+			}
+		}
+		
+		return true;
+	}
+	
+	/**
+	 * 写CSV文件，写入多行
+	 * 
+	 */
+	public static boolean csvFilePrinter(File file, String charset, List<String[]> values) throws Exception{
+		OutputStreamWriter fos = null;
+        try {
+        	fos = new OutputStreamWriter(
+    				new FileOutputStream(file), charset);
+    		
+    		
+    		ExcelCSVPrinter ecsvp = new ExcelCSVPrinter(fos);
+            ecsvp.changeDelimiter(',');
+            ecsvp.setAutoFlush(true);
+            for(String[] val : values){
+            	ecsvp.writeln(val);
+            }
+			
+			fos.flush();
+		} catch (IOException e) {
+			throw e;
+		}finally {
+			if(fos!=null){
+				try {
+					fos.close();
+				} catch (IOException e) {
+				}
+			}
+		}
+		
+		return true;
+	}
+	
+	/**
+	 * 解析CSV文件中的指定行
+	 * 
+	 */
+	public static String[] csvFileParser(File file, String charset, int rowNum) throws Exception{
+		Reader in = null;
+		String[] currLine = null;
+        try {
+        	 //创建解析信息流
+            in = new InputStreamReader(new FileInputStream(file),charset); 
+    		
+            ExcelCSVParser csvParser = new ExcelCSVParser(in);
+            while((currLine=csvParser.getLine())!=null){
+            	if(rowNum != csvParser.getLastLineNumber()){
+            		currLine = null;
+            	}
+            }
+			
+		} catch (IOException e) {
+			throw e;
+		}finally {
+			if(in!=null){
+				try {
+					in.close();
+				} catch (IOException e) {
+				}
+			}
+		}
+		
+		return currLine;
+	}
+	
+	/**
+	 * 解析CSV文件的所有行
+	 * 
+	 */
+	public static List<String[]> csvFileParser(File file, String charset) throws Exception{
+		Reader in = null;
+		List<String[]> allLineList = new ArrayList<String[]>();
+        try {
+        	 //创建解析信息流
+            in = new InputStreamReader(new FileInputStream(file),charset);
+    		
+            ExcelCSVParser csvParser = new ExcelCSVParser(in);
+            String[] currLine = null;
+            while((currLine=csvParser.getLine())!=null){
+            	allLineList.add(currLine);
+            }
+			
+		} catch (IOException e) {
+			throw e;
+		}finally {
+			if(in!=null){
+				try {
+					in.close();
+				} catch (IOException e) {
+				}
+			}
+		}
+		
+		return allLineList;
+	}
+	
+}