crud全部调整

Author: LinkinStars

src/base/httper/http_handle.go

@@ -9,52 +9,57 @@ import (
 
 "base/logger"
 "base/validator"
+"myerr"
 )
 
-// 统一处理异常，统一处理日志，统一处理返回
+// HandleResponse 统一处理异常，统一处理日志，统一处理返回
 func HandleResponse(c *gin.Context, err error, data interface{}) {
 // 如果没有错误，就是正常请求
 if err == nil {
-SendResponseSuccess(c, "操作成功", data)
+SendSuccessResp(c, "操作成功", data)
 return
 }
 
 // 针对不同的错误类型进行处理
 switch errors.Cause(err).(type) {
+case *myerr.ParameterError:
+SendFailResp(c, http.StatusBadRequest, err.Error())
 default:
 logStackInfo(err)
-SendResponseFail(c, http.StatusBadRequest, err.Error())
+SendFailResp(c, http.StatusInternalServerError, err.Error())
 }
 
 return
 }
 
-// 绑定参数并验证参数
+// BindAndCheck 绑定参数并验证参数
 // true: 确实存在问题，会返回400错误
 // false: 不存在问题，验证通过
 func BindAndCheck(ctx *gin.Context, data interface{}) bool {
 // 参数映射
 if err := ctx.Bind(data); err != nil {
-HandleResponse(ctx, err, nil)
+// 当需要的参数类型不匹配的时候会出现错误，属于开发测试时就应该发现的异常
+HandleResponse(ctx, myerr.NewParameterError("绑定参数异常"), nil)
 return true
 }
 
 // 验证参数
-if err := validator.GlobalValidate.Check(data); err != nil {
-HandleResponse(ctx, err, nil)
+if err := validator.GlobalValidator.Check(data); err != nil {
+HandleResponse(ctx, myerr.NewParameterError(err.Error()), nil)
 return true
 }
 
 return false
 }
 
-// 堆栈信息接口用于内部转换使用
+// stackTracer 堆栈信息接口用于内部转换使用
 type stackTracer interface {
 StackTrace() errors.StackTrace
 }
 
-// 判断如果包含堆栈信息的封装就打印出相关堆栈信息，如果没有封装就打印原本错误信息
+// logStackInfo 打印错误
 func logStackInfo(err error) {
+// 如果包含堆栈信息的封装就打印出相关堆栈信息，如果没有封装就打印原本错误信息
 if e, ok := err.(stackTracer); ok {
 stacks := e.StackTrace()
 var stackEntries []string

src/base/pager/pager.go

@@ -24,10 +24,11 @@ func InitRouter(port string) {
 r.Use(ginzap.Ginzap(zap.L(), "2006-01-02 15:04:05.000", false))
 
 r.POST("/gwt/api/v1/user", controller.AddUser)
-r.DELETE("/gwt/api/v1/user", controller.DeleteUser)
+r.DELETE("/gwt/api/v1/user", controller.RemoveUser)
 r.PUT("/gwt/api/v1/user", controller.UpdateUser)
 r.GET("/gwt/api/v1/user/:id", controller.GetUser)
-r.POST("/gwt/api/v1/users")
+r.GET("/gwt/api/v1/users", controller.GetUsers)
+r.GET("/gwt/api/v1/users/page", controller.GetUsersPage)
 
 // swagger
 r.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))

src/base/pager/pagination.go

@@ -11,14 +11,16 @@ import (
 "gopkg.in/go-playground/validator.v9/translations/zh"
 )
 
+// MyValidator 自定义验证器
 type MyValidator struct {
 Validate *validator.Validate
 Trans ut.Translator
 }
 
-var GlobalValidate MyValidator
+// GlobalValidator 全局验证器
+var GlobalValidator MyValidator
 
-// 初始化验证器
+// InitValidator 初始化验证器
 func InitValidator() {
 zhs := zhongwen.New()
 uni := ut.New(zhs, zhs)
@@ -40,11 +42,11 @@ func InitValidator() {
 panic(err)
 }
 
-GlobalValidate.Validate = validate
-GlobalValidate.Trans = trans
+GlobalValidator.Validate = validate
+GlobalValidator.Trans = trans
 }
 
-// 验证器通用验证方法
+// Check 验证器通用验证方法
 func (m *MyValidator) Check(value interface{}) error {
 // 首先使用validator.v9进行验证
 err := m.Validate.Struct(value)
@@ -67,16 +69,13 @@ func (m *MyValidator) Check(value interface{}) error {
 }
 
 // 如果它实现了CanCheck接口，就进行自定义验证
-if reflect.TypeOf(value).Implements(canCheckType) {
-return value.(CanCheck).Check()
+if v, ok := value.(CanCheck); ok {
+return v.Check()
 }
 return nil
 }
 
-// CanCheck接口类型，用于判断是否实现该接口
-var canCheckType = reflect.TypeOf(new(CanCheck)).Elem()
-
-// 如果需要特殊校验，可以实现验证接口，或者通过自定义tag标签实现
+// CanCheck 如果需要特殊校验，可以实现验证接口，或者通过自定义tag标签实现
 type CanCheck interface {
 Check() error
 }

src/base/router/router.go

@@ -1,6 +1,8 @@
 package main
 
 import (
+_ "github.com/go-sql-driver/mysql"
+
 "base/config"
 "base/db"
 "base/logger"
@@ -12,13 +14,13 @@ func main() {
 // 读取配置文件
 config.InitConfig("./default-conf.yml")
 
-c := config.GlobalConfig
-l := c.Logger
-m := c.Mysql
-s := c.Server
+all := config.All
+l := all.Logger
+m := all.Mysql
+s := all.Server
 
 // 初始化日志
-logger.InitLogger("golang-web-template", l.Path, l.MaxAge, l.RotationTime, l.Level)
+logger.InitLogger(l.Level, "golang-web-template", l.Path, l.MaxAge, l.RotationTime)
 logger.Debug("debug日志")
 logger.Info("info日志")
 logger.Warn("warn日志")
@@ -27,12 +29,12 @@ func main() {
 // 初始化数据库
 db.InitDB(m.Connection, m.MaxIdle, m.MaxOpen)
 
-// 初始化redis
+// 初始化redis ...
 
 // 初始化验证器
 validator.InitValidator()
 
-// 初始化pprof
+// 初始化pprof ...
 
 // 初始化路由
 router.InitRouter(s.HttpPort)