aunix/wvp-GB28181-pro
1
0
Fork 0
mirror of https://gitee.com/pan648540858/wvp-GB28181-pro.git synced 2026-05-24 22:17:49 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

1078-修复ftp-server对文件上传的通知

Browse Source
This commit is contained in:
648540858 2024-06-04 07:15:05 +08:00
parent 3728219177
commit 83875a5905
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/com/genersoft/iot/vmp/conf/ftpServer/ftplet.java
View File

@ -44,6 +44,19 @@ public class ftplet extends DefaultFtplet {
@Override @Override
public FtpletResult onAppendEnd(FtpSession session, FtpRequest request) throws FtpException, IOException { 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); FtpUploadEvent event = new FtpUploadEvent(this);
event.setFileName(session.getFileSystemView().getFile(request.getArgument()).getAbsolutePath()); event.setFileName(session.getFileSystemView().getFile(request.getArgument()).getAbsolutePath());
applicationEventPublisher.publishEvent(event); applicationEventPublisher.publishEvent(event);