feat:附件

rpc/consumer/consumer.go

@@ -2,13 +2,14 @@ package main
 
 import (
 	"fmt"
-	"github.com/zeromicro/go-zero/core/logx"
 	"log"
 
 	IC "app.yhyue.com/moapp/jyInfo/rpc/consumer/init"
 	"app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/server"
 	"app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/svc"
 	"app.yhyue.com/moapp/jyInfo/rpc/consumer/type/consumer"
+	"app.yhyue.com/moapp/jyInfo/rpc/util"
+
 	mc "app.yhyue.com/moapp/jybase/common"
 	"app.yhyue.com/moapp/jybase/endless"
 	"github.com/zeromicro/go-zero/core/service"
@@ -37,13 +38,7 @@ func main() {
 		}
 	})
 	//日志记录
-	err := logx.SetUp(logx.LogConf{
-		Mode:  "file",
-		Level: "info",
-		Path:  "./logs",
-	})
-	log.Println("err；", err)
-	//s.AddUnaryInterceptors(util.CustomInterceptors)
+	s.AddUnaryInterceptors(util.CustomInterceptors)
 	defer s.Stop()
 
 	fmt.Printf("Starting rpc server at %s...\n", IC.C.ListenOn)

rpc/consumer/internal/logic/infofileuploadlogic.go

@@ -1,9 +1,7 @@
 package logic
 
 import (
-	"app.yhyue.com/moapp/jyInfo/rpc/consumer/consumer"
 	IC "app.yhyue.com/moapp/jyInfo/rpc/consumer/init"
-	"app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/svc"
 	model "app.yhyue.com/moapp/jyInfo/rpc/model/oss"
 	"bytes"
 	"context"
@@ -11,6 +9,9 @@ import (
 	"strings"
 	"time"
 
+	"app.yhyue.com/moapp/jyInfo/rpc/consumer/consumer"
+	"app.yhyue.com/moapp/jyInfo/rpc/consumer/internal/svc"
+
 	mc "app.yhyue.com/moapp/jybase/common"
 	"github.com/zeromicro/go-zero/core/logx"
 )
@@ -51,7 +52,7 @@ func (l *InfoFileUploadLogic) InfoFileUpload(in *consumer.InfoFileUploadReq) (*c
 		}
 		data.Ftype = ftype
 		resp.Data = &data
-		return &resp, nil
+		return &resp, err
 	}
 	resp.ErrCode = -1
 	resp.ErrMsg = "上传失败"