3
0
Fork 0

Compare commits

..

No commits in common. "fb6b2d1d00f15119de63adda07d212789a4fc9dc" and "aa42aa02635e6c76e9cced7f80e4b34d1d8d4b02" have entirely different histories.

5 changed files with 41 additions and 52 deletions

View File

@ -608,12 +608,12 @@ public interface CuMemberMapper extends BaseMapper<CuMember> {
CuMember getShopkeeperMember(@Param("pkMember") Long pkMember, @Param("gradeValue") Integer gradeValue); CuMember getShopkeeperMember(@Param("pkMember") Long pkMember, @Param("gradeValue") Integer gradeValue);
/** /**
* 查询会员等级 * 查询高级店主
* *
* @param pkMember * @param pkMember
* @return * @return
*/ */
CuMemberExt getGradeSvipMember(@Param("pkMember") Long pkMember, @Param("gradeValue") Integer gradeValue); CuMember getGradeSvipMember(@Param("pkMember") Long pkMember);
/** /**
* 查询会员直推大于博羚店主的注册升级订单查询会员直推大于博羚店主的注册升级订单 * 查询会员直推大于博羚店主的注册升级订单查询会员直推大于博羚店主的注册升级订单
@ -622,7 +622,7 @@ public interface CuMemberMapper extends BaseMapper<CuMember> {
* @param orderCode * @param orderCode
* @return * @return
*/ */
SaOrder listRecommendVipOrder(@Param("pkMember") Long pkMember, @Param("orderCode") String orderCode, @Param("gradeValue") Integer gradeValue); SaOrder listRecommendVipOrder(@Param("pkMember") Long pkMember, @Param("orderCode") String orderCode);
/** /**

View File

@ -878,12 +878,12 @@ public interface ICuMemberService extends IService<CuMember> {
CuMember getShopkeeperMember(Long pkMember, Integer gradeValue); CuMember getShopkeeperMember(Long pkMember, Integer gradeValue);
/** /**
* 查询会员等级 * 查询高级店主
* *
* @param pkMember * @param pkMember
* @return * @return
*/ */
CuMemberExt getGradeSvipMember(Long pkMember, Integer gradeValue); CuMember getGradeSvipMember(Long pkMember);
/** /**
* 查询会员直推大于博羚店主的注册升级订单查询会员直推大于博羚店主的注册升级订单 * 查询会员直推大于博羚店主的注册升级订单查询会员直推大于博羚店主的注册升级订单
@ -892,7 +892,7 @@ public interface ICuMemberService extends IService<CuMember> {
* @param orderCode * @param orderCode
* @return * @return
*/ */
SaOrder listRecommendVipOrder(Long pkMember, String orderCode, Integer gradeValue); SaOrder listRecommendVipOrder(Long pkMember, String orderCode);
/** /**
* 查询汇总 * 查询汇总

View File

@ -1674,47 +1674,38 @@ public class CuMemberBusinessServiceImpl implements ICuMemberBusinessService {
memberLevelQuery.eq(CuMemberLevel::getUpType, EUpgradeType.AUTO_UPGRADE.getValue()); memberLevelQuery.eq(CuMemberLevel::getUpType, EUpgradeType.AUTO_UPGRADE.getValue());
CuMemberLevel parentLevel = iCuMemberLevelService.getOne(memberLevelQuery); CuMemberLevel parentLevel = iCuMemberLevelService.getOne(memberLevelQuery);
if (null != parentLevel) { if (null != parentLevel) {
// 查询推荐人及等级信息 // 查询推荐人信息必须是高级店主
CuMemberExt parentMember = iCuMemberService.getGradeSvipMember(parentLevel.getPkMember(), null); CuMember parentMember = iCuMemberService.getGradeSvipMember(parentLevel.getPkMember());
if (null != parentMember) { if (null != parentMember) {
SaOrder parentOrder = null; // 推荐是高级店主查询直推博羚店主以上订单
if (parentMember.getGradeValue() == EGrade.DIRECTOR.getValue()) { SaOrder parentOrder = iCuMemberService.listRecommendVipOrder(parentMember.getPkId(), saOrder.getOrderCode());
// 推荐人是董事代理查询直推区域代理以上订单 if (null != parentOrder) {
parentOrder = iCuMemberService.listRecommendVipOrder(parentMember.getPkId(), saOrder.getOrderCode(), EGrade.REGION.getValue()); // 存在其它博羚店主订单重新处理升级记录
} else if (parentMember.getGradeValue() == EGrade.S_VIP.getValue()) { CuMemberLevel parentNewLevel = BeanUtil.copyProperties(parentLevel, CuMemberLevel.class);
// 推荐人是高级店主查询直推博羚店主以上订单 parentNewLevel.setPkId(null);
parentOrder = iCuMemberService.listRecommendVipOrder(parentMember.getPkId(), saOrder.getOrderCode(), EGrade.VIP.getValue()); parentNewLevel.setPkOrder(parentOrder.getPkId());
parentNewLevel.setUpgradeTime(parentOrder.getPayTime());
parentNewLevel.setModifiedTime(parentOrder.getPayTime());
parentNewLevel.setPkModified(parentOrder.getPkMember());
iCuMemberLevelService.save(parentNewLevel);
} else {
// 不存在其它博羚店主订单会员需要降级处理
LambdaUpdateWrapper<CuMember> parentMemberUpdate = new LambdaUpdateWrapper<>();
parentMemberUpdate.eq(CuMember::getPkId, parentMember.getPkId());
parentMemberUpdate.set(CuMember::getPkSettleGrade, parentLevel.getOldLevel());
parentMemberUpdate.set(CuMember::getModifiedTime, currentDateTime);
iCuMemberService.update(parentMemberUpdate);
} }
this.handleParentLevelUpdate(parentOrder, parentLevel, parentMember, currentDateTime); // 删除原来升级记录
LambdaUpdateWrapper<CuMemberLevel> updateMemberLevel = new LambdaUpdateWrapper<>();
updateMemberLevel.eq(CuMemberLevel::getPkId, parentLevel.getPkId());
updateMemberLevel.set(CuMemberLevel::getDelFlag, EDelFlag.DELETE.getValue());
updateMemberLevel.set(CuMemberLevel::getModifiedTime, currentDateTime);
iCuMemberLevelService.update(updateMemberLevel);
} }
} }
} }
}
private void handleParentLevelUpdate(SaOrder parentOrder, CuMemberLevel parentLevel, CuMemberExt parentMember, Date currentDateTime) {
if (null != parentOrder) {
// 存在其它博羚店主订单重新处理升级记录
CuMemberLevel parentNewLevel = BeanUtil.copyProperties(parentLevel, CuMemberLevel.class);
parentNewLevel.setPkId(null);
parentNewLevel.setPkOrder(parentOrder.getPkId());
parentNewLevel.setUpgradeTime(parentOrder.getPayTime());
parentNewLevel.setModifiedTime(parentOrder.getPayTime());
parentNewLevel.setPkModified(parentOrder.getPkMember());
iCuMemberLevelService.save(parentNewLevel);
} else {
// 不存在其它博羚店主订单会员需要降级处理
LambdaUpdateWrapper<CuMember> parentMemberUpdate = new LambdaUpdateWrapper<>();
parentMemberUpdate.eq(CuMember::getPkId, parentMember.getPkId());
parentMemberUpdate.set(CuMember::getPkSettleGrade, parentLevel.getOldLevel());
parentMemberUpdate.set(CuMember::getModifiedTime, currentDateTime);
iCuMemberService.update(parentMemberUpdate);
}
// 删除原来升级记录
LambdaUpdateWrapper<CuMemberLevel> updateMemberLevel = new LambdaUpdateWrapper<>();
updateMemberLevel.eq(CuMemberLevel::getPkId, parentLevel.getPkId());
updateMemberLevel.set(CuMemberLevel::getDelFlag, EDelFlag.DELETE.getValue());
updateMemberLevel.set(CuMemberLevel::getModifiedTime, currentDateTime);
iCuMemberLevelService.update(updateMemberLevel);
} }

View File

@ -3250,13 +3250,13 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
} }
@Override @Override
public CuMemberExt getGradeSvipMember(Long pkMember, Integer gradeValue) { public CuMember getGradeSvipMember(Long pkMember) {
return baseMapper.getGradeSvipMember(pkMember, gradeValue); return baseMapper.getGradeSvipMember(pkMember);
} }
@Override @Override
public SaOrder listRecommendVipOrder(Long pkMember, String orderCode, Integer gradeValue) { public SaOrder listRecommendVipOrder(Long pkMember, String orderCode) {
return baseMapper.listRecommendVipOrder(pkMember, orderCode, gradeValue); return baseMapper.listRecommendVipOrder(pkMember, orderCode);
} }

View File

@ -2382,18 +2382,16 @@
and bg.grade_value = #{gradeValue} and bg.grade_value = #{gradeValue}
</select> </select>
<!-- 查询会员等级 --> <!-- 查询高级店主 -->
<select id="getGradeSvipMember" resultType="com.hzs.common.domain.member.ext.CuMemberExt"> <select id="getGradeSvipMember" resultType="com.hzs.common.domain.member.base.CuMember">
select cm.*, bg.grade_value gradeValue select cm.*
from cu_member cm from cu_member cm
left join bd_grade bg left join bd_grade bg
on bg.pk_id = cm.pk_settle_grade on bg.pk_id = cm.pk_settle_grade
where cm.del_flag = 0 where cm.del_flag = 0
and cm.category = 0 and cm.category = 0
and cm.pk_id = #{pkMember} and cm.pk_id = #{pkMember}
<!-- and bg.grade_value = 70
and bg.grade_value = #{gradeValue}
-->
</select> </select>
<!-- 查询会员直推大于博羚店主的注册、升级订单 --> <!-- 查询会员直推大于博羚店主的注册、升级订单 -->
@ -2418,7 +2416,7 @@
<if test="orderCode != null and orderCode != ''"> <if test="orderCode != null and orderCode != ''">
and so.order_code != #{orderCode} and so.order_code != #{orderCode}
</if> </if>
and bg.grade_value >= #{gradeValue}) so and bg.grade_value >= 60) so
where rownum = 1 where rownum = 1
</select> </select>
<select id="getMemberCountWithGradeAndParent" resultType="java.lang.Integer"> <select id="getMemberCountWithGradeAndParent" resultType="java.lang.Integer">