package com.gkhy.exam.system.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
|
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.utils.PageUtils;
|
import com.gkhy.exam.common.utils.SecurityUtils;
|
import com.gkhy.exam.system.domain.DocumentBorrowCopy;
|
import com.gkhy.exam.system.domain.DocumentBorrowCopyRecord;
|
import com.gkhy.exam.system.domain.DocumentDistributionCollection;
|
import com.gkhy.exam.system.domain.DocumentDistributionCollectionRecord;
|
import com.gkhy.exam.system.mapper.DocumentDistributionCollectionMapper;
|
import com.gkhy.exam.system.mapper.DocumentDistributionCollectionRecordMapper;
|
import com.gkhy.exam.system.service.DocumentDistributionCollectionService;
|
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-25 15:01:44
|
*/
|
@Service
|
public class DocumentDistributionCollectionServiceImpl extends ServiceImpl<DocumentDistributionCollectionMapper, DocumentDistributionCollection> implements DocumentDistributionCollectionService {
|
|
@Autowired
|
private DocumentDistributionCollectionMapper documentDistributionCollectionMapper;
|
@Autowired
|
private DocumentDistributionCollectionRecordMapper documentDistributionCollectionRecordMapper;
|
@Override
|
public CommonPage selectDocumentDistributionCollectionList(DocumentDistributionCollection documentDistributionCollection) {
|
PageUtils.startPage();
|
List<DocumentDistributionCollection> documentDistributionCollections = documentDistributionCollectionMapper.selectDocumentDistributionCollectionList(documentDistributionCollection);
|
return CommonPage.restPage(documentDistributionCollections);
|
}
|
|
@Override
|
@Transactional
|
public CommonResult saveDocumentDistributionCollection(DocumentDistributionCollection documentDistributionCollection) {
|
List<DocumentDistributionCollectionRecord> documentDistributionCollectionRecordList = documentDistributionCollection.getDocumentDistributionCollectionRecordList();
|
if (ObjectUtils.isEmpty(documentDistributionCollectionRecordList)){
|
return CommonResult.failed("保存参数不能为空");
|
}
|
int i = 0;
|
if (documentDistributionCollection.getId() == null){
|
documentDistributionCollection.setCreateBy(SecurityUtils.getUsername());
|
documentDistributionCollection.setCreateTime(LocalDateTime.now());
|
i = documentDistributionCollectionMapper.insert(documentDistributionCollection);
|
}else {
|
documentDistributionCollection.setUpdateBy(SecurityUtils.getUsername());
|
documentDistributionCollection.setUpdateTime(LocalDateTime.now());
|
i = documentDistributionCollectionMapper.updateById(documentDistributionCollection);
|
}
|
if (i > 0){
|
batchSave(documentDistributionCollection.getId(), documentDistributionCollectionRecordList,documentDistributionCollection.getDeleteIds());
|
}
|
return i > 0 ? CommonResult.success() : CommonResult.failed();
|
}
|
|
private void batchSave(Long id, List<DocumentDistributionCollectionRecord> documentDistributionCollectionRecordList,List<Long> delIds) {
|
if (ObjectUtils.isNotEmpty(delIds)) {
|
int update = documentDistributionCollectionRecordMapper.update(new DocumentDistributionCollectionRecord(),
|
new LambdaUpdateWrapper<DocumentDistributionCollectionRecord>().set(DocumentDistributionCollectionRecord::getDelFlag, UserConstant.DISENABLE)
|
.set(DocumentDistributionCollectionRecord::getUpdateTime, LocalDateTime.now())
|
.set(DocumentDistributionCollectionRecord::getUpdateBy, SecurityUtils.getUsername()).in(DocumentDistributionCollectionRecord::getId, delIds)
|
);
|
}
|
if (ObjectUtils.isNotEmpty(documentDistributionCollectionRecordList)) {
|
documentDistributionCollectionRecordList.forEach(documentDistributionCollectionRecord -> {
|
if (documentDistributionCollectionRecord.getId() == null){
|
documentDistributionCollectionRecord.setDocumentId(id);
|
documentDistributionCollectionRecord.setCreateTime(LocalDateTime.now());
|
documentDistributionCollectionRecord.setCreateBy(SecurityUtils.getUsername());
|
documentDistributionCollectionRecordMapper.insert(documentDistributionCollectionRecord);
|
}else {
|
documentDistributionCollectionRecord.setUpdateTime(LocalDateTime.now());
|
documentDistributionCollectionRecord.setUpdateBy(SecurityUtils.getUsername());
|
documentDistributionCollectionRecordMapper.updateById(documentDistributionCollectionRecord);
|
}
|
|
});
|
}
|
}
|
|
|
|
@Override
|
public CommonResult getDocumentDistributionCollection(Long id) {
|
DocumentDistributionCollection documentDistributionCollection = documentDistributionCollectionMapper.selectById(id);
|
if (documentDistributionCollection != null){
|
List<DocumentDistributionCollectionRecord> documentBorrowCopyRecordList = documentDistributionCollectionRecordMapper.selectList(
|
new LambdaQueryWrapper<>(DocumentDistributionCollectionRecord.class).eq(DocumentDistributionCollectionRecord::getDocumentId, id)
|
.eq(DocumentDistributionCollectionRecord::getDelFlag, UserConstant.ENABLE).orderByAsc(DocumentDistributionCollectionRecord::getSort)
|
);
|
documentDistributionCollection.setDocumentDistributionCollectionRecordList(documentBorrowCopyRecordList);
|
}
|
return CommonResult.success(documentDistributionCollection);
|
}
|
|
@Override
|
@Transactional
|
public CommonResult deletedDocumentDistributionCollection(Long id) {
|
int i = documentDistributionCollectionMapper.update(new DocumentDistributionCollection(),
|
new LambdaUpdateWrapper<DocumentDistributionCollection>().set(DocumentDistributionCollection::getDelFlag, UserConstant.DISENABLE)
|
.set(DocumentDistributionCollection::getUpdateTime, LocalDateTime.now())
|
.set(DocumentDistributionCollection::getUpdateBy, SecurityUtils.getUsername()).eq(DocumentDistributionCollection::getId, id)
|
);
|
if (i > 0){
|
documentDistributionCollectionRecordMapper.update(new DocumentDistributionCollectionRecord(),
|
new LambdaUpdateWrapper<DocumentDistributionCollectionRecord>().set(DocumentDistributionCollectionRecord::getDelFlag, UserConstant.DISENABLE)
|
.set(DocumentDistributionCollectionRecord::getUpdateTime, LocalDateTime.now()).set(DocumentDistributionCollectionRecord::getUpdateBy, SecurityUtils.getUsername())
|
.eq(DocumentDistributionCollectionRecord::getDocumentId, id));
|
}
|
return CommonResult.success();
|
}
|
}
|
