tps峰值接口重新调整

src/main/java/com/wuban/tron/explore/Bootstrapper.java

@@ -75,6 +75,9 @@ public class Bootstrapper {
         // 抓取最新区块高度
         this.executorService.scheduleWithFixedDelay(() -> this.lastBlockService.refresh(), 0, 1, TimeUnit.SECONDS);
 
+        // 每秒交易tps峰值统计
+        //this.executorService.scheduleWithFixedDelay(() -> this.transactionService.transTpsCount(0,0), 5, 1, TimeUnit.SECONDS);
+
         // 统计前一天区块、交易数据
         this.executorService.scheduleWithFixedDelay(() -> this.transactionService.censusBlockByLastDay(), getInitialDelay(), 24 * 60 * 60, TimeUnit.SECONDS);
     }

src/main/java/com/wuban/tron/explore/constant/Constant.java

@@ -52,6 +52,11 @@ public class Constant {
     public static final String CENSUS_TRANS = "census_trans";
     public static final String CENSUS_BLOCK_SIZE = "census_block_size";
 
+    /**
+     * 交易tps峰值
+     */
+    public static final String TRANS_TPS_PEAK = "trans_tps_peak";
+
     /**
      * 数据同步阀值
      */

src/main/java/com/wuban/tron/explore/controller/v1/TransactionControllerV1.java

@@ -17,6 +17,7 @@ import com.wuban.tron.explore.util.ResponseKit;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -53,6 +54,8 @@ public class TransactionControllerV1 {
 
     private final CensusService censusService;
 
+    private final StringRedisTemplate stringRedisTemplate;
+
     /**
      * 首页 - 搜索
      *
@@ -550,14 +553,20 @@ public class TransactionControllerV1 {
         /*
             计算上一分钟交易tps
          */
-        TransactionExample example = new TransactionExample();
+        /*TransactionExample example = new TransactionExample();
         example.createCriteria().andTimestampBetween(millis, curMillis);
         List<Transaction> list = this.transactionService.getByExample(example);
         BigDecimal tps = new BigDecimal(0);
         if (!StringUtils.isEmpty(list)) {
             tps = BigDecimalUtil.getDevide(1, new BigDecimal(list.size()), new BigDecimal(60));
         }
-        censusModel.setTps(tps.toPlainString());
+        censusModel.setTps(tps.toPlainString());*/
+        String tpsPeakStr = this.stringRedisTemplate.opsForValue().get(Constant.TRANS_TPS_PEAK);
+        Integer tpsPeak = 0;
+        if (tpsPeakStr != null) {
+            tpsPeak = Integer.valueOf(tpsPeakStr);
+        }
+        censusModel.setTps(tpsPeak.toString());
 
         // 最新区块高度
         LastBlock lastBlock = this.lastBlockService.getOneByExample();

src/main/java/com/wuban/tron/explore/dao/TransactionRepository.java

@@ -70,4 +70,12 @@ public interface TransactionRepository {
      */
     List<Transaction> selectPageByAddress(@Param("address") String address);
 
+    /**
+     * 根据条件检索数据记录数
+     *
+     * @param example
+     * @return
+     */
+    int countByExample(@Param("example") TransactionExample example);
+
 }

src/main/java/com/wuban/tron/explore/fetch/Engine.java

@@ -127,10 +127,10 @@ public class Engine {
          /*
             合约事件数据抓取、处理
          */
-        /*this.contractEventHandler = new ContractEventHandler();
+        this.contractEventHandler = new ContractEventHandler();
         this.contractEventFetcher = new ContractEventFetcher<>(this.contractEventHandler);
         this.executor.execute(this.contractEventFetcher);
-        this.executor.execute(this.contractEventHandler);*/
+        this.executor.execute(this.contractEventHandler);
     }
 
 

src/main/java/com/wuban/tron/explore/service/TransactionService.java

@@ -90,5 +90,12 @@ public interface TransactionService {
      */
     PageInfo<Transaction> selectPageByAddress(@Param("address") String address, Integer startIndex, Integer pageSize);
 
+    /**
+     * 每秒交易tps峰值统计
+     *
+     * @param startTime 开始时间（毫秒）
+     * @param endTime   结束时间（毫秒）
+     */
+    void transTpsCount(long startTime, long endTime);
 
 }

src/main/java/com/wuban/tron/explore/service/impl/TransactionServiceImpl.java

@@ -456,6 +456,44 @@ public class TransactionServiceImpl implements TransactionService {
         return pageInfo;
     }
 
+    /**
+     * 每秒交易tps峰值统计
+     *
+     * @param startTime 开始时间（毫秒）
+     * @param endTime   结束时间（毫秒）
+     * @return
+     */
+    @Override
+    public void transTpsCount(long startTime, long endTime) {
+        if (startTime == 0L) {
+            /*String endDate = DateUtil.getFormatDate(new Date(), DateUtil.PATTERN_YMD_HMS);
+            Long endDateSeconds = DateUtil.getDateFromDateStr(endDate, DateUtil.PATTERN_YMD_HMS);
+            endTime = endDateSeconds;
+            startTime = endTime - 1 * 1000;*/
+            startTime = System.currentTimeMillis() - 20 * 1000;
+            endTime = startTime + 1000;
+        }
+
+        TransactionExample example = new TransactionExample();
+        example.createCriteria().andTimestampBetween(startTime, endTime);
+        int count = this.transactionRepository.countByExample(example);
+
+        /*
+            当前count - (redis：trans_tps_peak value) > 0 重新设置此值
+         */
+        if (count != 0) {
+            String tpsPeakStr = this.stringRedisTemplate.opsForValue().get(Constant.TRANS_TPS_PEAK);
+            int tpsPeak = 0;
+            if (tpsPeakStr != null) {
+                tpsPeak = Integer.valueOf(tpsPeakStr);
+            }
+
+            if (count - tpsPeak > 0) {
+                this.stringRedisTemplate.opsForValue().set(Constant.TRANS_TPS_PEAK, Integer.valueOf(count).toString());
+            }
+        }
+    }
+
     private void census(String date, String startDate, String endDate) {
         Long startDateSeconds = DateUtil.getDateFromDateStr(startDate, DateUtil.PATTERN_YMD_HMS);
         Long endDateSeconds =  DateUtil.getDateFromDateStr(endDate, DateUtil.PATTERN_YMD_HMS);