fix: Handle null values for end_time filters

Author: itinycheng

flink-platform-web/src/main/java/com/flink/platform/web/controller/DashboardController.java

@@ -45,7 +45,9 @@ public ResultInfo<List<Map<String, Object>>> jobRunStatusCount(
         List<Map<String, Object>> maps = jobRunService.listMaps(new QueryWrapper<JobRunInfo>()
                 .select("status, count(id) as count")
                 .groupBy("status")
-                .between(nonNull(startTime) && nonNull(endTime), "stop_time", startTime, endTime)
+                .nested(
+                        nonNull(startTime) && nonNull(endTime),
+                        qw -> qw.isNull("stop_time").or().between("stop_time", startTime, endTime))
                 .eq("user_id", loginUser.getId()));
         return success(maps);
     }
@@ -60,7 +62,9 @@ public ResultInfo<List<Map<String, Object>>> jobFlowRunStatusCount(
         List<Map<String, Object>> maps = jobFlowRunService.listMaps(new QueryWrapper<JobFlowRun>()
                 .select("status, count(id) as count")
                 .groupBy("status")
-                .between(nonNull(startTime) && nonNull(endTime), "end_time", startTime, endTime)
+                .nested(
+                        nonNull(startTime) && nonNull(endTime),
+                        qw -> qw.isNull("end_time").or().between("end_time", startTime, endTime))
                 .eq("user_id", loginUser.getId()));
         return success(maps);
     }

flink-platform-web/src/main/java/com/flink/platform/web/controller/JobFlowRunController.java

@@ -94,7 +94,9 @@ public ResultInfo<IPage<JobFlowRun>> page(
                 .eq(nonNull(status), JobFlowRun::getStatus, status)
                 .likeRight(isNotEmpty(name), JobFlowRun::getName, name)
                 .like(isNotEmpty(tagCode), JobFlowRun::getTags, tagCode)
-                .between(nonNull(startTime) && nonNull(endTime), JobFlowRun::getEndTime, startTime, endTime);
+                .nested(nonNull(startTime) && nonNull(endTime), qw -> qw.isNull(JobFlowRun::getEndTime)
+                        .or()
+                        .between(JobFlowRun::getEndTime, startTime, endTime));
         if ("-id".equals(sort)) {
             queryWrapper.orderByDesc(JobFlowRun::getId);
         }

flink-platform-web/src/main/java/com/flink/platform/web/controller/JobRunController.java

@@ -83,7 +83,10 @@ public ResultInfo<IPage<JobRunInfo>> page(
                 .eq(nonNull(jobId), JobRunInfo::getJobId, jobId)
                 .eq(nonNull(status), JobRunInfo::getStatus, status)
                 .likeRight(nonNull(name), JobRunInfo::getName, name)
-                .between(nonNull(startTime) && nonNull(endTime), JobRunInfo::getEndTime, startTime, endTime);
+                .nested(nonNull(startTime) && nonNull(endTime), qw -> qw.isNull(JobRunInfo::getEndTime)
+                        .or()
+                        .between(JobRunInfo::getEndTime, startTime, endTime));
+
         if ("-id".equals(sort)) {
             queryWrapper.orderByDesc(JobRunInfo::getId);
         }