package com.ruoyi.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportDangerInfo; import com.ruoyi.doublePrevention.enums.E; import com.ruoyi.doublePrevention.exception.AusinessException; import com.ruoyi.doublePrevention.repository.PreventCJReportDangerInfoRepository; import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam; import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; import com.ruoyi.doublePrevention.service.baseService.PreventCJReportDangerInfoService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventCJReportDangerInfoService") public class PreventCJReportDangerInfoServiceImpl extends ServiceImpl implements PreventCJReportDangerInfoService { @Autowired private PreventCJReportDangerInfoRepository preventCJReportDangerInfoRepository; /** * 插入隐患信息 * */ @Override public int insert(PreventCJReportDangerInfo danger) { return preventCJReportDangerInfoRepository.insertDangerInfo(danger); } // /** // * 上报数据-隐患信息-分页查询 // */ // @Override // public IPage getReportDangerInfoPage(Page objectPage, PreventReportDangerInfoReqDTO queryReqDTO) { // return preventCJReportDangerInfoRepository.getReportDangerInfoPage(objectPage, queryReqDTO); // } /** * 上报数据-待上报数据查询 */ @Override public List listReportDangerDate() { return preventCJReportDangerInfoRepository.listReportDangerDate(); } /** * 上报数据-待上报状态变更 */ @Override public void updateTaskReportStatus(HandlerReportParam handlerReportParam) { int result = preventCJReportDangerInfoRepository.updateTaskReportStatus(handlerReportParam); if (result < 0){ throw new AusinessException(E.UPDATE_FAIL.getCode(), "隐患信息状态变更失败"); } } /** * 上报数据-待上报状态变更-通过id */ @Override public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) { int result = preventCJReportDangerInfoRepository.updateCJReportStatusById(handlerCJReportParam); if (result < 0){ throw new AusinessException(E.UPDATE_FAIL.getCode(), "隐患信息状态变更失败"); } } @Override public List getDangerListForCheckTask() { return preventCJReportDangerInfoRepository.getDangerListForCheckTask(); } }