瀏覽代碼

优化缓存

zhouhao 7 年之前
父節點
當前提交
841673a9f4

+ 6 - 0
hsweb-system/hsweb-system-organizational/hsweb-system-organizational-service/hsweb-system-organizational-service-simple/src/main/java/org/hswebframework/web/service/organizational/simple/SimpleDepartmentService.java

@@ -96,6 +96,12 @@ public class SimpleDepartmentService
         return super.deleteByPk(id);
     }
 
+    @Override
+    public String insert(DepartmentEntity entity) {
+        publisher.publishEvent(new ClearPersonCacheEvent());
+        return super.insert(entity);
+    }
+
     @Override
     public int updateByPk(String id, DepartmentEntity entity) {
         publisher.publishEvent(new ClearPersonCacheEvent());

+ 1 - 0
hsweb-system/hsweb-system-organizational/hsweb-system-organizational-service/hsweb-system-organizational-service-simple/src/main/java/org/hswebframework/web/service/organizational/simple/SimpleDistrictService.java

@@ -58,6 +58,7 @@ public class SimpleDistrictService extends AbstractTreeSortService<DistrictEntit
     @Override
     @CacheEvict(allEntries = true)
     public String insert(DistrictEntity entity) {
+        publisher.publishEvent(new ClearPersonCacheEvent());
         return super.insert(entity);
     }
 

+ 1 - 1
hsweb-system/hsweb-system-organizational/hsweb-system-organizational-service/hsweb-system-organizational-service-simple/src/main/java/org/hswebframework/web/service/organizational/simple/SimplePersonService.java

@@ -139,7 +139,7 @@ public class SimplePersonService extends GenericEntityService<PersonEntity, Stri
     @TransactionalEventListener
     @CacheEvict(allEntries = true)
     public void handleClearCache(ClearPersonCacheEvent event) {
-        logger.debug("clear all user cache");
+        logger.debug("clear all person cache");
     }
 
     @Override

+ 5 - 1
hsweb-system/hsweb-system-organizational/hsweb-system-organizational-service/hsweb-system-organizational-service-simple/src/main/java/org/hswebframework/web/service/organizational/simple/SimplePositionService.java

@@ -72,5 +72,9 @@ public class SimplePositionService extends AbstractTreeSortService<PositionEntit
         return super.updateByPk(id, entity);
     }
 
-    
+    @Override
+    public String insert(PositionEntity entity) {
+        publisher.publishEvent(new ClearPersonCacheEvent());
+        return super.insert(entity);
+    }
 }

+ 23 - 0
hsweb-system/hsweb-system-organizational/hsweb-system-organizational-service/hsweb-system-organizational-service-simple/src/main/java/org/hswebframework/web/service/organizational/simple/SimpleRelationDefineService.java

@@ -6,9 +6,11 @@ import org.hswebframework.web.service.EnableCacheGenericEntityService;
 import org.hswebframework.web.service.GenericEntityService;
 import org.hswebframework.web.id.IDGenerator;
 import org.hswebframework.web.service.organizational.RelationDefineService;
+import org.hswebframework.web.service.organizational.event.ClearPersonCacheEvent;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cache.annotation.CacheConfig;
 import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 
 /**
@@ -23,6 +25,9 @@ public class SimpleRelationDefineService extends EnableCacheGenericEntityService
     @Autowired
     private RelationDefineDao relationDefineDao;
 
+    @Autowired
+    private ApplicationEventPublisher publisher;
+
     @Override
     protected IDGenerator<String> getIDGenerator() {
         return IDGenerator.MD5;
@@ -33,4 +38,22 @@ public class SimpleRelationDefineService extends EnableCacheGenericEntityService
         return relationDefineDao;
     }
 
+    @Override
+    public String insert(RelationDefineEntity entity) {
+        publisher.publishEvent(new ClearPersonCacheEvent());
+        return super.insert(entity);
+    }
+
+    @Override
+    public int deleteByPk(String pk) {
+        publisher.publishEvent(new ClearPersonCacheEvent());
+        return super.deleteByPk(pk);
+    }
+
+    @Override
+    public int updateByPk(String pk, RelationDefineEntity entity) {
+        publisher.publishEvent(new ClearPersonCacheEvent());
+        return super.updateByPk(pk, entity);
+    }
+
 }