cws-sdk/ng_cws_client/api.go

package ng_cws_client

import (
	"encoding/json"
	"errors"
	"git.sxidc.com/service-supports/cws-sdk/service"
	"git.sxidc.com/service-supports/cws-sdk/service/request"
	"git.sxidc.com/service-supports/cws-sdk/service/response"
	"git.sxidc.com/service-supports/cws-sdk/utils/http_client"
	"strconv"
)

func launchWorkflowPrepareApi(reqParams *request.LaunchWorkflowPrepareParams) (*response.InfosResponse[response.PrepareInfo], error) {
	requestJson, err := json.Marshal(reqParams)
	if err != nil {
		return nil, err
	}
	postResponse, err := NGCwsClient.NewRequest(http_client.WithNewRequestTimeout(cwsTimeOut)).
		Post(cwsUrl+service.StartWorkFlowPrepareMethodName, requestJson)
	if err != nil {
		return nil, err
	}

	resp := new(response.InfosResponse[response.PrepareInfo])
	err = postResponse.Json(resp)
	if err != nil {
		return nil, err
	}
	if !resp.Success {
		return nil, errors.New(resp.Msg)
	}

	return resp, nil
}

func getWorkTemplateInfoByBusinessTypeApi(businessType string, tenantId string) (string, error) {
	//查询业务类型配置
	queryParams := map[string]string{
		"code":     businessType,
		"tenantId": tenantId,
	}
	newRequest := NGCwsClient.NewRequest(http_client.WithNewRequestTimeout(cwsTimeOut))
	newRequest.SetQueryParams(queryParams)
	resp, err := newRequest.Get(cwsUrl + service.GetWorkTemplateByCodeMethodName)
	if err != nil {
		return "", err
	}
	respInfo := new(response.InfoResponse[response.BusinessCatalogsInfoWithWorkflowTemplate])
	err = resp.Json(respInfo)
	if err != nil {
		return "", err
	}
	if !respInfo.Success {
		return "", errors.New(respInfo.Msg)
	}
	return respInfo.Info.WorkTemplateId, nil
}

// 条件查询流程列表信息
func getWorkflowListApi(reqParams *request.QueryMyWorkflowParams) (*response.InfosResponse[response.WorkflowInfo], error) {
	queryParams := map[string]string{
		"pageNo":             strconv.Itoa(reqParams.PageNo),
		"pageSize":           strconv.Itoa(reqParams.PageSize),
		"tenantId":           reqParams.TenantID,
		"launchUserId":       reqParams.LaunchUserID,
		"launchUserName":     reqParams.LaunchUserName,
		"workflowTemplateId": reqParams.TemplateID,
		"status":             strconv.Itoa(reqParams.Status),
		"matter":             reqParams.Matter,
		"catalogId":          reqParams.CatalogID,
	}
	newRequest := NGCwsClient.NewRequest(http_client.WithNewRequestTimeout(cwsTimeOut))
	newRequest.SetQueryParams(queryParams)
	resp, err := newRequest.Get(cwsUrl + service.GetWorkflowList)
	if err != nil {
		return nil, err
	}
	respInfo := new(response.InfosResponse[response.WorkflowInfo])
	err = resp.Json(respInfo)
	if err != nil {
		return nil, err
	}
	if !respInfo.Success {
		return nil, errors.New(respInfo.Msg)
	}
	return respInfo, nil
}

// 通过流程ID批量查询流程列表信息
func getWorkflowListByWorkflowIdListApi(reqParams *request.QueryWorkflowByIDs) (*response.InfosResponse[response.WorkflowInfo], error) {
	requestJson, err := json.Marshal(reqParams)
	if err != nil {
		return nil, err
	}
	postResponse, err := NGCwsClient.NewRequest(http_client.WithNewRequestTimeout(cwsTimeOut)).
		Post(cwsUrl+service.GetWorkflowListByWorkflowIdList, requestJson)
	if err != nil {
		return nil, err
	}

	resp := new(response.InfosResponse[response.WorkflowInfo])
	err = postResponse.Json(resp)
	if err != nil {
		return nil, err
	}
	if !resp.Success {
		return nil, errors.New(resp.Msg)
	}

	return resp, nil
}