package riotutil

import (
	"encoding/json"
	"reflect"
	"strings"

	"gitee.com/tomatomeatman/golang-repository/bricks2/model/msgentity"

	Log "github.com/cihub/seelog"
	"github.com/go-ego/riot"
	"github.com/go-ego/riot/types"
)

type RiotUtil struct{}

// 添加
func (ru RiotUtil) Add(dbName, key, data string) *msgentity.MsgEntity {
	if strings.TrimSpace(dbName) == "" {
		return msgentity.Err(1001, "未指定搜索库")
	}

	if strings.TrimSpace(key) == "" {
		return msgentity.Err(1002, "关键字为空")
	}

	dbName = strings.TrimSpace(dbName)
	key = strings.TrimSpace(key)

	searcher := riot.Engine{}
	searcher.Init(types.EngineOpts{
		Using:    3,
		GseDict:  "zh",
		UseStore: true,
		//GseDict: "./dictionary.txt",
		//GseDict:       "./temp/test_dict.txt",
		//StopTokenFile: "./temp/stop_tokens.txt",
		StoreFolder: "./temp/riot/" + dbName, //存储库
	})

	defer searcher.Close()

	searcher.Index(key, types.DocData{Content: data}, true)

	searcher.Flush() //等待索引刷新完毕

	return msgentity.Success(key, "添加内容成功")
}

// 添加
func (ru RiotUtil) Adds(dbName string, data map[string]string) *msgentity.MsgEntity {
	if strings.TrimSpace(dbName) == "" {
		return msgentity.Err(1001, "未指定搜索库")
	}

	if len(data) < 1 {
		return msgentity.Err(1002, "内容为空")
	}

	dbName = strings.TrimSpace(dbName)

	searcher := riot.Engine{}
	searcher.Init(types.EngineOpts{
		Using:    3,
		GseDict:  "zh",
		UseStore: true,
		//GseDict: "./dictionary.txt",
		//GseDict:       "./temp/test_dict.txt",
		//StopTokenFile: "./temp/stop_tokens.txt",
		StoreFolder: "./temp/riot/" + dbName, //存储库
	})

	defer searcher.Close()

	for key, val := range data {
		key = strings.TrimSpace(key)
		if key == "" {
			continue
		}

		searcher.Index(key, types.DocData{Content: val}, true)
	}

	searcher.Flush() //等待索引刷新完毕

	return msgentity.Success(data, "添加内容成功")
}

// 删除
func (ru RiotUtil) Del(dbName, key string) *msgentity.MsgEntity {
	if strings.TrimSpace(dbName) == "" {
		return msgentity.Err(1001, "未指定搜索库")
	}

	if strings.TrimSpace(key) == "" {
		return msgentity.Err(1002, "关键字为空")
	}

	dbName = strings.TrimSpace(dbName)
	key = strings.TrimSpace(key)

	searcher := riot.Engine{}
	searcher.Init(types.EngineOpts{
		Using:    3,
		GseDict:  "zh",
		UseStore: true,
		//GseDict: "./dictionary.txt",
		//GseDict:       "./temp/test_dict.txt",
		//StopTokenFile: "./temp/stop_tokens.txt",
		StoreFolder: "./temp/riot/" + dbName, //存储库
	})

	defer searcher.Close()

	searcher.RemoveDoc(key, true)

	searcher.Flush() //等待索引刷新完毕

	return msgentity.Success(key, "删除内容成功")
}

// 搜索
func (ru RiotUtil) Find(dbName, key string, entity interface{}) *msgentity.MsgEntity {
	if strings.TrimSpace(dbName) == "" {
		return msgentity.Err(1001, "未指定搜索库")
	}

	if strings.TrimSpace(key) == "" {
		return msgentity.Err(1002, "关键字为空")
	}

	dbName = strings.TrimSpace(dbName)
	key = strings.TrimSpace(key)

	searcher := riot.Engine{}
	searcher.Init(types.EngineOpts{
		Using:    3,
		GseDict:  "zh",
		UseStore: true,
		//GseDict: "./dictionary.txt",
		//GseDict:       "./temp/test_dict.txt",
		//StopTokenFile: "./temp/stop_tokens.txt",
		StoreFolder: "./temp/riot/" + dbName, //存储库
	})

	defer searcher.Close()
	searcher.Flush() //等待索引刷新完毕

	res := searcher.Search(types.SearchReq{Text: key})

	if res.NumDocs < 1 {
		return msgentity.Err(1003, "搜索结束,没有发现数据")
	}

	if entity == nil {
		result := []string{}
		for _, val := range res.Docs.(types.ScoredDocs) {
			result = append(result, val.Content)
		}

		return msgentity.Success(result, "搜索结束")
	}

	result := []interface{}{}
	for _, val := range res.Docs.(types.ScoredDocs) {
		result = append(result, ru.toObj(val.Content, entity))
	}

	return msgentity.Success(result, "搜索结束")
}

// 内容转换到结构实体
func (ru RiotUtil) toObj(str string, entity interface{}) *msgentity.MsgEntity {
	if entity == nil {
		entity = map[string]interface{}{}
	}

	str = strings.TrimSpace(str)
	if str == "" {
		return msgentity.Err(1003, "没有数据")
	}

	rve := reflect.New(reflect.TypeOf(entity)).Elem()
	result := rve.Interface()

	err := json.Unmarshal([]byte(str), &result)
	if err != nil {
		Log.Error("Json字符串转换异常: %+v\n", err)
		return msgentity.Err(1004, "字符串转换异常")
	}

	if (!strings.Contains(reflect.TypeOf(result).String(), "map[string]interface")) && (!strings.Contains(reflect.TypeOf(entity).String(), "map[string]interface")) {
		return msgentity.Success(result, "转换结束")
	}

	//--如果转换发生错误则进行再次转换--//
	// var vMap map[string]interface{}
	vMap := result.(map[string]interface{})
	for key, val := range vMap {
		field := rve.FieldByName(key)
		if !field.IsValid() {
			continue
		}

		if (field.Type().String() == "int64") && (reflect.TypeOf(val).String() == "float64") {
			field.Set(reflect.ValueOf(int64(val.(float64))))
			continue
		}

		field.Set(reflect.ValueOf(val))
	}

	return msgentity.Success(rve.Interface(), "转换结束")
}