申请单数据清洗test

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

@@ -52,6 +52,7 @@ public class ApplyListExportToBizFlowMain {
                 quotaCreditRow.setCreated_at(Timestamp.valueOf(quotaCreditTmp[13]));
             } catch (Exception e) {
                 System.out.println("申请单异常" + JSON.toJSONString(quotaCreditTmp));
+                e.printStackTrace();
             }
             return quotaCreditRow;
         }, Encoders.bean(QuotaCredit.class));
@@ -72,9 +73,11 @@ public class ApplyListExportToBizFlowMain {
                 applyQuotaRecordRow.setApply_status(applyQuotaRecordTmp[8]);
                 applyQuotaRecordRow.setRisk_notify_time(Timestamp.valueOf(applyQuotaRecordTmp[11]));
                 applyQuotaRecordRow.setOrder_no(applyQuotaRecordTmp[12]);
-                applyQuotaRecordRow.setFund_result_at(Timestamp.valueOf(applyQuotaRecordTmp[15]));
+                String s = applyQuotaRecordTmp[15];
+                applyQuotaRecordRow.setFund_result_at(StringUtils.isNotBlank(s) ? Timestamp.valueOf(applyQuotaRecordTmp[15]) : null);
             } catch (Exception e) {
                 System.out.println("提交申请单异常" + JSON.toJSONString(applyQuotaRecordTmp));
+                e.printStackTrace();
             }
             return applyQuotaRecordRow;
         }, Encoders.bean(ApplyQuotaRecord.class));