Java源码社

基于javaweb的SpringBoot在线嘿嘿网盘系统设计和实现(java+springboot+ssm+mysql+maven+thymeleaf+html)

更新于

运行环境

Java≥8、MySQL≥5.7

开发工具

eclipse/idea/myeclipse/sts等均可配置运行

适用

课程设计，大作业，毕业设计，项目练习，学习演示等

功能说明

090023102402

100023102402

110023102402

120023102402

130023102402

基于javaweb的SpringBoot在线嘿嘿网盘系统设计和实现(java+springboot+ssm+mysql+maven+thymeleaf+html)

一、项目简述

功能：用户的邮箱注册、验证码验证以及用户登录。 不需要注册账号，也可以上传满足条件的临时文件，但是 只4小时内有效。 文件的管理，上传、下载、重命名、删除、查看统计数 据、分类管理等。 文件夹的管理，创建、删除、重命名。 文件的分享，支持通过链博口二维码的分享方式等等。

二、项目运行

环境配置： Jdk1.8 + mysql + Eclispe (IntelliJ IDEA,Eclispe,MyEclispe,Sts 都支持)

项目技术： JSP +Springboot+ SpringMVC + MyBatis + ThymeLeaf + FTP+ JavaScript + JQuery + Ajax + maven等等

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 * @return void
 **/
