database

package

v0.0.0-...-59e287b Latest Latest Go to latest Published: Oct 15, 2025 License: Apache-2.0 Imports: 33 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/WeBankPartners/wecube-platform

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddProcCacheData(ctx context.Context, procInsId string, dataBinding []*models.ProcDataBinding) (err error)
func AddProcDefCollect(ctx context.Context, procDefId, operator string) (err error)
func AddProcScheduleExecTimes(ctx context.Context, id string)
func AddProcessDefinition(ctx context.Context, user string, param models.ProcessDefinitionParam) (draftEntity *models.ProcDef, err error)
func AddRoleMenu(ctx context.Context, menu models.RoleMenu) (err error)
func AddTransExportCustomer(ctx context.Context, exportCustomer *models.DataTransExportCustomerTable) (err error)
func AddUseRoles(ctx context.Context, procDefId string, useRoles []string) (err error)
func AddWorkflowOperation(ctx context.Context, operation *models.ProcRunOperation) (lastInsertId int64, err error)
func AnalyzeCMDBDataExport(ctx context.Context, param *models.AnalyzeDataTransParam) (actions []*db.ExecAction, err error)
func AnalyzePluginConfigDataExport(ctx context.Context, transExportId string) (actions []*db.ExecAction, err error)
func AutoAppendExportParam(ctx context.Context, userToken string, param models.DataTransExportParam) (newParam models.DataTransExportParam, err error)
func BatchAddProcDefPermission(ctx context.Context, procDefId string, permission models.PermissionToRole) (err error)
func BatchEnablePluginConfig(c *gin.Context, reqParam []*models.PluginConfigsBatchEnable, ...) (err error)
func BuildDockerEnvMap(ctx context.Context, envMap map[string]string, ...) (replaceMap map[string]string, err error)
func BuildPackageMenuItemDto(ctx context.Context, menus *models.PluginPackageMenus) *models.MenuItemDto
func CalAssignedPluginPackageMenusByMenuCode(ctx context.Context, menuCode string) (result []*models.PluginPackageMenus, err error)
func CalAvailablePluginPackageMenus(ctx context.Context) (result []*models.PluginPackageMenus, err error)
func CalcWebDisplayStep(detailList []*models.TransImportDetailTable) models.ImportWebDisplayStep
func CheckCollectBatchExecTemplate(c *gin.Context, reqParam *models.BatchExecutionTemplateCollect) (result *models.CheckBatchExecTemplateResp, err error)
func CheckIsCollected(c *gin.Context, templateData []*models.BatchExecutionTemplate, userId string) (err error)
func CheckPluginPackageDependence(ctx context.Context, pluginPackageId string) (ok bool, err error)
func CheckProcDefStatus(ctx context.Context, procDefId string) (err error)
func CheckProcInsUserPermission(ctx context.Context, userRoleList []string, procInsId string) (legal bool, err error)
func CheckProcSubRunning(ctx context.Context, procRunNodeId string) (runningRows []*models.ProcRunNodeSubProc, err error)
func CheckServerPortRunning(ctx context.Context, serverIp string, port int) (running bool, err error)
func CheckSubProcStart(ctx context.Context, sessionId string) (isSubProcSession bool, err error)
func CollectBatchExecTemplate(c *gin.Context, reqParam *models.BatchExecutionTemplateCollect) (err error)
func CopyProcessDefinition(ctx context.Context, procDef *models.ProcDef, operator string) (newProcDefId string, err error)
func CopyProcessDefinitionByDto(param models.ProcDefImportDto, procDef *models.ProcessDefinitionDto) (err error)
func CreateCertification(ctx context.Context, lic *models.WeLicense, userId string) (cert *models.PluginCertification, err error)
func CreateExport(c context.Context, param models.CreateExportParam, operator string) (transExportId string, err error)
func CreateOrUpdateBatchExecTemplate(c *gin.Context, reqParam *models.BatchExecutionTemplate) (result *models.BatchExecutionTemplate, err error)
func CreatePluginPackagePullReq(ctx context.Context, data *models.PluginArtifactPullReq, userId string) (result *models.PluginArtifactPullReq, err error)
func CreateProcInsEvent(ctx context.Context, param *models.ProcStartEventParam, ...) (eventId int64, err error)
func CreateProcInstance(ctx context.Context, procStartParam *models.ProcInsStartParam, operator string) (procInsId string, workflowRow *models.ProcRunWorkflow, ...)
func CreateProcPreview(ctx context.Context, previewRows []*models.ProcDataPreview, ...) (err error)
func CreateProcSchedule(ctx context.Context, param *models.CreateProcScheduleParam) (result *models.ProcScheduleConfig, err error)
func CreatePublicProcInstance(ctx context.Context, startParam *models.RequestProcessData, operator string) (procInsId string, workflowRow *models.ProcRunWorkflow, ...)
func CreateResourceItem(ctx context.Context, params []*models.ResourceItem, operator string) (err error)
func CreateResourceServer(ctx context.Context, params []*models.ResourceServer) (withHostServer bool, err error)
func CreateSystemVariables(ctx context.Context, params []*models.SystemVariables) (err error)
func CreateTransImportProcExecData(ctx context.Context, procExecList []*models.TransImportProcExecTable) (err error)
func DataTransExportArtifactData(ctx context.Context, transExportParam *models.TransExportJobParam) (err error)
func DataTransExportCMDBData(ctx context.Context, transExportId, path string) (err error)
func DataTransExportPluginConfig(ctx context.Context, transExportId, path string) (err error)
func DataTransImportCMDBData(ctx context.Context, inputFile string) (err error)
func DeactivateSystemVariablesByPackage(ctx context.Context, name, version string) (err error)
func DecodeUIPassword(ctx context.Context, inputValue string) (output string, err error)
func DecommissionPluginPackage(ctx context.Context, pluginPackageId, operator string) (err error)
func DecompressExportZip(ctx context.Context, nexusUrl, transImportId string) (localPath string, err error)
func DelProcDefCollect(ctx context.Context, procDefId, operator string) (err error)
func DeleteCertification(ctx context.Context, certId string) (err error)
func DeletePluginConfig(c *gin.Context, pluginConfigId string) (err error)
func DeleteProcDef(ctx context.Context, procDefId string) (err error)
func DeleteProcDefChain(ctx context.Context, procDefId string) (err error)
func DeleteProcDefNode(ctx context.Context, procDefId, nodeId string) (err error)
func DeleteProcDefNodeLink(ctx context.Context, procDefId string, linkId, operator string) (err error)
func DeleteProcDefNodeLinkByNode(ctx context.Context, nodeId string) (err error)
func DeleteProcDefNodeParam(ctx context.Context, procDefNodeId string) (err error)
func DeleteProcDefNodeParamByNodeId(ctx context.Context, nodeId string) (err error)
func DeleteProcSchedule(ctx context.Context, id string) (err error)
func DeleteResourceItem(ctx context.Context, params []*models.ResourceItem) (err error)
func DeleteResourceServer(ctx context.Context, params []*models.ResourceServer) (err error)
func DeleteRoleMenuById(ctx context.Context, id string) (err error)
func DeleteSystemVariables(ctx context.Context, params []*models.SystemVariables) (err error)
func DeleteTemplate(c *gin.Context, templateId string) (err error)
func DeleteTransExportCustomer(ctx context.Context, id string) (err error)
func DisableAllPluginConfigsByPackageId(ctx context.Context, pluginPackageId string) (err error)
func DownloadImportArtifactPackage(ctx context.Context, nexusConfig *models.TransDataImportConfig, ...) (localFilePath, dirPath string, err error)
func DownloadImportArtifactPackages(ctx context.Context, nexusUrl, transImportId string) (localDir string, fileNameList []string, err error)
func ExecExportAction(ctx context.Context, callParam *models.CallTransExportActionParam) (err error)
func ExportPluginConfigs(c context.Context, pluginPackageId string, ...) (result *models.PackagePluginsXML, err error)
func ExportTemplate(c context.Context, userToken string, ...) (result []*models.BatchExecutionTemplate, err error)
func GeneratePluginEnv(subsystemPubKey, subsystemPriKey, pluginName string) (lic_code, lic_pk, lic_data, lic_sign string, err error)
func GetAllByRoleName(ctx context.Context, roleName string) (list []*models.RoleMenu, err error)
func GetAllByRoleNames(ctx context.Context, roleNames []string) (list []*models.RoleMenu, err error)
func GetAllByServiceNameAndConfigStatus(ctx context.Context, serviceName, status string) (list []*models.RichPluginConfigInterfaces, err error)
func GetAllMenusByCodeAndPackageStatus(ctx context.Context, code string, statusArr []string) (result []*models.PluginPackageMenus, err error)
func GetAllMenusByCodesAndPackageStatus(ctx context.Context, codes []string, statusArr []string) (result map[string][]*models.PluginPackageMenus, err error)
func GetAllMenusByPackageStatus(ctx context.Context, statusArr []string) (result []*models.PluginPackageMenus, err error)
func GetAllRootMenus(ctx context.Context) (result []*models.MenuItemDto, err error)
func GetAllSysMenus(ctx context.Context) (result []*models.MenuItemDto, err error)
func GetAllTemplate(c *gin.Context) (templateData []*models.BatchExecutionTemplate, err error)
func GetAllTransExport(ctx context.Context) (list []*models.TransExportTable, err error)
func GetAllTransExportOptions(ctx context.Context) (options models.TransExportHistoryOptions, err error)
func GetAllTransImport(ctx context.Context) (list []*models.TransImportTable, err error)
func GetAllTransImportOptions(ctx context.Context) (options models.TransExportHistoryOptions, err error)
func GetAvailableContainerHost() (availableHost []string, err error)
func GetBatchExec(c *gin.Context, batchExecId string) (result *models.BatchExecution, err error)
func GetBatchExecutionTemplatePermissionByIds(ctx context.Context, batchExecutionTemplates []string) (list []*models.BatchExecutionTemplateRole, err error)
func GetBatchPluginConfigs(c *gin.Context, pluginPackageId string) (result []*models.PluginConfigsOutlines, err error)
func GetBusinessList(localPath string) (result models.GetBusinessListRes, err error)
func GetCertifications(ctx context.Context) (result []*models.PluginCertification, err error)
func GetConfigInterfaces(ctx context.Context, pluginConfigId string) (result []*models.PluginInterfaceQueryObj, err error)
func GetConfigInterfacesById(ctx context.Context, id string) (result *models.PluginConfigInterfaces, err error)
func GetCreatePluginConfigActions(ctx context.Context, pluginConfigId string, ...) (resultActions []*db.ExecAction, err error)
func GetDashboardTransExportAnalyzeData(ctx context.Context, transExportId string) (dashboardAnalyze models.TransExportAnalyzeDataTable, err error)
func GetDataModels(ctx context.Context, pluginPackage string, withAttr bool) (result []*models.DataModel, err error)
func GetDataTransImportConfig(ctx context.Context) (result *models.TransDataImportConfig, err error)
func GetDataTransVariableMap(ctx context.Context) (result *models.TransDataVariableConfig, err error)
func GetDelPluginConfigActions(ctx context.Context, pluginConfigId string) (resultActions []*db.ExecAction, err error)
func GetDelPluginConfigActionsForImportData(ctx context.Context, pluginPackageId string, ...) (resultActions []*db.ExecAction, err error)
func GetDeployedProcessDefinitionByIds(ctx context.Context, ids []string) (list []*models.ProcDef, err error)
func GetDeployedProcessDefinitionList(ctx context.Context) (list []*models.ProcDef, err error)
func GetDynamicBindNodeData(ctx context.Context, procInsId, procDefId, bindNodeId string) (dataBinding []*models.ProcDataBinding, err error)
func GetEncryptSeed(ctx context.Context) (encryptSeed string, err error)
func GetEntityModel(ctx context.Context, packageName, entityName string, onlyAttr bool) (result *models.DataModelEntity, err error)
func GetExportDashboardMap(ctx context.Context, transExportId, userToken string) (exportDashboardMap map[int][]string, err error)
func GetImportDetail(ctx context.Context, transImportId string) (detail *models.TransImportDetail, err error)
func GetInstanceTaskNodeBindings(ctx context.Context, procInsId, procInsNodeId string) (result []*models.TaskNodeBindingObj, err error)
func GetLastEnablePluginInterface(ctx context.Context, serviceName string) (pluginInterface *models.PluginConfigInterfaces, err error)
func GetLatestProcDefByKey(ctx context.Context, procDefKey string) (procDefObj *models.ProcDef, err error)
func GetLatestTransImportAction(ctx context.Context, transImportId string) (transImportAction *models.TransImportActionTable, err error)
func GetMenuItemsByCode(ctx context.Context, code string) (result *models.MenuItems, err error)
func GetMenuItemsByCodes(ctx context.Context, codes []string) (result map[string]*models.MenuItems, err error)
func GetMonitorNameById(dataTypeName string, ids []string, ...) interface{}
func GetNewProcScheduleList() (result []*models.ProcScheduleConfig, err error)
func GetObjectMetas(ctx context.Context, objectMetaId string) (objectMetaEntity *models.CoreObjectMeta, err error)
func GetPackageNames(ctx context.Context) (result []string, err error)
func GetPackages(ctx context.Context, allFlag bool) (result []*models.PluginPackages, err error)
func GetPluginAuthorities(ctx context.Context, pluginPackageId string) (result []*models.PluginPackageAuthorities, err error)
func GetPluginConfigById(ctx context.Context, id string) (result *models.PluginConfigs, err error)
func GetPluginConfigInterfaceById(id string, available bool) (result *models.PluginConfigInterfaces, err error)
func GetPluginConfigInterfaceParameters(ctx context.Context, pluginConfigInterfaceId, parameterType string) (list []*models.PluginConfigInterfaceParameters, err error)
func GetPluginConfigQueryObjById(c *gin.Context, pluginConfigId string) (result *models.PluginConfigDto, err error)
func GetPluginConfigRoles(c *gin.Context, pluginConfigId string) (result []*models.PluginConfigRoles, err error)
func GetPluginConfigVersionList(ctx context.Context, pluginPackageId, pluginPackageName string) (result []*models.PluginVersionListObj, err error)
func GetPluginConfigs(ctx context.Context, pluginPackageId string, roles []string, ...) (result []*models.PluginConfigQueryObj, err error)
func GetPluginConfigsById(c *gin.Context, pluginConfigId string) (result *models.PluginConfigs, err error)
func GetPluginConfigsWithInterfaces(c context.Context, pluginPackageId string, roles []string, ...) (result []*models.PluginConfigQueryObj, err error)
func GetPluginDependencies(ctx context.Context, pluginPackageId string) (result *models.PluginPackageDepObj, err error)
func GetPluginDockerRunningResource(dockerInstanceResourceId string) (pluginResourceServer *models.ResourceServer, err error)
func GetPluginDockerRuntimeMessage(pluginPackageId string) (imageName, containerName string, err error)
func GetPluginInstance(pluginInstanceId, instanceName, host, pluginPackageId string, forceCheck bool) (pluginInstance *models.PluginInstances, err error)
func GetPluginMenus(ctx context.Context, pluginPackageId string) (result []*models.PluginPackageMenus, err error)
func GetPluginMysqlInstance(ctx context.Context, name string) (result *models.PluginMysqlInstances, err error)
func GetPluginObjectMetaById(ctx context.Context, objectMetaId string) (result *models.CoreObjectMeta, err error)
func GetPluginPackageById(ctx context.Context, id string) (result *models.PluginPackages, err error)
func GetPluginPackageNum(ctx context.Context, name string) (registerNum int, err error)
func GetPluginPackagePullReq(ctx context.Context, pullId string) (result *models.PluginArtifactPullReq, err error)
func GetPluginResourceFiles(ctx context.Context) (result []*models.PluginPackageResourceFiles, err error)
func GetPluginRunningInstances(ctx context.Context, pluginPackageId string) (result []*models.PluginInstances, err error)
func GetPluginRunningInstancesByName(ctx context.Context, pluginPackageName string) (result []*models.PluginInstances, err error)
func GetPluginRuntimeResources(ctx context.Context, pluginPackageId string) (result *models.PluginRuntimeResourceData, err error)
func GetPluginSystemParameters(ctx context.Context, pluginPackageId string) (result []*models.SystemVariables, err error)
func GetProcCacheData(ctx context.Context, procInsId string) (procCacheDataRows []*models.ProcDataCache, err error)
func GetProcContextBindNodeType(ctx context.Context, procDefId, bindNodeId string) (sourceNodeDef *models.ProcDefNode, err error)
func GetProcDataNodeExpression(expression string) (result []*models.ProcDataNodeExprObj, err error)
func GetProcDefBySessionId(ctx context.Context, sessionId string) (procDefId string)
func GetProcDefDetailByProcDefId(ctx context.Context, procDefId string) (procDefDto *models.ProcessDefinitionDto, err error)
func GetProcDefNode(ctx context.Context, procDefId, nodeId string) (result *models.ProcDefNode, err error)
func GetProcDefNodeById(ctx context.Context, procDefId string) (list []*models.ProcDefNode, err error)
func GetProcDefNodeByIdAndProcDefId(ctx context.Context, procDefId, id string) (result *models.ProcDefNode, err error)
func GetProcDefNodeByProcDefId(ctx context.Context, procDefId string) (list []*models.ProcDefNode, result []*models.ProcDefNodeResultDto, err error)
func GetProcDefNodeIdsBySessionId(ctx context.Context, sessionId string) (result []string, err error)
func GetProcDefNodeLink(ctx context.Context, procDefId string, linkId string) (result *models.ProcDefNodeLink, err error)
func GetProcDefNodeLinkByProcDefIdAndSource(ctx context.Context, procDefId string, source string) (list []*models.ProcDefNodeLink, err error)
func GetProcDefNodeLinkByProcDefIdAndTarget(ctx context.Context, procDefId string, target string) (list []*models.ProcDefNodeLink, err error)
func GetProcDefNodeLinkListByProcDefId(ctx context.Context, procDefId string) (list []*models.ProcDefNodeLink, err error)
func GetProcDefNodeModelByProcDefId(ctx context.Context, procDefId string) (list []*models.ProcDefNode, err error)
func GetProcDefNodeParamByNodeId(ctx context.Context, nodeId string) (list []*models.ProcDefNodeParam, err error)
func GetProcDefParentList(ctx context.Context, procDefId string, pageInfo *models.PageInfo) (parentProcDefList []*models.ProcDefParentListItem, err error)
func GetProcDefPermissionByCondition(ctx context.Context, permission models.ProcDefPermission) (list []*models.ProcDefPermission, err error)
func GetProcDefPermissionByIds(ctx context.Context, procDefIds []string) (list []*models.ProcDefPermission, err error)
func GetProcExecNodeData(ctx context.Context, procRunNodeId string) (procInsNode *models.ProcInsNode, procDefNode *models.ProcDefNode, ...)
func GetProcInsNodeContext(ctx context.Context, procInsId, procInsNodeId, procDefNodeId string) (result []*models.ProcNodeContextReq, err error)
func GetProcInsRootEntityData(ctx context.Context, procInsId string) (entityDataId, entityTypeId, rootExpr string, err error)
func GetProcInstance(ctx context.Context, procInsId string) (result *models.ProcInsDetail, err error)
func GetProcInstanceBySessionId(ctx context.Context, sessionId string) (procInsId string, err error)
func GetProcNodeAllowOptions(ctx context.Context, procDefId, ProcNodeDefId string) (options []string, err error)
func GetProcNodeEndTime(ctx context.Context, procInsNodeId string) (endTime string, err error)
func GetProcNodeNextChoose(ctx context.Context, procInsNodeId string) (nextChooseList []string, err error)
func GetProcPreviewBySession(ctx context.Context, sessionId string) (result *models.ProcPreviewData, err error)
func GetProcPreviewEntityNode(ctx context.Context, procInsId string) (result *models.ProcPreviewData, err error)
func GetProcScheduleConfigStatus(ctx context.Context, id string) (status string)
func GetProcScheduleLoadList() (psConfigList []*models.ProcScheduleConfig, err error)
func GetProcWorkByInsId(ctx context.Context, procInsId, procInsNodeId string) (workflowId, nodeId string, err error)
func GetProcessDefinition(ctx context.Context, id string) (result *models.ProcDef, err error)
func GetProcessDefinitionAll(ctx context.Context, userToken, language string) (list []*models.ProcDefDto, err error)
func GetProcessDefinitionByCondition(ctx context.Context, condition models.ProcDefCondition) (list []*models.ProcDef, err error)
func GetProcessDefinitionByName(ctx context.Context, name, version string) (procDefDto *models.ProcDefDto, err error)
func GetResourceItem(ctx context.Context, resourceType, name string, isAllocated bool) (resourceItemRows []*models.ResourceItem, err error)
func GetResourceServer(ctx context.Context, serverType, serverIp, name, resourceItemId string) (resourceServerObj *models.ResourceServer, err error)
func GetResourceServerById(resId string) (resourceServer *models.ResourceServer, err error)
func GetResourceServerByIp(hostIp string) (resourceServer *models.ResourceServer, err error)
func GetRouteItems(pluginName string) (result []*models.RouteItem, err error)
func GetRunningPluginPackages(ctx context.Context) (result []*models.PluginPackages, err error)
func GetRunningProcInsSubWorkflow(ctx context.Context, procInsId, procNodeId string) (workflowIdList []string, err error)
func GetSimpleLastPluginInterface(ctx context.Context, serviceName string) (interfaceObj *models.PluginInterfaceWithVer, err error)
func GetSimplePluginPackage(ctx context.Context, param *models.PluginPackages, emptyCheck bool) (err error)
func GetSimpleProcDefNode(ctx context.Context, procDefNodeId string) (procDefNode *models.ProcDefNode, err error)
func GetSimpleProcDefRow(ctx context.Context, procDefId string) (result *models.ProcDef, err error)
func GetSimpleProcInsNode(ctx context.Context, procInsNodeId, procRunNodeId string) (procInsNode *models.ProcInsNode, err error)
func GetSimpleProcInsRow(ctx context.Context, procInsId string) (result *models.ProcIns, err error)
func GetSimpleProcNodeReq(ctx context.Context, procInsNodeId, reqId, procRunNodeId string) (procReq *models.ProcInsNodeReq, err error)
func GetSimpleTranExport(ctx context.Context, transExportId string) (transExport models.TransExportTable, err error)
func GetSingleCertification(ctx context.Context, certId string) (result *models.PluginCertification, err error)
func GetSingleCertificationByName(ctx context.Context, pluginName string) (result *models.PluginCertification, err error)
func GetSubProcResult(ctx context.Context, procRunNodeId string) (resultRows []*models.ProcSubProcQueryRow, err error)
func GetSystemVariable(ctx context.Context, name string) (result string, err error)
func GetSystemVariableScope() (result []string, err error)
func GetTemplate(c *gin.Context, templateId string) (result *models.BatchExecutionTemplate, err error)
func GetTransExport(ctx context.Context, transExportId string) (transExport *models.TransExportTable, err error)
func GetTransExportAnalyzeDataByCond(ctx context.Context, transExportId, dataType string) (analyzeData models.TransExportAnalyzeDataTable, err error)
func GetTransExportAnalyzeDataBySource(ctx context.Context, transExportId, source string) (result []*models.TransExportAnalyzeDataTable, err error)
func GetTransExportAnalyzeDataBySourceOne(ctx context.Context, transExportId, source string) (analyzeData models.TransExportAnalyzeDataTable, err error)
func GetTransExportCustomer(ctx context.Context, id string) (result *models.DataTransExportCustomerTable, err error)
func GetTransExportCustomerList(ctx context.Context) (result []*models.DataTransExportCustomerTable, err error)
func GetTransExportDetail(ctx context.Context, transExportId string) (detail *models.TransExportDetail, err error)
func GetTransImport(ctx context.Context, transImportId string) (transImport *models.TransImportTable, err error)
func GetTransImportDetail(ctx context.Context, transImportId string) (result []*models.TransImportDetailTable, err error)
func GetTransImportDetailInput(ctx context.Context, transImportDetailId string) (result string, err error)
func GetTransImportDetailOutput(ctx context.Context, transImportDetailId string) (result string, err error)
func GetTransImportProcDefId(ctx context.Context, procDefId, procDefKey string) (resultProcDefId string, err error)
func GetTransImportProcExecByDetailId(ctx context.Context, detailId string) (result []*models.TransImportProcExecTable, err error)
func GetTransImportProcExecList(ctx context.Context) (result []*models.TransImportProcExecTable, err error)
func GetTransImportWithDetail(ctx context.Context, transImportId string, withDetailData bool) (result *models.TransImportJobParam, err error)
func GetWorkflowNodeByReq(ctx context.Context, reqId string) (runNode *models.TaskCallbackReqQuery, err error)
func ImportPluginConfigs(ctx context.Context, pluginPackageId string, ...) (result *models.PluginConfigDto, err error)
func ImportTemplate(c context.Context, operator string, ...) (err error)
func InheritPluginConfig(ctx context.Context, param *models.InheritPluginConfigParam, operator string) (err error)
func InitTransImport(ctx context.Context, transImportId, ExportNexusUrl, localPath, operator string) (err error)
func InsertBatchExec(c *gin.Context, reqParam *models.BatchExecRun) (batchExecId string, err error)
func InsertBatchExecJobs(c *gin.Context, batchExecId string, execTime *time.Time, ...) (err error)
func InsertProcDefNode(ctx context.Context, node *models.ProcDefNode) (err error)
func InsertProcDefNodeLink(ctx context.Context, nodeLink *models.ProcDefNodeLink) (err error)
func InsertProcDefNodeParam(ctx context.Context, nodeParam *models.ProcDefNodeParam) (err error)
func IsPluginInstanceRunning(ctx context.Context, pluginPackageId string) (running bool, err error)
func LaunchPlugin(ctx context.Context, pluginInstance *models.PluginInstances, ...) (err error)
func ListImportNexusArtifactPackages(ctx context.Context, nexusUrl string) (fileMd5Map map[string]string, err error)
func ListProcInstance(ctx context.Context, userRoles []string, ...) (result []*models.ProcInsDetail, err error)
func MarshalWeLicense(lic *models.WeLicense) (data []byte, err error)
func ModifyImportStatus(ctx context.Context, param models.UpdateImportStatusParam) (err error)
func NewPluginMysqlInstance(ctx context.Context, mysqlServer *models.ResourceServer, ...) (err error)
func NewProcScheduleJob(ctx context.Context, psConfig *models.ProcScheduleConfig, newId string) (duplicateRow bool, err error)
func ParseJsonData(jsonPath string, data interface{}) (err error)
func ProcDefList(ctx context.Context, ...) (result []*models.ProcDefListObj, err error)
func ProcDefOutline(ctx context.Context, procDefId string) (result *models.ProcDefListObj, err error)
func ProcInsTaskNodeBindings(ctx context.Context, sessionId, taskNodeId string) (result []*models.TaskNodeBindingObj, err error)
func PublicProcDefNodeList(ctx context.Context, procDefId string) (nodes []*models.ProcNodeObj, err error)
func QueryAllEnablePluginConfigInterfaceByCondition(ctx context.Context, param models.TargetEntityFilterRuleDto, roles []string) (plugConfigInterfaceDtoList []*models.PluginConfigInterfaceDto, err error)
func QueryBusinessList(c context.Context, userToken, language string, param models.QueryBusinessParam) (result []map[string]interface{}, err error)
func QueryCoreObjectMeta(ctx context.Context, packageName, objectName string, configId string) *models.CoreObjectMeta
func QueryCoreObjectMetaV2(ctx context.Context, pluginConfigId string, objectName string) (result *models.CoreObjectMeta, err error)
func QueryExpressionEntityAttr(ctx context.Context, exprObj *models.ExpressionObj) (result *models.ExpressionEntitiesRespObj, err error)
func QueryPluginConfigInfo(ctx context.Context, pluginConfigIds []string) (result []*models.PluginConfigs, err error)
func QueryPluginInterfaceParam(ctx context.Context, param *models.PluginInterfaceParamQueryParam) (result *models.PluginConfigInterfaceParameters, err error)
func QueryPluginPackages(ctx context.Context, param *models.PluginPackageQueryParam) (result []*models.PluginPackageQueryObj, err error)
func QueryPluginProcessDefinitionList(ctx context.Context, plugin string) (list []*models.ProcDef, err error)
func QueryProcInsPage(ctx context.Context, param *models.QueryProcPageParam, userRoles []string) (result *models.QueryProcPageResponse, err error)
func QueryProcInstanceByIds(ctx context.Context, ids []string) (result []*models.ProcInsDetail, err error)
func QueryProcScheduleInstance(ctx context.Context, psConfigId, status string) (result []*models.ProcScheduleInstQueryObj, err error)
func QueryProcScheduleList(ctx context.Context, param *models.ProcScheduleQueryParam, operator string, ...) (result []*models.ProcScheduleConfigObj, err error)
func QueryProcessDefinitionList(ctx context.Context, param models.QueryProcessDefinitionParam, ...) (list []*models.ProcDefQueryDto, err error)
func QueryResourceItem(ctx context.Context, param *models.QueryRequestParam) (result *models.ResourceItemListPageData, err error)
func QueryResourceServer(ctx context.Context, param *models.QueryRequestParam) (result *models.ResourceServerListPageData, err error)
func QuerySimpleTransExportAnalyzeDataByTransExport(ctx context.Context, transExportId string) (result []*models.TransExportAnalyzeDataTable, err error)
func QuerySystemVariables(ctx context.Context, param *models.QueryRequestParam) (result *models.SystemVariablesListPageData, err error)
func QuerySystemVariablesByCondition(ctx context.Context, condition models.SystemVariablesQueryCondition) (list []*models.SystemVariables, err error)
func QueryTransExportByCondition(ctx context.Context, param models.TransExportHistoryParam) (pageInfo models.PageInfo, list []*models.TransExportTable, err error)
func QueryTransExportCustomerByName(ctx context.Context, name string) (result []*models.DataTransExportCustomerTable, err error)
func QueryTransImportByCondition(ctx context.Context, param models.TransImportHistoryParam) (pageInfo models.PageInfo, list []*models.TransImportTable, err error)
func QueryWebRunningPluginPackages(ctx context.Context) (versionMap map[string]string, err error)
func RecordCustomReq(ctx context.Context, param *models.ProcInsNodeReq) (err error)
func RecordProcCallReq(ctx context.Context, param *models.ProcInsNodeReq, inputFlag bool) (err error)
func RecordTransImportAction(ctx context.Context, callParam *models.CallTransImportActionParam) (actionId string, err error)
func RegisterPlugin(ctx context.Context, name, version, operator string) (err error)
func RemovePlugin(ctx context.Context, pluginPackageId, pluginInstanceId, resourceItemId string) (err error)
func RemoveTempExportDir(path string) (err error)
func RetrieveBatchExec(c *gin.Context, reqParam *models.QueryRequestParam) (result *models.BatchExecListPageData, err error)
func RetrieveBatchExecJobs(c *gin.Context, reqParam *models.QueryRequestParam) (result *models.BatchExecJobsPageData, err error)
func RetrieveTemplate(c *gin.Context, reqParam *models.QueryRequestParam) (result *models.BatchExecTemplatePageData, err error)
func RewriteProcInsEntityData(ctx context.Context, procInsId string, ...) (err error)
func RewriteProcInsEntityDataNew(ctx context.Context, procInsId string, ...) (err error)
func SavePluginConfig(c context.Context, reqParam *models.PluginConfigDto) (result *models.PluginConfigDto, err error)
func SetPluginPackageRegisterDone(ctx context.Context, pluginPackageId, operator string) (dynamicModel bool, err error)
func StatisticsBindingsEntityByNode(ctx *gin.Context, nodeList []string) (result []*models.TasknodeBindsEntityData, err error)
func StatisticsBindingsEntityByService(ctx *gin.Context, serviceNameList []string) (result []*models.TasknodeBindsEntityData, err error)
func StatisticsPluginExec(ctx *gin.Context, reqParam *models.StatisticsTasknodeExecReq) (result *models.StatisticsTasknodeExecResp, err error)
func StatisticsPluginExecDetails(ctx *gin.Context, reqParam *models.StatisticsTasknodeExecDetailsReq) (result []*models.StatisticsTasknodeExecDetailsResp, err error)
func StatisticsProcessExec(ctx *gin.Context, reqParam *models.StatisticsProcessExecReq) (result []*models.StatisticsProcessExecResp, err error)
func StatisticsServiceNames(ctx *gin.Context) (serviceNames []string, err error)
func StatisticsTasknodeExec(ctx *gin.Context, reqParam *models.StatisticsTasknodeExecReq) (result *models.StatisticsTasknodeExecResp, err error)
func StatisticsTasknodeExecDetails(ctx *gin.Context, reqParam *models.StatisticsTasknodeExecDetailsReq) (result []*models.StatisticsTasknodeExecDetailsResp, err error)
func StatisticsTasknodes(ctx *gin.Context, procDefIdList []string) (result []*models.Tasknode, err error)
func SyncPluginDataModels(ctx context.Context, packageName string, ...) (err error)
func TransScheduleToCronExpr(scheduleMode, scheduleExpr string) (cronExpr string, err error)
func TryFetchEnrichCoreObjectMeta(ctx context.Context, param *models.PluginConfigInterfaceParameters) *models.CoreObjectMeta
func TryFetchLatestAvailableDataModelEntity(ctx context.Context, packageName string) (latestDataModelEntity *models.PluginPackageDataModel, err error)
func UncollectBatchExecTemplate(c *gin.Context, reqParam *models.BatchExecutionTemplateCollect) (err error)
func UnmarshalWeLicense(data []byte) (result *models.WeLicense, err error)
func UpdateBatchExec(c *gin.Context, batchExecId string, updateData map[string]interface{}) (err error)
func UpdateCertification(ctx context.Context, certId string, lic *models.WeLicense, userId string) (cert *models.PluginCertification, err error)
func UpdateDynamicNodeBindData(ctx context.Context, procInsId, procInsNodeId, procDefId, procDefNodeId string, ...) (err error)
func UpdateExport(c context.Context, param models.UpdateExportParam, operator string) (err error)
func UpdateObjectMetas(c *gin.Context, reqParam *models.CoreObjectMeta) (err error)
func UpdatePluginConfigRoles(c *gin.Context, pluginConfigId string, ...) (err error)
func UpdatePluginConfigStatus(c *gin.Context, pluginConfigId string, status string) (result *models.PluginConfigDto, err error)
func UpdatePluginMysqlInstancePreVersion(ctx context.Context, mysqlInstanceId, preVersion string) (err error)
func UpdatePluginPackagePullReq(ctx context.Context, pullId, pkgId, state, stateMsg, userId string, ...) (err error)
func UpdatePluginStaticResourceFiles(ctx context.Context, pluginPackageId, pluginPackageName string, ...) (err error)
func UpdateProcCacheData(ctx context.Context, procInsId string, dataBinding []*models.ProcDataBinding) (err error)
func UpdateProcCacheDataByTaskForm(ctx context.Context, procInsId string, ...) (err error)
func UpdateProcDef(ctx context.Context, procDef *models.ProcDef) (err error)
func UpdateProcDefAndNode(ctx context.Context, procDef *models.ProcDef, nodeList []*models.ProcDefNode) (err error)
func UpdateProcDefHandler(ctx context.Context, procDefId, handler string) (err error)
func UpdateProcDefNode(ctx context.Context, procDefNode *models.ProcDefNode) (err error)
func UpdateProcDefNodeLink(ctx context.Context, procDefNodeLink *models.ProcDefNodeLink) (err error)
func UpdateProcDefNodeOrder(ctx context.Context, nodeIndexMap map[string]int) (err error)
func UpdateProcDefNodeStatusByProcDefId(ctx context.Context, procDefId, status, updatedBy string) (err error)
func UpdateProcDefStatus(ctx context.Context, procDef *models.ProcDef) (err error)
func UpdateProcDefStatusAndVersion(ctx context.Context, procDef *models.ProcDef) (err error)
func UpdateProcInsNodeBindingData(ctx context.Context, param []*models.TaskNodeBindingObj, ...) (err error)
func UpdateProcInstanceRequestInfo(ctx context.Context, procInstanceId, requestInfo string) (err error)
func UpdateProcNodeBindingData(ctx context.Context, param []*models.TaskNodeBindingObj, ...) (err error)
func UpdateProcRunNodeSubProc(ctx context.Context, procRunNodeId string, ...) (err error)
func UpdateProcScheduleJob(ctx context.Context, jobId, status, errorMsg, procInsId string) (err error)
func UpdateProcScheduleStatus(ctx context.Context, id, status, operator string, roleList []string) (err error)
func UpdateResourceItem(ctx context.Context, params []*models.ResourceItem, operator string) (err error)
func UpdateResourceServer(ctx context.Context, params []*models.ResourceServer) (withHostServer bool, err error)
func UpdateSystemVariables(ctx context.Context, params []*models.SystemVariables) (err error)
func UpdateTemplatePermission(c *gin.Context, reqParam *models.BatchExecutionTemplate) (result *models.BatchExecutionTemplate, err error)
func UpdateTemplateRolesDisplayName(c *gin.Context, templateDataList []*models.BatchExecutionTemplate) (err error)
func UpdateTemplateStatus(templateData []*models.BatchExecutionTemplate, userRoles []string, ...)
func UpdateTransExportCustomer(ctx context.Context, exportCustomer *models.DataTransExportCustomerTable) (err error)
func UpdateTransImport(ctx context.Context, transImportId, status string) (err error)
func UpdateTransImportCMDBData(ctx context.Context, transImportParam *models.TransImportJobParam) (err error)
func UpdateTransImportDetailInput(ctx context.Context, transImportId string, step models.TransImportStep, ...) (err error)
func UpdateTransImportDetailOutput(ctx context.Context, transImportId string, step models.TransImportStep, ...) (err error)
func UpdateTransImportDetailStatus(ctx context.Context, ...) (err error)
func UpdateTransImportProcExec(ctx context.Context, param *models.TransImportProcExecTable) (affectRow bool, err error)
func UploadPackage(ctx context.Context, registerConfig *models.RegisterXML, ...) (resultPackageId string, err error)
func ValidateBatchExecName(c *gin.Context, batchExecReqParam *models.BatchExecRun, continueToken string) (isValid bool, err error)
func ValidateResourceServer(ctx context.Context, resourceServer *models.ResourceServer) (err error)

