Function decodeEventDataToPost

internal/domain/events/es/process_util.go:142–159

decodeEventDataToPosts 解析事件数据为 Post 结构体

(data interface{}, posts *Post)

// decodeEventDataToPosts 解析事件数据为 Post 结构体
func decodeEventDataToPost(data interface{}, posts *Post) error {
	config := &mapstructure.DecoderConfig{
		Result:           posts,
		TagName:          "mapstructure",
		WeaklyTypedInput: true,
		DecodeHook: mapstructure.ComposeDecodeHookFunc(
			stringToTimeHookFunc("2006-01-02 15:04:05.999"),
			stringToNullTimeHookFunc("2006-01-02 15:04:05.999"),
		),
	}

	decoder, err := mapstructure.NewDecoder(config)
	if err != nil {
		return err
	}

	return decoder.Decode(data)
}

// decodeEventDataToUser 解析事件数据为 User 结构体
func decodeEventDataToUser(data interface{}, users *User) error {