@GetMapping("/downloadFile")
public String downloadFile(@RequestParam Integer fId){
    if (fileStoreService.getFileStoreByUserId(loginUser.getUserId()).getPermission() == 2){
        logger.error("用户没有下载文件的权限!下载失败...");
        return "redirect:/error401Page";
    }
    //获取文件信息
    MyFile myFile = myFileService.getFileByFileId(fId);
    String remotePath = myFile.getMyFilePath();
    String fileName = myFile.getMyFileName()+myFile.getPostfix();
    try {
        //去FTP上拉取
        OutputStream os = new BufferedOutputStream(response.getOutputStream());
        response.setCharacterEncoding("utf-8");
        // 设置返回类型
        response.setContentType("multipart/form-data");
        // 文件名转码一下，不然会出现中文乱码
        response.setHeader("Content-Disposition", "attachment;fileName=" + URLEncoder.encode(fileName, "UTF-8"));
        boolean flag = FtpUtil.downloadFile("/" + remotePath, fileName, os);
        if (flag) {
            myFileService.updateFile(
                    MyFile.builder().myFileId(myFile.getMyFileId()).downloadTime(myFile.getDownloadTime() + 1).build());
            os.flush();
            os.close();
            logger.info("文件下载成功!" + myFile);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return "success";
}

/**
 * @Description 删除文件
 * @Param [fId, folder]
 * @return java.lang.String
 **/
@GetMapping("/deleteFile")
public String deleteFile(@RequestParam Integer fId,Integer folder){
    //获得文件信息
    MyFile myFile = myFileService.getFileByFileId(fId);
    String remotePath = myFile.getMyFilePath();
    String fileName = myFile.getMyFileName()+myFile.getPostfix();
    //从FTP文件服务器上删除文件
    boolean b = FtpUtil.deleteFile("/"+remotePath, fileName);
    if (b){
        //删除成功,返回空间
        fileStoreService.subSize(myFile.getFileStoreId(),Integer.valueOf(myFile.getSize()));
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
    if (userByEmail != null) {
        logger.error("发送验证码失败！邮箱已被注册！");
        return "exitEmail";
    }
    logger.info("开始发送邮件.../n" + "获取的到邮件发送对象为:" + mailSender);
    mailUtils = new MailUtils(mailSender);
    String code = "123456";
    session.setAttribute(email + "_code", code);




    return "success";
}

/**
 * @Description 请求QQ登录
 * @Param []
 * @return void
 **/
@GetMapping("/loginByQQ")
public void login() {
    response.setContentType("text/html;charset=utf-8");
    try {
        response.sendRedirect(new Oauth().getAuthorizeURL(request));
        logger.info("请求QQ登录,开始跳转...");
    } catch (QQConnectException | IOException e) {
        e.printStackTrace();
    }
}

/**
 * @Description QQ登录回调地址
 * @Param []
 * @return java.lang.String
 **/
@GetMapping("/connection")
public String connection() {
    try {
        AccessToken accessTokenObj = (new Oauth()).getAccessTokenByRequest(request);
        String accessToken = null, openID = null;
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
@PostMapping("/register")
public String register(User user, String code, Map<String, Object> map) {
    String uCode = (String) session.getAttribute(user.getEmail() + "_code");
    if (!code.equals(uCode)) {
        map.put("errorMsg", "验证码错误");
        return "index";
    }
    // 用户名去空格
    user.setUserName(user.getUserName().trim());
    user.setImagePath("https://p.qpic.cn/qqconnect/0/app_101851241_1582451550/100?max-age=2592000&t=0");
    user.setRegisterTime(new Date());
    user.setRole(1);
    if (userService.insert(user)) {
        FileStore store = FileStore.builder().userId(user.getUserId()).currentSize(0).build();
        fileStoreService.addFileStore(store);
        user.setFileStoreId(store.getFileStoreId());
        userService.update(user);
        logger.info("注册用户成功！当前注册用户" + user);
        logger.info("注册仓库成功！当前注册仓库" + store);
    } else {
        map.put("errorMsg", "服务器发生错误，注册失败");
        return "index";
    }
    session.removeAttribute(user.getEmail() + "_code");
    session.setAttribute("loginUser", user);
    return "redirect:/index";
}

/**
 * 用户登录
 * @param map 存储提示信息
 * @return java.lang.String
 */
@PostMapping("/login")
public String login(User user, Map<String, Object> map) {
    User userByEmail = userService.getUserByEmail(user.getEmail());
    if (userByEmail != null && userByEmail.getPassword().equals(user.getPassword())) {
        session.setAttribute("loginUser", userByEmail);
        logger.info("登录成功！"+userByEmail);
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 **/
@Controller
public class LoginController extends BaseController {

    private Logger logger = LogUtils.getInstance(LoginController.class);

    /**
     * @Description 免登陆用户入口，用于本地开发测试，上线运营为了安全请删除此方法
     * @Param []
     * @return java.lang.String
     **/
    @GetMapping("/admin")
    public String adminLogin(){
        User user = userService.getUserByOpenId("123456");
        logger.info("使用免登陆方式登录成功！"+user);
        session.setAttribute("loginUser", user);
        return "redirect:/index";
    }

    /**
     * 用于注册流程,用户名，密码，邮箱等校验工作由前端来完成
     *
     * @param map 用于存储提示信息
     */
    @PostMapping("/register")
    public String register(User user, String code, Map<String, Object> map) {
        String uCode = (String) session.getAttribute(user.getEmail() + "_code");
        if (!code.equals(uCode)) {
            map.put("errorMsg", "验证码错误");
            return "index";
        }
        // 用户名去空格
        user.setUserName(user.getUserName().trim());
        user.setImagePath("https://p.qpic.cn/qqconnect/0/app_101851241_1582451550/100?max-age=2592000&t=0");
        user.setRegisterTime(new Date());
        user.setRole(1);
        if (userService.insert(user)) {
            FileStore store = FileStore.builder().userId(user.getUserId()).currentSize(0).build();
            fileStoreService.addFileStore(store);
            user.setFileStoreId(store.getFileStoreId());
            userService.update(user);
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
                session.setAttribute("msg", "服务器出错了，临时文件上传失败!");
            }
        }else{
            //上传失败
            logger.info("临时文件上传失败!"+name);
            session.setAttribute("url","error");
            session.setAttribute("msg", "服务器出错了，上传失败!");
        }
    } catch (IOException e) {
        e.printStackTrace();
    }
    return "redirect:/temp-file";
}

/**
 * @Description 网盘的文件上传
 * @Param [files]
 * @return java.util.Map<java.lang.String,java.lang.Object>
 **/
@PostMapping("/uploadFile")
@ResponseBody
public Map<String, Object> uploadFile(@RequestParam("file") MultipartFile files) {
    Map<String, Object> map = new HashMap<>();
    if (fileStoreService.getFileStoreByUserId(loginUser.getUserId()).getPermission() != 0){
        logger.error("用户没有上传文件的权限!上传失败...");
        map.put("code", 499);
        return map;
    }
    FileStore store = fileStoreService.getFileStoreByUserId(loginUser.getUserId());
    Integer folderId = Integer.valueOf(request.getHeader("id"));
    String name = files.getOriginalFilename().replaceAll(" ","");
    //获取当前目录下的所有文件，用来判断是否已经存在
    List<MyFile> myFiles = null;
    if (folderId == 0){
        //当前目录为根目录
        myFiles = myFileService.getRootFilesByFileStoreId(loginUser.getFileStoreId());
    }else {
        //当前目录为其他目录
        myFiles = myFileService.getFilesByParentFolderId(folderId);
    }
    for (int i = 0; i < myFiles.size(); i++) {
        if ((myFiles.get(i).getMyFileName()+myFiles.get(i).getPostfix()).equals(name)){
            logger.error("当前文件已存在!上传失败...");
            map.put("code", 501);
            return map;
        }
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
 * @return java.lang.String
 */
@PostMapping("/login")
public String login(User user, Map<String, Object> map) {
    User userByEmail = userService.getUserByEmail(user.getEmail());
    if (userByEmail != null && userByEmail.getPassword().equals(user.getPassword())) {
        session.setAttribute("loginUser", userByEmail);
        logger.info("登录成功！"+userByEmail);
        return "redirect:/index";
    }else{
        User user1 = userService.getUserByEmail(user.getEmail());
        String errorMsg = user1 == null ? "该邮箱尚未注册" : "密码错误";
        logger.info("登录失败！请确认邮箱和密码是否正确！");
        //登录失败，将失败信息返回前端渲染
        map.put("errorMsg", errorMsg);
        return "index";
    }
}

/**
 * @return void
 * @Description 向注册邮箱发送验证码, 并验证邮箱是否已使用
 * @Param [userName, email, password]
 **/
@ResponseBody
@RequestMapping("/sendCode")
public String sendCode(String userName, String email, String password) {
    User userByEmail = userService.getUserByEmail(email);
    if (userByEmail != null) {
        logger.error("发送验证码失败！邮箱已被注册！");
        return "exitEmail";
    }
    logger.info("开始发送邮件.../n" + "获取的到邮件发送对象为:" + mailSender);
    mailUtils = new MailUtils(mailSender);
    String code = "123456";
    session.setAttribute(email + "_code", code);




    return "success";
}

/**
 * @Description 请求QQ登录

项目链接：
https://javayms.github.io?id=201922152105200bq
https://javayms.pages.dev?id=201922152105200bq