/**
 * 使用Mapper接口调用时，使用PageHelper.startPage效果更好，不需要添加Mapper接口参数
 */
@Test
public void testMapperWithStartPage_OrderBy() {
    SqlSession sqlSession = MybatisHelper.getSqlSession();
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        //获取第1页，10条内容，默认查询总数count
        PageHelper.startPage(1, 10, "id desc");
        List<User> list = userMapper.selectChoose(183, 2);
        assertEquals(182, list.get(0).getId());
        assertEquals(10, list.size());
        assertEquals(182, ((Page<?>) list).getTotal());

        //获取第1页，10条内容，默认查询总数count
        PageHelper.startPage(1, 10, "id desc");
        list = userMapper.selectChoose(183, 2);
        assertEquals(182, list.get(0).getId());
        assertEquals(10, list.size());
        assertEquals(182, ((Page<?>) list).getTotal());
    } finally {
        sqlSession.close();
    }
}
 

@RequestMapping(value = "/getlist", method = RequestMethod.POST)
@ResponseBody
public PageResultBean<List<ErpStudent>> getList(int page, int limit, String keyword) {
    List<ErpStudent> list;
    PageHelper.startPage(page, limit, "create_date desc");
    if (keyword != null && !keyword.trim().isEmpty()) {
        keyword = "%" + keyword.trim() + "%";
        Example example = new Example(ErpStudent.class);
        example.createCriteria().andLike("name", keyword);
        list = service.selectByExample(example);
    } else {
        list = service.selectAll();
    }
    return new PageResultBean(list, page, limit, ((Page) list).getTotal());

}
 

@Override
public Object processPageParameter(MappedStatement ms, Map<String, Object> paramMap, Page page, BoundSql boundSql, CacheKey pageKey) {
    paramMap.put(PAGEPARAMETER_FIRST, page.getStartRow());
    paramMap.put(PAGEPARAMETER_SECOND, page.getPageSize());
    //处理pageKey
    pageKey.update(page.getStartRow());
    pageKey.update(page.getPageSize());
    //处理参数配置
    if (boundSql.getParameterMappings() != null) {
        List<ParameterMapping> newParameterMappings = new ArrayList<ParameterMapping>();
        if (page.getStartRow() > 0) {
            newParameterMappings.add(new ParameterMapping.Builder(ms.getConfiguration(), PAGEPARAMETER_FIRST, Integer.class).build());
        }
        if (page.getPageSize() > 0) {
            newParameterMappings.add(new ParameterMapping.Builder(ms.getConfiguration(), PAGEPARAMETER_SECOND, Integer.class).build());
        }
        newParameterMappings.addAll(boundSql.getParameterMappings());
        MetaObject metaObject = MetaObjectUtil.forObject(boundSql);
        metaObject.setValue("parameterMappings", newParameterMappings);
    }
    return paramMap;
}
 

public static Object okList(List list, List pagedList) {
    Map<String, Object> data = new HashMap<String, Object>();
    data.put("list", list);

    if (pagedList instanceof Page) {
        Page page = (Page) pagedList;
        data.put("total", page.getTotal());
        data.put("page", page.getPageNum());
        data.put("limit", page.getPageSize());
        data.put("pages", page.getPages());
    } else {
        data.put("total", pagedList.size());
        data.put("page", 1);
        data.put("limit", pagedList.size());
        data.put("pages", 1);
    }

    return ok(data);
}
 

/**
 * 使用Mapper接口调用时，使用PageHelper.startPage效果更好，不需要添加Mapper接口参数
 */
@Test
public void testMapperWithStartPage() {
    SqlSession sqlSession = MybatisHelper.getSqlSession();
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        //获取第1页，10条内容，默认查询总数count
        PageHelper.startPage(1, 10);
        List<User> list = userMapper.selectAllOrderByArray(new Integer[]{1, 2});
        assertEquals(3, list.get(0).getId());
        assertEquals(10, list.size());
        assertEquals(181, ((Page<?>) list).getTotal());
    } finally {
        sqlSession.close();
    }
}
 

@Test
public void testInList() {
    SqlSession sqlSession = MybatisHelper.getSqlSession();
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        UserExample example = new UserExample();
        example.createCriteria().andIdIn(Arrays.asList(1, 2, 3, 4, 5));
        PageHelper.startPage(1, 20);
        List<User> list = userMapper.selectByExample(example);
        assertEquals(1, list.get(0).getId());
        assertEquals(5, list.size());
        assertEquals(5, ((Page<?>) list).getTotal());
    } finally {
        sqlSession.close();
    }
}
 

