#

luxiaotao1123

2024-11-06 337746fee651f91e9c63bd1c33a474c236d51889

 zy-acs-manager/src/main/java/com/zy/acs/manager/manager/service/impl/SegmentServiceImpl.java

@@ -8,10 +8,13 @@
import com.zy.acs.manager.manager.service.AgvService;
import com.zy.acs.manager.manager.service.SegmentService;
import com.zy.acs.framework.common.Cools;
import com.zy.acs.manager.manager.service.TravelService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Comparator;
import java.util.Date;
import java.util.List;

@Slf4j
@@ -20,6 +23,30 @@

    @Autowired
    private AgvService agvService;
    @Autowired
    private TravelService travelService;

    @Override
    public void processNext(List<Segment> segmentList) {
        Date now = new Date();

        segmentList.stream().max(Comparator.comparingInt(Segment::getSerial)).ifPresent(segment -> {
            Segment nextSegment = this.getNextStepOfInit(segment.getTravelId(), segment.getSerial());

            if (null != nextSegment) {

                nextSegment.setState(SegmentStateType.WAITING.toString());
                nextSegment.setUpdateTime(now);
                if (!this.updateById(nextSegment)) {
                    log.error("Segment [{}] failed to update ！！！", nextSegment.getGroupId() + " - " + nextSegment.getSerial());
                }

            } else {

                travelService.checkFinish(segment.getTravelId());
            }
        });
    }

    @Override
    public Segment getNextStepOfInit(Long travelId, Integer serial) {