| | |
|---|
| | | package org.example.task; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; |
|---|
| | | import com.fasterxml.jackson.core.type.TypeReference; |
|---|
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
|---|
| | |
|---|
| | | * 同步bitget交易所交易对 |
|---|
| | | */ |
|---|
| | | @Scheduled(cron = "0 0/45 * * * ?") |
|---|
| | | // @Scheduled(cron = "0/10 * * * * ?") |
|---|
| | | public void syncCurrency() { |
|---|
| | | // 使用Lock来确保同步 |
|---|
| | | syncCurrencyLock.lock(); |
|---|
| | |
|---|
| | | getList.parallelStream().forEach(person -> person.setSymbol(StringUtils.remove(person.getSymbol(), "-"))); |
|---|
| | | |
|---|
| | | // 获取数据库中已有的symbol列表 |
|---|
| | | List<Currency> dbList = currencyService.list(); |
|---|
| | | List<Currency> dbList = currencyService.list(new LambdaQueryWrapper<Currency>().eq(Currency::getSource,"bitget")); |
|---|
| | | Set<String> symbolSet = dbList.stream().map(Currency::getSymbol).collect(Collectors.toSet()); |
|---|
| | | |
|---|
| | | // 比对接口返回的数据和数据库中已有的数据，找出新增的数据 |
|---|
