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.PreventReportCheckTaskFromWork; import com.gkhy.safePlatform.doublePrevention.entity.dto.report.req.PreventReportCheckTaskFromWorkReqDTO; import com.gkhy.safePlatform.doublePrevention.repository.PreventReportCheckTaskFromWorkRepository; import com.gkhy.safePlatform.doublePrevention.repository.param.HandlerReportParam; import com.gkhy.safePlatform.doublePrevention.service.baseService.PreventReportCheckTaskFromWorkService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventReportCheckTaskFromWorkService") public class PreventReportCheckTaskFromWorkServiceImpl extends ServiceImpl implements PreventReportCheckTaskFromWorkService { @Autowired private PreventReportCheckTaskFromWorkRepository preventReportCheckTaskFromWorkRepository; // /** // * 批量插入数据 // * */ // @Override // public int insert(List taskFromWorkLists) { // return preventReportCheckTaskFromWorkRepository.insertList(taskFromWorkLists); // } /** * 上报数据-任务配置-分页查询 */ @Override public IPage getReportTaskFromWorkPage(Page objectPage, PreventReportCheckTaskFromWorkReqDTO queryReqDTO) { return preventReportCheckTaskFromWorkRepository.getReportTaskFromWorkPage(objectPage,queryReqDTO); } /** * 插入数据 * */ @Override public int insertTaskFromWorkList(PreventReportCheckTaskFromWork taskFromWork) { int result = preventReportCheckTaskFromWorkRepository.insert(taskFromWork); if (result < 1){ throw new AusinessException(E.ADD_FAIL, "保存风险单元失败"); } return result; } /** * 任务配置 -查询待上报 * */ @Override public List listReportTaskFromWorkDate() { return preventReportCheckTaskFromWorkRepository.listReportTaskFromWorkDate(); } /** * 任务配置 -待上报状态变更 * */ @Override public void updateWorkReportStatus(HandlerReportParam handlerReportParam) { int result = preventReportCheckTaskFromWorkRepository.updateWorkReportStatus(handlerReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL, "任务-配置 状态变更失败"); } } }