package service

import (
	"github.com/linmadan/egglib-go/core/application"
	"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/application/factory"
	"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/application/table/command"
	"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/application/table/dto"
	"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/domain"
	"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/infrastructure/cache"
	"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/infrastructure/starrocks"
)

func (tableService *TableService) TablePreview(ctx *domain.Context, cmd *command.TablePreviewCommand) (interface{}, error) {
	if cmd.TableId == 0 {
		return &dto.TablePreviewDto{}, nil
	}
	if err := cmd.ValidateCommand(); err != nil {
		return nil, application.ThrowError(application.ARG_ERROR, err.Error())
	}
	transactionContext, err := factory.CreateTransactionContext(nil)
	if err != nil {
		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
	}
	if err := transactionContext.StartTransaction(); err != nil {
		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
	}
	defer func() {
		transactionContext.RollbackTransaction()
	}()
	var dataTable *domain.DataTable
	var table *domain.Table
	var cacheMiss bool
	_, table, err = factory.FastPgTable(transactionContext, cmd.TableId)
	if err != nil {
		return nil, factory.FastError(err)
	}
	// 方案 计算项  计算集 做缓存
	if cmd.UseCache && table.AssertTableType(domain.SchemaTable, domain.CalculateItem, domain.CalculateSet) {
		if d, ok := cache.GetDataTable(table.TableId); ok {
			dataTable = d
		} else {
			cacheMiss = true
		}
	}
	response := &dto.TablePreviewDto{}
	if dataTable == nil {
		switch table.TableType {
		case domain.CalculateSet.ToString():
			querySetRepository, _, _ := factory.FastPgQuerySet(transactionContext, 0)
			querySet, err := querySetRepository.FindOne(map[string]interface{}{"BindTableId": table.TableId})
			if err != nil {
				return nil, factory.FastError(err)
			}
			svr, _ := factory.FastQuerySetServices(transactionContext)
			dataTable, err = svr.LoadCalculateSetData(ctx, querySet, querySet.QueryComponents)
			if err != nil {
				return nil, factory.FastError(err)
			}
			response.Fields = dataTable.Fields
			response.Data = domain.GripData(domain.ToFieldData(dataTable.Fields, dataTable.Data, false), int64(len(dataTable.Data)))
		default:
			var options = starrocks.QueryOptions{
				Table:     table,
				TableName: table.SQLName,
				Select:    table.Fields(true),
			}
			options.SetCondition(cmd.Where.Conditions).SetDefaultOrder()
			options.SetOffsetLimit(cmd.Where.PageNumber, cmd.Where.PageSize)

			dataTable, err = factory.FastDataTable(options)
			if err != nil {
				return nil, factory.FastError(err)
			}
			// 计算项只返回第一个值
			// if table.TableType==domain.CalculateItem.ToString() && dataTable!=nil && len(dataTable.Data)>0{
			// 	dataTable.Data = dataTable.Data[:1]
			// }
			response.Load(table, dataTable, domain.ObjectMetaTable)
		}
	}

	switch table.TableType {
	case domain.CalculateSet.ToString():
		response.Fields = dataTable.Fields
		response.Data = domain.GripData(domain.ToFieldData(dataTable.Fields, dataTable.Data, false), int64(len(dataTable.Data)))
	default:
		response.Load(table, dataTable, domain.ObjectMetaTable)
	}

	if cacheMiss && dataTable != nil {
		// 存储缓存
		cache.SetDataTable(table.TableId, dataTable)
	}
	if err := transactionContext.CommitTransaction(); err != nil {
		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
	}
	return response, nil
}