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

import com.alibaba.fastjson.JSON;
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.iotechn.unimall.data.constant.CacheConst;
import com.iotechn.unimall.data.domain.FreightTemplateCarriageDO;
import com.iotechn.unimall.data.domain.FreightTemplateDO;
import com.iotechn.unimall.data.domain.SpuDO;
import com.iotechn.unimall.data.dto.freight.FreightTemplateDTO;
import com.iotechn.unimall.data.exception.ExceptionDefinition;
import com.iotechn.unimall.data.mapper.FreightTemplateCarriageMapper;
import com.iotechn.unimall.data.mapper.FreightTemplateMapper;
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.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: kbq
 * Date: 2019-07-07
 * Time: 下午4:25
 */
@Service
public class AdminFreightTemplateServiceImpl implements AdminFreightTemplateService {

    @Autowired
    private FreightTemplateMapper templateMapper;

    @Autowired
    private FreightTemplateCarriageMapper carriageMapper;

    @Autowired
    private CacheComponent cacheComponent;

    @Autowired
    private SpuMapper spuMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String create(String title, String spuLocation, Integer deliveryDeadline, Integer defaultFreePrice, Integer defaultFirstWeight, Integer defaultFirstPrice, Integer defaultContinueWeight, Integer defaultContinuePrice, List carriageDOList, Long adminId) throws ServiceException {
        FreightTemplateDO freightTemplateDO = newFreightTemplateDO(null,title,spuLocation,deliveryDeadline,defaultFreePrice,defaultFirstWeight,defaultFirstPrice,defaultContinueWeight,defaultContinuePrice);

        if (templateMapper.insert(freightTemplateDO) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.FREIGHT_TEMPLATE_INSERT_FAILED);
        }
        insertCarriage(freightTemplateDO, carriageDOList);
        return "ok";
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String delete(Long id, Long adminId) throws ServiceException {
        if (spuMapper.selectCount(new QueryWrapper<SpuDO>().eq("freight_template_id", id)) > 0) {
            throw new AdminServiceException(ExceptionDefinition.FREIGHT_SPU_QUERY_HAS);
        }
        if (templateMapper.delete(new QueryWrapper<FreightTemplateDO>().eq("id", id)) <= 0) {
            throw new AdminServiceException(ExceptionDefinition.FREIGHT_TEMPLATE_DELETE_FAILED);
        }
        if (carriageMapper.delete(
                new QueryWrapper<FreightTemplateCarriageDO>()
                        .eq("template_id", id)) >= 0) {

            clearCache(id);
            return "ok";
        }
        throw new AdminServiceException(ExceptionDefinition.FREIGHT_TEMPLATE_UPDATE_FAILED);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String edit(Long id, String title, String spuLocation, Integer deliveryDeadline, Integer defaultFreePrice, Integer defaultFirstWeight, Integer defaultFirstPrice, Integer defaultContinueWeight, Integer defaultContinuePrice, List carriageDOList, Long adminId) throws ServiceException {

        FreightTemplateDO freightTemplateDO = newFreightTemplateDO(id,title,spuLocation,deliveryDeadline,defaultFreePrice,defaultFirstWeight,defaultFirstPrice,defaultContinueWeight,defaultContinuePrice);
        if (templateMapper.updateById(freightTemplateDO) <= 0) {    //如果主表修改失败
            throw new AdminServiceException(ExceptionDefinition.FREIGHT_TEMPLATE_UPDATE_FAILED);
        }
        carriageMapper.delete(new QueryWrapper<FreightTemplateCarriageDO>().eq("template_id", id));
        insertCarriage(freightTemplateDO, carriageDOList);
        clearCache(id);
        return "ok";
    }

    @Override
    public List<FreightTemplateDTO> list(Long adminId) throws ServiceException {
        List<FreightTemplateDO> freightTemplateDOList = templateMapper.selectList(null); //查出主表所有数据
        if(CollectionUtils.isEmpty(freightTemplateDOList)){
            return new ArrayList<>();
        }

        List<FreightTemplateDTO> template_id = freightTemplateDOList.stream().map(item -> {
            FreightTemplateDTO freightTemplateDTO = new FreightTemplateDTO();
            List<FreightTemplateCarriageDO> freightTemplateCarriageDOList = carriageMapper.selectList(new QueryWrapper<FreightTemplateCarriageDO>()
                    .eq("template_id", item.getId()));
            BeanUtils.copyProperties(item, freightTemplateDTO);
            freightTemplateDTO.setCarriageDOList(freightTemplateCarriageDOList);
            return freightTemplateDTO;
        }).collect(Collectors.toList());
        return template_id;
    }

    /**
     * 将传入的特殊地区邮费计算插入表中
     * @param freightTemplateDO
     * @param carriageDOList
     * @return
     * @throws ServiceException
     */
    private boolean insertCarriage(FreightTemplateDO freightTemplateDO, List carriageDOList) throws ServiceException {
        Date now = new Date();
        if (CollectionUtils.isEmpty(carriageDOList)) {
            return true;
        }
        List<FreightTemplateCarriageDO> collect = (List<FreightTemplateCarriageDO>) carriageDOList.stream().map(item -> {
            FreightTemplateCarriageDO t = JSONObject.toJavaObject((JSON) item, FreightTemplateCarriageDO.class);
            return t;
        }).collect(Collectors.toList());
        //表中设定可默认值，所以就不检查是否为空
        for (FreightTemplateCarriageDO carriageDO : collect) {
            carriageDO.setTemplateId(freightTemplateDO.getId());
            carriageDO.setGmtCreate(now);
            carriageDO.setGmtUpdate(now);
            if (carriageMapper.insert(carriageDO) <= 0) {
                throw new AdminServiceException(ExceptionDefinition.FREIGHT_CARRIAGE_INSERT_FAILED);
            }
        }
        return true;
    }

    private FreightTemplateDO newFreightTemplateDO(Long id, String title, String spuLocation, Integer deliveryDeadline, Integer defaultFreePrice, Integer defaultFirstWeight, Integer defaultFirstPrice, Integer defaultContinueWeight, Integer defaultContinuePrice){
        FreightTemplateDO freightTemplateDO = new FreightTemplateDO();
        Date now = new Date();
        freightTemplateDO.setTitle(title);
        freightTemplateDO.setSpuLocation(spuLocation);
        freightTemplateDO.setDeliveryDeadline(deliveryDeadline);
        freightTemplateDO.setDefaultFreePrice(defaultFreePrice);
        freightTemplateDO.setDefaultFirstWeight(defaultFirstWeight);
        freightTemplateDO.setDefaultFirstPrice(defaultFirstPrice);
        freightTemplateDO.setDefaultContinueWeight(defaultContinueWeight);
        freightTemplateDO.setDefaultContinuePrice(defaultContinuePrice);
        freightTemplateDO.setGmtUpdate(now);

        if(id != null){
            freightTemplateDO.setId(id);
        }else {
            freightTemplateDO.setGmtCreate(now);
        }
        return freightTemplateDO;
    }

    /**
     * 清楚缓存
     */
    private void clearCache(Long id){
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
            @Override
            public void afterCommit() {
                cacheComponent.del(CacheConst.FREIGHT_TEMPLATE + id);
            }
        });
    }


}