//웹 프레임 웤
var express = require('express');

// 요청 리소스 표현 모듈
var request = require('request');

// api로 받아올 데이터포맷이 xml이므로 json으로 파싱할 필요가 있음
var convert = require('xml-js');
const bodyParser = require('body-parser');
var moment = require('moment');

// 라인 메신져
const TARGET_URL = 'https://api.line.me/v2/bot/message/reply'
const TOKEN = 'OPv3udmn1UGx+xWZFm80KeZbeGJm63nyt+sTpvBr1Mbc1Y0FAeK4MohQLcWq5yytJ6vnaNgXZfigAEFdbjzs05b4QAU+9r1jcZ05t6QvhWDTRYT0Z+YDMMePXtrQYCT84kmkH0OpJ4smBFwLxrtwtAdB04t89/1O/w1cDnyilFU='

// 공공보건포털_API
const CORONA_URL = 'http://openapi.data.go.kr/openapi/service/rest/Covid19/getCovid19InfStateJson';
const SERVICE_KEY = 'DMUPOq6b%2B%2F1gqfLEXQ6bnhgoTO73BfPprA6HVNcV%2F6vHMGG%2Bgiw%2BPDkPvX1eQ7b9uvl%2B42fxUPkU0W3Si907Lw%3D%3D'
queryParams = '?' + encodeURIComponent('ServiceKey') + '=' + SERVICE_KEY; // Service Key
queryParams += '&' + encodeURIComponent('pageNo') + '=' + encodeURIComponent('1'); 
queryParams += '&' + encodeURIComponent('numOfRows') + '=' + encodeURIComponent('4'); 
var menu = 0;
var start_checker = false;

// express 미들웨어 정의
var app = express();
app.use(bodyParser.json());

// 기타 비동기식 오류처리에 쓰일 모듈들
const fs = require('fs'); 
const path = require('path'); 
const HTTPS = require('https');
const { measureMemory } = require('vm');
const domain = "www.oss-chatbot-kwak.tk"
const sslport = 23023;

