From 0b4c87807860c0bfff0759a5cdc736c80e5f5772 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Thu, 25 Sep 2025 15:50:48 +0800
Subject: [PATCH] 1

---
 trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java |  110 ++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 105 insertions(+), 5 deletions(-)

diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java b/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
index 8820c3e..1332448 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
@@ -3,22 +3,44 @@
 
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DateTime;
+import cn.hutool.core.lang.Console;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.http.HttpStatus;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.yami.trading.api.UD.*;
 import com.yami.trading.bean.ico.domain.Ico;
 import com.yami.trading.bean.item.domain.Item;
-import com.yami.trading.common.util.ApplicationContextUtils;
+import com.yami.trading.bean.model.ChannelBlockchain;
+import com.yami.trading.bean.model.User;
+import com.yami.trading.bean.model.Withdraw;
+import com.yami.trading.common.domain.Result;
+import com.yami.trading.common.util.*;
 import com.yami.trading.huobi.data.internal.KlineInitService;
+import com.yami.trading.security.common.enums.CryptoCurrencyEnum;
+import com.yami.trading.security.common.enums.SysTypeEnum;
+import com.yami.trading.security.common.manager.PasswordCheckManager;
+import com.yami.trading.security.common.util.SecurityUtils;
+import com.yami.trading.service.IdentifyingCodeService;
+import com.yami.trading.service.WithdrawService;
 import com.yami.trading.service.ico.IcoService;
 import com.yami.trading.service.item.ItemService;
+import com.yami.trading.service.user.UserService;
 import lombok.extern.slf4j.Slf4j;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Optional;
+import java.io.IOException;
+import java.math.RoundingMode;
+import java.text.DecimalFormat;
+import java.util.*;
 import java.util.stream.Collectors;
 
 
@@ -38,6 +60,84 @@
     @Autowired
     private KlineInitService klineInitService;
 
+    @Autowired
+    UdunClient udunClient;
+
+    @Autowired
+    RedisTemplate redisTemplate;
+
+    @Autowired
+    WithdrawService withdrawService;
+
+    @Autowired
+    IdentifyingCodeService identifyingCodeService;
+    @Autowired
+    UserService userService;
+    @Autowired
+    PasswordCheckManager passwordCheckManager;
+
+    private double getRandomValue(int value) {
+        double addValue;
+        if (value > 0) {
+            int count = 0;
+            while (value > 0) {
+                value = value / 10;
+                count++;
+            }
+            // 个
+            if (count == 1) {
+                addValue = RandomUtil.randomFloat(0.01, 0.1999, 4);
+                return addValue;
+            }
+            // 十
+            if (count == 2) {
+                addValue = RandomUtil.randomFloat(0.1, 0.5999, 4);
+                return addValue;
+            }
+            // 百
+            if (count == 3) {
+                addValue = RandomUtil.randomFloat(0.1, 2.9999, 4);
+                return addValue;
+            }
+            // 千
+            if (count == 4) {
+                addValue = RandomUtil.randomFloat(1, 3.9999, 4);
+                return addValue;
+            }
+            // 万
+            if (count == 5) {
+                addValue = RandomUtil.randomFloat(1, 5.9999, 4);
+                return addValue;
+            }
+            // 十万
+            else {
+                addValue = RandomUtil.randomFloat(1, 5.9999, 4);
+                return addValue;
+            }
+        } else {
+            addValue = RandomUtil.randomFloat(0.01, 0.2999, 4);
+            return addValue;
+        }
+    }
+
+   // @Scheduled(cron = "*/5 * * * * ?")
+    public void test() throws Exception {
+        double amt = 0.005215;
+        double addPriceValue = getRandomValue((int)amt);
+        double price = Arith.add(amt, addPriceValue);
+
+        String format = "";
+        format = "#.";
+        for (int j = 0; j < 6; j++) {
+            format = format + "#";
+        }
+
+        DecimalFormat df = new DecimalFormat(format);
+        df.setRoundingMode(RoundingMode.FLOOR);// 向下取整
+
+        System.out.println(df.format(price));
+        System.out.println("dd");
+    }
     /**
      * ico转入产品
      */
@@ -74,7 +174,7 @@
     /**
      * K线数据修正
      */
-    @Scheduled(cron = "0 */1 * * * ?")
+    //@Scheduled(cron = "0 */5 * * * ?")
     public void klineInit() {
         List<Item> items = ApplicationContextUtils.getApplicationContext().getBean(ItemService.class).list();
         if (CollectionUtil.isNotEmpty(items)) {

--
Gitblit v1.9.3