115 lines
3.6 KiB
Plaintext
115 lines
3.6 KiB
Plaintext
#{moduleName}_proto "service/api/proto/#{moduleName}/proto"
|
|
|
|
_Default#{EntityName} *logic.#{EntityName}
|
|
|
|
_Default#{EntityName} = logic.New#{EntityName}(store)
|
|
|
|
// #{EntityName}
|
|
func (s *Service) OpCreate#{EntityName}(ctx *gin.Context, req *#{moduleName}_proto.OpCreateReq) (ec errcode.ErrCode) {
|
|
ec = errcode.ErrCode#{EntityName}SrvOk
|
|
err := _Default#{EntityName}.OpCreate(ctx, req)
|
|
if err != nil {
|
|
logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
|
|
ec = errcode.ErrCode#{EntityName}SrvFail
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *Service) OpUpdate#{EntityName}(ctx *gin.Context, req *#{moduleName}_proto.OpUpdateReq) (ec errcode.ErrCode) {
|
|
ec = errcode.ErrCode#{EntityName}SrvOk
|
|
err := _Default#{EntityName}.OpUpdate(ctx, req)
|
|
if err == qmgo.ErrNoSuchDocuments {
|
|
ec = errcode.ErrCode#{EntityName}NotExist
|
|
err = nil
|
|
return
|
|
}
|
|
if err != nil {
|
|
logger.Error("OpUpdate fail, req: %v, err: %v", util.ToJson(req), err)
|
|
ec = errcode.ErrCode#{EntityName}SrvFail
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *Service) OpDelete#{EntityName}(ctx *gin.Context, id int64) (ec errcode.ErrCode) {
|
|
ec = errcode.ErrCode#{EntityName}SrvOk
|
|
err := _Default#{EntityName}.OpDelete(ctx, id)
|
|
if err != nil {
|
|
logger.Error("OpDelete fail, id: %v, err: %v", id, err)
|
|
ec = errcode.ErrCode#{EntityName}SrvFail
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *Service) OpGet#{EntityName}List(ctx *gin.Context, req *#{moduleName}_proto.OpListReq) (list []*dbstruct.#{EntityName}, ec errcode.ErrCode) {
|
|
ec = errcode.ErrCode#{EntityName}SrvOk
|
|
list, err := _Default#{EntityName}.OpList(ctx, req)
|
|
if err != nil {
|
|
logger.Error("OpGet#{EntityName}List fail, req: %v, err: %v", util.ToJson(req), err)
|
|
ec = errcode.ErrCode#{EntityName}SrvFail
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
// #{EntityName}
|
|
func (s *Service) ApiCreate#{EntityName}(ctx *gin.Context, req *#{moduleName}_proto.ApiCreateReq) (ec errcode.ErrCode) {
|
|
ec = errcode.ErrCode#{EntityName}SrvOk
|
|
err := _Default#{EntityName}.OpCreate(ctx, &#{moduleName}_proto.OpCreateReq{
|
|
BaseRequest: req.BaseRequest,
|
|
#{EntityName}: req.#{EntityName},
|
|
})
|
|
if err != nil {
|
|
logger.Error("OpCreate fail, req: %v, err: %v", util.ToJson(req), err)
|
|
ec = errcode.ErrCode#{EntityName}SrvFail
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *Service) ApiUpdate#{EntityName}(ctx *gin.Context, req *#{moduleName}_proto.ApiUpdateReq) (ec errcode.ErrCode) {
|
|
ec = errcode.ErrCode#{EntityName}SrvOk
|
|
err := _Default#{EntityName}.OpUpdate(ctx, &#{moduleName}_proto.ApiUpdateReq{
|
|
BaseRequest: req.BaseRequest,
|
|
#{EntityName}: req.#{EntityName},
|
|
})
|
|
if err == qmgo.ErrNoSuchDocuments {
|
|
ec = errcode.ErrCode#{EntityName}NotExist
|
|
err = nil
|
|
return
|
|
}
|
|
if err != nil {
|
|
logger.Error("OpUpdate fail, req: %v, err: %v", util.ToJson(req), err)
|
|
ec = errcode.ErrCode#{EntityName}SrvFail
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *Service) ApiDelete#{EntityName}(ctx *gin.Context, id int64) (ec errcode.ErrCode) {
|
|
ec = errcode.ErrCode#{EntityName}SrvOk
|
|
err := _Default#{EntityName}.OpDelete(ctx, id)
|
|
if err != nil {
|
|
logger.Error("OpDelete fail, id: %v, err: %v", id, err)
|
|
ec = errcode.ErrCode#{EntityName}SrvFail
|
|
return
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *Service) ApiGet#{EntityName}List(ctx *gin.Context, req *#{moduleName}_proto.ApiListReq) (list []*dbstruct.#{EntityName}, ec errcode.ErrCode) {
|
|
ec = errcode.ErrCode#{EntityName}SrvOk
|
|
list, err := _Default#{EntityName}.OpList(ctx, &#{moduleName}_proto.OpListReq{
|
|
BaseRequest: req.BaseRequest,
|
|
Offset: req.Offset,
|
|
Limit: req.Limit,
|
|
})
|
|
if err != nil {
|
|
logger.Error("OpGet#{EntityName}List fail, req: %v, err: %v", util.ToJson(req), err)
|
|
ec = errcode.ErrCode#{EntityName}SrvFail
|
|
return
|
|
}
|
|
return
|
|
} |