Constants ¶

View Source

const (
	TempTransImportDir = "/tmp/trans_import/%s"
)

Variables ¶

View Source

var (
	ProcExecCompleted  = "Completed"
	ProcExecInProgress = "InProgress"
	ProcExecFaulted    = "Faulted"
	ProcExecTotal      = "Total"
)

Functions ¶

func AddProcCacheData ¶

func AddProcCacheData(ctx context.Context, procInsId string, dataBinding []*models.ProcDataBinding) (err error)

func AddProcDefCollect ¶

func AddProcDefCollect(ctx context.Context, procDefId, operator string) (err error)

func AddProcScheduleExecTimes ¶

func AddProcScheduleExecTimes(ctx context.Context, id string)

func AddProcessDefinition ¶

func AddProcessDefinition(ctx context.Context, user string, param models.ProcessDefinitionParam) (draftEntity *models.ProcDef, err error)

AddProcessDefinition 添加编排

func AddRoleMenu ¶

func AddRoleMenu(ctx context.Context, menu models.RoleMenu) (err error)

AddRoleMenu 添加roleMenu

func AddTransExportCustomer ¶

func AddTransExportCustomer(ctx context.Context, exportCustomer *models.DataTransExportCustomerTable) (err error)

func AddUseRoles ¶

func AddUseRoles(ctx context.Context, procDefId string, useRoles []string) (err error)

