+ ![]()
+ {{ item.nickname }}
+ ID: {{ item.userId }}
+
+
@@ -158,6 +166,7 @@
+
+
diff --git a/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/FriendAdminController.java b/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/FriendAdminController.java
index e8dd82c2..9cc58ba2 100644
--- a/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/FriendAdminController.java
+++ b/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/FriendAdminController.java
@@ -47,13 +47,15 @@ public class FriendAdminController {
sql.append("FROM eb_friend f ");
sql.append("LEFT JOIN eb_user u1 ON f.user_id = u1.uid ");
sql.append("LEFT JOIN eb_user u2 ON f.friend_id = u2.uid ");
- sql.append("WHERE f.status = 1 ");
+ // 只查询 user_id < friend_id 的记录，避免双向关系重复显示
+ sql.append("WHERE f.status = 1 AND f.user_id < f.friend_id ");
StringBuilder countSql = new StringBuilder();
countSql.append("SELECT COUNT(*) FROM eb_friend f ");
countSql.append("LEFT JOIN eb_user u1 ON f.user_id = u1.uid ");
countSql.append("LEFT JOIN eb_user u2 ON f.friend_id = u2.uid ");
- countSql.append("WHERE f.status = 1 ");
+ // 只统计 user_id < friend_id 的记录
+ countSql.append("WHERE f.status = 1 AND f.user_id < f.friend_id ");
// 筛选条件
if (userId != null) {
@@ -245,14 +247,14 @@ public class FriendAdminController {
Map stats = new HashMap<>();
try {
- // 总好友对数（除以2因为是双向关系）
+ // 总好友对数（只统计 user_id < friend_id 的记录）
Long totalFriends = jdbcTemplate.queryForObject(
- "SELECT COUNT(*) / 2 FROM eb_friend WHERE status = 1", Long.class);
+ "SELECT COUNT(*) FROM eb_friend WHERE status = 1 AND user_id < friend_id", Long.class);
stats.put("totalFriends", totalFriends != null ? totalFriends : 0);
- // 今日新增好友
+ // 今日新增好友（只统计 user_id < friend_id 的记录）
Long todayFriends = jdbcTemplate.queryForObject(
- "SELECT COUNT(*) / 2 FROM eb_friend WHERE status = 1 AND DATE(create_time) = CURDATE()", Long.class);
+ "SELECT COUNT(*) FROM eb_friend WHERE status = 1 AND user_id < friend_id AND DATE(create_time) = CURDATE()", Long.class);
stats.put("todayFriends", todayFriends != null ? todayFriends : 0);
// 待处理请求数
diff --git a/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/GroupAdminController.java b/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/GroupAdminController.java
new file mode 100644
index 00000000..c516ec5d
--- /dev/null
+++ b/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/GroupAdminController.java
@@ -0,0 +1,195 @@
+package com.zbkj.admin.controller;
+
+import com.zbkj.common.page.CommonPage;
+import com.zbkj.common.result.CommonResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 群组管理控制器（管理端）
+ */
+@Slf4j
+@RestController
+@RequestMapping("api/admin/group")
+@Api(tags = "群组管理")
+@Validated
+public class GroupAdminController {
+
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+
+ /**
+ * 群组列表
+ */
+ @ApiOperation(value = "群组列表")
+ @GetMapping("/list")
+ public CommonResult>> getGroupList(
+ @RequestParam(value = "keyword", required = false) String keyword,
+ @RequestParam(value = "ownerId", required = false) Integer ownerId,
+ @RequestParam(value = "startDate", required = false) String startDate,
+ @RequestParam(value = "endDate", required = false) String endDate,
+ @RequestParam(value = "page", defaultValue = "1") Integer page,
+ @RequestParam(value = "limit", defaultValue = "20") Integer limit) {
+
+ StringBuilder sql = new StringBuilder();
+ sql.append("SELECT g.*, ");
+ sql.append("u.nickname as ownerNickname, u.avatar as ownerAvatar, u.phone as ownerPhone ");
+ sql.append("FROM eb_group g ");
+ sql.append("LEFT JOIN eb_user u ON g.owner_id = u.uid ");
+ sql.append("WHERE g.is_deleted = 0 ");
+
+ StringBuilder countSql = new StringBuilder();
+ countSql.append("SELECT COUNT(*) FROM eb_group g ");
+ countSql.append("LEFT JOIN eb_user u ON g.owner_id = u.uid ");
+ countSql.append("WHERE g.is_deleted = 0 ");
+
+ // 筛选条件
+ if (keyword != null && !keyword.isEmpty()) {
+ String condition = " AND g.group_name LIKE '%" + keyword + "%' ";
+ sql.append(condition);
+ countSql.append(condition);
+ }
+ if (ownerId != null) {
+ String condition = " AND g.owner_id = " + ownerId;
+ sql.append(condition);
+ countSql.append(condition);
+ }
+ if (startDate != null && !startDate.isEmpty()) {
+ String condition = " AND g.create_time >= '" + startDate + " 00:00:00' ";
+ sql.append(condition);
+ countSql.append(condition);
+ }
+ if (endDate != null && !endDate.isEmpty()) {
+ String condition = " AND g.create_time <= '" + endDate + " 23:59:59' ";
+ sql.append(condition);
+ countSql.append(condition);
+ }
+
+ sql.append(" ORDER BY g.create_time DESC ");
+
+ Long total = jdbcTemplate.queryForObject(countSql.toString(), Long.class);
+
+ int offset = (page - 1) * limit;
+ sql.append(" LIMIT ").append(offset).append(", ").append(limit);
+
+ List> list = jdbcTemplate.queryForList(sql.toString());
+
+ // 转换字段名
+ list.forEach(item -> {
+ item.put("groupName", item.get("group_name"));
+ item.put("ownerId", item.get("owner_id"));
+ item.put("memberCount", item.get("member_count"));
+ item.put("maxMembers", item.get("max_members"));
+ item.put("createTime", item.get("create_time"));
+ item.put("updateTime", item.get("update_time"));
+ });
+
+ CommonPage> result = new CommonPage<>();
+ result.setList(list);
+ result.setTotal(total != null ? total : 0L);
+ result.setPage(page);
+ result.setLimit(limit);
+ result.setTotalPage((int) Math.ceil((double) (total != null ? total : 0) / limit));
+
+ return CommonResult.success(result);
+ }
+
+ /**
+ * 群组成员列表
+ */
+ @ApiOperation(value = "群组成员列表")
+ @GetMapping("/{groupId}/members")
+ public CommonResult>> getGroupMembers(
+ @PathVariable Long groupId,
+ @RequestParam(value = "page", defaultValue = "1") Integer page,
+ @RequestParam(value = "limit", defaultValue = "20") Integer limit) {
+
+ int offset = (page - 1) * limit;
+
+ String sql = "SELECT gm.*, u.nickname, u.avatar, u.phone " +
+ "FROM eb_group_member gm " +
+ "LEFT JOIN eb_user u ON gm.user_id = u.uid " +
+ "WHERE gm.group_id = ? AND gm.is_deleted = 0 " +
+ "ORDER BY gm.role DESC, gm.join_time ASC " +
+ "LIMIT ?, ?";
+
+ List> list = jdbcTemplate.queryForList(sql, groupId, offset, limit);
+
+ // 转换字段名
+ list.forEach(item -> {
+ item.put("userId", item.get("user_id"));
+ item.put("groupId", item.get("group_id"));
+ item.put("joinTime", item.get("join_time"));
+ });
+
+ String countSql = "SELECT COUNT(*) FROM eb_group_member WHERE group_id = ? AND is_deleted = 0";
+ Long total = jdbcTemplate.queryForObject(countSql, Long.class, groupId);
+
+ CommonPage> result = new CommonPage<>();
+ result.setList(list);
+ result.setTotal(total != null ? total : 0L);
+ result.setPage(page);
+ result.setLimit(limit);
+
+ return CommonResult.success(result);
+ }
+
+ /**
+ * 解散群组
+ */
+ @ApiOperation(value = "解散群组")
+ @DeleteMapping("/{id}")
+ public CommonResult deleteGroup(@PathVariable Long id) {
+ try {
+ // 软删除群组
+ jdbcTemplate.update("UPDATE eb_group SET is_deleted = 1, update_time = NOW() WHERE id = ?", id);
+ // 软删除所有成员
+ jdbcTemplate.update("UPDATE eb_group_member SET is_deleted = 1, update_time = NOW() WHERE group_id = ?", id);
+
+ return CommonResult.success(true);
+ } catch (Exception e) {
+ log.error("解散群组失败: {}", e.getMessage());
+ return CommonResult.failed("操作失败");
+ }
+ }
+
+ /**
+ * 群组统计
+ */
+ @ApiOperation(value = "群组统计")
+ @GetMapping("/statistics")
+ public CommonResult> getStatistics() {
+ Map stats = new HashMap<>();
+
+ try {
+ // 群组总数
+ Long totalGroups = jdbcTemplate.queryForObject(
+ "SELECT COUNT(*) FROM eb_group WHERE is_deleted = 0", Long.class);
+ stats.put("totalGroups", totalGroups != null ? totalGroups : 0);
+
+ // 今日新增群组
+ Long todayGroups = jdbcTemplate.queryForObject(
+ "SELECT COUNT(*) FROM eb_group WHERE is_deleted = 0 AND DATE(create_time) = CURDATE()", Long.class);
+ stats.put("todayGroups", todayGroups != null ? todayGroups : 0);
+
+ // 总成员数
+ Long totalMembers = jdbcTemplate.queryForObject(
+ "SELECT COUNT(*) FROM eb_group_member WHERE is_deleted = 0", Long.class);
+ stats.put("totalMembers", totalMembers != null ? totalMembers : 0);
+
+ } catch (Exception e) {
+ log.error("获取群组统计失败: {}", e.getMessage());
+ }
+
+ return CommonResult.success(stats);
+ }
+}
diff --git a/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/StreamerAdminController.java b/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/StreamerAdminController.java
new file mode 100644
index 00000000..9d24c598
--- /dev/null
+++ b/Zhibo/zhibo-h/crmeb-admin/src/main/java/com/zbkj/admin/controller/StreamerAdminController.java
@@ -0,0 +1,518 @@
+package com.zbkj.admin.controller;
+
+import com.zbkj.common.page.CommonPage;
+import com.zbkj.common.result.CommonResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 主播管理控制器（管理端）
+ */
+@Slf4j
+@RestController
+@RequestMapping("api/admin/streamer")
+@Api(tags = "主播管理")
+@Validated
+public class StreamerAdminController {
+
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+
+ /**
+ * 获取所有用户列表（用于选择主播）
+ */
+ @ApiOperation(value = "用户列表")
+ @GetMapping("/users")
+ public CommonResult>> getUserList(
+ @RequestParam(value = "keyword", required = false) String keyword) {
+ StringBuilder sql = new StringBuilder();
+ sql.append("SELECT uid as userId, nickname, avatar, phone FROM eb_user WHERE is_streamer = 0 ");
+ if (keyword != null && !keyword.isEmpty()) {
+ sql.append(" AND (nickname LIKE '%").append(keyword).append("%' OR phone LIKE '%").append(keyword).append("%' OR uid = '").append(keyword).append("') ");
+ }
+ sql.append(" ORDER BY uid DESC LIMIT 100");
+ List> list = jdbcTemplate.queryForList(sql.toString());
+ return CommonResult.success(list);
+ }
+
+ /**
+ * 获取所有主播列表（用于创建直播间选择）
+ */
+ @ApiOperation(value = "主播下拉列表")
+ @GetMapping("/streamers")
+ public CommonResult>> getStreamerOptions() {
+ String sql = "SELECT uid as userId, nickname, avatar FROM eb_user WHERE is_streamer = 1 ORDER BY streamer_certified_time DESC";
+ List> list = jdbcTemplate.queryForList(sql);
+ return CommonResult.success(list);
+ }
+
+ /**
+ * 获取主播列表
+ */
+ @ApiOperation(value = "主播列表")
+ @GetMapping("/list")
+ public CommonResult>> getStreamerList(
+ @RequestParam(value = "keyword", required = false) String keyword,
+ @RequestParam(value = "level", required = false) Integer level,
+ @RequestParam(value = "page", defaultValue = "1") Integer page,
+ @RequestParam(value = "limit", defaultValue = "20") Integer limit) {
+
+ StringBuilder sql = new StringBuilder();
+ sql.append("SELECT u.uid as userId, u.nickname, u.avatar, u.phone, ");
+ sql.append("u.is_streamer as isStreamer, u.streamer_level as streamerLevel, ");
+ sql.append("u.streamer_intro as streamerIntro, u.streamer_certified_time as certifiedTime, ");
+ sql.append("u.create_time as createTime, ");
+ sql.append("(SELECT COUNT(*) FROM eb_live_room r WHERE r.uid = u.uid) as roomCount, ");
+ sql.append("(SELECT COUNT(*) FROM eb_live_room r WHERE r.uid = u.uid AND DATE_FORMAT(r.create_time, '%Y-%m') = DATE_FORMAT(NOW(), '%Y-%m')) as monthRooms, ");
+ sql.append("EXISTS(SELECT 1 FROM eb_streamer_ban b WHERE b.user_id = u.uid AND b.is_active = 1 AND (b.ban_end_time IS NULL OR b.ban_end_time > NOW())) as isBanned ");
+ sql.append("FROM eb_user u WHERE u.is_streamer = 1 ");
+
+ StringBuilder countSql = new StringBuilder();
+ countSql.append("SELECT COUNT(*) FROM eb_user u WHERE u.is_streamer = 1 ");
+
+ if (keyword != null && !keyword.isEmpty()) {
+ String condition = " AND (u.nickname LIKE '%" + keyword + "%' OR u.phone LIKE '%" + keyword + "%') ";
+ sql.append(condition);
+ countSql.append(condition);
+ }
+ if (level != null) {
+ String condition = " AND u.streamer_level = " + level;
+ sql.append(condition);
+ countSql.append(condition);
+ }
+
+ sql.append(" ORDER BY u.streamer_certified_time DESC ");
+
+ Long total = jdbcTemplate.queryForObject(countSql.toString(), Long.class);
+
+ int offset = (page - 1) * limit;
+ sql.append(" LIMIT ").append(offset).append(", ").append(limit);
+
+ List> list = jdbcTemplate.queryForList(sql.toString());
+
+ CommonPage> result = new CommonPage<>();
+ result.setList(list);
+ result.setTotal(total != null ? total : 0L);
+ result.setPage(page);
+ result.setLimit(limit);
+ result.setTotalPage((int) Math.ceil((double) (total != null ? total : 0) / limit));
+
+ return CommonResult.success(result);
+ }
+
+ /**
+ * 获取主播认证申请列表
+ */
+ @ApiOperation(value = "认证申请列表")
+ @GetMapping("/applications")
+ public CommonResult>> getApplicationList(
+ @RequestParam(value = "status", required = false) Integer status,
+ @RequestParam(value = "page", defaultValue = "1") Integer page,
+ @RequestParam(value = "limit", defaultValue = "20") Integer limit) {
+
+ StringBuilder sql = new StringBuilder();
+ sql.append("SELECT a.*, u.nickname, u.avatar, u.phone ");
+ sql.append("FROM eb_streamer_application a ");
+ sql.append("LEFT JOIN eb_user u ON a.user_id = u.uid ");
+ sql.append("WHERE 1=1 ");
+
+ StringBuilder countSql = new StringBuilder();
+ countSql.append("SELECT COUNT(*) FROM eb_streamer_application a WHERE 1=1 ");
+
+ if (status != null) {
+ String condition = " AND a.status = " + status;
+ sql.append(condition);
+ countSql.append(condition);
+ }
+
+ sql.append(" ORDER BY a.create_time DESC ");
+
+ Long total = jdbcTemplate.queryForObject(countSql.toString(), Long.class);
+
+ int offset = (page - 1) * limit;
+ sql.append(" LIMIT ").append(offset).append(", ").append(limit);
+
+ List> list = jdbcTemplate.queryForList(sql.toString());
+
+ // 转换字段名
+ list.forEach(item -> {
+ item.put("userId", item.get("user_id"));
+ item.put("realName", item.get("real_name"));
+ item.put("idCard", item.get("id_card"));
+ item.put("idCardFront", item.get("id_card_front"));
+ item.put("idCardBack", item.get("id_card_back"));
+ item.put("categoryIds", item.get("category_ids"));
+ item.put("rejectReason", item.get("reject_reason"));
+ item.put("reviewerId", item.get("reviewer_id"));
+ item.put("reviewTime", item.get("review_time"));
+ item.put("createTime", item.get("create_time"));
+ });
+
+ CommonPage> result = new CommonPage<>();
+ result.setList(list);
+ result.setTotal(total != null ? total : 0L);
+ result.setPage(page);
+ result.setLimit(limit);
+
+ return CommonResult.success(result);
+ }
+
+ /**
+ * 审核主播认证申请
+ */
+ @ApiOperation(value = "审核认证申请")
+ @PostMapping("/applications/{id}/review")
+ public CommonResult reviewApplication(
+ @PathVariable Long id,
+ @RequestBody Map body) {
+
+ Integer status = (Integer) body.get("status"); // 1-通过 2-拒绝
+ String rejectReason = (String) body.get("rejectReason");
+ Integer reviewerId = (Integer) body.get("reviewerId");
+
+ if (status == null || (status != 1 && status != 2)) {
+ return CommonResult.failed("审核状态错误");
+ }
+ if (status == 2 && (rejectReason == null || rejectReason.trim().isEmpty())) {
+ return CommonResult.failed("请填写拒绝原因");
+ }
+
+ try {
+ // 获取申请信息
+ String querySql = "SELECT user_id, status FROM eb_streamer_application WHERE id = ?";
+ List> apps = jdbcTemplate.queryForList(querySql, id);
+ if (apps.isEmpty()) {
+ return CommonResult.failed("申请不存在");
+ }
+
+ Map app = apps.get(0);
+ Integer currentStatus = ((Number) app.get("status")).intValue();
+ if (currentStatus != 0) {
+ return CommonResult.failed("该申请已审核");
+ }
+
+ Integer userId = ((Number) app.get("user_id")).intValue();
+
+ // 更新申请状态
+ String updateSql = "UPDATE eb_streamer_application SET status = ?, reject_reason = ?, reviewer_id = ?, review_time = NOW() WHERE id = ?";
+ jdbcTemplate.update(updateSql, status, rejectReason, reviewerId, id);
+
+ // 如果通过，更新用户主播状态
+ if (status == 1) {
+ String userSql = "UPDATE eb_user SET is_streamer = 1, streamer_level = 1, streamer_certified_time = NOW() WHERE uid = ?";
+ jdbcTemplate.update(userSql, userId);
+ }
+
+ return CommonResult.success(true);
+ } catch (Exception e) {
+ log.error("审核申请失败", e);
+ return CommonResult.failed("审核失败：" + e.getMessage());
+ }
+ }
+
+ /**
+ * 设置用户为主播（直接认证）
+ */
+ @ApiOperation(value = "设置为主播")
+ @PostMapping("/set/{userId}")
+ public CommonResult setStreamer(
+ @PathVariable Integer userId,
+ @RequestBody Map body) {
+
+ Integer level = body.get("level") != null ? (Integer) body.get("level") : 1;
+ String intro = (String) body.get("intro");
+
+ try {
+ String sql = "UPDATE eb_user SET is_streamer = 1, streamer_level = ?, streamer_intro = ?, streamer_certified_time = NOW() WHERE uid = ?";
+ int rows = jdbcTemplate.update(sql, level, intro, userId);
+
+ if (rows > 0) {
+ return CommonResult.success(true);
+ } else {
+ return CommonResult.failed("用户不存在");
+ }
+ } catch (Exception e) {
+ log.error("设置主播失败", e);
+ return CommonResult.failed("设置失败：" + e.getMessage());
+ }
+ }
+
+ /**
+ * 取消主播资格
+ */
+ @ApiOperation(value = "取消主播资格")
+ @PostMapping("/cancel/{userId}")
+ public CommonResult cancelStreamer(@PathVariable Integer userId) {
+ try {
+ String sql = "UPDATE eb_user SET is_streamer = 0, streamer_level = 0 WHERE uid = ?";
+ int rows = jdbcTemplate.update(sql, userId);
+
+ if (rows > 0) {
+ return CommonResult.success(true);
+ } else {
+ return CommonResult.failed("用户不存在");
+ }
+ } catch (Exception e) {
+ log.error("取消主播资格失败", e);
+ return CommonResult.failed("操作失败：" + e.getMessage());
+ }
+ }
+
+ /**
+ * 封禁主播
+ */
+ @ApiOperation(value = "封禁主播")
+ @PostMapping("/ban/{userId}")
+ public CommonResult banStreamer(
+ @PathVariable Integer userId,
+ @RequestBody Map body) {
+
+ Integer banType = body.get("banType") != null ? (Integer) body.get("banType") : 1; // 1-临时 2-永久
+ String banReason = (String) body.get("banReason");
+ Integer banDays = body.get("banDays") != null ? (Integer) body.get("banDays") : 7;
+ Integer operatorId = (Integer) body.get("operatorId");
+
+ if (banReason == null || banReason.trim().isEmpty()) {
+ return CommonResult.failed("请填写封禁原因");
+ }
+
+ try {
+ String sql;
+ if (banType == 2) {
+ // 永久封禁
+ sql = "INSERT INTO eb_streamer_ban (user_id, ban_type, ban_reason, ban_start_time, operator_id, is_active, create_time) " +
+ "VALUES (?, 2, ?, NOW(), ?, 1, NOW())";
+ jdbcTemplate.update(sql, userId, banReason.trim(), operatorId);
+ } else {
+ // 临时封禁
+ sql = "INSERT INTO eb_streamer_ban (user_id, ban_type, ban_reason, ban_start_time, ban_end_time, operator_id, is_active, create_time) " +
+ "VALUES (?, 1, ?, NOW(), DATE_ADD(NOW(), INTERVAL ? DAY), ?, 1, NOW())";
+ jdbcTemplate.update(sql, userId, banReason.trim(), banDays, operatorId);
+ }
+
+ return CommonResult.success(true);
+ } catch (Exception e) {
+ log.error("封禁主播失败", e);
+ return CommonResult.failed("封禁失败：" + e.getMessage());
+ }
+ }
+
+ /**
+ * 解封主播
+ */
+ @ApiOperation(value = "解封主播")
+ @PostMapping("/unban/{userId}")
+ public CommonResult unbanStreamer(
+ @PathVariable Integer userId,
+ @RequestBody Map body) {
+
+ Integer operatorId = (Integer) body.get("operatorId");
+
+ try {
+ String sql = "UPDATE eb_streamer_ban SET is_active = 0, unban_time = NOW(), unban_operator_id = ? " +
+ "WHERE user_id = ? AND is_active = 1";
+ jdbcTemplate.update(sql, operatorId, userId);
+
+ return CommonResult.success(true);
+ } catch (Exception e) {
+ log.error("解封主播失败", e);
+ return CommonResult.failed("解封失败：" + e.getMessage());
+ }
+ }
+
+ /**
+ * 获取封禁记录
+ */
+ @ApiOperation(value = "封禁记录列表")
+ @GetMapping("/bans")
+ public CommonResult>> getBanList(
+ @RequestParam(value = "userId", required = false) Integer userId,
+ @RequestParam(value = "isActive", required = false) Integer isActive,
+ @RequestParam(value = "page", defaultValue = "1") Integer page,
+ @RequestParam(value = "limit", defaultValue = "20") Integer limit) {
+
+ StringBuilder sql = new StringBuilder();
+ sql.append("SELECT b.*, u.nickname, u.avatar ");
+ sql.append("FROM eb_streamer_ban b ");
+ sql.append("LEFT JOIN eb_user u ON b.user_id = u.uid ");
+ sql.append("WHERE 1=1 ");
+
+ StringBuilder countSql = new StringBuilder();
+ countSql.append("SELECT COUNT(*) FROM eb_streamer_ban b WHERE 1=1 ");
+
+ if (userId != null) {
+ String condition = " AND b.user_id = " + userId;
+ sql.append(condition);
+ countSql.append(condition);
+ }
+ if (isActive != null) {
+ String condition = " AND b.is_active = " + isActive;
+ sql.append(condition);
+ countSql.append(condition);
+ }
+
+ sql.append(" ORDER BY b.create_time DESC ");
+
+ Long total = jdbcTemplate.queryForObject(countSql.toString(), Long.class);
+
+ int offset = (page - 1) * limit;
+ sql.append(" LIMIT ").append(offset).append(", ").append(limit);
+
+ List> list = jdbcTemplate.queryForList(sql.toString());
+
+ // 转换字段名
+ list.forEach(item -> {
+ item.put("userId", item.get("user_id"));
+ item.put("banType", item.get("ban_type"));
+ item.put("banReason", item.get("ban_reason"));
+ item.put("banStartTime", item.get("ban_start_time"));
+ item.put("banEndTime", item.get("ban_end_time"));
+ item.put("operatorId", item.get("operator_id"));
+ item.put("isActive", item.get("is_active"));
+ item.put("unbanTime", item.get("unban_time"));
+ item.put("createTime", item.get("create_time"));
+ });
+
+ CommonPage> result = new CommonPage<>();
+ result.setList(list);
+ result.setTotal(total != null ? total : 0L);
+ result.setPage(page);
+ result.setLimit(limit);
+
+ return CommonResult.success(result);
+ }
+
+ /**
+ * 获取主播详情（包含直播统计）
+ */
+ @ApiOperation(value = "主播详情")
+ @GetMapping("/detail/{userId}")
+ public CommonResult> getStreamerDetail(@PathVariable Integer userId) {
+ try {
+ // 获取主播基本信息
+ String userSql = "SELECT u.uid as userId, u.nickname, u.avatar, u.phone, u.create_time as createTime, " +
+ "u.is_streamer as isStreamer, u.streamer_level as streamerLevel, " +
+ "u.streamer_intro as streamerIntro, u.streamer_certified_time as certifiedTime " +
+ "FROM eb_user u WHERE u.uid = ? AND u.is_streamer = 1";
+ List> users = jdbcTemplate.queryForList(userSql, userId);
+
+ if (users.isEmpty()) {
+ return CommonResult.failed("主播不存在");
+ }
+
+ Map result = new HashMap<>(users.get(0));
+
+ // 获取直播统计数据
+ try {
+ // 直播间总数
+ String roomCountSql = "SELECT COUNT(*) FROM eb_live_room WHERE uid = ?";
+ Long totalRooms = jdbcTemplate.queryForObject(roomCountSql, Long.class, userId);
+ result.put("totalRooms", totalRooms != null ? totalRooms : 0);
+
+ // 本月直播次数
+ String monthRoomsSql = "SELECT COUNT(*) FROM eb_live_room WHERE uid = ? AND DATE_FORMAT(create_time, '%Y-%m') = DATE_FORMAT(NOW(), '%Y-%m')";
+ Long monthRooms = jdbcTemplate.queryForObject(monthRoomsSql, Long.class, userId);
+ result.put("monthRooms", monthRooms != null ? monthRooms : 0);
+
+ // 今日直播次数
+ String todayRoomsSql = "SELECT COUNT(*) FROM eb_live_room WHERE uid = ? AND DATE(create_time) = CURDATE()";
+ Long todayRooms = jdbcTemplate.queryForObject(todayRoomsSql, Long.class, userId);
+ result.put("todayRooms", todayRooms != null ? todayRooms : 0);
+
+ // 最近直播记录
+ String recentRoomsSql = "SELECT id, title, create_time as createTime, is_live as status " +
+ "FROM eb_live_room WHERE uid = ? ORDER BY create_time DESC LIMIT 10";
+ List> recentRooms = jdbcTemplate.queryForList(recentRoomsSql, userId);
+ result.put("recentRooms", recentRooms);
+
+ } catch (Exception e) {
+ log.warn("获取直播统计数据失败", e);
+ result.put("totalRooms", 0);
+ result.put("monthRooms", 0);
+ result.put("todayRooms", 0);
+ result.put("recentRooms", new java.util.ArrayList<>());
+ }
+
+ // 获取封禁状态
+ try {
+ String banSql = "SELECT ban_reason, ban_end_time FROM eb_streamer_ban " +
+ "WHERE user_id = ? AND is_active = 1 AND (ban_end_time IS NULL OR ban_end_time > NOW()) LIMIT 1";
+ List> bans = jdbcTemplate.queryForList(banSql, userId);
+ result.put("isBanned", !bans.isEmpty());
+ if (!bans.isEmpty()) {
+ result.put("banInfo", bans.get(0));
+ }
+ } catch (Exception e) {
+ result.put("isBanned", false);
+ }
+
+ return CommonResult.success(result);
+ } catch (Exception e) {
+ log.error("获取主播详情失败", e);
+ return CommonResult.failed("获取失败：" + e.getMessage());
+ }
+ }
+
+ /**
+ * 主播统计
+ */
+ @ApiOperation(value = "主播统计")
+ @GetMapping("/statistics")
+ public CommonResult> getStatistics() {
+ Map stats = new HashMap<>();
+
+ try {
+ // 主播总数
+ Long totalStreamers = jdbcTemplate.queryForObject(
+ "SELECT COUNT(*) FROM eb_user WHERE is_streamer = 1", Long.class);
+ stats.put("totalStreamers", totalStreamers != null ? totalStreamers : 0);
+
+ // 今日新增主播
+ Long todayStreamers = jdbcTemplate.queryForObject(
+ "SELECT COUNT(*) FROM eb_user WHERE is_streamer = 1 AND DATE(streamer_certified_time) = CURDATE()", Long.class);
+ stats.put("todayStreamers", todayStreamers != null ? todayStreamers : 0);
+
+ // 直播间总数
+ try {
+ Long totalRooms = jdbcTemplate.queryForObject(
+ "SELECT COUNT(*) FROM eb_live_room", Long.class);
+ stats.put("totalRooms", totalRooms != null ? totalRooms : 0);
+ } catch (Exception e) {
+ stats.put("totalRooms", 0);
+ }
+
+ // 正在直播数
+ try {
+ Long liveNow = jdbcTemplate.queryForObject(
+ "SELECT COUNT(*) FROM eb_live_room WHERE is_live = 1", Long.class);
+ stats.put("liveNow", liveNow != null ? liveNow : 0);
+ } catch (Exception e) {
+ stats.put("liveNow", 0);
+ }
+
+ // 待审核申请数
+ Long pendingApplications = jdbcTemplate.queryForObject(
+ "SELECT COUNT(*) FROM eb_streamer_application WHERE status = 0", Long.class);
+ stats.put("pendingApplications", pendingApplications != null ? pendingApplications : 0);
+
+ // 被封禁主播数
+ Long bannedStreamers = jdbcTemplate.queryForObject(
+ "SELECT COUNT(DISTINCT user_id) FROM eb_streamer_ban WHERE is_active = 1 AND (ban_end_time IS NULL OR ban_end_time > NOW())", Long.class);
+ stats.put("bannedStreamers", bannedStreamers != null ? bannedStreamers : 0);
+
+ } catch (Exception e) {
+ log.error("获取主播统计失败", e);
+ }
+
+ return CommonResult.success(stats);
+ }
+}
diff --git a/Zhibo/zhibo-h/crmeb-front/src/main/java/com/zbkj/front/controller/GroupController.java b/Zhibo/zhibo-h/crmeb-front/src/main/java/com/zbkj/front/controller/GroupController.java
new file mode 100644
index 00000000..e5e50bfb
--- /dev/null
+++ b/Zhibo/zhibo-h/crmeb-front/src/main/java/com/zbkj/front/controller/GroupController.java
@@ -0,0 +1,671 @@
+package com.zbkj.front.controller;
+
+import com.zbkj.common.page.CommonPage;
+import com.zbkj.common.result.CommonResult;
+import com.zbkj.service.service.UserService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.*;
+
+/**
+ * 群组管理控制器
+ */
+@Slf4j
+@RestController
+@RequestMapping("api/front/groups")
+@Api(tags = "群组管理")
+@Validated
+public class GroupController {
+
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+
+ @Autowired
+ private UserService userService;
+
+ /**
+ * 获取群组列表（我加入的群组）
+ */
+ @ApiOperation(value = "获取群组列表")
+ @GetMapping("/list")
+ public CommonResult>> getGroupList(
+ @RequestParam(value = "page", defaultValue = "1") Integer page,
+ @RequestParam(value = "pageSize", defaultValue = "20") Integer pageSize) {
+
+ Integer userId = userService.getUserId();
+ if (userId == null || userId <= 0) {
+ return CommonResult.failed("请先登录");
+ }
+
+ try {
+ int offset = (page - 1) * pageSize;
+
+ // 查询用户加入的群组
+ String sql = "SELECT g.id, g.group_name as name, g.avatar as avatarUrl, g.description, " +
+ "g.member_count as memberCount, g.owner_id as ownerId, " +
+ "gm.role, g.create_time as createTime " +
+ "FROM eb_group g " +
+ "INNER JOIN eb_group_member gm ON g.id = gm.group_id " +
+ "WHERE gm.user_id = ? AND gm.is_deleted = 0 AND g.is_deleted = 0 " +
+ "ORDER BY g.update_time DESC " +
+ "LIMIT ?, ?";
+
+ List> list = jdbcTemplate.queryForList(sql, userId, offset, pageSize);
+
+ // 处理返回数据
+ for (Map item : list) {
+ Integer ownerId = (Integer) item.get("ownerId");
+ Integer role = item.get("role") != null ? ((Number) item.get("role")).intValue() : 0;
+ item.put("isOwner", userId.equals(ownerId));
+ item.put("isAdmin", role >= 1); // role: 0-普通成员, 1-管理员, 2-群主
+ }
+
+ // 统计总数
+ String countSql = "SELECT COUNT(*) FROM eb_group g " +
+ "INNER JOIN eb_group_member gm ON g.id = gm.group_id " +
+ "WHERE gm.user_id = ? AND gm.is_deleted = 0 AND g.is_deleted = 0";
+ Long total = jdbcTemplate.queryForObject(countSql, Long.class, userId);
+
+ CommonPage> result = new CommonPage<>();
+ result.setList(list);
+ result.setTotal(total != null ? total : 0L);
+ result.setPage(page);
+ result.setLimit(pageSize);
+ result.setTotalPage((int) Math.ceil((double) (total != null ? total : 0) / pageSize));
+
+ return CommonResult.success(result);
+ } catch (Exception e) {
+ log.error("获取群组列表失败", e);
+ return CommonResult.failed("获取群组列表失败");
+ }
+ }
+
+ /**
+ * 创建群组
+ */
+ @ApiOperation(value = "创建群组")
+ @PostMapping("/create")
+ public CommonResult> createGroup(@RequestBody Map body) {
+ Integer userId = userService.getUserId();
+ if (userId == null || userId <= 0) {
+ return CommonResult.failed("请先登录");
+ }
+
+ try {
+ String name = (String) body.get("name");
+ String description = (String) body.get("description");
+ String avatar = (String) body.get("avatar");
+
+ if (name == null || name.trim().isEmpty()) {
+ return CommonResult.failed("群组名称不能为空");
+ }
+
+ // 创建群组
+ String insertSql = "INSERT INTO eb_group (group_name, description, avatar, owner_id, member_count, create_time, update_time) " +
+ "VALUES (?, ?, ?, ?, 1, NOW(), NOW())";
+ jdbcTemplate.update(insertSql, name.trim(), description, avatar, userId);
+
+ // 获取新创建的群组ID
+ Long groupId = jdbcTemplate.queryForObject("SELECT LAST_INSERT_ID()", Long.class);
+
+ // 添加创建者为群主
+ String memberSql = "INSERT INTO eb_group_member (group_id, user_id, role, join_time, update_time) " +
+ "VALUES (?, ?, 2, NOW(), NOW())";
+ jdbcTemplate.update(memberSql, groupId, userId);
+
+ Map result = new HashMap<>();
+ result.put("id", groupId);
+ result.put("name", name.trim());
+ result.put("description", description);
+ result.put("avatar", avatar);
+ result.put("memberCount", 1);
+ result.put("isOwner", true);
+ result.put("isAdmin", true);
+
+ return CommonResult.success(result);
+ } catch (Exception e) {
+ log.error("创建群组失败", e);
+ return CommonResult.failed("创建群组失败");
+ }
+ }
+
+ /**
+ * 获取群组详情
+ */
+ @ApiOperation(value = "获取群组详情")
+ @GetMapping("/{groupId}")
+ public CommonResult> getGroupDetail(@PathVariable Long groupId) {
+ Integer userId = userService.getUserId();
+
+ try {
+ String sql = "SELECT g.*, gm.role FROM eb_group g " +
+ "LEFT JOIN eb_group_member gm ON g.id = gm.group_id AND gm.user_id = ? AND gm.is_deleted = 0 " +
+ "WHERE g.id = ? AND g.is_deleted = 0";
+
+ List> list = jdbcTemplate.queryForList(sql, userId, groupId);
+ if (list.isEmpty()) {
+ return CommonResult.failed("群组不存在");
+ }
+
+ Map group = list.get(0);
+ Integer ownerId = (Integer) group.get("owner_id");
+ Integer role = group.get("role") != null ? ((Number) group.get("role")).intValue() : -1;
+
+ Map result = new HashMap<>();
+ result.put("id", group.get("id"));
+ result.put("name", group.get("group_name"));
+ result.put("avatarUrl", group.get("avatar"));
+ result.put("description", group.get("description"));
+ result.put("announcement", group.get("announcement"));
+ result.put("memberCount", group.get("member_count"));
+ result.put("maxMembers", group.get("max_members"));
+ result.put("ownerId", ownerId);
+ result.put("isOwner", userId != null && userId.equals(ownerId));
+ result.put("isAdmin", role >= 1);
+ result.put("isMember", role >= 0);
+ result.put("muteAll", group.get("mute_all"));
+ result.put("allowMemberInvite", group.get("allow_member_invite"));
+ result.put("createTime", group.get("create_time"));
+
+ return CommonResult.success(result);
+ } catch (Exception e) {
+ log.error("获取群组详情失败", e);
+ return CommonResult.failed("获取群组详情失败");
+ }
+ }
+
+ /**
+ * 更新群组信息
+ */
+ @ApiOperation(value = "更新群组信息")
+ @PutMapping("/{groupId}")
+ public CommonResult> updateGroup(
+ @PathVariable Long groupId,
+ @RequestBody Map body) {
+
+ Integer userId = userService.getUserId();
+ if (userId == null || userId <= 0) {
+ return CommonResult.failed("请先登录");
+ }
+
+ try {
+ // 检查权限
+ String checkSql = "SELECT role FROM eb_group_member WHERE group_id = ? AND user_id = ? AND is_deleted = 0";
+ List> members = jdbcTemplate.queryForList(checkSql, groupId, userId);
+ if (members.isEmpty()) {
+ return CommonResult.failed("您不是群成员");
+ }
+ Integer role = ((Number) members.get(0).get("role")).intValue();
+ if (role < 1) {
+ return CommonResult.failed("您没有权限修改群组信息");
+ }
+
+ // 更新群组信息
+ StringBuilder updateSql = new StringBuilder("UPDATE eb_group SET update_time = NOW()");
+ List