Update Reader.cs
This commit is contained in:
@@ -31,15 +31,7 @@ namespace BoerseDataConvert
|
|||||||
string s = reader.ReadLine();
|
string s = reader.ReadLine();
|
||||||
if (reader.EndOfStream)
|
if (reader.EndOfStream)
|
||||||
{
|
{
|
||||||
CheckFinalLine(s);
|
s = NextFile(s);
|
||||||
EndFile();
|
|
||||||
fileInd++;
|
|
||||||
stopwatch.Start();
|
|
||||||
reader = new StreamReader($@"{adr}/{filesNames[fileInd]}", CodePagesEncodingProvider.Instance.GetEncoding(1252));
|
|
||||||
RecordController.NextFile(filesNames[fileInd]);
|
|
||||||
string date = reader.ReadLine();
|
|
||||||
CheckFirstLine(date);
|
|
||||||
s = reader.ReadLine();
|
|
||||||
}
|
}
|
||||||
string[] sr = s.Split("|").ToArray();
|
string[] sr = s.Split("|").ToArray();
|
||||||
Record record = new Record();
|
Record record = new Record();
|
||||||
@@ -50,6 +42,19 @@ namespace BoerseDataConvert
|
|||||||
}
|
}
|
||||||
return record;
|
return record;
|
||||||
}
|
}
|
||||||
|
private string NextFile(string s)
|
||||||
|
{
|
||||||
|
CheckFinalLine(s);
|
||||||
|
EndFile();
|
||||||
|
fileInd++;
|
||||||
|
stopwatch.Start();
|
||||||
|
reader = new StreamReader($@"{adr}/{filesNames[fileInd]}", CodePagesEncodingProvider.Instance.GetEncoding(1252));
|
||||||
|
RecordController.NextFile(filesNames[fileInd]);
|
||||||
|
string date = reader.ReadLine();
|
||||||
|
CheckFirstLine(date);
|
||||||
|
s = reader.ReadLine();
|
||||||
|
return s;
|
||||||
|
}
|
||||||
private void CheckFirstLine(string date)
|
private void CheckFirstLine(string date)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
|
|||||||
Reference in New Issue
Block a user