jy-docs/jydocs-back/rpc/fileSystemRpc.go

package rpc

import (
	"app.yhyue.com/moapp/jyfs/rpc/filesystem"
	"app.yhyue.com/moapp/jyfs/rpc/filesystemclient"
	"context"
	"fmt"
	"github.com/zeromicro/go-zero/core/discov"
	"github.com/zeromicro/go-zero/zrpc"
	"jy-docs/config"
	"log"
)

// 剑鱼文件系统RPC接口
var jyFilelLib filesystemclient.FileSystem

func init() {
	jyFilelLib = filesystemclient.NewFileSystem(zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Key:   config.JyDocsAppConfig.RpcServers.JyFile.Key,
			Hosts: config.JyDocsAppConfig.RpcServers.JyFile.Address,
		},
	}))
}

// 获取用户对话pdf文件地址
func GetFileContext(userId, ossId string, domain string) (string, error) {
	resp, err := jyFilelLib.GetOssUril(context.Background(), &filesystem.LoadFileReq{
		Domain: domain,
		FileId: ossId,
	})
	if err != nil {
		log.Printf("%s GetFileContext call error %v\n", userId, err)
		return "", err
	}
	if resp.OssUrl == "" {
		log.Printf("%s GetFileContext fail Message \n", userId)
		return "", fmt.Errorf("获取文件异常")
	}
	return resp.OssUrl, nil
}