diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSummaryServiceImpl.class b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSummaryServiceImpl.class index 5cc53d3..81a16ea 100644 Binary files a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSummaryServiceImpl.class and b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSummaryServiceImpl.class differ diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSyncServiceImpl.class b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSyncServiceImpl.class index f6b0894..7fd2bb1 100644 Binary files a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSyncServiceImpl.class and b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSyncServiceImpl.class differ diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.class b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.class index c1db3c5..af42ae5 100644 Binary files a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.class and b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/classes/java/main/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.class differ diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/tmp/compileJava/previous-compilation-data.bin b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/tmp/compileJava/previous-compilation-data.bin index 14acf18..37f0d35 100644 Binary files a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/tmp/compileJava/previous-compilation-data.bin and b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/build/tmp/compileJava/previous-compilation-data.bin differ diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSummaryServiceImpl.java b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSummaryServiceImpl.java index 2577ea1..bab198f 100644 --- a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSummaryServiceImpl.java +++ b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSummaryServiceImpl.java @@ -339,7 +339,7 @@ public class PurchaseDataSummaryServiceImpl implements DataSummaryService { " c.Year AS year, " + " c.Month AS month, " + " c.WLMC AS WLMC, " + - " c.SLGC AS SLGC,, " + + " c.SLGC AS SLGC, " + " c.tstotalAmount AS tstotalAmount, " + " c.totalQuantity AS totalQuantity, " + " tstotalAmount/totalQuantity AS PJDJ " + diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSyncServiceImpl.java b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSyncServiceImpl.java index 50852cd..dca3ea3 100644 --- a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSyncServiceImpl.java +++ b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/PurchaseDataSyncServiceImpl.java @@ -908,7 +908,8 @@ public class PurchaseDataSyncServiceImpl implements DataSyncService { double djhyfDou = djhyf1!=null?djhyf1:0.0; if (yfdjhs1!=0.0){ safeHsdjhyf+=yfdjhs1; - }else if (yfdjws1 != 0.0){ + } + if (yfdjws1 != 0.0){ djhyfDou+=yfdjws1; } BigDecimal multiply = BigDecimal.valueOf(safeRksl).multiply(BigDecimal.valueOf(safeHsdjhyf)); diff --git a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.java b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.java index 7ade690..d9c2142 100644 --- a/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.java +++ b/com.awspaas.user.apps.bnbm.datalinkup/com.awspaas.user.apps.bnbm.datalinkup/src/main/java/com/awspaas/user/apps/bnbm/datalinkup/service/impl/SaleDataSyncServiceImpl.java @@ -894,25 +894,23 @@ public class SaleDataSyncServiceImpl implements DataSyncService { try { do { // 构建查询每月最大日期的SQL - String maxDateSubQuery = "SELECT MAX(DATE(" + targetTimeField + ")) as max_date " + - "FROM " + targetTable + - " WHERE DATE_FORMAT(" + targetTimeField + ", '%Y-%m') = " + - "DATE_FORMAT(t." + targetTimeField + ", '%Y-%m')"; - if (startDated == null || endDated == null) { - pageSql = "SELECT t.* FROM " + targetTable + " t " + - "WHERE DATE(t." + targetTimeField + ") = (" + maxDateSubQuery + ") " + - "ORDER BY t.ID LIMIT " + PAGE_SIZE + " OFFSET " + (pageNo - 1) * PAGE_SIZE; - pageData = DBSql.getMaps(pageSql); - } else { + String maxDateSubQuery = "SELECT MAX(DATE(" + targetTimeField + ")) as max_date, " + + "DATE_FORMAT(" + targetTimeField + ", '%Y-%m') as month " + + "FROM " + targetTable; + // 根据是否传入时间范围添加条件 + if (startDated != null && endDated != null) { startDate = simpleDateFormat.format(startDated); endDate = simpleDateFormat.format(endDated); - pageSql = "SELECT t.* FROM " + targetTable + " t " + - "WHERE t." + targetTimeField + " BETWEEN '" + startDate + "' AND '" + endDate + "' " + - "AND DATE(t." + targetTimeField + ") = (" + maxDateSubQuery + ") " + - "ORDER BY t.ID LIMIT " + PAGE_SIZE + " OFFSET " + (pageNo - 1) * PAGE_SIZE; - LOGGER.info("执行查询的sql:{}", pageSql); - pageData = DBSql.getMaps(pageSql); + maxDateSubQuery += " WHERE " + targetTimeField + " BETWEEN '" + startDate + "' AND '" + endDate + "'"; } + maxDateSubQuery += " GROUP BY DATE_FORMAT(" + targetTimeField + ", '%Y-%m')"; + // 主查询:通过连接查询获取每月最大日期的全部数据 + pageSql = "SELECT t.* FROM " + targetTable + " t " + + "INNER JOIN (" + maxDateSubQuery + ") tmp " + + "ON DATE(t." + targetTimeField + ") = tmp.max_date " + + "ORDER BY t.ID LIMIT " + PAGE_SIZE + " OFFSET " + (pageNo - 1) * PAGE_SIZE; + + pageData = DBSql.getMaps(pageSql); if (pageData.isEmpty()) break; @@ -1005,7 +1003,7 @@ public class SaleDataSyncServiceImpl implements DataSyncService { LocalDate now = LocalDate.now(); int dayOfMonth = now.getDayOfMonth(); - if (dayOfMonth == 1) { +// if (dayOfMonth == 1) { try { LOGGER.info("开始执行每月1号的特殊数据处理任务"); @@ -1049,7 +1047,7 @@ public class SaleDataSyncServiceImpl implements DataSyncService { } catch (Exception e) { LOGGER.error("每月1号任务执行失败: {}", e.getMessage(), e); } - } +// } }catch (Exception e){ LOGGER.error("汇总数据失败 [汇总表={}, 第几页={}]: {}", hzb, PAGE_SIZE, e.getMessage(), e);