fix: [Bug] v1 系统管理 -> 任务列表加载不出来 #12323
This commit is contained in:
parent
429ceec506
commit
5f94092005
@ -21,4 +21,6 @@ public class DatasetTaskGridRequest extends KeywordRequest {
|
||||
private String id;
|
||||
|
||||
private Long userId;
|
||||
|
||||
private String datasetId;
|
||||
}
|
||||
|
||||
@ -23,6 +23,8 @@ public interface ExtDataSetTaskMapper {
|
||||
|
||||
List<DataSetTaskDTO> userTaskList(DatasetTaskGridRequest request);
|
||||
|
||||
String datasetPrivileges(DatasetTaskGridRequest request);
|
||||
|
||||
List<DataSetTaskDTO> taskWithTriggers(DatasetTaskGridRequest request);
|
||||
|
||||
List<DataSetTaskDTO> findByPanelId(@Param("panelId") String panelId);
|
||||
|
||||
@ -136,9 +136,12 @@
|
||||
|
||||
</select>
|
||||
|
||||
<select id="datasetPrivileges" resultType="String" parameterType="io.dataease.controller.dataset.request.DatasetTaskGridRequest">
|
||||
SELECT get_auths(#{datasetId}, 'dataset', #{userId})
|
||||
</select>
|
||||
|
||||
<select id="userTaskList" resultMap="TaskResult" parameterType="io.dataease.controller.dataset.request.DatasetTaskGridRequest">
|
||||
SELECT dataset_table.name as table_name, get_auths(dataset_table_task.table_id,'dataset', #{userId}) as
|
||||
`privileges`,dataset_table_task.* , qrtz_triggers.NEXT_FIRE_TIME
|
||||
SELECT dataset_table.name as table_name,dataset_table_task.* , qrtz_triggers.NEXT_FIRE_TIME
|
||||
FROM dataset_table_task
|
||||
left join dataset_table on dataset_table.id=dataset_table_task.table_id
|
||||
left join qrtz_triggers on dataset_table_task.id=qrtz_triggers.TRIGGER_NAME and qrtz_triggers.TRIGGER_STATE != 'PAUSED'
|
||||
|
||||
@ -271,7 +271,12 @@ public class DataSetTableTaskService {
|
||||
return extDataSetTaskMapper.taskList(request);
|
||||
} else {
|
||||
request.setUserId(AuthUtils.getUser().getUserId());
|
||||
return extDataSetTaskMapper.userTaskList(request);
|
||||
List<DataSetTaskDTO> dataSetTaskDTOS = extDataSetTaskMapper.userTaskList(request);
|
||||
dataSetTaskDTOS.forEach(dataSetTaskDTO -> {
|
||||
request.setDatasetId(dataSetTaskDTO.getId());
|
||||
dataSetTaskDTO.setPrivileges(extDataSetTaskMapper.datasetPrivileges(request));
|
||||
});
|
||||
return dataSetTaskDTOS;
|
||||
}
|
||||
}
|
||||
|
||||
@ -312,10 +317,10 @@ public class DataSetTableTaskService {
|
||||
record.setStatus(datasetTableTask.getStatus());
|
||||
datasetTableTaskMapper.updateByExampleSelective(record, datasetTableTaskExample);
|
||||
|
||||
if(datasetTableTask.getStatus().equalsIgnoreCase(TaskStatus.Pending.name())){
|
||||
if (datasetTableTask.getStatus().equalsIgnoreCase(TaskStatus.Pending.name())) {
|
||||
scheduleService.pauseTrigger(datasetTableTask);
|
||||
}
|
||||
if(datasetTableTask.getStatus().equalsIgnoreCase(TaskStatus.Underway.name())){
|
||||
if (datasetTableTask.getStatus().equalsIgnoreCase(TaskStatus.Underway.name())) {
|
||||
scheduleService.resumeTrigger(datasetTableTask);
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user