Browse Source

完善

master
review512jwy@163.com 3 months ago
parent
commit
07b9aaddbd
  1. 10
      src/main/java/com/dashboard/aws/lambda/handler/AccumulateIncrementHandler.java
  2. 4
      src/main/java/com/dashboard/aws/lambda/service/AccumulateIncrementService.java

10
src/main/java/com/dashboard/aws/lambda/handler/AggregationHandler.java → src/main/java/com/dashboard/aws/lambda/handler/AccumulateIncrementHandler.java

@ -3,7 +3,7 @@ package com.dashboard.aws.lambda.handler;
import com.amazonaws.services.lambda.runtime.Context; import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler; import com.amazonaws.services.lambda.runtime.RequestHandler;
import com.dashboard.aws.lambda.entity.AggregationLevel; import com.dashboard.aws.lambda.entity.AggregationLevel;
import com.dashboard.aws.lambda.service.AggregationService; import com.dashboard.aws.lambda.service.AccumulateIncrementService;
import com.dashboard.aws.lambda.service.MySQLService; import com.dashboard.aws.lambda.service.MySQLService;
import com.dashboard.aws.lambda.util.DateUtil; import com.dashboard.aws.lambda.util.DateUtil;
import org.slf4j.Logger; import org.slf4j.Logger;
@ -14,10 +14,10 @@ import java.time.ZoneId;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
public class AggregationHandler implements RequestHandler<Map<String, Object>, String> { public class AccumulateIncrementHandler implements RequestHandler<Map<String, Object>, String> {
private static final Logger logger = LoggerFactory.getLogger(AggregationHandler.class); private static final Logger logger = LoggerFactory.getLogger(AccumulateIncrementHandler.class);
private final AggregationService aggregationService = new AggregationService(); private final AccumulateIncrementService accumulateIncrementService = new AccumulateIncrementService();
private final MySQLService mysqlService = new MySQLService(); private final MySQLService mysqlService = new MySQLService();
@Override @Override
@ -36,7 +36,7 @@ public class AggregationHandler implements RequestHandler<Map<String, Object>, S
for (Long companyId : companyIds) { for (Long companyId : companyIds) {
for (AggregationLevel level : levels) { for (AggregationLevel level : levels) {
logger.info("Start aggregation [company:{}, level:{}]", companyId, level); logger.info("Start aggregation [company:{}, level:{}]", companyId, level);
aggregationService.aggregate(companyId, level, now); accumulateIncrementService.aggregate(companyId, level, now);
} }
} }

4
src/main/java/com/dashboard/aws/lambda/service/AggregationService.java → src/main/java/com/dashboard/aws/lambda/service/AccumulateIncrementService.java

@ -10,9 +10,9 @@ import java.sql.PreparedStatement;
import java.sql.SQLException; import java.sql.SQLException;
import java.time.LocalDateTime; import java.time.LocalDateTime;
public class AggregationService { public class AccumulateIncrementService {
private static final Logger logger = LoggerFactory.getLogger(AggregationService.class); private static final Logger logger = LoggerFactory.getLogger(AccumulateIncrementService.class);
private static final String MYSQL_URL = System.getenv("DB_URL"); private static final String MYSQL_URL = System.getenv("DB_URL");
private static final String DB_USER = System.getenv("DB_USER"); private static final String DB_USER = System.getenv("DB_USER");
Loading…
Cancel
Save