package com.zhitan.spikesandvalleys.service.impl;

import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import java.util.Arrays;
import java.util.List;
import java.util.UUID;
import java.util.stream.Collectors;

import com.zhitan.alarm.domain.LimitType;
import com.zhitan.common.utils.DateUtils;
import com.zhitan.common.utils.StringUtils;
import com.zhitan.spikesandvalleys.domain.SpikesAndValleysItem;
import com.zhitan.spikesandvalleys.domain.SpikesAndValleysScheme;
import com.zhitan.spikesandvalleys.domain.vo.SpikesAndValleysSchemeVo;
import com.zhitan.spikesandvalleys.mapper.SpikesAndValleysItemMapper;
import com.zhitan.spikesandvalleys.mapper.SpikesAndValleysSchemeMapper;
import com.zhitan.spikesandvalleys.service.ISpikesAndValleysSchemeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;


/**
 * 尖峰平谷时间段明细Service业务层处理
 *
 * @author ZhiTan
 * @date 2024-10-29
 */
@Service
public class SpikesAndValleysSchemeServiceImpl extends ServiceImpl<SpikesAndValleysSchemeMapper, SpikesAndValleysScheme> implements ISpikesAndValleysSchemeService {
    @Autowired
    private SpikesAndValleysSchemeMapper spikesAndValleysSchemeMapper;
    @Autowired
    private SpikesAndValleysItemMapper spikesAndValleysItemMapper;
    /**
     * 查询尖峰平谷时间段明细
     *
     * @param id 尖峰平谷时间段明细主键
     * @return 尖峰平谷时间段明细
     */
    @Override
    public SpikesAndValleysSchemeVo selectSpikesAndValleysSchemeById(String id) {
        SpikesAndValleysSchemeVo result = new SpikesAndValleysSchemeVo();
        SpikesAndValleysScheme info = spikesAndValleysSchemeMapper.selectSpikesAndValleysSchemeById(id);
        BeanUtil.copyProperties(info,result);
        LambdaQueryWrapper<SpikesAndValleysItem> queryWrapperItem = new LambdaQueryWrapper<>();
        queryWrapperItem.eq(SpikesAndValleysItem::getSchemeId,id);
        List<SpikesAndValleysItem> itemListOld = spikesAndValleysItemMapper.selectList(queryWrapperItem);
        result.setItemList(itemListOld);
        return result ;
    }

    /**
     * 查询尖峰平谷时间段明细列表
     *
     * @param spikesAndValleysScheme 尖峰平谷时间段明细
     * @return 尖峰平谷时间段明细
     */
    @Override
    public Page<SpikesAndValleysSchemeVo>  selectSpikesAndValleysSchemeList(SpikesAndValleysScheme spikesAndValleysScheme,Long pageNum, Long pageSize) {

        LambdaQueryWrapper<SpikesAndValleysScheme> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.like(StringUtils.isNotEmpty(spikesAndValleysScheme.getSchemeName()),SpikesAndValleysScheme::getSchemeName,spikesAndValleysScheme.getSchemeName());
        queryWrapper.eq(StringUtils.isNotEmpty(spikesAndValleysScheme.getType()),SpikesAndValleysScheme::getType,spikesAndValleysScheme.getType());
        queryWrapper.orderByDesc(SpikesAndValleysScheme::getCreateTime);
        Page<SpikesAndValleysScheme> page = spikesAndValleysSchemeMapper.selectPage(new Page<>(pageNum,pageSize),queryWrapper);
            IPage aa =  page.convert(s->{
            SpikesAndValleysSchemeVo v = new SpikesAndValleysSchemeVo();
            BeanUtil.copyProperties(s, v);
                LambdaQueryWrapper<SpikesAndValleysItem> queryWrapperItem = new LambdaQueryWrapper<>();
                queryWrapperItem.eq(SpikesAndValleysItem::getSchemeId,s.getId());
                List<SpikesAndValleysItem> itemListOld = spikesAndValleysItemMapper.selectList(queryWrapperItem);
                v.setItemList(itemListOld);
            return v;
        });

    return (Page<SpikesAndValleysSchemeVo>) aa;
    }

    /**
     * 新增尖峰平谷时间段明细
     *
     * @param spikesAndValleysSchemeVo 尖峰平谷时间段明细
     * @return 结果
     */
    @Override
    @Transactional
    public int insertSpikesAndValleysScheme(SpikesAndValleysSchemeVo spikesAndValleysSchemeVo) {
        spikesAndValleysSchemeVo.setCreateTime(DateUtils.getNowDate());
        spikesAndValleysSchemeVo.setId(UUID.randomUUID().toString());
        SpikesAndValleysScheme spikesAndValleysScheme = new SpikesAndValleysScheme();
        BeanUtil.copyProperties(spikesAndValleysSchemeVo,spikesAndValleysScheme);
       int result =  spikesAndValleysSchemeMapper.insert(spikesAndValleysScheme);
        //插入子表
        List<SpikesAndValleysItem> itemList =  spikesAndValleysSchemeVo.getItemList();
        itemList.stream().forEach(s->{
            s.setId(UUID.randomUUID().toString());
            s.setCreateTime(DateUtils.getNowDate());
            s.setCreateBy(spikesAndValleysSchemeVo.getCreateBy());
            s.setSchemeId(spikesAndValleysScheme.getId());
            spikesAndValleysItemMapper.insert(s);
        });

        return result;
    }

    /**
     * 修改尖峰平谷时间段明细
     *
     * @param spikesAndValleysSchemeVo 尖峰平谷时间段明细
     * @return 结果
     */
    @Override
    @Transactional
    public int updateSpikesAndValleysScheme(SpikesAndValleysSchemeVo spikesAndValleysSchemeVo) {
        spikesAndValleysSchemeVo.setUpdateTime(DateUtils.getNowDate());
        SpikesAndValleysScheme spikesAndValleysScheme = new SpikesAndValleysScheme();
        BeanUtil.copyProperties(spikesAndValleysSchemeVo,spikesAndValleysScheme);
        int result = spikesAndValleysSchemeMapper.updateSpikesAndValleysScheme(spikesAndValleysScheme);
        //删除子表
        LambdaQueryWrapper<SpikesAndValleysItem> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(SpikesAndValleysItem::getSchemeId,spikesAndValleysScheme.getId());
        List<SpikesAndValleysItem> itemListOld = spikesAndValleysItemMapper.selectList(queryWrapper);
        List<String>idList = itemListOld.stream().map(s->s.getId()).collect(Collectors.toList());
        String[] ids = idList.toArray(new String[idList.size()]);
        spikesAndValleysItemMapper.deleteSpikesAndValleysItemByIds(ids);
        //插入子表
        List<SpikesAndValleysItem> itemList =  spikesAndValleysSchemeVo.getItemList();
        itemList.stream().forEach(s->{
            s.setId(UUID.randomUUID().toString());
            s.setCreateTime(DateUtils.getNowDate());
            s.setCreateBy(spikesAndValleysSchemeVo.getCreateBy());
            s.setSchemeId(spikesAndValleysScheme.getId());
            spikesAndValleysItemMapper.insert(s);
        });
        return result;
    }

    /**
     * 批量删除尖峰平谷时间段明细
     *
     * @param ids 需要删除的尖峰平谷时间段明细主键
     * @return 结果
     */
    @Override
    public int deleteSpikesAndValleysSchemeByIds(String[] ids) {
        //删除子表
        List<String> list = Arrays.asList(ids);
        list.stream().forEach(item->{
            LambdaQueryWrapper<SpikesAndValleysItem> queryWrapper = new LambdaQueryWrapper<>();
            queryWrapper.eq(SpikesAndValleysItem::getSchemeId,item);
            List<SpikesAndValleysItem> itemListOld = spikesAndValleysItemMapper.selectList(queryWrapper);
            List<String>idList = itemListOld.stream().map(s->s.getId()).collect(Collectors.toList());
            String[] itemIds = idList.toArray(new String[idList.size()]);
            spikesAndValleysItemMapper.deleteSpikesAndValleysItemByIds(itemIds);
        });

        return spikesAndValleysSchemeMapper.deleteSpikesAndValleysSchemeByIds(ids);
    }

    /**
     * 删除尖峰平谷时间段明细信息
     *
     * @param id 尖峰平谷时间段明细主键
     * @return 结果
     */
    @Override
    public int deleteSpikesAndValleysSchemeById(String id) {
        return spikesAndValleysSchemeMapper.deleteSpikesAndValleysSchemeById(id);
    }
}