签章

peter

2026-01-11 ab4f5aafb0d7b6d77a3108a6fb7084219c56a1cf

签章

 src/main/java/com/nq/controller/protol/UserController.java

@@ -484,8 +484,9 @@
     * 查看用户协议PDF
     */
    @RequestMapping({"viewAgreementPdf.do"})
    public void viewAgreementPdf(HttpServletRequest request, HttpServletResponse response) {
        this.iUserAgreementService.viewAgreementPdf(request, response);
    @ResponseBody
    public ServerResponse viewAgreementPdf(HttpServletRequest request) {
        return this.iUserAgreementService.viewAgreementPdf(request);
    }

    /**

 src/main/java/com/nq/service/IUserAgreementService.java

@@ -18,10 +18,9 @@
    /**
     * 查看用户协议PDF（返回图片路径列表）
     * @param request
     * @param response
     * @return
     */
    void viewAgreementPdf(HttpServletRequest request, HttpServletResponse response);
    ServerResponse viewAgreementPdf(HttpServletRequest request);

    /**
     * 保存用户协议签名

 src/main/java/com/nq/service/impl/UserAgreementServiceImpl.java

@@ -70,11 +70,8 @@
                dir.mkdirs();
            }

            String pdfFileName = "agreement_" + user.getId() + ".pdf";
            String pdfFileName = "contract_" + user.getId() + ".pdf";
            File pdfFile = new File(dir, pdfFileName);

            // 构建完整的PDF访问URL
//            String pdfUrl = PropertiesUtil.getProperty("pdf.server.http.prefix") + "/agreement_" + user.getId() + ".pdf";

            // 如果PDF已存在，删除后重新生成，确保数据是最新的
            if (pdfFile.exists()) {
@@ -109,7 +106,7 @@
     */
    private void generatePdfFromTemplate(File templatePdf, File outputPdf, User user) throws Exception {
        log.info("开始生成PDF，模板路径: {}, 输出路径: {}, 用户: {}",
                templatePdf.getAbsolutePath(), outputPdf.getAbsolutePath(), user.getId());
        templatePdf.getAbsolutePath(), outputPdf.getAbsolutePath(), user.getId());

        PdfReader reader = null;
        PdfStamper stamper = null;
@@ -354,37 +351,28 @@
    }

    @Override
    public void viewAgreementPdf(HttpServletRequest request, HttpServletResponse response) {
    public ServerResponse viewAgreementPdf(HttpServletRequest request) {
        try {
            User user = iUserService.getCurrentUser(request);
            if (user == null) {
                response.sendError(HttpServletResponse.SC_UNAUTHORIZED, "用户未登录");
                return;
                return ServerResponse.createByErrorMsg("用户未登录");
            }

            String pdfDir = PropertiesUtil.getProperty("loca.pdf.dir");
            String pdfFileName = "agreement_" + user.getId() + ".pdf";
            File pdfFile = new File(pdfDir, pdfFileName);

            if (!pdfFile.exists()) {
                response.sendError(HttpServletResponse.SC_NOT_FOUND, "协议文件不存在，请先生成协议");
                return;
            // 从数据库查询已签名的图片
            List<ContractImage> contractImages = contractImageMapper.selectByUserIdAndType(user.getId(), "contract");
            List<String> imageUrls = new ArrayList<>();
            
            if (contractImages != null && !contractImages.isEmpty()) {
                for (ContractImage image : contractImages) {
                    imageUrls.add(image.getAddress());
                }
                log.info("从数据库查询到用户{}的{}张已签名合同图片", user.getId(), imageUrls.size());
            }

            List<String> imageUrls = convertPdfToImages(pdfFile, "contract", user.getId());

            response.setContentType("application/json;charset=UTF-8");
            response.getWriter().write(JSON.toJSONString(ServerResponse.createBySuccess(imageUrls)));
            response.getWriter().flush();
            return ServerResponse.createBySuccess(imageUrls);
        } catch (Exception e) {
            log.error("查看用户协议PDF失败", e);
            try {
                if (!response.isCommitted()) {
                    response.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, "查看PDF失败: " + e.getMessage());
                }
            } catch (IOException ex) {
                log.error("发送错误响应失败", ex);
            }
            return ServerResponse.createByErrorMsg("查看PDF失败: " + e.getMessage());
        }
    }

@@ -414,34 +402,21 @@
            log.info("用户{}的签名图片已保存: {}", user.getId(), signatureFileLocal.getAbsolutePath());

            String pdfDir = PropertiesUtil.getProperty("loca.pdf.dir");
            String pdfFileName = "agreement_" + user.getId() + ".pdf";
            String pdfFileName = "contract_" + user.getId() + ".pdf";
            File pdfFile = new File(pdfDir, pdfFileName);

            //删之前的图片
            deleteFilesWithPattern(pdfDir,"contract_" + user.getId());
            if (pdfFile.exists()) {
                addSignatureToPdf(pdfFile, signatureFileLocal, user);

                List<String> imageUrls = convertPdfToImages(pdfFile, "contract", user.getId());

                String imagePrefix = PropertiesUtil.getProperty("pdf.server.http.prefix");
                long timestamp = System.currentTimeMillis();

                for (int i = 0; i < imageUrls.size(); i++) {
                    String imageName;
                    if (i == 0) {
                        imageName = "contract_" + timestamp + ".png";
                    } else {
                        imageName = "contract_" + timestamp + "_" + (i + 1) + ".png";
                    }
                    String imagePath = imagePrefix + "/" + imageName;

                for(String imageUrl : imageUrls) {
                    ContractImage contractImage = new ContractImage();
                    contractImage.setUserId(user.getId());
                    contractImage.setContractType("contract");
                    contractImage.setAddress(imagePath);
                    contractImage.setAddress(imageUrl);
                    contractImage.setAddTime(new Date());
                    contractImageMapper.insert(contractImage);
                }

                iUserService.updateSignedContract(user.getId(), "Y");
            }
            return ServerResponse.createBySuccessMsg("签名保存成功");
@@ -498,7 +473,7 @@
                return ServerResponse.createByErrorMsg("用户未登录");
            }

            if (StringUtils.isBlank(user.getRealName()) || StringUtils.isBlank(user.getIdCard()) || StringUtils.isBlank(user.getRegAddress())) {
            if (user.getIsActive()!=2 || StringUtils.isBlank(user.getRealName()) || StringUtils.isBlank(user.getIdCard()) || StringUtils.isBlank(user.getRegAddress())) {
                return ServerResponse.createByErrorMsg("用户信息不完整，请先完成实名认证");
            }

@@ -508,10 +483,8 @@
                dir.mkdirs();
            }

            String pdfFileName = "contract_" + user.getId() + ".pdf";
            String pdfFileName = "agreement_" + user.getId() + ".pdf";
            File pdfFile = new File(dir, pdfFileName);

            String pdfUrl = PropertiesUtil.getProperty("pdf.server.http.prefix") + "/contract_" + user.getId() + ".pdf";

            if (pdfFile.exists()) {
                boolean deleted = pdfFile.delete();
@@ -547,16 +520,16 @@
                return;
            }

            String pdfDir = PropertiesUtil.getProperty("loca.pdf.dir");
            String pdfFileName = "contract_" + user.getId() + ".pdf";
            File pdfFile = new File(pdfDir, pdfFileName);

            if (!pdfFile.exists()) {
                response.sendError(HttpServletResponse.SC_NOT_FOUND, "合同文件不存在，请先生成合同");
                return;
            // 从数据库查询已签名的图片
            List<ContractImage> contractImages = contractImageMapper.selectByUserIdAndType(user.getId(), "agreement");
            List<String> imageUrls = new ArrayList<>();
            
            if (contractImages != null && !contractImages.isEmpty()) {
                for (ContractImage image : contractImages) {
                    imageUrls.add(image.getAddress());
                }
                log.info("从数据库查询到用户{}的{}张已签名保密协议图片", user.getId(), imageUrls.size());
            }

            List<String> imageUrls = convertPdfToImages(pdfFile, "agreement", user.getId());

            response.setContentType("application/json;charset=UTF-8");
            response.getWriter().write(JSON.toJSONString(ServerResponse.createBySuccess(imageUrls)));
@@ -591,7 +564,7 @@
                dir.mkdirs();
            }

            String signatureFileName = "contract_signature_" + user.getId() + ".png";
            String signatureFileName = "agreement_signature_" + user.getId() + ".png";
            File signatureFileLocal = new File(dir, signatureFileName);

            signatureFile.transferTo(signatureFileLocal);
@@ -599,34 +572,22 @@
            log.info("用户{}的合同签名图片已保存: {}", user.getId(), signatureFileLocal.getAbsolutePath());

            String pdfDir = PropertiesUtil.getProperty("loca.pdf.dir");
            String pdfFileName = "contract_" + user.getId() + ".pdf";
            String pdfFileName = "agreement_" + user.getId() + ".pdf";
            File pdfFile = new File(pdfDir, pdfFileName);

            //删之前的图片
            deleteFilesWithPattern(pdfDir,"agreement_" + user.getId());
            if (pdfFile.exists()) {
                addSignatureToContractPdf(pdfFile, signatureFileLocal, user);

                List<String> imageUrls = convertPdfToImages(pdfFile, "agreement", user.getId());

                String imagePrefix = PropertiesUtil.getProperty("pdf.server.http.prefix");
                long timestamp = System.currentTimeMillis();

                for (int i = 0; i < imageUrls.size(); i++) {
                    String imageName;
                    if (i == 0) {
                        imageName = "agreement_" + timestamp + ".png";
                    } else {
                        imageName = "agreement_" + timestamp + "_" + (i + 1) + ".png";
                    }
                    String imagePath = imagePrefix + "/" + imageName;

                for (String imageUrl : imageUrls) {
                    ContractImage contractImage = new ContractImage();
                    contractImage.setUserId(user.getId());
                    contractImage.setContractType("agreement");
                    contractImage.setAddress(imagePath);
                    contractImage.setAddress(imageUrl);
                    contractImage.setAddTime(new Date());
                    contractImageMapper.insert(contractImage);
                }

                iUserService.updateSignedAgreement(user.getId(), "Y");
            }

@@ -662,7 +623,7 @@

    private void replacePlaceholdersInContractPdf(PdfContentByte canvas, Rectangle pageSize, String currentDate, Font font, int pageNum) throws Exception {
        float margin = 50;
        float startY = pageSize.getHeight() - 364;
        float startY = pageSize.getHeight() - 374;
        if(pageNum == 2){
            // 生成透明背景的日期图片并插入
            File dateImage = createTextImage(currentDate, font);
@@ -730,85 +691,6 @@
            return null;
        }
    }

    public static void main(String[] args) {
        try {
            String pdfDir = "D:/work/A-stock/agreement_pdf";
            String pdfFileName = "agreement_" + 19998 + ".pdf";
            File pdfFile = new File(pdfDir, pdfFileName);
            convertPdfToImages1(pdfFile,"agreement");
        }catch (Exception e){
            e.printStackTrace();
        }
    }
    /**
     * 将PDF转换为图片
     */
    public static void convertPdfToImages1(File pdfFile, String contractType) throws Exception {
        List<String> imageUrls = new ArrayList<>();
        String imagePrefix = "http://localhost:8099";
        String pdfDir = "D:/work/A-stock/agreement_pdf";

        long timestamp = System.currentTimeMillis();
        PDDocument document = null;
        try {
            document = PDDocument.load(pdfFile);

            // 创建PDFRenderer，使用高质量渲染
            PDFRenderer pdfRenderer = new PDFRenderer(document);

            int pageCount = document.getNumberOfPages();
            log.info("PDF总页数: {}", pageCount);

            for (int page = 0; page < pageCount; page++) {
                // 使用RGB模式渲染，DPI设置为300确保文字清晰
                // ImageType.RGB可以更好地处理中文字体
                BufferedImage image = pdfRenderer.renderImageWithDPI(page, 300, ImageType.RGB);

                // 对图片进行优化处理，确保文字清晰
                BufferedImage optimizedImage = optimizeImage1(image);

                String imageFileName = contractType + "_" + timestamp + ".png";
                if (page > 0) {
                    imageFileName = contractType + "_" + timestamp + "_" + (page + 1) + ".png";
                }
                File imageFile = new File(pdfDir, imageFileName);

                ImageIO.write(optimizedImage, "png", imageFile);

                String imageUrl = imagePrefix + "/imgs/" + imageFileName;
                imageUrls.add(imageUrl);

                log.info("PDF第{}页已转换为图片: {}", page + 1, imageUrl);
            }
        } finally {
            if (document != null) {
                document.close();
            }
        }

//        return imageUrls;
    }

    public static BufferedImage optimizeImage1(BufferedImage originalImage) {
        int width = originalImage.getWidth();
        int height = originalImage.getHeight();

        BufferedImage optimizedImage = new BufferedImage(width, height, BufferedImage.TYPE_INT_RGB);
        Graphics2D g2d = optimizedImage.createGraphics();

        // 设置高质量渲染
        g2d.setRenderingHint(RenderingHints.KEY_INTERPOLATION, RenderingHints.VALUE_INTERPOLATION_BILINEAR);
        g2d.setRenderingHint(RenderingHints.KEY_RENDERING, RenderingHints.VALUE_RENDER_QUALITY);
        g2d.setRenderingHint(RenderingHints.KEY_ANTIALIASING, RenderingHints.VALUE_ANTIALIAS_ON);
        g2d.setRenderingHint(RenderingHints.KEY_TEXT_ANTIALIASING, RenderingHints.VALUE_TEXT_ANTIALIAS_ON);
        g2d.setRenderingHint(RenderingHints.KEY_FRACTIONALMETRICS, RenderingHints.VALUE_FRACTIONALMETRICS_ON);

        g2d.drawImage(originalImage, 0, 0, null);
        g2d.dispose();

        return optimizedImage;
    }
    /**
     * 将PDF转换为图片
     */
@@ -836,15 +718,15 @@
                // 对图片进行优化处理，确保文字清晰
                BufferedImage optimizedImage = optimizeImage(image);

                String imageFileName = contractType + "_" + timestamp + ".png";
                String imageFileName = contractType + "_" +userId +"_" + timestamp + ".png";
                if (page > 0) {
                    imageFileName = contractType + "_" + timestamp + "_" + (page + 1) + ".png";
                    imageFileName = contractType+ "_" + userId + "_" + timestamp + "_" + (page + 1) + ".png";
                }
                File imageFile = new File(pdfDir, imageFileName);

                ImageIO.write(optimizedImage, "png", imageFile);

                String imageUrl = imagePrefix + "/imgs/" + imageFileName;
                String imageUrl = imagePrefix + "/" + imageFileName;
                imageUrls.add(imageUrl);

                log.info("PDF第{}页已转换为图片: {}", page + 1, imageUrl);
@@ -922,4 +804,23 @@
            return ServerResponse.createByErrorMsg("查询失败：" + e.getMessage());
        }
    }

    public void deleteFilesWithPattern(String dirPath, String userId) {
        File directory = new File(dirPath);
        if (!directory.exists() || !directory.isDirectory()) {
            System.out.println("目录不存在或路径错误: " + dirPath);
            return;
        }

        File[] files = directory.listFiles((dir, name) -> name.contains(userId + "_"));
        if (files != null) {
            for (File file : files) {
                if (file.delete()) {
                    System.out.println("已删除文件: " + file.getName());
                } else {
                    System.out.println("删除失败: " + file.getName());
                }
            }
        }
    }
}

 src/main/java/com/nq/service/impl/UserServiceImpl.java

