File name
Commit message
Commit date
from flask_restx import Resource, Api, Namespace, fields,reqparse
from flask import request,jsonify
from flask import Flask, render_template, request
from werkzeug.utils import secure_filename
import os
from haversine import haversine
from database.database import DB
from datetime import datetime
import pandas as pd
from io import StringIO
import jwt
paths = os.getcwd()
Action = Namespace(
name="Action",
description="노드 분석을 위해 사용하는 api.",
)
def find_node(gps_address_y,gps_address_x):
db=DB()
nn_end = None
end_delta = float("inf")
value=0.0001
near_nodes=[]
while near_nodes==[]:
value=value*10
near_nodes=db.db_get_near_node(gps_address_y,gps_address_x,value)
for n in near_nodes:
e_dist = haversine((gps_address_x,gps_address_y), n)
if e_dist < end_delta :
nn_end = n
end_delta = e_dist
return nn_end
@Action.route('/image_summit')
class fileUpload(Resource):
@Action.doc(responses={200: 'Success'})
@Action.doc(responses={500: 'Register Failed'})
def post(self):
if request.method == 'POST':
current_time = datetime.now()
timestamp = current_time.strftime("%Y%m%d%H%M%S")
# 시간을 원하는 형식으로 포맷팅하기 (예: 년-월-일 시:분:초)
formatted_time = current_time.strftime("%Y-%m-%d %H:%M:%S")
# 포맷팅된 현재 시간 출력
token = request.headers.get('Authorization')
print(token)
#print(token)
if not token:
return jsonify({'result': 'fail', 'msg': '토큰이 없습니다.'})
else:
# Decode the token to verify it
decoded_token = jwt.decode(token, "secret", algorithms=['HS256'])
print(decoded_token)
user_id = decoded_token['id']
print("현재 시간,저장요청:", formatted_time)
f = request.files['file']
save_path = f"images/{timestamp}/{user_id}"
os.makedirs(save_path, exist_ok=True)
new_filename = f"{save_path}/{user_id}_{timestamp}.jpg"
print(f)
f.save(new_filename)
print("저장완료", formatted_time)
return {
'save': 'done' # str으로 반환하여 return
}, 200
@Action.route('/gps_update')
class fileUpload(Resource):
def post(self):
db = DB()
token = request.headers.get('Authorization')
if not token:
return jsonify({'result': 'fail', 'msg': '토큰이 없습니다.'})
else:
# Decode the token to verify it
decoded_token = jwt.decode(token, "secret", algorithms=['HS256'])
#print(decoded_token)
user_id = decoded_token['id']
data = request.get_json()
if len(data["trip_id"]) !=64:
return jsonify({500 :"ERROR! INVALID TRIP_ID!"})
if len(data["trip_log"]["timestamp"]) == 0:
return jsonify({500 :"ERROR! 'trip_log' is empty!"})
time_stamp_len = len(data["trip_log"]["timestamp"])
latitude_len = len(data["trip_log"]["latitude"])
longitude_len = len(data["trip_log"]["longitude"])
if time_stamp_len != latitude_len or latitude_len != longitude_len:
return jsonify(
{
500: f"ERROR! Mismatching length of data in trip_log! \n timestamp : {time_stamp_len} \n latitude : {latitude_len} \n longitude : {longitude_len}"
}
)
df = pd.DataFrame(data["trip_log"])
df["user_id"] = data["user_id"]
df["trip_id"] = data["trip_id"]
columns = df.columns
data_csv_block = df.to_csv(header=False, index=False)
print(f"recieved : {data}")
# GPS 데이터베이스에 삽입
db.insert_gps_data(data_csv_block, columns)
return jsonify({'result': f'success'})