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.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nova.sankuai.domain.dto.*;
import com.nova.sankuai.domain.entity.Customer;
import com.nova.sankuai.domain.entity.CustomerUser;
import com.nova.sankuai.domain.entity.SysUser;
import com.nova.sankuai.domain.enums.*;
import com.nova.sankuai.domain.vo.WelcomePageHistory;
import com.nova.sankuai.domain.vo.WelcomePageVo;
import com.nova.sankuai.domain.vo.common.MessageCode;
import com.nova.sankuai.domain.vo.sysuser.AdminVo;
import com.nova.sankuai.domain.vo.sysuser.MechanismConfigVo;
import com.nova.sankuai.domain.vo.sysuser.MechanismVo;
import com.nova.sankuai.domain.vo.sysuser.StaffVo;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.constants.Constants;
import com.nova.sankuai.infra.mapper.CustomerMapper;
import com.nova.sankuai.infra.mapper.CustomerUserMapper;
import com.nova.sankuai.infra.mapper.DeductionRecordMapper;
import com.nova.sankuai.infra.mapper.SysUserMapper;
import com.nova.sankuai.infra.utils.*;
import com.nova.sankuai.security.JwtUtils;
import com.nova.sankuai.security.UserDetail;
import com.nova.sankuai.security.UserDetailUtil;
import com.nova.sankuai.service.*;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * @author weikangdi
 */
@Service
@AllArgsConstructor
@Slf4j
public class SysUserServiceImpl extends ServiceImpl<SysUserMapper, SysUser> implements ISysUserService {

    private final JwtUtils jwtUtils;

    private final SysUserMapper sysUserMapper;

    private final MessageSendUtil messageSendUtil;

    private final ICustomerService customerService;

    private final PageUtil pageUtil;

    private final DeductionRecordMapper deductionRecordMapper;

    private final UserDetailUtil userDetailUtil;

    private final IRoleUserService roleUserService;

    private final ICustomerUserService customerUserService;

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

    private final IChannelMechanismConfigService channelMechanismConfigService;

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

    private final CustomerMapper customerMapper;

