diff --git a/order-management-consumer/src/test/java/CustomerClean.java b/order-management-consumer/src/test/java/CustomerClean.java new file mode 100644 index 00000000..c29ea2bd --- /dev/null +++ b/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(); + } + } +}