timed_tasks/download_file/src/filetext_grpc.go

package main

import (
	"context"
	"google.golang.org/grpc"
	"proto"
	qu "qfw/util"
)

var FileTextClient proto.FileExtractClient

//直接调用接口地址
//func InitFileTextGrpcClient() {
//	defer qu.Catch()
//	qu.Debug("address:", qu.ObjToString(Config["ocrserveraddr"])) //192.168.3.13:22101
//	conn, err := grpc.Dial(qu.ObjToString(Config["ocrserveraddr"]), grpc.WithTransportCredentials(insecure.NewCredentials()))
//	if err != nil {
//		qu.Debug("Init Connect Error: ", err)
//	}
//	FileTextClient = proto.NewFileExtractClient(conn)
//}

func GetFileText_back(fileName, fileUrl, fileType string, fileBytes []byte) (*proto.FileResponse, error) {
	defer qu.Catch()
	req := &proto.Request{
		FileName:    fileName,
		FileUrl:     fileUrl,
		FileType:    fileType,
		FileBytes:   fileBytes,
		ExtractType: 1,
		ReturnType:  0, //正式环境改为0
	}
	fileReq := &proto.FileRequest{
		Message: []*proto.Request{
			req,
		},
	}
	resp, err := FileTextClient.FileExtract(context.Background(), fileReq)
	if err != nil {
		return nil, err
	}
	qu.Debug(resp.Result)
	return resp, nil
}

func GetFileText(conn *grpc.ClientConn, fileName, fileUrl, fileType string, fileBytes []byte) *proto.FileResponse {
	defer qu.Catch()
	FileTextClient = proto.NewFileExtractClient(conn)
	defer conn.Close()
	req := &proto.Request{
		FileName:    fileName,
		FileUrl:     fileUrl,
		FileType:    fileType,
		FileBytes:   fileBytes,
		ExtractType: 1,
		ReturnType:  0, //正式环境改为0
	}
	fileReq := &proto.FileRequest{
		Message: []*proto.Request{
			req,
		},
	}
	resp, err := FileTextClient.FileExtract(context.Background(), fileReq)
	if err != nil {
		return nil
	}
	//qu.Debug(resp.Result)
	return resp
}