项目初始化

.mvn/wrapper/maven-wrapper.properties

@@ -0,0 +1,19 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+wrapperVersion=3.3.2
+distributionType=only-script
+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.9/apache-maven-3.9.9-bin.zip

Dockerfile

@@ -0,0 +1,6 @@
+FROM openjdk:8
+
+EXPOSE 8801
+RUN echo "Asia/Shanghai" > /etc/timezone
+COPY target/loan-call-back-star.jar /app/loan-call-back-star.jar
+ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom","-jar","/app/loan-call-back-star.jar"]

docker-compose.yml

@@ -0,0 +1,22 @@
+version: '3'
+services:
+  loan-admin-api:
+    image: "loan-call-back-star:${app_tag_name}"
+    restart: always
+    logging:
+      options:
+        max-size: "1g"
+    environment:
+    - spring.profiles.active=test1
+    - log-path=log
+    # - VIRTUAL_HOST=loan-admin-api1.internal.jiebide.xin
+    # - LETSENCRYPT_HOST=test.risk.jiebide.xin
+    # - LETSENCRYPT_EMAIL=test.risk.jiebide.xin@yo.com
+    networks:
+    - nginx-proxy
+    volumes:
+    - /melonmobile/log/loan-call-back-star:/melonmobile/log/loan-call-back-star
+networks:
+  nginx-proxy:
+    external:
+      name: nginx-proxy

pom.xml

