| | |
|---|
| | | import com.vincent.rsf.server.manager.entity.AsnOrder; |
|---|
| | | import com.vincent.rsf.server.manager.entity.AsnOrderItem; |
|---|
| | | import com.vincent.rsf.server.manager.entity.QlyIsptItem; |
|---|
| | | import com.vincent.rsf.server.manager.enums.QlyIsptStatus; |
|---|
| | | import com.vincent.rsf.server.manager.mapper.QlyInspectMapper; |
|---|
| | | import com.vincent.rsf.server.manager.entity.QlyInspect; |
|---|
| | | import com.vincent.rsf.server.manager.service.AsnOrderItemService; |
|---|
| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public R saveSelected(IsptOrderParam param) { |
|---|
| | | public R saveSelected(IsptOrderParam param, Long loginUserId) { |
|---|
| | | if (Objects.isNull(param.getIds()) || param.getIds().isEmpty()) { |
|---|
| | | throw new CoolException("单据ID不能为空！！"); |
|---|
| | | } |
|---|
| | | List<AsnOrder> asnOrders = asnOrderService.list(new LambdaQueryWrapper<AsnOrder>().in(AsnOrder::getId, param.getIds()).eq(AsnOrder::getNtyStatus, 1)); |
|---|
| | | List<AsnOrder> asnOrders = asnOrderService.list(new LambdaQueryWrapper<AsnOrder>().in(AsnOrder::getId, param.getIds()).eq(AsnOrder::getNtyStatus, 0)); |
|---|
| | | if (asnOrders.isEmpty()) { |
|---|
| | | throw new CoolException("单据不存在！！"); |
|---|
| | | } |
|---|
| | |
|---|
| | | throw new CoolException("单据明细不存在！！"); |
|---|
| | | } |
|---|
| | | Map<Long, List<AsnOrderItem>> listMap = orderItems.stream().collect(Collectors.groupingBy(AsnOrderItem::getAsnId)); |
|---|
| | | List<QlyInspect> qlyInspects = new ArrayList<>(); |
|---|
| | | for (AsnOrder asnOrder : asnOrders) { |
|---|
| | | QlyInspect inspect = new QlyInspect(); |
|---|
| | | String ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_INSPECT_CODE, null); |
|---|
| | | if (StringUtils.isBlank(ruleCode)) { |
|---|
| | | throw new CoolException("策略错误：请检查策略「" + SerialRuleCode.SYS_INSPECT_CODE + "」是否设置正确！！"); |
|---|
| | | } |
|---|
| | | inspect.setCode(ruleCode).setWkType(asnOrder.getWkType()).setAsnId(asnOrder.getId()).setCode(asnOrder.getCode()); |
|---|
| | | inspect.setCode(ruleCode) |
|---|
| | | .setWkType(asnOrder.getWkType()) |
|---|
| | | .setIsptStatus(QlyIsptStatus.QLY_ISPT_STAS_ING.val) |
|---|
| | | .setCreateBy(loginUserId) |
|---|
| | | .setAsnId(asnOrder.getId()) |
|---|
| | | .setAsnCode(asnOrder.getCode()); |
|---|
| | | /**获取单据明细*/ |
|---|
| | | List<AsnOrderItem> asnOrderItems = listMap.get(asnOrder.getId()); |
|---|
| | | if (Objects.isNull(asnOrderItems) || asnOrderItems.isEmpty()) { |
|---|
| | |
|---|
| | | QlyIsptItem isptItem = new QlyIsptItem(); |
|---|
| | | BeanUtils.copyProperties(orderItem, isptItem); |
|---|
| | | isptItem.setAsnItemId(orderItem.getId()) |
|---|
| | | .setIspectId(inspect.getId()) |
|---|
| | | .setRcptQty(orderItem.getQty()) |
|---|
| | | .setCreateBy(loginUserId) |
|---|
| | | .setDlyQty(orderItem.getAnfme()); |
|---|
| | | items.add(isptItem); |
|---|
| | | } |
|---|
| | | if (!qlyIsptItemService.saveBatch(items)) { |
|---|
| | | throw new CoolException("明细保存失败！！"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!this.saveBatch(qlyInspects)) { |
|---|
| | | throw new CoolException("质检单保存失败！！"); |
|---|
| | | } |
|---|
| | | return R.ok("保存成功！！"); |
|---|
| | | } |
|---|
