1

zj

2024-05-18 e26923972dffde65542e61d09032ee0234f0bb7f

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

@@ -24,9 +24,12 @@
import java.util.Base64;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * 新闻资讯
 *
 * @author lr
 * @date 2020/07/24
 */
@@ -132,15 +135,26 @@

    @Override
    public void grabNews() {
        addNews(1, EStockType.IN.getStockUrl() + "stock-markets?key=" + EStockType.IN.getStockKey() + "&type=4");
        ExecutorService executor = Executors.newFixedThreadPool(2);
        try {
            executor.submit(() -> addNews(1, EStockType.MAS.getStockUrl() + "stock-markets?key=" + EStockType.MAS.getStockKey() + "&type=4"));
            executor.submit(() -> addNews(3, EStockType.MAS.getStockUrl() + "stock-markets?key=" + EStockType.MAS.getStockKey() + "&type=2"));
        } catch (Exception e) {
            e.printStackTrace();
            log.error("添加新闻出现异常:  " + e.getMessage());
        } finally {
            if (executor != null) {
                executor.shutdown();
    }

        }
    }
    private void addNews(Integer type, String url) {
        try {
            String newlist = HttpRequest.doGrabGet(url);
            JSONArray jsonArray = JSONArray.fromObject(newlist);
            if (jsonArray.size() > 0) {
                for (int i = 0; i < jsonArray.size(); i++) {
            int size = jsonArray.size();  // 将jsonArray.size()的计算结果存储在变量中
            if (size > 0) {
                for (int i = 0; i < size; i++) {
                    JSONObject jsonObject = jsonArray.getJSONObject(i);
                    String newsId = jsonObject.getString("id");
                    if (siteNewsMapper.getNewsBySourceIdCount(newsId) == 0) {
@@ -150,7 +164,10 @@
                        siteNews.setTitle(jsonObject.getString("title"));
                        Long showTime = jsonObject.getLong("time");
                        siteNews.setShowTime(new Date(showTime * 1000));
                        siteNews.setImgurl(jsonObject.getString("img"));
                        if(jsonObject.has("img")){
                            convertBase64ToImage(jsonObject.getString("img"),PropertiesUtil.getProperty("ftp.address")+newsId+".jpg");
                            siteNews.setImgurl(PropertiesUtil.getProperty("ftp.server.http.prefix")+newsId+".jpg");
                        }
                        siteNews.setDescription(jsonObject.getString("content"));
                        siteNews.setContent(jsonObject.getString("content"));
                        siteNews.setStatus(1);
@@ -165,7 +182,6 @@
        }
    }


    public static String  convertBase64ToImage(String base64Str, String path) {
        byte[] imageBytes = Base64.getDecoder().decode(base64Str);
        try {
@@ -179,5 +195,4 @@
        }
        return  path;
    }

}