Commit 634fe741 sunke

分页及返回值修改

1 个父辈 452922e6
正在显示 26 个修改的文件 包含 170 行增加162 行删除
package com.neotel.smfcore.common.base;
import com.neotel.smfcore.common.bean.PageData;
import java.util.List;
public interface BaseMapper<D, E> {
......@@ -30,4 +32,9 @@ public interface BaseMapper<D, E> {
* @return /
*/
List <D> toDto(List<E> entityList);
/**
* Entity分页集合转DTO分页集合
*/
PageData<D> toDto(PageData<E> entityPage);
}
package com.neotel.smfcore.common.base;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
......@@ -18,7 +19,7 @@ public interface IBaseManager<T> {
void delete(T object) throws ValidateException;
List<T> findByPage(Query query, Pageable pageable);
PageData<T> findByPage(Query query, Pageable pageable);
List<T> findByQuery(Query query);
}
package com.neotel.smfcore.common.bean;
import io.swagger.annotations.ApiModelProperty;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* Created by sunke on 2021/7/22.
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class PageData<T> {
/**
* 当前页结果
*/
@ApiModelProperty("当前页结果列表")
private List<T> content;
/**
* 查询结果总数量
*/
@ApiModelProperty("查询结果总数量")
private int totalElements;
}
package com.neotel.smfcore.common.bean;
import com.fasterxml.jackson.annotation.JsonIgnore;
import io.swagger.annotations.ApiModelProperty;
import lombok.extern.slf4j.Slf4j;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
......@@ -8,7 +10,7 @@ import org.apache.logging.log4j.Logger;
* Created by sunke on 2019/12/12.
*/
@Slf4j
public class ResultBean {
public class ResultBean<T> {
public static ResultBean newErrorResult(int code, String msg){
return newErrorResult(code, msg, true);
......@@ -36,22 +38,18 @@ public class ResultBean {
return newOkResult("ok", data);
}
/**
* 结果码,0为正常,其他值表示异常
*/
@ApiModelProperty("结果码,0为正常,其他值表示异常")
private int code;
/**
* 提示信息
*/
@ApiModelProperty("提示信息")
private String msg;
/**
* 数据结果
*/
private Object data;
private T data;
/**
* 是否是OK的结果
*/
@JsonIgnore
public boolean isOkResult(){
return code == 0;
}
......@@ -64,11 +62,11 @@ public class ResultBean {
this.code = code;
}
public Object getData() {
public T getData() {
return data;
}
public void setData(Object data) {
public void setData(T data) {
this.data = data;
}
......
/*
* Copyright 2019-2020 Zheng Jie
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.neotel.smfcore.common.utils;
import org.springframework.data.domain.Page;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
/**
* 分页工具
* @author Zheng Jie
* @date 2018-12-10
*/
public class PageUtil extends cn.hutool.core.util.PageUtil {
/**
* List 分页
*/
public static List toPage(int page, int size , List list) {
int fromIndex = page * size;
int toIndex = page * size + size;
if(fromIndex > list.size()){
return new ArrayList();
} else if(toIndex >= list.size()) {
return list.subList(fromIndex,list.size());
} else {
return list.subList(fromIndex,toIndex);
}
}
/**
* Page 数据处理,预防redis反序列化报错
*/
public static Map<String,Object> toPage(Page page) {
Map<String,Object> map = new LinkedHashMap<>(2);
map.put("content",page.getContent());
map.put("totalElements",page.getTotalElements());
return map;
}
/**
* 自定义分页
*/
public static Map<String,Object> toPage(Object object, Object totalElements) {
Map<String,Object> map = new LinkedHashMap<>(2);
map.put("content",object);
map.put("totalElements",totalElements);
return map;
}
}
package com.neotel.smfcore.core.barcode.service.manager.impl;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.core.barcode.service.dao.IBarcodeDao;
import com.neotel.smfcore.core.barcode.service.manager.IBarcodeManager;
......@@ -34,7 +35,7 @@ public class BarcodeManagerImpl implements IBarcodeManager {
}
@Override
public List<Barcode> findByPage(Query query, Pageable pageable) {
public PageData<Barcode> findByPage(Query query, Pageable pageable) {
return null;
}
......
package com.neotel.smfcore.core.barcode.service.manager.impl;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.core.barcode.service.dao.IComponentDao;
import com.neotel.smfcore.core.barcode.service.manager.IComponentManager;
......@@ -34,8 +35,10 @@ public class ComponentManagerImpl implements IComponentManager {
}
@Override
public List<Component> findByPage(Query query, Pageable pageable) {
return componentDao.findByQuery(query,pageable);
public PageData<Component> findByPage(Query query, Pageable pageable) {
int totalCount = componentDao.countByQuery(query);
List<Component> list = componentDao.findByQuery(query, pageable);
return new PageData<Component>(list,totalCount);
}
@Override
......
......@@ -3,6 +3,7 @@ package com.neotel.smfcore.core.order.rest;
import com.google.common.collect.Lists;
import com.neotel.smfcore.common.annotation.QueryCondition;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.bean.ResultBean;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
......@@ -11,6 +12,7 @@ import com.neotel.smfcore.common.utils.PageUtil;
import com.neotel.smfcore.common.utils.QueryHelp;
import com.neotel.smfcore.common.utils.SecurityUtils;
import com.neotel.smfcore.core.order.LiteOrderCache;
import com.neotel.smfcore.core.order.rest.bean.dto.OrderDto;
import com.neotel.smfcore.core.order.rest.bean.mapstruct.OrderMapper;
import com.neotel.smfcore.core.order.rest.bean.query.OrderQueryCondition;
import com.neotel.smfcore.core.order.service.manager.ILiteOrderItemManager;
......@@ -77,16 +79,16 @@ public class OrderController {
@ApiOperation("工单出库")
@PostMapping(value = "/out")
@PreAuthorize("@el.check('order:out')")
public ResponseEntity<Object> delete(@RequestBody String orderNo) {
public ResultBean delete(@RequestBody String orderNo) {
LiteOrder liteOrder = liteOrderManager.findByOrderNo(orderNo);
ResultBean resultBean = liteOrderCache.checkOutOrder(liteOrder);
return new ResponseEntity<>(resultBean,HttpStatus.OK);
return resultBean;
}
@ApiOperation("查询工单")
@GetMapping
@PreAuthorize("@el.check('order:list')")
public ResponseEntity<Object> query(OrderQueryCondition criteria, Pageable pageable){
public PageData<OrderDto> query(OrderQueryCondition criteria, Pageable pageable){
User user = userManager.findByUserName(SecurityUtils.getCurrentUsername());
if(user != null){
//数据权限
......@@ -101,12 +103,12 @@ public class OrderController {
}
//都没有权限,返回空
if(ObjectUtils.isEmpty(groupNames)){
return new ResponseEntity<>(PageUtil.toPage(null,0), HttpStatus.OK);
return new PageData<>(Lists.newArrayList(),0);
}
criteria.setSourceList(groupNames);
}
}
List<LiteOrder> orderList = liteOrderManager.findByPage(QueryHelp.getQuery(criteria), pageable);
return new ResponseEntity<>(PageUtil.toPage(orderMapper.toDto(orderList),0), HttpStatus.OK);
PageData<LiteOrder> orderList = liteOrderManager.findByPage(QueryHelp.getQuery(criteria), pageable);
return orderMapper.toDto(orderList);
}
}
package com.neotel.smfcore.core.order.service.manager.impl;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.core.order.service.dao.ILiteOrderDao;
import com.neotel.smfcore.core.order.service.dao.ILiteOrderItemDao;
......@@ -41,8 +42,10 @@ public class LiteOrderItemManagerImpl implements ILiteOrderItemManager {
}
@Override
public List<LiteOrderItem> findByPage(Query query, Pageable pageable) {
return liteOrderItemDao.findByQuery(query,pageable);
public PageData<LiteOrderItem> findByPage(Query query, Pageable pageable) {
int totalCount = liteOrderItemDao.countByQuery(query);
List<LiteOrderItem> list = liteOrderItemDao.findByQuery(query, pageable);
return new PageData<LiteOrderItem>(list,totalCount);
}
@Override
......
package com.neotel.smfcore.core.order.service.manager.impl;
import com.google.common.collect.Lists;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.core.barcode.service.dao.IBarcodeDao;
import com.neotel.smfcore.core.barcode.service.manager.IBarcodeManager;
......@@ -61,8 +62,10 @@ public class LiteOrderManagerImpl implements ILiteOrderManager {
}
@Override
public List<LiteOrder> findByPage(Query query, Pageable pageable) {
return liteOrderDao.findByQuery(query,pageable);
public PageData<LiteOrder> findByPage(Query query, Pageable pageable) {
int totalCount = liteOrderDao.countByQuery(query);
List<LiteOrder> list = liteOrderDao.findByQuery(query, pageable);
return new PageData<LiteOrder>(list,totalCount);
}
@Override
......
package com.neotel.smfcore.core.storage.service.manager.impl;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.core.storage.service.dao.IStorageDao;
import com.neotel.smfcore.core.storage.service.manager.IStorageManager;
......@@ -33,8 +34,10 @@ public class StorageManagerImpl implements IStorageManager {
}
@Override
public List<Storage> findByPage(Query query, Pageable pageable) {
return storageDao.findByQuery(query,pageable);
public PageData<Storage> findByPage(Query query, Pageable pageable) {
int totalCount = storageDao.countByQuery(query);
List<Storage> list = storageDao.findByQuery(query, pageable);
return new PageData<Storage>(list,totalCount);
}
@Override
......
......@@ -2,6 +2,7 @@ package com.neotel.smfcore.core.storage.service.manager.impl;
import com.google.common.base.Strings;
import com.google.common.collect.Maps;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.core.barcode.bean.PlateSizeBean;
import com.neotel.smfcore.core.storage.bean.InventoryItem;
......@@ -233,8 +234,10 @@ public class StoragePosManagerImpl implements IStoragePosManager {
}
@Override
public List<StoragePos> findByPage(Query query, Pageable pageable) {
return storagePosDao.findByQuery(query,pageable);
public PageData<StoragePos> findByPage(Query query, Pageable pageable) {
int totalCount = storagePosDao.countByQuery(query);
List<StoragePos> list = storagePosDao.findByQuery(query, pageable);
return new PageData<StoragePos>(list,totalCount);
}
@Override
......
......@@ -2,6 +2,8 @@
package com.neotel.smfcore.core.system.rest;
import com.google.common.collect.Lists;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.bean.ResultBean;
import com.neotel.smfcore.common.utils.PageUtil;
import com.neotel.smfcore.common.utils.QueryHelp;
import com.neotel.smfcore.core.device.util.DataCache;
......@@ -57,15 +59,15 @@ public class TaskController {
@ApiOperation("查询出入库日志")
@GetMapping("/history")
@PreAuthorize("@el.check('task:list')")
public ResponseEntity<Object> query(TaskQueryCondition criteria, Pageable pageable){
List<DataLog> taskList = dataLogManager.findByPage(QueryHelp.getQuery(criteria), pageable);
return new ResponseEntity<>(PageUtil.toPage(taskMapper.toDto(taskList),0), HttpStatus.OK);
public PageData<TaskDto> query(TaskQueryCondition criteria, Pageable pageable){
PageData<DataLog> taskList = dataLogManager.findByPage(QueryHelp.getQuery(criteria), pageable);
return taskMapper.toDto(taskList);
}
@ApiOperation("获取队列中的任务")
@GetMapping
@PreAuthorize("@el.check('task:inQueue','task:list')")
public ResponseEntity<Object> query(String groupId, String[] cids){
public List<TaskDto> query(String groupId, String[] cids){
List<DataLog> resultTasks = Lists.newArrayList();
List<DataLog> allTasks = taskService.getAllTasks();
List<String> cidList = Lists.newArrayList();
......@@ -98,7 +100,7 @@ public class TaskController {
// testTask.setStatus("FINISHED");
// resultTasks.add(testTask);
List<TaskDto> resultDtos = taskMapper.toDto(resultTasks);
return new ResponseEntity<>(resultDtos, HttpStatus.OK);
return resultDtos;
}
@ApiOperation("取消任务")
......
package com.neotel.smfcore.core.system.rest.bean.dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Getter;
import lombok.Setter;
......@@ -13,37 +14,37 @@ public class TaskDto implements Serializable {
/**
* 是否是单盘出库(联电指出库项目,默认为false即默认批量出库)
*/
private boolean singleOut = false;
/**
* 所属料仓
*/
@ApiModelProperty("所属料仓")
private String storageName;
/**
* 料仓 cid
*/
@ApiModelProperty(value="料仓 cid")
private String cid;
/**
* 料仓 ID
*/
@ApiModelProperty("料仓 ID")
private String storageId;
/**
* 仓位 ID
*/
@ApiModelProperty("料仓 ID")
private String posId;
/**
* 仓位名称
*/
@ApiModelProperty("仓位名称")
private String posName;
//二维码(Reel ID)
@ApiModelProperty("二维码(Reel ID)")
private String barcode;
/**
* 物料编号
*/
@ApiModelProperty("物料编号")
private String partNumber;
/**
......
package com.neotel.smfcore.core.system.service.manager.impl;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.core.system.service.dao.IDataLogDao;
import com.neotel.smfcore.core.system.service.manager.IDataLogManager;
......@@ -33,8 +34,10 @@ public class DataLogManagerImpl implements IDataLogManager {
}
@Override
public List<DataLog> findByPage(Query query, Pageable pageable) {
return dataLogDao.findByQuery(query, pageable);
public PageData<DataLog> findByPage(Query query, Pageable pageable) {
int totalCount = dataLogDao.countByQuery(query);
List<DataLog> list = dataLogDao.findByQuery(query, pageable);
return new PageData<DataLog>(list,totalCount);
}
@Override
......
package com.neotel.smfcore.core.system.service.manager.impl;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.core.system.service.manager.IHumitureManager;
import com.neotel.smfcore.core.system.service.po.Humiture;
......@@ -27,7 +28,7 @@ public class HumitureManagerImpl implements IHumitureManager {
}
@Override
public List<Humiture> findByPage(Query query, Pageable pageable) {
public PageData<Humiture> findByPage(Query query, Pageable pageable) {
return null;
}
......
......@@ -15,10 +15,11 @@ import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
......@@ -30,6 +31,7 @@ import java.util.*;
*/
@Api(tags = "海拉感应料架")
@RequestMapping("/api/sensorShelf")
@RestController
@Slf4j
public class HellaSensorShelfController {
......@@ -52,19 +54,20 @@ public class HellaSensorShelfController {
* 扫码
*/
@ApiOperation("扫码入库")
@RequestMapping("/codeIn")
@ResponseBody
public ResultBean codeIn(HttpServletRequest request, HttpSession httpSession){
String codeStr = request.getParameter("code");
String groupStr = request.getParameter("group");
@PostMapping("/codeIn")
@PreAuthorize("@el.check('sensorShelf:putIn')")
public ResponseEntity<ResultBean> codeIn(String code, String group){
String loginUser = SecurityUtils.getLoginUsername();
Collection<DataLog> queueTasks = taskService.getQueueTasks();
ResultBean resultBean = null;
for (DataLog queueTask : queueTasks) {
if(queueTask.isPutInTask() && queueTask.getSourceName().equals(groupStr)){
return ResultBean.newErrorResult(-1, "the task of ["+queueTask.getBarcode()+"] is unfinished.");
if(queueTask.isPutInTask() && queueTask.getSourceName().equals(group)){
resultBean = ResultBean.newErrorResult(-1, "the task of ["+queueTask.getBarcode()+"] is unfinished.");
return new ResponseEntity<ResultBean>(resultBean,HttpStatus.OK);
}
}
return hellaServiceHandler.checkMaterial(loginUser,groupStr,codeStr);
resultBean = hellaServiceHandler.checkMaterial(loginUser, group, code);
return new ResponseEntity<ResultBean>(resultBean,HttpStatus.OK);
}
......
package com.neotel.smfcore.security.rest;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.common.utils.PageUtil;
import com.neotel.smfcore.common.utils.QueryHelp;
import com.neotel.smfcore.core.storage.service.manager.IStorageManager;
import com.neotel.smfcore.core.storage.service.po.Storage;
import com.neotel.smfcore.security.rest.bean.dto.GroupDto;
import com.neotel.smfcore.security.rest.bean.dto.MenuDto;
import com.neotel.smfcore.security.rest.bean.mapstruct.GroupMapper;
import com.neotel.smfcore.security.rest.bean.query.GroupQueryCriteria;
......@@ -65,11 +67,10 @@ public class GroupController {
@GetMapping
@ApiOperation("查询组列表")
// @PreAuthorize("@el.check('groups:list')")
public ResponseEntity<Object> query(GroupQueryCriteria criteria, Pageable pageable) throws Exception {
public PageData<GroupDto> query(GroupQueryCriteria criteria, Pageable pageable) throws Exception {
Query query = QueryHelp.getQuery(criteria);
List<Group> groups = groupManager.findByPage(query, pageable);
Map<String, Object> data = PageUtil.toPage(groupMapper.toDto(groups), groups.size());
return new ResponseEntity<>(data, HttpStatus.OK);
PageData<Group> groups = groupManager.findByPage(query, pageable);
return groupMapper.toDto(groups);
}
@ApiOperation("返回全部的分组")
......
......@@ -17,10 +17,10 @@ package com.neotel.smfcore.security.rest;
import cn.hutool.core.collection.CollectionUtil;
import com.neotel.smfcore.common.annotation.QueryCondition;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.common.utils.Constants;
import com.neotel.smfcore.common.utils.PageUtil;
import com.neotel.smfcore.common.utils.QueryHelp;
import com.neotel.smfcore.common.utils.SecurityUtils;
import com.neotel.smfcore.security.annotation.AnonymousAccess;
......@@ -117,11 +117,11 @@ public class MenuController {
@GetMapping
@ApiOperation("查询菜单")
@PreAuthorize("@el.check('menu:list')")
public ResponseEntity<Object> query(MenuQueryCondition criteria) throws Exception {
public PageData<MenuDto> query(MenuQueryCondition criteria) throws Exception {
Query query = QueryHelp.getQuery(criteria);
query.addCriteria(Criteria.where("type").ne(2));
List<MenuDto> menuDtoList = menuMapper.toDto(menuManager.findByQuery(query));
return new ResponseEntity<>(PageUtil.toPage(menuDtoList, menuDtoList.size()), HttpStatus.OK);
return new PageData(menuDtoList, menuDtoList.size());
}
@ApiOperation("查询菜单:根据ID获取同级与上级数据")
......
package com.neotel.smfcore.security.rest;
import cn.hutool.core.lang.Dict;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.common.utils.PageUtil;
......@@ -49,9 +50,9 @@ public class RoleController {
@ApiOperation("获取单个role")
@GetMapping(value = "/{id}")
@PreAuthorize("@el.check('roles:list')")
public ResponseEntity<Object> query(@PathVariable String id){
public RoleDto query(@PathVariable String id){
RoleDto dto=roleMapper.toDto(roleManager.get(id));
return new ResponseEntity<>(dto, HttpStatus.OK);
return dto;
}
@ApiOperation("导出角色数据")
......@@ -66,22 +67,20 @@ public class RoleController {
@ApiOperation("返回全部的角色")
@GetMapping(value = "/all")
@PreAuthorize("@el.check('roles:list','user:add','user:edit')")
public ResponseEntity<Object> query(){
public List<RoleDto> query(){
Query query=new Query();
// query.with(Sort.by(Sort.Direction.ASC,"levle"));
return new ResponseEntity<>(roleMapper.toDto(roleManager.findByQuery(query)) ,HttpStatus.OK);
return roleMapper.toDto(roleManager.findByQuery(query));
}
@ApiOperation("查询角色")
@GetMapping
@PreAuthorize("@el.check('roles:list')")
public ResponseEntity<Object> query(RoleQueryCriteria criteria, Pageable pageable){
public PageData<RoleDto> query(RoleQueryCriteria criteria, Pageable pageable){
Query query= QueryHelp.getQuery(criteria);
// query.with(Sort.by(Sort.Direction.ASC,"id"));
List<Role> roles=roleManager.findByPage(query,pageable);
List<RoleDto> dtos=roleMapper.toDto(roles);
Map<String ,Object> data= PageUtil.toPage(dtos,dtos.size());
return new ResponseEntity<>(data,HttpStatus.OK);
PageData<Role> rolePageData=roleManager.findByPage(query,pageable);
PageData<RoleDto> dtoPageData=roleMapper.toDto(rolePageData);
return dtoPageData;
}
......
......@@ -16,6 +16,7 @@
package com.neotel.smfcore.security.rest;
import com.neotel.smfcore.common.annotation.QueryCondition;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.common.utils.*;
......@@ -78,12 +79,11 @@ public class UserController {
@GetMapping
@PreAuthorize("@el.check('user:list')")
// public ResponseEntity<Object> query(UserQueryCriteria criteria, Pageable pageable){
public ResponseEntity<Object> query(UserQueryCriteria criteria, Pageable pageable) {
public PageData<UserDto> query(UserQueryCriteria criteria, Pageable pageable) {
Query query = QueryHelp.getQuery(criteria);
List<User> users = userManager.findByPage(query, pageable);
List<UserDto> dtos = userManager.listToDto(users);
Map<String, Object> data = PageUtil.toPage(dtos, dtos.size());
return new ResponseEntity<>(data, HttpStatus.OK);
PageData<User> userPageData = userManager.findByPage(query, pageable);
List<UserDto> dtos = userManager.listToDto(userPageData.getContent());
return new PageData<>(dtos,userPageData.getTotalElements());
}
@ApiOperation("新增用户")
......
......@@ -15,6 +15,7 @@
*/
package com.neotel.smfcore.security.service;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.security.bean.SecurityProperties;
import com.neotel.smfcore.security.rest.bean.dto.JwtUserDto;
import com.neotel.smfcore.security.rest.bean.dto.OnlineUserDto;
......@@ -55,12 +56,9 @@ public class OnlineUserService {
* @param pageable /
* @return /
*/
public Map<String,Object> getAll(String filter, Pageable pageable){
public PageData<OnlineUserDto> getAll(String filter, Pageable pageable){
List<OnlineUserDto> onlineUserDtos = getAll(filter);
return PageUtil.toPage(
PageUtil.toPage(pageable.getPageNumber(),pageable.getPageSize(), onlineUserDtos),
onlineUserDtos.size()
);
return new PageData(onlineUserDtos,onlineUserDtos.size());
}
/**
......
package com.neotel.smfcore.security.service.manager.impl;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.common.utils.FileUtil;
......@@ -7,6 +8,7 @@ import com.neotel.smfcore.security.service.dao.IGroupDao;
import com.neotel.smfcore.security.service.manager.IGroupManager;
import com.neotel.smfcore.security.service.po.Group;
import com.neotel.smfcore.security.service.po.Menu;
import com.neotel.smfcore.security.service.po.Role;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Pageable;
import org.springframework.data.mongodb.core.query.Criteria;
......@@ -78,8 +80,10 @@ public class GroupManagerImpl implements IGroupManager {
}
@Override
public List<Group> findByPage(Query query, Pageable pageable) {
return groupDao.findByQuery(query,pageable);
public PageData<Group> findByPage(Query query, Pageable pageable) {
int totalCount = groupDao.countByQuery(query);
List<Group> list = groupDao.findByQuery(query, pageable);
return new PageData<Group>(list,totalCount);
}
@Override
......
......@@ -2,6 +2,7 @@ package com.neotel.smfcore.security.service.manager.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjectUtil;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.common.utils.FileUtil;
......@@ -54,8 +55,10 @@ public class MenuManagerImpl implements IMenuManager {
}
@Override
public List<Menu> findByPage(Query query, Pageable pageable) {
return menuDao.findByQuery(query, pageable);
public PageData<Menu> findByPage(Query query, Pageable pageable) {
int totalCount = menuDao.countByQuery(query);
List<Menu> list = menuDao.findByQuery(query, pageable);
return new PageData<Menu>(list,totalCount);
}
@Override
......
package com.neotel.smfcore.security.service.manager.impl;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.common.utils.Constants;
......@@ -51,8 +52,10 @@ public class RoleManagerImpl implements IRoleManager {
}
@Override
public List<Role> findByPage(Query query, Pageable pageable) {
return roleDao.findByQuery(query, pageable);
public PageData<Role> findByPage(Query query, Pageable pageable) {
int totalCount = roleDao.countByQuery(query);
List<Role> list = roleDao.findByQuery(query, pageable);
return new PageData<Role>(list,totalCount);
}
@Override
......
package com.neotel.smfcore.security.service.manager.impl;
import com.google.common.base.Strings;
import com.neotel.smfcore.common.bean.PageData;
import com.neotel.smfcore.common.exception.BadRequestException;
import com.neotel.smfcore.common.exception.ValidateException;
import com.neotel.smfcore.common.utils.Constants;
import com.neotel.smfcore.common.utils.FileUtil;
import com.neotel.smfcore.core.storage.service.po.StoragePos;
import com.neotel.smfcore.security.rest.bean.dto.RoleSmallDto;
import com.neotel.smfcore.security.rest.bean.dto.UserDto;
import com.neotel.smfcore.security.rest.bean.mapstruct.RoleMapper;
......@@ -120,8 +122,10 @@ public class UserManagerImpl implements IUserManager {
}
@Override
public List<User> findByPage(Query query, Pageable pageable) {
return userDao.findByQuery(query, pageable);
public PageData<User> findByPage(Query query, Pageable pageable) {
int totalCount = userDao.countByQuery(query);
List<User> list = userDao.findByQuery(query, pageable);
return new PageData<User>(list,totalCount);
}
@Override
......
支持 Markdown 格式
你添加了 0 到此讨论。请谨慎行事。
Finish editing this message first!