package com.ruoyi.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportRiskEvent; import com.ruoyi.doublePrevention.entity.ZDReport.HandlerZDReportParam; import com.ruoyi.doublePrevention.enums.E; import com.ruoyi.doublePrevention.exception.AusinessException; import com.ruoyi.doublePrevention.repository.PreventCJReportRiskEventRepository; import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam; import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; import com.ruoyi.doublePrevention.service.baseService.PreventCJReportRiskEventService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventCJReportRiskEventService") public class PreventCJReportRiskEventServiceImpl extends ServiceImpl implements PreventCJReportRiskEventService { @Autowired private PreventCJReportRiskEventRepository preventCJReportRiskEventRepository; // /** // * 分页查询 // * */ // @Override // public IPage getReportRiskEventPage(Page objectPage, PreReportRiskEventQueryReqDTO queryReqDTO) { // return preventCJReportRiskEventRepository.getReportRiskEventPage(objectPage, queryReqDTO); // } /** * 插入 * */ @Override public int insertEventLists(PreventCJReportRiskEvent event) { int result = preventCJReportRiskEventRepository.insertEventLists(event); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "保存CJ风险单元失败"); } return result; } /** * 上报数据-查询待上报数据 * */ @Override public List listReportEventDate() { return preventCJReportRiskEventRepository.listReportEventDate(); } @Override public List listReportEventDateHuaiDong() { return preventCJReportRiskEventRepository.listReportEventDateHuaiDong(); } @Override public int updateEventReportStatusHuaiDong(HandlerZDReportParam handlerReportParam) { int result = preventCJReportRiskEventRepository.updateEventReportStatusHuaiDong(handlerReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败"); } return result; } /** * 修改上报状态 * */ @Override public int updateEventReportStatus(HandlerReportParam handlerReportParam) { int result = preventCJReportRiskEventRepository.updateEventReportStatus(handlerReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败"); } return result; } /** * 修改上报状态-通过id * */ @Override public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) { int result = preventCJReportRiskEventRepository.updateCJReportStatusById(handlerCJReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "修改上报-事件状态失败"); } } }