从大到小复制逻辑

CopyUSB.csproj

@@ -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>
 

FileCopy.cs

@@ -1,13 +1,46 @@
-using System;
+using CopyUSB.MyDB;
+using System;
 using System.Collections.Generic;
+using System.Diagnostics;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
 
 namespace CopyUSB;
-
+public class CopyList
+{
+	public string Func {  get; set; }
+	public long length { get; set; }
+	public FileInfo file { get; set; }
+	public string des { get; set; }
+}
 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)
 	{
 		try
@@ -20,23 +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));
-			}
-			foreach (var file in sourceDir.GetFiles())
-			{
-				string destinationFile = Path.Combine(desDir.FullName, file.Name);
-				file.CopyTo(destinationFile, true);
-
-				Console.WriteLine($"{file} CopyTo--> {destinationFile}");
+				foreach(var file in sortedFile)
+				{
+					try
+					{
+						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)
+					{
+						Debug.WriteLine(ex.Message);
+					}
+				}
+				fileInfoDb.SaveChanges();
 			}
 		}
 		catch (Exception ex)
 		{
-			Console.WriteLine($"{source} Copy Error");
+			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());*//*
+		}*/
+	}
 }

MyDB/Class/FileInfoTable.cs

@@ -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;
+}

MyDB/FileInfoDb.cs

@@ -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; }
+}

Program.cs

@@ -1,46 +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;
+		try
+		{
+			DriveInfo driveInfo = new DriveInfo(driveName);
+			return driveInfo.VolumeLabel.Length == 0 ? "default" : driveInfo.VolumeLabel;
+		}
+		catch (Exception)
+		{
+			return "default";
+		}
 	}
-	catch (Exception)
+
+	string query = "SELECT * FROM Win32_VolumeChangeEvent WHERE EventType = 2";
+
+	ManagementEventWatcher managementEventWatcher = new(query);
+
+	Debug.WriteLine("Waiting for USB...,take usb: RXRData");
+
+
+
+	managementEventWatcher.EventArrived += (s, e) =>
 	{
-		return null;
-	}
-}
-
-string query = "SELECT * FROM Win32_VolumeChangeEvent WHERE EventType = 2";
-
-ManagementEventWatcher managementEventWatcher = new(query);
-
-Console.WriteLine("Waiting for USB...");
+		try
+		{
+			/*Console.WriteLine("触发器被触发了");*/
+			string driveName = e.NewEvent.Properties["DriveName"].Value.ToString();
 
 
-managementEventWatcher.EventArrived += (s, e) =>
-{
-	string driveName = e.NewEvent.Properties["DriveName"].Value.ToString();
+			Debug.WriteLine(driveName);
+			
+			var dataDir = new DirectoryInfo(Path.Join("D:", "老师文档"));
 
-	string dPath = Path.Join(Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments), "USBCopy", GetVolumeLabel(driveName));
-	
-	Console.WriteLine($"Detected: {driveName} || Save To -> : {dPath}");
+			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());
 
-	if (!Directory.Exists(dPath))
+								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)
 	{
-		Directory.CreateDirectory(dPath);
+		Thread.Sleep(1000);
+		/*Console.WriteLine("一次休眠周期");*/
 	}
-	FileCopy.Copy(driveName, dPath);
-	Console.WriteLine("Scaned and waiting ----------------------");
-};
-
-managementEventWatcher.Start();
-
-// 让程序保持运行状态
-while (true)
-{
-	Thread.Sleep(1000);
-	/*Console.WriteLine("一次休眠周期");*/
-}

README.md

@@ -1 +1,3 @@
-# CopyUSB
+# CopyUSB
+
+自动监测USB插入存到 文档/USBCopy 文件夹