批量审核通过,修改lastPageBUG,暂时注释app IP的批量下发,需再考虑实现;
findAllListByGroupIno修改为findAllListByGroupInfo; delRow无变更;
This commit is contained in:
@@ -12,6 +12,7 @@ import java.util.Date;
|
|||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
import java.util.Map.Entry;
|
||||||
import java.util.Properties;
|
import java.util.Properties;
|
||||||
import java.util.concurrent.ArrayBlockingQueue;
|
import java.util.concurrent.ArrayBlockingQueue;
|
||||||
import java.util.concurrent.BlockingQueue;
|
import java.util.concurrent.BlockingQueue;
|
||||||
@@ -44,6 +45,7 @@ import com.nis.domain.FunctionRegionDict;
|
|||||||
import com.nis.domain.FunctionServiceDict;
|
import com.nis.domain.FunctionServiceDict;
|
||||||
import com.nis.domain.Page;
|
import com.nis.domain.Page;
|
||||||
import com.nis.domain.SysDataDictionaryItem;
|
import com.nis.domain.SysDataDictionaryItem;
|
||||||
|
import com.nis.domain.basics.AsnGroupInfo;
|
||||||
import com.nis.domain.basics.AsnIpCfg;
|
import com.nis.domain.basics.AsnIpCfg;
|
||||||
import com.nis.domain.basics.ServiceDictInfo;
|
import com.nis.domain.basics.ServiceDictInfo;
|
||||||
import com.nis.domain.basics.SysDictInfo;
|
import com.nis.domain.basics.SysDictInfo;
|
||||||
@@ -115,14 +117,13 @@ import com.nis.domain.maat.ToMaatBean;
|
|||||||
import com.nis.domain.specific.ConfigGroupInfo;
|
import com.nis.domain.specific.ConfigGroupInfo;
|
||||||
import com.nis.domain.specific.SpecificServiceCfg;
|
import com.nis.domain.specific.SpecificServiceCfg;
|
||||||
import com.nis.exceptions.MaatConvertException;
|
import com.nis.exceptions.MaatConvertException;
|
||||||
import com.nis.util.AsnCacheUtils;
|
//import com.nis.util.AsnCacheUtils;
|
||||||
import com.nis.util.ConfigServiceUtil;
|
import com.nis.util.ConfigServiceUtil;
|
||||||
import com.nis.util.Configurations;
|
import com.nis.util.Configurations;
|
||||||
//import com.nis.main.ConvertTool;
|
//import com.nis.main.ConvertTool;
|
||||||
import com.nis.util.Constants;
|
import com.nis.util.Constants;
|
||||||
import com.nis.util.DateUtils;
|
import com.nis.util.DateUtils;
|
||||||
import com.nis.util.DictUtils;
|
import com.nis.util.DictUtils;
|
||||||
import com.nis.util.FileUtils;
|
|
||||||
import com.nis.util.JsonMapper;
|
import com.nis.util.JsonMapper;
|
||||||
import com.nis.util.ServiceConfigTemplateUtil;
|
import com.nis.util.ServiceConfigTemplateUtil;
|
||||||
import com.nis.util.StringUtil;
|
import com.nis.util.StringUtil;
|
||||||
@@ -145,6 +146,7 @@ import com.nis.web.service.OfficeService;
|
|||||||
import com.nis.web.service.RoleService;
|
import com.nis.web.service.RoleService;
|
||||||
import com.nis.web.service.SystemService;
|
import com.nis.web.service.SystemService;
|
||||||
import com.nis.web.service.UserService;
|
import com.nis.web.service.UserService;
|
||||||
|
import com.nis.web.service.basics.AsnGroupInfoService;
|
||||||
import com.nis.web.service.basics.AsnIpCfgService;
|
import com.nis.web.service.basics.AsnIpCfgService;
|
||||||
import com.nis.web.service.basics.IpReuseIpCfgService;
|
import com.nis.web.service.basics.IpReuseIpCfgService;
|
||||||
import com.nis.web.service.basics.PolicyGroupInfoService;
|
import com.nis.web.service.basics.PolicyGroupInfoService;
|
||||||
@@ -317,6 +319,8 @@ public class BaseController {
|
|||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
protected PxyObjSpoofingIpPoolService pxyObjSpoofingIpPoolService;// 欺骗IP池
|
protected PxyObjSpoofingIpPoolService pxyObjSpoofingIpPoolService;// 欺骗IP池
|
||||||
|
@Autowired
|
||||||
|
protected AsnGroupInfoService asnGroupInfoService;// asn组
|
||||||
/**
|
/**
|
||||||
* 管理基础路径
|
* 管理基础路径
|
||||||
*/
|
*/
|
||||||
@@ -944,7 +948,7 @@ public class BaseController {
|
|||||||
* @throws InterruptedException
|
* @throws InterruptedException
|
||||||
* @throws ExecutionException
|
* @throws ExecutionException
|
||||||
*/
|
*/
|
||||||
public BlockingQueue<BaseIpCfg> checkIpCfgMulity(StringBuffer _msg,FunctionServiceDict serviceDict, FunctionRegionDict regionDict,List<Map<Long,Integer>> asnNos, BlockingQueue<? extends Object> list) throws ServiceException, InterruptedException, ExecutionException{
|
public BlockingQueue<BaseIpCfg> checkIpCfgMulity(StringBuffer _msg,FunctionServiceDict serviceDict, FunctionRegionDict regionDict,List<Map<Long,AsnGroupInfo>> asnNos,Map<Long,AsnGroupInfo> asnGroupInfos, BlockingQueue<? extends Object> list) throws ServiceException, InterruptedException, ExecutionException{
|
||||||
logger.warn("start checkIpCfgMulity ,size "+list.size());
|
logger.warn("start checkIpCfgMulity ,size "+list.size());
|
||||||
long start=System.currentTimeMillis();
|
long start=System.currentTimeMillis();
|
||||||
BlockingQueue<BaseIpCfg> queue=new ArrayBlockingQueue<>(list.size());
|
BlockingQueue<BaseIpCfg> queue=new ArrayBlockingQueue<>(list.size());
|
||||||
@@ -953,6 +957,7 @@ public class BaseController {
|
|||||||
for(int i=0;i<Constants.MULITY_THREAD_SIZE;i++) {
|
for(int i=0;i<Constants.MULITY_THREAD_SIZE;i++) {
|
||||||
CheckIpFormatThread t=new CheckIpFormatThread(serviceDict,regionDict, this.getMsgProp(), list, queue);
|
CheckIpFormatThread t=new CheckIpFormatThread(serviceDict,regionDict, this.getMsgProp(), list, queue);
|
||||||
t.setAsnNoMaps(asnNos);
|
t.setAsnNoMaps(asnNos);
|
||||||
|
t.setAsnGroupInfos(asnGroupInfos);
|
||||||
futures.add(service.submit(t));
|
futures.add(service.submit(t));
|
||||||
}
|
}
|
||||||
service.shutdown();
|
service.shutdown();
|
||||||
@@ -1278,9 +1283,10 @@ public class BaseController {
|
|||||||
List<CfgIndexInfo> cfgIndexInfos = new ArrayList<CfgIndexInfo>();
|
List<CfgIndexInfo> cfgIndexInfos = new ArrayList<CfgIndexInfo>();
|
||||||
List<AppPolicyCfg> appPolicyCfgs = new ArrayList<AppPolicyCfg>();
|
List<AppPolicyCfg> appPolicyCfgs = new ArrayList<AppPolicyCfg>();
|
||||||
List<AppFeatureIndex> appFeatureIndexs= new ArrayList<AppFeatureIndex>();
|
List<AppFeatureIndex> appFeatureIndexs= new ArrayList<AppFeatureIndex>();
|
||||||
List<Map<Long,Integer>> asnNoMaps=Lists.newArrayList();
|
List<Map<Long,AsnGroupInfo>> asnNoMaps=Lists.newArrayList();
|
||||||
Map<Long,Integer> newAsnNoMap=Maps.newConcurrentMap();
|
Map<Long,AsnGroupInfo> newAsnNoMap=Maps.newConcurrentMap();
|
||||||
Map<Long,Integer> OldAsnNoMap=Maps.newConcurrentMap();
|
Map<Long,AsnGroupInfo> OldAsnNoMap=Maps.newConcurrentMap();
|
||||||
|
Map<Long,AsnGroupInfo> asnGroupInfos=null;
|
||||||
asnNoMaps.add(newAsnNoMap);
|
asnNoMaps.add(newAsnNoMap);
|
||||||
asnNoMaps.add(OldAsnNoMap);
|
asnNoMaps.add(OldAsnNoMap);
|
||||||
FunctionRegionDict appRegion = null;
|
FunctionRegionDict appRegion = null;
|
||||||
@@ -1319,44 +1325,48 @@ public class BaseController {
|
|||||||
if (serviceDict!=null&&serviceDict.getAction().equals(64)) {
|
if (serviceDict!=null&&serviceDict.getAction().equals(64)) {
|
||||||
BlockingQueue<IpRateLimitTemplate> list = ei.getDataList(IpRateLimitTemplate.class
|
BlockingQueue<IpRateLimitTemplate> list = ei.getDataList(IpRateLimitTemplate.class
|
||||||
);
|
);
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict,null,asnGroupInfos, list);
|
||||||
} else {
|
} else {
|
||||||
BlockingQueue<IpAllTemplate> list = ei.getDataList(IpAllTemplate.class );
|
BlockingQueue<IpAllTemplate> list = ei.getDataList(IpAllTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
}
|
}
|
||||||
} else if (regionDict.getFunctionId().equals(7)&&serviceDict!=null&&serviceDict.getAction().intValue()==16) {
|
} else if (regionDict.getFunctionId().equals(7)&&serviceDict!=null&&serviceDict.getAction().intValue()==16) {
|
||||||
BlockingQueue<DnsIpTemplate> list = ei.getDataList(DnsIpTemplate.class );
|
BlockingQueue<DnsIpTemplate> list = ei.getDataList(DnsIpTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
}else if(regionDict.getFunctionId().equals(401)) {
|
}else if(regionDict.getFunctionId().equals(401)) {
|
||||||
BlockingQueue<DnsFakeIpTemplate> list = ei.getDataList(DnsFakeIpTemplate.class );
|
BlockingQueue<DnsFakeIpTemplate> list = ei.getDataList(DnsFakeIpTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
}else if (regionDict.getFunctionId().equals(212)) {
|
}else if (regionDict.getFunctionId().equals(212)) {
|
||||||
BlockingQueue<IpPayloadTemplate> list = ei.getDataList(IpPayloadTemplate.class );
|
BlockingQueue<IpPayloadTemplate> list = ei.getDataList(IpPayloadTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
} else if (regionDict.getFunctionId().equals(510)
|
} else if (regionDict.getFunctionId().equals(510)
|
||||||
&& "p2p_ip".equals(regionDict.getConfigServiceType())) { // P2p IP
|
&& "p2p_ip".equals(regionDict.getConfigServiceType())) { // P2p IP
|
||||||
BlockingQueue<P2pIpTemplate> list = ei.getDataList(P2pIpTemplate.class );
|
BlockingQueue<P2pIpTemplate> list = ei.getDataList(P2pIpTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
} else if (regionDict.getFunctionId().equals(600)) {// ASN IP
|
} else if (regionDict.getFunctionId().equals(600)) {// ASN IP
|
||||||
//加载asn缓存
|
//加载asn缓存
|
||||||
AsnCacheUtils.init(true);
|
//AsnCacheUtils.init(true);
|
||||||
|
//从数据库中读取
|
||||||
|
asnGroupInfos=asnGroupInfoService.getGroupList();
|
||||||
|
//OldAsnNoMap.putAll(asnGroupInfoService.getGroupList());
|
||||||
BlockingQueue<AsnIpTemplate> list = ei.getDataList(AsnIpTemplate.class );
|
BlockingQueue<AsnIpTemplate> list = ei.getDataList(AsnIpTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, asnNoMaps, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, asnNoMaps,asnGroupInfos, list);
|
||||||
|
|
||||||
}else if (regionDict.getFunctionId().equals(301)) {// DDOS IP
|
}else if (regionDict.getFunctionId().equals(301)) {// DDOS IP
|
||||||
BlockingQueue<DdosIpTemplate> list = ei.getDataList(DdosIpTemplate.class );
|
BlockingQueue<DdosIpTemplate> list = ei.getDataList(DdosIpTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
}else if(regionDict.getFunctionId().equals(207)){// HTTP(s)阻断
|
}else if(regionDict.getFunctionId().equals(207)){// HTTP(s)阻断
|
||||||
BlockingQueue<HttpsRejectIpTemplate> list = ei.getDataList(HttpsRejectIpTemplate.class );
|
BlockingQueue<HttpsRejectIpTemplate> list = ei.getDataList(HttpsRejectIpTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
}else if(regionDict.getFunctionId().equals(208)){// HTTP(s)重定向
|
}else if(regionDict.getFunctionId().equals(208)){// HTTP(s)重定向
|
||||||
BlockingQueue<HttpsRedirectIpTemplate> list = ei.getDataList(HttpsRedirectIpTemplate.class );
|
BlockingQueue<HttpsRedirectIpTemplate> list = ei.getDataList(HttpsRedirectIpTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
}else if(regionDict.getFunctionId().equals(209)){// HTTP(s)替换
|
}else if(regionDict.getFunctionId().equals(209)){// HTTP(s)替换
|
||||||
BlockingQueue<HttpsReplaceIpTemplate> list = ei.getDataList(HttpsReplaceIpTemplate.class );
|
BlockingQueue<HttpsReplaceIpTemplate> list = ei.getDataList(HttpsReplaceIpTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
} else {
|
} else {
|
||||||
BlockingQueue<IpAllTemplate> list = ei.getDataList(IpAllTemplate.class );
|
BlockingQueue<IpAllTemplate> list = ei.getDataList(IpAllTemplate.class );
|
||||||
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null, list);
|
ipPortCfgs=this.checkIpCfgMulity(errTip,serviceDict, regionDict, null,asnGroupInfos, list);
|
||||||
}
|
}
|
||||||
} else if (regionDict.getRegionType().equals(2)) {// 字符串类
|
} else if (regionDict.getRegionType().equals(2)) {// 字符串类
|
||||||
if (regionDict.getFunctionId().equals(510)
|
if (regionDict.getFunctionId().equals(510)
|
||||||
@@ -1454,88 +1464,20 @@ public class BaseController {
|
|||||||
}
|
}
|
||||||
if (regionDict.getRegionType().equals(1)) {// IP
|
if (regionDict.getRegionType().equals(1)) {// IP
|
||||||
if(regionDict.getFunctionId().intValue()==600) {//ans ip
|
if(regionDict.getFunctionId().intValue()==600) {//ans ip
|
||||||
if(asnNoMaps.get(0).size()>0) {
|
|
||||||
try {
|
|
||||||
//将未在缓存中找到对应config的asn no分配group ID
|
|
||||||
List<Integer> groupIds = ConfigServiceUtil.getId(2,asnNoMaps.get(0).size());
|
|
||||||
int ind=0;
|
|
||||||
for(Long key:asnNoMaps.get(0).keySet()) {
|
|
||||||
asnNoMaps.get(0).put(key, groupIds.get(ind));
|
|
||||||
ind++;
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
logger.info("获取编译ID出错");
|
|
||||||
throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
List<SysDataDictionaryItem> isImportAll=DictUtils.getDictList("IS_ASN_IP_IMPORT_ALL");
|
List<SysDataDictionaryItem> isImportAll=DictUtils.getDictList("IS_ASN_IP_IMPORT_ALL");
|
||||||
//处理组,新的组会在这里保存
|
//处理组,新的组会在这里保存
|
||||||
asnIpCfgService.processGroup(asnNoMaps.get(0));
|
if(!asnNoMaps.get(0).isEmpty()) {
|
||||||
|
asnIpCfgService.processGroup(asnNoMaps.get(0));
|
||||||
|
}
|
||||||
//全量下发,删除asnNo对应的已有的IP
|
//全量下发,删除asnNo对应的已有的IP
|
||||||
if(isImportAll.get(0).getItemCode().equals("1")) {
|
if(isImportAll.get(0).getItemCode().equals("1")) {
|
||||||
logger.warn("Delete and send ip reuse regions start");
|
logger.warn("Delete and send ip reuse regions start");
|
||||||
long _start=System.currentTimeMillis();
|
long _start=System.currentTimeMillis();
|
||||||
asnIpCfgService.deleteIps(asnNoMaps.get(1));
|
deleteIps(asnNoMaps.get(1));
|
||||||
// List<Future<Throwable>> list=Lists.newArrayList();
|
|
||||||
// ExecutorService service=Executors.newFixedThreadPool(Constants.SAVE_AND_DEL_THREAD_SIZE);
|
|
||||||
// BlockingQueue<Long> queue=new ArrayBlockingQueue<>(asnNoMaps.get(1).size());
|
|
||||||
// queue.addAll(asnNoMaps.get(1).keySet());
|
|
||||||
// for(int j=0;j<Constants.SAVE_AND_DEL_THREAD_SIZE;j++) {
|
|
||||||
// DeleteAsnIpTread t=new DeleteAsnIpTread(queue);
|
|
||||||
// list.add(service.submit(t));
|
|
||||||
// }
|
|
||||||
// service.shutdown();
|
|
||||||
// while(!service.isTerminated()) {
|
|
||||||
// Thread.sleep(10);
|
|
||||||
// }
|
|
||||||
// for(Future<Throwable> e:list) {
|
|
||||||
// if(e.get()!=null) {
|
|
||||||
// try {
|
|
||||||
// throw e.get();
|
|
||||||
// } catch (Throwable e1) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e1.printStackTrace();
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
long _end=System.currentTimeMillis();
|
long _end=System.currentTimeMillis();
|
||||||
logger.warn("Delete and send ip reuse regions end,cost:"+(_end-_start));
|
logger.warn("Delete and send ip reuse regions end,cost:"+(_end-_start));
|
||||||
}
|
}
|
||||||
Map<Long,Boolean> fullMap=Maps.newConcurrentMap();
|
|
||||||
for(Long asnNo:asnNoMaps.get(0).keySet()) {
|
|
||||||
fullMap.put(asnNo, false);
|
|
||||||
}
|
|
||||||
for(Long asnNo:asnNoMaps.get(1).keySet()) {
|
|
||||||
ConfigGroupInfo info=AsnCacheUtils.get(asnNo);
|
|
||||||
if(info==null) {
|
|
||||||
info=asnIpCfgService.getConfigGroupInfoByAsnNo(asnNo);
|
|
||||||
}
|
|
||||||
fullMap.put(asnNo, info.getIsIssued().intValue()==1);
|
|
||||||
}
|
|
||||||
// List<Future<Throwable>> list=Lists.newArrayList();
|
|
||||||
// ExecutorService service=Executors.newFixedThreadPool(Constants.SAVE_AND_DEL_THREAD_SIZE);
|
|
||||||
// for(int j=0;j<Constants.SAVE_AND_DEL_THREAD_SIZE;j++) {
|
|
||||||
// SaveAsnIpThread t=new SaveAsnIpThread(serviceDict, regionDict, requestId, ipPortCfgs);
|
|
||||||
// t.setAsnNoMaps(asnNoMaps);
|
|
||||||
// t.setFullMap(fullMap);
|
|
||||||
// list.add(service.submit(t));
|
|
||||||
// }
|
|
||||||
// service.shutdown();
|
|
||||||
// while(!service.isTerminated()) {
|
|
||||||
// Thread.sleep(10);
|
|
||||||
// }
|
|
||||||
// for(Future<Throwable> e:list) {
|
|
||||||
// if(e.get()!=null) {
|
|
||||||
// try {
|
|
||||||
// throw e.get();
|
|
||||||
// } catch (Throwable e1) {
|
|
||||||
// // TODO Auto-generated catch block
|
|
||||||
// e1.printStackTrace();
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
List<AsnIpCfg> asnIpCfgs=Lists.newArrayList(Constants.MAAT_JSON_SEND_SIZE);
|
List<AsnIpCfg> asnIpCfgs=Lists.newArrayList(Constants.MAAT_JSON_SEND_SIZE);
|
||||||
List<BaseIpCfg> _ipPortCfgs=Lists.newArrayList(Constants.MAAT_JSON_SEND_SIZE);
|
List<BaseIpCfg> _ipPortCfgs=Lists.newArrayList(Constants.MAAT_JSON_SEND_SIZE);
|
||||||
while(!ipPortCfgs.isEmpty()) {
|
while(!ipPortCfgs.isEmpty()) {
|
||||||
@@ -1553,17 +1495,21 @@ public class BaseController {
|
|||||||
AsnIpCfg _cfg=new AsnIpCfg();
|
AsnIpCfg _cfg=new AsnIpCfg();
|
||||||
BeanUtils.copyProperties(cfg, _cfg,new String[] {"cfgId"});
|
BeanUtils.copyProperties(cfg, _cfg,new String[] {"cfgId"});
|
||||||
_cfg.setTableName(AsnIpCfg.getTablename());
|
_cfg.setTableName(AsnIpCfg.getTablename());
|
||||||
_cfg.setAction(0);
|
_cfg.setAction(serviceDict==null?0:serviceDict.getAction());
|
||||||
_cfg.setCfgRegionCode(regionDict.getConfigRegionCode());
|
_cfg.setCfgRegionCode(regionDict.getConfigRegionCode());
|
||||||
_cfg.setCfgType(regionDict.getConfigRegionValue());
|
_cfg.setCfgType(regionDict.getConfigRegionValue());
|
||||||
_cfg.setCreateTime(date);
|
_cfg.setCreateTime(date);
|
||||||
_cfg.setCreatorId(UserUtils.getUser().getId());
|
_cfg.setCreatorId(UserUtils.getUser().getId());
|
||||||
_cfg.setDoLog(2);
|
_cfg.setDoLog(2);
|
||||||
_cfg.setFunctionId(regionDict.getFunctionId());
|
_cfg.setFunctionId(regionDict.getFunctionId());
|
||||||
_cfg.setIsAudit(0);
|
if(isSend.equals("1")) {
|
||||||
if(fullMap.get(Long.parseLong(_cfg.getUserRegion1()))) {
|
_cfg.setIsAudit(Constants.AUDIT_YES);
|
||||||
_cfg.setIsValid(Constants.VALID_YES);
|
_cfg.setIsValid(Constants.VALID_YES);
|
||||||
|
_cfg.setAuditorId(UserUtils.getUser().getId());
|
||||||
|
_cfg.setAuditTime(date);
|
||||||
|
|
||||||
}else {
|
}else {
|
||||||
|
_cfg.setIsAudit(Constants.AUDIT_NOT_YET);
|
||||||
_cfg.setIsValid(Constants.VALID_NO);
|
_cfg.setIsValid(Constants.VALID_NO);
|
||||||
}
|
}
|
||||||
_cfg.setIsAreaEffective(0);
|
_cfg.setIsAreaEffective(0);
|
||||||
@@ -1571,27 +1517,31 @@ public class BaseController {
|
|||||||
_cfg.setRequestId(StringUtil.isEmpty(requestId) ? 0 : requestId);
|
_cfg.setRequestId(StringUtil.isEmpty(requestId) ? 0 : requestId);
|
||||||
_cfg.setAttribute(attribute);
|
_cfg.setAttribute(attribute);
|
||||||
_cfg.setClassify(classify);
|
_cfg.setClassify(classify);
|
||||||
_cfg.setServiceId(0);
|
// _cfg.setServiceId(0);
|
||||||
|
_cfg.setServiceId(serviceDict==null?0:serviceDict.getServiceId());
|
||||||
//设置region id
|
//设置region id
|
||||||
if(regionIds!=null&®ionIds.size()==_ipPortCfgs.size()) {
|
if(regionIds!=null&®ionIds.size()==_ipPortCfgs.size()) {
|
||||||
_cfg.setRegionId(regionIds.get(ind));
|
_cfg.setRegionId(regionIds.get(ind));
|
||||||
}
|
}
|
||||||
//设置group id
|
//设置group id,compileId
|
||||||
if(asnNoMaps.get(0).containsKey(Long.parseLong(_cfg.getUserRegion1()))) {
|
if(asnNoMaps.get(0).containsKey(Long.parseLong(_cfg.getUserRegion1()))) {
|
||||||
_cfg.setAsnIpGroup(asnNoMaps.get(0).get(Long.parseLong(_cfg.getUserRegion1())));
|
_cfg.setAsnIpGroup(asnNoMaps.get(0).get(Long.parseLong(_cfg.getUserRegion1())).getGroupId());
|
||||||
|
_cfg.setCompileId(asnNoMaps.get(0).get(Long.parseLong(_cfg.getUserRegion1())).getCompileId());
|
||||||
}else if(asnNoMaps.get(1).containsKey(Long.parseLong(_cfg.getUserRegion1()))) {
|
}else if(asnNoMaps.get(1).containsKey(Long.parseLong(_cfg.getUserRegion1()))) {
|
||||||
_cfg.setAsnIpGroup(asnNoMaps.get(1).get(Long.parseLong(_cfg.getUserRegion1())));
|
_cfg.setAsnIpGroup(asnNoMaps.get(1).get(Long.parseLong(_cfg.getUserRegion1())).getGroupId());
|
||||||
|
_cfg.setCompileId(asnNoMaps.get(1).get(Long.parseLong(_cfg.getUserRegion1())).getCompileId());
|
||||||
}else {
|
}else {
|
||||||
ConfigGroupInfo info=AsnCacheUtils.get(Long.parseLong(_cfg.getUserRegion1()));
|
//AsnGroupInfo info=AsnCacheUtils.get(Long.parseLong(_cfg.getUserRegion1()));
|
||||||
if(info==null) {
|
AsnGroupInfo info=asnGroupInfos.get(Long.parseLong(_cfg.getUserRegion1()));
|
||||||
info=asnIpCfgService.getConfigGroupInfoByAsnNo(Long.parseLong(_cfg.getUserRegion1()));
|
if(info!=null) {
|
||||||
|
_cfg.setAsnIpGroup(info.getGroupId());
|
||||||
|
_cfg.setCompileId(info.getCompileId());
|
||||||
}
|
}
|
||||||
_cfg.setAsnIpGroup(info.getGroupId());
|
|
||||||
}
|
}
|
||||||
asnIpCfgs.add(_cfg);
|
asnIpCfgs.add(_cfg);
|
||||||
ind++;
|
ind++;
|
||||||
}
|
}
|
||||||
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, asnIpCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,isSend.equals("1"));
|
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, asnIpCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,asnNoMaps,isSend.equals("1"));
|
||||||
cfgIndexInfos.clear();
|
cfgIndexInfos.clear();
|
||||||
appPolicyCfgs.clear();
|
appPolicyCfgs.clear();
|
||||||
_ipPortCfgs.clear();
|
_ipPortCfgs.clear();
|
||||||
@@ -1734,7 +1684,7 @@ public class BaseController {
|
|||||||
}
|
}
|
||||||
ind++;
|
ind++;
|
||||||
}
|
}
|
||||||
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _ipPortCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,isSend.equals("1"));
|
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _ipPortCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,asnNoMaps,isSend.equals("1"));
|
||||||
cfgIndexInfos.clear();
|
cfgIndexInfos.clear();
|
||||||
appPolicyCfgs.clear();
|
appPolicyCfgs.clear();
|
||||||
_ipPortCfgs.clear();
|
_ipPortCfgs.clear();
|
||||||
@@ -1859,7 +1809,7 @@ public class BaseController {
|
|||||||
}
|
}
|
||||||
ind++;
|
ind++;
|
||||||
}
|
}
|
||||||
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _stringCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,isSend.equals("1"));
|
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _stringCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,asnNoMaps,isSend.equals("1"));
|
||||||
cfgIndexInfos.clear();
|
cfgIndexInfos.clear();
|
||||||
appPolicyCfgs.clear();
|
appPolicyCfgs.clear();
|
||||||
_stringCfgs.clear();
|
_stringCfgs.clear();
|
||||||
@@ -1970,7 +1920,7 @@ public class BaseController {
|
|||||||
}
|
}
|
||||||
ind++;
|
ind++;
|
||||||
}
|
}
|
||||||
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _complexkeywordCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,isSend.equals("1"));
|
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _complexkeywordCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,asnNoMaps,isSend.equals("1"));
|
||||||
cfgIndexInfos.clear();
|
cfgIndexInfos.clear();
|
||||||
appPolicyCfgs.clear();
|
appPolicyCfgs.clear();
|
||||||
_complexkeywordCfgs.clear();
|
_complexkeywordCfgs.clear();
|
||||||
@@ -2050,7 +2000,7 @@ public class BaseController {
|
|||||||
appFeatureIndexs.add(appfeature);
|
appFeatureIndexs.add(appfeature);
|
||||||
ind++;
|
ind++;
|
||||||
}
|
}
|
||||||
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _complexkeywordCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,isSend.equals("1"));
|
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _complexkeywordCfgs, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,asnNoMaps,isSend.equals("1"));
|
||||||
cfgIndexInfos.clear();
|
cfgIndexInfos.clear();
|
||||||
appPolicyCfgs.clear();
|
appPolicyCfgs.clear();
|
||||||
_complexkeywordCfgs.clear();
|
_complexkeywordCfgs.clear();
|
||||||
@@ -2092,7 +2042,7 @@ public class BaseController {
|
|||||||
cfg.setCompileId(compileIds.get(ind));
|
cfg.setCompileId(compileIds.get(ind));
|
||||||
ind++;
|
ind++;
|
||||||
}
|
}
|
||||||
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _dnsResStrategies, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,isSend.equals("1"));
|
ipCfgService.saveAndSend(regionDict, serviceDict, specificServiceCfg, _dnsResStrategies, cfgIndexInfos, appPolicyCfgs,appFeatureIndexs,asnNoMaps,isSend.equals("1"));
|
||||||
_dnsResStrategies.clear();
|
_dnsResStrategies.clear();
|
||||||
cfgIndexInfos.clear();
|
cfgIndexInfos.clear();
|
||||||
appPolicyCfgs.clear();
|
appPolicyCfgs.clear();
|
||||||
@@ -2123,6 +2073,48 @@ public class BaseController {
|
|||||||
long end=System.currentTimeMillis();
|
long end=System.currentTimeMillis();
|
||||||
logger.warn("import finish,cost:"+(end-start));
|
logger.warn("import finish,cost:"+(end-start));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void deleteIps(Map<Long,AsnGroupInfo> asnNoMap){
|
||||||
|
List<AsnIpCfg> toDelAndSendAsnIpCfgs=Lists.newArrayList();
|
||||||
|
List<Long> asnIds=Lists.newArrayList(asnNoMap.size());
|
||||||
|
for(Entry<Long, AsnGroupInfo> e:asnNoMap.entrySet()) {
|
||||||
|
AsnGroupInfo asnGroupInfo=e.getValue();
|
||||||
|
if(asnGroupInfo==null) {
|
||||||
|
asnGroupInfo=asnIpCfgService.getAsnGroupInfoByAsnNo(e.getKey());
|
||||||
|
}
|
||||||
|
if(asnGroupInfo.getIsValid()==1) {//已下发
|
||||||
|
List<AsnIpCfg> _toDelAsnIpCfgs=asnIpCfgService.getByAsnNo(asnGroupInfo.getAsnId());
|
||||||
|
toDelAndSendAsnIpCfgs.addAll(_toDelAsnIpCfgs);
|
||||||
|
}else {
|
||||||
|
asnIds.add(e.getKey());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if(asnIds.size()>0) {
|
||||||
|
asnIpCfgService.deleteByAsnNo(asnIds);
|
||||||
|
}
|
||||||
|
if(toDelAndSendAsnIpCfgs.size()>0) {
|
||||||
|
int pointsDataLimit = Constants.MAAT_JSON_SEND_SIZE;//限制条数
|
||||||
|
Integer size = toDelAndSendAsnIpCfgs.size();
|
||||||
|
//判断是否有必要分批
|
||||||
|
if(pointsDataLimit<size){
|
||||||
|
int part = size/pointsDataLimit;//分批数
|
||||||
|
for (int i = 0; i < part; i++) {
|
||||||
|
//pointsDataLimit条
|
||||||
|
List<AsnIpCfg> listPage = toDelAndSendAsnIpCfgs.subList(0, pointsDataLimit);
|
||||||
|
asnIpCfgService.delAndSend(listPage);
|
||||||
|
//剔除
|
||||||
|
toDelAndSendAsnIpCfgs.subList(0, pointsDataLimit).clear();
|
||||||
|
}
|
||||||
|
//最后剩下的
|
||||||
|
if(!toDelAndSendAsnIpCfgs.isEmpty()){
|
||||||
|
asnIpCfgService.delAndSend(toDelAndSendAsnIpCfgs);
|
||||||
|
|
||||||
|
}
|
||||||
|
}else {
|
||||||
|
asnIpCfgService.delAndSend(toDelAndSendAsnIpCfgs);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
/**
|
/**
|
||||||
* 加载模板
|
* 加载模板
|
||||||
* @param ei
|
* @param ei
|
||||||
@@ -2291,7 +2283,22 @@ public class BaseController {
|
|||||||
fileName = new String(fileName.getBytes("UTF-8"), "ISO8859-1");
|
fileName = new String(fileName.getBytes("UTF-8"), "ISO8859-1");
|
||||||
}
|
}
|
||||||
new ExportExcel(msgProp.getProperty(code, code),code,titleTime, headerList).ajaxDataList(dataList, code).write(response, fileName).dispose();
|
new ExportExcel(msgProp.getProperty(code, code),code,titleTime, headerList).ajaxDataList(dataList, code).write(response, fileName).dispose();
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
public void _ajaxCsv(HttpServletRequest request, HttpServletResponse response,
|
||||||
|
String code,String titleTime,List<String> headerList, List<List<String>> dataList)
|
||||||
|
throws Exception{
|
||||||
|
Properties msgProp = getMsgProp();
|
||||||
|
String fileName = msgProp.getProperty(code, code) + "_" + DateUtils.getDate("yyyyMMddHHmmss")
|
||||||
|
+ ".csv";
|
||||||
|
fileName = fileName.replaceAll(" ", "_");
|
||||||
|
if (request.getHeader("User-Agent").toUpperCase().indexOf("MSIE") > 0) {
|
||||||
|
fileName = URLEncoder.encode(fileName, "UTF-8");
|
||||||
|
} else {
|
||||||
|
fileName = new String(fileName.getBytes("UTF-8"), "ISO8859-1");
|
||||||
|
}
|
||||||
|
ExcelCsv.ajaxCSVFile(response,headerList,dataList,fileName,titleTime,msgProp);
|
||||||
}
|
}
|
||||||
|
|
||||||
public String initLogMap(BaseLogEntity log,String title){
|
public String initLogMap(BaseLogEntity log,String title){
|
||||||
@@ -2350,6 +2357,7 @@ public class BaseController {
|
|||||||
page.setOrderBy("");
|
page.setOrderBy("");
|
||||||
page.setPageSize(Constants.MAAT_JSON_SEND_SIZE);
|
page.setPageSize(Constants.MAAT_JSON_SEND_SIZE);
|
||||||
page.setPageNo(1);
|
page.setPageNo(1);
|
||||||
|
page.setLastPage(false);
|
||||||
//携带审核状态信息的BaseCfg
|
//携带审核状态信息的BaseCfg
|
||||||
BaseCfg auditBatchCfg=new BaseCfg();
|
BaseCfg auditBatchCfg=new BaseCfg();
|
||||||
//携带审核条件的BaseCfg
|
//携带审核条件的BaseCfg
|
||||||
@@ -2691,6 +2699,9 @@ public class BaseController {
|
|||||||
}
|
}
|
||||||
hasData=commonPolicyService.auditNtcMaatData(cfgList, page, auditBatchCfg,cfgFeatrureList, hasData);
|
hasData=commonPolicyService.auditNtcMaatData(cfgList, page, auditBatchCfg,cfgFeatrureList, hasData);
|
||||||
}
|
}
|
||||||
|
if(hasData) {
|
||||||
|
page.setPageNo(page.getNext());
|
||||||
|
}
|
||||||
}else{
|
}else{
|
||||||
hasData = false;
|
hasData = false;
|
||||||
}
|
}
|
||||||
@@ -2727,13 +2738,19 @@ public class BaseController {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}else{
|
}else{
|
||||||
//批量下发时,未下发过的app需要下发正常配置;已下发过的app需要下发ip复用配置(为保证事物,分两种方式下发)
|
|
||||||
//1028 app_ip_cfg
|
//1028 app_ip_cfg
|
||||||
|
//TODO 批量审核通过APP IP需要处理的问题:一批中存在一个APP 所有IP均未下发过的问题?待解决
|
||||||
|
//批量下发时,未下发过的app需要下发正常配置;已下发过的app需要下发ip复用配置(为保证事物,分两种方式下发)
|
||||||
if(auditBatchCfg.getServiceId().equals(1028)) {
|
if(auditBatchCfg.getServiceId().equals(1028)) {
|
||||||
if(true) {
|
/*if(true) {
|
||||||
|
page.setOrderBy("");
|
||||||
|
page.setPageSize(Constants.MAAT_JSON_SEND_SIZE);
|
||||||
|
page.setPageNo(1);
|
||||||
|
page.setLastPage(false);
|
||||||
|
|
||||||
boolean hasData = true;
|
boolean hasData = true;
|
||||||
while(hasData){
|
while(hasData){
|
||||||
/************预先获取已下发的groupid和compileid,且每批次重新获取,避免上一批次有新的compileId下发*************/
|
*//************预先获取已下发的groupid和compileid,且每批次重新获取,避免上一批次有新的compileId下发*************//*
|
||||||
Map<Integer, Integer> isIssuedCompileIds=new HashMap<>();
|
Map<Integer, Integer> isIssuedCompileIds=new HashMap<>();
|
||||||
//分组复用组信息1:app ip,2:内容,3:区域 ,4 asn
|
//分组复用组信息1:app ip,2:内容,3:区域 ,4 asn
|
||||||
ConfigGroupInfo groupInfo=new ConfigGroupInfo();
|
ConfigGroupInfo groupInfo=new ConfigGroupInfo();
|
||||||
@@ -2768,9 +2785,14 @@ public class BaseController {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if(auditBatchCfg.getIsValid().equals(1)) {
|
if(auditBatchCfg.getIsValid().equals(1)) {
|
||||||
|
page.setOrderBy("");
|
||||||
|
page.setPageSize(Constants.MAAT_JSON_SEND_SIZE);
|
||||||
|
page.setPageNo(1);
|
||||||
|
page.setLastPage(false);
|
||||||
|
|
||||||
boolean hasData = true;
|
boolean hasData = true;
|
||||||
while(hasData){
|
while(hasData){
|
||||||
/************预先获取未下发的groupid和compileid,********************/
|
*//************预先获取未下发的groupid和compileid,********************//*
|
||||||
//获取已下发的appcompileid
|
//获取已下发的appcompileid
|
||||||
Map<Integer, Integer> notIssuedCompileIds=new HashMap<>();
|
Map<Integer, Integer> notIssuedCompileIds=new HashMap<>();
|
||||||
//分组复用组信息1:app ip,2:内容,3:区域 ,4 asn
|
//分组复用组信息1:app ip,2:内容,3:区域 ,4 asn
|
||||||
@@ -2804,7 +2826,7 @@ public class BaseController {
|
|||||||
hasData = false;
|
hasData = false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}*/
|
||||||
}else {
|
}else {
|
||||||
boolean hasData = true;
|
boolean hasData = true;
|
||||||
while(hasData){
|
while(hasData){
|
||||||
|
|||||||
@@ -22,7 +22,7 @@
|
|||||||
from config_group_info
|
from config_group_info
|
||||||
where group_type =#{groupType}
|
where group_type =#{groupType}
|
||||||
</select>
|
</select>
|
||||||
<select id="findAllListByGroupIno" resultMap="configGroupInfoMap">
|
<select id="findAllListByGroupInfo" resultMap="configGroupInfoMap">
|
||||||
select
|
select
|
||||||
<include refid="columns"></include>
|
<include refid="columns"></include>
|
||||||
from config_group_info
|
from config_group_info
|
||||||
@@ -70,6 +70,10 @@
|
|||||||
select id,group_id,group_name,is_issued,insert_time,update_time,group_type,compile_id,asn_id
|
select id,group_id,group_name,is_issued,insert_time,update_time,group_type,compile_id,asn_id
|
||||||
from config_group_info where group_id= #{groupId}
|
from config_group_info where group_id= #{groupId}
|
||||||
</select>
|
</select>
|
||||||
|
<select id="getAsnGroupByName" resultType="com.nis.domain.specific.ConfigGroupInfo" parameterType="java.lang.String">
|
||||||
|
select id,group_id,group_name,is_issued,insert_time,update_time,group_type,compile_id,asn_id
|
||||||
|
from config_group_info where group_type=4 and group_name= #{groupName}
|
||||||
|
</select>
|
||||||
<!-- <select id="findPolicyGroupInfosByType" resultType="com.nis.domain.specific.ConfigGroupInfo" parameterType="java.lang.Integer">
|
<!-- <select id="findPolicyGroupInfosByType" resultType="com.nis.domain.specific.ConfigGroupInfo" parameterType="java.lang.Integer">
|
||||||
select id,group_id,group_name,is_issued,insert_time,update_time,group_type,compile_id,asn_id
|
select id,group_id,group_name,is_issued,insert_time,update_time,group_type,compile_id,asn_id
|
||||||
from config_group_info c where c.group_type= #{groupType}
|
from config_group_info c where c.group_type= #{groupType}
|
||||||
@@ -80,4 +84,7 @@
|
|||||||
<select id="getCountByType" resultType="java.lang.Long" parameterType="java.lang.Integer">
|
<select id="getCountByType" resultType="java.lang.Long" parameterType="java.lang.Integer">
|
||||||
select count(1) from config_group_info c where c.group_type=${groupType}
|
select count(1) from config_group_info c where c.group_type=${groupType}
|
||||||
</select>
|
</select>
|
||||||
|
<delete id="delAsnGroup" parameterType="java.lang.String">
|
||||||
|
delete from config_group_info where group_name=#{groupName} and group_type=4
|
||||||
|
</delete>
|
||||||
</mapper>
|
</mapper>
|
||||||
@@ -118,11 +118,11 @@ function update(url){
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
//处理asnIp,asn组下发过的ip配置不允许修改
|
//处理asnIp,asn组下发过的ip配置不允许修改
|
||||||
if(cked.attr("serviceGroupId")&&cked.attr("isValid")){
|
if(cked.attr("asnGroup")&&cked.attr("isValid")){
|
||||||
var serviceGroupId=cked.attr("serviceGroupId");
|
var asnGroup=cked.attr("asnGroup");
|
||||||
var _isValid=cked.attr("isValid");
|
var _isValid=cked.attr("isValid");
|
||||||
if(_isValid==1){
|
if(asnGroup&&_isValid==1){
|
||||||
top.$.jBox.tip("<spring:message code='can_not_edit_issued_ans_ip'/>", "<spring:message code='info'/>");
|
top.$.jBox.tip("<spring:message code='can_not_edit_issued_ans_group'/>", "<spring:message code='info'/>");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user