1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112
| using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.IO;
using System.Diagnostics;
using System.Data.Odbc;
namespace ConsoleApplication1
{
class Program
{
static void Main()
{
Run();
}
public static void Run()
{
FileSystemWatcher Watcher = new FileSystemWatcher();
Watcher.Path = @"C:\dwn";
Console.WriteLine("Sureveillance du repertoire : " + Watcher.Path);
Watcher.NotifyFilter = NotifyFilters.LastAccess | NotifyFilters.LastWrite | NotifyFilters.FileName | NotifyFilters.DirectoryName;
Watcher.Filter = "*.csv";
Watcher.Created += new FileSystemEventHandler(OnChanged);
Watcher.EnableRaisingEvents = true;
Console.WriteLine("Appuyer \'q\' pour quitter... ");
while (Console.Read() != 'q') ;
}
public static void OnChanged(object source, FileSystemEventArgs e)
{
string targetgls = @"C:\gls1";
string targetposte = @"C:\poste";
string filename = e.Name;
string debut = filename.Substring(0, 3);
string origine = e.FullPath;
Console.WriteLine("Fichier " + e.FullPath + " " + e.ChangeType);
Console.WriteLine("Fichier : " + origine);
if (debut == "lap")
{
System.IO.File.Copy((e.FullPath), targetposte);
Console.WriteLine("Fichier copier dans le repertoire poste");
System.IO.File.Delete(e.FullPath);
Console.WriteLine("Fichier supprimer du repertoire : " + e.FullPath);
}
if (debut == "gls")
{
try
{
System.IO.File.Copy((e.FullPath), (targetgls + "\\" + filename), true);
verif(targetgls + "\\" + filename);
Console.WriteLine("Fichier copier dans le repertoire gls");
System.IO.File.Delete((e.FullPath));
}
catch (IOException Copyerror)
{
Console.WriteLine(Copyerror.Message);
}
}
}
public static void OnChanged(FileSystemEventHandler Watcher)
{
}
private static void OnError(Object source, ErrorEventArgs e)
{
Exception ex = e.GetException();
Console.WriteLine(ex.ToString());
}
private static void verif(string fullpath)
{
string line;
System.IO.StreamReader file = new System.IO.StreamReader(fullpath);
while((line = file.ReadLine()) !=null)
{
string [] split = line.Split(new Char [] {';'});
Console.WriteLine(split[3]);
}
}
private static void accesbdd(string valeur)
{
try
{
OdbcConnection bdd = new OdbcConnection("Driver={HyperFileSQL};REP=C:\\GLS\\winexpe6\\DAT\\bddHF\\");
bdd.Open();
OdbcCommand sql = new OdbcCommand("SELECT SHIPMENT.GLSTRACKID, SHIPMENT.NAME FROM SHIPMENT WHERE ", bdd);
OdbcDataReader donnees = sql.ExecuteReader();
int i = 0;
while (donnees.Read())
{
i = i + 1;
Console.WriteLine("\t{0}\t{1}\t{2}", i, donnees.GetString(0), donnees.GetString(1));
}
donnees.Close();
bdd.Close();
}
catch (OdbcException eExcpt)
{
Console.WriteLine("Source = " + eExcpt.Source);
Console.WriteLine("Message = " + eExcpt.Message);
}
Console.ReadLine();
}
}
} |
Partager