package com.ruoyi.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportCheckRecordFromTask; import com.ruoyi.doublePrevention.entity.ZDReport.HandlerZDReportParam; import com.ruoyi.doublePrevention.enums.E; import com.ruoyi.doublePrevention.exception.AusinessException; import com.ruoyi.doublePrevention.repository.PreventCJReportCheckRecordFromTaskRepository; import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam; import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; import com.ruoyi.doublePrevention.service.baseService.PreventCJReportCheckRecordFromTaskService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventCJReportCheckRecordFromTaskService") public class PreventCJReportCheckRecordFromTaskServiceImpl extends ServiceImpl implements PreventCJReportCheckRecordFromTaskService { @Autowired private PreventCJReportCheckRecordFromTaskRepository preventCJReportCheckRecordFromTaskRepository; /** * 批量插入任务记录 * */ @Override public int insert(PreventCJReportCheckRecordFromTask recordFromTasks) { return preventCJReportCheckRecordFromTaskRepository.insertRecord(recordFromTasks); } @Override public int insertRecordList(List recordFromTaskList) { return preventCJReportCheckRecordFromTaskRepository.insertRecordList(recordFromTaskList); } // /** // * 任务记录-分页查询 // * */ // @Override // public IPage getReportTaskFromWorkPage(Page objectPage, PreventReportCheckRecordFromTaskReqDTO queryReqDTO) { // return preventCJReportCheckRecordFromTaskRepository.getReportTaskFromWorkPage(objectPage, queryReqDTO); // } /** * 任务-查询待上报 * */ @Override public List listReportTaskRecordDate() { return preventCJReportCheckRecordFromTaskRepository.listReportTaskRecordDate(); } /** * 任务-待上报状态变更 * */ @Override public void updateTaskReportStatus(HandlerReportParam handlerReportParam) { int result = preventCJReportCheckRecordFromTaskRepository.updateTaskReportStatus(handlerReportParam); if (result < 1){ throw new AusinessException(E.UPDATE_FAIL.getCode(), "修改任务配置数据上报状态失败"); } } /** * 任务-待上报状态变更 - 通过id * */ @Override public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) { int result = preventCJReportCheckRecordFromTaskRepository.updateCJReportStatusById(handlerCJReportParam); if (result < 1){ throw new AusinessException(E.UPDATE_FAIL.getCode(), "修改任务配置数据上报状态失败"); } } @Override public void updateCJReportStatusBatchById(List cjRecordFromTasks) { int result = preventCJReportCheckRecordFromTaskRepository.updateCJReportStatusBatchById(cjRecordFromTasks); if (result < 1){ throw new AusinessException(E.UPDATE_FAIL.getCode(), "修改任务配置数据上报状态失败"); } } @Override public List listReportTaskRecordDateHuaiDong() { return preventCJReportCheckRecordFromTaskRepository.listReportTaskRecordDateHuaiDong(); } @Override public int updateHDReportStatusById(HandlerZDReportParam handlerZDReportParam) { int result = preventCJReportCheckRecordFromTaskRepository.updateHDReportStatusById(handlerZDReportParam); if (result < 1){ throw new AusinessException(E.UPDATE_FAIL.getCode(), "修改任务配置数据上报状态失败"); } return result; } }