Skip to content

Q
qg-bl-service
Commit 27a13e8f authored by 郝彦辉's avatar 郝彦辉
Browse files
Options

方法update_huiTohei_type10,type=10的灰洗黑

parent b2b52cf6
Hide whitespace changes
Inline Side-by-side
Showing with 10 additions and 11 deletions
src/main/java/cn/quantgroup/qgblservice/service/impl/BlackListToolsManagerServiceImpl.java
View file @ 27a13e8f
...@@ -1165,7 +1165,7 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS ...@@ -1165,7 +1165,7 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS
"and a.user_id='##user_id##'"; "and a.user_id='##user_id##'";
//int maxId = 11429420; //int maxId = 11429420;
int maxId = 1; int maxId = 0;
try { try {
String value = stringRedisTemplate.opsForValue().get("UPDATE_HUITOHEI_MAXID_TYPE1"); String value = stringRedisTemplate.opsForValue().get("UPDATE_HUITOHEI_MAXID_TYPE1");
if (StringUtils.isNotEmpty(value)) { if (StringUtils.isNotEmpty(value)) {
...@@ -1174,7 +1174,7 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS ...@@ -1174,7 +1174,7 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS
} catch (Exception e) { } catch (Exception e) {
log.error("获取redis里值异常, key: {} ", "UPDATE_HUITOHEI_MAXID_TYPE1", e); log.error("获取redis里值异常, key: {} ", "UPDATE_HUITOHEI_MAXID_TYPE1", e);
} }
log.info("方法update_huiTohei_type2()查询缓存, maxId : {} ", maxId); log.info("方法update_huiTohei_type10()查询缓存, maxId : {} ", maxId);
if (maxId <= 0) { if (maxId <= 0) {
return; return;
} }
...@@ -1189,14 +1189,13 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS ...@@ -1189,14 +1189,13 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS
for (int page = 1; page <= totalPage; page++) { for (int page = 1; page <= totalPage; page++) {
startId = (page - 1) * LIMIT_1000; startId = (page - 1) * LIMIT_1000;
endId = page * LIMIT_1000; endId = page * LIMIT_1000;
endId = 8900932;
long thisPageStart = System.currentTimeMillis(); long thisPageStart = System.currentTimeMillis();
List<TmpBlackGreyList> updateBeanList = null; List<TmpBlackGreyList> updateBeanList = null;
int thisPageOk = 0; int thisPageOk = 0;
try { try {
log.info("方法update_huiTohei_type2()处理开始 page: {} , startId: {} , endId: {} , totalPage: {} ------>>>>>>", page, startId, endId, totalPage); log.info("方法update_huiTohei_type10()处理开始 page: {} , startId: {} , endId: {} , totalPage: {} ------>>>>>>", page, startId, endId, totalPage);
List<TmpBlackGreyList> tmpQueryList = blackListJdbcTemplate.query(sql_blacklist3_query, new Object[]{startId, endId}, new RowMapper<TmpBlackGreyList>() { List<TmpBlackGreyList> tmpQueryList = blackListJdbcTemplate.query(sql_blacklist3_query, new Object[]{startId, endId}, new RowMapper<TmpBlackGreyList>() {
@Override @Override
public TmpBlackGreyList mapRow(ResultSet rs, int rowNum) throws SQLException { public TmpBlackGreyList mapRow(ResultSet rs, int rowNum) throws SQLException {
...@@ -1246,9 +1245,9 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS ...@@ -1246,9 +1245,9 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS
try { try {
in_overdue_Obj = acsdbJdbcTemplate.queryForObject(sql_acsdb_query_type10.replace("##user_id##", "" + xyqbUser.getId()), String.class); in_overdue_Obj = acsdbJdbcTemplate.queryForObject(sql_acsdb_query_type10.replace("##user_id##", "" + xyqbUser.getId()), String.class);
} catch (EmptyResultDataAccessException e) { } catch (EmptyResultDataAccessException e) {
log.error("方法update_huiTohei_type2查询逾期in_overdue_Obj异常, uuid: {} , idNo: {} , name: {} , e: {} ", queryBean.getUuid(), queryBean.getIdNo().trim().toUpperCase(), queryBean.getName().trim(), e.toString()); log.error("方法update_huiTohei_type10查询逾期in_overdue_Obj异常, uuid: {} , idNo: {} , name: {} , e: {} ", queryBean.getUuid(), queryBean.getIdNo().trim().toUpperCase(), queryBean.getName().trim(), e.toString());
} finally { } finally {
log.info("方法update_huiTohei_type2查询逾期in_overdue_Obj : {} , uuid: {} ", in_overdue_Obj != null ? in_overdue_Obj.toString() : "null", queryBean.getUuid()); log.info("方法update_huiTohei_type10查询逾期in_overdue_Obj : {} , uuid: {} ", in_overdue_Obj != null ? in_overdue_Obj.toString() : "null", queryBean.getUuid());
} }
if (in_overdue_Obj != null && StringUtils.isNotEmpty(in_overdue_Obj.toString())) { if (in_overdue_Obj != null && StringUtils.isNotEmpty(in_overdue_Obj.toString())) {
...@@ -1264,7 +1263,7 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS ...@@ -1264,7 +1263,7 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS
log.warn("查询用户user_id为空跳过, id: {} ", queryBean.getId()); log.warn("查询用户user_id为空跳过, id: {} ", queryBean.getId());
} }
} }
log.info("方法update_huiTohei_type2()筛选结束, page: {} , startId: {} , endId: {}, list大小: {} ", page, startId, endId, updateBeanList.size()); log.info("方法update_huiTohei_type10()筛选结束, page: {} , startId: {} , endId: {}, list大小: {} ", page, startId, endId, updateBeanList.size());
} }
if (updateBeanList.size() > 0) { if (updateBeanList.size() > 0) {
...@@ -1282,19 +1281,19 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS ...@@ -1282,19 +1281,19 @@ public class BlackListToolsManagerServiceImpl implements IBlackListToolsManagerS
totalOkCount = totalOkCount + update; totalOkCount = totalOkCount + update;
} catch (Exception e) { } catch (Exception e) {
log.error("方法update_huiTohei_type2()修改异常, id: {} ", bean.getId(), e); log.error("方法update_huiTohei_type10()修改异常, id: {} ", bean.getId(), e);
} }
} }
} }
} }
} catch (Exception e) { } catch (Exception e) {
log.error("方法update_huiTohei_type2()处理异常, page: {} , startId: {} , endId: {} ", page, startId, endId, e); log.error("方法update_huiTohei_type10()处理异常, page: {} , startId: {} , endId: {} ", page, startId, endId, e);
} finally { } finally {
log.info("方法update_huiTohei_type2()处理结束 page: {} , startId: {} , endId: {} , updateBeanList: {} , thisPageOk: {} , 耗时: {} <<<<<<------\n", page, startId, endId, (updateBeanList != null ? updateBeanList.size() : 0), thisPageOk, ((System.currentTimeMillis() - thisPageStart) + ".ms")); log.info("方法update_huiTohei_type10()处理结束 page: {} , startId: {} , endId: {} , updateBeanList: {} , thisPageOk: {} , 耗时: {} <<<<<<------\n", page, startId, endId, (updateBeanList != null ? updateBeanList.size() : 0), thisPageOk, ((System.currentTimeMillis() - thisPageStart) + ".ms"));
} }
} }
log.info("\n>>>>>>方法update_huiTohei_type2()处理 Method End, totalQueryCount: {} , totalUpdateCount: {} , totalOkCount: {} , total cost: {} <<<<<<", totalQueryCount, totalUpdateCount, totalOkCount, (System.currentTimeMillis() - totalStar) + ".ms"); log.info("\n>>>>>>方法update_huiTohei_type10()处理 Method End, totalQueryCount: {} , totalUpdateCount: {} , totalOkCount: {} , total cost: {} <<<<<<", totalQueryCount, totalUpdateCount, totalOkCount, (System.currentTimeMillis() - totalStar) + ".ms");
} }
......
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