package service

import (
	"ecos/application/domain/mini_carousel_config"
	"git.sxidc.com/go-framework/baize/convenient/entity_crud"
	"git.sxidc.com/go-framework/baize/framework/binding"
	"git.sxidc.com/go-framework/baize/framework/core/api"
	"git.sxidc.com/go-framework/baize/framework/core/api/request"
	"git.sxidc.com/go-framework/baize/framework/core/api/response"
	"git.sxidc.com/go-framework/baize/framework/core/application"
	"git.sxidc.com/go-framework/baize/framework/core/domain"
	"git.sxidc.com/go-framework/baize/framework/core/domain/entity"
	"git.sxidc.com/go-framework/baize/framework/core/infrastructure"
	"git.sxidc.com/go-framework/baize/framework/core/infrastructure/database"
	"git.sxidc.com/go-framework/baize/framework/core/infrastructure/database/sql"
	"git.sxidc.com/go-tools/utils/strutils"
	"github.com/pkg/errors"
)

var miniCarouselConfigService = &MiniCarouselConfigService{}

type MiniCarouselConfigService struct{}

func (svc *MiniCarouselConfigService) Init(appInstance *application.App) error {
	svc.v1(appInstance)
	return nil
}

func (svc *MiniCarouselConfigService) Destroy() error {
	return nil
}

func (svc *MiniCarouselConfigService) v1(appInstance *application.App) {
	v1Binder := binding.NewBinder(appInstance.ChooseRouter(api.RouterPrefix, "v1"),
		appInstance.Infrastructure())

	entity_crud.BindSimple[mini_carousel_config.Info](v1Binder, &entity_crud.Simple[mini_carousel_config.Info]{
		Entity:             &mini_carousel_config.Entity{},
		Schema:             dbSchema,
		CreateJsonBody:     &mini_carousel_config.CreateMiniCarouselConfigJsonBody{},
		DeleteQueryParams:  &mini_carousel_config.DeleteMiniCarouselConfigQueryParams{},
		UpdateJsonBody:     &mini_carousel_config.UpdateMiniCarouselConfigJsonBody{},
		QueryQueryParams:   &mini_carousel_config.GetMiniCarouselConfigsQueryParams{},
		GetByIDQueryParams: &mini_carousel_config.GetMiniCarouselConfigQueryParams2{},
	},
		entity_crud.WithQueryFormCustomConditionFunc[mini_carousel_config.Info](func(c *api.Context, params request.Params, e entity.Entity, i *infrastructure.Infrastructure) (*entity_crud.CustomCondition, error) {
			requestParams, err := request.ToConcrete[*mini_carousel_config.GetMiniCarouselConfigsQueryParams](params)
			if err != nil {
				return nil, err
			}
			conditions := sql.NewConditions()

			if strutils.IsStringNotEmpty(requestParams.ComponentID) {
				conditions.Equal(mini_carousel_config.ColumnComponentID, requestParams.ComponentID)
			}

			if requestParams.LinkType > 0 {
				conditions.Equal(mini_carousel_config.ColumnLinkType, requestParams.LinkType)
			}

			if strutils.IsStringNotEmpty(requestParams.IsEnabled) {
				conditions.Equal(mini_carousel_config.ColumnIsEnabled, requestParams.IsEnabled)
			}

			return &entity_crud.CustomCondition{
				Conditions: conditions,
				OrderBy:    mini_carousel_config.ColumnSortOrder,
			}, nil
		}),
	)

	binding.PutBind(v1Binder, &binding.SimpleBindItem[any]{
		Path:             "/miniCarouselConfig/enabledOrDisable",
		SendResponseFunc: response.SendMsgResponse,
		RequestParams:    &mini_carousel_config.EnabledOrDisableJsonBody{},
		ServiceFunc: func(c *api.Context, params request.Params, objects []domain.Object, i *infrastructure.Infrastructure) (any, error) {
			requestParams, err := request.ToConcrete[*mini_carousel_config.EnabledOrDisableJsonBody](params)
			if err != nil {
				return nil, err
			}
			err = database.Transaction(i.DBExecutor(), func(tx database.Executor) error {
				err = database.Update(tx, &sql.UpdateExecuteParams{
					TableName:  domain.TableName(dbSchema, &mini_carousel_config.Entity{}),
					Conditions: sql.NewConditions().Equal(entity.ColumnID, requestParams.ID),
					TableRow:   sql.NewTableRow().Add(mini_carousel_config.ColumnIsEnabled, requestParams.IsEnabled),
				})
				//这个启用 别的都关掉
				if requestParams.IsEnabled == Enabled {
					err = database.Update(tx, &sql.UpdateExecuteParams{
						TableName:  domain.TableName(dbSchema, &mini_carousel_config.Entity{}),
						Conditions: sql.NewConditions().Not(entity.ColumnID, requestParams.ID),
						TableRow:   sql.NewTableRow().Add(mini_carousel_config.ColumnIsEnabled, Disable),
					})
					if err != nil {
						return err
					}
				}
				return nil
			})

			return nil, nil
		},
	})

}

func (svc *MiniCarouselConfigService) queryByKeyFields(e *mini_carousel_config.Entity, dbExecutor database.Executor) (*mini_carousel_config.Entity, error) {
	result, err := database.QueryOne(dbExecutor, &sql.QueryOneExecuteParams{
		TableName:  domain.TableName(dbSchema, e),
		Conditions: sql.NewConditions().Equal(entity.ColumnID, e.ID),
	})
	if err != nil {
		if database.IsErrorDBRecordNotExist(err) {
			return nil, errors.New(e.DomainCNName() + "不存在")
		}

		return nil, err
	}

	existEntity := new(mini_carousel_config.Entity)
	err = sql.ParseSqlResult(result, existEntity)
	if err != nil {
		return nil, err
	}

	return existEntity, nil
}

func (svc *MiniCarouselConfigService) checkExistByKeyFields(e *mini_carousel_config.Entity, dbExecutor database.Executor) error {
	exist, err := database.CheckExist(dbExecutor, &sql.CheckExistExecuteParams{
		TableName:  domain.TableName(dbSchema, e),
		Conditions: sql.NewConditions().Equal(entity.ColumnID, e.ID),
	})
	if err != nil {
		return err
	}

	if !exist {
		return errors.New(e.DomainCNName() + "不存在")
	}

	return nil
}