gfwleak/k18-ntcs-web-ntc
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

清空所有域以后引用组的定时任务删除

Browse Source
This commit is contained in:
wangxin
2019-06-19 11:13:41 +08:00
parent 46fd30e443
commit 5f7eb1ec43
3 changed files with 24 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/com/nis/web/dao/configuration/CommonPolicyDao.java
View File

@@ -51,4 +51,5 @@ public interface CommonPolicyDao {
List<ObjGroupCfg> getObjGroupList(@Param("ids")String ids);
List<ObjGroupCfg> getObjGroupPagedList(ObjGroupCfg entity);
void cancelScheduCfg(@Param("compileIds")String compileIds,@Param("tableName")String tableName);
}

5
src/main/java/com/nis/web/dao/configuration/CommonPolicyDao.xml
View File

@@ -1250,4 +1250,9 @@
</otherwise>
</choose>
</select>
<delete id="cancelScheduCfg" >
delete from schedule_cfg
where table_name= #{tableName}
and compile_id in(${compileIds})
</delete>
</mapper>

18
src/main/java/com/nis/web/service/BaseService.java
View File

@@ -3558,13 +3558,31 @@ public abstract class BaseService {
}
//需要更新的cfg_index_info数据库更新
if(toCancelCfgIndexInfos.size()>0){
StringBuffer ids=new StringBuffer();
for(CfgIndexInfo info:toCancelCfgIndexInfos){
commonPolicyDao.updateCfgIndexCommonGroupIds(info);
if(StringUtils.isBlank(info.getCommonGroupIds())){
ids.append(info.getCompileId()+",");
}
}
//查询定时任务，失效定时任务
if(ids.toString().length()>0){
ids.deleteCharAt(ids.toString().length()-1);
commonPolicyDao.cancelScheduCfg(ids.toString(),CfgIndexInfo.getTablename());
}
}
if(toUpdateCfgIndexInfos.size()>0){
StringBuffer ids=new StringBuffer();
for(CfgIndexInfo info:toUpdateCfgIndexInfos){
commonPolicyDao.updateCfgIndexCommonGroupIds(info);
if(StringUtils.isBlank(info.getCommonGroupIds())){
ids.append(info.getCompileId()+",");
}
}
//查询定时任务，失效定时任务
if(ids.toString().length()>0){
ids.deleteCharAt(ids.toString().length()-1);
commonPolicyDao.cancelScheduCfg(ids.toString(),CfgIndexInfo.getTablename());
}
}
//向maat发送配置