Commit ebe8a708957289fb8d5ff01b84accb0da6d9e1b4
1 parent
4fd39c38
feature(*): 优化查询活动资格
- 优化查询活动资格
Showing
2 changed files
with
1 additions
and
6 deletions
fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/PubStandTask.java
... | ... | @@ -71,7 +71,7 @@ public class PubStandTask { |
71 | 71 | /** |
72 | 72 | * 执行分配 |
73 | 73 | */ |
74 | - @Scheduled(cron = "0/20 * 8-20 * * *") | |
74 | + @Scheduled(cron = "0/50 * 8-20 * * *") | |
75 | 75 | public void distributeBatch() { |
76 | 76 | List<GroupDTO> groups = oopService.allGroup(); |
77 | 77 | for (GroupDTO group : groups) { | ... | ... |
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/pub/PubDistributeBizService.java
... | ... | @@ -352,11 +352,6 @@ public class PubDistributeBizService { |
352 | 352 | dto.setLoseClue(Boolean.FALSE); |
353 | 353 | dto.setRenewalClue(hasInsFollow); |
354 | 354 | dto.setActivityNo(staffInfo.getIdCode()); |
355 | - try { | |
356 | - Thread.sleep(450); | |
357 | - } catch (InterruptedException e) { | |
358 | - log.info("节流失败"); | |
359 | - } | |
360 | 355 | Boolean canJoinActivity = mktRpcService.queryQualifications(dto); |
361 | 356 | if (Boolean.TRUE.equals(canJoinActivity)) { |
362 | 357 | list.add(vin); | ... | ... |