Просмотр исходного кода

Merge branch 'fix/wecha_article' into debug

# Conflicts:
#	services/task.go
Roc 3 недель назад
Родитель
Сommit
1097198700
2 измененных файлов с 10 добавлено и 1 удалено
  1. 9 0
      cache/llm.go
  2. 1 1
      services/task.go

+ 9 - 0
cache/llm.go

@@ -16,6 +16,11 @@ type WechatArticleOp struct {
 // @param source
 // @param source
 // @return bool
 // @return bool
 func AddWechatArticleOpToCache(wechatPlatformId int, source string) bool {
 func AddWechatArticleOpToCache(wechatPlatformId int, source string) bool {
+	// 如果不在发布和调试模式,那么就不加入缓存
+	if !utils.InArrayByStr([]string{utils.BusinessCodeRelease, utils.BusinessCodeDebug}, utils.BusinessCode) {
+		return true
+	}
+
 	record := new(WechatArticleOp)
 	record := new(WechatArticleOp)
 	record.Source = source
 	record.Source = source
 	record.WechatPlatformId = wechatPlatformId
 	record.WechatPlatformId = wechatPlatformId
@@ -37,6 +42,10 @@ func AddWechatArticleOpToCache(wechatPlatformId int, source string) bool {
 // @param source
 // @param source
 // @return bool
 // @return bool
 func AddWechatArticleLlmOpToCache(wechatPlatformId int, source string) bool {
 func AddWechatArticleLlmOpToCache(wechatPlatformId int, source string) bool {
+	// 如果不在发布和调试模式,那么就不加入缓存
+	if !utils.InArrayByStr([]string{utils.BusinessCodeRelease, utils.BusinessCodeDebug}, utils.BusinessCode) {
+		return true
+	}
 	record := new(WechatArticleOp)
 	record := new(WechatArticleOp)
 	record.Source = source
 	record.Source = source
 	record.WechatPlatformId = wechatPlatformId
 	record.WechatPlatformId = wechatPlatformId

+ 1 - 1
services/task.go

@@ -68,7 +68,7 @@ func Task() {
 
 
 	go llm.SaveAllChatRecordsToDB()
 	go llm.SaveAllChatRecordsToDB()
 
 
-	// 定时任务进行微信文章操作
+	// 定时任务进行微信公众号添加、文章刷新操作(暂不处理了,改成其他服务处理)
 	//go HandleWechatArticleOp()
 	//go HandleWechatArticleOp()
 
 
 	// 定时任务进行微信文章LLM操作
 	// 定时任务进行微信文章LLM操作