package com.iotechn.unimall.admin.api.product;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.dobbinsoft.fw.core.exception.AdminServiceException;
import com.dobbinsoft.fw.core.exception.ServiceException;
import com.dobbinsoft.fw.support.component.CacheComponent;
import com.dobbinsoft.fw.support.model.Page;
import com.iotechn.unimall.data.domain.GroupShopDO;
import com.iotechn.unimall.data.domain.SkuActivityPriceDO;
import com.iotechn.unimall.data.domain.SkuDO;
import com.iotechn.unimall.data.domain.SpuDO;
import com.iotechn.unimall.data.dto.product.GroupShopDTO;
import com.iotechn.unimall.data.dto.product.GroupShopSkuDTO;
import com.iotechn.unimall.data.enums.GroupShopAutomaticRefundType;
import com.iotechn.unimall.data.enums.SpuActivityType;
import com.iotechn.unimall.data.enums.StatusType;
import com.iotechn.unimall.data.exception.ExceptionDefinition;
import com.iotechn.unimall.data.mapper.GroupShopMapper;
import com.iotechn.unimall.data.mapper.SkuActivityPriceMapper;
import com.iotechn.unimall.data.mapper.SkuMapper;
import com.iotechn.unimall.data.mapper.SpuMapper;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionSynchronization;
import org.springframework.transaction.support.TransactionSynchronizationManager;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;

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

/*
@PackageName:com.iotechn.unimall.admin.api.goods
@ClassName: AdminGroupShopGoodsServiceImpl
@Description:
@author kbq
@date 19-11-13下午4:21
*/
@Service
public class AdminGroupShopServiceImpl implements AdminGroupShopService {

    @Autowired
    private SkuMapper skuMapper;

    @Autowired
    private SpuMapper spuMapper;

    @Autowired
    private GroupShopMapper groupShopMapper;

    @Autowired
    private SkuActivityPriceMapper skuActivityPriceMapper;

    @Autowired
    private CacheComponent cacheComponent;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String create(Long spuId, Long gmtStart, Long gmtEnd, Integer minNum, Integer automaticRefund, String groupShopSkuListStr, Long adminId) throws ServiceException {
        // 1.转化为对应的GroupShopSkuDTO类的链表
        List<GroupShopSkuDTO> groupShopSkuDTOList = JSONObject.parseArray(groupShopSkuListStr, GroupShopSkuDTO.class)
                .stream().sorted(Comparator.comparingInt(GroupShopSkuDTO::getSkuGroupShopPrice)).collect(Collectors.toList());

        if (gmtStart.compareTo(gmtEnd) >= 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_START_MUST_LESS_THAN_END);
        }

