package commands

import (
	connection "cf-capital/module_server/handlers/connection"
	mail "cf-capital/module_server/handlers/email"
	investmentV1 "cf-capital/module_server/handlers/investment/statement-v1"
	server_handlers "cf-server/server/handlers"
	slack "cf-capital/module_server/handlers/slack"
	"database/sql"
	"encoding/json"
	"fmt"
	log "github.com/rs/zerolog/log"
	"net/http"
	"os"
	"reflect"
	"time"
)

type responseBody struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}

type Accounts struct {
	SchemeID         int64
	AccountID        int64
	XIRR_RATE        float64
	InvestorID       int64
	InitialAmount    float64
	EndDate          string
	StartDate        string
	InterestCredited float64
}

type InterestEntry struct {
	AccountID int64
	Type      string
	Credit    float64
	Debit     float64
}

type Customers struct {
	Name      string
	Mobile    int64
	Scheme    string
	AccountID int64
}

func DailyCron() http.HandlerFunc {
	return func(w http.ResponseWriter, req *http.Request) {
		w.Header().Set("Content-Type", "application/json")

		dt := getDate()

		params := map[string]interface{}{
			"Service":  "CFC Cron Service - 0.0.1",
			"Status": "Running",
			"Date":  dt.Format("2006-01-02"),
		}

		slack.SendSlack("New User Registration", params)

		//Cron Service - Start
		//Daily()
		//End

		params = map[string]interface{}{
			"Service":  "CFC Cron Service - 0.0.1",
			"Status": "Closed",
			"Date":  dt.Format("2006-01-02"),
		}

		slack.SendSlack("New User Registration", params)

		server_handlers.FormatResponse(w, 200)
		_ = json.NewEncoder(w).Encode(responseBody{Status: "OK", Message: "Daily cron - successfully executed"})
	}
}

