package com.iamberry.rst.service.customer;

import com.github.pagehelper.PageHelper;
import com.iamberry.rst.core.address.City;
import com.iamberry.rst.core.address.Province;
import com.iamberry.rst.core.customer.*;
import com.iamberry.rst.core.order.Product;
import com.iamberry.rst.core.order.ProductColor;
import com.iamberry.rst.core.page.PageRequest;
import com.iamberry.rst.core.page.PagedResult;
import com.iamberry.rst.faces.customer.CustomerBasicService;
import com.iamberry.rst.service.customer.mapper.CustomerBasicMapper;
import com.iamberry.rst.util.PageUtil;
import com.iamberry.wechat.tools.payUtil.StringUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * Created by Administrator on 2018/4/20.
 */
@Service
public class CustomerBasicServiceImpl implements CustomerBasicService{
    @Autowired
    private CustomerBasicMapper customerBasicMapper;

    @Override
    public PagedResult<CustomerBasicInfo> listCustomerBasic(PageRequest<CustomerBasicInfo> pageRequest) {
        PageHelper.startPage(pageRequest.getPageNO(), pageRequest.getPageSize(), pageRequest.isPageTotal());
        List<CustomerBasicInfo> customerBasicList = customerBasicMapper.listCustomerBasic(pageRequest.getData());
        return PageUtil.getPage(customerBasicList);
    }

    @Override
    public CustomerBasicInfo getCustomerBasic(CustomerBasicInfo customerBasicInfo) {
        return customerBasicMapper.getCustomerBasic(customerBasicInfo);
    }

    @Override
    public Integer updateState(CustomerBasicInfo customerBasicInfo) {
        return customerBasicMapper.updateState(customerBasicInfo);
    }

    @Override
    public BillingInfo getBillingInfo(BillingInfo billingInfo) {
        return customerBasicMapper.getBillingInfo(billingInfo);
    }

    @Override
    public TicketOpeningInfo getOpeningInfo(TicketOpeningInfo ticketOpeningInfo) {
        return customerBasicMapper.getOpeningInfo(ticketOpeningInfo);
    }

    @Override
    public List<DockedContactInfo> listDockedContactInfo(DockedContactInfo dockedContactInfo) {
        return customerBasicMapper.listDockedContactInfo(dockedContactInfo);
    }

    @Override
    public List<ChannelSaleInfo> listChannelSaleInfo(ChannelSaleInfo channelSaleInfo) {
        return customerBasicMapper.listChannelSaleInfo(channelSaleInfo);
    }

    @Override
    public List<ChannelDivisionInfo> listChannelDivisionInfo(Integer coustomerId) {
        return customerBasicMapper.listChannelDivisionInfo(coustomerId);
    }

    private Logger logger = LoggerFactory.getLogger(CustomerBasicServiceImpl.class);

    @Override
    public CustomerBasicInfo queryCustomerBasicInfoByCustomerId(int queryCustomerId) {
        return customerBasicMapper.queryCustomerBasicInfoByCustomerId(queryCustomerId);
    }

    @Override
    public List<DockedContactInfo> queryDockedContactInfoListByCustomerId(int queryCustomerId) {
        return customerBasicMapper.queryDockedContactInfoListByCustomerId(queryCustomerId);
    }

    @Override
    public List<ChannelSaleInfo> queryChannelSaleInfoListByCustomerId(int queryCustomerId) {
        return customerBasicMapper.queryChannelSaleInfoListByCustomerId(queryCustomerId);
    }

    @Override
    public BillingInfo queryBillingInfoByCustomerId(int queryCustomerId) {
        return customerBasicMapper.queryBillingInfoByCustomerId(queryCustomerId);
    }

    @Override
    public TicketOpeningInfo queryTicketOpeningInfoByCustomerId(int queryCustomerId) {
        return customerBasicMapper.queryTicketOpeningInfoByCustomerId(queryCustomerId);
    }

