格式

license/src/main/java/iot/sixiang/license/device/DeviceChannelInitializer.java

@@ -22,12 +22,10 @@ public class DeviceChannelInitializer extends BaseChannelInitializer {
 
     @Override
     protected void initChannel(SocketChannel ch) throws Exception {
-
         // 服务端心跳检测
         ch.pipeline().addLast(new IdleStateHandler(3, 0, 0, TimeUnit.SECONDS));
         ch.pipeline().addLast("decoder", new DeviceDecoder());
         ch.pipeline().addLast("encoder", new DeviceEncoder());
         ch.pipeline().addLast(workGroup, "handler", handler);
     }
-
 }

license/src/main/java/iot/sixiang/license/device/DeviceManager.java

@@ -12,16 +12,18 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.PostConstruct;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
 
 @Component
 @Slf4j
 public class DeviceManager {
-
-
     private Map<String, SessionContext> sessionContexts = null;
     private DeviceChannelInitializer channelInitializer;
-//    private TcpServer server = null;
+    //    private TcpServer server = null;
     private int port = 18889;
     private Map<String, DeviceVo> allDevice = null;
     @Autowired
@@ -32,8 +34,8 @@ public class DeviceManager {
     private AsyncTcpServer asyncTcpServer;
 
     public DeviceManager() {
-        sessionContexts = new HashMap<String, SessionContext>();
-        allDevice = new HashMap<String, DeviceVo>();
+        sessionContexts = new HashMap<>();
+        allDevice = new HashMap<>();
     }
 
     @PostConstruct
@@ -44,7 +46,7 @@ public class DeviceManager {
 
 
     private void startTcpService() {
-        sessionContexts = new HashMap<String, SessionContext>();
+        sessionContexts = new HashMap<>();
         channelInitializer = new DeviceChannelInitializer(handler);
         asyncTcpServer.start(port, channelInitializer);
     }
@@ -132,7 +134,6 @@ public class DeviceManager {
     }
 
     public boolean changeSessionOffline(String channelId) {
-
         Iterator<Map.Entry<String, SessionContext>> it = sessionContexts.entrySet().iterator();
         while (it.hasNext()) {
             Map.Entry<String, SessionContext> entry = it.next();
@@ -154,7 +155,6 @@ public class DeviceManager {
         PageInfoModel<DeviceDetailVo> detailVoPageInfoModel = new PageInfoModel<>();
         List<DeviceDetailVo> detailVos = new ArrayList<>();
         for (DeviceVo vo : deviceVos) {
-
             DeviceDetailVo detailVo = new DeviceDetailVo();
             detailVo.setDeviceId(vo.getDeviceId());
             detailVo.setAppName(vo.getAppName());
@@ -171,8 +171,6 @@ public class DeviceManager {
                 detailVo.setStatus(status);
                 detailVo.setOnline(online);
                 detailVo.setOffline(offline);
-
-
             }
             detailVos.add(detailVo);
         }