angelo
/
java-base-app
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

## 登录判断会员拆分拦截处理；

This commit is contained in:
cabbage 2025-10-14 13:38:18 +08:00
parent f998926cc3
commit f9f20562a2
6 changed files with 139 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
bd-business/bd-business-member/src/main/java/com/hzs/member/base/mapper/CuMemberMapper.java
View File

@ -2,6 +2,7 @@ package com.hzs.member.base.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.domain.member.base.CuMemberSplit;
import com.hzs.common.domain.member.ext.CuMemberExt;
import com.hzs.member.base.dto.MemberCountDTO;
import com.hzs.member.base.param.*;
@ -794,4 +795,12 @@ public interface CuMemberMapper extends BaseMapper<CuMember> {
List<DeleteDeadLockVO> queryDeleteDeadLockList(@Param("memberCode") String memberCode);
Integer queryIsDeadMember(@Param("memberCode") String memberCode);
/**
* 系统会员拆分列表
*
* @return
*/
List<CuMemberSplit> listMemberSplit();
}

90
bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/ICuMemberService.java
View File

@ -3,6 +3,7 @@ package com.hzs.member.base.service;
import cn.hutool.core.lang.tree.Tree;
import com.baomidou.mybatisplus.extension.service.IService;
import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.domain.member.base.CuMemberSplit;
import com.hzs.common.domain.member.ext.CuMemberExt;
import com.hzs.common.domain.member.ext.CuMemberSettleExt;
import com.hzs.member.base.param.UpdatePlaceParentPetitionParam;
@ -37,7 +38,7 @@ public interface ICuMemberService extends IService<CuMember> {
Boolean saveMember(CuMember cuMember);
/*
* @description: 查询网体是否存在推荐人
* 查询网体是否存在推荐人
**/
Integer queryCuMemberByPkMember(Long pkReference);
@ -65,7 +66,7 @@ public interface ICuMemberService extends IService<CuMember> {
List<CuMemberExt> getMemberInfoByCondition(CuMember cuMember);
/*
* @description: 根据条件查询会员信息，查询单表
* 根据条件查询会员信息，查询单表
**/
List<CuMemberExt> queryMemberByCondition(CuMember cuMember);
@ -86,12 +87,12 @@ public interface ICuMemberService extends IService<CuMember> {
CuMember getMember(Long pkId);
/*
* @description: 查询会员
* 查询会员
**/
CuMember queryMember(String memberCode);
/*
* @description: 查询会员
* 查询会员
**/
CuMember queryMember(Long pkMember);
@ -194,14 +195,14 @@ public interface ICuMemberService extends IService<CuMember> {
List<CuMemberVO> queryCuMemberByCondition(CuMemberVO memberParam);
/*
* @description: 查询会员信息，根据条件
* 查询会员信息，根据条件
**/
List<CuMemberVO> queryCuMemberByMemberList(List<CuMemberVO> cuMemberVOList, CuMemberVO memberParam);
List<CuMemberVO> queryCuMemberByMemberListExcel(CuMemberVO memberParam);
/**
* @description: 查询真实信息
* 查询真实信息
**/
List<CuMemberVO> realCuMemberByCondition(CuMemberVO memberParam);
@ -262,27 +263,27 @@ public interface ICuMemberService extends IService<CuMember> {
CuMember createEmptyOrderMember(CuMemberExt member);
/**
* @description: 特殊业务-修改会员编号列表
* 特殊业务-修改会员编号列表
**/
List<UpdateCodeVO> puCodeList(UpdateCodeVO updateCodeVO);
/**
* @description: 查询会员有效期休止期
* 查询会员有效期休止期
**/
List<UpdateExpireStopVO> getMemberExpireStopList(UpdateExpireStopVO updateExpireStopVO);
/**
* @description: 零元撤单列表
* 零元撤单列表
**/
List<ZeroElementRevokeVO> zeroList(ZeroElementRevokeVO zeroElementRevokeVO);
/**
* @description: 零元撤单签呈列表
* 零元撤单签呈列表
**/
List<ZeroElementRevokeDTO> zeroByBusinessList(AnalysisBusinessAppealParam analysisBusinessAppealParam);
/**
* @description: 查询会员变更前信息
* 查询会员变更前信息
**/
UpdateCodeVO specialBusinessQuery(UpdateCodeVO updateCodeVO);
@ -301,47 +302,47 @@ public interface ICuMemberService extends IService<CuMember> {
String updateParent(ParentParam parentParam);
/**
* @description: 批量修改会员编号
* 批量修改会员编号
**/
UpdateCodeVO updateCode(UpdateCodeVO updateCodeVO);
/**
* @description: 修改会员续约发起签呈
* 修改会员续约发起签呈
**/
UpdateExpireStopVO upExpireStop(UpdateExpireStopVO upESVO);
/**
* @description: 修改会员续约-审核通过驳回
* 修改会员续约-审核通过驳回
**/
boolean upExpireStopProcess(ApprovalBusinessResultDTO approvalBusinessResultDTO);
/**
* @description: 发起签呈-修改会员编号
* 发起签呈-修改会员编号
**/
UpdateCodeVO petition(UpdateCodeVO updateCodeVO);
/**
* @description: 审核通过根据业务单号，业务类型批量修改业务数据
* 审核通过根据业务单号，业务类型批量修改业务数据
**/
boolean updateCodeByBusinessNo(ApprovalBusinessResultDTO approvalBusinessResultDTO);
/**
* @description: 政策币签呈审核
* 政策币签呈审核
**/
boolean upPolicyCurrencyProcess(ApprovalBusinessResultDTO approvalBusinessResultDTO);
/**
* @description:删除政策币业务审核
* 删除政策币业务审核
**/
boolean delPolicyCurrencyProcess(ApprovalBusinessResultDTO approvalBusinessResultDTO);
/**
* @description: 审核驳回 根据业务单号，业务类型批量修改业务数据
* 审核驳回 根据业务单号，业务类型批量修改业务数据
**/
boolean updateCodeReject(ApprovalBusinessResultDTO approvalBusinessResultDTO);
/**
* @description: 真实奖衔控制-通过或驳回
* 真实奖衔控制-通过或驳回
**/
boolean awardsControlPetition(ApprovalBusinessResultDTO approvalBusinessResultDTO);
@ -372,47 +373,47 @@ public interface ICuMemberService extends IService<CuMember> {
Integer batchUpdateMemberByBusinessType(HandleBusinessVO handleBusinessVO);
/**
* @description: 招商列表
* 招商列表
**/
List<UserInvestmentVo> selectBiddingList(MarketNewsParam marketNewsParam);
/**
* @description:
*
**/
List<UpdateSettleCountryVO> upsettleCountryList(UpdateSettleCountryVO upseCountryVO);
/**
* @description:查询修改政策币列表
* 查询修改政策币列表
**/
List<UpPolicyCurrencyVO> upPolicyCurrencyList(UpPolicyCurrencyVO upVO);
/**
* @description: 特殊业务-修改结算国
* 特殊业务-修改结算国
**/
UpdateSettleCountryVO updateSettleCountry(UpdateSettleCountryVO upseCountryVO);
/**
* @description: 特殊业务-修改政策币
* 特殊业务-修改政策币
**/
UpPolicyCurrencyVO upPolicyCurrency(UpPolicyCurrencyVO policyCurrencyVO);
/**
* @description: 特殊业务-删除政策币业务
* 特殊业务-删除政策币业务
**/
UpPolicyCurrencyVO delPolicyCurrency(UpPolicyCurrencyVO policyCurrencyVO);
/**
* @description: 发起签呈-修改结算国
* 发起签呈-修改结算国
**/
UpdateSettleCountryVO petition(UpdateSettleCountryVO upseCountryVO);
/**
* @description: 发起签呈-修改政策币发起签呈
* 发起签呈-修改政策币发起签呈
**/
UpPolicyCurrencyVO petition(UpPolicyCurrencyVO policyCurrencyVO);
/**
* @description: 零元撤单审核-审核通过、驳回
* 零元撤单审核-审核通过、驳回
**/
boolean zeroByBusinessNo(ApprovalBusinessResultDTO approvalBusinessResultDTO);
@ -428,37 +429,37 @@ public interface ICuMemberService extends IService<CuMember> {
List<Tree<String>> systemTjSetListTree(List<CuMemberSettleExt> memberSettleExtList, CuMemberSettleExt memberSettleExt, String settleTableName, Boolean isMemberSecord);
/**
* @description: 特殊业务-修改结算国-审核通过
* 特殊业务-修改结算国-审核通过
**/
boolean updateSettleCountryAdopt(ApprovalBusinessResultDTO approvalBusinessResultDTO);
/**
* @description: 特殊业务-修改结算国-审核驳回
* 特殊业务-修改结算国-审核驳回
**/
boolean updateSettleCountryReject(ApprovalBusinessResultDTO approvalBusinessResultDTO);
/**
* @description: 校验会员是否有充值审核
* 校验会员是否有充值审核
**/
Integer checkCecharge(Long pkMember);
/**
* @description: 校验会员是否有提现审核
* 校验会员是否有提现审核
**/
Integer checkWithdraw(Long pkMember);
/**
* @description: 校验会员所有账户是否有余额
* 校验会员所有账户是否有余额
**/
Integer checkAccount(Long pkMember);
/**
* @description: 查询会员是否存在未完成基础业务办理
* 查询会员是否存在未完成基础业务办理
**/
Integer checkmsLogCount(Long pkMember, Integer editType);
/**
* @description: 查询会员是否存在未完成注水业绩业务
* 查询会员是否存在未完成注水业绩业务
**/
Integer checkMemberAchieveCount(Long pkMember);
@ -489,12 +490,12 @@ public interface ICuMemberService extends IService<CuMember> {
List<Tree<String>> systemAzSetListTreeFive(List<CuMemberSettleExt> list, CuMemberSettleExt memberSettleExt);
/**
* @description: 获取等级的翻译KEY值
* 获取等级的翻译KEY值
**/
Integer getGradeTranslateValue(Integer pkId);
/**
* @description: 获取奖衔的翻译KEY值
* 获取奖衔的翻译KEY值
**/
Integer getAwardsTranslateValue(Integer pkCountry, Integer pkId);
@ -720,7 +721,7 @@ public interface ICuMemberService extends IService<CuMember> {
void updateParentByBusinessNoReject(ApprovalBusinessResultDTO approvalBusinessResultDTO);
/*
* @description: 查询会员左右区人数
* 查询会员左右区人数
**/
List<CuMember> queryMemberLeftRightCount(Long pkMember);
@ -773,7 +774,7 @@ public interface ICuMemberService extends IService<CuMember> {
List<CuMemberExt> selectPlaceErrorCode();
/*
* @description: 查询伞下会员
* 查询伞下会员
**/
Boolean queryCuMemberUnderUmbrella(Long pkMember);
@ -858,7 +859,7 @@ public interface ICuMemberService extends IService<CuMember> {
List<MemberConsumptionStatVo> getMemberConsumptionStat(MemberConsumptionStatParam memberConsumptionStatParam);
/**
* @description: 查询表是否存在
* 查询表是否存在
**/
Integer selectExistTable(String tableName);
@ -1007,4 +1008,11 @@ public interface ICuMemberService extends IService<CuMember> {
*/
int countGradeMemberPoint(String memberName, String phone, Integer pkGrade, Integer pkCountry);
/**
* 系统会员拆分列表
*
* @return
*/
List<CuMemberSplit> listMemberSplit();
}

4
bd-business/bd-business-member/src/main/java/com/hzs/member/base/service/impl/CuMemberServiceImpl.java
View File

@ -3375,4 +3375,8 @@ public class CuMemberServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> i
return baseMapper.countGradeMemberPoint(memberName, phone, pkGrade, pkCountry);
}
@Override
public List<CuMemberSplit> listMemberSplit() {
return baseMapper.listMemberSplit();
}
}

16
bd-business/bd-business-member/src/main/java/com/hzs/member/login/service/impl/MemberLoginServiceImpl.java
View File

@ -1,5 +1,6 @@
package com.hzs.member.login.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.hzs.common.core.constant.msg.SystemMsgConstants;
import com.hzs.common.core.domain.R;
@ -10,6 +11,7 @@ import com.hzs.common.core.utils.StringUtils;
import com.hzs.common.core.utils.ip.IpUtils;
import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.domain.member.base.CuMemberShare;
import com.hzs.common.domain.member.base.CuMemberSplit;
import com.hzs.common.domain.member.detail.CuMemberLogin;
import com.hzs.common.domain.member.ext.CuMemberExt;
import com.hzs.common.security.utils.SecurityUtils;
@ -25,6 +27,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
/**
* 登录/登出服务
@ -86,6 +89,19 @@ public class MemberLoginServiceImpl implements IMemberLoginService {
throw new ServiceException(TransactionUtils.getContent(SystemMsgConstants.USER_NOT_EXIST, username));
}
// 判断会员拆分系统
List<CuMemberSplit> memberSplitList = iCuMemberService.listMemberSplit();
if (CollectionUtil.isNotEmpty(memberSplitList)) {
long nowTime = System.currentTimeMillis();
for (CuMemberSplit cuMemberSplit : memberSplitList) {
if (null != member.getPkVertex()
&& cuMemberSplit.getPkVertex().equals(member.getPkVertex())
&& nowTime > cuMemberSplit.getSplitTime()) {
throw new ServiceException(cuMemberSplit.getContent());
}
}
}
try {
// 是否更新会员
boolean updateFlag = false;

44
bd-business/bd-business-member/src/main/resources/mapper/member/base/CuMemberMapper.xml
View File

@ -3207,29 +3207,33 @@
cu.DEL_FLAG = 0
AND cu.CATEGORY = 2
<if test="memberCode != null and memberCode != ''">
AND cu.MEMBER_CODE = #{memberCode}
AND cu.MEMBER_CODE = #{memberCode}
</if>
</select>
<select id="queryIsDeadMember" resultType="java.lang.Integer">
SELECT
COUNT(*)
FROM
(
SELECT
MEMBER_CODE
FROM
CU_MEMBER
WHERE
DEL_FLAG = 0 START WITH MEMBER_CODE = #{memberCode} CONNECT BY PRIOR PK_ID = PK_PARENT UNION ALL
SELECT
MEMBER_CODE
FROM
CU_MEMBER
WHERE
DEL_FLAG = 0 START WITH MEMBER_CODE = #{memberCode} CONNECT BY PRIOR PK_ID = PK_PLACE_PARENT
) t
WHERE
t.MEMBER_CODE != #{memberCode}
SELECT COUNT(*)
FROM (
SELECT MEMBER_CODE
FROM CU_MEMBER
WHERE DEL_FLAG = 0 START
WITH MEMBER_CODE = #{memberCode}
CONNECT BY PRIOR PK_ID = PK_PARENT
UNION ALL
SELECT
MEMBER_CODE
FROM
CU_MEMBER
WHERE
DEL_FLAG = 0
START WITH MEMBER_CODE = #{memberCode}
CONNECT BY PRIOR PK_ID = PK_PLACE_PARENT
) t
WHERE t.MEMBER_CODE != #{memberCode}
</select>
<!-- 系统会员拆分列表 -->
<select id="listMemberSplit" resultType="com.hzs.common.domain.member.base.CuMemberSplit">
select * from CU_MEMBER_SPLIT cms
</select>
</mapper>

37
bd-common/bd-common-domain/src/main/java/com/hzs/common/domain/member/base/CuMemberSplit.java Normal file
View File

@ -0,0 +1,37 @@
package com.hzs.common.domain.member.base;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import lombok.experimental.Accessors;
/**
* 系统会员拆分表
*/
@Data
@Accessors(chain = true)
@TableName("CU_MEMBER_SPLIT")
public class CuMemberSplit {
private static final long serialVersionUID = 1L;
/**
* 体系ID
*/
@TableField("PK_VERTEX")
private Long pkVertex;
/**
* 时间线（时间戳毫秒级）
*/
@TableField("SPLIT_TIME")
private Long splitTime;
/**
* 提示信息
*/
@TableField("CONTENT")
private String content;
}