// 摘取主要代码段
    func init() {
        // 1. 初始化 项目根路径，参见 variable 常量包，相关路径：app\global\variable\variable.go
    
        //2.检查配置文件以及日志目录等非编译性的必要条件
        checkRequiredFolders()
    
        // 3.初始化全局日志句柄，并载入日志钩子处理函数
        variable.ZapLog = zap_factory.CreateZapFactory(sys_log_hook.ZapLogHandler)
    
        //4.初始化表单参数验证器，注册在容器
        register_validator.RegisterValidator()
    
        // 5.websocket Hub中心启动
        if yml_config.CreateYamlFactory().GetInt("Websocket.Start") == 1 {
            // websocket 管理中心hub全局初始化一份
            variable.WebsocketHub = core.CreateHubFactory()
            if Wh, ok := variable.WebsocketHub.(*core.Hub); ok {
                go Wh.Run()
            }
        }
    
    }

    //1.首先编写参数验证器逻辑，例如：用户注册模块
    // 详情参见：app\http\validator\web\users\register.go

    //2.将以上编写好的表单参数验证器进行注册，便于程序启动时自动加载到容器，路由则从容器调用
    // 详情参见：app\http\validator\common\register_validator\register_validator.go

	//  创建一个后端接口路由组
	V_Backend := routers.Group("/Admin/")
	{

		//  【不需要】中间件验证的路由  用户注册、登录
		v_noAuth := V_Backend.Group("users/")
		{
			v_noAuth.POST("register", validatorFactory.Create(Consts.ValidatorPrefix+"UsersRegister"))
		}

		// 需要中间件验证的路由
		V_Backend.Use(authorization.CheckAuth())
		{
			// 用户组路由
			v_users := V_Backend.Group("users/")
			{
				// 查询 ，这里的验证器直接从容器获取，是因为程序启动时，将验证器注册在了容器，具体代码位置：app\http\validator\Users\xxx
				v_users.GET("index", validatorFactory.Create(Consts.ValidatorPrefix+"UsersShow"))
			}

		}

	}

    // 选取一段代码说明
    type HeaderParams struct {
        authorization string `header:"authorization"`
    }
    ......
	return func(context *gin.Context) {
		//  模拟验证token
		V_HeaderParams := HeaderParams{}

		//  使用ShouldbindHeader 方式获取头参数
		context.ShouldBindHeader(&V_HeaderParams)
        // 对头参数中的token进行验证
		if len(V_HeaderParams.authorization) >= 20 {
        ...
	    context.Next()   // OK 下一步
        }else{
        	context.Abort()  // 不 OK 终止请求
        }

type Register struct {
	Base
	Phone string `form:"phone" json:"phone"  binding:"required,len=11"`    //  验证规则：必填，长度必须=11
	Pass  string `form:"pass" json:"pass" binding:"required,min=3,max=20"` //必填，密码长度范围：【3,20】闭区间
}
// 函数名称受验证器接口约束，命名必须是：CheckParams
func (r Register) CheckParams(context *gin.Context) {
	//1.先按照验证器提供的基本语法，基本可以校验90%以上的不合格参数
	if err := context.ShouldBind(r); err != nil {
        ....
        return
	}

	//  该函数主要是将验证器绑定的字段（成员）以 键=>值 形式直接传递给下一步（控制器）
    //  数据的绑定规则按照 json 标签定义的键为准!
	extraAddBindDataContext := DaTaTransfer.DataAddContext(r, Consts.ValidatorPrefix, context)
	if extraAddBindDataContext == nil {
		response.returnJson(context, http.StatusInternalServerError, Consts.ServerOccurredErrorCode, Consts.ServerOccurredErrorMsg+",UserRegister表单验证器json化失败", "")
	} else {
		// 验证完成，有验证器调用控制器,并将验证器成员(字段)递给控制器，保持上下文数据一致性
		(&Admin.Users{}).Register(extraAddBindDataContext)
	}
}

type Users struct {
}

// 1.用户注册
func (u *Users) Register(context *gin.Context) {

	//  由于本项目骨架已经将表单验证器的字段(成员)绑定在上下文，因此可以按照 GetString()、Getint64()、GetFloat64（）等快捷获取需要的数据类型
	// 当然也可以通过gin框架的上下缘原始方法获取，例如： context.PostForm("name") 获取，这样获取的数据格式为文本，需要自己继续转换
	name := context.GetString(Consts.ValidatorPrefix + "name")
	pass := context.GetString(Consts.ValidatorPrefix + "pass")
	user_ip := context.ClientIP()

    // 如果对参数需要进一步加工，建议将业务逻辑切换到service层进行处理，将处理结果返回
    // 如果参数可以直接进行写库存储，那么可以直接调用 Model 的具体业务模型方法即可 

	if Curd.CreateUserCurdFactory().Register(name, pass, user_ip) {
		response.returnJson(context, http.StatusOK, Consts.CurdStatusOkCode, Consts.CurdStatusOkMsg, "")
	} else {
		response.returnJson(context, http.StatusOK, Consts.CurdRegisterFailCode, Consts.CurdRegisterFailMsg, "")
	}
}

type usersModel struct {
	*BaseModel
	Id       int64  `json:"id"`
	Username string `json:"username"`
	Pass     string `json:"-"`
	Phone    string `json:"phone"`
	RealName string `json:"realname"`
	Status   int    `json:"status"`
	Token    string `json:"-"`
}

// 用户注册（写一个最简单的使用账号、密码注册即可）
func (u *usersModel) Register(username string, pass string, user_ip string) bool {
	sql := "INSERT  INTO tb_users(username,pass,last_login_ip) SELECT ?,?,? FROM DUAL   WHERE NOT EXISTS (SELECT 1  FROM tb_users WHERE  username=?)"
	if u.ExecuteSql(sql, username, pass, user_ip, username) > 0 {
		return true
	}
	return false
}

type UsersCurd struct {
}
 // 预先处理密码加密，然后存储在数据库
func (u *UsersCurd) Register(name string, pass string, user_ip string) bool {
	pass = md5Encrypt.Base64Md5(pass)
	return Model.CreateUserFactory("").Register(name, pass, user_ip)
}

func ReturnJson(Context *gin.Context, http_code int, data_code int, msg string, data interface{}) {

	//Context.Header("key2020","value2020")  	//可以根据实际情况在头部添加额外的其他信息

	// 返回 json数据
	Context.JSON(http_code, gin.H{
		"code": data_code,
		"msg":  msg,
		"data": data,
	})
}

// 将json字符窜以标准json格式返回（例如，从redis读取json、格式的字符串，返回给浏览器json格式）
func ReturnJsonFromString(Context *gin.Context, http_code int, json_str string) {
	Context.Header("Content-Type", "application/json; charset=utf-8")
	Context.String(http_code, json_str)
}
}

func init() {
	//  用于系统信号的监听
	go func() {
		c := make(chan os.Signal)
		signal.Notify(c, os.Interrupt, os.Kill, syscall.SIGQUIT, syscall.SIGINT, syscall.SIGTERM) // 监听可能的退出信号
		received := <-c                                                                           //接收信号管道中的值
		variable.ZapLog.Warn(consts.ProcessKilled, zap.String("信号值", received.String()))
		(event_manage.CreateEventManageFactory()).FuzzyCall(variable.EventDestroyPrefix)
		close(c)
		os.Exit(1)
	}()

}