Merge branch 'dev'

ruoyi-api/ruoyi-api-mall/src/main/java/org/dromara/mall/api/weishi/RemoteWeishiService.java

+package org.dromara.mall.api.weishi;
+
+/**
+ * @author wenhe
+ */
+public interface RemoteWeishiService {
+
+    /**
+     * 获取token
+     */
+    void getToken();
+
+    /**
+     * 更新订单状态
+     */
+    void updateOrderStatus();
+
+}

ruoyi-api/ruoyi-api-system/src/main/java/org/dromara/system/api/RemoteDeptService.java

@@ -15,4 +15,12 @@ public interface RemoteDeptService {
      */
     String selectDeptNameByIds(String deptIds);
 
+    /**
+     * 获取部门负责人id
+     *
+     * @param userId 用户id
+     * @return 负责人id
+     */
+    Long selectLeaderIdByUserId(Long userId);
+
 }

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/Api.java

@@ -2,6 +2,7 @@ package org.dromara.common.weishi;
 
 import cn.hutool.core.date.StopWatch;
 import cn.hutool.http.ContentType;
+import cn.hutool.http.HttpResponse;
 import com.alibaba.fastjson.JSON;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
@@ -13,7 +14,11 @@ import org.dromara.common.weishi.enums.ApiEnum;
 import org.dromara.common.weishi.enums.Domain;
 import org.dromara.common.weishi.enums.DomainEnum;
 
+import java.io.ByteArrayOutputStream;
 import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Base64;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -50,16 +55,31 @@ public class Api {
             .concat(apiEnum.getUrl());
     }
 
+    public static <T> T v1(RequestMethodEnum method, String urlPrefix, String urlSuffix,
+                           String token,
+                           String body,
+                           Class<T> clazz) {
+        return v1(method, urlPrefix, urlSuffix, token, null, body, null, clazz);
+    }
+
+    public static <T> T v1(RequestMethodEnum method, String urlPrefix, String urlSuffix,
+                           String token,
+                           String body,
+                           Map<String,Object> params,
+                           Class<T> clazz) {
+        return v1(method, urlPrefix, urlSuffix, token, params, body, null, clazz);
+    }
+
     public static ApiHttpResponse v1(RequestMethodEnum method, String urlPrefix, String urlSuffix,
                                      String token,
                                      String body) {
-        return v1(method, urlPrefix, urlSuffix, token, null, body, null);
+        return v1(method, urlPrefix, urlSuffix, token, null, body, null, ApiHttpResponse.class);
     }
 
     public static ApiHttpResponse v1(RequestMethodEnum method, String urlPrefix, String urlSuffix,
                                      String token,
                                      Map<String, Object> params, String body) {
-        return v1(method, urlPrefix, urlSuffix, token, params, body, null);
+        return v1(method, urlPrefix, urlSuffix, token, params, body, null, ApiHttpResponse.class);
     }
 
     /**
@@ -74,9 +94,9 @@ public class Api {
      * @param file      文件
      * @return 请求返回的结果
      */
-    public static ApiHttpResponse v1(RequestMethodEnum method, String urlPrefix, String urlSuffix,
+    public static <T> T v1(RequestMethodEnum method, String urlPrefix, String urlSuffix,
                            String token,
-                                     Map<String, Object> params, String body, File file) {
+                           Map<String, Object> params, String body, File file, Class<T> clazz) {
         if (null != params && !params.keySet().isEmpty()) {
             urlSuffix = urlSuffix.concat("?").concat(PayKit.createLinkString(params, true));
         }
@@ -84,20 +104,26 @@ public class Api {
         // 构建 Authorization
         String authorization = token;
 
+        String bodyRes = null;
         if (method == RequestMethodEnum.GET) {
-            return get(urlPrefix.concat(urlSuffix), authorization, null);
+            bodyRes = get(urlPrefix.concat(urlSuffix), authorization, params);
         } else if (method == RequestMethodEnum.POST) {
-            return post(urlPrefix.concat(urlSuffix), authorization, body);
+            bodyRes = post(urlPrefix.concat(urlSuffix), authorization, body);
         } else if (method == RequestMethodEnum.DELETE) {
-            return delete(urlPrefix.concat(urlSuffix), authorization, body);
+            bodyRes = delete(urlPrefix.concat(urlSuffix), authorization, body);
         } else if (method == RequestMethodEnum.UPLOAD) {
-            return upload(urlPrefix.concat(urlSuffix), authorization, body, file);
+            bodyRes = upload(urlPrefix.concat(urlSuffix), authorization, body, file);
         } else if (method == RequestMethodEnum.PATCH) {
-            return patch(urlPrefix.concat(urlSuffix), authorization, body);
+            bodyRes = patch(urlPrefix.concat(urlSuffix), authorization, body);
         } else if (method == RequestMethodEnum.PUT) {
-            return put(urlPrefix.concat(urlSuffix), authorization, body);
+            bodyRes = put(urlPrefix.concat(urlSuffix), authorization, body);
+        } else if (method == RequestMethodEnum.DOWNLOAD) {
+            bodyRes = download(urlPrefix.concat(urlSuffix), authorization, params);
         }
-        return null;
+        if (clazz == String.class) {
+            return (T) bodyRes;
+        }
+        return JSON.parseObject(bodyRes, clazz);
     }
 
     /**
@@ -108,7 +134,7 @@ public class Api {
      * @param data          请求参数
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse put(String url, String authorization, String data) {
+    public static String put(String url, String authorization, String data) {
         return put(url, data, getHeaders(authorization));
     }
 
@@ -120,7 +146,7 @@ public class Api {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse put(String url, String data, Map<String, String> headers) {
+    public static String put(String url, String data, Map<String, String> headers) {
         return HttpKit.getDelegate().put(url, data, headers);
     }
 
@@ -132,7 +158,7 @@ public class Api {
      * @param data          请求参数
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse patch(String url, String authorization, String data) {
+    public static String patch(String url, String authorization, String data) {
         return patch(url, data, getHeaders(authorization));
     }
 
@@ -144,7 +170,7 @@ public class Api {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse patch(String url, String data, Map<String, String> headers) {
+    public static String patch(String url, String data, Map<String, String> headers) {
         return HttpKit.getDelegate().patch(url, data, headers);
     }
 
@@ -157,7 +183,7 @@ public class Api {
      * @param file          上传文件
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse upload(String url, String authorization, String data, File file) {
+    public static String upload(String url, String authorization, String data, File file) {
         Map<String, Object> paramMap = new HashMap<>(2);
         paramMap.put("file", file);
         paramMap.put("meta", data);
@@ -172,7 +198,7 @@ public class Api {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse upload(String url, Map<String, Object> params, Map<String, String> headers) {
+    public static String upload(String url, Map<String, Object> params, Map<String, String> headers) {
         return HttpKit.getDelegate().post(url, params, headers);
     }
 
@@ -190,7 +216,7 @@ public class Api {
      * @param data          请求参数
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse delete(String url, String authorization, String data) {
+    public static String delete(String url, String authorization, String data) {
         return delete(url, data, getHeaders(authorization));
     }
 
@@ -202,7 +228,7 @@ public class Api {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse delete(String url, String data, Map<String, String> headers) {
+    public static String delete(String url, String data, Map<String, String> headers) {
         return HttpKit.getDelegate().delete(url, data, headers);
     }
 
@@ -214,7 +240,7 @@ public class Api {
      * @param data          请求参数
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse post(String url, String authorization, String data) {
+    public static String post(String url, String authorization, String data) {
         return post(url, data, getHeaders(authorization));
     }
 
@@ -226,17 +252,17 @@ public class Api {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse post(String url, String data, Map<String, String> headers) {
+    public static String post(String url, String data, Map<String, String> headers) {
         log.info("请求路径：{}", url);
         log.info("请求头：{}", JSON.toJSONString(headers));
         log.info("请求体:{}", data);
         StopWatch watch = new StopWatch();
         watch.start();
-        ApiHttpResponse res = HttpKit.getDelegate().post(url, data, headers);
-        log.info("返回参数：{}", JSON.toJSONString(res));
+        String body = HttpKit.getDelegate().post(url, data, headers);
+        log.info("返回参数：{}", body);
         watch.stop();
         log.info("请求耗时:{}ms", watch.getTotalTimeMillis());
-        return res;
+        return body;
     }
 
     /**
@@ -247,12 +273,51 @@ public class Api {
      * @param params        请求参数
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse get(String url, String authorization, Map<String, Object> params) {
+    public static String get(String url, String authorization, Map<String, Object> params) {
         return get(url, params, getHeaders(authorization));
     }
 
-    public static boolean isProd(String url) {
-        return url.startsWith(DomainEnum.PROD.getDomain());
+    private static String download(String url, String authorization, Map<String, Object> params) {
+        return download(url, params, getHeaders(authorization));
+    }
+
+    /**
+     * get 请求
+     *
+     * @param url     请求url
+     * @param params  请求参数
+     * @param headers 请求头
+     * @return {@link ApiHttpResponse}    请求返回的结果
+     */
+    public static String download(String url, Map<String, Object> params, Map<String, String> headers) {
+        log.info("请求路径：{}", url);
+        log.info("请求头：{}", JSON.toJSONString(headers));
+        log.info("请求参数:{}", params);
+        StopWatch watch = new StopWatch();
+        watch.start();
+        try (HttpResponse res = HttpKit.getDelegate().getToResponse(url, params, headers);) {
+            InputStream fileStream = res.bodyStream();
+
+            // 将流转换为字节数组
+            ByteArrayOutputStream buffer = new ByteArrayOutputStream();
+            byte[] data = new byte[1024];
+            int bytesRead;
+            while ((bytesRead = fileStream.read(data, 0, data.length)) != -1) {
+                buffer.write(data, 0, bytesRead);
+            }
+            buffer.flush();
+            byte[] byteArray = buffer.toByteArray();
+
+            // 转换为Base64编码
+            String base64String = Base64.getEncoder().encodeToString(byteArray);
+            log.info("返回参数：{}", base64String);
+            watch.stop();
+            log.info("请求耗时:{}ms", watch.getTotalTimeMillis());
+            return base64String;
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
     }
 
     /**
@@ -263,8 +328,17 @@ public class Api {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}    请求返回的结果
      */
-    public static ApiHttpResponse get(String url, Map<String, Object> params, Map<String, String> headers) {
-        return HttpKit.getDelegate().get(url, params, headers);
+    public static String get(String url, Map<String, Object> params, Map<String, String> headers) {
+        log.info("请求路径：{}", url);
+        log.info("请求头：{}", JSON.toJSONString(headers));
+        log.info("请求参数:{}", params);
+        StopWatch watch = new StopWatch();
+        watch.start();
+        String body = HttpKit.getDelegate().get(url, params, headers);
+        log.info("返回参数：{}", body);
+        watch.stop();
+        log.info("请求耗时:{}ms", watch.getTotalTimeMillis());
+        return body;
     }
 
     public static Map<String, String> getHeaders(String authorization) {

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/base/AbstractHttpDelegate.java

@@ -74,9 +74,8 @@ public abstract class AbstractHttpDelegate {
      * @param headers  请求头
      * @return {@link ApiHttpResponse} 请求返回的结果
      */
-    public ApiHttpResponse get(String url, Map<String, Object> paramMap, Map<String, String> headers) {
-        HttpResponse httpResponse = getToResponse(url, paramMap, headers);
-        return JSONObject.parseObject(httpResponse.body(), ApiHttpResponse.class);
+    public String get(String url, Map<String, Object> paramMap, Map<String, String> headers) {
+        return getToResponse(url, paramMap, headers).body();
     }
 
     /**
@@ -109,9 +108,8 @@ public abstract class AbstractHttpDelegate {
      * @param headers  请求头
      * @return {@link ApiHttpResponse}  请求返回的结果
      */
-    public ApiHttpResponse post(String url, Map<String, Object> paramMap, Map<String, String> headers) {
-        HttpResponse httpResponse = postToResponse(url, headers, paramMap);
-        return JSONObject.parseObject(httpResponse.body(), ApiHttpResponse.class);
+    public String post(String url, Map<String, Object> paramMap, Map<String, String> headers) {
+        return postToResponse(url, headers, paramMap).body();
     }
 
     /**
@@ -122,9 +120,8 @@ public abstract class AbstractHttpDelegate {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}  请求返回的结果
      */
-    public ApiHttpResponse post(String url, String data, Map<String, String> headers) {
-        HttpResponse httpResponse = postToResponse(url, headers, data);
-        return JSONObject.parseObject(httpResponse.body(), ApiHttpResponse.class);
+    public String post(String url, String data, Map<String, String> headers) {
+        return postToResponse(url, headers, data).body();
     }
 
     /**
@@ -148,9 +145,8 @@ public abstract class AbstractHttpDelegate {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}  请求返回的结果
      */
-    public ApiHttpResponse patch(String url, String data, Map<String, String> headers) {
-        HttpResponse httpResponse = patchToResponse(url, headers, data);
-        return JSONObject.parseObject(httpResponse.body(), ApiHttpResponse.class);
+    public String patch(String url, String data, Map<String, String> headers) {
+        return patchToResponse(url, headers, data).body();
     }
 
     /**
@@ -174,9 +170,8 @@ public abstract class AbstractHttpDelegate {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}  请求返回的结果
      */
-    public ApiHttpResponse delete(String url, String data, Map<String, String> headers) {
-        HttpResponse httpResponse = deleteToResponse(url, headers, data);
-        return JSONObject.parseObject(httpResponse.body(), ApiHttpResponse.class);
+    public String delete(String url, String data, Map<String, String> headers) {
+        return deleteToResponse(url, headers, data).body();
     }
 
     /**
@@ -200,9 +195,8 @@ public abstract class AbstractHttpDelegate {
      * @param headers 请求头
      * @return {@link ApiHttpResponse}  请求返回的结果
      */
-    public ApiHttpResponse put(String url, String data, Map<String, String> headers) {
-        HttpResponse httpResponse = putToResponse(url, headers, data);
-        return JSONObject.parseObject(httpResponse.body(), ApiHttpResponse.class);
+    public String put(String url, String data, Map<String, String> headers) {
+        return putToResponse(url, headers, data).body();
     }
 
     /**
@@ -330,7 +324,7 @@ public abstract class AbstractHttpDelegate {
      * @param headers  请求头
      * @return {@link HttpResponse} 请求返回的结果
      */
-    private HttpResponse getToResponse(String url, Map<String, Object> paramMap, Map<String, String> headers) {
+    public HttpResponse getToResponse(String url, Map<String, Object> paramMap, Map<String, String> headers) {
         return HttpRequest.get(url)
             .setProxy(getProxy())
             .addHeaders(headers)

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/base/RequestMethodEnum.java

@@ -47,6 +47,10 @@ public enum RequestMethodEnum {
      * PATCH 请求
      */
     PATCH("PATCH"),
+    /**
+     *
+     */
+    DOWNLOAD("GET");
     ;
 
     private final String method;

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/constant/OrderStatus.java

+package org.dromara.common.weishi.constant;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * @author wenhe
+ */
+@Getter
+@AllArgsConstructor
+public enum OrderStatus {
+    E("E", "已承保"),
+    W("W", "已撤单"),
+    P("P", "待支付"),
+    A("A", "已作废"),
+    D("D", "已删除");
+
+    private final String key;
+    private final String value;
+}

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/enums/insure/InsureApiEnum.java

@@ -22,10 +22,18 @@ public enum InsureApiEnum implements ApiEnum {
      * 签单接口
      */
     ISSUE("/api/v1/insure/issue/{OrderNum}", "签单接口"),
+    /**
+     * 作废接口
+     */
+    ABANDON("/api/v1/order/abandon/{orderId}", "作废接口"),
+    /**
+     * 订单详情
+     */
+    DETAIL("/api/v1/order/detail/{orderId}", "订单详情"),
     /**
      * 订单撤单接口
      */
-    CANCEL("/api/v1/order/insure/{orderNum}", "订单撤单接口"),
+    CANCEL("/api/v1/insure/withdraw/{orderNum}", "订单撤单接口"),
     /**
      * 保单撤单接口
      */
@@ -38,6 +46,10 @@ public enum InsureApiEnum implements ApiEnum {
      * 获取投/被保险人申明接口
      */
     AVOW_LIST("/api/v1/insurer/1/avow/list", "获取投/被保险人申明接口"),
+    /**
+     * 保单下载
+     */
+    DOWNLOAD("/api/v1/insure/download/order/{orderNum}", "保单下载接口"),
     ;
 
     /**

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/model/req/ApplyRequest.java

 package org.dromara.common.weishi.model.req;
 
+import com.alibaba.fastjson.annotation.JSONField;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
@@ -14,50 +15,67 @@ public class ApplyRequest {
     /**
      * 流水号，幂等且唯一不能重复
      */
+    @JSONField(name = "BatchNum")
     private String BatchNum;
+    /**
+     * 产品id
+     */
+    @JSONField(name = "ProductId")
+    private Integer ProductId;
     /**
      * 产品计划代码，需联系客户经理提供
      */
+    @JSONField(name = "ProductNum")
     private String ProductNum;
     /**
      * 保单生效时间，格式为YYYY-MM-DD HH:MM:SS
      */
+    @JSONField(name = "BeginDate")
     private String BeginDate;
     /**
      * 保单终止时间，格式为YYYY-MM-DD HH:MM:SS
      */
+    @JSONField(name = "EndDate")
     private String EndDate;
     /**
      * 旅行目的地
      */
+    @JSONField(name = "TourDest")
     private String TourDest;
     /**
      * 旅行团编号/航班号
      */
+    @JSONField(name = "TourNum")
     private String TourNum;
     /**
      * 标准保费合计，是Units中所有标准保费的总和
      */
+    @JSONField(name = "StdPremium")
     private BigDecimal StdPremium;
     /**
      * 实收保费合计，是Units中所有实收保费的总和
      */
+    @JSONField(name = "ActPremium")
     private BigDecimal ActPremium;
     /**
      * 投保单元列表，每个投保必须包含一个以上投保单元，一次投保多个被保险人且要求单人保单时此字段为多个元素，否则为单个元素
      */
+    @JSONField(name = "Units")
     private List<InsureUnit> Units;
     /**
      * 投保可选参数
      */
+    @JSONField(name = "Options")
     private Options Options;
     /**
      * 支付参数，在余额不足时需要此参数
      */
+    @JSONField(name = "PaymentOptions")
     private PaymentOptions PaymentOptions;
     /**
      * 发票信息，需要开票时填写
      */
+    @JSONField(name = "Taxpayer")
     private Taxpayer Taxpayer;
 
     @Data
@@ -65,10 +83,12 @@ public class ApplyRequest {
         /**
          * 投保人信息，若未指定投保人，默认选取第一个成年人作为投保人
          */
+        @JSONField(name = "PolicyHolder")
         private PolicyHolder PolicyHolder;
         /**
          * 被保人列表
          */
+        @JSONField(name = "Insureds")
         private List<Insurant> Insureds;
     }
 
@@ -77,26 +97,32 @@ public class ApplyRequest {
         /**
          * 投保人姓名/名称
          */
+        @JSONField(name = "Name")
         private String Name;
         /**
          * 投保人性别
          */
+        @JSONField(name = "Gender")
         private String Gender;
         /**
          * 证件类型，参考字段枚举
          */
+        @JSONField(name = "IDTp")
         private String IDTp;
         /**
          * 证件代码
          */
+        @JSONField(name = "IDNum")
         private String IDNum;
         /**
          * 出生日期
          */
+        @JSONField(name = "Birthday")
         private String Birthday;
         /**
          * 手机号码
          */
+        @JSONField(name = "Mobile")
         private String Mobile;
     }
 
@@ -105,38 +131,47 @@ public class ApplyRequest {
         /**
          * 被保险人姓名
          */
+        @JSONField(name = "Name")
         private String Name;
         /**
          * 性别，M代表男，F代表女，U代表未知
          */
+        @JSONField(name = "Gender")
         private String Gender;
         /**
          * 证件类型，参考字段枚举
          */
+        @JSONField(name = "IDTp")
         private String IDTp;
         /**
          * 证件号码
          */
+        @JSONField(name = "IDNum")
         private String IDNum;
         /**
          * 出生日期
          */
+        @JSONField(name = "Birthday")
         private String Birthday;
         /**
          * 手机号码
          */
+        @JSONField(name = "Mobile")
         private String Mobile;
         /**
          * 与投保人关系，参考字段枚举
          */
+        @JSONField(name = "RelationTp")
         private String RelationTp;
         /**
          * 标准保费
          */
+        @JSONField(name = "StdPremium")
         private BigDecimal StdPremium;
         /**
          * 实收保费
          */
+        @JSONField(name = "ActPremium")
         private BigDecimal ActPremium;
     }
 

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/model/res/ApplyResponse.java

@@ -12,13 +12,13 @@ import java.util.List;
 @AllArgsConstructor
 public class ApplyResponse {
     /**
-     * 流水号
+     * 订单id
      */
-    private String BatchNum;
+    private Integer OrderID;
     /**
-     * 产品代码
+     * 订单号
      */
-    private String ProductNum;
+    private String OrderNum;
     /**
      * 保单生效时间
      */
@@ -27,22 +27,6 @@ public class ApplyResponse {
      * 保单终止时间
      */
     private String EndDate;
-    /**
-     * 旅行团编号
-     */
-    private String TourNum;
-    /**
-     * 旅行目的地
-     */
-    private String TourDest;
-    /**
-     * 发票大类，p - 个人，E - 企业，U - 未知
-     */
-    private String InvoiceKind;
-    /**
-     * 开具发票的类型
-     */
-    private String InvoiceTp;
     /**
      * 标准保费
      */
@@ -52,48 +36,24 @@ public class ApplyResponse {
      */
     private BigDecimal ActPremium;
     /**
-     * 投保单元列表
-     */
-    private List<Unit> Units;
-    /**
-     * 投保数据格式，P:图片, D - 数据
-     */
-    private String DataTp;
-    /**
-     * 订单号
+     * 订单下载链接
      */
-    private String OrderNum;
+    private String OrderUrl;
     /**
-     * 计划ID
+     * 投保单元列表
      */
-    private int PlanID;
+    private List<Unit> Units;
     /**
      * 返回代码，0:成功，其他:失败
      */
-    private int ResultTp;
+    private Integer ResultTp;
     /**
      * 返回内容
      */
     private String ResultMsg;
-    /**
-     * 保单下载链接
-     */
-    private String PolicyUrl;
-    /**
-     * 订单下载链接
-     */
-    private String OrderUrl;
 
     @Data
     public static class Unit {
-        /**
-         * 投保人信息，投保人年龄必须大于18周岁
-         */
-        private PolicyHolder PolicyHolder;
-        /**
-         * 被保人列表
-         */
-        private List<Insured> Insureds;
         /**
          * 标准保费，Insureds下总被保险人数*标准单价
          */
@@ -106,85 +66,18 @@ public class ApplyResponse {
          * 保单号，投保时返回
          */
         private String PolicyNum;
+        /**
+         * 保单url
+         */
+        private String PolicyUrl;
         /**
          * 返回代码，0:成功，其他:失败
          */
-        private int ResultTp;
+        private Integer ResultTp;
         /**
          * 返回消息
          */
         private String ResultMsg;
     }
 
-    @Data
-    public static class PolicyHolder {
-        /**
-         * 投保人姓名/名称
-         */
-        private String Name;
-        /**
-         * 投保人性别
-         */
-        private String Gender;
-        /**
-         * 证件类型，参考字段枚举
-         */
-        private String IDTp;
-        /**
-         * 证件代码
-         */
-        private String IDNum;
-        /**
-         * 出生日期
-         */
-        private String Birthday;
-        /**
-         * 手机号码
-         */
-        private String Mobile;
-    }
-
-    @Data
-    public static class Insured {
-        /**
-         * 被保险人姓名
-         */
-        private String Name;
-        /**
-         * 性别，M男/F女/U未知
-         */
-        private String Gender;
-        /**
-         * 证件类型，参考字段枚举
-         */
-        private String IDTp;
-        /**
-         * 证件号码
-         */
-        private String IDNum;
-        /**
-         * 出生日期
-         */
-        private String Birthday;
-        /**
-         * 手机号码
-         */
-        private String Mobile;
-        /**
-         * 与投保人关系，参考字段枚举
-         */
-        private String RelationTp;
-        /**
-         * 标准保费
-         */
-        private BigDecimal StdPremium;
-        /**
-         * 实收保费
-         */
-        private BigDecimal ActPremium;
-        /**
-         * 被保险人ID
-         */
-        private int InsuredID;
-    }
 }

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/model/res/AuthResponse.java

@@ -15,7 +15,7 @@ public class AuthResponse {
     /**
      * 超时时间
      */
-    private int expires_in;
+    private Integer expires_in;
     /**
      * 令牌类型
      */

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/model/res/DetailResponse.java

+package org.dromara.common.weishi.model.res;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.math.BigDecimal;
+import java.util.List;
+
+/**
+ * @author wenhe
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class DetailResponse {
+    /**
+     * 订单id
+     */
+    private Integer OrderID;
+    /**
+     * 订单号
+     */
+    private String OrderNum;
+    /**
+     * 保单生效时间
+     */
+    private String BeginDate;
+    /**
+     * 保单终止时间
+     */
+    private String EndDate;
+    /**
+     * 创建时间
+     */
+    private String CreatedTime;
+    /**
+     * 过期时间
+     */
+    private String OverDate;
+    /**
+     * 计划名称
+     */
+    private String PlanName;
+    /**
+     * 保险公司
+     */
+    private String InsurerAbbr;
+    /**
+     * 保单数量
+     */
+    private Integer PolicyCount;
+    /**
+     * 被保人数量
+     */
+    private Integer InsuredCount;
+    /**
+     * 标准保费
+     */
+    private BigDecimal StdPremium;
+    /**
+     * 实收保费
+     */
+    private BigDecimal ActPremium;
+    /**
+     * 订单状态
+     */
+    private String status;
+    /**
+     * 被保人列表
+     */
+    private List<Insured> Insureds;
+
+    @Data
+    public static class Insured {
+        /**
+         * 标准保费，Insureds下总被保险人数*标准单价
+         */
+        private BigDecimal StdPremium;
+        /**
+         * 实收保费
+         */
+        private BigDecimal ActPremium;
+        /**
+         * 受益人
+         */
+        private String Beneficiaries;
+        /**
+         * 出生日期
+         */
+        private String Birthday;
+        /**
+         * 性别，M代表男，F代表女，U代表未知
+         */
+        private String Gender;
+        /**
+         * 证件号码
+         */
+        private String IDNum;
+        /**
+         * 证件类型，参考字段枚举
+         */
+        private String IDTp;
+        /**
+         * 被保人id
+         */
+        private Integer InsuredID;
+        /**
+         * 手机号码
+         */
+        private String Mobile;
+        /**
+         * 被保险人姓名
+         */
+        private String Name;
+        /**
+         * 停顿
+         */
+        private Boolean Pausing;
+        /**
+         * 计划名称
+         */
+        private String PlanName;
+        /**
+         * 保单id
+         */
+        private Integer PolicyID;
+        /**
+         * 保单编码
+         */
+        private String PolicyNum;
+        /**
+         * 与投保人关系，参考字段枚举
+         */
+        private String RelationTp;
+        /**
+         * 状态
+         */
+        private String Status;
+    }
+}

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/model/res/IssueResponse.java

@@ -15,37 +15,21 @@ import java.util.List;
 @AllArgsConstructor
 public class IssueResponse {
     /**
-     * 渠道类型，默认是B
+     * 订单id
      */
-    private String ChannelTp;
+    private Integer OrderID;
     /**
-     * 流水号
-     */
-    private String BatchNum;
-    /**
-     * 产品代码
+     * 订单号
      */
-    private String ProductNum;
+    private String OrderNum;
     /**
-     * 保单生效时间，格式：yyyy-MM-dd HH:mm:ss
+     * 保单生效时间
      */
     private String BeginDate;
     /**
-     * 保单终止时间，格式：yyyy-MM-dd HH:mm:ss
+     * 保单终止时间
      */
     private String EndDate;
-    /**
-     * 旅行团编号
-     */
-    private String TourNum;
-    /**
-     * 旅行目的地
-     */
-    private String TourDest;
-    /**
-     * 开具发票的类型
-     */
-    private String InvoiceTp;
     /**
      * 标准保费
      */
@@ -55,54 +39,24 @@ public class IssueResponse {
      */
     private BigDecimal ActPremium;
     /**
-     * 投保单元列表
+     * 订单下载链接
      */
-    private List<Unit> Units;
+    private String OrderUrl;
     /**
-     * 投保数据格式
-     */
-    private String DataTp;
-    /**
-     * 订单号
-     */
-    private String OrderNum;
-    /**
-     * 返回代码，0表示成功
-     */
-    private int ResultNum;
-    /**
-     * 付款链接，余额不足时返回
-     */
-    private String PaymentUrl;
-    /**
-     * 付款单号
-     */
-    private String PaymentNum;
-    /**
-     * 付款金额
+     * 投保单元列表
      */
-    private BigDecimal PaymentAmt;
+    private List<Unit> Units;
     /**
-     * 返回代码
+     * 返回代码，0:成功，其他:失败
      */
-    private String ResultTp;
+    private Integer ResultTp;
     /**
-     * 提示文本
+     * 返回内容
      */
     private String ResultMsg;
 
     @Data
-    @NoArgsConstructor
-    @AllArgsConstructor
     public static class Unit {
-        /**
-         * 投保人信息，年龄必须大于18周岁
-         */
-        private PolicyHolder PolicyHolder;
-        /**
-         * 被保人列表
-         */
-        private List<Insured> Insureds;
         /**
          * 标准保费，Insureds下总被保险人数*标准单价
          */
@@ -112,96 +66,20 @@ public class IssueResponse {
          */
         private BigDecimal ActPremium;
         /**
-         * 标准退款金额
-         */
-        private BigDecimal StdRefund;
-        /**
-         * 实际退款金额
-         */
-        private BigDecimal ActRefund;
-        /**
-         * 保单号，成功时返回
+         * 保单号，投保时返回
          */
         private String PolicyNum;
         /**
-         * 返回代码，0表示成功
-         */
-        private String ResultTp;
-        /**
-         * 提示文本
-         */
-        private String ResultMsg;
-    }
-
-    @Data
-    @NoArgsConstructor
-    @AllArgsConstructor
-    public static class PolicyHolder {
-        /**
-         * 投保人姓名/名称
+         * 保单url
          */
-        private String Name;
+        private String PolicyUrl;
         /**
-         * 投保人性别
+         * 返回代码，0:成功，其他:失败
          */
-        private String Gender;
+        private Integer ResultTp;
         /**
-         * 证件类型：I-身份证，P-护照，J-军官证，K-通行证，T-台湾通行证，G-港澳通行证，O-其他，E-统一信用代码
+         * 返回消息
          */
-        private String IDTp;
-        /**
-         * 证件代码
-         */
-        private String IDNum;
-        /**
-         * 出生日期，格式：yyyy-MM-dd
-         */
-        private String Birthday;
-    }
-
-    @Data
-    @NoArgsConstructor
-    @AllArgsConstructor
-    public static class Insured {
-        /**
-         * 被保险人姓名
-         */
-        private String Name;
-        /**
-         * 性别：M-男，F-女，U-未知
-         */
-        private String Gender;
-        /**
-         * 证件类型：I-身份证，P-护照，J-军官证，K-通行证，T-台湾通行证，G-港澳通行证，O-其他，E-统一信用代码
-         */
-        private String IDTp;
-        /**
-         * 证件号码
-         */
-        private String IDNum;
-        /**
-         * 出生日期，格式：yyyy-MM-dd
-         */
-        private String Birthday;
-        /**
-         * 与投保人关系
-         */
-        private String RelationTp;
-        /**
-         * 标准保费
-         */
-        private BigDecimal StdPremium;
-        /**
-         * 实收保费
-         */
-        private BigDecimal ActPremium;
-        /**
-         * 标准退款金额
-         */
-        private BigDecimal StdRefund;
-        /**
-         * 实际退款金额
-         */
-        private BigDecimal ActRefund;
+        private String ResultMsg;
     }
 }

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/model/res/ProposalResponse.java

@@ -7,13 +7,13 @@ import java.util.List;
 @Data
 public class ProposalResponse {
     /**
-     * 流水号
+     * 订单id
      */
-    private String BatchNum;
+    private Integer OrderID;
     /**
-     * 产品代码
+     * 订单号
      */
-    private String ProductNum;
+    private String OrderNum;
     /**
      * 保单生效时间
      */
@@ -22,22 +22,6 @@ public class ProposalResponse {
      * 保单终止时间
      */
     private String EndDate;
-    /**
-     * 旅行团编号
-     */
-    private String TourNum;
-    /**
-     * 旅行目的地
-     */
-    private String TourDest;
-    /**
-     * 发票大类，p-个人,E-企业,U-未知
-     */
-    private String InvoiceKind;
-    /**
-     * 开具发票的类型
-     */
-    private String InvoiceTp;
     /**
      * 标准保费
      */
@@ -49,23 +33,11 @@ public class ProposalResponse {
     /**
      * 投保单元列表
      */
-    private List<Unit> Units;
-    /**
-     * 投保数据格式，P-图片, D-数据
-     */
-    private String DataTp;
-    /**
-     * 订单号，后续签单，下载，撤单需要用
-     */
-    private String OrderNum;
-    /**
-     * 计划ID
-     */
-    private int PlanID;
+    private List<IssueResponse.Unit> Units;
     /**
-     * 返回代码，0:成功,其他:失败
+     * 返回代码，0:成功，其他:失败
      */
-    private int ResultTp;
+    private Integer ResultTp;
     /**
      * 返回内容
      */
@@ -73,14 +45,6 @@ public class ProposalResponse {
 
     @Data
     public static class Unit {
-        /**
-         * 投保人信息，投保人年龄必须大于18周岁
-         */
-        private PolicyHolder PolicyHolder;
-        /**
-         * 被保人列表
-         */
-        private List<Insured> Insureds;
         /**
          * 标准保费，Insureds下总被保险人数*标准单价
          */
@@ -90,88 +54,16 @@ public class ProposalResponse {
          */
         private BigDecimal ActPremium;
         /**
-         * 核保单号，投保时返回
+         * 保单号，投保时返回
          */
         private String PolicyNum;
         /**
-         * 返回代码，0:成功,其他:失败
+         * 返回代码，0:成功，其他:失败
          */
-        private int ResultTp;
+        private Integer ResultTp;
         /**
          * 返回消息
          */
         private String ResultMsg;
     }
-
-    @Data
-    public static class PolicyHolder {
-        /**
-         * 投保人姓名/名称
-         */
-        private String Name;
-        /**
-         * 投保人性别
-         */
-        private String Gender;
-        /**
-         * 证件类型，参考字段枚举
-         */
-        private String IDTp;
-        /**
-         * 证件代码
-         */
-        private String IDNum;
-        /**
-         * 出生日期
-         */
-        private String Birthday;
-        /**
-         * 手机号码
-         */
-        private String Mobile;
-    }
-
-    @Data
-    public static class Insured {
-        /**
-         * 被保险人姓名
-         */
-        private String Name;
-        /**
-         * 性别，M男/F女/U未知
-         */
-        private String Gender;
-        /**
-         * 证件类型，参考字段枚举
-         */
-        private String IDTp;
-        /**
-         * 证件号码
-         */
-        private String IDNum;
-        /**
-         * 出生日期
-         */
-        private String Birthday;
-        /**
-         * 手机号码
-         */
-        private String Mobile;
-        /**
-         * 与投保人关系，参考字段枚举
-         */
-        private String RelationTp;
-        /**
-         * 标准保费
-         */
-        private BigDecimal StdPremium;
-        /**
-         * 实收保费
-         */
-        private BigDecimal ActPremium;
-        /**
-         * 被保险人ID
-         */
-        private int InsuredID;
-    }
 }

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/service/WeishiService.java

 package org.dromara.common.weishi.service;
 
 import org.dromara.common.weishi.model.req.ApplyRequest;
+import org.dromara.common.weishi.model.req.AuthRequest;
 import org.dromara.common.weishi.model.req.ProposalRequest;
 import org.dromara.common.weishi.model.res.*;
 
@@ -11,12 +12,13 @@ import java.util.List;
  */
 public interface WeishiService {
 
+
     /**
-     * 认证接口
-     *
-     * @return 数据
+     * 认证
+     * @param request 请求参数
+     * @return 响应参数
      */
-    AuthResponse authorize();
+    AuthResponse authorize(AuthRequest request);
 
     /**
      * 保险下单接口
@@ -24,7 +26,7 @@ public interface WeishiService {
      * @param request 请求参数
      * @return 响应数据
      */
-    ApplyResponse insureApply(ApplyRequest request);
+    ApplyResponse insureApply(String token, ApplyRequest request);
 
     /**
      * 核保接口
@@ -32,7 +34,7 @@ public interface WeishiService {
      * @param request 请求参数
      * @return 响应数据
      */
-    ProposalResponse insureProposal(ProposalRequest request);
+    ProposalResponse insureProposal(String token, ProposalRequest request);
 
     /**
      * 签单接口
@@ -40,28 +42,53 @@ public interface WeishiService {
      * @param orderNum 订单号
      * @return 数据
      */
-    IssueResponse insureDetail(String orderNum);
+    IssueResponse insureIssue(String token, String orderNum);
+
+    /**
+     * 作废接口
+     * @param token token
+     * @param orderId 订单id
+     */
+    void insureAbandon(String token, Integer orderId);
+
+    /**
+     * 订单详情
+     *
+     * @param token   token
+     * @param orderId 订单id
+     * @return 数据
+     */
+    DetailResponse insureDetail(String token, Integer orderId);
+
+    /**
+     * 保单下载
+     *
+     * @param token   token
+     * @param orderNum 订单编码
+     * @return base64
+     */
+    String insureDownload(String token, String orderNum);
 
     /**
      * 订单撤单接口
      *
      * @param orderNum 订单号
      */
-    void insureCancel(String orderNum);
+    void insureCancel(String token, String orderNum);
 
     /**
      * 保单撤单接口
      *
      * @param policyNum 保单号
      */
-    void policyCancel(String policyNum);
+    void policyCancel(String token, String policyNum);
 
     /**
      * 产品列表接口
      *
      * @return 产品列表
      */
-    List<ProductsResponse> productList();
+    List<ProductsResponse> productList(String token);
 
     /**
      * 产品详情
@@ -69,7 +96,7 @@ public interface WeishiService {
      * @param productId 产品id
      * @return 产品详情
      */
-    ProductResponse productDetail(Integer productId);
+    ProductResponse productDetail(String token, Integer productId);
 
     /**
      * 获取保险公司相关文档接口
@@ -78,5 +105,5 @@ public interface WeishiService {
      * @param annexTp   annexTp
      * @return 数据
      */
-    AnnexResponse annex(Integer productId,String annexTp);
+    AnnexResponse annex(String token, Integer productId, String annexTp);
 }

ruoyi-common/ruoyi-common-51weishi/src/main/java/org/dromara/common/weishi/service/impl/WeishiServiceImpl.java

@@ -7,7 +7,6 @@ import org.dromara.common.weishi.Api;
 import org.dromara.common.weishi.base.RequestMethodEnum;
 import org.dromara.common.weishi.common.ApiHttpResponse;
 import org.dromara.common.weishi.common.Code;
-import org.dromara.common.weishi.config.UserConfig;
 import org.dromara.common.weishi.enums.DomainEnum;
 import org.dromara.common.weishi.enums.auth.AuthApiEnum;
 import org.dromara.common.weishi.enums.insure.InsureApiEnum;
@@ -30,16 +29,12 @@ import java.util.Objects;
 public class WeishiServiceImpl implements WeishiService {
 
     @Override
-    public AuthResponse authorize() {
+    public AuthResponse authorize(AuthRequest request) {
         ApiHttpResponse res = Api.v1(RequestMethodEnum.POST,
-            DomainEnum.TEST.getDomain(),
+            DomainEnum.PROD.getDomain(),
             AuthApiEnum.AUTHORIZE.getUrl(),
             null,
-            JSON.toJSONString(
-                new AuthRequest()
-                    .setUsername(UserConfig.USERNAME)
-                    .setPassword(UserConfig.PASSWORD)
-            ));
+            JSON.toJSONString(request));
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());
         }
@@ -47,56 +42,105 @@ public class WeishiServiceImpl implements WeishiService {
     }
 
     @Override
-    public ApplyResponse insureApply(ApplyRequest request) {
-        ApiHttpResponse res = Api.v1(RequestMethodEnum.POST,
-            DomainEnum.TEST.getDomain(),
+    public ApplyResponse insureApply(String token, ApplyRequest request) {
+        ApplyResponse res = Api.v1(RequestMethodEnum.POST,
+            DomainEnum.PROD.getDomain(),
             InsureApiEnum.APPLY.getUrl(),
-            getToken(),
-            JSON.toJSONString(request));
+            token,
+            JSON.toJSONString(request),
+            ApplyResponse.class);
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());
         }
-        return JSON.parseObject(res.getData(), ApplyResponse.class);
+        return res;
     }
 
     @Override
-    public ProposalResponse insureProposal(ProposalRequest request) {
-        ApiHttpResponse res = Api.v1(RequestMethodEnum.POST,
-            DomainEnum.TEST.getDomain(),
+    public ProposalResponse insureProposal(String token, ProposalRequest request) {
+        ProposalResponse res = Api.v1(RequestMethodEnum.POST,
+            DomainEnum.PROD.getDomain(),
             InsureApiEnum.PROPOSAL.getUrl(),
-            getToken(),
-            JSON.toJSONString(request));
+            token,
+            JSON.toJSONString(request),
+            ProposalResponse.class);
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());
         }
-        return JSON.parseObject(res.getData(), ProposalResponse.class);
+        return res;
     }
 
     @Override
-    public IssueResponse insureDetail(String orderNum) {
+    public IssueResponse insureIssue(String token, String orderNum) {
         Map<String, Object> map = MapUtil.<String, Object>builder()
             .put("OrderNum", orderNum)
             .build();
-        ApiHttpResponse res = Api.v1(RequestMethodEnum.POST,
-            DomainEnum.TEST.getDomain(),
+        IssueResponse res = Api.v1(RequestMethodEnum.POST,
+            DomainEnum.PROD.getDomain(),
             StrUtil.format(InsureApiEnum.ISSUE.getUrl(), map),
-            getToken(),
+            token,
+            null,
+            IssueResponse.class);
+        if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
+            throw new WeishiException(res.getResultMsg());
+        }
+        return res;
+    }
+
+    @Override
+    public void insureAbandon(String token, Integer orderId) {
+        Map<String, Object> map = MapUtil.<String, Object>builder()
+            .put("orderId", orderId)
+            .build();
+        IssueResponse res = Api.v1(RequestMethodEnum.POST,
+            DomainEnum.PROD.getDomain(),
+            StrUtil.format(InsureApiEnum.ABANDON.getUrl(), map),
+            token,
+            null,
+            IssueResponse.class);
+        if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
+            throw new WeishiException(res.getResultMsg());
+        }
+    }
+
+    @Override
+    public DetailResponse insureDetail(String token, Integer orderId) {
+        Map<String, Object> map = MapUtil.<String, Object>builder()
+            .put("orderId", orderId)
+            .build();
+        ApiHttpResponse res = Api.v1(RequestMethodEnum.GET,
+            DomainEnum.PROD.getDomain(),
+            StrUtil.format(InsureApiEnum.DETAIL.getUrl(), map),
+            token,
             null);
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());
         }
-        return JSON.parseObject(res.getData(), IssueResponse.class);
+        return JSON.parseObject(res.getData(), DetailResponse.class);
     }
 
     @Override
-    public void insureCancel(String orderNum) {
+    public String insureDownload(String token, String orderNum) {
         Map<String, Object> map = MapUtil.<String, Object>builder()
-            .put("OrderNum", orderNum)
+            .put("orderNum", orderNum)
+            .build();
+        return Api.v1(RequestMethodEnum.DOWNLOAD,
+            DomainEnum.PROD.getDomain(),
+            StrUtil.format(InsureApiEnum.DOWNLOAD.getUrl(), map),
+            token,
+            null,
+            null,
+            String.class);
+    }
+
+    @Override
+    public void insureCancel(String token, String orderNum) {
+        Map<String, Object> map = MapUtil.<String, Object>builder()
+            .put("orderNum", orderNum)
             .build();
         ApiHttpResponse res = Api.v1(RequestMethodEnum.POST,
-            DomainEnum.TEST.getDomain(),
+            DomainEnum.PROD.getDomain(),
             StrUtil.format(InsureApiEnum.CANCEL.getUrl(), map),
-            getToken(),
+            token,
             null);
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());
@@ -104,35 +148,26 @@ public class WeishiServiceImpl implements WeishiService {
     }
 
     @Override
-    public void policyCancel(String policyNum) {
+    public void policyCancel(String token, String policyNum) {
         Map<String, Object> map = MapUtil.<String, Object>builder()
             .put("policyNum", policyNum)
             .build();
         ApiHttpResponse res = Api.v1(RequestMethodEnum.POST,
-            DomainEnum.TEST.getDomain(),
+            DomainEnum.PROD.getDomain(),
             StrUtil.format(InsureApiEnum.POLICY_CANCEL.getUrl(), map),
-            getToken(),
+            token,
             null);
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());
         }
     }
 
-    /**
-     * 获取token
-     *
-     * @return token
-     */
-    private String getToken() {
-        return authorize().getAccess_token();
-    }
-
     @Override
-    public List<ProductsResponse> productList() {
+    public List<ProductsResponse> productList(String token) {
         ApiHttpResponse res = Api.v1(RequestMethodEnum.GET,
-            DomainEnum.TEST.getDomain(),
+            DomainEnum.PROD.getDomain(),
             ProductApiEnum.PRODUCT_LIST.getUrl(),
-            getToken(),
+            token,
             null);
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());
@@ -141,14 +176,14 @@ public class WeishiServiceImpl implements WeishiService {
     }
 
     @Override
-    public ProductResponse productDetail(Integer productId) {
+    public ProductResponse productDetail(String token, Integer productId) {
         Map<String, Object> map = MapUtil.<String, Object>builder()
             .put("productId", productId)
             .build();
-        ApiHttpResponse res = Api.v1(RequestMethodEnum.POST,
-            DomainEnum.TEST.getDomain(),
+        ApiHttpResponse res = Api.v1(RequestMethodEnum.GET,
+            DomainEnum.PROD.getDomain(),
             StrUtil.format(ProductApiEnum.PRODUCT_DETAIL.getUrl(), map),
-            getToken(),
+            token,
             null);
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());
@@ -157,15 +192,15 @@ public class WeishiServiceImpl implements WeishiService {
     }
 
     @Override
-    public AnnexResponse annex(Integer productId, String annexTp) {
+    public AnnexResponse annex(String token, Integer productId, String annexTp) {
         Map<String, Object> map = MapUtil.<String, Object>builder()
             .put("productId", productId)
             .put("annexTp", annexTp)
             .build();
-        ApiHttpResponse res = Api.v1(RequestMethodEnum.POST,
-            DomainEnum.TEST.getDomain(),
+        ApiHttpResponse res = Api.v1(RequestMethodEnum.GET,
+            DomainEnum.PROD.getDomain(),
             StrUtil.format(ProductApiEnum.ANNEX.getUrl(), map),
-            getToken(),
+            token,
             null);
         if (!Objects.equals(res.getResultTp(), Code.SUCCESS.getCode())) {
             throw new WeishiException(res.getResultMsg());

ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/mall/weishi/WeishiJob.java

+package org.dromara.job.snailjob.mall.weishi;
+
+import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
+import com.aizuda.snailjob.client.job.core.dto.JobArgs;
+import com.aizuda.snailjob.client.model.ExecuteResult;
+import lombok.AllArgsConstructor;
+import org.apache.dubbo.config.annotation.DubboReference;
+import org.dromara.mall.api.weishi.RemoteWeishiService;
+import org.springframework.stereotype.Component;
+
+/**
+ * 获取token
+ *
+ * @author wenhe
+ */
+@AllArgsConstructor
+@Component
+@JobExecutor(name = "WeishiJob")
+public class WeishiJob {
+
+    @DubboReference
+    private RemoteWeishiService weishiService;
+
+    public ExecuteResult jobExecute(JobArgs jobArgs) {
+        weishiService.getToken();
+        return ExecuteResult.success("跟新卫士token成功");
+    }
+
+}

ruoyi-modules/ruoyi-job/src/main/java/org/dromara/job/snailjob/mall/weishi/WeishiOrderUpdateStatusJob.java

+package org.dromara.job.snailjob.mall.weishi;
+
+import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
+import com.aizuda.snailjob.client.job.core.dto.JobArgs;
+import com.aizuda.snailjob.client.model.ExecuteResult;
+import lombok.AllArgsConstructor;
+import org.apache.dubbo.config.annotation.DubboReference;
+import org.dromara.mall.api.weishi.RemoteWeishiService;
+import org.springframework.stereotype.Component;
+
+/**
+ * 获取token
+ *
+ * @author wenhe
+ */
+@AllArgsConstructor
+@Component
+@JobExecutor(name = "WeishiOrderUpdateStatusJob")
+public class WeishiOrderUpdateStatusJob {
+
+    @DubboReference
+    private RemoteWeishiService weishiService;
+
+    public ExecuteResult jobExecute(JobArgs jobArgs) {
+        weishiService.updateOrderStatus();
+        return ExecuteResult.success("跟新卫士token成功");
+    }
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/AccountController.java

+package org.dromara.mall.controller.weishi.admin;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.RequiredArgsConstructor;
+import org.dromara.common.core.domain.R;
+import org.dromara.common.core.validate.EditGroup;
+import org.dromara.common.idempotent.annotation.RepeatSubmit;
+import org.dromara.common.log.annotation.Log;
+import org.dromara.common.log.enums.BusinessType;
+import org.dromara.common.web.core.BaseController;
+import org.dromara.mall.controller.weishi.admin.bo.AccountBo;
+import org.dromara.mall.controller.weishi.admin.vo.AccountVo;
+import org.dromara.mall.service.weishi.IAccountService;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * 保险账号
+ * 前端访问路由地址为:/mall/account
+ *
+ * @author hzh
+ * @date 2025-05-15
+ */
+@Validated
+@RequiredArgsConstructor
+@RestController
+@RequestMapping("/account")
+public class AccountController extends BaseController {
+
+    private final IAccountService accountService;
+
+    /**
+     * 获取保险账号详细信息
+     *
+     * @param deptId 主键
+     */
+    @GetMapping("/{deptId}")
+    public R<AccountVo> getInfo(@NotNull(message = "部门id不能为空")
+                                @PathVariable Long deptId) {
+        return R.ok(accountService.getOne(new AccountBo().setDeptId(deptId)));
+    }
+
+    /**
+     * 修改保险账号
+     */
+    @Log(title = "保险账号", businessType = BusinessType.UPDATE)
+    @RepeatSubmit()
+    @PutMapping()
+    public R<Void> edit(@Validated(EditGroup.class) @RequestBody AccountBo bo) {
+        return toAjax(accountService.update(bo));
+    }
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/InsureController.java

+package org.dromara.mall.controller.weishi.admin;
+
+import cn.dev33.satoken.annotation.SaCheckPermission;
+import jakarta.servlet.http.HttpServletResponse;
+import jakarta.validation.constraints.NotNull;
+import lombok.RequiredArgsConstructor;
+import org.dromara.common.core.domain.R;
+import org.dromara.common.excel.utils.ExcelUtil;
+import org.dromara.common.log.annotation.Log;
+import org.dromara.common.log.enums.BusinessType;
+import org.dromara.common.mybatis.core.page.PageQuery;
+import org.dromara.common.mybatis.core.page.TableDataInfo;
+import org.dromara.common.web.core.BaseController;
+import org.dromara.mall.controller.weishi.admin.bo.InsureBo;
+import org.dromara.mall.controller.weishi.admin.vo.InsureVo;
+import org.dromara.mall.service.weishi.IInsureService;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+/**
+ * 保险订单
+ * 前端访问路由地址为:/weishi/insure
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+@Validated
+@RequiredArgsConstructor
+@RestController
+@RequestMapping("/insure")
+public class InsureController extends BaseController {
+
+    private final IInsureService insureService;
+
+    /**
+     * 查询保险订单列表
+     */
+    @SaCheckPermission("weishi:insure:list")
+    @GetMapping("/list")
+    public TableDataInfo<InsureVo> list(InsureBo bo, PageQuery pageQuery) {
+        return insureService.queryPageList(bo, pageQuery);
+    }
+
+    /**
+     * 导出保险订单列表
+     */
+    @Log(title = "保险订单", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(InsureBo bo, HttpServletResponse response) {
+        List<InsureVo> list = insureService.queryList(bo);
+        ExcelUtil.exportExcel(list, "保险订单", InsureVo.class, response);
+    }
+
+    /**
+     * 获取保险订单详细信息
+     *
+     * @param id 主键
+     */
+    @GetMapping("/{id}")
+    public R<InsureVo> getInfo(@NotNull(message = "主键不能为空")
+                               @PathVariable Long id) {
+        return R.ok(insureService.getDetail(id));
+    }
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/bo/AccountBo.java

+package org.dromara.mall.controller.weishi.admin.bo;
+
+import io.github.linpeilie.annotations.AutoMapper;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.NotNull;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.dromara.common.core.validate.AddGroup;
+import org.dromara.common.core.validate.EditGroup;
+import org.dromara.common.mybatis.core.domain.BaseEntity;
+import org.dromara.mall.domain.weishi.Account;
+
+/**
+ * 保险账号业务对象 weishi_account
+ *
+ * @author hzh
+ * @date 2025-05-15
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = Account.class, reverseConvertGenerate = false)
+public class AccountBo extends BaseEntity {
+
+    /**
+     * id
+     */
+    private Long id;
+
+    /**
+     * 部门id
+     */
+    @NotNull(message = "部门id不能为空", groups = {AddGroup.class, EditGroup.class})
+    private Long deptId;
+
+    /**
+     * 账号
+     */
+    @NotBlank(message = "账号不能为空", groups = {AddGroup.class, EditGroup.class})
+    private String username;
+
+    /**
+     * 密码
+     */
+    @NotBlank(message = "密码不能为空", groups = {AddGroup.class, EditGroup.class})
+    private String password;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/bo/InsureBo.java

+package org.dromara.mall.controller.weishi.admin.bo;
+
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.dromara.common.mybatis.core.domain.BaseEntity;
+import org.dromara.mall.domain.weishi.Insure;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 保险订单业务对象 weishi_insure
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = Insure.class, reverseConvertGenerate = false)
+public class InsureBo extends BaseEntity {
+
+    private Long id;
+
+    /**
+     * 用户id
+     */
+    private Long userId;
+
+    /**
+     * 会员id
+     */
+    private Long memberId;
+
+    /**
+     * 请求参数
+     */
+    private String reqJson;
+
+    /**
+     * 响应参数
+     */
+    private String resJson;
+
+    /**
+     * 产品信息
+     */
+    private String productJson;
+
+    /**
+     * 产品列表信息
+     */
+    private String productListJson;
+
+    /**
+     * 渠道类型
+     */
+    private String channelTp;
+
+    /**
+     * 流水号，幂等且唯一不能重复
+     */
+    private String batchNum;
+
+    /**
+     * 产品计划代码，需联系客户经理提供
+     */
+    private String productNum;
+
+    /**
+     * 保单生效时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date beginDate;
+
+    /**
+     * 保单终止时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date endDate;
+
+    /**
+     * 订单过期时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date overDate;
+
+    /**
+     * 旅行目的地
+     */
+    private String tourDest;
+
+    /**
+     * 旅行团编号/航班号
+     */
+    private String tourNum;
+
+    /**
+     * 标准保费合计，是Units中所有标准保费的总和
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费合计，是Units中所有实收保费的总和
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 付款链接
+     */
+    private String paymentUrl;
+
+    /**
+     * 付款单号
+     */
+    private String paymentNum;
+
+    /**
+     * 付款金额
+     */
+    private BigDecimal paymentAmt;
+
+    /**
+     * 投保数据格式(	P:图片, D - 数据)
+     */
+    private String dataTp;
+
+    /**
+     * 计划ID
+     */
+    private Integer planId;
+
+    /**
+     * 下单日期
+     */
+    private Date orderTime;
+
+    /**
+     * 订单id
+     */
+    private Integer orderId;
+
+    /**
+     * 订单编码
+     */
+    private String orderNum;
+
+    /**
+     * 订单url
+     */
+    private String orderUrl;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 被保人数
+     */
+    private Integer insuredCount;
+
+    /**
+     * 投保人
+     */
+    private String insuredName;
+
+    /**
+     * 保险公司
+     */
+    private String insuredAbbr;
+
+    /**
+     * 计划名称
+     */
+    private String planName;
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/bo/InsureInsuredsBo.java

+package org.dromara.mall.controller.weishi.admin.bo;
+
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.dromara.common.mybatis.core.domain.BaseEntity;
+import org.dromara.mall.domain.weishi.InsureInsureds;
+
+import java.math.BigDecimal;
+
+/**
+ * 保险订单-被保人业务对象 weishi_insure_insureds
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = InsureInsureds.class, reverseConvertGenerate = false)
+public class InsureInsuredsBo extends BaseEntity {
+
+    /**
+     * id
+     */
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    private String orderNum;
+
+    /**
+     * 保单号
+     */
+    private String policyNum;
+
+    /**
+     * 姓名
+     */
+    private String name;
+
+    /**
+     * 性别
+     */
+    private String gender;
+
+    /**
+     * 证件类型
+     */
+    private String idTp;
+
+    /**
+     * 证件代码
+     */
+    private String idNum;
+
+    /**
+     * 出生日期
+     */
+    private String birthday;
+
+    /**
+     * 手机号码
+     */
+    private String mobile;
+
+    /**
+     * 与投保人关系
+     */
+    private String relationTp;
+
+    /**
+     * 标准保费
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 标准退费
+     */
+    private BigDecimal stdRefund;
+
+    /**
+     * 实收退费
+     */
+    private BigDecimal actRefund;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/bo/InsurePolicyHolderBo.java

+package org.dromara.mall.controller.weishi.admin.bo;
+
+import org.dromara.mall.domain.weishi.InsurePolicyHolder;
+import org.dromara.common.mybatis.core.domain.BaseEntity;
+import org.dromara.common.core.validate.AddGroup;
+import org.dromara.common.core.validate.EditGroup;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import jakarta.validation.constraints.*;
+
+/**
+ * 保险订单-投保人业务对象 weishi_insure_policy_holder
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = InsurePolicyHolder.class, reverseConvertGenerate = false)
+public class InsurePolicyHolderBo extends BaseEntity {
+
+    /**
+     * id
+     */
+    @NotNull(message = "id不能为空", groups = { EditGroup.class })
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    @NotBlank(message = "订单编号不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String orderNum;
+
+    /**
+     * 保单号
+     */
+    @NotBlank(message = "保单号不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String policyNum;
+
+    /**
+     * 姓名
+     */
+    @NotBlank(message = "姓名不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String name;
+
+    /**
+     * 性别
+     */
+    @NotBlank(message = "性别不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String gender;
+
+    /**
+     * 证件类型
+     */
+    @NotBlank(message = "证件类型不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String idTp;
+
+    /**
+     * 证件代码
+     */
+    @NotBlank(message = "证件代码不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String idNum;
+
+    /**
+     * 出生日期
+     */
+    @NotBlank(message = "出生日期不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String birthday;
+
+    /**
+     * 手机号码
+     */
+    @NotBlank(message = "手机号码不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String mobile;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/bo/InsureTaxpayerBo.java

+package org.dromara.mall.controller.weishi.admin.bo;
+
+import org.dromara.mall.domain.weishi.InsureTaxpayer;
+import org.dromara.common.mybatis.core.domain.BaseEntity;
+import org.dromara.common.core.validate.AddGroup;
+import org.dromara.common.core.validate.EditGroup;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import jakarta.validation.constraints.*;
+
+/**
+ * 保险订单-发票信息业务对象 weishi_insure_taxpayer
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = InsureTaxpayer.class, reverseConvertGenerate = false)
+public class InsureTaxpayerBo extends BaseEntity {
+
+    /**
+     * id
+     */
+    @NotNull(message = "id不能为空", groups = { EditGroup.class })
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    @NotBlank(message = "订单编号不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String orderNum;
+
+    /**
+     * 企业名称
+     */
+    @NotBlank(message = "企业名称不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String taxpayerName;
+
+    /**
+     * 信用代码
+     */
+    @NotBlank(message = "信用代码不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String taxpayerNum;
+
+    /**
+     * 企业开户银行
+     */
+    @NotBlank(message = "企业开户银行不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String taxpayerBank;
+
+    /**
+     * 银行账户
+     */
+    @NotBlank(message = "银行账户不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String taxpayerAccount;
+
+    /**
+     * 税务登记电话
+     */
+    @NotBlank(message = "税务登记电话不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String taxpayerTelephone;
+
+    /**
+     * 税务登记地址
+     */
+    @NotBlank(message = "税务登记地址不能为空", groups = { AddGroup.class, EditGroup.class })
+    private String taxpayerAddr;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/bo/InsureUnitBo.java

+package org.dromara.mall.controller.weishi.admin.bo;
+
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.dromara.common.mybatis.core.domain.BaseEntity;
+import org.dromara.mall.domain.weishi.InsureUnit;
+
+import java.math.BigDecimal;
+
+/**
+ * 保险订单-投保单元业务对象 weishi_insure_unit
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@AutoMapper(target = InsureUnit.class, reverseConvertGenerate = false)
+public class InsureUnitBo extends BaseEntity {
+
+    /**
+     * id
+     */
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    private String orderNum;
+
+    /**
+     * 标准保费
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 标准退费
+     */
+    private BigDecimal stdRefund;
+
+    /**
+     * 实收退费
+     */
+    private BigDecimal actRefund;
+
+    /**
+     * 保单号
+     */
+    private String policyNum;
+
+    /**
+     * 保单url
+     */
+    private String policyUrl;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/vo/AccountVo.java

+package org.dromara.mall.controller.weishi.admin.vo;
+
+import org.dromara.mall.domain.weishi.Account;
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+
+/**
+ * 保险账号视图对象 weishi_account
+ *
+ * @author hzh
+ * @date 2025-05-15
+ */
+@Data
+@ExcelIgnoreUnannotated
+@AutoMapper(target = Account.class)
+public class AccountVo implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @ExcelProperty(value = "id")
+    private Long id;
+
+    /**
+     * 部门id
+     */
+    @ExcelProperty(value = "部门id")
+    private Long deptId;
+
+    /**
+     * 账号
+     */
+    @ExcelProperty(value = "账号")
+    private String username;
+
+    /**
+     * 密码
+     */
+    @ExcelProperty(value = "密码")
+    private String password;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/vo/InsureInsuredsVo.java

+package org.dromara.mall.controller.weishi.admin.vo;
+
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import org.dromara.mall.domain.weishi.InsureInsureds;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
+
+/**
+ * 保险订单-被保人视图对象 weishi_insure_insureds
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@ExcelIgnoreUnannotated
+@AutoMapper(target = InsureInsureds.class)
+public class InsureInsuredsVo implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    private String orderNum;
+
+    /**
+     * 保单号
+     */
+    private String policyNum;
+
+    /**
+     * 姓名
+     */
+    private String name;
+
+    /**
+     * 性别
+     */
+    private String gender;
+
+    /**
+     * 证件类型
+     */
+    private String idTp;
+
+    /**
+     * 证件代码
+     */
+    private String idNum;
+
+    /**
+     * 出生日期
+     */
+    private String birthday;
+
+    /**
+     * 手机号码
+     */
+    private String mobile;
+
+    /**
+     * 与投保人关系
+     */
+    private String relationTp;
+
+    /**
+     * 标准保费
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 标准退费
+     */
+    private BigDecimal stdRefund;
+
+    /**
+     * 实收退费
+     */
+    private BigDecimal actRefund;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/vo/InsurePolicyHolderVo.java

+package org.dromara.mall.controller.weishi.admin.vo;
+
+import org.dromara.mall.domain.weishi.InsurePolicyHolder;
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+
+/**
+ * 保险订单-投保人视图对象 weishi_insure_policy_holder
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@ExcelIgnoreUnannotated
+@AutoMapper(target = InsurePolicyHolder.class)
+public class InsurePolicyHolderVo implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @ExcelProperty(value = "id")
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    @ExcelProperty(value = "订单编号")
+    private String orderNum;
+
+    /**
+     * 保单号
+     */
+    @ExcelProperty(value = "保单号")
+    private String policyNum;
+
+    /**
+     * 姓名
+     */
+    @ExcelProperty(value = "姓名")
+    private String name;
+
+    /**
+     * 性别
+     */
+    @ExcelProperty(value = "性别")
+    private String gender;
+
+    /**
+     * 证件类型
+     */
+    @ExcelProperty(value = "证件类型")
+    private String idTp;
+
+    /**
+     * 证件代码
+     */
+    @ExcelProperty(value = "证件代码")
+    private String idNum;
+
+    /**
+     * 出生日期
+     */
+    @ExcelProperty(value = "出生日期")
+    private String birthday;
+
+    /**
+     * 手机号码
+     */
+    @ExcelProperty(value = "手机号码")
+    private String mobile;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/vo/InsureTaxpayerVo.java

+package org.dromara.mall.controller.weishi.admin.vo;
+
+import org.dromara.mall.domain.weishi.InsureTaxpayer;
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import com.alibaba.excel.annotation.ExcelProperty;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+
+/**
+ * 保险订单-发票信息视图对象 weishi_insure_taxpayer
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@ExcelIgnoreUnannotated
+@AutoMapper(target = InsureTaxpayer.class)
+public class InsureTaxpayerVo implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @ExcelProperty(value = "id")
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    @ExcelProperty(value = "订单编号")
+    private String orderNum;
+
+    /**
+     * 企业名称
+     */
+    @ExcelProperty(value = "企业名称")
+    private String taxpayerName;
+
+    /**
+     * 信用代码
+     */
+    @ExcelProperty(value = "信用代码")
+    private String taxpayerNum;
+
+    /**
+     * 企业开户银行
+     */
+    @ExcelProperty(value = "企业开户银行")
+    private String taxpayerBank;
+
+    /**
+     * 银行账户
+     */
+    @ExcelProperty(value = "银行账户")
+    private String taxpayerAccount;
+
+    /**
+     * 税务登记电话
+     */
+    @ExcelProperty(value = "税务登记电话")
+    private String taxpayerTelephone;
+
+    /**
+     * 税务登记地址
+     */
+    @ExcelProperty(value = "税务登记地址")
+    private String taxpayerAddr;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/vo/InsureUnitVo.java

+package org.dromara.mall.controller.weishi.admin.vo;
+
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import org.dromara.mall.domain.weishi.InsureUnit;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.List;
+
+
+/**
+ * 保险订单-投保单元视图对象 weishi_insure_unit
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@ExcelIgnoreUnannotated
+@AutoMapper(target = InsureUnit.class)
+public class InsureUnitVo implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    private String orderNum;
+
+    /**
+     * 标准保费
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 标准退费
+     */
+    private BigDecimal stdRefund;
+
+    /**
+     * 实收退费
+     */
+    private BigDecimal actRefund;
+
+    /**
+     * 保单号
+     */
+    private String policyNum;
+
+    /**
+     * 保单url
+     */
+    private String policyUrl;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 被保人列表
+     */
+    private List<InsureInsuredsVo> insuredsList;
+
+    /**
+     * 投保人信息
+     */
+    private InsurePolicyHolderVo policyHolder;
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/admin/vo/InsureVo.java

+package org.dromara.mall.controller.weishi.admin.vo;
+
+import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
+import io.github.linpeilie.annotations.AutoMapper;
+import lombok.Data;
+import org.dromara.common.translation.annotation.Translation;
+import org.dromara.common.translation.constant.TransConstant;
+import org.dromara.mall.domain.weishi.Insure;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+import java.util.List;
+
+
+/**
+ * 保险订单视图对象 weishi_insure
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+@Data
+@ExcelIgnoreUnannotated
+@AutoMapper(target = Insure.class)
+public class InsureVo implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    private Long id;
+
+    /**
+     * 用户id
+     */
+    private Long userId;
+
+    /**
+     * 会员id
+     */
+    private Long memberId;
+
+    /**
+     * 请求参数
+     */
+    private String reqJson;
+
+    /**
+     * 响应参数
+     */
+    private String resJson;
+
+    /**
+     * 产品信息
+     */
+    private String productJson;
+
+    /**
+     * 产品列表信息
+     */
+    private String productListJson;
+
+    /**
+     * 渠道类型
+     */
+    private String channelTp;
+
+    /**
+     * 流水号，幂等且唯一不能重复
+     */
+    private String batchNum;
+
+    /**
+     * 产品计划代码，需联系客户经理提供
+     */
+    private String productNum;
+
+    /**
+     * 保单生效时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date beginDate;
+
+    /**
+     * 保单终止时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date endDate;
+
+    /**
+     * 订单过期时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date overDate;
+
+    /**
+     * 旅行目的地
+     */
+    private String tourDest;
+
+    /**
+     * 旅行团编号/航班号
+     */
+    private String tourNum;
+
+    /**
+     * 标准保费合计，是Units中所有标准保费的总和
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费合计，是Units中所有实收保费的总和
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 付款链接
+     */
+    private String paymentUrl;
+
+    /**
+     * 付款单号
+     */
+    private String paymentNum;
+
+    /**
+     * 付款金额
+     */
+    private BigDecimal paymentAmt;
+
+    /**
+     * 投保数据格式(	P:图片, D - 数据)
+     */
+    private String dataTp;
+
+    /**
+     * 计划ID
+     */
+    private Integer planId;
+
+    /**
+     * 下单日期
+     */
+    private Date orderTime;
+
+    /**
+     * 订单id
+     */
+    private Integer orderId;
+
+    /**
+     * 订单编码
+     */
+    private String orderNum;
+
+    /**
+     * 订单url
+     */
+    private String orderUrl;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 被保人数
+     */
+    private Integer insuredCount;
+
+    /**
+     * 投保人
+     */
+    private String insuredName;
+
+    /**
+     * 保险公司
+     */
+    private String insuredAbbr;
+
+    /**
+     * 计划名称
+     */
+    private String planName;
+
+    /**
+     * 创建部门
+     */
+    @Translation(type = TransConstant.DEPT_ID_TO_NAME)
+    private Long createDept;
+
+    /**
+     * 投保单元集合
+     */
+    private List<InsureUnitVo> unitList;
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/controller/weishi/app/WeishiController.java

@@ -3,10 +3,17 @@ package org.dromara.mall.controller.weishi.app;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
 import org.dromara.common.core.domain.R;
+import org.dromara.common.mybatis.core.page.PageQuery;
+import org.dromara.common.mybatis.core.page.TableDataInfo;
+import org.dromara.common.satoken.utils.LoginHelper;
 import org.dromara.common.weishi.model.req.ApplyRequest;
 import org.dromara.common.weishi.model.req.ProposalRequest;
 import org.dromara.common.weishi.model.res.*;
 import org.dromara.common.weishi.service.WeishiService;
+import org.dromara.mall.controller.weishi.admin.bo.InsureBo;
+import org.dromara.mall.controller.weishi.admin.vo.InsureVo;
+import org.dromara.mall.service.weishi.IInsureService;
+import org.dromara.mall.service.weishi.IThirdWeishiService;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
@@ -24,6 +31,8 @@ import java.util.List;
 public class WeishiController {
 
     private final WeishiService weishiService;
+    private final IInsureService insureService;
+    private final IThirdWeishiService thirdWeishiService;
 
     /**
      * 产品列表
@@ -32,7 +41,7 @@ public class WeishiController {
      */
     @GetMapping("/productList")
     public R<List<ProductsResponse>> productList() {
-        return R.ok(weishiService.productList());
+        return R.ok(weishiService.productList(getToken()));
     }
 
     /**
@@ -43,7 +52,7 @@ public class WeishiController {
      */
     @GetMapping("/productDetail")
     public R<ProductResponse> productDetail(@RequestParam Integer productId) {
-        return R.ok(weishiService.productDetail(productId));
+        return R.ok(weishiService.productDetail(getToken(), productId));
     }
 
     /**
@@ -56,7 +65,7 @@ public class WeishiController {
     @GetMapping("/annex")
     public R<AnnexResponse> annex(@RequestParam(value = "productId") Integer productId,
                                   @RequestParam(value = "annexTp") String annexTp) {
-        return R.ok(weishiService.annex(productId, annexTp));
+        return R.ok(weishiService.annex(getToken(), productId, annexTp));
     }
 
     /**
@@ -67,7 +76,9 @@ public class WeishiController {
      */
     @PostMapping("/insureApply")
     public R<ApplyResponse> insureApply(@RequestBody ApplyRequest req) {
-        return R.ok(weishiService.insureApply(req));
+        ApplyResponse res = weishiService.insureApply(getToken(), req);
+        insureService.apply(req, res);
+        return R.ok(res);
     }
 
 
@@ -79,19 +90,43 @@ public class WeishiController {
      */
     @PostMapping("/insureProposal")
     public R<ProposalResponse> insureProposal(@RequestBody ProposalRequest req) {
-        return R.ok(weishiService.insureProposal(req));
+        return R.ok(weishiService.insureProposal(getToken(), req));
     }
 
 
     /**
-     * 保单详情
+     * 签单接口
      *
      * @param orderNum 订单号
-     * @return 保单详情
+     * @return 签单数据
      */
-    @GetMapping("/insureDetail")
-    public R<IssueResponse> insureDetail(@RequestParam String orderNum) {
-        return R.ok(weishiService.insureDetail(orderNum));
+    @PostMapping("/insureIssue/{orderNum}")
+    public R<IssueResponse> insureIssue(@PathVariable String orderNum) {
+        IssueResponse res = weishiService.insureIssue(getToken(orderNum), orderNum);
+        insureService.insureIssue(orderNum);
+        return R.ok(res);
+    }
+
+    /**
+     * 订单详情
+     *
+     * @param orderId orderId
+     * @return 订单详情
+     */
+    @PostMapping("/insureDetail/{orderId}")
+    public R<DetailResponse> insureDetail(@PathVariable Integer orderId) {
+        return R.ok(weishiService.insureDetail(getToken(orderId), orderId));
+    }
+
+    /**
+     * 保单下载
+     *
+     * @param orderNum orderNum
+     * @return 保单base64
+     */
+    @GetMapping("/insureDownload/{orderNum}")
+    public R<String> insureDownload(@PathVariable String orderNum) {
+        return R.ok("操作成功", weishiService.insureDownload(getToken(orderNum), orderNum));
     }
 
 
@@ -102,7 +137,20 @@ public class WeishiController {
      */
     @PostMapping("/insureCancel/{orderNum}")
     public R<Void> insureCancel(@PathVariable String orderNum) {
-        weishiService.insureCancel(orderNum);
+        weishiService.insureCancel(getToken(orderNum), orderNum);
+        insureService.insureCancel(orderNum);
+        return R.ok();
+    }
+
+    /**
+     * 作废接口
+     *
+     * @param orderId 订单id
+     */
+    @PostMapping("/insureAbandon/{orderId}")
+    public R<IssueResponse> insureAbandon(@PathVariable Integer orderId) {
+        weishiService.insureAbandon(getToken(orderId), orderId);
+        insureService.insureAbandon(orderId);
         return R.ok();
     }
 
@@ -113,8 +161,51 @@ public class WeishiController {
      */
     @PostMapping("/policyCancel/{policyNum}")
     public R<Void> policyCancel(@PathVariable String policyNum) {
-        weishiService.policyCancel(policyNum);
+        weishiService.policyCancel(getToken(), policyNum);
+        insureService.policyCancel(policyNum);
         return R.ok();
     }
 
+    /**
+     * 获取token
+     *
+     * @param orderId 订单id
+     * @return 数据
+     */
+    @GetMapping("/token")
+    public R<String> token(@RequestParam Integer orderId) {
+        return R.ok("操作成功", getToken(orderId));
+    }
+
+
+    /**
+     * 订单列表
+     */
+    @GetMapping("/insureList")
+    public TableDataInfo<InsureVo> list(PageQuery pageQuery) {
+        InsureBo bo = new InsureBo();
+        bo.setUserId(LoginHelper.getUserId());
+        return insureService.queryPageList(bo, pageQuery);
+    }
+
+    /**
+     * 获取token
+     *
+     * @return token
+     */
+    private String getToken() {
+        return thirdWeishiService.getToken(LoginHelper.getDeptId());
+    }
+
+
+    private String getToken(Integer orderId) {
+        InsureVo insure = insureService.getOne(new InsureBo().setOrderId(orderId));
+        return thirdWeishiService.getToken(insure.getCreateDept());
+    }
+
+    private String getToken(String orderNum) {
+        InsureVo insure = insureService.getOne(new InsureBo().setOrderNum(orderNum));
+        return thirdWeishiService.getToken(insure.getCreateDept());
+    }
+
 }

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/domain/weishi/Account.java

+package org.dromara.mall.domain.weishi;
+
+import lombok.experimental.Accessors;
+import org.dromara.common.tenant.core.TenantEntity;
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+
+/**
+ * 保险账号对象 weishi_account
+ *
+ * @author hzh
+ * @date 2025-05-15
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@TableName("weishi_account")
+public class Account extends TenantEntity {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id")
+    private Long id;
+
+    /**
+     * 部门id
+     */
+    private Long deptId;
+
+    /**
+     * 账号
+     */
+    private String username;
+
+    /**
+     * 密码
+     */
+    private String password;
+
+    /**
+     * 删除标志（0代表存在 2代表删除）
+     */
+    @TableLogic
+    private String delFlag;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/domain/weishi/Insure.java

+package org.dromara.mall.domain.weishi;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.dromara.common.tenant.core.TenantEntity;
+
+import java.io.Serial;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 保险订单对象 weishi_insure
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@TableName("weishi_insure")
+public class Insure extends TenantEntity {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id")
+    private Long id;
+
+    /**
+     * 用户id
+     */
+    private Long userId;
+
+    /**
+     * 会员id
+     */
+    private Long memberId;
+
+    /**
+     * 请求参数
+     */
+    private String reqJson;
+
+    /**
+     * 响应参数
+     */
+    private String resJson;
+
+    /**
+     * 产品信息
+     */
+    private String productJson;
+
+    /**
+     * 产品列表信息
+     */
+    private String productListJson;
+
+    /**
+     * 渠道类型
+     */
+    private String channelTp;
+
+    /**
+     * 流水号，幂等且唯一不能重复
+     */
+    private String batchNum;
+
+    /**
+     * 产品id
+     */
+    private Integer productId;
+
+    /**
+     * 产品计划代码，需联系客户经理提供
+     */
+    private String productNum;
+
+    /**
+     * 保单生效时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date beginDate;
+
+    /**
+     * 保单终止时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date endDate;
+
+    /**
+     * 订单过期时间，格式为YYYY-MM-DD HH:MM:SS
+     */
+    private Date overDate;
+
+    /**
+     * 旅行目的地
+     */
+    private String tourDest;
+
+    /**
+     * 旅行团编号/航班号
+     */
+    private String tourNum;
+
+    /**
+     * 标准保费合计，是Units中所有标准保费的总和
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费合计，是Units中所有实收保费的总和
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 付款链接
+     */
+    private String paymentUrl;
+
+    /**
+     * 付款单号
+     */
+    private String paymentNum;
+
+    /**
+     * 付款金额
+     */
+    private BigDecimal paymentAmt;
+
+    /**
+     * 投保数据格式(	P:图片, D - 数据)
+     */
+    private String dataTp;
+
+    /**
+     * 计划ID
+     */
+    private Integer planId;
+
+    /**
+     * 下单日期
+     */
+    private Date orderTime;
+
+    /**
+     * 订单id
+     */
+    private Integer orderId;
+
+    /**
+     * 订单编码
+     */
+    private String orderNum;
+
+    /**
+     * 订单url
+     */
+    private String orderUrl;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 被保人数
+     */
+    private Integer insuredCount;
+
+    /**
+     * 投保人
+     */
+    private String insuredName;
+
+    /**
+     * 保险公司
+     */
+    private String insuredAbbr;
+
+    /**
+     * 计划名称
+     */
+    private String planName;
+
+    /**
+     * 删除标志（0代表存在 2代表删除）
+     */
+    @TableLogic
+    private String delFlag;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/domain/weishi/InsureInsureds.java

+package org.dromara.mall.domain.weishi;
+
+import lombok.experimental.Accessors;
+import org.dromara.common.tenant.core.TenantEntity;
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import java.math.BigDecimal;
+
+import java.io.Serial;
+
+/**
+ * 保险订单-被保人对象 weishi_insure_insureds
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@TableName("weishi_insure_insureds")
+public class InsureInsureds extends TenantEntity {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id")
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    private String orderNum;
+
+    /**
+     * 保单号
+     */
+    private String policyNum;
+
+    /**
+     * 姓名
+     */
+    private String name;
+
+    /**
+     * 性别
+     */
+    private String gender;
+
+    /**
+     * 证件类型
+     */
+    private String idTp;
+
+    /**
+     * 证件代码
+     */
+    private String idNum;
+
+    /**
+     * 出生日期
+     */
+    private String birthday;
+
+    /**
+     * 手机号码
+     */
+    private String mobile;
+
+    /**
+     * 与投保人关系
+     */
+    private String relationTp;
+
+    /**
+     * 标准保费
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 标准退费
+     */
+    private BigDecimal stdRefund;
+
+    /**
+     * 实收退费
+     */
+    private BigDecimal actRefund;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 删除标志（0代表存在 2代表删除）
+     */
+    @TableLogic
+    private String delFlag;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/domain/weishi/InsurePolicyHolder.java

+package org.dromara.mall.domain.weishi;
+
+import lombok.experimental.Accessors;
+import org.dromara.common.tenant.core.TenantEntity;
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+
+/**
+ * 保险订单-投保人对象 weishi_insure_policy_holder
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@TableName("weishi_insure_policy_holder")
+public class InsurePolicyHolder extends TenantEntity {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id")
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    private String orderNum;
+
+    /**
+     * 保单号
+     */
+    private String policyNum;
+
+    /**
+     * 姓名
+     */
+    private String name;
+
+    /**
+     * 性别
+     */
+    private String gender;
+
+    /**
+     * 证件类型
+     */
+    private String idTp;
+
+    /**
+     * 证件代码
+     */
+    private String idNum;
+
+    /**
+     * 出生日期
+     */
+    private String birthday;
+
+    /**
+     * 手机号码
+     */
+    private String mobile;
+
+    /**
+     * 删除标志（0代表存在 2代表删除）
+     */
+    @TableLogic
+    private String delFlag;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/domain/weishi/InsureTaxpayer.java

+package org.dromara.mall.domain.weishi;
+
+import lombok.experimental.Accessors;
+import org.dromara.common.tenant.core.TenantEntity;
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serial;
+
+/**
+ * 保险订单-发票信息对象 weishi_insure_taxpayer
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@TableName("weishi_insure_taxpayer")
+public class InsureTaxpayer extends TenantEntity {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id")
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    private String orderNum;
+
+    /**
+     * 企业名称
+     */
+    private String taxpayerName;
+
+    /**
+     * 信用代码
+     */
+    private String taxpayerNum;
+
+    /**
+     * 企业开户银行
+     */
+    private String taxpayerBank;
+
+    /**
+     * 银行账户
+     */
+    private String taxpayerAccount;
+
+    /**
+     * 税务登记电话
+     */
+    private String taxpayerTelephone;
+
+    /**
+     * 税务登记地址
+     */
+    private String taxpayerAddr;
+
+    /**
+     * 删除标志（0代表存在 2代表删除）
+     */
+    @TableLogic
+    private String delFlag;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/domain/weishi/InsureUnit.java

+package org.dromara.mall.domain.weishi;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.dromara.common.tenant.core.TenantEntity;
+
+import java.io.Serial;
+import java.math.BigDecimal;
+
+/**
+ * 保险订单-投保单元对象 weishi_insure_unit
+ *
+ * @author hzh
+ * @date 2025-05-14
+ */
+@Data
+@Accessors(chain = true)
+@EqualsAndHashCode(callSuper = true)
+@TableName("weishi_insure_unit")
+public class InsureUnit extends TenantEntity {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    @TableId(value = "id")
+    private Long id;
+
+    /**
+     * 订单编号
+     */
+    private String orderNum;
+
+    /**
+     * 标准保费
+     */
+    private BigDecimal stdPremium;
+
+    /**
+     * 实收保费
+     */
+    private BigDecimal actPremium;
+
+    /**
+     * 标准退费
+     */
+    private BigDecimal stdRefund;
+
+    /**
+     * 实收退费
+     */
+    private BigDecimal actRefund;
+
+    /**
+     * 保单号
+     */
+    private String policyNum;
+
+    /**
+     * 保单url
+     */
+    private String policyUrl;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 删除标志（0代表存在 2代表删除）
+     */
+    @TableLogic
+    private String delFlag;
+
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/dubbo/weishi/RemoteWeishiServiceImpl.java

+package org.dromara.mall.dubbo.weishi;
+
+import lombok.RequiredArgsConstructor;
+import org.apache.dubbo.config.annotation.DubboService;
+import org.dromara.mall.api.weishi.RemoteWeishiService;
+import org.dromara.mall.service.weishi.IInsureService;
+import org.dromara.mall.service.weishi.IThirdWeishiService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author hzh
+ * @date 2025-05-13
+ **/
+@RequiredArgsConstructor
+@Service
+@DubboService
+public class RemoteWeishiServiceImpl implements RemoteWeishiService {
+
+    private final IThirdWeishiService thirdWeishiService;
+    private final IInsureService insureService;
+
+    @Override
+    public void getToken() {
+        thirdWeishiService.updateToken(null);
+    }
+
+    @Override
+    public void updateOrderStatus() {
+        insureService.updateOrderStatus(null);
+    }
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/mapper/weishi/AccountMapper.java

+package org.dromara.mall.mapper.weishi;
+
+import org.dromara.mall.domain.weishi.Account;
+import org.dromara.mall.controller.weishi.admin.vo.AccountVo;
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+
+/**
+ * 保险账号Mapper接口
+ *
+ * @author hzh
+ * @date 2025-05-15
+ */
+public interface AccountMapper extends BaseMapperPlus<Account, AccountVo> {
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/mapper/weishi/InsureInsuredsMapper.java

+package org.dromara.mall.mapper.weishi;
+
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+import org.dromara.mall.controller.weishi.admin.vo.InsureInsuredsVo;
+import org.dromara.mall.domain.weishi.InsureInsureds;
+
+/**
+ * 保险订单-被保人Mapper接口
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+public interface InsureInsuredsMapper extends BaseMapperPlus<InsureInsureds, InsureInsuredsVo> {
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/mapper/weishi/InsureMapper.java

+package org.dromara.mall.mapper.weishi;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import org.apache.commons.collections4.CollectionUtils;
+import org.dromara.common.core.utils.StreamUtils;
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+import org.dromara.common.mybatis.helper.CustomerDataPermissionHelper;
+import org.dromara.common.satoken.utils.LoginHelper;
+import org.dromara.mall.controller.weishi.admin.vo.InsureVo;
+import org.dromara.mall.domain.weishi.Insure;
+
+import java.util.List;
+
+/**
+ * 保险订单Mapper接口
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+public interface InsureMapper extends BaseMapperPlus<Insure, InsureVo> {
+
+    /**
+     * 获取有权限的spuId集合
+     *
+     * @return spuId集合
+     */
+    default List<Long> selectOrderIdsByDataPermission() {
+        // 设置权限
+        if (CustomerDataPermissionHelper.isNeedFilter()) {
+            LambdaQueryWrapper<Insure> lqw = new LambdaQueryWrapper<>();
+            lqw.select(Insure::getId);
+            if (CustomerDataPermissionHelper.isNeedFilterDeptId()) {
+                lqw.in(Insure::getCreateDept, CustomerDataPermissionHelper.getDeptIds());
+            } else {
+                lqw.eq(Insure::getCreateBy, LoginHelper.getUserId());
+            }
+            List<Insure> spuList = selectList(lqw);
+            return CollectionUtils.isEmpty(spuList) ? List.of(-1L) : StreamUtils.toList(spuList, Insure::getId);
+        } else {
+            return List.of();
+        }
+    }
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/mapper/weishi/InsurePolicyHolderMapper.java

+package org.dromara.mall.mapper.weishi;
+
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+import org.dromara.mall.controller.weishi.admin.vo.InsurePolicyHolderVo;
+import org.dromara.mall.domain.weishi.InsurePolicyHolder;
+
+/**
+ * 保险订单-投保人Mapper接口
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+public interface InsurePolicyHolderMapper extends BaseMapperPlus<InsurePolicyHolder, InsurePolicyHolderVo> {
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/mapper/weishi/InsureTaxpayerMapper.java

+package org.dromara.mall.mapper.weishi;
+
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+import org.dromara.mall.controller.weishi.admin.vo.InsureTaxpayerVo;
+import org.dromara.mall.domain.weishi.InsureTaxpayer;
+
+/**
+ * 保险订单-发票信息Mapper接口
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+public interface InsureTaxpayerMapper extends BaseMapperPlus<InsureTaxpayer, InsureTaxpayerVo> {
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/mapper/weishi/InsureUnitMapper.java

+package org.dromara.mall.mapper.weishi;
+
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+import org.dromara.mall.controller.weishi.admin.vo.InsureUnitVo;
+import org.dromara.mall.domain.weishi.InsureUnit;
+
+/**
+ * 保险订单-投保单元Mapper接口
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+public interface InsureUnitMapper extends BaseMapperPlus<InsureUnit, InsureUnitVo> {
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/service/product/impl/ProductCommentServiceImpl.java

@@ -3,21 +3,22 @@ package org.dromara.mall.service.product.impl;
 
 import cn.hutool.core.util.ObjectUtil;
 import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
 import org.dromara.common.mybatis.core.page.PageResult;
 import org.dromara.common.mybatis.core.query.LambdaQueryWrapperX;
+import org.dromara.mall.api.dto.member.MemberUserRespDTO;
+import org.dromara.mall.api.dto.product.ProductCommentCreateReqDTO;
+import org.dromara.mall.api.service.member.MemberUserApi;
 import org.dromara.mall.controller.product.admin.comment.vo.ProductCommentCreateReqVO;
 import org.dromara.mall.controller.product.admin.comment.vo.ProductCommentPageReqVO;
 import org.dromara.mall.controller.product.admin.comment.vo.ProductCommentReplyReqVO;
 import org.dromara.mall.controller.product.admin.comment.vo.ProductCommentUpdateVisibleReqVO;
 import org.dromara.mall.controller.product.app.comment.vo.AppCommentPageReqVO;
 import org.dromara.mall.convert.product.ProductCommentConvert;
-import org.dromara.mall.api.dto.member.MemberUserRespDTO;
-import org.dromara.mall.api.dto.product.ProductCommentCreateReqDTO;
 import org.dromara.mall.domain.product.ProductCommentDO;
 import org.dromara.mall.domain.product.ProductSkuDO;
 import org.dromara.mall.domain.product.ProductSpuDO;
 import org.dromara.mall.mapper.product.ProductCommentMapper;
-import org.dromara.mall.api.service.member.MemberUserApi;
 import org.dromara.mall.service.product.ProductCommentService;
 import org.dromara.mall.service.product.ProductSkuService;
 import org.dromara.mall.service.product.ProductSpuService;
@@ -38,6 +39,7 @@ import static org.dromara.mall.enums.product.ErrorCodeConstants.*;
  */
 @Service
 @Validated
+@Slf4j
 public class ProductCommentServiceImpl implements ProductCommentService {
 
     @Resource
@@ -100,6 +102,7 @@ public class ProductCommentServiceImpl implements ProductCommentService {
     private ProductSkuDO validateSku(Long skuId) {
         ProductSkuDO sku = productSkuService.getSku(skuId);
         if (sku == null) {
+            log.info("商品 SKU {} 不存在", skuId);
             throw exception(SKU_NOT_EXISTS);
         }
         return sku;

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/service/weishi/IAccountService.java

+package org.dromara.mall.service.weishi;
+
+import org.dromara.common.mybatis.service.IBaseService;
+import org.dromara.mall.domain.weishi.Account;
+import org.dromara.mall.controller.weishi.admin.bo.AccountBo;
+import org.dromara.mall.controller.weishi.admin.vo.AccountVo;
+
+/**
+ * 保险账号Service接口
+ *
+ * @author hzh
+ * @date 2025-05-15
+ */
+public interface IAccountService extends IBaseService<AccountVo, AccountBo, Account> {
+
+    /**
+     * 跟新
+     *
+     * @param bo bo
+     * @return 是否成功
+     */
+    int update(AccountBo bo);
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/service/weishi/IInsureService.java

+package org.dromara.mall.service.weishi;
+
+import org.dromara.common.mybatis.service.IBaseService;
+import org.dromara.common.weishi.model.req.ApplyRequest;
+import org.dromara.common.weishi.model.res.ApplyResponse;
+import org.dromara.mall.controller.weishi.admin.bo.InsureBo;
+import org.dromara.mall.controller.weishi.admin.vo.InsureVo;
+import org.dromara.mall.domain.weishi.Insure;
+
+/**
+ * 保险订单Service接口
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+public interface IInsureService extends IBaseService<InsureVo, InsureBo, Insure> {
+
+    /**
+     * 保存
+     *
+     * @param req 请求参数
+     * @param res 响应参数
+     */
+    void apply(ApplyRequest req, ApplyResponse res);
+
+    /**
+     * 订单取消
+     *
+     * @param orderNum 订单号
+     */
+    void insureCancel(String orderNum);
+
+    /**
+     * 签单
+     *
+     * @param orderNum 订单编码
+     */
+    void insureIssue(String orderNum);
+
+    /**
+     * 保单取消
+     *
+     * @param policyNum 保单号
+     */
+    void policyCancel(String policyNum);
+
+    /**
+     * 更新订单状态
+     */
+    void updateOrderStatus(Integer orderId);
+
+    /**
+     * 订单详情
+     *
+     * @param id id
+     * @return 数据
+     */
+    InsureVo getDetail(Long id);
+
+    /**
+     * 作废接口
+     *
+     * @param orderId 订单id
+     */
+    void insureAbandon(Integer orderId);
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/service/weishi/IThirdWeishiService.java

+package org.dromara.mall.service.weishi;
+
+import org.dromara.mall.domain.weishi.Account;
+
+/**
+ * @author wenhe
+ */
+public interface IThirdWeishiService {
+
+    /**
+     * 获取token
+     *
+     * @param deptId 部门id
+     * @return token
+     */
+    String getToken(Long deptId);
+
+    /**
+     * 更新部门token
+     *
+     * @param deptId 部门id
+     */
+    void updateToken(Long deptId);
+
+    /**
+     * 更新
+     * @param account 账号
+     */
+    void updateTokens(Account account);
+
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/service/weishi/impl/AccountServiceImpl.java

+package org.dromara.mall.service.weishi.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import lombok.RequiredArgsConstructor;
+import org.dromara.common.core.utils.StringUtils;
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+import org.dromara.common.mybatis.service.AbstractBaseService;
+import org.dromara.mall.controller.weishi.admin.bo.AccountBo;
+import org.dromara.mall.controller.weishi.admin.vo.AccountVo;
+import org.dromara.mall.domain.weishi.Account;
+import org.dromara.mall.mapper.weishi.AccountMapper;
+import org.dromara.mall.service.weishi.IAccountService;
+import org.dromara.mall.service.weishi.IThirdWeishiService;
+import org.springframework.stereotype.Service;
+
+import java.util.Objects;
+
+/**
+ * 保险账号Service业务层处理
+ *
+ * @author hzh
+ * @date 2025-05-15
+ */
+@RequiredArgsConstructor
+@Service
+public class AccountServiceImpl extends AbstractBaseService<AccountVo, AccountBo, Account> implements IAccountService {
+
+    private final AccountMapper baseMapper;
+    private final IThirdWeishiService thirdWeishiService;
+
+    @Override
+    public BaseMapperPlus<Account, AccountVo> mapper() {
+        return baseMapper;
+    }
+
+    @Override
+    public LambdaQueryWrapper<Account> buildQueryWrapper(AccountBo bo) {
+        LambdaQueryWrapper<Account> lqw = Wrappers.lambdaQuery();
+        lqw.eq(bo.getDeptId() != null, Account::getDeptId, bo.getDeptId());
+        lqw.eq(StringUtils.isNotBlank(bo.getUsername()), Account::getUsername, bo.getUsername());
+        lqw.eq(StringUtils.isNotBlank(bo.getPassword()), Account::getPassword, bo.getPassword());
+        return lqw;
+    }
+
+    @Override
+    public int update(AccountBo bo) {
+        Account account = baseMapper.selectOne(new LambdaQueryWrapper<Account>().eq(Account::getDeptId, bo.getDeptId()));
+        int rows;
+        if (Objects.isNull(account)) {
+            account = BeanUtil.copyProperties(bo, Account.class);
+            rows = baseMapper.insert(account);
+            thirdWeishiService.updateTokens(account);
+        } else {
+            account.setUsername(bo.getUsername())
+                .setPassword(bo.getPassword());
+            rows = baseMapper.updateById(account);
+            thirdWeishiService.updateTokens(account);
+        }
+        return rows;
+    }
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/service/weishi/impl/InsureServiceImpl.java

+package org.dromara.mall.service.weishi.impl;
+
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.dromara.common.core.exception.ServiceException;
+import org.dromara.common.core.utils.StreamUtils;
+import org.dromara.common.core.utils.StringUtils;
+import org.dromara.common.mybatis.core.mapper.BaseMapperPlus;
+import org.dromara.common.mybatis.core.page.PageQuery;
+import org.dromara.common.mybatis.core.page.TableDataInfo;
+import org.dromara.common.mybatis.service.AbstractBaseService;
+import org.dromara.common.satoken.utils.LoginHelper;
+import org.dromara.common.weishi.constant.OrderStatus;
+import org.dromara.common.weishi.model.req.ApplyRequest;
+import org.dromara.common.weishi.model.res.ApplyResponse;
+import org.dromara.common.weishi.model.res.DetailResponse;
+import org.dromara.common.weishi.model.res.ProductResponse;
+import org.dromara.common.weishi.model.res.ProductsResponse;
+import org.dromara.common.weishi.service.WeishiService;
+import org.dromara.mall.controller.weishi.admin.bo.InsureBo;
+import org.dromara.mall.controller.weishi.admin.vo.InsureInsuredsVo;
+import org.dromara.mall.controller.weishi.admin.vo.InsurePolicyHolderVo;
+import org.dromara.mall.controller.weishi.admin.vo.InsureUnitVo;
+import org.dromara.mall.controller.weishi.admin.vo.InsureVo;
+import org.dromara.mall.domain.weishi.*;
+import org.dromara.mall.mapper.weishi.*;
+import org.dromara.mall.service.weishi.IInsureService;
+import org.dromara.mall.service.weishi.IThirdWeishiService;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.*;
+
+import static cn.hutool.core.date.DatePattern.NORM_DATETIME_MINUTE_PATTERN;
+
+/**
+ * 保险订单Service业务层处理
+ *
+ * @author hzh
+ * @date 2025-05-13
+ */
+@RequiredArgsConstructor
+@Service
+@Slf4j
+public class InsureServiceImpl extends AbstractBaseService<InsureVo, InsureBo, Insure> implements IInsureService {
+
+    private final InsureMapper baseMapper;
+    private final InsureTaxpayerMapper taxpayerMapper;
+    private final InsureUnitMapper unitMapper;
+    private final InsurePolicyHolderMapper policyHolderMapper;
+    private final InsureInsuredsMapper insuredsMapper;
+    private final IThirdWeishiService thirdWeishiService;
+
+    @Override
+    public BaseMapperPlus<Insure, InsureVo> mapper() {
+        return baseMapper;
+    }
+
+    @Override
+    public LambdaQueryWrapper<Insure> buildQueryWrapper(InsureBo bo) {
+        Map<String, Object> params = bo.getParams();
+        LambdaQueryWrapper<Insure> lqw = Wrappers.lambdaQuery();
+        lqw.eq(bo.getUserId() != null, Insure::getUserId, bo.getUserId());
+        lqw.eq(bo.getMemberId() != null, Insure::getMemberId, bo.getMemberId());
+        lqw.eq(StringUtils.isNotBlank(bo.getReqJson()), Insure::getReqJson, bo.getReqJson());
+        lqw.eq(StringUtils.isNotBlank(bo.getResJson()), Insure::getResJson, bo.getResJson());
+        lqw.eq(StringUtils.isNotBlank(bo.getProductJson()), Insure::getProductJson, bo.getProductJson());
+        lqw.eq(StringUtils.isNotBlank(bo.getProductListJson()), Insure::getProductListJson, bo.getProductListJson());
+        lqw.eq(StringUtils.isNotBlank(bo.getChannelTp()), Insure::getChannelTp, bo.getChannelTp());
+        lqw.eq(StringUtils.isNotBlank(bo.getBatchNum()), Insure::getBatchNum, bo.getBatchNum());
+        lqw.eq(StringUtils.isNotBlank(bo.getProductNum()), Insure::getProductNum, bo.getProductNum());
+        lqw.eq(bo.getBeginDate() != null, Insure::getBeginDate, bo.getBeginDate());
+        lqw.eq(bo.getEndDate() != null, Insure::getEndDate, bo.getEndDate());
+        lqw.eq(StringUtils.isNotBlank(bo.getTourDest()), Insure::getTourDest, bo.getTourDest());
+        lqw.eq(StringUtils.isNotBlank(bo.getTourNum()), Insure::getTourNum, bo.getTourNum());
+        lqw.eq(bo.getStdPremium() != null, Insure::getStdPremium, bo.getStdPremium());
+        lqw.eq(bo.getActPremium() != null, Insure::getActPremium, bo.getActPremium());
+        lqw.eq(StringUtils.isNotBlank(bo.getPaymentUrl()), Insure::getPaymentUrl, bo.getPaymentUrl());
+        lqw.eq(StringUtils.isNotBlank(bo.getPaymentNum()), Insure::getPaymentNum, bo.getPaymentNum());
+        lqw.eq(bo.getPaymentAmt() != null, Insure::getPaymentAmt, bo.getPaymentAmt());
+        lqw.eq(StringUtils.isNotBlank(bo.getDataTp()), Insure::getDataTp, bo.getDataTp());
+        lqw.like(StringUtils.isNotBlank(bo.getInsuredAbbr()), Insure::getInsuredAbbr, bo.getInsuredAbbr());
+        lqw.eq(StringUtils.isNotBlank(bo.getStatus()), Insure::getStatus, bo.getStatus());
+        lqw.eq(bo.getCreateDept() != null, Insure::getCreateDept, bo.getCreateDept());
+        lqw.eq(bo.getOrderTime() != null, Insure::getOrderTime, bo.getOrderTime());
+        if (params != null) {
+            String startTime = params.getOrDefault("beginDate", StringUtils.EMPTY).toString();
+            if (StringUtils.isNotEmpty(startTime)) {
+                lqw.ge(Insure::getBeginDate, startTime);
+            }
+            String endTime = params.getOrDefault("endDate", StringUtils.EMPTY).toString();
+            if (StringUtils.isNotEmpty(endTime)) {
+                lqw.le(Insure::getEndDate, endTime);
+            }
+        }
+        return lqw;
+    }
+
+    private final WeishiService weishiService;
+
+
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void apply(ApplyRequest req, ApplyResponse res) {
+        String token = thirdWeishiService.getToken(LoginHelper.getDeptId());
+        //获取产品列表
+        List<ProductsResponse> productList = weishiService.productList(token);
+        //设置参数
+        Insure insure = new Insure();
+        BeanUtil.copyProperties(req, insure, true);
+        ProductResponse productRes = weishiService.productDetail(token, req.getProductId());
+        ProductsResponse productsRes = StreamUtils.findFirst(productList, p -> Objects.equals(p.getProductID(), req.getProductId()));
+        ProductResponse.Plan plan = StreamUtils.findFirst(productRes.getPlans(), p -> StringUtils.equals(req.getProductNum(), p.getPlanNum()));
+        DetailResponse dr = null;
+        try {
+            dr = weishiService.insureDetail(token, res.getOrderID());
+        } catch (Exception e) {
+            log.info("旅游卫士订单详情接口报错,订单ID：{}", res.getOrderID());
+        }
+        insure.setUserId(LoginHelper.getUserId())
+            .setMemberId(LoginHelper.getMemberId())
+            .setReqJson(JSONUtil.toJsonStr(req))
+            .setResJson(JSONUtil.toJsonStr(res))
+            .setProductJson(JSONUtil.toJsonStr(productRes))
+            .setProductListJson(JSONUtil.toJsonStr(productsRes))
+            .setOrderNum(res.getOrderNum())
+            .setOrderUrl(res.getOrderUrl())
+            .setOrderId(res.getOrderID())
+            .setStatus(OrderStatus.P.getKey())
+            .setProductId(req.getProductId())
+            .setPlanId(Optional.ofNullable(plan).map(ProductResponse.Plan::getPlanID).orElse(null))
+            .setInsuredCount(req.getUnits().get(0).getInsureds().size())
+            .setInsuredName(req.getUnits().get(0).getPolicyHolder().getName())
+            .setInsuredAbbr(productsRes.getInsurerAbbr())
+            .setPlanName(productsRes.getInsurerAbbr() + " - " + Optional.ofNullable(plan).map(ProductResponse.Plan::getPlanName).orElse(null))
+            .setOverDate(dr == null ? null : DateUtil.parse(dr.getOverDate(), NORM_DATETIME_MINUTE_PATTERN))
+            .setOrderTime(new Date());
+        insure.setCreateDept(LoginHelper.getDeptId());
+        baseMapper.insert(insure);
+        //保存发票信息
+        ApplyRequest.Taxpayer taxpayer = req.getTaxpayer();
+        if (taxpayer != null) {
+            InsureTaxpayer tax = new InsureTaxpayer();
+            BeanUtil.copyProperties(taxpayer, tax, true);
+            tax.setOrderNum(res.getOrderNum());
+            taxpayerMapper.insert(tax);
+        }
+        //保存投保单元
+        List<ApplyResponse.Unit> units = res.getUnits();
+        List<ApplyRequest.InsureUnit> reqUnits = req.getUnits();
+        for (int i = 0; i < units.size(); i++) {
+            ApplyResponse.Unit unit = units.get(i);
+            InsureUnit iu = new InsureUnit();
+            BeanUtil.copyProperties(unit, iu, true);
+            iu.setOrderNum(res.getOrderNum())
+                .setStatus(insure.getStatus());
+            unitMapper.insert(iu);
+            //保存投保人信息
+            ApplyRequest.PolicyHolder ph = reqUnits.get(i).getPolicyHolder();
+            InsurePolicyHolder iph = BeanUtil.copyProperties(ph, InsurePolicyHolder.class);
+            iph.setOrderNum(res.getOrderNum())
+                .setPolicyNum(unit.getPolicyNum());
+            policyHolderMapper.insert(iph);
+            //保存被保人信息
+            List<ApplyRequest.Insurant> insureds = reqUnits.get(i).getInsureds();
+            for (ApplyRequest.Insurant insured : insureds) {
+                InsureInsureds ins = new InsureInsureds();
+                BeanUtil.copyProperties(insured, ins, true);
+                ins.setOrderNum(res.getOrderNum())
+                    .setPolicyNum(unit.getPolicyNum())
+                    .setStatus(insure.getStatus());
+                insuredsMapper.insert(ins);
+            }
+        }
+    }
+
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void insureCancel(String orderNum) {
+        updateStatus(orderNum, OrderStatus.W.getKey());
+    }
+
+    @Override
+    public void insureIssue(String orderNum) {
+        updateStatus(orderNum, OrderStatus.E.getKey());
+    }
+
+    @Override
+    public void insureAbandon(Integer orderId) {
+        Insure insure = baseMapper.selectOne(Insure::getOrderId, orderId);
+        updateStatus(insure.getOrderNum(), OrderStatus.A.getKey());
+    }
+
+    private void updateStatus(String orderNum, String orderStatus) {
+        Insure insure = baseMapper.selectOne(Insure::getOrderNum, orderNum);
+        insure.setStatus(orderStatus);
+        baseMapper.updateById(insure);
+
+        //获取投保单位
+        List<InsureUnit> unitList = unitMapper.selectList(InsureUnit::getOrderNum, orderNum);
+        //获取被保人信息
+        List<InsureInsureds> insuredList = insuredsMapper.selectList(InsureInsureds::getOrderNum, orderNum);
+        //跟新投保单位
+        unitList.forEach(unit -> {
+            unit.setStatus(orderStatus);
+            unitMapper.updateById(unit);
+        });
+        //跟新被保人信息
+        insuredList.forEach(i -> {
+            i.setStatus(orderStatus);
+            insuredsMapper.updateById(i);
+        });
+    }
+
+    @Override
+    public void policyCancel(String policyNum) {
+
+    }
+
+    @Override
+    public void updateOrderStatus(Integer orderId) {
+        //获取订单列表
+        List<Insure> insureList = orderId != null ?
+            baseMapper.selectList(Insure::getOrderId, orderId) :
+            baseMapper.selectList(new LambdaQueryWrapper<Insure>()
+                .notIn(Insure::getStatus, List.of(OrderStatus.D.getKey(), OrderStatus.A.getKey())));
+        if (CollectionUtils.isNotEmpty(insureList)) {
+            List<String> orderNumList = StreamUtils.toList(insureList, Insure::getOrderNum);
+            //获取投保单位集合
+            List<InsureUnit> unitList = unitMapper.selectList(new LambdaQueryWrapper<InsureUnit>().in(InsureUnit::getOrderNum, orderNumList));
+            //获取被保人集合
+            List<InsureInsureds> insuredsList = insuredsMapper.selectList(new LambdaQueryWrapper<InsureInsureds>().in(InsureInsureds::getOrderNum, orderNumList));
+            insureList.forEach(i -> {
+                try {
+                    DetailResponse dr = weishiService.insureDetail(thirdWeishiService.getToken(i.getCreateDept()), i.getOrderId());
+                    if (!StringUtils.equals(i.getStatus(), dr.getStatus())) {
+                        i.setStatus(dr.getStatus());
+                        baseMapper.updateById(i);
+                        //跟新投保单位
+                        List<InsureUnit> iuList = StreamUtils.filter(unitList, u -> StringUtils.equals(u.getOrderNum(), i.getOrderNum()));
+                        iuList.forEach(iu -> iu.setStatus(dr.getStatus()));
+                        unitMapper.updateBatch(iuList);
+                        //跟新被保人信息
+                        List<InsureInsureds> iiList = StreamUtils.filter(insuredsList, insureds -> StringUtils.equals(insureds.getOrderNum(), i.getOrderNum()));
+                        iiList.forEach(ii -> ii.setStatus(dr.getStatus()));
+                        insuredsMapper.updateBatch(iiList);
+                    }
+                } catch (Exception e) {
+                    log.info("旅游卫士订单{}更新失败", i.getOrderNum());
+                }
+            });
+        }
+    }
+
+    @Override
+    public InsureVo getDetail(Long id) {
+        InsureVo insure = baseMapper.selectVoById(id);
+        if (Objects.isNull(insure)) {
+            throw new ServiceException("保单不存在");
+        }
+        List<InsureUnitVo> unitList = unitMapper.selectVoList(new LambdaQueryWrapper<InsureUnit>().eq(InsureUnit::getOrderNum, insure.getOrderNum()));
+        List<InsurePolicyHolderVo> phList = policyHolderMapper.selectVoList(new LambdaQueryWrapper<InsurePolicyHolder>().eq(InsurePolicyHolder::getOrderNum, insure.getOrderNum()));
+        List<InsureInsuredsVo> iiList = insuredsMapper.selectVoList(new LambdaQueryWrapper<InsureInsureds>().eq(InsureInsureds::getOrderNum, insure.getOrderNum()));
+        //设置数据
+        unitList.forEach(unit -> {
+            unit.setPolicyHolder(StreamUtils.findFirst(phList, ph -> StringUtils.equals(ph.getPolicyNum(), unit.getPolicyNum())));
+            unit.setInsuredsList(StreamUtils.filter(iiList, ii -> StringUtils.equals(ii.getPolicyNum(), unit.getPolicyNum())));
+        });
+        insure.setUnitList(unitList);
+        return insure;
+    }
+
+    @Override
+    public TableDataInfo<InsureVo> queryPageList(InsureBo bo, PageQuery pageQuery) {
+        LambdaQueryWrapper<Insure> lqw = buildQueryWrapper(bo);
+        List<Long> permissionOrderIds = baseMapper.selectOrderIdsByDataPermission();
+        lqw.in(CollectionUtils.isNotEmpty(permissionOrderIds), Insure::getId, permissionOrderIds);
+        Page<InsureVo> result = mapper().selectVoPage(pageQuery.build(), lqw);
+        return TableDataInfo.build(result);
+    }
+}

ruoyi-modules/ruoyi-mall/src/main/java/org/dromara/mall/service/weishi/impl/ThirdWeishiServiceImpl.java

+package org.dromara.mall.service.weishi.impl;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.dromara.common.core.utils.StringUtils;
+import org.dromara.common.redis.utils.RedisUtils;
+import org.dromara.common.weishi.exception.WeishiException;
+import org.dromara.common.weishi.model.req.AuthRequest;
+import org.dromara.common.weishi.model.res.AuthResponse;
+import org.dromara.common.weishi.service.WeishiService;
+import org.dromara.mall.domain.weishi.Account;
+import org.dromara.mall.mapper.weishi.AccountMapper;
+import org.dromara.mall.service.weishi.IThirdWeishiService;
+import org.springframework.stereotype.Service;
+
+import java.time.Duration;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * @author hzh
+ * @date 2025-05-15
+ **/
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class ThirdWeishiServiceImpl implements IThirdWeishiService {
+
+    private final WeishiService weishiService;
+    private final AccountMapper accountMapper;
+    String WEISHI_TOKEN = "mall:third:weishi:token:{}:{}";
+
+    @Override
+    public String getToken(Long deptId) {
+        if (Objects.isNull(deptId)) {
+            throw new WeishiException("该账号无部门，请先配置部门在使用旅游产品接口");
+        }
+        Account account = accountMapper.selectOne(Account::getDeptId, deptId);
+        if (Objects.isNull(account)) {
+            throw new WeishiException("当前部门没有配置旅游产品账号密码，请先配置再使用");
+        }
+        return updateToken(account);
+    }
+
+    private String updateToken(Account account) {
+        String key = StringUtils.format(WEISHI_TOKEN, account.getTenantId(), account.getDeptId());
+        String token = RedisUtils.getCacheObject(key);
+        if (StringUtils.isEmpty(token)) {
+            AuthResponse res = weishiService.authorize(new AuthRequest(account.getUsername(), account.getPassword()));
+            RedisUtils.setCacheObject(key, res.getAccess_token(), Duration.ofSeconds(res.getExpires_in().longValue()));
+            token = res.getAccess_token();
+        }
+        return token;
+    }
+
+    @Override
+    public void updateTokens(Account account) {
+        String key = StringUtils.format(WEISHI_TOKEN, account.getTenantId(), account.getDeptId());
+        AuthResponse res = weishiService.authorize(new AuthRequest(account.getUsername(), account.getPassword()));
+        RedisUtils.setCacheObject(key, res.getAccess_token(), Duration.ofSeconds(res.getExpires_in().longValue()));
+    }
+
+    @Override
+    public void updateToken(Long deptId) {
+        List<Account> accountList;
+        if (Objects.nonNull(deptId)) {
+            accountList = accountMapper.selectList(Account::getDeptId, deptId);
+        } else {
+            accountList = accountMapper.selectList();
+        }
+        accountList.forEach(account -> {
+            try {
+                updateToken(account);
+            } catch (Exception e) {
+                log.info("旅游卫士token更新失败，部门id:{},账号:{},密码:{}", account.getDeptId(), account.getUsername(), account.getPassword());
+            }
+        });
+    }
+}

ruoyi-modules/ruoyi-mall/src/main/resources/mapper/weishi/AccountMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.dromara.mall.mapper.weishi.AccountMapper">
+
+</mapper>

ruoyi-modules/ruoyi-mall/src/main/resources/mapper/weishi/InsureInsuredsMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.dromara.mall.mapper.weishi.InsureInsuredsMapper">
+
+</mapper>

ruoyi-modules/ruoyi-mall/src/main/resources/mapper/weishi/InsureMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.dromara.mall.mapper.weishi.InsureMapper">
+
+</mapper>

ruoyi-modules/ruoyi-mall/src/main/resources/mapper/weishi/InsurePolicyHolderMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.dromara.mall.mapper.weishi.InsurePolicyHolderMapper">
+
+</mapper>

ruoyi-modules/ruoyi-mall/src/main/resources/mapper/weishi/InsureTaxpayerMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.dromara.mall.mapper.weishi.InsureTaxpayerMapper">
+
+</mapper>

ruoyi-modules/ruoyi-mall/src/main/resources/mapper/weishi/InsureUnitMapper.xml

+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="org.dromara.mall.mapper.weishi.InsureUnitMapper">
+
+</mapper>

ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/domain/bo/SysDeptTravelLineBo.java

@@ -42,19 +42,16 @@ public class SysDeptTravelLineBo extends BaseEntity {
     /**
      * 部门简介
      */
-    @NotBlank(message = "部门简介不能为空", groups = { AddGroup.class, EditGroup.class })
     private String desc;
 
     /**
      * 二维码
      */
-    @NotBlank(message = "二维码不能为空", groups = { AddGroup.class, EditGroup.class })
     private String qrCode;
 
     /**
      * 服务商
      */
-//    @NotBlank(message = "服务商不能为空", groups = { AddGroup.class, EditGroup.class })
     private String service;
 
 

ruoyi-modules/ruoyi-system/src/main/java/org/dromara/system/dubbo/RemoteDeptServiceImpl.java

 package org.dromara.system.dubbo;
 
-import org.dromara.system.api.RemoteDeptService;
-import org.dromara.system.service.ISysDeptService;
 import lombok.RequiredArgsConstructor;
 import org.apache.dubbo.config.annotation.DubboService;
+import org.dromara.system.api.RemoteDeptService;
+import org.dromara.system.domain.vo.SysDeptVo;
+import org.dromara.system.domain.vo.SysUserVo;
+import org.dromara.system.service.ISysDeptService;
+import org.dromara.system.service.ISysUserService;
 import org.springframework.stereotype.Service;
 
 /**
@@ -17,6 +20,7 @@ import org.springframework.stereotype.Service;
 public class RemoteDeptServiceImpl implements RemoteDeptService {
 
     private final ISysDeptService sysDeptService;
+    private final ISysUserService userService;
 
     /**
      * 通过部门ID查询部门名称
@@ -28,4 +32,21 @@ public class RemoteDeptServiceImpl implements RemoteDeptService {
     public String selectDeptNameByIds(String deptIds) {
         return sysDeptService.selectDeptNameByIds(deptIds);
     }
+
+    /**
+     * 获取部门负责人id
+     *
+     * @param userId 用户id
+     * @return 负责人id
+     */
+    @Override
+    public Long selectLeaderIdByUserId(Long userId) {
+        SysUserVo user = userService.selectUserById(userId);
+        if (user.getDeptId() == null) {
+            return null;
+        }
+        //获取部门
+        SysDeptVo dept = sysDeptService.selectDeptById(user.getDeptId());
+        return dept.getLeader();
+    }
 }

ruoyi-modules/ruoyi-workflow/pom.xml

@@ -22,6 +22,11 @@
             <artifactId>ruoyi-common-nacos</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.dromara</groupId>
+            <artifactId>ruoyi-common-sentinel</artifactId>
+        </dependency>
+
         <!--引入flowable依赖-->
         <dependency>
             <groupId>org.flowable</groupId>
@@ -113,6 +118,10 @@
             <groupId>org.dromara</groupId>
             <artifactId>ruoyi-common-tenant</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.dromara</groupId>
+            <artifactId>ruoyi-api-system</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.dromara</groupId>
@@ -134,6 +143,11 @@
             <artifactId>ruoyi-api-workflow</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.dromara</groupId>
+            <artifactId>ruoyi-common-core</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>commons-io</groupId>
             <artifactId>commons-io</artifactId>

ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/config/FlowableConfig.java

@@ -2,11 +2,14 @@ package org.dromara.workflow.flowable.config;
 
 import com.baomidou.mybatisplus.core.incrementer.IdentifierGenerator;
 import org.dromara.workflow.flowable.handler.TaskTimeoutJobHandler;
+import org.flowable.common.engine.impl.cfg.SpringBeanFactoryProxyMap;
 import org.flowable.spring.SpringProcessEngineConfiguration;
 import org.flowable.spring.boot.EngineConfigurationConfigurer;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
 import org.springframework.context.annotation.Configuration;
 
+import javax.annotation.Resource;
 import java.util.Collections;
 
 
@@ -22,11 +25,14 @@ public class FlowableConfig implements EngineConfigurationConfigurer<SpringProce
     private GlobalFlowableListener globalFlowableListener;
     @Autowired
     private IdentifierGenerator identifierGenerator;
+    @Resource
+    private ApplicationContext applicationContext;
 
     @Override
     public void configure(SpringProcessEngineConfiguration processEngineConfiguration) {
         processEngineConfiguration.setIdGenerator(() -> identifierGenerator.nextId(null).toString());
         processEngineConfiguration.setEventListeners(Collections.singletonList(globalFlowableListener));
         processEngineConfiguration.addCustomJobHandler(new TaskTimeoutJobHandler());
+        processEngineConfiguration.setBeans(new SpringBeanFactoryProxyMap(applicationContext));
     }
 }

ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/flowable/listener/DynamicAssigneeListener.java

+package org.dromara.workflow.flowable.listener;
+
+
+import org.dromara.common.core.utils.SpringUtils;
+import org.dromara.workflow.common.constant.FlowConstant;
+import org.dromara.workflow.service.IDeptService;
+import org.flowable.task.service.delegate.DelegateTask;
+import org.flowable.task.service.delegate.TaskListener;
+import org.springframework.stereotype.Component;
+
+import java.util.Objects;
+
+@Component
+public class DynamicAssigneeListener implements TaskListener {
+
+    @Override
+    public void notify(DelegateTask delegateTask) {
+        // 获取申请人ID（从流程变量中获取）
+        Long applicantId = Long.parseLong(delegateTask.getVariable(FlowConstant.INITIATOR).toString());
+
+        IDeptService deptService = SpringUtils.getBean(IDeptService.class);
+
+        // 调用服务获取审批人列表
+        Long approveId = deptService.selectLeaderIdByUserId(applicantId);
+
+        // 设置候选用户
+        delegateTask.setAssignee(Objects.isNull(approveId) ? null : approveId.toString());
+    }
+}

ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/runner/WorkflowApplicationRunner.java

@@ -4,6 +4,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.dromara.resource.api.RemoteFileService;
+import org.dromara.system.api.RemoteDeptService;
 import org.dromara.system.api.RemoteUserService;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
@@ -23,6 +24,8 @@ public class WorkflowApplicationRunner implements ApplicationRunner {
     private RemoteUserService remoteUserService;
     @DubboReference
     private RemoteFileService remoteFileService;
+    @DubboReference
+    private RemoteDeptService remoteDeptService;
 
     @Override
     public void run(ApplicationArguments args) throws Exception {

ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/service/IDeptService.java

+package org.dromara.workflow.service;
+
+public interface IDeptService {
+
+    /**
+     * 获取部门负责人id
+     *
+     * @param userId 用户id
+     * @return 负责人id
+     */
+    Long selectLeaderIdByUserId(Long userId);
+
+}

ruoyi-modules/ruoyi-workflow/src/main/java/org/dromara/workflow/service/impl/DeptServiceImpl.java

+package org.dromara.workflow.service.impl;
+
+import lombok.RequiredArgsConstructor;
+import org.apache.dubbo.config.annotation.DubboReference;
+import org.dromara.system.api.RemoteDeptService;
+import org.dromara.workflow.service.IDeptService;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author hzh
+ * @date 2025-05-20
+ * @desc TODO
+ **/
+@Service
+@RequiredArgsConstructor
+public class DeptServiceImpl implements IDeptService {
+
+    @DubboReference
+    private RemoteDeptService remoteDeptService;
+
+    @Override
+    public Long selectLeaderIdByUserId(Long userId) {
+        return remoteDeptService.selectLeaderIdByUserId(userId);
+    }
+}