比例分成算法--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学习手册之Filter和Listener使用方法

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》：本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter（过滤器）1. Filter 的工作原理2. Filter 的配置与使用二、Listen
阅读更多...
Spring Boot中JSON数值溢出问题从报错到优雅解决办法

Spring Boot中JSON数值溢出问题从报错到优雅解决办法

《SpringBoot中JSON数值溢出问题从报错到优雅解决办法》：本文主要介绍SpringBoot中JSON数值溢出问题从报错到优雅的解决办法,通过修改字段类型为Long、添加全局异常处理和... 目录一、问题背景：为什么我的接口突然报错了？二、为什么会发生这个错误？1. Java 数据类型的“容量”限制
阅读更多...
Java对象转换的实现方式汇总

Java对象转换的实现方式汇总

《Java对象转换的实现方式汇总》：本文主要介绍Java对象转换的多种实现方式,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Java对象转换的多种实现方式1. 手动映射（Manual Mapping）2. Builder模式3. 工具类辅助映
阅读更多...
SpringBoot请求参数接收控制指南分享

SpringBoot请求参数接收控制指南分享

《SpringBoot请求参数接收控制指南分享》：本文主要介绍SpringBoot请求参数接收控制指南,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Spring Boot 请求参数接收控制指南1. 概述2. 有注解时参数接收方式对比3. 无注解时接收参数默认位置
阅读更多...
SpringBoot基于配置实现短信服务策略的动态切换

SpringBoot基于配置实现短信服务策略的动态切换

《SpringBoot基于配置实现短信服务策略的动态切换》这篇文章主要为大家详细介绍了SpringBoot在接入多个短信服务商（如阿里云、腾讯云、华为云）后,如何根据配置或环境切换使用不同的服务商,需... 目录目标功能示例配置（application.yml）配置类绑定短信发送策略接口示例：阿里云 & 腾
阅读更多...
SpringBoot项目中报错The field screenShot exceeds its maximum permitted size of 1048576 bytes.的问题及解决

SpringBoot项目中报错The field screenShot exceeds its maximum permitted size of 1048576 bytes.的问题及解决

《SpringBoot项目中报错ThefieldscreenShotexceedsitsmaximumpermittedsizeof1048576bytes.的问题及解决》这篇文章... 目录项目场景问题描述原因分析解决方案总结项目场景javascript提示：项目相关背景：项目场景：基于Spring
阅读更多...
Spring Boot 整合 SSE的高级实践(Server-Sent Events)

Spring Boot 整合 SSE的高级实践(Server-Sent Events)

《SpringBoot整合SSE的高级实践(Server-SentEvents)》SSE（Server-SentEvents）是一种基于HTTP协议的单向通信机制,允许服务器向浏览器持续发送实... 目录1、简述2、Spring Boot 中的SSE实现2.1 添加依赖2.2 实现后端接口2.3 配置超时时
阅读更多...
Spring Boot读取配置文件的五种方式小结

Spring Boot读取配置文件的五种方式小结

《SpringBoot读取配置文件的五种方式小结》SpringBoot提供了灵活多样的方式来读取配置文件,这篇文章为大家介绍了5种常见的读取方式,文中的示例代码简洁易懂,大家可以根据自己的需要进... 目录1. 配置文件位置与加载顺序2. 读取配置文件的方式汇总方式一：使用 @Value 注解读取配置方式二
阅读更多...
一文详解Java异常处理你都了解哪些知识

一文详解Java异常处理你都了解哪些知识

《一文详解Java异常处理你都了解哪些知识》：本文主要介绍Java异常处理的相关资料,包括异常的分类、捕获和处理异常的语法、常见的异常类型以及自定义异常的实现,文中通过代码介绍的非常详细,需要的朋... 目录前言一、什么是异常二、异常的分类2.1 受检异常2.2 非受检异常三、异常处理的语法3.1 try-
阅读更多...
Java中的@SneakyThrows注解用法详解

Java中的@SneakyThrows注解用法详解

《Java中的@SneakyThrows注解用法详解》：本文主要介绍Java中的@SneakyThrows注解用法的相关资料,Lombok的@SneakyThrows注解简化了Java方法中的异常... 目录前言一、@SneakyThrows 简介1.1 什么是 Lombok？二、@SneakyThrows
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2