|
@@ -127,13 +127,14 @@ public class WdRedisStoreage {
|
|
|
|
|
|
if (cursor != null) {
|
|
|
for (WdInfo wdInfo : cursor) {
|
|
|
- //打印进度条
|
|
|
- Console.print("{}当前进度:{} {}/{}", '\r', StrUtil.repeat('#', (int) (50 * (cursor.getCurrentIndex() + 1) / total)), cursor.getCurrentIndex() + 1, total);
|
|
|
-
|
|
|
RedisUtils.getClient().getGeo(wdInfo.getAddrCode().substring(0, 4)).add(wdInfo.getLng().doubleValue(), wdInfo.getLat().doubleValue(), wdInfo.getWdId());
|
|
|
|
|
|
//存入已处理网点的时间
|
|
|
RedisUtils.setCacheObject(RedisContant.WD_TAG_LASTTIME, DateUtil.formatDateTime(wdInfo.getCollectTime()));
|
|
|
+
|
|
|
+ //打印进度条
|
|
|
+ //Console.print("{}当前进度:{} {}/{}", '\r', StrUtil.repeat('#', (int) (50 * (cursor.getCurrentIndex() + 1) / total)), cursor.getCurrentIndex() + 1, total);
|
|
|
+ Console.print("{}当前进度:{}/{}", '\r', cursor.getCurrentIndex() + 1, total);
|
|
|
}
|
|
|
if (cursor.isConsumed()) {
|
|
|
Console.log("----查询sql匹配中的数据已经消费完毕!");
|
|
@@ -187,10 +188,9 @@ public class WdRedisStoreage {
|
|
|
|
|
|
if (cursor != null) {
|
|
|
for (WdInfo wdInfo : cursor) {
|
|
|
- //打印进度条
|
|
|
- Console.print("{}当前进度:{} {}/{}", '\r', StrUtil.repeat('#', (int) (50 * (cursor.getCurrentIndex() + 1) / total)), cursor.getCurrentIndex() + 1, total);
|
|
|
-
|
|
|
wdTagAnalyse(wdInfo);
|
|
|
+ //打印进度条
|
|
|
+ Console.print("{}当前进度:{}/{}", '\r', cursor.getCurrentIndex() + 1, total);
|
|
|
}
|
|
|
if (cursor.isConsumed()) {
|
|
|
Console.log("----查询sql匹配中的数据已经消费完毕!");
|