package service

import (
	"fmt"
	"github.com/linmadan/egglib-go/core/application"
	"github.com/linmadan/egglib-go/utils/tool_funs"
	"gitlab.fjmaimaimai.com/linmadan/mmm-worth/pkg/application/factory"
	"gitlab.fjmaimaimai.com/linmadan/mmm-worth/pkg/application/listInterval/command"
	"gitlab.fjmaimaimai.com/linmadan/mmm-worth/pkg/application/listInterval/query"
	"gitlab.fjmaimaimai.com/linmadan/mmm-worth/pkg/domain"
)

type ListIntervalService struct {
}

// 创建排行榜时间
func (listIntervalService *ListIntervalService) CreateListInterval(createListIntervalCommand *command.CreateListIntervalCommand) (interface{}, error) {
	if err := createListIntervalCommand.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 listIntervalRepository domain.ListIntervalRepository
	if value, err := factory.CreateListIntervalRepository(map[string]interface{}{
		"transactionContext": transactionContext,
	}); err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	} else {
		listIntervalRepository = value
	}

	// 获取当前最新排行榜时间
	listListIntervalQuery := &query.ListListIntervalQuery {
		CompanyId: createListIntervalCommand.CompanyId,
		Offset: 0,
		Limit: 1,
	}

	// 获取上个年榜时间
	_, listIntervals, err := listIntervalRepository.Find(tool_funs.SimpleStructToMap(listListIntervalQuery))
	if err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	}

	// 判断年榜时间是否和上个年榜重叠
	if len(listIntervals) > 0 {
		if createListIntervalCommand.ListIntervalStartTime.Before(listIntervals[0].IntervalEndTime) ||  createListIntervalCommand.ListIntervalStartTime.Equal(listIntervals[0].IntervalEndTime){
			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "年榜开始时间必须大于上一个年榜结束时间")
		} else {
			// 创建排行榜时间命令
			newListInterval := &domain.ListInterval {
				CompanyId: createListIntervalCommand.CompanyId,
				IntervalStartTime: createListIntervalCommand.ListIntervalStartTime,
				IntervalEndTime: createListIntervalCommand.ListIntervalEndTime,
			}

			// 保存排行榜时间
			listInterval, err := listIntervalRepository.Save(newListInterval)
			if err != nil {
				return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
			}
			if err := transactionContext.CommitTransaction(); err != nil {
				return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
			}

			return listInterval, nil
		}
	} else {
		// 创建排行榜时间命令
		newListInterval := &domain.ListInterval {
			CompanyId: createListIntervalCommand.CompanyId,
			IntervalStartTime: createListIntervalCommand.ListIntervalStartTime,
			IntervalEndTime: createListIntervalCommand.ListIntervalEndTime,
		}

		// 保存排行榜时间
		listInterval, err := listIntervalRepository.Save(newListInterval)
		if err != nil {
			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
		}
		if err := transactionContext.CommitTransaction(); err != nil {
			return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
		}
		return listInterval, nil
	}
}

// 返回排行榜时间列表
func (listIntervalService *ListIntervalService) ListListInterval(listListIntervalQuery *query.ListListIntervalQuery) (interface{}, error) {
	if err := listListIntervalQuery.ValidateQuery(); 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 listIntervalRepository domain.ListIntervalRepository
	if value, err := factory.CreateListIntervalRepository(map[string]interface{}{
		"transactionContext": transactionContext,
	}); err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	} else {
		listIntervalRepository = value
	}

	if count, listIntervals, err := listIntervalRepository.Find(tool_funs.SimpleStructToMap(listListIntervalQuery)); err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	} else {
		if err := transactionContext.CommitTransaction(); err != nil {
			return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
		}
		return map[string]interface{}{
			"count":       count,
			"listIntervals": listIntervals,
		}, nil
	}
}

