yml2213
8b9f3d710f
- handler 只保留请求绑定、权限检查与响应映射；业务校验顺序、状态码与文案逐字保留 - 新增 service.Error 语义错误，由 handler 统一映射 HTTP 响应 - session 875→361 行、widget 745→321 行、settings 540→73 行 - 自动分配/租户设置(工作时间、欢迎语)/消息校验/黑名单检查/联系方式提取随迁 service 包 - 相关单元测试随迁 service 包，go test ./... 全部通过
58 lines
1.6 KiB
Go
58 lines
1.6 KiB
Go
package service
|
|
|
|
import (
|
|
"errors"
|
|
"strings"
|
|
"unicode/utf8"
|
|
|
|
"kefu-cloud/server/internal/storage"
|
|
)
|
|
|
|
const (
|
|
maxTextMessageLength = 2000
|
|
)
|
|
|
|
// imagePublicBase 由 SetupRoutes 注入，用于校验图片消息 URL 归属
|
|
var imagePublicBase string
|
|
|
|
// SetImagePublicBase 设置允许的图片存储公开前缀。
|
|
func SetImagePublicBase(base string) {
|
|
imagePublicBase = storage.NormalizePublicBase(base)
|
|
}
|
|
|
|
// ValidateMessageContent 校验消息内容；文本去空白，图片校验存储白名单。
|
|
func ValidateMessageContent(messageType, content string) (string, error) {
|
|
switch messageType {
|
|
case "text":
|
|
content = strings.TrimSpace(content)
|
|
if content == "" {
|
|
return "", errors.New("消息内容不能为空")
|
|
}
|
|
if utf8.RuneCountInString(content) > maxTextMessageLength {
|
|
return "", errors.New("单条文本消息不能超过 2000 字")
|
|
}
|
|
return content, nil
|
|
case "image":
|
|
content = strings.TrimSpace(content)
|
|
if content == "" {
|
|
return "", errors.New("图片地址不能为空")
|
|
}
|
|
// 开发阶段直接切换为对象存储 URL，不再接受 base64
|
|
if strings.HasPrefix(content, "data:") {
|
|
return "", errors.New("请先上传图片，勿直接发送 base64")
|
|
}
|
|
if !strings.HasPrefix(content, "http://") && !strings.HasPrefix(content, "https://") {
|
|
return "", errors.New("图片地址无效")
|
|
}
|
|
if imagePublicBase != "" && !storage.IsAllowedObjectURL(imagePublicBase, content) {
|
|
return "", errors.New("图片地址不在允许的存储域名下")
|
|
}
|
|
if len(content) > 2000 {
|
|
return "", errors.New("图片地址过长")
|
|
}
|
|
return content, nil
|
|
default:
|
|
return "", errors.New("不支持的消息类型")
|
|
}
|
|
}
|