workspace/apps/go-crm/internal/db/crud.go

package db

import (
	"database/sql"
	"fmt"
)

type Client struct {
	ClientID int64  `json:"client_id"`
	Name     string `json:"name"`
	Phone    string `json:"phone,omitempty"`
	Email    string `json:"email,omitempty"`
	Address  string `json:"address,omitempty"`
	Notes    string `json:"notes,omitempty"`
	CreatedAt int64 `json:"created_at"`
}

type Customer struct {
	CustomerID int64  `json:"customer_id"`
	ClientID   int64  `json:"client_id"`
	Name       string `json:"name"`
	Phone      string `json:"phone,omitempty"`
	BirthDate  string `json:"birth_date,omitempty"`
	Instagram  string `json:"instagram,omitempty"`
	CreatedAt  int64  `json:"created_at"`
}

type Service struct {
	ServiceID  int64   `json:"service_id"`
	ClientID   int64   `json:"client_id"`
	Name       string  `json:"name"`
	Price      float64 `json:"price,omitempty"`
	Description string `json:"description,omitempty"`
	Duration   string `json:"duration,omitempty"`
	CreatedAt  int64   `json:"created_at"`
}

type Schedule struct {
	ScheduleID     int64  `json:"schedule_id"`
	CustomerID     int64  `json:"customer_id"`
	ClientID       int64  `json:"client_id"`
	PlanDate       string `json:"plan_date,omitempty"`
	ConfirmedDate  string `json:"confirmed_date,omitempty"`
	Time           string `json:"time,omitempty"`
	Status         string `json:"status"`
	Notes          string `json:"notes,omitempty"`
	CreatedAt      int64  `json:"created_at"`
}

type Payment struct {
	PaymentID     int64   `json:"payment_id"`
	ClientID      int64   `json:"client_id"`
	CustomerID    int64   `json:"customer_id"`
	ScheduleID    int64   `json:"schedule_id,omitempty"`
	HasPaid       bool    `json:"has_paid"`
	Amount        float64 `json:"amount,omitempty"`
	PaymentDate   string  `json:"payment_date,omitempty"`
	PaymentMethod string  `json:"payment_method,omitempty"`
	CreatedAt     int64   `json:"created_at"`
}

type Question struct {
	QuestionID int64  `json:"question_id"`
	ClientID   int64  `json:"client_id"`
	CustomerID int64  `json:"customer_id"`
	Question   string `json:"question"`
	Timestamp  int64  `json:"timestamp"`
	Status     string `json:"status"`
	CreatedAt  int64  `json:"created_at"`
}

type Answer struct {
	AnswerID   int64  `json:"answer_id"`
	ClientID   int64  `json:"client_id"`
	QuestionID int64  `json:"question_id"`
	Answer     string `json:"answer"`
	Timestamp  int64  `json:"timestamp"`
	Status     string `json:"status"`
	CreatedAt  int64  `json:"created_at"`
}

func (c *Client) Create(db *sql.DB) error {
	result, err := db.Exec(
		"INSERT INTO clients (name, phone, email, address, notes, created_at) VALUES (?, ?, ?, ?, ?, ?)",
		c.Name, c.Phone, c.Email, c.Address, c.Notes, c.CreatedAt,
	)
	if err != nil {
		return err
	}
	id, err := result.LastInsertId()
	if err != nil {
		return err
	}
	c.ClientID = id
	return nil
}

func (c *Client) Read(db *sql.DB, id int64) error {
	return db.QueryRow(
		"SELECT client_id, name, phone, email, address, notes, created_at FROM clients WHERE client_id = ?",
		id,
	).Scan(&c.ClientID, &c.Name, &c.Phone, &c.Email, &c.Address, &c.Notes, &c.CreatedAt)
}

func (c *Client) Update(db *sql.DB) error {
	_, err := db.Exec(
		"UPDATE clients SET name = ?, phone = ?, email = ?, address = ?, notes = ? WHERE client_id = ?",
		c.Name, c.Phone, c.Email, c.Address, c.Notes, c.ClientID,
	)
	return err
}

func (c *Client) Delete(db *sql.DB, id int64) error {
	_, err := db.Exec("DELETE FROM clients WHERE client_id = ?", id)
	return err
}

func ListClients(db *sql.DB, limit, offset int) ([]Client, error) {
	rows, err := db.Query(
		"SELECT client_id, name, phone, email, address, notes, created_at FROM clients ORDER BY created_at DESC LIMIT ? OFFSET ?",
		limit, offset,
	)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var clients []Client
	for rows.Next() {
		var c Client
		if err := rows.Scan(&c.ClientID, &c.Name, &c.Phone, &c.Email, &c.Address, &c.Notes, &c.CreatedAt); err != nil {
			return nil, err
		}
		clients = append(clients, c)
	}
	return clients, rows.Err()
}

