Commit fe5fcdc1 authored by 黎博's avatar 黎博

去掉acs_capital_transfer_plan

parent 8622d7f2
......@@ -27,12 +27,6 @@ public class ClearDataServiceImpl implements ClearDataService {
XjfqGenProcessVo xjfqGenProcessVo = xyqbBasicQueryService.getUserInfoByPhoneNo(namespace, phoneNo);
String userId = xjfqGenProcessVo.getUserId();
String uuid = xjfqGenProcessVo.getUuid();
log.info("开始删除{}环境{}用户xyqb_user中的数据!", namespace, phoneNo);
SwitchDataSource.dataSourceSwitch(namespace, "xyqb_user");
jdbcTemplate.execute("DELETE FROM `user` WHERE id = " + userId);
jdbcTemplate.execute("DELETE FROM `user_detail` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `wechat_userinfo` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `address` WHERE user_id = " + userId);
log.info("开始删除{}环境{}用户kdsp中的数据!", namespace, phoneNo);
SwitchDataSource.dataSourceSwitch(namespace, "kdsp");
......@@ -76,7 +70,7 @@ public class ClearDataServiceImpl implements ClearDataService {
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);
jdbcTemplate.execute("DELETE FROM `acs_capital_transfer_plan` WHERE user_id = " + userId);
// jdbcTemplate.execute("DELETE FROM `acs_capital_transfer_plan` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `acs_commodity` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `acs_customer` WHERE uuid = '" + uuid + "'");
jdbcTemplate.execute("DELETE FROM `acs_pay_order` WHERE user_id = " + userId);
......@@ -90,6 +84,13 @@ public class ClearDataServiceImpl implements ClearDataService {
jdbcTemplate.execute("DELETE FROM `user_quota_locker` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `user_quota_log` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `user_quota_record` WHERE user_id = " + userId);
log.info("开始删除{}环境{}用户xyqb_user中的数据!", namespace, phoneNo);
SwitchDataSource.dataSourceSwitch(namespace, "xyqb_user");
jdbcTemplate.execute("DELETE FROM `user` WHERE id = " + userId);
jdbcTemplate.execute("DELETE FROM `user_detail` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `wechat_userinfo` WHERE user_id = " + userId);
jdbcTemplate.execute("DELETE FROM `address` WHERE user_id = " + userId);
return true;
}
}
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