668 lines
32 KiB
Java
668 lines
32 KiB
Java
package com.nis.web.service.configuration;
|
||
|
||
import com.nis.domain.FunctionRegionDict;
|
||
import com.nis.domain.FunctionServiceDict;
|
||
import com.nis.domain.Page;
|
||
import com.nis.domain.basics.*;
|
||
import com.nis.domain.configuration.*;
|
||
import com.nis.domain.maat.MaatCfg;
|
||
import com.nis.domain.maat.ToMaatBean;
|
||
import com.nis.domain.maat.ToMaatResult;
|
||
import com.nis.exceptions.MaatConvertException;
|
||
import com.nis.util.*;
|
||
import com.nis.web.dao.basics.*;
|
||
import com.nis.web.dao.configuration.AreaIpCfgDao;
|
||
import com.nis.web.dao.configuration.CommonPolicyDao;
|
||
import com.nis.web.dao.configuration.ObjectGroupDao;
|
||
import com.nis.web.security.UserUtils;
|
||
import com.nis.web.service.BaseService;
|
||
import net.sf.json.JSONObject;
|
||
import org.apache.commons.collections.CollectionUtils;
|
||
import org.apache.commons.collections.MapUtils;
|
||
import org.apache.commons.lang.StringEscapeUtils;
|
||
import org.apache.commons.lang3.StringUtils;
|
||
import org.springframework.beans.BeanUtils;
|
||
import org.springframework.beans.factory.annotation.Autowired;
|
||
import org.springframework.stereotype.Service;
|
||
import org.springframework.transaction.annotation.Transactional;
|
||
|
||
import java.util.*;
|
||
|
||
@Service
|
||
public class ObjectGroupService extends BaseService {
|
||
@Autowired
|
||
private ObjectGroupDao objectGroupDao;
|
||
@Autowired
|
||
private CommonPolicyDao commonPolicyDao;
|
||
@Autowired
|
||
private AreaIpCfgDao areaIpCfgDao;
|
||
@Autowired
|
||
private PolicyGroupInfoDao policyGroupInfoDao;
|
||
@Autowired
|
||
private IpCommGroupCfgDao ipCommGroupCfgDao;
|
||
@Autowired
|
||
private UrlCommGroupDao urlCommGroupCfgDao;
|
||
@Autowired
|
||
private ScriberIdCommGroupDao scriberIdCommGroupDao;
|
||
@Autowired
|
||
private DomainCommGroupDao domainCommGroupDao;
|
||
public Page getPolicyListList(Page searchPage, CfgIndexInfo searchCfg) {
|
||
// 生成数据权限过滤条件（dsf为dataScopeFilter的简写，在xml中使用 ${sqlMap.dsf}调用权限SQL）
|
||
searchCfg.getSqlMap().put("dsf", configScopeFilter(searchCfg.getCurrentUser(),"a"));
|
||
searchCfg.setPage(searchPage);
|
||
List<CfgIndexInfo> list = commonPolicyDao.getPolicyList(searchCfg);
|
||
for(CfgIndexInfo c:list){
|
||
if(StringUtils.isNotBlank(c.getCommonGroupIds())){
|
||
c.setUserRegion(this.gsonFromJson(c.getCommonGroupIds(),Map.class));
|
||
}
|
||
}
|
||
searchPage.setList(list);
|
||
return searchPage;
|
||
}
|
||
public CfgIndexInfo getObjectGroupCfg(Long cfgId,Integer compileId) {
|
||
CfgIndexInfo cfg=objectGroupDao.getObjectGroupConfig(cfgId,compileId);
|
||
//去除首尾括号
|
||
if(StringUtils.isNotBlank(cfg.getCommonGroupIds())){
|
||
Map<String,Object> userRegionMap=gsonFromJson(cfg.getCommonGroupIds(),Map.class);
|
||
for(Map.Entry<String,Object> e:userRegionMap.entrySet()){
|
||
String value=(String)e.getValue();
|
||
if(value.startsWith(",")){
|
||
value=value.substring(1);
|
||
}
|
||
if(value.endsWith(",")){
|
||
value=value.substring(0,value.length()-1);
|
||
}
|
||
userRegionMap.put(e.getKey(),value);
|
||
}
|
||
cfg.setUserRegion(userRegionMap);
|
||
}
|
||
return cfg;
|
||
}
|
||
|
||
public void saveOrUpdate(CfgIndexInfo entity) {
|
||
String protocolType=entity.getUserRegion1();
|
||
//获取旧的ID，用于更新时恢复policyGroupInfo的可选状态
|
||
String oldCommonGroupIds= StringEscapeUtils.unescapeHtml(entity.getCommonGroupIds());
|
||
//设置区域运营商信息
|
||
setAreaEffectiveIds(entity);
|
||
|
||
int isValid=0;
|
||
if(!StringUtil.isEmpty(entity.getIsValid()) && entity.getIsValid()==1) {
|
||
isValid=1;
|
||
}
|
||
entity.setIsValid(0);
|
||
entity.setIsAudit(0);
|
||
//设置service_id
|
||
if("HTTP".equalsIgnoreCase(protocolType)){
|
||
|
||
}else if("HTTPS".equalsIgnoreCase(protocolType)){
|
||
if(entity.getAction().equals(1)){
|
||
entity.setServiceId(592);
|
||
}else if(entity.getAction().equals(16)){
|
||
entity.setServiceId(576);
|
||
}
|
||
}else if("INTERCEPT".equalsIgnoreCase(protocolType)){
|
||
entity.setServiceId(512);
|
||
}
|
||
if(entity.getCfgId()==null){
|
||
Integer compileId = 0;
|
||
try {
|
||
//处理组
|
||
if(!StringUtil.isEmpty(entity.getUserRegion())){
|
||
entity.setCommonGroupIds(gsonToJson(entity.getUserRegion()));
|
||
}
|
||
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
|
||
if(idList!=null && idList.size()>0){
|
||
compileId = idList.get(0);
|
||
}
|
||
entity.setCompileId(compileId);
|
||
entity.setCreateTime(new Date());
|
||
entity.setCreatorId(entity.getCurrentUser().getId());
|
||
commonPolicyDao.saveCfgIndex(entity);
|
||
//保存区域IP信息
|
||
if(entity.getAreaCfg()!=null){
|
||
for(AreaIpCfg cfg:entity.getAreaCfg()){
|
||
cfg.initDefaultValue();
|
||
BeanUtils.copyProperties(entity, cfg,new String[]{"cfgRegionCode","cfgType"});
|
||
areaIpCfgDao.saveAreaIpCfg(cfg);
|
||
}
|
||
}
|
||
} catch (Exception e) {
|
||
e.printStackTrace();
|
||
logger.info("数据保存出错");
|
||
throw e;
|
||
}
|
||
|
||
if(isValid==1) {
|
||
entity.setIsAudit(1);
|
||
entity.setIsValid(1);
|
||
auditPolicy(entity, entity.getIsAudit(),Constants.INSERT_ACTION);
|
||
}
|
||
|
||
}else{
|
||
//处理公共分组
|
||
if(MapUtils.isNotEmpty(entity.getUserRegion())){
|
||
entity.setCommonGroupIds(gsonToJson(entity.getUserRegion()));
|
||
}else{
|
||
entity.setCommonGroupIds("");
|
||
}
|
||
// 审核未通过状态的配置 修改后状态改为未审核
|
||
entity.setIsValid(0);
|
||
entity.setIsAudit(0);
|
||
entity.setEditorId(UserUtils.getUser().getId());
|
||
entity.setEditTime(new Date());
|
||
commonPolicyDao.updateCfgIndex(entity);
|
||
|
||
AreaIpCfg area = new AreaIpCfg();
|
||
area.setCompileId(entity.getCompileId());
|
||
area.setFunctionId(entity.getFunctionId());
|
||
areaIpCfgDao.deleteAreaIpCfg(area);
|
||
entity.setCreateTime(new Date());
|
||
entity.setCreatorId(entity.getCurrentUser().getId());
|
||
|
||
//保存区域IP信息
|
||
if(entity.getAreaCfg()!=null){
|
||
for(AreaIpCfg cfg:entity.getAreaCfg()){
|
||
cfg.initDefaultValue();
|
||
BeanUtils.copyProperties(entity, cfg,new String[]{"cfgDesc","cfgRegionCode","cfgType"});
|
||
areaIpCfgDao.saveAreaIpCfg(cfg);
|
||
}
|
||
}
|
||
|
||
if(isValid==1) {
|
||
entity.setIsAudit(1);
|
||
entity.setIsValid(1);
|
||
auditPolicy(entity, entity.getIsAudit(), Constants.UPDATE_ACTION);
|
||
}
|
||
}
|
||
//更新UD_FLAG
|
||
if(StringUtils.isNotBlank(oldCommonGroupIds)){
|
||
Map<String,Object> oldMap=gsonFromJson(oldCommonGroupIds,Map.class);
|
||
Map<String,Object> newMap=entity.getUserRegion();
|
||
StringBuffer canceledGroup=new StringBuffer();
|
||
|
||
for(Map.Entry<String,Object> e:oldMap.entrySet()){
|
||
if(MapUtils.isEmpty(newMap)){
|
||
for(String s:((String)e.getValue()).split(",")){
|
||
if(StringUtils.isNotBlank(s)){
|
||
canceledGroup.append(","+s);
|
||
}
|
||
}
|
||
}else if(newMap.containsKey(e.getKey())){
|
||
for(String s:((String)e.getValue()).split(",")){
|
||
if(StringUtils.isNotBlank(s)&&newMap.get(e.getKey()).toString().indexOf(","+s+",")==-1){
|
||
canceledGroup.append(","+s);
|
||
}
|
||
}
|
||
}else{
|
||
if(StringUtils.isNotBlank(e.getValue().toString())){
|
||
String val=e.getValue().toString().substring(0,e.getValue().toString().length()-1);
|
||
canceledGroup.append(val);
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
StringBuffer okGroup=new StringBuffer();
|
||
for(Object val:newMap.values()){
|
||
String _val=(String)val;
|
||
if(StringUtils.isNotBlank(_val)){
|
||
if(_val.startsWith(",")){
|
||
okGroup.append(_val.substring(1));
|
||
}else{
|
||
okGroup.append(_val);
|
||
}
|
||
}
|
||
}
|
||
//取消勾选的组更新UD_FLAG
|
||
if(StringUtils.isNotBlank(canceledGroup.toString())){
|
||
policyGroupInfoDao.updateUdFlag(canceledGroup.toString().substring(1),1,null);
|
||
}
|
||
//新选择的组更新UD_FALG
|
||
if(StringUtils.isNotBlank(okGroup.toString())){
|
||
okGroup.deleteCharAt(okGroup.toString().length()-1);
|
||
policyGroupInfoDao.updateUdFlag(okGroup.toString(),2,null);
|
||
}
|
||
}else if(MapUtils.isNotEmpty(entity.getUserRegion())){
|
||
policyGroupInfoDao.updateUdFlag(userRegionMapToString(entity.getUserRegion()),2,null);
|
||
}
|
||
//处理定时任务
|
||
handelScheduleCfg(entity, entity.getIndexTable(), entity);
|
||
}
|
||
public CfgIndexInfo getObjGroupPolicyWithoutSubCfg(Long cfgId){
|
||
CfgIndexInfo entity = commonPolicyDao.getPolicyById(cfgId);
|
||
entity.setUserRegion((Map<String,Object>)this.gsonFromJson(entity.getUserRegion1(),Map.class));
|
||
return entity;
|
||
}
|
||
public CfgIndexInfo getObjGroupPolicy(Long cfgId){
|
||
CfgIndexInfo entity = commonPolicyDao.getPolicyById(cfgId);
|
||
entity.setUserRegion((Map<String,Object>)this.gsonFromJson(entity.getCommonGroupIds(),Map.class));
|
||
if(entity.getUserRegion().containsKey("ipGroup")){
|
||
String ids=entity.getUserRegion().get("ipGroup").toString().startsWith(",")?entity.getUserRegion().get("ipGroup").toString().substring(1):entity.getUserRegion().get("ipGroup").toString();
|
||
ids=ids.endsWith(",")?ids.substring(0,ids.length()-1):ids;
|
||
List<IpCommCfg> ipList = objectGroupDao.getIpCommonList(ids,null);
|
||
entity.setIpCommGroupCfgList(ipList);
|
||
}
|
||
if(entity.getUserRegion().containsKey("subscribeIdGroup")){
|
||
String ids=entity.getUserRegion().get("subscribeIdGroup").toString().startsWith(",")?entity.getUserRegion().get("subscribeIdGroup").toString().substring(1):entity.getUserRegion().get("subscribeIdGroup").toString();
|
||
ids=ids.endsWith(",")?ids.substring(0,ids.length()-1):ids;
|
||
List<ScriberIdCommCfg> stringList=objectGroupDao.getScriberIdCommonList(ids,null);
|
||
entity.setScriberIdCommGroupList(stringList);
|
||
}
|
||
if(entity.getUserRegion().containsKey("domainGroup")){
|
||
String ids=entity.getUserRegion().get("domainGroup").toString().startsWith(",")?entity.getUserRegion().get("domainGroup").toString().substring(1):entity.getUserRegion().get("domainGroup").toString();
|
||
ids=ids.endsWith(",")?ids.substring(0,ids.length()-1):entity.getUserRegion().get("domainGroup").toString();
|
||
List<DomainCommCfg> stringList=objectGroupDao.getDomainCommonList(ids,null);
|
||
entity.setDomainCommGroupList(stringList);
|
||
}
|
||
if(entity.getUserRegion().containsKey("urlGroup")){
|
||
String ids=entity.getUserRegion().get("urlGroup").toString().startsWith(",")?entity.getUserRegion().get("urlGroup").toString().substring(1):entity.getUserRegion().get("urlGroup").toString();
|
||
ids=ids.endsWith(",")?ids.substring(0,ids.length()-1):ids;
|
||
List<UrlCommCfg> stringList = objectGroupDao.getUrlCommonList(ids,null);
|
||
entity.setUrlCommGroupList(stringList);
|
||
}
|
||
|
||
return entity;
|
||
}
|
||
|
||
public void auditPolicy(CfgIndexInfo entity,Integer isAudit,Integer opAction) throws MaatConvertException {
|
||
//修改数据库审核状态信息
|
||
entity.setTableName(CfgIndexInfo.getTablename());
|
||
entity.setIsAudit(isAudit);
|
||
entity.setAuditorId(UserUtils.getUser().getId());
|
||
entity.setAuditTime(new Date());
|
||
//审核cfg_index_info
|
||
commonPolicyDao.auditCfg(entity);
|
||
|
||
ToMaatBean maatBean = new ToMaatBean();
|
||
MaatCfg maatCfg = new MaatCfg();
|
||
Set<Integer> groupIdSet=new HashSet<>();
|
||
List<MaatCfg> configCompileList = new ArrayList();
|
||
List<MaatCfg.GroupCfg> groupRelationList = new ArrayList();
|
||
List<MaatCfg.IpCfg> ipRegionList = new ArrayList();
|
||
List<MaatCfg.StringCfg> strRegionList = new ArrayList();
|
||
List<MaatCfg.NumBoundaryCfg> numRegionList = new ArrayList();
|
||
List<MaatCfg.DigestCfg> digestRegionList = new ArrayList();
|
||
List<MaatCfg.IpCfg> areaIpRegionList = new ArrayList();
|
||
|
||
//查询子配置并修改审核状态
|
||
entity = this.getObjGroupPolicy(entity.getCfgId());
|
||
// if(StringUtils.isBlank(entity.getCommonGroupIds())){
|
||
//
|
||
// }
|
||
ServiceConfigTemplateUtil templateUtil=new ServiceConfigTemplateUtil();
|
||
List<Map<String,Object>> serviceMapList= ServiceConfigTemplateUtil.getServiceList();
|
||
List<FunctionServiceDict> dicts=DictUtils.getFunctionServiceDictList();
|
||
Integer serviceId=entity.getServiceId();
|
||
Map<String,Object> maatTableMap=new HashMap<>();
|
||
|
||
StringBuffer userRegion=new StringBuffer();
|
||
if(serviceId!=null){
|
||
if(isAudit==1){
|
||
List<Map<String,Object>> list= templateUtil.getServiceListByServiceId(serviceId);
|
||
//获取业务下的配置域
|
||
List<Map<String,Object>> cfgList = new ArrayList<>();
|
||
//获取业务下的自定义域
|
||
List<Map<String,Object>> userRegionList = new ArrayList<>();
|
||
for(Map<String,Object> service:list){
|
||
String serviceType = service.get("serviceType").toString();
|
||
if(service.containsKey("maatTable")){ }
|
||
if(service.containsKey("cfgList")) {
|
||
cfgList=(List<Map<String, Object>>) service.get("cfgList");
|
||
maatTableMap=ConfigConvertUtil.convertCommonGroupMaatTable(entity,cfgList);
|
||
}
|
||
if(service.containsKey("userRegionList")){
|
||
Map<String,Object> userregionMap=new HashMap<>();
|
||
userRegionList=(List<Map<String, Object>>) service.get("userRegionList");
|
||
userRegion.append(ConfigConvertUtil.generateCommonGroupDefaultUserRegion(userregionMap,serviceId));
|
||
}
|
||
}
|
||
}
|
||
}
|
||
//IP公共分组
|
||
if(CollectionUtils.isNotEmpty(entity.getIpCommGroupCfgList())){
|
||
IpPortCfg cfg = new IpPortCfg();
|
||
BeanUtils.copyProperties(entity, cfg, new String[]{"cfgId"});
|
||
//cfg.setTableName("ip_comm_cfg");
|
||
//commonPolicyDao.auditCfg(cfg);
|
||
if(isAudit==1){
|
||
Map<String,List> map = ConfigConvertUtil.objGroupCfgConvert(ipRegionList,entity.getIpCommGroupCfgList(),1,cfg,groupRelationList,maatTableMap,groupIdSet);
|
||
groupRelationList=map.get("groupList");
|
||
ipRegionList=map.get("dstList");
|
||
if(map.get("numRegionList")!=null){
|
||
numRegionList.addAll(map.get("numRegionList"));
|
||
}
|
||
}
|
||
}
|
||
//URL公共分组
|
||
if(CollectionUtils.isNotEmpty(entity.getUrlCommGroupList())){
|
||
CommonStringCfg cfg = new CommonStringCfg();
|
||
BeanUtils.copyProperties(entity, cfg, new String[]{"cfgId"});
|
||
//cfg.setTableName(CommonStringCfg.getTablename());
|
||
//commonPolicyDao.auditCfg(cfg);
|
||
if(isAudit==1){
|
||
Map<String,List> map =ConfigConvertUtil.objGroupCfgConvert(strRegionList,entity.getUrlCommGroupList(),2,cfg,groupRelationList,maatTableMap,groupIdSet);
|
||
groupRelationList=map.get("groupList");
|
||
strRegionList=map.get("dstList");
|
||
}
|
||
}
|
||
//账号公共分组
|
||
if(CollectionUtils.isNotEmpty(entity.getScriberIdCommGroupList())){
|
||
CommonStringCfg cfg = new CommonStringCfg();
|
||
BeanUtils.copyProperties(entity, cfg, new String[]{"cfgId"});
|
||
//cfg.setTableName(CommonStringCfg.getTablename());
|
||
//commonPolicyDao.auditCfg(cfg);
|
||
if(isAudit==1){
|
||
Map<String,List> map =ConfigConvertUtil.objGroupCfgConvert(strRegionList,entity.getScriberIdCommGroupList(),2,cfg,groupRelationList,maatTableMap,groupIdSet);
|
||
groupRelationList=map.get("groupList");
|
||
strRegionList=map.get("dstList");
|
||
}
|
||
}
|
||
//域名公共分组
|
||
if(CollectionUtils.isNotEmpty(entity.getDomainCommGroupList())){
|
||
CommonStringCfg cfg = new CommonStringCfg();
|
||
BeanUtils.copyProperties(entity, cfg, new String[]{"cfgId"});
|
||
//cfg.setTableName(CommonStringCfg.getTablename());
|
||
//commonPolicyDao.auditCfg(cfg);
|
||
if(isAudit==1){
|
||
Map<String,List> map =ConfigConvertUtil.objGroupCfgConvert(strRegionList,entity.getDomainCommGroupList(),2,cfg,groupRelationList,maatTableMap,groupIdSet);
|
||
groupRelationList=map.get("groupList");
|
||
strRegionList=map.get("dstList");
|
||
}
|
||
}
|
||
//保存区域IP信息
|
||
List<AreaIpCfg> areaIpCfgList=areaIpCfgDao.getByCompileId(entity.getCompileId());
|
||
if(!StringUtil.isEmpty(areaIpCfgList)){
|
||
AreaIpCfg cfg = new AreaIpCfg();
|
||
BeanUtils.copyProperties(entity, cfg, new String[]{"cfgId"});
|
||
cfg.setTableName(AreaIpCfg.getTablename());
|
||
commonPolicyDao.auditCfg(cfg);
|
||
if(isAudit==1){
|
||
Map<String,List> map = cfgConvert(areaIpRegionList,areaIpCfgList,1,entity,groupRelationList);
|
||
groupRelationList=map.get("groupList");
|
||
areaIpRegionList=map.get("dstList");
|
||
}
|
||
}
|
||
|
||
//构造提交综合服务参数格式，一条配置提交一次综合服务
|
||
if(isAudit==1){
|
||
maatCfg.initDefaultValue();
|
||
if(entity.getServiceId().equals(512)){
|
||
maatCfg.setAction(2);
|
||
}
|
||
BeanUtils.copyProperties(entity, maatCfg);
|
||
|
||
if(entity.getServiceId().equals(512)){
|
||
maatCfg.setAction(2);
|
||
}else{
|
||
maatCfg.setAction(entity.getAction());
|
||
}
|
||
maatCfg.setAuditTime(entity.getAuditTime());
|
||
maatCfg.setIpRegionList(ipRegionList);
|
||
maatCfg.setStrRegionList(strRegionList);
|
||
maatCfg.setNumRegionList(numRegionList);
|
||
maatCfg.setDigestRegionList(digestRegionList);
|
||
maatCfg.setGroupRelationList(groupRelationList);
|
||
maatCfg.setGroupNum(groupRelationList.size());
|
||
maatCfg.setAreaIpRegionList(areaIpRegionList);
|
||
maatCfg.setIsValid(entity.getIsValid());
|
||
//设置用户自定义域
|
||
String protpcolType=entity.getUserRegion1();
|
||
|
||
if("HTTPS".equalsIgnoreCase(protpcolType)||"INTERCEPT".equalsIgnoreCase(protpcolType)){
|
||
if(StringUtils.isBlank(userRegion.toString())){
|
||
userRegion.append("{}");
|
||
}
|
||
}else if("HTTP".equalsIgnoreCase(protpcolType)){
|
||
|
||
}
|
||
maatCfg.setUserRegion(userRegion.toString());
|
||
|
||
configCompileList.add(maatCfg);
|
||
maatBean.setConfigCompileList(configCompileList);
|
||
maatBean.setAuditTime(entity.getAuditTime());
|
||
maatBean.setCreatorName(entity.getCurrentUser().getName());
|
||
maatBean.setVersion(Constants.MAAT_VERSION);
|
||
maatBean.setOpAction(opAction);
|
||
//调用服务接口下发配置数据
|
||
String json=gsonToJson(maatBean);
|
||
logger.info("策略对象组下发配置参数："+json);
|
||
//调用服务接口下发配置
|
||
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
|
||
logger.info("策略对象组下发响应信息："+result.getMsg());
|
||
|
||
}else if(isAudit==3){
|
||
maatCfg.setCompileId(entity.getCompileId());
|
||
maatCfg.setServiceId(entity.getServiceId());
|
||
maatCfg.setIsValid(0);//无效
|
||
configCompileList.add(maatCfg);
|
||
maatBean.setConfigCompileList(configCompileList);
|
||
maatBean.setAuditTime(entity.getAuditTime());
|
||
maatBean.setCreatorName(entity.getCurrentUser().getName());
|
||
maatBean.setVersion(Constants.MAAT_VERSION);
|
||
maatBean.setOpAction(Constants.UPDATE_ACTION);
|
||
//调用服务接口取消配置
|
||
String json=gsonToJson(maatBean);
|
||
logger.info("策略对象组下发配置参数："+json);
|
||
//调用服务接口下发配置
|
||
ToMaatResult result = ConfigServiceUtil.put(json,1);
|
||
logger.info("策略对象组取消配置响应信息："+result.getMsg());
|
||
}
|
||
}
|
||
public boolean indexOfContains(String arrayString,String splitor,String current){
|
||
if(arrayString==null||arrayString==null){
|
||
return false;
|
||
}
|
||
return arrayString.equals(current)?true:arrayString.indexOf(splitor+current+splitor)>-1?true:arrayString.startsWith(current+splitor)?true:arrayString.endsWith(splitor+current)?true:false;
|
||
}
|
||
|
||
public void updatePolicyValid(Integer isValid, String ids, Integer functionId) {
|
||
String[] idArray = ids.split(",");
|
||
for(String id :idArray){
|
||
CfgIndexInfo entity = new CfgIndexInfo();
|
||
entity.setCfgId(Long.parseLong(id));
|
||
entity.setIsValid(isValid);
|
||
entity.setEditorId(UserUtils.getUser().getId());
|
||
entity.setEditTime(new Date());
|
||
entity.setTableName(CfgIndexInfo.getTablename());
|
||
entity.setFunctionId(functionId);
|
||
commonPolicyDao.updateCfgValid(entity);
|
||
//修改对应的policyGroupInfo的udFlag状态
|
||
CfgIndexInfo cfg=commonPolicyDao.getPolicyById(Long.parseLong(id));
|
||
String userregion=cfg.getCommonGroupIds();
|
||
if(StringUtils.isNotBlank(userregion)){
|
||
Map<String,Object> userRegionMap=gsonFromJson(userregion,Map.class);
|
||
StringBuffer serviceGroupIds=new StringBuffer();
|
||
for(Object val:userRegionMap.values()){
|
||
if(val.toString().startsWith(",")){
|
||
serviceGroupIds.append(val.toString().substring(1));
|
||
}else{
|
||
serviceGroupIds.append(val.toString());
|
||
}
|
||
}
|
||
if(serviceGroupIds.toString().endsWith(",")){
|
||
serviceGroupIds.deleteCharAt(serviceGroupIds.toString().length()-1);
|
||
}
|
||
//删除之后恢复组的ud_flag
|
||
int size = ipCommGroupCfgDao.getCfgInfoByGroupIds(serviceGroupIds.toString());
|
||
int size1 = urlCommGroupCfgDao.getCfgInfoByGroupIds(serviceGroupIds.toString());
|
||
int size2 = scriberIdCommGroupDao.getCfgInfoByGroupIds(serviceGroupIds.toString());
|
||
int size3 = domainCommGroupDao.getCfgInfoByGroupIds(serviceGroupIds.toString());
|
||
if((size+size1+size2+size3)==0){
|
||
policyGroupInfoDao.updateUdFlag(serviceGroupIds.toString(),0,null);
|
||
}else{
|
||
policyGroupInfoDao.updateUdFlag(serviceGroupIds.toString(),1,null);
|
||
}
|
||
|
||
}
|
||
|
||
}
|
||
}
|
||
@Transactional(rollbackFor = RuntimeException.class)
|
||
public boolean batchDeleteMaatData(Page page, BaseCfg entity,
|
||
List<BaseCfg> list, boolean hasData,String groupIds) {
|
||
// 1.获取所有配置的编译ID
|
||
List<Integer> compileIds = new ArrayList();
|
||
|
||
for(BaseCfg cfg:list){
|
||
compileIds.add(cfg.getCompileId());
|
||
cfg.setIsValid(-1);
|
||
cfg.setIsAudit(0);
|
||
}
|
||
|
||
// 2.更新配置状态（主表）
|
||
if(!StringUtil.isEmpty(compileIds) && !StringUtil.isEmpty(entity.getTableName())) {
|
||
commonPolicyDao.deleteCfgBatch(entity.getTableName(), entity,compileIds); // 批量修改配置状态（主表）
|
||
//更新各配置定时任务信息
|
||
handelScheduleCfg(list, entity.getTableName(),entity);
|
||
}
|
||
//3.恢复policy_group_info可选状态
|
||
if(StringUtils.isNotBlank(groupIds)){
|
||
policyGroupInfoDao.updateUdFlag(groupIds,1,null);
|
||
}
|
||
// 4.判断是否是当前检索条件下最后一页数据 并返回结果
|
||
page.setList(list);
|
||
if(page.isLastPage()){
|
||
hasData = false;
|
||
}
|
||
return hasData;
|
||
}
|
||
private String userRegionMapToString(Map<String,Object> dataMap){
|
||
StringBuffer buf=new StringBuffer();
|
||
for(Object val:dataMap.values()){
|
||
String _val=(String)val;
|
||
if(_val.startsWith(",")){
|
||
buf.append(_val.substring(1));
|
||
}else{
|
||
buf.append(_val);
|
||
}
|
||
}
|
||
if(buf.toString().endsWith(",")){
|
||
buf.deleteCharAt(buf.toString().length()-1);
|
||
}
|
||
return buf.toString();
|
||
}
|
||
|
||
public List<ObjGroupCfg> getObjGroupList(String ids,Properties msgProp,Integer functionId){
|
||
List<ObjGroupCfg> list = commonPolicyDao.getObjGroupList(ids);
|
||
StringBuffer groupIds=new StringBuffer();
|
||
List<PolicyGroupInfo> policyGroupInfos=new ArrayList<>();
|
||
List<FunctionServiceDict> serviceList = DictUtils.getFunctionServiceDictList(functionId);
|
||
for (ObjGroupCfg c : list) {
|
||
if(!StringUtil.isBlank(c.getCommonGroupIds())) {
|
||
Map<String,String> groupIdMap=ConfigConvertUtil.gsonFromJson(c.getCommonGroupIds(),Map.class);
|
||
for(String value:groupIdMap.values()){
|
||
if(StringUtils.isNotBlank(value)){
|
||
groupIds.append(value.substring(1));
|
||
}
|
||
}
|
||
}
|
||
for (FunctionServiceDict service : serviceList) {
|
||
if(c.getAction().intValue()==service.getAction().intValue()){
|
||
c.setActionCode(msgProp.getProperty(service.getActionCode(),service.getActionCode()));
|
||
}
|
||
}
|
||
}
|
||
if(StringUtils.isNotBlank(groupIds.toString())){
|
||
groupIds.deleteCharAt(groupIds.toString().length()-1);
|
||
policyGroupInfos=policyGroupInfoDao.findPolicyByServiceGroupInfoList(groupIds.toString());
|
||
}
|
||
Map<Integer,PolicyGroupInfo> policyGroupInfoMap=new HashMap<>();
|
||
for(PolicyGroupInfo info:policyGroupInfos){
|
||
policyGroupInfoMap.put(info.getServiceGroupId(),info);
|
||
}
|
||
Map<Integer,PolicyGroupInfo> policyGroupInfoMapCopy=new HashMap<>();
|
||
policyGroupInfoMapCopy.putAll(policyGroupInfoMap);
|
||
for (ObjGroupCfg c : list) {
|
||
for(Map.Entry<Integer,PolicyGroupInfo> e:policyGroupInfoMap.entrySet()){
|
||
if(c.getCommonGroupIds().indexOf(","+e.getKey()+",")>-1){
|
||
if(e.getValue().getGroupType().equals(Constants.IP_OBJ_GROUP_TYPE)){
|
||
String name=(StringUtils.isBlank(c.getIpGroup())?"":c.getIpGroup())+","+e.getValue().getGroupName();
|
||
c.setIpGroup(name);
|
||
policyGroupInfoMap.remove(e.getKey());
|
||
}else if(e.getValue().getGroupType().equals(Constants.URL_OBJ_GROUP_TYPE)){
|
||
String name=(StringUtils.isBlank(c.getIpGroup())?"":c.getUrlGroup())+","+e.getValue().getGroupName();
|
||
c.setUrlGroup(name);
|
||
policyGroupInfoMap.remove(e.getKey());
|
||
}else if(e.getValue().getGroupType().equals(Constants.SUBID_OBJ_GROUP_TYPE)){
|
||
String name=(StringUtils.isBlank(c.getSubscribeIdGroup())?"":c.getSubscribeIdGroup())+","+e.getValue().getGroupName();
|
||
c.setSubscribeIdGroup(name);
|
||
policyGroupInfoMap.remove(e.getKey());
|
||
}else if(e.getValue().getGroupType().equals(Constants.DOMAIN_OBJ_GROUP_TYPE)){
|
||
String name=(StringUtils.isBlank(c.getDomainGroup())?"":c.getDomainGroup())+","+e.getValue().getGroupName();
|
||
c.setDomainGroup(name);
|
||
policyGroupInfoMap.remove(e.getKey());
|
||
}
|
||
}
|
||
}
|
||
policyGroupInfoMapCopy.clear();
|
||
policyGroupInfoMapCopy.putAll(policyGroupInfoMap);
|
||
}
|
||
return list;
|
||
}
|
||
|
||
public Page<ObjGroupCfg> getObjGroup(Page<ObjGroupCfg> page, ObjGroupCfg entity,Properties msgProp){
|
||
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(),"a"));
|
||
entity.setPage(page);
|
||
StringBuffer groupIds=new StringBuffer();
|
||
List<ObjGroupCfg> list = commonPolicyDao.getObjGroupPagedList(entity);
|
||
List<PolicyGroupInfo> policyGroupInfos=new ArrayList<>();
|
||
List<FunctionServiceDict> serviceList = DictUtils.getFunctionServiceDictList(entity.getFunctionId());
|
||
|
||
for (ObjGroupCfg c : list) {
|
||
if(StringUtils.isNotBlank(c.getCommonGroupIds())) {
|
||
Map<String,String> groupIdMap=ConfigConvertUtil.gsonFromJson(c.getCommonGroupIds(),Map.class);
|
||
for(String value:groupIdMap.values()){
|
||
if(StringUtils.isNotBlank(value)){
|
||
groupIds.append(value.substring(1));
|
||
}
|
||
}
|
||
}
|
||
for (FunctionServiceDict service : serviceList) {
|
||
if(c.getAction().intValue()==service.getAction().intValue()){
|
||
c.setActionCode(msgProp.getProperty(service.getActionCode(),service.getActionCode()));
|
||
}
|
||
}
|
||
}
|
||
if(StringUtils.isNotBlank(groupIds.toString())){
|
||
groupIds.deleteCharAt(groupIds.toString().length()-1);
|
||
policyGroupInfos=policyGroupInfoDao.findPolicyByServiceGroupInfoList(groupIds.toString());
|
||
}
|
||
Map<Integer,PolicyGroupInfo> policyGroupInfoMap=new HashMap<>();
|
||
for(PolicyGroupInfo info:policyGroupInfos){
|
||
policyGroupInfoMap.put(info.getServiceGroupId(),info);
|
||
}
|
||
Map<Integer,PolicyGroupInfo> policyGroupInfoMapCopy=new HashMap<>();
|
||
policyGroupInfoMapCopy.putAll(policyGroupInfoMap);
|
||
for (ObjGroupCfg c : list) {
|
||
for(Map.Entry<Integer,PolicyGroupInfo> e:policyGroupInfoMapCopy.entrySet()){
|
||
if(c.getCommonGroupIds().indexOf(","+e.getKey()+",")>-1){
|
||
if(e.getValue().getGroupType().equals(Constants.IP_OBJ_GROUP_TYPE)){
|
||
String name=(StringUtils.isBlank(c.getIpGroup())?"":c.getIpGroup())+","+e.getValue().getGroupName();
|
||
c.setIpGroup(name);
|
||
policyGroupInfoMap.remove(e.getKey());
|
||
}else if(e.getValue().getGroupType().equals(Constants.URL_OBJ_GROUP_TYPE)){
|
||
String name=(StringUtils.isBlank(c.getIpGroup())?"":c.getUrlGroup())+","+e.getValue().getGroupName();
|
||
c.setUrlGroup(name);
|
||
policyGroupInfoMap.remove(e.getKey());
|
||
}else if(e.getValue().getGroupType().equals(Constants.SUBID_OBJ_GROUP_TYPE)){
|
||
String name=(StringUtils.isBlank(c.getSubscribeIdGroup())?"":c.getSubscribeIdGroup())+","+e.getValue().getGroupName();
|
||
c.setSubscribeIdGroup(name);
|
||
policyGroupInfoMap.remove(e.getKey());
|
||
}else if(e.getValue().getGroupType().equals(Constants.DOMAIN_OBJ_GROUP_TYPE)){
|
||
String name=(StringUtils.isBlank(c.getDomainGroup())?"":c.getDomainGroup())+","+e.getValue().getGroupName();
|
||
c.setDomainGroup(name);
|
||
policyGroupInfoMap.remove(e.getKey());
|
||
}
|
||
}
|
||
}
|
||
policyGroupInfoMapCopy.clear();
|
||
policyGroupInfoMapCopy.putAll(policyGroupInfoMap);
|
||
}
|
||
page.setList(list);
|
||
return page;
|
||
}
|
||
|
||
public void saveAndSend(FunctionRegionDict regionDict, FunctionServiceDict serviceDict, List<BaseStringCfg<?>> stringCfgs) {
|
||
}
|
||
} |