测试controller
This commit is contained in:
zhangfan
@@ -0,0 +1,138 @@
|
||||
package com.volvo.ai.analytic.center.controller;
|
||||
|
||||
|
||||
import com.alibaba.fastjson.JSON;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.volvo.ai.analytic.center.dto.req.CallItem;
|
||||
import com.volvo.ai.analytic.center.dto.req.DiFyReq;
|
||||
import com.volvo.ai.analytic.center.dto.req.DiffDefeatanAlysis;
|
||||
import com.volvo.ai.analytic.center.dto.resp.DiffDefeatAnalyseOutputResult;
|
||||
import com.volvo.ai.analytic.center.feign.DiFyFeign;
|
||||
import com.volvo.ai.analytic.center.service.DiFyService;
|
||||
import com.volvo.ai.analytic.center.service.MqMessageRecordService;
|
||||
import com.volvo.common.core.util.ResultMsg;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author wmm
|
||||
* @since 2023-03-14
|
||||
*/
|
||||
@RestController
|
||||
@Api(tags = "社区配置表API", description ="社区配置表")
|
||||
@RequestMapping("/test")
|
||||
public class TestController {
|
||||
|
||||
@Autowired
|
||||
private DiFyFeign diFyFeign;
|
||||
|
||||
@Autowired
|
||||
private DiFyService diFyService;
|
||||
|
||||
@Autowired
|
||||
private MqMessageRecordService mqMessageRecordService;
|
||||
|
||||
@PostMapping("/runWorkflows")
|
||||
@ApiOperation(value = "测试Dify")
|
||||
public ResultMsg<Object> runWorkflows() {
|
||||
Map<String, Object> record = new HashMap<>();
|
||||
record.put("record","（1）语音电话（2024-11-09 12:10:57）客服：哎，哎，姚先生，你好打扰到您了，蹦蹦沃沃赛练呢。客户：喂你好。客服：哎，对对，小明那个昨天看了车不要着急走，今天可有时间到店来接待您试驾感受一下呢。客户：我现在已经开工了，我现在没时间过去啊。客服：好的，那等你忙完这段时间好吧。客户：好的，好的，好的好，再见啊。客服：好，那这边先不打扰您，哎，好，再见。");
|
||||
Map<String, Object> map = new HashMap<>();
|
||||
map.put("inputs",record);
|
||||
map.put("response_mode","blocking");
|
||||
map.put("user","abc-123");
|
||||
return ResultMsg.ok(diFyFeign.runWorkflows("Bearer app-MVGxogM08CDCg7jMo7GNF6eS",map));
|
||||
}
|
||||
|
||||
@PostMapping("/runWorkflows2")
|
||||
@ApiOperation(value = "测试Dify")
|
||||
public ResultMsg<Object> runWorkflows2() {
|
||||
String summaryText = "（1）语音电话（2024-11-09 12:10:57）客服：哎，哎，姚先生，你好打扰到您了，蹦蹦沃沃赛练呢。客户：喂你好。客服：哎，对对，小明那个昨天看了车不要着急走，今天可有时间到店来接待您试驾感受一下呢。客户：我现在已经开工了，我现在没时间过去啊。客服：好的，那等你忙完这段时间好吧。客户：好的，好的，好的好，再见啊。客服：好，那这边先不打扰您，哎，好，再见。";
|
||||
Map<String, Object> record = new HashMap<>();
|
||||
record.put("record",summaryText);
|
||||
DiFyReq diFyReq = new DiFyReq();
|
||||
diFyReq.setUser("voc");
|
||||
diFyReq.setFlowId("app-MVGxogM08CDCg7jMo7GNF6eS");
|
||||
diFyReq.setInputs(record);
|
||||
Object difyResult = diFyService.getDiFyObject(diFyReq);
|
||||
JSONObject dify = JSONObject.parseObject(difyResult.toString());
|
||||
String resultStr = dify.getString("result").replace("\n", "").replaceAll(" ", "");
|
||||
return ResultMsg.ok(resultStr);
|
||||
}
|
||||
|
||||
@PostMapping("/runWorkflows3")
|
||||
@ApiOperation(value = "测试Dify")
|
||||
public ResultMsg<Object> runWorkflows3() {
|
||||
|
||||
List<CallItem> callList = JSON.parseArray("[{\"sessionId\":\"1\",\"sourceId\":\"1\",\"audioTime\":\"2024-11-09 12:10:57\",\"audioBillsec\":\"10\"},{\"sessionId\":\"2\",\"sourceId\":\"2\",\"audioTime\":\"2024-11-09 12:11:57\",\"audioBillsec\":\"20\"}]", CallItem.class);
|
||||
DiffDefeatanAlysis input = new DiffDefeatanAlysis();
|
||||
input.setCallList(callList);
|
||||
DiffDefeatAnalyseOutputResult diffDefeatAnalyseOutputResult = mqMessageRecordService.processChatRecord(input);
|
||||
|
||||
return ResultMsg.ok("");
|
||||
}
|
||||
|
||||
@PostMapping("/runWorkflows4")
|
||||
@ApiOperation(value = "测试Dify")
|
||||
public ResultMsg<Object> runWorkflows4() {
|
||||
|
||||
String input = "{\n" +
|
||||
" \"formId\": \"123456789\",\n" +
|
||||
" \"sinceType\": 2,\n" +
|
||||
" \"subSinceType\": 51,\n" +
|
||||
" \"data\": {\n" +
|
||||
" \"businessId\": \"123456789\",\n" +
|
||||
" \"vdqwUserId\": \"XX\",\n" +
|
||||
" \"vdqwCustomerId\": \"uuid\",\n" +
|
||||
" \"defeatTime\": \"2024-10-27 08:09:09\",\n" +
|
||||
" \"callList\": [{\n" +
|
||||
" \"sessionId\": \"123456789\",\n" +
|
||||
" \"sourceId\": \"123456789\",\n" +
|
||||
" \"audioTime\": \"2024-10-27 08:09:09\",\n" +
|
||||
" \"audioBillsec\": 1800\n" +
|
||||
" }, {\n" +
|
||||
" \"sessionId\": \"123456789\",\n" +
|
||||
" \"sourceId\": \"123456789\",\n" +
|
||||
" \"audioTime\": \"2024-10-27 08:09:09\",\n" +
|
||||
" \"audioBillsec\": 1800\n" +
|
||||
" }]\n" +
|
||||
" }\n" +
|
||||
"}";
|
||||
boolean result = mqMessageRecordService.processMessageByMQ(input);
|
||||
|
||||
String input2 = "{\n" +
|
||||
"\n" +
|
||||
" \"formId\": \"123456789\",\n" +
|
||||
" \"sinceType\": 2,\n" +
|
||||
" \"subSinceType\": 52,\n" +
|
||||
" \"data\": {\n" +
|
||||
" \"businessId\": \"123456789\",\n" +
|
||||
"\n" +
|
||||
" \"approveCode\": \"10001\",\n" +
|
||||
" \"approveResult\": \"审批通过\",\n" +
|
||||
" \"approveOpinion\": \"\"\n" +
|
||||
" }\n" +
|
||||
"}";
|
||||
boolean result2 = mqMessageRecordService.processMessageByMQ(input2);
|
||||
|
||||
return ResultMsg.ok(result+"--"+result2);
|
||||
}
|
||||
|
||||
@PostMapping("/runWorkflows5")
|
||||
@ApiOperation(value = "补偿处理消息")
|
||||
public ResultMsg<Object> runWorkflows5() {
|
||||
mqMessageRecordService.processMessageByTask();
|
||||
return ResultMsg.ok("");
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user