订单追溯完善

pjb

6 天以前 e50218d4ba057a4a33af708ad13b8ef77c41e91c

 src/main/java/com/zy/common/web/WcsController.java

@@ -10,6 +10,7 @@
import com.zy.asrs.entity.param.EmptyPlateOutParam;
import com.zy.asrs.entity.param.StockOutParam;
import com.zy.asrs.entity.result.FindLocNoAttributeVo;
import com.zy.asrs.mapper.BasCrnpMapper;
import com.zy.asrs.mapper.LocMastMapper;
import com.zy.asrs.mapper.WrkMastMapper;
import com.zy.asrs.service.*;
@@ -28,6 +29,7 @@

import javax.annotation.Resource;
import java.util.*;
import java.util.stream.Collectors;

/**
 * Created by vincent on 2020/10/30
@@ -67,6 +69,18 @@

    @Resource
    private WrkMastMapper wrkMastMapper;

    @Resource
    private BasCrnpMapper basCrnpMapper;

    public static final Map<Integer,ArrayList<Integer>> crnOutSite;

    static {
        crnOutSite = new HashMap<>();
        crnOutSite.put(1,new ArrayList<Integer>(){{add(1091);add(1092);add(1093);}});
        crnOutSite.put(2,new ArrayList<Integer>(){{add(1097);add(1098);add(1099);}});
        crnOutSite.put(3,new ArrayList<Integer>(){{add(1105);add(1106);add(1107);}});
    }

    @PostMapping("/pakin/loc/v1")
    @ResponseBody
@@ -698,14 +712,43 @@
        // 出库站点
        Integer site = Integer.valueOf(emptyPalletSite.get("site"));

        LocMast locMast;
        LocMast locMast = null;

        // 先找浅库位
        locMast = locMastMapper.queryLocMasterByLocStsAndRow(Arrays.asList(2, 3), type);
        List<BasCrnp> basCrnps = basCrnpMapper.selectList(new EntityWrapper<BasCrnp>().eq("crn_sts", 3).eq("crn_err", 0).in("crn_no",1,2,3)
                .eq("out_enable","Y"));
        if (basCrnps.size() == 0) {
            log.error("空拖出库请求库位失败，没有联机堆垛机或堆垛机异常");
            throw new CoolException("空拖出库请求库位失败，没有联机堆垛机或堆垛机异常");
        }

        // 浅库位没有则查询所有
        if (locMast == null) {
            locMast = locMastMapper.queryLocMasterByLocStsAndRow(null, type);
        List<BasCrnp> basCrnpList = new ArrayList<>();
        for(BasCrnp basCrnp: basCrnps) {
            List<BasDevp> devps = basDevpService.selectList(new EntityWrapper<BasDevp>().in("dev_no", crnOutSite.get(basCrnp.getCrnNo())).ne("wrk_no", 0));
            long count = devps.stream().map(BasDevp::getWrkNo).distinct().count();
            basCrnp.setWrkNo(count + basCrnp.getWrkNo() >= 5001 && basCrnp.getWrkNo() <= 9000 ? 1 : 0);
            basCrnpList.add(basCrnp);
        }

        basCrnpList = basCrnpList.stream().sorted(Comparator.comparing(BasCrnp::getWrkNo).thenComparing(BasCrnp::getCrnNo,Comparator.reverseOrder())).collect(Collectors.toList());

        for(BasCrnp basCrnp:basCrnpList) {
            Integer crnNo = basCrnp.getCrnNo();
            Wrapper<LocMast> wrapper = new EntityWrapper<LocMast>().eq("loc_sts", type)
                    .eq("crn_no", crnNo).orderBy("lev1").orderBy("bay1").orderBy("row1");
            if (crnNo == 1) {
                wrapper.in("row1", 1, 4);
            }
            locMast = locMastService.selectOne(wrapper);
            if (locMast != null) {
                break;
            }
            // 深库位没有了则获取一个浅库位
            if (crnNo == 1) {
                locMast = locMastService.selectOne(wrapper.in("row1", 2, 3));
                if (locMast != null) {
                    break;
                }
            }
        }

        if (locMast == null) {