package main import ( "flag" "fmt" "net/http" "strconv" "strings" "git.algo.com.cn/public/saasapi" "git.algo.com.cn/public/saasapi/pkg/saashttp" "google.golang.org/protobuf/encoding/protojson" ) type bindSetAccountParams struct { target string accounts []int64 saasHttp *saashttp.SaasClient } func RunBindSetAccount(args ...string) error { fs := flag.NewFlagSet("setaccount", flag.ExitOnError) cfgFile := paramConfig(fs) target := paramTarget(fs) accounts := paramAccounts(fs) if err := fs.Parse(args); err != nil { return fmt.Errorf("Command line parse error: %w", err) } // 切割字符串 idsSlice := strings.Split(*accounts, ",") if len(idsSlice) == 1 && idsSlice[0] == "" { idsSlice = []string{} } if fs.NArg() > 0 || len(idsSlice) == 0 || (len(idsSlice) == 1 && idsSlice[0] == "") { fs.PrintDefaults() return nil } numAccounts := []int64{} for _, v := range idsSlice { n, err := strconv.ParseInt(v, 10, 64) if err != nil { return fmt.Errorf("Account parse error. value: %v. %w", v, err) } numAccounts = append(numAccounts, n) } cfg, err := LoadConfigFile(*cfgFile) if err != nil { return fmt.Errorf("LoadConfigFile error: %w", err) } bindSetAccountParams := bindSetAccountParams{ target: *target, accounts: numAccounts, saasHttp: &saashttp.SaasClient{ Client: &http.Client{}, ApiUrls: saashttp.InitAPIUrl(&cfg.ApiUrls), Auth: &cfg.Auth, }, } return doBindSetAccount(bindSetAccountParams) } func doBindSetAccount(p bindSetAccountParams) error { bindSet := &saasapi.BindSet{} saasReq := &saasapi.SaasReq{ Cmd: &saasapi.SaasReq_BindSet{ BindSet: bindSet, }, } for _, v := range p.accounts { bindSet.Binds = append(bindSet.Binds, &saasapi.Bind{ BindId: v, BindType: saasapi.BindType_AccountId, TargetId: p.target, AccountId: v, }) } res, err := p.saasHttp.BindSet(saasReq) if err != nil { return fmt.Errorf("Submit Command error: %w", err) } if res.Code != saasapi.ErrorCode_SUCC { return fmt.Errorf("Command failed. code:%v, status:%v", res.Code, res.Status) } fmt.Printf("bind res: %v\n", protojson.Format(res.GetBindSetRes())) return nil }