自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
pang.jiabao
2024-08-12 1b7c03baf021e4896b296e2c0af277c4c57656e8 
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java


@@ -2,6 +2,7 @@




import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.baomidou.mybatisplus.mapper.Wrapper;


import com.core.common.Cools;


import com.core.common.DateUtils;


import com.core.common.R;


@@ -11,6 +12,8 @@


import com.zy.asrs.entity.param.*;


import com.zy.asrs.entity.result.OpenOrderCompeteResult;


import com.zy.asrs.entity.result.StockVo;


import com.zy.asrs.entity.result.ZphjcdgzVo;


import com.zy.asrs.entity.result.ZphjcdwcVo;


import com.zy.asrs.mapper.TagMapper;


import com.zy.asrs.service.*;


import com.zy.asrs.utils.MatUtils;


@@ -28,6 +31,7 @@


import org.springframework.transaction.annotation.Transactional;




import java.util.*;


import java.util.stream.Collectors;




/**


 * Created by vincent on 2022/4/9


@@ -69,6 +73,8 @@


    @Autowired


    private WrkDetlSingleService wrkDetlSingleService;


    @Autowired


    private WrkMastLogService wrkMastLogService;


    @Autowired


    private WrkMastStaService wrkMastStaService;


    @Autowired


    private WrkMastStaLogService wrkMastStaLogService;


@@ -76,6 +82,8 @@


    private StaDescService staDescService;


    @Autowired


    private LocMastService locMastService;


    @Autowired


    private ApiLogService apiLogService;




    @Override


    @Transactional


@@ -984,25 +992,30 @@


        if (Cools.isEmpty(param)) {


            throw new CoolException("请求参数有误：" + param);


        }


        int zpalletCount = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet", param.getBarcode()));


        if (zpalletCount > 0) {


            throw new CoolException("库存托盘码已存在：" + param.getBarcode());


        }


        if (!Cools.isEmpty(param.getBarcode())) {


            int zpalletCount = locDetlService.selectCount(new EntityWrapper<LocDetl>().eq("zpallet", param.getBarcode()));


            if (zpalletCount > 0) {


                throw new CoolException("库存托盘码已存在：" + param.getBarcode());


            }




        int barcodeCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("barcode", param.getBarcode()));


        if (barcodeCount > 0) {


            throw new CoolException("工作档已存在该托盘码：" + param.getBarcode());


            int barcodeCount = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("barcode", param.getBarcode()));


            if (barcodeCount > 0) {


                throw new CoolException("工作档已存在该托盘码：" + param.getBarcode());


            }


        }




        LocTypeDto locTypeDto = new LocTypeDto();


        locTypeDto.setLocType1((short)1);




        int iotype = 1;


        if (Cools.isEmpty(param.getMatList())) {


            iotype = 10;


        }


        // 根据源站点寻找库位


//        StartupDto dto = commonService.getLocNo(1, 1, param.getPalletizingNo(), null,null,null, locTypeDto);


        StartupDto dto = commonService.getLocNo(1, param.getPalletizingNo(), locTypeDto);


        StartupDto dto = commonService.getLocNo(iotype, param.getPalletizingNo(), locTypeDto,0);




        // 返回GWCS目标信息


        pushStaNoToGwcs(param.getPalletizingNo(),dto.getStaNo(),dto.getWorkNo());






        int workNo = dto.getWorkNo();


        Date now = new Date();


@@ -1011,7 +1024,7 @@


        wrkMast.setWrkNo(workNo);


        wrkMast.setIoTime(new Date());


        wrkMast.setWrkSts(1L); // 工作状态：设备上走


        wrkMast.setIoType(1); // 入出库状态：1.入库


        wrkMast.setIoType(iotype); // 入出库状态：1.入库


        wrkMast.setIoPri(13D); // 优先级


        wrkMast.setCrnNo(dto.getCrnNo());


        wrkMast.setSourceStaNo(param.getPalletizingNo());


@@ -1032,46 +1045,49 @@


            throw new CoolException("保存工作档失败");


        }




        List<GwmsGenerateInventoryDto.MatList> matList = param.getMatList();


        for (GwmsGenerateInventoryDto.MatList obj :matList) {


            WrkDetl wrkDetl = new WrkDetl();


            wrkDetl.setWrkNo(wrkMast.getWrkNo());


            obj.getRolls().forEach(roll -> {


                Mat mat = matService.selectByMatnr(roll.getSpecs());


                if (mat == null) {


                    mat = new Mat();


                    mat.setTagId(6L);


                    mat.setMatnr(roll.getSpecs());


                    mat.setMaktx(roll.getSpecs());


                    mat.setSpecs(roll.getSpecs());


                    mat.setStatus(1);


                    mat.setCreateTime(now);


                    mat.setUpdateTime(now);


                    if (!matService.insert(mat)) {


                        throw new CoolException("物料导入失败！");


                    }


                }


        if (!Cools.isEmpty(param.getMatList())) {


            List<GwmsGenerateInventoryDto.MatList> matList = param.getMatList();


            for (GwmsGenerateInventoryDto.MatList obj :matList) {


                WrkDetl wrkDetl = new WrkDetl();


                wrkDetl.setWrkNo(wrkMast.getWrkNo());


                wrkDetl.setMatnr(roll.getSpecs()); // 规格


                wrkDetl.setMaktx(roll.getSpecs()); //规格


                wrkDetl.setBatch(roll.getBoxNo()); // 箱号


                wrkDetl.setModel(roll.getRollNo()); // 卷号


                wrkDetl.setBrand(""); // 木箱类型


                wrkDetl.setZpallet(param.getBarcode()); // 托盘吗


                wrkDetl.setOrigin(obj.getBoxPos()); // 木箱在托盘位置


                wrkDetl.setWeight(roll.getNetWeight()); // 净重


                wrkDetl.setVolume(roll.getGrossWeight()); // 毛重


                wrkDetl.setPrice(roll.getLength());


                wrkDetl.setSpecs(String.valueOf(roll.getSplices()));


                wrkDetl.setAnfme(1.0);


                wrkDetl.setIoTime(now);


                wrkDetl.setAppeTime(now);


                wrkDetl.setModiTime(now);


                if (!wrkDetlService.insert(wrkDetl)) {


                    throw new CoolException("保存工作明细失败");


                }


            });


                obj.getRolls().forEach(roll -> {


//                Mat mat = matService.selectByMatnr(roll.getSpecs());


//                if (mat == null) {


//                    mat = new Mat();


//                    mat.setTagId(6L);


//                    mat.setMatnr(roll.getSpecs());


//                    mat.setMaktx(roll.getSpecs());


//                    mat.setSpecs(roll.getSpecs());


//                    mat.setStatus(1);


//                    mat.setCreateTime(now);


//                    mat.setUpdateTime(now);


//                    if (!matService.insert(mat)) {


//                        throw new CoolException("物料导入失败！");


//                    }


//                }


                    wrkDetl.setWrkNo(wrkMast.getWrkNo());


                    wrkDetl.setMatnr(roll.getSpecs()); // 规格


                    wrkDetl.setMaktx(roll.getSpecs()); //规格


                    wrkDetl.setBatch(roll.getBoxNo()); // 箱号


                    wrkDetl.setModel(roll.getRollNo()); // 卷号


                    wrkDetl.setBrand(obj.getPackageGroupNo()); // 包装组号


                    wrkDetl.setZpallet(param.getBarcode()); // 托盘吗


                    wrkDetl.setOrigin(obj.getBoxPos()); // 木箱在托盘位置


                    wrkDetl.setWeight(roll.getNetWeight()); // 净重


                    wrkDetl.setVolume(roll.getGrossWeight()); // 毛重


                    wrkDetl.setPrice(roll.getLength());


                    wrkDetl.setSpecs(String.valueOf(roll.getSplices()));


                    wrkDetl.setAnfme(1.0);


                    wrkDetl.setIoTime(now);


                    wrkDetl.setAppeTime(now);


                    wrkDetl.setModiTime(now);


                    if (!wrkDetlService.insert(wrkDetl)) {


                        throw new CoolException("保存工作明细失败");


                    }


                });


            }


        }






        // 更新目标库位状态


        LocMast locMast = locMastService.selectById(dto.getLocNo());


@@ -1100,6 +1116,9 @@


        }




        wrkMast.setWrkSts(2L);


        if(wrkMast.getIoType() == 10){


            wrkMast.setBarcode(param.getBarcode());


        }


        wrkMastService.updateById(wrkMast);




        return "请求成功";


@@ -1162,6 +1181,7 @@


        for (ZwmsOutLocWorkDto.Rolls detail : orderDetails) {


            DetlDto dto = new DetlDto(detail.getRollNo(), detail.getBoxNo(), 1.0);


            dto.setOrderNo(detail.getSpecs());


            dto.setSplices(detail.getSplices());


            if (DetlDto.has(list, dto)) {


                DetlDto detlDto = DetlDto.find(list, dto.getMatnr(), dto.getBatch());


                assert detlDto != null;


@@ -1178,7 +1198,7 @@


//            } else {


//                orderDetl.sync(mat);


//            }




            orderDetl.setSpecs(String.valueOf(detlDto.getSplices()));


            orderDetl.setBatch(detlDto.getBatch() == null ? "" : detlDto.getBatch());


            orderDetl.setModel(detlDto.getMatnr());


            orderDetl.setMatnr(detlDto.getOrderNo());


@@ -1228,17 +1248,32 @@


        return "出库结果上报成功";


    }




    @Autowired


    private BasCrnpService basCrnpService;




    @Override


    @Transactional


    public String emptyOutLoc(GhjtApiParam param) {


//        3102/3009/3008/3006/3003/3002→3047/3112


        // 获取模式为电脑模式，无任务的堆垛机列表:防止分配到堆垛机不可用


        List<BasCrnp> basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>().eq("crn_sts",3)


                .eq("wrk_no",0));


        if (basCrnps.isEmpty()) {


            // 都有任务则获取电脑模式的堆垛机列表


            basCrnps = basCrnpService.selectList(new EntityWrapper<BasCrnp>().eq("crn_sts",3));


        }


        if (basCrnps.isEmpty()) {


            throw new CoolException("没有可用堆垛机,堆垛机停止或异常");


        }


        // 可用堆垛机列表


        List<Integer> crnNoList = basCrnps.stream().map(BasCrnp::getCrnNo).collect(Collectors.toList());


        // 寻找空托盘库位，先找浅库位


        List<LocMast> locMasts;


            locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts","D")


                    .orderAsc(Arrays.asList("row1","lev1","bay1")).in("row1",3,4,6,7,10,11,14,15,18,19,22,23));


                    .orderAsc(Arrays.asList("row1","lev1","bay1")).in("crn_no",crnNoList).in("row1",3,4,6,7,10,11,14,15,18,19,22,23));


            if (locMasts.isEmpty()) {


                locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts","D")


                        .orderAsc(Arrays.asList("row1","lev1","bay1")).in("row1",1,4,5,8,9,12,13,16,17,20,21,24));


                        .orderAsc(Arrays.asList("row1","lev1","bay1")).in("crn_no",crnNoList).in("row1",1,4,5,8,9,12,13,16,17,20,21,24));


            }




        if (locMasts.isEmpty()) {


@@ -1268,6 +1303,7 @@


        wrkMast.setStaNo(staDesc.getStnNo()); // 目标站


        wrkMast.setCrnNo(locMast.getCrnNo());


        wrkMast.setSourceLocNo(locMast.getLocNo()); // 源库位


        wrkMast.setBarcode(locMast.getBarcode());


        wrkMast.setFullPlt("N"); // 满板：Y


        wrkMast.setPicking("N"); // 拣料


        wrkMast.setExitMk("N"); // 退出


@@ -1294,10 +1330,131 @@


        return "出库成功";


    }




    @Autowired


    private ApiLogService apiLogService;


    @Override


    @Transactional


    public R zphjDw(ZphjckdwParam param) {


        // 根据任务号得到工作主档


        if (Cools.isEmpty(param.getWorkNo())) {


            throw new CoolException("工作号不能为空！");


        }


        WrkMast wrkMast = wrkMastService.selectById(param.getWorkNo());


        if (wrkMast == null) {


            throw new CoolException("工作档不存在！");


        }


        if (wrkMast.getWrkSts() != 2 || wrkMast.getIoType() != 103) {


            throw new CoolException("工作档当前状态不为2/出库类型不为拣料！");


        }


        // 更新工作档状态2.设备上走->42.等待码垛


        wrkMast.setWrkSts(42L);


        wrkMastService.updateById(wrkMast);




    private void pushStaNoToGwcs(Integer palletizingNo, Integer staNo, Integer workNo) {


        // 查询要拆的位置，只有一个


        List<WrkDetl> wrkDetls = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));


        List<String> collect = wrkDetls.stream().map(WrkDetl::getOrigin).distinct().collect(Collectors.toList());


        String position = collect.get(0);




        // 返回拆垛规则


        ZphjcdgzVo zphjcdgzVo = new ZphjcdgzVo();


        zphjcdgzVo.setWorkNo(wrkMast.getWrkNo());


        zphjcdgzVo.setPosition(position);




        return R.ok(zphjcdgzVo);


    }




    @Override


    @Transactional


    public R zphjCdwc(ZphjcdwcParam param) {




        if (Cools.isEmpty(param.getWorkNo())) {


            throw new CoolException("工作号不能为空！");


        }


        WrkMast wrkMast = wrkMastService.selectById(param.getWorkNo());


        if (wrkMast == null) {


            throw new CoolException("工作档不存在！");


        }


        if (wrkMast.getWrkSts() != 42 || wrkMast.getIoType() != 103) {


            throw new CoolException("工作档当前状态不为42/出库类型不为拣料！");


        }




        // 保存工作主档历史档


        if (!wrkMastLogService.save(wrkMast.getWrkNo())) {


            throw new CoolException("保存工作主档历史档失败");


        }


        // 获取目标站


        Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()


                .eq("type_no", wrkMast.getIoType() - 50)


                .eq("stn_no", wrkMast.getStaNo()) // 作业站点 = 拣料出库的目标站


                .eq("crn_no", wrkMast.getCrnNo()); // 堆垛机号


        StaDesc staDesc = staDescService.selectOne(wrapper);


        if (Cools.isEmpty(staDesc)) {


            throw new CoolException("入库路径不存在");


        }


        // 堆垛机站点(目标站)


        Integer staNo = staDesc.getCrnStn();


        // 更新工作类型103->53


        wrkMast.setIoType(53);


        wrkMast.setWrkSts(52L); // 工作状态42->52.设备上走（拆垛完成）


        // 目标站点源站点转换


        wrkMast.setSourceStaNo(wrkMast.getStaNo());


        wrkMast.setStaNo(staNo);


        // 目标库位=源库位


        wrkMast.setLocNo(wrkMast.getSourceLocNo());


        // 源库位清除


        wrkMast.setSourceLocNo("");


        wrkMast.setModiTime(new Date());




        int outStaNo = 0; // 出库源站点


        if (staNo == 3044 || staNo == 3045) {


             outStaNo = 3046;


        } else if(staNo == 3040 || staNo == 3041) {


             outStaNo = 3042;


        }


        if (outStaNo == 0) {


            throw new CoolException("出库源站点转换有误：" + staNo);


        }




        // 获取出库物料


        List<WrkDetl> wrkDetls = wrkDetlService.selectList(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkMast.getWrkNo()));


        int descFlag = getType(wrkDetls);




        // get0原托盘回流信息，get1拆垛出来物料出库信息


        List<ZphjcdwcVo> zphjcdwcVos = new ArrayList<>();


        ZphjcdwcVo zphjcdwcVo1 = new ZphjcdwcVo();


        zphjcdwcVo1.setWorkNo(wrkMast.getWrkNo());


        zphjcdwcVo1.setStaNo(wrkMast.getStaNo());


        zphjcdwcVo1.setSourceStaNo(wrkMast.getSourceStaNo());


        zphjcdwcVos.add(zphjcdwcVo1);




        ZphjcdwcVo zphjcdwcVo2 = new ZphjcdwcVo();


        zphjcdwcVo2.setSourceStaNo(outStaNo);


        zphjcdwcVo2.setStaNo(3106); // 3106/3077


        zphjcdwcVo2.setDescFlag(descFlag);


        zphjcdwcVos.add(zphjcdwcVo2);




        // 更新工作主档


        wrkMastService.updateById(wrkMast);


        // 修改库位状态 Q.拣料/盘点/并板再入库


        LocMast locMast = locMastService.selectById(wrkMast.getLocNo());


        locMast.setLocSts("Q");


        locMast.setModiTime(new Date());


        if (!locMastService.updateById(locMast)) {


            throw new CoolException("修改库位状态失败");


        }




        // 下发回库的目标站点和拆垛的出库目标站点给gwcs


        return R.ok(zphjcdwcVos);


    }




    /**


     * 根据出库物料明细判断是否去贴标(单卷贴标，多卷不贴标)


     * @param wrkDetls 物料明细


     * @return 0.多卷不贴标路径，1.单卷贴标路径


     */


    private int getType(List<WrkDetl> wrkDetls) {


        return wrkDetls.size() > 1 ? 0 : 1; // 一条记录就是一卷


    }




    public void pushStaNoToGwcs(Integer palletizingNo, Integer staNo, Integer workNo) {


        boolean success = false;


        // 获取请求头


        Map<String, Object> headers = getHeaders();


@@ -1311,8 +1468,8 @@


        String response = "";


        try {


            response = new HttpHandler.Builder()


                    .setUri(MesConstant.URL)


                    .setPath(MesConstant.PAKIN_URL)


                    .setUri(MesConstant.GWCS_IP_PORT)


                    .setPath(MesConstant.GWCS_FPKW_URL)


                    .setHeaders(headers)


                    .setJson(body)


                    .build()


@@ -1336,10 +1493,10 @@


                // 保存接口日志


                apiLogService.save(


                        "入库",


                        MesConstant.URL + MesConstant.PAKIN_URL,


                        MesConstant.GWCS_IP_PORT + MesConstant.GWCS_FPKW_URL,


                        null,


                        "127.0.0.1",


                        jsonObject.toJSONString(),


                        body,


                        response,


                        success


                );