func AddWorkflowOperation ¶

func AddWorkflowOperation(ctx context.Context, operation *models.ProcRunOperation) (lastInsertId int64, err error)

func AnalyzeCMDBDataExport ¶

func AnalyzeCMDBDataExport(ctx context.Context, param *models.AnalyzeDataTransParam) (actions []*db.ExecAction, err error)

AnalyzeCMDBDataExport 分析cmdb数据并写入自动分析表

func AnalyzePluginConfigDataExport ¶

func AnalyzePluginConfigDataExport(ctx context.Context, transExportId string) (actions []*db.ExecAction, err error)

AnalyzePluginConfigDataExport 分析插件服务和系统数据数据

func AutoAppendExportParam ¶

func AutoAppendExportParam(ctx context.Context, userToken string, param models.DataTransExportParam) (newParam models.DataTransExportParam, err error)

func BatchAddProcDefPermission ¶

func BatchAddProcDefPermission(ctx context.Context, procDefId string, permission models.PermissionToRole) (err error)

func BatchEnablePluginConfig ¶

func BatchEnablePluginConfig(c *gin.Context, reqParam []*models.PluginConfigsBatchEnable, pluginPackageId string) (err error)

func BuildDockerEnvMap ¶

func BuildDockerEnvMap(ctx context.Context, envMap map[string]string, packageName, packageVersion string) (replaceMap map[string]string, err error)

