#

luxiaotao1123

2024-11-21 ef04d6657d2190cb02c821140a2036e7c6760b45

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

@@ -3,8 +3,10 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zy.acs.framework.common.Cools;
import com.zy.acs.manager.manager.entity.Agv;
import com.zy.acs.manager.manager.entity.Code;
import com.zy.acs.manager.manager.entity.Jam;
import com.zy.acs.manager.manager.entity.Segment;
import com.zy.acs.manager.manager.enums.JamStateType;
import com.zy.acs.manager.manager.mapper.JamMapper;
import com.zy.acs.manager.manager.service.AgvService;
@@ -40,6 +42,15 @@
        return null;
    }

    /**
     * 因为你而阻塞的车,现在你已经在避让点了
     * 你的下一个segment是不是又会导致阻塞
     */
    @Override
    public List<Jam> getUnfinishedOriginJamByAvo(Long avoAgv, Long currCode, Long currSeg) {
        return this.baseMapper.selectUnfinishedJamByAvo(avoAgv, currCode, null);
    }

    @Override
    public Jam getCycleJam(Long jamAgv, Long jamSeg, String avoAgvNo) {
        List<Jam> jams = this.list(new LambdaQueryWrapper<Jam>()
@@ -56,6 +67,18 @@
    }

    @Override
    public List<Jam> getJamFromSegmentByAvo(Segment jamSeg, String avoAgvNo) {
        Agv avoAgv = agvService.selectByUuid(avoAgvNo);
        return this.baseMapper.selectJamFromSegmentByAvo(jamSeg.getId(), avoAgv.getId());
    }

    @Override
    public List<Jam> getUnfinishedAvoSegByAvo(String avoAgvNo, Segment currSeg) {
        Agv avoAgv = agvService.selectByUuid(avoAgvNo);
        return this.baseMapper.selectUnfinishedAvoSegByAvo(avoAgv.getId(), null);
    }

    @Override
    public List<Jam> queryByAvoid(Long avoAgv, JamStateType jamState) {
        if (null == avoAgv) {
            return null;