申请单数据清洗test

src/main/java/cn/quantgroup/dbc/spark/applyList/ApplyListExportToBizFlowMain.java

@@ -131,7 +131,7 @@ public class ApplyListExportToBizFlowMain {
 
                     Timestamp fund_result_at = result.getAs("fund_result_at");
                     applyListRow.setAssetsResult(getAssetsResult(apply_status, fund_result_at));
-                    applyListRow.setAssetsFinishTime(getAssetsFinishTime(fund_result_at, apply_status, risk_notify_time, orderNo));
+                    applyListRow.setAssetsFinishTime(getAssetsFinishTime(fund_result_at, apply_status, risk_notify_time, orderNo, parse));
 
                     Timestamp applyNoCreatedAt = result.getAs("created_at");
                     applyListRow.setCreatedAt(applyNoCreatedAt);
@@ -173,7 +173,7 @@ public class ApplyListExportToBizFlowMain {
         return null; //未知情况为空
     }
 
-    public static Timestamp getAssetsFinishTime(Timestamp fund_result_at, String apply_status, Timestamp risk_notify_time, String orderNo) {
+    public static Timestamp getAssetsFinishTime(Timestamp fund_result_at, String apply_status, Timestamp risk_notify_time, String orderNo, Date parse) {
 
         if(StringUtils.isBlank(apply_status)){ //apply_status = null 一定是未提交申请单
             return null;
@@ -184,6 +184,9 @@ public class ApplyListExportToBizFlowMain {
         }
 
         if("1".equals(apply_status)){  //说明该申请单提交成功授信了 1-风控审核拒绝
+            if(new Timestamp(parse.getTime()).compareTo(risk_notify_time) == 0){
+                return null; //召回
+            }
             return risk_notify_time; //返回风控审核通知时间
         }
 
@@ -193,7 +196,7 @@ public class ApplyListExportToBizFlowMain {
 
     public static String getAssetsResult(String apply_status, Timestamp fund_result_at) { // fund_result_at为null 且 apply_status为2 并不清楚资方是否审核通过还是拒绝
 
-        if("3".equals(apply_status)){ //资方审核拒绝  只有这个时候才知道资产分发状态是成功还是失败
+        if("3".equals(apply_status) && "1".equals(apply_status)){ //资方审核拒绝  只有这个时候才知道资产分发状态是成功还是失败   apply_status = 1 拒绝 资方拒绝
             return "0"; //biz 0 失败
         }