Java全栈项目 - 智能停车场管理系统

项目介绍

智能停车场管理系统是一个基于 Java 全栈技术开发的现代化停车场解决方案。本系统旨在提供便捷的车辆进出管理、实时车位监控、收费管理等功能，提高停车场运营效率。

技术栈

后端

Spring Boot 2.7.x
Spring Security
MyBatis-Plus
MySQL 8.0
Redis
JWT

前端

Vue 3
Element Plus
Axios
Echarts
Vue Router
Pinia

核心功能模块

1. 车辆管理

车辆进场识别
车牌自动识别
临时车辆管理
月卡车辆管理
黑名单管理

2. 停车位管理

实时车位统计
车位使用状态展示
车位预约
车位导航

3. 收费管理

灵活的收费规则配置
多种支付方式（微信、支付宝）
发票管理
收费统计报表

4. 系统管理

用户权限管理
系统参数配置
操作日志
数据备份

数据库设计

-- 车辆信息表
CREATE TABLE t_vehicle (id BIGINT PRIMARY KEY AUTO_INCREMENT,plate_number VARCHAR(20) NOT NULL COMMENT '车牌号',vehicle_type TINYINT COMMENT '车辆类型：1-临时车辆 2-月卡车辆',owner_name VARCHAR(50) COMMENT '车主姓名',owner_phone VARCHAR(20) COMMENT '联系电话',create_time DATETIME,update_time DATETIME
);-- 停车记录表
CREATE TABLE t_parking_record (id BIGINT PRIMARY KEY AUTO_INCREMENT,vehicle_id BIGINT COMMENT '车辆ID',entry_time DATETIME COMMENT '入场时间',exit_time DATETIME COMMENT '出场时间',parking_space_id BIGINT COMMENT '车位ID',fee DECIMAL(10,2) COMMENT '停车费用',status TINYINT COMMENT '状态：1-进行中 2-已完成'
);

核心代码示例

1. 车辆入场处理

