From 85069103bd0b1a801924c660daad78aedd0bfb6c Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 18 Sep 2025 16:52:52 +0800
Subject: [PATCH] ``` feat(AiMemberTalkStreamService): 添加answerV3方法以支持流式生成报告

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallMemberServiceImpl.java |   28 +++++++++++++++++++++++++++-
 1 files changed, 27 insertions(+), 1 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 2ff0da9..2709a51 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
@@ -2,6 +2,7 @@
 
 import cc.mrbird.febs.ai.entity.AiMember;
 import cc.mrbird.febs.ai.mapper.AiMemberMapper;
+import cc.mrbird.febs.ai.service.AiMemberService;
 import cc.mrbird.febs.ai.utils.UUID;
 import cc.mrbird.febs.common.configure.FebsConfigure;
 import cc.mrbird.febs.common.entity.FebsResponse;
@@ -104,6 +105,7 @@
     private final HappyMemberLabelRecordMapper happyMemberLabelRecordMapper;
     private final HappyMemberLabelMapper happyMemberLabelMapper;
     private final FebsConfigure febsConfigure;
+    private final AiMemberService aiMemberService;
 
 
     @Value("${spring.profiles.active}")
@@ -734,13 +736,20 @@
 
                     AiMember aiMember = new AiMember();
                     aiMember.setId(UUID.getSimpleUUIDString());
+                    if (StrUtil.isNotEmpty(apiXcxLoginDto.getCompanyId())){
+                        aiMember.setCompanyId(apiXcxLoginDto.getCompanyId());
+                    }
                     aiMember.setCreatedTime(new Date());
                     aiMemberMapper.insert(aiMember);
 
                     mallMember = this.baseMapper.selectMemberByOpenId(openId);
                     String inviteId = ShareCodeUtil.toSerialCode(mallMember.getId());
                     mallMember.setMemberUuid(aiMember.getId());
+                    if (StrUtil.isNotEmpty(aiMember.getCompanyId())){
+                        mallMember.setCompanyId(aiMember.getCompanyId());
+                    }
                     mallMember.setInviteId(inviteId);
+                    mallMember.setName("新用户"+inviteId);
                     this.baseMapper.updateById(mallMember);
                     MallMemberWallet wallet = new MallMemberWallet();
                     wallet.setBalance(BigDecimal.ZERO);
@@ -838,9 +847,26 @@
             mallMember.setLevel(mallVipConfig.getCode());
         }
 
-        mallMember.setSex(1 == apiXcxSaveInfoDto.getGender() ? "女" : "男");
+        if(ObjectUtil.isNotEmpty(apiXcxSaveInfoDto.getGender())){
+            mallMember.setSex(1 == apiXcxSaveInfoDto.getGender() ? "女" : "男");
+        }
+
+        if(ObjectUtil.isNotEmpty(apiXcxSaveInfoDto.getCompanyId())){
+            mallMember.setCompanyId(apiXcxSaveInfoDto.getCompanyId());
+        }
         this.baseMapper.updateById(mallMember);
 
+        String memberUuid = mallMember.getMemberUuid();
+        AiMember aiMember = aiMemberService.getById(memberUuid);
+        if (ObjectUtil.isNotEmpty(aiMember) && StrUtil.isNotEmpty(apiXcxSaveInfoDto.getCompanyId())){
+            aiMemberService.update(null,
+                    Wrappers.lambdaUpdate(AiMember.class)
+                    .set(AiMember::getCompanyId, aiMember.getCompanyId())
+                    .eq(AiMember::getId, aiMember.getId())
+                    );
+        }
+
+
 //        //完善信息赠送新人礼
 //        if (StrUtil.isNotBlank(mallMember.getPhone()) && mallMember.getNewGift() == 0) {
 //            DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(

--
Gitblit v1.9.1