diff --git a/doc/万车充小程序-未分账明细.xlsx b/doc/万车充小程序-未分账明细.xlsx
new file mode 100644
index 000000000..fd6c198fc
Binary files /dev/null and b/doc/万车充小程序-未分账明细.xlsx differ
diff --git a/doc/万车充小程序未分账补分账SOP.md b/doc/万车充小程序未分账补分账SOP.md
new file mode 100644
index 000000000..035053143
--- /dev/null
+++ b/doc/万车充小程序未分账补分账SOP.md
@@ -0,0 +1,305 @@
+# 万车充小程序未分账补分账 SOP（adapayMemberId=0）
+
+## 1. 目标与背景
+
+- 目标：将未分账订单批量向汇付发起 `PaymentConfirm` 请求，分账对象固定为 `adapayMemberId=0`（平台默认账户）。
+- 数据来源：`doc/万车充小程序-未分账明细.xlsx`。
+- 编写日期：2026-03-11（Asia/Shanghai）。
+
+说明：本 SOP 面向“拿到一份未分账明细文件后，批量补分账”的场景。文档中的流程可复用于后续同类任务。
+
+## 2. 本次文件分析结论
+
+对 `doc/万车充小程序-未分账明细.xlsx` 的 `Sheet1` 统计结果如下：
+
+- 总记录数：`42,225`
+- `paymentId` 去重后重复数：`0`
+- `app_id`：全部为 `app_d0c80cb1-ffc8-48cb-a030-fe9bec823aaa`
+- 支付时间范围：`2024-09-07 19:29:00` ~ `2026-03-06 00:11:20`
+- 未分账金额（列“剩余未分账金额”）
+  - 合计：`171,710.73`
+  - 最小：`0.01`
+  - 中位数：`0.50`
+  - P90：`8.45`
+  - 最大：`268.39`
+- 金额分布：
+  - `0.01~1`: `34,367`
+  - `1~10`: `4,018`
+  - `10~50`: `3,061`
+  - `50~100`: `507`
+  - `>=100`: `272`
+- 交易订单号格式：`42,223/42,225` 包含下划线（通常为 `orderCode_时间戳`）
+
+关键结论：
+
+1. 量大（4.2 万+），必须批处理+可重试+可追踪。
+2. 文件最晚数据到 `2026-03-06`，执行时必须先查汇付最新状态，不能盲目按文件金额直发。
+3. 小额单非常多（0.01~1 占比高），要考虑接口速率与批次执行时长。
+
+## 3. 现有代码落点（可复用）
+
+- 发起汇付分账请求：
+  - `jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayService.java`
+  - 方法：`createPaymentConfirmRequest(PaymentConfirmParam param)`
+- 查询支付确认列表：
+  - 同上 `queryPaymentConfirmList(QueryPaymentConfirmDTO dto)`
+- 分账对象模型：
+  - `DivMember.memberId` 设为 `0`，`feeFlag` 设为 `Y`
+- 已有“未分账处理”参考（测试代码）：
+  - `jsowell-admin/src/test/java/PaymentTestController.java`
+  - 方法：`processUnSettledOrder()`
+
+注意：
+
+- `jsowell-quartz` 里的 `processUnSettledOrder()` 当前版本（V2）主要是“查汇付确认信息”，不是生产可直接执行的补分账任务。
+
+## 4. 推荐执行方案（生产可落地）
+
+## 4.1 方案总览
+
+分三阶段执行：
+
+1. 任务清单准备
+2. 批量补分账执行
+3. 结果复核与失败重试
+
+建议新增一个“一次性批处理工具（仅本次任务分支）”，不要直接依赖手工接口逐条处理。
+
+## 4.2 任务清单准备
+
+从 Excel 抽取以下字段形成任务清单（CSV/临时表均可）：
+
+- `payment_id` ← 交易流水号
+- `source_order_no` ← 交易订单号
+- `order_code` ← `source_order_no` 按 `_` 分割取前半段；若无 `_` 则回退原值
+- `pay_amt` ← 交易订单金额
+- `file_confirmed_amt` ← 已确认分账金额
+- `file_reserved_amt` ← 支付确认撤销金额
+- `file_remaining_amt` ← 剩余未分账金额
+- `pay_time` ← 支付时间
+
+过滤条件：
+
+- `file_remaining_amt > 0`
+- `payment_id` 非空
+
+## 4.3 批量补分账执行（核心）
+
+单条任务处理逻辑（必须幂等）：
+
+1. 用 `payment_id` 调 `queryPaymentConfirmList` 查询汇付最新确认信息。
+2. 计算“执行时最新可分账金额” `latest_remaining_amt`：
+   - 基线金额使用文件中的 `file_remaining_amt`。
+   - 若汇付返回了确认信息，使用 `pay_amt - confirmed_amt - reserved_amt` 再算一遍，取两者较小值（且不小于 0）。
+3. 若 `latest_remaining_amt <= 0`：跳过（记为 `SKIPPED_NO_REMAINING`）。
+4. 构造分账请求：
+   - `paymentId = payment_id`
+   - `confirmAmt = latest_remaining_amt`
+   - `divMemberList = [{ memberId: "0", amount: latest_remaining_amt, feeFlag: "Y" }]`
+   - `orderCode = order_code`
+   - `wechatAppId = 对应 appId`
+5. 调用 `createPaymentConfirmRequest(param)`。
+6. 按响应记录结果：
+   - 成功：记录 `payment_confirm_id`、`confirm_amt`、`fee_amt`
+   - 失败：记录 `error_code`、`error_msg`
+
+建议执行参数：
+
+- 批次：每批 `500`（或 `200` 起步）
+- QPS：`3~5`（每笔 sleep `200~300ms`）
+- 失败重试：对可重试错误最多 `2` 次
+
+建议错误处理：
+
+- `confirm_amt_over_limit`：立即重查汇付最新金额，按新金额重试一次。
+- `payment_over_time_doing` / `refund_repeate_request`：放入重试队列，延迟重跑。
+- 其他错误：记录失败，人工复核。
+
+## 4.4 结果复核与验收
+
+必须输出三类结果文件（CSV）：
+
+- `success.csv`：成功明细（含 paymentConfirmId）
+- `skipped.csv`：跳过明细（无剩余可分账）
+- `failed.csv`：失败明细（含错误码）
+
+验收标准：
+
+1. `success + skipped + failed = 总任务数`
+2. 对 `success` 样本抽查 `queryPaymentConfirmList`，确认 `div_members` 包含 `memberId=0`
+3. `failed` 有明确可重试策略或人工处理结论
+
+## 4.5 回滚预案（必要时）
+
+如果误分账到错误对象或金额错误：
+
+1. 从 `success.csv` 取 `payment_confirm_id`
+2. 调用 `createConfirmReverse(paymentConfirmId, wechatAppId)` 撤销支付确认
+3. 撤销后重新按正确参数执行补分账
+
+代码参考：
+
+- `AdapayService.createConfirmReverse(...)`
+
+## 5. 下次同类任务复用清单
+
+执行前 Checklist：
+
+1. 明细文件是否包含 `payment_id`、`remaining_amt`、`pay_amt`
+2. 是否确认目标账户（本 SOP 为 `memberId=0`）
+3. 是否先做 100 条小批次试跑
+4. 是否有完整执行日志与 `success/skipped/failed` 三份结果
+5. 是否准备了 `payment_confirm_id` 级别回滚能力
+
+执行后 Checklist：
+
+1. 失败项是否重试完毕
+2. 关键样本是否验证到汇付侧最新状态
+3. 本次任务结果文件是否归档到 `doc/` 或运维归档目录
+
+## 6. 当前已落地入口
+
+已新增任务方法（`JsowellTask`）：
+
+- `importAdapayUnsplitRecordAndCompleteFields()`
+- `importAdapayUnsplitRecordAndCompleteFields(String filePath)`
+
+实现位置：
+
+- `jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java`
+
+方法职责：
+
+1. 从 Excel 导入 `adapay_unsplit_record`（按 `insertOrUpdateSelective`，支持重复执行）
+2. 自动补齐 `order_code / due_refund_amount / settle_amount / pile_type` 等缺失字段
+3. 输出导入与补齐统计日志
+
+执行示例：
+
+- 使用默认路径：`jsowellTask.importAdapayUnsplitRecordAndCompleteFields()`
+- 指定路径：`jsowellTask.importAdapayUnsplitRecordAndCompleteFields('doc/万车充小程序-未分账明细.xlsx')`
+
+## 7. 完整执行流程（落地版）
+
+以下流程是当前代码已支持、可直接按顺序执行的标准操作。
+
+### 7.1 执行前检查
+
+1. 使用 JDK8。
+2. 编译通过：
+
+```bash
+mvn -pl jsowell-quartz -am -DskipTests compile
+```
+
+3. 确认 Excel 文件就绪：
+
+- 默认路径：`doc/万车充小程序-未分账明细.xlsx`
+- 或你自己的绝对路径/相对路径
+
+### 7.2 第一步：导入并补齐缺失字段
+
+执行任务方法（任选其一）：
+
+1. 默认路径：
+
+```text
+jsowellTask.importAdapayUnsplitRecordAndCompleteFields()
+```
+
+2. 指定路径：
+
+```text
+jsowellTask.importAdapayUnsplitRecordAndCompleteFields('doc/万车充小程序-未分账明细.xlsx')
+```
+
+本步骤会自动完成：
+
+1. Excel -> `adapay_unsplit_record` 导入（`insertOrUpdateSelective`，可重复执行）
+2. 自动补齐 `order_code / due_refund_amount / settle_amount / pile_type`
+3. 输出导入统计与补齐统计日志
+
+### 7.3 第二步：导入后校验
+
+建议执行以下 SQL：
+
+```sql
+-- 总量
+SELECT COUNT(*) AS total_cnt
+FROM adapay_unsplit_record;
+
+-- 核心补齐字段缺失情况
+SELECT COUNT(*) AS missing_cnt
+FROM adapay_unsplit_record
+WHERE order_code IS NULL
+   OR settle_amount IS NULL
+   OR due_refund_amount IS NULL
+   OR pile_type IS NULL;
+```
+
+`missing_cnt` 理想结果应接近 `0`（少量异常数据可人工排查）。
+
+### 7.4 第三步：执行未分账处理（分账到 memberId=0）
+
+执行任务方法（任选其一）：
+
+1. 使用默认 appId（`Constants.DEFAULT_APP_ID`）+ pageSize=500：
+
+```text
+jsowellTask.processUnsplitRecordToDefaultMember()
+```
+
+2. 指定 appId 和分页大小：
+
+```text
+jsowellTask.processUnsplitRecordToDefaultMember('你的wechatAppId', 200)
+```
+
+建议先用 `200` 小批量试跑，再提升到 `500`。
+
+本步骤会自动完成：
+
+1. 分页读取 `queryList()` 的待分账记录
+2. 先查汇付最新确认信息，计算实时剩余可分账金额
+3. 取 `min(数据库待分账金额, 汇付实时剩余金额)` 作为本次 `confirmAmt`
+4. 调 `PaymentConfirm` 分账，分账对象固定 `memberId=0`
+5. 回写结果：
+   - 成功：更新 `confirmed_split_amount`，`split_flag=SUCCESS`
+   - 失败：`split_flag=FAILED`
+
+### 7.5 第四步：循环执行直到待分账清零
+
+每轮执行后，建议跑以下 SQL：
+
+```sql
+-- 按当前业务口径，仍待处理数量
+SELECT COUNT(*) AS remain_cnt
+FROM adapay_unsplit_record
+WHERE (settle_amount > confirmed_split_amount - payment_revoke_amount)
+   OR (due_refund_amount > refund_amount);
+
+-- 分账结果分布
+SELECT split_flag, COUNT(*) AS cnt
+FROM adapay_unsplit_record
+GROUP BY split_flag;
+```
+
+当 `remain_cnt = 0` 可视为本次补分账完成。
+
+### 7.6 失败重试与回滚
+
+1. 失败重试：重新执行 `processUnsplitRecordToDefaultMember(...)` 即可。
+2. 回滚（如金额或目标账户异常）：
+   - 按 `paymentId` 查询对应 `payment_confirm_id`
+   - 调 `createConfirmReverse(paymentConfirmId, wechatAppId)` 撤销
+   - 重新执行正确参数的分账流程
+
+## 8. 一键操作建议（便于下次复用）
+
+按下面顺序执行，基本可覆盖同类任务：
+
+1. `jsowellTask.importAdapayUnsplitRecordAndCompleteFields('文件路径')`
+2. 校验 `missing_cnt`
+3. `jsowellTask.processUnsplitRecordToDefaultMember('appId', 200)`
+4. 查看 `remain_cnt`
+5. 若 `remain_cnt > 0`，重复第 3-4 步，最后切 `pageSize=500` 提速
diff --git a/jsowell-admin/src/main/java/com/jsowell/api/thirdparty/ChargeAlgorithmController.java b/jsowell-admin/src/main/java/com/jsowell/api/thirdparty/ChargeAlgorithmController.java
index 632b79522..87928fff5 100644
--- a/jsowell-admin/src/main/java/com/jsowell/api/thirdparty/ChargeAlgorithmController.java
+++ b/jsowell-admin/src/main/java/com/jsowell/api/thirdparty/ChargeAlgorithmController.java
@@ -5,8 +5,7 @@ import com.jsowell.common.core.controller.BaseController;
 import com.jsowell.common.response.RestApiResponse;
 import com.jsowell.common.util.StringUtils;
 import com.jsowell.pile.dto.BatteryChargeReportDTO;
-import com.jsowell.thirdparty.platform.service.impl.BatteryChargeReportService;
-import com.jsowell.thirdparty.platform.service.impl.ChargeAlgorithmService;
+import com.jsowell.pile.service.batteryreport.BatteryChargeReportService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -21,9 +20,6 @@ import org.springframework.web.bind.annotation.*;
 @RequestMapping("/chargealgorithm")
 public class ChargeAlgorithmController extends BaseController {
 
-    @Autowired
-    private ChargeAlgorithmService chargeAlgorithmService;
-
     @Autowired
     private BatteryChargeReportService batteryChargeReportService;
 
@@ -44,4 +40,18 @@ public class ChargeAlgorithmController extends BaseController {
         }
         return response;
     }
+
+    @PostMapping("/getUrlByTaskId")
+    public RestApiResponse<?> getUrlByTaskId(@RequestBody BatteryChargeReportDTO dto) {
+        RestApiResponse<?> response = null;
+        try {
+            String url = batteryChargeReportService.getUrlByTaskId(dto.getTaskId(), dto.getReportType());
+            response = new RestApiResponse<>(url);
+        }catch (Exception e) {
+            logger.error("算法应用推送订单信息 error, ", e);
+            response = new RestApiResponse<>(e);
+        }
+        return response;
+    }
+
 }
diff --git a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/OrderController.java b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/OrderController.java
index a511a9066..1975ebb97 100644
--- a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/OrderController.java
+++ b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/customer/OrderController.java
@@ -22,7 +22,7 @@ import com.jsowell.pile.vo.uniapp.customer.ParkingOrderVO;
 import com.jsowell.pile.vo.uniapp.customer.UniAppOrderVO;
 import com.jsowell.service.OrderService;
 import com.jsowell.pile.dto.BatteryChargeReportDTO;
-import com.jsowell.thirdparty.platform.service.impl.BatteryChargeReportService;
+import com.jsowell.pile.service.batteryreport.BatteryChargeReportService;
 import com.jsowell.wxpay.dto.WechatSendMsgDTO;
 import com.jsowell.wxpay.service.WxAppletRemoteService;
 import org.springframework.beans.factory.annotation.Autowired;
diff --git a/jsowell-admin/src/main/java/com/jsowell/web/controller/pile/PileSimInfoController.java b/jsowell-admin/src/main/java/com/jsowell/web/controller/pile/PileSimInfoController.java
index 0c0eaa02b..5852d03bf 100644
--- a/jsowell-admin/src/main/java/com/jsowell/web/controller/pile/PileSimInfoController.java
+++ b/jsowell-admin/src/main/java/com/jsowell/web/controller/pile/PileSimInfoController.java
@@ -150,4 +150,9 @@ public class PileSimInfoController extends BaseController {
         // return result;
     }
 
+    @PostMapping("/batchRechargeSimCard")
+    public AjaxResult batchRechargeSimCard(@RequestBody SimRenewDTO dto) {
+        return null;
+    }
+
 }
diff --git a/jsowell-admin/src/main/resources/application-dev.yml b/jsowell-admin/src/main/resources/application-dev.yml
index e5ecb7476..5de23e895 100644
--- a/jsowell-admin/src/main/resources/application-dev.yml
+++ b/jsowell-admin/src/main/resources/application-dev.yml
@@ -36,11 +36,11 @@ spring:
     druid:
       # 主库数据源
       master:
-        url: jdbc:mysql://106.14.94.149:3306/jsowell_pre?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
-        username: jsowell_pre
-#        url: jdbc:mysql://192.168.2.46:3306/jsowell_prd_copy?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
-#        username: jsowell_prd_copy
-        password: Js@160829
+#        url: jdbc:mysql://106.14.94.149:3306/jsowell_pre?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+#        username: jsowell_pre
+        url: jdbc:mysql://192.168.0.32:3306/jsowell_dev?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
+        username: jsowell_dev
+        password: 123456
       # 从库数据源
       slave:
         # 从数据源开关/默认关闭
@@ -262,7 +262,7 @@ batteryChargeReport:
   webDomainPrefix: https://wx.btiger.net/jeecg-boot
   getTaskIdApi: /api/docking/api/evaluate
   apiPrefix: /api/docking/report/
-  token: MTc0NzcyMjgwMzg0NC1xNmFucG96cHR4aQ==
+  token: MTc3MzAzODY1ODYwNy1sbjdiM3h3dHJi
   mfrID: mfr8944567890598756
 
 # dubbo配置
diff --git a/jsowell-admin/src/main/resources/application-prd.yml b/jsowell-admin/src/main/resources/application-prd.yml
index 669e2e1b4..304beec3b 100644
--- a/jsowell-admin/src/main/resources/application-prd.yml
+++ b/jsowell-admin/src/main/resources/application-prd.yml
@@ -257,7 +257,7 @@ batteryChargeReport:
   webDomainPrefix: https://wx.btiger.net/jeecg-boot
   getTaskIdApi: /api/docking/api/evaluate
   apiPrefix: /api/docking/report/
-  token: MTc0NzcyMjgwMzg0NC1xNmFucG96cHR4aQ==
+  token: MTc3MzAzODY1ODYwNy1sbjdiM3h3dHJi
   mfrID: mfr8944567890598756
 
 # dubbo配置
diff --git a/jsowell-admin/src/main/resources/application-pre.yml b/jsowell-admin/src/main/resources/application-pre.yml
index 53d67a247..eecf00098 100644
--- a/jsowell-admin/src/main/resources/application-pre.yml
+++ b/jsowell-admin/src/main/resources/application-pre.yml
@@ -280,7 +280,7 @@ batteryChargeReport:
   webDomainPrefix: https://wx.btiger.net/jeecg-boot
   getTaskIdApi: /api/docking/api/evaluate
   apiPrefix: /api/docking/report/
-  token: MTc0NzcyMjgwMzg0NC1xNmFucG96cHR4aQ==
+  token: MTc3MzAzODY1ODYwNy1sbjdiM3h3dHJi
   mfrID: mfr8944567890598756
 
 # dubbo配置
diff --git a/jsowell-admin/src/main/resources/application-sit.yml b/jsowell-admin/src/main/resources/application-sit.yml
index fc31b5fd2..d1889bc1a 100644
--- a/jsowell-admin/src/main/resources/application-sit.yml
+++ b/jsowell-admin/src/main/resources/application-sit.yml
@@ -289,7 +289,7 @@ batteryChargeReport:
   webDomainPrefix: https://wx.btiger.net/jeecg-boot
   getTaskIdApi: /api/docking/api/evaluate
   apiPrefix: /api/docking/report/
-  token: MTc0NzcyMjgwMzg0NC1xNmFucG96cHR4aQ==
+  token: MTc3MzAzODY1ODYwNy1sbjdiM3h3dHJi
   mfrID: mfr8944567890598756
 
 # dubbo配置
diff --git a/jsowell-admin/src/main/resources/application.yml b/jsowell-admin/src/main/resources/application.yml
index 7f073a6e6..b158f0628 100644
--- a/jsowell-admin/src/main/resources/application.yml
+++ b/jsowell-admin/src/main/resources/application.yml
@@ -156,7 +156,7 @@ batteryChargeReport:
   webDomainPrefix: https://wx.btiger.net/jeecg-boot
   getTaskIdApi: /api/docking/api/evaluate
   apiPrefix: /api/docking/report/
-  token: MTc0NzcyMjgwMzg0NC1xNmFucG96cHR4aQ==
+  token: MTc3MzAzODY1ODYwNy1sbjdiM3h3dHJi
   mfrID: mfr8944567890598756
 
 # sms4j
diff --git a/jsowell-admin/src/test/java/PaymentTestController.java b/jsowell-admin/src/test/java/PaymentTestController.java
index b39220367..1ab1b3fa1 100644
--- a/jsowell-admin/src/test/java/PaymentTestController.java
+++ b/jsowell-admin/src/test/java/PaymentTestController.java
@@ -851,6 +851,9 @@ public class PaymentTestController {
 
     }
 
+    /**
+     * 处理临时过度账户订单
+     */
     @Test
     public void queryAdapayData() {
         String startTime = "2025-01-01 00:00:00";
diff --git a/jsowell-admin/src/test/java/SpringBootTestController.java b/jsowell-admin/src/test/java/SpringBootTestController.java
index 85ddd5491..a5a4e655f 100644
--- a/jsowell-admin/src/test/java/SpringBootTestController.java
+++ b/jsowell-admin/src/test/java/SpringBootTestController.java
@@ -64,6 +64,7 @@ import com.jsowell.pile.dto.lutongyunting.BindCouponDTO;
 import com.jsowell.pile.mapper.MemberBasicInfoMapper;
 import com.jsowell.pile.mapper.PileBillingTemplateMapper;
 import com.jsowell.pile.service.*;
+import com.jsowell.pile.service.batteryreport.BatteryChargeReportService;
 import com.jsowell.pile.service.programlogic.AbstractProgramLogic;
 import com.jsowell.pile.service.programlogic.ProgramLogicFactory;
 import com.jsowell.pile.thirdparty.CommonParamsDTO;
@@ -87,7 +88,6 @@ import com.jsowell.thirdparty.parking.common.bean.QcyunParkCouponDTO;
 import com.jsowell.thirdparty.parking.service.LTYTService;
 import com.jsowell.thirdparty.parking.service.QcyunsService;
 import com.jsowell.thirdparty.platform.service.ThirdPartyPlatformService;
-import com.jsowell.thirdparty.platform.service.impl.BatteryChargeReportService;
 import com.jsowell.thirdparty.platform.util.Cryptos;
 import com.jsowell.thirdparty.platform.util.Encodes;
 import com.jsowell.thirdparty.platform.util.GBSignUtils;
diff --git a/jsowell-charge-ui b/jsowell-charge-ui
index 7881ac11f..a9714216b 160000
--- a/jsowell-charge-ui
+++ b/jsowell-charge-ui
@@ -1 +1 @@
-Subproject commit 7881ac11ff7c4b2842b866641aa62be64bf7a945
+Subproject commit a9714216b15b42c54b9967f8d6698ae0d73414aa
diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/TransactionRecordsRequestHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/TransactionRecordsRequestHandler.java
index 9754e52ef..0a87a1276 100644
--- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/TransactionRecordsRequestHandler.java
+++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/yunkuaichong/TransactionRecordsRequestHandler.java
@@ -27,7 +27,7 @@ import com.jsowell.pile.service.*;
 import com.jsowell.pile.service.programlogic.AbstractProgramLogic;
 import com.jsowell.pile.service.programlogic.ProgramLogicFactory;
 import com.jsowell.thirdparty.common.CommonService;
-import com.jsowell.thirdparty.platform.service.impl.BatteryChargeReportService;
+import com.jsowell.pile.service.batteryreport.BatteryChargeReportService;
 import io.netty.channel.ChannelHandlerContext;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
@@ -768,12 +768,13 @@ public class TransactionRecordsRequestHandler extends AbstractYkcHandler {
             }
         }
         if (StringUtils.isBlank(taskId)) {
-            log.info("推送充电订单算法平台 taskId 为空");
+            taskId = batteryChargeReportService.getTaskIdByOrderCode(orderCode);
+            // log.info("推送充电订单算法平台 taskId 为空");
         }
-        log.info("推送充电订单算法平台 taskId:{}", taskId);
+        log.info("推送充电订单算法平台 orderCode:{}, taskId:{}", orderCode, taskId);
         // 再根据 tasKId 获取链接
         String url = batteryChargeReportService.getUrlByTaskId(taskId, reportType);
-        log.info("推送充电订单算法平台 result:{}", url);
+        log.info("推送充电订单算法平台 orderCode:{}, result:{}", orderCode, url);
 
         return url;
     }
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/domain/SimRechargeRecord.java b/jsowell-pile/src/main/java/com/jsowell/pile/domain/SimRechargeRecord.java
new file mode 100644
index 000000000..ca6f16340
--- /dev/null
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/domain/SimRechargeRecord.java
@@ -0,0 +1,64 @@
+package com.jsowell.pile.domain;
+
+import java.math.BigDecimal;
+
+import com.jsowell.common.annotation.Excel;
+import com.jsowell.common.core.domain.BaseEntity;
+import lombok.*;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+/**
+ * sim卡续费记录表对象 sim_recharge_record
+ *
+ * @author jsowell
+ * @date 2026-03-06
+ */
+@EqualsAndHashCode(callSuper = true)
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class SimRechargeRecord extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * $column.columnComment
+     */
+    private Long id;
+
+    /**
+     * 充值订单号
+     */
+    @Excel(name = "充值订单号")
+    private String rechargeOrderCode;
+
+    /**
+     * iccid
+     */
+    @Excel(name = "iccId")
+    private String iccId;
+
+    /**
+     * 支付金额
+     */
+    @Excel(name = "支付金额")
+    private BigDecimal payAmount;
+
+    /**
+     * 状态（0-成功；1-失败）
+     */
+    @Excel(name = "状态", readConverterExp = "0=-成功；1-失败")
+    private String status;
+
+    /**
+     * 订单金额
+     */
+    @Excel(name = "订单金额")
+    private BigDecimal orderAmount;
+
+    /**
+     * 删除标识
+     */
+    private String delFlag;
+}
diff --git a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/domain/BatteryChargeReportData.java b/jsowell-pile/src/main/java/com/jsowell/pile/domain/batteryreport/BatteryChargeReportData.java
similarity index 98%
rename from jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/domain/BatteryChargeReportData.java
rename to jsowell-pile/src/main/java/com/jsowell/pile/domain/batteryreport/BatteryChargeReportData.java
index dcf26c673..fea9e9793 100644
--- a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/domain/BatteryChargeReportData.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/domain/batteryreport/BatteryChargeReportData.java
@@ -1,4 +1,4 @@
-package com.jsowell.thirdparty.platform.domain;
+package com.jsowell.pile.domain.batteryreport;
 
 import com.alibaba.fastjson2.annotation.JSONField;
 import lombok.AllArgsConstructor;
diff --git a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/domain/BatteryReportResult.java b/jsowell-pile/src/main/java/com/jsowell/pile/domain/batteryreport/BatteryReportResult.java
similarity index 92%
rename from jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/domain/BatteryReportResult.java
rename to jsowell-pile/src/main/java/com/jsowell/pile/domain/batteryreport/BatteryReportResult.java
index 3692a9bea..00e6c2644 100644
--- a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/domain/BatteryReportResult.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/domain/batteryreport/BatteryReportResult.java
@@ -1,4 +1,4 @@
-package com.jsowell.thirdparty.platform.domain;
+package com.jsowell.pile.domain.batteryreport;
 
 import lombok.AllArgsConstructor;
 import lombok.Builder;
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/dto/BatteryChargeReportDTO.java b/jsowell-pile/src/main/java/com/jsowell/pile/dto/BatteryChargeReportDTO.java
index 71cf5676a..fac3351bb 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/dto/BatteryChargeReportDTO.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/dto/BatteryChargeReportDTO.java
@@ -23,4 +23,6 @@ public class BatteryChargeReportDTO {
      * 1-web; 2-pdf
      */
     private String reportType;
+
+    private String taskId;
 }
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/AdapayUnsplitRecordMapper.java b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/AdapayUnsplitRecordMapper.java
index 60e7f9218..b4df2b4ce 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/AdapayUnsplitRecordMapper.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/AdapayUnsplitRecordMapper.java
@@ -31,6 +31,8 @@ public interface AdapayUnsplitRecordMapper {
 
     int batchInsert(@Param("list") List<AdapayUnsplitRecord> list);
 
+    int batchInsertOrUpdateSelective(@Param("list") List<AdapayUnsplitRecord> list);
+
     List<AdapayUnsplitRecord> queryUnsplitOrders(@Param("startTime") String startTime, @Param("endTime") String endTime);
 
     List<AdapayUnsplitRecordVO> queryList();
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/SimRechargeRecordMapper.java b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/SimRechargeRecordMapper.java
new file mode 100644
index 000000000..d113c5f83
--- /dev/null
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/SimRechargeRecordMapper.java
@@ -0,0 +1,63 @@
+package com.jsowell.pile.mapper;
+
+import java.util.List;
+
+import com.jsowell.pile.domain.SimRechargeRecord;
+import org.springframework.stereotype.Repository;
+
+/**
+ * sim卡续费记录表Mapper接口
+ *
+ * @author jsowell
+ * @date 2026-03-06
+ */
+@Repository
+public interface SimRechargeRecordMapper {
+    /**
+     * 查询sim卡续费记录表
+     *
+     * @param id sim卡续费记录表主键
+     * @return sim卡续费记录表
+     */
+    public SimRechargeRecord selectSimRechargeRecordById(Long id);
+
+    /**
+     * 查询sim卡续费记录表列表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return sim卡续费记录表集合
+     */
+    public List<SimRechargeRecord> selectSimRechargeRecordList(SimRechargeRecord simRechargeRecord);
+
+    /**
+     * 新增sim卡续费记录表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return 结果
+     */
+    public int insertSimRechargeRecord(SimRechargeRecord simRechargeRecord);
+
+    /**
+     * 修改sim卡续费记录表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return 结果
+     */
+    public int updateSimRechargeRecord(SimRechargeRecord simRechargeRecord);
+
+    /**
+     * 删除sim卡续费记录表
+     *
+     * @param id sim卡续费记录表主键
+     * @return 结果
+     */
+    public int deleteSimRechargeRecordById(Long id);
+
+    /**
+     * 批量删除sim卡续费记录表
+     *
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteSimRechargeRecordByIds(Long[] ids);
+}
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/AdapayUnsplitRecordService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/AdapayUnsplitRecordService.java
index ba7d84052..39483bbbc 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/AdapayUnsplitRecordService.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/AdapayUnsplitRecordService.java
@@ -28,6 +28,8 @@ public interface AdapayUnsplitRecordService{
 
     int batchInsert(List<AdapayUnsplitRecord> list);
 
+    int batchInsertOrUpdateSelective(List<AdapayUnsplitRecord> list);
+
     List<AdapayUnsplitRecord> queryUnsplitOrders(String startTime, String endTime);
 
     List<AdapayUnsplitRecordVO> queryList();
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/OrderBasicInfoService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/OrderBasicInfoService.java
index b9789c4d8..496903511 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/OrderBasicInfoService.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/OrderBasicInfoService.java
@@ -77,6 +77,8 @@ public interface OrderBasicInfoService{
      */
     List<OrderListVO> selectOrderBasicInfoList(QueryOrderDTO dto);
 
+    boolean checkRefundInsuranceAmount(OrderBasicInfo orderBasicInfo);
+
     void refundInsurance(OrderBasicInfo orderBasicInfo);
 
     /**
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/SimCardService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/SimCardService.java
index 896f48af6..5e50bcfbb 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/SimCardService.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/SimCardService.java
@@ -4,6 +4,7 @@ import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 import com.jsowell.common.enums.sim.SimCardStatusCorrespondEnum;
 import com.jsowell.common.enums.sim.SimSupplierEnum;
 import com.jsowell.common.enums.ykc.ReturnCodeEnum;
@@ -15,6 +16,8 @@ import com.jsowell.common.util.id.IdUtils;
 import com.jsowell.common.util.sim.SimCardUtils;
 import com.jsowell.common.util.sim.XunZhongSimUtils;
 import com.jsowell.pile.domain.PileSimInfo;
+import com.jsowell.pile.domain.SimRechargeRecord;
+import com.jsowell.pile.dto.SimRenewDTO;
 import com.jsowell.pile.vo.web.*;
 import org.apache.commons.collections4.CollectionUtils;
 import org.slf4j.Logger;
@@ -27,6 +30,7 @@ import java.math.BigDecimal;
 import java.util.ArrayList;
 import java.util.Hashtable;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 
@@ -42,6 +46,9 @@ public class SimCardService {
     @Autowired
     private PileSimInfoService pileSimInfoService;
 
+    @Autowired
+    private SimRechargeRecordService simRechargeRecordService;
+
     protected final Logger logger = LoggerFactory.getLogger(SimCardService.class);
 
     @Value("${xunzhong.apiId}")
@@ -193,6 +200,69 @@ public class SimCardService {
         return list;
     }
 
+    /**
+     * 批量续费Sim卡（26年新版）
+     *
+     * @param dto
+     */
+    public void batchRenewSimCard(SimRenewDTO dto) {
+        List<String> iccIds = dto.getIccIds();
+        // 先分组 key: 卡商名    value:流量卡卡号
+        Map<String, List<String>> map = goupingBySimSupplier(iccIds);
+        // 讯众 Sim 卡卡号
+        List<String> xunZhongCards = map.get("xunzhong");
+        // 智宇物联平台 Sim卡卡号
+        List<String> wuLianCards = map.get("wulian");
+        // 异步批量执行续费方法
+        XunZhongSimRenewal(xunZhongCards, dto.getCycleNumber());
+
+        WuLianSimRenew(wuLianCards, dto.getCycleNumber());
+
+        // 将续费完成后的数据插入数据库
+        // SimRechargeRecord record = SimRechargeRecord.builder()
+        //         .iccId(iccId)
+        //         .status("1")
+        //         .build();
+        // simRechargeRecordService.insertSimRechargeRecord()
+    }
+
+    /**
+     * 将iccid按照卡商分组
+     * @param iccIds
+     * @return
+     */
+    public Map<String, List<String>> goupingBySimSupplier(List<String> iccIds) {
+        Map<String, List<String>> map = Maps.newHashMap();
+
+        if (CollectionUtils.isEmpty(iccIds)) {
+            return Maps.newHashMap();
+        }
+        // 将集合中为空和0的过滤
+        iccIds = iccIds.stream()
+                .filter(StringUtils::isNotEmpty)
+                .filter(x -> !StringUtils.equals(x, "0"))
+                .collect(Collectors.toList());
+
+        List<String> xunzhongList = new ArrayList<>();
+        List<String> wulianList = new ArrayList<>();
+        for (String iccId : iccIds) {
+            // 查出此卡属于哪家公司(拿到code)
+            SimCardVO simCardVO = searchByLoop(Lists.newArrayList(iccId)).get(0);
+            String simSupplierCode = simCardVO.getSimCardFactory();
+
+            // 根据 code 分组
+            if (StringUtils.equals(simSupplierCode, SimSupplierEnum.XUN_ZHONG.getCode())) {
+                xunzhongList.add(iccId);
+            }
+            if (StringUtils.equals(simSupplierCode, SimSupplierEnum.WU_LIAN_INTERNET.getCode())) {
+                wulianList.add(iccId);
+            }
+        }
+        map.put("xunzhong", xunzhongList);
+        map.put("wulian", wulianList);
+        return map;
+    }
+
 
     /**
      * 根据不同的公司执行不同的续费方法
@@ -396,6 +466,10 @@ public class SimCardService {
             String message = jsonResult.getString("message");
             throw new BusinessException(code, message);
         }
+        // 续费成功， 将信息存库
+        SimRechargeRecord record = SimRechargeRecord.builder()
+                .iccId()
+                .build();
     }
 
 
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/SimRechargeRecordService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/SimRechargeRecordService.java
new file mode 100644
index 000000000..84d4e5d9c
--- /dev/null
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/SimRechargeRecordService.java
@@ -0,0 +1,61 @@
+package com.jsowell.pile.service;
+
+import java.util.List;
+
+import com.jsowell.pile.domain.SimRechargeRecord;
+
+/**
+ * sim卡续费记录表Service接口
+ *
+ * @author jsowell
+ * @date 2026-03-06
+ */
+public interface SimRechargeRecordService {
+    /**
+     * 查询sim卡续费记录表
+     *
+     * @param id sim卡续费记录表主键
+     * @return sim卡续费记录表
+     */
+    public SimRechargeRecord selectSimRechargeRecordById(Long id);
+
+    /**
+     * 查询sim卡续费记录表列表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return sim卡续费记录表集合
+     */
+    public List<SimRechargeRecord> selectSimRechargeRecordList(SimRechargeRecord simRechargeRecord);
+
+    /**
+     * 新增sim卡续费记录表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return 结果
+     */
+    public int insertSimRechargeRecord(SimRechargeRecord simRechargeRecord);
+
+    /**
+     * 修改sim卡续费记录表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return 结果
+     */
+    public int updateSimRechargeRecord(SimRechargeRecord simRechargeRecord);
+
+    /**
+     * 批量删除sim卡续费记录表
+     *
+     * @param ids 需要删除的sim卡续费记录表主键集合
+     * @return 结果
+     */
+    public int deleteSimRechargeRecordByIds(Long[] ids);
+
+    /**
+     * 删除sim卡续费记录表信息
+     *
+     * @param id sim卡续费记录表主键
+     * @return 结果
+     */
+    public int deleteSimRechargeRecordById(Long id);
+}
diff --git a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/BatteryChargeReportService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/batteryreport/BatteryChargeReportService.java
similarity index 96%
rename from jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/BatteryChargeReportService.java
rename to jsowell-pile/src/main/java/com/jsowell/pile/service/batteryreport/BatteryChargeReportService.java
index b9d0e6715..942a1b678 100644
--- a/jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/platform/service/impl/BatteryChargeReportService.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/batteryreport/BatteryChargeReportService.java
@@ -1,4 +1,4 @@
-package com.jsowell.thirdparty.platform.service.impl;
+package com.jsowell.pile.service.batteryreport;
 
 import cn.hutool.http.HttpRequest;
 import com.alibaba.fastjson2.JSON;
@@ -10,14 +10,15 @@ import com.jsowell.common.core.redis.RedisCache;
 import com.jsowell.common.util.DateUtils;
 import com.jsowell.common.util.StringUtils;
 import com.jsowell.pile.domain.ChargeAlgorithmRecord;
+import com.jsowell.pile.domain.batteryreport.BatteryChargeReportData;
+import com.jsowell.pile.domain.batteryreport.BatteryReportResult;
 import com.jsowell.pile.service.*;
 import com.jsowell.pile.thirdparty.ParameterConfigData;
 import com.jsowell.pile.vo.uniapp.customer.OrderVO;
 import com.jsowell.pile.vo.web.PileConnectorInfoVO;
 import com.jsowell.pile.vo.web.PileDetailVO;
 import com.jsowell.pile.vo.web.PileStationVO;
-import com.jsowell.thirdparty.platform.domain.BatteryChargeReportData;
-import com.jsowell.thirdparty.platform.domain.BatteryReportResult;
+import org.apache.commons.lang3.RandomUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -139,7 +140,7 @@ public class BatteryChargeReportService {
             apiUrl = webDomainPrefix + apiPrefix + "pdf/" + taskId;
         }
         // 发送请求
-        String result = HttpRequest.get(apiUrl).execute().body();
+        String result = HttpRequest.get(apiUrl).header("token", token).execute().body();
         log.info("发送获取报告result:{}", result);
 
         // 将返回结果转化为json
@@ -216,6 +217,13 @@ public class BatteryChargeReportService {
                 .map(PileConnectorInfoVO::getPileSn)
                 .collect(Collectors.toSet());
 
+        String batteryType = String.valueOf(Integer.parseInt(chargingHandshakeData.getBmsBatteryType()));
+        // 如果 batteryType != 1/2/3/4/5
+        if (!StringUtils.equalsAny(batteryType, "1", "2", "3", "4", "5")) {
+            // 随机生成一个1-3的数
+            batteryType = String.valueOf(RandomUtils.nextInt(1, 4));
+        }
+
         BatteryChargeReportData data = BatteryChargeReportData.builder()
                 .mfrID(mfrID)
                 .siteName(stationVO.getStationName())
@@ -235,7 +243,7 @@ public class BatteryChargeReportService {
                 .doorStatus(Constants.zero)
                 .bmsChargeMode(Integer.parseInt(bmsDemandAndChargerOutputData.getBmsChargingModel()))
                 .vin(transactionRecordsData.getVinCode())
-                .batteryType(String.valueOf(Integer.parseInt(chargingHandshakeData.getBmsBatteryType())))
+                .batteryType(batteryType)
                 .nominalEnergy(new BigDecimal(parameterConfigData.getBmsSumEnergy()).toBigInteger().toString())
                 .ratedCapacity(new BigDecimal(parameterConfigData.getBmsSumEnergy()).toBigInteger().toString())
                 .ratedVoltage(chargingHandshakeData.getBmsBatteryVoltage())
@@ -251,6 +259,7 @@ public class BatteryChargeReportService {
 
                 .build();
 
+
         List<BatteryChargeReportData
                 .ChargeData> chargingDetailInfos = transformData(map);
 
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ChargeAlgorithmRecordServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ChargeAlgorithmRecordServiceImpl.java
index b7e7d0323..7932ab67f 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ChargeAlgorithmRecordServiceImpl.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ChargeAlgorithmRecordServiceImpl.java
@@ -8,6 +8,7 @@ import com.jsowell.common.util.DateUtils;
 import com.jsowell.common.util.StringUtils;
 import com.jsowell.pile.dto.BatteryChargeReportDTO;
 import com.jsowell.pile.service.ChargeAlgorithmRecordService;
+import com.jsowell.pile.service.batteryreport.BatteryChargeReportService;
 import com.jsowell.pile.vo.uniapp.customer.ChargeAlgorithmRecordVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -25,6 +26,9 @@ public class ChargeAlgorithmRecordServiceImpl implements ChargeAlgorithmRecordSe
     @Autowired
     private ChargeAlgorithmRecordMapper chargeAlgorithmRecordMapper;
 
+    @Autowired
+    private BatteryChargeReportService batteryChargeReportService;
+
     /**
      * 查询电池充电算法记录
      *
@@ -125,16 +129,44 @@ public class ChargeAlgorithmRecordServiceImpl implements ChargeAlgorithmRecordSe
      */
     @Override
     public String getUrlByParams(BatteryChargeReportDTO dto) {
+        // 参数校验
+        if (dto == null || StringUtils.isBlank(dto.getOrderCode())) {
+            return StringUtils.EMPTY;
+        }
+
         ChargeAlgorithmRecord record = queryRecordByOrderCode(dto.getOrderCode());
-        String reportType = dto.getReportType();
+        if (record == null) {
+            return StringUtils.EMPTY;
+        }
+
+        // 获取记录中的URL
+        String urlFromRecord = getUrlFromRecordByType(record, dto.getReportType());
+
+        if (StringUtils.isNotBlank(urlFromRecord)) {
+            return urlFromRecord;
+        }
+
+        // 如果记录中没有且taskId存在，通过服务获取
+        if (StringUtils.isNotBlank(record.getTaskId())) {
+            return batteryChargeReportService.getUrlByTaskId(record.getTaskId(), dto.getReportType());
+        }
+
+        return StringUtils.EMPTY;
+    }
+
+    /**
+     * 通过记录获取URL
+     * @param record
+     * @param reportType
+     * @return
+     */
+    private String getUrlFromRecordByType(ChargeAlgorithmRecord record, String reportType) {
         if (StringUtils.equals(Constants.ONE, reportType)) {
-            // 1-web 端
             return record.getWebUrl();
-        }else if (StringUtils.equals(Constants.TWO, reportType)) {
-            // 2-pdf 端
+        } else if (StringUtils.equals(Constants.TWO, reportType)) {
             return record.getPdfUrl();
         }
-        return "";
+        return null;
     }
 
     /**
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ClearingWithdrawInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ClearingWithdrawInfoServiceImpl.java
index 15c82f981..ededd9750 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ClearingWithdrawInfoServiceImpl.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/ClearingWithdrawInfoServiceImpl.java
@@ -92,6 +92,9 @@ public class ClearingWithdrawInfoServiceImpl implements ClearingWithdrawInfoServ
 
     @Override
     public List<ClearingBillVO> selectWithdrawInfoByOrderCodeList(List<String> orderCodeList) {
+        if (CollectionUtils.isEmpty(orderCodeList)) {
+            return Lists.newArrayList();
+        }
         return clearingWithdrawInfoMapper.selectWithdrawInfoByOrderCodeList(orderCodeList);
     }
 
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java
index ab7bdfe34..c9e1ed587 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java
@@ -798,6 +798,43 @@ public class OrderBasicInfoServiceImpl implements OrderBasicInfoService {
         }
     }
 
+    /**
+     * 判断是否退款保险金额
+     * @return
+     */
+    @Override
+    public boolean checkRefundInsuranceAmount(OrderBasicInfo orderBasicInfo) {
+        if (Objects.isNull(orderBasicInfo)) {
+            return false;
+        }
+        // 判断该订单是否支付保险
+        BigDecimal insuranceAmount = orderBasicInfo.getInsuranceAmount();
+        // 判断保险费是否大于0
+        if (insuranceAmount.compareTo(BigDecimal.ZERO) <= 0) {
+            return false;
+        }
+
+        // 判断是否已经退过保险费
+        AdapayRefundRecord entry = new AdapayRefundRecord();
+        entry.setOrderCode(orderBasicInfo.getOrderCode());
+        List<AdapayRefundRecord> adapayRefundRecords = adapayRefundRecordService.selectAdapayRefundRecordList(entry);
+        if (CollectionUtils.isNotEmpty(adapayRefundRecords)) {
+            for (AdapayRefundRecord adapayRefundRecord : adapayRefundRecords) {
+                String reason = adapayRefundRecord.getReason();
+                // reason转为json
+                JSONObject jsonObject = JSONObject.parseObject(reason);
+                // 取scenarioType
+                String scenarioType = jsonObject.getString("scenarioType");
+                if (StringUtils.equals(scenarioType, ScenarioEnum.INSURANCE.getValue())) {
+                    // 退过保险
+                    logger.info("订单号:{}已经退过保险，请勿重复退保险", orderBasicInfo.getOrderCode());
+                    return false;
+                }
+            }
+        }
+        return true;
+    }
+
     /**
      * 退保险费，需要退保险调此方法，此方法会调用退款接口
      */
@@ -6437,7 +6474,6 @@ public class OrderBasicInfoServiceImpl implements OrderBasicInfoService {
     }
 
     /**
-<<<<<<< HEAD
      * 运营端小程序查询订单
      * @param dto 查询条件
      * @return 订单查询结果
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SettleOrderReportServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SettleOrderReportServiceImpl.java
index 50d93e8df..0e485d80a 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SettleOrderReportServiceImpl.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SettleOrderReportServiceImpl.java
@@ -109,6 +109,9 @@ public class SettleOrderReportServiceImpl implements SettleOrderReportService {
         // 查询订单支付信息 分页
         int pageNum = dto.getPageNum() != null ? dto.getPageNum() : 1;
         int pageSize = dto.getPageSize() != null ? dto.getPageSize() : 10;
+        if (CollectionUtils.isEmpty(orderCodes)) {
+            return new PageResponse();
+        }
         PageHelper.startPage(pageNum, pageSize);
         List<ClearingBillVO> clearingBillVOList = clearingWithdrawInfoService.selectWithdrawInfoByOrderCodeList(orderCodes);
         PageInfo<ClearingBillVO> pageInfo = new PageInfo<>(clearingBillVOList);
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SimRechargeRecordServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SimRechargeRecordServiceImpl.java
new file mode 100644
index 000000000..ccceb1359
--- /dev/null
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SimRechargeRecordServiceImpl.java
@@ -0,0 +1,91 @@
+package com.jsowell.pile.service.impl;
+
+import java.util.List;
+
+import com.jsowell.common.util.DateUtils;
+import com.jsowell.pile.service.SimRechargeRecordService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import com.jsowell.pile.mapper.SimRechargeRecordMapper;
+import com.jsowell.pile.domain.SimRechargeRecord;
+import com.jsowell.pile.service.SimRechargeRecordService;
+
+/**
+ * sim卡续费记录表Service业务层处理
+ *
+ * @author jsowell
+ * @date 2026-03-06
+ */
+@Service
+public class SimRechargeRecordServiceImpl implements SimRechargeRecordService {
+    @Autowired
+    private SimRechargeRecordMapper simRechargeRecordMapper;
+
+    /**
+     * 查询sim卡续费记录表
+     *
+     * @param id sim卡续费记录表主键
+     * @return sim卡续费记录表
+     */
+    @Override
+    public SimRechargeRecord selectSimRechargeRecordById(Long id) {
+        return simRechargeRecordMapper.selectSimRechargeRecordById(id);
+    }
+
+    /**
+     * 查询sim卡续费记录表列表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return sim卡续费记录表
+     */
+    @Override
+    public List<SimRechargeRecord> selectSimRechargeRecordList(SimRechargeRecord simRechargeRecord) {
+        return simRechargeRecordMapper.selectSimRechargeRecordList(simRechargeRecord);
+    }
+
+    /**
+     * 新增sim卡续费记录表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return 结果
+     */
+    @Override
+    public int insertSimRechargeRecord(SimRechargeRecord simRechargeRecord) {
+        simRechargeRecord.setCreateTime(DateUtils.getNowDate());
+        return simRechargeRecordMapper.insertSimRechargeRecord(simRechargeRecord);
+    }
+
+    /**
+     * 修改sim卡续费记录表
+     *
+     * @param simRechargeRecord sim卡续费记录表
+     * @return 结果
+     */
+    @Override
+    public int updateSimRechargeRecord(SimRechargeRecord simRechargeRecord) {
+        simRechargeRecord.setUpdateTime(DateUtils.getNowDate());
+        return simRechargeRecordMapper.updateSimRechargeRecord(simRechargeRecord);
+    }
+
+    /**
+     * 批量删除sim卡续费记录表
+     *
+     * @param ids 需要删除的sim卡续费记录表主键
+     * @return 结果
+     */
+    @Override
+    public int deleteSimRechargeRecordByIds(Long[] ids) {
+        return simRechargeRecordMapper.deleteSimRechargeRecordByIds(ids);
+    }
+
+    /**
+     * 删除sim卡续费记录表信息
+     *
+     * @param id sim卡续费记录表主键
+     * @return 结果
+     */
+    @Override
+    public int deleteSimRechargeRecordById(Long id) {
+        return simRechargeRecordMapper.deleteSimRechargeRecordById(id);
+    }
+}
diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/programlogic/DelayMerchantProgramLogic.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/programlogic/DelayMerchantProgramLogic.java
index c64c7b1df..2abdd860e 100644
--- a/jsowell-pile/src/main/java/com/jsowell/pile/service/programlogic/DelayMerchantProgramLogic.java
+++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/programlogic/DelayMerchantProgramLogic.java
@@ -1098,12 +1098,24 @@ public class DelayMerchantProgramLogic extends AbstractProgramLogic {
                 .updateGiftBalance(returnGift)
                 .relatedOrderCode(orderCode)
                 .build();
-        memberBasicInfoService.updateMemberBalance(updateMemberBalanceDTO);
 
         // 判断消费金额，如果消费金额 - 折扣金额小于 1 元，则将保险费也进行退回
         if (orderBasicInfo.getOrderAmount().subtract(orderBasicInfo.getDiscountAmount()).compareTo(BigDecimal.ONE) < 0) {
-            orderBasicInfoService.refundInsurance(orderBasicInfo);
+            // orderBasicInfoService.refundInsurance(orderBasicInfo);
+            // 判断是否需要退保险费用
+            boolean checkResult = orderBasicInfoService.checkRefundInsuranceAmount(orderBasicInfo);
+            if (checkResult) {
+                // 退保险, 计算退保金额
+                Map<String, BigDecimal> refundMap = calculateBalanceRefund(principalPay, giftPay, orderBasicInfo.getOrderAmount(), orderBasicInfo.getDiscountAmount(), orderBasicInfo.getInsuranceAmount());
+                BigDecimal returnPrincipalForInsurance = refundMap.get("returnPrincipalForInsurance");
+                BigDecimal returnGiftForInsurance = refundMap.get("returnGiftForInsurance");
+
+                updateMemberBalanceDTO.setUpdatePrincipalBalance(returnPrincipal.add(returnPrincipalForInsurance));
+                updateMemberBalanceDTO.setUpdateGiftBalance(returnGift.add(returnGiftForInsurance));
+            }
         }
+        // 统一退款
+        memberBasicInfoService.updateMemberBalance(updateMemberBalanceDTO);
 
         // 更新order_pay_record, 解冻部分
         // List<Map<String, Object>> list = calculateUnfreezeAmount(orderAmount, payRecordList);
@@ -1150,13 +1162,19 @@ public class DelayMerchantProgramLogic extends AbstractProgramLogic {
         if (StringUtils.isNotBlank(wechatAppId)) {
             applyRefundDTO.setWechatAppId(wechatAppId);
         }
-        this.refundOrderWithAdapay(applyRefundDTO);
 
         // 判断消费金额，如果消费金额 - 折扣金额小于 1 元，则将保险费也进行退回
         if (orderBasicInfo.getOrderAmount().subtract(orderBasicInfo.getDiscountAmount()).compareTo(BigDecimal.ONE) < 0) {
-            orderBasicInfoService.refundInsurance(orderBasicInfo);
+            // orderBasicInfoService.refundInsurance(orderBasicInfo);
+            // 判断是否需要退款保险金额
+            boolean checkResult = orderBasicInfoService.checkRefundInsuranceAmount(orderBasicInfo);
+            if (checkResult) {
+                // 退款保险，将保险金额进行合并
+                applyRefundDTO.setRefundAmount(refundAmount.add(orderBasicInfo.getInsuranceAmount()));
+            }
         }
 
+        this.refundOrderWithAdapay(applyRefundDTO);
     }
 
     /**
diff --git a/jsowell-pile/src/main/java/com/jsowell/web/controller/pile/AdapayUnsplitRecordServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/web/controller/pile/AdapayUnsplitRecordServiceImpl.java
index b3b26b4d6..b418b9573 100644
--- a/jsowell-pile/src/main/java/com/jsowell/web/controller/pile/AdapayUnsplitRecordServiceImpl.java
+++ b/jsowell-pile/src/main/java/com/jsowell/web/controller/pile/AdapayUnsplitRecordServiceImpl.java
@@ -69,6 +69,11 @@ public class AdapayUnsplitRecordServiceImpl implements AdapayUnsplitRecordServic
         return adapayUnsplitRecordMapper.batchInsert(list);
     }
 
+    @Override
+    public int batchInsertOrUpdateSelective(List<AdapayUnsplitRecord> list) {
+        return adapayUnsplitRecordMapper.batchInsertOrUpdateSelective(list);
+    }
+
     @Override
     public List<AdapayUnsplitRecord> queryUnsplitOrders(String startTime, String endTime) {
         return adapayUnsplitRecordMapper.queryUnsplitOrders(startTime, endTime);
diff --git a/jsowell-pile/src/main/resources/mapper/pile/AdapayUnsplitRecordMapper.xml b/jsowell-pile/src/main/resources/mapper/pile/AdapayUnsplitRecordMapper.xml
index 9cc93db45..306f82ee1 100644
--- a/jsowell-pile/src/main/resources/mapper/pile/AdapayUnsplitRecordMapper.xml
+++ b/jsowell-pile/src/main/resources/mapper/pile/AdapayUnsplitRecordMapper.xml
@@ -447,6 +447,32 @@
       #{item.id,jdbcType=INTEGER}
     </foreach>
   </update>
+  <insert id="batchInsertOrUpdateSelective" keyColumn="id" keyProperty="id" parameterType="map" useGeneratedKeys="true">
+    insert into adapay_unsplit_record
+    (merchant_code, pay_time, payment_id, order_no, pay_amount, confirmed_split_amount,
+      refund_amount, payment_revoke_amount, remaining_split_amount, order_code, pile_type,
+      due_refund_amount, settle_amount, refund_flag, split_flag, update_time)
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.merchantCode,jdbcType=VARCHAR}, #{item.payTime,jdbcType=TIMESTAMP}, #{item.paymentId,jdbcType=VARCHAR},
+        #{item.orderNo,jdbcType=VARCHAR}, #{item.payAmount,jdbcType=DECIMAL}, #{item.confirmedSplitAmount,jdbcType=DECIMAL},
+        #{item.refundAmount,jdbcType=DECIMAL}, #{item.paymentRevokeAmount,jdbcType=DECIMAL},
+        #{item.remainingSplitAmount,jdbcType=DECIMAL}, #{item.orderCode,jdbcType=VARCHAR},
+        #{item.pileType,jdbcType=VARCHAR}, #{item.dueRefundAmount,jdbcType=DECIMAL}, #{item.settleAmount,jdbcType=DECIMAL},
+        #{item.refundFlag,jdbcType=VARCHAR}, #{item.splitFlag,jdbcType=VARCHAR}, #{item.updateTime,jdbcType=TIMESTAMP})
+    </foreach>
+    on duplicate key update
+      merchant_code = values(merchant_code),
+      pay_time = values(pay_time),
+      order_no = values(order_no),
+      pay_amount = values(pay_amount),
+      confirmed_split_amount = values(confirmed_split_amount),
+      refund_amount = values(refund_amount),
+      payment_revoke_amount = values(payment_revoke_amount),
+      remaining_split_amount = values(remaining_split_amount),
+      order_code = values(order_code),
+      update_time = values(update_time)
+  </insert>
   <insert id="batchInsert" keyColumn="id" keyProperty="id" parameterType="map" useGeneratedKeys="true">
     <!--@mbg.generated-->
     insert into adapay_unsplit_record
diff --git a/jsowell-pile/src/main/resources/mapper/pile/SimRechargeRecordMapper.xml b/jsowell-pile/src/main/resources/mapper/pile/SimRechargeRecordMapper.xml
new file mode 100644
index 000000000..ed9a06ca9
--- /dev/null
+++ b/jsowell-pile/src/main/resources/mapper/pile/SimRechargeRecordMapper.xml
@@ -0,0 +1,96 @@
+<?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="com.jsowell.pile.mapper.SimRechargeRecordMapper">
+
+    <resultMap type="com.jsowell.pile.domain.SimRechargeRecord" id="SimRechargeRecordResult">
+        <result property="id"    column="id"    />
+        <result property="rechargeOrderCode"    column="recharge_order_code"    />
+        <result property="iccId"    column="iccid"    />
+        <result property="payAmount"    column="pay_amount"    />
+        <result property="status"    column="status"    />
+        <result property="orderAmount"    column="order_amount"    />
+        <result property="createBy"    column="create_by"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateBy"    column="update_by"    />
+        <result property="updateTime"    column="update_time"    />
+        <result property="delFlag"    column="del_flag"    />
+    </resultMap>
+
+    <sql id="selectSimRechargeRecordVo">
+        select id, recharge_order_code, iccid, pay_amount, status, order_amount, create_by, create_time, update_by, update_time, del_flag from sim_recharge_record
+    </sql>
+
+    <select id="selectSimRechargeRecordList" parameterType="com.jsowell.pile.domain.SimRechargeRecord" resultMap="SimRechargeRecordResult">
+        <include refid="selectSimRechargeRecordVo"/>
+        <where>
+            <if test="rechargeOrderCode != null  and rechargeOrderCode != ''"> and recharge_order_code = #{rechargeOrderCode}</if>
+            <if test="iccId != null  and iccId != ''"> and iccid = #{iccId}</if>
+            <if test="payAmount != null "> and pay_amount = #{payAmount}</if>
+            <if test="status != null  and status != ''"> and status = #{status}</if>
+            <if test="orderAmount != null "> and order_amount = #{orderAmount}</if>
+        </where>
+    </select>
+
+    <select id="selectSimRechargeRecordById" parameterType="Long" resultMap="SimRechargeRecordResult">
+        <include refid="selectSimRechargeRecordVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertSimRechargeRecord" parameterType="com.jsowell.pile.domain.SimRechargeRecord" useGeneratedKeys="true" keyProperty="id">
+        insert into sim_recharge_record
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="rechargeOrderCode != null">recharge_order_code,</if>
+            <if test="iccId != null">iccid,</if>
+            <if test="payAmount != null">pay_amount,</if>
+            <if test="status != null">status,</if>
+            <if test="orderAmount != null">order_amount,</if>
+            <if test="createBy != null">create_by,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateBy != null">update_by,</if>
+            <if test="updateTime != null">update_time,</if>
+            <if test="delFlag != null">del_flag,</if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="rechargeOrderCode != null">#{rechargeOrderCode},</if>
+            <if test="iccId != null">#{iccId},</if>
+            <if test="payAmount != null">#{payAmount},</if>
+            <if test="status != null">#{status},</if>
+            <if test="orderAmount != null">#{orderAmount},</if>
+            <if test="createBy != null">#{createBy},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateBy != null">#{updateBy},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+            <if test="delFlag != null">#{delFlag},</if>
+        </trim>
+    </insert>
+
+    <update id="updateSimRechargeRecord" parameterType="com.jsowell.pile.domain.SimRechargeRecord">
+        update sim_recharge_record
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="rechargeOrderCode != null">recharge_order_code = #{rechargeOrderCode},</if>
+            <if test="iccId != null">iccid = #{iccid},</if>
+            <if test="payAmount != null">pay_amount = #{payAmount},</if>
+            <if test="status != null">status = #{status},</if>
+            <if test="orderAmount != null">order_amount = #{orderAmount},</if>
+            <if test="createBy != null">create_by = #{createBy},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateBy != null">update_by = #{updateBy},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+            <if test="delFlag != null">del_flag = #{delFlag},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteSimRechargeRecordById" parameterType="Long">
+        delete from sim_recharge_record where id = #{id}
+    </delete>
+
+    <delete id="deleteSimRechargeRecordByIds" parameterType="String">
+        delete from sim_recharge_record where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>
\ No newline at end of file
diff --git a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
index 151cac0cf..4517f433a 100644
--- a/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
+++ b/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java
@@ -2,8 +2,12 @@ package com.jsowell.quartz.task;
 
 import com.alibaba.fastjson2.JSON;
 import com.google.common.collect.Lists;
+import com.jsowell.adapay.common.DivMember;
+import com.jsowell.adapay.common.PaymentConfirmInfo;
+import com.jsowell.adapay.dto.PaymentConfirmParam;
 import com.jsowell.adapay.dto.QueryPaymentConfirmDTO;
 import com.jsowell.adapay.dto.WithdrawDTO;
+import com.jsowell.adapay.response.PaymentConfirmResponse;
 import com.jsowell.adapay.response.QueryPaymentConfirmDetailResponse;
 import com.jsowell.adapay.service.AdapayService;
 import com.jsowell.common.YouDianUtils;
@@ -23,18 +27,24 @@ import com.jsowell.pile.domain.ykcCommond.PublishPileBillingTemplateCommand;
 import com.jsowell.pile.domain.ykcCommond.StartChargingCommand;
 import com.jsowell.pile.service.*;
 import com.jsowell.pile.service.MemberCouponService;
+import com.jsowell.pile.vo.AdapayUnsplitRecordVO;
 import com.jsowell.pile.vo.base.StationInfoVO;
 import com.jsowell.pile.vo.web.BillingTemplateVO;
 import com.jsowell.thirdparty.amap.service.AMapService;
 import com.jsowell.thirdparty.common.NotificationDTO;
 import com.jsowell.thirdparty.common.NotificationService;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.poi.ss.usermodel.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.io.InputStream;
 import java.math.BigDecimal;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.*;
@@ -422,6 +432,576 @@ public class JsowellTask {
         }
     }
 
+    /**
+     * 处理adapay_unsplit_record待分账数据，统一分账到memberId=0
+     * 依赖queryList()，请先完成settle_amount/due_refund_amount等字段补齐
+     * jsowellTask.processUnsplitRecordToDefaultMember()
+     */
+    public void processUnsplitRecordToDefaultMember() {
+        processUnsplitRecordToDefaultMember(Constants.DEFAULT_APP_ID, 500);
+    }
+
+    /**
+     * 处理adapay_unsplit_record待分账数据，统一分账到memberId=0
+     * jsowellTask.processUnsplitRecordToDefaultMember(wechatAppId, pageSize)
+     */
+    public void processUnsplitRecordToDefaultMember(String wechatAppId, Integer pageSize) {
+        int size = pageSize == null || pageSize <= 0 ? 500 : pageSize;
+        int pageNum = 1;
+        int total = 0;
+        int success = 0;
+        int skipped = 0;
+        int failed = 0;
+
+        while (true) {
+            PageUtils.startPage(pageNum, size);
+            List<AdapayUnsplitRecordVO> list = adapayUnsplitRecordService.queryList();
+            if (CollectionUtils.isEmpty(list)) {
+                break;
+            }
+
+            log.info("处理未分账数据到默认账户, pageNum:{}, pageSize:{}, 当前页:{}条", pageNum, size, list.size());
+            for (AdapayUnsplitRecordVO item : list) {
+                total++;
+                String paymentId = item.getPaymentId();
+                String orderCode = item.getOrderCode();
+                BigDecimal waitSplitAmount = parseAmount(item.getWaitSplitAmount());
+
+                if (StringUtils.isBlank(paymentId) || waitSplitAmount.compareTo(BigDecimal.ZERO) <= 0) {
+                    skipped++;
+                    continue;
+                }
+
+                BigDecimal confirmAmt = getLatestConfirmAmount(waitSplitAmount, item.getPayAmount(), paymentId, wechatAppId);
+                if (confirmAmt.compareTo(BigDecimal.ZERO) <= 0) {
+                    skipped++;
+                    continue;
+                }
+
+                PaymentConfirmResponse response;
+                try {
+                    DivMember divMember = new DivMember();
+                    divMember.setMemberId(Constants.ZERO);
+                    divMember.setAmount(confirmAmt.setScale(2, BigDecimal.ROUND_HALF_UP).toPlainString());
+                    divMember.setFeeFlag(Constants.Y);
+
+                    PaymentConfirmParam param = PaymentConfirmParam.builder()
+                            .paymentId(paymentId)
+                            .divMemberList(Lists.newArrayList(divMember))
+                            .confirmAmt(confirmAmt)
+                            .orderCode(orderCode)
+                            .wechatAppId(wechatAppId)
+                            .build();
+                    response = adapayService.createPaymentConfirmRequest(param);
+                } catch (Exception e) {
+                    failed++;
+                    log.error("处理未分账数据到默认账户异常, paymentId:{}, orderCode:{}, confirmAmt:{}",
+                            paymentId, orderCode, confirmAmt, e);
+                    markSplitResult(paymentId, "FAILED");
+                    continue;
+                }
+
+                if (response != null && response.isSuccess()) {
+                    success++;
+                    updateConfirmedSplitAmount(item, confirmAmt, paymentId);
+                    markSplitResult(paymentId, "SUCCESS");
+                    log.info("处理未分账数据成功, paymentId:{}, orderCode:{}, confirmAmt:{}, response:{}",
+                            paymentId, orderCode, confirmAmt, JSON.toJSONString(response));
+                } else {
+                    failed++;
+                    String errorCode = response == null ? "response_null" : response.getError_code();
+                    String errorMsg = response == null ? "response_is_null" : response.getError_msg();
+                    log.error("处理未分账数据失败, paymentId:{}, orderCode:{}, confirmAmt:{}, errorCode:{}, errorMsg:{}",
+                            paymentId, orderCode, confirmAmt, errorCode, errorMsg);
+                    markSplitResult(paymentId, "FAILED");
+                }
+            }
+
+            if (list.size() < size) {
+                break;
+            }
+            pageNum++;
+        }
+
+        log.info("处理未分账数据到默认账户结束, total:{}, success:{}, skipped:{}, failed:{}",
+                total, success, skipped, failed);
+    }
+
+    /**
+     * 从Excel导入adapay_unsplit_record，并补齐缺失字段
+     * 默认文件路径：doc/万车充小程序-未分账明细.xlsx
+     * jsowellTask.importAdapayUnsplitRecordAndCompleteFields()
+     */
+    /**
+     * 从默认路径导入未分账明细并补齐缺失字段（无参入口）
+     * 默认读取 doc/万车充小程序-未分账明细.xlsx（相对于工作目录）
+     * jsowellTask.importAdapayUnsplitRecordAndCompleteFields()
+     */
+    public void importAdapayUnsplitRecordAndCompleteFields() {
+        importAdapayUnsplitRecordAndCompleteFields("doc/万车充小程序-未分账明细.xlsx");
+    }
+
+    /**
+     * 补齐 adapay_unsplit_record 表中缺失字段（独立入口，可单独作为定时任务调用）
+     * 以指定时间范围内的未分账记录为目标，补齐 orderCode、退款金额、结算金额、桩类型
+     * jsowellTask.completeAdapayUnsplitRecordFields(startTime, endTime)
+     * 示例：jsowellTask.completeAdapayUnsplitRecordFields('2024-01-01 00:00:00', '2025-12-31 23:59:59')
+     */
+    public void completeAdapayUnsplitRecordFields(String startTime, String endTime) {
+        int updatedCount = completeUnsplitRecordMissingFields(startTime, endTime, 1000);
+        log.info("补齐未分账数据缺失字段完成, startTime:{}, endTime:{}, 更新:{}条", startTime, endTime, updatedCount);
+    }
+
+    /**
+     * 从Excel导入adapay_unsplit_record，并补齐缺失字段
+     * 流程：
+     *   1. 校验文件路径（相对路径自动拼接工作目录转为绝对路径）
+     *   2. 解析Excel，逐行转换为 AdapayUnsplitRecord，调用 insertOrUpdateSelective 写入数据库
+     *   3. 以导入数据的支付时间范围为条件，分页查询已入库记录，补齐 orderCode/退款金额/结算金额/桩类型等缺失字段
+     * jsowellTask.importAdapayUnsplitRecordAndCompleteFields(文件路径)
+     */
+    public void importAdapayUnsplitRecordAndCompleteFields(String filePath) {
+        // 相对路径转绝对路径（基于 JVM 工作目录）
+        Path path = Paths.get(filePath);
+        if (!path.isAbsolute()) {
+            path = Paths.get(System.getProperty("user.dir"), filePath);
+        }
+        if (!Files.exists(path)) {
+            log.error("导入未分账数据失败，文件不存在:{}", path.toAbsolutePath());
+            return;
+        }
+
+        // 第一步：读取Excel，将每行数据 insertOrUpdate 到 adapay_unsplit_record 表
+        ImportSummary summary = importAdapayUnsplitRecord(path);
+
+        if (summary.successRows == 0) {
+            log.info("导入未分账数据结束，未写入任何数据，统计:{}", summary);
+            return;
+        }
+
+        // 第二步：以导入数据中最早/最晚支付时间为范围，补齐已入库记录的缺失字段
+        // 若 Excel 中无有效支付时间，则使用兜底时间范围（2024-01-01 至当前时间）
+        String startTime = summary.minPayTime == null
+                ? "2024-01-01 00:00:00"
+                : DateUtils.formatDateTime(summary.minPayTime);
+        String endTime = summary.maxPayTime == null
+                ? DateUtils.getDateTime()
+                : DateUtils.formatDateTime(summary.maxPayTime);
+
+        int updatedCount = completeUnsplitRecordMissingFields(startTime, endTime, 1000);
+        log.info("导入并补齐未分账数据完成, 导入统计:{}, 补齐更新:{}条", summary, updatedCount);
+    }
+
+    private static final int IMPORT_BATCH_SIZE = 500;
+
+    private ImportSummary importAdapayUnsplitRecord(Path filePath) {
+        ImportSummary summary = new ImportSummary();
+        DataFormatter formatter = new DataFormatter();
+
+        try (InputStream inputStream = Files.newInputStream(filePath);
+             Workbook workbook = WorkbookFactory.create(inputStream)) {
+            Sheet sheet = workbook.getSheetAt(0);
+            if (sheet == null) {
+                log.error("导入未分账数据失败，Excel没有sheet, file:{}", filePath.toAbsolutePath());
+                return summary;
+            }
+
+            Row headerRow = sheet.getRow(sheet.getFirstRowNum());
+            if (headerRow == null) {
+                log.error("导入未分账数据失败，Excel没有表头, file:{}", filePath.toAbsolutePath());
+                return summary;
+            }
+
+            Map<String, Integer> headerIndexMap = buildHeaderIndexMap(headerRow, formatter);
+            List<String> requiredHeaders = Lists.newArrayList(
+                    "商户号", "支付时间", "交易流水号", "交易订单号", "交易订单金额", "已确认分账金额", "已撤销金额", "支付确认撤销金额", "剩余未分账金额"
+            );
+            for (String requiredHeader : requiredHeaders) {
+                if (!headerIndexMap.containsKey(normalizeHeader(requiredHeader))) {
+                    log.error("导入未分账数据失败，缺少字段:{}, file:{}", requiredHeader, filePath.toAbsolutePath());
+                    return summary;
+                }
+            }
+
+            int firstDataRow = sheet.getFirstRowNum() + 1;
+            int lastDataRow = sheet.getLastRowNum();
+            // 批量收集记录，每 IMPORT_BATCH_SIZE 条执行一次批量 upsert，减少数据库交互次数
+            List<AdapayUnsplitRecord> batch = new ArrayList<>(IMPORT_BATCH_SIZE);
+            for (int rowNum = firstDataRow; rowNum <= lastDataRow; rowNum++) {
+                Row row = sheet.getRow(rowNum);
+                if (row == null || isRowEmpty(row)) {
+                    continue;
+                }
+                summary.totalRows++;
+
+                try {
+                    AdapayUnsplitRecord record = convertRowToRecord(row, headerIndexMap, formatter);
+                    if (record == null) {
+                        summary.skippedRows++;
+                        continue;
+                    }
+                    batch.add(record);
+                    summary.updatePayTimeRange(record.getPayTime());
+
+                    // 达到批量大小时执行一次批量写入
+                    if (batch.size() >= IMPORT_BATCH_SIZE) {
+                        adapayUnsplitRecordService.batchInsertOrUpdateSelective(batch);
+                        summary.successRows += batch.size();
+                        batch.clear();
+                    }
+                } catch (Exception e) {
+                    summary.failedRows++;
+                    log.error("导入未分账数据失败, rowNum:{}, file:{}", rowNum + 1, filePath.toAbsolutePath(), e);
+                }
+
+                if (summary.totalRows % 1000 == 0) {
+                    log.info("导入未分账数据进行中, total:{}, success:{}, skipped:{}, failed:{}",
+                            summary.totalRows, summary.successRows, summary.skippedRows, summary.failedRows);
+                }
+            }
+            // 处理剩余不足一批的记录
+            if (!batch.isEmpty()) {
+                adapayUnsplitRecordService.batchInsertOrUpdateSelective(batch);
+                summary.successRows += batch.size();
+            }
+        } catch (Exception e) {
+            log.error("导入未分账数据失败, file:{}", filePath.toAbsolutePath(), e);
+        }
+
+        return summary;
+    }
+
+    private int completeUnsplitRecordMissingFields(String startTime, String endTime, int pageSize) {
+        int pageNum = 1;
+        int updatedCount = 0;
+
+        while (true) {
+            PageUtils.startPage(pageNum, pageSize);
+            List<AdapayUnsplitRecord> list = adapayUnsplitRecordService.queryUnsplitOrders(startTime, endTime);
+            if (CollectionUtils.isEmpty(list)) {
+                break;
+            }
+
+            Set<String> orderCodeSet = new HashSet<>();
+            for (AdapayUnsplitRecord record : list) {
+                if (StringUtils.isBlank(record.getOrderCode())) {
+                    String extractedOrderCode = extractOrderCode(record.getOrderNo());
+                    if (StringUtils.isNotBlank(extractedOrderCode)) {
+                        record.setOrderCode(extractedOrderCode);
+                    }
+                }
+                if (StringUtils.isNotBlank(record.getOrderCode())) {
+                    orderCodeSet.add(record.getOrderCode());
+                }
+            }
+
+            Map<String, OrderBasicInfo> orderMap = new HashMap<>();
+            if (CollectionUtils.isNotEmpty(orderCodeSet)) {
+                List<OrderBasicInfo> orderList = orderBasicInfoService.selectOrderTemp(orderCodeSet);
+                orderMap = orderList.stream()
+                        .collect(Collectors.toMap(OrderBasicInfo::getOrderCode, v -> v, (k1, k2) -> k1));
+            }
+
+            List<AdapayUnsplitRecord> updateList = new ArrayList<>();
+            Date now = DateUtils.getNowDate();
+            for (AdapayUnsplitRecord record : list) {
+                boolean needUpdate = false;
+
+                String orderCode = record.getOrderCode();
+                if (StringUtils.isBlank(orderCode)) {
+                    orderCode = extractOrderCode(record.getOrderNo());
+                    if (StringUtils.isNotBlank(orderCode)) {
+                        record.setOrderCode(orderCode);
+                        needUpdate = true;
+                    }
+                }
+
+                if (StringUtils.isNotBlank(orderCode)) {
+                    OrderBasicInfo orderBasicInfo = orderMap.get(orderCode);
+                    if (orderBasicInfo != null) {
+                        BigDecimal refundAmount = orderBasicInfo.getRefundAmount();
+                        if (!isSameAmount(record.getDueRefundAmount(), refundAmount)) {
+                            record.setDueRefundAmount(refundAmount);
+                            needUpdate = true;
+                        }
+                        BigDecimal settleAmount = orderBasicInfo.getSettleAmount();
+                        if (!isSameAmount(record.getSettleAmount(), settleAmount)) {
+                            record.setSettleAmount(settleAmount);
+                            needUpdate = true;
+                        }
+                        String pileType = YouDianUtils.isEBikePileSn(orderBasicInfo.getPileSn()) ? "eBike" : "EV";
+                        if (!StringUtils.equals(record.getPileType(), pileType)) {
+                            record.setPileType(pileType);
+                            needUpdate = true;
+                        }
+                    }
+                }
+
+                if (needUpdate) {
+                    record.setUpdateTime(now);
+                    updateList.add(record);
+                }
+            }
+
+            if (CollectionUtils.isNotEmpty(updateList)) {
+                adapayUnsplitRecordService.updateBatchSelective(updateList);
+                updatedCount += updateList.size();
+            }
+
+            if (list.size() < pageSize) {
+                break;
+            }
+            pageNum++;
+        }
+
+        return updatedCount;
+    }
+
+    private BigDecimal getLatestConfirmAmount(BigDecimal waitSplitAmount, String payAmount, String paymentId, String wechatAppId) {
+        BigDecimal confirmAmt = waitSplitAmount;
+        try {
+            QueryPaymentConfirmDTO dto = new QueryPaymentConfirmDTO();
+            dto.setWechatAppId(wechatAppId);
+            dto.setPaymentId(paymentId);
+            QueryPaymentConfirmDetailResponse response = adapayService.queryPaymentConfirmList(dto);
+            BigDecimal latestRemaining = calculateLatestRemainingAmount(payAmount, response);
+            if (latestRemaining.compareTo(BigDecimal.ZERO) > 0) {
+                confirmAmt = waitSplitAmount.min(latestRemaining);
+            }
+        } catch (Exception e) {
+            log.warn("查询汇付确认金额异常，使用数据库待分账金额继续处理, paymentId:{}, waitSplitAmount:{}",
+                    paymentId, waitSplitAmount, e);
+        }
+        return confirmAmt;
+    }
+
+    private BigDecimal calculateLatestRemainingAmount(String payAmount, QueryPaymentConfirmDetailResponse response) {
+        BigDecimal payAmt = parseAmount(payAmount);
+        if (payAmt.compareTo(BigDecimal.ZERO) <= 0 || response == null || CollectionUtils.isEmpty(response.getPaymentConfirms())) {
+            return payAmt;
+        }
+
+        BigDecimal maxConfirmedAmt = BigDecimal.ZERO;
+        BigDecimal maxReservedAmt = BigDecimal.ZERO;
+        List<PaymentConfirmInfo> confirms = response.getPaymentConfirms();
+        for (PaymentConfirmInfo confirm : confirms) {
+            BigDecimal confirmedAmt = parseAmount(confirm.getConfirmedAmt());
+            BigDecimal reservedAmt = parseAmount(confirm.getReservedAmt());
+            if (confirmedAmt.compareTo(maxConfirmedAmt) > 0) {
+                maxConfirmedAmt = confirmedAmt;
+            }
+            if (reservedAmt.compareTo(maxReservedAmt) > 0) {
+                maxReservedAmt = reservedAmt;
+            }
+        }
+        BigDecimal latestRemaining = payAmt.subtract(maxConfirmedAmt).subtract(maxReservedAmt);
+        return latestRemaining.compareTo(BigDecimal.ZERO) > 0 ? latestRemaining : BigDecimal.ZERO;
+    }
+
+    private void updateConfirmedSplitAmount(AdapayUnsplitRecordVO item, BigDecimal confirmAmt, String paymentId) {
+        BigDecimal oldConfirmedAmt = parseAmount(item.getConfirmedSplitAmount());
+        BigDecimal newConfirmedAmt = oldConfirmedAmt.add(confirmAmt).setScale(2, BigDecimal.ROUND_HALF_UP);
+        AdapayUnsplitRecord updateRecord = new AdapayUnsplitRecord();
+        updateRecord.setPaymentId(paymentId);
+        updateRecord.setConfirmedSplitAmount(newConfirmedAmt);
+        updateRecord.setUpdateTime(DateUtils.getNowDate());
+        adapayUnsplitRecordService.insertOrUpdateSelective(updateRecord);
+    }
+
+    private void markSplitResult(String paymentId, String splitFlag) {
+        AdapayUnsplitRecord updateRecord = new AdapayUnsplitRecord();
+        updateRecord.setPaymentId(paymentId);
+        updateRecord.setSplitFlag(splitFlag);
+        updateRecord.setUpdateTime(DateUtils.getNowDate());
+        adapayUnsplitRecordService.insertOrUpdateSelective(updateRecord);
+    }
+
+    private AdapayUnsplitRecord convertRowToRecord(Row row, Map<String, Integer> headerIndexMap, DataFormatter formatter) {
+        String paymentId = getCellString(row, headerIndexMap.get(normalizeHeader("交易流水号")), formatter);
+        if (StringUtils.isBlank(paymentId)) {
+            return null;
+        }
+
+        String orderNo = getCellString(row, headerIndexMap.get(normalizeHeader("交易订单号")), formatter);
+        Date payTime = parsePayTime(getCell(row, headerIndexMap.get(normalizeHeader("支付时间"))), formatter);
+
+        AdapayUnsplitRecord record = new AdapayUnsplitRecord();
+        record.setMerchantCode(getCellString(row, headerIndexMap.get(normalizeHeader("商户号")), formatter));
+        record.setPayTime(payTime);
+        record.setPaymentId(paymentId);
+        record.setOrderNo(orderNo);
+        record.setOrderCode(extractOrderCode(orderNo));
+        record.setPayAmount(getCellDecimal(row, headerIndexMap.get(normalizeHeader("交易订单金额")), formatter));
+        record.setConfirmedSplitAmount(getCellDecimal(row, headerIndexMap.get(normalizeHeader("已确认分账金额")), formatter));
+        record.setRefundAmount(getCellDecimal(row, headerIndexMap.get(normalizeHeader("已撤销金额")), formatter));
+        record.setPaymentRevokeAmount(getCellDecimal(row, headerIndexMap.get(normalizeHeader("支付确认撤销金额")), formatter));
+        record.setRemainingSplitAmount(getCellDecimal(row, headerIndexMap.get(normalizeHeader("剩余未分账金额")), formatter));
+        record.setUpdateTime(DateUtils.getNowDate());
+        return record;
+    }
+
+    private Map<String, Integer> buildHeaderIndexMap(Row headerRow, DataFormatter formatter) {
+        Map<String, Integer> headerIndexMap = new HashMap<>();
+        short firstCellNum = headerRow.getFirstCellNum();
+        short lastCellNum = headerRow.getLastCellNum();
+        if (firstCellNum < 0 || lastCellNum < 0) {
+            return headerIndexMap;
+        }
+        for (int cellIndex = firstCellNum; cellIndex < lastCellNum; cellIndex++) {
+            Cell cell = headerRow.getCell(cellIndex, Row.MissingCellPolicy.RETURN_BLANK_AS_NULL);
+            if (cell == null) {
+                continue;
+            }
+            String header = normalizeHeader(formatter.formatCellValue(cell));
+            if (StringUtils.isNotBlank(header)) {
+                headerIndexMap.put(header, cellIndex);
+            }
+        }
+        return headerIndexMap;
+    }
+
+    private String getCellString(Row row, Integer columnIndex, DataFormatter formatter) {
+        Cell cell = getCell(row, columnIndex);
+        if (cell == null) {
+            return null;
+        }
+        String value = formatter.formatCellValue(cell);
+        return StringUtils.isBlank(value) ? null : value.trim();
+    }
+
+    private Cell getCell(Row row, Integer columnIndex) {
+        if (row == null || columnIndex == null) {
+            return null;
+        }
+        return row.getCell(columnIndex, Row.MissingCellPolicy.RETURN_BLANK_AS_NULL);
+    }
+
+    private BigDecimal getCellDecimal(Row row, Integer columnIndex, DataFormatter formatter) {
+        String value = getCellString(row, columnIndex, formatter);
+        return parseAmount(value);
+    }
+
+    private Date parsePayTime(Cell cell, DataFormatter formatter) {
+        if (cell == null) {
+            return null;
+        }
+        if (cell.getCellType() == CellType.NUMERIC) {
+            return DateUtil.getJavaDate(cell.getNumericCellValue());
+        }
+        if (cell.getCellType() == CellType.FORMULA && cell.getCachedFormulaResultType() == CellType.NUMERIC) {
+            return DateUtil.getJavaDate(cell.getNumericCellValue());
+        }
+
+        String value = formatter.formatCellValue(cell);
+        if (StringUtils.isBlank(value)) {
+            return null;
+        }
+        Date date = DateUtils.parseDate(value.trim());
+        if (date != null) {
+            return date;
+        }
+        try {
+            return DateUtil.getJavaDate(Double.parseDouble(value.trim()));
+        } catch (Exception e) {
+            log.warn("解析支付时间失败，value:{}", value);
+            return null;
+        }
+    }
+
+    private String extractOrderCode(String orderNo) {
+        if (StringUtils.isBlank(orderNo)) {
+            return null;
+        }
+        int index = orderNo.indexOf("_");
+        String orderCode = index > 0 ? orderNo.substring(0, index) : orderNo;
+        // order_code 字段长度限制为 16，超长则无法匹配订单，返回 null
+        if (orderCode.length() >= 16) {
+            log.warn("order_code 字段长度超出限制，order_no:{}", orderNo);
+        }
+        return orderCode.length() <= 16 ? orderCode : null;
+    }
+
+    private String normalizeHeader(String header) {
+        return header == null ? "" : header.replace(" ", "").trim();
+    }
+
+    private boolean isSameAmount(BigDecimal left, BigDecimal right) {
+        if (left == null && right == null) {
+            return true;
+        }
+        if (left == null || right == null) {
+            return false;
+        }
+        return left.compareTo(right) == 0;
+    }
+
+    private BigDecimal parseAmount(String value) {
+        if (StringUtils.isBlank(value)) {
+            return BigDecimal.ZERO;
+        }
+        String normalizedValue = value.replace(",", "").trim();
+        try {
+            return new BigDecimal(normalizedValue);
+        } catch (NumberFormatException e) {
+            log.warn("解析数字失败，value:{}", value);
+            return BigDecimal.ZERO;
+        }
+    }
+
+    private boolean isRowEmpty(Row row) {
+        if (row == null) {
+            return true;
+        }
+        short firstCellNum = row.getFirstCellNum();
+        short lastCellNum = row.getLastCellNum();
+        if (firstCellNum < 0 || lastCellNum < 0) {
+            return true;
+        }
+        for (int i = firstCellNum; i < lastCellNum; i++) {
+            Cell cell = row.getCell(i, Row.MissingCellPolicy.RETURN_BLANK_AS_NULL);
+            if (cell == null) {
+                continue;
+            }
+            if (cell.getCellType() != CellType.BLANK) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    private static class ImportSummary {
+        private int totalRows;
+        private int successRows;
+        private int skippedRows;
+        private int failedRows;
+        private Date minPayTime;
+        private Date maxPayTime;
+
+        private void updatePayTimeRange(Date payTime) {
+            if (payTime == null) {
+                return;
+            }
+            if (minPayTime == null || payTime.before(minPayTime)) {
+                minPayTime = payTime;
+            }
+            if (maxPayTime == null || payTime.after(maxPayTime)) {
+                maxPayTime = payTime;
+            }
+        }
+
+        @Override
+        public String toString() {
+            return "{"
+                    + "\"totalRows\":" + totalRows
+                    + ", \"successRows\":" + successRows
+                    + ", \"skippedRows\":" + skippedRows
+                    + ", \"failedRows\":" + failedRows
+                    + ", \"minPayTime\":\"" + (minPayTime == null ? "" : DateUtils.formatDateTime(minPayTime)) + "\""
+                    + ", \"maxPayTime\":\"" + (maxPayTime == null ? "" : DateUtils.formatDateTime(maxPayTime)) + "\""
+                    + "}";
+        }
+    }
+
     /**
      * V1方法，获取退款金额与结算金额
      * @param batchNum