package com.gkhy.testFourierSpecialGasMonitor.service.impl;

import com.gkhy.testFourierSpecialGasMonitor.commons.domain.Result;
import com.gkhy.testFourierSpecialGasMonitor.commons.enums.ResultCode;
import com.gkhy.testFourierSpecialGasMonitor.commons.exception.BusinessException;
import com.gkhy.testFourierSpecialGasMonitor.domain.account.entity.User;
import com.gkhy.testFourierSpecialGasMonitor.domain.account.enums.UserStatusEnum;
import com.gkhy.testFourierSpecialGasMonitor.domain.account.repository.jpa.UserRepository;
import com.gkhy.testFourierSpecialGasMonitor.entity.GasCategoryConfiguration;
import com.gkhy.testFourierSpecialGasMonitor.entity.req.GasCategoryConfigurationReqDTO;
import com.gkhy.testFourierSpecialGasMonitor.repository.GasCategoryConfigurationRepository;
import com.gkhy.testFourierSpecialGasMonitor.service.GasCategoryConfigurationService;
import com.gkhy.testFourierSpecialGasMonitor.utils.ThreadLocalUtil;
import io.micrometer.core.instrument.util.StringUtils;
import org.redisson.api.RedissonClient;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;
import java.util.Optional;

@Service
public class GasCategoryConfigurationServiceImpl implements GasCategoryConfigurationService {
    @Autowired
    private UserRepository userRepository;

    @Autowired
    private RedissonClient redissonClient;

    @Autowired
    private GasCategoryConfigurationRepository gasCategoryConfigurationRepository;


    private User getCurrentUser(){
        Long userId = ThreadLocalUtil.get().getId();
        User user = userRepository.findUserByIdAndStatus(userId, UserStatusEnum.STATUS_ACTIVE.getStatus());
        if (user == null)
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(),"未成功获取用户信息");
        return user;
    }

    @Override
    public Result updateById(GasCategoryConfigurationReqDTO reqDTO) {
        if (reqDTO==null)
            throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_NULL.getCode(),"参数不能为空");

        if (reqDTO.getOrientation()==null)
            throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_NULL.getCode(),"方位不能为空");

        if (reqDTO.getConcentration()==null)
            throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_NULL.getCode(),"本底浓度不能为空");

        if (reqDTO.getMultiplication()==null)
            throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_NULL.getCode(),"倍增系数不能为空");

        GasCategoryConfiguration byOrientation = gasCategoryConfigurationRepository.findByGasCategoryIdAndOrientation(reqDTO.getGasCategoryId(), reqDTO.getOrientation());
        if (byOrientation!=null && byOrientation.getId() != reqDTO.getId())
            throw new BusinessException(this.getClass(),ResultCode.BUSINESS_ERROR.getCode(),"同一方位不能重复添加");


        User user = getCurrentUser();
        Optional<GasCategoryConfiguration> byId = gasCategoryConfigurationRepository.findById(reqDTO.getId());
        if (byId.isPresent()){
            GasCategoryConfiguration gasCategoryConfiguration = byId.get();
            BeanUtils.copyProperties(reqDTO,gasCategoryConfiguration);
            gasCategoryConfiguration.setUpdateBy(user.getRealName());
            gasCategoryConfiguration.setUpdateTime(LocalDateTime.now());
            GasCategoryConfiguration save = gasCategoryConfigurationRepository.save(gasCategoryConfiguration);
            if (save==null)
                throw new BusinessException(this.getClass(),ResultCode.SYSTEM_ERROR_DATABASE_FAIL.getCode(),"更新气体参数失败");
        }

        return Result.success();
    }

    @Override
    public Result deletedById(Integer id) {
        Optional<GasCategoryConfiguration> byId = gasCategoryConfigurationRepository.findById(id);
        if (byId.isPresent()){
            GasCategoryConfiguration gasCategoryConfiguration = byId.get();
            gasCategoryConfiguration.setDelFlag(1);
            GasCategoryConfiguration save = gasCategoryConfigurationRepository.save(gasCategoryConfiguration);
            if (save==null)
                throw new BusinessException(this.getClass(),ResultCode.SYSTEM_ERROR_DATABASE_FAIL.getCode(),"删除气体参数失败");
        }

        return Result.success();
    }

    @Override
    public Result createGasCategoryConfiguration(GasCategoryConfigurationReqDTO reqDTO) {
        if (reqDTO==null)
            throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_NULL.getCode(),"参数不能为空");
        if (reqDTO.getOrientation()==null)
            throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_NULL.getCode(),"方位不能为空");

        if (reqDTO.getConcentration()==null)
            throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_NULL.getCode(),"本底浓度不能为空");

        if (reqDTO.getMultiplication()==null)
            throw new BusinessException(this.getClass(),ResultCode.PARAM_ERROR_NULL.getCode(),"倍增系数不能为空");

        GasCategoryConfiguration byOrientation = gasCategoryConfigurationRepository.findByGasCategoryIdAndOrientation(reqDTO.getGasCategoryId(), reqDTO.getOrientation());
        if (byOrientation!=null)
            throw new BusinessException(this.getClass(),ResultCode.BUSINESS_ERROR.getCode(),"同一方位不能重复添加");

        User currentUser = getCurrentUser();
        GasCategoryConfiguration gasCategoryConfiguration = new GasCategoryConfiguration();
        BeanUtils.copyProperties(reqDTO,gasCategoryConfiguration);
        gasCategoryConfiguration.setCreateBy(currentUser.getRealName());
        gasCategoryConfiguration.setCreateTime(LocalDateTime.now());
        gasCategoryConfiguration.setUpdateTime(LocalDateTime.now());
        gasCategoryConfiguration.setUpdateBy(currentUser.getRealName());
        gasCategoryConfiguration.setDelFlag(0);
        GasCategoryConfiguration save = gasCategoryConfigurationRepository.save(gasCategoryConfiguration);
        if (save==null)
            throw new BusinessException(this.getClass(),ResultCode.SYSTEM_ERROR_DATABASE_FAIL.getCode(),"新增气体参数失败");
        return Result.success();
    }
}