diff --git a/src/com/ample/esb/common/EsbCommon.java b/src/com/ample/esb/common/EsbCommon.java index b6f90f57c..e15418b4b 100644 --- a/src/com/ample/esb/common/EsbCommon.java +++ b/src/com/ample/esb/common/EsbCommon.java @@ -121,7 +121,7 @@ public class EsbCommon implements EsbServise { public Transaction transactionDo(){ //.创建实体类 Transaction tranRequest = createEsbTransaction(); - String logPath = BaicPropertiesUtil.get("log_path")+tranRequest.getMessageEsbHead().getTranCode()+"_"+tranRequest.getMessageEsbHead().getGlobalSeqNo(); + String logPath = BaicPropertiesUtil.get("log_path")+tranRequest.getMessageEsbHead().getTranCode()+"/"+DateUtils.dateNowCore()+"/"+tranRequest.getMessageEsbHead().getGlobalSeqNo(); //.转换为xml请求报文 String xmlRrquest = XstreamUtil.xmlConvert(tranRequest); //.将xml请求报文存为文件 diff --git a/src/com/ample/esb/controller/AfsResultServlet.java b/src/com/ample/esb/controller/AfsResultServlet.java index 9bc0b7382..d41debfa5 100644 --- a/src/com/ample/esb/controller/AfsResultServlet.java +++ b/src/com/ample/esb/controller/AfsResultServlet.java @@ -35,6 +35,7 @@ public class AfsResultServlet extends HttpServlet { response.setCharacterEncoding("utf-8"); PrintWriter out = null; String resultXml = null; + Transaction tran = null; try { out = response.getWriter(); BufferedReader in = new BufferedReader(new InputStreamReader(request.getInputStream(), "UTF-8")); @@ -44,7 +45,13 @@ public class AfsResultServlet extends HttpServlet { sb.append(line); } resultXml = sb.toString(); - ARE.getLog().info("接收到Rpt记录:" + resultXml); + ARE.getLog().info("反欺诈人工判定结果记录:" + resultXml); + + tran = this.objectConvert(resultXml); + String targetSystemId = tran.getMessageEsbHead().getTargetSystemId(); + if(!"APF".equals(targetSystemId)){ + return; + } } catch (IOException e) { e.printStackTrace(); } @@ -53,14 +60,17 @@ public class AfsResultServlet extends HttpServlet { out.close(); System.out.println("============反欺诈人工判定结果请求回调结束!============"); } - - public String updateResult(String requestXml){ + public Transaction objectConvert(String requestXml){ + Transaction tran = (Transaction)XstreamUtil.objectConvert(requestXml); + return tran; + } + public String updateResult(String requestXml){ + Transaction tran = (Transaction)XstreamUtil.objectConvert(requestXml); - String logPath = BaicPropertiesUtil.get("log_path"); String globalSeqNo = tran.getMessageEsbHead().getGlobalSeqNo(); String tranCode = tran.getMessageEsbHead().getTranCode(); String projectNo = tran.getMessageBody().getAfsResultRequest().getApplyNo(); - String filePath = logPath + tranCode + "_" + projectNo +"_"+ globalSeqNo; + String filePath =BaicPropertiesUtil.get("log_path")+ tranCode+ "/" +DateUtils.dateNowCore()+"/" + projectNo +"_"+ globalSeqNo; FileUtil.writeFile( filePath + "_request.txt", requestXml); String fraudAlert = tran.getMessageBody().getAfsResultRequest().getFraudAlert(); String actionTaken = tran.getMessageBody().getAfsResultRequest().getActionTaken();