@Service
@Slf4j
public class ParkingServiceImpl implements ParkingService {@Autowiredprivate VehicleMapper vehicleMapper;@Autowiredprivate ParkingRecordMapper parkingRecordMapper;@Override@Transactional(rollbackFor = Exception.class)public void handleVehicleEntry(String plateNumber) {// 1. 查询车辆信息Vehicle vehicle = vehicleMapper.selectByPlateNumber(plateNumber);if (vehicle == null) {// 临时车辆登记vehicle = createTemporaryVehicle(plateNumber);}// 2. 创建停车记录ParkingRecord record = new ParkingRecord();record.setVehicleId(vehicle.getId());record.setEntryTime(LocalDateTime.now());record.setStatus(ParkingStatus.IN_PROGRESS.getCode());parkingRecordMapper.insert(record);// 3. 更新车位状态updateParkingSpaceStatus(record.getParkingSpaceId(), true);log.info("车辆入场成功：{}", plateNumber);}
}

2. 停车费用计算

public class ParkingFeeCalculator {public BigDecimal calculate(LocalDateTime entryTime, LocalDateTime exitTime, VehicleType type) {// 计算停车时长（小时）long hours = ChronoUnit.HOURS.between(entryTime, exitTime);// 根据车辆类型和时长计算费用switch (type) {case TEMPORARY:return calculateTemporaryFee(hours);case MONTHLY:return BigDecimal.ZERO;default:throw new IllegalArgumentException("未知的车辆类型");}}private BigDecimal calculateTemporaryFee(long hours) {// 首两小时20元，之后每小时10元if (hours <= 2) {return new BigDecimal("20");}return new BigDecimal("20").add(new BigDecimal("10").multiply(new BigDecimal(hours - 2)));}
}

系统部署

环境要求

JDK 1.8+
MySQL 8.0+
Redis 6.0+
Nginx 1.18+
Node.js 14+

部署步骤

后端部署

# 打包
mvn clean package# 运行
java -jar parking-system.jar --spring.profiles.active=prod

前端部署

# 安装依赖
npm install# 构建
npm run build# Nginx配置
server {listen 80;server_name parking.example.com;location / {root /usr/share/nginx/html;index index.html;try_files $uri $uri/ /index.html;}location /api {proxy_pass http://localhost:8080;}
}

项目优化

性能优化
- 使用 Redis 缓存热点数据
- MyBatis-Plus 分页查询优化
- 前端组件懒加载
安全优化
- 实现 JWT 令牌认证
- 接口参数校验
- SQL 注入防护
- XSS 防护
可用性优化
- 统一异常处理
- 操作日志记录
- 数据定时备份
- 系统监控告警

总结

本项目采用主流的 Java 全栈技术栈，实现了一个功能完整的智能停车场管理系统。通过合理的架构设计和优化措施，确保了系统的高性能、高可用性和安全性。项目中的一些技术方案和最佳实践，可以为类似的管理系统开发提供参考。

项目亮点

采用前后端分离架构
实现了灵活的权限控制
提供了丰富的数据统计分析
支持多种支付方式对接
良好的系统可扩展性

后续优化方向

引入微服务架构
添加实时监控大屏
对接物联网设备
引入人工智能算法优化车位分配
支持移动端 APP

智能停车场管理系统 - 车辆与停车位管理模块详解

一、车辆管理模块

1. 车辆进场识别系统

1.1 硬件集成

@Service
public class EntranceDeviceService {@Autowiredprivate CameraService cameraService;@Autowiredprivate GateService gateService;public void handleVehicleEntrance() {// 1. 触发入场摄像头CameraImage image = cameraService.captureImage();// 2. 识别车牌String plateNumber = plateRecognitionService.recognize(image);// 3. 控制道闸if (validateVehicle(plateNumber)) {gateService.open();createParkingRecord(plateNumber);}}
}

1.2 车牌识别算法

@Service
public class PlateRecognitionService {@Autowiredprivate OpenCVProcessor opencvProcessor;public String recognize(CameraImage image) {// 1. 图像预处理Mat processedImage = opencvProcessor.preprocess(image);// 2. 车牌区域定位Rectangle plateRegion = opencvProcessor.locatePlateRegion(processedImage);// 3. 字符分割List<Mat> characters = opencvProcessor.segmentCharacters(plateRegion);// 4. 字符识别return opencvProcessor.recognizeCharacters(characters);}
}

2. 临时车辆管理

2.1 数据模型

-- 临时车辆表
CREATE TABLE t_temporary_vehicle (id BIGINT PRIMARY KEY AUTO_INCREMENT,plate_number VARCHAR(20) NOT NULL COMMENT '车牌号',entry_time DATETIME COMMENT '入场时间',parking_space_id BIGINT COMMENT '分配车位ID',status TINYINT COMMENT '状态：1-在场 2-离场',payment_status TINYINT COMMENT '支付状态：0-未支付 1-已支付',create_time DATETIME,update_time DATETIME
);

2.2 核心业务逻辑

@Service
public class TemporaryVehicleService {@Autowiredprivate TemporaryVehicleMapper temporaryVehicleMapper;@Autowiredprivate ParkingSpaceService parkingSpaceService;@Transactional(rollbackFor = Exception.class)public void handleTemporaryVehicleEntry(String plateNumber) {// 1. 检查车位可用性ParkingSpace space = parkingSpaceService.allocateSpace();if (space == null) {throw new BusinessException("暂无可用车位");}// 2. 创建临时车辆记录TemporaryVehicle vehicle = new TemporaryVehicle();vehicle.setPlateNumber(plateNumber);vehicle.setEntryTime(LocalDateTime.now());vehicle.setParkingSpaceId(space.getId());vehicle.setStatus(VehicleStatus.IN_PARK.getCode());temporaryVehicleMapper.insert(vehicle);// 3. 更新车位状态parkingSpaceService.occupySpace(space.getId());}
}

3. 月卡车辆管理

3.1 数据模型

-- 月卡会员表
CREATE TABLE t_monthly_member (id BIGINT PRIMARY KEY AUTO_INCREMENT,plate_number VARCHAR(20) NOT NULL,owner_name VARCHAR(50),owner_phone VARCHAR(20),card_type TINYINT COMMENT '卡类型：1-普通月卡 2-VIP月卡',valid_start_date DATE,valid_end_date DATE,status TINYINT COMMENT '状态：1-正常 2-过期 3-禁用'
);

3.2 月卡管理功能

@Service
public class MonthlyMemberService {@Autowiredprivate MonthlyMemberMapper memberMapper;public void createMonthlyCard(MonthlyMemberDTO dto) {// 1. 验证会员信息validateMemberInfo(dto);// 2. 创建月卡会员MonthlyMember member = new MonthlyMember();BeanUtils.copyProperties(dto, member);// 3. 设置有效期member.setValidStartDate(LocalDate.now());member.setValidEndDate(LocalDate.now().plusMonths(dto.getMonths()));member.setStatus(MemberStatus.NORMAL.getCode());memberMapper.insert(member);}public void renewCard(Long memberId, int months) {MonthlyMember member = memberMapper.selectById(memberId);if (member == null) {throw new BusinessException("会员不存在");}// 续费逻辑LocalDate newEndDate = member.getValidEndDate().plusMonths(months);member.setValidEndDate(newEndDate);member.setStatus(MemberStatus.NORMAL.getCode());memberMapper.updateById(member);}
}

4. 黑名单管理

4.1 数据模型

-- 黑名单表
CREATE TABLE t_blacklist (id BIGINT PRIMARY KEY AUTO_INCREMENT,plate_number VARCHAR(20) NOT NULL,reason VARCHAR(200) COMMENT '加入原因',operator VARCHAR(50) COMMENT '操作人',start_time DATETIME COMMENT '生效时间',end_time DATETIME COMMENT '结束时间',status TINYINT COMMENT '状态：1-生效 2-失效'
);

4.2 黑名单服务

@Service
public class BlacklistService {@Autowiredprivate BlacklistMapper blacklistMapper;public void addToBlacklist(BlacklistDTO dto) {Blacklist blacklist = new Blacklist();BeanUtils.copyProperties(dto, blacklist);blacklist.setStatus(BlacklistStatus.ACTIVE.getCode());blacklist.setStartTime(LocalDateTime.now());blacklistMapper.insert(blacklist);}public boolean isInBlacklist(String plateNumber) {return blacklistMapper.countActiveBlacklist(plateNumber) > 0;}public void removeFromBlacklist(Long id, String operator) {Blacklist blacklist = blacklistMapper.selectById(id);blacklist.setStatus(BlacklistStatus.INACTIVE.getCode());blacklist.setEndTime(LocalDateTime.now());blacklist.setOperator(operator);blacklistMapper.updateById(blacklist);}
}

二、停车位管理模块

1. 实时车位统计

1.1 数据模型

-- 停车位表
CREATE TABLE t_parking_space (id BIGINT PRIMARY KEY AUTO_INCREMENT,space_number VARCHAR(20) COMMENT '车位编号',area_code VARCHAR(20) COMMENT '区域编号',type TINYINT COMMENT '类型：1-普通 2-充电桩 3-无障碍',status TINYINT COMMENT '状态：0-空闲 1-占用 2-预约 3-维护',current_vehicle_id BIGINT COMMENT '当前车辆ID',last_update_time DATETIME
);-- 车位统计表
CREATE TABLE t_parking_statistics (id BIGINT PRIMARY KEY AUTO_INCREMENT,area_code VARCHAR(20),total_spaces INT,occupied_spaces INT,reserved_spaces INT,maintenance_spaces INT,statistics_time DATETIME
);

1.2 实时统计服务

@Service
public class ParkingStatisticsService {@Autowiredprivate ParkingSpaceMapper spaceMapper;@Autowiredprivate RedisTemplate redisTemplate;@Scheduled(fixedRate = 60000) // 每分钟统计一次public void updateStatistics() {// 1. 按区域统计List<ParkingAreaStatistics> areaStats = spaceMapper.countByArea();// 2. 更新Redis缓存for (ParkingAreaStatistics stats : areaStats) {String redisKey = "parking:stats:" + stats.getAreaCode();redisTemplate.opsForHash().putAll(redisKey, stats.toMap());}// 3. 保存历史数据saveParkingStatistics(areaStats);}public ParkingStatistics getRealtimeStatistics(String areaCode) {String redisKey = "parking:stats:" + areaCode;return redisTemplate.opsForHash().entries(redisKey);}
}

2. 车位状态展示

2.1 前端展示组件

<template><div class="parking-layout"><!-- 停车场平面图 --><div class="parking-map"><div v-for="space in parkingSpaces" :key="space.id" :class="['space-item', getSpaceClass(space.status)]":style="getSpacePosition(space)"><span class="space-number">{{ space.spaceNumber }}</span><span class="space-status">{{ getStatusText(space.status) }}</span></div></div><!-- 图例说明 --><div class="legend"><div class="legend-item"><span class="legend-color empty"></span><span>空闲</span></div><div class="legend-item"><span class="legend-color occupied"></span><span>占用</span></div><!-- 其他状态... --></div></div>
</template><script>
export default {data() {return {parkingSpaces: [],refreshInterval: null}},methods: {getSpaceClass(status) {const statusMap = {0: 'empty',1: 'occupied',2: 'reserved',3: 'maintenance'}return statusMap[status] || 'empty'},async refreshSpaces() {try {const response = await this.axios.get('/api/parking/spaces/status')this.parkingSpaces = response.data} catch (error) {console.error('获取车位状态失败:', error)}}},mounted() {this.refreshSpaces()this.refreshInterval = setInterval(this.refreshSpaces, 30000) // 每30秒刷新},beforeDestroy() {if (this.refreshInterval) {clearInterval(this.refreshInterval)}}
}
</script>

3. 车位预约

3.1 数据模型

-- 车位预约表
CREATE TABLE t_parking_reservation (id BIGINT PRIMARY KEY AUTO_INCREMENT,user_id BIGINT COMMENT '用户ID',space_id BIGINT COMMENT '车位ID',plate_number VARCHAR(20),reservation_time DATETIME COMMENT '预约时间',expire_time DATETIME COMMENT '预约过期时间',status TINYINT COMMENT '状态：1-预约中 2-已使用 3-已取消 4-已过期'
);

3.2 预约服务

@Service
public class ParkingReservationService {@Autowiredprivate ParkingReservationMapper reservationMapper;@Autowiredprivate ParkingSpaceService spaceService;@Transactional(rollbackFor = Exception.class)public void createReservation(ReservationDTO dto) {// 1. 检查车位是否可预约ParkingSpace space = spaceService.getSpace(dto.getSpaceId());if (!spaceService.isSpaceAvailable(space)) {throw new BusinessException("该车位不可预约");}// 2. 创建预约记录ParkingReservation reservation = new ParkingReservation();BeanUtils.copyProperties(dto, reservation);reservation.setReservationTime(LocalDateTime.now());reservation.setExpireTime(LocalDateTime.now().plusHours(2)); // 预约2小时有效reservation.setStatus(ReservationStatus.ACTIVE.getCode());reservationMapper.insert(reservation);// 3. 更新车位状态spaceService.updateSpaceStatus(space.getId(), SpaceStatus.RESERVED.getCode());}@Scheduled(fixedRate = 300000) // 每5分钟检查过期预约public void checkExpiredReservations() {List<ParkingReservation> expiredList = reservationMapper.findExpiredReservations();for (ParkingReservation reservation : expiredList) {cancelReservation(reservation.getId());}}
}

4. 车位导航

4.1 导航算法服务

@Service
public class ParkingNavigationService {@Autowiredprivate ParkingMapService mapService;public List<NavigationStep> calculateRoute(Point start, Long targetSpaceId) {// 1. 获取目标车位位置ParkingSpace targetSpace = spaceService.getSpace(targetSpaceId);Point destination = new Point(targetSpace.getX(), targetSpace.getY());// 2. 获取停车场地图ParkingMap parkingMap = mapService.getParkingMap();// 3. A*寻路算法return AStarPathFinder.findPath(parkingMap, start, destination);}public List<NavigationInstruction> generateInstructions(List<NavigationStep> route) {List<NavigationInstruction> instructions = new ArrayList<>();for (int i = 0; i < route.size() - 1; i++) {NavigationStep current = route.get(i);NavigationStep next = route.get(i + 1);// 根据两点关系生成导航指令String instruction = generateInstruction(current, next);instructions.add(new NavigationInstruction(instruction));}return instructions;}
}

4.2 前端导航组件

<template><div class="navigation-container"><!-- 导航地图 --><div class="navigation-map"><canvas ref="mapCanvas"></canvas><!-- 导航路线 --><div class="navigation-route" v-if="route.length > 0"><svg class="route-path"><polyline :points="routePoints" class="route-line"/></svg></div><!-- 当前位置标记 --><div class="current-location-marker":style="currentLocationStyle"><i class="el-icon-location"></i></div></div><!-- 导航指令 --><div class="navigation-instructions"><div v-for="(instruction, index) in instructions":key="index":class="['instruction-item', { 'active': currentStepIndex === index }]"><span class="step-number">{{ index + 1 }}</span><span class="instruction-text">{{ instruction.text }}</span><span class="distance">{{ instruction.distance }}米</span></div></div></div>
</template><script>
export default {data() {return {route: [],instructions: [],currentStepIndex: 0,currentLocation: null}},methods: {async startNavigation(spaceId) {try {// 1. 获取导航路线const response = await this.axios.get(`/api/parking/navigation/${spaceId}`)this.route = response.data.routethis.instructions = response.data.instructions// 2. 开始实时位置更新this.startLocationTracking()// 3. 渲染导航路线this.renderRoute()} catch (error) {this.$message.error('获取导航路线失败')}},startLocationTracking() {// 模拟定位更新，实际项目中可能使用蓝牙信标或其他室内定位技术this.locationInterval = setInterval(() => {this.updateCurrentLocation()}, 1000)},updateCurrentLocation() {// 获取最新位置// 更新当前导航步骤// 检查是否到达目的地}}
}
</script>

以上是智能停车场管理系统中车辆管理和停车位管理模块的详细实现。系统通过整合硬件设备（摄像头、道闸等）和软件系统，实现了车辆的自动识别、车位的智能分配、实时监控和导航等功能。同时，通过合理的数据模型设计和缓存策略，确保了系统的高性能和可靠性。

关键特点：

采用分布式缓存（Redis）提升系统性能
使用定时任务处理过期预约和统计更新
实现了实时车位状态更新和展示
提供了智能导航功能帮助用户快速找到车位
支持多种类型的车辆管理（临时、月卡、黑名单）

智能停车场管理系统 - 收费与系统管理模块详解

一、收费管理模块

1. 收费规则配置

1.1 数据模型

-- 收费规则表
CREATE TABLE t_fee_rule (id BIGINT PRIMARY KEY AUTO_INCREMENT,rule_name VARCHAR(50) COMMENT '规则名称',vehicle_type TINYINT COMMENT '车辆类型：1-临时车 2-月卡车',time_period VARCHAR(20) COMMENT '时间段(如: 00:00-24:00)',is_holiday TINYINT COMMENT '是否节假日：0-否 1-是',first_hour_fee DECIMAL(10,2) COMMENT '首小时费用',additional_hour_fee DECIMAL(10,2) COMMENT '后续每小时费用',max_daily_fee DECIMAL(10,2) COMMENT '每日最高收费',status TINYINT COMMENT '状态：1-启用 2-禁用',create_time DATETIME,update_time DATETIME
);-- 特殊日期费率表
CREATE TABLE t_special_date_fee (id BIGINT PRIMARY KEY AUTO_INCREMENT,date DATE COMMENT '特殊日期',fee_rule_id BIGINT COMMENT '对应的收费规则ID',description VARCHAR(100) COMMENT '说明'
);

1.2 收费规则服务

@Service
public class FeeRuleService {@Autowiredprivate FeeRuleMapper feeRuleMapper;@Autowiredprivate RedisTemplate redisTemplate;public BigDecimal calculateParkingFee(ParkingRecord record) {// 1. 获取适用的收费规则FeeRule rule = getApplicableRule(record);// 2. 计算停车时长Duration duration = Duration.between(record.getEntryTime(), record.getExitTime());long hours = duration.toHours();// 3. 计算费用BigDecimal totalFee = BigDecimal.ZERO;// 首小时费用totalFee = totalFee.add(rule.getFirstHourFee());// 后续小时费用if (hours > 1) {BigDecimal additionalFee = rule.getAdditionalHourFee().multiply(new BigDecimal(hours - 1));totalFee = totalFee.add(additionalFee);}// 判断是否超过每日最高限额return totalFee.min(rule.getMaxDailyFee());}@Cacheable(value = "feeRules", key = "#date")public FeeRule getApplicableRule(LocalDate date, VehicleType vehicleType) {// 1. 检查是否特殊日期FeeRule specialRule = feeRuleMapper.findSpecialDateRule(date);if (specialRule != null) {return specialRule;}// 2. 检查是否节假日boolean isHoliday = holidayService.isHoliday(date);// 3. 获取适用规则return feeRuleMapper.findApplicableRule(vehicleType, isHoliday);}
}

2. 支付管理

2.1 数据模型

-- 支付记录表
CREATE TABLE t_payment_record (id BIGINT PRIMARY KEY AUTO_INCREMENT,parking_record_id BIGINT COMMENT '停车记录ID',amount DECIMAL(10,2) COMMENT '支付金额',payment_type TINYINT COMMENT '支付方式：1-微信 2-支付宝 3-现金',transaction_id VARCHAR(64) COMMENT '第三方交易号',payment_status TINYINT COMMENT '支付状态：1-待支付 2-支付中 3-支付成功 4-支付失败',create_time DATETIME,update_time DATETIME
);

2.2 支付服务实现

@Service
public class PaymentService {@Autowiredprivate WechatPayService wechatPayService;@Autowiredprivate AlipayService alipayService;@Autowiredprivate PaymentRecordMapper paymentRecordMapper;@Transactional(rollbackFor = Exception.class)public PaymentResponse createPayment(PaymentRequest request) {// 1. 创建支付记录PaymentRecord record = new PaymentRecord();record.setParkingRecordId(request.getParkingRecordId());record.setAmount(request.getAmount());record.setPaymentType(request.getPaymentType());record.setPaymentStatus(PaymentStatus.PENDING.getCode());paymentRecordMapper.insert(record);// 2. 根据支付方式调用对应的支付服务PaymentResponse response;switch (request.getPaymentType()) {case WECHAT:response = wechatPayService.createOrder(record);break;case ALIPAY:response = alipayService.createOrder(record);break;default:throw new BusinessException("不支持的支付方式");}return response;}@Transactional(rollbackFor = Exception.class)public void handlePaymentCallback(PaymentCallback callback) {// 1. 验证回调签名if (!verifyCallback(callback)) {throw new BusinessException("回调签名验证失败");}// 2. 更新支付记录PaymentRecord record = paymentRecordMapper.findByTransactionId(callback.getTransactionId());record.setPaymentStatus(PaymentStatus.SUCCESS.getCode());record.setUpdateTime(LocalDateTime.now());paymentRecordMapper.updateById(record);// 3. 触发支付成功事件applicationEventPublisher.publishEvent(new PaymentSuccessEvent(record));}
}

3. 发票管理

3.1 数据模型

-- 发票信息表
CREATE TABLE t_invoice (id BIGINT PRIMARY KEY AUTO_INCREMENT,payment_record_id BIGINT COMMENT '支付记录ID',invoice_type TINYINT COMMENT '发票类型：1-电子发票 2-纸质发票',invoice_title VARCHAR(100) COMMENT '发票抬头',tax_number VARCHAR(50) COMMENT '税号',amount DECIMAL(10,2) COMMENT '发票金额',invoice_status TINYINT COMMENT '状态：1-待开具 2-已开具 3-已作废',invoice_number VARCHAR(50) COMMENT '发票号码',create_time DATETIME,update_time DATETIME
);

3.2 发票服务

@Service
public class InvoiceService {@Autowiredprivate InvoiceMapper invoiceMapper;@Autowiredprivate ThirdPartyInvoiceService thirdPartyInvoiceService;@Transactional(rollbackFor = Exception.class)public void createInvoice(InvoiceRequest request) {// 1. 验证支付记录PaymentRecord payment = validatePayment(request.getPaymentRecordId());// 2. 创建发票记录Invoice invoice = new Invoice();BeanUtils.copyProperties(request, invoice);invoice.setAmount(payment.getAmount());invoice.setInvoiceStatus(InvoiceStatus.PENDING.getCode());invoiceMapper.insert(invoice);// 3. 调用第三方开票服务InvoiceResult result = thirdPartyInvoiceService.createInvoice(invoice);// 4. 更新发票信息invoice.setInvoiceNumber(result.getInvoiceNumber());invoice.setInvoiceStatus(InvoiceStatus.ISSUED.getCode());invoiceMapper.updateById(invoice);}public void sendInvoiceEmail(Long invoiceId, String email) {Invoice invoice = invoiceMapper.selectById(invoiceId);if (invoice.getInvoiceType() != InvoiceType.ELECTRONIC.getCode()) {throw new BusinessException("非电子发票不支持邮件发送");}// 发送邮件emailService.sendInvoiceEmail(email, invoice);}
}

4. 收费统计报表

4.1 数据模型

-- 收费统计表
CREATE TABLE t_fee_statistics (id BIGINT PRIMARY KEY AUTO_INCREMENT,statistics_date DATE COMMENT '统计日期',total_amount DECIMAL(10,2) COMMENT '总收入',temporary_amount DECIMAL(10,2) COMMENT '临时车收入',monthly_amount DECIMAL(10,2) COMMENT '月卡收入',payment_type_stats JSON COMMENT '支付方式统计',create_time DATETIME
);

4.2 统计服务

@Service
public class FeeStatisticsService {@Autowiredprivate PaymentRecordMapper paymentRecordMapper;@Autowiredprivate FeeStatisticsMapper statisticsMapper;@Scheduled(cron = "0 0 1 * * ?") // 每天凌晨1点执行public void generateDailyStatistics() {LocalDate yesterday = LocalDate.now().minusDays(1);// 1. 统计总收入BigDecimal totalAmount = paymentRecordMapper.sumDailyAmount(yesterday);// 2. 按车辆类型统计Map<VehicleType, BigDecimal> typeStats = paymentRecordMapper.sumByVehicleType(yesterday);// 3. 按支付方式统计Map<PaymentType, BigDecimal> paymentStats = paymentRecordMapper.sumByPaymentType(yesterday);// 4. 保存统计数据FeeStatistics statistics = new FeeStatistics();statistics.setStatisticsDate(yesterday);statistics.setTotalAmount(totalAmount);statistics.setTemporaryAmount(typeStats.get(VehicleType.TEMPORARY));statistics.setMonthlyAmount(typeStats.get(VehicleType.MONTHLY));statistics.setPaymentTypeStats(JSON.toJSONString(paymentStats));statisticsMapper.insert(statistics);}public StatisticsResponse getStatistics(StatisticsRequest request) {// 1. 构建查询条件QueryWrapper<FeeStatistics> wrapper = new QueryWrapper<>();wrapper.between("statistics_date", request.getStartDate(), request.getEndDate());// 2. 查询统计数据List<FeeStatistics> statisticsList = statisticsMapper.selectList(wrapper);// 3. 汇总数据return aggregateStatistics(statisticsList);}
}

二、系统管理模块

1. 用户权限管理

1.1 数据模型

-- 用户表
CREATE TABLE sys_user (id BIGINT PRIMARY KEY AUTO_INCREMENT,username VARCHAR(50) NOT NULL UNIQUE,password VARCHAR(100) NOT NULL,real_name VARCHAR(50),phone VARCHAR(20),email VARCHAR(100),status TINYINT COMMENT '状态：1-正常 2-禁用',last_login_time DATETIME,create_time DATETIME,update_time DATETIME
);-- 角色表
CREATE TABLE sys_role (id BIGINT PRIMARY KEY AUTO_INCREMENT,role_name VARCHAR(50) NOT NULL,role_code VARCHAR(50) NOT NULL,description VARCHAR(200),status TINYINT,create_time DATETIME
);-- 权限表
CREATE TABLE sys_permission (id BIGINT PRIMARY KEY AUTO_INCREMENT,permission_name VARCHAR(50),permission_code VARCHAR(50),type TINYINT COMMENT '类型：1-菜单 2-按钮',parent_id BIGINT,path VARCHAR(200),component VARCHAR(100),icon VARCHAR(50),sort_order INT
);-- 用户角色关联表
CREATE TABLE sys_user_role (user_id BIGINT,role_id BIGINT,PRIMARY KEY (user_id, role_id)
);-- 角色权限关联表
CREATE TABLE sys_role_permission (role_id BIGINT,permission_id BIGINT,PRIMARY KEY (role_id, permission_id)
);

1.2 权限服务实现

@Service
public class UserPermissionService {@Autowiredprivate SysUserMapper userMapper;@Autowiredprivate SysRoleMapper roleMapper;@Autowiredprivate SysPermissionMapper permissionMapper;@Cacheable(value = "userPermissions", key = "#userId")public Set<String> getUserPermissions(Long userId) {// 1. 获取用户角色List<SysRole> roles = roleMapper.findByUserId(userId);// 2. 获取角色对应的权限Set<String> permissions = new HashSet<>();for (SysRole role : roles) {List<SysPermission> rolePerms = permissionMapper.findByRoleId(role.getId());rolePerms.forEach(perm -> permissions.add(perm.getPermissionCode()));}return permissions;}@Transactional(rollbackFor = Exception.class)public void assignUserRoles(Long userId, List<Long> roleIds) {// 1. 删除原有角色userRoleMapper.deleteByUserId(userId);// 2. 添加新角色if (!CollectionUtils.isEmpty(roleIds)) {userRoleMapper.batchInsert(userId, roleIds);}// 3. 清除缓存redisTemplate.delete("userPermissions::" + userId);}
}

2. 系统参数配置

2.1 数据模型

-- 系统参数表
CREATE TABLE sys_config (id BIGINT PRIMARY KEY AUTO_INCREMENT,param_key VARCHAR(50) NOT NULL UNIQUE,param_value VARCHAR(500),param_type TINYINT COMMENT '参数类型：1-系统参数 2-业务参数',description VARCHAR(200),create_time DATETIME,update_time DATETIME
);

2.2 参数配置服务

@Service
public class SystemConfigService {@Autowiredprivate SysConfigMapper configMapper;@Autowiredprivate RedisTemplate redisTemplate;@PostConstructpublic void init() {// 系统启动时加载所有配置到缓存List<SysConfig> configs = configMapper.selectList(null);for (SysConfig config : configs) {redisTemplate.opsForValue().set(getConfigRedisKey(config.getParamKey()),config.getParamValue());}}public String getConfigValue(String key) {String redisKey = getConfigRedisKey(key);String value = (String) redisTemplate.opsForValue().get(redisKey);if (value == null) {// 从数据库加载SysConfig config = configMapper.selectByKey(key);if (config != null) {value = config.getParamValue();redisTemplate.opsForValue().set(redisKey, value);}}return value;}@Transactional(rollbackFor = Exception.class)public void updateConfig(String key, String value) {// 1. 更新数据库SysConfig config = configMapper.selectByKey(key);config.setParamValue(value);config.setUpdateTime(LocalDateTime.now());configMapper.updateById(config);// 2. 更新缓存redisTemplate.opsForValue().set(getConfigRedisKey(key), value);}private String getConfigRedisKey(String key) {return "system:config:" + key;}
}

3. 操作日志

3.1 数据模型

-- 操作日志表
CREATE TABLE sys_operation_log (id BIGINT PRIMARY KEY AUTO_INCREMENT,user_id BIGINT COMMENT '操作人ID',username VARCHAR(50) COMMENT '操作人用户名',module VARCHAR(50) COMMENT '操作模块',operation VARCHAR(50) COMMENT '操作类型',method VARCHAR(100) COMMENT '方法名',params TEXT COMMENT '请求参数',ip VARCHAR(50) COMMENT '操作IP',status TINYINT COMMENT '操作状态：1-成功 2-失败',error_msg TEXT COMMENT '错误信息',operation_time DATETIME COMMENT '操作时间'
);

3.2 日志服务实现

@Aspect
@Component
public class OperationLogAspect {@Autowiredprivate SysOperationLogMapper logMapper;@Around("@annotation(operationLog)")public Object around(ProceedingJoinPoint point, OperationLog operationLog) throws Throwable {// 1. 准备日志记录SysOperationLog log = new SysOperationLog();log.setModule(operationLog.module());log.setOperation(operationLog.operation());log.setMethod(point.getSignature().getName());log.setParams(JSON.toJSONString(point.getArgs()));log.setOperationTime(LocalDateTime.now());// 2. 获取当前用户信息UserDetails user = SecurityUtils.getCurrentUser();log.setUserId(user.getId());log.setUsername(user.getUsername());// 3. 获取请求IPHttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();log.setIp(getIpAddress(request));try {// 4. 执行目标方法Object result = point.proceed();log.setStatus(OperationStatus.SUCCESS.getCode());return result;} catch (Exception e) {// 5. 记录异常信息log.setStatus(OperationStatus.FAIL.getCode());log.setErrorMsg(e.getMessage());throw e;} finally {// 6. 保存日志logMapper.insert(log);}}
}

4. 数据备份

4.1 备份服务实现

@Service
public class DatabaseBackupService {@Value("${backup.path}")private String backupPath;@Autowiredprivate DataSource dataSource;@Scheduled(cron = "0 0 2 * * ?") // 每天凌晨2点执行备份public void performBackup() {String timestamp = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"));String backupFile = backupPath + "/backup_" + timestamp + ".sql";try {// 1. 创建备份目录File dir = new File(backupPath);if (!dir.exists()) {dir.mkdirs();}// 2. 执行备份命令Process process = Runtime.getRuntime().exec(String.format("mysqldump -u%s -p%s %s > %s",username, password, database, backupFile));// 3. 等待备份完成int exitCode = process.waitFor();if (exitCode == 0) {// 4. 压缩备份文件compressBackup(backupFile);// 5. 删除超过30天的备份cleanOldBackups();log.info("数据库备份成功：{}", backupFile);} else {log.error("数据库备份失败");}} catch (Exception e) {log.error("执行数据库备份时发生错误", e);// 发送告警通知alertService.sendAlert("数据库备份失败：" + e.getMessage());}}private void compressBackup(String backupFile) throws IOException {String zipFile = backupFile + ".zip";try (ZipOutputStream zos = new ZipOutputStream(new FileOutputStream(zipFile))) {File file = new File(backupFile);try (FileInputStream fis = new FileInputStream(file)) {ZipEntry entry = new ZipEntry(file.getName());zos.putNextEntry(entry);byte[] buffer = new byte[1024];int len;while ((len = fis.read(buffer)) > 0) {zos.write(buffer, 0, len);}}}// 删除原始备份文件new File(backupFile).delete();}private void cleanOldBackups() {File dir = new File(backupPath);if (dir.exists() && dir.isDirectory()) {File[] files = dir.listFiles((d, name) -> name.startsWith("backup_"));if (files != null) {LocalDateTime thirtyDaysAgo = LocalDateTime.now().minusDays(30);for (File file : files) {try {String timestamp = file.getName().substring(7, 21);LocalDateTime backupTime = LocalDateTime.parse(timestamp, DateTimeFormatter.ofPattern("yyyyMMddHHmmss"));if (backupTime.isBefore(thirtyDaysAgo)) {file.delete();}} catch (Exception e) {log.error("清理旧备份文件时发生错误", e);}}}}}
}