更新缓存

web/src/main/java/com/ibeetl/jlw/service/TeacherOpenCourseMergeCourseInfoService.java

@@ -23,6 +23,7 @@ import com.ibeetl.jlw.entity.*;
 import com.ibeetl.jlw.web.query.ResourcesInfoQuery;
 import com.ibeetl.jlw.web.query.ResourcesQuestionQuery;
 import com.ibeetl.jlw.web.query.TeacherOpenCourseMergeCourseInfoQuery;
+import lombok.SneakyThrows;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.poi.hssf.usermodel.HSSFWorkbook;
 import org.apache.poi.ss.usermodel.Row;
@@ -32,10 +33,12 @@ import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.beetl.sql.core.SqlId;
 import org.beetl.sql.core.engine.PageQuery;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
 
+import javax.validation.constraints.NotBlank;
 import javax.validation.constraints.NotEmpty;
 import javax.validation.constraints.NotNull;
 import java.io.*;
@@ -73,6 +76,8 @@ public class TeacherOpenCourseMergeCourseInfoService extends CoreBaseService<Tea
     private ResourcesInfoService resourcesInfoService;
     @Autowired
     private ResourcesQuestionService resourcesQuestionService;
+    @Autowired
+    private TeacherOpenCourseMergeCourseInfoService teacherOpenCourseMergeCourseInfoService;
 
     //树结构缓存
 
@@ -102,6 +107,25 @@ public class TeacherOpenCourseMergeCourseInfoService extends CoreBaseService<Tea
         return ret;
     }
 
+    /**
+     * 指定Key刷新缓存
+     * 异步刷新。不影响正常业务逻辑
+     *
+     * @param key
+     */
+    @Async
+    @SneakyThrows
+     public void refreshCourseInfoTreeLocalCache(Long key) {
+        treeLocalCache.refresh(key);
+    }
+    /**
+     * 清理刷新缓存
+     */
+    @SneakyThrows
+     public void cleanUpCourseInfoTreeLocalCache() {
+        treeLocalCache.cleanUp();
+    }
+
     public void deleteByList(List list){
         String ids = "";
         ToolUtils.deleteNullList(list);
@@ -110,12 +134,19 @@ public class TeacherOpenCourseMergeCourseInfoService extends CoreBaseService<Tea
         }
         if(StringUtils.isNotBlank(ids)){
             teacherOpenCourseMergeCourseInfoDao.deleteTeacherOpenCourseMergeCourseInfoByIds(ids);
+
+            for (String id : ids.split(",")) {
+                teacherOpenCourseMergeCourseInfoService.refreshCourseInfoTreeLocalCache(Long.valueOf(id));
+            }
         }
     }
 
-    public void deleteTeacherOpenCourseMergeCourseInfo(String ids){
+    public void deleteTeacherOpenCourseMergeCourseInfo(@NotBlank(message = "ID不能为空！") String ids){
         try {
             teacherOpenCourseMergeCourseInfoDao.deleteTeacherOpenCourseMergeCourseInfoByIds(ids);
+            for (String id : ids.split(",")) {
+                teacherOpenCourseMergeCourseInfoService.refreshCourseInfoTreeLocalCache(Long.valueOf(id));
+            }
         } catch (Exception e) {
             throw new PlatformException("批量删除开课课程拉取失败", e);
         }
@@ -139,6 +170,11 @@ public class TeacherOpenCourseMergeCourseInfoService extends CoreBaseService<Tea
                 teacherOpenCourseMergeCourseInfo.setOrgId(teacherOpenCourseMergeCourseInfoQuery.getOrgId());
             }
             insertBatch(teacherOpenCourseMergeCourseInfoList);
+
+            // 循环刷新缓存
+            for (TeacherOpenCourseMergeCourseInfo openCourseMergeCourseInfo : teacherOpenCourseMergeCourseInfoList) {
+                teacherOpenCourseMergeCourseInfoService.refreshCourseInfoTreeLocalCache(openCourseMergeCourseInfo.getTeacherOpenCourseMergeCourseInfoId());
+            }
         }
         return msg;
     }
