客服可以给会话设置个人备注, 设置 快捷回复

建群自动话术

backend/internal/model/chat.go

@@ -29,6 +29,7 @@ type ChatParticipant struct {
 	ParticipantType string     `gorm:"size:16;not null;index" json:"participant_type"`
 	ParticipantID   uint64     `gorm:"not null;index" json:"participant_id"`
 	Role            string     `gorm:"size:32;not null" json:"role"`
+	Remark          string     `gorm:"size:128;not null;default:''" json:"remark"`
 	LastReadAt      *time.Time `json:"last_read_at"`
 	JoinedAt        time.Time  `json:"joined_at"`
 	CreatedAt       time.Time  `json:"created_at"`

backend/internal/model/chat_quick_reply.go

@@ -0,0 +1,17 @@
+package model
+
+import "time"
+
+type ChatQuickReply struct {
+	ID          uint64    `gorm:"primaryKey;autoIncrement" json:"id"`
+	AdminUserID uint64    `gorm:"not null;default:0;index" json:"admin_user_id"` // 0=全局, >0=个人
+	Title       string    `gorm:"size:64;not null" json:"title"`
+	Content     string    `gorm:"type:text;not null" json:"content"`
+	SortOrder   int       `gorm:"not null;default:0" json:"sort_order"`
+	CreatedAt   time.Time `gorm:"not null;default:CURRENT_TIMESTAMP" json:"created_at"`
+	UpdatedAt   time.Time `gorm:"not null;default:CURRENT_TIMESTAMP" json:"updated_at"`
+}
+
+func (ChatQuickReply) TableName() string {
+	return "chat_quick_replies"
+}

backend/internal/modules/chat/dto.go

@@ -29,6 +29,7 @@ type ParticipantDTO struct {
 	ParticipantType string     `json:"participant_type"`
 	ParticipantID   uint64     `json:"participant_id"`
 	Role            string     `json:"role"`
+	Remark          string     `json:"remark"`
 	DisplayName     string     `json:"display_name"`
 	AvatarURL       string     `json:"avatar_url"`
 	LastReadAt      *time.Time `json:"last_read_at"`
@@ -54,6 +55,41 @@ type SendMessageRequest struct {
 	Content string `json:"content" binding:"required"`
 }
 
+type TransferRequest struct {
+	ToAdminID uint64 `json:"to_admin_id" binding:"required"`
+}
+
+type UpdateRemarkRequest struct {
+	Remark string `json:"remark"`
+}
+
+type SupportAdminDTO struct {
+	ID        uint64 `json:"id"`
+	Nickname  string `json:"nickname"`
+	ChatCount int64  `json:"chat_count"`
+}
+
+type QuickReplyDTO struct {
+	ID          uint64 `json:"id"`
+	AdminUserID uint64 `json:"admin_user_id"`
+	Title       string `json:"title"`
+	Content     string `json:"content"`
+	SortOrder   int    `json:"sort_order"`
+	IsGlobal    bool   `json:"is_global"`
+}
+
+type CreateQuickReplyRequest struct {
+	Title     string `json:"title" binding:"required"`
+	Content   string `json:"content" binding:"required"`
+	SortOrder int    `json:"sort_order"`
+}
+
+type UpdateQuickReplyRequest struct {
+	Title     string `json:"title"`
+	Content   string `json:"content"`
+	SortOrder *int   `json:"sort_order"`
+}
+
 type PaginatedResult struct {
 	Items    interface{} `json:"items"`
 	Total    int64       `json:"total"`

backend/internal/modules/chat/handler.go

@@ -34,7 +34,15 @@ func (h *Handler) AdminList(c *gin.Context) {
 		response.Unauthorized(c, "缺少管理员上下文")
 		return
 	}
-	h.list(c, Principal{Type: "admin", ID: adminID})
+	filter := c.DefaultQuery("filter", "all")
+	page, pageSize := parsePagination(c)
+	principal := Principal{Type: "admin", ID: adminID}
+	result, err := h.service.ListConversationsWithFilter(principal, page, pageSize, filter)
+	if err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.OK(c, result)
 }
 
 func (h *Handler) Detail(c *gin.Context) {
@@ -127,6 +135,153 @@ func (h *Handler) AdminMarkRead(c *gin.Context) {
 	h.markRead(c, Principal{Type: "admin", ID: adminID})
 }
 
+func (h *Handler) AdminTransfer(c *gin.Context) {
+	adminID, ok := currentAdminID(c)
+	if !ok {
+		response.Unauthorized(c, "缺少管理员上下文")
+		return
+	}
+	id, ok := parseID(c, "id")
+	if !ok {
+		return
+	}
+	var req TransferRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		response.BadRequest(c, "目标客服 ID 不能为空")
+		return
+	}
+	principal := Principal{Type: "admin", ID: adminID}
+	if err := h.service.TransferConversation(principal, id, req); err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.OK(c, gin.H{"transferred": true})
+}
+
+func (h *Handler) AdminSupportAdmins(c *gin.Context) {
+	admins, err := h.service.GetAvailableSupportAdmins()
+	if err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.OK(c, admins)
+}
+
+func (h *Handler) AdminUpdateRemark(c *gin.Context) {
+	adminID, ok := currentAdminID(c)
+	if !ok {
+		response.Unauthorized(c, "缺少管理员上下文")
+		return
+	}
+	id, ok := parseID(c, "id")
+	if !ok {
+		return
+	}
+	var req UpdateRemarkRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		response.BadRequest(c, "请求参数错误")
+		return
+	}
+	principal := Principal{Type: "admin", ID: adminID}
+	if err := h.service.UpdateRemark(principal, id, req); err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.OK(c, gin.H{"updated": true})
+}
+
+func (h *Handler) AdminListQuickReplies(c *gin.Context) {
+	adminID, ok := currentAdminID(c)
+	if !ok {
+		response.Unauthorized(c, "缺少管理员上下文")
+		return
+	}
+	replies, err := h.service.ListQuickReplies(adminID)
+	if err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.OK(c, replies)
+}
+
+func (h *Handler) AdminCreateQuickReply(c *gin.Context) {
+	adminID, ok := currentAdminID(c)
+	if !ok {
+		response.Unauthorized(c, "缺少管理员上下文")
+		return
+	}
+	var req CreateQuickReplyRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		response.BadRequest(c, "标题和内容不能为空")
+		return
+	}
+	reply, err := h.service.CreateQuickReply(adminID, req)
+	if err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.Created(c, reply)
+}
+
+func (h *Handler) AdminUpdateQuickReply(c *gin.Context) {
+	adminID, ok := currentAdminID(c)
+	if !ok {
+		response.Unauthorized(c, "缺少管理员上下文")
+		return
+	}
+	id, ok := parseID(c, "id")
+	if !ok {
+		return
+	}
+	var req UpdateQuickReplyRequest
+	if err := c.ShouldBindJSON(&req); err != nil {
+		response.BadRequest(c, "请求参数错误")
+		return
+	}
+	if err := h.service.UpdateQuickReply(adminID, id, req); err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.OK(c, gin.H{"updated": true})
+}
+
+func (h *Handler) AdminDeleteQuickReply(c *gin.Context) {
+	adminID, ok := currentAdminID(c)
+	if !ok {
+		response.Unauthorized(c, "缺少管理员上下文")
+		return
+	}
+	id, ok := parseID(c, "id")
+	if !ok {
+		return
+	}
+	if err := h.service.DeleteQuickReply(adminID, id); err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.OK(c, gin.H{"deleted": true})
+}
+
+func (h *Handler) AdminGetAutoWelcome(c *gin.Context) {
+	message := h.service.GetAutoWelcomeMessage()
+	response.OK(c, gin.H{"message": message})
+}
+
+func (h *Handler) AdminUpdateAutoWelcome(c *gin.Context) {
+	var req struct {
+		Message string `json:"message" binding:"required"`
+	}
+	if err := c.ShouldBindJSON(&req); err != nil {
+		response.BadRequest(c, "话术内容不能为空")
+		return
+	}
+	if err := h.service.UpdateAutoWelcomeMessage(req.Message); err != nil {
+		writeChatError(c, err)
+		return
+	}
+	response.OK(c, gin.H{"updated": true})
+}
+
 func (h *Handler) list(c *gin.Context, principal Principal) {
 	page, pageSize := parsePagination(c)
 	result, err := h.service.ListConversations(principal, page, pageSize)

backend/internal/modules/chat/repository.go

@@ -83,12 +83,18 @@ func EnsureOrderConversation(tx *gorm.DB, order model.RentalOrder) (*model.ChatC
 		}
 	}
 
