Commit fa252412 authored by 杨锐's avatar 杨锐

根据md5(phoneNo,idNo)获取用户信息 测试DONE。

parent f1f7a089
...@@ -52,17 +52,17 @@ public class UserHashPhoneNoIdNoMappingController { ...@@ -52,17 +52,17 @@ public class UserHashPhoneNoIdNoMappingController {
log.info("start"); log.info("start");
long start = System.currentTimeMillis(); long start = System.currentTimeMillis();
long idStart = 0; long idStart = 0;
final int limit = 5000;
long count = jdbcTemplate.queryForObject("select count(id) from user_detail", Long.class);
Object state = stringRedisTemplate.opsForHash().get(SYNC_DATA_PHONE_NO_ID_NO, SYNC_DATA_PHONE_NO_ID_NO_SWITCH);
Object lastIdObj = stringRedisTemplate.opsForHash().get(SYNC_DATA_PHONE_NO_ID_NO, SYNC_DATA_PHONE_NO_ID_NO_LAST_ID); Object lastIdObj = stringRedisTemplate.opsForHash().get(SYNC_DATA_PHONE_NO_ID_NO, SYNC_DATA_PHONE_NO_ID_NO_LAST_ID);
if (lastIdObj != null) { if (lastIdObj != null) {
idStart = Long.valueOf(String.valueOf(lastIdObj)); idStart = Long.valueOf(String.valueOf(lastIdObj));
} }
if (state == null || "on".equals(state)) { final int limit = 5000;
if (count > 0) { long count = jdbcTemplate.queryForObject("select count(id) from user_detail where id > ?", Long.class, new Object[]{idStart});
long page = count / limit + 1; if (count > 0) {
for (int i = 0; i < page; i++) { long page = count / limit + 1;
for (int i = 0; i < page; i++) {
Object state = stringRedisTemplate.opsForHash().get(SYNC_DATA_PHONE_NO_ID_NO, SYNC_DATA_PHONE_NO_ID_NO_SWITCH);
if (state == null || "on".equals(state)) {
List<UserHashPhoneNoIdNoMapping> userHashPhoneNoIdNoMappings = Lists.newArrayList(); List<UserHashPhoneNoIdNoMapping> userHashPhoneNoIdNoMappings = Lists.newArrayList();
jdbcTemplate.query("select id, user_id, phone_no, id_no" + jdbcTemplate.query("select id, user_id, phone_no, id_no" +
" from user_detail where id > ? limit ?", new Object[]{idStart, limit}, new RowCallbackHandler() { " from user_detail where id > ? limit ?", new Object[]{idStart, limit}, new RowCallbackHandler() {
......
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