search_log_controller.go

package controller

import (
	"encoding/json"
	"github.com/gin-gonic/gin"
	"search_server/pkg/common"
	"search_server/pkg/es"
	"search_server/requests"
	"search_server/service"
	"strconv"
	"strings"
)

//提供日志接口给日志系统
func SearchLogIndex(ctx *gin.Context) {
	request := make(map[string]string, 0)
	ctx.MultipartForm()
	for name, value := range ctx.Request.Form {
		if value[0] != "" {
			request[name] = strings.TrimSpace(value[0])
		}
	}

	searchLogService := service.SearchLogService{}
	result, err := searchLogService.GetIndexData(request)
	if err != nil {
		common.ReturnData(ctx,1, "获取ES数据失败 : "+err.Error(), nil)
	}

	common.ReturnData(ctx,0, "", result)
	return
}

func Scroll(c *gin.Context) {
	var r requests.ScrollRequest
	c.ShouldBind(&r)
	if r.ScrollId == 0 {
		common.ReturnData(c,1, "", nil)
	}
	params := make(map[string]interface{})
	if r.Scroll > 0 {
		params["scroll"] = strconv.Itoa(r.Scroll) + "m"
	} else {
		params["scroll"] = "5m"
	}
	params["scroll_id"] = r.ScrollId
	paramsStr, _ := json.Marshal(params)
	_, err := es.ScrollES(string(paramsStr))
	if err != nil {
		common.ReturnData(c,1, "Scroll失败 : "+err.Error(), nil)
	}
}

//根据搜索日志统计出时间短访问最多的ip'
func SumIp(c *gin.Context) {
	//统计品牌下的商品数量
	flag := common.CheckSignApi(c)
	if flag > 0 {
		common.ReturnData(c,flag, "", nil)
		return
	}
	var r requests.SumIpRequest
	c.ShouldBind(&r)
	searchLogService := service.SearchLogService{}
	res, err := searchLogService.GetSumIp(r)
	if err != nil {
		common.ReturnData(c,1, err.Error(), nil)
		return
	}
	common.ReturnData(c,0, "", res)
	return
}