zhang
2 天以前 bd956ec24c5995e6a2a585d6a4987c6b7de372c1
zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/SegmentServiceImpl.java
@@ -4,6 +4,7 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zy.acs.framework.common.Cools;
import com.zy.acs.framework.exception.CoolException;
import com.zy.acs.manager.common.constant.Constants;
import com.zy.acs.manager.manager.entity.Segment;
import com.zy.acs.manager.manager.entity.Task;
import com.zy.acs.manager.manager.enums.ActionStsType;
@@ -59,10 +60,17 @@
    @Override
    public Segment getNextStepOfInit(Long travelId, Integer serial) {
//        return this.getOne(new LambdaQueryWrapper<Segment>()
//                .eq(Segment::getTravelId, travelId)
//                .eq(Segment::getSerial, serial + 1)
//                .eq(Segment::getState, SegmentStateType.INIT.toString())
//        );
        // 不是固定查询一个,而是查询一个片段,因为存在人为完结任务导致查不到下一个+1的片段
        return this.getOne(new LambdaQueryWrapper<Segment>()
                .eq(Segment::getTravelId, travelId)
                .eq(Segment::getSerial, serial + 1)
                .eq(Segment::getState, SegmentStateType.INIT.toString())
                .orderByDesc(Segment::getSerial)
                .last(Constants.LIMIT_ONE)
        );
    }
@@ -73,7 +81,7 @@
                .eq(Segment::getSerial, serial - 1)
                .eq(Segment::getState, SegmentStateType.FINISH.toString())
                .orderByDesc(Segment::getId)
                .last("limit 1")
                .last(Constants.LIMIT_ONE)
        );
    }