Browse Source

3维瓦斯爆炸

huangxingxing 8 tháng trước cách đây
mục cha
commit
f1f07f825d
1 tập tin đã thay đổi với 32 bổ sung6 xóa
  1. 32 6
      src/main/java/com/miniframe/disaster/service/LogService.java

+ 32 - 6
src/main/java/com/miniframe/disaster/service/LogService.java

@@ -53,7 +53,35 @@ public class LogService {
      * @param
      */
     public static void addLog(Integer aid,Integer jid,String stype,String log){
-        String filePath =TemplateGenerator.BPATH+"/"+aid+"/"+jid+"/"+stype.toLowerCase()+"/log.txt";
+        if(stype.equals("gass")){//排除其他日志
+            gassAlllog(aid, jid, stype, log);
+            if(log.indexOf("求解")>0){
+                savelog(aid, jid, stype, log);
+            }else if(log.indexOf("LOG")>0){
+                savelog(aid, jid, stype, log);
+            }
+        }else{
+           savelog(aid, jid, stype, log);
+        }
+    }
+
+    private static void gassAlllog(Integer aid, Integer jid, String stype, String log) {
+        String filePath = TemplateGenerator.BPATH+"/"+ aid +"/"+ jid +"/"+ stype.toLowerCase()+"/alllog.txt";
+        FileWriter writer = null;
+        try {
+            writer = new FileWriter(filePath,true);
+            BufferedWriter bwriter = new BufferedWriter(writer);
+            bwriter.write(log);  // 将内容写入文件末尾
+            bwriter.newLine();
+            bwriter.close();
+            writer.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private static void savelog(Integer aid, Integer jid, String stype, String log) {
+        String filePath =TemplateGenerator.BPATH+"/"+ aid +"/"+ jid +"/"+ stype.toLowerCase()+"/log.txt";
         FileWriter writer = null;
         try {
             writer = new FileWriter(filePath,true);
@@ -66,14 +94,12 @@ public class LogService {
             e.printStackTrace();
         }
         CompletableFuture<Void> cf = CompletableFuture.supplyAsync(()->{
-//                System.out.println("s消息发送:aid:"+aid+"--log:"+log);
-        WebsocketEndPoint webs =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
-        webs.sendMessageToUser(String.valueOf(aid),log);
-//                System.out.println("d消息发送:aid:"+aid+"--log:"+log);
+            WebsocketEndPoint webs =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
+            webs.sendMessageToUser(String.valueOf(aid), log);
             return null;
         });
-
     }
+
     /**
      * 文件内容追加
      * @param