package com.yami.trading.service.cms.impl;

import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yami.trading.bean.cms.Cms;
import com.yami.trading.bean.cms.News;
import com.yami.trading.bean.cms.dto.NewsDto;
import com.yami.trading.common.util.GoogleAuthenticator;
import com.yami.trading.dao.cms.CmsMapper;
import com.yami.trading.dao.cms.NewsMapper;
import com.yami.trading.service.cms.CmsService;
import com.yami.trading.service.cms.NewsSerivce;
import com.yami.trading.util.GoogleTranslateUtil;
import jodd.util.PropertiesUtil;
import org.apache.commons.collections.CollectionUtils;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.json.JSONArray;
import org.json.JSONObject;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.*;

@Service
public class NewsSerivceImpl extends ServiceImpl<NewsMapper, News> implements NewsSerivce {

    @Value("${http.prefix}")
    private String httpPrefix;
    @Override
    public Page<NewsDto> pageNews(Page page,String title,String language,String userCode) {
        return baseMapper.pageNews(page,title,language,userCode);
    }

    @Override
    public News getIndex(String language) {
        List<News> list  = list(Wrappers.<News>query().lambda().orderByDesc(News::getCreateTime));

        if (!CollectionUtil.isEmpty(list)) {

            Date date = new Date();

            for (News news : list) {

                if ((null != news.getStartTime() && date.before(news.getStartTime()))
                        || (null != news.getEndTime() && news.getEndTime().before(date))) {
                    continue;
                }

                if (news.isIndexTop() && !news.isPopUp()) {
                    list.add(news);
                }
            }
        }

        if (CollectionUtils.isEmpty(list))
            return null;
        return list.get(0);

    }

    @Override
    public void grabNews() {

        addNews(1, "http://api-in-pro.js-stock.top/stock-markets?key=xKChgi47AP1NMwMeYI3c&type=1&country_id=14");
    }

    private void addNews(Integer type, String url) {
        // 使用CloseableHttpClient发送请求
        try (CloseableHttpClient client = HttpClients.createDefault()) {
            // 创建HttpGet请求
            HttpGet request = new HttpGet(url);

            // 执行请求并获取响应
            HttpResponse response = client.execute(request);

            // 输出响应状态码
            System.out.println("响应状态: " + response.getStatusLine());
            GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();

            // 获取响应内容并转换成字符串
            String content = EntityUtils.toString(response.getEntity());
            JSONArray jsonArray = new JSONArray(content);
            if (jsonArray.length() > 0) {
                for (int i = 0; i < jsonArray.length(); i++) {
                    JSONObject jsonObject = jsonArray.getJSONObject(i);
                    String newsId = jsonObject.getString("id");
                    if (list(Wrappers.<News>query().lambda().eq(News::getSourceId,newsId)).size() == 0) {
                        News siteNews = new News();
                        siteNews.setSourceId(newsId);
                        siteNews.setContent(googleTranslateUtil.translate("en","zh-TW",jsonObject.getString("content")));
                        siteNews.setTitle(googleTranslateUtil.translate("en", "zh-TW",jsonObject.getString("title")));
                        if(jsonObject.has("img")){
                            convertBase64ToImage(jsonObject.getString("img"), com.yami.trading.common.util.PropertiesUtil.getProperty("loca.images.dir")  + "/" +newsId+".jpg");
                            siteNews.setImgUrl(httpPrefix + newsId+".jpg");
                        }
                        siteNews.setCreateTime(new Date());
                        save(siteNews);
                    }
                }
            }
        } catch (Exception e) {
            // 捕获并打印异常
            e.printStackTrace();
            log.error("添加新闻出现异常: " + e.getMessage());
        }
    }

    public static String  convertBase64ToImage(String base64Str, String path) {
        byte[] imageBytes = Base64.getDecoder().decode(base64Str);
        try {
            File file = new File(path);
            FileOutputStream fos = new FileOutputStream(file);
            fos.write(imageBytes);
            fos.flush();
            fos.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return  path;
    }
}