预约

ltrq-api/src/main/java/api/controller/HomeController.java

@@ -15,6 +15,7 @@ import api.model.AjaxResult;
 import api.service.call.ICallLogService;
 import api.service.call.ITranslateService;
 import api.service.docking.IDockingService;
+import api.service.rasa.IRasaKnowledgeService;
 import api.service.system.ILogininforService;
 import api.service.system.IUserRoleService;
 import api.service.system.IUserService;
@@ -23,6 +24,7 @@ import api.util.annotation.Anonymous;
 import api.util.constants.CacheConstants;
 import api.util.helper.*;
 import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
 import com.anji.captcha.model.common.ResponseModel;
 import com.anji.captcha.model.vo.CaptchaVO;
 import com.anji.captcha.service.CaptchaService;
@@ -31,6 +33,9 @@ import com.baomidou.mybatisplus.extension.toolkit.SqlRunner;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.google.gson.Gson;
+import com.google.gson.JsonObject;
+import com.google.gson.JsonParser;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
@@ -71,6 +76,8 @@ public class HomeController extends BaseController {
 
     @Autowired
     private IUserRoleService userRoleService;
+    @Autowired
+    private IRasaKnowledgeService rasaKnowledgeService;
 
 
     @Autowired
@@ -131,29 +138,31 @@ public class HomeController extends BaseController {
         if (list == null) {
             return Error("导入失败");
         }
-        for (int i=1;i <=30;i++)
-        {
-            TtsHelper.TextToSpeech("你当前的位置为"+i, String.valueOf(i));
-        }
+//        TtsHelper.TextToSpeech("欢迎致电蓝天燃气语音客服中心 为了确保服务质量 您的通话将被录音", "hyc");
+//
+//        TtsHelper.TextToSpeech("您好 请问有什么可以帮您?", "robot");
+//
+//        TtsHelper.TextToSpeech("别着急，说得详细一点，我才能帮到您。", "shgd");
+//
+//        TtsHelper.TextToSpeech("检测到您的问题较为复杂，为提供精准服务现为您转接人工坐席。转接中，请稍候。", "zjrg");
+//
+//        TtsHelper.TextToSpeech("可通过“河南蓝天燃气”微信公众号，燃气营业厅，或者拨打4000678099/4000693666,24小时服务热线进行登记，由设计人员勘察现场后出方案。", "2");
+//        TtsHelper.TextToSpeech("请您先把窗户和门打开，不要使用燃气。我将尽快为您转接人工", "33");
 
-        for (int i=1000;i <=1030;i++)
-        {
-            TtsHelper.TextToSpeech("你好，"+ String.valueOf(i).replaceAll("(.)", " $1").substring(1) +"号话务员正在为你服务", String.valueOf(i));
-        }
-     //   redisHelper.setCache("DocExcel",JSON.toJSONString(list));
-//        for (KnowledgeExcel item :list)
-//        {
-//            String filename=item.getEncoding();
 //
 //
-//            String parentPath = "files/audio/2025-10-14";
-//            File files = new File(parentPath+"/"+filename+".wav");
-//            if (files.exists()) {
-//                continue;
-//            }
-//            TtsHelper.TextToSpeech(item.getContent(), filename);
-//            System.out.println(filename);
+//
+//        for (int i=1000;i <=1030;i++)
+//        {
+//            TtsHelper.TextToSpeech("你好，"+ String.valueOf(i).replaceAll("(.)", " $1").substring(1) +"号话务员正在为你服务", String.valueOf(i));
 //        }
+      //  redisHelper.setCache("DocExcel",JSON.toJSONString(list));
+        for (KnowledgeExcel item :list)
+        {
+            String filename=item.getEncoding();
+            TtsHelper.TextToSpeech(item.getContent(), filename);
+            System.out.println(filename);
+        }
         return Success("成功", list);
     }
     @ApiOperation("导出Excel")
@@ -283,6 +292,42 @@ public class HomeController extends BaseController {
     }
 
 
+    @ApiOperation("登录")
+    @PostMapping("/byUserLogin")
+    public AjaxResult Login(@RequestParam String token) throws Exception {
+        try {
+            // 发送请求并获取结果
+            String response = HttpHelper.sendGetRequest("https://lt.lantian-life.com/api/byTokenGetUserInfo",token);
+            // 使用 Gson 解析
+            Gson gson = new Gson();
+            JsonObject jsonObject = JsonParser.parseString(response).getAsJsonObject();
+            // 获取 status
+            int status = jsonObject.get("status").getAsInt();
+            boolean isDataEmpty = jsonObject.get("data").isJsonNull();
+            // 业务逻辑
+            if (status == 200) {
+                if (!isDataEmpty) {
+                    List<Long> roleids =new ArrayList<>();
+                    roleids.add(20L);
+                    Map<String, Object> cls = new HashMap<>();
+                    cls.put("UserId", 57);
+                    cls.put("RoleIds", roleids);
+                    String basetoken = JwtHelper.createToken(cls);
+                    Map<String, Object> data = new HashMap<>();
+                    data.put("token", basetoken);
+                    return Success("登录成功", data);
+                }
+            } else {
+                String msg = jsonObject.get("msg").getAsString();
+                System.out.println("错误信息: " + msg);
+            }
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return Error("token 错误");
+
+    }
 
     @ApiOperation("退出")
     @PostMapping("/logout")

ltrq-api/src/main/java/api/controller/docking/DockingController.java

@@ -53,7 +53,6 @@ public class DockingController extends BaseController {
     @ApiOperation("请求接口")
     @Log(title = "请求接口",businessType = BusinessType.QUERY)
     @PostMapping("/docking")
-    @Anonymous
     public  AjaxResult  docking(@RequestBody dockingInput input) throws Exception {
 //        if (Objects.equals(input.getUrl(), "http://192.168.16.31:8301/enesysapi/rest/v1/charging/querypayrecord"))
 //        {
@@ -138,6 +137,40 @@ public class DockingController extends BaseController {
             return  Success("获取成功",json);
         }
     }
+    @ApiOperation("查询预约记录列表")
+    @Log(title = "查询预约记录列表",businessType = BusinessType.QUERY)
+    @PostMapping("/queryListByConditioin")
+    public  AjaxResult  queryListByConditioin(@RequestBody dockingInput input) {
+
+
+        String jsonBody="{";
+        if(StringHelper.isNotEmpty(input.getUserNo()))
+        {
+            jsonBody+="\"userNo\":\""+input.getUserNo()+"\"";
+        }
+        if(StringHelper.isNotEmpty(input.getUserPhone()))
+        {
+            jsonBody+="\"userPhone\":\""+input.getUserPhone()+"\"";
+        }
+        if(StringHelper.isNotEmpty(input.getUserName()))
+        {
+            jsonBody+="\"userName\":\""+input.getUserName()+"\"";
+        }
+        if(StringHelper.isNotEmpty(input.getStartDate()))
+        {
+            jsonBody+=(",\"startDate\":\""+input.getStartDate()+"\"");
+        }
+        if(StringHelper.isNotEmpty(input.getEndDate()))
+        {
+            jsonBody+=(",\"endDate\":\""+input.getEndDate()+"\"");
+        }
+        jsonBody+="}";
+
+        var json= dockingService.queryListByConditioin(jsonBody);
+        return  Success("获取成功",json);
+    }
+
+
     @ApiOperation("筛选条件")
     @Log(title = "筛选条件",businessType = BusinessType.QUERY)
     @GetMapping("/option")

ltrq-api/src/main/resources/application-production.yml

@@ -42,7 +42,7 @@ spring:
   isNote: 0
   pushUrl: 192.168.16.58:8160/Home/receiveCall
   curlUrl: http://192.168.16.58:8160/
-  middlewareUrl: http://192.168.16.56:9000/
+  middlewareUrl: http://192.168.16.58:9000/
   milvusclient:
     host: 192.168.16.59
     port: 19530

ltrq-entity/src/main/java/api/entity/input/docking/dockingInput.java

@@ -15,6 +15,10 @@ public class dockingInput {
     private String userNo;
     @ApiModelProperty("工单号")
     private String woId;
+    @ApiModelProperty("手机号")
+    private String userPhone;
+    @ApiModelProperty("用户姓名")
+    private String userName;
     @ApiModelProperty("开始时间")
     private String startDate;
     @ApiModelProperty("结束时间")

ltrq-service/src/main/java/api/service/docking/IDockingService.java

@@ -20,4 +20,6 @@ public interface IDockingService {
 
     // 执行POST请求
     String doPost( String jsonBody,String Url) throws Exception;
+
+    String queryListByConditioin(String jsonBody);
 }

ltrq-service/src/main/java/api/service/docking/impl/DockingServiceImpl.java

@@ -38,6 +38,12 @@ public class DockingServiceImpl implements IDockingService {
     private IPatientService patientService;
     private final String appId="hujiao";
     private final String appSecret="huJiaoEslink";
+
+   // private final String eslinkappId="OTHER65NFaz6AFzjpP3WR";
+  //  private final String eslinkappSecret="Nt7dH8XZ5QDkQramwABMeNxyYpdtDAkd";
+
+    private final String eslinkappId="OTHER6QG5Kr5S8QECE4jA";
+    private final String eslinkappSecret="xwzy2GbkStZyMimKKyxBKNns7mcrkQc4";
     // 生成时间戳
     private String generateTimestamp() {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
@@ -480,4 +486,90 @@ public class DockingServiceImpl implements IDockingService {
         return  response.toString();
     }
 
+    /**
+     * Base64编码
+     */
+    public static String base64Encode(String input) {
+        return Base64.getEncoder().encodeToString(input.getBytes(StandardCharsets.UTF_8));
+    }
+
+    /**
+     * 查询预约列表
+     * @return 是否请求成功
+     */
+    @Override
+    public String queryListByConditioin(String jsonBody) {
+        HttpURLConnection connection = null;
+        BufferedReader reader = null;
+
+        try {
+            // 构建URL
+
+           // String apiUrl =  "http://cloudselfhelp-gateway.test-new.eslink.net.cn/reserve/queryListByConditioin";
+            String apiUrl =  "https://cloudselfhelp-gateway.eslink.com/reserve/queryListByConditioin";
+            URL url = new URL(apiUrl);
+
+            // 创建连接
+            connection = (HttpURLConnection) url.openConnection();
+            connection.setRequestMethod("POST");
+            connection.setDoOutput(true);
+            String timestamp = generateTimestamp();
+
+            // 生成 AccessToken: MD5(appId + appSecret + timestamp)
+            String accessTokenContent = eslinkappId + eslinkappSecret + timestamp;
+            String accessToken =  SecretHelper.MD5(accessTokenContent);
+
+            // 生成 Authorization: Base64(appId + ":" + timestamp)
+            String authContent = eslinkappId + ":" + timestamp;
+            String authorization = base64Encode(authContent);
+
+            // 设置请求头
+            connection.setRequestProperty("Accept", "application/json");
+            connection.setRequestProperty("Content-Type", "application/json;charset=utf-8");
+            connection.setRequestProperty("AccessToken", accessToken);
+            connection.setRequestProperty("Authorization", authorization);
+            connection.setRequestProperty("SourceType", "AUTH_HNLTGAS");
+            connection.setRequestProperty("UserTicket", "PLAT_002");
+
+            // 发送请求体
+            try (OutputStream os = connection.getOutputStream()) {
+                byte[] input = jsonBody.getBytes(StandardCharsets.UTF_8);
+                os.write(input, 0, input.length);
+            }
+            BufferedReader in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
+            String inputLine;
+            StringBuilder response = new StringBuilder();
+
+            while ((inputLine = in.readLine()) != null) {
+                response.append(inputLine);
+            }
+            in.close();
+
+            return  response.toString();
+
+        } catch (Exception e) {
+            System.err.println("请求异常: " + e.getMessage());
+            e.printStackTrace();
+            return e.getMessage();
+        } finally {
+            // 清理资源
+            try {
+                if (reader != null) reader.close();
+                if (connection != null) connection.disconnect();
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+
+
+
+
+
+
+
+
+
+
 }

ltrq-service/src/main/java/api/service/websocket/WebSocket.java

@@ -9,6 +9,7 @@ import api.entity.view.online.MessageView;
 import api.service.dify.IDifyAssistantService;
 import api.service.online.IMessageService;
 import api.service.patient.IPatientService;
+import api.service.sf.ISfPlanService;
 import api.service.system.IConfigService;
 import api.util.enums.PatientSource;
 import api.util.helper.*;
@@ -40,12 +41,9 @@ public class WebSocket {
     private IMessageService messageService;
     @Autowired
     private IPatientService patientService;
-    @Autowired
-    private IDifyAssistantService difyAssistantService;
+
     @Autowired
     private WxMpService wxMpService;
-    @Autowired
-    private IConfigService configService;
 
     private static WebSocket webSocket;
 
@@ -91,11 +89,11 @@ public class WebSocket {
                     customers.put(userCode, source);
                     khsessionPool.put(userCode, session);
                     Long pid = null;
-                    List<String> ps = session.getRequestParameterMap().get("project");
-                    if(ps!=null&&ps.size()>0)
-                    {
-                        pid = Long.valueOf(ps.get(0));
-                    }
+                   // List<String> ps = session.getRequestParameterMap().get("project");
+//                    if(ps!=null&&ps.size()>0)
+//                    {
+//                        pid = Long.valueOf(ps.get(0));
+//                    }
                     addCustomer(userCode, source, pid);
                 }
             }
@@ -214,25 +212,59 @@ public class WebSocket {
 
                 if (!exist) {
                     session.getAsyncRemote().sendText(JSON.toJSONString(mv1));
-                    return;
                 }
+                webSocket.messageService.insert(msg);
             } else {
                 //客户发送消息
                 msg.setSend(1);
                 msg.setKhUser(userCode);
                 msg.setKhSource(source);
                 String kf = khkfs.get(userCode);
+              if(content.contains("人工"))
+              {
+
                 if (StringHelper.isEmpty(kf)||servicers.get(kf)==2) {
                     kf = servicerQueue.poll();
                     if (!StringHelper.isEmpty(kf)) {
                         servicerQueue.add(kf);
-                        khkfs.put(userCode, kf);
+                        Session session1 = khsessionPool.get(userCode);
+                        if (session1 != null) {
+                            msg.setKfUser(kf);
+                            webSocket.messageService.insert(msg);
+                            MessageView mv1 = new MessageView();
+                            mv1.setUser("admin");
+                            mv1.setStatus("success");
+                            mv1.setType(type);
+                            mv1.setContent("正在为您转接人工，请稍后");
+                            session1.getAsyncRemote().sendText(JSON.toJSONString(mv1));
+                            addMsg(userCode,"正在为您转接人工，请稍后");
+                        }
                     }
-                }
+                    else
+                    {
+                        IConfigService configService = SpringHelper.getBean(IConfigService.class);
+                        String  answer= configService.getConfigValue("prompt");
+                        Session session1 = khsessionPool.get(userCode);
+                        if (session1 != null) {
+                            MessageView mv1 = new MessageView();
+                            mv1.setStatus("success");
+                            mv1.setType(type);
+                            mv1.setContent(answer);
+                            mv1.setUser(userCode);
+                            session1.getAsyncRemote().sendText(JSON.toJSONString(mv1));
+                        }
+                        addMsg(userCode,answer);
+                    }
+                  }
+              }
+              else
+              {
+                  webSocket.messageService.insert(msg);
+              }
                 if (!StringHelper.isEmpty(kf)) {
+                    msg.setKfUser(kf);
                     Session session1 = kfsessionPool.get(kf);
                     if (session1 != null) {
-                        msg.setKfUser(kf);
                         MessageView mv1 = new MessageView();
                         mv1.setStatus("success");
                         mv1.setType(type);
@@ -241,14 +273,74 @@ public class WebSocket {
                         session1.getAsyncRemote().sendText(JSON.toJSONString(mv1));
                     }
                 }
-            }
-            //webSocket.messageService.insert(msg);
-            AsyncHelper.instance().execute(new TimerTask() {
-                @Override
-                public void run() {
-                    webSocket.messageService.insert(msg);
+                else
+                {
+                    if(!content.contains("人工")) {
+                        IDifyAssistantService difyAssistantService = SpringHelper.getBean(IDifyAssistantService.class);
+                        DifyChatMessagesInput input = new DifyChatMessagesInput();
+                        LambdaQueryWrapper<DifyAssistant> qw = new LambdaQueryWrapper<>();
+                        qw.eq(DifyAssistant::getCode, "mxyh");
+                        DifyAssistant dify = difyAssistantService.getEntity(qw);
+                        if (dify != null) {
+                            input.setId(dify.getAssistantId());
+                            input.setQuery(content);
+                            Map<String, Object> conversationMap = conversations.get(userCode);
+                            String Conversation_id = "";
+                            if (conversationMap != null) {
+                                Object Aime = conversationMap.get("conversationAime");
+                                Object Id = conversationMap.get("conversationId");
+                                if (Aime != null) {
+                                    Date time = (Date) conversationMap.get("conversationAime");
+                                    // 获取当前时间
+                                    Date now = new Date();
+                                    // 计算时间差的绝对值（毫秒）
+                                    long diffInMilliseconds = Math.abs(now.getTime() - time.getTime());
+                                    if (diffInMilliseconds <= (30 * 60 * 1000) && Id != null) {
+                                        Conversation_id = Id.toString();
+                                    }
+                                }
+                            }
+                            input.setConversation_id(Conversation_id);
+                            input.setAuto_generate_name(false);
+                            try {
+                                String json = difyAssistantService.sendMessages(input, dify, userCode);
+                                ObjectMapper mapper = new ObjectMapper();
+                                JsonNode rootNode = mapper.readTree(json);
+                                String answer = rootNode.get("answer").asText();
+                                String conversationId = rootNode.get("conversation_id").asText();
+                                if (!conversations.containsKey(userCode)) {
+                                    conversations.remove(userCode);
+                                    Map<String, Object> conversationsMap = new HashMap<>();
+                                    conversationsMap.put("conversationId", conversationId);
+                                    conversationsMap.put("conversationAime", new Date());
+                                    conversations.put(userCode, conversationsMap);
+                                }
+                                Session session1 = khsessionPool.get(userCode);
+                                if (session1 != null) {
+                                    MessageView mv1 = new MessageView();
+                                    mv1.setStatus("success");
+                                    mv1.setType(type);
+                                    mv1.setContent(answer);
+                                    mv1.setUser(userCode);
+                                    session1.getAsyncRemote().sendText(JSON.toJSONString(mv1));
+                                }
+                                addMsg(userCode, answer);
+
+                            } catch (Exception E) {
+                            }
+
+                        }
+                    }
                 }
-            });
+
+            }
+          //  webSocket.messageService.insert(msg);
+//            AsyncHelper.instance().execute(new TimerTask() {
+//                @Override
+//                public void run() {
+//                    webSocket.messageService.insert(msg);
+//                }
+//            });
         }
     }
 
@@ -583,8 +675,6 @@ public class WebSocket {
             String kf = khkfs.get(sendUser);
 //            if(content.contains("人工"))
 //            {
-//
-//
 //                if (StringHelper.isEmpty(kf)||servicers.get(kf)==2) {
 //                    kf = servicerQueue.poll();
 //                    if (!StringHelper.isEmpty(kf)) {
@@ -631,6 +721,7 @@ public class WebSocket {
             {
                 if ("text".equals(msgType))
                 {
+                    IDifyAssistantService difyAssistantService= SpringHelper.getBean(IDifyAssistantService.class);
                     webSocket.messageService.insert(message);
                     DifyChatMessagesInput input=new DifyChatMessagesInput();
                     LambdaQueryWrapper<DifyAssistant> qw = new LambdaQueryWrapper<>();

ltrq-util/src/main/java/api/util/helper/HttpHelper.java

@@ -463,6 +463,40 @@ public class HttpHelper {
         }
         return result.toString();
     }
+    public static String sendGetRequest(String urlString, String token) throws Exception {
+        URL url = new URL(urlString);
+        HttpURLConnection connection = (HttpURLConnection) url.openConnection();
+
+        // 设置请求方法
+        connection.setRequestMethod("GET");
+
+        // 设置请求头
+        connection.setRequestProperty("authori-zation", token);
+        connection.setRequestProperty("Content-Type", "application/json");
+        connection.setRequestProperty("User-Agent", "Mozilla/5.0");
+
+        // 设置超时时间
+        connection.setConnectTimeout(5000);
+        connection.setReadTimeout(5000);
+
+        // 获取响应码
+        int responseCode = connection.getResponseCode();
+        System.out.println("响应码: " + responseCode);
+
+        // 读取响应内容
+        BufferedReader in = new BufferedReader(
+                new InputStreamReader(connection.getInputStream()));
+        String inputLine;
+        StringBuilder response = new StringBuilder();
+
+        while ((inputLine = in.readLine()) != null) {
+            response.append(inputLine);
+        }
+        in.close();
+
+        connection.disconnect();
+        return response.toString();
+    }
     /**
      * 简化版 - 发送 form-data 格式的 POST 请求(不带请求头)
      *