【睿智鼎华勤对接】

src/main/java/com/uas/eis/config/HQConfig.java

@@ -0,0 +1,55 @@
+package com.uas.eis.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.PropertySource;
+@Configuration
+@PropertySource("classpath:hq.properties")
+public class HQConfig {
+    private String ev;
+    @Value("${prod.url}")
+    private String apiUrl;
+    @Value("${prod.userName}")
+    private String userName;
+    @Value("${prod.password}")
+    private String pwd;
+
+    @Value("${test.url}")
+    private String apiUrlTest;
+    @Value("${test.userName}")
+    private String userNameTest;
+    @Value("${test.password}")
+    private String pwdTest;
+
+
+    public String getEv() {
+        return ev;
+    }
+
+    public void setEv(String ev) {
+        this.ev = ev;
+    }
+    public String getApiUrl() {
+        if("test".equals(getEv())){
+            return apiUrlTest;
+        }else {
+            return apiUrl;
+        }
+    }
+
+    public String getUserName() {
+        if("test".equals(getEv())){
+            return userNameTest;
+        }else {
+            return userName;
+        }
+    }
+
+    public String getPwd() {
+        if("test".equals(getEv())){
+            return pwdTest;
+        }else {
+            return pwd;
+        }
+    }
+}

src/main/java/com/uas/eis/controller/ERPController.java

@@ -57,4 +57,10 @@ public class ERPController {
     public ApiResult<String> syncUpdateReceiveByErp(String data){
         return erpService.syncUpdateReceiveByErp(data);
     }
+
+
+    @RequestMapping("/erp/syncHQPOPlan")
+    public ApiResult<String> syncHQPOPlan(String master, Integer id,String emCode,String caller){
+        return erpService.syncHQPOPlan(master, id,emCode,caller);
+    }
 }

src/main/java/com/uas/eis/entity/HQPODadaList.java

@@ -0,0 +1,24 @@
+package com.uas.eis.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class HQPODadaList {
+    @JSONField(name = "OU_NAME")
+    private String ou_name ;//华勤通讯香港有限公司",
+    @JSONField(name = "PO_NUMBER")
+    private String po_number;//": "110306037",
+    @JSONField(name = "PO_LINE")
+    private String po_line;//": "1.1",
+    @JSONField(name = "HQ_PN")
+    private String hq_pn;//": "HQ11430351000",
+    @JSONField(name = "ORDERED_QUANTITY")
+    private Double ordered_quantity;//": 12000,
+    @JSONField(name = "REQUIRE_DATE")
+    private String require_date;//": "2025/08/01",
+    @JSONField(name = "ORIGIN_MANUFACTURER_PO_INFO")
+    private List<HQPOInfo> origin_manufacturer_po_info;//
+}

src/main/java/com/uas/eis/entity/HQPOInfo.java

@@ -0,0 +1,22 @@
+package com.uas.eis.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+@Data
+public class HQPOInfo {
+    @JSONField(name = "ORIGIN_PO_NO")
+    private String origin_po_no;//": "STOCK",
+    @JSONField(name = "ORIGIN_PO_LINE")
+    private String origin_po_line;//": "1",
+    @JSONField(name = "MANUFACTURER_PN")
+    private String manufacturer_pn;//": "BF1109-A2R4NCCT/LF",
+    @JSONField(name = "HQ_PN")
+    private String hq_pn;//": "HQ11430351000",
+    @JSONField(name = "SUPPLIER_ORDER_DATE")
+    private String supplier_order_date;//": "2999/12/31",
+    @JSONField(name = "QUANTITY")
+    private Double quantity;//": 12000,
+    @JSONField(name = "ESTIMATE_SHIP_DATE")
+    private String estimate_ship_date;//": "2025/08/01"
+}

src/main/java/com/uas/eis/entity/HQPOReq.java

@@ -0,0 +1,16 @@
+package com.uas.eis.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class HQPOReq {
+    @JSONField(name = "VENDOR_NAME")
+    private String vendor_name;
+    @JSONField(name = "VENDOR_CODE")
+    private String vendor_code;
+    @JSONField(name = "PODATALIST")
+    private List<HQPODadaList> podatalist;
+}

src/main/java/com/uas/eis/entity/HQPOResp.java

@@ -0,0 +1,35 @@
+package com.uas.eis.entity;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.Data;
+
+@Data
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class HQPOResp {
+    private String msg;
+    private HQPORespHeader header;
+    @Data
+    @JsonIgnoreProperties(ignoreUnknown = true)
+    public static class HQPORespHeader {
+        private String code;//-- 非200为请求失败
+        private String desc;//"success" -- code非200时存放错误信息
+    }
+
+    public String getCode() {
+        if(header!=null){
+            return header.getCode();
+        }
+        return "500";
+    }
+
+    public String getErrTip() {
+        if(msg!=null){
+            return msg;
+        }else {
+            if(header!=null&&header.getDesc()!=null){
+                return header.getDesc();
+            }
+        }
+        return "";
+    }
+}

src/main/java/com/uas/eis/service/ERPService.java

@@ -9,6 +9,7 @@ import com.uas.eis.sdk.entity.ApiResult;
  * @date 2021-12-06 18:25
  */
 public interface ERPService {
+    ApiResult<String> syncHQPOPlan(String master, Integer id,String emCode,String caller);
 
     ApiResult<String> syncProduct(String data);
 

src/main/java/com/uas/eis/service/Impl/ERPServiceImpl.java

@@ -3,6 +3,8 @@ package com.uas.eis.service.Impl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.uas.eis.config.HQConfig;
 import com.uas.eis.core.support.TokenProperties;
 import com.uas.eis.dao.BaseDao;
 import com.uas.eis.dao.SqlRowList;
@@ -17,8 +19,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jdbc.core.BeanPropertyRowMapper;
 import org.springframework.stereotype.Service;
 
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * @author koul
@@ -34,6 +35,95 @@ public class ERPServiceImpl implements ERPService {
     @Autowired
     private BaseDao baseDao;
 
+    @Autowired
+    private HQConfig hqConfig;
+
+    @Override
+    public ApiResult<String> syncHQPOPlan(String master, Integer id, String emCode, String caller) {
+        logger.info("syncHQPOPlan-Begin:master {} id {}",master,id);
+        hqConfig.setEv(getMasterEv(master));
+        // 执行查询
+        SqlRowList docMsg = baseDao.queryForRowSet(" select vp_statuscode from "+master+".vendPurExecplan where vp_id  = "+id);
+        if(!docMsg.next()){
+            baseDao.execute("update "+master+".VENDPUREXECPLAN set vp_uploadstatus='上传失败',vp_uploaderr='上传单据不存在。' where vp_id = "+id);
+            logger.info("syncHQPOPlan-End:master {} id {} err {}",master,id,"上传单据不存在");
+            return ApiResponse.failRsp("101","上传单据不存在");
+        }
+        if(!docMsg.getGeneralString("vp_statuscode").equals("AUDITED")){
+            baseDao.execute("update "+master+".VENDPUREXECPLAN set vp_uploadstatus='上传失败',vp_uploaderr='请先审核再上传。' where vp_id = "+id);
+            logger.info("syncHQPOPlan-End:master {} id {} err {}",master,id,"请先审核再上传");
+            return ApiResponse.failRsp("101","请先审核再上传");
+        }
+        SqlRowList docList = baseDao.queryForRowSet(" select * from "+master+".VENDPUREXECPLANDETAIL where VD_VPID  = "+id);
+        if(docList.next()){
+            HQPOReq hqVendPurExecplanReq = new HQPOReq();
+            hqVendPurExecplanReq.setVendor_code(docList.getGeneralString("vd_vendor_code"));
+            hqVendPurExecplanReq.setVendor_name(docList.getGeneralString("vd_vendor_name"));
+            List<HQPODadaList> podatalist = new ArrayList<>();
+            List<Map<String, Object>> dataList = docList.getResultList();
+            Map<String, List<Map<String, Object>>> POGroup = BaseUtil.groupsMap(dataList, new Object[] { "vd_po_number", "vd_po_line"});
+            List<Map<String, Object>> items;
+            for (Object m : POGroup.keySet()) {
+                items = POGroup.get(m);
+                Map<String, Object> poMap = items.get(0);
+                String hq_pn = poMap.get("vd_hq_pn").toString();
+                HQPODadaList hqpoDadaList = new HQPODadaList();
+                hqpoDadaList.setOu_name(poMap.get("vd_ou_name").toString());
+                hqpoDadaList.setPo_number(poMap.get("vd_po_number").toString());
+                hqpoDadaList.setPo_line(poMap.get("vd_po_line").toString());
+                hqpoDadaList.setHq_pn(hq_pn);
+                hqpoDadaList.setOrdered_quantity(Double.valueOf(poMap.get("vd_ordered_quantity").toString()));
+                hqpoDadaList.setRequire_date(DateUtil.format((Date)poMap.get("vd_require_date"),"yyyy/MM/dd"));
+                List<HQPOInfo> poInfos = new ArrayList<>();
+                for (Map<String, Object> poInfo : items){
+                    HQPOInfo hqpoInfo = new HQPOInfo();
+                    hqpoInfo.setOrigin_po_no(poInfo.get("vd_origin_po_no").toString());
+                    hqpoInfo.setOrigin_po_line(poInfo.get("vd_origin_po_line").toString());
+                    hqpoInfo.setManufacturer_pn(poInfo.get("vd_manufacturer_pn").toString());
+                    hqpoInfo.setHq_pn(hq_pn);
+                    hqpoInfo.setSupplier_order_date(DateUtil.format((Date)poInfo.get("vd_supplier_order_date"),"yyyy/MM/dd"));
+                    hqpoInfo.setQuantity(Double.valueOf(poInfo.get("vd_quantity").toString()));
+                    hqpoInfo.setEstimate_ship_date(DateUtil.format((Date)poInfo.get("vd_estimate_ship_date"),"yyyy/MM/dd"));
+                    poInfos.add(hqpoInfo);
+                }
+                hqpoDadaList.setOrigin_manufacturer_po_info(poInfos);
+                podatalist.add(hqpoDadaList);
+            }
+            hqVendPurExecplanReq.setPodatalist(podatalist);
+            String jsonBody = JSON.toJSONString(hqVendPurExecplanReq,
+                    SerializerFeature.WriteMapNullValue).replace("null","\"\"");
+            System.out.println("jsonBody: "+jsonBody);
+            try {
+                String url = hqConfig.getApiUrl();
+                String userName = hqConfig.getUserName();
+                String pwd = hqConfig.getPwd();
+                HttpUtil.Response response = HttpUtil.sendPostWithBasicAuthRequest(url,userName,pwd, jsonBody);
+                logger.info("syncHQPOPlan-End:master {} id {} tip {}",master,id,"("+response.getStatusCode()+")"+response.getResponseText());
+                HQPOResp hqpoResp = new ObjectMapper().readValue(response.getResponseText(), HQPOResp.class);
+                if(hqpoResp.getCode().equals("200")){
+                    baseDao.execute("update "+master+".VENDPUREXECPLAN set vp_uploadtime=sysdate,vp_uploadstatus='上传成功',vp_uploaderr='' where vp_id = "+id);
+                    return ApiResponse.successRsp("200","上传成功");
+                }else {
+                    baseDao.execute("update "+master+".VENDPUREXECPLAN set vp_uploadstatus='上传失败',vp_uploaderr='"+hqpoResp.getCode()+": "+hqpoResp.getErrTip()+"' where vp_id = "+id);
+                    return ApiResponse.failRsp(hqpoResp.getCode(),hqpoResp.getErrTip());
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }else {
+            baseDao.execute("update "+master+".VENDPUREXECPLAN set vp_uploadstatus='上传失败',vp_uploaderr='请先审核再上传。' where vp_id = "+id);
+            logger.info("syncHQPOPlan-End:master {} id {} err {}",master,id,"请先审核再上传");
+            return ApiResponse.failRsp("101","请先审核再上传");
+        }
+
+        return null;
+    }
+
+    public String getMasterEv(String master){
+      return baseDao.queryForObject("select max(DISPLAY) from RZ_T.configs LEFT JOIN RZ_T.CONFIGPROPS ON CONFIGPROPS.CONFIG_ID = configs.ID AND configs.DATA =  CONFIGPROPS.VALUE " +
+              "where configs.CODE='DocEv'",String.class);
+    }
+
     @Override
     public ApiResult<String> syncProduct(String data) {
         Map<Object, Object> store = BaseUtil.parseFormStoreToMap(data);

src/main/java/com/uas/eis/task/HQPODataUploadTask.java

@@ -0,0 +1,39 @@
+package com.uas.eis.task;
+
+import com.uas.eis.dao.BaseDao;
+import com.uas.eis.dao.SqlRowList;
+import com.uas.eis.sdk.entity.ApiResult;
+import com.uas.eis.service.ERPService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@EnableAsync
+@EnableScheduling
+public class HQPODataUploadTask {
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+    @Autowired
+    private BaseDao baseDao;
+    @Autowired
+    private ERPService erpService;
+    // 0 0/2 * * * ? 每2分钟
+    // 0 0 0 * * ?
+    @Scheduled(cron = "0 0 0 * * ?")
+    public void uploadHQPOPlan() {
+        logger.info("uploadHQPOPlan-begin");
+        String master = "RZ_T";
+        Integer vpId = baseDao.queryForObject("select max(vp_id) vp_id from RZ_T.vendPurExecplan where vp_statuscode='AUDITED'",Integer.class);
+        if(vpId!=null && vpId > 0){
+            String emCode="TASK";
+            String caller = "";
+            ApiResult<String> apiResult = erpService.syncHQPOPlan(master,vpId,emCode,caller);
+            System.out.println(apiResult.toString());
+        }
+        logger.info("uploadHQPOPlan-End:master {} id {}",master,vpId);
+    }
+}

src/main/java/com/uas/eis/utils/BaseUtil.java

@@ -177,5 +177,53 @@ public class BaseUtil {
 	public static String parseGridStore2Str(List<Map<String, Object>> list) {
 		return JacksonUtil.toJsonArray(list);
 	}
-	
+
+	/**
+	 * 把一个list集合的map按指定字段{groupField}分组
+	 */
+	public static Map<Object, List<Map<Object, Object>>> groupMap(List<Map<Object, Object>> maps, String groupField) {
+		Map<Object, List<Map<Object, Object>>> set = new HashMap<Object, List<Map<Object, Object>>>();
+		List<Map<Object, Object>> list = null;
+		for (Map<Object, Object> map : maps) {
+			Object key = map.get(groupField);
+			if (set.containsKey(key)) {
+				list = set.get(key);
+			} else {
+				list = new ArrayList<Map<Object, Object>>();
+			}
+			list.add(map);
+			set.put(key, list);
+		}
+		return set;
+	}
+
+	public static Map<String, List<Map<String, Object>>> groupsMap(List<Map<String, Object>> maps, Object[] objects) {
+		Map<String, List<Map<String, Object>>> set = new HashMap<String, List<Map<String, Object>>>();
+		List<Map<String, Object>> list = null;
+		String keyValue = null;
+		Object value = null;
+		for (Map<String, Object> map : maps) {
+			keyValue = null;
+			for (Object field : objects) {
+				if (keyValue != null) {
+					keyValue += "#";
+				} else {
+					keyValue = "";
+				}
+				value = map.get(field);
+				keyValue += value == null ? "" : value;
+			}
+			// Object key = map.get(groupField);
+			if (keyValue != null && !keyValue.equals("") && set.containsKey(keyValue)) {
+				list = set.get(keyValue);
+			} else {
+				list = new ArrayList<Map<String, Object>>();
+			}
+			list.add(map);
+			set.put(keyValue, list);
+		}
+		return set;
+	}
+
+
 }

src/main/java/com/uas/eis/utils/HttpUtil.java

@@ -12,16 +12,12 @@ import java.io.UnsupportedEncodingException;
 import java.net.HttpURLConnection;
 import java.net.URL;
 import java.net.URLEncoder;
+import java.nio.charset.StandardCharsets;
 import java.security.KeyManagementException;
 import java.security.NoSuchAlgorithmException;
 import java.security.cert.CertificateException;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.Map.Entry;
-import java.util.Set;
 
 import javax.net.ssl.SSLContext;
 import javax.net.ssl.TrustManager;
@@ -976,4 +972,42 @@ public class HttpUtil {
 			return null;
 		}
 	}
+
+
+	public static Response sendPostWithBasicAuthRequest(String postUrl,String userName,String pwd, String reqBody) throws Exception {
+		// 创建URL对象
+		URL url = new URL(postUrl);
+		HttpURLConnection urlConn = (HttpURLConnection) url.openConnection();
+		try {
+			// 设置请求方法
+			urlConn.setRequestMethod("POST");
+			// 设置Basic Auth认证头
+			String auth = userName+":"+pwd;
+			String encodedAuth = Base64.getEncoder().encodeToString(auth.getBytes(StandardCharsets.UTF_8));
+			String authHeader = "Basic " + encodedAuth;
+			urlConn.setRequestProperty("Authorization", authHeader);
+			// 设置请求头
+			urlConn.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
+			urlConn.setRequestProperty("Accept", "application/json");
+			// 启用输出流，用于发送请求体
+			urlConn.setDoOutput(true);
+			urlConn.setDoInput(true);
+
+			urlConn.setUseCaches(false);
+			urlConn.setInstanceFollowRedirects(true);
+			if (null != reqBody) {
+				OutputStreamWriter osw = new OutputStreamWriter(urlConn.getOutputStream(), "UTF-8");
+				osw.write(reqBody);
+				osw.flush();
+				osw.close();
+			}
+			return new Response(urlConn.getResponseCode() == 200, streamToString(urlConn.getInputStream()));
+		} catch (Exception e) {
+			return new Response(false, e.getMessage());
+		} finally {
+			if (urlConn != null) {
+				urlConn.disconnect();
+			}
+		}
+	}
 }

src/main/resources/hq.properties

@@ -0,0 +1,6 @@
+test.url=https://editst.huaqin.com:10443/httpsync/agent-vendor-api/poData
+test.userName=19149
+test.password=f7E]Rb(9Ce
+prod.url=
+prod.userName=TBD
+prod.password=TBD

src/test/java/com/uas/eis/UasEisApplicationTests.java

@@ -1,19 +1,28 @@
 package com.uas.eis;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.serializer.SerializerFeature;
 import com.uas.eis.beans.result.CrmQueryResult;
-import com.uas.eis.beans.result.Goods;
-import com.uas.eis.exception.AccessTokenException;
+import com.uas.eis.entity.*;
 import com.uas.eis.listener.UasProdInOutListener;
 import com.uas.eis.manager.CustomerManager;
 import com.uas.eis.manager.ProductManager;
+import com.uas.eis.sdk.entity.ApiResult;
+import com.uas.eis.service.ERPService;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
-import java.util.HashMap;
+import java.util.Base64;
 import java.util.List;
 import java.util.Map;
 
@@ -28,6 +37,108 @@ public class UasEisApplicationTests {
 
 	@Autowired
 	private CustomerManager customerManager;
+	@Autowired
+	private ERPService erpService;
+
+	@Test
+	public void TestsyncHQPOPlan(){
+		String master = "RZ_T";
+		Integer id = 24;
+		String emCode="TEST";
+		String caller = "";
+		ApiResult<String>  apiResult = erpService.syncHQPOPlan(master,id,emCode,caller);
+		System.out.println(apiResult.toString());
+	}
+	@Test
+	public void TestHQ() {
+		// 请求URL
+		String url = "https://editst.huaqin.com:10443/httpsync/agent-vendor-api/poData";
+		String userName = "19149";
+		String pwd = "f7E]Rb(9Ce";
+		// JSON请求体
+		HQPOReq hqVendPurExecplanReq = new HQPOReq();
+		hqVendPurExecplanReq.setVendor_name("睿智科技发展有限公司");
+		hqVendPurExecplanReq.setVendor_code("19149");
+		List<HQPODadaList> PODATALIST = new ArrayList<>();
+		HQPODadaList hqPODATALIST = new HQPODadaList();
+		hqPODATALIST.setOu_name("华勤通讯香港有限公司");
+		hqPODATALIST.setPo_number("110306037");
+		hqPODATALIST.setPo_line("1.1");
+		hqPODATALIST.setHq_pn("HQ11430351000");
+		hqPODATALIST.setOrdered_quantity(12000.0);
+		hqPODATALIST.setRequire_date("2025/08/01");
+
+		List<HQPOInfo> hqPO_INFOS = new ArrayList<>();
+		HQPOInfo hqpoInfo = new HQPOInfo();
+		hqpoInfo.setOrigin_po_no("STOCK");
+		hqpoInfo.setOrigin_po_line("1");
+		hqpoInfo.setManufacturer_pn("BF1109-A2R4NCCT/LF");
+		hqpoInfo.setHq_pn("HQ11430351000");
+		hqpoInfo.setSupplier_order_date("2999/12/31");
+		hqpoInfo.setQuantity(12000.0);
+		hqpoInfo.setEstimate_ship_date("2025/08/01");
+		hqPO_INFOS.add(hqpoInfo);
+		hqPODATALIST.setOrigin_manufacturer_po_info(hqPO_INFOS);
+
+		PODATALIST.add(hqPODATALIST);
+		hqVendPurExecplanReq.setPodatalist(PODATALIST);
+		String jsonBody = JSON.toJSONString(hqVendPurExecplanReq,
+				SerializerFeature.WriteMapNullValue).replace("null","\"\"");
+		System.out.println("jsonBody: "+jsonBody);
+		try {
+			String response = sendPostRequest(url,userName,pwd, jsonBody);
+			System.out.println("响应结果: " + response);
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+
+	public static String sendPostRequest(String url,String userName,String pwd, String jsonBody) throws Exception {
+		// 创建URL对象
+		URL obj = new URL(url);
+		HttpURLConnection connection = (HttpURLConnection) obj.openConnection();
+
+		// 设置请求方法
+		connection.setRequestMethod("POST");
+
+		// 设置Basic Auth认证头
+		String auth = userName+":"+pwd;
+		String encodedAuth = Base64.getEncoder().encodeToString(auth.getBytes(StandardCharsets.UTF_8));
+		String authHeader = "Basic " + encodedAuth;
+		connection.setRequestProperty("Authorization", authHeader);
+
+		// 设置请求头
+		connection.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
+		connection.setRequestProperty("Accept", "application/json");
+
+		// 启用输出流，用于发送请求体
+		connection.setDoOutput(true);
+
+		// 发送JSON请求体
+		try (OutputStream os = connection.getOutputStream()) {
+			byte[] input = jsonBody.getBytes(StandardCharsets.UTF_8);
+			os.write(input, 0, input.length);
+		}
+
+		// 获取响应码
+		int responseCode = connection.getResponseCode();
+		System.out.println("响应码: " + responseCode);
+
+		// 读取响应
+		StringBuilder response = new StringBuilder();
+		try (BufferedReader br = new BufferedReader(
+				new InputStreamReader(connection.getInputStream(), StandardCharsets.UTF_8))) {
+			String responseLine;
+			while ((responseLine = br.readLine()) != null) {
+				response.append(responseLine.trim());
+			}
+		}
+
+		// 断开连接
+		connection.disconnect();
+
+		return response.toString();
+	}
 
 	@Test
 	public void Test() {
@@ -72,4 +183,5 @@ public class UasEisApplicationTests {
 		}
 	}
 
-}
+
+}