| | |
| | | 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<PreventRiskDangerCheckLog> 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<Long> taskIds) {
|
| | | List<Long> ids = new ArrayList<>();
|
| | | Byte reportStatus = 1;
|
| | | Date reportTime = new Date();
|
| | | return preventRiskDangerCheckLogRepository.updateTaskReportStatusByList(taskIds, reportStatus, reportTime);
|
| | | }
|
| | | }
|
| | | 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<PreventRiskDangerCheckLog> 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<Long> taskIds) { |
| | | List<Long> ids = new ArrayList<>(); |
| | | Byte reportStatus = 1; |
| | | Date reportTime = new Date(); |
| | | return preventRiskDangerCheckLogRepository.updateTaskReportStatusByList(taskIds, reportStatus, reportTime); |
| | | } |
| | | |
| | | @Override |
| | | public List<PreventRiskDangerCheckLog> listRectifyReportTask() { |
| | | return preventRiskDangerCheckLogRepository.listRectifyReportTask(); |
| | | } |
| | | |
| | | @Override |
| | | public List<PreventRiskDangerCheckLog> listSearchRectifyReportTask() { |
| | | return preventRiskDangerCheckLogRepository.listSearchRectifyReportTask(); |
| | | } |
| | | |
| | | @Override |
| | | public int updateSearchRectifyReportTask(PreventRiskDangerCheckLog dangerCheckLog) { |
| | | return preventRiskDangerCheckLogRepository.updateSearchRectifyReportTask(dangerCheckLog); |
| | | } |
| | | } |