手机号注销接口 未验证

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/A_fskfsfs/AdamController.java

@@ -6,11 +6,13 @@ import com.fasterxml.jackson.databind.JsonNode;
 import com.liquidnet.common.cache.redis.util.AbstractRedisUtil;
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.common.exception.LiquidnetServiceException;
+import com.liquidnet.commons.lang.core.JwtValidator;
 import com.liquidnet.commons.lang.util.IdentityUtils;
 import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.adam.constant.AdamRedisConst;
 import com.liquidnet.service.adam.dto.AdamEntersParam;
 import com.liquidnet.service.adam.dto.vo.AdamEntersVo;
+import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
 import com.liquidnet.service.adam.entity.AdamEnters;
 import com.liquidnet.service.adam.entity.AdamUser;
 import com.liquidnet.service.adam.mapper.AdamEntersMapper;
@@ -31,10 +33,7 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.time.LocalDateTime;
 import java.util.ArrayList;
@@ -66,6 +65,8 @@ public class AdamController {
     private RedisDataSourceUtil redisDataSourceUtil;
     @Autowired
     QueueUtils queueUtils;
+    @Autowired
+    JwtValidator jwtValidator;
 
     @GetMapping("A001")
     @ApiOperation("用户改名 修改入场人信息")
@@ -159,11 +160,40 @@ public class AdamController {
             @RequestParam("phone") String phone,
             @RequestParam("day") Integer day
     ) {
-        Integer time= day*60*60*24;
+        Integer time = day * 60 * 60 * 24;
         String smsCode = RandomStringUtils.randomNumeric(6);
-        redisDataSourceUtil.getRedisAdamUtil().set(AdamRedisConst.VALID_SMS_CODE_MOBILE + phone, smsCode,time);
+        redisDataSourceUtil.getRedisAdamUtil().set(AdamRedisConst.VALID_SMS_CODE_MOBILE + phone, smsCode, time);
         return ResponseDto.success(smsCode);
     }
+
+    @PostMapping("A004")
+    @ApiOperation("手机号注销账户(未验证版本)")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "query", dataType = "String", name = "mobile", value = "账户手机号", required = true),
+    })
+    public ResponseDto<Object> A004(
+            @RequestParam("mobile") String mobile
+    ) {
+        // 退出登陆
+        String key = AdamRedisConst.IDENTITY_MOBILE.concat(mobile);
+        String uid = (String) redisDataSourceUtil.getRedisAdamUtil().get(key);
+        redisDataSourceUtil.getRedisAdamUtil().del(jwtValidator.getSsoRedisKey().concat(uid));
+        // 更改状态
+        LocalDateTime now = LocalDateTime.now();
+        String rk = AdamRedisConst.INFO_USER.concat(uid);
+        AdamUserInfoVo vo = (AdamUserInfoVo) redisDataSourceUtil.getRedisAdamUtil().get(rk);
+        vo.setState(2);
+        vo.setUpdatedAt(now);
+        vo.setClosedAt(now);
+        redisDataSourceUtil.getRedisAdamUtil().set(rk, vo);
+        queueUtils.sendMsgByRedis(
+                MQConst.AdamQueue.SQL_UCENTER.getKey(),
+                SqlMapping.get("adam_user.close", now, now, uid)
+        );
+
+        return ResponseDto.success();
+    }
+
     /**
      * 身份证实名处理
      *