From fc772cecd6b662204909b37c7a68e9e9906e0d57 Mon Sep 17 00:00:00 2001
From: “mitao” <“2763622819@qq.com”>
Date: 星期一, 22 十二月 2025 18:05:26 +0800
Subject: [PATCH] feat：管理后台积分结算接口
---
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TIntegralSettlementServiceImpl.java | 71 +++++++++++++++++++++++++++++++++++
1 files changed, 71 insertions(+), 0 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TIntegralSettlementServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TIntegralSettlementServiceImpl.java
index b264fcf..5929deb 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TIntegralSettlementServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/TIntegralSettlementServiceImpl.java
@@ -1,10 +1,34 @@
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>
@@ -15,6 +39,53 @@
* @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();
+ }
}
--
Gitblit v1.7.1