自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
#
luxiaotao1123
2022-03-30 a4aad3f61c9264fef86b433e0efb39558cc31e83 
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java


@@ -1,6 +1,5 @@


package com.zy.asrs.service.impl;




import com.alibaba.fastjson.JSON;


import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.baomidou.mybatisplus.mapper.Wrapper;


import com.core.common.BaseRes;


@@ -18,11 +17,8 @@


import com.zy.common.model.*;


import com.zy.common.model.enums.WorkNoType;


import com.zy.common.service.CommonService;


import com.zy.common.service.wms.Result;


import com.zy.common.service.wms.WmsService;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.jdbc.core.JdbcTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




@@ -45,11 +41,11 @@


    @Autowired


    private WrkMastService wrkMastService;


    @Autowired


    private WrkDetlService wrkDetlService;


    @Autowired


    private BasDevpService basDevpService;


    @Autowired


    private CommonService commonService;


    @Autowired


    private WrkDetlService wrkDetlService;


    @Autowired


    private LocMastService locMastService;


    @Autowired


@@ -65,9 +61,11 @@


    @Autowired


    private WrkDetlLogService wrkDetlLogService;


    @Autowired


    private WmsService wmsService;


    @Autowired


    private SnowflakeIdWorker snowflakeIdWorker;


    @Autowired


    private OrderService orderService;


    @Autowired


    private OrderDetlService orderDetlService;




    @Override


    @Transactional


@@ -76,12 +74,11 @@


        if (Cools.isEmpty(param.getDevpNo(), param.getList())) {


            throw new CoolException(BaseRes.PARAM);


        }


        Date now = new Date();


        // 源站点状态检测


        BasDevp sourceStaNo = basDevpService.checkSiteStatus(param.getDevpNo(), true);


        // 检索库位


        LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);


        log.info(JSON.toJSONString(locTypeDto));


        log.info("{}入库口尺寸检测：{}", param.getDevpNo(), locTypeDto.getLocType1()==1?"低规格库位":"高规格库位");


        List<String> matNos = param.getList().stream().map(FullStoreParam.MatCodeStore::getMatNo).distinct().collect(Collectors.toList());


        StartupDto dto = commonService.getLocNo(DEFAULT_ROW_NO_TYPE, 1, param.getDevpNo(), matNos, locTypeDto, 0);


        // 生成工作号


@@ -92,7 +89,7 @@


        wrkMast.setIoTime(new Date());


        wrkMast.setWrkSts(1L); // 工作状态：生成入库ID


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


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


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


        wrkMast.setCrnNo(dto.getCrnNo());


        wrkMast.setSourceStaNo(dto.getSourceStaNo());


        wrkMast.setStaNo(dto.getStaNo());


@@ -104,25 +101,30 @@


        wrkMast.setEmptyMk("N"); // 空板


        wrkMast.setLinkMis("N");


        wrkMast.setCtnType(sourceStaNo.getCtnType()); // 容器类型


        // 操作人员数据


        wrkMast.setAppeUser(userId);


        wrkMast.setAppeTime(new Date());


        wrkMast.setAppeTime(now);


        wrkMast.setModiUser(userId);


        wrkMast.setModiTime(new Date());


        boolean res = wrkMastService.insert(wrkMast);


        if (!res) {


        wrkMast.setModiTime(now);


        if (!wrkMastService.insert(wrkMast)) {


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


        }


        // 生成工作档明细


        List<DetlDto> detlDtos = new ArrayList<>();


        param.getList().forEach(elem -> {


            detlDtos.add(new DetlDto(elem.getMatNo(), elem.getCount()));


            DetlDto detlDto = new DetlDto(elem.getMatNo(), elem.getBatch(), elem.getAnfme());


            if (DetlDto.has(detlDtos, detlDto)) {


                DetlDto detlDto1 = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch());


                assert detlDto1 != null;


                detlDto1.setAnfme(detlDto1.getAnfme() + detlDto.getAnfme());


            } else {


                detlDtos.add(detlDto);


            }


        });


        wrkDetlService.createWorkDetail(workNo, detlDtos, param.getBarcode(), userId);


        // 更新源站点信息


        sourceStaNo.setWrkNo(workNo);


        sourceStaNo.setModiUser(userId);


        sourceStaNo.setModiTime(new Date());


        sourceStaNo.setModiTime(now);


        if (!basDevpService.updateById(sourceStaNo)){


            throw new CoolException("更新源站失败");


        }