@Test
public void brokerTokenTest() {
    BrokerTokenEntity brokerTokenEntity = new BrokerTokenEntity();
    brokerTokenEntity.setRole("test");
    brokerTokenEntity.setDescription("This role for test");
    brokerTokenEntity.setToken("xxxxxxxxxxxxx");
    brokerTokensRepository.save(brokerTokenEntity);
    Page<BrokerTokenEntity> brokerTokenEntityPage = brokerTokensRepository.getBrokerTokensList(1, 1);
    brokerTokenEntityPage.count(true);
    brokerTokenEntityPage.getResult().forEach((result) -> {
        Assert.assertEquals(brokerTokenEntity.getRole(), result.getRole());
        Assert.assertEquals(brokerTokenEntity.getDescription(), result.getDescription());
    });

    brokerTokenEntity.setDescription("This role for update test");
    brokerTokenEntity.setToken("tokentestupdate");
    brokerTokensRepository.update(brokerTokenEntity);
    Optional<BrokerTokenEntity> optionalBrokerTokenEntity = brokerTokensRepository.findTokenByRole(brokerTokenEntity.getRole());
    BrokerTokenEntity updatedBrokerTokenEntity = optionalBrokerTokenEntity.get();
    Assert.assertEquals(brokerTokenEntity.getRole(), updatedBrokerTokenEntity.getRole());
    Assert.assertEquals(brokerTokenEntity.getDescription(), updatedBrokerTokenEntity.getDescription());

    brokerTokensRepository.remove(brokerTokenEntity.getRole());
    Assert.assertFalse(brokerTokensRepository.findTokenByRole(brokerTokenEntity.getRole()).isPresent());
}
 

@Override
public Object processPageParameter(MappedStatement ms, Map<String, Object> paramMap, Page page, BoundSql boundSql, CacheKey pageKey) {
    paramMap.put(PAGEPARAMETER_FIRST, page.getStartRow());
    paramMap.put(PAGEPARAMETER_SECOND, page.getPageSize());
    //处理pageKey
    pageKey.update(page.getStartRow());
    pageKey.update(page.getPageSize());
    //处理参数配置
    if (boundSql.getParameterMappings() != null) {
        List<ParameterMapping> newParameterMappings = new ArrayList<ParameterMapping>(boundSql.getParameterMappings());
        if (page.getStartRow() == 0) {
            newParameterMappings.add(new ParameterMapping.Builder(ms.getConfiguration(), PAGEPARAMETER_SECOND, Integer.class).build());
        } else {
            newParameterMappings.add(new ParameterMapping.Builder(ms.getConfiguration(), PAGEPARAMETER_FIRST, Integer.class).build());
            newParameterMappings.add(new ParameterMapping.Builder(ms.getConfiguration(), PAGEPARAMETER_SECOND, Integer.class).build());
        }
        MetaObject metaObject = MetaObjectUtil.forObject(boundSql);
        metaObject.setValue("parameterMappings", newParameterMappings);
    }
    return paramMap;
}
 

@Select({"<script>",
        "SELECT environment, cluster, tenant, namespace, persistent, topic,"
            + "sum(producer_count) as producerCount,"
            + "sum(subscription_count) as subscriptionCount,"
            + "sum(msg_rate_in) as msgRateIn,"
            + "sum(msg_throughput_in) as msgThroughputIn,"
            + "sum(msg_rate_out) as msgRateOut,"
            + "sum(msg_throughput_out) as msgThroughputOut,"
            + "avg(average_msg_size) as averageMsgSize,"
            + "sum(storage_size) as storageSize, time_stamp  FROM topics_stats",
        "WHERE environment=#{environment} and tenant=#{tenant} and namespace=#{namespace} and time_stamp=#{timestamp} and " +
                "topic IN <foreach collection='topicList' item='topic' open='(' separator=',' close=')'> #{topic} </foreach>" +
        "GROUP BY environment, cluster, tenant, namespace, persistent, topic, time_stamp" +
        "</script>"})
Page<TopicStatsEntity> findByMultiTopic(
        @Param("environment") String environment,
        @Param("tenant") String tenant,
        @Param("namespace") String namespace,
        @Param("persistent") String persistent,
        @Param("topicList") List<String> topicList,
        @Param("timestamp") long timestamp);
 

