From 7132399202b75a84afaeab4c94065cc5dcf1480d Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 24 Mar 2021 11:52:17 +0800
Subject: [PATCH] 分销设置自购返佣

---
 zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/SalesOrderTask.java |   35 +++++++++++++++++++++++++++++++++--
 1 files changed, 33 insertions(+), 2 deletions(-)

diff --git a/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/SalesOrderTask.java b/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/SalesOrderTask.java
index 86c6c9a..c1fccd0 100644
--- a/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/SalesOrderTask.java
+++ b/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/SalesOrderTask.java
@@ -1,13 +1,17 @@
 package com.matrix.system.shopXcx.mqTask;
 
 
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.matrix.biz.bean.BizUser;
 import com.matrix.biz.service.BizUserService;
 import com.matrix.core.constance.MatrixConstance;
 import com.matrix.core.tools.LogUtil;
 import com.matrix.core.tools.StringUtils;
+import com.matrix.system.common.bean.BusParameterSettings;
 import com.matrix.system.common.dao.BusParameterSettingsDao;
+import com.matrix.system.fenxiao.constant.FenxiaoSettingConstant;
 import com.matrix.system.fenxiao.dao.ShopSalesmanGradeDao;
 import com.matrix.system.fenxiao.dao.ShopSalesmanOrderDao;
 import com.matrix.system.fenxiao.entity.ShopSalesmanGrade;
@@ -20,6 +24,7 @@
 import com.matrix.system.hive.service.SysOrderService;
 import com.matrix.system.shopXcx.bean.ShopOrder;
 import com.matrix.system.shopXcx.bean.ShopOrderDetails;
+import com.matrix.system.shopXcx.bean.ShopProduct;
 import com.matrix.system.shopXcx.dao.ShopOrderDao;
 import com.matrix.system.shopXcx.dao.ShopOrderDetailsDao;
 import com.matrix.system.shopXcx.dao.ShopSkuDao;
@@ -129,6 +134,7 @@
                 salesmanOrder.setRevenueType(ShopSalesmanOrder.REVENUE_TYPE_SALES);
                 salesmanOrder.setOrderStatus(ShopSalesmanOrder.STATUS_DJS);
                 Double salesAmount=0D;
+                Double selfAmount=0D;
                 Double invitationAmount=0D;
                 Double orderTotal=0D;
                 Double zk=1D;
@@ -137,7 +143,7 @@
                 BizUser invitationMan=null;
                 ShopSalesmanOrder invitationOrder=null;
                 boolean hasInvitationMan=StringUtils.isNotBlank(salesMan.getParentOpenId());
-
+                
                 //判断推广员是否还存在上级,存在则计算邀请收益
                 if(hasInvitationMan){
                     invitationMan=bizUserService.findByOpenId(salesMan.getParentOpenId());
@@ -150,7 +156,7 @@
                 //收益计算
                 for (ShopOrderDetails item:order.getDetails() ){
                     if(StringUtils.isNotBlank(item.getShopProduct().getAttrValues())
-                            && item.getShopProduct().getAttrValues().contains("分销商城")){
+                            && item.getShopProduct().getAbleSales()==ShopProduct.ABLE_SALES){
                         if(item.getShopSku().getSealesPrice()==null
                                 ||item.getShopSku().getSealesPrice().doubleValue()==0){
                             //按分销等级计算
@@ -169,9 +175,34 @@
                                 invitationAmount+=item.getShopSku().getInvitationPrice().doubleValue()*item.getCount();
                             }
                         }
+                        //分销规则是否开启自购返佣
+                        BusParameterSettings zgfy = parameterSettingsDao.selectCompanyParamByCode(FenxiaoSettingConstant.FX_ZGFY, bizUser.getCompanyId());
+                        if(ObjectUtil.isNotEmpty(zgfy)) {
+                            //获取商品的自购返佣价格,如果没有设置,在去获取当前推广人的等级的自购返佣比例
+                        	if(StrUtil.isNotEmpty(zgfy.getParamValue()) && 
+                        			FenxiaoSettingConstant.FX_ZGFY_YES.equals(zgfy.getParamValue())) {
+                        		if(item.getShopSku().getSelfPrice() == null
+                                        ||item.getShopSku().getSealesPrice().doubleValue() == 0){
+                        			//按分销等级计算
+                                    ShopSalesmanGrade shopSalesmanGrade = shopSalesmanGradeDao.selectById(salesMan.getSalesmanGrade());
+                                    selfAmount+=item.getTotalPrice().doubleValue()*(shopSalesmanGrade.getSelfCommission()/100);
+                        		}else {
+                        			//按产品设置的自购返佣金额计算
+                        			selfAmount+=item.getShopSku().getSelfPrice().doubleValue()*item.getCount();
+                        		}
+                        	}
+                        }
                         orderTotal+=item.getTotalPrice().doubleValue();
                     }
                 }
+                //自购返佣记录生成
+                if(selfAmount > 0) {
+                	//整体的优惠金额折算成折扣,* 佣金
+                    zk=order.getOrderMoney().doubleValue()/orderTotal;
+                    selfAmount=selfAmount*zk;
+                    salesmanOrder.setAmount(selfAmount);
+                    shopSalesmanOrderDao.insert(salesmanOrder);
+                }
                 if(salesAmount>0){
                     //整体的优惠金额折算成折扣,* 佣金
                     zk=order.getOrderMoney().doubleValue()/orderTotal;

--
Gitblit v1.9.1