Compare commits

...

4 Commits

Author SHA1 Message Date
zhangheng a34fd94c44 ## 删除死点优化 2025-09-12 09:57:42 +08:00
zhangheng cd36cdd586 ## 删除死点代码优化 2025-09-12 09:57:41 +08:00
zhangheng 8c62bcf380 ## 删除死点添加日志 2025-09-12 09:57:41 +08:00
zhangheng 1192bea7a4 ## 删除死点 2025-09-12 09:57:41 +08:00
7 changed files with 46 additions and 38 deletions

View File

@ -1,6 +1,9 @@
package com.hzs.member.base.controller.manage;
import com.hzs.common.core.annotation.Log;
import com.hzs.common.core.enums.EOperationMethod;
import com.hzs.common.core.enums.EOperationModule;
import com.hzs.common.core.web.controller.BaseController;
import com.hzs.common.core.web.domain.AjaxResult;
import com.hzs.common.core.web.page.TableDataInfo;
@ -9,10 +12,7 @@ import com.hzs.member.base.param.DeleteDeadLockParam;
import com.hzs.member.base.service.DeleteDeadLockService;
import com.hzs.member.base.vo.DeleteDeadLockVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@ -26,6 +26,7 @@ public class DeleteDeadLockController extends BaseController {
/**
* 删除死点列表
*/
@Log(module = EOperationModule.DELETE_DEAD_LOCK, method = EOperationMethod.SELECT)
@GetMapping("list")
public TableDataInfo list(DeleteDeadLockParam deleteDeadLockParam) {
startPage();
@ -37,8 +38,9 @@ public class DeleteDeadLockController extends BaseController {
/**
* 删除死点
*/
@Log(module = EOperationModule.DELETE_DEAD_LOCK, method = EOperationMethod.DELETE)
@PostMapping("delete")
public AjaxResult delete(DeleteDeadLockParam deleteDeadLockParam) {
public AjaxResult delete(@RequestBody DeleteDeadLockParam deleteDeadLockParam) {
String check = deleteDeadLockService.deleteDeadLockMember(deleteDeadLockParam);
if (check == null) {
return AjaxResult.success();

View File

@ -15,7 +15,6 @@ public class DeleteDeadLockParam {
/**
* 会员编号
*/
@NotNull(message = "会员编号不可为空")
private String memberCode;
/**

View File

@ -3,6 +3,8 @@ package com.hzs.member.base.service.impl;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hzs.common.core.constant.msg.MemberMsgConstants;
import com.hzs.common.core.enums.EDelFlag;
import com.hzs.common.core.enums.EPlaceDept;
import com.hzs.common.domain.member.base.CuMember;
import com.hzs.common.security.utils.SecurityUtils;
import com.hzs.member.account.service.ICuMemberAccountService;
@ -10,6 +12,7 @@ import com.hzs.member.base.mapper.CuMemberMapper;
import com.hzs.member.base.param.DeleteDeadLockParam;
import com.hzs.member.base.service.DeleteDeadLockService;
import com.hzs.member.base.vo.DeleteDeadLockVO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@ -18,13 +21,18 @@ import java.util.Date;
import java.util.List;
@Service
@Slf4j
public class DeleteDeadLockServiceImpl extends ServiceImpl<CuMemberMapper, CuMember> implements DeleteDeadLockService {
@Autowired
private ICuMemberAccountService iCuMemberAccountService;
@Override
public List<DeleteDeadLockVO> queryDeleteDeadLockList(String memberCode) {
return baseMapper.queryDeleteDeadLockList(memberCode);
List<DeleteDeadLockVO> deleteDeadLockVOList = baseMapper.queryDeleteDeadLockList(memberCode);
deleteDeadLockVOList.forEach(deleteDeadLockVO -> {
deleteDeadLockVO.setPlaceDept(EPlaceDept.getEPlaceDept(Integer.parseInt(deleteDeadLockVO.getPlaceDept())));
});
return deleteDeadLockVOList;
}
@Override
@ -35,6 +43,7 @@ public class DeleteDeadLockServiceImpl extends ServiceImpl<CuMemberMapper, CuMem
}
// 查询安置伞下和推荐伞下未删除会员数量,如果未删除会员数量为0返回true
Integer isNoDeadNum = baseMapper.queryIsDeadMember(deleteDeadLockParam.getMemberCode());
log.info("安置伞下和推荐伞下未删除会员数量:{}",isNoDeadNum);
if(isNoDeadNum == 0){
// 删除操作
Long userId = SecurityUtils.getUserId();
@ -44,7 +53,7 @@ public class DeleteDeadLockServiceImpl extends ServiceImpl<CuMemberMapper, CuMem
.eq(CuMember::getMemberCode,deleteDeadLockParam.getMemberCode())
.set(CuMember::getPkModified,userId)
.set(CuMember::getModifiedTime,date)
.set(CuMember::getDelFlag,1));
.set(CuMember::getDelFlag, EDelFlag.DELETE));
// 删除会员账户
iCuMemberAccountService.deleteCuMemberAccountByMemberCode(userId,date,deleteDeadLockParam.getMemberCode());
} else {

View File

@ -27,7 +27,7 @@ public class DeleteDeadLockVO {
/**
* 结算等级
*/
private Integer pkSettleGrade;
private String pkSettleGrade;
/**
* 推荐人编号
*/

View File

@ -69,14 +69,14 @@
<result column="ACCOUNT_STATUS" property="accountStatus"/>
<result column="PK_COUNTRY" property="pkCountry"/>
</resultMap>
<delete id="deleteCuMemberAccountByMemberCode">
<update id="deleteCuMemberAccountByMemberCode">
update cu_member_account cma
set cma.del_flag = 1,cma.PK_MODIFIED = #{userId},cma.MODIFIED_TIME = #{date}
where cma.pk_member in
(select cm.pk_id
from cu_member cm
where cm.member_code = #{memberCode})
</delete>
</update>
<select id="queryMemberAccountByCondition" resultMap="AccountExResultMap">
select cm.pay_pwd,

View File

@ -3207,7 +3207,7 @@
<select id="queryDeleteDeadLockList" resultType="com.hzs.member.base.vo.DeleteDeadLockVO">
SELECT
cu.MEMBER_CODE,
cu.MEMBER_NAMEcu.PK_SETTLE_GRADE,
cu.MEMBER_NAMEbdg.GRADE_NAME as pkSettleGrade,
cus.MEMBER_CODE AS parMemberCode,
cuss.MEMBER_CODE AS placeMemberCodecu.PLACE_DEPT,
cu.CREATION_TIME
@ -3215,10 +3215,11 @@
CU_MEMBER cu
LEFT JOIN CU_MEMBER cus ON cu.PK_PARENT = cus.PK_ID
LEFT JOIN CU_MEMBER cuss ON cu.PK_PLACE_PARENT = cuss.PK_ID
LEFT JOIN BD_GRADE bdg ON cu.PK_SETTLE_GRADE = bdg.PK_ID
WHERE
cu.DEL_FLAG = 0
AND cu.CATEGORY = 2
<if test="memberCode != null">
<if test="memberCode != null and memberCode != ''">
AND cu.MEMBER_CODE = #{memberCode}
</if>
</select>
@ -3230,23 +3231,18 @@
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 START WITH MEMBER_CODE = #{memberCode} CONNECT BY PRIOR PK_ID = PK_PARENT
AND MEMBER_CODE = #{memberCode}
AND DEL_FLAG = 0 UNION
SELECT
MEMBER_CODE
FROM
CU_MEMBER START WITH MEMBER_CODE = #{memberCode} CONNECT BY PRIOR PK_ID = PK_PLACE_PARENT
AND MEMBER_CODE = #{memberCode}
AND DEL_FLAG = 0
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>

View File

@ -357,6 +357,8 @@ public enum EOperationModule {
CANCEL_ORDER_CONFIRM("撤销订单确认"),
DELETE_DEAD_LOCK("删除死点"),
///////////////////////////统计分析////////////////////////////
STATISTIC_ANALYSIS("统计分析"),