upload code

Dockerfile

@@ -0,0 +1,15 @@
+FROM python:3.9.7
+
+COPY ./requirements.txt /api/requirements.txt
+COPY ./sabiduria_tool_api /api/sabiduria_tool_api
+
+WORKDIR /api
+
+RUN python -m venv /api/venv
+# Enable venv
+ENV PATH="/api/venv/bin:$PATH"
+
+RUN pip install --upgrade pip
+RUN pip install -r requirements.txt
+
+CMD ["uvicorn", "sabiduria_tool_api.main:app", "--host", "0.0.0.0", "--port", "7860"]

sabiduria_tool_api/api/routes/router.py

@@ -0,0 +1,8 @@
+from fastapi import APIRouter
+
+from sabiduria_tool_api.api.routes import router_sabiduria_tool
+from sabiduria_tool_api.api.routes import router_health_check
+
+api_router = APIRouter()
+api_router.include_router(router_health_check.router_health_check)
+api_router.include_router(router_sabiduria_tool.router_file)

sabiduria_tool_api/api/routes/router_health_check.py

@@ -0,0 +1,9 @@
+from fastapi import APIRouter
+
+from sabiduria_tool_api.services.service_health_check import health_check_message
+
+router_health_check = APIRouter()
+
+@router_health_check.get("/health", name="Health Check")
+async def health_check() -> str:
+    return await health_check_message()

sabiduria_tool_api/api/routes/router_sabiduria_tool.py

@@ -0,0 +1,20 @@
+from starlette.requests import Request
+from fastapi import APIRouter, UploadFile, File
+from fastapi.responses import FileResponse
+
+from sabiduria_tool_api.services.service_sabiduria_tool import FileProcess
+
+from pathlib import Path
+
+router_file = APIRouter()
+ROOT_DIR = str(Path(__file__).parent.parent.parent.parent)
+
+@router_file.post("/file", name="concatane files")
+async def upload_files(
+    request: Request,
+    files: list[UploadFile] = File(description="Multiple files as UploadFile"),
+):
+    processer = FileProcess(files=files, root_dir=ROOT_DIR)
+    await processer.calculate()
+
+    return FileResponse(path=f"{ROOT_DIR}/output.xlsx", filename="output.xlsx")

sabiduria_tool_api/core/config.py

@@ -0,0 +1,3 @@
+APP_VERSION = "0.0.1"
+APP_NAME = "FILE UPLOAD API"
+API_PREFIX = "/api"

sabiduria_tool_api/core/event_handler.py

@@ -0,0 +1,18 @@
+from fastapi import FastAPI
+from typing import Callable
+
+from loguru import logger
+
+logger.level("INFO", color="<green>")
+
+def start_app_handler(app: FastAPI) -> Callable:
+    def startup() -> None:
+        logger.info("Running app start handler.")
+    
+    return startup
+
+def stop_app_handler(app: FastAPI) -> Callable:
+    def shutdown() -> None:
+        logger.info("Running app shutdown handler.")
+
+    return shutdown

sabiduria_tool_api/main.py

@@ -0,0 +1,17 @@
+from fastapi import FastAPI
+
+from sabiduria_tool_api.core.config import API_PREFIX, APP_NAME, APP_VERSION
+from sabiduria_tool_api.core.event_handler import start_app_handler, stop_app_handler
+from sabiduria_tool_api.api.routes.router import api_router
+
+def get_app() -> FastAPI:
+    fast_app = FastAPI(title=APP_NAME, version=APP_VERSION)
+    fast_app.include_router(api_router, prefix=API_PREFIX)
+
+    fast_app.add_event_handler("startup", start_app_handler(fast_app))
+    fast_app.add_event_handler("shutdown", stop_app_handler(fast_app))
+
+    return fast_app
+
+
+app = get_app()

sabiduria_tool_api/services/service_health_check.py

@@ -0,0 +1,2 @@
+async def health_check_message():
+    return "API is runnings"

sabiduria_tool_api/services/service_sabiduria_tool.py

