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

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.biz.service.category.CategoryBizService;
import com.iotechn.unimall.data.constant.CacheConst;
import com.iotechn.unimall.data.domain.AdvertDO;
import com.iotechn.unimall.data.domain.CategoryDO;
import com.iotechn.unimall.data.domain.SpuDO;
import com.iotechn.unimall.data.dto.CategoryDTO;
import com.iotechn.unimall.data.enums.AdvertUnionType;
import com.iotechn.unimall.data.enums.CategoryLevelType;
import com.iotechn.unimall.data.exception.ExceptionDefinition;
import com.iotechn.unimall.data.mapper.AdvertMapper;
import com.iotechn.unimall.data.mapper.CategoryMapper;
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 java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * Created by rize on 2019/7/12.
 */
@Service
public class AdminCategoryServiceImpl implements AdminCategoryService {

    @Autowired
    private CategoryMapper categoryMapper;

    @Autowired
    private AdvertMapper advertMapper;

    @Autowired
    private SpuMapper spuMapper;

    @Autowired
    private CategoryBizService categoryBizService;

    @Autowired
    private CacheComponent cacheComponent;

    /**
     * 获取两级类目树,用于添加类目时选择使用 商品、优惠券
     */
    @Override
    public List<CategoryDTO> categoryTree() throws ServiceException {
        return categoryBizService.categorySecondLevelTree();
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public CategoryDO create(String title, Long parentId, String picUrl, Long adminId) throws ServiceException {
        CategoryDO parent = null;
        CategoryDO categoryDO = new CategoryDO();
        if (!parentId.equals(0l)) {
            parent = categoryMapper.selectById(parentId);
            if (parent == null || parent.getLevel().intValue() > CategoryLevelType.TWO.getCode()) {
                throw new AdminServiceException(ExceptionDefinition.CATEGORY_PARENT_NODE_INFORMATION_ERROR);
            }
            categoryDO.setLevel(parent.getLevel() + 1);
            if (parent.getLevel().intValue() == CategoryLevelType.ONE.getCode().intValue()) {
                categoryDO.setFirstLevelId(parentId);
            } else if (parent.getLevel().intValue() == CategoryLevelType.ONE.getCode().intValue()) {
                categoryDO.setFirstLevelId(parent.getFirstLevelId());
            }
        } else {
            categoryDO.setLevel(CategoryLevelType.ONE.getCode());
        }
        categoryDO.setParentId(parentId);
        categoryDO.setPicUrl(picUrl);
        categoryDO.setTitle(title);
        Date now = new Date();
        categoryDO.setGmtCreate(now);
        categoryDO.setGmtUpdate(now);
        if (categoryMapper.insert(categoryDO) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.ADMIN_UNKNOWN_EXCEPTION);
        }
        this.clearCache();
        return categoryDO;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String delete(Long id, Long adminId) throws ServiceException {
        /**
         *  删除类目时 不允许类目有子类目
         *  删除类目时 不允许类目有商品
         *  删除类目时 不允许有广告关联类目
         */
        Integer countCategory = categoryMapper.selectCount(new QueryWrapper<CategoryDO>().eq("parent_id", id));
        Integer countSpu = spuMapper.selectCount(new QueryWrapper<SpuDO>().eq("category_id", id));
        Integer countAdvert = advertMapper.selectCount(
                new QueryWrapper<AdvertDO>()
                        .eq("union_type", AdvertUnionType.CATEGORY.getCode())
                        .eq("union_value", id.toString()));
        if (countCategory != 0 || countSpu != 0) {
            throw new AdminServiceException(ExceptionDefinition.CATEGORY_OUGHT_TO_EMPTY);
        }
        if (countAdvert != 0) {
            throw new AdminServiceException(ExceptionDefinition.CATEGORY_EXIST_ADVERT);
        }
        if (categoryMapper.deleteById(id) > 0) {
            this.clearCache();
            return "ok";
        }
        throw new AdminServiceException(ExceptionDefinition.ADMIN_UNKNOWN_EXCEPTION);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public CategoryDTO update(Long id, String title, Long parentId, String iconUrl, String picUrl, Long adminId) throws ServiceException {
        CategoryDO categoryParent = null;
        if (parentId.longValue() != 0L) {
            categoryParent = categoryMapper.selectById(parentId);
        }
        CategoryDO category = categoryMapper.selectById(id);

        // 1. 检验类目是否存在,非一级类目的父类目是否存在
        if (category == null || (categoryParent == null && !parentId.equals(0L))) {
            throw new AdminServiceException(ExceptionDefinition.CATEGORY_NOT_FIND_PARENT_NODE_OR_NODE);
        }

        CategoryDO updateDO = new CategoryDO();

        // 如果是一级类目修改，就不会变更父类目；如果没有变更父类目，也不会变更对应的一二级长辈类目
        if (!category.getParentId().equals(0L) && !category.getParentId().equals(parentId)) {
            // 节点只能平级变更
            if (category.getLevel().intValue() != categoryParent.getLevel().intValue() + 1) {
                throw new AdminServiceException(ExceptionDefinition.ADMIN_UNKNOWN_EXCEPTION);
            }
            if (categoryParent.getLevel().intValue() == CategoryLevelType.ONE.getCode().intValue()) {
                updateDO.setFirstLevelId(parentId);
            } else if (categoryParent.getLevel().intValue() == CategoryLevelType.TWO.getCode().intValue()) {
                updateDO.setFirstLevelId(categoryParent.getFirstLevelId());
            }
        }
        updateDO.setId(id);
        updateDO.setGmtUpdate(new Date());
        updateDO.setParentId(parentId);
        updateDO.setTitle(title);
        updateDO.setPicUrl(picUrl);
        if (categoryMapper.updateById(updateDO) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.CATEGORY_UPDATE_FAILURE);
        }

        // 如果变更了父节点，就需要变更当前节点的子孙节点的一二级长辈节点
        if (!category.getParentId().equals(parentId)) {
            // 只有二三级节点能变更父节点，其中只有二级节点变更后，会造成子节点的长辈节点变更。
            if (updateDO.getLevel().intValue() == 1) {
                QueryWrapper<CategoryDO> wrapper = new QueryWrapper<>();
                wrapper.eq("parent_id", updateDO.getId());
                CategoryDO child = new CategoryDO();
                child.setFirstLevelId(updateDO.getFirstLevelId());
                categoryMapper.update(child, wrapper);
            }
        }

        CategoryDTO categoryDTO = new CategoryDTO();
        BeanUtils.copyProperties(updateDO, categoryDTO);
        List<CategoryDTO> list = categoryBizService.getCategoryList();
        for (CategoryDTO temp : list) {
            if (updateDO.getId().equals(temp.getId())) {
                BeanUtils.copyProperties(temp, categoryDTO);
                break;
            }
        }
        this.clearCache();
        return categoryDTO;
    }

    @Override
    public Page<CategoryDTO> list(Long id, String title, Integer level, Long parentId, Integer page, Integer limit, Long adminId) throws ServiceException {
        QueryWrapper wrapper = new QueryWrapper();
        if (id != null) {
            wrapper.eq("id", id);
        }
        if (title != null) {
            wrapper.like("title", title);
        }
        if (level != null) {
            wrapper.eq("level", level);
        }
        if (parentId != null) {
            List<Long> categorySelfAndChildren = categoryBizService.getCategorySelfAndChildren(parentId);
            if (!CollectionUtils.isEmpty(categorySelfAndChildren)) {
                wrapper.in("id", categorySelfAndChildren);
            }
        }
        wrapper.orderByAsc("level");

        Page selectPage = categoryMapper.selectPage(Page.div(page, limit, CategoryDO.class), wrapper);
        List<CategoryDO> categoryDOS = selectPage.getItems();
        List<CategoryDTO> totalCategory = categoryBizService.getCategoryList();
        List<CategoryDTO> list = categoryDOS.stream().map(item -> {
            CategoryDTO dto = new CategoryDTO();
            for (CategoryDTO temp : totalCategory) {
                if (temp.getId().equals(item.getId())) {
                    BeanUtils.copyProperties(temp, dto);
                    return dto;
                }
            }
            BeanUtils.copyProperties(item, dto);
            return dto;
        }).collect(Collectors.toList());
        return new Page<>(list, page, limit, selectPage.getCount());
    }

    /**
     * 抽取删除缓存公共代码
     */
    private void clearCache() {
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
            @Override
            public void afterCommit() {
                cacheComponent.del(CacheConst.CATEGORY_ALL_LIST);
                cacheComponent.del(CacheConst.CATEGORY_SECOND_LEVEL_TREE);
                cacheComponent.del(CacheConst.CATEGORY_THREE_LEVEL_TREE);
            }
        });
    }

}