...
|
...
|
@@ -31,7 +31,7 @@ public class SellerOrderQuantityStatsProcessor implements StatsProcessor<SellerO |
|
|
|
|
|
@Override
|
|
|
public void accept(SellerOrderStatsEntry entry, SellerOrderStatsConfiguration configuration) {
|
|
|
logger.info("[{}] sellerOrderQuantityStatsProcessor accept entry:{},configuration:{}", entry.getSellerUid(), entry, configuration);
|
|
|
logger.info("[{}] sellerOrderQuantityStatsProcessor accept entry:{}", entry.getSellerUid(), entry);
|
|
|
|
|
|
Pair<Integer, Integer> timeTuple = configuration.getStatsUnit().nextPeriodTimeTuple(configuration.getStatsPeriod(), configuration.getStatsPeriod());
|
|
|
|
...
|
...
|
@@ -51,7 +51,7 @@ public class SellerOrderQuantityStatsProcessor implements StatsProcessor<SellerO |
|
|
|
|
|
@Override
|
|
|
public SellerPlatformServiceFee apply(SellerOrderStatsEntry entry, SellerOrderStatsConfiguration configuration) {
|
|
|
logger.info("[{}] sellerOrderQuantityStatsProcessor apply entry:{},configuration:{}", entry.getSellerUid(), entry, configuration);
|
|
|
logger.info("[{}] sellerOrderQuantityStatsProcessor apply entry:{}", entry.getSellerUid(), entry);
|
|
|
SellerOrderStatsResult result = sellerOrderStatsResultMapper.selectStatsResult(entry.getSellerUid(), configuration.getStatsCode(), entry.getTime());
|
|
|
int quantity = (result != null) ? result.getQuantity() : 0;
|
|
|
PlatformServiceFeeDefinition psfd = PlatformServiceFeeDefinition.convert(configuration.getActionParam());
|
...
|
...
|
|