package com.gkhy.exam.system.service.impl;
|
|
import cn.hutool.core.util.ObjectUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.gkhy.exam.common.api.CommonPage;
|
import com.gkhy.exam.common.api.CommonResult;
|
import com.gkhy.exam.common.constant.UserConstant;
|
import com.gkhy.exam.common.exception.ApiException;
|
import com.gkhy.exam.common.utils.PageUtils;
|
import com.gkhy.exam.common.utils.SecurityUtils;
|
import com.gkhy.exam.system.domain.Material;
|
import com.gkhy.exam.system.domain.OutsourcedUnqualified;
|
import com.gkhy.exam.system.domain.WarehousingRecord;
|
import com.gkhy.exam.system.domain.WarehousingRecordDetails;
|
import com.gkhy.exam.system.mapper.MaterialMapper;
|
import com.gkhy.exam.system.mapper.WarehousingRecordDetailsMapper;
|
import com.gkhy.exam.system.mapper.WarehousingRecordMapper;
|
import com.gkhy.exam.system.service.WarehousingRecordService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
/**
|
* <p>
|
* 出入库记录主表 服务实现类
|
* </p>
|
*
|
* @author hh
|
* @since 2025-08-13 09:16:37
|
*/
|
@Service
|
public class WarehousingRecordServiceImpl extends ServiceImpl<WarehousingRecordMapper, WarehousingRecord> implements WarehousingRecordService {
|
|
@Autowired
|
private WarehousingRecordMapper warehousingRecordMapper;
|
@Autowired
|
private WarehousingRecordDetailsMapper warehousingRecordDetailsMapper;
|
@Autowired
|
private MaterialMapper materialMapper;
|
|
@Override
|
public CommonPage selectWarehousingRecordList(WarehousingRecord warehousingRecord) {
|
PageUtils.startPage();
|
List<WarehousingRecord> warehousingRecords = warehousingRecordMapper.selectWarehousingRecordList(warehousingRecord);
|
warehousingRecords.stream().forEach(item -> {
|
List<WarehousingRecordDetails> de = warehousingRecordDetailsMapper.selectList(
|
new LambdaQueryWrapper<>(WarehousingRecordDetails.class).eq(WarehousingRecordDetails::getRecordId, item.getId())
|
.eq(WarehousingRecordDetails::getDelFlag, UserConstant.ENABLE).orderByAsc(WarehousingRecordDetails::getCreateTime));
|
item.setWarehousingRecordDetails(de);
|
});
|
return CommonPage.restPage(warehousingRecords);
|
}
|
|
@Override
|
public CommonPage selectWarehousingRecordDetailList(WarehousingRecord warehousingRecord) {
|
PageUtils.startPage();
|
List<WarehousingRecordDetails> warehousingRecords = warehousingRecordDetailsMapper.selectWarehousingRecordDetailList(warehousingRecord);
|
return CommonPage.restPage(warehousingRecords);
|
}
|
|
@Override
|
@Transactional
|
public CommonResult saveWarehousingRecord(WarehousingRecord warehousingRecord) {
|
|
List<WarehousingRecordDetails> warehousingRecordDetails = warehousingRecord.getWarehousingRecordDetails();
|
if (ObjectUtil.isEmpty(warehousingRecordDetails)){
|
return CommonResult.validateFailed("请选择入库记录详情");
|
}
|
int i = 0;
|
if (warehousingRecord.getId() == null){
|
warehousingRecord.setCreateTime(LocalDateTime.now());
|
warehousingRecord.setCreateBy(SecurityUtils.getUsername());
|
i = warehousingRecordMapper.insert(warehousingRecord);
|
}else {
|
|
warehousingRecord.setUpdateTime(LocalDateTime.now());
|
warehousingRecord.setUpdateBy(SecurityUtils.getUsername());
|
i = warehousingRecordMapper.updateById(warehousingRecord);
|
}
|
if (i > 0){
|
batchSave(warehousingRecord.getId(), warehousingRecordDetails,warehousingRecord.getDelDetails(),warehousingRecord.getMaterialId(),warehousingRecord.getInventory());
|
}
|
|
|
return CommonResult.success();
|
}
|
|
private void batchSave(Long id, List<WarehousingRecordDetails> warehousingRecordDetails,List<Long> delDetails,Long materialId,int inventory) {
|
|
Material material = materialMapper.selectById(materialId);
|
if (ObjectUtil.isEmpty(material)){
|
throw new ApiException("物料不存在");
|
}
|
warehousingRecordDetails.stream().filter(item -> item.getId() == null).forEach(item -> {
|
item.setRecordId(id);
|
item.setCreateTime(LocalDateTime.now());
|
item.setCreateBy(SecurityUtils.getUsername());
|
warehousingRecordDetailsMapper.insert(item);
|
});
|
warehousingRecordDetails.stream().filter(item -> item.getId() != null).forEach(item -> {
|
item.setRecordId(id);
|
item.setUpdateTime(LocalDateTime.now());
|
item.setUpdateBy(SecurityUtils.getUsername());
|
warehousingRecordDetailsMapper.updateById(item);
|
});
|
if (ObjectUtil.isNotEmpty(delDetails)){
|
warehousingRecordDetailsMapper.update(new WarehousingRecordDetails(),
|
new LambdaUpdateWrapper<WarehousingRecordDetails>().in(WarehousingRecordDetails::getId, delDetails)
|
.set(WarehousingRecordDetails::getDelFlag, UserConstant.DEPT_DISABLE)
|
.set(WarehousingRecordDetails::getUpdateTime, LocalDateTime.now())
|
.set(WarehousingRecordDetails::getUpdateBy, SecurityUtils.getUsername()));
|
}
|
|
materialMapper.update(new Material(),
|
new LambdaUpdateWrapper<Material>().eq(Material::getId, materialId)
|
.set(Material::getInventory, inventory)
|
.set(Material::getUpdateTime, LocalDateTime.now())
|
.set(Material::getUpdateBy, SecurityUtils.getUsername()));
|
|
}
|
|
@Override
|
public CommonResult getWarehousingRecord(Long id) {
|
WarehousingRecord warehousingRecord = warehousingRecordMapper.selectById(id);
|
List<WarehousingRecordDetails > de = warehousingRecordDetailsMapper.selectList(
|
new LambdaQueryWrapper<>(WarehousingRecordDetails.class).eq(WarehousingRecordDetails::getRecordId, id)
|
.eq(WarehousingRecordDetails::getDelFlag, UserConstant.ENABLE).orderByAsc(WarehousingRecordDetails::getCreateTime));
|
warehousingRecord.setWarehousingRecordDetails(de);
|
return CommonResult.success(warehousingRecord);
|
}
|
|
@Override
|
@Transactional
|
public CommonResult deletedWarehousingRecord(Long id) {
|
warehousingRecordMapper.update(new WarehousingRecord(),
|
new LambdaUpdateWrapper<WarehousingRecord>().eq(WarehousingRecord::getId, id)
|
.set(WarehousingRecord::getDelFlag, UserConstant.DEPT_DISABLE)
|
.set(WarehousingRecord::getUpdateTime, LocalDateTime.now())
|
.set(WarehousingRecord::getUpdateBy, SecurityUtils.getUsername()));
|
warehousingRecordDetailsMapper.update(new WarehousingRecordDetails(),
|
new LambdaUpdateWrapper<WarehousingRecordDetails>().eq(WarehousingRecordDetails::getRecordId, id)
|
.set(WarehousingRecordDetails::getDelFlag, UserConstant.DEPT_DISABLE)
|
.set(WarehousingRecordDetails::getUpdateTime, LocalDateTime.now())
|
.set(WarehousingRecordDetails::getUpdateBy, SecurityUtils.getUsername()));
|
return CommonResult.success();
|
}
|
}
|
