chudk 7 years ago
parent
commit
2bc5d3963e

+ 7 - 2
src/main/java/com/tidecloud/datacceptance/service/impl/DiscardServerHandler.java

@@ -71,10 +71,13 @@ public class DiscardServerHandler extends ChannelInboundHandlerAdapter {
         switch (adviceType) {
         
         case "UD":
-            Device device = getDevice(msg);
-            logger.info("正常存储设备信息:" + device.toString());
+            Device deviceUD = getDevice(msg);
+            dataStorage(deviceUD);
+            logger.info("正常存储设备信息:" + deviceUD.toString());
             break;
         case "UD2":
+            Device deviceUD2 = getDevice(msg);
+            dataStorage(deviceUD2);
             logger.info("正常存储设备信息:" + getDevice(msg).toString());
             break;
         case "LK":
@@ -173,6 +176,7 @@ public class DiscardServerHandler extends ChannelInboundHandlerAdapter {
                // String fileName = dataPath + prefixName + new SimpleDateFormat("yyMMddHHmmss").format(new Date());
                // File file = new File(fileName);
                 writeDevice2File(sonFile, deviceStr);
+                logger.info("正在写入数据: " + deviceStr);
                 isTouch = false;
             }
         }
@@ -180,6 +184,7 @@ public class DiscardServerHandler extends ChannelInboundHandlerAdapter {
             String fileName = dataPath + prefixName + new SimpleDateFormat("yyMMddHHmmss").format(new Date());
             File file = new File(fileName);
             writeDevice2File(file, deviceStr);
+            logger.info("满10M,创建新的文件 正在写入数据:" + deviceStr + "timestamp:" + new SimpleDateFormat("yyMMddHHmmss").format(new Date()));
         }
     }