框架及用户相关

controllers/auth.go

@@ -1,54 +1,41 @@
 package controllers
 
-// Authenticate 权限验证
-// 其中 token 的处理方式是
-// 1、获取 request 中 token
-// 2、放入 Context 中
-// 3、校验 token
-// 4、结束后，设置过期并从 Context 中删除
-// 5、生成新的 token， 并放入 Context 中
-// func (c *BaseController) authenticate() {
-// 	c.serv = service.NewSysServ(c.Context)
-
-// 	// 鉴权 - 并初始化上下文
-// 	res := c.serv.AuthAndInitCtx(c.Ctx)
-
-// 	if res != nil {
-// 		code := http.StatusOK
-// 		if res["code"] != nil {
-// 			code = res["code"].(int)
-// 		}
-
-// 		if code != http.StatusOK {
-// 			err := res["error"].(error)
-// 			data := map[string]interface{}{}
-
-// 			if res["message"] != nil {
-// 				data = res["message"].(map[string]interface{})
-// 			}
-
-// 			c.ResponseData(data, err, code)
-// 		}
-// 	}
-// }
-
-// // SetTokenExipre 设置 token 过期
-// func (c *BaseController) SetTokenExipre(uid string) {
-// 	token := c.Context.Get("token")
-// 	if token != nil {
-// 		c.serv.UpdateTokenExpire(token.(string), uid)
-// 	}
-
-// 	c.Context.Set("token", "")
-// }
-
-// // CreateNewToken 新 token
-// func (c *BaseController) CreateNewToken() {
-
-// 	batchNo := ""
-// 	if c.Context.Get("token-batch") != nil {
-// 		batchNo = c.Context.Get("token-batch").(string)
-// 	}
-
-// 	c.Context.Set("token", c.serv.NewToken(batchNo))
-// }
+import (
+	"strings"
+	"wechat-conf/service/user"
+	"wechat-conf/utils"
+
+	"github.com/astaxie/beego"
+)
+
+const (
+	SESSION_USER = "wechat-conf.user"
+)
+
+// auth 鉴权
+func (c *BaseController) auth() {
+	apiPrefix := beego.AppConfig.String("ApiPrefix")
+	path := strings.TrimPrefix(c.Ctx.Request.URL.Path, apiPrefix)
+	method := c.Ctx.Request.Method
+	userID, _ := c.GetSession(SESSION_USER).(string)
+	serv := user.NewUserServ(c.Context)
+
+	code, err := serv.CheckUserRoute(userID, path, method)
+	if err != nil {
+		c.ResponseError(err, code)
+	}
+
+	if userID != "" {
+		userDetail, err := serv.GetUserByID(userID)
+
+		if err != nil {
+			c.ResponseError(err)
+		}
+
+		if userDetail.UserId == "" {
+			c.ResponseError(utils.LogError("用户不存在, 请重新登录"))
+		}
+
+		c.Context.Set("user", userDetail)
+	}
+}

controllers/base.go

@@ -28,7 +28,7 @@ func (c *BaseController) Prepare() {
 	c.initContext()
 
 	// 鉴权
-	// c.authenticate()
+	c.auth()
 
 	// 路由对应的实际 Controller 初始化
 	c.initController()

controllers/user.go

@@ -0,0 +1,91 @@
+package controllers
+
+import (
+	"wechat-conf/models/model"
+	"wechat-conf/service/user"
+	"wechat-conf/utils"
+
+	"github.com/astaxie/beego"
+)
+
+// UserController 用户
+type UserController struct {
+	serv *user.UserServ
+	BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *UserController) Constructor() {
+	c.serv = user.NewUserServ(c.Context)
+}
+
+// Login 用户登录
+func (c *UserController) Login() {
+
+	var user *model.SysUser
+	var err error
+	// 如果有 session 就算已经登录
+	userId := c.GetSession(SESSION_USER)
+	if userId != nil {
+		c.ResponseError(utils.LogError("用户已经登录!"))
+	}
+	userName := c.GetString("UserName")
+	pwd := c.GetString("UserPass")
+	if userName == "" || pwd == "" {
+		c.ResponseError(utils.LogError("用户名或密码不能为空！"))
+	}
+	user, err = c.serv.ValidUserNameLogin(userName, pwd)
+	if err != nil {
+		beego.Error("用户登录失败, ", err)
+		c.ResponseError(utils.LogError("用户名或密码错误"))
+	}
+
+	// 密码不能送到前端
+	user.Pwd = ""
+
+	c.SetSession(SESSION_USER, user.UserId)
+	c.ResponseJSON(user)
+}
+
+// SignOut 登出
+// @Title 登出
+// @Description 登出
+// @Success 200 string ok-string
+// @Failure >300 error message
+func (c *UserController) SignOut() {
+	c.Context.Set("user", nil)
+	c.DestroySession()
+
+	c.ResponseJSON("ok")
+}
+
+// UpdatePassword 更新用户密码
+// @Title 更新用户密码
+// @Description 更新用户密码
+// @Param   oriPasswd     form    string  true        "旧密码"
+// @Param   newPasswd     form    string  true        "新密码"
+// @Success 200 string ok-string
+// @Failure >300 error message
+func (c *UserController) UpdatePassword() {
+	oriPasswd := c.GetString("oriPasswd")
+	newPasswd := c.GetString("newPasswd")
+	user := c.Context.Get("user").(*model.SysUser)
+
+	if !c.serv.ValidatePassword(user, oriPasswd) {
+		c.ResponseError(utils.LogError("原始密码不正确"))
+	}
+
+	if err := c.serv.UpdatePassword(user.UserId, newPasswd); err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("ok")
+}
+
+// GetUser 获取用户信息
+func (c *UserController) GetUser() {
+	user := c.Context.Get("user").(*model.SysUser)
+	c.ResponseJSON(user)
+}

models/user/user.go

@@ -0,0 +1,67 @@
+package user
+
+import (
+	"wechat-conf/models/model"
+	"wechat-conf/utils"
+
+	"github.com/go-xorm/xorm"
+	"github.com/yl10/kit/encrypt"
+)
+
+// UserDAO 当前数据库操作对象
+type UserDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewUserDAO New Inst
+func NewUserDAO(ctx *utils.Context) *UserDAO {
+	return &UserDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}
+
+//GetUserByUserName  通过用户名获取用户信息
+func (m *UserDAO) GetUserByUserName(name string) (model.SysUser, error) {
+	query := `
+			SELECT * FROM
+		    	sys_user t
+				WHERE
+				user_name = '` + name + `'`
+
+	user := new(model.SysUser)
+	if has, err := m.db.Sql(query).Get(user); err != nil {
+		return *user, err
+	} else if !has {
+		return *user, utils.LogError("账户不存在")
+	}
+
+	return *user, nil
+}
+
+// UpdatePassword 更新用户密码
+func (m *UserDAO) UpdatePassword(userId, newPass string) error {
+	password := encrypt.Md5(newPass, userId)
+
+	sql := "update sys_user set pwd=? where user_id=?"
+
+	_, err := m.db.Exec(sql, password, userId)
+	if err != nil {
+		return utils.LogError("更新新密码出错", err)
+	}
+
+	return nil
+}
+
+// GetUserByID 获取用户信息
+func (m *UserDAO) GetUserByID(userId string) (*model.SysUser, error) {
+	var user model.SysUser
+	_, err := m.db.Where("user_id=?", userId).Get(&user)
+
+	if err != nil {
+		return nil, utils.LogError("获取人员信息失败", err)
+	}
+
+	return &user, nil
+}

service/sys.go

@@ -19,490 +19,3 @@ func NewSysServ(ctx *utils.Context) *SysServ {
 		ctx: ctx,
 	}
 }