@@ -118,10 +118,10 @@
        }


        String keys = "AliyunSmsCode:" + phone;
        String redis_yzm = RedisShardedPoolUtils.get(keys);

        log.info("redis_yzm = {},yzmCode = {}", redis_yzm, yzmCode);
//        String keys = "AliyunSmsCode:" + phone;
//        String redis_yzm = RedisShardedPoolUtils.get(keys);
//
//        log.info("redis_yzm = {},yzmCode = {}", redis_yzm, yzmCode);
//        if (!yzmCode.equals(redis_yzm) && !"6666".equals(yzmCode)) {
//            return ServerResponse.createByErrorMsg("注册失败, 验证码错误");
//        }
@@ -154,10 +154,19 @@
        user.setIsActive(Integer.valueOf(0));

        user.setRegTime(new Date());
        String uip = IpUtils.getIp(request);
        user.setRegIp(uip);
        String uadd = JuheIpApi.ip2Add(uip);
//        user.setRegAddress(uadd);
//        String uip = IpUtils.getIp(request);
//        user.setRegIp(uip);
//        // IP地址查询改为异步处理，避免阻塞注册接口
//        final String finalUip = uip;
//        final String finalPhone = phone;
//        new Thread(() -> {
//            try {
//                String uadd = JuheIpApi.ip2Add(finalUip);
//                log.info("用户注册IP地址查询完成 手机 {} , ip = {} 地址 = {}", finalPhone, finalUip, uadd);
//            } catch (Exception e) {
//                log.error("IP地址查询异常", e);
//            }
//        }).start();

        user.setIsLogin(Integer.valueOf(0));

