package com.artfess.bo.instance.impl; import com.artfess.base.constants.DataSourceConsts; import com.artfess.base.datasource.DatabaseContext; import com.artfess.base.datasource.DatabaseSwitchResult; import com.artfess.base.enums.ResponseErrorEnums; import com.artfess.base.exception.BaseException; import com.artfess.base.feign.SystemConfigFeignService; import com.artfess.base.feign.WorkflowFeignService; import com.artfess.base.feign.dto.PortalDataSensitive; import com.artfess.base.manager.CommonManager; import com.artfess.base.model.CommonResult; import com.artfess.base.query.PageList; import com.artfess.base.query.QueryFilter; import com.artfess.base.util.AppUtil; import com.artfess.base.util.AuthenticationUtil; import com.artfess.base.util.BeanUtils; import com.artfess.base.util.JsonUtil; import com.artfess.base.util.StringUtil; import com.artfess.base.util.ThreadMsgUtil; import com.artfess.base.util.UniqueIdUtil; import com.artfess.base.util.time.DateFormatUtil; import com.artfess.base.util.time.DateUtil; import com.artfess.base.util.time.TimeUtil; import com.artfess.bo.constant.BoConstants; import com.artfess.bo.context.FormContextThreadUtil; import com.artfess.bo.exception.BoBaseException; import com.artfess.bo.model.BoAttribute; import com.artfess.bo.model.BoData; import com.artfess.bo.model.BoDataRel; import com.artfess.bo.model.BoDef; import com.artfess.bo.model.BoEnt; import com.artfess.bo.model.BoResult; import com.artfess.bo.model.SqlModel; import com.artfess.bo.persistence.dao.BoDataRelDao; import com.artfess.bo.persistence.manager.BoEntManager; import com.artfess.table.meta.impl.BaseTableMeta; import com.artfess.table.model.Column; import com.artfess.table.util.MetaDataUtil; import com.artfess.uc.api.util.IPermissionCalc; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.node.ArrayNode; import com.fasterxml.jackson.databind.node.ObjectNode; import io.jsonwebtoken.lang.Assert; import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.exception.ExceptionUtils; import org.springframework.dao.DuplicateKeyException; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.io.IOException; import java.sql.SQLIntegrityConstraintViolationException; import java.sql.Timestamp; import java.text.ParseException; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.HashSet; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Map.Entry; import java.util.Set; import java.util.UUID; import java.util.function.UnaryOperator; /** * 保存到数据库中的处理器 * * @author heyifan * @company 阿特菲斯信息技术有限公司 * @email heyf@jee-soft.cn * @date 2018年4月12日 */ @Service("boDataHandler") public class BoDbHandlerImpl extends AbstractBoDataHandler { @Resource DatabaseContext databaseContext; @Resource BoDataRelDao boDataRelDao; @Resource CommonManager commonManager; @Resource BoEntManager boEntManager; @Resource SystemConfigFeignService systemConfigFeignService; @Resource IPermissionCalc permissionCalc; @Override public List save(String id, String defId, BoData curData) { BoEnt boEnt = curData.getBoEnt(); Map row = curData.getData(); String pk = ""; if (boEnt != null) { pk = boEnt.getPkKey().toLowerCase(); if (StringUtil.isNotEmpty(id)) { row.put(pk, id); } } // 添加结果。 List resultList = new ArrayList(); try { // 数据中包含主表表示更新 if (row.containsKey(pk)) { update(curData, resultList); } else { add(curData, resultList, "0"); } } catch (NumberFormatException ex) { ex.printStackTrace(); String[] str = ex.getMessage().split(":"); throw new NumberFormatException(str[1] + "非数字，请输入正确数值！"); } catch (BaseException e) { throw new BaseException(e.getMessage(), e); } catch (Exception ex) { throw new BaseException(ex.getMessage(), ex); } // 设置bodefAlias. if (curData.getBoDef() != null) { setBoDefAlias(resultList, curData.getBoDef().getAlias()); } return resultList; } private BoDef getBoDefByAlias(String alias) { BoDef boDef = boDefManager.getByAlias(alias); return boDef; } @Override public BoData getById(Object pk, String bodefCode) { BoDef boDef = getBoDefByAlias(bodefCode); BoData boData = new BoData(); boData.setBoDef(boDef); BoEnt boEnt = boDef.getBoEnt(); boData.setBoEnt(boEnt); Map row = getById(boEnt, pk); boData.setData(row); // 子表处理 List childEntList = boEnt.getChildEntList(); for (BoEnt childEnt : childEntList) { List> list = getByFk(childEnt, pk); // list为子表数据 String key = childEnt.getName(); List listData = new ArrayList(); //孙表实体列表 List sunEntList = childEnt.getChildEntList(); Map initData = childEnt.getInitData(); if (BeanUtils.isNotEmpty(sunEntList)) { Map sunInitData = new HashMap(); for (BoEnt sunEnt : sunEntList) { initData.put("sub_" + sunEnt.getName(), new ArrayList<>()); sunInitData.put(sunEnt.getName(), sunEnt.getInitData()); } initData.put("initData", sunInitData); } for (Map rowMap : list) { BoData childData = new BoData(); Map rtnMap = convertDbToData(childEnt, rowMap); childData.setData(rtnMap); //处理孙表 if (BeanUtils.isNotEmpty(sunEntList)) { String subPkStr = StringUtil.isNotEmpty(childEnt.getPk()) ? childEnt.getPk() : BoEnt.PK_NAME; //String subPk = (String) rowMap.get(subPkStr); String subPk = String.valueOf(rowMap.get(subPkStr)); //如果获取到的子表主键为空，则尝试使用小写方式获取 if (StringUtil.isEmpty(subPk) && StringUtil.isNotEmpty(subPkStr)) { subPk = (String) rowMap.get(subPkStr.toLowerCase()); } for (BoEnt sunEnt : sunEntList) { List> sunList = getByFk(sunEnt, subPk); String sunKey = sunEnt.getName(); List sunListData = new ArrayList(); for (Map sunRowMap : sunList) { BoData sunData = new BoData(); Map sunRtnMap = convertDbToData(sunEnt, sunRowMap); sunData.setData(sunRtnMap); sunListData.add(sunData); } childData.addInitDataMap(sunKey, sunEnt.getInitData()); childData.setSubList(sunKey, sunListData); } } listData.add(childData); } boData.addInitDataMap(key, initData); boData.setSubList(key, listData); } return boData; } /** * 将从数据库读取的数据到实例数据。 * * @param boEnt * @param map * @return */ private Map convertDbToData(BoEnt boEnt, Map map) { Map rtnMap = new HashMap(); for (Entry ent : map.entrySet()) { String field = ent.getKey().toLowerCase(); BoAttribute attribute = boEnt.getAttrByField(field); if (BeanUtils.isNotEmpty(attribute)) { // 处理日期。 Object val = handValue(attribute, ent.getValue()); rtnMap.put(attribute.getName(), val); } } Object f_form_data_rev_ = 0; if (map.containsKey("F_form_data_rev_")) { f_form_data_rev_ = map.get("F_form_data_rev_"); } else if (map.containsKey("f_form_data_rev_")) { f_form_data_rev_ = map.get("f_form_data_rev_"); } else if (map.containsKey("F_FORM_DATA_REV_")) { f_form_data_rev_ = map.get("F_FORM_DATA_REV_"); } if (map.containsKey(BoEnt.SUB_ROW_READONLY)) { rtnMap.put(BoEnt.SUB_ROW_READONLY, map.get(BoEnt.SUB_ROW_READONLY)); } rtnMap.put("form_data_rev_", f_form_data_rev_); if (!BoEnt.GRADE.MAIN.equals(boEnt.getType())) { rtnMap.put(BoEnt.SUB_KEY, UUID.randomUUID());//处理子表v-for 渲染DOM出错新加的字段 } String pkKey = boEnt.getPkKey(); if (boEnt.isPkNumber() && BeanUtils.isNotEmpty(rtnMap.get(pkKey))) { rtnMap.put(pkKey, rtnMap.get(pkKey).toString()); } return rtnMap; } /** * 数据根据bo属性处理。 * * @param attr * @param val * @return */ private Object handValue(BoAttribute attr, Object val) { if (BeanUtils.isEmpty(val)) return val; if (Column.COLUMN_TYPE_DATE.equals(attr.getDataType())) { String format = attr.getFormat(); if (val instanceof Timestamp) { Timestamp times = (Timestamp) val; return TimeUtil.getDateTimeString(times.toLocalDateTime(), format); } else if (val instanceof Date) { return TimeUtil.getDateTimeString(DateFormatUtil.parse((Date) val), format); } else if (val instanceof LocalDateTime) { return TimeUtil.getDateTimeString((LocalDateTime) val, format); } } return val; } /** * 获取一行数据。 * * @param boEnt * @return */ private Map getById(BoEnt boEnt, Object pk) { String sql = String.format("select * from %s where %s=#{pk}", boEnt.getTableName(), boEnt.getPkKey()); if (boEnt.isPkNumber()) { pk = Long.valueOf(pk.toString()); } Map map = null; if (boEnt.isExternal()) { // 切换外部表查询数据 try (DatabaseSwitchResult setDataSource = databaseContext.setDataSource(boEnt.getDsName())) { map = getOneById(sql, pk); } catch (Exception e) { throw new BoBaseException("操作外部表：" + boEnt.getDsName() + " 中的 " + boEnt.getDesc() + " 出错：" + ExceptionUtils.getRootCauseMessage(e)); } } else { map = getOneById(sql, pk); } Map rtnMap = convertDbToData(boEnt, map); return rtnMap; } /** * 通过主键查询一行数据 * * @param sql * @param pk * @return */ private Map getOneById(String sql, Object pk) { Map buildMap = new HashMap<>(); if (BeanUtils.isNotEmpty(pk)) { buildMap.put("pk", pk); } List> result = commonManager.query(sql, buildMap); Assert.isTrue(BeanUtils.isNotEmpty(result) && result.size() == 1, "通过主键查询数据时结果为空或查询到超过一条记录"); return result.get(0); } /** * 根据外键获取列表数据。 * * @param boEnt * @return */ private List> getByFk(BoEnt boEnt, Object pk) { List> list = new ArrayList>(); ObjectNode subRowAuthJosn = null; if (BeanUtils.isNotEmpty(FormContextThreadUtil.getCommuVar("subRowAuthJosn", ""))) { try { ObjectNode curTab = (ObjectNode) JsonUtil.toJsonNode((String) FormContextThreadUtil.getCommuVar("subRowAuthJosn", "")); subRowAuthJosn = (ObjectNode) curTab.get(boEnt.getName()); } catch (IOException e) { e.printStackTrace(); } } // 拼装sql String sql = ""; String readSql = ""; Set totalAuth = new HashSet<>(); Map varMap = new HashMap<>(); // 如果子表授权不为空，则添加过滤。把编辑和查看权限的数据一起查出来。 if (BeanUtils.isNotEmpty(subRowAuthJosn)) { if (boEnt.getType().equals("manytomany")) { sql = "select A.* from " + boEnt.getTableName() + " A , form_bo_data_relation B where " + " B.SUB_BO_NAME = '" + boEnt.getName() + "' AND A." + boEnt.getPk() + "=B.FK_ AND B.PK_=?"; } else { String fk = boEnt.getFk(); if (StringUtil.isEmpty(fk)) { throw new RuntimeException("通过添加外部表构建业务对象时必须指定外键"); } sql = "select * from " + boEnt.getTableName() + " A where A." + fk + "=?"; } varMap.put("curDate", DateUtil.getCurrentTime()); varMap.put("curUserId", AuthenticationUtil.getCurrentUserId()); varMap.put("curUserAccount", AuthenticationUtil.getCurrentUsername()); varMap.put("curUserName", AuthenticationUtil.getCurrentUserFullname()); varMap.put("curUserOrgIds", transToInsql(AuthenticationUtil.getCurrentUserOrgIds())); varMap.put("curUserOrgAndUnderIds", transToInsql(AuthenticationUtil.getCurrentUserSubOrgIds())); varMap.put("curUserRolesAlias", transToInsql(StringUtil.join(AuthenticationUtil.getCurrentUserRolesAlias(), ","))); readSql = sql; ArrayNode total = (ArrayNode) subRowAuthJosn.get("total"); for (JsonNode jsonNode : total) { totalAuth.add(jsonNode.asText()); } //没有配置查看所有的权限。则追加过滤sql if (!totalAuth.contains("r") && StringUtil.isNotEmpty(JsonUtil.getStrByPath(subRowAuthJosn, "r.conditionString"))) { readSql = sql + " and (" + JsonUtil.getStrByPath(subRowAuthJosn, "r.conditionString") + ")"; readSql = StringUtil.getStrByRule(readSql, varMap); } } else { //没有配置新的子表数据过滤则使用老的子表数据授权逻辑。 WorkflowFeignService workflowFeignService = AppUtil.getBean(WorkflowFeignService.class); ObjectNode objectNode = JsonUtil.getMapper().createObjectNode(); try { objectNode = (ObjectNode) JsonUtil.toJsonNode(boEnt); } catch (IOException e) { throw new RuntimeException(e); } String defId = (String) FormContextThreadUtil.getCommuVar("defId", ""); String nodeId = (String) FormContextThreadUtil.getCommuVar("nodeId", ""); String parentDefKey = (String) FormContextThreadUtil.getCommuVar("parentDefKey", "local_"); CommonResult result = workflowFeignService.getSubDataSqlByFk(objectNode, pk, defId, nodeId, parentDefKey); readSql = result.getValue(); } list = executeQuery(boEnt, readSql, pk); //没有配置子表数据过滤，过着配置了编辑所有。则直接返回列表，不作编辑权限控制 if (BeanUtils.isEmpty(list) || BeanUtils.isEmpty(subRowAuthJosn) || totalAuth.contains("w") || StringUtil.isEmpty(JsonUtil.getStrByPath(subRowAuthJosn, "w.conditionString"))) { return list; } Set editKeys = new HashSet<>(); // 查询有编辑权限的数据 String editSql = sql + " and (" + JsonUtil.getStrByPath(subRowAuthJosn, "w.conditionString") + ")"; editSql = StringUtil.getStrByRule(editSql, varMap); List> editList = executeQuery(boEnt, editSql, pk); if (BeanUtils.isNotEmpty(editList)) { for (Map data : editList) { editKeys.add(data.get(BoEnt.PK_NAME)); } } for (Map data : list) { // 有编辑权限，则标记为可以编辑 if (editKeys.contains(data.get(BoEnt.PK_NAME))) { data.put(BoEnt.SUB_ROW_READONLY, false); } else { data.put(BoEnt.SUB_ROW_READONLY, true); } } return list; } private String transToInsql(String str) { StringBuilder sBuilder = new StringBuilder(); sBuilder.append("('"); if (StringUtil.isNotEmpty(str)) { sBuilder.append(StringUtil.join(str.split(","), "','")); } sBuilder.append("')"); return sBuilder.toString(); } /** * 根据外键获取子表数据 * * @param boEnt bo实体 * @param sql * @param pk 外键值 * @return 子表数据列表 */ public List> executeQuery(BoEnt boEnt, String sql, Object pk) { if (boEnt.isExternal()) { // 外部表数据 try (DatabaseSwitchResult setDataSource = databaseContext.setDataSource(boEnt.getDsName())) { return commonManager.query(sql, pk); } catch (Exception e) { throw new RuntimeException("操作外部表：" + boEnt.getDsName() + " 中的 " + boEnt.getDesc() + " 出错：" + e.getMessage(), e); } } else { return commonManager.query(sql, pk); } } /** * 处理添加数据的情况。 * * @param curData * @param resultList * @param parentId * @throws ParseException */ private void add(BoData curData, List resultList, String parentId) throws ParseException { BoEnt boEnt = curData.getBoEnt(); Map map = convertDbMap(curData); // 添加主表 BoResult boResult = insert(boEnt, map, parentId); boResult.setBoAlias(curData.getBoDefAlias()); resultList.add(boResult); if (BeanUtils.isEmpty(boEnt)) return; Map entMap = boEnt.getChildMap(); if (BeanUtils.isEmpty(entMap) && StringUtil.isNotEmpty(parentId) && BeanUtils.isNotEmpty(curData.getData()) && !curData.getData().isEmpty()) { boolean hasSun = false; for (String key : curData.getData().keySet()) { if (key.startsWith("sub_") && BeanUtils.isNotEmpty(curData.getData().get(key))) { hasSun = true; break; } } if (hasSun) { List sunEnts = boEntManager.getBySubEntId(boEnt.getId()); if (BeanUtils.isNotEmpty(sunEnts)) { boEnt.setChildEntList(sunEnts); entMap = boEnt.getChildMap(); } else { return; } } else { return; } } // 子表添加 for (Entry> ent : curData.getSubMap().entrySet()) { String key = ent.getKey(); String tableName = key.replaceFirst("sub_", ""); BoEnt childEnt = entMap.get(tableName.toLowerCase()); List subDataList = ent.getValue(); for (BoData chidData : subDataList) { // 设置子数据的实体元数据。 chidData.setBoEnt(childEnt); add(chidData, resultList, boResult.getPk()); } } } /** * 更新数据只管两层结构。 * * 
     * 	1.更新主表。
     *  2.更新子表。
     *  	1.添加
     *  	2.删除
     *  	3.更新
     *
* * @param curData * @param resultList * @throws ParseException */ private void update(BoData curData, List resultList) throws Exception { BoEnt boEnt = curData.getBoEnt(); Map map = convertDbMap(curData); String modifyResult = ""; // 更新主表 BoResult boResult = update(boEnt, map); if (StringUtil.isNotEmpty(boResult.getModifyDetail())) { modifyResult = String.format("主表【%s】修改明细：\n%s", boEnt.getDesc(), boResult.getModifyDetail()); } boResult.setBoAlias(curData.getBoDefAlias()); resultList.add(boResult); String pk = (String) map.get(boEnt.getPkKey()); Map entMap = boEnt.getChildMap(); //if (BeanUtils.isEmpty(entMap)) return; if (BeanUtils.isEmpty(entMap) && BeanUtils.isNotEmpty(curData.getData()) && !curData.getData().isEmpty()) { boolean hasSun = false; for (String key : curData.getData().keySet()) { if (key.startsWith("sub_") && BeanUtils.isNotEmpty(curData.getData().get(key))) { hasSun = true; break; } } if (hasSun) { List sunEnts = boEntManager.getBySubEntId(boEnt.getId()); if (BeanUtils.isNotEmpty(sunEnts)) { boEnt.setChildEntList(sunEnts); entMap = boEnt.getChildMap(); } else { return; } } else { return; } } //删除子表数据中不存在的数据 if (BeanUtils.isEmpty(curData.getSubMap())) { for (Entry entry : entMap.entrySet()) { BoEnt childEnt = (BoEnt) entMap.get(entry.getKey()); if (BeanUtils.isNotEmpty(childEnt)) { // 获取原来的数据。 //TODO 拿到流程key，formkey，nodeId查询流程权限。获取子表授权配置 Map> oldDatas = getOldSubDatas(childEnt, pk); // 删除孙表数据 deleteSunBoData(childEnt, oldDatas, resultList); for (String subPk : oldDatas.keySet()) { BoResult result = delete(childEnt, subPk); resultList.add(result); } modifyResult += String.format("\n子表【%s】删除明细：%s", childEnt.getDesc(), BeanUtils.ObjectToString(oldDatas)); } } } else { // 子表数据更新。 for (Entry> ent : curData.getSubMap().entrySet()) { String key = ent.getKey(); String tableName = key.replaceFirst("sub_", ""); BoEnt childEnt = entMap.get(tableName.toLowerCase()); if (BeanUtils.isEmpty(childEnt)) { continue; } // 获取原来的数据。 Map> oldDatas = getOldSubDatas(childEnt, pk); //存在的记录。 Set updSet = new HashSet(); List subDataList = ent.getValue(); String curSubModifyRes = ""; //获取孙表 List sunEnts = boEntManager.getBySubEntId(childEnt.getId()); for (int i = 0; i < subDataList.size(); i++) { BoData chidData = subDataList.get(i); chidData.setBoEnt(childEnt); String childPkField = childEnt.getPkKey(); Map childRow = convertDbMap(chidData); // 表示数据存在。 if (chidData.containKey(childPkField)) { String childPk = chidData.getString(childPkField); updSet.add(childPk); // 包含 if (oldDatas.keySet().contains(childPk)) { BoResult result = update(childEnt, childRow); //处理孙表数据 if (BeanUtils.isNotEmpty(sunEnts)) { updateSunBoData(sunEnts, chidData, childPk, resultList); } if (StringUtil.isNotEmpty(result.getModifyDetail())) { curSubModifyRes += String.format("\n第【%s】行修改明细：%s", i + 1, result.getModifyDetail()); } if (result != null) { if ("0".equals(result.getParentId())) { result.setParentId(pk); } resultList.add(result); } } } // 数据不存在则添加 else { BoResult result = insert(childEnt, childRow, pk); //处理孙表数据 addSunBoData(resultList, sunEnts, chidData, result.getPk()); //if(BeanUtils.isNotEmpty(childEnt.getChildEntList())) curSubModifyRes += String.format("\n第【%s】行新增明细：%s", i + 1, BeanUtils.ObjectToString(childRow)); resultList.add(result); } } //原来的集合不包含提交的记录就要删除。 List delDatas = new ArrayList<>(); for (String subPk : oldDatas.keySet()) { if (!updSet.contains(subPk)) { delDatas.add(BeanUtils.ObjectToString(oldDatas.get(subPk))); //处理孙表数据删除 deleteSunBoData(resultList, sunEnts, subPk); BoResult result = delete(childEnt, subPk); resultList.add(result); } } if (delDatas.size() > 0) { curSubModifyRes += String.format("\n删除明细【%s】", StringUtil.join(delDatas, ",")); } if (StringUtil.isNotEmpty(curSubModifyRes)) { modifyResult += String.format("\n子表【%s】变更明细：%s", childEnt.getDesc(), curSubModifyRes); } } } // 设置bodefAlias setBoDefAlias(resultList, curData.getBoDefAlias()); if (resultList.size() > 0) { resultList.get(0).setModifyDetail(modifyResult); } } //子表数据更新后处理孙表数据 private void updateSunBoData(List sunEnts, BoData chidData, String childPk, List resultList) throws IOException, ParseException { Map subData = chidData.getData(); if (BeanUtils.isNotEmpty(subData)) { for (BoEnt sunEnt : sunEnts) { //获取原来的数据 Map> oldSunDatas = getOldSubDatas(sunEnt, childPk); if (BeanUtils.isNotEmpty(subData.get("sub_" + sunEnt.getName()))) { JsonNode sunDatas = JsonUtil.toJsonNode(subData.get("sub_" + sunEnt.getName())); String sunPkField = sunEnt.getPkKey(); for (JsonNode sunNode : sunDatas) { BoData sunData = new BoData(); sunData.setBoEnt(sunEnt); sunData.setData(JsonUtil.toMap(JsonUtil.toJson(sunNode))); Map sunRow = convertDbMap(sunData); if (sunData.containKey(sunPkField)) { String sunPk = sunData.getString(sunPkField); if (oldSunDatas.keySet().contains(sunPk)) {//更新 BoResult result = update(sunEnt, sunRow); if (result != null) { if ("0".equals(result.getParentId())) { result.setParentId(childPk); } resultList.add(result); } oldSunDatas.remove(sunPk); } } else {//新增 BoResult result = insert(sunEnt, sunRow, childPk); if (result != null) { if ("0".equals(result.getParentId())) { result.setParentId(childPk); } resultList.add(result); } } } if (BeanUtils.isNotEmpty(oldSunDatas)) {//删除 for (String sunPk : oldSunDatas.keySet()) { BoResult result = delete(sunEnt, sunPk); resultList.add(result); } } } else if (BeanUtils.isNotEmpty(oldSunDatas)) { for (String sunPk : oldSunDatas.keySet()) { BoResult result = delete(sunEnt, sunPk); resultList.add(result); } } } } } /** * 删除孙表数据 * * @param childEnt * @param oldDatas * @param resultList */ private void deleteSunBoData(BoEnt childEnt, Map> oldDatas, List resultList) { if (BeanUtils.isNotEmpty(childEnt) && BeanUtils.isNotEmpty(childEnt.getChildEntList()) && BeanUtils.isNotEmpty(oldDatas)) { List sunEnts = childEnt.getChildEntList(); for (BoEnt sunEnt : sunEnts) { for (String subPk : oldDatas.keySet()) { Map> oldSunDatas = getOldSubDatas(sunEnt, subPk); if (BeanUtils.isNotEmpty(oldSunDatas)) { for (String sunPk : oldSunDatas.keySet()) { BoResult result = delete(sunEnt, sunPk); resultList.add(result); } } } } } } /** * 处理孙数据的新增 * * @param resultList * @param sunEnts * @param chidData * @param parentId */ private void addSunBoData(List resultList, List sunEnts, BoData chidData, String parentId) { //处理孙表数据 try { if (BeanUtils.isNotEmpty(sunEnts)) { boolean hasSun = false; Map sunDataMap = new HashMap(); for (String subKey : chidData.getData().keySet()) { if (subKey.startsWith("sub_") && BeanUtils.isNotEmpty(chidData.getData().get(subKey))) { sunDataMap.put(subKey, chidData.getData().get(subKey)); hasSun = true; } } if (hasSun) { for (BoEnt sunBoEnt : sunEnts) { if (sunDataMap.containsKey("sub_" + sunBoEnt.getName())) { ArrayNode sunArray = (ArrayNode) JsonUtil.toJsonNode(sunDataMap.get("sub_" + sunBoEnt.getName())); for (JsonNode jsonNode : sunArray) { Map sunRow = JsonUtil.toMap(JsonUtil.toJson(jsonNode)); BoData sunData = new BoData(); sunData.setBoDef(chidData.getBoDef()); sunData.setBoEnt(sunBoEnt); sunData.setBoDefAlias(chidData.getBoDefAlias()); sunData.setData(sunRow); Map row = convertDbMap(sunData); BoResult sunresult = insert(sunBoEnt, row, parentId); resultList.add(sunresult); } } } } } } catch (Exception e) { throw new RuntimeException("处理孙表数据失败：" + e.getMessage()); } } private void deleteSunBoData(List resultList, List sunEnts, String subPk) { //处理孙表数据删除 if (BeanUtils.isNotEmpty(sunEnts)) { for (BoEnt sunEnt : sunEnts) { // 获取原来的数据。 Map> oldSunDatas = getOldSubDatas(sunEnt, subPk); if (BeanUtils.isNotEmpty(oldSunDatas)) { for (String sunPk : oldSunDatas.keySet()) { BoResult sunResult = delete(sunEnt, sunPk); resultList.add(sunResult); } } } } } /** * 将数据进行转换。 * * 
     * 1.将map数据转成DB字段。
     * 2.转换数据的类型。
     *
* * @param curData * @return * @throws ParseException */ private Map convertDbMap(BoData curData) throws ParseException { Map rtnMap = new HashMap(); BoEnt boEnt = curData.getBoEnt(); if (boEnt == null) { return rtnMap; } List list = boEnt.getBoAttrList(); for (BoAttribute attr : list) { BoAttribute boAttr = (BoAttribute) attr; String fieldName = boAttr.getFieldName(); String name = boAttr.getName(); if (!curData.containKey(name)) continue; Object obj = curData.getValByKey(name); if (BeanUtils.isNotEmpty(obj) && (!name.equals("form_data_rev_") && !name.equals("F_form_data_rev_"))) { String dataType = "varchar"; if (obj.toString().length() > attr.getIntLen() && dataType.equals(attr.getDataType())) { throw new BaseException(attr.getDesc() + "字段超过设置的字符长度！"); } } /*if(attr.getIsRequired() == 1 && BeanUtils.isEmpty(obj.toString()) && !"hide".equals(attr.getStatus())){ throw new BaseException(attr.getDesc() + "：请输入内容！"); }*/ rtnMap.put(fieldName, obj); } String pk = boEnt.getPkKey(); // String fk=boEnt.getFk(); //去掉添加外键的逻辑 if (curData.containKey(pk)) { rtnMap.put(pk, curData.getString(pk)); } //去掉添加外键sql // if (StringUtil.isNotEmpty(fk) && curData.containKey(fk)) { // rtnMap.put(fk, curData.getString(fk)); // } if (!boEnt.isExternal()) { rtnMap.put("F_form_data_rev_", BeanUtils.isNotEmpty(curData.getByKey("form_data_rev_")) ? curData.getByKey("form_data_rev_") : 0); } return rtnMap; } /** * 插入数据。 * * @param row * @param parentId * @return */ private BoResult insert(BoEnt boEnt, Map row, String parentId) { String tableName = ""; String pkField = ""; if (boEnt != null) { tableName = boEnt.getTableName(); pkField = boEnt.getPkKey(); } Object id = UniqueIdUtil.getSuid(); if (boEnt.isPkNumber()) { id = Long.valueOf(id.toString()); } StringBuffer fieldNames = new StringBuffer(","); StringBuffer params = new StringBuffer(); final List values = new ArrayList(); fieldNames.append(pkField).append(","); params.append("?,"); values.add(id); // 多对多时关联放到第三张表中。 if (boEnt != null) { if (!boEnt.getType().equals(BoConstants.RELATION_MANY_TO_MANY) && StringUtil.isNotEmpty(boEnt.getFk())) { if (fieldNames.toString().toUpperCase().indexOf("," + boEnt.getFk().toUpperCase() + ",") > -1) { throw new RuntimeException(String.format("外部表【%s(%s)】的外键不能和主键相同", boEnt.getDesc(), boEnt.getName())); } fieldNames.append(boEnt.getFk()).append(","); params.append("?,"); values.add(parentId); } } for (Entry entry : row.entrySet()) { if (fieldNames.toString().toUpperCase().indexOf("," + entry.getKey().toUpperCase() + ",") < 0) { fieldNames.append(entry.getKey()).append(","); params.append("?,"); values.add(entry.getValue()); } } fieldNames = new StringBuffer(fieldNames.substring(1)); StringBuffer sql = new StringBuffer(); if (!"".equals(tableName) && tableName != null) { sql.append(" INSERT INTO "); sql.append(tableName); sql.append("("); sql.append(fieldNames.substring(0, fieldNames.length() - 1)); sql.append(")"); sql.append(" VALUES ("); sql.append(params.substring(0, params.length() - 1)); sql.append(")"); SqlModel sqlModel = new SqlModel(sql.toString(), values.toArray()); // 执行插入动作。 executeSql(sqlModel, boEnt); // 多对多的情况处理中间表。 if (boEnt.getType().equals(BoConstants.RELATION_MANY_TO_MANY)) { String relPk = UniqueIdUtil.getSuid(); BoDataRel entRel = new BoDataRel(relPk, parentId, id.toString(), boEnt.getName()); boDataRelDao.insert(entRel); } } /** * 结果返回 */ BoResult result = new BoResult(); result.setParentId(parentId); result.setAction(BoConstants.HANDLE_ADD); result.setBoEnt(boEnt); result.setPk(id.toString()); return result; } /** * 执行sql语句。 * * @param model * @param boEnt :为null时默认是在本地数据与执行该sql void * @return * @throws * @since 1.0.0 */ @SuppressWarnings("all") private int executeSql(SqlModel model, BoEnt boEnt) { String sql = model.getSql(); int update = -1; if (StringUtil.isEmpty(sql)) { return update; } Object[] obs = model.getValues(); if (boEnt == null || !boEnt.isExternal()) { try { update = commonManager.execute(sql, obs); } catch (DuplicateKeyException ex) { Throwable cause = ex.getCause(); String dsName = boEnt.getDsName(); if (StringUtil.isEmpty(dsName)) { dsName = DataSourceConsts.LOCAL_DATASOURCE; } if (cause instanceof SQLIntegrityConstraintViolationException) { List> tables = null; try (DatabaseSwitchResult dResult = databaseContext.setDataSource(dsName)) { BaseTableMeta baseTableMeta = MetaDataUtil.getBaseTableMetaAfterSetDT(dResult.getDbType());// 获取表操作元 tables = baseTableMeta.getTablesByNameIndex(boEnt.getTableName()); } catch (Exception e) { e.printStackTrace(); } //错误信息 String errMsg = ((SQLIntegrityConstraintViolationException) cause).getMessage(); //根据约束名称定位是那个字段 if (StringUtils.isNotBlank(errMsg)) { String customMsg = ""; if (BeanUtils.isNotEmpty(tables)) { //这里转换成set如果有联合索引会有重复记录 Set> result = new HashSet>(tables); for (Map table : result) { if (errMsg.contains(table.get("keyName").toString()) && StringUtil.isEmpty(customMsg)) { customMsg += table.get("indexComment").toString(); } else if (errMsg.contains(table.get("keyName").toString()) && StringUtil.isNotEmpty(customMsg)) { customMsg += "," + table.get("indexComment").toString(); } } } if (StringUtil.isEmpty(customMsg)) { customMsg = "您填写的内容有重复，请核查！"; } throw new BaseException(customMsg, ex); } } throw new RuntimeException("操作外部表：" + boEnt.getDsName() + " 中的 " + boEnt.getDesc() + " 出错：" + ex.getMessage(), ex); } catch (Exception e) { throw new BaseException(e.getMessage(), e); } } else { try (DatabaseSwitchResult setDataSource = databaseContext.setDataSource(boEnt.getDsName())) { return commonManager.execute(sql, obs); } catch (DuplicateKeyException ex) { Throwable cause = ex.getCause(); String dsName = boEnt.getDsName(); if (StringUtil.isEmpty(dsName)) { dsName = DataSourceConsts.LOCAL_DATASOURCE; } if (cause instanceof SQLIntegrityConstraintViolationException) { List> tables = null; try (DatabaseSwitchResult dResult = databaseContext.setDataSource(dsName)) { BaseTableMeta baseTableMeta = MetaDataUtil.getBaseTableMetaAfterSetDT(dResult.getDbType());// 获取表操作元 tables = baseTableMeta.getTablesByNameIndex(boEnt.getTableName()); } catch (Exception e) { e.printStackTrace(); } //错误信息 String errMsg = ((SQLIntegrityConstraintViolationException) cause).getMessage(); //根据约束名称定位是那个字段 if (StringUtils.isNotBlank(errMsg)) { String customMsg = ""; if (BeanUtils.isNotEmpty(tables)) { //这里转换成set如果有联合索引会有重复记录 Set> result = new HashSet>(tables); for (Map table : result) { if (errMsg.contains(table.get("keyName").toString()) && StringUtil.isEmpty(customMsg)) { customMsg += table.get("indexComment").toString(); } else if (errMsg.contains(table.get("keyName").toString()) && StringUtil.isNotEmpty(customMsg)) { customMsg += "," + table.get("indexComment").toString(); } } } if (StringUtil.isEmpty(customMsg)) { customMsg = "您填写的内容有重复，请核查！"; } throw new BaseException(customMsg, ex); } } throw new RuntimeException("操作外部表：" + boEnt.getDsName() + " 中的 " + boEnt.getDesc() + " 出错：" + ex.getMessage(), ex); } catch (Exception e) { throw new RuntimeException("操作外部表：" + boEnt.getDsName() + " 中的 " + boEnt.getDesc() + " 出错：" + e.getMessage(), e); } } return update; } /** * 更新一行数据。 * * @param boEnt * @param row * @return */ private BoResult update(BoEnt boEnt, Map row) { BoResult result = new BoResult(); String tableName = boEnt.getTableName(); String pkField = boEnt.getPkKey(); Object pkValue = BeanUtils.isNotEmpty(row.get(pkField)) ? row.get(pkField).toString() : row.get(pkField.toUpperCase()).toString(); if (boEnt.isPkNumber() && BeanUtils.isNotEmpty(pkValue)) { pkValue = Long.valueOf(pkValue.toString()); } String pkType = boEnt.getPkType(); boolean isDataChange = false; if (!boEnt.isExternal()) { Map oldEntData = null; if (!(Column.COLUMN_TYPE_NUMBER.equals(pkType) || Column.COLUMN_TYPE_INT.equals(pkType))) { oldEntData = this.getOneById("select * from " + tableName + " where " + pkField + " ='" + pkValue + "'", null); } else { oldEntData = this.getOneById("select * from " + tableName + " where " + pkField + " =" + pkValue, null); } if (BeanUtils.isNotEmpty(oldEntData)) { String modifyDetail = compareData(boEnt, row, oldEntData); if (StringUtil.isNotEmpty(modifyDetail)) { result.setModifyDetail(modifyDetail); isDataChange = true; } } } else {//外部表更新时不进行数据版本校验 ThreadMsgUtil.addMapMsg("hasCheckFormDataRev", "true"); } CommonResult portalDataSensitiveResult = systemConfigFeignService.getPortalDataSensitive(boEnt.getDsName(), tableName); PortalDataSensitive portalDataSensitive = null; Map> currentProfiles = null; if (portalDataSensitiveResult.getState() && BeanUtils.isNotEmpty(portalDataSensitiveResult.getValue())) { portalDataSensitive = portalDataSensitiveResult.getValue(); currentProfiles = permissionCalc.getCurrentProfiles(); } int version = 0; if (BeanUtils.isNotEmpty(row.get("F_form_data_rev_"))) { version = Integer.parseInt(row.get("F_form_data_rev_").toString()); } if (isDataChange) { row.put("F_form_data_rev_", version + 1); } final List values = new ArrayList(); StringBuffer set = new StringBuffer(); for (Entry entry : row.entrySet()) { // 主键忽略 if (pkField.equals(entry.getKey()) || BoEnt.SUB_ROW_READONLY.equals(entry.getKey())) continue; // 判断字段是否设置了脱敏设置 已经设置的不能再更新到数据库 if (BeanUtils.isNotEmpty(portalDataSensitive)) { boolean hasRight = hasFieldNameRight(entry.getKey(), portalDataSensitive, currentProfiles); if (hasRight) { continue; } } set.append(entry.getKey()).append("=?,"); values.add(entry.getValue()); } result.setAction(BoConstants.HANDLE_UPDATE); result.setBoEnt(boEnt); result.setPk(pkValue.toString()); if (values.size() == 0) return result; // sql StringBuffer sql = new StringBuffer(); sql.append(" update "); sql.append(tableName); sql.append(" set "); sql.append(set.substring(0, set.length() - 1)); sql.append(" where "); sql.append(pkField); sql.append("=?"); values.add(pkValue); //同一个线程只做一次根据表单版本进行的校验 if (!"true".equals(ThreadMsgUtil.getMapMsg("hasCheckFormDataRev")) && !"false".equals(FormContextThreadUtil.getCommuVars().get("hasCheckFormDataRev"))) { sql.append(" and F_form_data_rev_=?"); values.add(version); } SqlModel sqlModel = new SqlModel(sql.toString(), values.toArray()); int numger = executeSql(sqlModel, boEnt); if (numger == 0) { throw new RuntimeException("表单数据已被其他用户修改，请重新加载数据。"); } ThreadMsgUtil.addMapMsg("hasCheckFormDataRev", "true"); String fkField = boEnt.getFk(); if (row.containsKey(fkField)) { String fkValue = row.get(fkField).toString(); if (StringUtils.isNotEmpty(fkValue) && !fkValue.equals("0")) { result.setParentId(fkValue); } } return result; } private boolean hasFieldNameRight(String fieldName, PortalDataSensitive portalDataSensitive, Map> currentProfiles) { try { ArrayNode arrayNode = (ArrayNode) JsonUtil.toJsonNode(portalDataSensitive.getDesensitizationRules()); for (JsonNode jsonNode : arrayNode) { if (fieldName.equalsIgnoreCase(jsonNode.get("fieldName").asText())) { boolean hasRight = hasRight(jsonNode.get("rights").asText(), currentProfiles); if (!hasRight) { return true; } } } } catch (IOException e) { throw new BaseException(ResponseErrorEnums.DESENSITIZATION); } return false; } private boolean hasRight(String rights, Map> currentProfiles) throws IOException { ArrayNode arrayNode = (ArrayNode) JsonUtil.toJsonNode(rights); for (JsonNode jsonNode : arrayNode) { return permissionCalc.hasRight(JsonUtil.toJsonString(jsonNode), currentProfiles); } return false; } /** * 删除数据。 * * @param boEnt * @return */ private BoResult delete(BoEnt boEnt, Object pk) { if (boEnt.isPkNumber() && BeanUtils.isNotEmpty(pk)) { pk = Long.valueOf(pk.toString()); } String sql = "delete from " + boEnt.getTableName() + " where " + boEnt.getPkKey() + " =? "; SqlModel sqlModel = new SqlModel(sql, new Object[]{pk}); executeSql(sqlModel, boEnt); // 多对多的情况删除关联数据。 if (boEnt.getType().equals(BoConstants.RELATION_MANY_TO_MANY)) { sql = "delete from form_bo_data_relation where SUB_BO_NAME='" + boEnt.getName() + "' and FK_=?"; sqlModel = new SqlModel(sql, new Object[]{pk}); executeSql(sqlModel, null); } // 删除表数据 BoResult result = new BoResult(); result.setAction(BoConstants.HANDLE_DELETE); //实体表中的数据被删除，则删除对应的bpm_bus_link里的数据 result.setBoEnt(boEnt); result.setPk(pk.toString()); return result; } /** * 根据主键递归获取数据。 */ @Override public BoData getResById(Object id, String bodefCode) { BoDef boDef = getBoDefByAlias(bodefCode); BoData boData = new BoData(); BoEnt boEnt = boDef.getBoEnt(); Map row = getById(boEnt, id); boData.setData(row); getCascadeById(id, boEnt, boData); return boData; } /** * 递归调用。 * * @param id * @param boEnt * @param boData */ private void getCascadeById(Object id, BoEnt boEnt, BoData boData) { // 子表处理 List childEntList = boEnt.getChildEntList(); if (BeanUtils.isEmpty(childEntList)) return; /** * 子表处理。 */ for (BoEnt childEnt : childEntList) { List> list = getByFk(childEnt, id); String key = childEnt.getName(); List listData = new ArrayList(); for (Map rowMap : list) { BoData childData = new BoData(); Map rtnMap = convertDbToData(childEnt, rowMap); childData.setData(rtnMap); listData.add(childData); String pkKey = childEnt.getPkKey(); //小写 String childId = (String) rowMap.get(pkKey); if (StringUtil.isEmpty(childId)) { childId = (String) rowMap.get(pkKey.toUpperCase()); } // 递归 getCascadeById(childId, childEnt, childData); } String subName = key.startsWith("sub_") ? key : "sub_" + key; ArrayList subArr = new ArrayList<>(); for (BoData listDatum : listData) { subArr.add(listDatum.getData()); } boData.getData().put(subName, subArr); boData.setSubList(key, listData); } } @Override public String saveType() { return BoConstants.SAVE_MODE_DB; } @Override public void removeBoData(String boCode, String[] aryIds) { BoDef boDef = getBoDefByAlias(boCode); BoEnt boEnt = boDef.getBoEnt(); List childEntList = boEnt.getChildEntList(); for (String id : aryIds) { delete(boEnt, id); for (BoEnt child : childEntList) { String sql = "delete from " + child.getTableName() + " where " + child.getFk() + " =? "; SqlModel sqlModel = new SqlModel(sql, new Object[]{id}); executeSql(sqlModel, boEnt); } } } @Override public List> getList(String boCode, Map param) { BoDef boDef = getBoDefByAlias(boCode); BoEnt boEnt = boDef.getBoEnt(); StringBuffer sql = new StringBuffer("select * from " + boEnt.getTableName()); List p = new ArrayList(); if (BeanUtils.isNotEmpty(param)) { sql.append(" where 1=1 "); for (String fieldName : param.keySet()) { String filedName = fieldName.toLowerCase(); // 如果param Name为某个字段。则拼接where 条件 if (boEnt.getAttrFieldMap().containsKey(filedName)) { sql.append(" and " + filedName + "=? "); p.add(param.get(fieldName)); } } } List> list = null; if (boEnt.isExternal()) { try (DatabaseSwitchResult setDataSource = databaseContext.setDataSource(boEnt.getDsName())) { list = commonManager.query(sql.toString(), p.toArray()); } catch (Exception e) { throw new RuntimeException("操作外部表：" + boEnt.getDsName() + " 中的 " + boEnt.getDesc() + " 出错：" + ExceptionUtils.getRootCauseMessage(e)); } } else { list = commonManager.query(sql.toString(), p.toArray()); } // 数据转换 List> returnData = new ArrayList>(); for (Map rowMap : list) { Map rtnMap = convertDbToData(boEnt, rowMap); returnData.add(rtnMap); } return returnData; } /** * 查询数据 */ @SuppressWarnings("rawtypes") @Override public PageList> getList(String boCode, QueryFilter queryFilter) { BoDef boDef = getBoDefByAlias(boCode); BoEnt boEnt = boDef.getBoEnt(); StringBuffer sb = new StringBuffer(" select * from " + boEnt.getTableName()); // 通过通用查询器查询分页数据 PageList> queryForPageList = commonManager.query(sb.toString(), queryFilter); List> rows = queryForPageList.getRows(); rows.replaceAll(new UnaryOperator>() { @Override public Map apply(Map rowMap) { return convertDbToData(boEnt, rowMap); } }); return queryForPageList; } private String compareData(BoEnt boEnt, Map newMap, Map oldMap) { //因为前端和后台返回的字段大小写不一致，所以此处统一的字段别名全部转小写来判断 Map newData = new HashMap(); for (Iterator> iterator = newMap.entrySet().iterator(); iterator.hasNext(); ) { Entry next = iterator.next(); newData.put(next.getKey().toLowerCase(), next.getValue()); } Map oldData = new HashMap(); for (Iterator> iterator = oldMap.entrySet().iterator(); iterator.hasNext(); ) { Entry next = iterator.next(); oldData.put(next.getKey().toLowerCase(), next.getValue()); } Map attrFieldMap = boEnt.getAttrFieldMap(); List changeList = new ArrayList<>(); //首先遍历新的,和老数据中不一致的，则视为修改了。老数据中不存在的，则为新增的。 for (Iterator> iterator = newData.entrySet().iterator(); iterator.hasNext(); ) { Entry next = iterator.next(); String filed = next.getKey(); if (!filed.equals("f_form_data_rev_")) { Object newVal = next.getValue(); Object oldVal = oldData.get(filed); if (!BeanUtils.isEquals(newVal, oldVal) && attrFieldMap.containsKey(filed)) { changeList.add(String.format("【%s】由【%s】修改为【%s】", attrFieldMap.get(filed).getDesc(), BeanUtils.ObjectToString(oldVal), BeanUtils.ObjectToString(newVal))); } } } //遍历旧的，如果新的不存在则认为已删除 for (Iterator> iterator = oldData.entrySet().iterator(); iterator.hasNext(); ) { Entry next = iterator.next(); if (BeanUtils.isEmpty(newData.get(next.getKey())) && BeanUtils.isNotEmpty(oldData.get(next.getKey())) && !BoEnt.FK_NAME.equalsIgnoreCase(next.getKey())) { BoAttribute boAttribute = attrFieldMap.get(next.getKey()); if (BeanUtils.isEmpty(boAttribute)) { continue; } String desc = boAttribute.getDesc(); String objectToString = BeanUtils.ObjectToString(oldData.get(next.getKey())); changeList.add(String.format("【%s】由【%s】修改为【】", desc, objectToString)); } } return StringUtil.join(changeList, ","); } /** * 获取子表数据map集合 * * @param childEnt * @param pk * @return */ private Map> getOldSubDatas(BoEnt childEnt, String pk) { Map> map = new HashMap<>(); String pkField = childEnt.getPkKey().toLowerCase(); List> oldList = new ArrayList>(); oldList = this.getByFk(childEnt, pk); for (Map row : oldList) { for (Entry entry : row.entrySet()) { if (entry.getKey().equalsIgnoreCase(pkField)) { map.put(entry.getValue().toString(), row); break; } } } return map; } }