From 3c7c28b5e39c59e2bbaf7641e55f39953ae22c8c Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 02 Sep 2025 17:36:00 +0800
Subject: [PATCH] refactor(ai): 优化通义灵码回复内容处理并添加日志输出
---
src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java | 374 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 370 insertions(+), 4 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
index 57ddbee..d5bfefa 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java
@@ -1,5 +1,9 @@
package cc.mrbird.febs.mall.service.impl;
+import cc.mrbird.febs.ai.entity.AiMember;
+import cc.mrbird.febs.ai.mapper.AiMemberMapper;
+import cc.mrbird.febs.ai.utils.UUID;
+import cc.mrbird.febs.common.configure.FebsConfigure;
import cc.mrbird.febs.common.entity.FebsResponse;
import cc.mrbird.febs.common.enumerates.*;
import cc.mrbird.febs.common.exception.FebsException;
@@ -9,13 +13,14 @@
import cc.mrbird.febs.mall.conversion.MallShopApplyConversion;
import cc.mrbird.febs.mall.conversion.MallStoreConversion;
import cc.mrbird.febs.mall.dto.*;
+import cc.mrbird.febs.mall.dto.memberLevel.*;
import cc.mrbird.febs.mall.dto.signActivity.ApiNewGiftSettingDto;
import cc.mrbird.febs.mall.entity.*;
import cc.mrbird.febs.mall.mapper.*;
import cc.mrbird.febs.mall.service.*;
import cc.mrbird.febs.mall.vo.*;
-import cc.mrbird.febs.mall.vo.memberLevel.ApiLabelInfoVo;
-import cc.mrbird.febs.mall.vo.memberLevel.ApiMemberLabelVo;
+import cc.mrbird.febs.mall.vo.memberLevel.*;
+import cc.mrbird.febs.mall.vo.sale.ApiSaleRecordInfoVo;
import cc.mrbird.febs.pay.model.BrandWCPayRequestData;
import cc.mrbird.febs.pay.service.IXcxPayService;
import cc.mrbird.febs.pay.util.MD5;
@@ -24,6 +29,7 @@
import cc.mrbird.febs.vip.mapper.MallVipConfigMapper;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.IdUtil;
@@ -38,6 +44,7 @@
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.RequiredArgsConstructor;
@@ -51,6 +58,7 @@
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
+import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
/**
@@ -62,6 +70,7 @@
@RequiredArgsConstructor
public class ApiMallMemberServiceImpl extends ServiceImpl<MallMemberMapper, MallMember> implements IApiMallMemberService {
+ private final AiMemberMapper aiMemberMapper;
private final MallMemberWalletMapper mallMemberWalletMapper;
private final ICommonService commonService;
private final RedisUtils redisUtils;
@@ -94,6 +103,7 @@
private final IApiMallMemberWalletService mallMemberWalletService;
private final HappyMemberLabelRecordMapper happyMemberLabelRecordMapper;
private final HappyMemberLabelMapper happyMemberLabelMapper;
+ private final FebsConfigure febsConfigure;
@Value("${spring.profiles.active}")
@@ -722,8 +732,14 @@
}
this.baseMapper.insert(mallMember);
+ AiMember aiMember = new AiMember();
+ aiMember.setId(UUID.getSimpleUUIDString());
+ aiMember.setCreatedTime(new Date());
+ aiMemberMapper.insert(aiMember);
+
mallMember = this.baseMapper.selectMemberByOpenId(openId);
String inviteId = ShareCodeUtil.toSerialCode(mallMember.getId());
+ mallMember.setMemberUuid(aiMember.getId());
mallMember.setInviteId(inviteId);
this.baseMapper.updateById(mallMember);
MallMemberWallet wallet = new MallMemberWallet();
@@ -822,7 +838,9 @@
mallMember.setLevel(mallVipConfig.getCode());
}
- mallMember.setSex(1 == apiXcxSaveInfoDto.getGender() ? "女" : "男");
+ if(ObjectUtil.isNotEmpty(apiXcxSaveInfoDto.getGender())){
+ mallMember.setSex(1 == apiXcxSaveInfoDto.getGender() ? "女" : "男");
+ }
this.baseMapper.updateById(mallMember);
// //完善信息赠送新人礼
@@ -1735,12 +1753,15 @@
Set<Long> collect = happyMemberLabelRecords.stream().map(HappyMemberLabelRecord::getLabelId).collect(Collectors.toSet());
List<HappyMemberLabel> happyMemberLabels = happyMemberLabelMapper.selectList(
new LambdaQueryWrapper<HappyMemberLabel>()
- .select(HappyMemberLabel::getIconPng)
+ .select( HappyMemberLabel::getId, HappyMemberLabel::getCode,HappyMemberLabel::getIconPng, HappyMemberLabel::getName, HappyMemberLabel::getContent, HappyMemberLabel::getHeaderPng)
.in(HappyMemberLabel::getId, collect)
+ .orderByDesc(HappyMemberLabel::getCode)
);
if(CollUtil.isNotEmpty(happyMemberLabels)){
for (HappyMemberLabel happyMemberLabel : happyMemberLabels) {
ApiMemberLabelVo apiMemberLabelVo = new ApiMemberLabelVo();
+ apiMemberLabelVo.setId(happyMemberLabel.getId());
+ apiMemberLabelVo.setCode(happyMemberLabel.getCode());
apiMemberLabelVo.setName(happyMemberLabel.getName());
apiMemberLabelVo.setContent(happyMemberLabel.getContent());
apiMemberLabelVo.setHeaderPng(happyMemberLabel.getHeaderPng());
@@ -1753,6 +1774,351 @@
return new FebsResponse().success().data(apiMemberLabelVos);
}
+ @Override
+ public FebsResponse getLabelListById(ApiMemberLabelInfoDto dto) {
+ // 获取当前登录用户的ID
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+
+ List<ApiMemberLabelInfoVo> apiMemberLabelInfoVos = new ArrayList<>();
+
+ HappyMemberLabelRecord happyMemberLabelRecord = happyMemberLabelRecordMapper.selectOne(
+ Wrappers.lambdaQuery(HappyMemberLabelRecord.class)
+ .eq(HappyMemberLabelRecord::getMemberId, memberId)
+ .eq(HappyMemberLabelRecord::getLabelId, dto.getId())
+ );
+ if(ObjectUtil.isEmpty(happyMemberLabelRecord)){
+ throw new FebsException("您没有该会员标签");
+ }
+ HappyMemberLabel happyMemberLabel = happyMemberLabelMapper.selectById(dto.getId());
+ if(ObjectUtil.isEmpty(happyMemberLabel)){
+ throw new FebsException("您没有该会员标签");
+ }
+ if(!ObjectUtil.equal(happyMemberLabel.getCode(),1)){
+ throw new FebsException("没有查看权限");
+ }
+
+ List<HappyMemberLabel> happyMemberLabels = happyMemberLabelMapper.selectList(
+ Wrappers.lambdaQuery(HappyMemberLabel.class)
+ .eq(HappyMemberLabel::getParentId, dto.getId())
+ );
+ if(CollUtil.isNotEmpty(happyMemberLabels)){
+ for (HappyMemberLabel happyMemberLabelItem : happyMemberLabels) {
+ ApiMemberLabelInfoVo apiMemberLabelInfoVo = new ApiMemberLabelInfoVo();
+
+ apiMemberLabelInfoVo.setId(happyMemberLabelItem.getId());
+ apiMemberLabelInfoVo.setName(happyMemberLabelItem.getName());
+ apiMemberLabelInfoVos.add(apiMemberLabelInfoVo);
+ }
+ }
+
+ return new FebsResponse().success().data(apiMemberLabelInfoVos);
+ }
+
+ @Override
+ public FebsResponse scoreRecord(ApiScoreRecordInfoDto dto) {
+ // 初始化结果列表
+ List<ApiScoreRecordInfoVo> apiSaleRecordInfoVos = new ArrayList<>();
+
+ List<HappyMemberLabel> happyMemberLabels = happyMemberLabelMapper.selectList(
+ Wrappers.lambdaQuery(HappyMemberLabel.class)
+ .eq(HappyMemberLabel::getCode, 1)
+ .eq(HappyMemberLabel::getParentId, 0)
+ );
+ if(CollUtil.isEmpty(happyMemberLabels)){
+ return new FebsResponse().success().data(apiSaleRecordInfoVos);
+ }
+
+ // 获取类型参数
+ Integer type = dto.getType();
+ // 校验类型参数，确保其为1（月）或2（周）
+ if (type == null || (type != 1 && type != 2 && type != 3)) {
+ return new FebsResponse().fail().message("非法的类型参数");
+ }
+ DateTime startTime = DateUtil.beginOfMonth(new Date());
+ if(1 == type){
+ startTime = DateUtil.beginOfMonth(new Date());
+ }
+ if(2 == type){
+ startTime = DateUtil.beginOfWeek(new Date());
+ }
+ if(3 == type){
+ startTime = DateUtil.beginOfYear(new Date());
+ }
+
+ // 合并查询所有子标签
+ Set<Long> parentIds = happyMemberLabels.stream()
+ .map(HappyMemberLabel::getId)
+ .collect(Collectors.toSet());
+
+ List<HappyMemberLabel> allChildLabels = happyMemberLabelMapper.selectList(
+ Wrappers.lambdaQuery(HappyMemberLabel.class)
+ .in(HappyMemberLabel::getParentId, parentIds)
+ );
+
+ Map<Long, List<HappyMemberLabel>> childLabelMap = new HashMap<>();
+ if (CollUtil.isNotEmpty(allChildLabels)) {
+ childLabelMap = allChildLabels.stream()
+ .collect(Collectors.groupingBy(HappyMemberLabel::getParentId));
+ }
+
+ // 提取所有子标签 ID
+ Set<Long> labelIds = allChildLabels.stream()
+ .map(HappyMemberLabel::getId)
+ .collect(Collectors.toSet());
+
+ // 获取所有绑定关系
+ List<HappyMemberLabelRecord> labelRecords = CollUtil.isEmpty(labelIds) ? Collections.emptyList() :
+ happyMemberLabelRecordMapper.selectList(
+ Wrappers.lambdaQuery(HappyMemberLabelRecord.class)
+ .in(HappyMemberLabelRecord::getLabelId, labelIds)
+ );
+
+ Map<Long, Set<Long>> labelToMembersMap = new HashMap<>();
+ if (CollUtil.isNotEmpty(labelRecords)) {
+ labelToMembersMap = labelRecords.stream()
+ .collect(Collectors.groupingBy(
+ HappyMemberLabelRecord::getLabelId,
+ Collectors.mapping(HappyMemberLabelRecord::getMemberId, Collectors.toSet())
+ ));
+ }
+
+ Set<Long> memberIds = labelToMembersMap.values().stream()
+ .flatMap(Set::stream)
+ .collect(Collectors.toSet());
+
+ // 获取资金流
+ List<MallMoneyFlow> moneyFlows = CollUtil.isEmpty(memberIds) ? Collections.emptyList() :
+ mallMoneyFlowMapper.selectList(
+ Wrappers.lambdaQuery(MallMoneyFlow.class)
+ .select(MallMoneyFlow::getAmount, MallMoneyFlow::getMemberId)
+ .in(MallMoneyFlow::getMemberId, memberIds)
+ .eq(MallMoneyFlow::getFlowType, FlowTypeEnum.PRIZE_SCORE.getValue())
+ .gt(MallMoneyFlow::getAmount, BigDecimal.ZERO)
+ .ge(MallMoneyFlow::getCreatedTime, startTime)
+ );
+
+ Map<Long, BigDecimal> memberScoreMap = new HashMap<>();
+ if (CollUtil.isNotEmpty(moneyFlows)) {
+ memberScoreMap = moneyFlows.stream()
+ .collect(Collectors.groupingBy(
+ MallMoneyFlow::getMemberId,
+ Collectors.mapping(MallMoneyFlow::getAmount, Collectors.reducing(BigDecimal.ZERO, BigDecimal::add))
+ ));
+ }
+
+ List<CompletableFuture<ApiScoreRecordInfoVo>> futures = new ArrayList<>();
+
+ Map<Long, List<HappyMemberLabel>> finalChildLabelMap = childLabelMap;
+ Map<Long, Set<Long>> finalLabelToMembersMap = labelToMembersMap;
+ Map<Long, BigDecimal> finalMemberScoreMap = memberScoreMap;
+ happyMemberLabels.forEach(item -> {
+ CompletableFuture<ApiScoreRecordInfoVo> uCompletableFuture = CompletableFuture.supplyAsync(() -> {
+ ApiScoreRecordInfoVo vo = new ApiScoreRecordInfoVo();
+ vo.setName(item.getName());
+ vo.setAvatar(item.getIconPng());
+ vo.setScore(BigDecimal.ZERO);
+
+ List<HappyMemberLabel> children = finalChildLabelMap.getOrDefault(item.getId(), Collections.emptyList());
+ if (CollUtil.isEmpty(children)) {
+ return vo;
+ }
+
+ Set<Long> childIds = children.stream().map(HappyMemberLabel::getId).collect(Collectors.toSet());
+ Set<Long> members = new HashSet<>();
+ for (Long childId : childIds) {
+ Set<Long> ids = finalLabelToMembersMap.getOrDefault(childId, Collections.emptySet());
+ members.addAll(ids);
+ }
+
+ if (CollUtil.isEmpty(members)) {
+ return vo;
+ }
+
+ BigDecimal total = BigDecimal.ZERO;
+ for (Long memberId : members) {
+ total = total.add(finalMemberScoreMap.getOrDefault(memberId, BigDecimal.ZERO));
+ }
+ vo.setScore(total.setScale(0, RoundingMode.DOWN));
+ return vo;
+ }, febsConfigure.asyncThreadPoolTaskExecutor()).exceptionally(ex -> {
+ // 异常兜底返回默认值
+ ApiScoreRecordInfoVo vo = new ApiScoreRecordInfoVo();
+ vo.setName(item.getName());
+ vo.setAvatar(item.getIconPng());
+ vo.setScore(BigDecimal.ZERO);
+ return vo;
+ });
+
+ futures.add(uCompletableFuture);
+ });
+ // 等待所有任务完成
+ CompletableFuture<Void> allOf = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));
+ allOf.join(); // 阻塞直到所有任务完成
+
+ //等任务结束，获取返回结果
+ apiSaleRecordInfoVos = futures.stream()
+ .map(CompletableFuture::join)
+ .sorted(Comparator.comparing(ApiScoreRecordInfoVo::getScore).reversed())
+ .collect(Collectors.toList());
+
+
+ // 返回成功响应，包含销售记录信息
+ return new FebsResponse().success().data(apiSaleRecordInfoVos);
+ }
+
+ @Override
+ public FebsResponse getMemberLabelListById(ApiMemberLabelItemDto dto) {
+
+ // 获取当前登录用户的ID
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+
+ List<ApiMemberLabelItemVo> apiMemberLabelItemVos = new ArrayList<>();
+
+ Integer labelId = dto.getLabelId();
+ List<HappyMemberLabelRecord> happyMemberLabelRecords = happyMemberLabelRecordMapper.selectList(
+ Wrappers.lambdaQuery(HappyMemberLabelRecord.class)
+ .eq(HappyMemberLabelRecord::getLabelId, labelId)
+ );
+ if(CollUtil.isNotEmpty(happyMemberLabelRecords)){
+
+ //stream流操作happyMemberLabelRecords,返回memberId的set集合
+ Set<Long> memberIdSet = happyMemberLabelRecords.stream().map(HappyMemberLabelRecord::getMemberId).collect(Collectors.toSet());
+ List<MallMember> mallMembers = this.baseMapper.selectList(
+ Wrappers.lambdaQuery(MallMember.class)
+ .select(MallMember::getId, MallMember::getName, MallMember::getPhone, MallMember::getAvatar)
+ .in(MallMember::getId, memberIdSet)
+ .eq(MallMember::getAccountStatus, MallMember.ACCOUNT_STATUS_ENABLE)
+ );
+
+ List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowMapper.selectList(
+ Wrappers.lambdaQuery(MallMoneyFlow.class)
+ .select(MallMoneyFlow::getAmount, MallMoneyFlow::getMemberId)
+ .in(MallMoneyFlow::getMemberId, memberIdSet)
+ .eq(MallMoneyFlow::getFlowType, FlowTypeEnum.PRIZE_SCORE.getValue())
+ .gt(MallMoneyFlow::getAmount, BigDecimal.ZERO)
+ );
+ //stream流操作mallMoneyFlows,返回一个map<Long,BigDecimal>,其中key为memberId,value为mallMoneyFlow的memberId等于key的amount的总和
+ Map<Long, BigDecimal> prizeScoreMap = mallMoneyFlows.stream()
+ .filter(Objects::nonNull) // 防止 MallMoneyFlow 为 null
+ .collect(Collectors.groupingBy(
+ MallMoneyFlow::getMemberId,
+ Collectors.mapping(
+ MallMoneyFlow::getAmount,
+ Collectors.reducing(BigDecimal.ZERO, BigDecimal::add)
+ )
+ ));
+ for (MallMember mallMember : mallMembers){
+ ApiMemberLabelItemVo apiMemberLabelItemVo = new ApiMemberLabelItemVo();
+ apiMemberLabelItemVo.setName(mallMember.getName());
+ apiMemberLabelItemVo.setAvatar(mallMember.getAvatar());
+ apiMemberLabelItemVo.setPhone(mallMember.getPhone());
+ apiMemberLabelItemVo.setScore(prizeScoreMap.get(mallMember.getId()).setScale(0,RoundingMode.DOWN));
+ apiMemberLabelItemVos.add(apiMemberLabelItemVo);
+ }
+ }
+
+ return new FebsResponse().success().data(apiMemberLabelItemVos);
+ }
+
+ @Override
+ public FebsResponse addLabelMember(ApiMemberLabelAddDto dto) {
+
+ // 获取当前登录用户的ID
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+
+ ApiMemberLabelAddVo apiMemberLabelAddVo = new ApiMemberLabelAddVo();
+
+ Integer labelId = dto.getLabelId();
+ String phone = dto.getPhone();
+
+ List<MallMember> mallMembers = this.baseMapper.selectList(
+ Wrappers.lambdaQuery(MallMember.class)
+ .eq(MallMember::getPhone, phone)
+ );
+ if(CollUtil.isEmpty(mallMembers)){
+ throw new FebsException("未查询到用户");
+ }
+
+ MallMember mallMember = mallMembers.get(0);
+ apiMemberLabelAddVo.setMemberId(mallMember.getId());
+ apiMemberLabelAddVo.setName(mallMember.getName());
+ apiMemberLabelAddVo.setPhone(mallMember.getPhone());
+
+ HappyMemberLabel happyMemberLabel = happyMemberLabelMapper.selectById(labelId);
+ apiMemberLabelAddVo.setLabelId(happyMemberLabel.getId());
+ apiMemberLabelAddVo.setLabelName(happyMemberLabel.getName());
+
+ //获取会员标签
+ Integer integer = happyMemberLabelRecordMapper.selectCount(
+ Wrappers.lambdaQuery(HappyMemberLabelRecord.class)
+ .eq(HappyMemberLabelRecord::getMemberId, mallMember.getId())
+ .eq(HappyMemberLabelRecord::getLabelId, labelId)
+ );
+ if(integer > 0){
+ apiMemberLabelAddVo.setState(0);
+ }else{
+ apiMemberLabelAddVo.setState(1);
+ }
+ return new FebsResponse().success().data(apiMemberLabelAddVo);
+ }
+
+ @Override
+ public FebsResponse insureLabelMember(ApiMemberLabelInsureDto dto) {
+
+ // 获取当前登录用户的ID
+ Long memberId = LoginUserUtil.getLoginUser().getId();
+ Long labelId = dto.getLabelId();
+ Long insureMemberId = dto.getMemberId();
+
+ List<HappyMemberLabelRecord> happyMemberLabelRecords1 = happyMemberLabelRecordMapper.selectList(Wrappers.lambdaQuery(HappyMemberLabelRecord.class)
+ .eq(HappyMemberLabelRecord::getMemberId, insureMemberId)
+ );
+ if(CollUtil.isNotEmpty(happyMemberLabelRecords1)){
+ throw new FebsException("该用户不能重复加入");
+ }
+
+ HappyMemberLabel happyMemberLabel = happyMemberLabelMapper.selectById(labelId);
+ if(ObjectUtil.isEmpty(happyMemberLabel)){
+ throw new FebsException("会员标签不存在");
+ }
+ if(happyMemberLabel.getParentId() == 0){
+ throw new FebsException("会员标签不存在");
+ }
+
+ Long parentId = happyMemberLabel.getParentId();
+ HappyMemberLabel happyMemberLabelParent = happyMemberLabelMapper.selectById(parentId);
+ if(ObjectUtil.isEmpty(happyMemberLabelParent)){
+ throw new FebsException("会员标签不存在");
+ }
+ if(happyMemberLabelParent.getCode() != 1){
+ throw new FebsException("权限不足");
+ }
+
+ List<HappyMemberLabelRecord> happyMemberLabelRecordsParent = happyMemberLabelRecordMapper.selectList(
+ Wrappers.lambdaQuery(HappyMemberLabelRecord.class)
+ .eq(HappyMemberLabelRecord::getMemberId, memberId)
+ .eq(HappyMemberLabelRecord::getLabelId, parentId)
+ );
+ if(ObjectUtil.isEmpty(happyMemberLabelRecordsParent)){
+ throw new FebsException("权限不足");
+ }
+
+
+ List<HappyMemberLabelRecord> happyMemberLabelRecords = happyMemberLabelRecordMapper.selectList(
+ Wrappers.lambdaQuery(HappyMemberLabelRecord.class)
+ .eq(HappyMemberLabelRecord::getMemberId, insureMemberId)
+ .eq(HappyMemberLabelRecord::getLabelId, labelId)
+ );
+ if(CollUtil.isEmpty(happyMemberLabelRecords)){
+ HappyMemberLabelRecord happyMemberLabelRecord = new HappyMemberLabelRecord();
+ happyMemberLabelRecord.setMemberId(insureMemberId);
+ happyMemberLabelRecord.setLabelId(labelId);
+ happyMemberLabelRecordMapper.insert(happyMemberLabelRecord);
+ }
+
+ return new FebsResponse().success().message("操作成功");
+ }
+
// public static void main(String[] args) {
// Long userld = 16425L;
// String shopAccount = "爱和美医疗";
--
Gitblit v1.9.1