@Test
public void getNamespaceByTenantOrNamespaceTest() {
    NamespaceEntity namespacesEntity = new NamespaceEntity();
    initNamespaceEntity(namespacesEntity);
    namespacesRepository.save(namespacesEntity);
    String tenant = "test-namespace-public";
    Page<NamespaceEntity> namespacesEntityPageByTenant = namespacesRepository.
            findByTenantOrNamespace(1, 2, tenant);
    namespacesEntityPageByTenant.count(true);
    checkResult(namespacesEntityPageByTenant);
    String namespace = "test-namespace-default";
    Page<NamespaceEntity> namespacesEntityPageByNamespace = namespacesRepository.
            findByTenantOrNamespace(1, 2, namespace);
    namespacesEntityPageByNamespace.count(true);
    checkResult(namespacesEntityPageByNamespace);
    namespacesEntityPageByNamespace.getResult().forEach((result) -> {
        namespacesRepository.remove(result.getTenant(), result.getNamespace());
    });
    Page<NamespaceEntity> deleteNamespace = namespacesRepository.getNamespacesList(1, 2);
    deleteNamespace.count(true);
    checkDeleteResult(deleteNamespace);
}
 

/**
 * 分页 - 书单更多接口
 * @param booklistId            书单ID
 * @param page                  页数
 * @param limit                 每页数量
 * @return
 */
@Override
public Result getBooklistPagingBooks(Integer booklistId, Integer page, Integer limit) {
    String key = RedisHomepageKey.getBooklistItemPagingKey(booklistId);
    // 使用页码+数量作为Hash的key，防止不同数量的分页页码冲突
    String field = page.toString() + limit;
    List<BooklistBookVO> list = this.redisService.getHashListVal(key, field, BooklistBookVO.class);
    if (CommonUtil.isEmpty(list)) {
        list = new ArrayList<>();
        PageHelper.startPage(page, limit);
        Page<IndexBooklistItem> pageList = (Page<IndexBooklistItem>) this.indexBooklistItemMapper.findPageWithResult(booklistId);
        for (int i = 0; i < pageList.size(); i++) {
            String bookId = pageList.get(i).getBookId();
            BooklistBookVO vo = this.getBookVO(bookId);
            if (vo != null) {
                list.add(vo);
            }
        }

        if (list.size() > 0) {
            this.redisService.setHashValExpire(key, field, list, RedisExpire.HOUR_TWO);
        }
    }
    return ResultUtil.success(list);
}
 

@Test
public void testUserProvider() {
    SqlSession sqlSession = MybatisHelper.getSqlSession();
    User user = new User();
    user.setId(100);
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        PageHelper.startPage(1, 10);
        List<User> list = userMapper.selectByUserProvider(user);
        assertEquals(100, list.get(0).getId());
        assertEquals(1, list.size());
        assertEquals(1, ((Page<?>) list).getTotal());

        user.setName("不存在");
        PageHelper.startPage(1, 10);
        list = userMapper.selectByUserProvider(user);
        assertEquals(0, list.size());
    } finally {
        sqlSession.close();
    }
}
 

@Override
public Pagination<UserEntity> pageAll(Integer page, Integer rows, String sorterField, String sorterOrder, UserEntity userEntity, String gmtCreatedStart, String gmtCreatedEnd, String gmtDeletedStart, String gmtDeletedEnd) {
    if (sorterField != null && !"".equals(sorterField) && sorterOrder != null && !"".equals(sorterOrder)) {
        sorterField = StringUtil.camelToUnderline(sorterField);
        String orderBy = sorterField + " " + sorterOrder;
        PageHelper.startPage(page, rows, orderBy);
    } else {
        PageHelper.startPage(page, rows);
    }
    Page<UserEntity> userEntityPage = userMapper.pageAll(userEntity, gmtCreatedStart, gmtCreatedEnd, gmtDeletedStart, gmtDeletedEnd);
    Pagination<UserEntity> pagination = new Pagination<>();
    List<UserEntity> userEntityList = new ArrayList<>();
    List<UserEntity> tempUserEntityList = userEntityPage.getResult();
    if (tempUserEntityList != null) {
        for (UserEntity userEntity2 : tempUserEntityList) {
            userEntity2.setPassword(null);
            userEntity2.setDepartment(departmentService.listAllByDepartmentId(userEntity2.getDepartmentId()));
            userEntityList.add(userEntity2);
        }
    }
    pagination.setRows(userEntityList);
    pagination.setTotal(userEntityPage.getTotal());
    return pagination;
}
 

