| | |
|---|
| | | import com.aizuda.snailjob.client.job.core.dto.JobArgs; |
|---|
| | | import com.aizuda.snailjob.client.model.ExecuteResult; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|---|
| | | import lombok.RequiredArgsConstructor; |
|---|
| | | import lombok.SneakyThrows; |
|---|
| | |
|---|
| | | @SneakyThrows |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public ExecuteResult jobExecute(JobArgs jobArgs) { |
|---|
| | | // 获取今天日期 |
|---|
| | | |
|---|
| | | Date today = new Date(); |
|---|
| | | LambdaQueryWrapper<EimsInspectPlan> planBoQueryWrapper = Wrappers.lambdaQuery(); |
|---|
| | | QueryWrapper<EimsInspectPlan> planBoQueryWrapper = Wrappers.query(); |
|---|
| | | // 查询启用的点检计划 |
|---|
| | | planBoQueryWrapper.eq(EimsInspectPlan::getStatus, DictConstants.SYS_NORMAL_DISABLE_DETAIL.NORMAL); |
|---|
| | | planBoQueryWrapper.eq("ip.status", DictConstants.SYS_NORMAL_DISABLE_DETAIL.NORMAL) |
|---|
| | | .eq("equ.status", DictConstants.EIMS_EQU_STATUS_DETAIL.SHIYONG); |
|---|
| | | // 增加过滤条件 上次生成日期小于当前日期 |
|---|
| | | planBoQueryWrapper.and(wrapper -> wrapper.le("ip.insp_next_time", DateUtils.getDate()).or().isNull("ip.insp_next_time")); |
|---|
| | | // // 过滤没有下次运行时间 |
|---|
| | | // planBoQueryWrapper.isNotNull(EimsInspectPlan::getInspNextTime); |
|---|
| | | // // 过滤没有点检周期的数据 |
|---|
| | | // planBoQueryWrapper.isNotNull(EimsInspectPlan::getInspCycle); |
|---|
| | | // planBoQueryWrapper.isNotNull(EimsInspectPlan::getInspCycleUnit); |
|---|
| | | |
|---|
| | | List<EimsInspectPlanVo> planVoList = planMapper.selectVoList(planBoQueryWrapper); |
|---|
| | | List<EimsInspectPlanVo> planVoList = planMapper.selectVoListJoinEqu(planBoQueryWrapper); |
|---|
| | | for (int i = 0; i < planVoList.size(); i++) { |
|---|
| | | EimsInspectPlanVo planVo = planVoList.get(i); |
|---|
| | | // // 点检计划add的时候会自动生成下次运行时间 |
|---|
