存算联动修改

Former-commit-id: 617e29e56c

api/desc/storelink/pcm-storelink.api

@@ -99,7 +99,8 @@ type (
     }
 
     GetParticipantsResp {
-
+        Success bool `json:"success"`
+        Participants []Participant `json:"participant"`
     }
 
     GetResourceSpecsReq {
@@ -107,6 +108,20 @@ type (
     }
 
     GetResourceSpecsResp {
+        Success bool `json:"success"`
+        ResourceSpecs []ResourceSpec `json:"resourceSpecs"`
+    }
 
+    ResourceSpec {
+        ParticipantId string `json:"participantId"`
+        ParticipantName string `json:"participantName"`
+        SpecName string `json:"resourceSpecName"`
+        SpecId string `json:"resourceSpecId"`
+    }
+
+    Participant {
+        ParticipantId string `json:"id"`
+        ParticipantName string `json:"name"`
+        ParticipantType string `json:"type"`
     }
 )

api/internal/storeLink/storeLink.go

@@ -5,6 +5,7 @@ import (
 	"github.com/pkg/errors"
 	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/svc"
 	"gitlink.org.cn/jcce-pcm/pcm-coordinator/api/internal/types"
+	"gitlink.org.cn/jcce-pcm/pcm-coordinator/pkg/models"
 	"gitlink.org.cn/jcce-pcm/pcm-participant-octopus/octopus"
 )
 
@@ -33,9 +34,11 @@ type StoreLink struct {
 	ILinkage Linkage
 }
 
-// todo 根据participantId 创建对应对象
 func NewStoreLink(ctx context.Context, svcCtx *svc.ServiceContext, partId int64) *StoreLink {
-	linkStruct := NewOctopusLink(ctx, svcCtx, "hanwuji")
+	var participant models.ScParticipantPhyInfo
+	svcCtx.DbEngin.Raw("select * from sc_participant_phy_info where id = ?", partId).Scan(&participant)
+
+	linkStruct := NewOctopusLink(ctx, svcCtx, participant.Name)
 	return &StoreLink{ILinkage: linkStruct}
 }