func BuildPackageMenuItemDto ¶

func BuildPackageMenuItemDto(ctx context.Context, menus *models.PluginPackageMenus) *models.MenuItemDto

func CalAssignedPluginPackageMenusByMenuCode ¶

func CalAssignedPluginPackageMenusByMenuCode(ctx context.Context, menuCode string) (result []*models.PluginPackageMenus, err error)

CalAssignedPluginPackageMenusByMenuCode 通过menuCode查找可用插件菜单

func CalAvailablePluginPackageMenus ¶

func CalAvailablePluginPackageMenus(ctx context.Context) (result []*models.PluginPackageMenus, err error)

CalAvailablePluginPackageMenus 获取可用的插件菜单

func CalcWebDisplayStep ¶

func CalcWebDisplayStep(detailList []*models.TransImportDetailTable) models.ImportWebDisplayStep

CalcWebDisplayStep 第二步导入基础数据, 第三步修改新环境数据,第四步执行自动化编排,第五步配置监控

func CheckCollectBatchExecTemplate ¶

func CheckCollectBatchExecTemplate(c *gin.Context, reqParam *models.BatchExecutionTemplateCollect) (result *models.CheckBatchExecTemplateResp, err error)

func CheckIsCollected ¶

func CheckIsCollected(c *gin.Context, templateData []*models.BatchExecutionTemplate, userId string) (err error)

func CheckPluginPackageDependence ¶

func CheckPluginPackageDependence(ctx context.Context, pluginPackageId string) (ok bool, err error)

func CheckProcDefStatus ¶

func CheckProcDefStatus(ctx context.Context, procDefId string) (err error)

func CheckProcInsUserPermission ¶

func CheckProcInsUserPermission(ctx context.Context, userRoleList []string, procInsId string) (legal bool, err error)

func CheckProcSubRunning ¶

func CheckProcSubRunning(ctx context.Context, procRunNodeId string) (runningRows []*models.ProcRunNodeSubProc, err error)

func CheckServerPortRunning ¶

func CheckServerPortRunning(ctx context.Context, serverIp string, port int) (running bool, err error)

func CheckSubProcStart ¶

func CheckSubProcStart(ctx context.Context, sessionId string) (isSubProcSession bool, err error)

func CollectBatchExecTemplate ¶

func CollectBatchExecTemplate(c *gin.Context, reqParam *models.BatchExecutionTemplateCollect) (err error)

func CopyProcessDefinition ¶

func CopyProcessDefinition(ctx context.Context, procDef *models.ProcDef, operator string) (newProcDefId string, err error)

CopyProcessDefinition 复制编排

func CopyProcessDefinitionByDto ¶

func CopyProcessDefinitionByDto(param models.ProcDefImportDto, procDef *models.ProcessDefinitionDto) (err error)

func CreateCertification ¶

func CreateCertification(ctx context.Context, lic *models.WeLicense, userId string) (cert *models.PluginCertification, err error)

func CreateExport ¶

func CreateExport(c context.Context, param models.CreateExportParam, operator string) (transExportId string, err error)

func CreateOrUpdateBatchExecTemplate ¶

func CreateOrUpdateBatchExecTemplate(c *gin.Context, reqParam *models.BatchExecutionTemplate) (result *models.BatchExecutionTemplate, err error)

func CreatePluginPackagePullReq ¶

func CreatePluginPackagePullReq(ctx context.Context, data *models.PluginArtifactPullReq, userId string) (result *models.PluginArtifactPullReq, err error)

func CreateProcInsEvent ¶

func CreateProcInsEvent(ctx context.Context, param *models.ProcStartEventParam, procDefObj *models.ProcDef) (eventId int64, err error)

func CreateProcInstance ¶

func CreateProcInstance(ctx context.Context, procStartParam *models.ProcInsStartParam, operator string) (procInsId string, workflowRow *models.ProcRunWorkflow, workNodes []*models.ProcRunNode, workLinks []*models.ProcRunLink, err error)

func CreateProcPreview ¶

func CreateProcPreview(ctx context.Context, previewRows []*models.ProcDataPreview, graphRows []*models.ProcInsGraphNode) (err error)

func CreateProcSchedule ¶

func CreateProcSchedule(ctx context.Context, param *models.CreateProcScheduleParam) (result *models.ProcScheduleConfig, err error)

func CreatePublicProcInstance ¶

func CreatePublicProcInstance(ctx context.Context, startParam *models.RequestProcessData, operator string) (procInsId string, workflowRow *models.ProcRunWorkflow, workNodes []*models.ProcRunNode, workLinks []*models.ProcRunLink, err error)

func CreateResourceItem ¶

func CreateResourceItem(ctx context.Context, params []*models.ResourceItem, operator string) (err error)

func CreateResourceServer ¶

func CreateResourceServer(ctx context.Context, params []*models.ResourceServer) (withHostServer bool, err error)

func CreateSystemVariables ¶

func CreateSystemVariables(ctx context.Context, params []*models.SystemVariables) (err error)

func CreateTransImportProcExecData ¶

func CreateTransImportProcExecData(ctx context.Context, procExecList []*models.TransImportProcExecTable) (err error)

func DataTransExportArtifactData ¶

func DataTransExportArtifactData(ctx context.Context, transExportParam *models.TransExportJobParam) (err error)

DataTransExportArtifactData 把物料包直接迁到物料插件配置好的nexus上

func DataTransExportCMDBData ¶

func DataTransExportCMDBData(ctx context.Context, transExportId, path string) (err error)

func DataTransExportPluginConfig ¶

func DataTransExportPluginConfig(ctx context.Context, transExportId, path string) (err error)

func DataTransImportCMDBData ¶

func DataTransImportCMDBData(ctx context.Context, inputFile string) (err error)

func DeactivateSystemVariablesByPackage ¶

func DeactivateSystemVariablesByPackage(ctx context.Context, name, version string) (err error)

func DecodeUIPassword ¶

func DecodeUIPassword(ctx context.Context, inputValue string) (output string, err error)

func DecommissionPluginPackage ¶

func DecommissionPluginPackage(ctx context.Context, pluginPackageId, operator string) (err error)

func DecompressExportZip ¶

func DecompressExportZip(ctx context.Context, nexusUrl, transImportId string) (localPath string, err error)

DecompressExportZip 导出压缩文件解压

func DelProcDefCollect ¶

func DelProcDefCollect(ctx context.Context, procDefId, operator string) (err error)

func DeleteCertification ¶

func DeleteCertification(ctx context.Context, certId string) (err error)

func DeletePluginConfig ¶

func DeletePluginConfig(c *gin.Context, pluginConfigId string) (err error)

func DeleteProcDef ¶

func DeleteProcDef(ctx context.Context, procDefId string) (err error)

func DeleteProcDefChain ¶

func DeleteProcDefChain(ctx context.Context, procDefId string) (err error)

DeleteProcDefChain 删除编排链,包含节点，线，节点参数

func DeleteProcDefNode ¶

func DeleteProcDefNode(ctx context.Context, procDefId, nodeId string) (err error)