@@ -183,7 +192,7 @@
            String newAgentCode = generateUniqueAgentCode();
            agentUser.setAgentCode(newAgentCode);
            iAgentUserService.updateAgentCode(agentUser);
            log.info("用户注册成功 手机 {} , ip = {} 地址 = {}", new Object[] { phone, uip, uadd });
            log.info("用户注册成功 手机 {} , ip = {}", phone, "123123");
            return ServerResponse.createBySuccessMsg("注册成功.请登录");
        }
        return ServerResponse.createBySuccessMsg("注册出错, 请重试");

 src/main/resources/application.properties

@@ -10,22 +10,28 @@
ftp.pass=ftp_red
ftp.server.http.prefix=https://ftp.shengliankeji.top/
loca.images.dir=/www/wwwroot/ftp.shengliankeji.top/
#??
#pdf.server.http.prefix=https://stockapdf.shengliankeji.top
#??
pdf.server.http.prefix=http://localhost:8099
#??
#loca.pdf.dir=/www/wwwroot/stock.A.PDF
#??
loca.pdf.dir=D:/work/A-stock/agreement_pdf
#??
#pdf.template.dir=/www/wwwroot/ftp.shengliankeji.top/templates
#??
pdf.template.dir=D:/work/A-stock/src/main/resources/templates
#????????????--??
pdf.server.http.prefix=https://stockapdf.shengliankeji.top
#????????????--??
#pdf.server.http.prefix=http://localhost:8099/imgs
#????????--??
loca.pdf.dir=/www/wwwroot/stock.A.PDF
#????????--??
#loca.pdf.dir=D:/work/A-stock/agreement_pdf
#????--??
pdf.template.dir=/www/wwwroot/ftp.shengliankeji.top/templates
#????--??
#pdf.template.dir=D:/work/A-stock/src/main/resources/templates
#ftp.server.ip=47.56.200.145
#ftp.user=ofsuccess
#ftp.pass=fdymdM34HHsS8iB6
#ftp.server.http.prefix=http://www.img.yfkgzq.com/
#??
sina.single.stock.sort.proxy.url=http://103.30.7.134:7001/crypto/getStockSort.do?
sina.single.stock.proxy.url=http://103.30.7.134:7001/crypto/getSinaStock?stockGid=
#??
#sina.single.stock.sort.proxy.url=http://localhost:7001/crypto/getStockSort.do?
#sina.single.stock.proxy.url=http://localhost:7001/crypto/getSinaStock?stockGid=

