From 258505fa3bd1529867b3a77e6afccfd2ada62c10 Mon Sep 17 00:00:00 2001
From: "zhanglei@ap-leasing.com.cn" <zhanglei@ap-leasing.com.cn>
Date: Wed, 27 Sep 2023 11:00:29 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A3=8E=E6=8E=A7=E4=B8=AD=E5=8F=B0-=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96=E6=97=A5=E5=BF=97=E6=96=87=E4=BB=B6=E5=AD=98=E5=82=A8?=
 =?UTF-8?q?=E8=B7=AF=E5=BE=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/com/ample/esb/common/EsbCommon.java       |  2 +-
 .../esb/controller/AfsResultServlet.java      | 20 ++++++++++++++-----
 2 files changed, 16 insertions(+), 6 deletions(-)

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();