package com.nova.sankuai.controller.v2;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.nova.sankuai.domain.api.yixin.response.YXAuditResponse;
import com.nova.sankuai.domain.api.yixin.response.YXCreditLimitResponse;
import com.nova.sankuai.domain.dto.*;
import com.nova.sankuai.domain.entity.City;
import com.nova.sankuai.domain.entity.Customer;
import com.nova.sankuai.domain.vo.Version4FlowPathVo;
import com.nova.sankuai.domain.vo.common.MapVo;
import com.nova.sankuai.infra.constants.ResultCode;
import com.nova.sankuai.infra.utils.ImageUtil;
import com.nova.sankuai.infra.utils.MapUtil;
import com.nova.sankuai.infra.utils.ResultJson;
import com.nova.sankuai.infra.utils.UserUtil;
import com.nova.sankuai.infra.utils.chuxin.ChuxinDataUtil;
import com.nova.sankuai.security.UserDetail;
import com.nova.sankuai.service.IChannelInfoService;
import com.nova.sankuai.service.ICustomerService;
import com.nova.sankuai.service.IYiXinService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.jetbrains.annotations.Nullable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.security.core.annotation.AuthenticationPrincipal;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;

import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @author weikangdi
 */
@Api(tags = "客户管理V2版本")
@RestController
@RequestMapping(value = "/api/v2/customer")
@AllArgsConstructor
@Slf4j
public class CustomerV2Controller {

    private final ICustomerService customerService;


    private final IChannelInfoService channelInfoService;

    private final IYiXinService yiXinService;

    private final ImageUtil imageUtil;

    // 身份证二要素验证工具类
    private final ChuxinDataUtil chuxinDataUtil;

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

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

    @GetMapping("/getCustomerUserNameAndIdCard")
    @ApiOperation(value = "获取用户姓名和身份证")
    public ResultJson<Map<String,String>> getCustomerUserNameAndIdCard(HttpServletRequest request) {
        String token = request.getHeader("Authorization");
        UserDetail user = UserUtil.getUser(token);
        Customer customer = customerService.getOne(Wrappers.lambdaQuery(Customer.class).eq(Customer::getPhone, user.getPhone()).orderByDesc(Customer::getApplyDate).last("LIMIT 1"));
        Map<String,String> map = new HashMap<>();
        map.put("name",customer.getName());
        map.put("idCard",customer.getIdCard());
        return ResultJson.ok(map);
    }

    @GetMapping("/searchPlace")
    @ApiOperation(value = "地址联想")
    @PreAuthorize("hasAuthority('customer.searchPlace')")
    public ResultJson<List<MapVo>> searchPlace(String query, String city) {
        if (StringUtils.isEmpty(query)) {
            return ResultJson.failure(ResultCode.SERVER_ERROR, "搜索关键字不能为空");
        }
        List<MapVo> place = MapUtil.searchPlace(query, city);
        return ResultJson.ok(place);
    }

    @PostMapping(value = "/appAddBasicInfo")
    @ApiOperation(value = "APP新增客户基本资料")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson appAddBasicInfo(@RequestBody CustomerBaseDto customer, String appId, HttpServletRequest request) {
        ResultJson checkResult = channelInfoService.checkChannel(appId, customer.toString());
        if (checkResult != null) {
            return checkResult;
        }
        String id = customerService.appAddBasicInfo(customer, appId, request);

        return ResultJson.ok(id);
    }

    @PostMapping(value = "/h5Match")
    @ApiOperation(value = "H5匹配资金方")
    public ResultJson h5Match(@RequestBody CustomerBaseDto customer, HttpServletRequest request) {
        return customerService.h5Match(customer, request);
    }

    @GetMapping(value = "/getH5Match")
    @ApiOperation(value = "根据手机号获取H5匹配资金方的信息")
    public ResultJson getH5Match(@RequestParam String phone) {
        return customerService.getH5Match(phone);
    }

    @PostMapping(value = "/appAddCapitalInfo")
    @ApiOperation(value = "APP新增客户资金方资料")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson appAddCapitalInfo(HttpServletRequest request, @RequestBody CustomerCapitalDto customer, String appId, String channelInfo) {
        log.info("客户资金方资料原始参数信息:" + customer.toString());
        ResultJson checkResult = channelInfoService.checkChannel(appId, customer.toString());
        if (checkResult != null) {
            return checkResult;
        }
        String id = customerService.appAddCapitalInfo(request, customer, appId, channelInfo);
        return ResultJson.ok(id);
    }

    @GetMapping(value = "/getTXFaceInfo")
    @ApiOperation(value = "人脸核身的SIGN和NONCE 信息")
    public ResultJson getTXFaceInfo(@RequestParam String phone, String name, String idNo, String channelInfo) {
        ResultJson resultJson = yiXinService.getTXFaceInfo(phone, name, idNo, channelInfo);
        return resultJson;
    }

