Commit d9f35c9ff94b2735a48d4b21a96e3db265411775

Authored by 张志伟
1 parent 8c7566e0

:sparkles: 处理通话记录信息bug修复

fw-valhalla-server/src/main/java/cn/fw/valhalla/controller/task/CallReportDealTask.java
... ... @@ -69,7 +69,7 @@ public class CallReportDealTask {
69 69 /**
70 70 * 处理通话记录
71 71 */
72   - @Scheduled(initialDelay = 1000 * 5, fixedRate = 1000 * 5)
  72 + @Scheduled(initialDelay = 1000 * 5, fixedRate = 1000 * 15)
73 73 public void dealCallReport() {
74 74 List<String> failList = new ArrayList<>();
75 75 String callStr;
... ... @@ -78,20 +78,21 @@ public class CallReportDealTask {
78 78 if (Objects.isNull(dto)) {
79 79 continue;
80 80 }
81   - final String mobileNo = dto.getPeerNo();
  81 + final String staffMobile = dto.getStaffMobile();
  82 + final String peerMobile = dto.getPeerNo();
82 83 final Long groupId = dto.getGroupId();
83 84 final Long staffId = dto.getStaffId();
84 85 try {
85 86 boolean isValid = Objects.nonNull(staffId) && Objects.nonNull(groupId);
86 87 if (!isValid) {
87   - StaffInfoDTO info = ehrRpcService.queryStaffInfoByMobile(mobileNo);
88   - BV.notNull(info, () -> "员工信息获取失败");
  88 + StaffInfoDTO info = ehrRpcService.queryStaffInfoByMobile(staffMobile);
  89 + BV.notNull(info, () -> String.format("[%s]员工信息获取失败", staffMobile));
89 90 assert info != null;
90 91 dto.setStaffId(info.getId());
91 92 dto.setGroupId(info.getGroupId());
92 93 }
93   - followBizService.readCallReport(dto, true, queryAccidentCar(mobileNo, groupId));
94   - followBizService.readCallReport(dto, false, queryCustomerIds(mobileNo, groupId));
  94 + followBizService.readCallReport(dto, true, queryAccidentCar(peerMobile, groupId));
  95 + followBizService.readCallReport(dto, false, queryCustomerIds(peerMobile, groupId));
95 96 } catch (Exception e) {
96 97 if (StringUtils.isValid(callStr)) {
97 98 failList.add(callStr);
... ...