func Daily() {

	dt := getDate()

	tx, ctx, db := connection.Connect()

	query := "select ac.scheme_id, ac.account_id, s.xirr_rate, investor_id, initial_amount, start_date, COALESCE(end_date, '') as end_date, IF ((select txn_id from transaction where status = 'SUCCESS' and txn_type = 'INTEREST_CREDIT' and date(txn_date) = DATE(NOW() - INTERVAL 1 DAY) and ac.account_id = transaction.account_id limit 1) is null, 0, 1) as interest_credited from account ac left join scheme s on ac.scheme_id = s.scheme_id where account_status = 'ACTIVE' and start_date <= DATE(NOW() - INTERVAL 1 DAY)"
	//query := "select ac.scheme_id, ac.account_id, s.xirr_rate, investor_id, initial_amount, start_date, COALESCE(end_date, '') as end_date, IF ((select txn_id from transaction where status = 'SUCCESS' and txn_type = 'INTEREST_CREDIT' and date(created_at) = DATE(NOW()) and ac.account_id = transaction.account_id) is null, 0, 1) as interest_credited from account ac left join scheme s on ac.scheme_id = s.scheme_id where account_status = 'ACTIVE' and s.scheme_type = 'FLEXI' and end_date = '0000-00-00' and start_date <= DATE(NOW() - INTERVAL 1 DAY)"

	rows, err := tx.Query(query)

	var accounts []Accounts
	var customers []Customers
	today := dt.Format("2006-01-02")

	for rows.Next() {
		var account Accounts

		err = rows.Scan(&account.SchemeID, &account.AccountID, &account.XIRR_RATE, &account.InvestorID, &account.InitialAmount, &account.StartDate, &account.EndDate, &account.InterestCredited)

		if account.InterestCredited == 0 {
			if err != nil {
				log.Print(err.Error())
			}
			if len(account.EndDate) == 0 || account.EndDate == "0000-00-00" {
				account.EndDate = today
			}

			//account.InitialAmount = GetClosingBalance(account.AccountID)

			accounts = append(accounts, account)
			//log.Print(account.InitialAmount)
			//log.Print("AccountID:", account.AccountID)
			//log.Print("start:", account.StartDate)
			//log.Print("end:", account.EndDate)
		} else {
			log.Print("Interest already credited")
		}
	}

	if len(accounts) > 0 {
		log.Print("calculating interest")
		var investment investmentV1.FlexiPlan
		var interestEntries []InterestEntry

		for i := 0; i < len(accounts); i++ {

			var investmentStruct investmentV1.FlexiPlan
			var invest investmentV1.Invest
			var interestEntry InterestEntry
			var customer Customers

			investmentStruct.AccountId = accounts[i].AccountID
			investmentStruct.Principal = accounts[i].InitialAmount
			investmentStruct.MonthlyROI = accounts[i].XIRR_RATE
			investmentStruct.StartDate = accounts[i].StartDate
			investmentStruct.EndDate = accounts[i].EndDate
			investmentStruct.ForIndividualInvestment = accounts[i].EndDate

			investment, _ = investmentStruct.DailyCron()


			txns := getTransactionsByAccountID(tx, accounts[i].AccountID)

			/*log.Print(txns)

			dataJson, _ := json.Marshal(investment)

			log.Print(string(dataJson))
			return*/

			//----- ----- ----- ----- Multiple Interest Credit Entry START ----- ----- ----- -----

			if len(investment.Payout) > 0 {
				//log.Print(len(investment.Payout))

				payoutDateMap := make(map[string]bool)

				for f := 1; f < len(investment.Payout); f++ {
					if investment.Payout[f].Amount > 0 {

						payoutDate := investment.Payout[f].Date

						if ok := payoutDateMap[payoutDate.Format("2006-01-02")]; !ok {

							payoutDateMap[payoutDate.Format("2006-01-02")] = true

							log.Print("Interest calculating Account ID ", accounts[i].AccountID, " ", payoutDate.Format("2006-01-02"))

							//if payoutDate.Format("2006-01-02") < today && isInterestCredited(tx, accounts[i].AccountID, payoutDate) == 0{
							if payoutDate.Format("2006-01-02") < today {

								if ok := txns[payoutDate.Format("2006-01-02")]; !ok {
									interestEntry.AccountID = accounts[i].AccountID
									interestEntry.Type = "Deposit"
									interestEntry.Credit = investment.Payout[f].Amount
									interestEntries = append(interestEntries, interestEntry)

									log.Print("creating CreatePassbook")
									_, err = investmentV1.CreatePassbook(interestEntry.AccountID, tx, ctx, "Interest Accrued for Date "+investment.Payout[f].Date.Format("2006-01-02"), interestEntry.Credit, 0, investment.Payout[f].PrincipalAmount)
									if err != nil {
										tx.Rollback()
										log.Print(err.Error())
									}

									invest.AccountID = accounts[i].AccountID
									invest.Amount = interestEntry.Credit
									invest.PaymentMethod = 1
									invest.PaymentGateway = 1
									invest.MHP = accounts[i].SchemeID
									invest.TxnDate = investment.Payout[f].Date.Format("2006-01-02")
									invest.ReferenceCode = investmentV1.GetRequestID()
									log.Print("creating CreateTransaction")
									_, err = investmentV1.CreateTransaction(invest, tx, ctx, "INTEREST_CREDIT", "SUCCESS")
									if err != nil {
										log.Print(err.Error())
										tx.Rollback()
									}

									if isMonthEnd() == 1 {
										customer.Name = "A"
										customer.Mobile = 0
										customer.Scheme = "A"
										customer.AccountID = 0
										customers = append(customers, customer)
									}
								} else {
									//log.Print("Interest already calculated ", investment.Payout[f].Date, " Account Id", accounts[i].AccountID)
								}
							} else {
								log.Print("Beyond date ", investment.Payout[f].Date, " Account Id", accounts[i].AccountID)
							}
						}
					}
				}
			} else {
				log.Print("No Interest accrued: Account ID ", accounts[i].AccountID)
			}
			//----- ----- ----- ----- Multiple Interest Credit Entry END ----- ----- ----- -----

			//----- ----- ----- ----- Single Interest Credit Entry START ----- ----- ----- -----

			/*if investment.IndividualInvestment.TotalInterest > 0 {

				interestEntry.AccountID = accounts[i].AccountID
				interestEntry.Type = "Deposit"
				interestEntry.Credit = investment.IndividualInvestment.TotalInterest
				interestEntries = append(interestEntries, interestEntry)

				log.Print("creating CreatePassbook")
				_, err = investmentV1.CreatePassbook(interestEntry.AccountID, tx, ctx, "Interest Accrued for Date "+today, interestEntry.Credit, 0)
				if err != nil {
					tx.Rollback()
					log.Print(err.Error())
				}

				invest.AccountID = accounts[i].AccountID
				invest.Amount = interestEntry.Credit
				invest.PaymentMethod = 1
				invest.PaymentGateway = 1
				invest.MHP = accounts[i].SchemeID
				invest.ReferenceCode = investmentV1.GetRequestID()
				log.Print("creating CreateTransaction")
				_, err = investmentV1.CreateTransaction(invest, tx, ctx, "INTEREST_CREDIT")
				if err != nil {
					log.Print(err.Error())
					tx.Rollback()
				}
			} else {
				log.Print("No Interest accrued: Account ID", accounts[i].AccountID)
			}*/

			//----- ----- ----- ----- Single Interest Credit Entry END ----- ----- ----- -----
		}
	} else {
		log.Print("No entries are found")
	}

	if len(customers) > 0 {
		//sendMonthEndCommunication(customers)
	}

	connection.Close(tx, db)
}

