using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Collections;
using System.Data;
using System.IO;
using System.Reflection;
using System.ComponentModel;
namespace Neusoft.Core.Neusoft.Core.Utils
{
/// <summary>
/// //讀CSV文件類,讀取指定的CSV文件，可以導出DataTable..........add by chujianqin
/// </summary>
public class CsvStreamReader
{
private ArrayList rowAL; //行鏈表,CSV文件的每一行就是一個鏈
private string fileName; //文件名
public DataTable csvDT = new DataTable();
private Encoding encoding; //編碼
public DataTable table = new DataTable();
bool IsFirst = true;
List<ArrayList> arry = new List<ArrayList>();
public CsvStreamReader()
{
this.rowAL = new ArrayList();
this.fileName = "";
this.encoding = Encoding.Default;
}
/// <summary>
///
/// </summary>
/// <param name="fileName">文件名,包括文件路徑</param>
public CsvStreamReader(string fileName)
{
this.rowAL = new ArrayList();
this.fileName = fileName;
this.encoding = Encoding.Default;
LoadCsvFile();
DataView dataView = csvDT.DefaultView;
dataView.Sort = "ID desc";
csvDT = dataView.ToTable();
}
/// <summary>
///
/// </summary>
/// <param name="fileName">文件名,包括文件路徑</param>
/// <param name="encoding">文件編碼</param>
public CsvStreamReader(string fileName, Encoding encoding)
{
this.rowAL = new ArrayList();
this.fileName = fileName;
this.encoding = encoding;
LoadCsvFile();
}
/// <summary>
/// 載入CSV文件
/// </summary>
private void LoadCsvFile()
{
//對數據的有效性進行驗證
if (this.fileName == null)
{
throw new Exception("請指定要載入的CSV文件名");
}
else if (!File.Exists(this.fileName))
{
throw new Exception("指定的CSV文件不存在");
}
else
{
}
if (this.encoding == null)
{
this.encoding = Encoding.Default;
}
DataTable dt = new DataTable();
StreamReader sr = new StreamReader(this.fileName, this.encoding);
string csvDataLine;
csvDataLine = "";
while (true)
{
string fileDataLine;
fileDataLine = sr.ReadLine();
if (fileDataLine == null)
{
break;
}
if (csvDataLine == "")
{
csvDataLine = fileDataLine;//GetDeleteQuotaDataLine(fileDataLine);
}
else
{
csvDataLine += "\r\n" + fileDataLine;//GetDeleteQuotaDataLine(fileDataLine);
}
//如果包含偶數個引號，說明該行數據中出現回車符或包含逗號
if (!IfOddQuota(csvDataLine))
{
AddNewDataLine(csvDataLine);
csvDataLine = "";
}
}
sr.Close();
//數據行出現奇數個引號
if (csvDataLine.Length > 0)
{
throw new Exception("CSV文件的格式有錯誤");
}
}
/// <summary>
/// 獲取兩個連續引號變成單個引號的數據行
/// </summary>
/// <param name="fileDataLine">文件數據行</param>
/// <returns></returns>
private string GetDeleteQuotaDataLine(string fileDataLine)
{
return fileDataLine.Replace("\"\"", "\"");
}
/// <summary>
/// 判斷字符串是否包含奇數個引號
/// </summary>
/// <param name="dataLine">數據行</param>
/// <returns>為奇數時，返回為真；否則返回為假</returns>
private bool IfOddQuota(string dataLine)
{
int quotaCount;
bool oddQuota;
quotaCount = 0;
for (int i = 0; i < dataLine.Length; i++)
{
if (dataLine[i] == '\"')
{
quotaCount++;
}
}
oddQuota = false;
if (quotaCount % 2 == 1)
{
oddQuota = true;
}
return oddQuota;
}
/// <summary>
/// 判斷是否以奇數個引號開始
/// </summary>
/// <param name="dataCell"></param>
/// <returns></returns>
private bool IfOddStartQuota(string dataCell)
{
int quotaCount;
bool oddQuota;
quotaCount = 0;
for (int i = 0; i < dataCell.Length; i++)
{
if (dataCell[i] == '\"')
{
quotaCount++;
}
else
{
break;
}
}
oddQuota = false;
if (quotaCount % 2 == 1)
{
oddQuota = true;
}
return oddQuota;
}
/// <summary>
/// 判斷是否以奇數個引號結尾
/// </summary>
/// <param name="dataCell"></param>
/// <returns></returns>
private bool IfOddEndQuota(string dataCell)
{
int quotaCount;
bool oddQuota;
quotaCount = 0;
for (int i = dataCell.Length - 1; i >= 0; i--)
{
if (dataCell[i] == '\"')
{
quotaCount++;
}
else
{
break;
}
}
oddQuota = false;
if (quotaCount % 2 == 1)
{
oddQuota = true;
}
return oddQuota;
}
/// <summary>
/// 加入新的數據行
/// </summary>
/// <param name="newDataLine">新的數據行</param>
private void AddNewDataLine(string newDataLine)
{
int Column = 0;
DataRow Row = csvDT.NewRow();
ArrayList colAL = new ArrayList();
string[] dataArray = newDataLine.Split(',');
bool oddStartQuota; //是否以奇數個引號開始
string cellData;
oddStartQuota = false;
cellData = "";
for (int j = 0; j < dataArray.Length; j++)
{
if (IsFirst)
{
DataColumn dc = new DataColumn(dataArray[j]);
csvDT.Columns.Add(dc);
}
else
{
if (oddStartQuota)
{
//因為前面用逗號分割,所以要加上逗號
cellData += "," + dataArray[j];
//是否以奇數個引號結尾
if (IfOddEndQuota(dataArray[j]))
{
Row[Column] = GetHandleData(cellData);
Column++;
oddStartQuota = false;
continue;
}
}
else
{
//是否以奇數個引號開始
if (IfOddStartQuota(dataArray[j]))
{
//是否以奇數個引號結尾,不能是一個雙引號,並且不是奇數個引號
if (IfOddEndQuota(dataArray[j]) && dataArray[j].Length > 2 && !IfOddQuota(dataArray[j]))
{
Row[Column] = GetHandleData(dataArray[j]);
Column++;
oddStartQuota = false;
continue;
}
else
{
oddStartQuota = true;
cellData = dataArray[j];
continue;
}
}
else
{
Row[Column] = GetHandleData(dataArray[j]);
Column++;
}
}
}
}
if (!IsFirst)
{
this.csvDT.Rows.Add(Row);
}
IsFirst = false;
if (oddStartQuota)
{
throw new Exception("數據格式有問題");
}
}
/// <summary>
/// 去掉格子的首尾引號，把雙引號變成單引號
/// </summary>
/// <param name="fileCellData"></param>
/// <returns></returns>
private string GetHandleData(string fileCellData)
{
if (fileCellData == "")
{
return "";
}
if (IfOddStartQuota(fileCellData))
{
if (IfOddEndQuota(fileCellData))
{
return fileCellData.Substring(1, fileCellData.Length - 2).Replace("\"\"", "\""); //去掉首尾引號，然后把雙引號變成單引號
}
else
{
throw new Exception("數據引號無法匹配" + fileCellData);
}
}
else
{
//考慮形如"" """" """"""
if (fileCellData.Length > 2 && fileCellData[0] == '\"')
{
fileCellData = fileCellData.Substring(1, fileCellData.Length - 2).Replace("\"\"", "\""); //去掉首尾引號，然后把雙引號變成單引號
}
}
return fileCellData;
}
}
}