@@ -131,7 +133,7 @@


        if (locMast.getLocSts().equals("O")){


            locMast.setLocSts("S"); // S.入库预约


            locMast.setModiUser(userId);


            locMast.setModiTime(new Date());


            locMast.setModiTime(now);


            if (!locMastService.updateById(locMast)){


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


            }


@@ -150,10 +152,7 @@


        List<LocDetlDto> locDetlDtos = new ArrayList<>();


        for (StockOutParam.LocDetl paramLocDetl : param.getLocDetls()) {


            if (!Cools.isEmpty(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getCount())) {


                LocDetl sqlParam = new LocDetl();


                sqlParam.setLocNo(paramLocDetl.getLocNo());


                sqlParam.setMatnr(paramLocDetl.getMatnr());


                LocDetl one = locDetlService.selectOne(new EntityWrapper<>(sqlParam));


                LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getBatch());


                if (null != one) locDetlDtos.add(new LocDetlDto(one, paramLocDetl.getCount()));


            }


        }


@@ -161,7 +160,7 @@


            // 启动出库开始 101.出库


            stockOut(staNo, locDetlDtos, null, userId);


        } else {


            throw new CoolException("库位物料不存在");


            throw new CoolException("库存不存在");


        }


    }




@@ -194,14 +193,7 @@


            // 获取库位


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


            // 获取路径


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


                    .eq("type_no", ioType)


                    .eq("stn_no", staNo.getDevNo())


                    .eq("crn_no", locMast.getCrnNo());


            StaDesc staDesc = staDescService.selectOne(wrapper);


            if (Cools.isEmpty(staDesc)) {


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


            }


            StaDesc staDesc = staDescService.queryCrnStn(ioType, locMast.getCrnNo(), staNo.getDevNo());


            // 生成工作号


            int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(ioType));


            // 生成工作档


@@ -229,11 +221,10 @@


            }


            // 生成工作档明细


            for (LocDetlDto detlDto : dto.getLocDetlDtos()) {


                // 出库时，数量为0的直接忽略


                if (detlDto.getCount()==null || detlDto.getCount() <= 0.0D) {continue;}


                WrkDetl wrkDetl = new WrkDetl();


                wrkDetl.setWrkNo(workNo);


                wrkDetl.setIoTime(new Date());


                wrkDetl.setIoTime(now);


                Double anfme = ioType==101?detlDto.getLocDetl().getAnfme():detlDto.getCount();


                wrkDetl.setAnfme(anfme); // 数量


                VersionUtils.setWrkDetl(wrkDetl, detlDto.getLocDetl()); // 版本控制


@@ -273,14 +264,8 @@


        // 获取库位


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


        // 获取路径


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


                .eq("type_no", ioType)


                .eq("stn_no", staNo.getDevNo())


                .eq("crn_no", locMast.getCrnNo());


        StaDesc staDesc = staDescService.selectOne(wrapper);


        if (Cools.isEmpty(staDesc)) {


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


        }


        int ioType = taskDto.isAll() ? 101 : 103;


        StaDesc staDesc = staDescService.queryCrnStn(ioType, locMast.getCrnNo(), staNo.getDevNo());


        // 生成工作号


        int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(ioType));


        // 生成工作档


