package cn.lili.modules.lmk.service.impl;

import cn.lili.common.enums.CollectTypeEnum;
import cn.lili.common.properties.RocketmqCustomProperties;
import cn.lili.common.security.context.UserContext;
import cn.lili.modules.goods.entity.vos.GoodsVO;
import cn.lili.modules.lmk.domain.query.AuthorVideoQuery;
import cn.lili.modules.lmk.domain.vo.*;
import cn.lili.modules.lmk.service.MySubscribeService;
import cn.lili.modules.lmk.service.VideoService;
import cn.lili.rocketmq.RocketmqSendCallbackBuilder;
import cn.lili.rocketmq.tags.CommentTagsEnum;
import cn.lili.rocketmq.tags.VideoTagsEnum;
import cn.lili.utils.COSUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import cn.lili.modules.lmk.domain.entity.MyCollect;
import cn.lili.modules.lmk.mapper.MyCollectMapper;
import cn.lili.modules.lmk.service.MyCollectService;
import cn.lili.base.Result;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import cn.lili.modules.lmk.domain.form.MyCollectForm;
import cn.lili.modules.lmk.domain.query.MyCollectQuery;
import com.xkcoding.http.util.StringUtil;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import lombok.RequiredArgsConstructor;
import cn.lili.utils.PageUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.util.Assert;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;

import java.util.*;
import java.util.stream.Collectors;

/**
 * 我的收藏 服务实现类
 *
 * @author xp
 * @since 2025-05-22
 */
@Service
@RequiredArgsConstructor
public class MyCollectServiceImpl extends ServiceImpl<MyCollectMapper, MyCollect> implements MyCollectService {

    private final MyCollectMapper myCollectMapper;
    private final RocketmqCustomProperties rocketmqCustomProperties;
    private final LmkFileServiceImpl fileService;
    private final RocketMQTemplate rocketMQTemplate;
    private final VideoServiceMakeUpImpl serviceMakeUp;



    /**
     * 收藏/取消收藏
     * @param form
     * @return
     */
    @Override
    public Result change(MyCollectForm form) {
        // 视频收藏走mq
        if (CollectTypeEnum.video.getType().equals(form.getCollectType())) {
            MyCollect collect = new MyCollect();
            collect.setRefId(form.getRefId());
            collect.setCollectType(form.getCollectType());
            collect.setUserId(UserContext.getCurrentUserId());
            String destination = rocketmqCustomProperties.getVideoTopic() + ":" + VideoTagsEnum.COLLECT.name();
            rocketMQTemplate.asyncSend(destination, JSON.toJSONString(collect), RocketmqSendCallbackBuilder.commonCallback());
        } else {
            MyCollect myCollect = new LambdaQueryChainWrapper<>(baseMapper)
                    .eq(MyCollect::getCollectType, form.getCollectType())
                    .eq(MyCollect::getRefId, form.getRefId())
                    .eq(MyCollect::getUserId, UserContext.getCurrentUserId())
                    .one();
            if (Objects.nonNull(myCollect)) {
                baseMapper.deleteById(myCollect.getId());
            } else {
                myCollect = new MyCollect();
                myCollect.setRefId(form.getRefId());
                myCollect.setCollectType(form.getCollectType());
                myCollect.setUserId(UserContext.getCurrentUserId());
                baseMapper.insert(myCollect);
            }
        }
        return Result.ok("操作成功");
    }

    /**
     * 修改
     * @param form
     * @return
     */
    @Override
    public Result update(MyCollectForm form) {
        MyCollect entity = baseMapper.selectById(form.getId());

        // 为空抛IllegalArgumentException，做全局异常处理
        Assert.notNull(entity, "记录不存在");
        BeanUtils.copyProperties(form, entity);
        baseMapper.updateById(entity);
        return Result.ok("修改成功");
    }

    /**
     * 批量删除
     * @param ids
     * @return
     */
    @Override
    public Result remove(List<String> ids) {
        baseMapper.deleteBatchIds(ids);
        return Result.ok("删除成功");
    }

    /**
     * id删除
     * @param id
     * @return
     */
    @Override
    public Result removeById(String id) {
        baseMapper.deleteById(id);
        return Result.ok("删除成功");
    }

    /**
     * 分页查询
     * @param query
     * @return
     */
    @Override
    public Result page(MyCollectQuery query) {
        IPage<MyCollectVO> page = PageUtil.getPage(query, MyCollectVO.class);
        baseMapper.getPage(page, query);
        return Result.ok().data(page.getRecords()).total(page.getTotal());
    }

    /**
     * 根据id查找
     * @param id
     * @return
     */
    @Override
    public Result detail(String id) {
        MyCollectVO vo = baseMapper.getById(id);
        Assert.notNull(vo, "记录不存在");
        return Result.ok().data(vo);
    }

    /**
     * 列表
     * @return
     */
    @Override
    public Result all() {
        List<MyCollect> entities = baseMapper.selectList(null);
        List<MyCollectVO> vos = entities.stream()
                .map(entity -> MyCollectVO.getVoByEntity(entity, null))
                .collect(Collectors.toList());
        return Result.ok().data(vos);
    }

    @Override
    public List<SimpleMyCollectVO> getCollectsByVideoIds(List<String> videoIds) {
        if (videoIds == null || videoIds.isEmpty()) {
            return new ArrayList<>();
        }
        return baseMapper.getCollectsByVideoIds(videoIds, UserContext.getCurrentUserId());
    }

    @Override
    public List<CollectTypeNumVO> countNumGroupByVideo() {
        return baseMapper.countNumGroupByVideo();
    }


    @Override
    public Result getMyCollectList(MyCollectQuery query) {
        String userId = UserContext.getCurrentUserId();
        IPage<Object> page = PageUtil.getPage(query, Object.class);
        if (CollectTypeEnum.activity.getType().equals(query.getType())){
            baseMapper.getActivityCollectPage(page, userId);
            List<ActivityVO> activityVOS = page.getRecords().stream()
                    .filter(obj -> obj instanceof ActivityVO)
                    .map(obj -> (ActivityVO) obj)
                    .collect(Collectors.toList());
            for (ActivityVO activityVO : activityVOS) {
                activityVO.setUrl(fileService.getPreviewUrl(activityVO.getCover()));
            }
        }else if (CollectTypeEnum.video.getType().equals(query.getType())) {
            AuthorVideoQuery videoQuery = new AuthorVideoQuery();
            videoQuery.setAuthorId(UserContext.getCurrentUserId());
            videoQuery.setAuthorSelf(true);
            videoQuery.setPageSize(query.getPageSize());

            videoQuery.setPageNumber(query.getPageNumber());
            return serviceMakeUp.getAuthorCollectVideoPage(videoQuery);
        }else if (CollectTypeEnum.goods.getType().equals(query.getType())) {
            baseMapper.getGoodsCollectPage(page, userId);

        }

        return Result.ok().data(page.getRecords()).total(page.getTotal());
    }

}