package jnpf.onlinedev.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.util.ObjectUtil; import com.baomidou.dynamic.datasource.annotation.DSTransactional; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.pagehelper.page.PageMethod; import com.google.common.collect.Lists; import jnpf.base.ActionResult; import jnpf.base.DataSourceApi; import jnpf.base.ModuleApi; import jnpf.base.UserInfo; import jnpf.base.entity.ModuleEntity; import jnpf.base.entity.VisualdevEntity; import jnpf.base.entity.VisualdevReleaseEntity; import jnpf.base.mapper.FlowFormDataMapper; import jnpf.base.model.*; import jnpf.base.model.flow.DataModel; import jnpf.base.model.flow.FlowFormDataModel; import jnpf.base.model.form.ModuleFormModel; import jnpf.base.model.module.PropertyJsonModel; import jnpf.base.model.online.VisualdevModelDataInfoVO; import jnpf.base.service.SuperServiceImpl; import jnpf.base.service.VisualdevReleaseService; import jnpf.base.util.FlowFormDataUtil; import jnpf.base.util.FormCheckUtils; import jnpf.base.util.FormPublicUtils; import jnpf.constant.JnpfConst; import jnpf.constant.KeyConst; import jnpf.constant.MsgCode; import jnpf.database.model.entity.DbLinkEntity; import jnpf.database.model.query.SuperJsonModel; import jnpf.database.model.query.SuperQueryJsonModel; import jnpf.database.util.ConnUtil; import jnpf.database.util.DynamicDataSourceUtil; import jnpf.exception.DataException; import jnpf.exception.WorkFlowException; import jnpf.flowable.WorkFlowApi; import jnpf.flowable.entity.TaskEntity; import jnpf.model.OnlineDevData; import jnpf.model.visualjson.*; import jnpf.model.visualjson.analysis.FormAllModel; import jnpf.model.visualjson.analysis.RecursionForm; import jnpf.onlinedev.entity.VisualdevModelDataEntity; import jnpf.onlinedev.mapper.VisualdevModelDataMapper; import jnpf.onlinedev.model.*; import jnpf.onlinedev.model.log.VisualLogForm; import jnpf.onlinedev.model.online.VisualColumnSearchVO; import jnpf.onlinedev.service.VisualDevInfoService; import jnpf.onlinedev.service.VisualDevListService; import jnpf.onlinedev.service.VisualLogService; import jnpf.onlinedev.service.VisualdevModelDataService; import jnpf.onlinedev.util.DisplayOnlyFieldUtils; import jnpf.onlinedev.util.OnlineProductSqlUtils; import jnpf.onlinedev.util.OnlinePublicUtils; import jnpf.onlinedev.util.OnlineSwapDataUtils; import jnpf.permission.UserApi; import jnpf.permission.entity.UserEntity; import jnpf.permission.model.authorize.OnlineDynamicSqlModel; import jnpf.permissions.PermissionInterfaceImpl; import jnpf.util.*; import jnpf.util.context.RequestContext; import jnpf.util.visiual.JnpfKeyConsts; import lombok.Cleanup; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.mybatis.dynamic.sql.*; import org.mybatis.dynamic.sql.delete.DeleteDSL; import org.mybatis.dynamic.sql.delete.DeleteModel; import org.mybatis.dynamic.sql.render.RenderingStrategies; import org.mybatis.dynamic.sql.select.QueryExpressionDSL; import org.mybatis.dynamic.sql.select.SelectModel; import org.mybatis.dynamic.sql.select.join.EqualTo; import org.mybatis.dynamic.sql.select.render.SelectStatementProvider; import org.springframework.stereotype.Service; import java.nio.charset.StandardCharsets; import java.sql.Connection; import java.sql.SQLException; import java.util.*; import java.util.stream.Collectors; /** * @author JNPF开发平台组 * @version V3.1.0 * @copyright 引迈信息技术有限公司（https://www.jnpfsoft.com） * @date 2021/3/16 */ @Slf4j @Service @RequiredArgsConstructor public class VisualdevModelDataServiceImpl extends SuperServiceImpl implements VisualdevModelDataService { private final UserApi userApi; private final DataSourceApi dblinkService; private final VisualdevReleaseService visualdevReleaseService; private final VisualDevListService visualDevListService; private final OnlineSwapDataUtils onlineSwapDataUtils; private final FlowFormDataUtil flowFormDataUtil; private final FormCheckUtils formCheckUtils; private final WorkFlowApi workFlowApi; private final ModuleApi moduleService; private final VisualLogService visualLogService; private final VisualDevInfoService visualDevInfoService; private final FlowFormDataMapper flowFormDataMapper; @Override public List getList(String modelId) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(VisualdevModelDataEntity::getVisualDevId, modelId); return this.list(queryWrapper); } /** * 表单字段 * * @param id * @param filterType 过滤类型，0或者不传为默认过滤子表和关联表单，1-弹窗配置需要过滤掉的类型 * @return */ @Override public List fieldList(String id, Integer filterType) { VisualdevReleaseEntity entity = visualdevReleaseService.getById(id); FormDataModel formData = JsonUtil.getJsonToBean(entity.getFormData(), FormDataModel.class); List fieLdsModelList = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class); List mainFieldModelList = new ArrayList<>(); OnlinePublicUtils.recursionFields(mainFieldModelList, fieLdsModelList); //过滤掉无法传递的组件 List notInList = new ArrayList<>(); notInList.add(JnpfKeyConsts.RELATIONFORM); notInList.add(JnpfKeyConsts.CHILD_TABLE); if (Objects.equals(filterType, 1)) { notInList.add("link"); notInList.add("button"); notInList.add("JNPFText"); notInList.add("alert"); notInList.add(JnpfKeyConsts.POPUPSELECT); notInList.add(JnpfKeyConsts.QR_CODE); notInList.add(JnpfKeyConsts.BARCODE); notInList.add(JnpfKeyConsts.CREATEUSER); notInList.add(JnpfKeyConsts.CREATETIME); notInList.add(JnpfKeyConsts.UPLOADIMG); notInList.add(JnpfKeyConsts.UPLOADFZ); notInList.add(JnpfKeyConsts.MODIFYUSER); notInList.add(JnpfKeyConsts.MODIFYTIME); notInList.add(JnpfKeyConsts.CURRORGANIZE); notInList.add(JnpfKeyConsts.CURRPOSITION); notInList.add(JnpfKeyConsts.IFRAME); notInList.add(JnpfKeyConsts.RELATIONFORM_ATTR); notInList.add(JnpfKeyConsts.POPUPSELECT_ATTR); } return mainFieldModelList.stream() .filter(fieLdsModel -> !"".equals(fieLdsModel.getVModel()) && StringUtil.isNotEmpty(fieLdsModel.getVModel()) && !notInList.contains(fieLdsModel.getConfig().getJnpfKey())) .map(fieLdsModel -> { FormDataField formDataField = new FormDataField(); formDataField.setLabel(fieLdsModel.getConfig().getLabel()); formDataField.setVModel(fieLdsModel.getVModel()); return formDataField; }).collect(Collectors.toList()); } @Override public List> getPageList(VisualdevEntity entity, PaginationModel paginationModel) { VisualDevJsonModel visualJsonModel = OnlinePublicUtils.getVisualJsonModel(entity); //判断请求客户端来源 if (!RequestContext.isOrignPc()) { visualJsonModel.setColumnData(visualJsonModel.getAppColumnData()); } return visualDevListService.getRelationFormList(visualJsonModel, paginationModel); } @Override public List> exportData(String[] keys, PaginationModelExport paginationModelExport, VisualDevJsonModel visualDevJsonModel) { PaginationModel paginationModel = new PaginationModel(); BeanUtil.copyProperties(paginationModelExport, paginationModel); List keyList = Arrays.asList(keys); List> noSwapDataList = new ArrayList<>(); ColumnDataModel columnDataModel = visualDevJsonModel.getColumnData(); List searchVOList; List visualTables = visualDevJsonModel.getVisualTables(); //解析控件 FormDataModel formDataModel = visualDevJsonModel.getFormData(); List fieLdsModels = JsonUtil.getJsonToList(formDataModel.getFields(), FieLdsModel.class); RecursionForm recursionForm = new RecursionForm(fieLdsModels, visualTables); List formAllModel = new ArrayList<>(); FormCloumnUtil.recursionForm(recursionForm, formAllModel); //封装查询条件 if (StringUtil.isNotEmpty(paginationModel.getQueryJson())) { Map keyJsonMap = JsonUtil.stringToMap(paginationModel.getQueryJson()); searchVOList = JsonUtil.getJsonToList(columnDataModel.getSearchList(), VisualColumnSearchVO.class); searchVOList = searchVOList.stream().map(searchVO -> { searchVO.setValue(keyJsonMap.get(searchVO.getId())); return searchVO; }).filter(vo -> vo.getValue() != null && StringUtil.isNotEmpty(String.valueOf(vo.getValue()))).collect(Collectors.toList()); //左侧树查询 boolean b = false; if (columnDataModel.getTreeRelation() != null) { b = keyJsonMap.keySet().stream().anyMatch(t -> t.equalsIgnoreCase(String.valueOf(columnDataModel.getTreeRelation()))); } if (b && keyJsonMap.size() > searchVOList.size()) { String relation = columnDataModel.getTreeRelation(); VisualColumnSearchVO vo = new VisualColumnSearchVO(); vo.setSearchType("1"); vo.setVModel(relation); vo.setValue(keyJsonMap.get(relation)); searchVOList.add(vo); } } setFlowVersion(visualDevJsonModel, paginationModel.getMenuId()); if (!visualDevJsonModel.getVisualTables().isEmpty()) { //当前用户信息 UserInfo userInfo = UserProvider.getUser(); //封装搜索数据 OnlineProductSqlUtils.queryList(formAllModel, visualDevJsonModel, paginationModel); noSwapDataList = visualDevListService.getListWithTable(visualDevJsonModel, paginationModel, userInfo, keyList); //数据转换 List fields = new ArrayList<>(); OnlinePublicUtils.recursionFields(fields, fieLdsModels); noSwapDataList = onlineSwapDataUtils.getSwapList(noSwapDataList, fields, visualDevJsonModel.getId(), false); } return noSwapDataList; } private void setFlowVersion(VisualDevJsonModel visualDevJsonModel, String menuId) { String flowTemplateId = null; boolean canResolveFlowByForm = true; if (StringUtil.isNotEmpty(menuId)) { ModuleEntity info = moduleService.getModuleByList(menuId); if (info != null) { if (Objects.equals(info.getType(), 9)) { PropertyJsonModel model = JsonUtil.getJsonToBean(info.getPropertyJson(), PropertyJsonModel.class); flowTemplateId = model.getModuleId(); } else { canResolveFlowByForm = Objects.equals(info.getType(), 1); } } } if (StringUtil.isEmpty(flowTemplateId) && canResolveFlowByForm) { flowTemplateId = getFlowTemplateIdByFormId(visualDevJsonModel.getId()); } if (StringUtil.isNotEmpty(flowTemplateId)) { visualDevJsonModel.setEnableFlow(true); visualDevJsonModel.setFlowId(flowTemplateId); visualDevJsonModel.setFlowVersionIds(workFlowApi.getFlowIdsByTemplateId(flowTemplateId)); } } private String getFlowTemplateIdByFormId(String formId) { if (StringUtil.isEmpty(formId)) { return null; } Map flowFormMap = workFlowApi.getFlowFormMap(); if (flowFormMap == null || flowFormMap.isEmpty()) { return null; } return flowFormMap.entrySet().stream() .filter(item -> Objects.equals(formId, item.getValue())) .map(Map.Entry::getKey) .findFirst() .orElse(null); } @Override public VisualdevModelDataEntity getInfo(String id) { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.lambda().eq(VisualdevModelDataEntity::getId, id); return this.getOne(queryWrapper); } @Override public DataModel visualCreate(VisualParamModel visualParamModel) throws WorkFlowException { VisualdevEntity visualdevEntity = visualParamModel.getVisualdevEntity(); Map map = visualParamModel.getData(); boolean isLink = visualParamModel.getIsLink(); boolean isUpload = visualParamModel.getIsUpload(); FormDataModel formData = JsonUtil.getJsonToBean(visualdevEntity.getFormData(), FormDataModel.class); ColumnDataModel columnDataModel = JsonUtil.getJsonToBean(visualdevEntity.getColumnData(), ColumnDataModel.class); boolean needP = false; List formPerList = new ArrayList<>(); if (columnDataModel != null && StringUtil.isNotEmpty(visualParamModel.getMenuId())) { needP = columnDataModel.getUseFormPermission(); Map pMap = PermissionInterfaceImpl.getFormMap(); if (pMap.get(visualParamModel.getMenuId()) != null) { formPerList = JsonUtil.getJsonToList(pMap.get(visualParamModel.getMenuId()), ModuleFormModel.class).stream() .map(ModuleFormModel::getEnCode).collect(Collectors.toList()); } } List list = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class); DisplayOnlyFieldUtils.filter(formData.getFields(), list, map); List tableModels = JsonUtil.getJsonToList(visualdevEntity.getVisualTables(), TableModel.class); DbLinkEntity linkEntity = StringUtil.isNotEmpty(visualdevEntity.getDbLinkId()) ? dblinkService.getInfo(visualdevEntity.getDbLinkId()) : null; //递归遍历模板 RecursionForm recursionForm = new RecursionForm(list, tableModels); List formAllModel = new ArrayList<>(); FormCloumnUtil.recursionForm(recursionForm, formAllModel); //是否开启并发锁 boolean concurrency = false; Integer primaryKeyPolicy = formData.getPrimaryKeyPolicy(); if (Boolean.TRUE.equals(formData.getConcurrencyLock())) { //初始化version值 map.put(TableFeildsEnum.VERSION.getField(), 0); concurrency = true; } OnlineSwapDataUtils.swapDatetime(list, map); //单行唯一校验 if (!isUpload) { CheckFormModel checkFormModel = CheckFormModel.builder().formFieldList(list).dataMap(map).linkEntity(linkEntity).tableModelList(tableModels) .visualdevEntity(visualdevEntity).id(null).isLink(isLink).build(); String b = formCheckUtils.checkForm(checkFormModel); if (StringUtil.isNotEmpty(b)) { throw new WorkFlowException(b); } } String mainId = RandomUtil.uuId(); UserInfo userInfo = UserProvider.getUser(); UserEntity info = userApi.getInfoById(userInfo.getUserId()); DataModel dataModel = DataModel.builder().visualId(visualdevEntity.getId()) .dataNewMap(map).fieLdsModelList(list).tableModelList(tableModels).formAllModel(formAllModel) .mainId(mainId).link(linkEntity).userEntity(info).concurrencyLock(concurrency) .primaryKeyPolicy(primaryKeyPolicy).linkOpen(isLink) .needPermission(needP).formPerList(formPerList) .build(); flowFormDataUtil.create(dataModel); //数据日志 if (!isUpload && !isLink) { visualLogService.createEventLog(VisualLogForm.builder().modelId(visualdevEntity.getId()) .dataId(dataModel.getMainId()).newData(map).type(0) .bizSign(auditBizSign(map)) .auditDisplayFields(visualParamModel.getAuditDisplayFields()) .auditOnly(!formData.isDataLog()).build()); } return dataModel; } @Override public DataModel visualUpdate(VisualParamModel visualParamModel) throws WorkFlowException { VisualdevEntity visualdevEntity = visualParamModel.getVisualdevEntity(); Map map = visualParamModel.getData(); String id = visualParamModel.getId(); boolean isUpload = visualParamModel.getIsUpload(); boolean onlyUpdate = visualParamModel.getOnlyUpdate(); ColumnDataModel columnDataModel = JsonUtil.getJsonToBean(visualdevEntity.getColumnData(), ColumnDataModel.class); FormDataModel formData = JsonUtil.getJsonToBean(visualdevEntity.getFormData(), FormDataModel.class); boolean needP = false; List formPerList = new ArrayList<>(); if (columnDataModel != null && StringUtil.isNotEmpty(visualParamModel.getMenuId())) { needP = columnDataModel.getUseFormPermission(); Map pMap = PermissionInterfaceImpl.getFormMap(); if (pMap.get(visualParamModel.getMenuId()) != null) { formPerList = JsonUtil.getJsonToList(pMap.get(visualParamModel.getMenuId()), ModuleFormModel.class).stream() .map(ModuleFormModel::getEnCode).collect(Collectors.toList()); } } List list = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class); boolean inlineEdit = columnDataModel.getType() != null && columnDataModel.getType() == 4; if (inlineEdit && RequestContext.isOrignPc()) { list = JsonUtil.getJsonToList(columnDataModel.getColumnList(), FieLdsModel.class); list = list.stream().filter(f -> !f.getId().toLowerCase().contains(JnpfKeyConsts.CHILD_TABLE_PREFIX)).collect(Collectors.toList()); } DisplayOnlyFieldUtils.filter(formData.getFields(), list, map); List tableModels = JsonUtil.getJsonToList(visualdevEntity.getVisualTables(), TableModel.class); TableModel mainT = tableModels.stream().filter(t -> t.getTypeId().equals("1")).findFirst().orElse(null); DbLinkEntity linkEntity = StringUtil.isNotEmpty(visualdevEntity.getDbLinkId()) ? dblinkService.getInfo(visualdevEntity.getDbLinkId()) : null; //递归遍历模板 RecursionForm recursionForm = new RecursionForm(list, tableModels); List formAllModel = new ArrayList<>(); FormCloumnUtil.recursionForm(recursionForm, formAllModel); Integer primaryKeyPolicy = formData.getPrimaryKeyPolicy(); //是否开启并发锁 boolean isConcurrencyLock = isConcurrencyLock(formData, map, id, primaryKeyPolicy, mainT, linkEntity); OnlineSwapDataUtils.swapDatetime(list, map); //单行唯一校验 if (!isUpload) { CheckFormModel checkFormModel = CheckFormModel.builder().formFieldList(list).dataMap(map).linkEntity(linkEntity).tableModelList(tableModels) .visualdevEntity(visualdevEntity).id(id).build(); String b = formCheckUtils.checkForm(checkFormModel); if (StringUtil.isNotEmpty(b)) { throw new WorkFlowException(b); } } //数据日志 VisualdevModelDataInfoVO resOld = visualDevInfoService.getDetailsDataInfo(id, visualdevEntity, OnlineInfoModel.builder().needRlationFiled(true).needSwap(false).formAllModel(formAllModel).build()); Map oldData = JsonUtil.stringToMap(resOld.getData()); UserInfo userInfo = UserProvider.getUser(); UserEntity info = userApi.getInfoById(userInfo.getUserId()); DataModel dataModel = DataModel.builder().visualId(visualdevEntity.getId()) .dataNewMap(map).fieLdsModelList(list).tableModelList(tableModels).formAllModel(formAllModel) .mainId(id).link(linkEntity).userEntity(info).concurrencyLock(isConcurrencyLock) .primaryKeyPolicy(primaryKeyPolicy).onlyUpdate(onlyUpdate).logicalDelete(formData.getLogicalDelete()) .needPermission(needP).formPerList(formPerList) .build(); flowFormDataUtil.update(dataModel); VisualdevModelDataInfoVO res = visualDevInfoService.getDetailsDataInfo(id, visualdevEntity, OnlineInfoModel.builder().needRlationFiled(true).needSwap(false).formAllModel(formAllModel).build()); Map newData = JsonUtil.stringToMap(res.getData()); VisualLogForm form = VisualLogForm.builder().modelId(visualdevEntity.getId()).dataId(id).oldData(oldData).newData(newData).type(1) .bizSign(auditBizSign(newData)).auditDisplayFields(visualParamModel.getAuditDisplayFields()).build(); //处理变更字段信息-任务流程用 List listLog = new ArrayList<>(); visualLogService.addLog(form, listLog); dataModel.setListLog(listLog); //数据日志 if (!isUpload) { form.setListLog(listLog); form.setAuditOnly(!formData.isDataLog()); visualLogService.createEventLog(form); } return dataModel; } private boolean isConcurrencyLock(FormDataModel formData, Map map, String id, Integer primaryKeyPolicy, TableModel mainT, DbLinkEntity linkEntity) throws WorkFlowException { boolean isConcurrencyLock = false; if (Boolean.TRUE.equals(formData.getConcurrencyLock())) { if (map.get(TableFeildsEnum.VERSION.getField()) == null) { map.put(TableFeildsEnum.VERSION.getField(), 0); } else { boolean version = true; try { Object realId = id; if (Objects.equals(primaryKeyPolicy, 2)) { realId = Long.parseLong(id); } version = flowFormDataUtil.getVersion(mainT.getTable(), linkEntity, map, realId); } catch (Exception e) { throw new WorkFlowException(e.getMessage(), e); } if (!version) { throw new WorkFlowException(MsgCode.VS405.get()); } else { Integer vs = Integer.valueOf(String.valueOf(map.get(TableFeildsEnum.VERSION.getField()))); map.put(TableFeildsEnum.VERSION.getField(), vs + 1); } } isConcurrencyLock = true; } return isConcurrencyLock; } @Override public void visualDelete(VisualdevEntity visualdevEntity, List> data) throws WorkFlowException { VisualDevJsonModel visualJsonModel = OnlinePublicUtils.getVisualJsonModel(visualdevEntity); //判断请求客户端来源 if (!RequestContext.isOrignPc()) { visualJsonModel.setColumnData(visualJsonModel.getAppColumnData()); } List idsList = new ArrayList<>(); StringJoiner errMess = new StringJoiner(","); for (Map map : data) { String id = String.valueOf(map.get(FlowFormConstant.ID)); TaskEntity taskEntity = workFlowApi.getInfoSubmit(String.valueOf(map.get(FlowFormConstant.FLOWTASKID))); if (taskEntity != null) { try { workFlowApi.delete(taskEntity); idsList.add(id); } catch (Exception e) { errMess.add(e.getMessage()); } } else { idsList.add(id); } } if (idsList.isEmpty()) { throw new WorkFlowException(errMess.toString()); } if (!StringUtil.isEmpty(visualdevEntity.getVisualTables()) && !OnlineDevData.TABLE_CONST.equals(visualdevEntity.getVisualTables())) { for (String id : idsList) { try { tableDelete(id, visualJsonModel); } catch (Exception e) { throw new WorkFlowException(e.getMessage(), e); } } } } @DSTransactional(rollbackFor = Exception.class) @Override public void delete(VisualdevModelDataEntity entity) { if (entity != null) { this.removeById(entity.getId()); } } @Override public FormDeleteResult tableDelete(String id, VisualDevJsonModel visualDevJsonModel) throws SQLException { DbLinkEntity linkEntity = dblinkService.getInfo(visualDevJsonModel.getDbLinkId()); VisualDevJsonModel model = BeanUtil.copyProperties(visualDevJsonModel, VisualDevJsonModel.class); return flowFormDataUtil.deleteTable(id, model, linkEntity); } @Override public ActionResult tableDeleteMore(List ids, VisualDevJsonModel visualDevJsonModel) throws SQLException { List dataInfoVOList = new ArrayList<>(); for (String id : ids) { // AUDIT 补丁（2026-08-05，#7）：改前 tableDelete 恒返回 true，不存在的 id 也会进列表。 // 已实查全仓无人读 getDataIdList，收紧判据无下游影响。 FormDeleteResult delResult = tableDelete(id, visualDevJsonModel); if (delResult != null && delResult.isDeleted()) { dataInfoVOList.add(id); } } visualDevJsonModel.setDataIdList(dataInfoVOList); return ActionResult.success(MsgCode.SU003.get()); } @Override @DSTransactional public void deleteByTableName(FlowFormDataModel model) throws WorkFlowException, SQLException { String tableName = model.getTableName(); List> ruleList = model.getRuleList(); String realTableName = tableName; VisualdevReleaseEntity entity = visualdevReleaseService.getById(model.getFormId()); List tableModels = JsonUtil.getJsonToList(entity.getVisualTables(), TableModel.class); FormDataModel formData = JsonUtil.getJsonToBean(entity.getFormData(), FormDataModel.class); DbLinkEntity linkEntity = StringUtil.isNotEmpty(entity.getDbLinkId()) ? dblinkService.getInfo(entity.getDbLinkId()) : null; List fieLdsModels = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class); List fields = new ArrayList<>(); OnlinePublicUtils.recursionFields(fields, fieLdsModels); if (StringUtil.isNotEmpty(tableName) && tableName.toLowerCase().contains(JnpfKeyConsts.CHILD_TABLE_PREFIX)) { FieLdsModel fieLdsModel = fields.stream().filter(t -> t.getVModel().equalsIgnoreCase(tableName)).findFirst().orElse(null); if (fieLdsModel != null) { realTableName = fieLdsModel.getConfig().getTableName(); } } String finalRealTableName = realTableName; TableModel tableModel = tableModels.stream().filter(t -> t.getTable().equals(finalRealTableName)).findFirst().orElse(null); if(tableModel == null){ throw new DataException("表不存在"); } List sqlModelList = new ArrayList<>(); OnlineDynamicSqlModel sqlModel = new OnlineDynamicSqlModel(); SqlTable sqlTable = SqlTable.of(tableModel.getTable()); sqlModel.setSqlTable(sqlTable); sqlModel.setTableName(tableModel.getTable()); sqlModelList.add(sqlModel); SuperJsonModel ruleJsonModel = null; //组装查询条件 if (ObjectUtil.isNotEmpty(ruleList)) { ruleJsonModel = new SuperJsonModel(); ruleJsonModel.setMatchLogic(model.getRuleMatchLogic()); List superQueryJsonModelList = new ArrayList<>(); for (Object obj : ruleList) { SuperQueryJsonModel ruleQueryModel = JsonUtil.getJsonToBean(obj, SuperQueryJsonModel.class); List groups = ruleQueryModel.getGroups(); if (ObjectUtil.isNotEmpty(groups)) { groups.stream().forEach(group -> { if (group.getId().toLowerCase().contains(JnpfKeyConsts.CHILD_TABLE_PREFIX)) { group.setVModel(group.getId().split("-")[1]); } }); } superQueryJsonModelList.add(ruleQueryModel); } ruleJsonModel.setConditionList(superQueryJsonModelList); } DynamicDataSourceUtil.switchToDataSource(linkEntity); try { @Cleanup Connection conn = ConnUtil.getConnOrDefault(linkEntity); String dbType = conn.getMetaData().getDatabaseProductName().trim(); String pkeyId = flowFormDataUtil.getKey(tableModel, dbType); List idStringList = new ArrayList<>(); if (ObjectUtil.isNotEmpty(ruleJsonModel)) { QueryExpressionDSL.QueryExpressionWhereBuilder where = SqlBuilder.selectDistinct(sqlTable.column(pkeyId)).from(sqlTable).where(); OnlineProductSqlUtils.getSuperSql(where, ruleJsonModel, sqlModelList, dbType, null, false); List> dataList = flowFormDataMapper.selectManyMappedRows(where.build().render(RenderingStrategies.MYBATIS3)); idStringList = dataList.stream().map(m -> m.get(pkeyId)).distinct().collect(Collectors.toList()); if (ObjectUtil.isEmpty(idStringList)) { idStringList.add("nodata"); } } DeleteDSL.DeleteWhereBuilder whereD = SqlBuilder.deleteFrom(SqlTable.of(tableModel.getTable())).where(); if (ObjectUtil.isNotEmpty(idStringList)) { whereD.and(sqlTable.column(pkeyId), SqlBuilder.isIn(idStringList)); } flowFormDataMapper.delete(whereD.build().render(RenderingStrategies.MYBATIS3)); } catch (Exception e) { e.printStackTrace(); throw new WorkFlowException(MsgCode.FA103.get(), e.getMessage()); } finally { DynamicDataSourceUtil.clearSwitchDataSource(); } } @Override public List> relationQuery(VisualdevEntity entity, RelationQuery query) { VisualDevJsonModel visualDevJsonModel = OnlinePublicUtils.getVisualJsonModel(entity); FormDataModel formData = visualDevJsonModel.getFormData(); boolean logicalDelete = visualDevJsonModel.getFormData().getLogicalDelete(); List collect = StringUtil.isNotEmpty(query.getColumnOptions()) ? Arrays.asList(query.getColumnOptions().split(",")) : new ArrayList<>(); List fieLdsModels = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class); List allFields = new ArrayList<>(); List tableModelList = JsonUtil.getJsonToList(visualDevJsonModel.getVisualTables(), TableModel.class); OnlinePublicUtils.recursionFields(allFields, fieLdsModels); List> resList = new ArrayList<>(); List> dataList; //判断有无表 if (!visualDevJsonModel.getVisualTables().isEmpty()) { try { //主表 TableModel mainTable = tableModelList.stream().filter(t -> t.getTypeId().equals("1")).findFirst().orElse(null); DbLinkEntity linkEntity = dblinkService.getInfo(visualDevJsonModel.getDbLinkId()); List sqlModelList = new ArrayList<>(); //根据表字段创建sqltable for (TableModel model : tableModelList) { OnlineDynamicSqlModel sqlModel = new OnlineDynamicSqlModel(); sqlModel.setSqlTable(SqlTable.of(model.getTable())); sqlModel.setTableName(model.getTable()); if (model.getTypeId().equals("1")) { sqlModel.setMain(true); } else { sqlModel.setForeign(model.getTableField()); sqlModel.setRelationKey(model.getRelationField()); sqlModel.setMain(false); } sqlModelList.add(sqlModel); } //判断是否分页 boolean isPage = query.getPageSize() != null && query.getPageSize() < 1000; //获取表单主表副表全字段 List allFieldsKey = new ArrayList<>(); for (FieLdsModel item : allFields) { if (StringUtil.isNotEmpty(item.getVModel()) && collect.contains(item.getVModel())) { allFieldsKey.add(item.getVModel()); } } OnlineProductSqlUtils.getColumnListSql(sqlModelList, visualDevJsonModel, allFieldsKey, linkEntity); //高级查询 RecursionForm recursionForm = new RecursionForm(fieLdsModels, tableModelList); List formAllModel = new ArrayList<>(); FormCloumnUtil.recursionForm(recursionForm, formAllModel); PaginationModel paginationModel = JsonUtil.getJsonToBean(query, PaginationModel.class); OnlineProductSqlUtils.queryList(formAllModel, visualDevJsonModel, paginationModel); SuperJsonModel superQuery = visualDevJsonModel.getSuperQuery(); ColumnDataModel listColumnDataModel = visualDevJsonModel.getColumnData(); List listquery = Arrays.asList(superQuery); DynamicDataSourceUtil.switchToDataSource(linkEntity); @Cleanup Connection connection = ConnUtil.getConnOrDefault(linkEntity); String databaseProductName = connection.getMetaData().getDatabaseProductName().trim(); String pkeyId = flowFormDataUtil.getKey(mainTable, databaseProductName); visualDevJsonModel.setPkeyId(pkeyId); List jsonToList = JsonUtil.getJsonToList(formData.getFields(), FieLdsModel.class); //递归处理控件 List allFieLds = new ArrayList<>(); OnlinePublicUtils.recursionFields(allFieLds, jsonToList); Map tableFieldAndTableName = new HashMap<>(8); Map tableNameAndTableField = new HashMap<>(8); allFields.stream().filter(f -> f.getConfig().getJnpfKey().equals(JnpfKeyConsts.CHILD_TABLE)).forEach(f -> { tableFieldAndTableName.put(f.getVModel(), f.getConfig().getTableName()); tableNameAndTableField.put(f.getConfig().getTableName(), f.getVModel()); }); //取出所有有用到的表-进行关联过滤 List allTableName = OnlinePublicUtils.getAllTableName(new ArrayList<>(), listquery, tableFieldAndTableName); for (String str : collect) { if (str.toLowerCase().startsWith(JnpfConst.SIDE_MARK_PRE)) { allTableName.add(str.split(JnpfConst.SIDE_MARK)[0].substring(5)); } else if (str.toLowerCase().startsWith(JnpfKeyConsts.CHILD_TABLE_PREFIX)) { allTableName.add(tableFieldAndTableName.get(str.split("-")[0])); } } //主表 OnlineDynamicSqlModel mainSqlModel = sqlModelList.stream().filter(OnlineDynamicSqlModel::isMain).findFirst().orElse(null); //非主表 List dycList = sqlModelList.stream().filter(dyc -> !dyc.isMain()).collect(Collectors.toList()); List sqlColumns = new ArrayList<>(); Map aliasMap = new HashMap<>(); boolean isOracle = databaseProductName.equalsIgnoreCase("oracle"); boolean isDm = databaseProductName.equalsIgnoreCase("DM DBMS"); boolean isPostgreSql = databaseProductName.equalsIgnoreCase("PostgreSQL"); boolean isUp = databaseProductName.equalsIgnoreCase("oracle") || databaseProductName.equalsIgnoreCase("DM DBMS"); String flowStateKey = isUp ? TableFeildsEnum.FLOWSTATE.getField().toUpperCase() : TableFeildsEnum.FLOWSTATE.getField(); String flowIdKey = isUp ? TableFeildsEnum.FLOWID.getField().toUpperCase() : TableFeildsEnum.FLOWID.getField(); String deleteMarkKey = isUp ? TableFeildsEnum.DELETEMARK.getField().toUpperCase() : TableFeildsEnum.DELETEMARK.getField(); for (OnlineDynamicSqlModel dynamicSqlModel : sqlModelList) { List basicColumns = Optional.ofNullable(dynamicSqlModel.getColumns()).orElse(new ArrayList<>()); // Oracle/DM aliases are always normalized. PostgreSQL only needs aliases over 63 bytes normalized. if (isOracle || isDm || isPostgreSql) { for (int i = 0; i < basicColumns.size(); i++) { BasicColumn item = basicColumns.get(i); String alias = item.alias().orElse(null); boolean needsShortAlias = isOracle || isDm || (isPostgreSql && StringUtil.isNotEmpty(alias) && alias.getBytes(StandardCharsets.UTF_8).length > 63); if (needsShortAlias) { String aliasNewName = isPostgreSql ? "jnpf_a_" + RandomUtil.uuId() : "A" + RandomUtil.uuId(); aliasMap.put(aliasNewName, alias); basicColumns.set(i, item.as(aliasNewName)); } } } sqlColumns.addAll(basicColumns); } if (visualDevJsonModel.isEnableFlow()) { sqlColumns.add(mainSqlModel.getSqlTable().column(flowStateKey).as(FlowFormConstant.FLOW_STATE)); } QueryExpressionDSL from = SqlBuilder.select(sqlColumns).from(mainSqlModel.getSqlTable()); QueryExpressionDSL subFrom = SqlBuilder.select(mainSqlModel.getSqlTable().column(pkeyId)).from(mainSqlModel.getSqlTable()); // 构造table和table下字段的分组 Map> tableFieldGroup = new HashMap<>(8); allFieLds.forEach(f -> tableFieldGroup.computeIfAbsent(f.getConfig().getTableName(), k -> new ArrayList<>()).add( "table".equals(f.getConfig().getType()) ? f.getConfig().getTableName() : f.getVModel())); Map subSqlTableMap = new HashMap<>(); if (!dycList.isEmpty()) { for (OnlineDynamicSqlModel sqlModel : dycList) { if (!allTableName.contains(sqlModel.getTableName())) continue; String relationKey = sqlModel.getRelationKey(); boolean relationKeyTypeString = false; for (TableModel item : tableModelList) { if (item.getTable().equals(sqlModel.getTableName())) { String foreign = sqlModel.getForeign(); TableFields thisfield = item.getFields().stream().filter(t -> t.getField().equals(foreign)).findFirst().orElse(null); if (thisfield != null) { relationKeyTypeString = thisfield.getDataType().toLowerCase().contains(KeyConst.VARCHAR); } } } //postgresql自增 int和varchar无法对比-添加以下判断 if (Objects.equals(formData.getPrimaryKeyPolicy(), 2) && "PostgreSQL".equalsIgnoreCase(databaseProductName) && relationKeyTypeString) { relationKey += "::varchar"; } //移除子表的外联--用于查询主副表字段数据 if (!tableNameAndTableField.containsKey(sqlModel.getTableName())) { from.leftJoin(sqlModel.getSqlTable()) .on(sqlModel.getSqlTable().column(sqlModel.getForeign()), new EqualTo(mainSqlModel.getSqlTable().column(relationKey))); } //用于查询拼接各条件之后的主表id列表（和统计数量） subFrom.leftJoin(sqlModel.getSqlTable()) .on(sqlModel.getSqlTable().column(sqlModel.getForeign()), new EqualTo(mainSqlModel.getSqlTable().column(relationKey))); String tableName = sqlModel.getTableName(); List fieldList = tableFieldGroup.get(tableName); if (fieldList != null) { fieldList.forEach(fieldKey -> subSqlTableMap.put(fieldKey, sqlModel.getSqlTable())); } } } QueryExpressionDSL.QueryExpressionWhereBuilder where = from.where(); QueryExpressionDSL.QueryExpressionWhereBuilder subWhere = subFrom.where(); //逻辑删除不展示 if (logicalDelete) { subWhere.and(mainSqlModel.getSqlTable().column(deleteMarkKey), SqlBuilder.isNull()); } //非流程数据 if (listColumnDataModel == null || !Boolean.TRUE.equals(listColumnDataModel.getFlowForm())) { subWhere.and(mainSqlModel.getSqlTable().column(flowIdKey), SqlBuilder.isNull()); } //高级查询 OnlineProductSqlUtils.getSuperSql(subWhere, superQuery, sqlModelList, databaseProductName, null, false); //统计语句 BasicColumn countColumn; if (!dycList.isEmpty()) { countColumn = SqlBuilder.countDistinct(mainSqlModel.getSqlTable().column(pkeyId)); } else { countColumn = SqlBuilder.count(mainSqlModel.getSqlTable().column(pkeyId)); } QueryExpressionDSL.QueryExpressionWhereBuilder countSelect = SqlBuilder .select(countColumn) .from(subWhere, "tmp") .where(); SelectStatementProvider renderCount = countSelect.build().render(RenderingStrategies.MYBATIS3); long count = flowFormDataMapper.count(renderCount); if (count == 0) { paginationModel.setTotal(0); return new ArrayList<>(); } //排序 -- 是流程先按状态排序 List sidxList = new ArrayList<>(); if (StringUtil.isNotEmpty(paginationModel.getSidx())) { String[] split = paginationModel.getSidx().split(","); for (String sidx : split) { //目前只支持主表排序 if (sidx.toLowerCase().contains(JnpfConst.SIDE_MARK) || sidx.toLowerCase().contains(JnpfKeyConsts.CHILD_TABLE_PREFIX)) { continue; } SortSpecification sortSpecification; if (sidx.startsWith("-")) { sortSpecification = SqlBuilder.sortColumn(mainTable.getTable(), SqlTable.of(mainTable.getTable()).column(sidx.substring(1))).descending(); } else { sortSpecification = SqlBuilder.sortColumn(mainTable.getTable(), SqlTable.of(mainTable.getTable()).column(sidx)); } sidxList.add(sortSpecification); } } else { sidxList.add(SqlBuilder.sortColumn(mainTable.getTable(), SqlTable.of(mainTable.getTable()).column(pkeyId)).descending()); } where.orderBy(sidxList); if (isPage) { PageMethod.startPage((int) paginationModel.getCurrentPage(), (int) paginationModel.getPageSize(), false); } //查询主副表数据 where.and(SqlTable.of(mainTable.getTable()).column(pkeyId), SqlBuilder.isIn(subWhere)); SelectStatementProvider render = where.build().render(RenderingStrategies.MYBATIS3); dataList = flowFormDataMapper.selectManyMappedRows(render); String finalPkeyId = pkeyId; List idStringList = dataList.stream().map(m -> m.get(finalPkeyId)).distinct().collect(Collectors.toList()); if (!idStringList.isEmpty()) { //处理子表 List tableFields = collect.stream().filter(c -> c.toLowerCase().contains(JnpfKeyConsts.CHILD_TABLE_PREFIX)).collect(Collectors.toList()); List childTableModels = tableModelList.stream().filter(t -> t.getTypeId().equals("0")).collect(Collectors.toList()); Map> tableMap = tableFields.stream().collect(Collectors.groupingBy(t -> t.substring(0, t.lastIndexOf("-")))); for (TableModel tableModel : childTableModels) { String table = tableModel.getTable(); if (!allTableName.contains(table)) continue; String tableField = tableNameAndTableField.get(table); String childPrimKey = flowFormDataUtil.getKey(tableModel, databaseProductName); String fogID = tableModel.getTableField(); String mainPrimKey = tableModel.getRelationField(); //外键值集合（通过主表关联键查询） List fogValueList = dataList.stream().map(m -> m.get(mainPrimKey)).distinct().collect(Collectors.toList()); //外键是字符串 - 转换主表数据string TableFields fogIdField = tableModel.getFields().stream().filter(t -> t.getField().equals(fogID)).findFirst().orElse(null); boolean fogIdTypeString = Objects.nonNull(fogIdField) && fogIdField.getDataType().toLowerCase().contains(KeyConst.VARCHAR); if (fogIdTypeString) { idStringList = idStringList.stream().map(Object::toString).collect(Collectors.toList()); } List childFields = tableMap.get(tableField); if (childFields != null) { OnlineDynamicSqlModel onlineDynamicSqlModel = sqlModelList.stream().filter(s -> s.getTableName().equalsIgnoreCase(table)).findFirst().orElse(null); if(onlineDynamicSqlModel == null){ throw new DataException("表不存在"); } SqlTable childSqlTable = onlineDynamicSqlModel.getSqlTable(); List childSqlColumns = new ArrayList<>(); for (String c : childFields) { String childF = c.substring(c.lastIndexOf("-") + 1); SqlColumn column = childSqlTable.column(childF); childSqlColumns.add(column); } childSqlColumns.add(childSqlTable.column(childPrimKey)); childSqlColumns.add(childSqlTable.column(fogID)); //查子表数据字段，不去重 QueryExpressionDSL childFrom = SqlBuilder.select(childSqlColumns).from(mainSqlModel.getSqlTable()); if (!dycList.isEmpty()) { for (OnlineDynamicSqlModel sqlModel : dycList) { String relationKey = sqlModel.getRelationKey(); boolean relationKeyTypeString = false; for (TableModel item : tableModelList) { if (item.getTable().equals(sqlModel.getTableName())) { String foreign = sqlModel.getForeign(); TableFields thisfield = item.getFields().stream().filter(t -> t.getField().equals(foreign)).findFirst().orElse(null); if (thisfield != null) { relationKeyTypeString = thisfield.getDataType().toLowerCase().contains(KeyConst.VARCHAR); } } } //postgresql自增 int和varchar无法对比-添加以下判断 if (Objects.equals(formData.getPrimaryKeyPolicy(), 2) && "PostgreSQL".equalsIgnoreCase(databaseProductName) && relationKeyTypeString) { relationKey += "::varchar"; } //用于查询拼接各条件之后的主表id列表（和统计数量） childFrom.leftJoin(sqlModel.getSqlTable()) .on(sqlModel.getSqlTable().column(sqlModel.getForeign()), new EqualTo(mainSqlModel.getSqlTable().column(relationKey))); } } QueryExpressionDSL.QueryExpressionWhereBuilder childWhere = childFrom.where(); if (fogValueList.size() > 1000) { List> lists = Lists.partition(fogValueList, 1000); List groupListAll = new ArrayList<>(); for (List item : lists) { groupListAll.add(SqlBuilder.or(childSqlTable.column(fogID), SqlBuilder.isIn(item))); } groupListAll.remove(0); childWhere.and(childSqlTable.column(fogID), SqlBuilder.isIn(lists.get(0)), groupListAll); } else { childWhere.and(childSqlTable.column(fogID), SqlBuilder.isIn(fogValueList)); } //逻辑删除不展示 if (logicalDelete) { childWhere.and(childSqlTable.column(deleteMarkKey), SqlBuilder.isNull()); } //高级查询 OnlineProductSqlUtils.getSuperSql(childWhere, superQuery, sqlModelList, databaseProductName, null, false); SelectStatementProvider childRender = childWhere.build().render(RenderingStrategies.MYBATIS3); List> mapList = flowFormDataMapper.selectManyMappedRows(childRender); //连表去重，distinct去不掉 List dictinctKey = new ArrayList<>(); List> newList = new ArrayList<>(); for (Map item : mapList) { Object o = item.get(childPrimKey); if (!dictinctKey.contains(o)) { newList.add(item); dictinctKey.add(o); } item.put(FlowFormConstant.ID, o); } Map>> idMap = newList.stream().collect(Collectors.groupingBy(m -> m.get(fogID).toString())); for (Map m : dataList) { if (ObjectUtil.isNotEmpty(m.get(mainPrimKey))) { String s = m.get(mainPrimKey).toString(); Map valueMap = new HashMap<>(); valueMap.put(tableField, idMap.get(s)); m.putAll(valueMap); } } } } } else { return new ArrayList<>(); } //添加id属性 dataList = FormPublicUtils.addIdToList(dataList, pkeyId); //别名key还原 VisualDevListServiceImpl.setAliasKey(dataList, aliasMap); query.setTotal(count); resList = dataList; } catch (Exception e) { e.printStackTrace(); } finally { DynamicDataSourceUtil.clearSwitchDataSource(); } } if (resList.isEmpty()) { return new ArrayList<>(); } resList = onlineSwapDataUtils.getSwapList(resList, allFields, visualDevJsonModel.getId(), false); return resList; } /** 在线表单标准提交中的签名凭证，供审计跨请求关联；凭证真实性仍由审计消费端校验。 */ private static String auditBizSign(Map data) { Object value = data == null ? null : data.get("biz_sign"); if (value == null) { return null; } String sign = String.valueOf(value).trim(); return sign.isEmpty() ? null : sign; } }