| | |
| | | .findFirst(); |
| | | |
| | | Reference finalRef = existingRef.orElse(validRefGroup.get(0)); |
| | | // 重复次数 = 老的 + (这一组里一共抓到多少-1) |
| | | int repetitionNum = (finalRef.getRepetition_num() == null ? 1 : finalRef.getRepetition_num()) |
| | | + (validRefGroup.size() - 1); |
| | | finalRef.setRepetition_num(repetitionNum); |
| | |
| | | log.warn("引用核心字段为空,跳过映射:{}", ref); |
| | | return; |
| | | } |
| | | String key = ref.getQuestion_id() + "|" + ref.getTitle() + "|" + ref.getUrl() + "|" + ref.getDomain(); |
| | | String key = ref.getQuestion_id() + "|" + ref.getTitle() + "|" + ref.getUrl() + "|" + ref.getDomain() + "|" + ref.getNum(); |
| | | map.computeIfAbsent(key, k -> new ArrayList<>()).add(ref); |
| | | } |
| | | |
| | |
| | | } else if (userResult.getError().contains("信息错误")) { |
| | | userWrapper.set(User::getStatus, "信息错误"); |
| | | userService.update(userWrapper); |
| | | // 批量更新问题状态为失败 |
| | | questionService.update(new LambdaUpdateWrapper<Question>() |
| | | .eq(Question::getKeyword_id, keyword.getKeyword_id()) |
| | | .set(Question::getStatus, "failed") |
| | | .set(Question::getError, "账户信息错误")); |
| | | } |
| | | } |
| | | } |