Ver Fonte

修改定时任务

sss há 3 anos atrás
pai
commit
ad9e205815

+ 1 - 1
eladmin-system/src/main/java/me/zhengjie/modules/quartz/task/ZkDataSyncTask.java

@@ -156,7 +156,7 @@ public class ZkDataSyncTask {
                     if (deptDto != null) {
                         deptService.update(dept);
                     } else {
-                        deptService.create(dept);
+                        deptService.syncCreate(dept);
                     }
                 } catch (Exception ex) {
                     System.out.println(JSONObject.toJSON(dept));

+ 6 - 0
eladmin-system/src/main/java/me/zhengjie/modules/system/service/DeptService.java

@@ -80,6 +80,12 @@ public interface DeptService {
      */
     void create(Dept resources);
 
+    /**
+     * 创建
+     * @param resources /
+     */
+    void syncCreate(Dept resources);
+
     /**
      * 编辑
      * @param resources /

+ 10 - 0
eladmin-system/src/main/java/me/zhengjie/modules/system/service/impl/DeptServiceImpl.java

@@ -176,6 +176,16 @@ public class DeptServiceImpl implements DeptService {
         updateSubCnt(resources.getPid());
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void syncCreate(Dept resources) {
+        deptRepository.save(resources);
+        // 计算子节点数目
+        resources.setSubCount(0);
+        // 清理缓存
+        updateSubCnt(resources.getPid());
+    }
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void update(Dept resources) {