注销逻辑调整;

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserServiceImpl.java

 package com.liquidnet.service.adam.service.impl;
 
-import com.fasterxml.jackson.databind.JsonNode;
-import com.liquidnet.common.exception.LiquidnetServiceException;
-import com.liquidnet.commons.lang.util.*;
+import com.liquidnet.commons.lang.util.CollectionUtil;
+import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.adam.constant.AdamConst;
 import com.liquidnet.service.adam.dto.AdamThirdPartParam;
-import com.liquidnet.service.adam.dto.vo.AdamRealInfoVo;
-import com.liquidnet.service.adam.dto.vo.AdamThirdPartInfoVo;
-import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
+import com.liquidnet.service.adam.dto.vo.*;
 import com.liquidnet.service.adam.entity.AdamRealName;
 import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamEntersService;
@@ -274,50 +271,99 @@ public class AdamUserServiceImpl implements IAdamUserService {
         LinkedList<String> toMqSqls = CollectionUtil.linkedListString();
         LinkedList<Object[]> objsUser = CollectionUtil.linkedListObjectArr(),
                 objsThirdPart = CollectionUtil.linkedListObjectArr(),
+                objsUserMember = CollectionUtil.linkedListObjectArr(),
+                objsRealInfo = CollectionUtil.linkedListObjectArr(),
+                objsEnters = CollectionUtil.linkedListObjectArr(),
                 objsAddresses = CollectionUtil.linkedListObjectArr();
 
         long s = System.currentTimeMillis();
 //        AdamUserInfoVo userInfoVo = adamRdmService.getUserInfoVoByUid(uid);
 //
 //        adamRdmService.delUidByMobile(userInfoVo.getMobile());
-        List<AdamThirdPartInfoVo> thirdPartInfoVos = adamRdmService.getThirdPartVoListByUid(uid);
-        if (!CollectionUtils.isEmpty(thirdPartInfoVos)) {
-            thirdPartInfoVos.forEach(r -> {
-                adamRdmService.delUidByPlatformOpenId(r.getPlatform(), r.getOpenId());
-            });
-            adamRdmService.delThirdPartVoListByUid(uid);
-        }
-        adamRdmService.delUserInfoVoByUid(uid);
-        adamRdmService.delUserMemberVoByUid(uid);
-        adamRdmService.delAddressesVoByUid(uid);
-        adamRdmService.delEntersVoByUid(uid);
+//        adamRdmService.delUserInfoVoByUid(uid);
+//        adamRdmService.delUserMemberVoByUid(uid);
+//        adamRdmService.delAddressesVoByUid(uid);
+//        adamRdmService.delEntersVoByUid(uid);
         log.debug("##RDS耗时:{}ms", System.currentTimeMillis() - s);
 
+        /* ---------------------- 账号基础信息 */
+        AdamUserInfoVo userInfoVoByUid = adamRdmService.getUserInfoVoByUid(uid);
+        if (null != userInfoVoByUid) {
+            userInfoVoByUid.setState(2);
+            userInfoVoByUid.setUpdatedAt(now);
+            userInfoVoByUid.setClosedAt(now);
+            adamRdmService.setUserInfoVoByUid(uid, userInfoVoByUid);
+        }
         toMqSqls.add(SqlMapping.get("adam_user.close"));
         objsUser.add(new Object[]{now, now, uid});
 
         /* ---------------------- 三方账号信息 */
+        List<AdamThirdPartInfoVo> thirdPartInfoVos = adamRdmService.getThirdPartVoListByUid(uid);
         if (!CollectionUtils.isEmpty(thirdPartInfoVos)) {
-            toMqSqls.add(SqlMapping.get("adam_third_party.close"));
-            objsThirdPart.add(new Object[]{now, uid});
+            thirdPartInfoVos.forEach(r -> {
+                r.setState(2);
+                r.setUpdatedAt(now);
+
+                adamRdmService.delUidByPlatformOpenId(r.getPlatform(), r.getOpenId());
+            });
+            adamRdmService.setThirdPartVoListByUid(uid, thirdPartInfoVos);
         }
+        toMqSqls.add(SqlMapping.get("adam_third_party.close"));
+        objsThirdPart.add(new Object[]{now, uid});
 
         /* ---------------------- 用户会员信息 */
+        AdamUserMemberVo userMemberVoByUid = adamRdmService.getUserMemberVoByUid(uid);
+        if (null != userMemberVoByUid) {
+            userMemberVoByUid.setState(2);
+            userMemberVoByUid.setUpdatedAt(now);
+
+            adamRdmService.setUserMemberVoByUid(uid, userMemberVoByUid);
+        }
         toMqSqls.add(SqlMapping.get("adam_user_member.close"));
-        objsThirdPart.add(new Object[]{now, uid});
+        objsUserMember.add(new Object[]{now, uid});
+
+        /* ---------------------- 用户实名信息 */
+        AdamRealInfoVo realInfoVoByUid = adamRdmService.getRealInfoVoByUid(uid);
+        if (null != realInfoVoByUid) {
+            realInfoVoByUid.setState(2);
+
+            adamRdmService.setRealInfoVoByUid(uid, realInfoVoByUid);
+        }
+        toMqSqls.add(SqlMapping.get("adam_real_name.close"));
+        objsRealInfo.add(new Object[]{now, uid});
 
         /* ---------------------- 收货地址信息 */
+        List<AdamAddressesVo> addressesVoByUid = adamRdmService.getAddressesVoByUid(uid);
+        if (!CollectionUtils.isEmpty(addressesVoByUid)) {
+            addressesVoByUid.forEach(r -> {
+                r.setState(2);
+                r.setUpdatedAt(now);
+                r.setDeletedAt(now);
+            });
+
+            adamRdmService.setAddressesVoByUid(uid, addressesVoByUid);
+        }
         toMqSqls.add(SqlMapping.get("adam_addresses.close"));
         objsAddresses.add(new Object[]{now, now, uid});
 
         /* ---------------------- 入场人信息 */
+        List<AdamEntersVo> entersVoByUid = adamRdmService.getEntersVoByUid(uid);
+        if (!CollectionUtils.isEmpty(entersVoByUid)) {
+            entersVoByUid.forEach(r -> {
+                r.setState(2);
+                r.setUpdatedAt(now);
+                r.setDeletedAt(now);
+            });
+
+            adamRdmService.setEntersVoByUid(uid, entersVoByUid);
+        }
         toMqSqls.add(SqlMapping.get("adam_enters.close"));
-        objsAddresses.add(new Object[]{now, now, uid});
+        objsEnters.add(new Object[]{now, now, uid});
 
         s = System.currentTimeMillis();
         queueUtils.sendMsgByRedis(
                 MQConst.AdamQueue.SQL_UCENTER.getKey(),
-                SqlMapping.gets(toMqSqls, objsUser)
+                SqlMapping.gets(toMqSqls, objsUser, objsThirdPart, objsUserMember, objsRealInfo, objsAddresses, objsEnters)
         );
         log.debug("#MQ耗时:{}ms", System.currentTimeMillis() - s);
     }

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/resources/sqlmap.properties

@@ -11,6 +11,7 @@ adam_user_info.update_by_member=UPDATE adam_user_info SET birthday=?, area=? WHE
 
 # ----------------------------------------------------
 adam_real_name.add=INSERT INTO adam_real_name (real_name_id, `uid`, `type`, `name`, id_card, `state`, created_at) VALUES (?,?,?,?,?,?,?) 
+adam_real_name.close=UPDATE adam_real_name SET `state`=2, updated_at=?, comment='close' WHERE `uid`=? 
 
 # ----------------------------------------------------
 adam_third_party.add=INSERT INTO adam_third_party (`uid`, open_id, avatar, nickname, platform, `state`, created_at) values (?,?,?,?,?,?,?)