比例分成算法--java

2024-06-22 11:18
文章标签 java 算法 分成 比例

本文主要是介绍比例分成算法--java，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

关于业绩分配，常常会出现几家公司或者几个人合作的情况，那么合作之后创造出来的业绩价值如何分配的呢？有可能是1:1或者3:7.或者是3:3:4等等。那么我们针对这种情况就设计出来了一套比例分成系统。

代码如下所示：

主代码：

package com.handler.mark.cardperformance;import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.dataplatform.dto.base.IBaseOrgDTO;
import com.dataplatform.enums.DimensionChannelGroupEnum;
import com.dataplatform.model.ApplyDetailInfo;
import com.dataplatform.util.MarkByProportionUtil;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import redis.clients.jedis.ShardedJedis;
import redis.clients.jedis.ShardedJedisPool;import java.math.BigInteger;
import java.util.ArrayList;
import java.util.List;/*** Created by on 2018/7/20.*//*** 比例分成算法* @author * @date 2018-07-26* @version 1.0**/
public class WeightRoundRobinBo {private static final int DEF_CURRENT_INDEX = -1;private static final int DEF_CURRENT_WEIGHT = 0;private static final String KEY_CURRENT_INDEX = "currentIndex";private static final String KEY_CURRENT_WEIGHT = "currentWeight";private Logger LOG = LoggerFactory.getLogger(WeightRoundRobinBo.class);private ShardedJedisPool shardedJedisPool;@SuppressWarnings("unused")private WeightRoundRobinBo() {}/*** 自定义构造方法* @param orgListOfChannel 渠道所对应机构列表* @param currentEnum* @param applyDetailInfo    当前进件信息* @param shardedJedisPool*/public WeightRoundRobinBo(List<? extends IBaseOrgDTO> orgListOfChannel, DimensionChannelGroupEnum currentEnum, ApplyDetailInfo applyDetailInfo, ShardedJedisPool shardedJedisPool) {this.orgListOfChannel = orgListOfChannel;this.shardedJedisPool = shardedJedisPool;try(ShardedJedis jedis = shardedJedisPool.getResource()){/** 持卡用户进件与新用户进件分开打标*/this.redisKey = MarkByProportionUtil.getRedisKeyOfCurrentWight(currentEnum.getDimensionCode(),currentEnum.getChannelGroupCode(),applyDetailInfo.getSource(),applyDetailInfo.getIsCardHolder());if(StringUtils.isBlank(redisKey)){throw new RuntimeException("illegal parameters: redisKey is null");}JSONObject json = JSON.parseObject(jedis.get(this.redisKey));String currentIndexStr = json == null ? null : json.getString(KEY_CURRENT_INDEX);String currentWeightStr = json == null ? null : json.getString(KEY_CURRENT_WEIGHT);this.currentIndex = StringUtils.isNumeric(currentIndexStr) ? Integer.parseInt(currentIndexStr) : DEF_CURRENT_INDEX;this.currentWeight = StringUtils.isNumeric(currentWeightStr) ? Integer.parseInt(currentWeightStr) : DEF_CURRENT_WEIGHT;this.orgCount = orgListOfChannel.size();this.maxWeight = greatestWeight();this.gcdWeight = greatestCommonDivisor();this.initStatus = true;}catch (Exception e){LOG.error("WeightRoundRobin init error: ", e);}}/*** 上次选择机构*/private int currentIndex = DEF_CURRENT_INDEX;/*** 当前调度的权值*/private int currentWeight = DEF_CURRENT_WEIGHT;/*** 最大权重*/private int maxWeight;/*** 权重的最大公约数*/private int gcdWeight;/*** 机构数量*/private int orgCount;private List<? extends IBaseOrgDTO> orgListOfChannel = new ArrayList<>();/*** redis上保存当前index和weight的key*/private String redisKey;/*** 是否初始化*/private boolean initStatus = false;/*** 获取两个数的最大公约数*/private int greaterCommonDivisor(int a, int b) {BigInteger aBig = new BigInteger(String.valueOf(a));BigInteger bBig = new BigInteger(String.valueOf(b));return aBig.gcd(bBig).intValue();}/*** 遍历获取所有机构比例的最大公约数*/private int greatestCommonDivisor() {int divisor = 0;for (int index = 0, len = orgListOfChannel.size(); index < len - 1; index++) {if (index == 0) {divisor = greaterCommonDivisor(orgListOfChannel.get(index).getProportion(), orgListOfChannel.get(index + 1).getProportion());} else {divisor = greaterCommonDivisor(divisor, orgListOfChannel.get(index).getProportion());}}return divisor;}/*** 遍历获取最大的机构占比（权重）*/private int greatestWeight() {int weight = 0;for (IBaseOrgDTO orgObj : orgListOfChannel) {if (weight < orgObj.getProportion()) {weight = orgObj.getProportion();}}return weight;}/*** 根据权重轮询获取当前org** @gcdWeight 权重的最大公约数* @currentIndex 用于记录当前轮询链表的位置* @currentWeight 用于记录当前权重值* @orgListOfChannel 用于当前进件的渠道所对应的分成机构列表*** 初始从最大的权重（占比）进行分配 currentWeight = maxWeight** 非初始情况，根据redis缓存中保存的位置currentIndex和currentWeight继续分配** 遍历机构列表，每次遍历输出大于等于currentWeight的机构对象** 每次遍历完，将currentWeight减去 所有机构权重值的最大公约数，再次遍历输出** 直到currentWeight小于等于零，即完成了一遍权重轮询，每一个权重值都输出了对应比例的次数***/private IBaseOrgDTO getOrgInfo() {while (true) {currentIndex = (currentIndex + 1) % orgCount;if (currentIndex == 0) {currentWeight = currentWeight - gcdWeight;if (currentWeight <= 0) {currentWeight = maxWeight;if (currentWeight == 0) {return null;}}}if (orgListOfChannel.get(currentIndex).getProportion() >= currentWeight) {return orgListOfChannel.get(currentIndex);}}}/*** 输出org后，将currentIndex和currentWeight更新到redis上*/private void updateRedis(){JSONObject json = new JSONObject();json.put(KEY_CURRENT_INDEX, currentIndex);json.put(KEY_CURRENT_WEIGHT, currentWeight);try(ShardedJedis jedis = shardedJedisPool.getResource()){jedis.set(this.redisKey, json.toJSONString());}catch (Exception e){LOG.error("updateRedis error: ", e);}}public IBaseOrgDTO execute(){IBaseOrgDTO org = null;if(initStatus) {org = getOrgInfo();updateRedis();}return org;}}

package com.cmbc.util;import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;/*** Created by on 2018/8/13.*/
public class MarkByProportionUtil {private static Logger LOG = LoggerFactory.getLogger(MarkByProportionUtil.class);/*** 比例打标redis key前缀*/public static final String REDIS_KEY_PREFIX = "WSDP_index&weight";/*** 比例打标redis key分隔符*/public static final String REDIS_KEY_SEPARATOR = ":";public static String getRedisKeyOfCurrentWight(String dimensionCode, String channelGroupCode, String channel, int isCardHolder) {if (StringUtils.isAnyBlank(dimensionCode, channelGroupCode, channel)) {LOG.error("illegal parameters:  dimensionCode:{},  channelGroupCode:{},  channel:{}", dimensionCode, channelGroupCode, channel);}/** 固定前缀 + 维度code + 渠道组code + 渠道代码 +　是否持卡人　*/String key = new StringBuffer().append(REDIS_KEY_PREFIX).append(REDIS_KEY_SEPARATOR).append(dimensionCode).append(REDIS_KEY_SEPARATOR).append(channelGroupCode).append(REDIS_KEY_SEPARATOR).append(channel).append("_").append(isCardHolder).toString();return key;}
}

package com.cmbc.dto.base;/*** Created by on 2018/7/22.*/
public interface  IBaseOrgDTO {/*** 获取机构id* @return*/public abstract Integer getOrgId();/*** 获取比例* @return*/public abstract Integer getProportion();/*** 获取机构类型* @return*/public abstract String getOrgType();
}

调用方法：

