implementation group: 'com.opencsv', name: 'opencsv', version: '3.7'
  compile 'org.apache.commons:commons-csv:1.8'

package org.techlead.highchart_csv_example.services;


import lombok.Data;
import org.apache.commons.csv.CSVFormat;
import com.opencsv.CSVReader;
import org.apache.commons.csv.CSVRecord;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import java.io.*;
import java.net.URI;
import java.net.URL;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.util.ArrayList;
import java.util.List;


@Service
@Data
public class CoronaVirusDataService {

    //Raw 데이터가 있는 URL 저장
    private static String VIRUS_DATA_URL = "https://raw.githubusercontent.com/"+
            "CSSEGISandData/COVID-19/master/"+
            "csse_covid_19_data/csse_covid_19_time_series/"+
            "time_series_covid19_confirmed_global.csv";
    private List<String> dates = new ArrayList<>();
    private List<Integer> datesConfirmed = new ArrayList<>();
    private List<Integer> increaseFromYesterday = new ArrayList<>();


    //이 어노테이션은 어플리케이션이 시작되면 스프링은
    //이 서비스 객체를 만들게 되고 객체를 다 생성하고 나면
    //이 @PostConstruct 어노테이션이
    //있는 메소드를 자동으로 실행시켜준다.
    @PostConstruct
    //이 메소드를 매초 실행하라고 알려주는 것이다.
    //* * * * * *는 년도, 달, 일, 시간, 분, 초를 나타낸다.
    @Scheduled(cron = "* * 1 * * *")
    //http call를 할 메소드
    //client.send부분에서 send 함수를 쓰려면 exception를 받아야 한다.
    //그것을 받는 대신 throw를 하겠다.
    //client.send이 실패하면 exception를 throw한다.
    public void fetchVirusData() throws IOException, InterruptedException {
        //우리가 Http call를 하기 위해서는 HttpClient를 사용한다.
        HttpClient client = HttpClient.newHttpClient();


        //빌더 패턴을 사용가능하게 해주고 위에 선언한 VIRUS_DATA_URL 문자열을 uri로 바꾸기 위한 작업이다.
        //어디로 Http 요청을 할지 설정한다.
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create(VIRUS_DATA_URL))
                .build();

        //이제 client를 보냄으로써 response를 받을 것이다.
        //첫 번째 파라미터로는 request 그리고 두 번째로는 bodyHandler를 넣는다.
        //BodyHandler는 Body를 무엇을 할 건지 정할 수 있는 몇 가지 기능들이 있다.
        //http Body를 문자열로 반환해주는 것이다.
        HttpResponse<String> httpResponse = client.send(request, HttpResponse.BodyHandlers.ofString());


        //StringReader는 String을 Parse하는 리더 객체이다.
        //그래서 나는 String 객체로부터 reader객체가 있는 것이다.
        StringReader csvBodyReader = new StringReader(httpResponse.body());


        //그리고 위해서 반환받은 문자열을 찍어본다.
        // System.out.println(httpResponse.body());

        Iterable<CSVRecord> records = CSVFormat.DEFAULT.withFirstRecordAsHeader().parse(csvBodyReader);


        //csv 헤더를 추출하기 위한 코드 2줄
        URL headerURL = new URL(VIRUS_DATA_URL);
        BufferedReader in = new BufferedReader(new InputStreamReader(headerURL.openStream()));
        CSVReader reader = new CSVReader(in);


       // if the first line is the header
        String[] header = reader.readNext();


        for (CSVRecord record : records) {
            if(record.get("Country/Region").equals("Korea, South")) {

                for (int i = 10; i > 0; i--) {
                    //10일 동안의 날짜 문자열을 얻음
                    dates.add(header[header.length - i]);
                    System.out.println("Dates: " + header[header.length - i]);

                    //10일 동안의 전체 확진자수
                    datesConfirmed.add(Integer.parseInt(record.get(record.size() - i)));
                    System.out.println("Confirmed: " + Integer.parseInt(record.get(record.size() - i)));

                    //제일 최근 전체 확진자 수
                    int latestCases = Integer.parseInt(record.get(record.size() - i));
                    //바로 전날 전체 확진자 수
                    int prevDayCases = Integer.parseInt(record.get(record.size() - (i + 1)));

                    //위 두 변수의 차이로 전날 대비 몇명의 확진자가 증가했는지 구해서 넣는다.
                    increaseFromYesterday.add(latestCases - prevDayCases);
                    System.out.println("Confirmed difference: " + (latestCases - prevDayCases));

                }
            }
        }
    }
}

package org.techlead.highchart_csv_example.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.techlead.highchart_csv_example.services.CoronaVirusDataService;


@Controller
public class HomeController {

    @Autowired
    CoronaVirusDataService coronaVirusDataService;


    @RequestMapping("/")
    public String getData(Model model){


        model.addAttribute("dates",coronaVirusDataService.getDates());
        model.addAttribute("datesConfirmed",coronaVirusDataService.getDatesConfirmed());
        model.addAttribute("increaseFromYesterday",coronaVirusDataService.getIncreaseFromYesterday());
        return "index";
    }
}