// 챗봇으로 입력
app.post('/hook', function (req, res) {

    var eventObj = req.body.events[0];
    var source = eventObj.source;
    var message = eventObj.message;

    // request log
    console.log('======================', new Date() ,'======================');
    console.log('[request]', req.body);
    console.log('[request source] ', eventObj.source);
    console.log('[request message]', eventObj.message);

    // 챗봇시작
    if(message.text == '/코로나' || message.text == '/corona'){
        request.post(
            {
                url: TARGET_URL,
                headers: {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: {
                    "replyToken":eventObj.replyToken,
                    "messages":[
                        {
                            "type":"text",
                            "text":"명령어 : " + message.text + " 로 코로나 19 bot을 시작하셨습니다."
                        },
                        {
                            "type":"text",
                            "text":"명령어 :\n1. 확진자 수 :\t\t\t\t\t\t\t/확진자\n2. 격리해제 수 :\t\t/격리해제\n3. 검사진행 수 :\t\t/검사진행\n4. 사망자 수 :\t\t\t\t\t\t\t/사망자\n5. 치료중 환자 수 :\t/치료중\n6. 결과음성 수 :\t\t/결과음성\n7. 누적검사 수 :\t\t/누적검사\n8. 누적 확진률 :\t\t/누적확진\n"
                        }
                    ]
                }
            },(error, response, body) => {
                console.log(body)
            });
            start_checker = true;
        return;
    }
    else if(message.text == '/확진자' && start_checker == true){
       menu = 1;
       start_checker = false;
       request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"확인하고 싶으신 일자를 적어주세요."
                    },
                    {
                        "type":"text",
                        "text":"포맷) YYYYMMDD"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
       return;
    }
    else if(message.text == '/격리해제' && start_checker == true){
       menu = 2;
       start_checker = false;
       request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"확인하고 싶으신 일자를 적어주세요."
                    },
                    {
                        "type":"text",
                        "text":"포맷) YYYYMMDD"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
       return;
    }
    else if(message.text == '/검사진행' && start_checker == true){
       menu = 3;
       start_checker = false;
       request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"확인하고 싶으신 일자를 적어주세요."
                    },
                    {
                        "type":"text",
                        "text":"포맷) YYYYMMDD"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
       return;
    }
    else if(message.text == '/사망자' && start_checker == true){
       menu = 4;
       start_checker = false;
       request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"확인하고 싶으신 일자를 적어주세요."
                    },
                    {
                        "type":"text",
                        "text":"포맷) YYYYMMDD"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
       return;
    }
    else if(message.text == '/치료중' && start_checker == true){
       menu = 5;
       start_checker = false;
       request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"확인하고 싶으신 일자를 적어주세요."
                    },
                    {
                        "type":"text",
                        "text":"포맷) YYYYMMDD"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
       return;
    }
    else if(message.text == '/음성' && start_checker == true){
       menu = 6;
       start_checker = false;
       request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"확인하고 싶으신 일자를 적어주세요."
                    },
                    {
                        "type":"text",
                        "text":"포맷) YYYYMMDD"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
       return;
    }
    else if(message.text == '/누적검사' && start_checker == true){
       menu = 7;
       start_checker = false;
       request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"확인하고 싶으신 일자를 적어주세요."
                    },
                    {
                        "type":"text",
                        "text":"포맷) YYYYMMDD"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
       return;
    }
    else if(message.text == '/누적확진' && start_checker == true){
       menu = 8;
       start_checker = false;
       request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"확인하고 싶으신 일자를 적어주세요.\n포맷 : YYYYMMDD 입니다."
                    },
                    {
                        "type":"text",
                        "text":"포맷) YYYYMMDD"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
       return;
    }
    else if(start_checker == true){
        menu = 0;
        request.post(
            {
                url: TARGET_URL,
                headers: {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: {
                    "replyToken":eventObj.replyToken,
                    "messages":[
                        {
                            "type":"text",
                            "text":"선택하신 정보가 정확하지 않거나 없습니다.\n처음부터 다시 진행해주세요."
                        },
                    ]
                }
            },(error, response, body) => {
                console.log(body)
            });
        start_checker = false;
        return;
    }

    if((menu != 0) && moment(message.text).isAfter(20200301)){
        today = message.text;
        queryParams += '&' + encodeURIComponent('endCreateDt') + '=' + encodeURIComponent(today); 
        switch(menu){
            case 1: 
                bot_reply_1(eventObj.replyToken, message);
                break;
            case 2: 
                bot_reply_2(eventObj.replyToken, message);
                break;
            case 3: 
                bot_reply_3(eventObj.replyToken, message);
                break;
            case 4: 
                bot_reply_4(eventObj.replyToken, message);
                break;
            case 5: 
                bot_reply_5(eventObj.replyToken, message);
                break;
            case 6: 
                bot_reply_6(eventObj.replyToken, message);
                break;
            case 7: 
                bot_reply_7(eventObj.replyToken, message);
                break;
            case 8: 
                bot_reply_8(eventObj.replyToken, message);
                break;
            default : 
                break;
        }
    }
    else if(menu == 0){
        request.post(
            {
                url: TARGET_URL,
                headers: {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: {
                    "replyToken":eventObj.replyToken,
                    "messages":[
                        {
                            "type":"text",
                            "text":"코로나 봇을 찾으시나요?\n명령어는 /코로나  또는 /corona 입니다."
                        }
                    ]
                }
            },(error, response, body) => {
                console.log(body)
            });
    }
    else{
        request.post(
            {
                url: TARGET_URL,
                headers: {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: {
                    "replyToken":eventObj.replyToken,
                    "messages":[
                        {
                            "type":"text",
                            "text":"바른 날짜를 입력해주세요.."
                        }
                    ]
                }
            },(error, response, body) => {
                console.log(body)
            });
    }
    

    res.sendStatus(200);
});

function bot_reply_1(replyToken, message) {
    request({
            url: CORONA_URL + queryParams,
            method: 'GET'
        },(error, response, body) => {
            if(!error && response.statusCode == 200) {
                console.log('Status', response.statusCode);
                console.log('Headers', JSON.stringify(response.headers));
                var xmlToJson = convert.xml2json(response.body, {compact: true, spaces: 4});
                const jsonData = JSON.parse(xmlToJson); // json text -> json object
                console.log('Reponse received', xmlToJson); // json text
                
                var resultMessage1 = jsonData.response.body.items.item[1];
                var resultMessage2 = jsonData.response.body.items.item[0];

                request.post(
                    {
                        url: TARGET_URL,
                        headers: {
                            'Authorization': `Bearer ${TOKEN}`
                        },
                        json: {
                            "replyToken":replyToken,
                            "messages":[
                                {
                                    "type":"text",
                                    "text": '선택하신 날짜와 정보의 Corona Virus-19 현황은 다음과 같습니다.'
                                },
                                {
                                    "type":"text",
                                    "text": "확진자 수 : " + (parseInt(resultMessage2.decideCnt._text)-parseInt(resultMessage1.decideCnt._text))
                                },
                                {
                                    "type":"text",
                                    "text": "등록일시분초 : " + resultMessage2.createDt._text
                                }
                            ]
                        }
                    },(error, response, body) => {
                        console.log(body)
                    });
            }
        });
}
function bot_reply_2(replyToken, message) {
    request({
            url: CORONA_URL + queryParams,
            method: 'GET'
        },(error, response, body) => {
            if(!error && response.statusCode == 200) {
                console.log('Status', response.statusCode);
                console.log('Headers', JSON.stringify(response.headers));
                var xmlToJson = convert.xml2json(response.body, {compact: true, spaces: 4});
                const jsonData = JSON.parse(xmlToJson); // json text -> json object
                console.log('Reponse received', xmlToJson); // json text
                
                var resultMessage1 = jsonData.response.body.items.item[1];
                var resultMessage2 = jsonData.response.body.items.item[0];                
                request.post(
                    {
                        url: TARGET_URL,
                        headers: {
                            'Authorization': `Bearer ${TOKEN}`
                        },
                        json: {
                            "replyToken":replyToken,
                            "messages":[
                                {
                                    "type":"text",
                                    "text": '선택하신 날짜와 정보의 Corona Virus-19 현황은 다음과 같습니다.'
                                },
                                {
                                    "type":"text",
                                    "text": "격리해제 수 : " + (parseInt(resultMessage2.clearCnt._text)-parseInt(resultMessage1.clearCnt._text))
                                },
                                {
                                    "type":"text",
                                    "text": "등록일시분초 : " + resultMessage2.createDt._text
                                }
                            ]
                        }
                    },(error, response, body) => {
                        console.log(body)
                    });
            }
        });
}
function bot_reply_3(replyToken, message) {
    request({
            url: CORONA_URL + queryParams,
            method: 'GET'
        },(error, response, body) => {
            if(!error && response.statusCode == 200) {
                console.log('Status', response.statusCode);
                console.log('Headers', JSON.stringify(response.headers));
                var xmlToJson = convert.xml2json(response.body, {compact: true, spaces: 4});
                const jsonData = JSON.parse(xmlToJson); // json text -> json object
                console.log('Reponse received', xmlToJson); // json text
                
                var resultMessage1 = jsonData.response.body.items.item[1];
                var resultMessage2 = jsonData.response.body.items.item[0];                
                request.post(
                    {
                        url: TARGET_URL,
                        headers: {
                            'Authorization': `Bearer ${TOKEN}`
                        },
                        json: {
                            "replyToken":replyToken,
                            "messages":[
                                {
                                    "type":"text",
                                    "text": '선택하신 날짜와 정보의 Corona Virus-19 현황은 다음과 같습니다.'
                                },
                                {
                                    "type":"text",
                                    "text": "검사진행 수 : " + (parseInt(resultMessage2.examCnt._text)-parseInt(resultMessage1.examCnt._text))
                                },
                                {
                                    "type":"text",
                                    "text": "등록일시분초 : " + resultMessage2.createDt._text
                                }
                            ]
                        }
                    },(error, response, body) => {
                        console.log(body)
                    });
            }
        });
}
function bot_reply_4(replyToken, message) {
    request({
            url: CORONA_URL + queryParams,
            method: 'GET'
        },(error, response, body) => {
            if(!error && response.statusCode == 200) {
                console.log('Status', response.statusCode);
                console.log('Headers', JSON.stringify(response.headers));
                var xmlToJson = convert.xml2json(response.body, {compact: true, spaces: 4});
                const jsonData = JSON.parse(xmlToJson); // json text -> json object
                console.log('Reponse received', xmlToJson); // json text
                
                var resultMessage1 = jsonData.response.body.items.item[1];
                var resultMessage2 = jsonData.response.body.items.item[0];                
                request.post(
                    {
                        url: TARGET_URL,
                        headers: {
                            'Authorization': `Bearer ${TOKEN}`
                        },
                        json: {
                            "replyToken":replyToken,
                            "messages":[
                                {
                                    "type":"text",
                                    "text": '선택하신 날짜와 정보의 Corona Virus-19 현황은 다음과 같습니다.'
                                },
                                {
                                    "type":"text",
                                    "text": "사망자 수 : " + (parseInt(resultMessage2.deathCnt._text)-parseInt(resultMessage1.deathCnt._text))
                                },
                                {
                                    "type":"text",
                                    "text": "등록일시분초 : " + resultMessage2.createDt._text
                                }
                            ]
                        }
                    },(error, response, body) => {
                        console.log(body)
                    });
            }
        });
}
function bot_reply_5(replyToken, message) {
    request({
            url: CORONA_URL + queryParams,
            method: 'GET'
        },(error, response, body) => {
            if(!error && response.statusCode == 200) {
                console.log('Status', response.statusCode);
                console.log('Headers', JSON.stringify(response.headers));
                var xmlToJson = convert.xml2json(response.body, {compact: true, spaces: 4});
                const jsonData = JSON.parse(xmlToJson); // json text -> json object
                console.log('Reponse received', xmlToJson); // json text
                
                var resultMessage1 = jsonData.response.body.items.item[1];
                var resultMessage2 = jsonData.response.body.items.item[0];                
                request.post(
                    {
                        url: TARGET_URL,
                        headers: {
                            'Authorization': `Bearer ${TOKEN}`
                        },
                        json: {
                            "replyToken":replyToken,
                            "messages":[
                                {
                                    "type":"text",
                                    "text": '선택하신 날짜와 정보의 Corona Virus-19 현황은 다음과 같습니다.'
                                },
                                {
                                    "type":"text",
                                    "text": "치료중 환자 수 : " + (parseInt(resultMessage2.careCnt._text)-parseInt(resultMessage1.careCnt._text))
                                },
                                {
                                    "type":"text",
                                    "text": "등록일시분초 : " + resultMessage2.createDt._text
                                }
                            ]
                        }
                    },(error, response, body) => {
                        console.log(body)
                    });
            }
        });
}
function bot_reply_6(replyToken, message) {
    request({
            url: CORONA_URL + queryParams,
            method: 'GET'
        },(error, response, body) => {
            if(!error && response.statusCode == 200) {
                console.log('Status', response.statusCode);
                console.log('Headers', JSON.stringify(response.headers));
                var xmlToJson = convert.xml2json(response.body, {compact: true, spaces: 4});
                const jsonData = JSON.parse(xmlToJson); // json text -> json object
                console.log('Reponse received', xmlToJson); // json text
                
                var resultMessage1 = jsonData.response.body.items.item[1];
                var resultMessage2 = jsonData.response.body.items.item[0];                
                request.post(
                    {
                        url: TARGET_URL,
                        headers: {
                            'Authorization': `Bearer ${TOKEN}`
                        },
                        json: {
                            "replyToken":replyToken,
                            "messages":[
                                {
                                    "type":"text",
                                    "text": '선택하신 날짜와 정보의 Corona Virus-19 현황은 다음과 같습니다.'
                                },
                                {
                                    "type":"text",
                                    "text": "결과 음성 수 : " + (parseInt(resultMessage2.resutlNegCnt._text)-parseInt(resultMessage1.resutlNegCnt._text))
                                },
                                {
                                    "type":"text",
                                    "text": "등록일시분초 : " + resultMessage2.createDt._text
                                }
                            ]
                        }
                    },(error, response, body) => {
                        console.log(body)
                    });
            }
        });
}
function bot_reply_7(replyToken, message) {
    request({
            url: CORONA_URL + queryParams,
            method: 'GET'
        },(error, response, body) => {
            if(!error && response.statusCode == 200) {
                console.log('Status', response.statusCode);
                console.log('Headers', JSON.stringify(response.headers));
                var xmlToJson = convert.xml2json(response.body, {compact: true, spaces: 4});
                const jsonData = JSON.parse(xmlToJson); // json text -> json object
                console.log('Reponse received', xmlToJson); // json text
                
                var resultMessage = jsonData.response.body.items.item;
                
                request.post(
                    {
                        url: TARGET_URL,
                        headers: {
                            'Authorization': `Bearer ${TOKEN}`
                        },
                        json: {
                            "replyToken":replyToken,
                            "messages":[
                                {
                                    "type":"text",
                                    "text": '선택하신 날짜와 정보의 Corona Virus-19 현황은 다음과 같습니다.'
                                },
                                {
                                    "type":"text",
                                    "text": "누적 검사 수 : " + resultMessage.accExamCnt._text
                                },
                                {
                                    "type":"text",
                                    "text": "누적 검사 완료 수 : " + resultMessage.accExamCompCnt._text
                                },
                                {
                                    "type":"text",
                                    "text": "등록일시분초 : " + resultMessage.createDt._text
                                }
                            ]
                        }
                    },(error, response, body) => {
                        console.log(body)
                    });
            }
        });
}
function bot_reply_8(replyToken, message) {
    request({
            url: CORONA_URL + queryParams,
            method: 'GET'
        },(error, response, body) => {
            if(!error && response.statusCode == 200) {
                console.log('Status', response.statusCode);
                console.log('Headers', JSON.stringify(response.headers));
                var xmlToJson = convert.xml2json(response.body, {compact: true, spaces: 4});
                const jsonData = JSON.parse(xmlToJson); // json text -> json object
                console.log('Reponse received', xmlToJson); // json text
                
                var resultMessage = jsonData.response.body.items.item;
                
                request.post(
                    {
                        url: TARGET_URL,
                        headers: {
                            'Authorization': `Bearer ${TOKEN}`
                        },
                        json: {
                            "replyToken":replyToken,
                            "messages":[
                                {
                                    "type":"text",
                                    "text": '선택하신 날짜와 정보의 Corona Virus-19 현황은 다음과 같습니다.'
                                },
                                {
                                    "type":"text",
                                    "text": "누적 확진률 : " + resultMessage.accDefRate._text
                                },
                                {
                                    "type":"text",
                                    "text": "등록일시분초 : " + resultMessage.createDt._text
                                }
                            ]
                        }
                    },(error, response, body) => {
                        console.log(body)
                    });
            }
        });
}

// Https server 오류처리
try {
    const option = {
      ca: fs.readFileSync('/etc/letsencrypt/live/' + domain +'/fullchain.pem'),
      key: fs.readFileSync(path.resolve(process.cwd(), '/etc/letsencrypt/live/' + domain +'/privkey.pem'), 'utf8').toString(),
      cert: fs.readFileSync(path.resolve(process.cwd(), '/etc/letsencrypt/live/' + domain +'/cert.pem'), 'utf8').toString(),
    };
  
    HTTPS.createServer(option, app).listen(sslport, () => {
      console.log(`[HTTPS] Server is started on port ${sslport}`);
    });
  } catch (error) {
    console.log('[HTTPS] HTTPS 오류가 발생하였습니다. HTTPS 서버는 실행되지 않습니다.');
    console.log(error);
  }