socketio.js
3.79 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
const db = require('./db.js');
const secret_key = require('../keys/api_option').key;
const requesting = require('request');
const lat = "37.239795";
const lon = "127.083240";
module.exports = (server, app) => {
const io = require('socket.io', )(server, {
transports: ['websocket']
});
let info = {}
const CALL = (when, what) => {
requesting.get({
// api를 요청할 주소 -- 시크릿키,위도,경도 입력
url: `https://api2.sktelecom.com/weather/${when}/${what}?appKey=${secret_key}&lat=${lat}&lon=${lon}`,
json: true
},
//api에게 응답 받았을때 실행되는 callback function
function (err, api_res, api_body) {
if (err) throw err;
// api의 대답이 있을경우 실행
if (api_res) {
return api_body;
// api_body.weather.minutely[0]
}
});
}
io.on('connection', (socket) => { //웹 페이지 연결시 루프 동작
let API_CALL;
let Current_Weather ={};
let Sensible_T;
let Heat_index={};
let Discomport_index={};
let Ultra_Violet_index={};
let sending_to_client_info={};
socket.on("connection", () => {
API_CALL = setInterval(() => {
Current_Weather = CALL("current","minutely"); //현재날씨 (분별)
Sensible_T = CALL("index","wct"); //체감온도
Heat_index = CALL("index","heat"); //열지수
Discomport_index = CALL("index","th"); //불쾌지수
Ultra_Violet_index = CALL("index","uv"); //자외선지수
info = {
heat : Sensible_T.weather.wIndex.heatIndex[0].current.index, //열지수
sensible_temperature : Sensible_T.weather.wIndex.wctIndex[0].current.index, //체감온도
discomport : Discomport_index.weather.wIndex.thIndex[0].current.index, //불쾌지수
UV : Ultra_Violet_index.weather.wIndex.uvindex[0].day00.index,
windspd : Current_Weather.weather.minutely[0].wind.wspd,
sky : Current_Weather.weather.minutely[0].sky.code,
rain : Current_Weather.weather.minutely[0].rain.last24hour,
current_temperature : Current_Weather.weather.minutely[0].temperature.tc,
lightning : Current_Weather.weather.minutely[0].lightning,
warning : common.alertYn,
typhoon : Current_Weather.common.stormYn,
time : Current_Weather.weather.minutely[0].timeObservation,
death_prob:0
}
info.death_prob += info.sky.substr(5)*1 //하늘 상태에 따라 확률 증가
if(info.lightning===1) //낙뢰시에 확률 증가
info.death_prob += 10;
if(info.typhoon === "Y") //태풍시에 확률 증가
info.death_prob += 10;
if(info.warning === "Y") // 특보 발령시 확률 증가
info.death_prob += 5
//죽을 확률 계산(내맘대로)
info.death_prob =(
(info.heat/8) + (abs(info.sensible_temperature-15)/2) + (info.discomport/10) + (info.UV/5)
+ (info.windspd*3) + (info.rain/10) + (abs(info.current_temperature-15)/2)
);
socket.emit("weatherInfo_minutely_send_to_client",info); // 클라이언트에게 이벤트 발산
}, 60 * 1000); //1분마다 호출
});
socket.on('disconnecting', (reason) => {
clearInterval(API_CALL); //연결 종료시 해제
})
})
}