    private final CustomerUserMapper customerUserMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void add(SysUser sysUser) {
        checkUser(sysUser);
        sysUser.setCreationDate(new Date());
        sysUser.setProduct(sysUser.getCompanyName());
        sysUser.setAmountLimit(100000);
        sysUser.setAnnualInterestRate(17.42);
        sysUser.setServiceSpeed(0);
        save(sysUser);
        roleUserService.setDefaultRole(sysUser.getId(), sysUser.getType());
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void edit(SysUser sysUser) {
        SysUser user = getById(sysUser.getId());
        if (user == null) {
            throw new CommonException("该用户不存在");
        }
        checkUser(sysUser);
        updateById(sysUser);
    }

    private void checkUser(SysUser sysUser) {
        SysUser sysUserDb = lambdaQuery().eq(SysUser::getUserPhone, sysUser.getUserPhone()).one();
        if (sysUserDb != null) {
            if (sysUser.getId() == null) {
                throw new CommonException("该手机号已经被使用");
            } else if (sysUser.getId() != null && !sysUserDb.getId().equals(sysUser.getId())) {
                throw new CommonException("该手机号已经被使用");
            }
        }
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void invalidUser(Long id, Integer status) {
        SysUser user = getById(id);
        if (user == null) {
            throw new CommonException("该用户不存在");
        }
        user.setStatus(status);
        updateById(user);
    }


    @Override
    public IPage<MechanismVo> page(SysUserPageDto sysUser, PageRequest pageRequest) {
        Page<SysUser> sysUserPage = new Page<>(pageRequest.getPageNo(), pageRequest.getPageSize());
        IPage<MechanismVo> result = sysUserMapper.pageModel(sysUserPage, sysUser);
        List<MechanismVo> records = new ArrayList<>();
        for (MechanismVo record : result.getRecords()) {
            record.setProductType(ProductTypeEnum.getValues(record.getProductType()));
            record.setProductAttributes(ProductAttributesEnum.getValues(record.getProductAttributes()));
            record.setProfessionInfo(ProfessionInfoEnum.getValues(record.getProfessionInfo()));
            records.add(record);
        }
        result.setRecords(records);
        return result;
    }

    @Override
    public MechanismVo selectOne(Long id) {
        SysUser sysUser = lambdaQuery().eq(SysUser::getId, id)
                .eq(SysUser::getType, UserTypeEnum.USER.getCode()).one();
        if (sysUser == null) {
            throw new CommonException("该用户不存在");
        }
        return MechanismVo.parse(sysUser);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public JSONObject smsLogin(LoginUserDto userDto) {
        JSONObject params = getJsonObject(userDto, false);
        return params;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public JSONObject otherSmsLogin(LoginUserDto userDto) {
        JSONObject params = getJsonObject(userDto, true);

        return params;
    }

    private JSONObject getJsonObject(LoginUserDto userDto, boolean isOther) {
        // 于2022-10-20修改：新增了测试手机 13182271165 是测试号 13828761749 是登录后台超级管理员，密码 686868
        if (("13868686868".equals(userDto.getPhone()) || "13182271165".equals(userDto.getPhone())
                || "13828761749".equals(userDto.getPhone()) || "15289944944".equals(userDto.getPhone())
                || "15289944674".equals(userDto.getPhone()) || "13520295299".equals(userDto.getPhone())
                || "15108937627".equals(userDto.getPhone()) || "15501883525".equals(userDto.getPhone())
                || userDto.getPhone().contains("8888")
        )
                && "686868".equals(userDto.getVerificationCode())) {
            logger.info("使用测试账号登录" + userDto);
        } else if (!Constants.SANDBOX_KEY.equals(userDto.getAppId())) {
            MessageCodeUtil.checkCode(userDto.getPhone(), userDto.getVerificationCode());
        }
        UserDetail userDetail = null;

        boolean hasRecord = false;// 用来专门处理小凌登录用的，别的用不到
        if (SourceTypeEnum.ADMIN.getCode().equals(userDto.getSource())) {
            SysUser sysUser = lambdaQuery().eq(SysUser::getUserPhone, userDto.getPhone()).eq(SysUser::getDefaultFlag, 0).one();
            if (sysUser != null) {
                if (Constants.UserStatus.DISABLE.equals(sysUser.getStatus())) {
                    throw new CommonException("该账号已经被禁用");
                }
                userDetail = userDetailUtil.parse(sysUser);
                sysUser.setLastLoginTime(new Date());
                saveOrUpdate(sysUser);
            }
        } else {
            CustomerUser customerUser = customerUserService.getUser(userDto);

            if (isOther) {
                // 判断是否有记录
                Customer user = customerService.getUser(userDto);
                hasRecord = user != null ? true : false;
            }

            if (userDto.getLoginSource() != null && CustomerUser.H5 == userDto.getLoginSource()) {
                customerUser.setH5LastUpdatedDate(new Date());
                customerUserService.update(Wrappers.<CustomerUser>lambdaUpdate()
                        .set(CustomerUser::getH5LastUpdatedDate, customerUser.getH5LastUpdatedDate())
                        .eq(CustomerUser::getId, customerUser.getId()));
            } else if (userDto.getLoginSource() != null && CustomerUser.APP == userDto.getLoginSource()){
                customerUser.setAppLastUpdatedDate(new Date());
                customerUserService.update(Wrappers.<CustomerUser>lambdaUpdate()
                        .set(CustomerUser::getAppLastUpdatedDate, customerUser.getAppLastUpdatedDate())
                        .eq(CustomerUser::getId, customerUser.getId()));
            }
            userDetail = userDetailUtil.parseCustomer(customerUser);
        }
        if (userDetail == null) {
            throw new CommonException("该账号不存在");
        }
        String token = jwtUtils.generateToken(userDetail);
        UserUtil.setUser(token, userDetail);
        JSONObject params = userDetailUtil.getUserJson(userDetail, token);
        MessageCodeUtil.CODE_LIST.remove(userDto.getPhone());

        // 若是专门给小凌登录用的
        if (isOther) {
            params.put("hasRecord", hasRecord);
        }
        return params;
    }

    @Override
    public void getCode(String phone, Integer source, String ip) {
        if (SourceTypeEnum.ADMIN.getCode().equals(source)) {
            SysUser sysUser = lambdaQuery().eq(SysUser::getUserPhone, phone).one();
            if (sysUser == null) {
                throw new CommonException("该账号不存在");
            }
        }
        logger.info("发送验证码" + phone);
        boolean verify = MessageCodeUtil.sendVerify(phone, ip, logger);
        logger.info("发送验证码校验" + verify);
        if (!verify) {
            return;
        }
        MessageCode messageCode = MessageCodeUtil.createCode(phone);
        MessageCodeUtil.setCode(phone, messageCode);
        MessageCodeUtil.setIpVerify(phone, ip);
        MessageCodeUtil.setPhoneVerify(phone, ip);
        boolean success = messageSendUtil.sendCode(phone, messageCode.getCode(), source, ip);
        if (!success) {
            throw new CommonException("验证码发送失败");
        }
    }

    @Override
    public WelcomePageVo welcomePage(Long userId) {
        WelcomePageVo pageVo = sysUserMapper.welcomePage(userId);
        Double expendAmount = deductionRecordMapper.getAllExpendAmount(userId);
        pageVo.setExpendAmount(expendAmount);
        pageVo.setAvailableAmount(pageVo.getUseAmount() - pageVo.getExpendAmount());
        pageVo.setGiftAmount(pageVo.getUseAmount() - pageVo.getRechargeAmount());
        Integer count = customerService.lambdaQuery().eq(Customer::getMechanismId, userId).count();
        pageVo.setCustomerCount(count != null ? count : 0);
        return pageVo;
    }

    @Override
    public IPage<WelcomePageHistory> welcomePageList(UserDetail user, WelcomePageDto pageDto, PageRequest pageRequest) {
        if (pageDto.getStartDate() == null && pageDto.getEndDate() == null) {
            pageDto.setEndDate(DateUtil.endOfDay(new Date()));
            pageDto.setStartDate(DateUtil.beginOfDay(DateUtil.offsetDay(new Date(), -5)));
        }
        return deductionRecordMapper.welcomePageList(pageUtil.getPage(pageRequest), pageDto, user.getId());
    }

    @Override
    public IPage<StaffVo> pageStaff(StaffDto staffDto, PageRequest pageRequest) {
        Page<SysUser> page = new Page<>(pageRequest.getPageNo(), pageRequest.getPageSize());
        return sysUserMapper.pageStaff(page, staffDto);
    }

    @Override
    public IPage<AdminVo> pageAdmin(AdminDto adminDto, PageRequest pageRequest) {
        Page<SysUser> page = new Page<>(pageRequest.getPageNo(), pageRequest.getPageSize());
        return sysUserMapper.pageAdmin(page, adminDto);
    }

    @Override
    public IPage<SysUserDto> pageSysUser(SysUserDto sysUserDto, PageRequest pageRequest) {
        Page<SysUser> page = new Page<>(pageRequest.getPageNo(), pageRequest.getPageSize());
        return sysUserMapper.pageSysUser(page, sysUserDto);
    }

    @Override
    public IPage<MechanismConfigVo> pageMechanismConfig(MechanismConfigPageDto pageDto, PageRequest pageRequest) {
        Page<SysUser> sysUserPage = new Page<>(pageRequest.getPageNo(), pageRequest.getPageSize());
        return sysUserMapper.pageMechanismConfig(sysUserPage, pageDto);
    }


    @Override
    @Transactional(rollbackFor = Exception.class)
    public void editMechanismConfig(MechanismConfigVo configVo) {
        SysUser sysUser = getById(configVo.getMechanismId());
        if (sysUser == null) {
            throw new CommonException("机构不存在");
        }
        sysUser.setProduct(configVo.getProduct());
        sysUser.setIconUrl(configVo.getIconUrl());
        sysUser.setAmountLimit(configVo.getAmountLimit());
        sysUser.setAnnualInterestRate(configVo.getAnnualInterestRate());
        sysUser.setServiceSpeed(configVo.getServiceSpeed());
        updateById(sysUser);
    }

    @Override
    public List<MechanismVo> getAssignableMechanism() {
        return sysUserMapper.getAssignableMechanism();
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void editMechanism(MechanismDto mechanismDto) {
        SysUser sysUser = mechanismDto.parseUser(mechanismDto);
        SysUser user = getById(sysUser.getId());
        if (user == null) {
            throw new CommonException("该用户不存在");
        }
        checkUser(sysUser);
        updateById(sysUser);
        channelMechanismConfigService.updateConfig(mechanismDto);
    }

    @Override
    public MechanismVo getMechanismById(Long mechanismId) {
        MechanismVo result = sysUserMapper.selectMechanismById(mechanismId);
        List<Long> channelIds = channelMechanismConfigService.getChannelsByMechanismId(result.getId());
        result.setChannelIds(channelIds);
        return result;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public String logoutUser(HttpServletRequest request) {
        String logNumber = IdUtil.randomUUID();
        String token = request.getHeader("Authorization");
        UserDetail userDetail = UserUtil.getUser(token);
        if (userDetail == null) {
            throw new CommonException("用户Token无效");
        }
        logout.info("日志编号" + logNumber + "注销用户开始：手机号为：{}", userDetail.getPhone());
        CustomerUser customerUser = customerUserService.getOne(new LambdaQueryWrapper<CustomerUser>()
                .eq(CustomerUser::getPhone, userDetail.getPhone()));
        if (customerUser == null) {
            logout.error("日志编号" + logNumber + "注销手机号" + userDetail.getPhone() + "注销失败：用户不存在");
            throw new CommonException("该用户不存在");
        }
        customerUserMapper.deleteById(customerUser.getId());
        logout.info("日志编号" + logNumber + "注销手机号" + userDetail.getPhone()
                + "注销customerUser记录：{}", customerUser);

        List<Customer> customerList = customerService.list(new LambdaQueryWrapper<Customer>()
                .eq(Customer::getPhone, userDetail.getPhone()));
        if (customerList != null && customerList.size() > 0) {
            List<Long> idLists = customerList.stream().map(Customer::getId).collect(Collectors.toList());
            customerMapper.deleteBatchIds(idLists);
            logout.info("日志编号" + logNumber + "注销手机号" + userDetail.getPhone()
                    + "注销customer申请记录列表：{}", customerList);
        }
        UserUtil.removeUserByToken(token);
        return "注销成功";
    }

}