    @Override
    @Transactional
    public void saveCustomerBasicInfo(CustomerBasicInfo customerBasicInfo,List<DockedContactInfo> dockedContactInfoList, List<ChannelSaleInfo> channelSaleInfoList,
                                      BillingInfo billingInfo, TicketOpeningInfo ticketOpeningInfo) throws Exception{
        logger.info("saveCustomerBasicInfo start...");
        int customerId = -1;
        String channelDivisionId = "";
        int cooperativeState = customerBasicInfo.getCooperativeState();
        try {
            customerBasicMapper.saveCustomerBasicInfo(customerBasicInfo);
            customerId = customerBasicInfo.getCustomerId();
            if(customerId != -1){
                if(dockedContactInfoList != null && dockedContactInfoList.size()>1){
                    dockedContactInfoList.remove(0);
                    for (DockedContactInfo dockedContactInfo: dockedContactInfoList) {
                        dockedContactInfo.setCustomerId(customerId);
                        customerBasicMapper.saveDockedContactInfo(dockedContactInfo);
                    }
                }
                if(channelSaleInfoList != null && channelSaleInfoList.size()>1){
                    channelSaleInfoList.remove(0);
                    for (ChannelSaleInfo channelSaleInfo: channelSaleInfoList) {
                        channelSaleInfo.setCustomerId(customerId);
                        String channelName = channelSaleInfo.getChannelName();
                        channelDivisionId = customerBasicMapper.queryIsExsitChannelNameChannelName(channelSaleInfo);
                        if(StringUtil.isNotEmpty(channelDivisionId)){
                            if(Integer.valueOf(channelDivisionId)>0){
                                channelSaleInfo.setChannelDivisionId(Integer.valueOf(channelDivisionId));
                                customerBasicMapper.saveChannelSaleInfo(channelSaleInfo);
                            }else{
                                customerBasicMapper.saveChannelDivisionInfo(channelSaleInfo);
                                customerBasicMapper.saveChannelSaleInfo(channelSaleInfo);
                            }
                        }else{
                            customerBasicMapper.saveChannelDivisionInfo(channelSaleInfo);
                            customerBasicMapper.saveChannelSaleInfo(channelSaleInfo);
                        }
                    }
                }
                if(cooperativeState == 2 || cooperativeState ==3){
                    billingInfo.setCustomerId(customerId);
                    ticketOpeningInfo.setCustomerId(customerId);
                    customerBasicMapper.saveBillingInfo(billingInfo);
                    customerBasicMapper.saveTicketOpeningInfo(ticketOpeningInfo);
                }
            }
            logger.info("saveCustomerBasicInfo end...");
        }catch (Exception e){
            logger.error("添加客户信息失败"+e.getMessage());
            throw new RuntimeException("添加客户信息失败");
        }

    }

    @Override
    @Transactional
    public void updateCustomerBasicInfo(CustomerBasicInfo customerBasicInfo,List<DockedContactInfo> dockedContactInfoList, List<ChannelSaleInfo> channelSaleInfoList,
                                      BillingInfo billingInfo, TicketOpeningInfo ticketOpeningInfo) throws Exception{
        int customerId = -1;
        String channelDivisionId = "";
        try {
            customerBasicMapper.updateCustomerBasic(customerBasicInfo);
            customerId = customerBasicInfo.getCustomerId();

            //删除旧联系人数据和渠道销售信息
            customerBasicMapper.deleteContactInfo(customerId);
            List<ChannelSaleInfo> listChannelSale = customerBasicMapper.queryChannelSaleInfoListByCustomerId(customerId);
            if(listChannelSale.size() > 0){
                for(ChannelSaleInfo channelSaleInfo : listChannelSale){
                    customerBasicMapper.deleteDivisionInfo(channelSaleInfo.getChannelDivisionId());
                }
                customerBasicMapper.deleteSaleInfo(customerId);
            }

            if(customerId != -1){
                if(dockedContactInfoList != null && dockedContactInfoList.size()>1){
                    dockedContactInfoList.remove(0);
                    for (DockedContactInfo dockedContactInfo: dockedContactInfoList) {
                        dockedContactInfo.setCustomerId(customerId);
                        customerBasicMapper.saveDockedContactInfo(dockedContactInfo);
                    }
                }
                if(channelSaleInfoList != null && channelSaleInfoList.size()>1){
                    channelSaleInfoList.remove(0);
                    for (ChannelSaleInfo channelSaleInfo: channelSaleInfoList) {
                        channelSaleInfo.setCustomerId(customerId);
                        channelDivisionId = customerBasicMapper.queryIsExsitChannelNameChannelName(channelSaleInfo);
                        if(StringUtil.isNotEmpty(channelDivisionId)){
                            if(Integer.valueOf(channelDivisionId)>0){
                                channelSaleInfo.setChannelDivisionId(Integer.valueOf(channelDivisionId));
                                customerBasicMapper.saveChannelSaleInfo(channelSaleInfo);
                            }else{
                                customerBasicMapper.saveChannelDivisionInfo(channelSaleInfo);
                                customerBasicMapper.saveChannelSaleInfo(channelSaleInfo);
                            }
                        }else{
                            customerBasicMapper.saveChannelDivisionInfo(channelSaleInfo);
                            customerBasicMapper.saveChannelSaleInfo(channelSaleInfo);
                        }
                    }
                }
                billingInfo.setCustomerId(customerId);
                ticketOpeningInfo.setCustomerId(customerId);
                if(billingInfo.getBillingId()!=null){
                    customerBasicMapper.updateBillingInfo(billingInfo);
                }else{
                    customerBasicMapper.saveBillingInfo(billingInfo);
                }
                if(ticketOpeningInfo.getTicketOpeningId()!=null){
                    customerBasicMapper.updateOpeningInfo(ticketOpeningInfo);
                }else{
                    customerBasicMapper.saveTicketOpeningInfo(ticketOpeningInfo);
                }

            }
        }catch (Exception e){
            logger.error("修改客户信息失败"+e.getMessage());
            throw new RuntimeException("修改客户信息失败");
        }

    }
    public List<Province> queryProvinceList(String provinceId){
        return (List<Province>)customerBasicMapper.queryProvinceList(provinceId);
    }

