diff --git a/web/api/web_seopush/seopush.go b/web/api/web_seopush/seopush.go new file mode 100644 index 0000000..011ca28 --- /dev/null +++ b/web/api/web_seopush/seopush.go @@ -0,0 +1,31 @@ +package web_seopush + +import ( + "strconv" + + "hkdj-web-server/pub/common" + "hkdj-web-server/pub/common/srvdef" + "hkdj-web-server/web/service/srv_seopush" + + "github.com/gin-gonic/gin" +) + +// @Tags SEO推送 +// @Summary IndexNow 批量提交(主页 + 专题) +// @Description 组装主页和前 N 个专题(按 Rank 降序)地址,提交到 IndexNow(Bing / Yandex 等)。 +// @Produce json +// @Param limit query int false "URL 总数,含主页,默认 10" +// @Success 200 {object} srv_seopush.BulkIndexNowResult +// @Router /api/web/seopush/indexnow/bulk [POST] +func SubmitHomeAndThemes(ctx *gin.Context) { + limit, _ := strconv.Atoi(ctx.Query("limit")) + if limit <= 0 { + limit = 10 + } + resp, serr := srv_seopush.SubmitHomeAndThemes(ctx, limit) + if serr != nil { + common.ServerJSON(ctx, serr.Code, serr.Msg) + return + } + common.ServerJSON(ctx, srvdef.Success, resp) +} diff --git a/web/router/gin.go b/web/router/gin.go index 0fd763e..64b285d 100644 --- a/web/router/gin.go +++ b/web/router/gin.go @@ -95,6 +95,7 @@ func registerRouter(router *gin.Engine) { homeConfigRouter(rootRouter) feedbackRouter(rootRouter) contactUsRouter(rootRouter) + seopushRouter(rootRouter) } // 第三方回调路由(免鉴权,挂在 engine 上而非 /api/web 分组) thirdRouter(router) diff --git a/web/router/seopush.go b/web/router/seopush.go new file mode 100644 index 0000000..47692e0 --- /dev/null +++ b/web/router/seopush.go @@ -0,0 +1,14 @@ +package router + +import ( + "hkdj-web-server/web/api/web_seopush" + + "github.com/gin-gonic/gin" +) + +func seopushRouter(root *gin.RouterGroup) { + group := root.Group("/seopush") + { + group.POST("/indexnow/bulk", web_seopush.SubmitHomeAndThemes) + } +} diff --git a/web/service/srv_seopush/bulk.go b/web/service/srv_seopush/bulk.go new file mode 100644 index 0000000..c811e56 --- /dev/null +++ b/web/service/srv_seopush/bulk.go @@ -0,0 +1,75 @@ +package srv_seopush + +import ( + "context" + "fmt" + "strings" + + "hkdj-web-server/pub/common/log" + "hkdj-web-server/pub/common/srvdef" + "hkdj-web-server/pub/models/playletthememod" + "hkdj-web-server/pub/seo/h5path" + seoindexnow "hkdj-web-server/pub/seo/indexnow" + "hkdj-web-server/web/webg" + + "go.mongodb.org/mongo-driver/bson" + "go.mongodb.org/mongo-driver/mongo/options" +) + +// BulkIndexNowResult 批量提交结果,包含提交的 URL 列表和 IndexNow 原始回执。 +type BulkIndexNowResult struct { + URLs []string `json:"urls"` + SubmitInfo *seoindexnow.BatchResult `json:"submitInfo"` +} + +// SubmitHomeAndThemes 组装主页 + 前 N 个专题(按 Rank 降序)URL,批量提交 IndexNow。 +// limit 为 URL 总数(包含主页),默认 10;小于等于 1 时视为仅主页。 +func SubmitHomeAndThemes(ctx context.Context, limit int) (*BulkIndexNowResult, *srvdef.SrvErr) { + if limit <= 0 { + limit = 10 + } + webAddr := SEOBaseURL(ctx) + if webAddr == "" { + return nil, srvdef.New(srvdef.ErrNoData, "WebAddr 未配置", "") + } + key := strings.TrimSpace(webg.Conf.IndexNow.Key) + if key == "" { + return nil, srvdef.New(srvdef.ErrNoData, "indexNow.key 未配置", "") + } + + urls := make([]string, 0, limit) + urls = append(urls, h5path.Abs(webAddr, "/")) + if remain := limit - 1; remain > 0 { + themes, err := playletthememod.FindManyPlayletTheme(ctx, + bson.M{playletthememod.FN.PlayletTheme.Status: true}, + options.Find(). + SetSort(bson.M{playletthememod.FN.PlayletTheme.Rank: -1}). + SetLimit(int64(remain))) + if err == nil { + for _, t := range themes { + if t == nil || t.Id <= 0 { + continue + } + path := h5path.TopicDetail(t.Slug, t.Id) + if path == "" { + continue + } + urls = append(urls, h5path.Abs(webAddr, path)) + } + } else { + log.Warn("seopush bulk: list themes failed", log.E(err)) + } + } + + config, cerr := seoindexnow.BuildConfig(webAddr, key) + if cerr != nil { + return nil, srvdef.New(srvdef.Failure, fmt.Sprintf("构造 IndexNow 配置失败: %v", cerr), "") + } + result := seoindexnow.NewBatchIndexNowSubmitter(config).SubmitBatch(urls) + log.Info("seopush bulk: indexnow submitted", + log.Any("urls", urls), + log.Any("statusCodes", result.StatusCodes), + log.Any("success", result.SuccessCount), + log.Any("fail", result.FailCount)) + return &BulkIndexNowResult{URLs: urls, SubmitInfo: result}, nil +}