优化订单同步逻辑及库位查找

zhangc

2024-12-25 ab14726215678ac69adfeafbd845ebc5b0776ea2

 src/main/java/com/zy/asrs/service/impl/AgvWaitPakinServiceImpl.java

@@ -1,12 +1,44 @@
package com.zy.asrs.service.impl;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import com.zy.asrs.entity.AgvWaitPakin;
import com.zy.asrs.entity.AgvWrkMast;
import com.zy.asrs.mapper.AgvWaitPakinMapper;
import com.zy.asrs.service.AgvWaitPakinService;
import com.zy.asrs.service.AgvWrkMastService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class AgvWaitPakinServiceImpl extends ServiceImpl<AgvWaitPakinMapper, AgvWaitPakin> implements AgvWaitPakinService {

    @Autowired
    AgvWrkMastService agvWrkMastService;

    public void updateIoStatus(int wrkNo, String ioStatus) {
        AgvWrkMast agvWrkMast = agvWrkMastService.selectById(wrkNo);
        List<AgvWaitPakin> agvWaitPakinList = this.selectList(new EntityWrapper<AgvWaitPakin>().eq("zpallet", agvWrkMast.getBarcode()));
        agvWaitPakinList.stream().forEach(agvWaitPakin -> {
            agvWaitPakin.setIoStatus("Y");
            this.update(agvWaitPakin,new EntityWrapper<AgvWaitPakin>().eq("supp_code",agvWaitPakin.getZpallet()));
        });
    }

    @Override
    public void updateIoStatus(String containerCode, String ioStatus) {
        this.baseMapper.updateIoStatus(containerCode,ioStatus);
    }

    @Override
    public List<AgvWaitPakin> selectByContainerCode(String containerCode) {
        return this.selectList(new EntityWrapper<AgvWaitPakin>().eq("supp_code",containerCode).eq("io_status","N"));
    }

    @Override
    public List<AgvWaitPakin> selectByContainerCode2(String containerCode) {
        return this.selectList(new EntityWrapper<AgvWaitPakin>().eq("supp_code",containerCode));
    }
}