package com.ruoyi.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportCheckTaskFromWork; import com.ruoyi.doublePrevention.enums.E; import com.ruoyi.doublePrevention.exception.AusinessException; import com.ruoyi.doublePrevention.repository.PreventCJReportCheckTaskFromWorkRepository; import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam; import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; import com.ruoyi.doublePrevention.service.baseService.PreventCJReportCheckTaskFromWorkService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventCJReportCheckTaskFromWorkService") public class PreventCJReportCheckTaskFromWorkServiceImpl extends ServiceImpl implements PreventCJReportCheckTaskFromWorkService { @Autowired private PreventCJReportCheckTaskFromWorkRepository preventCJReportCheckTaskFromWorkRepository; // /** // * 上报数据-任务配置-分页查询 // */ // @Override // public IPage getReportTaskFromWorkPage(Page objectPage, PreventReportCheckTaskFromWorkReqDTO queryReqDTO) { // return preventCJReportCheckTaskFromWorkRepository.getReportTaskFromWorkPage(objectPage,queryReqDTO); // } /** * 插入数据 * */ @Override public int insertTaskFromWorkList(PreventCJReportCheckTaskFromWork CJTaskFromWork) { int result = preventCJReportCheckTaskFromWorkRepository.insertTaskFromWorkList(CJTaskFromWork); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "CJ保存风险单元失败"); } return result; } /** * 任务配置 -查询待上报 * */ @Override public List listReportTaskFromWorkDate() { return preventCJReportCheckTaskFromWorkRepository.listReportTaskFromWorkDate(); } /** * 任务配置 -待上报状态变更 * */ @Override public void updateWorkReportStatus(HandlerReportParam handlerReportParam) { int result = preventCJReportCheckTaskFromWorkRepository.updateWorkReportStatus(handlerReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "任务-配置 状态变更失败"); } } /** * 任务配置 -待上报状态变更 -通过id * */ @Override public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) { int result = preventCJReportCheckTaskFromWorkRepository.updateCJReportStatusById(handlerCJReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "任务-配置 状态变更失败"); } } @Override public PreventCJReportCheckTaskFromWork geByMeasureUUidAndJobId(String measureUuid, Long jobId) { return preventCJReportCheckTaskFromWorkRepository.geByMeasureUUidAndJobId(measureUuid, jobId); } @Override public List listWork() { return preventCJReportCheckTaskFromWorkRepository.listWork(); } @Override public List listWork1() { return preventCJReportCheckTaskFromWorkRepository.listWork1(); } @Override public int updateInfo1(PreventCJReportCheckTaskFromWork work) { return preventCJReportCheckTaskFromWorkRepository.updateInfo1(work); } @Override public int updateInfo(PreventCJReportCheckTaskFromWork work) { return preventCJReportCheckTaskFromWorkRepository.updateInfo(work); } }