演示站

zj

2025-11-05 9c6296d07a668b15b9794709172e28ce3d9603e2

 src/main/java/com/nq/service/impl/PriceServicesImpl.java

@@ -9,7 +9,9 @@
import com.nq.dao.StockDzMapper;
import com.nq.dao.StockMapper;
import com.nq.dao.StockSettingMapper;
import com.nq.dao.StockTimeSettingMapper;
import com.nq.enums.EConfigKey;
import com.nq.enums.EStockType;
import com.nq.pojo.*;
import com.nq.service.IPriceServices;
import com.nq.service.IStockConfigServices;
@@ -28,6 +30,7 @@
import  java.io.InputStreamReader;
import  java.net.HttpURLConnection;
import  java.net.URL;
import java.time.LocalDate;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
@@ -51,37 +54,58 @@
    @Resource
    StockDzMapper stockDZMapper;

    @Resource
    StockTimeSettingMapper stockTimeSettingMapper;

    @Override
    public BigDecimal getNowPrice(String stockCode) {
        Stock stock = stockMapper.selectOne(new QueryWrapper<Stock>().eq("stock_code",stockCode));
        if(null == stock){
            return BigDecimal.ZERO;
        }
        StockSetting stockSetting = stockSettingMapper.selectOne(new QueryWrapper<StockSetting>().eq("stock_code",stockCode));
        if(stockSetting != null){
            Date newDate = new Date();
            DateTime startTime = DateUtil.parseDateTime(stockSetting.getStartTime());
            DateTime endTime = DateUtil.parseDateTime(stockSetting.getEndTime());
            if(newDate.after(startTime) && newDate.before(endTime)){
//            if(TimeUtil.isTradingHour(stockSetting.getStartTime(),stockSetting.getEndTime())){
                if(stockSetting.getType().equals("0")){
                    return  new BigDecimal(stockSetting.getPrice());
                }else{
                    String s = doPost(stock.getStockCode());
                    if(null != s){
                        Map<String, Object> stringObjectMap = jsonToMap(s);
                        return   new BigDecimal(stringObjectMap.get("Last").toString()).multiply(new BigDecimal(stockSetting.getPrice()));
                    }
                }
            }
        }
//        StockSetting stockSetting = stockSettingMapper.selectOne(new QueryWrapper<StockSetting>().eq("stock_code",stockCode));
//        if(stockSetting != null){
//            Date newDate = new Date();
//            DateTime startTime = DateUtil.parseDateTime(stockSetting.getStartTime());
//            DateTime endTime = DateUtil.parseDateTime(stockSetting.getEndTime());
//            if(newDate.after(startTime) && newDate.before(endTime)){
////            if(TimeUtil.isTradingHour(stockSetting.getStartTime(),stockSetting.getEndTime())){
//                if(stockSetting.getType().equals("0")){
//                    return  new BigDecimal(stockSetting.getPrice());
//                }else{
//                    String s = doPost(stock.getStockCode());
//                    if(null != s){
//                        Map<String, Object> stringObjectMap = jsonToMap(s);
//                        return   new BigDecimal(stringObjectMap.get("Last").toString()).multiply(new BigDecimal(stockSetting.getPrice()));
//                    }
//                }
//            }
//        }

        String s = doPost(stock.getStockCode());
        if(null != s) {
            Map<String, Object> stringObjectMap = jsonToMap(s);
            return  new BigDecimal(stringObjectMap.get("Last").toString());
            Boolean b = timeCheck();
            if(b){
                return  new BigDecimal(stringObjectMap.get("Last").toString());
            }else{
                return  new BigDecimal(stringObjectMap.get("PrevClose").toString());
            }

        }
        return BigDecimal.ZERO;
    }

    public  Boolean timeCheck() {
        StockTimeSetting stockTimeSetting = stockTimeSettingMapper.selectOne(new QueryWrapper<StockTimeSetting>().eq("accets_type","US"));

        if(stockTimeSetting == null){
            return  false;
        }
        if(!stockTimeSetting.getWeekDay().contains(String.valueOf(LocalDate.now().getDayOfWeek().getValue()))){
            return false;
        }
        return TimeUtil.isTradingHour(stockTimeSetting.getAmStartTime(),stockTimeSetting.getAmEndTime(),stockTimeSetting.getPmStartTime(),stockTimeSetting.getPmEndTime());
    }

    @Override
@@ -112,7 +136,7 @@

    public String doPost(String pid) {
        // 从配置中获取 API URL，并拼接 key
        String apiUrl = PropertiesUtil.getProperty("JS_IN_HTTP_URL") + "stock?key=" + PropertiesUtil.getProperty("JS_IN_KEY");
        String apiUrl = EStockType.US.getStockUrl() + "stock?key=" + EStockType.US.getStockKey();
        String result = null;
        try {
            URL url = new URL(apiUrl);