test: 更新投诉分析接口测试

src/test/java/com/nokia/domainb/capability/UsercomplaintQuerysTest.java

@@ -1,5 +1,6 @@
 package com.nokia.domainb.capability;
 
+import cn.chinaunicom.open.nlgxptconnection.COMPConnectionContext;
 import com.alibaba.fastjson2.JSON;
 import com.google.gson.JsonObject;
 import com.google.gson.JsonParser;
@@ -42,6 +43,8 @@ class UsercomplaintQuerysTest {
         // LocalDateTime endTimeLocalDateTime = LocalDateTime.now();
         // String endTime = AESUtil.getTimeString(endTimeLocalDateTime);
         // String beginTime = AESUtil.getTimeString(endTimeLocalDateTime.minusDays(7));
+
+        // 投诉类型：1发不通 ，2收不到
 //        String complaintType = "2";
         String complaintType = "1";
         // 可以统一传空
@@ -49,10 +52,10 @@ class UsercomplaintQuerysTest {
         UsercomplaintQuerys usercomplaintQuerys = new UsercomplaintQuerys();
         StopWatch stopWatch = new StopWatch();
         stopWatch.start();
-        String result = usercomplaintQuerys.queryDirect(mobile, destAddr, complaintType, isMobile, flowNo, beginTime,
-                endTime, token, false);
-//        COMPConnectionContext result = usercomplaintQuerys.query(mobile, destAddr, complaintType, isMobile, flowNo,
-//                beginTime, endTime, token, false);
+//        String result = usercomplaintQuerys.queryDirect(mobile, destAddr, complaintType, isMobile, flowNo, beginTime,
+//                endTime, token, false);
+        COMPConnectionContext result = usercomplaintQuerys.query(mobile, destAddr, complaintType, isMobile, flowNo,
+                beginTime, endTime, token, false);
         stopWatch.stop();
         Map<String, String> req = new HashMap<>();
         req.put("mobile", mobile);
@@ -65,8 +68,8 @@ class UsercomplaintQuerysTest {
         req.put("token", token);
         Map<Object, Object> map = new HashMap<>();
         map.put("req", req);
-        Object res = JSON.parse(result);
-//        Object res = JSON.parse(result.getResponseContext());
+//        Object res = JSON.parse(result);
+        Object res = JSON.parse(result.getResponseContext());
         map.put("res", res);
         log.info("入参：{}", JSON.toJSONString(req));
         log.info("{} ms | 结果：{}", stopWatch.getTotalTimeMillis(), res);