From 9c96acb246e35b2481276321876abe9b85aa51fb Mon Sep 17 00:00:00 2001
From: lijiuwei <lijiuwei@ht-atia.com>
Date: Mon, 11 Aug 2025 17:10:09 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E6=8A=A5=E4=B8=8A=E7=BA=A7=E7=B3=BB?=
 =?UTF-8?q?=E7=BB=9F=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../tcpserver/minio/service/MinioService.java      |  4 ++--
 .../com/inspect/tcpserver/tcp/NettyClient.java     |  1 -
 .../inspect/tcpserver/tcp/NettyClientHandler.java  | 14 ++++++++++++--
 3 files changed, 14 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/inspect/tcpserver/minio/service/MinioService.java b/src/main/java/com/inspect/tcpserver/minio/service/MinioService.java
index 203f3a5..46c7c29 100644
--- a/src/main/java/com/inspect/tcpserver/minio/service/MinioService.java
+++ b/src/main/java/com/inspect/tcpserver/minio/service/MinioService.java
@@ -26,7 +26,7 @@ public class MinioService {
 
     public UploadResponse upload(MultipartFile file) throws Exception {
         String fileName = file.getOriginalFilename();
-        String objectName = "lingzhouzhiliu/Model/" + fileName;
+        String objectName = "/lingzhouzhiliu/Model/" + fileName;
         log.info("fileName: {}, objectName: {}", fileName, objectName);
 
         try (InputStream in = file.getInputStream()) {
@@ -43,7 +43,7 @@ public class MinioService {
         String url = getObjectUrl(fileName);
         log.info("url: {}", url);
 
-        return new UploadResponse(fileName, url);
+        return new UploadResponse(fileName, objectName);
     }
 
     public String getObjectUrl(String objectName) throws Exception {
diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java b/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java
index 6ab406d..ccc6078 100644
--- a/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java
+++ b/src/main/java/com/inspect/tcpserver/tcp/NettyClient.java
@@ -157,7 +157,6 @@ public class NettyClient {
 
             client.sendProtoBuffer(allBuf);
             this.sendIndex++;
-            log.info("sent data to upperServer successfully");
         } else {
             log.info("###### 会话:{}, 与上级系统连接失败 ######", uuid);
         }
diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyClientHandler.java b/src/main/java/com/inspect/tcpserver/tcp/NettyClientHandler.java
index e3460ab..1af1284 100644
--- a/src/main/java/com/inspect/tcpserver/tcp/NettyClientHandler.java
+++ b/src/main/java/com/inspect/tcpserver/tcp/NettyClientHandler.java
@@ -1,6 +1,9 @@
 package com.inspect.tcpserver.tcp;
 
+import com.inspect.tcpserver.util.Color;
 import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 import io.netty.channel.EventLoop;
@@ -30,9 +33,16 @@ public class NettyClientHandler extends ChannelInboundHandlerAdapter {
 
     public void sendProtoBuffer(ByteBuf byteBuf) {
         if (clientChannelHandlerContext != null) {
-            clientChannelHandlerContext.writeAndFlush(byteBuf);
+            clientChannelHandlerContext.writeAndFlush(Unpooled.wrappedBuffer(byteBuf)).addListener(
+                    (ChannelFuture future) -> {
+                        if (future.isSuccess()) {
+                            log.info(Color.CYAN + "###### 向上级系统发送消息成功 ######" + Color.END);
+                        } else {
+                            log.info(Color.RED + "###### 向上级系发送消息失败 ######" + Color.END);
+                        }
+                    });
         } else {
-            log.info("client发送消息时，content为空，未连接服务端，取消发送");
+            log.info(Color.RED + "###### 无法向上级系发送消息,ctx==null ######" + Color.END);
         }
     }