violet/ensign-crm-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

log:add log

Browse Source
This commit is contained in:
zzs 2024-09-29 11:04:53 +08:00
parent 032ffbd876
commit bf0a2d06e4
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm/service/ProxyService.java
View File

@ -8,6 +8,7 @@ import com.alibaba.fastjson.JSONObject;
import com.ensign.crm.module.crm.exception.AllKingdeeException; import com.ensign.crm.module.crm.exception.AllKingdeeException;
import com.ensign.crm.module.crm.model.ImageStorage; import com.ensign.crm.module.crm.model.ImageStorage;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.http.Header;
import org.apache.http.HttpEntity; import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse; import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient; import org.apache.http.client.HttpClient;
@ -168,6 +169,7 @@ public class ProxyService {
String target = initBasePath() + path.replace("/crm-api/proxy/file/do", ""); String target = initBasePath() + path.replace("/crm-api/proxy/file/do", "");
String accessToken = initAccessToken(); String accessToken = initAccessToken();
target = target + "?access_token=" + accessToken; target = target + "?access_token=" + accessToken;
log.info("proxy target: {}",target);
URI newUri = new URI(target); URI newUri = new URI(target);
CloseableHttpClient httpClient = HttpClients.createDefault(); CloseableHttpClient httpClient = HttpClients.createDefault();
HttpPost httpPost = new HttpPost(newUri); HttpPost httpPost = new HttpPost(newUri);
@ -176,9 +178,18 @@ public class ProxyService {
builder.addPart("file", fileBody); builder.addPart("file", fileBody);
HttpEntity multipartEntity = builder.build(); HttpEntity multipartEntity = builder.build();
httpPost.setEntity(multipartEntity); httpPost.setEntity(multipartEntity);
Header[] requestHeader = httpPost.getAllHeaders();
for (Header header : requestHeader) {
log.info("request Header: {}: {}", header.getName(), header.getValue());
}
HttpResponse kResponse = httpClient.execute(httpPost); HttpResponse kResponse = httpClient.execute(httpPost);
Header[] headers = kResponse.getAllHeaders();
for (Header header : headers) {
log.info("response Header: {}: {}", header.getName(), header.getValue());
}
HttpEntity entity = kResponse.getEntity(); HttpEntity entity = kResponse.getEntity();
String jsonStr = EntityUtils.toString(entity, "UTF-8").trim(); String jsonStr = EntityUtils.toString(entity, "UTF-8").trim();
log.info("receive response: {}", jsonStr);
JSONObject jsonObject = JSON.parseObject(jsonStr); JSONObject jsonObject = JSON.parseObject(jsonStr);
if (jsonObject.containsKey("url")) { if (jsonObject.containsKey("url")) {
String url = jsonObject.getString("url"); String url = jsonObject.getString("url");
@ -193,14 +204,19 @@ public class ProxyService {
imageStorage.setFileContent(transformToBase64(bytes)); imageStorage.setFileContent(transformToBase64(bytes));
imageService.saveImage(fileId, imageStorage); imageService.saveImage(fileId, imageStorage);
return doConvertFileUrl(fileId, true); String convertFileUrl = doConvertFileUrl(fileId, true);
log.info("convertFileUrl: {}", convertFileUrl);
return convertFileUrl;
} }
return null; return null;
} }
private String getFileMediaType(String filename) { private String getFileMediaType(String filename) {
log.info("filename: {}", filename);
Optional<MediaType> mediaType = MediaTypeFactory.getMediaType(filename); Optional<MediaType> mediaType = MediaTypeFactory.getMediaType(filename);
return mediaType.map(MimeType::toString).orElse(""); String type = mediaType.map(MimeType::toString).orElse("");
log.info("mediaType: {}", type);
return type;
} }