| | |
| | | */ |
| | | @Value("${bzApply.seriesFlow:seriesFlow}") |
| | | private String seriesFlow; |
| | | |
| | | /*** |
| | | * 是否变更系列 |
| | | */ |
| | |
| | | public static final String BTM_NAME = "btm:name"; |
| | | |
| | | /** |
| | | * 配置的用来申请集团码的用户 |
| | | */ |
| | | @Value("${docking.apply.personUserAccount:28201728}") |
| | | public String applyCodeUserAccount; |
| | | |
| | | /** |
| | | * 密级的字段 |
| | | */ |
| | | public static final String SECRET_FILED = "secretgrade"; |
| | |
| | | } |
| | | R r = updateBatchByBaseModel(baseModelDTO.getBtmname(), baseModels); |
| | | if (!r.isSuccess()) { |
| | | throw new VciBaseException("更新数据出错,重试!" + r.getMsg()); |
| | | throw new VciBaseException("更新数据出错,请重试!" + r.getMsg()); |
| | | } |
| | | } |
| | | // 刚好顺序是一致的,所以直接按照codeallcode的顺序来拿业务数据 |
| | |
| | | return uiInfoVO; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 模板属性转换为表单定义的信息 |
| | | * |
| | |
| | | @Override |
| | | public DataGrid<Map<String, String>> queryGrid(String btmType, CodeClassifyTemplateVO templateVO, Map<String, String> conditionMap, PageHelper pageHelper) { |
| | | CodeTemplateAttrSqlBO sqlBO = getSqlByTemplateVO(btmType, templateVO, conditionMap, pageHelper); |
| | | // List<Map> maps = boService.queryByOnlySqlForMap(sqlBO.getSqlHasPage()); |
| | | // List<Map> maps = boService.queryByOnlySqlForMap(sqlBO.getSqlHasPage()); |
| | | List<Map<String, String>> maps = null; |
| | | try { |
| | | maps = commonsMapper.queryByOnlySqlForMap(sqlBO.getSqlHasPage()); |
| | |
| | | for (String s : map.keySet()) { |
| | | data.put(s.toLowerCase(Locale.ROOT), map.get(s) == null ? null : String.valueOf(map.get(s))); |
| | | } |
| | | // map.forEach((key, value) -> { |
| | | // data.put(((String) key).toLowerCase(Locale.ROOT), String.valueOf(value)); |
| | | // }); |
| | | // map.forEach((key, value) -> { |
| | | // data.put(((String) key).toLowerCase(Locale.ROOT), String.valueOf(value)); |
| | | // }); |
| | | dataList.add(data); |
| | | }); |
| | | wrapperData(dataList, templateVO, sqlBO.getSelectFieldList(), false); |
| | | // maps.stream().forEach(map -> { |
| | | // Map<String, String> data = new HashMap<>(); |
| | | //// map.forEach((key, value) -> { |
| | | //// data.put(((String) key).toLowerCase(Locale.ROOT), String.valueOf(value)); |
| | | //// }); |
| | | // for (String s : map.keySet()) { |
| | | // data.put(((String) s).toLowerCase(Locale.ROOT), String.valueOf(map.get(s))); |
| | | // } |
| | | // dataList.add(data); |
| | | // }); |
| | | // maps.stream().forEach(map -> { |
| | | // Map<String, String> data = new HashMap<>(); |
| | | // map.forEach((key, value) -> { |
| | | // data.put(((String) key).toLowerCase(Locale.ROOT), String.valueOf(value)); |
| | | // }); |
| | | // for (String s : map.keySet()) { |
| | | // data.put(((String) s).toLowerCase(Locale.ROOT), String.valueOf(map.get(s))); |
| | | // } |
| | | // dataList.add(data); |
| | | // }); |
| | | } |
| | | // dataGrid.setData(dataList); |
| | | // if (!CollectionUtils.isEmpty(maps)) { |
| | | // wrapperData(maps, templateVO, sqlBO.getSelectFieldList(), false); |
| | | // maps.stream().forEach(map -> { |
| | | // Map<String, String> data = new HashMap<>(); |
| | | //// map.forEach((key, value) -> { |
| | | //// data.put(((String) key).toLowerCase(Locale.ROOT), String.valueOf(value)); |
| | | //// }); |
| | | // for (String s : map.keySet()) { |
| | | // data.put(((String) s).toLowerCase(Locale.ROOT), String.valueOf(map.get(s))); |
| | | // } |
| | | // dataList.add(data); |
| | | // }); |
| | | // dataGrid.setData(dataList); |
| | | // if (!CollectionUtils.isEmpty(maps)) { |
| | | // wrapperData(maps, templateVO, sqlBO.getSelectFieldList(), false); |
| | | // maps.stream().forEach(map -> { |
| | | // Map<String, String> data = new HashMap<>(); |
| | | //// map.forEach((key, value) -> { |
| | | //// data.put(((String) key).toLowerCase(Locale.ROOT), String.valueOf(value)); |
| | | //// }); |
| | | // for (String s : map.keySet()) { |
| | | // data.put(((String) s).toLowerCase(Locale.ROOT), String.valueOf(map.get(s))); |
| | | // } |
| | | // dataList.add(data); |
| | | // }); |
| | | dataGrid.setData(dataList); |
| | | dataGrid.setTotal(Long.parseLong(commonsMapper.selectBySql(sqlBO.getSqlCount()).get(0).values().toArray()[0].toString())); |
| | | // } |
| | | // } |
| | | return dataGrid; |
| | | } |
| | | |
| | |
| | | userVOMap.put(String.valueOf(data.getId()), data); |
| | | } |
| | | } |
| | | // Map<String, SmUserVO> userVOMap = Optional.ofNullable(userQueryService.listUserByUserIds(userIds)).orElseGet(() -> new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t)); |
| | | // Map<String, SmUserVO> userVOMap = Optional.ofNullable(userQueryService.listUserByUserIds(userIds)).orElseGet(() -> new ArrayList<>()).stream().collect(Collectors.toMap(s -> s.getId().toLowerCase(Locale.ROOT), t -> t)); |
| | | dataMap.stream().forEach(data -> { |
| | | String creator = data.getOrDefault("creator", null); |
| | | if (StringUtils.isNotBlank(creator) && userVOMap.containsKey(creator.toLowerCase(Locale.ROOT))) { |
| | |
| | | if (referFieldMap.containsKey(field)) { |
| | | return VciBaseUtil.toInSql(referFieldMap.get(field), value); //referFieldMap.get(field) + SPACE + "= '" + value + "'" + SPACE; |
| | | } else { |
| | | return (field.contains(".") ? "" : "t.") + field + SPACE + "= " + getStringValueInWhere(field, value, attrVOMap) + "" + SPACE; |
| | | //TODO:暂时没考虑IN>1000条的问题 |
| | | //return (field.contains(".") ? "" : "t.") + field + SPACE + "= " + getStringValueInWhere(field, value, attrVOMap) + "" + SPACE; |
| | | return (field.contains(".") ? "" : "t.") + field + SPACE + "IN (" + getStringValueInWhere(field, "IN//"+value, attrVOMap) + ")" + SPACE; |
| | | } |
| | | } else if (key.endsWith("_notin")) { |
| | | String field = UBCSSqlKeyword.getColumn(key, "_in"); |
| | | if (referFieldMap.containsKey(field)) { |
| | | return VciBaseUtil.toInSql(referFieldMap.get(field), value); //referFieldMap.get(field) + SPACE + "= '" + value + "'" + SPACE; |
| | | } else { |
| | | //return (field.contains(".") ? "" : "t.") + field + SPACE + "not in (" + getStringValueInWhere(field, "IN//"+value, attrVOMap) + ")" + SPACE; |
| | | return (field.contains(".") ? "" : "t.") + field + SPACE + "IN (" + getStringValueInWhere(field, "IN//"+value, attrVOMap) + ")" + SPACE; |
| | | } |
| | | |
| | | } else { |
| | | // if (referFieldMap.containsKey(key)) { |
| | | // //说明是参照的,我们参照的查询都认为是字符串,如果是时间格式的查询肯定有问题, |
| | |
| | | || VciFieldTypeEnum.VTInteger.equals(fieldTypeEnum)) { |
| | | return value; |
| | | } else { |
| | | if(value.contains("IN//")){ |
| | | return MybatisParameterUtil.getInClause(Func.toStrList(value.replace("IN//",""))); |
| | | } |
| | | return "'" + value + "'"; |
| | | } |
| | | } else { |
| | | if ((value.startsWith("(") && value.endsWith(")")) || (value.startsWith("'") && value.endsWith("'"))) { |
| | | return value; |
| | | }else if(value.contains("IN//")){ |
| | | //暂时不考虑>1000的情况,因为搜索一般也不会出现搜索1000条的情况 |
| | | //return MybatisParameterUtil.convertToOrConditions(field, Func.toStrList(value.replace("IN//",""))); |
| | | return MybatisParameterUtil.getInClause(Func.toStrList(value.replace("IN//",""))); |
| | | }else{ |
| | | return "'" + value + "'"; |
| | | } |
| | | return "'" + value + "'"; |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | }); |
| | | return mapDataGrid; |
| | | // List<String> selectFieldList = templateVO.getAttributes().stream().map(CodeClassifyTemplateAttrVO::getId).collect(Collectors.toList()); |
| | | // //参照让平台直接查询就行 |
| | | // List<String> finalSelectFieldList = selectFieldList; |
| | | // List<CodeClassifyTemplateAttrVO> referAttrVOs = templateVO.getAttributes().stream().filter( |
| | | // s -> StringUtils.isNotBlank(s.getReferbtmid()) |
| | | // && |
| | | // (finalSelectFieldList.size() ==0 || finalSelectFieldList.contains(s.getId().toLowerCase(Locale.ROOT))) |
| | | // ).collect(Collectors.toList()); |
| | | // if(!CollectionUtils.isEmpty(referAttrVOs)){ |
| | | // for (int i = 0; i < referAttrVOs.size(); i++) { |
| | | // selectFieldList.add(referAttrVOs.get(i).getId() + ".name"); |
| | | // } |
| | | // } |
| | | // //我们使用和业务类型的来查询 |
| | | // DataGrid<Map<String,String>> dataGrid = boService.queryGridByBo(btmTypeId, conditionMap, pageHelper, selectFieldList); |
| | | // //我们需要使用模板来转换 |
| | | // if(!CollectionUtils.isEmpty(dataGrid.getData())){ |
| | | // wrapperData(dataGrid.getData(),templateVO,finalSelectFieldList,false); |
| | | // } |
| | | // return dataGrid; |
| | | // List<String> selectFieldList = templateVO.getAttributes().stream().map(CodeClassifyTemplateAttrVO::getId).collect(Collectors.toList()); |
| | | // //参照让平台直接查询就行 |
| | | // List<String> finalSelectFieldList = selectFieldList; |
| | | // List<CodeClassifyTemplateAttrVO> referAttrVOs = templateVO.getAttributes().stream().filter( |
| | | // s -> StringUtils.isNotBlank(s.getReferbtmid()) |
| | | // && |
| | | // (finalSelectFieldList.size() ==0 || finalSelectFieldList.contains(s.getId().toLowerCase(Locale.ROOT))) |
| | | // ).collect(Collectors.toList()); |
| | | // if(!CollectionUtils.isEmpty(referAttrVOs)){ |
| | | // for (int i = 0; i < referAttrVOs.size(); i++) { |
| | | // selectFieldList.add(referAttrVOs.get(i).getId() + ".name"); |
| | | // } |
| | | // } |
| | | // //我们使用和业务类型的来查询 |
| | | // DataGrid<Map<String,String>> dataGrid = boService.queryGridByBo(btmTypeId, conditionMap, pageHelper, selectFieldList); |
| | | // //我们需要使用模板来转换 |
| | | // if(!CollectionUtils.isEmpty(dataGrid.getData())){ |
| | | // wrapperData(dataGrid.getData(),templateVO,finalSelectFieldList,false); |
| | | // } |
| | | // return dataGrid; |
| | | } |
| | | |
| | | /** |
| | |
| | | cbos.add(data); |
| | | }); |
| | | |
| | | // List<ClientBusinessObject> cbos = boService.queryByOnlySql(sqlBO.getSqlUnPage()); |
| | | // List<ClientBusinessObject> cbos = boService.queryByOnlySql(sqlBO.getSqlUnPage()); |
| | | if (CollectionUtils.isEmpty(cbos)) { |
| | | throw new VciBaseException("数据在系统中不存在,是否因为修改过业务类型?"); |
| | | return R.fail("数据在系统中不存在,是否因为修改过业务类型?"); |
| | | } |
| | | // Map<String, String> data = new HashMap<>(); |
| | | // Map<String, String> data = new HashMap<>(); |
| | | Map<String, String> cbo = cbos.get(0); |
| | | // WebUtil.copyValueToMapFromCbos(cbo, data); |
| | | // WebUtil.copyValueToMapFromCbos(cbo, data); |
| | | List<Map<String, String>> dataList = new ArrayList<>(); |
| | | dataList.add(cbo); |
| | | wrapperData(dataList, templateVO, sqlBO.getSelectFieldList(), true); |
| | | R<List<Map<String, String>>> result = R.data(Collections.singletonList(cbo)); |
| | | if(templateVO.getAttributes().isEmpty()){ |
| | | throw new ServiceException(String.format("主键为:{}的模板下,模板属性配置为空!",templateVO.getOid())); |
| | | return R.fail(String.format("主键为:%s的模板下,模板属性配置为空!",templateVO.getOid())); |
| | | } |
| | | //处理返回数据与模板数据配置的字段不一样问题 |
| | | templateVO.getAttributes().stream().forEach(e -> { |
| | |
| | | }); |
| | | |
| | | //我们要看是否不是升版的,升版的话,需要对比不相等的属性 |
| | | /* String copy = cbo.get("copyfromversion"); |
| | | // if (StringUtils.isBlank(copy)) { |
| | | // copy = cbo.getAttributeValue("copyfromversion"); |
| | | // } |
| | | if (StringUtils.isNotBlank(copy)) { |
| | | //说明有变更的内容 |
| | | /* String copy = cbo.get("copyfromversion"); |
| | | // if (StringUtils.isBlank(copy)) { |
| | | // copy = cbo.getAttributeValue("copyfromversion"); |
| | | // } |
| | | if (StringUtils.isNotBlank(copy)) { |
| | | //说明有变更的内容 |
| | | |
| | | CodeTemplateAttrSqlBO oldSqlBO = getSqlByTemplateVO(btmId, templateVO, WebUtil.getOidQuery(copy), new PageHelper(-1)); |
| | | //我们使用和业务类型的来查询 |
| | | // List<Map> cbos = commonsMapper.selectBySql(sqlBO.getSqlUnPage()); |
| | | List<Map> oldCbos = commonsMapper.selectBySql(oldSqlBO.getSqlUnPage()); |
| | | if (!CollectionUtils.isEmpty(oldCbos)) { |
| | | // Map<String, String> newData = new HashMap<>(); |
| | | // WebUtil.copyValueToMapFromCbos(cbo, newData); |
| | | Map<String, String> oldData = new HashMap<>(); |
| | | oldData = oldCbos.get(0); |
| | | Map<String, String> difFieldMap = new HashMap<>(); |
| | | Map<String, String> finalOldData = oldData; |
| | | cbo.forEach((key, value) -> { |
| | | // 这儿oldmap中的全是大写,而cbo中的全是小写所以会拿不到只,这儿直接处理成小写拿不到就用大写拿 |
| | | String oldValue = String.valueOf(finalOldData.getOrDefault(key.toUpperCase(Locale.ROOT), finalOldData.getOrDefault(key, ""))); |
| | | if (value == null || value == "null") { |
| | | value = ""; |
| | | } |
| | | if (oldValue == null || oldValue == "null") { |
| | | oldValue = ""; |
| | | } |
| | | if (!value.equalsIgnoreCase(oldValue)) { |
| | | difFieldMap.put(key, oldValue); |
| | | } |
| | | }); |
| | | List<Map<String, String>> difFieldList = new ArrayList<>(); |
| | | difFieldList.add(difFieldMap); |
| | | result.setData(difFieldList); |
| | | } |
| | | }*/ |
| | | CodeTemplateAttrSqlBO oldSqlBO = getSqlByTemplateVO(btmId, templateVO, WebUtil.getOidQuery(copy), new PageHelper(-1)); |
| | | //我们使用和业务类型的来查询 |
| | | // List<Map> cbos = commonsMapper.selectBySql(sqlBO.getSqlUnPage()); |
| | | List<Map> oldCbos = commonsMapper.selectBySql(oldSqlBO.getSqlUnPage()); |
| | | if (!CollectionUtils.isEmpty(oldCbos)) { |
| | | // Map<String, String> newData = new HashMap<>(); |
| | | // WebUtil.copyValueToMapFromCbos(cbo, newData); |
| | | Map<String, String> oldData = new HashMap<>(); |
| | | oldData = oldCbos.get(0); |
| | | Map<String, String> difFieldMap = new HashMap<>(); |
| | | Map<String, String> finalOldData = oldData; |
| | | cbo.forEach((key, value) -> { |
| | | // 这儿oldmap中的全是大写,而cbo中的全是小写所以会拿不到只,这儿直接处理成小写拿不到就用大写拿 |
| | | String oldValue = String.valueOf(finalOldData.getOrDefault(key.toUpperCase(Locale.ROOT), finalOldData.getOrDefault(key, ""))); |
| | | if (value == null || value == "null") { |
| | | value = ""; |
| | | } |
| | | if (oldValue == null || oldValue == "null") { |
| | | oldValue = ""; |
| | | } |
| | | if (!value.equalsIgnoreCase(oldValue)) { |
| | | difFieldMap.put(key, oldValue); |
| | | } |
| | | }); |
| | | List<Map<String, String>> difFieldList = new ArrayList<>(); |
| | | difFieldList.add(difFieldMap); |
| | | result.setData(difFieldList); |
| | | } |
| | | }*/ |
| | | return result; |
| | | } |
| | | |
| | |
| | | if (cboMap.containsKey(oid)) { |
| | | CodeAllCode codeAllCode = cboMap.get(oid); |
| | | codeAllCode.setId(baseModel.getId()); |
| | | // codeAllCode.setLastModifier(AuthUtil.getUser().getUserName()); |
| | | codeAllCode.setLastModifier(AuthUtil.getUser().getAccount()); |
| | | // 主数据推送形式,是拿不到用户信息的 |
| | | codeAllCode.setLastModifier(Func.isBlank(AuthUtil.getUserAccount()) ? applyCodeUserAccount:AuthUtil.getUserAccount()); |
| | | codeAllCode.setLastModifyTime(new Date()); |
| | | codeAllCode.setLcStatus(baseModel.getLcStatus()); |
| | | newCodeAllCodeList.add(codeAllCode); |
| | |
| | | */ |
| | | Map<String, Object> nextRevision = commonsMapper.getCurrentRevision(listR.getData().get(0).getTableName(), fromBo.getNameOid()); |
| | | R<RevisionRuleVO> revisionRuleVOR = revisionRuleClient.selectById(listR.getData().get(0).getRevisionRuleId()); |
| | | String revisionval = nextRevision.get("REVISIONVAL").toString(); |
| | | String revisionval = ""; |
| | | try{ |
| | | revisionval = nextRevision.get("REVISIONVAL").toString(); |
| | | }catch (Exception e){ |
| | | throw new ServiceException("业务数据版次值获取出错,原因:" + e.getMessage()); |
| | | } |
| | | |
| | | // 未查询到版本规则,默认直接给大版本加一 |
| | | if (!revisionRuleVOR.isSuccess() || Func.isEmpty(revisionRuleVOR.getData())) { |
| | | revisionval = String.valueOf((Integer.parseInt(revisionval) + 1)); |