package com.vincent.rsf.server.manager.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import com.vincent.rsf.framework.common.R;
|
import com.vincent.rsf.framework.exception.CoolException;
|
import com.vincent.rsf.server.manager.controller.params.ReviseLogParams;
|
import com.vincent.rsf.server.manager.entity.*;
|
import com.vincent.rsf.server.manager.enums.CommonExceStatus;
|
import com.vincent.rsf.server.manager.enums.OrderType;
|
import com.vincent.rsf.server.manager.enums.OrderWorkType;
|
import com.vincent.rsf.server.manager.mapper.ReviseLogMapper;
|
import com.vincent.rsf.server.manager.service.*;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.Set;
|
import java.util.stream.Collectors;
|
|
@Service("reviseLogService")
|
public class ReviseLogServiceImpl extends ServiceImpl<ReviseLogMapper, ReviseLog> implements ReviseLogService {
|
|
@Autowired
|
private LocReviseService locReviseService;
|
|
@Autowired
|
private ReviseLogService reviseLogService;
|
|
@Autowired
|
private LocItemService locItemService;
|
|
@Autowired
|
private LocService locService;
|
|
@Autowired
|
private ReviseLogItemService reviseLogItemService;
|
|
/**
|
* 库存调整单明细添加
|
*
|
* @param revise
|
* @param loginUserId
|
* @return
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public List<ReviseLog> reviseLoc(ReviseLogParams revise, Long loginUserId) {
|
LocRevise locRevise = locReviseService.getById(revise.getReviseId());
|
if (Objects.isNull(locRevise)) {
|
throw new CoolException("调整单据不存在！！");
|
}
|
List<ReviseLog> items = revise.getItems();
|
if (items.isEmpty()) {
|
throw new CoolException("调整单明细参数为空！！");
|
}
|
items.forEach(item -> {
|
ReviseLog reviseLog = new ReviseLog();
|
BeanUtils.copyProperties(item, reviseLog);
|
reviseLog.setAreaId(locRevise.getAreaId())
|
.setReviseId(locRevise.getId())
|
.setCreateBy(loginUserId)
|
.setUpdateBy(loginUserId)
|
.setReviseCode(locRevise.getCode());
|
if (!reviseLogService.save(reviseLog)) {
|
throw new CoolException("调整单明细保存失败！！");
|
}
|
|
List<LocItem> locItems = locItemService.list(new LambdaQueryWrapper<LocItem>()
|
.eq(LocItem::getLocCode, item.getLocCode()));
|
if (!locItems.isEmpty()) {
|
locItems.forEach(ote -> {
|
ReviseLogItem logItem = new ReviseLogItem();
|
BeanUtils.copyProperties(ote, logItem);
|
logItem.setReviseLogId(reviseLog.getId());
|
if (!reviseLogItemService.save(logItem)) {
|
throw new CoolException("明细保存失败！！");
|
}
|
});
|
}
|
|
Double sum = locItems.stream().mapToDouble(LocItem::getAnfme).sum();
|
|
locRevise.setAnfme(Math.round((sum + locRevise.getAnfme()) * 10000) / 10000.0);
|
});
|
|
locRevise.setExceStatus(CommonExceStatus.COMMON_EXCE_STATUS_UN_EXCE.val);
|
|
if (!locReviseService.updateById(locRevise)) {
|
throw new CoolException("状态更新失败！！");
|
}
|
return items;
|
}
|
|
/**
|
* @author Ryan
|
* @date 2025/8/18
|
* @description: 确认调整库存
|
* @version 1.0
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public R complete(Long id, Long loginUserId) {
|
LocRevise revise = locReviseService.getById(id);
|
if (Objects.isNull(revise)) {
|
throw new CoolException("调整单不存在！！");
|
}
|
if (!revise.getExceStatus().equals(CommonExceStatus.COMMON_EXCE_STATUS_EXCE_ING.val)) {
|
throw new CoolException("单据状态未执行或已完成，无法执行完成操作！！");
|
}
|
List<ReviseLog> logs = reviseLogService.list(new LambdaQueryWrapper<ReviseLog>().eq(ReviseLog::getReviseId, revise.getId()));
|
if (logs.isEmpty()) {
|
throw new CoolException("库存日志不存在！！");
|
}
|
Set<Long> longs = logs.stream().map(ReviseLog::getId).collect(Collectors.toSet());
|
List<ReviseLogItem> logItems = reviseLogItemService.list(new LambdaQueryWrapper<ReviseLogItem>().in(ReviseLogItem::getReviseLogId, longs));
|
if (logItems.isEmpty()) {
|
throw new CoolException("调整明细为空!!");
|
}
|
Map<Long, List<ReviseLogItem>> listMap = logItems.stream().collect(Collectors.groupingBy(ReviseLogItem::getLocId));
|
listMap.keySet().forEach(items -> {
|
Loc loc = locService.getById(items);
|
if (Objects.isNull(loc)) {
|
throw new CoolException("库位不存在！！");
|
}
|
List<LocItem> list = locItemService.list(new LambdaQueryWrapper<LocItem>().eq(LocItem::getLocId, loc.getId()));
|
if (!list.isEmpty()) {
|
throw new CoolException("库位:" + loc.getCode() + ", 调整信息为空！！");
|
}
|
locItemService.remove(new LambdaQueryWrapper<LocItem>().eq(LocItem::getLocId, loc.getId()));
|
listMap.get(items).forEach(logItem -> {
|
LocItem locDetl = new LocItem();
|
BeanUtils.copyProperties(logItem, locDetl);
|
locDetl.setLocId(loc.getId())
|
.setType(OrderType.ORDER_REVISE.type)
|
.setWkType(Short.parseShort(OrderWorkType.ORDER_WORK_TYPE_STOCK_REVISE.type))
|
.setLocCode(loc.getCode())
|
.setAnfme(logItem.getReviseQty())
|
.setUpdateBy(loginUserId)
|
.setId(null)
|
.setCreateBy(loginUserId);
|
if (!locItemService.save(locDetl)) {
|
throw new CoolException("库存明细保存失败！！");
|
}
|
});
|
});
|
revise.setExceStatus(CommonExceStatus.COMMON_EXCE_STATUS_TASK_DONE.val);
|
if (!locReviseService.updateById(revise)) {
|
throw new CoolException("调整单修改失败！！");
|
}
|
return R.ok();
|
}
|
}
|
