yinruoxi

添加：
    1.引入Tlog框架
    2.标注NLTlog

pom.xml

@@ -48,6 +48,7 @@
         <sonar.password>Digimeta@2023</sonar.password>
         <jakarta-json.version>2.0.1</jakarta-json.version>
         <elasticsearch.version>8.3.3</elasticsearch.version>
+        <tlog.version>1.5.1</tlog.version>
     </properties>
 
     <!-- 依赖声明 -->

xueyi-api/xueyi-api-nlt/src/main/java/com/xueyi/nlt/api/nlt/domain/vo/response/DmIntentResponse.java

@@ -24,6 +24,10 @@ public class DmIntentResponse  implements Serializable {
 
     private String motion;
 
+    private String type;
+
+    private String hit;
+
     public void clear() {
         this.msg = null;
         this.skillCode = null;

xueyi-common/xueyi-common-log/pom.xml

@@ -22,6 +22,12 @@
             <groupId>com.xueyi</groupId>
             <artifactId>xueyi-common-security</artifactId>
         </dependency>
+
+        <dependency>
+            <groupId>com.yomahub</groupId>
+            <artifactId>tlog-all-spring-boot-starter</artifactId>
+            <version>${tlog.version}</version>
+        </dependency>
         
     </dependencies>
 </project>

xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/netty/client/WebSocketClientManager.java

@@ -3,6 +3,7 @@ package com.xueyi.nlt.netty.client;
 import com.xueyi.nlt.netty.client.listener.LlmWebSocketListener;
 import com.xueyi.nlt.nlt.domain.LlmContext;
 import com.xueyi.nlt.nlt.domain.LlmParam;
+import com.yomahub.tlog.okhttp.TLogOkHttpInterceptor;
 import okhttp3.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -47,7 +48,7 @@ public class WebSocketClientManager {
     @PostConstruct
     public void init() {
         ConnectionPool okHttpConnectionPool = new ConnectionPool(MAX_CONCURRENT_CONNECTIONS, KEEP_ALIVE_TIME, TimeUnit.SECONDS);
-        client = new OkHttpClient.Builder().connectionPool(okHttpConnectionPool).build();
+        client = new OkHttpClient.Builder().connectionPool(okHttpConnectionPool).addInterceptor(new TLogOkHttpInterceptor()).build();
         connectionPool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME, TimeUnit.SECONDS, new LinkedBlockingQueue<>());
     }
 

xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/netty/client/listener/LlmWebSocketListener.java

@@ -12,6 +12,7 @@ import com.xueyi.nlt.netty.server.config.ServerConfig;
 import com.xueyi.nlt.nlt.domain.LlmContent;
 import com.xueyi.nlt.nlt.domain.LlmContext;
 import com.xueyi.nlt.nlt.domain.LlmParam;
+import com.yomahub.tlog.core.annotation.TLogAspect;
 import io.netty.channel.Channel;
 import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
 import okhttp3.Response;
@@ -118,6 +119,7 @@ public class LlmWebSocketListener extends WebSocketListener {
         ).start();
     }
 
+    @TLogAspect(str = "DGMAN-NLT")
     @Override
     public void onMessage(WebSocket webSocket, String text) {
         super.onMessage(webSocket, text);

xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/nlt/controller/DmIntentController.java

@@ -67,6 +67,7 @@ import com.xueyi.system.api.model.LoginUser;
 import com.xueyi.system.api.model.Source;
 import com.xueyi.system.api.organize.domain.dto.SysEnterpriseDto;
 import com.xueyi.system.api.organize.feign.RemoteEnterpriseService;
+import com.yomahub.tlog.core.annotation.TLogAspect;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -87,8 +88,13 @@ import org.springframework.web.bind.annotation.RestController;
 import java.io.Serializable;
 import java.text.DateFormat;
 import java.text.SimpleDateFormat;
-import java.time.format.DateTimeFormatter;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.time.LocalDateTime;
 import java.util.*;
+import java.time.format.DateTimeFormatter;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
@@ -223,6 +229,7 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
         return AjaxResult.success(jsonObjectR.getData());
     }
 
+    @TLogAspect(str="DGMAN-NLT")
     @PostMapping("/api/skill-intent")
     @ResponseBody
     public AjaxResult skillIntentApi(@RequestBody DmIntentVo intent) {
@@ -361,10 +368,19 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
     /**
      * 联动北方大模型请求
      */
+    @TLogAspect(str="DGMAN-NLT")
     @PostMapping("/api/searchQuestionAnswer")
     @ResponseBody
     public AjaxResult searchQuestionAnswer(@RequestBody DmIntentVo intent) {
         log.info("交互对象：{}",intent.toString());
+        // 定义标注日志对象
+        MarkRecordVo recordVo = new MarkRecordVo();
+        recordVo.setDevId(intent.getDevId());
+        recordVo.setId(IdUtil.getSnowflakeNextId());
+        recordVo.setCreateTime(LocalDateTime.now());
+        recordVo.setQuestion(intent.getContent());
+        recordVo.setHit(1);
+
         redisTemplate.opsForValue().increment("dashboard:server", 1);
         R<DmManDeviceDto> manDeviceDtoR = manDeviceService.manDeviceInfoInner(intent.getDevId());
         if (manDeviceDtoR.isFail()) {
@@ -376,8 +392,8 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
         if (enterpriseDtoR.isOk()) {
             enterpriseName = enterpriseDtoR.getData().getName();
         }
+        recordVo.setTenantId(Long.valueOf(manDeviceDtoR.getData().getTId()));
         DmIntentResponse response = new DmIntentResponse();
-
         //先调用意图
         //根据技能调用知识库或大模型
         CoversationSessionVo sessionObject = (CoversationSessionVo) redisTemplate2.opsForValue().get("group:device" + ":" + intent.getDevId() + ":" +"session");
@@ -385,6 +401,13 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
                 response.setMsg("");
                 response.setSkillCode("34");
                 response.setH5(flightMessageTemplate.handle(intent.getDevId(),intent.getContent()));
+                recordVo.setType(2);
+                recordVo.setSkillCode("34");  // 航班查询
+                List answers = new ArrayList();
+                answers.add(response.getH5().toJSONString());
+                recordVo.setAnswers(answers);
+                // 记录log
+                log.info(recordVo.toString());
                 return AjaxResult.success(response);
 
         }
@@ -394,6 +417,12 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
                 redisTemplate.opsForValue().increment("dashboard:flight", 1);
                 pushIntoDashboardRedis(enterpriseName, "查询航班信息", "skill");
                 response.setH5(flightMessageTemplate.handle(intent.getDevId(), intent.getContent()));
+                recordVo.setType(2);
+                recordVo.setSkillCode("34");  // 航班查询
+                List answers = new ArrayList();
+                answers.add(response.getH5().toJSONString());
+                recordVo.setAnswers(answers);
+                log.info(recordVo.toString());
                 return AjaxResult.success(response);
             }
         }
@@ -410,6 +439,12 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
                 content = qaAjax.getResult().get(0).getKnowledgeLib();
                 pushIntoDashboardRedis(enterpriseName,content,"knowledge");
                 response.setH5(JSONObject.from(qaAjax));
+                recordVo.setType(0);
+                recordVo.setSkillCode("34");  // 航班查询
+                List answers = new ArrayList();
+                answers.add(response.getH5().getJSONArray("result").getJSONObject(0).getString("answer"));
+                recordVo.setAnswers(answers);
+                log.info(recordVo.toString());
                 return AjaxResult.success(response);
             }
         }
