Commit 90a3b668 authored by 黎博's avatar 黎博

清数据新增兜底删除方案

parent 0561a4f3
......@@ -68,6 +68,7 @@ public class ClearDataController {
log.info("开始删除{}环境{}用户vcc_talos中的数据!", namespace, phoneNo);
SwitchDataSource.dataSourceSwitch(namespace, "vcc_talos");
jdbcTemplate.execute("DELETE FROM `account` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `account` WHERE phone_no = " + phoneNo);
jdbcTemplate.execute("DELETE FROM `risk_record` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `auth_record` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `contract_record` WHERE user_id = " + userId);
......@@ -84,6 +85,7 @@ public class ClearDataController {
log.info("开始删除{}环境{}用户acsdb中的数据!", namespace, phoneNo);
SwitchDataSource.dataSourceSwitch(namespace, "acsdb");
jdbcTemplate.execute("DELETE FROM `acs_account` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `acs_account` WHERE mobile_no = " + phoneNo);
jdbcTemplate.execute("DELETE FROM `acs_bill` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `acs_cash_account` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `acs_cash_account_record` WHERE user_id = " + userId);
......@@ -124,7 +126,9 @@ public class ClearDataController {
}
}
jdbcTemplate.execute("DELETE FROM `user` WHERE id = " + userId);
jdbcTemplate.execute("DELETE FROM `user` WHERE phone_no = " + phoneNo);
jdbcTemplate.execute("DELETE FROM `user_detail` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `user_detail` WHERE phone_no = " + phoneNo);
jdbcTemplate.execute("DELETE FROM `wechat_userinfo` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `address` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `user_attached` WHERE user_id = " + userId);
......
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