@ -16,7 +16,9 @@
* /
package org.apache.dolphinscheduler.api.controller ;
import com.fasterxml.jackson.core.JsonProcessingException ;
import org.apache.dolphinscheduler.api.enums.Status ;
import org.apache.dolphinscheduler.api.exceptions.ApiException ;
import org.apache.dolphinscheduler.api.service.ProcessDefinitionService ;
import org.apache.dolphinscheduler.api.utils.Result ;
import org.apache.dolphinscheduler.common.Constants ;
@ -37,6 +39,8 @@ import java.util.HashMap;
import java.util.List ;
import java.util.Map ;
import static org.apache.dolphinscheduler.api.enums.Status.* ;
/ * *
* process definition controller
@ -44,7 +48,7 @@ import java.util.Map;
@Api ( tags = "PROCESS_DEFINITION_TAG" , position = 2 )
@RestController
@RequestMapping ( "projects/{projectName}/process" )
public class ProcessDefinitionController extends BaseController {
public class ProcessDefinitionController extends BaseController {
private static final Logger logger = LoggerFactory . getLogger ( ProcessDefinitionController . class ) ;
@ -54,130 +58,120 @@ public class ProcessDefinitionController extends BaseController{
/ * *
* create process definition
*
* @param loginUser login user
* @param loginUser login user
* @param projectName project name
* @param name process definition name
* @param json process definition json
* @param name process definition name
* @param json process definition json
* @param description description
* @param locations locations for nodes
* @param connects connects for nodes
* @param locations locations for nodes
* @param connects connects for nodes
* @return create result code
* /
@ApiOperation ( value = "save" , notes = "CREATE_PROCESS_DEFINITION_NOTES" )
@ApiOperation ( value = "save" , notes = "CREATE_PROCESS_DEFINITION_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "name" , value = "PROCESS_DEFINITION_NAME" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "processDefinitionJson" , value = "PROCESS_DEFINITION_JSON" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "locations" , value = "PROCESS_DEFINITION_LOCATIONS" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "connects" , value = "PROCESS_DEFINITION_CONNECTS" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "description" , value = "PROCESS_DEFINITION_DESC" , required = false , type = "String" ) ,
@ApiImplicitParam ( name = "processDefinitionJson" , value = "PROCESS_DEFINITION_JSON" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "locations" , value = "PROCESS_DEFINITION_LOCATIONS" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "connects" , value = "PROCESS_DEFINITION_CONNECTS" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "description" , value = "PROCESS_DEFINITION_DESC" , required = false , type = "String" ) ,
} )
@PostMapping ( value = "/save" )
@ResponseStatus ( HttpStatus . CREATED )
@ApiException ( CREATE_PROCESS_DEFINITION )
public Result createProcessDefinition ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( value = "name" , required = true ) String name ,
@RequestParam ( value = "processDefinitionJson" , required = true ) String json ,
@RequestParam ( value = "locations" , required = true ) String locations ,
@RequestParam ( value = "connects" , required = true ) String connects ,
@RequestParam ( value = "description" , required = false ) String description ) {
try {
logger . info ( "login user {}, create process definition, project name: {}, process definition name: {}, " +
"process_definition_json: {}, desc: {} locations:{}, connects:{}" ,
loginUser . getUserName ( ) , projectName , name , json , description , locations , connects ) ;
Map < String , Object > result = processDefinitionService . createProcessDefinition ( loginUser , projectName , name , json ,
description , locations , connects ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . CREATE_PROCESS_DEFINITION . getMsg ( ) , e ) ;
return error ( Status . CREATE_PROCESS_DEFINITION . getCode ( ) , Status . CREATE_PROCESS_DEFINITION . getMsg ( ) ) ;
}
@RequestParam ( value = "description" , required = false ) String description ) throws JsonProcessingException {
logger . info ( "login user {}, create process definition, project name: {}, process definition name: {}, " +
"process_definition_json: {}, desc: {} locations:{}, connects:{}" ,
loginUser . getUserName ( ) , projectName , name , json , description , locations , connects ) ;
Map < String , Object > result = processDefinitionService . createProcessDefinition ( loginUser , projectName , name , json ,
description , locations , connects ) ;
return returnDataList ( result ) ;
}
/ * *
* verify process definition name unique
*
* @param loginUser login user
* @param loginUser login user
* @param projectName project name
* @param name name
* @param name name
* @return true if process definition name not exists , otherwise false
* /
@ApiOperation ( value = "verify-name" , notes = "VERIFY_PROCC ESS_DEFINITION_NAME_NOTES" )
@ApiOperation ( value = "verify-name" , notes = "VERIFY_PROCESS_DEFINITION_NAME_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "name" , value = "PROCESS_DEFINITION_NAME" , required = true , type = "String" )
} )
@GetMapping ( value = "/verify-name" )
@ResponseStatus ( HttpStatus . OK )
public Result verifyProccessDefinitionName ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( value = "name" , required = true ) String name ) {
try {
logger . info ( "verify process definition name unique, user:{}, project name:{}, process definition name:{}" ,
loginUser . getUserName ( ) , projectName , name ) ;
Map < String , Object > result = processDefinitionService . verifyProccessDefinitionName ( loginUser , projectName , name ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . VERIFY_PROCESS_DEFINITION_NAME_UNIQUE_ERROR . getMsg ( ) , e ) ;
return error ( Status . VERIFY_PROCESS_DEFINITION_NAME_UNIQUE_ERROR . getCode ( ) , Status . VERIFY_PROCESS_DEFINITION_NAME_UNIQUE_ERROR . getMsg ( ) ) ;
}
@ApiException ( VERIFY_PROCESS_DEFINITION_NAME_UNIQUE_ERROR )
public Result verifyProcessDefinitionName ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( value = "name" , required = true ) String name ) {
logger . info ( "verify process definition name unique, user:{}, project name:{}, process definition name:{}" ,
loginUser . getUserName ( ) , projectName , name ) ;
Map < String , Object > result = processDefinitionService . verifyProcessDefinitionName ( loginUser , projectName , name ) ;
return returnDataList ( result ) ;
}
/ * *
* update process definition
*
* @param loginUser login user
* @param projectName project name
* @param name process definition name
* @param id process definition id
* @param loginUser login user
* @param projectName project name
* @param name process definition name
* @param id process definition id
* @param processDefinitionJson process definition json
* @param description description
* @param locations locations for nodes
* @param connects connects for nodes
* @param description description
* @param locations locations for nodes
* @param connects connects for nodes
* @return update result code
* /
@ApiOperation ( value = "updateProccessDefinition" , notes = "UPDATE_PROCCESS_DEFINITION_NOTES" )
@ApiOperation ( value = "updateProcessDefinition" , notes = "UPDATE_PROCESS_DEFINITION_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "name" , value = "PROCESS_DEFINITION_NAME" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "id" , value = "PROCESS_DEFINITION_ID" , required = true , dataType = "Int" , example = "100" ) ,
@ApiImplicitParam ( name = "processDefinitionJson" , value = "PROCESS_DEFINITION_JSON" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "locations" , value = "PROCESS_DEFINITION_LOCATIONS" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "connects" , value = "PROCESS_DEFINITION_CONNECTS" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "description" , value = "PROCESS_DEFINITION_DESC" , required = false , type = "String" ) ,
@ApiImplicitParam ( name = "processDefinitionJson" , value = "PROCESS_DEFINITION_JSON" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "locations" , value = "PROCESS_DEFINITION_LOCATIONS" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "connects" , value = "PROCESS_DEFINITION_CONNECTS" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "description" , value = "PROCESS_DEFINITION_DESC" , required = false , type = "String" ) ,
} )
@PostMapping ( value = "/update" )
@ResponseStatus ( HttpStatus . OK )
public Result updateProccessDefinition ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( value = "name" , required = true ) String name ,
@RequestParam ( value = "id" , required = true ) int id ,
@RequestParam ( value = "processDefinitionJson" , required = true ) String processDefinitionJson ,
@RequestParam ( value = "locations" , required = false ) String locations ,
@RequestParam ( value = "connects" , required = false ) String connects ,
@RequestParam ( value = "description" , required = false ) String description ) {
try {
logger . info ( "login user {}, update process define, project name: {}, process define name: {}, " +
"process_definition_json: {}, desc: {}, locations:{}, connects:{}" ,
loginUser . getUserName ( ) , projectName , name , processDefinitionJson , description , locations , connects ) ;
Map < String , Object > result = processDefinitionService . updateProcessDefinition ( loginUser , projectName , id , name ,
processDefinitionJson , description , locations , connects ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . UPDATE_PROCESS_DEFINITION_ERROR . getMsg ( ) , e ) ;
return error ( Status . UPDATE_PROCESS_DEFINITION_ERROR . getCode ( ) , Status . UPDATE_PROCESS_DEFINITION_ERROR . getMsg ( ) ) ;
}
@ApiException ( UPDATE_PROCESS_DEFINITION_ERROR )
public Result updateProcessDefinition ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( value = "name" , required = true ) String name ,
@RequestParam ( value = "id" , required = true ) int id ,
@RequestParam ( value = "processDefinitionJson" , required = true ) String processDefinitionJson ,
@RequestParam ( value = "locations" , required = false ) String locations ,
@RequestParam ( value = "connects" , required = false ) String connects ,
@RequestParam ( value = "description" , required = false ) String description ) {
logger . info ( "login user {}, update process define, project name: {}, process define name: {}, " +
"process_definition_json: {}, desc: {}, locations:{}, connects:{}" ,
loginUser . getUserName ( ) , projectName , name , processDefinitionJson , description , locations , connects ) ;
Map < String , Object > result = processDefinitionService . updateProcessDefinition ( loginUser , projectName , id , name ,
processDefinitionJson , description , locations , connects ) ;
return returnDataList ( result ) ;
}
/ * *
* release process definition
*
* @param loginUser login user
* @param projectName project name
* @param processId process definition id
* @param loginUser login user
* @param projectName project name
* @param processId process definition id
* @param releaseState release state
* @return release result code
* /
@ApiOperation ( value = "releaseProccessDefinition" , notes = "RELEASE_PROCCESS_DEFINITION_NOTES" )
@ApiOperation ( value = "releaseProcessDefinition" , notes = "RELEASE_PROCESS_DEFINITION_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "name" , value = "PROCESS_DEFINITION_NAME" , required = true , type = "String" ) ,
@ApiImplicitParam ( name = "processId" , value = "PROCESS_DEFINITION_ID" , required = true , dataType = "Int" , example = "100" ) ,
@ -185,344 +179,296 @@ public class ProcessDefinitionController extends BaseController{
} )
@PostMapping ( value = "/release" )
@ResponseStatus ( HttpStatus . OK )
public Result releaseProccessDefinition ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( value = "processId" , required = true ) int processId ,
@RequestParam ( value = "releaseState" , required = true ) int releaseState ) {
try {
logger . info ( "login user {}, release process definition, project name: {}, release state: {}" ,
loginUser . getUserName ( ) , projectName , releaseState ) ;
Map < String , Object > result = processDefinitionService . releaseProcessDefinition ( loginUser , projectName , processId , releaseState ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . RELEASE_PROCESS_DEFINITION_ERROR . getMsg ( ) , e ) ;
return error ( Status . RELEASE_PROCESS_DEFINITION_ERROR . getCode ( ) , Status . RELEASE_PROCESS_DEFINITION_ERROR . getMsg ( ) ) ;
}
@ApiException ( RELEASE_PROCESS_DEFINITION_ERROR )
public Result releaseProcessDefinition ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( value = "processId" , required = true ) int processId ,
@RequestParam ( value = "releaseState" , required = true ) int releaseState ) {
logger . info ( "login user {}, release process definition, project name: {}, release state: {}" ,
loginUser . getUserName ( ) , projectName , releaseState ) ;
Map < String , Object > result = processDefinitionService . releaseProcessDefinition ( loginUser , projectName , processId , releaseState ) ;
return returnDataList ( result ) ;
}
/ * *
* query datail of process definition
*
* @param loginUser login user
* @param loginUser login user
* @param projectName project name
* @param processId process definition id
* @param processId process definition id
* @return process definition detail
* /
@ApiOperation ( value = "queryProcc essDefinitionById" , notes = "QUERY_PROC CESS_DEFINITION_BY_ID_NOTES" )
@ApiOperation ( value = "queryProcessDefinitionById" , notes = "QUERY_PROCESS_DEFINITION_BY_ID_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "processId" , value = "PROCESS_DEFINITION_ID" , required = true , dataType = "Int" , example = "100" )
} )
@GetMapping ( value = "/select-by-id" )
@GetMapping ( value = "/select-by-id" )
@ResponseStatus ( HttpStatus . OK )
public Result queryProccessDefinitionById ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@ApiException ( QUERY_DATAIL_OF_PROCESS_DEFINITION_ERROR )
public Result queryProcessDefinitionById ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processId" ) Integer processId
) {
try {
logger . info ( "query datail of process definition, login user:{}, project name:{}, process definition id:{}" ,
loginUser . getUserName ( ) , projectName , processId ) ;
Map < String , Object > result = processDefinitionService . queryProccessDefinitionById ( loginUser , projectName , processId ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . QUERY_DATAIL_OF_PROCESS_DEFINITION_ERROR . getMsg ( ) , e ) ;
return error ( Status . QUERY_DATAIL_OF_PROCESS_DEFINITION_ERROR . getCode ( ) , Status . QUERY_DATAIL_OF_PROCESS_DEFINITION_ERROR . getMsg ( ) ) ;
}
) {
logger . info ( "query detail of process definition, login user:{}, project name:{}, process definition id:{}" ,
loginUser . getUserName ( ) , projectName , processId ) ;
Map < String , Object > result = processDefinitionService . queryProcessDefinitionById ( loginUser , projectName , processId ) ;
return returnDataList ( result ) ;
}
/ * *
* query proc cessdefinition list
* query Process definition list
*
* @param loginUser login user
* @param loginUser login user
* @param projectName project name
* @return process definition list
* /
@ApiOperation ( value = "queryProcc essDefinitionList" , notes = "QUERY_PROC CESS_DEFINITION_LIST_NOTES" )
@GetMapping ( value = "/list" )
@ApiOperation ( value = "queryProcessDefinitionList" , notes = "QUERY_PROCESS_DEFINITION_LIST_NOTES" )
@GetMapping ( value = "/list" )
@ResponseStatus ( HttpStatus . OK )
public Result queryProccessDefinitionList ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName
) {
try {
logger . info ( "query proccess definition list, login user:{}, project name:{}" ,
loginUser . getUserName ( ) , projectName ) ;
Map < String , Object > result = processDefinitionService . queryProccessDefinitionList ( loginUser , projectName ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . QUERY_PROCCESS_DEFINITION_LIST . getMsg ( ) , e ) ;
return error ( Status . QUERY_PROCCESS_DEFINITION_LIST . getCode ( ) , Status . QUERY_PROCCESS_DEFINITION_LIST . getMsg ( ) ) ;
}
@ApiException ( QUERY_PROCESS_DEFINITION_LIST )
public Result queryProcessDefinitionList ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName
) {
logger . info ( "query process definition list, login user:{}, project name:{}" ,
loginUser . getUserName ( ) , projectName ) ;
Map < String , Object > result = processDefinitionService . queryProcessDefinitionList ( loginUser , projectName ) ;
return returnDataList ( result ) ;
}
/ * *
* query proccess definition list paging
* @param loginUser login user
* query process definition list paging
*
* @param loginUser login user
* @param projectName project name
* @param searchVal search value
* @param pageNo page number
* @param pageSize page size
* @param userId user id
* @param searchVal search value
* @param pageNo page number
* @param pageSize page size
* @param userId user id
* @return process definition page
* /
@ApiOperation ( value = "queryProcessDefinitionListPaging" , notes = "QUERY_PROCC ESS_DEFINITION_LIST_PAGING_NOTES" )
@ApiOperation ( value = "queryProcessDefinitionListPaging" , notes = "QUERY_PROCESS_DEFINITION_LIST_PAGING_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "pageNo" , value = "PAGE_NO" , required = true , dataType = "Int" , example = "100" ) ,
@ApiImplicitParam ( name = "searchVal" , value = "SEARCH_VAL" , required = false , type = "String" ) ,
@ApiImplicitParam ( name = "userId" , value = "USER_ID" , required = false , dataType = "Int" , example = "100" ) ,
@ApiImplicitParam ( name = "pageSize" , value = "PAGE_SIZE" , required = true , dataType = "Int" , example = "100" )
} )
@GetMapping ( value = "/list-paging" )
@GetMapping ( value = "/list-paging" )
@ResponseStatus ( HttpStatus . OK )
@ApiException ( QUERY_PROCESS_DEFINITION_LIST_PAGING_ERROR )
public Result queryProcessDefinitionListPaging ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "pageNo" ) Integer pageNo ,
@RequestParam ( value = "searchVal" , required = false ) String searchVal ,
@RequestParam ( value = "userId" , required = false , defaultValue = "0" ) Integer userId ,
@RequestParam ( "pageSize" ) Integer pageSize ) {
try {
logger . info ( "query proccess definition list paging, login user:{}, project name:{}" , loginUser . getUserName ( ) , projectName ) ;
Map < String , Object > result = checkPageParams ( pageNo , pageSize ) ;
if ( result . get ( Constants . STATUS ) ! = Status . SUCCESS ) {
return returnDataListPaging ( result ) ;
}
searchVal = ParameterUtils . handleEscapes ( searchVal ) ;
result = processDefinitionService . queryProcessDefinitionListPaging ( loginUser , projectName , searchVal , pageNo , pageSize , userId ) ;
@RequestParam ( "pageSize" ) Integer pageSize ) {
logger . info ( "query process definition list paging, login user:{}, project name:{}" , loginUser . getUserName ( ) , projectName ) ;
Map < String , Object > result = checkPageParams ( pageNo , pageSize ) ;
if ( result . get ( Constants . STATUS ) ! = Status . SUCCESS ) {
return returnDataListPaging ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . QUERY_PROCCESS_DEFINITION_LIST_PAGING_ERROR . getMsg ( ) , e ) ;
return error ( Status . QUERY_PROCCESS_DEFINITION_LIST_PAGING_ERROR . getCode ( ) , Status . QUERY_PROCCESS_DEFINITION_LIST_PAGING_ERROR . getMsg ( ) ) ;
}
searchVal = ParameterUtils . handleEscapes ( searchVal ) ;
result = processDefinitionService . queryProcessDefinitionListPaging ( loginUser , projectName , searchVal , pageNo , pageSize , userId ) ;
return returnDataListPaging ( result ) ;
}
/ * *
* encapsulation treeview structure
*
* @param loginUser login user
* @param loginUser login user
* @param projectName project name
* @param id process definition id
* @param limit limit
* @param id process definition id
* @param limit limit
* @return tree view json data
* /
@ApiOperation ( value = "viewTree" , notes = "VIEW_TREE_NOTES" )
@ApiOperation ( value = "viewTree" , notes = "VIEW_TREE_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "processId" , value = "PROCESS_DEFINITION_ID" , required = true , dataType = "Int" , example = "100" ) ,
@ApiImplicitParam ( name = "limit" , value = "LIMIT" , required = true , dataType = "Int" , example = "100" )
} )
@GetMapping ( value = "/view-tree" )
@GetMapping ( value = "/view-tree" )
@ResponseStatus ( HttpStatus . OK )
@ApiException ( ENCAPSULATION_TREEVIEW_STRUCTURE_ERROR )
public Result viewTree ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processId" ) Integer id ,
@RequestParam ( "limit" ) Integer limit ) {
try {
Map < String , Object > result = processDefinitionService . viewTree ( id , limit ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . ENCAPSULATION_TREEVIEW_STRUCTURE_ERROR . getMsg ( ) , e ) ;
return error ( Status . ENCAPSULATION_TREEVIEW_STRUCTURE_ERROR . getCode ( ) , Status . ENCAPSULATION_TREEVIEW_STRUCTURE_ERROR . getMsg ( ) ) ;
}
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processId" ) Integer id ,
@RequestParam ( "limit" ) Integer limit ) throws Exception {
Map < String , Object > result = processDefinitionService . viewTree ( id , limit ) ;
return returnDataList ( result ) ;
}
/ * *
*
* get tasks list by process definition id
*
*
* @param loginUser login user
* @param projectName project name
* @param loginUser login user
* @param projectName project name
* @param processDefinitionId process definition id
* @return task list
* /
@ApiOperation ( value = "getNodeListByDefinitionId" , notes = "GET_NODE_LIST_BY_DEFINITION_ID_NOTES" )
@ApiOperation ( value = "getNodeListByDefinitionId" , notes = "GET_NODE_LIST_BY_DEFINITION_ID_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "processDefinitionId" , value = "PROCESS_DEFINITION_ID" , required = true , dataType = "Int" , example = "100" )
} )
@GetMapping ( value = "gen-task-list" )
@GetMapping ( value = "gen-task-list" )
@ResponseStatus ( HttpStatus . OK )
@ApiException ( GET_TASKS_LIST_BY_PROCESS_DEFINITION_ID_ERROR )
public Result getNodeListByDefinitionId (
@ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processDefinitionId" ) Integer processDefinitionId ) {
try {
logger . info ( "query task node name list by definitionId, login user:{}, project name:{}, id : {}" ,
loginUser . getUserName ( ) , projectName , processDefinitionId ) ;
Map < String , Object > result = processDefinitionService . getTaskNodeListByDefinitionId ( processDefinitionId ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . GET_TASKS_LIST_BY_PROCESS_DEFINITION_ID_ERROR . getMsg ( ) , e ) ;
return error ( Status . GET_TASKS_LIST_BY_PROCESS_DEFINITION_ID_ERROR . getCode ( ) , Status . GET_TASKS_LIST_BY_PROCESS_DEFINITION_ID_ERROR . getMsg ( ) ) ;
}
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processDefinitionId" ) Integer processDefinitionId ) throws Exception {
logger . info ( "query task node name list by definitionId, login user:{}, project name:{}, id : {}" ,
loginUser . getUserName ( ) , projectName , processDefinitionId ) ;
Map < String , Object > result = processDefinitionService . getTaskNodeListByDefinitionId ( processDefinitionId ) ;
return returnDataList ( result ) ;
}
/ * *
*
* get tasks list by process definition id
*
*
* @param loginUser login user
* @param projectName project name
* @param loginUser login user
* @param projectName project name
* @param processDefinitionIdList process definition id list
* @return node list data
* /
@ApiOperation ( value = "getNodeListByDefinitionIdList" , notes = "GET_NODE_LIST_BY_DEFINITION_ID_NOTES" )
@ApiOperation ( value = "getNodeListByDefinitionIdList" , notes = "GET_NODE_LIST_BY_DEFINITION_ID_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "processDefinitionIdList" , value = "PROCESS_DEFINITION_ID_LIST" , required = true , type = "String" )
} )
@GetMapping ( value = "get-task-list" )
@GetMapping ( value = "get-task-list" )
@ResponseStatus ( HttpStatus . OK )
@ApiException ( GET_TASKS_LIST_BY_PROCESS_DEFINITION_ID_ERROR )
public Result getNodeListByDefinitionIdList (
@ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processDefinitionIdList" ) String processDefinitionIdList ) {
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processDefinitionIdList" ) String processDefinitionIdList ) throws Exception {
try {
logger . info ( "query task node name list by definitionId list, login user:{}, project name:{}, id list: {}" ,
loginUser . getUserName ( ) , projectName , processDefinitionIdList ) ;
Map < String , Object > result = processDefinitionService . getTaskNodeListByDefinitionIdList ( processDefinitionIdList ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . GET_TASKS_LIST_BY_PROCESS_DEFINITION_ID_ERROR . getMsg ( ) , e ) ;
return error ( Status . GET_TASKS_LIST_BY_PROCESS_DEFINITION_ID_ERROR . getCode ( ) , Status . GET_TASKS_LIST_BY_PROCESS_DEFINITION_ID_ERROR . getMsg ( ) ) ;
}
logger . info ( "query task node name list by definitionId list, login user:{}, project name:{}, id list: {}" ,
loginUser . getUserName ( ) , projectName , processDefinitionIdList ) ;
Map < String , Object > result = processDefinitionService . getTaskNodeListByDefinitionIdList ( processDefinitionIdList ) ;
return returnDataList ( result ) ;
}
/ * *
* delete process definition by id
*
* @param loginUser login user
* @param projectName project name
* @param loginUser login user
* @param projectName project name
* @param processDefinitionId process definition id
* @return delete result code
* /
@ApiOperation ( value = "deleteProcessDefinitionById" , notes = "DELETE_PROCESS_DEFINITION_BY_ID_NOTES" )
@ApiOperation ( value = "deleteProcessDefinitionById" , notes = "DELETE_PROCESS_DEFINITION_BY_ID_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "processDefinitionId" , value = "PROCESS_DEFINITION_ID" , dataType = "Int" , example = "100" )
} )
@GetMapping ( value = "/delete" )
@GetMapping ( value = "/delete" )
@ResponseStatus ( HttpStatus . OK )
@ApiException ( DELETE_PROCESS_DEFINE_BY_ID_ERROR )
public Result deleteProcessDefinitionById ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processDefinitionId" ) Integer processDefinitionId
) {
try {
logger . info ( "delete process definition by id, login user:{}, project name:{}, process definition id:{}" ,
loginUser . getUserName ( ) , projectName , processDefinitionId ) ;
Map < String , Object > result = processDefinitionService . deleteProcessDefinitionById ( loginUser , projectName , processDefinitionId ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . DELETE_PROCESS_DEFINE_BY_ID_ERROR . getMsg ( ) , e ) ;
return error ( Status . DELETE_PROCESS_DEFINE_BY_ID_ERROR . getCode ( ) , Status . DELETE_PROCESS_DEFINE_BY_ID_ERROR . getMsg ( ) ) ;
}
@RequestParam ( "processDefinitionId" ) Integer processDefinitionId
) {
logger . info ( "delete process definition by id, login user:{}, project name:{}, process definition id:{}" ,
loginUser . getUserName ( ) , projectName , processDefinitionId ) ;
Map < String , Object > result = processDefinitionService . deleteProcessDefinitionById ( loginUser , projectName , processDefinitionId ) ;
return returnDataList ( result ) ;
}
/ * *
* batch delete process definition by ids
*
* @param loginUser login user
* @param projectName project name
* @param loginUser login user
* @param projectName project name
* @param processDefinitionIds process definition id list
* @return delete result code
* /
@ApiOperation ( value = "batchDeleteProcessDefinitionByIds" , notes = "BATCH_DELETE_PROCESS_DEFINITION_BY_IDS_NOTES" )
@ApiOperation ( value = "batchDeleteProcessDefinitionByIds" , notes = "BATCH_DELETE_PROCESS_DEFINITION_BY_IDS_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "processDefinitionIds" , value = "PROCESS_DEFINITION_IDS" , type = "String" )
} )
@GetMapping ( value = "/batch-delete" )
@GetMapping ( value = "/batch-delete" )
@ResponseStatus ( HttpStatus . OK )
@ApiException ( BATCH_DELETE_PROCESS_DEFINE_BY_IDS_ERROR )
public Result batchDeleteProcessDefinitionByIds ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@ApiParam ( name = "projectName" , value = "PROJECT_NAME" , required = true ) @PathVariable String projectName ,
@RequestParam ( "processDefinitionIds" ) String processDefinitionIds
) {
try {
logger . info ( "delete process definition by ids, login user:{}, project name:{}, process definition ids:{}" ,
loginUser . getUserName ( ) , projectName , processDefinitionIds ) ;
Map < String , Object > result = new HashMap < > ( 5 ) ;
List < String > deleteFailedIdList = new ArrayList < > ( ) ;
if ( StringUtils . isNotEmpty ( processDefinitionIds ) ) {
String [ ] processDefinitionIdArray = processDefinitionIds . split ( "," ) ;
for ( String strProcessDefinitionId : processDefinitionIdArray ) {
int processDefinitionId = Integer . parseInt ( strProcessDefinitionId ) ;
try {
Map < String , Object > deleteResult = processDefinitionService . deleteProcessDefinitionById ( loginUser , projectName , processDefinitionId ) ;
if ( ! Status . SUCCESS . equals ( deleteResult . get ( Constants . STATUS ) ) ) {
deleteFailedIdList . add ( strProcessDefinitionId ) ;
logger . error ( ( String ) deleteResult . get ( Constants . MSG ) ) ;
}
} catch ( Exception e ) {
@RequestParam ( "processDefinitionIds" ) String processDefinitionIds
) {
logger . info ( "delete process definition by ids, login user:{}, project name:{}, process definition ids:{}" ,
loginUser . getUserName ( ) , projectName , processDefinitionIds ) ;
Map < String , Object > result = new HashMap < > ( 5 ) ;
List < String > deleteFailedIdList = new ArrayList < > ( ) ;
if ( StringUtils . isNotEmpty ( processDefinitionIds ) ) {
String [ ] processDefinitionIdArray = processDefinitionIds . split ( "," ) ;
for ( String strProcessDefinitionId : processDefinitionIdArray ) {
int processDefinitionId = Integer . parseInt ( strProcessDefinitionId ) ;
try {
Map < String , Object > deleteResult = processDefinitionService . deleteProcessDefinitionById ( loginUser , projectName , processDefinitionId ) ;
if ( ! Status . SUCCESS . equals ( deleteResult . get ( Constants . STATUS ) ) ) {
deleteFailedIdList . add ( strProcessDefinitionId ) ;
logger . error ( ( String ) deleteResult . get ( Constants . MSG ) ) ;
}
} catch ( Exception e ) {
deleteFailedIdList . add ( strProcessDefinitionId ) ;
}
}
}
if ( ! deleteFailedIdList . isEmpty ( ) ) {
putMsg ( result , Status . BATCH_DELETE_PROCESS_DEFINE_BY_IDS_ERROR , String . join ( "," , deleteFailedIdList ) ) ;
} else {
putMsg ( result , Status . SUCCESS ) ;
}
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . BATCH_DELETE_PROCESS_DEFINE_BY_IDS_ERROR . getMsg ( ) , e ) ;
return error ( Status . BATCH_DELETE_PROCESS_DEFINE_BY_IDS_ERROR . getCode ( ) , Status . BATCH_DELETE_PROCESS_DEFINE_BY_IDS_ERROR . getMsg ( ) ) ;
if ( ! deleteFailedIdList . isEmpty ( ) ) {
putMsg ( result , Status . BATCH_DELETE_PROCESS_DEFINE_BY_IDS_ERROR , String . join ( "," , deleteFailedIdList ) ) ;
} else {
putMsg ( result , Status . SUCCESS ) ;
}
return returnDataList ( result ) ;
}
/ * *
* export process definition by id
*
* @param loginUser login user
* @param projectName project name
* @param loginUser login user
* @param projectName project name
* @param processDefinitionId process definition id
* @param response response
* @param response response
* /
@ApiOperation ( value = "exportProcessDefinitionById" , notes = "EXPORT_PROCCESS_DEFINITION_BY_ID_NOTES" )
@ApiOperation ( value = "exportProcessDefinitionById" , notes = "EXPORT_PROCESS_DEFINITION_BY_ID_NOTES" )
@ApiImplicitParams ( {
@ApiImplicitParam ( name = "processDefinitionId" , value = "PROCESS_DEFINITION_ID" , required = true , dataType = "Int" , example = "100" )
} )
@GetMapping ( value = "/export" )
@GetMapping ( value = "/export" )
@ResponseBody
public void exportProcessDefinitionById ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@PathVariable String projectName ,
@RequestParam ( "processDefinitionId" ) Integer processDefinitionId ,
HttpServletResponse response ) {
try {
HttpServletResponse response ) {
try {
logger . info ( "export process definition by id, login user:{}, project name:{}, process definition id:{}" ,
loginUser . getUserName ( ) , projectName , processDefinitionId ) ;
processDefinitionService . exportProcessDefinitionById ( loginUser , projectName , processDefinitionId , response ) ;
} catch ( Exception e ) {
logger . error ( Status . EXPORT_PROCESS_DEFINE_BY_ID_ERROR . getMsg ( ) , e ) ;
processDefinitionService . exportProcessDefinitionById ( loginUser , projectName , processDefinitionId , response ) ;
} catch ( Exception e ) {
logger . error ( Status . EXPORT_PROCESS_DEFINE_BY_ID_ERROR . getMsg ( ) , e ) ;
}
}
/ * *
* query procc ess definition all by project id
* query process definition all by project id
*
* @param loginUser login user
* @param projectId project id
* @param projectId project id
* @return process definition list
* /
@ApiOperation ( value = "queryProcc essDefinitionAllByProjectId" , notes = "QUERY_PROC CESS_DEFINITION_All_BY_PROJECT_ID_NOTES" )
@GetMapping ( value = "/queryProc cessDefinitionAllByProjectId" )
@ApiOperation ( value = "queryProcessDefinitionAllByProjectId" , notes = "QUERY_PROCESS_DEFINITION_All_BY_PROJECT_ID_NOTES" )
@GetMapping ( value = "/queryProcessDefinitionAllByProjectId" )
@ResponseStatus ( HttpStatus . OK )
public Result queryProccessDefinitionAllByProjectId ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@RequestParam ( "projectId" ) Integer projectId ) {
try {
logger . info ( "query proccess definition list, login user:{}, project id:{}" ,
loginUser . getUserName ( ) , projectId ) ;
Map < String , Object > result = processDefinitionService . queryProccessDefinitionAllByProjectId ( projectId ) ;
return returnDataList ( result ) ;
} catch ( Exception e ) {
logger . error ( Status . QUERY_PROCCESS_DEFINITION_LIST . getMsg ( ) , e ) ;
return error ( Status . QUERY_PROCCESS_DEFINITION_LIST . getCode ( ) , Status . QUERY_PROCCESS_DEFINITION_LIST . getMsg ( ) ) ;
}
@ApiException ( QUERY_PROCESS_DEFINITION_LIST )
public Result queryProcessDefinitionAllByProjectId ( @ApiIgnore @RequestAttribute ( value = Constants . SESSION_USER ) User loginUser ,
@RequestParam ( "projectId" ) Integer projectId ) {
logger . info ( "query process definition list, login user:{}, project id:{}" ,
loginUser . getUserName ( ) , projectId ) ;
Map < String , Object > result = processDefinitionService . queryProcessDefinitionAllByProjectId ( projectId ) ;
return returnDataList ( result ) ;
}
}
liwenhe1993
4 years ago