modify

Helius

2021-06-03 72b7d6b5ac0e3e4804886382bcada61e7469e9d0

modify

 src/main/java/com/xcong/excoin/configurations/ScheduleConfig.java

New file
@@ -0,0 +1,18 @@
package com.xcong.excoin.configurations;


import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import java.util.concurrent.Executors;

@Configuration
public class ScheduleConfig implements SchedulingConfigurer {

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(Executors.newScheduledThreadPool(50));
    }
}

 src/main/java/com/xcong/excoin/rabbit/producer/UsdtUpdateProducer.java

@@ -26,12 +26,12 @@

    public void sendMsg(String content) {
        CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_USDT_UPDATE, RabbitMqConfig.ROUTING_KEY_USDT_UPDATE, content, correlationData);
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_XCH, RabbitMqConfig.ROUTING_KEY_USDT_UPDATE, content, correlationData);
    }

    public void sendAddressMsg(String content) {
        CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_USDT_ADDRESS, RabbitMqConfig.ROUTING_KEY_USDT_ADDRESS, content, correlationData);
        rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_XCH, RabbitMqConfig.ROUTING_KEY_USDT_ADDRESS, content, correlationData);
    }



 src/main/resources/application.yml

@@ -7,9 +7,9 @@
  profiles:
    active: dev
  datasource:
#    url: jdbc:mysql://rm-bp151tw8er79ig9kb5o.mysql.rds.aliyuncs.com:3306/db_biue?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
#    username: ctcoin_data
#    password: ctcoin_123
#    url: jdbc:mysql://124.70.222.34:3306/yunding?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
#    username: yunding
#    password: yunding123!@#
    url: jdbc:mysql://120.27.238.55:3306/yunding_test?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
    username: ct_test
    password: 123456

 src/test/java/com/xcong/excoin/XchTest.java

@@ -7,6 +7,7 @@
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.http.HttpRequest;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.xcong.excoin.modules.blackchain.service.TrxUsdtUpdateService;
import com.xcong.excoin.modules.coin.parameter.dto.CoinInListDto;
import com.xcong.excoin.modules.coin.service.CoinService;
import com.xcong.excoin.modules.yunding.dao.YdOrderDao;
@@ -175,4 +176,12 @@
    public void baseDataTest() {
        xchBaseDataUpdateJob.baseDataUpdate();
    }

    @Autowired
    private TrxUsdtUpdateService trxUsdtUpdateService;

    @Test
    public void trxTest() {
        trxUsdtUpdateService.monitorCoinListener(30747892L);
    }
}