Generating...

zhangc

2024-12-12 5dc8a9f9aba3310fd21cad9509635bb7ec2f007f

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

@@ -37,38 +37,58 @@

    public void initBasDevp(){

        //初始化1楼缓存货架站点 2排5列3层
        this.insertBatch(getCacheBasDevpList(1,2,1,5,1,3,1));
        //初始化3楼缓存货架站点 3排5列3层
        this.insertBatch(getCacheBasDevpList(5,9,1,5,1,3,3));
        //初始化3楼输送线工作站点 4个站点
        this.insertBatch(getLineBasDevpList());
//        //初始化1楼缓存货架站点 2排5列3层
//        this.insertBatch(getCacheBasDevpList(1,2,1,5,1,3,1));
//        //初始化3楼缓存货架站点 3排5列3层
//        this.insertBatch(getCacheBasDevpList(5,9,1,5,1,3,3));
//        //初始化3楼输送线工作站点 4个站点
//        this.insertBatch(getLineBasDevpList());

        //待包装成品存储区入库接驳位
        this.insertBatch(getConnectionBasDevpList("DI",12,2,true,(short)1));
        //待包装成品存储区出库接驳位
        this.insertBatch(getConnectionBasDevpList("DO",8,2,false,(short)1));
        //原材料入库接驳位
        this.insertBatch(getConnectionBasDevpList("YI",14,2,true,(short)2));
        //原材料出库接驳位
        this.insertBatch(getConnectionBasDevpList("YO",18,2,false,(short)2));
        //箱壳入库接驳位
        this.insertBatch(getConnectionBasDevpList("XI",5,2,true,(short)3));
        //箱壳出库接驳位
        this.insertBatch(getConnectionBasDevpList("XO",12,2,false,(short)3));
    }

    private List<AgvBasDevp> getLineBasDevpList(){
//    private List<AgvBasDevp> getLineBasDevpList(){
//        List<AgvBasDevp> agvBasDevpList = new ArrayList<>();
//        Date now = new Date();
//        for(int row=1; row<=4; row++){
//            agvBasDevpList.add(getAgvBasDevp(row,1,1,3,"N",now));
//        }
//        return agvBasDevpList;
//    }

    private List<AgvBasDevp> getConnectionBasDevpList(String type, int num, int floor, boolean inEnable, Short locType){
        List<AgvBasDevp> agvBasDevpList = new ArrayList<>();
        Date now = new Date();
        for(int row=1; row<=4; row++){
            agvBasDevpList.add(getAgvBasDevp(row,1,1,3,"N",now));
        for(int index=1; index<=num; index++){
            agvBasDevpList.add(getAgvBasDevp(type,index,floor,inEnable,locType,now));
        }
        return agvBasDevpList;
    }

    //根据排列层获取AGV缓存货架站点列表
    private List<AgvBasDevp> getCacheBasDevpList(int rowIndex, int rowMax, int bayIndex, int bayMax, int levIndex, int levMax, int floor){
        List<AgvBasDevp> agvBasDevpList = new ArrayList<>();
        Date now = new Date();
        for(int row=rowIndex; row<=rowMax; row++){
            for(int bay=bayIndex; bay<=bayMax; bay++){
                for(int lev=levIndex; lev<=levMax; lev++){
                    agvBasDevpList.add(getAgvBasDevp(row,bay,lev,floor,"Y",now));
                }
            }
        }

        return agvBasDevpList;
    }
//    //根据排列层获取AGV缓存货架站点列表
//    private List<AgvBasDevp> getCacheBasDevpList(int rowIndex, int rowMax, int bayIndex, int bayMax, int levIndex, int levMax, int floor){
//        List<AgvBasDevp> agvBasDevpList = new ArrayList<>();
//        Date now = new Date();
//        for(int row=rowIndex; row<=rowMax; row++){
//            for(int bay=bayIndex; bay<=bayMax; bay++){
//                for(int lev=levIndex; lev<=levMax; lev++){
//                    agvBasDevpList.add(getAgvBasDevp(row,bay,lev,floor,"Y",now));
//                }
//            }
//        }
//        return agvBasDevpList;
//    }

    private AgvBasDevp getAgvBasDevp(int row, int bay, int lev, int floor, String cacheShelves, Date now){
        AgvBasDevp agvBasDevp = new AgvBasDevp();
@@ -84,11 +104,27 @@
        return agvBasDevp;
    }

    public void updateLocStsAndBarcodeByDevNo(String devNo, String locSts, String barcode){
    private AgvBasDevp getAgvBasDevp(String type, int index, int floor, boolean inEnable, Short locType, Date now){
        AgvBasDevp agvBasDevp = new AgvBasDevp();
        String no = index >= 10 ? index + "" : "0" + index;
        String devNo = type + "_" + no + "F" + floor;
        agvBasDevp.setDevNo(devNo);
        agvBasDevp.setLocSts("O");
        agvBasDevp.setInEnable(inEnable ? "Y" : "N");
        agvBasDevp.setOutEnable(inEnable ? "N" : "Y");
        agvBasDevp.setFloor(floor);
        agvBasDevp.setLocType1(locType);
        agvBasDevp.setModiTime(now);
        agvBasDevp.setAppeTime(now);
        return agvBasDevp;
    }

    public void updateLocStsAndBarcodeByDevNo(String devNo, String locSts, String barcode, Short containerType){

        AgvBasDevp agvBasDevp = this.selectById(devNo);
        agvBasDevp.setLocSts(locSts);
        agvBasDevp.setBarcode(barcode);
        agvBasDevp.setLocType2(containerType);
        this.updateById(agvBasDevp);
    }

@@ -100,8 +136,11 @@
                    .eq("station_code", stationCode)
                    .like("dev_no", "0" + i + "@");

            if("CS-305".equals(stationCode) || "CS-306".equals(stationCode) || "CS-307".equals(stationCode)){
                wrapper.orderBy("dev_no",false);
            List<String> list = this.selectCacheShelvesStationCodeByFloor(3);
            if(list.contains(stationCode)){
                if(Cools.eq(stationCode,"CS-305") || Cools.eq(stationCode,"CS-306") || Cools.eq(stationCode,"CS-307")){
                    wrapper.orderBy("dev_no",false);
                }
            }

            List<AgvBasDevp> agvBasDevpList = this.selectList(wrapper);
@@ -117,33 +156,68 @@
                    return agvBasDevpDto;
                }

                AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>()
                //一个工作位可能会对应多个工作档，显示工作状态最大的工作档
                List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
                        .eq("loc_no", agvBasDevpDto.getDevNo())
                        .or().eq("source_loc_no",agvBasDevpDto.getDevNo()));

                AgvWrkMast agvWrkMast = null;
                for (AgvWrkMast wrkMast : agvWrkMasts){
                    if(Cools.isEmpty(agvWrkMast)){
                        agvWrkMast = wrkMast;
                    }else {
                        if(agvWrkMast.getWrkSts() < wrkMast.getWrkSts()){
                            agvWrkMast = wrkMast;
                        }
                    }
                }

                agvBasDevpDto.setAgvWrkMast(agvWrkMast);

                if("F".equals(agvBasDevpDto.getLocSts()) || "R".equals(agvBasDevpDto.getLocSts())){
                    AgvWaitPakin agvWaitPakin = agvWaitPakinService.selectOne(new EntityWrapper<AgvWaitPakin>()
                    //AgvWaitPakin agvWaitPakin = agvWaitPakinService.selectOne(new EntityWrapper<AgvWaitPakin>().eq("supp_code", agvBasDevpDto.getBarcode()));
                    List<AgvWaitPakin> agvWaitPakinList = agvWaitPakinService.selectList(new EntityWrapper<AgvWaitPakin>()
                            .eq("supp_code", agvBasDevpDto.getBarcode()));

                    agvBasDevpDto.setAgvWaitPakin(agvWaitPakin);
                    //如果有入库通知档，则该工作位为入库作业
                    if(!Cools.isEmpty(agvWaitPakinList)){
                        //用于电视机显示
                        agvBasDevpDto.setAgvWaitPakins(agvWaitPakinList);
                        //用于可视化站点显示
                        agvBasDevpDto.setAgvWaitPakin(agvWaitPakinList.get(0));
                    }

                    if(Cools.isEmpty(agvWaitPakin)){
                        AgvWrkDetl agvWrkDetl = agvWrkDetlService.selectOne(new EntityWrapper<AgvWrkDetl>().
                                eq("wrk_no",agvWrkMast.getWrkNo()));
                    //如果没有入库通知档，则该工作位为出库作业
                    if(Cools.isEmpty(agvWaitPakinList)){
                        List<AgvWrkDetl> agvWrkDetlList = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("wrk_no", agvWrkMast.getWrkNo()));

                        //agv站点可视化管理中的结余数量显示
                        agvWrkDetl.setVolume(0.0);
                        if(agvWrkMast.getIoType() == 103){
                            AgvLocDetl agvLocDetl = agvLocDetlService.selectByLocNo(agvWrkMast.getSourceLocNo());
                            agvWrkDetl.setVolume(agvLocDetl.getAnfme() - agvWrkDetl.getAnfme());
                        for(AgvWrkDetl agvWrkDetl : agvWrkDetlList){
                            agvWrkDetl.setVolume(0.0);
                            if(agvWrkMast.getIoType() == 103){
                                //寻找是否有相同物料的工作档明细，并返回数量之和
                                double anfme = getAllAnfmeInAgvWrkDetlList(agvWrkDetlList,agvWrkDetl);
                                AgvLocDetl agvLocDetl = agvLocDetlService.selectByMatnrAndBatchAndCsocodeAndisoCode(agvWrkMast.getSourceLocNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode(), agvWrkDetl.getDeadTime());
                                //用于结余数量显示
                                agvWrkDetl.setVolume(agvLocDetl.getAnfme() - anfme);
                            }
                            if(agvWrkMast.getIoType() == 53){
                                AgvLocDetl agvLocDetl = agvLocDetlService.selectByMatnrAndBatchAndCsocodeAndisoCode(agvWrkMast.getLocNo(), agvWrkDetl.getMatnr(), agvWrkDetl.getBatch(), agvWrkDetl.getThreeCode(), agvWrkDetl.getDeadTime());
                                if(Cools.isEmpty(agvLocDetl)){
                                    agvWrkDetl.setVolume(0.0);
                                }else {
                                    agvWrkDetl.setVolume(agvLocDetl.getAnfme());
                                }
                            }
                        }
                        if(agvWrkMast.getIoType() == 53){
                            AgvLocDetl agvLocDetl = agvLocDetlService.selectByLocNo(agvWrkMast.getLocNo());
                            agvWrkDetl.setVolume(agvLocDetl.getAnfme());
                            //agvWrkDetl.setAnfme(agvLocDetl.getAnfme() - agvWrkDetl.getAnfme());

                        if(!Cools.isEmpty(agvWrkDetlList)){
                            //用于电视机显示
                            agvBasDevpDto.setAgvWrkDetls(agvWrkDetlList);
                            //用于可视化站点显示
                            agvBasDevpDto.setAgvWrkDetl(agvWrkDetlList.get(0));
                        }
                        agvBasDevpDto.setAgvWrkDetl(agvWrkDetl);

                    }
                }

@@ -165,13 +239,26 @@
        return result;
    }

    private double getAllAnfmeInAgvWrkDetlList(List<AgvWrkDetl> agvWrkDetlList, AgvWrkDetl wd0) {
        double allAnfme = 0;
        for (AgvWrkDetl wd1 : agvWrkDetlList){
            if(Cools.eq(wd0.getMatnr(),wd1.getMatnr())
                    && Cools.eq(wd0.getBatch(),wd1.getBatch())
                    && Cools.eq(wd0.getThreeCode(),wd1.getThreeCode())
                    && Cools.eq(wd0.getDeadTime(),wd1.getDeadTime())){
                allAnfme += wd1.getAnfme();
            }
        }
        return allAnfme;
    }

    private void setFlagForAgvBasDevpDto(AgvWrkMast agvWrkMast, AgvBasDevpDto agvBasDevpDto){
        //当工作档类型为101.出库 并且 工作位状态为F.在库时，显示容器离场按钮
        //当工作档类型为101.出库 并且 工作位状态为F.在库时，显示货架离场按钮
        if(agvWrkMast.getIoType() == 101 && "F".equals(agvBasDevpDto.getLocSts())){
            agvBasDevpDto.setContainerMoveOutFlag(true);
        }

        //当工作档类型为101.出库 并且 工作位状态为F.在库时，显示容器离场按钮
        //当工作档类型为101.出库 并且 工作位状态为F.在库时，显示货架离场按钮
        if(agvWrkMast.getIoType() == 110 && "D".equals(agvBasDevpDto.getLocSts())){
            agvBasDevpDto.setContainerMoveOutFlag(true);
        }
@@ -206,4 +293,33 @@
        return this.selectList(new EntityWrapper<AgvBasDevp>().eq("cache_shelves","N"));
    }

    @Override
    public List<String> selectCacheShelvesStationCodeByFloor(int floor) {
        //Object o = this.selectList(new EntityWrapper<AgvBasDevp>().setSqlSelect("station_code").eq("floor",floor).eq("cache_shelves","Y").groupBy("station_code"));
        return this.baseMapper.selectCacheShelvesStationCodeByFloor(floor);
    }

    @Override
    public List<String> selectCacheShelvesStationCodeByLocType(short locType, int floor) {
        return this.baseMapper.selectCacheShelvesStationCodeByLocType(locType,floor);
    }
    @Override
    public List<String> selectCacheShelvesStationCodeByLocType2(short locType, int floor) {
        return this.baseMapper.selectCacheShelvesStationCodeByLocType2(locType,floor);
    }

    public List<Map<String,Object>> selectDevNoAndNumBystationCode(String stationCode){
        return this.baseMapper.selectDevNoAndNumBystationCode(stationCode);
    }

    @Override
    public List<String> selectAllStationCode() {
        return this.baseMapper.selectAllStationCode();
    }

    @Override
    public AgvBasDevp selectByDevNo(String devNo) {
        return this.selectOne(new EntityWrapper<AgvBasDevp>().eq("dev_no",devNo));
    }

}