package com.ruoyi.system.service.impl;
|
|
import java.math.BigDecimal;
|
import java.util.Date;
|
import java.util.List;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.ruoyi.system.mapper.VehicleAbnormalAlertMapper;
|
import com.ruoyi.system.domain.VehicleAbnormalAlert;
|
import com.ruoyi.system.service.IVehicleAbnormalAlertService;
|
|
/**
|
* 车辆异常告警Service业务层处理
|
*
|
* @author ruoyi
|
*/
|
@Service
|
public class VehicleAbnormalAlertServiceImpl implements IVehicleAbnormalAlertService {
|
|
@Autowired
|
private VehicleAbnormalAlertMapper vehicleAbnormalAlertMapper;
|
|
/**
|
* 查询车辆异常告警
|
*
|
* @param alertId 车辆异常告警主键
|
* @return 车辆异常告警
|
*/
|
@Override
|
public VehicleAbnormalAlert selectVehicleAbnormalAlertByAlertId(Long alertId) {
|
return vehicleAbnormalAlertMapper.selectVehicleAbnormalAlertByAlertId(alertId);
|
}
|
|
/**
|
* 查询车辆异常告警列表
|
*
|
* @param vehicleAbnormalAlert 车辆异常告警
|
* @return 车辆异常告警
|
*/
|
@Override
|
public List<VehicleAbnormalAlert> selectVehicleAbnormalAlertList(VehicleAbnormalAlert vehicleAbnormalAlert) {
|
return vehicleAbnormalAlertMapper.selectVehicleAbnormalAlertList(vehicleAbnormalAlert);
|
}
|
|
/**
|
* 新增车辆异常告警
|
*
|
* @param vehicleAbnormalAlert 车辆异常告警
|
* @return 结果
|
*/
|
@Override
|
public int insertVehicleAbnormalAlert(VehicleAbnormalAlert vehicleAbnormalAlert) {
|
vehicleAbnormalAlert.setCreateTime(DateUtils.getNowDate());
|
return vehicleAbnormalAlertMapper.insertVehicleAbnormalAlert(vehicleAbnormalAlert);
|
}
|
|
/**
|
* 修改车辆异常告警
|
*
|
* @param vehicleAbnormalAlert 车辆异常告警
|
* @return 结果
|
*/
|
@Override
|
public int updateVehicleAbnormalAlert(VehicleAbnormalAlert vehicleAbnormalAlert) {
|
vehicleAbnormalAlert.setUpdateTime(DateUtils.getNowDate());
|
return vehicleAbnormalAlertMapper.updateVehicleAbnormalAlert(vehicleAbnormalAlert);
|
}
|
|
/**
|
* 批量删除车辆异常告警
|
*
|
* @param alertIds 需要删除的车辆异常告警主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteVehicleAbnormalAlertByAlertIds(Long[] alertIds) {
|
return vehicleAbnormalAlertMapper.deleteVehicleAbnormalAlertByAlertIds(alertIds);
|
}
|
|
/**
|
* 删除车辆异常告警信息
|
*
|
* @param alertId 车辆异常告警主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteVehicleAbnormalAlertByAlertId(Long alertId) {
|
return vehicleAbnormalAlertMapper.deleteVehicleAbnormalAlertByAlertId(alertId);
|
}
|
|
/**
|
* 处理告警
|
*
|
* @param alertId 告警ID
|
* @param handlerId 处理人ID
|
* @param handlerName 处理人姓名
|
* @param handleRemark 处理备注
|
* @return 结果
|
*/
|
@Override
|
public int handleAlert(Long alertId, Long handlerId, String handlerName, String handleRemark) {
|
VehicleAbnormalAlert alert = new VehicleAbnormalAlert();
|
alert.setAlertId(alertId);
|
alert.setStatus("1"); // 已处理
|
alert.setHandlerId(handlerId);
|
alert.setHandlerName(handlerName);
|
alert.setHandleTime(new Date());
|
alert.setHandleRemark(handleRemark);
|
|
return updateVehicleAbnormalAlert(alert);
|
}
|
|
/**
|
* 批量处理告警
|
*
|
* @param alertIds 告警ID列表
|
* @param handlerId 处理人ID
|
* @param handlerName 处理人姓名
|
* @param handleRemark 处理备注
|
* @return 结果
|
*/
|
@Override
|
public int batchHandleAlert(Long[] alertIds, Long handlerId, String handlerName, String handleRemark) {
|
return vehicleAbnormalAlertMapper.batchHandleAlert(alertIds, handlerId, handlerName, handleRemark);
|
}
|
|
/**
|
* 检查并创建车辆异常告警
|
*
|
* @param vehicleId 车辆ID
|
* @param vehicleNo 车牌号
|
* @param mileage 运行公里数
|
* @param startTime 开始时间
|
* @param endTime 结束时间
|
* @param deptId 部门ID
|
* @param deptName 部门名称
|
* @return 是否创建成功
|
*/
|
@Override
|
public boolean checkAndCreateAlert(Long vehicleId, String vehicleNo, BigDecimal mileage,
|
Date startTime, Date endTime, Long deptId, String deptName) {
|
try {
|
// 获取当日告警次数
|
Date today = DateUtils.parseDate(DateUtils.getDate());
|
int todayCount = vehicleAbnormalAlertMapper.selectDailyAlertCount(vehicleId, today);
|
|
// 创建告警记录
|
VehicleAbnormalAlert alert = new VehicleAbnormalAlert();
|
alert.setVehicleId(vehicleId);
|
alert.setVehicleNo(vehicleNo);
|
alert.setAlertDate(today);
|
alert.setAlertTime(new Date());
|
alert.setMileage(mileage);
|
alert.setAlertType("NO_TASK_MILEAGE");
|
alert.setAlertReason(String.format("车辆在无任务状态下运行了 %.2f 公里", mileage));
|
alert.setStartTime(startTime);
|
alert.setEndTime(endTime);
|
alert.setAlertCount(todayCount + 1);
|
alert.setStatus("0"); // 未处理
|
alert.setNotifyStatus("0"); // 未发送
|
alert.setDeptId(deptId);
|
alert.setDeptName(deptName);
|
|
int result = insertVehicleAbnormalAlert(alert);
|
return result > 0;
|
|
} catch (Exception e) {
|
throw new RuntimeException("创建告警记录失败: " + e.getMessage(), e);
|
}
|
}
|
}
|