@@ -468,6 +503,14 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
             joImage.put("msg","抱歉，您的问题我无法解答。");
             response.setH5(joImage);
         }
+        // 记录日志
+        recordVo.setType(1);
+        recordVo.setSkillCode("30");  // 航班查询
+        recordVo.setLlm("lagi");
+        List answers = new ArrayList();
+        answers.add(response.getH5().getString("msg"));
+        recordVo.setAnswers(answers);
+        log.info(recordVo.toString());
         return AjaxResult.success(response);
     }
 
@@ -572,11 +615,20 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
     /**
      * 意图请求列表
      */
+    @TLogAspect(str="DGMAN-NLT")
     @PostMapping("/inner/conversation")
     @ResponseBody
     public R<DmIntentResponse> conversationInner(@RequestBody DmIntentVo intent) {
         DmIntentResponse response = new DmIntentResponse();
 
+        // 记录
+        // 定义标注日志对象
+        MarkRecordVo recordVo = new MarkRecordVo();
+        recordVo.setDevId(intent.getDevId());
+        recordVo.setId(IdUtil.getSnowflakeNextId());
+        recordVo.setCreateTime(LocalDateTime.now());
+        recordVo.setQuestion(intent.getContent());
+        recordVo.setHit(1);
 
         String enterpriseId = (String)SecurityContextHolder.getLocalMap().get("enterprise_id");
         String enterpriseName = "";
@@ -595,6 +647,11 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
             if (response == null || StringUtils.isEmpty(response.getSkillCode())) {
                 // 做场景1、2处理
                 if (!StringUtils.isEmpty(response.getMsg())) {
+                    // 记录log
+                    recordVo.setType(2);
+                    List answers = new ArrayList();
+                    answers.add(response.getMsg());
+                    recordVo.setAnswers(answers);  // 航班查询
                     return R.ok(response);
                 }
                 else {
@@ -609,6 +666,11 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
                             content = qaAjax.getResult().get(0).getKnowledgeLib();
                             pushIntoDashboardRedis(enterpriseName,content,"knowledge");
                             response.setH5(JSONObject.from(qaAjax));
+                            // 记录log
+                            recordVo.setType(2);
+                            List answers = new ArrayList();
+                            answers.add(response.getMsg());
+                            recordVo.setAnswers(answers);  // 航班查询
                             return R.ok(response);
                         }
                         else {
@@ -749,8 +811,6 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
         return R.ok();
     }
 
-
-
     /**
      * 意图请求
      列表

xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/nlt/domain/vo/MarkRecordVo.java

@@ -1,5 +1,6 @@
 package com.xueyi.nlt.nlt.domain.vo;
 
+import com.alibaba.fastjson2.JSONObject;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import com.fasterxml.jackson.databind.annotation.JsonSerialize;
@@ -17,7 +18,7 @@ public class MarkRecordVo implements Serializable {
     @Serial
     private static final long serialVersionUID = 1L;
 
-
+    // 唯一id
     protected Long id;
     protected String devId;
     /** 标注来源
@@ -48,6 +49,11 @@ public class MarkRecordVo implements Serializable {
     /** 问题 */
     protected String question;
 
+    /** 是否命中 */
+    protected Integer hit;
+
+    /** 命中的技能 */
+    protected String skillCode;
     /** 答案 */
     protected List<String> answers;
 

xueyi-modules/xueyi-nlt/src/main/resources/logback.xml

@@ -22,7 +22,7 @@
 			<!-- 日志最大的历史 60天 -->
 			<maxHistory>60</maxHistory>
 		</rollingPolicy>
-		<encoder>
+		<encoder class="com.yomahub.tlog.core.enhance.logback.AspectLogbackEncoder">
 			<pattern>${log.pattern}</pattern>
 		</encoder>
 		<filter class="ch.qos.logback.classic.filter.LevelFilter">
@@ -44,7 +44,7 @@
 			<!-- 日志最大的历史 60天 -->
 			<maxHistory>60</maxHistory>
         </rollingPolicy>
-        <encoder>
+        <encoder class="com.yomahub.tlog.core.enhance.logback.AspectLogbackEncoder">
             <pattern>${log.pattern}</pattern>
         </encoder>
         <filter class="ch.qos.logback.classic.filter.LevelFilter">