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.ResultCodes;
|
import com.gkhy.safePlatform.commons.exception.BusinessException;
|
import com.gkhy.safePlatform.doublePrevention.entity.PreventDangerManage;
|
import com.gkhy.safePlatform.doublePrevention.entity.dto.DataCountI1RespDO;
|
import com.gkhy.safePlatform.doublePrevention.entity.dto.DataCountI2RespDO;
|
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventDangerManageQueryReqDTO;
|
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventHandReportConfigReqDTO;
|
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventRectifyOverQueryReqDTO;
|
import com.gkhy.safePlatform.doublePrevention.repository.PreventDangerManageRepository;
|
import com.gkhy.safePlatform.doublePrevention.repository.param.*;
|
import com.gkhy.safePlatform.doublePrevention.service.baseService.PreventDangerManageService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Date;
|
import java.util.List;
|
|
@Service("PreventDangerManageService")
|
public class PreventDangerManageServiceImpl
|
extends ServiceImpl<PreventDangerManageRepository, PreventDangerManage> implements PreventDangerManageService {
|
|
@Autowired
|
private PreventDangerManageRepository preventDangerManageRepository;
|
|
/**
|
* 隐患治理清单-分页查询
|
*/
|
@Override
|
public IPage<PreventDangerManage> getDangerManagePage(Page<Object> page, PreventDangerManageQueryReqDTO manageQueryReqDTO) {
|
return preventDangerManageRepository.getDangerManagePage(page, manageQueryReqDTO);
|
}
|
/**
|
* 隐患治理清单-新增
|
*/
|
@Override
|
public int saveDangerManage(PreventDangerManage dangerManage) {
|
return preventDangerManageRepository.insert(dangerManage);
|
}
|
|
/**
|
* 隐患治理清单-修改
|
*/
|
@Override
|
public int updateDangerManage(PreventDangerManageUpdateParams updateParams) {
|
return preventDangerManageRepository.updateDangerManage(updateParams);
|
}
|
|
/**
|
* 隐患治理清单-删除
|
*/
|
@Override
|
public int deleteDangerManage(PreventDeleteParams deleteParams) {
|
return preventDangerManageRepository.deleteDangerManage(deleteParams);
|
}
|
|
/**
|
* 隐患治理清单-根据dangerCode查询
|
*/
|
@Override
|
public PreventDangerManage getDangerManageByCode(String dangerCode) {
|
return preventDangerManageRepository.getDangerManageByCode(dangerCode);
|
}
|
/**
|
* 隐患治理清单-根据id查询
|
*/
|
@Override
|
public PreventDangerManage getDangerManageById(Long dangerManagerId) {
|
return preventDangerManageRepository.getDangerManageById(dangerManagerId);
|
}
|
/**
|
* 隐患治理清单-根据taskId查询
|
*/
|
@Override
|
public PreventDangerManage getDangerManageByTaskId(Long taskId) {
|
return preventDangerManageRepository.getDangerManageByTaskId(taskId);
|
}
|
|
/**
|
* 隐患治理清单-列表
|
*/
|
@Override
|
public List<PreventDangerManage> listDangerManage() {
|
return preventDangerManageRepository.listDangerManage();
|
}
|
/**
|
* 隐患管理-手工上报-配置
|
*/
|
@Override
|
public int updateDangerManagerReport(PreventHandReportConfigReqDTO preventHandReportConfigReqDTO) {
|
return preventDangerManageRepository.updateDangerManagerReport(preventHandReportConfigReqDTO);
|
}
|
/**
|
* 隐患管理-验收
|
*/
|
@Override
|
public int updateRectifyResult(UpdateRectifyResultParams updateParams) {
|
return preventDangerManageRepository.updateRectifyResult(updateParams);
|
}
|
|
/**
|
* 隐患管理-延期状态
|
*/
|
@Override
|
public int updateManagerStatus(Long dangerManagerId, byte code) {
|
return preventDangerManageRepository.updateManagerStatus(dangerManagerId, code);
|
}
|
|
/**
|
* 隐患管理-关闭隐患单
|
*/
|
@Override
|
public int closeDanger(CloseDangerParams closeDangerParams) {
|
return preventDangerManageRepository.closeDanger(closeDangerParams);
|
}
|
/**
|
* 隐患-整改完成的
|
*/
|
@Override
|
public List<PreventDangerManage> listRectifyOver(PreventRectifyOverQueryReqDTO rectifyOverQueryReqDTO) {
|
return preventDangerManageRepository.listRectifyOver(rectifyOverQueryReqDTO);
|
}
|
|
/**
|
* 隐患-上报数据
|
*/
|
@Override
|
public List<PreventDangerManage> listReportDanger() {
|
return preventDangerManageRepository.listReportDanger();
|
}
|
/**
|
* 隐患-上报数据状态变更
|
*/
|
@Override
|
public void updateManageReportStatus(HandlerReportParam handlerReportParam) {
|
int result = preventDangerManageRepository.updateManageReportStatus(handlerReportParam);
|
if (result == 0) {
|
throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
|
}
|
}
|
|
@Override
|
public IPage<PreventDangerManage> getDangerManagePageTORectify(Page<Object> objectPage, PreventRectifyOverQueryReqDTO rectifyOverQueryReqDTO) {
|
return preventDangerManageRepository.getDangerManagePageTORectify(objectPage, rectifyOverQueryReqDTO);
|
}
|
|
@Override
|
public int countByCreateTime(Date startTime, Date endTime) {
|
if(startTime == null || endTime == null || startTime.after(endTime))
|
return 0;
|
return preventDangerManageRepository.countByCreateTime(startTime,endTime);
|
}
|
|
@Override
|
public PreventDangerManage findByDangerSerialCode(String serialCode) {
|
if(serialCode == null || serialCode.length() < 13){
|
return null;
|
}
|
return preventDangerManageRepository.findByDangerSerialCode(serialCode);
|
}
|
|
/**
|
* 统计I1
|
*/
|
@Override
|
public DataCountI1RespDO listMonthDataCountI1(DataCountIMonthParams countParams) {
|
return preventDangerManageRepository.listMonthDataCountI1(countParams);
|
}
|
/**
|
* 数据统计-隐患数据统计-I2计算 - 月
|
*/
|
@Override
|
public DataCountI2RespDO listMonthDataCountI2(DataCountIMonthParams countParams) {
|
return preventDangerManageRepository.listMonthDataCountI2(countParams);
|
}
|
}
|