@@ -308,14 +293,15 @@


        }


        // 生成工作档明细


        for (LocDto locDto : taskDto.getLocDtos()) {


            // 出库时，数量为0的直接忽略


            if (detlDto.getCount()==null || detlDto.getCount() <= 0.0D) {continue;}


            if (locDto.getAnfme()==null || locDto.getAnfme() <= 0.0D) { continue; }


            OrderDetl orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());


            WrkDetl wrkDetl = new WrkDetl();


            wrkDetl.setIoTime(now);


            wrkDetl.setWrkNo(workNo);


            wrkDetl.setIoTime(new Date());


            Double anfme = ioType==101?detlDto.getLocDetl().getAnfme():detlDto.getCount();


            wrkDetl.setAnfme(anfme); // 数量


            VersionUtils.setWrkDetl(wrkDetl, detlDto.getLocDetl()); // 版本控制


            wrkDetl.setBatch(locDto.getBatch());


            wrkDetl.setOrderNo(locDto.getOrderNo());


            wrkDetl.setAnfme(locDto.getAnfme()); // 数量


            VersionUtils.setWrkDetl(wrkDetl, orderDetl); // 版本控制


            wrkDetl.setAppeTime(now);


            wrkDetl.setAppeUser(userId);


            wrkDetl.setModiTime(now);


@@ -323,6 +309,11 @@


            if (!wrkDetlService.insert(wrkDetl)) {


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


            }


            // 修改订单明细


            if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), locDto.getAnfme())) {


                throw new CoolException("修改订单明细数量失败");


            }


            orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);


        }


        // 修改库位状态:   F.在库 ====>>> R.出库预约/P.拣料/盘点/并板出库中


        locMast = locMastService.selectById(taskDto.getLocNo());


@@ -452,7 +443,6 @@


                    throw new CoolException("更新库位状态失败");


                }


            }


            // todo 更新站点信息（工作号）


        }


    }




@@ -628,36 +618,12 @@


                adjDetl.setOriQty(0.0D);


                adjDetl.setAdjQty(adjust.getCount());


                adjDetlService.save(adjDetl, userId);


                // 上报erp


                String docNum = "CS-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);


                Integer docId = 14; // 报溢单


                List<BillDto> dtos = new ArrayList<>();


                BillDto billDto = new BillDto();


                billDto.setMatnr(adjust.getMatnr());


                billDto.setQty(Math.abs(adjust.getCount()));


                dtos.add(billDto);


                Result result = wmsService.erpUpload(dtos, docId, docNum);


                if (result.getCode() != 200) {


                    throw new CoolException("库存调整失败，原因：无法上报至ERP");


                }


            // 修改原库存明细


            } else {


                // 如果数量修改，则更新库存明细


                if (!adjust.getCount().equals(one.getAnfme())) {


                    // 当数量被修改为 0 时，直接清除库存明细


                    if (adjust.getCount() == 0) {


                        // 上报erp


                        String docNum = "CD-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);


                        Integer docId = 9; // 报损单


                        List<BillDto> dtos = new ArrayList<>();


                        BillDto billDto = new BillDto();


                        billDto.setMatnr(adjust.getMatnr());


                        billDto.setQty(Math.abs(one.getAnfme()));


                        dtos.add(billDto);


                        Result result = wmsService.erpUpload(dtos, docId, docNum);


                        if (result.getCode() != 200) {


                            throw new CoolException("库存调整失败，原因：无法上报至ERP");


                        }


                        // 删除库存


                        if (!locDetlService.delete(new EntityWrapper<>(one))) {


                            throw new CoolException("清除库存明细失败");


@@ -671,27 +637,6 @@


                                .eq("loc_no", locMast.getLocNo())


                                .eq("matnr", adjust.getMatnr()))) {


                            throw new CoolException("修改库存明细失败");


                        }


                        // 上报erp


                        String docNum;


                        Integer docId;


                        if (one.getAnfme() > adjust.getCount()) {


                            // 报损


                            docNum = "CD-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);


                            docId = 9;


                        } else {


                            // 报溢


                            docNum = "CS-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15);


                            docId = 14;


                        }


                        List<BillDto> dtos = new ArrayList<>();


                        BillDto billDto = new BillDto();


                        billDto.setMatnr(adjust.getMatnr());


                        billDto.setQty(Math.abs(one.getAnfme() - adjust.getCount()));


                        dtos.add(billDto);


                        Result result = wmsService.erpUpload(dtos, docId, docNum);


                        if (result.getCode() != 200) {


                            throw new CoolException("库存调整失败，原因：无法上报至ERP");


                        }


                    }


                    // 保存调整记录


@@ -750,18 +695,6 @@


            // 出库 ===>> F.在库


            if (wrkMast.getIoType() > 100 && wrkMast.getIoType() != 110) {


                locSts = "F";


                // 销售单关联，则生成新的出库任务


                if (wrkMast.getPdcType().equals("Y")) {


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


                    for (WrkDetl wrkDetl : wrkDetls) {


                        Double sumAnfme = Optional.ofNullable(locDetlService.getSumAnfme(wrkDetl.getMatnr())).orElse(0.0D);


                        if (sumAnfme < wrkDetl.getAnfme()) {


                            throw new CoolException("取消失败！库存不足以重新生成出库作业");


                        }


                    }


                    // 生成新的出库作业


                    stockOutRe(wrkMast, wrkDetls);


                }


            // 空板出库 ===>> D.空桶/空栈板


            } else if (wrkMast.getIoType() == 110) {


                locSts = "D";


@@ -780,6 +713,17 @@


            }


        } else {


            throw new CoolException("当前工作状态无法取消");


        }


        // 订单关联


        List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo());


        for (WrkDetl wrkDetl : wrkDetls) {


            if (!Cools.isEmpty(wrkDetl.getOrderNo())) {


                if (!orderDetlService.decrease(wrkDetl.getOrderNo(), wrkDetl.getMatnr(), wrkDetl.getBatch(), wrkDetl.getAnfme())) {


                    throw new CoolException("订单数据回滚失败");


                }


                // 生成新的出库作业


//                        stockOutRe(wrkMast, wrkDetls);


            }


        }


        // 取消操作人员记录


        wrkMast.setManuType("手动取消");


