最高最低值优化

zyy

2025-10-28 e84b3c45f7ecef39926b582b10d03b30ff77ee95

 trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/HighLowHandleJob.java

@@ -4,6 +4,8 @@
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.common.util.ThreadUtils;
import com.yami.trading.huobi.data.DataCache;
import com.yami.trading.huobi.data.internal.DataDBService;
import com.yami.trading.service.data.DataService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.syspara.SysparaService;
import org.slf4j.Logger;
@@ -15,6 +17,7 @@
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;

/**
 * 最高最低修正
@@ -34,31 +37,45 @@
   private SysparaService sysparaService;
   @Autowired
   private ItemService itemService;
	
    @Autowired
    private DataService dataService;
   @Autowired
   DataDBService dataDBService;

   public void start() {
      new Thread(this, "HighLowHandleJob").start();
   }

   @Override
   public void run() {
      ThreadUtils.sleep(1000 * 60 * 3);
      bulidHighLow();
      ThreadUtils.sleep(1000 * 60 * 5);
      while (true) {
         bulidHighLow();
         ThreadUtils.sleep(1000 * 60 * 3);
         ThreadUtils.sleep(1000 * 60 * 5);
      }
   }

   public void bulidHighLow() {
      try {
         if (first) {
         /*if (first) {
            // data数据保存间隔时长(毫秒)
            this.interval = this.sysparaService.find("data_interval").getInteger().intValue() / 1000;
            first = false;
         }
         // 秒
         int num = (24 * 60 * 60) / this.interval;
         int num = (24 * 60 * 60) / this.interval;*/
         List<Item> item_list = itemService.findByType(Item.cryptos);
         item_list = item_list.stream()
               .filter(x -> x.getAdjustmentValue()!=null && x.getAdjustmentValue().doubleValue()!=0)
               .collect(Collectors.toList());
         for (int i = 0; i < item_list.size(); i++) {
            String symbol = item_list.get(i).getSymbol();
            //重新查询缓存
            dataDBService.cacheBefore24Hour(symbol);
         }

         /*for (int i = 0; i < item_list.size(); i++) {
            Item item = item_list.get(i);
            try {

@@ -96,10 +113,10 @@
            } catch (Exception e) {
               logger.error("run fail", e);
            }
         }
         }*/

      } catch (Exception e) {
         logger.error("run fail", e);
         logger.error("bulidHighLow run fail", e);
      }
   }