diff --git a/fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/CallReportDealTask.java b/fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/CallReportDealTask.java index 7dab208..68ad79c 100644 --- a/fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/CallReportDealTask.java +++ b/fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/CallReportDealTask.java @@ -69,7 +69,7 @@ public class CallReportDealTask { /** * 处理通话记录 */ - @Scheduled(initialDelay = 1000 * 5, fixedRate = 1000 * 5) + @Scheduled(initialDelay = 1000 * 5, fixedRate = 1000 * 15) public void dealCallReport() { List failList = new ArrayList<>(); String callStr; @@ -78,20 +78,21 @@ public class CallReportDealTask { if (Objects.isNull(dto)) { continue; } - final String mobileNo = dto.getPeerNo(); + final String staffMobile = dto.getStaffMobile(); + final String peerMobile = dto.getPeerNo(); final Long groupId = dto.getGroupId(); final Long staffId = dto.getStaffId(); try { boolean isValid = Objects.nonNull(staffId) && Objects.nonNull(groupId); if (!isValid) { - StaffInfoDTO info = ehrRpcService.queryStaffInfoByMobile(mobileNo); - BV.notNull(info, () -> "员工信息获取失败"); + StaffInfoDTO info = ehrRpcService.queryStaffInfoByMobile(staffMobile); + BV.notNull(info, () -> String.format("[%s]员工信息获取失败", staffMobile)); assert info != null; dto.setStaffId(info.getId()); dto.setGroupId(info.getGroupId()); } - followBizService.readCallReport(dto, true, queryAccidentCar(mobileNo, groupId)); - followBizService.readCallReport(dto, false, queryCustomerIds(mobileNo, groupId)); + followBizService.readCallReport(dto, true, queryAccidentCar(peerMobile, groupId)); + followBizService.readCallReport(dto, false, queryCustomerIds(peerMobile, groupId)); } catch (Exception e) { if (StringUtils.isValid(callStr)) { failList.add(callStr);