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

917 строки
44 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. 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>() {

  40.             { "SecretV", "gB58Q~ivZRcVK4Qhu3PWJr8yLS288ZhoQwglcaPi" },

  41.             { "SecretID", "92927063-e101-45ba-8a4c-bff8d63bcb34" },

  42.             { "ObjectId", "c7647074-edb6-4e8e-8a01-a1ed924fdae9" },

  43.             { "TenentID", "1fd06c96-d3a4-45e9-9ed7-bcecb394d277" },

  44.             { "AppID", "489776b1-ee79-4b14-bc44-9f6bf47332db" } };

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

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

  47.         {

  48.             RESTService rservice = new RESTService();

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

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

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

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

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

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

  55. 

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

  57.             _exeDir = Environment.CurrentDirectory;

  58.             SetupDirectories();

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

  60.             var cca = ConfidentialClientApplicationBuilder

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

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

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

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

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

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

  67.                 .Build();

  68. 

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

  70.             try

  71.             {

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

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

  74.                     .ExecuteAsync();

  75. 

  76.                 // Configure the ExchangeService with the access token

  77.                 var ewsClient = new ExchangeService();

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

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

  80.                 ewsClient.ImpersonatedUserId =

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

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

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

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

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

  86.                 foreach (string s in filters)

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

  88. 

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

  90.                 ItemView view = new ItemView(100);

  91. 

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

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

  94.                 view.Traversal = ItemTraversal.Shallow;

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

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

  97.                 foreach (EmailMessage msg in findResults.Items)

  98.                 {

  99.                     msg.Load();

  100.                     if (!msg.IsRead)

  101.                     {

  102.                         if (msg.HasAttachments)

  103.                         {

  104.                             foreach (Attachment attachment in msg.Attachments)

  105.                             {

  106.                                 attachment.Load();

  107.                                 if (attachment is FileAttachment)

  108.                                 {

  109.                                     ToDo todo = new ToDo();

  110.                                     todo.Sender = msg.Sender.Address;

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

  112.                                     todo.FileName = attachment.Name;

  113.                                     list.Add(todo);

  114.                                     //Download File

  115.                                     FileAttachment fAttachment = attachment as FileAttachment;

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

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

  118.                                     msg.IsRead = true;

  119.                                     msg.Update(ConflictResolutionMode.AlwaysOverwrite);

  120.                                 }

  121.                             }

  122.                         }

  123.                     }

  124.                 }

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

  126.                 foreach (ToDo import in list)

  127.                 {

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

  129. 

  130.                     //Start Importing

  131.                     BeginImport(import);

  132.                     GetInspectionTypes();

  133.                     ReadFile(import);

  134.                 }

  135.                 foreach (ToDo sendMsg in list)

  136.                 {

  137.                     EmailMessage msgToSend = new EmailMessage(ewsClient);

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

  139.                     if (sendMsg.Success)

  140.                     {

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

  142.                     }

  143.                     else

  144.                     {

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

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

  147. 

  148.                     }

  149. 

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

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

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

  153.                     msgToSend.Body = body;

  154.                     msgToSend.SendAndSaveCopy();

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

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

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

  158.                 }

  159.             }

  160.             catch (MsalException ex)

  161.             {

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

  163.             }

  164.             catch (Exception ex)

  165.             {

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

  167.             }

  168. 

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

  170.             {

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

  172.                 Console.ReadKey();

  173.             }

  174. 

  175. 

  176. 

  177.         }

  178. 

  179.         public static void BeginImport(ToDo todo)

  180.         {

  181.             XMLData.BuildIntervalLookup();

  182.         }

  183.         private static void SetupDirectories()

  184.         {

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

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

  187.                 Directory.CreateDirectory(path);

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

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

  190.                 Directory.CreateDirectory(path);

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

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

  193.                 Directory.CreateDirectory(path);

  194.         }

  195.         public static void GetInspectionTypes()

  196.         {

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

  198.             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;");

  199.             con.Open();

  200.             SqlCommand cmd = con.CreateCommand();

  201.             cmd.CommandTimeout = 0;

  202.             cmd.Connection = con;

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

  204.             cmd.CommandType = CommandType.Text;

  205.             DataSet ds = new DataSet();

  206.             SqlDataAdapter da = new SqlDataAdapter(cmd);

  207.             da.Fill(ds);

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

  209.             {

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

  211.             }

  212.             ds.Dispose();

  213.             cmd.Dispose();

  214.             con.Close();

  215.             con.Dispose();

  216. 

  217.         }

  218.         private static string frmtString

  219.         {

  220.             get

  221.             {

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

  223.                 else return "{0}";

  224.             }

  225.         }

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

  227.         {

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

  229.             string txt = string.Empty;

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

  231.             {

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

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

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

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

  236.                 sr.Close();

  237.             }

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

  239.             list.AddRange(array);

  240.             return list;

  241.         }

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

  243.         {

  244.             string month, day, year, time;

  245. 

  246.             DateTime dt = new DateTime();

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

  248.             {

  249.                 month = "01";

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

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

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

  253.                 if (hastime)

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

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

  256. 

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

  258.                 dt = DateTime.Parse(date);

  259.             }

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

  261.             {

  262.                 month = "02";

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

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

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

  266.                 if (hastime)

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

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

  269. 

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

  271.                 dt = DateTime.Parse(date);

  272.             }

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

  274.             {

  275.                 month = "03";

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

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

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

  279.                 if (hastime)

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

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

  282. 

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

  284.                 dt = DateTime.Parse(date);

  285.             }

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

  287.             {

  288.                 month = "03";

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

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

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

  292.                 if (hastime)

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

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

  295. 

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

  297.                 dt = DateTime.Parse(date);

  298.             }

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

  300.             {

  301.                 month = "04";

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

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

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

  305.                 if (hastime)

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

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

  308. 

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

  310.                 dt = DateTime.Parse(date);

  311.             }

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

  313.             {

  314.                 month = "04";

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

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

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

  318.                 if (hastime)

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

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

  321. 

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

  323.                 dt = DateTime.Parse(date);

  324.             }

  325. 

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

  327.             {

  328.                 month = "05";

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

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

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

  332.                 if (hastime)

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

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

  335. 

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

  337.                 dt = DateTime.Parse(date);

  338.             }

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

  340.             {

  341.                 month = "06";

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

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

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

  345.                 if (hastime)

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

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

  348. 

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

  350.                 dt = DateTime.Parse(date);

  351.             }

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

  353.             {

  354.                 month = "06";

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

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

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

  358.                 if (hastime)

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

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

  361. 

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

  363.                 dt = DateTime.Parse(date);

  364.             }

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

  366.             {

  367.                 month = "07";

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

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

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

  371.                 if (hastime)

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

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

  374. 

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

  376.                 dt = DateTime.Parse(date);

  377.             }

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

  379.             {

  380.                 month = "07";

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

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

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

  384.                 if (hastime)

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

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

  387. 

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

  389.                 dt = DateTime.Parse(date);

  390.             }

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

  392.             {

  393.                 month = "08";

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

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

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

  397.                 if (hastime)

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

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

  400. 

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

  402.                 dt = DateTime.Parse(date);

  403.             }

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

  405.             {

  406.                 month = "09";

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

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

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

  410.                 if (hastime)

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

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

  413. 

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

  415.                 dt = DateTime.Parse(date);

  416.             }

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

  418.             {

  419.                 month = "09";

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

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

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

  423.                 if (hastime)

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

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

  426. 

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

  428.                 dt = DateTime.Parse(date);

  429.             }

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

  431.             {

  432.                 month = "10";

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

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

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

  436.                 if (hastime)

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

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

  439. 

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

  441.                 dt = DateTime.Parse(date);

  442.             }

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

  444.             {

  445.                 month = "10";

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

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

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

  449.                 if (hastime)

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

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

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

  453.                 dt = DateTime.Parse(date);

  454.             }

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

  456.             {

  457.                 month = "11";

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

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

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

  461.                 if (hastime)

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

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

  464. 

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

  466.                 dt = DateTime.Parse(date);

  467.             }

  468.             else

  469.             {

  470.                 month = "12";

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

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

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

  474.                 if (hastime)

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

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

  477. 

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

  479.                 dt = DateTime.Parse(date);

  480.             }

  481.             return dt;

  482.         }

  483.         private static void ReadFile(ToDo todo)

  484.         {

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

  486.             todo.FileName = file;

  487.             CustomerImport c = new CustomerImport();

  488.             WorkOrderImport wo = new WorkOrderImport();

  489.             EquipmentImport eq = new EquipmentImport();

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

  491. 

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

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

  494.             string filemove = string.Empty;

  495.             string filetxt = string.Empty;

  496.             string inspectionLevel = string.Empty;

  497.             bool isSpecial = false;

  498.             StringBuilder specialInstructions = new StringBuilder();

  499.             int line = 1;

  500.             try

  501.             {

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

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

  504.                 {

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

  506.                 }

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

  508. 

  509.                 foreach (string s in lines)

  510.                 {

  511. 

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

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

  514.                         line = 18;

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

  516.                         line = 1;

  517. 

  518.                     switch (line)

  519.                     {

  520.                         case 1:

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

  522.                             strDate = strDate.Trim();

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

  524.                             wo.CreateDate = DateFormatter(strDate);

  525.                             break;

  526.                         case 2:

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

  528.                             strWONum = strWONum.Trim();

  529.                             wo.Number = strWONum;

  530.                             todo.WorkOrder = strWONum;

  531.                             _workOrderNumber = strWONum;

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

  533.                             strSeg = strSeg.Trim();

  534.                             wo.Segment = strSeg;

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

  536.                             strODate = strODate.Trim();

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

  538.                             break;

  539.                         case 5:

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

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

  542.                             break;

  543.                         case 6:

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

  545.                             break;

  546.                         case 7:

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

  548.                             break;

  549.                         case 8:

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

  551.                             int length = currentline.Length - 3;

  552. 

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

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

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

  556.                             break;

  557.                         case 11:

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

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

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

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

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

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

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

  565.                             break;

  566.                         default:

  567.                             break;

  568.                     }

  569. 

  570.                     if (line > 14)

  571.                     {

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

  573.                         {

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

  575.                             {

  576.                                 isSpecial = false;

  577.                             }

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

  579.                             {

  580.                                 isSpecial = false;

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

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

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

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

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

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

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

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

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

  590.                                 if (InspectionType.ContainsKey(strService))

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

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

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

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

  595.                                 wo.CodeAndDescriptionOriginal = codeanddescriptionoriginal;

  596.                             }

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

  598.                             {

  599.                                 isSpecial = false;

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

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

  602.                                 wo.TechnicianUserID = empid;

  603.                             }

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

  605.                             {

  606.                                 isSpecial = false;

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

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

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

  610.                             }

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

  612.                             {

  613.                                 isSpecial = true;

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

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

  616.                                 specialInstructions.Append(special);

  617.                             }

  618.                             else

  619.                             {

  620.                                 if (isSpecial)

  621.                                 {

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

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

  624.                                 }

  625.                             }

  626.                         }

  627.                         else

  628.                         {

  629. 

  630.                             isSpecial = false;

  631.                             int qty = 0;

  632. 

  633.                             if (currentline.Length > 0)

  634.                             {

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

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

  637.                                 {

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

  639.                                     {

  640.                                         PartImport pt = new PartImport();

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

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

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

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

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

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

  647.                                         parts.Add(pt);

  648.                                     }

  649.                                 }

  650.                             }

  651. 

  652.                         }

  653.                     }

  654.                     line++;

  655.                 }

  656. 

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

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

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

  660.                 if (parts.Count == 0)

  661.                 {

  662.                     PartImport p = new PartImport();

  663.                     p.Description = string.Empty;

  664.                     p.Qty = string.Empty;

  665.                     p.Number = string.Empty;

  666.                     parts.Add(p);

  667. 

  668.                 }

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

  670.                 {

  671.                     _sqlMessages.Add(e.Message);

  672.                 }

  673. 

  674.                 foreach (PartImport prt in parts)

  675.                 {

  676.                     CSVObject obj = new CSVObject();

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  713.                     obj.Validate();

  714. 

  715. 

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

  717.                     {

  718.                         exceptions.Add(obj);

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

  720.                     }

  721.                     else list.Add(obj);

  722.                     if (list.Count == 0)

  723.                     {

  724.                         StringBuilder sbException = new StringBuilder();

  725.                         foreach (CSVObject csvobj in exceptions)

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

  727.                             {

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

  729.                             }

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

  731.                     }

  732.                 }

  733. 

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

  735.                 try

  736.                 {

  737.                     SqlConnection conn = new SqlConnection(_connection);

  738.                     conn.Open();

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

  740.                     conn.Close();

  741.                     conn.Dispose();

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

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

  744.                     cmd.CommandTimeout = 0;

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

  746.                     sqlReturn.Direction = ParameterDirection.ReturnValue;

  747.                     cmd.Connection.Open();

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

  749.                     cmd.Connection.FireInfoMessageEventOnUserErrors = true;

  750.                     cmd.CommandType = CommandType.StoredProcedure;

  751.                     cmd.ExecuteNonQuery();

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

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

  754.                     cmd.Connection.Close();

  755.                     cmd.Dispose();

  756.                     conn.Dispose();

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

  758.                     delcmd.CommandTimeout = 0;

  759.                     delcmd.Connection.Open();

  760.                     delcmd.CommandType = CommandType.Text;

  761.                     try

  762.                     {

  763. 

  764.                         delcmd.ExecuteNonQuery();

  765.                     }

  766.                     catch (Exception dex)

  767.                     {

  768.                         throw new Exception(dex.Message);

  769.                     }

  770.                     delcmd.Connection.Close();

  771.                     delcmd.Dispose();

  772.                 }

  773.                 catch (Exception exSql)

  774.                 {

  775.                     string msg = exSql.Message;

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

  777.                     WriteToLog(logmsg);

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

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

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

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

  782. 

  783.                 }

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

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

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

  787.                 if (_log)

  788.                 {

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

  790.                     WriteToLog(successmsg);

  791.                     if (exceptions.Count > 0)

  792.                     {

  793.                         foreach (CSVObject csvobj in exceptions)

  794.                         {

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

  796.                             WriteToLog(csvmsg);

  797.                         }

  798.                     }

  799.                     if (_sqlMessages.Count > 0)

  800.                     {

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

  802.                         foreach (string sqlmessg in _sqlMessages)

  803.                             WriteToLog(sqlmessg);

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

  805.                     }

  806.                 }

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

  808.                 {

  809.                     SqlCommand cmddoublecheck = doublecheck.CreateCommand();

  810.                     cmddoublecheck.Connection.Open();

  811.                     cmddoublecheck.CommandTimeout = 0;

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

  813.                     cmddoublecheck.CommandType = CommandType.Text;

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

  815. 

  816. 

  817. 

  818.                     cmddoublecheck.Dispose();

  819.                     if (rslt > 0)

  820.                     {

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

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

  823.                         if (rslt > 0)

  824.                         {

  825.                             todo.Success = true;

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

  827.                         }

  828.                         else

  829.                         {

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

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

  832.                             todo.Success = false;

  833.                         }

  834.                     }

  835.                     else

  836.                     {

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

  838.                     }

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

  840.                 }

  841.                 //Console.ReadLine();

  842. 

  843.             }

  844.             catch (Exception ex)

  845.             {

  846. 

  847.                 string exMesg = string.Empty;

  848.                 try

  849.                 {

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

  851.                 }

  852.                 catch (Exception exSend)

  853.                 {

  854.                     Console.Write(exSend.Message);

  855. 

  856.                 }

  857.                 WriteToLog(exMesg);

  858. 

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

  860. 

  861. 

  862. 

  863.                 try

  864.                 {

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

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

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

  868.                 }

  869.                 catch (Exception moveExcept)

  870.                 {

  871.                     Console.WriteLine(moveExcept.Message);

  872.                 }

  873.                 todo.Success = false;

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

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

  876.             }

  877.         }

  878.         private static void CreateLogFile(string logfile)

  879.         {

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

  881.             {

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

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

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

  885.             }

  886.         }

  887. 

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

  889.         {

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

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

  892.             {

  893.                 CreateLogFile(logfile);

  894.             }

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

  896.             {

  897.                 sw.WriteLine(message);

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

  899.                     sw.WriteLine(sqlmessage);

  900.             }

  901.         }

  902. 

  903.     }

  904. 

  905.     public class ToDo

  906.     {

  907.         private bool _success = false;

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

  909.         public string Sender { get; set; }

  910.         public string SenderName { get; set; }

  911.         public string FileName { get; set; }

  912.         public string Validation { get; set; }

  913. 

  914.         public string WorkOrder { get; set; }

  915.     }

  916. }