package com.ruoyi.doublePrevention.service.baseService.impl; import com.ruoyi.doublePrevention.entity.PreventRiskDangerCheckLog; import com.ruoyi.doublePrevention.enums.E; import com.ruoyi.doublePrevention.exception.AusinessException; import com.ruoyi.doublePrevention.repository.PreventRiskDangerCheckLogRepository; import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; import com.ruoyi.doublePrevention.service.baseService.PreventRiskDangerCheckLogService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.Date; import java.util.List; @Service("PreventRiskDangerCheckLogService") public class PreventRiskDangerCheckLogServiceImpl implements PreventRiskDangerCheckLogService { @Autowired private PreventRiskDangerCheckLogRepository preventRiskDangerCheckLogRepository; /** * 定时生成排查任务记录时, * 插入排查记录附属表 */ @Override public int insertDangerCheckLog(PreventRiskDangerCheckLog dangerCheck) { return preventRiskDangerCheckLogRepository.insertDangerCheckLog(dangerCheck); } /** * 删除定时核查任务 * */ @Override public int deleteDangerCheck(Long checkId) { return preventRiskDangerCheckLogRepository.deleteDangerCheck(checkId); } /** * 检索需要上报的任务记录 * */ @Override public List listReportTask() { return preventRiskDangerCheckLogRepository.listReportTask(); } /** * 修改上报的数据状态 * */ @Override public int updateTaskReportStatus(HandlerReportParam handlerReportParam) { int result = preventRiskDangerCheckLogRepository.updateEventReportStatus(handlerReportParam); if (result < 1){ throw new AusinessException(E.UPDATE_FAIL.getCode(), "安全风险事件-更新上报状态失败"); } return result; } /** * 查询by checkId * */ @Override public PreventRiskDangerCheckLog getByDangerCheckByCheckId(Long checkId) { return preventRiskDangerCheckLogRepository.getByDangerCheckByCheckId(checkId); } @Override public PreventRiskDangerCheckLog getByDangerCheckByJobId(Long jobId) { return preventRiskDangerCheckLogRepository.getByDangerCheckByJobId(jobId); } @Override public int updateCheckLog(Long checkId, Long mobileCode) { return preventRiskDangerCheckLogRepository.updateCheckLog(checkId, mobileCode); } @Override public int updateTaskReportStatusByList(List taskIds) { List ids = new ArrayList<>(); Byte reportStatus = 1; Date reportTime = new Date(); return preventRiskDangerCheckLogRepository.updateTaskReportStatusByList(taskIds, reportStatus, reportTime); } @Override public List listRectifyReportTask() { return preventRiskDangerCheckLogRepository.listRectifyReportTask(); } @Override public List listSearchRectifyReportTask() { return preventRiskDangerCheckLogRepository.listSearchRectifyReportTask(); } @Override public int updateSearchRectifyReportTask(PreventRiskDangerCheckLog dangerCheckLog) { return preventRiskDangerCheckLogRepository.updateSearchRectifyReportTask(dangerCheckLog); } }