Sfoglia il codice sorgente

回应指令:配置信息回应

wanggaokun 1 anno fa
parent
commit
50dbdc6abc

+ 2 - 2
PHM-admin/phm-netty/src/main/java/com/phm/netty/server/handler/ByteArrayMessageHandler.java

@@ -88,8 +88,8 @@ public class ByteArrayMessageHandler extends SimpleChannelInboundHandler<byte[]>
             lastMsg = byteArrayMessageHandler.processService.timing(msg);
         }
         if (OrderEnum.PARAMETER.getType() == type) {
-            // 校时功能
-            lastMsg = byteArrayMessageHandler.processService.timing(msg);
+            // 参数传递
+            lastMsg = byteArrayMessageHandler.processService.getParameterConfig(msg);
         }
         if (ObjectUtil.isEmpty(lastMsg)) {
             log.info("Message数据为空");

+ 22 - 0
PHM-admin/phm-netty/src/main/java/com/phm/netty/service/IProcessService.java

@@ -8,9 +8,31 @@ import com.phm.netty.domain.Message;
  * @Date 2023/9/22 9:52
  */
 public interface IProcessService {
+
+    /**
+     * 通用指令处理
+     *
+     * @param message msg
+     * @return res
+     * @throws Exception exception
+     */
     Message orderHandle(Message message) throws Exception;
 
+    /**
+     * 校时处理
+     *
+     * @param message msg
+     * @return res
+     * @throws Exception exception
+     */
     Message timing(Message message) throws Exception;
 
+    /**
+     * 参数传递处理
+     *
+     * @param message msg
+     * @return res
+     * @throws Exception exception
+     */
     Message getParameterConfig(Message message) throws Exception;
 }