package com.nova.sankuai.service.impl;

import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.nova.sankuai.domain.api.externalInterface.*;
import com.nova.sankuai.domain.dto.LoginUserDto;
import com.nova.sankuai.domain.entity.*;
import com.nova.sankuai.domain.enums.vipservice.VipCardTypeEnum;
import com.nova.sankuai.domain.vo.VipEffectiveTimeVo;
import com.nova.sankuai.domain.vo.auth.AutoLoginVo;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.constants.ResultCode;
import com.nova.sankuai.infra.mapper.*;
import com.nova.sankuai.infra.utils.RsaSecretUtils;
import com.nova.sankuai.infra.utils.UserUtil;
import com.nova.sankuai.security.JwtUtils;
import com.nova.sankuai.security.UserDetail;
import com.nova.sankuai.security.UserDetailUtil;
import com.nova.sankuai.service.IChannelInfoService;
import com.nova.sankuai.service.ICustomerUserService;
import com.nova.sankuai.service.IVipCardOrderLogService;
import com.nova.sankuai.service.UnionloginChannelService;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.DigestUtils;

import java.net.URLDecoder;
import java.nio.charset.StandardCharsets;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.Date;
import java.util.Objects;
import java.util.Random;

/**
 * @author weikangdi
 * @create 2021/11/8
 */
@Service
@AllArgsConstructor
@Slf4j
public class CustomerUserServiceImpl extends ServiceImpl<CustomerUserMapper, CustomerUser> implements ICustomerUserService {

    private final ChannelInfoMapper channelInfoMapper;

    private final VipCardMapper vipCardMapper;

    private final RsaSecretUtils rsaSecretUtils;

    private final UserDetailUtil userDetailUtil;

    private final JwtUtils jwtUtils;

    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();

    private final IChannelInfoService channelInfoService;

    private final IVipCardOrderLogService vipCardOrderLogService;

    private static final Logger logger = LoggerFactory.getLogger("payLogger");

    private final EIUtil eiUtil;

    private static final Logger autoLogger = LoggerFactory.getLogger("autoLogger");

    private final UnionloginChannelService unionloginChannelService;

    private final CustomerMapper customerMapper;
    private final CustomerUserLoginLogMapper customerUserLoginLogMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void registerUserByCustomer(Customer customer) {
        CustomerUser customerUserDb = lambdaQuery().eq(CustomerUser::getPhone, customer.getPhone()).one();
        if (customerUserDb == null) {
            String logNumber = IdUtil.randomUUID();
            autoLogger.info("日志编号" + logNumber + "通过申请记录注册新用户，用户手机号:" + customer.getPhone() + "渠道Code:" + customer.getSourceChannel());
            CustomerUser customerUser = new CustomerUser();
            customerUser.setName(customer.getName());
            customerUser.setPhone(customer.getPhone());
            customerUser.setCreationDate(new Date());
            customerUser.setSourceChannel(customer.getSourceChannel());
            //对姓名、手机号、身份证进行MD5加密
            String phoneMd5 = DigestUtils.md5DigestAsHex(customer.getPhone().getBytes());
            customerUser.setPhoneMd5(phoneMd5);
            String nameMd5 = DigestUtils.md5DigestAsHex(customer.getName().getBytes());
            customerUser.setNameMd5(nameMd5);
            if (StringUtils.isNotEmpty(customer.getIdCard())) {
                String idCardMd5 = DigestUtils.md5DigestAsHex(customer.getIdCard().getBytes());
                customerUser.setIdCardMd5(idCardMd5);
            }
            save(customerUser);
            autoLogger.info("日志编号" + logNumber + "通过申请记录注册新用户成功，用户Id" + customerUser.getId() + "，用户手机号" + customerUser.getPhone());
            customerUserDb = customerUser;
        } else {
            checkAndUpdateUser(customerUserDb, customer);
        }
        if (customer.getCustomerUserId() == null) {
            customerMapper.update(null, Wrappers.<Customer>lambdaUpdate()
                    .set(Customer::getCustomerUserId, customerUserDb.getId())
                    .eq(Customer::getId, customer.getId()));
        }
    }

