package com.ruoyi.quartz.task;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.cwgl.domain.ApiResponse;
|
import com.ruoyi.cwgl.domain.VehicleDailyData;
|
import com.ruoyi.cwgl.service.IVehicleDailyDataService;
|
import com.ruoyi.cwgl.service.impl.VehicleDataApiClient;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 车辆每日数据同步定时任务
|
*
|
* @author ruoyi
|
*/
|
@Component("vehicleDataSyncTask")
|
public class VehicleDataSyncTask {
|
private static Logger logger = LoggerFactory.getLogger(VehicleDataSyncTask.class);
|
|
@Autowired
|
private IVehicleDailyDataService vehicleDailyDataService;
|
|
@Autowired
|
private VehicleDataApiClient vehicleDataApiClient;
|
|
/**
|
* 同步前一天的车辆数据（简单版本，执行即同步昨天数据）
|
*/
|
public void syncVehicleData() {
|
logger.info("开始同步车辆每日数据任务");
|
|
// 获取前一天的日期，格式为yyyy-MM-dd
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
Date yesterday = DateUtils.addDays(new Date(), -1);
|
String dateStr = sdf.format(yesterday);
|
|
logger.info("开始同步日期[{}]的车辆数据", dateStr);
|
|
try {
|
// 直接使用注入的API客户端调用方法
|
ApiResponse<List<VehicleDailyData>> response = vehicleDataApiClient.getDailyVehicleData(dateStr);
|
|
if (response != null && response.getCode().equals(200) && CollectionUtil.isNotEmpty(response.getData())) {
|
List<VehicleDailyData> vehicleDataList = response.getData();
|
logger.info("成功获取到{}条车辆数据", vehicleDataList.size());
|
|
// 设置创建时间和事件日期
|
Date now = new Date();
|
SimpleDateFormat dateTimeFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
for (VehicleDailyData data : vehicleDataList) {
|
data.setCreateTime(now);
|
|
try {
|
// 设置事件日期
|
data.setEventDate(dateTimeFormat.parse(dateStr + " 00:00:00"));
|
} catch (Exception e) {
|
logger.error("日期格式化错误: {}", e.getMessage());
|
}
|
}
|
|
// 批量插入数据库
|
int rows = vehicleDailyDataService.insertVehicleDailyDataBatch(vehicleDataList);
|
logger.info("车辆数据同步完成，成功插入{}条记录", rows);
|
} else {
|
String errorMsg = response != null ? response.getMsg() : "获取API响应失败";
|
logger.error("获取车辆数据失败: {}", errorMsg);
|
}
|
} catch (Exception e) {
|
logger.error("车辆数据同步任务执行异常: {}", e.getMessage(), e);
|
}
|
}
|
|
/**
|
* 根据指定日期同步车辆数据（保留用于手动触发特定日期的数据同步）
|
* @param date 日期，格式为yyyy-MM-dd
|
*/
|
public void syncVehicleDataByDate(String date) {
|
logger.info("开始同步日期[{}]的车辆数据", date);
|
|
try {
|
// 直接使用注入的API客户端调用方法
|
ApiResponse<List<VehicleDailyData>> response = vehicleDataApiClient.getDailyVehicleData(date);
|
|
if (response != null && response.getCode().equals(200) && CollectionUtil.isNotEmpty(response.getData())) {
|
List<VehicleDailyData> vehicleDataList = response.getData();
|
logger.info("成功获取到{}条车辆数据", vehicleDataList.size());
|
|
// 设置创建时间和事件日期
|
Date now = new Date();
|
SimpleDateFormat dateTimeFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
for (VehicleDailyData data : vehicleDataList) {
|
data.setCreateTime(now);
|
|
try {
|
// 设置事件日期
|
data.setEventDate(dateTimeFormat.parse(date + " 00:00:00"));
|
} catch (Exception e) {
|
logger.error("日期格式化错误: {}", e.getMessage());
|
}
|
}
|
|
// 批量插入数据库
|
int rows = vehicleDailyDataService.insertVehicleDailyDataBatch(vehicleDataList);
|
logger.info("车辆数据同步完成，成功插入{}条记录", rows);
|
} else {
|
String errorMsg = response != null ? response.getMsg() : "获取API响应失败";
|
logger.error("获取车辆数据失败: {}", errorMsg);
|
}
|
} catch (Exception e) {
|
logger.error("车辆数据同步任务执行异常: {}", e.getMessage(), e);
|
}
|
}
|
}
|
