Compare commits
7 Commits
Author | SHA1 | Date |
---|---|---|
ZtRXR | cbb5b5588b | |
ZtRXR | 872644e47e | |
ZtRXR | 745d2e2b6c | |
ZtRXR | c07715536c | |
ZtRXR | 3a3f866bf4 | |
ZtRXR | cd7c3385fa | |
ZtRXR | ca29d275a8 |
|
@ -1,13 +1,14 @@
|
|||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net7.0</TargetFramework>
|
||||
<OutputType>WinExe</OutputType>
|
||||
<TargetFramework>net7.0-windows</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Microsoft.EntityFrameworkCore.Sqlite" Version="7.0.12" />
|
||||
<PackageReference Include="System.Management" Version="7.0.2" />
|
||||
</ItemGroup>
|
||||
|
||||
|
|
180
FileCopy.cs
180
FileCopy.cs
|
@ -1,5 +1,7 @@
|
|||
using System;
|
||||
using CopyUSB.MyDB;
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Diagnostics;
|
||||
using System.Linq;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
|
@ -14,8 +16,32 @@ public class CopyList
|
|||
}
|
||||
public class FileCopy
|
||||
{
|
||||
private static void ListFileInDic(DirectoryInfo source,DirectoryInfo target,List<(FileInfo,FileInfo)> values)
|
||||
{
|
||||
foreach (var file in source.GetFiles())
|
||||
{
|
||||
/*Debug.WriteLine(Path.Join(target.FullName, file.Name));*/
|
||||
try
|
||||
{
|
||||
values.Add((file, new FileInfo(Path.Join(target.FullName, file.Name))));
|
||||
}catch (Exception ex)
|
||||
{
|
||||
Debug.WriteLine(ex);
|
||||
}
|
||||
}
|
||||
foreach(var dir in source.GetDirectories())
|
||||
{
|
||||
try
|
||||
{
|
||||
ListFileInDic(dir, new DirectoryInfo(Path.Join(target.FullName, dir.Name)), values);
|
||||
}catch(Exception ex)
|
||||
{
|
||||
Debug.WriteLine(ex);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public static void Copy(string source,string des, List<(long, FileInfo, string, string)> copyList)
|
||||
public static void Copy(string source,string des)
|
||||
{
|
||||
try
|
||||
{
|
||||
|
@ -27,43 +53,141 @@ public class FileCopy
|
|||
{
|
||||
desDir.Create();
|
||||
}
|
||||
//遍历目录
|
||||
foreach (var subDir in sourceDir.GetDirectories())
|
||||
var cpFileList = new List<(FileInfo, FileInfo)>();
|
||||
ListFileInDic(sourceDir, desDir, cpFileList);
|
||||
var sortedFile = cpFileList.OrderBy(o=>o.Item1.Length).ToList();
|
||||
using (var fileInfoDb = new FileInfoDb())
|
||||
{
|
||||
Copy(subDir.FullName, Path.Combine(desDir.FullName, subDir.Name), copyList);
|
||||
}
|
||||
foreach (var file in sourceDir.GetFiles())
|
||||
{
|
||||
string destinationFile = Path.Combine(desDir.FullName, file.Name);
|
||||
if (File.Exists(destinationFile))
|
||||
foreach(var file in sortedFile)
|
||||
{
|
||||
var desFileInfo = new FileInfo(destinationFile);
|
||||
if (desFileInfo.Length != file.Length)
|
||||
try
|
||||
{
|
||||
/*Console.WriteLine($"Renew {file} --> {destinationFile}");*/
|
||||
copyList.Add((file.Length,file, destinationFile,"Renew"));
|
||||
/*file.CopyTo(destinationFile, true);*/
|
||||
}
|
||||
else
|
||||
var tryGetFileDb = fileInfoDb.Files.Where(w=>w.Path==file.Item2.FullName).FirstOrDefault();
|
||||
if (tryGetFileDb == null)
|
||||
{
|
||||
tryGetFileDb = new MyDB.Class.FileInfoTable();
|
||||
tryGetFileDb.NeedChange = true;
|
||||
tryGetFileDb.Path = file.Item2.FullName;
|
||||
tryGetFileDb.Size = file.Item1.Length;
|
||||
if (!file.Item2.Directory.Exists)
|
||||
{
|
||||
file.Item2.Directory.Create();
|
||||
}
|
||||
file.Item1.CopyTo(file.Item2.FullName,true);
|
||||
fileInfoDb.Files.Add(tryGetFileDb);
|
||||
Debug.WriteLine($"Copied and added into Db {file.Item1.FullName} --> {file.Item2.FullName}");
|
||||
}
|
||||
else
|
||||
{
|
||||
if(tryGetFileDb.Size == file.Item1.Length)
|
||||
{
|
||||
Debug.WriteLine($"Found Same file from db {file.Item1.FullName}");
|
||||
}
|
||||
else
|
||||
{
|
||||
file.Item1.CopyTo (file.Item2.FullName,true);
|
||||
tryGetFileDb.Size = (int)file.Item1.Length;
|
||||
tryGetFileDb.NeedChange= true;
|
||||
Debug.WriteLine($"Renew {file.Item1.FullName}");
|
||||
}
|
||||
}
|
||||
}catch (Exception ex)
|
||||
{
|
||||
Console.WriteLine($"Same {file} --> {destinationFile} {file.Length/1024/1024}MB");
|
||||
/*copyList.Add((file, destinationFile, 0, "Same"));*/
|
||||
Debug.WriteLine(ex.Message);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
/*Console.WriteLine($"NewFile {file} --> {destinationFile}");*/
|
||||
copyList.Add((file.Length,file, destinationFile, "NewFile"));
|
||||
}
|
||||
|
||||
fileInfoDb.SaveChanges();
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Console.WriteLine($"Copy Error {source}");
|
||||
Debug.WriteLine(ex.ToString());
|
||||
/*Console.WriteLine($"Copy Error {source}");*/
|
||||
/*Console.WriteLine(ex.ToString());*/
|
||||
}
|
||||
}
|
||||
public static long DicFileNum(string source)
|
||||
{
|
||||
long num = 0;
|
||||
using (var fileInfoDb = new FileInfoDb())
|
||||
{
|
||||
num = fileInfoDb.Files.Where(w=>w.NeedChange==true).Count();
|
||||
/*FileNum(source,ref num);*/
|
||||
Debug.WriteLine($"Totle Dic Num is {num} (From Db)");
|
||||
}
|
||||
return num<0?0:num;
|
||||
}
|
||||
private static void FileNum(string source, ref long num)
|
||||
{
|
||||
try
|
||||
{
|
||||
var sourceDir = new DirectoryInfo(source);
|
||||
num += sourceDir.GetFiles().Length;
|
||||
//遍历目录
|
||||
foreach (var subDir in sourceDir.GetDirectories())
|
||||
{
|
||||
FileNum(subDir.FullName,ref num);
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Debug.WriteLine(ex.ToString());
|
||||
/*Console.WriteLine($"Copy Error {source}");*/
|
||||
/*Console.WriteLine(ex.ToString());*/
|
||||
}
|
||||
}
|
||||
public static void SimpleCopy(string des,string baseDic , ref Int64 doneNum)
|
||||
{
|
||||
/*try
|
||||
{*/
|
||||
var desDir = new DirectoryInfo(des);
|
||||
|
||||
//数据库查找需要更改的数据
|
||||
using (var fileInfoDb = new FileInfoDb())
|
||||
{
|
||||
var allNeedChangeFile = fileInfoDb.Files.Where(w => w.NeedChange == true).OrderBy(o => o.Size).ToList();
|
||||
foreach (var file in allNeedChangeFile)
|
||||
{
|
||||
var desInfo = new FileInfo(Path.Join(des, file.Path.Replace(baseDic, "")));
|
||||
var fileInfo = new FileInfo(file.Path);
|
||||
if (!fileInfo.Exists)
|
||||
{
|
||||
Debug.WriteLine($"Cannot Find File In Computer {fileInfo.FullName}");
|
||||
file.NeedChange= false;
|
||||
continue;
|
||||
}
|
||||
if (!desInfo.Directory.Exists)
|
||||
{
|
||||
try
|
||||
{
|
||||
desInfo.Directory.Create();
|
||||
}catch(Exception ex)
|
||||
{
|
||||
Debug.WriteLine(ex.ToString());
|
||||
}
|
||||
}
|
||||
try
|
||||
{
|
||||
fileInfo.CopyTo(desInfo.FullName, true);
|
||||
fileInfo.Delete();
|
||||
file.NeedChange = false;
|
||||
Debug.WriteLine($"moved the file and marked into Db {fileInfo.FullName} --> {desInfo.FullName}");
|
||||
}
|
||||
catch(Exception ex)
|
||||
{
|
||||
Debug.WriteLine($"Error: moved the file and marked into Db {fileInfo.FullName} --> {desInfo.FullName}\n{ex.ToString()}");
|
||||
}
|
||||
|
||||
doneNum++;
|
||||
}
|
||||
fileInfoDb.SaveChanges();
|
||||
}
|
||||
/*}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Debug.WriteLine(ex.ToString());
|
||||
*//*Console.WriteLine($"Copy Error {source}");*/
|
||||
/*Console.WriteLine(ex.ToString());*//*
|
||||
}*/
|
||||
}
|
||||
}
|
||||
|
|
|
@ -0,0 +1,15 @@
|
|||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
|
||||
namespace CopyUSB.MyDB.Class;
|
||||
|
||||
public class FileInfoTable
|
||||
{
|
||||
public long Id { get; set; }
|
||||
public long Size { get; set; }
|
||||
public string Path { get; set; }
|
||||
public bool NeedChange { get; set; } = true;
|
||||
}
|
|
@ -0,0 +1,23 @@
|
|||
using CopyUSB.MyDB.Class;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
|
||||
namespace CopyUSB.MyDB;
|
||||
|
||||
public class FileInfoDb:DbContext
|
||||
{
|
||||
public FileInfoDb()
|
||||
{
|
||||
this.Database.EnsureCreated();
|
||||
}
|
||||
protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
|
||||
{
|
||||
/*base.OnConfiguring(optionsBuilder);*/
|
||||
optionsBuilder.UseSqlite("Data Source=./fileInfo.db");
|
||||
}
|
||||
public DbSet<FileInfoTable> Files { get; set; }
|
||||
}
|
179
Program.cs
179
Program.cs
|
@ -1,66 +1,135 @@
|
|||
using CopyUSB;
|
||||
using CopyUSB.MyDB;
|
||||
using System.Diagnostics;
|
||||
using System.Management;
|
||||
static string GetVolumeLabel(string driveName)
|
||||
{
|
||||
try
|
||||
|
||||
static string GetVolumeLabel(string driveName)
|
||||
{
|
||||
DriveInfo driveInfo = new DriveInfo(driveName);
|
||||
return driveInfo.VolumeLabel;
|
||||
}
|
||||
catch (Exception)
|
||||
{
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
string query = "SELECT * FROM Win32_VolumeChangeEvent WHERE EventType = 2";
|
||||
|
||||
ManagementEventWatcher managementEventWatcher = new(query);
|
||||
|
||||
Console.WriteLine("Waiting for USB...");
|
||||
|
||||
|
||||
managementEventWatcher.EventArrived += (s, e) =>
|
||||
{
|
||||
/*Console.WriteLine("触发器被触发了");*/
|
||||
string driveName = e.NewEvent.Properties["DriveName"].Value.ToString();
|
||||
|
||||
string dPath = Path.Join(Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments), "USBCopy", GetVolumeLabel(driveName));
|
||||
|
||||
Console.WriteLine($"Detected: {driveName} || Save To -> : {dPath}");
|
||||
|
||||
if (!Directory.Exists(dPath))
|
||||
{
|
||||
Directory.CreateDirectory(dPath);
|
||||
}
|
||||
|
||||
var copyList = new List<(long, FileInfo, string, string)>();
|
||||
|
||||
FileCopy.Copy(driveName, dPath,copyList);
|
||||
|
||||
var sortedList = copyList.OrderBy(s => s.Item1).Select(s => s);
|
||||
/*Console.WriteLine($"元素个数{sortedList.Count()}");*/
|
||||
foreach (var copyItem in sortedList)
|
||||
{
|
||||
Console.WriteLine($"{copyItem.Item4} {copyItem.Item2} --> {copyItem.Item3} {copyItem.Item1 / 1024 / 1024}MB");
|
||||
try
|
||||
{
|
||||
copyItem.Item2.CopyTo(copyItem.Item3, true);
|
||||
DriveInfo driveInfo = new DriveInfo(driveName);
|
||||
return driveInfo.VolumeLabel.Length == 0 ? "default" : driveInfo.VolumeLabel;
|
||||
}
|
||||
catch (Exception ex)
|
||||
catch (Exception)
|
||||
{
|
||||
Console.WriteLine($"Copy Error {copyItem.Item2}");
|
||||
/*Console.WriteLine(ex.ToString());*/
|
||||
return "default";
|
||||
}
|
||||
}
|
||||
Console.WriteLine("\n--------------Scaned and waiting--------------\n");
|
||||
};
|
||||
|
||||
managementEventWatcher.Start();
|
||||
string query = "SELECT * FROM Win32_VolumeChangeEvent WHERE EventType = 2";
|
||||
|
||||
// 让程序保持运行状态
|
||||
while (true)
|
||||
{
|
||||
Thread.Sleep(1000);
|
||||
/*Console.WriteLine("一次休眠周期");*/
|
||||
}
|
||||
ManagementEventWatcher managementEventWatcher = new(query);
|
||||
|
||||
Debug.WriteLine("Waiting for USB...,take usb: RXRData");
|
||||
|
||||
|
||||
|
||||
managementEventWatcher.EventArrived += (s, e) =>
|
||||
{
|
||||
try
|
||||
{
|
||||
/*Console.WriteLine("触发器被触发了");*/
|
||||
string driveName = e.NewEvent.Properties["DriveName"].Value.ToString();
|
||||
|
||||
|
||||
Debug.WriteLine(driveName);
|
||||
|
||||
var dataDir = new DirectoryInfo(Path.Join("D:", "老师文档"));
|
||||
|
||||
if (GetVolumeLabel(driveName) == "RXRData")
|
||||
{
|
||||
Debug.WriteLine("检测到拷出USB");
|
||||
if (!dataDir.Exists)
|
||||
{
|
||||
dataDir.Create();
|
||||
}
|
||||
long doneNum = 0;
|
||||
var copyTask = Task.Run(() =>
|
||||
{
|
||||
FileCopy.SimpleCopy(Path.Join(driveName, "FILE", "USBCopy"), Path.Join("D:", "老师文档"), ref doneNum);
|
||||
});
|
||||
var planPrint = Task.Run(() =>
|
||||
{
|
||||
try
|
||||
{
|
||||
Debug.WriteLine("scanning and get totle num");
|
||||
var fileNumber = FileCopy.DicFileNum(Path.Join("D:", "老师文档"));
|
||||
Debug.WriteLine("scanned ok and get totle num");
|
||||
Debug.WriteLine($"{doneNum} {fileNumber} {((int)((float)doneNum / (float)fileNumber * 100) < 0 ? 100 : (int)((float)doneNum / (float)fileNumber * 100))}.upd");
|
||||
while (!copyTask.IsCompleted)
|
||||
{
|
||||
var usbRoot = new DirectoryInfo(driveName);
|
||||
if (usbRoot.GetFiles().Where(w => w.Name == $"{((int)((float)doneNum / (float)fileNumber * 100) < 0 ? 100 : (int)((float)doneNum / (float)fileNumber * 100))}.upd").ToArray().Length != 1)
|
||||
{
|
||||
var oldPrint = usbRoot.GetFiles().Where(w => w.Name.EndsWith(".upd")).ToArray();
|
||||
Debug.WriteLine(doneNum.ToString());
|
||||
|
||||
foreach (var file in oldPrint)
|
||||
{
|
||||
file.Delete();
|
||||
}
|
||||
}
|
||||
|
||||
var newPrint = new FileInfo(Path.Join(driveName, $"{((int)((float)doneNum / (float)fileNumber * 100) < 0 ? 100 : (int)((float)doneNum / (float)fileNumber * 100))}.upd"));
|
||||
var nPStream = newPrint.Create();
|
||||
nPStream.Close();
|
||||
|
||||
Thread.Sleep(1000);
|
||||
}
|
||||
{
|
||||
var usbRoot = new DirectoryInfo(driveName);
|
||||
var oldPrint = usbRoot.GetFiles().Where(w => w.Name.EndsWith(".upd")).ToArray();
|
||||
Debug.WriteLine(doneNum.ToString());
|
||||
|
||||
foreach (var file in oldPrint)
|
||||
{
|
||||
file.Delete();
|
||||
}
|
||||
|
||||
var newPrint = new FileInfo(Path.Join(driveName, $"{((int)((float)doneNum / (float)fileNumber * 100) < 0 ? 100: (int)((float)doneNum / (float)fileNumber * 100))}.upd"));
|
||||
var nPStream = newPrint.Create();
|
||||
nPStream.Close();
|
||||
}
|
||||
}catch(Exception ex)
|
||||
{
|
||||
Debug.WriteLine(ex.ToString());
|
||||
}
|
||||
});
|
||||
|
||||
Task.WaitAll(copyTask, planPrint);
|
||||
Debug.WriteLine("-----Copy out OK---------");
|
||||
return;
|
||||
}
|
||||
if (GetVolumeLabel(driveName).StartsWith("RXR"))
|
||||
{
|
||||
Debug.WriteLine("-----It's my USB-----");
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
string dPath = Path.Join("D:", "老师文档", GetVolumeLabel(driveName));
|
||||
|
||||
Debug.WriteLine($"Detected: {driveName} || Save To -> : {dPath}");
|
||||
|
||||
if (!Directory.Exists(dPath))
|
||||
{
|
||||
Directory.CreateDirectory(dPath);
|
||||
}
|
||||
FileCopy.Copy(driveName, dPath);
|
||||
|
||||
/*Console.WriteLine($"元素个数{sortedList.Count()}");*/
|
||||
Debug.WriteLine("\n--------------Scaned and waiting--------------\n");
|
||||
}catch(Exception ex)
|
||||
{
|
||||
Debug.WriteLine(ex.ToString());
|
||||
}
|
||||
};
|
||||
|
||||
managementEventWatcher.Start();
|
||||
|
||||
// 让程序保持运行状态
|
||||
while (true)
|
||||
{
|
||||
Thread.Sleep(1000);
|
||||
/*Console.WriteLine("一次休眠周期");*/
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue