作者 朱兆平

优化READER

@@ -53,11 +53,15 @@ public class IMFReader extends Thread { @@ -53,11 +53,15 @@ public class IMFReader extends Thread {
53 53
54 try { 54 try {
55 String stype_value = XMPParse.getNodeValueFromXmlString(message, "/MSG/META/STYP"); 55 String stype_value = XMPParse.getNodeValueFromXmlString(message, "/MSG/META/STYP");
56 - fileName = path + stype_value + "_" + Utils.dateToStr(dt, "yyyyMMddhhmmssSSS") + ".xml";  
57 - Utils.saveFile(fileName, message);  
58 - dao.saveRecord("ALL", "FIMS", message);  
59 - logger.info("created " + fileName + " ok"); 56 + String type_value = XMPParse.getNodeValueFromXmlString(message, "/MSG/META/TYPE");
  57 + String sender_value = XMPParse.getNodeValueFromXmlString(message, "/MSG/META/SNDR");
  58 +
  59 +// fileName = path + stype_value + "_" + Utils.dateToStr(dt, "yyyyMMddhhmmssSSS") + ".xml";
  60 +// Utils.saveFile(fileName, message);
  61 + dao.saveRecord("ALL", sender_value, message,type_value,stype_value);
  62 +// logger.info("created " + fileName + " ok");
60 } catch (Exception var7) { 63 } catch (Exception var7) {
  64 + //出错的报文存储到报文目录
61 fileName = path + Utils.dateToStr(dt, "yyyyMMddhhmmssSSS") + ".txt"; 65 fileName = path + Utils.dateToStr(dt, "yyyyMMddhhmmssSSS") + ".txt";
62 Utils.saveFile(fileName, message); 66 Utils.saveFile(fileName, message);
63 logger.warn("created " + fileName + " ok"); 67 logger.warn("created " + fileName + " ok");