02309f74c0
Backend: - Adiciona constraint UNIQUE para 'email' na tabela cadastro_profissionais. - Atualiza schema.sql para converter e-mails vazios para NULL automaticamente. - Modifica query CreateProfissional para usar ON CONFLICT (email) DO UPDATE (Upsert). - Ajusta helper toPgText para tratar string vazia como NULL, permitindo múltiplos profissionais sem e-mail. Frontend: - Adiciona Modal de Detalhes do Usuário na página de Aprovação. - Oculta seletor de função para usuários do tipo 'Cliente'.
619 lines
22 KiB
Go
619 lines
22 KiB
Go
package profissionais
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
|
|
"photum-backend/internal/db/generated"
|
|
|
|
"github.com/google/uuid"
|
|
"github.com/jackc/pgx/v5/pgtype"
|
|
)
|
|
|
|
type Service struct {
|
|
queries *generated.Queries
|
|
}
|
|
|
|
func NewService(queries *generated.Queries) *Service {
|
|
return &Service{queries: queries}
|
|
}
|
|
|
|
type CreateProfissionalInput struct {
|
|
Nome string `json:"nome"`
|
|
FuncaoProfissionalID string `json:"funcao_profissional_id"`
|
|
FuncoesIds []string `json:"funcoes_ids"` // New field
|
|
Endereco *string `json:"endereco"`
|
|
Cidade *string `json:"cidade"`
|
|
Uf *string `json:"uf"`
|
|
Whatsapp *string `json:"whatsapp"`
|
|
CpfCnpjTitular *string `json:"cpf_cnpj_titular"`
|
|
Banco *string `json:"banco"`
|
|
Agencia *string `json:"agencia"`
|
|
ContaPix *string `json:"conta_pix"`
|
|
CarroDisponivel *bool `json:"carro_disponivel"`
|
|
TemEstudio *bool `json:"tem_estudio"`
|
|
QtdEstudio *int `json:"qtd_estudio"`
|
|
TipoCartao *string `json:"tipo_cartao"`
|
|
Observacao *string `json:"observacao"`
|
|
QualTec *int `json:"qual_tec"`
|
|
EducacaoSimpatia *int `json:"educacao_simpatia"`
|
|
DesempenhoEvento *int `json:"desempenho_evento"`
|
|
DispHorario *int `json:"disp_horario"`
|
|
Media *float64 `json:"media"`
|
|
TabelaFree *string `json:"tabela_free"`
|
|
ExtraPorEquipamento *bool `json:"extra_por_equipamento"`
|
|
Equipamentos *string `json:"equipamentos"`
|
|
Email *string `json:"email"`
|
|
AvatarURL *string `json:"avatar_url"`
|
|
TargetUserID *string `json:"target_user_id"` // Optional: For admin creation
|
|
}
|
|
|
|
func (s *Service) Create(ctx context.Context, userID string, input CreateProfissionalInput) (*generated.GetProfissionalByIDRow, error) {
|
|
finalUserID := userID
|
|
if input.TargetUserID != nil && *input.TargetUserID != "" {
|
|
finalUserID = *input.TargetUserID
|
|
}
|
|
|
|
usuarioUUID, err := uuid.Parse(finalUserID)
|
|
if err != nil {
|
|
return nil, errors.New("invalid usuario_id")
|
|
}
|
|
|
|
// Check if CPF/CNPJ is provided and if it exists (Claim flow)
|
|
if input.CpfCnpjTitular != nil && *input.CpfCnpjTitular != "" {
|
|
existing, err := s.queries.GetProfissionalByCPF(ctx, pgtype.Text{String: *input.CpfCnpjTitular, Valid: true})
|
|
if err == nil {
|
|
// Found! Check if already claimed
|
|
if existing.UsuarioID.Valid {
|
|
return nil, errors.New("professional with this CPF already has a user associated")
|
|
}
|
|
|
|
// Not claimed -> Link and Update
|
|
// Helper for merging (prefer new input, fallback to existing)
|
|
mergeStr := func(newVal *string, oldVal pgtype.Text) *string {
|
|
if newVal != nil {
|
|
return newVal
|
|
}
|
|
if oldVal.Valid {
|
|
s := oldVal.String
|
|
return &s
|
|
}
|
|
return nil
|
|
}
|
|
mergeInt := func(newVal *int, oldVal pgtype.Int4) *int {
|
|
if newVal != nil {
|
|
return newVal
|
|
}
|
|
if oldVal.Valid {
|
|
i := int(oldVal.Int32)
|
|
return &i
|
|
}
|
|
return nil
|
|
}
|
|
mergeBool := func(newVal *bool, oldVal pgtype.Bool) *bool {
|
|
if newVal != nil {
|
|
return newVal
|
|
}
|
|
if oldVal.Valid {
|
|
b := oldVal.Bool
|
|
return &b
|
|
}
|
|
return nil
|
|
}
|
|
mergeFloat := func(newVal *float64, oldVal pgtype.Numeric) *float64 {
|
|
if newVal != nil {
|
|
return newVal
|
|
}
|
|
if oldVal.Valid {
|
|
f, _ := oldVal.Float64Value()
|
|
v := f.Float64
|
|
return &v
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Use Update Logic with Merging
|
|
updateInput := UpdateProfissionalInput{
|
|
Nome: input.Nome,
|
|
FuncaoProfissionalID: input.FuncaoProfissionalID,
|
|
FuncoesIds: input.FuncoesIds,
|
|
Endereco: mergeStr(input.Endereco, existing.Endereco),
|
|
Cidade: mergeStr(input.Cidade, existing.Cidade),
|
|
Uf: mergeStr(input.Uf, existing.Uf),
|
|
Whatsapp: mergeStr(input.Whatsapp, existing.Whatsapp),
|
|
CpfCnpjTitular: mergeStr(input.CpfCnpjTitular, existing.CpfCnpjTitular),
|
|
Banco: mergeStr(input.Banco, existing.Banco),
|
|
Agencia: mergeStr(input.Agencia, existing.Agencia),
|
|
ContaPix: mergeStr(input.ContaPix, existing.ContaPix),
|
|
CarroDisponivel: mergeBool(input.CarroDisponivel, existing.CarroDisponivel),
|
|
TemEstudio: mergeBool(input.TemEstudio, existing.TemEstudio),
|
|
QtdEstudio: mergeInt(input.QtdEstudio, existing.QtdEstudio),
|
|
TipoCartao: mergeStr(input.TipoCartao, existing.TipoCartao),
|
|
Observacao: mergeStr(input.Observacao, existing.Observacao),
|
|
QualTec: mergeInt(input.QualTec, existing.QualTec),
|
|
EducacaoSimpatia: mergeInt(input.EducacaoSimpatia, existing.EducacaoSimpatia),
|
|
DesempenhoEvento: mergeInt(input.DesempenhoEvento, existing.DesempenhoEvento),
|
|
DispHorario: mergeInt(input.DispHorario, existing.DispHorario),
|
|
Media: mergeFloat(input.Media, existing.Media),
|
|
TabelaFree: mergeStr(input.TabelaFree, existing.TabelaFree),
|
|
ExtraPorEquipamento: mergeBool(input.ExtraPorEquipamento, existing.ExtraPorEquipamento),
|
|
Equipamentos: mergeStr(input.Equipamentos, existing.Equipamentos),
|
|
Email: mergeStr(input.Email, existing.Email),
|
|
AvatarURL: mergeStr(input.AvatarURL, existing.AvatarUrl),
|
|
}
|
|
|
|
// Link User to Professional
|
|
idStr := uuid.UUID(existing.ID.Bytes).String()
|
|
err = s.queries.LinkUserToProfessional(ctx, generated.LinkUserToProfessionalParams{
|
|
ID: existing.ID,
|
|
UsuarioID: pgtype.UUID{Bytes: usuarioUUID, Valid: true},
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Update other fields
|
|
_, err = s.Update(ctx, idStr, updateInput)
|
|
if err != nil {
|
|
// Should rollback link? Ideally within transaction.
|
|
// For now, return error.
|
|
return nil, err
|
|
}
|
|
|
|
// Return updated professional (fetch again to be sure or use return from Update)
|
|
return s.GetByID(ctx, idStr)
|
|
}
|
|
}
|
|
|
|
var funcaoUUID uuid.UUID
|
|
var funcaoValid bool
|
|
if input.FuncaoProfissionalID != "" {
|
|
parsed, err := uuid.Parse(input.FuncaoProfissionalID)
|
|
if err != nil {
|
|
return nil, errors.New("invalid funcao_profissional_id")
|
|
}
|
|
funcaoUUID = parsed
|
|
funcaoValid = true
|
|
} else {
|
|
funcaoValid = false
|
|
}
|
|
|
|
params := generated.CreateProfissionalParams{
|
|
UsuarioID: pgtype.UUID{Bytes: usuarioUUID, Valid: true},
|
|
Nome: input.Nome,
|
|
FuncaoProfissionalID: pgtype.UUID{Bytes: funcaoUUID, Valid: funcaoValid},
|
|
Endereco: toPgText(input.Endereco),
|
|
Cidade: toPgText(input.Cidade),
|
|
Uf: toPgText(input.Uf),
|
|
Whatsapp: toPgText(input.Whatsapp),
|
|
CpfCnpjTitular: toPgText(input.CpfCnpjTitular),
|
|
Banco: toPgText(input.Banco),
|
|
Agencia: toPgText(input.Agencia),
|
|
ContaPix: toPgText(input.ContaPix),
|
|
CarroDisponivel: toPgBool(input.CarroDisponivel),
|
|
TemEstudio: toPgBool(input.TemEstudio),
|
|
QtdEstudio: toPgInt4(input.QtdEstudio),
|
|
TipoCartao: toPgText(input.TipoCartao),
|
|
Observacao: toPgText(input.Observacao),
|
|
QualTec: toPgInt4(input.QualTec),
|
|
EducacaoSimpatia: toPgInt4(input.EducacaoSimpatia),
|
|
DesempenhoEvento: toPgInt4(input.DesempenhoEvento),
|
|
DispHorario: toPgInt4(input.DispHorario),
|
|
Media: toPgNumeric(input.Media),
|
|
TabelaFree: toPgText(input.TabelaFree),
|
|
ExtraPorEquipamento: toPgBool(input.ExtraPorEquipamento),
|
|
Equipamentos: toPgText(input.Equipamentos),
|
|
Email: toPgText(input.Email),
|
|
AvatarUrl: toPgText(input.AvatarURL),
|
|
}
|
|
|
|
prof, err := s.queries.CreateProfissional(ctx, params)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Insert multiple functions if provided
|
|
if len(input.FuncoesIds) > 0 {
|
|
for _, fid := range input.FuncoesIds {
|
|
fUUID, err := uuid.Parse(fid)
|
|
if err == nil {
|
|
_ = s.queries.AddFunctionToProfessional(ctx, generated.AddFunctionToProfessionalParams{
|
|
ProfissionalID: pgtype.UUID{Bytes: prof.ID.Bytes, Valid: true},
|
|
FuncaoID: pgtype.UUID{Bytes: fUUID, Valid: true},
|
|
})
|
|
}
|
|
}
|
|
} else if funcaoValid {
|
|
// If no list provided but single ID is, insert that one too into junction
|
|
_ = s.queries.AddFunctionToProfessional(ctx, generated.AddFunctionToProfessionalParams{
|
|
ProfissionalID: pgtype.UUID{Bytes: prof.ID.Bytes, Valid: true},
|
|
FuncaoID: pgtype.UUID{Bytes: funcaoUUID, Valid: true},
|
|
})
|
|
}
|
|
|
|
// Fetch full object to return
|
|
return s.GetByID(ctx, uuid.UUID(prof.ID.Bytes).String())
|
|
}
|
|
|
|
func (s *Service) List(ctx context.Context) ([]generated.ListProfissionaisRow, error) {
|
|
return s.queries.ListProfissionais(ctx)
|
|
}
|
|
|
|
func (s *Service) GetByID(ctx context.Context, id string) (*generated.GetProfissionalByIDRow, error) {
|
|
uuidVal, err := uuid.Parse(id)
|
|
if err != nil {
|
|
return nil, errors.New("invalid id")
|
|
}
|
|
prof, err := s.queries.GetProfissionalByID(ctx, pgtype.UUID{Bytes: uuidVal, Valid: true})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &prof, nil
|
|
}
|
|
|
|
type UpdateProfissionalInput struct {
|
|
Nome string `json:"nome"`
|
|
FuncaoProfissionalID string `json:"funcao_profissional_id"`
|
|
FuncoesIds []string `json:"funcoes_ids"` // New field
|
|
Endereco *string `json:"endereco"`
|
|
Cidade *string `json:"cidade"`
|
|
Uf *string `json:"uf"`
|
|
Whatsapp *string `json:"whatsapp"`
|
|
CpfCnpjTitular *string `json:"cpf_cnpj_titular"`
|
|
Banco *string `json:"banco"`
|
|
Agencia *string `json:"agencia"`
|
|
ContaPix *string `json:"conta_pix"`
|
|
CarroDisponivel *bool `json:"carro_disponivel"`
|
|
TemEstudio *bool `json:"tem_estudio"`
|
|
QtdEstudio *int `json:"qtd_estudio"`
|
|
TipoCartao *string `json:"tipo_cartao"`
|
|
Observacao *string `json:"observacao"`
|
|
QualTec *int `json:"qual_tec"`
|
|
EducacaoSimpatia *int `json:"educacao_simpatia"`
|
|
DesempenhoEvento *int `json:"desempenho_evento"`
|
|
DispHorario *int `json:"disp_horario"`
|
|
Media *float64 `json:"media"`
|
|
TabelaFree *string `json:"tabela_free"`
|
|
ExtraPorEquipamento *bool `json:"extra_por_equipamento"`
|
|
Equipamentos *string `json:"equipamentos"`
|
|
Email *string `json:"email"`
|
|
AvatarURL *string `json:"avatar_url"`
|
|
}
|
|
|
|
func (s *Service) Update(ctx context.Context, id string, input UpdateProfissionalInput) (*generated.CadastroProfissionai, error) {
|
|
uuidVal, err := uuid.Parse(id)
|
|
if err != nil {
|
|
return nil, errors.New("invalid id")
|
|
}
|
|
|
|
funcaoUUID, err := uuid.Parse(input.FuncaoProfissionalID)
|
|
if err != nil {
|
|
return nil, errors.New("invalid funcao_profissional_id")
|
|
}
|
|
|
|
params := generated.UpdateProfissionalParams{
|
|
ID: pgtype.UUID{Bytes: uuidVal, Valid: true},
|
|
Nome: input.Nome,
|
|
FuncaoProfissionalID: pgtype.UUID{Bytes: funcaoUUID, Valid: true},
|
|
Endereco: toPgText(input.Endereco),
|
|
Cidade: toPgText(input.Cidade),
|
|
Uf: toPgText(input.Uf),
|
|
Whatsapp: toPgText(input.Whatsapp),
|
|
CpfCnpjTitular: toPgText(input.CpfCnpjTitular),
|
|
Banco: toPgText(input.Banco),
|
|
Agencia: toPgText(input.Agencia),
|
|
ContaPix: toPgText(input.ContaPix),
|
|
CarroDisponivel: toPgBool(input.CarroDisponivel),
|
|
TemEstudio: toPgBool(input.TemEstudio),
|
|
QtdEstudio: toPgInt4(input.QtdEstudio),
|
|
TipoCartao: toPgText(input.TipoCartao),
|
|
Observacao: toPgText(input.Observacao),
|
|
QualTec: toPgInt4(input.QualTec),
|
|
EducacaoSimpatia: toPgInt4(input.EducacaoSimpatia),
|
|
DesempenhoEvento: toPgInt4(input.DesempenhoEvento),
|
|
DispHorario: toPgInt4(input.DispHorario),
|
|
Media: toPgNumeric(input.Media),
|
|
TabelaFree: toPgText(input.TabelaFree),
|
|
ExtraPorEquipamento: toPgBool(input.ExtraPorEquipamento),
|
|
Equipamentos: toPgText(input.Equipamentos),
|
|
Email: toPgText(input.Email),
|
|
AvatarUrl: toPgText(input.AvatarURL),
|
|
}
|
|
|
|
prof, err := s.queries.UpdateProfissional(ctx, params)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Update functions logic
|
|
// If input.FuncoesIds is provided (even empty), replace all.
|
|
// If nil, maybe keep existing? For simplicity, let's assume if present we update.
|
|
// Actually frontend should send full list.
|
|
if input.FuncoesIds != nil {
|
|
// Clear existing
|
|
_ = s.queries.ClearProfessionalFunctions(ctx, pgtype.UUID{Bytes: uuidVal, Valid: true})
|
|
// Add new
|
|
for _, fid := range input.FuncoesIds {
|
|
fUUID, err := uuid.Parse(fid)
|
|
if err == nil {
|
|
_ = s.queries.AddFunctionToProfessional(ctx, generated.AddFunctionToProfessionalParams{
|
|
ProfissionalID: pgtype.UUID{Bytes: uuidVal, Valid: true},
|
|
FuncaoID: pgtype.UUID{Bytes: fUUID, Valid: true},
|
|
})
|
|
}
|
|
}
|
|
} else if input.FuncaoProfissionalID != "" {
|
|
// If legacy field matches, ensure it's in junction set too?
|
|
// Or maybe we treat legacy ID as primary and sync it.
|
|
// For now, let's just make sure at least one exists if provided.
|
|
// But usually update sends all data.
|
|
}
|
|
|
|
return &prof, nil
|
|
}
|
|
|
|
func (s *Service) GetByUserID(ctx context.Context, userID string) (*generated.GetProfissionalByUsuarioIDRow, error) {
|
|
uuidVal, err := uuid.Parse(userID)
|
|
if err != nil {
|
|
return nil, errors.New("invalid user id")
|
|
}
|
|
|
|
prof, err := s.queries.GetProfissionalByUsuarioID(ctx, pgtype.UUID{Bytes: uuidVal, Valid: true})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &prof, nil
|
|
}
|
|
|
|
func (s *Service) Delete(ctx context.Context, id string) error {
|
|
fmt.Printf("[DEBUG] Deleting Professional: %s\n", id)
|
|
uuidVal, err := uuid.Parse(id)
|
|
if err != nil {
|
|
return errors.New("invalid id")
|
|
}
|
|
|
|
// Get professional to find associated user
|
|
prof, err := s.queries.GetProfissionalByID(ctx, pgtype.UUID{Bytes: uuidVal, Valid: true})
|
|
if err != nil {
|
|
fmt.Printf("[DEBUG] Failed to get professional %s: %v\n", id, err)
|
|
return err
|
|
}
|
|
|
|
fmt.Printf("[DEBUG] Prof Found:: ID=%s, UsuarioID.Valid=%v, UsuarioID=%s\n",
|
|
uuid.UUID(prof.ID.Bytes).String(),
|
|
prof.UsuarioID.Valid,
|
|
uuid.UUID(prof.UsuarioID.Bytes).String())
|
|
|
|
// Delete associated user first (ensures login access is revoked)
|
|
if prof.UsuarioID.Valid {
|
|
fmt.Printf("[DEBUG] Attempting to delete User ID: %s\n", uuid.UUID(prof.UsuarioID.Bytes).String())
|
|
err = s.queries.DeleteUsuario(ctx, prof.UsuarioID)
|
|
if err != nil {
|
|
fmt.Printf("[DEBUG] Failed to delete User: %v\n", err)
|
|
return err
|
|
}
|
|
fmt.Println("[DEBUG] User deleted successfully.")
|
|
} else {
|
|
fmt.Println("[DEBUG] UsuarioID is invalid/null. Skipping User deletion.")
|
|
}
|
|
|
|
// Delete professional profile
|
|
fmt.Println("[DEBUG] Deleting Professional profile...")
|
|
err = s.queries.DeleteProfissional(ctx, pgtype.UUID{Bytes: uuidVal, Valid: true})
|
|
if err != nil {
|
|
fmt.Printf("[DEBUG] Failed to delete Professional: %v\n", err)
|
|
return err
|
|
}
|
|
fmt.Println("[DEBUG] Professional deleted successfully.")
|
|
|
|
return nil
|
|
}
|
|
|
|
// Helpers
|
|
|
|
func toPgText(s *string) pgtype.Text {
|
|
if s == nil || *s == "" {
|
|
return pgtype.Text{Valid: false}
|
|
}
|
|
return pgtype.Text{String: *s, Valid: true}
|
|
}
|
|
|
|
func toPgBool(b *bool) pgtype.Bool {
|
|
if b == nil {
|
|
return pgtype.Bool{Valid: false}
|
|
}
|
|
return pgtype.Bool{Bool: *b, Valid: true}
|
|
}
|
|
|
|
func toPgInt4(i *int) pgtype.Int4 {
|
|
if i == nil {
|
|
return pgtype.Int4{Valid: false}
|
|
}
|
|
return pgtype.Int4{Int32: int32(*i), Valid: true}
|
|
}
|
|
|
|
func toPgNumeric(f *float64) pgtype.Numeric {
|
|
if f == nil {
|
|
return pgtype.Numeric{Valid: false}
|
|
}
|
|
var n pgtype.Numeric
|
|
if err := n.Scan(fmt.Sprintf("%f", *f)); err != nil {
|
|
return pgtype.Numeric{Valid: false}
|
|
}
|
|
return n
|
|
}
|
|
|
|
// Import Logic
|
|
|
|
type ImportProfessionalInput struct {
|
|
CreateProfissionalInput
|
|
// Any extra fields? Maybe not.
|
|
}
|
|
|
|
type ImportStats struct {
|
|
Created int
|
|
Updated int
|
|
Errors int
|
|
}
|
|
|
|
func (s *Service) Import(ctx context.Context, items []CreateProfissionalInput) (ImportStats, []error) {
|
|
stats := ImportStats{}
|
|
var errs []error
|
|
|
|
for i, input := range items {
|
|
// 1. Validate / Normalize CPF
|
|
if input.CpfCnpjTitular == nil || *input.CpfCnpjTitular == "" {
|
|
errs = append(errs, fmt.Errorf("row %d: cpf is required", i))
|
|
stats.Errors++
|
|
continue
|
|
}
|
|
|
|
cpf := *input.CpfCnpjTitular
|
|
|
|
// 2. Check if exists
|
|
existing, err := s.queries.GetProfissionalByCPF(ctx, pgtype.Text{String: cpf, Valid: true})
|
|
if err == nil {
|
|
// Found -> Update
|
|
// Map input to UpdateProfissionalInput
|
|
// Using a helper or manual mapping
|
|
updateInput := UpdateProfissionalInput{
|
|
Nome: input.Nome,
|
|
FuncaoProfissionalID: input.FuncaoProfissionalID,
|
|
FuncoesIds: input.FuncoesIds,
|
|
Endereco: input.Endereco,
|
|
Cidade: input.Cidade,
|
|
Uf: input.Uf,
|
|
Whatsapp: input.Whatsapp,
|
|
CpfCnpjTitular: input.CpfCnpjTitular,
|
|
Banco: input.Banco,
|
|
Agencia: input.Agencia,
|
|
ContaPix: input.ContaPix,
|
|
CarroDisponivel: input.CarroDisponivel,
|
|
TemEstudio: input.TemEstudio,
|
|
QtdEstudio: input.QtdEstudio,
|
|
TipoCartao: input.TipoCartao,
|
|
Observacao: input.Observacao,
|
|
QualTec: input.QualTec,
|
|
EducacaoSimpatia: input.EducacaoSimpatia,
|
|
DesempenhoEvento: input.DesempenhoEvento,
|
|
DispHorario: input.DispHorario,
|
|
Media: input.Media,
|
|
TabelaFree: input.TabelaFree,
|
|
ExtraPorEquipamento: input.ExtraPorEquipamento,
|
|
Equipamentos: input.Equipamentos,
|
|
Email: input.Email,
|
|
AvatarURL: input.AvatarURL,
|
|
}
|
|
// Use existing ID
|
|
idStr := uuid.UUID(existing.ID.Bytes).String()
|
|
_, err := s.Update(ctx, idStr, updateInput)
|
|
if err != nil {
|
|
errs = append(errs, fmt.Errorf("row %d (update): %v", i, err))
|
|
stats.Errors++
|
|
} else {
|
|
stats.Updated++
|
|
}
|
|
} else {
|
|
// Not Found (or error) -> Check if it is Not Found
|
|
// sqlc returns err on Not Found? likely pgx.ErrNoRows or similar
|
|
// If it's real error, log it. But for now assume err means Not Found.
|
|
|
|
// Create New
|
|
// Use empty userID (or nil)
|
|
// Create function takes userID string.
|
|
// I need to adjust Create to accept nullable userID or pass "" and handle it.
|
|
// Looking at Create code:
|
|
// uuid.Parse(finalUserID). If "" -> error "invalid usuario_id"
|
|
// So Create DOES NOT support empty user ID currently.
|
|
|
|
// I need to Modify Create to support NULL user_id.
|
|
|
|
// For now, I'll direct call queries.CreateProfissional here to bypass service check, OR fix Service.Create.
|
|
// Fixing Service.Create is better.
|
|
|
|
// Workaround: Call logic directly here for creation without User
|
|
// Copy Logic from Create but allow UserID to be invalid/null
|
|
|
|
var funcaoUUID uuid.UUID
|
|
var funcaoValid bool
|
|
if input.FuncaoProfissionalID != "" {
|
|
parsed, err := uuid.Parse(input.FuncaoProfissionalID)
|
|
if err == nil {
|
|
funcaoUUID = parsed
|
|
funcaoValid = true
|
|
}
|
|
}
|
|
|
|
params := generated.CreateProfissionalParams{
|
|
UsuarioID: pgtype.UUID{Valid: false}, // Is NULL
|
|
Nome: input.Nome,
|
|
FuncaoProfissionalID: pgtype.UUID{Bytes: funcaoUUID, Valid: funcaoValid},
|
|
Endereco: toPgText(input.Endereco),
|
|
Cidade: toPgText(input.Cidade),
|
|
Uf: toPgText(input.Uf),
|
|
Whatsapp: toPgText(input.Whatsapp),
|
|
CpfCnpjTitular: toPgText(input.CpfCnpjTitular),
|
|
Banco: toPgText(input.Banco),
|
|
Agencia: toPgText(input.Agencia),
|
|
ContaPix: toPgText(input.ContaPix),
|
|
CarroDisponivel: toPgBool(input.CarroDisponivel),
|
|
TemEstudio: toPgBool(input.TemEstudio),
|
|
QtdEstudio: toPgInt4(input.QtdEstudio),
|
|
TipoCartao: toPgText(input.TipoCartao),
|
|
Observacao: toPgText(input.Observacao),
|
|
QualTec: toPgInt4(input.QualTec),
|
|
EducacaoSimpatia: toPgInt4(input.EducacaoSimpatia),
|
|
DesempenhoEvento: toPgInt4(input.DesempenhoEvento),
|
|
DispHorario: toPgInt4(input.DispHorario),
|
|
Media: toPgNumeric(input.Media),
|
|
TabelaFree: toPgText(input.TabelaFree),
|
|
ExtraPorEquipamento: toPgBool(input.ExtraPorEquipamento),
|
|
Equipamentos: toPgText(input.Equipamentos),
|
|
Email: toPgText(input.Email),
|
|
AvatarUrl: toPgText(input.AvatarURL),
|
|
}
|
|
|
|
prof, err := s.queries.CreateProfissional(ctx, params)
|
|
if err != nil {
|
|
errs = append(errs, fmt.Errorf("row %d (create): %v", i, err))
|
|
stats.Errors++
|
|
} else {
|
|
// Insert multiple functions if provided
|
|
if len(input.FuncoesIds) > 0 {
|
|
for _, fid := range input.FuncoesIds {
|
|
fUUID, err := uuid.Parse(fid)
|
|
if err == nil {
|
|
_ = s.queries.AddFunctionToProfessional(ctx, generated.AddFunctionToProfessionalParams{
|
|
ProfissionalID: pgtype.UUID{Bytes: prof.ID.Bytes, Valid: true},
|
|
FuncaoID: pgtype.UUID{Bytes: fUUID, Valid: true},
|
|
})
|
|
}
|
|
}
|
|
} else if funcaoValid {
|
|
_ = s.queries.AddFunctionToProfessional(ctx, generated.AddFunctionToProfessionalParams{
|
|
ProfissionalID: pgtype.UUID{Bytes: prof.ID.Bytes, Valid: true},
|
|
FuncaoID: pgtype.UUID{Bytes: funcaoUUID, Valid: true},
|
|
})
|
|
}
|
|
stats.Created++
|
|
}
|
|
}
|
|
}
|
|
|
|
return stats, errs
|
|
}
|
|
|
|
// CheckExistence checks if a professional exists by CPF
|
|
func (s *Service) CheckExistence(ctx context.Context, cpf string) (exists bool, claimed bool, name string, err error) {
|
|
prof, err := s.queries.GetProfissionalByCPF(ctx, pgtype.Text{String: cpf, Valid: true})
|
|
if err != nil {
|
|
if err.Error() == "no rows in result set" {
|
|
return false, false, "", nil
|
|
}
|
|
return false, false, "", err
|
|
}
|
|
|
|
return true, prof.UsuarioID.Valid, prof.Nome, nil
|
|
}
|