func isInterestCredited(tx *sql.Tx, accountId int64, date time.Time) int64 {

	//dt,_ := time.Parse("2006-01-02 15:04:05", date)

	row := tx.QueryRow("select txn_id from transaction where status = 'SUCCESS' and txn_type = 'INTEREST_CREDIT' and account_id = ? and date(txn_date) = ?", accountId, date.Format("2006-01-02"))

	var txn_id int64
	err := row.Scan(&txn_id)
	if err != nil && err != sql.ErrNoRows {
		log.Print("isInterestCredited, error exeception")
		log.Print(err.Error())
		return 1
	}
	if txn_id > 0 {
		return 1
	}
	return 0
}

func getTransactionsByAccountID(tx *sql.Tx, accountId int64) map[string]bool {

	//dt,_ := time.Parse("2006-01-02 15:04:05", date)

	rows, err := tx.Query("select date(txn_date) from transaction where status = 'SUCCESS' and txn_type = 'INTEREST_CREDIT' and account_id = ?", accountId)

	transactions := make(map[string]bool)
	for rows.Next() {
		var txnDate string
		err = rows.Scan(&txnDate)
		if err != nil && err != sql.ErrNoRows {
			log.Print("getTransactionsByAccountID, no entry")
			log.Print(err.Error())
		}else{
			transactions[txnDate] = true
		}
	}
	return transactions
}

func GetClosingBalance(accountId int64) float64 {

	tx, _, db := connection.Connect()

	//Interest Paid Out (Debit)
	row := tx.QueryRow("select IF(amount is null, 0, SUM(amount)) as amount from transaction where txn_type in ('INTEREST_DEBIT', 'INTEREST_DEBIT_MONTHLY', 'WITHDRAW','WITHDRAW_MONTHLY') and status = 'SUCCESS' and account_id = ?", accountId)

	var interestPaidOut float64
	var interestGained float64

	err := row.Scan(&interestPaidOut)
	if err != nil {
		log.Print("GetClosingBalance: interestPaidOut")
		log.Print(err.Error())
		return 0
	}
	//End

	//Interest Gained (Credit)
	row = tx.QueryRow("select IF(amount is null, 0, SUM(amount)) as amount from transaction where txn_type in ('INTEREST_CREDIT', 'DEPOSIT') and status = 'SUCCESS' and account_id = ?", accountId)

	err = row.Scan(&interestGained)
	if err != nil {
		log.Print("GetClosingBalance: interestGained")
		log.Print(err.Error())
		return 0
	}
	//End

	connection.Close(tx, db)
	return interestGained - interestPaidOut
}

func InterestCalculationByDays() {
	log.Print(os.Args[1:])
	dt := getDate()
	format := "2006-01-02"

	tx, ctx, db := connection.Connect()

	query := "select ac.scheme_id, account_id, s.xirr_rate, investor_id, initial_amount, start_date, COALESCE(end_date, '') as end_date from account ac left join scheme s on ac.scheme_id = s.scheme_id where account_status = 'ACTIVE' and s.scheme_type = 'FLEXI' and s.tenure_type = 'D' and end_date is null"

	rows, err := tx.Query(query)

	var accounts []Accounts
	today := dt.Format(format)

	for rows.Next() {
		var account Accounts

		err = rows.Scan(&account.SchemeID, &account.AccountID, &account.XIRR_RATE, &account.InvestorID, &account.InitialAmount, &account.StartDate, &account.EndDate)
		if err != nil {
			log.Print(err.Error())
		}
		if len(account.EndDate) == 0 {
			account.EndDate = today
		}
		accounts = append(accounts, account)
	}

	log.Print("calculating interest")

	if len(accounts) > 0 {

		var interestEntries []InterestEntry

		for i := 0; i < len(accounts); i++ {

			var investmentStruct investmentV1.FlexiPlan
			var invest investmentV1.Invest
			var interestEntry InterestEntry

			investmentStruct.Principal = accounts[i].InitialAmount
			investmentStruct.MonthlyROI = accounts[i].XIRR_RATE
			investmentStruct.StartDate = accounts[i].StartDate
			investmentStruct.EndDate = accounts[i].EndDate

			end, _ := time.Parse(format, accounts[i].EndDate)
			start, _ := time.Parse(format, accounts[i].StartDate)

			diff := end.Sub(start)

			days := int64(diff.Hours() / 24)

			if days > 1 {
				//get only one day's calculation
				days = 1
			}

			log.Print("Days:", days)
			log.Print(investmentStruct)

			//data, _ := investmentStruct.FlexiV1()
			investment, _ := investmentStruct.InterestCalculationByDays(days)
			log.Print(investment.TotalInterestEarned)

			if investment.IndividualInvestment.TotalInterest > 0 {

				interestEntry.AccountID = accounts[i].AccountID
				interestEntry.Type = "Deposit"
				interestEntry.Credit = investment.TotalInterestEarned
				interestEntries = append(interestEntries, interestEntry)

				_, err = investmentV1.CreatePassbook(interestEntry.AccountID, tx, ctx, interestEntry.Type, interestEntry.Credit, 0, 0)
				if err != nil {
					tx.Rollback()
					log.Print(err.Error())
				}

				invest.AccountID = accounts[i].AccountID
				invest.Amount = interestEntry.Credit
				invest.PaymentMethod = 1
				invest.PaymentGateway = 1
				invest.MHP = accounts[i].SchemeID
				invest.ReferenceCode = investmentV1.GetRequestID()
				log.Print("creating CreateTransaction")
				_, err = investmentV1.CreateTransaction(invest, tx, ctx, "INTEREST_CREDIT", "SUCCESS")
				if err != nil {
					log.Print(err.Error())
					tx.Rollback()
				}
			} else {
				log.Print("No Interest accrued: Account ID", accounts[i].AccountID)
			}
		}
	} else {
		log.Print("No entries are found")
	}

	connection.Close(tx, db)
}

func getDate() time.Time {
	loc, _ := time.LoadLocation("Asia/Kolkata")
	dt := time.Now().In(loc)
	return dt
}

func getLastDayOfMonth() int {
	now := time.Now()
	currentYear, currentMonth, _ := now.Date()
	currentLocation := now.Location()

	firstOfMonth := time.Date(currentYear, currentMonth, 1, 0, 0, 0, 0, currentLocation)

	return firstOfMonth.AddDate(0, 1, -1).Day()
}

func getFirstDayOfMonth() int {
	now := time.Now()
	currentYear, currentMonth, _ := now.Date()
	currentLocation := now.Location()

	firstOfMonth := time.Date(currentYear, currentMonth, 1, 0, 0, 0, 0, currentLocation)

	return firstOfMonth.Day()
}

func isMonthEnd() int {
	now := time.Now()
	if now.Day() == getLastDayOfMonth() {
		return 1
	}
	return 0
}

func isMonthStart() int {
	now := time.Now()
	if now.Day() == getFirstDayOfMonth() {
		return 1
	}
	return 0
}

