package dao

import (
	"micro-bundle/internal/model"
	"micro-bundle/pb/bundle"
	"micro-bundle/pkg/app"
	commonErr "micro-bundle/pkg/err"
	"micro-bundle/pkg/msg"
)

func CreateBundle(req *model.BundleProfile) (res *bundle.CommonResponse, err error) {
	res = new(bundle.CommonResponse)
	err = app.ModuleClients.BundleDB.Model(&model.BundleProfile{}).Create(&req).Error
	if err != nil {
		res.Msg = msg.ErrorCreateBundleInfo
		return res, commonErr.ReturnError(err, msg.ErrorCreateBundleInfo, "创建套餐信息失败: ")
	}
	res.Msg = msg.SuccessCreateBundleInfo
	return
}

func UpdateBundle(req *model.BundleProfile) (res *bundle.CommonResponse, err error) {
	res = new(bundle.CommonResponse)
	err = app.ModuleClients.BundleDB.Model(&model.BundleProfile{}).Where("uuid = ?", req.UUID).Updates(req).Error
	if err != nil {
		res.Msg = msg.ErrorUpdateBundleInfo
		return res, commonErr.ReturnError(err, msg.ErrorUpdateBundleInfo, "更新套餐信息失败: ")
	}
	res.Msg = msg.SuccessUpdateBundleInfo
	return
}

func DeleteBundle(uuid string) (res *bundle.CommonResponse, err error) {
	res = new(bundle.CommonResponse)
	err = app.ModuleClients.BundleDB.Where("uuid = ?", uuid).Delete(&model.BundleProfile{}).Error
	if err != nil {
		res.Msg = msg.ErrorDeleteBundleInfo
		return res, commonErr.ReturnError(err, msg.ErrorDeleteBundleInfo, "删除套餐信息失败: ")
	}
	res.Msg = msg.SuccessDeleteBundleInfo
	return
}

func BundleList(req *bundle.BundleListRequest) (res *bundle.BundleListResponse, err error) {
	res = new(bundle.BundleListResponse)
	res.Bundles = make([]*bundle.BundleProfile, 0)
	bundles := make([]*model.BundleProfile, 0)

	query := app.ModuleClients.BundleDB.Model(&model.BundleProfile{})

	if req.Name != "" {
		query = query.Where("name like ?", "%"+req.Name+"%")
	}

	if req.Content != "" {
		query = query.Where("content like ?", "%"+req.Content+"%")
	}

	if req.Language != "" {
		query = query.Where("language like ?", req.Language)
	}

	count := *query

	if req.PageSize != 0 && req.Page != 0 {
		query = query.Limit(int(req.PageSize)).Offset(int(req.Page-1) * int(req.PageSize))
	}

	if err = query.Find(&bundles).Error; err != nil {
		return res, commonErr.ReturnError(err, msg.ErrorGetBundleList, "获取套餐列表失败: ")
	}

	for _, bundleProfile := range bundles {
		res.Bundles = append(res.Bundles, &bundle.BundleProfile{
			Uuid:             bundleProfile.UUID,
			Name:             bundleProfile.Name,
			Price:            bundleProfile.Price,
			PriceType:        bundleProfile.PriceType,
			Contract:         bundleProfile.Contract,
			Content:          bundleProfile.Content,
			Language:         bundleProfile.Language,
			CreatedAt:        bundleProfile.CreatedAt.String(),
			UpdatedAt:        bundleProfile.UpdatedAt.String(),
			CompanySign:      bundleProfile.CompanySign,
			ContractDuration: int64(bundleProfile.ContractDuration),
			BundleCommonUid:  bundleProfile.BundleCommonUid,
		})
	}

	// _ = copier.CopyWithOption(&res.Bundles, bundles, copier.Option{DeepCopy: true})

	// fmt.Printf("res.Bundles %+v\n", res.Bundles)

	var total int64

	count.Count(&total)

	res.Total = int32(total)

	return

}

func BundleDetail(uuid string) (res *bundle.BundleProfile, err error) {
	res = new(bundle.BundleProfile)
	bundleProfile := new(model.BundleProfile)
	err = app.ModuleClients.BundleDB.Where("uuid = ?", uuid).First(&bundleProfile).Error
	if err != nil {
		return res, commonErr.ReturnError(err, msg.ErrorGetBundleInfo, "获取套餐信息失败: ")
	}
	//_ = copier.CopyWithOption(&res, bundle, copier.Option{DeepCopy: true})

	res = &bundle.BundleProfile{
		Uuid:             bundleProfile.UUID,
		Name:             bundleProfile.Name,
		Price:            bundleProfile.Price,
		PriceType:        bundleProfile.PriceType,
		Contract:         bundleProfile.Contract,
		Content:          bundleProfile.Content,
		Language:         bundleProfile.Language,
		CreatedAt:        bundleProfile.CreatedAt.String(),
		UpdatedAt:        bundleProfile.UpdatedAt.String(),
		CompanySign:      bundleProfile.CompanySign,
		ContractDuration: int64(bundleProfile.ContractDuration),
		BundleCommonUid:  bundleProfile.BundleCommonUid,
	}
	return
}