feature:元年客户明细SQL组装

release
gaorl 2 years ago
parent a1c0b5c850
commit e8703fba53
  1. 52
      order-management-consumer/src/test/java/CustomerClean.java

@ -0,0 +1,52 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.junit.platform.commons.util.StringUtils;
import java.io.*;
public class CustomerClean {
public static void main(String[] args) {
try {
BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(new File("D:\\test\\buyer_manage_info_detail.txt"))));
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(new File("D:\\test\\detail_bak.txt"),true)));
while (true){
String s = br.readLine();
if(StringUtils.isBlank(s)){break;}
String[] split = s.split("\t");
String banks = split[3];
banks = banks.substring(1,banks.length()-1).replaceAll("\"\"","\"");
JSONArray jsonArray = JSONObject.parseArray(banks);
int i = 0;
for (Object o : jsonArray) {
StringBuilder sb = new StringBuilder();
sb.append("INSERT INTO `sales_order`.`buyer_manage_info_detail` ( `buyer_manage_id`, `bank_name`, `bank_account`, `address`, `phone`, `default_mark`, `create_user`, `update_user`, `create_time`, `update_time`) values (");
JSONObject o1 = (JSONObject) o;
String bankAccount = o1.getString("bankAccount");
String bankName = o1.getString("bankName");
sb.append("'").append(split[0].replaceAll("\"", "")).append("',");
sb.append("'").append(bankName).append("',");
sb.append("'").append(bankAccount).append("',");
sb.append("'").append(split[1].replaceAll("\"", "").replace(" ","")).append("',");
sb.append("'").append(split[2].replaceAll("\"", "")).append("',");
sb.append("'").append(i==0?1:0).append("',");
sb.append("'38',");
sb.append("'38',");
sb.append("'2023-04-28 11:44:11',");
sb.append("'2023-04-28 11:44:11');").append("\r\n");
bw.write(sb.toString());
//System.out.println(sb.toString());
i++;
}
}
bw.flush();
bw.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
Loading…
Cancel
Save