@Override
public Pagination<UserEntity> pageAllByDepartmentId(Long departmentId, Integer page, Integer rows) {
    Pagination<UserEntity> pagination = new Pagination<>();
    PageHelper.startPage(page, rows);
    Page<UserEntity> tempUserEntityPage = userMapper.pageAllByDepartmentId(departmentId);
    List<UserEntity> userEntityList = new ArrayList<>();
    if (tempUserEntityPage != null) {
        for (UserEntity userEntity : tempUserEntityPage.getResult()) {
            userEntity.setPassword(null);
            userEntityList.add(userEntity);
        }
        pagination.setRows(userEntityList);
        pagination.setTotal(tempUserEntityPage.getTotal());
    }
    return pagination;
}
 

@Test
public void testMapperWithStartPage() {
    SqlSession sqlSession = MybatisHelper.getSqlSession();
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        //获取第1页，10条内容，默认查询总数count
        Map<String, Object> params = new HashMap<String, Object>(2);
        params.put("pageNum", 1L);
        params.put("pageSize", "100");
        PageHelper.startPage(params);
        Map<String, Object> where = new HashMap<String, Object>();
        where.put("id", 100);
        List<User> list = userMapper.selectByWhereMap(new Where(where));
        assertEquals(100, list.get(0).getId());
        assertEquals(1, list.size());
        assertEquals(1, ((Page<?>) list).getTotal());
    } finally {
        sqlSession.close();
    }
}
 

/**
 * union的count查询sql特殊
 */
@Test
public void testUnion() {
    SqlSession sqlSession = MybatisHelper.getSqlSession();
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        //获取第1页，10条内容，默认查询总数count
        PageHelper.startPage(1, 10);
        List<User> list = userMapper.selectUnion();
        assertEquals(1, list.get(0).getId());
        assertEquals(10, list.size());
        assertEquals(13, ((Page<?>) list).getTotal());

        //获取第1页，10条内容，默认查询总数count
        PageHelper.startPage(2, 10);
        list = userMapper.selectUnion();
        assertEquals(181, list.get(0).getId());
        assertEquals(3, list.size());
        assertEquals(13, ((Page<?>) list).getTotal());
    } finally {
        sqlSession.close();
    }
}
 

@Test
public void testPageNum() {
    SqlSession sqlSession = MybatisHelper.getSqlSession();
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        PageHelper.offsetPage(5, 5);
        List<User> list = userMapper.selectAll();
        assertEquals(2, ((Page<?>) list).getPageNum());
        assertEquals(5, list.size());
        assertEquals(183, ((Page<?>) list).getTotal());

        PageHelper.offsetPage(15, 5);
        list = userMapper.selectAll();
        assertEquals(4, ((Page<?>) list).getPageNum());
        assertEquals(5, list.size());
        assertEquals(183, ((Page<?>) list).getTotal());
    } finally {
        sqlSession.close();
    }
}
 

/**
 * 使用Mapper接口调用时，使用PageHelper.startPage效果更好，不需要添加Mapper接口参数
 */
@Test
public void testMapperWithStartPage_OrderBy() {
    SqlSession sqlSession = MybatisHelper.getSqlSession();
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        //获取第1页，10条内容，默认查询总数count
        PageHelper.orderBy("id desc");
        User user = new User();
        user.setName("刘");
        List<User> list = userMapper.selectLike(user);
        assertEquals(92, list.get(0).getId());
        assertEquals(15, list.size());
        assertEquals(15, ((Page<?>) list).getTotal());
    } finally {
        sqlSession.close();
    }
}
 

@Select("SELECT subscription_stats_id as subscriptionStatsId,topic_stats_id as topicStatsId," +
        "subscription as subscription,msg_backlog as msgBacklog,msg_rate_expired as msgRateExpired," +
        "msg_rate_out as msgRateOut,msg_throughput_out as msgThroughputOut,msg_rate_redeliver as msgRateRedeliver," +
        "number_of_entries_since_first_not_acked_message as numberOfEntriesSinceFirstNotAckedMessage," +
        "total_non_contiguous_deleted_messages_range as totalNonContiguousDeletedMessagesRange," +
        "subscription_type as subscriptionType,time_stamp  FROM subscriptions_stats " +
        "where topic_stats_id=#{topicStatsId} and time_stamp=#{timestamp}")
