查询用户团队接口

cweb/src/main/java/com/hfkj/controller/TestController.java

@@ -28,6 +28,7 @@ import java.math.BigDecimal;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
+import java.util.Map;
 
 
 @Controller
@@ -104,15 +105,18 @@ public class TestController {
 
     @RequestMapping(value="/purchase",method = RequestMethod.GET)
     @ResponseBody
-    @ApiOperation(value = "purchase ")
-    public ResponseData purchase() {
+    @ApiOperation(value = "会员贡献测试")
+    public ResponseData purchase(@RequestParam(value = "rebate" , required = true) BigDecimal rebate,
+                                 @RequestParam(value = "userId" , required = true) Long userId) {
         try {
 
-            userContributeService.purchase(new BigDecimal("10"), 4L, new HashMap<>());
+            Map<String,Object> otherParam = new HashMap<>();
+            otherParam.put("sourceId", System.currentTimeMillis());
+            otherParam.put("sourceOrderNo", System.currentTimeMillis());
+            userContributeService.purchase(rebate, userId, otherParam);
 
             return ResponseMsgUtil.success("操作成功");
 
-
         } catch (Exception e) {
             log.error("error!",e);
             return ResponseMsgUtil.exception(e);

cweb/src/main/java/com/hfkj/controller/UserTeamController.java

@@ -0,0 +1,141 @@
+package com.hfkj.controller;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.hfkj.common.security.UserCenter;
+import com.hfkj.common.utils.ResponseMsgUtil;
+import com.hfkj.entity.BsUser;
+import com.hfkj.model.ResponseData;
+import com.hfkj.model.UserSessionObject;
+import com.hfkj.model.UserTeamModel;
+import com.hfkj.service.user.BsUserParentRelService;
+import com.hfkj.service.user.BsUserService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * @className: UserTeamController
+ * @author: HuRui
+ * @date: 2024/9/24
+ **/
+@Controller
+@RequestMapping(value="/userTeam")
+@Api(value="客户端业务")
+public class UserTeamController {
+
+    @Autowired
+    private UserCenter userCenter;
+    @Resource
+    private BsUserParentRelService userParentRelService;
+    @Resource
+    private BsUserService userService;
+
+    @RequestMapping(value = "/statistic", method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "团队统计")
+    public ResponseData statistic() {
+        try {
+            UserSessionObject userSession = userCenter.getSessionModel(UserSessionObject.class);
+
+            Map<String,Object> param = new HashMap<>();
+            param.put("parentUserId", userSession.getUser().getId());
+            // 查询下级数据
+            List<UserTeamModel> subList = userParentRelService.getTeamSubList(param);
+
+            Map<String,Object> map = new HashMap<>();
+            // 直属成员
+            map.put("directlyUnder", subList.stream().filter(o -> o.getRelType().equals(1)).count());
+            // 团队好友
+            map.put("teamFriend", subList.stream().filter(o -> o.getRelType().equals(2)).count());
+
+            Map<String,Object> active = new HashMap<>();
+
+            // 今日
+            Map<String,Object> today = new HashMap<>();
+            today.put("", "");
+            today.put("", "");
+            active.put("today", today);
+
+            // 昨日
+            Map<String,Object> yesterday = new HashMap<>();
+            yesterday.put("", "");
+            yesterday.put("", "");
+            active.put("yesterday", yesterday);
+
+            // 本月
+            Map<String,Object> thisMonth = new HashMap<>();
+            thisMonth.put("", "");
+            thisMonth.put("", "");
+            active.put("thisMonth", thisMonth);
+
+            // 上月
+            Map<String,Object> lastMonth = new HashMap<>();
+            lastMonth.put("", "");
+            lastMonth.put("", "");
+            active.put("lastMonth", lastMonth);
+
+            map.put("active", active);
+            return ResponseMsgUtil.success(map);
+
+        } catch (Exception e) {
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+    @RequestMapping(value = "/queryList", method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "查询列表")
+    public ResponseData queryList(@RequestParam(value = "userType" , required = true) Integer userType,
+                                  @RequestParam(value = "userId" , required = false) Long userId,
+                                  @RequestParam(value = "pageNum" , required = true) Integer pageNum,
+                                  @RequestParam(value = "pageSize" , required = true) Integer pageSize) {
+        try {
+            UserSessionObject userSession = userCenter.getSessionModel(UserSessionObject.class);
+
+            Map<String,Object> param = new HashMap<>();
+            // 用户类型  1：直属好友  2：团队好友  3：见习会员  4：优淘会员  5：元气团长  6：渠道
+            param.put("userType", userType);
+            param.put("parentUserId", userSession.getUser().getId());
+            param.put("userId", userId);
+
+            PageHelper.startPage(pageNum,pageSize);
+            return ResponseMsgUtil.success(new PageInfo<>(userParentRelService.getTeamSubList(param)));
+
+        } catch (Exception e) {
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+    @RequestMapping(value = "/queryInviteUser", method = RequestMethod.GET)
+    @ResponseBody
+    @ApiOperation(value = "查询邀请人")
+    public ResponseData queryInviteUser() {
+        try {
+            UserSessionObject userSession = userCenter.getSessionModel(UserSessionObject.class);
+            if (userSession.getUser().getInviteUserId() != null) {
+                BsUser inviteUser = userService.getUser(userSession.getUser().getInviteUserId());
+                if (inviteUser != null) {
+                    inviteUser.setPhone(null);
+                    return ResponseMsgUtil.success(inviteUser);
+                }
+            }
+            return ResponseMsgUtil.success(null);
+
+        } catch (Exception e) {
+            return ResponseMsgUtil.exception(e);
+        }
+    }
+
+}

service/src/main/java/com/hfkj/dao/BsUserParentRelMapperExt.java

@@ -1,7 +1,40 @@
 package com.hfkj.dao;
 
+import com.hfkj.model.UserTeamModel;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.util.List;
+import java.util.Map;
+
 /**
  * mapper扩展类
  */
 public interface BsUserParentRelMapperExt {
+
+    @Select("<script>" +
+            " select * from ( " +
+            "  SELECT " +
+            "  au.id userId," +
+            "  au.head_img headImg," +
+            "  au.name," +
+            "  au.grade," +
+            "  au.wechat_num wechatNum," +
+            "  au.invite_user_id inviteUserId," +
+            "  case au.invite_user_id when #{param.parentUserId} then 1 else 2 end relType" +
+            "  " +
+            "  FROM (SELECT * FROM bs_user WHERE invite_user_id IS NOT NULL) au," +
+            "  (SELECT @pid := #{param.parentUserId}) pd" +
+            "   WHERE FIND_IN_SET(invite_user_id, @pid) > 0 and @pid := concat(@pid, ',', id)" +
+            "  ORDER BY id" +
+            " ) a where 1 = 1" +
+            " <if test='param.userId != null'> and a.id = #{param.userId} </if>" +
+            " <if test='param.userType != null &amp;&amp; param.userType == 1'> and a.relType = 1 </if>" +
+            " <if test='param.userType != null &amp;&amp; param.userType == 2'> and a.relType = 2 </if>" +
+            " <if test='param.userType != null &amp;&amp; param.userType == 3'> and a.grade = 1 </if>" +
+            " <if test='param.userType != null &amp;&amp; param.userType == 4'> and a.grade = 2 </if>" +
+            " <if test='param.userType != null &amp;&amp; param.userType == 5'> and a.grade = 3 </if>" +
+            " <if test='param.userType != null &amp;&amp; param.userType == 6'> and a.grade = 4 </if>" +
+            "</script>")
+    List<UserTeamModel> queryTeamSubList(@Param("param") Map<String,Object> param);
 }

service/src/main/java/com/hfkj/model/UserTeamModel.java

@@ -0,0 +1,48 @@
+package com.hfkj.model;
+
+import lombok.Data;
+
+/**
+ * 团队用户模型
+ * @className: UserTeamModel
+ * @author: HuRui
+ * @date: 2024/9/24
+ **/
+@Data
+public class UserTeamModel {
+
+    /**
+     * 用户id
+     */
+    private Long userId;
+
+    /**
+     * 头像
+     */
+    private String headImg;
+
+    /**
+     * 名称
+     */
+    private String name;
+
+    /**
+     * 等级
+     */
+    private Integer grade;
+
+    /**
+     * 微信
+     */
+    private String wechatNum;
+
+    /**
+     * 邀请人
+     */
+    private Long inviteUserId;
+
+    /**
+     * 关系类型  1：直属好友  2：团队成员
+     */
+    private Integer relType;
+}

service/src/main/java/com/hfkj/service/user/BsUserParentRelService.java

@@ -2,9 +2,11 @@ package com.hfkj.service.user;
 
 import com.hfkj.entity.BsUser;
 import com.hfkj.entity.BsUserParentRel;
+import com.hfkj.model.UserTeamModel;
 import com.hfkj.sysenum.user.UserGradeEnum;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * @className: BsUserParentRelService
@@ -34,4 +36,10 @@ public interface BsUserParentRelService {
      */
     BsUserParentRel getParent(List<UserGradeEnum> grade, Long userId);
 
+    /**
+     * 查询下级用户列表
+     * @param param
+     * @return
+     */
+    List<UserTeamModel> getTeamSubList(Map<String,Object> param);
 }

service/src/main/java/com/hfkj/service/user/impl/BsUserContributeServiceImpl.java

@@ -26,7 +26,9 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+
 /**
+ * 会员等级贡献
  * @className: BsUserContributeServiceImpl
  * @author: HuRui
  * @date: 2024/9/12
@@ -55,7 +57,7 @@ public class BsUserContributeServiceImpl implements BsUserContributeService {
         // 元宝汇率
         BigDecimal goldCoinExchangeRate = new BigDecimal(secDictionaryService.getDictionary("GOLD_COIN_EXCHANGE_RATE").get(0).getCodeValue());
         // 获得元宝数量  （返利金额 * 元宝汇率） * 等级自购奖励比例
-        BigDecimal goldCoin = (rebateAmount.multiply(goldCoinExchangeRate)).multiply(selfPurchaseReward).setScale(6, BigDecimal.ROUND_HALF_DOWN);
+        BigDecimal goldCoin = (rebateAmount.multiply(goldCoinExchangeRate)).multiply(selfPurchaseReward.divide(new BigDecimal("100"))).setScale(6, BigDecimal.ROUND_HALF_DOWN);
 
         Map<String, Object> userRechargeParam = new HashMap<>();
         userRechargeParam.put("sourceId", MapUtils.getLong(otherParam, "sourceId"));
@@ -67,18 +69,28 @@ public class BsUserContributeServiceImpl implements BsUserContributeService {
         // 查询用户上级
         BsUserParentRel parentRel = userParentRelService.getDetailByUserId(userId);
         if (parentRel != null && parentRel.getParentUserId() != null) {
+            // 购买用户等级是渠道，贡献时只能贡献给 渠道等级
+            if (UserGradeEnum.grade4.getCode().equals(user.getGrade())) {
+                // 渠道
+                parentGrade4(UserGradeEnum.getDataByType(user.getGrade()), rebateAmount, parentRel, otherParam);
+
+            } else {
                 if (UserGradeEnum.grade4.getCode().equals(parentRel.getParentUserGrade())) {
                     // 渠道
-                parentGrade4(UserGradeEnum.grade4, rebateAmount, parentRel, otherParam);
+                    parentGrade4(UserGradeEnum.getDataByType(user.getGrade()), rebateAmount, parentRel, otherParam);
 
                 } else if (UserGradeEnum.grade3.getCode().equals(parentRel.getParentUserGrade())) {
                     // 团长
-                parentGrade4(UserGradeEnum.grade4, rebateAmount, parentRel, otherParam);
+                    parentGrade3(UserGradeEnum.getDataByType(user.getGrade()), rebateAmount, parentRel, otherParam);
 
                 } else if (UserGradeEnum.grade2.getCode().equals(parentRel.getParentUserGrade())) {
                     // 正式会员
+                    parentGrade2(UserGradeEnum.getDataByType(user.getGrade()), rebateAmount, parentRel, otherParam);
+
                 } else if (UserGradeEnum.grade1.getCode().equals(parentRel.getParentUserGrade())) {
                     // 见习会员
+                    parentGrade1(UserGradeEnum.getDataByType(user.getGrade()), rebateAmount, parentRel, otherParam);
+                }
             }
         }
     }
@@ -87,31 +99,49 @@ public class BsUserContributeServiceImpl implements BsUserContributeService {
      * 渠道
      */
     public void parentGrade4(UserGradeEnum userGrade,BigDecimal rebateAmount,BsUserParentRel parentRel,Map<String,Object> otherParam) throws Exception {
+        Map<String, Object> parentUserParam = new HashMap<>();
+        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
         // 元宝汇率
         BigDecimal goldCoinExchangeRate = new BigDecimal(secDictionaryService.getDictionary("GOLD_COIN_EXCHANGE_RATE").get(0).getCodeValue());
-
         // 直属贡献比例
         BigDecimal directlyContributeRate = new BigDecimal("0");
 
-        if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+        if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode())
+                || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
             directlyContributeRate = new BigDecimal("100");
+            parentUserParam.put("sourceContent", "直属会员贡献");
+
+        } else if (UserGradeEnum.grade3.getCode().equals(userGrade.getCode())) {
+            directlyContributeRate = new BigDecimal("23");
+            parentUserParam.put("sourceContent", "直属团长团队贡献");
+
+        } else if (UserGradeEnum.grade4.getCode().equals(userGrade.getCode())) {
+            directlyContributeRate = new BigDecimal("9");
+            parentUserParam.put("sourceContent", "直属渠道团队贡献");
+
+            if (!UserGradeEnum.grade4.getCode().equals(parentRel.getParentUserGrade())) {
+                // 递归判断找到渠道
+                parentRel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), parentRel.getParentUserId());
+            }
         }
         // 直属贡献  = （返利金额 * 元宝汇率） * 直属贡献
         BigDecimal goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
                 .multiply(directlyContributeRate.divide(new BigDecimal("100")))
                 .setScale(6, BigDecimal.ROUND_HALF_DOWN);
-
-        Map<String, Object> parentUserParam = new HashMap<>();
-        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
-        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
-        parentUserParam.put("sourceContent", "直属会员贡献");
+        if (parentRel != null) {
             // 上级账户
             userAccountService.recharge(parentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+        }
 
-
-        // 直属贡献比例 9%
+        // 渠道用户购买无需再进行贡献
+        if (!UserGradeEnum.grade4.getCode().equals(userGrade.getCode())) {
+            // 递归判断找到渠道
+            BsUserParentRel channel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), parentRel.getParentUserId());
+            if (channel != null) {
+                // 贡献比例 9%
                 directlyContributeRate = new BigDecimal("9");
-        // 直属贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
                 goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
                         .multiply(directlyContributeRate.divide(new BigDecimal("100")))
                         .setScale(6, BigDecimal.ROUND_HALF_DOWN);
@@ -121,39 +151,51 @@ public class BsUserContributeServiceImpl implements BsUserContributeService {
                 parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
                 parentUserParam.put("sourceContent", "直属渠道团队贡献");
                 // 渠道账户
-        userAccountService.recharge(parentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+                userAccountService.recharge(channel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+            }
+        }
     }
 
     /**
      * 团长
      */
     public void parentGrade3(UserGradeEnum userGrade,BigDecimal rebateAmount,BsUserParentRel parentRel,Map<String,Object> otherParam) throws Exception {
+        Map<String,Object> parentUserParam = new HashMap<>();
+        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
         // 元宝汇率
         BigDecimal goldCoinExchangeRate = new BigDecimal(secDictionaryService.getDictionary("GOLD_COIN_EXCHANGE_RATE").get(0).getCodeValue());
         // 直属贡献比例
         BigDecimal directlyContributeRate = new BigDecimal("0");
 
-        if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+        if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode())
+                || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
             directlyContributeRate = new BigDecimal("66.6");
+            parentUserParam.put("sourceContent", "直属会员贡献");
+
+        } else if (UserGradeEnum.grade3.getCode().equals(userGrade.getCode())) {
+            directlyContributeRate = new BigDecimal("10");
+            parentUserParam.put("sourceContent", "直属团长团队贡献");
         }
         // 直属贡献  = （返利金额 * 元宝汇率） * 直属贡献
         BigDecimal goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
                 .multiply(directlyContributeRate.divide(new BigDecimal("100")))
                 .setScale(6, BigDecimal.ROUND_HALF_DOWN);
-        Map<String,Object> parentUserParam = new HashMap<>();
-        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
-        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
-        parentUserParam.put("sourceContent", "直属会员贡献");
+
         // 上级账户
         userAccountService.recharge(parentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
 
+        // 购买商品用户等级
+        if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
             // 递归判断找到团长或渠道
             BsUserParentRel userParentRel = userParentRelService.getParent(
                     Arrays.asList(UserGradeEnum.grade4, UserGradeEnum.grade3),
                     parentRel.getParentUserId()
             );
-
+            // 团长或渠道
             if (userParentRel != null) {
+                // 团长
                 if (UserGradeEnum.grade3.getCode().equals(userParentRel.getParentUserGrade())) {
                     // 贡献比例 10%
                     directlyContributeRate = new BigDecimal("10");
@@ -162,12 +204,12 @@ public class BsUserContributeServiceImpl implements BsUserContributeService {
                             .multiply(directlyContributeRate.divide(new BigDecimal("100")))
                             .setScale(6, BigDecimal.ROUND_HALF_DOWN);
                     // 渠道贡献
-                otherParam.clear();
-                otherParam.put("sourceId", "");
-                otherParam.put("sourceOrderNo", "");
-                otherParam.put("sourceContent", "直属团长贡献");
+                    parentUserParam.clear();
+                    parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                    parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                    parentUserParam.put("sourceContent", "直属团长团队贡献");
                     // 团长账户
-                userAccountService.recharge(userParentRel.getUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, otherParam);
+                    userAccountService.recharge(userParentRel.getUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
 
                     // 递归判断找到渠道
                     userParentRel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), parentRel.getParentUserId());
@@ -179,16 +221,47 @@ public class BsUserContributeServiceImpl implements BsUserContributeService {
                                 .multiply(directlyContributeRate.divide(new BigDecimal("100")))
                                 .setScale(6, BigDecimal.ROUND_HALF_DOWN);
                         // 渠道贡献
-                    otherParam.clear();
-                    otherParam.put("sourceId", "");
-                    otherParam.put("sourceOrderNo", "");
-                    otherParam.put("sourceContent", "非直属团长团队贡献");
+                        parentUserParam.clear();
+                        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                        parentUserParam.put("sourceContent", "非直属团长团队贡献");
                         // 团长账户
-                    userAccountService.recharge(userParentRel.getUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, otherParam);
+                        userAccountService.recharge(userParentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
                     }
 
                 } else if (UserGradeEnum.grade4.getCode().equals(userParentRel.getParentUserGrade())) {
-                // 递归找到团长
+                    // 贡献比例 23%
+                    directlyContributeRate = new BigDecimal("23");
+                    // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                    goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                            .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                            .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                    // 渠道贡献
+                    parentUserParam.clear();
+                    parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                    parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                    parentUserParam.put("sourceContent", "直属团长团队贡献");
+                    // 渠道账户
+                    userAccountService.recharge(userParentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+
+                    // 递归判断找到渠道
+                    BsUserParentRel channel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), userParentRel.getParentUserId());
+                    if (channel != null) {
+                        // 贡献比例 9%
+                        directlyContributeRate = new BigDecimal("9");
+                        // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                        goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                                .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                                .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                        // 渠道贡献
+                        parentUserParam.clear();
+                        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                        parentUserParam.put("sourceContent", "直属渠道团队贡献");
+                        // 渠道账户
+                        userAccountService.recharge(channel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+                    }
+   /*                 // 递归找到团长
                     BsUserParentRel teamLeader = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade3), parentRel.getParentUserId());
                     if (teamLeader != null) {
                         // 贡献比例 2   3%
@@ -198,14 +271,187 @@ public class BsUserContributeServiceImpl implements BsUserContributeService {
                                 .multiply(directlyContributeRate.divide(new BigDecimal("100")))
                                 .setScale(6, BigDecimal.ROUND_HALF_DOWN);
                         // 贡献
-                    otherParam.clear();
-                    otherParam.put("sourceId", "");
-                    otherParam.put("sourceOrderNo", "");
-                    otherParam.put("sourceContent", "直属团长团队贡献");
+                        parentUserParam.clear();
+                        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                        parentUserParam.put("sourceContent", "直属团长团队贡献");
+                        // 团长账户
+                        userAccountService.recharge(teamLeader.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+
+                        // 贡献比例 9%
+                        directlyContributeRate = new BigDecimal("9");
+                        // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                        goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                                .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                                .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                        // 贡献
+                        parentUserParam.clear();
+                        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                        parentUserParam.put("sourceContent", "直属渠道团队贡献");
+                        // 渠道账户
+                        userAccountService.recharge(userParentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+                    }*/
+                }
+            }
+        }
+        else if (UserGradeEnum.grade3.getCode().equals(userGrade.getCode())) {
+            // 递归判断找到渠道
+            BsUserParentRel userParentRel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4),parentRel.getParentUserId());
+            if (userParentRel != null) {
+                // 贡献比例 10%
+                directlyContributeRate = new BigDecimal("13");
+                // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                        .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                        .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                // 渠道贡献
+                parentUserParam.clear();
+                parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                parentUserParam.put("sourceContent", "非直属团长团队贡献");
+                // 渠道账户
+                userAccountService.recharge(userParentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+
+                // 递归判断找到渠道
+                BsUserParentRel channel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), userParentRel.getParentUserId());
+                if (channel != null) {
+                    // 贡献比例 9%
+                    directlyContributeRate = new BigDecimal("9");
+                    // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                    goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                            .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                            .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                    // 渠道贡献
+                    parentUserParam.clear();
+                    parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                    parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                    parentUserParam.put("sourceContent", "直属渠道团队贡献");
+                    // 团长账户
+                    userAccountService.recharge(channel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+                }
+            }
+        }
+    }
+
+    /**
+     * 元气会员
+     */
+    public void parentGrade2(UserGradeEnum userGrade,BigDecimal rebateAmount,BsUserParentRel parentRel,Map<String,Object> otherParam) throws Exception {
+        // 元宝汇率
+        BigDecimal goldCoinExchangeRate = new BigDecimal(secDictionaryService.getDictionary("GOLD_COIN_EXCHANGE_RATE").get(0).getCodeValue());
+        // 直属贡献比例
+        BigDecimal directlyContributeRate = new BigDecimal("0");
+        // 贡献元宝
+        BigDecimal goldCoin = new BigDecimal("0");
+
+        Map<String,Object> parentUserParam = new HashMap<>();
+        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
+        if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+            directlyContributeRate = new BigDecimal("45");
+            parentUserParam.put("sourceContent", "直属会员贡献");
+
+            // 直属贡献  = （返利金额 * 元宝汇率） * 直属贡献
+            goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                    .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                    .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+
+            // 上级账户
+            userAccountService.recharge(parentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+        }
+        // 递归判断找到团长或渠道
+        BsUserParentRel userParentRel = userParentRelService.getParent(
+                Arrays.asList(UserGradeEnum.grade4, UserGradeEnum.grade3),
+                parentRel.getParentUserId()
+        );
+        // 团长或渠道
+        if (userParentRel != null) {
+            // 团长
+            if (UserGradeEnum.grade3.getCode().equals(userParentRel.getParentUserGrade())) {
+                parentUserParam.clear();
+                parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
+                // 购买用户等级
+                if (UserGradeEnum.grade3.getCode().equals(userGrade.getCode())) {
+                    // 贡献比例 10%
+                    directlyContributeRate = new BigDecimal("10");
+                    parentUserParam.put("sourceContent", "直属团长团队贡献");
+
+                } else if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+                    // 贡献比例 21.6%
+                    directlyContributeRate = new BigDecimal("21.6");
+                    parentUserParam.put("sourceContent", "非直属会员贡献");
+                }
+                // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                        .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                        .setScale(6, BigDecimal.ROUND_HALF_DOWN);
                 // 团长账户
-                    userAccountService.recharge(teamLeader.getUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, otherParam);
+                userAccountService.recharge(userParentRel.getUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+
+                // 递归判断找到渠道
+                BsUserParentRel channel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), userParentRel.getParentUserId());
+                if (channel != null) {
+                    parentUserParam.clear();
+                    parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                    parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
+                    // 购买用户等级
+                    if (UserGradeEnum.grade3.getCode().equals(userGrade.getCode())) {
+                        // 贡献比例 13%
+                        directlyContributeRate = new BigDecimal("13");
+                        parentUserParam.put("sourceContent", "非直属团长团队贡献");
+
+                    } else if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+                        // 是否有团长
+                        if (userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), userParentRel.getParentUserId()) == null) {
+                            // 贡献比例 23%
+                            directlyContributeRate = new BigDecimal("23");
+                            parentUserParam.put("sourceContent", "直属团长团队贡献");
+                        } else {
+                            // 贡献比例 13%
+                            directlyContributeRate = new BigDecimal("13");
+                            parentUserParam.put("sourceContent", "非直属团长团队贡献");
+                        }
+                    }
+                    // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                    goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                            .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                            .setScale(6, BigDecimal.ROUND_HALF_DOWN);
 
+                    // 渠道账户
+                    userAccountService.recharge(channel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+                }
 
+            }
+            else if (UserGradeEnum.grade4.getCode().equals(userParentRel.getParentUserGrade())) {
+                    parentUserParam.clear();
+                    parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                    parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
+                    if (UserGradeEnum.grade4.getCode().equals(userGrade.getCode())) {
+                        // 贡献比例 23%
+                        directlyContributeRate = new BigDecimal("23");
+                        parentUserParam.put("sourceContent", "直属团长团队贡献");
+
+                    } else if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+                        // 贡献比例 55%
+                        directlyContributeRate = new BigDecimal("55");
+                        parentUserParam.put("sourceContent", "非直属会员贡献");
+                    }
+                    // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                    goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                            .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                            .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                    // 渠道账户
+                    userAccountService.recharge(userParentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+
+                    // 递归判断渠道
+                    BsUserParentRel channel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), parentRel.getParentUserId());
+                    if (channel != null) {
                         // 贡献比例 9%
                         directlyContributeRate = new BigDecimal("9");
                         // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
@@ -213,16 +459,153 @@ public class BsUserContributeServiceImpl implements BsUserContributeService {
                                 .multiply(directlyContributeRate.divide(new BigDecimal("100")))
                                 .setScale(6, BigDecimal.ROUND_HALF_DOWN);
                         // 贡献
-                    otherParam.clear();
-                    otherParam.put("sourceId", "");
-                    otherParam.put("sourceOrderNo", "");
-                    otherParam.put("sourceContent", "直属渠道团队贡献");
+                        parentUserParam.clear();
+                        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                        parentUserParam.put("sourceContent", "直属渠道团队贡献");
                         // 渠道账户
-                    userAccountService.recharge(userParentRel.getUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, otherParam);
+                        userAccountService.recharge(channel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+                    }
                  }
             }
 
         }