// 返回排行榜时间
func (listIntervalService *ListIntervalService) GetListInterval(getListIntervalQuery *query.GetListIntervalQuery) (interface{}, error) {
	if err := getListIntervalQuery.ValidateQuery(); 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 listIntervalRepository domain.ListIntervalRepository
	if value, err := factory.CreateListIntervalRepository(map[string]interface{}{
		"transactionContext": transactionContext,
	}); err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	} else {
		listIntervalRepository = value
	}

	listInterval, err := listIntervalRepository.FindOne(map[string]interface{}{"listId": getListIntervalQuery.ListIntervalId})
	if err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	}
	if listInterval == nil {
		return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", string(getListIntervalQuery.ListIntervalId)))
	} else {
		if err := transactionContext.CommitTransaction(); err != nil {
			return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
		}
		return listInterval, nil
	}
}

// 更新排行榜时间
func (listIntervalService *ListIntervalService) UpdateListInterval(updateListIntervalCommand *command.UpdateListIntervalCommand) (interface{}, error) {
	if err := updateListIntervalCommand.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 listIntervalRepository domain.ListIntervalRepository
	if value, err := factory.CreateListIntervalRepository(map[string]interface{}{
		"transactionContext": transactionContext,
	}); err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	} else {
		listIntervalRepository = value
	}

	// 获取当前年榜
	listIntervalFound, err := listIntervalRepository.FindOne(map[string]interface{}{"listId": updateListIntervalCommand.ListIntervalId})
	if err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	}
	if listIntervalFound == nil {
		return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", string(updateListIntervalCommand.ListIntervalId)))
	}

	// 获取上一个榜单
	listListIntervalQuery := &query.ListListIntervalQuery {
		CompanyId: listIntervalFound.CompanyId,
		Offset: 1,
		Limit: 1,
	}

	//获取上个年榜时间
	_, listIntervals, err := listIntervalRepository.Find(tool_funs.SimpleStructToMap(listListIntervalQuery))
	if err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	}

	// 判断年榜时间是否和上个年榜重叠
	if len(listIntervals) > 0 {
		if updateListIntervalCommand.ListIntervalStartTime.Before(listIntervals[0].IntervalEndTime) ||  updateListIntervalCommand.ListIntervalStartTime.Equal(listIntervals[0].IntervalEndTime){
			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "年榜开始时间必须大于上一个年榜结束时间")
		} else {  // 正常更新
			if err := listIntervalFound.Update(tool_funs.SimpleStructToMap(updateListIntervalCommand)); err != nil {
				return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
			}

			if listIntervalUpdated, err := listIntervalRepository.Save(listIntervalFound); err != nil {
				return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
			} else {
				if err := transactionContext.CommitTransaction(); err != nil {
					return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
				}
				return listIntervalUpdated, nil
			}
		}
	} else {  // 正常更新
		if err := listIntervalFound.Update(tool_funs.SimpleStructToMap(updateListIntervalCommand)); err != nil {
			return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
		}

		if listIntervalUpdated, err := listIntervalRepository.Save(listIntervalFound); err != nil {
			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
		} else {
			if err := transactionContext.CommitTransaction(); err != nil {
				return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
			}
			return listIntervalUpdated, nil
		}
	}
}

// 移除排行榜时间
func (listIntervalService *ListIntervalService) RemoveListInterval(removeListIntervalCommand *command.RemoveListIntervalCommand) (interface{}, error) {
	if err := removeListIntervalCommand.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 listIntervalRepository domain.ListIntervalRepository
	if value, err := factory.CreateListIntervalRepository(map[string]interface{}{
		"transactionContext": transactionContext,
	}); err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	} else {
		listIntervalRepository = value
	}

	listInterval, err := listIntervalRepository.FindOne(map[string]interface{}{"listId": removeListIntervalCommand.ListIntervalId})
	if err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	}
	if listInterval == nil {
		return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", string(removeListIntervalCommand.ListIntervalId)))
	}

	if listInterval, err := listIntervalRepository.Remove(listInterval); err != nil {
		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
	} else {
		if err := transactionContext.CommitTransaction(); err != nil {
			return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
		}
		return listInterval, nil
	}
}

func NewListIntervalService(options map[string] interface{}) *ListIntervalService {
	newListIntervalService := &ListIntervalService{}
	return newListIntervalService
}