package com.nova.sankuai.controller.v1.platform;

import com.nova.sankuai.domain.api.xiamenzhongheyinhua.XiaMenZhongHeYinHuaResponse;
import com.nova.sankuai.domain.api.xiamenzhongheyinhua.XiaMenZhongHeYinHuaUtil;
import com.nova.sankuai.domain.entity.ApiCompany;
import com.nova.sankuai.domain.entity.ApiCompanyRecord;
import com.nova.sankuai.domain.entity.CustomerUser;
import com.nova.sankuai.domain.entity.ProtocolInfo;
import com.nova.sankuai.domain.enums.ApiCompanyCodeEnum;
import com.nova.sankuai.domain.vo.platform.ImportCustomerParameter;
import com.nova.sankuai.infra.config.CommonException;
import com.nova.sankuai.infra.constants.ResultCode;
import com.nova.sankuai.infra.utils.ResultJson;
import com.nova.sankuai.service.*;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.web.bind.annotation.*;

import javax.validation.Valid;
import java.util.Objects;

/**
 * <p>
 * 平台提供给其他系统调用的接口
 * </p>
 *
 * @author Zhangjc
 * @since 2021/11/18
 */
@Api(tags = "平台提供给其他系统调用的接口")
@RestController()
@RequestMapping("/api/v1/largecredit")
@RequiredArgsConstructor
@Slf4j
public class LargeCreditController {

    private final ICustomerService customerService;

    private final IChannelInfoService channelInfoService;

    private final IApiCompanyService apiCompanyService;

    private final IApiCompanyRecordService apiCompanyRecordService;

    private final IProtocolInfoService protocolInfoService;

    private final ICustomerUserService customerUserService;

    @ApiOperation("撞库测试")
    @GetMapping("/customCheck")
    public ResultJson<Boolean> checkCustomer(@RequestParam(name = "phone",required = false) String phone, @RequestParam(name = "phone_md5",required = false) String phoneMD5) {
        ResultJson<Boolean> result = new ResultJson<>(ResultCode.SUCCESS);
        if (StringUtils.isEmpty(phone) && StringUtils.isEmpty(phoneMD5)) {
            result.setData(false);
            result.setMsg("失败");
            result.setCode(ResultCode.BAD_REQUEST.getCode());
            return result;
        }
        CustomerUser customerUser = customerUserService.checkCustomer(phone, phoneMD5);
        if (customerUser == null) {
            result.setMsg("成功");
            result.setData(true);
        } else {
            result.setMsg("失败");
            result.setData(false);
        }
        return result;
    }

    @ApiOperation("爱助贷撞库测试")
    @GetMapping("/aizhudai/customCheck")
    public ResultJson<?> aizhudaiCustomCheck(@RequestParam String phone) {
        ApiCompany one = apiCompanyService.lambdaQuery()
                .eq(ApiCompany::getCompanyCode, ApiCompanyCodeEnum.XiaMenZhongHeYinHua.getCode())
                .eq(ApiCompany::getEnableFlag, 1).one();
        if (one != null) {
            Integer count = apiCompanyRecordService.lambdaQuery().eq(ApiCompanyRecord::getCompanyId, one.getId())
                    .eq(ApiCompanyRecord::getStatus, ApiCompanyRecord.SUCCESS).count();
            if (one.getCustomerNum() == null || count < one.getCustomerNum()) {
                XiaMenZhongHeYinHuaResponse checkResp = XiaMenZhongHeYinHuaUtil.phoneCheckExists(phone);
                if (Objects.equals(checkResp.getCode(), 0)) {
                    return ResultJson.ok(true);
                }
            }
        }
        return ResultJson.ok(false);
    }

    @ApiOperation("同步用户信息")
    @PostMapping("/customImport")
    public ResultJson<Boolean> importCustomer(@RequestBody @Valid ImportCustomerParameter parameter) {
        ResultJson<Boolean> result = new ResultJson<>(ResultCode.SUCCESS);
        CustomerUser customerUser = customerUserService.checkCustomer(parameter.getPhone(), null);
        if (customerUser != null) {
            log.info("撞库失败：手机号为：" + parameter.getPhone());
            result.setCode(ResultCode.SERVER_ERROR.getCode());
            result.setMsg("失败");
            result.setData(false);
            return result;
        }
        try {
            ResultJson checkResult = channelInfoService.checkChannel(parameter.getAppid(), parameter.toString());
            if (checkResult != null) {
                return checkResult;
            }
            log.info("导入其他平台用户开始,原始数据：" + parameter.toString());
            customerService.importCustomerFromPlatform(parameter);
            result.setMsg("成功");
            result.setData(true);
        } catch (CommonException e) {
            log.error("导入其他平台用户出错", e);
            result.setCode(ResultCode.SERVER_ERROR.getCode());
            result.setMsg(e.getMessage());
            result.setData(false);
        }
        return result;
    }

    @ApiOperation("爱助贷同步用户信息")
    @PostMapping("/aizhudai/customImport")
    public ResultJson aizhudaiCustomImport(@RequestBody @Valid ImportCustomerParameter parameter) {
        ResultJson<Boolean> result = new ResultJson<>(ResultCode.SUCCESS);
        try {
            ResultJson<?> checkResult = channelInfoService.checkChannel(parameter.getAppid(), parameter.toString());
            if (checkResult != null) {
                return checkResult;
            }
            log.info("爱助贷同步用户信息开始,原始数据：" + parameter);
            customerService.aizhudaiCustomImport(parameter);
            result.setMsg("成功");
            result.setData(true);
            log.info("爱助贷同步用户信息结束");
        } catch (CommonException e) {
            log.error("爱助贷同步用户信息出错", e);
            result.setCode(ResultCode.SERVER_ERROR.getCode());
            result.setMsg(e.getMessage());
            result.setData(false);
        }
        return result;
    }

    @GetMapping(value = "/getProtocol")
    @ApiOperation(value = "获取协议")
    public String getProtocol(String code) {
        ProtocolInfo protocolInfo = protocolInfoService.lambdaQuery().eq(ProtocolInfo::getCode, code).one();
        String content = "";
        if (protocolInfo != null) {
            content = String.format("<!DOCTYPE html><head><title></title><script>document.title=\"\\u200E\"</script></head><body>%s</body></html>", protocolInfo.getContent());
        }
        return content;
    }
}