Skip to content

GitLab

Commit fb5b6d1c authored by KangMin An's avatar KangMin An
Browse files

Update : 데이터 저장 체계 변경 및, 데이터 꼴 일부 수정.

parent aed98b4c
Hide whitespace changes
Inline Side-by-side
server/Data명세서.md
View file @ fb5b6d1c
......@@ -9,12 +9,14 @@
∟ Local Code (SGG/시군구)
∟ Local Code (EMD/읍면동)
∟ Outside
∟ weather.csv
∟ YYYY (연)
∟ YYYYMM (연/월)
∟ YYYYMMDD (연/월/일)
∟ weather.csv
∟ Users
∟ ID (사용자 개인 ID)
∟ weather.csv
∟ YYYY (연)
∟ YYYYMM (연/월)
∟ YYYYMMDD (연/월/일)
......@@ -24,9 +26,17 @@
데이터가 저장되는 경로의 구조입니다.
- 1차 : 지역별 대분류
- 2차 : 사용자와 외부 정보 분류
- 3차 : 연 / 월 / 일 분류
- 통합 데이터
1. 지역별 분류
2. 외부 / 내부 구분
3. 내부의 경우 사용자 아이디별 구분
- 날짜별 분류 데이터
1. 지역별 대분류
2. 사용자와 외부 정보 분류
3. 연 / 월 / 일 분류
<br><br>
......@@ -38,9 +48,9 @@
외부 데이터는 다음과 같은 형식으로 저장됩니다.
| Month | Date | Hour | Minute | Temperature | Humidity | Press | Wind Speed |
| :---: | :--: | :--: | :----: | :---------: | :------: | :-------: | :--------: |
| 월 | 일 | 시 | 분 | 온도(℃) | 습도(%) | 기압(hPa) | 풍속(m/s) |
| Date | Temperature | Humidity | Press | Wind Speed |
| :-------------------------: | :---------: | :------: | :-------: | ---------- |
| YYYYMMDDHHmm ( 연월일시분 ) | 온도(℃) | 습도(%) | 기압(hPa) | 풍속(m/s) |
<br><br>
......@@ -48,9 +58,9 @@
사용자가 설정한 장소의 데이터는 다음과 같은 형식으로 저장됩니다.
| Month | Date | Hour | Minute | Temperature | Humidity | Lights |
| :---: | :--: | :--: | :----: | :---------: | :------: | :----: |
| 월 | 일 | 시 | 분 | 온도(℃) | 습도(%) | 광도 |
| Date | Temperature | Humidity | Lights |
| :-------------------------: | :---------: | :------: | :----: |
| YYYYMMDDHHmm ( 연월일시분 ) | 온도(℃) | 습도(%) | 광도 |
<br><br>
......
server/src/controllers/dataController.js
View file @ fb5b6d1c
......@@ -31,22 +31,33 @@ const locCodeSep = (code = "") => {
};
// 데이터가 들어온 시간 데이터 생성
const getTimeInfo = () => {
const cur = new Date();
const year = cur.getFullYear();
const month = cur.getMonth() + 1;
const date = cur.getDate();
const hour = cur.getHours();
const minute = cur.getMinutes();
const 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}` : minute,
};
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;
};
......@@ -114,22 +125,18 @@ const storeData = (type, time, loc, dir, data) => {
if (err) console.log(err);
});
// 디렉토리를 새로 생성하는 경우 header 추가.
// 디렉토리를 새로 생성하는 경우 header 추가 및 데이터 추가.
const header = type == OUT ? OUT_DATA_HEADER : IN_DATA_HEADER;
fs.appendFile(dir + `/${fileName}`, header, (err) => {
if (err) console.log(err);
else console.log("Create directory and record header.");
});
// 헤더 추가 후 데이터 추가
fs.appendFile(dir + `/${fileName}`, data, (err) => {
fs.appendFile(dir + `/${fileName}`, header + data, (err) => {
if (err) console.log(err);
else
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.`
);
}
});
}
// 그 외의 에러는 출력
......@@ -151,7 +158,7 @@ const storeData = (type, time, loc, dir, data) => {
};
// 외부 수집기로 부터 들어온 정보 처리
const handleOutData = async (locCode, lat, lng) => {
const handleOutData = async (locCode, date, lat, lng) => {
// OpenWeatherAPI로 부터 지역의 날씨 정보획득을 위해 지역의 경도와 위도, API Key, 단위 기준 metric 전달
const response = await fetch(
`https://api.openweathermap.org/data/2.5/weather?lat=${lat}&lon=${lng}&appid=${process.env.OPENWEATHERMAP_API_KEY}&units=metric`
......@@ -164,26 +171,26 @@ const handleOutData = async (locCode, lat, lng) => {
const wind_speed = json["wind"]["speed"];
const loc = locCodeSep(locCode);
const time = getTimeInfo();
const time = getTimeInfo(date);
const dirs = await getDataDIR(loc, time, OUT, OUTSIDE);
// 데이터 형식 - [ 연 월 일 시 분 | 온도 | 습도 | 기압 | 풍속 ]
const data = `${time.year}${time.month}${time.date}${time.hour}${time.minute},${temp},${humi},${press},${wind_speed}\n`;
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);
};
// 내부 수집기로 부터 들어온 정보 처리
const handleInData = async (id, locCode, temp, humi, lights) => {
const handleInData = async (id, locCode, date, temp, humi, lights) => {
const loc = locCodeSep(locCode);
const time = getTimeInfo();
const time = getTimeInfo(date);
const dirs = await getDataDIR(loc, time, IN, id);
// 데이터 형식 - [ 연 월 일 시 분 | 온도 | 습도 | 광도 ]
const data = `${time.year}${time.month}${time.date}${time.hour}${time.minute},${temp},${humi},${lights}\n`;
const data = `${date},${temp},${humi},${lights}\n`;
storeData(IN, time, loc, dirs.base, data);
storeData(IN, time, loc, dirs.base + dirs.time, data);
......@@ -195,17 +202,19 @@ export const getDataInput = (req, res) => {
if (req.query.type === OUT) {
// 외부 데이터 수집기
const {
query: { locCode, lat, lng },
query: { locCode, date, lat, lng },
} = req;
handleOutData(locCode, lat, lng);
console.log(locCode, date, lat, lng);
// handleOutData(locCode, date, lat, lng);
} else {
// 내부 데이터 수집기 동작
const {
query: { id, locCode, temp, humi, lights },
query: { id, locCode, date, temp, humi, lights },
} = req;
handleInData(id, locCode, temp, humi, lights);
console.log(id, locCode, date, temp, humi, lights);
// handleInData(id, locCode, 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