From b88073bd09443b82ae8480d27decee95430d5192 Mon Sep 17 00:00:00 2001 From: lxu75 Date: Tue, 18 Mar 2025 14:36:45 +0800 Subject: [PATCH] =?UTF-8?q?=E8=88=86=E6=83=85=E8=87=AA=E5=8A=A8=E5=8C=96?= =?UTF-8?q?=E4=B8=8A=E7=BA=BF=E5=88=86=E6=94=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/AiCompareController.java | 26 -------- .../controller/AiImageCompareController.java | 63 ------------------- .../controller/DataMaskingController.java | 46 -------------- .../center/controller/TestController.java | 29 --------- .../center/mq/CorpusProcessKafkaConsumer.java | 6 +- 5 files changed, 5 insertions(+), 165 deletions(-) delete mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiCompareController.java delete mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiImageCompareController.java delete mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/DataMaskingController.java diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiCompareController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiCompareController.java deleted file mode 100644 index f0a8c3f..0000000 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiCompareController.java +++ /dev/null @@ -1,26 +0,0 @@ -package com.volvo.ai.analytic.center.controller; - -import com.volvo.ai.analytic.center.exception.BizException; -import com.volvo.ai.analytic.center.service.impl.DeepSeekServiceImpl; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; - -@RestController -@RequestMapping("/api/v1") -public class AiCompareController { - - @Autowired - private DeepSeekServiceImpl deepSeekService; - - @GetMapping("/chat1") - public String chat1( @RequestParam(value = "source") String source,@RequestParam(value = "target") String tag ) { - try { - return deepSeekService.chat(source, tag); - } catch (Exception e) { - throw new BizException(e.getMessage()); - } - } -} diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiImageCompareController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiImageCompareController.java deleted file mode 100644 index 2cbd2d8..0000000 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/AiImageCompareController.java +++ /dev/null @@ -1,63 +0,0 @@ -package com.volvo.ai.analytic.center.controller; - -import com.alibaba.fastjson.JSONObject; -import com.obs.services.model.ObsObject; -import com.volvo.ai.analytic.center.feign.DiFyFeign; -import com.volvo.ai.analytic.center.utils.ObsUtil; -import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.*; -import org.springframework.web.multipart.MultipartFile; - -import java.io.*; -import java.util.HashMap; -import java.util.Map; - -@Slf4j -@RestController -@RequestMapping("/dms/run") -public class AiImageCompareController { - - @Autowired - private DiFyFeign diFyFeign; - - @PostMapping("/fileUpload") - public String fileUpload(@RequestHeader(value = "Authorization") String authorization, @RequestBody String filePath) throws IOException { - - JSONObject jsonObjectResult; - try { - ObsObject obsObject = ObsUtil.downloadFile(filePath); - InputStream inputStream = obsObject.getObjectContent(); - MultipartFile file = ObsUtil.getMultipartFile(inputStream, ObsUtil.getFilenameByUrl(filePath)); - JSONObject jsonObjectResult1 = diFyFeign.fileUpload(authorization,file); - ObsObject obsObjectDoc = ObsUtil.downloadFile("file_test/business.docx"); - InputStream inputStreamDoc = obsObjectDoc.getObjectContent(); - MultipartFile fileDoc = ObsUtil.getMultipartFile(inputStreamDoc, ObsUtil.getFilenameByUrl("file_test/business.docx")); - JSONObject jsonObjectResult2 = diFyFeign.fileUpload(authorization,fileDoc); - JSONObject tpJSon = new JSONObject(); - tpJSon.put("type","image"); - tpJSon.put("transfer_method","local_file"); - tpJSon.put("upload_file_id",jsonObjectResult1.get("id")); - JSONObject mbJsonp = new JSONObject(); - mbJsonp.put("type","document"); - mbJsonp.put("transfer_method","local_file"); - mbJsonp.put("upload_file_id",jsonObjectResult2.get("id")); - Map tpMpMap = new HashMap<>(); - tpMpMap.put("tp",tpJSon); - tpMpMap.put("mb",mbJsonp); - Map reqMap = new HashMap<>(); - reqMap.put("inputs",tpMpMap); - reqMap.put("response_mode","blocking"); - reqMap.put("user","streaming232"); - JSONObject runResultJson = diFyFeign.runWorkflows(authorization,reqMap); - System.out.println("runResultJson:"+runResultJson); - return runResultJson.toJSONString(); - } catch (Exception e) { - log.error("error:{}",e); - } - - return ""; - } - - -} diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/DataMaskingController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/DataMaskingController.java deleted file mode 100644 index 486eb6a..0000000 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/DataMaskingController.java +++ /dev/null @@ -1,46 +0,0 @@ -package com.volvo.ai.analytic.center.controller; - -import com.volvo.ai.analytic.center.constant.Constant; -import com.volvo.ai.analytic.center.dto.req.RunMaskingRuleInput; -import com.volvo.ai.analytic.center.entity.DataMaskingRule; -import com.volvo.ai.analytic.center.service.DataMaskingRuleService; -import com.volvo.common.core.util.ResultMsg; -import io.swagger.annotations.Api; -import io.swagger.annotations.ApiOperation; -import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.util.CollectionUtils; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; - -import java.util.List; - -@RestController -@Api(tags = "ai脱敏类API") -@RequestMapping("/dataMasking") -@Slf4j -public class DataMaskingController { - - @Autowired - private DataMaskingRuleService dataMaskingRuleService; - - @PostMapping("/runMaskingRule") - @ApiOperation(value = "执行文字脱敏") - public ResultMsg runMaskingRule(@RequestBody String contentStr) { - log.info("输入需要脱敏的文字信息为 {}", contentStr); - List maskingRuleItems = dataMaskingRuleService.getDataMaskingRuleListByApplicationChannel(Constant.CHANNEL_DCC); - if (CollectionUtils.isEmpty(maskingRuleItems)){ - log.info("没有找到脱敏规则"); - return ResultMsg.failed("没有找到脱敏规则"); - } - log.info("开始脱敏 {}", contentStr); - RunMaskingRuleInput runMaskingRuleInput = new RunMaskingRuleInput(); - runMaskingRuleInput.setOldStr(contentStr); - runMaskingRuleInput.setDataMaskingRules(maskingRuleItems); - String summaryText = dataMaskingRuleService.runMaskingRule(runMaskingRuleInput); - log.info("脱敏结果 {}", summaryText); - return ResultMsg.ok(summaryText); - } -} diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java index 6f26d61..902fdf7 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/controller/TestController.java @@ -34,38 +34,9 @@ import java.util.Map; @Slf4j public class TestController { - @Autowired - private DiFyFeign diFyFeign; - - @Autowired - private DiFyService diFyService; - - @Autowired - private MqMessageRecordService mqMessageRecordService; - @Autowired private RocketMQTemplate rocketMQTemplate; - @PostMapping("/runWorkflows") - @ApiOperation(value = "测试Dify") - public ResultMsg runWorkflows2(@RequestBody String contentStr) { - //"（1）语音电话（2024-11-09 12:10:57）客服：哎，哎，姚先生，你好打扰到您了，蹦蹦沃沃赛练呢。客户：喂你好。客服：哎，对对，小明那个昨天看了车不要着急走，今天可有时间到店来接待您试驾感受一下呢。客户：我现在已经开工了，我现在没时间过去啊。客服：好的，那等你忙完这段时间好吧。客户：好的，好的，好的好，再见啊。客服：好，那这边先不打扰您，哎，好，再见。"; - JSONObject mbJsonp = new JSONObject(); - mbJsonp.put("type", "image"); - mbJsonp.put("transfer_method", "remote_url"); - mbJsonp.put("imageUrl", "https://newbie-assets.digitalvolvo.com/images/2025/02/21/174011708518185205a49d2aead89b9aa8918c72fe5c08dcc66777df1f9df95535d991fbc8533.1740117074777.386.png"); - DiFyReq diFyImageReq = new DiFyReq(); - diFyImageReq.setUser("admin"); - diFyImageReq.setFlowId("app-ZcRTduhbcyu9qzXs2GAnXo0v"); - JSONObject imageInputs = new JSONObject(); - imageInputs.put("image", mbJsonp); - diFyImageReq.setInputs(imageInputs.toJSONString()); - log.info("difyImageReq:{}", JSON.toJSONString(diFyImageReq)); - Object difyResult = diFyService.getDiFyObject(diFyImageReq); - JSONObject dify = JSONObject.parseObject(difyResult.toString()); - return ResultMsg.ok(dify); - } - @PostMapping("/mockMq") diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaConsumer.java index 90596a8..2242cb1 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaConsumer.java @@ -1,3 +1,4 @@ +/* package com.volvo.ai.analytic.center.mq; import com.fasterxml.jackson.databind.ObjectMapper; @@ -15,13 +16,15 @@ import org.springframework.web.bind.annotation.RestController; import java.time.LocalDateTime; +*/ /** * @ClassName CorpusProcessKafkaConsumer * @Description * @Author renzhen * @Date 2025-03-04 10:18 * @Version 1.0 - **/ + **//* + @Slf4j @Component @RestController @@ -56,3 +59,4 @@ public class CorpusProcessKafkaConsumer { } } } +*/