func DeleteProcDefNodeLink ¶

func DeleteProcDefNodeLink(ctx context.Context, procDefId string, linkId, operator string) (err error)

func DeleteProcDefNodeLinkByNode ¶

func DeleteProcDefNodeLinkByNode(ctx context.Context, nodeId string) (err error)

func DeleteProcDefNodeParam ¶

func DeleteProcDefNodeParam(ctx context.Context, procDefNodeId string) (err error)

func DeleteProcDefNodeParamByNodeId ¶

func DeleteProcDefNodeParamByNodeId(ctx context.Context, nodeId string) (err error)

func DeleteProcSchedule ¶

func DeleteProcSchedule(ctx context.Context, id string) (err error)

func DeleteResourceItem ¶

func DeleteResourceItem(ctx context.Context, params []*models.ResourceItem) (err error)

func DeleteResourceServer ¶

func DeleteResourceServer(ctx context.Context, params []*models.ResourceServer) (err error)

func DeleteRoleMenuById ¶

func DeleteRoleMenuById(ctx context.Context, id string) (err error)

DeleteRoleMenuById 根据id删除roleMenu

func DeleteSystemVariables ¶

func DeleteSystemVariables(ctx context.Context, params []*models.SystemVariables) (err error)

func DeleteTemplate ¶

func DeleteTemplate(c *gin.Context, templateId string) (err error)

func DeleteTransExportCustomer ¶

func DeleteTransExportCustomer(ctx context.Context, id string) (err error)

func DisableAllPluginConfigsByPackageId ¶

func DisableAllPluginConfigsByPackageId(ctx context.Context, pluginPackageId string) (err error)

func DownloadImportArtifactPackage ¶

func DownloadImportArtifactPackage(ctx context.Context, nexusConfig *models.TransDataImportConfig, nexusUrl, transImportId, remoteFileName, expectMd5 string) (localFilePath, dirPath string, err error)

func DownloadImportArtifactPackages ¶

func DownloadImportArtifactPackages(ctx context.Context, nexusUrl, transImportId string) (localDir string, fileNameList []string, err error)

func ExecExportAction ¶

func ExecExportAction(ctx context.Context, callParam *models.CallTransExportActionParam) (err error)

func ExportPluginConfigs ¶

func ExportPluginConfigs(c context.Context, pluginPackageId string, exportConfigList []*models.PluginConfigsBatchEnable, userRoles []string) (result *models.PackagePluginsXML, err error)

func ExportTemplate ¶

func ExportTemplate(c context.Context, userToken string, reqParam *models.ExportBatchExecTemplateReqParam) (result []*models.BatchExecutionTemplate, err error)

func GeneratePluginEnv ¶

func GeneratePluginEnv(subsystemPubKey, subsystemPriKey, pluginName string) (lic_code, lic_pk, lic_data, lic_sign string, err error)

* * Func: GeneratePluginEnv 用于生成启动插件时自动生成LICENSE_PK & LICENSE_DATA & LICENSE_SIGNATURE & LICENSE_CODE环境变量值

@params subsystemPubKey 子系统公钥(可选，若不提供，则必须提供子系统私钥)
@params subsystemPriKey 子系统私钥(可选，若不提供，则必须提供子系统公钥)
@params pluginName 插件名称，必须提供，如果找不到插件的License配置，则返回的环境变量值都是空值

* @return LICENSE_CODE, LICENSE_PK, LICENSE_DATA, LICENSE_SIGNATURE环境变量对应的值

func GetAllByRoleName ¶

func GetAllByRoleName(ctx context.Context, roleName string) (list []*models.RoleMenu, err error)

func GetAllByRoleNames ¶

func GetAllByRoleNames(ctx context.Context, roleNames []string) (list []*models.RoleMenu, err error)

GetAllByRoleNames 批量根据角色名称获取角色菜单

func GetAllByServiceNameAndConfigStatus ¶

func GetAllByServiceNameAndConfigStatus(ctx context.Context, serviceName, status string) (list []*models.RichPluginConfigInterfaces, err error)

func GetAllMenusByCodeAndPackageStatus ¶

func GetAllMenusByCodeAndPackageStatus(ctx context.Context, code string, statusArr []string) (result []*models.PluginPackageMenus, err error)

GetAllMenusByCodeAndPackageStatus 根据code和包状态返回对应菜单列表

func GetAllMenusByCodesAndPackageStatus ¶

func GetAllMenusByCodesAndPackageStatus(ctx context.Context, codes []string, statusArr []string) (result map[string][]*models.PluginPackageMenus, err error)

GetAllMenusByCodesAndPackageStatus 批量根据codes和包状态返回对应菜单列表

func GetAllMenusByPackageStatus ¶

func GetAllMenusByPackageStatus(ctx context.Context, statusArr []string) (result []*models.PluginPackageMenus, err error)

GetAllMenusByPackageStatus 根据包状态返回对应菜单列表

func GetAllRootMenus ¶

func GetAllRootMenus(ctx context.Context) (result []*models.MenuItemDto, err error)

GetAllRootMenus 查询所有根菜单

func GetAllSysMenus ¶

func GetAllSysMenus(ctx context.Context) (result []*models.MenuItemDto, err error)

GetAllSysMenus 查询所有系统菜单

func GetAllTemplate ¶

func GetAllTemplate(c *gin.Context) (templateData []*models.BatchExecutionTemplate, err error)

func GetAllTransExport ¶

func GetAllTransExport(ctx context.Context) (list []*models.TransExportTable, err error)

func GetAllTransExportOptions ¶

func GetAllTransExportOptions(ctx context.Context) (options models.TransExportHistoryOptions, err error)

func GetAllTransImport ¶

func GetAllTransImport(ctx context.Context) (list []*models.TransImportTable, err error)

func GetAllTransImportOptions ¶

func GetAllTransImportOptions(ctx context.Context) (options models.TransExportHistoryOptions, err error)

func GetAvailableContainerHost ¶

func GetAvailableContainerHost() (availableHost []string, err error)

func GetBatchExec ¶

func GetBatchExec(c *gin.Context, batchExecId string) (result *models.BatchExecution, err error)

func GetBatchExecutionTemplatePermissionByIds ¶

func GetBatchExecutionTemplatePermissionByIds(ctx context.Context, batchExecutionTemplates []string) (list []*models.BatchExecutionTemplateRole, err error)

func GetBatchPluginConfigs ¶

func GetBatchPluginConfigs(c *gin.Context, pluginPackageId string) (result []*models.PluginConfigsOutlines, err error)

func GetBusinessList ¶

func GetBusinessList(localPath string) (result models.GetBusinessListRes, err error)

func GetCertifications ¶

func GetCertifications(ctx context.Context) (result []*models.PluginCertification, err error)

func GetConfigInterfaces ¶

func GetConfigInterfaces(ctx context.Context, pluginConfigId string) (result []*models.PluginInterfaceQueryObj, err error)

func GetConfigInterfacesById ¶

func GetConfigInterfacesById(ctx context.Context, id string) (result *models.PluginConfigInterfaces, err error)

func GetCreatePluginConfigActions ¶

func GetCreatePluginConfigActions(ctx context.Context, pluginConfigId string, pluginConfigDto *models.PluginConfigDto, isImportRequest bool, pluginPackageData *models.PluginPackages, baseInterfaceParamMap map[string][]*models.PluginConfigInterfaceParameters) (resultActions []*db.ExecAction, err error)

func GetDashboardTransExportAnalyzeData ¶

func GetDashboardTransExportAnalyzeData(ctx context.Context, transExportId string) (dashboardAnalyze models.TransExportAnalyzeDataTable, err error)

func GetDataModels ¶

func GetDataModels(ctx context.Context, pluginPackage string, withAttr bool) (result []*models.DataModel, err error)

func GetDataTransImportConfig ¶

func GetDataTransImportConfig(ctx context.Context) (result *models.TransDataImportConfig, err error)

func GetDataTransVariableMap ¶

func GetDataTransVariableMap(ctx context.Context) (result *models.TransDataVariableConfig, err error)

func GetDelPluginConfigActions ¶

func GetDelPluginConfigActions(ctx context.Context, pluginConfigId string) (resultActions []*db.ExecAction, err error)

func GetDelPluginConfigActionsForImportData ¶

func GetDelPluginConfigActionsForImportData(ctx context.Context, pluginPackageId string, pluginConfigDtoForImportList []*models.PluginConfigDto) (resultActions []*db.ExecAction, err error)

func GetDeployedProcessDefinitionByIds ¶

func GetDeployedProcessDefinitionByIds(ctx context.Context, ids []string) (list []*models.ProcDef, err error)

func GetDeployedProcessDefinitionList ¶

func GetDeployedProcessDefinitionList(ctx context.Context) (list []*models.ProcDef, err error)

func GetDynamicBindNodeData ¶

func GetDynamicBindNodeData(ctx context.Context, procInsId, procDefId, bindNodeId string) (dataBinding []*models.ProcDataBinding, err error)

func GetEncryptSeed ¶

func GetEncryptSeed(ctx context.Context) (encryptSeed string, err error)

func GetEntityModel ¶

func GetEntityModel(ctx context.Context, packageName, entityName string, onlyAttr bool) (result *models.DataModelEntity, err error)

func GetExportDashboardMap ¶

func GetExportDashboardMap(ctx context.Context, transExportId, userToken string) (exportDashboardMap map[int][]string, err error)

func GetImportDetail ¶

func GetImportDetail(ctx context.Context, transImportId string) (detail *models.TransImportDetail, err error)

GetImportDetail 获取导入详情

func GetInstanceTaskNodeBindings ¶

func GetInstanceTaskNodeBindings(ctx context.Context, procInsId, procInsNodeId string) (result []*models.TaskNodeBindingObj, err error)

func GetLastEnablePluginInterface ¶

func GetLastEnablePluginInterface(ctx context.Context, serviceName string) (pluginInterface *models.PluginConfigInterfaces, err error)

func GetLatestProcDefByKey ¶

func GetLatestProcDefByKey(ctx context.Context, procDefKey string) (procDefObj *models.ProcDef, err error)

func GetLatestTransImportAction ¶

func GetLatestTransImportAction(ctx context.Context, transImportId string) (transImportAction *models.TransImportActionTable, err error)

GetLatestTransImportAction 获取最新的导入操作

func GetMenuItemsByCode ¶

func GetMenuItemsByCode(ctx context.Context, code string) (result *models.MenuItems, err error)

GetMenuItemsByCode 根据code返回菜单

func GetMenuItemsByCodes ¶

func GetMenuItemsByCodes(ctx context.Context, codes []string) (result map[string]*models.MenuItems, err error)

GetMenuItemsByCodes 批量根据codes返回菜单

func GetMonitorNameById ¶

func GetMonitorNameById(dataTypeName string, ids []string, displayServiceGroupMap map[string]*monitor.ServiceGroupTable) interface{}

func GetNewProcScheduleList ¶

func GetNewProcScheduleList() (result []*models.ProcScheduleConfig, err error)

GetNewProcScheduleList 获取1小时内新增加的定时配置

func GetObjectMetas ¶

func GetObjectMetas(ctx context.Context, objectMetaId string) (objectMetaEntity *models.CoreObjectMeta, err error)

func GetPackageNames ¶

func GetPackageNames(ctx context.Context) (result []string, err error)

func GetPackages ¶

func GetPackages(ctx context.Context, allFlag bool) (result []*models.PluginPackages, err error)

func GetPluginAuthorities ¶

func GetPluginAuthorities(ctx context.Context, pluginPackageId string) (result []*models.PluginPackageAuthorities, err error)

func GetPluginConfigById ¶

func GetPluginConfigById(ctx context.Context, id string) (result *models.PluginConfigs, err error)

func GetPluginConfigInterfaceById ¶

func GetPluginConfigInterfaceById(id string, available bool) (result *models.PluginConfigInterfaces, err error)

func GetPluginConfigInterfaceParameters ¶

func GetPluginConfigInterfaceParameters(ctx context.Context, pluginConfigInterfaceId, parameterType string) (list []*models.PluginConfigInterfaceParameters, err error)

func GetPluginConfigQueryObjById ¶

