添加详情api

mesh/bus/api.go

@@ -0,0 +1,49 @@
+package bus
+
+import (
+	"context"
+	"fmt"
+	"mesh/db"
+	"mesh/db/model"
+	"mesh/db/repo"
+
+	"github.com/nats-io/nats.go"
+	"infish.cn/comm"
+)
+
+type ReqDetail struct {
+	Id string
+}
+
+func RegLibDetail() *comm.NatsMsgReplyer {
+
+	return &comm.NatsMsgReplyer{
+		Subject: "meshlib.item.detail",
+		Entity:  func() interface{} { return &ReqDetail{} },
+		Cb2: func(msg *nats.Msg, entity interface{}) (interface{}, error) {
+			req, ok := entity.(*ReqDetail)
+			if !ok {
+				return nil, fmt.Errorf("参数错误不是ReqDetail类型")
+			}
+			if len(req.Id) < 1 {
+				return nil, fmt.Errorf("Id不能为空")
+			}
+
+			var CreateRepoCtx = func() *repo.RepoSession {
+				return &repo.RepoSession{
+					Ctx:    context.Background(),
+					Client: db.MongoClient,
+				}
+			}
+			out := &model.HubMesh{}
+			ok, err := repo.RepoSeachDoc(CreateRepoCtx(), &repo.DocSearchOptions{CollectName: repo.CollectionHubMeshes, Query: repo.Map{"_id": req.Id}}, out)
+			if err != nil {
+				return nil, err
+			}
+			if !ok {
+				return nil, fmt.Errorf("查询的模型库不存在")
+			}
+			return out, nil
+		},
+	}
+}

mesh/bus/main.go

@@ -12,7 +12,9 @@ func NewNatsBus(app *conf.AppConf) *comm.NatsBus {
 	bus, _ := comm.NewNatsBus2(app.Nats.Url, app.Nats.MaxReconnect,
 		app.Nats.ReconnDelaySecond,
 		[]*comm.NatsStreamWather{},
-		[]*comm.NatsMsgReplyer{})
+		[]*comm.NatsMsgReplyer{
+			RegLibDetail(),
+		})
 	NatsCenter = bus
 
 	return NatsCenter