package com.doumee.service.business.impl;

import com.doumee.config.listener.event.IntegralEvent;
import com.doumee.core.model.LoginUserInfo;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.SharesMapper;
import com.doumee.dao.business.model.Shares;
import com.doumee.service.business.SharesService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.Objects;

/**
 * 用户分享信息表Service实现
 * @author 江蹄蹄
 * @date 2023/03/21 15:48
 */
@Service
public class SharesServiceImpl implements SharesService {

    @Autowired
    private SharesMapper sharesMapper;

    @Resource
    private ApplicationEventPublisher applicationEventPublisher;

    @Override
    public Integer create(Shares shares,Integer memberId) {
//        LoginUserInfo userInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
        Shares target = new Shares();
//        target.setCreator(userInfo.getId());
//        target.setEditor(userInfo.getId());
        target.setMemberId(memberId);
        target.setObjId(shares.getObjId());
        target.setObjType(shares.getObjType());
        target.setImgurl(shares.getImgurl());
        target.setTitle(shares.getTitle());
        target.setIntegral(new BigDecimal("0"));
        sharesMapper.insert(target);
        IntegralEvent<Shares> event = new IntegralEvent<>(this,target, Constants.CoffeeBeanTask.SHARE_INFO,memberId);
        applicationEventPublisher.publishEvent(event);
        return shares.getId();
    }

    @Override
    public void deleteById(Integer id) {
        sharesMapper.deleteById(id);
    }

    @Override
    public void delete(Shares shares) {
        UpdateWrapper<Shares> deleteWrapper = new UpdateWrapper<>(shares);
        sharesMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        sharesMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(Shares shares) {
        sharesMapper.updateById(shares);
    }

    @Override
    public void updateByIdInBatch(List<Shares> sharess) {
        if (CollectionUtils.isEmpty(sharess)) {
            return;
        }
        for (Shares shares: sharess) {
            this.updateById(shares);
        }
    }

    @Override
    public Shares findById(Integer id) {
        return sharesMapper.selectById(id);
    }

    @Override
    public Shares findOne(Shares shares) {
        QueryWrapper<Shares> wrapper = new QueryWrapper<>(shares);
        return sharesMapper.selectOne(wrapper);
    }

    @Override
    public List<Shares> findList(Shares shares) {
        QueryWrapper<Shares> wrapper = new QueryWrapper<>(shares);
        return sharesMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<Shares> findPage(PageWrap<Shares> pageWrap) {
        IPage<Shares> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<Shares> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        if (pageWrap.getModel().getId() != null) {
            queryWrapper.lambda().eq(Shares::getId, pageWrap.getModel().getId());
        }
        if (pageWrap.getModel().getCreator() != null) {
            queryWrapper.lambda().eq(Shares::getCreator, pageWrap.getModel().getCreator());
        }
        if (pageWrap.getModel().getCreateDate() != null) {
            queryWrapper.lambda().ge(Shares::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
            queryWrapper.lambda().le(Shares::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
        }
        if (pageWrap.getModel().getEditor() != null) {
            queryWrapper.lambda().eq(Shares::getEditor, pageWrap.getModel().getEditor());
        }
        if (pageWrap.getModel().getEditDate() != null) {
            queryWrapper.lambda().ge(Shares::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
            queryWrapper.lambda().le(Shares::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
        }
        if (pageWrap.getModel().getIsdeleted() != null) {
            queryWrapper.lambda().eq(Shares::getIsdeleted, pageWrap.getModel().getIsdeleted());
        }
        if (pageWrap.getModel().getRemark() != null) {
            queryWrapper.lambda().eq(Shares::getRemark, pageWrap.getModel().getRemark());
        }
        if (pageWrap.getModel().getMemberId() != null) {
            queryWrapper.lambda().eq(Shares::getMemberId, pageWrap.getModel().getMemberId());
        }
        if (pageWrap.getModel().getObjId() != null) {
            queryWrapper.lambda().eq(Shares::getObjId, pageWrap.getModel().getObjId());
        }
        if (pageWrap.getModel().getObjType() != null) {
            queryWrapper.lambda().eq(Shares::getObjType, pageWrap.getModel().getObjType());
        }
        if (pageWrap.getModel().getImgurl() != null) {
            queryWrapper.lambda().eq(Shares::getImgurl, pageWrap.getModel().getImgurl());
        }
        if (pageWrap.getModel().getTitle() != null) {
            queryWrapper.lambda().eq(Shares::getTitle, pageWrap.getModel().getTitle());
        }
        if (pageWrap.getModel().getIntegral() != null) {
            queryWrapper.lambda().eq(Shares::getIntegral, pageWrap.getModel().getIntegral());
        }
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        return PageData.from(sharesMapper.selectPage(page, queryWrapper));
    }

    @Override
    public long count(Shares shares) {
        QueryWrapper<Shares> wrapper = new QueryWrapper<>(shares);
        return sharesMapper.selectCount(wrapper);
    }

    @Override
    public long count(Date start, Date end, Integer memberId,List<Integer> objTypes) {
        QueryWrapper<Shares> wrapper = new QueryWrapper<>();
        wrapper.lambda().eq(Shares::getMemberId,memberId)
                .in(!CollectionUtils.isEmpty(objTypes),Shares::getObjType,objTypes)
                .between(Shares::getCreateDate,start,end);
        return sharesMapper.selectCount(wrapper);

    }
}