func GetPluginConfigQueryObjById(c *gin.Context, pluginConfigId string) (result *models.PluginConfigDto, err error)

func GetPluginConfigRoles ¶

func GetPluginConfigRoles(c *gin.Context, pluginConfigId string) (result []*models.PluginConfigRoles, err error)

func GetPluginConfigVersionList ¶

func GetPluginConfigVersionList(ctx context.Context, pluginPackageId, pluginPackageName string) (result []*models.PluginVersionListObj, err error)

func GetPluginConfigs ¶

func GetPluginConfigs(ctx context.Context, pluginPackageId string, roles []string, pluginConfigId string) (result []*models.PluginConfigQueryObj, err error)

func GetPluginConfigsById ¶

func GetPluginConfigsById(c *gin.Context, pluginConfigId string) (result *models.PluginConfigs, err error)

func GetPluginConfigsWithInterfaces ¶

func GetPluginConfigsWithInterfaces(c context.Context, pluginPackageId string, roles []string, pluginConfigId string) (result []*models.PluginConfigQueryObj, err error)

func GetPluginDependencies ¶

func GetPluginDependencies(ctx context.Context, pluginPackageId string) (result *models.PluginPackageDepObj, err error)

func GetPluginDockerRunningResource ¶

func GetPluginDockerRunningResource(dockerInstanceResourceId string) (pluginResourceServer *models.ResourceServer, err error)

func GetPluginDockerRuntimeMessage ¶

func GetPluginDockerRuntimeMessage(pluginPackageId string) (imageName, containerName string, err error)

func GetPluginInstance ¶

func GetPluginInstance(pluginInstanceId, instanceName, host, pluginPackageId string, forceCheck bool) (pluginInstance *models.PluginInstances, err error)

func GetPluginMenus ¶

func GetPluginMenus(ctx context.Context, pluginPackageId string) (result []*models.PluginPackageMenus, err error)

func GetPluginMysqlInstance ¶

func GetPluginMysqlInstance(ctx context.Context, name string) (result *models.PluginMysqlInstances, err error)

func GetPluginObjectMetaById ¶

func GetPluginObjectMetaById(ctx context.Context, objectMetaId string) (result *models.CoreObjectMeta, err error)

func GetPluginPackageById ¶

func GetPluginPackageById(ctx context.Context, id string) (result *models.PluginPackages, err error)

func GetPluginPackageNum ¶

func GetPluginPackageNum(ctx context.Context, name string) (registerNum int, err error)

func GetPluginPackagePullReq ¶

func GetPluginPackagePullReq(ctx context.Context, pullId string) (result *models.PluginArtifactPullReq, err error)

func GetPluginResourceFiles ¶

func GetPluginResourceFiles(ctx context.Context) (result []*models.PluginPackageResourceFiles, err error)

func GetPluginRunningInstances ¶

func GetPluginRunningInstances(ctx context.Context, pluginPackageId string) (result []*models.PluginInstances, err error)

func GetPluginRunningInstancesByName ¶

func GetPluginRunningInstancesByName(ctx context.Context, pluginPackageName string) (result []*models.PluginInstances, err error)

func GetPluginRuntimeResources ¶

func GetPluginRuntimeResources(ctx context.Context, pluginPackageId string) (result *models.PluginRuntimeResourceData, err error)

func GetPluginSystemParameters ¶

func GetPluginSystemParameters(ctx context.Context, pluginPackageId string) (result []*models.SystemVariables, err error)

func GetProcCacheData ¶

func GetProcCacheData(ctx context.Context, procInsId string) (procCacheDataRows []*models.ProcDataCache, err error)

func GetProcContextBindNodeType ¶

func GetProcContextBindNodeType(ctx context.Context, procDefId, bindNodeId string) (sourceNodeDef *models.ProcDefNode, err error)

func GetProcDataNodeExpression ¶

func GetProcDataNodeExpression(expression string) (result []*models.ProcDataNodeExprObj, err error)

func GetProcDefBySessionId ¶

func GetProcDefBySessionId(ctx context.Context, sessionId string) (procDefId string)

func GetProcDefDetailByProcDefId ¶

func GetProcDefDetailByProcDefId(ctx context.Context, procDefId string) (procDefDto *models.ProcessDefinitionDto, err error)

func GetProcDefNode ¶

func GetProcDefNode(ctx context.Context, procDefId, nodeId string) (result *models.ProcDefNode, err error)

GetProcDefNode 获取编排节点

func GetProcDefNodeById ¶

func GetProcDefNodeById(ctx context.Context, procDefId string) (list []*models.ProcDefNode, err error)

GetProcDefNodeById 根据编排Id编排节点

func GetProcDefNodeByIdAndProcDefId ¶

func GetProcDefNodeByIdAndProcDefId(ctx context.Context, procDefId, id string) (result *models.ProcDefNode, err error)

GetProcDefNodeByIdAndProcDefId 获取编排节点

func GetProcDefNodeByProcDefId ¶

func GetProcDefNodeByProcDefId(ctx context.Context, procDefId string) (list []*models.ProcDefNode, result []*models.ProcDefNodeResultDto, err error)

func GetProcDefNodeIdsBySessionId ¶

func GetProcDefNodeIdsBySessionId(ctx context.Context, sessionId string) (result []string, err error)

func GetProcDefNodeLink ¶

func GetProcDefNodeLink(ctx context.Context, procDefId string, linkId string) (result *models.ProcDefNodeLink, err error)

GetProcDefNodeLink 获取编排线

func GetProcDefNodeLinkByProcDefIdAndSource ¶

func GetProcDefNodeLinkByProcDefIdAndSource(ctx context.Context, procDefId string, source string) (list []*models.ProcDefNodeLink, err error)

func GetProcDefNodeLinkByProcDefIdAndTarget ¶

func GetProcDefNodeLinkByProcDefIdAndTarget(ctx context.Context, procDefId string, target string) (list []*models.ProcDefNodeLink, err error)

func GetProcDefNodeLinkListByProcDefId ¶

func GetProcDefNodeLinkListByProcDefId(ctx context.Context, procDefId string) (list []*models.ProcDefNodeLink, err error)

GetProcDefNodeLinkListByProcDefId 根据编排id获取编排线列表

func GetProcDefNodeModelByProcDefId ¶

func GetProcDefNodeModelByProcDefId(ctx context.Context, procDefId string) (list []*models.ProcDefNode, err error)

func GetProcDefNodeParamByNodeId ¶

func GetProcDefNodeParamByNodeId(ctx context.Context, nodeId string) (list []*models.ProcDefNodeParam, err error)

GetProcDefNodeParamByNodeId 根据节点获取编排节点参数

func GetProcDefParentList ¶

func GetProcDefParentList(ctx context.Context, procDefId string, pageInfo *models.PageInfo) (parentProcDefList []*models.ProcDefParentListItem, err error)

func GetProcDefPermissionByCondition ¶

func GetProcDefPermissionByCondition(ctx context.Context, permission models.ProcDefPermission) (list []*models.ProcDefPermission, err error)

GetProcDefPermissionByCondition 根据条件获取编排权限

func GetProcDefPermissionByIds ¶

func GetProcDefPermissionByIds(ctx context.Context, procDefIds []string) (list []*models.ProcDefPermission, err error)

func GetProcExecNodeData ¶

func GetProcExecNodeData(ctx context.Context, procRunNodeId string) (procInsNode *models.ProcInsNode, procDefNode *models.ProcDefNode, procDefNodeParams []*models.ProcDefNodeParam, dataBinding []*models.ProcDataBinding, err error)

func GetProcInsNodeContext ¶

func GetProcInsNodeContext(ctx context.Context, procInsId, procInsNodeId, procDefNodeId string) (result []*models.ProcNodeContextReq, err error)

func GetProcInsRootEntityData ¶

func GetProcInsRootEntityData(ctx context.Context, procInsId string) (entityDataId, entityTypeId, rootExpr string, err error)

func GetProcInstance ¶

func GetProcInstance(ctx context.Context, procInsId string) (result *models.ProcInsDetail, err error)

func GetProcInstanceBySessionId ¶

func GetProcInstanceBySessionId(ctx context.Context, sessionId string) (procInsId string, err error)

func GetProcNodeAllowOptions ¶

func GetProcNodeAllowOptions(ctx context.Context, procDefId, ProcNodeDefId string) (options []string, err error)

func GetProcNodeEndTime ¶

func GetProcNodeEndTime(ctx context.Context, procInsNodeId string) (endTime string, err error)

func GetProcNodeNextChoose ¶

func GetProcNodeNextChoose(ctx context.Context, procInsNodeId string) (nextChooseList []string, err error)

func GetProcPreviewBySession ¶

func GetProcPreviewBySession(ctx context.Context, sessionId string) (result *models.ProcPreviewData, err error)

func GetProcPreviewEntityNode ¶

func GetProcPreviewEntityNode(ctx context.Context, procInsId string) (result *models.ProcPreviewData, err error)

func GetProcScheduleConfigStatus ¶

func GetProcScheduleConfigStatus(ctx context.Context, id string) (status string)

func GetProcScheduleLoadList ¶

func GetProcScheduleLoadList() (psConfigList []*models.ProcScheduleConfig, err error)

func GetProcWorkByInsId ¶

func GetProcWorkByInsId(ctx context.Context, procInsId, procInsNodeId string) (workflowId, nodeId string, err error)

func GetProcessDefinition ¶

func GetProcessDefinition(ctx context.Context, id string) (result *models.ProcDef, err error)

GetProcessDefinition 获取编排定义

func GetProcessDefinitionAll ¶

func GetProcessDefinitionAll(ctx context.Context, userToken, language string) (list []*models.ProcDefDto, err error)

func GetProcessDefinitionByCondition ¶

func GetProcessDefinitionByCondition(ctx context.Context, condition models.ProcDefCondition) (list []*models.ProcDef, err error)

func GetProcessDefinitionByName ¶

func GetProcessDefinitionByName(ctx context.Context, name, version string) (procDefDto *models.ProcDefDto, err error)

func GetResourceItem ¶

func GetResourceItem(ctx context.Context, resourceType, name string, isAllocated bool) (resourceItemRows []*models.ResourceItem, err error)

func GetResourceServer ¶

func GetResourceServer(ctx context.Context, serverType, serverIp, name, resourceItemId string) (resourceServerObj *models.ResourceServer, err error)

func GetResourceServerById ¶

func GetResourceServerById(resId string) (resourceServer *models.ResourceServer, err error)

func GetResourceServerByIp ¶

func GetResourceServerByIp(hostIp string) (resourceServer *models.ResourceServer, err error)

func GetRouteItems ¶

func GetRouteItems(pluginName string) (result []*models.RouteItem, err error)

func GetRunningPluginPackages ¶

func GetRunningPluginPackages(ctx context.Context) (result []*models.PluginPackages, err error)

func GetRunningProcInsSubWorkflow ¶

func GetRunningProcInsSubWorkflow(ctx context.Context, procInsId, procNodeId string) (workflowIdList []string, err error)

func GetSimpleLastPluginInterface ¶

func GetSimpleLastPluginInterface(ctx context.Context, serviceName string) (interfaceObj *models.PluginInterfaceWithVer, err error)

func GetSimplePluginPackage ¶

func GetSimplePluginPackage(ctx context.Context, param *models.PluginPackages, emptyCheck bool) (err error)

func GetSimpleProcDefNode ¶

func GetSimpleProcDefNode(ctx context.Context, procDefNodeId string) (procDefNode *models.ProcDefNode, err error)

func GetSimpleProcDefRow ¶

func GetSimpleProcDefRow(ctx context.Context, procDefId string) (result *models.ProcDef, err error)

func GetSimpleProcInsNode ¶

func GetSimpleProcInsNode(ctx context.Context, procInsNodeId, procRunNodeId string) (procInsNode *models.ProcInsNode, err error)

func GetSimpleProcInsRow ¶

func GetSimpleProcInsRow(ctx context.Context, procInsId string) (result *models.ProcIns, err error)

func GetSimpleProcNodeReq ¶

func GetSimpleProcNodeReq(ctx context.Context, procInsNodeId, reqId, procRunNodeId string) (procReq *models.ProcInsNodeReq, err error)

