[Fix] Fix abnormal data in pg query (DataLinkDC#3768)

Signed-off-by: Zzm0809 <934230207@qq.com> Co-authored-by: Zzm0809 <Zzm0809@users.noreply.github.com>
aiwenmo · Sep 2, 2024 · b5ee335 · b5ee335
1 parent acc53b1
commit b5ee335
Showing 1 changed file with 13 additions and 10 deletions.
diff --git a/dinky-admin/src/main/java/org/dinky/service/impl/TaskServiceImpl.java b/dinky-admin/src/main/java/org/dinky/service/impl/TaskServiceImpl.java
@@ -1041,16 +1041,19 @@ public List<TaskDTO> getUserTasks(Integer userId) {
                 }
             }
         });
-
-        LambdaQueryWrapper<JobInstance> wrapper = new LambdaQueryWrapper<>();
-        wrapper.in(JobInstance::getId, tskMap.keySet());
-        jobInstanceService.getBaseMapper().selectList(wrapper, resultContext -> {
-            JobInstance jobInstance = resultContext.getResultObject();
-            TaskDTO taskDTO = tskMap.get(jobInstance.getId());
-            if (Objects.nonNull(taskDTO)) {
-                taskDTO.setStatus(jobInstance.getStatus());
-            }
-        });
+        // When the postgre data source query in () is empty, a syntax error will be reported, so it is necessary to
+        // judge
+        if (!tskMap.keySet().isEmpty()) {
+            LambdaQueryWrapper<JobInstance> wrapper = new LambdaQueryWrapper<>();
+            wrapper.in(JobInstance::getId, tskMap.keySet());
+            jobInstanceService.getBaseMapper().selectList(wrapper, resultContext -> {
+                JobInstance jobInstance = resultContext.getResultObject();
+                TaskDTO taskDTO = tskMap.get(jobInstance.getId());
+                if (Objects.nonNull(taskDTO)) {
+                    taskDTO.setStatus(jobInstance.getStatus());
+                }
+            });
+        }
 
         List<TaskDTO> tasks = new ArrayList<>(tskMap.values());
         // 按照step排序，发布>开发>,相同情况 下按照状态排序