| | |
|---|
| | | import com.zy.common.properties.SlaveProperties; |
|---|
| | | import com.zy.common.service.CommonService; |
|---|
| | | import com.zy.common.web.WcsController; |
|---|
| | | import com.zy.system.entity.User; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional |
|---|
| | | public void startupFullTakeStore(StockOutParam param, Long userId) { |
|---|
| | | public void startupFullTakeStore(StockOutParam param, User userId) { |
|---|
| | | String agvStaNo = param.getOutSite(); |
|---|
| | | // 获取库位明细 |
|---|
| | | List<LocDetlDto> locDetlDtos = new ArrayList<>(); |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional |
|---|
| | | public void stockOut(BasDevp staNo, List<LocDetlDto> locDetlDtos, IoWorkType ioWorkType, Long userId,String agvStaNo) { |
|---|
| | | public void stockOut(BasDevp staNo, List<LocDetlDto> locDetlDtos, IoWorkType ioWorkType, User user, String agvStaNo) { |
|---|
| | | Date now = new Date(); |
|---|
| | | // 合并同类项 |
|---|
| | | Set<String> locNos = new HashSet<>(); |
|---|
| | |
|---|
| | | wrkMast.setEmptyMk("N"); // 空板 |
|---|
| | | wrkMast.setLinkMis("N"); |
|---|
| | | wrkMast.setBarcode(locMast.getBarcode()); |
|---|
| | | wrkMast.setAppeUser(userId); // 操作人员数据 |
|---|
| | | wrkMast.setAppeUser(user.getId()); // 操作人员数据 |
|---|
| | | wrkMast.setAppeTime(now); |
|---|
| | | wrkMast.setModiUser(userId); |
|---|
| | | wrkMast.setModiUser(user.getId()); |
|---|
| | | wrkMast.setModiTime(now); |
|---|
| | | wrkMast.setMemo(Cools.isEmpty(agvStaNo) ? "" : agvStaNo); |
|---|
| | | if (!wrkMastService.insert(wrkMast)) { |
|---|
| | |
|---|
| | | } |
|---|
| | | // 生成工作档明细 |
|---|
| | | for (LocDetlDto detlDto : dto.getLocDetlDtos()) { |
|---|
| | | if (detlDto.getCount()==null || detlDto.getCount() <= 0.0D) {continue;} |
|---|
| | | if (detlDto.getCount() == null || detlDto.getCount() <= 0.0D) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | WrkDetl wrkDetl = new WrkDetl(); |
|---|
| | | wrkDetl.sync(detlDto.getLocDetl()); |
|---|
| | | wrkDetl.setOrderNo(""); // 手动出库不需要带出库存中的单据编号 |
|---|
| | |
|---|
| | | Double anfme = ioType==101?detlDto.getLocDetl().getAnfme():detlDto.getCount(); |
|---|
| | | wrkDetl.setAnfme(anfme); // 数量 |
|---|
| | | wrkDetl.setAppeTime(now); |
|---|
| | | wrkDetl.setAppeUser(userId); |
|---|
| | | wrkDetl.setAppeUser(user.getId()); |
|---|
| | | wrkDetl.setModiTime(now); |
|---|
| | | wrkDetl.setModiUser(userId); |
|---|
| | | wrkDetl.setModiUser(user.getId()); |
|---|
| | | if (!wrkDetlService.insert(wrkDetl)) { |
|---|
| | | throw new CoolException("保存工作档明细失败"); |
|---|
| | | } |
|---|
| | |
|---|
| | | locMast = locMastService.selectById(dto.getLocNo()); |
|---|
| | | if (locMast.getLocSts().equals("F")) { |
|---|
| | | locMast.setLocSts(ioType==101?"R":"P"); |
|---|
| | | locMast.setModiUser(userId); |
|---|
| | | locMast.setModiUser(user.getId()); |
|---|
| | | locMast.setModiTime(now); |
|---|
| | | if (!locMastService.updateById(locMast)) { |
|---|
| | | throw new CoolException("预约库位状态失败，库位号："+dto.getLocNo()); |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional |
|---|
| | | public void stockOut(BasDevp staNo, TaskDto taskDto, Long userId,String agvStaNo) { |
|---|
| | | public void stockOut(BasDevp staNo, TaskDto taskDto, User user, String agvStaNo) { |
|---|
| | | Date now = new Date(); |
|---|
| | | List<LocDto> locDtos = taskDto.getLocDtos(); |
|---|
| | | for (LocDto locDto : locDtos) { |
|---|
| | |
|---|
| | | wrkMast.setEmptyMk("N"); // 空板 |
|---|
| | | wrkMast.setLinkMis("N"); |
|---|
| | | wrkMast.setBarcode(locMast.getBarcode()); |
|---|
| | | wrkMast.setAppeUser(userId); // 操作人员数据 |
|---|
| | | wrkMast.setAppeUser(user.getId()); // 操作人员数据 |
|---|
| | | wrkMast.setAppeTime(now); |
|---|
| | | wrkMast.setModiUser(userId); |
|---|
| | | wrkMast.setModiUser(user.getId()); |
|---|
| | | wrkMast.setModiTime(now); |
|---|
| | | wrkMast.setMemo(Cools.isEmpty(agvStaNo) ? "" : agvStaNo); |
|---|
| | | if (!wrkMastService.insert(wrkMast)) { |
|---|
| | |
|---|
| | | } |
|---|
| | | // 生成工作档明细 |
|---|
| | | for (LocDto locDto : taskDto.getLocDtos()) { |
|---|
| | | if (locDto.getAnfme()==null || locDto.getAnfme() <= 0.0D) { continue; } |
|---|
| | | if (locDto.getAnfme() == null || locDto.getAnfme() <= 0.0D) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | OrderDetl orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch()); |
|---|
| | | if (orderDetl == null) { |
|---|
| | | orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), null); |
|---|
| | |
|---|
| | | wrkDetl.setModel(mat.getModel()); |
|---|
| | | wrkDetl.setAnfme(locDto.getAnfme()); // 数量 |
|---|
| | | wrkDetl.setAppeTime(now); |
|---|
| | | wrkDetl.setAppeUser(userId); |
|---|
| | | wrkDetl.setAppeUser(user.getId()); |
|---|
| | | wrkDetl.setModiTime(now); |
|---|
| | | wrkDetl.setModiUser(userId); |
|---|
| | | wrkDetl.setModiUser(user.getId()); |
|---|
| | | if (!wrkDetlService.insert(wrkDetl)) { |
|---|
| | | throw new CoolException("保存工作档明细失败"); |
|---|
| | | } |
|---|
| | | // 修改订单明细 |
|---|
| | | if (!orderDetlService.increaseWorkQty(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), locDto.getAnfme())) { |
|---|
| | | if (!orderDetlService.increaseWorkQty2(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), locDto.getAnfme(), user.getEmail())) { |
|---|
| | | throw new CoolException("修改订单明细数量失败"); |
|---|
| | | } |
|---|
| | | orderService.updateSettle(orderDetl.getOrderId(), 2L, userId); |
|---|
| | | orderService.updateSettle(orderDetl.getOrderId(), 2L, user.getId()); |
|---|
| | | } |
|---|
| | | // 修改库位状态: F.在库 ====>>> R.出库预约/P.拣料/盘点/并板出库中 |
|---|
| | | locMast = locMastService.selectById(taskDto.getLocNo()); |
|---|
| | | if (locMast.getLocSts().equals("F")) { |
|---|
| | | locMast.setLocSts(ioType==101?"R":"P"); |
|---|
| | | locMast.setModiUser(userId); |
|---|
| | | locMast.setModiUser(user.getId()); |
|---|
| | | locMast.setModiTime(now); |
|---|
| | | if (!locMastService.updateById(locMast)) { |
|---|
| | | throw new CoolException("预约库位状态失败，库位号："+taskDto.getLocNo()); |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional |
|---|
| | | public void locCheckOut(StockOutParam param, Long userId) { |
|---|
| | | public void locCheckOut(StockOutParam param, User userId) { |
|---|
| | | |
|---|
| | | // 获取库位明细 |
|---|
| | | List<LocDetlDto> locDetlDtos = new ArrayList<>(); |
|---|
| | |
|---|
| | | Iterator<LocDetlAdjustParam.LocDetlAdjust> iterator1 = list.iterator(); |
|---|
| | | while (iterator1.hasNext()) { |
|---|
| | | LocDetlAdjustParam.LocDetlAdjust adjust = iterator1.next(); |
|---|
| | | if (adjust.getCount() == 0) { continue; } |
|---|
| | | if (adjust.getCount() == 0) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | if (locDetl.getMatnr().equals(adjust.getMatnr()) && Cools.eq(locDetl.getBatch(), adjust.getBatch())) { |
|---|
| | | if (!locDetl.getAnfme().equals(adjust.getCount())) { |
|---|
| | | // todo 盘点记录 |
|---|
| | |
|---|
| | | |
|---|
| | | // 添加库存 |
|---|
| | | for (LocDetlAdjustParam.LocDetlAdjust adjust : list) { |
|---|
| | | if (adjust.getCount() == 0.0D) { continue; } |
|---|
| | | if (adjust.getCount() == 0.0D) { |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | Mat mat = matService.selectByMatnr(adjust.getMatnr()); |
|---|
| | | LocDetl locDetl = new LocDetl(); |
|---|
| | | locDetl.sync(mat); |
|---|