    /**
     * 根据最新申请记录更新用户注册表信息
     *
     * @param customerUser
     * @param customer
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public void checkAndUpdateUser(CustomerUser customerUser, Customer customer) {
        boolean isUpdate = false;
        if (StringUtils.isNotEmpty(customer.getName()) && !customer.getName().equals(customerUser.getName())) {
            isUpdate = true;
        }
        if (!Objects.equals(customer.getIdCard(), customerUser.getIdCard())) {
            isUpdate = true;
        }
        if (isUpdate) {
            String nameMd5 = DigestUtils.md5DigestAsHex(customer.getName().getBytes());
            String idCardMd5 = null;
            if (StringUtils.isNotEmpty(customer.getIdCard())) {
                idCardMd5 = DigestUtils.md5DigestAsHex(customer.getIdCard().getBytes());
            }
            update(Wrappers.<CustomerUser>lambdaUpdate()
                    .set(CustomerUser::getName, customer.getName())
                    .set(CustomerUser::getNameMd5, nameMd5)
                    .set(CustomerUser::getIdCard, customer.getIdCard())
                    .set(CustomerUser::getIdCardMd5, idCardMd5)
                    .eq(CustomerUser::getId, customerUser.getId()));
        }
    }

    @Override
    public JSONObject autodownload(String autodownload) throws Exception {
        autoLogger.info("加密字符串：{}", autodownload);
        if (org.apache.commons.lang3.StringUtils.isBlank(autodownload)) {
            throw new Exception("加密字符串为空");
        }
        autodownload = URLDecoder.decode(autodownload, "UTF-8");
        // 将空格全部替换为+，不然会解密失败
        autodownload = autodownload.replaceAll(" ", "+");
        // 将autologin Base64解码
        byte[] contentBytes = rsaSecretUtils.base642Byte(autodownload);
        // 使用私钥解密
        String content = new String(rsaSecretUtils.privateDecrypt(contentBytes), StandardCharsets.UTF_8);
        // 序列化对象
        AutoLoginVo autoLoginVo = OBJECT_MAPPER.readValue(content, AutoLoginVo.class);
        // 数据校验
        if (StringUtils.isEmpty(autoLoginVo.getAppId())) {
            throw new Exception("appId为空");
        }
        if (StringUtils.isEmpty(autoLoginVo.getPhone())) {
            throw new Exception("phone为空");
        }
        boolean channelCodeEmpty = StringUtils.isEmpty(autoLoginVo.getChannelCode());
        boolean channelNameEmpty = StringUtils.isEmpty(autoLoginVo.getChannelName());
        if (!channelCodeEmpty || !channelNameEmpty) {
            if (channelNameEmpty || channelCodeEmpty) {
                throw new Exception("channelName和channelName必须同时存在");
            }
        }
        ChannelInfo channelInfo = channelInfoMapper.getChannelByAppId(autoLoginVo.getAppId());
        if (channelInfo == null) {
            throw new Exception("该渠道AppId不合法");
        }
        CustomerUser customerUser = getUserByPhone(autoLoginVo.getPhone());
        String appId = autoLoginVo.getAppId();
        if (!channelCodeEmpty) {
            appId = channelInfoService.createThirdChannel(autoLoginVo, channelInfo);
        }
        if (customerUser == null) {
            String logNumber = IdUtil.randomUUID();
            autoLogger.info("日志编号" + logNumber + "联登下载开始注册新用户，用户手机号:" + autoLoginVo.getPhone() + "渠道AppId:" + appId);
            customerUser = registerInitCustomerUser(autoLoginVo.getPhone(), appId, null, autoLoginVo.getBusinessType());
            autoLogger.info("日志编号" + logNumber + "联登下载注册新用户成功，用户Id" + customerUser.getId() + "，用户手机号" + customerUser.getPhone());
        }
        ChannelInfo channelInfoUser = channelInfoService.getOne(new LambdaQueryWrapper<ChannelInfo>().eq(ChannelInfo::getCode, customerUser.getSourceChannel()));
        if (channelInfoUser == null) {
            throw new Exception("用户渠道AppId不合法");
        }
        JSONObject params = userDetailUtil.getAutoDownloadUserJson(customerUser, channelInfoUser.getAppId());
        return params;
    }

    @Override
    public CustomerUser getCustomerUser(Long id) {
        return baseMapper.getCustomerUser(id);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public CustomerUser registerInitCustomerUser(String phone, String appId, Integer device, String businessType) {
        CustomerUser customerUserDb = lambdaQuery().eq(CustomerUser::getPhone, phone).one();
        if (StringUtils.isNotBlank(phone) && customerUserDb == null) {
            ChannelInfo channelInfo = channelInfoMapper.getChannelByAppId(appId);
            CustomerUser customerUser = new CustomerUser();
            customerUser.setPhone(phone);
            customerUser.setName(phone);
            customerUser.setCreationDate(new Date());
            customerUser.setDevice(device);
            customerUser.setSourceChannel(channelInfo.getCode());
            //对姓名和手机号进行MD5加密
            String phoneMd5 = DigestUtils.md5DigestAsHex(phone.getBytes());
            customerUser.setPhoneMd5(phoneMd5);
            customerUser.setNameMd5(phoneMd5);
            if (customerUser.getFirstQuota() == null) {
                Random random = new Random();
                int nextInt = 3 + random.nextInt(8);
                Integer quota = nextInt * 1000;
                customerUser.setFirstQuota(quota);
            }
            if (!StringUtils.isEmpty(businessType)) {
                customerUser.setBusinessType(businessType);
            }
            save(customerUser);
            return customerUser;
        }
        return customerUserDb;
    }


    @Override
    public CustomerUser getUser(LoginUserDto userDto) {
        CustomerUser customerUser = getUserByPhone(userDto.getPhone());
        if (customerUser == null) {
            String logNumber = IdUtil.randomUUID();
            autoLogger.info("日志编号" + logNumber + "登录时开始注册新用户，用户手机号:" + userDto.getPhone() + "渠道AppId:" + userDto.getAppId());
            customerUser = registerInitCustomerUser(userDto.getPhone(), userDto.getAppId(), userDto.getDevice(), null);
            autoLogger.info("日志编号" + logNumber + "登录时注册新用户成功，用户Id" + customerUser.getId() + "，用户手机号" + customerUser.getPhone());
        }
        //日志入库
        CustomerUserLoginLog customerUserLoginLog = new CustomerUserLoginLog();
        customerUserLoginLog.setPhone(customerUser.getPhone());
        customerUserLoginLog.setCreateTime(new Date());
        customerUserLoginLogMapper.insert(customerUserLoginLog);
        return customerUser;
    }


    @Override
    public CustomerUser getUserByPhone(String phone) {
        return lambdaQuery().eq(CustomerUser::getPhone, phone).eq(CustomerUser::getDeleteFlag, 0).one();
    }

    /**
     * 联登接口
     *
     * @param autologin
     */
    @Override
    public JSONObject autoLogin(String autologin) throws Exception {
        if (org.apache.commons.lang3.StringUtils.isBlank(autologin)) {
            throw new Exception("加密字符串为空");
        }
        // 将空格全部替换为+，不然会解密失败
        autologin = autologin.replaceAll(" ", "+");
        // 将autologin Base64解码
        byte[] contentBytes = rsaSecretUtils.base642Byte(autologin);
        // 使用私钥解密
        String content = new String(rsaSecretUtils.privateDecrypt(contentBytes), StandardCharsets.UTF_8);
        // 序列化对象
        AutoLoginVo autoLoginVo = OBJECT_MAPPER.readValue(content, AutoLoginVo.class);
        // 数据校验
        if (StringUtils.isEmpty(autoLoginVo.getAppId())) {
            throw new Exception("appId为空");
        }
        if (StringUtils.isEmpty(autoLoginVo.getPhone())) {
            throw new Exception("phone为空");
        }
        boolean channelCodeEmpty = StringUtils.isEmpty(autoLoginVo.getChannelCode());
        boolean channelNameEmpty = StringUtils.isEmpty(autoLoginVo.getChannelName());
        if (!channelCodeEmpty || !channelNameEmpty) {
            if (channelNameEmpty || channelCodeEmpty) {
                throw new Exception("channelName和channelName必须同时存在");
            }
        }
        ChannelInfo channelInfo = channelInfoMapper.getChannelByAppId(autoLoginVo.getAppId());
        if (channelInfo == null) {
            throw new Exception("该渠道AppId不合法");
        }
        CustomerUser customerUser = getUserByPhone(autoLoginVo.getPhone());
        String appId = autoLoginVo.getAppId();
        if (!channelCodeEmpty) {
            appId = channelInfoService.createThirdChannel(autoLoginVo, channelInfo);
        }
        if (customerUser == null) {
            String logNumber = IdUtil.randomUUID();
            autoLogger.info("日志编号" + logNumber + "联登跳转开始注册新用户，用户手机号:" + autoLoginVo.getPhone() + "渠道AppId:" + appId);
            customerUser = registerInitCustomerUser(autoLoginVo.getPhone(), appId, null, autoLoginVo.getBusinessType());
            autoLogger.info("日志编号" + logNumber + "联登跳转注册新用户成功，用户Id" + customerUser.getId() + "，用户手机号" + customerUser.getPhone());
        }
        UserDetail userDetail = userDetailUtil.parseCustomer(customerUser);
        String token = jwtUtils.generateToken(userDetail);
        UserUtil.setUser(token, userDetail);
        JSONObject params = userDetailUtil.getUserJson(userDetail, token);
        return params;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateVipEffectiveTime(VipCardOrder cardOrder, VipEffectiveTimeVo vipEffectiveTimeVo) {
        logger.info("开始更新会员有效日期，原始数据：" + cardOrder.toString() + vipEffectiveTimeVo.toString());
        VipCard card = vipCardMapper.selectOne(Wrappers.<VipCard>lambdaQuery()
                .eq(VipCard::getCardId, cardOrder.getCardId()));
        // 更新用户会员到期时间
        logger.info("更新用户会员到期时间 userId={}", cardOrder.getUserId());
        CustomerUser user = getOne(Wrappers.<CustomerUser>lambdaQuery()
                .eq(CustomerUser::getId, cardOrder.getUserId()));
        logger.info("更新用户会员到期时间 user={}", user);
        if (user == null) {
            logger.error("更新用户会员到期时间失败，用户不存在，原始数据" + cardOrder.toString());
            return;
        }
        if (vipEffectiveTimeVo == null) {
            logger.error("更新用户会员到期时间失败，更新的有效期为空，原始数据" + cardOrder.toString());
            return;
        }
        if (VipCardTypeEnum.MEMBER_SERVICE.getCode().equals(card.getVipType())) {
            update(Wrappers.<CustomerUser>lambdaUpdate()
                    .set(CustomerUser::getVipStartDate, vipEffectiveTimeVo.getVipStartDate())
                    .set(CustomerUser::getVipEndDate, vipEffectiveTimeVo.getVipEndDate())
                    .set(CustomerUser::getSeniorVipStartDate, vipEffectiveTimeVo.getVipStartDate())
                    .set(CustomerUser::getSeniorVipEndDate, vipEffectiveTimeVo.getVipEndDate())
                    .eq(CustomerUser::getId, user.getId()));
        } else if (VipCardTypeEnum.AUDIT_QUEUE.getCode().equals(card.getVipType())) {
            if (StringUtils.isNotEmpty(card.getQueueVipCode())) {
                user.setQueueVipCode(card.getQueueVipCode());
                update(Wrappers.<CustomerUser>lambdaUpdate()
                        .set(CustomerUser::getQueueVipCode, card.getQueueVipCode())
                        .eq(CustomerUser::getId, user.getId()));
            }
        } else if (VipCardTypeEnum.LOAN_MARKET_VIP.getCode().equals(card.getVipType())) {
            update(Wrappers.<CustomerUser>lambdaUpdate()
                    .set(CustomerUser::getLoanVipStartDate, vipEffectiveTimeVo.getVipStartDate())
                    .set(CustomerUser::getLoanVipEndDate, vipEffectiveTimeVo.getVipEndDate())
                    .set(CustomerUser::getVipCardId, card.getCardId())
                    .eq(CustomerUser::getId, user.getId()));
        } else if (VipCardTypeEnum.SENIOR_VIP.getCode().equals(card.getVipType())) {
            update(Wrappers.<CustomerUser>lambdaUpdate()
                    .set(CustomerUser::getSeniorVipStartDate, vipEffectiveTimeVo.getVipStartDate())
                    .set(CustomerUser::getSeniorVipEndDate, vipEffectiveTimeVo.getVipEndDate())
                    .set(CustomerUser::getVipStartDate, vipEffectiveTimeVo.getVipStartDate())
                    .set(CustomerUser::getVipEndDate, vipEffectiveTimeVo.getVipEndDate())
                    .eq(CustomerUser::getId, user.getId()));
        }
        vipCardOrderLogService.addOrderSuccessLog(cardOrder.getPartnerThirdOrderId(), cardOrder.getUserId());
    }

    @Override
    public VipEffectiveTimeVo calculateExpiredDate(Long userId, Integer day, Date startDate, Date endDate) {
        logger.info("更新用户会员到期时间 userId={}", userId);
        CustomerUser user = getOne(Wrappers.<CustomerUser>lambdaQuery()
                .eq(CustomerUser::getId, userId));
        Date from, to, today = new Date();
        if (day != null) {
            if (user.getVipStartDate() != null && user.getVipEndDate() != null && user.getVipStartDate().after(today)) {
                // 只修改到期时间
                from = user.getVipStartDate();
                to = addDay(user.getVipEndDate(), day);
            } else {
                from = today;
                to = addDay(today, day);
            }
            return new VipEffectiveTimeVo(from, to);
        } else if (day == null && startDate != null && endDate != null) {
            from = user.getVipStartDate();
            to = user.getVipEndDate();
            if (from == null) {
                from = startDate;
            }
            if (to == null) {
                to = endDate;
            } else {
                int compare = DateUtil.compare(endDate, user.getVipEndDate());
                if (compare > 0) {
                    to = endDate;
                }
            }
            return new VipEffectiveTimeVo(from, to);
        }
        logger.error("更新用户会员到期时间失败：转换最新会员有效时间失败，原始数据:UserId=" + userId
                + ",会员卡期限=" + day + ",会员开始时间=" + startDate + "会员结束时间=" + endDate);
        throw new CommonException("更新用户会员到期时间失败");
    }

    @Override
    public CustomerUser checkCustomer(String phone, String phoneMD5) {
        CustomerUser customerUser = null;
        if (!StringUtils.isEmpty(phone)) {
            customerUser = getOne(new LambdaQueryWrapper<CustomerUser>().eq(CustomerUser::getPhone, phone));
        } else {
            customerUser = getOne(new LambdaQueryWrapper<CustomerUser>().eq(CustomerUser::getPhoneMd5, phoneMD5));
        }
        return customerUser;
    }

    @Override
    public CheckUserResponse unionCheckUser(UserDto checkUserDto) {
        String uuId = IdUtil.randomUUID();
        CheckUserResponse checkUserResponse = new CheckUserResponse();
        ChannelInfo channelInfo = channelInfoMapper.getChannelByAppId(checkUserDto.getAppId());
        if (channelInfo == null) {
            throw new CommonException("该渠道AppId不合法");
        }
        if (StringUtils.isEmpty(checkUserDto.getData())) {
            throw new CommonException("参数data不能为空");
        }
        autoLogger.info("日志编号:" + uuId + "渠道方撞库原始数据" + checkUserDto.getData());
        CheckUserData checkUserData = eiUtil.checkUserDataParse(uuId, checkUserDto.getData());
        if (checkUserData != null) {
            autoLogger.info("日志编号:" + uuId + "渠道方撞库原始数据data" + checkUserData.toString());
        }
        if (checkUserData == null) {
            throw new CommonException("撞库解密转换失败");
        }
        if (StringUtils.isEmpty(checkUserData.getPhoneMd5())) {
            throw new CommonException("手机号不能为空");
        }
        CustomerUser customerUser = getOne(new LambdaQueryWrapper<CustomerUser>().eq(CustomerUser::getPhoneMd5, checkUserData.getPhoneMd5()));
        if (customerUser == null) {
            checkUserResponse.setCode(ResultCode.SUCCESS.getCode());
            checkUserResponse.setMsg("成功");
            checkUserResponse.setData(true);
        } else {
            checkUserResponse.setCode(ResultCode.SERVER_ERROR.getCode());
            checkUserResponse.setMsg("失败");
            checkUserResponse.setData(false);
        }
        return checkUserResponse;
    }

    @Override
    public RegisterResponse unionRegister(UserDto checkUserDto) {
        String uuId = IdUtil.randomUUID();
        RegisterResponse registerResponse = new RegisterResponse();
        ChannelInfo channelInfo = channelInfoMapper.getChannelByAppId(checkUserDto.getAppId());
        if (channelInfo == null) {
            throw new CommonException("该渠道AppId不合法");
        }
        if (StringUtils.isEmpty(checkUserDto.getData())) {
            throw new CommonException("参数data不能为空");
        }
        autoLogger.info("日志编号:" + uuId + "渠道方联登原始数据" + checkUserDto.getData());
        RegisterData registerData = eiUtil.rigisterDataParse(uuId, checkUserDto.getData());
        if (registerData != null) {
            autoLogger.info("日志编号:" + uuId + "渠道方联登原始数据data" + registerData.toString());
        }
        if (registerData == null) {
            throw new CommonException("联登解密转换失败失败");
        }
        if (StringUtils.isEmpty(registerData.getPhone())) {
            throw new CommonException("手机号不能为空");
        }
        CustomerUser customerUser = getOne(new LambdaQueryWrapper<CustomerUser>().eq(CustomerUser::getPhone, registerData.getPhone()));
        if (customerUser == null) {
            String logNumber = IdUtil.randomUUID();
            autoLogger.info("日志编号" + logNumber + "面向渠道方联登开始注册新用户，用户手机号:" + registerData.getPhone() + "渠道AppId:" + checkUserDto.getAppId());
            registerInitCustomerUser(registerData.getPhone(), checkUserDto.getAppId(), null, null);
            autoLogger.info("日志编号" + logNumber + "面向渠道方联登注册新用户成功，用户Id" + customerUser.getId() + "，用户手机号" + customerUser.getPhone());

        }
        registerResponse.setCode(ResultCode.SUCCESS.getCode());
        registerResponse.setMsg("成功");
        UnionloginChannel unionloginChannel = unionloginChannelService.getOne(new LambdaQueryWrapper<UnionloginChannel>()
                .eq(UnionloginChannel::getAppId, checkUserDto.getAppId()));
        if (unionloginChannel != null && StringUtils.isNotEmpty(unionloginChannel.getReturnUrl())) {
            if (unionloginChannel.getReturnUrl().contains("${autologin}")) {
                try {
                    JSONObject jsonObject = new JSONObject();
                    jsonObject.put("appId", checkUserDto.getAppId());
                    jsonObject.put("phone", registerData.getPhone());
                    byte[] bytes = rsaSecretUtils.publicEncrypt(jsonObject.toJSONString().getBytes());
                    String autologin = RsaSecretUtils.byte2Base64(bytes);
                    unionloginChannel.setReturnUrl(unionloginChannel.getReturnUrl().replace("${autologin}", autologin));
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            registerResponse.setUrl(unionloginChannel.getReturnUrl());
        }
        return registerResponse;
    }

    private Date addDay(Date before, int days) {
        LocalDateTime after = LocalDateTime.ofInstant(before.toInstant(), ZoneId.systemDefault()).plusDays(days);
        return Date.from(after.atZone(ZoneId.systemDefault()).toInstant());
    }
}