package com.mzl.flower.service.impl.comment;

import cn.hutool.core.util.IdUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.mzl.flower.config.exception.ValidationException;
import com.mzl.flower.config.security.SecurityUtils;
import com.mzl.flower.dto.request.comment.*;
import com.mzl.flower.dto.response.comment.FlowerCommentStatisVO;
import com.mzl.flower.dto.response.comment.FlowerCommentVO;
import com.mzl.flower.entity.FlowerCommentDO;
import com.mzl.flower.entity.customer.Customer;
import com.mzl.flower.entity.payment.Order;
import com.mzl.flower.entity.payment.OrderItem;
import com.mzl.flower.entity.supplier.Supplier;
import com.mzl.flower.enums.FlowerCommentShowEnum;
import com.mzl.flower.enums.TrueOrFalseEnum;
import com.mzl.flower.mapper.comment.FlowerCommentMapper;
import com.mzl.flower.mapper.comment.FlowerCommentMapperCustom;
import com.mzl.flower.mapper.customer.CustomerMapper;
import com.mzl.flower.mapper.payment.OrderItemMapper;
import com.mzl.flower.mapper.payment.OrderMapper;
import com.mzl.flower.mapper.supplier.SupplierMapper;
import com.mzl.flower.service.comment.FlowerCommentService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.List;

/**
 * <p>
 * 商品评论表 服务实现类
 * </p>
 *
 * @author @TaoJie
 * @since 2024-09-29
 */
@Service
public class FlowerCommentServiceImpl extends ServiceImpl<FlowerCommentMapper, FlowerCommentDO> implements FlowerCommentService {

    @Autowired
    private FlowerCommentMapperCustom flowerCommentMapperCustom;

    @Autowired
    private OrderItemMapper orderItemMapper;

    @Autowired
    private SupplierMapper supplierMapper;

    @Autowired
    private CustomerMapper customerMapper;

    @Autowired
    private OrderMapper orderMapper;


    @Transactional
    @Override
    public boolean createFlowerComment(CreateFlowerCommentDTO dto) {
        final FlowerCommentVO byOrderItemId = getByOrderItemId(dto.getOrderItemId());
        if(null!=byOrderItemId){
            throw new ValidationException("当前商品已经评论过！");
        }

        FlowerCommentDO flowerCommentDO=new FlowerCommentDO();
        BeanUtils.copyProperties(dto,flowerCommentDO);
        flowerCommentDO.setId(IdUtil.simpleUUID());
        flowerCommentDO.create(SecurityUtils.getUserId());

        final OrderItem orderItem = orderItemMapper.selectById(dto.getOrderItemId());
        if(null==orderItem){
            throw new ValidationException("当前订单项目不存在！");
        }
        flowerCommentDO.setOrderId(orderItem.getOrderId());
        flowerCommentDO.setCustomerUserId(orderItem.getCreateBy());
        flowerCommentDO.setSupplierId(orderItem.getSupplierId());
        flowerCommentDO.setFlowerId(orderItem.getFlowerId());
        flowerCommentDO.setFlowerCover(orderItem.getFlowerCover());

        // 补充商户信息
        Customer customer = customerMapper.selectOne(new QueryWrapper<Customer>()
                .eq("user_id", orderItem.getCreateBy()));
        if(null!=customer && null!=customer.getId()){
            flowerCommentDO.setCustomerId(customer.getId());
        }


        // 补充供应商信息
        Supplier supplier = supplierMapper.selectById(orderItem.getSupplierId());
        if(null!=supplier && StringUtils.isNotBlank(supplier.getUserId())){
            flowerCommentDO.setSupplierUserId(supplier.getUserId());
        }

        // 设置显示状态为显示
        flowerCommentDO.setShowFlag(FlowerCommentShowEnum.SHOW.getFlag());
        return baseMapper.insert(flowerCommentDO)>0;
    }

    @Transactional
    @Override
    public boolean updateFlowerComment(UpdateFlowerCommentDTO dto) {
        FlowerCommentDO flowerCommentDO=baseMapper.selectById(dto.getId());
        BeanUtils.copyProperties(dto,flowerCommentDO);
        flowerCommentDO.update(SecurityUtils.getUserId());
        
        return baseMapper.updateById(flowerCommentDO)>0;
    }

    @Override
    public boolean deleteFlowerComment(String id) {
        return baseMapper.deleteById(id)>0;
    }

