申请单数据清洗test

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

@@ -18,6 +18,33 @@ public class ApplyListRow {
     private String auditResult;
     private Timestamp auditValidTime;
     private Timestamp applySubmitTime;
+    private String assetsResult;
+    private Timestamp assetsFinishTime;
+    private Timestamp createdAt;
+
+    public String getAssetsResult() {
+        return assetsResult;
+    }
+
+    public void setAssetsResult(String assetsResult) {
+        this.assetsResult = assetsResult;
+    }
+
+    public Timestamp getAssetsFinishTime() {
+        return assetsFinishTime;
+    }
+
+    public void setAssetsFinishTime(Timestamp assetsFinishTime) {
+        this.assetsFinishTime = assetsFinishTime;
+    }
+
+    public Timestamp getCreatedAt() {
+        return createdAt;
+    }
+
+    public void setCreatedAt(Timestamp createdAt) {
+        this.createdAt = createdAt;
+    }
 
     public Long getId() {
         return id;

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

@@ -18,6 +18,15 @@ public class ApplyQuotaRecord {
     private String apply_status;
     private Timestamp risk_notify_time;
     private String order_no;
+    private Timestamp fund_result_at;
+
+    public Timestamp getFund_result_at() {
+        return fund_result_at;
+    }
+
+    public void setFund_result_at(Timestamp fund_result_at) {
+        this.fund_result_at = fund_result_at;
+    }
 
     public String getUser_id() {
         return user_id;

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

@@ -16,6 +16,15 @@ public class QuotaCredit {
     private String order_no;
     private Timestamp receive_at;
     private String credit_status;
+    private Timestamp created_at;
+
+    public Timestamp getCreated_at() {
+        return created_at;
+    }
+
+    public void setCreated_at(Timestamp created_at) {
+        this.created_at = created_at;
+    }
 
     public Timestamp getReceive_at() {
         return receive_at;

src/main/java/cn/quantgroup/dbc/utils/JdbcExecuters.java

@@ -127,7 +127,7 @@ public class JdbcExecuters {
             conn.setAutoCommit(false);
             for (int i = 0; i < applyListRows.size(); i++) {
                 ApplyListRow applyListRow = applyListRows.get(i);
-//                ps.setString(1, applyListRow.getApplyNo());
+//                `channel_group_no`, `channel_id`, `product_type`, `uuid`, `apply_no`, `apply_status`, `audit_result`, `apply_submit_time`, `audit_valid_time`, `assets_result`, `assets_finish_time`, created_at
                 ps.setString(1, applyListRow.getChannelGroupNo());
                 ps.setString(2, applyListRow.getChannelId());
                 ps.setString(3, applyListRow.getProductType());
@@ -136,6 +136,11 @@ public class JdbcExecuters {
                 ps.setString(6, applyListRow.getApplyStatus());
                 ps.setString(7, applyListRow.getAuditResult());
                 ps.setTimestamp(8, applyListRow.getApplySubmitTime()==null?null:applyListRow.getApplySubmitTime());
+                ps.setTimestamp(9, applyListRow.getAuditValidTime()==null?null:applyListRow.getAuditValidTime());
+                ps.setString(10, applyListRow.getAssetsResult()==null?null:applyListRow.getAssetsResult());
+                ps.setTimestamp(11, applyListRow.getAssetsFinishTime()==null?null:applyListRow.getAssetsFinishTime());
+                ps.setTimestamp(12, applyListRow.getCreatedAt()==null?null:applyListRow.getCreatedAt());
+
 
                 ps.addBatch();
             }