From 62b7640f5b0799fd8b2d393ed01a7a49d8429d00 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9B=B9=E7=A3=8A?= <45566618@qq.com>
Date: Wed, 11 Sep 2024 10:31:59 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=B7=E4=BB=96=E4=B8=8A=E7=BA=BF=E7=94=B5?=
 =?UTF-8?q?=E8=AF=9D=E9=80=9A=E7=9F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/app/AppMessageController.java  |  6 +---
 .../message/service/MessageService.java       |  2 ++
 .../service/impl/MessageServiceImpl.java      | 29 ++++++++++++++++---
 .../com/sqx/modules/utils/AppNotifyUtil.java  | 23 +++++++++++++++
 4 files changed, 51 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/sqx/modules/message/controller/app/AppMessageController.java b/src/main/java/com/sqx/modules/message/controller/app/AppMessageController.java
index 422feea..d213b5e 100644
--- a/src/main/java/com/sqx/modules/message/controller/app/AppMessageController.java
+++ b/src/main/java/com/sqx/modules/message/controller/app/AppMessageController.java
@@ -128,14 +128,10 @@ public class AppMessageController {
         messageInfo.setTitle("通知上线");
         messageInfo.setByUserName(userEntity.getUserName());
         messageInfo.setUserName(artificer.getArtificerName());
-        messageService.saveBody(messageInfo);
-
-
+        messageService.insertUpMessage(messageInfo);
         if (StringUtils.isNotEmpty(artificerUser.getPhone())) {
             userService.sendMsg(artificerUser.getPhone(), "qtsx");
         }
-
-
         return Result.success();
     }
 
diff --git a/src/main/java/com/sqx/modules/message/service/MessageService.java b/src/main/java/com/sqx/modules/message/service/MessageService.java
index 2633e29..c2b7005 100644
--- a/src/main/java/com/sqx/modules/message/service/MessageService.java
+++ b/src/main/java/com/sqx/modules/message/service/MessageService.java
@@ -22,6 +22,8 @@ public interface MessageService extends IService<MessageInfo> {
 
     int saveBody(MessageInfo messageInfo);
 
+    int insertUpMessage(MessageInfo messageInfo);
+
     Result insertArtificerLocation(MessageInfo messageInfo);
 
     int update(MessageInfo messageInfo);
diff --git a/src/main/java/com/sqx/modules/message/service/impl/MessageServiceImpl.java b/src/main/java/com/sqx/modules/message/service/impl/MessageServiceImpl.java
index d6053f0..bf5da5d 100644
--- a/src/main/java/com/sqx/modules/message/service/impl/MessageServiceImpl.java
+++ b/src/main/java/com/sqx/modules/message/service/impl/MessageServiceImpl.java
@@ -30,10 +30,7 @@ import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * 消息
@@ -165,6 +162,30 @@ public class MessageServiceImpl extends
         return messageInfoDao.insert(messageInfo);
     }
 
+    @Override
+    public int insertUpMessage(MessageInfo messageInfo){
+        messageInfo.setCreateAt(DateUtils.format(new Date()));
+        int returncount = messageInfoDao.insert(messageInfo);
+        if(returncount == 1) {
+            //技师电话通知业务
+            //accountId
+            String accountId = commonInfoService.findOne(428).getValue();
+            //token
+            String token = commonInfoService.findOne(429).getValue();
+            //templateId 模板id
+            String templateId = commonInfoService.findOne(466).getValue();
+            //呼救手机号
+            Artificer artificer = artificerService.getById(Long.valueOf(messageInfo.getUserId()));
+            UserEntity byId = userService.getById(artificer.getUserId());
+            //参数
+            LinkedHashMap<String,String> params = new LinkedHashMap<String,String>();
+            params.put("var1",messageInfo.getByUserName());
+            //呼叫
+            AppNotifyUtil.AppNotify(byId.getPhone(), accountId, token, templateId, params);
+        }
+        return returncount;
+    }
+
     @Override
     public Result insertArtificerLocation(MessageInfo messageInfo){
         messageInfo.setState("12");
diff --git a/src/main/java/com/sqx/modules/utils/AppNotifyUtil.java b/src/main/java/com/sqx/modules/utils/AppNotifyUtil.java
index 0e6f106..17b9dac 100644
--- a/src/main/java/com/sqx/modules/utils/AppNotifyUtil.java
+++ b/src/main/java/com/sqx/modules/utils/AppNotifyUtil.java
@@ -31,4 +31,27 @@ public class AppNotifyUtil {
         }
         return Result.error("系统错误，请联系管理员。");
     }
+
+    public static Result AppNotify(String calleeNumber, String accountId, String token, String templateId, LinkedHashMap<String,String> params) {
+        VoiceNotifyBody message = new VoiceNotifyBody();
+        /*用户接收回执的服务器地址*/
+        message.setCallbackUrl("");
+        message.setCalleeNumber(calleeNumber);
+        message.setReplayTimes(1);
+        /*设置平台分配的模板ID*/
+        message.setTemplateId(templateId);
+        if(params == null){
+            params = new LinkedHashMap<String,String>();
+        }
+        message.setTemplateArgs(params);
+        try {
+            VoiceResponseResult result1 = VoiceSender.httpsSendVoiceNotify(message, accountId, token);
+            System.out.println("result = " + result1);
+            return Result.success().put("data",result1);
+        }catch (Exception e) {
+            //Log.e(this.getClass(), " e = " + e);
+            e.printStackTrace();
+        }
+        return Result.error("系统错误，请联系管理员。");
+    }
 }