Commit c5855d83 authored by data爬虫-冯 军凯's avatar data爬虫-冯 军凯

申请单数据清洗test

parent 55e4658a
package cn.quantgroup.dbc.utils;
import cn.quantgroup.dbc.spark.applyList.ApplyListRow;
import org.apache.commons.lang3.StringUtils;
import java.sql.*;
import java.util.ArrayList;
......@@ -131,6 +132,11 @@ public class JdbcExecuters {
ps.setString(1, applyListRow.getChannelGroupNo());
ps.setString(2, applyListRow.getChannelId());
ps.setString(3, applyListRow.getProductType());
String uuid = applyListRow.getUuid();
if(StringUtils.isBlank(uuid)){
System.out.println("orderNo: "+applyListRow.getApplyNo());
continue;
}
ps.setString(4, applyListRow.getUuid());
ps.setString(5, applyListRow.getApplyNo());
ps.setString(6, applyListRow.getApplyStatus());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment