신원형

temp version

......@@ -14,6 +14,10 @@ const TOKEN = tokens.channel
const id = tokens.id
const pw = tokens.pw
var first = false; //첫 시도인지
var second = false; //첫번째 분류 선택했는지
var destCar = "";
var destination = [];
const canvas = require('./khcanvas')
const selector = require('./schedule_selector')
const weather = require('./weather')
......@@ -87,6 +91,66 @@ function is_good_weather(weather_data) {
return true
}
const csv = require('csv-parser')
const results = [];
function chooseFile () {
if (destCar == "cafe") {
fs.createReadStream('cafe_list.csv')
.pipe(csv())
.on('data', (data) => results.push(data))
.on('end', () => {
console.log(results);
});
}
else if (destCar == "meal") {
fs.createReadStream('meal_list.csv')
.pipe(csv())
.on('data', (data) => results.push(data))
.on('end', () => {
console.log(results);
});
}
else if (destCar == "play") {
fs.createReadStream('play_list.csv')
.pipe(csv())
.on('data', (data) => results.push(data))
.on('end', () => {
console.log(results);
});
}
else if (destCar == "bar") {
fs.createReadStream('bar_list.csv')
.pipe(csv())
.on('data', (data) => results.push(data))
.on('end', () => {
console.log(results);
});
}
}
function randomNum(min, max) {
var randNum = Math.floor(Math.random() * (max - min + 1)) + min;
return randNum;
}
function getX() {
return destination.x;
}
function getY() {
return destination.y;
}
function getName() {
return destination.name;
}
function getAddress() {
return destination.address;
}
/*
1. 사용자가 아무 메세지나 입력?
......@@ -101,8 +165,8 @@ app.use(bodyParser.json());
app.post('/hook', async function (req, res) {
var eventObj = req.body.events[0];
// var source = eventObj.source;
// var message = eventObj.message;
var source = eventObj.source;
var message = eventObj.message;
// request log
console.log('======================', new Date(), '======================');
......@@ -110,37 +174,134 @@ app.post('/hook', async function (req, res) {
console.log('[request source] ', eventObj.source);
console.log('[request message]', eventObj.message);
const today = new Date()
const filter_result = filter_date(today, id, pw)
if (first == false && eventObj.message.text == "처음") {
if (filter_result) {
sendText(eventObj.replyToken, filter_result)
}
const today = new Date()
const filter_result = filter_date(today, id, pw)
if (filter_result) {
sendText(eventObj.replyToken, filter_result)
}
const good_weather = (await weather.get_weather_current()).then(it => {
return is_good_weather(it)
})
if (!good_weather) {
sendText(eventObj.replyToken, "날씨가 나쁨")
}
const good_weather = (await weather.get_weather_current()).then(it => {
return is_good_weather(it)
})
if (!good_weather) {
sendText(eventObj.replyToken, "날씨가 나쁨")
request.post(
{
url: TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"replyToken": eventObj.replyToken,
"messages": [
{
"type": "text",
"text": "카테고리를 선택해주세요.\n1. 식사\n2. 카페\n3. 술\n4. 놀거리\n(숫자만 입력해주세요)"
}
]
},
}, (error, response, body) => {
console.log(body)
});
first = true;
}
else if (first == true && second == false) {
if (eventObj.message.text == 1) { //식사 선택
request.post(
{
url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
"replyToken": eventObj.replyToken,
"messages": [{ "type": "text", "text": "[식사] 키워드를 선택해주세요\n1. 양식\n2. 한식\n3. 중식\n4. 일식\n5. 기타\n(숫자만 입력해주세요)" }]
}
}, (error, response, body) => {
console.log(body)
});
destCar = "meal";
} else if (eventObj.message.text == 2) { //카페 선택
request.post(
{
url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
"replyToken": eventObj.replyToken,
"messages": [{ "type": "text", "text": "[카페] 키워드를 선택해주세요\n1. 감성\n2. 카공\n3. 디저트\n(숫자만 입력해주세요)" }]
}
}, (error, response, body) => {
console.log(body)
});
destCar = "cafe";
} else if (eventObj.message.text == 3) { //술 선택
request.post(
{
url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
"replyToken": eventObj.replyToken,
"messages": [{ "type": "text", "text": "[술] 키워드를 선택해주세요\n1. 소주\n2. 이자카야\n3. 막걸리\n4. 맥주\n(숫자만 입력해주세요)" }]
}
}, (error, response, body) => {
console.log(body)
});
destCar = "bar"
} else if (eventObj.message.text == 4) { //놀거리 선택
request.post(
{
url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
"replyToken": eventObj.replyToken,
"messages": [{ "type": "text", "text": "[놀거리] 키워드를 선택해주세요\n1. 노래방\n2. 피시방\n3. 기타\n(숫자만 입력해주세요)" }]
}
}, (error, response, body) => {
console.log(body)
});
destCar = "play"
}
chooseFile();
second = true;
}
else if (first == true && second == true) {
if (destCar == "meal") {
if (eventObj.message.text == 1) { var randpick = randomNum(0, 6); destination = results[randpick] }
else if (eventObj.message.text == 2) { var randpick = randomNum(7, 19); destination = results[randpick] }
else if (eventObj.message.text == 3) { var randpick = randomNum(20, 25); destination = results[randpick] }
else if (eventObj.message.text == 4) { var randpick = randomNum(26, 36); destination = results[randpick] }
else if (eventObj.message.text == 5) { var randpick = randomNum(37, 46); destination = results[randpick] }
}
else if (destCar == "cafe") {
if (eventObj.message.text == 1) { var randpick = randomNum(0, 5); destination = results[randpick] }
else if (eventObj.message.text == 2) { var randpick = randomNum(6, 12); destination = results[randpick] }
else if (eventObj.message.text == 3) { var randpick = randomNum(13, 17); destination = results[randpick] }
}
else if (destCar == "bar") {
if (eventObj.message.text == 1) { var randpick = randomNum(0, 5); destination = results[randpick] }
else if (eventObj.message.text == 2) { var randpick = randomNum(6, 11); destination = results[randpick] }
else if (eventObj.message.text == 3) { var randpick = randomNum(12, 15); destination = results[randpick] }
else if (eventObj.message.text == 4) { var randpick = randomNum(16, 20); destination = results[randpick] }
}
else if (destCar == "play") {
if (eventObj.message.text == 1) { var randpick = randomNum(0, 3); destination = results[randpick] }
else if (eventObj.message.text == 2) { var randpick = randomNum(4, 8); destination = results[randpick] }
else if (eventObj.message.text == 3) { var randpick = randomNum(9, 13); destination = results[randpick] }
}
sendLocation(eventObj.replyToken, getX(), getY(), getAddress(), getName())
}
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(),
// };
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(app).listen(sslport, () => {
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);
}
}
\ No newline at end of file
......
......@@ -11,6 +11,7 @@
"@types/axios": "^0.14.0",
"@types/selenium-webdriver": "^4.1.0",
"axios": "^0.27.2",
"csv-parser": "^3.0.0",
"express": "^4.18.1",
"express-session": "^1.17.3",
"mocha": "^10.0.0",
......@@ -555,6 +556,20 @@
"node": ">= 8"
}
},
"node_modules/csv-parser": {
"version": "3.0.0",
"resolved": "https://registry.npmjs.org/csv-parser/-/csv-parser-3.0.0.tgz",
"integrity": "sha512-s6OYSXAK3IdKqYO33y09jhypG/bSDHPuyCme/IdEHfWpLf/jKcpitVFyOC6UemgGk8v7Q5u2XE0vvwmanxhGlQ==",
"dependencies": {
"minimist": "^1.2.0"
},
"bin": {
"csv-parser": "bin/csv-parser"
},
"engines": {
"node": ">= 10"
}
},
"node_modules/dashdash": {
"version": "1.14.1",
"resolved": "https://registry.npmjs.org/dashdash/-/dashdash-1.14.1.tgz",
......@@ -1721,6 +1736,11 @@
"node": ">=10"
}
},
"node_modules/minimist": {
"version": "1.2.6",
"resolved": "https://registry.npmjs.org/minimist/-/minimist-1.2.6.tgz",
"integrity": "sha512-Jsjnk4bw3YJqYzbdyBiNsPWHPfO++UGG749Cxs6peCu5Xg4nrena6OVxOYxrQTqww0Jmwt+Ref8rggumkTLz9Q=="
},
"node_modules/mocha": {
"version": "10.0.0",
"resolved": "https://registry.npmjs.org/mocha/-/mocha-10.0.0.tgz",
......@@ -3150,6 +3170,14 @@
"which": "^2.0.1"
}
},
"csv-parser": {
"version": "3.0.0",
"resolved": "https://registry.npmjs.org/csv-parser/-/csv-parser-3.0.0.tgz",
"integrity": "sha512-s6OYSXAK3IdKqYO33y09jhypG/bSDHPuyCme/IdEHfWpLf/jKcpitVFyOC6UemgGk8v7Q5u2XE0vvwmanxhGlQ==",
"requires": {
"minimist": "^1.2.0"
}
},
"dashdash": {
"version": "1.14.1",
"resolved": "https://registry.npmjs.org/dashdash/-/dashdash-1.14.1.tgz",
......@@ -4031,6 +4059,11 @@
"brace-expansion": "^2.0.1"
}
},
"minimist": {
"version": "1.2.6",
"resolved": "https://registry.npmjs.org/minimist/-/minimist-1.2.6.tgz",
"integrity": "sha512-Jsjnk4bw3YJqYzbdyBiNsPWHPfO++UGG749Cxs6peCu5Xg4nrena6OVxOYxrQTqww0Jmwt+Ref8rggumkTLz9Q=="
},
"mocha": {
"version": "10.0.0",
"resolved": "https://registry.npmjs.org/mocha/-/mocha-10.0.0.tgz",
......
......@@ -16,6 +16,7 @@
"@types/axios": "^0.14.0",
"@types/selenium-webdriver": "^4.1.0",
"axios": "^0.27.2",
"csv-parser": "^3.0.0",
"express": "^4.18.1",
"express-session": "^1.17.3",
"mocha": "^10.0.0",
......
var first = false; //첫 시도인지
var second = false; //첫번째 분류 선택했는지
var destCar = "";
var destination = [];
const bodyParser = require('body-parser');
var app = express();
app.use(bodyParser.json());
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 (first == false && eventObj.message.text == "처음") {
request.post(
{
url: TARGET_URL,
headers: {
'Authorization': `Bearer ${TOKEN}`
},
json: {
"replyToken": eventObj.replyToken,
"messages": [
{
"type": "text",
"text": "카테고리를 선택해주세요.\n1. 식사\n2. 카페\n3. 술\n4. 놀거리\n(숫자만 입력해주세요)"
}
]
},
}, (error, response, body) => {
console.log(body)
});
first = true;
}
else if (first == true && second == false) {
if (eventObj.message.text == 1) { //식사 선택
request.post(
{
url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
"replyToken": eventObj.replyToken,
"messages": [{ "type": "text", "text": "[식사] 키워드를 선택해주세요\n1. 양식\n2. 한식\n3. 중식\n4. 일식\n5. 기타\n(숫자만 입력해주세요)" }]
}
}, (error, response, body) => {
console.log(body)
});
destCar = "meal";
} else if (eventObj.message.text == 2) { //카페 선택
request.post(
{
url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
"replyToken": eventObj.replyToken,
"messages": [{ "type": "text", "text": "[카페] 키워드를 선택해주세요\n1. 감성\n2. 카공\n3. 디저트\n(숫자만 입력해주세요)" }]
}
}, (error, response, body) => {
console.log(body)
});
destCar = "cafe";
} else if (eventObj.message.text == 3) { //술 선택
request.post(
{
url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
"replyToken": eventObj.replyToken,
"messages": [{ "type": "text", "text": "[술] 키워드를 선택해주세요\n1. 소주\n2. 이자카야\n3. 막걸리\n4. 맥주\n(숫자만 입력해주세요)" }]
}
}, (error, response, body) => {
console.log(body)
});
destCar = "bar"
} else if (eventObj.message.text == 4) { //놀거리 선택
request.post(
{
url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
"replyToken": eventObj.replyToken,
"messages": [{ "type": "text", "text": "[놀거리] 키워드를 선택해주세요\n1. 노래방\n2. 피시방\n3. 기타\n(숫자만 입력해주세요)" }]
}
}, (error, response, body) => {
console.log(body)
});
destCar = "play"
}
chooseFile();
second = true;
}
else if (first == true && second == true) {
if (destCar == "meal") {
if (eventObj.message.text == 1) { var randpick = randomNum(0, 6); destination = results[randpick] }
else if (eventObj.message.text == 2) { var randpick = randomNum(7, 19); destination = results[randpick] }
else if (eventObj.message.text == 3) { var randpick = randomNum(20, 25); destination = results[randpick] }
else if (eventObj.message.text == 4) { var randpick = randomNum(26, 36); destination = results[randpick] }
else if (eventObj.message.text == 5) { var randpick = randomNum(37, 46); destination = results[randpick] }
}
else if (destCar == "cafe") {
if (eventObj.message.text == 1) { var randpick = randomNum(0, 5); destination = results[randpick] }
else if (eventObj.message.text == 2) { var randpick = randomNum(6, 12); destination = results[randpick] }
else if (eventObj.message.text == 3) { var randpick = randomNum(13, 17); destination = results[randpick] }
}
else if (destCar == "bar") {
if (eventObj.message.text == 1) { var randpick = randomNum(0, 5); destination = results[randpick] }
else if (eventObj.message.text == 2) { var randpick = randomNum(6, 11); destination = results[randpick] }
else if (eventObj.message.text == 3) { var randpick = randomNum(12, 15); destination = results[randpick] }
else if (eventObj.message.text == 4) { var randpick = randomNum(16, 20); destination = results[randpick] }
}
else if (destCar == "play") {
if (eventObj.message.text == 1) { var randpick = randomNum(0, 3); destination = results[randpick] }
else if (eventObj.message.text == 2) { var randpick = randomNum(4, 8); destination = results[randpick] }
else if (eventObj.message.text == 3) { var randpick = randomNum(9, 13); destination = results[randpick] }
}
}
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);
}
const csv = require('csv-parser')
const results = [];
chooseFile = function () {
if (destCar == "cafe") {
fs.createReadStream('cafe_list.csv')
.pipe(csv())
.on('data', (data) => results.push(data))
.on('end', () => {
console.log(results);
});
}
else if (destCar == "meal") {
fs.createReadStream('meal_list.csv')
.pipe(csv())
.on('data', (data) => results.push(data))
.on('end', () => {
console.log(results);
});
}
else if (destCar == "play") {
fs.createReadStream('play_list.csv')
.pipe(csv())
.on('data', (data) => results.push(data))
.on('end', () => {
console.log(results);
});
}
else if (destCar == "bar") {
fs.createReadStream('bar_list.csv')
.pipe(csv())
.on('data', (data) => results.push(data))
.on('end', () => {
console.log(results);
});
}
}
function randomNum(min, max) {
var randNum = Math.floor(Math.random() * (max - min + 1)) + min;
return randNum;
}
function getX() {
return destination.x;
}
function getY() {
return destination.y;
}
function getName() {
return destination.name;
}
function getAddress() {
return destination.address;
}
export { getX, getY, getName, getAddress }
\ No newline at end of file