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


@@ -20,6 +20,8 @@


import com.zy.asrs.utils.MatUtils;


import com.zy.common.constant.MesConstant;


import com.zy.common.model.DetlDto;


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


import com.zy.common.service.CommonService;


import com.zy.common.utils.HttpHandler;


import com.zy.common.utils.NodeUtils;


import lombok.extern.slf4j.Slf4j;


@@ -65,9 +67,12 @@


    private TestMastService testMastService;


    @Autowired


    private LocMastService locMastService;




    @Autowired


    private CommonService commonService;


    @Autowired


    private ApiLogService apiLogService;


    @Autowired


    private WrkMastService wrkMastService;




    @Value("${mes.url}")


    private String mesUrl;


@@ -621,6 +626,99 @@


            throw new CoolException("保存入库通知档失败");


        }


    }


    @Override


    @Transactional


    public void combPackOut(CombParam param) {


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


            throw new CoolException(BaseRes.PARAM);


        }


        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()


//                .eq("fire_status", 0)


//                .eq("loc_sts", "F")


                .eq("barcode", param.getPackNo()));


        if (Cools.isEmpty(locMast)){


            throw new CoolException("未查询到PACK码为："+param.getPackNo()+"的货物");


        }else if (locMast.getLocSts().equals("F")){


            throw new CoolException("PACK码为："+param.getPackNo()+"的货物库位状态不是“F”");


        }else if (locMast.getFireStatus()!=0){


            throw new CoolException("警告！！！PACK码为："+param.getPackNo()+"的库位："+locMast.getLocNo()+"消防状态异常！！！");


//        }else if (locMast.getFireStatus()!=0){


//            throw new CoolException("警告！！！PACK码为："+param.getPackNo()+"的库位："+locMast.getLocNo()+"消防状态异常！！！");


//        }else if (locMast.getFireStatus()!=0){


//            throw new CoolException("警告！！！PACK码为："+param.getPackNo()+"的库位："+locMast.getLocNo()+"消防状态异常！！！");


//        }else if (locMast.getFireStatus()!=0){


//            throw new CoolException("警告！！！PACK码为："+param.getPackNo()+"的库位："+locMast.getLocNo()+"消防状态异常！！！");


        }else {


            Date now = new Date();


            Integer ioType = 101;   //入出库类型


            LocDetl locDetl=locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no",locMast.getLocNo()));


            if (Cools.isEmpty(locDetl)){


                log.error("库位:"+locMast.getLocNo()+"没有明细");


//            } else if (Cools.isEmpty(locDetl.getDeadWarn())){


//                log.error("库位:"+locMast.getLocNo()+"没有静置时间");


//            } else if (Cools.isEmpty(locMast.getModiTime())){


//                log.error("库位:"+locMast.getLocNo()+"modiTime为空");


            } else if (Cools.isEmpty(locMast.getBarcode())){


                log.error("库位:"+locMast.getLocNo()+"Pack码为空");


            } else {


                // 生成工作号


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


                // 生成工作档


                WrkMast wrkMast = new WrkMast();


                wrkMast.setWrkNo(workNo);


                wrkMast.setIoTime(now);


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


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


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


                wrkMast.setCrnNo(1);


                wrkMast.setSourceStaNo(107); // 源站


                wrkMast.setStaNo(104); // 目标站


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


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


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


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


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


                wrkMast.setLinkMis("N");


                wrkMast.setBarcode(locMast.getBarcode());


                wrkMast.setAppeTime(now);


                wrkMast.setModiTime(now);


                if (!wrkMastService.insert(wrkMast)) {


                    throw new CoolException("保存工作档失败，出库库位号："+locMast.getLocNo());


                }


                // 生成工作档明细


                WrkDetl wrkDetl = new WrkDetl();


                wrkDetl.sync(locDetl);


                wrkDetl.setWrkNo(workNo);


                wrkDetl.setIoTime(now);


                wrkDetl.setAnfme(1.0); // 数量


                wrkDetl.setAppeTime(now);


                wrkDetl.setModiTime(now);


                if (!wrkDetlService.insert(wrkDetl)) {


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


                }


                // 修改库位状态:   F.在库 ====>>> R.出库预约


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


                    locMast.setLocSts("R");


                    locMast.setModiTime(now);


                    locMast.setPackStatus(5); //5:静置完成


                    CombParam combParam = new CombParam();


                    combParam.setPackNo(locMast.getBarcode());


                    combParam.setLocNo(locMast.getLocNo());


                    combParam.setPackSts(6);


                    combParam.setRequestTime(DateUtils.convert(new Date()));


                    postMesData(inpath,combParam);




                    if (!locMastService.updateById(locMast)) {


                        throw new CoolException("预约库位状态失败，库位号："+locMast.getLocNo());


                    }


                } else {


                    throw new CoolException(locMast.getLocNo() + "库位不是在库状态");


                }


            }


        }






    }




    @Override


    @Transactional


@@ -647,7 +745,7 @@


                locMast.setPackStatus(2);


                CombParam combParam = new CombParam();


                combParam.setPackNo(locMast.getBarcode());


                combParam.setLocno(locMast.getLocNo());


                combParam.setLocNo(locMast.getLocNo());


                combParam.setPackSts(2);


                combParam.setRequestTime(DateUtils.convert(new Date()));


                postMesData(inpath,combParam);


@@ -692,7 +790,7 @@


                testMast.setModiTime(date);


                CombParam combParam = new CombParam();


                combParam.setPackNo(locMast.getBarcode());


                combParam.setLocno(locMast.getLocNo());


                combParam.setLocNo(locMast.getLocNo());


                combParam.setPackSts(3);


                combParam.setRequestTime(DateUtils.convert(new Date()));


                postMesData(inpath,combParam);


@@ -715,9 +813,10 @@


            String response = "";


            boolean success = false;


            try {


                Map<String, Object> map = new HashMap<>();


                map.put("appkey","ea1f0459efc02a79f046f982767939ae");


                response = new HttpHandler.Builder().setHeaders(map)


//                Map<String, Object> map = new HashMap<>();


//                map.put("appkey","ea1f0459efc02a79f046f982767939ae");


                response = new HttpHandler.Builder()


//                        .setHeaders(map)


                        .setUri(mesUrl)


                        .setPath(mesPath)


                        .setJson(JSON.toJSONString(combParam))


@@ -730,11 +829,11 @@


                    }else if (jsonObject.getDate("isComplete").equals(false)){


                        success = false;


                    }else {


                        log.error("返回值出错!!!url：{}；request：{}；response：{}", MesConstant.URL+MesConstant.PAKIN_URL, JSON.toJSONString(combParam), response);


                        log.error("返回值出错!!!url：{}；request：{}；response：{}", mesUrl+mesPath, JSON.toJSONString(combParam), response);


                        throw new CoolException("返回值出错");


                    }


                } else {


                    log.error("请求接口失败！！！url：{}；request：{}；response：{}", MesConstant.URL+MesConstant.PAKIN_URL, JSON.toJSONString(combParam), response);


                    log.error("请求接口失败！！！url：{}；request：{}；response：{}", mesUrl+mesPath, JSON.toJSONString(combParam), response);


                    throw new CoolException("上报mes系统失败");


                }


            } catch (Exception e) {


@@ -746,7 +845,7 @@


                    // 保存接口日志


                    apiLogService.save(


                            "成品库入库上报",


                            MesConstant.URL + MesConstant.PAKIN_URL,


                            mesUrl + mesPath,


                            null,


                            "127.0.0.1",


                            JSON.toJSONString(combParam),