-
-// // AuthAndInitCtx 鉴权
-// // gctx 是 beego 框架中的 Context
-// func (s *SysServ) AuthAndInitCtx(gctx *context.Context) map[string]interface{} {
-// 	// 确认机构
-// 	orgID := gctx.Input.Query(":org")
-// 	if orgID == "" {
-// 		return map[string]interface{}{
-// 			"code":  http.StatusBadRequest,
-// 			"error": errors.New("接口地址访问不正确"),
-// 		}
-// 	}
-// 	if err := s.SetOrgByID(orgID); err != nil {
-// 		return map[string]interface{}{
-// 			"code":  http.StatusInternalServerError,
-// 			"error": err,
-// 		}
-// 	}
-
-// 	// 客户端类型
-// 	// 通过 UA 判断
-// 	clientType := utils.GetClientType(gctx.Request)
-
-// 	// pc 管理端
-// 	if clientType == utils.ClientAdmin {
-// 		return s.authPCAdmin(gctx)
-// 	}
-
-// 	// 小程序 端
-// 	if strings.Index(gctx.Input.URI(), "/wechat/mini") > -1 {
-// 		return s.authMini(gctx)
-// 	}
-
-// 	// wechat 端
-// 	if clientType == utils.ClientWechat {
-// 		return s.authWechat(gctx)
-// 	}
-
-// 	// if clientType == utils.ClientMini {
-// 	// 	return s.authMini(gctx)
-// 	// }
-
-// 	return map[string]interface{}{
-// 		"code":  http.StatusBadRequest,
-// 		"error": errors.New("暂无该客户端的 API"),
-// 	}
-// }
-
-// // NewToken 设置 TOKEN
-// // 15 分钟后过期
-// func (s *SysServ) NewToken(batch string) string {
-// 	var token *utils.JWTToken
-// 	exp := time.Now().Local().Add(15 * time.Second)
-
-// 	if s.ctx.Get("userMap") != nil {
-// 		userMap := s.ctx.Get("userMap").(model.TaUserMapping)
-
-// 		token = &utils.JWTToken{
-// 			Guest:   false,
-// 			ID:      userMap.Openid,
-// 			Expire:  exp,
-// 			BatchNo: batch,
-// 		}
-// 	} else if s.ctx.Get("user") != nil {
-// 		user := s.ctx.Get("user").(model.SysUser)
-
-// 		token = &utils.JWTToken{
-// 			Guest:   false,
-// 			ID:      user.UserId,
-// 			Expire:  exp,
-// 			BatchNo: batch,
-// 		}
-// 	} else {
-// 		token = &utils.JWTToken{
-// 			Guest:  true,
-// 			Expire: exp,
-// 		}
-// 	}
-
-// 	tokenEncodeStr, err := utils.CreateToken(token.ToMap())
-// 	if err != nil {
-// 		utils.LogError("系统生成 Token 失败: " + err.Error())
-// 		return ""
-// 	}
-
-// 	// 入库
-// 	if !token.Guest {
-// 		if err := models.InsertToken(tokenEncodeStr, token.ID, batch, exp); err != nil {
-// 			utils.LogError("入库 Token 失败: " + err.Error())
-// 			return tokenEncodeStr
-// 		}
-// 	}
-
-// 	return tokenEncodeStr
-// }
-
-// // authPCAdmin
-// // 管理端 API 校验
-// func (s *SysServ) authPCAdmin(gctx *context.Context) map[string]interface{} {
-// 	if !s.needAuth(gctx) {
-// 		return nil
-// 	}
-
-// 	// 获取 token
-// 	token, err := s.getToken(gctx)
-// 	if err != nil {
-// 		// token 报错一律视为需要重新登录
-// 		return map[string]interface{}{
-// 			"code":  http.StatusUnauthorized,
-// 			"error": err,
-// 		}
-// 	}
-
-// 	if token.ID == "" || token.Guest == true {
-// 		return map[string]interface{}{
-// 			"code":  http.StatusUnauthorized,
-// 			"error": errors.New("用户未登录"),
-// 		}
-// 	}
-
-// 	if err := s.SetUserProfile(token.ID); err != nil {
-// 		return map[string]interface{}{
-// 			"code":  http.StatusInternalServerError,
-// 			"error": err,
-// 		}
-// 	}
-
-// 	return nil
-// }
-
-// func (s *SysServ) authWechat(gctx *context.Context) map[string]interface{} {
-// 	var wxUser *utils.WechatUser
-// 	var openID string
-
-// 	if beego.BConfig.RunMode == "dev" {
-// 		openID = "OPENID"
-// 	} else {
-// 		// 初始化微信配置
-// 		if err := s.initWechatClient(s.org.OrgId); err != nil {
-// 			utils.LogError("初始化微信服务失败: " + err.Error())
-
-// 			return map[string]interface{}{
-// 				"code":  http.StatusInternalServerError,
-// 				"error": errors.New("初始化微信服务失败"),
-// 			}
-// 		}
-
-// 		// 微信 code
-// 		code := gctx.Input.Query("code")
-
-// 		// 获取 token
-// 		token, err := s.getToken(gctx)
-// 		if err != nil {
-// 			tokenStr := s.ctx.Get("token").(string)
-// 			if tokenStr != "" {
-// 				// token 报错一律视为需要重新登录
-// 				return map[string]interface{}{
-// 					"code":  http.StatusUnauthorized,
-// 					"error": err,
-// 					"message": map[string]interface{}{
-// 						"appid": utils.GetWxAppID(s.org.OrgId),
-// 					},
-// 				}
-// 			}
-// 		}
-
-// 		// 未登录 或 未验证
-// 		if token == nil || token.ID == "" {
-// 			if code == "" {
-// 				return map[string]interface{}{
-// 					"code":  http.StatusUnauthorized,
-// 					"error": errors.New("请授权微信用户登录"),
-// 					"message": map[string]interface{}{
-// 						"appid": utils.GetWxAppID(s.org.OrgId),
-// 					},
-// 				}
-// 			}
-
-// 			// 微信用户信息
-// 			var err error
-// 			wxUser, err = s.wechartSignIn(gctx, code)
-// 			if err != nil {
-// 				return map[string]interface{}{
-// 					"code":  http.StatusInternalServerError,
-// 					"error": err,
-// 				}
-// 			}
-
-// 			if wxUser == nil {
-// 				return map[string]interface{}{
-// 					"code":  http.StatusInternalServerError,
-// 					"error": errors.New("请先关注公众号"),
-// 				}
-// 			}
-
-// 			utils.LogError("获取到微信人员: ", wxUser)
-
-// 			openID = wxUser.OpenID
-// 		} else {
-// 			openID = token.ID
-// 		}
-// 	}
-
-// 	// 查询数据库是否存在已有映射
-// 	userMapList, err := models.GetUserMappingByOpenID(openID)
-// 	if err != nil {
-// 		utils.LogError("校验人员失败: " + err.Error())
-// 		return map[string]interface{}{
-// 			"code":  http.StatusInternalServerError,
-// 			"error": errors.New("校验人员失败"),
-// 		}
-// 	}
-
-// 	var userMapping *model.TaUserMapping
-// 	for _, ump := range userMapList {
-// 		if openID == ump.Openid && models.ACCMAP_WECHAT == ump.AccountType {
-// 			userMapping = &ump
-// 		}
-// 	}
-
-// 	// 如果尚无人员映射信息, 代表人员初次使用本系统
-// 	if userMapping == nil {
-// 		// 如果没有微信用户信息, 代表产生了未知异常
-// 		if wxUser == nil || wxUser.OpenID == "" {
-// 			return map[string]interface{}{
-// 				"code":  http.StatusInternalServerError,
-// 				"error": errors.New("系统异常, 请清空缓存后重试"),
-// 			}
-// 		}
-
-// 		wxInfoJSON, err := json.Marshal(wxUser)
-// 		if err != nil {
-// 			utils.LogError("转换微信json信息失败: " + err.Error())
-// 			return map[string]interface{}{
-// 				"code":  http.StatusInternalServerError,
-// 				"error": errors.New("微信信息异常"),
-// 			}
-// 		}
-
-// 		userMapping = &model.TaUserMapping{
-// 			AccountType: models.ACCMAP_WECHAT,
-// 			Openid:      openID,
-// 			Uuid:        wxUser.UnionID,
-// 			AccountInfo: string(wxInfoJSON),
-// 		}
-// 	}
-
-// 	// 防止JSON解析失败
-// 	if userMapping.AccountInfo == "" {
-// 		userMapping.AccountInfo = "{}"
-// 	}
-
-// 	// 更新映射信息, 没有的话则插入
-// 	err = models.EditUserMapping(userMapping)
-// 	if err != nil {
-// 		utils.LogError("保存用户映射信息失败: " + err.Error())
-// 		return map[string]interface{}{
-// 			"code":  http.StatusInternalServerError,
-// 			"error": errors.New("更新用户信息失败"),
-// 		}
-// 	}
-// 	s.ctx.Set("userMap", *userMapping)
-
-// 	// if !s.needAuth(gctx) {
-// 	// 	return nil
-// 	// }
-
-// 	var cust *model.TaCustomer
-
-// 	// 如果只有映射, 但是没有人员信息
-// 	// 则新增人员
-// 	if userMapping.UserId == "" {
-// 		cust, err = s.saveNewCustomer(wxUser, userMapping)
-// 		if err != nil {
-// 			return map[string]interface{}{
-// 				"code":  http.StatusInternalServerError,
-// 				"error": err,
-// 			}
-// 		}
-// 	} else {
-// 		cust, err = models.GetCustomerByID(userMapping.UserId)
-// 		if err != nil {
-// 			utils.LogError("查询用户信息失败: " + err.Error())
-// 			return map[string]interface{}{
-// 				"code":  http.StatusInternalServerError,
-// 				"error": err,
-// 			}
-// 		}
-// 	}
-// 	s.ctx.Set("customer", *cust)
-
-// 	if cust.UserId != "" {
-// 		if err := s.SetUserProfile(cust.UserId); err != nil {
-// 			return map[string]interface{}{
-// 				"code":  http.StatusInternalServerError,
-// 				"error": err,
-// 			}
-// 		}
-// 	}
-
-// 	return nil
-// }
-
-// // 小程序端暂时无人员或者其他业务要求
-// func (s *SysServ) authMini(gctx *context.Context) map[string]interface{} {
-// 	if err := s.initMiniClient(s.org.OrgId); err != nil {
-// 		utils.LogError("初始化小程序服务失败: " + err.Error())
-
-// 		return map[string]interface{}{
-// 			"code":  http.StatusInternalServerError,
-// 			"error": errors.New("初始化小程序服务失败"),
-// 		}
-// 	}
-
-// 	return nil
-// }
-
-// // wechartSignIn 使用 code 微信登录
-// func (s *SysServ) wechartSignIn(gctx *context.Context, code string) (*utils.WechatUser, error) {
-// 	// 获取 微信信息
-// 	// 可能出现的情况是 openid 获取到了, 但是详情没有获取到
-// 	wxUserMap, err := utils.WxClientFor(s.org.OrgId).GetUserInfo(code)
-// 	if err != nil {
-// 		utils.LogError("获取微信信息失败: " + err.Error())
-
-// 		if wxUserMap == nil {
-// 			return nil, errors.New("获取微信信息失败")
-// 		}
-// 	}
-
-// 	return utils.MapToWechatUser(wxUserMap), nil
-// }
-
-// func (s *SysServ) getToken(gctx *context.Context) (*utils.JWTToken, error) {
-// 	tokenEnStr := gctx.Input.Query("token")
-// 	if tokenEnStr == "" {
-// 		tokenRaw := gctx.Input.Header(utils.TokenHeader)
-// 		if tokenRaw == "" {
-// 			return new(utils.JWTToken), nil
-// 		}
-
-// 		tokenEnStr = strings.Trim(strings.TrimLeft(tokenRaw, utils.TokenSchema), " ")
-// 	} else {
-// 		tokenEnStr = strings.Trim(strings.TrimLeft(tokenEnStr, utils.TokenSchema), " ")
-// 	}
-
-// 	s.ctx.Set("token", tokenEnStr)
-
-// 	token, err := utils.PareseToken(tokenEnStr)
-// 	if err != nil {
-// 		utils.LogError("解析 Token 失败: " + err.Error())
-// 		return nil, errors.New("解析Token失败或已过期")
-// 	}
-
-// 	// 校验 token
-// 	tk, err := models.GetToken(tokenEnStr)
-// 	if err != nil {
-// 		utils.LogError("查询 Token 失败: " + err.Error())
-// 		return nil, errors.New("校验Token失败或已过期")
-// 	}
-
-// 	if tk.Status == models.STATUS_DEL {
-// 		return nil, errors.New("超时 或者 Token 已过期")
-// 	}
-
-// 	s.ctx.Set("token-batch", tk.BatchNo)
-// 	return utils.MapToJWTToken(token), nil
-// }
-
-// // UpdateTokenExpire 更新 token 为过期
-// // 如果发生错误, 此处选择忽略
-// func (s *SysServ) UpdateTokenExpire(token, uid string) {
-// 	if err := models.UpdateTokenExpire(token, uid); err != nil {
-// 		utils.LogError("更新 Token 过期失败: " + err.Error())
-// 	}
-// }
-
-// func (s *SysServ) needAuth(gctx *context.Context) bool {
-// 	route := gctx.Input.URL()
-// 	apiPrefix := beego.AppConfig.String("api::prefix")
-// 	guestAPI := beego.AppConfig.String("api::guest")
-
-// 	if strings.Index(route, apiPrefix+strings.Split(guestAPI, ":")[0]) > -1 {
-// 		return false
-// 	}
-
-// 	return true
-// }
-
-// // SetUserProfile 设置用户信息
-// func (s *SysServ) SetUserProfile(id string) error {
-// 	user, err := models.GetPureUserInfo(id)
-// 	if err != nil {
-// 		return utils.LogError("获取用户基本信息失败: " + err.Error())
-// 	}
-// 	s.ctx.Set("user", *user)
-
-// 	cases, err := models.GetUserCase(id)
-// 	if err != nil {
-// 		return utils.LogError("获取用户案场信息失败: " + err.Error())
-// 	}
-// 	s.ctx.Set("cases", cases)
-
-// 	found := false
-// 	for _, cs := range cases {
-// 		if cs.IsBelong == models.BOOL_TRUE {
-// 			found = true
-// 			s.ctx.Set("currentCase", cs)
-// 		}
-// 	}
-
-// 	if !found {
-// 		utils.LogError("用户没有设置默认案场")
-// 	}
-
-// 	return nil
-// }
-
-// // saveNewCustomer 新增用户
-// func (s *SysServ) saveNewCustomer(wxUser *utils.WechatUser, userMap *model.TaUserMapping) (*model.TaCustomer, error) {
-// 	cust := model.TaCustomer{
-// 		CustomerName: wxUser.NickName,
-// 		Name:         wxUser.NickName,
-// 		Sex:          int(wxUser.Sex),
-// 		Headimgurl:   wxUser.HeadImgURL,
-// 		OrgId:        s.org.OrgId,
-// 	}
-
-// 	if err := models.SaveCustomer(&cust); err != nil {
-// 		utils.LogError("更新客户信息失败: " + err.Error())
-// 		return nil, errors.New("更新客户信息失败")
-// 	}
-
-// 	account := new(model.TaCustomerAccount)
-// 	account.CustomerId = cust.CustomerId
-// 	account.CustomerName = cust.CustomerName
-// 	account.OrgId = cust.OrgId
-// 	account.Amount = "0"
-// 	account.Points = "0"
-// 	account.PayedAmount = "0"
-// 	account.PayedPoints = "0"
-
-// 	if err := models.SaveAccount(account); err != nil {
-// 		utils.LogError("插入账户信息失败: " + err.Error())
-// 		return nil, errors.New("更新客户信息失败")
-// 	}
-
-// 	// 更新映射表信息
-// 	userMap.UserId = cust.CustomerId
-// 	if err := models.UpdateUserMapping(userMap, []string{"user_id"}); err != nil {
-// 		utils.LogError("更新用户映射信息失败:" + err.Error())
-// 		return nil, errors.New("映射用户信息失败")
-// 	}
-
-// 	return &cust, nil
-// }
-
-// // initWechatClient 初始化微信客户端
-// func (s *SysServ) initWechatClient(orgID string) error {
-// 	cert, err := models.GetWeChatConfig(orgID, models.WECHAT_WX)
-// 	if err != nil {
-// 		utils.LogError("获取微信配置失败: " + err.Error())
-// 		return errors.New("获取微信配置失败")
-// 	}
-
-// 	if cert == nil {
-// 		return errors.New("未找到微信配置")
-// 	}
-
-// 	utils.WxClientSingleton(orgID, cert)
-// 	return nil
-// }
-
-// func (s *SysServ) initMiniClient(orgID string) error {
-// 	cert, err := models.GetWeChatConfig(orgID, models.WECHAT_MINI)
-// 	if err != nil {
-// 		utils.LogError("获取小程序配置失败: " + err.Error())
-// 		return errors.New("获取小程序配置失败")
-// 	}
-
-// 	if cert == nil {
-// 		return errors.New("未找到小程序配置")
-// 	}
-
-// 	utils.MiniClientSingleton(orgID, cert)
-// 	return nil
-// }

