package esentity

import (
	"strings"

	"gitee.com/gowebframe3/webframe.git/goconfig/base/basedto"
	"gitee.com/gowebframe3/webframe.git/goconfig/base/baseindex"
	"gitee.com/gowebframe3/webframe.git/goconfig/ichubconfig"
	"gitee.com/gowebframe3/webframe.git/goconfig/ichublog/golog"
	"gitee.com/gowebframe3/webframe.git/goweb/pagemodel"
	"gitee.com/gowebframe3/webframe.git/goweb/webclient/eswebclient/webfacade"
	"gitee.com/gowebframe3/webframe.git/goweb/webclient/eswebclient/webfacade/webui"
	"github.com/gogf/gf/v2/util/gconv"
	jsoniter "github.com/json-iterator/go"
	"github.com/olivere/elastic/v7"
)

/*
@Title    文件名称: sys_dept_es.go
@Description  描述: 统一返回结构

@Author  作者: raymond@163.com  时间(2025-12-07 22:24:50)
@Update  作者: raymond@163.com  时间(2025-12-07 22:24:50)
*/

type SysDeptEs struct {
	basedto.BaseEntity
	//basedto.BaseEntityIndex

	DeptId   string `json:"deptId"`
	CreateBy string `json:"createBy"`
}

func NewSysDeptEs() *SysDeptEs {
	return &SysDeptEs{}
}

type SysDeptEsRequest struct {
	basedto.BaseEntity
	webui.WebuiRequest

	SysDeptEs `json:"param"`
}

func NewSysDeptEsRequest() *SysDeptEsRequest {
	return &SysDeptEsRequest{}
}

func (self *SysDeptEs) PkeyName() string {
	return "id"
}
func (self *SysDeptEs) PkeyValue() string {
	return gconv.String(self.DeptId)
}
func (self *SysDeptEs) TableName() string {
	return "ichub_sys_dept"
}

//	func (self *SysDeptEs) TableName() string {
//		return common.Env+"_sys_dept"
//	}
func (self *SysDeptEs) IndexName() string {
	return self.TableName()
}

func (self *SysDeptEs) GetMapping() string {
	return `{
     "settings": {
          "index": {
               "routing": {
                    "allocation": {
                         "include": {
                              "_tier_preference": "data_content"
                         }
                    }
               },
               "number_of_shards": "1",
               "number_of_replicas": "1"
          }
     },
     "mappings": {
          "properties": {
               "create_by": {
                    "type": "text",
                    "fields": {
                         "keyword": {
                              "ignore_above": 256,
                              "type": "keyword"
                         }
                    }
               },
               "dept_id": {
                    "type": "text",
                    "fields": {
                         "keyword": {
                              "ignore_above": 256,
                              "type": "keyword"
                         }
                    }
               }
          }
     }
}`
}
func (self *SysDeptEs) Mapping() string {
	return self.GetMapping()
}
func (self *SysDeptEs) Unmarshal(data []byte) error {
	return jsoniter.Unmarshal(data, self)
}

func (self SysDeptEs) IndexID() string {
	return self.PkeyName()
}

func (self SysDeptEs) AliasName() string {
	return self.IndexName() + "_alias"
}

func (self *SysDeptEs) InitDoc() baseindex.IndexEsObject {
	ss := *self
	return &ss
}

func (self *SysDeptEs) EsFill(p any) error {
	var err = gconv.Struct(p, self)
	if err != nil {
		golog.Error("SysDeptEs err:", err)
	}
	return err
}

func (self *SysDeptEs) Init() {
}
func (self *SysDeptEs) Shutdown() {

}

func NewWebFacadeSysDeptEsOf(q elastic.Query) *webfacade.WebFacade[*SysDeptEs] {
	var facade = webfacade.DefaultOf[*SysDeptEs](q)
	facade.Query(q)
	return facade
}

func NewWebFacadeSysDeptEs() *webfacade.WebFacade[*SysDeptEs] {
	return webfacade.Default[*SysDeptEs]()

}

func (self *SysDeptEs) DefaultOf(q elastic.Query) *webfacade.WebFacade[*SysDeptEs] {
	return NewWebFacadeSysDeptEsOf(q)

}
func (self *SysDeptEs) Default() *webfacade.WebFacade[*SysDeptEs] {
	return NewWebFacadeSysDeptEs()
}

func (self *SysDeptEs) ObjectKey() string {
	var keys = []any{ichubconfig.FindEnv(), "es", self.TableName(), self.PkeyValue()}
	return strings.Join(gconv.SliceStr(keys), ":")
}
func (self *SysDeptEs) EsFindId() *pagemodel.IchubResult[*SysDeptEs] {
	var ret = NewWebFacadeSysDeptEs().EsFindKeyId(self.PkeyName(), self.PkeyValue())
	if ret.IsFailed() {
		golog.Error("SysDeptEs [EsFindKey] ret:", ret)
	}
	return ret
}