insist777 commented on code in PR #12990:
URL:
https://github.com/apache/dolphinscheduler/pull/12990#discussion_r1032271395
##########
dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/process/ProcessService.java:
##########
@@ -83,7 +83,7 @@ ProcessInstance handleCommand(String host,
void removeTaskLogFile(Integer processInstanceId);
- void deleteWorkTaskInstanceByProcessInstanceId(int processInstanceId);
+ void deleteWorkTaskInstanceByProcessInstanceId(ProcessInstance
processInstance);
Review Comment:
done.
##########
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessInstanceServiceImpl.java:
##########
@@ -766,6 +811,22 @@ public Map<String, Object> deleteProcessInstanceById(User
loginUser, long projec
return result;
}
+ /**
+ * delete workflow instance by id, at the same timeļ¼delete task instance
and their mapping relation data
+ *
+ * @param loginUser login user
+ * @param workflowInstanceId workflow instance id
+ * @return delete result code
+ */
+ @Override
+ public Map<String, Object> deleteProcessInstanceById(User loginUser,
Integer workflowInstanceId) {
+ ProcessInstance processInstance =
processInstanceMapper.selectById(workflowInstanceId);
+ ProcessDefinition processDefinition =
Review Comment:
done.
##########
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ProcessInstanceServiceImpl.java:
##########
@@ -344,6 +360,35 @@ public Result queryProcessInstanceList(User loginUser,
long projectCode, long pr
return result;
}
+ /**
+ * paging query process instance list, filtering according to project,
process definition, time range, keyword, process status
+ *
+ * @param loginUser login user
+ * @param projectName project name
+ * @param pageNo page number
+ * @param pageSize page size
+ * @param processDefineName process definition name
+ * @param searchVal search value
+ * @param stateType state type
+ * @param host host
+ * @param startDate start time
+ * @param endDate end time
+ * @return process instance list
+ */
+ @Override
+ public Result queryProcessInstanceList(User loginUser, String projectName,
String processDefineName,
+ String startDate, String endDate,
String searchVal, String executorName,
+ WorkflowExecutionStatus stateType,
String host, Integer pageNo,
+ Integer pageSize) {
+ Project project = projectMapper.queryByName(projectName);
+ ProcessDefinition processDefinition =
+ processDefineMapper.queryByDefineName(project.getCode(),
processDefineName);
+
+ return queryProcessInstanceList(loginUser, project.getCode(),
processDefinition.getCode(),
Review Comment:
done.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
