add api globalSetting

Helius

2022-03-24 e9fc4f4b843a4ecc4ea7a1b26f75dd844cbbcb7e

add api globalSetting

 lib/huobi-client-1.0.8-SNAPSHOT.jar

Binary files differ

 pom.xml

@@ -345,6 +345,15 @@
                </exclusion>
            </exclusions>
        </dependency>


        <dependency>
            <groupId>com.huobi.sdk</groupId>
            <artifactId>huobi-client</artifactId>
            <version>1.0.8-SNAPSHOT</version>
            <scope>system</scope>
            <systemPath>${basedir}/lib/huobi-client-1.0.8-SNAPSHOT.jar</systemPath>
        </dependency>
    </dependencies>

    <build>

 src/main/java/cc/mrbird/febs/common/contants/AppContants.java

@@ -98,4 +98,7 @@
     * 采矿

     */

    public static final int MONEY_TYPE_MINE = 3;



    public static final String REDIS_KEY_ETH_NEW_PRICE = "ETH_NEW_PRICE";

    public static final String REDIS_KEY_CHANGE_FEE = "DAPP_CHANGE_FEE";

}


 src/main/java/cc/mrbird/febs/dapp/controller/ApiCommonController.java

@@ -47,4 +47,10 @@
    public FebsResponse totalIncome() {
        return new FebsResponse().success().data(dappSystemService.findTotalInComeAndList());
    }

    @ApiOperation(value = "全局设置", notes = "全局设置")
    @GetMapping(value = "/globalSetting")
    public FebsResponse globalSetting() {
        return new FebsResponse().success().data(dappSystemService.globalSetting());
    }
}

 src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java

@@ -7,4 +7,6 @@
public interface DappSystemService {

    Map<String, Object> findTotalInComeAndList();

    Map<String, Object> globalSetting();
}

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java

@@ -1,5 +1,7 @@
package cc.mrbird.febs.dapp.service.impl;

import cc.mrbird.febs.common.contants.AppContants;
import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.dapp.entity.DappMineDataEntity;
import cc.mrbird.febs.dapp.mapper.DappSystemDao;
import cc.mrbird.febs.dapp.service.DappSystemService;
@@ -7,6 +9,7 @@
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -22,6 +25,7 @@
public class DappSystemServiceImpl implements DappSystemService {

    private final DappSystemDao dappSystemDao;
    private final RedisUtils redisUtils;

    @Override
    public Map<String, Object> findTotalInComeAndList() {
@@ -40,4 +44,15 @@
        result.put("userIncome", incomeList);
        return result;
    }

    @Override
    public Map<String, Object> globalSetting() {
        BigDecimal newPrice = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_ETH_NEW_PRICE);
        Integer changeFee = (Integer) redisUtils.get(AppContants.REDIS_KEY_CHANGE_FEE);

        Map<String, Object> result = new HashMap<>();
        result.put("newPrice", newPrice);
        result.put("changeFee", changeFee);
        return result;
    }
}

 src/main/java/cc/mrbird/febs/job/GiveMeMoneyJob.java

File was renamed from src/main/java/cc/mrbird/febs/Job/GiveMeMoneyJob.java
@@ -1,4 +1,4 @@
package cc.mrbird.febs.Job;
package cc.mrbird.febs.job;

import cc.mrbird.febs.common.contants.AppContants;
import cc.mrbird.febs.dapp.entity.DappAddressList;
@@ -6,7 +6,6 @@
import cn.hutool.core.collection.CollUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.tron.trident.core.ApiWrapper;
import org.tron.trident.core.contract.Contract;

 src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java

New file
@@ -0,0 +1,36 @@
package cc.mrbird.febs.job;

import cc.mrbird.febs.common.contants.AppContants;
import cc.mrbird.febs.common.utils.RedisUtils;
import com.huobi.client.SubscriptionClient;
import com.huobi.client.SubscriptionOptions;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;

/**
 * @author wzy
 * @date 2022-03-24
 **/
@Slf4j
@Component
public class NewPriceUpdateJob{

    @Autowired
    private RedisUtils redisUtils;

    @PostConstruct
    public void initNewPriceUpdate() {
        log.info("#最新价更新启动#");
        redisUtils.set(AppContants.REDIS_KEY_CHANGE_FEE, 30);
        SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
        subscriptionOptions.setConnectionDelayOnFailure(5);
        subscriptionOptions.setUri("wss://api.hadax.com/ws");
        SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
        subscriptionClient.subscribeTradeEvent("ethusdt", tradeEvent -> {
            redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, tradeEvent.getTradeList().get(0).getPrice());
        });
    }
}