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.enums.ResultCodes;
import com.gkhy.safePlatform.commons.exception.AusinessException;
import com.gkhy.safePlatform.commons.exception.BusinessException;
import com.gkhy.safePlatform.commons.utils.idService.BusinessCodeEnum;
import com.gkhy.safePlatform.doublePrevention.entity.PreventDangerCheckTaskUnit;
import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventDangerCheckTaskUnitQueryReqDTO;
import com.gkhy.safePlatform.doublePrevention.repository.PreventDangerCheckTaskUnitRepository;
import com.gkhy.safePlatform.doublePrevention.repository.param.PreventDangerCheckTaskUnitDeleteParams;
import com.gkhy.safePlatform.doublePrevention.repository.param.PreventDangerCheckTaskUnitUpdateParams;
import com.gkhy.safePlatform.doublePrevention.service.baseService.PreventDangerCheckTaskUnitService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service("PreventDangerCheckTaskUnitService")
public class PreventDangerCheckTaskUnitServiceImpl
        extends ServiceImpl<PreventDangerCheckTaskUnitRepository, PreventDangerCheckTaskUnit> implements PreventDangerCheckTaskUnitService {

    @Autowired
    private PreventDangerCheckTaskUnitRepository preventDangerCheckTaskUnitRepository;

    /**
     * 隐患排查任务单元-分页查询
     */
    @Override
    public IPage<PreventDangerCheckTaskUnit> getTaskUnitPage(Page<Object> page, PreventDangerCheckTaskUnitQueryReqDTO taskUnitQueryReqDTO) {

        return preventDangerCheckTaskUnitRepository.getTaskUnitPage(page, taskUnitQueryReqDTO);
    }

    /**
     * 隐患排查任务单元-通过名称查询单元信息
     */
    @Override
    public PreventDangerCheckTaskUnit getTaskUnitByName(String taskUnitName) {
        return preventDangerCheckTaskUnitRepository.getTaskUnitByName(taskUnitName);
    }

    /**
     * 隐患排查任务单元-新增
     */
    @Override
    public int saveTaskUnit(PreventDangerCheckTaskUnit taskUnit) {
        int insertResult = preventDangerCheckTaskUnitRepository.insert(taskUnit);
        if (insertResult == 0){
            throw new BusinessException(ResultCodes.SERVER_ADD_ERROR);
        }
        return insertResult;
    }

    /**
     * 隐患排查任务单元-修改
     */
    @Override
    public int updateTaskUnit(PreventDangerCheckTaskUnitUpdateParams updateParams) {
        int i = preventDangerCheckTaskUnitRepository.updateTaskUnit(updateParams);
        if (i == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
        return i;
    }
    /**
     * 隐患排查任务单元-删除
     */
    @Override
    public int deleteTaskUnit(PreventDangerCheckTaskUnitDeleteParams deleteParams) {
        int i = preventDangerCheckTaskUnitRepository.deleteTaskUnit(deleteParams);
        if (i == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
        return i;
    }

    /**
     * 隐患排查任务单元-
     * 根据名称修改关联作业id
     */
    @Override
    public PreventDangerCheckTaskUnit updateWorkIdByUnitName(String taskUnitName, Long checkWorkId) {

        return preventDangerCheckTaskUnitRepository.updateWorkIdByUnitName(taskUnitName, checkWorkId);
    }

    /**
     * 隐患排查任务单元-
     * 根据workId 查询
     */
    @Override
    public PreventDangerCheckTaskUnit getTaskUnitByWorkId(Long workId) {
        return preventDangerCheckTaskUnitRepository.getTaskUnitByWorkId(workId);
    }

    /**
     * 隐患排查任务单元-重置关联任务单元workId
     * 根据taskUnitName
     */
    @Override
    public void deleteWorkIdByUnitName(String taskUnitName) {
        int result = preventDangerCheckTaskUnitRepository.deleteWorkIdByUnitName(taskUnitName);
        if (result == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
    }

    /**
     * 隐患排查任务单元-根据Id查询
     */
    @Override
    public PreventDangerCheckTaskUnit getTaskUnitById(Long id) {
        return preventDangerCheckTaskUnitRepository.getTaskUnitById(id);
    }

    /**
     * 隐患排查任务单元-
     * 根据unitId 修改 workId
     */
    @Override
    public void updateWorkIdByUnitId(Long taskUnitId, Long checkWorkId , String checkWorkUuid) {
        preventDangerCheckTaskUnitRepository.updateWorkIdByUnitId(taskUnitId, checkWorkId ,checkWorkUuid);
    }

    /**
     * 隐患作业id,重置与任务单元的关联
     */
    @Override
    public void deleteByWorkId(Long workId) {
        int result = preventDangerCheckTaskUnitRepository.deleteByWorkId(workId);
        if (result == 0) {
            throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR);
        }
    }
    /**
     * 隐患排查任务单元-任务单元列表
     */
    @Override
    public List<PreventDangerCheckTaskUnit> listTaskUnit() {
        return preventDangerCheckTaskUnitRepository.listTaskUnit();
    }
}