删除关注临时

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/controller/syncRedis/UserDataController.java

@@ -92,4 +92,31 @@ public class UserDataController {
         }
     }
 
+    @GetMapping("userOpenIdDel")
+    @ApiOperation("以openid删除用户")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "query", dataType = "String", name = "openId", value = "openId", required = true),
+            @ApiImplicitParam(type = "query", dataType = "Integer", name = "type", value = "type 1正在 2摩登", required = true)
+    })
+    public void userOpenIdDel(@RequestParam() String openId, @RequestParam() Integer type) {
+        try {
+            userDataService.userOpenIdDel(openId, type);
+        } catch (Exception e) {
+            log.error("userOpenIdDel", e);
+        }
+    }
+
+    @GetMapping("userPhoneDel")
+    @ApiOperation("以phone删除用户")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "query", dataType = "String", name = "phone", value = "phone", required = true)
+    })
+    public void userPhoneDel(@RequestParam() String phone) {
+        try {
+            userDataService.userPhoneDel(phone);
+        } catch (Exception e) {
+            log.error("userPhoneDel", e);
+        }
+    }
+
 }

liquidnet-bus-service/liquidnet-service-sweet/src/main/java/com/liquidnet/service/sweet/service/impl/syncRedis/UserDataServiceImpl.java

 package com.liquidnet.service.sweet.service.impl.syncRedis;
 
+import com.liquidnet.common.cache.redis.util.RedisUtil;
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.sweet.config.WechatMpConfigure;
+import com.liquidnet.service.sweet.constant.SweetConstant;
 import com.liquidnet.service.sweet.mapper.SweetWechatUsersMapper;
 import com.liquidnet.service.sweet.utils.QueueUtils;
 import com.liquidnet.service.sweet.utils.WechatUsersRedisUtils;
@@ -30,6 +32,8 @@ public class UserDataServiceImpl {
     @Autowired
     private WechatUsersRedisUtils redisUtils;
     @Autowired
+    private RedisUtil redisUtil;
+    @Autowired
     private QueueUtils queueUtils;
 
     @Autowired
@@ -230,4 +234,16 @@ public class UserDataServiceImpl {
         }
     }*/
 
+    public void userOpenIdDel(String openId, Integer type) {
+        SweetWechatUsersVo sweetWechatUsers = redisUtils.getSweetWechatUsersOfOpenId(openId, type);
+        redisUtils.delSweetWechatUsers(sweetWechatUsers.getUnionId(), openId, type);
+    }
+    public void userPhoneDel(String phone) {
+        String redisKey1 = SweetConstant.REDIS_KEY_SWEET_APPLET_USERS_PHONE.concat(phone);
+        SweetWechatUsersVo sweetWechatUsersVo = (SweetWechatUsersVo) redisUtil.get(redisKey1);
+        redisUtil.del(redisKey1);
+        String redisKey2 = SweetConstant.REDIS_KEY_SWEET_APPLET_USERS_UNIONID.concat(sweetWechatUsersVo.getUnionId());
+        redisUtil.del(redisKey2);
+    }
+
 }