后端 okhttp 开发语言 基于Java+Spring Boot+MySQL的协同过滤电影推荐系统的设计与实现

目录

前言

 一、技术栈

二、系统功能介绍

管理员功能实现

付费电影管理

免费电影管理

公告管理

公告类型管理

用户功能实现

付费电影

免费电影

公告

公告类型

三、核心代码

1、登录模块

 2、文件上传模块

3、代码封装

前言

如今社会上各行各业，都喜欢用自己行业的专属软件工作，互联网发展到这个时候，人们已经发现离不开了互联网。新技术的产生，往往能解决一些老技术的弊端问题。因为传统电影推荐系统信息管理难度大，容错率低，管理人员处理数据费工费时，所以专门为解决这个难题开发了一个电影推荐系统管理系统，可以解决许多问题。

电影推荐系统管理系统按照操作主体分为管理员和用户。管理员的功能包括付费电影管理、付费电影收藏管理、付费电影评价管理、电影购买管理、字典管理、电影论坛管理、电影资讯管理、免费电影管理、免费电影收藏管理、免费电影评论管理、用户管理、管理员管理。用户的功能等。该系统采用了Mysql数据库，Java语言，Spring Boot框架等技术进行编程实现。

电影推荐系统管理系统可以提高电影推荐系统信息管理问题的解决效率，优化电影推荐系统信息处理流程，保证电影推荐系统信息数据的安全，它是一个非常可靠，非常安全的应用程序。

 一、技术栈

末尾获取源码 Spring Boot+JS+ jQuery+Ajax...

二、系统功能介绍

管理员功能实现

付费电影管理

图5.1 即为编码实现的付费电影管理界面，管理员在付费电影管理界面中可以对界面中显示，可以对付费电影信息的付费电影状态进行查看，可以添加新的付费电影信息等。

免费电影管理

图5.2 即为编码实现的免费电影管理界面，管理员在免费电影管理界面中查看免费电影种类信息，免费电影描述信息，新增免费电影信息等。

公告管理

图5.3 即为编码实现的公告管理界面，管理员在公告管理界面中新增公告，可以删除公告。

公告类型管理

图5.4 即为编码实现的公告类型管理界面，管理员在公告类型管理界面查看公告的工作状态，可以对公告的数据进行导出，可以添加新公告的信息，可以编辑公告信息，删除公告信息。

用户功能实现

付费电影

图5.2.1 即为编码实现的付费电影界面

免费电影

图5.2 即为编码实现的免费电影界面。

公告

图5.3 即为编码实现的公告管理界面。

公告类型

图5.4 即为编码实现的公告类型管理界面。

三、核心代码

1、登录模块

package com.controller;

import java.util.Arrays;

import java.util.Calendar;

import java.util.Date;

import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.ResponseBody;

import org.springframework.web.bind.annotation.RestController;

import com.annotation.IgnoreAuth;

import com.baomidou.mybatisplus.mapper.EntityWrapper;

import com.entity.TokenEntity;

import com.entity.UserEntity;

import com.service.TokenService;

import com.service.UserService;

import com.utils.CommonUtil;

import com.utils.MD5Util;

import com.utils.MPUtil;

import com.utils.PageUtils;

import com.utils.R;

import com.utils.ValidatorUtils;

/**

* 登录相关

*/

@RequestMapping("users")

@RestController

public class UserController{

@Autowired

private UserService userService;

@Autowired

private TokenService tokenService;

/**

* 登录

*/

@IgnoreAuth

@PostMapping(value = "/login")

public R login(String username, String password, String captcha, HttpServletRequest request) {

UserEntity user = userService.selectOne(new EntityWrapper().eq("username", username));

if(user==null || !user.getPassword().equals(password)) {

return R.error("账号或密码不正确");

}

String token = tokenService.generateToken(user.getId(),username, "users", user.getRole());

return R.ok().put("token", token);

}

/**

* 注册

*/

@IgnoreAuth

@PostMapping(value = "/register")

public R register(@RequestBody UserEntity user){

// ValidatorUtils.validateEntity(user);

if(userService.selectOne(new EntityWrapper().eq("username", user.getUsername())) !=null) {

return R.error("用户已存在");

}

userService.insert(user);

return R.ok();

}

/**

* 退出

*/

@GetMapping(value = "logout")

public R logout(HttpServletRequest request) {

request.getSession().invalidate();

return R.ok("退出成功");

}

/**

* 密码重置

*/

@IgnoreAuth

@RequestMapping(value = "/resetPass")

public R resetPass(String username, HttpServletRequest request){

UserEntity user = userService.selectOne(new EntityWrapper().eq("username", username));

if(user==null) {

return R.error("账号不存在");

}

user.setPassword("123456");

userService.update(user,null);

return R.ok("密码已重置为：123456");

}

/**

* 列表

*/

@RequestMapping("/page")

public R page(@RequestParam Map params,UserEntity user){

EntityWrapper ew = new EntityWrapper();

PageUtils page = userService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.allLike(ew, user), params), params));

return R.ok().put("data", page);

}

/**

* 列表

*/

@RequestMapping("/list")

public R list( UserEntity user){

EntityWrapper ew = new EntityWrapper();

ew.allEq(MPUtil.allEQMapPre( user, "user"));

return R.ok().put("data", userService.selectListView(ew));

}