@@ -0,0 +1,119 @@
+from shutil import copyfileobj 
+from pandas import read_excel, DataFrame
+from os import listdir, remove, mkdir
+from os.path import isdir
+from loguru import logger
+
+class FileProcess:
+
+    def __init__(self, files, root_dir) -> None:
+        self.files = files
+        self.data_store_path = f"{root_dir}/sabiduria_tool_api/data/"
+        self.root_dir = root_dir
+        self.final_data = {
+            "Ad": [],
+            "Soyad": [],
+            "TC": [],
+            "ToplamMatrah": [],
+            "Brut": [],
+            "EnAzMatrah": [],
+            "OdenecekTutar": [],
+            "DamgaVergisiKesintiToplami": [],
+            "GelirVergisiKesintiToplami": [],
+            "IstisnaEdilenGelirVergisiToplami": [],
+            "GorevSayisi": [],
+            "EnAzMatrahDosyasi": [],
+            "GorevYerleri": []
+        }
+
+    async def save_files(self) -> None:
+        if isdir(self.data_store_path):
+            old_files = self.get_files()
+            for o_file in old_files:
+                remove(f"{self.data_store_path}{o_file}")
+        else:
+            mkdir(self.data_store_path)
+        for file in self.files:
+            with open(f"{self.data_store_path}{file.filename}", "wb") as destination:
+                copyfileobj(file.file, destination)
+    
+
+    def get_files(self) -> list:
+        all_files = listdir(f"{self.data_store_path}")
+        return all_files
+
+    def preprocess_files(self):
+        all_files = self.get_files()
+        for file in all_files:
+            values = []
+            selected_data = read_excel(f"{self.data_store_path}{file}", skiprows=9)
+            del selected_data[selected_data.columns[0]]
+            selected_data.rename(columns={'Unnamed: 17':'Kesintiler Toplamı'}, inplace=True)
+            selected_data.rename(columns={'Unnamed: 18':'Ödenecek Tutar'}, inplace=True)
+            for i, sira_no in enumerate(selected_data["Sıra No"]):
+                if type(sira_no) != int:
+                    break
+                values.append(selected_data.iloc[[i]].values[0])
+            temp_df = DataFrame(values, columns=selected_data.columns.values)
+            logger.info(f"FILE SAVED TO: {self.data_store_path}{file}")
+            temp_df.to_excel(f"{self.data_store_path}{file}", sheet_name="page1")
+
+    def init_data(self):
+        all_file = self.get_files()
+        for file in all_file:
+            file_data = read_excel(f"{self.data_store_path}{file}")
+            file_name = file.split(".")[0]
+            for i, tc in enumerate(file_data['Tc. No']):
+                # init data
+                if tc not in self.final_data["TC"]:
+                    self.final_data["TC"].append(tc)
+                    self.final_data["Ad"].append(file_data["Adı"][i])
+                    self.final_data["Soyad"].append(file_data["Soyadı"][i])
+                    self.final_data["EnAzMatrah"].append(file_data["Aylık Vergi Matrahı  (Kümülatif)**"][i])
+                    self.final_data["Brut"].append(file_data["Brüt Ücret ****"][i])
+                    self.final_data["ToplamMatrah"].append(file_data["Aylık Vergi Matrahı  (Kümülatif)**"][i] + file_data["Brüt Ücret ****"][i])
+                    self.final_data["OdenecekTutar"].append(file_data["Ödenecek Tutar"][i])
+                    self.final_data["DamgaVergisiKesintiToplami"].append(file_data["Damga Vergisi Kesintisi"][i])
+                    self.final_data["GelirVergisiKesintiToplami"].append(file_data["Gelir Vergisi Kesintisi"][i])
+                    self.final_data["IstisnaEdilenGelirVergisiToplami"].append(file_data["İstisna Edilen Gelir Vergisi"][i])
+                    self.final_data["GorevSayisi"].append(1)
+                    self.final_data["GorevYerleri"].append(file_name + ", ")
+                    self.final_data["EnAzMatrahDosyasi"].append(file_name)
+                # find lower basis
+                else:
+                    id = self.final_data["TC"].index(tc)
+                    if self.final_data["EnAzMatrah"][id] > file_data["Aylık Vergi Matrahı  (Kümülatif)**"][i]:
+                        self.final_data["EnAzMatrah"][id] = file_data["Aylık Vergi Matrahı  (Kümülatif)**"][i]
+                        self.final_data["EnAzMatrahDosyasi"][id] = file_name
+                        self.final_data["Brut"][id] = file_data["Brüt Ücret ****"][i]
+                        self.final_data["ToplamMatrah"][id] = file_data["Aylık Vergi Matrahı  (Kümülatif)**"][i] + file_data["Brüt Ücret ****"][i]
+                        self.final_data["OdenecekTutar"][id] = file_data["Ödenecek Tutar"][i]
+                        self.final_data["DamgaVergisiKesintiToplami"][id] = file_data["Damga Vergisi Kesintisi"][i]
+                        self.final_data["GelirVergisiKesintiToplami"][id] = file_data["Gelir Vergisi Kesintisi"][i]
+                        self.final_data["IstisnaEdilenGelirVergisiToplami"][id] = file_data["İstisna Edilen Gelir Vergisi"][i]
+                        self.final_data["GorevYerleri"][id] = file_name + ", "
+
+    async def calculate(self):
+        await self.save_files()
+        self.preprocess_files()
+        self.init_data()
+        all_files = self.get_files()
+        for file in all_files:
+            file_data = read_excel(f"{self.data_store_path}{file}")
+            file_name = file.split(".")[0]
+            for i, tc in enumerate(file_data['Tc. No']):
+                id = self.final_data["TC"].index(tc)
+                if file_name != self.final_data["EnAzMatrahDosyasi"][id]:
+                    self.final_data["Brut"][id] += file_data["Brüt Ücret ****"][i]
+                    self.final_data["ToplamMatrah"][id] += file_data["Brüt Ücret ****"][i]
+                    self.final_data["OdenecekTutar"][id] += file_data["Ödenecek Tutar"][i]
+                    self.final_data["DamgaVergisiKesintiToplami"][id] += file_data["Damga Vergisi Kesintisi"][i]
+                    self.final_data["GelirVergisiKesintiToplami"][id] += file_data["Gelir Vergisi Kesintisi"][i]
+                    self.final_data["IstisnaEdilenGelirVergisiToplami"][id] += file_data["İstisna Edilen Gelir Vergisi"][i]
+                    self.final_data["GorevSayisi"][id] += 1
+                    self.final_data["GorevYerleri"][id] += file_name + ", "
+
+        del all_files
+        clean_data = DataFrame(self.final_data)
+        del self.final_data
+        clean_data.to_excel(f"{self.root_dir}/output.xlsx", sheet_name="page1")