|
@@ -2,10 +2,8 @@ package services
|
|
|
|
|
|
import (
|
|
|
"context"
|
|
|
- "eta/eta_task/models/rag"
|
|
|
"eta/eta_task/utils"
|
|
|
"fmt"
|
|
|
- "time"
|
|
|
)
|
|
|
|
|
|
type WechatArticleOp struct {
|
|
@@ -41,18 +39,18 @@ func AddWechatArticleOpToCache(wechatPlatformId int, source string) bool {
|
|
|
|
|
|
|
|
|
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 {
|
|
|
-
|
|
|
-
|
|
|
- }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
return
|
|
|
}
|