func GetSimpleTranExport ¶

func GetSimpleTranExport(ctx context.Context, transExportId string) (transExport models.TransExportTable, err error)

func GetSingleCertification ¶

func GetSingleCertification(ctx context.Context, certId string) (result *models.PluginCertification, err error)

func GetSingleCertificationByName ¶

func GetSingleCertificationByName(ctx context.Context, pluginName string) (result *models.PluginCertification, err error)

func GetSubProcResult ¶

func GetSubProcResult(ctx context.Context, procRunNodeId string) (resultRows []*models.ProcSubProcQueryRow, err error)

func GetSystemVariable ¶

func GetSystemVariable(ctx context.Context, name string) (result string, err error)

func GetSystemVariableScope ¶

func GetSystemVariableScope() (result []string, err error)

func GetTemplate ¶

func GetTemplate(c *gin.Context, templateId string) (result *models.BatchExecutionTemplate, err error)

func GetTransExport ¶

func GetTransExport(ctx context.Context, transExportId string) (transExport *models.TransExportTable, err error)

func GetTransExportAnalyzeDataByCond ¶

func GetTransExportAnalyzeDataByCond(ctx context.Context, transExportId, dataType string) (analyzeData models.TransExportAnalyzeDataTable, err error)

func GetTransExportAnalyzeDataBySource ¶

func GetTransExportAnalyzeDataBySource(ctx context.Context, transExportId, source string) (result []*models.TransExportAnalyzeDataTable, err error)

func GetTransExportAnalyzeDataBySourceOne ¶

func GetTransExportAnalyzeDataBySourceOne(ctx context.Context, transExportId, source string) (analyzeData models.TransExportAnalyzeDataTable, err error)

func GetTransExportCustomer ¶

func GetTransExportCustomer(ctx context.Context, id string) (result *models.DataTransExportCustomerTable, err error)

func GetTransExportCustomerList ¶

func GetTransExportCustomerList(ctx context.Context) (result []*models.DataTransExportCustomerTable, err error)

func GetTransExportDetail ¶

func GetTransExportDetail(ctx context.Context, transExportId string) (detail *models.TransExportDetail, err error)

func GetTransImport ¶

func GetTransImport(ctx context.Context, transImportId string) (transImport *models.TransImportTable, err error)

func GetTransImportDetail ¶

func GetTransImportDetail(ctx context.Context, transImportId string) (result []*models.TransImportDetailTable, err error)

func GetTransImportDetailInput ¶

func GetTransImportDetailInput(ctx context.Context, transImportDetailId string) (result string, err error)

func GetTransImportDetailOutput ¶

func GetTransImportDetailOutput(ctx context.Context, transImportDetailId string) (result string, err error)

func GetTransImportProcDefId ¶

func GetTransImportProcDefId(ctx context.Context, procDefId, procDefKey string) (resultProcDefId string, err error)

func GetTransImportProcExecByDetailId ¶

func GetTransImportProcExecByDetailId(ctx context.Context, detailId string) (result []*models.TransImportProcExecTable, err error)

func GetTransImportProcExecList ¶

func GetTransImportProcExecList(ctx context.Context) (result []*models.TransImportProcExecTable, err error)

func GetTransImportWithDetail ¶

func GetTransImportWithDetail(ctx context.Context, transImportId string, withDetailData bool) (result *models.TransImportJobParam, err error)

func GetWorkflowNodeByReq ¶

func GetWorkflowNodeByReq(ctx context.Context, reqId string) (runNode *models.TaskCallbackReqQuery, err error)

func ImportPluginConfigs ¶

func ImportPluginConfigs(ctx context.Context, pluginPackageId string, packagePluginsXmlData *models.PackagePluginsXML) (result *models.PluginConfigDto, err error)

func ImportTemplate ¶

func ImportTemplate(c context.Context, operator string, batchExecTemplateData []*models.BatchExecutionTemplate) (err error)

func InheritPluginConfig ¶

func InheritPluginConfig(ctx context.Context, param *models.InheritPluginConfigParam, operator string) (err error)

func InitTransImport ¶

func InitTransImport(ctx context.Context, transImportId, ExportNexusUrl, localPath, operator string) (err error)

func InsertBatchExec ¶

func InsertBatchExec(c *gin.Context, reqParam *models.BatchExecRun) (batchExecId string, err error)

func InsertBatchExecJobs ¶

func InsertBatchExecJobs(c *gin.Context, batchExecId string, execTime *time.Time,
	batchExecRunParam *models.BatchExecRun,
	pluginCallParam *models.BatchExecutionPluginExecParam,
	batchExecRunResult *models.PluginInterfaceApiResultData) (err error)

func InsertProcDefNode ¶

func InsertProcDefNode(ctx context.Context, node *models.ProcDefNode) (err error)

InsertProcDefNode 添加编排节点

func InsertProcDefNodeLink ¶

func InsertProcDefNodeLink(ctx context.Context, nodeLink *models.ProcDefNodeLink) (err error)

InsertProcDefNodeLink 添加编排节点线

func InsertProcDefNodeParam ¶

func InsertProcDefNodeParam(ctx context.Context, nodeParam *models.ProcDefNodeParam) (err error)

InsertProcDefNodeParam 添加编排节点参数

func IsPluginInstanceRunning ¶

func IsPluginInstanceRunning(ctx context.Context, pluginPackageId string) (running bool, err error)

func LaunchPlugin ¶

func LaunchPlugin(ctx context.Context, pluginInstance *models.PluginInstances, resourceItem *models.ResourceItem, operator string) (err error)

func ListImportNexusArtifactPackages ¶

func ListImportNexusArtifactPackages(ctx context.Context, nexusUrl string) (fileMd5Map map[string]string, err error)

func ListProcInstance ¶

func ListProcInstance(ctx context.Context, userRoles []string, withCronIns, withSubProc, mgmtRole, search, status, createdBy string) (result []*models.ProcInsDetail, err error)

func MarshalWeLicense ¶

func MarshalWeLicense(lic *models.WeLicense) (data []byte, err error)

func ModifyImportStatus ¶

func ModifyImportStatus(ctx context.Context, param models.UpdateImportStatusParam) (err error)

ModifyImportStatus 更新导入状态

func NewPluginMysqlInstance ¶

func NewPluginMysqlInstance(ctx context.Context, mysqlServer *models.ResourceServer, mysqlInstance *models.PluginMysqlInstances, operator string, withResourceItem bool) (err error)

func NewProcScheduleJob ¶

func NewProcScheduleJob(ctx context.Context, psConfig *models.ProcScheduleConfig, newId string) (duplicateRow bool, err error)

func ParseJsonData ¶

func ParseJsonData(jsonPath string, data interface{}) (err error)

func ProcDefList ¶

func ProcDefList(ctx context.Context, includeDraft, permission, tag, plugin, subProc, operator, rootEntity string, userRoles []string) (result []*models.ProcDefListObj, err error)

ProcDefList subProc -> all(全部) | main(主编排) | sub(子编排)

func ProcDefOutline ¶

func ProcDefOutline(ctx context.Context, procDefId string) (result *models.ProcDefListObj, err error)

func ProcInsTaskNodeBindings ¶

func ProcInsTaskNodeBindings(ctx context.Context, sessionId, taskNodeId string) (result []*models.TaskNodeBindingObj, err error)

func PublicProcDefNodeList ¶

func PublicProcDefNodeList(ctx context.Context, procDefId string) (nodes []*models.ProcNodeObj, err error)

func QueryAllEnablePluginConfigInterfaceByCondition ¶

func QueryAllEnablePluginConfigInterfaceByCondition(ctx context.Context, param models.TargetEntityFilterRuleDto, roles []string) (plugConfigInterfaceDtoList []*models.PluginConfigInterfaceDto, err error)

func QueryBusinessList ¶

func QueryBusinessList(c context.Context, userToken, language string, param models.QueryBusinessParam) (result []map[string]interface{}, err error)

func QueryCoreObjectMeta ¶

func QueryCoreObjectMeta(ctx context.Context, packageName, objectName string, configId string) *models.CoreObjectMeta

func QueryCoreObjectMetaV2 ¶

func QueryCoreObjectMetaV2(ctx context.Context, pluginConfigId string, objectName string) (result *models.CoreObjectMeta, err error)

func QueryExpressionEntityAttr ¶

func QueryExpressionEntityAttr(ctx context.Context, exprObj *models.ExpressionObj) (result *models.ExpressionEntitiesRespObj, err error)

func QueryPluginConfigInfo ¶

func QueryPluginConfigInfo(ctx context.Context, pluginConfigIds []string) (result []*models.PluginConfigs, err error)

func QueryPluginInterfaceParam ¶

func QueryPluginInterfaceParam(ctx context.Context, param *models.PluginInterfaceParamQueryParam) (result *models.PluginConfigInterfaceParameters, err error)

func QueryPluginPackages ¶

func QueryPluginPackages(ctx context.Context, param *models.PluginPackageQueryParam) (result []*models.PluginPackageQueryObj, err error)

func QueryPluginProcessDefinitionList ¶

func QueryPluginProcessDefinitionList(ctx context.Context, plugin string) (list []*models.ProcDef, err error)

func QueryProcInsPage ¶

func QueryProcInsPage(ctx context.Context, param *models.QueryProcPageParam, userRoles []string) (result *models.QueryProcPageResponse, err error)

func QueryProcInstanceByIds ¶

func QueryProcInstanceByIds(ctx context.Context, ids []string) (result []*models.ProcInsDetail, err error)

func QueryProcScheduleInstance ¶

func QueryProcScheduleInstance(ctx context.Context, psConfigId, status string) (result []*models.ProcScheduleInstQueryObj, err error)

func QueryProcScheduleList ¶

func QueryProcScheduleList(ctx context.Context, param *models.ProcScheduleQueryParam, operator string, roleList []string) (result []*models.ProcScheduleConfigObj, err error)

func QueryProcessDefinitionList ¶

func QueryProcessDefinitionList(ctx context.Context, param models.QueryProcessDefinitionParam, userToken, language, operator string) (list []*models.ProcDefQueryDto, err error)

QueryProcessDefinitionList 查询编排列表

func QueryResourceItem ¶

func QueryResourceItem(ctx context.Context, param *models.QueryRequestParam) (result *models.ResourceItemListPageData, err error)

func QueryResourceServer ¶

func QueryResourceServer(ctx context.Context, param *models.QueryRequestParam) (result *models.ResourceServerListPageData, err error)

func QuerySimpleTransExportAnalyzeDataByTransExport ¶

func QuerySimpleTransExportAnalyzeDataByTransExport(ctx context.Context, transExportId string) (result []*models.TransExportAnalyzeDataTable, err error)

func QuerySystemVariables ¶

func QuerySystemVariables(ctx context.Context, param *models.QueryRequestParam) (result *models.SystemVariablesListPageData, err error)

func QuerySystemVariablesByCondition ¶

func QuerySystemVariablesByCondition(ctx context.Context, condition models.SystemVariablesQueryCondition) (list []*models.SystemVariables, err error)

func QueryTransExportByCondition ¶

func QueryTransExportByCondition(ctx context.Context, param models.TransExportHistoryParam) (pageInfo models.PageInfo, list []*models.TransExportTable, err error)

func QueryTransExportCustomerByName ¶

func QueryTransExportCustomerByName(ctx context.Context, name string) (result []*models.DataTransExportCustomerTable, err error)

func QueryTransImportByCondition ¶

func QueryTransImportByCondition(ctx context.Context, param models.TransImportHistoryParam) (pageInfo models.PageInfo, list []*models.TransImportTable, err error)

func QueryWebRunningPluginPackages ¶

func QueryWebRunningPluginPackages(ctx context.Context) (versionMap map[string]string, err error)

func RecordCustomReq ¶

func RecordCustomReq(ctx context.Context, param *models.ProcInsNodeReq) (err error)

func RecordProcCallReq ¶

func RecordProcCallReq(ctx context.Context, param *models.ProcInsNodeReq, inputFlag bool) (err error)

func RecordTransImportAction ¶

func RecordTransImportAction(ctx context.Context, callParam *models.CallTransImportActionParam) (actionId string, err error)