service/user/user.go

@@ -0,0 +1,74 @@
+package user
+
+import (
+	"net/http"
+	"strings"
+	"wechat-conf/models/model"
+	"wechat-conf/models/user"
+	"wechat-conf/utils"
+	"wechat/helper"
+
+	"github.com/yl10/kit/encrypt"
+)
+
+// UserServ 用户
+type UserServ struct {
+	ctx *utils.Context
+	dao *user.UserDAO
+}
+
+// NewUserServ 初始化
+func NewUserServ(ctx *utils.Context) *UserServ {
+	return &UserServ{
+		ctx: ctx,
+		dao: user.NewUserDAO(ctx),
+	}
+}
+
+// CheckUserRoute 判断用户理由
+func (s *UserServ) CheckUserRoute(userId, route, method string) (int, error) {
+
+	if strings.Index(route, "admin") < 0 {
+		return http.StatusOK, nil
+	}
+
+	// 如果没有登录
+	if userId == "" {
+		return http.StatusUnauthorized, utils.LogError("请先登录系统")
+	}
+
+	return http.StatusOK, nil
+}
+
+// ValidUserNameLogin 验证登陆
+func (s *UserServ) ValidUserNameLogin(userName, pass string) (*model.SysUser, error) {
+	user, err := s.dao.GetUserByUserName(userName)
+	if err != nil {
+		return nil, err
+	}
+
+	if !s.ValidatePassword(&user, pass) {
+		return nil, helper.LogError("用户密码不正确")
+	}
+
+	return &user, nil
+}
+
+// UpdatePassword 更新用户密码
+func (s *UserServ) UpdatePassword(userID, newPass string) error {
+	return s.dao.UpdatePassword(userID, newPass)
+}
+
+// ValidatePassword 验证密码是否正确
+func (m *UserServ) ValidatePassword(user *model.SysUser, password string) bool {
+	return user.Pwd == encrypt.Md5(password, user.UserId)
+}
+
+// GetUserByID 根据ID获取用户信息
+func (s *UserServ) GetUserByID(userid string) (*model.SysUser, error) {
+	user, err := s.dao.GetUserByID(userid)
+	if err != nil {
+		return nil, err
+	}
+	return user, nil
+}