Title:
+ *Description:
+ * + * @author H.Yang + * @QQ 1033542070 + * @date 2018年3月10日 + */ +public class FTPUtils { + + private final Logger LOGGER = LogManager.getLogger(getClass()); + + private FTPClient ftpClient = null; + private String server; + private int port; + private String userName; + private String userPassword; + + public FTPUtils(String server, int port, String userName, String userPassword) { + this.server = server; + this.port = port; + this.userName = userName; + this.userPassword = userPassword; + } + + /** + *Title: 连接服务器
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月10日 + * + * @return 连接成功与否 true:成功， false:失败 + */ + public boolean open() { + // 判断是否已连接 + if (ftpClient != null && ftpClient.isConnected()) { + return true; + } + + try { + ftpClient = new FTPClient(); + // 连接FTP服务器 + ftpClient.connect(this.server, this.port); + // 如果采用默认端口，可以使用ftp.connect(host)的方式直接连接FTP服务器 + ftpClient.login(this.userName, this.userPassword); + // 检测连接是否成功 + int reply = ftpClient.getReplyCode(); + if (!FTPReply.isPositiveCompletion(reply)) { + System.out.println("FTP服务器拒绝连接."); + this.close(); + System.exit(1); + } + System.out.println("FTP连接成功:" + this.server + ";port:" + this.port + ";name:" + this.userName + ";pwd:" + this.userPassword); + ftpClient.setFileType(FTP.BINARY_FILE_TYPE); // 设置上传模式.binally or ascii + ftpClient.enterLocalPassiveMode(); + + return true; + } catch (Exception e) { + this.close(); + e.printStackTrace(); + return false; + } + + } + + /** + *Title: 切换到父目录
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @return 切换结果 true：成功， false：失败 + */ + private boolean changeToParentDir() { + try { + return ftpClient.changeToParentDirectory(); + } catch (IOException e) { + e.printStackTrace(); + return false; + } + } + + /** + *Title: 改变当前目录到指定目录
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param dir 目的目录 + * @return 切换结果 true：成功，false：失败 + */ + private boolean cd(String dir) { + try { + return ftpClient.changeWorkingDirectory(dir); + } catch (IOException e) { + e.printStackTrace(); + return false; + } + } + + /** + *Title: 获取目录下所有的文件名称
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param filePath 指定的目录 + * @return 文件列表,或者null + */ + private FTPFile[] getFileList(String filePath) { + try { + return ftpClient.listFiles(filePath); + } catch (IOException e) { + e.printStackTrace(); + return null; + } + } + + /** + *Title: 层层切换工作目录
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param ftpPath 目的目录 + * @return 切换结果 + */ + public boolean changeDir(String ftpPath) { + if (!ftpClient.isConnected()) { + return false; + } + try { + // 将路径中的斜杠统一 + char[] chars = ftpPath.toCharArray(); + StringBuffer sbStr = new StringBuffer(256); + for (int i = 0; i < chars.length; i++) { + if ('\\' == chars[i]) { + sbStr.append('/'); + } else { + sbStr.append(chars[i]); + } + } + ftpPath = sbStr.toString(); + if (ftpPath.indexOf('/') == -1) { + // 只有一层目录 + ftpClient.changeWorkingDirectory(new String(ftpPath.getBytes(), "UTF-8")); + } else { + // 多层目录循环创建 + String[] paths = ftpPath.split("/"); + for (int i = 0; i < paths.length; i++) { + ftpClient.changeWorkingDirectory(new String(paths[i].getBytes(), "UTF-8")); + } + } + return true; + } catch (Exception e) { + e.printStackTrace(); + return false; + } + } + + /** + *Title: 循环创建目录，并且创建完目录后，设置工作目录为当前创建的目录下
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param ftpPath 需要创建的目录 + * @return + */ + public boolean mkDir(String ftpPath) { + if (!ftpClient.isConnected()) { + return false; + } + try { + // 将路径中的斜杠统一 + char[] chars = ftpPath.toCharArray(); + StringBuffer sbStr = new StringBuffer(256); + for (int i = 0; i < chars.length; i++) { + if ('\\' == chars[i]) { + sbStr.append('/'); + } else { + sbStr.append(chars[i]); + } + } + ftpPath = sbStr.toString(); + System.out.println("ftpPath:" + ftpPath); + if (ftpPath.indexOf('/') == -1) { + // 只有一层目录 + ftpClient.makeDirectory(new String(ftpPath.getBytes(), "UTF-8")); + ftpClient.changeWorkingDirectory(new String(ftpPath.getBytes(), "UTF-8")); + } else { + // 多层目录循环创建 + String[] paths = ftpPath.split("/"); + for (int i = 0; i < paths.length; i++) { + ftpClient.makeDirectory(new String(paths[i].getBytes(), "UTF-8")); + ftpClient.changeWorkingDirectory(new String(paths[i].getBytes(), "UTF-8")); + } + } + return true; + } catch (Exception e) { + e.printStackTrace(); + return false; + } + } + + /** + *Title: 上传文件到FTP服务器
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param //localDirectoryAndFileName 本地文件目录和文件名 + * @param ftpFileName 上传到服务器的文件名() + * @param ftpDirectory FTP目录如:/path1/pathb2/,如果目录不存在会自动创建目录(目录可以省略) + * @return + */ + //public boolean upload(String localDirectoryAndFileName, String ftpFileName, String ftpDirectory) { + public boolean upload(File srcFile, String ftpFileName, String ftpDirectory) { + + if (!ftpClient.isConnected()) { + return false; + } + boolean flag = false; + if (ftpClient != null) { + //File srcFile = new File(localDirectoryAndFileName); + FileInputStream fis = null; + try { + fis = new FileInputStream(srcFile); + // 创建目录 + this.mkDir(ftpDirectory); + ftpClient.setBufferSize(100000); + ftpClient.setControlEncoding("UTF-8"); + // 设置文件类型（二进制） + ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE); + + if (ftpFileName == null || ftpFileName == "") { + ftpFileName = srcFile.getName(); + } + + // 上传 + flag = ftpClient.storeFile(new String(ftpFileName.getBytes(), "UTF-8"), fis); + } catch (Exception e) { + this.close(); + e.printStackTrace(); + return false; + } finally { + try { + fis.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + } + System.out.println("上传文件成功，本地文件名： " + "，上传到目录：" + ftpDirectory + "/" + ftpFileName); + return flag; + } + + /** + *Title: 从FTP服务器上下载文件
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param ftpDirectoryAndFileName ftp服务器文件路径，以/dir形式开始 + * @param localDirectoryAndFileName 保存到本地的目录 + * @return + */ + public boolean get(String ftpDirectoryAndFileName, String localDirectoryAndFileName) { + if (!ftpClient.isConnected()) { + return false; + } + ftpClient.enterLocalPassiveMode(); // Use passive mode as default + try { + // 将路径中的斜杠统一 + char[] chars = ftpDirectoryAndFileName.toCharArray(); + StringBuffer sbStr = new StringBuffer(256); + for (int i = 0; i < chars.length; i++) { + if ('\\' == chars[i]) { + sbStr.append('/'); + } else { + sbStr.append(chars[i]); + } + } + ftpDirectoryAndFileName = sbStr.toString(); + String filePath = ftpDirectoryAndFileName.substring(0, ftpDirectoryAndFileName.lastIndexOf("/")); + String fileName = ftpDirectoryAndFileName.substring(ftpDirectoryAndFileName.lastIndexOf("/") + 1); + this.changeDir(filePath); + ftpClient.retrieveFile(new String(fileName.getBytes(), "UTF-8"), new FileOutputStream(localDirectoryAndFileName)); // download + // file + System.out.println(ftpClient.getReplyString()); // check result + System.out.println("从ftp服务器上下载文件：" + ftpDirectoryAndFileName + "， 保存到：" + localDirectoryAndFileName); + return true; + } catch (IOException e) { + e.printStackTrace(); + return false; + } + } + + /** + *Title: 返回FTP目录下的文件列表
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param pathName + * @return + */ + public String[] getFileNameList(String pathName) { + try { + return ftpClient.listNames(pathName); + } catch (IOException e) { + e.printStackTrace(); + return null; + } + } + + /** + *Title: 删除FTP上的文件
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param ftpDirAndFileName 路径开头不能加/，比如应该是test/filename1 + * @return + */ + public boolean deleteFile(String ftpDirAndFileName) { + if (!ftpClient.isConnected()) { + return false; + } + try { + return ftpClient.deleteFile(ftpDirAndFileName); + } catch (IOException e) { + e.printStackTrace(); + return false; + } + } + + /** + *Title: 删除FTP目录
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月11日 + * + * @param ftpDirectory + * @return + */ + public boolean deleteDirectory(String ftpDirectory) { + if (!ftpClient.isConnected()) { + return false; + } + try { + return ftpClient.removeDirectory(ftpDirectory); + } catch (IOException e) { + e.printStackTrace(); + return false; + } + } + + /** + *Title: 关闭链接
+ *Description:
+ * + * @author H.Yang + * @date 2018年3月10日 + * + */ + public void close() { + try { + if (ftpClient != null && ftpClient.isConnected()) { + ftpClient.disconnect(); + } + System.out.println("成功关闭连接，服务器ip:" + this.server + ", 端口:" + this.port); + } catch (Exception e) { + e.printStackTrace(); + } + } + + public static void main(String[] args) { + FTPUtils ftp = new FTPUtils("hellohao.cn", 21, "test", "test"); + boolean flag = ftp.open(); + if (flag) { + // 上传 + //ftp.upload("D:/新建文件夹/1.jpg", "/admin/shihao.jpg", ""); + + ftp.close(); + } + } + +} diff --git a/src/main/java/cn/hellohao/utils/StringUtils.java b/src/main/java/cn/hellohao/utils/StringUtils.java index f3cb8ab..74166fa 100644 --- a/src/main/java/cn/hellohao/utils/StringUtils.java +++ b/src/main/java/cn/hellohao/utils/StringUtils.java @@ -41,6 +41,11 @@ public class StringUtils { && k.getBucketname()!=null && k.getRequestAddress()!=null ) { return true; } + }else if(sourcekey==7){ + //FTP + if(k.getEndpoint()!=null && k.getAccessSecret()!=null && k.getEndpoint()!=null && k.getRequestAddress()!=null ) { + return true; + } } return false; } diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties index 628a18f..22fe57c 100644 --- a/src/main/resources/application.properties +++ b/src/main/resources/application.properties @@ -1,9 +1,9 @@ #ݿ˺ -spring.datasource.username=root +spring.datasource.username=picturebed #ݿ -spring.datasource.password=root +spring.datasource.password=Aa923453645 #ݿӵַ -spring.datasource.url=jdbc:mysql://localhost:3306/picturebed?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8 +spring.datasource.url=jdbc:mysql://129.28.173.126:3306/picturebed?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8 #˿ server.port=8088 #ڱʽ ·ʽΪÿߵִ diff --git a/src/main/resources/static/static/css/style.css b/src/main/resources/static/static/css/style.css index 5d7c603..13e9812 100644 --- a/src/main/resources/static/static/css/style.css +++ b/src/main/resources/static/static/css/style.css @@ -2110,7 +2110,7 @@ table.dataTable thead .sorting:after { border-color: #cfdadd; border-radius: 2px; width: 100%; - height: 30px; + /*height: 30px;*/ padding: 6px 12px; font-size: 14px; line-height: 1.42857143; diff --git a/src/main/resources/templates/admin/about.html b/src/main/resources/templates/admin/about.html index 3a6da6a..8282034 100644 --- a/src/main/resources/templates/admin/about.html +++ b/src/main/resources/templates/admin/about.html @@ -27,7 +27,7 @@开发者交流群：32452345342
-
当前系统版本：2019-07-25 检查更新
+当前系统版本：2019-07-26 检查更新
支持一下作者吧：
diff --git a/src/main/resources/templates/admin/storageconfig.html b/src/main/resources/templates/admin/storageconfig.html index fc2c393..e9d61ac 100644 --- a/src/main/resources/templates/admin/storageconfig.html +++ b/src/main/resources/templates/admin/storageconfig.html @@ -18,13 +18,14 @@
- 需带有http://或https://
+ 需带有http://或https://
@@ -141,11 +142,18 @@
$("#c3-1").css('display','block');
$("#keyusername").text('AccessKey');
$("#keypass").text('SecretKey');
- }else if(data.value=6){
+ }else if(data.value==6){
$("#c3-1").css('display','none');
$("#c3 label").text('地区代码');
$("#keyusername").text('SecretId');
$("#keypass").text('SecretKey');
+ }else if(data.value==7){
+ //$("#c3").css('display','none');
+ $("#c3-1").css('display','none');
+ $("#c4").css('display','none');
+ $("#keyusername").text('FTP账号');
+ $("#keypass").text('FTP密码');
+ $("#c3 label").text('FTP地址');
}else{
$("#c3").css('display','block');
$("#c3-1").css('display','none');
@@ -167,6 +175,13 @@
}else{
$("#ysm").text("需带有http://或https:");
}
+ if(data.value==7){
+ $("#c3 label").text('FTP地址');
+ $("#ysm").text('按格式填写如：127.0.0.1:21不需要添加ftp:// 推荐使用21默认端口，修改过得端口先用xftp等客户端工具测试一下能不能链接。');
+ }else{
+ $("#c3 label").text('Endpoint');
+ $("#ysm").text('需带有http://或https://');
+ }
$.ajax({
type: "POST",
url: "/admin/root/getkey",
@@ -243,8 +258,14 @@
$("#c3 label").text('地区代码');
$("#keyusername").text('SecretId');
$("#keypass").text('SecretKey');
- }
- else{
+ }else if(types==7){
+ //$("#c3").css('display','none');
+ $("#c3-1").css('display','none');
+ $("#c4").css('display','none');
+ //$("#c3 label").text('地区代码');
+ $("#keyusername").text('FTP账号');
+ $("#keypass").text('FTP密码');
+ }else{
$("#c3").css('display','block');
$("#c3-1").css('display','none');
$("#keyusername").text('AccessKey');
@@ -257,6 +278,14 @@
}else{
$("#ysm").text("需带有http://或https:");
}
+ if(types==7){
+ $("#c3 label").text('FTP地址');
+ $("#ysm").text('按格式填写如：127.0.0.1:21不需要添加ftp:// 推荐使用21默认端口，修改过得端口先用xftp等客户端工具测试一下能不能链接。');
+ }else{
+ $("#c3 label").text('Endpoint');
+ $("#ysm").text('需带有http://或https://');
+ }
+
});
//保存KEY
@@ -292,7 +321,33 @@
}
}
});
- }else{
+ }else if($("#StorageType").val()==7){
+ if(AccessKey!="" && AccessSecret!="" &&Endpoint!="" && RequestAddress!="" && StorageType!=""){
+ $.ajax({
+ type: "POST",
+ url: "/admin/root/updatekey",
+ data: {
+ AccessKey: AccessKey,
+ AccessSecret: AccessSecret,
+ Endpoint: Endpoint,
+ Bucketname: Bucketname,
+ RequestAddress: RequestAddress,
+ StorageType: StorageType
+ },
+ dataType: "json",
+ success: function (data) {
+ if (data > 0) {
+ layer.msg("保存成功", {icon: 1});
+ } else {
+ layer.msg("保存失败", {icon: 2});
+ }
+ }
+ });
+ }else{
+ layer.msg("有参数不正确，请检查", {icon: 2});
+ }
+ }
+ else{
if(AccessKey!="" && AccessSecret!="" &&Endpoint!="" && Bucketname!="" && RequestAddress!="" && StorageType!=""){
$.ajax({
type: "POST",
diff --git a/src/main/resources/templates/admin/survey.html b/src/main/resources/templates/admin/survey.html
index a6dc8e9..b6edab5 100644
--- a/src/main/resources/templates/admin/survey.html
+++ b/src/main/resources/templates/admin/survey.html
@@ -190,6 +190,8 @@
str = '本地存储';
}else if (data.source == 6) {
str = '腾云COS';
+ }else if (data.source == 7) {
+ str = 'FTP存储';
}else {
str = '未知';
}
diff --git a/src/main/resources/templates/admin/table.html b/src/main/resources/templates/admin/table.html
index e6d8582..204c68a 100644
--- a/src/main/resources/templates/admin/table.html
+++ b/src/main/resources/templates/admin/table.html
@@ -88,6 +88,7 @@
+
@@ -148,39 +149,6 @@
// 分页
fenye('/admin/selecttable', 1);//1代表查询所有人
-
- // $("#myselect").change(function () {
- // var opt = $("#myselect").val();
- // // 先销毁table中的数据
- // $("#table_server").bootstrapTable('destroy');
- // fenye('/admin/selecttable', opt);
- // });
-
- //获取本站概况
- // $.ajax({
- // type: "POST",
- // url: "/admin/getwebconfig",
- // dataType: "json",
- // success: function (data) {
- // $("#counts").text(data.counts);
- // $("#getusertotal").text(data.getusertotal);
- // $("#imgreviewcount").text(data.imgreviewcount);
- // $("#usercount").text(data.usercount);
- // var str = "";
- // if (data.source == 1) {
- // str = "网易NOS";
- // } else if (data.source == 2) {
- // str = "阿里OSS";
- // } else if (data.source == 3) {
- // str = "又拍USS";
- // } else if (data.source == 4) {
- // str = '七牛KODO';
- // } else {
- // str = '未知';
- // }
- // $("#source").text(str);
- // }
- // });
});
function screening(){
$("#table_server").bootstrapTable('destroy');
@@ -449,8 +417,9 @@
source = '本地存储';
}else if (rows.source == 6) {
source = '腾讯COS';
- }
- else {
+ }else if (rows.source == 7) {
+ source = 'FTP存储';
+ }else {
source = '未知';
}
return source;
diff --git a/src/main/resources/templates/index.html b/src/main/resources/templates/index.html
index c417943..3c94cfc 100644
--- a/src/main/resources/templates/index.html
+++ b/src/main/resources/templates/index.html
@@ -234,7 +234,7 @@ Technology constantly updated, we will always move forward on the road ahead.
+ 
+ 