会员分成记录信息

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/MemberShareRecordBiz.java

@@ -210,9 +210,15 @@ public class MemberShareRecordBiz extends BaseBiz<MemberShareRecordMapper, Membe
 	public void generateMemberShareQueue(OrderMemberDetail orderMemberDetail) {
 		if (orderMemberDetail != null) {
 			log.info("会员订单信息: {}", orderMemberDetail);
-			BaseUserMemberLevel baseUserMemberLevel = baseUserMemberLevelMapper.selectOne(new BaseUserMemberLevel(){{setIsdel(0); setId(orderMemberDetail.getMemberLevelId());}});
-			log.info("会员等级信息: {}", baseUserMemberLevel);
-			if (baseUserMemberLevel != null && baseUserMemberLevel.getIsShare() == 1) {
+			Example example = new Example(BaseUserMemberLevel.class);
+			example.createCriteria().andEqualTo("isdel", 0).andEqualTo("isShare", 1);
+			example.orderBy("level");
+			List<BaseUserMemberLevel> baseUserMemberLevelList = baseUserMemberLevelMapper.selectByExample(example);
+			if (baseUserMemberLevelList != null && baseUserMemberLevelList.size() > 0) {
+				//如果购买会员是分成会员低一级会员以及分成会员，才参与分成
+				if (orderMemberDetail.getMemberLevel().compareTo(baseUserMemberLevelList.get(0).getLevel() - 1) >= 0) {
+					//所有分成会员都需要新增一条记录
+					for (BaseUserMemberLevel baseUserMemberLevel : baseUserMemberLevelList) {
 						List<BaseUserMember> baseUserMemberList = baseUserMemberBiz.selectList(new BaseUserMember(){{setIsDel(0); setMemberLevel(orderMemberDetail.getMemberLevel());}});
 						if (baseUserMemberList != null && baseUserMemberList.size() > 0) {
 							List<Integer> userIds = baseUserMemberList.stream().map(BaseUserMember::getUserId).collect(Collectors.toList());
@@ -241,5 +247,7 @@ public class MemberShareRecordBiz extends BaseBiz<MemberShareRecordMapper, Membe
 					}
 				}
 				}
+			}
+	}
 
 }
\ No newline at end of file