package com.ruoyi.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportRiskAnaUnit; import com.ruoyi.doublePrevention.enums.E; import com.ruoyi.doublePrevention.exception.AusinessException; import com.ruoyi.doublePrevention.repository.PreventCJReportRiskAnaUnitRepository; import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam; import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; import com.ruoyi.doublePrevention.service.baseService.PreventCJReportRiskAnaUnitService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventCJReportRiskAnaUnitService") public class PreventCJReportRiskAnaUnitServiceImpl extends ServiceImpl implements PreventCJReportRiskAnaUnitService { @Autowired private PreventCJReportRiskAnaUnitRepository preventCJReportRiskAnaUnitRepository; // /** // * 上报数据-风险分析单元-分页查询 // */ // @Override // public IPage getReportRiskUnitPage(Page page, PreReportRiskUnitQueryReqDTO queryReqDTO) { // return preventCJReportRiskAnaUnitRepository.getReportRiskUnitPage(page, queryReqDTO); // } /** * 上报数据-插入 */ @Override public int insertUnitList(PreventCJReportRiskAnaUnit unit) { int result = preventCJReportRiskAnaUnitRepository.insertUnitList(unit); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "保存CJ风险单元失败"); } return result; } /** * 上报数据-查询待上报数据 */ @Override public List listReportUnitDate() { return preventCJReportRiskAnaUnitRepository.listReportUnitDate(); } /** * 上报数据-修改待上报 */ @Override public void updateReportStatus(HandlerReportParam handlerReportParam) { int result = preventCJReportRiskAnaUnitRepository.updateReportStatus(); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败"); } } /** * 上报数据-修改待上报-通过id */ @Override public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) { int result = preventCJReportRiskAnaUnitRepository.updateCJReportStatusById(handlerCJReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败"); } } }