refactor(services): 重新启用 RefreshWechatPlatform 函数

- 移除了 RefreshWechatPlatform函数中的注释代码
-保留了获取启用状态的微信平台列表并刷新缓存的逻辑- 添加了日志记录和错误处理

services/wechat_platform.go

@@ -2,8 +2,10 @@ package services
 
 import (
 	"context"
+	"eta/eta_task/models/rag"
 	"eta/eta_task/utils"
 	"fmt"
+	"time"
 )
 
 type WechatArticleOp struct {
@@ -39,18 +41,18 @@ func AddWechatArticleOpToCache(wechatPlatformId int, source string) bool {
 // @param cont context.Context
 // @return err error
 func RefreshWechatPlatform(cont context.Context) (err error) {
-	//utils.FileLog.Debug("RefreshWechatPlatform：", time.Now().Format(utils.FormatDateTime))
-	//obj := new(rag.WechatPlatform)
-	//platformList, tmpErr := obj.GetListByCondition(` AND enabled = 1 `, []interface{}{}, 0, 100000)
-	//if tmpErr != nil {
-	//	err = tmpErr
-	//	return
-	//}
-	//
-	//for _, v := range platformList {
-	//	AddWechatArticleOpToCache(v.WechatPlatformId, "refresh")
-	//	time.Sleep(1 * time.Minute)
-	//}
+	utils.FileLog.Debug("RefreshWechatPlatform：", time.Now().Format(utils.FormatDateTime))
+	obj := new(rag.WechatPlatform)
+	platformList, tmpErr := obj.GetListByCondition(` AND enabled = 1 `, []interface{}{}, 0, 100000)
+	if tmpErr != nil {
+		err = tmpErr
+		return
+	}
+
+	for _, v := range platformList {
+		AddWechatArticleOpToCache(v.WechatPlatformId, "refresh")
+		time.Sleep(1 * time.Minute)
+	}
 
 	return
 }