floraachy
/
pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pcm api修改 

Former-commit-id: 528898e30240dfb33e757c1522ff8dbfa38614dd
This commit is contained in:
tzwang 2023-09-15 10:00:11 +08:00
parent 86cbae719d
commit bd7b0cee71
2 changed files with 30 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
api/desc/pcm.api
View File

@ -302,14 +302,14 @@ service pcm {
get /storelink/getImageList (GetLinkImageListReq) returns (GetLinkImageListResp) get /storelink/getImageList (GetLinkImageListReq) returns (GetLinkImageListResp)
@handler DeleteLinkImageHandler @handler DeleteLinkImageHandler
delete /storelink/deleteImageList (DeleteLinkImageReq) returns (DeleteLinkImageResp) delete /storelink/deleteImage (DeleteLinkImageReq) returns (DeleteLinkImageResp)
@handler SubmitLinkTaskHandler @handler SubmitLinkTaskHandler
post /storelink/submitLinkTask (SubmitLinkTaskReq) returns (SubmitLinkTaskResp) post /storelink/submitTask (SubmitLinkTaskReq) returns (SubmitLinkTaskResp)
@handler GetLinkTaskHandler @handler GetLinkTaskHandler
get /storelink/getLinkTask (GetLinkTaskReq) returns (GetLinkTaskResp) get /storelink/getTask (GetLinkTaskReq) returns (GetLinkTaskResp)
@handler DeleteLinkTaskHandler @handler DeleteLinkTaskHandler
delete /storelink/deleteLinkTask (DeleteLinkTaskReq) returns (DeleteLinkTaskResp) delete /storelink/deleteTask (DeleteLinkTaskReq) returns (DeleteLinkTaskResp)
} }

28
api/internal/pkg/storeLink/storeLink.go
View File

@ -21,6 +21,14 @@ const (
COMMA = "," COMMA = ","
) )
var (
OctImgStatus = map[int32]string{
1: "未上传",
3: "制作完成",
4: "制作失败",
}
)
type StoreLink struct { type StoreLink struct {
ILinkage Linkage ILinkage Linkage
} }
@ -37,14 +45,30 @@ func ConvertType[T any](in *T) (interface{}, error) {
var resp types.GetLinkImageListResp var resp types.GetLinkImageListResp
inresp := (interface{})(in).(*octopus.GetUserImageListResp) inresp := (interface{})(in).(*octopus.GetUserImageListResp)
resp.Success = inresp.Success resp.Success = inresp.Success
resp.ErrorMsg = inresp.Error.Message if inresp.Error == nil {
resp.ErrorMsg = ""
} else {
resp.ErrorMsg = inresp.Error.Message
}
for _, v := range inresp.Payload.Images { for _, v := range inresp.Payload.Images {
var image types.ImageSl var image types.ImageSl
image.ImageId = v.Image.Id image.ImageId = v.Image.Id
image.ImageName = v.Image.ImageName image.ImageName = v.Image.ImageName
image.ImageStatus = OctImgStatus[v.Image.ImageStatus]
resp.Images = append(resp.Images, image) resp.Images = append(resp.Images, image)
} }
return resp, nil
case *octopus.DeleteImageResp:
var resp types.DeleteLinkImageResp
return resp, nil
case *octopus.CreateTrainJobResp:
var resp types.SubmitLinkTaskResp
return resp, nil
case *octopus.GetTrainJobResp:
var resp types.GetLinkTaskResp
return resp, nil
case *octopus.DeleteTrainJobResp:
var resp types.DeleteLinkTaskResp
return resp, nil return resp, nil
default: default:
return nil, errors.New("type convert fail") return nil, errors.New("type convert fail")