| | |
| | | ); |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywPatrolSchemeList)){ |
| | | for (YwPatrolScheme ywPatrolScheme:ywPatrolSchemeList) { |
| | | this.createTask(new Date(),ywPatrolScheme); |
| | | this.createTask(DateUtil.getXDayAfterDate(new Date(),2),ywPatrolScheme); |
| | | } |
| | | } |
| | | } |
| | |
| | | ywPatrolScheme.setEditDate(new Date()); |
| | | ywPatrolScheme.setEditor(loginUserInfo.getId()); |
| | | ywPatrolSchemeMapper.updateById(ywPatrolScheme); |
| | | this.createThreeDaysData(ywPatrolScheme); |
| | | } |
| | | |
| | | @Override |
| | |
| | | YwPatrolScheme model = pageWrap.getModel(); |
| | | queryWrapper.selectAll(YwPatrolScheme.class) |
| | | .select(" t2.realName as createUserName ") |
| | | // .select(" t1.realName as userName ") |
| | | // .leftJoin(SystemUser.class,SystemUser::getId,YwPatrolScheme::getUserIds) |
| | | .leftJoin(" system_user t2 on t.creator = t2.id ") |
| | | .eq(YwPatrolScheme::getIsdeleted,Constants.ZERO) |
| | | .like(StringUtils.isNotBlank(model.getTitle()),YwPatrolScheme::getTitle,model.getTitle()) |
| | | //查询有时段交集的数据 |
| | | /* .apply(Objects.nonNull(model.getStartDate())&&Objects.nonNull(model.getEndDate()), |
| | | " t.START_DATE <= '"+pageWrap.getModel().getEndDate()+"' or t.END_DATE >= '"+pageWrap.getModel().getStartDate()+"' " |
| | | )*/ |
| | | .ge( model.getStartDate()!=null,YwPatrolScheme::getStartDate, Utils.Date.getStart(pageWrap.getModel().getStartDate())) |
| | | .le(Objects.nonNull(model.getEndDate()),YwPatrolScheme::getStartDate, Utils.Date.getStart(pageWrap.getModel().getEndDate())) |
| | | .ge(Objects.nonNull(model.getStartDateSec()),YwPatrolScheme::getEndDate, Utils.Date.getStart(pageWrap.getModel().getStartDateSec())) |
| | |
| | | ywPatrolScheme.setTimeOutTaskNum(Constants.ZERO); |
| | | return; |
| | | } |
| | | |
| | | //过滤数据是不是全部未开始 |
| | | if(Constants.equalsInteger(ywPatrolTaskList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ZERO)) |
| | | .collect(Collectors.toList()).size(),ywPatrolTaskList.size())){ |
| | | ywPatrolScheme.setSchemeStatus(Constants.ZERO); |
| | | ywPatrolScheme.setTimeOutTaskNum(ywPatrolTaskList.stream().filter(i->i.getEndDate().getTime()>System.currentTimeMillis()) |
| | | .collect(Collectors.toList()).size()); |
| | | return; |
| | | } |
| | | |
| | | //过滤数据是否存在进行中的 |
| | | if(ywPatrolTaskList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ONE)).collect(Collectors.toList()).size()>Constants.ZERO){ |
| | | if(ywPatrolTaskList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ONE)||Constants.equalsInteger(i.getStatus(),Constants.ZERO)).collect(Collectors.toList()).size()>Constants.ZERO){ |
| | | ywPatrolScheme.setSchemeStatus(Constants.ONE); |
| | | ywPatrolScheme.setTimeOutTaskNum(ywPatrolTaskList.stream().filter(i->i.getEndDate().getTime()>System.currentTimeMillis()) |
| | | .collect(Collectors.toList()).size()); |
| | | return; |
| | | } |
| | | |
| | | //过滤数据是不是全部未开始 |
| | | if(Constants.equalsInteger(ywPatrolTaskList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.ZERO)).collect(Collectors.toList()).size(),ywPatrolTaskList.size())){ |
| | | ywPatrolScheme.setSchemeStatus(Constants.ZERO); |
| | | ywPatrolScheme.setTimeOutTaskNum(ywPatrolTaskList.stream().filter(i->i.getEndDate().getTime()>System.currentTimeMillis()) |
| | | .collect(Collectors.toList()).size()); |
| | | return; |
| | | } |
| | | //过滤数据是不是全部已完成 |
| | | if(Constants.equalsInteger(ywPatrolTaskList.stream().filter(i->Constants.equalsInteger(i.getStatus(),Constants.THREE)).collect(Collectors.toList()).size() |
| | | ,ywPatrolTaskList.size())){ |