package service

import (
	"fmt"
	"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"
	"gitlab.fjmaimaimai.com/allied-creation/character-library-metadata-bastion/pkg/log"
)

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())
	}
	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)
	}

	// 字段只传name时,补齐sqlName
	for i, c := range cmd.Where.Conditions {
		if c.Field != nil && c.Field.SQLName == "" {
			if v, ok := table.MatchField(c.Field); ok {
				cmd.Where.Conditions[i].Field.SQLName = v.SQLName
			}
		}
	}

	// 方案 计算项  计算集 做缓存
	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{HiddenData: cmd.HiddenData, TableType: table.TableType, Name: table.Name, TableId: table.TableId}
	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)
			}
			data, total := dataTable.FilterByWhere(cmd.Where)
			response.Fields = dataTable.Fields
			response.Data = domain.GripData(domain.ToFieldData(dataTable.Fields, data, false), total)
		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)
		}
	} else {
		switch table.TableType {
		case domain.CalculateSet.ToString():
			data, total := dataTable.FilterByWhere(cmd.Where)
			response.Fields = dataTable.Fields
			response.Data = domain.GripData(domain.ToFieldData(dataTable.Fields, data, false), total)
		default:
			response.Load(table, dataTable, domain.ObjectMetaTable)
		}
	}

	if cacheMiss && dataTable != nil {
		// 存储缓存
		cache.SetDataTable(table.TableId, dataTable)
	}
	return response, nil
}

func pageData(pageNumber, pageSize int, data [][]string) [][]string {
	if pageNumber == 0 || pageSize == 0 {
		return data
	}
	offset := (pageNumber - 1) * pageSize
	if len(data) < offset {
		return [][]string{}
	}
	if len(data) < offset+pageSize {
		pageSize = len(data) - offset
	}
	log.Logger.Info(fmt.Sprintf("%v %v %v", len(data), offset, pageSize))
	return data[offset : offset+pageSize]
}