Skip to content

GitLab

Commit 3c19afc1 authored by KangMin An's avatar KangMin An
Browse files

Update : 날씨 데이터 저장 처리 갱신.

parent 1ca14fdc
Hide whitespace changes
Inline Side-by-side
server/src/controllers/dataController.js
View file @ 3c19afc1
import fs from "fs";
import fetch from "node-fetch";
import { serverMSG, statusCode } from "../serverinfo";
import { pool as db, dbMSG, pool } from "../db";
import db from "../db/index";
import dotenv from "dotenv";
dotenv.config();
const OUT = "Out";
const IN = "In";
const OUTSIDE = "Outside";
const USERS = "Users";
const OUT_DATA_HEADER = "date,temp,humi,press,wind_speed\n";
const IN_DATA_HEADER = "date,temp,humi,lights\n";
// 데이터 수집 기로 부터 받아온 지역 코드 세분화
const locCodeSep = (code = "") => {
const DO = code.slice(0, 2);
const SGG = code.slice(0, 5);
const EMD = code;
const loc = {
DO: DO,
SGG: SGG,
EMD: EMD,
};
return loc;
};
// 데이터가 들어온 시간 데이터 생성
const getTimeInfo = (date = null) => {
let time;
if (date == null) {
const now = new Date();
const year = now.getFullYear();
const month = now.getMonth() + 1;
const date = now.getDate();
const hour = now.getHours();
const minute = now.getMinutes();
time = {
year: year,
month: month < 10 ? `0${month}` : month,
date: date < 10 ? `0${date}` : date,
hour: hour < 10 ? `0${hour}` : hour,
minute: minute < 10 ? `0${minute}` : hour,
};
} else {
time = {
year: date.substring(0, 4),
month: date.substring(4, 6),
date: date.substring(6, 8),
hour: date.substring(8, 10),
minute: date.substring(10),
};
}
return time;
};
// Data 접근 경로 반환, DB에 존재 하지 않을 시 Update 동작
const getDataDIR = async (loc, time, type, id) => {
const year = time.year;
const month = time.month;
const date = time.date;
const select_query =
"SELECT DATALINK" +
" " +
`FROM ${type === OUT ? "LOCINFO" : "USER"}` +
" " +
`WHERE ${type === OUT ? `CODE=${loc.EMD}` : `ID='${id}'`}`;
const [row, fields] = await db.execute(select_query);
let baseDIR;
if (row.length != 0) baseDIR = row[0]["DATALINK"];
else baseDIR = null;
// DB에 Data 저장 경로가 존재하지 않을 시 UPDATE
if (baseDIR === null) {
baseDIR =
"/data" +
`/${loc.DO}` +
`/${loc.SGG}` +
`/${loc.EMD}` +
`/${type === OUT ? OUTSIDE : USERS + "/" + id}`;
const update_query =
`UPDATE ${type === OUT ? "LOCINFO" : "USER"}` +
" " +
`SET DATALINK='${baseDIR}'` +
" " +
`WHERE ${type === OUT ? `CODE=${loc.EMD}` : `ID='${id}'`}`;
db.execute(update_query);
}
const timeDIR = `/${year}` + `/${year}${month}` + `/${year}${month}${date}`;
// 지역별 통합 데이터와 지역+날짜별 Data 저장소 경로
const dirs = {
base: process.env.LOCAL_SERVER_DIR + baseDIR,
time: timeDIR,
};
return dirs;
};
// 데이터를 파일 형식으로 저장
const storeData = (type, time, loc, dir, data) => {
const fileName = "weather.csv";
fs.open(dir + `/${fileName}`, "a", (err, fd) => {
if (err) {
// Directory가 존재하지 않는 경우, 생성
if (err.code === "ENOENT") {
console.log("There is no directory.");
fs.mkdirSync(dir, { recursive: true }, (err) => {
if (err) console.log(err);
});
// 디렉토리를 새로 생성하는 경우 header 추가 및 데이터 추가.
const header = type == OUT ? OUT_DATA_HEADER : IN_DATA_HEADER;
fs.appendFile(dir + `/${fileName}`, header + data, (err) => {
if (err) console.log(err);
else {
console.log("Create directory and record header.");
console.log(
`${time.year}/${time.month}/${time.date} ${time.hour}:${
time.minute
} - ${loc.EMD} ${type === OUT ? OUTSIDE : USERS} data append.`
);
}
});
}
// 그 외의 에러는 출력
else console.log(err);
}
// 디렉토리가 존재하는 경우 실행
else {
fs.appendFile(dir + `/${fileName}`, data, (err) => {
if (err) console.log(err);
else
console.log(
`${time.year}/${time.month}/${time.date} ${time.hour}:${
time.minute
} - ${loc.EMD} ${type === OUT ? OUTSIDE : USERS} data append.`
);
});
}
});
};
// 외부 수집기로 부터 들어온 정보 처리
const handleOutData = async (locCode, date, lat, lng) => {
// OpenWeatherAPI로 부터 지역의 날씨 정보획득을 위해 지역의 경도와 위도, API Key, 단위 기준 metric 전달
......@@ -170,36 +19,41 @@ const handleOutData = async (locCode, date, lat, lng) => {
const press = json["main"]["pressure"];
const wind_speed = json["wind"]["speed"];
const loc = locCodeSep(locCode);
const time = getTimeInfo(date);
const dirs = await getDataDIR(loc, time, OUT, OUTSIDE);
// 데이터 형식 - [ 연 월 일 시 분 | 온도 | 습도 | 기압 | 풍속 ]
const data = `${date},${temp},${humi},${press},${wind_speed}\n`;
storeData(OUT, time, loc, dirs.base, data);
storeData(OUT, time, loc, dirs.base + dirs.time, data);
await db.Weather_out.create(
{
loc_code: Number(locCode),
collected_at: date,
temp: temp,
humi: humi,
press: press,
wind_speed: wind_speed,
},
{
logging: false,
}
);
};
// 내부 수집기로 부터 들어온 정보 처리
const handleInData = async (id, locCode, date, temp, humi, lights) => {
const loc = locCodeSep(locCode);
const time = getTimeInfo(date);
const dirs = await getDataDIR(loc, time, IN, id);
// 데이터 형식 - [ 연 월 일 시 분 | 온도 | 습도 | 광도 ]
const data = `${date},${temp},${humi},${lights}\n`;
storeData(IN, time, loc, dirs.base, data);
storeData(IN, time, loc, dirs.base + dirs.time, data);
const handleInData = async (id, date, temp, humi, lights) => {
db.Weather_in.create(
{
host: id,
collected_at: date,
temp: temp,
humi: humi,
lights: lights,
},
{
logging: false,
}
);
};
// 데이터 수신 처리
export const getDataInput = (req, res) => {
try {
if (req.query.type === OUT) {
if (req.query.type === "OUT") {
// 외부 데이터 수집기
const {
query: { locCode, date, lat, lng },
......@@ -214,7 +68,7 @@ export const getDataInput = (req, res) => {
} = req;
console.log(id, locCode, date, temp, humi, lights);
// handleInData(id, locCode, date, temp, humi, lights);
// handleInData(id, date, temp, humi, lights);
}
res.status(statusCode.ok).send(serverMSG.server_ok);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment