[update] 统计司机日货损逻辑加入参数逻辑, 允许选择指定日期

warehouse-admin-event/src/main/java/com/yr/warehouse/admin/event/task/DriverCargoDamageStatisticsTask.java

@@ -1,10 +1,12 @@
 package com.yr.warehouse.admin.event.task;
 
+import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import com.yr.warehouse.admin.service.context.TransactionAwareComponent;
 import com.yr.warehouse.admin.service.statistics.DriverStatistics;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDate;
@@ -27,12 +29,24 @@ public class DriverCargoDamageStatisticsTask {
      */
     @XxlJob("driverCargoDamageStatisticsTask")
     public void driverCargoDamageStatisticsTask() {
-        log.info("开始执行司机货损统计任务");
+        String dayParamStr = XxlJobHelper.getJobParam();
+        XxlJobHelper.log("货损统计任务参数：{}", dayParamStr);
+        XxlJobHelper.log("开始执行司机货损统计任务");
+        if (StringUtils.isNotBlank(dayParamStr) && dayParamStr.contains("-")) {
+            for (String dayStr : dayParamStr.split(",")) {
+                LocalDate day = LocalDate.parse(dayStr);
+                driverStatistics.cargoDamageStatistics(day);
+                XxlJobHelper.log("结束执行司机货损统计任务：{}", day);
+            }
+            return;
+        }
+
+
         transactionAwareComponent.execute(status -> {
             driverStatistics.cargoDamageStatistics(LocalDate.now());
             return null;
         });
-        log.info("结束执行司机货损统计任务");
+        XxlJobHelper.log("结束执行司机货损统计任务：{}", LocalDate.now());
     }
 
 }