kaifabu/AssetsMap
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

完成初版

Browse Source
This commit is contained in:
RuicyWu
2026-06-18 16:26:31 +08:00
parent 6ca67ec941
commit 8e3dd5e1cd
27 changed files with 5024 additions and 678 deletions
Download Patch File Download Diff File Expand all files Collapse all files

571
src/main/java/com/seeyon/apps/assetsmap/service/AssetsQueryService.java
View File

@@ -1,158 +1,469 @@
package com.seeyon.apps.assetsmap.service;
import cn.hutool.log.Log;
import com.seeyon.apps.assetsmap.config.AssetsMapConfigProvider;
import com.seeyon.apps.assetsmap.constants.AssetsMapConstans;
import com.seeyon.apps.assetsmap.vo.AssetsCatagory;
import com.seeyon.apps.assetsmap.vo.AssetsItem;
import com.seeyon.apps.assetsmap.vo.BoundsQueryVo;
import com.seeyon.apps.assetsmap.vo.RegionVo;
import com.seeyon.ctp.common.AppContext;
import com.seeyon.ctp.common.exceptions.BusinessException;
import com.seeyon.ctp.organization.bo.V3xOrgDepartment;
import com.seeyon.ctp.common.po.ctpenumnew.CtpEnumItem;
import com.seeyon.ctp.organization.bo.V3xOrgAccount;
import com.seeyon.ctp.organization.manager.OrgManager;
import com.seeyon.ctp.util.JDBCAgent;
import com.seeyon.utils.form.*;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang.StringUtils;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;
public class AssetsQueryService {
private AssetsMapConfigProvider configProvider = (AssetsMapConfigProvider) AppContext.getBean("assetsMapConfigProvider");
private OrgManager orgManager = (OrgManager) AppContext.getBean("orgManager");
private static final Log log = Log.get(AssetsQueryService.class);
// 部门名称缓存，避免 N+1 查询
private Map<Long, String> deptCache = new HashMap<>();
private String getFormNo(){
return configProvider.getBizConfigByKey(AssetsMapConstans.ASSETSFORMNO);
}
private TableContext getMasterTableContext() throws Exception {
return FormTableExecutor.master(getFormNo());
}
public List<RegionVo> queryAllZoneAssets() throws Exception {
System.out.println("表单编码为:" + getFormNo());
TableContext tableContext = FormTableExecutor.master(getFormNo());
List<FormColumn> formColumns = FormTableExecutor.query(tableContext,null, null, true);
List<RegionVo> regionVos = new ArrayList<>();
List<FormWhereCondition> conditions = buildQueryCondition();
List<FormColumn> formColumns = FormTableExecutor.query(tableContext, null, conditions, true);
System.out.println("查询出的数据条数：" + formColumns.size());
// 用 Map 做 O(1) 查找，替代 List 遍历
Map<String, RegionVo> regionMap = new HashMap<>();
for (FormColumn formColumn : formColumns) {
Map<String, Object> fieldsMap = formColumn.getFieldsMap();
if(fieldsMap == null) {
if (fieldsMap == null) {
continue;
}
upsertRegionVos(regionVos,fieldsMap);
upsertRegionVos(regionMap, fieldsMap);
}
return regionVos;
return new ArrayList<>(regionMap.values());
}
public void upsertRegionVos(List<RegionVo> regionVos, Map<String, Object> fieldsMap) {
private List<FormWhereCondition> buildQueryCondition() {
long currentAccountId = AppContext.currentAccountId();
List<FormWhereCondition> conditions = new ArrayList<>();
conditions.add(FormWhereCondition.build().display("所属单位-").value(currentAccountId).concatFactor(ClauseFactor.OR));
conditions.add(FormWhereCondition.build().display("管理单位-").value(currentAccountId).concatFactor(ClauseFactor.OR));
return conditions;
}
String latStr = (String) fieldsMap.get("纬度");
String lngStr = (String) fieldsMap.get("经度");
/**
* 视口懒加载：通过数据库层经纬度范围过滤，只查询视口内的资产
* 生成 SQL: WHERE 纬度 >= south AND 纬度 <= north AND 经度 >= west AND 经度 <= east
*/
public List<RegionVo> queryAssetsByBounds(BoundsQueryVo vo) throws Exception {
TableContext tableContext = FormTableExecutor.master(getFormNo());
List<FormWhereCondition> conditions = new ArrayList<>();
// 如果传了 assetId，按 资产编号 精确查询，忽略经纬度范围
if (StringUtils.isNotBlank(vo.getAssetId())) {
conditions.add(FormWhereCondition.build().display("资产编号").value(vo.getAssetId()));
} else {
conditions.add(FormWhereCondition.build().display("经度-").between(vo.getWest(), vo.getEast()));
conditions.add(FormWhereCondition.build().display("纬度-").between(vo.getSouth(), vo.getNorth()));
}
conditions.add(FormWhereCondition.build().display("经度-").clauseFactor(ClauseFactor.NOT_NULL));
conditions.add(FormWhereCondition.build().display("纬度-").clauseFactor(ClauseFactor.NOT_NULL));
// 代码层过滤权限，避免 LIKE 导致索引失效
boolean showAll = showAll();
log.info("是否允许查看所有数据: " + showAll);
final String permIdStr = showAll ? null : (AppContext.currentAccountId() + "");
if (StringUtils.isNotBlank(vo.getOwner())) {
conditions.add(FormWhereCondition.build().display("所属单位").value(vo.getOwner()));
}
// 1️⃣ 经纬度必须有
if (StringUtils.isAnyBlank(latStr, lngStr)) {
if (StringUtils.isNotBlank(vo.getLevel2())) {
conditions.add(FormWhereCondition.build().display("资产类型二级").value(vo.getLevel2()));
}
if (StringUtils.isNotBlank(vo.getLevel1())) {
conditions.add(FormWhereCondition.build().display("资产类型一级").value(vo.getLevel1()));
}
if (StringUtils.isNotBlank(vo.getLevel3())) {
conditions.add(FormWhereCondition.build().display("资产分类-").value(vo.getLevel3()));
}
System.out.println("开始查询资产数据");
List<FormColumn> formColumns = FormTableExecutor.query(tableContext, null, conditions, true);
// 代码层过滤权限（当前单位及下级单位）
if (!showAll && formColumns != null) {
List<String> unitIds = getCurrentAndChildUnitIds();
formColumns = formColumns.stream()
.filter(col -> {
Map<String, Object> fields = col.getFieldsMap();
if (fields == null) return false;
Object permObj = fields.get("查看权限-选单位");
String perm = permObj == null ? null : permObj.toString();
return hasPermission(perm, unitIds);
})
.collect(Collectors.toList());
}
log.info("权限过滤后的数据条数: " + formColumns.size());
Map<String, RegionVo> regionMap = new HashMap<>();
for (FormColumn formColumn : formColumns) {
Map<String, Object> fieldsMap = formColumn.getFieldsMap();
if (fieldsMap == null) continue;
upsertRegionVos(regionMap, fieldsMap);
}
log.info("返回资产数据结果");
return new ArrayList<>(regionMap.values());
}
private boolean showAll() throws Exception {
V3xOrgAccount currentAccount = orgManager.getAccountById(AppContext.currentAccountId());
if(currentAccount == null) {
return false;
}else {
return currentAccount.getName().contains("国清办")
|| currentAccount.getName().contains("国资局")
|| currentAccount.getName().contains("软件开发");
}
}
/**
* 获取当前登录者单位及其所有下级单位的ID列表
*/
private List<String> getCurrentAndChildUnitIds() {
List<String> ids = new ArrayList<>();
long currentAccountId = AppContext.currentAccountId();
JDBCAgent jdbcAgent = new JDBCAgent();
try {
// 查当前单位的 path
jdbcAgent.execute("select path from org_unit where id = ?", currentAccountId);
List list = jdbcAgent.resultSetToList();
if (list == null || list.isEmpty()) {
ids.add(String.valueOf(currentAccountId));
return ids;
}
Map unitMap = (Map) list.get(0);
String rootPath = unitMap.get("path") + "";
// 查所有子单位
jdbcAgent.execute("select id from org_unit where path like ?", rootPath + "%");
list = jdbcAgent.resultSetToList();
if (list != null) {
for (Object o : list) {
Map map = (Map) o;
ids.add(map.get("id") + "");
}
}
} catch (Exception e) {
e.printStackTrace();
ids.add(String.valueOf(currentAccountId));
} finally {
jdbcAgent.close();
}
return ids;
}
/**
* 检查权限字段是否包含当前单位或下级单位
* permField: 逗号分隔的单位ID字符串，如 "100,200,300"
* unitIds: 当前单位及下级单位ID列表
*/
private boolean hasPermission(String permField, List<String> unitIds) {
if (StringUtils.isBlank(permField) || unitIds == null || unitIds.isEmpty()) {
return false;
}
// 用逗号分隔后逐一匹配
String[] permParts = permField.split(",");
for (String part : permParts) {
String trimmed = part.trim();
if (unitIds.contains(trimmed)) {
return true;
}
}
return false;
}
/**
* 保存资产边界数据到表单字段"资产边界数据"
* polygonData: JSON格式，包含polygon坐标和color颜色
*/
public void saveAssetPolygon(String assetId, String polygonData) throws Exception {
if (StringUtils.isBlank(assetId)) {
throw new IllegalArgumentException("assetId不能为空");
}
List<FormUpdateField> updateFields = new ArrayList<>();
updateFields.add(FormUpdateField.build().display("资产边界数据").value(polygonData));
List<FormWhereCondition> conditions = new ArrayList<>();
conditions.add(FormWhereCondition.build().display("id").value(assetId));
FormTableExecutor.update(getMasterTableContext(),updateFields,conditions);
}
public String getDetailBaseUrlByAssetsType(String assetsType) throws Exception {
TableContext master = FormTableExecutor.master(configProvider.getBizConfigByKey(AssetsMapConstans.ASSETSDETAILURLCONFIGFORMNO));
List<FormWhereCondition> conditions = new ArrayList<>();
if(StringUtils.isBlank(assetsType)) {
conditions.add(FormWhereCondition.build().display("资产类型").value("不动产"));
}else {
conditions.add(FormWhereCondition.build().display("资产类型").value(assetsType));
}
FormColumn formColumn = FormTableExecutor.queryOne(master, conditions, true);
if(formColumn == null) {
return null;
}
Object urlObj = formColumn.getFieldsMap().get("前置地址");
return urlObj == null ? null : urlObj.toString();
}
/**
* 查询单个资产的边界数据
*/
public Map<String, String> getAssetBound(String assetId) throws Exception {
if (StringUtils.isBlank(assetId)) {
return null;
}
TableContext tableContext = FormTableExecutor.master(getFormNo());
List<FormWhereCondition> conditions = new ArrayList<>();
conditions.add(FormWhereCondition.build().display("id").value(assetId));
FormColumn formColumn = FormTableExecutor.queryOne(tableContext, conditions, true);
if (formColumn == null) {
log.info("getAssetBound: 未查到记录, assetId=" + assetId);
return null;
}
Map<String, Object> fieldsMap = formColumn.getFieldsMap();
if (fieldsMap == null) {
return null;
}
log.info("getAssetBound: 查到记录, assetId=" + assetId + ", 资产编号=" + fieldsMap.get("资产编号") + ", 资产名称=" + fieldsMap.get("资产名称"));
log.info("getAssetBound: 资产边界数据字段值=" + fieldsMap.get("资产边界数据") + ", 类型=" + (fieldsMap.get("资产边界数据") == null ? "null" : fieldsMap.get("资产边界数据").getClass().getName()));
Object boundObj = fieldsMap.get("资产边界数据");
String boundData = boundObj == null ? null : boundObj.toString();
Map<String, String> result = new HashMap<>();
result.put("boundData", boundData);
return result;
}
/**
* 返回当前登录者单位的树形结构
* path 每4字符代表一个层级，如 0000 → 00000001 → 000000010001
*/
public List<Map<String, Object>> getDeptSelectOptions() throws BusinessException {
long currentAccountId = AppContext.currentAccountId();
JDBCAgent jdbcAgent = new JDBCAgent();
try {
// 查当前单位的 path
jdbcAgent.execute("select path from org_unit where id = ?", currentAccountId);
List list = jdbcAgent.resultSetToList();
if (list == null || list.isEmpty()) {
return new ArrayList<>();
}
Map unitMap = (Map) list.get(0);
String rootPath = unitMap.get("path") + "";
// 查所有子单位
jdbcAgent.execute("select id, name, path from org_unit where path like ?", rootPath + "%");
list = jdbcAgent.resultSetToList();
// 用 LinkedHashMap 保持插入顺序，path → node
Map<String, Map<String, Object>> nodeMap = new LinkedHashMap<>();
for (Object o : list) {
Map map = (Map) o;
String path = map.get("path") + "";
Map<String, Object> node = new LinkedHashMap<>();
node.put("id", map.get("id") + "");
node.put("name", map.get("name") + "");
node.put("path", path);
node.put("children", new ArrayList<Map<String, Object>>());
nodeMap.put(path, node);
}
// 按 path 长度排序（浅层先处理），逐个挂到父节点
List<Map<String, Object>> roots = new ArrayList<>();
List<String> sortedPaths = new ArrayList<>(nodeMap.keySet());
Collections.sort(sortedPaths, Comparator.comparingInt(String::length));
for (String path : sortedPaths) {
Map<String, Object> node = nodeMap.get(path);
if (path.equals(rootPath) || path.length() <= 4) {
roots.add(node);
} else {
// 父节点 path = 去掉最后4字符
String parentPath = path.substring(0, path.length() - 4);
Map<String, Object> parent = nodeMap.get(parentPath);
if (parent != null) {
((List<Map<String, Object>>) parent.get("children")).add(node);
} else {
// 找不到父节点，作为根节点
roots.add(node);
}
}
}
return roots;
} catch (Exception e) {
e.printStackTrace();
return new ArrayList<>();
} finally {
jdbcAgent.close();
}
}
public Map<String,AssetsCatagory> getAssetsCatagorySelectOptions() throws Exception {
TableContext tableContext = FormTableExecutor.master(getFormNo());
Map<String, CtpEnumItem> enumItemMap = EnumMapUtils.getEnumItemMap(tableContext.getTableBean(), "资产分类");
if(enumItemMap == null) {
return new HashMap<>();
}
Map<String,AssetsCatagory> resultMap = new HashMap<>();
for (String key : enumItemMap.keySet()) {
CtpEnumItem tempItem = enumItemMap.get(key);
AssetsCatagory assetsCatagory = new AssetsCatagory();
assetsCatagory.setId(tempItem.getId() + "");
assetsCatagory.setShowValue(key);
resultMap.put(key,assetsCatagory);
}
return resultMap;
}
/**
* 生成 region 的唯一 key，用于 Map 查找
*/
private String regionKey(double lat, double lng, String address) {
return lat + "_" + lng + "_" + address;
}
/**
* 优化：接收 Map 而非 List，O(1) 查找替代 O(n) 遍历
*/
public void upsertRegionVos(Map<String, RegionVo> regionMap, Map<String, Object> fieldsMap) {
BigDecimal latObj = (BigDecimal) fieldsMap.get("纬度-");
BigDecimal lngObj = (BigDecimal) fieldsMap.get("经度-");
if (latObj == null || lngObj == null) {
return;
}
double lat = Double.parseDouble(latStr);
double lng = Double.parseDouble(lngStr);
double lat = Double.parseDouble(latObj.toString());
double lng = Double.parseDouble(lngObj.toString());
String address = (String) fieldsMap.get("位置详情");
String owner = (String) fieldsMap.get("权属公司");
Object addrObj = fieldsMap.get("所在位置");
String address = addrObj == null ? null : addrObj.toString();
// 2️⃣ 地址 & 权属公司建议也做非空控制（关键！）
if (StringUtils.isAnyBlank(address)) {
if (StringUtils.isBlank(address)) {
return;
}
String assetId = getStringValue(fieldsMap,"id");
String assetId = getStringValue(fieldsMap, "id");
AssetsItem newAsset = buildAssetsItem(fieldsMap);
Long managerId = fieldsMap.get("运营单位") == null ? null : Long.parseLong(fieldsMap.get("运营单位") + "");
String deptName = getDeptName(managerId);
// 3️⃣ 查找区域
for (RegionVo regionVo : regionVos) {
// 3.1 经纬度必须存在
if (regionVo.getLat() == null || regionVo.getLng() == null) {
continue;
String key = regionKey(lat, lng, address);
RegionVo regionVo = regionMap.get(key);
if (regionVo != null) {
// 判断资产是否已存在
boolean exists = regionVo.getAssets().stream()
.anyMatch(a -> a.getId().equals(assetId));
if (!exists) {
regionVo.getAssets().add(newAsset);
}
} else {
// 新建区域
RegionVo newRegion = new RegionVo();
newRegion.setLat(lat);
newRegion.setLng(lng);
newRegion.setAddress(address);
newRegion.setManager(getStringValue(fieldsMap,"管理单位"));
boolean sameLocation =
Double.compare(regionVo.getLat(), lat) == 0 &&
Double.compare(regionVo.getLng(), lng) == 0;
List<AssetsItem> assets = new ArrayList<>();
assets.add(newAsset);
newRegion.setAssets(assets);
// 3.2 地址 & 权属公司必须非空才参与匹配
if (!sameLocation ||
StringUtils.isAnyBlank(regionVo.getAddress())) {
continue;
}
boolean sameAddress = address.equals(regionVo.getAddress());
if (sameAddress) {
// 4️⃣ 判断资产是否存在
boolean exists = regionVo.getAssets().stream()
.anyMatch(a -> a.getId().equals(assetId) );
if (!exists) {
regionVo.getAssets().add(newAsset);
}
return;
}
regionMap.put(key, newRegion);
}
// 5️⃣ 新建区域（这里可以放心，因为关键字段都有值）
RegionVo newRegion = new RegionVo();
newRegion.setLat(lat);
newRegion.setLng(lng);
newRegion.setAddress(address);
newRegion.setOwner(owner);
newRegion.setManager(deptName);
List<AssetsItem> assets = new ArrayList<>();
assets.add(newAsset);
newRegion.setAssets(assets);
regionVos.add(newRegion);
}
private String getDeptName(Long deptId) {
if(deptId != null) {
try {
V3xOrgDepartment department = orgManager.getDepartmentById(deptId);
if(department != null) {
return department.getName();
}
}catch (Exception e) {
}
/**
* 优化：带缓存的单位名称查询
*/
private String getUnitName(Long unitId) {
if (unitId == null) {
return null;
}
if (deptCache.containsKey(unitId)) {
return deptCache.get(unitId);
}
try {
V3xOrgAccount account = orgManager.getAccountById(unitId);
String name = account != null ? account.getName() : null;
deptCache.put(unitId, name);
return name;
} catch (Exception e) {
deptCache.put(unitId, null);
return null;
}
return null;
}
private AssetsItem buildAssetsItem(Map<String, Object> fieldsMap) {
AssetsItem assetsItem = new AssetsItem();
assetsItem.setId(getStringValue(fieldsMap,"id"));
assetsItem.setArea(fieldsMap.get("资产面积") == null ? null : Double.parseDouble(fieldsMap.get("资产面积") + ""));
assetsItem.setTenant(getStringValue(fieldsMap,"租户名称"));
assetsItem.setPurpose(getStringValue(fieldsMap,"资产用途"));
assetsItem.setRemark(getStringValue(fieldsMap,"备注"));
assetsItem.setOwner(getStringValue(fieldsMap,"权属单位"));
assetsItem.setAssetName(getStringValue(fieldsMap,"资产名称"));
assetsItem.setAddress(getStringValue(fieldsMap,"位置详情"));
String certNo = fieldsMap.get("权证号码") == null ? null : (String)fieldsMap.get("权证号码");
// assetsItem.setManager(fieldsMap.get("运营单位") == null ? null : (String)fieldsMap.get("运营单位") + "");
Long managerId = fieldsMap.get("运营单位") == null ? null : Long.parseLong(fieldsMap.get("运营单位") + "");
assetsItem.setLat(getStringValue(fieldsMap,"纬度"));
assetsItem.setLng(getStringValue(fieldsMap,"经度"));
assetsItem.setManager(getDeptName(managerId));
assetsItem.setCertNo(certNo);
assetsItem.setStatus(getStringValue(fieldsMap,"资产状态"));
assetsItem.setId(getStringValue(fieldsMap, "id"));
assetsItem.setArea(fieldsMap.get("数量面积") == null ? null : Double.parseDouble(fieldsMap.get("数量面积") + ""));
assetsItem.setAssetCode(getStringValue(fieldsMap, "资产编号"));
assetsItem.setRemark(getStringValue(fieldsMap, "备注"));
assetsItem.setAssetName(getStringValue(fieldsMap, "资产名称"));
assetsItem.setAddress(getStringValue(fieldsMap, "所在位置"));
assetsItem.setLat(Optional.ofNullable(fieldsMap.get("纬度-")).map(Object::toString).orElse(null));
assetsItem.setLng(Optional.ofNullable(fieldsMap.get("经度-")).map(Object::toString).orElse(null));
assetsItem.setManager(getStringValue(fieldsMap,"管理单位"));
assetsItem.setAssetType(getStringValue(fieldsMap, "资产类型一级"));
return assetsItem;
}
private String getStringValue(Map<String, Object> fieldsMap, String key) {
return fieldsMap.get(key) == null ? null : (String)fieldsMap.get(key);
Object val = fieldsMap.get(key);
return val == null ? null : val.toString();
}
public Integer countAssets(String type) throws BusinessException {
/**
* 优化：一次查询全量数据，内存中分类计数，替代3次独立查询
*/
public Map<String, Integer> countAllStats() throws Exception {
TableContext tableContext = FormTableExecutor.master(getFormNo());
List<FormColumn> formColumns = FormTableExecutor.query(tableContext, null, null, true);
int total = 0;
int rented = 0;
int vacant = 0;
String rentedValue = EnumMapUtils.getEnumItemValueByDisplayValue(tableContext.getTableBean(), "资产状态", "已租");
String vacantValue = EnumMapUtils.getEnumItemValueByDisplayValue(tableContext.getTableBean(), "资产状态", "待租");
for (FormColumn col : formColumns) {
Map<String, Object> fields = col.getFieldsMap();
if (fields == null) continue;
total++;
String status = fields.get("资产状态") == null ? null : fields.get("资产状态") + "";
if (rentedValue != null && rentedValue.equals(status)) {
rented++;
} else if (vacantValue != null && vacantValue.equals(status)) {
vacant++;
}
}
Map<String, Integer> result = new HashMap<>();
result.put("total", total);
result.put("rented", rented);
result.put("vacant", vacant);
return result;
}
public Integer countAssets(String type) throws Exception {
TableContext tableContext = FormTableExecutor.master(getFormNo());
List<FormWhereCondition> conditions = new ArrayList<FormWhereCondition>();
if(type == null || "0".equals(type)) {
@@ -168,10 +479,76 @@ public class AssetsQueryService {
return formColumns.size();
}
public List<AssetsItem> queryAssetsByKeyword(String keyword) throws BusinessException {
/**
* 按筛选条件分页查询资产列表（不走视口），用于地图右侧列表展示
* 返回格式: {records: [...], total: n}
*/
public Map<String, Object> queryAssetList(BoundsQueryVo vo) throws Exception {
TableContext tableContext = FormTableExecutor.master(getFormNo());
List<FormWhereCondition> conditions = new ArrayList<>();
if (StringUtils.isNotBlank(vo.getOwner())) {
conditions.add(FormWhereCondition.build().display("所属单位").value(vo.getOwner()));
}
if (StringUtils.isNotBlank(vo.getLevel1())) {
conditions.add(FormWhereCondition.build().display("资产类型一级").value(vo.getLevel1()));
}
if (StringUtils.isNotBlank(vo.getLevel2())) {
conditions.add(FormWhereCondition.build().display("资产类型二级").value(vo.getLevel2()));
}
if (StringUtils.isNotBlank(vo.getLevel3())) {
conditions.add(FormWhereCondition.build().display("资产分类-").value(vo.getLevel3()));
}
if (StringUtils.isNotBlank(vo.getKeyword())) {
conditions.add(FormWhereCondition.build().display("资产名称").value(vo.getKeyword()).clauseFactor(ClauseFactor.LIKE)
.concatFactor(ClauseFactor.OR));
conditions.add(FormWhereCondition.build().display("资产编号").value(vo.getKeyword()).clauseFactor(ClauseFactor.LIKE));
}
// 先查全量用于权限过滤
List<FormColumn> formColumns = FormTableExecutor.query(tableContext, null, conditions, true);
// 权限过滤（当前单位及下级单位）
boolean showAll = showAll();
if (!showAll) {
List<String> unitIds = getCurrentAndChildUnitIds();
formColumns = formColumns.stream()
.filter(col -> {
Map<String, Object> fields = col.getFieldsMap();
if (fields == null) return false;
String perm = (String) fields.get("查看权限-选单位");
return hasPermission(perm, unitIds);
})
.collect(Collectors.toList());
}
int total = formColumns.size();
// 分页
int pageNum = vo.getPageNum() != null && vo.getPageNum() > 0 ? vo.getPageNum() : 1;
int pageSize = vo.getPageSize() != null && vo.getPageSize() > 0 ? vo.getPageSize() : 10;
int fromIndex = (pageNum - 1) * pageSize;
int toIndex = Math.min(fromIndex + pageSize, total);
List<AssetsItem> records = new ArrayList<>();
if (fromIndex < total) {
List<FormColumn> pageColumns = formColumns.subList(fromIndex, toIndex);
for (FormColumn col : pageColumns) {
Map<String, Object> fieldsMap = col.getFieldsMap();
if (fieldsMap == null) continue;
records.add(buildAssetsItem(fieldsMap));
}
}
Map<String, Object> result = new HashMap<>();
result.put("records", records);
result.put("total", total);
return result;
}
public List<AssetsItem> queryAssetsByKeyword(String keyword) throws Exception {
List<FormWhereCondition> conditions = new ArrayList<FormWhereCondition>();
if(StringUtils.isNotBlank(keyword)){
conditions.add(FormWhereCondition.build().display("位置详情").value(keyword).concatFactor(ClauseFactor.OR).clauseFactor(ClauseFactor.LIKE));
conditions.add(FormWhereCondition.build().display("所在位置").value(keyword).concatFactor(ClauseFactor.OR).clauseFactor(ClauseFactor.LIKE));
}
TableContext tableContext = FormTableExecutor.master(getFormNo());
List<FormColumn> formColumns = FormTableExecutor.pageQuery(tableContext,null, conditions, 1,10,true);