    @Override
    public FlowerCommentVO getDetailById(String id) {
        QueryFlowerCommentDTO dto=new QueryFlowerCommentDTO();
        dto.setId(id);
        final List<FlowerCommentVO> list = getList(dto);
        if(CollectionUtils.isNotEmpty(list)){
            return list.get(0);
        }
        return null;
    }

    @Override
    public Page<FlowerCommentVO> getPage(Page page, QueryFlowerCommentDTO dto) {
        List<FlowerCommentVO> list=flowerCommentMapperCustom.getPage(page,dto);
        return page.setRecords(list);
    }

    @Override
    public List<FlowerCommentVO> getList(QueryFlowerCommentDTO dto) {
        return flowerCommentMapperCustom.getList(dto);
    }

    @Override
    public FlowerCommentVO getByOrderItemId(String orderItemId) {
        QueryFlowerCommentDTO dto=new QueryFlowerCommentDTO();
        dto.setOrderItemId(orderItemId);
        final List<FlowerCommentVO> list = getList(dto);
        if(CollectionUtils.isNotEmpty(list)){
            return list.get(0);
        }
        return null;
    }

    @Override
    public BigDecimal getSupplierAvgScore(Long supplierId) {
        return flowerCommentMapperCustom.getSupplierAvgScore(supplierId);
    }

    @Transactional
    @Override
    public boolean createFlowerCommentBatch(CreateFlowerCommentBatchDTO dto) {
        if(CollectionUtils.isNotEmpty(dto.getList())){
            dto.getList().forEach(item->{
                // 保存评论信息
                final FlowerCommentVO byOrderItemId = getByOrderItemId(item.getOrderItemId());
                if(null!=byOrderItemId){
                    // 更新
                    UpdateFlowerCommentDTO updateFlowerCommentDTO=new UpdateFlowerCommentDTO();
                    BeanUtils.copyProperties(item,updateFlowerCommentDTO);
                    updateFlowerCommentDTO.setId(byOrderItemId.getId());
                    updateFlowerComment(updateFlowerCommentDTO);
                }else{
                    createFlowerComment(item);
                }

            });
            // 设置订单的评论状态为评论的下个阶段
            Order order=orderMapper.selectById(dto.getOrderId());

            return true;
        }
        return false;
    }

    @Override
    public FlowerCommentStatisVO getSupplierStatis(Long supplierId) {
        FlowerCommentStatisVO vo=new FlowerCommentStatisVO();

        // 获取平均分
        final BigDecimal supplierAvgScore = flowerCommentMapperCustom.getSupplierAvgScore(supplierId);
        vo.setAvg(supplierAvgScore);

        //当前商家评论总数
        final Integer amount = baseMapper.selectCount(new QueryWrapper<FlowerCommentDO>().lambda()
                        .eq(FlowerCommentDO::getDeleted, TrueOrFalseEnum.FALSE)
                        .eq(FlowerCommentDO::getShowFlag,FlowerCommentShowEnum.SHOW.getFlag())
                        .eq(FlowerCommentDO::getSupplierId, supplierId));
        vo.setCommentAmount(amount);
        return vo;
    }

    @Override
    public boolean updateShowFlowerComment(ShowFlowerCommentDTO dto) {
        FlowerCommentDO flowerCommentDO = baseMapper.selectById(dto.getId());
        if (null == flowerCommentDO) {
            throw new ValidationException("评论不存在");
        }
        flowerCommentDO.setShowFlag(dto.getShowFalg());
        flowerCommentDO.setUpdateBy(SecurityUtils.getUserId());
        return baseMapper.updateById(flowerCommentDO)>0;
    }

    @Override
    public boolean updateReplayFlowerComment(ReplayFlowerCommentDTO dto) {
        FlowerCommentDO flowerCommentDO = baseMapper.selectById(dto.getId());
        if (null == flowerCommentDO) {
            throw new ValidationException("评论不存在");
        }
        flowerCommentDO.setReplayContent(dto.getReplayContent());
        flowerCommentDO.setReplayBy(SecurityUtils.getUserId());
        flowerCommentDO.setReplayTime(LocalDateTime.now());
        flowerCommentDO.setUpdateBy(SecurityUtils.getUserId());
        return baseMapper.updateById(flowerCommentDO)>0;
    }


}