package com.nova.sankuai.controller.v2;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.nova.sankuai.domain.entity.Customer;
import com.nova.sankuai.domain.entity.CustomerZcy;
import com.nova.sankuai.domain.entity.PlatformCapital;
import com.nova.sankuai.domain.entity.ProtocolInfo;
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.ICustomerService;
import com.nova.sankuai.service.ICustomerZcyService;
import com.nova.sankuai.service.IPlatformCapitalService;
import com.nova.sankuai.service.IProtocolInfoService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletResponse;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.List;
import java.util.Random;

/**
 * @author weikangdi
 * @create 2021/10/29
 */
@Api(tags = "协议管理V2")
@RestController
@RequestMapping(value = "/api/v2/protocolInfo")
@AllArgsConstructor
@Slf4j
public class ProtocolInfoV2Controller {

    private final IProtocolInfoService protocolInfoService;

    private final IPlatformCapitalService platformCapitalService;

    private final ICustomerService customerService;
    private final ICustomerZcyService customerZcyService;

    @GetMapping(value = "/getProtocol")
    @ApiOperation(value = "获取协议")
    public ResultJson<ProtocolInfo> getProtocol(String code) {
        ProtocolInfo protocolInfo = protocolInfoService.lambdaQuery().eq(ProtocolInfo::getCode, code).one();
        if (protocolInfo == null) {
            return ResultJson.failure(ResultCode.SERVER_ERROR, "没有找到对应的协议");
        }
        return ResultJson.ok(protocolInfo);
    }

    @GetMapping(value = "/getPlatformProtocol")
    @ApiOperation(value = "获取平台服务协议")
    public ResultJson<List<ProtocolInfo>> getPlatformProtocol() {
        List<ProtocolInfo> list = protocolInfoService.lambdaQuery().eq(ProtocolInfo::getAlias, "平台协议").list();
        if (list == null || list.size() == 0) {
            return ResultJson.failure(ResultCode.SERVER_ERROR, "没有找到对应的协议");
        }
        return ResultJson.ok(list);
    }

//    @GetMapping(value = "/getProtocolInfo.html")
    @GetMapping(value = "/getProtocolInfo/{code}/{id}.html")
    @ApiOperation(value = "获取协议2")
//    public void getProtocolInfo(HttpServletResponse response, Long id, String code) {
    public void getProtocolInfo(HttpServletResponse response, @PathVariable("id") Long id, @PathVariable("code") String code) {
        PlatformCapital platformCapital = platformCapitalService.lambdaQuery().eq(PlatformCapital::getId, id).one();
        if (platformCapital == null) {
            throw new CommonException("没有找到对应的对象信息");
        }
        LambdaQueryWrapper<Customer> wr = new LambdaQueryWrapper<>();
        wr.eq(Customer::getId, platformCapital.getCustomerId());
        wr.last(" limit 1 ");
        Customer customer = customerService.getOne(wr);
        if (customer == null) {
            throw new CommonException("没有找到对应的用户信息");
        }

        ProtocolInfo protocolInfo = protocolInfoService.lambdaQuery().eq(ProtocolInfo::getCode, code).one();
        if (protocolInfo == null) {
            throw new CommonException("没有找到对应的协议");
        }

        List<PlatformCapital> platformCapitalList = platformCapitalService.lambdaQuery().eq(PlatformCapital::getCustomerId, platformCapital.getCustomerId()).list();
        if (platformCapitalList == null) {
            throw new CommonException("没有找到对应的对象信息");
        }

        String content = protocolInfo.getContent();
        content = StringUtils.replace(content, "AAAAAA", customer.getName());
        content = StringUtils.replace(content, "BBBBBB", customer.getIdCard());

        String names = "";
//        String companys = "";

        for(PlatformCapital vo : platformCapitalList) {
//            ProductNameVo productNameVo = new ProductNameVo();
//            productNameVo.setProductName(vo.getProductName());
//            CompanyNameVo companyNameVo = new CompanyNameVo();
//            companyNameVo.setCompanyName(vo.getCompanyName());
//
//            productNameList.add(productNameVo);
//            compayNameList.add(companyNameVo);
            String productName = vo.getProductName() == null ? "" : vo.getProductName();
            names +=  productName + "；";
            String companyName = vo.getCompanyName() == null ? "" : vo.getCompanyName();
//            companys += companyName + "；";
        }

        if (names.length() > 0) {
            names = names.substring(0, names.length() - 1);
        }
//        if (companys.length() > 0) {
//            companys = companys.substring(0, companys.length() - 1);
//        }

        content = StringUtils.replace(content, "CCCCCC", names);
        content = StringUtils.replace(content, "DDDDDD", "杭州紫荆花互动广告有限公司");
        content = StringUtils.replace(content, "GGGGGG", "");
        content = StringUtils.replace(content, "EEEEEE", customer.getPhone());
        content = StringUtils.replace(content, "FFFFFF", generateSixDigitNumber());
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
        content = StringUtils.replace(content, "HHHHHH", dateFormat.format(System.currentTimeMillis()));

        // 生成HTML内容
        String htmlContent = "<html>\n" +
                "<head>\n" +
                "<meta charset=\"UTF-8\">\n" +
                "<title>个人信息共享授权协议</title>\n" +
                "</head>\n" +
                "<body>\n" +
                content + // 添加解析后的内容
                "\n</body>\n" +
                "</html>";

        try {
            // 创建PDF
//            PdfRendererBuilder builder = new PdfRendererBuilder();
//            builder.useFastMode();
//            builder.withHtmlContent(contentntent, null);
//            BufferedWriter writer = new BufferedWriter(new FileWriter("output.html"));
//            writer.write(htmlContent); // 写入HTML内容
//            writer.close(); // 关闭writer
            response.setContentType("text/html;charset=UTF-8"); // 设置HTTP响应的内容类型为PDF
//            response.setHeader("Content-Disposition", "attachment; filename=\"data.html\""); // 设置HTTP响应的头信息，告诉浏览器这是一个附件，建议保存的文件名为"data.pdf"
//            response.setHeader(HttpHeaders.CONTENT_DISPOSITION, "attachment;filename=" + URLEncoder.encode("个人信息共享授权协议.html", "UTF-8"));
//            response.setHeader("Content-disposition", "attachment;filename=" + new String(("个人信息共享授权协议.html").getBytes(StandardCharsets.UTF_8), "ISO8859-1"));
//            ByteArrayInputStream in = new ByteArrayInputStream(htmlContent.getBytes(StandardCharsets.UTF_8));
//            org.apache.commons.io.IOUtils.copy(in, response.getOutputStream());
// 上面一行利用Apache Commons IO库的IOUtils类的copy方法，
// 将PDF文件的内容（现在存储在ByteArrayInputStream 'in'）复制到HTTP响应的输出流中
// 这使得PDF的内容能够被发送到请求该服务的客户端
            byte[] isoBytes = htmlContent.getBytes("UTF-8");
            String html = new String(isoBytes, "ISO-8859-1");
            response.getOutputStream().println(html);
            response.flushBuffer(); // 刷新响应的缓冲区，完成响应的发送

        }
        catch (Exception ex) {
            log.error("getProtocolInfo Exception:{}", ex);
        }



//        CustomerProtocolInfo customerProtocolInfo = new CustomerProtocolInfo();
//        customerProtocolInfo.setName(customer.getName());
//        customerProtocolInfo.setPhone(customer.getPhone());
//        customerProtocolInfo.setIdCard(customer.getIdCard());
//        customerProtocolInfo.setContent(protocolInfo.getContent());
//        customerProtocolInfo.setProductNameList(productNameList);
//        customerProtocolInfo.setCompanyNameList(compayNameList);
//
//        return ResultJson.ok(customerProtocolInfo);
    }//    @GetMapping(value = "/getProtocolInfo.html")

