268 lines
8.6 KiB
Java
268 lines
8.6 KiB
Java
|
package com.nis.web.service.configuration;
|
|||
|
|
|
|||
|
|
|
|||
|
|
import java.util.ArrayList;
|
|||
|
|
import java.util.Date;
|
|||
|
|
import java.util.HashMap;
|
|||
|
|
import java.util.List;
|
|||
|
|
import java.util.Set;
|
|||
|
|
|
|||
|
|
import org.springframework.beans.BeanUtils;
|
|||
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|||
|
|
import org.springframework.stereotype.Service;
|
|||
|
|
import org.springframework.transaction.annotation.Transactional;
|
|||
|
|
|
|||
|
|
import com.nis.domain.Page;
|
|||
|
|
import com.nis.domain.basics.SysDictInfo;
|
|||
|
|
import com.nis.domain.callback.ProxyObjKeyring;
|
|||
|
|
import com.nis.domain.callback.ProxyObjTrustedCa;
|
|||
|
|
import com.nis.domain.callback.ProxyObjTrustedCaCrl;
|
|||
|
|
import com.nis.domain.configuration.AvFileSampleCfg;
|
|||
|
|
import com.nis.domain.configuration.PxyObjSpoofingIpPool;
|
|||
|
|
import com.nis.domain.configuration.PxyObjSpoofingIpPool;
|
|||
|
|
import com.nis.domain.configuration.PxyObjTrustedCaCrl;
|
|||
|
|
import com.nis.domain.maat.EffectiveRangeCfg;
|
|||
|
|
import com.nis.domain.maat.ToMaatResult;
|
|||
|
|
import com.nis.domain.maat.EffectiveRangeCfg.AreaIsp;
|
|||
|
|
import com.nis.exceptions.MaatConvertException;
|
|||
|
|
import com.nis.util.ConfigServiceUtil;
|
|||
|
|
import com.nis.util.Constants;
|
|||
|
|
import com.nis.util.StringUtil;
|
|||
|
|
import com.nis.util.StringUtils;
|
|||
|
|
import com.nis.web.dao.basics.ServiceDictInfoDao;
|
|||
|
|
import com.nis.web.dao.basics.SysDictInfoDao;
|
|||
|
|
import com.nis.web.dao.configuration.PxyObjSpoofingIpPoolDao;
|
|||
|
|
import com.nis.web.security.UserUtils;
|
|||
|
|
import com.nis.web.service.BaseService;
|
|||
|
|
import com.nis.web.service.SpringContextHolder;
|
|||
|
|
import com.nis.web.service.basics.SysDictInfoService;
|
|||
|
|
|
|||
|
|
import oracle.sql.ARRAY;
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 欺骗IP地址池管理
|
|||
|
|
* @author dell
|
|||
|
|
*
|
|||
|
|
*/
|
|||
|
|
@Service
|
|||
|
|
public class PxyObjSpoofingIpPoolService extends BaseService{
|
|||
|
|
@Autowired
|
|||
|
|
protected PxyObjSpoofingIpPoolDao pxyObjSpoofingIpPoolDao;
|
|||
|
|
@Autowired
|
|||
|
|
private SysDictInfoDao sysDictInfoDao;
|
|||
|
|
/**
|
|||
|
|
* @param entity
|
|||
|
|
* @return
|
|||
|
|
*/
|
|||
|
|
public PxyObjSpoofingIpPool getPxyObjSpoofingIpPool(Long cfgId) {
|
|||
|
|
return pxyObjSpoofingIpPoolDao.getPxyObjSpoofingIpPool(cfgId);
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
* 查询分页数据
|
|||
|
|
* @param page 分页对象
|
|||
|
|
* @param entity
|
|||
|
|
* @return
|
|||
|
|
*/
|
|||
|
|
public Page<PxyObjSpoofingIpPool> findPage(Page page, PxyObjSpoofingIpPool entity) {
|
|||
|
|
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(),"r"));
|
|||
|
|
entity.setPage(page);
|
|||
|
|
List<PxyObjSpoofingIpPool> list=pxyObjSpoofingIpPoolDao.findPage(entity);
|
|||
|
|
page.setList(list);
|
|||
|
|
return page;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
public List<PxyObjSpoofingIpPool> findPxyObjSpoofingIpPools(PxyObjSpoofingIpPool entity) {
|
|||
|
|
List<PxyObjSpoofingIpPool> list=pxyObjSpoofingIpPoolDao.findList(entity);
|
|||
|
|
return list;
|
|||
|
|
}
|
|||
|
|
//新增或保存
|
|||
|
|
@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
|
|||
|
|
public void saveOrUpdate(PxyObjSpoofingIpPool entity){
|
|||
|
|
Date createTime=new Date();
|
|||
|
|
setAreaEffectiveIds(entity);
|
|||
|
|
entity.setIsValid(0);
|
|||
|
|
entity.setIsAudit(0);
|
|||
|
|
//设置区域运营商信息
|
|||
|
|
setAreaEffectiveIds(entity);
|
|||
|
|
//新增
|
|||
|
|
if(StringUtil.isEmpty(entity.getCfgId())){
|
|||
|
|
entity.setCreatorId(UserUtils.getUser().getId());
|
|||
|
|
entity.setCreateTime(createTime);
|
|||
|
|
//调用服务接口获取compileId
|
|||
|
|
List<Integer> compileIds = new ArrayList<Integer>();
|
|||
|
|
try {
|
|||
|
|
compileIds = ConfigServiceUtil.getId(1,1);
|
|||
|
|
} catch (Exception e) {
|
|||
|
|
e.printStackTrace();
|
|||
|
|
logger.info("获取编译ID出错");
|
|||
|
|
throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
|
|||
|
|
}
|
|||
|
|
if(compileIds != null && compileIds.size() >0 && compileIds.get(0) != 0){
|
|||
|
|
entity.setCompileId(compileIds.get(0));
|
|||
|
|
}
|
|||
|
|
pxyObjSpoofingIpPoolDao.insert(entity);
|
|||
|
|
//修改
|
|||
|
|
}else{
|
|||
|
|
Date editTime=new Date();
|
|||
|
|
entity.setEditorId(UserUtils.getUser().getId());
|
|||
|
|
entity.setEditTime(editTime);
|
|||
|
|
pxyObjSpoofingIpPoolDao.update(entity);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
*
|
|||
|
|
* @param isAudit
|
|||
|
|
* @param isValid
|
|||
|
|
* @param ids compileIds
|
|||
|
|
*/
|
|||
|
|
@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
|
|||
|
|
public void delete(Integer isAudit,Integer isValid,String ids,Integer functionId){
|
|||
|
|
String[] idArray = ids.split(",");
|
|||
|
|
for(String id :idArray){
|
|||
|
|
PxyObjSpoofingIpPool entity = new PxyObjSpoofingIpPool();
|
|||
|
|
entity.setCfgId(Long.valueOf(id));
|
|||
|
|
entity.setFunctionId(functionId);
|
|||
|
|
entity.setIsAudit(isAudit);
|
|||
|
|
entity.setIsValid(isValid);
|
|||
|
|
entity.setEditorId(UserUtils.getUser().getId());
|
|||
|
|
entity.setEditTime(new Date());
|
|||
|
|
pxyObjSpoofingIpPoolDao.update(entity);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/**
|
|||
|
|
*
|
|||
|
|
* @param isAudit
|
|||
|
|
* @param isValid
|
|||
|
|
* @param ids cfgId
|
|||
|
|
* @param functionId
|
|||
|
|
*/
|
|||
|
|
@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
|
|||
|
|
public void audit(Integer isAudit,Integer isValid,Integer functionId,String id,Date auditTime){
|
|||
|
|
PxyObjSpoofingIpPool entity=new PxyObjSpoofingIpPool();
|
|||
|
|
entity.setCfgId(Long.valueOf(id));
|
|||
|
|
entity.setIsValid(isValid);
|
|||
|
|
entity.setIsAudit(isAudit);
|
|||
|
|
entity.setEditTime(auditTime);
|
|||
|
|
entity.setEditorId(UserUtils.getUser().getId());
|
|||
|
|
entity.setAuditorId(UserUtils.getUser().getId());
|
|||
|
|
entity.setAuditTime(auditTime);
|
|||
|
|
pxyObjSpoofingIpPoolDao.update(entity);
|
|||
|
|
entity=pxyObjSpoofingIpPoolDao.getPxyObjSpoofingIpPool(entity.getCfgId());
|
|||
|
|
List<PxyObjSpoofingIpPool> list = new ArrayList<PxyObjSpoofingIpPool>();
|
|||
|
|
String json="";
|
|||
|
|
String areaEffectiveIds="0";
|
|||
|
|
if(entity.getIsAudit()==1){
|
|||
|
|
if(!StringUtils.isEmpty(entity.getAreaEffectiveIds())){
|
|||
|
|
// 组织区域、运营商配置下发格式
|
|||
|
|
areaEffectiveIds = this.setEffectiveRange(entity.getAreaEffectiveIds());
|
|||
|
|
}
|
|||
|
|
entity.setAreaEffectiveIds(areaEffectiveIds);
|
|||
|
|
list.add(entity);
|
|||
|
|
//调用服务接口下发配置数据
|
|||
|
|
json=gsonToJson(list);
|
|||
|
|
logger.info("欺骗IP池配置下发配置参数："+json);
|
|||
|
|
//调用服务接口下发配置
|
|||
|
|
try {
|
|||
|
|
ToMaatResult result = ConfigServiceUtil.postCallbackCfg(json);
|
|||
|
|
if(result!=null){
|
|||
|
|
logger.info("欺骗IP池配置下发响应信息："+result.getMsg());
|
|||
|
|
}
|
|||
|
|
} catch (Exception e) {
|
|||
|
|
logger.error("欺骗IP池配置配置下发失败",e);
|
|||
|
|
throw e;
|
|||
|
|
}
|
|||
|
|
}else if(entity.getIsAudit()==3){
|
|||
|
|
PxyObjSpoofingIpPool cfg = new PxyObjSpoofingIpPool();
|
|||
|
|
cfg.setIsValid(0);
|
|||
|
|
cfg.setCompileId(entity.getCompileId());
|
|||
|
|
cfg.setServiceId(entity.getServiceId());
|
|||
|
|
list.add(cfg);
|
|||
|
|
//调用服务接口取消配置
|
|||
|
|
json=gsonToJson(list);
|
|||
|
|
logger.info("欺骗IP池配置配置参数："+json);
|
|||
|
|
//调用服务接口取消配置
|
|||
|
|
try {
|
|||
|
|
ToMaatResult result = ConfigServiceUtil.put(json, 2);
|
|||
|
|
logger.info("欺骗IP池配置响应信息："+result.getMsg());
|
|||
|
|
} catch (Exception e) {
|
|||
|
|
e.printStackTrace();
|
|||
|
|
logger.info("欺骗IP池配置配置失败");
|
|||
|
|
throw e;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
public String setEffectiveRange(String areaEffectiveIds){
|
|||
|
|
HashMap<String, List<String>> map = new HashMap<String,List<String>>();
|
|||
|
|
List<String> ispList = new ArrayList();
|
|||
|
|
for (String areaEffectiveId : StringUtils.split(areaEffectiveIds, ",")) {
|
|||
|
|
if(areaEffectiveId.contains(":")) {
|
|||
|
|
// 区域和运营商
|
|||
|
|
int index = areaEffectiveId.indexOf(":");
|
|||
|
|
String areaCode = areaEffectiveId.substring(0, index);
|
|||
|
|
String ispCode = areaEffectiveId.substring(index+1);
|
|||
|
|
|
|||
|
|
if(!map.containsKey(areaCode)){
|
|||
|
|
ispList = new ArrayList();
|
|||
|
|
ispList.add(ispCode);
|
|||
|
|
map.put(areaCode, ispList);
|
|||
|
|
}else{
|
|||
|
|
if(!ispList.contains(ispCode)){
|
|||
|
|
ispList.add(ispCode);
|
|||
|
|
}
|
|||
|
|
map.replace(areaCode, ispList);
|
|||
|
|
}
|
|||
|
|
}else {
|
|||
|
|
// 区域
|
|||
|
|
if(!map.containsKey(areaEffectiveId)){
|
|||
|
|
map.put(areaEffectiveId, null);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
EffectiveRangeCfg rangeCfg = new EffectiveRangeCfg();
|
|||
|
|
List<List<AreaIsp>> effectiveRangeList = new ArrayList();
|
|||
|
|
Set<String> keySet = map.keySet();
|
|||
|
|
for (String key : keySet) {
|
|||
|
|
AreaIsp area = new AreaIsp();
|
|||
|
|
area.setTag(Constants.AREA_TAG);
|
|||
|
|
AreaIsp isp = new AreaIsp();
|
|||
|
|
isp.setTag(Constants.ISP_TAG);
|
|||
|
|
List<String> locaValueList = new ArrayList();
|
|||
|
|
List<String> ispValueList = new ArrayList();
|
|||
|
|
List<AreaIsp> areaIspList = new ArrayList();
|
|||
|
|
// 获取区域信息
|
|||
|
|
String areaStr = "";
|
|||
|
|
SysDictInfo areaDict = sysDictInfoDao.getDictByItemCode(key);
|
|||
|
|
areaStr += areaDict.getItemValue();
|
|||
|
|
while(areaDict.getParent().getSysDictId() != 0) {
|
|||
|
|
areaDict = sysDictInfoDao.getDictById(areaDict.getParent().getSysDictId());
|
|||
|
|
areaStr += "/"+areaDict.getItemValue();
|
|||
|
|
}
|
|||
|
|
locaValueList.add(StringUtils.revertStr(areaStr, "/"));
|
|||
|
|
area.setValue(locaValueList);
|
|||
|
|
areaIspList.add(area);
|
|||
|
|
|
|||
|
|
// 获取运营商信息
|
|||
|
|
if(map.get(key) != null){
|
|||
|
|
for (String ispCode : map.get(key)) {
|
|||
|
|
SysDictInfo ispDict = sysDictInfoDao.getDictByItemCode(ispCode);
|
|||
|
|
ispValueList.add(ispDict.getItemValue());
|
|||
|
|
}
|
|||
|
|
isp.setValue(ispValueList);
|
|||
|
|
areaIspList.add(isp);
|
|||
|
|
}
|
|||
|
|
effectiveRangeList.add(areaIspList);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
rangeCfg.setEffectiveRangeList(effectiveRangeList);
|
|||
|
|
return gsonToJson(rangeCfg);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|