mcarman
/
jdis_import
1
0
Форкнуть 0
Код Задачи 0 Pull Request'ы 0 Релизы 1 Вики Активность
Replacement for JDIS Importer
Вы не можете выбрать более 25 тем Темы должны начинаться с буквы или цифры, могут содержать дефисы(-) и должны содержать не более 35 символов.
14 коммитов
2 Ветки
191 MiB
 
Дерево: 40db67e556
Ветки Теги
${ item.name }
Создать ветку ${ searchTerm }
из '40db67e556'
${ noResults }
jdis_import/Program.cs

888 строки
42 KiB
Исходник Вина История 

  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. 

  12. /*

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

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

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

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

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

  18. */

  19. 

  20. namespace jdis_import

  21. {

  22.     class Program

  23.     {

  24.         private static string _exeDir;

  25.         private static bool _log = true;

  26.         private static string _connection = "Data Source=192.168.0.7;Initial Catalog=Connexion_Brandt;User ID=mobilepmuser;Password=data4techs;";

  27.         private static string _workOrderNumber = string.Empty;

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

  29.         private static bool _newMachine = false;

  30.         private static bool _quoted = false;

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

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

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

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

  35.         {

  36.             _exeDir = Environment.CurrentDirectory;

  37.             SetupDirectories();

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

  39.             var cca = ConfidentialClientApplicationBuilder

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

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

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

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

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

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

  46.                 .Build();

  47. 

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

  49.             try

  50.             {

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

  52.                     .ExecuteAsync();

  53. 

  54.                 // Configure the ExchangeService with the access token

  55.                 var ewsClient = new ExchangeService();

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

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

  58.                 ewsClient.ImpersonatedUserId =

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

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

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

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

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

  64.                 foreach (string s in filters)

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

  66. 

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

  68.                 ItemView view = new ItemView(100);

  69. 

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

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

  72.                 view.Traversal = ItemTraversal.Shallow;

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

  74.                 foreach (EmailMessage msg in findResults.Items)

  75.                 {

  76.                     msg.Load();

  77.                     if (!msg.IsRead)

  78.                     {

  79.                         if (msg.HasAttachments)

  80.                         {

  81.                             foreach (Attachment attachment in msg.Attachments)

  82.                             {

  83.                                 attachment.Load();

  84.                                 if (attachment is FileAttachment)

  85.                                 {

  86.                                     ToDo todo = new ToDo();

  87.                                     todo.Sender = msg.Sender.Address;

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

  89.                                     todo.FileName = attachment.Name;

  90.                                     list.Add(todo);

  91.                                     //Download File

  92.                                     FileAttachment fAttachment = attachment as FileAttachment;

  93.                                     string fileAttachmentPath = Path.Combine(_exeDir, fAttachment.FileName);

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

  95.                                     msg.IsRead = true;

  96.                                 }

  97.                             }

  98.                         }

  99.                     }

  100.                 }

  101.                 foreach (ToDo import in list)

  102.                 {

  103. 

  104.                     //Start Importing

  105.                     BeginImport(import);

  106.                     GetInspectionTypes();

  107.                     ReadFile(import);

  108.                 }

  109.                 foreach (ToDo sendMsg in list)

  110.                 {

  111.                     EmailMessage msgToSend = new EmailMessage(ewsClient);

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

  113.                     if (sendMsg.Success)

  114.                     {

  115.                         body = string.Format(body, sendMsg.FileName, sendMsg.WorkOrder, "Was Imported Successfully");

  116.                     }

  117.                     else

  118.                     {

  119.                         body = string.Format(body, sendMsg.FileName, sendMsg.WorkOrder, string.Format("Had Errors while importing: {0}", sendMsg.Validation));

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

  121. 

  122.                     }

  123. 

  124.                     msgToSend.Subject = sendMsg.FileName;

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

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

  127.                     msgToSend.Body = body;

  128.                     msgToSend.SendAndSaveCopy();

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

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

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

  132.                 }

  133.             }

  134.             catch (MsalException ex)

  135.             {

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

  137.             }

  138.             catch (Exception ex)

  139.             {

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

  141.             }

  142. 

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

  144.             {

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

  146.                 Console.ReadKey();

  147.             }

  148. 

  149. 

  150. 

  151.         }

  152. 

  153.         public static void BeginImport(ToDo todo)

  154.         {

  155.             XMLData.BuildIntervalLookup();

  156.         }

  157.         private static void SetupDirectories()

  158.         {

  159.             if (!Directory.Exists("Success"))

  160.                 Directory.CreateDirectory("Success");

  161.             if (!Directory.Exists("Fail"))

  162.                 Directory.CreateDirectory("Fail");

  163.             if (!Directory.Exists("Log"))

  164.                 Directory.CreateDirectory("Log");

  165.         }

  166.         public static void GetInspectionTypes()

  167.         {

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

  169.             SqlConnection con = new SqlConnection("Data Source=192.168.0.7;Initial Catalog=Connexion_Brandt;User ID=mobilepmuser;Password=data4techs;");

  170.             con.Open();

  171.             SqlCommand cmd = con.CreateCommand();

  172.             cmd.CommandTimeout = 0;

  173.             cmd.Connection = con;

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

  175.             cmd.CommandType = CommandType.Text;

  176.             DataSet ds = new DataSet();

  177.             SqlDataAdapter da = new SqlDataAdapter(cmd);

  178.             da.Fill(ds);

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

  180.             {

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

  182.             }

  183.             ds.Dispose();

  184.             cmd.Dispose();

  185.             con.Close();

  186.             con.Dispose();

  187. 

  188.         }

  189.         private static string frmtString

  190.         {

  191.             get

  192.             {

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

  194.                 else return "{0}";

  195.             }

  196.         }

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

  198.         {

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

  200.             string txt = string.Empty;

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

  202.             {

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

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

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

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

  207.                 sr.Close();

  208.             }

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

  210.             list.AddRange(array);

  211.             return list;

  212.         }

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

  214.         {

  215.             string month, day, year, time;

  216. 

  217.             DateTime dt = new DateTime();

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

  219.             {

  220.                 month = "01";

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

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

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

  224.                 if (hastime)

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

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

  227. 

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

  229.                 dt = DateTime.Parse(date);

  230.             }

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

  232.             {

  233.                 month = "02";

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

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

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

  237.                 if (hastime)

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

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

  240. 

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

  242.                 dt = DateTime.Parse(date);

  243.             }

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

  245.             {

  246.                 month = "03";

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

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

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

  250.                 if (hastime)

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

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

  253. 

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

  255.                 dt = DateTime.Parse(date);

  256.             }

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

  258.             {

  259.                 month = "03";

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

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

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

  263.                 if (hastime)

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

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

  266. 

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

  268.                 dt = DateTime.Parse(date);

  269.             }

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

  271.             {

  272.                 month = "04";

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

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

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

  276.                 if (hastime)

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

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

  279. 

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

  281.                 dt = DateTime.Parse(date);

  282.             }

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

  284.             {

  285.                 month = "04";

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

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

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

  289.                 if (hastime)

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

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

  292. 

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

  294.                 dt = DateTime.Parse(date);

  295.             }

  296. 

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

  298.             {

  299.                 month = "05";

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

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

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

  303.                 if (hastime)

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

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

  306. 

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

  308.                 dt = DateTime.Parse(date);

  309.             }

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

  311.             {

  312.                 month = "06";

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

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

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

  316.                 if (hastime)

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

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

  319. 

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

  321.                 dt = DateTime.Parse(date);

  322.             }

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

  324.             {

  325.                 month = "06";

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

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

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

  329.                 if (hastime)

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

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

  332. 

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

  334.                 dt = DateTime.Parse(date);

  335.             }

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

  337.             {

  338.                 month = "07";

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

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

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

  342.                 if (hastime)

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

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

  345. 

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

  347.                 dt = DateTime.Parse(date);

  348.             }

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

  350.             {

  351.                 month = "07";

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

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

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

  355.                 if (hastime)

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

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

  358. 

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

  360.                 dt = DateTime.Parse(date);

  361.             }

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

  363.             {

  364.                 month = "08";

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

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

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

  368.                 if (hastime)

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

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

  371. 

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

  373.                 dt = DateTime.Parse(date);

  374.             }

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

  376.             {

  377.                 month = "09";

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

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

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

  381.                 if (hastime)

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

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

  384. 

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

  386.                 dt = DateTime.Parse(date);

  387.             }

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

  389.             {

  390.                 month = "09";

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

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

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

  394.                 if (hastime)

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

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

  397. 

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

  399.                 dt = DateTime.Parse(date);

  400.             }

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

  402.             {

  403.                 month = "10";

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

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

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

  407.                 if (hastime)

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

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

  410. 

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

  412.                 dt = DateTime.Parse(date);

  413.             }

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

  415.             {

  416.                 month = "10";

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

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

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

  420.                 if (hastime)

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

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

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

  424.                 dt = DateTime.Parse(date);

  425.             }

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

  427.             {

  428.                 month = "11";

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

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

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

  432.                 if (hastime)

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

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

  435. 

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

  437.                 dt = DateTime.Parse(date);

  438.             }

  439.             else

  440.             {

  441.                 month = "12";

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

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

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

  445.                 if (hastime)

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

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

  448. 

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

  450.                 dt = DateTime.Parse(date);

  451.             }

  452.             return dt;

  453.         }

  454.         private static void ReadFile(ToDo todo)

  455.         {

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

  457.             todo.FileName = file;

  458.             Customer c = new Customer();

  459.             WorkOrder wo = new WorkOrder();

  460.             Equipment eq = new Equipment();

  461.             List<Part> parts = new List<Part>();

  462. 

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

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

  465.             string filemove = string.Empty;

  466.             string filetxt = string.Empty;

  467.             string inspectionLevel = string.Empty;

  468.             bool isSpecial = false;

  469.             StringBuilder specialInstructions = new StringBuilder();

  470.             int line = 1;

  471.             try

  472.             {

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

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

  475.                 {

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

  477.                 }

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

  479. 

  480.                 foreach (string s in lines)

  481.                 {

  482. 

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

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

  485.                         line = 18;

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

  487.                         line = 1;

  488. 

  489.                     switch (line)

  490.                     {

  491.                         case 1:

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

  493.                             strDate = strDate.Trim();

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

  495.                             wo.CreateDate = DateFormatter(strDate);

  496.                             break;

  497.                         case 2:

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

  499.                             strWONum = strWONum.Trim();

  500.                             wo.Number = strWONum;

  501.                             todo.WorkOrder = strWONum;

  502.                             _workOrderNumber = strWONum;

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

  504.                             strSeg = strSeg.Trim();

  505.                             wo.Segment = strSeg;

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

  507.                             strODate = strODate.Trim();

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

  509.                             break;

  510.                         case 5:

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

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

  513.                             break;

  514.                         case 6:

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

  516.                             break;

  517.                         case 7:

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

  519.                             break;

  520.                         case 8:

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

  522.                             int length = currentline.Length - 3;

  523. 

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

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

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

  527.                             break;

  528.                         case 11:

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

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

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

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

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

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

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

  536.                             break;

  537.                         default:

  538.                             break;

  539.                     }

  540. 

  541.                     if (line > 14)

  542.                     {

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

  544.                         {

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

  546.                             {

  547.                                 isSpecial = false;

  548.                             }

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

  550.                             {

  551.                                 isSpecial = false;

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

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

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

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

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

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

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

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

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

  561.                                 if (InspectionType.ContainsKey(strService))

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

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

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

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

  566.                                 wo.CodeAndDescriptionOriginal = codeanddescriptionoriginal;

  567.                             }

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

  569.                             {

  570.                                 isSpecial = false;

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

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

  573.                                 wo.TechnicianUserID = empid;

  574.                             }

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

  576.                             {

  577.                                 isSpecial = false;

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

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

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

  581.                             }

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

  583.                             {

  584.                                 isSpecial = true;

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

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

  587.                                 specialInstructions.Append(special);

  588.                             }

  589.                             else

  590.                             {

  591.                                 if (isSpecial)

  592.                                 {

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

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

  595.                                 }

  596.                             }

  597.                         }

  598.                         else

  599.                         {

  600. 

  601.                             isSpecial = false;

  602.                             int qty = 0;

  603. 

  604.                             if (currentline.Length > 0)

  605.                             {

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

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

  608.                                 {

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

  610.                                     {

  611.                                         Part pt = new Part();

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

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

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

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

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

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

  618.                                         parts.Add(pt);

  619.                                     }

  620.                                 }

  621.                             }

  622. 

  623.                         }

  624.                     }

  625.                     line++;

  626.                 }

  627. 

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

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

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

  631.                 if (parts.Count == 0)

  632.                 {

  633.                     Part p = new Part();

  634.                     p.Description = string.Empty;

  635.                     p.Qty = string.Empty;

  636.                     p.Number = string.Empty;

  637.                     parts.Add(p);

  638. 

  639.                 }

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

  641.                 {

  642.                     _sqlMessages.Add(e.Message);

  643.                 }

  644. 

  645.                 foreach (Part prt in parts)

  646.                 {

  647.                     CSVObject obj = new CSVObject();

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  684.                     obj.Validate();

  685. 

  686. 

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

  688.                     {

  689.                         exceptions.Add(obj);

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

  691.                     }

  692.                     else list.Add(obj);

  693.                     if (list.Count == 0)

  694.                     {

  695.                         StringBuilder sbException = new StringBuilder();

  696.                         foreach (CSVObject csvobj in exceptions)

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

  698.                             {

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

  700.                             }

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

  702.                     }

  703.                 }

  704. 

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

  706.                 try

  707.                 {

  708.                     SqlConnection conn = new SqlConnection(_connection);

  709.                     conn.Open();

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

  711.                     conn.Close();

  712.                     conn.Dispose();

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

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

  715.                     cmd.CommandTimeout = 0;

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

  717.                     sqlReturn.Direction = ParameterDirection.ReturnValue;

  718.                     cmd.Connection.Open();

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

  720.                     cmd.Connection.FireInfoMessageEventOnUserErrors = true;

  721.                     cmd.CommandType = CommandType.StoredProcedure;

  722.                     cmd.ExecuteNonQuery();

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

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

  725.                     cmd.Connection.Close();

  726.                     cmd.Dispose();

  727.                     conn.Dispose();

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

  729.                     delcmd.CommandTimeout = 0;

  730.                     delcmd.Connection.Open();

  731.                     delcmd.CommandType = CommandType.Text;

  732.                     try

  733.                     {

  734. 

  735.                         delcmd.ExecuteNonQuery();

  736.                     }

  737.                     catch (Exception dex)

  738.                     {

  739.                         throw new Exception(dex.Message);

  740.                     }

  741.                     delcmd.Connection.Close();

  742.                     delcmd.Dispose();

  743.                 }

  744.                 catch (Exception exSql)

  745.                 {

  746.                     string msg = exSql.Message;

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

  748.                     WriteToLog(logmsg);

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

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

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

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

  753. 

  754.                 }

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

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

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

  758.                 if (_log)

  759.                 {

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

  761.                     WriteToLog(successmsg);

  762.                     if (exceptions.Count > 0)

  763.                     {

  764.                         foreach (CSVObject csvobj in exceptions)

  765.                         {

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

  767.                             WriteToLog(csvmsg);

  768.                         }

  769.                     }

  770.                     if (_sqlMessages.Count > 0)

  771.                     {

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

  773.                         foreach (string sqlmessg in _sqlMessages)

  774.                             WriteToLog(sqlmessg);

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

  776.                     }

  777.                 }

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

  779.                 {

  780.                     SqlCommand cmddoublecheck = doublecheck.CreateCommand();

  781.                     cmddoublecheck.Connection.Open();

  782.                     cmddoublecheck.CommandTimeout = 0;

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

  784.                     cmddoublecheck.CommandType = CommandType.Text;

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

  786. 

  787. 

  788. 

  789.                     cmddoublecheck.Dispose();

  790.                     if (rslt > 0)

  791.                     {

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

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

  794.                         if (rslt > 0)

  795.                         {

  796.                             todo.Success = true;

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

  798.                         }

  799.                         else

  800.                         {

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

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

  803.                             todo.Success = false;

  804.                         }

  805.                     }

  806.                     else

  807.                     {

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

  809.                     }

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

  811.                 }

  812.                 //Console.ReadLine();

  813. 

  814.             }

  815.             catch (Exception ex)

  816.             {

  817. 

  818.                 string exMesg = string.Empty;

  819.                 try

  820.                 {

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

  822.                 }

  823.                 catch (Exception exSend)

  824.                 {

  825.                     Console.Write(exSend.Message);

  826. 

  827.                 }

  828.                 WriteToLog(exMesg);

  829. 

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

  831. 

  832. 

  833. 

  834.                 try

  835.                 {

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

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

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

  839.                 }

  840.                 catch (Exception moveExcept)

  841.                 {

  842.                     Console.WriteLine(moveExcept.Message);

  843.                 }

  844.                 todo.Success = false;

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

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

  847.             }

  848.         }

  849.         private static void CreateLogFile(string logfile)

  850.         {

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

  852.             {

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

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

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

  856.             }

  857.         }

  858. 

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

  860.         {

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

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

  863.             {

  864.                 CreateLogFile(logfile);

  865.             }

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

  867.             {

  868.                 sw.WriteLine(message);

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

  870.                     sw.WriteLine(sqlmessage);

  871.             }

  872.         }

  873. 

  874.     }

  875. 

  876.     public class ToDo

  877.     {

  878.         private bool _success = false;

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

  880.         public string Sender { get; set; }

  881.         public string SenderName { get; set; }

  882.         public string FileName { get; set; }

  883.         public string Validation { get; set; }

  884. 

  885.         public string WorkOrder { get; set; }

  886.     }

  887. }