+	// 获取自动话术
+	autoMessage := "订单已支付，群聊已创建。租客、号主和客服可在这里沟通交接与结账问题。"
+	var cfg model.SystemConfig
+	if err := tx.Where("`key` = ?", "chat.auto_welcome_message").First(&cfg).Error; err == nil && cfg.Value != "" {
+		autoMessage = cfg.Value
+	}
 	message := model.ChatMessage{
 		ConversationID: conversation.ID,
 		SenderType:     "system",
 		SenderRole:     "system",
 		ContentType:    "system",
-		Content:        "订单已支付，群聊已创建。租客、号主和客服可在这里沟通交接与结账问题。",
+		Content:        autoMessage,
 		AttachmentURLS: emptyJSONList(),
 	}
 	if err := tx.Create(&message).Error; err != nil {
@@ -499,6 +505,54 @@ func (row conversationRow) toDTO(participants []ParticipantDTO) ConversationDTO
 }
 
 func defaultSupportAdminID(tx *gorm.DB) uint64 {
+	// 查询所有有 chat:view 权限且状态为 active 的管理员
+	var adminIDs []uint64
+	err := tx.Table("admin_users AS au").
+		Joins("JOIN admin_user_roles AS aur ON aur.admin_user_id = au.id").
+		Joins("JOIN role_permissions AS rp ON rp.role_id = aur.role_id").
+		Joins("JOIN permissions AS p ON p.id = rp.permission_id").
+		Where("au.status = ? AND p.code = ?", "active", "chat:view").
+		Distinct("au.id").
+		Pluck("au.id", &adminIDs).Error
+	if err != nil || len(adminIDs) == 0 {
+		// 回退到原有逻辑
+		return fallbackSupportAdminID(tx)
+	}
+
+	// 统计每个客服当前负责的会话数，选择负载最少的
+	type adminLoad struct {
+		AdminID uint64
+		Count   int64
+	}
+	var loads []adminLoad
+	tx.Table("chat_participants AS cp").
+		Select("cp.participant_id AS admin_id, COUNT(*) AS count").
+		Where("cp.participant_type = ? AND cp.role = ? AND cp.participant_id IN ?", "admin", "support", adminIDs).
+		Group("cp.participant_id").
+		Scan(&loads)
+
+	loadMap := make(map[uint64]int64)
+	for _, l := range loads {
+		loadMap[l.AdminID] = l.Count
+	}
+
+	// 找到负载最少的客服
+	var minLoad int64 = -1
+	var selectedID uint64
+	for _, id := range adminIDs {
+		count := loadMap[id]
+		if minLoad < 0 || count < minLoad {
+			minLoad = count
+			selectedID = id
+		}
+	}
+	if selectedID > 0 {
+		return selectedID
+	}
+	return fallbackSupportAdminID(tx)
+}
+
+func fallbackSupportAdminID(tx *gorm.DB) uint64 {
 	var cfg model.SystemConfig
 	if err := tx.Where("`key` = ?", "chat.default_support_admin_id").First(&cfg).Error; err == nil {
 		id, parseErr := strconv.ParseUint(cfg.Value, 10, 64)
@@ -570,6 +624,175 @@ func truncatePreview(content string) string {
 	return string(runes[:80])
 }
 
+// TransferConversation 转接会话给其他客服
+func (r *Repository) TransferConversation(principal Principal, conversationID uint64, toAdminID uint64) error {
+	return r.db.Transaction(func(tx *gorm.DB) error {
+		// 验证当前操作者是会话参与者
+		if _, err := r.findParticipant(tx, principal, conversationID, false); err != nil {
+			return err
+		}
+		// 验证目标客服存在且活跃
+		if !adminActive(tx, toAdminID) {
+			return fmt.Errorf("目标客服不存在或已禁用")
+		}
+		// 检查目标客服是否已有该会话
+		var count int64
+		if err := tx.Model(&model.ChatParticipant{}).
+			Where("conversation_id = ? AND participant_type = ? AND participant_id = ?", conversationID, "admin", toAdminID).
+			Count(&count).Error; err != nil {
+			return err
+		}
+		if count > 0 {
+			return fmt.Errorf("该客服已在会话中")
+		}
+		// 删除原客服参与者
+		if err := tx.Where("conversation_id = ? AND participant_type = ? AND role = ?", conversationID, "admin", "support").
+			Delete(&model.ChatParticipant{}).Error; err != nil {
+			return err
+		}
+		// 添加新客服参与者
+		participant := model.ChatParticipant{
+			ConversationID:  conversationID,
+			ParticipantType: "admin",
+			ParticipantID:   toAdminID,
+			Role:            "support",
+			JoinedAt:        time.Now(),
+		}
+		if err := tx.Create(&participant).Error; err != nil {
+			return err
+		}
+		// 添加系统消息记录转接
+		message := model.ChatMessage{
+			ConversationID: conversationID,
+			SenderType:     "system",
+			SenderRole:     "system",
+			ContentType:    "system",
+			Content:        "会话已转接给其他客服",
+			AttachmentURLS: emptyJSONList(),
+		}
+		if err := tx.Create(&message).Error; err != nil {
+			return err
+		}
+		return nil
+	})
+}
+
+// GetAvailableSupportAdmins 获取可用客服列表及其会话数
+func (r *Repository) GetAvailableSupportAdmins() ([]SupportAdminDTO, error) {
+	// 查询所有有 chat:view 权限且状态为 active 的管理员
+	type adminRow struct {
+		ID       uint64
+		Nickname string
+	}
+	var admins []adminRow
+	err := r.db.Table("admin_users AS au").
+		Select("au.id, au.nickname").
+		Joins("JOIN admin_user_roles AS aur ON aur.admin_user_id = au.id").
+		Joins("JOIN role_permissions AS rp ON rp.role_id = aur.role_id").
+		Joins("JOIN permissions AS p ON p.id = rp.permission_id").
+		Where("au.status = ? AND p.code = ?", "active", "chat:view").
+		Distinct("au.id").
+		Scan(&admins).Error
+	if err != nil {
+		return nil, err
+	}
+
+	// 统计每个客服的会话数
+	type loadRow struct {
+		AdminID uint64
+		Count   int64
+	}
+	var loads []loadRow
+	adminIDs := make([]uint64, len(admins))
+	for i, a := range admins {
+		adminIDs[i] = a.ID
+	}
+	if len(adminIDs) > 0 {
+		r.db.Table("chat_participants").
+			Select("participant_id AS admin_id, COUNT(*) AS count").
+			Where("participant_type = ? AND role = ? AND participant_id IN ?", "admin", "support", adminIDs).
+			Group("participant_id").
+			Scan(&loads)
+	}
+	loadMap := make(map[uint64]int64)
+	for _, l := range loads {
+		loadMap[l.AdminID] = l.Count
+	}
+
+	result := make([]SupportAdminDTO, len(admins))
+	for i, a := range admins {
+		result[i] = SupportAdminDTO{
+			ID:           a.ID,
+			Nickname:     a.Nickname,
+			ChatCount:    loadMap[a.ID],
+		}
+	}
+	return result, nil
+}
+
+// ListConversationsWithFilter 支持筛选的会话列表
+func (r *Repository) ListConversationsWithFilter(principal Principal, page, pageSize int, filter string) (*PaginatedResult, error) {
+	page, pageSize = normalizePagination(page, pageSize)
+	var total int64
+
+	countDB := r.db.Table("chat_conversations AS c").
+		Joins("JOIN chat_participants AS cp ON cp.conversation_id = c.id")
+
+	switch filter {
+	case "mine":
+		// 只看我的会话
+		countDB = countDB.Where("cp.participant_type = ? AND cp.participant_id = ?", principal.Type, principal.ID)
+	case "unassigned":
+		// 未分配客服的会话
+		countDB = countDB.Where("c.id NOT IN (?)",
+			r.db.Table("chat_participants").Select("conversation_id").Where("participant_type = ? AND role = ?", "admin", "support"))
+	default:
+		// 全部会话（admin 可以看所有）
+		if principal.Type == "admin" {
+			// 管理员看所有会话
+		} else {
+			countDB = countDB.Where("cp.participant_type = ? AND cp.participant_id = ?", principal.Type, principal.ID)
+		}
+	}
+
+	if err := countDB.Count(&total).Error; err != nil {
+		return nil, err
+	}
+
+	var rows []conversationRow
+	offset := (page - 1) * pageSize
+
+	queryDB := r.conversationQuery(principal)
+	switch filter {
+	case "mine":
+		queryDB = queryDB.Where("cp.participant_type = ? AND cp.participant_id = ?", principal.Type, principal.ID)
+	case "unassigned":
+		queryDB = queryDB.Where("c.id NOT IN (?)",
+			r.db.Table("chat_participants").Select("conversation_id").Where("participant_type = ? AND role = ?", "admin", "support"))
+	default:
+		if principal.Type == "admin" {
+			// 管理员看所有会话
+		} else {
+			queryDB = queryDB.Where("cp.participant_type = ? AND cp.participant_id = ?", principal.Type, principal.ID)
+		}
+	}
+
+	err := queryDB.
+		Order("COALESCE(c.last_message_at, c.created_at) DESC, c.id DESC").
+		Offset(offset).
+		Limit(pageSize).
+		Scan(&rows).Error
+	if err != nil {
+		return nil, err
+	}
+
+	items := make([]ConversationDTO, 0, len(rows))
+	for _, row := range rows {
+		items = append(items, row.toDTO(nil))
+	}
+	return &PaginatedResult{Items: items, Total: total, Page: page, PageSize: pageSize}, nil
+}
+
 func fallbackName(participantType string, id uint64, name string) string {
 	if name != "" {
 		return name
@@ -602,6 +825,98 @@ func emptyJSONList() datatypes.JSON {
 	return datatypes.JSON(raw)
 }
 
+// UpdateRemark 更新会话备注
+func (r *Repository) UpdateRemark(principal Principal, conversationID uint64, remark string) error {
+	return r.db.Model(&model.ChatParticipant{}).
+		Where("conversation_id = ? AND participant_type = ? AND participant_id = ?", conversationID, principal.Type, principal.ID).
+		Update("remark", remark).Error
+}
+
+// ListQuickReplies 获取快捷回复列表（个人 + 全局）
+func (r *Repository) ListQuickReplies(adminID uint64) ([]QuickReplyDTO, error) {
+	var replies []model.ChatQuickReply
+	err := r.db.Where("admin_user_id = ? OR admin_user_id = 0", adminID).
+		Order("admin_user_id DESC, sort_order ASC, id ASC").
+		Find(&replies).Error
+	if err != nil {
+		return nil, err
+	}
+	result := make([]QuickReplyDTO, len(replies))
+	for i, reply := range replies {
+		result[i] = QuickReplyDTO{
+			ID:          reply.ID,
+			AdminUserID: reply.AdminUserID,
+			Title:       reply.Title,
+			Content:     reply.Content,
+			SortOrder:   reply.SortOrder,
+			IsGlobal:    reply.AdminUserID == 0,
+		}
+	}
+	return result, nil
+}
+
+// CreateQuickReply 创建快捷回复
+func (r *Repository) CreateQuickReply(adminID uint64, req CreateQuickReplyRequest) (*QuickReplyDTO, error) {
+	reply := model.ChatQuickReply{
+		AdminUserID: adminID,
+		Title:       req.Title,
+		Content:     req.Content,
+		SortOrder:   req.SortOrder,
+	}
+	if err := r.db.Create(&reply).Error; err != nil {
+		return nil, err
+	}
+	return &QuickReplyDTO{
+		ID:          reply.ID,
+		AdminUserID: reply.AdminUserID,
+		Title:       reply.Title,
+		Content:     reply.Content,
+		SortOrder:   reply.SortOrder,
+		IsGlobal:    false,
+	}, nil
+}
+
+// UpdateQuickReply 更新快捷回复
+func (r *Repository) UpdateQuickReply(adminID uint64, replyID uint64, req UpdateQuickReplyRequest) error {
+	query := r.db.Model(&model.ChatQuickReply{}).Where("id = ? AND (admin_user_id = ? OR admin_user_id = 0)", replyID, adminID)
+	updates := map[string]interface{}{}
+	if req.Title != "" {
+		updates["title"] = req.Title
+	}
+	if req.Content != "" {
+		updates["content"] = req.Content
+	}
+	if req.SortOrder != nil {
+		updates["sort_order"] = *req.SortOrder
+	}
+	if len(updates) == 0 {
+		return nil
+	}
+	return query.Updates(updates).Error
+}
+
+// DeleteQuickReply 删除快捷回复
+func (r *Repository) DeleteQuickReply(adminID uint64, replyID uint64) error {
+	return r.db.Where("id = ? AND admin_user_id = ?", replyID, adminID).
+		Delete(&model.ChatQuickReply{}).Error
+}
+
+// GetAutoWelcomeMessage 获取建群自动话术
+func (r *Repository) GetAutoWelcomeMessage() string {
+	var cfg model.SystemConfig
+	if err := r.db.Where("`key` = ?", "chat.auto_welcome_message").First(&cfg).Error; err != nil {
+		return "欢迎加入订单群聊！如有任何问题，请随时沟通。"
+	}
+	return cfg.Value
+}
+
+// UpdateAutoWelcomeMessage 更新建群自动话术
+func (r *Repository) UpdateAutoWelcomeMessage(message string) error {
+	return r.db.Model(&model.SystemConfig{}).
+		Where("`key` = ?", "chat.auto_welcome_message").
+		Update("value", message).Error
+}
+
 func decodeStringList(raw datatypes.JSON) []string {
 	if len(raw) == 0 {
 		return []string{}

backend/internal/modules/chat/service.go

@@ -68,3 +68,79 @@ func (s *Service) MarkRead(principal Principal, conversationID uint64) error {
 	}
 	return s.repo.MarkRead(principal, conversationID)
 }
+
+func (s *Service) TransferConversation(principal Principal, conversationID uint64, req TransferRequest) error {
+	if s.repo == nil {
+		return ErrDependencyUnavailable
+	}
+	if conversationID == 0 || req.ToAdminID == 0 {
+		return ErrInvalidMessage
+	}
+	return s.repo.TransferConversation(principal, conversationID, req.ToAdminID)
+}
+
+func (s *Service) GetAvailableSupportAdmins() ([]SupportAdminDTO, error) {
+	if s.repo == nil {
+		return nil, ErrDependencyUnavailable
+	}
+	return s.repo.GetAvailableSupportAdmins()
+}
+
+func (s *Service) ListConversationsWithFilter(principal Principal, page, pageSize int, filter string) (*PaginatedResult, error) {
+	if s.repo == nil {
+		return nil, ErrDependencyUnavailable
+	}
+	return s.repo.ListConversationsWithFilter(principal, page, pageSize, filter)
+}
+
+func (s *Service) UpdateRemark(principal Principal, conversationID uint64, req UpdateRemarkRequest) error {
+	if s.repo == nil {
+		return ErrDependencyUnavailable
+	}
+	return s.repo.UpdateRemark(principal, conversationID, req.Remark)
+}
+
+func (s *Service) ListQuickReplies(adminID uint64) ([]QuickReplyDTO, error) {
+	if s.repo == nil {
+		return nil, ErrDependencyUnavailable
+	}
+	return s.repo.ListQuickReplies(adminID)
+}
+
+func (s *Service) CreateQuickReply(adminID uint64, req CreateQuickReplyRequest) (*QuickReplyDTO, error) {
+	if s.repo == nil {
+		return nil, ErrDependencyUnavailable
+	}
+	if req.Title == "" || req.Content == "" {
+		return nil, ErrInvalidMessage
+	}
+	return s.repo.CreateQuickReply(adminID, req)
+}
+
+func (s *Service) UpdateQuickReply(adminID uint64, replyID uint64, req UpdateQuickReplyRequest) error {
+	if s.repo == nil {
+		return ErrDependencyUnavailable
+	}
+	return s.repo.UpdateQuickReply(adminID, replyID, req)
+}
+
+func (s *Service) DeleteQuickReply(adminID uint64, replyID uint64) error {
+	if s.repo == nil {
+		return ErrDependencyUnavailable
+	}
+	return s.repo.DeleteQuickReply(adminID, replyID)
+}
+
+func (s *Service) GetAutoWelcomeMessage() string {
+	if s.repo == nil {
+		return ""
+	}
+	return s.repo.GetAutoWelcomeMessage()
+}
+
+func (s *Service) UpdateAutoWelcomeMessage(message string) error {
+	if s.repo == nil {
+		return ErrDependencyUnavailable
+	}
+	return s.repo.UpdateAutoWelcomeMessage(message)
+}

backend/internal/router/router.go

@@ -303,6 +303,15 @@ func New(cfg config.Config, deps Dependencies, logger *zap.Logger) *gin.Engine {
 			adminRoutes.GET("/chats/:id/messages", requirePerm("chat:view"), chatHandler.AdminMessages)
 			adminRoutes.POST("/chats/:id/messages", requirePerm("chat:send"), chatHandler.AdminSend)
 			adminRoutes.POST("/chats/:id/read", requirePerm("chat:view"), chatHandler.AdminMarkRead)
+			adminRoutes.POST("/chats/:id/transfer", requirePerm("chat:send"), chatHandler.AdminTransfer)
+			adminRoutes.GET("/chats/support-admins", requirePerm("chat:view"), chatHandler.AdminSupportAdmins)
+			adminRoutes.PUT("/chats/:id/remark", requirePerm("chat:send"), chatHandler.AdminUpdateRemark)
+			adminRoutes.GET("/chats/quick-replies", requirePerm("chat:view"), chatHandler.AdminListQuickReplies)
+			adminRoutes.POST("/chats/quick-replies", requirePerm("chat:send"), chatHandler.AdminCreateQuickReply)
+			adminRoutes.PUT("/chats/quick-replies/:id", requirePerm("chat:send"), chatHandler.AdminUpdateQuickReply)
+			adminRoutes.DELETE("/chats/quick-replies/:id", requirePerm("chat:send"), chatHandler.AdminDeleteQuickReply)
+			adminRoutes.GET("/chats/auto-welcome", requirePerm("system_config:view"), chatHandler.AdminGetAutoWelcome)
+			adminRoutes.PUT("/chats/auto-welcome", requirePerm("system_config:update"), chatHandler.AdminUpdateAutoWelcome)
 
 			// 角色管理
 			adminRoutes.GET("/roles", requirePerm("role:manage"), adminRoleHandler.List)