package cms

import (
	"errors"
	"fmt"
	"sync"

	"git.rosy.net.cn/baseapi/utils"
	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
	"git.rosy.net.cn/jx-callback/business/partner"
)

type SyncErrResult struct {
	SkuID        int    `json:"商品ID"`
	CategoryName string `json:"分类名"`
	StoreID      int    `json:"门店ID"`
	VendorName   string `json:"平台名"`
	VendorSkuID  string `json:"平台商品ID"`
	NameID       int    `json:"商品nameID"`
	VendorPrice  int64  `json:"平台价"`
	SyncType     string `json:"同步类型"`
	ErrMsg       string `json:"错误信息"`
}

type SyncErrResultLock struct {
	syncErrResult []SyncErrResult
	locker        sync.RWMutex
}

type LoopStoreMapInfo struct {
	VendorID int
	// StoreMapList []*model.StoreMap
}

type VendorSync struct {
}

type SyncError struct {
	Original error  `json:"original"`
	Message  string `json:"message"`
}

type SpecSyncError struct {
	SpecErr error `json:"specErr"`
}

// 对于多门店平台接口的通用处理
type MultiStoreHandlerWrapper struct {
	partner.IMultipleStoresHandler
}

// 对于单门店平台接口的通用处理
type SingleStoreHandlerWrapper struct {
	partner.ISingleStoreHandler
}

var (
	CurVendorSync VendorSync
)

var (
	ErrHaveNotImplementedYet = errors.New("还没有实现")
	ErrEntityNotExist        = errors.New("找不到相应实体")
	SyncErrResultTitle       = []string{
		"商品ID",
		"分类名",
		"门店ID",
		"平台名",
		"平台商品ID",
		"商品nameID",
		"平台价",
		"同步类型",
		"错误信息",
	}
	syncErrResultLock SyncErrResultLock
)

func buildErrMsg(task tasksch.ITask) (err error) {
	err = fmt.Errorf(utils.Format4Output(buildErrMsgJson(task), true))
	return makeSpecSyncError(err)
}

func buildErrMsgJson(task tasksch.ITask) (resultL []*SyncErrResult) {
	failedList := task.GetFailedList()
	for _, v := range failedList {
		for _, vv := range v.([]*partner.StoreSkuInfoWithErr) {
			result := &SyncErrResult{
				SkuID:        0,
				StoreID:      vv.StoreID,
				CategoryName: vv.CategoryName,
				VendorName:   vv.VendoreName,
				VendorSkuID:  "",
				NameID:       0,
				VendorPrice:  0,
				SyncType:     vv.SyncType,
				ErrMsg:       vv.ErrMsg,
			}
			if vv.StoreSkuInfo != nil {
				result.SkuID = vv.StoreSkuInfo.SkuID
				result.VendorSkuID = vv.StoreSkuInfo.VendorSkuID
				result.NameID = vv.StoreSkuInfo.NameID
				result.VendorPrice = vv.StoreSkuInfo.VendorPrice
			}
			resultL = append(resultL, result)
		}
	}
	return resultL
}

func makeSyncError(err error) (newErr error) {
	if err != nil {
		if _, ok := err.(*SyncError); !ok {
			return &SyncError{
				Original: err,
			}
		}
	}
	return err
}

func makeSpecSyncError(err error) (newErr error) {
	if err != nil {
		if _, ok := err.(*SpecSyncError); !ok {
			return &SpecSyncError{
				SpecErr: err,
			}
		}
	}
	return err
}

func (e *SpecSyncError) Error() string {
	return e.SpecErr.Error()
}

func (e *SyncError) Error() string {
	return fmt.Sprintf("本地数据修改成功，但同步失败，请根据错误提示处理！，同步错误信息：%s", e.Original.Error())
}