anpeng/apzl_leasing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

风控中台-优化日志文件存储路径

Browse Source
This commit is contained in:
zhanglei@ap-leasing.com.cn 2023-09-27 11:00:29 +08:00
parent 889f555a16
commit 258505fa3b
2 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/com/ample/esb/common/EsbCommon.java
View File

@ -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请求报文存为文件

20
src/com/ample/esb/controller/AfsResultServlet.java
View File

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