spring boot SpringBoot+微信小程序实现的酒店预订小程序系统 附带详细运行指导视频

文章目录

一、项目演示二、项目介绍三、运行截图四、主要代码

一、项目演示

项目演示地址：视频地址

二、项目介绍

项目描述：这是一个基于SpringBoot+微信小程序框架开发的酒店预订小程序系统。首先，这是一个前后端分离的项目，代码简洁规范，注释说明详细，易于理解和学习。其次，这项目功能丰富，具有一个酒店预订小程序系统该有的所有功能。

项目功能：此项目分为两个角色：普通用户和管理员。普通用户有微信授权登录、浏览房间信息、提交房间预订订单、浏览酒店图集和配套设施信息、浏览公告信息、管理个人基本信息、查看个人订单信息、管理个人评价信息、发布评价信息等等功能。管理员有管理所有房间信息、管理所有订单信息、管理所有用户信息、管理所有评价信息、管理所有公告信息、管理所有图集信息、浏览收益图表数据等等功能。

应用技术：SpringBoot + 微信小程序 + MySQL + MyBatis + Redis + ElementUI + Vue + Vant Weapp

运行环境：IntelliJ IDEA2019.3.5 + 微信开发者工具（项目压缩包中自带）+ MySQL5.7（项目压缩包中自带) + Redis5.0.5（项目压缩包中自带） + JDK1.8 + Maven3.6.3（项目压缩包中自带）+ Node14.16.1（项目压缩包中自带）

三、运行截图

四、主要代码

1.提交预订房间订单代码：

/**

* 提交订单操作

* @param orderDTO

* @return

*/

@Override

public ResponseDTO submitOrder(OrderDTO orderDTO) {

ResponseDTO loginUserResponse = userService.getLoginUser(orderDTO.getToken());

if(!CodeMsg.SUCCESS.getCode().equals(loginUserResponse.getCode())) {

return ResponseDTO.errorByMsg(CodeMsg.USER_SESSION_EXPIRED);

}

UserDTO loginUserDTO = loginUserResponse.getData();

// 进行统一表单验证

CodeMsg validate = ValidateEntityUtil.validate(orderDTO);

if(!validate.getCode().equals(CodeMsg.SUCCESS.getCode())){

return ResponseDTO.errorByMsg(validate);

}

Room room = roomMapper.selectByPrimaryKey(orderDTO.getRoomId());

if(room == null) {

return ResponseDTO.errorByMsg(CodeMsg.ROOM_NOT_EXIST);

}

Order order = CopyUtil.copy(orderDTO, Order.class);

if(order.getNum() > room.getNum()) {

return ResponseDTO.errorByMsg(CodeMsg.ROOM_NOT_ENOUGH);

}

RoomExample roomExample = new RoomExample();

// 乐观锁控制更新房间余量 防止超卖

roomExample.createCriteria().andIdEqualTo(room.getId()).andVersionEqualTo(room.getVersion());

// 版本号 + 1

room.setVersion(room.getVersion() + 1);

room.setNum(room.getNum() - order.getNum());

if(roomMapper.updateByExampleSelective(room, roomExample) == 0) {

return ResponseDTO.errorByMsg(CodeMsg.ORDER_BUSY);

}

order.setId(UuidUtil.getShortUuid());

order.setCreateTime(new Date());

order.setRoomType(room.getType());

order.setRoomPhoto(room.getPhoto());

order.setUserId(loginUserDTO.getId());

order.setRoomPrice(room.getPrice());

order.setTotalPrice(room.getPrice().multiply(new BigDecimal(order.getNum())));

// 入队操作，队列已满则阻塞等待

try {

blockingQueue.put(order);

} catch (InterruptedException e) {

e.printStackTrace();

return ResponseDTO.errorByMsg(CodeMsg.ORDER_BUSY);

}

return ResponseDTO.successByMsg(true, "预订成功！");

}

2.小程序微信授权登录代码：

/**

* 小程序授权登录验证

* @param userDTO

* @return

*/

@Override

public ResponseDTO appWxLogin(UserDTO userDTO) {

String url = LOGIN_URL + "?appid=" + APP_ID + "&secret="+ APP_SECRET + "&grant_type=authorization_code&js_code=" + userDTO.getCode();

HttpClient client = HttpClients.createDefault(); // 创建默认http连接

HttpGet getRequest = new HttpGet(url);// 创建一个post请求

LoginDTO loginDTO = new LoginDTO();

try {

// 用http连接去执行get请求并且获得http响应

HttpResponse response = client.execute(getRequest);

// 从response中取到响实体

HttpEntity entity = response.getEntity();

// 把响应实体转成文本

String html = EntityUtils.toString(entity);

loginDTO = JSON.parseObject(html, LoginDTO.class);

if(null == loginDTO.getErrcode()) {

userDTO.setWxId(loginDTO.getOpenid());

} else {

return ResponseDTO.errorByMsg(CodeMsg.USER_WX_LOGIN_ERROR);

}

} catch (Exception e) {

e.printStackTrace();

return ResponseDTO.errorByMsg(CodeMsg.USER_WX_LOGIN_ERROR);

}

// 使用微信openId查询是否有此用户

UserExample userExample = new UserExample();

userExample.createCriteria().andWxIdEqualTo(userDTO.getWxId());

List userList = userMapper.selectByExample(userExample);

if(null != userList && userList.size() > 0) {

// 已经存在用户信息，读取数据库中用户信息

User user = userList.get(0);

userDTO = CopyUtil.copy(user, UserDTO.class);

} else {

// 数据库中不存在，注册用户信息

User user = CopyUtil.copy(userDTO, User.class);

user.setId(UuidUtil.getShortUuid());

user.setUsername(user.getWxUsername());

user.setHeadPic(user.getWxHeadPic());

user.setRoleId(RoleEnum.USER.getCode());

if(userMapper.insertSelective(user) == 0) {

return ResponseDTO.errorByMsg(CodeMsg.USER_REGISTER_ERROR);

}

userDTO = CopyUtil.copy(user, UserDTO.class);

}

userDTO.setToken(UuidUtil.getShortUuid());

stringRedisTemplate.opsForValue().set("USER_" + userDTO.getToken(), JSON.toJSONString(userMapper.selectByPrimaryKey(userDTO.getId())), 3600, TimeUnit.SECONDS);

return ResponseDTO.successByMsg(userDTO, "登录成功！");

}

3.提交评价信息代码：

/**

* 提交评价信息

* @param commentDTO

* @return

*/

@Override

public ResponseDTO submitComment(CommentDTO commentDTO) {

ResponseDTO loginUserResponse = userService.getLoginUser(commentDTO.getToken());

if(!CodeMsg.SUCCESS.getCode().equals(loginUserResponse.getCode())) {

return ResponseDTO.errorByMsg(CodeMsg.USER_SESSION_EXPIRED);

}

UserDTO loginUserDTO = loginUserResponse.getData();

// 进行统一表单验证

CodeMsg validate = ValidateEntityUtil.validate(commentDTO);

if(!validate.getCode().equals(CodeMsg.SUCCESS.getCode())){

return ResponseDTO.errorByMsg(validate);

}

Comment comment = CopyUtil.copy(commentDTO, Comment.class);

comment.setId(UuidUtil.getShortUuid());

comment.setCreateTime(new Date());

comment.setUserId(loginUserDTO.getId());

if(commentMapper.insertSelective(comment) == 0) {

return ResponseDTO.errorByMsg(CodeMsg.COMMENT_ADD_ERROR);

}

return ResponseDTO.successByMsg(true, "评价成功！");

}

相关阅读

 您阅读本篇文章共花了：