mcarman
/
jdis_import
1
0
複製 0
程式碼 問題管理 0 合併請求 0 版本發佈 1 Wiki Activity
Replacement for JDIS Importer
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
36 Commit
2 分支
191 MiB
 
分支: APIIntegration
分支列表 標籤列表
${ item.name }
Create branch ${ searchTerm }
from 'APIIntegration'
${ noResults }
jdis_import/Program.cs

1205 line
58 KiB
原始文件 永久連結 Blame 文件歷史 

  1. using System.Collections.Generic;

  2. using System;

  3. using System.Text;

  4. using System.Threading.Tasks;

  5. using Microsoft.Identity.Client;

  6. using Microsoft.Exchange.WebServices.Data;

  7. using System.IO;

  8. using System.Data;

  9. using System.Data.SqlClient;

  10. using System.Reflection;

  11. using jdis_import.RESTObjects;

  12. using System.Linq;

  13. using System.Net;

  14. 

  15. /*

  16. Secret Value up-8Q~y46~JyQZjJlsAJ-zpXpglpmuPIJ1Gx3a2O

  17. Secret ID cba04a6c-a233-4646-909b-b50921edbe1c

  18. Client ID 489776b1-ee79-4b14-bc44-9f6bf47332db

  19. Object ID c7647074-edb6-4e8e-8a01-a1ed924fdae9

  20. Tenant ID 1fd06c96-d3a4-45e9-9ed7-bcecb394d277

  21. */

  22. 

  23. namespace jdis_import

  24. {

  25.     class Program

  26.     {

  27.         private static JSONSetting _settings;

  28.         private static string _os, _logDir, _logFile, _successDir, _failureDir, _downloadDir;

  29.         private static bool _runAPI = true;

  30.         private static RESTService _rservice;

  31.         private static List<User> _users;

  32.         private static Priority _priority;

  33.         private static Reason _reason;

  34.         private static Status _status;

  35.         private static List<Equipment> _machines;

  36.         private static List<Customer> _customers;

  37.         private static List<Make> _makes;

  38.         private static List<Product> _products;

  39.         private static List<Model> _models;

  40.         private static List<InspectionType> _inspectionTypes;

  41.         private static List<Template> _templates;

  42.         private static string _exeDir;

  43.         private static bool _log = true;

  44.         private static string _connection = "Data Source=192.168.0.7;Initial Catalog=Connexion_Brandt;User ID=mobilepmuser;Password=data4techs;Encrypt=No;TrustServerCertificate=true;Persist Security Info=True;";

  45.         private static string _workOrderNumber = string.Empty;

  46.         private static List<string> _sqlMessages = new List<string>();

  47.         private static bool _newMachine = false;

  48.         private static bool _newMake = false;

  49.         private static bool _newModel = false;

  50.         private static bool _newCustomer = false;

  51.         private static bool _quoted = false;

  52.         public static string ExeDir { get { return _exeDir; } }

  53.         private static Dictionary<string, string> _keys = new Dictionary<string, string>() { { "SecretV", "up-8Q~y46~JyQZjJlsAJ-zpXpglpmuPIJ1Gx3a2O" }, { "SecretID", "cba04a6c-a233-4646-909b-b50921edbe1c" }, { "ObjectId", "c7647074-edb6-4e8e-8a01-a1ed924fdae9" }, { "TenentID", "1fd06c96-d3a4-45e9-9ed7-bcecb394d277" }, { "AppID", "489776b1-ee79-4b14-bc44-9f6bf47332db" } };

  54.         public static Dictionary<string, int> InspectionType;

  55. 

  56.         private static Customer CreateNewCustomer(CustomerImport c, ToDo todo)

  57.         {

  58.             Customer cust = new Customer();

  59.             cust.Name = c.Name;

  60.             cust.Address = c.Addr1;

  61.             cust.Address2 = c.Addr2;

  62.             cust.City = c.City;

  63.             cust.State = c.State;

  64.             cust.CreateDate = DateTime.Now;

  65.             cust.CreateUserID = -1;

  66.             cust.UpdateDate = DateTime.Now;

  67.             cust.UpdateUserID = -1;

  68.             cust.IsActive = true;

  69.             cust.Number = c.Number;

  70.             cust.ZipCode = c.Zip;

  71.             string json = Serialize.ToJson<Customer>(cust);

  72.             cust = _rservice.PostRest<Customer>(json, "customers.svc");

  73.             return cust;

  74.         }

  75.         private static Model CreateNewModel(Product defaultP, EquipmentImport eq, ToDo todo)

  76.         {

  77.             Model mdl = new Model();

  78.             //Find the Make and assign the default Product

  79.             mdl.Name = eq.Model.Trim();

  80.             mdl.IsActive = true;

  81.             mdl.CreateDate = DateTime.Now;

  82.             mdl.CreateUserID = -1;

  83.             mdl.UpdateDate = DateTime.Now; ;

  84.             mdl.UpdateUserID = -1;

  85.             mdl.Product = defaultP;

  86.             Make mk = (from x in _makes where x.Name.Trim() == eq.Make.Trim() select x).FirstOrDefault();

  87.             if (mk == null)

  88.             {

  89.                 //Create new Make

  90.                 mk.Name = eq.Make.Trim();

  91.                 mk.CreateDate = DateTime.Now;

  92.                 mk.CreateUserID = -1;

  93.                 mk.UpdateDate = DateTime.Now;

  94.                 mk.UpdateUserID = -1;

  95.                 mk.IsActive = true;

  96.                 mk.Description = eq.Make.Trim();

  97.                 string mkJson = Serialize.ToJson<Make>(mk);

  98.                 mk = _rservice.PostRest<Make>(mkJson, "makes.svc");

  99. 

  100.             }

  101.             mdl.Make = mk;

  102.             string json = Serialize.ToJson<Model>(mdl);

  103.             mdl = _rservice.PostRest<Model>(json, "models.svc");

  104.             return mdl;

  105.         }

  106.         private static Equipment CreateNewMachine(EquipmentImport eq, Model mdl, Customer cust, ToDo todo)

  107.         {

  108.             Equipment newMachine = new Equipment();

  109.             newMachine.Model = mdl;

  110.             newMachine.Make = mdl.Make;

  111.             newMachine.Product = mdl.Product;

  112.             newMachine.BarcodeID = null;

  113.             newMachine.CreateDate = DateTime.Now;

  114.             newMachine.UpdateDate = DateTime.Now;

  115.             newMachine.UpateUserID = -1;

  116.             newMachine.CreateUserID = -1;

  117.             newMachine.Description = eq.SerialNumber;

  118.             newMachine.IsActive = true;

  119.             newMachine.LastServiceDate = null;

  120.             newMachine.Location = null;

  121.             newMachine.ManufacturerYear = "2000";

  122.             newMachine.MeterReading = eq.MeterReading;

  123.             newMachine.Number = eq.EquipmentNumber;

  124.             newMachine.Odometer = null;

  125.             newMachine.SerialNumber = eq.SerialNumber;

  126.             newMachine.Customer = cust;

  127.             string eqJson = Serialize.ToJson<Equipment>(newMachine);

  128.             newMachine = _rservice.PostRest<Equipment>(eqJson, "Equipments.svc");

  129.             return newMachine;

  130.         }

  131.         public static void APIPush(CustomerImport c, WorkOrderImport wo, List<PartImport> parts, EquipmentImport eq, ToDo todo)

  132.         {

  133.             Equipment machine = new Equipment();

  134.             Model mdl = _models.Find(x => x.Name.Trim() == eq.Model.Trim());

  135.             Product defaultP = _products.Find(x => x.ID == 14);

  136.             //Customer cust = new Customer();

  137.             Customer cust = IsNewCustomer(c.Name);

  138.             if (cust == null)

  139.                 cust = CreateNewCustomer(c, todo);

  140.             List<Equipment> equipment = IsNewMachine(eq.SerialNumber);

  141.             _newMachine = equipment.Count == 0;

  142.             if (_newMachine)

  143.             {

  144.                 bool isNewModel = mdl == null;

  145.                 if (isNewModel)

  146.                 {

  147.                     string sModel = eq.Model.Trim().Substring(0, eq.Model.Length - 1);

  148.                     mdl = (from x in _models where x.Name.Contains(sModel) orderby x.ID select x).LastOrDefault();

  149.                     if (mdl == null)

  150.                         mdl = CreateNewModel(defaultP, eq, todo);

  151.                     else

  152.                         machine = CreateNewMachine(eq, mdl, cust, todo);

  153.                 }

  154.                 else

  155.                 {

  156.                     machine = CreateNewMachine(eq, mdl, cust, todo);

  157.                 }

  158.             }

  159.             else

  160.             {

  161.                 machine = equipment.FindAll(x => x.SerialNumber == eq.SerialNumber).LastOrDefault();

  162.                 machine.Customer = cust;

  163. 

  164.             }

  165.             //Find the Template

  166.             Template template = _templates.Find(x => x.InspectionLevel.ID == Convert.ToInt32(wo.InspectionLevel) && x.InspectionType.ID == Convert.ToInt32(wo.InspectionType) && x.Name == eq.Model);

  167.             if (template == null)

  168.             {

  169.                 //Search by model prefix and get the last one

  170.                 string prefix = eq.Model.Trim();

  171.                 prefix = prefix.Substring(0, prefix.Length - 1);

  172.                 template = (from x in _templates where x.InspectionLevel.ID == Convert.ToInt32(wo.InspectionLevel) && x.InspectionType.ID == Convert.ToInt32(wo.InspectionType) && x.Name.Contains(prefix) orderby x.ID select x).LastOrDefault();

  173.                 if (template == null || template.ID == 0)

  174.                 {

  175.                     todo.Success = false;

  176.                     todo.Validation = todo.Validation + " No template for this model.";

  177.                 }

  178. 

  179.             }

  180.             User user = _users.Find(x => x.Number == wo.TechnicianUserID.Trim());

  181.             WorkOrder workorder = new WorkOrder();

  182.             workorder.Number = wo.Number;

  183. 

  184.             workorder.Technician = user;

  185.             workorder.Reason = _reason;

  186.             workorder.Priority = _priority;

  187.             workorder.Status = _status;

  188.             workorder.CreateDate = DateTime.Now;

  189.             workorder.CreateUserID = -1;

  190.             workorder.Equipment = machine;

  191.             workorder.Customer = cust;

  192.             workorder.MeterReading = Convert.ToDecimal(eq.MeterReading);

  193.             workorder.ScheduledStartDate = wo.OpnDt;

  194.             workorder.ScheduledEndDate = wo.OpnDt.AddDays(1d);

  195.             workorder.UpdateDate = DateTime.Now;

  196.             workorder.UpdateUserID = -1;

  197.             string woJson = Serialize.ToJson<WorkOrder>(workorder);

  198.             //Console.WriteLine("WorkOrder Object");

  199.             //Console.WriteLine();

  200.             //Console.WriteLine(woJson);

  201.             JDISLog.WriteToLog(_logFile, string.Format("Creating Work Order: {0}", workorder.Number));

  202.             workorder = _rservice.PostRest<WorkOrder>(woJson, "workorders.svc");

  203.             if (template == null || template.ID == 0)

  204.             {

  205.                 todo.Validation = todo.Validation + Environment.NewLine + string.Format("Work Order {0} was created but there is no template matching model # {1}", workorder.Number, mdl.Name);

  206.                 todo.Success = false;

  207.             }

  208.             else

  209.             {

  210.                 JDISLog.WriteToLog(_logFile, String.Format("Creating Inspections for Workorder {0}", workorder.Number));

  211.                 Dictionary<string, string> tps = new Dictionary<string, string>();

  212.                 tps.Add("create", string.Format("{0}/{1}/{2}", template.ID, workorder.ID, -1));

  213.                 Inspection i = _rservice.RestGet<Inspection>(true, "inspections.svc", tps);

  214.                 tps["create"] = string.Format("{0}/{1}/{2}", 1691, workorder.ID, -1);

  215.                 Inspection sta = _rservice.RestGet<Inspection>(true, "inspections.svc", tps);

  216.                 if (i != null && i.ID != 0)

  217.                 {

  218.                     todo.Success = true;

  219.                 }

  220.             }

  221. 

  222.         }

  223.         private static Customer IsNewCustomer(string name)

  224.         {

  225.             List<Customer> list = _customers.FindAll(x => x.Name.Trim() == name.Trim());

  226.             if (list.Count > 1)

  227.                 return list.LastOrDefault();

  228.             else if (list.Count == 1)

  229.                 return list[0];

  230.             else return null;

  231. 

  232. 

  233.         }

  234.         private static List<Equipment> IsNewMachine(string serial)

  235.         {

  236.             Dictionary<string, string> ps = new Dictionary<string, string>();

  237.             ps.Add("search", serial);

  238. 

  239.             _machines = _rservice.RestGet<Equipment>("equipments.svc", ps);

  240. 

  241.             return _machines;

  242.         }

  243.         private static void ListsAndDefaults()

  244.         {

  245.             _rservice = new RESTService();

  246.             _rservice.BaseUrl = _settings.Prelub.ActiveService;

  247.             _customers = _rservice.RestGet<Customer>("customers.svc");

  248.             _makes = _rservice.RestGet<Make>("makes.svc");

  249.             _products = _rservice.RestGet<Product>("products.svc");

  250.             _models = _rservice.RestGet<Model>("models.svc");

  251.             _inspectionTypes = _rservice.RestGet<InspectionType>("inspectionTypes.svc");

  252.             _templates = _rservice.RestGet<Template>("templates.svc");

  253.             _users = _rservice.RestGet<User>("users.svc");

  254.             _status = new Status();

  255.             _status.ID = 1;

  256.             _status.Name = "Open";

  257.             _priority = new Priority();

  258.             _priority.ID = 3;

  259.             _priority.Name = "Medium";

  260.             _reason = new Reason();

  261.             _reason.ID = 9;

  262.             _reason.Name = "Cust. Request";

  263.             _reason.IsActive = true;

  264.             _reason.CreateDate = new DateTime(2013, 10, 1, 9, 23, 7);

  265.             _reason.CreateUserID = -1;

  266.             _reason.UpdateDate = new DateTime(2013, 10, 1, 9, 23, 7);

  267.             _reason.UpdateUserID = -1;

  268.         }

  269.         static async System.Threading.Tasks.Task IsLocalNetwork()

  270.         {

  271.             var client = new System.Net.Http.HttpClient();

  272.             try

  273.             {

  274.                 var result = await client.GetAsync(_settings.Prelub.Check);

  275.                 _settings.Prelub.ActiveService = _settings.Prelub.LocalService;

  276.             }

  277.             catch

  278.             {

  279.                 _settings.Prelub.ActiveService = _settings.Prelub.RemoteService;

  280.             }

  281.         }

  282.         static async System.Threading.Tasks.Task Main(string[] args)

  283.         {

  284.             _settings = JSONMethods.GetSettings();

  285.             await IsLocalNetwork();

  286. 

  287. 

  288.             if (IsWindows()) _os = "Windows";

  289.             else if (IsMacOS()) _os = "Mac";

  290.             else if (IsLinux()) _os = "Linux";

  291.             SetupDirectories();

  292.             JDISLog.Begin(_logFile);

  293.             ListsAndDefaults();

  294. 

  295.             //Console.WriteLine("Web APIs have loaded.");

  296.             JDISLog.WriteToLog(_logFile, string.Format("Default data loaded..... {0} {1}", DateTime.Now.ToShortDateString(), DateTime.Now.ToLongTimeString()));

  297.             _exeDir = Environment.CurrentDirectory;

  298. 

  299.             List<ToDo> list = new List<ToDo>();

  300.             var cca = ConfidentialClientApplicationBuilder

  301.                 .Create(_keys["AppID"])

  302.                 .WithClientSecret(_keys["SecretV"])

  303.                 .WithTenantId(_keys["TenentID"])

  304.                 .Build();

  305. 

  306.             var ewsScopes = new string[] { "https://outlook.office365.com/.default" };

  307.             try

  308.             {

  309.                 //Console.WriteLine("Connecting To Exchange.");

  310.                 JDISLog.WriteToLog(_logFile, string.Format("Connectiong to Exchange Server....{0} {1}", DateTime.Now.ToShortDateString(), DateTime.Now.ToLongTimeString()));

  311.                 var authResult = await cca.AcquireTokenForClient(ewsScopes)

  312.                     .ExecuteAsync();

  313. 

  314.                 // Configure the ExchangeService with the access token

  315.                 var ewsClient = new ExchangeService();

  316.                 ewsClient.Url = new Uri("https://outlook.office365.com/EWS/Exchange.asmx");

  317.                 ewsClient.Credentials = new OAuthCredentials(authResult.AccessToken);

  318.                 ewsClient.ImpersonatedUserId = new ImpersonatedUserId(ConnectingIdType.SmtpAddress, "cmobile@prelub.com");

  319.                 Mailbox mb = new Mailbox("connexionmobile@rpmindustries.org");

  320.                 FolderId fid = new FolderId(WellKnownFolderName.Inbox, mb);

  321.                 List<SearchFilter> searchFilterCollection = new List<SearchFilter>();

  322.                 string[] filters = "Brandt Import;BRANDT IMPORT;brandt import;TEST Brandt".Split(';');

  323.                 foreach (string s in filters)

  324.                     searchFilterCollection.Add(new SearchFilter.ContainsSubstring(ItemSchema.Subject, s));

  325. 

  326.                 SearchFilter searchFilter = new SearchFilter.SearchFilterCollection(LogicalOperator.Or, searchFilterCollection.ToArray());

  327.                 ItemView view = new ItemView(100);

  328. 

  329.                 view.PropertySet = new PropertySet(BasePropertySet.IdOnly, ItemSchema.Subject, ItemSchema.DateTimeReceived);

  330.                 view.OrderBy.Add(ItemSchema.DateTimeReceived, SortDirection.Descending);

  331.                 view.Traversal = ItemTraversal.Shallow;

  332.                 //Console.WriteLine("Line 90: Finding emails.");

  333. 

  334.                 FindItemsResults<Item> findResults = ewsClient.FindItems(fid, searchFilter, view);

  335.                 List<EmailMessage> messages = new List<EmailMessage>();

  336.                 foreach (EmailMessage message in findResults.Items)

  337.                 {

  338.                     message.Load();

  339.                     if (!message.IsRead)

  340.                         messages.Add(message);

  341.                 }

  342.                 JDISLog.WriteToLog(_logFile, string.Format("Found {0} emails", messages.Count));

  343.                 foreach (EmailMessage msg in findResults.Items)

  344.                 {

  345.                     msg.Load();

  346.                     if (!msg.IsRead)

  347.                     {

  348.                         if (msg.HasAttachments)

  349.                         {

  350.                             foreach (Attachment attachment in msg.Attachments)

  351.                             {

  352.                                 attachment.Load();

  353.                                 if (attachment is FileAttachment)

  354.                                 {

  355.                                     ToDo todo = new ToDo();

  356.                                     todo.Sender = msg.Sender.Address;

  357. 

  358.                                     todo.SenderName = msg.Sender.Name;

  359.                                     todo.FileName = attachment.Name;

  360.                                     list.Add(todo);

  361.                                     //Download File

  362.                                     FileAttachment fAttachment = attachment as FileAttachment;

  363.                                     string fileAttachmentPath = Path.Combine(_downloadDir, fAttachment.Name);

  364.                                     File.WriteAllBytes(fileAttachmentPath, fAttachment.Content);

  365.                                     msg.IsRead = true;

  366.                                     msg.Update(ConflictResolutionMode.AlwaysOverwrite);

  367.                                 }

  368.                             }

  369.                         }

  370.                     }

  371.                 }

  372.                 //Console.WriteLine("Beginning Import.");

  373.                 JDISLog.WriteToLog(_logFile, string.Format("Importing JDIS files....{0} {1}", DateTime.Now.ToShortDateString(), DateTime.Now.ToLongDateString()));

  374.                 foreach (ToDo import in list)

  375.                 {

  376. 

  377.                     BeginImport(import);

  378.                     GetInspectionTypes();

  379.                     ReadFile(import);

  380.                 }

  381.                 foreach (ToDo sendMsg in list)

  382.                 {

  383.                     EmailMessage msgToSend = new EmailMessage(ewsClient);

  384.                     JDISLog.WriteToLog(_logFile, string.Format("Sending Message to: {0}\r\nFor Work Order: {1}\r\nJDIS File: {2}", sendMsg.Sender, sendMsg.WorkOrderNumber, sendMsg.FileName.Substring(sendMsg.FileName.LastIndexOf("/") + 1).Trim()));

  385.                     string body = "JDIS File: {0} Work Order:{1} {2}";

  386.                     if (sendMsg.Success)

  387.                     {

  388.                         body = string.Format(body, sendMsg.FileName.Substring(sendMsg.FileName.LastIndexOf("/") + 1).Trim(), sendMsg.WorkOrderNumber, "Was Imported Successfully");

  389.                     }

  390.                     else

  391.                     {

  392.                         body = string.Format(body, sendMsg.FileName.Substring(sendMsg.FileName.LastIndexOf("/") + 1).Trim(), sendMsg.WorkOrderNumber, string.Format("Had Errors while importing: {0}", sendMsg.Validation));

  393.                         msgToSend.Attachments.AddFileAttachment(Path.Combine(_downloadDir, sendMsg.FileName));

  394. 

  395.                     }

  396.                     string fileNameOnly = sendMsg.FileName.Substring(sendMsg.FileName.LastIndexOf("/") + 1);

  397.                     msgToSend.Subject = fileNameOnly;

  398.                     msgToSend.ToRecipients.Add(new EmailAddress(sendMsg.Sender));

  399.                     msgToSend.CcRecipients.Add(new EmailAddress("mcarman@rpmindustries.com"));

  400.                     msgToSend.Body = body;

  401.                     msgToSend.SendAndSaveCopy();

  402.                     string pathToFile = Path.Combine(_downloadDir, sendMsg.FileName);

  403.                     if (sendMsg.Success) File.Move(pathToFile, Path.Combine(_successDir, fileNameOnly));

  404.                     else File.Move(sendMsg.FileName, Path.Combine(_failureDir, fileNameOnly));

  405.                 }

  406.             }

  407.             catch (MsalException ex)

  408.             {

  409.                 //Console.WriteLine($"Error acquiring access token: {ex}");

  410.                 JDISLog.WriteToLog(_logFile, $"Error acquiring access token: {ex}");

  411.             }

  412.             catch (Exception ex)

  413.             {

  414.                 //Console.WriteLine($"Error: {ex}");

  415.                 JDISLog.WriteToLog(_logFile, $"Error: {ex}");

  416.             }

  417. 

  418.             if (System.Diagnostics.Debugger.IsAttached)

  419.             {

  420.                 Console.WriteLine("Hit any key to exit...");

  421.                 Console.ReadKey();

  422.             }

  423. 

  424. 

  425. 

  426.         }

  427. 

  428.         public static void BeginImport(ToDo todo)

  429.         {

  430.             XMLData.BuildIntervalLookup();

  431.         }

  432.         private static void SetupDirectories()

  433.         {

  434.             OS os = new OS();

  435.             switch (_os)

  436.             {

  437.                 case "Windows":

  438.                     os = _settings.OSs.Find(x => x.Name == "WINDOWS");

  439.                     _logDir = os.Log.Replace("/", "\\");

  440.                     _logFile = Path.Combine(os.Log.Replace("/", "\\"), "jdis.log");

  441.                     _successDir = os.Success.Replace("/", "\\");

  442.                     _failureDir = os.Fail.Replace("/", "\\");

  443.                     _downloadDir = os.Temp.Replace("/", "\\");

  444.                     break;

  445.                 case "Mac":

  446.                     os = _settings.OSs.Find(x => x.Name == "OSX");

  447.                     _logDir = os.Log;

  448.                     _logFile = Path.Combine(os.Log, "jdis.log");

  449.                     _successDir = os.Success;

  450.                     _failureDir = os.Fail;

  451.                     _downloadDir = os.Temp;

  452.                     break;

  453.                 case "Linux":

  454.                     os = _settings.OSs.Find(x => x.Name == "LINUX");

  455.                     _logDir = os.Log;

  456.                     _logFile = Path.Combine(os.Log, "jdis.log");

  457.                     _successDir = os.Success;

  458.                     _failureDir = os.Fail;

  459.                     _downloadDir = os.Temp;

  460.                     break;

  461.                 default:

  462.                     break;

  463.             }

  464.             if (!Directory.Exists(_logDir)) Directory.CreateDirectory(_logDir);

  465.             if (!Directory.Exists(_failureDir)) Directory.CreateDirectory(_failureDir);

  466.             if (!Directory.Exists(_successDir)) Directory.CreateDirectory(_successDir);

  467.             //string path = Path.Combine(_exeDir, "Success");

  468.             //if (!Directory.Exists(path))

  469.             //    Directory.CreateDirectory(path);

  470.             //path = Path.Combine(_exeDir, "Fail");

  471.             //if (!Directory.Exists(path))

  472.             //    Directory.CreateDirectory(path);

  473.             //path = Path.Combine(_exeDir, "Log");

  474.             //if (!Directory.Exists(path))

  475.             //    Directory.CreateDirectory(path);

  476.         }

  477.         public static void GetInspectionTypes()

  478.         {

  479. 

  480.             List<InspectionType> list = _rservice.RestGet<InspectionType>("inspectiontypes.svc");

  481.             InspectionType = new Dictionary<string, int>();

  482.             foreach (InspectionType t in list)

  483.             {

  484.                 InspectionType.Add(t.Name, t.ID);

  485.             }

  486. 

  487.         }

  488.         private static string frmtString

  489.         {

  490.             get

  491.             {

  492.                 if (_quoted) return "\"{0}\"";

  493.                 else return "{0}";

  494.             }

  495.         }

  496.         private static List<string> WriteFileToText(string file)

  497.         {

  498.             List<string> list = new List<string>();

  499.             string txt = string.Empty;

  500.             using (StreamReader sr = new StreamReader(file))

  501.             {

  502.                 txt = sr.ReadToEnd().Trim();

  503.                 txt = txt.Replace("\r\r\r", "");

  504.                 txt = txt.Replace("\r\r", "");

  505.                 txt = txt.Replace("\r", "");

  506.                 sr.Close();

  507.             }

  508.             string[] array = txt.Trim().Split('\n');

  509.             list.AddRange(array);

  510.             return list;

  511.         }

  512.         private static DateTime DateFormatter(string d, bool hastime = true)

  513.         {

  514.             string month, day, year, time;

  515. 

  516.             DateTime dt = new DateTime();

  517.             if (d.IndexOf("JAN") != -1)

  518.             {

  519.                 month = "01";

  520.                 d = d.Replace("JAN", "|");

  521.                 day = d.Substring(0, d.IndexOf("|"));

  522.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  523.                 if (hastime)

  524.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  525.                 else time = "00:00:00.000";

  526. 

  527.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  528.                 dt = DateTime.Parse(date);

  529.             }

  530.             else if (d.IndexOf("FEB") != -1)

  531.             {

  532.                 month = "02";

  533.                 d = d.Replace("FEB", "|");

  534.                 day = d.Substring(0, d.IndexOf("|"));

  535.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  536.                 if (hastime)

  537.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  538.                 else time = "00:00:00.000";

  539. 

  540.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  541.                 dt = DateTime.Parse(date);

  542.             }

  543.             else if (d.IndexOf("MARCH") != -1)

  544.             {

  545.                 month = "03";

  546.                 d = d.Replace("MARCH", "|");

  547.                 day = d.Substring(0, d.IndexOf("|"));

  548.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  549.                 if (hastime)

  550.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  551.                 else time = "00:00:00.000";

  552. 

  553.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  554.                 dt = DateTime.Parse(date);

  555.             }

  556.             else if (d.IndexOf("MAR") != -1)

  557.             {

  558.                 month = "03";

  559.                 d = d.Replace("MAR", "|");

  560.                 day = d.Substring(0, d.IndexOf("|"));

  561.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  562.                 if (hastime)

  563.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  564.                 else time = "00:00:00.000";

  565. 

  566.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  567.                 dt = DateTime.Parse(date);

  568.             }

  569.             else if (d.IndexOf("APRIL") != -1)

  570.             {

  571.                 month = "04";

  572.                 d = d.Replace("APRIL", "|");

  573.                 day = d.Substring(0, d.IndexOf("|"));

  574.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  575.                 if (hastime)

  576.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  577.                 else time = "00:00:00.000";

  578. 

  579.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  580.                 dt = DateTime.Parse(date);

  581.             }

  582.             else if (d.IndexOf("APR") != -1)

  583.             {

  584.                 month = "04";

  585.                 d = d.Replace("APR", "|");

  586.                 day = d.Substring(0, d.IndexOf("|"));

  587.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  588.                 if (hastime)

  589.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  590.                 else time = "00:00:00.000";

  591. 

  592.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  593.                 dt = DateTime.Parse(date);

  594.             }

  595. 

  596.             else if (d.IndexOf("MAY") != -1)

  597.             {

  598.                 month = "05";

  599.                 d = d.Replace("MAY", "|");

  600.                 day = d.Substring(0, d.IndexOf("|"));

  601.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  602.                 if (hastime)

  603.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  604.                 else time = "00:00:00.000";

  605. 

  606.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  607.                 dt = DateTime.Parse(date);

  608.             }

  609.             else if (d.IndexOf("JUNE") != -1)

  610.             {

  611.                 month = "06";

  612.                 d = d.Replace("JUNE", "|");

  613.                 day = d.Substring(0, d.IndexOf("|"));

  614.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  615.                 if (hastime)

  616.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  617.                 else time = "00:00:00.000";

  618. 

  619.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  620.                 dt = DateTime.Parse(date);

  621.             }

  622.             else if (d.IndexOf("JUN") != -1)

  623.             {

  624.                 month = "06";

  625.                 d = d.Replace("JUN", "|");

  626.                 day = d.Substring(0, d.IndexOf("|"));

  627.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  628.                 if (hastime)

  629.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  630.                 else time = "00:00:00.000";

  631. 

  632.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  633.                 dt = DateTime.Parse(date);

  634.             }

  635.             else if (d.IndexOf("JULY") != -1)

  636.             {

  637.                 month = "07";

  638.                 d = d.Replace("JULY", "|");

  639.                 day = d.Substring(0, d.IndexOf("|"));

  640.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  641.                 if (hastime)

  642.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  643.                 else time = "00:00:00.000";

  644. 

  645.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  646.                 dt = DateTime.Parse(date);

  647.             }

  648.             else if (d.IndexOf("JUL") != -1)

  649.             {

  650.                 month = "07";

  651.                 d = d.Replace("JUL", "|");

  652.                 day = d.Substring(0, d.IndexOf("|"));

  653.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  654.                 if (hastime)

  655.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  656.                 else time = "00:00:00.000";

  657. 

  658.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  659.                 dt = DateTime.Parse(date);

  660.             }

  661.             else if (d.IndexOf("AUG") != -1)

  662.             {

  663.                 month = "08";

  664.                 d = d.Replace("AUG", "|");

  665.                 day = d.Substring(0, d.IndexOf("|"));

  666.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  667.                 if (hastime)

  668.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  669.                 else time = "00:00:00.000";

  670. 

  671.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  672.                 dt = DateTime.Parse(date);

  673.             }

  674.             else if (d.IndexOf("SEPT") != -1)

  675.             {

  676.                 month = "09";

  677.                 d = d.Replace("SEPT", "|");

  678.                 day = d.Substring(0, d.IndexOf("|"));

  679.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  680.                 if (hastime)

  681.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  682.                 else time = "00:00:00.000";

  683. 

  684.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  685.                 dt = DateTime.Parse(date);

  686.             }

  687.             else if (d.IndexOf("SEP") != -1)

  688.             {

  689.                 month = "09";

  690.                 d = d.Replace("SEP", "|");

  691.                 day = d.Substring(0, d.IndexOf("|"));

  692.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  693.                 if (hastime)

  694.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  695.                 else time = "00:00:00.000";

  696. 

  697.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  698.                 dt = DateTime.Parse(date);

  699.             }

  700.             else if (d.IndexOf("OCT") != -1)

  701.             {

  702.                 month = "10";

  703.                 d = d.Replace("OCT", "|");

  704.                 day = d.Substring(0, d.IndexOf("|"));

  705.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  706.                 if (hastime)

  707.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  708.                 else time = "00:00:00.000";

  709. 

  710.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  711.                 dt = DateTime.Parse(date);

  712.             }

  713.             else if (d.IndexOf("0CT") != -1)

  714.             {

  715.                 month = "10";

  716.                 d = d.Replace("0CT", "|");

  717.                 day = d.Substring(0, d.IndexOf("|"));

  718.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  719.                 if (hastime)

  720.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  721.                 else time = "00:00:00.000";

  722.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  723.                 dt = DateTime.Parse(date);

  724.             }

  725.             else if (d.IndexOf("NOV") != -1)

  726.             {

  727.                 month = "11";

  728.                 d = d.Replace("NOV", "|");

  729.                 day = d.Substring(0, d.IndexOf("|"));

  730.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  731.                 if (hastime)

  732.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  733.                 else time = "00:00:00.000";

  734. 

  735.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  736.                 dt = DateTime.Parse(date);

  737.             }

  738.             else

  739.             {

  740.                 month = "12";

  741.                 d = d.Replace("DEC", "|");

  742.                 day = d.Substring(0, d.IndexOf("|"));

  743.                 year = d.Substring(d.IndexOf("|") + 1, 4);

  744.                 if (hastime)

  745.                     time = d.Substring(d.IndexOf(":") - 3 + 2);

  746.                 else time = "00:00:00.000";

  747. 

  748.                 string date = string.Format("{0}-{1}-{2} {3}", year, month, day, time);

  749.                 dt = DateTime.Parse(date);

  750.             }

  751.             return dt;

  752.         }

  753.         private static void ReadFile(ToDo todo)

  754.         {

  755.             string file = Path.Combine(_downloadDir, todo.FileName);// todo.FileName;

  756.             todo.FileName = file;

  757.             CustomerImport c = new CustomerImport();

  758.             WorkOrderImport wo = new WorkOrderImport();

  759.             EquipmentImport eq = new EquipmentImport();

  760.             List<PartImport> parts = new List<PartImport>();

  761. 

  762.             //Console.WriteLine("Line 306: " + file);

  763.             //Console.WriteLine("Line 307: " + file);

  764.             string filemove = string.Empty;

  765.             string filetxt = string.Empty;

  766.             string inspectionLevel = string.Empty;

  767.             bool isSpecial = false;

  768.             StringBuilder specialInstructions = new StringBuilder();

  769.             int line = 1;

  770.             try

  771.             {

  772.                 List<string> filelines = WriteFileToText(file);

  773.                 for (int i = filelines.Count - 1; i >= 0; i--)

  774.                 {

  775.                     if (string.IsNullOrEmpty(filelines[i])) filelines.RemoveAt(i);

  776.                 }

  777.                 string[] lines = filelines.ToArray();

  778. 

  779.                 foreach (string s in lines)

  780.                 {

  781. 

  782.                     string currentline = s.Trim().Replace("'", "''");

  783.                     if (currentline.Contains("Page") && currentline.Substring(78).Trim() != "1")

  784.                         line = 18;

  785.                     if (currentline.Contains("Page") && currentline.Substring(78).Trim() == "1")

  786.                         line = 1;

  787. 

  788.                     switch (line)

  789.                     {

  790.                         case 1:

  791.                             string strDate = currentline.Substring(5, currentline.IndexOf("*") - 6);

  792.                             strDate = strDate.Trim();

  793.                             strDate.Replace("  ", " ");

  794.                             wo.CreateDate = DateFormatter(strDate);

  795.                             break;

  796.                         case 2:

  797.                             string strWONum = currentline.Substring(currentline.IndexOf("Work Order") + 10, 12);

  798.                             strWONum = strWONum.Trim();

  799.                             wo.Number = strWONum;

  800.                             todo.WorkOrderNumber = strWONum;

  801.                             _workOrderNumber = strWONum;

  802.                             string strSeg = currentline.Substring(currentline.IndexOf("Seg.") + 4, 25);

  803.                             strSeg = strSeg.Trim();

  804.                             wo.Segment = strSeg;

  805.                             string strODate = currentline.Substring(currentline.IndexOf("Opn Dt") + 6);

  806.                             strODate = strODate.Trim();

  807.                             wo.OpnDt = DateFormatter(strODate, false);

  808.                             break;

  809.                         case 5:

  810.                             c.Name = currentline.Substring(3, 25);

  811.                             c.Number = currentline.Substring(38, 10);

  812.                             break;

  813.                         case 6:

  814.                             c.Addr1 = currentline.Substring(3, 25);

  815.                             break;

  816.                         case 7:

  817.                             c.Addr2 = currentline.Substring(3, 25);

  818.                             break;

  819.                         case 8:

  820.                             int comma = currentline.IndexOf(",");

  821.                             int length = currentline.Length - 3;

  822. 

  823.                             c.City = (comma == -1) ? "" : currentline.Substring(3, comma - 3);

  824.                             c.State = currentline.Substring(currentline.IndexOf(",") + 2, 2);

  825.                             c.Zip = currentline.Substring(comma + 5, 7);

  826.                             break;

  827.                         case 11:

  828.                             eq.Make = currentline.Substring(0, 8).Trim();

  829.                             eq.Model = currentline.Substring(8, 14).Trim();

  830.                             eq.SerialNumber = currentline.Substring(22, 22).Trim();

  831.                             eq.EquipmentNumber = currentline.Substring(42, 16).Trim();

  832.                             eq.MeterReading = currentline.Substring(60, 7).Trim();

  833.                             eq.MID = CSVObject.MachineExists(eq.SerialNumber, _connection);

  834.                             if (eq.MID == 0) _newMachine = true;

  835.                             break;

  836.                         default:

  837.                             break;

  838.                     }

  839. 

  840.                     if (line > 14)

  841.                     {

  842.                         if (currentline.EndsWith(" T"))

  843.                         {

  844.                             if (currentline.Contains("PM LEVEL"))

  845.                             {

  846.                                 isSpecial = false;

  847.                             }

  848.                             else if (currentline.Contains("PM INTERVAL"))

  849.                             {

  850.                                 isSpecial = false;

  851.                                 string pminterval = currentline.Substring(currentline.IndexOf(":") + 2);

  852.                                 pminterval = pminterval.Substring(0, pminterval.IndexOf(" ")).Trim();

  853.                                 if (XMLData.IntervalLookup.ContainsKey(pminterval)) wo.InspectionLevel = XMLData.IntervalLookup[pminterval].ToString();

  854.                                 if (!string.IsNullOrEmpty(wo.InspectionLevel)) wo.InspectionInterval = pminterval;

  855.                                 string strService = currentline.Substring(currentline.IndexOf(":") + 2);

  856.                                 strService = strService.Substring(strService.IndexOf(" ") + 1).Trim();

  857.                                 strService = strService.Substring(0, strService.IndexOf("  ") + 1).Trim();

  858.                                 if (strService.IndexOf(" ") > 0)

  859.                                     strService = strService.Substring(0, strService.IndexOf(" ")).Trim();

  860.                                 if (InspectionType.ContainsKey(strService))

  861.                                     wo.InspectionType = InspectionType[strService].ToString();

  862.                                 else wo.InspectionType = InspectionType["PM"].ToString();

  863.                                 string codeanddescriptionoriginal = currentline.Substring(currentline.IndexOf(":") + 2);

  864.                                 codeanddescriptionoriginal = codeanddescriptionoriginal.Substring(0, codeanddescriptionoriginal.IndexOf("  T") - 3).Trim();

  865.                                 wo.CodeAndDescriptionOriginal = codeanddescriptionoriginal;

  866.                             }

  867.                             else if (currentline.Contains("EMPID"))

  868.                             {

  869.                                 isSpecial = false;

  870.                                 string empid = currentline.Substring(currentline.IndexOf(":") + 2);

  871.                                 empid = empid.Substring(0, empid.IndexOf(" ")).Trim();

  872.                                 wo.TechnicianUserID = empid;

  873.                             }

  874.                             else if (currentline.Contains("PROMISE DATE"))

  875.                             {

  876.                                 isSpecial = false;

  877.                                 string promisedate = currentline.Substring(currentline.IndexOf(":") + 2);

  878.                                 promisedate = promisedate.Substring(0, promisedate.IndexOf(" ")).Trim();

  879.                                 wo.ScheduledStartDate = DateFormatter(promisedate, false);

  880.                             }

  881.                             else if (currentline.Contains("SPECIAL INSTRUCTIONS"))

  882.                             {

  883.                                 isSpecial = true;

  884.                                 string special = currentline.Substring(currentline.IndexOf(":") + 2);

  885.                                 special = special.Substring(0, special.IndexOf("  T") - 1).Trim();

  886.                                 specialInstructions.Append(special);

  887.                             }

  888.                             else

  889.                             {

  890.                                 if (isSpecial)

  891.                                 {

  892.                                     string addspecial = currentline.Substring(0, currentline.IndexOf("  T") - 1).Trim();

  893.                                     specialInstructions.Append(string.Format(" {0}", addspecial));

  894.                                 }

  895.                             }

  896.                         }

  897.                         else

  898.                         {

  899. 

  900.                             isSpecial = false;

  901.                             int qty = 0;

  902. 

  903.                             if (currentline.Length > 0)

  904.                             {

  905.                                 string input = currentline.Substring(0, (currentline.IndexOf(" ") == -1) ? 1 : currentline.IndexOf(" ")).Trim();

  906.                                 if (int.TryParse(input, out qty))

  907.                                 {

  908.                                     if (qty < 100 && !currentline.Contains("HR"))

  909.                                     {

  910.                                         PartImport pt = new PartImport();

  911.                                         string sline = currentline.Substring(19).Trim();

  912.                                         //pt.Description = currentline.Substring(34, 14);

  913.                                         pt.Number = sline.Substring(0, sline.IndexOf(" "));

  914.                                         sline = sline.Substring(sline.IndexOf(" ")).Trim();

  915.                                         pt.Description = sline.Substring(0, sline.IndexOf("  ")).Trim();

  916.                                         pt.Qty = currentline.Substring(0, currentline.IndexOf(" ")).Trim();

  917.                                         parts.Add(pt);

  918.                                     }

  919.                                 }

  920.                             }

  921. 

  922.                         }

  923.                     }

  924.                     line++;

  925.                 }

  926. 

  927.                 if (wo.ScheduledStartDate == DateTime.MinValue) wo.ScheduledStartDate = DateTime.Now;

  928.                 List<CSVObject> list = new List<CSVObject>();

  929.                 List<CSVObject> exceptions = new List<CSVObject>();

  930.                 if (parts.Count == 0)

  931.                 {

  932.                     PartImport p = new PartImport();

  933.                     p.Description = string.Empty;

  934.                     p.Qty = string.Empty;

  935.                     p.Number = string.Empty;

  936.                     parts.Add(p);

  937. 

  938.                 }

  939.                 //Put API Integration here

  940.                 if (_runAPI)

  941.                 {

  942.                     APIPush(c, wo, parts, eq, todo);

  943.                 }

  944.                 else

  945.                 {

  946.                     static void conn_InfoMsg(object sender, SqlInfoMessageEventArgs e)

  947.                     {

  948.                         _sqlMessages.Add(e.Message);

  949.                     }

  950. 

  951.                     foreach (PartImport prt in parts)

  952.                     {

  953.                         CSVObject obj = new CSVObject();

  954.                         obj.Address = string.Format(frmtString, c.Addr1.Trim());

  955.                         obj.Address2 = string.Format(frmtString, c.Addr2.Trim());

  956.                         obj.City = string.Format(frmtString, c.City.Trim());

  957.                         obj.State = string.Format(frmtString, c.State.Trim());

  958.                         obj.CustomerName = string.Format(frmtString, c.Name.Trim());

  959.                         obj.CustomerNumber = string.Format(frmtString, c.Number.Trim());

  960.                         obj.DBSWorkOrderNumber = string.Format(frmtString, wo.Number.Trim());

  961.                         obj.EquipmentNumber = string.Format(frmtString, eq.EquipmentNumber.Trim());

  962.                         obj.Make = string.Format(frmtString, eq.Make.Trim());

  963.                         obj.MeterReading = string.Format(frmtString, eq.MeterReading.Trim());

  964.                         obj.Model = string.Format(frmtString, eq.Model.Trim());

  965.                         obj.PartNumber = string.Format(frmtString, prt.Number.Trim());

  966.                         obj.PartNumberDescription = string.Format(frmtString, prt.Description.Trim());

  967.                         obj.Quantity = string.Format(frmtString, prt.Qty.Trim());

  968.                         obj.SegmentNumber = string.Format(frmtString, wo.Segment.Trim());

  969.                         obj.SerialNumber = string.Format(frmtString, eq.SerialNumber.Trim());

  970.                         obj.ZipCode = string.Format(frmtString, c.Zip.Trim());

  971.                         obj.CodeAndDescription = string.Format(frmtString, wo.InspectionLevel.Trim());

  972.                         obj.SpecialInstructions = specialInstructions.ToString();

  973.                         obj.CodeAndDescriptionOriginal = string.Format(frmtString, wo.CodeAndDescriptionOriginal);

  974.                         obj.ContractTypeCode = string.Format(frmtString, "");

  975.                         obj.DateActualStart = string.Format(frmtString, wo.CreateDate);

  976.                         obj.FamilyCode = string.Format(frmtString, "");

  977.                         obj.FamilyDescription = string.Format(frmtString, "");

  978.                         obj.JobSiteContactName = string.Format(frmtString, "");

  979.                         obj.JobSiteContactPhone = string.Format(frmtString, "");

  980.                         obj.LastServiceDate = string.Format(frmtString, "");

  981.                         obj.PriorityCode = string.Format(frmtString, "");

  982.                         obj.ReferenceDocNumber = string.Format(frmtString, "");

  983.                         obj.ServiceTech = string.Format(frmtString, wo.TechnicianUserID);

  984.                         obj.StoreDescription = string.Format(frmtString, "");

  985.                         obj.Store = string.Format(frmtString, "");

  986.                         obj.TechName = string.Format(frmtString, "");

  987.                         obj.Year = string.Format(frmtString, "");

  988.                         obj.ScheduledStartDate = string.Format(frmtString, wo.ScheduledStartDate.ToString("yyyy-MM-dd hh:mm:ss"));

  989.                         obj.InspectionType = string.Format(frmtString, wo.InspectionType.ToString());

  990.                         obj.Validate();

  991. 

  992. 

  993.                         if (string.IsNullOrEmpty(obj.SerialNumber))

  994.                         {

  995.                             exceptions.Add(obj);

  996.                             //throw new ApplicationException("Serial Number is missing.");

  997.                         }

  998.                         else list.Add(obj);

  999.                         if (list.Count == 0)

  1000.                         {

  1001.                             StringBuilder sbException = new StringBuilder();

  1002.                             foreach (CSVObject csvobj in exceptions)

  1003.                                 foreach (PropertyInfo pi in csvobj.GetType().GetProperties())

  1004.                                 {

  1005.                                     sbException.AppendLine(string.Format("{0}: {1}", pi.Name, pi.GetValue(csvobj, null)));

  1006.                                 }

  1007.                             throw new ApplicationException(string.Format("Object Validation Error\r\n{0}", sbException.ToString()));

  1008.                         }

  1009.                     }

  1010. 

  1011.                     filemove = Path.Combine("Success", file);// string.Format("{0}\\{1}\\{2}", _currentDir, _settings["SUCCESSDIR"], file);

  1012.                     try

  1013.                     {

  1014.                         SqlConnection conn = new SqlConnection(_connection);

  1015.                         conn.Open();

  1016.                         string errorstr = CSVObject.WriteToDB(list, conn);

  1017.                         conn.Close();

  1018.                         conn.Dispose();

  1019.                         if (!string.IsNullOrEmpty(errorstr)) throw new ApplicationException(errorstr);

  1020.                         SqlCommand cmd = new SqlCommand("usp_DoImport", new SqlConnection(_connection));

  1021.                         cmd.CommandTimeout = 0;

  1022.                         SqlParameter sqlReturn = cmd.Parameters.Add("@b", SqlDbType.Int);

  1023.                         sqlReturn.Direction = ParameterDirection.ReturnValue;

  1024.                         cmd.Connection.Open();

  1025.                         cmd.Connection.InfoMessage += new SqlInfoMessageEventHandler(conn_InfoMsg);

  1026.                         cmd.Connection.FireInfoMessageEventOnUserErrors = true;

  1027.                         cmd.CommandType = CommandType.StoredProcedure;

  1028.                         cmd.ExecuteNonQuery();

  1029.                         if (Convert.ToInt32(cmd.Parameters["@b"].Value) != 0)

  1030.                             throw new Exception("Error happend in the do import");

  1031.                         cmd.Connection.Close();

  1032.                         cmd.Dispose();

  1033.                         conn.Dispose();

  1034.                         SqlCommand delcmd = new SqlCommand("Delete Results_Brandt", new SqlConnection(_connection));

  1035.                         delcmd.CommandTimeout = 0;

  1036.                         delcmd.Connection.Open();

  1037.                         delcmd.CommandType = CommandType.Text;

  1038.                         try

  1039.                         {

  1040. 

  1041.                             delcmd.ExecuteNonQuery();

  1042.                         }

  1043.                         catch (Exception dex)

  1044.                         {

  1045.                             throw new Exception(dex.Message);

  1046.                         }

  1047.                         delcmd.Connection.Close();

  1048.                         delcmd.Dispose();

  1049.                     }

  1050.                     catch (Exception exSql)

  1051.                     {

  1052.                         string msg = exSql.Message;

  1053.                         string logmsg = string.Format("Date: {0} Error: {1}", DateTime.Now.ToString("MM/dd/yyyy hh:mm:ss tt"), exSql.Message);

  1054.                         WriteToLog(logmsg);

  1055.                         todo.Validation = exSql.Message + " " + _workOrderNumber;

  1056.                         filemove = Path.Combine("Fail", todo.FileName);

  1057.                         //File.Move(todo.FileName, filemove);

  1058.                         //MailSvc.SendResponse(msg, _workOrderNumber);

  1059. 

  1060.                     }

  1061.                     Console.WriteLine("Line 584: " + filemove);

  1062.                     if (File.Exists(filemove)) File.Delete(filemove);

  1063.                     //File.Move(file, filemove);

  1064.                     if (_log)

  1065.                     {

  1066.                         string successmsg = string.Format("Success Date: {0} File Name: {1} Work Order #: {2}{3}", DateTime.Now.ToString("MM/dd/yyyy hh:mm:ss tt"), file, _workOrderNumber, "********************************");

  1067.                         WriteToLog(successmsg);

  1068.                         if (exceptions.Count > 0)

  1069.                         {

  1070.                             foreach (CSVObject csvobj in exceptions)

  1071.                             {

  1072.                                 string csvmsg = string.Format("Null Serial# Exception Date: {0} File Name: {1} Work Order #: {2}{3}", DateTime.Now.ToString("MM/dd/yyyy hh:mm:ss tt"), file, _workOrderNumber, "********************************");

  1073.                                 WriteToLog(csvmsg);

  1074.                             }

  1075.                         }

  1076.                         if (_sqlMessages.Count > 0)

  1077.                         {

  1078.                             WriteToLog("***********************SQL Messages************************");

  1079.                             foreach (string sqlmessg in _sqlMessages)

  1080.                                 WriteToLog(sqlmessg);

  1081.                             WriteToLog("*********************End SQL Messages**********************");

  1082.                         }

  1083.                     }

  1084.                     using (SqlConnection doublecheck = new SqlConnection(_connection))

  1085.                     {

  1086.                         SqlCommand cmddoublecheck = doublecheck.CreateCommand();

  1087.                         cmddoublecheck.Connection.Open();

  1088.                         cmddoublecheck.CommandTimeout = 0;

  1089.                         cmddoublecheck.CommandText = string.Format("Select MAX(ID) from WorkOrder where Number = '{0}'", wo.Number);

  1090.                         cmddoublecheck.CommandType = CommandType.Text;

  1091.                         int rslt = (cmddoublecheck.ExecuteScalar() == DBNull.Value ? 0 : (int)cmddoublecheck.ExecuteScalar());

  1092. 

  1093. 

  1094. 

  1095.                         cmddoublecheck.Dispose();

  1096.                         if (rslt > 0)

  1097.                         {

  1098.                             cmddoublecheck.CommandText = string.Format("Select ID from Inspection where workorderid = {0}", rslt);

  1099.                             rslt = (cmddoublecheck.ExecuteScalar() == DBNull.Value ? 0 : (int)cmddoublecheck.ExecuteScalar());

  1100.                             if (rslt > 0)

  1101.                             {

  1102.                                 todo.Success = true;

  1103.                                 //MailSvc.SendResponse("Work Order was imported successfully.", wo.Number);

  1104.                             }

  1105.                             else

  1106.                             {

  1107.                                 //string noTemplate = string.Format("Work Order was created successfully.  However, it appears there is no template for this model: {0}", eq.Model);

  1108.                                 todo.Validation = todo.Validation + "\r\n" + string.Format("Work Order was created successfully.  However, it appears there is no template for this model: {0}", eq.Model);

  1109.                                 todo.Success = false;

  1110.                             }

  1111.                         }

  1112.                         else

  1113.                         {

  1114.                             todo.Validation = todo.Validation + "\r\n" + string.Format("Failed to import work order {0}", wo.Number);//)

  1115.                         }

  1116.                         //MailSvc.SendResponse(string.Format("Failed to import work order {0}.", wo.Number), wo.Number);

  1117.                     }

  1118.                 }

  1119.                 //Console.ReadLine();

  1120. 

  1121. 

  1122.             }

  1123.             catch (Exception ex)

  1124.             {

  1125. 

  1126.                 string exMesg = string.Empty;

  1127.                 try

  1128.                 {

  1129.                     exMesg = string.Format("Date: {0} Error: {1}\r\nError occured in line # {2}", DateTime.Now.ToString("MM/dd/yyyy hh:mm:ss tt"), ex.Message, line);

  1130.                 }

  1131.                 catch (Exception exSend)

  1132.                 {

  1133.                     Console.Write(exSend.Message);

  1134. 

  1135.                 }

  1136.                 WriteToLog(exMesg);

  1137. 

  1138.                 filemove = Path.Combine("Fail", file);//, file);

  1139. 

  1140. 

  1141. 

  1142.                 try

  1143.                 {

  1144.                     Console.WriteLine("Line 634: " + file);

  1145.                     Console.WriteLine("Line 635: " + filemove);

  1146.                     //File.Move(file, filemove);

  1147.                 }

  1148.                 catch (Exception moveExcept)

  1149.                 {

  1150.                     Console.WriteLine(moveExcept.Message);

  1151.                 }

  1152.                 todo.Success = false;

  1153.                 todo.Validation = todo.Validation + "\r\n" + string.Format("Failed to import work order {0}.  Error: {1}", wo.Number, exMesg);

  1154.                 //MailSvc.SendResponse(string.Format("Failed to import work order {0}.  Error: {1}", wo.Number, exMesg), wo.Number, filemove);

  1155.             }

  1156.         }

  1157.         private static void CreateLogFile(string logfile)

  1158.         {

  1159.             using (StreamWriter sw = File.CreateText(logfile))

  1160.             {

  1161.                 sw.WriteLine("******************************************");

  1162.                 sw.WriteLine("****************IMPORT LOG****************");

  1163.                 sw.WriteLine("******************************************");

  1164.             }

  1165.         }

  1166. 

  1167.         public static void WriteToLog(string message, string sqlmessage = "")

  1168.         {

  1169.             string logfile = Path.Combine("Log", "log.log");

  1170.             if (!File.Exists(logfile))

  1171.             {

  1172.                 CreateLogFile(logfile);

  1173.             }

  1174.             using (StreamWriter sw = File.AppendText(logfile))

  1175.             {

  1176.                 sw.WriteLine(message);

  1177.                 if (!string.IsNullOrEmpty(sqlmessage))

  1178.                     sw.WriteLine(sqlmessage);

  1179.             }

  1180.         }

  1181. 

  1182. 

  1183.         public static bool IsWindows() =>

  1184.             System.Runtime.InteropServices.RuntimeInformation.IsOSPlatform(System.Runtime.InteropServices.OSPlatform.Windows);

  1185. 

  1186.         public static bool IsMacOS() =>

  1187.             System.Runtime.InteropServices.RuntimeInformation.IsOSPlatform(System.Runtime.InteropServices.OSPlatform.OSX);

  1188. 

  1189.         public static bool IsLinux() =>

  1190.             System.Runtime.InteropServices.RuntimeInformation.IsOSPlatform(System.Runtime.InteropServices.OSPlatform.Linux);

  1191.     }

  1192. 

  1193.     public class ToDo

  1194.     {

  1195.         private bool _success = false;

  1196.         public bool Success { get { return _success; } set { _success = value; } }

  1197.         public string Sender { get; set; }

  1198.         public string SenderName { get; set; }

  1199.         public string FileName { get; set; }

  1200.         public string Validation { get; set; }

  1201. 

  1202.         public string WorkOrderNumber { get; set; }

  1203.     }

  1204. }