package com.cl.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.cl.common.constant.DelFlagConstant;
import com.cl.common.context.BaseContext;
import com.cl.common.exception.data.DataException;
import com.cl.mapper.DataMapper;
import com.cl.pojo.dto.AddDataDTO;
import com.cl.pojo.entity.DataEntity;
import com.cl.pojo.vo.DataDetailVO;
import com.cl.pojo.vo.DataRateVO;
import com.cl.pojo.vo.DataVO;
import com.cl.pojo.vo.EditDataDTO;
import com.cl.pojo.vo.screen.*;
import com.cl.service.DataService;
import io.swagger.models.auth.In;
import net.bytebuddy.asm.Advice;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import java.text.DecimalFormat;
import java.time.LocalDateTime;
import java.util.Collections;
import java.util.Date;
import java.util.List;

@Service
public class DataServiceImpl extends ServiceImpl<DataMapper, DataEntity> implements DataService {

    private final DataMapper dataMapper;

    public DataServiceImpl(DataMapper dataMapper) {
        this.dataMapper = dataMapper;
    }

    @Override
    public ScreenVO screen(Integer county,Integer year) {
        LocalDateTime createTime = LocalDateTime.of(year, 12, 31, 23, 59, 59);
        ScreenVO screenVO = new ScreenVO();
        DataEntity data =dataMapper.screen(county,createTime);
        if (null== data) {
            return screenVO;
        }
        screenVO.setAssistiveDeviceTotal(data.getAssistiveDeviceTotal());
        screenVO.setCreateTime(data.getCreateTime());
        screenVO.setTechnicalTraining(data.getTechnicalTraining());
        screenVO.setHomeAllowance(data.getHomeAllowance());
        screenVO.setEducationSubsidy(data.getEducationSubsidy());

        CertificateVO certificateVO = new CertificateVO();
        BeanUtils.copyProperties(data,certificateVO);
        screenVO.setCertificateVO(certificateVO);

        WorkerVO workerVO = new WorkerVO();
        BeanUtils.copyProperties(data,workerVO);
        screenVO.setWorkerVO(workerVO);

        DrillVO drillVO = new DrillVO();
        BeanUtils.copyProperties(data,drillVO);
        screenVO.setDrillVO(drillVO);

        SalvationVO salvationVO = new SalvationVO();
        BeanUtils.copyProperties(data,salvationVO);
        screenVO.setSalvationVO(salvationVO);

        DifficultyVO difficultyVO = new DifficultyVO();
        BeanUtils.copyProperties(data,difficultyVO);
        screenVO.setDifficultyVO(difficultyVO);

        AssistiveDeviceVO assistiveDeviceVO = new AssistiveDeviceVO();
        BeanUtils.copyProperties(data,assistiveDeviceVO);
        screenVO.setAssistiveDeviceVO(assistiveDeviceVO);

        AssistiveDeviceTypeVO assistiveDeviceTypeVO = new AssistiveDeviceTypeVO();
        BeanUtils.copyProperties(data,assistiveDeviceTypeVO);
        screenVO.setAssistiveDeviceTypeVO(assistiveDeviceTypeVO);

        AssistiveDeviceGradeVO assistiveDeviceGradeVO = new AssistiveDeviceGradeVO();
        BeanUtils.copyProperties(data,assistiveDeviceGradeVO);
        screenVO.setAssistiveDeviceGradeVO(assistiveDeviceGradeVO);

        StatutoryCertificateVO statutoryCertificateVO = new StatutoryCertificateVO();
        BeanUtils.copyProperties(data,statutoryCertificateVO);
        screenVO.setStatutoryCertificateVO(statutoryCertificateVO);

        EmployedVO employedVO = new EmployedVO();
        BeanUtils.copyProperties(data,employedVO);
        screenVO.setEmployedVO(employedVO);

        HighSchoolVO highSchoolVO = new HighSchoolVO();
        BeanUtils.copyProperties(data,highSchoolVO);
        screenVO.setHighSchoolVO(highSchoolVO);

        EducationVO educationVO = new EducationVO();
        BeanUtils.copyProperties(data,educationVO);
        screenVO.setEducationVO(educationVO);

        RightDownVO rightDownVO = new RightDownVO();
        BeanUtils.copyProperties(data,rightDownVO);
        screenVO.setRightDownVO(rightDownVO);

        return screenVO;
    }

    @Override
    public void add(AddDataDTO addDataDTO) {
        DataEntity dataEntity = new DataEntity();
        BeanUtils.copyProperties(addDataDTO,dataEntity);
        dataEntity.setCreateTime(LocalDateTime.now());
        dataEntity.setCreateBy(BaseContext.getCurrentUser().getId());
        int insert = dataMapper.insert(dataEntity);
        if (insert != 1) {
            throw new DataException("保存数据失败");
        }
    }

    @Override
    public IPage<DataVO> pageList(IPage<DataEntity> page, List<Integer> county, String name) {
        return dataMapper.pageList(page,county,name);
    }

    @Override
    public void delete(Integer id) {
        LambdaQueryWrapper<DataEntity> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(DataEntity::getId,id);
        queryWrapper.eq(DataEntity::getDelFlag, DelFlagConstant.UNDELETE);
        DataEntity dataEntity = dataMapper.selectOne(queryWrapper);
        if (dataEntity == null) {
            throw new DataException("删除数据失败，数据不存在");
        }
        dataEntity.setDelFlag(DelFlagConstant.DELETE);
        dataEntity.setUpdateTime(LocalDateTime.now());
        dataEntity.setUpdateBy(BaseContext.getCurrentUser().getId());
        int i = dataMapper.updateById(dataEntity);
        if (i != 1) {
            throw new DataException("删除失败");
        }
    }

    @Override
    public void edit(EditDataDTO editDataDTO) {
        LambdaQueryWrapper<DataEntity> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(DataEntity::getId,editDataDTO.getId());
        queryWrapper.eq(DataEntity::getDelFlag, DelFlagConstant.UNDELETE);
        DataEntity data = dataMapper.selectOne(queryWrapper);
        if (data == null) {
            throw new DataException("修改数据失败，数据id不存在");
        }
        DataEntity dataEntity = new DataEntity();
        BeanUtils.copyProperties(editDataDTO,dataEntity);
        dataEntity.setUpdateTime(LocalDateTime.now());
        dataEntity.setUpdateBy(BaseContext.getCurrentUser().getId());
        int i = dataMapper.updateById(dataEntity);
        if (i != 1) {
            throw new DataException("修改失败");
        }
    }

    @Override
    public DataDetailVO detail(Integer id) {
        LambdaQueryWrapper<DataEntity> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(DataEntity::getId,id);
        queryWrapper.eq(DataEntity::getDelFlag, DelFlagConstant.UNDELETE);
        DataEntity dataEntity = dataMapper.selectOne(queryWrapper);
        if (dataEntity == null) {
            throw new DataException("该条数据不存在");
        }
        DataDetailVO dataDetailVO = new DataDetailVO();
        //当前数据
        EditDataDTO data=new EditDataDTO();
        BeanUtils.copyProperties(dataEntity,data);
        dataDetailVO.setData(data);
        //当前数据的前一条数据
        EditDataDTO beforeData=new EditDataDTO();
        DataEntity beforeDataEntity= dataMapper.beforeOne(id);
        if (beforeDataEntity != null) {
            BeanUtils.copyProperties(beforeDataEntity,beforeData);
        }
        dataDetailVO.setBeforeData(beforeData);
        //计算比率
        DataRateVO dataRateVO = getRateVO(data,beforeData);
        dataDetailVO.setRateVO(dataRateVO);
        return dataDetailVO;
    }

    @Override
    public DataDetailVO addDetail(Integer county) {
        DataDetailVO dataDetailVO = new DataDetailVO();
        //通过区县获取上一次数据
        DataEntity dataEntity = dataMapper.getAddDetail(county);
        EditDataDTO editDataDTO=new EditDataDTO();
        BeanUtils.copyProperties(dataEntity,editDataDTO);
        dataDetailVO.setBeforeData(editDataDTO);
        return dataDetailVO;
    }

    @Override
    public List<Integer> getYearList(Integer county) {
        return dataMapper.getYearList( county);

    }

    @Override
    public Integer getAssistiveDeviceTotal(Integer county, Integer year) {
        LocalDateTime createTime = LocalDateTime.of(year, 12, 31, 23, 59, 59);
        return dataMapper.getAssistiveDeviceTotal(county,createTime);
    }

    private DataRateVO getRateVO(EditDataDTO data, EditDataDTO beforeData) {
        if (beforeData == null || beforeData.equals(new EditDataDTO())) {
            return null;
        }
        DataRateVO dataRateVO = new DataRateVO();
        //计算每个字段
        dataRateVO.setCertificateEyesight(calcRate(data.getCertificateEyesight(),beforeData.getCertificateEyesight()));
        dataRateVO.setCertificateIntellect(calcRate(data.getCertificateIntellect(),beforeData.getCertificateIntellect()));
        dataRateVO.setCertificateLimb(calcRate(data.getCertificateLimb(),beforeData.getCertificateLimb()));
        dataRateVO.setCertificateSpeech(calcRate(data.getCertificateSpeech(), beforeData.getCertificateSpeech()));
        dataRateVO.setCertificateHearing(calcRate(data.getCertificateHearing(), beforeData.getCertificateHearing()));
        dataRateVO.setCertificateSpirit(calcRate(data.getCertificateSpirit(), beforeData.getCertificateSpirit()));
        dataRateVO.setCertificateMultiple(calcRate(data.getCertificateMultiple(), beforeData.getCertificateMultiple()));
        dataRateVO.setWorkerCity(calcRate(data.getWorkerCity(), beforeData.getWorkerCity()));
        dataRateVO.setWorkerAssociation(calcRate(data.getWorkerAssociation(), beforeData.getWorkerAssociation()));
        dataRateVO.setWorkerServiceCorps(calcRate(data.getWorkerServiceCorps(), beforeData.getWorkerServiceCorps()));
        dataRateVO.setWorkerCounty(calcRate(data.getWorkerCounty(), beforeData.getWorkerCounty()));
        dataRateVO.setWorkerTownship(calcRate(data.getWorkerTownship(), beforeData.getWorkerTownship()));
        dataRateVO.setWorkerVillage(calcRate(data.getWorkerVillage(), beforeData.getWorkerVillage()));
        dataRateVO.setDrillAutism(calcRate(data.getDrillAutism(), beforeData.getDrillAutism()));
        dataRateVO.setDrillIntellect(calcRate(data.getDrillIntellect(), beforeData.getDrillIntellect()));
        dataRateVO.setDrillLimb(calcRate(data.getDrillLimb(), beforeData.getDrillLimb()));
        dataRateVO.setDrillSpeech(calcRate(data.getDrillSpeech(), beforeData.getDrillSpeech()));
        dataRateVO.setDrillHearing(calcRate(data.getDrillHearing(), beforeData.getDrillHearing()));
        dataRateVO.setDrillSpirit(calcRate(data.getDrillSpirit(), beforeData.getDrillSpirit()));
        dataRateVO.setSalvationBeforeSeven(calcRate(data.getSalvationBeforeSeven(), beforeData.getSalvationBeforeSeven()));
        dataRateVO.setSalvationAfterSeven(calcRate(data.getSalvationAfterSeven(), beforeData.getSalvationAfterSeven()));
        dataRateVO.setSalvationAutism(calcRate(data.getSalvationAutism(), beforeData.getSalvationAutism()));
        dataRateVO.setSalvationIntellect(calcRate(data.getSalvationIntellect(), beforeData.getSalvationIntellect()));
        dataRateVO.setSalvationLimb(calcRate(data.getSalvationLimb(), beforeData.getSalvationLimb()));
        dataRateVO.setSalvationSpeech(calcRate(data.getSalvationSpeech(), beforeData.getSalvationSpeech()));
        dataRateVO.setDifficultyMedication(calcRate(data.getDifficultyMedication(), beforeData.getDifficultyMedication()));
        dataRateVO.setDifficultyHospitalisation(calcRate(data.getDifficultyHospitalisation(), beforeData.getDifficultyHospitalisation()));
        dataRateVO.setAssistiveDeviceTotal(calcRate(data.getAssistiveDeviceTotal(), beforeData.getAssistiveDeviceTotal()));
        dataRateVO.setAssistiveDeviceOne(calcRate(data.getAssistiveDeviceOne(), beforeData.getAssistiveDeviceOne()));
        dataRateVO.setAssistiveDeviceTwo(calcRate(data.getAssistiveDeviceTwo(), beforeData.getAssistiveDeviceTwo()));
        dataRateVO.setAssistiveDeviceThree(calcRate(data.getAssistiveDeviceThree(), beforeData.getAssistiveDeviceThree()));
        dataRateVO.setAssistiveDeviceOther(calcRate(data.getAssistiveDeviceOther(), beforeData.getAssistiveDeviceOther()));
        dataRateVO.setAssistiveDeviceTypeOne(calcRate(data.getAssistiveDeviceTypeOne(), beforeData.getAssistiveDeviceTypeOne()));
        dataRateVO.setAssistiveDeviceTypeTwo(calcRate(data.getAssistiveDeviceTypeTwo(), beforeData.getAssistiveDeviceTypeTwo()));
        dataRateVO.setAssistiveDeviceTypeThree(calcRate(data.getAssistiveDeviceTypeThree(), beforeData.getAssistiveDeviceTypeThree()));
        dataRateVO.setAssistiveDeviceTypeFour(calcRate(data.getAssistiveDeviceTypeFour(), beforeData.getAssistiveDeviceTypeFour()));
        dataRateVO.setAssistiveDeviceGradeOne(calcRate(data.getAssistiveDeviceGradeOne(), beforeData.getAssistiveDeviceGradeOne()));
        dataRateVO.setAssistiveDeviceGradeTwo(calcRate(data.getAssistiveDeviceGradeTwo(), beforeData.getAssistiveDeviceGradeTwo()));
        dataRateVO.setAssistiveDeviceGradeThree(calcRate(data.getAssistiveDeviceGradeThree(), beforeData.getAssistiveDeviceGradeThree()));
        dataRateVO.setAssistiveDeviceGradeFour(calcRate(data.getAssistiveDeviceGradeFour(), beforeData.getAssistiveDeviceGradeFour()));
        dataRateVO.setTechnicalTraining(calcRate(data.getTechnicalTraining(), beforeData.getTechnicalTraining()));
        dataRateVO.setHomeAllowance(calcRate(data.getHomeAllowance(), beforeData.getHomeAllowance()));
        dataRateVO.setStatutoryCertificateEyesight(calcRate(data.getStatutoryCertificateEyesight(), beforeData.getStatutoryCertificateEyesight()));
        dataRateVO.setStatutoryCertificateIntellect(calcRate(data.getStatutoryCertificateIntellect(), beforeData.getStatutoryCertificateIntellect()));
        dataRateVO.setStatutoryCertificateLimb(calcRate(data.getStatutoryCertificateLimb(), beforeData.getStatutoryCertificateLimb()));
        dataRateVO.setStatutoryCertificateSpeech(calcRate(data.getStatutoryCertificateSpeech(), beforeData.getStatutoryCertificateSpeech()));
        dataRateVO.setStatutoryCertificateHearing(calcRate(data.getStatutoryCertificateHearing(), beforeData.getStatutoryCertificateHearing()));
        dataRateVO.setEmployedEmployment(calcRate(data.getEmployedEmployment(), beforeData.getEmployedEmployment()));
        dataRateVO.setEmployedConcentrated(calcRate(data.getEmployedConcentrated(), beforeData.getEmployedConcentrated()));
        dataRateVO.setEmployedPublicWelfare(calcRate(data.getEmployedPublicWelfare(), beforeData.getEmployedPublicWelfare()));
        dataRateVO.setEmployedAuxiliary(calcRate(data.getEmployedAuxiliary(), beforeData.getEmployedAuxiliary()));
        dataRateVO.setEmployedIndividual(calcRate(data.getEmployedIndividual(), beforeData.getEmployedIndividual()));
        dataRateVO.setHighSchoolEmployment(calcRate(data.getHighSchoolEmployment(), beforeData.getHighSchoolEmployment()));
        dataRateVO.setHighSchoolIndividual(calcRate(data.getHighSchoolIndividual(), beforeData.getHighSchoolIndividual()));
        dataRateVO.setHighSchoolFlexible(calcRate(data.getHighSchoolFlexible(), beforeData.getHighSchoolFlexible()));
        dataRateVO.setEducationOne(calcRate(data.getEducationOne(), beforeData.getEducationOne()));
        dataRateVO.setEducationTwo(calcRate(data.getEducationTwo(), beforeData.getEducationTwo()));
        dataRateVO.setEducationThree(calcRate(data.getEducationThree(), beforeData.getEducationThree()));
        dataRateVO.setEducationFour(calcRate(data.getEducationFour(), beforeData.getEducationFour()));
        dataRateVO.setEducationFive(calcRate(data.getEducationFive(), beforeData.getEducationFive()));
        dataRateVO.setEducationSix(calcRate(data.getEducationSix(), beforeData.getEducationSix()));
        dataRateVO.setEducationSeven(calcRate(data.getEducationSeven(), beforeData.getEducationSeven()));
        dataRateVO.setEducationEight(calcRate(data.getEducationEight(), beforeData.getEducationEight()));
        dataRateVO.setEducationNine(calcRate(data.getEducationNine(), beforeData.getEducationNine()));
        dataRateVO.setEducationSubsidy(calcRate(data.getEducationSubsidy(), beforeData.getEducationSubsidy()));
        dataRateVO.setActivityFrequency(calcRate(data.getActivityFrequency(), beforeData.getActivityFrequency()));
        dataRateVO.setEducationNumber(calcRate(data.getEducationNumber(), beforeData.getEducationNumber()));
        dataRateVO.setMatter(calcRate(data.getMatter(), beforeData.getMatter()));
        dataRateVO.setDoctorApprecitation(calcRate(data.getDoctorApprecitation(), beforeData.getDoctorApprecitation()));
        dataRateVO.setRemould(calcRate(data.getRemould(), beforeData.getRemould()));
        dataRateVO.setInterviewsOffice(calcRate(data.getInterviewsOffice(), beforeData.getInterviewsOffice()));
        dataRateVO.setInterviewsPhone(calcRate(data.getInterviewsPhone(), beforeData.getInterviewsPhone()));
        dataRateVO.setInterviewsSuperior(calcRate(data.getInterviewsSuperior(), beforeData.getInterviewsSuperior()));
        dataRateVO.setInterviewsHotline(calcRate(data.getInterviewsHotline(), beforeData.getInterviewsHotline()));
        return dataRateVO;
    }

    private String calcRate(Integer currentValue, Integer previousValue) {
        //去年的数据为0的情况
        if (previousValue == 0){
            return currentValue == 0 ? "同比持平" : "无同比数据";
        }
        // 计算变化率
        double changeRate = (currentValue - previousValue) * 100.0 / previousValue;
        // 格式化输出（保留两位小数，带正负号）
        DecimalFormat df = new DecimalFormat("0.00");
        String absoluteValue = df.format(Math.abs(changeRate));
        if (changeRate > 0) {
            return "同比增加" + absoluteValue + "%";
        } else if (changeRate < 0) {
            return "同比减少" + absoluteValue + "%";
        } else {
            return "同比持平";
        }

    }

}