比例分成算法--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集合中的链表与结构详解

Java集合中的链表与结构详解

《Java集合中的链表与结构详解》链表是一种物理存储结构上非连续的存储结构,数据元素的逻辑顺序的通过链表中的引用链接次序实现,文章对比ArrayList与LinkedList的结构差异,详细讲解了链表... 目录一、链表概念与结构二、当向单链表的实现2.1 准备工作2.2 初始化链表2.3 打印数据、链表长
阅读更多...
Java异常捕获及处理方式详解

Java异常捕获及处理方式详解

《Java异常捕获及处理方式详解》异常处理是Java编程中非常重要的一部分,它允许我们在程序运行时捕获并处理错误或不预期的行为,而不是让程序直接崩溃,本文将介绍Java中如何捕获异常,以及常用的异常处... 目录前言什么是异常？Java异常的基本语法解释：1. 捕获异常并处理示例1：捕获并处理单个异常解释：
阅读更多...
Java实现TXT文件导入功能的详细步骤

Java实现TXT文件导入功能的详细步骤

《Java实现TXT文件导入功能的详细步骤》在实际开发中,很多应用场景需要将用户上传的TXT文件进行解析,并将文件中的数据导入到数据库或其他存储系统中,本文将演示如何用Java实现一个基本的TXT文件... 目录前言1. 项目需求分析2. 示例文件格式3. 实现步骤3.1. 准备数据库（假设使用 mysql
阅读更多...
java -jar example.jar 产生的日志输出到指定文件的方法

java -jar example.jar 产生的日志输出到指定文件的方法

《java-jarexample.jar产生的日志输出到指定文件的方法》这篇文章给大家介绍java-jarexample.jar产生的日志输出到指定文件的方法,本文给大家介绍的非常详细,对大家的... 目录怎么让 Java -jar example.jar 产生的日志输出到指定文件一、方法1：使用重定向1、
阅读更多...
Java报错:org.springframework.beans.factory.BeanCreationException的五种解决方法

Java报错:org.springframework.beans.factory.BeanCreationException的五种解决方法

《Java报错:org.springframework.beans.factory.BeanCreationException的五种解决方法》本文解析Spring框架中BeanCreationExce... 目录引言一、问题描述1.1 报错示例假设我们有一个简单的Java类，代表一个用户信息的实体类：然后，
阅读更多...
SpringBoot集成P6Spy的实现示例

SpringBoot集成P6Spy的实现示例

《SpringBoot集成P6Spy的实现示例》本文主要介绍了SpringBoot集成P6Spy的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录本节目标P6Spy简介抛出问题集成P6Spy1. SpringBoot三板斧之加入依赖2. 修改
阅读更多...
Spring Integration Redis 使用示例详解

Spring Integration Redis 使用示例详解

《SpringIntegrationRedis使用示例详解》本文给大家介绍SpringIntegrationRedis的配置与使用,涵盖依赖添加、Redis连接设置、分布式锁实现、消息通道配置及... 目录一、依赖配置1.1 Maven 依赖1.2 Gradle 依赖二、Redis 连接配置2.1 配置 R
阅读更多...
Spring Security重写AuthenticationManager实现账号密码登录或者手机号码登录

Spring Security重写AuthenticationManager实现账号密码登录或者手机号码登录

《SpringSecurity重写AuthenticationManager实现账号密码登录或者手机号码登录》本文主要介绍了SpringSecurity重写AuthenticationManage... 目录一、创建自定义认证提供者CustomAuthenticationProvider二、创建认证业务Us
阅读更多...
Java Stream流以及常用方法操作实例

Java Stream流以及常用方法操作实例

《JavaStream流以及常用方法操作实例》Stream是对Java中集合的一种增强方式,使用它可以将集合的处理过程变得更加简洁、高效和易读,：本文主要介绍JavaStream流以及常用方法... 目录一、Stream流是什么？二、stream的操作2.1、stream流创建2.2、stream的使用2.
阅读更多...
Java对接MQTT协议的完整实现示例代码

Java对接MQTT协议的完整实现示例代码

《Java对接MQTT协议的完整实现示例代码》MQTT是一个基于客户端-服务器的消息发布/订阅传输协议,MQTT协议是轻量、简单、开放和易于实现的,这些特点使它适用范围非常广泛,：本文主要介绍Ja... 目录前言前置依赖1. MQTT配置类代码解析1.1 MQTT客户端工厂1.2 MQTT消息订阅适配器1.
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2