From 325512b168a45323131f6f06485d3ccbd5a95c4b Mon Sep 17 00:00:00 2001 From: "925116093-qq.com" <925116093@qq.com> Date: Sat, 16 Aug 2025 17:57:02 +0800 Subject: [PATCH] 2025008071805 --- .../system/controllerUtil/DispatchUtil.java | 10 +++++----- .../controllerUtil/ScheduledTaskUtil.java | 7 ++++--- .../controllerUtil/YunXinPhoneUtilAPI.java | 19 ++++++++++++------- 3 files changed, 21 insertions(+), 15 deletions(-) diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/DispatchUtil.java b/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/DispatchUtil.java index 39ecbeb..ca17559 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/DispatchUtil.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/DispatchUtil.java @@ -2963,11 +2963,11 @@ public class DispatchUtil { //给师傅派单的时候的推送 WXsendMsgUtil.sendMsgForWorkerInfo(worker.getOpenid(), order, serviceGoods); Map map= OrderBindWorkerUtil.getOrderBindWorker(order.getId()); - YunXinPhoneUtilAPI.httpsAxbTransfer(order.getWorkerPhone()); - if (map.get("code").equals("200")) { - //电话通知 - YunXinPhoneUtilAPI.httpsAxbTransfer(order.getWorkerPhone()); - } + YunXinPhoneUtilAPI.httpsAxbTransfer(order.getWorkerPhone(), order.getId()); +// if (map.get("code").equals("200")) { +// //电话通知 +// YunXinPhoneUtilAPI.httpsAxbTransfer(order.getWorkerPhone()); +// } return worker; diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/ScheduledTaskUtil.java b/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/ScheduledTaskUtil.java index b573cee..458b5af 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/ScheduledTaskUtil.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/ScheduledTaskUtil.java @@ -293,9 +293,10 @@ public class ScheduledTaskUtil implements CommandLineRunner { * 使用说明： * - 用于测试定时任务的执行情况 */ - @Scheduled(fixedRate = 3000) // 每3秒执行一次 - public void testScheduledTask() { - log.info("测试定时任务执行中... 当前时间: {}", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); + @Scheduled(fixedRate = 3 * 60 * 1000) // // 每3分钟执行一次 + public void TheCallWordercheduledTask() throws Exception { + OrderUtil.TheCallWorder(); + log.info("每3分钟执行一次师傅的语音通知... 当前时间: {}", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"))); } /** diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/YunXinPhoneUtilAPI.java b/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/YunXinPhoneUtilAPI.java index 9dae68f..0769163 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/YunXinPhoneUtilAPI.java +++ b/ruoyi-system/src/main/java/com/ruoyi/system/controllerUtil/YunXinPhoneUtilAPI.java @@ -7,6 +7,7 @@ import com.winnerlook.util.Base64; import com.winnerlook.util.MD5Util; import java.util.LinkedHashMap; +import java.util.Map; /** * 云信小号相关API工具类 @@ -36,7 +37,7 @@ public class YunXinPhoneUtilAPI { // 回调地址常量（可通过set方法动态设置） private static String AXB_CALLBACK_URL = ""; - private static String NOTIFY_CALLBACK_URL = ""; + private static String NOTIFY_CALLBACK_URL = "https://552e105d.r3.cpolar.top/api/YunXin/notify"; // 回调地址常量（可通过set方法动态设置） @@ -64,16 +65,20 @@ public class YunXinPhoneUtilAPI { * @throws Exception 异常 *

回调地址使用 NOTIFY_CALLBACK_URL 常量，如需动态设置请调用 setNotifyCallbackUrl 方法

*/ - public static VoiceResponseResult httpsAxbTransfer(String phone) throws Exception { + public static VoiceResponseResult httpsAxbTransfer(String phone,Long oid) throws Exception { VoiceResponseResult resultObj = new VoiceResponseResult(); String url = NOTIFY_URL; try { + LinkedHashMap templateArgsDATA = new LinkedHashMap(); + templateArgsDATA.put("orderid", oid.toString()); // 组装请求体 VoiceNotifyBody transfer = new VoiceNotifyBody(); transfer.setCalleeNumber(phone); transfer.setTemplateId(templateID); - transfer.setTemplateArgs(new LinkedHashMap()); // 可根据需要传递参数 + transfer.setTemplateArgs( new LinkedHashMap()); // 可根据需要传递参数 transfer.setCallbackUrl(NOTIFY_CALLBACK_URL); + JSONObject json = JSONObject.parseObject(JSON.toJSONString(transfer)); + json.put("customerData", String.valueOf(oid)); // 获取当前时间戳 long timestamp = System.currentTimeMillis(); @@ -82,7 +87,7 @@ public class YunXinPhoneUtilAPI { String sig = MD5Util.getMD5(APP_ID + TOKEN + timestamp); // 拼接最终URL url = url + "/" + APP_ID + "/" + sig; - String body = JSON.toJSONString(transfer); + String body = json.toJSONString(); // 调用HTTPS服务 HttpsService httpsService = new HttpsService(); @@ -183,10 +188,10 @@ public class YunXinPhoneUtilAPI { */ public static void main(String[] args) throws Exception { // 设置回调地址（如有需要） - setAxbCallbackUrl("http://your-callback-url.com/axb"); - setNotifyCallbackUrl("http://your-callback-url.com/notify"); +// setAxbCallbackUrl("http://your-callback-url.com/axb"); +// setNotifyCallbackUrl("http://your-callback-url.com/notify"); // 示例：解绑操作 - VoiceResponseResult res = httpsPrivacyUnbind("15270824290", "18339212639", "13279237164"); + VoiceResponseResult res = httpsAxbTransfer("18339212639",3252L); System.out.println("解绑结果：" + JSON.toJSONString(res)); } }