package com.ruoyi.system.service.impl;
|
|
import cn.afterturn.easypoi.excel.ExcelImportUtil;
|
import cn.afterturn.easypoi.excel.entity.ImportParams;
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.collection.CollUtil;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.google.common.collect.Sets;
|
import com.ruoyi.common.exception.ServiceException;
|
import com.ruoyi.system.dto.TIntegralSettlementDTO;
|
import com.ruoyi.system.export.IntegralSettlementImport;
|
import com.ruoyi.system.model.TAppUser;
|
import com.ruoyi.system.model.TIntegralSettlement;
|
import com.ruoyi.system.mapper.TIntegralSettlementMapper;
|
import com.ruoyi.system.query.TIntegralSettlementQuery;
|
import com.ruoyi.system.service.TAppUserService;
|
import com.ruoyi.system.service.TIntegralSettlementService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.system.vo.TIntegralSettlementVO;
|
import lombok.Cleanup;
|
import lombok.RequiredArgsConstructor;
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import java.io.InputStream;
|
import java.util.Collections;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 积分结算记录 服务实现类
|
* </p>
|
*
|
* @author xiaochen
|
* @since 2025-12-08
|
*/
|
@Service
|
@RequiredArgsConstructor(onConstructor_ = @Lazy)
|
public class TIntegralSettlementServiceImpl extends ServiceImpl<TIntegralSettlementMapper, TIntegralSettlement> implements TIntegralSettlementService {
|
private final TAppUserService appUserService;
|
@Override
|
public Page<TIntegralSettlementVO> getSettlementPageList(TIntegralSettlementQuery query) {
|
Page<TIntegralSettlementVO> page = new Page<>(query.getPageNum(), query.getPageSize());
|
page.setRecords(baseMapper.selectSettlementPageList(page, query));
|
return page;
|
}
|
|
@Override
|
public void importData(MultipartFile file, TIntegralSettlementDTO dto) {
|
try {
|
ImportParams importParams = new ImportParams();
|
importParams.setTitleRows(0);
|
importParams.setHeadRows(1);
|
@Cleanup
|
InputStream inputStream = file.getInputStream();
|
List<IntegralSettlementImport> list = ExcelImportUtil.importExcel(inputStream, IntegralSettlementImport.class, importParams);
|
// 保存主表
|
Map<String, Integer> allAppUserIdMap = getAllAppUserIdMap(list);
|
List<TIntegralSettlement> saveList = list.stream().map(item -> {
|
TIntegralSettlement model = new TIntegralSettlement();
|
model.setAppUserId(allAppUserIdMap.get(item.getCode()));
|
model.setTotalSettlementIntegral(item.getTotalSettlementIntegral());
|
model.setRemark(item.getRemark());
|
return model;
|
}).collect(Collectors.toList());
|
saveBatch(saveList);
|
} catch (Exception e) {
|
throw new RuntimeException(e);
|
}
|
}
|
|
private Map<String, Integer> getAllAppUserIdMap(List<IntegralSettlementImport> list) {
|
Set<String> codeList = list.stream().map(IntegralSettlementImport::getCode).collect(Collectors.toSet());
|
if (CollUtil.isNotEmpty(codeList)) {
|
List<TAppUser> appUserList = appUserService.lambdaQuery().in(TAppUser::getCode, codeList)
|
.ne(TAppUser::getStatus, 3).list();
|
Set<String> existCodeList = appUserList.stream().map(TAppUser::getCode).collect(Collectors.toSet());
|
Sets.SetView<String> difference = Sets.difference(codeList, existCodeList);
|
if (CollUtil.isNotEmpty(difference)) {
|
throw new ServiceException("推荐码不存在或已停用：" + String.join(",", difference));
|
}
|
Map<String, Integer> appUserIdMap = appUserList.stream().collect(Collectors.toMap(TAppUser::getCode, TAppUser::getId));
|
return appUserIdMap;
|
}
|
return Collections.emptyMap();
|
}
|
}
|