func RegisterPlugin ¶

func RegisterPlugin(ctx context.Context, name, version, operator string) (err error)

func RemovePlugin ¶

func RemovePlugin(ctx context.Context, pluginPackageId, pluginInstanceId, resourceItemId string) (err error)

func RemoveTempExportDir ¶

func RemoveTempExportDir(path string) (err error)

func RetrieveBatchExec ¶

func RetrieveBatchExec(c *gin.Context, reqParam *models.QueryRequestParam) (result *models.BatchExecListPageData, err error)

func RetrieveBatchExecJobs ¶

func RetrieveBatchExecJobs(c *gin.Context, reqParam *models.QueryRequestParam) (result *models.BatchExecJobsPageData, err error)

func RetrieveTemplate ¶

func RetrieveTemplate(c *gin.Context, reqParam *models.QueryRequestParam) (result *models.BatchExecTemplatePageData, err error)

func RewriteProcInsEntityData ¶

func RewriteProcInsEntityData(ctx context.Context, procInsId string, rewriteList []*models.RewriteEntityDataObj) (err error)

func RewriteProcInsEntityDataNew ¶

func RewriteProcInsEntityDataNew(ctx context.Context, procInsId string, rewriteData *models.RewriteEntityDataObj) (err error)

func SavePluginConfig ¶

func SavePluginConfig(c context.Context, reqParam *models.PluginConfigDto) (result *models.PluginConfigDto, err error)

func SetPluginPackageRegisterDone ¶

func SetPluginPackageRegisterDone(ctx context.Context, pluginPackageId, operator string) (dynamicModel bool, err error)

func StatisticsBindingsEntityByNode ¶

func StatisticsBindingsEntityByNode(ctx *gin.Context, nodeList []string) (result []*models.TasknodeBindsEntityData, err error)

编排节点-数据对象

func StatisticsBindingsEntityByService ¶

func StatisticsBindingsEntityByService(ctx *gin.Context, serviceNameList []string) (result []*models.TasknodeBindsEntityData, err error)

插件服务-数据对象

func StatisticsPluginExec ¶

func StatisticsPluginExec(ctx *gin.Context, reqParam *models.StatisticsTasknodeExecReq) (result *models.StatisticsTasknodeExecResp, err error)

插件注册-查询

func StatisticsPluginExecDetails ¶

func StatisticsPluginExecDetails(ctx *gin.Context, reqParam *models.StatisticsTasknodeExecDetailsReq) (result []*models.StatisticsTasknodeExecDetailsResp, err error)

插件注册-查询-详情

func StatisticsProcessExec ¶

func StatisticsProcessExec(ctx *gin.Context, reqParam *models.StatisticsProcessExecReq) (result []*models.StatisticsProcessExecResp, err error)

编排-查询

func StatisticsServiceNames ¶

func StatisticsServiceNames(ctx *gin.Context) (serviceNames []string, err error)

插件注册列表

func StatisticsTasknodeExec ¶

func StatisticsTasknodeExec(ctx *gin.Context, reqParam *models.StatisticsTasknodeExecReq) (result *models.StatisticsTasknodeExecResp, err error)

编排节点-查询

func StatisticsTasknodeExecDetails ¶

func StatisticsTasknodeExecDetails(ctx *gin.Context, reqParam *models.StatisticsTasknodeExecDetailsReq) (result []*models.StatisticsTasknodeExecDetailsResp, err error)

编排节点-查询-详情

func StatisticsTasknodes ¶

func StatisticsTasknodes(ctx *gin.Context, procDefIdList []string) (result []*models.Tasknode, err error)

任务节点查询

func SyncPluginDataModels ¶

func SyncPluginDataModels(ctx context.Context, packageName string, allModels []*models.SyncDataModelCiType) (err error)

func TransScheduleToCronExpr ¶

func TransScheduleToCronExpr(scheduleMode, scheduleExpr string) (cronExpr string, err error)

func TryFetchEnrichCoreObjectMeta ¶

func TryFetchEnrichCoreObjectMeta(ctx context.Context, param *models.PluginConfigInterfaceParameters) *models.CoreObjectMeta

func TryFetchLatestAvailableDataModelEntity ¶

func TryFetchLatestAvailableDataModelEntity(ctx context.Context, packageName string) (latestDataModelEntity *models.PluginPackageDataModel, err error)

TryFetchLatestAvailableDataModelEntity 尝试获取最新版本包插件

func UncollectBatchExecTemplate ¶

func UncollectBatchExecTemplate(c *gin.Context, reqParam *models.BatchExecutionTemplateCollect) (err error)

func UnmarshalWeLicense ¶

func UnmarshalWeLicense(data []byte) (result *models.WeLicense, err error)

func UpdateBatchExec ¶

func UpdateBatchExec(c *gin.Context, batchExecId string, updateData map[string]interface{}) (err error)

func UpdateCertification ¶

func UpdateCertification(ctx context.Context, certId string, lic *models.WeLicense, userId string) (cert *models.PluginCertification, err error)

func UpdateDynamicNodeBindData ¶

func UpdateDynamicNodeBindData(ctx context.Context, procInsId, procInsNodeId, procDefId, procDefNodeId string, dataBinding []*models.ProcDataBinding) (err error)

func UpdateExport ¶

func UpdateExport(c context.Context, param models.UpdateExportParam, operator string) (err error)

func UpdateObjectMetas ¶

func UpdateObjectMetas(c *gin.Context, reqParam *models.CoreObjectMeta) (err error)

func UpdatePluginConfigRoles ¶

func UpdatePluginConfigRoles(c *gin.Context, pluginConfigId string, reqParam *models.UpdatePluginCfgRolesReqParam) (err error)

func UpdatePluginConfigStatus ¶

func UpdatePluginConfigStatus(c *gin.Context, pluginConfigId string, status string) (result *models.PluginConfigDto, err error)

func UpdatePluginMysqlInstancePreVersion ¶

func UpdatePluginMysqlInstancePreVersion(ctx context.Context, mysqlInstanceId, preVersion string) (err error)

func UpdatePluginPackagePullReq ¶

func UpdatePluginPackagePullReq(ctx context.Context, pullId, pkgId, state, stateMsg, userId string, fileSize int) (err error)

func UpdatePluginStaticResourceFiles ¶

func UpdatePluginStaticResourceFiles(ctx context.Context, pluginPackageId, pluginPackageName string, inputs []*models.PluginPackageResourceFiles, operator string) (err error)

func UpdateProcCacheData ¶

func UpdateProcCacheData(ctx context.Context, procInsId string, dataBinding []*models.ProcDataBinding) (err error)

func UpdateProcCacheDataByTaskForm ¶

func UpdateProcCacheDataByTaskForm(ctx context.Context, procInsId string, taskFormList []*models.PluginTaskFormDto) (err error)

func UpdateProcDef ¶

func UpdateProcDef(ctx context.Context, procDef *models.ProcDef) (err error)

func UpdateProcDefAndNode ¶

func UpdateProcDefAndNode(ctx context.Context, procDef *models.ProcDef, nodeList []*models.ProcDefNode) (err error)

UpdateProcDefAndNode 编排根节点改变,需要同时清除编排所有节点的 RoutineExpression、ServiceName、ParamInfos

func UpdateProcDefHandler ¶

func UpdateProcDefHandler(ctx context.Context, procDefId, handler string) (err error)

func UpdateProcDefNode ¶

func UpdateProcDefNode(ctx context.Context, procDefNode *models.ProcDefNode) (err error)

UpdateProcDefNode 更新编排节点

func UpdateProcDefNodeLink ¶

func UpdateProcDefNodeLink(ctx context.Context, procDefNodeLink *models.ProcDefNodeLink) (err error)

UpdateProcDefNodeLink 更新编排节点线

func UpdateProcDefNodeOrder ¶

func UpdateProcDefNodeOrder(ctx context.Context, nodeIndexMap map[string]int) (err error)

func UpdateProcDefNodeStatusByProcDefId ¶

func UpdateProcDefNodeStatusByProcDefId(ctx context.Context, procDefId, status, updatedBy string) (err error)

UpdateProcDefNodeStatusByProcDefId 根据编排id更新编排节点状态

func UpdateProcDefStatus ¶

func UpdateProcDefStatus(ctx context.Context, procDef *models.ProcDef) (err error)

func UpdateProcDefStatusAndVersion ¶

func UpdateProcDefStatusAndVersion(ctx context.Context, procDef *models.ProcDef) (err error)

func UpdateProcInsNodeBindingData ¶

func UpdateProcInsNodeBindingData(ctx context.Context, param []*models.TaskNodeBindingObj, procInsId, procInsNodeId, operator string) (err error)

func UpdateProcInstanceRequestInfo ¶

func UpdateProcInstanceRequestInfo(ctx context.Context, procInstanceId, requestInfo string) (err error)

func UpdateProcNodeBindingData ¶

func UpdateProcNodeBindingData(ctx context.Context, param []*models.TaskNodeBindingObj, sessionId, taskNodeId, operator string) (err error)

func UpdateProcRunNodeSubProc ¶

func UpdateProcRunNodeSubProc(ctx context.Context, procRunNodeId string, subProcWorkflowList []*models.ProcRunNodeSubProc, dataBinding []*models.ProcDataBinding, parentInsNodeId string) (err error)

func UpdateProcScheduleJob ¶

func UpdateProcScheduleJob(ctx context.Context, jobId, status, errorMsg, procInsId string) (err error)

func UpdateProcScheduleStatus ¶

func UpdateProcScheduleStatus(ctx context.Context, id, status, operator string, roleList []string) (err error)

func UpdateResourceItem ¶

func UpdateResourceItem(ctx context.Context, params []*models.ResourceItem, operator string) (err error)

func UpdateResourceServer ¶

func UpdateResourceServer(ctx context.Context, params []*models.ResourceServer) (withHostServer bool, err error)

func UpdateSystemVariables ¶

func UpdateSystemVariables(ctx context.Context, params []*models.SystemVariables) (err error)

func UpdateTemplatePermission ¶

func UpdateTemplatePermission(c *gin.Context, reqParam *models.BatchExecutionTemplate) (result *models.BatchExecutionTemplate, err error)

func UpdateTemplateRolesDisplayName ¶

func UpdateTemplateRolesDisplayName(c *gin.Context, templateDataList []*models.BatchExecutionTemplate) (err error)

func UpdateTemplateStatus ¶

func UpdateTemplateStatus(templateData []*models.BatchExecutionTemplate, userRoles []string, permissionTypesToCheck []string)

func UpdateTransExportCustomer ¶

func UpdateTransExportCustomer(ctx context.Context, exportCustomer *models.DataTransExportCustomerTable) (err error)

func UpdateTransImport ¶

func UpdateTransImport(ctx context.Context, transImportId, status string) (err error)

func UpdateTransImportCMDBData ¶

func UpdateTransImportCMDBData(ctx context.Context, transImportParam *models.TransImportJobParam) (err error)

func UpdateTransImportDetailInput ¶

func UpdateTransImportDetailInput(ctx context.Context, transImportId string, step models.TransImportStep, input string) (err error)

func UpdateTransImportDetailOutput ¶

func UpdateTransImportDetailOutput(ctx context.Context, transImportId string, step models.TransImportStep, output string) (err error)

func UpdateTransImportDetailStatus ¶

func UpdateTransImportDetailStatus(ctx context.Context, transImportId, transImportDetailId, status, output, errorMsg string) (err error)

func UpdateTransImportProcExec ¶

func UpdateTransImportProcExec(ctx context.Context, param *models.TransImportProcExecTable) (affectRow bool, err error)

func UploadPackage ¶

func UploadPackage(ctx context.Context, registerConfig *models.RegisterXML, withUi, enterprise bool, pluginPackageId, operator string) (resultPackageId string, err error)

func ValidateBatchExecName ¶

func ValidateBatchExecName(c *gin.Context, batchExecReqParam *models.BatchExecRun, continueToken string) (isValid bool, err error)

func ValidateResourceServer ¶

func ValidateResourceServer(ctx context.Context, resourceServer *models.ResourceServer) (err error)

Types ¶

This section is empty.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL