Skip to content

杨树贤 / search_server

Go to a project
Commit 5339e1d8 by mushishixian
Options

整理目录

parent aafca9f7
Inline Side-by-side
Showing with 122 additions and 126 deletions
boot/app.go
...@@ -8,7 +8,7 @@ import ( ...@@ -8,7 +8,7 @@ import (
func Boot() (err error) { func Boot() (err error) {
if err = config.SetUp(); err != nil { if err = config.SetUp(); err != nil {
return panic(err)
} }
if err = mysql.Setup(); err != nil { if err = mysql.Setup(); err != nil {
return return
......
cmd/user_server.go
...@@ -3,20 +3,20 @@ package main ...@@ -3,20 +3,20 @@ package main
import ( import (
"context" "context"
"github.com/micro/go-micro/v2/client" "github.com/micro/go-micro/v2/client"
"search_server/Course" "search_server/protopb/course"
"github.com/micro/go-micro/v2" "github.com/micro/go-micro/v2"
"search_server/Users" "search_server/protopb/users"
"log" "log"
) )
type UserService struct{ type UserService struct{
client client.Client client client.Client
} }
func (this *UserService) Test(ctx context.Context, req *Users.UserRequest, rsp *Users.UserResponse) error { func (this *UserService) Test(ctx context.Context, req *users.UserRequest, rsp *users.UserResponse) error {
rsp.Ret="users"+req.Id rsp.Ret="users"+req.Id
c:=Course.NewCourseService("go.micro.api.jtthink.course",this.client) c:=course.NewCourseService("go.micro.api.jtthink.course",this.client)
course_rsp,_:=c.ListForTop(ctx,&Course.ListRequest{Size:10}) course_rsp,_:=c.ListForTop(ctx,&course.ListRequest{Size:10})
log.Println(course_rsp.Result) log.Println(course_rsp.Result)
return nil return nil
} }
...@@ -31,7 +31,7 @@ func main() { ...@@ -31,7 +31,7 @@ func main() {
err:=Users.RegisterUserServiceHandler(service.Server(),NewUserService(service.Client())) err:=users.RegisterUserServiceHandler(service.Server(),NewUserService(service.Client()))
if err!=nil{ if err!=nil{
log.Fatal(err) log.Fatal(err)
} }
......
Mapper/CourseMapper.go → mapper/course_mapper.go
package Mapper package mapper
import ( import (
"github.com/jinzhu/gorm" "github.com/jinzhu/gorm"
......
pkg/config/config.go
...@@ -10,7 +10,7 @@ var ( ...@@ -10,7 +10,7 @@ var (
) )
func SetUp() (err error) { func SetUp() (err error) {
cfg, err = ini.Load("conf/config.ini") cfg, err = ini.Load("../conf/config.ini")
return return
} }
......
protopb/course/course.pb.go
...@@ -28,10 +28,10 @@ type CourseModel struct { ...@@ -28,10 +28,10 @@ type CourseModel struct {
CoursePrice float32 `protobuf:"fixed32,5,opt,name=course_price,json=coursePrice,proto3" json:"course_price,omitempty"` CoursePrice float32 `protobuf:"fixed32,5,opt,name=course_price,json=coursePrice,proto3" json:"course_price,omitempty"`
CoursePrice2 float32 `protobuf:"fixed32,6,opt,name=course_price2,json=coursePrice2,proto3" json:"course_price2,omitempty"` CoursePrice2 float32 `protobuf:"fixed32,6,opt,name=course_price2,json=coursePrice2,proto3" json:"course_price2,omitempty"`
// @inject_tag: gorm:"type:timestamp" // @inject_tag: gorm:"type:timestamp"
Addtime *Timestamp `protobuf:"bytes,7,opt,name=addtime,proto3" json:"addtime,omitempty" gorm:"type:timestamp"` Addtime int64 `protobuf:"varint,7,opt,name=addtime,proto3" json:"addtime,omitempty" gorm:"type:timestamp"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
} }
func (m *CourseModel) Reset() { *m = CourseModel{} } func (m *CourseModel) Reset() { *m = CourseModel{} }
...@@ -101,11 +101,11 @@ func (m *CourseModel) GetCoursePrice2() float32 { ...@@ -101,11 +101,11 @@ func (m *CourseModel) GetCoursePrice2() float32 {
return 0 return 0
} }
func (m *CourseModel) GetAddtime() *Timestamp { func (m *CourseModel) GetAddtime() int64 {
if m != nil { if m != nil {
return m.Addtime return m.Addtime
} }
return nil return 0
} }
type ListRequest struct { type ListRequest struct {
...@@ -361,34 +361,32 @@ func init() { ...@@ -361,34 +361,32 @@ func init() {
func init() { proto.RegisterFile("course.proto", fileDescriptor_ad75674299e1bb1e) } func init() { proto.RegisterFile("course.proto", fileDescriptor_ad75674299e1bb1e) }
var fileDescriptor_ad75674299e1bb1e = []byte{ var fileDescriptor_ad75674299e1bb1e = []byte{
// 449 bytes of a gzipped FileDescriptorProto // 431 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x93, 0x4f, 0x6f, 0xd3, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x93, 0xcf, 0x8b, 0xd3, 0x40,
0x10, 0xc5, 0xe5, 0xb4, 0x49, 0xc8, 0xd8, 0xa9, 0x60, 0x29, 0xc8, 0x04, 0x21, 0x5c, 0x73, 0xb1, 0x14, 0xc7, 0x99, 0x76, 0xdb, 0xda, 0xd7, 0x76, 0x91, 0x71, 0x95, 0x71, 0x45, 0xcc, 0xc6, 0x4b,
0x54, 0x94, 0x83, 0x39, 0x20, 0xc1, 0xb1, 0x15, 0x28, 0x2a, 0x20, 0x64, 0x22, 0xae, 0x96, 0x89, 0x40, 0xd9, 0x43, 0x3d, 0x08, 0x7a, 0xdc, 0x45, 0x29, 0xab, 0x22, 0x71, 0xf1, 0x1a, 0x62, 0xf3,
0x07, 0xb1, 0x6a, 0xbc, 0x6b, 0xbc, 0xe3, 0x4a, 0xe1, 0xdc, 0x1b, 0x5f, 0x1a, 0x79, 0x67, 0x4d, 0xc4, 0x61, 0xdb, 0x49, 0x9c, 0x79, 0x59, 0xa8, 0xe7, 0xfd, 0xa3, 0x3d, 0x4a, 0xe6, 0x4d, 0x6c,
0x9c, 0x4a, 0x70, 0xf3, 0xbe, 0xf9, 0xcd, 0x9f, 0x7d, 0x3b, 0x86, 0x60, 0xa3, 0xdb, 0xc6, 0xe0, 0x52, 0xd0, 0x5b, 0xe6, 0xfb, 0x3e, 0xef, 0xc7, 0x7c, 0xdf, 0x04, 0xe6, 0xeb, 0xb2, 0xb6, 0x0e,
0xb2, 0x6e, 0x34, 0x69, 0x31, 0xe1, 0xd3, 0x22, 0xd8, 0xe8, 0xaa, 0xd2, 0x8a, 0xd5, 0xf8, 0xf7, 0xcf, 0x2b, 0x5b, 0x52, 0x29, 0xc7, 0x7c, 0x8a, 0x7f, 0x0b, 0x98, 0x5d, 0xf8, 0xcf, 0x8f, 0x65,
0x08, 0xfc, 0x0b, 0x1b, 0xf8, 0xa8, 0x4b, 0xdc, 0x8a, 0xa7, 0x30, 0x63, 0x2e, 0x97, 0x65, 0xe8, 0x81, 0x1b, 0xf9, 0x04, 0xa6, 0x1c, 0xc9, 0x74, 0xa1, 0x44, 0x24, 0x92, 0x51, 0x7a, 0x8f, 0x85,
0x45, 0x5e, 0x32, 0xce, 0xee, 0xb1, 0xb0, 0x2a, 0xc5, 0x73, 0xf0, 0x5d, 0x50, 0x15, 0x15, 0x86, 0x55, 0x21, 0x9f, 0xc1, 0x2c, 0x04, 0x4d, 0xbe, 0x45, 0x35, 0x88, 0x44, 0x32, 0x4d, 0x81, 0xa5,
0xa3, 0xc8, 0x4b, 0x66, 0x19, 0xb0, 0xf4, 0xa9, 0xa8, 0x50, 0x24, 0x70, 0xdf, 0x01, 0xa5, 0x34, 0x4f, 0xf9, 0x16, 0x65, 0x02, 0xf7, 0x03, 0x50, 0x68, 0x57, 0x31, 0x35, 0xf4, 0xd4, 0x31, 0xeb,
0x35, 0x53, 0x47, 0x96, 0x3a, 0x61, 0xfd, 0x52, 0x9a, 0xda, 0x92, 0xfb, 0x52, 0x52, 0x51, 0x13, 0x97, 0xda, 0x55, 0x9e, 0xdc, 0x97, 0xd2, 0x86, 0xac, 0x3a, 0xea, 0x96, 0x5a, 0x19, 0xb2, 0xf2,
0x1e, 0x0f, 0x4b, 0xad, 0x14, 0x35, 0xe2, 0xac, 0x1f, 0x3f, 0xaf, 0x1b, 0xb9, 0xc1, 0x70, 0x1c, 0xac, 0x1d, 0x38, 0xab, 0xac, 0x5e, 0xa3, 0x1a, 0x45, 0x22, 0x19, 0xa4, 0x21, 0xe9, 0x73, 0x23,
0x79, 0xc9, 0x28, 0x73, 0x49, 0x9f, 0x3b, 0x49, 0xbc, 0x80, 0xf9, 0x10, 0x49, 0xc3, 0x89, 0x65, 0xc9, 0xe7, 0xb0, 0xe8, 0x22, 0x4b, 0x35, 0xf6, 0xcc, 0xbc, 0xc3, 0x2c, 0xa5, 0x82, 0x49, 0x5e,
0x82, 0x01, 0x93, 0x8a, 0x73, 0x98, 0x16, 0x65, 0x49, 0xb2, 0xc2, 0x70, 0x1a, 0x79, 0x89, 0x9f, 0x14, 0xa4, 0xb7, 0xa8, 0x26, 0x91, 0x48, 0x86, 0x69, 0x7b, 0x8c, 0xcf, 0x60, 0xf6, 0x41, 0x3b,
0x3e, 0x58, 0x3a, 0x03, 0xd6, 0xb2, 0x42, 0x43, 0x45, 0x55, 0x67, 0x3d, 0x11, 0x9f, 0x81, 0xff, 0x4a, 0xf1, 0x67, 0x8d, 0x8e, 0xa4, 0x84, 0x23, 0xa7, 0x7f, 0x61, 0xb8, 0xb4, 0xff, 0x8e, 0xaf,
0x41, 0x1a, 0xca, 0xf0, 0x67, 0x8b, 0x86, 0x84, 0x80, 0x63, 0x23, 0x7f, 0xa1, 0xf3, 0xc1, 0x7e, 0x60, 0x71, 0x89, 0x94, 0xeb, 0x4d, 0x0b, 0xfd, 0xd7, 0x9e, 0xa7, 0x00, 0xdf, 0x91, 0xd6, 0x3f,
0xc7, 0x57, 0x30, 0xbf, 0x44, 0x2a, 0xe4, 0xb6, 0x87, 0xfe, 0xeb, 0xd8, 0x33, 0x80, 0xef, 0x48, 0x32, 0xda, 0x55, 0xec, 0xce, 0x28, 0x9d, 0x7a, 0xe5, 0x7a, 0x57, 0x61, 0x7c, 0x27, 0x60, 0xce,
0x9b, 0x1f, 0x39, 0xed, 0x6a, 0x36, 0x6c, 0x9c, 0xcd, 0xac, 0xb2, 0xde, 0xd5, 0x18, 0xdf, 0x7a, 0x56, 0x5f, 0x94, 0xb5, 0x21, 0x27, 0x1f, 0x43, 0x93, 0x6b, 0x68, 0x5f, 0x6b, 0xe2, 0xcf, 0xab,
0x10, 0xb0, 0xfb, 0x17, 0xba, 0x55, 0x64, 0xc4, 0x13, 0xe8, 0x72, 0x15, 0xed, 0x6b, 0x4d, 0xed, 0xa2, 0xdf, 0x67, 0x70, 0xd0, 0x87, 0x83, 0x86, 0xb2, 0x1b, 0xdc, 0x05, 0x7b, 0xb9, 0xd0, 0x15,
0x79, 0x55, 0x1e, 0xf6, 0x19, 0xdd, 0xe9, 0xc3, 0x41, 0x45, 0xf9, 0x35, 0xee, 0x9c, 0xe3, 0x5c, 0xee, 0x82, 0xb1, 0x86, 0xb2, 0xdb, 0x7c, 0x53, 0xa3, 0x37, 0x76, 0xe4, 0x8d, 0x35, 0xf4, 0xb5,
0xe8, 0x0a, 0x77, 0xce, 0x6b, 0x45, 0xf9, 0x4d, 0xb1, 0x6d, 0xd1, 0x7a, 0x3d, 0xb6, 0x5e, 0x2b, 0x51, 0xe2, 0xb7, 0x30, 0xe7, 0x6b, 0xbb, 0xaa, 0x34, 0x0e, 0xe5, 0x0b, 0x18, 0x5b, 0x74, 0xf5,
0xfa, 0xda, 0x29, 0xf1, 0x5b, 0x08, 0xf8, 0xda, 0xa6, 0xd6, 0xca, 0xa0, 0x38, 0x87, 0x49, 0x83, 0x86, 0x94, 0x88, 0x86, 0xc9, 0x6c, 0xf9, 0xe0, 0x3c, 0x3c, 0x94, 0xce, 0xb3, 0x48, 0x03, 0x12,
0xa6, 0xdd, 0x52, 0xe8, 0x45, 0x47, 0x89, 0x9f, 0x3e, 0x5c, 0xba, 0x4d, 0x1a, 0x6c, 0x4a, 0xe6, 0xdf, 0xc0, 0x71, 0x6b, 0xc8, 0x3e, 0x9d, 0x79, 0x7f, 0x85, 0x7f, 0xa5, 0xb3, 0x26, 0x5f, 0x7a,
0x90, 0xf8, 0x1a, 0x4e, 0x7a, 0x43, 0xf6, 0xe9, 0xcc, 0xdb, 0x2b, 0xfc, 0x2b, 0x9d, 0x35, 0xf1, 0xd8, 0x90, 0x53, 0x03, 0xdf, 0xeb, 0xa4, 0x0f, 0xb3, 0x2f, 0x69, 0x60, 0x96, 0x77, 0x02, 0x16,
0xd2, 0xc2, 0x8a, 0x4c, 0x38, 0xb2, 0xbd, 0x4e, 0x0f, 0x61, 0xf6, 0x25, 0x73, 0x4c, 0x7a, 0xeb, 0x1c, 0xf8, 0x82, 0xf6, 0xb6, 0xd9, 0xf8, 0x6b, 0x80, 0x66, 0xf6, 0x77, 0xa5, 0xbd, 0x2e, 0x2b,
0xc1, 0x9c, 0x03, 0x5f, 0xb0, 0xb9, 0xe9, 0x96, 0xe0, 0x35, 0x40, 0x37, 0xfb, 0x3b, 0xdd, 0xac, 0xf9, 0xb7, 0x55, 0x67, 0x8d, 0xa7, 0x27, 0x7d, 0x31, 0x4c, 0xf9, 0x06, 0xa6, 0xef, 0x91, 0x78,
0x75, 0x2d, 0xfe, 0xb6, 0x1a, 0x3c, 0xe3, 0xe2, 0xf4, 0x50, 0x74, 0x53, 0xbe, 0x81, 0xd9, 0x7b, 0x74, 0xf9, 0xb0, 0x45, 0x7a, 0xbb, 0x3d, 0x7d, 0x74, 0x28, 0x73, 0xee, 0xb7, 0xb1, 0xff, 0x63,
0x24, 0x1e, 0x5d, 0x3c, 0xea, 0x91, 0x83, 0xb7, 0x5d, 0x3c, 0xbe, 0x2b, 0x73, 0xee, 0xb7, 0x89, 0x5e, 0xfd, 0x09, 0x00, 0x00, 0xff, 0xff, 0x18, 0x2c, 0xe0, 0xbb, 0x41, 0x03, 0x00, 0x00,
0xfd, 0x79, 0x5e, 0xfd, 0x09, 0x00, 0x00, 0xff, 0xff, 0x3d, 0xb6, 0x49, 0xa7, 0x62, 0x03, 0x00,
0x00,
} }
protopb/course/course_topic.pb.go
...@@ -21,19 +21,19 @@ var _ = math.Inf ...@@ -21,19 +21,19 @@ var _ = math.Inf
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
type CourseTopic struct { type CourseTopic struct {
Id int32 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"` Id int32 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
CourseId int32 `protobuf:"varint,2,opt,name=CourseId,proto3" json:"CourseId,omitempty"` CourseId int32 `protobuf:"varint,2,opt,name=CourseId,proto3" json:"CourseId,omitempty"`
CourseDid int32 `protobuf:"varint,3,opt,name=CourseDid,proto3" json:"CourseDid,omitempty"` CourseDid int32 `protobuf:"varint,3,opt,name=CourseDid,proto3" json:"CourseDid,omitempty"`
Likes int32 `protobuf:"varint,4,opt,name=Likes,proto3" json:"Likes,omitempty"` Likes int32 `protobuf:"varint,4,opt,name=Likes,proto3" json:"Likes,omitempty"`
Unlikes int32 `protobuf:"varint,5,opt,name=Unlikes,proto3" json:"Unlikes,omitempty"` Unlikes int32 `protobuf:"varint,5,opt,name=Unlikes,proto3" json:"Unlikes,omitempty"`
Title string `protobuf:"bytes,6,opt,name=Title,proto3" json:"Title,omitempty"` Title string `protobuf:"bytes,6,opt,name=Title,proto3" json:"Title,omitempty"`
Content string `protobuf:"bytes,7,opt,name=Content,proto3" json:"Content,omitempty"` Content string `protobuf:"bytes,7,opt,name=Content,proto3" json:"Content,omitempty"`
UserId int32 `protobuf:"varint,8,opt,name=UserId,proto3" json:"UserId,omitempty"` UserId int32 `protobuf:"varint,8,opt,name=UserId,proto3" json:"UserId,omitempty"`
Addtime *Timestamp `protobuf:"bytes,9,opt,name=Addtime,proto3" json:"Addtime,omitempty"` Addtime int64 `protobuf:"varint,9,opt,name=Addtime,proto3" json:"Addtime,omitempty"`
Updatetime *Timestamp `protobuf:"bytes,10,opt,name=Updatetime,proto3" json:"Updatetime,omitempty"` Updatetime int64 `protobuf:"varint,10,opt,name=Updatetime,proto3" json:"Updatetime,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
} }
func (m *CourseTopic) Reset() { *m = CourseTopic{} } func (m *CourseTopic) Reset() { *m = CourseTopic{} }
...@@ -117,31 +117,31 @@ func (m *CourseTopic) GetUserId() int32 { ...@@ -117,31 +117,31 @@ func (m *CourseTopic) GetUserId() int32 {
return 0 return 0
} }
func (m *CourseTopic) GetAddtime() *Timestamp { func (m *CourseTopic) GetAddtime() int64 {
if m != nil { if m != nil {
return m.Addtime return m.Addtime
} }
return nil return 0
} }
func (m *CourseTopic) GetUpdatetime() *Timestamp { func (m *CourseTopic) GetUpdatetime() int64 {
if m != nil { if m != nil {
return m.Updatetime return m.Updatetime
} }
return nil return 0
} }
type CourseTopicReply struct { type CourseTopicReply struct {
Id int32 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"` Id int32 `protobuf:"varint,1,opt,name=Id,proto3" json:"Id,omitempty"`
TopicId int32 `protobuf:"varint,2,opt,name=TopicId,proto3" json:"TopicId,omitempty"` TopicId int32 `protobuf:"varint,2,opt,name=TopicId,proto3" json:"TopicId,omitempty"`
Content string `protobuf:"bytes,3,opt,name=Content,proto3" json:"Content,omitempty"` Content string `protobuf:"bytes,3,opt,name=Content,proto3" json:"Content,omitempty"`
UserId int32 `protobuf:"varint,4,opt,name=UserId,proto3" json:"UserId,omitempty"` UserId int32 `protobuf:"varint,4,opt,name=UserId,proto3" json:"UserId,omitempty"`
Likes int32 `protobuf:"varint,5,opt,name=Likes,proto3" json:"Likes,omitempty"` Likes int32 `protobuf:"varint,5,opt,name=Likes,proto3" json:"Likes,omitempty"`
Unlikes int32 `protobuf:"varint,6,opt,name=Unlikes,proto3" json:"Unlikes,omitempty"` Unlikes int32 `protobuf:"varint,6,opt,name=Unlikes,proto3" json:"Unlikes,omitempty"`
Addtime *Timestamp `protobuf:"bytes,7,opt,name=Addtime,proto3" json:"Addtime,omitempty"` Addtime int64 `protobuf:"varint,7,opt,name=Addtime,proto3" json:"Addtime,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
} }
func (m *CourseTopicReply) Reset() { *m = CourseTopicReply{} } func (m *CourseTopicReply) Reset() { *m = CourseTopicReply{} }
...@@ -211,11 +211,11 @@ func (m *CourseTopicReply) GetUnlikes() int32 { ...@@ -211,11 +211,11 @@ func (m *CourseTopicReply) GetUnlikes() int32 {
return 0 return 0
} }
func (m *CourseTopicReply) GetAddtime() *Timestamp { func (m *CourseTopicReply) GetAddtime() int64 {
if m != nil { if m != nil {
return m.Addtime return m.Addtime
} }
return nil return 0
} }
type TopicRequest struct { type TopicRequest struct {
...@@ -306,28 +306,27 @@ func init() { ...@@ -306,28 +306,27 @@ func init() {
func init() { proto.RegisterFile("course_topic.proto", fileDescriptor_f51a07ace88d3cfc) } func init() { proto.RegisterFile("course_topic.proto", fileDescriptor_f51a07ace88d3cfc) }
var fileDescriptor_f51a07ace88d3cfc = []byte{ var fileDescriptor_f51a07ace88d3cfc = []byte{
// 360 bytes of a gzipped FileDescriptorProto // 337 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x92, 0x41, 0x4f, 0x83, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x92, 0xc1, 0x4b, 0xc3, 0x30,
0x10, 0x85, 0x03, 0x2d, 0xd0, 0x4e, 0xab, 0xd1, 0xb5, 0x9a, 0x4d, 0xe3, 0x81, 0x70, 0x22, 0x36, 0x14, 0xc6, 0x49, 0xbb, 0xb6, 0xdb, 0x9b, 0x8a, 0xc4, 0x29, 0x61, 0x88, 0x94, 0x9e, 0x8a, 0xc2,
0x21, 0xb1, 0x1e, 0xbc, 0x78, 0x31, 0x35, 0x31, 0x24, 0x7a, 0xc1, 0xf6, 0x6c, 0x2a, 0x3b, 0x07, 0x0e, 0xf3, 0xe0, 0xc5, 0x8b, 0x4c, 0x90, 0x82, 0x5e, 0xea, 0x76, 0x16, 0x5d, 0xde, 0xa1, 0x58,
0x22, 0xb0, 0xc8, 0x6e, 0x4d, 0xfc, 0x55, 0xfe, 0x10, 0xff, 0x94, 0xe9, 0x2e, 0xd4, 0x45, 0xd3, 0xdb, 0xda, 0x64, 0x82, 0x7f, 0x82, 0xff, 0x91, 0x7f, 0x9e, 0xf4, 0xa5, 0x9d, 0xa9, 0xb2, 0x5b,
0x78, 0xe3, 0xbd, 0x79, 0xc0, 0xbe, 0x6f, 0x07, 0x48, 0xca, 0x37, 0xb5, 0xc0, 0x67, 0xc9, 0xab, 0xbe, 0xdf, 0xf7, 0xd2, 0x7e, 0xf9, 0x12, 0xe0, 0xeb, 0x72, 0x53, 0x2b, 0x7c, 0xd2, 0x65, 0x95,
0x2c, 0x8d, 0xaa, 0x9a, 0x4b, 0x4e, 0x5c, 0xed, 0x4d, 0xc7, 0x29, 0x2f, 0x0a, 0x5e, 0x6a, 0x37, 0xad, 0x67, 0x55, 0x5d, 0xea, 0x92, 0xfb, 0x86, 0x45, 0x5f, 0x0e, 0x8c, 0x17, 0xb4, 0x5c, 0x36,
0xf8, 0xb4, 0x61, 0xb4, 0x50, 0x83, 0xe5, 0x36, 0x4b, 0x0e, 0xc1, 0x8e, 0x19, 0xb5, 0x7c, 0x2b, 0x2e, 0x3f, 0x00, 0x27, 0x91, 0x82, 0x85, 0x2c, 0xf6, 0x52, 0x27, 0x91, 0x7c, 0x0a, 0x43, 0x63,
0x74, 0x12, 0x3b, 0x66, 0x64, 0x0a, 0x03, 0x3d, 0x8e, 0x19, 0xb5, 0x95, 0xbb, 0xd3, 0xe4, 0x1c, 0x27, 0x52, 0x38, 0x44, 0xb7, 0x9a, 0x9f, 0xc2, 0xc8, 0xac, 0x6f, 0x33, 0x29, 0x5c, 0x32, 0x7f,
0x86, 0xfa, 0xf9, 0x2e, 0x63, 0xb4, 0xa7, 0x86, 0x3f, 0x06, 0x99, 0x80, 0xf3, 0x90, 0xbd, 0xa2, 0x01, 0x9f, 0x80, 0x77, 0x9f, 0xbd, 0xa2, 0x12, 0x03, 0x72, 0x8c, 0xe0, 0x02, 0x82, 0x55, 0x91,
0xa0, 0x7d, 0x35, 0xd1, 0x82, 0x50, 0xf0, 0x56, 0x65, 0xae, 0x7c, 0x47, 0xf9, 0xad, 0xdc, 0xe6, 0x13, 0xf7, 0x88, 0x77, 0xb2, 0x99, 0x5f, 0x66, 0x3a, 0x47, 0xe1, 0x87, 0x2c, 0x1e, 0xa5, 0x46,
0x97, 0x99, 0xcc, 0x91, 0xba, 0xbe, 0x15, 0x0e, 0x13, 0x2d, 0xb6, 0xf9, 0x05, 0x2f, 0x25, 0x96, 0x34, 0xf3, 0x8b, 0xb2, 0xd0, 0x58, 0x68, 0x11, 0x10, 0xef, 0x24, 0x3f, 0x01, 0x7f, 0xa5, 0xb0,
0x92, 0x7a, 0xca, 0x6f, 0x25, 0x39, 0x03, 0x77, 0x25, 0xb0, 0x8e, 0x19, 0x1d, 0xa8, 0x0f, 0x35, 0x4e, 0xa4, 0x18, 0xd2, 0x87, 0x5a, 0xd5, 0xec, 0xb8, 0x91, 0x52, 0x67, 0x6f, 0x28, 0x46, 0x21,
0x8a, 0xcc, 0xc0, 0xbb, 0x65, 0x4c, 0x66, 0x05, 0xd2, 0xa1, 0x6f, 0x85, 0xa3, 0xf9, 0x71, 0xd4, 0x8b, 0xdd, 0xb4, 0x93, 0xfc, 0x0c, 0x60, 0x55, 0xc9, 0x67, 0x8d, 0x64, 0x02, 0x99, 0x16, 0x89,
0x34, 0x5e, 0x66, 0x05, 0x0a, 0xb9, 0x2e, 0xaa, 0xa4, 0x4d, 0x90, 0x4b, 0x80, 0x55, 0xc5, 0xd6, 0xbe, 0x19, 0x1c, 0x5a, 0x5d, 0xa4, 0x58, 0xe5, 0x9f, 0xff, 0x0a, 0x11, 0x10, 0x90, 0xbb, 0xed,
0x12, 0x55, 0x1e, 0xf6, 0xe5, 0x8d, 0x50, 0xf0, 0x65, 0xc1, 0x91, 0x41, 0x2c, 0xc1, 0x2a, 0xff, 0xa3, 0x93, 0x76, 0x54, 0x77, 0x57, 0xd4, 0x41, 0x2f, 0xea, 0xb6, 0x22, 0x6f, 0x47, 0x45, 0x7e,
0xf8, 0x83, 0x8d, 0x82, 0xa7, 0xa6, 0x3b, 0x6a, 0xad, 0x34, 0x0b, 0xf5, 0xf6, 0x15, 0xea, 0x77, 0xbf, 0x22, 0xeb, 0x68, 0x41, 0xef, 0x68, 0xd1, 0x39, 0xec, 0xb5, 0x99, 0xdf, 0x37, 0xa8, 0x74,
0x0a, 0xed, 0x40, 0x3a, 0x7b, 0x40, 0xba, 0x5d, 0x90, 0x06, 0x00, 0xef, 0x3f, 0x00, 0xc1, 0x05, 0xef, 0xda, 0x58, 0xff, 0xda, 0xa2, 0x6b, 0xd8, 0x6f, 0x67, 0x55, 0x55, 0x16, 0x0a, 0xf9, 0x05,
0x8c, 0x9b, 0x1a, 0x6f, 0x1b, 0x14, 0xb2, 0x73, 0xdf, 0x56, 0xf7, 0xbe, 0x83, 0x1b, 0x38, 0x68, 0xf8, 0x35, 0xaa, 0x4d, 0xae, 0x05, 0x0b, 0xdd, 0x78, 0x3c, 0x3f, 0x9a, 0x99, 0xc7, 0x31, 0xb3,
0xb2, 0xa2, 0xe2, 0xa5, 0x40, 0x32, 0x03, 0xb7, 0x46, 0xb1, 0xc9, 0x25, 0xb5, 0xfc, 0x5e, 0x38, 0xcb, 0x68, 0x47, 0xe6, 0x0f, 0xc0, 0x2d, 0xfc, 0x88, 0xf5, 0x47, 0xb6, 0x46, 0x7e, 0x05, 0xc3,
0x9a, 0x9f, 0x44, 0x7a, 0xc7, 0x22, 0x93, 0x4f, 0x13, 0x99, 0x3f, 0x02, 0x31, 0xec, 0x27, 0xac, 0x3b, 0xd4, 0xe6, 0x09, 0x4d, 0xba, 0xed, 0x76, 0xa2, 0xe9, 0xf1, 0x1f, 0x6a, 0xfe, 0xfd, 0xe2,
0xdf, 0xb3, 0x14, 0xc9, 0x35, 0x0c, 0xee, 0x51, 0xea, 0xdd, 0x9b, 0xb4, 0xaf, 0x9b, 0x27, 0x9a, 0xd3, 0x73, 0xbc, 0xfc, 0x09, 0x00, 0x00, 0xff, 0xff, 0x5e, 0x1f, 0xc4, 0xb7, 0xa4, 0x02, 0x00,
0x9e, 0xfe, 0x72, 0xf5, 0xbf, 0x5f, 0x5c, 0xb5, 0xbf, 0x57, 0xdf, 0x01, 0x00, 0x00, 0xff, 0xff, 0x00,
0x79, 0x8f, 0x11, 0xab, 0xeb, 0x02, 0x00, 0x00,
} }
protos/course.proto
syntax = "proto3"; syntax = "proto3";
import "common.proto";
package course; package course;
service CourseService { service CourseService {
rpc ListForTop(ListRequest) returns (ListResponse); rpc ListForTop(ListRequest) returns (ListResponse);
rpc GetDetail(DetailRequest) returns(DetailResponse); rpc GetDetail(DetailRequest) returns(DetailResponse);
...@@ -15,7 +13,7 @@ message CourseModel{ ...@@ -15,7 +13,7 @@ message CourseModel{
float course_price=5; float course_price=5;
float course_price2=6; float course_price2=6;
// @inject_tag: gorm:"type:timestamp" // @inject_tag: gorm:"type:timestamp"
common.Timestamp addtime=7; int64 addtime=7;
} }
message ListRequest { message ListRequest {
......
protos/course_topic.proto
syntax = "proto3"; syntax = "proto3";
import "common.proto";
package course; package course;
message CourseTopic{ message CourseTopic{
int32 Id=1; int32 Id = 1;
int32 CourseId=2; int32 CourseId = 2;
int32 CourseDid=3; int32 CourseDid = 3;
int32 Likes=4; int32 Likes = 4;
int32 Unlikes=5; int32 Unlikes = 5;
string Title=6; string Title = 6;
string Content=7; string Content = 7;
int32 UserId=8; int32 UserId = 8;
common.Timestamp Addtime=9; int64 Addtime = 9;
common.Timestamp Updatetime=10; int64 Updatetime = 10;
} }
message CourseTopicReply{ message CourseTopicReply{
int32 Id=1; int32 Id = 1;
int32 TopicId=2; int32 TopicId = 2;
string Content=3; string Content = 3;
int32 UserId=4; int32 UserId = 4;
int32 Likes=5; int32 Likes = 5;
int32 Unlikes=6; int32 Unlikes = 6;
common.Timestamp Addtime=7; int64 Addtime = 7;
} }
message TopicRequest{ message TopicRequest{
int32 CourseId=1; int32 CourseId = 1;
} }
message TopicResponse{ message TopicResponse{
repeated CourseTopic result=1; repeated CourseTopic result = 1;
} }
service CourseTopicService { service CourseTopicService {
rpc GetTopic(TopicRequest) returns (TopicResponse); rpc GetTopic(TopicRequest) returns (TopicResponse);
} }
\ No newline at end of file
service/course_service.go
...@@ -2,7 +2,7 @@ package service ...@@ -2,7 +2,7 @@ package service
import ( import (
"context" "context"
"search_server/Mapper" "search_server/mapper"
. "search_server/protopb/course" . "search_server/protopb/course"
) )
...@@ -14,7 +14,7 @@ type CourseServiceImpl struct{} ...@@ -14,7 +14,7 @@ type CourseServiceImpl struct{}
func (this *CourseServiceImpl) ListForTop(ctx context.Context, req *ListRequest, rsp *ListResponse) error { func (this *CourseServiceImpl) ListForTop(ctx context.Context, req *ListRequest, rsp *ListResponse) error {
course := make([]*CourseModel, 0) course := make([]*CourseModel, 0)
err := Mapper.GetCourseListBySql(req.Size).Find(&course).Error err := mapper.GetCourseListBySql(req.Size).Find(&course).Error
if err != nil { if err != nil {
return err return err
} }
...@@ -24,13 +24,13 @@ func (this *CourseServiceImpl) ListForTop(ctx context.Context, req *ListRequest, ...@@ -24,13 +24,13 @@ func (this *CourseServiceImpl) ListForTop(ctx context.Context, req *ListRequest,
func (this *CourseServiceImpl) GetDetail(ctx context.Context, req *DetailRequest, rsp *DetailResponse) error { func (this *CourseServiceImpl) GetDetail(ctx context.Context, req *DetailRequest, rsp *DetailResponse) error {
//只取课程详细 //只取课程详细
if req.FetchType == 0 || req.FetchType == 1 || req.FetchType == 3 { if req.FetchType == 0 || req.FetchType == 1 || req.FetchType == 3 {
if err := Mapper.GetCourseDetail(int(req.CourseId)).Find(rsp.Course).Error; err != nil { if err := mapper.GetCourseDetail(int(req.CourseId)).Find(rsp.Course).Error; err != nil {
return err return err
} }
} }
//只取计数表详细 //只取计数表详细
if req.FetchType == 2 || req.FetchType == 3 { if req.FetchType == 2 || req.FetchType == 3 {
if err := Mapper.GetCourseCounts(int(req.CourseId)).Find(&rsp.Counts).Error; err != nil { if err := mapper.GetCourseCounts(int(req.CourseId)).Find(&rsp.Counts).Error; err != nil {
return err return err
} }
} }
......
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