| | |
| | | package com.product.server.report.service; |
| | | |
| | | import cn.hutool.core.collection.CollectionUtil; |
| | | import cn.hutool.core.date.DateTime; |
| | | import cn.hutool.core.util.NumberUtil; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.google.common.collect.Lists; |
| | |
| | | import com.product.server.report.config.ReportCode; |
| | | import com.product.server.report.entity.ReportColumn; |
| | | import com.product.server.report.entity.ReportEntity; |
| | | import com.product.server.report.util.QuerySqlParseUtil; |
| | | import com.product.util.BaseUtil; |
| | | import com.product.util.SystemParamReplace; |
| | | import org.jsoup.Jsoup; |
| | | import org.jsoup.nodes.Document; |
| | | import org.jsoup.nodes.Element; |
| | | import org.jsoup.select.Elements; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | |
| | | private SystemDataExportService exportService; |
| | | |
| | | public void outReportExcel(HttpServletResponse response, FieldSetEntity fse) throws BaseException, IOException { |
| | | ReportEntity reportEntity = getReportEntity(fse); |
| | | ReportEntity reportEntity = getReport(fse); |
| | | List<List<ReportColumn>> reportHeader = reportEntity.getReportHeader(); |
| | | |
| | | List<List<String>> headerTemp = processingMergeData(reportHeader); |
| | |
| | | List<ReportColumn> columns = data.get(i); |
| | | for (ReportColumn column : columns) { |
| | | //跨行 |
| | | int rowspan = column.getRowspan() < 1 ? 1 : column.getRowspan(); |
| | | int rowspan = column.getRowspanInt() < 1 ? 1 : column.getRowspanInt(); |
| | | //跨列 |
| | | int colspan = column.getColspan() < 1 ? 1 : column.getColspan(); |
| | | int colspan = column.getColspanInt() < 1 ? 1 : column.getColspanInt(); |
| | | List<String> currentCell = new ArrayList<>(); |
| | | for (int k = 0; k < colspan; k++) { |
| | | currentCell.add(column.getContent(true)); |
| | |
| | | for (int j = 0; j < rowspan; j++) { |
| | | resultData.get(j + i).addAll(currentCell); |
| | | } |
| | | System.out.println(resultData); |
| | | } |
| | | } |
| | | return resultData; |
| | |
| | | } |
| | | |
| | | |
| | | /** |
| | | * @param target |
| | | * @param content |
| | | * @param colspan |
| | | * @param rowspan |
| | | * @param currentColspan |
| | | * @param currentRowsSpan |
| | | */ |
| | | private void rowspanAndColspan(String[][] target, String content, int colspan, int rowspan, int currentColspan, int currentRowsSpan) { |
| | | int k = currentColspan; |
| | | int i = currentRowsSpan; |
| | | if (colspan > 1) { |
| | | for (int j = 1; j < colspan; j++) { |
| | | int index = j + k; |
| | | while (target[i][index] != null) { |
| | | index++; |
| | | } |
| | | target[i][index] = content; |
| | | } |
| | | } |
| | | if (rowspan > 1) { |
| | | for (int j = 1; j < rowspan; j++) { |
| | | int index = i + k; |
| | | while (target[index][k] != null) { |
| | | index++; |
| | | } |
| | | target[index][k] = content; |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 加载所有缓存 |
| | |
| | | fieldConfigObj = new JSONObject(); |
| | | areaList.add(fieldConfigObj); |
| | | } else { |
| | | fieldConfigObj = areaList.get(areaList.size() - 1); |
| | | } |
| | | fieldConfigObj = areaList.get(areaList.size() - 1); |
| | | } |
| | | fieldConfigObj.put(attrFse.getString(CmnConst.ATTR_NAME), attrFse.getString(CmnConst.ATTR_VALUE)); |
| | | fieldConfigObj.put(CmnConst.ATTR_X, x); |
| | | fieldConfigObj.put(CmnConst.ATTR_Y, y); |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 获取报表 |
| | | * |
| | | * @return |
| | | */ |
| | | public ReportEntity getReportEntity(FieldSetEntity fse) { |
| | | ReportEntity report = null; |
| | | public ReportEntity getReport(FieldSetEntity fse) { |
| | | ReportEntity reportEntity = new ReportEntity(); |
| | | String reportConfigUUID = fse.getUUID(); |
| | | if (!StringUtils.isEmpty(fse.getString("~report_config_uuid~"))) { |
| | | //子报表会传入此key作为报表的uuid 规避参数中有uuid的key |
| | |
| | | FieldSetEntity reportSourceFse = reportSourceDte.getFieldSetEntity(0); |
| | | int curPage = fse.getInteger(CmnConst.CPAGE) == null ? 1 : fse.getInteger(CmnConst.CPAGE); |
| | | |
| | | JSONObject resultObj = new JSONObject(); |
| | | // JSONObject resultObj = new JSONObject(); |
| | | // 首次加载,默认添加条件 |
| | | Map<String, Map<String, String>> outerMap = Maps.newHashMap(); |
| | | if (fse.getBoolean(CmnConst.FIRST_LOAD)) { |
| | | DataTableEntity allFilterDte = getDefaultSearchFilter(reportSourceFse.getUUID()); |
| | | Map<String, DataTableEntity> subMap = Maps.newHashMap(); |
| | |
| | | DataTableEntity defaultFilterDte = new DataTableEntity(); |
| | | |
| | | FieldSetEntity tempFse; |
| | | |
| | | Map<String, Map<String, String>> outerMap = Maps.newHashMap(); |
| | | Map<String, String> innerMap; |
| | | for (int i = 0; i < allFilterDte.getRows(); i++) { |
| | | tempFse = allFilterDte.getFieldSetEntity(i); |
| | |
| | | outerMap.put(tempFse.getString(CmnConst.FIELD_NAME), innerMap); |
| | | } |
| | | // resultObj.put("filterInfo", outerMap); |
| | | |
| | | reportEntity.setFilterInfo(outerMap); |
| | | if (!DataTableEntity.isEmpty(defaultFilterDte)) { |
| | | subMap.put("systemSeniorQueryString", defaultFilterDte); |
| | | } |
| | | fse.setSubData(subMap); |
| | | } |
| | | |
| | | DataTableEntity recordDte = getRecordDte(sort, curPage, reportSourceFse, fse, reportConfigFse, null); |
| | | List<String> unpivotInfoContainer = Lists.newArrayList(); |
| | | DataTableEntity recordDte = getRecordDte(sort, curPage, reportSourceFse, fse, reportConfigFse, null, unpivotInfoContainer); |
| | | // 是否添加总合计 |
| | | boolean totalStatisticsFlag = "1".equalsIgnoreCase(reportConfigFse.getString(CmnConst.LAST_TOTAL)); |
| | | String totalName = totalStatisticsFlag ? (StringUtils.isEmpty(reportConfigFse.getString(CmnConst.TOTAL_NAME)) ? "总计" : reportConfigFse.getString(CmnConst.TOTAL_NAME)) : ""; |
| | | |
| | | // JSONObject checkObj = checkRecordDte(recordDte); |
| | | // if (CmnConst.FALSE.equals(checkObj.getString(CmnConst.RETURN_ATTR_RESULT))) { |
| | | // return checkObj; |
| | | // } |
| | | |
| | | // StringBuilder tableStyle = new StringBuilder(32); |
| | | // String widthType = reportConfigFse.getString(CmnConst.REPORT_WIDTH_TYPE); |
| | |
| | | // tableStyle.append(" style=\"width:").append(width).append("px\""); |
| | | // } |
| | | // } |
| | | |
| | | List<List<ReportColumn>>[] report = null; |
| | | if (CmnConst.REPORT_TYPE_COMMON.equals(reportType)) { |
| | | report = commonReportService.getReportEntity(recordDte, totalName, reportConfigMap); |
| | | report.setFilterInfo(outerMap); |
| | | report = commonReportService.getReport(recordDte, totalName, reportConfigMap, unpivotInfoContainer); |
| | | |
| | | } else if (CmnConst.REPORT_TYPE_GROUP.equals(reportType)) { |
| | | // 特殊处理额外查询内容 |
| | | recordDte.addFieldSetEntity(getRecordDte(sort, curPage, reportSourceFse, fse, reportConfigFse, reportConfigMap)); |
| | | report = groupReportService.getReportEntity(recordDte, totalName, reportConfigMap); |
| | | // resultObj.putAll(groupReportService.getReport(recordDte, totalName, reportConfigMap, tableStyle)); |
| | | recordDte.addFieldSetEntity(getRecordDte(sort, curPage, reportSourceFse, fse, reportConfigFse, reportConfigMap, null)); |
| | | report = groupReportService.getReport(recordDte, totalName, reportConfigMap); |
| | | } |
| | | report.setReportConfigUid(reportConfigFse.getUUID()); |
| | | report.setReportName(reportConfigFse.getString(CmnConst.REPORT_NAME)); |
| | | // report.setFilterInfo(outerMap); |
| | | if (CmnConst.FALSE.equals(resultObj.getString(CmnConst.RETURN_ATTR_RESULT))) { |
| | | resultObj.put(CmnConst.RETURN_ATTR_RESULT, true); |
| | | resultObj.put(CmnConst.RETURN_ATTR_MESSAGE, "获取报表失败!"); |
| | | if (report != null) { |
| | | List<List<ReportColumn>> head = report[0]; |
| | | List<List<ReportColumn>> data = report[1]; |
| | | List<List<ReportColumn>> tail = report[2]; |
| | | reportEntity.setReportHeader(head); |
| | | reportEntity.setReportData(data); |
| | | reportEntity.setReportTail(tail); |
| | | } |
| | | |
| | | |
| | | reportEntity.setReportConfigUid(reportConfigFse.getUUID()); |
| | | reportEntity.setReportName(reportConfigFse.getString(CmnConst.REPORT_NAME)); |
| | | |
| | | // 分页参数 |
| | | SQLEntity sqlEntity = recordDte.getSqle(); |
| | | if ("1".equals(reportConfigFse.getString(CmnConst.IS_PAGE)) && sqlEntity != null) { |
| | | reportEntity.setPage(true); |
| | | reportEntity.setPageIndex(curPage); |
| | | reportEntity.setTotalCount(sqlEntity.getTotalCount()); |
| | | reportEntity.setPageSize(StringUtils.isEmpty(reportConfigFse.getString(CmnConst.PAGE_SIZE)) ? 0 : reportConfigFse.getInteger(CmnConst.PAGE_SIZE)); |
| | | } else { |
| | | // 分页参数 |
| | | SQLEntity sqlEntity = recordDte.getSqle(); |
| | | if ("1".equals(reportConfigFse.getString(CmnConst.IS_PAGE)) && sqlEntity != null) { |
| | | report.setPage(true); |
| | | report.setTotalCount(sqlEntity.getTotalCount()); |
| | | report.setPageSize(StringUtils.isEmpty(reportConfigFse.getString(CmnConst.PAGE_SIZE)) ? 0 : reportConfigFse.getInteger(CmnConst.PAGE_SIZE)); |
| | | report.setPageIndex(curPage); |
| | | // resultObj.put(CmnConst.IS_PAGE, 1); |
| | | // resultObj.put(CmnConst.CPAGE, curPage); |
| | | // resultObj.put("totalCount", sqlEntity.getTotalCount()); |
| | | // resultObj.put("totalpage", sqlEntity.getTotalpage()); |
| | | // resultObj.put("pagesize", StringUtils.isEmpty(reportConfigFse.getString(CmnConst.PAGE_SIZE)) ? 0 : reportConfigFse.getInteger(CmnConst.PAGE_SIZE)); |
| | | } |
| | | reportEntity.setPage(false); |
| | | } |
| | | // if (!DataTableEntity.isEmpty(recordDte)) { |
| | | // resultObj.put("current_page_count", recordDte.getRows()); |
| | | // |
| | | // } |
| | | report.setSystemFieldMeta(getSearchInfo(reportSourceFse.getUUID())); |
| | | report.setReportType(reportConfigFse.getString("type_uuid")); |
| | | // resultObj.put("systemFieldMeta", ); |
| | | // resultObj.put("report_type", reportConfigFse.getString("type_uuid")); |
| | | // System.out.println(resultObj.getString("html")); |
| | | |
| | | return report; |
| | | reportEntity.setReportType(reportConfigFse.getString("type_uuid")); |
| | | reportEntity.setSystemFieldMeta(getSearchInfo(reportSourceFse.getUUID())); |
| | | return reportEntity; |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 获取报表缓存信息 |
| | |
| | | * @param reportConfigFse |
| | | * @return |
| | | */ |
| | | private DataTableEntity getRecordDte(StringBuilder sort, int curPage, FieldSetEntity |
| | | reportSourceFse, FieldSetEntity fse, FieldSetEntity |
| | | reportConfigFse, Map<Integer, List<JSONObject>> reportConfigMap) { |
| | | private DataTableEntity getRecordDte(StringBuilder sort, int curPage, FieldSetEntity reportSourceFse, FieldSetEntity fse, FieldSetEntity reportConfigFse, Map<Integer, List<JSONObject>> reportConfigMap, Collection<String> unpivotInfoContainer) { |
| | | boolean spTimeFlag = reportConfigMap != null; |
| | | String sql; |
| | | String sqlText = reportSourceFse.getString(CmnConst.SQL_TEXT); |
| | | Map<String, List<String>> queryFilterMap = queryFilterService.getQueryFilterMore(fse); |
| | | // [=table_name=]写法处理——替换为对应的with语句,0-近期,1-所有 |
| | | int year = queryFilterMap == null || queryFilterMap.get("query_time") == null || "0".equals(queryFilterMap.get("query_time").get(0)) ? 2 : 0; |
| | | sqlText = QuerySqlParseUtil.parseSplitTableSql(baseDao, sqlText, year); |
| | | // {==}写法处理-替换为对应的行列转换语句 |
| | | sqlText = dealUnpivot(sqlText, queryFilterMap, unpivotInfoContainer); |
| | | |
| | | DataTableEntity recordDte = new DataTableEntity(); |
| | | |
| | | if (spTimeFlag) { |
| | |
| | | Set<String> spTimeStatisticsTypeSet = Sets.newHashSet(); |
| | | spTimeStatisticsTypeSet.addAll(getFieldAndSpTimeStatisticsTypeSet(baseFieldSet, spTimeStatisticsFieldMap, reportConfigMap.get(0))); |
| | | spTimeStatisticsTypeSet.addAll(getFieldAndSpTimeStatisticsTypeSet(baseFieldSet, spTimeStatisticsFieldMap, reportConfigMap.get(2))); |
| | | Map<String, List<String>> queryFilterMap = queryFilterService.getQueryFilterMore(fse); |
| | | Set<String> selectedFieldSet; |
| | | String headContent; |
| | | DataTableEntity tempDte; |
| | |
| | | } |
| | | |
| | | /** |
| | | * 子方法-处理行列转换的语句 |
| | | * |
| | | * @param sql 待处理的sql |
| | | * @param queryFilterMap 过滤条件map |
| | | * @param unpivotInfoContainer 行列转换容器,该方法会将处理好了的内容直接放入该容器中 |
| | | * @return |
| | | */ |
| | | private String dealUnpivot(String sql, Map<String, List<String>> queryFilterMap, Collection<String> unpivotInfoContainer) { |
| | | String regexp = "\\{=.+=\\}"; |
| | | List<String> suitList = getSuitContent(sql, regexp); |
| | | String tempStr; |
| | | List<String> fieldInfoList; |
| | | String[] fieldArr; |
| | | String filter; |
| | | String startTimeStr; |
| | | String finalTimeStr; |
| | | int beginIndex; |
| | | SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); |
| | | List<String> timeList; |
| | | for (String content : suitList) { |
| | | tempStr = content.substring(2, content.length() - 2).trim(); |
| | | fieldInfoList = getSuitContent(tempStr, "\\{\\$((?!\\{\\$).)+\\$\\}"); |
| | | for (String fieldInfo : fieldInfoList) { |
| | | fieldArr = fieldInfo.substring(2, fieldInfo.length() - 2).trim().split(" "); |
| | | if (fieldArr.length != 3) { |
| | | continue; |
| | | } |
| | | if ("date".equalsIgnoreCase(fieldArr[1])) { |
| | | if (queryFilterMap == null || queryFilterMap.isEmpty()) { |
| | | return sql.replaceAll(regexp, ""); |
| | | } |
| | | filter = queryFilterMap.get(fieldArr[0]).get(0); |
| | | beginIndex = filter.indexOf("str_to_date('") + "str_to_date('".length(); |
| | | startTimeStr = filter.substring(beginIndex, beginIndex + 19); |
| | | beginIndex = filter.lastIndexOf("str_to_date('") + "str_to_date('".length(); |
| | | finalTimeStr = filter.substring(beginIndex, beginIndex + 19); |
| | | try { |
| | | timeList = enumTime(dateFormat.parse(startTimeStr), dateFormat.parse(finalTimeStr), fieldArr[2]); |
| | | } catch (Exception e) { |
| | | SpringMVCContextHolder.getSystemLogger().error("transfer error: " + filter); |
| | | timeList = Lists.newArrayList(); |
| | | } |
| | | unpivotInfoContainer.addAll(timeList); |
| | | tempStr = joinSql(timeList, tempStr, fieldInfo); |
| | | } else if ("prompt".equalsIgnoreCase(fieldArr[1])) { |
| | | String promptName = fieldArr[2]; |
| | | DataTableEntity dte; |
| | | StringBuilder promptSql = new StringBuilder(); |
| | | FieldSetEntity fse; |
| | | if (promptName.startsWith("《")) { |
| | | promptSql.append("select dict_label show_value,dict_value real_value from product_sys_dict where is_used=1 and dict_name=?"); |
| | | if (queryFilterMap != null && !queryFilterMap.isEmpty() && queryFilterMap.get(fieldArr[0]) != null && !StringUtils.isEmpty(queryFilterMap.get(fieldArr[0]).get(1))) { |
| | | promptSql.append(" and (dict_value").append(queryFilterMap.get(fieldArr[0]).get(1)).append(")"); |
| | | } |
| | | dte = baseDao.listTable(promptSql.toString(), new Object[]{promptName.substring(1, promptName.length() - 1)}); |
| | | } else { |
| | | fse = baseDao.getFieldSetEntityByFilter("product_sys_prompt", "prompt_name=?", new Object[]{promptName}, false); |
| | | promptSql.append("select ").append(fse.getString("view_fields")).append(" show_value,").append(fse.getString("value_field")).append(" real_value from ").append(fse.getString("source_table")); |
| | | if (!StringUtils.isEmpty(fse.getString("filter"))) { |
| | | promptSql.append(" where (").append(fse.getString("filter")).append(")"); |
| | | } |
| | | if (queryFilterMap != null && !queryFilterMap.isEmpty() && queryFilterMap.get(fieldArr[0]) != null && !StringUtils.isEmpty(queryFilterMap.get(fieldArr[0]).get(1))) { |
| | | if (!StringUtils.isEmpty(fse.getString("filter"))) { |
| | | promptSql.append(" and"); |
| | | } else { |
| | | promptSql.append(" where"); |
| | | } |
| | | promptSql.append(" (").append(fse.getString("value_field")).append(queryFilterMap.get(fieldArr[0]).get(1)).append(")"); |
| | | } |
| | | dte = baseDao.listTable(promptSql.toString(), new Object[]{}); |
| | | } |
| | | for (int i = 0; i < dte.getRows(); i++) { |
| | | fse = dte.getFieldSetEntity(i); |
| | | unpivotInfoContainer.add(fse.getString("show_value")); |
| | | } |
| | | tempStr = joinSql(dte, tempStr, fieldInfo); |
| | | } |
| | | } |
| | | sql = sql.replace(content, tempStr.contains("{$") ? "" : tempStr); |
| | | } |
| | | return sql; |
| | | } |
| | | |
| | | private String joinSql(Collection<String> collection, String unpivotContent, String fieldInfo) { |
| | | StringBuilder unpivotSb = new StringBuilder(128); |
| | | for (String singleStr : collection) { |
| | | if (unpivotSb.length() > 0) { |
| | | unpivotSb.append("\n "); |
| | | } |
| | | unpivotSb.append(unpivotContent.replace(fieldInfo, singleStr)).append(" '").append(singleStr).append("'"); |
| | | } |
| | | return unpivotSb.toString(); |
| | | } |
| | | |
| | | private String joinSql(DataTableEntity dte, String unpivotContent, String fieldInfo) { |
| | | StringBuilder unpivotSb = new StringBuilder(128); |
| | | for (int i = 0; i < dte.getRows(); i++) { |
| | | FieldSetEntity fse = dte.getFieldSetEntity(i); |
| | | if (unpivotSb.length() > 0) { |
| | | unpivotSb.append("\n "); |
| | | } |
| | | unpivotSb.append(unpivotContent.replace(fieldInfo, fse.getString("real_value"))).append(" '").append(fse.getString("show_value")).append("'"); |
| | | } |
| | | return unpivotSb.toString(); |
| | | } |
| | | |
| | | /** |
| | | * 按照时间步长枚举时间范围之内的时间 |
| | | * |
| | | * @param startTime |
| | | * @param finalTime |
| | | * @param formatInfo |
| | | * @return |
| | | */ |
| | | public static List<String> enumTime(Date startTime, Date finalTime, String formatInfo) { |
| | | Calendar c1 = Calendar.getInstance(); |
| | | Calendar c2 = Calendar.getInstance(); |
| | | c1.setTime(startTime); |
| | | c2.setTime(finalTime); |
| | | int step = 1; |
| | | String format = formatInfo; |
| | | if (formatInfo.contains("[")) { |
| | | step = Integer.parseInt(formatInfo.substring(formatInfo.indexOf("[") + 1, formatInfo.indexOf("]"))); |
| | | format = formatInfo.substring(0, formatInfo.indexOf("[")); |
| | | } |
| | | SimpleDateFormat dateFormat = new SimpleDateFormat(format); |
| | | List<String> timeList = Lists.newArrayList(); |
| | | if (formatInfo.contains("H")) { |
| | | enumTime(c1, c2, timeList, dateFormat, step, Calendar.HOUR); |
| | | } else if (formatInfo.contains("d")) { |
| | | enumTime(c1, c2, timeList, dateFormat, step, Calendar.DATE); |
| | | } else if (formatInfo.contains("M")) { |
| | | enumTime(c1, c2, timeList, dateFormat, step, Calendar.MONTH); |
| | | } else if (formatInfo.contains("y")) { |
| | | enumTime(c1, c2, timeList, dateFormat, step, Calendar.YEAR); |
| | | } |
| | | return timeList; |
| | | } |
| | | |
| | | private static void enumTime(Calendar c1, Calendar c2, List<String> timeList, SimpleDateFormat dateFormat, int step, int param) { |
| | | if (c1.compareTo(c2) <= 0) { |
| | | timeList.add(dateFormat.format(c1.getTime())); |
| | | c1.add(param, step); |
| | | enumTime(c1, c2, timeList, dateFormat, step, param); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 子方法-getRecordDte-加载参照 |
| | | * |
| | | * @param recordDte |
| | |
| | | * @param sort |
| | | * @return |
| | | */ |
| | | private String replaceSqlContent(String sqlText, FieldSetEntity fse, StringBuilder sort, FieldSetEntity |
| | | reportConfigFse, int curPage, String selectedFields, Map<String, List<String>> queryFilterMap) { |
| | | private String replaceSqlContent(String sqlText, FieldSetEntity fse, StringBuilder sort, FieldSetEntity reportConfigFse, int curPage, String selectedFields, Map<String, List<String>> queryFilterMap) { |
| | | queryFilterMap = queryFilterMap == null ? queryFilterService.getQueryFilterMore(fse) : queryFilterMap; |
| | | // 处理掉近期和所有的过滤条件 |
| | | queryFilterMap.remove("query_time"); |
| | | selectedFields = StringUtils.isEmpty(selectedFields) ? "*" : selectedFields; |
| | | // 替换sql中的系统参数 |
| | | sqlText = SystemParamReplace.replaceParams(sqlText, fse); |
| | |
| | | } |
| | | } |
| | | // 剔除异常区域 |
| | | sqlText = sqlText.replaceAll(CmnConst.REGEXP_FILTER_AREA, "").replaceAll(CmnConst.REGEXP_ALL_TYPE, "null").replaceAll(CmnConst.REGEXP_ALWAYS_TRUE, ""); |
| | | sqlText = sqlText.replaceAll(CmnConst.REGEXP_FILTER_AREA, "").replaceAll(CmnConst.REGEXP_ALL_TYPE, "null").replaceAll(CmnConst.REGEXP_ALWAYS_TRUE, "").replaceAll("(\\t*\\n){2,}", "\n"); |
| | | String queryFilter = ""; |
| | | if (signCount > 0) { |
| | | for (Map.Entry<String, List<String>> entry : residueQueryFilterMap.entrySet()) { |
| | |
| | | queryFilter += " (" + entry.getValue().get(2) + ") "; |
| | | } |
| | | } else { |
| | | queryFilter = queryFilterMap.isEmpty() ? queryFilterService.getQueryFilter(fse) : queryFilterMap.get(CmnConst.SYSTEM_SENIOR_QUERY_STRING).get(0); |
| | | queryFilter = queryFilterMap.isEmpty() || queryFilterMap.size() == 1 ? queryFilterService.getQueryFilter(fse) : queryFilterMap.get(CmnConst.SYSTEM_SENIOR_QUERY_STRING).get(0); |
| | | } |
| | | |
| | | StringBuilder sql = new StringBuilder(1024); |
| | |
| | | return sql.toString(); |
| | | } |
| | | |
| | | private String replaceSqlContent(String sqlText, FieldSetEntity fse, StringBuilder sort, FieldSetEntity |
| | | reportConfigFse, int curPage) { |
| | | private String replaceSqlContent(String sqlText, FieldSetEntity fse, StringBuilder sort, FieldSetEntity reportConfigFse, int curPage) { |
| | | return replaceSqlContent(sqlText, fse, sort, reportConfigFse, curPage, null, null); |
| | | } |
| | | |
| | |
| | | * @param queryFilterMap |
| | | * @return |
| | | */ |
| | | private String spReplaceSqlContent(String suitContent, String regexp, int num, Map< |
| | | String, List<String>> queryFilterMap, Map<String, List<String>> residueQueryFilterMap) { |
| | | private String spReplaceSqlContent(String suitContent, String regexp, int num, Map<String, List<String>> queryFilterMap, Map<String, List<String>> residueQueryFilterMap) { |
| | | List<String> innerSuitList = getSuitContent(suitContent, regexp); |
| | | String curField; |
| | | String filter; |
| | |
| | | // 上期 |
| | | spDealFilterForPrePeriod(tempQueryFilterMap, queryFilterMap, curField); |
| | | } |
| | | filter = tempQueryFilterMap.get(curField).get(num); |
| | | suitContent = suitContent.replace(innerSuitContent, filter); |
| | | } else if ("split".equals(spStatisticsWay)) { |
| | | // 只是拆分并提取区域的值,只有获取范围的值的时候可以这样操作 |
| | | List<String> paramList = tempQueryFilterMap.get(curField); |
| | | String[] timeArr = paramList.get(0).split("~"); |
| | | suitContent = suitContent.replace(innerSuitContent, timeArr[Integer.parseInt(spStatisticsWayValue)]); |
| | | } else { |
| | | filter = tempQueryFilterMap.get(curField).get(num); |
| | | suitContent = suitContent.replace(innerSuitContent, filter); |
| | | } |
| | | filter = tempQueryFilterMap.get(curField).get(num); |
| | | suitContent = suitContent.replace(innerSuitContent, filter); |
| | | residueQueryFilterMap.remove(curField); |
| | | if (getSuitContent(suitContent, CmnConst.REGEXP_ALL_TYPE).isEmpty() && suitContent.matches(CmnConst.REGEXP_FILTER_AREA)) { |
| | | suitContent = suitContent.substring(2, suitContent.length() - 2); |
| | |
| | | * @param queryFilterMap |
| | | * @param curFieldName |
| | | */ |
| | | private void spDealFilterForLastYear |
| | | (Map<String, List<String>> tempQueryFilterMap, Map<String, List<String>> queryFilterMap, String |
| | | curFieldName) { |
| | | private void spDealFilterForLastYear(Map<String, List<String>> tempQueryFilterMap, Map<String, List<String>> queryFilterMap, String curFieldName) { |
| | | List<String> paramList = tempQueryFilterMap.get(curFieldName); |
| | | for (int i = 0; i < paramList.size(); i++) { |
| | | paramList.set(i, paramList.get(i).replace("str_to_date(", "date_add(str_to_date(") |
| | |
| | | * @param queryFilterMap |
| | | * @param curFieldName |
| | | */ |
| | | private void spDealFilterForPrePeriod |
| | | (Map<String, List<String>> tempQueryFilterMap, Map<String, List<String>> queryFilterMap, String |
| | | curFieldName) { |
| | | private void spDealFilterForPrePeriod(Map<String, List<String>> tempQueryFilterMap, Map<String, List<String>> queryFilterMap, String curFieldName) { |
| | | List<String> paramList = tempQueryFilterMap.get(curFieldName); |
| | | String[] timeArr = paramList.get(0).split("~"); |
| | | try { |
| | |
| | | * @param dataList |
| | | * @return |
| | | */ |
| | | private Set<String> getFieldAndSpTimeStatisticsTypeSet |
| | | (Set<String> baseFieldSet, Map<String, Map<String, JSONObject>> spTimeStatisticsFieldMap, List<JSONObject> dataList) { |
| | | private Set<String> getFieldAndSpTimeStatisticsTypeSet(Set<String> baseFieldSet, Map<String, Map<String, JSONObject>> spTimeStatisticsFieldMap, List<JSONObject> dataList) { |
| | | Set<String> spTimeStatisticsTypeSet = Sets.newHashSet(); |
| | | JSONObject curFieldObj; |
| | | String fieldName; |
| | |
| | | tempObj.put("table_name", reportSourceFieldFse.getString(CmnConst.TABLE_NAME)); |
| | | tempObj.put(CmnConst.SEARCH_TYPE, reportSourceFieldFse.getObject(CmnConst.SEARCH_TYPE)); |
| | | tempObj.put("is_multiple", "2".equals(reportSourceFieldFse.getString(CmnConst.SEARCH_TYPE))); |
| | | tempObj.put("field_prompt_filter", reportSourceFieldFse.getString("field_prompt_filter")); |
| | | } |
| | | } |
| | | } |
| | |
| | | * @param locationType 位置类型,head-头部,tail-尾部 |
| | | * @return |
| | | */ |
| | | public StringBuilder getTitleHtml(List<JSONObject> list, int totalColCount, Map< |
| | | String, Set<String>> headAndTailTitleDataMap, String locationType) { |
| | | public List<List<ReportColumn>> getTitleRows(List<JSONObject> list, int totalColCount, Map<String, Set<String>> headAndTailTitleDataMap, String locationType) { |
| | | List<List<ReportColumn>> reportColumnList = new ArrayList<>(); |
| | | StringBuilder html = new StringBuilder(1024); |
| | | int colspan; |
| | | int preRow = 0; |
| | |
| | | int curRow; |
| | | int curCol; |
| | | String value; |
| | | String style; |
| | | for (JSONObject singleObj : list) { |
| | | curRow = singleObj.getIntValue(CmnConst.ATTR_Y); |
| | | curCol = singleObj.getIntValue(CmnConst.ATTR_X); |
| | |
| | | colspan = colspan < 0 ? totalColCount : Math.max(1, colspan); |
| | | value = replaceFormDataAndSysData(singleObj.getString(CmnConst.ATTR_SHOW_NAME), headAndTailTitleDataMap, singleObj); |
| | | value = value == null ? "" : value; |
| | | if ("1".equals(singleObj.getString(CmnConst.ATTR_IS_TITLE))) { |
| | | style = " class=\"" + CmnConst.CLASS_TR_REPORT_TITLE + "\""; |
| | | } else { |
| | | if ("head".equals(locationType)) { |
| | | style = " class=\"" + CmnConst.CLASS_TR_HEAD + "\""; |
| | | } else { |
| | | style = " class=\"" + CmnConst.CLASS_TR_TAIL + "\""; |
| | | } |
| | | } |
| | | if (preRow < curRow) { |
| | | if (preRow == 0) { |
| | | html.append("\n<tr "); |
| | |
| | | html.append(getAimNumTdPlaceholder(totalColCount - preCol, 1)); |
| | | html.append("\n</tr>\n<tr "); |
| | | } |
| | | html.append(style).append(">\n "); |
| | | html.append(">\n "); |
| | | if (preRow == 0 && preCol == 0 && preCol < curCol - 1) { |
| | | html.append(getAimNumTdPlaceholder(curCol - preCol - 1, 1)); |
| | | } |
| | |
| | | } |
| | | html.append(getAimNumTdPlaceholder(totalColCount - preCol, 1)); |
| | | html.append("\n</tr>"); |
| | | return html; |
| | | } |
| | | |
| | | /** |
| | | * 报表-解析-获取头部或者尾部标题Html |
| | | * |
| | | * @param list 报表配置信息,缓存list |
| | | * @param totalColCount 总列数 |
| | | * @param headAndTailTitleDataMap 头部、尾部标题区数据字段map |
| | | * @param locationType 位置类型,head-头部,tail-尾部 |
| | | * @return |
| | | */ |
| | | public List<List<ReportColumn>> getTitle(List<JSONObject> list, int totalColCount, Map< |
| | | String, Set<String>> headAndTailTitleDataMap, String locationType) { |
| | | List<List<ReportColumn>> row = new ArrayList<>(); |
| | | // StringBuilder html = new StringBuilder(1024); |
| | | int colspan; |
| | | int preRow = 0; |
| | | int preCol = 0; |
| | | int curRow; |
| | | int curCol; |
| | | String value; |
| | | // String style; |
| | | |
| | | List<ReportColumn> reportColumns = new ArrayList<>(); |
| | | for (JSONObject singleObj : list) { |
| | | curRow = singleObj.getIntValue(CmnConst.ATTR_Y); |
| | | curCol = singleObj.getIntValue(CmnConst.ATTR_X); |
| | | colspan = singleObj.getIntValue(CmnConst.ATTR_COLSPAN); |
| | | colspan = colspan < 0 ? totalColCount : Math.max(1, colspan); |
| | | value = replaceFormDataAndSysData(singleObj.getString(CmnConst.ATTR_SHOW_NAME), headAndTailTitleDataMap, singleObj); |
| | | value = value == null ? "" : value; |
| | | // if ("1".equals(singleObj.getString(CmnConst.ATTR_IS_TITLE))) { |
| | | // style = " class=\"" + CmnConst.CLASS_TR_REPORT_TITLE + "\""; |
| | | // } else { |
| | | // if ("head".equals(locationType)) { |
| | | // style = " class=\"" + CmnConst.CLASS_TR_HEAD + "\""; |
| | | // } else { |
| | | // style = " class=\"" + CmnConst.CLASS_TR_TAIL + "\""; |
| | | // } |
| | | // } |
| | | if (preRow < curRow) { |
| | | if(!reportColumns.isEmpty()){ |
| | | row.add(reportColumns); |
| | | reportColumns=new ArrayList<>(); |
| | | } |
| | | // if (preRow != 0) { |
| | | // row.add(getAimNumTdPlaceholderColumn(totalColCount - preCol, 1)); |
| | | // } |
| | | // if (preRow == 0 && preCol == 0 && preCol < curCol - 1) { |
| | | // row.add(getAimNumTdPlaceholderColumn(curCol - preCol - 1, 1)); |
| | | // } |
| | | preCol = curCol; |
| | | // 解析html |
| | | Document doc = Jsoup.parse(html.toString()); |
| | | Elements trs = doc.select("tr"); |
| | | Elements tds; |
| | | List<ReportColumn> reportColumn; |
| | | ReportColumn column; |
| | | for (Element tr : trs) { |
| | | tds = tr.select("td"); |
| | | reportColumn = new ArrayList<>(); |
| | | for (Element td : tds) { |
| | | column = new ReportColumn(); |
| | | column.setColspan(Integer.parseInt(BaseUtil.ifNull(td.attr("colspan"), "1"))); |
| | | column.setRowspan(Integer.parseInt(BaseUtil.ifNull(td.attr("rowspan"), "1"))); |
| | | column.setContent(td.text()); |
| | | reportColumn.add(column); |
| | | } |
| | | if (preCol < curCol - 1) { |
| | | row.add(getAimNumTdPlaceholderColumn(curCol - preCol - 1, 1)); |
| | | } |
| | | if ("1".equals(singleObj.getString(CmnConst.ATTR_IS_TITLE))) { |
| | | colspan = totalColCount; |
| | | } |
| | | ReportColumn column = new ReportColumn(); |
| | | column.setColspan(colspan); |
| | | column.setContent(value); |
| | | reportColumns.add(column); |
| | | preRow = curRow; |
| | | preCol = curCol + singleObj.getIntValue(CmnConst.ATTR_COLSPAN) - 1; |
| | | if ("1".equals(singleObj.getString(CmnConst.ATTR_IS_TITLE))) { |
| | | preCol = totalColCount; |
| | | } |
| | | reportColumnList.add(reportColumn); |
| | | } |
| | | row.add(reportColumns); |
| | | // reportColumns.addAll(getAimNumTdPlaceholderColumn(totalColCount - preCol, 1)); |
| | | // row.add(); |
| | | return row; |
| | | return reportColumnList; |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param lastStageFlag 是否末级(数据区分组字段末级和分组表头区字段都是末级才为末级) |
| | | * @return |
| | | */ |
| | | public JSONObject getStatisticsValueObj(JSONObject valueJsonObject, JSONObject dataAreaFieldConfigObj, String |
| | | actualValue, String type, boolean lastStageFlag) { |
| | | public JSONObject getStatisticsValueObj(JSONObject valueJsonObject, JSONObject dataAreaFieldConfigObj, String actualValue, String type, boolean lastStageFlag) { |
| | | if (valueJsonObject == null) { |
| | | valueJsonObject = new JSONObject(); |
| | | } |
| | |
| | | * @param set |
| | | * @param recordFse |
| | | */ |
| | | public void getHeadAndTailTitleDataMap |
| | | (Map<String, Set<String>> headAndTailTitleDataMap, Set<String> set, FieldSetEntity recordFse) { |
| | | public void getHeadAndTailTitleDataMap(Map<String, Set<String>> headAndTailTitleDataMap, Set<String> set, FieldSetEntity recordFse) { |
| | | for (String fieldName : set) { |
| | | headAndTailTitleDataMap.computeIfAbsent(fieldName, k -> Sets.newLinkedHashSet()).add(recordFse.getString(fieldName)); |
| | | } |
| | |
| | | return dealedValueSb.toString(); |
| | | } |
| | | |
| | | public int dealColumnWidth(JSONObject dataAreaFieldConfigObj) { |
| | | return NumberUtil.isNumber(dataAreaFieldConfigObj.getString(CmnConst.ATTR_WIDTH)) ? NumberUtil.parseInt(dataAreaFieldConfigObj.getString(CmnConst.ATTR_WIDTH)) : 0; |
| | | } |
| | | |
| | | /** |
| | | * 获取td的属性 |
| | | * |
| | |
| | | * @param singleObj |
| | | * @return |
| | | */ |
| | | public String replaceFormDataAndSysData(String |
| | | str, Map<String, Set<String>> headAndTailTitleDataMap, JSONObject singleObj) { |
| | | public String replaceFormDataAndSysData(String str, Map<String, Set<String>> headAndTailTitleDataMap, JSONObject singleObj) { |
| | | if (StringUtils.isEmpty(str)) { |
| | | return ""; |
| | | } |
| | |
| | | * @param num |
| | | * @return |
| | | */ |
| | | public List<ReportColumn> getAimNumTdPlaceholderColumn(int num, int type) { |
| | | List<ReportColumn> columns = new ArrayList<>(); |
| | | if (num <= 0) { |
| | | return columns; |
| | | } |
| | | if (type == 0) { |
| | | for (int i = 0; i < num; i++) { |
| | | columns.add(new ReportColumn()); |
| | | } |
| | | } else { |
| | | |
| | | ReportColumn column = new ReportColumn(); |
| | | column.setColspan(num); |
| | | columns.add(column); |
| | | } |
| | | return columns; |
| | | } |
| | | |
| | | /** |
| | | * 获取指定个数的td占位 |
| | | * |
| | | * @param num |
| | | * @return |
| | | */ |
| | | public String getAimNumTdPlaceholder(int num, int type) { |
| | | StringBuilder result = new StringBuilder(64); |
| | | if (num <= 0) { |
| | |
| | | * @param type 类型:1-获取目标属性,其他-排除目标属性 |
| | | * @return |
| | | */ |
| | | public JSONObject extendJSONObject(JSONObject aimObj, JSONObject sourceObj, Collection<String> aimAttr, |
| | | int type) { |
| | | public JSONObject extendJSONObject(JSONObject aimObj, JSONObject sourceObj, Collection<String> aimAttr, int type) { |
| | | if (aimObj == null) { |
| | | aimObj = new JSONObject(); |
| | | } |