| | |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.StringUtils; |
| | | import com.vincent.rsf.framework.exception.CoolException; |
| | | import com.vincent.rsf.server.manager.controller.params.ReviseLogItemParams; |
| | | import com.vincent.rsf.server.manager.entity.*; |
| | | import com.vincent.rsf.server.manager.enums.CommonExceStatus; |
| | | import com.vincent.rsf.server.manager.mapper.ReviseLogMapper; |
| | | import com.vincent.rsf.server.manager.mapper.ReviseLogItemMapper; |
| | | import com.vincent.rsf.server.manager.service.*; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | |
| | | public class ReviseLogItemServiceImpl extends ServiceImpl<ReviseLogItemMapper, ReviseLogItem> implements ReviseLogItemService { |
| | | |
| | | @Autowired |
| | | private ReviseLogService reviseLogService; |
| | | private ReviseLogMapper reviseLogMapper; |
| | | @Autowired |
| | | private LocItemService locItemService; |
| | | @Autowired |
| | | private LocService locService; |
| | | @Autowired |
| | | private ReviseLogItemService reviseLogItemService; |
| | | @Autowired |
| | | private LocReviseService locReviseService; |
| | | |
| | |
| | | @Override |
| | | @Transactional(timeout = 60, rollbackFor = Exception.class) |
| | | public List<ReviseLogItem> itemSave(ReviseLogItemParams reviseLogItem, Long userId) { |
| | | ReviseLog reviseLog = reviseLogService.getById(reviseLogItem.getReviseLogId()); |
| | | ReviseLog reviseLog = reviseLogMapper.selectById(reviseLogItem.getReviseLogId()); |
| | | if (Objects.isNull(reviseLog)) { |
| | | throw new RuntimeException("库存历史单据不存在!!"); |
| | | } |
| | |
| | | // } |
| | | }); |
| | | |
| | | List<ReviseLog> list = reviseLogService.list(new LambdaQueryWrapper<ReviseLog>().eq(ReviseLog::getReviseId, reviseLog.getReviseId())); |
| | | List<ReviseLog> list = reviseLogMapper.selectList(new LambdaQueryWrapper<ReviseLog>().eq(ReviseLog::getReviseId, reviseLog.getReviseId())); |
| | | if (Objects.isNull(list)) { |
| | | throw new RuntimeException("数据错误:库存调整单不存在!!"); |
| | | } |
| | | List<Long> reviseIds = list.stream().map(ReviseLog::getId).collect(Collectors.toList()); |
| | | List<ReviseLogItem> logItems = reviseLogItemService.list(new LambdaQueryWrapper<ReviseLogItem>() |
| | | List<ReviseLogItem> logItems = this.list(new LambdaQueryWrapper<ReviseLogItem>() |
| | | .in(ReviseLogItem::getReviseLogId, reviseIds)); |
| | | |
| | | Double anfems = logItems.stream().mapToDouble(ReviseLogItem::getAnfme).sum(); |