from flask_restx import Resource, Api, Namespace, fields,reqparse from flask import request,jsonify from flask import Flask, request import os from haversine import haversine from database.database import DB from datetime import datetime import pandas as pd 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) 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'})