Page<SubscriptionStatsEntity> findByTopicStatsId(@Param("topicStatsId") long topicStatsId,
                                                 @Param("timestamp") long timestamp);
 

@Select({"<script>",
        "SELECT role_name AS roleName, role_id AS roleId, description, resource_type AS resourceType," +
                "resource_name AS resourceName, resource_verbs AS resourceVerbs, resource_id as resourceId," +
                "role_source AS roleSource, flag FROM roles",
        "WHERE role_id IN <foreach collection='roleIdList' item='roleId' open='(' separator=',' close=')'> #{roleId} </foreach>" +
                "</script>"})
Page<RoleInfoEntity> findByMultiId(@Param("roleIdList") List<Long> roleIdList);
 

@GetMapping("/_useSqlhelper_over_pageHelper")
public Page list_sqlhelper_over_pageHelper(
        @RequestParam(name = "pageNo") Integer pageNo,
        @RequestParam(name = "pageSize") Integer pageSize,
        @RequestParam(name = "sort", required = false) String sort,
        @RequestParam(value = "countColumn", required = false) String countColumn) {

    Page page = PageHelper.offsetPage(pageNo, pageSize);
    // Page page = PageHelper.startPage(pageNo, pageSize, sort);
    page.setCountColumn(countColumn);
    PageHelper.orderBy(" id desc");

    WeekendSqls weekendSqls = WeekendSqls.custom()
            .andLike("name", "%zhangsan%")
            .andGreaterThanOrEqualTo("age", 10);
    Example example = Example.builder(User.class).setDistinct(false).where(weekendSqls).build();

    JSON jsons = JSONBuilderProvider.simplest();

    List<User> users = userDao.selectByExample(example);
    String json = jsons.toJson(users);
    System.out.println(json);
    json = jsons.toJson(users);
    System.out.println(json);
    PageInfo pageInfo1 = new PageInfo(page);
    json = jsons.toJson(pageInfo1);
    System.out.println(json);
    PageInfo pageInfo2 = new PageInfo(users);
    json = jsons.toJson(pageInfo2);
    System.out.println(json);
    return page;
}
 

/**
 * 分页查询-条件查询方法
 *
 * @param customer 查询条件
 * @param pageCode 当前页
 * @param pageSize 每页的记录数
 * @return
 */
public PageBean findByPage(Customer customer, int pageCode, int pageSize) {
    //使用Mybatis分页插件
    PageHelper.startPage(pageCode, pageSize);

    //调用分页查询方法，其实就是查询所有数据，mybatis自动帮我们进行分页计算
    Page<Customer> page = customerMapper.findByPage(customer);

    return new PageBean(pageCode, (int)Math.ceil((double)(page.getTotal() / (double)pageSize)), (int)page.getTotal(), pageSize, page.getResult());
}
 

@RequestMapping(value = "/getlist", method = RequestMethod.GET)
@ResponseBody
public PageResultBean<List<ErpCalendarTask>> getList(int page, int limit) {
    List<ErpCalendarTask> list;
    PageHelper.startPage(page, limit);
    list = service.selectAll();
    return new PageResultBean(list, page, limit, ((Page) list).getTotal());

}
 

@Override
public String getPageSql(String sql, Page page, CacheKey pageKey) {
    StringBuilder sqlBuilder = new StringBuilder(sql.length() + 140);
    sqlBuilder.append("SELECT * FROM (SELECT TMP_PAGE.*,ROWNUMBER() OVER() AS ROW_ID FROM ( ");
    sqlBuilder.append(sql);
    sqlBuilder.append(" ) AS TMP_PAGE) TMP_PAGE WHERE ROW_ID BETWEEN ? AND ?");
    return sqlBuilder.toString();
}
 

@RequestMapping(value = "/getlist", method = RequestMethod.GET)
@ResponseBody
public PageResultBean<List<ErpSFamilyMember>> getList(int page, int limit) {
    List<ErpSFamilyMember> list;
    PageHelper.startPage(page, limit);
    list = service.selectAll();
    return new PageResultBean(list, page, limit, ((Page) list).getTotal());

}
 

