From 33fb9a2fdb0e6cd68a987bbdcbe22ef587fa5813 Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Wed, 17 Sep 2025 16:30:32 +0800 Subject: [PATCH] refactor(mallMember): 修改会员列表中管理员字段的标题 --- src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java | 59 ++++++++++++++++++----------------------------------------- 1 files changed, 18 insertions(+), 41 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java b/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java index 24d05ec..06a3247 100644 --- a/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/ai/service/impl/AiProductQuestionServiceImpl.java @@ -11,6 +11,7 @@ import cc.mrbird.febs.common.entity.QueryRequest; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; @@ -19,6 +20,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.SerializationFeature; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; @@ -52,6 +56,9 @@ public IPage<AiProductQuestion> listInPage(AiProductQuestion dto, QueryRequest request) { Page<AiProductQuestion> page = new Page<>(request.getPageNum(), request.getPageSize()); LambdaQueryWrapper<AiProductQuestion> query = Wrappers.lambdaQuery(AiProductQuestion.class); + if (StrUtil.isNotEmpty(dto.getCompanyId())){ + query.eq(AiProductQuestion::getCompanyId, dto.getCompanyId()); + } query.ne(AiProductQuestion::getState, 2); Page<AiProductQuestion> pages = aiProductQuestionMapper.selectPage(page, query); return pages; @@ -96,6 +103,7 @@ for (AiProductQuestionItem item : dto.getAiProductQuestionItems()){ item.setId(UUID.getSimpleUUIDString()); item.setProductQuestionId(entity.getId()); + item.setCompanyId(dto.getCompanyId()); item.setTitle(entity.getTitle()); item.setCreatedTime(new Date()); aiProductQuestionItemService.getBaseMapper().insert(item); @@ -122,7 +130,6 @@ if (ObjectUtil.isNotNull( entity)){ this.update(null, Wrappers.lambdaUpdate(AiProductQuestion.class) - .set(AiProductQuestion::getCompanyId, dto.getCompanyId()) .set(AiProductQuestion::getProductCategoryId, dto.getProductCategoryId()) .set(AiProductQuestion::getTitle, dto.getTitle()) .set(AiProductQuestion::getDifficulty, dto.getDifficulty()) @@ -158,9 +165,13 @@ } @Override - public List<AiProductQuestion> questionTree() { + public List<AiProductQuestion> questionTree(String companyId) { + LambdaQueryWrapper<AiProductQuestion> query = Wrappers.lambdaQuery(AiProductQuestion.class); + if (StrUtil.isNotEmpty(companyId)){ + query.eq(AiProductQuestion::getCompanyId, companyId); + } - return aiProductQuestionMapper.selectList(null); + return aiProductQuestionMapper.selectList(query); } @Override @@ -174,6 +185,7 @@ String jsonFormat = "{\"question_list\":[{\"title\": \"消费者对透明质酸的主要担忧是什么?\",\"answer_list\":[{\"answer\": \"消费者担心透明质酸维持时间短,效果不明显。\",\"type\": 1,\"analysis\": \"\"},{\"answer\": \"消费者担心透明质酸注射后可能出现移位、凹陷、馒化、僵硬以及炎症反应。\",\"type\": 1,\"analysis\": \"\"},{\"answer\": \"消费者的主要担忧包括效果不明显、维持时间短、注射后出现移位、凹陷、馒化、僵硬以及炎症反应。他们希望既达到理想效果,又避免这些副作用。\",\"type\": 2,\"analysis\": \"标准答案涵盖了消费者对透明质酸的所有主要担忧,既包括效果问题,也涵盖副作用风险,全面反映消费者心理需求。\"}]}]} "; dto.setJsonFormat(jsonFormat); String questionAndAnswerStr = aiService.llmInvokeNonStreaming(dto); + System.out.println(questionAndAnswerStr); // 解析AI返回的结果 List<JSONObject> questionList = parseAiQuestionResponse(questionAndAnswerStr); @@ -186,6 +198,7 @@ AiProductQuestion aiProductQuestion = new AiProductQuestion(); aiProductQuestion.setId(UUID.getSimpleUUIDString()); + aiProductQuestion.setCompanyId(dto.getCompanyId()); aiProductQuestion.setProductCategoryId(productCategoryId); aiProductQuestion.setTitle(title); aiProductQuestion.setDifficulty(difficulty); @@ -201,6 +214,7 @@ System.out.println("分析: " + answer.getStr("analysis")); AiProductQuestionItem aiProductQuestionItem = new AiProductQuestionItem(); aiProductQuestionItem.setId(UUID.getSimpleUUIDString()); + aiProductQuestionItem.setCompanyId(dto.getCompanyId()); aiProductQuestionItem.setProductQuestionId(aiProductQuestion.getId()); aiProductQuestionItem.setTitle(aiProductQuestion.getTitle()); aiProductQuestionItem.setAnswer(answer.getStr("answer")); @@ -230,6 +244,7 @@ String jsonContent = output.replace("<start>", "") .replace("</start>", "") .replace("\\n", "") + .replace("\\n", "") .replace("\\\"", "\"") .trim(); @@ -246,44 +261,6 @@ log.error("解析AI问题响应失败: ", e); throw new RuntimeException("解析AI响应失败", e); } - } - - public static void main(String[] args) { - String questionStr = "{\"output\":\"<start>\\n{\\n \\\"question_list\\\": [\\n {\\n \\\"title\\\": \\\"1. 如何通过菲欧曼品牌背景和价值塑造透明质酸产品的高端形象?\\\",\\n \\\"answer_list\\\": [\\n {\\n \\\"answer\\\": \\\"强调菲欧曼拥有45年历史,是法国第一家医学美容实验室,产品行销全球60多个国家,树立其国际权威形象。\\\",\\n \\\"type\\\": \\\"2\\\",\\n \\\"analysis\\\": \\\"该答案全面结合品牌历史、科研投入及市场影响力,系统塑造高端定位,符合标准答案要求。\\\"\\n },\\n {\\n \\\"answer\\\": \\\"通过讲述菲欧曼产品获得欧盟CE、中国NMPA等国际认证,强调其安全性和合规性。\\\",\\n \\\"type\\\": \\\"1\\\",\\n \\\"analysis\\\": \\\"\\\"\\n },\\n {\\n \\\"answer\\\": \\\"通过明星使用、医生推荐等口碑效应,提升菲欧曼在消费者心中的高端认知。\\\",\\n \\\"type\\\": \\\"1\\\",\\n \\\"analysis\\\": \\\"\\\"\\n }\\n ]\\n }\\n ]\\n}\\n</start>\"}"; - // 第一步:解析外层JSON - JSONObject outerJson = JSONUtil.parseObj(questionStr); - - // 第二步:提取output字段 - String output = outerJson.getStr("output"); - - // 第三步:去除<start>和</start>标签 - String jsonContent = output.replace("<start>", "").replace("</start>", "").trim(); - - // 第四步:解析内部的JSON - JSONObject innerJson = JSONUtil.parseObj(jsonContent); - - // 第五步:提取question_list - JSONArray questionList = innerJson.getJSONArray("question_list"); - - // 遍历问题列表 - for (int i = 0; i < questionList.size(); i++) { - JSONObject question = questionList.getJSONObject(i); - - System.out.println("问题标题: " + question.getStr("title")); - - JSONArray answerList = question.getJSONArray("answer_list"); - System.out.println("答案列表:"); - - // 遍历答案列表 - for (int j = 0; j < answerList.size(); j++) { - JSONObject answer = answerList.getJSONObject(j); - System.out.println(" 答案 " + (j+1) + ": " + answer.getStr("answer")); - System.out.println(" 类型: " + answer.getStr("type")); - System.out.println(" 分析: " + answer.getStr("analysis")); - System.out.println(); - } - } - } } -- Gitblit v1.9.1