lichunyang/beixin
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1、销售bi汇总销量销额增加工厂简称，维护经纬度

Browse Source
This commit is contained in:
llllon 2025-09-25 10:29:24 +08:00
parent d612cf8311
commit ca7fc95faa
3 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleCountDimensionImpl.class
View File

Binary file not shown.

BIN
com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/tmp/compileJava/previous-compilation-data.bin
View File

Binary file not shown.

16
com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleCountDimensionImpl.java
View File

@ -136,6 +136,19 @@ public class SaleCountDimensionImpl implements DataSummaryService {
LOGGER.error("应收账款-删除{}数据错误，删除sql为：{}，请检查数据库链接：{}", bkgs, deleteSql, e.getMessage());
throw e;
}
// 获取公司简称
List<RowMap> gsjcList = DBSql.getMaps("SELECT GSMC,JC FROM BO_EU_BNBM_ZZWHB");
Map<String, String> gsjcMap = gsjcList.stream()
.filter(row -> {
String gsmc = row.getString("GSMC");
String jc = row.getString("JC");
return gsmc != null && jc != null;
})
.collect(Collectors.toMap(
row -> row.getString("GSMC"),
row -> row.getString("JC"),
(existing, replacement) -> existing // 处理重复key
));
String sql = "SELECT t.RQ AS RQ,t.QYGS AS QYGS,t.XSZZ AS XSZZ,t.SHENGQU AS SHENGQU,t.SHIQU AS SHIQU," +
" t.QX AS QX,t.QCYE AS QCYE,t.LJXS AS LJXS,t.LJHK AS LJHK,t.YSYE AS YSYE," +
@ -224,6 +237,9 @@ public class SaleCountDimensionImpl implements DataSummaryService {
bo.set("ZL4_5", map.getDouble("ZLFX4_5"));
bo.set("ZL5", map.getDouble("ZLFX5"));
// bo.set("QYTQYSZK", map.getString("LAST_YEAR_YSYE"));
if (gsjcMap.containsKey(xszz)) {
bo.set("GCJC", gsjcMap.get(xszz));
}
bos.add(bo);
}