/** 按比例分成 */
WeightRoundRobinBo wrr = new WeightRoundRobinBo(orgList, rule, applyDetailInfo,cacheService.getShardedJedisPool());org = wrr.execute();
if (null == org) {LOG.error(ErrorEnums.ERR_10013.getMsg());return ErrorEnums.ERR_10013.getMsg();}

 

这篇关于比例分成算法--java的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1084135。

相关文章

java如何解压zip压缩包

java如何解压zip压缩包

《java如何解压zip压缩包》：本文主要介绍java如何解压zip压缩包问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java解压zip压缩包实例代码结果如下总结java解压zip压缩包坐在旁边的小伙伴问我怎么用 java 将服务器上的压缩文件解压出来，
阅读更多...
SpringBoot中SM2公钥加密、私钥解密的实现示例详解

SpringBoot中SM2公钥加密、私钥解密的实现示例详解

《SpringBoot中SM2公钥加密、私钥解密的实现示例详解》本文介绍了如何在SpringBoot项目中实现SM2公钥加密和私钥解密的功能,通过使用Hutool库和BouncyCastle依赖,简化... 目录一、前言1、加密信息(示例)2、加密结果(示例)二、实现代码1、yml文件配置2、创建SM2工具
阅读更多...
Spring WebFlux 与 WebClient 使用指南及最佳实践

Spring WebFlux 与 WebClient 使用指南及最佳实践

《SpringWebFlux与WebClient使用指南及最佳实践》WebClient是SpringWebFlux模块提供的非阻塞、响应式HTTP客户端,基于ProjectReactor实现,... 目录Spring WebFlux 与 WebClient 使用指南1. WebClient 概述2. 核心依
阅读更多...
Spring Boot @RestControllerAdvice全局异常处理最佳实践

Spring Boot @RestControllerAdvice全局异常处理最佳实践

《SpringBoot@RestControllerAdvice全局异常处理最佳实践》本文详解SpringBoot中通过@RestControllerAdvice实现全局异常处理,强调代码复用、统... 目录前言一、为什么要使用全局异常处理？二、核心注解解析1. @RestControllerAdvice2
阅读更多...
Spring IoC 容器的使用详解(最新整理)

Spring IoC 容器的使用详解(最新整理)

《SpringIoC容器的使用详解(最新整理)》文章介绍了Spring框架中的应用分层思想与IoC容器原理,通过分层解耦业务逻辑、数据访问等模块,IoC容器利用@Component注解管理Bean... 目录1. 应用分层2. IoC 的介绍3. IoC 容器的使用3.1. bean 的存储3.2. 方法注
阅读更多...
Spring事务传播机制最佳实践

Spring事务传播机制最佳实践

《Spring事务传播机制最佳实践》Spring的事务传播机制为我们提供了优雅的解决方案,本文将带您深入理解这一机制,掌握不同场景下的最佳实践,感兴趣的朋友一起看看吧... 目录1. 什么是事务传播行为2. Spring支持的七种事务传播行为2.1 REQUIRED（默认）2.2 SUPPORTS2
阅读更多...
怎样通过分析GC日志来定位Java进程的内存问题

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》：本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.
阅读更多...
Java进程异常故障定位及排查过程

Java进程异常故障定位及排查过程

《Java进程异常故障定位及排查过程》：本文主要介绍Java进程异常故障定位及排查过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、故障发现与初步判断1. 监控系统告警2. 日志初步分析二、核心排查工具与步骤1. 进程状态检查2. CPU 飙升问题3. 内存
阅读更多...
java中新生代和老生代的关系说明

java中新生代和老生代的关系说明

《java中新生代和老生代的关系说明》：本文主要介绍java中新生代和老生代的关系说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、内存区域划分新生代老年代二、对象生命周期与晋升流程三、新生代与老年代的协作机制1. 跨代引用处理2. 动态年龄判定3. 空间分
阅读更多...
Java设计模式---迭代器模式(Iterator)解读

Java设计模式---迭代器模式(Iterator)解读

《Java设计模式---迭代器模式(Iterator)解读》：本文主要介绍Java设计模式---迭代器模式(Iterator),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录1、迭代器（Iterator）1.1、结构1.2、常用方法1.3、本质1、解耦集合与遍历逻辑2、统一
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2