|
|
@@ -114,7 +114,7 @@ public class EarlyWarningInstanceNotStartTask { |
|
|
|
.eq(Project::getAreaCode, areaCode) |
|
|
|
.eq(Project::getNewest, Boolean.TRUE) |
|
|
|
.eq(Project::getStatus,projectStutas)); |
|
|
|
log.info("needNextProjects :{}",needNextProjects.size()); |
|
|
|
|
|
|
|
//需要发通知的项目 |
|
|
|
List<Project> needToWaringProjects = needNextProjects.stream() |
|
|
|
.filter(p -> { |
|
|
@@ -130,9 +130,6 @@ public class EarlyWarningInstanceNotStartTask { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
log.info("projectId :{}",p.getId()); |
|
|
|
log.info("秒数差 :{}",Duration.between(p.getUpdateOn(),LocalDateTime.now()).getSeconds()); |
|
|
|
|
|
|
|
if(Duration.between(p.getUpdateOn(),LocalDateTime.now()).toMinutes() >= time * 60 && //time * 60 |
|
|
|
Duration.between(p.getUpdateOn(),LocalDateTime.now()).toMinutes() <= time * 60 + 1){ //time * 60 |
|
|
|
return Boolean.TRUE; |
|
|
@@ -221,7 +218,7 @@ public class EarlyWarningInstanceNotStartTask { |
|
|
|
.eq(Project::getAreaCode, areaCode) |
|
|
|
.eq(Project::getNewest, Boolean.TRUE) |
|
|
|
.eq(Project::getStatus,projectStutas)); |
|
|
|
log.info("needNextProjects :{}",needNextProjects.size()); |
|
|
|
|
|
|
|
List<String> projectCodes = needNextProjects.stream().map(Project::getProjectCode).collect(Collectors.toList()); |
|
|
|
|
|
|
|
List<Operation> operations = operationService.list(Wrappers.lambdaQuery(Operation.class) |
|
|
|