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