mcarman
/
jdis_import
1
0
Forkuj 0
Kod Zgłoszenia 0 Oczekujące zmiany 0 Wydania 1 Wiki Aktywność
Replacement for JDIS Importer
Nie możesz wybrać więcej, niż 25 tematów Tematy muszą się zaczynać od litery lub cyfry, mogą zawierać myślniki ('-') i mogą mieć do 35 znaków.
26 Commity
2 Gałęzie
191 MiB
 
Drzewo: 34ef67ca71
Gałęzie Tagi
${ item.name }
Utwórz gałąź ${ searchTerm }
z '34ef67ca71'
${ noResults }
jdis_import/Program.cs

912 wiersze
44 KiB
Czysty Wina Historia 

  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. 

  13. /*

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

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

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

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

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

  19. */

  20. 

  21. namespace jdis_import

  22. {

  23.     class Program

  24.     {

  25.         private static List<Customer> _customers;

  26.         private static List<Make> _makes;

  27.         private static List<Product> _products;

  28.         private static List<Model> _models;

  29.         private static List<InspectionType> _inspectionTypes;

  30.         private static List<Template> _templates;

  31.         private static string _exeDir;

  32.         private static bool _log = true;

  33.         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;";

  34.         private static string _workOrderNumber = string.Empty;

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

  36.         private static bool _newMachine = false;

  37.         private static bool _quoted = false;

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

  39.         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" } };

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

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

  42.         {

  43.             RESTService rservice = new RESTService();

  44.             _customers = rservice.RestGet<Customer>("customers.svc");

  45.             _makes = rservice.RestGet<Make>("makes.svc");

  46.             _products = rservice.RestGet<Product>("products.svc");

  47.             _models = rservice.RestGet<Model>("models.svc");

  48.             _inspectionTypes = rservice.RestGet<InspectionType>("inspectionTypes.svc");

  49.             _templates = rservice.RestGet<Template>("templates.svc");

  50. 

  51.             Console.WriteLine("Web APIs have loaded.");

  52.             _exeDir = Environment.CurrentDirectory;

  53.             SetupDirectories();

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

  55.             var cca = ConfidentialClientApplicationBuilder

  56.                 // .Create("1dff6bdb-7009-4d2a-ae0f-9f333a4f182b")

  57.                 // .WithClientSecret("VOD8Q~7BI9u4ySU0saesCG87TaEtKSCya5vw6as5")

  58.                 // .WithTenantId("1fd06c96-d3a4-45e9-9ed7-bcecb394d277")

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

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

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

  62.                 .Build();

  63. 

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

  65.             try

  66.             {

  67.                 Console.WriteLine("Connecting To Exchange.");

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

  69.                     .ExecuteAsync();

  70. 

  71.                 // Configure the ExchangeService with the access token

  72.                 var ewsClient = new ExchangeService();

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

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

  75.                 ewsClient.ImpersonatedUserId =

  76.                     new ImpersonatedUserId(ConnectingIdType.SmtpAddress, "cmobile@prelub.com");

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

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

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

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

  81.                 foreach (string s in filters)

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

  83. 

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

  85.                 ItemView view = new ItemView(100);

  86. 

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

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

  89.                 view.Traversal = ItemTraversal.Shallow;

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

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

  92.                 foreach (EmailMessage msg in findResults.Items)

  93.                 {

  94.                     msg.Load();

  95.                     if (!msg.IsRead)

  96.                     {

  97.                         if (msg.HasAttachments)

  98.                         {

  99.                             foreach (Attachment attachment in msg.Attachments)

  100.                             {

  101.                                 attachment.Load();

  102.                                 if (attachment is FileAttachment)

  103.                                 {

  104.                                     ToDo todo = new ToDo();

  105.                                     todo.Sender = msg.Sender.Address;

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

  107.                                     todo.FileName = attachment.Name;

  108.                                     list.Add(todo);

  109.                                     //Download File

  110.                                     FileAttachment fAttachment = attachment as FileAttachment;

  111.                                     string fileAttachmentPath = Path.Combine(_exeDir, fAttachment.Name);

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

  113.                                     msg.IsRead = true;

  114.                                     msg.Update(ConflictResolutionMode.AlwaysOverwrite);

  115.                                 }

  116.                             }

  117.                         }

  118.                     }

  119.                 }

  120.                 Console.WriteLine("Beginning Import.");

  121.                 foreach (ToDo import in list)

  122.                 {

  123.                     //System.Net.ServicePointManager.SecurityProtocol = System.Net.SecurityProtocolType.Tls;

  124. 

  125.                     //Start Importing

  126.                     BeginImport(import);

  127.                     GetInspectionTypes();

  128.                     ReadFile(import);

  129.                 }

  130.                 foreach (ToDo sendMsg in list)

  131.                 {

  132.                     EmailMessage msgToSend = new EmailMessage(ewsClient);

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

  134.                     if (sendMsg.Success)

  135.                     {

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

  137.                     }

  138.                     else

  139.                     {

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

  141.                         msgToSend.Attachments.AddFileAttachment(Path.Combine(_exeDir, sendMsg.FileName));

  142. 

  143.                     }

  144. 

  145.                     msgToSend.Subject = sendMsg.FileName.Substring(sendMsg.FileName.LastIndexOf("/") + 1);

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

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

  148.                     msgToSend.Body = body;

  149.                     msgToSend.SendAndSaveCopy();

  150.                     string pathToFile = Path.Combine(_exeDir, sendMsg.FileName);

  151.                     if (sendMsg.Success) File.Move(pathToFile, Path.Combine(_exeDir, "Success", sendMsg.FileName));

  152.                     else File.Move(sendMsg.FileName, Path.Combine(_exeDir, "Fail", sendMsg.FileName));

  153.                 }

  154.             }

  155.             catch (MsalException ex)

  156.             {

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

  158.             }

  159.             catch (Exception ex)

  160.             {

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

  162.             }

  163. 

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

  165.             {

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

  167.                 Console.ReadKey();

  168.             }

  169. 

  170. 

  171. 

  172.         }

  173. 

  174.         public static void BeginImport(ToDo todo)

  175.         {

  176.             XMLData.BuildIntervalLookup();

  177.         }

  178.         private static void SetupDirectories()

  179.         {

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

  181.             if (!Directory.Exists(path))

  182.                 Directory.CreateDirectory(path);

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

  184.             if (!Directory.Exists(path))

  185.                 Directory.CreateDirectory(path);

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

  187.             if (!Directory.Exists(path))

  188.                 Directory.CreateDirectory(path);

  189.         }

  190.         public static void GetInspectionTypes()

  191.         {

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

  193.             SqlConnection con = new SqlConnection("Data Source=192.168.0.7;Initial Catalog=Connexion_Brandt;User ID=mobilepmuser;Password=data4techs;Encrypt=No;TrustServerCertificate=true;Persist Security Info=True;");

  194.             con.Open();

  195.             SqlCommand cmd = con.CreateCommand();

  196.             cmd.CommandTimeout = 0;

  197.             cmd.Connection = con;

  198.             cmd.CommandText = "Select ID, [Name] From InspectionType";

  199.             cmd.CommandType = CommandType.Text;

  200.             DataSet ds = new DataSet();

  201.             SqlDataAdapter da = new SqlDataAdapter(cmd);

  202.             da.Fill(ds);

  203.             foreach (DataRow row in ds.Tables[0].Rows)

  204.             {

  205.                 InspectionType.Add(row["Name"].ToString(), Convert.ToInt32(row["ID"]));

  206.             }

  207.             ds.Dispose();

  208.             cmd.Dispose();

  209.             con.Close();

  210.             con.Dispose();

  211. 

  212.         }

  213.         private static string frmtString

  214.         {

  215.             get

  216.             {

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

  218.                 else return "{0}";

  219.             }

  220.         }

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

  222.         {

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

  224.             string txt = string.Empty;

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

  226.             {

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

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

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

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

  231.                 sr.Close();

  232.             }

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

  234.             list.AddRange(array);

  235.             return list;

  236.         }

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

  238.         {

  239.             string month, day, year, time;

  240. 

  241.             DateTime dt = new DateTime();

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

  243.             {

  244.                 month = "01";

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

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

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

  248.                 if (hastime)

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

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

  251. 

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

  253.                 dt = DateTime.Parse(date);

  254.             }

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

  256.             {

  257.                 month = "02";

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

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

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

  261.                 if (hastime)

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

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

  264. 

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

  266.                 dt = DateTime.Parse(date);

  267.             }

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

  269.             {

  270.                 month = "03";

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

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

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

  274.                 if (hastime)

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

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

  277. 

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

  279.                 dt = DateTime.Parse(date);

  280.             }

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

  282.             {

  283.                 month = "03";

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

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

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

  287.                 if (hastime)

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

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

  290. 

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

  292.                 dt = DateTime.Parse(date);

  293.             }

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

  295.             {

  296.                 month = "04";

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

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

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

  300.                 if (hastime)

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

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

  303. 

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

  305.                 dt = DateTime.Parse(date);

  306.             }

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

  308.             {

  309.                 month = "04";

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

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

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

  313.                 if (hastime)

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

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

  316. 

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

  318.                 dt = DateTime.Parse(date);

  319.             }

  320. 

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

  322.             {

  323.                 month = "05";

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

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

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

  327.                 if (hastime)

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

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

  330. 

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

  332.                 dt = DateTime.Parse(date);

  333.             }

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

  335.             {

  336.                 month = "06";

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

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

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

  340.                 if (hastime)

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

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

  343. 

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

  345.                 dt = DateTime.Parse(date);

  346.             }

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

  348.             {

  349.                 month = "06";

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

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

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

  353.                 if (hastime)

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

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

  356. 

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

  358.                 dt = DateTime.Parse(date);

  359.             }

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

  361.             {

  362.                 month = "07";

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

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

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

  366.                 if (hastime)

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

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

  369. 

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

  371.                 dt = DateTime.Parse(date);

  372.             }

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

  374.             {

  375.                 month = "07";

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

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

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

  379.                 if (hastime)

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

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

  382. 

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

  384.                 dt = DateTime.Parse(date);

  385.             }

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

  387.             {

  388.                 month = "08";

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

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

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

  392.                 if (hastime)

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

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

  395. 

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

  397.                 dt = DateTime.Parse(date);

  398.             }

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

  400.             {

  401.                 month = "09";

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

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

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

  405.                 if (hastime)

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

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

  408. 

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

  410.                 dt = DateTime.Parse(date);

  411.             }

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

  413.             {

  414.                 month = "09";

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

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

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

  418.                 if (hastime)

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

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

  421. 

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

  423.                 dt = DateTime.Parse(date);

  424.             }

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

  426.             {

  427.                 month = "10";

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

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

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

  431.                 if (hastime)

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

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

  434. 

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

  436.                 dt = DateTime.Parse(date);

  437.             }

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

  439.             {

  440.                 month = "10";

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

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

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

  444.                 if (hastime)

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

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

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

  448.                 dt = DateTime.Parse(date);

  449.             }

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

  451.             {

  452.                 month = "11";

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

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

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

  456.                 if (hastime)

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

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

  459. 

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

  461.                 dt = DateTime.Parse(date);

  462.             }

  463.             else

  464.             {

  465.                 month = "12";

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

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

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

  469.                 if (hastime)

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

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

  472. 

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

  474.                 dt = DateTime.Parse(date);

  475.             }

  476.             return dt;

  477.         }

  478.         private static void ReadFile(ToDo todo)

  479.         {

  480.             string file = Path.Combine(_exeDir, todo.FileName);// todo.FileName;

  481.             todo.FileName = file;

  482.             CustomerImport c = new CustomerImport();

  483.             WorkOrderImport wo = new WorkOrderImport();

  484.             EquipmentImport eq = new EquipmentImport();

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

  486. 

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

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

  489.             string filemove = string.Empty;

  490.             string filetxt = string.Empty;

  491.             string inspectionLevel = string.Empty;

  492.             bool isSpecial = false;

  493.             StringBuilder specialInstructions = new StringBuilder();

  494.             int line = 1;

  495.             try

  496.             {

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

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

  499.                 {

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

  501.                 }

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

  503. 

  504.                 foreach (string s in lines)

  505.                 {

  506. 

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

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

  509.                         line = 18;

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

  511.                         line = 1;

  512. 

  513.                     switch (line)

  514.                     {

  515.                         case 1:

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

  517.                             strDate = strDate.Trim();

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

  519.                             wo.CreateDate = DateFormatter(strDate);

  520.                             break;

  521.                         case 2:

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

  523.                             strWONum = strWONum.Trim();

  524.                             wo.Number = strWONum;

  525.                             todo.WorkOrder = strWONum;

  526.                             _workOrderNumber = strWONum;

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

  528.                             strSeg = strSeg.Trim();

  529.                             wo.Segment = strSeg;

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

  531.                             strODate = strODate.Trim();

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

  533.                             break;

  534.                         case 5:

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

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

  537.                             break;

  538.                         case 6:

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

  540.                             break;

  541.                         case 7:

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

  543.                             break;

  544.                         case 8:

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

  546.                             int length = currentline.Length - 3;

  547. 

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

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

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

  551.                             break;

  552.                         case 11:

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

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

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

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

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

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

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

  560.                             break;

  561.                         default:

  562.                             break;

  563.                     }

  564. 

  565.                     if (line > 14)

  566.                     {

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

  568.                         {

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

  570.                             {

  571.                                 isSpecial = false;

  572.                             }

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

  574.                             {

  575.                                 isSpecial = false;

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

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

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

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

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

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

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

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

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

  585.                                 if (InspectionType.ContainsKey(strService))

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

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

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

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

  590.                                 wo.CodeAndDescriptionOriginal = codeanddescriptionoriginal;

  591.                             }

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

  593.                             {

  594.                                 isSpecial = false;

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

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

  597.                                 wo.TechnicianUserID = empid;

  598.                             }

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

  600.                             {

  601.                                 isSpecial = false;

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

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

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

  605.                             }

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

  607.                             {

  608.                                 isSpecial = true;

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

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

  611.                                 specialInstructions.Append(special);

  612.                             }

  613.                             else

  614.                             {

  615.                                 if (isSpecial)

  616.                                 {

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

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

  619.                                 }

  620.                             }

  621.                         }

  622.                         else

  623.                         {

  624. 

  625.                             isSpecial = false;

  626.                             int qty = 0;

  627. 

  628.                             if (currentline.Length > 0)

  629.                             {

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

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

  632.                                 {

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

  634.                                     {

  635.                                         PartImport pt = new PartImport();

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

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

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

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

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

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

  642.                                         parts.Add(pt);

  643.                                     }

  644.                                 }

  645.                             }

  646. 

  647.                         }

  648.                     }

  649.                     line++;

  650.                 }

  651. 

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

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

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

  655.                 if (parts.Count == 0)

  656.                 {

  657.                     PartImport p = new PartImport();

  658.                     p.Description = string.Empty;

  659.                     p.Qty = string.Empty;

  660.                     p.Number = string.Empty;

  661.                     parts.Add(p);

  662. 

  663.                 }

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

  665.                 {

  666.                     _sqlMessages.Add(e.Message);

  667.                 }

  668. 

  669.                 foreach (PartImport prt in parts)

  670.                 {

  671.                     CSVObject obj = new CSVObject();

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  708.                     obj.Validate();

  709. 

  710. 

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

  712.                     {

  713.                         exceptions.Add(obj);

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

  715.                     }

  716.                     else list.Add(obj);

  717.                     if (list.Count == 0)

  718.                     {

  719.                         StringBuilder sbException = new StringBuilder();

  720.                         foreach (CSVObject csvobj in exceptions)

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

  722.                             {

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

  724.                             }

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

  726.                     }

  727.                 }

  728. 

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

  730.                 try

  731.                 {

  732.                     SqlConnection conn = new SqlConnection(_connection);

  733.                     conn.Open();

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

  735.                     conn.Close();

  736.                     conn.Dispose();

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

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

  739.                     cmd.CommandTimeout = 0;

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

  741.                     sqlReturn.Direction = ParameterDirection.ReturnValue;

  742.                     cmd.Connection.Open();

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

  744.                     cmd.Connection.FireInfoMessageEventOnUserErrors = true;

  745.                     cmd.CommandType = CommandType.StoredProcedure;

  746.                     cmd.ExecuteNonQuery();

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

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

  749.                     cmd.Connection.Close();

  750.                     cmd.Dispose();

  751.                     conn.Dispose();

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

  753.                     delcmd.CommandTimeout = 0;

  754.                     delcmd.Connection.Open();

  755.                     delcmd.CommandType = CommandType.Text;

  756.                     try

  757.                     {

  758. 

  759.                         delcmd.ExecuteNonQuery();

  760.                     }

  761.                     catch (Exception dex)

  762.                     {

  763.                         throw new Exception(dex.Message);

  764.                     }

  765.                     delcmd.Connection.Close();

  766.                     delcmd.Dispose();

  767.                 }

  768.                 catch (Exception exSql)

  769.                 {

  770.                     string msg = exSql.Message;

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

  772.                     WriteToLog(logmsg);

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

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

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

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

  777. 

  778.                 }

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

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

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

  782.                 if (_log)

  783.                 {

  784.                     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, "********************************");

  785.                     WriteToLog(successmsg);

  786.                     if (exceptions.Count > 0)

  787.                     {

  788.                         foreach (CSVObject csvobj in exceptions)

  789.                         {

  790.                             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, "********************************");

  791.                             WriteToLog(csvmsg);

  792.                         }

  793.                     }

  794.                     if (_sqlMessages.Count > 0)

  795.                     {

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

  797.                         foreach (string sqlmessg in _sqlMessages)

  798.                             WriteToLog(sqlmessg);

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

  800.                     }

  801.                 }

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

  803.                 {

  804.                     SqlCommand cmddoublecheck = doublecheck.CreateCommand();

  805.                     cmddoublecheck.Connection.Open();

  806.                     cmddoublecheck.CommandTimeout = 0;

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

  808.                     cmddoublecheck.CommandType = CommandType.Text;

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

  810. 

  811. 

  812. 

  813.                     cmddoublecheck.Dispose();

  814.                     if (rslt > 0)

  815.                     {

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

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

  818.                         if (rslt > 0)

  819.                         {

  820.                             todo.Success = true;

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

  822.                         }

  823.                         else

  824.                         {

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

  826.                             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);

  827.                             todo.Success = false;

  828.                         }

  829.                     }

  830.                     else

  831.                     {

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

  833.                     }

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

  835.                 }

  836.                 //Console.ReadLine();

  837. 

  838.             }

  839.             catch (Exception ex)

  840.             {

  841. 

  842.                 string exMesg = string.Empty;

  843.                 try

  844.                 {

  845.                     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);

  846.                 }

  847.                 catch (Exception exSend)

  848.                 {

  849.                     Console.Write(exSend.Message);

  850. 

  851.                 }

  852.                 WriteToLog(exMesg);

  853. 

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

  855. 

  856. 

  857. 

  858.                 try

  859.                 {

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

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

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

  863.                 }

  864.                 catch (Exception moveExcept)

  865.                 {

  866.                     Console.WriteLine(moveExcept.Message);

  867.                 }

  868.                 todo.Success = false;

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

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

  871.             }

  872.         }

  873.         private static void CreateLogFile(string logfile)

  874.         {

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

  876.             {

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

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

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

  880.             }

  881.         }

  882. 

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

  884.         {

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

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

  887.             {

  888.                 CreateLogFile(logfile);

  889.             }

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

  891.             {

  892.                 sw.WriteLine(message);

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

  894.                     sw.WriteLine(sqlmessage);

  895.             }

  896.         }

  897. 

  898.     }

  899. 

  900.     public class ToDo

  901.     {

  902.         private bool _success = false;

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

  904.         public string Sender { get; set; }

  905.         public string SenderName { get; set; }

  906.         public string FileName { get; set; }

  907.         public string Validation { get; set; }

  908. 

  909.         public string WorkOrder { get; set; }

  910.     }

  911. }