    public List<City> queryCityList(String provinceId){
        return (List<City>)customerBasicMapper.queryCityList(provinceId);
    }

    public List<ChannelDivisionInfo> queryChannelCategoryList(String channelCategoryId){
        return (List<ChannelDivisionInfo>)customerBasicMapper.queryChannelCategoryList(channelCategoryId);
    }

    public List<ChannelDivisionInfo> queryChannelTypeList(String channelCategoryId){
        return (List<ChannelDivisionInfo>)customerBasicMapper.queryChannelTypeList(channelCategoryId);
    }

    public List<Product> queryPromotingProductsList(String promotingProductsInfo){
        return (List<Product>)customerBasicMapper.queryPromotingProductsList(promotingProductsInfo);
    }

    public List<ProductColor> querySupplyPriceList(String promotingProductsId){
        return (List<ProductColor>)customerBasicMapper.querySupplyPriceList(promotingProductsId);
    }
    /*@Override
    public void saveDockedContactInfo(DockedContactInfo dockedContactInfo) {
        customerBasicInfoSaveMapper.saveDockedContactInfo(dockedContactInfo);
    }

    @Override
    public void saveChannelSaleInfo(ChannelSaleInfo channelSaleInfo) {
        customerBasicInfoSaveMapper.saveChannelSaleInfo(channelSaleInfo);
    }

    @Override
    public void saveBillingInfo(BillingInfo billingInfo) {
        customerBasicInfoSaveMapper.saveBillingInfo(billingInfo);
    }

    @Override
    public void saveTicketOpeningInfo(TicketOpeningInfo ticketOpeningInfo) {
        customerBasicInfoSaveMapper.saveTicketOpeningInfo(ticketOpeningInfo);
    }*/

    @Override
    public Integer updateCustomerBasic(CustomerBasicInfo customerBasicInfo) {
        return customerBasicMapper.updateCustomerBasic(customerBasicInfo);
    }

    @Override
    public Integer updateBillingInfo(BillingInfo billingInfo) {
        return customerBasicMapper.updateBillingInfo(billingInfo);
    }

    @Override
    public Integer updateOpeningInfo(TicketOpeningInfo ticketOpeningInfo) {
        return customerBasicMapper.updateOpeningInfo(ticketOpeningInfo);
    }

    @Override
    public Integer deleteContactInfo(Integer customerId) {
        return customerBasicMapper.deleteContactInfo(customerId);
    }

    @Override
    public Integer deleteSaleInfo(Integer customerId) {
        return customerBasicMapper.deleteSaleInfo(customerId);
    }

    @Override
    public Integer deleteDivisionInfo(Integer channelDivisionId) {
        return customerBasicMapper.deleteDivisionInfo(channelDivisionId);
    }
    /*@Override
    public void saveDockedContactInfo(DockedContactInfo dockedContactInfo) {
        customerBasicInfoSaveMapper.saveDockedContactInfo(dockedContactInfo);
    }

    @Override
    public void saveChannelSaleInfo(ChannelSaleInfo channelSaleInfo) {
        customerBasicInfoSaveMapper.saveChannelSaleInfo(channelSaleInfo);
    }

    @Override
    public void saveBillingInfo(BillingInfo billingInfo) {
        customerBasicInfoSaveMapper.saveBillingInfo(billingInfo);
    }

    @Override
    public void saveTicketOpeningInfo(TicketOpeningInfo ticketOpeningInfo) {
        customerBasicInfoSaveMapper.saveTicketOpeningInfo(ticketOpeningInfo);
    }*/
}