@@ -0,0 +1,82 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.1.0.RELEASE</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>com.tiangua</groupId>
+    <artifactId>star2</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>star2</name>
+    <description>Demo project for Spring Boot</description>
+    <url/>
+    <licenses>
+        <license/>
+    </licenses>
+    <developers>
+        <developer/>
+    </developers>
+    <scm>
+        <connection/>
+        <developerConnection/>
+        <tag/>
+        <url/>
+    </scm>
+    <properties>
+        <java.version>18</java.version>
+        <kirin-aliyun-oss-starter.version>1.0.0</kirin-aliyun-oss-starter.version>
+        <kirin-utils.version>1.0.2-SNAPSHOT</kirin-utils.version>
+        <kirin-api.version>1.0.2-SNAPSHOT</kirin-api.version>
+        <kirin-mbp-generator.version>1.0.2-SNAPSHOT</kirin-mbp-generator.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.2</version>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.tiangua.kirin</groupId>
+            <artifactId>kirin-api</artifactId>
+            <version>${kirin-api.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.tiangua.kirin</groupId>
+            <artifactId>kirin-utils</artifactId>
+            <version>${kirin-utils.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.tiangua.kirin</groupId>
+            <artifactId>kirin-mbp-generator</artifactId>
+            <version>${kirin-mbp-generator.version}</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+
+    </build>
+
+</project>

src/main/java/com/tiangua/star/Star2Application.java

@@ -0,0 +1,13 @@
+package com.tiangua.star;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class Star2Application {
+
+    public static void main(String[] args) {
+        SpringApplication.run(Star2Application.class, args);
+    }
+
+}

src/main/java/com/tiangua/star/controller/XinLuController.java

@@ -0,0 +1,45 @@
+package com.tiangua.star.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import com.tiangua.kirin.api.MessageResult;
+import com.tiangua.star.service.XinLuService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author
+ * @description 本应用 +诚易融 需求开发上线一共两天
+ *              流程：诚易融定时任务扫，将api存在starl的http推送过来
+ *                  本应用使用http请求接受，获取数据，并对应星级，然后返回诚意融，不用mq 没有为什么
+  * @project loan-supermarket-parent
+ * @date 2025/3/21 10:45:49
+ */
+@RestController
+@RequestMapping(value = "/xinlu")
+@Slf4j
+public class XinLuController {
+
+    @Autowired
+    private XinLuService xinLuService;
+
+    @PostMapping("/request")
+    public MessageResult<Integer> request(@RequestBody Map<String,List<JSONObject>> map) {
+        log.info("xinlu get begin");
+        List<JSONObject> data = map.get("data");
+        if (CollectionUtils.isEmpty(data)) {
+            log.info("xinlu 解析回传数据为null");
+            return MessageResult.ok();
+        }
+        xinLuService.processInstitutionData(data);
+        log.info("xinlu get end");
+        return MessageResult.ok();
+    }
+}

src/main/java/com/tiangua/star/model/UserStarFollowCallbackParam.java

@@ -0,0 +1,14 @@
+package com.tiangua.star.model;
+
+import lombok.Data;
+
+/**
+ *
+ *
+ * @author linsong
+ */
+@Data
+public class UserStarFollowCallbackParam {
+    private String followContent;
+    private String followTime;
+}

src/main/java/com/tiangua/star/model/XinLuUserStarCallbackParam.java

@@ -0,0 +1,25 @@
+package com.tiangua.star.model;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ *
+ * 用户星级回传 response
+ *
+ * @author linsong
+ */
+@Data
+public class XinLuUserStarCallbackParam {
+    private String customerName;
+    private String maskPhone;
+    private String followTime;
+    private Float starLevel;
+    private String followRemark;
+    private Integer productBizId;
+    private String busiId;
+    private List<UserStarFollowCallbackParam> callbackParamList;
+    private String importantDegreeStr;
+
+}

src/main/java/com/tiangua/star/service/XinLuService.java

@@ -0,0 +1,9 @@
+package com.tiangua.star.service;
+
+import com.alibaba.fastjson.JSONObject;
+
+import java.util.List;
+
+public interface XinLuService {
+    void processInstitutionData(List<JSONObject> jsonObjects);
+}

src/main/java/com/tiangua/star/service/impl/XinLuDataProcessor.java

@@ -0,0 +1,245 @@
+package com.tiangua.star.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+
+import com.tiangua.star.model.UserStarFollowCallbackParam;
+import com.tiangua.star.model.XinLuUserStarCallbackParam;
+import com.tiangua.star.service.XinLuService;
+import com.tiangua.star.util.HttpClientThreeUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.utils.URIBuilder;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
+import org.springframework.boot.SpringApplication;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.core.env.Environment;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.net.URISyntaxException;
+import java.nio.charset.StandardCharsets;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+@Service
+@Slf4j
+public class XinLuDataProcessor implements XinLuService {
+
+    // HTTP请求工具
+    private static final CloseableHttpClient httpClient = HttpClients.createDefault();
+
+
+//    @Value("${xinlu.callback.url}")
+//    private String url;
+
+
+//    @PostConstruct
+//    public void init() {
+//        System.out.println("Loaded XinLu callback URL: " + environment.getProperty("xinlu.callback.url"));
+//        System.out.println("Loaded XinLu callback URL: " + environment.getProperty("spring.application.name"));
+//        System.out.println("Loaded XinLu callback URL: " + environment.getProperty("spring.application.name"));
+////        log.info("Loaded XinLu callback URL: {}", url); // 查看日志输出
+//    }
+
+////    private static final String URL =  "https://loan-web-api2.internal.jiebide.xin/xinlu/callback";
+////    private static final String URL =  "https://api.hryk.net/xinlu/callback";
+    private static final String url =  "http://192.168.0.61:810/xinlu/callback";
+
+    /**
+     * 处理机构数据入口
+     * @param jsonObjects 包含productBizId和busiId的配置列表
+     */
+    @Override
+    public void processInstitutionData(List<JSONObject> jsonObjects) {
+        jsonObjects.forEach(config -> {
+            Integer institutionId = config.getInteger("institutionId");
+            String busiId = config.getString("busiId");
+            // 1. 根据institutionId获取对应URL
+            String targetUrl =  config.getString("starLevelBackInter");
+            if (targetUrl == null) {
+                log.warn("未找到institutionId={}对应的URL", institutionId);
+                return;
+            }
+            String currentDate = getCurrentDate();
+//            String testBegin = "2025-03-01";
+//            String testEnd = "2025-03-24";
+            // 2. 发送GET请求
+            String responseJson = sendGetRequest(targetUrl,1,currentDate,currentDate);
+//            String responseJson = sendGetRequest(targetUrl,1,testBegin,testEnd);
+            if (responseJson == null) return;
+            // 3. 解析并映射数据
+            List<XinLuUserStarCallbackParam> mappedData = parseAndMapData(responseJson, institutionId, busiId);
+            log.info("鑫路回传诚易融数据{},{}", institutionId,mappedData);
+            if (CollectionUtils.isEmpty(mappedData)) {
+                log.info("鑫路没有回传数据{},{}", institutionId,currentDate);
+                return;
+            }
+            // 4. 后续处理（存储/推送等）
+            handleMappedData(mappedData);
+        });
+    }
+
+    private String sendGetRequest(String originalUrl,int pageNum, String beginTime, String endTime){
+        HttpGet httpGet = new HttpGet(buildUrl(originalUrl,pageNum,beginTime,endTime));
+        try (CloseableHttpResponse response = httpClient.execute(httpGet)) {
+            int statusCode = response.getStatusLine().getStatusCode();
+            if (statusCode == 200) {
+               return EntityUtils.toString(response.getEntity(), StandardCharsets.UTF_8);
+            } else {
+                log.warn("请求失败，状态码：%d%n", statusCode);
+                return null;
+            }
+        } catch (IOException e) {
+            log.warn("HTTP请求异常，URL: %s%n", originalUrl);
+        }
+        return null;
+    }
+
+    private String buildUrl(String originalUrl, int pageNum, String beginTime, String endTime)  {
+        try {
+            URIBuilder uriBuilder = new URIBuilder(originalUrl.trim());
+            List<org.apache.http.NameValuePair> params = new ArrayList<>();
+            for (org.apache.http.NameValuePair param : uriBuilder.getQueryParams()) {
+                String name = param.getName();
+                if (!"pageNum".equals(name) && !"pageSize".equals(name) && !"beginTime".equals(name) && !"endTime".equals(name)) {
+                    params.add(param);
+                }
+            }
+            params.add(new org.apache.http.message.BasicNameValuePair("pageNum", String.valueOf(pageNum)));
+            params.add(new org.apache.http.message.BasicNameValuePair("pageSize", "100"));
+            params.add(new org.apache.http.message.BasicNameValuePair("beginTime", beginTime));
+            params.add(new org.apache.http.message.BasicNameValuePair("endTime", endTime));
+            uriBuilder.setParameters(params);
+            return uriBuilder.build().toString();
+        } catch (URISyntaxException e) {
+           log.error("buildUrl error",e);
+        }
+        return null;
+    }
+
+//    public List<Map<String, Object>> fetchAllData(String originalUrl, String beginTime, String endTime) {
+//        List<Map<String, Object>> allRows = new ArrayList<>();
+//        int pageNum = 1;
+//        int total = -1;
+//        int count = 0;
+//        while (count < 10) {
+//            try {
+//                String url = buildUrl(originalUrl, pageNum, beginTime, endTime);
+//                ApiResponse response = sendGetRequest(url);
+//                if (response == null || response.getCode() != 200) {
+//                    System.err.printf("请求失败，pageNum: %d%n", pageNum);
+//                    break;
+//                }
+//                if (total == -1) {
+//                    total = response.getTotal();
+//                    if (total == 0) break;
+//                }
+//                if (response.getRows() != null) {
+//                    allRows.addAll(response.getRows());
+//                }
+//                int currentSize = response.getRows() == null ? 0 : response.getRows().size();
+//                if (currentSize < 100 || allRows.size() >= total) {
+//                    break;
+//                }
+//                pageNum++;
+//                count++;
+//            } catch (URISyntaxException | IOException e) {
+//                System.err.println("请求异常: " + e.getMessage());
+//                break;
+//            }
+//        }
+//        return allRows;
+//    }
+
+    private List<XinLuUserStarCallbackParam> parseAndMapData(String json, Integer productBizId, String busiId) {
+        JSONObject responseData = JSON.parseObject(json);
+        
+        // 验证响应结构
+        if (responseData.getIntValue("code") != 200 || !responseData.containsKey("rows")) {
+            log.warn("无效的响应数据");
+            return Collections.emptyList();
+        }
+
+        // 解析rows数组
+        return responseData.getJSONArray("rows").stream()
+                .filter(obj -> {
+                    JSONObject item = (JSONObject) obj;
+                    return item.containsKey("importantDegree")
+                            && !Objects.isNull(item.getFloat("importantDegree"));
+                })
+                .map(obj -> {
+                    JSONObject item = (JSONObject) obj;
+                    XinLuUserStarCallbackParam param = new XinLuUserStarCallbackParam();
+
+                    // 基础字段映射
+                    param.setCustomerName(item.getString("name"));
+                    param.setMaskPhone(item.getString("phone"));
+                    param.setFollowTime(item.getString("customerCreateTime"));
+                    param.setStarLevel(item.getFloat("importantDegree"));
+                    param.setImportantDegreeStr(item.getString("importantDegreeStr"));
+                    
+                    // 从上游传入的字段
+                    param.setProductBizId(productBizId);
+                    param.setBusiId(busiId);
+
+                    // 处理跟进记录列表
+                    if (item.containsKey("cuFollowList") && CollectionUtils.isNotEmpty(item.getJSONArray("cuFollowList"))) {
+                        List<UserStarFollowCallbackParam> followParams = item.getJSONArray("cuFollowList")
+                                .stream()
+                                .map(followObj -> {
+                                    JSONObject follow = (JSONObject) followObj;
+                                    UserStarFollowCallbackParam followParam = new UserStarFollowCallbackParam();
+                                    followParam.setFollowContent(follow.getString("followContent"));
+                                    followParam.setFollowTime(follow.getString("followTime"));
+                                    return followParam;
+                                })
+                                .collect(Collectors.toList());
+                        param.setCallbackParamList(followParams);
+                    }
+                    
+                    return param;
+                })
+                .collect(Collectors.toList());
+    }
+
+    private void handleMappedData(List<XinLuUserStarCallbackParam> data) {
+        log.info("成功处理 {} 条映射数据 明细：{}", data.size(), data);
+        String post = HttpClientThreeUtil.post(url, JSON.toJSONString(data));
+        log.info("post结果：{}", post);
+    }
+
+    public static String getCurrentDate() {
+        LocalDate date = LocalDate.now(); // 获取当前日期
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        return date.format(formatter); // 格式化为字符串
+    }
+
+
+    public static void main(String[] args) {
+//        CloseableHttpClient httpClient = HttpClients.createDefault();
+//        ApiClient apiClient = new ApiClient(httpClient);
+//        String url = "https://xl.cdsxyc.com/api-xl/customer/verification/customerPlatformList/your_token";
+//        String beginTime = "2025-03-21";
+//        String endTime = "2025-03-21";
+//        List<Map<String, Object>> result = apiClient.fetchAllData(url, beginTime, endTime);
+//        System.out.println("获取数据条数: " + result.size());
+//        SpringApplication app = new SpringApplication(LoanCallBackStarApplication.class);
+//        app.setAdditionalProfiles("pre");  // 显式指定激活 pre 环境
+//        ConfigurableApplicationContext ctx = app.run(args);
+//            Environment env = ctx.getEnvironment();
+//            System.out.println("=== 当前配置 ===");
+//            System.out.println("server.port: " + env.getProperty("server.port"));
+//            System.out.println("xinlu.callback.url: " + env.getProperty("xinlu.callback.url"));
+    }
+
+}

src/main/java/com/tiangua/star/util/HttpClientThreeUtil.java

@@ -0,0 +1,303 @@
+package com.tiangua.star.util;
+
+import com.alibaba.fastjson.JSONObject;
+import com.tiangua.kirin.api.exception.ServiceException;
+import org.apache.http.Consts;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpStatus;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicHeader;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.protocol.HTTP;
+import org.apache.http.util.EntityUtils;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+public class HttpClientThreeUtil {
+
+
+    private static CloseableHttpClient httpClient = HttpClients.createDefault();
+
+
+    public static RequestConfig HUIRONG_CONFIG = RequestConfig.custom()
+            .setConnectTimeout(3500)
+            .setConnectionRequestTimeout(1500)
+            .setSocketTimeout(3500)
+            .build();
+
+
+    /**
+     * get
+     *
+     * @param url     请求的url
+     * @param queries 请求的参数，在浏览器？后面的数据，没有可以传null
+     * @return
+     */
+    public static String get(String url, Map<String, String> queries) {
+
+        String responseBody = "";
+        //支持https
+        StringBuilder sb = new StringBuilder(url);
+
+        if (queries != null && !queries.isEmpty()) {
+            boolean firstFlag = true;
+            for (Map.Entry<String, String> entry : queries.entrySet()) {
+                if (firstFlag) {
+                    sb.append("?").append(entry.getKey()).append("=").append(entry.getValue());
+                    firstFlag = false;
+                } else {
+                    sb.append("&").append(entry.getKey()).append("=").append(entry.getValue());
+                }
+            }
+        }
+
+        HttpGet httpGet = new HttpGet(sb.toString());
+        //设置超时
+        httpGet.setConfig(HUIRONG_CONFIG);
+        //HttpEntity
+        HttpEntity entity = null;
+        //请求数据
+        CloseableHttpResponse response = null;
+        try {
+            response = httpClient.execute(httpGet);
+            int status = response.getStatusLine().getStatusCode();
+            if (status == HttpStatus.SC_OK) {
+                entity = response.getEntity();
+                responseBody = EntityUtils.toString(entity);
+//                EntityUtils.consume(response.getEntity()); //会自动释放连接
+            }
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        } finally {
+            // 关闭连接,释放资源
+            if (entity != null) {
+                EntityUtils.consumeQuietly(entity); //会自动释放连接
+            }
+            if (response != null) {
+                try {
+                    response.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+        return responseBody;
+    }
+
+
+
+    /**
+     * post
+     *
+     * @param url     请求的url
+     * @param queries 请求的参数，在浏览器？后面的数据，没有可以传null
+     * @param params  post form 提交的参数
+     * @return
+     */
+    public static String post(String url, Map<String, String> queries, Map<String, String> params) {
+        String responseBody = "";
+        //支持https
+        StringBuilder sb = new StringBuilder(url);
+
+        if (queries != null && !queries.isEmpty()) {
+            boolean firstFlag = true;
+            for (Map.Entry<String, String> entry : queries.entrySet()) {
+                if (firstFlag) {
+                    sb.append("?").append(entry.getKey()).append("=").append(entry.getValue());
+                    firstFlag = false;
+                } else {
+                    sb.append("&").append(entry.getKey()).append("=").append(entry.getValue());
+                }
+            }
+        }
+
+        //指定url,和http方式
+        HttpPost httpPost = new HttpPost(sb.toString());
+        httpPost.setConfig(HUIRONG_CONFIG);
+        //添加参数
+        List<NameValuePair> nvps = new ArrayList<>();
+        if (params != null && !params.isEmpty()) {
+            for (Map.Entry<String, String> entry : params.entrySet()) {
+                nvps.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
+            }
+        }
+        httpPost.setEntity(new UrlEncodedFormEntity(nvps, Consts.UTF_8));
+        //HttpEntity
+        HttpEntity entity = null;
+        //请求数据
+        CloseableHttpResponse response = null;
+        try {
+            response = httpClient.execute(httpPost);
+            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
+                entity = response.getEntity();
+                responseBody = EntityUtils.toString(entity);
+//                EntityUtils.consume(response.getEntity()); //会自动释放连接
+            }
+        } catch (IOException ex) {
+            ex.printStackTrace();
+        } finally {
+            // 关闭连接,释放资源
+            if (entity != null) {
+                EntityUtils.consumeQuietly(entity); //会自动释放连接
+            }
+            if (response != null) {
+                try {
+                    response.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+        return responseBody;
+    }
+
+
+    /**
+     * post
+     *
+     * @param url  请求的url
+     * @param data post json 提交的参数
+     * @return
+     */
+    public static String post(String url, String data) {
+        String responseBody = "";
+
+        //指定url,和http方式
+        HttpPost httpPost = new HttpPost(url);
+        httpPost.setConfig(HUIRONG_CONFIG);
+        //设置类型
+        StringEntity se = new StringEntity(data, "utf-8");
+        se.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE, "application/json"));
+        httpPost.setEntity(se);
+        se.setContentType("application/json");
+        //HttpEntity
+        HttpEntity entity = null;
+        //请求数据
+        CloseableHttpResponse response = null;
+        try {
+            response = httpClient.execute(httpPost);
+            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
+                entity = response.getEntity();
+                responseBody = EntityUtils.toString(entity);
+            }else{
+                throw new ServiceException("接口调用异常：" + response.getStatusLine().getStatusCode() + "  " + url);
+            }
+        } catch (IOException ex) {
+            ex.printStackTrace();
+        } finally {
+            // 关闭连接,释放资源
+            if (entity != null) {
+                EntityUtils.consumeQuietly(entity); //会自动释放连接
+            }
+            if (response != null) {
+                try {
+                    response.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+        return responseBody;
+    }
+
+    public static String post(String url, String data,String mchId) {
+        String responseBody = "";
+
+        //指定url,和http方式
+        HttpPost httpPost = new HttpPost(url);
+        httpPost.setConfig(HUIRONG_CONFIG);
+
+        //设置类型
+        StringEntity se = new StringEntity(data, "utf-8");
+        httpPost.addHeader("Content-Type", "text/xml");
+        httpPost.addHeader("User-Agent", "wxpay sdk java v1.0 " + mchId);
+        httpPost.setEntity(se);
+        //HttpEntity
+        HttpEntity entity = null;
+        //请求数据
+        CloseableHttpResponse response = null;
+        try {
+            response = httpClient.execute(httpPost);
+            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
+                entity = response.getEntity();
+                responseBody = EntityUtils.toString(entity);
+            }
+        } catch (IOException ex) {
+            ex.printStackTrace();
+        } finally {
+            // 关闭连接,释放资源
+            if (entity != null) {
+                EntityUtils.consumeQuietly(entity); //会自动释放连接
+            }
+            if (response != null) {
+                try {
+                    response.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+        return responseBody;
+    }
+
+
+    /**
+     * 发送HTTP POST请求 带头
+     * @param url
+     * @param headers
+     * @param requestBody
+     * @return
+     * @throws Exception
+     */
+    public static String sendHttpPostRequest(String url, Map<String, String> headers, JSONObject requestBody) throws Exception {
+        HttpPost httpPost = new HttpPost(url);
+
+        // 设置请求头
+        for (Map.Entry<String, String> entry : headers.entrySet()) {
+            httpPost.setHeader(entry.getKey(), entry.getValue());
+        }
+
+        // 设置请求体
+        StringEntity requestEntity = new StringEntity(requestBody.toString(), "UTF-8");
+        requestEntity.setContentType("application/json");
+        httpPost.setEntity(requestEntity);
+
+        // 发送请求并获取响应
+        String responseBody = "";
+        CloseableHttpResponse response = null;
+        try {
+            response = httpClient.execute(httpPost);
+            int statusCode = response.getStatusLine().getStatusCode();
+            if (statusCode == HttpStatus.SC_OK) {
+                HttpEntity entity = response.getEntity();
+                responseBody = EntityUtils.toString(entity, "UTF-8");
+            } else {
+                throw new Exception("HTTP request failed with status code: " + statusCode);
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            // 释放资源
+            if (response != null) {
+                try {
+                    response.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+
+        return responseBody;
+    }
+}

src/main/resources/application-pre.yml

@@ -0,0 +1,10 @@
+server:
+  port: 8801
+spring:
+  application:
+    name: loan-call-back-star
+
+xinlu:
+  callback:
+    url: https://loan-web-api2.internal.jiebide.xin/xinlu/request
+

src/main/resources/application-prod.yml

@@ -0,0 +1,11 @@
+# tomcat配置
+server:
+  port: 8801
+spring:
+  application:
+    name: loan-call-back-star
+
+
+xinlu:
+  callback:
+    url: https://api.hryk.net/xinlu/request

src/main/resources/application.yml

@@ -0,0 +1,6 @@
+spring:
+  profiles:
+    active: pre
+logging.config: classpath:logback-${spring.profiles.active}.xml
+
+

src/main/resources/logback-pre.xml

@@ -0,0 +1,61 @@
+<configuration>
+    <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
+    <property name="PROJECT_NAME" value="loan-admin-api"/>
+    <property name="LOG_HOME"  value="/melonmobile/log/${PROJECT_NAME}/pre"/>
+
+    <!-- 控制台输出 -->
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS}[%X{X-B3-TraceId:-},%X{X-B3-SpanId:-}] [%thread] %-5level %logger{50} - %msg%n</pattern>
+            <!-- 记录日志的编码 -->
+            <charset>UTF-8</charset> <!-- 此处设置字符集 -->
+        </encoder>
+    </appender>
+    <!-- 按照每天生成日志文件   -->
+    <appender name="dailyFile"  class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!-- 日志文件输出的文件名 -->
+            <FileNamePattern>${LOG_HOME}/${PROJECT_NAME}.log.%d{yyyy-MM-dd}.log</FileNamePattern>
+            <MaxHistory>30</MaxHistory>
+        </rollingPolicy>
+        <encoder>
+            <!-- 格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 -->
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS}[%X{X-B3-TraceId:-},%X{X-B3-SpanId:-}] [%thread] %-5level %logger{50} - %msg%n</pattern>
+            <!-- 记录日志的编码 -->
+            <charset>UTF-8</charset> <!-- 此处设置字符集 -->
+        </encoder>
+    </appender>
+
+    <appender name="errorFile" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!--日志文件输出的文件名-->
+            <FileNamePattern>${LOG_HOME}/${PROJECT_NAME}.error.log.%d{yyyy-MM-dd}.log</FileNamePattern>
+            <!--日志文件保留天数-->
+            <MaxHistory>30</MaxHistory>
+        </rollingPolicy>
+        <!-- 所有error日志都在这里-->
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>ERROR</level>
+            <onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>
+        </filter>
+        <encoder>
+            <!-- 格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 -->
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS}[%X{X-B3-TraceId:-},%X{X-B3-SpanId:-}] [%thread] %-5level %logger{50} - %msg%n</pattern>
+            <!-- 记录日志的编码 -->
+            <charset>UTF-8</charset> <!-- 此处设置字符集 -->
+        </encoder>
+    </appender>
+
+    <!-- 日志输出级别 -->
+    <root level="info">
+        <appender-ref ref="STDOUT" level="info"/>
+        <appender-ref ref="dailyFile" />
+        <appender-ref ref="errorFile" />
+    </root>
+    <!-- 指定项目中某个包，当有日志操作行为时的日志记录级别 -->
+    <!-- com.tml为根包，也就是只要是发生在这个根包下面的所有日志操作行为的权限都是DEBUG -->
+    <!-- 级别依次为【从高到低】：FATAL > ERROR > WARN > INFO > DEBUG > TRACE  -->
+    <logger name="com.tiangua.adminapi.dao" level="debug"/>
+    <logger name="com.tiangua.common.dao" level="debug"/>
+</configuration>

src/main/resources/logback-prod.xml

@@ -0,0 +1,61 @@
+<configuration>
+    <!--定义日志文件的存储地址 勿在 LogBack 的配置中使用相对路径-->
+    <property name="PROJECT_NAME" value="loan-admin-api"/>
+    <property name="LOG_HOME"  value="/melonmobile/log/${PROJECT_NAME}"/>
+
+    <!-- 控制台输出 -->
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS}[%X{X-B3-TraceId:-},%X{X-B3-SpanId:-}] [%thread] %-5level %logger{50} - %msg%n</pattern>
+            <!-- 记录日志的编码 -->
+            <charset>UTF-8</charset> <!-- 此处设置字符集 -->
+        </encoder>
+    </appender>
+    <!-- 按照每天生成日志文件   -->
+    <appender name="dailyFile"  class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!-- 日志文件输出的文件名 -->
+            <FileNamePattern>${LOG_HOME}/${PROJECT_NAME}.log.%d{yyyy-MM-dd}.log</FileNamePattern>
+            <MaxHistory>30</MaxHistory>
+        </rollingPolicy>
+        <encoder>
+            <!-- 格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 -->
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS}[%X{X-B3-TraceId:-},%X{X-B3-SpanId:-}] [%thread] %-5level %logger{50} - %msg%n</pattern>
+            <!-- 记录日志的编码 -->
+            <charset>UTF-8</charset> <!-- 此处设置字符集 -->
+        </encoder>
+    </appender>
+
+    <appender name="errorFile" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <!--日志文件输出的文件名-->
+            <FileNamePattern>${LOG_HOME}/${PROJECT_NAME}.error.log.%d{yyyy-MM-dd}.log</FileNamePattern>
+            <!--日志文件保留天数-->
+            <MaxHistory>30</MaxHistory>
+        </rollingPolicy>
+        <!-- 所有error日志都在这里-->
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>ERROR</level>
+            <onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>
+        </filter>
+        <encoder>
+            <!-- 格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符 -->
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS}[%X{X-B3-TraceId:-},%X{X-B3-SpanId:-}] [%thread] %-5level %logger{50} - %msg%n</pattern>
+            <!-- 记录日志的编码 -->
+            <charset>UTF-8</charset> <!-- 此处设置字符集 -->
+        </encoder>
+    </appender>
+
+    <!-- 日志输出级别 -->
+    <root level="info">
+        <appender-ref ref="STDOUT" level="info"/>
+        <appender-ref ref="dailyFile" />
+        <appender-ref ref="errorFile" />
+    </root>
+    <!-- 指定项目中某个包，当有日志操作行为时的日志记录级别 -->
+    <!-- com.tml为根包，也就是只要是发生在这个根包下面的所有日志操作行为的权限都是DEBUG -->
+    <!-- 级别依次为【从高到低】：FATAL > ERROR > WARN > INFO > DEBUG > TRACE  -->
+    <logger name="com.tiangua.adminapi.dao" level="info"/>
+    <logger name="com.tiangua.dao" level="info"/>
+</configuration>