jypkg/middleground/base.go

// 微服务 基础服务 jyBase
package middleground

import (
	bbc "bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXBase/rpc/bxbase"
	"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXBase/rpc/type/bxbase"
	"context"
	"github.com/zeromicro/go-zero/core/discov"
	"github.com/zeromicro/go-zero/zrpc"
	"log"
)

type jyBase struct {
	hosts  []string
	key    string
	client zrpc.Client
}

func newBase(hosts []string, key string) *jyBase {
	b := &jyBase{
		hosts: hosts,
		key:   key,
	}
	b.client = b.NewClient()
	return b
}

func (b *jyBase) NewClient() zrpc.Client {
	if b.client != nil && b.client.Conn() != nil {
		return b.client
	}
	client, err := zrpc.NewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: b.hosts,
			Key:   b.key,
		},
	})
	if err != nil {
		log.Println(err)
		return nil
	}
	b.client = client
	return client
}

// 搜索标签 过滤
func (b *jyBase) CheckSearch(asr *bxbase.AddSearchReq) *bxbase.CheckRes {
	client := b.NewClient()
	if client == nil {
		return nil
	}
	//defer client.Conn().Close()
	resp, err := bbc.NewBxbase(client).CheckSearch(context.Background(), asr)
	if err != nil {
		log.Println(err)
		return nil
	}
	return resp
}

// 添加搜索标签
func (b *jyBase) AddSearch(asr *bxbase.AddSearchReq) *bxbase.CommonRes {
	client := b.NewClient()
	if client == nil {
		return nil
	}
	//defer client.Conn().Close()
	resp, err := bbc.NewBxbase(client).AddSearch(context.Background(), asr)
	if err != nil {
		log.Println(err)
		return nil
	}
	return resp
}

// 删除搜索标签
func (b *jyBase) DelSearch(dsr *bxbase.DelSearchReq) *bxbase.CommonRes {
	client := b.NewClient()
	if client == nil {
		return nil
	}
	//defer client.Conn().Close()
	resp, err := bbc.NewBxbase(client).DelSearch(context.Background(), dsr)
	if err != nil {
		log.Println(err)
		return nil
	}
	return resp
}

// 搜索标签
func (b *jyBase) ShowSearch(ssr *bxbase.ShowSearchReq) *bxbase.ShowSearchRes {
	client := b.NewClient()
	if client == nil {
		return nil
	}
	//defer client.Conn().Close()
	resp, err := bbc.NewBxbase(client).ShowSearch(context.Background(), ssr)
	if err != nil {
		log.Println(err)
		return nil
	}
	return resp
}