    @GetMapping(value = "/checkIdCardTwo")
    @ApiOperation(value = "身份证二要素验证")
    public ResultJson checkIdCardTwo(@RequestParam String idCard, String name) {
        return chuxinDataUtil.getRemoteResult(idCard, name);
    }

    @GetMapping(value = "/getTXOcrInfo")
    @ApiOperation(value = "获取ocr签名信息")
    public ResultJson getTXOcrInfo(@RequestParam String phone, String channelInfo) {
        ResultJson resultJson = yiXinService.getTXOcrInfo(phone, channelInfo);
        return resultJson;
    }

    @PostMapping("/uploadBase64File")
    @ApiOperation(value = "上传base64图片")
    public ResultJson uploadBase64File(@RequestBody Base64InfoDto base64Info, HttpServletRequest request) {
        if (StringUtils.isEmpty(base64Info.getBase64Info())) {
            systemLogger.error("上传图片失败，图片内容为空" + base64Info);
            return ResultJson.failure(ResultCode.SERVER_ERROR, "上传图片失败，图片内容为空");
        }
        UserDetail user = null;
        try {
            String token = request.getHeader("Authorization");
            user = UserUtil.getUser(token);
            systemLogger.info("上传图片用户信息：" + user.toString());
            ResultJson resultJson = yiXinService.uploadBase64File(base64Info.getBase64Info());
            return resultJson;
        } catch (Exception e) {
            if (user != null) {
                systemLogger.error("上传base64图片出错，" + "登录用户信息:" + user.toString()
                        + "原始参数信息：" + base64Info + "错误日志详情：", e);
            } else {
                systemLogger.error("上传base64图片出错，原始参数信息：" + base64Info + "错误日志详情：", e);
            }
            return ResultJson.failure(ResultCode.SERVER_ERROR, "上传图片失败");
        }
    }

    @PostMapping("/yxUploadFile")
    @ApiOperation(value = "上传图片")
    public ResultJson yxUploadFile(HttpServletRequest request) {
        try {
            logger.info("file=====>:{}", request);
            MultipartHttpServletRequest req = (MultipartHttpServletRequest) request;

            //对应前端的upload的name参数"file"
            MultipartFile file = req.getFile("file");
            logger.info("file.getOriginalFilename=====>:{}", file.getOriginalFilename());
            logger.info("file.getBytes=====>:{}", file.getBytes());
            return ResultJson.ok(imageUtil.yxUploadFile(file, false));
        } catch (IOException e) {
            e.printStackTrace();
        }
        return ResultJson.failure(ResultCode.SERVER_ERROR);
    }


    @GetMapping(value = "/getYxContractListQuery")
    @ApiOperation(value = "宜信合同信息")
    public ResultJson getYxContractListQuery(@AuthenticationPrincipal UserDetail userDetail) {
        ResultJson resultJson = yiXinService.getYxContractListQuery(userDetail);
        return resultJson;
    }

    @PostMapping(value = "/appAddOCRInfo")
    @ApiOperation(value = "APP新增客户OCR+人脸识别资料")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson appAddOCRInfo(@RequestBody CustomerOcrDto customerOcrDto, String appId) {
//        logger.info("客户OCR+人脸识别资料原始参数信息:" + customerOcrDto.toString());
        ResultJson checkResult = channelInfoService.checkChannel(appId, customerOcrDto.toString());
        if (checkResult != null) {
            return checkResult;
        }
        String id = customerService.appAddOCRInfo(customerOcrDto, appId);
        return ResultJson.ok(id);
    }

    @PostMapping(value = "/appAddBankCardInfo")
    @ApiOperation(value = "APP新增客户银行卡信息")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson appAddBankCardInfo(@RequestBody CustomerBankCardDto customerBankCardDto, String appId) {
        log.info("客户银行卡资料原始参数信息:" + customerBankCardDto.toString());
        ResultJson checkResult = channelInfoService.checkChannel(appId, customerBankCardDto.toString());
        if (checkResult != null) {
            return checkResult;
        }
        String id = customerService.appAddBankCardInfo(customerBankCardDto, appId);
        return ResultJson.ok(id);
    }

    @GetMapping(value = "/getYxCreditAudit")
    @ApiOperation(value = "授信审批查询")
    public ResultJson getYxCreditAudit(@AuthenticationPrincipal UserDetail userDetail) {
        YXAuditResponse yxResponse = yiXinService.getYxCreditAudit(userDetail.getPhone());
        return ResultJson.ok(yxResponse);
    }


    @GetMapping(value = "/getYxCreditLimit")
    @ApiOperation(value = "额度查询接口")
    public ResultJson getYxCreditLimit(@AuthenticationPrincipal UserDetail userDetail) {
        YXCreditLimitResponse yxResponse = yiXinService.getYxCreditLimit(userDetail);
        return ResultJson.ok(yxResponse);
    }

