Browse Source

提交定时任务为配置

chenxiaofei 3 weeks ago
parent
commit
22d3bbc194

+ 3 - 0
.gitignore

@@ -29,3 +29,6 @@ logs
 
 /sckw-modules/.yapix
 /sckw-modules/sckw-transport/openapi.yaml
+**/rebel.xml
+*.rebel.xml
+**/*.rebel.xml

+ 25 - 5
sckw-modules/sckw-system/src/main/java/com/sckw/system/service/SysDictFlexBusinessService.java

@@ -8,6 +8,7 @@ import com.sckw.core.model.base.BaseModel;
 import com.sckw.core.utils.IdWorker;
 import com.sckw.core.web.context.LoginUserHolder;
 import com.sckw.core.web.response.result.PageDataResult;
+import com.sckw.redis.utils.RedissonUtils;
 import com.sckw.system.model.SysDict;
 import com.sckw.system.model.SysDictType;
 import com.sckw.system.model.vo.req.SysDictReqVo;
@@ -70,7 +71,15 @@ public class SysDictFlexBusinessService {
         Long userId = LoginUserHolder.getUserId();
         long id = new IdWorker(1L).nextId();
         SysDict sysDict = getSysDict(entity, id, userId);
-        return sysDictRepository.save(sysDict) ;
+        Boolean result = sysDictRepository.save(sysDict);
+        
+        // 删除以"dictInfo:"开头的缓存
+        if (result) {
+            log.info("新增字典成功删除以\"dictInfo:\"开头的缓存");
+            RedissonUtils.deleteBactch("dictInfo:*");
+        }
+        
+        return result;
     }
 
     @NotNull
@@ -124,14 +133,20 @@ public class SysDictFlexBusinessService {
         sysDict.setLabel(entity.getLabel());
         sysDict.setType(entity.getType());
         sysDict.setDescription(entity.getDescription());
-        sysDict.setParentId(entity.getParentId());
+        sysDict.setParentId(StringUtils.isBlank(entity.getParentId()) ? "0" : entity.getParentId());
         sysDict.setId(existDict.getId());
         sysDict.setSort(entity.getSort());
         sysDict.setRemark(entity.getRemark());
         sysDict.setUpdateBy(userId);
         sysDict.setUpdateTime(new Date());
-        
-        return sysDictRepository.update(sysDict);
+
+        Boolean update = sysDictRepository.update(sysDict);
+        // 删除以"dictInfo:"开头的缓存
+        if (update) {
+            log.info("更新字典成功删除以\"dictInfo:\"开头的缓存");
+            RedissonUtils.deleteBactch("dictInfo:*");
+        }
+        return update;
     }
 
 
@@ -228,7 +243,12 @@ public class SysDictFlexBusinessService {
         }
         
         // 更新状态
-        return sysDictRepository.updateStatus(id, status);
+        Boolean update = sysDictRepository.updateStatus(id, status);
+        if (update) {
+            log.info("更新字典状态成功,删除缓存,字典id:{}", id);
+            RedissonUtils.deleteBactch("dictInfo:*");
+        }
+        return update;
     }
 
     /**