package com.moral.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.moral.mapper.AQIMapper;
import com.moral.service.AQIService;
import com.moral.util.HttpUtils;

import org.apache.http.HttpResponse;
import org.apache.http.util.EntityUtils;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import javax.annotation.Resource;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
public class AQIServiceImpl implements AQIService {
    @Resource
    private AQIMapper aqiMapper;

    @Override
    public List<Map<String, Object>> getCityAqiConfig() {
        return aqiMapper.getCityAqiConfig();
    }

    @Override
    public int insertAQIData(Map<String, Object> parameters) {
        return aqiMapper.insertAQIData(parameters);
    }

    @Override
    public int insertStationData() {
        int state = 500;
        List<Map<String, Object>> stationCodes = aqiMapper.getStationConfig();
        String host = "https://api.epmap.org";
        String path = "/api/v1/air/station";
        String method = "GET";
        String appcode = "31b6ea8f804a4472be3b633cfee44849";
        Map<String, String> headers = new HashMap<String, String>();
        headers.put("Authorization", "APPCODE " + appcode);
        Map<String, String> querys = new HashMap<String, String>();
        Date date = new Date();
        DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH");
        String pubtime = df.format(date) + ":00:00";
        querys.put("pubtime", pubtime);
        List<Map<String, Object>> insertList = new ArrayList<>();
        for (Map<String, Object> stationMap : stationCodes) {
            String stationCode = stationMap.get("station_code").toString();
            String cityCode = stationMap.get("city_code").toString();
            Map<String, Object> map = new HashMap<>();
            querys.put("station_code", stationCode);
            try {
                HttpResponse response = HttpUtils.doGet(host, path, method, headers, querys);
                JSONObject json = JSON.parseObject(EntityUtils.toString(response.getEntity()));
                Map<String, Object> data = (Map<String, Object>) json.get("data");
                if (!ObjectUtils.isEmpty(data)) {
                    pubtime = data.get("pubtime").toString();
                    map.put("time", pubtime);
                    map.put("json", JSON.toJSONString(data));
                    map.put("stationCode", stationCode);
                    map.put("cityCode", cityCode);
                    insertList.add(map);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        if (!insertList.isEmpty()) {
            aqiMapper.insertStationData(insertList);
            state = 200;
        }
        return state;
    }
}