package com.nova.sankuai.service.impl;

import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.nova.sankuai.domain.api.tongbao.TBResposeInfo;
import com.nova.sankuai.domain.api.tongbao.TBUtil;
import com.nova.sankuai.domain.api.weiyaquanyi.WeiYaConfigProperties;
import com.nova.sankuai.domain.api.weiyaquanyi.WeiYaKeyUtil;
import com.nova.sankuai.domain.api.weiyaquanyi.WeiYaRespVO;
import com.nova.sankuai.domain.api.weiyaquanyi.WeiYaUtil;
import com.nova.sankuai.domain.entity.CustomerUser;
import com.nova.sankuai.domain.entity.TongbaoLog;
import com.nova.sankuai.domain.entity.VipCard;
import com.nova.sankuai.domain.vo.MemberRightAutoLoginVo;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.mapper.CustomerUserMapper;
import com.nova.sankuai.infra.mapper.TongbaoLogMapper;
import com.nova.sankuai.infra.mapper.VipCardMapper;
import com.nova.sankuai.security.UserDetail;
import com.nova.sankuai.service.IMemberRightService;
import com.nova.sankuai.service.IShanTaiService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Service;

import java.util.Date;
import java.util.Objects;

/**
 * @Description 会员权益ServiceImpl
 * @Author CWR
 * @Date 2022/4/4 16:04
 */

@Slf4j
@Service
@AllArgsConstructor
public class MemberRightServiceImpl implements IMemberRightService {

    private final WeiYaUtil weiYaUtil;
    private final WeiYaConfigProperties properties;

    private final CustomerUserMapper customerUserMapper;

    private final VipCardMapper vipCardMapper;

    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();

    private final TongbaoLogMapper tongbaoLogMapper;

    private final IShanTaiService shanTaiService;
    /**
     * 渠道商用户开通会员卡回调
     *
     * @param userId          渠道侧会员id
     * @param channelMemberId 渠道侧会员卡id
     * @return
     */
    @Override
    public WeiYaRespVO channelMemberNotify(String userId, String channelMemberId) {
        return this.weiYaUtil.channelMemberNotify(userId, channelMemberId);
    }

    /**
     * 联登接口（AES加密请求参数并返回）
     *
     * @param vo 请求参数
     * @return
     */
    @Override
    public String autoLogin(MemberRightAutoLoginVo vo) throws JsonProcessingException {
        vo.setChannelCode(properties.getChannelCode());
        String json = OBJECT_MAPPER.writeValueAsString(vo);
        return WeiYaKeyUtil.encryptAES(json, properties.getAesSecretKey());
    }


    @Override
    public String getChannelMemberId(UserDetail user) {
        if (user == null) {
            throw new CommonException("用户不存在");
        }
        CustomerUser customerUser = customerUserMapper.selectOne(Wrappers.<CustomerUser>lambdaQuery()
                .eq(CustomerUser::getPhone, user.getPhone()));
        if (customerUser == null) {
            throw new CommonException("用户不存在");
        }
        int compare = DateUtil.compare(new Date(), customerUser.getVipEndDate());
        if (compare > 0) {
            throw new CommonException("当前用户不存在有效的会员权益");
        }
        if (StringUtils.isNotEmpty(customerUser.getVipCardId())) {
            return customerUser.getVipCardId();
        } else {
            VipCard vipCard = vipCardMapper.getVipLowestCard();
            return vipCard.getCardId();
        }
    }

    @Override
    public String membershipInterests(String phone) {
        //获取当前用户
        CustomerUser customerUser = customerUserMapper.selectOne(new LambdaQueryWrapper<CustomerUser>()
                .eq(CustomerUser::getPhone, phone));
        //判断当前用户是否已经开通会员权益 true为开通
        boolean ownership = isOwnership(customerUser);
        String h5Url = "";
        String serialNo = TBUtil.getOrder();
        if (!ownership) {
            //创建订单
            TBResposeInfo tbRespose = TBUtil.createOrder(customerUser, serialNo);
            if (tbRespose == null) {
                throw new CommonException("通宝会员权益创建订单失败");
            }
            //存储数据记录
            insertLog(customerUser, tbRespose, serialNo);
            //修改用户
            updateCustomer(customerUser, tbRespose);
            h5Url = TBUtil.getH5Url(tbRespose.getOrderNumber(), customerUser);
        } else {
            //判断该用户是不是绑卡闪态
            if (Objects.nonNull(customerUser)){
                h5Url = shanTaiService.getEquityUrl(customerUser);
            }
            if (Objects.isNull(h5Url)){
                h5Url = TBUtil.getH5Url(customerUser.getOrderNumber(), customerUser);
            }
        }
        return h5Url;

    }

    @Override
    public String manualMembershipInterests(String phone) {
        //获取当前用户
        CustomerUser customerUser = customerUserMapper.selectOne(new LambdaQueryWrapper<CustomerUser>()
                .eq(CustomerUser::getPhone, phone));
        boolean ownership = isOwnership(customerUser);
        if (!ownership) {
            String serialNo = TBUtil.getOrder();
            //创建订单
            TBResposeInfo tbRespose = TBUtil.createOrder(customerUser, serialNo);
            if (tbRespose == null) {
                throw new CommonException("通宝会员权益创建订单失败");
            }
            //存储数据记录
            insertLog(customerUser, tbRespose, serialNo);
            //修改用户
            updateCustomer(customerUser, tbRespose);
            return "操作成功";
        } else {
            throw new CommonException("该用户已开通会员权益");
        }
    }

    public boolean isOwnership(CustomerUser customerUser) {
        if (customerUser == null) {
            throw new CommonException("当前用户不存在");
        }
        Date date = new Date();
        if (customerUser.getVipStartDate() == null && customerUser.getVipEndDate() == null
                && customerUser.getSeniorVipStartDate() == null && customerUser.getSeniorVipEndDate() == null) {
            throw new CommonException("当前用户不是会员");
        } else if (date.getTime() > customerUser.getVipEndDate().getTime()) {
            throw new CommonException("当前用户会员已过期");
        }
        if (StringUtils.isEmpty(customerUser.getOrderNumber())) {
            return false;
        }
        return true;
    }

    public void insertLog(CustomerUser customerUser, TBResposeInfo tbRespose, String serialNo) {
        TongbaoLog tongbaoLog = new TongbaoLog();
        tongbaoLog.setCustomerUserId(customerUser.getId());
        tongbaoLog.setCreationDate(new Date());
        tongbaoLog.setOrderValidEndDay(tbRespose.getOrderValidEndDay());
        tongbaoLog.setOrderNumber(tbRespose.getOrderNumber());
        tongbaoLog.setPhone(customerUser.getPhone());
        tongbaoLog.setName(customerUser.getName());
        tongbaoLog.setSerialNo(serialNo);
        tongbaoLogMapper.insert(tongbaoLog);
    }


    public void updateCustomer(CustomerUser customerUser, TBResposeInfo tbRespose) {
        customerUserMapper.update(null, Wrappers.<CustomerUser>lambdaUpdate()
                .set(CustomerUser::getOrderNumber, tbRespose.getOrderNumber())
                .set(CustomerUser::getOrderValidEndDay, tbRespose.getOrderValidEndDay())
                .eq(CustomerUser::getId, customerUser.getId()));
    }

}