임승현 / Multiplex_Ticketing_Platform

Go to a project
Toggle navigation Toggle navigation pinning
임승현
e8d79e57 2 parents b0983bc3 4dc20d92

Merge branch 'feature/Chatbot_megabox' into 'master' 

Feature/chatbot megabox



See merge request !35
Inline Side-by-side
Showing 8 changed files with 1211 additions and 6 deletions
const chatbot = require("./app.js");
const request = require('request');
const cheerio = require('cheerio');
const puppeteer = require('puppeteer');
require('chromedriver');
const {Builder,until} = require('selenium-webdriver'); //모듈 불러오기
var webdriver = require('selenium-webdriver');
var By = webdriver.By;
const chrome = require('selenium-webdriver/chrome');//크롬 사용시
const async = require('async')
let express = require('express');
let app = express();
let bodyParser = require('body-parser');
const { timeout } = require('async');
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());
const booking_url = "https://megabox.co.kr/booking?";
exports.booking_url = booking_url;
const rate_url = "https://www.megabox.co.kr/movie";
let r =0;
let movie_data = [];
exports.movie_data = movie_data;
let location_data = [];
exports.location_data = location_data;
let index = 0;
exports.init = ()=>{async.waterfall([//for 동기적 처리
async () => {
const driver = new webdriver.Builder().forBrowser('chrome').setChromeOptions(new chrome.Options().headless()).build();//
driver.get(booking_url);
driver.switchTo().frame(0)//frameBokdMBooking 프레임 가져옴
let seoul = await driver.wait(until.elementsLocated(By.css('#mCSB_4_container>ul>li>#btn')));
let Gyeonggi = await driver.wait(until.elementsLocated(By.css('#mCSB_5_container>ul>li>#btn')));
const Incheon = await driver.wait(until.elementsLocated(By.css('#mCSB_6_container>ul>li>#btn')));
const DCS = await driver.wait(until.elementsLocated(By.css('#mCSB_7_container>ul>li>#btn')));//Daejeon Chungcheong Sejong
const BDG = await driver.wait(until.elementsLocated(By.css('#mCSB_8_container>ul>li>#btn')));//Busan Daegu Gyeongsang
const GJ= await driver.wait(until.elementsLocated(By.css('#mCSB_9_container>ul>li>#btn')));//gwangju_jeonla
const Gangwon = await driver.wait(until.elementsLocated(By.css('#mCSB_10_container>ul>li>#btn')));
const location_list = [seoul, Gyeonggi, Incheon, DCS, BDG, GJ, Gangwon]//
for(let i = 0; i < location_list.length; i++){
for (item of location_list[i]) {
location_data[index++] = {
'LocationName':await item.getAttribute("brch-nm"),
'LocationNum' : await item.getAttribute("brch-no")
}
// let location_name = await item.getAttribute("brch-nm");
// let location_num = await item.getAttribute("brch-no");
// let obj = {};
// obj[location_name]= location_num
// location_data[index++] = obj;
}
}
let movie_list = await driver.wait(until.elementsLocated(By.css('#mCSB_1_container>ul>li>.btn')));
r = 0;
for (item of movie_list) {
//Using getAttribute to get the data
movie_data[r++] = {
'rank' : r,
'title' : await item.getAttribute("movie-nm"),
'movie_num':await item.getAttribute("movie-no"),
}
}
driver.close();
},
async () => {
r = 0;
const browser = await puppeteer.launch({
headless: true
});
const page = await browser.newPage();
await page.goto(rate_url);
const content = await page.content();
const $ = cheerio.load(content);
const $rate_lists = $("ol.list>li");
$rate_lists.each((index, list) => {
const name = $(list).find('div.tit-area > p.tit').attr('title');
const rate = $(list).find('div.rate-date > span.rate').text();
if(movie_data[r].title === name){
movie_data[r++]['rate'] = rate;
}
});
for(i of movie_data){
if(Object.keys(i).length==3){
movie_data[r++]['rate'] = '예매율 0%';
}
}
browser.close();
console.log("Comepleted!");
},
])}
let appdriver;
exports.using_PlayingMovieURL = async(PlayingMovieURL) => {
appdriver = new webdriver.Builder().forBrowser('chrome').setChromeOptions(new chrome.Options().headless()).build();
appdriver.get(PlayingMovieURL);
//appdriver.switchTo().frame(0)
//frameBokdMBooking 프레임 가져옴
}
exports.geting_PlayingMovie= async() => {
let movie_list = await appdriver.wait(until.elementsLocated(By.css('#mCSB_1_container>ul>li>.btn')));
let n = 0;
console.log(movie_list);
for (item of movie_list) {
movie_data[n++]['running'] = await item.getAttribute('form-at');
}
console.log("Completed get Running");
}
app.listen(5000);
\ No newline at end of file
const megabox = require('./Megabox.js');
//const SearchingTheaterAPI = require('./SearchingTheaterAPI');
const async = require('async');
megabox.init(); //메가박스 코드 시작(영화관 리스트 가져오기)
const PUSH_TARGET_URL = 'https://api.line.me/v2/bot/message/push'
const REPLY_TARGET_URL = 'https://api.line.me/v2/bot/message/reply'
const asyncHandler = require('express-async-handler')
const bodyParser = require('body-parser');
const request = require('request');
const moment = require("moment");
const HTTPS = require('https');
const path = require('path');
const fs = require('fs');
const sslport = 23023;
var express = require('express');
var app = express();
app.use(bodyParser.json());
/////////////////////////////////////////////////
// commit 할때 지워야 할것들
const USER_ID = '';
const TOKEN = '';
const domain = '';
const KAKAO_KEY = '';
/////////////////////////////////////////////////
let MEGA_date;
let MEGA_TheaterLocation;
let MEGA_TheaterLocationCode;
let MEGA_PlayingMovieList = [];
let MEGA_title;
let MEGA_PlayingMovieURL;
let initFlag = false; //브랜드 선택 flag
let MEGA_flag = -1; //메가박스 인지 확인하는 flag
let MEGA_count; //메가박스에서 영화관 판단하는 count
let MEGA_AbleLocationList = []; //메가박스에서 영화관 이름 매치하는 것 저장하는 list
let MegaboxKakaoResultTheater = [];
exports.MEGA_PlayingMovieURL = MEGA_PlayingMovieURL;
////////////////////////////////////////////////
//처음 영화관을 가져오는 것까지 대략 30초가 걸림 => 30초 기다리고 메세지 전송
setTimeout(function () {
PushSingleMessage("원하시는 브랜드의 번호를 입력해주세요.\n1: CGV\n2: LotteCinema\n3: Megabox\n언제든 브랜드를 바꾸고 싶으시다면 '브랜드'를 입력해주세요.");
}, 30000);
//app.post('/hook', function (req, res) {
app.post('/hook', asyncHandler(async (req, res, next) => {
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);
//어느 순간에서든 "브랜드"를 입력해 원하는 브랜드 선택
//initFlag : false ==> 브랜드 선택 전
//initFlag : true ==> 브랜드 선택 됨
if (eventObj.message.text == "브랜드") {
initFlag = false;
MEGA_flag = -1;
PushSingleMessage("원하시는 브랜드의 번호를 입력해주세요.\n1: CGV\n2: LotteCinema\n3: Megabox\n언제든 브랜드를 바꾸고 싶으시다면 '브랜드'를 입력해주세요.");
}
//브랜드 선택- 메가박스 인 경우 MEGA_flag를 0으로 두어 메가박스 임을 확인
if (initFlag == false && eventObj.message.text == 3) {
initFlag = true;
MEGA_flag = 0;
}
//메가박스로 브랜드 선택된 경우
if (initFlag == true && MEGA_flag != -1) {
if (MEGA_flag == 0) {
const text1 = "영화관 위치를 입력해주세요";
const text2 = "ex1)강남";
SendMessage(eventObj, text1, text2);
MEGA_flag++;
//PusbuttonhMessage("https://developers.line.biz/en/reference/messaging-api/#message-common-properties");
//console.log(MEGA_flag)
}else if (MEGA_flag === 1) {
MEGA_count = 0; //MEGA_count 초기화
MEGA_AbleLocationList.length = 0; //MEGA_AbleLocationList 초기화
for (i of megabox.location_data) {
if (i['LocationName'].includes(message.text)) {
MEGA_AbleLocationList[MEGA_count++] = i;
}
}
if (MEGA_count == 1) { //결과 1개 => 바로 다음 단계 넘어가기
MEGA_TheaterLocation = MEGA_AbleLocationList[0].LocationName;
MEGA_TheaterLocationCode = MEGA_AbleLocationList[0].LocationNum;
console.log(MEGA_TheaterLocation, MEGA_TheaterLocationCode);
MEGA_flag++;
} else if (MEGA_count > 1) { //결과 2개 이상 => 리스트 출력해주고 번호로 입력받아 넘어가기
console.log(MEGA_AbleLocationList[0], MEGA_AbleLocationList[1]);
let MEGA_OutputString = "원하시는 상영관의 번호를 정확히 입력해주세요\n"; //메가박스 영화관 가능 정보 string
//PushSingleMessage("원하시는 상영관의 번호를 정확히 입력해주세요");
for (let x = 0; x < MEGA_count; x++) {
//PushSingleMessage(String(x + 1) + ": " + MEGA_AbleLocationList[x].LocationName);
MEGA_OutputString += String(x + 1) + ": " + MEGA_AbleLocationList[x].LocationName + "\n";
console.log(String(x + 1), MEGA_AbleLocationList[x].LocationName);
}
MEGA_OutputString += String(MEGA_count + 1) + ": 다시 검색하기";
PushSingleMessage(MEGA_OutputString);
MEGA_flag = 101;
} else {
PushSingleMessage("다시 입력해주세요.");
}
//원본 코드
//console.log(MEGA_flag);
// for (i of megabox.location_data) {
// if (i['LocationName'] === message.text) {
// MEGA_TheaterLocationCode = i['LocationNUm'];
// console.log(MEGA_TheaterLocationCode);
// MEGA_flag++;
// console.log(MEGA_flag)
// break;
// }
// }
} else if (MEGA_flag == 101) {
// 0< input || input > MEGA_count+1 : 다시 검색
let tempNum = parseInt(message.text);
if (tempNum > 0 && tempNum < MEGA_count + 1) {
//번호에 맞는 LocationCode 전달
MEGA_TheaterLocation = MEGA_AbleLocationList[tempNum - 1].LocationName;
MEGA_TheaterLocationCode = MEGA_AbleLocationList[tempNum - 1].LocationNum;
console.log(MEGA_TheaterLocation, MEGA_TheaterLocationCode);
MEGA_flag = 2;
} else {
//다시 장소 입력받기
const text1 = "영화관 위치를 입력해주세요";
const text2 = "ex1)강남";
SendMessage(eventObj, text1, text2);
MEGA_flag = 1;
}
}
//날짜 입력 받기
if (MEGA_flag == 2) {
const text1 = "현재 영화관은 " + MEGA_TheaterLocation + " 입니다.\n영화를 보실 날짜를 입력해주세요.";
const text2 = "ex)20020409";
SendMessage(eventObj, text1, text2);
MEGA_flag = 3;
}
//날짜 확인 및 날짜, 장소에 대해 상영중인 영화 리스트 가져오기
if (moment(message.text, "YYYYMMDD", true).isValid() && MEGA_flag == 3) {
MEGA_date = parseInt(message.text);
let today = GettingToday();//오늘 이후인지 확인하기 위해 날짜 가져옴
//console.log(MEGA_date, MEGA_TheaterLocation);
if (today<=MEGA_date && MEGA_date && MEGA_TheaterLocationCode) {
const text1 = "현재상영작을 가져오는 중입니다.";
const text2 = "잠시만 기다려주세요.";
PushMessage(text1, text2);
MEGA_PlayingMovieURL = "https://megabox.co.kr/on/oh/ohb/SimpleBooking/simpleBookingPage.do" + '?brchNo1=' + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
megabox.using_PlayingMovieURL(MEGA_PlayingMovieURL);
await megabox.geting_PlayingMovie();
console.log(MEGA_PlayingMovieURL, megabox.movie_data);
MEGA_flag = 4;
}
else{
const text1 = "영화를 보실 날짜를 다시 입력해주세요.";
const text2 = "ex)20020409";
SendMessage(eventObj, text1, text2);
}
//원본 코드
// MEGA_date = parseInt(eventObj.message.text);
// if (MEGA_date && MEGA_TheaterLocationCode) {
// MEGA_PlayingMovieURL = "https://megabox.co.kr/on/oh/ohb/SimpleBooking/simpleBookingPage.do" + '?brchNo1=' + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
// console.log(MEGA_PlayingMovieURL)
// async.waterfall[
// megabox.using_PlayingMovieURL(MEGA_PlayingMovieURL),
// megabox.geting_PlayingMovie()
// ]
// MEGA_flag++
// console.log(MEGA_flag);
// }
}
if (MEGA_flag == 4) {
let obj = {};
let n;
let PlayingMovie = "-현재 상영작-\n\n";
let movietitle;
console.log(megabox.movie_data);
for (n = 0; n < Object.keys(megabox.movie_data).length; n++) {
if (megabox.movie_data[n].running == 'Y') {
console.log(megabox.movie_data[n]);
movietitle = megabox.movie_data[n].title;
MEGA_PlayingMovieList[movietitle] = megabox.movie_data[n].movie_num;
}
}
console.log(Object.keys(MEGA_PlayingMovieList).length);
if (Object.keys(MEGA_PlayingMovieList).length == 0) {
PushSingleMessage("현재상영작이 없습니다.\n영화관 선택 단계로 이동합니다.");
setTimeout(function () {
PushMessage("영화관 위치를 입력해주세요", "ex1)강남");
}, 1000);
MEGA_flag = 1;
}else if (Object.keys(MEGA_PlayingMovieList).length == 1) {
PlayingMovie += '1: ' + Object.keys(MEGA_PlayingMovieList)[0];
PushMessage(PlayingMovie, "바로 링크가 보내집니다.");
MEGA_title = MEGA_PlayingMovieList[Object.keys(MEGA_PlayingMovieList)[0]];
setTimeout(function () {
const PC_final_URL = "https://www.megabox.co.kr/booking?rpstMovieNo=" + MEGA_title + "&brchNo1=" + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
const Smartphone_final_URL = "https://m.megabox.co.kr/booking/movie?movieNo="+ MEGA_title + "&brchNo1=" + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
PushURLMessage(PC_final_URL, Smartphone_final_URL);
setTimeout(function () {
initFlag = false;
MEGA_flag = -1;
MEGA_PlayingMovieList = [];
PushSingleMessage("원하시는 브랜드의 번호를 입력해주세요.\n1: CGV\n2: LotteCinema\n3: Megabox\n언제든 브랜드를 바꾸고 싶으시다면 '브랜드'를 입력해주세요.");
}, 1000);
}, 1000);
} else {
let index = 0;
for (let playingmovie = 0; playingmovie < Object.keys(MEGA_PlayingMovieList).length; playingmovie++) {
PlayingMovie += (playingmovie + 1).toString() + '. ' + Object.keys(MEGA_PlayingMovieList)[index++];
PlayingMovie += "\n";
}
console.log(PlayingMovie);
await PushMessage(PlayingMovie, "예매할 영화 번호를 입력해주세요.\n ex)1 (영화 앞 숫자만 입력)");
MEGA_flag = 5;
}
}else if (MEGA_flag == 5) {
const index = parseInt(message.text) - 1;
MEGA_title = MEGA_PlayingMovieList[Object.keys(MEGA_PlayingMovieList)[index]];
const PC_final_URL = "https://www.megabox.co.kr/booking?rpstMovieNo=" + MEGA_title + "&brchNo1=" + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
const Smartphone_final_URL = "https://m.megabox.co.kr/booking/movie?movieNo="+ MEGA_title + "&brchNo1=" + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
console.log(PC_final_URL, Smartphone_final_URL);
PushURLMessage(PC_final_URL, Smartphone_final_URL);
MEGA_PlayingMovieList = []; //영화 리스트 초기화
MegaboxKakaoResultTheater = [];
GetMegaboxKakaoMapURL(MEGA_TheaterLocation);
setTimeout(function () {
console.log(MegaboxKakaoResultTheater[0]);
let MegaboxKakaoResultTheaterNAME = MegaboxKakaoResultTheater[0]['theater_name'];
let MegaboxKakaoResultTheaterURL = MegaboxKakaoResultTheater[0]['theater_url'];
console.log(MegaboxKakaoResultTheaterNAME, MegaboxKakaoResultTheaterURL);
PushMessage(MegaboxKakaoResultTheaterURL, "카카오맵으로 검색한 " + MegaboxKakaoResultTheaterNAME+ "의 위치입니다.");
setTimeout(function () {
//EGA_PlayingMovieList = [];
initFlag = false;
MEGA_flag = -1;
PushSingleMessage("원하시는 브랜드의 번호를 입력해주세요.\n1: CGV\n2: LotteCinema\n3: Megabox\n언제든 브랜드를 바꾸고 싶으시다면 '브랜드'를 입력해주세요.");
}, 1000);
}, 2000);
}
}
res.sendStatus(200);
}))
//});
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);
}
//오늘 날짜 구하기
function GettingToday(){
var today = new Date();
var year = today.getFullYear();
var month = ('0' + (today.getMonth() + 1)).slice(-2);
var day = ('0' + today.getDate()).slice(-2);
var dateString = year + month + day;
var dateInt = parseInt(dateString);
console.log(dateInt);
return dateInt;
}
//24시간마다 데이터 초기화
var dayInMilliseconds = 1000 * 60 * 60 * 24;
setInterval(function() { megabox.init(); console.log("success") },dayInMilliseconds );
//Megabox - Kakao API로 영화관 위치 찾기
GetMegaboxKakaoMapURL= async(LOCATE) => {
let KAKAOOPTION = {
url: "https://dapi.kakao.com/v2/local/search/keyword",
method: "GET",
headers: {
'Authorization': `KakaoAK ${KAKAO_KEY}` // commit 할때 지워야 할것
},
qs: {
'query': '메가박스 ' + LOCATE, // 메가박스 영화관이름
//'category_group_code' : 'CT1',
'size': 5
},
encoding: 'UTF-8'
};
let selectable_theaters = [];
request(KAKAOOPTION, function (err, res, body) {
info_list = JSON.parse(body).documents;
if (!err && res.statusCode == 200) {
info_list.forEach(info => {
//console.log(info.category_name);
if (info.category_name.endsWith("메가박스")) {
const theater_info = {
"theater_name": info.place_name,
"theater_url": info.place_url
};
//console.log(theater_info);
//return theater_info;
selectable_theaters.push(theater_info);
}
});
}
console.log(selectable_theaters);
MegaboxKakaoResultTheater = selectable_theaters;
return;
});
}
//메세지 전송하는 function 모음
function SendMessage(eventObj, text1, text2 = "") { //reply message
request.post(
{
url: REPLY_TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"replyToken": eventObj.replyToken,
"messages": [
{
"type": "text",
"text": text1
},
{
"type": "text",
"text": text2
}
]
}
}, (error, response, body) => {
console.log(body);
});
}
function PushMessage(text1, text2 = "") { //push two message
request.post(
{
url: PUSH_TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"to": `${USER_ID}`,
"messages": [
{
"type": "text",
"text": text1
},
{
"type": "text",
"text": text2
}
]
}
}, (error, response, body) => {
console.log(body)
});
}
function PushSingleMessage(text1) {//push single message
request.post(
{
url: PUSH_TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"to": `${USER_ID}`,
"messages": [
{
"type": "text",
"text": text1
}
]
}
}, (error, response, body) => {
console.log(body)
});
}
function PushURLMessage(pcurl, smartphoneurl) {//push single message
request.post(
{
url: PUSH_TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"to": `${USER_ID}`,
"messages": [
{
"type": "text",
"text": "pc버전 url입니다\n\n" + pcurl
},
{
"type": "text",
"text": "mobile버전 url입니다\n\n" + smartphoneurl
}
]
}
}, (error, response, body) => {
console.log(body)
});
}
This diff could not be displayed because it is too large.
{
"name": "megabox",
"version": "1.0.0",
"description": "",
"main": "app.js",
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1"
},
"keywords": [],
"author": "",
"license": "ISC",
"dependencies": {
"async": "^3.2.3",
"body-parser": "^1.20.0",
"cheerio": "^1.0.0-rc.11",
"chromedriver": "^101.0.0",
"express": "^4.18.1",
"express-async-handler": "^1.2.0",
"moment": "^2.29.3",
"puppeteer": "^14.1.1",
"request": "^2.88.2",
"selenium-webdriver": "^4.1.2"
}
}
const chatbot = require("./app.js");
const request = require('request');
const cheerio = require('cheerio');
const puppeteer = require('puppeteer');
require('chromedriver');
const {Builder,until} = require('selenium-webdriver'); //모듈 불러오기
var webdriver = require('selenium-webdriver');
var By = webdriver.By;
const chrome = require('selenium-webdriver/chrome');//크롬 사용시
const async = require('async')
let express = require('express');
let app = express();
let bodyParser = require('body-parser');
const { timeout } = require('async');
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());
const booking_url = "https://megabox.co.kr/booking?";
exports.booking_url = booking_url;
const rate_url = "https://www.megabox.co.kr/movie";
let r =0;
let movie_data = [];
exports.movie_data = movie_data;
let location_data = [];
exports.location_data = location_data;
let index = 0;
exports.init = ()=>{async.waterfall([//for 동기적 처리
async () => {
const driver = new webdriver.Builder().forBrowser('chrome').setChromeOptions(new chrome.Options().headless()).build();//
driver.get(booking_url);
driver.switchTo().frame(0)//frameBokdMBooking 프레임 가져옴
let seoul = await driver.wait(until.elementsLocated(By.css('#mCSB_4_container>ul>li>#btn')));
let Gyeonggi = await driver.wait(until.elementsLocated(By.css('#mCSB_5_container>ul>li>#btn')));
const Incheon = await driver.wait(until.elementsLocated(By.css('#mCSB_6_container>ul>li>#btn')));
const DCS = await driver.wait(until.elementsLocated(By.css('#mCSB_7_container>ul>li>#btn')));//Daejeon Chungcheong Sejong
const BDG = await driver.wait(until.elementsLocated(By.css('#mCSB_8_container>ul>li>#btn')));//Busan Daegu Gyeongsang
const GJ= await driver.wait(until.elementsLocated(By.css('#mCSB_9_container>ul>li>#btn')));//gwangju_jeonla
const Gangwon = await driver.wait(until.elementsLocated(By.css('#mCSB_10_container>ul>li>#btn')));
const location_list = [seoul, Gyeonggi, Incheon, DCS, BDG, GJ, Gangwon]//
for(let i = 0; i < location_list.length; i++){
for (item of location_list[i]) {
location_data[index++] = {
'LocationName':await item.getAttribute("brch-nm"),
'LocationNum' : await item.getAttribute("brch-no")
}
// let location_name = await item.getAttribute("brch-nm");
// let location_num = await item.getAttribute("brch-no");
// let obj = {};
// obj[location_name]= location_num
// location_data[index++] = obj;
}
}
let movie_list = await driver.wait(until.elementsLocated(By.css('#mCSB_1_container>ul>li>.btn')));
r = 0;
for (item of movie_list) {
//Using getAttribute to get the data
movie_data[r++] = {
'rank' : r,
'title' : await item.getAttribute("movie-nm"),
'movie_num':await item.getAttribute("movie-no"),
}
}
driver.close();
},
async () => {
r = 0;
const browser = await puppeteer.launch({
headless: true
});
const page = await browser.newPage();
await page.goto(rate_url);
const content = await page.content();
const $ = cheerio.load(content);
const $rate_lists = $("ol.list>li");
$rate_lists.each((index, list) => {
const name = $(list).find('div.tit-area > p.tit').attr('title');
const rate = $(list).find('div.rate-date > span.rate').text();
if(movie_data[r].title === name){
movie_data[r++]['rate'] = rate;
}
});
for(i of movie_data){
if(Object.keys(i).length==3){
movie_data[r++]['rate'] = '예매율 0%';
}
}
browser.close();
console.log("Comepleted!");
},
])}
const appdriver = new webdriver.Builder().forBrowser('chrome').setChromeOptions(new chrome.Options().headless()).build();
exports.using_PlayingMovieURL = async(PlayingMovieURL) => {
appdriver.get(PlayingMovieURL);
//appdriver.switchTo().frame(0)
//frameBokdMBooking 프레임 가져옴
}
exports.geting_PlayingMovie= async() => {
let movie_list = await appdriver.wait(until.elementsLocated(By.css('#mCSB_1_container>ul>li>.btn')));
let n = 0;
for (item of movie_list) {
movie_data[n++]['running'] = await item.getAttribute('form-at');
}
console.log("Completed get Running");
}
// let userData = {
// 'Date': '',
// 'location':''
// };
// // const _sleep = (delay) => new Promise((resolve) => setTimeout(resolve, delay));
// app.get('/Megabox', (req, res) => {
// res.send(movie_data);
// })
// app.post('/Megabox', (req, res) => {//사용자에게 Date와 location(영화관 장소) 받아옴
// let PlayingMovieURL;
// userData['Date'] = req.body.Date;
// for(i of location_data){
// if(i['LocationName'] == req.body.location){
// userData['location']=i['LocationNum'];
// break;
// }
// }
// PlayingMovieURL = booking_url + '?brchNo1='+userData['location']+'&playDe='+userData['Date'];//사용자 정보 바탕으로 해당 일자 영화관 영화 상영 여부 확인
// appdriver.get(PlayingMovieURL);
// appdriver.switchTo().frame(0)//frameBokdMBooking 프레임 가져옴
// res.send(movie_data);
// })
// app.post('/Megabox', (req, res) => {//사용자에게 Date와 location(영화관 장소) 받아옴
// userData['Date'] = req.body.Date;
// for(i of location_data){
// if(i['LocationName'] == req.body.location){
// userData['location']=i['LocationNum'];
// break;
// }
// }
// let PlayingMovieURL = booking_url + '?brchNo1='+userData['location']+'&playDe='+userData['Date'];//사용자 정보 바탕으로 해당 일자 영화관 영화 상영 여부 확인
// appdriver.get(PlayingMovieURL);
// appdriver.switchTo().frame(0)//frameBokdMBooking 프레임 가져옴
// res.send(movie_data);
// })
app.get('/Megabox/GetPlayingMovie', async(req, res, next) => {//영화 상영 여부 객체에 넣음
// let movie_list = await appdriver.wait(until.elementsLocated(By.css('#mCSB_1_container>ul>li>.btn')));
// let n = 0;
// for (item of movie_list) {
// movie_data[n++]['running'] = await item.getAttribute('form-at')
// }
using_PlayingMovieURL('https://megabox.co.kr/booking?brchNo1=4451&playDe=20220606');
geting_PlayingMovie();
res.send(PlayingMovieList);
})
app.listen(5000);
\ No newline at end of file
const megabox = require('./Megabox.js');
//const SearchingTheaterAPI = require('./SearchingTheaterAPI');
const async = require('async');
megabox.init(); //메가박스 코드 시작(영화관 리스트 가져오기)
const PUSH_TARGET_URL = 'https://api.line.me/v2/bot/message/push'
const REPLY_TARGET_URL = 'https://api.line.me/v2/bot/message/reply'
const asyncHandler = require('express-async-handler')
const bodyParser = require('body-parser');
const request = require('request');
const moment = require("moment");
const HTTPS = require('https');
const path = require('path');
const fs = require('fs');
const sslport = 23023;
var express = require('express');
var app = express();
app.use(bodyParser.json());
/////////////////////////////////////////////////
// commit 할때 지워야 할것들
const USER_ID = '';
const TOKEN = '';
const domain = "";
/////////////////////////////////////////////////
let MEGA_date;
let MEGA_TheaterLocation;
let MEGA_TheaterLocationCode;
let MEGA_PlayingMovieList = [];
let MEGA_title;
let MEGA_PlayingMovieURL;
let initFlag = false; //브랜드 선택 flag
let MEGA_flag = -1; //메가박스 인지 확인하는 flag
let MEGA_count; //메가박스에서 영화관 판단하는 count
let MEGA_AbleLocationList = []; //메가박스에서 영화관 이름 매치하는 것 저장하는 list
exports.MEGA_PlayingMovieURL = MEGA_PlayingMovieURL;
////////////////////////////////////////////////
//처음 영화관을 가져오는 것까지 대략 30초가 걸림 => 30초 기다리고 메세지 전송
setTimeout(function () {
PushSingleMessage("원하시는 브랜드의 번호를 입력해주세요.\n1: CGV\n2: LotteCinema\n3: Megabox\n언제든 브랜드를 바꾸고 싶으시다면 '브랜드'를 입력해주세요.");
}, 30000);
//app.post('/hook', function (req, res) {
app.post('/hook', asyncHandler(async (req, res, next) => {
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);
//어느 순간에서든 "브랜드"를 입력해 원하는 브랜드 선택
//initFlag : false ==> 브랜드 선택 전
//initFlag : true ==> 브랜드 선택 됨
if (eventObj.message.text == "브랜드") {
initFlag = false;
MEGA_flag = -1;
PushSingleMessage("원하시는 브랜드의 번호를 입력해주세요.\n1: CGV\n2: LotteCinema\n3: Megabox\n언제든 브랜드를 바꾸고 싶으시다면 '브랜드'를 입력해주세요.");
}
//브랜드 선택- 메가박스 인 경우 MEGA_flag를 0으로 두어 메가박스 임을 확인
if (initFlag == false && eventObj.message.text == 3) {
initFlag = true;
MEGA_flag = 0;
}
//메가박스로 브랜드 선택된 경우
if (initFlag == true && MEGA_flag != -1) {
if (MEGA_flag == 0) {
const text1 = "영화관 위치를 입력해주세요";
const text2 = "ex1)강남";
SendMessage(eventObj, text1, text2);
MEGA_flag++;
//PusbuttonhMessage("https://developers.line.biz/en/reference/messaging-api/#message-common-properties");
//console.log(MEGA_flag)
}else if (MEGA_flag === 1) {
MEGA_count = 0; //MEGA_count 초기화
MEGA_AbleLocationList.length = 0; //MEGA_AbleLocationList 초기화
for (i of megabox.location_data) {
if (i['LocationName'].includes(message.text)) {
MEGA_AbleLocationList[MEGA_count++] = i;
}
}
if (MEGA_count == 1) { //결과 1개 => 바로 다음 단계 넘어가기
MEGA_TheaterLocation = MEGA_AbleLocationList[0].LocationName;
MEGA_TheaterLocationCode = MEGA_AbleLocationList[0].LocationNum;
console.log(MEGA_TheaterLocation, MEGA_TheaterLocationCode);
MEGA_flag++;
} else if (MEGA_count > 1) { //결과 2개 이상 => 리스트 출력해주고 번호로 입력받아 넘어가기
console.log(MEGA_AbleLocationList[0], MEGA_AbleLocationList[1]);
let MEGA_OutputString = "원하시는 상영관의 번호를 정확히 입력해주세요\n"; //메가박스 영화관 가능 정보 string
//PushSingleMessage("원하시는 상영관의 번호를 정확히 입력해주세요");
for (let x = 0; x < MEGA_count; x++) {
//PushSingleMessage(String(x + 1) + ": " + MEGA_AbleLocationList[x].LocationName);
MEGA_OutputString += String(x + 1) + ": " + MEGA_AbleLocationList[x].LocationName + "\n";
console.log(String(x + 1), MEGA_AbleLocationList[x].LocationName);
}
MEGA_OutputString += String(MEGA_count + 1) + ": 다시 검색하기";
PushSingleMessage(MEGA_OutputString);
MEGA_flag = 101;
} else {
PushSingleMessage("다시 입력해주세요.");
}
//원본 코드
//console.log(MEGA_flag);
// for (i of megabox.location_data) {
// if (i['LocationName'] === message.text) {
// MEGA_TheaterLocationCode = i['LocationNUm'];
// console.log(MEGA_TheaterLocationCode);
// MEGA_flag++;
// console.log(MEGA_flag)
// break;
// }
// }
} else if (MEGA_flag == 101) {
// 0< input || input > MEGA_count+1 : 다시 검색
let tempNum = parseInt(message.text);
if (tempNum > 0 && tempNum < MEGA_count + 1) {
//번호에 맞는 LocationCode 전달
MEGA_TheaterLocation = MEGA_AbleLocationList[tempNum - 1].LocationName;
MEGA_TheaterLocationCode = MEGA_AbleLocationList[tempNum - 1].LocationNum;
console.log(MEGA_TheaterLocation, MEGA_TheaterLocationCode);
MEGA_flag = 2;
} else {
//다시 장소 입력받기
const text1 = "영화관 위치를 입력해주세요";
const text2 = "ex1)강남";
SendMessage(eventObj, text1, text2);
MEGA_flag = 1;
}
}
//날짜 입력 받기
if (MEGA_flag == 2) {
const text1 = "현재 영화관은 " + MEGA_TheaterLocation + " 입니다.\n영화를 보실 날짜를 입력해주세요.";
const text2 = "ex)20020409";
SendMessage(eventObj, text1, text2);
MEGA_flag = 3;
}
//날짜 확인 및 날짜, 장소에 대해 상영중인 영화 리스트 가져오기
if (moment(message.text, "YYYYMMDD", true).isValid() && MEGA_flag == 3) {
MEGA_date = parseInt(message.text);
//console.log(MEGA_date, MEGA_TheaterLocation);
if (MEGA_date && MEGA_TheaterLocationCode) {
const text1 = "현재상영작을 가져오는 중입니다.";
const text2 = "잠시만 기다려주세요.";
PushMessage(text1, text2);
MEGA_PlayingMovieURL = "https://megabox.co.kr/on/oh/ohb/SimpleBooking/simpleBookingPage.do" + '?brchNo1=' + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
megabox.using_PlayingMovieURL(MEGA_PlayingMovieURL);
await megabox.geting_PlayingMovie();
console.log(MEGA_PlayingMovieURL, megabox.movie_data);
MEGA_flag = 4;
}
//원본 코드
// MEGA_date = parseInt(eventObj.message.text);
// if (MEGA_date && MEGA_TheaterLocationCode) {
// MEGA_PlayingMovieURL = "https://megabox.co.kr/on/oh/ohb/SimpleBooking/simpleBookingPage.do" + '?brchNo1=' + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
// console.log(MEGA_PlayingMovieURL)
// async.waterfall[
// megabox.using_PlayingMovieURL(MEGA_PlayingMovieURL),
// megabox.geting_PlayingMovie()
// ]
// MEGA_flag++
// console.log(MEGA_flag);
// }
}
if (MEGA_flag == 4) {
let obj = {};
let n;
let PlayingMovie = "-현재 상영작-\n\n";
let movietitle;
console.log(megabox.movie_data);
for (n = 0; n < Object.keys(megabox.movie_data).length; n++) {
if (megabox.movie_data[n].running == 'Y') {
console.log(megabox.movie_data[n]);
movietitle = megabox.movie_data[n].title;
MEGA_PlayingMovieList[movietitle] = megabox.movie_data[n].movie_num;
}
}
console.log(Object.keys(megabox.movie_data).length);
if (Object.keys(megabox.movie_data).length == 0) {
PushMessage("현재상영작이 없습니다.","영화관 선택 단계로 이동합니다.");
setTimeout(function () {
PushMessage("영화관 위치를 입력해주세요", "ex1)강남");
}, 1000);
MEGA_flag = 1;
}else if (Object.keys(MEGA_PlayingMovieList).length == 1) {
PlayingMovie += '1. ' + Object.keys(MEGA_PlayingMovieList)[0];
PushMessage(PlayingMovie, "바로 링크가 보내집니다.");
MEGA_title = MEGA_PlayingMovieList[Object.keys(MEGA_PlayingMovieList)[0]];
setTimeout(function () {
const final_URL = "https://www.megabox.co.kr/booking?rpstMovieNo=" + MEGA_title + "&brchNo1=" + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
console.log(final_URL)
PushMessage(final_URL, "링크를 누르면 예매창으로 바로 이동합니다.");
}, 1000);
setTimeout(function () {
initFlag = false;
MEGA_flag = -1;
PushSingleMessage("원하시는 브랜드의 번호를 입력해주세요.\n1: CGV\n2: LotteCinema\n3: Megabox\n언제든 브랜드를 바꾸고 싶으시다면 '브랜드'를 입력해주세요.");
}, 1000);
} else {
let index = 0;
for (let playingmovie = 0; playingmovie < Object.keys(MEGA_PlayingMovieList).length; playingmovie++) {
PlayingMovie += (playingmovie + 1).toString() + '. ' + Object.keys(MEGA_PlayingMovieList)[index++];
PlayingMovie += "\n";
}
console.log(PlayingMovie);
await PushMessage(PlayingMovie, "예매할 영화 번호를 입력해주세요.\n ex)1 (영화 앞 숫자만 입력)");
MEGA_flag = 5;
}
}else if (MEGA_flag == 5) {
const index = parseInt(message.text) - 1;
MEGA_title = MEGA_PlayingMovieList[Object.keys(MEGA_PlayingMovieList)[index]];
const final_URL = "https://www.megabox.co.kr/booking?rpstMovieNo=" + MEGA_title + "&brchNo1=" + MEGA_TheaterLocationCode + '&playDe=' + MEGA_date;
console.log(final_URL);
PushMessage(final_URL, "예매창으로 바로 이동합니다.");
setTimeout(function () {
initFlag = false;
MEGA_flag = -1;
PushSingleMessage("원하시는 브랜드의 번호를 입력해주세요.\n1: CGV\n2: LotteCinema\n3: Megabox\n언제든 브랜드를 바꾸고 싶으시다면 '브랜드'를 입력해주세요.");
}, 1000);
}
}
res.sendStatus(200);
}))
//});
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);
}
//메세지 전송하는 function 모음
function SendMessage(eventObj, text1, text2 = "") { //reply message
request.post(
{
url: REPLY_TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"replyToken": eventObj.replyToken,
"messages": [
{
"type": "text",
"text": text1
},
{
"type": "text",
"text": text2
}
]
}
}, (error, response, body) => {
console.log(body);
});
}
function PushMessage(text1, text2 = "") { //push two message
request.post(
{
url: PUSH_TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"to": `${USER_ID}`,
"messages": [
{
"type": "text",
"text": text1
},
{
"type": "text",
"text": text2
}
]
}
}, (error, response, body) => {
console.log(body)
});
}
function PushSingleMessage(text1) {//push single message
request.post(
{
url: PUSH_TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"to": `${USER_ID}`,
"messages": [
{
"type": "text",
"text": text1
}
]
}
}, (error, response, body) => {
console.log(body)
});
}
function PusbuttonhMessage(final_URL) {
request.post(
{
url: PUSH_TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json:
{
"to": `${USER_ID}`,
"type": "template",
"altText": "this is a carousel template",
"template": {
"type": "carousel",
"columns": [
{
"thumbnailImageUrl": "https://megabox.co.kr/SharedImg/2022/05/16/WApIttC9CrStYU7j7jzFRlc2HsIXBQtY_150.jpg",
"imageBackgroundColor": "#FFFFFF",
"title": "this is menu",
"text": "description",
"defaultAction": {
"type": "uri",
"label": "View detail",
"uri": "https://megabox.co.kr/"
},
"actions": [
{
"type": "message",
"label": "Yes",
"text": "Yes"
},
{
"type": "message",
"label": "Yes",
"text": "Yes"
},
{
"type": "uri",
"label": "View detail",
"uri": "https://megabox.co.kr/"
}
]
},
{
"thumbnailImageUrl": "https://example.com/bot/images/item2.jpg",
"imageBackgroundColor": "#000000",
"title": "this is menu",
"text": "description",
"defaultAction": {
"type": "uri",
"label": "View detail",
"uri": "http://example.com/page/222"
},
"actions": [
{
"type": "message",
"label": "Yes",
"text": "Yes"
},
{
"type": "message",
"label": "Yes",
"text": "Yes"
},
{
"type": "uri",
"label": "View detail",
"uri": "https://megabox.co.kr/"
}
]
}
],
"imageAspectRatio": "rectangle",
"imageSize": "cover"
}
}
// {
// "type": "template",
// //"altText": "This is a buttons template",
// "template": {
// "type": "buttons",
// "thumbnailImageUrl": "https://megabox.co.kr/SharedImg/2022/05/16/WApIttC9CrStYU7j7jzFRlc2HsIXBQtY_150.jpg",
// "imageAspectRatio": "rectangle",
// "imageSize": "cover",
// "imageBackgroundColor": "#FFFFFF",
// "title": "Menu",
// "text": "Please select",
// "actions": [
// {
// "type": "message",
// "label": "Yes",
// "text": "yes"
// },
// {
// "type": "uri",
// "label": "View detail",
// "uri": final_URL
// }
// ]
// }
//}
}
)
}
{
"name": "megabox",
"version": "1.0.0",
"description": "",
"main": "app.js",
"scripts": {
"test": "echo \"Error: no test specified\" && exit 1"
},
"keywords": [],
"author": "",
"license": "ISC",
"dependencies": {
"async": "^3.2.3",
"body-parser": "^1.20.0",
"cheerio": "^1.0.0-rc.11",
"chromedriver": "^101.0.0",
"express": "^4.18.1",
"puppeteer": "^14.1.1",
"express-async-handler": "^1.2.0",
"selenium-webdriver": "^4.1.2"
}
}
\ No newline at end of file
[![node](https://img.shields.io/badge/Node-v16.15.0-important?logo=nodedotjs)](https://nodejs.org/ko/) [![express](https://img.shields.io/badge/Express-4.18.1-important?logo=express)](https://expressjs.com/ko/)
[![puppeteer](https://img.shields.io/badge/puppeteer-v14.1.1-success?logo=Puppeteer)](https://github.com/puppeteer/puppeteer) [![selenium-webdriver](https://img.shields.io/badge/selenium--webdriver-v4.1.2-success?logo=Selenium)](https://www.selenium.dev/documentation/webdriver/) [![express-async-handler](https://img.shields.io/badge/express--async--handler-v1.2.0-success)](https://www.npmjs.com/package/express-async-handler) [![cheerio](https://img.shields.io/badge/cheerio-v1.0.0--rc.11-success)](https://cheerio.js.org/)
# 3대 멀티플렉스 통합 예매 챗봇
......@@ -20,14 +22,46 @@ CGV, 롯데시네마, MEGABOX 영화관의 정보를 통합 제공 및 예매를
+ Line Messaging API
+ Kakao Search-by-Keyword API
## Getting Started
### Prerequisites
## Getting Started
### Installation
1. Kakao REST API관련 KEY를 발급받습니다.
[Kakao Search API](https://developers.kakao.com/)
2. 해당 Repository를 Clone합니다.
`git clone http://khuhub.khu.ac.kr/{YourID}/Multiplex_Ticketing_Platform.git`
3. 코드를 실행하는데 필요한 npm 요소들을 Install합니다.
`npm install`
4. Line Messaging API - Webhook 설정에서 본인의 domain을 입력합니다.
![webhook](https://ifh.cc/g/gQCJw4.png)
5. 코드에 본인이 발급받은 API KEY, Domain을 입력합니다.
`const USER_ID = '{YOUR OWN LINE MESSAGING API USER_ID}';`
`const TOKEN = '{YOUR OWN LINE MESSAGING API TOKEN}';`
`const domain = '{YOUR OWN DOMAIN}';`
`const KAKAO_KEY = '{YOUR OWN KAKAO REST API KEY}';`
6. QR 코드를 휴대폰의 카메라로 스캔하거나 <__@583zdtpz__>을 친구 찾기에 입력하여 "영화관통합예매챗봇"을 추가합니다.
![](https://qr-official.line.me/sid/L/583zdtpz.png)
## Usage
챗봇을 추가하게 되면 자동으로 다음과 같은 메세지가 전송됩니다.
![chatbot start message](https://ifh.cc/g/xfZdhM.png)
영화 예매 링크를 받는데 까지는 총 4가지의 단계를 거치게 됩니다!
# Contributing
1. 브랜드 선택
2. 영화관 선택
2-1.영화관 세부 선택
3. 날짜 선택
4. 상영 중인 영화 목록에서 원하는 영화 선택
위와 같은 단계로 입력이 모두 완료되면 선택하신 영화 예매 링크 및 영화관 위치 링크를 챗봇을 통해 바로 전달받으실 수 있습니다!!
## Contributing
1. 해당 Repository를 Fork합니다.
`git fork http://khuhub.khu.ac.kr/2021105632/Multiplex_Ticketing_Platform.git`
......@@ -51,9 +85,7 @@ Apache License를 사용합니다. LICENSE.txt를 통해 자세한 정보를 확
## Contact
> 임승현 - kevinlsh17@khu.ac.kr
> 이혜인 - hil0409@khu.ac.kr
> 신승민 - s091506@khu.ac.kr
>
> Project Link: [http://khuhub.khu.ac.kr/2021105632/Multiplex_Ticketing_Platform.git](http://khuhub.khu.ac.kr/2021105632/Multiplex_Ticketing_Platform.git)
\ No newline at end of file
......