백승욱

Create showYesterdayRank function

1 +var express = require('express');
2 +const request = require('request');
3 +
4 +// 라인 API 요청 URL(메시징 API)
5 +const LINE_URL = 'https://api.line.me/v2/bot/message/reply'
6 +const TOKEN = ''
7 +
8 +// 한국영화진흥위원회 API 요청 URL(일별 박스오피스)
9 +const BOXOFFICE_URL = 'http://www.kobis.or.kr/kobisopenapi/webservice/rest/boxoffice/searchDailyBoxOfficeList.json'
10 +// 한국영화진흥위원회 API 발급 받은 키
11 +const KOFIC_KEY = ''
12 +
13 +
14 +// ================== SETTINGS ==================
15 +const fs = require('fs');
16 +const path = require('path');
17 +const HTTPS = require('https');
18 +const domain = ""
19 +const sslport = 23023;
20 +const bodyParser = require('body-parser');
21 +var app = express();
22 +app.use(bodyParser.json());
23 +// ===============================================
24 +
25 +
26 +app.post('/hook', function (req, res) {
27 +
28 + var eventObj = req.body.events[0];
29 +
30 + // (디버깅용) req.body 내용 콘솔로 확인
31 + console.log('======================', new Date() ,'======================');
32 + console.log('[request]', req.body);
33 + console.log('[request source] ', eventObj.source);
34 + console.log('[request message]', eventObj.message);
35 +
36 + showYesterdayRank(eventObj.replyToken, eventObj.message.text);
37 + res.sendStatus(200);
38 +});
39 +
40 +// 해당 날짜 영화 순위 출력 함수
41 +// 입력 인자 중 message 에는 어제 날짜 들어감(ex: 20220528)
42 +function showYesterdayRank(replyToken, message) {
43 +
44 + // 한국영화진흥위원회 API는 get 형태로 호출
45 + request.get(
46 + {
47 + url: BOXOFFICE_URL+`?key=${KOFIC_KEY}&targetDt=${message}`,
48 + json:true
49 + },(error, response, body) => {
50 + if(!error && response.statusCode == 200) {
51 + console.log(body.boxOfficeResult);
52 +
53 + var transMessage_1 = body.boxOfficeResult.dailyBoxOfficeList[0].movieNm;
54 + var transMessage_2 = body.boxOfficeResult.dailyBoxOfficeList[1].movieNm;
55 + var transMessage_3 = body.boxOfficeResult.dailyBoxOfficeList[2].movieNm;
56 + var transMessage_4 = body.boxOfficeResult.dailyBoxOfficeList[3].movieNm;
57 +
58 + request.post(
59 + {
60 + url: LINE_URL,
61 + headers: {
62 + 'Authorization': `Bearer ${TOKEN}`
63 + },
64 + json: {
65 + "replyToken":replyToken,
66 + "messages":[
67 + {
68 + "type":"text",
69 + "text": `1위 : ${transMessage_1}\n2위 : ${transMessage_2}\n3위 : ${transMessage_3}\n4위 : ${transMessage_4}`
70 + }
71 + ]
72 + }
73 + },(error, response, body) => {
74 + console.log(body)
75 + });
76 + }
77 + });
78 +}
79 +
80 +try {
81 + const option = {
82 + ca: fs.readFileSync('/etc/letsencrypt/live/' + domain +'/fullchain.pem'),
83 + key: fs.readFileSync(path.resolve(process.cwd(), '/etc/letsencrypt/live/' + domain +'/privkey.pem'), 'utf8').toString(),
84 + cert: fs.readFileSync(path.resolve(process.cwd(), '/etc/letsencrypt/live/' + domain +'/cert.pem'), 'utf8').toString(),
85 + };
86 +
87 + HTTPS.createServer(option, app).listen(sslport, () => {
88 + console.log(`[HTTPS] Server is started on port ${sslport}`);
89 + });
90 + } catch (error) {
91 + console.log('[HTTPS] HTTPS 오류가 발생하였습니다. HTTPS 서버는 실행되지 않습니다.');
92 + console.log(error);
93 + }
94 +
...\ No newline at end of file ...\ No newline at end of file