SQuiz/amocrm
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

make code simply

Browse Source
This commit is contained in:
Pavel 2024-04-08 18:24:50 +03:00
parent 48d64be033
commit 3160626553
8 changed files with 232 additions and 238 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

99
internal/controllers/account.go
View File

@ -3,7 +3,6 @@ package controllers
import (
"amocrm/internal/models"
"amocrm/internal/service"
"github.com/gofiber/fiber/v2"
)
@ -18,131 +17,123 @@ func NewAccountController(service *service.AccountService) *AccountController {
}
func (c *AccountController) Register(router fiber.Router) {
router.Patch("/users", c.Updatelistusers)
router.Get("/users", c.Gettinguserfromcash)
router.Delete("/utms", c.Deletinguserutm)
router.Post("/utms", c.Savinguserutm)
router.Get("/utms/{quizID}", c.Gettinguserutm)
router.Delete("/account", c.Softdeleteaccount)
router.Get("/account", c.Getcurrentaccount)
router.Post("/account", c.Connectaccount)
router.Patch("/users", c.UpdateListUsers)
router.Get("/users", c.GettingUserFromCash)
router.Delete("/utms/:quizID", c.DeletingUserUtm)
router.Post("/utms/:quizID", c.SavingUserUtm)
router.Get("/utms/:quizID", c.GettingUserUtm)
router.Delete("/account", c.SoftDeleteAccount)
router.Get("/account", c.GetCurrentAccount)
router.Post("/account", c.ConnectAccount)
}
func (c *AccountController) Name() string {
return ""
}
func (c *AccountController) Updatelistusers(ctx *fiber.Ctx) error {
// Обработчик для метода Updatelistusers
err := c.AccountService.Updatelistusers(ctx.Context())
func (c *AccountController) UpdateListUsers(ctx *fiber.Ctx) error {
err := c.AccountService.UpdateListUsers(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *AccountController) Gettinguserfromcash(ctx *fiber.Ctx) error {
// Обработчик для метода Gettinguserfromcash
func (c *AccountController) GettingUserFromCash(ctx *fiber.Ctx) error {
req, err := extractParams(ctx)
if err != nil {
return err
}
response, err := c.AccountService.Gettinguserfromcash(ctx.Context())
response, err := c.AccountService.GettingUserFromCash(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *AccountController) Deletinguserutm(ctx *fiber.Ctx) error {
// Обработчик для метода Deletinguserutm
func (c *AccountController) DeletingUserUtm(ctx *fiber.Ctx) error {
quizID := ctx.Params("quizID")
if quizID == "" {
return ctx.Status(fiber.StatusBadRequest).SendString("quizID is nil")
}
var request models.ListDeleteUTMIDsReq
if err := ctx.BodyParser(&request); err != nil {
return ctx.Status(fiber.StatusBadRequest).JSON(fiber.Map{"error": "Invalid request payload"})
}
err := c.AccountService.Deletinguserutm(ctx.Context(), &request)
err := c.AccountService.DeletingUserUtm(ctx.Context(), &request)
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *AccountController) Savinguserutm(ctx *fiber.Ctx) error {
// Обработчик для метода Savinguserutm
func (c *AccountController) SavingUserUtm(ctx *fiber.Ctx) error {
quizID := ctx.Params("quizID")
if quizID == "" {
return ctx.Status(fiber.StatusBadRequest).SendString("quizID is nil")
}
var request models.SaveUserListUTMReq
if err := ctx.BodyParser(&request); err != nil {
return ctx.Status(fiber.StatusBadRequest).JSON(fiber.Map{"error": "Invalid request payload"})
}
response, err := c.AccountService.Savinguserutm(ctx.Context(), &request)
response, err := c.AccountService.SavingUserUtm(ctx.Context(), &request)
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *AccountController) Gettinguserutm(ctx *fiber.Ctx) error {
// Обработчик для метода Gettinguserutm
func (c *AccountController) GettingUserUtm(ctx *fiber.Ctx) error {
quizID := ctx.Params("quizID")
if quizID == "" {
return ctx.Status(fiber.StatusBadRequest).SendString("quizID is nil")
}
response, err := c.AccountService.Gettinguserutm(ctx.Context())
req, err := extractParams(ctx)
if err != nil {
return err
}
response, err := c.AccountService.GettingUserUtm(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *AccountController) Softdeleteaccount(ctx *fiber.Ctx) error {
// Обработчик для метода Softdeleteaccount
err := c.AccountService.Softdeleteaccount(ctx.Context())
func (c *AccountController) SoftDeleteAccount(ctx *fiber.Ctx) error {
err := c.AccountService.SoftDeleteAccount(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *AccountController) Getcurrentaccount(ctx *fiber.Ctx) error {
// Обработчик для метода Getcurrentaccount
response, err := c.AccountService.Getcurrentaccount(ctx.Context())
func (c *AccountController) GetCurrentAccount(ctx *fiber.Ctx) error {
response, err := c.AccountService.GetCurrentAccount(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *AccountController) Connectaccount(ctx *fiber.Ctx) error {
// Обработчик для метода Connectaccount
response, err := c.AccountService.Connectaccount(ctx.Context())
func (c *AccountController) ConnectAccount(ctx *fiber.Ctx) error {
response, err := c.AccountService.ConnectAccount(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}

155
internal/controllers/different.go
View File

@ -3,7 +3,6 @@ package controllers
import (
"amocrm/internal/models"
"amocrm/internal/service"
"github.com/gofiber/fiber/v2"
)
@ -18,201 +17,181 @@ func NewDifferentController(service *service.DifferentService) *DifferentControl
}
func (c *DifferentController) Register(router fiber.Router) {
router.Get("/steps", c.Gettingstepsfromcash)
router.Patch("/steps", c.Updateliststeps)
router.Get("/webhook/create", c.Webhookcreate)
router.Get("/webhook/delete", c.Webhookdelete)
router.Patch("/pipelines", c.Updatelistpipelines)
router.Get("/pipelines", c.Gettingpipelinesfromcash)
router.Patch("/rules", c.Changequizsettings)
router.Post("/rules", c.Setquizsettings)
router.Get("/rules/{quizID}", c.Gettingquizrules)
router.Get("/tags", c.Gettingtagsfromcash)
router.Patch("/tags", c.Updatelisttags)
router.Get("/fields", c.Gettingfieldsfromcash)
router.Patch("/fields", c.Updatelistcustom)
router.Get("/steps", c.GettingStepsFromCash)
router.Patch("/steps", c.UpdateListSteps)
router.Get("/webhook/create", c.WebhookCreate)
router.Get("/webhook/delete", c.WebhookDelete)
router.Patch("/pipelines", c.UpdateListPipelines)
router.Get("/pipelines", c.GettingPipelinesFromCash)
router.Patch("/rules/:quizID", c.ChangeQuizSettings)
router.Post("/rules/:quizID", c.SetQuizSettings)
router.Get("/rules/:quizID", c.GettingQuizRules)
router.Get("/tags", c.GettingTagsFromCash)
router.Patch("/tags", c.UpdateListTags)
router.Get("/fields", c.GettingFieldsFromCash)
router.Patch("/fields", c.UpdateListCustom)
}
func (c *DifferentController) Name() string {
return ""
}
func (c *DifferentController) Gettingstepsfromcash(ctx *fiber.Ctx) error {
// Обработчик для метода Gettingstepsfromcash
func (c *DifferentController) GettingStepsFromCash(ctx *fiber.Ctx) error {
req, err := extractParams(ctx)
if err != nil {
return err
}
response, err := c.DifferentService.Gettingstepsfromcash(ctx.Context())
response, err := c.DifferentService.GettingStepsFromCash(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *DifferentController) Updateliststeps(ctx *fiber.Ctx) error {
// Обработчик для метода Updateliststeps
err := c.DifferentService.Updateliststeps(ctx.Context())
func (c *DifferentController) UpdateListSteps(ctx *fiber.Ctx) error {
err := c.DifferentService.UpdateListSteps(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *DifferentController) Webhookcreate(ctx *fiber.Ctx) error {
// Обработчик для метода Webhookcreate
err := c.DifferentService.Webhookcreate(ctx.Context())
func (c *DifferentController) WebhookCreate(ctx *fiber.Ctx) error {
err := c.DifferentService.WebhookCreate(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *DifferentController) Webhookdelete(ctx *fiber.Ctx) error {
// Обработчик для метода Webhookdelete
err := c.DifferentService.Webhookdelete(ctx.Context())
func (c *DifferentController) WebhookDelete(ctx *fiber.Ctx) error {
err := c.DifferentService.WebhookDelete(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *DifferentController) Updatelistpipelines(ctx *fiber.Ctx) error {
// Обработчик для метода Updatelistpipelines
err := c.DifferentService.Updatelistpipelines(ctx.Context())
func (c *DifferentController) UpdateListPipelines(ctx *fiber.Ctx) error {
err := c.DifferentService.UpdateListPipelines(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *DifferentController) Gettingpipelinesfromcash(ctx *fiber.Ctx) error {
// Обработчик для метода Gettingpipelinesfromcash
func (c *DifferentController) GettingPipelinesFromCash(ctx *fiber.Ctx) error {
req, err := extractParams(ctx)
if err != nil {
return err
}
response, err := c.DifferentService.Gettingpipelinesfromcash(ctx.Context())
response, err := c.DifferentService.GettingPipelinesFromCash(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *DifferentController) Changequizsettings(ctx *fiber.Ctx) error {
// Обработчик для метода Changequizsettings
func (c *DifferentController) ChangeQuizSettings(ctx *fiber.Ctx) error {
quizID := ctx.Params("quizID")
if quizID == "" {
return ctx.Status(fiber.StatusBadRequest).SendString("quizID is nil")
}
var request models.RulesReq
if err := ctx.BodyParser(&request); err != nil {
return ctx.Status(fiber.StatusBadRequest).JSON(fiber.Map{"error": "Invalid request payload"})
}
err := c.DifferentService.Changequizsettings(ctx.Context(), &request)
err := c.DifferentService.ChangeQuizSettings(ctx.Context(), &request)
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *DifferentController) Setquizsettings(ctx *fiber.Ctx) error {
// Обработчик для метода Setquizsettings
func (c *DifferentController) SetQuizSettings(ctx *fiber.Ctx) error {
quizID := ctx.Params("quizID")
if quizID == "" {
return ctx.Status(fiber.StatusBadRequest).SendString("quizID is nil")
}
var request models.RulesReq
if err := ctx.BodyParser(&request); err != nil {
return ctx.Status(fiber.StatusBadRequest).JSON(fiber.Map{"error": "Invalid request payload"})
}
err := c.DifferentService.Setquizsettings(ctx.Context(), &request)
err := c.DifferentService.SetQuizSettings(ctx.Context(), &request)
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *DifferentController) Gettingquizrules(ctx *fiber.Ctx) error {
// Обработчик для метода Gettingquizrules
func (c *DifferentController) GettingQuizRules(ctx *fiber.Ctx) error {
quizID := ctx.Params("quizID")
if quizID == "" {
return ctx.Status(fiber.StatusBadRequest).SendString("quizID is nil")
}
response, err := c.DifferentService.Gettingquizrules(ctx.Context())
response, err := c.DifferentService.GettingQuizRules(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *DifferentController) Gettingtagsfromcash(ctx *fiber.Ctx) error {
// Обработчик для метода Gettingtagsfromcash
func (c *DifferentController) GettingTagsFromCash(ctx *fiber.Ctx) error {
req, err := extractParams(ctx)
if err != nil {
return err
}
response, err := c.DifferentService.Gettingtagsfromcash(ctx.Context())
response, err := c.DifferentService.GettingTagsFromCash(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *DifferentController) Updatelisttags(ctx *fiber.Ctx) error {
// Обработчик для метода Updatelisttags
err := c.DifferentService.Updatelisttags(ctx.Context())
func (c *DifferentController) UpdateListTags(ctx *fiber.Ctx) error {
err := c.DifferentService.UpdateListTags(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}
func (c *DifferentController) Gettingfieldsfromcash(ctx *fiber.Ctx) error {
// Обработчик для метода Gettingfieldsfromcash
response, err := c.DifferentService.Gettingfieldsfromcash(ctx.Context())
func (c *DifferentController) GettingFieldsFromCash(ctx *fiber.Ctx) error {
req, err := extractParams(ctx)
if err != nil {
return err
}
response, err := c.DifferentService.GettingFieldsFromCash(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.Status(fiber.StatusOK).JSON(response)
}
func (c *DifferentController) Updatelistcustom(ctx *fiber.Ctx) error {
// Обработчик для метода Updatelistcustom
err := c.DifferentService.Updatelistcustom(ctx.Context())
func (c *DifferentController) UpdateListCustom(ctx *fiber.Ctx) error {
err := c.DifferentService.UpdateListCustom(ctx.Context())
if err != nil {
return ctx.Status(fiber.StatusInternalServerError).SendString("Internal Server Error")
}
return ctx.SendStatus(fiber.StatusOK)
}

29
internal/controllers/middleware.go Normal file
View File

@ -0,0 +1,29 @@
package controllers
import (
"amocrm/internal/models"
"github.com/gofiber/fiber/v2"
"strconv"
)
func extractParams(ctx *fiber.Ctx) (*models.PaginationReq, error) {
pageStr := ctx.Query("page")
sizeStr := ctx.Query("size")
page, err := strconv.Atoi(pageStr)
if err != nil {
return nil, ctx.Status(fiber.StatusBadRequest).SendString("Invalid page parameter")
}
size, err := strconv.Atoi(sizeStr)
if err != nil {
return nil, ctx.Status(fiber.StatusBadRequest).SendString("Invalid size parameter")
}
req := models.PaginationReq{
Page: page,
Size: size,
}
return &req, nil
}

22
internal/repository/account.go
View File

@ -12,58 +12,52 @@ func NewAccountRepository() *AccountRepository {
return &AccountRepository{}
}
func (r *AccountRepository) Updatelistusers(ctx context.Context) error {
func (r *AccountRepository) UpdateListUsers(ctx context.Context) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *AccountRepository) Gettinguserfromcash(ctx context.Context) (*models.UserListResp, error) {
func (r *AccountRepository) GettingUserFromCash(ctx context.Context) (*models.UserListResp, error) {
//TODO:IMPLEMENT ME
return &models.UserListResp{}, nil
}
func (r *AccountRepository) Deletinguserutm(ctx context.Context, request *models.ListDeleteUTMIDsReq) error {
func (r *AccountRepository) DeletingUserUtm(ctx context.Context, request *models.ListDeleteUTMIDsReq) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *AccountRepository) Savinguserutm(ctx context.Context, request *models.SaveUserListUTMReq) (*models.ListSavedIDUTMResp, error) {
func (r *AccountRepository) SavingUserUtm(ctx context.Context, request *models.SaveUserListUTMReq) (*models.ListSavedIDUTMResp, error) {
//TODO:IMPLEMENT ME
return &models.ListSavedIDUTMResp{}, nil
}
func (r *AccountRepository) Gettinguserutm(ctx context.Context) (*models.GetListUserUTMResp, error) {
func (r *AccountRepository) GettingUserUtm(ctx context.Context) (*models.GetListUserUTMResp, error) {
//TODO:IMPLEMENT ME
return &models.GetListUserUTMResp{}, nil
}
func (r *AccountRepository) Softdeleteaccount(ctx context.Context) error {
func (r *AccountRepository) SoftDeleteAccount(ctx context.Context) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *AccountRepository) Getcurrentaccount(ctx context.Context) (*models.GetCurrentAccountResp, error) {
func (r *AccountRepository) GetCurrentAccount(ctx context.Context) (*models.GetCurrentAccountResp, error) {
//TODO:IMPLEMENT ME
return &models.GetCurrentAccountResp{}, nil
}
func (r *AccountRepository) Connectaccount(ctx context.Context) (*models.ConnectAccountResp, error) {
func (r *AccountRepository) ConnectAccount(ctx context.Context) (*models.ConnectAccountResp, error) {
//TODO:IMPLEMENT ME
return &models.ConnectAccountResp{}, nil
}

30
internal/repository/different.go
View File

@ -12,91 +12,87 @@ func NewDifferentRepository() *DifferentRepository {
return &DifferentRepository{}
}
func (r *DifferentRepository) Gettingstepsfromcash(ctx context.Context) (*models.UserListStepsResp, error) {
func (r *DifferentRepository) GettingStepsFromCash(ctx context.Context) (*models.UserListStepsResp, error) {
//TODO:IMPLEMENT ME
return &models.UserListStepsResp{}, nil
}
func (r *DifferentRepository) Updateliststeps(ctx context.Context) error {
func (r *DifferentRepository) UpdateListSteps(ctx context.Context) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *DifferentRepository) Webhookcreate(ctx context.Context) error {
func (r *DifferentRepository) WebhookCreate(ctx context.Context) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *DifferentRepository) Webhookdelete(ctx context.Context) error {
func (r *DifferentRepository) WebhookDelete(ctx context.Context) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *DifferentRepository) Updatelistpipelines(ctx context.Context) error {
func (r *DifferentRepository) UpdateListPipelines(ctx context.Context) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *DifferentRepository) Gettingpipelinesfromcash(ctx context.Context) (*models.UserListPipelinesResp, error) {
func (r *DifferentRepository) GettingPipelinesFromCash(ctx context.Context) (*models.UserListPipelinesResp, error) {
//TODO:IMPLEMENT ME
return &models.UserListPipelinesResp{}, nil
}
func (r *DifferentRepository) Changequizsettings(ctx context.Context, request *models.RulesReq) error {
func (r *DifferentRepository) ChangeQuizSettings(ctx context.Context, request *models.RulesReq) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *DifferentRepository) Setquizsettings(ctx context.Context, request *models.RulesReq) error {
func (r *DifferentRepository) SetQuizSettings(ctx context.Context, request *models.RulesReq) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *DifferentRepository) Gettingquizrules(ctx context.Context) (*models.Rule, error) {
func (r *DifferentRepository) GettingQuizRules(ctx context.Context) (*models.Rule, error) {
//TODO:IMPLEMENT ME
return &models.Rule{}, nil
}
func (r *DifferentRepository) Gettingtagsfromcash(ctx context.Context) (*models.UserListTagsResp, error) {
func (r *DifferentRepository) GettingTagsFromCash(ctx context.Context) (*models.UserListTagsResp, error) {
//TODO:IMPLEMENT ME
return &models.UserListTagsResp{}, nil
}
func (r *DifferentRepository) Updatelisttags(ctx context.Context) error {
func (r *DifferentRepository) UpdateListTags(ctx context.Context) error {
//TODO:IMPLEMENT ME
return nil
}
func (r *DifferentRepository) Gettingfieldsfromcash(ctx context.Context) (*models.UserListFieldsResp, error) {
func (r *DifferentRepository) GettingFieldsFromCash(ctx context.Context) (*models.UserListFieldsResp, error) {
//TODO:IMPLEMENT ME
return &models.UserListFieldsResp{}, nil
}
func (r *DifferentRepository) Updatelistcustom(ctx context.Context) error {
func (r *DifferentRepository) UpdateListCustom(ctx context.Context) error {
//TODO:IMPLEMENT ME
return nil

40
internal/service/account.go
View File

@ -16,82 +16,74 @@ func NewAccountService(repository *repository.AccountRepository) *AccountService
}
}
func (s *AccountService) Updatelistusers(ctx context.Context) error {
func (s *AccountService) UpdateListUsers(ctx context.Context) error {
err := s.AccountRepository.Updatelistusers(ctx)
err := s.AccountRepository.UpdateListUsers(ctx)
if err != nil {
return err
}
return nil
}
func (s *AccountService) Gettinguserfromcash(ctx context.Context) (*models.UserListResp, error) {
func (s *AccountService) GettingUserFromCash(ctx context.Context) (*models.UserListResp, error) {
response, err := s.AccountRepository.Gettinguserfromcash(ctx)
response, err := s.AccountRepository.GettingUserFromCash(ctx)
if err != nil {
return nil, err
}
return response, nil
}
func (s *AccountService) Deletinguserutm(ctx context.Context, request *models.ListDeleteUTMIDsReq) error {
func (s *AccountService) DeletingUserUtm(ctx context.Context, request *models.ListDeleteUTMIDsReq) error {
err := s.AccountRepository.Deletinguserutm(ctx, request)
err := s.AccountRepository.DeletingUserUtm(ctx, request)
if err != nil {
return err
}
return nil
}
func (s *AccountService) Savinguserutm(ctx context.Context, request *models.SaveUserListUTMReq) (*models.ListSavedIDUTMResp, error) {
func (s *AccountService) SavingUserUtm(ctx context.Context, request *models.SaveUserListUTMReq) (*models.ListSavedIDUTMResp, error) {
response, err := s.AccountRepository.Savinguserutm(ctx, request)
response, err := s.AccountRepository.SavingUserUtm(ctx, request)
if err != nil {
return nil, err
}
return response, nil
}
func (s *AccountService) Gettinguserutm(ctx context.Context) (*models.GetListUserUTMResp, error) {
func (s *AccountService) GettingUserUtm(ctx context.Context) (*models.GetListUserUTMResp, error) {
response, err := s.AccountRepository.Gettinguserutm(ctx)
response, err := s.AccountRepository.GettingUserUtm(ctx)
if err != nil {
return nil, err
}
return response, nil
}
func (s *AccountService) Softdeleteaccount(ctx context.Context) error {
func (s *AccountService) SoftDeleteAccount(ctx context.Context) error {
err := s.AccountRepository.Softdeleteaccount(ctx)
err := s.AccountRepository.SoftDeleteAccount(ctx)
if err != nil {
return err
}
return nil
}
func (s *AccountService) Getcurrentaccount(ctx context.Context) (*models.GetCurrentAccountResp, error) {
func (s *AccountService) GetCurrentAccount(ctx context.Context) (*models.GetCurrentAccountResp, error) {
response, err := s.AccountRepository.Getcurrentaccount(ctx)
response, err := s.AccountRepository.GetCurrentAccount(ctx)
if err != nil {
return nil, err
}
return response, nil
}
func (s *AccountService) Connectaccount(ctx context.Context) (*models.ConnectAccountResp, error) {
func (s *AccountService) ConnectAccount(ctx context.Context) (*models.ConnectAccountResp, error) {
response, err := s.AccountRepository.Connectaccount(ctx)
response, err := s.AccountRepository.ConnectAccount(ctx)
if err != nil {
return nil, err
}
return response, nil
}

65
internal/service/different.go
View File

@ -16,132 +16,119 @@ func NewDifferentService(repository *repository.DifferentRepository) *DifferentS
}
}
func (s *DifferentService) Gettingstepsfromcash(ctx context.Context) (*models.UserListStepsResp, error) {
func (s *DifferentService) GettingStepsFromCash(ctx context.Context) (*models.UserListStepsResp, error) {
response, err := s.DifferentRepository.Gettingstepsfromcash(ctx)
response, err := s.DifferentRepository.GettingStepsFromCash(ctx)
if err != nil {
return nil, err
}
return response, nil
}
func (s *DifferentService) Updateliststeps(ctx context.Context) error {
func (s *DifferentService) UpdateListSteps(ctx context.Context) error {
err := s.DifferentRepository.Updateliststeps(ctx)
err := s.DifferentRepository.UpdateListSteps(ctx)
if err != nil {
return err
}
return nil
}
func (s *DifferentService) Webhookcreate(ctx context.Context) error {
func (s *DifferentService) WebhookCreate(ctx context.Context) error {
err := s.DifferentRepository.Webhookcreate(ctx)
err := s.DifferentRepository.WebhookCreate(ctx)
if err != nil {
return err
}
return nil
}
func (s *DifferentService) Webhookdelete(ctx context.Context) error {
func (s *DifferentService) WebhookDelete(ctx context.Context) error {
err := s.DifferentRepository.Webhookdelete(ctx)
err := s.DifferentRepository.WebhookDelete(ctx)
if err != nil {
return err
}
return nil
}
func (s *DifferentService) Updatelistpipelines(ctx context.Context) error {
func (s *DifferentService) UpdateListPipelines(ctx context.Context) error {
err := s.DifferentRepository.Updatelistpipelines(ctx)
err := s.DifferentRepository.UpdateListPipelines(ctx)
if err != nil {
return err
}
return nil
}
func (s *DifferentService) Gettingpipelinesfromcash(ctx context.Context) (*models.UserListPipelinesResp, error) {
func (s *DifferentService) GettingPipelinesFromCash(ctx context.Context) (*models.UserListPipelinesResp, error) {
response, err := s.DifferentRepository.Gettingpipelinesfromcash(ctx)
response, err := s.DifferentRepository.GettingPipelinesFromCash(ctx)
if err != nil {
return nil, err
}
return response, nil
}
func (s *DifferentService) Changequizsettings(ctx context.Context, request *models.RulesReq) error {
func (s *DifferentService) ChangeQuizSettings(ctx context.Context, request *models.RulesReq) error {
err := s.DifferentRepository.Changequizsettings(ctx, request)
err := s.DifferentRepository.ChangeQuizSettings(ctx, request)
if err != nil {
return err
}
return nil
}
func (s *DifferentService) Setquizsettings(ctx context.Context, request *models.RulesReq) error {
func (s *DifferentService) SetQuizSettings(ctx context.Context, request *models.RulesReq) error {
err := s.DifferentRepository.Setquizsettings(ctx, request)
err := s.DifferentRepository.SetQuizSettings(ctx, request)
if err != nil {
return err
}
return nil
}
func (s *DifferentService) Gettingquizrules(ctx context.Context) (*models.Rule, error) {
func (s *DifferentService) GettingQuizRules(ctx context.Context) (*models.Rule, error) {
response, err := s.DifferentRepository.Gettingquizrules(ctx)
response, err := s.DifferentRepository.GettingQuizRules(ctx)
if err != nil {
return nil, err
}
return response, nil
}
func (s *DifferentService) Gettingtagsfromcash(ctx context.Context) (*models.UserListTagsResp, error) {
func (s *DifferentService) GettingTagsFromCash(ctx context.Context) (*models.UserListTagsResp, error) {
response, err := s.DifferentRepository.Gettingtagsfromcash(ctx)
response, err := s.DifferentRepository.GettingTagsFromCash(ctx)
if err != nil {
return nil, err
}
return response, nil
}
func (s *DifferentService) Updatelisttags(ctx context.Context) error {
func (s *DifferentService) UpdateListTags(ctx context.Context) error {
err := s.DifferentRepository.Updatelisttags(ctx)
err := s.DifferentRepository.UpdateListTags(ctx)
if err != nil {
return err
}
return nil
}
func (s *DifferentService) Gettingfieldsfromcash(ctx context.Context) (*models.UserListFieldsResp, error) {
func (s *DifferentService) GettingFieldsFromCash(ctx context.Context) (*models.UserListFieldsResp, error) {
response, err := s.DifferentRepository.Gettingfieldsfromcash(ctx)
response, err := s.DifferentRepository.GettingFieldsFromCash(ctx)
if err != nil {
return nil, err
}
return response, nil
}
func (s *DifferentService) Updatelistcustom(ctx context.Context) error {
func (s *DifferentService) UpdateListCustom(ctx context.Context) error {
err := s.DifferentRepository.Updatelistcustom(ctx)
err := s.DifferentRepository.UpdateListCustom(ctx)
if err != nil {
return err
}
return nil
}

30
openapi.yaml
View File

@ -101,12 +101,18 @@ paths:
'application/json':
schema:
$ref: '#/components/schemas/GetListUserUTMResp'
/utms:
post:
operationId: SavingUserUTM
tags:
- account
description: сохранение списка заданных юзером utm меток
parameters:
- in: path
name: quizID
required: true
schema:
type: string
description: Id квиза
requestBody:
content:
application/json:
@ -124,6 +130,13 @@ paths:
tags:
- account
description: удаление utm по айдишникам
parameters:
- in: path
name: quizID
required: true
schema:
type: string
description: Id квиза
requestBody:
content:
'application/json':
@ -353,12 +366,18 @@ paths:
'application/json':
schema:
$ref: "#/components/schemas/Rule"
/rules:
post:
operationId: SetQuizSettings
description: создание настроек интеграции для конкретного квиза
tags:
- different
parameters:
- in: path
name: quizID
required: true
schema:
type: string
description: Id квиза
requestBody:
content:
application/json:
@ -372,6 +391,13 @@ paths:
description: изменение настроек интеграции для конкретного квиза
tags:
- different
parameters:
- in: path
name: quizID
required: true
schema:
type: string
description: Id квиза
requestBody:
content:
application/json: