From 80a512d460dc3ad5cfced73afaebbfe09bb91aba Mon Sep 17 00:00:00 2001
From: ke <893754509@qq.com>
Date: Wed, 27 Nov 2024 17:29:16 +0800
Subject: [PATCH] 白蚁新模块。图片上传接口。更新11-27 17:00
---
skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java | 45 +++++++++++++++++++++++++++++----------------
1 files changed, 29 insertions(+), 16 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java b/skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java
index 9caf4a1..e3ebda8 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-by/src/main/java/cn/gistack/by/nettyUpload/HttpUploadFileHandler.java
@@ -78,9 +78,12 @@
protected void channelRead0(ChannelHandlerContext ctx, FullHttpRequest fullRequest) throws Exception {
+ System.err.println("fullRequest:::"+fullRequest);
boolean isRequestValid = isValidHttpRequest(ctx, fullRequest);
if (!isRequestValid) {
log.warn("Discard invalid request.");
+
+ //HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.BAD_REQUEST, "验证失败");
return;
}
@@ -92,9 +95,9 @@
// file.write(ByteBufUtil.getBytes(fullRequest.content()));
// file.close();
- String fileName = this.parseFileName(fullRequest);
+ //String fileName = this.parseFileName(fullRequest);
-
+ String fileName = System.currentTimeMillis() + ".jpg";
ByteArrayInputStream stream = new ByteArrayInputStream(ByteBufUtil.getBytes(fullRequest.content()));
MockMultipartFile multipartFile
@@ -103,12 +106,13 @@
// 上传荆楚水库的文件地址
- System.err.println("iOssClient::");
- System.err.println(iOssClient.getClass().getName());
- System.err.println(iOssClient);
+// System.err.println("iOssClient::");
+// System.err.println(iOssClient.getClass().getName());
+// System.err.println(iOssClient);
String picurl = iOssClient.uploadFile(fileName, multipartFile);
- System.err.println("最终地址"+picurl);
+// System.err.println("图片上传地址"+picurl);
+ log.info("图片上传地址：："+picurl);
// 请求参数放入实体中
BaiyiPicEntity baiyiPicEntity = parseEntity(fullRequest);
@@ -190,21 +194,30 @@
try {
URI uri = UriUtils.getURI(request);
log.info(uri.getPath());
-
- // 密码校验
- boolean authFlag = auth(ctx, uri);
- if (!authFlag) {
- // 校验不通过
+ // authorization效验
+ String authorization = request.headers().get("Authorization");
+ if(!this.nettyHttpConfig.getAuthorization().equals(authorization)) {
+ log.warn("Authorization校验失败！！");
+ // 校验不通过
HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.UNAUTHORIZED, HttpResponseStatus.UNAUTHORIZED.toString());
// 校验不通过
return false;
- }
+ }
+
+ // 密码校验
+// boolean authFlag = auth(ctx, uri);
+// if (!authFlag) {
+// // 校验不通过
+// HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.UNAUTHORIZED, HttpResponseStatus.UNAUTHORIZED.toString());
+// // 校验不通过
+// return false;
+// }
// uri 路径校验
- if (!uri.getPath().startsWith(UPLOAD_FILE_URL)) {
- HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.BAD_REQUEST,"the url must starts with /postfile");
- return false;
- }
+// if (!uri.getPath().startsWith(UPLOAD_FILE_URL)) {
+// HttpResponseUtils.sendResponseJson(ctx, HttpResponseStatus.BAD_REQUEST,"the url must starts with /postfile");
+// return false;
+// }
return true;
} catch (Exception exception) {
--
Gitblit v1.9.3