package com.gkhy.safePlatform.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gkhy.safePlatform.commons.enums.E; import com.gkhy.safePlatform.commons.exception.AusinessException; import com.gkhy.safePlatform.doublePrevention.entity.CJReport.PreventCJReportRiskAnaUnit; import com.gkhy.safePlatform.doublePrevention.entity.PreventReportRiskAnaUnit; import com.gkhy.safePlatform.doublePrevention.entity.dto.report.req.PreReportRiskUnitQueryReqDTO; import com.gkhy.safePlatform.doublePrevention.repository.PreventCJReportRiskAnaUnitRepository; import com.gkhy.safePlatform.doublePrevention.repository.PreventReportRiskAnaUnitRepository; import com.gkhy.safePlatform.doublePrevention.repository.param.HandlerCJReportParam; import com.gkhy.safePlatform.doublePrevention.repository.param.HandlerReportParam; import com.gkhy.safePlatform.doublePrevention.service.baseService.PreventCJReportRiskAnaUnitService; import com.gkhy.safePlatform.doublePrevention.service.baseService.PreventReportRiskAnaUnitService; 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.insert(unit); if (result < 1){ throw new AusinessException(E.ADD_FAIL, "保存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, "CJ保存风险单元失败"); } } /** * 上报数据-修改待上报-通过id */ @Override public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) { int result = preventCJReportRiskAnaUnitRepository.updateCJReportStatusById(handlerCJReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL, "CJ保存风险单元失败"); } } }