背景分析
图书馆座位资源有限,尤其在考试周或高峰期,座位供不应求,传统的人工占座或现场排队方式效率低下,易引发纠纷。数字化管理需求迫切,微信小程序因其轻量化和高普及率成为理想载体。
技术背景
Spring Boot 提供快速开发能力,集成MyBatis、Redis等组件,支持高并发预约请求处理;微信小程序提供扫码、消息推送等原生能力,与后端API无缝对接。
现实意义
- 资源优化:通过分时段预约、自动释放机制提升座位周转率。
- 用户体验:实时查看座位状态、在线选座,减少排队时间。
- 管理效率:后台数据统计辅助决策,如高峰时段分析、座位利用率报表。
创新点
- 动态分配算法:结合用户历史行为(如预约取消率)实现智能推荐。
- 信用积分机制:违约(如超时未签到)扣分,影响后续预约权限。
- 多端协同:小程序与图书馆闸机系统联动,实现扫码签到核验。
实现示例(关键技术)
后端核心逻辑(Spring Boot)
@RestController @RequestMapping("/seat") public class SeatController { @Autowired private RedisTemplate<String, String> redisTemplate; @PostMapping("/reserve") public Response reserveSeat(@RequestBody ReservationDTO dto) { // 使用Redis分布式锁防止超卖 String lockKey = "seat_lock:" + dto.getSeatId(); try { if (redisTemplate.opsForValue().setIfAbsent(lockKey, "1", 30, TimeUnit.SECONDS)) { // 业务逻辑:检查座位状态、写入数据库 return doReserve(dto); } return Response.fail("操作频繁,请重试"); } finally { redisTemplate.delete(lockKey); } } }小程序端功能模块
- 座位地图:Canvas绘制楼层平面图,点击座位触发预约。
- 消息模板:推送预约成功、倒计时提醒等通知。
数据模型设计
CREATE TABLE `reservation` ( `id` BIGINT PRIMARY KEY AUTO_INCREMENT, `user_id` VARCHAR(32) NOT NULL COMMENT '微信OpenID', `seat_id` INT NOT NULL, `start_time` DATETIME NOT NULL, `end_time` DATETIME NOT NULL, `status` TINYINT DEFAULT 0 COMMENT '0-待签到,1-已完成,2-已取消' );扩展方向
- 可视化看板:Echarts展示实时座位占用热力图。
- AI预测:基于历史数据预测未来时段座位紧张程度。
技术栈选择
后端技术栈
Spring Boot 2.7.x(稳定版本)作为核心框架,提供RESTful API和业务逻辑处理。
MySQL 8.0作为关系型数据库,存储用户信息、座位数据和预约记录。
Redis 7.0用于缓存高频访问数据(如实时座位状态)和分布式锁控制并发预约。
Spring Security + JWT实现用户认证与授权。
WebSocket实现座位状态实时推送。
前端技术栈
微信小程序原生开发或Uni-app跨平台框架,兼容微信生态。
WXML/WXSS + JavaScript/TypeScript构建界面与交互逻辑。
ECharts或小程序原生图表库展示座位占用率统计。
辅助工具
Swagger/Knife4j生成API文档。
Lombok简化Java代码。
Quartz或XXL-JOB处理定时任务(如释放超时未签到座位)。
Jenkins/Docker实现CI/CD部署。
核心功能模块设计
座位管理模块
基于MySQL设计座位表(seat_id, location, status, type)和预约记录表(order_id, user_id, seat_id, start_time, end_time, status)。
使用Redis Bitmap记录座位实时状态(0/1表示可用/占用),优化查询性能。
预约流程
用户发起预约时,通过Redis分布式锁(Redisson)防止重复预约。
采用乐观锁(MySQL版本号)处理并发更新预约记录。
微信模板消息通知预约成功/变更信息。
签到与超时处理
调用微信小程序扫码接口获取座位二维码信息,与数据库匹配完成签到。
Quartz定时任务检查预约记录:
- 预约后15分钟未签到自动释放座位。
- 使用结束时间前30分钟推送提醒。
性能优化策略
数据库分表存储历史预约记录,按月份拆分。
Nginx反向代理 + Spring Boot Actuator监控接口性能。
CDN加速静态资源(如小程序页面图片)。
采用限流工具(如Sentinel)防止恶意刷单。
示例代码片段(关键逻辑)
Redis座位状态检查
// 使用Redis Bitmap标记座位状态 String seatKey = "library:seat:status:" + date; Boolean isOccupied = redisTemplate.opsForValue().getBit(seatKey, seatId); if (Boolean.TRUE.equals(isOccupied)) { throw new BusinessException("该座位已被预约"); }微信小程序API调用
// 小程序端调用预约接口 wx.request({ url: 'https://api.example.com/reserve', method: 'POST', data: { seatId: 123, startTime: '14:00' }, header: { 'Authorization': 'Bearer ' + token } })数据库表结构示例
CREATE TABLE `seat_reservation` ( `id` bigint NOT NULL AUTO_INCREMENT, `user_id` varchar(32) NOT NULL COMMENT '微信OpenID', `seat_id` int NOT NULL, `reserve_time` datetime NOT NULL COMMENT '预约时间', `status` tinyint DEFAULT 0 COMMENT '0-待签到 1-已使用 2-已取消', PRIMARY KEY (`id`), KEY `idx_seat_time` (`seat_id`, `reserve_time`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;数据库设计
核心表包括用户表、座位表、预约记录表。用户表存储微信用户openid和基本信息;座位表记录座位编号、区域、状态;预约记录表关联用户和座位,包含预约时间段、状态等字段。
@Entity @Table(name = "seat") public class Seat { @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Long id; private String seatNumber; private String zone; private Integer status; // 0-空闲 1-已预约 2-使用中 } @Entity @Table(name = "reservation") public class Reservation { @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Long id; @ManyToOne private User user; @ManyToOne private Seat seat; private LocalDateTime startTime; private LocalDateTime endTime; private Integer status; // 0-待使用 1-使用中 2-已完成 3-已取消 }微信登录集成
通过微信小程序获取code,后端调用微信接口获取openid实现无感登录。
@RestController @RequestMapping("/api/auth") public class AuthController { @Value("${wechat.appid}") private String appid; @Value("${wechat.secret}") private String secret; @PostMapping("/login") public Result login(@RequestParam String code) { String url = "https://api.weixin.qq.com/sns/jscode2session?appid=" + appid + "&secret=" + secret + "&js_code=" + code + "&grant_type=authorization_code"; // 调用微信接口获取openid String response = restTemplate.getForObject(url, String.class); JSONObject json = JSONObject.parseObject(response); String openid = json.getString("openid"); User user = userService.findByOpenid(openid); if(user == null) { user = new User(); user.setOpenid(openid); userService.save(user); } String token = jwtUtil.generateToken(user.getId().toString()); return Result.success(token); } }座位预约逻辑
处理预约请求时需要检查座位状态和冲突预约,采用乐观锁防止超卖。
@Service public class ReservationService { @Transactional public Result makeReservation(Long userId, Long seatId, LocalDateTime start, LocalDateTime end) { // 检查时间有效性 if(start.isBefore(LocalDateTime.now()) || end.isBefore(start)) { return Result.error("无效时间段"); } // 检查座位状态 Seat seat = seatRepository.findById(seatId).orElseThrow(); if(seat.getStatus() != 0) { return Result.error("座位不可用"); } // 检查时间冲突 boolean conflict = reservationRepository.existsConflict(seatId, start, end); if(conflict) { return Result.error("时间段已被预约"); } // 创建预约记录 Reservation reservation = new Reservation(); reservation.setUser(userRepository.findById(userId).orElseThrow()); reservation.setSeat(seat); reservation.setStartTime(start); reservation.setEndTime(end); reservation.setStatus(0); reservationRepository.save(reservation); // 更新座位状态 seat.setStatus(1); seatRepository.save(seat); return Result.success(reservation); } }定时任务处理
使用Spring Scheduler处理过期预约和自动释放座位。
@Scheduled(cron = "0 */5 * * * ?") public void checkExpiredReservations() { LocalDateTime now = LocalDateTime.now(); // 处理超时未签到的预约 List<Reservation> expired = reservationRepository .findByStatusAndStartTimeBefore(0, now.minusMinutes(15)); expired.forEach(res -> { res.setStatus(3); // 已取消 res.getSeat().setStatus(0); // 空闲 reservationRepository.save(res); }); // 处理使用超时的预约 List<Reservation> overtime = reservationRepository .findByStatusAndEndTimeBefore(1, now); overtime.forEach(res -> { res.setStatus(2); // 已完成 res.getSeat().setStatus(0); // 空闲 reservationRepository.save(res); }); }微信消息通知
通过微信订阅消息通知用户预约状态变化。
public void sendReservationNotice(String openid, String templateId, String page, Map<String, String> data) { String accessToken = getWechatAccessToken(); String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + accessToken; JSONObject params = new JSONObject(); params.put("touser", openid); params.put("template_id", templateId); params.put("page", page); JSONObject content = new JSONObject(); data.forEach((k,v) -> content.put(k, new JSONObject().put("value", v))); params.put("data", content); restTemplate.postForObject(url, params, String.class); }