public void duplication(TaskInfo taskInfo) {
 ? ?// 配置示例:{"contentDeduplication":{"num":1,"time":300},"frequencyDeduplication":{"num":5}}
 ? ?JSONObject property = JSON.parseObject(config.getProperty(DEDUPLICATION_RULE_KEY, AustinConstant.APOLLO_DEFAULT_VALUE_JSON_OBJECT));
 ? ?JSONObject contentDeduplication = property.getJSONObject(CONTENT_DEDUPLICATION);
 ? ?JSONObject frequencyDeduplication = property.getJSONObject(FREQUENCY_DEDUPLICATION);
?
 ? ?// 文案去重
 ? ?DeduplicationParam contentParams = DeduplicationParam.builder()
 ? ? ?  .deduplicationTime(contentDeduplication.getLong(TIME))
 ? ? ?  .countNum(contentDeduplication.getInteger(NUM)).taskInfo(taskInfo)
 ? ? ?  .anchorState(AnchorState.CONTENT_DEDUPLICATION)
 ? ? ?  .build();
 ? ?contentDeduplicationService.deduplication(contentParams);
?
?
 ? ?// 運(yùn)營(yíng)總規(guī)則去重(一天內(nèi)用戶收到最多同一個(gè)渠道的消息次數(shù))
 ? ?Long seconds = (DateUtil.endOfDay(new Date()).getTime() - DateUtil.current()) / 1000;
 ? ?DeduplicationParam businessParams = DeduplicationParam.builder()
 ? ? ?  .deduplicationTime(seconds)
 ? ? ?  .countNum(frequencyDeduplication.getInteger(NUM)).taskInfo(taskInfo)
 ? ? ?  .anchorState(AnchorState.RULE_DEDUPLICATION)
 ? ? ?  .build();
 ? ?frequencyDeduplicationService.deduplication(businessParams);
}

public void duplication(TaskInfo taskInfo) {
 ? ?// 配置樣例：{"contentDeduplication":{"num":1,"time":300},"frequencyDeduplication":{"num":5}}
 ? ?String deduplication = config.getProperty(DeduplicationConstants.DEDUPLICATION_RULE_KEY, AustinConstant.APOLLO_DEFAULT_VALUE_JSON_OBJECT);
 ? ?//去重
 ? ?DEDUPLICATION_LIST.forEach(
 ? ? ? ?key -> {
 ? ? ? ? ? ?DeduplicationParam deduplicationParam = builderFactory.select(key).build(deduplication, key);
 ? ? ? ? ? ?if (deduplicationParam != null) {
 ? ? ? ? ? ? ? ?deduplicationParam.setTaskInfo(taskInfo);
 ? ? ? ? ? ? ? ?DeduplicationService deduplicationService = findService(key + SERVICE);
 ? ? ? ? ? ? ? ?deduplicationService.deduplication(deduplicationParam);
 ? ? ? ? ?  }
 ? ? ?  }
 ?  );
}

public void duplication(TaskInfo taskInfo) {
 ? ?// 配置樣例：{"deduplication_10":{"num":1,"time":300},"deduplication_20":{"num":5}}
 ? ?String deduplicationConfig = config.getProperty(DEDUPLICATION_RULE_KEY, CommonConstant.EMPTY_JSON_OBJECT);
?
 ? ?// 去重
 ? ?List<Integer> deduplicationList = DeduplicationType.getDeduplicationList();
 ? ?for (Integer deduplicationType : deduplicationList) {
 ? ? ? ?DeduplicationParam deduplicationParam = deduplicationHolder.selectBuilder(deduplicationType).build(deduplicationConfig, taskInfo);
 ? ? ? ?if (Objects.nonNull(deduplicationParam)) {
 ? ? ? ? ? ?deduplicationHolder.selectService(deduplicationType).deduplication(deduplicationParam);
 ? ? ?  }
 ?  }
}

DeduplicationParam deduplicationParam = deduplicationHolder.selectBuilder(deduplicationType).build(deduplicationConfig, taskInfo);

/**
 * @author huskey
 * @date 2022/1/18
 */
@Service
public class DeduplicationHolder {
?
 ? ?private final Map<Integer, Builder> builderHolder = new HashMap<>(4);
 ? ?private final Map<Integer, DeduplicationService> serviceHolder = new HashMap<>(4);
?
 ? ?public Builder selectBuilder(Integer key) {
 ? ? ? ?return builderHolder.get(key);
 ?  }
?
 ? ?public DeduplicationService selectService(Integer key) {
 ? ? ? ?return serviceHolder.get(key);
 ?  }
?
 ? ?public void putBuilder(Integer key, Builder builder) {
 ? ? ? ?builderHolder.put(key, builder);
 ?  }
?
 ? ?public void putService(Integer key, DeduplicationService service) {
 ? ? ? ?serviceHolder.put(key, service);
 ?  }
}