public PagerContract<AlertLog> findAlertLog(int pageIndex, int pageSize, Date startTime, Date endTime,
                                            Long executeId, Long alarmId, String recipient, String way,
                                            String sendStatus, String inSilence, String alertType) {
    Page page = PageHelper.startPage(pageIndex, pageSize);
    List<AlertLog> list = alertLogMapper.find(startTime, endTime, executeId, alarmId, recipient, way, sendStatus, inSilence, alertType);
    return new PagerContract<>(list, page.getPageSize(), page.getPageNum(), (int) page.getTotal());
}
 

/**
 * 使用Mapper接口调用时，对接口增加RowBounds参数，不需要修改对应的xml配置（或注解配置）
 * <p/>
 * RowBounds方式不进行count查询，可以通过修改Page代码实现
 * <p/>
 * 这种情况下如果同时使用startPage方法，以startPage为准
 */
@Test
public void testMapperWithRowBounds() {
    SqlSession sqlSession = MybatisRowBoundsHelper.getSqlSession();
    UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
    try {
        //获取第1页，10条内容，默认查询总数count
        List<User> list = userMapper.selectAll(new RowBounds(1, 10));
        //新增PageInfo对象，对返回结果进行封装
        PageInfo<User> page = new PageInfo<User>(list);
        assertEquals(10, list.size());
        assertEquals(183, page.getTotal());
        //判断查询结果的位置是否正确
        assertEquals(1, list.get(0).getId());
        assertEquals(10, list.get(list.size() - 1).getId());


        //获取第10页，10条内容，显式查询总数count
        list = userMapper.selectAll(new RowBounds(10, 10));
        assertEquals(10, list.size());
        assertEquals(183, ((Page<?>) list).getTotal());
        //判断查询结果的位置是否正确
        assertEquals(91, list.get(0).getId());
        assertEquals(100, list.get(list.size() - 1).getId());


        //获取第3页，20条内容，默认查询总数count
        list = userMapper.selectAll(new RowBounds(6, 20));
        assertEquals(20, list.size());
        assertEquals(183, ((Page<?>) list).getTotal());
        //判断查询结果的位置是否正确
        assertEquals(101, list.get(0).getId());
        assertEquals(120, list.get(list.size() - 1).getId());
    } finally {
        sqlSession.close();
    }
}
 

public PageResult<Order> queryUserOrderList(Integer page, Integer rows, Integer status) {
    try {
        // 分页
        PageHelper.startPage(page, rows);
        // 获取登录用户
        UserInfo user = LoginInterceptor.getLoginUser();
        // 创建查询条件
        Page<Order> pageInfo = (Page<Order>) this.orderMapper.queryOrderList(user.getId(), status);

        return new PageResult<>(pageInfo.getTotal(), pageInfo);
    } catch (Exception e) {
        logger.error("查询订单出错", e);
        return null;
    }
}
 

/**
 * 开始分页
 *
 * @param pageNum      页码
 * @param pageSize     每页显示数量
 * @param count        是否进行count查询
 * @param reasonable   分页合理化,null时用默认配置
 * @param pageSizeZero true且pageSize=0时返回全部结果，false时分页,null时用默认配置
 */
public static <E> Page<E> startPage(int pageNum, int pageSize, boolean count, Boolean reasonable, Boolean pageSizeZero) {
    Page<E> page = new Page<E>(pageNum, pageSize, count);
    page.setReasonable(reasonable);
    page.setPageSizeZero(pageSizeZero);
    //当已经执行过orderBy的时候
    Page<E> oldPage = getLocalPage();
    if (oldPage != null && oldPage.isOrderByOnly()) {
        page.setOrderBy(oldPage.getOrderBy());
    }
    setLocalPage(page);
    return page;
}
 

/**
 * 描述:查找排班记录、分页
 * <p>author: ma
 */
@ApiOperation("查找排班记录、分页")
@RequestMapping(value = "/listSkd", method = RequestMethod.POST)
@ResponseBody
public  CommonResult<CommonPage<SmsSkdResult>> listSkd(@RequestBody SmsSkdParam queryParam,
                                                       @RequestParam(value = "pageSize", defaultValue = "5") Integer pageSize,
                                                       @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum){
    Page page =PageHelper.startPage(pageNum, pageSize);

    List<SmsSkdResult> smsSkdResultList = smsSkdService.listSkd(queryParam);
    Long pageTotal=page.getTotal();
    return CommonResult.success(CommonPage.restPage(smsSkdResultList,pageTotal));
}