    @GetMapping(value = "/getProtocolInfoWld/{code}/{id}.html")
    @ApiOperation(value = "获取协议3(我来贷)")
    public void getProtocolInfoByWld(HttpServletResponse response, @PathVariable("id") Long id, @PathVariable("code") String code) {
        PlatformCapital platformCapital = platformCapitalService.lambdaQuery().eq(PlatformCapital::getId, id).one();
        if (platformCapital == null) {
            throw new CommonException("没有找到对应的对象信息");
        }
        LambdaQueryWrapper<CustomerZcy> wr = new LambdaQueryWrapper<>();
        wr.eq(CustomerZcy::getId, platformCapital.getCustomerId());
        wr.last(" limit 1 ");
        CustomerZcy customer = customerZcyService.getOne(wr);
        if (customer == null) {
            throw new CommonException("没有找到对应的用户信息");
        }

        ProtocolInfo protocolInfo = protocolInfoService.lambdaQuery().eq(ProtocolInfo::getCode, code).one();
        if (protocolInfo == null) {
            throw new CommonException("没有找到对应的协议");
        }

        List<PlatformCapital> platformCapitalList = platformCapitalService.lambdaQuery().eq(PlatformCapital::getCustomerId, platformCapital.getCustomerId()).list();
        if (platformCapitalList == null) {
            throw new CommonException("没有找到对应的对象信息");
        }

        String content = protocolInfo.getContent();
        content = StringUtils.replace(content, "AAAAAA", customer.getName());
        content = StringUtils.replace(content, "BBBBBB", customer.getIdCard());

        StringBuilder names = new StringBuilder();

        for(PlatformCapital vo : platformCapitalList) {
            String productName = vo.getProductName() == null ? "" : vo.getProductName();
            names.append(productName).append("；");
        }

        if (names.length() > 0) {
            names = new StringBuilder(names.substring(0, names.length() - 1));
        }

        content = StringUtils.replace(content, "CCCCCC", names.toString());
        content = StringUtils.replace(content, "DDDDDD", "杭州紫荆花互动广告有限公司");
        content = StringUtils.replace(content, "GGGGGG", "");
        content = StringUtils.replace(content, "EEEEEE", customer.getPhone());
        content = StringUtils.replace(content, "FFFFFF", generateSixDigitNumber());
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
        content = StringUtils.replace(content, "HHHHHH", dateFormat.format(System.currentTimeMillis()));

        // 生成HTML内容
        String htmlContent = "<html>\n" +
                "<head>\n" +
                "<meta charset=\"UTF-8\">\n" +
                "<title>个人信息共享授权协议</title>\n" +
                "</head>\n" +
                "<body>\n" +
                content + // 添加解析后的内容
                "\n</body>\n" +
                "</html>";

        try {
            response.setContentType("text/html;charset=UTF-8"); // 设置HTTP响应的内容类型为PDF
            byte[] isoBytes = htmlContent.getBytes(StandardCharsets.UTF_8);
            String html = new String(isoBytes, StandardCharsets.ISO_8859_1);
            response.getOutputStream().println(html);
            response.flushBuffer(); // 刷新响应的缓冲区，完成响应的发送

        }
        catch (Exception ex) {
            log.error("getProtocolInfo Exception:{}", ex.getMessage());
        }
    }

    private String generateSixDigitNumber() {
        Random random = new Random();
        int randomNumber = 100000 + random.nextInt(999999); // 生成一个6位数，范围在100000到 999999 之间
        return randomNumber + "";
    }
}