+
+    /**
+     * 见习会员
+     */
+    public void parentGrade1(UserGradeEnum userGrade,BigDecimal rebateAmount,BsUserParentRel parentRel,Map<String,Object> otherParam) throws Exception {
+        // 元宝汇率
+        BigDecimal goldCoinExchangeRate = new BigDecimal(secDictionaryService.getDictionary("GOLD_COIN_EXCHANGE_RATE").get(0).getCodeValue());
+        // 直属贡献比例
+        BigDecimal directlyContributeRate = new BigDecimal("0");
+        // 贡献元宝
+        BigDecimal goldCoin = new BigDecimal("0");
+
+        Map<String,Object> parentUserParam = new HashMap<>();
+        parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+        parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
+        if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+            directlyContributeRate = new BigDecimal("18");
+            parentUserParam.put("sourceContent", "直属会员贡献");
+
+            // 直属贡献  = （返利金额 * 元宝汇率） * 直属贡献
+            goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                    .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                    .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+
+            // 上级账户
+            userAccountService.recharge(parentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+        }
+        // 递归判断找到团长或渠道
+        BsUserParentRel userParentRel = userParentRelService.getParent(
+                Arrays.asList(UserGradeEnum.grade4, UserGradeEnum.grade3),
+                parentRel.getParentUserId()
+        );
+        // 团长或渠道
+        if (userParentRel != null) {
+            // 团长
+            if (UserGradeEnum.grade3.getCode().equals(userParentRel.getParentUserGrade())) {
+                parentUserParam.clear();
+                parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
+                // 购买用户等级
+                if (UserGradeEnum.grade3.getCode().equals(userGrade.getCode())) {
+                    // 贡献比例 10%
+                    directlyContributeRate = new BigDecimal("10");
+                    parentUserParam.put("sourceContent", "直属团长团队贡献");
+
+                } else if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+                    // 贡献比例 21.6%
+                    directlyContributeRate = new BigDecimal("21.6");
+                    parentUserParam.put("sourceContent", "非直属会员贡献");
+                }
+                // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                        .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                        .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                // 团长账户
+                userAccountService.recharge(userParentRel.getUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+
+                // 递归判断找到渠道
+                BsUserParentRel channel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), userParentRel.getParentUserId());
+                if (channel != null) {
+                    parentUserParam.clear();
+                    parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                    parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
+                    // 购买用户等级
+                    if (UserGradeEnum.grade3.getCode().equals(userGrade.getCode())) {
+                        // 贡献比例 13%
+                        directlyContributeRate = new BigDecimal("13");
+                        parentUserParam.put("sourceContent", "非直属团长团队贡献");
+
+                    } else if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+                        // 是否有团长
+                        if (userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), userParentRel.getParentUserId()) == null) {
+                            // 贡献比例 23%
+                            directlyContributeRate = new BigDecimal("23");
+                            parentUserParam.put("sourceContent", "直属团长团队贡献");
+                        } else {
+                            // 贡献比例 13%
+                            directlyContributeRate = new BigDecimal("13");
+                            parentUserParam.put("sourceContent", "非直属团长团队贡献");
+                        }
+                    }
+                    // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                    goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                            .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                            .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+
+                    // 渠道账户
+                    userAccountService.recharge(channel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+                }
+
+            }
+            else if (UserGradeEnum.grade4.getCode().equals(userParentRel.getParentUserGrade())) {
+                parentUserParam.clear();
+                parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+
+                if (UserGradeEnum.grade4.getCode().equals(userGrade.getCode())) {
+                    // 贡献比例 23%
+                    directlyContributeRate = new BigDecimal("23");
+                    parentUserParam.put("sourceContent", "直属团长团队贡献");
+
+                } else if (UserGradeEnum.grade1.getCode().equals(userGrade.getCode()) || UserGradeEnum.grade2.getCode().equals(userGrade.getCode())) {
+                    // 贡献比例 55%
+                    directlyContributeRate = new BigDecimal("55");
+                    parentUserParam.put("sourceContent", "非直属会员贡献");
                 }
+                // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                        .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                        .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                // 渠道账户
+                userAccountService.recharge(userParentRel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+
+                // 递归判断渠道
+                BsUserParentRel channel = userParentRelService.getParent(Arrays.asList(UserGradeEnum.grade4), parentRel.getParentUserId());
+                if (channel != null) {
+                    // 贡献比例 9%
+                    directlyContributeRate = new BigDecimal("9");
+                    // 贡献  = （返利金额 * 元宝汇率） * 直属贡献
+                    goldCoin = (rebateAmount.multiply(goldCoinExchangeRate))
+                            .multiply(directlyContributeRate.divide(new BigDecimal("100")))
+                            .setScale(6, BigDecimal.ROUND_HALF_DOWN);
+                    // 贡献
+                    parentUserParam.clear();
+                    parentUserParam.put("sourceId", MapUtils.getString(otherParam, "sourceId"));
+                    parentUserParam.put("sourceOrderNo", MapUtils.getString(otherParam, "sourceOrderNo"));
+                    parentUserParam.put("sourceContent", "直属渠道团队贡献");
+                    // 渠道账户
+                    userAccountService.recharge(channel.getParentUserId(), goldCoin, UserAccountRecordSourceTypeEnum.type1, parentUserParam);
+                }
+            }
+        }
+    }
+
 
 }

service/src/main/java/com/hfkj/service/user/impl/BsUserParentRelServiceImpl.java

@@ -3,6 +3,7 @@ package com.hfkj.service.user.impl;
 import com.hfkj.dao.BsUserParentRelMapper;
 import com.hfkj.entity.BsUserParentRel;
 import com.hfkj.entity.BsUserParentRelExample;
+import com.hfkj.model.UserTeamModel;
 import com.hfkj.service.user.BsUserParentRelService;
 import com.hfkj.sysenum.user.UserGradeEnum;
 import org.springframework.stereotype.Service;
@@ -56,6 +57,11 @@ public class BsUserParentRelServiceImpl implements BsUserParentRelService {
         return recursionParent(grade, userParentRel.getParentUserId(), new ArrayList<>(Arrays.asList(userParentRel)));
     }
 
+    @Override
+    public List<UserTeamModel> getTeamSubList(Map<String, Object> param) {
+        return userParentRelMapper.queryTeamSubList(param);
+    }
+
     /**
      * 递归获取上级
      * @param grade 等级列表，匹配其中一个等级就返回数据