diff --git a/app/api/services/file_upload.py b/app/api/services/file_upload.py index 961bead..1e474c7 100644 --- a/app/api/services/file_upload.py +++ b/app/api/services/file_upload.py @@ -2,6 +2,7 @@ from flask import jsonify from app.api.enums import KafkaMessage from app.api.services import MyProductsService +from app.models import Members from app.utils.logger import logger from app.api.services.base_service import BaseService from sqlalchemy import func, desc @@ -17,19 +18,42 @@ class FileUploadService(BaseService): @staticmethod def process_file_upload(upload_type: str, file, member_uid): + + file_uid = "I GOT HERE " try: + #Who is this + member_data = Members.get_member_by_uid(member_uid) + if not member_data: + return [] + + final_folder = f"W{member_data.member_id:010d}" + + personal_data = { + "firstname": member_data.firstname, + "lastname": member_data.lastname, + "account_name": member_data.account_name, + "email": member_data.email, + "phone": member_data.phone, + "full_address": member_data.full_address, + "picture": 'https://media.mermsemr.com/media/show/merms-profile', + "country": member_data.country, + } + + save_path = FileUploadService.UPLOAD_FOLDER + "/WEBSITE" + if not os.path.isdir(save_path): + os.makedirs(save_path) logger.info(f'POST CALLED 5 {file.filename}') - save_path = FileUploadService.UPLOAD_FOLDER + "/" + "F000000000001" + save_path = FileUploadService.UPLOAD_FOLDER + "/WEBSITE/" + final_folder + if not os.path.isdir(save_path): + os.makedirs(save_path) + filename = secure_filename(file.filename) final_save_path = os.path.join(save_path, filename) logger.info(f'POST CALLED 6 {final_save_path}') - if not os.path.isdir(save_path): - os.makedirs(save_path) - file.save(final_save_path) response_data = { @@ -39,5 +63,5 @@ class FileUploadService(BaseService): return response_data except Exception as e: - logger.error(f"An error occurred while getting dashboard data: {str(e)}", exc_info=True) + logger.error(f"An error occurred while uploading file: {str(e)}", exc_info=True) return jsonify({"message": "Internal Server Error"}), 500