Author SHA1 Message Date
liwentao cacc8997ec 移除流程中的支付相关和会员卡相关 2026-07-14 18:49:15 +08:00
liwentao 593f6f13e7 新增数据统计页面 2026-07-10 13:56:16 +08:00
liwentao 8ee326b43a 修补缺失文件 2026-07-09 15:34:50 +08:00
liwentao 8fb4e714d8 新增会员卡管理 2026-07-09 15:33:05 +08:00
liwentao a8e69e0850 新增会员管理 2026-07-09 14:45:45 +08:00
liwentao f5b5724e92 完善团课相关管理 2026-07-08 17:02:04 +08:00
liwentao 1e41f31271 更新后台管理系统,实现团课管理基础显示 2026-07-06 16:44:27 +08:00
63 changed files with 4909 additions and 818 deletions
@@ -52,32 +52,24 @@ public class CheckServiceImpl implements ICheckInService {
@Override
public Mono<QRCodeVo> getQRCode(Long memberId) {
log.info("开始查询会员信息, memberId: {}", memberId);
log.info("开始生成会员签到二维码, memberId: {}", memberId);
return findValidMemberCard(memberId)
.flatMap(cardRecord -> {
log.info("会员信息查询完成, memberCardRecordId: {}", cardRecord.getMemberCardRecordId());
log.info("开始生成二维码");
String qrContent = QRRedisKey.generateQrcodeContent();
Map<String, Object> redisMap = new HashMap<>();
redisMap.put("qrContent", qrContent);
redisMap.put("isUsed", false);
redisMap.put("memberId", memberId);
redisMap.put("memberCardRecordId", cardRecord.getMemberCardRecordId());
String qrContent = QRRedisKey.generateQrcodeContent();
Map<String, Object> redisMap = new HashMap<>();
redisMap.put("qrContent", qrContent);
redisMap.put("isUsed", false);
redisMap.put("memberId", memberId);
return redisUtil.setWithExpire(
RedisKeyConstants.QRCODE_USER_DAILY + memberId + LocalDate.now(),
redisMap,
getSecondsUntilEndOfDay()
)
.then(Mono.fromSupplier(() -> {
String qrCodeBase64 = QrCodeUtil.generateAsBase64(qrContent,
BeanUtil.copyProperties(qrCodeConfig, QrConfig.class), "png");
return new QRCodeVo(qrCodeBase64, false, qrContent, qrCodeConfig.getWidth(), qrCodeConfig.getHeight(), LocalDate.now());
}));
})
.switchIfEmpty(Mono.error(new RuntimeException("该会员没有可用的会员卡")));
return redisUtil.setWithExpire(
RedisKeyConstants.QRCODE_USER_DAILY + memberId + LocalDate.now(),
redisMap,
getSecondsUntilEndOfDay()
)
.then(Mono.fromSupplier(() -> {
String qrCodeBase64 = QrCodeUtil.generateAsBase64(qrContent,
BeanUtil.copyProperties(qrCodeConfig, QrConfig.class), "png");
return new QRCodeVo(qrCodeBase64, false, qrContent, qrCodeConfig.getWidth(), qrCodeConfig.getHeight(), LocalDate.now());
}));
}
@Override
@@ -113,9 +105,10 @@ public class CheckServiceImpl implements ICheckInService {
}
log.info("二维码匹配成功,memberId: {}", memberId);
Long memberCardRecordId = ((Number) map.get("memberCardRecordId")).longValue();
Long memberCardRecordId = map.get("memberCardRecordId") != null
? ((Number) map.get("memberCardRecordId")).longValue() : null;
return processCheckIn(memberId, memberCardRecordId, map, qrContent);
return processCheckIn(memberId, memberCardRecordId, map, qrContent);
} else {
MyWebSocketHandler.sendFailure(qrContent, "二维码无效");
return Mono.error(new RuntimeException("二维码无效"));
@@ -145,54 +138,23 @@ public class CheckServiceImpl implements ICheckInService {
LocalDateTime now = LocalDateTime.now();
// 发送实时进度通知
MyWebSocketHandler.sendProgress(qrContent, "VALIDATE_CARD", "正在验证会员卡...");
return memberCardRecordRepository.findById(memberCardRecordId)
.switchIfEmpty(Mono.defer(() -> {
MyWebSocketHandler.sendFailure(qrContent, "会员卡记录不存在");
return Mono.error(new RuntimeException("会员卡记录不存在"));
}))
.flatMap(cardRecord -> {
if (!"ACTIVE".equals(cardRecord.getStatus().name())) {
MyWebSocketHandler.sendFailure(qrContent, "会员卡状态不正确");
return Mono.error(new RuntimeException("会员卡状态不正确"));
}
MyWebSocketHandler.sendProgress(qrContent, "VALIDATE_BOOKING", "正在检查预约信息...");
// 检查是否有需要签到的团课预约
return validateBooking(memberId, now)
.then(Mono.defer(() -> {
redisMap.put("isUsed", true);
redisMap.put("checkInTime", now.format(DATE_FORMATTER));
if (cardRecord.getExpireTime() != null && cardRecord.getExpireTime().isBefore(now)) {
MyWebSocketHandler.sendFailure(qrContent, "会员卡已过期");
return Mono.error(new RuntimeException("会员卡已过期"));
}
// 发送实时进度通知
MyWebSocketHandler.sendProgress(qrContent, "VALIDATE_BOOKING", "会员卡验证通过,正在检查预约信息...");
// 检查是否有需要签到的团课预约
return validateBooking(memberId, now)
.then(memberCardRepository.findByMemberCardIdAndDeletedAtIsNull(cardRecord.getMemberCardId())
.switchIfEmpty(Mono.defer(() -> {
MyWebSocketHandler.sendFailure(qrContent, "会员卡类型不存在");
return Mono.error(new RuntimeException("会员卡类型不存在"));
}))
.flatMap(card -> {
// 发送实时进度通知
MyWebSocketHandler.sendProgress(qrContent, "DEDUCT_USAGE", "正在扣减会员卡次数...");
return deductCardUsage(cardRecord, card)
.flatMap(updatedRecord -> {
redisMap.put("isUsed", true);
redisMap.put("checkInTime", now.format(DATE_FORMATTER));
return saveSignInRecord(memberId, cardRecord.getMemberCardRecordId(), card.getMemberCardId())
.then(redisUtil.set(RedisKeyConstants.QRCODE_USER_DAILY + memberId + LocalDate.now(), redisMap))
.then(Mono.defer(() -> {
String successMsg = buildSuccessResponse(now);
MyWebSocketHandler.sendSuccess(qrContent, memberId, now.format(DATE_FORMATTER));
log.info("签到成功, memberId: {}, cardRecordId: {}", memberId, memberCardRecordId);
return Mono.just(successMsg);
}));
});
}));
});
return saveSignInRecord(memberId, null, null)
.then(redisUtil.set(RedisKeyConstants.QRCODE_USER_DAILY + memberId + LocalDate.now(), redisMap))
.then(Mono.defer(() -> {
String successMsg = buildSuccessResponse(now);
MyWebSocketHandler.sendSuccess(qrContent, memberId, now.format(DATE_FORMATTER));
log.info("签到成功, memberId: {}", memberId);
return Mono.just(successMsg);
}));
}));
}
/**
+6 -1
View File
@@ -67,7 +67,12 @@
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>5.2.5</version>
</dependency>
<!-- Fix commons-compress version for POI compatibility -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-compress</artifactId>
</dependency>
<!-- Gym Modules -->
@@ -59,6 +59,12 @@ public class DataStatistics {
public static final String WEEK = "WEEK";
/** 月统计 */
public static final String MONTH = "MONTH";
/** 近30天 */
public static final String LAST_30_DAYS = "LAST_30_DAYS";
/** 近90天 */
public static final String LAST_90_DAYS = "LAST_90_DAYS";
/** 今年 */
public static final String YEAR = "YEAR";
private PeriodType() {}
}
@@ -458,13 +458,16 @@ public class DataStatisticsServiceImpl implements IDataStatisticsService {
String periodType = query.getPeriodType();
if (DataStatistics.PeriodType.WEEK.equals(periodType)) {
// 周统计:本周一
return today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY)).atStartOfDay();
} else if (DataStatistics.PeriodType.MONTH.equals(periodType)) {
// 月统计:本月第一天
return today.withDayOfMonth(1).atStartOfDay();
} else if (DataStatistics.PeriodType.LAST_30_DAYS.equals(periodType)) {
return today.minusDays(29).atStartOfDay();
} else if (DataStatistics.PeriodType.LAST_90_DAYS.equals(periodType)) {
return today.minusDays(89).atStartOfDay();
} else if (DataStatistics.PeriodType.YEAR.equals(periodType)) {
return today.withDayOfYear(1).atStartOfDay();
} else {
// 日统计:当天零点
return today.atStartOfDay();
}
}
@@ -478,13 +481,14 @@ public class DataStatisticsServiceImpl implements IDataStatisticsService {
String periodType = query.getPeriodType();
if (DataStatistics.PeriodType.WEEK.equals(periodType)) {
// 周统计:本周日 23:59:59
return today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY)).atTime(23, 59, 59);
} else if (DataStatistics.PeriodType.MONTH.equals(periodType)) {
// 月统计:本月最后一天 23:59:59
return today.with(TemporalAdjusters.lastDayOfMonth()).atTime(23, 59, 59);
} else if (DataStatistics.PeriodType.LAST_30_DAYS.equals(periodType)
|| DataStatistics.PeriodType.LAST_90_DAYS.equals(periodType)
|| DataStatistics.PeriodType.YEAR.equals(periodType)) {
return LocalDateTime.now();
} else {
// 日统计:当前时间
return LocalDateTime.now();
}
}
@@ -503,6 +507,15 @@ public class DataStatisticsServiceImpl implements IDataStatisticsService {
} else if (DataStatistics.PeriodType.MONTH.equals(periodType)) {
startTime = date.withDayOfMonth(1).atStartOfDay();
endTime = date.with(TemporalAdjusters.lastDayOfMonth()).atTime(23, 59, 59);
} else if (DataStatistics.PeriodType.LAST_30_DAYS.equals(periodType)) {
startTime = date.minusDays(29).atStartOfDay();
endTime = date.atTime(23, 59, 59);
} else if (DataStatistics.PeriodType.LAST_90_DAYS.equals(periodType)) {
startTime = date.minusDays(89).atStartOfDay();
endTime = date.atTime(23, 59, 59);
} else if (DataStatistics.PeriodType.YEAR.equals(periodType)) {
startTime = date.withDayOfYear(1).atStartOfDay();
endTime = date.atTime(23, 59, 59);
} else {
startTime = date.atStartOfDay();
endTime = date.plusDays(1).atStartOfDay();
+9
View File
@@ -94,11 +94,20 @@
<version>3.5.3</version>
</dependency>
<!-- 阿里云OSS SDK -->
<!--
<dependency>
<groupId>com.aliyun.oss</groupId>
<artifactId>aliyun-sdk-oss</artifactId>
<version>3.17.4</version>
</dependency>
-->
<!-- 文件管理模块(统一文件存储) -->
<dependency>
<groupId>cn.novalon.gym.manage</groupId>
<artifactId>manage-file</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
<build>
@@ -1,5 +1,6 @@
package cn.novalon.gym.manage.groupcourse.dao;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.groupcourse.dto.GroupCourseQueryDto;
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseEntity;
import org.springframework.data.domain.Sort;
@@ -160,6 +161,7 @@ public interface GroupCourseDao extends R2dbcRepository<GroupCourseEntity, Long>
entity.setCoverImage(row.get("cover_image", String.class));
entity.setDescription(row.get("description", String.class));
entity.setStoredValueAmount(row.get("stored_value_amount", java.math.BigDecimal.class));
entity.setQrCodePath(row.get("qr_code_path", String.class));
entity.setCreateBy(row.get("create_by", String.class));
entity.setUpdateBy(row.get("update_by", String.class));
entity.setCreatedAt(row.get("created_at", LocalDateTime.class));
@@ -226,4 +228,99 @@ public interface GroupCourseDao extends R2dbcRepository<GroupCourseEntity, Long>
return spec.map((row, meta) -> row.get(0, Long.class)).one();
}
/**
* 分页查询团课(支持 keyword 和 status 过滤)
*/
default Flux<GroupCourseEntity> findByPageFiltered(DatabaseClient databaseClient, PageRequest pageRequest) {
StringBuilder sql = new StringBuilder("SELECT * FROM group_course WHERE deleted_at IS NULL");
List<String> conditions = new ArrayList<>();
if (pageRequest.getKeyword() != null && !pageRequest.getKeyword().isEmpty()) {
conditions.add("course_name ILIKE :keyword");
}
if (pageRequest.getStatus() != null && !pageRequest.getStatus().isEmpty()) {
conditions.add("status = :status");
}
if (!conditions.isEmpty()) {
sql.append(" AND ").append(String.join(" AND ", conditions));
}
String sort = pageRequest.getSort() != null ? pageRequest.getSort() : "id";
String order = "desc".equalsIgnoreCase(pageRequest.getOrder()) ? "DESC" : "ASC";
sql.append(" ORDER BY ").append(sort).append(" ").append(order);
int size = pageRequest.getSize();
if (size < 1) size = 10;
if (size > 100) size = 100;
int offset = pageRequest.getPage() * size;
sql.append(" LIMIT :limit OFFSET :offset");
DatabaseClient.GenericExecuteSpec spec = databaseClient.sql(sql.toString());
if (pageRequest.getKeyword() != null && !pageRequest.getKeyword().isEmpty()) {
spec = spec.bind("keyword", "%" + pageRequest.getKeyword() + "%");
}
if (pageRequest.getStatus() != null && !pageRequest.getStatus().isEmpty()) {
spec = spec.bind("status", pageRequest.getStatus());
}
spec = spec.bind("limit", size);
spec = spec.bind("offset", offset);
return spec.map((row, meta) -> {
GroupCourseEntity entity = new GroupCourseEntity();
entity.setId(row.get("id", Long.class));
entity.setCourseName(row.get("course_name", String.class));
entity.setCoachId(row.get("coach_id", Long.class));
entity.setCourseType(row.get("course_type", Long.class));
entity.setStartTime(row.get("start_time", LocalDateTime.class));
entity.setEndTime(row.get("end_time", LocalDateTime.class));
entity.setMaxMembers(row.get("max_members", Integer.class));
entity.setCurrentMembers(row.get("current_members", Integer.class));
String statusStr = row.get("status", String.class);
entity.setStatus(statusStr != null ? Long.parseLong(statusStr) : null);
entity.setLocation(row.get("location", String.class));
entity.setCoverImage(row.get("cover_image", String.class));
entity.setDescription(row.get("description", String.class));
entity.setStoredValueAmount(row.get("stored_value_amount", java.math.BigDecimal.class));
entity.setQrCodePath(row.get("qr_code_path", String.class));
entity.setCreateBy(row.get("create_by", String.class));
entity.setUpdateBy(row.get("update_by", String.class));
entity.setCreatedAt(row.get("created_at", LocalDateTime.class));
entity.setUpdatedAt(row.get("updated_at", LocalDateTime.class));
entity.setDeletedAt(row.get("deleted_at", LocalDateTime.class));
return entity;
}).all();
}
/**
* 分页查询团课总数(支持 keyword 和 status 过滤)
*/
default Mono<Long> countByPageFiltered(DatabaseClient databaseClient, PageRequest pageRequest) {
StringBuilder sql = new StringBuilder("SELECT COUNT(*) FROM group_course WHERE deleted_at IS NULL");
List<String> conditions = new ArrayList<>();
if (pageRequest.getKeyword() != null && !pageRequest.getKeyword().isEmpty()) {
conditions.add("course_name ILIKE :keyword");
}
if (pageRequest.getStatus() != null && !pageRequest.getStatus().isEmpty()) {
conditions.add("status = :status");
}
if (!conditions.isEmpty()) {
sql.append(" AND ").append(String.join(" AND ", conditions));
}
DatabaseClient.GenericExecuteSpec spec = databaseClient.sql(sql.toString());
if (pageRequest.getKeyword() != null && !pageRequest.getKeyword().isEmpty()) {
spec = spec.bind("keyword", "%" + pageRequest.getKeyword() + "%");
}
if (pageRequest.getStatus() != null && !pageRequest.getStatus().isEmpty()) {
spec = spec.bind("status", pageRequest.getStatus());
}
return spec.map((row, meta) -> row.get(0, Long.class)).one();
}
}
@@ -1,5 +1,6 @@
package cn.novalon.gym.manage.groupcourse.handler;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
import cn.novalon.gym.manage.groupcourse.service.ICourseLabelService;
import io.swagger.v3.oas.annotations.Operation;
@@ -29,6 +30,13 @@ public class CourseLabelHandler {
.body(courseLabelService.findAll(), CourseLabel.class);
}
@Operation(summary = "分页查询标签", description = "支持按关键词筛选并分页查询标签")
public Mono<ServerResponse> getLabelsByPage(ServerRequest request) {
return request.bodyToMono(PageRequest.class)
.flatMap(pageRequest -> courseLabelService.findByPage(pageRequest)
.flatMap(response -> ServerResponse.ok().bodyValue(response)));
}
@Operation(summary = "根据ID获取标签", description = "根据ID获取标签详情")
public Mono<ServerResponse> getLabelById(ServerRequest request) {
Long id = Long.valueOf(request.pathVariable("id"));
@@ -147,17 +155,17 @@ public class CourseLabelHandler {
return request.bodyToMono(Map.class)
.flatMap(body -> {
@SuppressWarnings("unchecked")
List<Integer> labelIdsInt = (List<Integer>) body.get("labelIds");
if (labelIdsInt == null || labelIdsInt.isEmpty()) {
List<?> rawIds = (List<?>) body.get("labelIds");
if (rawIds == null || rawIds.isEmpty()) {
Map<String, Object> error = new HashMap<>();
error.put("success", false);
error.put("message", "labelIds不能为空");
return ServerResponse.badRequest().bodyValue(error);
}
List<Long> labelIds = labelIdsInt.stream()
.map(Integer::longValue)
List<Long> labelIds = rawIds.stream()
.map(id -> Long.valueOf(String.valueOf(id)))
.collect(java.util.stream.Collectors.toList());
return courseLabelService.addLabelsToType(typeId, labelIds)
@@ -2,7 +2,6 @@ package cn.novalon.gym.manage.groupcourse.handler;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseBooking;
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseBookingService;
import cn.novalon.gym.manage.member.service.IMemberStoredCardService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.stereotype.Component;
@@ -24,12 +23,9 @@ import java.util.Map;
public class GroupCourseBookingHandler {
private final IGroupCourseBookingService bookingService;
private final IMemberStoredCardService memberStoredCardService;
public GroupCourseBookingHandler(IGroupCourseBookingService bookingService,
IMemberStoredCardService memberStoredCardService) {
public GroupCourseBookingHandler(IGroupCourseBookingService bookingService) {
this.bookingService = bookingService;
this.memberStoredCardService = memberStoredCardService;
}
/**
@@ -46,38 +42,23 @@ public class GroupCourseBookingHandler {
if (body.get("memberId") == null) {
return buildErrorResponse("请提供会员ID");
}
if (body.get("memberCardRecordId") == null) {
return buildErrorResponse("请提供会员卡记录ID");
}
if (body.get("payPassword") == null || body.get("payPassword").toString().isEmpty()) {
return buildErrorResponse("请输入支付密码");
}
Long courseId = toLong(body.get("courseId"), "courseId");
Long memberId = toLong(body.get("memberId"), "memberId");
Long memberCardRecordId = toLong(body.get("memberCardRecordId"), "memberCardRecordId");
String payPassword = body.get("payPassword").toString();
// 验证支付密码
return memberStoredCardService.verifyPayPassword(memberId, payPassword)
.flatMap(passwordValid -> {
if (!passwordValid) {
return buildErrorResponse("支付密码错误");
}
return bookingService.bookCourse(courseId, memberId, memberCardRecordId)
.flatMap(booking -> {
Map<String, Object> response = new HashMap<>();
response.put("success", true);
response.put("message", "预约成功");
response.put("data", booking);
return ServerResponse.ok().bodyValue(response);
})
.onErrorResume(error -> {
Map<String, Object> response = new HashMap<>();
response.put("success", false);
response.put("message", error.getMessage());
return ServerResponse.badRequest().bodyValue(response);
});
return bookingService.bookCourse(courseId, memberId)
.flatMap(booking -> {
Map<String, Object> response = new HashMap<>();
response.put("success", true);
response.put("message", "预约成功");
response.put("data", booking);
return ServerResponse.ok().bodyValue(response);
})
.onErrorResume(error -> {
Map<String, Object> response = new HashMap<>();
response.put("success", false);
response.put("message", error.getMessage());
return ServerResponse.badRequest().bodyValue(response);
});
});
}
@@ -92,31 +73,20 @@ public class GroupCourseBookingHandler {
return request.bodyToMono(Map.class)
.flatMap(body -> {
Long memberId = toLong(body.get("memberId"), "memberId");
if (body.get("payPassword") == null || body.get("payPassword").toString().isEmpty()) {
return buildErrorResponse("请输入支付密码");
}
String payPassword = body.get("payPassword").toString();
// 验证支付密码
return memberStoredCardService.verifyPayPassword(memberId, payPassword)
.flatMap(passwordValid -> {
if (!passwordValid) {
return buildErrorResponse("支付密码错误");
}
return bookingService.cancelBooking(bookingId, memberId)
.flatMap(booking -> {
Map<String, Object> response = new HashMap<>();
response.put("success", true);
response.put("message", "取消成功");
response.put("data", booking);
return ServerResponse.ok().bodyValue(response);
})
.onErrorResume(error -> {
Map<String, Object> response = new HashMap<>();
response.put("success", false);
response.put("message", error.getMessage());
return ServerResponse.badRequest().bodyValue(response);
});
return bookingService.cancelBooking(bookingId, memberId)
.flatMap(booking -> {
Map<String, Object> response = new HashMap<>();
response.put("success", true);
response.put("message", "取消成功");
response.put("data", booking);
return ServerResponse.ok().bodyValue(response);
})
.onErrorResume(error -> {
Map<String, Object> response = new HashMap<>();
response.put("success", false);
response.put("message", error.getMessage());
return ServerResponse.badRequest().bodyValue(response);
});
});
}
@@ -1,5 +1,6 @@
package cn.novalon.gym.manage.groupcourse.handler;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseTypeService;
import io.swagger.v3.oas.annotations.Operation;
@@ -134,4 +135,12 @@ public class GroupCourseTypeHandler {
return ServerResponse.badRequest().bodyValue(response);
});
}
@Operation(summary = "分页查询团课类型", description = "支持按关键词、分类筛选并分页查询团课类型")
public Mono<ServerResponse> getGroupCourseTypesByPage(ServerRequest request) {
return request.bodyToMono(PageRequest.class)
.flatMap(pageRequest -> groupCourseTypeService.findByPage(pageRequest)
.flatMap(response -> ServerResponse.ok().bodyValue(response))
);
}
}
@@ -1,5 +1,6 @@
package cn.novalon.gym.manage.groupcourse.initializer;
import cn.novalon.gym.manage.file.core.service.ISysFileService;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
import cn.novalon.gym.manage.groupcourse.util.QRCodeUtil;
@@ -10,15 +11,12 @@ import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Mono;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;
/**
* 项目启动时补全缺失的团课二维码
* 遍历所有未删除的团课,对qrCodePath为空的课程生成二维码并上传至阿里云OSS
* 遍历所有未删除的团课,对qrCodePath为空的课程生成二维码并通过统一文件服务保存
*/
@Component
public class QrCodeInitializer implements CommandLineRunner {
@@ -27,11 +25,14 @@ public class QrCodeInitializer implements CommandLineRunner {
private final IGroupCourseRepository groupCourseRepository;
private final ObjectMapper objectMapper;
private final ISysFileService fileService;
public QrCodeInitializer(IGroupCourseRepository groupCourseRepository,
ObjectMapper objectMapper) {
ObjectMapper objectMapper,
ISysFileService fileService) {
this.groupCourseRepository = groupCourseRepository;
this.objectMapper = objectMapper;
this.fileService = fileService;
}
@Override
@@ -58,20 +59,22 @@ public class QrCodeInitializer implements CommandLineRunner {
String jsonContent = objectMapper.writeValueAsString(qrCodeContent);
// 生成二维码并上传到阿里云OSS
String uuid = UUID.randomUUID().toString().replace("-", "");
String timestamp = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"));
String fileName = "qr_" + uuid + "_" + timestamp + ".png";
String ossUrl = QRCodeUtil.generateQRCodeAndUploadToOSS(jsonContent, fileName);
course.setQrCodePath(ossUrl);
// 更新数据库
return groupCourseRepository.update(course)
.doOnSuccess(updated -> logger.info("团课二维码补全成功 - id={}, name={}, ossUrl={}",
updated.getId(), updated.getCourseName(), ossUrl))
.doOnError(error -> logger.error("团课二维码补全失败(更新DB) - id={}, name={}, error: {}",
course.getId(), course.getCourseName(), error.getMessage()));
// 生成二维码字节数组,通过统一文件服务保存
return Mono.fromCallable(() -> QRCodeUtil.generateQrCodeBytes(jsonContent))
.flatMap(qrCodeBytes -> {
String fileName = "qrcode_" + course.getId() + ".png";
return fileService.saveBytes(qrCodeBytes, fileName, "image/png", "system");
})
.flatMap(sysFile -> {
String qrCodeUrl = "/api/files/" + sysFile.getId() + "/preview";
course.setQrCodePath(qrCodeUrl);
return groupCourseRepository.update(course)
.doOnSuccess(updated -> logger.info("团课二维码补全成功 - id={}, name={}, url={}",
updated.getId(), updated.getCourseName(), qrCodeUrl))
.doOnError(error -> logger.error("团课二维码补全失败(更新DB) - id={}, name={}, error: {}",
course.getId(), course.getCourseName(), error.getMessage()));
});
} catch (Exception e) {
logger.error("团课二维码补全失败(生成) - id={}, name={}, error: {}",
course.getId(), course.getCourseName(), e.getMessage(), e);
@@ -1,5 +1,7 @@
package cn.novalon.gym.manage.groupcourse.repository;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.common.dto.PageResponse;
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -29,4 +31,6 @@ public interface ICourseLabelRepository {
Mono<Void> removeLabelFromType(Long typeId, Long labelId);
Mono<Void> clearLabelsFromType(Long typeId);
Mono<PageResponse<CourseLabel>> findByPage(PageRequest pageRequest);
}
@@ -1,5 +1,7 @@
package cn.novalon.gym.manage.groupcourse.repository;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.common.dto.PageResponse;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -25,4 +27,6 @@ public interface IGroupCourseTypeRepository {
Mono<GroupCourseType> update(GroupCourseType groupCourseType);
Mono<Void> deleteById(Long id);
Mono<PageResponse<GroupCourseType>> findByPage(PageRequest pageRequest);
}
@@ -1,5 +1,7 @@
package cn.novalon.gym.manage.groupcourse.repository.impl;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.common.dto.PageResponse;
import cn.novalon.gym.manage.groupcourse.converter.GroupCourseConverter;
import cn.novalon.gym.manage.groupcourse.dao.CourseLabelDao;
import cn.novalon.gym.manage.groupcourse.dao.CourseTypeLabelDao;
@@ -9,12 +11,17 @@ import cn.novalon.gym.manage.groupcourse.entity.CourseTypeLabelEntity;
import cn.novalon.gym.manage.groupcourse.repository.ICourseLabelRepository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.domain.Sort;
import org.springframework.data.r2dbc.core.R2dbcEntityTemplate;
import org.springframework.data.relational.core.query.Criteria;
import org.springframework.data.relational.core.query.Query;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
@Repository
@@ -26,12 +33,14 @@ public class CourseLabelRepository implements ICourseLabelRepository {
private final CourseLabelDao courseLabelDao;
private final CourseTypeLabelDao courseTypeLabelDao;
private final GroupCourseConverter converter;
private final R2dbcEntityTemplate r2dbcEntityTemplate;
public CourseLabelRepository(CourseLabelDao courseLabelDao, CourseTypeLabelDao courseTypeLabelDao,
GroupCourseConverter converter) {
GroupCourseConverter converter, R2dbcEntityTemplate r2dbcEntityTemplate) {
this.courseLabelDao = courseLabelDao;
this.courseTypeLabelDao = courseTypeLabelDao;
this.converter = converter;
this.r2dbcEntityTemplate = r2dbcEntityTemplate;
}
@Override
@@ -158,4 +167,41 @@ public class CourseLabelRepository implements ICourseLabelRepository {
}
return entity;
}
@Override
public Mono<PageResponse<CourseLabel>> findByPage(PageRequest pageRequest) {
int page = pageRequest.getPage();
int size = pageRequest.getSize();
String sort = pageRequest.getSort();
String order = pageRequest.getOrder();
String keyword = pageRequest.getKeyword();
Sort sortObj = Sort.unsorted();
if (sort != null && !sort.isEmpty()) {
sortObj = Sort.by(Sort.Direction.fromString(order), sort);
}
List<Criteria> criteriaList = new ArrayList<>();
criteriaList.add(Criteria.where("deleted_at").isNull());
if (keyword != null && !keyword.isEmpty()) {
criteriaList.add(Criteria.where("label_name").like("%" + keyword + "%").ignoreCase(true));
}
Criteria criteria = criteriaList.isEmpty() ? Criteria.empty() : Criteria.from(criteriaList);
Query query = Query.query(criteria).with(org.springframework.data.domain.PageRequest.of(page, size, sortObj));
return r2dbcEntityTemplate.select(CourseLabelEntity.class)
.matching(query)
.all()
.collectList()
.zipWith(r2dbcEntityTemplate.count(Query.query(criteria), CourseLabelEntity.class))
.map(tuple -> {
long total = tuple.getT2();
int totalPages = (int) Math.ceil((double) total / size);
List<CourseLabel> list = tuple.getT1().stream()
.map(this::toCourseLabel)
.toList();
return new PageResponse<>(list, totalPages, total, page, size);
});
}
}
@@ -97,37 +97,19 @@ public class GroupCourseRepository implements IGroupCourseRepository {
public Mono<PageResponse<GroupCourse>> findByPageAndNotDeleted(PageRequest pageRequest) {
int page = pageRequest.getPage();
int size = pageRequest.getSize();
String sort = pageRequest.getSort();
String order = pageRequest.getOrder();
Sort sortObj = Sort.unsorted();
if (sort != null && !sort.isEmpty()) {
sortObj = Sort.by(Sort.Direction.fromString(order), sort);
}
org.springframework.data.domain.PageRequest pageable = org.springframework.data.domain.PageRequest.of(page, size, sortObj);
return groupCourseDao.findAllByDeletedAtIsNull(sortObj)
.collectList()
.zipWith(groupCourseDao.findAllByDeletedAtIsNull().count())
.map(tuple -> {
List<GroupCourseEntity> allEntities = tuple.getT1();
long total = tuple.getT2();
int fromIndex = page * size;
int toIndex = Math.min(fromIndex + size, allEntities.size());
List<GroupCourse> courseList;
if (fromIndex < allEntities.size()) {
courseList = allEntities.subList(fromIndex, toIndex).stream()
.map(groupCourseConverter::toDomain)
.toList();
} else {
courseList = List.of();
return groupCourseDao.countByPageFiltered(r2dbcEntityTemplate.getDatabaseClient(), pageRequest)
.flatMap(total -> {
if (total == 0) {
return Mono.just(new PageResponse<>(List.of(), 0, 0L, page, size));
}
int totalPages = (int) Math.ceil((double) total / size);
return new PageResponse<>(courseList, totalPages, total, page, size);
return groupCourseDao.findByPageFiltered(r2dbcEntityTemplate.getDatabaseClient(), pageRequest)
.map(groupCourseConverter::toDomain)
.collectList()
.map(courseList -> {
int totalPages = (int) Math.ceil((double) total / size);
return new PageResponse<>(courseList, totalPages, total, page, size);
});
});
}
@@ -1,5 +1,7 @@
package cn.novalon.gym.manage.groupcourse.repository.impl;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.common.dto.PageResponse;
import cn.novalon.gym.manage.groupcourse.converter.GroupCourseConverter;
import cn.novalon.gym.manage.groupcourse.dao.GroupCourseTypeDao;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
@@ -7,12 +9,18 @@ import cn.novalon.gym.manage.groupcourse.entity.GroupCourseTypeEntity;
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseTypeRepository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.domain.Sort;
import org.springframework.data.r2dbc.core.R2dbcEntityTemplate;
import org.springframework.data.relational.core.query.Criteria;
import org.springframework.data.relational.core.query.Query;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
@Repository
@Transactional
@@ -22,10 +30,13 @@ public class GroupCourseTypeRepository implements IGroupCourseTypeRepository {
private final GroupCourseTypeDao groupCourseTypeDao;
private final GroupCourseConverter converter;
private final R2dbcEntityTemplate r2dbcEntityTemplate;
public GroupCourseTypeRepository(GroupCourseTypeDao groupCourseTypeDao, GroupCourseConverter converter) {
public GroupCourseTypeRepository(GroupCourseTypeDao groupCourseTypeDao, GroupCourseConverter converter,
R2dbcEntityTemplate r2dbcEntityTemplate) {
this.groupCourseTypeDao = groupCourseTypeDao;
this.converter = converter;
this.r2dbcEntityTemplate = r2dbcEntityTemplate;
}
@Override
@@ -129,4 +140,46 @@ public class GroupCourseTypeRepository implements IGroupCourseTypeRepository {
return groupCourseTypeDao.softDelete(id, LocalDateTime.now())
.then();
}
@Override
public Mono<PageResponse<GroupCourseType>> findByPage(PageRequest pageRequest) {
int page = pageRequest.getPage();
int size = pageRequest.getSize();
String order = pageRequest.getOrder();
String sort = pageRequest.getSort();
String keyword = pageRequest.getKeyword();
String category = pageRequest.getCategory();
Sort sortObj = Sort.unsorted();
if (sort != null && !sort.isEmpty()) {
sortObj = Sort.by(Sort.Direction.fromString(order), sort);
}
// Build dynamic criteria
List<Criteria> criteriaList = new ArrayList<>();
criteriaList.add(Criteria.where("deleted_at").isNull());
if (keyword != null && !keyword.isEmpty()) {
criteriaList.add(Criteria.where("type_name").like("%" + keyword + "%").ignoreCase(true));
}
if (category != null && !category.isEmpty()) {
criteriaList.add(Criteria.where("category").is(category));
}
Criteria criteria = criteriaList.isEmpty() ? Criteria.empty() : Criteria.from(criteriaList);
Query query = Query.query(criteria).with(org.springframework.data.domain.PageRequest.of(page, size, sortObj));
return r2dbcEntityTemplate.select(GroupCourseTypeEntity.class)
.matching(query)
.all()
.collectList()
.zipWith(r2dbcEntityTemplate.count(Query.query(criteria), GroupCourseTypeEntity.class))
.map(tuple -> {
long total = tuple.getT2();
int totalPages = (int) Math.ceil((double) total / size);
List<GroupCourseType> list = tuple.getT1().stream()
.map(converter::toGroupCourseType)
.toList();
return new PageResponse<>(list, totalPages, total, page, size);
});
}
}
@@ -1,5 +1,7 @@
package cn.novalon.gym.manage.groupcourse.service;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.common.dto.PageResponse;
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -27,4 +29,6 @@ public interface ICourseLabelService {
Mono<Void> removeLabelFromType(Long typeId, Long labelId);
Mono<Void> clearLabelsFromType(Long typeId);
Mono<PageResponse<CourseLabel>> findByPage(PageRequest pageRequest);
}
@@ -17,10 +17,9 @@ public interface IGroupCourseBookingService {
*
* @param courseId 团课ID
* @param memberId 会员ID
* @param memberCardRecordId 会员卡记录ID
* @return 预约记录
*/
Mono<GroupCourseBooking> bookCourse(Long courseId, Long memberId, Long memberCardRecordId);
Mono<GroupCourseBooking> bookCourse(Long courseId, Long memberId);
/**
* 取消预约
@@ -1,5 +1,7 @@
package cn.novalon.gym.manage.groupcourse.service;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.common.dto.PageResponse;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -29,4 +31,6 @@ public interface IGroupCourseTypeService {
* @return 分类名称列表
*/
Flux<String> findCategories();
Mono<PageResponse<GroupCourseType>> findByPage(PageRequest pageRequest);
}
@@ -1,5 +1,7 @@
package cn.novalon.gym.manage.groupcourse.service.impl;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.common.dto.PageResponse;
import cn.novalon.gym.manage.common.util.RedisUtil;
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
@@ -109,4 +111,12 @@ public class CourseLabelService implements ICourseLabelService {
.doOnSuccess(v -> logger.info("清空类型标签成功 - typeId={}", typeId))
.doOnError(error -> logger.error("清空类型标签失败 - typeId={}, error: {}", typeId, error.getMessage()));
}
@Override
public Mono<PageResponse<CourseLabel>> findByPage(PageRequest pageRequest) {
return courseLabelRepository.findByPage(pageRequest)
.doOnSuccess(result -> logger.info("分页查询标签成功 - page={}, size={}, total={}",
pageRequest.getPage(), pageRequest.getSize(), result.getTotalElements()))
.doOnError(error -> logger.error("分页查询标签失败 - error: {}", error.getMessage()));
}
}
@@ -3,7 +3,6 @@ package cn.novalon.gym.manage.groupcourse.service.impl;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseBooking;
import cn.novalon.gym.manage.groupcourse.event.BookingReminderEventPublisher;
import cn.novalon.gym.manage.groupcourse.handler.BookingSagaHandler;
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseBookingRepository;
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseBookingService;
@@ -13,7 +12,6 @@ import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.temporal.ChronoUnit;
import java.util.UUID;
@@ -26,7 +24,6 @@ import java.util.UUID;
* - 取消预约需在课程开始前至少2小时
* - 每节课最多20人
* - 预约成功后发送提醒
* - 预约成功后扣减权益
*
* 技术要点:
* - 使用Redis缓存团课信息
@@ -45,7 +42,6 @@ public class GroupCourseBookingService implements IGroupCourseBookingService {
private final IGroupCourseRepository courseRepository;
private final GroupCourseRedisService redisService;
private final BookingReminderEventPublisher bookingReminderEventPublisher;
private final BookingSagaHandler bookingSagaHandler;
// 预约提前时间限制(分钟)
private static final long BOOKING_MIN_ADVANCE_MINUTES = 30;
@@ -55,18 +51,16 @@ public class GroupCourseBookingService implements IGroupCourseBookingService {
public GroupCourseBookingService(IGroupCourseBookingRepository bookingRepository,
IGroupCourseRepository courseRepository,
GroupCourseRedisService redisService,
BookingReminderEventPublisher bookingReminderEventPublisher,
BookingSagaHandler bookingSagaHandler) {
BookingReminderEventPublisher bookingReminderEventPublisher) {
this.bookingRepository = bookingRepository;
this.courseRepository = courseRepository;
this.redisService = redisService;
this.bookingReminderEventPublisher = bookingReminderEventPublisher;
this.bookingSagaHandler = bookingSagaHandler;
}
@Override
public Mono<GroupCourseBooking> bookCourse(Long courseId, Long memberId, Long memberCardRecordId) {
logger.info("开始预约团课:courseId={}, memberId={}, memberCardRecordId={}", courseId, memberId, memberCardRecordId);
public Mono<GroupCourseBooking> bookCourse(Long courseId, Long memberId) {
logger.info("开始预约团课:courseId={}, memberId={}", courseId, memberId);
// 生成唯一请求ID用于分布式锁
String requestId = UUID.randomUUID().toString();
@@ -82,14 +76,14 @@ public class GroupCourseBookingService implements IGroupCourseBookingService {
return getCourseWithCache(courseId)
.flatMap(course -> {
// 3. 验证课程状态
Long status = course.getStatus();
if (status == null || status != 0L) {
Long courseStatus = course.getStatus();
if (courseStatus == null || courseStatus != 0L) {
String errorMessage;
if (status == null) {
if (courseStatus == null) {
errorMessage = "课程状态异常";
} else if (status == 1L) {
} else if (courseStatus == 1L) {
errorMessage = "课程已取消,无法预约";
} else if (status == 2L) {
} else if (courseStatus == 2L) {
errorMessage = "课程已结束,无法预约";
} else {
errorMessage = "课程状态不可预约";
@@ -132,57 +126,61 @@ public class GroupCourseBookingService implements IGroupCourseBookingService {
// 7. 验证是否已预约
return bookingRepository.findValidBooking(courseId, memberId)
.flatMap(existingBooking -> {
return releaseLockAndError(courseId, requestId, "您已预约该课程");
})
.flatMap(existingBooking ->
releaseLockAndError(courseId, requestId, "您已预约该课程")
)
.switchIfEmpty(
// 8. 使用Redis原子操作验证课程人数是否已满
validateAndIncrementBookingCount(courseId, course.getMaxMembers())
.flatMap(countValid -> {
if (countValid > course.getMaxMembers()) {
return releaseLockAndError(courseId, requestId, "课程已满");
}
// 8. 创建预约记录
Mono.defer(() -> {
GroupCourseBooking booking = new GroupCourseBooking();
booking.setCourseId(courseId);
booking.setMemberId(memberId);
booking.setBookingTime(LocalDateTime.now());
booking.setStatus("0"); // 0-已预约
// 9. 创建预约记录
GroupCourseBooking booking = new GroupCourseBooking();
booking.setCourseId(courseId);
booking.setMemberId(memberId);
booking.setMemberCardRecordId(memberCardRecordId);
booking.setBookingTime(LocalDateTime.now());
booking.setStatus("0"); // 0-已预约
// 添加课程信息到预约记录
booking.setCourseName(course.getCourseName());
booking.setCourseStartTime(course.getStartTime());
booking.setCourseEndTime(course.getEndTime());
booking.setLocation(course.getLocation());
// 添加课程信息到预约记录
booking.setCourseName(course.getCourseName());
booking.setCourseStartTime(course.getStartTime());
booking.setCourseEndTime(course.getEndTime());
booking.setLocation(course.getLocation());
// 10. 使用Saga事务执行预约(包含权益扣减)
BigDecimal courseAmount = course.getStoredValueAmount() != null ? course.getStoredValueAmount() : BigDecimal.ZERO;
return bookingSagaHandler.executeBooking(booking, memberCardRecordId, courseAmount)
.flatMap(savedBooking -> {
// 11. 释放锁
return redisService.releaseLock(courseId, requestId)
.then(Mono.just(savedBooking));
})
.doOnSuccess(savedBooking -> {
logger.info("预约成功:bookingId={}, courseId={}, memberId={}",
savedBooking.getId(), courseId, memberId);
// 发布预约成功事件
bookingReminderEventPublisher.publishBookingSuccessEvent(
savedBooking.getId(),
savedBooking.getMemberId(),
savedBooking.getCourseName(),
savedBooking.getCourseStartTime().toString()
);
})
.doOnError(error -> {
// 回滚Redis计数
redisService.decrementBookingCount(courseId).subscribe();
logger.error("预约失败:courseId={}, memberId={}, error={}",
courseId, memberId, error.getMessage());
});
})
// 9. 保存预约记录
return bookingRepository.save(booking)
.flatMap(saved -> {
if (saved.getId() == null) {
return Mono.error(new RuntimeException("保存预约记录失败"));
}
// 10. 更新课程当前人数
return courseRepository.updateCurrentMembers(courseId, 1)
.flatMap(updatedCourse -> {
// 11. 更新Redis预约计数
return redisService.incrementBookingCount(courseId)
.flatMap(count -> {
// 12. 释放锁
return redisService.releaseLock(courseId, requestId)
.then(Mono.just(saved));
});
})
.doOnSuccess(savedBooking -> {
logger.info("预约成功:bookingId={}, courseId={}, memberId={}",
saved.getId(), courseId, memberId);
// 发布预约成功事件
bookingReminderEventPublisher.publishBookingSuccessEvent(
saved.getId(),
saved.getMemberId(),
saved.getCourseName(),
saved.getCourseStartTime().toString()
);
})
.doOnError(error -> {
// 失败时回滚Redis计数和课程人数
redisService.decrementBookingCount(courseId).subscribe();
courseRepository.updateCurrentMembers(courseId, -1).subscribe();
logger.error("预约失败:courseId={}, memberId={}, error={}",
courseId, memberId, error.getMessage());
});
});
})
);
});
})
@@ -210,29 +208,6 @@ public class GroupCourseBookingService implements IGroupCourseBookingService {
);
}
/**
* 验证并增加预约人数(使用Redis原子操作)
*/
private Mono<Integer> validateAndIncrementBookingCount(Long courseId, Integer maxMembers) {
// 先获取当前Redis中的预约计数
return redisService.getBookingCount(courseId)
.flatMap(currentCount -> {
// 如果Redis中计数为0,可能是首次访问,需要从数据库同步
if (currentCount == 0) {
// 从数据库查询实际预约人数
return bookingRepository.countValidBookings(courseId)
.flatMap(dbCount -> {
// 将数据库中的实际预约人数同步到Redis
return redisService.setBookingCount(courseId, dbCount.intValue())
.then(Mono.just(dbCount.intValue()));
});
}
return Mono.just(currentCount);
})
// 递增预约计数
.flatMap(count -> redisService.incrementBookingCount(courseId).map(Long::intValue));
}
/**
* 释放锁并返回错误
*/
@@ -292,33 +267,37 @@ public class GroupCourseBookingService implements IGroupCourseBookingService {
"需在课程开始前" + CANCEL_MIN_ADVANCE_HOURS + "小时取消");
}
// 5. 查询课程金额和已取消次数,使用Saga事务执行取消预约
return courseRepository.findByIdAndDeletedAtIsNull(booking.getCourseId())
.flatMap(course -> {
BigDecimal courseAmount = course.getStoredValueAmount() != null ? course.getStoredValueAmount() : BigDecimal.valueOf(50);
return bookingRepository.countCancelledByMemberId(memberId)
.flatMap(cancelCount -> {
return bookingSagaHandler.executeCancelBooking(bookingId, booking.getCourseId(), booking.getMemberCardRecordId(), memberId, courseAmount, cancelCount);
});
})
.flatMap(updatedBooking -> {
// 6. 释放锁
return redisService.releaseLock(bookingId, requestId)
.then(Mono.just(updatedBooking));
})
.doOnSuccess(updatedBooking -> {
logger.info("取消预约成功:bookingId={}, memberId={}", bookingId, memberId);
// 发布预约取消事件
bookingReminderEventPublisher.publishBookingCancelEvent(
updatedBooking.getId(),
updatedBooking.getMemberId(),
updatedBooking.getCourseName()
);
})
.doOnError(error -> {
logger.error("取消预约失败:bookingId={}, memberId={}, error={}",
bookingId, memberId, error.getMessage());
});
// 5. 更新预约状态为已取消
return bookingRepository.updateStatus(bookingId, "1")
.flatMap(rows -> {
if (rows == 0) {
return Mono.error(new RuntimeException("更新预约状态失败"));
}
// 6. 减少课程当前人数
return courseRepository.updateCurrentMembers(booking.getCourseId(), -1)
.flatMap(updatedCourse -> {
// 7. 更新Redis预约计数
return redisService.decrementBookingCount(booking.getCourseId())
.flatMap(count -> {
// 8. 释放锁
return redisService.releaseLock(bookingId, requestId)
.then(bookingRepository.findById(bookingId));
});
})
.doOnSuccess(updatedBooking -> {
logger.info("取消预约成功:bookingId={}, memberId={}", bookingId, memberId);
// 发布预约取消事件
bookingReminderEventPublisher.publishBookingCancelEvent(
updatedBooking.getId(),
updatedBooking.getMemberId(),
updatedBooking.getCourseName()
);
})
.doOnError(error -> {
logger.error("取消预约失败:bookingId={}, memberId={}, error={}",
bookingId, memberId, error.getMessage());
});
});
})
.onErrorResume(error -> {
redisService.releaseLock(bookingId, requestId).subscribe();
@@ -19,6 +19,7 @@ import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseTypeRepository;
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseService;
import cn.novalon.gym.manage.groupcourse.util.QRCodeUtil;
import cn.novalon.gym.manage.file.core.service.ISysFileService;
import cn.novalon.gym.manage.member.entity.MemberCard;
import cn.novalon.gym.manage.member.entity.MemberCardRecord;
import cn.novalon.gym.manage.member.enums.MemberCardType;
@@ -51,6 +52,7 @@ public class GroupCourseService implements IGroupCourseService {
private final ObjectMapper objectMapper;
private final GroupCourseStateMachine stateMachine;
private final DatabaseClient databaseClient;
private final ISysFileService fileService;
private static final String CACHE_KEY_PREFIX = "group_course:page:";
private static final String CACHE_KEY_ID_PREFIX = "group_course:id:";
@@ -68,7 +70,8 @@ public class GroupCourseService implements IGroupCourseService {
RedisUtil redisUtil,
ObjectMapper objectMapper,
GroupCourseStateMachine stateMachine,
DatabaseClient databaseClient){
DatabaseClient databaseClient,
ISysFileService fileService){
this.groupCourseRepository = groupCourseRepository;
this.bookingRepository = bookingRepository;
this.groupCourseTypeRepository = groupCourseTypeRepository;
@@ -79,6 +82,7 @@ public class GroupCourseService implements IGroupCourseService {
this.objectMapper = objectMapper;
this.stateMachine = stateMachine;
this.databaseClient = databaseClient;
this.fileService = fileService;
}
@Override
@@ -224,8 +228,9 @@ public class GroupCourseService implements IGroupCourseService {
String sort = pageRequest.getSort();
String order = pageRequest.getOrder();
String keyword = pageRequest.getKeyword() != null ? pageRequest.getKeyword() : "";
String status = pageRequest.getStatus() != null ? pageRequest.getStatus() : "";
String cacheKey = CACHE_KEY_PREFIX + page + ":" + size + ":" + includeDeleted + ":" + sort + ":" + order + ":" + keyword;
String cacheKey = CACHE_KEY_PREFIX + page + ":" + size + ":" + includeDeleted + ":" + sort + ":" + order + ":" + keyword + ":" + status;
return redisUtil.get(cacheKey, String.class)
.flatMap(cachedJson -> {
@@ -287,15 +292,21 @@ public class GroupCourseService implements IGroupCourseService {
String jsonContent = objectMapper.writeValueAsString(qrCodeContent);
// 生成二维码并上传到阿里云OSS
String qrCodeUrl = QRCodeUtil.generateQRCodeAndUploadToOSS(jsonContent);
course.setQrCodePath(qrCodeUrl);
logger.info("团课二维码上传到OSS成功 - id={}, qrCodeUrl={}", course.getId(), qrCodeUrl);
// 更新团课信息,保存二维码路径
return groupCourseRepository.update(course)
.doOnSuccess(updatedCourse -> logger.info("团课创建成功 - id={}, name={}", updatedCourse.getId(), updatedCourse.getCourseName()));
// 生成二维码字节数组,通过统一文件服务保存
return Mono.fromCallable(() -> QRCodeUtil.generateQrCodeBytes(jsonContent))
.flatMap(qrCodeBytes -> {
String fileName = "qrcode_" + course.getId() + ".png";
return fileService.saveBytes(qrCodeBytes, fileName, "image/png", "system");
})
.flatMap(sysFile -> {
String qrCodeUrl = "/api/files/" + sysFile.getId() + "/preview";
course.setQrCodePath(qrCodeUrl);
logger.info("团课二维码已保存 - id={}, fileId={}, url={}", course.getId(), sysFile.getId(), qrCodeUrl);
return groupCourseRepository.update(course)
.doOnSuccess(updatedCourse -> logger.info("团课创建成功 - id={}, name={}", updatedCourse.getId(), updatedCourse.getCourseName()));
});
} catch (Exception e) {
logger.error("团课二维码生成失败 - id={}, error: {}", course.getId(), e.getMessage(), e);
// 即使二维码生成失败,也返回成功创建的团课
@@ -503,29 +514,14 @@ public class GroupCourseService implements IGroupCourseService {
return Mono.error(new RuntimeException("课程已满员,无法签到"));
}
// 校验5:用户今日是否已到店签到(直接查询sign_in_record表
LocalDateTime todayStart = LocalDateTime.now().toLocalDate().atStartOfDay();
LocalDateTime todayEnd = todayStart.plusDays(1);
return databaseClient.sql("SELECT sign_in_status FROM sign_in_record WHERE member_id = :memberId AND sign_in_time >= :startTime AND sign_in_time < :endTime AND is_delete = false ORDER BY sign_in_time DESC LIMIT 1")
.bind("memberId", memberId)
.bind("startTime", todayStart)
.bind("endTime", todayEnd)
.map(row -> row.get("sign_in_status", String.class))
.one()
.switchIfEmpty(Mono.error(new RuntimeException("请先完成到店签到")))
.flatMap(status -> {
if (!"SUCCESS".equals(status)) {
return Mono.error(new RuntimeException("到店签到未成功,请重新签到"));
}
// 校验6:用户已预约此课程(有效预约,状态为0-已预约)
return bookingRepository.findValidBooking(courseId, memberId)
.switchIfEmpty(Mono.error(new RuntimeException("您未预约此课程,无法签到")))
.flatMap(booking -> {
return groupCourseRepository.updateCurrentMembers(courseId, 1)
.flatMap(updatedCourse -> {
return bookingRepository.updateStatus(booking.getId(), "2")
.thenReturn(updatedCourse);
});
// 校验5:用户已预约此课程(有效预约,状态为0-已预约
return bookingRepository.findValidBooking(courseId, memberId)
.switchIfEmpty(Mono.error(new RuntimeException("您未预约此团课")))
.flatMap(booking -> {
return groupCourseRepository.updateCurrentMembers(courseId, 1)
.flatMap(updatedCourse -> {
return bookingRepository.updateStatus(booking.getId(), "2")
.thenReturn(updatedCourse);
});
});
})
@@ -536,14 +532,15 @@ public class GroupCourseService implements IGroupCourseService {
@Override
public Mono<Void> delete(Long id) {
// 先查询课程状态,只有已取消的课程才能删除
// 只有已取消或已结束的课程才能删除
return groupCourseRepository.findByIdAndDeletedAtIsNull(id)
.switchIfEmpty(Mono.error(new RuntimeException("团课不存在")))
.flatMap(course -> {
// 检查课程状态是否为已取消(状态码1)
if (course.getStatus() == null || !course.getStatus().equals(CourseStatus.CANCELLED.getValue())) {
return Mono.error(new RuntimeException("只有已取消的课程才能删除,当前状态: " +
(course.getStatus() != null ? course.getStatus() : "未知")));
// 检查课程状态是否为已取消(状态码1)或已结束(状态码2
Long status = course.getStatus();
if (status == null || (!status.equals(CourseStatus.CANCELLED.getValue()) && !status.equals(CourseStatus.ENDED.getValue()))) {
return Mono.error(new RuntimeException("只有已取消或已结束的课程才能删除,当前状态: " +
(status != null ? status : "未知")));
}
// 删除课程
@@ -1,6 +1,9 @@
package cn.novalon.gym.manage.groupcourse.service.impl;
import cn.novalon.gym.manage.common.dto.PageRequest;
import cn.novalon.gym.manage.common.dto.PageResponse;
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseTypeRepository;
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseTypeService;
import org.slf4j.Logger;
@@ -9,18 +12,18 @@ import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.util.HashSet;
import java.util.Set;
@Service
public class GroupCourseTypeService implements IGroupCourseTypeService {
private static final Logger logger = LoggerFactory.getLogger(GroupCourseTypeService.class);
private final IGroupCourseTypeRepository groupCourseTypeRepository;
private final IGroupCourseRepository groupCourseRepository;
public GroupCourseTypeService(IGroupCourseTypeRepository groupCourseTypeRepository) {
public GroupCourseTypeService(IGroupCourseTypeRepository groupCourseTypeRepository,
IGroupCourseRepository groupCourseRepository) {
this.groupCourseTypeRepository = groupCourseTypeRepository;
this.groupCourseRepository = groupCourseRepository;
}
@Override
@@ -71,9 +74,17 @@ public class GroupCourseTypeService implements IGroupCourseTypeService {
@Override
public Mono<Void> delete(Long id) {
return groupCourseTypeRepository.deleteById(id)
.doOnSuccess(v -> logger.info("团课类型删除成功 - id={}", id))
.doOnError(error -> logger.error("团课类型删除失败 - id={}, error: {}", id, error.getMessage()));
// 检查是否有团课依赖该类型
return groupCourseRepository.findByCourseType(id)
.hasElements()
.flatMap(hasDependents -> {
if (hasDependents) {
return Mono.<Void>error(new RuntimeException("该类型下存在团课,无法删除"));
}
return groupCourseTypeRepository.deleteById(id)
.doOnSuccess(v -> logger.info("团课类型删除成功 - id={}", id))
.doOnError(error -> logger.error("团课类型删除失败 - id={}, error: {}", id, error.getMessage()));
});
}
@Override
@@ -83,4 +94,12 @@ public class GroupCourseTypeService implements IGroupCourseTypeService {
.filter(category -> category != null && !category.isEmpty())
.distinct();
}
@Override
public Mono<PageResponse<GroupCourseType>> findByPage(PageRequest pageRequest) {
return groupCourseTypeRepository.findByPage(pageRequest)
.doOnSuccess(result -> logger.info("分页查询团课类型成功 - page={}, size={}, total={}",
pageRequest.getPage(), pageRequest.getSize(), result.getTotalElements()))
.doOnError(error -> logger.error("分页查询团课类型失败 - error: {}", error.getMessage()));
}
}
@@ -1,109 +0,0 @@
package cn.novalon.gym.manage.groupcourse.util;
import com.aliyun.oss.OSS;
import com.aliyun.oss.OSSClientBuilder;
import com.aliyun.oss.model.PutObjectRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
/**
* 阿里云OSS工具类
*/
public class OSSUtil {
private static final Logger logger = LoggerFactory.getLogger(OSSUtil.class);
// OSS配置信息
private static final String ENDPOINT = "oss-cn-beijing.aliyuncs.com";
private static final String ACCESS_KEY_ID = "LTAI5t9TFh9Vayeahz45kZjg";
private static final String ACCESS_KEY_SECRET = "zD6NlCeH5UhjBs4vnQVqn8Ksi3CaZz";
private static final String BUCKET_NAME = "ycc-filesaver";
// OSS访问地址前缀
private static final String OSS_URL_PREFIX = "https://" + BUCKET_NAME + "." + ENDPOINT + "/";
// 文件存储目录
private static final String QRCODE_DIR = "qrcode/";
/**
* 上传文件到阿里云OSS
*
* @param localFilePath 本地文件路径
* @param fileName 文件名(不含路径)
* @return OSS访问地址
*/
public static String uploadToOSS(String localFilePath, String fileName) {
OSS ossClient = null;
try {
// 创建OSS客户端
ossClient = new OSSClientBuilder().build(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET);
// 构建OSS文件路径:qrcode/2026/06/18/xxx.png
String datePath = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd"));
String ossFilePath = QRCODE_DIR + datePath + "/" + fileName;
// 创建上传请求
PutObjectRequest putObjectRequest = new PutObjectRequest(BUCKET_NAME, ossFilePath, new File(localFilePath));
// 上传文件
ossClient.putObject(putObjectRequest);
// 构建访问地址
String accessUrl = OSS_URL_PREFIX + ossFilePath;
logger.info("文件上传到OSS成功: localPath={}, ossUrl={}", localFilePath, accessUrl);
return accessUrl;
} catch (Exception e) {
logger.error("文件上传到OSS失败 - localPath: {}, error: {}", localFilePath, e.getMessage(), e);
throw new RuntimeException("文件上传到OSS失败: " + e.getMessage(), e);
} finally {
if (ossClient != null) {
ossClient.shutdown();
}
}
}
/**
* 上传文件到阿里云OSS(自定义存储路径)
*
* @param localFilePath 本地文件路径
* @param ossDirectory OSS存储目录
* @param fileName 文件名(不含路径)
* @return OSS访问地址
*/
public static String uploadToOSS(String localFilePath, String ossDirectory, String fileName) {
OSS ossClient = null;
try {
// 创建OSS客户端
ossClient = new OSSClientBuilder().build(ENDPOINT, ACCESS_KEY_ID, ACCESS_KEY_SECRET);
// 构建OSS文件路径
String ossFilePath = ossDirectory + fileName;
// 创建上传请求
PutObjectRequest putObjectRequest = new PutObjectRequest(BUCKET_NAME, ossFilePath, new File(localFilePath));
// 上传文件
ossClient.putObject(putObjectRequest);
// 构建访问地址
String accessUrl = OSS_URL_PREFIX + ossFilePath;
logger.info("文件上传到OSS成功: localPath={}, ossUrl={}", localFilePath, accessUrl);
return accessUrl;
} catch (Exception e) {
logger.error("文件上传到OSS失败 - localPath: {}, error: {}", localFilePath, e.getMessage(), e);
throw new RuntimeException("文件上传到OSS失败: " + e.getMessage(), e);
} finally {
if (ossClient != null) {
ossClient.shutdown();
}
}
}
}
@@ -10,46 +10,33 @@ import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;
/**
* 二维码生成工具类
* 生成二维码的字节数组,由调用方统一通过文件服务保存
*/
public class QRCodeUtil {
private static final Logger logger = LoggerFactory.getLogger(QRCodeUtil.class);
// 二维码默认保存路径(本地临时路径)
private static final String DEFAULT_SAVE_PATH = "D:\\Games\\exmp\\image";
// 二维码尺寸
private static final int QR_CODE_WIDTH = 300;
private static final int QR_CODE_HEIGHT = 300;
/**
* 生成二维码并保存到指定路径
* 生成二维码图片的字节数组
*
* @param content 二维码内容
* @param savePath 保存路径
* @param fileName 文件名(不含扩展名)
* @return 生成的二维码文件完整路径
* @return PNG格式的二维码图片字节数组
*/
public static String generateQRCode(String content, String savePath, String fileName) {
public static byte[] generateQrCodeBytes(String content) {
try {
Path directory = Paths.get(savePath);
if (!Files.exists(directory)) {
Files.createDirectories(directory);
logger.info("创建二维码保存目录: {}", savePath);
}
Map<EncodeHintType, Object> hints = new HashMap<>();
hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.H);
@@ -58,99 +45,21 @@ public class QRCodeUtil {
QRCodeWriter qrCodeWriter = new QRCodeWriter();
BitMatrix bitMatrix = qrCodeWriter.encode(content, BarcodeFormat.QR_CODE, QR_CODE_WIDTH, QR_CODE_HEIGHT, hints);
String filePath = Paths.get(savePath, fileName + ".png").toString();
Path path = Paths.get(filePath);
BufferedImage image = MatrixToImageWriter.toBufferedImage(bitMatrix);
MatrixToImageWriter.writeToPath(bitMatrix, "PNG", path);
logger.info("二维码生成成功: {}", filePath);
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ImageIO.write(image, "PNG", baos);
byte[] bytes = baos.toByteArray();
baos.close();
return filePath;
logger.info("二维码字节数组生成成功, size={} bytes", bytes.length);
return bytes;
} catch (WriterException e) {
logger.error("二维码生成失败 - WriterException: {}", e.getMessage(), e);
throw new RuntimeException("二维码生成失败: " + e.getMessage(), e);
} catch (IOException e) {
logger.error("二维码保存失败 - IOException: {}", e.getMessage(), e);
throw new RuntimeException("二维码保存失败: " + e.getMessage(), e);
}
}
/**
* 生成二维码并保存到默认路径
* 文件名格式: UUID + 创建时间
*
* @param content 二维码内容
* @return 生成的二维码文件完整路径
*/
public static String generateQRCode(String content) {
String uuid = UUID.randomUUID().toString().replace("-", "");
String timestamp = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"));
String fileName = uuid + "_" + timestamp;
return generateQRCode(content, DEFAULT_SAVE_PATH, fileName);
}
/**
* 生成二维码并保存到默认路径,使用自定义文件名
*
* @param content 二维码内容
* @param fileName 文件名(不含扩展名)
* @return 生成的二维码文件完整路径
*/
public static String generateQRCodeWithFileName(String content, String fileName) {
return generateQRCode(content, DEFAULT_SAVE_PATH, fileName);
}
/**
* 生成二维码并上传到阿里云OSS
* 文件名格式: UUID + 创建时间
*
* @param content 二维码内容
* @return 阿里云OSS访问地址
*/
public static String generateQRCodeAndUploadToOSS(String content) {
String uuid = UUID.randomUUID().toString().replace("-", "");
String timestamp = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss"));
String fileName = uuid + "_" + timestamp + ".png";
return generateQRCodeAndUploadToOSS(content, fileName);
}
/**
* 生成二维码并上传到阿里云OSS
*
* @param content 二维码内容
* @param fileName 文件名(含扩展名)
* @return 阿里云OSS访问地址
*/
public static String generateQRCodeAndUploadToOSS(String content, String fileName) {
try {
Path tempDir = Files.createTempDirectory("qrcode_temp");
String tempFilePath = tempDir.resolve(fileName).toString();
Map<EncodeHintType, Object> hints = new HashMap<>();
hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
hints.put(EncodeHintType.ERROR_CORRECTION, ErrorCorrectionLevel.H);
hints.put(EncodeHintType.MARGIN, 1);
QRCodeWriter qrCodeWriter = new QRCodeWriter();
BitMatrix bitMatrix = qrCodeWriter.encode(content, BarcodeFormat.QR_CODE, QR_CODE_WIDTH, QR_CODE_HEIGHT, hints);
MatrixToImageWriter.writeToPath(bitMatrix, "PNG", Paths.get(tempFilePath));
logger.info("二维码临时文件生成成功: {}", tempFilePath);
String ossUrl = OSSUtil.uploadToOSS(tempFilePath, fileName);
Files.deleteIfExists(Paths.get(tempFilePath));
Files.deleteIfExists(tempDir);
logger.info("临时文件已删除: {}", tempFilePath);
return ossUrl;
} catch (WriterException e) {
logger.error("二维码生成失败 - WriterException: {}", e.getMessage(), e);
throw new RuntimeException("二维码生成失败: " + e.getMessage(), e);
} catch (IOException e) {
logger.error("二维码处理失败 - IOException: {}", e.getMessage(), e);
throw new RuntimeException("二维码处理失败: " + e.getMessage(), e);
logger.error("二维码输出失败 - IOException: {}", e.getMessage(), e);
throw new RuntimeException("二维码输出失败: " + e.getMessage(), e);
}
}
}
@@ -1,9 +1,6 @@
package cn.novalon.gym.manage.groupcourse.util;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir;
import java.nio.file.Path;
import static org.junit.jupiter.api.Assertions.*;
@@ -12,60 +9,41 @@ import static org.junit.jupiter.api.Assertions.*;
*/
class QRCodeUtilTest {
@TempDir
Path tempDir;
@Test
void testGenerateQRCode() {
void testGenerateQrCodeBytes() {
String content = "测试二维码内容";
String qrCodePath = QRCodeUtil.generateQRCode(content);
byte[] bytes = QRCodeUtil.generateQrCodeBytes(content);
assertNotNull(qrCodePath, "二维码路径不应为空");
assertTrue(qrCodePath.endsWith(".png"), "二维码文件应为PNG格式");
assertTrue(qrCodePath.contains("D:\\Games\\exmp\\image"), "二维码应保存到指定路径");
assertNotNull(bytes, "二维码字节数组不应为空");
assertTrue(bytes.length > 0, "二维码字节数组应包含数据");
System.out.println("生成的二维码路径: " + qrCodePath);
System.out.println("生成的二维码字节大小: " + bytes.length + " bytes");
}
@Test
void testGenerateQRCodeWithCustomPath() {
String content = "自定义路径测试";
String customPath = tempDir.toString();
String fileName = "test_qrcode";
void testGenerateQrCodeBytesWithJsonContent() {
String jsonContent = "{\"id\":1,\"courseName\":\"瑜伽课\",\"coachId\":100,\"startTime\":\"2026-07-14T10:00:00\"}";
String qrCodePath = QRCodeUtil.generateQRCode(content, customPath, fileName);
byte[] bytes = QRCodeUtil.generateQrCodeBytes(jsonContent);
assertNotNull(qrCodePath, "二维码路径不应为空");
assertTrue(qrCodePath.endsWith(".png"), "二维码文件应为PNG格式");
assertTrue(qrCodePath.contains(fileName), "二维码文件名应包含指定名称");
assertNotNull(bytes, "二维码字节数组不应为空");
assertTrue(bytes.length > 0, "二维码字节数组应包含数据");
System.out.println("生成的二维码路径: " + qrCodePath);
System.out.println("JSON内容二维码字节大小: " + bytes.length + " bytes");
}
@Test
void testGenerateQRCodeWithJsonContent() {
String jsonContent = "{\"id\":1,\"courseName\":\"瑜伽课\",\"coachId\":100,\"startTime\":\"2026-06-18T10:00:00\"}";
void testGenerateQrCodeBytesWithLongContent() {
StringBuilder sb = new StringBuilder();
for (int i = 0; i < 100; i++) {
sb.append("这是第").append(i).append("行测试数据\n");
}
String qrCodePath = QRCodeUtil.generateQRCode(jsonContent);
byte[] bytes = QRCodeUtil.generateQrCodeBytes(sb.toString());
assertNotNull(qrCodePath, "二维码路径不应为空");
assertTrue(qrCodePath.endsWith(".png"), "二维码文件应为PNG格式");
assertNotNull(bytes, "二维码字节数组不应为空");
assertTrue(bytes.length > 0, "长内容二维码应正常生成");
System.out.println("JSON内容二维码路径: " + qrCodePath);
System.out.println("内容二维码字节大小: " + bytes.length + " bytes");
}
@Test
void testGenerateQRCodeAndUploadToOSS() {
String jsonContent = "{\"id\":1,\"courseName\":\"瑜伽课\",\"coachId\":100,\"startTime\":\"2026-06-18T10:00:00\"}";
String ossUrl = QRCodeUtil.generateQRCodeAndUploadToOSS(jsonContent);
assertNotNull(ossUrl, "OSS访问地址不应为空");
assertTrue(ossUrl.startsWith("https://"), "OSS访问地址应为HTTPS");
assertTrue(ossUrl.contains("ycc-filesaver.oss-cn-beijing.aliyuncs.com"), "OSS访问地址应包含正确的域名");
assertTrue(ossUrl.contains("/qrcode/"), "OSS访问地址应包含qrcode目录");
assertTrue(ossUrl.endsWith(".png"), "OSS访问地址应为PNG格式");
System.out.println("上传到OSS的二维码地址: " + ossUrl);
}
}
}
@@ -16,6 +16,9 @@ import org.springframework.stereotype.Component;
@ConfigurationProperties(prefix = "wechat")
public class WechatProperties {
// Mock模式:true=使用模拟数据,false=调用真实微信API
private Boolean mockEnabled;
// 小程序配置
private MiniApp miniapp = new MiniApp();
@@ -63,13 +63,24 @@ public class MemberCardHandler {
@Operation(summary = "更新会员卡类型", description = "更新会员卡类型信息")
public Mono<ServerResponse> updateMemberCard(ServerRequest request) {
Long id = Long.valueOf(request.pathVariable("id"));
return request.bodyToMono(MemberCard.class)
.flatMap(card -> {
card.setMemberCardId(id);
return memberCardService.save(card);
return memberCardService.findByMemberCardIdAndDeletedAtIsNull(id)
.switchIfEmpty(Mono.error(new RuntimeException("会员卡不存在: " + id)))
.zipWith(request.bodyToMono(MemberCard.class))
.flatMap(tuple -> {
MemberCard existing = tuple.getT1();
MemberCard body = tuple.getT2();
// 仅更新非 null 字段,避免 null 覆盖已有值
if (body.getMemberCardName() != null) existing.setMemberCardName(body.getMemberCardName());
if (body.getMemberCardType() != null) existing.setMemberCardType(body.getMemberCardType());
if (body.getMemberCardPrice() != null) existing.setMemberCardPrice(body.getMemberCardPrice());
if (body.getMemberCardValidityDays() != null) existing.setMemberCardValidityDays(body.getMemberCardValidityDays());
if (body.getMemberCardTotalTimes() != null) existing.setMemberCardTotalTimes(body.getMemberCardTotalTimes());
if (body.getMemberCardAmount() != null) existing.setMemberCardAmount(body.getMemberCardAmount());
if (body.getMemberCardStatus() != null) existing.setMemberCardStatus(body.getMemberCardStatus());
if (body.getExtraConfig() != null) existing.setExtraConfig(body.getExtraConfig());
return memberCardService.save(existing);
})
.flatMap(updated -> ServerResponse.ok().bodyValue(updated))
.switchIfEmpty(ServerResponse.notFound().build());
.flatMap(updated -> ServerResponse.ok().bodyValue(updated));
}
@Operation(summary = "删除会员卡类型", description = "逻辑删除会员卡类型")
@@ -155,8 +155,8 @@ public class MemberHandler {
String decryptedPhone = AesUtil.decrypt(detail.getPhone());
detail.setPhone(WechatPhoneUtil.maskPhone(decryptedPhone));
} catch (Exception e) {
log.error("手机号解密失败, memberId: {}", detail.getId(), e);
detail.setPhone(null);
log.warn("手机号解密失败(可能为明文存储), memberId: {}", detail.getId());
detail.setPhone(WechatPhoneUtil.maskPhone(detail.getPhone()));
}
}
return ServerResponse.ok()
@@ -204,8 +204,8 @@ public class MemberHandler {
String decryptedPhone = AesUtil.decrypt(member.getPhone());
member.setPhone(WechatPhoneUtil.maskPhone(decryptedPhone));
} catch (Exception e) {
log.error("手机号解密失败, memberId: {}", member.getId(), e);
member.setPhone(null);
log.warn("手机号解密失败(可能为明文存储), memberId: {}", member.getId());
member.setPhone(WechatPhoneUtil.maskPhone(member.getPhone()));
}
}
return member;
@@ -222,11 +222,13 @@ public class MemberHandler {
int pageNum = NumberUtils.toInt(request.queryParam("pageNum").orElse("1"), 1);
int pageSize = NumberUtils.toInt(request.queryParam("pageSize").orElse("10"), 10);
String sortField = request.queryParam("sortField").orElse(null);
String sortOrder = request.queryParam("sortOrder").orElse(null);
log.info("前台查看会员列表, adminId: {}, pageNum: {}, pageSize: {}", adminId, pageNum, pageSize);
// TODO: 补充签到记录
log.info("前台查看会员列表, adminId: {}, pageNum: {}, pageSize: {}, sortField: {}, sortOrder: {}",
adminId, pageNum, pageSize, sortField, sortOrder);
return memberService.findAll(pageNum, pageSize)
return memberService.findAll(pageNum, pageSize, sortField, sortOrder)
.map(member -> {
// 解密手机号
if (member.getPhone() != null && !member.getPhone().isEmpty()) {
@@ -234,8 +236,8 @@ public class MemberHandler {
String decryptedPhone = AesUtil.decrypt(member.getPhone());
member.setPhone(WechatPhoneUtil.maskPhone(decryptedPhone));
} catch (Exception e) {
log.error("手机号解密失败, memberId: {}", member.getId(), e);
member.setPhone(null);
log.warn("手机号解密失败(可能为明文存储), memberId: {}", member.getId());
member.setPhone(WechatPhoneUtil.maskPhone(member.getPhone()));
}
}
return member;
@@ -46,7 +46,7 @@ public interface MemberCardRepository extends R2dbcRepository<MemberCard, Long>
"AND (:type IS NULL OR member_card_type = :type) " +
"AND (:minPrice IS NULL OR member_card_price >= :minPrice) " +
"AND (:maxPrice IS NULL OR member_card_price <= :maxPrice) " +
"ORDER BY created_at DESC LIMIT :#{#pageable.pageSize} OFFSET :#{#pageable.offset}")
"ORDER BY id ASC LIMIT :#{#pageable.pageSize} OFFSET :#{#pageable.offset}")
Flux<MemberCard> findWithConditions(Integer status, String name, String type,
Double minPrice, Double maxPrice, Pageable pageable);
@@ -58,7 +58,7 @@ public interface MemberService {
* @param pageSize 页大小
* @return 所有会员信息
*/
Flux<Member> findAll(Integer pageNum, Integer pageSize);
Flux<Member> findAll(Integer pageNum, Integer pageSize, String sortField, String sortOrder);
/**
* 前台管理端获取会员详情(含会员卡信息)
@@ -26,6 +26,7 @@ import jakarta.annotation.PostConstruct;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Pageable;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;
@@ -230,13 +231,31 @@ public class MemberServiceImpl implements MemberService {
);
}
/** 合法的排序字段白名单,key=前端传值, value=数据库字段名 */
private static final java.util.Map<String, String> ALLOWED_SORT_FIELDS = java.util.Map.of(
"createdAt", "created_at",
"memberNo", "member_no",
"gender", "gender",
"id", "id"
);
@Override
public Flux<Member> findAll(Integer pageNum, Integer pageSize) {
log.info("查询所有会员列表, pageNum: {}, pageSize: {}", pageNum, pageSize);
public Flux<Member> findAll(Integer pageNum, Integer pageSize, String sortField, String sortOrder) {
log.info("查询所有会员列表, pageNum: {}, pageSize: {}, sortField: {}, sortOrder: {}",
pageNum, pageSize, sortField, sortOrder);
// 排序方向:desc(默认) / asc
Sort.Direction direction = "asc".equalsIgnoreCase(sortOrder)
? Sort.Direction.ASC : Sort.Direction.DESC;
// 排序字段白名单校验,不在白名单中则使用默认排序
String dbField = (sortField != null && ALLOWED_SORT_FIELDS.containsKey(sortField))
? ALLOWED_SORT_FIELDS.get(sortField) : "created_at";
Pageable pageable = PageRequest.of(
pageNum - 1,
pageSize
pageSize,
Sort.by(direction, dbField)
);
return memberRepository.findAllBy(pageable);
@@ -249,50 +268,51 @@ public class MemberServiceImpl implements MemberService {
String cacheKey = MEMBER_DETAIL_CACHE_PREFIX + memberId;
return redisUtil.get(cacheKey, MemberDetailVO.class)
.flatMap(cached -> {
if (cached != null) {
log.debug("从缓存获取会员详情, memberId: {}", memberId);
return Mono.just(cached);
}
return memberRepository.findById(memberId)
.zipWith(
memberRepository.findCardRecordsWithCardInfoByMemberId(memberId)
.collectList(),
(baseInfo, cardList) -> {
MemberDetailVO memberDetailVO = BeanConvertUtil.toBean(baseInfo, MemberDetailVO.class);
.filter(cached -> cached != null)
.switchIfEmpty(Mono.defer(() ->
memberRepository.findById(memberId)
.switchIfEmpty(Mono.error(() -> {
log.error("会员不存在: memberId={}", memberId);
throw new NotFoundException(ErrorCode.NOT_FOUND_USER, "会员不存在");
}))
.zipWith(
memberRepository.findCardRecordsWithCardInfoByMemberId(memberId)
.collectList(),
(baseInfo, cardList) -> {
MemberDetailVO memberDetailVO = BeanConvertUtil.toBean(baseInfo, MemberDetailVO.class);
GenderEnum genderEnum = GenderEnum.fromCode(baseInfo.getGender());
memberDetailVO.setGenderDesc(genderEnum.getDesc());
GenderEnum genderEnum = GenderEnum.fromCode(baseInfo.getGender());
memberDetailVO.setGenderDesc(genderEnum.getDesc());
List<MemberCardInfoVO> enrichedCards = cardList.stream()
.peek(vo -> {
if (vo.getMemberCardType() != null) {
try {
MemberCardType cardType = MemberCardType.valueOf(vo.getMemberCardType());
vo.setMemberCardTypeDesc(cardType.getDesc());
} catch (IllegalArgumentException e) {
vo.setMemberCardTypeDesc(vo.getMemberCardType());
List<MemberCardInfoVO> enrichedCards = cardList.stream()
.peek(vo -> {
if (vo.getMemberCardType() != null) {
try {
MemberCardType cardType = MemberCardType.valueOf(vo.getMemberCardType());
vo.setMemberCardTypeDesc(cardType.getDesc());
} catch (IllegalArgumentException e) {
vo.setMemberCardTypeDesc(vo.getMemberCardType());
}
}
}
if (vo.getMemberCardStatus() != null) {
vo.setMemberCardStatusDesc(vo.getMemberCardStatus() == 1 ? "上架" : "下架");
}
})
.collect(Collectors.toList());
memberDetailVO.setMemberCards(enrichedCards);
if (vo.getMemberCardStatus() != null) {
vo.setMemberCardStatusDesc(vo.getMemberCardStatus() == 1 ? "上架" : "下架");
}
})
.collect(Collectors.toList());
memberDetailVO.setMemberCards(enrichedCards);
long activeCount = enrichedCards.stream()
.filter(card -> card.getMemberCardStatus() != null && card.getMemberCardStatus() == 1)
.count();
memberDetailVO.setActiveCardCount((int) activeCount);
memberDetailVO.setInactiveCardCount(enrichedCards.size() - (int) activeCount);
long activeCount = enrichedCards.stream()
.filter(card -> card.getMemberCardStatus() != null && card.getMemberCardStatus() == 1)
.count();
memberDetailVO.setActiveCardCount((int) activeCount);
memberDetailVO.setInactiveCardCount(enrichedCards.size() - (int) activeCount);
return memberDetailVO;
}
)
.flatMap(vo -> redisUtil.setWithExpire(cacheKey, vo, CACHE_EXPIRE_SECONDS)
.then(Mono.just(vo)));
});
return memberDetailVO;
}
)
.flatMap(vo -> redisUtil.setWithExpire(cacheKey, vo, CACHE_EXPIRE_SECONDS)
.then(Mono.just(vo)))
));
}
@@ -43,12 +43,25 @@ public class WechatApiServiceImpl implements WechatApiService {
@Override
public Mono<Map<String, String>> jsCode2Session(String code) {
log.info("微信jsCode2Session API");
log.info("信息 - AppID: {}, AppSecret {}",
log.info("微信jsCode2Session API, code: {}", code);
// Mock模式:返回模拟数据
if (wechatProperties.getMockEnabled() != null && wechatProperties.getMockEnabled()) {
log.info("Mock模式已启用,返回模拟微信登录数据");
Map<String, String> mockResult = new HashMap<>();
// 使用 code 的哈希生成唯一的 openid,确保每次登录创建不同用户
String mockOpenId = "mock_openid_" + Math.abs(code.hashCode() % 1000000);
mockResult.put("openid", mockOpenId);
mockResult.put("session_key", "mock_session_key");
mockResult.put("unionid", "mock_unionid_" + Math.abs(code.hashCode() % 1000000));
log.info("Mock微信API响应成功, openid: {}, unionid: {}", mockOpenId, mockResult.get("unionid"));
return Mono.just(mockResult);
}
log.info("真实微信API调用 - AppID: {}, AppSecret {}",
wechatProperties.getMiniapp().getAppId(),
wechatProperties.getMiniapp().getAppSecret() != null ?
wechatProperties.getMiniapp().getAppSecret().substring(0, Math.min(4, wechatProperties.getMiniapp().getAppSecret().length())) + "***" : "null");
log.info(" - code: {}", code);
return webClient.get()
.uri(uriBuilder -> uriBuilder
@@ -152,6 +165,12 @@ public class WechatApiServiceImpl implements WechatApiService {
public Mono<String> getAccessToken(String appType) {
log.debug("获取access_token, appType: {}", appType);
// Mock模式:返回模拟access_token
if (wechatProperties.getMockEnabled() != null && wechatProperties.getMockEnabled()) {
log.debug("Mock模式已启用,返回模拟access_token");
return Mono.just("mock_access_token");
}
String cacheKey = ACCESS_TOKEN_CACHE_PREFIX + appType;
return redisUtil.get(cacheKey, String.class)
@@ -257,8 +257,11 @@ public class SystemRouter {
// ===== 会员卡类型管理 =====
.GET("/api/member-cards/active", memberCardHandler::getActiveCards)
.GET("/api/member-cards", memberCardHandler::listMemberCards)
.GET("/api/member-cards/{memberCardId}", memberCardHandler::getMemberCardById)
.POST("/api/member-cards", memberCardHandler::createMemberCard)
.PUT("/api/member-cards/{id}", memberCardHandler::updateMemberCard)
.DELETE("/api/member-cards/{id}", memberCardHandler::deleteMemberCard)
// ===== 会员卡记录管理(核心业务)=====
.POST("/api/member-card-records/purchase", memberCardRecordHandler::purchaseCard)
@@ -305,6 +308,7 @@ public class SystemRouter {
.GET("/api/groupCourse/types/category/{category}", groupCourseTypeHandler::getGroupCourseTypesByCategory)
.GET("/api/groupCourse/types/{id}", groupCourseTypeHandler::getGroupCourseTypeById)
.POST("/api/groupCourse/types", groupCourseTypeHandler::createGroupCourseType)
.POST("/api/groupCourse/types/page", groupCourseTypeHandler::getGroupCourseTypesByPage)
.PUT("/api/groupCourse/types/{id}", groupCourseTypeHandler::updateGroupCourseType)
.DELETE("/api/groupCourse/types/{id}", groupCourseTypeHandler::deleteGroupCourseType)
@@ -313,6 +317,7 @@ public class SystemRouter {
.GET("/api/groupCourse/labels/search", courseLabelHandler::searchLabels)
.GET("/api/groupCourse/labels/{id}", courseLabelHandler::getLabelById)
.GET("/api/groupCourse/types/{typeId}/labels", courseLabelHandler::getLabelsByTypeId)
.POST("/api/groupCourse/labels/page", courseLabelHandler::getLabelsByPage)
.POST("/api/groupCourse/labels", courseLabelHandler::createLabel)
.PUT("/api/groupCourse/labels/{id}", courseLabelHandler::updateLabel)
.DELETE("/api/groupCourse/labels/{id}", courseLabelHandler::deleteLabel)
@@ -1,18 +1,18 @@
# 微信配置(测试环境使用模拟数据)
wechat:
# Mock模式:true=使用模拟数据(开发测试),false=调用真实微信API(生产环境)
mock-enabled: false
mock-enabled: true
miniapp:
app-id: ${WECHAT_MINIAPP_APP_ID}
app-secret: ${WECHAT_MINIAPP_SECRET}
app-id: ${WECHAT_MINIAPP_APP_ID:}
app-secret: ${WECHAT_MINIAPP_SECRET:}
mp:
app-id: ${WECHAT_MP_APP_ID}
app-secret: ${WECHAT_MP_SECRET}
token: ${WECHAT_MP_TOKEN}
aes-key: ${WECHAT_MP_AESKEY}
callback-url: ${WECHAT_MP_CALLBACK_URL}
app-id: ${WECHAT_MP_APP_ID:}
app-secret: ${WECHAT_MP_SECRET:}
token: ${WECHAT_MP_TOKEN:}
aes-key: ${WECHAT_MP_AESKEY:}
callback-url: ${WECHAT_MP_CALLBACK_URL:}
# 手机号加密配置(AES-128-CBC16字节密钥和IVBase64编码)
phone-encryption:
@@ -1,5 +1,9 @@
package cn.novalon.gym.manage.common.config;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.ReactiveRedisConnectionFactory;
@@ -8,6 +12,9 @@ import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSeriali
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
/**
* Redis 配置类(响应式版本)
*
@@ -17,20 +24,41 @@ import org.springframework.data.redis.serializer.StringRedisSerializer;
@Configuration
public class RedisConfig {
/**
* 创建支持 Java 8 时间类型与类型信息的 ObjectMapper,用于 Redis JSON 序列化
*/
private ObjectMapper createRedisObjectMapper() {
ObjectMapper mapper = new ObjectMapper();
JavaTimeModule javaTimeModule = new JavaTimeModule();
javaTimeModule.addSerializer(LocalDateTime.class,
new LocalDateTimeSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
mapper.registerModule(javaTimeModule);
mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
// 启用默认类型信息,确保反序列化时能还原为原始 Java 类型
mapper.activateDefaultTyping(
mapper.getPolymorphicTypeValidator(),
ObjectMapper.DefaultTyping.NON_FINAL
);
return mapper;
}
/**
* 配置 ReactiveRedisTemplate
*/
@Bean
public ReactiveRedisTemplate<String, Object> reactiveRedisTemplate(
ReactiveRedisConnectionFactory connectionFactory) {
GenericJackson2JsonRedisSerializer jsonSerializer =
new GenericJackson2JsonRedisSerializer(createRedisObjectMapper());
// 配置序列化上下文
RedisSerializationContext<String, Object> serializationContext =
RedisSerializationContext.<String, Object>newSerializationContext()
.key(StringRedisSerializer.UTF_8)
.value(new GenericJackson2JsonRedisSerializer())
.value(jsonSerializer)
.hashKey(StringRedisSerializer.UTF_8)
.hashValue(new GenericJackson2JsonRedisSerializer())
.hashValue(jsonSerializer)
.build();
return new ReactiveRedisTemplate<>(connectionFactory, serializationContext);
@@ -12,6 +12,8 @@ public class PageRequest {
private String sort = "id";
private String order = "asc";
private String keyword;
private String status;
private String category;
public int getPage() {
return page;
@@ -52,4 +54,20 @@ public class PageRequest {
public void setKeyword(String keyword) {
this.keyword = keyword;
}
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
public String getCategory() {
return category;
}
public void setCategory(String category) {
this.category = category;
}
}
@@ -1,5 +1,6 @@
package cn.novalon.gym.manage.common.util;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.ReactiveRedisTemplate;
import org.springframework.stereotype.Component;
@@ -13,6 +14,7 @@ import java.time.Duration;
* @author liwentao
* @date 2026/5/15
*/
@Slf4j
@Component
public class RedisUtil {
@@ -34,12 +36,19 @@ public class RedisUtil {
}
/**
* 获取值
* 获取值(带类型转换)
* filter+cast 替代 map 避免 NPEonErrorResume 兼容旧缓存格式反序列化失败
*/
@SuppressWarnings("unchecked")
public <T> Mono<T> get(String key, Class<T> clazz) {
return reactiveRedisTemplate.opsForValue().get(key)
.map(obj -> clazz.isInstance(obj) ? (T) obj : null);
.filter(clazz::isInstance)
.cast(clazz)
.onErrorResume(e -> {
// 旧缓存数据格式不兼容时静默跳过,后续逻辑会 fallback 到 DB 查询
log.warn("读取 Redis 缓存失败(可能为旧格式): key={}, error={}", key, e.getMessage());
return Mono.empty();
});
}
/**
@@ -1,7 +1,7 @@
-- ============================================================
-- V13: 整合所有测试数据(基于 2026-06-29 17:13
-- V13: 整合所有测试数据(基于 2026-07-14
-- 说明: 系统初始数据由 V2 处理,本文件仅包含业务测试数据
-- 所有时间相关字段已更新为基于 2026-06-29
-- 所有时间相关字段已更新为基于 2026-07-14
-- ============================================================
-- ============================================================
@@ -84,38 +84,38 @@ INSERT INTO member_card (member_card_name, member_card_type, member_card_price,
-- E1: 数据统计测试会员(V14,显式 ID 1001-1012
INSERT INTO member_user (id, member_no, nickname, phone, created_at, updated_at, is_deleted) VALUES
(1001, 'M20260629001', '张三', '13800138001', '2026-06-29 08:00:00', '2026-06-29 08:00:00', false),
(1002, 'M20260629002', '李四', '13800138002', '2026-06-29 09:00:00', '2026-06-29 09:00:00', false),
(1003, 'M20260628003', '王五', '13800138003', '2026-06-28 10:00:00', '2026-06-28 10:00:00', false),
(1004, 'M20260627004', '赵六', '13800138004', '2026-06-27 11:00:00', '2026-06-27 11:00:00', false),
(1005, 'M20260629005', '钱七', '13800138005', '2026-06-29 08:00:00', '2026-06-29 08:00:00', false),
(1006, 'M20260629006', '孙八', '13800138006', '2026-06-29 09:00:00', '2026-06-29 09:00:00', false),
(1007, 'M20260629007', '周九', '13800138007', '2026-06-29 10:00:00', '2026-06-29 10:00:00', false),
(1008, 'M20260626008', '吴十', '13800138008', '2026-06-26 14:00:00', '2026-06-26 14:00:00', false),
(1009, 'M20260625009', '郑十一', '13800138009', '2026-06-25 15:00:00', '2026-06-25 15:00:00', false),
(1010, 'M20260624010', '王十二', '13800138010', '2026-06-24 16:00:00', '2026-06-24 16:00:00', false),
(1011, 'M20260623011', '陈十三', '13800138011', '2026-06-23 17:00:00', '2026-06-23 17:00:00', false),
(1012, 'M20260622012', '刘十四', '13800138012', '2026-06-22 18:00:00', '2026-06-22 18:00:00', false);
(1001, 'M20260714001', '张三', '13800138001', '2026-07-14 08:00:00', '2026-07-14 08:00:00', false),
(1002, 'M20260714002', '李四', '13800138002', '2026-07-14 09:00:00', '2026-07-14 09:00:00', false),
(1003, 'M20260713003', '王五', '13800138003', '2026-07-13 10:00:00', '2026-07-13 10:00:00', false),
(1004, 'M20260712004', '赵六', '13800138004', '2026-07-12 11:00:00', '2026-07-12 11:00:00', false),
(1005, 'M20260714005', '钱七', '13800138005', '2026-07-14 08:00:00', '2026-07-14 08:00:00', false),
(1006, 'M20260714006', '孙八', '13800138006', '2026-07-14 09:00:00', '2026-07-14 09:00:00', false),
(1007, 'M20260714007', '周九', '13800138007', '2026-07-14 10:00:00', '2026-07-14 10:00:00', false),
(1008, 'M20260711008', '吴十', '13800138008', '2026-07-11 14:00:00', '2026-07-11 14:00:00', false),
(1009, 'M20260710009', '郑十一', '13800138009', '2026-07-10 15:00:00', '2026-07-10 15:00:00', false),
(1010, 'M20260709010', '王十二', '13800138010', '2026-07-09 16:00:00', '2026-07-09 16:00:00', false),
(1011, 'M20260708011', '陈十三', '13800138011', '2026-07-08 17:00:00', '2026-07-08 17:00:00', false),
(1012, 'M20260707012', '刘十四', '13800138012', '2026-07-07 18:00:00', '2026-07-07 18:00:00', false);
-- E2: 预约场景测试会员(V10: A-G)
INSERT INTO member_user (member_no, nickname, phone, gender, is_deleted, created_at, updated_at) VALUES
('MEM_TEST_A', '用户A_无卡新用户', '13800001001', 1, false, '2026-06-29 10:00:00', '2026-06-29 10:00:00'),
('MEM_TEST_B', '用户B_过期时长卡', '13800001002', 1, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00'),
('MEM_TEST_C', '会员C_有效时长卡', '13800001003', 2, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00'),
('MEM_TEST_D', '会员D_次数用尽', '13800001004', 1, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00'),
('MEM_TEST_E', '会员E_次数充足', '13800001005', 2, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00'),
('MEM_TEST_F', '会员F_储值卡余额不足', '13800001006', 1, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00'),
('MEM_TEST_G', '会员G_储值卡余额充足', '13800001007', 2, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00');
('MEM_TEST_A', '用户A_无卡新用户', '13800001001', 1, false, '2026-07-14 10:00:00', '2026-07-14 10:00:00'),
('MEM_TEST_B', '用户B_过期时长卡', '13800001002', 1, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00'),
('MEM_TEST_C', '会员C_有效时长卡', '13800001003', 2, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00'),
('MEM_TEST_D', '会员D_次数用尽', '13800001004', 1, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00'),
('MEM_TEST_E', '会员E_次数充足', '13800001005', 2, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00'),
('MEM_TEST_F', '会员F_储值卡余额不足', '13800001006', 1, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00'),
('MEM_TEST_G', '会员G_储值卡余额充足', '13800001007', 2, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00');
-- E3: 取消预约测试会员(V11: 张三/李四/王五)
INSERT INTO member_user (member_no, nickname, phone, gender, is_deleted, created_at, updated_at) VALUES
('MEM_TEST_ZHANG', '张三_时长卡用户', '13800002001', 1, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00'),
('MEM_TEST_LI', '李四_次数卡用户', '13800002002', 1, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00'),
('MEM_TEST_WANG', '王五_储值卡用户', '13800002003', 2, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00');
('MEM_TEST_ZHANG', '张三_时长卡用户', '13800002001', 1, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00'),
('MEM_TEST_LI', '李四_次数卡用户', '13800002002', 1, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00'),
('MEM_TEST_WANG', '王五_储值卡用户', '13800002003', 2, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00');
-- E4: 时间冲突测试会员(V12)
INSERT INTO member_user (member_no, nickname, phone, gender, is_deleted, created_at, updated_at) VALUES
('MEM_TIME_CONFLICT', '时间冲突测试会员', '13800009999', 1, false, '2026-06-28 10:00:00', '2026-06-28 10:00:00');
('MEM_TIME_CONFLICT', '时间冲突测试会员', '13800009999', 1, false, '2026-07-13 10:00:00', '2026-07-13 10:00:00');
-- ============================================================
-- Section F: 会员卡记录
@@ -123,67 +123,67 @@ INSERT INTO member_user (member_no, nickname, phone, gender, is_deleted, created
-- F1: V10 预约场景 - 6条会员卡记录
INSERT INTO member_card_record (member_id, member_card_id, status, remaining_times, remaining_amount, expire_time, purchase_time, version, card_composition, created_at, updated_at) VALUES
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_B'), (SELECT member_card_id FROM member_card WHERE member_card_name = '30天时长卡'), 'EXPIRED', 0, 0.00, '2026-06-28 23:59:59', '2026-05-29 10:00:00', 0, '{}', '2026-05-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_B'), (SELECT member_card_id FROM member_card WHERE member_card_name = '30天时长卡'), 'EXPIRED', 0, 0.00, '2026-07-13 23:59:59', '2026-06-13 10:00:00', 0, '{}', '2026-06-13 10:00:00', '2026-07-14 10:00:00');
INSERT INTO member_card_record (member_id, member_card_id, status, remaining_times, remaining_amount, expire_time, purchase_time, version, card_composition, created_at, updated_at) VALUES
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_C'), (SELECT member_card_id FROM member_card WHERE member_card_name = '30天时长卡'), 'ACTIVE', 0, 0.00, '2026-07-29 23:59:59', '2026-06-29 10:00:00', 0, '{}', '2026-06-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_C'), (SELECT member_card_id FROM member_card WHERE member_card_name = '30天时长卡'), 'ACTIVE', 0, 0.00, '2026-08-13 23:59:59', '2026-07-14 10:00:00', 0, '{}', '2026-07-14 10:00:00', '2026-07-14 10:00:00');
INSERT INTO member_card_record (member_id, member_card_id, status, remaining_times, remaining_amount, expire_time, purchase_time, version, card_composition, created_at, updated_at) VALUES
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_D'), (SELECT member_card_id FROM member_card WHERE member_card_name = '10次卡'), 'ACTIVE', 0, 0.00, '2026-12-31 23:59:59', '2026-05-29 10:00:00', 0, '{}', '2026-05-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_D'), (SELECT member_card_id FROM member_card WHERE member_card_name = '10次卡'), 'ACTIVE', 0, 0.00, '2026-12-31 23:59:59', '2026-06-13 10:00:00', 0, '{}', '2026-06-13 10:00:00', '2026-07-14 10:00:00');
INSERT INTO member_card_record (member_id, member_card_id, status, remaining_times, remaining_amount, expire_time, purchase_time, version, card_composition, created_at, updated_at) VALUES
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_E'), (SELECT member_card_id FROM member_card WHERE member_card_name = '10次卡'), 'ACTIVE', 5, 0.00, '2026-12-31 23:59:59', '2026-05-29 10:00:00', 0, '{}', '2026-05-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_E'), (SELECT member_card_id FROM member_card WHERE member_card_name = '10次卡'), 'ACTIVE', 5, 0.00, '2026-12-31 23:59:59', '2026-06-13 10:00:00', 0, '{}', '2026-06-13 10:00:00', '2026-07-14 10:00:00');
INSERT INTO member_card_record (member_id, member_card_id, status, remaining_times, remaining_amount, expire_time, purchase_time, version, card_composition, created_at, updated_at) VALUES
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_F'), (SELECT member_card_id FROM member_card WHERE member_card_name = '储值卡500'), 'ACTIVE', 0, 30.00, '2027-06-29 23:59:59', '2026-05-29 10:00:00', 0, '{}', '2026-05-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_F'), (SELECT member_card_id FROM member_card WHERE member_card_name = '储值卡500'), 'ACTIVE', 0, 30.00, '2027-07-14 23:59:59', '2026-06-13 10:00:00', 0, '{}', '2026-06-13 10:00:00', '2026-07-14 10:00:00');
INSERT INTO member_card_record (member_id, member_card_id, status, remaining_times, remaining_amount, expire_time, purchase_time, version, card_composition, created_at, updated_at) VALUES
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_G'), (SELECT member_card_id FROM member_card WHERE member_card_name = '储值卡500'), 'ACTIVE', 0, 200.00, '2027-06-29 23:59:59', '2026-05-29 10:00:00', 0, '{}', '2026-05-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_G'), (SELECT member_card_id FROM member_card WHERE member_card_name = '储值卡500'), 'ACTIVE', 0, 200.00, '2027-07-14 23:59:59', '2026-06-13 10:00:00', 0, '{}', '2026-06-13 10:00:00', '2026-07-14 10:00:00');
-- F2: V11 取消预约场景 - 3条
INSERT INTO member_card_record (member_id, member_card_id, status, remaining_times, remaining_amount, expire_time, purchase_time, version, card_composition, created_at, updated_at) VALUES
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_ZHANG'), (SELECT member_card_id FROM member_card WHERE member_card_name = '30天时长卡'), 'ACTIVE', 0, 0.00, '2026-07-29 23:59:59', '2026-06-29 10:00:00', 0, '{}', '2026-06-29 10:00:00', '2026-06-29 10:00:00'),
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_LI'), (SELECT member_card_id FROM member_card WHERE member_card_name = '10次卡'), 'ACTIVE', 5, 0.00, '2026-12-31 23:59:59', '2026-05-29 10:00:00', 0, '{}', '2026-05-29 10:00:00', '2026-06-29 10:00:00'),
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_WANG'), (SELECT member_card_id FROM member_card WHERE member_card_name = '储值卡500'), 'ACTIVE', 0, 200.00, '2027-06-29 23:59:59', '2026-05-29 10:00:00', 0, '{}', '2026-05-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_ZHANG'), (SELECT member_card_id FROM member_card WHERE member_card_name = '30天时长卡'), 'ACTIVE', 0, 0.00, '2026-08-13 23:59:59', '2026-07-14 10:00:00', 0, '{}', '2026-07-14 10:00:00', '2026-07-14 10:00:00'),
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_LI'), (SELECT member_card_id FROM member_card WHERE member_card_name = '10次卡'), 'ACTIVE', 5, 0.00, '2026-12-31 23:59:59', '2026-06-13 10:00:00', 0, '{}', '2026-06-13 10:00:00', '2026-07-14 10:00:00'),
((SELECT id FROM member_user WHERE member_no = 'MEM_TEST_WANG'), (SELECT member_card_id FROM member_card WHERE member_card_name = '储值卡500'), 'ACTIVE', 0, 200.00, '2027-07-14 23:59:59', '2026-06-13 10:00:00', 0, '{}', '2026-06-13 10:00:00', '2026-07-14 10:00:00');
-- F3: V12 时间冲突场景 - 1条
INSERT INTO member_card_record (member_id, member_card_id, status, remaining_times, remaining_amount, expire_time, purchase_time, version, card_composition, created_at, updated_at) VALUES
((SELECT id FROM member_user WHERE member_no = 'MEM_TIME_CONFLICT'), (SELECT member_card_id FROM member_card WHERE member_card_name = '10次卡'), 'ACTIVE', 10, 0.00, '2026-12-31 23:59:59', '2026-06-29 10:00:00', 0, '{}', '2026-06-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM member_user WHERE member_no = 'MEM_TIME_CONFLICT'), (SELECT member_card_id FROM member_card WHERE member_card_name = '10次卡'), 'ACTIVE', 10, 0.00, '2026-12-31 23:59:59', '2026-07-14 10:00:00', 0, '{}', '2026-07-14 10:00:00', '2026-07-14 10:00:00');
-- ============================================================
-- Section G: 团课课程(来源 V7 / V10 / V11 / V12 / V14,基于 2026-06-29
-- Section G: 团课课程(来源 V7 / V10 / V11 / V12 / V14,基于 2026-07-14
-- ============================================================
-- G1: V7 - 7种场景团课
INSERT INTO group_course (course_name, coach_id, course_type, start_time, end_time, max_members, current_members, status, location, cover_image, description, stored_value_amount, create_by, created_at, updated_at) VALUES
('极速燃脂单车', 104, 2, '2026-06-30 16:45:00', '2026-06-30 20:20:00', 25, 0, 0, '单车房', '/images/spinning.jpg', '跟随音乐节奏变换阻力和速度,体验爬坡与冲刺的快感。', 50.00, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00'),
('清晨流瑜伽', 101, 1, '2026-07-03 09:00:00', '2026-07-03 10:30:00', 15, 5, 0, 'A座3楼瑜伽教室', '/images/yoga_flow.jpg', '适合有一定基础的学员,通过流畅的体式连接呼吸。', 50.00, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00'),
('燃脂搏击', 102, 2, '2026-07-01 18:30:00', '2026-07-01 19:30:00', 20, 20, 0, '综合训练区', '/images/kickboxing.jpg', '高强度间歇训练,名额已满。', 50.00, 'coach_zhang', '2026-06-29 14:30:00', '2026-06-29 14:30:00'),
('哈他瑜伽', 101, 1, '2026-06-29 17:45:00', '2026-06-29 18:50:00', 12, 3, 0, '瑜伽教室B', '/images/hatha_yoga.jpg', '基础哈他瑜伽,距开始不足30分钟,已停止预约。', 50.00, 'coach_li', '2026-06-29 08:00:00', '2026-06-29 08:00:00'),
('周末冥想修复', 101, 1, '2026-07-11 15:00:00', '2026-07-11 16:00:00', 12, 3, 1, '冥想室', '/images/meditation.jpg', '通过呼吸和正念冥想,该课程已被取消。', 50.00, 'coach_wang', '2026-06-29 08:00:00', '2026-06-29 08:00:00'),
('蜜桃臀塑造', 103, 3, '2026-06-23 19:00:00', '2026-06-23 20:00:00', 10, 8, 2, '私教专区', '/images/glute.jpg', '针对性训练臀部肌肉群,课程已结束。', 50.00, 'coach_li', '2026-06-23 09:15:00', '2026-06-23 09:15:00'),
('午间冥想放松', 101, 1, '2026-06-25 12:00:00', '2026-06-25 13:00:00', 15, 6, 2, '冥想室', '/images/meditation_noon.jpg', '午间冥想课程,已结束。', 50.00, 'admin', '2026-06-25 09:00:00', '2026-06-25 09:00:00');
('极速燃脂单车', 104, 2, '2026-07-15 16:45:00', '2026-07-15 20:20:00', 25, 0, 0, '单车房', '/images/spinning.jpg', '跟随音乐节奏变换阻力和速度,体验爬坡与冲刺的快感。', 50.00, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00'),
('清晨流瑜伽', 101, 1, '2026-07-18 09:00:00', '2026-07-18 10:30:00', 15, 5, 0, 'A座3楼瑜伽教室', '/images/yoga_flow.jpg', '适合有一定基础的学员,通过流畅的体式连接呼吸。', 50.00, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00'),
('燃脂搏击', 102, 2, '2026-07-16 18:30:00', '2026-07-16 19:30:00', 20, 20, 0, '综合训练区', '/images/kickboxing.jpg', '高强度间歇训练,名额已满。', 50.00, 'coach_zhang', '2026-07-14 14:30:00', '2026-07-14 14:30:00'),
('哈他瑜伽', 101, 1, '2026-07-14 17:45:00', '2026-07-14 18:50:00', 12, 3, 0, '瑜伽教室B', '/images/hatha_yoga.jpg', '基础哈他瑜伽,距开始不足30分钟,已停止预约。', 50.00, 'coach_li', '2026-07-14 08:00:00', '2026-07-14 08:00:00'),
('周末冥想修复', 101, 1, '2026-07-26 15:00:00', '2026-07-26 16:00:00', 12, 3, 1, '冥想室', '/images/meditation.jpg', '通过呼吸和正念冥想,该课程已被取消。', 50.00, 'coach_wang', '2026-07-14 08:00:00', '2026-07-14 08:00:00'),
('蜜桃臀塑造', 103, 3, '2026-07-08 19:00:00', '2026-07-08 20:00:00', 10, 8, 2, '私教专区', '/images/glute.jpg', '针对性训练臀部肌肉群,课程已结束。', 50.00, 'coach_li', '2026-07-08 09:15:00', '2026-07-08 09:15:00'),
('午间冥想放松', 101, 1, '2026-07-10 12:00:00', '2026-07-10 13:00:00', 15, 6, 2, '冥想室', '/images/meditation_noon.jpg', '午间冥想课程,已结束。', 50.00, 'admin', '2026-07-10 09:00:00', '2026-07-10 09:00:00');
-- G2: V10 预约场景(已取消次数卡支付,仅保留储值卡)
INSERT INTO group_course (course_name, coach_id, course_type, start_time, end_time, max_members, current_members, status, location, description, stored_value_amount, create_by, created_at, updated_at) VALUES
('燃脂搏击_储值测试', 102, 2, '2026-07-01 19:30:00', '2026-07-01 20:30:00', 20, 0, 0, '综合训练区', '消耗储值50元', 50.00, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00'),
('高端普拉提_储值卡课程', 103, 1, '2026-07-02 19:00:00', '2026-07-02 20:00:00', 15, 0, 0, '普拉提教室', '消耗储值20元', 20.00, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00');
('燃脂搏击_储值测试', 102, 2, '2026-07-16 19:30:00', '2026-07-16 20:30:00', 20, 0, 0, '综合训练区', '消耗储值50元', 50.00, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00'),
('高端普拉提_储值卡课程', 103, 1, '2026-07-17 19:00:00', '2026-07-17 20:00:00', 15, 0, 0, '普拉提教室', '消耗储值20元', 20.00, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00');
-- G3: V11 取消预约场景
INSERT INTO group_course (course_name, coach_id, course_type, start_time, end_time, max_members, current_members, status, location, description, stored_value_amount, create_by, created_at, updated_at) VALUES
('晚间瑜伽_取消测试', 101, 1, '2026-07-02 19:00:00', '2026-07-02 20:00:00', 20, 0, 0, '瑜伽教室', '用于测试取消预约功能', 30.00, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00');
('晚间瑜伽_取消测试', 101, 1, '2026-07-17 19:00:00', '2026-07-17 20:00:00', 20, 0, 0, '瑜伽教室', '用于测试取消预约功能', 30.00, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00');
-- G4: V12 时间冲突场景
INSERT INTO group_course (course_name, coach_id, course_type, start_time, end_time, max_members, current_members, status, location, description, stored_value_amount, create_by, created_at, updated_at) VALUES
('时间冲突测试_A_13点-15点', 102, 2, '2026-07-01 13:00:00', '2026-07-01 15:00:00', 20, 0, 0, '综合训练区', '测试用团课A', 50.00, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00'),
('时间冲突测试_B_14点-16点', 103, 1, '2026-07-01 14:00:00', '2026-07-01 16:00:00', 15, 0, 0, '普拉提教室', '与团课A时间重叠', 50.00, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00'),
('时间冲突测试_C_10点-12点', 101, 1, '2026-07-01 10:00:00', '2026-07-01 12:00:00', 15, 0, 0, '瑜伽教室', '与A/B不冲突', 50.00, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00');
('时间冲突测试_A_13点-15点', 102, 2, '2026-07-16 13:00:00', '2026-07-16 15:00:00', 20, 0, 0, '综合训练区', '测试用团课A', 50.00, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00'),
('时间冲突测试_B_14点-16点', 103, 1, '2026-07-16 14:00:00', '2026-07-16 16:00:00', 15, 0, 0, '普拉提教室', '与团课A时间重叠', 50.00, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00'),
('时间冲突测试_C_10点-12点', 101, 1, '2026-07-16 10:00:00', '2026-07-16 12:00:00', 15, 0, 0, '瑜伽教室', '与A/B不冲突', 50.00, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00');
-- G5: V14 数据统计场景(今天 2026-06-29
-- G5: V14 数据统计场景(今天 2026-07-14
INSERT INTO group_course (id, course_name, coach_id, course_type, start_time, end_time, max_members, current_members, status, location, cover_image, description, stored_value_amount, created_at, updated_at) VALUES
(3001, '瑜伽入门', 1, 1, '2026-06-29 08:00:00', '2026-06-29 09:00:00', 20, 15, 0, '健身房A区', 'https://example.com/yoga.jpg', '适合初学者的瑜伽课程', 50.00, '2026-06-29 10:00:00', '2026-06-29 10:00:00'),
(3002, '动感单车', 2, 2, '2026-06-29 09:30:00', '2026-06-29 10:30:00', 25, 20, 0, '健身房B区', 'https://example.com/spinning.jpg', '高强度有氧运动', 50.00, '2026-06-29 11:00:00', '2026-06-29 11:00:00'),
(3003, '普拉提', 3, 1, '2026-06-29 14:00:00', '2026-06-29 15:00:00', 15, 10, 0, '健身房C区', 'https://example.com/pilates.jpg', '核心力量训练', 50.00, '2026-06-29 12:00:00', '2026-06-29 12:00:00');
(3001, '瑜伽入门', 1, 1, '2026-07-14 08:00:00', '2026-07-14 09:00:00', 20, 15, 0, '健身房A区', 'https://example.com/yoga.jpg', '适合初学者的瑜伽课程', 50.00, '2026-07-14 10:00:00', '2026-07-14 10:00:00'),
(3002, '动感单车', 2, 2, '2026-07-14 09:30:00', '2026-07-14 10:30:00', 25, 20, 0, '健身房B区', 'https://example.com/spinning.jpg', '高强度有氧运动', 50.00, '2026-07-14 11:00:00', '2026-07-14 11:00:00'),
(3003, '普拉提', 3, 1, '2026-07-14 14:00:00', '2026-07-14 15:00:00', 15, 10, 0, '健身房C区', 'https://example.com/pilates.jpg', '核心力量训练', 50.00, '2026-07-14 12:00:00', '2026-07-14 12:00:00');
-- ============================================================
-- Section H: 团课预约记录
@@ -191,116 +191,116 @@ INSERT INTO group_course (id, course_name, coach_id, course_type, start_time, en
-- H1: V11 取消预约测试
INSERT INTO group_course_booking (course_id, member_id, member_card_id, booking_time, status, course_name, course_start_time, course_end_time, location, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '晚间瑜伽_取消测试'), (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_ZHANG'), (SELECT id FROM member_card_record WHERE member_id = (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_ZHANG')), '2026-06-29 11:00:00', '0', '晚间瑜伽_取消测试', '2026-07-02 19:00:00', '2026-07-02 20:00:00', '瑜伽教室', '2026-06-29 11:00:00', '2026-06-29 11:00:00'),
((SELECT id FROM group_course WHERE course_name = '晚间瑜伽_取消测试'), (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_LI'), (SELECT id FROM member_card_record WHERE member_id = (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_LI')), '2026-06-29 11:30:00', '0', '晚间瑜伽_取消测试', '2026-07-02 19:00:00', '2026-07-02 20:00:00', '瑜伽教室', '2026-06-29 11:30:00', '2026-06-29 11:30:00'),
((SELECT id FROM group_course WHERE course_name = '晚间瑜伽_取消测试'), (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_WANG'), (SELECT id FROM member_card_record WHERE member_id = (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_WANG')), '2026-06-29 12:00:00', '0', '晚间瑜伽_取消测试', '2026-07-02 19:00:00', '2026-07-02 20:00:00', '瑜伽教室', '2026-06-29 12:00:00', '2026-06-29 12:00:00');
((SELECT id FROM group_course WHERE course_name = '晚间瑜伽_取消测试'), (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_ZHANG'), (SELECT id FROM member_card_record WHERE member_id = (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_ZHANG')), '2026-07-14 11:00:00', '0', '晚间瑜伽_取消测试', '2026-07-17 19:00:00', '2026-07-17 20:00:00', '瑜伽教室', '2026-07-14 11:00:00', '2026-07-14 11:00:00'),
((SELECT id FROM group_course WHERE course_name = '晚间瑜伽_取消测试'), (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_LI'), (SELECT id FROM member_card_record WHERE member_id = (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_LI')), '2026-07-14 11:30:00', '0', '晚间瑜伽_取消测试', '2026-07-17 19:00:00', '2026-07-17 20:00:00', '瑜伽教室', '2026-07-14 11:30:00', '2026-07-14 11:30:00'),
((SELECT id FROM group_course WHERE course_name = '晚间瑜伽_取消测试'), (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_WANG'), (SELECT id FROM member_card_record WHERE member_id = (SELECT id FROM member_user WHERE member_no = 'MEM_TEST_WANG')), '2026-07-14 12:00:00', '0', '晚间瑜伽_取消测试', '2026-07-17 19:00:00', '2026-07-17 20:00:00', '瑜伽教室', '2026-07-14 12:00:00', '2026-07-14 12:00:00');
UPDATE group_course SET current_members = current_members + 3 WHERE course_name = '晚间瑜伽_取消测试';
-- H2: V14 数据统计预约 - 今天(6月24日)
-- H2: V14 数据统计预约 - 今天(7月14日)
INSERT INTO group_course_booking (id, member_id, member_card_id, course_id, booking_time, status, created_at, updated_at) VALUES
(4001, 1001, 1, 3001, '2026-06-29 08:00:00', '2', '2026-06-23 20:00:00', '2026-06-29 08:30:00'),
(4002, 1002, 2, 3001, '2026-06-29 08:00:00', '2', '2026-06-23 21:00:00', '2026-06-29 08:30:00'),
(4003, 1003, 3, 3001, '2026-06-29 08:00:00', '3', '2026-06-23 22:00:00', '2026-06-29 09:00:00'),
(4004, 1004, 4, 3002, '2026-06-29 09:30:00', '2', '2026-06-23 19:00:00', '2026-06-29 09:30:00'),
(4005, 1005, 5, 3002, '2026-06-29 09:30:00', '1', '2026-06-23 20:30:00', '2026-06-29 09:00:00'),
(4006, 1006, 6, 3002, '2026-06-29 09:30:00', '2', '2026-06-23 21:30:00', '2026-06-29 09:30:00'),
(4007, 1007, 7, 3003, '2026-06-29 14:00:00', '2', '2026-06-23 22:30:00', '2026-06-29 14:00:00'),
(4008, 1008, 8, 3003, '2026-06-29 14:00:00', '3', '2026-06-29 08:00:00', '2026-06-29 14:00:00'),
(4009, 1009, 9, 3003, '2026-06-29 14:00:00', '2', '2026-06-29 09:00:00', '2026-06-29 14:00:00'),
(4010, 1010, 10, 3001, '2026-06-29 08:00:00', '2', '2026-06-29 07:00:00', '2026-06-29 08:00:00'),
(4011, 1011, 11, 3002, '2026-06-29 09:30:00', '1', '2026-06-29 08:30:00', '2026-06-29 09:00:00'),
(4012, 1012, 12, 3003, '2026-06-29 14:00:00', '2', '2026-06-29 10:00:00', '2026-06-29 14:00:00');
(4001, 1001, 1, 3001, '2026-07-14 08:00:00', '2', '2026-07-08 20:00:00', '2026-07-14 08:30:00'),
(4002, 1002, 2, 3001, '2026-07-14 08:00:00', '2', '2026-07-08 21:00:00', '2026-07-14 08:30:00'),
(4003, 1003, 3, 3001, '2026-07-14 08:00:00', '3', '2026-07-08 22:00:00', '2026-07-14 09:00:00'),
(4004, 1004, 4, 3002, '2026-07-14 09:30:00', '2', '2026-07-08 19:00:00', '2026-07-14 09:30:00'),
(4005, 1005, 5, 3002, '2026-07-14 09:30:00', '1', '2026-07-08 20:30:00', '2026-07-14 09:00:00'),
(4006, 1006, 6, 3002, '2026-07-14 09:30:00', '2', '2026-07-08 21:30:00', '2026-07-14 09:30:00'),
(4007, 1007, 7, 3003, '2026-07-14 14:00:00', '2', '2026-07-08 22:30:00', '2026-07-14 14:00:00'),
(4008, 1008, 8, 3003, '2026-07-14 14:00:00', '3', '2026-07-14 08:00:00', '2026-07-14 14:00:00'),
(4009, 1009, 9, 3003, '2026-07-14 14:00:00', '2', '2026-07-14 09:00:00', '2026-07-14 14:00:00'),
(4010, 1010, 10, 3001, '2026-07-14 08:00:00', '2', '2026-07-14 07:00:00', '2026-07-14 08:00:00'),
(4011, 1011, 11, 3002, '2026-07-14 09:30:00', '1', '2026-07-14 08:30:00', '2026-07-14 09:00:00'),
(4012, 1012, 12, 3003, '2026-07-14 14:00:00', '2', '2026-07-14 10:00:00', '2026-07-14 14:00:00');
-- H3: V14 数据统计预约 - 昨天(6月23日)
-- H3: V14 数据统计预约 - 昨天(7月13日)
INSERT INTO group_course_booking (id, member_id, member_card_id, course_id, booking_time, status, created_at, updated_at) VALUES
(4013, 1001, 1, 3001, '2026-06-23 08:00:00', '2', '2026-06-22 20:00:00', '2026-06-23 08:30:00'),
(4014, 1002, 2, 3001, '2026-06-23 08:00:00', '2', '2026-06-22 21:00:00', '2026-06-23 08:30:00'),
(4015, 1003, 3, 3002, '2026-06-23 09:30:00', '3', '2026-06-22 22:00:00', '2026-06-23 09:30:00'),
(4016, 1004, 4, 3002, '2026-06-23 09:30:00', '2', '2026-06-22 19:00:00', '2026-06-23 09:30:00'),
(4017, 1005, 5, 3003, '2026-06-23 14:00:00', '1', '2026-06-22 20:30:00', '2026-06-23 13:00:00'),
(4018, 1006, 6, 3003, '2026-06-23 14:00:00', '2', '2026-06-22 21:30:00', '2026-06-23 14:00:00');
(4013, 1001, 1, 3001, '2026-07-08 08:00:00', '2', '2026-07-07 20:00:00', '2026-07-08 08:30:00'),
(4014, 1002, 2, 3001, '2026-07-08 08:00:00', '2', '2026-07-07 21:00:00', '2026-07-08 08:30:00'),
(4015, 1003, 3, 3002, '2026-07-08 09:30:00', '3', '2026-07-07 22:00:00', '2026-07-08 09:30:00'),
(4016, 1004, 4, 3002, '2026-07-08 09:30:00', '2', '2026-07-07 19:00:00', '2026-07-08 09:30:00'),
(4017, 1005, 5, 3003, '2026-07-08 14:00:00', '1', '2026-07-07 20:30:00', '2026-07-08 13:00:00'),
(4018, 1006, 6, 3003, '2026-07-08 14:00:00', '2', '2026-07-07 21:30:00', '2026-07-08 14:00:00');
-- H4: V14 数据统计预约 - 前天(6月22日)
-- H4: V14 数据统计预约 - 前天(7月12日)
INSERT INTO group_course_booking (id, member_id, member_card_id, course_id, booking_time, status, created_at, updated_at) VALUES
(4019, 1001, 1, 3002, '2026-06-22 09:30:00', '2', '2026-06-21 20:00:00', '2026-06-22 09:30:00'),
(4020, 1002, 2, 3002, '2026-06-22 09:30:00', '2', '2026-06-21 21:00:00', '2026-06-22 09:30:00'),
(4021, 1003, 3, 3003, '2026-06-22 14:00:00', '2', '2026-06-21 22:00:00', '2026-06-22 14:00:00'),
(4022, 1004, 4, 3003, '2026-06-22 14:00:00', '3', '2026-06-21 19:00:00', '2026-06-22 14:00:00');
(4019, 1001, 1, 3002, '2026-07-07 09:30:00', '2', '2026-07-06 20:00:00', '2026-07-07 09:30:00'),
(4020, 1002, 2, 3002, '2026-07-07 09:30:00', '2', '2026-07-06 21:00:00', '2026-07-07 09:30:00'),
(4021, 1003, 3, 3003, '2026-07-07 14:00:00', '2', '2026-07-06 22:00:00', '2026-07-07 14:00:00'),
(4022, 1004, 4, 3003, '2026-07-07 14:00:00', '3', '2026-07-06 19:00:00', '2026-07-07 14:00:00');
-- ============================================================
-- Section I: 签到记录(来源 V14,基于 2026-06-29
-- Section I: 签到记录(来源 V14,基于 2026-07-14
-- ============================================================
INSERT INTO sign_in_record (id, member_id, sign_in_time, sign_in_type, sign_in_status, source, is_delete) VALUES
(2001, 1001, '2026-06-29 08:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2002, 1002, '2026-06-29 08:15:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2003, 1003, '2026-06-29 08:30:00', 'FACE', 'SUCCESS', 'MINI_PROGRAM', false),
(2004, 1004, '2026-06-29 09:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2005, 1005, '2026-06-29 09:15:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2006, 1006, '2026-06-29 09:30:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2007, 1007, '2026-06-29 10:00:00', 'FACE', 'SUCCESS', 'MINI_PROGRAM', false),
(2008, 1008, '2026-06-29 10:15:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2009, 1009, '2026-06-29 10:30:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2010, 1010, '2026-06-29 11:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2011, 1011, '2026-06-29 11:15:00', 'FACE', 'FAIL', 'MINI_PROGRAM', false),
(2012, 1012, '2026-06-29 11:30:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false);
(2001, 1001, '2026-07-14 08:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2002, 1002, '2026-07-14 08:15:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2003, 1003, '2026-07-14 08:30:00', 'FACE', 'SUCCESS', 'MINI_PROGRAM', false),
(2004, 1004, '2026-07-14 09:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2005, 1005, '2026-07-14 09:15:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2006, 1006, '2026-07-14 09:30:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2007, 1007, '2026-07-14 10:00:00', 'FACE', 'SUCCESS', 'MINI_PROGRAM', false),
(2008, 1008, '2026-07-14 10:15:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2009, 1009, '2026-07-14 10:30:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2010, 1010, '2026-07-14 11:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2011, 1011, '2026-07-14 11:15:00', 'FACE', 'FAIL', 'MINI_PROGRAM', false),
(2012, 1012, '2026-07-14 11:30:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false);
INSERT INTO sign_in_record (id, member_id, sign_in_time, sign_in_type, sign_in_status, source, is_delete) VALUES
(2013, 1001, '2026-06-23 07:30:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2014, 1002, '2026-06-23 08:00:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2015, 1003, '2026-06-23 08:30:00', 'FACE', 'SUCCESS', 'MINI_PROGRAM', false),
(2016, 1004, '2026-06-23 09:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2017, 1005, '2026-06-23 09:30:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2018, 1006, '2026-06-23 10:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2019, 1007, '2026-06-23 10:30:00', 'FACE', 'SUCCESS', 'MINI_PROGRAM', false),
(2020, 1008, '2026-06-23 11:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false);
(2013, 1001, '2026-07-08 07:30:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2014, 1002, '2026-07-08 08:00:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2015, 1003, '2026-07-08 08:30:00', 'FACE', 'SUCCESS', 'MINI_PROGRAM', false),
(2016, 1004, '2026-07-08 09:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2017, 1005, '2026-07-08 09:30:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2018, 1006, '2026-07-08 10:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2019, 1007, '2026-07-08 10:30:00', 'FACE', 'SUCCESS', 'MINI_PROGRAM', false),
(2020, 1008, '2026-07-08 11:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false);
INSERT INTO sign_in_record (id, member_id, sign_in_time, sign_in_type, sign_in_status, source, is_delete) VALUES
(2021, 1001, '2026-06-22 07:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2022, 1002, '2026-06-22 07:30:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2023, 1003, '2026-06-22 08:00:00', 'FACE', 'FAIL', 'MINI_PROGRAM', false),
(2024, 1004, '2026-06-22 08:30:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2025, 1005, '2026-06-22 09:00:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false);
(2021, 1001, '2026-07-07 07:00:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2022, 1002, '2026-07-07 07:30:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false),
(2023, 1003, '2026-07-07 08:00:00', 'FACE', 'FAIL', 'MINI_PROGRAM', false),
(2024, 1004, '2026-07-07 08:30:00', 'QR_CODE', 'SUCCESS', 'MINI_PROGRAM', false),
(2025, 1005, '2026-07-07 09:00:00', 'MANUAL', 'SUCCESS', 'PC_BACKEND', false);
-- ============================================================
-- Section J: 团课推荐测试数据(来源 V18,基于 2026-06-29
-- Section J: 团课推荐测试数据(来源 V18,基于 2026-07-14
-- ============================================================
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '极速燃脂单车'), '本周热门推荐', '极速燃脂单车课程,跟随音乐节奏变换阻力和速度,体验爬坡与冲刺的快感,一节课消耗800大卡!', '教练专业,课程内容丰富,深受学员喜爱,燃脂效果显著', 20, true, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM group_course WHERE course_name = '极速燃脂单车'), '本周热门推荐', '极速燃脂单车课程,跟随音乐节奏变换阻力和速度,体验爬坡与冲刺的快感,一节课消耗800大卡!', '教练专业,课程内容丰富,深受学员喜爱,燃脂效果显著', 20, true, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '清晨流瑜伽'), '新手友好推荐', '清晨流瑜伽课程,适合有一定基础的学员,通过流畅的体式连接呼吸,唤醒身体能量。', '适合新手入门,教练耐心指导,课程节奏适中', 15, true, 'admin', '2026-06-29 11:00:00', '2026-06-29 11:00:00');
((SELECT id FROM group_course WHERE course_name = '清晨流瑜伽'), '新手友好推荐', '清晨流瑜伽课程,适合有一定基础的学员,通过流畅的体式连接呼吸,唤醒身体能量。', '适合新手入门,教练耐心指导,课程节奏适中', 15, true, 'admin', '2026-07-14 11:00:00', '2026-07-14 11:00:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '燃脂搏击'), '高强度燃脂', '燃脂搏击课程,高强度间歇训练,配合音乐快速燃脂,释放压力。', '高强度训练,适合进阶学员,快速燃脂塑形', 10, false, 'admin', '2026-06-29 12:00:00', '2026-06-29 12:00:00');
((SELECT id FROM group_course WHERE course_name = '燃脂搏击'), '高强度燃脂', '燃脂搏击课程,高强度间歇训练,配合音乐快速燃脂,释放压力。', '高强度训练,适合进阶学员,快速燃脂塑形', 10, false, 'admin', '2026-07-14 12:00:00', '2026-07-14 12:00:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '哈他瑜伽'), '基础瑜伽推荐', '基础哈他瑜伽课程,适合所有级别学员,通过基础体式练习提升身体柔韧性和平衡能力。', '零基础友好,适合所有健身水平,放松身心', 12, true, 'coach_li', '2026-06-29 13:00:00', '2026-06-29 13:00:00');
((SELECT id FROM group_course WHERE course_name = '哈他瑜伽'), '基础瑜伽推荐', '基础哈他瑜伽课程,适合所有级别学员,通过基础体式练习提升身体柔韧性和平衡能力。', '零基础友好,适合所有健身水平,放松身心', 12, true, 'coach_li', '2026-07-14 13:00:00', '2026-07-14 13:00:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '蜜桃臀塑造'), '塑形热门课程', '蜜桃臀塑造课程,针对性训练臀部肌肉群,打造完美曲线。', '专业私教指导,动作标准,效果显著,深受女性学员喜爱', 18, true, 'coach_li', '2026-06-29 09:15:00', '2026-06-29 09:15:00');
((SELECT id FROM group_course WHERE course_name = '蜜桃臀塑造'), '塑形热门课程', '蜜桃臀塑造课程,针对性训练臀部肌肉群,打造完美曲线。', '专业私教指导,动作标准,效果显著,深受女性学员喜爱', 18, true, 'coach_li', '2026-07-14 09:15:00', '2026-07-14 09:15:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '午间冥想放松'), '午间放松推荐', '午间冥想放松课程,通过呼吸和正念冥想,深度放松身心,缓解工作压力。', '适合上班族,午间放松充电,提升下午工作效率', 8, true, 'admin', '2026-06-29 09:00:00', '2026-06-29 09:00:00');
((SELECT id FROM group_course WHERE course_name = '午间冥想放松'), '午间放松推荐', '午间冥想放松课程,通过呼吸和正念冥想,深度放松身心,缓解工作压力。', '适合上班族,午间放松充电,提升下午工作效率', 8, true, 'admin', '2026-07-14 09:00:00', '2026-07-14 09:00:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '极速燃脂单车'), '减脂首选课程', '想要快速减脂?极速燃脂单车是你的最佳选择!专业教练带领,科学训练计划。', '减脂效果最佳,课程强度适中,适合想要快速瘦身的学员', 16, true, 'coach_zhang', '2026-06-29 14:00:00', '2026-06-29 14:00:00');
((SELECT id FROM group_course WHERE course_name = '极速燃脂单车'), '减脂首选课程', '想要快速减脂?极速燃脂单车是你的最佳选择!专业教练带领,科学训练计划。', '减脂效果最佳,课程强度适中,适合想要快速瘦身的学员', 16, true, 'coach_zhang', '2026-07-14 14:00:00', '2026-07-14 14:00:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '清晨流瑜伽'), '晨练优选', '清晨流瑜伽,唤醒身体能量,开启活力一天!适合晨练爱好者。', '晨练最佳选择,提升身体活力,改善精神状态', 14, true, 'coach_wang', '2026-06-29 15:00:00', '2026-06-29 15:00:00');
((SELECT id FROM group_course WHERE course_name = '清晨流瑜伽'), '晨练优选', '清晨流瑜伽,唤醒身体能量,开启活力一天!适合晨练爱好者。', '晨练最佳选择,提升身体活力,改善精神状态', 14, true, 'coach_wang', '2026-07-14 15:00:00', '2026-07-14 15:00:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '哈他瑜伽'), '身心平衡推荐', '哈他瑜伽课程,通过体式练习和呼吸控制,达到身心平衡,提升整体健康水平。', '改善身体柔韧性,增强核心力量,提升身体协调性', 11, true, 'coach_li', '2026-06-29 16:00:00', '2026-06-29 16:00:00');
((SELECT id FROM group_course WHERE course_name = '哈他瑜伽'), '身心平衡推荐', '哈他瑜伽课程,通过体式练习和呼吸控制,达到身心平衡,提升整体健康水平。', '改善身体柔韧性,增强核心力量,提升身体协调性', 11, true, 'coach_li', '2026-07-14 16:00:00', '2026-07-14 16:00:00');
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
((SELECT id FROM group_course WHERE course_name = '午间冥想放松'), '职场减压课程', '午间冥想放松,专为职场人士设计,快速缓解工作压力,提升工作状态。', '职场减压首选,课程时间短,效果显著', 9, false, 'admin', '2026-06-29 10:00:00', '2026-06-29 10:00:00');
((SELECT id FROM group_course WHERE course_name = '午间冥想放松'), '职场减压课程', '午间冥想放松,专为职场人士设计,快速缓解工作压力,提升工作状态。', '职场减压首选,课程时间短,效果显著', 9, false, 'admin', '2026-07-14 10:00:00', '2026-07-14 10:00:00');
-- ============================================================
-- Section K: 统计说明
-- ============================================================
-- 今日(2026-06-29)统计预期:
-- 今日(2026-07-14)统计预期:
-- 新增会员: 3 (1005, 1006, 1007)
-- 签到会员: 12
-- 预约总数: 12 (4001-4012),取消: 2,出席: 8,缺席: 2
@@ -1,7 +1,7 @@
-- ============================================================
-- V23: 教练账号测试数据
-- 描述: 创建教练角色、教练用户及相关团课测试数据
-- 日期: 2026-06-22
-- 日期: 2026-07-14
-- ============================================================
-- ============================================================
@@ -4,7 +4,7 @@
-- 1. 新增测试教练用户 coachli(李教练)
-- 2. 为李教练分配教练角色(继承教练的有限权限)
-- 3. 为李教练分配未来一周的测试团课
-- 日期: 2026-06-22
-- 日期: 2026-07-14
-- ============================================================
-- ============================================================
@@ -0,0 +1,47 @@
-- ============================================
-- V28: 新增业务模块菜单
-- 描述: 为团课管理、团课类型、团课标签、团课推荐创建菜单项
-- ============================================
-- 团课管理一级菜单(目录)
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(400, '团课管理', 0, 4, 'M', NULL, NULL, 1, NOW(), NOW());
-- 团课管理子菜单(页面)
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(401, '团课管理', 400, 1, 'C', 'business:groupCourse:list', 'gymCourse/course/index', 1, NOW(), NOW()),
(402, '团课类型', 400, 2, 'C', 'business:groupCourseType:list', 'gymCourse/type/index', 1, NOW(), NOW()),
(403, '类型标签', 400, 3, 'C', 'business:groupCourseLabel:list', 'gymCourse/label/index', 1, NOW(), NOW()),
(404, '团课推荐', 400, 4, 'C', 'business:groupCourseRecommend:list', 'gymCourse/recommend/index', 1, NOW(), NOW());
-- 团课管理按钮权限
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(4011, '团课查询', 401, 1, 'F', 'business:groupCourse:query', NULL, 1, NOW(), NOW()),
(4012, '团课新增', 401, 2, 'F', 'business:groupCourse:add', NULL, 1, NOW(), NOW()),
(4013, '团课修改', 401, 3, 'F', 'business:groupCourse:edit', NULL, 1, NOW(), NOW()),
(4014, '团课删除', 401, 4, 'F', 'business:groupCourse:remove', NULL, 1, NOW(), NOW()),
(4015, '团课取消', 401, 5, 'F', 'business:groupCourse:cancel', NULL, 1, NOW(), NOW());
-- 团课类型按钮权限
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(4021, '类型查询', 402, 1, 'F', 'business:groupCourseType:query', NULL, 1, NOW(), NOW()),
(4022, '类型新增', 402, 2, 'F', 'business:groupCourseType:add', NULL, 1, NOW(), NOW()),
(4023, '类型修改', 402, 3, 'F', 'business:groupCourseType:edit', NULL, 1, NOW(), NOW()),
(4024, '类型删除', 402, 4, 'F', 'business:groupCourseType:remove', NULL, 1, NOW(), NOW());
-- 团课标签按钮权限
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(4031, '标签查询', 403, 1, 'F', 'business:groupCourseLabel:query', NULL, 1, NOW(), NOW()),
(4032, '标签新增', 403, 2, 'F', 'business:groupCourseLabel:add', NULL, 1, NOW(), NOW()),
(4033, '标签修改', 403, 3, 'F', 'business:groupCourseLabel:edit', NULL, 1, NOW(), NOW()),
(4034, '标签删除', 403, 4, 'F', 'business:groupCourseLabel:remove', NULL, 1, NOW(), NOW());
-- 团课推荐按钮权限
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(4041, '推荐查询', 404, 1, 'F', 'business:groupCourseRecommend:query', NULL, 1, NOW(), NOW()),
(4042, '推荐新增', 404, 2, 'F', 'business:groupCourseRecommend:add', NULL, 1, NOW(), NOW()),
(4043, '推荐修改', 404, 3, 'F', 'business:groupCourseRecommend:edit', NULL, 1, NOW(), NOW()),
(4044, '推荐删除', 404, 4, 'F', 'business:groupCourseRecommend:remove', NULL, 1, NOW(), NOW());
-- 重置菜单序列
SELECT setval('sys_menu_id_seq', (SELECT COALESCE(MAX(id), 1) FROM sys_menu));
@@ -0,0 +1,23 @@
-- ============================================
-- V29: 新增会员管理菜单
-- 描述: 为会员管理功能创建菜单项
-- ============================================
-- 会员管理一级菜单(目录)
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(500, '会员管理', 0, 5, 'M', NULL, NULL, 1, NOW(), NOW());
-- 会员管理子菜单(页面)
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(501, '会员管理', 500, 1, 'C', 'business:member:list', 'member/member/index', 1, NOW(), NOW());
-- 会员管理按钮权限
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(5011, '会员查询', 501, 1, 'F', 'business:member:query', NULL, 1, NOW(), NOW()),
(5012, '会员新增', 501, 2, 'F', 'business:member:add', NULL, 1, NOW(), NOW()),
(5013, '会员修改', 501, 3, 'F', 'business:member:edit', NULL, 1, NOW(), NOW()),
(5014, '会员删除', 501, 4, 'F', 'business:member:remove', NULL, 1, NOW(), NOW()),
(5015, '会员详情', 501, 5, 'F', 'business:member:detail', NULL, 1, NOW(), NOW());
-- 重置菜单序列
SELECT setval('sys_menu_id_seq', (SELECT COALESCE(MAX(id), 1) FROM sys_menu));
@@ -0,0 +1,22 @@
-- ============================================
-- V30: 新增会员卡管理菜单
-- 描述: 为会员卡管理功能创建菜单项
-- ============================================
-- 会员卡管理一级菜单(目录)
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(502, '会员卡管理', 0, 6, 'M', NULL, NULL, 1, NOW(), NOW());
-- 会员卡管理子菜单(页面)
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(503, '会员卡管理', 502, 1, 'C', 'business:memberCard:list', 'member/card/index', 1, NOW(), NOW());
-- 会员卡管理按钮权限
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(5031, '会员卡查询', 503, 1, 'F', 'business:memberCard:query', NULL, 1, NOW(), NOW()),
(5032, '会员卡新增', 503, 2, 'F', 'business:memberCard:add', NULL, 1, NOW(), NOW()),
(5033, '会员卡修改', 503, 3, 'F', 'business:memberCard:edit', NULL, 1, NOW(), NOW()),
(5034, '会员卡删除', 503, 4, 'F', 'business:memberCard:remove', NULL, 1, NOW(), NOW());
-- 重置菜单序列
SELECT setval('sys_menu_id_seq', (SELECT COALESCE(MAX(id), 1) FROM sys_menu));
@@ -0,0 +1,19 @@
-- ============================================
-- V31: 新增数据统计菜单
-- 描述: 为数据统计看板功能创建菜单项
-- ============================================
-- 数据统计一级菜单(目录)
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(504, '数据统计', 0, 7, 'M', NULL, NULL, 1, NOW(), NOW());
-- 数据统计子菜单(页面)
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(505, '数据统计看板', 504, 1, 'C', 'business:statistics:view', 'statistics/dashboard/index', 1, NOW(), NOW());
-- 数据统计按钮权限
INSERT INTO sys_menu (id, menu_name, parent_id, order_num, menu_type, perms, component, status, created_at, updated_at) VALUES
(5051, '数据统计导出', 505, 1, 'F', 'business:statistics:export', NULL, 1, NOW(), NOW());
-- 重置菜单序列
SELECT setval('sys_menu_id_seq', (SELECT COALESCE(MAX(id), 1) FROM sys_menu));
@@ -0,0 +1,8 @@
-- ============================================================
-- V32: 将 group_course_booking 表的 member_card_id 改为可空
-- 说明: 预约团课不再需要会员卡,member_card_id 允许为空
-- 日期: 2026-07-14
-- ============================================================
ALTER TABLE group_course_booking
ALTER COLUMN member_card_id DROP NOT NULL;
@@ -15,6 +15,17 @@ public interface ISysFileService {
Mono<SysFile> uploadFile(FilePart filePart, String username);
/**
* 保存字节数组为文件(用于服务端生成的文件,如二维码)
*
* @param content 文件字节内容
* @param filename 原始文件名
* @param contentType MIME类型
* @param username 操作用户名
* @return 保存后的文件信息
*/
Mono<SysFile> saveBytes(byte[] content, String filename, String contentType, String username);
Mono<Void> downloadFile(Long id);
Mono<Void> deleteFile(Long id);
@@ -29,6 +29,43 @@ public class SysFileServiceImpl implements ISysFileService {
this.uploadDir = uploadDir;
}
@Override
public Mono<SysFile> saveBytes(byte[] content, String filename, String contentType, String username) {
String fileExtension = filename.contains(".")
? filename.substring(filename.lastIndexOf("."))
: ".png";
String newFileName = UUID.randomUUID().toString() + fileExtension;
Path uploadPath = Paths.get(uploadDir);
return Mono.fromCallable(() -> {
if (!Files.exists(uploadPath)) {
Files.createDirectories(uploadPath);
}
return uploadPath;
})
.flatMap(path -> {
Path filePath = path.resolve(newFileName);
return Mono.fromCallable(() -> {
Files.write(filePath, content);
return filePath;
});
})
.flatMap(filePath -> Mono.fromCallable(() -> {
long fileSize = Files.size(filePath);
SysFile sysFile = new SysFile();
sysFile.setFileName(filename);
sysFile.setFilePath(filePath.toString());
sysFile.setFileSize(fileSize);
sysFile.setFileType(contentType != null ? contentType : "image/png");
sysFile.setStorageType("LOCAL");
sysFile.setCreateBy(username);
sysFile.setCreatedAt(LocalDateTime.now());
return sysFile;
}).flatMap(fileRepository::save));
}
@Override
public Flux<SysFile> getAllFiles() {
return fileRepository.findByDeletedAtIsNullOrderByCreatedAtDesc();
+6
View File
@@ -106,6 +106,12 @@
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
</dependency>
<!-- Fix commons-compress version for POI compatibility -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-compress</artifactId>
</dependency>
</dependencies>
<build>
+5
View File
@@ -213,6 +213,11 @@
<artifactId>poi-ooxml</artifactId>
<version>${poi.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-compress</artifactId>
<version>1.21</version>
</dependency>
</dependencies>
</dependencyManagement>
+268
View File
@@ -0,0 +1,268 @@
import request from '@/utils/request'
// ==================== 团课课程 ====================
export interface GroupCourse {
id?: number
courseName: string
coachId?: number
courseType?: number
startTime: string
endTime: string
maxMembers?: number
currentMembers?: number
status?: string
actualStartTime?: string
actualEndTime?: string
location?: string
coverImage?: string
description?: string
storedValueAmount?: number
qrCodePath?: string
createBy?: string
updateBy?: string
createdAt?: string
updatedAt?: string
}
export interface GroupCoursePageRequest {
page: number
size: number
keyword?: string
status?: string
courseType?: number
coachId?: number
startTime?: string
endTime?: string
sortBy?: string
sortOrder?: 'asc' | 'desc'
}
export interface PageResponse<T> {
content: T[]
totalElements: number
totalPages: number
size: number
number: number
first: boolean
last: boolean
}
export const groupCourseApi = {
getAll: () =>
request.get<GroupCourse[]>('/groupCourse/list'),
getPage: (params: GroupCoursePageRequest) =>
request.post<PageResponse<GroupCourse>>('/groupCourse/page', params),
getById: (id: number) =>
request.get<GroupCourse>(`/groupCourse/${id}`),
getDetailById: (id: number) =>
request.get<GroupCourse>(`/groupCourse/${id}/detail`),
create: (data: GroupCourse) =>
request.post<GroupCourse>('/groupCourse', data),
update: (id: number, data: GroupCourse) =>
request.put<GroupCourse>(`/groupCourse/${id}`, data),
delete: (id: number) =>
request.delete<void>(`/groupCourse/${id}`),
cancel: (id: number) =>
request.post<void>(`/groupCourse/${id}/cancel`),
search: (params: any) =>
request.post<GroupCourse[]>('/groupCourse/search', params),
}
// ==================== 团课类型 ====================
export interface GroupCourseType {
id?: number
typeName: string
baseDifficulty?: number
description?: string
category?: string
createBy?: string
updateBy?: string
createdAt?: string
updatedAt?: string
}
export interface GroupCourseTypePageRequest {
page: number
size: number
keyword?: string
category?: string
sort?: string
order?: 'asc' | 'desc'
}
export interface CourseLabelPageRequest {
page: number
size: number
keyword?: string
sort?: string
order?: 'asc' | 'desc'
}
export const groupCourseTypeApi = {
getAll: () =>
request.get<GroupCourseType[]>('/groupCourse/types'),
search: (params: any) =>
request.get<GroupCourseType[]>('/groupCourse/types/search', { params }),
getCategories: () =>
request.get<string[]>('/groupCourse/types/categories'),
getByCategory: (category: string) =>
request.get<GroupCourseType[]>(`/groupCourse/types/category/${encodeURIComponent(category)}`),
getById: (id: number) =>
request.get<GroupCourseType>(`/groupCourse/types/${id}`),
getPage: (params: GroupCourseTypePageRequest) =>
request.post<PageResponse<GroupCourseType>>('/groupCourse/types/page', params),
create: (data: GroupCourseType) =>
request.post<GroupCourseType>('/groupCourse/types', data),
update: (id: number, data: GroupCourseType) =>
request.put<GroupCourseType>(`/groupCourse/types/${id}`, data),
delete: (id: number) =>
request.delete<void>(`/groupCourse/types/${id}`),
}
// ==================== 团课标签 ====================
export interface CourseLabel {
id?: number
labelName: string
color?: string
description?: string
createBy?: string
updateBy?: string
createdAt?: string
updatedAt?: string
}
export const courseLabelApi = {
getAll: () =>
request.get<CourseLabel[]>('/groupCourse/labels'),
search: (params: any) =>
request.get<CourseLabel[]>('/groupCourse/labels/search', { params }),
getById: (id: number) =>
request.get<CourseLabel>(`/groupCourse/labels/${id}`),
getByTypeId: (typeId: number) =>
request.get<CourseLabel[]>(`/groupCourse/types/${typeId}/labels`),
getPage: (params: CourseLabelPageRequest) =>
request.post<PageResponse<CourseLabel>>('/groupCourse/labels/page', params),
create: (data: CourseLabel) =>
request.post<CourseLabel>('/groupCourse/labels', data),
update: (id: number, data: CourseLabel) =>
request.put<CourseLabel>(`/groupCourse/labels/${id}`, data),
delete: (id: number) =>
request.delete<void>(`/groupCourse/labels/${id}`),
addLabelsToType: (typeId: number, labelIds: number[]) =>
request.post<void>(`/groupCourse/types/${typeId}/labels`, { labelIds }),
removeLabelFromType: (typeId: number, labelId: number) =>
request.delete<void>(`/groupCourse/types/${typeId}/labels/${labelId}`),
clearLabelsFromType: (typeId: number) =>
request.delete<void>(`/groupCourse/types/${typeId}/labels`),
}
// ==================== 团课推荐 ====================
export interface GroupCourseRecommend {
id?: number
courseId: number
recommendTitle?: string
recommendContent?: string
recommendReason?: string
priority?: number
isActive?: boolean
createBy?: string
updateBy?: string
createdAt?: string
updatedAt?: string
}
export const groupCourseRecommendApi = {
getAll: () =>
request.get<GroupCourseRecommend[]>('/groupCourse/recommend/list'),
getActive: () =>
request.get<GroupCourseRecommend[]>('/groupCourse/recommend/active'),
getById: (id: number) =>
request.get<GroupCourseRecommend>(`/groupCourse/recommend/${id}`),
getByCourseId: (courseId: number) =>
request.get<GroupCourseRecommend[]>(`/groupCourse/recommend/course/${courseId}`),
create: (data: GroupCourseRecommend) =>
request.post<GroupCourseRecommend>('/groupCourse/recommend', data),
update: (id: number, data: GroupCourseRecommend) =>
request.put<GroupCourseRecommend>(`/groupCourse/recommend/${id}`, data),
delete: (id: number) =>
request.delete<void>(`/groupCourse/recommend/${id}`),
enable: (id: number) =>
request.post<void>(`/groupCourse/recommend/${id}/enable`),
disable: (id: number) =>
request.post<void>(`/groupCourse/recommend/${id}/disable`),
}
// ==================== 团课预约 ====================
export interface GroupCourseBooking {
id?: number
courseId: number
memberId: number
memberCardId: number
bookingTime?: string
status?: string
cancelTime?: string
courseName?: string
courseStartTime?: string
courseEndTime?: string
location?: string
createBy?: string
updateBy?: string
createdAt?: string
updatedAt?: string
}
export const groupCourseBookingApi = {
book: (data: GroupCourseBooking) =>
request.post<GroupCourseBooking>('/groupCourse/book', data),
cancel: (bookingId: number) =>
request.post<void>(`/groupCourse/booking/${bookingId}/cancel`),
getByMemberId: (memberId: number) =>
request.get<GroupCourseBooking[]>(`/groupCourse/bookings/member/${memberId}`),
getByCourseId: (courseId: number) =>
request.get<GroupCourseBooking[]>(`/groupCourse/bookings/course/${courseId}`),
getById: (bookingId: number) =>
request.get<GroupCourseBooking>(`/groupCourse/bookings/${bookingId}`),
}
+107
View File
@@ -0,0 +1,107 @@
import request from '@/utils/request'
// ==================== 会员基础信息 ====================
export interface Member {
id?: number | string
memberNo?: string
nickname?: string
phone?: string
gender?: number
genderDesc?: string
avatar?: string
createdAt?: string
updatedAt?: string
}
export interface MemberDetail {
id?: number
memberNo?: string
nickname?: string
phone?: string
gender?: number
genderDesc?: string
birthday?: string
address?: string
avatar?: string
subscribed?: boolean
lastLoginAt?: string
createdAt?: string
memberCards?: MemberCardInfo[]
activeCardCount?: number
inactiveCardCount?: number
}
export interface MemberCardInfo {
id?: number
memberCardId?: number
memberCardName?: string
memberCardType?: string
memberCardTypeDesc?: string
memberCardPrice?: number
memberCardValidityDays?: number
memberCardTotalTimes?: number
memberCardAmount?: number
memberCardStatus?: string
memberCardStatusDesc?: string
extraConfig?: string
createdAt?: string
updatedAt?: string
}
export interface MemberCardRecord {
id?: number
memberCardRecordId?: number
memberId?: number
memberCardId?: number
memberCardName?: string
memberCardType?: string
memberCardPrice?: number
memberCardValidityDays?: number
memberCardTotalTimes?: number
status?: string
remainingTimes?: number
remainingAmount?: number
expireTime?: string
purchaseTime?: string
}
export interface UpdateMemberDto {
nickname?: string
gender?: string
birthday?: string
avatar?: string
address?: string
}
export interface UpdatePhoneDto {
phone: string
}
export const memberApi = {
/** 搜索会员 */
search: (params: { searchValue?: string; pageNum?: number; pageSize?: number }) =>
request.get<Member[]>('/admin/members', { params }),
/** 获取所有会员 */
getAll: (params: { pageNum?: number; pageSize?: number; sortField?: string; sortOrder?: string }) =>
request.get<Member[]>('/admin/members/all', { params }),
/** 获取会员详情 */
getDetail: (id: number) =>
request.get<MemberDetail>(`/admin/member/${id}`),
/** 更新会员信息 */
update: (id: number, data: UpdateMemberDto) =>
request.put<void>(`/admin/member/${id}`, data),
/** 管理员更新会员手机号 */
updatePhone: (id: number, data: UpdatePhoneDto) =>
request.post<void>(`/admin/member/${id}/phone`, data),
/** 获取会员绑定的会员卡记录 */
getMemberCardRecords: (memberId: number) =>
request.get<MemberCardRecord[]>(`/member-card-records/my-cards-with-status/${memberId}`, {
params: { status: 'all' },
}),
}
+54
View File
@@ -0,0 +1,54 @@
import request from '@/utils/request'
// ==================== 会员卡类型 ====================
export interface MemberCardType {
id?: number
memberCardId?: number
memberCardName?: string
memberCardType?: string
memberCardTypeDesc?: string
memberCardPrice?: number
memberCardValidityDays?: number
memberCardTotalTimes?: number
memberCardAmount?: number
memberCardStatus?: number
memberCardStatusDesc?: string
extraConfig?: string
createdAt?: string
updatedAt?: string
}
export interface MemberCardPageParams {
status?: number
name?: string
type?: string
page?: number
size?: number
}
export const memberCardApi = {
/** 查询会员卡类型列表(分页+条件) */
list: (params: MemberCardPageParams) =>
request.get<MemberCardType[]>('/member-cards', { params }),
/** 查询上架中的会员卡类型 */
getActiveCards: (status?: number) =>
request.get<MemberCardType[]>('/member-cards/active', { params: { status } }),
/** 根据ID查询会员卡类型 */
getById: (memberCardId: number) =>
request.get<MemberCardType>(`/member-cards/${memberCardId}`),
/** 创建会员卡类型 */
create: (data: MemberCardType) =>
request.post<MemberCardType>('/member-cards', data),
/** 更新会员卡类型 */
update: (id: number, data: MemberCardType) =>
request.put<void>(`/member-cards/${id}`, data),
/** 删除会员卡类型 */
delete: (id: number) =>
request.delete<void>(`/member-cards/${id}`),
}
+100
View File
@@ -0,0 +1,100 @@
import request from '@/utils/request'
// ========== 接口类型定义 ==========
export interface MemberStatistics {
statDate: string
newMembers: number
activeMembers: number
totalMembers: number
signInMembers: number
bookingMembers: number
cancelBookingMembers: number
}
export interface BookingStatistics {
statDate: string
newBookings: number
cancelBookings: number
attendBookings: number
absentBookings: number
attendanceRate: number
cancelRate: number
bookingMembers: number
cancelMembers: number
}
export interface SignInStatistics {
statDate: string
totalSignIns: number
successSignIns: number
failedSignIns: number
successRate: number
signInMembers: number
qrCodeSignIns: number
manualSignIns: number
faceSignIns: number
}
export interface StatisticsSummary {
statDate: string
memberStatistics: MemberStatistics
bookingStatistics: BookingStatistics
signInStatistics: SignInStatistics
generatedAt: string
}
export interface HistoryRecord {
statType: string
periodType: string
statDate: string
count: number
relatedId: number
extraData: string
}
export interface StatisticsQuery {
statType?: string
periodType?: string
startTime?: string
endTime?: string
page?: number
size?: number
}
// ========== API ==========
export const statisticsApi = {
/** 获取综合统计摘要 */
getSummary(params?: StatisticsQuery) {
return request.get<any, StatisticsSummary>('/datacount/summary', { params })
},
/** 获取会员统计 */
getMember(params?: StatisticsQuery) {
return request.get<any, MemberStatistics>('/datacount/member', { params })
},
/** 获取预约统计 */
getBooking(params?: StatisticsQuery) {
return request.get<any, BookingStatistics>('/datacount/booking', { params })
},
/** 获取签到统计 */
getSignIn(params?: StatisticsQuery) {
return request.get<any, SignInStatistics>('/datacount/signin', { params })
},
/** 查询历史统计数据 */
getHistory(params?: StatisticsQuery) {
return request.get<any, HistoryRecord[]>('/datacount/history', { params })
},
/** 导出统计报表 (Excel) */
exportStatistics(params?: StatisticsQuery) {
return request.get('/datacount/export', {
params,
responseType: 'blob',
})
},
}
+9 -9
View File
@@ -97,15 +97,15 @@ onMounted(async () => {
if (!token) {
router.push('/login')
} else if (!permissionStore.loaded) {
permissionStore.initFromStorage()
if (!permissionStore.loaded || permissionStore.menus.length === 0) {
try {
await permissionStore.fetchUserMenus()
} catch (error) {
console.error('获取用户菜单失败:', error)
}
} else {
// 先尝试从 localStorage 快速恢复,再异步获取最新菜单
if (!permissionStore.loaded) {
permissionStore.initFromStorage()
}
try {
await permissionStore.fetchUserMenus()
} catch (error) {
console.error('获取用户菜单失败:', error)
}
}
})
+42
View File
@@ -93,6 +93,48 @@ const routes: RouteRecordRaw[] = [
name: 'ExceptionLog',
component: () => import('@/views/audit/ExceptionLog.vue'),
meta: { title: '异常日志' }
},
{
path: 'courses',
name: 'GroupCourseManagement',
component: () => import('@/views/groupcourse/GroupCourseManagement.vue'),
meta: { title: '团课管理' }
},
{
path: 'courses/types',
name: 'CourseTypeManagement',
component: () => import('@/views/groupcourse/CourseTypeManagement.vue'),
meta: { title: '团课类型' }
},
{
path: 'courses/labels',
name: 'CourseLabelManagement',
component: () => import('@/views/groupcourse/CourseLabelManagement.vue'),
meta: { title: '团课标签' }
},
{
path: 'courses/recommend',
name: 'CourseRecommendManagement',
component: () => import('@/views/groupcourse/CourseRecommendManagement.vue'),
meta: { title: '团课推荐' }
},
{
path: 'members',
name: 'MemberManagement',
component: () => import('@/views/member/MemberManagement.vue'),
meta: { title: '会员管理' }
},
{
path: 'member-cards',
name: 'MemberCardManagement',
component: () => import('@/views/member/MemberCardManagement.vue'),
meta: { title: '会员卡管理' }
},
{
path: 'statistics',
name: 'StatisticsDashboard',
component: () => import('@/views/statistics/StatisticsDashboard.vue'),
meta: { title: '数据统计看板' }
}
]
}
+15 -1
View File
@@ -38,6 +38,13 @@ function transformMenuData(backendMenus: BackendMenuItem[]): MenuItem[] {
'audit/operation/index': '/oplog',
'audit/login/index': '/loginlog',
'audit/exception/index': '/exceptionlog',
'gymCourse/course/index': '/courses',
'gymCourse/type/index': '/courses/types',
'gymCourse/label/index': '/courses/labels',
'gymCourse/recommend/index': '/courses/recommend',
'member/member/index': '/members',
'member/card/index': '/member-cards',
'statistics/dashboard/index': '/statistics',
}
const filteredMenus = backendMenus.filter(menu => menu.menuType !== 'F')
@@ -92,7 +99,14 @@ function getMenuIcon(menuName: string): string {
'文件管理': 'Folder',
'操作日志': 'Document',
'登录日志': 'Document',
'异常日志': 'Warning'
'异常日志': 'Warning',
'团课管理': 'TrophyBase',
'团课类型': 'Grid',
'团课标签': 'Discount',
'团课推荐': 'Star',
'会员管理': 'Avatar',
'会员卡管理': 'CreditCard',
'数据统计': 'DataAnalysis',
}
return iconMap[menuName] || 'Document'
}
@@ -0,0 +1,274 @@
<template>
<div class="course-label-management">
<el-card>
<template #header>
<div class="card-header">
<div class="search-section">
<el-input
v-model="searchKeyword"
placeholder="搜索标签名称"
clearable
style="width: 240px"
@clear="handleSearch"
@keyup.enter="handleSearch"
>
<template #prefix>
<el-icon><Search /></el-icon>
</template>
</el-input>
<el-button type="primary" @click="handleSearch">
搜索
</el-button>
</div>
<el-button type="primary" @click="handleAdd">
新增标签
</el-button>
</div>
</template>
<el-table
v-loading="loading"
:data="dataSource"
style="width: 100%"
>
<el-table-column prop="id" label="ID" width="80" />
<el-table-column prop="labelName" label="标签名称" min-width="140">
<template #default="{ row }">
<el-tag
:color="row.color"
effect="dark"
style="font-weight: 500; font-size: 14px; border-color: transparent;"
>
{{ row.labelName }}
</el-tag>
</template>
</el-table-column>
<el-table-column prop="color" label="颜色" width="100">
<template #default="{ row }">
<div style="display: flex; align-items: center; gap: 6px;">
<span
:style="{
display: 'inline-block',
width: '16px',
height: '16px',
borderRadius: '4px',
backgroundColor: row.color,
border: '1px solid #ddd',
}"
/>
<span>{{ row.color }}</span>
</div>
</template>
</el-table-column>
<el-table-column prop="description" label="描述" min-width="200" show-overflow-tooltip />
<el-table-column label="操作" width="150" fixed="right">
<template #default="{ row }">
<el-button type="primary" link size="small" @click="handleEdit(row)">
编辑
</el-button>
<el-button type="danger" link size="small" @click="handleDelete(row)">
删除
</el-button>
</template>
</el-table-column>
</el-table>
<el-pagination
v-model:current-page="currentPage"
v-model:page-size="pageSize"
:total="total"
:page-sizes="[10, 20, 50]"
layout="total, sizes, prev, pager, next, jumper"
background
style="margin-top: 16px; justify-content: flex-end"
@size-change="onSizeChange"
@current-change="onPageChange"
/>
</el-card>
<el-dialog
v-model="modalVisible"
:title="modalTitle"
width="500px"
>
<el-form
ref="formRef"
:model="formState"
:rules="formRules"
label-width="100px"
>
<el-form-item label="标签名称" prop="labelName">
<el-input v-model="formState.labelName" placeholder="请输入标签名称" />
</el-form-item>
<el-form-item label="标签颜色" prop="color">
<el-color-picker v-model="formState.color" show-alpha />
<span style="margin-left: 8px; color: #909399;">{{ formState.color }}</span>
</el-form-item>
<el-form-item label="描述">
<el-input
v-model="formState.description"
type="textarea"
:rows="3"
placeholder="请输入标签描述"
/>
</el-form-item>
</el-form>
<template #footer>
<el-button @click="modalVisible = false">取消</el-button>
<el-button type="primary" @click="handleModalOk">确定</el-button>
</template>
</el-dialog>
</div>
</template>
<script setup lang="ts">
import { ref, reactive, onMounted } from 'vue'
import { ElMessage, ElMessageBox } from 'element-plus'
import { Search } from '@element-plus/icons-vue'
import { courseLabelApi, type CourseLabel, type CourseLabelPageRequest } from '@/api/groupCourse.api'
const loading = ref(false)
const dataSource = ref<CourseLabel[]>([])
const searchKeyword = ref('')
const currentPage = ref(1)
const pageSize = ref(10)
const total = ref(0)
const modalVisible = ref(false)
const modalTitle = ref('')
const formRef = ref()
const formState = reactive<CourseLabel>({
labelName: '',
color: '#1890ff',
description: '',
})
const formRules = {
labelName: [
{ required: true, message: '请输入标签名称', trigger: 'blur' },
{ min: 2, max: 50, message: '标签名称长度在 2 到 50 个字符', trigger: 'blur' },
],
color: [{ required: true, message: '请选择标签颜色', trigger: 'change' }],
}
const fetchData = async () => {
loading.value = true
try {
const params: CourseLabelPageRequest = {
page: currentPage.value - 1,
size: pageSize.value,
sort: 'id',
order: 'asc',
}
if (searchKeyword.value) params.keyword = searchKeyword.value
const res = await courseLabelApi.getPage(params)
dataSource.value = res.content
total.value = Number(res.totalElements)
} catch {
ElMessage.error('加载数据失败')
} finally {
loading.value = false
}
}
const onPageChange = () => fetchData()
const onSizeChange = () => {
currentPage.value = 1
fetchData()
}
const handleSearch = () => {
currentPage.value = 1
fetchData()
}
const handleAdd = () => {
modalTitle.value = '新增标签'
Object.assign(formState, {
id: undefined,
labelName: '',
color: '#1890ff',
description: '',
})
modalVisible.value = true
}
const handleEdit = (row: CourseLabel) => {
modalTitle.value = '编辑标签'
Object.assign(formState, { ...row })
modalVisible.value = true
}
const handleDelete = async (row: CourseLabel) => {
try {
await ElMessageBox.confirm('确定要删除该标签吗?', '提示', {
confirmButtonText: '确定',
cancelButtonText: '取消',
type: 'warning',
})
await courseLabelApi.delete(row.id!)
ElMessage.success('删除成功')
fetchData()
} catch (error) {
if (error !== 'cancel') {
ElMessage.error('删除失败')
}
}
}
const handleModalOk = async () => {
if (!formRef.value) return
try {
await formRef.value.validate()
// Convert RGBA to hex before submitting
const data = { ...formState }
if (data.color?.startsWith('rgba')) {
data.color = rgbaToHex(data.color)
}
if (formState.id) {
await courseLabelApi.update(formState.id, data)
} else {
await courseLabelApi.create(data)
}
ElMessage.success('操作成功')
modalVisible.value = false
fetchData()
} catch (error) {
if (error !== 'cancel') {
ElMessage.error('操作失败')
}
}
}
/** Convert rgba(r, g, b, a) to #rrggbb or #rrggbbaa hex */
const rgbaToHex = (rgba: string): string => {
const match = rgba.match(/[\d.]+/g)
if (!match || match.length < 3) return rgba
const r = parseInt(match[0])
const g = parseInt(match[1])
const b = parseInt(match[2])
const a = match.length >= 4 ? Math.round(parseFloat(match[3]) * 255) : 255
const toHex = (n: number) => n.toString(16).padStart(2, '0')
const hex = `#${toHex(r)}${toHex(g)}${toHex(b)}`
return a < 255 ? `${hex}${toHex(a)}` : hex
}
onMounted(() => fetchData())
</script>
<style scoped lang="css">
.course-label-management {
.card-header {
display: flex;
justify-content: space-between;
align-items: center;
gap: 16px;
.search-section {
display: flex;
gap: 8px;
align-items: center;
}
}
}
</style>
@@ -0,0 +1,331 @@
<template>
<div class="course-recommend-management">
<el-card>
<template #header>
<div class="card-title">
<span>团课推荐管理</span>
<div class="header-actions">
<el-button size="small" @click="resetSort">恢复默认排序</el-button>
<el-button type="primary" @click="handleAdd">新增推荐</el-button>
</div>
</div>
</template>
<el-table
ref="tableRef"
v-loading="loading"
:data="sortedData"
style="width: 100%"
@sort-change="onSortChange"
>
<el-table-column prop="id" label="ID" width="100" sortable="custom" />
<el-table-column prop="courseName" label="团课名称" min-width="160" show-overflow-tooltip sortable="custom">
<template #default="{ row }">
{{ courseMap[row.courseId] || `课程 #${row.courseId}` }}
</template>
</el-table-column>
<el-table-column prop="recommendTitle" label="推荐标题" min-width="160" show-overflow-tooltip />
<el-table-column prop="priority" label="优先级" width="100" sortable="custom">
<template #default="{ row }">
<el-tag
:type="row.priority >= 5 ? 'danger' : row.priority >= 3 ? 'warning' : 'info'"
effect="dark"
style="font-weight: 500; font-size: 14px;"
>
{{ row.priority }}
</el-tag>
</template>
</el-table-column>
<el-table-column label="启用状态" width="100">
<template #default="{ row }">
<el-tag
:type="row.isActive ? 'success' : 'danger'"
effect="dark"
style="font-weight: 500; font-size: 14px;"
>
{{ row.isActive ? '启用' : '停用' }}
</el-tag>
</template>
</el-table-column>
<el-table-column prop="recommendReason" label="推荐理由" min-width="180" show-overflow-tooltip />
<el-table-column prop="createdAt" label="创建时间" width="170" sortable="custom">
<template #default="{ row }">
{{ formatTime(row.createdAt) }}
</template>
</el-table-column>
<el-table-column label="操作" width="280" fixed="right">
<template #default="{ row }">
<el-button type="primary" link size="small" @click="handleEdit(row)">
编辑
</el-button>
<el-button
v-if="row.isActive"
type="warning"
link
size="small"
@click="handleToggleActive(row)"
>
停用
</el-button>
<el-button
v-else
type="success"
link
size="small"
@click="handleToggleActive(row)"
>
启用
</el-button>
<el-button type="danger" link size="small" @click="handleDelete(row)">
删除
</el-button>
</template>
</el-table-column>
</el-table>
</el-card>
<el-dialog
v-model="modalVisible"
:title="modalTitle"
width="550px"
>
<el-form
ref="formRef"
:model="formState"
:rules="formRules"
label-width="100px"
>
<el-form-item label="关联团课" prop="courseId">
<el-select
v-model="formState.courseId"
filterable
placeholder="请选择团课"
style="width: 100%"
>
<el-option
v-for="course in courseList"
:key="course.id"
:value="course.id!"
:label="course.courseName"
/>
</el-select>
</el-form-item>
<el-form-item label="推荐标题" prop="recommendTitle">
<el-input v-model="formState.recommendTitle" placeholder="请输入推荐标题" />
</el-form-item>
<el-form-item label="推荐内容">
<el-input
v-model="formState.recommendContent"
type="textarea"
:rows="3"
placeholder="请输入推荐内容"
/>
</el-form-item>
<el-form-item label="推荐理由">
<el-input
v-model="formState.recommendReason"
type="textarea"
:rows="2"
placeholder="请输入推荐理由"
/>
</el-form-item>
<el-form-item label="优先级" prop="priority">
<el-input-number v-model="formState.priority" :min="0" :max="20" style="width: 100%" />
</el-form-item>
</el-form>
<template #footer>
<el-button @click="modalVisible = false">取消</el-button>
<el-button type="primary" @click="handleModalOk">确定</el-button>
</template>
</el-dialog>
</div>
</template>
<script setup lang="ts">
import { ref, reactive, computed, onMounted } from 'vue'
import { ElMessage, ElMessageBox } from 'element-plus'
import { groupCourseRecommendApi, groupCourseApi, type GroupCourseRecommend, type GroupCourse } from '@/api/groupCourse.api'
const loading = ref(false)
const dataSource = ref<GroupCourseRecommend[]>([])
const courseMap = ref<Record<number, string>>({})
const courseList = ref<GroupCourse[]>([])
const sortState = ref<{ prop: string; order: 'ascending' | 'descending' | null }>({ prop: 'priority', order: 'descending' })
const sortedData = computed(() => {
const list = [...dataSource.value]
const { prop, order } = sortState.value
if (!order) return list
const dir = order === 'ascending' ? 1 : -1
const getName = (courseId: number) => courseMap.value[courseId] || ''
switch (prop) {
case 'id':
return list.sort((a, b) => ((a.id || 0) - (b.id || 0)) * dir)
case 'priority':
return list.sort((a, b) => ((a.priority || 0) - (b.priority || 0)) * dir)
case 'courseName':
return list.sort((a, b) => getName(a.courseId).localeCompare(getName(b.courseId), 'zh') * dir)
case 'createdAt':
return list.sort((a, b) => (a.createdAt || '').localeCompare(b.createdAt || '') * dir)
default:
return list
}
})
const onSortChange = ({ prop, order }: { prop: string; order: 'ascending' | 'descending' | null }) => {
sortState.value = { prop, order }
}
const tableRef = ref()
const resetSort = () => {
tableRef.value?.clearSort()
sortState.value = { prop: 'priority', order: 'descending' }
// Re-apply default sort arrows on the table
tableRef.value?.sort('priority', 'descending')
}
const formatTime = (time?: string) => {
if (!time) return '-'
return new Date(time).toLocaleString('zh-CN', {
year: 'numeric', month: '2-digit', day: '2-digit',
hour: '2-digit', minute: '2-digit',
})
}
const modalVisible = ref(false)
const modalTitle = ref('')
const formRef = ref()
const formState = reactive<GroupCourseRecommend>({
courseId: 0,
recommendTitle: '',
recommendContent: '',
recommendReason: '',
priority: 0,
isActive: true,
})
const formRules = {
courseId: [{ required: true, message: '请选择团课', trigger: 'change' }],
recommendTitle: [
{ required: true, message: '请输入推荐标题', trigger: 'blur' },
{ max: 200, message: '标题长度不能超过200个字符', trigger: 'blur' },
],
priority: [{ required: true, message: '请设置优先级', trigger: 'blur' }],
}
const fetchData = async () => {
loading.value = true
try {
const [recommends, courses] = await Promise.all([
groupCourseRecommendApi.getAll(),
groupCourseApi.getAll(),
])
dataSource.value = recommends
courseList.value = courses
// Build courseId -> courseName map
const map: Record<number, string> = {}
courses.forEach((c) => {
if (c.id != null) map[c.id] = c.courseName
})
courseMap.value = map
} catch {
ElMessage.error('加载数据失败')
} finally {
loading.value = false
}
}
const handleAdd = () => {
modalTitle.value = '新增推荐'
Object.assign(formState, {
id: undefined,
courseId: 0,
recommendTitle: '',
recommendContent: '',
recommendReason: '',
priority: 0,
isActive: true,
})
modalVisible.value = true
}
const handleEdit = (row: GroupCourseRecommend) => {
modalTitle.value = '编辑推荐'
Object.assign(formState, { ...row })
modalVisible.value = true
}
const handleToggleActive = async (row: GroupCourseRecommend) => {
try {
const actionText = row.isActive ? '停用' : '启用'
await ElMessageBox.confirm(`确定要${actionText}该推荐吗?`, '提示', {
confirmButtonText: '确定',
cancelButtonText: '取消',
type: 'warning',
})
if (row.isActive) {
await groupCourseRecommendApi.disable(row.id!)
} else {
await groupCourseRecommendApi.enable(row.id!)
}
ElMessage.success(`${actionText}成功`)
fetchData()
} catch (error) {
if (error !== 'cancel') {
ElMessage.error('操作失败')
}
}
}
const handleDelete = async (row: GroupCourseRecommend) => {
try {
await ElMessageBox.confirm('确定要删除该推荐吗?', '提示', {
confirmButtonText: '确定',
cancelButtonText: '取消',
type: 'warning',
})
await groupCourseRecommendApi.delete(row.id!)
ElMessage.success('删除成功')
fetchData()
} catch (error) {
if (error !== 'cancel') {
ElMessage.error('删除失败')
}
}
}
const handleModalOk = async () => {
if (!formRef.value) return
try {
await formRef.value.validate()
if (formState.id) {
await groupCourseRecommendApi.update(formState.id, formState)
} else {
await groupCourseRecommendApi.create(formState)
}
ElMessage.success('操作成功')
modalVisible.value = false
fetchData()
} catch (error) {
if (error !== 'cancel') {
ElMessage.error('操作失败')
}
}
}
onMounted(() => fetchData())
</script>
<style scoped lang="css">
.course-recommend-management .card-title {
display: flex;
justify-content: space-between;
align-items: center;
}
.course-recommend-management .header-actions {
display: flex;
align-items: center;
gap: 8px;
}
</style>
@@ -0,0 +1,455 @@
<template>
<div class="course-type-management">
<el-card>
<template #header>
<div class="card-header">
<div class="search-section">
<el-input
v-model="searchKeyword"
placeholder="搜索类型名称"
clearable
style="width: 240px"
@clear="handleSearch"
@keyup.enter="handleSearch"
>
<template #prefix>
<el-icon><Search /></el-icon>
</template>
</el-input>
<el-select
v-model="searchCategory"
placeholder="筛选分类"
clearable
style="width: 160px"
@change="handleSearch"
>
<el-option
v-for="cat in categories"
:key="cat"
:value="cat"
:label="cat"
/>
</el-select>
<el-button type="primary" @click="handleSearch">
搜索
</el-button>
</div>
<el-button type="primary" @click="handleAdd">
新增类型
</el-button>
</div>
</template>
<el-table
v-loading="loading"
:data="dataSource"
style="width: 100%"
>
<el-table-column prop="id" label="ID" width="80" sortable="custom" />
<el-table-column prop="typeName" label="类型名称" min-width="180" />
<el-table-column label="基础难度" width="100">
<template #default="{ row }">
{{ difficultyLabel(row.baseDifficulty) }}
</template>
</el-table-column>
<el-table-column prop="category" label="分类" width="140">
<template #default="{ row }">
<el-tag effect="dark" style="font-weight: 500; font-size: 14px;">
{{ row.category || '-' }}
</el-tag>
</template>
</el-table-column>
<el-table-column label="标签" min-width="160">
<template #default="{ row }">
<template v-if="typeLabelsMap[row.id!]?.length">
<el-tag
v-for="label in typeLabelsMap[row.id!]"
:key="label.id"
:color="label.color"
effect="dark"
size="small"
style="margin-right: 4px; border-color: transparent;"
>
{{ label.labelName }}
</el-tag>
</template>
<span v-else style="color: #999;">-</span>
</template>
</el-table-column>
<el-table-column prop="description" label="描述" min-width="200" show-overflow-tooltip />
<el-table-column label="操作" width="150" fixed="right">
<template #default="{ row }">
<el-button type="primary" link size="small" @click="handleEdit(row)">
编辑
</el-button>
<el-button type="danger" link size="small" @click="handleDelete(row)">
删除
</el-button>
</template>
</el-table-column>
</el-table>
<el-pagination
v-model:current-page="currentPage"
v-model:page-size="pageSize"
:total="total"
:page-sizes="[10, 20, 50]"
layout="total, sizes, prev, pager, next, jumper"
background
style="margin-top: 16px; justify-content: flex-end"
@size-change="onSizeChange"
@current-change="onPageChange"
/>
</el-card>
<el-dialog
v-model="modalVisible"
:title="modalTitle"
width="650px"
>
<el-form
ref="formRef"
:model="formState"
:rules="formRules"
label-width="100px"
>
<el-form-item label="类型名称" prop="typeName">
<el-input v-model="formState.typeName" placeholder="请输入类型名称" />
</el-form-item>
<el-form-item label="基础难度" prop="baseDifficulty">
<el-slider v-model="formState.baseDifficulty" :min="1" :max="10" show-stops style="width: 100%" />
</el-form-item>
<el-form-item label="分类" prop="category">
<el-select
v-model="formState.category"
placeholder="请选择分类"
allow-create
filterable
style="width: 100%"
>
<el-option
v-for="cat in categories"
:key="cat"
:value="cat"
:label="cat"
/>
</el-select>
</el-form-item>
<el-form-item label="描述">
<el-input
v-model="formState.description"
type="textarea"
:rows="3"
placeholder="请输入类型描述"
/>
</el-form-item>
<el-form-item v-if="formState.id" label="类型标签">
<div class="label-select-area">
<div class="label-section-title">
已选标签{{ selectedLabelIds.length }}/5
</div>
<div class="label-tags-row">
<el-tag
v-for="id in selectedLabelIds"
:key="id"
:color="getLabelById(id)?.color"
effect="dark"
size="default"
closable
style="border-color: transparent; margin: 0 6px 6px 0;"
@close="toggleLabel(id)"
>
{{ getLabelById(id)?.labelName }}
</el-tag>
<span v-if="selectedLabelIds.length === 0" style="color: #999;">点击下方标签选择</span>
</div>
<div class="label-section-title">
可选标签
</div>
<div class="label-tags-row">
<el-tag
v-for="label in allLabels"
:key="label.id"
:color="label.color"
:effect="selectedLabelIds.includes(label.id!) ? 'dark' : 'plain'"
:class="{
'label-tag': true,
'label-tag--selected': selectedLabelIds.includes(label.id!),
'label-tag--disabled': !selectedLabelIds.includes(label.id!) && selectedLabelIds.length >= 5,
}"
size="default"
style="cursor: pointer; margin: 0 6px 6px 0; user-select: none;"
@click="toggleLabel(label.id!)"
>
{{ label.labelName }}
</el-tag>
<span v-if="allLabels.length === 0" style="color: #999;">暂无可用标签</span>
</div>
</div>
</el-form-item>
</el-form>
<template #footer>
<el-button @click="modalVisible = false">取消</el-button>
<el-button type="primary" @click="handleModalOk">确定</el-button>
</template>
</el-dialog>
</div>
</template>
<script setup lang="ts">
import { ref, reactive, onMounted } from 'vue'
import { ElMessage, ElMessageBox } from 'element-plus'
import { Search } from '@element-plus/icons-vue'
import { groupCourseTypeApi, courseLabelApi, type GroupCourseType, type CourseLabel, type GroupCourseTypePageRequest } from '@/api/groupCourse.api'
const loading = ref(false)
const dataSource = ref<GroupCourseType[]>([])
const searchKeyword = ref('')
const searchCategory = ref('')
const categories = ref<string[]>([])
const currentPage = ref(1)
const pageSize = ref(10)
const total = ref(0)
const allLabels = ref<CourseLabel[]>([])
const selectedLabelIds = ref<number[]>([])
const typeLabelsMap = ref<Record<number, CourseLabel[]>>({})
const modalVisible = ref(false)
const modalTitle = ref('')
const formRef = ref()
const formState = reactive<GroupCourseType>({
typeName: '',
baseDifficulty: 3,
description: '',
category: '',
})
const formRules = {
typeName: [
{ required: true, message: '请输入类型名称', trigger: 'blur' },
{ min: 2, max: 100, message: '类型名称长度在 2 到 100 个字符', trigger: 'blur' },
],
baseDifficulty: [
{ required: true, message: '请设置基础难度', trigger: 'change' },
],
}
const difficultyLabel = (val?: number) => {
if (!val) return '-'
if (val <= 2) return '入门'
if (val <= 4) return '初级'
if (val <= 6) return '中级'
if (val <= 8) return '进阶'
return '高级'
}
const fetchCategories = async () => {
try {
categories.value = await groupCourseTypeApi.getCategories()
} catch {
// ignore
}
}
const fetchAllLabels = async () => {
try {
allLabels.value = await courseLabelApi.getAll()
} catch {
// ignore
}
}
const toggleLabel = (id: number) => {
const idx = selectedLabelIds.value.indexOf(id)
if (idx >= 0) {
selectedLabelIds.value.splice(idx, 1)
} else if (selectedLabelIds.value.length < 5) {
selectedLabelIds.value.push(id)
}
}
const getLabelById = (id: number): CourseLabel | undefined =>
allLabels.value.find(l => l.id === id)
const fetchTypeLabels = async (typeId: number) => {
try {
const labels = await courseLabelApi.getByTypeId(typeId)
selectedLabelIds.value = (labels || []).map(l => l.id!).filter(Boolean) as number[]
} catch {
selectedLabelIds.value = []
}
}
const fetchData = async () => {
loading.value = true
try {
const params: GroupCourseTypePageRequest = {
page: currentPage.value - 1,
size: pageSize.value,
sort: 'id',
order: 'asc',
}
if (searchKeyword.value) params.keyword = searchKeyword.value
if (searchCategory.value) params.category = searchCategory.value
const res = await groupCourseTypeApi.getPage(params)
dataSource.value = res.content
total.value = Number(res.totalElements)
loadTypeLabels()
} catch {
ElMessage.error('加载数据失败')
} finally {
loading.value = false
}
}
const onPageChange = () => fetchData()
const onSizeChange = () => {
currentPage.value = 1
fetchData()
}
const loadTypeLabels = async () => {
const map: Record<number, CourseLabel[]> = {}
const promises = dataSource.value.map(async (type) => {
if (!type.id) return
try {
const labels = await courseLabelApi.getByTypeId(type.id)
map[type.id] = labels || []
} catch {
map[type.id] = []
}
})
await Promise.all(promises)
typeLabelsMap.value = map
}
const handleSearch = () => {
currentPage.value = 1
fetchData()
}
const handleAdd = () => {
modalTitle.value = '新增类型'
Object.assign(formState, {
id: undefined,
typeName: '',
baseDifficulty: 3,
description: '',
category: '',
})
selectedLabelIds.value = []
modalVisible.value = true
}
const handleEdit = (row: GroupCourseType) => {
modalTitle.value = '编辑类型'
Object.assign(formState, { ...row })
modalVisible.value = true
// Load labels after dialog opens
fetchAllLabels()
if (row.id) fetchTypeLabels(row.id)
}
const handleDelete = async (row: GroupCourseType) => {
try {
await ElMessageBox.confirm('确定要删除该团课类型吗?', '提示', {
confirmButtonText: '确定',
cancelButtonText: '取消',
type: 'warning',
})
await groupCourseTypeApi.delete(row.id!)
ElMessage.success('删除成功')
fetchData()
} catch (error: any) {
if (error !== 'cancel') {
const msg = error?.response?.data?.message || error?.message || '删除失败'
ElMessage.error(msg)
}
}
}
const handleModalOk = async () => {
if (!formRef.value) return
try {
await formRef.value.validate()
if (formState.id) {
await groupCourseTypeApi.update(formState.id, formState)
// Sync labels: clear all then add selected ones
await courseLabelApi.clearLabelsFromType(formState.id)
if (selectedLabelIds.value.length > 0) {
await courseLabelApi.addLabelsToType(formState.id, selectedLabelIds.value)
}
} else {
await groupCourseTypeApi.create(formState)
}
ElMessage.success('操作成功')
modalVisible.value = false
fetchCategories()
fetchData()
} catch (error: any) {
if (error !== 'cancel') {
const msg = error?.response?.data?.message || error?.message || '操作失败'
ElMessage.error(msg)
}
}
}
onMounted(() => {
fetchCategories()
fetchData()
})
</script>
<style scoped lang="css">
.course-type-management {
.card-header {
display: flex;
justify-content: space-between;
align-items: center;
gap: 16px;
.search-section {
display: flex;
gap: 8px;
align-items: center;
}
}
}
.label-select-area {
width: 100%;
}
.label-section-title {
font-size: 12px;
color: #999;
margin-bottom: 6px;
margin-top: 4px;
}
.label-tags-row {
display: flex;
flex-wrap: wrap;
align-items: center;
min-height: 28px;
}
.label-tag {
transition: all 0.2s;
border: 2px solid transparent;
}
.label-tag--selected {
border-color: #fff !important;
box-shadow: 0 0 0 1px rgba(0, 0, 0, 0.15);
transform: scale(1.05);
}
.label-tag--disabled {
opacity: 0.4;
cursor: not-allowed !important;
}
</style>
@@ -0,0 +1,710 @@
<template>
<div class="group-course-management">
<el-card>
<template #header>
<div class="card-header">
<div class="search-section">
<el-input
v-model="searchKeyword"
placeholder="搜索课程名称"
clearable
style="width: 240px"
@clear="handleSearch"
@keyup.enter="handleSearch"
>
<template #prefix>
<el-icon><Search /></el-icon>
</template>
</el-input>
<el-select
v-model="searchStatus"
placeholder="课程状态"
clearable
style="width: 140px"
@change="handleSearch"
>
<el-option value="0" label="正常" />
<el-option value="1" label="已取消" />
<el-option value="2" label="已结束" />
<el-option value="3" label="进行中" />
<el-option value="4" label="超时" />
</el-select>
<el-button type="primary" @click="handleSearch">
搜索
</el-button>
</div>
<el-button type="primary" @click="handleAdd">
新增团课
</el-button>
</div>
</template>
<el-table
v-loading="loading"
:data="dataSource"
style="width: 100%"
@sort-change="handleSortChange"
>
<el-table-column prop="id" label="ID" width="80" sortable="custom" />
<el-table-column label="封面" width="100">
<template #default="{ row }">
<div class="cover-cell">
<img
v-if="coverCache[row.coverImage]"
:src="coverCache[row.coverImage]"
class="cover-thumb"
@error="onCoverError(row)"
/>
<span v-else class="cover-no-data">No data</span>
</div>
</template>
</el-table-column>
<el-table-column prop="courseName" label="课程名称" min-width="140" />
<el-table-column label="课程类型" width="100">
<template #default="{ row }">
{{ getCourseTypeName(row.courseType) }}
</template>
</el-table-column>
<el-table-column label="状态" width="90">
<template #default="{ row }">
<el-tag
:type="statusMap[row.status]?.type || 'info'"
effect="dark"
style="font-weight: 500; font-size: 14px;"
>
{{ statusMap[row.status]?.label || row.status }}
</el-tag>
</template>
</el-table-column>
<el-table-column prop="startTime" label="开始时间" width="170">
<template #default="{ row }">
{{ formatDateTime(row.startTime) }}
</template>
</el-table-column>
<el-table-column prop="endTime" label="结束时间" width="170">
<template #default="{ row }">
{{ formatDateTime(row.endTime) }}
</template>
</el-table-column>
<el-table-column prop="location" label="上课地点" width="120" />
<el-table-column label="人数" width="90">
<template #default="{ row }">
{{ row.currentMembers || 0 }}/{{ row.maxMembers || 0 }}
</template>
</el-table-column>
<el-table-column label="操作" width="260" fixed="right">
<template #default="{ row }">
<el-button type="primary" link size="small" @click="handleEdit(row)">
编辑
</el-button>
<el-button type="success" link size="small" @click="showQrCode(row)">
二维码
</el-button>
<el-button
v-if="row.status === '0'"
type="warning"
link
size="small"
@click="handleCancel(row)"
>
取消
</el-button>
<el-button type="danger" link size="small" @click="handleDelete(row)">
删除
</el-button>
</template>
</el-table-column>
</el-table>
<el-pagination
v-model:current-page="pagination.current"
v-model:page-size="pagination.pageSize"
:page-sizes="[10, 20, 50, 100]"
:total="pagination.total"
layout="total, sizes, prev, pager, next, jumper"
style="margin-top: 16px; justify-content: flex-end"
@current-change="handleTableChange"
@size-change="handleSizeChange"
/>
</el-card>
<el-dialog
v-model="modalVisible"
:title="modalTitle"
width="600px"
>
<el-form
ref="formRef"
:model="formState"
:rules="formRules"
label-width="120px"
>
<el-form-item label="课程名称" prop="courseName">
<el-input v-model="formState.courseName" placeholder="请输入课程名称" />
</el-form-item>
<el-form-item label="课程类型" prop="courseType">
<el-select v-model="formState.courseType" placeholder="请选择课程类型" style="width: 100%">
<el-option
v-for="type in courseTypes"
:key="type.id"
:value="type.id"
:label="type.typeName"
/>
</el-select>
</el-form-item>
<el-form-item label="开始时间" prop="startTime">
<el-date-picker
v-model="formState.startTime"
type="datetime"
placeholder="选择开始时间"
value-format="YYYY-MM-DDTHH:mm:ss"
:disabled-date="notBeforeToday"
style="width: 100%"
/>
</el-form-item>
<el-form-item label="结束时间" prop="endTime" v-if="false">
<span />
</el-form-item>
<el-form-item label="持续时间(分钟)" prop="duration">
<el-input-number
v-model="formState.duration"
:min="1"
:max="1440"
placeholder="请输入课程持续时间"
style="width: 100%"
/>
</el-form-item>
<el-form-item label="最大人数" prop="maxMembers">
<el-input-number v-model="formState.maxMembers" :min="1" :max="999" style="width: 100%" />
</el-form-item>
<el-form-item label="上课地点" prop="location">
<el-input v-model="formState.location" placeholder="请输入上课地点" />
</el-form-item>
<el-form-item label="封面图片">
<el-upload
class="cover-upload"
:http-request="uploadCover"
:before-upload="beforeCoverUpload"
:show-file-list="false"
accept="image/*"
>
<img v-if="coverPreviewSrc" :src="coverPreviewSrc" class="cover-preview" />
<el-icon v-else class="cover-upload-icon"><Plus /></el-icon>
</el-upload>
</el-form-item>
<el-form-item v-if="formState.id" label="课程状态" prop="status">
<el-select v-model="formState.status" placeholder="请选择状态" style="width: 100%">
<el-option value="0" label="正常" />
<el-option value="1" label="已取消" />
</el-select>
</el-form-item>
<el-form-item label="储值卡额度">
<el-input-number v-model="formState.storedValueAmount" :min="0" :precision="2" style="width: 100%" />
</el-form-item>
<el-form-item label="课程描述">
<el-input
v-model="formState.description"
type="textarea"
:rows="3"
placeholder="请输入课程描述"
/>
</el-form-item>
</el-form>
<template #footer>
<el-button @click="modalVisible = false">取消</el-button>
<el-button type="primary" @click="handleModalOk">确定</el-button>
</template>
</el-dialog>
<!-- 签到二维码弹窗 -->
<el-dialog
v-model="qrDialogVisible"
:title="'签到二维码 - ' + currentCourseName"
width="420px"
center
>
<div class="qr-dialog-body">
<div v-loading="qrLoading" class="qr-image-wrapper">
<img
v-if="qrImageUrl"
:src="qrImageUrl"
class="qr-image"
alt="签到二维码"
/>
<el-empty v-else-if="!qrLoading" description="暂无二维码" />
</div>
<p class="qr-tip">扫码签到参加团课</p>
</div>
<template #footer>
<el-button @click="qrDialogVisible = false">关闭</el-button>
<el-button type="primary" :disabled="!qrImageUrl" @click="downloadQrCode">
下载二维码
</el-button>
</template>
</el-dialog>
</div>
</template>
<script setup lang="ts">
import { ref, reactive, watch, onMounted } from 'vue'
import { ElMessage, ElMessageBox } from 'element-plus'
import { Search, Plus } from '@element-plus/icons-vue'
import { groupCourseApi, groupCourseTypeApi, type GroupCourse, type GroupCourseType } from '@/api/groupCourse.api'
import request from '@/utils/request'
import { formatDateTime } from '@/utils/dateFormat'
const loading = ref(false)
const dataSource = ref<GroupCourse[]>([])
const searchKeyword = ref('')
const searchStatus = ref('')
const courseTypes = ref<GroupCourseType[]>([])
const statusMap: Record<string, { type: string; label: string }> = {
'0': { type: 'success', label: '正常' },
'1': { type: 'danger', label: '已取消' },
'2': { type: 'info', label: '已结束' },
'3': { type: '', label: '进行中' },
'4': { type: 'warning', label: '超时' },
}
const pagination = reactive({
current: 1,
pageSize: 10,
total: 0,
})
const sortInfo = reactive({
sortBy: 'id',
sortOrder: 'asc' as 'asc' | 'desc',
})
const modalVisible = ref(false)
const modalTitle = ref('')
const formRef = ref()
const formState = reactive<GroupCourse>({
courseName: '',
courseType: undefined,
startTime: '',
endTime: '',
maxMembers: 20,
location: '',
coverImage: '',
description: '',
storedValueAmount: 0,
status: '0',
})
const duration = ref(60)
// @ts-expect-error duration is a frontend-only field
formState.duration = duration
const formRules = {
courseName: [
{ required: true, message: '请输入课程名称', trigger: 'blur' },
{ min: 2, max: 100, message: '课程名称长度在 2 到 100 个字符', trigger: 'blur' },
],
startTime: [{ required: true, message: '请选择开始时间', trigger: 'change' }],
duration: [{ required: true, message: '请输入课程持续时间', trigger: 'blur' }],
maxMembers: [{ required: true, message: '请输入最大人数', trigger: 'blur' }],
}
const coverCache = reactive<Record<string, string>>({})
const loadRowCover = async (coverImage: string | undefined) => {
if (!coverImage) return
// already loaded
if (coverCache[coverImage]) return
// if it's a numeric file ID, fetch via preview API
if (/^\d+$/.test(coverImage)) {
try {
const blob: any = await request.get(`/files/${coverImage}/preview`, { responseType: 'blob' })
coverCache[coverImage] = URL.createObjectURL(blob)
} catch {
// leave empty, template will show "No data"
}
} else {
// legacy URL — use directly, but may fail at load time
coverCache[coverImage] = coverImage
}
}
const onCoverError = (row: GroupCourse) => {
if (row.coverImage) {
delete coverCache[row.coverImage]
}
}
const fetchCourseTypes = async () => {
try {
courseTypes.value = await groupCourseTypeApi.getAll()
} catch {
// ignore
}
}
const getCourseTypeName = (typeId: number | undefined): string => {
if (typeId === undefined || typeId === null) return '-'
const type = courseTypes.value.find(t => t.id === typeId)
return type?.typeName || String(typeId)
}
const fetchData = async () => {
loading.value = true
try {
const res = await groupCourseApi.getPage({
page: pagination.current - 1,
size: pagination.pageSize,
sortBy: sortInfo.sortBy,
sortOrder: sortInfo.sortOrder,
keyword: searchKeyword.value || undefined,
status: searchStatus.value || undefined,
})
dataSource.value = res.content
pagination.total = Number(res.totalElements) || 0
// load cover images for all rows
res.content.forEach((row: GroupCourse) => loadRowCover(row.coverImage))
} catch {
ElMessage.error('加载数据失败')
} finally {
loading.value = false
}
}
const handleTableChange = () => fetchData()
const handleSizeChange = () => {
pagination.current = 1
fetchData()
}
const handleSearch = () => {
pagination.current = 1
fetchData()
}
const handleSortChange = ({ prop, order }: any) => {
sortInfo.sortBy = prop
sortInfo.sortOrder = order === 'ascending' ? 'asc' : 'desc'
fetchData()
}
const beforeCoverUpload = (file: File) => {
const isImage = file.type.startsWith('image/')
if (!isImage) {
ElMessage.error('只能上传图片文件')
return false
}
const isLt5M = file.size / 1024 / 1024 < 5
if (!isLt5M) {
ElMessage.error('图片大小不能超过 5MB')
return false
}
return true
}
const notBeforeToday = (date: Date) => {
const today = new Date()
today.setHours(0, 0, 0, 0)
return date.getTime() < today.getTime()
}
const uploadCover = async (options: any) => {
const formData = new FormData()
formData.append('file', options.file)
try {
const res: any = await request.post('/files/upload', formData, {
headers: { 'Content-Type': 'multipart/form-data' },
})
// res is the SysFile object (axios interceptor unwrapped response.data)
if (res && res.id) {
formState.coverImage = String(res.id)
// immediately fetch preview for the newly uploaded file
loadCoverPreview(String(res.id))
}
ElMessage.success('封面上传成功')
} catch {
ElMessage.error('封面上传失败')
}
}
const coverPreviewSrc = ref('')
// ===== 二维码弹窗相关 =====
const qrDialogVisible = ref(false)
const qrLoading = ref(false)
const qrImageUrl = ref('')
const currentCourseName = ref('')
/**
* 从 qrCodePath 中提取文件 ID
* 支持格式:/api/files/preview/{id} 或旧版 OSS URL
*/
const extractFileId = (path: string | undefined): string | null => {
if (!path) return null
// 新格式: /api/files/{id}/preview
const match = path.match(/\/files\/(\d+)\/preview/)
if (match) return match[1]
// 旧格式 OSS URL: 直接作为图片 URL 使用
if (path.startsWith('http')) return path
// 纯数字 ID
if (/^\d+$/.test(path)) return path
return null
}
/**
* 显示团课签到二维码
*/
const showQrCode = async (row: GroupCourse) => {
currentCourseName.value = row.courseName
qrDialogVisible.value = true
qrLoading.value = true
qrImageUrl.value = ''
const fileId = extractFileId(row.qrCodePath)
if (!fileId) {
qrLoading.value = false
return
}
try {
if (fileId.startsWith('http')) {
// 旧版 OSS URL,直接使用
qrImageUrl.value = fileId
} else {
// 新版文件 ID,通过预览接口获取
const blob: any = await request.get(`/files/${fileId}/preview`, { responseType: 'blob' })
// 释放旧 URL
if (qrImageUrl.value) URL.revokeObjectURL(qrImageUrl.value)
qrImageUrl.value = URL.createObjectURL(blob)
}
} catch {
ElMessage.error('获取二维码失败')
} finally {
qrLoading.value = false
}
}
/**
* 下载二维码图片
*/
const downloadQrCode = () => {
if (!qrImageUrl.value) return
const a = document.createElement('a')
a.href = qrImageUrl.value
a.download = `签到二维码_${currentCourseName.value}.png`
document.body.appendChild(a)
a.click()
document.body.removeChild(a)
ElMessage.success('二维码下载成功')
}
const loadCoverPreview = async (val: string) => {
if (!val) {
coverPreviewSrc.value = ''
return
}
// If it looks like a numeric file ID, fetch via preview API
if (/^\d+$/.test(val)) {
try {
const blob: any = await request.get(`/files/${val}/preview`, { responseType: 'blob' })
const oldUrl = coverPreviewSrc.value
if (oldUrl) URL.revokeObjectURL(oldUrl)
coverPreviewSrc.value = URL.createObjectURL(blob)
} catch {
coverPreviewSrc.value = ''
}
} else {
// Legacy: direct URL
coverPreviewSrc.value = val
}
}
// Watch coverImage changes to auto-load preview (e.g. when editing an existing course)
watch(() => formState.coverImage, (val) => loadCoverPreview(val || ''), { immediate: true })
const handleAdd = () => {
modalTitle.value = '新增团课'
Object.assign(formState, {
id: undefined,
courseName: '',
courseType: undefined,
startTime: '',
endTime: '',
maxMembers: 20,
location: '',
coverImage: '',
description: '',
storedValueAmount: 0,
})
formState.duration = 60
modalVisible.value = true
}
const handleEdit = (row: GroupCourse) => {
modalTitle.value = '编辑团课'
Object.assign(formState, { ...row })
// Calculate duration from startTime and endTime
if (row.startTime && row.endTime) {
const start = new Date(row.startTime)
const end = new Date(row.endTime)
formState.duration = Math.max(1, Math.round((end.getTime() - start.getTime()) / 60000))
}
modalVisible.value = true
}
const handleCancel = async (row: GroupCourse) => {
try {
await ElMessageBox.confirm('确定要取消该团课吗?', '提示', {
confirmButtonText: '确定',
cancelButtonText: '取消',
type: 'warning',
})
await groupCourseApi.cancel(row.id!)
ElMessage.success('取消成功')
fetchData()
} catch (error) {
if (error !== 'cancel') {
ElMessage.error('取消失败')
}
}
}
const handleDelete = async (row: GroupCourse) => {
try {
await ElMessageBox.confirm('确定要删除该团课吗?', '提示', {
confirmButtonText: '确定',
cancelButtonText: '取消',
type: 'warning',
})
await groupCourseApi.delete(row.id!)
ElMessage.success('删除成功')
fetchData()
} catch (error) {
if (error !== 'cancel') {
ElMessage.error('删除失败')
}
}
}
const handleModalOk = async () => {
if (!formRef.value) return
try {
await formRef.value.validate()
// Auto-calculate endTime from startTime + duration
if (formState.startTime && formState.duration) {
const start = new Date(formState.startTime)
start.setMinutes(start.getMinutes() + formState.duration)
const pad = (n: number) => String(n).padStart(2, '0')
formState.endTime = `${start.getFullYear()}-${pad(start.getMonth() + 1)}-${pad(start.getDate())}T${pad(start.getHours())}:${pad(start.getMinutes())}:${pad(start.getSeconds())}`
}
if (formState.id) {
await groupCourseApi.update(formState.id, formState)
} else {
await groupCourseApi.create(formState)
}
ElMessage.success('操作成功')
modalVisible.value = false
fetchData()
} catch (error) {
if (error !== 'cancel') {
ElMessage.error('操作失败')
}
}
}
onMounted(() => {
fetchCourseTypes()
fetchData()
})
</script>
<style scoped lang="css">
.group-course-management {
.card-header {
display: flex;
justify-content: space-between;
align-items: center;
gap: 16px;
.search-section {
display: flex;
gap: 8px;
align-items: center;
}
}
}
.cover-upload :deep(.el-upload) {
border: 1px dashed #d9d9d9;
border-radius: 6px;
cursor: pointer;
width: 180px;
height: 120px;
display: flex;
align-items: center;
justify-content: center;
transition: border-color 0.3s;
}
.cover-upload :deep(.el-upload:hover) {
border-color: #409eff;
}
.cover-preview {
width: 180px;
height: 120px;
object-fit: cover;
border-radius: 6px;
}
.cover-upload-icon {
font-size: 28px;
color: #8c939d;
}
.cover-cell {
display: flex;
align-items: center;
justify-content: center;
}
.cover-thumb {
width: 64px;
height: 48px;
object-fit: cover;
border-radius: 4px;
}
.cover-no-data {
color: #c0c4cc;
font-size: 12px;
}
/* 二维码弹窗样式 */
.qr-dialog-body {
display: flex;
flex-direction: column;
align-items: center;
padding: 16px 0;
}
.qr-image-wrapper {
width: 260px;
height: 260px;
display: flex;
align-items: center;
justify-content: center;
border: 1px solid #ebeef5;
border-radius: 8px;
background: #fafafa;
overflow: hidden;
}
.qr-image {
width: 100%;
height: 100%;
object-fit: contain;
}
.qr-tip {
margin-top: 16px;
color: #909399;
font-size: 14px;
}
</style>
@@ -0,0 +1,438 @@
<template>
<div class="member-card-management">
<el-card>
<template #header>
<div class="card-header">
<div class="left-section">
<el-select
v-model="filterType"
placeholder="卡类型"
clearable
style="width: 140px"
@change="handleFilter"
>
<el-option value="TIME_CARD" label="时长卡" />
<el-option value="COUNT_CARD" label="次卡" />
<el-option value="STORED_VALUE_CARD" label="储值卡" />
</el-select>
<el-input
v-model="filterName"
placeholder="搜索卡名称"
clearable
style="width: 200px"
@clear="handleFilter"
@keyup.enter="handleFilter"
>
<template #prefix>
<el-icon><Search /></el-icon>
</template>
</el-input>
<el-button type="primary" @click="handleFilter">搜索</el-button>
</div>
<div class="right-section">
<el-button type="primary" @click="handleCreate">
<el-icon><Plus /></el-icon>
新增会员卡
</el-button>
</div>
</div>
</template>
<el-table
v-loading="loading"
:data="dataSource"
style="width: 100%"
>
<el-table-column prop="memberCardId" label="ID" width="80" />
<el-table-column prop="memberCardName" label="卡名称" min-width="140" />
<el-table-column label="卡类型" width="100">
<template #default="{ row }">
{{ cardTypeMap[row.memberCardType as string] || row.memberCardTypeDesc || '-' }}
</template>
</el-table-column>
<el-table-column label="价格" width="100">
<template #default="{ row }">
¥{{ row.memberCardPrice ?? '-' }}
</template>
</el-table-column>
<el-table-column label="卡片详情" min-width="180">
<template #default="{ row }">
<template v-if="row.memberCardType === 'TIME_CARD'">
有效期 {{ row.memberCardValidityDays ?? '-' }}
</template>
<template v-else-if="row.memberCardType === 'COUNT_CARD'">
{{ row.memberCardTotalTimes ?? '-' }}
</template>
<template v-else-if="row.memberCardType === 'STORED_VALUE_CARD'">
面额 ¥{{ row.memberCardAmount ?? '-' }}
</template>
<template v-else>
-
</template>
</template>
</el-table-column>
<el-table-column label="状态" width="90">
<template #default="{ row }">
<el-switch
:model-value="row.memberCardStatus === 1"
active-text="上架"
inactive-text="下架"
inline-prompt
@change="(val: boolean) => handleToggleStatus(row, val)"
/>
</template>
</el-table-column>
<el-table-column label="创建时间" width="170">
<template #default="{ row }">
{{ row.createdAt ? formatDateTime(row.createdAt) : '-' }}
</template>
</el-table-column>
<el-table-column label="操作" width="160" fixed="right">
<template #default="{ row }">
<el-button type="primary" link size="small" @click="handleEdit(row)">
编辑
</el-button>
<el-button type="danger" link size="small" @click="handleDelete(row)">
删除
</el-button>
</template>
</el-table-column>
</el-table>
<el-pagination
v-model:current-page="pagination.current"
v-model:page-size="pagination.pageSize"
:page-sizes="[10, 20, 50]"
:total="pagination.total"
layout="total, sizes, prev, pager, next, jumper"
style="margin-top: 16px; justify-content: flex-end"
@current-change="fetchData"
@size-change="handleSizeChange"
/>
</el-card>
<!-- 新增/编辑弹窗 -->
<el-dialog
v-model="dialogVisible"
:title="dialogTitle"
width="520px"
>
<el-form
ref="formRef"
:model="form"
:rules="formRules"
label-width="110px"
>
<el-form-item label="卡名称" prop="memberCardName">
<el-input v-model="form.memberCardName" placeholder="请输入卡名称" />
</el-form-item>
<el-form-item label="卡类型" prop="memberCardType">
<el-select
v-model="form.memberCardType"
placeholder="请选择卡类型"
style="width: 100%"
:disabled="isEditing"
@change="handleTypeChange"
>
<el-option value="TIME_CARD" label="时长卡" />
<el-option value="COUNT_CARD" label="次卡" />
<el-option value="STORED_VALUE_CARD" label="储值卡" />
</el-select>
</el-form-item>
<el-form-item label="价格" prop="memberCardPrice">
<el-input-number
v-model="form.memberCardPrice"
:min="0"
:precision="2"
:step="10"
style="width: 100%"
placeholder="请输入价格"
/>
</el-form-item>
<!-- 时长卡专用 -->
<el-form-item
v-if="form.memberCardType === 'TIME_CARD'"
label="有效天数"
prop="memberCardValidityDays"
>
<el-input-number
v-model="form.memberCardValidityDays"
:min="1"
:step="30"
style="width: 100%"
placeholder="请输入有效天数"
/>
</el-form-item>
<!-- 次卡专用 -->
<el-form-item
v-if="form.memberCardType === 'COUNT_CARD'"
label="总次数"
prop="memberCardTotalTimes"
>
<el-input-number
v-model="form.memberCardTotalTimes"
:min="1"
:step="10"
style="width: 100%"
placeholder="请输入总次数"
/>
</el-form-item>
<!-- 储值卡专用 -->
<el-form-item
v-if="form.memberCardType === 'STORED_VALUE_CARD'"
label="面额"
prop="memberCardAmount"
>
<el-input-number
v-model="form.memberCardAmount"
:min="0"
:precision="2"
:step="100"
style="width: 100%"
placeholder="请输入面额"
/>
</el-form-item>
<el-form-item label="状态" prop="memberCardStatus">
<el-radio-group v-model="form.memberCardStatus">
<el-radio :value="1">上架</el-radio>
<el-radio :value="0">下架</el-radio>
</el-radio-group>
</el-form-item>
</el-form>
<template #footer>
<el-button @click="dialogVisible = false">取消</el-button>
<el-button type="primary" @click="handleSubmit" :loading="submitting">确定</el-button>
</template>
</el-dialog>
</div>
</template>
<script setup lang="ts">
import { ref, reactive, computed, onMounted } from 'vue'
import { ElMessage, ElMessageBox } from 'element-plus'
import { Search, Plus } from '@element-plus/icons-vue'
import { memberCardApi, type MemberCardType } from '@/api/memberCard.api'
import { formatDateTime } from '@/utils/dateFormat'
const loading = ref(false)
const dataSource = ref<MemberCardType[]>([])
const filterType = ref('')
const filterName = ref('')
const cardTypeMap: Record<string, string> = {
TIME_CARD: '时长卡',
COUNT_CARD: '次卡',
STORED_VALUE_CARD: '储值卡',
}
const pagination = reactive({
current: 1,
pageSize: 10,
total: 0,
})
const fetchData = async () => {
loading.value = true
try {
const res: any = await memberCardApi.list({
status: undefined,
name: filterName.value || undefined,
type: filterType.value || undefined,
page: pagination.current - 1,
size: pagination.pageSize,
})
if (Array.isArray(res)) {
dataSource.value = res
pagination.total = res.length
} else if (res?.content) {
dataSource.value = res.content
pagination.total = res.totalElements ?? res.total ?? 0
} else if (res?.data) {
dataSource.value = res.data
pagination.total = res.total ?? res.data?.length ?? 0
} else {
dataSource.value = []
pagination.total = 0
}
} catch (e: any) {
ElMessage.error(e?.response?.data?.message || e?.message || '加载失败')
} finally {
loading.value = false
}
}
const handleFilter = () => {
pagination.current = 1
fetchData()
}
const handleSizeChange = () => {
pagination.current = 1
fetchData()
}
// ========== 新增/编辑 ==========
const dialogVisible = ref(false)
const dialogTitle = ref('')
const submitting = ref(false)
const isEditing = ref(false)
const editingId = ref<number>()
const formRef = ref()
const defaultForm = () => ({
memberCardName: '',
memberCardType: 'TIME_CARD' as string,
memberCardPrice: undefined as number | undefined,
memberCardValidityDays: undefined as number | undefined,
memberCardTotalTimes: undefined as number | undefined,
memberCardAmount: undefined as number | undefined,
memberCardStatus: 1,
})
const form = reactive(defaultForm())
const formRules = {
memberCardName: [{ required: true, message: '请输入卡名称', trigger: 'blur' }],
memberCardType: [{ required: true, message: '请选择卡类型', trigger: 'change' }],
memberCardPrice: [{ required: true, message: '请输入价格', trigger: 'blur' }],
}
const handleTypeChange = () => {
// 切换类型时清空不相关字段
if (!isEditing.value) {
form.memberCardValidityDays = undefined
form.memberCardTotalTimes = undefined
form.memberCardAmount = undefined
}
}
const handleCreate = () => {
isEditing.value = false
editingId.value = undefined
dialogTitle.value = '新增会员卡'
Object.assign(form, defaultForm())
dialogVisible.value = true
}
const handleEdit = (row: MemberCardType) => {
isEditing.value = true
editingId.value = row.memberCardId
dialogTitle.value = '编辑会员卡'
form.memberCardName = row.memberCardName || ''
form.memberCardType = row.memberCardType || 'TIME_CARD'
form.memberCardPrice = row.memberCardPrice
form.memberCardValidityDays = row.memberCardValidityDays
form.memberCardTotalTimes = row.memberCardTotalTimes
form.memberCardAmount = row.memberCardAmount
form.memberCardStatus = row.memberCardStatus ?? 1
dialogVisible.value = true
}
const handleSubmit = async () => {
if (!formRef.value) return
try {
await formRef.value.validate()
} catch {
return
}
submitting.value = true
try {
const body: any = {
memberCardName: form.memberCardName,
memberCardType: form.memberCardType,
memberCardPrice: form.memberCardPrice,
memberCardStatus: form.memberCardStatus,
}
if (form.memberCardType === 'TIME_CARD') {
body.memberCardValidityDays = form.memberCardValidityDays
} else if (form.memberCardType === 'COUNT_CARD') {
body.memberCardTotalTimes = form.memberCardTotalTimes
} else if (form.memberCardType === 'STORED_VALUE_CARD') {
body.memberCardAmount = form.memberCardAmount
}
if (isEditing.value && editingId.value) {
await memberCardApi.update(editingId.value, body)
ElMessage.success('更新成功')
} else {
await memberCardApi.create(body)
ElMessage.success('创建成功')
}
dialogVisible.value = false
fetchData()
} catch (e: any) {
ElMessage.error(e?.response?.data?.message || e?.message || '操作失败')
} finally {
submitting.value = false
}
}
// ========== 上下架切换 ==========
const handleToggleStatus = async (row: MemberCardType, val: boolean) => {
if (!row.memberCardId) return
try {
const body: any = {
memberCardName: row.memberCardName,
memberCardType: row.memberCardType,
memberCardPrice: row.memberCardPrice,
memberCardStatus: val ? 1 : 0,
}
if (row.memberCardType === 'TIME_CARD') {
body.memberCardValidityDays = row.memberCardValidityDays
} else if (row.memberCardType === 'COUNT_CARD') {
body.memberCardTotalTimes = row.memberCardTotalTimes
} else if (row.memberCardType === 'STORED_VALUE_CARD') {
body.memberCardAmount = row.memberCardAmount
}
await memberCardApi.update(row.memberCardId, body)
ElMessage.success(val ? '已上架' : '已下架')
fetchData()
} catch (e: any) {
ElMessage.error(e?.response?.data?.message || e?.message || '操作失败')
}
}
// ========== 删除 ==========
const handleDelete = async (row: MemberCardType) => {
if (!row.memberCardId) return
try {
await ElMessageBox.confirm(`确定删除会员卡 "${row.memberCardName}" 吗?`, '确认删除', {
type: 'warning',
})
await memberCardApi.delete(row.memberCardId)
ElMessage.success('删除成功')
fetchData()
} catch (e: any) {
if (e !== 'cancel' && e?.message !== 'cancel') {
ElMessage.error(e?.response?.data?.message || e?.message || '删除失败')
}
}
}
onMounted(() => {
fetchData()
})
</script>
<style scoped lang="css">
.member-card-management {
.card-header {
display: flex;
justify-content: space-between;
align-items: center;
gap: 16px;
.left-section {
display: flex;
gap: 8px;
align-items: center;
}
.right-section {
display: flex;
gap: 8px;
align-items: center;
}
}
}
</style>
@@ -0,0 +1,642 @@
<template>
<div class="member-management">
<el-card>
<template #header>
<div class="card-header">
<div class="search-section">
<el-input
v-model="searchKeyword"
placeholder="搜索会员编号/昵称/手机号"
clearable
style="width: 280px"
@clear="handleSearch"
@keyup.enter="handleSearch"
>
<template #prefix>
<el-icon><Search /></el-icon>
</template>
</el-input>
<el-button type="primary" @click="handleSearch">
搜索
</el-button>
</div>
<div class="sort-section">
<el-button @click="handleResetSort" :type="sortField === 'createdAt' && sortOrder === 'desc' ? 'primary' : 'default'">
<el-icon><Clock /></el-icon>
最近注册
</el-button>
</div>
</div>
</template>
<el-table
v-loading="loading"
:data="dataSource"
style="width: 100%"
@sort-change="handleSortChange"
>
<el-table-column prop="id" label="ID" width="80" sortable="custom" />
<el-table-column label="头像" width="80">
<template #default="{ row }">
<el-avatar v-if="row.avatar" :src="row.avatar" :size="40" />
<el-avatar v-else :size="40">
<el-icon><UserFilled /></el-icon>
</el-avatar>
</template>
</el-table-column>
<el-table-column prop="memberNo" label="会员编号" width="140" sortable="custom">
<template #default="{ row }">
{{ row.memberNo || '-' }}
</template>
</el-table-column>
<el-table-column prop="nickname" label="昵称" min-width="120">
<template #default="{ row }">
{{ row.nickname || '-' }}
</template>
</el-table-column>
<el-table-column label="手机号" width="140">
<template #default="{ row }">
{{ formatPhone(row.phone) }}
</template>
</el-table-column>
<el-table-column label="性别" width="70">
<template #default="{ row }">
{{ row.genderDesc || genderMap[row.gender as number] || '-' }}
</template>
</el-table-column>
<el-table-column label="注册时间" width="170" prop="createdAt" sortable="custom">
<template #default="{ row }">
{{ row.createdAt ? formatDateTime(row.createdAt) : '-' }}
</template>
</el-table-column>
<el-table-column label="操作" width="240" fixed="right">
<template #default="{ row }">
<el-button type="primary" link size="small" @click="handleDetail(row)">
详情
</el-button>
<el-button type="primary" link size="small" @click="handleEdit(row)">
编辑
</el-button>
<el-button type="warning" link size="small" @click="handleEditPhone(row)">
修改手机号
</el-button>
</template>
</el-table-column>
</el-table>
<el-pagination
v-model:current-page="pagination.current"
v-model:page-size="pagination.pageSize"
:page-sizes="[10, 20, 50, 100]"
:total="pagination.total"
layout="total, sizes, prev, pager, next, jumper"
style="margin-top: 16px; justify-content: flex-end"
@current-change="handleTableChange"
@size-change="handleSizeChange"
/>
</el-card>
<!-- 详情弹窗 -->
<el-dialog
v-model="detailVisible"
title="会员详情"
width="650px"
>
<div v-loading="detailLoading" style="min-height: 200px">
<el-descriptions v-if="currentDetail" :column="2" border>
<el-descriptions-item label="ID">{{ currentDetail.id }}</el-descriptions-item>
<el-descriptions-item label="会员编号">{{ currentDetail.memberNo || '-' }}</el-descriptions-item>
<el-descriptions-item label="昵称">{{ currentDetail.nickname || '-' }}</el-descriptions-item>
<el-descriptions-item label="手机号">{{ formatPhone(currentDetail.phone) }}</el-descriptions-item>
<el-descriptions-item label="性别">{{ currentDetail.genderDesc || '-' }}</el-descriptions-item>
<el-descriptions-item label="生日">{{ currentDetail.birthday || '-' }}</el-descriptions-item>
<el-descriptions-item label="地址" :span="2">{{ currentDetail.address || '-' }}</el-descriptions-item>
<el-descriptions-item label="关注状态">
<el-tag :type="currentDetail.subscribed ? 'success' : 'info'" size="small">
{{ currentDetail.subscribed ? '已关注' : '未关注' }}
</el-tag>
</el-descriptions-item>
<el-descriptions-item label="最后登录">{{ formatDateTime(currentDetail.lastLoginAt) }}</el-descriptions-item>
<el-descriptions-item label="注册时间">{{ formatDateTime(currentDetail.createdAt) }}</el-descriptions-item>
<el-descriptions-item label="有效会员卡">{{ currentDetail.activeCardCount ?? 0 }}</el-descriptions-item>
<el-descriptions-item label="头像" :span="2">
<el-avatar v-if="currentDetail.avatar" :src="currentDetail.avatar" :size="60" />
<span v-else>未设置</span>
</el-descriptions-item>
</el-descriptions>
<!-- 绑定的会员卡记录 -->
<div style="margin-top: 20px">
<h4 style="margin-bottom: 10px">
绑定的会员卡
<span v-if="currentDetail?.activeCardCount !== undefined" style="font-weight: normal; font-size: 13px; color: #909399; margin-left: 8px">
(有效 {{ currentDetail.activeCardCount }} / {{ (currentDetail.activeCardCount ?? 0) + (currentDetail.inactiveCardCount ?? 0) }} )
</span>
</h4>
<el-table v-if="memberCardRecords.length > 0" :data="memberCardRecords" size="small" border>
<el-table-column prop="memberCardName" label="卡名称" min-width="120" />
<el-table-column label="卡类型" width="90">
<template #default="{ row: rec }">
{{ cardTypeMap[rec.memberCardType as string] || rec.memberCardType || '-' }}
</template>
</el-table-column>
<el-table-column label="剩余" width="120">
<template #default="{ row: rec }">
<template v-if="rec.memberCardType === 'TIME_CARD'">
{{ formatDateTime(rec.expireTime) }}
</template>
<template v-else-if="rec.memberCardType === 'COUNT_CARD'">
{{ rec.remainingTimes ?? 0 }}
</template>
<template v-else-if="rec.memberCardType === 'STORED_VALUE_CARD'">
¥{{ rec.remainingAmount ?? 0 }}
</template>
<template v-else>-</template>
</template>
</el-table-column>
<el-table-column label="购买时间" width="170">
<template #default="{ row: rec }">
{{ formatDateTime(rec.purchaseTime) }}
</template>
</el-table-column>
<el-table-column prop="status" label="状态" width="80">
<template #default="{ row: rec }">
<el-tag :type="rec.status === 'ACTIVE' ? 'success' : 'info'" size="small">
{{ rec.status || '-' }}
</el-tag>
</template>
</el-table-column>
</el-table>
<el-empty v-else description="暂无绑定的会员卡" :image-size="60" />
</div>
</div>
</el-dialog>
<!-- 编辑弹窗 -->
<el-dialog
v-model="editVisible"
title="编辑会员信息"
width="500px"
>
<div v-loading="editLoading" style="min-height: 200px">
<el-form
v-if="!editLoading"
ref="editFormRef"
:model="editForm"
label-width="100px"
>
<el-form-item label="昵称">
<el-input v-model="editForm.nickname" placeholder="请输入昵称" />
</el-form-item>
<el-form-item label="性别">
<el-select v-model="editForm.gender" placeholder="请选择性别" style="width: 100%">
<el-option value="MALE" label="男" />
<el-option value="FEMALE" label="女" />
<el-option value="UNKNOWN" label="未知" />
</el-select>
</el-form-item>
<el-form-item label="生日">
<el-date-picker
v-model="editForm.birthday"
type="date"
placeholder="选择生日"
value-format="YYYY-MM-DD"
style="width: 100%"
/>
</el-form-item>
<el-form-item label="地址">
<el-input v-model="editForm.address" placeholder="请输入地址" />
</el-form-item>
<el-form-item label="头像">
<div class="avatar-edit-row">
<div class="avatar-upload">
<el-upload
class="avatar-uploader"
:http-request="uploadAvatar"
:before-upload="beforeAvatarUpload"
:show-file-list="false"
accept="image/*"
>
<el-avatar v-if="editForm.avatar" :src="editForm.avatar" :size="80" />
<el-icon v-else class="avatar-uploader-icon"><Plus /></el-icon>
</el-upload>
<span class="avatar-hint">点击上传</span>
</div>
<el-button
v-if="editForm.avatar"
type="danger"
plain
size="small"
@click="handleClearAvatar"
>
删除头像
</el-button>
</div>
</el-form-item>
</el-form>
</div>
<template #footer>
<el-button @click="editVisible = false">取消</el-button>
<el-button type="primary" @click="handleEditSubmit" :loading="editSubmitting" :disabled="editLoading">确定</el-button>
</template>
</el-dialog>
<!-- 修改手机号弹窗 -->
<el-dialog
v-model="phoneVisible"
title="修改手机号"
width="400px"
>
<el-form
ref="phoneFormRef"
:model="phoneForm"
:rules="phoneRules"
label-width="100px"
>
<el-form-item label="会员ID">
<span>{{ currentMemberId }}</span>
</el-form-item>
<el-form-item label="新手机号" prop="phone">
<el-input v-model="phoneForm.phone" placeholder="请输入新手机号" />
</el-form-item>
</el-form>
<template #footer>
<el-button @click="phoneVisible = false">取消</el-button>
<el-button type="primary" @click="handlePhoneSubmit">确定</el-button>
</template>
</el-dialog>
</div>
</template>
<script setup lang="ts">
import { ref, reactive, onMounted } from 'vue'
import { ElMessage } from 'element-plus'
import { Search, UserFilled, Plus, Clock } from '@element-plus/icons-vue'
import { memberApi, type Member, type MemberDetail, type MemberCardRecord, type UpdateMemberDto } from '@/api/member.api'
import request from '@/utils/request'
import { formatDateTime } from '@/utils/dateFormat'
const loading = ref(false)
const dataSource = ref<Member[]>([])
const searchKeyword = ref('')
const sortField = ref<string>('')
const sortOrder = ref<string>('')
const genderMap: Record<number, string> = {
0: '未知',
1: '男',
2: '女',
}
const cardTypeMap: Record<string, string> = {
TIME_CARD: '时长卡',
COUNT_CARD: '次卡',
STORED_VALUE_CARD: '储值卡',
}
/** 格式化手机号显示,null/空时显示"未绑定" */
const formatPhone = (phone: string | undefined | null): string => {
if (!phone) return '未绑定'
return phone
}
const pagination = reactive({
current: 1,
pageSize: 10,
total: 0,
})
// 详情相关
const detailVisible = ref(false)
const detailLoading = ref(false)
const currentDetail = ref<MemberDetail | null>(null)
const memberCardRecords = ref<MemberCardRecord[]>([])
// 编辑相关
const editVisible = ref(false)
const editLoading = ref(false)
const editSubmitting = ref(false)
const editFormRef = ref()
const editingMemberId = ref<number>()
const editForm = reactive<UpdateMemberDto>({
nickname: '',
gender: undefined,
birthday: '',
address: '',
avatar: '',
})
// 修改手机号相关
const phoneVisible = ref(false)
const phoneFormRef = ref()
const currentMemberId = ref<number>()
const phoneForm = reactive({
phone: '',
})
const phoneRules = {
phone: [
{ required: true, message: '请输入手机号', trigger: 'blur' },
{ pattern: /^1[3-9]\d{9}$/, message: '请输入正确的手机号格式', trigger: 'blur' },
],
}
const fetchData = async () => {
loading.value = true
try {
const params: any = {
pageNum: pagination.current,
pageSize: pagination.pageSize,
sortField: sortField.value || 'createdAt',
sortOrder: sortOrder.value || 'desc',
}
if (searchKeyword.value) {
params.searchValue = searchKeyword.value
}
let res: any
if (searchKeyword.value) {
res = await memberApi.search(params)
} else {
res = await memberApi.getAll(params)
}
console.log('会员列表API返回:', res)
// 兼容多种返回格式:数组、{content/records/list/data: [...]}
let list: any[] = []
if (Array.isArray(res)) {
list = res
} else if (res?.content) {
list = res.content
} else if (res?.records) {
list = res.records
} else if (res?.list) {
list = res.list
} else if (res?.data && Array.isArray(res.data)) {
list = res.data
}
dataSource.value = list
// 分页总数
if (res?.totalElements !== undefined) {
pagination.total = Number(res.totalElements)
} else if (res?.total !== undefined) {
pagination.total = Number(res.total)
} else if (Array.isArray(res)) {
pagination.total = res.length
} else {
pagination.total = list.length
}
} catch (e: any) {
const msg = e?.response?.data?.message || e?.message || '加载数据失败'
ElMessage.error(msg)
console.error('加载会员列表失败:', e)
} finally {
loading.value = false
}
}
const handleTableChange = () => fetchData()
const handleSizeChange = () => {
pagination.current = 1
fetchData()
}
const handleSearch = () => {
pagination.current = 1
fetchData()
}
const handleSortChange = ({ prop, order }: { prop: string; order: string | null }) => {
sortField.value = prop || ''
sortOrder.value = order === 'ascending' ? 'asc' : order === 'descending' ? 'desc' : ''
pagination.current = 1
fetchData()
}
const handleResetSort = () => {
sortField.value = 'createdAt'
sortOrder.value = 'desc'
pagination.current = 1
fetchData()
}
const handleDetail = async (row: Member) => {
console.log('点击详情, row:', row, 'row.id:', row.id, 'type:', typeof row.id)
if (!row.id) return
detailVisible.value = true
detailLoading.value = true
currentDetail.value = null
memberCardRecords.value = []
try {
const detail = await memberApi.getDetail(Number(row.id))
console.log('会员详情API返回:', detail)
currentDetail.value = detail
// 获取绑定的会员卡记录
try {
const records: any = await memberApi.getMemberCardRecords(Number(row.id))
memberCardRecords.value = Array.isArray(records) ? records : (records?.content || records?.data || [])
} catch {
memberCardRecords.value = []
}
} catch (e: any) {
const msg = e?.response?.data?.message || e?.message || '获取会员详情失败'
ElMessage.error(msg)
console.error('获取会员详情失败:', e)
detailVisible.value = false
} finally {
detailLoading.value = false
}
}
const handleEdit = async (row: Member) => {
console.log('点击编辑, row:', row)
if (!row.id) return
editingMemberId.value = Number(row.id)
editVisible.value = true
editLoading.value = true
// 先重置表单
editForm.nickname = ''
editForm.gender = undefined
editForm.birthday = ''
editForm.address = ''
editForm.avatar = ''
try {
const detail = await memberApi.getDetail(Number(row.id))
console.log('编辑-会员详情API返回:', detail)
editForm.nickname = detail.nickname || ''
// genderDesc 为中文"男"/"女",需转为后端枚举值
if (detail.genderDesc === '男') {
editForm.gender = 'MALE'
} else if (detail.genderDesc === '女') {
editForm.gender = 'FEMALE'
} else {
editForm.gender = 'UNKNOWN'
}
// birthday 可能是 ISO 格式("2026-01-01T00:00:00.000+00:00"),取前10位
if (detail.birthday) {
const bd = String(detail.birthday)
editForm.birthday = bd.length >= 10 ? bd.substring(0, 10) : bd
} else {
editForm.birthday = ''
}
editForm.address = detail.address || ''
editForm.avatar = detail.avatar || ''
console.log('编辑表单数据:', JSON.parse(JSON.stringify(editForm)))
} catch (e: any) {
const msg = e?.response?.data?.message || e?.message || '获取会员信息失败'
ElMessage.error(msg)
console.error('获取会员信息失败:', e)
editVisible.value = false
} finally {
editLoading.value = false
}
}
const handleEditSubmit = async () => {
if (!editingMemberId.value) return
editSubmitting.value = true
try {
const body: UpdateMemberDto = {
nickname: editForm.nickname || undefined,
gender: editForm.gender || undefined,
birthday: editForm.birthday || undefined,
address: editForm.address || undefined,
avatar: editForm.avatar || undefined,
}
await memberApi.update(editingMemberId.value, body)
ElMessage.success('更新成功')
editVisible.value = false
fetchData()
} catch (e: any) {
const msg = e?.response?.data?.message || e?.message || '更新失败'
ElMessage.error(msg)
} finally {
editSubmitting.value = false
}
}
// ========== 头像上传 ==========
const beforeAvatarUpload = (file: File) => {
const isImage = file.type.startsWith('image/')
if (!isImage) {
ElMessage.error('只能上传图片文件')
return false
}
const isLt5M = file.size / 1024 / 1024 < 5
if (!isLt5M) {
ElMessage.error('图片大小不能超过 5MB')
return false
}
return true
}
const uploadAvatar = async (options: any) => {
const formData = new FormData()
formData.append('file', options.file)
try {
const res: any = await request.post('/files/upload', formData, {
headers: { 'Content-Type': 'multipart/form-data' },
})
if (res && res.id) {
// 通过预览接口获取图片URL
const blob: any = await request.get(`/files/${res.id}/preview`, { responseType: 'blob' })
editForm.avatar = URL.createObjectURL(blob)
}
ElMessage.success('头像上传成功')
} catch {
ElMessage.error('头像上传失败')
}
}
const handleClearAvatar = () => {
editForm.avatar = ''
ElMessage.success('头像已清除,保存后生效')
}
// ========== 修改手机号 ==========
const handleEditPhone = (row: Member) => {
currentMemberId.value = Number(row.id)
phoneForm.phone = ''
phoneVisible.value = true
}
const handlePhoneSubmit = async () => {
if (!phoneFormRef.value || !currentMemberId.value) return
try {
await phoneFormRef.value.validate()
await memberApi.updatePhone(currentMemberId.value, { phone: phoneForm.phone })
ElMessage.success('手机号更新成功')
phoneVisible.value = false
fetchData()
} catch (error: any) {
if (error !== 'cancel' && error?.message !== 'cancel') {
const msg = error?.response?.data?.message || error?.message || '手机号更新失败'
ElMessage.error(msg)
}
}
}
onMounted(() => {
fetchData()
})
</script>
<style scoped lang="css">
.member-management {
.card-header {
display: flex;
justify-content: space-between;
align-items: center;
gap: 16px;
.search-section {
display: flex;
gap: 8px;
align-items: center;
}
.sort-section {
display: flex;
gap: 8px;
align-items: center;
}
}
}
.avatar-edit-row {
display: flex;
align-items: flex-end;
gap: 16px;
}
.avatar-upload {
display: flex;
flex-direction: column;
align-items: center;
gap: 4px;
}
.avatar-uploader :deep(.el-upload) {
border: 1px dashed #d9d9d9;
border-radius: 6px;
cursor: pointer;
width: 80px;
height: 80px;
display: flex;
align-items: center;
justify-content: center;
transition: border-color 0.3s;
}
.avatar-uploader :deep(.el-upload:hover) {
border-color: #409eff;
}
.avatar-uploader-icon {
font-size: 28px;
color: #8c939d;
}
.avatar-hint {
font-size: 12px;
color: #909399;
}
</style>
@@ -0,0 +1,402 @@
<template>
<div class="statistics-dashboard">
<!-- 顶部操作栏 -->
<div class="toolbar">
<div class="toolbar-left">
<span class="toolbar-label">统计区间</span>
<el-radio-group v-model="selectedRange" size="default" @change="onRangeChange">
<el-radio-button value="today">今日</el-radio-button>
<el-radio-button value="week">本周</el-radio-button>
<el-radio-button value="month">本月</el-radio-button>
<el-radio-button value="last30">近30天</el-radio-button>
<el-radio-button value="last90">近90天</el-radio-button>
<el-radio-button value="year">今年</el-radio-button>
</el-radio-group>
</div>
<div class="toolbar-right">
<el-button
type="primary"
:icon="Download"
:loading="exporting"
@click="handleExport"
>
导出报表
</el-button>
<span class="generated-hint" v-if="generatedAt">
数据更新时间{{ generatedAt }}
</span>
</div>
</div>
<div v-loading="loading" class="dashboard-content">
<!-- ========== 总览统计卡片 ========== -->
<el-row :gutter="16" class="stat-cards-row">
<el-col :xs="12" :sm="6">
<el-card shadow="hover" class="stat-card stat-card--primary">
<div class="stat-card__label">会员总数</div>
<div class="stat-card__value">{{ summary?.memberStatistics?.totalMembers ?? '-' }}</div>
</el-card>
</el-col>
<el-col :xs="12" :sm="6">
<el-card shadow="hover" class="stat-card stat-card--success">
<div class="stat-card__label">活跃会员</div>
<div class="stat-card__value">{{ summary?.memberStatistics?.activeMembers ?? '-' }}</div>
</el-card>
</el-col>
<el-col :xs="12" :sm="6">
<el-card shadow="hover" class="stat-card stat-card--warning">
<div class="stat-card__label">预约总数</div>
<div class="stat-card__value">{{ summary?.bookingStatistics?.newBookings ?? '-' }}</div>
</el-card>
</el-col>
<el-col :xs="12" :sm="6">
<el-card shadow="hover" class="stat-card stat-card--info">
<div class="stat-card__label">签到总数</div>
<div class="stat-card__value">{{ summary?.signInStatistics?.totalSignIns ?? '-' }}</div>
</el-card>
</el-col>
</el-row>
<!-- ========== 会员统计明细 ========== -->
<el-card class="section-card">
<template #header>
<span class="section-title">会员统计</span>
</template>
<el-row :gutter="20">
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">新增会员</span>
<span class="metric-value">{{ summary?.memberStatistics?.newMembers ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">签到会员</span>
<span class="metric-value">{{ summary?.memberStatistics?.signInMembers ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">预约会员</span>
<span class="metric-value">{{ summary?.memberStatistics?.bookingMembers ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">取消预约</span>
<span class="metric-value">{{ summary?.memberStatistics?.cancelBookingMembers ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">活跃会员</span>
<span class="metric-value">{{ summary?.memberStatistics?.activeMembers ?? '-' }}</span>
</div>
</el-col>
</el-row>
</el-card>
<!-- ========== 预约统计明细 ========== -->
<el-card class="section-card">
<template #header>
<span class="section-title">预约统计</span>
</template>
<el-row :gutter="20">
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">总预约</span>
<span class="metric-value">{{ summary?.bookingStatistics?.newBookings ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">已签到</span>
<span class="metric-value">{{ summary?.bookingStatistics?.attendBookings ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">已取消</span>
<span class="metric-value">{{ summary?.bookingStatistics?.cancelBookings ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">缺席</span>
<span class="metric-value">{{ summary?.bookingStatistics?.absentBookings ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="16" :sm="8">
<div class="rate-group">
<div class="rate-item">
<span class="rate-label">出勤率</span>
<el-progress
:percentage="Number(summary?.bookingStatistics?.attendanceRate ?? 0)"
:stroke-width="12"
:color="rateColor(summary?.bookingStatistics?.attendanceRate)"
/>
</div>
<div class="rate-item">
<span class="rate-label">取消率</span>
<el-progress
:percentage="Number(summary?.bookingStatistics?.cancelRate ?? 0)"
:stroke-width="12"
:color="rateColor(summary?.bookingStatistics?.cancelRate, true)"
/>
</div>
</div>
</el-col>
</el-row>
</el-card>
<!-- ========== 签到统计明细 ========== -->
<el-card class="section-card">
<template #header>
<span class="section-title">签到统计</span>
</template>
<el-row :gutter="20">
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">总签到</span>
<span class="metric-value">{{ summary?.signInStatistics?.totalSignIns ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">成功</span>
<span class="metric-value">{{ summary?.signInStatistics?.successSignIns ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="8" :sm="4">
<div class="metric-item">
<span class="metric-label">失败</span>
<span class="metric-value">{{ summary?.signInStatistics?.failedSignIns ?? '-' }}</span>
</div>
</el-col>
<el-col :xs="24" :sm="12">
<div class="rate-group">
<div class="rate-item">
<span class="rate-label">成功率</span>
<el-progress
:percentage="Number(summary?.signInStatistics?.successRate ?? 0)"
:stroke-width="12"
color="#67c23a"
/>
</div>
<div class="signin-type-row">
<el-tag type="primary" size="small">扫码: {{ summary?.signInStatistics?.qrCodeSignIns ?? 0 }}</el-tag>
<el-tag type="warning" size="small">手动: {{ summary?.signInStatistics?.manualSignIns ?? 0 }}</el-tag>
<el-tag type="success" size="small">人脸: {{ summary?.signInStatistics?.faceSignIns ?? 0 }}</el-tag>
</div>
</div>
</el-col>
</el-row>
</el-card>
</div>
</div>
</template>
<script setup lang="ts">
import { ref, onMounted } from 'vue'
import { Download } from '@element-plus/icons-vue'
import { ElMessage } from 'element-plus'
import { statisticsApi, type StatisticsSummary } from '@/api/statistics.api'
// ---- ----
const RANGE_MAP: Record<string, { periodType: string }> = {
today: { periodType: 'DAY' },
week: { periodType: 'WEEK' },
month: { periodType: 'MONTH' },
last30: { periodType: 'LAST_30_DAYS' },
last90: { periodType: 'LAST_90_DAYS' },
year: { periodType: 'YEAR' },
}
const loading = ref(false)
const exporting = ref(false)
const summary = ref<StatisticsSummary>()
const generatedAt = ref('')
const selectedRange = ref('today')
const rateColor = (rate: number | undefined, inverse = false) => {
const val = Number(rate ?? 0)
if (inverse) {
if (val <= 20) return '#67c23a'
if (val <= 50) return '#e6a23c'
return '#f56c6c'
}
if (val >= 80) return '#67c23a'
if (val >= 50) return '#e6a23c'
return '#f56c6c'
}
const getQueryParams = () => {
const config = RANGE_MAP[selectedRange.value]
if (!config) return {}
return { periodType: config.periodType }
}
const fetchSummary = async () => {
loading.value = true
try {
const data = await statisticsApi.getSummary(getQueryParams())
summary.value = data
if (data?.generatedAt) {
generatedAt.value = new Date(data.generatedAt).toLocaleString()
}
} catch (e: any) {
ElMessage.error(e?.response?.data?.message || e?.message || '获取统计数据失败')
} finally {
loading.value = false
}
}
const onRangeChange = () => {
fetchSummary()
}
const handleExport = async () => {
exporting.value = true
try {
const blob: any = await statisticsApi.exportStatistics(getQueryParams())
const url = URL.createObjectURL(blob instanceof Blob ? blob : new Blob([blob]))
const link = document.createElement('a')
link.href = url
const label = selectedRange.value === 'today' ? '今日' :
selectedRange.value === 'week' ? '本周' :
selectedRange.value === 'month' ? '本月' :
selectedRange.value === 'last30' ? '近30天' :
selectedRange.value === 'last90' ? '近90天' : '今年'
link.download = `statistics_${label}_${new Date().toISOString().slice(0, 10)}.xlsx`
link.click()
URL.revokeObjectURL(url)
ElMessage.success('导出成功')
} catch (e: any) {
ElMessage.error(e?.response?.data?.message || e?.message || '导出失败')
} finally {
exporting.value = false
}
}
onMounted(() => {
fetchSummary()
})
</script>
<style scoped>
.statistics-dashboard {
padding: 16px;
}
.toolbar {
display: flex;
align-items: center;
justify-content: space-between;
flex-wrap: wrap;
gap: 12px;
margin-bottom: 16px;
}
.toolbar-left {
display: flex;
align-items: center;
gap: 8px;
}
.toolbar-label {
color: #606266;
font-size: 14px;
white-space: nowrap;
}
.toolbar-right {
display: flex;
align-items: center;
gap: 12px;
}
.generated-hint {
color: #909399;
font-size: 13px;
white-space: nowrap;
}
.dashboard-content {
min-height: 400px;
}
/* ---- 统计卡片 ---- */
.stat-cards-row {
margin-bottom: 16px;
}
.stat-card {
text-align: center;
margin-bottom: 12px;
}
.stat-card__label {
font-size: 14px;
color: #909399;
margin-bottom: 8px;
}
.stat-card__value {
font-size: 28px;
font-weight: 700;
}
.stat-card--primary .stat-card__value { color: #409eff; }
.stat-card--success .stat-card__value { color: #67c23a; }
.stat-card--warning .stat-card__value { color: #e6a23c; }
.stat-card--info .stat-card__value { color: #909399; }
/* ---- 明细分区 ---- */
.section-card {
margin-bottom: 16px;
}
.section-title {
font-size: 15px;
font-weight: 600;
}
.metric-item {
display: flex;
flex-direction: column;
align-items: center;
padding: 12px 0;
}
.metric-label {
font-size: 13px;
color: #909399;
margin-bottom: 6px;
}
.metric-value {
font-size: 22px;
font-weight: 600;
color: #303133;
}
.rate-group {
display: flex;
flex-direction: column;
gap: 8px;
}
.rate-item .rate-label {
font-size: 13px;
color: #606266;
display: block;
margin-bottom: 4px;
}
.signin-type-row {
display: flex;
gap: 8px;
margin-top: 4px;
flex-wrap: wrap;
}
</style>