fix: 通过JSON对象的方式传递RPC的参数

This commit is contained in:
ningyu
2019-05-15 15:20:44 +08:00
parent bbae65f73a
commit cea2140309
2 changed files with 9 additions and 4 deletions
@@ -69,7 +69,10 @@ func init() {
ID string `help:"ID of user"`
}
R(&HistoricProcessInstanceStaticticsOptions{}, "historic-process-instance-statistics", "Delete all contacts for the user", func(s *mcclient.ClientSession, args *HistoricProcessInstanceStaticticsOptions) error {
rst, err := modules.HistoricProcessInstance.DoGetStatistics(s, args.ID)
params := jsonutils.NewDict()
params.Add(jsonutils.NewString(args.ID), "user_id")
rst, err := modules.HistoricProcessInstance.DoGetStatistics(s, params)
if err != nil {
return err
@@ -26,9 +26,11 @@ type HiProcInstManager struct {
ResourceManager
}
func (this *HiProcInstManager) DoGetStatistics(s *mcclient.ClientSession, user_id string) (jsonutils.JSONObject, error) {
hiProcInstPath := fmt.Sprintf("/historic-process-instances?status=unfinished&user_id=%s", user_id)
procTaskPath := fmt.Sprintf("/process-tasks?user_id=%s", user_id)
func (this *HiProcInstManager) DoGetStatistics(s *mcclient.ClientSession, params jsonutils.JSONObject) (jsonutils.JSONObject, error) {
userId, _ := params.GetString("user_id")
hiProcInstPath := fmt.Sprintf("/historic-process-instances?status=unfinished&user_id=%s", userId)
procTaskPath := fmt.Sprintf("/process-tasks?user_id=%s", userId)
hiProcInstObj, _ := this._list(s, hiProcInstPath, "historic-process-instances")
procTaskObj, _ := this._list(s, procTaskPath, "process-tasks")