From c50561d007e420f7397f73afce8966231973ec54 Mon Sep 17 00:00:00 2001
From: peter <14100000001@qq.com>
Date: Mon, 18 Aug 2025 17:35:30 +0800
Subject: [PATCH] 外汇接口调整

---
 trading-order-admin/src/main/java/com/yami/trading/api/controller/ApiItemController.java |   17 ++++++++++++++---
 1 files changed, 14 insertions(+), 3 deletions(-)

diff --git a/trading-order-admin/src/main/java/com/yami/trading/api/controller/ApiItemController.java b/trading-order-admin/src/main/java/com/yami/trading/api/controller/ApiItemController.java
index 4f12551..35f075c 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/api/controller/ApiItemController.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/api/controller/ApiItemController.java
@@ -9,6 +9,7 @@
 import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 import com.yami.trading.api.dto.RelatedStocksDto;
+import com.yami.trading.bean.data.domain.Kline;
 import com.yami.trading.bean.data.domain.Realtime;
 import com.yami.trading.bean.data.dto.StocksDto;
 import com.yami.trading.bean.item.domain.Item;
@@ -21,6 +22,8 @@
 import com.yami.trading.common.lang.LangUtils;
 import com.yami.trading.common.util.MarketOpenChecker;
 import com.yami.trading.common.util.StringUtils;
+import com.yami.trading.huobi.data.internal.KlineConstant;
+import com.yami.trading.huobi.data.internal.KlineService;
 import com.yami.trading.service.data.DataService;
 import com.yami.trading.service.item.ItemService;
 import com.yami.trading.service.syspara.LocalSysparaService;
@@ -31,6 +34,8 @@
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
@@ -60,6 +65,8 @@
     @Autowired
     @Qualifier("dataService")
     private DataService dataService;
+    @Autowired
+    private KlineService klineService;
 
     /**
      * 产品列表数据
@@ -135,8 +142,8 @@
         queryWrapper.in(CollectionUtil.isNotEmpty(symbols), "symbol", symbols);
         String name = itemQuery.getName();
         queryWrapper.and(StringUtils.isNotEmpty(name), itemWrapper->itemWrapper.like("name",name).or().like("symbol", name));
-        queryWrapper.eq(StrUtil.isNotBlank(type), "type", type);
-        queryWrapper.like(StrUtil.isNotBlank(category), "category", category);
+        queryWrapper.eq(StrUtil.isNotBlank(type), "type", "forex");
+        queryWrapper.like(StrUtil.isNotBlank(category), "category", "forex");
         queryWrapper.orderByDesc("sorted");
         Page<Item> page = new Page<>(1, 1000);
         IPage<Item> result = itemService.page(page, queryWrapper);
@@ -160,6 +167,11 @@
 
             if (CollectionUtil.isNotEmpty(realtimes)) {
                 Realtime realtime = realtimes.get(0);
+//                if("forex".equals(type)){
+//                    symbolDTO.setChangeRatio(realtime.getChangeRatioStr());
+//                }else{
+//
+//                }
                 symbolDTO.setChangeRatio(realtime.getChangeRatio());
                 symbolDTO.setAmount(realtime.getAmount());
                 symbolDTO.setVolume(realtime.getVolume());
@@ -167,7 +179,6 @@
                 symbolDTO.setTs(realtime.getTs());
                 symbolDTO.setCurrent_time(realtime.getTs());
                 symbolDTO.setChg(realtime.getClose().subtract(realtime.getOpen()));
-
             }
             dtos.add(symbolDTO);
         }

--
Gitblit v1.9.3