package service

import (
	"github.com/linmadan/egglib-go/core/application"
	"github.com/linmadan/egglib-go/utils/json"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/application/mobile/cooperation/command"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/domain"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/infrastructure/service_gateway/allied_creation_cooperation"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/infrastructure/service_gateway/allied_creation_user"
)

// 企业端统计
type CompanyStatisticsService struct {
}

// IndexStatistics  首页统计 （入口页面统计数据）
func (srv CompanyStatisticsService) IndexStatistics(cmd *command.IndexStatisticsCommand) (interface{}, error) {
	gateway := allied_creation_cooperation.NewHttplibAlliedCreationCooperation(
		cmd.Operator)
	companyDividendsStatistics, err := gateway.CooperationStatistics(allied_creation_cooperation.CompanyDividendsStatistics, map[string]interface{}{
		"companyId": cmd.Operator.CompanyId,
		"orgId":     cmd.Operator.OrgId,
		"action":    1, //当前月
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}
	cooperationModeStatistics, err := gateway.CooperationStatistics(allied_creation_cooperation.CooperationModeStatistics, map[string]interface{}{
		"companyId": cmd.Operator.CompanyId,
		"orgId":     cmd.Operator.OrgId,
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}
	cooperationGoodsStatistics, err := gateway.CooperationStatistics(allied_creation_cooperation.CooperationGoodsStatistics, map[string]interface{}{
		"companyId": cmd.Operator.CompanyId,
		"orgId":     cmd.Operator.OrgId,
		"rankType":  1, //月榜
		"top":       5,
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}

	// 模式列表
	var modeStatistics []CooperationModeStatistics
	var responseModeStatistics []CooperationModeStatistics
	var modeNumbers []string
	err = json.UnmarshalFromString(json.MarshalToString(cooperationModeStatistics), &modeStatistics)
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}
	for i := range modeStatistics {
		modeNumbers = append(modeNumbers, modeStatistics[i].CooperationModeNumber)
	}

	var cooperationModes = make([]interface{}, 0)
	models, err := gateway.CooperationModesSearch(allied_creation_cooperation.ReqCooperationModesSearch{
		PageSize:   domain.NormalQueryRowCount,
		PageNumber: 1,
		CompanyId:  cmd.Operator.CompanyId,
		OrgId:      cmd.Operator.OrgId,
		//CooperationModeNumbers: modeNumbers,
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}
	mapModels := make(map[string]CooperationModeStatistics)
	for i := range responseModeStatistics {
		item := responseModeStatistics[i]
		mapModels[item.CooperationModeNumber] = item
	}
	if len(models.List) > 0 {
		for i := range models.List {
			item := models.List[i]
			if value, ok := mapModels[item.CooperationModeNumber]; !ok {
				responseModeStatistics = append(responseModeStatistics, CooperationModeStatistics{
					CooperationPeople:     0,
					DividendsEstimate:     0,
					OrderAmount:           0,
					CooperationModeNumber: item.CooperationModeNumber,
					SettlementAmount:      0,
				})
			} else {
				responseModeStatistics = append(responseModeStatistics, value)
			}
			cooperationModes = append(cooperationModes, map[string]interface{}{
				"cooperationModeId":     item.CooperationModeId,
				"cooperationModeName":   item.CooperationModeName,
				"cooperationModeNumber": item.CooperationModeNumber,
			})
		}
	}

	// 项目概览统计
	contracts, err := gateway.CooperationContractSearch(allied_creation_cooperation.ReqCooperationContractSearch{
		PageNumber: 1,
		PageSize:   1,
		CompanyId:  cmd.Operator.CompanyId,
		OrgId:      cmd.Operator.OrgId,
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}
	projects, err := gateway.CooperationProjectsSearch(allied_creation_cooperation.ReqCooperationProjectSearch{
		PageNumber: 1,
		PageSize:   1,
		CompanyId:  cmd.Operator.CompanyId,
		OrgId:      cmd.Operator.OrgId,
		Status:     1,
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}
	gatewayUser := allied_creation_user.NewHttplibAlliedCreationUser(
		cmd.Operator)
	users, err := gatewayUser.UserSearch(allied_creation_user.ReqUserSearch{
		Limit:          1,
		Offset:         0,
		CompanyId:      cmd.Operator.CompanyId,
		OrganizationId: cmd.Operator.OrgId,
		UserType:       domain.UserTypeCooperation,
		InEnableStatus: []int{domain.UserStatusEnable},
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}
	var projectOverviewStatistics = map[string]interface{}{
		"contractSum":          contracts.Grid.Total,
		"cooperationUserCount": users.Count,
		"projectSum":           projects.Total,
	}

	return map[string]interface{}{
		"projectOverviewStatistics":       projectOverviewStatistics,
		"currentMonthDividendsStatistics": companyDividendsStatistics,
		"cooperationModeStatistics":       responseModeStatistics,
		"cooperationGoodsStatistics":      cooperationGoodsStatistics,
		"cooperationModes":                cooperationModes,
	}, nil
}

// GoodsStatistics  产品统计排行榜 年月榜
func (srv CompanyStatisticsService) GoodsStatistics(cmd *command.GoodsStatisticsCommand) (int64, interface{}, error) {
	gateway := allied_creation_cooperation.NewHttplibAlliedCreationCooperation(
		cmd.Operator)
	cooperationGoodsStatistics, err := gateway.CooperationStatistics(allied_creation_cooperation.CooperationGoodsStatistics, map[string]interface{}{
		"companyId": cmd.Operator.CompanyId,
		"orgId":     cmd.Operator.OrgId,
		"rankType":  cmd.RankingType, //当前月
		//"offset":cmd.PageNumber*cmd.PageSize,
		"top": 100,
	})
	if err != nil {
		return 0, nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}

	return 0, cooperationGoodsStatistics, nil
}

// CooperationDividendsStatistics 公司共创人员列表
func (srv CompanyStatisticsService) CooperationDividendsStatistics(cmd *command.CooperationDividendsStatisticsCommand) (int64, interface{}, error) {
	gateway := allied_creation_cooperation.NewHttplibAlliedCreationCooperation(
		cmd.Operator)
	cooperationUsersStatistics, err := gateway.CooperationStatistics(allied_creation_cooperation.CompanyCooperationUsersStatistics, map[string]interface{}{
		"orgId":                    cmd.Operator.OrgId,
		"offset":                   cmd.PageNumber * cmd.PageSize,
		"limit":                    cmd.PageSize,
		"sortByActuallyPaidAmount": cmd.SortByActuallyPaidAmount,
	})
	if err != nil {
		return 0, nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}
	return 0, cooperationUsersStatistics, nil
}

// CooperationPersonStatistics  共创人明细员统计（共创人员明细）
func (srv CompanyStatisticsService) CooperationPersonStatistics(cmd *command.CooperationPersonStatisticsCommand) (interface{}, error) {
	gatewayUser := allied_creation_user.NewHttplibAlliedCreationUser(
		cmd.Operator)
	user, err := gatewayUser.UserGet(allied_creation_user.ReqGetUser{
		UserId: cmd.UserId,
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}

	gateway := allied_creation_cooperation.NewHttplibAlliedCreationCooperation(
		cmd.Operator)
	cooperationUserModeStatistics, err := gateway.CooperationStatistics(allied_creation_cooperation.CooperationUserModeStatistics, map[string]interface{}{
		"userId": cmd.UserId,
		"orgId":  cmd.Operator.OrgId,
	})
	if err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}

	var modeStatistics = struct {
		CooperationTypes interface{} `json:"cooperationTypes"`
		DividendsDetails interface{} `json:"dividendsDetails"`
		OrderDetails     interface{} `json:"orderDetails"`
	}{}

	if err := json.UnmarshalFromString(json.MarshalToString(cooperationUserModeStatistics), &modeStatistics); err != nil {
		return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
	}

	var response = map[string]interface{}{
		"userName":         user.UserInfo.UserName,
		"cooperationTime":  user.CreatedAt.Unix() * 1000,
		"cooperationTypes": modeStatistics.CooperationTypes,
		"dividendsDetails": modeStatistics.DividendsDetails,
		"orderDetails":     modeStatistics.OrderDetails,
	}
	return map[string]interface{}{
		"cooperationPersonStatistics": response,
	}, nil
}

type CooperationModeStatistics struct {
	// 共创人数
	CooperationPeople float64 `json:"cooperationPeople"`
	// 分红预算
	DividendsEstimate float64 `json:"dividendsEstimate"`
	// 订单金额
	OrderAmount float64 `json:"orderAmount"`
	// 共创模式编号
	CooperationModeNumber string `json:"cooperationModeNumber"`
	// 结算金额
	SettlementAmount float64 `json:"settlementAmount"`
}