ScheduledTask.java 文件源码

@Scheduled(fixedRate = 60000, initialDelay=15000)
    public void insertCoinbaseQuote() {
        Date start = new Date();
        WebClient wc = buildWebClient(URLCB);
        try {
            operations.insert(
                    wc.get().uri("/exchange-rates?currency=BTC")
                    .accept(MediaType.APPLICATION_JSON).exchange()
                    .flatMap(response ->    response.bodyToMono(WrapperCb.class))
                    .flatMap(resp -> Mono.just(resp.getData()))
                    .flatMap(resp2 -> {log.info(resp2.getRates().toString()); return Mono.just(resp2.getRates());})
                    ).then().block(Duration.ofSeconds(3));
            log.info("CoinbaseQuote " + dateFormat.format(new Date()) + " " + (new Date().getTime()-start.getTime()) + "ms");
        } catch (Exception e) {
//          log.error("Coinbase insert error", e);
            log.error("Coinbase insert error "+ dateFormat.format(new Date()));
        }
    }