package com.by4cloud.platformx.business.service.impl;
|
|
import cn.hutool.core.collection.CollUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.by4cloud.platformx.admin.api.entity.SysDept;
|
import com.by4cloud.platformx.admin.api.vo.DeptExcelVO;
|
import com.by4cloud.platformx.business.dto.ContractSubjectMatterAddDTO;
|
import com.by4cloud.platformx.business.entity.ContractSubjectMatter;
|
import com.by4cloud.platformx.business.entity.Product;
|
import com.by4cloud.platformx.business.mapper.ContractSubjectMatterMapper;
|
import com.by4cloud.platformx.business.mapper.ProductMapper;
|
import com.by4cloud.platformx.business.service.ContractSubjectMatterService;
|
import com.by4cloud.platformx.business.vo.ContractSubjectMatterVo;
|
import com.by4cloud.platformx.business.vo.SubjectMatterExcelVO;
|
import com.by4cloud.platformx.common.core.util.R;
|
import com.by4cloud.platformx.common.data.datascope.DataScope;
|
import com.by4cloud.platformx.common.data.mybatis.BaseModel;
|
import com.by4cloud.platformx.common.excel.vo.ErrorMessage;
|
import com.by4cloud.platformx.common.security.util.SecurityUtils;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.validation.BindingResult;
|
|
import java.util.ArrayList;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Set;
|
|
/**
|
* 合同标的物明细表
|
*
|
* @author platformx
|
* @date 2026-04-29 16:39:29
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class ContractSubjectMatterServiceImpl extends ServiceImpl<ContractSubjectMatterMapper, ContractSubjectMatter> implements ContractSubjectMatterService {
|
|
private final ProductMapper productMapper;
|
|
@Override
|
public R selectSubjectMatterProcess(Long id) {
|
MPJLambdaWrapper<ContractSubjectMatter> wrapper = new MPJLambdaWrapper<ContractSubjectMatter>()
|
.selectAll(ContractSubjectMatter.class)
|
.eq(ContractSubjectMatter::getContractId,id)
|
.orderByAsc(ContractSubjectMatter::getCreateTime);
|
List<ContractSubjectMatterVo> matterVoList = baseMapper.selectJoinList(ContractSubjectMatterVo.class,wrapper);
|
return R.ok(matterVoList);
|
}
|
|
@Override
|
public R selectSubjectMatter(Long contractId) {
|
return R.ok(baseMapper.selectListByScope(Wrappers.<ContractSubjectMatter>lambdaQuery().eq(ContractSubjectMatter::getContractId,contractId)
|
.orderByAsc(ContractSubjectMatter::getCreateTime), DataScope.of("comp_id")));
|
}
|
|
@Override
|
public R importSubjectMatter(List<SubjectMatterExcelVO> excelVOList, BindingResult bindingResult) {
|
List<ErrorMessage> errorMessageList = (List<ErrorMessage>) bindingResult.getTarget();
|
List<ContractSubjectMatterAddDTO> addDTOList = new ArrayList<>();
|
for (SubjectMatterExcelVO item : excelVOList) {
|
Set<String> errorMsg = new HashSet<>();
|
|
Product one = productMapper.selectOne(Wrappers.<Product>lambdaQuery()
|
.eq(Product::getErpCode, item.getMaterialCode())
|
.eq(Product::getCompId, SecurityUtils.getUser().getCompId()));
|
|
if (one == null) {
|
errorMsg.add(item.getMaterialCode()+"erp编码不存在");
|
}
|
if (CollUtil.isEmpty(errorMsg)) {
|
ContractSubjectMatterAddDTO addDTO = new ContractSubjectMatterAddDTO();
|
addDTO.setMaterialCode(item.getMaterialCode());
|
addDTO.setMaterialInternalName(one.getProductName());
|
addDTO.setMaterialName(item.getMaterialName());
|
addDTO.setUnitPrice(item.getUnitPrice());
|
addDTO.setQuantity(item.getQuantity());
|
addDTO.setSpecification(one.getProductType());
|
addDTOList.add(addDTO);
|
}
|
else {
|
// 数据不合法情况
|
errorMessageList.add(new ErrorMessage(item.getLineNum(), errorMsg));
|
}
|
}
|
if (CollUtil.isNotEmpty(errorMessageList)) {
|
return R.failed(errorMessageList,"部门导入失败");
|
}
|
return R.ok(addDTOList, "部门导入成功");
|
}
|
|
|
}
|