# redis config start
redis1.ip=localhost
@@ -93,10 +99,7 @@
sina.index.market.url=https://ws.api.cnyes.com/ws/api/v4/universal/quote?type=LITQ&column=L

sina.single.stock.url=https://hq.sinajs.cn/list=
sina.single.stock.sort.proxy.url=http://103.30.7.134:7001/crypto/getStockSort.do?
sina.single.stock.proxy.url=http://103.30.7.134:7001/crypto/getSinaStock?stockGid=
#sina.single.stock.sort.proxy.url=http://localhost:7001/crypto/getStockSort.do?
#sina.single.stock.proxy.url=http://localhost:7001/crypto/getSinaStock?stockGid=

#????
sina.single.stock.introduction.url=https://quotes.sina.cn/cn/api/openapi.php/CompanyF10Service.getCompanyInformation?market=cn&symbol=
nq.single.stock.url=http://192.168.10.5/stock/?type=

 src/main/resources/application.yml

@@ -104,12 +104,12 @@
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driverClassName: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/stock_hongta_101?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
    username: root
    password: 123456
#    url: jdbc:mysql://127.0.0.1:3306/stock_hongta_101?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
#    username: stock_hongta_101
#    password: mFi7EZKGmnJFh8at
#    username: root
#    password: 123456
    url: jdbc:mysql://127.0.0.1:3306/stock_hongta_101?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
    username: stock_hongta_101
    password: mFi7EZKGmnJFh8at
    druid:
      # 初始连接数
      initialSize: 5