- GetUsers支持分页

business/jxstore/cms/authz.go

@@ -55,7 +55,7 @@ func TransferLegacyWeixins() (err error) {
 			if user.Name == "" {
 				user.Name = user.Mobile
 			}
-			userList, err2 := dao.GetUsers(db, 0, "", nil, "", v.Tel)
+			userList, _, err2 := dao.GetUsers(db, 0, "", nil, "", v.Tel, 0, -1)
 			if err = err2; err != nil {
 				return err
 			}

business/jxstore/cms/cms.go

@@ -265,8 +265,8 @@ func DeleteConfig(ctx *jxcontext.Context, key, configType string) (err error) {
 		errList := errlist.New()
 		userIDs, err2 := api2.RoleMan.GetRoleUserList(autils.NewRole(key, 0))
 		if err = err2; err == nil && len(userIDs) > 0 {
-			userList, err2 := GetUsers(ctx, 0, "", userIDs, "", "")
-			if err = err2; err == nil {
+			userList, totalCount, err2 := dao.GetUsers(dao.GetDB(), 0, "", userIDs, "", "", 0, -1)
+			if err = err2; err == nil && totalCount > 0 {
 				err = fmt.Errorf("还有人员在使用角色:%s，人员信息:%s", key, utils.MustMarshal(utils.Struct2Map(userList, "compact")))
 			}
 		}

business/jxstore/cms/user2.go

@@ -155,8 +155,15 @@ func OnDingDingMsg(msg map[string]interface{}) (callbackResponse *dingdingapi.Ca
 	return api.DingDingAPI.Err2CallbackResponse(nil)
 }
 
-func GetUsers(ctx *jxcontext.Context, userType int, keyword string, userIDs []string, userID2, mobile string) (userList []*model.User, err error) {
-	return dao.GetUsers(dao.GetDB(), userType, keyword, userIDs, userID2, mobile)
+func GetUsers(ctx *jxcontext.Context, userType int, keyword string, userIDs []string, userID2, mobile string, offset, pageSize int) (pagedInfo *model.PagedInfo, err error) {
+	userList, totalCount, err := dao.GetUsers(dao.GetDB(), userType, keyword, userIDs, userID2, mobile, offset, pageSize)
+	if err == nil {
+		pagedInfo = &model.PagedInfo{
+			TotalCount: totalCount,
+			Data:       userList,
+		}
+	}
+	return pagedInfo, err
 }
 
 func GetStoreList4User(ctx *jxcontext.Context, mobileNum, userID string) (storeList []*dao.StoreWithCityName, err error) {

business/jxutils/jxutils.go

@@ -438,7 +438,7 @@ func HandleUserWXRemark(db *dao.DaoDB, mobile string) (err error) {
 			storeID = wxinfo.JxStoreID
 		}
 	} else {
-		userList, err2 := dao.GetUsers(db, model.UserTypeStoreBoss, "", nil, "", mobile)
+		userList, _, err2 := dao.GetUsers(db, model.UserTypeStoreBoss, "", nil, "", mobile, 0, -1)
 		if err = err2; len(userList) > 0 {
 			userID := userList[0].GetID()
 			authBind, err2 := dao.GetAuthBind(db, userID, weixin.AuthTypeMP, "")

business/model/dao/dao_user2.go

@@ -23,12 +23,15 @@ func GetUserByID(db *DaoDB, fieldName, fieldValue string) (user *model.User, err
 	return user, err
 }
 
-func GetUsers(db *DaoDB, userType int, keyword string, userIDs []string, userID2, mobile string) (userList []*model.User, err error) {
+func GetUsers(db *DaoDB, userType int, keyword string, userIDs []string, userID2, mobile string, offset, pageSize int) (userList []*model.User, totalCount int, err error) {
+	offset = FormalizePageOffset(offset)
+	pageSize = FormalizePageSize(pageSize)
 	if userType == 0 {
 		userType = 255
 	}
 	sql := `
-	SELECT *
+	SELECT SQL_CALC_FOUND_ROWS
+	t1.*
 	FROM user t1
 	WHERE t1.status = 1 AND t1.deleted_at = ? AND t1.type & ? <> 0`
 	sqlParams := []interface{}{
@@ -52,6 +55,12 @@ func GetUsers(db *DaoDB, userType int, keyword string, userIDs []string, userID2
 		sql += " AND (t1.user_id2 LIKE ? OR t1.mobile LIKE ? OR t1.email LIKE ? OR t1.name LIKE ?)"
 		sqlParams = append(sqlParams, keywordLike, keywordLike, keywordLike, keywordLike)
 	}
-	err = GetRows(db, &userList, sql, sqlParams...)
-	return userList, err
+	sql += " LIMIT ? OFFSET ?"
+	sqlParams = append(sqlParams, pageSize, offset)
+	Begin(db)
+	defer Rollback(db)
+	if err = GetRows(db, &userList, sql, sqlParams...); err == nil {
+		totalCount = GetLastTotalRowCount(db)
+	}
+	return userList, totalCount, err
 }