    @PostMapping(value = "/appAddRepayInfo")
    @ApiOperation(value = "APP新增客户还款计划")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson appAddRepayInfo(@RequestBody CustomerRepayDto customerRepayDto, String appId) {
        ResultJson checkResult = channelInfoService.checkChannel(appId, customerRepayDto.toString());
        if (checkResult != null) {
            return checkResult;
        }
        String id = customerService.appAddRepayInfo(customerRepayDto, appId);
        return ResultJson.ok(id);
    }

    @GetMapping(value = "/rongYiTuiVip")
    @ApiOperation(value = "融易推用户会员购买")
    public UserDetail rongYiTuiVip(@AuthenticationPrincipal UserDetail userDetail, Integer vipCardType) {
        customerService.rongYiTuiVip(userDetail, vipCardType);
        return userDetail;
    }

    @GetMapping("/getUserIpCity")
    @ApiOperation(value = "根据用户ip获取城市信息")
    public ResultJson<City> getUserIpCity(HttpServletRequest request) {
        City userIpCity = customerService.getUserIpCity(request);
        return ResultJson.ok(userIpCity);
    }

    @GetMapping("/version4FlowPath")
    @ApiOperation(value = "4.0流程")
    public ResultJson<Version4FlowPathVo> version4FlowPath(@AuthenticationPrincipal UserDetail userDetail) {
        Version4FlowPathVo version4FlowPathVo = customerService.version4FlowPath(userDetail);
        return ResultJson.ok(version4FlowPathVo);
    }


    @PostMapping(value = "/appFourAddRelationInfo")
    @ApiOperation(value = "4.0开启下APP新增客户资料二")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson appFourAddRelationInfo(HttpServletRequest request, @RequestBody CustomerRelationDto customer, String appId, String channelInfo) {
        log.info("客户资金方资料原始参数信息:" + customer.toString());
        ResultJson checkResult = channelInfoService.checkChannel(appId, customer.toString());
        if (checkResult != null) {
            return checkResult;
        }
        String id = customerService.appFourAddRelationInfo(request, customer, appId, channelInfo);
        return ResultJson.ok(id);
    }

    @PostMapping(value = "/appFourAddCompanyInfo")
    @ApiOperation(value = "4.0开启下APP新增客户资料三")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson appFourAddCompanyInfo(HttpServletRequest request, @RequestBody CustomerCompanyDto customer, String appId, String channelInfo) {
        log.info("客户资金方资料原始参数信息:" + customer.toString());
        ResultJson checkResult = channelInfoService.checkChannel(appId, customer.toString());
        if (checkResult != null) {
            return checkResult;
        }
        String id = customerService.appFourAddCompanyInfo(request, customer, appId);
        return ResultJson.ok(id);
    }

    @PostMapping(value = "/appFiveAddAssetInfo")
    @ApiOperation(value = "新增资产信息")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson appFiveAddAssetInfo(HttpServletRequest request, @RequestBody CustomerAssetDto customer, String appId) {
        ResultJson checkResult = getResultJson(customer, appId);
        if (checkResult != null) return checkResult;
        String id = customerService.appFiveAddAssetInfo(request, customer, appId);
        return ResultJson.ok(id);
    }

    @PostMapping(value = "/h5FiveAddAssetInfo")
    @ApiOperation(value = "从浏览器新增资产信息")
    @PreAuthorize("hasAuthority('customer.appAdd')")
    public ResultJson h5FiveAddAssetInfo(HttpServletRequest request, @RequestBody CustomerAssetDto customer, String appId) {
        ResultJson checkResult = getResultJson(customer, appId);
        if (checkResult != null) return checkResult;
        String id = customerService.h5FiveAddAssetInfo(request, customer, appId);
        return ResultJson.ok(id);
    }

    @PostMapping(value = "/h5PushInfo")
    @ApiOperation(value = "浏览器推送数据")
    public ResultJson h5PushInfo(@RequestBody Customer customer) {// 这个接口不推送慧借钱包
        customerService.h5PushInfo(customer);
        return ResultJson.ok("ok");
    }

    @PostMapping(value = "/h5HjPushInfo")
    @ApiOperation(value = "浏览器推送数据给慧借钱包")
    public ResultJson h5HjPushInfo(@RequestBody Customer customer) {// 这个接口只推送慧借钱包
        customerService.h5PushInfoInclude(customer);
        return ResultJson.ok("ok");
    }

    @PostMapping(value = "/appPushInfo")
    @ApiOperation(value = "app推送数据")
    public ResultJson appPushInfo(HttpServletRequest request) {
        customerService.appPushInfo(request);
        return ResultJson.ok("ok");
    }

    @Nullable
    private ResultJson getResultJson(@RequestBody CustomerAssetDto customer, String appId) {
        log.info("客户资金方资料原始参数信息:" + customer.toString());
        ResultJson checkResult = channelInfoService.checkChannel(appId, customer.toString());
        if (checkResult != null) {
            return checkResult;
        }
        return null;
    }
}