package com.zy.asrs.service.impl; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.BaseRes; import com.core.common.Cools; import com.core.exception.CoolException; import com.zy.asrs.entity.*; import com.zy.asrs.entity.param.CombParam; import com.zy.asrs.entity.param.MobileAdjustParam; import com.zy.asrs.entity.param.PickParam; import com.zy.asrs.service.*; import com.zy.common.model.DetlDto; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.stream.Collectors; /** * 移动端服务核心类 * Created by vincent on 2020/6/28 */ @Slf4j @Service public class AgvMobileServiceImpl implements AgvMobileService { @Autowired private MatService matService; @Autowired private AgvWaitPakinService agvWaitPakinService; @Autowired private OrderService orderService; @Autowired private OrderDetlService orderDetlService; @Autowired private AgvBasDevpService agvBasDevpService; @Autowired private AgvLocDetlService agvLocDetlService; @Autowired private AgvWrkMastService agvWrkMastService; @Autowired private AgvWorkService agvWorkService; @Autowired private AgvWrkDetlService agvWrkDetlService; /* 组托 + 绑定暂存位 */ @Override @Transactional public String comb(CombParam param, Long userId) { if (Cools.isEmpty(param.getBarcode(), param.getCombMats())) { throw new CoolException(BaseRes.PARAM); } param.setContainerType(Short.valueOf(param.getBarcode().substring(0,2))); // //检查是否已存在相同的托盘条码，存在则抛出异常 // if (agvWaitPakinService.selectCount(new EntityWrapper().eq("supp_code", param.getBarcode())) > 0) { // throw new CoolException(param.getBarcode() + "料想码已存在AGV入库通知档中"); // } //检查库存是否有相同料箱，存在则抛出异常 if(!Cools.isEmpty(agvLocDetlService.selectOne(new EntityWrapper().eq("supp_code",param.getBarcode())))){ throw new CoolException(param.getBarcode() + "料箱码已存在AGV库存明细中"); } //查看工作档是否有相同料箱，存在则抛出异常 if(!Cools.isEmpty(agvWrkMastService.selectByContainerCode(param.getBarcode()))){ throw new CoolException(param.getBarcode() + "料箱码已存在AGV工作档中"); } if (Cools.isEmpty(param.getOrderNo())) { //无单组托 NoOrderComb(param,userId); }else { //有单组托 OrderComb(param,userId); } if(StringUtils.isEmpty(param.getLocno())){ return "组托成功"; }else { combBinding(param.getBarcode(),param.getLocno(),param.getContainerType()); return "组托成功，绑定站点成功"; } } /* 组托 + 绑定暂存位 */ @Override @Transactional public String pickAgain(PickParam pickParams, Long userId) { Date now = new Date(); List agvLocDetls = agvLocDetlService.selectList(new EntityWrapper().eq("loc_no", pickParams.getLocNo())); for (PickParam.Pick pick : pickParams.getPicks()) { if (pick.getCount().equals(0D)) continue; AgvWrkDetl wrkDetl = new AgvWrkDetl(); Mat mat = matService.selectByMatnr(pick.getMatnr()); if (Cools.isEmpty(mat)) { throw new CoolException(pick.getMatnr() + "商品不存在"); } wrkDetl.sync(mat); wrkDetl.setWrkNo(pickParams.getWrkNo()); wrkDetl.setOrderNo(pick.getOrderNo()); wrkDetl.setIoTime(now); wrkDetl.setAnfme(pick.getCount()); // 数量 wrkDetl.setSuppCode(pick.getSuppCode()); // 托盘条码 wrkDetl.setAppeUser(userId); wrkDetl.setAppeTime(now); wrkDetl.setModiUser(userId); wrkDetl.setModiTime(now); wrkDetl.setThreeCode(pick.getThreeCode()); agvWrkDetlService.insert(wrkDetl); // 更新订单 OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper().eq("order_no", pick.getOrderNo()).eq("matnr", pick.getMatnr()).eq("three_code",pick.getThreeCode())); orderDetl.setQty(orderDetl.getQty() + pick.getCount()); if (!orderDetlService.update(orderDetl,new EntityWrapper().eq("order_no", pick.getOrderNo()).eq("matnr", pick.getMatnr()).eq("three_code",pick.getThreeCode()))){ throw new CoolException("修改订单明细失败，请联系管理员"+pick.getOrderNo()+pick.getMatnr()); } } // 确认是否全部出库 int sameNumber = 0; List agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper().eq("wrk_no", pickParams.getWrkNo())); for (AgvLocDetl agvLocDetl : agvLocDetls) { for (AgvWrkDetl agvWrkDetl : agvWrkDetls) { if (agvLocDetl.getMatnr().equals(agvWrkDetl.getMatnr()) && agvLocDetl.getThreeCode().equals(agvWrkDetl.getThreeCode()) && agvLocDetl.getSuppCode().equals(agvWrkDetl.getSuppCode()) && agvLocDetl.getAnfme().equals(agvWrkDetl.getAnfme())) { sameNumber++; } } } if (agvLocDetls.size() == sameNumber) { AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper().eq("wrk_no", pickParams.getWrkNo())); agvWrkMast.setIoType(101); agvWrkMastService.update(agvWrkMast,new EntityWrapper().eq("wrk_no", pickParams.getWrkNo())); } return "组托成功，绑定站点成功"; } /* AGV无单组托 */ private void NoOrderComb(CombParam param, Long userId){ List detlDtos = mappingDetlDtoByCombMat(param,null); //用于统一一个托盘下的入库通知档的生成时间 Date now = new Date(); detlDtos.forEach(detlDto -> { syncWaitPakin(detlDto,"",param.getBarcode(),userId,now); }); } /* AGV有单组托 */ private void OrderComb(CombParam param, Long userId){ //关联组托 Order order = orderService.selectByNo(param.getOrderNo()); if(Cools.isEmpty(order)){ throw new CoolException("单据编号不存在"); } //订单状态2以上为完成或者取消的订单 if (order.getSettle() > 2) { throw new CoolException("单据编号已过期"); } // 用于生成入库通知档所需参数 List detlDtos = mappingDetlDtoByCombMat(param,order); //用于统一一个托盘下的入库通知档的生成时间 Date now = new Date(); for (DetlDto detlDto : detlDtos) { //同步生成入库通知档 syncWaitPakin(detlDto,order.getOrderNo(),param.getBarcode(),userId,now); } //修改单据状态为2.作业中 orderService.updateSettle(order.getId(), 2L, userId); } /* 根据PDA扫码所传的物料信息参数映射为DetlDto */ private List mappingDetlDtoByCombMat(CombParam param, Order order){ List detlDtos = new ArrayList<>(); param.getCombMats().forEach(combMat -> { if(!Cools.isEmpty(order)){ //检查入库数量 checkOrderQty(order,combMat); } DetlDto detlDto = new DetlDto(combMat.getMatnr(), combMat.getBatch(), combMat.getAnfme(), combMat.getCsocode(), combMat.getIsoseq(),combMat.getContainerCode(),param.getLocType()); //同一托盘下相同物料信息和批号转为一个入库通知档 if (DetlDto.has(detlDtos, detlDto)) { DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch(), detlDto.getCsocode(), detlDto.getIsoseq(),detlDto.getContainerCode()); assert one != null; one.setAnfme(one.getAnfme() + detlDto.getAnfme()); } else { detlDtos.add(detlDto); } }); return detlDtos; } /* 检查入库数量是否小于等于单据数量，合理则修改OrderDetl作业数量信息，否则抛出异常 */ private void checkOrderQty(Order order, CombParam.CombMat combMat){ // 订单明细数量校验，如果作业数量大于单据数量则抛出异常 OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), combMat.getMatnr(), combMat.getBatch(), combMat.getCsocode(),combMat.getIsoseq()); if(Cools.isEmpty(orderDetl)){ throw new CoolException("未匹配到该单据下的物料"); } if (combMat.getAnfme() > orderDetl.getEnableQty()) { throw new CoolException(orderDetl.getMatnr() + "入库数量不合法"); } // 修改订单明细数量 if (!orderDetlService.increase(order.getId(), combMat.getMatnr(), combMat.getBatch(), combMat.getAnfme(), combMat.getCsocode(),combMat.getIsoseq())) { throw new CoolException("修改单据明细数量失败"); } } /* 同步生成AGV入库通知档数据 */ private void syncWaitPakin(DetlDto detlDto, String orderNo, String zpallet, Long userId, Date now ){ Mat mat = matService.selectByMatnr(detlDto.getMatnr()); if (Cools.isEmpty(mat)) { throw new CoolException(detlDto.getMatnr() + "商品档案不存在"); } AgvWaitPakin waitPakin = new AgvWaitPakin(); waitPakin.sync(mat); waitPakin.setOrderNo(orderNo); // 单据编号 waitPakin.setBatch(detlDto.getBatch()); // 序列码 //waitPakin.setZpallet(zpallet); // 托盘码 waitPakin.setSuppCode(zpallet); // 托盘码 waitPakin.setIoStatus("N"); // 入出状态 waitPakin.setAnfme(detlDto.getAnfme()); // 数量 waitPakin.setStatus("Y"); // 状态 ////销售订单号 waitPakin.setThreeCode(detlDto.getCsocode()); //销售订单行号 waitPakin.setDeadTime(detlDto.getIsoseq()); waitPakin.setLocType(detlDto.getLocType()); waitPakin.setAppeUser(userId); waitPakin.setAppeTime(now); waitPakin.setModiUser(userId); waitPakin.setModiTime(now); if (!agvWaitPakinService.insert(waitPakin)) { throw new CoolException("保存入库通知档失败"); } } @Override @Transactional public void adjust(MobileAdjustParam param, Long userId) { } @Override @Transactional public void packComb(CombParam param, Long userId) { } @Override public void combBinding(String barcode, String stationCode, Short containerType) { AgvBasDevp agvBasDevp = agvBasDevpService.selectOne(new EntityWrapper().eq("dev_no", stationCode)); if(Cools.eq(agvBasDevp.getBarcode(),barcode)){ return; } if(Cools.isEmpty(agvWaitPakinService.selectByContainerCode(barcode))){ throw new CoolException("该料箱未组托，无法绑定站点"); } AgvBasDevp agvBasDevp1 = agvBasDevpService.selectOne(new EntityWrapper().eq("barcode", barcode)); if(!Cools.isEmpty(agvBasDevp1)){ throw new CoolException(barcode + "已经绑定在"+ agvBasDevp.getDevNo() +"站点"); } if(agvBasDevp == null){ throw new CoolException(stationCode + "站点信息错误"); } if(!"O".equals(agvBasDevp.getLocSts())){ throw new CoolException(stationCode + "该站点货位状态非空"); } AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper().eq("loc_no", agvBasDevp.getDevNo())); if(!Cools.isEmpty(agvWrkMast)){ throw new CoolException(stationCode + "该站点已被工作号为" + agvWrkMast.getWrkNo() + "占用，无法绑定"); } agvBasDevp.setBarcode(barcode); agvBasDevp.setLocSts("F"); agvBasDevp.setLocType2(containerType); agvBasDevpService.update(agvBasDevp,(new EntityWrapper().eq("dev_no",stationCode))); } public List getAgvBasDevpByFloor(int floor) { EntityWrapper wrapper = new EntityWrapper<>(); wrapper.eq("floor",floor).eq("cache_shelves","Y").eq("loc_sts","F"); List agvBasDevpList = agvBasDevpService.selectList(wrapper); return agvBasDevpList.stream().filter(agvBasDevp -> { return !Cools.isEmpty(agvWaitPakinService.selectByContainerCode(agvBasDevp.getBarcode())); }).collect(Collectors.toList()); } @Override public void pakinEmpty(String devNo, boolean pakin) { //当前站点信息 AgvBasDevp agvBasDevp = agvBasDevpService.selectById(devNo); //寻找相同类型的库位 //生成空盘工作档 //更改库位状态以及站点状态 } @Override public void pakoutEmpty(String devNo) { } }