u proxy detect

lcstore · Jul 14, 2015 · 0f85ad4 · 0f85ad4
1 parent 13b64ef
commit 0f85ad4
Showing 1 changed file with 11 additions and 3 deletions.
diff --git a/...-core-tasker/src/test/java/com/lezo/iscript/yeam/config/strategy/ProxyDetectStrategy.java b/...-core-tasker/src/test/java/com/lezo/iscript/yeam/config/strategy/ProxyDetectStrategy.java
@@ -80,17 +80,25 @@ public void run() {
                     Long fromId = 0L;
                     Long minRetryId = 2863037L;
                     lastMaxId = lastMaxId < minRetryId ? minRetryId : lastMaxId;
-                    fromId = status == 0 ? lastMaxId : fromId;
                     while (true) {
                         List<ProxyDetectDto> dtoList = proxyDetectService.getProxyDetectDtosFromId(fromId, limit,
                                 status);
-                        taskId = UUID.randomUUID().toString();
-                        offerDetectTasks(dtoList, taskId);
+                        if (ProxyDetectDto.STATUS_RETRY == status) {
+                            List<ProxyDetectDto> newList = new ArrayList<ProxyDetectDto>(dtoList.size());
+                            for (ProxyDetectDto dto : dtoList) {
+                                if (dto.getId() >= lastMaxId || dto.getSuccessCount() > 5) {
+                                    newList.add(dto);
+                                }
+                            }
+                            dtoList = newList;
+                        }
                         for (ProxyDetectDto dto : dtoList) {
                             if (dto.getId() > fromId) {
                                 fromId = dto.getId();
                             }
                         }
+                        taskId = UUID.randomUUID().toString();
+                        offerDetectTasks(dtoList, taskId);
                         totalCount += dtoList.size();
                         if (dtoList.size() < limit) {
                             break;