@@ -872,56 +816,6 @@


        if (!locMastService.updateById(locMast)) {


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


        }


    }




    @Autowired


    private JdbcTemplate jdbcTemplate;


    private boolean pickSite = false;


    private void stockOutRe(WrkMast wrkMast, List<WrkDetl> wrkDetls) {


        for (WrkDetl wrkDetl : wrkDetls) {


            List<LocDetl> locDetls = locDetlService.selectPakoutByRule(wrkDetl.getMatnr());


            double issued = wrkDetl.getAnfme();


            for (LocDetl locDetl : locDetls) {


                if (issued > 0) {


                    // 生成出库工作档


                    // 全板


                    if (issued>=locDetl.getAnfme()) {


                        BasDevp staNo = basDevpService.checkSiteStatus(103);


                        List<LocDetlDto> detlDtos = new ArrayList<>();


                        LocDetlDto dto = new LocDetlDto();


                        dto.setLocDetl(locDetl);


                        dto.setCount(issued>=locDetl.getAnfme()?locDetl.getAnfme():issued);


                        detlDtos.add(dto);


                        stockOut(staNo, detlDtos, 101, 9527L);


                        // 拣料


                    } else {


                        int priorCount = jdbcTemplate.queryForObject("select isnull(count(*),0) from man_prior where 1=1 and matnr = '" + wrkDetl.getMatnr() + "'", Integer.class);


                        if (priorCount > 0) {


                            BasDevp staNo = basDevpService.checkSiteStatus(103);


                            List<LocDetlDto> detlDtos = new ArrayList<>();


                            LocDetlDto dto = new LocDetlDto();


                            dto.setLocDetl(locDetl);


                            dto.setCount(locDetl.getAnfme());


                            detlDtos.add(dto);


                            stockOut(staNo, detlDtos, 101, 9527L);


                        } else {


                            BasDevp staNo = basDevpService.checkSiteStatus(pickSite?113:109);


                            List<LocDetlDto> detlDtos = new ArrayList<>();


                            LocDetlDto dto = new LocDetlDto();


                            dto.setLocDetl(locDetl);


                            dto.setCount(issued>=locDetl.getAnfme()?locDetl.getAnfme():issued);


                            detlDtos.add(dto);


                            stockOut(staNo, detlDtos, 103, 9527L);


                        }




                    }




                    // 剩余待出数量递减


                    issued = issued - locDetl.getAnfme();


                }


            }


        }


        pickSite = !pickSite;


    }




}