From 83875a5905d4819ee162dee341805b70afa09225 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Tue, 4 Jun 2024 07:15:05 +0800
Subject: [PATCH] =?UTF-8?q?1078-=E4=BF=AE=E5=A4=8Dftp-server=E5=AF=B9?=
 =?UTF-8?q?=E6=96=87=E4=BB=B6=E4=B8=8A=E4=BC=A0=E7=9A=84=E9=80=9A=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../genersoft/iot/vmp/conf/ftpServer/ftplet.java    | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/src/main/java/com/genersoft/iot/vmp/conf/ftpServer/ftplet.java b/src/main/java/com/genersoft/iot/vmp/conf/ftpServer/ftplet.java
index fc1d9c049..28cc2c1c3 100644
--- a/src/main/java/com/genersoft/iot/vmp/conf/ftpServer/ftplet.java
+++ b/src/main/java/com/genersoft/iot/vmp/conf/ftpServer/ftplet.java
@@ -44,6 +44,19 @@ public class ftplet extends DefaultFtplet {
 
     @Override
     public FtpletResult onAppendEnd(FtpSession session, FtpRequest request) throws FtpException, IOException {
+        FtpUploadEvent event = new FtpUploadEvent(this);
+        String argument = request.getArgument();
+        FileSystemView fileSystemView = session.getFileSystemView();
+        FtpFile file = fileSystemView.getFile(request.getArgument());
+        event.setFileName(session.getFileSystemView().getFile(request.getArgument()).getAbsolutePath());
+        applicationEventPublisher.publishEvent(event);
+
+        logger.info("[文件已上传]: {}", session.getFileSystemView().getFile(request.getArgument()).getAbsolutePath());
+        return super.onUploadEnd(session, request);
+    }
+
+    @Override
+    public FtpletResult onUploadUniqueEnd(FtpSession session, FtpRequest request) throws FtpException, IOException {
         FtpUploadEvent event = new FtpUploadEvent(this);
         event.setFileName(session.getFileSystemView().getFile(request.getArgument()).getAbsolutePath());
         applicationEventPublisher.publishEvent(event);