|
|
@@ -5,11 +5,14 @@ import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
import com.fasterxml.jackson.databind.*;
|
|
|
import com.fasterxml.jackson.dataformat.xml.XmlMapper;
|
|
|
import com.jzg.commons.exception.SystemException;
|
|
|
+import com.jzg.quotation.commons.constant.enums.base.InsuranceEnum;
|
|
|
+import com.jzg.quotation.commons.utils.InsuranceLog;
|
|
|
import com.jzg.quotation.yongcheng.api.constants.RequestUrl;
|
|
|
import com.jzg.quotation.yongcheng.api.entity.YcBuildData;
|
|
|
import com.jzg.quotation.yongcheng.api.entity.request.*;
|
|
|
import com.jzg.quotation.yongcheng.api.entity.response.*;
|
|
|
import com.jzg.quotation.yongcheng.api.properties.YcConfigurationProperties;
|
|
|
+import org.apache.commons.lang3.StringEscapeUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
import org.springframework.http.MediaType;
|
|
|
@@ -96,14 +99,16 @@ public class YcRequestApiComponents {
|
|
|
gainXmlMapper().writeValueAsString(q) +
|
|
|
"</soapenv:Body>" +
|
|
|
"</soapenv:Envelope>";
|
|
|
-
|
|
|
+ InsuranceLog.infoLog(InsuranceEnum.AICS.getPinyin(), "\n\t---------> URl: {} \n---------> 保险公司:{} {}\n---------> 请求参数:{}", url,
|
|
|
+ InsuranceEnum.AICS.getName(), requestUrl.getDesc(), xmlString);
|
|
|
// 发送请求
|
|
|
String responseStringMsg = webClient.post()
|
|
|
.bodyValue(xmlString)
|
|
|
.retrieve()
|
|
|
.bodyToMono(String.class)
|
|
|
.block(); // block() 会阻塞获取响应,若是异步环境可使用 Mono 处理
|
|
|
-
|
|
|
+ String response = StringEscapeUtils.unescapeXml(responseStringMsg);
|
|
|
+ InsuranceLog.infoLog(InsuranceEnum.AICS.getPinyin(), "\n\n---------> 响应参数:{}", response);
|
|
|
// 解析响应
|
|
|
String cleanStr = YcBuildData.cleanResponseStr(responseStringMsg);
|
|
|
if (!cleanStr.contains("<")) {
|