feat(expense): import expense

internal/expense/database.go

@@ -1,8 +1,10 @@
 package expense
 
 import (
-	"github.com/lib/pq"
 	"nos-comptes/internal/storage/dao/postgresql"
+	"nos-comptes/internal/utils"
+
+	"github.com/lib/pq"
 )
 
 type Database struct {
@@ -14,13 +16,16 @@ func (db *Database) CreateExpense(expense *Expense) error {
 		INSERT INTO public.expense
 			(account_id, value, type_expense, expense_date, libelle)
 		VALUES
-			($1, $2, $3, $4)
+			($1, $2, $3, $4, $5)
 		RETURNING id, created_at
 	`
 
 	err := db.Session.
 		QueryRow(q, expense.AccountId, expense.Value, expense.TypeExpense, expense.ExpenseDate, expense.Libelle).
 		Scan(&expense.ID, &expense.CreatedAt)
+	if err != nil {
+		utils.GetLogger().Info(err)
+	}
 	if errPq, ok := err.(*pq.Error); ok {
 		return postgresql.HandlePgError(errPq)
 	}

internal/expense/handler.go

@@ -1,8 +1,10 @@
 package expense
 
 import (
+	"encoding/csv"
 	"net/http"
 	"nos-comptes/handler"
+	"nos-comptes/internal/account"
 	"nos-comptes/internal/storage/dao/postgresql"
 	"nos-comptes/internal/storage/model"
 	"nos-comptes/internal/storage/validators"
@@ -12,13 +14,48 @@ import (
 )
 
 type Context struct {
-	service *Service
-	db      *Database
+	service        *Service
+	db             *Database
+	accountService *account.Service
 	*handler.Context
 }
 
+func (c *Context) ImportExpenseFromCSV(gc *gin.Context) {
+}
 func (c *Context) CreateAnExpense(gc *gin.Context) {
 	accountID := gc.Param("accountId")
+	userId := gc.Param("userId")
+	csvHeaderFile, err := gc.FormFile("attachment")
+	if err != nil {
+		utils.GetLogger().Info(err)
+		utils.JSONErrorWithMessage(gc.Writer, model.ErrInternalServer, err.Error())
+		return
+	}
+	if err == nil {
+		csvFile, err := csvHeaderFile.Open()
+		if err != nil {
+			utils.GetLogger().Info(err)
+			utils.JSONErrorWithMessage(gc.Writer, model.ErrInternalServer, err.Error())
+			return
+		}
+		csvr := csv.NewReader(csvFile)
+		csvr.FieldsPerRecord = -1
+		csvr.Comma = ';'
+		filedata, err := csvr.ReadAll()
+
+		account, err := c.accountService.GetASpecificAccountForUser(userId, accountID)
+		if err != nil {
+			utils.GetLogger().Info(err)
+			utils.JSONErrorWithMessage(gc.Writer, model.ErrInternalServer, err.Error())
+			return
+		}
+		err = c.service.ProcessCSVFile(filedata, account)
+		if err != nil {
+			utils.JSONErrorWithMessage(gc.Writer, model.ErrInternalServer, err.Error())
+			return
+		}
+		return
+	}
 	var expense Expense
 	var expenseEditable ExpenseEditable
 	if err := gc.BindJSON(&expenseEditable); err != nil {
@@ -26,7 +63,7 @@ func (c *Context) CreateAnExpense(gc *gin.Context) {
 		return
 	}
 	expense = Expense{ExpenseEditable: expenseEditable, AccountId: accountID}
-	err := c.service.CreateExpense(&expense)
+	err = c.service.CreateExpense(&expense)
 	if err != nil {
 		utils.GetLogger().Info(err)
 		utils.JSONErrorWithMessage(gc.Writer, model.ErrInternalServer, err.Error())
@@ -65,5 +102,6 @@ func (c *Context) GetAnExpenses(context *gin.Context) {
 func NewHandler(ctx *handler.Context, db *postgresql.DatabasePostgreSQL) *Context {
 	database := NewDatabase(db)
 	service := NewService(database)
-	return &Context{service: service, db: database, Context: ctx}
+	accountService := account.NewService(account.NewDatabase(db))
+	return &Context{service: service, db: database, accountService: accountService, Context: ctx}
 }

internal/expense/service.go

@@ -1,9 +1,13 @@
 package expense
 
 import (
+	"nos-comptes/internal/account"
 	"nos-comptes/internal/storage/dao"
 	"nos-comptes/internal/storage/model"
 	"nos-comptes/internal/utils"
+	"strconv"
+	"strings"
+	"time"
 )
 
 type Service struct {
@@ -35,6 +39,62 @@ func (s Service) CreateExpense(expense *Expense) error {
 	return s.db.CreateExpense(expense)
 }
 
+func (s Service) ProcessCSVFile(filedata [][]string, account *account.Account) error {
+	switch account.Provider {
+	case "caisse-epargne":
+		return s.processCaisseEpargne(filedata, account)
+	case "boursorama":
+		return s.processBoursorama(filedata, account)
+	case "bnp":
+		return s.processBnp(filedata, account)
+	default:
+		return nil
+	}
+
+}
+
+func (s Service) processCaisseEpargne(filedata [][]string, account *account.Account) error {
+	for _, val := range filedata[4:] {
+		expenseDate, err := time.Parse("02/01/06", val[0])
+		if err != nil {
+			utils.GetLogger().Info(err)
+			continue
+		}
+		amount := val[3]
+		typeExpense := "D"
+		if amount == "" {
+			amount = val[4]
+			typeExpense = "C"
+		}
+		amountParsed, err := strconv.ParseFloat(strings.Trim(strings.ReplaceAll(amount, ",", "."), "+"), 32)
+		if err != nil {
+			utils.GetLogger().Info(err)
+			continue
+		}
+		expense := &Expense{
+			ExpenseEditable: ExpenseEditable{
+				Value:       float32(amountParsed),
+				Libelle:     val[2],
+				TypeExpense: typeExpense,
+				ExpenseDate: expenseDate,
+			},
+			AccountId: account.ID,
+		}
+		s.CreateExpense(expense)
+		utils.GetLogger().Info(val)
+	}
+
+	return nil
+}
+
+func (s Service) processBoursorama(filedata [][]string, account *account.Account) error {
+	return nil
+}
+
+func (s Service) processBnp(filedata [][]string, account *account.Account) error {
+	return nil
+}
+
 func NewService(database *Database) *Service {
 	return &Service{db: database}
 }