package domainService

import (
	"fmt"
	"github.com/linmadan/egglib-go/core/application"
	pgTransaction "github.com/linmadan/egglib-go/transaction/pg"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/domain"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/infrastructure/redis"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/infrastructure/repository"
	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-manufacture/pkg/log"
	"strconv"
	"time"
)

type PGBatchAddProductService struct {
	transactionContext *pgTransaction.TransactionContext
}

func (ptr *PGBatchAddProductService) BatchAddProduct(opt *domain.OperateInfo, list []*domain.ImportProductItem) ([]interface{}, error) {
	var failRows = make([]interface{}, 0)

	productRepository, _ := repository.NewProductRepository(ptr.transactionContext)
	_, products, _ := productRepository.Find(map[string]interface{}{"companyId": opt.CompanyId, "orgId": opt.OrgId})
	var mapProduct = make(map[string]*domain.Product)
	for i := range products {
		mapProduct[products[i].ProductCode] = products[i]
	}

	var generator = redis.NewProductCodeCache(opt.CompanyId)
	for i := range list {
		item := list[i]
		if err := item.Valid(); err != nil {
			item.FailReason = err.Error()
			failRows = append(failRows, item)
			continue
		}
		unitWeight, _ := strconv.ParseFloat(item.UnitWeight, 64)
		newItem := &domain.Product{
			CompanyId:       opt.CompanyId,
			OrgId:           opt.OrgId,
			ProductCode:     item.ProductCode,
			ProductName:     item.ProductName,
			ProductCategory: item.ProductCategory,
			ProductSpec: &domain.UnitQuantity{
				Unit:       item.Unit,
				UnitWeight: unitWeight,
			},
			CreatedAt: time.Now(),
			UpdatedAt: time.Now(),
		}
		if len(newItem.ProductCode) == 0 {
			code, err := redis.GenCode(generator)
			if err != nil {
				log.Logger.Error(err.Error())
				return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "服务器异常")
			}
			newItem.ProductCode = code
		}

		if _, ok := mapProduct[newItem.ProductCode]; !ok {
			mapProduct[newItem.ProductCode] = newItem
		} else {
			item.FailReason = "导入的产品编号已存在"
			failRows = append(failRows, item)
			continue
		}
		if _, err := productRepository.Save(newItem); err != nil {
			log.Logger.Error(err.Error())
			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "服务器异常")
		}
	}
	return failRows, nil
}

func NewPGBatchAddProductService(transactionContext *pgTransaction.TransactionContext) (*PGBatchAddProductService, error) {
	if transactionContext == nil {
		return nil, fmt.Errorf("transactionContext参数不能为nil")
	} else {
		return &PGBatchAddProductService{
			transactionContext: transactionContext,
		}, nil
	}
}