Skip to content

杨树贤 / search_server

Go to a project
Commit 80cb2bda by huangchengyi
Options

1.0

parent 004422b4
Inline Side-by-side
Showing with 8 additions and 180 deletions
boot/app.go
...@@ -4,27 +4,18 @@ import ( ...@@ -4,27 +4,18 @@ import (
"search_server/pkg/config" "search_server/pkg/config"
"search_server/pkg/gredis" "search_server/pkg/gredis"
"search_server/pkg/logger" "search_server/pkg/logger"
<<<<<<< HEAD
"search_server/pkg/mongo" "search_server/pkg/mongo"
"search_server/pkg/mysql" "search_server/pkg/mysql"
=======
>>>>>>> f2b8edb8d28bbb6afad6bbeb1baddb7f7d245e57
) )
func Boot(configPath string) (err error) { func Boot(configPath string) (err error) {
if err = config.SetUp(configPath); err != nil { if err = config.SetUp(configPath); err != nil {
panic(err) panic(err)
} }
<<<<<<< HEAD
if err = mysql.Setup(); err != nil { if err = mysql.Setup(); err != nil {
panic(err) panic(err)
return return
} }
=======
//if err = mysql.Setup(); err != nil {
// return
//}
>>>>>>> f2b8edb8d28bbb6afad6bbeb1baddb7f7d245e57
if err = gredis.Setup(); err != nil { if err = gredis.Setup(); err != nil {
panic(err) panic(err)
return return
......
controller/course_controller.go deleted 100644 → 0
package controller
import (
"github.com/gin-gonic/gin"
"search_server/framework/gin_"
"search_server/protopb/course"
"search_server/service"
)
func Init2() {
courseService := service.NewCourseServiceImpl()
gin_.NewBuilder().WithService(courseService).
WithMiddleware(Check_Middleware()).
WithMiddleware(Cors_Middleware()).
WithEndpoint(Courselist_Endpoint(courseService)).
WithRequest(Courselist_Request()).
WithResponse(Course_Response()).Build("/course", "GET")
gin_.NewBuilder().WithService(courseService).
WithMiddleware(Check_Middleware()).
WithEndpoint(Coursedetail_Endpoint(courseService)).
WithRequest(Coursedetail_Request()).
WithResponse(Course_Response()).Build("/detail/:course_id", "GET")
}
//详细相关
func Coursedetail_Endpoint(c *service.CourseServiceImpl) gin_.Endpoint {
return func(context *gin.Context, request interface{}) (response interface{}, err error) {
rsp := &course.DetailResponse{Course: new(course.CourseModel), Counts: make([]*course.CourseCounts, 0)}
err = c.GetDetail(context, request.(*course.DetailRequest), rsp)
return rsp, err
}
}
//这个函数的作用是怎么处理请求
func Coursedetail_Request() gin_.EncodeRequestFunc {
return func(context *gin.Context) (i interface{}, e error) {
bReq := &course.DetailRequest{}
err := context.BindUri(bReq)
if err != nil {
return nil, err
}
err = context.BindHeader(bReq)
if err != nil {
return nil, err
}
return bReq, nil
}
}
//获取列表相关
func Courselist_Endpoint(c *service.CourseServiceImpl) gin_.Endpoint {
return func(context *gin.Context, request interface{}) (response interface{}, err error) {
rsp := &course.ListResponse{}
err = c.ListForTop(context, request.(*course.ListRequest), rsp)
return rsp, err
}
}
//这个函数的作用是怎么处理请求
func Courselist_Request() gin_.EncodeRequestFunc {
return func(context *gin.Context) (i interface{}, e error) {
bReq := &course.ListRequest{}
err := context.BindQuery(bReq) //使用的是query 参数
if err != nil {
return nil, err
}
return bReq, nil
}
}
//这个函数作用是：怎么处理响应结果
func Course_Response() gin_.DecodeResponseFunc {
return func(context *gin.Context, res interface{}) error {
context.JSON(200, res)
return nil
}
}
controller/course_topic_controller.go deleted 100644 → 0
package controller
import (
"github.com/gin-gonic/gin"
"search_server/framework/gin_"
"search_server/protopb/course"
"search_server/service"
)
func Init() {
courseService:=service.NewCourseTopicServiceImpl()
gin_.NewBuilder().WithService(courseService).
WithMiddleware(Check_Middleware()).
WithEndpoint(CourseTopicList_Endpoint(courseService)).
WithRequest(CourseTopicList_Request()).
WithResponse(Course_Response()).Build("/topic/:cid","GET")
}
func CourseTopicList_Endpoint(c *service.CourseTopicServiceImpl) gin_.Endpoint {
return func(context *gin.Context, request interface{}) (response interface{}, err error) {
rsp:=&course.TopicResponse{Result:make([]*course.CourseTopic,0)}
err=c.GetTopic(context,request.(*course.TopicRequest),rsp)
return rsp,err
}
}
//这个函数的作用是怎么处理请求
func CourseTopicList_Request() gin_.EncodeRequestFunc{
return func(context *gin.Context) (i interface{}, e error) {
bReq:=&course.TopicRequest{}
err:=context.BindUri(bReq) //使用的是query 参数
if err!=nil{
return nil,err
}
return bReq,nil
}
}
\ No newline at end of file
controller/middleware_controller.go
...@@ -4,6 +4,7 @@ import ( ...@@ -4,6 +4,7 @@ import (
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"net/http" "net/http"
"search_server/framework/gin_" "search_server/framework/gin_"
"search_server/pkg/config"
) )
//放 通用中间件 //放 通用中间件
...@@ -21,14 +22,14 @@ func Cors_Middleware() gin_.Middleware { ...@@ -21,14 +22,14 @@ func Cors_Middleware() gin_.Middleware {
return func(next gin_.Endpoint) gin_.Endpoint { return func(next gin_.Endpoint) gin_.Endpoint {
return func(c *gin.Context, request interface{}) (response interface{}, err error) { return func(c *gin.Context, request interface{}) (response interface{}, err error) {
method := c.Request.Method method := c.Request.Method
//corsDomains := config.Get("web.cors.domain").Strings(",") corsDomains := config.Get("web.cors.domain").Strings(",")
//for _, domain := range corsDomains { for _, domain := range corsDomains {
// c.Header("Access-Control-Allow-Origin", domain) c.Header("Access-Control-Allow-Origin", domain)
//} }
c.Header("Access-Control-Allow-Origin", "https://bom.ichunt.com") c.Header("Access-Control-Allow-Origin", "https://bom.ichunt.com")
//c.Header("Access-Control-Allow-Headers", "Content-Type,AccessToken,X-CSRF-Token, Authorization, Token") c.Header("Access-Control-Allow-Headers", "Content-Type,AccessToken,X-CSRF-Token, Authorization, Token")
//c.Header("Access-Control-Allow-Methods", "POST, GET, OPTIONS") c.Header("Access-Control-Allow-Methods", "POST, GET, OPTIONS")
//c.Header("Access-Control-Expose-Headers", "Content-Length, Access-Control-Allow-Origin, Access-Control-Allow-Headers, Content-Type") c.Header("Access-Control-Expose-Headers", "Content-Length, Access-Control-Allow-Origin, Access-Control-Allow-Headers, Content-Type")
c.Header("Access-Control-Allow-Credentials", "true") c.Header("Access-Control-Allow-Credentials", "true")
//放行所有OPTIONS方法 //放行所有OPTIONS方法
......
controller/mouser_controller.go deleted 100644 → 0
package controller
import (
"github.com/gin-gonic/gin"
"search_server/framework/gin_"
"search_server/protopb/mouser"
"search_server/service"
)
func Init3() {
MouserService := service.NewMouserServiceImpl()
gin_.NewBuilder().WithService(MouserService).
WithEndpoint(MouserGetData(MouserService)).
WithRequest(MouserRequest()).
WithResponse(MouserResponse()).Build("/search/mouser/test", "POST")
}
//处理请求
func MouserGetData(c *service.MouserServiceImpl) gin_.Endpoint {
return func(context *gin.Context, request interface{}) (response interface{}, err error) {
rsp := &mouser.MouserResponse{}
err = c.MouserGetData(context, request.(*mouser.MouserRequest), rsp)
return rsp, err
}
}
//接收请求
func MouserRequest() gin_.EncodeRequestFunc {
return func(context *gin.Context) (i interface{}, e error) {
bReq := &mouser.MouserRequest{}
err := context.BindQuery(bReq) //使用的是query 参数
bReq.GoodsName, _ = context.GetPostForm("goods_name")
if err != nil {
return nil, err
}
return bReq, nil
}
}
//响应请求
func MouserResponse() gin_.DecodeResponseFunc {
return func(context *gin.Context, res interface{}) error {
context.JSON(200, res)
return nil
}
}
service/bom_service.go
...@@ -167,12 +167,8 @@ func getBomTermQuery(goodsName, brandName string, number int, isRawSearch bool) ...@@ -167,12 +167,8 @@ func getBomTermQuery(goodsName, brandName string, number int, isRawSearch bool)
} }
source := elastic.NewSearchSource().Query(query) source := elastic.NewSearchSource().Query(query)
source.From(0) source.From(0)
<<<<<<< HEAD
source.Size(30) source.Size(30)
=======
source.Size(50)
>>>>>>> f2b8edb8d28bbb6afad6bbeb1baddb7f7d245e57
source.Sort("_score", false).Sort("sort", false).Sort("single_price", true) source.Sort("_score", false).Sort("sort", false).Sort("single_price", true)
queryRequest := elastic.NewSearchRequest().Source(source) queryRequest := elastic.NewSearchRequest().Source(source)
result, _ = queryRequest.Body() result, _ = queryRequest.Body()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment