新增定时 刷新冗余机构Path 定时任务

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/RemoteOrgService.java

@@ -215,4 +215,7 @@ public interface RemoteOrgService {
 
     @GetMapping("/dept/findDisableOrgAndClearData")
     AjaxResult findDisableOrgAndClearData();
+
+    @GetMapping("/export/refresh/redundancy/orgpath")
+    AjaxResult refreshRedundancyOrgPath();
 }

soc-api/soc-api-system/src/main/java/com/xunmei/system/api/factory/RemoteOrgFallbackFactory.java

@@ -232,6 +232,11 @@ public class RemoteOrgFallbackFactory implements FallbackFactory<RemoteOrgServic
             }
 
             @Override
+            public AjaxResult refreshRedundancyOrgPath() {
+                return null;
+            }
+
+            @Override
             public List<SysOrg> selectOrgByPathAndType(String path, Integer type, String source) {
                 return Collections.emptyList();
             }

soc-modules/soc-modules-job/src/main/java/com/xunmei/job/task/OrgTask.java

@@ -25,5 +25,10 @@ public class OrgTask {
         log.info("处理停用机构数据结束....,当前任务 id:{},当前时间:{},结果:{}", id, new Date(), JSON.toJSONString(result));
     }
 
+    public void refreshRedundancyOrgPath() {
+        log.info("开始处理 刷新冗余机构Path数据");
+        AjaxResult result = orgService.refreshRedundancyOrgPath();
+        log.info("刷新冗余机构Path 结束处理");
+    }
 
 }

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/controller/ExportSqlController.java

@@ -60,7 +60,16 @@ public class ExportSqlController {
 
     }
 
+    @GetMapping("/refresh/redundancy/orgpath")
+    public Object refreshRedundancyOrgPath(){
+        try {
+            Object o = exportSqlService.refreshRedundancyOrgPath();
+            return o;
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
 
+    }
 
 
 

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/mapper/ObjectMapper.java

@@ -2,6 +2,7 @@ package com.xunmei.system.mapper;
 
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Update;
 
 import java.util.LinkedHashMap;
 import java.util.List;
@@ -25,4 +26,7 @@ public interface ObjectMapper {
      */
     int updateData(@Param(value="sqlStr") String sqlStr);
 
+    int refreshRedundancyOrgPath();
+
+
 }

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/ExportSqlService.java

@@ -37,5 +37,6 @@ public interface ExportSqlService {
      */
     Object executeSql(String sql)throws Exception;
 
+    int refreshRedundancyOrgPath() throws  Exception;
 
 }

soc-modules/soc-modules-system/src/main/java/com/xunmei/system/service/impl/ExportSqlServiceImpl.java

@@ -90,6 +90,11 @@ public class ExportSqlServiceImpl implements ExportSqlService {
         return null;
     }
 
+    @Override
+    public int refreshRedundancyOrgPath() {
+        return objectMapper.refreshRedundancyOrgPath();
+    }
+
     /**
      * 导出数据
      * @param response

soc-modules/soc-modules-system/src/main/resources/mapper/system/ObjectMapper.xml

@@ -9,4 +9,50 @@
         ${sqlStr}
     </select>
 
+    <update id="refreshRedundancyOrgPath">
+        UPDATE core_announcement_notification  t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_compensate_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_drill_dictionary t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_drill_dictionary_branch t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_drill_task t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_edu_training_task t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_evaluate_plan t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_evaluate_task t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_introduce_letter t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_monitoring_retrieval_plan t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_monitoring_retrieval_task t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_question t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_register_book_pdf t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_resumption t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_safe_month_score t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_safety_deduct_data t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_safety_exception_data t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_safety_source_data t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE core_safety_task t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_alarm_defence_area t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_alarm_defence_area_alarm_data t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_alarm_defence_area_data t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_alarm_defence_area_data_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_alarm_subsystem t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_device t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_device_detection t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_device_detection_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_dvr_channel t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_dvr_disk t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_dvr_disk_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_dvr_hard_disk_detection t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_dvr_hard_disk_detection_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_sensor t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE iot_sensor_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE mediator_video_days_check t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE mediator_video_days_check_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE mediator_video_diagnosis_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE mediator_video_diagnosis_record t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE mediator_video_integrity_check t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE mediator_video_integrity_check_log t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE sys_area_check t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE sys_device t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+        UPDATE sys_learning_materials t INNER JOIN sys_org o ON t.org_id = o.id  set t.org_path =o.path WHERE t.org_path != o.path AND  t.org_path is not null;
+</update>
+
 </mapper>