| | |
|---|
| | | |
|---|
| | | @Value("${phoneUpEveryHour}") |
|---|
| | | private Integer phoneUpEveryHour; |
|---|
| | | @Value("${phoneEndHour}") |
|---|
| | | private Integer phoneEndHour; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 查询单一任务（随访） |
|---|
| | |
|---|
| | | //phoneCount() 通过给出的每个小时需要打出的电话量，算出到晚上8点一点能打出多少个电话，获取到总量 |
|---|
| | | //如果需要立即执行的数据量大于一天要执行的上限，则只取上限的数量，其它的则放回redis中 |
|---|
| | | count = Math.min(phoneCount(), (int) size); |
|---|
| | | if (count != 0) { |
|---|
| | | cacheList = listOps.range("cache-0", 0, count - 1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | log.error("任务拉取cache-0的值是多少：{}", cacheList); |
|---|
| | |
|---|
| | | PullTaskVO pullTaskVO = new PullTaskVO(); |
|---|
| | | String subId = subIds.get(i).trim(); |
|---|
| | | ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(Long.valueOf(subId)); |
|---|
| | | if (ObjectUtils.isEmpty(serviceSubtask)) { |
|---|
| | | log.error("该subId有问题，在表中查询不到：{}", subId); |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid()); |
|---|
| | | IvrTaskTemplate ivrTaskTemplate = ivrTaskTemplateService.selectIvrTaskTemplateByID(serviceSubtask.getTemplateid()); |
|---|
| | | if (ObjectUtils.isEmpty(ivrTaskTemplate)) continue; |
|---|
| | |
|---|
| | | // 当前时间 |
|---|
| | | LocalTime currentTime = LocalTime.now(); |
|---|
| | | // 目标时间（晚上 8 点） |
|---|
| | | LocalTime targetTime = LocalTime.of(20, 0); |
|---|
| | | LocalTime targetTime = LocalTime.of(phoneEndHour, 0); |
|---|
| | | // 计算当前时间到目标时间的时长 |
|---|
| | | Duration duration = Duration.between(currentTime, targetTime); |
|---|
| | | // 获取剩余时间的小时数 |
|---|
| | | long remainingHours = duration.toHours(); |
|---|
| | | long remainingHours = 0; |
|---|
| | | long remainingMinutes = duration.toMinutes(); |
|---|
| | | //如果超过8点,就设置为0 |
|---|
| | | if (remainingHours < 0) remainingHours = 0; |
|---|
| | | //距离结束时间小于20分钟，就不拉取了 |
|---|
| | | if (remainingMinutes < 20) remainingHours = 0; |
|---|
| | | else if (remainingMinutes < 60 && remainingMinutes > 20) remainingHours = 1; |
|---|
| | | else if (remainingMinutes > 60) remainingHours = remainingMinutes / 60; |
|---|
| | | // 计算剩余可以打的电话数 |
|---|
| | | int remainingCalls = (int) (remainingHours * phoneUpEveryHour); |
|---|
| | | return remainingCalls; |
|---|
