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);
    }
}