update:优化线程池

README.md

@@ -39,11 +39,14 @@
 [Core版](https://hellohao.cn)：开源版的基础上增加`Backblaze(B2)` 并且可`同个对象存储商家`可开多个存储源（可添加至90+存储源）
 
 
-### 更新日志 `20240111`
+### 更新日志 `20240124`
 
+- 新增支持对接WebDAV存储源
 - 修复本地存储源上传失败的情况
 - 修复某些存储源目录创建不正确的问题
 - 优化页面部分提示
+- 修复潜在的一些安全隐患
+
 
 
 ### 主要功能
@@ -151,6 +154,8 @@
 
 更多部署教程参考程序[相关文档](http://doc.hellohao.cn)
 
+更强大的功能可[购买Core版](http://tbed.hellohao.cn/pay)程序
+
 
 ### 启动项目
 > 访问你的前端域名即可
@@ -186,7 +191,7 @@
 
 ![Hellohao图像托管](https://hellohao.cn/newassets/img/twechat.png)
 
-[//]: # (![Hellohao图像托管](https://upload.cc/i1/2022/03/28/Vnp0bT.png))
+[//]: # "![Hellohao图像托管](https://upload.cc/i1/2022/03/28/Vnp0bT.png)"
 
 
 ### 运行环境
@@ -233,4 +238,3 @@ Hellohao图像托管已申请[**中国国家版权局计算机软件著作权**]
 **如需程序定制或其他业务，请与我们取得联系**
 [Hellohao图像托管官网](http://hellohao.cn)
 
-

pom.xml

@@ -248,7 +248,7 @@
                 <configuration>
                     <testFailureIgnore>true</testFailureIgnore>
                 </configuration>
-            </plugin>
+            </plugin><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><configuration><source>8</source><target>8</target></configuration></plugin>
         </plugins>
     </build>
 

src/main/java/cn/hellohao/auth/shiro/ShiroConfig.java

@@ -33,6 +33,7 @@ public class ShiroConfig {
         filterMap.put("/verifyCodeForRetrieve","anon");
         filterMap.put("/verifyCodeFortowSendEmail","anon");
         filterMap.put("/api/**","anon");
+        filterMap.put("/w/**","anon");
         filterMap.put("/user/**","anon");
         filterMap.put("/ota/**","anon");
         filterMap.put("/admin/root/**","roles[admin]");

src/main/java/cn/hellohao/config/PoolConfig.java

@@ -16,9 +16,9 @@ public class PoolConfig {
     @Bean(name = "taskExecutor")
     public ThreadPoolTaskExecutor taskExecutor() {
         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(properties.getCorePoolSize());
-        executor.setMaxPoolSize(properties.getMaxPoolSize());
-        executor.setQueueCapacity(properties.getQueueCapacity());
+        executor.setCorePoolSize(properties.getCorePoolSize()); //设置核心线程数
+        executor.setMaxPoolSize(properties.getMaxPoolSize()); //设置最大线程数
+        executor.setQueueCapacity(properties.getQueueCapacity()); //设置队列容量
         executor.setThreadNamePrefix(properties.getThreadNamePrefix());
         executor.setKeepAliveSeconds(properties.getKeepAliveTime());
         executor.setWaitForTasksToCompleteOnShutdown(properties.isWaitForTasksToCompleteOnShutdown());
@@ -42,7 +42,7 @@ public class PoolConfig {
         private int corePoolSize = 5;
         private int maxPoolSize = 50;
         private int keepAliveTime = 15;
-        private int queueCapacity = 6;
+        private int queueCapacity = 10;
         private String threadNamePrefix = "Tbed-Thread";
         private boolean allowCoreThreadTimeout = false;
         private boolean waitForTasksToCompleteOnShutdown = false;

src/main/java/cn/hellohao/controller/AdminController.java

@@ -7,7 +7,6 @@ import cn.hellohao.service.*;
 import cn.hellohao.service.impl.AlbumServiceImpl;
 import cn.hellohao.service.impl.UserServiceImpl;
 import cn.hellohao.service.impl.deleImages;
-import cn.hellohao.utils.Base64Encryption;
 import cn.hellohao.utils.SetFiles;
 import cn.hellohao.utils.SetText;
 import cn.hellohao.utils.progress.MyProgress;
@@ -28,10 +27,7 @@ import org.springframework.web.bind.annotation.ResponseBody;
 
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.UUID;
+import java.util.*;
 
 /**
  * @author Hellohao
@@ -444,10 +440,11 @@ public class AdminController {
                         user.setEmail(email);
                     }
                 }
-                user.setPassword(Base64Encryption.encryptBASE64(password.getBytes()));
+
+                user.setPassword(Base64.getEncoder().encodeToString(password.getBytes()));
                 user.setUid(u.getUid());
             } else {
-                user.setPassword(Base64Encryption.encryptBASE64(password.getBytes()));
+                user.setPassword(Base64.getEncoder().encodeToString(password.getBytes()));
                 user.setUid(u.getUid());
             }
             userService.change(user);

src/main/java/cn/hellohao/controller/AdminRootController.java

@@ -47,6 +47,22 @@ public class AdminRootController {
     private ImgreviewService imgreviewService;
     @Autowired
     private AppClientService appClientService;
+    @Autowired
+    private NOSImageupload nOSImageupload;
+    @Autowired
+    private OSSImageupload ossImageupload;
+    @Autowired
+    private USSImageupload ussImageupload;
+    @Autowired
+    private KODOImageupload kodoImageupload;
+    @Autowired
+    private COSImageupload cosImageupload;
+    @Autowired
+    private FtpServiceImpl ftpService;
+    @Autowired
+    private S3Imageupload s3Imageupload;
+    @Autowired
+    private WebDAVImageupload webDAVImageupload;
 
 
     @PostMapping(value = "/getUserList")
@@ -189,19 +205,21 @@ public class AdminRootController {
             Keys key = keysService.selectKeys(keyId);
             Integer ret = 0;
             if (key.getStorageType() == 1) {
-                ret = NOSImageupload.Initialize(key);
+                ret = nOSImageupload.Initialize(key);
             } else if (key.getStorageType() == 2) {
-                ret = OSSImageupload.Initialize(key);
+                ret = ossImageupload.Initialize(key);
             } else if (key.getStorageType() == 3) {
-                ret = USSImageupload.Initialize(key);
+                ret = ussImageupload.Initialize(key);
             } else if (key.getStorageType() == 4) {
-                ret = KODOImageupload.Initialize(key);
+                ret = kodoImageupload.Initialize(key);
             } else if (key.getStorageType() == 6) {
-                ret = COSImageupload.Initialize(key);
+                ret = cosImageupload.Initialize(key);
             } else if (key.getStorageType() == 7) {
-                ret = FtpServiceImpl.Initialize(key);
+                ret = ftpService.Initialize(key);
             } else if (key.getStorageType() == 8) {
-                ret = S3Imageupload.Initialize(key);
+                ret = s3Imageupload.Initialize(key);
+            }else if (key.getStorageType() == 9) {
+                ret = webDAVImageupload.Initialize(key);
             }
             Long l = imgService.getsourcememory(keyId);
             jsonObject.put("isok", ret);
@@ -224,23 +242,6 @@ public class AdminRootController {
     @ResponseBody
     public Msg updateStorage(@RequestParam(value = "data", defaultValue = "") String data) {
         JSONObject jsonObj = JSONObject.parseObject(data);
-//        Integer id = jsonObj.getInteger("id");
-//        String AccessKey = jsonObj.getString("AccessKey");
-//        String AccessSecret = jsonObj.getString("AccessSecret");
-//        String Endpoint = jsonObj.getString("Endpoint");
-//        String Bucketname = jsonObj.getString("Bucketname");
-//        String RequestAddress = jsonObj.getString("RequestAddress");
-//        Integer storageType = jsonObj.getInteger("storageType");
-//        String keyname = jsonObj.getString("keyname");
-//        Keys keys = new Keys();
-//        keys.setId(id);
-//        keys.setAccessKey(AccessKey);
-//        keys.setAccessSecret(AccessSecret);
-//        keys.setEndpoint(Endpoint);
-//        keys.setBucketname(Bucketname);
-//        keys.setRequestAddress(RequestAddress);
-//        keys.setStorageType(storageType);
-//        keys.setKeyname(keyname);
         Keys keys = JSON.toJavaObject(jsonObj,Keys.class);
         Msg msg = keysService.updateKey(keys);
         return msg;

src/main/java/cn/hellohao/controller/IndexController.java

@@ -5,6 +5,7 @@ import cn.hellohao.config.GlobalConstant;
 import cn.hellohao.pojo.*;
 import cn.hellohao.service.*;
 import cn.hellohao.service.impl.UploadServicel;
+import cn.hellohao.service.impl.WebDAVImageupload;
 import cn.hellohao.service.impl.deleImages;
 import cn.hellohao.utils.GetIPS;
 import cn.hellohao.utils.MyVersion;
@@ -19,6 +20,8 @@ import org.apache.shiro.SecurityUtils;
 import org.apache.shiro.authc.UsernamePasswordToken;
 import org.apache.shiro.subject.Subject;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.io.InputStreamResource;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.*;
@@ -43,8 +46,8 @@ public class IndexController {
     @Autowired private deleImages deleimages;
     @Autowired private IRedisService iRedisService;
     @Autowired private AppClientService appClientService;
-
-    public static String version =  "20240111";
+    @Autowired private WebDAVImageupload webDAVImageupload;
+    public static String version =  "20240124";
     @RequestMapping(value = "/")
     public String Welcome(Model model, HttpServletRequest httpServletRequest) {
         model.addAttribute("name", "服务端程序(开源版)");
@@ -191,6 +194,14 @@ public class IndexController {
         return retMsg;
     }
 
+    //webdav本地托管
+    @GetMapping("/w/{shortuuid}")
+    public ResponseEntity<InputStreamResource> getNextcloudImage(HttpServletRequest request, @PathVariable("shortuuid") String shortuuid) {
+        ResponseEntity<InputStreamResource> webDAV = webDAVImageupload.getWebDAV(shortuuid);
+        return webDAV;
+
+    }
+
     @RequestMapping(value = "/getUploadInfo")
     @ResponseBody
     public Msg getUploadInfo() {

src/main/java/cn/hellohao/controller/UserController.java

@@ -5,7 +5,6 @@ import cn.hellohao.auth.token.JWTUtil;
 import cn.hellohao.config.SysName;
 import cn.hellohao.pojo.*;
 import cn.hellohao.service.*;
-import cn.hellohao.utils.Base64Encryption;
 import cn.hellohao.utils.NewSendEmail;
 import cn.hellohao.utils.Print;
 import cn.hellohao.utils.SetText;
@@ -27,6 +26,7 @@ import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import javax.servlet.http.HttpSession;
 import java.text.SimpleDateFormat;
+import java.util.Base64;
 import java.util.Date;
 import java.util.UUID;
 
@@ -55,7 +55,7 @@ public class UserController {
         JSONObject jsonObj = JSONObject.parseObject(data);
         String username = jsonObj.getString("username");
         String email = jsonObj.getString("email");
-        String password = Base64Encryption.encryptBASE64(jsonObj.getString("password").getBytes());
+        String password = Base64.getEncoder().encodeToString(jsonObj.getString("password").getBytes());
         String verifyCodeForRegister = jsonObj.getString("verifyCode");
         Object redis_verifyCodeForRegister = iRedisService.getValue("verifyCodeForRegister_"+httpServletRequest.getHeader("verifyCodeForRegister"));
         if(!SetText.checkEmail(email)){
@@ -203,7 +203,7 @@ public class UserController {
         Msg msg = new Msg();
         JSONObject jsonObj = JSONObject.parseObject(data);
         String email = jsonObj.getString("email");
-        String password = Base64Encryption.encryptBASE64(jsonObj.getString("password").getBytes());
+        String password = Base64.getEncoder().encodeToString(jsonObj.getString("password").getBytes());
         String verifyCode = jsonObj.getString("verifyCode");
         if(null == email || null == password || null == verifyCode){
             msg.setCode("5000");
@@ -385,7 +385,7 @@ public class UserController {
             User user = userService.getUsers(u2);
             user.setIsok(1);
             String new_pass = HexUtil.decodeHexStr(cip);//解密密码
-            user.setPassword(Base64Encryption.encryptBASE64(new_pass.getBytes()));
+            user.setPassword(Base64.getEncoder().encodeToString(new_pass.getBytes()));
             String uid = UUID.randomUUID().toString().replace("-", "").toLowerCase();
             user.setUid(uid);
             if (user != null) {

src/main/java/cn/hellohao/pojo/Keys.java

@@ -16,4 +16,7 @@ public class Keys {
     private String RootPath;//存入的目录
     private Boolean SysTransmit;
 
+    public Boolean getSysTransmit() {
+        return SysTransmit==null?false:SysTransmit;
+    }
 }

src/main/java/cn/hellohao/quartz/job/FirstJob.java

@@ -34,6 +34,8 @@ public class FirstJob {
 	@Autowired
 	private S3Imageupload s3Imageupload;
 	@Autowired
+	private WebDAVImageupload webDAVImageupload;
+	@Autowired
 	private FtpServiceImpl ftpService;
 	@Autowired
 	ImgTempService imgTempService;
@@ -78,6 +80,8 @@ public class FirstJob {
 					firstJob.ftpService.delFTP(keys.getId(), images);
 				}else if(keys.getStorageType()==8){
 					firstJob.s3Imageupload.deleS3(keys.getId(), images);
+				}else if(keys.getStorageType()==9){
+					firstJob.webDAVImageupload.delWebDAV(keys.getId(), images);
 				}else{
 					System.err.println("未获取到对象存储参数，上传失败。");
 				}

src/main/java/cn/hellohao/service/impl/ClientService.java

@@ -11,6 +11,8 @@ import org.apache.commons.codec.digest.DigestUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -26,12 +28,11 @@ import java.util.*;
  * @date 2021/10/28 16:38
  */
 @Service
+@EnableAsync
 public class ClientService {
     private static Logger logger = LoggerFactory.getLogger(ClientService.class);
-    @Autowired
-    ConfdataService confdataService;
-    @Autowired
-    SysConfigService sysConfigService;
+    @Autowired private ConfdataService confdataService;
+    @Autowired private SysConfigService sysConfigService;
     @Autowired private UserMapper userMapper;
     @Autowired private KeysMapper keysMapper;
     @Autowired private UploadConfigMapper uploadConfigMapper;
@@ -40,6 +41,7 @@ public class ClientService {
     @Autowired private GetSource getSource;
     @Autowired private ImgViolationJudgeServiceImpl imgViolationJudgeService;
 
+    @Async("taskExecutor")
     public Msg uploadImg(
             HttpServletRequest request, MultipartFile multipartFile, String email, String pass,Integer setday) {
         Msg msg = new Msg();
@@ -67,7 +69,7 @@ public class ClientService {
                 return msg;
             }
             u2.setEmail(email);
-            u2.setPassword(Base64Encryption.encryptBASE64(pass.getBytes()));
+            u2.setPassword(Base64.getEncoder().encodeToString(pass.getBytes()));
             User u = userMapper.getUsers(u2);
             if (null == u || u.getIsok() != 1) {
                 msg.setCode("4006");
@@ -142,8 +144,10 @@ public class ClientService {
                 imgnameEd = updatePath + "/" + shortUuid_y + "." + prefix;
                 imgObj.setImgname(imgnameEd);
                 if (key.getStorageType().equals(5)) {
-                    imgObj.setImgurl(key.getRequestAddress() + "/ota/" + imgnameEd);
-                } else {
+                    imgObj.setImgurl(confdata.getString("domain") + "/ota/" + imgnameEd);
+                } else if(key.getStorageType().equals(9) && key.getSysTransmit()){
+                    imgObj.setImgurl(confdata.getString("domain") + "/w/" + shortUuid_y);
+                }else {
                     imgObj.setImgurl(key.getRequestAddress() + "/" + imgnameEd);
                 }
                 imgObj.setSizes(Long.toString(file.length()));

src/main/java/cn/hellohao/service/impl/InitializationStorage.java

@@ -58,6 +58,8 @@ public class InitializationStorage implements CommandLineRunner {
                     FtpServiceImpl.Initialize(key);
                 }else if(key.getStorageType()==8){
                     S3Imageupload.Initialize(key);
+                }else if(key.getStorageType()==9){
+                    WebDAVImageupload.Initialize(key);
                 }
             }
         }

src/main/java/cn/hellohao/service/impl/KeysServiceImpl.java

@@ -2,6 +2,7 @@ package cn.hellohao.service.impl;
 
 import cn.hellohao.pojo.Msg;
 import cn.hellohao.utils.Print;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -30,6 +31,8 @@ public class KeysServiceImpl implements KeysService {
     private FtpServiceImpl ftpService;
     @Autowired
     private S3Imageupload s3Imageupload;
+    @Autowired
+    private WebDAVImageupload webDAVImageupload;
 
 
     @Override
@@ -51,6 +54,29 @@ public class KeysServiceImpl implements KeysService {
     public Msg updateKey(Keys key) {
         Msg msg = new Msg();
         Integer ret = -2;
+        //修正一边数据格式，去除末尾的斜杠
+        if(key.getStorageType()==9 || key.getStorageType()==8){
+            //s3或者webdav
+            if(!StringUtils.isBlank(key.getRootPath()) && !key.getRootPath().equals("/")){
+                if (key.getRootPath().endsWith("/")) {
+                    String rootpath = key.getRootPath();
+                    key.setRootPath(rootpath.substring(0, rootpath.length() - 1));
+                }
+            }
+        }
+        if(!StringUtils.isBlank(key.getEndpoint())){
+            final String endpoint = key.getEndpoint();
+            if (endpoint.endsWith("/")) {
+                key.setEndpoint(endpoint.substring(0, endpoint.length() - 1));
+            }
+        }
+        if(!StringUtils.isBlank(key.getRequestAddress())){
+            final String requestAddress = key.getRequestAddress();
+            if (requestAddress.endsWith("/")) {
+                key.setRequestAddress(requestAddress.substring(0, requestAddress.length() - 1));
+            }
+        }
+
         if(key.getStorageType()==1){
             ret =nOSImageupload.Initialize(key);
         }else if (key.getStorageType()==2){
@@ -67,6 +93,8 @@ public class KeysServiceImpl implements KeysService {
             ret = ftpService.Initialize(key);
         }else if(key.getStorageType()==8){
             ret = s3Imageupload.Initialize(key);
+        }else if(key.getStorageType()==9){
+            ret = webDAVImageupload.Initialize(key);
         }else{
             Print.Normal("为获取到存储参数，或者使用存储源是本地的。");
         }

src/main/java/cn/hellohao/service/impl/UploadServicel.java

@@ -18,6 +18,8 @@ import org.apache.shiro.subject.Subject;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.stereotype.Service;
 
 import javax.servlet.http.HttpServletRequest;
@@ -33,6 +35,7 @@ import java.util.concurrent.CompletableFuture;
  * @date 2020/1/9 15:46
  */
 @Service
+@EnableAsync
 public class UploadServicel {
     private static Logger logger = LoggerFactory.getLogger(UploadServicel.class);
     @Autowired
@@ -48,6 +51,7 @@ public class UploadServicel {
     @Autowired deleImages deleimages;
     @Autowired ImgViolationJudgeServiceImpl imgViolationJudgeService;
 
+    @Async("taskExecutor")
     public Msg uploadForLoc(
             HttpServletRequest request,
             File file,
@@ -148,8 +152,10 @@ public class UploadServicel {
                 imgnameEd = updatePath + "/" + shortUuid_y + "." + prefix;
                 imgObj.setImgname(imgnameEd);
                 if (key.getStorageType().equals(5)) {
-                    imgObj.setImgurl(key.getRequestAddress() + "/ota/" + imgnameEd);
-                } else {
+                    imgObj.setImgurl(confdata.getString("domain") + "/ota/" + imgnameEd);
+                } else if(key.getStorageType().equals(9) && key.getSysTransmit()){
+                    imgObj.setImgurl(confdata.getString("domain") + "/w/" + shortUuid_y);
+                }else {
                     imgObj.setImgurl(key.getRequestAddress() + "/" + imgnameEd);
                 }
                 imgObj.setSizes(Long.toString(file.length()));

src/main/java/cn/hellohao/service/impl/WebDAVImageupload.java

@@ -48,8 +48,6 @@ public class WebDAVImageupload {
     private static Logger logger = LoggerFactory.getLogger(WebDAVImageupload.class);
     public ReturnImage ImageuploadWebDAV(Map<Map<String, String>, File> fileMap, String username,Integer keyID) {
         ReturnImage returnImage = new ReturnImage();
-        CloseableHttpClient httpClient  =null;
-        Keys key = null;
         try {
             if(null==httpClient || null==key){
                 System.out.println("WebDAV = 存储源对象为空");
@@ -69,9 +67,7 @@ public class WebDAVImageupload {
                 String ShortUIDName = entry.getKey().get("name");
                 file = entry.getValue();
                 Msg fileMiME = TypeDict.FileMiME(file);
-                //webdav不能自动创建目录，上传件先创建目录
                 createDirectories(httpClient, key.getEndpoint(),  "/" + username);
-                //上传文件
                 System.out.println("WebDAV地址："+key.getEndpoint() + "/" + username + "/" + ShortUIDName + "." + prefix);
                 HttpPut httpPut = new HttpPut(key.getEndpoint() + "/" + username + "/" + ShortUIDName + "." + prefix);
                 FileEntity fileEntity = new FileEntity(file, ContentType.DEFAULT_BINARY);
@@ -79,10 +75,7 @@ public class WebDAVImageupload {
                 HttpResponse response = httpClient.execute(httpPut);
                 final int statusCode = response.getStatusLine().getStatusCode();
                 logger.info("WebDav上传响应代码："+statusCode);
-//                System.out.println(response.getStatusLine().getStatusCode());//正常成功201  已经存在204（有可能204还代表其他意思）
-//                System.out.println("File upload response for " + file.getName() + ": " + response.getStatusLine());
                 EntityUtils.consume(response.getEntity());
-//                System.out.println(EntityUtils.toString(response.getEntity(),"UTF-8"));
                 if(statusCode >= 200 && statusCode < 300){
                     returnImage.setCode("200");
                 }else{
@@ -100,29 +93,29 @@ public class WebDAVImageupload {
     //webdav初始化
     public static Integer Initialize(Keys k) {
         int ret = -1;
-        if(k.getSysTransmit()==false){
-            if (StringUtils.isBlank(k.getAccessKey())
-                    || StringUtils.isBlank(k.getAccessSecret())
-                    || StringUtils.isBlank(k.getEndpoint())
-                    || StringUtils.isBlank(k.getRequestAddress())) {
-                return -1;
-            }
-        }else{
-            if (StringUtils.isBlank(k.getAccessKey())
-                    || StringUtils.isBlank(k.getAccessSecret())
-                    || StringUtils.isBlank(k.getEndpoint())) {
-                return -1;
-            }
-        }
-        String endpoint = k.getEndpoint();
-        CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
-        credentialsProvider.setCredentials(
-                new AuthScope(AuthScope.ANY_HOST, AuthScope.ANY_PORT),
-                new UsernamePasswordCredentials(k.getAccessKey(), k.getAccessSecret()));
-        CloseableHttpClient httpClientObj = HttpClients.custom()
-                .setDefaultCredentialsProvider(credentialsProvider)
-                .build();
         try {
+            if(k.getSysTransmit()==false){
+                if (StringUtils.isBlank(k.getAccessKey())
+                        || StringUtils.isBlank(k.getAccessSecret())
+                        || StringUtils.isBlank(k.getEndpoint())
+                        || StringUtils.isBlank(k.getRequestAddress())) {
+                    return -1;
+                }
+            }else{
+                if (StringUtils.isBlank(k.getAccessKey())
+                        || StringUtils.isBlank(k.getAccessSecret())
+                        || StringUtils.isBlank(k.getEndpoint())) {
+                    return -1;
+                }
+            }
+            String endpoint = k.getEndpoint();
+            CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
+            credentialsProvider.setCredentials(
+                    new AuthScope(AuthScope.ANY_HOST, AuthScope.ANY_PORT),
+                    new UsernamePasswordCredentials(k.getAccessKey(), k.getAccessSecret()));
+            CloseableHttpClient httpClientObj = HttpClients.custom()
+                    .setDefaultCredentialsProvider(credentialsProvider)
+                    .build();
             HttpUriRequest request = RequestBuilder.create("PROPFIND")
                     .setUri(endpoint +"/"+ k.getRootPath())
                     .addHeader("Depth", "1")
@@ -185,19 +178,11 @@ public class WebDAVImageupload {
             String fileUrl = keys.getEndpoint()+"/"+images.getImgname();
             HttpGet httpGet = new HttpGet(fileUrl);
             HttpResponse response = httpClient.execute(httpGet);
-//            if (sardine.exists(keys.getEndpoint() + images.getImgname())) {
-//                InputStream inputStream = sardine.get(keys.getEndpoint() + images.getImgname());
                 HttpHeaders headers = new HttpHeaders();
                 headers.add("Content-Type", "image/jpeg");
-//                headers.add("Content-disposition", "attachment; filename=wallhaven-5g6yr3.jpg");
                 return ResponseEntity.ok()
                         .headers(headers)
-                        //.header("Content-disposition", "attachment; filename=Nextcloud.png")
-//                        .header("Content-Type", "image/jpg")
                         .body(new InputStreamResource(response.getEntity().getContent()));
-//            } else {
-//                return ResponseEntity.status(HttpStatus.NOT_FOUND).body(null);
-//            }
         } catch (IOException e) {
             return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(null);
         }

src/main/java/cn/hellohao/service/impl/deleImages.java

@@ -26,6 +26,7 @@ public class deleImages {
   @Autowired private USSImageupload ussImageupload;
   @Autowired private S3Imageupload s3Imageupload;
   @Autowired private FtpServiceImpl ftpService;
+  @Autowired private WebDAVImageupload webDAVImageupload;
   @Autowired private ImgAndAlbumService imgAndAlbumService;
   @Autowired private ImgTempService imgTempService;
   @Autowired private ImgService imgService;
@@ -75,6 +76,8 @@ public class deleImages {
           isDele = ftpService.delFTP(key.getId(), image);
         } else if (key.getStorageType() == 8) {
           isDele = s3Imageupload.deleS3(key.getId(), image);
+        }else if (key.getStorageType() == 9) {
+          isDele = webDAVImageupload.delWebDAV(key.getId(), image);
         } else {
           System.err.println("未获取到对象存储参数，删除失败。");
         }
@@ -149,6 +152,8 @@ public class deleImages {
           ftpService.delFTP(key.getId(), image);
         } else if (key.getStorageType() == 8) {
           s3Imageupload.deleS3(key.getId(), image);
+        }else if (key.getStorageType() == 9) {
+          webDAVImageupload.delWebDAV(key.getId(), image);
         } else {
           System.err.println("未获取到对象存储参数，删除失败。");
         }

src/main/java/cn/hellohao/utils/Base64Encryption.java

@@ -1,29 +1,51 @@
-package cn.hellohao.utils;
-
-import sun.misc.BASE64Decoder;
-import sun.misc.BASE64Encoder;
-
-import java.io.IOException;
-import java.util.Base64;
- 
-/**
- * Created by Hellohao on 2019-08-27.
- */
-public class Base64Encryption {
-    public static void toBaseCode(String str) {
-        String data = encryptBASE64(str.getBytes());
-    }
-    public static String decryptBASE64(String key)  {
-        byte[] b =null;
-        try {
-            b = (new BASE64Decoder()).decodeBuffer(key);
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
-        return  new String(b);
-    }
-    public static String encryptBASE64(byte[] key)  {
-        String string = "SGVsbG9oYW8K";
-        return (new BASE64Encoder()).encodeBuffer(key).replaceAll("\r|\n", "");
-    }
-}
+//package cn.hellohao.utils;
+//
+//import java.io.IOException;
+//import java.util.Base64;
+//
+///**
+// * Created by Hellohao on 2019-08-27.
+// */
+//public class Base64Encryption {
+////    public static void toBaseCode(String str) {
+////        String data = encryptBASE64(str.getBytes());
+////    }
+////    public static String decryptBASE64(String key)  {
+////        byte[] b =null;
+////        try {
+////            b = (new BASE64Decoder()).decodeBuffer(key);
+////        } catch (IOException e) {
+////            e.printStackTrace();
+////        }
+////        return  new String(b);
+////    }
+////    public static String encryptBASE64(byte[] key)  {
+////        String string = "SGVsbG9oYW8K";
+////        return (new BASE64Encoder()).encodeBuffer(key).replaceAll("\r|\n", "");
+////    }
+//
+//
+//    public static void toBaseCode(String str) {
+//        String data = encryptBASE64(str.getBytes());
+//    }
+//
+//    public static String decryptBASE64(String key) {
+//        byte[] b = null;
+//        try {
+//            b = Base64.getDecoder().decode(key);
+//        } catch (IllegalArgumentException e) {
+//            e.printStackTrace();
+//        }
+//        return new String(b);
+//    }
+//
+//    public static String encryptBASE64(byte[] key) {
+//        String string = "SGVsbG9oYW8K";
+//        return Base64.getEncoder().encodeToString(key);
+//    }
+//
+//
+//
+//
+//
+//}

src/main/java/cn/hellohao/utils/Base64ToMultipartFile.java

@@ -1,9 +1,9 @@
 package cn.hellohao.utils;
 
 import org.springframework.web.multipart.MultipartFile;
-import sun.misc.BASE64Decoder;
 
 import java.io.*;
+import java.util.Base64;
 
 /**
  * base64转为multipartFile工具类
@@ -74,21 +74,30 @@ public class Base64ToMultipartFile implements MultipartFile {
      * @return
      */
     public static MultipartFile base64Convert(String base64) {
-        String[] baseStrs = base64.split(",");
+//        String[] baseStrs = base64.split(",");
+//        BASE64Decoder decoder = new BASE64Decoder();
+//        byte[] b = new byte[0];
+//        try {
+//            b = decoder.decodeBuffer(baseStrs[1]);
+//        } catch (IOException e) {
+//            e.printStackTrace();
+//        }
+//        for (int i = 0; i < b.length; ++i) {
+//            if (b[i] < 0) {
+//                b[i] += 256;
+//            }
+//        }
+//        return new Base64ToMultipartFile (b, baseStrs[0]);
 
-        BASE64Decoder decoder = new BASE64Decoder();
-        byte[] b = new byte[0];
-        try {
-            b = decoder.decodeBuffer(baseStrs[1]);
-        } catch (IOException e) {
-            e.printStackTrace();
-        }
+        String[] baseStrs = base64.split(",");
+        byte[] b = Base64.getDecoder().decode(baseStrs[1]);
         for (int i = 0; i < b.length; ++i) {
             if (b[i] < 0) {
                 b[i] += 256;
             }
         }
-        return new Base64ToMultipartFile (b, baseStrs[0]);
+        return new Base64ToMultipartFile(b, baseStrs[0]);
+
     }
 
 

src/main/java/cn/hellohao/utils/GetSource.java

@@ -31,7 +31,8 @@ public class GetSource {
     FtpServiceImpl ftpService;
     @Autowired
     S3Imageupload s3Imageupload;
-
+    @Autowired
+    WebDAVImageupload webDAVImageupload;
     public ReturnImage storageSource(Integer type, Map<Map<String, String>, File> fileMap, String userpath,Integer keyID){
         ReturnImage returnImage = null;
         try {
@@ -52,7 +53,7 @@ public class GetSource {
             }else if(type==8){
                 returnImage =  s3Imageupload.ImageuploadS3(fileMap, userpath,keyID);
             }else if(type==9){
-                returnImage =  s3Imageupload.ImageuploadS3(fileMap, userpath,keyID);
+                returnImage =  webDAVImageupload.ImageuploadWebDAV(fileMap, userpath,keyID);
             }
             else{
                 new StorageSourceInitException("GetSource类捕捉异常：未找到存储源");

src/main/java/cn/hellohao/utils/verifyCode/SimpleCharVerifyCodeGenImpl.java

@@ -30,22 +30,22 @@ private static final int VALICATE_CODE_LENGTH = 4;
 * @param height
 */
 private static void fillBackground(Graphics graphics, int width, int height) {
-// 填充背景
-graphics.setColor(Color.WHITE);
-//设置矩形坐标x y 为0
-graphics.fillRect(0, 0, width, height);
+    // 填充背景
+    graphics.setColor(Color.WHITE);
+    //设置矩形坐标x y 为0
+    graphics.fillRect(0, 0, width, height);
 
-// 加入干扰线条
-for (int i = 0; i < 8; i++) {
-//设置随机颜色算法参数
-graphics.setColor(RandomUtils.randomColor(40, 150));
-Random random = new Random();
-int x = random.nextInt(width);
-int y = random.nextInt(height);
-int x1 = random.nextInt(width);
-int y1 = random.nextInt(height);
-graphics.drawLine(x, y, x1, y1);
-}
+    // 加入干扰线条
+    for (int i = 0; i < 8; i++) {
+    //设置随机颜色算法参数
+    graphics.setColor(RandomUtils.randomColor(40, 150));
+    Random random = new Random();
+    int x = random.nextInt(width);
+    int y = random.nextInt(height);
+    int x1 = random.nextInt(width);
+    int y1 = random.nextInt(height);
+    graphics.drawLine(x, y, x1, y1);
+    }
 }
 
 /**
@@ -59,15 +59,15 @@ graphics.drawLine(x, y, x1, y1);
 */
 @Override
 public String generate(int width, int height, OutputStream os) throws IOException {
-BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);
-Graphics graphics = image.getGraphics();
-fillBackground(graphics, width, height);
-String randomStr = RandomUtils.randomString(VALICATE_CODE_LENGTH);
-createCharacter(graphics, randomStr);
-graphics.dispose();
-//设置JPEG格式
-ImageIO.write(image, "JPEG", os);
-return randomStr;
+    BufferedImage image = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);
+    Graphics graphics = image.getGraphics();
+    fillBackground(graphics, width, height);
+    String randomStr = RandomUtils.randomString(VALICATE_CODE_LENGTH);
+    createCharacter(graphics, randomStr);
+    graphics.dispose();
+    //设置JPEG格式
+    ImageIO.write(image, "JPEG", os);
+    return randomStr;
 }
 
 /**
@@ -79,20 +79,20 @@ return randomStr;
 */
 @Override
 public VerifyCode generate(int width, int height) {
-VerifyCode verifyCode = null;
-try (
-//将流的初始化放到这里就不需要手动关闭流
-ByteArrayOutputStream baos = new ByteArrayOutputStream();
-) {
-String code = generate(width, height, baos);
-verifyCode = new VerifyCode();
-verifyCode.setCode(code);
-verifyCode.setImgBytes(baos.toByteArray());
-} catch (IOException e) {
-logger.error(e.getMessage(), e);
-verifyCode = null;
-}
-return verifyCode;
+    VerifyCode verifyCode = null;
+    try (
+    //将流的初始化放到这里就不需要手动关闭流
+    ByteArrayOutputStream baos = new ByteArrayOutputStream();
+    ) {
+    String code = generate(width, height, baos);
+    verifyCode = new VerifyCode();
+    verifyCode.setCode(code);
+    verifyCode.setImgBytes(baos.toByteArray());
+    } catch (IOException e) {
+    logger.error(e.getMessage(), e);
+    verifyCode = null;
+    }
+    return verifyCode;
 }
 
 /**
@@ -102,15 +102,15 @@ return verifyCode;
 * @param randomStr
 */
 private void createCharacter(Graphics g, String randomStr) {
-char[] charArray = randomStr.toCharArray();
-for (int i = 0; i < charArray.length; i++) {
-//设置RGB颜色算法参数
-g.setColor(new Color(50 + RandomUtils.nextInt(100),
-50 + RandomUtils.nextInt(100), 50 + RandomUtils.nextInt(100)));
-//设置字体大小，类型
-g.setFont(new Font(FONT_TYPES[RandomUtils.nextInt(FONT_TYPES.length)], Font.BOLD, 26));
-//设置x y 坐标
-g.drawString(String.valueOf(charArray[i]), 15 * i + 5, 19 + RandomUtils.nextInt(8));
-}
-}
+    char[] charArray = randomStr.toCharArray();
+        for (int i = 0; i < charArray.length; i++) {
+        //设置RGB颜色算法参数
+        g.setColor(new Color(50 + RandomUtils.nextInt(100),
+        50 + RandomUtils.nextInt(100), 50 + RandomUtils.nextInt(100)));
+        //设置字体大小，类型
+        g.setFont(new Font(FONT_TYPES[RandomUtils.nextInt(FONT_TYPES.length)], Font.BOLD, 26));
+        //设置x y 坐标
+        g.drawString(String.valueOf(charArray[i]), 15 * i + 5, 19 + RandomUtils.nextInt(8));
+        }
+    }
 }

src/main/resources/mapper/AlbumMapper.xml

@@ -41,10 +41,10 @@
         <where>
            1=1
             <if test="albumkey != null">
-                and `albumkey` like '%${albumkey}%'
+                and `albumkey` like CONCAT('%', #{albumkey}, '%')
             </if>
             <if test="username != null">
-                and `username` like '%${username}%'
+                and `username` like CONCAT('%', #{username}, '%')
             </if>
             <if test="userid != null">
                 and a.userid = #{userid}

src/main/resources/mapper/ImgMapper.xml

@@ -53,11 +53,11 @@
                     <choose>
                         <when test="selecttype==1">
                             and
-                            a.userid in ( SELECT id  from `user` where username LIKE '%${username}%')
+                            a.userid in ( SELECT id  from `user` where username LIKE CONCAT('%', #{username}, '%'))
                         </when>
                         <otherwise>
                             and
-                            a.userid not in ( SELECT id  from `user` where username LIKE '%${username}%')
+                            a.userid not in ( SELECT id  from `user` where username LIKE CONCAT('%', #{username}, '%'))
                         </otherwise>
                     </choose>
                 </if>
@@ -71,10 +71,10 @@
             and CONCAT(
             imgurl,
             idname
-            ) LIKE '%${searchname}%'
+            ) LIKE CONCAT('%', #{searchname}, '%')
         </if>
         <if test="idname != null and idname !=''">
-            and idname LIKE '%${idname}%'
+            and idname LIKE CONCAT('%', #{idname}, '%')
         </if>
         order by
         <choose>

src/main/resources/mapper/UserMapper.xml

@@ -213,7 +213,7 @@
             and CONCAT(
             username,
             email
-            ) LIKE '%${username}%'
+            ) LIKE CONCAT('%', #{username}, '%')
         </if>
         order by birthder desc
     </select>