package tech.powerjob.server.persistence.remote.repository;
|
|
import org.springframework.data.jpa.repository.JpaRepository;
|
import org.springframework.data.jpa.repository.Modifying;
|
import org.springframework.data.jpa.repository.Query;
|
import tech.powerjob.server.persistence.remote.model.WorkflowNodeInfoDO;
|
|
import javax.transaction.Transactional;
|
import java.util.Date;
|
import java.util.List;
|
|
|
/**
|
* WorkflowNodeInfo 数据访问层
|
*
|
* @author Echo009
|
* @since 2021/2/1
|
*/
|
public interface WorkflowNodeInfoRepository extends JpaRepository<WorkflowNodeInfoDO, Long> {
|
|
/**
|
* 根据工作流id查找所有的节点
|
*
|
* @param workflowId 工作流id
|
* @return 节点信息集合
|
*/
|
List<WorkflowNodeInfoDO> findByWorkflowId(Long workflowId);
|
|
/**
|
* 根据工作流节点 ID 删除节点
|
*
|
* @param workflowId 工作流ID
|
* @param id 节点 ID
|
* @return 删除记录数
|
*/
|
int deleteByWorkflowIdAndIdNotIn(Long workflowId, List<Long> id);
|
|
/**
|
* 删除工作流 ID 为空，且创建时间早于指定时间的节点信息
|
*
|
* @param crtTimeThreshold 创建时间阈值
|
* @return 删除记录条数
|
*/
|
@Modifying
|
@Transactional(rollbackOn = Exception.class)
|
@Query(value = "delete from WorkflowNodeInfoDO where workflowId is null and gmtCreate < ?1")
|
int deleteAllByWorkflowIdIsNullAndGmtCreateBefore(Date crtTimeThreshold);
|
|
}
|