func sendMonthEndCommunication(customers []Customers) {
	currentTime := time.Now()
	dateTime := currentTime.Format("Mon 2006-01-2 15:04:05")

	HtmlBody := "<div style='border-radius:3px;padding:32px 28px;border:1px solid #e9e9e9'>" +

		"<div style='border-bottom-width:1px;border-bottom-color:#f6f6f7;border-bottom-style:solid;color:#6c6c72;font-size:14px;line-height:16px;margin-bottom:16px;padding-bottom:12px;padding-left:0;padding-right:0'><table style='border-collapse:collapse;border-spacing:0;border:0' cellpadding='0' cellspacing='0'><tbody><tr style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol'>" +

		"<td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;margin:0;padding:0'>" +

		"<div></div>" +

		"<a>CreditFair Capital</a>" +

		"</td>" +

		"<td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;color:#ddddde;margin:0;padding:0 8px'> ·</td>" +

		"<td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;margin:0;padding:0'>New Registration</td>" +

		"</tr></tbody></table></div>" +

		"<table style='border-collapse:collapse;border-spacing:0;word-wrap:break-word;width:100%;word-break:break-all;border:0' cellpadding='0' cellspacing='0'><tbody><tr style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol'>" +

		"<td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;margin:0;padding:0 16px 16px 0'><a style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;text-decoration:none;color:#4949e4' target='_blank' data-saferedirecturl='https://www.google.com/url?q=https://links.bugsnag.com/ls/click?upn%3DBIY5nkUQr0HlxeaZ2i147ec0ZxpJpJ2lmwvEwdDBCQaFDwx3WSciDiFGGSEys8ulJPa7NZIyGuyI0ixuPKTSRq7-2Bbydkr4rcsqme0eLPaVcqXDCM3Wt4y8q2cxjw0n9ayRreNGLrg1caOQyjhimJd0c4rdHgcLi9jVeKC2POgn3mCcF6Su5wPTYeok8CnS3JzYR6oDHmxFT-2B7uJ4c1zKEQ-3D-3Dg7c7_dvvvDMjJQYEgbGNoV6RcVxbfjg0XkB-2B-2FbaDq-2FbsQcHbIfo-2BPE5XSsK6jsjnVwhtXgvUW2zU33e7fJFso-2FLYFJUhlf7RvROWcJ-2B-2B51amwlZoWpjfup79Cq1wpDZ5Z9BeYz6LCrDu4iUCNMh-2B3BrajUINEudGl3ztTaV5YjnpZWdaERW2W8ZF4yWocO4PC74LNhou129jkRiflMZy7IxcQSA-3D-3D&amp;source=gmail&amp;ust=1666083924443000&amp;usg=AOvVaw3JD6vqoHitBOTIkCWqzNhr'>" +

		"<div style='color:#636363;font-size:14px'><span style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol'>Monthly Withdrawal </span></div>" +

		"<div style='color:#959595;font-size:12px;line-height:1.75'><span style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol'>" + dateTime + "<span style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;font-feature-settings:&quot;smcp&quot;,&quot;c2sc&quot;,&quot;smcp&quot;,&quot;smcp&quot;;font-size:10px;font-variant:small-caps;font-variant-caps:small-caps'></span></span></div></a></td>" +

		"<td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;margin:0;padding:0' align='right'><table style='border-collapse:collapse;border-spacing:0;line-height:24px;padding-left:32px;white-space:nowrap;border:0' cellpadding='0' cellspacing='0'><tbody><tr style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol'>" +

		"<td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;white-space:nowrap;margin:0;padding:0 4px 0 0'></td>" +

		"<td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;white-space:nowrap;color:#ddddde;font-size:18.5px;font-weight:100;margin:0;padding:0 4px'></td>" +

		"<td align='center' height='20' valign='middle' style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;white-space:nowrap;margin:0;padding:0'></td>" +

		"</tr></tbody></table></td>" +

		"</tr></tbody></table>" +

		"<div style='margin-bottom:16px'><table style='border-collapse:collapse;border-spacing:0;font-family:Consolas,source code pro,Liberation Mono,Courier,monospace;font-size:14px;width:100%;border:0' bgcolor='#f6f6f7' cellpadding='0' cellspacing='0'><tbody><tr style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol'><td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;border-bottom-width:1px;border-bottom-color:#ebebec;border-bottom-style:solid;border-top-width:1px;border-top-color:#ebebec;border-top-style:solid;margin:0;padding:8px 12px'><div style='word-wrap:break-word;word-break:break-all;margin:0'>Registration Summary <span style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;color:#ddddde'>·</span></div></td></tr></tbody></table></div>" +

		"<table style='border-collapse:collapse;border-spacing:0;font-family:Consolas,source code pro,Liberation Mono,Courier,monospace;font-size:14px;line-height:16px;width:100%;margin:16px 0;border:0' cellpadding='0' cellspacing='0'>" +

		"<tbody>" +
		"<tr style='font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol'>" +

		"<td style='border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;color:#9d9da1;white-space:nowrap;margin:0;padding:9px 0 8px' align='right'>Email</td>" +

		"<td style='width:99%;border-collapse:collapse;font-family:-apple-system,BlinkMacSystemFont,Segoe UI,Roboto,Helvetica,Arial,sans-serif,Apple Color Emoji,Segoe UI Emoji,Segoe UI Symbol;color:#48484f;margin:0;padding:9px 16px 8px'>Test</td>" +

		"</tr>" +

		"</tbody></table>" +

		"</div>"

	//storage.Save(customers)

	log.Print("trigger email, month end")
	_, err := mail.Email(HtmlBody, fmt.Sprint("System - Monthly Withdrawal ", dateTime))
	if err != nil {
		log.Print("trigger email error")
		log.Print(err.Error())
	}
}

func (d Customers) String() string {
	v := reflect.ValueOf(d)
	var csvString string
	for i := 0; i < v.NumField(); i++ {
		csvString = fmt.Sprintf("%v%v,", csvString, v.Field(i).Interface())
	}

	return csvString
}