@@ -147,6 +183,8 @@ public class TeacherOpenCourseMergeCourseInfoService extends CoreBaseService<Tea
         String msg = "";
         TeacherOpenCourseMergeCourseInfo teacherOpenCourseMergeCourseInfo = teacherOpenCourseMergeCourseInfoQuery.pojo();
         teacherOpenCourseMergeCourseInfoDao.insert(teacherOpenCourseMergeCourseInfo);
+
+        teacherOpenCourseMergeCourseInfoService.refreshCourseInfoTreeLocalCache(teacherOpenCourseMergeCourseInfo.getTeacherOpenCourseMergeCourseInfoId());
         teacherOpenCourseMergeCourseInfoQuery.setTeacherOpenCourseMergeCourseInfoId(teacherOpenCourseMergeCourseInfo.getTeacherOpenCourseMergeCourseInfoId());
         JsonResult jsonResult = new JsonResult();
         jsonResult.setData(teacherOpenCourseMergeCourseInfo.getTeacherOpenCourseMergeCourseInfoId());//自增的ID丢进去
@@ -159,6 +197,8 @@ public class TeacherOpenCourseMergeCourseInfoService extends CoreBaseService<Tea
         String msg = "";
         TeacherOpenCourseMergeCourseInfo teacherOpenCourseMergeCourseInfo = teacherOpenCourseMergeCourseInfoQuery.pojo();
         teacherOpenCourseMergeCourseInfoDao.updateTemplateById(teacherOpenCourseMergeCourseInfo);
+        teacherOpenCourseMergeCourseInfoService.refreshCourseInfoTreeLocalCache(teacherOpenCourseMergeCourseInfo.getTeacherOpenCourseMergeCourseInfoId());
+
         return msg;
     }
 

web/src/main/java/com/ibeetl/jlw/service/TeacherOpenCourseMergeResourcesInfoService.java

@@ -51,6 +51,8 @@ public class TeacherOpenCourseMergeResourcesInfoService extends CoreBaseService<
     @Autowired private TeacherOpenCourseMergeResourcesInfoDao teacherOpenCourseMergeResourcesInfoDao;
     @Autowired
     private ResourcesInfoService resourcesInfoService;
+    @Autowired
+    private TeacherOpenCourseMergeCourseInfoService teacherOpenCourseMergeCourseInfoService;
 
     public PageQuery<TeacherOpenCourseMergeResourcesInfo>queryByCondition(PageQuery query){
         PageQuery ret =  teacherOpenCourseMergeResourcesInfoDao.queryByCondition(query);
@@ -114,6 +116,9 @@ public class TeacherOpenCourseMergeResourcesInfoService extends CoreBaseService<
         jsonResult.setData(teacherOpenCourseMergeResourcesInfo.getTeacherOpenCourseMergeResourcesInfoId());//自增的ID丢进去
         jsonResult.setCode(JsonReturnCode.SUCCESS.getCode());
         jsonResult.setMsg(msg);
+
+        // 刷新缓存
+        teacherOpenCourseMergeCourseInfoService.refreshCourseInfoTreeLocalCache(teacherOpenCourseMergeResourcesInfo.getTeacherOpenCourseMergeCourseInfoId());
         return jsonResult;
     }
 
@@ -121,6 +126,9 @@ public class TeacherOpenCourseMergeResourcesInfoService extends CoreBaseService<
         String msg = "";
         TeacherOpenCourseMergeResourcesInfo teacherOpenCourseMergeResourcesInfo = teacherOpenCourseMergeResourcesInfoQuery.pojo();
         teacherOpenCourseMergeResourcesInfoDao.updateTemplateById(teacherOpenCourseMergeResourcesInfo);
+
+        // 刷新缓存
+        teacherOpenCourseMergeCourseInfoService.refreshCourseInfoTreeLocalCache(teacherOpenCourseMergeResourcesInfo.getTeacherOpenCourseMergeCourseInfoId());
         return msg;
     }