Commit e5466146 authored by lijiazhi's avatar lijiazhi
Browse files

update beetlsql3,springboot 2.5

parent ea3cb83a
package com.ibeetl.admin.console.dao; package com.ibeetl.admin.console.dao;
import org.beetl.sql.core.annotatoin.SqlResource;
import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.mapper.BaseMapper;
import com.ibeetl.admin.core.entity.CoreAudit; import com.ibeetl.admin.core.entity.CoreAudit;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.beetl.sql.mapper.BaseMapper;
import org.beetl.sql.mapper.annotation.Root;
import org.beetl.sql.mapper.annotation.SqlResource;
import java.util.Map;
@SqlResource("console.audit") @SqlResource("console.audit")
public interface AuditConsoleDao extends BaseMapper<CoreAudit> { public interface AuditConsoleDao extends BaseMapper<CoreAudit> {
PageQuery<CoreAudit> queryByCondtion(PageQuery<CoreAudit> query); PageResult<CoreAudit> queryByCondtion(PageRequest<CoreAudit> query, @Root Map paras);
} }
package com.ibeetl.admin.console.dao; package com.ibeetl.admin.console.dao;
import java.util.List; import java.util.List;
import java.util.Map;
import org.beetl.sql.core.annotatoin.SqlResource;
import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.mapper.BaseMapper;
import com.ibeetl.admin.core.entity.CoreDict; import com.ibeetl.admin.core.entity.CoreDict;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.beetl.sql.mapper.BaseMapper;
import org.beetl.sql.mapper.annotation.Root;
import org.beetl.sql.mapper.annotation.SqlResource;
/** /**
* CoreDict Dao * CoreDict Dao
*/ */
@SqlResource("console.dict") @SqlResource("console.dict")
public interface DictConsoleDao extends BaseMapper<CoreDict>{ public interface DictConsoleDao extends BaseMapper<CoreDict> {
public PageQuery<CoreDict> queryByCondition(PageQuery query); PageResult<CoreDict> queryByCondition(PageRequest query, @Root Map params);
public void batchDelCoreDictByIds( List<Long> ids); void batchDelCoreDictByIds( List<Long> ids);
} }
\ No newline at end of file
package com.ibeetl.admin.console.dao; package com.ibeetl.admin.console.dao;
import org.beetl.sql.core.annotatoin.SqlResource;
import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.mapper.BaseMapper;
import com.ibeetl.admin.core.entity.CoreFunction; import com.ibeetl.admin.core.entity.CoreFunction;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.beetl.sql.mapper.BaseMapper;
import org.beetl.sql.mapper.annotation.Root;
import org.beetl.sql.mapper.annotation.SqlResource;
import java.util.Map;
@SqlResource("console.function") @SqlResource("console.function")
public interface FunctionConsoleDao extends BaseMapper<CoreFunction> { public interface FunctionConsoleDao extends BaseMapper<CoreFunction> {
...@@ -14,5 +18,5 @@ public interface FunctionConsoleDao extends BaseMapper<CoreFunction> { ...@@ -14,5 +18,5 @@ public interface FunctionConsoleDao extends BaseMapper<CoreFunction> {
* *
* @param query * @param query
*/ */
public void queryByCondtion(PageQuery query); PageResult<CoreFunction> queryByCondtion(PageRequest query, @Root Map params);
} }
package com.ibeetl.admin.console.dao; package com.ibeetl.admin.console.dao;
import org.beetl.sql.core.annotatoin.SqlResource;
import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.mapper.BaseMapper;
import com.ibeetl.admin.core.entity.CoreMenu; import com.ibeetl.admin.core.entity.CoreMenu;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.beetl.sql.mapper.BaseMapper;
import org.beetl.sql.mapper.annotation.Root;
import org.beetl.sql.mapper.annotation.SqlResource;
import java.util.Map;
@SqlResource("console.menu") @SqlResource("console.menu")
public interface MenuConsoleDao extends BaseMapper<CoreMenu> { public interface MenuConsoleDao extends BaseMapper<CoreMenu> {
...@@ -13,7 +18,7 @@ public interface MenuConsoleDao extends BaseMapper<CoreMenu> { ...@@ -13,7 +18,7 @@ public interface MenuConsoleDao extends BaseMapper<CoreMenu> {
* 根据条件分页查询 * 根据条件分页查询
* @param query 查询条件 * @param query 查询条件
*/ */
void queryByCondtion(PageQuery query); PageResult<CoreMenu> queryByCondition(PageRequest query, @Root Map params);
} }
package com.ibeetl.admin.console.dao; package com.ibeetl.admin.console.dao;
import java.util.List; import java.util.List;
import java.util.Map;
import org.beetl.sql.core.annotatoin.Param;
import org.beetl.sql.core.annotatoin.SqlResource;
import org.beetl.sql.core.annotatoin.SqlStatement;
import org.beetl.sql.core.annotatoin.SqlStatementType;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.mapper.BaseMapper;
import com.ibeetl.admin.core.entity.CoreOrg; import com.ibeetl.admin.core.entity.CoreOrg;
import com.ibeetl.admin.core.entity.CoreUser; import com.ibeetl.admin.core.entity.CoreUser;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.beetl.sql.mapper.BaseMapper;
import org.beetl.sql.mapper.annotation.Root;
import org.beetl.sql.mapper.annotation.SqlResource;
@SqlResource("console.org") @SqlResource("console.org")
public interface OrgConsoleDao extends BaseMapper<CoreOrg> { public interface OrgConsoleDao extends BaseMapper<CoreOrg> {
PageResult<CoreOrg> queryByCondition(PageRequest query, @Root Map params);
PageResult<CoreUser> queryUserByCondition(PageRequest<CoreUser> query,@Root Map params);
void queryByCondtion(PageQuery<CoreOrg> query);
@SqlStatement(type=SqlStatementType.SELECT)
void queryUserByCondtion(PageQuery<CoreUser> query);
void batchDelByIds(@Param(value = "ids") List<Long> ids);
} }
package com.ibeetl.admin.console.dao; package com.ibeetl.admin.console.dao;
import java.util.List; import java.util.List;
import java.util.Map;
import org.beetl.sql.core.annotatoin.SqlResource;
import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.mapper.BaseMapper;
import com.ibeetl.admin.console.web.query.RoleUserQuery; import com.ibeetl.admin.console.web.query.RoleUserQuery;
import com.ibeetl.admin.core.entity.CoreRole; import com.ibeetl.admin.core.entity.CoreRole;
import com.ibeetl.admin.core.entity.CoreUser; import com.ibeetl.admin.core.entity.CoreUser;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.beetl.sql.mapper.BaseMapper;
import org.beetl.sql.mapper.annotation.Root;
import org.beetl.sql.mapper.annotation.SqlResource;
@SqlResource("console.role") @SqlResource("console.role")
public interface RoleConsoleDao extends BaseMapper<CoreRole> { public interface RoleConsoleDao extends BaseMapper<CoreRole> {
...@@ -17,7 +20,7 @@ public interface RoleConsoleDao extends BaseMapper<CoreRole> { ...@@ -17,7 +20,7 @@ public interface RoleConsoleDao extends BaseMapper<CoreRole> {
* 根据条件分页查询 * 根据条件分页查询
* @param query 查询条件 * @param query 查询条件
*/ */
void queryByCondtion(PageQuery query); PageResult<CoreRole> queryByCondition(PageRequest query, Map params);
/** /**
* 批量删除角色 * 批量删除角色
...@@ -28,9 +31,9 @@ public interface RoleConsoleDao extends BaseMapper<CoreRole> { ...@@ -28,9 +31,9 @@ public interface RoleConsoleDao extends BaseMapper<CoreRole> {
void batchDeleteRoleFunction(List<Long> ids); void batchDeleteRoleFunction(List<Long> ids);
void batchDeleteRoleMenu(List<Long> ids); void batchDeleteRoleMenu(List<Long> ids);
void batchDeleteUserRole(List<Long> ids); void batchDeleteUserRole(List<Long> ids);
PageQuery<CoreUser> queryUser(PageQuery query); PageResult<CoreUser> queryUser(PageRequest query, @Root Map params);
......
...@@ -2,12 +2,10 @@ package com.ibeetl.admin.console.dao; ...@@ -2,12 +2,10 @@ package com.ibeetl.admin.console.dao;
import java.util.List; import java.util.List;
import org.beetl.sql.core.annotatoin.Param;
import org.beetl.sql.core.annotatoin.SqlResource;
import org.beetl.sql.core.mapper.BaseMapper;
import com.ibeetl.admin.console.web.dto.RoleDataAccessFunction; import com.ibeetl.admin.console.web.dto.RoleDataAccessFunction;
import com.ibeetl.admin.core.entity.CoreRoleFunction; import com.ibeetl.admin.core.entity.CoreRoleFunction;
import org.beetl.sql.mapper.BaseMapper;
import org.beetl.sql.mapper.annotation.SqlResource;
@SqlResource("console.roleFunction") @SqlResource("console.roleFunction")
public interface RoleFunctionConsoleDao extends BaseMapper<CoreRoleFunction> { public interface RoleFunctionConsoleDao extends BaseMapper<CoreRoleFunction> {
......
package com.ibeetl.admin.console.dao; package com.ibeetl.admin.console.dao;
import org.beetl.sql.core.annotatoin.Param;
import org.beetl.sql.core.annotatoin.SqlResource;
import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.mapper.BaseMapper;
import com.ibeetl.admin.core.entity.CoreUser; import com.ibeetl.admin.core.entity.CoreUser;
import com.ibeetl.admin.core.entity.CoreUserRole; import com.ibeetl.admin.core.entity.CoreUserRole;
import com.ibeetl.admin.core.util.enums.GeneralStateEnum; import com.ibeetl.admin.core.util.enums.GeneralStateEnum;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.beetl.sql.mapper.BaseMapper;
import org.beetl.sql.mapper.annotation.Root;
import org.beetl.sql.mapper.annotation.SqlResource;
import java.util.List; import java.util.List;
import java.util.Map;
@SqlResource("console.user") @SqlResource("console.user")
public interface UserConsoleDao extends BaseMapper<CoreUser> { public interface UserConsoleDao extends BaseMapper<CoreUser> {
PageQuery<CoreUser> queryByCondtion(PageQuery<CoreUser> query); PageResult<CoreUser> queryByCondition(PageRequest<CoreUser> query, @Root Map params);
void batchDelUserByIds( List<Long> ids); void batchDelUserByIds( List<Long> ids);
......
package com.ibeetl.admin.console.service; package com.ibeetl.admin.console.service;
import com.ibeetl.admin.console.web.query.AuditQuery;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -9,6 +12,8 @@ import com.ibeetl.admin.console.dao.AuditConsoleDao; ...@@ -9,6 +12,8 @@ import com.ibeetl.admin.console.dao.AuditConsoleDao;
import com.ibeetl.admin.core.entity.CoreAudit; import com.ibeetl.admin.core.entity.CoreAudit;
import com.ibeetl.admin.core.service.CoreBaseService; import com.ibeetl.admin.core.service.CoreBaseService;
import java.util.Map;
@Service @Service
@Transactional @Transactional
public class AuditConsoleService extends CoreBaseService<CoreAudit> { public class AuditConsoleService extends CoreBaseService<CoreAudit> {
...@@ -19,11 +24,14 @@ public class AuditConsoleService extends CoreBaseService<CoreAudit> { ...@@ -19,11 +24,14 @@ public class AuditConsoleService extends CoreBaseService<CoreAudit> {
/** /**
* 根据条件查询 * 根据条件查询
* *
* @param query * @param condition
*/ */
public void queryByCondtion(PageQuery<CoreAudit> query) { public PageResult<CoreAudit> queryByCondtion(AuditQuery condition) {
PageQuery<CoreAudit> ret = auditConsoleDao.queryByCondtion(query); PageRequest pageRequest = condition.getPageRequest();
Map params = condition.getPageParam();
PageResult<CoreAudit> ret = auditConsoleDao.queryByCondtion(pageRequest,params);
queryListAfter(ret.getList()); queryListAfter(ret.getList());
return ret;
} }
......
...@@ -5,8 +5,11 @@ import java.util.HashMap; ...@@ -5,8 +5,11 @@ import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import com.ibeetl.admin.console.web.query.CoreDictQuery;
import org.apache.poi.ss.util.CellReference; import org.apache.poi.ss.util.CellReference;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -29,8 +32,10 @@ public class DictConsoleService extends CoreBaseService<CoreDict> { ...@@ -29,8 +32,10 @@ public class DictConsoleService extends CoreBaseService<CoreDict> {
@Autowired private DictConsoleDao dictDao; @Autowired private DictConsoleDao dictDao;
public PageQuery<CoreDict>queryByCondition(PageQuery query){ public PageResult<CoreDict> queryByCondition(CoreDictQuery query){
PageQuery ret = dictDao.queryByCondition(query); PageRequest pageRequest = query.getPageRequest();
Map params = query.getPageParam();
PageResult<CoreDict> ret = dictDao.queryByCondition(pageRequest,params);
queryListAfter(ret.getList()); queryListAfter(ret.getList());
return ret; return ret;
} }
...@@ -43,9 +48,9 @@ public class DictConsoleService extends CoreBaseService<CoreDict> { ...@@ -43,9 +48,9 @@ public class DictConsoleService extends CoreBaseService<CoreDict> {
throw new PlatformException("批量删除CoreDict失败", e); throw new PlatformException("批量删除CoreDict失败", e);
} }
} }
public List<CoreDict> queryExcel(PageQuery<CoreUser> query) { public List<CoreDict> queryExcel(PageRequest query) {
//同查询,不需要额外数据 //同查询,不需要额外数据
PageQuery ret = dictDao.queryByCondition(query); PageResult<CoreDict> ret = dictDao.queryByCondition(query,null);
queryListAfter(ret.getList()); queryListAfter(ret.getList());
return ret.getList(); return ret.getList();
......
...@@ -3,8 +3,12 @@ package com.ibeetl.admin.console.service; ...@@ -3,8 +3,12 @@ package com.ibeetl.admin.console.service;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
import com.ibeetl.admin.console.web.query.FunctionQuery;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -42,9 +46,11 @@ public class FunctionConsoleService extends CoreBaseService<CoreFunction> { ...@@ -42,9 +46,11 @@ public class FunctionConsoleService extends CoreBaseService<CoreFunction> {
CorePlatformService platformService; CorePlatformService platformService;
public void queryByCondtion(PageQuery<CoreFunction> query) { public PageResult<CoreFunction> queryByCondtion(FunctionQuery query) {
functionDao.queryByCondtion(query); PageRequest pageRequest = query.getPageRequest();
List<CoreFunction> list = query.getList(); Map params = query.getPageParam();
PageResult<CoreFunction> pageResult = functionDao.queryByCondtion(pageRequest,params);
List<CoreFunction> list = pageResult.getList();
this.queryListAfter(list); this.queryListAfter(list);
//处理父功能名称显示 //处理父功能名称显示
FunctionItem root = platformService.buildFunction(); FunctionItem root = platformService.buildFunction();
...@@ -57,13 +63,13 @@ public class FunctionConsoleService extends CoreBaseService<CoreFunction> { ...@@ -57,13 +63,13 @@ public class FunctionConsoleService extends CoreBaseService<CoreFunction> {
} }
function.set("parentFunctionText", name); function.set("parentFunctionText", name);
} }
return pageResult;
} }
public Long saveFunction(CoreFunction function){ public Long saveFunction(CoreFunction function){
functionDao.insert(function);
functionDao.insert(function,true);
platformService.clearFunctionCache(); platformService.clearFunctionCache();
return function.getId(); return function.getId();
} }
...@@ -125,7 +131,6 @@ public class FunctionConsoleService extends CoreBaseService<CoreFunction> { ...@@ -125,7 +131,6 @@ public class FunctionConsoleService extends CoreBaseService<CoreFunction> {
} }
/** /**
* 更新角色对应的功能点所有, * 更新角色对应的功能点所有,
* @param roleId
* @param data,必须包含id,和 dataAcerssType,采用模板更新 * @param data,必须包含id,和 dataAcerssType,采用模板更新
*/ */
public void updateFunctionAccessByRole(List<RoleDataAccessFunction> data ){ public void updateFunctionAccessByRole(List<RoleDataAccessFunction> data ){
...@@ -153,7 +158,6 @@ public class FunctionConsoleService extends CoreBaseService<CoreFunction> { ...@@ -153,7 +158,6 @@ public class FunctionConsoleService extends CoreBaseService<CoreFunction> {
/** 给角色赋予功能同时,根据赋予的功能权限,更新能访问的菜单 /** 给角色赋予功能同时,根据赋予的功能权限,更新能访问的菜单
* @param adds * @param adds
* @param updates
* @param dels * @param dels
* @return 返回增加的项的id,用于前端 * @return 返回增加的项的id,用于前端
*/ */
......
package com.ibeetl.admin.console.service; package com.ibeetl.admin.console.service;
import com.ibeetl.admin.console.dao.MenuConsoleDao; import com.ibeetl.admin.console.dao.MenuConsoleDao;
import com.ibeetl.admin.console.web.query.MenuQuery;
import com.ibeetl.admin.core.dao.CoreRoleMenuDao; import com.ibeetl.admin.core.dao.CoreRoleMenuDao;
import com.ibeetl.admin.core.entity.CoreMenu; import com.ibeetl.admin.core.entity.CoreMenu;
import com.ibeetl.admin.core.rbac.tree.MenuItem; import com.ibeetl.admin.core.rbac.tree.MenuItem;
...@@ -9,12 +10,15 @@ import com.ibeetl.admin.core.service.CorePlatformService; ...@@ -9,12 +10,15 @@ import com.ibeetl.admin.core.service.CorePlatformService;
import com.ibeetl.admin.core.util.PlatformException; import com.ibeetl.admin.core.util.PlatformException;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map;
@Service @Service
@Transactional @Transactional
...@@ -28,9 +32,12 @@ public class MenuConsoleService extends CoreBaseService<CoreMenu> { ...@@ -28,9 +32,12 @@ public class MenuConsoleService extends CoreBaseService<CoreMenu> {
@Autowired @Autowired
CorePlatformService platformService; CorePlatformService platformService;
public void queryByCondtion(PageQuery<CoreMenu> query) { public PageResult<CoreMenu> queryByCondition(MenuQuery condition) {
menuDao.queryByCondtion(query); PageRequest pageRequest = condition.getPageRequest();
queryListAfter(query.getList()); Map params = condition.getPageParam();
PageResult<CoreMenu> pageResult = menuDao.queryByCondition(pageRequest,params);
queryListAfter(pageResult.getList());
return pageResult;
} }
public Long saveMenu(CoreMenu menu) { public Long saveMenu(CoreMenu menu) {
...@@ -40,7 +47,7 @@ public class MenuConsoleService extends CoreBaseService<CoreMenu> { ...@@ -40,7 +47,7 @@ public class MenuConsoleService extends CoreBaseService<CoreMenu> {
if (queryCount > 0) { if (queryCount > 0) {
throw new PlatformException("菜单编码已存在"); throw new PlatformException("菜单编码已存在");
} }
menuDao.insert(menu, true); menuDao.insert(menu);
platformService.clearMenuCache(); platformService.clearMenuCache();
return menu.getId(); return menu.getId();
} }
......
...@@ -2,8 +2,13 @@ package com.ibeetl.admin.console.service; ...@@ -2,8 +2,13 @@ package com.ibeetl.admin.console.service;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map;
import com.ibeetl.admin.console.web.query.OrgQuery;
import com.ibeetl.admin.console.web.query.OrgUserQuery;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -34,9 +39,11 @@ public class OrgConsoleService extends CoreBaseService<CoreOrg> { ...@@ -34,9 +39,11 @@ public class OrgConsoleService extends CoreBaseService<CoreOrg> {
* 根据条件查询 * 根据条件查询
* @param query * @param query
*/ */
public void queryByCondtion(PageQuery<CoreOrg> query) { public PageResult<CoreOrg> queryByCondition(OrgQuery condition) {
orgDao.queryByCondtion(query); PageRequest request = condition.getPageRequest();
List<CoreOrg> list = query.getList(); Map params = condition.getPageParam();
PageResult<CoreOrg> pageResult = orgDao.queryByCondition(request,params);
List<CoreOrg> list = pageResult.getList();
queryListAfter(list); queryListAfter(list);
OrgItem root = platformService.buildOrg(); OrgItem root = platformService.buildOrg();
//处理父机构名称显示,没有用sql查询是考虑到跨数据库 //处理父机构名称显示,没有用sql查询是考虑到跨数据库
...@@ -46,11 +53,15 @@ public class OrgConsoleService extends CoreBaseService<CoreOrg> { ...@@ -46,11 +53,15 @@ public class OrgConsoleService extends CoreBaseService<CoreOrg> {
String name = item!=null?item.getName():""; String name = item!=null?item.getName():"";
org.set("parentOrgText", name); org.set("parentOrgText", name);
} }
return pageResult;
} }
public void queryUserByCondition(PageQuery<CoreUser> query) { public PageResult<CoreUser> queryUserByCondition(OrgUserQuery condition) {
orgDao.queryUserByCondtion(query); PageRequest pageRequest = condition.getPageRequest();
queryListAfter(query.getList()); Map param = condition.getPageParam();
PageResult<CoreUser> pageResult = orgDao.queryUserByCondition(pageRequest,param);
queryListAfter(pageResult.getList());
return pageResult;
} }
......
package com.ibeetl.admin.console.service; package com.ibeetl.admin.console.service;
import java.util.List; import java.util.List;
import java.util.Map;
import com.ibeetl.admin.console.web.query.RoleQuery;
import com.ibeetl.admin.console.web.query.RoleUserQuery;
import org.beetl.sql.core.SQLManager; import org.beetl.sql.core.SQLManager;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -54,17 +59,22 @@ public class RoleConsoleService extends CoreBaseService<CoreRole> { ...@@ -54,17 +59,22 @@ public class RoleConsoleService extends CoreBaseService<CoreRole> {
/** /**
* 根据条件查询 * 根据条件查询
* @param query * @param condition
*/ */
public void queryByCondtion(PageQuery query) { public PageResult<CoreRole> queryByCondition(RoleQuery condition) {
roleDao.queryByCondtion(query); PageRequest pageRequest = condition.getPageRequest();
super.queryListAfter(query.getList()); Map params = condition.getPageParam();
PageResult<CoreRole> pageResult = roleDao.queryByCondition(pageRequest,params);
super.queryListAfter(pageResult.getList());
return pageResult;
} }
public PageQuery<CoreUser> queryRoleUser(PageQuery query) { public PageResult<CoreUser> queryRoleUser(RoleUserQuery condition) {
OrgItem root = platformService.buildOrg(); OrgItem root = platformService.buildOrg();
PageQuery<CoreUser> ret = roleDao.queryUser(query); PageRequest pageRequest = condition.getPageRequest();
Map params = condition.getPageParam();
PageResult<CoreUser> ret = roleDao.queryUser(pageRequest,params);
List<CoreUser> list = ret.getList(); List<CoreUser> list = ret.getList();
//从缓存里取出组织机构名称 //从缓存里取出组织机构名称
for(CoreUser user:list) { for(CoreUser user:list) {
......
...@@ -3,10 +3,14 @@ package com.ibeetl.admin.console.service; ...@@ -3,10 +3,14 @@ package com.ibeetl.admin.console.service;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
import com.ibeetl.admin.console.web.query.UserQuery;
import org.apache.catalina.User; import org.apache.catalina.User;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
...@@ -52,11 +56,14 @@ public class UserConsoleService extends CoreBaseService<CoreUser> { ...@@ -52,11 +56,14 @@ public class UserConsoleService extends CoreBaseService<CoreUser> {
/** /**
* 根据条件查询 * 根据条件查询
* *
* @param query * @param condition
*/ */
public void queryByCondtion(PageQuery<CoreUser> query) { public PageResult<CoreUser> queryByCondition(UserQuery condition) {
PageQuery<CoreUser> ret = userDao.queryByCondtion(query); PageRequest pageRequest = condition.getPageRequest();
Map params = condition.getPageParam();
PageResult<CoreUser> ret = userDao.queryByCondition(pageRequest,params);
queryListAfter(ret.getList()); queryListAfter(ret.getList());
return ret;
} }
/** /**
...@@ -75,7 +82,7 @@ public class UserConsoleService extends CoreBaseService<CoreUser> { ...@@ -75,7 +82,7 @@ public class UserConsoleService extends CoreBaseService<CoreUser> {
user.setState(GeneralStateEnum.ENABLE.getValue()); user.setState(GeneralStateEnum.ENABLE.getValue());
user.setPassword(passwordEncryptService.password(user.getPassword())); user.setPassword(passwordEncryptService.password(user.getPassword()));
user.setDelFlag(DelFlagEnum.NORMAL.getValue()); user.setDelFlag(DelFlagEnum.NORMAL.getValue());
userDao.insert(user, true); userDao.insert(user);
if(StringUtils.isNotEmpty(user.getAttachmentId())){ if(StringUtils.isNotEmpty(user.getAttachmentId())){
//更新附件详细信息,关联到这个用户 //更新附件详细信息,关联到这个用户
fileService.updateFile(user.getAttachmentId(), User.class.getSimpleName(), String.valueOf(user.getId())); fileService.updateFile(user.getAttachmentId(), User.class.getSimpleName(), String.valueOf(user.getId()));
...@@ -152,7 +159,7 @@ public class UserConsoleService extends CoreBaseService<CoreUser> { ...@@ -152,7 +159,7 @@ public class UserConsoleService extends CoreBaseService<CoreUser> {
/** /**
* 重置用户密码 * 重置用户密码
* *
* @param uId * @param id
* @param password * @param password
*/ */
public int resetPassword(Long id, String password) { public int resetPassword(Long id, String password) {
...@@ -185,8 +192,10 @@ public class UserConsoleService extends CoreBaseService<CoreUser> { ...@@ -185,8 +192,10 @@ public class UserConsoleService extends CoreBaseService<CoreUser> {
sqlManager.insert(userRole); sqlManager.insert(userRole);
} }
public List<UserExcelExportData> queryExcel(PageQuery<CoreUser> query) { public List<UserExcelExportData> queryExcel(UserQuery condition) {
PageQuery<CoreUser> ret = userDao.queryByCondtion(query); PageRequest pageRequest = condition.getPageRequest();
Map params = condition.getPageParam();
PageResult<CoreUser> ret = userDao.queryByCondition(pageRequest,params);
List<CoreUser> list = ret.getList(); List<CoreUser> list = ret.getList();
OrgItem orgRoot = platformService.buildOrg(); OrgItem orgRoot = platformService.buildOrg();
List<UserExcelExportData> items = new ArrayList<>(); List<UserExcelExportData> items = new ArrayList<>();
......
package com.ibeetl.admin.console.web; package com.ibeetl.admin.console.web;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
...@@ -24,7 +25,7 @@ import com.ibeetl.admin.core.entity.CoreAudit; ...@@ -24,7 +25,7 @@ import com.ibeetl.admin.core.entity.CoreAudit;
import com.ibeetl.admin.core.util.AnnotationUtil; import com.ibeetl.admin.core.util.AnnotationUtil;
import com.ibeetl.admin.core.web.JsonResult; import com.ibeetl.admin.core.web.JsonResult;
/** /**
* 用户管理接口 * 用户审计接口
* @author xiandafu * @author xiandafu
* *
*/ */
...@@ -38,7 +39,6 @@ public class AuditConsoleController { ...@@ -38,7 +39,6 @@ public class AuditConsoleController {
/*页面*/ /*页面*/
@GetMapping(MODEL + "/index.do") @GetMapping(MODEL + "/index.do")
@Function("trace") @Function("trace")
public ModelAndView index() { public ModelAndView index() {
...@@ -49,7 +49,6 @@ public class AuditConsoleController { ...@@ -49,7 +49,6 @@ public class AuditConsoleController {
/*Json*/ /*Json*/
@PostMapping(MODEL + "/view.json") @PostMapping(MODEL + "/view.json")
@ResponseBody @ResponseBody
@Function("trace") @Function("trace")
...@@ -63,11 +62,9 @@ public class AuditConsoleController { ...@@ -63,11 +62,9 @@ public class AuditConsoleController {
@RequestMapping(MODEL + "/list.json") @RequestMapping(MODEL + "/list.json")
@Function("trace") @Function("trace")
@ResponseBody @ResponseBody
public JsonResult<PageQuery<CoreAudit>> list(AuditQuery condtion) { public JsonResult<PageResult<CoreAudit>> list(AuditQuery condition) {
PageResult<CoreAudit> pageResult = auditConsoleService.queryByCondtion(condition);
PageQuery<CoreAudit> page = condtion.getPageQuery(); return JsonResult.success(pageResult);
auditConsoleService.queryByCondtion(page);
return JsonResult.success(page);
} }
......
...@@ -14,6 +14,9 @@ import javax.servlet.http.HttpServletResponse; ...@@ -14,6 +14,9 @@ import javax.servlet.http.HttpServletResponse;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.DefaultPageRequest;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.jxls.common.Context; import org.jxls.common.Context;
import org.jxls.reader.ReaderBuilder; import org.jxls.reader.ReaderBuilder;
import org.jxls.reader.ReaderConfig; import org.jxls.reader.ReaderConfig;
...@@ -92,11 +95,10 @@ public class DictConsoleController{ ...@@ -92,11 +95,10 @@ public class DictConsoleController{
@PostMapping(MODEL + "/list.json") @PostMapping(MODEL + "/list.json")
@Function("dict.query") @Function("dict.query")
@ResponseBody @ResponseBody
public JsonResult<PageQuery> list(CoreDictQuery condtion) public JsonResult<PageResult<CoreDict>> list(CoreDictQuery condition)
{ {
PageQuery page = condtion.getPageQuery(); PageResult<CoreDict> pageResult = dictService.queryByCondition(condition);
dictService.queryByCondition(page); return JsonResult.success(pageResult);
return JsonResult.success(page);
} }
@PostMapping(MODEL + "/add.json") @PostMapping(MODEL + "/add.json")
...@@ -147,13 +149,10 @@ public class DictConsoleController{ ...@@ -147,13 +149,10 @@ public class DictConsoleController{
@PostMapping(MODEL + "/excel/export.json") @PostMapping(MODEL + "/excel/export.json")
@Function("dict.export") @Function("dict.export")
@ResponseBody @ResponseBody
public JsonResult<String> export(HttpServletResponse response,CoreDictQuery condtion) { public JsonResult<String> export(HttpServletResponse response,CoreDictQuery condition) {
String excelTemplate ="excelTemplates/admin/dict/dict_collection_template.xls"; String excelTemplate ="excelTemplates/admin/dict/dict_collection_template.xls";
PageQuery<CoreUser> page = condtion.getPageQuery(); PageRequest page = DefaultPageRequest.of(1,Integer.MAX_VALUE);
//取出全部符合条件的
page.setPageSize(Integer.MAX_VALUE);
page.setPageNumber(1);
page.setTotalRow(Integer.MAX_VALUE);
List<CoreDict> dicts =dictService.queryExcel(page); List<CoreDict> dicts =dictService.queryExcel(page);
try(InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream(excelTemplate)) { try(InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream(excelTemplate)) {
if(is==null) { if(is==null) {
......
...@@ -9,6 +9,7 @@ import java.util.Map; ...@@ -9,6 +9,7 @@ import java.util.Map;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
...@@ -153,11 +154,10 @@ public class FunctionController { ...@@ -153,11 +154,10 @@ public class FunctionController {
@RequestMapping(MODEL + "/list.json") @RequestMapping(MODEL + "/list.json")
@Function("function.query") @Function("function.query")
@ResponseBody @ResponseBody
public JsonResult<PageQuery<CoreFunction>> list(FunctionQuery condtion) { public JsonResult<PageResult<CoreFunction>> list(FunctionQuery condtion) {
PageQuery page = condtion.getPageQuery(); PageResult<CoreFunction> pageResult = functionConsoleService.queryByCondtion(condtion);
functionConsoleService.queryByCondtion(page); return JsonResult.success(pageResult);
return JsonResult.success(page);
} }
......
...@@ -7,6 +7,8 @@ import java.util.Map; ...@@ -7,6 +7,8 @@ import java.util.Map;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
...@@ -74,7 +76,6 @@ public class MenuController { ...@@ -74,7 +76,6 @@ public class MenuController {
/** /**
* 查询 * 查询
* @param menu
* @return * @return
*/ */
@PostMapping(MODEL + "/list/condition.json") @PostMapping(MODEL + "/list/condition.json")
...@@ -89,10 +90,9 @@ public class MenuController { ...@@ -89,10 +90,9 @@ public class MenuController {
@PostMapping(MODEL + "/list.json") @PostMapping(MODEL + "/list.json")
@Function("menu.query") @Function("menu.query")
@ResponseBody @ResponseBody
public JsonResult<PageQuery> list(MenuQuery condtion) { public JsonResult<PageResult<CoreMenu>> list(MenuQuery condition) {
PageQuery page = condtion.getPageQuery(); PageResult<CoreMenu> pageResult = menuService.queryByCondition(condition);
menuService.queryByCondtion(page); return JsonResult.success(pageResult);
return JsonResult.success(page);
} }
......
...@@ -8,6 +8,8 @@ import org.apache.commons.lang3.StringUtils; ...@@ -8,6 +8,8 @@ import org.apache.commons.lang3.StringUtils;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.beetl.sql.core.engine.PageQuery; import org.beetl.sql.core.engine.PageQuery;
import org.beetl.sql.core.page.PageRequest;
import org.beetl.sql.core.page.PageResult;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller; import org.springframework.stereotype.Controller;
import org.springframework.validation.BindingResult; import org.springframework.validation.BindingResult;
...@@ -92,16 +94,16 @@ public class OrgConsoleController { ...@@ -92,16 +94,16 @@ public class OrgConsoleController {
/** /**
* 组织机构列表 分页 * 组织机构列表 分页
* @param condtion 查询条件 * @param condition 查询条件
* @return * @return
*/ */
@PostMapping(MODEL + "/list.json") @PostMapping(MODEL + "/list.json")
@Function("org.query") @Function("org.query")
@ResponseBody @ResponseBody
public JsonResult<PageQuery<CoreOrg>> list(OrgQuery condtion) { public JsonResult<PageResult<CoreOrg>> list(OrgQuery condition) {
PageQuery page = condtion.getPageQuery();
orgConsoleService.queryByCondtion(page); PageResult<CoreOrg> pageResult = orgConsoleService.queryByCondition(condition);
return JsonResult.success(page); return JsonResult.success(pageResult);
} }
/** /**
...@@ -111,7 +113,7 @@ public class OrgConsoleController { ...@@ -111,7 +113,7 @@ public class OrgConsoleController {
@PostMapping(MODEL + "/list/condition.json") @PostMapping(MODEL + "/list/condition.json")
@Function("org.query") @Function("org.query")
@ResponseBody @ResponseBody
public JsonResult<List<Map<String, Object>>> listCondtion() { public JsonResult<List<Map<String, Object>>> listCondition() {
List<Map<String, Object>> list = AnnotationUtil.getInstance().getAnnotations(Query.class, OrgQuery.class); List<Map<String, Object>> list = AnnotationUtil.getInstance().getAnnotations(Query.class, OrgQuery.class);
return JsonResult.success(list); return JsonResult.success(list);
} }
...@@ -181,10 +183,9 @@ public class OrgConsoleController { ...@@ -181,10 +183,9 @@ public class OrgConsoleController {
@PostMapping(MODEL + "/user/list.json") @PostMapping(MODEL + "/user/list.json")
@Function("org.query") @Function("org.query")
@ResponseBody @ResponseBody
public JsonResult<PageQuery<CoreUser>> getUsers(OrgUserQuery userQuery) { public JsonResult<PageResult<CoreUser>> getUsers(OrgUserQuery userQuery) {
PageQuery<CoreUser> page = userQuery.getPageQuery(); PageResult<CoreUser> pageResult = orgConsoleService.queryUserByCondition(userQuery);
orgConsoleService.queryUserByCondition(page); return JsonResult.success(pageResult);
return JsonResult.success(page);
} }
} }
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment