添加imClient的redis缓存;

添加apns的redis缓存;

common/src/main/java/com/wecloud/im/controller/ImClientController.java

@@ -52,7 +52,7 @@ public class ImClientController extends BaseController {
     @PostMapping("/addDeviceInfo")
     @PostMapping("/addDeviceInfo")
     @ApiOperation(value = "添加或修改推送设备信息(每次请求都会覆盖之前的数据)")
     @ApiOperation(value = "添加或修改推送设备信息(每次请求都会覆盖之前的数据)")
     public ApiResult<Boolean> addDeviceInfo(@Validated(Add.class) @RequestBody ImClientDeviceInfoAdd imClientDevice) throws Exception {
     public ApiResult<Boolean> addDeviceInfo(@Validated(Add.class) @RequestBody ImClientDeviceInfoAdd imClientDevice) throws Exception {
-        boolean flag = imClientService.addDeviceInfo(imClientDevice);
+        boolean flag = imClientService.updateDeviceInfo(imClientDevice);
         return ApiResult.result(flag);
         return ApiResult.result(flag);
     }
     }
 
 

common/src/main/java/com/wecloud/im/service/ImClientService.java

@@ -30,7 +30,7 @@ public interface ImClientService extends BaseService<ImClient> {
      * @param imClientDevice
      * @param imClientDevice
      * @return
      * @return
      */
      */
-    boolean addDeviceInfo(ImClientDeviceInfoAdd imClientDevice);
+    boolean updateDeviceInfo(ImClientDeviceInfoAdd imClientDevice);
 
 
     /**
     /**
      * 修改
      * 修改
@@ -76,4 +76,8 @@ public interface ImClientService extends BaseService<ImClient> {
      */
      */
     ImClient getCurentClient();
     ImClient getCurentClient();
 
 
+    ImClient getCacheImClient(Long applicationId, String clientId);
+
+    void deleteCacheImClient(Long applicationId, String clientId);
+
 }
 }

common/src/main/java/com/wecloud/im/service/impl/ImClientServiceImpl.java

@@ -20,6 +20,9 @@ import io.geekidea.springbootplus.framework.shiro.util.JwtUtil;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.CacheConfig;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.annotation.Transactional;
 
 
@@ -31,6 +34,7 @@ import org.springframework.transaction.annotation.Transactional;
  */
  */
 @Slf4j
 @Slf4j
 @Service
 @Service
+@CacheConfig(cacheNames = "client")
 public class ImClientServiceImpl extends BaseServiceImpl<ImClientMapper, ImClient> implements ImClientService {
 public class ImClientServiceImpl extends BaseServiceImpl<ImClientMapper, ImClient> implements ImClientService {
 
 
     @Autowired
     @Autowired
@@ -46,18 +50,22 @@ public class ImClientServiceImpl extends BaseServiceImpl<ImClientMapper, ImClien
 
 
     @Override
     @Override
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
-    public boolean addDeviceInfo(ImClientDeviceInfoAdd imClientDevice) {
+    public boolean updateDeviceInfo(ImClientDeviceInfoAdd imClientDevice) {
         ImClient client = getCurentClient();
         ImClient client = getCurentClient();
-
         ImClient clientNew = new ImClient();
         ImClient clientNew = new ImClient();
         BeanUtils.copyProperties(imClientDevice, clientNew);
         BeanUtils.copyProperties(imClientDevice, clientNew);
         clientNew.setId(client.getId());
         clientNew.setId(client.getId());
-        return this.saveOrUpdate(clientNew);
+
+        // 清楚缓存
+        deleteCacheImClient(client.getFkAppid(), client.getClientId());
+
+        // 修改
+        return this.updateImClient(clientNew);
     }
     }
 
 
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     @Override
     @Override
-    public boolean updateImClient(ImClient imClient) throws Exception {
+    public boolean updateImClient(ImClient imClient) {
         return super.updateById(imClient);
         return super.updateById(imClient);
     }
     }
 
 
@@ -76,7 +84,7 @@ public class ImClientServiceImpl extends BaseServiceImpl<ImClientMapper, ImClien
     public Paging<ImClientQueryVo> getImClientPageList(ImClientPageParam imClientPageParam) throws Exception {
     public Paging<ImClientQueryVo> getImClientPageList(ImClientPageParam imClientPageParam) throws Exception {
         Page<ImClientQueryVo> page = new PageInfo<>(imClientPageParam, OrderItem.desc(getLambdaColumn(ImClient::getCreateTime)));
         Page<ImClientQueryVo> page = new PageInfo<>(imClientPageParam, OrderItem.desc(getLambdaColumn(ImClient::getCreateTime)));
         IPage<ImClientQueryVo> iPage = imClientMapper.getImClientPageList(page, imClientPageParam);
         IPage<ImClientQueryVo> iPage = imClientMapper.getImClientPageList(page, imClientPageParam);
-        return new Paging<ImClientQueryVo>(iPage);
+        return new Paging<>(iPage);
     }
     }
 
 
     @Override
     @Override
@@ -84,13 +92,22 @@ public class ImClientServiceImpl extends BaseServiceImpl<ImClientMapper, ImClien
 
 
         // shiro线程中获取当前token
         // shiro线程中获取当前token
         JwtToken curentJwtToken = JwtUtil.getCurentJwtToken();
         JwtToken curentJwtToken = JwtUtil.getCurentJwtToken();
-
         //  根据appKey查询appid
         //  根据appKey查询appid
         ImApplication imApplication = imApplicationService.getOneByAppKey(curentJwtToken.getAppKey());
         ImApplication imApplication = imApplicationService.getOneByAppKey(curentJwtToken.getAppKey());
+        return getCacheImClient(imApplication.getId(), curentJwtToken.getClientId());
+    }
 
 
+    @Override
+    @Cacheable(key = "#p0+#p1")
+    public ImClient getCacheImClient(Long applicationId, String clientId) {
         return this.getOne(new QueryWrapper<ImClient>().lambda()
         return this.getOne(new QueryWrapper<ImClient>().lambda()
-                .eq(ImClient::getFkAppid, imApplication.getId())
-                .eq(ImClient::getClientId, curentJwtToken.getClientId()));
+                .eq(ImClient::getFkAppid, applicationId)
+                .eq(ImClient::getClientId, clientId));
+    }
+
+    @Override
+    @CacheEvict(key = "#p0+#p1")
+    public void deleteCacheImClient(Long applicationId, String clientId) {
     }
     }
 
 
 }
 }