| 
					
				 | 
			
			
				@@ -1,23 +1,20 @@ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 package com.xunmei.core.access.service.impl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import cn.hutool.core.util.ObjectUtil; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.alibaba.nacos.common.utils.CollectionUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.baomidou.mybatisplus.core.toolkit.IdWorker; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.baomidou.mybatisplus.extension.plugins.pagination.Page; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.xunmei.common.core.constant.ErrorMsgConstants; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.common.core.constant.SecurityConstants; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.xunmei.common.core.domain.edu.domain.CoreEduTrainingPlan; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.xunmei.common.core.domain.edu.vo.CoreEduTrainingPlanPageVo; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.xunmei.common.core.domain.edu.vo.CoreEduTrainingPlanRoleVo; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.common.core.domain.retrieval.domain.CoreMonitoringRetrievalTask; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.common.core.exception.ServiceException; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.common.core.util.BeanHelper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.common.core.utils.DateUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.common.core.utils.StringUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.xunmei.common.core.vo.IdNameVo; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.common.core.web.page.TableDataInfo; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.common.security.utils.SecurityUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.core.access.domain.TMonitoringRetrievalPlan; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -25,14 +22,14 @@ import com.xunmei.core.access.mapper.TMonitoringRetrievalPlanMapper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.core.access.service.ITMonitoringRetrievalPlanService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.core.access.vo.TMonitoringRetrievalPlanVO; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.core.retrieval.service.ICoreMonitoringRetrievalTaskService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.xunmei.system.api.Eto.RoleConditionEto; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.system.api.RemoteOrgService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.system.api.RemoteRoleService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.system.api.RemoteUserService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.system.api.domain.SysOrg; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.system.api.domain.SysRole; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.xunmei.system.api.domain.SysUser; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.xunmei.system.api.function.RemoteCallHandlerExecutor; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.beans.factory.annotation.Autowired; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.context.annotation.Lazy; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.stereotype.Service; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -40,7 +37,7 @@ import org.springframework.stereotype.Service; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import javax.annotation.Resource; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import java.util.ArrayList; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import java.util.List; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import java.util.Map; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import java.util.stream.Collectors; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -55,6 +52,7 @@ import java.util.stream.Collectors; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoringRetrievalPlanMapper, TMonitoringRetrievalPlan> implements ITMonitoringRetrievalPlanService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     private static final Integer MINUS_ONE = -1; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     private static final Integer ZERO = 0; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    private static final String PARENT_ID="parent_id"; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     @Autowired 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     private TMonitoringRetrievalPlanMapper tMonitoringRetrievalPlanMapper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     @Autowired 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -94,7 +92,7 @@ public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoring 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         if (Boolean.TRUE.equals(checkSub)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             SysOrg sysOrg = remoteOrgService.selectSysOrgById(tMonitoringRetrievalPlan.getOrgId(), SecurityConstants.INNER); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             tMonitoringRetrievalPlan.setOrgId(null); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            query.lambda().likeRight(TMonitoringRetrievalPlan::getOrgPath,sysOrg.getPath()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            query.lambda().likeRight(TMonitoringRetrievalPlan::getOrgPath, sysOrg.getPath()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         if (StringUtils.isNotEmpty(planName)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             query.like("plan_name", planName); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -105,13 +103,12 @@ public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoring 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         query.orderByDesc("create_time"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         //获取数据 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        query.eq("create_type", 0); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        query.isNull(PARENT_ID); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         page = tMonitoringRetrievalPlanMapper.selectPage(page, query); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        SysOrg sysOrg = RemoteCallHandlerExecutor.executeRemoteCall(() -> orgService.selectTopOrg(SecurityConstants.INNER), ErrorMsgConstants.QUERY_ORG_DATA_ERROR); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         List<TMonitoringRetrievalPlan> records = page.getRecords(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         List<TMonitoringRetrievalPlanVO> tMonitoringRetrievalPlanVOS = BeanHelper.copyProperties(records, TMonitoringRetrievalPlanVO.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         for (TMonitoringRetrievalPlanVO monitoringRetrievalPlan : tMonitoringRetrievalPlanVOS) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            dealData(monitoringRetrievalPlan, tMonitoringRetrievalPlanVOS, sysOrg.getId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            dealData(monitoringRetrievalPlan, tMonitoringRetrievalPlanVOS); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         //抓换为TableDataInfo适配前端 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         TableDataInfo<TMonitoringRetrievalPlanVO> tableDataInfo = new TableDataInfo(); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -122,7 +119,7 @@ public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoring 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         return tableDataInfo; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    private void dealData(TMonitoringRetrievalPlanVO record, List<TMonitoringRetrievalPlanVO> records, Long orgId) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    private void dealData(TMonitoringRetrievalPlanVO record, List<TMonitoringRetrievalPlanVO> records) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         record.setNo(records.indexOf(record) + 1); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         List<TMonitoringRetrievalPlan> tMonitoringRetrievalPlans = tMonitoringRetrievalPlanMapper.selectList(new LambdaQueryWrapper<TMonitoringRetrievalPlan>().eq(TMonitoringRetrievalPlan::getParentId, record.getId())); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         List<TMonitoringRetrievalPlanVO> children = BeanHelper.copyProperties(tMonitoringRetrievalPlans, TMonitoringRetrievalPlanVO.class); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -144,9 +141,15 @@ public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoring 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public int distribute(Long id) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         //查询 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         TMonitoringRetrievalPlan tMonitoringRetrievalPlan = tMonitoringRetrievalPlanMapper.selectById(id); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (tMonitoringRetrievalPlan.getPlanStatus()==1){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        if (tMonitoringRetrievalPlan.getPlanStatus() == 1) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             throw new ServiceException("禁用中,不能下发"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        QueryWrapper queryWrapper = new QueryWrapper(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        queryWrapper.eq(PARENT_ID, id); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        List list1 = tMonitoringRetrievalPlanMapper.selectList(queryWrapper); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        if (CollectionUtils.isNotEmpty(list1)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            throw new ServiceException("请勿重复下发"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         List<SysOrg> list = remoteOrgService.selectSysOrgByParentId(tMonitoringRetrievalPlan.getOrgId(), SecurityConstants.INNER); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         Integer i = ZERO; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         List<TMonitoringRetrievalPlan> tMonitoringRetrievalPlans = new ArrayList<>(); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -216,10 +219,10 @@ public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoring 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         tMonitoringRetrievalPlan.setId(id); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         tMonitoringRetrievalPlan.setOrgPath(data.getPath()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         if (tMonitoringRetrievalPlan.getOrgType().equals("1")) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            tMonitoringRetrievalPlan.setPlanStatus(1); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             tMonitoringRetrievalPlan.setCreateType(ZERO); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            tMonitoringRetrievalPlan.setPlanStatus(ZERO); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             tMonitoringRetrievalPlan.setCreateType(1); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             //无周期调用 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             if (tMonitoringRetrievalPlan.getPlanCycle().equals(ZERO.toString())) { 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -241,6 +244,11 @@ public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoring 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public int updateTMonitoringRetrievalPlan(TMonitoringRetrievalPlan tMonitoringRetrievalPlan) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         tMonitoringRetrievalPlan.setUpdateTime(DateUtils.getNowDate()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         tMonitoringRetrievalPlan.setUpdateBy(SecurityUtils.getUsername()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        if (tMonitoringRetrievalPlan.getOrgType().equals("1")) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            tMonitoringRetrievalPlan.setCreateType(ZERO); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        }else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            tMonitoringRetrievalPlan.setCreateType(1); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         return tMonitoringRetrievalPlanMapper.updateById(tMonitoringRetrievalPlan); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -265,7 +273,7 @@ public class TMonitoringRetrievalPlanServiceImpl extends ServiceImpl<TMonitoring 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             } else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 if (monitoringRetrievalPlan.getCreateType() == 0) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     QueryWrapper queryWrapper = new QueryWrapper(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                    queryWrapper.eq("parent_id", monitoringRetrievalPlan.getId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+                    queryWrapper.eq(PARENT_ID, monitoringRetrievalPlan.getId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     List<TMonitoringRetrievalPlan> list = tMonitoringRetrievalPlanMapper.selectList(queryWrapper); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     list.add(monitoringRetrievalPlan); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     for (TMonitoringRetrievalPlan p : list) { 
			 |