From b0049ffc851dae11fff65ff3e0b43cf8e7fd1446 Mon Sep 17 00:00:00 2001
From: jsowell <123@jsowell.com>
Date: Wed, 10 Jun 2026 16:41:40 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4Strategy=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/yunkuaichong/YKCBusinessService.java |  5 +----
 .../impl/YKCBusinessServiceImpl.java             | 16 ----------------
 2 files changed, 1 insertion(+), 20 deletions(-)

diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/YKCBusinessService.java b/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/YKCBusinessService.java
index 573c182ff..f969a871c 100644
--- a/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/YKCBusinessService.java
+++ b/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/YKCBusinessService.java
@@ -2,7 +2,6 @@ package com.jsowell.netty.service.yunkuaichong;
 
 import com.jsowell.common.core.domain.ykc.YKCDataProtocol;
 import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelId;
 
 /**
  * 云快充处理service
@@ -12,12 +11,10 @@ public interface YKCBusinessService {
 	/**
 	 * 处理桩发来的请求
 	 * 不需要应答的返回null
-	 * @param msg 请求报文
+	 * @param ykcDataProtocol 请求报文
 	 * @param ctx 通道信息
 	 * @return 结果
 	 */
-	byte[] process(byte[] msg, ChannelHandlerContext ctx);
-
 	byte[] process(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext ctx);
 
 	/**
diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java b/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java
index 9b2249e22..bef23f684 100644
--- a/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java
+++ b/jsowell-netty/src/main/java/com/jsowell/netty/service/yunkuaichong/impl/YKCBusinessServiceImpl.java
@@ -10,11 +10,9 @@ import com.jsowell.common.util.DateUtils;
 import com.jsowell.common.util.StringUtils;
 import com.jsowell.common.util.YKCUtils;
 import com.jsowell.netty.factory.YKCOperateFactory;
-import com.jsowell.netty.factory.YKCOperateFactoryV2;
 import com.jsowell.netty.handler.yunkuaichong.AbstractYkcHandler;
 import com.jsowell.netty.server.yunkuaichong.NettyServerHandler;
 import com.jsowell.netty.service.yunkuaichong.YKCBusinessService;
-import com.jsowell.netty.strategy.ykc.AbstractYkcStrategy;
 import com.jsowell.pile.dto.SavePileMsgDTO;
 import com.jsowell.pile.service.OrderBasicInfoService;
 import com.jsowell.pile.service.PileConnectorInfoService;
@@ -47,26 +45,12 @@ public class YKCBusinessServiceImpl implements YKCBusinessService {
     @Autowired
     private OrderBasicInfoService orderBasicInfoService;
 
-    @Autowired
-    private YKCOperateFactoryV2 ykcOperateFactoryV2;
-
     @Autowired
     private RedisCache redisCache;
 
     @Resource(name = "scheduledExecutorService")
     private ScheduledExecutorService scheduledExecutorService;
 
-    @Override
-    public byte[] process(byte[] msg, ChannelHandlerContext ctx) {
-        if (!YKCUtils.checkMsg(msg)) {
-            return null;
-        }
-        YKCDataProtocol ykcDataProtocol = new YKCDataProtocol(msg);
-        String frameType = YKCUtils.frameType2Str(ykcDataProtocol.getFrameType());
-        AbstractYkcStrategy invokeStrategy = ykcOperateFactoryV2.getInvokeStrategy(frameType);
-        return invokeStrategy.supplyProcess(ykcDataProtocol, ctx);
-    }
-
     @Override
     public byte[] process(YKCDataProtocol ykcDataProtocol, ChannelHandlerContext ctx) {
         if (!YKCUtils.checkMsg(ykcDataProtocol)) {