博主介绍：✌在职Java研发工程师、专注于程序设计、源码分享、技术交流、专注于Java技术领域和毕业设计✌
项目名称
基于协同过滤算法的外贸出口电子电器产品的推荐系统的设计与实现源码+文档
视频演示
https://www.bilibili.com/video/BV1HW4y197Fe/
系统介绍
摘 要
伴随着信息时期的发展趋势，便捷有效的处理信息已成为了各个行业的主要要求。电子产品作为日常生活中的必选项之一，越来越低廉的价格以及优秀的品质，使得电子产品受到越来越多人的喜爱。在电子商务的浪潮中，电子产品领域缺失一片红海。互联网化管理目前已经拥有很多类型的平台，电子化管理会使外贸出口电子电器产品的买卖更加专业和自动化，并且提高了效率和降低维护成本。
外贸出口电子电器产品推荐系统需要采用新版软件管理方法，系统软件采用个性化的制定观念，用户会觉得实际操作十分便捷。首先管理人员要把基础信息录入到数据库中，数据库可以保证数据的持久化而且可以保存大量数据，不易遗失，并且查询的时候快速、精准。系统使用SpringBoot、MySQL、JPA、JSP等技术框架实现了包括分类管理、产品管理、产品套餐管理、用户管理、订单管理等外贸电子电器产品销售功能，实现了用户浏览、用户购买等购买功能，实现了基于协同过滤算法的推荐功能。系统详细介绍了如何实现基于 B/S架构以及协同过滤算法的外贸出口电子电器产品推荐系统，促使电子产品销售随着市场竞争的加剧和全球形势的变化增加出口额。
关键词：电子产品；协同过滤；外贸出口；Spring Boot
系统采用MVC模式进行逻辑上和代码上的功能划分，保证程序逻辑、视图和数据的分离，方便系统的扩展。为了保证数据持久化需要使用数据库保存数据，本系统选择MySQL数据库来保存数据，系统架构使用Spring Boot作为整体代码结构，使用Freemarker作为前端模板引擎进行页面渲染，使用Servlet技术框架实现动态网页，使用协同过滤算法实现电子电器产品的个性化推荐，使用AOP技术实现日志记录。
系统分为前台、后台两个实现部分，系统前台是用户的主要操作界面，系统后台是管理员进行系统管理和数据管理的主要操作界面。系统使用基于用户的协同过滤算法对外贸出口的电子电器商品进行可视化展示，系统功能模块结构图如图4-1所示。
图4-1 系统功能模块结构图
1.系统前台：
系统前台是用户的主要操作页面，功能包括了登录、注册、产品浏览、产品套餐、产品推荐、产品图片浏览、商店服务、新闻列表、个人中心、我的订单、我的收藏、购物车等功能。其中产品浏览功能包括详情浏览、价格筛选、类别筛选、产品搜索、浏览量、收藏、购买等功能。个人中心包括个人信息修改和充值等功能。我的订单包括付款和评论等功能。
2.系统后台：
系统后台为管理员进行系统管理和数据管理的功能界面，主要功能包括统计信息、操作日志、菜单管理、角色管理、日志管理、数据备份、分类管理、产品管理、产品套餐管理、关于我们、团队管理、新闻分类、新闻管理、常见问题管理、用户管理、订单管理等功能。
3.推荐算法：
本系统采用 Jaccard对于用户和产品之间的相似度进行计算。在相似度计算完成后，计算用户对每个物品的推荐度，生成推荐列表。根据用户历史行为，预测用户可能会感兴趣的电子电器产品，将这些过滤后的产品推荐给用户。随着用户、商品数量和用户购买次数的不断增多，随着数据量和计算量的增加，推荐效果更加准确。推荐系统可以根据用户的行为反馈和推荐效果进行优化和改进，不断提高推荐精度和用户体验。
4.创新模块：
（1）系统后台拥有数据库自动备份功能可以定时进行备份，保证了数据的安全性和时间性。
（2）系统后台通过AOP技术将系统用户操作日志进行记录，方便管理员对每次的操作行为进行查询和回溯，避免不当操作造成的损失。
1.商品管理模块设计
管理员执行添加商品、修该商品和删除商品操作，后台逻辑把管理员在表单中添加、修改或删除的商品信息传递至数据库，数据库进行增删改查操作更新商品表，数据库确认存储后，管理员界面显示更新后的商品列表和商品详情。
2.订单管理模块设计
数据库在用户购买行为后获取用户订单信息，在商店订单数据表中添加新的订单信息，并且将数据返回到订单管理界面。订单完成后，管理员修改订单状态，后台逻辑代码向数据库申请修改，数据表修改完成后，返回订单管理界面显示订单已经完成。
- 用户管理模块设计
用户填写用户名、手机号、地址信息，后台逻辑代码传递给数据库存储，后台逻辑代码在用户管理界面解析出来用户信息。当管理员执行用户添加、用户编辑和用户删除操作，数据库进行增删改查操作，在用户管理界面返回更新后的用户列表。
1.商品推荐模块设计
当用户登录系统时，系统根据用户编号从数据库获取用户的历史数据，主要包括用户的个人信息和以前购买、收藏的商品信息。当这些数据返回系统后，系统计算当前用户与其他用户间的相似度，计算各个产品的推荐度。
用户可以从推荐的产品中选择感兴趣的产品。当用户选择一个产品后，系统会将选择结果存储在数据库中，以便在以后改进和调整推荐算法。最后系统会向用户确认他们的选择，完成整个推荐过程。
因为用户每一次地购买行为和收藏行为，属于该用户的商品列表是不断发生改变的。本系统是可以不断学习和改进推荐结果的。每当用户进行新的行为时，系统都会更新用户的历史数据，并且重新计算用户间的相似度和产品的推荐度，以提供更精准的推荐。商品推荐时序图如图4-2所示。
图4-2 商品推荐时序图
用户向系统发送请求，申请获取商品列表。系统会根据当前用户的历史数据计算，根据用户的需求、过滤条件和排序方式，从数据库中获取相应的商品列表。
当数据库返回过滤后的商品列表时，系统便会应用协同过滤算法对这些商品进行排序和过滤。协同过滤算法会考虑用户之间的相似性以及商品的相关性，从而提供更符合用户需求的商品列表。然后系统会将排序和过滤后的商品列表返回前台界面进而解析、展示给用户。
用户可以与商品列表进行交互，例如更改过滤条件、排序方式等。当用户进行这些行为操作时，系统会再次从数据库获取更新后的商品列表，并将其结果展示给用户。商品展示时序图如图4-3所示。
图4-3 商品展示时序图
2.类别筛选模块设计
用户在商品界面选择想购买商品的类别，后台逻辑代码向数据库申请获取该类别的商品数据信息，数据库查询商品数据表，返回相应数据信息，在用户界面解析出来。
3.购物车模块设计
在购物车界面，用户选择购买后，后台逻辑代码根据商品价格累加计算商品总额，将计算结果返回用户界面。用户确认购买后，后台逻辑代码会继续计算用户账户剩余金额，计算结果传入数据库修改账户数据表，数据库确认存储返回。后台逻辑代码还会向数据库传递已购买商品信息，数据库修改用户订单数据表，确认存储后返回用户界面显示用户订单。
- 评论模块设计
用户在订单完成后选择评论，后台逻辑在订单界面弹出包含五星评分和评论表单的对话框。用户打分和填写评论表单后提交给后台逻辑。后台逻辑代码将其保存至数据库，在订单界面显示已评论，在商品详情界面解析出来当前用户的用户名、评分和评论。
环境需要
1.运行环境：最好是java jdk 1.8，我们在这个平台上运行的。其他版本理论上也可以。
2.IDE环境：IDEA，Eclipse,Myeclipse都可以。推荐IDEA;
3.tomcat环境：Tomcat 7.x,8.x,9.x版本均可
4.硬件环境：windows 7/8/10 1G内存以上；或者 Mac OS；
5.数据库：MySql 5.7版本；
6.是否Maven项目：否；
技术栈
1. 后端：Spring+SpringMVC+Mybatis
2. 前端：JSP+CSS+JavaScript+jQuery
使用说明
1. 使用Navicat或者其它工具，在mysql中创建对应名称的数据库，并导入项目的sql文件；
2. 使用IDEA/Eclipse/MyEclipse导入项目，Eclipse/MyEclipse导入时，若为maven项目请选择maven;
若为maven项目，导入成功后请执行maven clean;maven install命令，然后运行；
3. 将项目中springmvc-servlet.xml配置文件中的数据库配置改为自己的配置;
4. 运行项目，在浏览器中输入http://localhost:8080/ 登录
运行截图
用户管理控制层:
package com.houserss.controller;
import javax.servlet.http.HttpSession;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import com.houserss.common.Const;
import com.houserss.common.Const.Role;
import com.houserss.common.ServerResponse;
import com.houserss.pojo.User;
import com.houserss.service.IUserService;
import com.houserss.service.impl.UserServiceImpl;
import com.houserss.util.MD5Util;
import com.houserss.util.TimeUtils;
import com.houserss.vo.DeleteHouseVo;
import com.houserss.vo.PageInfoVo;
/**
* Created by admin
*/
@Controller
@RequestMapping("/user/")
public class UserController {
@Autowired
private IUserService iUserService;
/**
* 用户登录
* @param username
* @param password
* @param session
* @return
*/
@RequestMapping(value = "login.do",method = RequestMethod.POST)
@ResponseBody
public ServerResponse<User> login(User user,String uvcode, HttpSession session){
String code = (String)session.getAttribute("validationCode");
if(StringUtils.isNotBlank(code)) {
if(!code.equalsIgnoreCase(uvcode)) {
return ServerResponse.createByErrorMessage("验证码不正确");
}
}
ServerResponse<User> response = iUserService.login(user.getUsername(),user.getPassword());
if(response.isSuccess()){
session.setAttribute(Const.CURRENT_USER,response.getData());
}
return response;
}
}
管理员管理控制层:
package com.sxl.controller.admin;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import com.sxl.controller.MyController;
@Controller("adminController")
@RequestMapping(value = "/admin")
public class AdminController extends MyController {
@RequestMapping(value = "/index")
public String frame(Model model, HttpServletRequest request)throws Exception {
return "/admin/index";
}
@RequestMapping(value = "/main")
public String main(Model model, HttpServletRequest request)throws Exception {
return "/admin/main";
}
@RequestMapping(value = "/tj1")
public String tj1(Model model, HttpServletRequest request)throws Exception {
String sql="select DATE_FORMAT(insertDate,'%Y-%m-%d') dates,sum(allPrice) price from t_order order by DATE_FORMAT(insertDate,'%Y-%m-%d') desc";
List<Map> list = db.queryForList(sql);
model.addAttribute("list", list);
System.out.println(list);
return "/admin/tj/tj1";
}
@RequestMapping(value = "/password")
public String password(Model model, HttpServletRequest request)throws Exception {
return "/admin/password";
}
@RequestMapping(value = "/changePassword")
public ResponseEntity<String> loginSave(Model model,HttpServletRequest request,String oldPassword,String newPassword) throws Exception {
Map admin = getAdmin(request);
if(oldPassword.equals(admin.get("password").toString())){
String sql="update t_admin set password=? where id=?";
db.update(sql, new Object[]{newPassword,admin.get("id")});
return renderData(true,"1",null);
}else{
return renderData(false,"1",null);
}
}
}
修改密码业务逻辑:
package com.sxl.controller.admin;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import com.sxl.controller.MyController;
@Controller("userController")
@RequestMapping(value = "/user")
public class UserController extends MyController {
@RequestMapping(value = "/index")
public String frame(Model model, HttpServletRequest request)throws Exception {
return "/user/index";
}
@RequestMapping(value = "/main")
public String main(Model model, HttpServletRequest request)throws Exception {
return "/user/main";
}
@RequestMapping(value = "/password")
public String password(Model model, HttpServletRequest request)throws Exception {
return "/user/password";
}
@RequestMapping(value = "/changePassword")
public ResponseEntity<String> loginSave(Model model,HttpServletRequest request,String oldPassword,String newPassword) throws Exception {
Map user = getUser(request);
if(oldPassword.equals(user.get("password").toString())){
String sql="update t_user set password=? where id=?";
db.update(sql, new Object[]{newPassword,user.get("id")});
return renderData(true,"1",null);
}else{
return renderData(false,"1",null);
}
}
@RequestMapping(value = "/mine")
public String mine(Model model, HttpServletRequest request)throws Exception {
Map user =getUser(request);Map map = db.queryForMap("select * from t_user where id=?",new Object[]{user.get("id")});model.addAttribute("map", map); return "/user/mine";
}
@RequestMapping(value = "/mineSave")
public ResponseEntity<String> mineSave(Model model,HttpServletRequest request,Long id
,String username,String password,String name,String gh,String mobile) throws Exception{
int result = 0;
String sql="update t_user set name=?,gh=?,mobile=? where id=?";
result = db.update(sql, new Object[]{name,gh,mobile,id});
if(result==1){
return renderData(true,"操作成功",null);
}else{
return renderData(false,"操作失败",null);
}
}
}
通用管理模块:
package com.sxl.controller;
import java.nio.charset.Charset;
import java.util.Locale;
import java.util.ResourceBundle;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang.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 com.sxl.util.JacksonJsonUtil;
import com.sxl.util.StringUtil;
import com.sxl.util.SystemProperties;
public class BaseController {
public static final Long EXPIRES_IN = 1000 * 3600 * 24 * 1L;// 1天
@Autowired
private SystemProperties systemProperties;
/**
* 获得配置文件内容
*/
public String getConfig(String key) {
return systemProperties.getProperties(key);
}
/**
* 返回服务器地址 like http://192.168.1.1:8441/UUBean/
*/
public String getHostUrl(HttpServletRequest request) {
String hostName = request.getServerName();
Integer hostPort = request.getServerPort();
String path = request.getContextPath();
if (hostPort == 80) {
return "http://" + hostName + path + "/";
} else {
return "http://" + hostName + ":" + hostPort + path + "/";
}
}
/***
* 获取当前的website路径 String
*/
public static String getWebSite(HttpServletRequest request) {
String returnUrl = request.getScheme() + "://"
+ request.getServerName();
if (request.getServerPort() != 80) {
returnUrl += ":" + request.getServerPort();
}
returnUrl += request.getContextPath();
return returnUrl;
}
/**
* 初始化HTTP头.
*
* @return HttpHeaders
*/
public HttpHeaders initHttpHeaders() {
HttpHeaders headers = new HttpHeaders();
MediaType mediaType = new MediaType("text", "html",
Charset.forName("utf-8"));
headers.setContentType(mediaType);
return headers;
}
/**
* 返回 信息数据
*
* @param status
* @param msg
* @return
*/
public ResponseEntity<String> renderMsg(Boolean status, String msg) {
if (StringUtils.isEmpty(msg)) {
msg = "";
}
String str = "{\"status\":\"" + status + "\",\"msg\":\"" + msg + "\"}";
ResponseEntity<String> responseEntity = new ResponseEntity<String>(str,
initHttpHeaders(), HttpStatus.OK);
return responseEntity;
}
/**
* 返回obj数据
*
* @param status
* @param msg
* @param obj
* @return
*/
public ResponseEntity<String> renderData(Boolean status, String msg,
Object obj) {
if (StringUtils.isEmpty(msg)) {
msg = "";
}
StringBuffer sb = new StringBuffer();
sb.append("{");
sb.append("\"status\":\"" + status + "\",\"msg\":\"" + msg + "\",");
sb.append("\"data\":" + JacksonJsonUtil.toJson(obj) + "");
sb.append("}");
ResponseEntity<String> responseEntity = new ResponseEntity<String>(
sb.toString(), initHttpHeaders(), HttpStatus.OK);
return responseEntity;
}
/***
* 获取IP（如果是多级代理，则得到的是一串IP值）
*/
public static String getIpAddr(HttpServletRequest request) {
String ip = request.getHeader("x-forwarded-for");
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("Proxy-Client-IP");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getHeader("WL-Proxy-Client-IP");
}
if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
ip = request.getRemoteAddr();
}
if (ip != null && ip.length() > 0) {
String[] ips = ip.split(",");
for (int i = 0; i < ips.length; i++) {
if (!"unknown".equalsIgnoreCase(ips[i])) {
ip = ips[i];
break;
}
}
}
return ip;
}
/**
* 国际化获得语言内容
*
* @param key
* 语言key
* @param args
* @param argsSplit
* @param defaultMessage
* @param locale
* @return
*/
public static String getLanguage(String key, String args, String argsSplit,
String defaultMessage, String locale) {
String language = "zh";
String contry = "cn";
String returnValue = defaultMessage;
if (!StringUtil.isEmpty(locale)) {
try {
String[] localeArray = locale.split("_");
language = localeArray[0];
contry = localeArray[1];
} catch (Exception e) {
}
}
try {
ResourceBundle resource = ResourceBundle.getBundle("lang.resource",
new Locale(language, contry));
returnValue = resource.getString(key);
if (!StringUtil.isEmpty(args)) {
String[] argsArray = args.split(argsSplit);
for (int i = 0; i < argsArray.length; i++) {
returnValue = returnValue.replace("{" + i + "}",
argsArray[i]);
}
}
} catch (Exception e) {
}
return returnValue;
}
}