func GetClientByID(db *sql.DB, id int64) (*Client, error) {
	var c Client
	err := db.QueryRow(
		"SELECT client_id, name, phone, email, address, notes, created_at FROM clients WHERE client_id = ?",
		id,
	).Scan(&c.ClientID, &c.Name, &c.Phone, &c.Email, &c.Address, &c.Notes, &c.CreatedAt)
	if err != nil {
		return nil, err
	}
	return &c, nil
}

func (cu *Customer) Create(db *sql.DB) error {
	result, err := db.Exec(
		"INSERT INTO customers (client_id, name, phone, birth_date, instagram, created_at) VALUES (?, ?, ?, ?, ?, ?)",
		cu.ClientID, cu.Name, cu.Phone, cu.BirthDate, cu.Instagram, cu.CreatedAt,
	)
	if err != nil {
		return err
	}
	id, err := result.LastInsertId()
	if err != nil {
		return err
	}
	cu.CustomerID = id
	return nil
}

func ListCustomers(db *sql.DB, clientID int64, limit, offset int) ([]Customer, error) {
	query := "SELECT customer_id, client_id, name, phone, birth_date, instagram, created_at FROM customers"
	var args []interface{}
	if clientID > 0 {
		query += " WHERE client_id = ?"
		args = append(args, clientID)
	}
	query += " ORDER BY created_at DESC LIMIT ? OFFSET ?"
	args = append(args, limit, offset)

	rows, err := db.Query(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var customers []Customer
	for rows.Next() {
		var cu Customer
		if err := rows.Scan(&cu.CustomerID, &cu.ClientID, &cu.Name, &cu.Phone, &cu.BirthDate, &cu.Instagram, &cu.CreatedAt); err != nil {
			return nil, err
		}
		customers = append(customers, cu)
	}
	return customers, rows.Err()
}

func (s *Service) Create(db *sql.DB) error {
	result, err := db.Exec(
		"INSERT INTO services (client_id, name, price, description, duration, created_at) VALUES (?, ?, ?, ?, ?, ?)",
		s.ClientID, s.Name, s.Price, s.Description, s.Duration, s.CreatedAt,
	)
	if err != nil {
		return err
	}
	id, err := result.LastInsertId()
	if err != nil {
		return err
	}
	s.ServiceID = id
	return nil
}

func ListServices(db *sql.DB, clientID int64, limit, offset int) ([]Service, error) {
	query := "SELECT service_id, client_id, name, price, description, duration, created_at FROM services"
	var args []interface{}
	if clientID > 0 {
		query += " WHERE client_id = ?"
		args = append(args, clientID)
	}
	query += " ORDER BY created_at DESC LIMIT ? OFFSET ?"
	args = append(args, limit, offset)

	rows, err := db.Query(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var services []Service
	for rows.Next() {
		var s Service
		if err := rows.Scan(&s.ServiceID, &s.ClientID, &s.Name, &s.Price, &s.Description, &s.Duration, &s.CreatedAt); err != nil {
			return nil, err
		}
		services = append(services, s)
	}
	return services, rows.Err()
}

func (sch *Schedule) Create(db *sql.DB) error {
	result, err := db.Exec(
		"INSERT INTO scheduling (customer_id, client_id, plan_date, confirmed_date, time, status, notes, created_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?)",
		sch.CustomerID, sch.ClientID, sch.PlanDate, sch.ConfirmedDate, sch.Time, sch.Status, sch.Notes, sch.CreatedAt,
	)
	if err != nil {
		return err
	}
	id, err := result.LastInsertId()
	if err != nil {
		return err
	}
	sch.ScheduleID = id
	return nil
}

func ListSchedules(db *sql.DB, clientID, customerID int64, limit, offset int) ([]Schedule, error) {
	query := "SELECT schedule_id, customer_id, client_id, plan_date, confirmed_date, time, status, notes, created_at FROM scheduling WHERE 1=1"
	var args []interface{}
	if clientID > 0 {
		query += " AND client_id = ?"
		args = append(args, clientID)
	}
	if customerID > 0 {
		query += " AND customer_id = ?"
		args = append(args, customerID)
	}
	query += " ORDER BY plan_date DESC LIMIT ? OFFSET ?"
	args = append(args, limit, offset)

	rows, err := db.Query(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var schedules []Schedule
	for rows.Next() {
		var sch Schedule
		if err := rows.Scan(&sch.ScheduleID, &sch.CustomerID, &sch.ClientID, &sch.PlanDate, &sch.ConfirmedDate, &sch.Time, &sch.Status, &sch.Notes, &sch.CreatedAt); err != nil {
			return nil, err
		}
		schedules = append(schedules, sch)
	}
	return schedules, rows.Err()
}

func (p *Payment) Create(db *sql.DB) error {
	result, err := db.Exec(
		"INSERT INTO payments (client_id, customer_id, schedule_id, has_paid, amount, payment_date, payment_method, created_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?)",
		p.ClientID, p.CustomerID, p.ScheduleID, boolToInt(p.HasPaid), p.Amount, p.PaymentDate, p.PaymentMethod, p.CreatedAt,
	)
	if err != nil {
		return err
	}
	id, err := result.LastInsertId()
	if err != nil {
		return err
	}
	p.PaymentID = id
	return nil
}

func ListPayments(db *sql.DB, clientID int64, limit, offset int) ([]Payment, error) {
	query := "SELECT payment_id, client_id, customer_id, schedule_id, has_paid, amount, payment_date, payment_method, created_at FROM payments"
	var args []interface{}
	if clientID > 0 {
		query += " WHERE client_id = ?"
		args = append(args, clientID)
	}
	query += " ORDER BY created_at DESC LIMIT ? OFFSET ?"
	args = append(args, limit, offset)

	rows, err := db.Query(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var payments []Payment
	for rows.Next() {
		var p Payment
		var hasPaid int
		if err := rows.Scan(&p.PaymentID, &p.ClientID, &p.CustomerID, &p.ScheduleID, &hasPaid, &p.Amount, &p.PaymentDate, &p.PaymentMethod, &p.CreatedAt); err != nil {
			return nil, err
		}
		p.HasPaid = hasPaid == 1
		payments = append(payments, p)
	}
	return payments, rows.Err()
}

func (q *Question) Create(db *sql.DB) error {
	result, err := db.Exec(
		"INSERT INTO questions (client_id, customer_id, question, timestamp, status, created_at) VALUES (?, ?, ?, ?, ?, ?)",
		q.ClientID, q.CustomerID, q.Question, q.Timestamp, q.Status, q.CreatedAt,
	)
	if err != nil {
		return err
	}
	id, err := result.LastInsertId()
	if err != nil {
		return err
	}
	q.QuestionID = id
	return nil
}

func ListQuestions(db *sql.DB, clientID int64, limit, offset int) ([]Question, error) {
	query := "SELECT question_id, client_id, customer_id, question, timestamp, status, created_at FROM questions"
	var args []interface{}
	if clientID > 0 {
		query += " WHERE client_id = ?"
		args = append(args, clientID)
	}
	query += " ORDER BY created_at DESC LIMIT ? OFFSET ?"
	args = append(args, limit, offset)

	rows, err := db.Query(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var questions []Question
	for rows.Next() {
		var q Question
		if err := rows.Scan(&q.QuestionID, &q.ClientID, &q.CustomerID, &q.Question, &q.Timestamp, &q.Status, &q.CreatedAt); err != nil {
			return nil, err
		}
		questions = append(questions, q)
	}
	return questions, rows.Err()
}

func (a *Answer) Create(db *sql.DB) error {
	result, err := db.Exec(
		"INSERT INTO answers (client_id, question_id, answer, timestamp, status, created_at) VALUES (?, ?, ?, ?, ?, ?, ?)",
		a.ClientID, a.QuestionID, a.Answer, a.Timestamp, a.Status, a.CreatedAt,
	)
	if err != nil {
		return err
	}
	id, err := result.LastInsertId()
	if err != nil {
		return err
	}
	a.AnswerID = id
	return nil
}

func ListAnswers(db *sql.DB, questionID int64, limit, offset int) ([]Answer, error) {
	query := "SELECT answer_id, client_id, question_id, answer, timestamp, status, created_at FROM answers"
	var args []interface{}
	if questionID > 0 {
		query += " WHERE question_id = ?"
		args = append(args, questionID)
	}
	query += " ORDER BY created_at DESC LIMIT ? OFFSET ?"
	args = append(args, limit, offset)

	rows, err := db.Query(query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var answers []Answer
	for rows.Next() {
		var a Answer
		if err := rows.Scan(&a.AnswerID, &a.ClientID, &a.QuestionID, &a.Answer, &a.Timestamp, &a.Status, &a.CreatedAt); err != nil {
			return nil, err
		}
		answers = append(answers, a)
	}
	return answers, rows.Err()
}

func boolToInt(b bool) int {
	if b {
		return 1
	}
	return 0
}