删除common/config包 - 配置已迁移到customerservice
This commit is contained in:
Cold
@@ -1,42 +0,0 @@
|
||||
package config
|
||||
|
||||
// ==================== 可配置常量 ====================
|
||||
// 修改以下值来调整系统行为
|
||||
|
||||
// -------------------- 追问配置 --------------------
|
||||
|
||||
// FollowUpDelay1 第一次追问延时（秒）
|
||||
var FollowUpDelay1 = 30
|
||||
|
||||
// FollowUpDelay2 第二次追问延时（秒）
|
||||
var FollowUpDelay2 = 60
|
||||
|
||||
// FollowUpDelay3 第三次追问延时（秒）
|
||||
var FollowUpDelay3 = 180
|
||||
|
||||
// FollowUpContent1 第一次追问话术
|
||||
var FollowUpContent1 = "还有其他问题吗？"
|
||||
|
||||
// FollowUpContent2 第二次追问话术
|
||||
var FollowUpContent2 = "如果需要帮助，随时告诉我～"
|
||||
|
||||
// FollowUpContent3 第三次追问话术
|
||||
var FollowUpContent3 = "我一直在线，有问题随时找我～"
|
||||
|
||||
// -------------------- 归档配置 --------------------
|
||||
|
||||
// ArchiveDelay 归档延时（秒），默认 1 小时
|
||||
var ArchiveDelay = 3600
|
||||
|
||||
// -------------------- 历史上下文配置 --------------------
|
||||
|
||||
// HistoryContextLimit 读取历史对话轮数（用于新 Session 上下文注入）
|
||||
var HistoryContextLimit int64 = 5
|
||||
|
||||
// -------------------- Stream 消费配置 --------------------
|
||||
|
||||
// DefaultBatchSize 批量读取消息数量（削峰填谷）
|
||||
var DefaultBatchSize int64 = 200
|
||||
|
||||
// DefaultBlockTimeout 阻塞超时时间（毫秒）
|
||||
var DefaultBlockTimeout int64 = 2000
|
||||
@@ -1,236 +0,0 @@
|
||||
// Package config 提供全局配置管理和Consul监听
|
||||
//
|
||||
// 本包实现了基于Consul的配置热更新机制，所有服务导入common包即可自动获得配置监听能力
|
||||
package config
|
||||
|
||||
import (
|
||||
"context"
|
||||
"encoding/json"
|
||||
"sync"
|
||||
"time"
|
||||
|
||||
"github.com/gogf/gf/v2/frame/g"
|
||||
"github.com/gogf/gf/v2/os/glog"
|
||||
"github.com/hashicorp/consul/api"
|
||||
)
|
||||
|
||||
// Direction 咨询方向配置
|
||||
type Direction struct {
|
||||
Name string `json:"name"` // 方向名称（如：气血、减肥）
|
||||
ChatId string `json:"chat_id"` // RAGFlow对话ID
|
||||
}
|
||||
|
||||
var (
|
||||
directionsCache []Direction // 本地缓存（内存读取，超快）
|
||||
cacheMu sync.RWMutex // 读写锁（支持多goroutine并发读）
|
||||
startOnce sync.Once // 确保只启动一次监听
|
||||
consulClient *api.Client // Consul客户端（复用连接）
|
||||
)
|
||||
|
||||
// init 包初始化函数（所有服务导入common包时自动执行）
|
||||
//
|
||||
// Fallback顺序：Consul → config.yml
|
||||
func init() {
|
||||
ctx := context.Background()
|
||||
|
||||
// 检查Consul是否配置
|
||||
consulAddr := g.Cfg().MustGet(ctx, "consul.address").String()
|
||||
if consulAddr == "" {
|
||||
glog.Warning(ctx, "Consul未配置，使用本地配置")
|
||||
loadDirectionsFromLocal(ctx)
|
||||
return
|
||||
}
|
||||
|
||||
// 初始化Consul客户端
|
||||
config := api.DefaultConfig()
|
||||
config.Address = consulAddr
|
||||
client, err := api.NewClient(config)
|
||||
if err != nil {
|
||||
glog.Errorf(ctx, "Consul客户端初始化失败: %v，fallback到本地配置", err)
|
||||
loadDirectionsFromLocal(ctx)
|
||||
return
|
||||
}
|
||||
consulClient = client
|
||||
|
||||
// 启动后台监听（单例，确保只启动一次）
|
||||
startOnce.Do(func() {
|
||||
go startConsulWatcher(ctx)
|
||||
glog.Info(ctx, "Consul配置监听已启动")
|
||||
})
|
||||
}
|
||||
|
||||
// GetDirections 获取咨询方向配置（从内存缓存读取）
|
||||
//
|
||||
// 返回：
|
||||
//
|
||||
// []Direction: 方向列表
|
||||
//
|
||||
// 特点：
|
||||
// - 高性能：读内存缓存，无网络IO
|
||||
// - 线程安全：使用读锁，支持并发读取
|
||||
// - 自动更新：后台监听Consul，配置变化时自动更新缓存
|
||||
//
|
||||
// 使用示例：
|
||||
//
|
||||
// dirs := config.GetDirections()
|
||||
// for _, dir := range dirs {
|
||||
// fmt.Printf("%s -> %s\n", dir.Name, dir.ChatId)
|
||||
// }
|
||||
func GetDirections() []Direction {
|
||||
cacheMu.RLock()
|
||||
defer cacheMu.RUnlock()
|
||||
|
||||
// 返回副本，避免外部修改缓存
|
||||
result := make([]Direction, len(directionsCache))
|
||||
copy(result, directionsCache)
|
||||
return result
|
||||
}
|
||||
|
||||
// GetDirectionChatId 根据方向名称获取对应的ChatId
|
||||
//
|
||||
// 参数：
|
||||
//
|
||||
// name: 方向名称（如："气血"、"减肥"）
|
||||
//
|
||||
// 返回：
|
||||
//
|
||||
// chatId: 对应的RAGFlow对话ID，未找到返回空字符串
|
||||
//
|
||||
// 使用示例：
|
||||
//
|
||||
// chatId := config.GetDirectionChatId("气血")
|
||||
func GetDirectionChatId(name string) string {
|
||||
cacheMu.RLock()
|
||||
defer cacheMu.RUnlock()
|
||||
|
||||
for _, dir := range directionsCache {
|
||||
if dir.Name == name {
|
||||
return dir.ChatId
|
||||
}
|
||||
}
|
||||
return ""
|
||||
}
|
||||
|
||||
// startConsulWatcher 后台监听Consul配置变化（Blocking Query长连接）
|
||||
//
|
||||
// 工作原理：
|
||||
// 1. 使用Consul Blocking Query API（长连接，只在变化时返回）
|
||||
// 2. 收到变化通知后更新本地缓存
|
||||
// 3. 自动重连（网络异常时自动恢复）
|
||||
//
|
||||
// 资源消耗：
|
||||
// - 一个长连接（保持5分钟）
|
||||
// - 配置未变化时几乎不占用CPU和网络
|
||||
// - 对比轮询：节省99%资源
|
||||
//
|
||||
// 注意：
|
||||
// - 此函数在后台goroutine中运行
|
||||
// - 使用Blocking Query避免轮询
|
||||
func startConsulWatcher(ctx context.Context) {
|
||||
const consulKey = "ragflow/directions"
|
||||
kv := consulClient.KV()
|
||||
var lastIndex uint64
|
||||
|
||||
// 初始化时先读取一次配置
|
||||
if err := loadDirectionsFromConsul(ctx, kv); err != nil {
|
||||
glog.Warningf(ctx, "初始化加载Consul配置失败: %v", err)
|
||||
}
|
||||
|
||||
// 持续监听配置变化
|
||||
for {
|
||||
// Consul Blocking Query（长连接模式）
|
||||
// WaitIndex: 指定版本号，只在配置变化时返回
|
||||
// WaitTime: 最长等待时间（超时后返回，客户端重新请求）
|
||||
pair, meta, err := kv.Get(consulKey, &api.QueryOptions{
|
||||
WaitIndex: lastIndex,
|
||||
WaitTime: 5 * time.Minute,
|
||||
})
|
||||
|
||||
if err != nil {
|
||||
glog.Errorf(ctx, "Consul查询失败: %v", err)
|
||||
time.Sleep(5 * time.Second) // 错误时等待5秒重试
|
||||
continue
|
||||
}
|
||||
|
||||
// 配置版本号变化，说明有更新
|
||||
if meta.LastIndex != lastIndex {
|
||||
lastIndex = meta.LastIndex
|
||||
|
||||
// 配置被删除
|
||||
if pair == nil {
|
||||
glog.Warning(ctx, "Consul配置已删除: "+consulKey)
|
||||
cacheMu.Lock()
|
||||
directionsCache = []Direction{}
|
||||
cacheMu.Unlock()
|
||||
continue
|
||||
}
|
||||
|
||||
// 解析并更新缓存
|
||||
var dirs []Direction
|
||||
if err := json.Unmarshal(pair.Value, &dirs); err != nil {
|
||||
glog.Errorf(ctx, "解析Consul配置失败: %v", err)
|
||||
continue
|
||||
}
|
||||
|
||||
cacheMu.Lock()
|
||||
directionsCache = dirs
|
||||
cacheMu.Unlock()
|
||||
|
||||
glog.Infof(ctx, "Consul配置已更新: %d个方向", len(dirs))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// loadDirectionsFromConsul 从Consul加载配置（初始化时调用）
|
||||
func loadDirectionsFromConsul(ctx context.Context, kv *api.KV) error {
|
||||
const consulKey = "ragflow/directions"
|
||||
|
||||
pair, _, err := kv.Get(consulKey, nil)
|
||||
if err != nil {
|
||||
// Consul查询失败，fallback到本地配置
|
||||
glog.Warningf(ctx, "Consul查询失败: %v，fallback到本地配置", err)
|
||||
loadDirectionsFromLocal(ctx)
|
||||
return err
|
||||
}
|
||||
|
||||
if pair == nil {
|
||||
glog.Warning(ctx, "Consul中未找到配置: "+consulKey+"，fallback到本地配置")
|
||||
loadDirectionsFromLocal(ctx)
|
||||
return nil
|
||||
}
|
||||
|
||||
var dirs []Direction
|
||||
if err := json.Unmarshal(pair.Value, &dirs); err != nil {
|
||||
glog.Errorf(ctx, "解析Consul配置失败: %v，fallback到本地配置", err)
|
||||
loadDirectionsFromLocal(ctx)
|
||||
return err
|
||||
}
|
||||
|
||||
cacheMu.Lock()
|
||||
directionsCache = dirs
|
||||
cacheMu.Unlock()
|
||||
|
||||
glog.Infof(ctx, "已加载Consul配置: %d个方向", len(dirs))
|
||||
return nil
|
||||
}
|
||||
|
||||
// loadDirectionsFromLocal 从本地config.yml加载配置（fallback机制）
|
||||
func loadDirectionsFromLocal(ctx context.Context) {
|
||||
directionsConfig := g.Cfg().MustGet(ctx, "ragflow.directions")
|
||||
if directionsConfig.IsEmpty() {
|
||||
glog.Warning(ctx, "本地配置中也未找到 ragflow.directions")
|
||||
return
|
||||
}
|
||||
|
||||
var dirs []Direction
|
||||
if err := directionsConfig.Scan(&dirs); err != nil {
|
||||
glog.Errorf(ctx, "解析本地配置失败: %v", err)
|
||||
return
|
||||
}
|
||||
|
||||
cacheMu.Lock()
|
||||
directionsCache = dirs
|
||||
cacheMu.Unlock()
|
||||
|
||||
glog.Infof(ctx, "已加载config.yml配置: %d个方向", len(dirs))
|
||||
}
|
||||
@@ -1,40 +0,0 @@
|
||||
package config
|
||||
|
||||
import (
|
||||
"context"
|
||||
"sync"
|
||||
|
||||
"github.com/gogf/gf/v2/frame/g"
|
||||
"github.com/gogf/gf/v2/os/glog"
|
||||
)
|
||||
|
||||
var (
|
||||
welcomeCache map[string]string
|
||||
welcomeMu sync.RWMutex
|
||||
welcomeOnce sync.Once
|
||||
)
|
||||
|
||||
// initWelcomeMessages 初始化欢迎话术配置
|
||||
func initWelcomeMessages(ctx context.Context) {
|
||||
welcomeOnce.Do(func() {
|
||||
// 从默认配置文件（config.yml）读取 welcomes 配置
|
||||
welcomeMap := g.Cfg().MustGet(ctx, "welcomes").MapStrStr()
|
||||
|
||||
welcomeMu.Lock()
|
||||
welcomeCache = welcomeMap
|
||||
welcomeMu.Unlock()
|
||||
|
||||
glog.Infof(ctx, "已加载欢迎话术配置: %d个方向", len(welcomeMap))
|
||||
})
|
||||
}
|
||||
|
||||
// GetWelcomeMessage 根据方向名称获取欢迎话术
|
||||
func GetWelcomeMessage(direction string) string {
|
||||
ctx := context.Background()
|
||||
initWelcomeMessages(ctx)
|
||||
|
||||
welcomeMu.RLock()
|
||||
defer welcomeMu.RUnlock()
|
||||
|
||||
return welcomeCache[direction]
|
||||
}
|
||||
@@ -1,53 +0,0 @@
|
||||
# 各咨询方向的欢迎话术配置
|
||||
# 当用户在状态5选择方向后，会自动发送对应的欢迎语
|
||||
|
||||
welcomes:
|
||||
乳腺贴: |
|
||||
🙋♀️ 欢迎姐妹们来到药济堂！我们是一个拥有10年经验的大健康专业团队🏅，专注于保守调理乳腺问题，已经成功帮助超过1万位姐妹轻松调理乳腺健康❤️。
|
||||
如果您有结节或增生的困扰，欢迎随时咨询！
|
||||
请回复下面的数字，让我帮助您分析结节情况：
|
||||
|
||||
结节
|
||||
增生
|
||||
点击👇获取更快速的服务！
|
||||
|
||||
肝病: |
|
||||
你好，我是黄医生，有什么肝脏方面的问题我可以帮助您吗？无论是肝病、乙肝、丙肝，还是肝硬化腹水、脂肪肝、酒精肝，我都会为您提供专业的建议。😷
|
||||
肝病的类型很多，常见症状有乏力、食欲减退和肝区不适等。为了更好地帮您，我需要了解一些详细的信息，比如：
|
||||
|
||||
您现在有腹胀或腹水的情况吗？
|
||||
是第一次出现还是反复出现呢？
|
||||
目前是早期还是中晚期呢？
|
||||
有没有病毒性肝炎的病史呢？
|
||||
请您留一下联系方式，我可以发送您的报告，并给您详细解读肝病治疗方案和成功案例。📋
|
||||
|
||||
车膜: |
|
||||
🎉亲爱的车主，欢迎来到6膜王！
|
||||
🚗 我们在车膜行业深耕十年，拥有2家千平米的门店和30+专业团队，致力于为您提供最优质的服务！
|
||||
✨ 无论是隐形车衣还是改色膜，我们都能精准适配您的需求。留下您的【车型➕VX】，我们的资深顾问会立即为您匹配专属方案、膜材讲解以及报价！❤️
|
||||
|
||||
毛孔: |
|
||||
啊啊~亲爱的姐妹们，最近有很多小伙伴在问我关于毛孔的问题！我之前也是毛孔大到妆容卡粉，真的是烦恼不断。😩 但在经过一段时间的摸索后，我终于找到了合适的方法，效果真的很好，差不多一个月就改善了许多！（亲测有效！）💖
|
||||
如果需要帮助，可以随时告诉我，我非常乐意分享我的经验给你们哦！
|
||||
|
||||
免税店: |
|
||||
Hi，长春的宝子们～💕欢迎锁定小红提免税集合店！
|
||||
这里有你想要的一切：美妆、香水、包包、首饰和大牌护肤品，正品保真不踩雷，价格特别美丽哦✨
|
||||
全城顺丰包邮，购物更方便！期待你们来逛快来发现更多惊喜吧！💖
|
||||
|
||||
门店地址：长春市绿园区皓月大路吾悦广场1楼 1036号，等你来哦！🌟
|
||||
|
||||
减肥: |
|
||||
你好呀，姐妹～你也有肉肉的困扰吗？我现在已经掉了二十多斤了，至今都没有反弹！
|
||||
想要方法的话可以直接回复"1"，我分享给你哦~
|
||||
(💗未成年发育期、哺乳期的姐妹我就不推荐啦)
|
||||
|
||||
气血: |
|
||||
亲爱的，欢迎光临！🌸
|
||||
如果你有月经不调或气血不足的问题，随时可以问我哦！
|
||||
|
||||
停经闭经
|
||||
痛经难忍
|
||||
量少
|
||||
经期不准
|
||||
💗只需回复数字，我们会为你提供专业建议！ 🌟如需更多帮助，点击下方咨询专业老师，我们一起寻求解决方案~
|
||||
Reference in New Issue
Block a user