        // 2.1 检验数据库中是否存在spuId对应的sku
        SpuDO spuDO = spuMapper.selectById(spuId);
        List<SkuDO> skuDOList = skuMapper.selectList((new QueryWrapper<SkuDO>().eq("spu_id", spuId)));
        if (spuDO == null || CollectionUtils.isEmpty(skuDOList)) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SPU_NO_EXIST_OR_ONLY_SPU);
        }
        // 2.2 检验groupShop表中是否存在此商品
        Integer count = groupShopMapper.selectCount((new QueryWrapper<GroupShopDO>().eq("spu_id", spuId)));
        if (count > 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_ALREADY_EXIT);
        }
        // 2.3 校验商品是否还有未存在的活动
        if (spuDO.getActivityId() != null && spuDO.getActivityType() != null
                && spuDO.getActivityType() != SpuActivityType.NONE.getCode()
                && spuDO.getGmtActivityEnd() != null && spuDO.getGmtActivityEnd().getTime() > System.currentTimeMillis()) {
            throw new AdminServiceException(ExceptionDefinition.PRODUCT_SPU_EXIST_ACTIVITY);
        }

        // 3.创建团购活动信息
        // 3.1.插入主表
        Date timeStart = new Date(gmtStart);
        Date timeEnd = new Date(gmtEnd);
        Date now = new Date();
        GroupShopDO groupShopDO = new GroupShopDO();

        groupShopDO.setBuyerNum(0);
        groupShopDO.setMinNum(minNum);
        groupShopDO.setGmtStart(timeStart);
        groupShopDO.setGmtEnd(timeEnd);
        groupShopDO.setAutomaticRefund(automaticRefund.compareTo(0) > 0 ? GroupShopAutomaticRefundType.YES.getCode() : GroupShopAutomaticRefundType.NO.getCode());
        groupShopDO.setSpuId(spuId);
        groupShopDO.setMinPrice(groupShopSkuDTOList.get(0).getSkuGroupShopPrice());
        groupShopDO.setMaxPrice(groupShopSkuDTOList.get(groupShopSkuDTOList.size() - 1).getSkuGroupShopPrice());
        groupShopDO.setGmtCreate(now);
        groupShopDO.setGmtUpdate(now);
        // 由活动开始定时任务更改其状态
        groupShopDO.setStatus(StatusType.LOCK.getCode());
        if (groupShopMapper.insert(groupShopDO) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SPU_ADD_SQL_QUERY_ERROR);
        }

        if (skuDOList.size() != groupShopSkuDTOList.size()) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SKU_NUMBER_ERROR);
        }
        // 3.2 插入groupShopSkuList（插入从表）
        this.insertGroupShopSkuList(groupShopSkuDTOList, skuDOList, groupShopDO.getId(), now);
        // 4.修改商品表活动信息
        SpuDO updateSpuDO = new SpuDO();
        updateSpuDO.setId(spuId);
        updateSpuDO.setActivityType(SpuActivityType.GROUP_SHOP.getCode());
        updateSpuDO.setActivityId(groupShopDO.getId());
        updateSpuDO.setGmtActivityStart(timeStart);
        updateSpuDO.setGmtActivityEnd(timeEnd);
        updateSpuDO.setGmtUpdate(now);
        spuMapper.updateById(updateSpuDO);
        // 5 清理缓存
        this.clearCache(spuId);
        return "ok";
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String delete(Long id, Long adminId) throws ServiceException {
        // 1. 参数校验
        GroupShopDO groupShopDO = groupShopMapper.selectById(id);
        if (groupShopDO == null) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SPU_NO_EXIST_OR_ONLY_SPU);
        }

        if (groupShopDO.getStatus() > 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_ALREADY_ACTIVE);
        }

        // 2. 删除团购
        if (groupShopMapper.deleteById(id) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SPU_DELETE_SQL_QUERY_ERROR);
        }
        if (skuActivityPriceMapper.delete((
                new QueryWrapper<SkuActivityPriceDO>()
                        .eq("activity_id", id)
                        .eq("activity_type", SpuActivityType.GROUP_SHOP.getCode()))) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SKU_DELETE_SQL_QUERY_ERROR);
        }

        // 3. 更新SPU状态
        // 3.1. 检查一下活动是否被其他活动覆盖
        SpuDO existSpu = spuMapper.selectById(groupShopDO.getSpuId());
        if (existSpu.getActivityType() == SpuActivityType.GROUP_SHOP.getCode()) {
            // 3.2.执行状态修改
            SpuDO updateSpuDO = new SpuDO();
            updateSpuDO.setId(groupShopDO.getSpuId());
            updateSpuDO.setActivityType(SpuActivityType.NONE.getCode());
            updateSpuDO.setGmtUpdate(new Date());
            spuMapper.updateById(updateSpuDO);
        }
        // 4. 清理缓存
        this.clearCache(groupShopDO.getSpuId());
        return "ok";
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public GroupShopDTO edit(Long id, Long spuId, Long gmtStart, Long gmtEnd, Integer minimumNumber, Integer automaticRefund, String groupShopSkuListStr, Long adminId) throws ServiceException {
        // 1.转化为对应的GroupShopSkuDO类的链表
        List<GroupShopSkuDTO> groupShopSkuDOList = JSONObject.parseArray(groupShopSkuListStr, GroupShopSkuDTO.class)
                .stream().sorted(Comparator.comparingInt(GroupShopSkuDTO::getSkuGroupShopPrice)).collect(Collectors.toList());
        // 2校验参数
        // 2.1.校验过期
        if (gmtStart.compareTo(gmtEnd) >= 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_START_MUST_LESS_THAN_END);
        }

        // 2.2.校验团购
        GroupShopDO groupShopDO = groupShopMapper.selectById(id);
        if (groupShopDO == null) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SPU_NO_EXIST);
        }

        if (groupShopDO.getStatus() > 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_ALREADY_ACTIVE);
        }

        // 2.2. 校验SPU
        SpuDO spuDO = spuMapper.selectById(spuId);
        List<SkuDO> skuDOList = skuMapper.selectList((new QueryWrapper<SkuDO>().eq("spu_id", spuId)));
        if (spuDO == null || CollectionUtils.isEmpty(skuDOList)) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SPU_NO_EXIST_OR_ONLY_SPU);
        }

        if (skuDOList.size() != groupShopSkuDOList.size()) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SKU_NUMBER_ERROR);
        }

        // 3. 修改团购信息
        // 3.1. 修改主表
        Date timeStart = new Date(gmtStart);
        Date timeEnd = new Date(gmtEnd);
        Date now = new Date();
        groupShopDO.setMinNum(minimumNumber);
        groupShopDO.setGmtStart(timeStart);
        groupShopDO.setGmtEnd(timeEnd);
        groupShopDO.setAutomaticRefund(automaticRefund.compareTo(0) > 0 ? StatusType.ACTIVE.getCode() : StatusType.LOCK.getCode());
        groupShopDO.setSpuId(spuId);
        groupShopDO.setMinPrice(groupShopSkuDOList.get(0).getSkuGroupShopPrice());
        groupShopDO.setMinPrice(groupShopSkuDOList.get(groupShopSkuDOList.size() - 1).getSkuGroupShopPrice());
        groupShopDO.setGmtUpdate(now);
        groupShopDO.setStatus(StatusType.LOCK.getCode());
        if (groupShopMapper.updateById(groupShopDO) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SPU_UPDATE_SQL_QUERY_ERROR);
        }
        // 3.2.插入groupShopSkuList(即修改活动商品价格表)
        // 3.2.1. 删除旧有活动商品价格
        if (skuActivityPriceMapper.delete((
                new QueryWrapper<SkuActivityPriceDO>()
                        .eq("activity_id", id)
                        .eq("activity_type", SpuActivityType.GROUP_SHOP.getCode()))) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SKU_DELETE_SQL_QUERY_ERROR);
        }
        // 3.3.2. 插入新的活动商品价格
        this.insertGroupShopSkuList(groupShopSkuDOList, skuDOList, groupShopDO.getId(), now);
        // 4.修改商品活动信息
        SpuDO updateSpuDO = new SpuDO();
        updateSpuDO.setId(spuId);
        updateSpuDO.setActivityType(SpuActivityType.GROUP_SHOP.getCode());
        updateSpuDO.setActivityId(groupShopDO.getId());
        updateSpuDO.setGmtActivityStart(timeStart);
        updateSpuDO.setGmtActivityEnd(timeEnd);
        updateSpuDO.setGmtUpdate(now);
        spuMapper.updateById(updateSpuDO);
        // 5.清理缓存
        this.clearCache(spuId);
        return new GroupShopDTO();
    }

    @Override
    public Page<GroupShopDTO> list(Long id, String spuName, Integer status, Integer page, Integer limit, Long adminId) throws ServiceException {
        QueryWrapper<GroupShopDO> queryWrapper = new QueryWrapper<GroupShopDO>();
        if (id != null) {
            queryWrapper.eq("id", id);
        }
        if (status != null) {
            queryWrapper.eq("status", status);
        }

        if (!StringUtils.isEmpty(spuName)) {
            List<SpuDO> objectList = spuMapper.selectList(
                    new QueryWrapper<SpuDO>()
                            .select("id")
                            .like("title", spuName));
            List<Long> spuIds = objectList.stream().map(SpuDO::getId).collect(Collectors.toList());
            if (CollectionUtils.isEmpty(objectList)) {
                return new Page<>(new ArrayList<>(), page, limit, 0);
            }
            queryWrapper.in("spu_id", spuIds);
        }

        Page<GroupShopDTO> groupShopDTOPage = groupShopMapper
                .selectPage(Page.div(page, limit, GroupShopDO.class), queryWrapper).trans(groupShopDO -> {
                    GroupShopDTO groupShopDTO = new GroupShopDTO();
                    SpuDO spuDO = spuMapper.selectById(groupShopDO.getSpuId());
                    BeanUtils.copyProperties(spuDO, groupShopDTO);
                    BeanUtils.copyProperties(groupShopDO, groupShopDTO);
                    /**
                     * 添加groupShopSkuDTOList
                     */
                    Map<Long, SkuDO> skuMap = skuMapper.selectList((new QueryWrapper<SkuDO>().eq("spu_id", spuDO.getId()))).stream().collect(Collectors.toMap(SkuDO::getId, v -> v));
                    List<SkuActivityPriceDO> skuActivityPriceDOList = skuActivityPriceMapper.selectList((
                            new QueryWrapper<SkuActivityPriceDO>())
                            .eq("activity_id", groupShopDO.getId())
                            .eq("activity_type", SpuActivityType.GROUP_SHOP.getCode()));
                    List<GroupShopSkuDTO> groupShopSkuDTOList = skuActivityPriceDOList.stream().map(item -> {
                        GroupShopSkuDTO groupShopSkuDTO = new GroupShopSkuDTO();
                        groupShopSkuDTO.setSkuId(item.getSkuId());
                        groupShopSkuDTO.setGroupShopId(item.getActivityId());
                        groupShopSkuDTO.setSkuGroupShopPrice(item.getActivityPrice());
                        SkuDO skuDO = skuMap.get(item.getSkuId());
                        BeanUtils.copyProperties(skuDO, groupShopSkuDTO);
                        groupShopSkuDTO.setTitle(skuDO.getTitle());
                        return groupShopSkuDTO;
                    }).sorted((o1, o2) -> (int)(o1.getSkuId().longValue() - o2.getSkuId().longValue())).collect(Collectors.toList());
                    groupShopDTO.setGroupShopSkuDTOList(groupShopSkuDTOList);
                    return groupShopDTO;
                });
        return groupShopDTOPage;
    }

    private void insertGroupShopSkuList(List<GroupShopSkuDTO> groupShopSkuDTOList, List<SkuDO> skuDOList, Long groupShopId, Date now) throws ServiceException {
        for (GroupShopSkuDTO groupShopSkuDTO : groupShopSkuDTOList) {
            boolean judge = false;
            for (SkuDO sku : skuDOList) {
                if (sku.getId().equals(groupShopSkuDTO.getSkuId())) {
                    judge = true;
                    break;
                }
            }

            if (!judge) {
                throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SKU_ID_ERROR);
            }

            if (groupShopSkuDTO.getSkuGroupShopPrice() == null || groupShopSkuDTO.getSkuGroupShopPrice().equals(0)) {
                throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SKU_PRICE_ERROR);
            }
            // 插入到商品活动价表
            SkuActivityPriceDO skuActivityPriceDO = new SkuActivityPriceDO();
            skuActivityPriceDO.setActivityType(SpuActivityType.GROUP_SHOP.getCode());
            skuActivityPriceDO.setActivityId(groupShopId);
            skuActivityPriceDO.setActivityPrice(groupShopSkuDTO.getSkuGroupShopPrice());
            skuActivityPriceDO.setGmtUpdate(now);
            skuActivityPriceDO.setGmtCreate(now);
            skuActivityPriceDO.setSkuId(groupShopSkuDTO.getSkuId());
            if (skuActivityPriceMapper.insert(skuActivityPriceDO) <= 0) {
                throw new AdminServiceException(ExceptionDefinition.GROUP_SHOP_SKU_ADD_SQL_QUERY_ERROR);
            }
        }
    }

    /**
     * 清除团购列表缓存
     */
    private void clearCache(Long spuId) {
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
            @Override
            public void afterCommit() {
//                cacheComponent.delPrefixKey(CacheConst.PRT_GROUP_SHOP_LIST);
                // TODO 别忘记刷新商品缓存
//                cacheComponent.delHashKey(CacheConst.PRT_SPU_HASH_BUCKET, "P" + spuId);
            }
        });
    }

}