Merge branch 'main' of http://192.168.65.198:3000/toolchaintechnologycenter/spdm-backend

job/src/main/java/com/sdm/job/schedule/DataSchedule.java

@@ -2,6 +2,8 @@ package com.sdm.job.schedule;
 
 import com.sdm.common.common.SdmResponse;
 import com.sdm.common.feign.inter.data.IDataScheduleFeignClient;
+import com.sdm.common.utils.MdcUtil;
+import com.xxl.job.core.context.XxlJobHelper;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,10 +22,12 @@ public class DataSchedule {
      */
     @XxlJob("dataStorageMonitorHandler")
     public void checkDataStorageSpaceAndSendAlert() throws Exception {
-        log.info("开始执行定时筛选存储空间达到阈值的用户任务");
+        String traceId = MdcUtil.generateAndPutTraceId();
+        XxlJobHelper.log("XXL-JOB:开始执行定时筛选存储空间达到阈值的用户任务traceId:{}",traceId);
         // 业务逻辑方法调度
         SdmResponse<String> response = dataScheduleFeignClient.dataStorageMonitor();
-        log.info("定时筛选存储空间达到阈值的用户任务执行完成");
+        XxlJobHelper.log("定时筛选存储空间达到阈值的用户任务执行完成");
+        MdcUtil.removeTraceId();
     }