using System;
using System.IO;
using System.Messaging;
using System.Net.Http;
using System.Text;
using System.Windows.Forms;
using NeoEnergiaRequester.NeoEnergiaScrapper;
using NeoEnergiaRequester.NeoEnergiaScrapper.DTO;
using NeoEnergiaRequester.NeoEnergiaScrapper.Performace;
namespace NeoEnergiaRequester
{
internal class Program
{
private static void Main(string[] args)
{
var needLogin = true;
var scrapper = new Scrapper();
var performace = new PerformaceHandler();
var contrats = new []
{
}
while (true)
{
var perfFile = new StreamWriter(ConfigSettings.PERF_LOG_FILE, true);
performace.StartCounting();
var begin = DateTime.Now;
var receiveQueue = new MessageQueue(ConfigSettings.INPUT_QUEUE)
{
Formatter = new XmlMessageFormatter(new []{typeof(StartInfo)})
};
var info = new StartInfo { Empresa = "CELPE", NumeroContrato = "2643852023" };//receiveQueue.Receive().Body as StartInfo;
Console.Write("Processando..." + info.NumeroContrato);
if (begin.AddMinutes(20) < DateTime.Now) needLogin = true;
try
{
var billDto = scrapper.Scrap(info, needLogin);
perfFile.WriteLine("{0};{1};{2}",
info.NumeroContrato, performace.StopCounting(), "SUCCESS");
Console.Write(" Sucesso!");
Console.Write("\n");
var sendQueue = new MessageQueue(ConfigSettings.OUTPUT_QUEUE);
sendQueue.Send(billDto);
}
catch (AggregateException ex)
{
HandleException(info, ex, performace.StopCounting());
perfFile.WriteLine("{0};{1};{2}",
info.NumeroContrato, performace.StopCounting(), "FAIL");
Console.Write(" Falha!");
Console.Write("\n");
}
catch (Exception ex)
{
HandleException(info, ex, performace.StopCounting());
perfFile.WriteLine("{0};{1};{2}",
info.NumeroContrato, performace.StopCounting(), "FAIL");
Console.Write(" Falha!");
Console.Write("\n");
}
finally
{
needLogin = false;
perfFile.Close();
}
}
}
private static void HandleException(StartInfo info, Exception ex, TimeSpan elapsedTime)
{
var sendQueue = new MessageQueue(ConfigSettings.FAIL_QUEUE);
sendQueue.Send(info);
using (var stream = new StreamWriter(ConfigSettings.FAIL_LOG_FILE, true))
{
stream.WriteLine("Contract: {0}\nTime of Error: {1}\nException: {2}",
info.NumeroContrato, DateTime.Now,
ex.InnerException == null
? ex.StackTrace
: ex.InnerException.Message);
}
if (ex.InnerException == null || ex.InnerException.GetType() != typeof(HttpRequestException)) return;
}
private static string GenerateString(BillDto bill)
{
var sbuilder = new StringBuilder();
foreach (var property in bill.GetType().GetProperties())
{
sbuilder.Append(property.Name);
sbuilder.Append(" : ");
sbuilder.Append(property.GetValue(bill, null));
sbuilder.Append(Environment.NewLine);
}
return sbuilder.ToString();
}
}
}
