1 /// <summary> 
  2 /// 通用函数,读文本文件 
  3 /// </summary> 
  4 /// <param name="fileName">读入的文本文件名称</param> 
  5     public static void ReadTextFromFileName(string fileName)     
  6     { 
  7       string strRecord = ""; 
  8  
  9       //读入文本文件时,一定要指定文件的编码格式.其中:default为文本文件本来的编码格式 
 10 //如果是简体中文的文本文件,也可以这样设置编码格式: System.Text.Encoding.GetEncode("gb2312") 
 11 //Encoding.GetEncode("gb2312")为简体中文编码格式,Encoding.GetEncode("big5")为繁体中文编码格式. 
 12       StreamReader reader = new StreamReader(fileName,System.Text.Encoding.Default); 
 13                          
 14       da = new DataAccess(); 
 15       da.OpenConnection(); 
 16  
 17       //指定本次数据操作进行事务处理 
 18       da.StartTrans = true; 
 19  
 20       //开始事务处理 
 21       da.BeginTrans(); 
 22  
 23       //i is the really row 
 24 //j is the row of writed to database 
 25       int i ,j; 
 26       i=0; 
 27       j=0; 
 28       try 
 29       {         
 30         while (reader.Peek() >= 0) 
 31         {            
 32           strRecord = reader.ReadLine(); 
 33           if (StringConvertByteArray(strRecord)) 
 34           { 
 35             j++; 
 36           } 
 37           i++; 
 38         }    
 39         
 40         //执行事务 
 41         da.Commit(); 
 42  
 43         TotalLine = i; 
 44         RealLine = j; 
 45       } 
 46       catch (Exception ex) 
 47       { 
 48         //事务回滚 
 49         da.Rollback(); 
 50  
 51  
 52         SystemError.SystemLog("文件:" + fileName +"导入失败,错误行是第"+ i.ToString()+ "行,原因是: " + ex.Message); 
 53         throw new Exception(ex.Message); 
 54       } 
 55  
 56             //相关资源的消除 
 57       finally 
 58       {                
 59         reader.Close(); 
 60         da.CloseConnection();         
 61       } 
 62     } 
 63  
 64  
 65     /// <summary> 
 66 /// 处理定长文本文件的函数,将字符串转换成byte[]数组 
 67 /// </summary> 
 68 /// <param name="aRecord"></param> 
 69     private static bool StringConvertByteArray(string aRecord) 
 70     { 
 71       //解决文本文件一行中可能存在中文的情况,将string类型转换为byte[]来达到 
 72 //正确处理文本文件的目的 
 73       byte[] repRecord = System.Text.Encoding.Default.GetBytes(aRecord); 
 74         
 75       //判断取得的文本文件长度是否等于定义的文本文件长度 
 76       if (repRecord.Length    != iLineLength) 
 77       { 
 78         SystemError.SystemLog("文件:" + fileName +"导入出错,出错原因是文件长度不符合"); 
 79         throw new Exception("文件文本长度不对,导入失败,请检查文件文件格式"); 
 80       } 
 81  
 82       bool isInsert=false; 
 83       isInsert = AddRecord( 
 84         GetString(repRecord,0,8),    
 85         GetString(repRecord,8,8), 
 86         GetString(repRecord,16,6), 
 87         GetString(repRecord,22,6), 
 88         GetString(repRecord,28,8), 
 89         GetString(repRecord,36,6), 
 90         GetString(repRecord,42,10), 
 91         GetString(repRecord,52,4), 
 92         GetString(repRecord,56,6), 
 93         GetString(repRecord,62,8), 
 94         GetString(repRecord,70,7), 
 95         GetString(repRecord,77,32), 
 96         GetString(repRecord,109,72), 
 97         GetString(repRecord,181,8), 
 98         GetString(repRecord,189,30), 
 99         GetString(repRecord,219,45), 
100         GetString(repRecord,264,10), 
101         GetString(repRecord,274,25), 
102         GetString(repRecord,299,2), 
103         GetString(repRecord,301,25), 
104         GetString(repRecord,326,3), 
105         GetString(repRecord,329,15), 
106         GetString(repRecord,344,1), 
107         GetString(repRecord,345,8), 
108         GetString(repRecord,353,6), 
109         GetString(repRecord,359,8), 
110         GetString(repRecord,367,1), 
111         GetString(repRecord,368,1), 
112         GetString(repRecord,369,32), 
113         GetString(repRecord,401,7), 
114         GetString(repRecord,408,60), 
115         GetString(repRecord,468,20), 
116         GetString(repRecord,488,20),         
117         GetString(repRecord,508,20), 
118         GetString(repRecord,528,36), 
119         GetString(repRecord,564,15), 
120         GetString(repRecord,579,15), 
121         GetString(repRecord,594,15) 
122         ); 
123       return isInsert; 
124                              
125     } 
126      
127                  
128     //private static void    
129                 /// <summary> 
130 /// 处理长度固定的文本文,读取到每个字段的值 
131 /// </summary> 
132 /// <param name="aStr">文本文件的每行文本转换的Byte数组</param> 
133 /// <param name="iStart">读取的起始位置</param> 
134 /// <param name="iLength">读取的长度</param> 
135 /// <returns>返回的字符串,对应于具体的字段值</returns> 
136     private static string GetString(byte[] aStr,int iStart,int iLength) 
137     { 
138  
139       byte[] tempStr = new byte[iLength]; 
140       for ( int i = 0; i < iLength; i ++) 
141       { 
142         tempStr[i] = (byte)aStr.GetValue(iStart + i);         
143       } 
144  
145       return System.Text.Encoding.Default.GetString(tempStr); 
146     }