只把新舱单系统要的报文放到本地备份文件A夹，入库错误的也记录

 #登录账号
 #登录账号
-loginname = KKW1
+loginname = SJCK
 #登录密码
 #登录密码
-loginpass = KKW1
+loginpass = SJCK_P
 #发送报文目录,相对程序目录
 #发送报文目录,相对程序目录
 readDirectory = /Users/mrz/Downloads/1.woowo
 readDirectory = /Users/mrz/Downloads/1.woowo
 #接收存储报文目录
 #接收存储报文目录

@@ -56,12 +56,34 @@ public class IMFSaveHandle {
             Document document = DocumentHelper.parseText(xmlmessage);
             Document document = DocumentHelper.parseText(xmlmessage);
             T_ETL_MESSAGE message = new T_ETL_MESSAGE();
             T_ETL_MESSAGE message = new T_ETL_MESSAGE();
 
 
-            message.setSndr(XMLXPath.getSingleValueByPath(document,SNDR));
+            String sndrm = XMLXPath.getSingleValueByPath(document,SNDR);
+            String typem = XMLXPath.getSingleValueByPath(document,TYPE);
+            String stypm = XMLXPath.getSingleValueByPath(document,STYP);
+
+            if ("TXD".equals(sndrm)){
+                if("EDEP".equals(stypm)
+                        || "EFOH".equals(stypm)
+                        || "ERCF".equals(stypm)
+                        || "PFFM".equals(stypm)
+                        || "UDEP".equals(stypm)
+                        || "UFOH".equals(stypm)
+                        || "URCF".equals(stypm)
+                        || "FFM".equals(stypm)
+                        || "IFWB".equals(stypm)
+                        || "IFHL".equals(stypm)){
+                    //存储至备份目录
+                    FileTool.writeFileToBak(xmlmessage);
+                }
+            }
+
+            message.setSndr(sndrm);
             message.setRcvr(XMLXPath.getSingleValueByPath(document,RCVR));
             message.setRcvr(XMLXPath.getSingleValueByPath(document,RCVR));
-            message.setType(XMLXPath.getSingleValueByPath(document,TYPE));
-            message.setStyp(XMLXPath.getSingleValueByPath(document,STYP));
+            message.setType(typem);
+            message.setStyp(stypm);
             message.setSeqn(XMLXPath.getSingleValueByPath(document,SEQN));
             message.setSeqn(XMLXPath.getSingleValueByPath(document,SEQN));
 
 
+
+
             String ddtm = XMLXPath.getSingleValueByPath(document,DDTM);
             String ddtm = XMLXPath.getSingleValueByPath(document,DDTM);
             Date ddtmDate = DateUtil.formatByyyyyMMddHHmmss(ddtm);
             Date ddtmDate = DateUtil.formatByyyyyMMddHHmmss(ddtm);
             message.setDdtm(ddtmDate);
             message.setDdtm(ddtmDate);

@@ -23,8 +23,6 @@ public class IMF_Reader extends Thread{
                 if (IMF_Task.LOGIN_OK) {
                 if (IMF_Task.LOGIN_OK) {
                         String message = this.client.getMSG();
                         String message = this.client.getMSG();
                         if (message != null) {
                         if (message != null) {
-                            //存储至备份目录
-                            FileTool.writeFileToBak(message);
                             IMFSaveHandle imfSaveHandle = new IMFSaveHandle();
                             IMFSaveHandle imfSaveHandle = new IMFSaveHandle();
                             imfSaveHandle.handle(message);
                             imfSaveHandle.handle(message);
                         }
                         }