@Test public void testProjectFlowfindByName() { }
public ProjectFlow projectFlowfindByName(int projectId, String name) { ProjectFlow projectFlow = projectFlowMapper.findByName(projectId, name); if (projectFlow != null) { List<FlowNode> flowNodeList = flowNodeMapper.selectByFlowId(projectFlow.getId()); projectFlow.setFlowsNodes(flowNodeList); } return projectFlow; }
FlowDao extends BaseDao { public ProjectFlow projectFlowfindByName(int projectId, String name) { ProjectFlow projectFlow = projectFlowMapper.findByName(projectId, name); if (projectFlow != null) { List<FlowNode> flowNodeList = flowNodeMapper.selectByFlowId(projectFlow.getId()); projectFlow.setFlowsNodes(flowNodeList); } return projectFlow; } }
FlowDao extends BaseDao { public ProjectFlow projectFlowfindByName(int projectId, String name) { ProjectFlow projectFlow = projectFlowMapper.findByName(projectId, name); if (projectFlow != null) { List<FlowNode> flowNodeList = flowNodeMapper.selectByFlowId(projectFlow.getId()); projectFlow.setFlowsNodes(flowNodeList); } return projectFlow; }  }
FlowDao extends BaseDao { public ProjectFlow projectFlowfindByName(int projectId, String name) { ProjectFlow projectFlow = projectFlowMapper.findByName(projectId, name); if (projectFlow != null) { List<FlowNode> flowNodeList = flowNodeMapper.selectByFlowId(projectFlow.getId()); projectFlow.setFlowsNodes(flowNodeList); } return projectFlow; }  ExecutionFlow queryExecutionFlow(int execId); int deleteExecutionNodes(int execId); List<ExecutionFlow> queryAllNoFinishFlow(); List<ExecutionFlow> queryNoFinishFlow(String worker); ExecutionFlow queryExecutionFlowByScheduleTime(int flowId, Date scheduleTime); boolean updateExecutionFlowStatus(int execId, FlowStatus status); boolean updateExecutionFlowStatus(int execId, FlowStatus status, String worker); boolean updateExecutionFlow(ExecutionFlow executionFlow); boolean updateExecutionFlowDataSub(ExecutionFlow executionFlow); ExecutionFlow scheduleFlowToExecution(Integer projectId,
      Integer workflowId,
      int submitUser,
      Date scheduleTime,
      ExecType runType,
      FailurePolicyType failurePolicyType,
      Integer maxTryTimes,
      String nodeName,
      NodeDepType nodeDep,
      NotifyType notifyType,
      List<String> mails,
      int timeout); @Transactional(value = "TransactionManager") void deleteWorkflow(int workflowId); void insertExecutionNode(ExecutionNode executionNode); void updateExecutionNode(ExecutionNode executionNode); ExecutionNode queryExecutionNode(long execId, String nodeName); Schedule querySchedule(int flowId); ProjectFlow projectFlowfindByName(int projectId, String name); ProjectFlow projectFlowFindById(int id); @Transactional(value = "TransactionManager", rollbackFor = Exception.class) void createProjectFlow(ProjectFlow projectFlow); @Transactional(value = "TransactionManager", rollbackFor = Exception.class) void modifyProjectFlow(ProjectFlow projectFlow); ProjectFlow projectFlowFindByPorjectNameAndName(String projectName, String name); List<ProjectFlow> projectFlowFindByProject(int projectId); ExecutionFlow executionFlowPreDate(int flowId, Date date); ExecutionFlow executionFlowPreDate2(int flowId, Date date); ExecutionFlow executionFlowByStartTimeAndScheduleTime(int flowId, Date startTIme,
      Date scheduleTime); }
FlowDao extends BaseDao { public ProjectFlow projectFlowfindByName(int projectId, String name) { ProjectFlow projectFlow = projectFlowMapper.findByName(projectId, name); if (projectFlow != null) { List<FlowNode> flowNodeList = flowNodeMapper.selectByFlowId(projectFlow.getId()); projectFlow.setFlowsNodes(flowNodeList); } return projectFlow; }  ExecutionFlow queryExecutionFlow(int execId); int deleteExecutionNodes(int execId); List<ExecutionFlow> queryAllNoFinishFlow(); List<ExecutionFlow> queryNoFinishFlow(String worker); ExecutionFlow queryExecutionFlowByScheduleTime(int flowId, Date scheduleTime); boolean updateExecutionFlowStatus(int execId, FlowStatus status); boolean updateExecutionFlowStatus(int execId, FlowStatus status, String worker); boolean updateExecutionFlow(ExecutionFlow executionFlow); boolean updateExecutionFlowDataSub(ExecutionFlow executionFlow); ExecutionFlow scheduleFlowToExecution(Integer projectId,
      Integer workflowId,
      int submitUser,
      Date scheduleTime,
      ExecType runType,
      FailurePolicyType failurePolicyType,
      Integer maxTryTimes,
      String nodeName,
      NodeDepType nodeDep,
      NotifyType notifyType,
      List<String> mails,
      int timeout); @Transactional(value = "TransactionManager") void deleteWorkflow(int workflowId); void insertExecutionNode(ExecutionNode executionNode); void updateExecutionNode(ExecutionNode executionNode); ExecutionNode queryExecutionNode(long execId, String nodeName); Schedule querySchedule(int flowId); ProjectFlow projectFlowfindByName(int projectId, String name); ProjectFlow projectFlowFindById(int id); @Transactional(value = "TransactionManager", rollbackFor = Exception.class) void createProjectFlow(ProjectFlow projectFlow); @Transactional(value = "TransactionManager", rollbackFor = Exception.class) void modifyProjectFlow(ProjectFlow projectFlow); ProjectFlow projectFlowFindByPorjectNameAndName(String projectName, String name); List<ProjectFlow> projectFlowFindByProject(int projectId); ExecutionFlow executionFlowPreDate(int flowId, Date date); ExecutionFlow executionFlowPreDate2(int flowId, Date date); ExecutionFlow executionFlowByStartTimeAndScheduleTime(int flowId, Date startTIme,
      Date scheduleTime);  }