Compare commits
5
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8da58a8f51 | ||
|
|
0b2146f237 | ||
|
|
7cc9a68144 | ||
|
|
b5c8a087dd | ||
|
|
7a94145819 |
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,530 @@
|
|||||||
|
# 团课推荐模块 API 文档
|
||||||
|
|
||||||
|
> **文档版本**: v1.0
|
||||||
|
> **创建日期**: 2026-06-15
|
||||||
|
> **作者**: 张翔
|
||||||
|
> **状态**: 正式发布
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 📋 目录
|
||||||
|
|
||||||
|
1. [概述](#概述)
|
||||||
|
2. [基础路径](#基础路径)
|
||||||
|
3. [团课推荐管理接口](#团课推荐管理接口)
|
||||||
|
- [获取所有团课推荐](#获取所有团课推荐)
|
||||||
|
- [获取所有启用的团课推荐](#获取所有启用的团课推荐)
|
||||||
|
- [根据ID获取团课推荐](#根据ID获取团课推荐)
|
||||||
|
- [根据团课ID获取推荐](#根据团课ID获取推荐)
|
||||||
|
- [创建团课推荐](#创建团课推荐)
|
||||||
|
- [更新团课推荐](#更新团课推荐)
|
||||||
|
- [删除团课推荐](#删除团课推荐)
|
||||||
|
- [启用团课推荐](#启用团课推荐)
|
||||||
|
- [禁用团课推荐](#禁用团课推荐)
|
||||||
|
4. [数据模型](#数据模型)
|
||||||
|
- [GroupCourseRecommend(团课推荐)](#GroupCourseRecommend团课推荐)
|
||||||
|
5. [状态码说明](#状态码说明)
|
||||||
|
6. [业务规则](#业务规则)
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 概述
|
||||||
|
|
||||||
|
团课推荐模块提供团课推荐信息的创建、编辑、查询、删除和状态管理功能。推荐信息包含团课ID、推荐标题、推荐内容、推荐理由、优先级等必要信息,支持按优先级排序展示。
|
||||||
|
|
||||||
|
## 基础路径
|
||||||
|
|
||||||
|
所有接口的基础路径为: `http://{host}:{port}/api/groupCourse/recommend`
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 团课推荐管理接口
|
||||||
|
|
||||||
|
### 获取所有团课推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | GET |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend/list` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**请求参数**:
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 默认值 | 说明 |
|
||||||
|
|--------|------|------|--------|------|
|
||||||
|
| sortBy | string | 否 | priority | 排序字段(支持:priority、createdAt、updatedAt) |
|
||||||
|
| sortOrder | string | 否 | desc | 排序方式(asc-升序,desc-降序) |
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
[
|
||||||
|
{
|
||||||
|
"id": 1,
|
||||||
|
"courseId": 1,
|
||||||
|
"recommendTitle": "本周热门课程",
|
||||||
|
"recommendContent": "这是一门非常棒的课程,快来参加吧!",
|
||||||
|
"recommendReason": "教练专业,课程内容丰富",
|
||||||
|
"priority": 10,
|
||||||
|
"isActive": true,
|
||||||
|
"groupCourse": {
|
||||||
|
"id": 1,
|
||||||
|
"courseName": "瑜伽入门",
|
||||||
|
"coachId": 1,
|
||||||
|
"courseType": 1,
|
||||||
|
"startTime": "2026-06-15T09:00:00",
|
||||||
|
"endTime": "2026-06-15T10:00:00",
|
||||||
|
"maxMembers": 20,
|
||||||
|
"currentMembers": 15,
|
||||||
|
"status": 0,
|
||||||
|
"location": "健身房A区",
|
||||||
|
"coverImage": "https://example.com/yoga.jpg",
|
||||||
|
"description": "适合初学者的瑜伽课程"
|
||||||
|
},
|
||||||
|
"createdAt": "2026-06-15T10:00:00",
|
||||||
|
"updatedAt": "2026-06-15T10:00:00"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### 获取所有启用的团课推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | GET |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend/active` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**功能说明**: 获取系统中所有已启用的团课推荐列表,按优先级从高到低排序。
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
[
|
||||||
|
{
|
||||||
|
"id": 2,
|
||||||
|
"courseId": 3,
|
||||||
|
"recommendTitle": "新学员推荐",
|
||||||
|
"recommendContent": "专为新学员设计的入门课程,轻松上手",
|
||||||
|
"recommendReason": "零基础友好,教练耐心指导",
|
||||||
|
"priority": 20,
|
||||||
|
"isActive": true,
|
||||||
|
"groupCourse": {
|
||||||
|
"id": 3,
|
||||||
|
"courseName": "基础有氧",
|
||||||
|
"coachId": 2,
|
||||||
|
"courseType": 2,
|
||||||
|
"startTime": "2026-06-16T18:00:00",
|
||||||
|
"endTime": "2026-06-16T19:00:00",
|
||||||
|
"maxMembers": 30,
|
||||||
|
"currentMembers": 8,
|
||||||
|
"status": 0,
|
||||||
|
"location": "健身房B区",
|
||||||
|
"coverImage": "https://example.com/aerobic.jpg",
|
||||||
|
"description": "适合所有健身水平的有氧课程"
|
||||||
|
},
|
||||||
|
"createdAt": "2026-06-15T11:00:00",
|
||||||
|
"updatedAt": "2026-06-15T11:00:00"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### 根据ID获取团课推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | GET |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend/{id}` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**路径参数**:
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 说明 |
|
||||||
|
|--------|------|------|------|
|
||||||
|
| id | Long | 是 | 团课推荐ID |
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"id": 1,
|
||||||
|
"courseId": 1,
|
||||||
|
"recommendTitle": "本周热门课程",
|
||||||
|
"recommendContent": "这是一门非常棒的课程,快来参加吧!",
|
||||||
|
"recommendReason": "教练专业,课程内容丰富",
|
||||||
|
"priority": 10,
|
||||||
|
"isActive": true,
|
||||||
|
"groupCourse": {
|
||||||
|
"id": 1,
|
||||||
|
"courseName": "瑜伽入门",
|
||||||
|
"coachId": 1,
|
||||||
|
"courseType": 1,
|
||||||
|
"startTime": "2026-06-15T09:00:00",
|
||||||
|
"endTime": "2026-06-15T10:00:00",
|
||||||
|
"maxMembers": 20,
|
||||||
|
"currentMembers": 15,
|
||||||
|
"status": 0,
|
||||||
|
"location": "健身房A区",
|
||||||
|
"coverImage": "https://example.com/yoga.jpg",
|
||||||
|
"description": "适合初学者的瑜伽课程"
|
||||||
|
},
|
||||||
|
"createdAt": "2026-06-15T10:00:00",
|
||||||
|
"updatedAt": "2026-06-15T10:00:00"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
**失败响应** (404 Not Found):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{}
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### 根据团课ID获取推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | GET |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend/course/{courseId}` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**路径参数**:
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 说明 |
|
||||||
|
|--------|------|------|------|
|
||||||
|
| courseId | Long | 是 | 团课ID |
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
[
|
||||||
|
{
|
||||||
|
"id": 1,
|
||||||
|
"courseId": 1,
|
||||||
|
"recommendTitle": "本周热门课程",
|
||||||
|
"recommendContent": "这是一门非常棒的课程,快来参加吧!",
|
||||||
|
"recommendReason": "教练专业,课程内容丰富",
|
||||||
|
"priority": 10,
|
||||||
|
"isActive": true,
|
||||||
|
"groupCourse": {
|
||||||
|
"id": 1,
|
||||||
|
"courseName": "瑜伽入门",
|
||||||
|
"coachId": 1,
|
||||||
|
"courseType": 1,
|
||||||
|
"startTime": "2026-06-15T09:00:00",
|
||||||
|
"endTime": "2026-06-15T10:00:00",
|
||||||
|
"maxMembers": 20,
|
||||||
|
"currentMembers": 15,
|
||||||
|
"status": 0,
|
||||||
|
"location": "健身房A区"
|
||||||
|
},
|
||||||
|
"createdAt": "2026-06-15T10:00:00",
|
||||||
|
"updatedAt": "2026-06-15T10:00:00"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### 创建团课推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | POST |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**请求体**:
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"courseId": 1,
|
||||||
|
"recommendTitle": "本周热门课程",
|
||||||
|
"recommendContent": "这是一门非常棒的课程,快来参加吧!",
|
||||||
|
"recommendReason": "教练专业,课程内容丰富",
|
||||||
|
"priority": 10,
|
||||||
|
"isActive": true
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 默认值 | 说明 |
|
||||||
|
|--------|------|------|--------|------|
|
||||||
|
| courseId | Long | **是** | - | 团课ID(必须是有效的团课) |
|
||||||
|
| recommendTitle | String | 否 | - | 推荐标题 |
|
||||||
|
| recommendContent | String | 否 | - | 推荐内容 |
|
||||||
|
| recommendReason | String | 否 | - | 推荐理由 |
|
||||||
|
| priority | Integer | 否 | 0 | 优先级(数字越大优先级越高) |
|
||||||
|
| isActive | Boolean | 否 | true | 是否启用 |
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": true,
|
||||||
|
"message": "团课推荐创建成功",
|
||||||
|
"data": {
|
||||||
|
"id": 1,
|
||||||
|
"courseId": 1,
|
||||||
|
"recommendTitle": "本周热门课程",
|
||||||
|
"recommendContent": "这是一门非常棒的课程,快来参加吧!",
|
||||||
|
"recommendReason": "教练专业,课程内容丰富",
|
||||||
|
"priority": 10,
|
||||||
|
"isActive": true,
|
||||||
|
"createdAt": "2026-06-15T10:00:00",
|
||||||
|
"updatedAt": "2026-06-15T10:00:00"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
**失败响应** (400 Bad Request):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": false,
|
||||||
|
"message": "团课ID不能为空"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### 更新团课推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | PUT |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend/{id}` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**路径参数**:
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 说明 |
|
||||||
|
|--------|------|------|------|
|
||||||
|
| id | Long | 是 | 团课推荐ID |
|
||||||
|
|
||||||
|
**请求体**:
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"recommendTitle": "本周热门课程(更新)",
|
||||||
|
"recommendContent": "更新后的推荐内容",
|
||||||
|
"recommendReason": "更新后的推荐理由",
|
||||||
|
"priority": 15,
|
||||||
|
"isActive": true
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 说明 |
|
||||||
|
|--------|------|------|------|
|
||||||
|
| courseId | Long | 否 | 团课ID |
|
||||||
|
| recommendTitle | String | 否 | 推荐标题 |
|
||||||
|
| recommendContent | String | 否 | 推荐内容 |
|
||||||
|
| recommendReason | String | 否 | 推荐理由 |
|
||||||
|
| priority | Integer | 否 | 优先级 |
|
||||||
|
| isActive | Boolean | 否 | 是否启用 |
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": true,
|
||||||
|
"message": "团课推荐更新成功",
|
||||||
|
"data": {
|
||||||
|
"id": 1,
|
||||||
|
"courseId": 1,
|
||||||
|
"recommendTitle": "本周热门课程(更新)",
|
||||||
|
"recommendContent": "更新后的推荐内容",
|
||||||
|
"recommendReason": "更新后的推荐理由",
|
||||||
|
"priority": 15,
|
||||||
|
"isActive": true,
|
||||||
|
"updatedAt": "2026-06-15T12:00:00"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
**失败响应** (400 Bad Request):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": false,
|
||||||
|
"message": "团课推荐不存在"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### 删除团课推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | DELETE |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend/{id}` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**路径参数**:
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 说明 |
|
||||||
|
|--------|------|------|------|
|
||||||
|
| id | Long | 是 | 团课推荐ID |
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": true,
|
||||||
|
"message": "团课推荐删除成功"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
**失败响应** (400 Bad Request):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": false,
|
||||||
|
"message": "团课推荐不存在"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### 启用团课推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | POST |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend/{id}/enable` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**路径参数**:
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 说明 |
|
||||||
|
|--------|------|------|------|
|
||||||
|
| id | Long | 是 | 团课推荐ID |
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": true,
|
||||||
|
"message": "团课推荐启用成功",
|
||||||
|
"data": {
|
||||||
|
"id": 1,
|
||||||
|
"courseId": 1,
|
||||||
|
"recommendTitle": "本周热门课程",
|
||||||
|
"isActive": true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
**失败响应** (400 Bad Request):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": false,
|
||||||
|
"message": "团课推荐不存在"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
### 禁用团课推荐
|
||||||
|
|
||||||
|
| 属性 | 值 |
|
||||||
|
|------|-----|
|
||||||
|
| **HTTP方法** | POST |
|
||||||
|
| **接口路径** | `/api/groupCourse/recommend/{id}/disable` |
|
||||||
|
| **所属文件** | `GroupCourseRecommendHandler.java` |
|
||||||
|
|
||||||
|
**路径参数**:
|
||||||
|
|
||||||
|
| 参数名 | 类型 | 必填 | 说明 |
|
||||||
|
|--------|------|------|------|
|
||||||
|
| id | Long | 是 | 团课推荐ID |
|
||||||
|
|
||||||
|
**成功响应** (200 OK):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": true,
|
||||||
|
"message": "团课推荐禁用成功",
|
||||||
|
"data": {
|
||||||
|
"id": 1,
|
||||||
|
"courseId": 1,
|
||||||
|
"recommendTitle": "本周热门课程",
|
||||||
|
"isActive": false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
**失败响应** (400 Bad Request):
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": false,
|
||||||
|
"message": "团课推荐不存在"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 数据模型
|
||||||
|
|
||||||
|
### GroupCourseRecommend(团课推荐)
|
||||||
|
|
||||||
|
| 字段名 | 类型 | 说明 |
|
||||||
|
|--------|------|------|
|
||||||
|
| id | Long | 主键ID |
|
||||||
|
| courseId | Long | 团课ID(关联group_course.id) |
|
||||||
|
| recommendTitle | String | 推荐标题 |
|
||||||
|
| recommendContent | String | 推荐内容 |
|
||||||
|
| recommendReason | String | 推荐理由 |
|
||||||
|
| priority | Integer | 优先级(数字越大优先级越高),默认0 |
|
||||||
|
| isActive | Boolean | 是否启用,默认true |
|
||||||
|
| groupCourse | GroupCourse | 关联的团课信息(查询时自动填充) |
|
||||||
|
| createdBy | String | 创建人 |
|
||||||
|
| updatedBy | String | 更新人 |
|
||||||
|
| createdAt | LocalDateTime | 创建时间 |
|
||||||
|
| updatedAt | LocalDateTime | 更新时间 |
|
||||||
|
| deletedAt | LocalDateTime | 删除时间(软删除) |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 状态码说明
|
||||||
|
|
||||||
|
### 推荐状态
|
||||||
|
|
||||||
|
| 状态值 | 含义 |
|
||||||
|
|--------|------|
|
||||||
|
| true | 启用 |
|
||||||
|
| false | 禁用 |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 业务规则
|
||||||
|
|
||||||
|
### 团课推荐管理
|
||||||
|
1. **创建推荐**:团课ID为必填项,且必须是有效的团课
|
||||||
|
2. **优先级排序**:获取启用的推荐列表时,按优先级从高到低排序
|
||||||
|
3. **删除推荐**:采用软删除机制,数据保留可恢复
|
||||||
|
4. **状态管理**:支持启用/禁用推荐状态,禁用的推荐不会在推荐列表中显示
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## 附录:错误响应格式
|
||||||
|
|
||||||
|
所有接口的错误响应统一格式:
|
||||||
|
|
||||||
|
```json
|
||||||
|
{
|
||||||
|
"success": false,
|
||||||
|
"message": "错误描述信息"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
*文档结束*
|
||||||
@@ -0,0 +1,87 @@
|
|||||||
|
一、基础有氧与热身(难度 1-3)
|
||||||
|
|
||||||
|
主要是低冲击、低技巧,用于建立运动基础。
|
||||||
|
|
||||||
|
慢走/椭圆机轻松模式:1(几乎无难度,适合所有人)
|
||||||
|
|
||||||
|
固定自行车(低阻力):2(注意座椅高度调节即可)
|
||||||
|
|
||||||
|
跑步机慢跑:3(需要基本协调性,膝盖有压力)
|
||||||
|
|
||||||
|
跳绳(连续基础跳):3(需要手脚配合,心肺要求明显)
|
||||||
|
|
||||||
|
二、固定器械训练(难度 2-5)
|
||||||
|
|
||||||
|
轨迹固定,主要考验力量和耐力,技巧要求低。
|
||||||
|
|
||||||
|
坐姿腿屈伸/腿弯举:2(很容易找到发力感)
|
||||||
|
|
||||||
|
坐姿推胸机:3(需注意肩胛后收,避免耸肩)
|
||||||
|
|
||||||
|
高位下拉(坐姿):3(需控制不要过度后仰)
|
||||||
|
|
||||||
|
史密斯机深蹲:4(轨迹固定,但需保持核心稳定)
|
||||||
|
|
||||||
|
蝴蝶机夹胸:3(易用肘关节代偿,需锁定肩关节)
|
||||||
|
|
||||||
|
三、自重基础动作(难度 3-7)
|
||||||
|
|
||||||
|
需要一定的力量-体重比和身体控制能力。
|
||||||
|
|
||||||
|
平板支撑:3(耐力考验,技巧低)
|
||||||
|
|
||||||
|
跪姿俯卧撑:3(上肢力量较弱者首选)
|
||||||
|
|
||||||
|
标准俯卧撑:5(需核心收紧,身体成直线)
|
||||||
|
|
||||||
|
引体向上(弹力带辅助):6(背部和手臂力量要求高)
|
||||||
|
|
||||||
|
标准引体向上:8(力量-体重比极高,多数男性无法完成1次)
|
||||||
|
|
||||||
|
徒手深蹲:3(注意膝盖方向与背部直立)
|
||||||
|
|
||||||
|
单腿深蹲(手枪蹲):8(需要极高下肢力量、柔韧性和平衡)
|
||||||
|
|
||||||
|
四、自由重量杠铃/哑铃(难度 5-9)
|
||||||
|
|
||||||
|
技巧风险最高,需要神经系统协调和长期动作打磨。
|
||||||
|
|
||||||
|
哑铃二头弯举:4(容易晃动借力,但较安全)
|
||||||
|
|
||||||
|
哑铃侧平举:5(极易用斜方肌代偿,真正练到三角肌中束很难)
|
||||||
|
|
||||||
|
杠铃卧推:7(肩关节压力大,起桥、沉肩、稳定手腕均有技巧,有压伤风险)
|
||||||
|
|
||||||
|
杠铃深蹲(颈后):8(全身协调性、核心抗压、杠位放置、呼吸模式,学习曲线陡峭)
|
||||||
|
|
||||||
|
传统硬拉:9(风险极高,需要精确的脊柱中立、髋铰链、背阔肌收紧,错误时伤腰)
|
||||||
|
|
||||||
|
高翻/抓举(奥运举重):10(需要爆发力、柔韧、精准衔接,非数月训练不能掌握)
|
||||||
|
|
||||||
|
五、高强度与爆发力(难度 6-10)
|
||||||
|
|
||||||
|
对心肺、神经系统和恢复能力要求极高。
|
||||||
|
|
||||||
|
波比跳(标准版):6(连续做时心肺压力极大)
|
||||||
|
|
||||||
|
冲刺跑(短跑):7(对腘绳肌和脚踝爆发力要求高)
|
||||||
|
|
||||||
|
跳箱(合理高度):6(需要落地缓冲技巧)
|
||||||
|
|
||||||
|
负重雪橇推:6(主要考验腿部耐力和意志力)
|
||||||
|
|
||||||
|
双力臂(引体向上后翻腕上杠):9(需要爆发引体 + 极高相对力量)
|
||||||
|
|
||||||
|
六、柔韧与平衡类(难度 3-8)
|
||||||
|
|
||||||
|
考验本体感觉和关节活动度。
|
||||||
|
|
||||||
|
静态拉伸(坐姿体前屈):2(无风险,但需要坚持)
|
||||||
|
|
||||||
|
瑜伽下犬式:3(常见,但需背部与手臂对齐)
|
||||||
|
|
||||||
|
单腿罗马尼亚硬拉(徒手):6(极考验平衡和髋稳定)
|
||||||
|
|
||||||
|
全深蹲(脚跟贴地,亚洲蹲):5(踝关节灵活度限制多数人)
|
||||||
|
|
||||||
|
竖叉/横叉:8(需要数月甚至数年拉伸)
|
||||||
@@ -35,6 +35,11 @@
|
|||||||
<artifactId>manage-common</artifactId>
|
<artifactId>manage-common</artifactId>
|
||||||
<version>${project.version}</version>
|
<version>${project.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>cn.novalon.gym.manage</groupId>
|
||||||
|
<artifactId>manage-sys</artifactId>
|
||||||
|
<version>${project.version}</version>
|
||||||
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>cn.novalon.gym.manage</groupId>
|
<groupId>cn.novalon.gym.manage</groupId>
|
||||||
<artifactId>manage-db</artifactId>
|
<artifactId>manage-db</artifactId>
|
||||||
@@ -81,6 +86,25 @@
|
|||||||
<artifactId>gym-member</artifactId>
|
<artifactId>gym-member</artifactId>
|
||||||
<version>${project.version}</version>
|
<version>${project.version}</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
|
<!-- ZXing二维码生成库 -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.google.zxing</groupId>
|
||||||
|
<artifactId>core</artifactId>
|
||||||
|
<version>3.5.3</version>
|
||||||
|
</dependency>
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.google.zxing</groupId>
|
||||||
|
<artifactId>javase</artifactId>
|
||||||
|
<version>3.5.3</version>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
|
<!-- 阿里云OSS SDK -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>com.aliyun.oss</groupId>
|
||||||
|
<artifactId>aliyun-sdk-oss</artifactId>
|
||||||
|
<version>3.17.1</version>
|
||||||
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
<build>
|
<build>
|
||||||
|
|||||||
+31
@@ -4,8 +4,10 @@ package cn.novalon.gym.manage.groupcourse.converter;
|
|||||||
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.bean.BeanUtil;
|
||||||
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseBooking;
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseBooking;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
|
||||||
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseBookingEntity;
|
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseBookingEntity;
|
||||||
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseEntity;
|
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseEntity;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseTypeEntity;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
@@ -124,4 +126,33 @@ public class GroupCourseConverter {
|
|||||||
.map(this::toBookingEntity)
|
.map(this::toBookingEntity)
|
||||||
.collect(Collectors.toList());
|
.collect(Collectors.toList());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 将团课类型实体转换为领域模型
|
||||||
|
*/
|
||||||
|
public GroupCourseType toGroupCourseType(GroupCourseTypeEntity entity){
|
||||||
|
if(entity == null){
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
GroupCourseType groupCourseType = new GroupCourseType();
|
||||||
|
BeanUtil.copyProperties(entity, groupCourseType);
|
||||||
|
log.debug("转换团课类型实体到领域模型:typeId={}", entity.getId());
|
||||||
|
return groupCourseType;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 将团课类型领域模型转换为实体
|
||||||
|
*/
|
||||||
|
public GroupCourseTypeEntity toGroupCourseTypeEntity(GroupCourseType domain){
|
||||||
|
if(domain == null){
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
GroupCourseTypeEntity entity = new GroupCourseTypeEntity();
|
||||||
|
BeanUtil.copyProperties(domain, entity);
|
||||||
|
if (domain.getId() != null) {
|
||||||
|
entity.markNotNew();
|
||||||
|
}
|
||||||
|
log.debug("转换团课类型领域模型到实体:typeId={}", domain.getId());
|
||||||
|
return entity;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+27
@@ -0,0 +1,27 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.dao;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.entity.CourseLabelEntity;
|
||||||
|
import org.springframework.data.r2dbc.repository.Modifying;
|
||||||
|
import org.springframework.data.r2dbc.repository.Query;
|
||||||
|
import org.springframework.data.r2dbc.repository.R2dbcRepository;
|
||||||
|
import org.springframework.stereotype.Repository;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
@Repository
|
||||||
|
public interface CourseLabelDao extends R2dbcRepository<CourseLabelEntity, Long> {
|
||||||
|
|
||||||
|
Mono<CourseLabelEntity> findByIdIsAndDeletedAtIsNull(Long id);
|
||||||
|
|
||||||
|
Flux<CourseLabelEntity> findAllByDeletedAtIsNull();
|
||||||
|
|
||||||
|
Flux<CourseLabelEntity> findByLabelNameContainingAndDeletedAtIsNull(String labelName);
|
||||||
|
|
||||||
|
Mono<CourseLabelEntity> findByLabelNameAndDeletedAtIsNull(String labelName);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("UPDATE course_label SET deleted_at = :deletedAt WHERE id = :id")
|
||||||
|
Mono<Integer> softDelete(Long id, LocalDateTime deletedAt);
|
||||||
|
}
|
||||||
+38
@@ -0,0 +1,38 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.dao;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.entity.CourseTypeLabelEntity;
|
||||||
|
import org.springframework.data.r2dbc.repository.Modifying;
|
||||||
|
import org.springframework.data.r2dbc.repository.Query;
|
||||||
|
import org.springframework.data.r2dbc.repository.R2dbcRepository;
|
||||||
|
import org.springframework.stereotype.Repository;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
@Repository
|
||||||
|
public interface CourseTypeLabelDao extends R2dbcRepository<CourseTypeLabelEntity, Long> {
|
||||||
|
|
||||||
|
Flux<CourseTypeLabelEntity> findByTypeIdAndDeletedAtIsNull(Long typeId);
|
||||||
|
|
||||||
|
Flux<CourseTypeLabelEntity> findByLabelIdAndDeletedAtIsNull(Long labelId);
|
||||||
|
|
||||||
|
Mono<CourseTypeLabelEntity> findByTypeIdAndLabelIdAndDeletedAtIsNull(Long typeId, Long labelId);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("UPDATE course_type_label SET deleted_at = :deletedAt WHERE type_id = :typeId AND label_id = :labelId")
|
||||||
|
Mono<Integer> deleteByTypeIdAndLabelId(Long typeId, Long labelId, LocalDateTime deletedAt);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("UPDATE course_type_label SET deleted_at = :deletedAt WHERE type_id = :typeId")
|
||||||
|
Mono<Integer> deleteByTypeId(Long typeId, LocalDateTime deletedAt);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("DELETE FROM course_type_label WHERE type_id = :typeId AND label_id = :labelId")
|
||||||
|
Mono<Integer> physicalDeleteByTypeIdAndLabelId(Long typeId, Long labelId);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("UPDATE course_type_label SET deleted_at = :deletedAt WHERE label_id = :labelId")
|
||||||
|
Mono<Integer> deleteByLabelId(Long labelId, LocalDateTime deletedAt);
|
||||||
|
}
|
||||||
+187
-2
@@ -1,16 +1,19 @@
|
|||||||
|
|
||||||
package cn.novalon.gym.manage.groupcourse.dao;
|
package cn.novalon.gym.manage.groupcourse.dao;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dto.GroupCourseQueryDto;
|
||||||
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseEntity;
|
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseEntity;
|
||||||
import org.springframework.data.domain.Sort;
|
import org.springframework.data.domain.Sort;
|
||||||
import org.springframework.data.r2dbc.repository.Modifying;
|
import org.springframework.data.r2dbc.repository.Modifying;
|
||||||
import org.springframework.data.r2dbc.repository.Query;
|
import org.springframework.data.r2dbc.repository.Query;
|
||||||
import org.springframework.data.r2dbc.repository.R2dbcRepository;
|
import org.springframework.data.r2dbc.repository.R2dbcRepository;
|
||||||
|
import org.springframework.r2dbc.core.DatabaseClient;
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
import reactor.core.publisher.Flux;
|
import reactor.core.publisher.Flux;
|
||||||
import reactor.core.publisher.Mono;
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
@Repository
|
@Repository
|
||||||
public interface GroupCourseDao extends R2dbcRepository<GroupCourseEntity, Long> {
|
public interface GroupCourseDao extends R2dbcRepository<GroupCourseEntity, Long> {
|
||||||
@@ -36,4 +39,186 @@ public interface GroupCourseDao extends R2dbcRepository<GroupCourseEntity, Long>
|
|||||||
@Modifying
|
@Modifying
|
||||||
@Query("UPDATE group_course SET deleted_at = :deletedAt WHERE id = :id")
|
@Query("UPDATE group_course SET deleted_at = :deletedAt WHERE id = :id")
|
||||||
Mono<Integer> softDelete(Long id, LocalDateTime deletedAt);
|
Mono<Integer> softDelete(Long id, LocalDateTime deletedAt);
|
||||||
}
|
|
||||||
|
Flux<GroupCourseEntity> findByCourseTypeAndDeletedAtIsNull(Long courseType);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 多条件查询团课(使用 DatabaseClient 构建动态 SQL)
|
||||||
|
*/
|
||||||
|
default Flux<GroupCourseEntity> searchGroupCourses(DatabaseClient databaseClient, GroupCourseQueryDto query) {
|
||||||
|
StringBuilder sql = new StringBuilder("SELECT * FROM group_course WHERE deleted_at IS NULL");
|
||||||
|
List<String> conditions = new ArrayList<>();
|
||||||
|
|
||||||
|
// 默认不查询不可预约的团课(仅查询 status = '0')
|
||||||
|
conditions.add("status = '0'");
|
||||||
|
|
||||||
|
// 1. 团课名称模糊查询
|
||||||
|
if (query.getCourseName() != null && !query.getCourseName().isEmpty()) {
|
||||||
|
conditions.add("course_name ILIKE :courseName");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2. 基于团课类型查询
|
||||||
|
if (query.getCourseType() != null) {
|
||||||
|
conditions.add("course_type = :courseType");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3. 基于日期时间段查询
|
||||||
|
if (query.getStartDate() != null) {
|
||||||
|
conditions.add("start_time >= :startDate");
|
||||||
|
}
|
||||||
|
if (query.getEndDate() != null) {
|
||||||
|
conditions.add("start_time <= :endDate");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 4. 基于早晨/下午/夜晚时间段查询
|
||||||
|
if (query.getTimePeriod() != null && !query.getTimePeriod().isEmpty()) {
|
||||||
|
switch (query.getTimePeriod().toLowerCase()) {
|
||||||
|
case "morning":
|
||||||
|
conditions.add("EXTRACT(HOUR FROM start_time) >= 6 AND EXTRACT(HOUR FROM start_time) < 12");
|
||||||
|
break;
|
||||||
|
case "afternoon":
|
||||||
|
conditions.add("EXTRACT(HOUR FROM start_time) >= 12 AND EXTRACT(HOUR FROM start_time) < 18");
|
||||||
|
break;
|
||||||
|
case "evening":
|
||||||
|
conditions.add("EXTRACT(HOUR FROM start_time) >= 18 AND EXTRACT(HOUR FROM start_time) < 24");
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
sql.append(" AND ").append(String.join(" AND ", conditions));
|
||||||
|
|
||||||
|
// 5. 价格排序 / 6. 剩余名额最多排序
|
||||||
|
boolean hasPriceSort = query.getPriceSort() != null && !query.getPriceSort().isEmpty();
|
||||||
|
boolean hasRemainingMost = query.getRemainingMost() != null && query.getRemainingMost();
|
||||||
|
|
||||||
|
if (hasPriceSort || hasRemainingMost) {
|
||||||
|
sql.append(" ORDER BY");
|
||||||
|
List<String> orderClauses = new ArrayList<>();
|
||||||
|
|
||||||
|
if (hasRemainingMost) {
|
||||||
|
orderClauses.add(" (max_members - current_members) DESC");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (hasPriceSort) {
|
||||||
|
if ("asc".equalsIgnoreCase(query.getPriceSort())) {
|
||||||
|
orderClauses.add(" stored_value_amount ASC");
|
||||||
|
} else if ("desc".equalsIgnoreCase(query.getPriceSort())) {
|
||||||
|
orderClauses.add(" stored_value_amount DESC");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
sql.append(String.join(",", orderClauses));
|
||||||
|
} else {
|
||||||
|
sql.append(" ORDER BY start_time ASC");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 分页
|
||||||
|
int page = query.getPage() != null ? query.getPage() : 0;
|
||||||
|
int size = query.getSize() != null ? query.getSize() : 10;
|
||||||
|
if (size < 1) size = 10;
|
||||||
|
if (size > 100) size = 100;
|
||||||
|
int offset = page * size;
|
||||||
|
sql.append(" LIMIT :limit OFFSET :offset");
|
||||||
|
|
||||||
|
DatabaseClient.GenericExecuteSpec spec = databaseClient.sql(sql.toString());
|
||||||
|
|
||||||
|
if (query.getCourseName() != null && !query.getCourseName().isEmpty()) {
|
||||||
|
spec = spec.bind("courseName", "%" + query.getCourseName() + "%");
|
||||||
|
}
|
||||||
|
if (query.getCourseType() != null) {
|
||||||
|
spec = spec.bind("courseType", query.getCourseType());
|
||||||
|
}
|
||||||
|
if (query.getStartDate() != null) {
|
||||||
|
spec = spec.bind("startDate", query.getStartDate());
|
||||||
|
}
|
||||||
|
if (query.getEndDate() != null) {
|
||||||
|
spec = spec.bind("endDate", query.getEndDate());
|
||||||
|
}
|
||||||
|
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.setPointCardAmount(row.get("point_card_amount", Integer.class));
|
||||||
|
entity.setStoredValueAmount(row.get("stored_value_amount", java.math.BigDecimal.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();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 多条件查询团课总数
|
||||||
|
*/
|
||||||
|
default Mono<Long> countSearchGroupCourses(DatabaseClient databaseClient, GroupCourseQueryDto query) {
|
||||||
|
StringBuilder sql = new StringBuilder("SELECT COUNT(*) FROM group_course WHERE deleted_at IS NULL");
|
||||||
|
List<String> conditions = new ArrayList<>();
|
||||||
|
|
||||||
|
conditions.add("status = '0'");
|
||||||
|
|
||||||
|
if (query.getCourseName() != null && !query.getCourseName().isEmpty()) {
|
||||||
|
conditions.add("course_name ILIKE :courseName");
|
||||||
|
}
|
||||||
|
if (query.getCourseType() != null) {
|
||||||
|
conditions.add("course_type = :courseType");
|
||||||
|
}
|
||||||
|
if (query.getStartDate() != null) {
|
||||||
|
conditions.add("start_time >= :startDate");
|
||||||
|
}
|
||||||
|
if (query.getEndDate() != null) {
|
||||||
|
conditions.add("start_time <= :endDate");
|
||||||
|
}
|
||||||
|
if (query.getTimePeriod() != null && !query.getTimePeriod().isEmpty()) {
|
||||||
|
switch (query.getTimePeriod().toLowerCase()) {
|
||||||
|
case "morning":
|
||||||
|
conditions.add("EXTRACT(HOUR FROM start_time) >= 6 AND EXTRACT(HOUR FROM start_time) < 12");
|
||||||
|
break;
|
||||||
|
case "afternoon":
|
||||||
|
conditions.add("EXTRACT(HOUR FROM start_time) >= 12 AND EXTRACT(HOUR FROM start_time) < 18");
|
||||||
|
break;
|
||||||
|
case "evening":
|
||||||
|
conditions.add("EXTRACT(HOUR FROM start_time) >= 18 AND EXTRACT(HOUR FROM start_time) < 24");
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
sql.append(" AND ").append(String.join(" AND ", conditions));
|
||||||
|
|
||||||
|
DatabaseClient.GenericExecuteSpec spec = databaseClient.sql(sql.toString());
|
||||||
|
|
||||||
|
if (query.getCourseName() != null && !query.getCourseName().isEmpty()) {
|
||||||
|
spec = spec.bind("courseName", "%" + query.getCourseName() + "%");
|
||||||
|
}
|
||||||
|
if (query.getCourseType() != null) {
|
||||||
|
spec = spec.bind("courseType", query.getCourseType());
|
||||||
|
}
|
||||||
|
if (query.getStartDate() != null) {
|
||||||
|
spec = spec.bind("startDate", query.getStartDate());
|
||||||
|
}
|
||||||
|
if (query.getEndDate() != null) {
|
||||||
|
spec = spec.bind("endDate", query.getEndDate());
|
||||||
|
}
|
||||||
|
|
||||||
|
return spec.map((row, meta) -> row.get(0, Long.class)).one();
|
||||||
|
}
|
||||||
|
}
|
||||||
+42
@@ -0,0 +1,42 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.dao;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseRecommendEntity;
|
||||||
|
import org.springframework.data.domain.Sort;
|
||||||
|
import org.springframework.data.r2dbc.repository.Modifying;
|
||||||
|
import org.springframework.data.r2dbc.repository.Query;
|
||||||
|
import org.springframework.data.r2dbc.repository.R2dbcRepository;
|
||||||
|
import org.springframework.stereotype.Repository;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
@Repository
|
||||||
|
public interface GroupCourseRecommendDao extends R2dbcRepository<GroupCourseRecommendEntity, Long> {
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommendEntity> findByIdAndDeletedAtIsNull(Long id);
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommendEntity> findAllByDeletedAtIsNull();
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommendEntity> findAllByDeletedAtIsNull(Sort sort);
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommendEntity> findByCourseIdAndDeletedAtIsNull(Long courseId);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommendEntity> findByCourseIdAndDeletedAtIsNullAndIsActiveTrue(Long courseId);
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommendEntity> findByIsActiveTrueAndDeletedAtIsNull();
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommendEntity> findByIsActiveTrueAndDeletedAtIsNull(Sort sort);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("UPDATE group_course_recommend SET is_active = :isActive, updated_at = :updatedAt WHERE id = :id AND deleted_at IS NULL")
|
||||||
|
Mono<Integer> updateActiveStatus(Long id, Boolean isActive, LocalDateTime updatedAt);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("UPDATE group_course_recommend SET deleted_at = :deletedAt WHERE id = :id")
|
||||||
|
Mono<Integer> softDelete(Long id, LocalDateTime deletedAt);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("UPDATE group_course_recommend SET deleted_at = :deletedAt WHERE course_id = :courseId")
|
||||||
|
Mono<Integer> softDeleteByCourseId(Long courseId, LocalDateTime deletedAt);
|
||||||
|
}
|
||||||
+32
@@ -0,0 +1,32 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.dao;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseTypeEntity;
|
||||||
|
import org.springframework.data.domain.Sort;
|
||||||
|
import org.springframework.data.r2dbc.repository.Modifying;
|
||||||
|
import org.springframework.data.r2dbc.repository.Query;
|
||||||
|
import org.springframework.data.r2dbc.repository.R2dbcRepository;
|
||||||
|
import org.springframework.stereotype.Repository;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
@Repository
|
||||||
|
public interface GroupCourseTypeDao extends R2dbcRepository<GroupCourseTypeEntity, Long> {
|
||||||
|
|
||||||
|
Mono<GroupCourseTypeEntity> findByIdIsAndDeletedAtIsNull(Long id);
|
||||||
|
|
||||||
|
Flux<GroupCourseTypeEntity> findAllByDeletedAtIsNull();
|
||||||
|
|
||||||
|
Flux<GroupCourseTypeEntity> findAllByDeletedAtIsNull(Sort sort);
|
||||||
|
|
||||||
|
Flux<GroupCourseTypeEntity> findByTypeNameContainingAndDeletedAtIsNull(String typeName);
|
||||||
|
|
||||||
|
Flux<GroupCourseTypeEntity> findByCategoryAndDeletedAtIsNull(String category);
|
||||||
|
|
||||||
|
Mono<GroupCourseTypeEntity> findByTypeNameAndDeletedAtIsNull(String typeName);
|
||||||
|
|
||||||
|
@Modifying
|
||||||
|
@Query("UPDATE group_course_type SET deleted_at = :deletedAt WHERE id = :id")
|
||||||
|
Mono<Integer> softDelete(Long id, LocalDateTime deletedAt);
|
||||||
|
}
|
||||||
+43
@@ -0,0 +1,43 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.domain;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.sys.core.domain.BaseDomain;
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
|
||||||
|
public class CourseLabel extends BaseDomain {
|
||||||
|
|
||||||
|
//标签名称
|
||||||
|
@Schema(description = "标签名称", example = "适合新手")
|
||||||
|
private String labelName;
|
||||||
|
|
||||||
|
//标签颜色(十六进制)
|
||||||
|
@Schema(description = "标签颜色(十六进制)", example = "#52c41a")
|
||||||
|
private String color;
|
||||||
|
|
||||||
|
//标签描述
|
||||||
|
@Schema(description = "标签描述", example = "适合健身初学者")
|
||||||
|
private String description;
|
||||||
|
|
||||||
|
public String getLabelName() {
|
||||||
|
return labelName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setLabelName(String labelName) {
|
||||||
|
this.labelName = labelName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getColor() {
|
||||||
|
return color;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setColor(String color) {
|
||||||
|
this.color = color;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getDescription() {
|
||||||
|
return description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setDescription(String description) {
|
||||||
|
this.description = description;
|
||||||
|
}
|
||||||
|
}
|
||||||
+12
@@ -60,6 +60,10 @@ public class GroupCourse extends BaseDomain{
|
|||||||
@Schema(description = "储值卡额度(消耗金额)", example = "50.00")
|
@Schema(description = "储值卡额度(消耗金额)", example = "50.00")
|
||||||
private java.math.BigDecimal storedValueAmount;
|
private java.math.BigDecimal storedValueAmount;
|
||||||
|
|
||||||
|
//二维码路径
|
||||||
|
@Schema(description = "二维码路径", example = "D:\\Games\\exmp\\image\\abc123_20260618120000.png")
|
||||||
|
private String qrCodePath;
|
||||||
|
|
||||||
public String getCourseName() {
|
public String getCourseName() {
|
||||||
return courseName;
|
return courseName;
|
||||||
}
|
}
|
||||||
@@ -163,4 +167,12 @@ public class GroupCourse extends BaseDomain{
|
|||||||
public void setStoredValueAmount(java.math.BigDecimal storedValueAmount) {
|
public void setStoredValueAmount(java.math.BigDecimal storedValueAmount) {
|
||||||
this.storedValueAmount = storedValueAmount;
|
this.storedValueAmount = storedValueAmount;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public String getQrCodePath() {
|
||||||
|
return qrCodePath;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setQrCodePath(String qrCodePath) {
|
||||||
|
this.qrCodePath = qrCodePath;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+265
@@ -0,0 +1,265 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.domain;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.sys.core.domain.BaseDomain;
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
|
||||||
|
import java.math.BigDecimal;
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 团课完整信息领域模型
|
||||||
|
* 包含团课基础信息、关联的类型信息以及类型的标签信息
|
||||||
|
*/
|
||||||
|
public class GroupCourseDetail extends BaseDomain {
|
||||||
|
|
||||||
|
// ===== 团课基础信息 =====
|
||||||
|
|
||||||
|
@Schema(description = "课程名称", example = "瑜伽入门")
|
||||||
|
private String courseName;
|
||||||
|
|
||||||
|
@Schema(description = "教练ID", example = "1")
|
||||||
|
private Long coachId;
|
||||||
|
|
||||||
|
@Schema(description = "课程类型ID", example = "1")
|
||||||
|
private Long courseType;
|
||||||
|
|
||||||
|
@Schema(description = "开始时间", example = "2026-06-02T09:00:00")
|
||||||
|
private LocalDateTime startTime;
|
||||||
|
|
||||||
|
@Schema(description = "结束时间", example = "2026-06-02T10:00:00")
|
||||||
|
private LocalDateTime endTime;
|
||||||
|
|
||||||
|
@Schema(description = "最大参与人数", example = "20")
|
||||||
|
private Integer maxMembers;
|
||||||
|
|
||||||
|
@Schema(description = "当前参与人数", example = "15")
|
||||||
|
private Integer currentMembers;
|
||||||
|
|
||||||
|
@Schema(description = "课程状态", example = "0")
|
||||||
|
private Long status;
|
||||||
|
|
||||||
|
@Schema(description = "上课地点", example = "健身房A区")
|
||||||
|
private String location;
|
||||||
|
|
||||||
|
@Schema(description = "封面图URL", example = "https://example.com/yoga.jpg")
|
||||||
|
private String coverImage;
|
||||||
|
|
||||||
|
@Schema(description = "课程描述", example = "适合初学者的瑜伽课程")
|
||||||
|
private String description;
|
||||||
|
|
||||||
|
@Schema(description = "点卡额度(消耗次数)", example = "1")
|
||||||
|
private Integer pointCardAmount;
|
||||||
|
|
||||||
|
@Schema(description = "储值卡额度(消耗金额)", example = "50.00")
|
||||||
|
private BigDecimal storedValueAmount;
|
||||||
|
|
||||||
|
@Schema(description = "二维码路径", example = "D:\\Games\\exmp\\image\\abc123_20260618120000.png")
|
||||||
|
private String qrCodePath;
|
||||||
|
|
||||||
|
// ===== 关联的类型信息 =====
|
||||||
|
|
||||||
|
@Schema(description = "类型信息")
|
||||||
|
private GroupCourseType typeInfo;
|
||||||
|
|
||||||
|
// ===== 快捷访问属性(从类型信息派生)=====
|
||||||
|
|
||||||
|
@Schema(description = "类型名称", example = "瑜伽入门")
|
||||||
|
private String typeName;
|
||||||
|
|
||||||
|
@Schema(description = "类型分类", example = "柔韧与平衡类")
|
||||||
|
private String typeCategory;
|
||||||
|
|
||||||
|
@Schema(description = "基础难度", example = "2")
|
||||||
|
private Integer baseDifficulty;
|
||||||
|
|
||||||
|
@Schema(description = "难度等级描述", example = "初级")
|
||||||
|
private String difficultyLevel;
|
||||||
|
|
||||||
|
@Schema(description = "综合难度系数", example = "2")
|
||||||
|
private Integer calculatedDifficulty;
|
||||||
|
|
||||||
|
// ===== 标签信息(从类型标签派生)=====
|
||||||
|
|
||||||
|
@Schema(description = "标签列表")
|
||||||
|
private List<CourseLabel> labels;
|
||||||
|
|
||||||
|
// ===== Getters and Setters =====
|
||||||
|
|
||||||
|
public String getCourseName() {
|
||||||
|
return courseName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCourseName(String courseName) {
|
||||||
|
this.courseName = courseName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Long getCoachId() {
|
||||||
|
return coachId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCoachId(Long coachId) {
|
||||||
|
this.coachId = coachId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Long getCourseType() {
|
||||||
|
return courseType;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCourseType(Long courseType) {
|
||||||
|
this.courseType = courseType;
|
||||||
|
}
|
||||||
|
|
||||||
|
public LocalDateTime getStartTime() {
|
||||||
|
return startTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setStartTime(LocalDateTime startTime) {
|
||||||
|
this.startTime = startTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public LocalDateTime getEndTime() {
|
||||||
|
return endTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setEndTime(LocalDateTime endTime) {
|
||||||
|
this.endTime = endTime;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getMaxMembers() {
|
||||||
|
return maxMembers;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setMaxMembers(Integer maxMembers) {
|
||||||
|
this.maxMembers = maxMembers;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getCurrentMembers() {
|
||||||
|
return currentMembers;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCurrentMembers(Integer currentMembers) {
|
||||||
|
this.currentMembers = currentMembers;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Long getStatus() {
|
||||||
|
return status;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setStatus(Long status) {
|
||||||
|
this.status = status;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getLocation() {
|
||||||
|
return location;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setLocation(String location) {
|
||||||
|
this.location = location;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getCoverImage() {
|
||||||
|
return coverImage;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCoverImage(String coverImage) {
|
||||||
|
this.coverImage = coverImage;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getDescription() {
|
||||||
|
return description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setDescription(String description) {
|
||||||
|
this.description = description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getPointCardAmount() {
|
||||||
|
return pointCardAmount;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setPointCardAmount(Integer pointCardAmount) {
|
||||||
|
this.pointCardAmount = pointCardAmount;
|
||||||
|
}
|
||||||
|
|
||||||
|
public BigDecimal getStoredValueAmount() {
|
||||||
|
return storedValueAmount;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setStoredValueAmount(BigDecimal storedValueAmount) {
|
||||||
|
this.storedValueAmount = storedValueAmount;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getQrCodePath() {
|
||||||
|
return qrCodePath;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setQrCodePath(String qrCodePath) {
|
||||||
|
this.qrCodePath = qrCodePath;
|
||||||
|
}
|
||||||
|
|
||||||
|
public GroupCourseType getTypeInfo() {
|
||||||
|
return typeInfo;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTypeInfo(GroupCourseType typeInfo) {
|
||||||
|
this.typeInfo = typeInfo;
|
||||||
|
// 同步派生属性
|
||||||
|
if (typeInfo != null) {
|
||||||
|
this.typeName = typeInfo.getTypeName();
|
||||||
|
this.typeCategory = typeInfo.getCategory();
|
||||||
|
this.baseDifficulty = typeInfo.getBaseDifficulty();
|
||||||
|
this.difficultyLevel = typeInfo.getDifficultyLevel();
|
||||||
|
this.calculatedDifficulty = typeInfo.getCalculatedDifficulty();
|
||||||
|
this.labels = typeInfo.getLabels();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getTypeName() {
|
||||||
|
return typeName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTypeName(String typeName) {
|
||||||
|
this.typeName = typeName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getTypeCategory() {
|
||||||
|
return typeCategory;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTypeCategory(String typeCategory) {
|
||||||
|
this.typeCategory = typeCategory;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getBaseDifficulty() {
|
||||||
|
return baseDifficulty;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setBaseDifficulty(Integer baseDifficulty) {
|
||||||
|
this.baseDifficulty = baseDifficulty;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getDifficultyLevel() {
|
||||||
|
return difficultyLevel;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setDifficultyLevel(String difficultyLevel) {
|
||||||
|
this.difficultyLevel = difficultyLevel;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getCalculatedDifficulty() {
|
||||||
|
return calculatedDifficulty;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCalculatedDifficulty(Integer calculatedDifficulty) {
|
||||||
|
this.calculatedDifficulty = calculatedDifficulty;
|
||||||
|
}
|
||||||
|
|
||||||
|
public List<CourseLabel> getLabels() {
|
||||||
|
return labels;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setLabels(List<CourseLabel> labels) {
|
||||||
|
this.labels = labels;
|
||||||
|
}
|
||||||
|
}
|
||||||
+84
@@ -0,0 +1,84 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.domain;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.sys.core.domain.BaseDomain;
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
|
||||||
|
public class GroupCourseRecommend extends BaseDomain {
|
||||||
|
|
||||||
|
@Schema(description = "团课ID", example = "1")
|
||||||
|
private Long courseId;
|
||||||
|
|
||||||
|
@Schema(description = "推荐标题", example = "本周热门课程")
|
||||||
|
private String recommendTitle;
|
||||||
|
|
||||||
|
@Schema(description = "推荐内容", example = "这是一门非常棒的课程,快来参加吧!")
|
||||||
|
private String recommendContent;
|
||||||
|
|
||||||
|
@Schema(description = "推荐理由", example = "教练专业,课程内容丰富")
|
||||||
|
private String recommendReason;
|
||||||
|
|
||||||
|
@Schema(description = "优先级(数字越大优先级越高)", example = "10")
|
||||||
|
private Integer priority;
|
||||||
|
|
||||||
|
@Schema(description = "是否启用", example = "true")
|
||||||
|
private Boolean isActive;
|
||||||
|
|
||||||
|
@Schema(description = "团课信息")
|
||||||
|
private GroupCourse groupCourse;
|
||||||
|
|
||||||
|
public Long getCourseId() {
|
||||||
|
return courseId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCourseId(Long courseId) {
|
||||||
|
this.courseId = courseId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getRecommendTitle() {
|
||||||
|
return recommendTitle;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setRecommendTitle(String recommendTitle) {
|
||||||
|
this.recommendTitle = recommendTitle;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getRecommendContent() {
|
||||||
|
return recommendContent;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setRecommendContent(String recommendContent) {
|
||||||
|
this.recommendContent = recommendContent;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getRecommendReason() {
|
||||||
|
return recommendReason;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setRecommendReason(String recommendReason) {
|
||||||
|
this.recommendReason = recommendReason;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getPriority() {
|
||||||
|
return priority;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setPriority(Integer priority) {
|
||||||
|
this.priority = priority;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Boolean getIsActive() {
|
||||||
|
return isActive;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setIsActive(Boolean isActive) {
|
||||||
|
this.isActive = isActive;
|
||||||
|
}
|
||||||
|
|
||||||
|
public GroupCourse getGroupCourse() {
|
||||||
|
return groupCourse;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setGroupCourse(GroupCourse groupCourse) {
|
||||||
|
this.groupCourse = groupCourse;
|
||||||
|
}
|
||||||
|
}
|
||||||
+113
@@ -0,0 +1,113 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.domain;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.sys.core.domain.BaseDomain;
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public class GroupCourseType extends BaseDomain {
|
||||||
|
|
||||||
|
//类型名称
|
||||||
|
@Schema(description = "类型名称", example = "瑜伽入门")
|
||||||
|
private String typeName;
|
||||||
|
|
||||||
|
//基础难度(1-10)
|
||||||
|
@Schema(description = "基础难度(1-10)", example = "2")
|
||||||
|
private Integer baseDifficulty;
|
||||||
|
|
||||||
|
//类型描述
|
||||||
|
@Schema(description = "类型描述", example = "适合初学者的瑜伽课程")
|
||||||
|
private String description;
|
||||||
|
|
||||||
|
//分类(如:有氧、力量、柔韧等)
|
||||||
|
@Schema(description = "分类", example = "柔韧与平衡类")
|
||||||
|
private String category;
|
||||||
|
|
||||||
|
//标签列表
|
||||||
|
@Schema(description = "标签列表")
|
||||||
|
private List<CourseLabel> labels = new ArrayList<>();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 计算综合难度系数
|
||||||
|
*
|
||||||
|
* 当前实现仅返回基础难度,为后续扩展预留空间。
|
||||||
|
* 未来可扩展的影响因素包括:
|
||||||
|
* 1. 课程时长系数(时长越长难度越高)
|
||||||
|
* 2. 教练难度调整系数(教练可根据实际情况微调)
|
||||||
|
* 3. 会员等级适配系数(根据会员等级动态调整显示难度)
|
||||||
|
* 4. 课程强度系数(高强度课程难度加成)
|
||||||
|
*
|
||||||
|
* @return 综合难度系数(1-10)
|
||||||
|
*/
|
||||||
|
@Schema(description = "综合难度系数(预留扩展字段)", example = "2")
|
||||||
|
public Integer getCalculatedDifficulty() {
|
||||||
|
// TODO: 预留扩展点 - 未来可在此处添加更多难度计算逻辑
|
||||||
|
// 例如:return calculateDynamicDifficulty(baseDifficulty, additionalFactors...);
|
||||||
|
return this.baseDifficulty != null ? this.baseDifficulty : 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取难度等级描述
|
||||||
|
* 将数字难度转换为友好的文字描述
|
||||||
|
*
|
||||||
|
* @return 难度等级描述
|
||||||
|
*/
|
||||||
|
@Schema(description = "难度等级描述", example = "初级")
|
||||||
|
public String getDifficultyLevel() {
|
||||||
|
if (baseDifficulty == null) {
|
||||||
|
return "未知";
|
||||||
|
}
|
||||||
|
if (baseDifficulty <= 2) {
|
||||||
|
return "初级";
|
||||||
|
} else if (baseDifficulty <= 4) {
|
||||||
|
return "中级";
|
||||||
|
} else if (baseDifficulty <= 6) {
|
||||||
|
return "中高级";
|
||||||
|
} else if (baseDifficulty <= 8) {
|
||||||
|
return "高级";
|
||||||
|
} else {
|
||||||
|
return "专家级";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getTypeName() {
|
||||||
|
return typeName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTypeName(String typeName) {
|
||||||
|
this.typeName = typeName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getBaseDifficulty() {
|
||||||
|
return baseDifficulty;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setBaseDifficulty(Integer baseDifficulty) {
|
||||||
|
this.baseDifficulty = baseDifficulty;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getDescription() {
|
||||||
|
return description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setDescription(String description) {
|
||||||
|
this.description = description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getCategory() {
|
||||||
|
return category;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCategory(String category) {
|
||||||
|
this.category = category;
|
||||||
|
}
|
||||||
|
|
||||||
|
public List<CourseLabel> getLabels() {
|
||||||
|
return labels;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setLabels(List<CourseLabel> labels) {
|
||||||
|
this.labels = labels;
|
||||||
|
}
|
||||||
|
}
|
||||||
+116
@@ -0,0 +1,116 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.dto;
|
||||||
|
|
||||||
|
import io.swagger.v3.oas.annotations.media.Schema;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 团课多条件查询请求DTO
|
||||||
|
*
|
||||||
|
* @author 张翔
|
||||||
|
* @date 2026-06-14
|
||||||
|
*/
|
||||||
|
@Schema(description = "团课多条件查询参数")
|
||||||
|
public class GroupCourseQueryDto {
|
||||||
|
|
||||||
|
@Schema(description = "课程名称(模糊查询)", example = "瑜伽")
|
||||||
|
private String courseName;
|
||||||
|
|
||||||
|
@Schema(description = "课程类型ID", example = "1")
|
||||||
|
private Long courseType;
|
||||||
|
|
||||||
|
@Schema(description = "查询开始日期", example = "2026-06-01T00:00:00")
|
||||||
|
private LocalDateTime startDate;
|
||||||
|
|
||||||
|
@Schema(description = "查询结束日期", example = "2026-06-30T23:59:59")
|
||||||
|
private LocalDateTime endDate;
|
||||||
|
|
||||||
|
@Schema(description = "时间段:morning-早晨(6:00-12:00), afternoon-下午(12:00-18:00), evening-夜晚(18:00-24:00)", example = "morning")
|
||||||
|
private String timePeriod;
|
||||||
|
|
||||||
|
@Schema(description = "价格排序:asc-从低到高, desc-从高到低", example = "asc")
|
||||||
|
private String priceSort;
|
||||||
|
|
||||||
|
@Schema(description = "按剩余名额最多排序", example = "true")
|
||||||
|
private Boolean remainingMost;
|
||||||
|
|
||||||
|
@Schema(description = "页码", example = "0")
|
||||||
|
private Integer page = 0;
|
||||||
|
|
||||||
|
@Schema(description = "每页大小", example = "10")
|
||||||
|
private Integer size = 10;
|
||||||
|
|
||||||
|
// ===== Getters and Setters =====
|
||||||
|
|
||||||
|
public String getCourseName() {
|
||||||
|
return courseName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCourseName(String courseName) {
|
||||||
|
this.courseName = courseName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Long getCourseType() {
|
||||||
|
return courseType;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCourseType(Long courseType) {
|
||||||
|
this.courseType = courseType;
|
||||||
|
}
|
||||||
|
|
||||||
|
public LocalDateTime getStartDate() {
|
||||||
|
return startDate;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setStartDate(LocalDateTime startDate) {
|
||||||
|
this.startDate = startDate;
|
||||||
|
}
|
||||||
|
|
||||||
|
public LocalDateTime getEndDate() {
|
||||||
|
return endDate;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setEndDate(LocalDateTime endDate) {
|
||||||
|
this.endDate = endDate;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getTimePeriod() {
|
||||||
|
return timePeriod;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTimePeriod(String timePeriod) {
|
||||||
|
this.timePeriod = timePeriod;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getPriceSort() {
|
||||||
|
return priceSort;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setPriceSort(String priceSort) {
|
||||||
|
this.priceSort = priceSort;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Boolean getRemainingMost() {
|
||||||
|
return remainingMost;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setRemainingMost(Boolean remainingMost) {
|
||||||
|
this.remainingMost = remainingMost;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getPage() {
|
||||||
|
return page;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setPage(Integer page) {
|
||||||
|
this.page = page;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getSize() {
|
||||||
|
return size;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setSize(Integer size) {
|
||||||
|
this.size = size;
|
||||||
|
}
|
||||||
|
}
|
||||||
+45
@@ -0,0 +1,45 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.entity;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.db.entity.BaseEntity;
|
||||||
|
import org.springframework.data.relational.core.mapping.Column;
|
||||||
|
import org.springframework.data.relational.core.mapping.Table;
|
||||||
|
|
||||||
|
@Table("course_label")
|
||||||
|
public class CourseLabelEntity extends BaseEntity {
|
||||||
|
|
||||||
|
//标签名称
|
||||||
|
@Column("label_name")
|
||||||
|
private String labelName;
|
||||||
|
|
||||||
|
//标签颜色(十六进制)
|
||||||
|
@Column("color")
|
||||||
|
private String color;
|
||||||
|
|
||||||
|
//标签描述
|
||||||
|
@Column("description")
|
||||||
|
private String description;
|
||||||
|
|
||||||
|
public String getLabelName() {
|
||||||
|
return labelName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setLabelName(String labelName) {
|
||||||
|
this.labelName = labelName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getColor() {
|
||||||
|
return color;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setColor(String color) {
|
||||||
|
this.color = color;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getDescription() {
|
||||||
|
return description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setDescription(String description) {
|
||||||
|
this.description = description;
|
||||||
|
}
|
||||||
|
}
|
||||||
+33
@@ -0,0 +1,33 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.entity;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.db.entity.BaseEntity;
|
||||||
|
import org.springframework.data.relational.core.mapping.Column;
|
||||||
|
import org.springframework.data.relational.core.mapping.Table;
|
||||||
|
|
||||||
|
@Table("course_type_label")
|
||||||
|
public class CourseTypeLabelEntity extends BaseEntity {
|
||||||
|
|
||||||
|
//团课类型ID
|
||||||
|
@Column("type_id")
|
||||||
|
private Long typeId;
|
||||||
|
|
||||||
|
//标签ID
|
||||||
|
@Column("label_id")
|
||||||
|
private Long labelId;
|
||||||
|
|
||||||
|
public Long getTypeId() {
|
||||||
|
return typeId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTypeId(Long typeId) {
|
||||||
|
this.typeId = typeId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Long getLabelId() {
|
||||||
|
return labelId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setLabelId(Long labelId) {
|
||||||
|
this.labelId = labelId;
|
||||||
|
}
|
||||||
|
}
|
||||||
+12
@@ -62,6 +62,10 @@ public class GroupCourseEntity extends BaseEntity {
|
|||||||
@Column("stored_value_amount")
|
@Column("stored_value_amount")
|
||||||
private java.math.BigDecimal storedValueAmount;
|
private java.math.BigDecimal storedValueAmount;
|
||||||
|
|
||||||
|
//二维码路径
|
||||||
|
@Column("qr_code_path")
|
||||||
|
private String qrCodePath;
|
||||||
|
|
||||||
public String getCourseName() {
|
public String getCourseName() {
|
||||||
return courseName;
|
return courseName;
|
||||||
}
|
}
|
||||||
@@ -165,4 +169,12 @@ public class GroupCourseEntity extends BaseEntity {
|
|||||||
public void setStoredValueAmount(java.math.BigDecimal storedValueAmount) {
|
public void setStoredValueAmount(java.math.BigDecimal storedValueAmount) {
|
||||||
this.storedValueAmount = storedValueAmount;
|
this.storedValueAmount = storedValueAmount;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public String getQrCodePath() {
|
||||||
|
return qrCodePath;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setQrCodePath(String qrCodePath) {
|
||||||
|
this.qrCodePath = qrCodePath;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+77
@@ -0,0 +1,77 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.entity;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.db.entity.BaseEntity;
|
||||||
|
import org.springframework.data.relational.core.mapping.Column;
|
||||||
|
import org.springframework.data.relational.core.mapping.Table;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
@Table("group_course_recommend")
|
||||||
|
public class GroupCourseRecommendEntity extends BaseEntity {
|
||||||
|
|
||||||
|
@Column("course_id")
|
||||||
|
private Long courseId;
|
||||||
|
|
||||||
|
@Column("recommend_title")
|
||||||
|
private String recommendTitle;
|
||||||
|
|
||||||
|
@Column("recommend_content")
|
||||||
|
private String recommendContent;
|
||||||
|
|
||||||
|
@Column("recommend_reason")
|
||||||
|
private String recommendReason;
|
||||||
|
|
||||||
|
@Column("priority")
|
||||||
|
private Integer priority;
|
||||||
|
|
||||||
|
@Column("is_active")
|
||||||
|
private Boolean isActive;
|
||||||
|
|
||||||
|
public Long getCourseId() {
|
||||||
|
return courseId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCourseId(Long courseId) {
|
||||||
|
this.courseId = courseId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getRecommendTitle() {
|
||||||
|
return recommendTitle;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setRecommendTitle(String recommendTitle) {
|
||||||
|
this.recommendTitle = recommendTitle;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getRecommendContent() {
|
||||||
|
return recommendContent;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setRecommendContent(String recommendContent) {
|
||||||
|
this.recommendContent = recommendContent;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getRecommendReason() {
|
||||||
|
return recommendReason;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setRecommendReason(String recommendReason) {
|
||||||
|
this.recommendReason = recommendReason;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getPriority() {
|
||||||
|
return priority;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setPriority(Integer priority) {
|
||||||
|
this.priority = priority;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Boolean getIsActive() {
|
||||||
|
return isActive;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setIsActive(Boolean isActive) {
|
||||||
|
this.isActive = isActive;
|
||||||
|
}
|
||||||
|
}
|
||||||
+57
@@ -0,0 +1,57 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.entity;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.db.entity.BaseEntity;
|
||||||
|
import org.springframework.data.relational.core.mapping.Column;
|
||||||
|
import org.springframework.data.relational.core.mapping.Table;
|
||||||
|
|
||||||
|
@Table("group_course_type")
|
||||||
|
public class GroupCourseTypeEntity extends BaseEntity {
|
||||||
|
|
||||||
|
//类型名称
|
||||||
|
@Column("type_name")
|
||||||
|
private String typeName;
|
||||||
|
|
||||||
|
//基础难度(1-10)
|
||||||
|
@Column("base_difficulty")
|
||||||
|
private Integer baseDifficulty;
|
||||||
|
|
||||||
|
//类型描述
|
||||||
|
@Column("description")
|
||||||
|
private String description;
|
||||||
|
|
||||||
|
//分类(如:有氧、力量、柔韧等)
|
||||||
|
@Column("category")
|
||||||
|
private String category;
|
||||||
|
|
||||||
|
public String getTypeName() {
|
||||||
|
return typeName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTypeName(String typeName) {
|
||||||
|
this.typeName = typeName;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Integer getBaseDifficulty() {
|
||||||
|
return baseDifficulty;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setBaseDifficulty(Integer baseDifficulty) {
|
||||||
|
this.baseDifficulty = baseDifficulty;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getDescription() {
|
||||||
|
return description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setDescription(String description) {
|
||||||
|
this.description = description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getCategory() {
|
||||||
|
return category;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setCategory(String category) {
|
||||||
|
this.category = category;
|
||||||
|
}
|
||||||
|
}
|
||||||
+217
@@ -0,0 +1,217 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.handler;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.service.ICourseLabelService;
|
||||||
|
import io.swagger.v3.oas.annotations.Operation;
|
||||||
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
import org.springframework.web.reactive.function.server.ServerRequest;
|
||||||
|
import org.springframework.web.reactive.function.server.ServerResponse;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
@Component
|
||||||
|
@Tag(name = "团课标签管理", description = "团课标签相关操作")
|
||||||
|
public class CourseLabelHandler {
|
||||||
|
|
||||||
|
private final ICourseLabelService courseLabelService;
|
||||||
|
|
||||||
|
public CourseLabelHandler(ICourseLabelService courseLabelService) {
|
||||||
|
this.courseLabelService = courseLabelService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "获取所有标签", description = "获取系统中所有标签列表")
|
||||||
|
public Mono<ServerResponse> getAllLabels(ServerRequest request) {
|
||||||
|
return ServerResponse.ok()
|
||||||
|
.body(courseLabelService.findAll(), CourseLabel.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "根据ID获取标签", description = "根据ID获取标签详情")
|
||||||
|
public Mono<ServerResponse> getLabelById(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
return courseLabelService.findById(id)
|
||||||
|
.flatMap(label -> ServerResponse.ok().bodyValue(label))
|
||||||
|
.switchIfEmpty(ServerResponse.notFound().build());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "搜索标签", description = "根据关键词搜索标签")
|
||||||
|
public Mono<ServerResponse> searchLabels(ServerRequest request) {
|
||||||
|
String keyword = request.queryParam("keyword").orElse("");
|
||||||
|
return ServerResponse.ok()
|
||||||
|
.body(courseLabelService.findByKeyword(keyword), CourseLabel.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "创建标签", description = "创建新的标签")
|
||||||
|
public Mono<ServerResponse> createLabel(ServerRequest request) {
|
||||||
|
return request.bodyToMono(CourseLabel.class)
|
||||||
|
.flatMap(courseLabel -> {
|
||||||
|
if (courseLabel.getLabelName() == null || courseLabel.getLabelName().isEmpty()) {
|
||||||
|
Map<String, Object> error = new HashMap<>();
|
||||||
|
error.put("success", false);
|
||||||
|
error.put("message", "标签名称不能为空");
|
||||||
|
return ServerResponse.badRequest().bodyValue(error);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (courseLabel.getLabelName().length() > 50) {
|
||||||
|
Map<String, Object> error = new HashMap<>();
|
||||||
|
error.put("success", false);
|
||||||
|
error.put("message", "标签名称不能超过50个字符");
|
||||||
|
return ServerResponse.badRequest().bodyValue(error);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (courseLabel.getColor() == null || courseLabel.getColor().isEmpty()) {
|
||||||
|
courseLabel.setColor("#1890ff");
|
||||||
|
}
|
||||||
|
|
||||||
|
return courseLabelService.create(courseLabel)
|
||||||
|
.flatMap(label -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "标签创建成功");
|
||||||
|
response.put("data", label);
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "更新标签", description = "更新指定标签信息")
|
||||||
|
public Mono<ServerResponse> updateLabel(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
|
||||||
|
return request.bodyToMono(CourseLabel.class)
|
||||||
|
.flatMap(courseLabel -> {
|
||||||
|
if (courseLabel.getLabelName() != null && courseLabel.getLabelName().length() > 50) {
|
||||||
|
Map<String, Object> error = new HashMap<>();
|
||||||
|
error.put("success", false);
|
||||||
|
error.put("message", "标签名称不能超过50个字符");
|
||||||
|
return ServerResponse.badRequest().bodyValue(error);
|
||||||
|
}
|
||||||
|
|
||||||
|
return courseLabelService.update(id, courseLabel)
|
||||||
|
.flatMap(label -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "标签更新成功");
|
||||||
|
response.put("data", label);
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "删除标签", description = "删除指定标签(软删除)")
|
||||||
|
public Mono<ServerResponse> deleteLabel(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
|
||||||
|
return courseLabelService.delete(id)
|
||||||
|
.then(Mono.defer(() -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "标签删除成功");
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "获取类型的标签", description = "获取指定团课类型的所有标签")
|
||||||
|
public Mono<ServerResponse> getLabelsByTypeId(ServerRequest request) {
|
||||||
|
Long typeId = Long.valueOf(request.pathVariable("typeId"));
|
||||||
|
return courseLabelService.findByTypeId(typeId)
|
||||||
|
.collectList()
|
||||||
|
.flatMap(list -> ServerResponse.ok().bodyValue(list));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "为类型添加标签", description = "为指定团课类型添加标签")
|
||||||
|
public Mono<ServerResponse> addLabelsToType(ServerRequest request) {
|
||||||
|
Long typeId = Long.valueOf(request.pathVariable("typeId"));
|
||||||
|
|
||||||
|
return request.bodyToMono(Map.class)
|
||||||
|
.flatMap(body -> {
|
||||||
|
@SuppressWarnings("unchecked")
|
||||||
|
List<Integer> labelIdsInt = (List<Integer>) body.get("labelIds");
|
||||||
|
|
||||||
|
if (labelIdsInt == null || labelIdsInt.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)
|
||||||
|
.collect(java.util.stream.Collectors.toList());
|
||||||
|
|
||||||
|
return courseLabelService.addLabelsToType(typeId, labelIds)
|
||||||
|
.then(Mono.defer(() -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "标签添加成功");
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "从类型移除标签", description = "从指定团课类型移除标签")
|
||||||
|
public Mono<ServerResponse> removeLabelFromType(ServerRequest request) {
|
||||||
|
Long typeId = Long.valueOf(request.pathVariable("typeId"));
|
||||||
|
Long labelId = Long.valueOf(request.pathVariable("labelId"));
|
||||||
|
|
||||||
|
return courseLabelService.removeLabelFromType(typeId, labelId)
|
||||||
|
.then(Mono.defer(() -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "标签移除成功");
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "清空类型标签", description = "清空指定团课类型的所有标签")
|
||||||
|
public Mono<ServerResponse> clearLabelsFromType(ServerRequest request) {
|
||||||
|
Long typeId = Long.valueOf(request.pathVariable("typeId"));
|
||||||
|
|
||||||
|
return courseLabelService.clearLabelsFromType(typeId)
|
||||||
|
.then(Mono.defer(() -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "标签清空成功");
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
+36
-5
@@ -4,6 +4,8 @@ package cn.novalon.gym.manage.groupcourse.handler;
|
|||||||
import cn.novalon.gym.manage.common.dto.PageRequest;
|
import cn.novalon.gym.manage.common.dto.PageRequest;
|
||||||
import cn.novalon.gym.manage.common.util.RedisUtil;
|
import cn.novalon.gym.manage.common.util.RedisUtil;
|
||||||
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseDetail;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dto.GroupCourseQueryDto;
|
||||||
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseService;
|
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseService;
|
||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
import io.swagger.v3.oas.annotations.Operation;
|
import io.swagger.v3.oas.annotations.Operation;
|
||||||
@@ -76,6 +78,14 @@ public class GroupCourseHandler {
|
|||||||
.switchIfEmpty(ServerResponse.notFound().build());
|
.switchIfEmpty(ServerResponse.notFound().build());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "根据ID获取团课完整信息", description = "根据ID获取团课完整信息,包括团课基础信息、类型信息和标签信息")
|
||||||
|
public Mono<ServerResponse> getGroupCourseDetailById(ServerRequest request){
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
return groupCourseService.findDetailById(id)
|
||||||
|
.flatMap(detail -> ServerResponse.ok().bodyValue(detail))
|
||||||
|
.switchIfEmpty(ServerResponse.notFound().build());
|
||||||
|
}
|
||||||
|
|
||||||
@Operation(summary = "创建团课", description = "创建新的团课")
|
@Operation(summary = "创建团课", description = "创建新的团课")
|
||||||
public Mono<ServerResponse> createGroupCourse(ServerRequest request) {
|
public Mono<ServerResponse> createGroupCourse(ServerRequest request) {
|
||||||
return request.bodyToMono(GroupCourse.class)
|
return request.bodyToMono(GroupCourse.class)
|
||||||
@@ -149,7 +159,7 @@ public class GroupCourseHandler {
|
|||||||
|
|
||||||
@Operation(summary = "团课签到", description = "会员签到参加团课")
|
@Operation(summary = "团课签到", description = "会员签到参加团课")
|
||||||
public Mono<ServerResponse> signIn(ServerRequest request) {
|
public Mono<ServerResponse> signIn(ServerRequest request) {
|
||||||
Long courseId = Long.valueOf(request.pathVariable("courseId"));
|
Long memberId = Long.valueOf(request.pathVariable("memberId"));
|
||||||
|
|
||||||
return request.bodyToMono(Map.class)
|
return request.bodyToMono(Map.class)
|
||||||
.flatMap(body -> {
|
.flatMap(body -> {
|
||||||
@@ -160,15 +170,15 @@ public class GroupCourseHandler {
|
|||||||
return ServerResponse.badRequest().bodyValue(response);
|
return ServerResponse.badRequest().bodyValue(response);
|
||||||
}
|
}
|
||||||
|
|
||||||
Object memberIdObj = body.get("memberId");
|
Object courseIdObj = body.get("courseId");
|
||||||
if (memberIdObj == null) {
|
if (courseIdObj == null) {
|
||||||
Map<String, Object> response = new HashMap<>();
|
Map<String, Object> response = new HashMap<>();
|
||||||
response.put("success", false);
|
response.put("success", false);
|
||||||
response.put("message", "memberId不能为空");
|
response.put("message", "courseId不能为空");
|
||||||
return ServerResponse.badRequest().bodyValue(response);
|
return ServerResponse.badRequest().bodyValue(response);
|
||||||
}
|
}
|
||||||
|
|
||||||
Long memberId = ((Number) memberIdObj).longValue();
|
Long courseId = ((Number) courseIdObj).longValue();
|
||||||
|
|
||||||
return groupCourseService.signIn(courseId, memberId)
|
return groupCourseService.signIn(courseId, memberId)
|
||||||
.flatMap(course -> {
|
.flatMap(course -> {
|
||||||
@@ -206,6 +216,27 @@ public class GroupCourseHandler {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "多条件查询团课", description = "支持团课名称模糊查询、类型筛选、日期范围、时间段、价格排序、剩余名额排序等多条件组合查询")
|
||||||
|
public Mono<ServerResponse> searchGroupCourses(ServerRequest request) {
|
||||||
|
return request.bodyToMono(GroupCourseQueryDto.class)
|
||||||
|
.flatMap(query -> {
|
||||||
|
return groupCourseService.searchGroupCourses(query)
|
||||||
|
.flatMap(response -> {
|
||||||
|
Map<String, Object> result = new HashMap<>();
|
||||||
|
result.put("success", true);
|
||||||
|
result.put("message", "查询成功");
|
||||||
|
result.put("data", response);
|
||||||
|
return ServerResponse.ok().bodyValue(result);
|
||||||
|
});
|
||||||
|
})
|
||||||
|
.onErrorResume(error -> {
|
||||||
|
Map<String, Object> errorResponse = new HashMap<>();
|
||||||
|
errorResponse.put("success", false);
|
||||||
|
errorResponse.put("message", error.getMessage());
|
||||||
|
return ServerResponse.badRequest().bodyValue(errorResponse);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
@Operation(summary = "测试-根据Key获取Redis缓存", description = "测试接口:根据传入的key值获取Redis中缓存的数据")
|
@Operation(summary = "测试-根据Key获取Redis缓存", description = "测试接口:根据传入的key值获取Redis中缓存的数据")
|
||||||
public Mono<ServerResponse> getCacheByKey(ServerRequest request) {
|
public Mono<ServerResponse> getCacheByKey(ServerRequest request) {
|
||||||
return request.bodyToMono(Map.class)
|
return request.bodyToMono(Map.class)
|
||||||
|
|||||||
+164
@@ -0,0 +1,164 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.handler;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseRecommend;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseRecommendService;
|
||||||
|
import io.swagger.v3.oas.annotations.Operation;
|
||||||
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
import org.springframework.web.reactive.function.server.ServerRequest;
|
||||||
|
import org.springframework.web.reactive.function.server.ServerResponse;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
@Component
|
||||||
|
@Tag(name = "团课推荐管理", description = "团课推荐相关操作")
|
||||||
|
public class GroupCourseRecommendHandler {
|
||||||
|
|
||||||
|
private final IGroupCourseRecommendService recommendService;
|
||||||
|
|
||||||
|
public GroupCourseRecommendHandler(IGroupCourseRecommendService recommendService) {
|
||||||
|
this.recommendService = recommendService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "获取所有团课推荐", description = "获取系统中所有团课推荐列表,支持按优先级排序")
|
||||||
|
public Mono<ServerResponse> getAllRecommendations(ServerRequest request) {
|
||||||
|
String sortBy = request.queryParam("sortBy").orElse("priority");
|
||||||
|
String sortOrder = request.queryParam("sortOrder").orElse("desc");
|
||||||
|
|
||||||
|
return ServerResponse.ok()
|
||||||
|
.body(recommendService.findAll(sortBy, sortOrder), GroupCourseRecommend.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "获取所有启用的团课推荐", description = "获取系统中所有已启用的团课推荐列表(按优先级排序)")
|
||||||
|
public Mono<ServerResponse> getAllActiveRecommendations(ServerRequest request) {
|
||||||
|
return ServerResponse.ok()
|
||||||
|
.body(recommendService.findAllActive(), GroupCourseRecommend.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "根据ID获取团课推荐", description = "根据ID获取团课推荐详情")
|
||||||
|
public Mono<ServerResponse> getRecommendationById(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
return recommendService.findById(id)
|
||||||
|
.flatMap(recommend -> ServerResponse.ok().bodyValue(recommend))
|
||||||
|
.switchIfEmpty(ServerResponse.notFound().build());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "根据团课ID获取推荐", description = "根据团课ID获取该团课的推荐信息")
|
||||||
|
public Mono<ServerResponse> getRecommendationsByCourseId(ServerRequest request) {
|
||||||
|
Long courseId = Long.valueOf(request.pathVariable("courseId"));
|
||||||
|
return ServerResponse.ok()
|
||||||
|
.body(recommendService.findByCourseId(courseId), GroupCourseRecommend.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "创建团课推荐", description = "创建新的团课推荐")
|
||||||
|
public Mono<ServerResponse> createRecommendation(ServerRequest request) {
|
||||||
|
return request.bodyToMono(GroupCourseRecommend.class)
|
||||||
|
.flatMap(recommend -> {
|
||||||
|
if (recommend.getCourseId() == null) {
|
||||||
|
Map<String, Object> error = new HashMap<>();
|
||||||
|
error.put("success", false);
|
||||||
|
error.put("message", "团课ID不能为空");
|
||||||
|
return ServerResponse.badRequest().bodyValue(error);
|
||||||
|
}
|
||||||
|
|
||||||
|
return recommendService.create(recommend)
|
||||||
|
.flatMap(r -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "团课推荐创建成功");
|
||||||
|
response.put("data", r);
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "更新团课推荐", description = "更新指定团课推荐信息")
|
||||||
|
public Mono<ServerResponse> updateRecommendation(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
|
||||||
|
return request.bodyToMono(GroupCourseRecommend.class)
|
||||||
|
.flatMap(recommend -> {
|
||||||
|
return recommendService.update(id, recommend)
|
||||||
|
.flatMap(r -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "团课推荐更新成功");
|
||||||
|
response.put("data", r);
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "删除团课推荐", description = "删除指定团课推荐(软删除)")
|
||||||
|
public Mono<ServerResponse> deleteRecommendation(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
|
||||||
|
return recommendService.delete(id)
|
||||||
|
.then(Mono.defer(() -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "团课推荐删除成功");
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "启用团课推荐", description = "启用指定团课推荐")
|
||||||
|
public Mono<ServerResponse> enableRecommendation(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
|
||||||
|
return recommendService.enable(id)
|
||||||
|
.flatMap(r -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "团课推荐启用成功");
|
||||||
|
response.put("data", r);
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "禁用团课推荐", description = "禁用指定团课推荐")
|
||||||
|
public Mono<ServerResponse> disableRecommendation(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
|
||||||
|
return recommendService.disable(id)
|
||||||
|
.flatMap(r -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "团课推荐禁用成功");
|
||||||
|
response.put("data", r);
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
+137
@@ -0,0 +1,137 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.handler;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseTypeService;
|
||||||
|
import io.swagger.v3.oas.annotations.Operation;
|
||||||
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
import org.springframework.web.reactive.function.server.ServerRequest;
|
||||||
|
import org.springframework.web.reactive.function.server.ServerResponse;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
@Component
|
||||||
|
@Tag(name = "团课类型管理", description = "团课类型及难度相关操作")
|
||||||
|
public class GroupCourseTypeHandler {
|
||||||
|
|
||||||
|
private final IGroupCourseTypeService groupCourseTypeService;
|
||||||
|
|
||||||
|
public GroupCourseTypeHandler(IGroupCourseTypeService groupCourseTypeService) {
|
||||||
|
this.groupCourseTypeService = groupCourseTypeService;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "获取所有团课类型", description = "获取系统中所有团课类型列表")
|
||||||
|
public Mono<ServerResponse> getAllGroupCourseTypes(ServerRequest request) {
|
||||||
|
boolean includeDeleted = Boolean.valueOf(request.queryParam("includeDeleted").orElse("false"));
|
||||||
|
return ServerResponse.ok()
|
||||||
|
.body(groupCourseTypeService.findAll(includeDeleted), GroupCourseType.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "根据ID获取团课类型", description = "根据ID获取团课类型详情")
|
||||||
|
public Mono<ServerResponse> getGroupCourseTypeById(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
return groupCourseTypeService.findById(id)
|
||||||
|
.flatMap(type -> ServerResponse.ok().bodyValue(type))
|
||||||
|
.switchIfEmpty(ServerResponse.notFound().build());
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "根据关键词搜索团课类型", description = "根据类型名称关键词搜索团课类型")
|
||||||
|
public Mono<ServerResponse> searchGroupCourseTypes(ServerRequest request) {
|
||||||
|
String keyword = request.queryParam("keyword").orElse("");
|
||||||
|
return ServerResponse.ok()
|
||||||
|
.body(groupCourseTypeService.findByKeyword(keyword), GroupCourseType.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "根据分类获取团课类型", description = "根据分类获取团课类型列表")
|
||||||
|
public Mono<ServerResponse> getGroupCourseTypesByCategory(ServerRequest request) {
|
||||||
|
String category = request.pathVariable("category");
|
||||||
|
String keyword = request.queryParam("keyword").orElse("");
|
||||||
|
return ServerResponse.ok()
|
||||||
|
.body(groupCourseTypeService.findByCategoryAndKeyword(category, keyword), GroupCourseType.class);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "获取所有分类", description = "获取所有团课类型分类(去重)")
|
||||||
|
public Mono<ServerResponse> getCategories(ServerRequest request) {
|
||||||
|
return groupCourseTypeService.findCategories()
|
||||||
|
.collectList()
|
||||||
|
.flatMap(list -> ServerResponse.ok().bodyValue(list));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "创建团课类型", description = "创建新的团课类型")
|
||||||
|
public Mono<ServerResponse> createGroupCourseType(ServerRequest request) {
|
||||||
|
return request.bodyToMono(GroupCourseType.class)
|
||||||
|
.flatMap(groupCourseType -> {
|
||||||
|
if (groupCourseType.getTypeName() == null || groupCourseType.getTypeName().isEmpty()) {
|
||||||
|
Map<String, Object> error = new HashMap<>();
|
||||||
|
error.put("success", false);
|
||||||
|
error.put("message", "类型名称不能为空");
|
||||||
|
return ServerResponse.badRequest().bodyValue(error);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 默认基础难度为1
|
||||||
|
if (groupCourseType.getBaseDifficulty() == null) {
|
||||||
|
groupCourseType.setBaseDifficulty(1);
|
||||||
|
}
|
||||||
|
|
||||||
|
return groupCourseTypeService.create(groupCourseType)
|
||||||
|
.flatMap(type -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "团课类型创建成功");
|
||||||
|
response.put("data", type);
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "更新团课类型", description = "更新指定团课类型信息")
|
||||||
|
public Mono<ServerResponse> updateGroupCourseType(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
|
||||||
|
return request.bodyToMono(GroupCourseType.class)
|
||||||
|
.flatMap(groupCourseType -> {
|
||||||
|
groupCourseType.setId(id);
|
||||||
|
return groupCourseTypeService.update(id, groupCourseType)
|
||||||
|
.flatMap(type -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "团课类型更新成功");
|
||||||
|
response.put("data", type);
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Operation(summary = "删除团课类型", description = "删除指定团课类型(软删除)")
|
||||||
|
public Mono<ServerResponse> deleteGroupCourseType(ServerRequest request) {
|
||||||
|
Long id = Long.valueOf(request.pathVariable("id"));
|
||||||
|
|
||||||
|
return groupCourseTypeService.delete(id)
|
||||||
|
.then(Mono.defer(() -> {
|
||||||
|
Map<String, Object> response = new HashMap<>();
|
||||||
|
response.put("success", true);
|
||||||
|
response.put("message", "团课类型删除成功");
|
||||||
|
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);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
+89
@@ -0,0 +1,89 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.initializer;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.util.QRCodeUtil;
|
||||||
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
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
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
public class QrCodeInitializer implements CommandLineRunner {
|
||||||
|
|
||||||
|
private static final Logger logger = LoggerFactory.getLogger(QrCodeInitializer.class);
|
||||||
|
|
||||||
|
private final IGroupCourseRepository groupCourseRepository;
|
||||||
|
private final ObjectMapper objectMapper;
|
||||||
|
|
||||||
|
public QrCodeInitializer(IGroupCourseRepository groupCourseRepository,
|
||||||
|
ObjectMapper objectMapper) {
|
||||||
|
this.groupCourseRepository = groupCourseRepository;
|
||||||
|
this.objectMapper = objectMapper;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void run(String... args) {
|
||||||
|
logger.info("===== 开始检查团课二维码缺失情况 =====");
|
||||||
|
|
||||||
|
groupCourseRepository.findByDeletedAtIsNull()
|
||||||
|
.filter(course -> course.getQrCodePath() == null || course.getQrCodePath().isEmpty())
|
||||||
|
.flatMap(course -> {
|
||||||
|
try {
|
||||||
|
logger.info("发现缺失二维码的团课 - id={}, name={}", course.getId(), course.getCourseName());
|
||||||
|
|
||||||
|
// 生成二维码内容:团课基础信息JSON
|
||||||
|
Map<String, Object> qrCodeContent = new HashMap<>();
|
||||||
|
qrCodeContent.put("id", course.getId());
|
||||||
|
qrCodeContent.put("courseName", course.getCourseName());
|
||||||
|
qrCodeContent.put("coachId", course.getCoachId());
|
||||||
|
qrCodeContent.put("courseType", course.getCourseType());
|
||||||
|
qrCodeContent.put("startTime", course.getStartTime() != null ? course.getStartTime().toString() : null);
|
||||||
|
qrCodeContent.put("endTime", course.getEndTime() != null ? course.getEndTime().toString() : null);
|
||||||
|
qrCodeContent.put("maxMembers", course.getMaxMembers());
|
||||||
|
qrCodeContent.put("location", course.getLocation());
|
||||||
|
qrCodeContent.put("description", course.getDescription());
|
||||||
|
|
||||||
|
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()));
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("团课二维码补全失败(生成) - id={}, name={}, error: {}",
|
||||||
|
course.getId(), course.getCourseName(), e.getMessage(), e);
|
||||||
|
return Mono.empty();
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.collectList()
|
||||||
|
.doOnSuccess(list -> logger.info("===== 团课二维码检查完毕,共补全 {} 个缺失二维码 =====", list.size()))
|
||||||
|
.onErrorResume(error -> {
|
||||||
|
logger.error("团课二维码初始化检查异常: {}", error.getMessage(), error);
|
||||||
|
return Mono.empty();
|
||||||
|
})
|
||||||
|
.subscribe();
|
||||||
|
}
|
||||||
|
}
|
||||||
+32
@@ -0,0 +1,32 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.repository;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public interface ICourseLabelRepository {
|
||||||
|
|
||||||
|
Mono<CourseLabel> findById(Long id);
|
||||||
|
|
||||||
|
Flux<CourseLabel> findAll();
|
||||||
|
|
||||||
|
Flux<CourseLabel> findByKeyword(String keyword);
|
||||||
|
|
||||||
|
Mono<CourseLabel> findByLabelName(String labelName);
|
||||||
|
|
||||||
|
Mono<CourseLabel> save(CourseLabel courseLabel);
|
||||||
|
|
||||||
|
Mono<CourseLabel> update(CourseLabel courseLabel);
|
||||||
|
|
||||||
|
Mono<Void> deleteById(Long id);
|
||||||
|
|
||||||
|
Flux<CourseLabel> findByTypeId(Long typeId);
|
||||||
|
|
||||||
|
Mono<Void> addLabelsToType(Long typeId, List<Long> labelIds);
|
||||||
|
|
||||||
|
Mono<Void> removeLabelFromType(Long typeId, Long labelId);
|
||||||
|
|
||||||
|
Mono<Void> clearLabelsFromType(Long typeId);
|
||||||
|
}
|
||||||
+30
@@ -0,0 +1,30 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.repository;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseRecommend;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
public interface IGroupCourseRecommendRepository {
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> findById(Long id);
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommend> findAll();
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommend> findAll(String sortBy, String sortOrder);
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommend> findAllActive();
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommend> findByCourseId(Long courseId);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> findActiveByCourseId(Long courseId);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> save(GroupCourseRecommend recommend);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> update(GroupCourseRecommend recommend);
|
||||||
|
|
||||||
|
Mono<Void> deleteById(Long id);
|
||||||
|
|
||||||
|
Mono<Void> deleteByCourseId(Long courseId);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> updateActiveStatus(Long id, Boolean isActive);
|
||||||
|
}
|
||||||
+5
@@ -4,6 +4,7 @@ package cn.novalon.gym.manage.groupcourse.repository;
|
|||||||
import cn.novalon.gym.manage.common.dto.PageRequest;
|
import cn.novalon.gym.manage.common.dto.PageRequest;
|
||||||
import cn.novalon.gym.manage.common.dto.PageResponse;
|
import cn.novalon.gym.manage.common.dto.PageResponse;
|
||||||
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dto.GroupCourseQueryDto;
|
||||||
import org.springframework.data.domain.Sort;
|
import org.springframework.data.domain.Sort;
|
||||||
import reactor.core.publisher.Flux;
|
import reactor.core.publisher.Flux;
|
||||||
import reactor.core.publisher.Mono;
|
import reactor.core.publisher.Mono;
|
||||||
@@ -27,4 +28,8 @@ public interface IGroupCourseRepository {
|
|||||||
Mono<Void> deleteById(Long id);
|
Mono<Void> deleteById(Long id);
|
||||||
|
|
||||||
Mono<GroupCourse> updateCurrentMembers(Long id, Integer delta);
|
Mono<GroupCourse> updateCurrentMembers(Long id, Integer delta);
|
||||||
|
|
||||||
|
Flux<GroupCourse> findByCourseType(Long courseType);
|
||||||
|
|
||||||
|
Mono<PageResponse<GroupCourse>> searchGroupCourses(GroupCourseQueryDto query);
|
||||||
}
|
}
|
||||||
|
|||||||
+28
@@ -0,0 +1,28 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.repository;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
public interface IGroupCourseTypeRepository {
|
||||||
|
|
||||||
|
Mono<GroupCourseType> findById(Long id);
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findAll();
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findAll(boolean includeDeleted);
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findByKeyword(String keyword);
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findByCategory(String category);
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findByCategoryAndKeyword(String category, String keyword);
|
||||||
|
|
||||||
|
Mono<GroupCourseType> findByTypeName(String typeName);
|
||||||
|
|
||||||
|
Mono<GroupCourseType> save(GroupCourseType groupCourseType);
|
||||||
|
|
||||||
|
Mono<GroupCourseType> update(GroupCourseType groupCourseType);
|
||||||
|
|
||||||
|
Mono<Void> deleteById(Long id);
|
||||||
|
}
|
||||||
+161
@@ -0,0 +1,161 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.repository.impl;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.converter.GroupCourseConverter;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dao.CourseLabelDao;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dao.CourseTypeLabelDao;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.entity.CourseLabelEntity;
|
||||||
|
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.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.List;
|
||||||
|
|
||||||
|
@Repository
|
||||||
|
@Transactional
|
||||||
|
public class CourseLabelRepository implements ICourseLabelRepository {
|
||||||
|
|
||||||
|
private static final Logger logger = LoggerFactory.getLogger(CourseLabelRepository.class);
|
||||||
|
|
||||||
|
private final CourseLabelDao courseLabelDao;
|
||||||
|
private final CourseTypeLabelDao courseTypeLabelDao;
|
||||||
|
private final GroupCourseConverter converter;
|
||||||
|
|
||||||
|
public CourseLabelRepository(CourseLabelDao courseLabelDao, CourseTypeLabelDao courseTypeLabelDao,
|
||||||
|
GroupCourseConverter converter) {
|
||||||
|
this.courseLabelDao = courseLabelDao;
|
||||||
|
this.courseTypeLabelDao = courseTypeLabelDao;
|
||||||
|
this.converter = converter;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<CourseLabel> findById(Long id) {
|
||||||
|
return courseLabelDao.findByIdIsAndDeletedAtIsNull(id)
|
||||||
|
.map(this::toCourseLabel);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<CourseLabel> findAll() {
|
||||||
|
return courseLabelDao.findAllByDeletedAtIsNull()
|
||||||
|
.map(this::toCourseLabel);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<CourseLabel> findByKeyword(String keyword) {
|
||||||
|
if (keyword == null || keyword.isEmpty()) {
|
||||||
|
return findAll();
|
||||||
|
}
|
||||||
|
return courseLabelDao.findByLabelNameContainingAndDeletedAtIsNull(keyword)
|
||||||
|
.map(this::toCourseLabel);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<CourseLabel> findByLabelName(String labelName) {
|
||||||
|
return courseLabelDao.findByLabelNameAndDeletedAtIsNull(labelName)
|
||||||
|
.map(this::toCourseLabel);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<CourseLabel> save(CourseLabel courseLabel) {
|
||||||
|
CourseLabelEntity entity = toCourseLabelEntity(courseLabel);
|
||||||
|
return courseLabelDao.save(entity)
|
||||||
|
.map(this::toCourseLabel);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<CourseLabel> update(CourseLabel courseLabel) {
|
||||||
|
return courseLabelDao.findByIdIsAndDeletedAtIsNull(courseLabel.getId())
|
||||||
|
.switchIfEmpty(Mono.error(new RuntimeException("标签不存在")))
|
||||||
|
.flatMap(existing -> {
|
||||||
|
existing.markNotNew();
|
||||||
|
if (courseLabel.getLabelName() != null) {
|
||||||
|
existing.setLabelName(courseLabel.getLabelName());
|
||||||
|
}
|
||||||
|
if (courseLabel.getColor() != null) {
|
||||||
|
existing.setColor(courseLabel.getColor());
|
||||||
|
}
|
||||||
|
if (courseLabel.getDescription() != null) {
|
||||||
|
existing.setDescription(courseLabel.getDescription());
|
||||||
|
}
|
||||||
|
existing.setUpdatedAt(LocalDateTime.now());
|
||||||
|
return courseLabelDao.save(existing);
|
||||||
|
})
|
||||||
|
.map(this::toCourseLabel);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> deleteById(Long id) {
|
||||||
|
return courseLabelDao.softDelete(id, LocalDateTime.now())
|
||||||
|
.then(courseTypeLabelDao.deleteByLabelId(id, LocalDateTime.now()))
|
||||||
|
.then();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<CourseLabel> findByTypeId(Long typeId) {
|
||||||
|
return courseTypeLabelDao.findByTypeIdAndDeletedAtIsNull(typeId)
|
||||||
|
.flatMap(typeLabel -> courseLabelDao.findByIdIsAndDeletedAtIsNull(typeLabel.getLabelId()))
|
||||||
|
.map(this::toCourseLabel);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> addLabelsToType(Long typeId, List<Long> labelIds) {
|
||||||
|
return Flux.fromIterable(labelIds)
|
||||||
|
.flatMap(labelId -> {
|
||||||
|
return courseTypeLabelDao.physicalDeleteByTypeIdAndLabelId(typeId, labelId)
|
||||||
|
.then(Mono.defer(() -> {
|
||||||
|
CourseTypeLabelEntity entity = new CourseTypeLabelEntity();
|
||||||
|
entity.setTypeId(typeId);
|
||||||
|
entity.setLabelId(labelId);
|
||||||
|
return courseTypeLabelDao.save(entity).then(Mono.empty());
|
||||||
|
}));
|
||||||
|
})
|
||||||
|
.then();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> removeLabelFromType(Long typeId, Long labelId) {
|
||||||
|
return courseTypeLabelDao.deleteByTypeIdAndLabelId(typeId, labelId, LocalDateTime.now())
|
||||||
|
.then();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> clearLabelsFromType(Long typeId) {
|
||||||
|
return courseTypeLabelDao.deleteByTypeId(typeId, LocalDateTime.now())
|
||||||
|
.then();
|
||||||
|
}
|
||||||
|
|
||||||
|
private CourseLabel toCourseLabel(CourseLabelEntity entity) {
|
||||||
|
if (entity == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
CourseLabel label = new CourseLabel();
|
||||||
|
label.setId(entity.getId());
|
||||||
|
label.setLabelName(entity.getLabelName());
|
||||||
|
label.setColor(entity.getColor());
|
||||||
|
label.setDescription(entity.getDescription());
|
||||||
|
label.setCreatedAt(entity.getCreatedAt());
|
||||||
|
label.setUpdatedAt(entity.getUpdatedAt());
|
||||||
|
return label;
|
||||||
|
}
|
||||||
|
|
||||||
|
private CourseLabelEntity toCourseLabelEntity(CourseLabel domain) {
|
||||||
|
if (domain == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
CourseLabelEntity entity = new CourseLabelEntity();
|
||||||
|
entity.setId(domain.getId());
|
||||||
|
entity.setLabelName(domain.getLabelName());
|
||||||
|
entity.setColor(domain.getColor());
|
||||||
|
entity.setDescription(domain.getDescription());
|
||||||
|
if (domain.getId() != null) {
|
||||||
|
entity.markNotNew();
|
||||||
|
}
|
||||||
|
return entity;
|
||||||
|
}
|
||||||
|
}
|
||||||
+136
@@ -0,0 +1,136 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.repository.impl;
|
||||||
|
|
||||||
|
import cn.hutool.core.bean.BeanUtil;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dao.GroupCourseRecommendDao;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseRecommend;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseRecommendEntity;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRecommendRepository;
|
||||||
|
import org.springframework.data.domain.Sort;
|
||||||
|
import org.springframework.data.r2dbc.core.R2dbcEntityTemplate;
|
||||||
|
import org.springframework.stereotype.Repository;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
@Repository
|
||||||
|
public class GroupCourseRecommendRepository implements IGroupCourseRecommendRepository {
|
||||||
|
|
||||||
|
private final GroupCourseRecommendDao recommendDao;
|
||||||
|
private final R2dbcEntityTemplate r2dbcEntityTemplate;
|
||||||
|
|
||||||
|
public GroupCourseRecommendRepository(GroupCourseRecommendDao recommendDao,
|
||||||
|
R2dbcEntityTemplate r2dbcEntityTemplate) {
|
||||||
|
this.recommendDao = recommendDao;
|
||||||
|
this.r2dbcEntityTemplate = r2dbcEntityTemplate;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> findById(Long id) {
|
||||||
|
return recommendDao.findByIdAndDeletedAtIsNull(id)
|
||||||
|
.map(this::toDomain);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseRecommend> findAll() {
|
||||||
|
return recommendDao.findAllByDeletedAtIsNull()
|
||||||
|
.map(this::toDomain);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseRecommend> findAll(String sortBy, String sortOrder) {
|
||||||
|
Sort.Direction direction = "asc".equalsIgnoreCase(sortOrder)
|
||||||
|
? Sort.Direction.ASC
|
||||||
|
: Sort.Direction.DESC;
|
||||||
|
Sort sort = Sort.by(direction, sortBy);
|
||||||
|
return recommendDao.findAllByDeletedAtIsNull(sort)
|
||||||
|
.map(this::toDomain);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseRecommend> findAllActive() {
|
||||||
|
return recommendDao.findByIsActiveTrueAndDeletedAtIsNull(Sort.by(Sort.Direction.DESC, "priority"))
|
||||||
|
.map(this::toDomain);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseRecommend> findByCourseId(Long courseId) {
|
||||||
|
return recommendDao.findByCourseIdAndDeletedAtIsNull(courseId)
|
||||||
|
.map(this::toDomain);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> findActiveByCourseId(Long courseId) {
|
||||||
|
return recommendDao.findByCourseIdAndDeletedAtIsNullAndIsActiveTrue(courseId)
|
||||||
|
.map(this::toDomain);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> save(GroupCourseRecommend recommend) {
|
||||||
|
GroupCourseRecommendEntity entity = toEntity(recommend);
|
||||||
|
entity.setCreatedAt(LocalDateTime.now());
|
||||||
|
entity.setUpdatedAt(LocalDateTime.now());
|
||||||
|
if (entity.getPriority() == null) {
|
||||||
|
entity.setPriority(0);
|
||||||
|
}
|
||||||
|
if (entity.getIsActive() == null) {
|
||||||
|
entity.setIsActive(true);
|
||||||
|
}
|
||||||
|
|
||||||
|
return recommendDao.save(entity)
|
||||||
|
.map(this::toDomain);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> update(GroupCourseRecommend recommend) {
|
||||||
|
GroupCourseRecommendEntity entity = toEntity(recommend);
|
||||||
|
entity.setUpdatedAt(LocalDateTime.now());
|
||||||
|
|
||||||
|
return r2dbcEntityTemplate.update(entity)
|
||||||
|
.then(findById(recommend.getId()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> deleteById(Long id) {
|
||||||
|
return recommendDao.softDelete(id, LocalDateTime.now())
|
||||||
|
.then();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> deleteByCourseId(Long courseId) {
|
||||||
|
return recommendDao.softDeleteByCourseId(courseId, LocalDateTime.now())
|
||||||
|
.then();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> updateActiveStatus(Long id, Boolean isActive) {
|
||||||
|
return recommendDao.updateActiveStatus(id, isActive, LocalDateTime.now())
|
||||||
|
.flatMap(updated -> {
|
||||||
|
if (updated > 0) {
|
||||||
|
return findById(id);
|
||||||
|
}
|
||||||
|
return Mono.empty();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
private GroupCourseRecommend toDomain(GroupCourseRecommendEntity entity) {
|
||||||
|
if (entity == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
GroupCourseRecommend recommend = new GroupCourseRecommend();
|
||||||
|
BeanUtil.copyProperties(entity, recommend);
|
||||||
|
return recommend;
|
||||||
|
}
|
||||||
|
|
||||||
|
private GroupCourseRecommendEntity toEntity(GroupCourseRecommend domain) {
|
||||||
|
if (domain == null) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
GroupCourseRecommendEntity entity = new GroupCourseRecommendEntity();
|
||||||
|
BeanUtil.copyProperties(domain, entity);
|
||||||
|
if (domain.getId() != null) {
|
||||||
|
entity.markNotNew();
|
||||||
|
}
|
||||||
|
return entity;
|
||||||
|
}
|
||||||
|
}
|
||||||
+30
@@ -6,6 +6,7 @@ import cn.novalon.gym.manage.common.dto.PageResponse;
|
|||||||
import cn.novalon.gym.manage.groupcourse.converter.GroupCourseConverter;
|
import cn.novalon.gym.manage.groupcourse.converter.GroupCourseConverter;
|
||||||
import cn.novalon.gym.manage.groupcourse.dao.GroupCourseDao;
|
import cn.novalon.gym.manage.groupcourse.dao.GroupCourseDao;
|
||||||
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dto.GroupCourseQueryDto;
|
||||||
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseEntity;
|
import cn.novalon.gym.manage.groupcourse.entity.GroupCourseEntity;
|
||||||
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
|
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
|
||||||
import org.springframework.data.domain.Sort;
|
import org.springframework.data.domain.Sort;
|
||||||
@@ -178,4 +179,33 @@ public class GroupCourseRepository implements IGroupCourseRepository {
|
|||||||
return Mono.empty();
|
return Mono.empty();
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourse> findByCourseType(Long courseType) {
|
||||||
|
return groupCourseDao.findByCourseTypeAndDeletedAtIsNull(courseType)
|
||||||
|
.map(groupCourseConverter::toDomain);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<PageResponse<GroupCourse>> searchGroupCourses(GroupCourseQueryDto query) {
|
||||||
|
return groupCourseDao.countSearchGroupCourses(r2dbcEntityTemplate.getDatabaseClient(), query)
|
||||||
|
.flatMap(total -> {
|
||||||
|
if (total == 0) {
|
||||||
|
return Mono.just(new PageResponse<>(
|
||||||
|
List.of(), 0, 0L,
|
||||||
|
query.getPage() != null ? query.getPage() : 0,
|
||||||
|
query.getSize() != null ? query.getSize() : 10));
|
||||||
|
}
|
||||||
|
return groupCourseDao.searchGroupCourses(r2dbcEntityTemplate.getDatabaseClient(), query)
|
||||||
|
.map(groupCourseConverter::toDomain)
|
||||||
|
.collectList()
|
||||||
|
.map(courseList -> {
|
||||||
|
int size = query.getSize() != null ? query.getSize() : 10;
|
||||||
|
int totalPages = (int) Math.ceil((double) total / size);
|
||||||
|
return new PageResponse<>(
|
||||||
|
courseList, totalPages, total,
|
||||||
|
query.getPage() != null ? query.getPage() : 0, size);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+132
@@ -0,0 +1,132 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.repository.impl;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.converter.GroupCourseConverter;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dao.GroupCourseTypeDao;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
|
||||||
|
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.stereotype.Repository;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
@Repository
|
||||||
|
@Transactional
|
||||||
|
public class GroupCourseTypeRepository implements IGroupCourseTypeRepository {
|
||||||
|
|
||||||
|
private static final Logger logger = LoggerFactory.getLogger(GroupCourseTypeRepository.class);
|
||||||
|
|
||||||
|
private final GroupCourseTypeDao groupCourseTypeDao;
|
||||||
|
private final GroupCourseConverter converter;
|
||||||
|
|
||||||
|
public GroupCourseTypeRepository(GroupCourseTypeDao groupCourseTypeDao, GroupCourseConverter converter) {
|
||||||
|
this.groupCourseTypeDao = groupCourseTypeDao;
|
||||||
|
this.converter = converter;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseType> findById(Long id) {
|
||||||
|
return groupCourseTypeDao.findByIdIsAndDeletedAtIsNull(id)
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findAll() {
|
||||||
|
return groupCourseTypeDao.findAll()
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findAll(boolean includeDeleted) {
|
||||||
|
if (includeDeleted) {
|
||||||
|
return groupCourseTypeDao.findAll()
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
} else {
|
||||||
|
return groupCourseTypeDao.findAllByDeletedAtIsNull()
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findByKeyword(String keyword) {
|
||||||
|
if (keyword == null || keyword.isEmpty()) {
|
||||||
|
return findAll(false);
|
||||||
|
}
|
||||||
|
return groupCourseTypeDao.findByTypeNameContainingAndDeletedAtIsNull(keyword)
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findByCategory(String category) {
|
||||||
|
if (category == null || category.isEmpty()) {
|
||||||
|
return findAll(false);
|
||||||
|
}
|
||||||
|
return groupCourseTypeDao.findByCategoryAndDeletedAtIsNull(category)
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findByCategoryAndKeyword(String category, String keyword) {
|
||||||
|
Flux<GroupCourseType> result;
|
||||||
|
|
||||||
|
if (category != null && !category.isEmpty()) {
|
||||||
|
result = findByCategory(category);
|
||||||
|
} else {
|
||||||
|
result = findAll(false);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (keyword != null && !keyword.isEmpty()) {
|
||||||
|
result = result.filter(type -> type.getTypeName() != null &&
|
||||||
|
type.getTypeName().toLowerCase().contains(keyword.toLowerCase()));
|
||||||
|
}
|
||||||
|
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseType> findByTypeName(String typeName) {
|
||||||
|
return groupCourseTypeDao.findByTypeNameAndDeletedAtIsNull(typeName)
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseType> save(GroupCourseType groupCourseType) {
|
||||||
|
GroupCourseTypeEntity entity = converter.toGroupCourseTypeEntity(groupCourseType);
|
||||||
|
return groupCourseTypeDao.save(entity)
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseType> update(GroupCourseType groupCourseType) {
|
||||||
|
return groupCourseTypeDao.findByIdIsAndDeletedAtIsNull(groupCourseType.getId())
|
||||||
|
.switchIfEmpty(Mono.error(new RuntimeException("团课类型不存在")))
|
||||||
|
.flatMap(existing -> {
|
||||||
|
existing.markNotNew();
|
||||||
|
if (groupCourseType.getTypeName() != null) {
|
||||||
|
existing.setTypeName(groupCourseType.getTypeName());
|
||||||
|
}
|
||||||
|
if (groupCourseType.getBaseDifficulty() != null) {
|
||||||
|
existing.setBaseDifficulty(groupCourseType.getBaseDifficulty());
|
||||||
|
}
|
||||||
|
if (groupCourseType.getDescription() != null) {
|
||||||
|
existing.setDescription(groupCourseType.getDescription());
|
||||||
|
}
|
||||||
|
if (groupCourseType.getCategory() != null) {
|
||||||
|
existing.setCategory(groupCourseType.getCategory());
|
||||||
|
}
|
||||||
|
existing.setUpdatedAt(LocalDateTime.now());
|
||||||
|
return groupCourseTypeDao.save(existing);
|
||||||
|
})
|
||||||
|
.map(converter::toGroupCourseType);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> deleteById(Long id) {
|
||||||
|
return groupCourseTypeDao.softDelete(id, LocalDateTime.now())
|
||||||
|
.then();
|
||||||
|
}
|
||||||
|
}
|
||||||
+30
@@ -0,0 +1,30 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.service;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
public interface ICourseLabelService {
|
||||||
|
|
||||||
|
Mono<CourseLabel> findById(Long id);
|
||||||
|
|
||||||
|
Flux<CourseLabel> findAll();
|
||||||
|
|
||||||
|
Flux<CourseLabel> findByKeyword(String keyword);
|
||||||
|
|
||||||
|
Mono<CourseLabel> create(CourseLabel courseLabel);
|
||||||
|
|
||||||
|
Mono<CourseLabel> update(Long id, CourseLabel courseLabel);
|
||||||
|
|
||||||
|
Mono<Void> delete(Long id);
|
||||||
|
|
||||||
|
Flux<CourseLabel> findByTypeId(Long typeId);
|
||||||
|
|
||||||
|
Mono<Void> addLabelsToType(Long typeId, List<Long> labelIds);
|
||||||
|
|
||||||
|
Mono<Void> removeLabelFromType(Long typeId, Long labelId);
|
||||||
|
|
||||||
|
Mono<Void> clearLabelsFromType(Long typeId);
|
||||||
|
}
|
||||||
+28
@@ -0,0 +1,28 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.service;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseRecommend;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
public interface IGroupCourseRecommendService {
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> findById(Long id);
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommend> findAll();
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommend> findAll(String sortBy, String sortOrder);
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommend> findAllActive();
|
||||||
|
|
||||||
|
Flux<GroupCourseRecommend> findByCourseId(Long courseId);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> create(GroupCourseRecommend recommend);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> update(Long id, GroupCourseRecommend recommend);
|
||||||
|
|
||||||
|
Mono<Void> delete(Long id);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> enable(Long id);
|
||||||
|
|
||||||
|
Mono<GroupCourseRecommend> disable(Long id);
|
||||||
|
}
|
||||||
+5
@@ -4,11 +4,14 @@ package cn.novalon.gym.manage.groupcourse.service;
|
|||||||
import cn.novalon.gym.manage.common.dto.PageRequest;
|
import cn.novalon.gym.manage.common.dto.PageRequest;
|
||||||
import cn.novalon.gym.manage.common.dto.PageResponse;
|
import cn.novalon.gym.manage.common.dto.PageResponse;
|
||||||
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseDetail;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dto.GroupCourseQueryDto;
|
||||||
import reactor.core.publisher.Flux;
|
import reactor.core.publisher.Flux;
|
||||||
import reactor.core.publisher.Mono;
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
public interface IGroupCourseService {
|
public interface IGroupCourseService {
|
||||||
Mono<GroupCourse> findById(Long id);
|
Mono<GroupCourse> findById(Long id);
|
||||||
|
Mono<GroupCourseDetail> findDetailById(Long id);
|
||||||
Flux<GroupCourse> findAll();
|
Flux<GroupCourse> findAll();
|
||||||
Flux<GroupCourse> findAll(boolean includeDeleted);
|
Flux<GroupCourse> findAll(boolean includeDeleted);
|
||||||
|
|
||||||
@@ -23,4 +26,6 @@ public interface IGroupCourseService {
|
|||||||
Mono<GroupCourse> signIn(Long courseId, Long memberId);
|
Mono<GroupCourse> signIn(Long courseId, Long memberId);
|
||||||
|
|
||||||
Mono<Void> delete(Long id);
|
Mono<Void> delete(Long id);
|
||||||
|
|
||||||
|
Mono<PageResponse<GroupCourse>> searchGroupCourses(GroupCourseQueryDto query);
|
||||||
}
|
}
|
||||||
|
|||||||
+32
@@ -0,0 +1,32 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.service;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
public interface IGroupCourseTypeService {
|
||||||
|
|
||||||
|
Mono<GroupCourseType> findById(Long id);
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findAll();
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findAll(boolean includeDeleted);
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findByKeyword(String keyword);
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findByCategory(String category);
|
||||||
|
|
||||||
|
Flux<GroupCourseType> findByCategoryAndKeyword(String category, String keyword);
|
||||||
|
|
||||||
|
Mono<GroupCourseType> create(GroupCourseType groupCourseType);
|
||||||
|
|
||||||
|
Mono<GroupCourseType> update(Long id, GroupCourseType groupCourseType);
|
||||||
|
|
||||||
|
Mono<Void> delete(Long id);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取分类列表(去重)
|
||||||
|
* @return 分类名称列表
|
||||||
|
*/
|
||||||
|
Flux<String> findCategories();
|
||||||
|
}
|
||||||
+112
@@ -0,0 +1,112 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.service.impl;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.common.util.RedisUtil;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.repository.ICourseLabelRepository;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.service.ICourseLabelService;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
public class CourseLabelService implements ICourseLabelService {
|
||||||
|
|
||||||
|
private static final Logger logger = LoggerFactory.getLogger(CourseLabelService.class);
|
||||||
|
private static final String CACHE_KEY_DETAIL_PREFIX = "group_course:detail:";
|
||||||
|
|
||||||
|
private final ICourseLabelRepository courseLabelRepository;
|
||||||
|
private final IGroupCourseRepository groupCourseRepository;
|
||||||
|
private final RedisUtil redisUtil;
|
||||||
|
|
||||||
|
public CourseLabelService(ICourseLabelRepository courseLabelRepository,
|
||||||
|
IGroupCourseRepository groupCourseRepository,
|
||||||
|
RedisUtil redisUtil) {
|
||||||
|
this.courseLabelRepository = courseLabelRepository;
|
||||||
|
this.groupCourseRepository = groupCourseRepository;
|
||||||
|
this.redisUtil = redisUtil;
|
||||||
|
}
|
||||||
|
|
||||||
|
private Mono<Void> invalidateGroupCourseDetailCache(Long typeId) {
|
||||||
|
return groupCourseRepository.findByCourseType(typeId)
|
||||||
|
.flatMap(course -> {
|
||||||
|
String cacheKey = CACHE_KEY_DETAIL_PREFIX + course.getId();
|
||||||
|
return redisUtil.delete(cacheKey)
|
||||||
|
.doOnSuccess(deleted -> logger.debug("清除团课详情缓存 - courseId={}", course.getId()));
|
||||||
|
})
|
||||||
|
.then();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<CourseLabel> findById(Long id) {
|
||||||
|
return courseLabelRepository.findById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<CourseLabel> findAll() {
|
||||||
|
return courseLabelRepository.findAll();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<CourseLabel> findByKeyword(String keyword) {
|
||||||
|
return courseLabelRepository.findByKeyword(keyword);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<CourseLabel> create(CourseLabel courseLabel) {
|
||||||
|
return courseLabelRepository.findByLabelName(courseLabel.getLabelName())
|
||||||
|
.flatMap(existing -> Mono.<CourseLabel>error(new RuntimeException("标签名称已存在")))
|
||||||
|
.switchIfEmpty(courseLabelRepository.save(courseLabel))
|
||||||
|
.doOnSuccess(label -> logger.info("标签创建成功 - id={}, name={}", label.getId(), label.getLabelName()))
|
||||||
|
.doOnError(error -> logger.error("标签创建失败 - error: {}", error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<CourseLabel> update(Long id, CourseLabel courseLabel) {
|
||||||
|
courseLabel.setId(id);
|
||||||
|
return courseLabelRepository.update(courseLabel)
|
||||||
|
.doOnSuccess(label -> logger.info("标签更新成功 - id={}", id))
|
||||||
|
.doOnError(error -> logger.error("标签更新失败 - id={}, error: {}", id, error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> delete(Long id) {
|
||||||
|
return courseLabelRepository.deleteById(id)
|
||||||
|
.doOnSuccess(v -> logger.info("标签删除成功 - id={}", id))
|
||||||
|
.doOnError(error -> logger.error("标签删除失败 - id={}, error: {}", id, error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<CourseLabel> findByTypeId(Long typeId) {
|
||||||
|
return courseLabelRepository.findByTypeId(typeId);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> addLabelsToType(Long typeId, List<Long> labelIds) {
|
||||||
|
return courseLabelRepository.addLabelsToType(typeId, labelIds)
|
||||||
|
.then(invalidateGroupCourseDetailCache(typeId))
|
||||||
|
.doOnSuccess(v -> logger.info("标签添加到类型成功 - typeId={}, labelIds={}", typeId, labelIds))
|
||||||
|
.doOnError(error -> logger.error("标签添加到类型失败 - typeId={}, error: {}", typeId, error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> removeLabelFromType(Long typeId, Long labelId) {
|
||||||
|
return courseLabelRepository.removeLabelFromType(typeId, labelId)
|
||||||
|
.then(invalidateGroupCourseDetailCache(typeId))
|
||||||
|
.doOnSuccess(v -> logger.info("从类型移除标签成功 - typeId={}, labelId={}", typeId, labelId))
|
||||||
|
.doOnError(error -> logger.error("从类型移除标签失败 - typeId={}, labelId={}, error: {}", typeId, labelId, error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> clearLabelsFromType(Long typeId) {
|
||||||
|
return courseLabelRepository.clearLabelsFromType(typeId)
|
||||||
|
.then(invalidateGroupCourseDetailCache(typeId))
|
||||||
|
.doOnSuccess(v -> logger.info("清空类型标签成功 - typeId={}", typeId))
|
||||||
|
.doOnError(error -> logger.error("清空类型标签失败 - typeId={}, error: {}", typeId, error.getMessage()));
|
||||||
|
}
|
||||||
|
}
|
||||||
+142
@@ -0,0 +1,142 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.service.impl;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseRecommend;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRecommendRepository;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseRecommendService;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import reactor.core.publisher.Flux;
|
||||||
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
public class GroupCourseRecommendService implements IGroupCourseRecommendService {
|
||||||
|
|
||||||
|
private static final Logger logger = LoggerFactory.getLogger(GroupCourseRecommendService.class);
|
||||||
|
|
||||||
|
private final IGroupCourseRecommendRepository recommendRepository;
|
||||||
|
private final IGroupCourseRepository groupCourseRepository;
|
||||||
|
|
||||||
|
public GroupCourseRecommendService(IGroupCourseRecommendRepository recommendRepository,
|
||||||
|
IGroupCourseRepository groupCourseRepository) {
|
||||||
|
this.recommendRepository = recommendRepository;
|
||||||
|
this.groupCourseRepository = groupCourseRepository;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> findById(Long id) {
|
||||||
|
return recommendRepository.findById(id)
|
||||||
|
.flatMap(this::fillGroupCourseInfo);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseRecommend> findAll() {
|
||||||
|
return recommendRepository.findAll()
|
||||||
|
.flatMap(this::fillGroupCourseInfo);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseRecommend> findAll(String sortBy, String sortOrder) {
|
||||||
|
return recommendRepository.findAll(sortBy, sortOrder)
|
||||||
|
.flatMap(this::fillGroupCourseInfo);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseRecommend> findAllActive() {
|
||||||
|
return recommendRepository.findAllActive()
|
||||||
|
.flatMap(this::fillGroupCourseInfo);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseRecommend> findByCourseId(Long courseId) {
|
||||||
|
return recommendRepository.findByCourseId(courseId)
|
||||||
|
.flatMap(this::fillGroupCourseInfo);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> create(GroupCourseRecommend recommend) {
|
||||||
|
if (recommend.getCourseId() == null) {
|
||||||
|
return Mono.error(new RuntimeException("团课ID不能为空"));
|
||||||
|
}
|
||||||
|
|
||||||
|
return groupCourseRepository.findByIdAndDeletedAtIsNull(recommend.getCourseId())
|
||||||
|
.switchIfEmpty(Mono.error(new RuntimeException("团课不存在")))
|
||||||
|
.flatMap(course -> {
|
||||||
|
return recommendRepository.save(recommend)
|
||||||
|
.doOnSuccess(r -> logger.info("团课推荐创建成功 - id={}, courseId={}", r.getId(), r.getCourseId()))
|
||||||
|
.doOnError(error -> logger.error("团课推荐创建失败 - error: {}", error.getMessage()));
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> update(Long id, GroupCourseRecommend recommend) {
|
||||||
|
return recommendRepository.findById(id)
|
||||||
|
.switchIfEmpty(Mono.error(new RuntimeException("团课推荐不存在")))
|
||||||
|
.flatMap(existing -> {
|
||||||
|
if (recommend.getRecommendTitle() != null) {
|
||||||
|
existing.setRecommendTitle(recommend.getRecommendTitle());
|
||||||
|
}
|
||||||
|
if (recommend.getRecommendContent() != null) {
|
||||||
|
existing.setRecommendContent(recommend.getRecommendContent());
|
||||||
|
}
|
||||||
|
if (recommend.getRecommendReason() != null) {
|
||||||
|
existing.setRecommendReason(recommend.getRecommendReason());
|
||||||
|
}
|
||||||
|
if (recommend.getPriority() != null) {
|
||||||
|
existing.setPriority(recommend.getPriority());
|
||||||
|
}
|
||||||
|
if (recommend.getIsActive() != null) {
|
||||||
|
existing.setIsActive(recommend.getIsActive());
|
||||||
|
}
|
||||||
|
if (recommend.getCourseId() != null) {
|
||||||
|
existing.setCourseId(recommend.getCourseId());
|
||||||
|
}
|
||||||
|
|
||||||
|
return recommendRepository.update(existing);
|
||||||
|
})
|
||||||
|
.doOnSuccess(r -> logger.info("团课推荐更新成功 - id={}", id))
|
||||||
|
.doOnError(error -> logger.error("团课推荐更新失败 - id={}, error: {}", id, error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<Void> delete(Long id) {
|
||||||
|
return recommendRepository.findById(id)
|
||||||
|
.switchIfEmpty(Mono.error(new RuntimeException("团课推荐不存在")))
|
||||||
|
.flatMap(recommend -> {
|
||||||
|
return recommendRepository.deleteById(id)
|
||||||
|
.doOnSuccess(v -> logger.info("团课推荐删除成功 - id={}", id))
|
||||||
|
.doOnError(error -> logger.error("团课推荐删除失败 - id={}, error: {}", id, error.getMessage()));
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> enable(Long id) {
|
||||||
|
return recommendRepository.updateActiveStatus(id, true)
|
||||||
|
.switchIfEmpty(Mono.error(new RuntimeException("团课推荐不存在")))
|
||||||
|
.doOnSuccess(r -> logger.info("团课推荐启用成功 - id={}", id))
|
||||||
|
.doOnError(error -> logger.error("团课推荐启用失败 - id={}, error: {}", id, error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseRecommend> disable(Long id) {
|
||||||
|
return recommendRepository.updateActiveStatus(id, false)
|
||||||
|
.switchIfEmpty(Mono.error(new RuntimeException("团课推荐不存在")))
|
||||||
|
.doOnSuccess(r -> logger.info("团课推荐禁用成功 - id={}", id))
|
||||||
|
.doOnError(error -> logger.error("团课推荐禁用失败 - id={}, error: {}", id, error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
private Mono<GroupCourseRecommend> fillGroupCourseInfo(GroupCourseRecommend recommend) {
|
||||||
|
if (recommend.getCourseId() == null) {
|
||||||
|
return Mono.just(recommend);
|
||||||
|
}
|
||||||
|
|
||||||
|
return groupCourseRepository.findByIdAndDeletedAtIsNull(recommend.getCourseId())
|
||||||
|
.map(course -> {
|
||||||
|
recommend.setGroupCourse(course);
|
||||||
|
return recommend;
|
||||||
|
})
|
||||||
|
.defaultIfEmpty(recommend);
|
||||||
|
}
|
||||||
|
}
|
||||||
+202
-17
@@ -4,14 +4,21 @@ package cn.novalon.gym.manage.groupcourse.service.impl;
|
|||||||
import cn.novalon.gym.manage.common.dto.PageRequest;
|
import cn.novalon.gym.manage.common.dto.PageRequest;
|
||||||
import cn.novalon.gym.manage.common.dto.PageResponse;
|
import cn.novalon.gym.manage.common.dto.PageResponse;
|
||||||
import cn.novalon.gym.manage.common.util.RedisUtil;
|
import cn.novalon.gym.manage.common.util.RedisUtil;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.CourseLabel;
|
||||||
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourse;
|
||||||
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseBooking;
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseBooking;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseDetail;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.dto.GroupCourseQueryDto;
|
||||||
import cn.novalon.gym.manage.groupcourse.enums.CourseEvent;
|
import cn.novalon.gym.manage.groupcourse.enums.CourseEvent;
|
||||||
import cn.novalon.gym.manage.groupcourse.enums.CourseStatus;
|
import cn.novalon.gym.manage.groupcourse.enums.CourseStatus;
|
||||||
import cn.novalon.gym.manage.groupcourse.handler.GroupCourseStateMachine;
|
import cn.novalon.gym.manage.groupcourse.handler.GroupCourseStateMachine;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.repository.ICourseLabelRepository;
|
||||||
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseBookingRepository;
|
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseBookingRepository;
|
||||||
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseRepository;
|
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.service.IGroupCourseService;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.util.QRCodeUtil;
|
||||||
import cn.novalon.gym.manage.member.entity.MemberCard;
|
import cn.novalon.gym.manage.member.entity.MemberCard;
|
||||||
import cn.novalon.gym.manage.member.entity.MemberCardRecord;
|
import cn.novalon.gym.manage.member.entity.MemberCardRecord;
|
||||||
import cn.novalon.gym.manage.member.enums.MemberCardType;
|
import cn.novalon.gym.manage.member.enums.MemberCardType;
|
||||||
@@ -21,11 +28,14 @@ import com.fasterxml.jackson.core.JsonProcessingException;
|
|||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.r2dbc.core.DatabaseClient;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import reactor.core.publisher.Flux;
|
import reactor.core.publisher.Flux;
|
||||||
import reactor.core.publisher.Mono;
|
import reactor.core.publisher.Mono;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
public class GroupCourseService implements IGroupCourseService {
|
public class GroupCourseService implements IGroupCourseService {
|
||||||
@@ -33,32 +43,130 @@ public class GroupCourseService implements IGroupCourseService {
|
|||||||
|
|
||||||
private final IGroupCourseRepository groupCourseRepository;
|
private final IGroupCourseRepository groupCourseRepository;
|
||||||
private final IGroupCourseBookingRepository bookingRepository;
|
private final IGroupCourseBookingRepository bookingRepository;
|
||||||
|
private final IGroupCourseTypeRepository groupCourseTypeRepository;
|
||||||
|
private final ICourseLabelRepository courseLabelRepository;
|
||||||
private final IMemberCardRecordService memberCardRecordService;
|
private final IMemberCardRecordService memberCardRecordService;
|
||||||
private final MemberCardRepository memberCardRepository;
|
private final MemberCardRepository memberCardRepository;
|
||||||
private final RedisUtil redisUtil;
|
private final RedisUtil redisUtil;
|
||||||
private final ObjectMapper objectMapper;
|
private final ObjectMapper objectMapper;
|
||||||
private final GroupCourseStateMachine stateMachine;
|
private final GroupCourseStateMachine stateMachine;
|
||||||
|
private final DatabaseClient databaseClient;
|
||||||
|
|
||||||
private static final String CACHE_KEY_PREFIX = "group_course:page:";
|
private static final String CACHE_KEY_PREFIX = "group_course:page:";
|
||||||
private static final String CACHE_KEY_ID_PREFIX = "group_course:id:";
|
private static final String CACHE_KEY_ID_PREFIX = "group_course:id:";
|
||||||
|
private static final String CACHE_KEY_DETAIL_PREFIX = "group_course:detail:";
|
||||||
private static final long CACHE_EXPIRE_SECONDS = 300;
|
private static final long CACHE_EXPIRE_SECONDS = 300;
|
||||||
|
|
||||||
private static final double DEFAULT_GROUP_COURSE_PRICE = 50.0;
|
private static final double DEFAULT_GROUP_COURSE_PRICE = 50.0;
|
||||||
|
|
||||||
public GroupCourseService(IGroupCourseRepository groupCourseRepository,
|
public GroupCourseService(IGroupCourseRepository groupCourseRepository,
|
||||||
IGroupCourseBookingRepository bookingRepository,
|
IGroupCourseBookingRepository bookingRepository,
|
||||||
|
IGroupCourseTypeRepository groupCourseTypeRepository,
|
||||||
|
ICourseLabelRepository courseLabelRepository,
|
||||||
IMemberCardRecordService memberCardRecordService,
|
IMemberCardRecordService memberCardRecordService,
|
||||||
MemberCardRepository memberCardRepository,
|
MemberCardRepository memberCardRepository,
|
||||||
RedisUtil redisUtil,
|
RedisUtil redisUtil,
|
||||||
ObjectMapper objectMapper,
|
ObjectMapper objectMapper,
|
||||||
GroupCourseStateMachine stateMachine){
|
GroupCourseStateMachine stateMachine,
|
||||||
|
DatabaseClient databaseClient){
|
||||||
this.groupCourseRepository = groupCourseRepository;
|
this.groupCourseRepository = groupCourseRepository;
|
||||||
this.bookingRepository = bookingRepository;
|
this.bookingRepository = bookingRepository;
|
||||||
|
this.groupCourseTypeRepository = groupCourseTypeRepository;
|
||||||
|
this.courseLabelRepository = courseLabelRepository;
|
||||||
this.memberCardRecordService = memberCardRecordService;
|
this.memberCardRecordService = memberCardRecordService;
|
||||||
this.memberCardRepository = memberCardRepository;
|
this.memberCardRepository = memberCardRepository;
|
||||||
this.redisUtil = redisUtil;
|
this.redisUtil = redisUtil;
|
||||||
this.objectMapper = objectMapper;
|
this.objectMapper = objectMapper;
|
||||||
this.stateMachine = stateMachine;
|
this.stateMachine = stateMachine;
|
||||||
|
this.databaseClient = databaseClient;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseDetail> findDetailById(Long id) {
|
||||||
|
String cacheKey = CACHE_KEY_DETAIL_PREFIX + id;
|
||||||
|
|
||||||
|
return redisUtil.get(cacheKey, String.class)
|
||||||
|
.flatMap(cachedJson -> {
|
||||||
|
if (cachedJson != null) {
|
||||||
|
try {
|
||||||
|
GroupCourseDetail detail = objectMapper.readValue(cachedJson, GroupCourseDetail.class);
|
||||||
|
logger.info("缓存命中 - findDetailById: id={}", id);
|
||||||
|
return Mono.just(detail);
|
||||||
|
} catch (JsonProcessingException e) {
|
||||||
|
logger.warn("缓存解析失败,删除缓存 - id: {}, error: {}", id, e.getMessage());
|
||||||
|
return redisUtil.delete(cacheKey).then(Mono.empty());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return Mono.empty();
|
||||||
|
})
|
||||||
|
.switchIfEmpty(
|
||||||
|
groupCourseRepository.findByIdAndDeletedAtIsNull(id)
|
||||||
|
.flatMap(course -> {
|
||||||
|
// 查询类型信息
|
||||||
|
Long courseTypeId = course.getCourseType();
|
||||||
|
|
||||||
|
if (courseTypeId == null) {
|
||||||
|
// 没有类型,直接构建详情
|
||||||
|
return Mono.just(buildDetail(course, null));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 有类型,查询类型信息
|
||||||
|
return groupCourseTypeRepository.findById(courseTypeId)
|
||||||
|
.flatMap(type -> {
|
||||||
|
// 查询标签
|
||||||
|
return courseLabelRepository.findByTypeId(type.getId())
|
||||||
|
.collectList()
|
||||||
|
.map(labels -> {
|
||||||
|
type.setLabels(labels);
|
||||||
|
return buildDetail(course, type);
|
||||||
|
});
|
||||||
|
})
|
||||||
|
.switchIfEmpty(Mono.just(buildDetail(course, null)));
|
||||||
|
})
|
||||||
|
.flatMap(detail -> {
|
||||||
|
try {
|
||||||
|
String jsonData = objectMapper.writeValueAsString(detail);
|
||||||
|
return redisUtil.setWithExpire(cacheKey, jsonData, CACHE_EXPIRE_SECONDS)
|
||||||
|
.thenReturn(detail)
|
||||||
|
.doOnSuccess(d -> logger.debug("缓存已设置 - findDetailById: id={}", id));
|
||||||
|
} catch (JsonProcessingException e) {
|
||||||
|
logger.error("缓存设置失败 - id: {}, error: {}", id, e.getMessage());
|
||||||
|
return Mono.just(detail);
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.doOnSubscribe(sub -> logger.debug("缓存未命中,查询数据库 - findDetailById: id={}", id))
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 构建团课完整信息对象
|
||||||
|
*/
|
||||||
|
private GroupCourseDetail buildDetail(GroupCourse course, GroupCourseType type) {
|
||||||
|
GroupCourseDetail detail = new GroupCourseDetail();
|
||||||
|
detail.setId(course.getId());
|
||||||
|
detail.setCourseName(course.getCourseName());
|
||||||
|
detail.setCoachId(course.getCoachId());
|
||||||
|
detail.setCourseType(course.getCourseType());
|
||||||
|
detail.setStartTime(course.getStartTime());
|
||||||
|
detail.setEndTime(course.getEndTime());
|
||||||
|
detail.setMaxMembers(course.getMaxMembers());
|
||||||
|
detail.setCurrentMembers(course.getCurrentMembers());
|
||||||
|
detail.setStatus(course.getStatus());
|
||||||
|
detail.setLocation(course.getLocation());
|
||||||
|
detail.setCoverImage(course.getCoverImage());
|
||||||
|
detail.setDescription(course.getDescription());
|
||||||
|
detail.setPointCardAmount(course.getPointCardAmount());
|
||||||
|
detail.setStoredValueAmount(course.getStoredValueAmount());
|
||||||
|
detail.setQrCodePath(course.getQrCodePath());
|
||||||
|
detail.setCreatedAt(course.getCreatedAt());
|
||||||
|
detail.setUpdatedAt(course.getUpdatedAt());
|
||||||
|
|
||||||
|
// 设置类型信息
|
||||||
|
if (type != null) {
|
||||||
|
detail.setTypeInfo(type);
|
||||||
|
}
|
||||||
|
|
||||||
|
return detail;
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@@ -163,7 +271,38 @@ public class GroupCourseService implements IGroupCourseService {
|
|||||||
@Override
|
@Override
|
||||||
public Mono<GroupCourse> create(GroupCourse groupCourse) {
|
public Mono<GroupCourse> create(GroupCourse groupCourse) {
|
||||||
return groupCourseRepository.save(groupCourse)
|
return groupCourseRepository.save(groupCourse)
|
||||||
.doOnSuccess(course -> logger.info("团课创建成功 - id={}, name={}", course.getId(), course.getCourseName()))
|
.flatMap(course -> {
|
||||||
|
try {
|
||||||
|
// 生成二维码内容:团课基础信息JSON
|
||||||
|
Map<String, Object> qrCodeContent = new HashMap<>();
|
||||||
|
qrCodeContent.put("id", course.getId());
|
||||||
|
qrCodeContent.put("courseName", course.getCourseName());
|
||||||
|
qrCodeContent.put("coachId", course.getCoachId());
|
||||||
|
qrCodeContent.put("courseType", course.getCourseType());
|
||||||
|
qrCodeContent.put("startTime", course.getStartTime());
|
||||||
|
qrCodeContent.put("endTime", course.getEndTime());
|
||||||
|
qrCodeContent.put("maxMembers", course.getMaxMembers());
|
||||||
|
qrCodeContent.put("location", course.getLocation());
|
||||||
|
qrCodeContent.put("description", course.getDescription());
|
||||||
|
qrCodeContent.put("createdAt", course.getCreatedAt());
|
||||||
|
|
||||||
|
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()));
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.error("团课二维码生成失败 - id={}, error: {}", course.getId(), e.getMessage(), e);
|
||||||
|
// 即使二维码生成失败,也返回成功创建的团课
|
||||||
|
return Mono.just(course);
|
||||||
|
}
|
||||||
|
})
|
||||||
.flatMap(course -> clearCache().thenReturn(course))
|
.flatMap(course -> clearCache().thenReturn(course))
|
||||||
.doOnError(error -> logger.error("团课创建失败 - error: {}", error.getMessage()));
|
.doOnError(error -> logger.error("团课创建失败 - error: {}", error.getMessage()));
|
||||||
}
|
}
|
||||||
@@ -209,6 +348,9 @@ public class GroupCourseService implements IGroupCourseService {
|
|||||||
if (groupCourse.getStoredValueAmount() != null) {
|
if (groupCourse.getStoredValueAmount() != null) {
|
||||||
existing.setStoredValueAmount(groupCourse.getStoredValueAmount());
|
existing.setStoredValueAmount(groupCourse.getStoredValueAmount());
|
||||||
}
|
}
|
||||||
|
if (groupCourse.getQrCodePath() != null) {
|
||||||
|
existing.setQrCodePath(groupCourse.getQrCodePath());
|
||||||
|
}
|
||||||
return groupCourseRepository.update(existing);
|
return groupCourseRepository.update(existing);
|
||||||
})
|
})
|
||||||
.doOnSuccess(course -> logger.info("团课更新成功 - id={}", id))
|
.doOnSuccess(course -> logger.info("团课更新成功 - id={}", id))
|
||||||
@@ -341,26 +483,56 @@ public class GroupCourseService implements IGroupCourseService {
|
|||||||
@Override
|
@Override
|
||||||
public Mono<GroupCourse> signIn(Long courseId, Long memberId) {
|
public Mono<GroupCourse> signIn(Long courseId, Long memberId) {
|
||||||
return groupCourseRepository.findByIdAndDeletedAtIsNull(courseId)
|
return groupCourseRepository.findByIdAndDeletedAtIsNull(courseId)
|
||||||
.switchIfEmpty(Mono.error(new RuntimeException("团课不存在")))
|
.switchIfEmpty(Mono.error(new RuntimeException("团课不存在或已删除")))
|
||||||
.flatMap(course -> {
|
.flatMap(course -> {
|
||||||
if (course.getStatus() != 0L) {
|
// 校验1:团课已取消
|
||||||
return Mono.error(new RuntimeException("课程状态不允许签到"));
|
if (course.getStatus().equals(CourseStatus.CANCELLED.getValue())) {
|
||||||
|
return Mono.error(new RuntimeException("团课已取消,无法签到"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 校验2:团课已结束
|
||||||
|
if (course.getStatus().equals(CourseStatus.ENDED.getValue())) {
|
||||||
|
return Mono.error(new RuntimeException("团课已结束,无法签到"));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 校验3:签到时间校验(开课前2小时内才能签到)
|
||||||
|
LocalDateTime now = LocalDateTime.now();
|
||||||
|
LocalDateTime signInStart = course.getStartTime().minusHours(2);
|
||||||
|
if (now.isBefore(signInStart)) {
|
||||||
|
return Mono.error(new RuntimeException("未到签到时间,请在开课前2小时内签到"));
|
||||||
|
}
|
||||||
|
if (now.isAfter(course.getEndTime())) {
|
||||||
|
return Mono.error(new RuntimeException("团课已结束,无法签到"));
|
||||||
|
}
|
||||||
|
|
||||||
|
// 校验4:课程已满员
|
||||||
if (course.getCurrentMembers() >= course.getMaxMembers()) {
|
if (course.getCurrentMembers() >= course.getMaxMembers()) {
|
||||||
return Mono.error(new RuntimeException("课程已满员"));
|
return Mono.error(new RuntimeException("课程已满员,无法签到"));
|
||||||
}
|
}
|
||||||
|
|
||||||
// 检查会员是否已预约此课程
|
// 校验5:用户今日是否已到店签到(直接查询sign_in_record表)
|
||||||
return bookingRepository.findValidBooking(courseId, memberId)
|
LocalDateTime todayStart = LocalDateTime.now().toLocalDate().atStartOfDay();
|
||||||
.switchIfEmpty(Mono.error(new RuntimeException("会员未预约此课程")))
|
LocalDateTime todayEnd = todayStart.plusDays(1);
|
||||||
.flatMap(booking -> {
|
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)
|
||||||
return groupCourseRepository.updateCurrentMembers(courseId, 1)
|
.bind("startTime", todayStart)
|
||||||
.flatMap(updatedCourse -> {
|
.bind("endTime", todayEnd)
|
||||||
// 更新预约状态为已出席
|
.map(row -> row.get("sign_in_status", String.class))
|
||||||
return bookingRepository.updateStatus(booking.getId(), "2")
|
.one()
|
||||||
.thenReturn(updatedCourse);
|
.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);
|
||||||
|
});
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
})
|
})
|
||||||
@@ -389,8 +561,21 @@ public class GroupCourseService implements IGroupCourseService {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<PageResponse<GroupCourse>> searchGroupCourses(GroupCourseQueryDto query) {
|
||||||
|
logger.info("多条件查询团课 - courseName={}, courseType={}, startDate={}, endDate={}, timePeriod={}, priceSort={}, remainingMost={}",
|
||||||
|
query.getCourseName(), query.getCourseType(), query.getStartDate(), query.getEndDate(),
|
||||||
|
query.getTimePeriod(), query.getPriceSort(), query.getRemainingMost());
|
||||||
|
|
||||||
|
return groupCourseRepository.searchGroupCourses(query)
|
||||||
|
.doOnSuccess(result -> logger.info("多条件查询结果 - total={}, page={}, size={}",
|
||||||
|
result.getTotalElements(), result.getCurrentPage(), result.getPageSize()))
|
||||||
|
.doOnError(error -> logger.error("多条件查询失败 - error: {}", error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
private Mono<Void> clearCache() {
|
private Mono<Void> clearCache() {
|
||||||
return redisUtil.deleteByPattern(CACHE_KEY_PREFIX + "*")
|
return redisUtil.deleteByPattern(CACHE_KEY_PREFIX + "*")
|
||||||
.then(redisUtil.deleteByPattern(CACHE_KEY_ID_PREFIX + "*")).then();
|
.then(redisUtil.deleteByPattern(CACHE_KEY_ID_PREFIX + "*"))
|
||||||
|
.then(redisUtil.deleteByPattern(CACHE_KEY_DETAIL_PREFIX + "*")).then();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+86
@@ -0,0 +1,86 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.service.impl;
|
||||||
|
|
||||||
|
import cn.novalon.gym.manage.groupcourse.domain.GroupCourseType;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.repository.IGroupCourseTypeRepository;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.service.IGroupCourseTypeService;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
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;
|
||||||
|
|
||||||
|
public GroupCourseTypeService(IGroupCourseTypeRepository groupCourseTypeRepository) {
|
||||||
|
this.groupCourseTypeRepository = groupCourseTypeRepository;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseType> findById(Long id) {
|
||||||
|
return groupCourseTypeRepository.findById(id);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findAll() {
|
||||||
|
return groupCourseTypeRepository.findAll(false);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findAll(boolean includeDeleted) {
|
||||||
|
return groupCourseTypeRepository.findAll(includeDeleted);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findByKeyword(String keyword) {
|
||||||
|
return groupCourseTypeRepository.findByKeyword(keyword);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findByCategory(String category) {
|
||||||
|
return groupCourseTypeRepository.findByCategory(category);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<GroupCourseType> findByCategoryAndKeyword(String category, String keyword) {
|
||||||
|
return groupCourseTypeRepository.findByCategoryAndKeyword(category, keyword);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseType> create(GroupCourseType groupCourseType) {
|
||||||
|
return groupCourseTypeRepository.findByTypeName(groupCourseType.getTypeName())
|
||||||
|
.flatMap(existing -> Mono.<GroupCourseType>error(new RuntimeException("团课类型名称已存在")))
|
||||||
|
.switchIfEmpty(groupCourseTypeRepository.save(groupCourseType))
|
||||||
|
.doOnSuccess(type -> logger.info("团课类型创建成功 - id={}, name={}", type.getId(), type.getTypeName()))
|
||||||
|
.doOnError(error -> logger.error("团课类型创建失败 - error: {}", error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Mono<GroupCourseType> update(Long id, GroupCourseType groupCourseType) {
|
||||||
|
return groupCourseTypeRepository.update(groupCourseType)
|
||||||
|
.doOnSuccess(type -> logger.info("团课类型更新成功 - id={}", id))
|
||||||
|
.doOnError(error -> logger.error("团课类型更新失败 - id={}, error: {}", id, error.getMessage()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@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()));
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Flux<String> findCategories() {
|
||||||
|
return groupCourseTypeRepository.findAll(false)
|
||||||
|
.map(GroupCourseType::getCategory)
|
||||||
|
.filter(category -> category != null && !category.isEmpty())
|
||||||
|
.distinct();
|
||||||
|
}
|
||||||
|
}
|
||||||
+109
@@ -0,0 +1,109 @@
|
|||||||
|
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();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+156
@@ -0,0 +1,156 @@
|
|||||||
|
package cn.novalon.gym.manage.groupcourse.util;
|
||||||
|
|
||||||
|
import com.google.zxing.BarcodeFormat;
|
||||||
|
import com.google.zxing.EncodeHintType;
|
||||||
|
import com.google.zxing.WriterException;
|
||||||
|
import com.google.zxing.client.j2se.MatrixToImageWriter;
|
||||||
|
import com.google.zxing.common.BitMatrix;
|
||||||
|
import com.google.zxing.qrcode.QRCodeWriter;
|
||||||
|
import com.google.zxing.qrcode.decoder.ErrorCorrectionLevel;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
|
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 生成的二维码文件完整路径
|
||||||
|
*/
|
||||||
|
public static String generateQRCode(String content, String savePath, String fileName) {
|
||||||
|
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);
|
||||||
|
hints.put(EncodeHintType.MARGIN, 1);
|
||||||
|
|
||||||
|
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);
|
||||||
|
|
||||||
|
MatrixToImageWriter.writeToPath(bitMatrix, "PNG", path);
|
||||||
|
logger.info("二维码生成成功: {}", filePath);
|
||||||
|
|
||||||
|
return filePath;
|
||||||
|
} 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);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
+71
@@ -0,0 +1,71 @@
|
|||||||
|
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.*;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* QRCodeUtil测试类
|
||||||
|
*/
|
||||||
|
class QRCodeUtilTest {
|
||||||
|
|
||||||
|
@TempDir
|
||||||
|
Path tempDir;
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void testGenerateQRCode() {
|
||||||
|
String content = "测试二维码内容";
|
||||||
|
String qrCodePath = QRCodeUtil.generateQRCode(content);
|
||||||
|
|
||||||
|
assertNotNull(qrCodePath, "二维码路径不应为空");
|
||||||
|
assertTrue(qrCodePath.endsWith(".png"), "二维码文件应为PNG格式");
|
||||||
|
assertTrue(qrCodePath.contains("D:\\Games\\exmp\\image"), "二维码应保存到指定路径");
|
||||||
|
|
||||||
|
System.out.println("生成的二维码路径: " + qrCodePath);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void testGenerateQRCodeWithCustomPath() {
|
||||||
|
String content = "自定义路径测试";
|
||||||
|
String customPath = tempDir.toString();
|
||||||
|
String fileName = "test_qrcode";
|
||||||
|
|
||||||
|
String qrCodePath = QRCodeUtil.generateQRCode(content, customPath, fileName);
|
||||||
|
|
||||||
|
assertNotNull(qrCodePath, "二维码路径不应为空");
|
||||||
|
assertTrue(qrCodePath.endsWith(".png"), "二维码文件应为PNG格式");
|
||||||
|
assertTrue(qrCodePath.contains(fileName), "二维码文件名应包含指定名称");
|
||||||
|
|
||||||
|
System.out.println("生成的二维码路径: " + qrCodePath);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
void testGenerateQRCodeWithJsonContent() {
|
||||||
|
String jsonContent = "{\"id\":1,\"courseName\":\"瑜伽课\",\"coachId\":100,\"startTime\":\"2026-06-18T10:00:00\"}";
|
||||||
|
|
||||||
|
String qrCodePath = QRCodeUtil.generateQRCode(jsonContent);
|
||||||
|
|
||||||
|
assertNotNull(qrCodePath, "二维码路径不应为空");
|
||||||
|
assertTrue(qrCodePath.endsWith(".png"), "二维码文件应为PNG格式");
|
||||||
|
|
||||||
|
System.out.println("JSON内容二维码路径: " + qrCodePath);
|
||||||
|
}
|
||||||
|
|
||||||
|
@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);
|
||||||
|
}
|
||||||
|
}
|
||||||
+387
-152
File diff suppressed because one or more lines are too long
+49
-6
@@ -6,6 +6,9 @@ import cn.novalon.gym.manage.datacount.handler.DataStatisticsHandler;
|
|||||||
import cn.novalon.gym.manage.file.handler.SysFileHandler;
|
import cn.novalon.gym.manage.file.handler.SysFileHandler;
|
||||||
import cn.novalon.gym.manage.groupcourse.handler.GroupCourseBookingHandler;
|
import cn.novalon.gym.manage.groupcourse.handler.GroupCourseBookingHandler;
|
||||||
import cn.novalon.gym.manage.groupcourse.handler.GroupCourseHandler;
|
import cn.novalon.gym.manage.groupcourse.handler.GroupCourseHandler;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.handler.GroupCourseRecommendHandler;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.handler.GroupCourseTypeHandler;
|
||||||
|
import cn.novalon.gym.manage.groupcourse.handler.CourseLabelHandler;
|
||||||
import cn.novalon.gym.manage.member.handler.MemberCardHandler;
|
import cn.novalon.gym.manage.member.handler.MemberCardHandler;
|
||||||
import cn.novalon.gym.manage.member.handler.MemberCardRecordHandler;
|
import cn.novalon.gym.manage.member.handler.MemberCardRecordHandler;
|
||||||
import cn.novalon.gym.manage.member.handler.MemberCardTransactionHandler;
|
import cn.novalon.gym.manage.member.handler.MemberCardTransactionHandler;
|
||||||
@@ -69,6 +72,9 @@ public class SystemRouter {
|
|||||||
MemberCardTransactionHandler memberCardTransactionHandler,
|
MemberCardTransactionHandler memberCardTransactionHandler,
|
||||||
GroupCourseHandler groupCourseHandler,
|
GroupCourseHandler groupCourseHandler,
|
||||||
GroupCourseBookingHandler groupCourseBookingHandler,
|
GroupCourseBookingHandler groupCourseBookingHandler,
|
||||||
|
GroupCourseRecommendHandler groupCourseRecommendHandler,
|
||||||
|
GroupCourseTypeHandler groupCourseTypeHandler,
|
||||||
|
CourseLabelHandler courseLabelHandler,
|
||||||
CheckInHandler checkInHandler,
|
CheckInHandler checkInHandler,
|
||||||
DataStatisticsHandler dataStatisticsHandler) {
|
DataStatisticsHandler dataStatisticsHandler) {
|
||||||
|
|
||||||
@@ -265,12 +271,28 @@ public class SystemRouter {
|
|||||||
// ===== 团课课程管理 =====
|
// ===== 团课课程管理 =====
|
||||||
.GET("/api/groupCourse/list", groupCourseHandler::getAllGroupCourse)
|
.GET("/api/groupCourse/list", groupCourseHandler::getAllGroupCourse)
|
||||||
.POST("/api/groupCourse/page", groupCourseHandler::getGroupCoursesByPage)
|
.POST("/api/groupCourse/page", groupCourseHandler::getGroupCoursesByPage)
|
||||||
.GET("/api/groupCourse/{id}", groupCourseHandler::getGroupCourseById)
|
|
||||||
.POST("/api/groupCourse", groupCourseHandler::createGroupCourse)
|
// ===== 团课类型管理 =====
|
||||||
.PUT("/api/groupCourse/{id}", groupCourseHandler::updateGroupCourse)
|
.GET("/api/groupCourse/types", groupCourseTypeHandler::getAllGroupCourseTypes)
|
||||||
.DELETE("/api/groupCourse/{id}", groupCourseHandler::deleteGroupCourse)
|
.GET("/api/groupCourse/types/search", groupCourseTypeHandler::searchGroupCourseTypes)
|
||||||
.POST("/api/groupCourse/{id}/cancel", groupCourseHandler::cancelGroupCourse)
|
.GET("/api/groupCourse/types/categories", groupCourseTypeHandler::getCategories)
|
||||||
.POST("/api/groupCourse/{courseId}/signin", groupCourseHandler::signIn)
|
.GET("/api/groupCourse/types/category/{category}", groupCourseTypeHandler::getGroupCourseTypesByCategory)
|
||||||
|
.GET("/api/groupCourse/types/{id}", groupCourseTypeHandler::getGroupCourseTypeById)
|
||||||
|
.POST("/api/groupCourse/types", groupCourseTypeHandler::createGroupCourseType)
|
||||||
|
.PUT("/api/groupCourse/types/{id}", groupCourseTypeHandler::updateGroupCourseType)
|
||||||
|
.DELETE("/api/groupCourse/types/{id}", groupCourseTypeHandler::deleteGroupCourseType)
|
||||||
|
|
||||||
|
// ===== 团课标签管理 =====
|
||||||
|
.GET("/api/groupCourse/labels", courseLabelHandler::getAllLabels)
|
||||||
|
.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", courseLabelHandler::createLabel)
|
||||||
|
.PUT("/api/groupCourse/labels/{id}", courseLabelHandler::updateLabel)
|
||||||
|
.DELETE("/api/groupCourse/labels/{id}", courseLabelHandler::deleteLabel)
|
||||||
|
.POST("/api/groupCourse/types/{typeId}/labels", courseLabelHandler::addLabelsToType)
|
||||||
|
.DELETE("/api/groupCourse/types/{typeId}/labels/{labelId}", courseLabelHandler::removeLabelFromType)
|
||||||
|
.DELETE("/api/groupCourse/types/{typeId}/labels", courseLabelHandler::clearLabelsFromType)
|
||||||
|
|
||||||
// ===== 团课预约管理 =====
|
// ===== 团课预约管理 =====
|
||||||
.POST("/api/groupCourse/book", groupCourseBookingHandler::bookCourse)
|
.POST("/api/groupCourse/book", groupCourseBookingHandler::bookCourse)
|
||||||
@@ -278,6 +300,27 @@ public class SystemRouter {
|
|||||||
.GET("/api/groupCourse/bookings/member/{memberId}", groupCourseBookingHandler::getBookingsByMemberId)
|
.GET("/api/groupCourse/bookings/member/{memberId}", groupCourseBookingHandler::getBookingsByMemberId)
|
||||||
.GET("/api/groupCourse/bookings/course/{courseId}", groupCourseBookingHandler::getBookingsByCourseId)
|
.GET("/api/groupCourse/bookings/course/{courseId}", groupCourseBookingHandler::getBookingsByCourseId)
|
||||||
.GET("/api/groupCourse/bookings/{bookingId}", groupCourseBookingHandler::getBookingById)
|
.GET("/api/groupCourse/bookings/{bookingId}", groupCourseBookingHandler::getBookingById)
|
||||||
|
|
||||||
|
// ===== 团课推荐管理 =====
|
||||||
|
.GET("/api/groupCourse/recommend/list", groupCourseRecommendHandler::getAllRecommendations)
|
||||||
|
.GET("/api/groupCourse/recommend/active", groupCourseRecommendHandler::getAllActiveRecommendations)
|
||||||
|
.GET("/api/groupCourse/recommend/{id}", groupCourseRecommendHandler::getRecommendationById)
|
||||||
|
.GET("/api/groupCourse/recommend/course/{courseId}", groupCourseRecommendHandler::getRecommendationsByCourseId)
|
||||||
|
.POST("/api/groupCourse/recommend", groupCourseRecommendHandler::createRecommendation)
|
||||||
|
.PUT("/api/groupCourse/recommend/{id}", groupCourseRecommendHandler::updateRecommendation)
|
||||||
|
.DELETE("/api/groupCourse/recommend/{id}", groupCourseRecommendHandler::deleteRecommendation)
|
||||||
|
.POST("/api/groupCourse/recommend/{id}/enable", groupCourseRecommendHandler::enableRecommendation)
|
||||||
|
.POST("/api/groupCourse/recommend/{id}/disable", groupCourseRecommendHandler::disableRecommendation)
|
||||||
|
|
||||||
|
// ===== 团课课程管理(需要放在具体路由之后)=====
|
||||||
|
.GET("/api/groupCourse/{id}", groupCourseHandler::getGroupCourseById)
|
||||||
|
.GET("/api/groupCourse/{id}/detail", groupCourseHandler::getGroupCourseDetailById)
|
||||||
|
.POST("/api/groupCourse", groupCourseHandler::createGroupCourse)
|
||||||
|
.PUT("/api/groupCourse/{id}", groupCourseHandler::updateGroupCourse)
|
||||||
|
.DELETE("/api/groupCourse/{id}", groupCourseHandler::deleteGroupCourse)
|
||||||
|
.POST("/api/groupCourse/{id}/cancel", groupCourseHandler::cancelGroupCourse)
|
||||||
|
.POST("/api/groupCourse/signin/{memberId}", groupCourseHandler::signIn)
|
||||||
|
.POST("/api/groupCourse/search", groupCourseHandler::searchGroupCourses)
|
||||||
|
|
||||||
// ========= 签到模块路由 ==========
|
// ========= 签到模块路由 ==========
|
||||||
// ===== 签到核心功能 =====
|
// ===== 签到核心功能 =====
|
||||||
|
|||||||
+76
@@ -0,0 +1,76 @@
|
|||||||
|
-- ============================================
|
||||||
|
-- 团课类型表
|
||||||
|
-- ============================================
|
||||||
|
|
||||||
|
-- 团课类型表
|
||||||
|
CREATE TABLE IF NOT EXISTS group_course_type (
|
||||||
|
id BIGSERIAL PRIMARY KEY,
|
||||||
|
type_name VARCHAR(100) NOT NULL,
|
||||||
|
base_difficulty INTEGER DEFAULT 1,
|
||||||
|
description TEXT,
|
||||||
|
category VARCHAR(50),
|
||||||
|
create_by VARCHAR(50),
|
||||||
|
update_by VARCHAR(50),
|
||||||
|
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
deleted_at TIMESTAMP
|
||||||
|
);
|
||||||
|
|
||||||
|
COMMENT ON TABLE group_course_type IS '团课类型表';
|
||||||
|
COMMENT ON COLUMN group_course_type.id IS '主键ID';
|
||||||
|
COMMENT ON COLUMN group_course_type.type_name IS '类型名称';
|
||||||
|
COMMENT ON COLUMN group_course_type.base_difficulty IS '基础难度(1-10)';
|
||||||
|
COMMENT ON COLUMN group_course_type.description IS '类型描述';
|
||||||
|
COMMENT ON COLUMN group_course_type.category IS '分类(如:有氧、力量、柔韧等)';
|
||||||
|
COMMENT ON COLUMN group_course_type.create_by IS '创建人';
|
||||||
|
COMMENT ON COLUMN group_course_type.update_by IS '更新人';
|
||||||
|
COMMENT ON COLUMN group_course_type.created_at IS '创建时间';
|
||||||
|
COMMENT ON COLUMN group_course_type.updated_at IS '更新时间';
|
||||||
|
COMMENT ON COLUMN group_course_type.deleted_at IS '删除时间(软删除)';
|
||||||
|
|
||||||
|
-- 创建索引
|
||||||
|
CREATE INDEX idx_group_course_type_type_name ON group_course_type(type_name);
|
||||||
|
CREATE INDEX idx_group_course_type_category ON group_course_type(category);
|
||||||
|
|
||||||
|
-- 插入初始团课类型数据(参考exmp.txt)
|
||||||
|
INSERT INTO group_course_type (type_name, base_difficulty, description, category) VALUES
|
||||||
|
('慢走/椭圆机轻松模式', 1, '几乎无难度,适合所有人', '基础有氧与热身'),
|
||||||
|
('固定自行车(低阻力)', 2, '注意座椅高度调节即可', '基础有氧与热身'),
|
||||||
|
('跑步机慢跑', 3, '需要基本协调性,膝盖有压力', '基础有氧与热身'),
|
||||||
|
('跳绳(连续基础跳)', 3, '需要手脚配合,心肺要求明显', '基础有氧与热身'),
|
||||||
|
('坐姿腿屈伸/腿弯举', 2, '很容易找到发力感', '固定器械训练'),
|
||||||
|
('坐姿推胸机', 3, '需注意肩胛后收,避免耸肩', '固定器械训练'),
|
||||||
|
('高位下拉(坐姿)', 3, '需控制不要过度后仰', '固定器械训练'),
|
||||||
|
('史密斯机深蹲', 4, '轨迹固定,但需保持核心稳定', '固定器械训练'),
|
||||||
|
('蝴蝶机夹胸', 3, '易用肘关节代偿,需锁定肩关节', '固定器械训练'),
|
||||||
|
('平板支撑', 3, '耐力考验,技巧低', '自重基础动作'),
|
||||||
|
('跪姿俯卧撑', 3, '上肢力量较弱者首选', '自重基础动作'),
|
||||||
|
('标准俯卧撑', 5, '需核心收紧,身体成直线', '自重基础动作'),
|
||||||
|
('引体向上(弹力带辅助)', 6, '背部和手臂力量要求高', '自重基础动作'),
|
||||||
|
('标准引体向上', 8, '力量-体重比极高,多数男性无法完成1次', '自重基础动作'),
|
||||||
|
('徒手深蹲', 3, '注意膝盖方向与背部直立', '自重基础动作'),
|
||||||
|
('单腿深蹲(手枪蹲)', 8, '需要极高下肢力量、柔韧性和平衡', '自重基础动作'),
|
||||||
|
('哑铃二头弯举', 4, '容易晃动借力,但较安全', '自由重量杠铃/哑铃'),
|
||||||
|
('哑铃侧平举', 5, '极易用斜方肌代偿,真正练到三角肌中束很难', '自由重量杠铃/哑铃'),
|
||||||
|
('杠铃卧推', 7, '肩关节压力大,起桥、沉肩、稳定手腕均有技巧,有压伤风险', '自由重量杠铃/哑铃'),
|
||||||
|
('杠铃深蹲(颈后)', 8, '全身协调性、核心抗压、杠位放置、呼吸模式,学习曲线陡峭', '自由重量杠铃/哑铃'),
|
||||||
|
('传统硬拉', 9, '风险极高,需要精确的脊柱中立、髋铰链、背阔肌收紧,错误时伤腰', '自由重量杠铃/哑铃'),
|
||||||
|
('高翻/抓举(奥运举重)', 10, '需要爆发力、柔韧、精准衔接,非数月训练不能掌握', '自由重量杠铃/哑铃'),
|
||||||
|
('波比跳(标准版)', 6, '连续做时心肺压力极大', '高强度与爆发力'),
|
||||||
|
('冲刺跑(短跑)', 7, '对腘绳肌和脚踝爆发力要求高', '高强度与爆发力'),
|
||||||
|
('跳箱(合理高度)', 6, '需要落地缓冲技巧', '高强度与爆发力'),
|
||||||
|
('负重雪橇推', 6, '主要考验腿部耐力和意志力', '高强度与爆发力'),
|
||||||
|
('双力臂(引体向上后翻腕上杠)', 9, '需要爆发引体 + 极高相对力量', '高强度与爆发力'),
|
||||||
|
('静态拉伸(坐姿体前屈)', 2, '无风险,但需要坚持', '柔韧与平衡类'),
|
||||||
|
('瑜伽下犬式', 3, '常见,但需背部与手臂对齐', '柔韧与平衡类'),
|
||||||
|
('单腿罗马尼亚硬拉(徒手)', 6, '极考验平衡和髋稳定', '柔韧与平衡类'),
|
||||||
|
('全深蹲(脚跟贴地,亚洲蹲)', 5, '踝关节灵活度限制多数人', '柔韧与平衡类'),
|
||||||
|
('竖叉/横叉', 8, '需要数月甚至数年拉伸', '柔韧与平衡类'),
|
||||||
|
('瑜伽入门', 2, '适合初学者的瑜伽课程,注重基础体式', '柔韧与平衡类'),
|
||||||
|
('瑜伽进阶', 5, '针对有一定基础的学员,包含更复杂体式', '柔韧与平衡类'),
|
||||||
|
('普拉提', 4, '注重核心力量和身体控制', '柔韧与平衡类'),
|
||||||
|
('动感单车', 4, '高强度有氧运动,节奏感强', '基础有氧与热身'),
|
||||||
|
('搏击操', 5, '结合拳击动作的有氧运动', '高强度与爆发力'),
|
||||||
|
('HIIT训练', 7, '高强度间歇训练,对心肺要求极高', '高强度与爆发力'),
|
||||||
|
('核心训练', 4, '针对核心肌群的专项训练', '自重基础动作')
|
||||||
|
ON CONFLICT DO NOTHING;
|
||||||
+73
@@ -0,0 +1,73 @@
|
|||||||
|
-- ============================================
|
||||||
|
-- 团课标签相关表
|
||||||
|
-- ============================================
|
||||||
|
|
||||||
|
-- 团课标签表
|
||||||
|
CREATE TABLE IF NOT EXISTS course_label (
|
||||||
|
id BIGSERIAL PRIMARY KEY,
|
||||||
|
label_name VARCHAR(50) NOT NULL,
|
||||||
|
color VARCHAR(20) DEFAULT '#1890ff',
|
||||||
|
description VARCHAR(200),
|
||||||
|
create_by VARCHAR(50),
|
||||||
|
update_by VARCHAR(50),
|
||||||
|
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
deleted_at TIMESTAMP
|
||||||
|
);
|
||||||
|
|
||||||
|
-- 团课类型-标签关联表
|
||||||
|
CREATE TABLE IF NOT EXISTS course_type_label (
|
||||||
|
id BIGSERIAL PRIMARY KEY,
|
||||||
|
type_id BIGINT NOT NULL,
|
||||||
|
label_id BIGINT NOT NULL,
|
||||||
|
create_by VARCHAR(50),
|
||||||
|
update_by VARCHAR(50),
|
||||||
|
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
deleted_at TIMESTAMP,
|
||||||
|
UNIQUE (type_id, label_id)
|
||||||
|
);
|
||||||
|
|
||||||
|
COMMENT ON TABLE course_label IS '团课标签表';
|
||||||
|
COMMENT ON COLUMN course_label.id IS '主键ID';
|
||||||
|
COMMENT ON COLUMN course_label.label_name IS '标签名称';
|
||||||
|
COMMENT ON COLUMN course_label.color IS '标签颜色(十六进制)';
|
||||||
|
COMMENT ON COLUMN course_label.description IS '标签描述';
|
||||||
|
COMMENT ON COLUMN course_label.create_by IS '创建人';
|
||||||
|
COMMENT ON COLUMN course_label.update_by IS '更新人';
|
||||||
|
COMMENT ON COLUMN course_label.created_at IS '创建时间';
|
||||||
|
COMMENT ON COLUMN course_label.updated_at IS '更新时间';
|
||||||
|
COMMENT ON COLUMN course_label.deleted_at IS '删除时间(软删除)';
|
||||||
|
|
||||||
|
COMMENT ON TABLE course_type_label IS '团课类型-标签关联表';
|
||||||
|
COMMENT ON COLUMN course_type_label.id IS '主键ID';
|
||||||
|
COMMENT ON COLUMN course_type_label.type_id IS '团课类型ID';
|
||||||
|
COMMENT ON COLUMN course_type_label.label_id IS '标签ID';
|
||||||
|
COMMENT ON COLUMN course_type_label.create_by IS '创建人';
|
||||||
|
COMMENT ON COLUMN course_type_label.update_by IS '更新人';
|
||||||
|
COMMENT ON COLUMN course_type_label.created_at IS '创建时间';
|
||||||
|
COMMENT ON COLUMN course_type_label.updated_at IS '更新时间';
|
||||||
|
COMMENT ON COLUMN course_type_label.deleted_at IS '删除时间(软删除)';
|
||||||
|
|
||||||
|
-- 创建索引
|
||||||
|
CREATE INDEX idx_course_label_label_name ON course_label(label_name);
|
||||||
|
CREATE INDEX idx_course_type_label_type_id ON course_type_label(type_id);
|
||||||
|
CREATE INDEX idx_course_type_label_label_id ON course_type_label(label_id);
|
||||||
|
|
||||||
|
-- 插入初始标签数据
|
||||||
|
INSERT INTO course_label (label_name, color, description) VALUES
|
||||||
|
('适合新手', '#52c41a', '适合健身初学者'),
|
||||||
|
('中级过渡', '#faad14', '适合有一定基础的学员'),
|
||||||
|
('高级进阶', '#f5222d', '适合高级学员'),
|
||||||
|
('减脂塑形', '#722ed1', '有助于减脂塑形'),
|
||||||
|
('增肌强化', '#13c2c2', '有助于增肌强化'),
|
||||||
|
('柔韧性训练', '#eb2f96', '注重柔韧性提升'),
|
||||||
|
('核心训练', '#1890ff', '注重核心力量'),
|
||||||
|
('心肺训练', '#fa8c16', '提升心肺功能'),
|
||||||
|
('低冲击', '#52c41a', '低冲击运动,适合关节保护'),
|
||||||
|
('高强度', '#f5222d', '高强度间歇训练'),
|
||||||
|
('团体互动', '#722ed1', '注重团队协作'),
|
||||||
|
('私教推荐', '#13c2c2', '私教推荐课程'),
|
||||||
|
('热门课程', '#ff1493', '人气较高的课程'),
|
||||||
|
('新课上线', '#00ced1', '新上线的课程')
|
||||||
|
ON CONFLICT DO NOTHING;
|
||||||
+38
@@ -0,0 +1,38 @@
|
|||||||
|
-- ============================================
|
||||||
|
-- 团课推荐表
|
||||||
|
-- ============================================
|
||||||
|
|
||||||
|
-- 团课推荐表
|
||||||
|
CREATE TABLE IF NOT EXISTS group_course_recommend (
|
||||||
|
id BIGSERIAL PRIMARY KEY,
|
||||||
|
course_id BIGINT NOT NULL,
|
||||||
|
recommend_title VARCHAR(200),
|
||||||
|
recommend_content TEXT,
|
||||||
|
recommend_reason VARCHAR(500),
|
||||||
|
priority INTEGER DEFAULT 0,
|
||||||
|
is_active BOOLEAN DEFAULT TRUE,
|
||||||
|
create_by VARCHAR(50),
|
||||||
|
update_by VARCHAR(50),
|
||||||
|
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
|
deleted_at TIMESTAMP
|
||||||
|
);
|
||||||
|
|
||||||
|
-- 创建索引
|
||||||
|
CREATE INDEX IF NOT EXISTS idx_group_course_recommend_course_id ON group_course_recommend(course_id);
|
||||||
|
CREATE INDEX IF NOT EXISTS idx_group_course_recommend_priority ON group_course_recommend(priority);
|
||||||
|
CREATE INDEX IF NOT EXISTS idx_group_course_recommend_is_active ON group_course_recommend(is_active);
|
||||||
|
|
||||||
|
COMMENT ON TABLE group_course_recommend IS '团课推荐表';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.id IS '主键ID';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.course_id IS '团课ID(关联group_course.id)';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.recommend_title IS '推荐标题';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.recommend_content IS '推荐内容';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.recommend_reason IS '推荐理由';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.priority IS '优先级(数字越大优先级越高)';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.is_active IS '是否启用';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.create_by IS '创建人';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.update_by IS '更新人';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.created_at IS '创建时间';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.updated_at IS '更新时间';
|
||||||
|
COMMENT ON COLUMN group_course_recommend.deleted_at IS '删除时间(软删除)';
|
||||||
+43
@@ -0,0 +1,43 @@
|
|||||||
|
-- ============================================
|
||||||
|
-- 团课推荐测试数据
|
||||||
|
-- ============================================
|
||||||
|
|
||||||
|
-- 推荐数据1: 极速燃脂单车 - 高优先级推荐(热门课程)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(1, '本周热门推荐', '极速燃脂单车课程,跟随音乐节奏变换阻力和速度,体验爬坡与冲刺的快感,一节课消耗800大卡!', '教练专业,课程内容丰富,深受学员喜爱,燃脂效果显著', 20, true, 'admin', '2026-06-15 10:00:00', '2026-06-15 10:00:00');
|
||||||
|
|
||||||
|
-- 推荐数据2: 清晨流瑜伽 - 中等优先级推荐(适合新手)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(2, '新手友好推荐', '清晨流瑜伽课程,适合有一定基础的学员,通过流畅的体式连接呼吸,唤醒身体能量。', '适合新手入门,教练耐心指导,课程节奏适中', 15, true, 'admin', '2026-06-15 11:00:00', '2026-06-15 11:00:00');
|
||||||
|
|
||||||
|
-- 推荐数据3: 燃脂搏击 - 低优先级推荐(满员课程,已禁用)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(3, '高强度燃脂', '燃脂搏击课程,高强度间歇训练,配合音乐快速燃脂,释放压力。', '高强度训练,适合进阶学员,快速燃脂塑形', 10, false, 'admin', '2026-06-15 12:00:00', '2026-06-15 12:00:00');
|
||||||
|
|
||||||
|
-- 推荐数据4: 哈他瑜伽 - 中等优先级推荐(基础课程)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(4, '基础瑜伽推荐', '基础哈他瑜伽课程,适合所有级别学员,通过基础体式练习提升身体柔韧性和平衡能力。', '零基础友好,适合所有健身水平,放松身心', 12, true, 'coach_li', '2026-06-15 13:00:00', '2026-06-15 13:00:00');
|
||||||
|
|
||||||
|
-- 推荐数据5: 蜜桃臀塑造 - 高优先级推荐(热门课程,但课程已结束)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(6, '塑形热门课程', '蜜桃臀塑造课程,针对性训练臀部肌肉群,打造完美曲线。', '专业私教指导,动作标准,效果显著,深受女性学员喜爱', 18, true, 'coach_li', '2026-05-25 09:15:00', '2026-05-25 09:15:00');
|
||||||
|
|
||||||
|
-- 推荐数据6: 午间冥想放松 - 低优先级推荐(放松课程)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(7, '午间放松推荐', '午间冥想放松课程,通过呼吸和正念冥想,深度放松身心,缓解工作压力。', '适合上班族,午间放松充电,提升下午工作效率', 8, true, 'admin', '2026-05-25 09:00:00', '2026-05-25 09:00:00');
|
||||||
|
|
||||||
|
-- 推荐数据7: 极速燃脂单车 - 第二个推荐(不同角度推荐)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(1, '减脂首选课程', '想要快速减脂?极速燃脂单车是你的最佳选择!专业教练带领,科学训练计划。', '减脂效果最佳,课程强度适中,适合想要快速瘦身的学员', 16, true, 'coach_zhang', '2026-06-15 14:00:00', '2026-06-15 14:00:00');
|
||||||
|
|
||||||
|
-- 推荐数据8: 清晨流瑜伽 - 第二个推荐(不同角度推荐)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(2, '晨练优选', '清晨流瑜伽,唤醒身体能量,开启活力一天!适合晨练爱好者。', '晨练最佳选择,提升身体活力,改善精神状态', 14, true, 'coach_wang', '2026-06-15 15:00:00', '2026-06-15 15:00:00');
|
||||||
|
|
||||||
|
-- 推荐数据9: 哈他瑜伽 - 第二个推荐(不同角度推荐)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(4, '身心平衡推荐', '哈他瑜伽课程,通过体式练习和呼吸控制,达到身心平衡,提升整体健康水平。', '改善身体柔韧性,增强核心力量,提升身体协调性', 11, true, 'coach_li', '2026-06-15 16:00:00', '2026-06-15 16:00:00');
|
||||||
|
|
||||||
|
-- 推荐数据10: 午间冥想放松 - 第二个推荐(不同角度推荐,已禁用)
|
||||||
|
INSERT INTO group_course_recommend (course_id, recommend_title, recommend_content, recommend_reason, priority, is_active, create_by, created_at, updated_at) VALUES
|
||||||
|
(7, '职场减压课程', '午间冥想放松,专为职场人士设计,快速缓解工作压力,提升工作状态。', '职场减压首选,课程时间短,效果显著', 9, false, 'admin', '2026-05-25 10:00:00', '2026-05-25 10:00:00');
|
||||||
+9
@@ -0,0 +1,9 @@
|
|||||||
|
-- ============================================
|
||||||
|
-- 为团课表添加二维码路径字段
|
||||||
|
-- ============================================
|
||||||
|
|
||||||
|
-- 添加二维码路径字段
|
||||||
|
ALTER TABLE group_course ADD COLUMN qr_code_path VARCHAR(500);
|
||||||
|
|
||||||
|
-- 添加字段注释
|
||||||
|
COMMENT ON COLUMN group_course.qr_code_path IS '二维码图片路径';
|
||||||
Reference in New Issue
Block a user