/**

* 信息

*/

@RequestMapping("/info/{id}")

public R info(@PathVariable("id") String id){

UserEntity user = userService.selectById(id);

return R.ok().put("data", user);

}

/**

* 获取用户的session用户信息

*/

@RequestMapping("/session")

public R getCurrUser(HttpServletRequest request){

Long id = (Long)request.getSession().getAttribute("userId");

UserEntity user = userService.selectById(id);

return R.ok().put("data", user);

}

/**

* 保存

*/

@PostMapping("/save")

public R save(@RequestBody UserEntity user){

// ValidatorUtils.validateEntity(user);

if(userService.selectOne(new EntityWrapper().eq("username", user.getUsername())) !=null) {

return R.error("用户已存在");

}

userService.insert(user);

return R.ok();

}

/**

* 修改

*/

@RequestMapping("/update")

public R update(@RequestBody UserEntity user){

// ValidatorUtils.validateEntity(user);

userService.updateById(user);//全部更新

return R.ok();

}

/**

* 删除

*/

@RequestMapping("/delete")

public R delete(@RequestBody Long[] ids){

userService.deleteBatchIds(Arrays.asList(ids));

return R.ok();

}

}

 2、文件上传模块

package com.controller;

import java.io.File;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.util.Arrays;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Random;

import java.util.UUID;

import org.apache.commons.io.FileUtils;

import org.apache.commons.lang3.StringUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.http.HttpHeaders;

import org.springframework.http.HttpStatus;

import org.springframework.http.MediaType;

import org.springframework.http.ResponseEntity;

import org.springframework.util.ResourceUtils;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.RestController;

import org.springframework.web.multipart.MultipartFile;

import com.annotation.IgnoreAuth;

import com.baomidou.mybatisplus.mapper.EntityWrapper;

import com.entity.ConfigEntity;

import com.entity.EIException;

import com.service.ConfigService;

import com.utils.R;

/**

* 上传文件映射表

*/

@RestController

@RequestMapping("file")

@SuppressWarnings({"unchecked","rawtypes"})

public class FileController{

@Autowired

private ConfigService configService;

/**

* 上传文件

*/

@RequestMapping("/upload")

public R upload(@RequestParam("file") MultipartFile file,String type) throws Exception {

if (file.isEmpty()) {

throw new EIException("上传文件不能为空");

}

String fileExt = file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(".")+1);

File path = new File(ResourceUtils.getURL("classpath:static").getPath());

if(!path.exists()) {

path = new File("");

}

File upload = new File(path.getAbsolutePath(),"/upload/");

if(!upload.exists()) {

upload.mkdirs();

}

String fileName = new Date().getTime()+"."+fileExt;

File dest = new File(upload.getAbsolutePath()+"/"+fileName);

file.transferTo(dest);

FileUtils.copyFile(dest, new File("C:\\Users\\Desktop\\jiadian\\springbootl7own\\src\\main\\resources\\static\\upload"+"/"+fileName));

if(StringUtils.isNotBlank(type) && type.equals("1")) {

ConfigEntity configEntity = configService.selectOne(new EntityWrapper().eq("name", "faceFile"));

if(configEntity==null) {

configEntity = new ConfigEntity();

configEntity.setName("faceFile");

configEntity.setValue(fileName);

} else {

configEntity.setValue(fileName);

}

configService.insertOrUpdate(configEntity);

}

return R.ok().put("file", fileName);

}

/**

* 下载文件

*/

@IgnoreAuth

@RequestMapping("/download")

public ResponseEntity download(@RequestParam String fileName) {

try {

File path = new File(ResourceUtils.getURL("classpath:static").getPath());

if(!path.exists()) {

path = new File("");

}

File upload = new File(path.getAbsolutePath(),"/upload/");

if(!upload.exists()) {

upload.mkdirs();

}

File file = new File(upload.getAbsolutePath()+"/"+fileName);

if(file.exists()){

/*if(!fileService.canRead(file, SessionManager.getSessionUser())){

getResponse().sendError(403);

}*/

HttpHeaders headers = new HttpHeaders();

headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);

headers.setContentDispositionFormData("attachment", fileName);

return new ResponseEntity(FileUtils.readFileToByteArray(file),headers, HttpStatus.CREATED);

}

} catch (IOException e) {

e.printStackTrace();

}

return new ResponseEntity(HttpStatus.INTERNAL_SERVER_ERROR);

}

}

3、代码封装

package com.utils;

import java.util.HashMap;

import java.util.Map;

/**

* 返回数据

*/

public class R extends HashMap {

private static final long serialVersionUID = 1L;

public R() {

put("code", 0);

}

public static R error() {

return error(500, "未知异常，请联系管理员");

}

public static R error(String msg) {

return error(500, msg);

}

public static R error(int code, String msg) {

R r = new R();

r.put("code", code);

r.put("msg", msg);

return r;

}

public static R ok(String msg) {

R r = new R();

r.put("msg", msg);

return r;

}

public static R ok(Map map) {

R r = new R();

r.putAll(map);

return r;

}

public static R ok() {

return new R();

}

public R put(String key, Object value) {

super.put(key, value);

return this;

}

}

相关阅读

 您阅读本篇文章共花了：