feat: 回调地址可配置、回调接口文档和知情同意

wzp

2025-05-04 938d93722b6ebaf8953e1e17307ef7739affc3d0

 ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/RyTask.java

@@ -1,12 +1,10 @@
package com.ruoyi.quartz.task;

import com.ruoyi.common.utils.HttpUtil;
import com.ruoyi.system.domain.AOrderStatus;
import com.ruoyi.system.domain.DispatchOrd;
import com.ruoyi.system.domain.OrderStatusCallBackVo;
import com.ruoyi.system.domain.TbOrders;
import com.ruoyi.system.domain.*;
import com.ruoyi.system.service.IAOrderStatusService;
import com.ruoyi.system.service.IDispatchOrdService;
import com.ruoyi.system.service.ISysClientAppService;
import com.ruoyi.system.service.ITbOrdersService;
import com.ruoyi.system.service.impl.SysUserServiceImpl;
import org.slf4j.Logger;
@@ -37,6 +35,9 @@
    @Autowired
    private IDispatchOrdService dispatchOrdService;

    @Autowired
    private ISysClientAppService sysClientAppService;

    public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
    {
        System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
@@ -52,6 +53,9 @@
        System.out.println("执行无参方法");
    }

    /**
     * 回调推送状态
     */
    public void ryOrderStatus() {
        try {
            List<AOrderStatus> orderStatusList = orderStatusService.selectAOrderStatusList();
@@ -62,7 +66,6 @@
            for (AOrderStatus orderStatus : orderStatusList) {
                int count = tbOrdersService.checkServiceOrdIDExists(orderStatus.getServiceOrdID());
                if (count > 0) {
                    // orderStatusService.updateAOrderStatusFlag(orderStatus.getId());
                    System.out.println("服务订单ID存在：" + orderStatus.getServiceOrdID());

                    TbOrders tbOrders = tbOrdersService.selectTbOrdersByServiceOrdID(orderStatus.getServiceOrdID());
@@ -108,10 +111,13 @@
                        log.error("获取调度单异常："+e.getMessage());
                    }

                    SysClientApp clientApp = sysClientAppService.selectSysClientAppByAppId(1L);
                    if(clientApp==null){
                        log.error("回调地址不存在");
                        return;
                    }


                    // 使用获取到的所有司机姓名
                    String callbackUrl = "http://localhost:8080/system/apitest/orderCallback";
                    String callbackUrl = clientApp.getCallbackUrl();
                    try {
                        // 构建请求参数
                        Map<String, String> map = new HashMap<>();
@@ -123,25 +129,29 @@
                        map.put("driverMobile",driverMobiles.toString());
                        map.put("driverName", driverNames.toString());

                        // 打印请求参数
                        log.info("发送回调请求，URL: " + callbackUrl);
                        log.info("请求参数: " + map);

                        // 发送请求并获取响应
                        String response = HttpUtil.post(callbackUrl, map);

                        // 打印响应结果
                        log.info("回调响应结果: " + response);

                        // 更新状态
                        // orderStatusService.updateAOrderStatusFlag(orderStatus.getId());
                        // 第一次尝试
                        String response = sendCallback(callbackUrl, map);
                        
                        if (response == null) {
                            // 如果第一次失败，等待3秒后重试
                            Thread.sleep(3000);
                            log.info("第一次回调失败，准备重试");
                            response = sendCallback(callbackUrl, map);
                        }
                        
                        if (response != null) {
                            // 更新状态
                            log.info("回调推送成功，参数如下：");
                            map.forEach((key, value) -> log.info("    {} : {}", key, value));
                            orderStatusService.updateAOrderStatusFlag(orderStatus.getId());
                        } else {
                            log.error("回调请求重试后仍然失败");
                            orderStatusService.updateAOrderStatusFlag(orderStatus.getId());
                        }
                    } catch (Exception e) {
                        log.error("回调请求失败: " + e.getMessage());
                        // 可以考虑重试机制或者记录失败日志
                        orderStatusService.updateAOrderStatusFlag(orderStatus.getId());
                    }



                }
                else {
                    log.info("服务订单ID不存在：" + orderStatus.getServiceOrdID());
@@ -153,4 +163,24 @@
            e.printStackTrace();
        }
    }

    // 新增发送回调的方法
    private String sendCallback(String callbackUrl, Map<String, String> params) {
        try {
            // 打印请求参数
            log.info("发送回调请求，URL: " + callbackUrl);
            log.info("请求参数: " + params);

            // 发送请求并获取响应
            String response = HttpUtil.post(callbackUrl, params);

            // 打印响应结果
            log.info("回调响应结果: " + response);
            
            return response;
        } catch (Exception e) {
            log.error("回调请求异常: " + e.getMessage());
            return null;
        }
    }
}