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.PreventRiskEvent;
import com.gkhy.safePlatform.doublePrevention.entity.dto.PreventRiskEventDO;
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventHandReportConfigReqDTO;
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventRiskEventDeleteReqDTO;
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventRiskEventQueryReqDTO;
import com.gkhy.safePlatform.doublePrevention.repository.PreventRiskEventRepository;
import com.gkhy.safePlatform.doublePrevention.repository.param.HandlerReportParam;
import com.gkhy.safePlatform.doublePrevention.repository.param.PreventDeleteParams;
import com.gkhy.safePlatform.doublePrevention.repository.param.PreventRiskEventQueryParams;
import com.gkhy.safePlatform.doublePrevention.repository.param.PreventRiskEventUpdateParams;
import com.gkhy.safePlatform.doublePrevention.service.baseService.PreventRiskEventService;
import org.apache.ibatis.annotations.Param;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service("PreventRiskEventService")
public class PreventRiskEventServiceImpl extends ServiceImpl<PreventRiskEventRepository, PreventRiskEvent> implements PreventRiskEventService {

    @Autowired
    private PreventRiskEventRepository preventRiskEventRepository;

    /**
     * 风险事件-分页查询
     */
    @Override
    public IPage<PreventRiskEvent> getRiskEventPage(Page<Object> page, @Param("queryParams")PreventRiskEventQueryParams queryParams) {
        return preventRiskEventRepository.getRiskEventPage(page, queryParams);
    }

    /**
     * 风险事件-根据事件名字查询
     */
    @Override
    public PreventRiskEvent getRiskEventByName(String riskEventName) {
        return preventRiskEventRepository.getRiskEventByName(riskEventName);
    }

    /**
     * 风险事件-新增
     */
    @Override
    public int saveRiskEvent(PreventRiskEvent riskEvent) {
        return preventRiskEventRepository.insert(riskEvent);
    }

    /**
     * 风险事件-修改
     */
    @Override
    public int updateRiskEvent(PreventRiskEventUpdateParams updateParams) {
        return preventRiskEventRepository.updateRiskEvent(updateParams);
    }

    /**
     * 风险事件-删除
     */
    @Override
    public int deleteRiskEventById(PreventDeleteParams deleteParams) {
        return preventRiskEventRepository.deleteRiskEventById(deleteParams);
    }

    /**
     * 风险事件-根据id获取名名称
     */
    @Override
    public PreventRiskEvent getRiskEventNameById(Long id) {
        return preventRiskEventRepository.getRiskEventNameById(id);
    }

    /**
     * 风险事件-根据RiskUnitId获取
     */
    @Override
    public List<PreventRiskEvent> getRiskEventNameByRiskUnitId(Long riskUnitId) {
        return preventRiskEventRepository.getRiskEventNameByRiskUnitId(riskUnitId);
    }

    /**
     * 风险事件-事件list
     */
    @Override
    public List<PreventRiskEvent> getListEvents() {
        return preventRiskEventRepository.getListEvents();
    }

    /**
     * 安全风险事件-手工上报-配置
     */
    @Override
    public int updateRiskEventReport(PreventHandReportConfigReqDTO preventHandReportConfigReqDTO) {
        return preventRiskEventRepository.updateRiskEventReport(preventHandReportConfigReqDTO);
    }



    /**
     * 安全风险事件-上报数据
     */
    @Override
    public List<PreventRiskEvent> listReportEvent() {
        return preventRiskEventRepository.listReportEvent();
    }
    /**
     * 安全风险事件-更新上报状态
     */
    @Override
    public void updateEventReportStatus(HandlerReportParam handlerReportParam) {
        int result = preventRiskEventRepository.updateEventReportStatus(handlerReportParam);
        if (result < 1){
            throw new AusinessException(E.UPDATE_FAIL, "安全风险事件-更新上报状态失败");
        }
    }
}