This repository has been archived on 2025-09-14. You can view files and clone it, but cannot push or open issues or pull requests.
Files
k18-ntcs-web-ntc/src/main/java/com/nis/web/service/configuration/AppCfgService.java

1828 lines
71 KiB
Java
Raw Normal View History

package com.nis.web.service.configuration;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
2018-06-22 18:46:01 +08:00
import java.util.Map;
2018-06-22 18:46:01 +08:00
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;
2018-06-22 18:46:01 +08:00
import com.nis.domain.configuration.AppByteCfg;
import com.nis.domain.configuration.AppDomainCfg;
import com.nis.domain.configuration.AppHeaderCfg;
2018-06-22 18:46:01 +08:00
import com.nis.domain.configuration.AppHttpCfg;
import com.nis.domain.configuration.AppIpCfg;
import com.nis.domain.configuration.AppPolicyCfg;
import com.nis.domain.configuration.AppSslCertCfg;
2018-08-24 10:25:01 +08:00
import com.nis.domain.configuration.AppTcpCfg;
2018-08-23 17:07:09 +08:00
import com.nis.domain.configuration.AppTopicDomainCfg;
2018-06-22 18:46:01 +08:00
import com.nis.domain.configuration.AreaIpCfg;
import com.nis.domain.configuration.IpPortCfg;
2018-08-21 18:00:20 +08:00
import com.nis.domain.configuration.NtcSubscribeIdCfg;
2018-08-29 22:46:49 +08:00
import com.nis.domain.configuration.WebsiteDomainTopic;
2018-06-22 18:46:01 +08:00
import com.nis.domain.maat.MaatCfg;
import com.nis.domain.maat.MaatCfg.DigestCfg;
import com.nis.domain.maat.MaatCfg.GroupCfg;
import com.nis.domain.maat.MaatCfg.IpCfg;
import com.nis.domain.maat.MaatCfg.NumBoundaryCfg;
import com.nis.domain.maat.MaatCfg.StringCfg;
import com.nis.domain.maat.ToMaatBean;
import com.nis.domain.maat.ToMaatResult;
2018-06-22 18:46:01 +08:00
import com.nis.exceptions.MaatConvertException;
import com.nis.util.ConfigServiceUtil;
import com.nis.util.Constants;
import com.nis.util.DictUtils;
import com.nis.util.StringUtil;
import com.nis.util.StringUtils;
import com.nis.web.dao.configuration.AppCfgDao;
2018-06-22 18:46:01 +08:00
import com.nis.web.dao.configuration.AreaIpCfgDao;
2018-08-21 18:00:20 +08:00
import com.nis.web.dao.configuration.StringCfgDao;
2018-06-22 18:46:01 +08:00
import com.nis.web.security.UserUtils;
import com.nis.web.service.BaseService;
/**
* 特定协议相关配置事务类
2018-08-24 15:32:11 +08:00
*
* @author dell
*
*/
@Service
2018-06-22 18:46:01 +08:00
public class AppCfgService extends BaseService {
@Autowired
protected AppCfgDao appCfgDao;
@Autowired
2018-06-22 18:46:01 +08:00
protected AreaIpCfgDao areaIpCfgDao;
2018-08-21 18:00:20 +08:00
@Autowired
protected StringCfgDao stringcfgDao;
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
public Page<AppPolicyCfg> findAppPolicyList(Page<AppPolicyCfg> page, AppPolicyCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
entity.setPage(page);
2018-06-22 18:46:01 +08:00
List<AppPolicyCfg> list = appCfgDao.findAppPolicyList(entity);
page.setList(list);
return page;
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
public Page<AppIpCfg> findAppIpList(Page<AppIpCfg> page, AppIpCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
2018-06-22 18:46:01 +08:00
entity.setPage(page);
List<AppIpCfg> list = appCfgDao.findAppIpList(entity);
page.setList(list);
return page;
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
public Page<AppHttpCfg> findAppHttpList(Page<AppHttpCfg> page, AppHttpCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
2018-06-22 18:46:01 +08:00
entity.setPage(page);
List<AppHttpCfg> list = appCfgDao.findAppHttpList(entity);
page.setList(list);
return page;
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
public Page<AppDomainCfg> findAppDomainList(Page<AppDomainCfg> page, AppDomainCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
2018-06-22 18:46:01 +08:00
entity.setPage(page);
List<AppDomainCfg> list = appCfgDao.findAppDomainList(entity);
page.setList(list);
return page;
}
2018-08-24 15:32:11 +08:00
// 主题网站列表
2018-08-23 17:07:09 +08:00
public Page<AppTopicDomainCfg> findAppTopicDomainList(Page<AppTopicDomainCfg> page, AppTopicDomainCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
2018-08-23 17:07:09 +08:00
entity.setPage(page);
List<AppTopicDomainCfg> list = appCfgDao.findAppTopicDomainList(entity);
page.setList(list);
return page;
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
public Page<AppByteCfg> findAppByteList(Page<AppByteCfg> page, AppByteCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
2018-06-22 18:46:01 +08:00
entity.setPage(page);
List<AppByteCfg> list = appCfgDao.findAppByteList(entity);
page.setList(list);
return page;
}
2018-08-24 15:32:11 +08:00
public Page<AppSslCertCfg> findAppSslList(Page<AppSslCertCfg> page, AppSslCertCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
entity.setPage(page);
List<AppSslCertCfg> list = appCfgDao.findAppSslList(entity);
page.setList(list);
return page;
}
2018-08-24 10:25:01 +08:00
public Page<AppTcpCfg> findAppTcpList(Page<AppTcpCfg> page, AppTcpCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
2018-08-24 10:25:01 +08:00
entity.setPage(page);
List<AppTcpCfg> list = appCfgDao.findAppTcpList(entity);
page.setList(list);
return page;
}
2018-08-24 15:32:11 +08:00
public AppTcpCfg getAppTcpCfg(Long cfgId) {
2018-08-24 10:25:01 +08:00
return appCfgDao.getAppTcpCfg(cfgId);
}
2018-08-24 15:32:11 +08:00
public AppPolicyCfg getAppPolicyCfg(Long cfgId) {
AppPolicyCfg policy = appCfgDao.getAppPolicyCfg(cfgId);
List<IpPortCfg> ipPortList = appCfgDao.getAppPolicyIpList(policy);
2018-08-24 15:32:11 +08:00
// 查询关键字
if (policy.getCompileId() != null) {
2018-08-21 18:00:20 +08:00
NtcSubscribeIdCfg ntcSubscribeIdCfg = new NtcSubscribeIdCfg();
ntcSubscribeIdCfg.setCompileId(policy.getCompileId());
List<NtcSubscribeIdCfg> ntcList = stringcfgDao.findSubscribeIdCfgList(ntcSubscribeIdCfg);
policy.setNtcSubscribeIdCfgList(ntcList);
}
2018-08-24 15:32:11 +08:00
policy.setIpPortList(ipPortList);
return policy;
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
public AppIpCfg getAppIpCfg(Long cfgId) {
2018-06-22 18:46:01 +08:00
return appCfgDao.getAppIpCfg(cfgId);
}
2018-08-24 15:32:11 +08:00
public AppHttpCfg getAppHttpCfg(Long cfgId) {
2018-06-22 18:46:01 +08:00
return appCfgDao.getAppHttpCfg(cfgId);
}
2018-08-24 15:32:11 +08:00
public AppDomainCfg getAppDomainCfg(Long cfgId) {
2018-06-22 18:46:01 +08:00
return appCfgDao.getAppDomainCfg(cfgId);
}
2018-08-24 15:32:11 +08:00
// 主题网站form
public AppTopicDomainCfg getAppTopicDomainCfg(Long cfgId) {
2018-08-23 17:07:09 +08:00
return appCfgDao.getAppTopicDomainCfg(cfgId);
}
2018-08-24 15:32:11 +08:00
public AppByteCfg getAppByteCfg(Long cfgId) {
2018-06-22 18:46:01 +08:00
return appCfgDao.getAppByteCfg(cfgId);
}
2018-08-24 15:32:11 +08:00
public AppSslCertCfg getAppSslCfg(Long cfgId) {
return appCfgDao.getAppSslCfg(cfgId);
}
2018-08-24 15:32:11 +08:00
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveOrUpdateAppPolicyCfg(AppPolicyCfg entity) throws Exception {
// 设置区域运营商信息
2018-06-22 18:46:01 +08:00
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
2018-06-22 18:46:01 +08:00
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
2018-06-22 18:46:01 +08:00
compileId = idList.get(0);
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
}
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
entity.setIsValid(0);
entity.setIsAudit(0);
// 设置SubscribeID域配置参数
if (entity != null && entity.getNtcSubscribeIdCfgList() != null) {
for (NtcSubscribeIdCfg cfg : entity.getNtcSubscribeIdCfgList()) {
entity.setExprType(cfg.getExprType());
entity.setIsHexbin(cfg.getIsHexbin());
entity.setMatchMethod(cfg.getMatchMethod());
entity.setCfgKeywords(cfg.getCfgKeywords());
}
2018-08-24 15:32:11 +08:00
}
entity.initDefaultValue();
appCfgDao.insertAppPolicyCfg(entity);
// 保存策略IP配置
if (entity != null && entity.getIpPortList() != null) {
for (IpPortCfg cfg : entity.getIpPortList()) {
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgRegionCode", "cfgType" });
appCfgDao.insertAppPolicyIpCfg(cfg);
}
2018-08-24 15:32:11 +08:00
}
// 保存关键字配置
if (entity != null && entity.getNtcSubscribeIdCfgList() != null) {
for (NtcSubscribeIdCfg cfg : entity.getNtcSubscribeIdCfgList()) {
if (StringUtils.isNotBlank(cfg.getCfgKeywords())) {
entity.setCfgKeywords(cfg.getCfgKeywords());
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgRegionCode", "cfgType" });
stringcfgDao.saveSubscribeIdCfg(cfg);
}
}
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
} else {
2018-06-22 18:46:01 +08:00
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
2018-08-24 15:32:11 +08:00
// 设置SubscribeID域配置参数
if (entity != null && entity.getNtcSubscribeIdCfgList() != null) {
for (NtcSubscribeIdCfg cfg : entity.getNtcSubscribeIdCfgList()) {
entity.setExprType(cfg.getExprType());
entity.setIsHexbin(cfg.getIsHexbin());
entity.setMatchMethod(cfg.getMatchMethod());
}
}
appCfgDao.updateAppPolicyCfg(entity);
2018-08-25 17:07:34 +08:00
// 先删后加 各域配置
appCfgDao.deleteAppPolicyIpCfg(entity);
2018-08-25 17:07:34 +08:00
appCfgDao.deleteSubscribeIdCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
2018-08-24 15:32:11 +08:00
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存策略IP配置
if (entity.getIpPortList() != null) {
for (IpPortCfg cfg : entity.getIpPortList()) {
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgRegionCode", "cfgType" });
appCfgDao.insertAppPolicyIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
if (entity != null && entity.getNtcSubscribeIdCfgList() != null) {
for (NtcSubscribeIdCfg cfg : entity.getNtcSubscribeIdCfgList()) {
if (StringUtils.isNotBlank(cfg.getCfgKeywords())) {
entity.setCfgKeywords(cfg.getCfgKeywords());
BeanUtils.copyProperties(entity, cfg,
new String[] { "cfgRegionCode", "cfgType", "exprType", "matchMethod", "isHexbin" });
stringcfgDao.saveSubscribeIdCfg(cfg);
}
}
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
}
2018-08-24 15:32:11 +08:00
}
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveOrUpdateAppIpCfg(AppIpCfg entity) throws Exception {
// 设置区域运营商信息
2018-06-22 18:46:01 +08:00
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
2018-06-22 18:46:01 +08:00
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
2018-06-22 18:46:01 +08:00
compileId = idList.get(0);
}
2018-06-22 18:46:01 +08:00
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
2018-08-24 15:32:11 +08:00
appCfgDao.insertAppIpCfg(entity);
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
BeanUtils.copyProperties(entity, cfg,
2018-08-24 15:32:11 +08:00
new String[] { "cfgRegionCode", "cfgType", "ipType", "isAreaEffective",
"areaEffectiveIds", "protocol", "portPattern", "srcPort", "destPort",
"direction", "destIpAddress", "srcIpAddress", "ipPattern" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
2018-06-22 18:46:01 +08:00
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
}
2018-08-24 15:32:11 +08:00
} else {
2018-06-22 18:46:01 +08:00
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.updateAppIpCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg,
new String[] { "cfgRegionCode", "cfgType", "ipType", "isAreaEffective", "areaEffectiveIds",
"protocol", "portPattern", "srcPort", "destPort", "direction", "destIpAddress",
"srcIpAddress", "ipPattern" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
}
2018-08-24 15:32:11 +08:00
}
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveOrUpdateAppHttpCfg(AppHttpCfg entity) throws Exception {
// 设置区域运营商信息
2018-06-22 18:46:01 +08:00
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
2018-06-22 18:46:01 +08:00
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
2018-06-22 18:46:01 +08:00
compileId = idList.get(0);
}
2018-06-22 18:46:01 +08:00
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.insertAppHttpCfg(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
2018-06-22 18:46:01 +08:00
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
}
2018-08-24 15:32:11 +08:00
} else {
2018-06-22 18:46:01 +08:00
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.updateAppHttpCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveOrUpdateAppDomainCfg(AppDomainCfg entity) throws Exception {
// 设置区域运营商信息
2018-06-22 18:46:01 +08:00
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
2018-06-22 18:46:01 +08:00
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
2018-06-22 18:46:01 +08:00
compileId = idList.get(0);
}
2018-06-22 18:46:01 +08:00
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
2018-08-24 15:32:11 +08:00
appCfgDao.insertAppDomainCfg(entity);
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
2018-06-22 18:46:01 +08:00
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
}
2018-08-24 15:32:11 +08:00
} else {
2018-06-22 18:46:01 +08:00
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.updateAppDomainCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
}
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
// 主题网站新增 修改
public void saveOrUpdateAppTopicDomainCfg(AppTopicDomainCfg entity) throws Exception {
// 设置区域运营商信息
2018-08-23 17:07:09 +08:00
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
2018-08-23 17:07:09 +08:00
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
2018-08-23 17:07:09 +08:00
compileId = idList.get(0);
}
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
entity.setIsValid(0);
entity.setIsAudit(0);
2018-08-24 15:32:11 +08:00
appCfgDao.insertAppTopicDomainCfg(entity);
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
2018-08-23 17:07:09 +08:00
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
2018-08-23 17:07:09 +08:00
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
2018-08-23 17:07:09 +08:00
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
}
2018-08-24 15:32:11 +08:00
} else {
2018-08-23 17:07:09 +08:00
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.updateAppTopicDomainCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
2018-08-23 17:07:09 +08:00
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
2018-08-23 17:07:09 +08:00
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
2018-08-23 17:07:09 +08:00
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
}
}
2018-08-24 15:32:11 +08:00
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveOrUpdateAppByteCfg(AppByteCfg entity) throws Exception {
// 设置区域运营商信息
2018-06-22 18:46:01 +08:00
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
2018-06-22 18:46:01 +08:00
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
2018-06-22 18:46:01 +08:00
compileId = idList.get(0);
}
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
2018-08-24 15:32:11 +08:00
appCfgDao.insertAppByteCfg(entity);
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
2018-06-22 18:46:01 +08:00
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
} else {
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
2018-06-23 17:29:14 +08:00
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.updateAppByteCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveOrUpdateAppSslCfg(AppSslCertCfg entity) throws Exception {
// 设置区域运营商信息
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
compileId = idList.get(0);
}
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.insertAppSslCfg(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
}
2018-08-24 15:32:11 +08:00
} else {
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.updateAppSslCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveOrUpdateAppTcpeCfg(AppTcpCfg entity) throws Exception {
// 设置区域运营商信息
2018-08-24 10:25:01 +08:00
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
2018-08-24 10:25:01 +08:00
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
2018-08-24 10:25:01 +08:00
compileId = idList.get(0);
}
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
entity.setIsValid(0);
entity.setIsAudit(0);
2018-08-24 15:32:11 +08:00
appCfgDao.insertAppTcpCfg(entity);
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
2018-08-24 10:25:01 +08:00
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
2018-08-24 10:25:01 +08:00
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
2018-08-24 10:25:01 +08:00
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
}
2018-08-24 15:32:11 +08:00
} else {
2018-08-24 10:25:01 +08:00
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.updateAppTcpCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
2018-08-24 10:25:01 +08:00
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
2018-08-24 10:25:01 +08:00
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
2018-08-24 10:25:01 +08:00
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
}
}
2018-08-24 15:32:11 +08:00
public void auditAppTcpCfg(AppTcpCfg entity, Integer isAudit) {
ToMaatBean maatBean = new ToMaatBean();
2018-08-24 10:25:01 +08:00
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
List<IpCfg> areaIpRegionList = new ArrayList();
entity.setTableName(AppTcpCfg.getTablename());
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
2018-08-24 10:25:01 +08:00
List<AppTcpCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(numRegionList, list, 4, entity, groupRelationList);
groupRelationList = map.get("groupList");
numRegionList = map.get("dstList");
2018-08-24 10:25:01 +08:00
}
2018-08-24 15:32:11 +08:00
/*
* //保存区域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()); appCfgDao.auditCfg(cfg);
* if(isAudit==1){ Map<String,List> map =
* cfgConvert(areaIpRegionList,areaIpCfgList,4,entity,groupRelationList);
* groupRelationList=map.get("groupList"); areaIpRegionList=map.get("dstList");
* } }
*/
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
2018-08-24 10:25:01 +08:00
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
// 设置APP自定义域
String userRegion = "APP_ID=" + entity.getAppCode();
2018-08-24 10:25:01 +08:00
maatCfg.setUserRegion(userRegion);
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app SSL配置下发配置参数" + json);
// 调用服务接口下发配置
2018-08-24 10:25:01 +08:00
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app TCP配置下发响应信息" + result.getMsg());
2018-08-24 10:25:01 +08:00
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
2018-08-24 10:25:01 +08:00
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
maatCfg.setIsValid(0);// 无效
2018-08-24 10:25:01 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app TCP配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app TCP配置取消配置响应信息" + result.getMsg());
2018-08-24 10:25:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
public void auditAppPolicyCfg(AppPolicyCfg entity, Integer isAudit) {
String configType = entity.getConfigType();
ToMaatBean maatBean = new ToMaatBean();
2018-06-22 18:46:01 +08:00
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
2018-08-24 15:32:11 +08:00
List<IpCfg> areaIpRegionList = new ArrayList();
2018-06-22 18:46:01 +08:00
entity.setTableName(AppPolicyCfg.getTablename());
2018-08-24 15:32:11 +08:00
List<NtcSubscribeIdCfg> ntcList = new ArrayList();
2018-06-22 18:46:01 +08:00
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
// 更新关键字表状态
if (entity.getCompileId() != null) {
NtcSubscribeIdCfg ntc = new NtcSubscribeIdCfg();
ntc.setCompileId(entity.getCompileId());
ntc.setIsAudit(entity.getIsAudit());
ntc.setIsValid(entity.getIsValid());
ntc.setAuditorId(UserUtils.getUser().getId());
ntc.setAuditTime(entity.getAuditTime());
stringcfgDao.updateSubscribeIdCfg(ntc);
}
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
StringBuffer cfgKeywords = new StringBuffer();
if (entity.getBehavCode() != null) {
if (Constants.SPECIFIC_SERVICE_CFG_TYPE_APP.equalsIgnoreCase(configType)) {
cfgKeywords.append(Constants.APP_ID_REGION + "=" + entity.getAppCode());
} else if (Constants.SPECIFIC_SERVICE_CFG_TYPE_ENCRYPTED_TUNNEL_BEHAVIOR.equalsIgnoreCase(configType)
|| Constants.SPECIFIC_SERVICE_CFG_TYPE_BASIC_PROTOCOL.equalsIgnoreCase(configType)) {
cfgKeywords.append(Constants.PROTO_ID_REGION + "=" + entity.getAppCode());
}
cfgKeywords.append(Constants.KEYWORD_EXPR);
2018-08-24 15:32:11 +08:00
cfgKeywords.append(Constants.BEHAV_ID_REGION + "=" + entity.getBehavCode());
// entity.setCfgKeywords(entity.getAppCode()+Constants.KEYWORD_EXPR+entity.getBehavCode());
} else {
if (Constants.SPECIFIC_SERVICE_CFG_TYPE_APP.equalsIgnoreCase(configType)) {
cfgKeywords.append(Constants.APP_ID_REGION + "=" + entity.getAppCode());
} else if (Constants.SPECIFIC_SERVICE_CFG_TYPE_ENCRYPTED_TUNNEL_BEHAVIOR.equalsIgnoreCase(configType)
|| Constants.SPECIFIC_SERVICE_CFG_TYPE_BASIC_PROTOCOL.equalsIgnoreCase(configType)) {
cfgKeywords.append(Constants.PROTO_ID_REGION + "=" + entity.getAppCode());
}
2018-08-24 15:32:11 +08:00
// entity.setCfgKeywords(entity.getAppCode()+"");
}
entity.setCfgKeywords(cfgKeywords.toString());
2018-06-22 18:46:01 +08:00
List<AppPolicyCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(strRegionList, list, 2, entity, groupRelationList);
groupRelationList = map.get("groupList");
strRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
// 查询子配置并修改审核状态
entity = this.getAppPolicyCfg(entity.getCfgId());
2018-08-24 15:32:11 +08:00
if (entity.getIpPortList() != null && entity.getIpPortList().size() > 0) {
IpPortCfg cfg = new IpPortCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
cfg.setTableName(IpPortCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(ipRegionList, entity.getIpPortList(), 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
ipRegionList = map.get("dstList");
if (map.get("numRegionList") != null) {
numRegionList.addAll(map.get("numRegionList"));
}
}
}
2018-08-24 15:32:11 +08:00
if (entity.getNtcSubscribeIdCfgList() != null && entity.getNtcSubscribeIdCfgList().size() > 0) {
if (isAudit == 1) {
Map<String, List> ntcMap = cfgConvert(strRegionList, entity.getNtcSubscribeIdCfgList(), 2, entity,
groupRelationList);
groupRelationList = ntcMap.get("groupList");
strRegionList = ntcMap.get("dstList");
}
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
List<AreaIpCfg> areaIpCfgList = areaIpCfgDao.getByCompileId(entity.getCompileId());
if (!StringUtil.isEmpty(areaIpCfgList)) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(areaIpRegionList, areaIpCfgList, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
areaIpRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
2018-06-22 18:46:01 +08:00
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
String userRegion = null;
if (Constants.SPECIFIC_SERVICE_CFG_TYPE_APP.equalsIgnoreCase(configType)) {
// 设置APP自定义域
userRegion = Constants.APP_ID_REGION + "=" + entity.getAppCode();
if (entity.getBehavCode() != null) {
userRegion += Constants.USER_REGION_SPLIT + Constants.BEHAV_ID_REGION + "=" + entity.getBehavCode();
}
2018-08-24 15:32:11 +08:00
} else if (Constants.SPECIFIC_SERVICE_CFG_TYPE_BASIC_PROTOCOL.equalsIgnoreCase(configType)) {
userRegion = Constants.PROTO_ID_REGION + "=" + entity.getAppCode();
} else if (Constants.SPECIFIC_SERVICE_CFG_TYPE_ENCRYPTED_TUNNEL_BEHAVIOR.equalsIgnoreCase(configType)) {
userRegion = Constants.PROTO_ID_REGION + "=" + entity.getAppCode();
if (entity.getBehavCode() != null) {
userRegion += Constants.USER_REGION_SPLIT + Constants.BEHAV_ID_REGION + "=" + entity.getBehavCode();
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
// 限速业务需要设置
String actionCode = DictUtils.getDictCode("SERVICE_ACTION", "action_ratelimit");
2018-08-24 15:32:11 +08:00
if (!actionCode.equals("默认")) {
if (entity.getAction().equals(Integer.parseInt(actionCode))) {
userRegion += Constants.USER_REGION_SPLIT + Constants.RATE_LIMIT_REGION + "="
+ entity.getRatelimit();
}
2018-06-22 18:46:01 +08:00
}
maatCfg.setUserRegion(userRegion);
2018-06-22 18:46:01 +08:00
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app策略配置下发配置参数" + json);
// 调用服务接口下发配置
2018-06-22 18:46:01 +08:00
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app策略配置下发响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
2018-06-22 18:46:01 +08:00
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
maatCfg.setIsValid(0);// 无效
2018-06-22 18:46:01 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app策略配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app策略配置取消配置响应信息" + result.getMsg());
}
}
2018-08-24 15:32:11 +08:00
public void auditAppIpCfg(AppIpCfg entity, Integer isAudit) {
ToMaatBean maatBean = new ToMaatBean();
2018-06-22 18:46:01 +08:00
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
List<IpCfg> areaIpRegionList = new ArrayList();
2018-06-23 17:29:14 +08:00
entity.setTableName(AppIpCfg.getTablename());
2018-06-22 18:46:01 +08:00
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
2018-06-22 18:46:01 +08:00
List<AppIpCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(ipRegionList, list, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
ipRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
List<AreaIpCfg> areaIpCfgList = areaIpCfgDao.getByCompileId(entity.getCompileId());
if (!StringUtil.isEmpty(areaIpCfgList)) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(areaIpRegionList, areaIpCfgList, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
areaIpRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
2018-06-22 18:46:01 +08:00
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
// 设置APP自定义域
String userRegion = "APP_ID=" + entity.getAppCode();
2018-06-22 18:46:01 +08:00
maatCfg.setUserRegion(userRegion);
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app协议IP配置下发配置参数" + json);
// 调用服务接口下发配置
2018-06-22 18:46:01 +08:00
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app协议IP配置下发响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
2018-06-22 18:46:01 +08:00
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
maatCfg.setIsValid(0);// 无效
2018-06-22 18:46:01 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app协议IP配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app协议IP配置取消配置响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
public void auditAppHttpCfg(AppHttpCfg entity, Integer isAudit) {
ToMaatBean maatBean = new ToMaatBean();
2018-06-22 18:46:01 +08:00
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
List<IpCfg> areaIpRegionList = new ArrayList();
2018-06-23 17:29:14 +08:00
entity.setTableName(AppHttpCfg.getTablename());
2018-06-22 18:46:01 +08:00
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
2018-06-22 18:46:01 +08:00
List<AppHttpCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(strRegionList, list, 2, entity, groupRelationList);
groupRelationList = map.get("groupList");
strRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
List<AreaIpCfg> areaIpCfgList = areaIpCfgDao.getByCompileId(entity.getCompileId());
if (!StringUtil.isEmpty(areaIpCfgList)) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(areaIpRegionList, areaIpCfgList, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
areaIpRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
2018-06-22 18:46:01 +08:00
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
// 设置APP自定义域
String userRegion = "APP_ID=" + entity.getAppCode();
2018-06-22 18:46:01 +08:00
maatCfg.setUserRegion(userRegion);
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app HTTP配置下发配置参数" + json);
// 调用服务接口下发配置
2018-06-22 18:46:01 +08:00
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app HTTP配置下发响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
2018-06-22 18:46:01 +08:00
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
maatCfg.setIsValid(0);// 无效
2018-06-22 18:46:01 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app HTTP配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app HTTP配置取消配置响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
public void auditAppDomainCfg(AppDomainCfg entity, Integer isAudit) {
ToMaatBean maatBean = new ToMaatBean();
2018-06-22 18:46:01 +08:00
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
List<IpCfg> areaIpRegionList = new ArrayList();
2018-06-23 17:29:14 +08:00
entity.setTableName(AppDomainCfg.getTablename());
2018-06-22 18:46:01 +08:00
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
2018-06-23 17:29:14 +08:00
entity.setCfgKeywords(entity.getDomain());
2018-06-22 18:46:01 +08:00
List<AppDomainCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(strRegionList, list, 2, entity, groupRelationList);
groupRelationList = map.get("groupList");
strRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
List<AreaIpCfg> areaIpCfgList = areaIpCfgDao.getByCompileId(entity.getCompileId());
if (!StringUtil.isEmpty(areaIpCfgList)) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(areaIpRegionList, areaIpCfgList, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
areaIpRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
2018-06-22 18:46:01 +08:00
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
// 设置APP自定义域
String userRegion = "APP_ID=" + entity.getAppCode() + Constants.USER_REGION_SPLIT + "DOMAIN_ID="
+ entity.getCompileId() + Constants.USER_REGION_SPLIT + "DOMAIN_STR="
+ keywordsEscape(entity.getDomain());
2018-06-22 18:46:01 +08:00
maatCfg.setUserRegion(userRegion);
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app域名配置下发配置参数" + json);
// 调用服务接口下发配置
2018-06-22 18:46:01 +08:00
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app域名配置下发响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
2018-06-22 18:46:01 +08:00
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
maatCfg.setIsValid(0);// 无效
2018-06-22 18:46:01 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app域名配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app域名配置取消配置响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
// app主题网站配置审核
public void auditAppTopicDomainCfg(AppTopicDomainCfg entity, Integer isAudit) {
ToMaatBean maatBean = new ToMaatBean();
2018-08-23 17:07:09 +08:00
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
List<IpCfg> areaIpRegionList = new ArrayList();
entity.setTableName(AppTopicDomainCfg.getTablename());
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
// 域名为关键字
if (isAudit == 1) {
2018-08-23 17:07:09 +08:00
entity.setCfgKeywords(entity.getDomain());
List<AppTopicDomainCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(strRegionList, list, 2, entity, groupRelationList);
groupRelationList = map.get("groupList");
strRegionList = map.get("dstList");
2018-08-23 17:07:09 +08:00
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
List<AreaIpCfg> areaIpCfgList = areaIpCfgDao.getByCompileId(entity.getCompileId());
if (!StringUtil.isEmpty(areaIpCfgList)) {
2018-08-23 17:07:09 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-08-23 17:07:09 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(areaIpRegionList, areaIpCfgList, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
areaIpRegionList = map.get("dstList");
2018-08-23 17:07:09 +08:00
}
}
2018-08-24 15:32:11 +08:00
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
2018-08-23 17:07:09 +08:00
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
2018-08-29 22:46:49 +08:00
// 设置APP自定义域
String domain = entity.getDomain();
WebsiteDomainTopic websiteDomainTopic = new WebsiteDomainTopic();
websiteDomainTopic.setDomain(domain);
//查询domainId
List<WebsiteDomainTopic> domainDict = appCfgDao.getDomainDict(websiteDomainTopic);
Long domainId = domainDict.get(0).getId();
2018-08-24 15:32:11 +08:00
// "APP_ID="+entity.getAppCode()+Constants.USER_REGION_SPLIT+
2018-08-29 22:46:49 +08:00
String userRegion = "DOMAIN_ID=" + domainId + Constants.USER_REGION_SPLIT + "DOMAIN_STR="
2018-08-24 15:32:11 +08:00
+ keywordsEscape(entity.getDomain());
maatCfg.setUserRegion(userRegion);
2018-08-24 15:32:11 +08:00
2018-08-23 17:07:09 +08:00
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app主题网站配置下发配置参数" + json);
// 调用服务接口下发配置
2018-08-23 17:07:09 +08:00
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app主题网站配置下发响应信息" + result.getMsg());
2018-08-23 17:07:09 +08:00
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
2018-08-23 17:07:09 +08:00
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
maatCfg.setIsValid(0);// 无效
2018-08-23 17:07:09 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app主题网站配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app主题网站配置取消配置响应信息" + result.getMsg());
2018-08-23 17:07:09 +08:00
}
}
2018-08-24 15:32:11 +08:00
public void auditAppByteCfg(AppByteCfg entity, Integer isAudit) {
ToMaatBean maatBean = new ToMaatBean();
2018-06-22 18:46:01 +08:00
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
List<IpCfg> areaIpRegionList = new ArrayList();
2018-06-23 17:29:14 +08:00
entity.setTableName(AppByteCfg.getTablename());
2018-06-22 18:46:01 +08:00
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
2018-06-23 17:29:14 +08:00
entity.setCfgKeywords(entity.getBytes());
2018-06-22 18:46:01 +08:00
List<AppByteCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(strRegionList, list, 2, entity, groupRelationList);
groupRelationList = map.get("groupList");
strRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
List<AreaIpCfg> areaIpCfgList = areaIpCfgDao.getByCompileId(entity.getCompileId());
if (!StringUtil.isEmpty(areaIpCfgList)) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(areaIpRegionList, areaIpCfgList, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
areaIpRegionList = map.get("dstList");
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
2018-06-22 18:46:01 +08:00
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
// 设置用户自定义域
String userRegion = "APP_ID=" + entity.getAppCode();
2018-06-22 18:46:01 +08:00
maatCfg.setUserRegion(userRegion);
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app字节配置下发配置参数" + json);
// 调用服务接口下发配置
2018-06-22 18:46:01 +08:00
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app字节配置下发响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
2018-06-22 18:46:01 +08:00
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
maatCfg.setIsValid(0);// 无效
2018-06-22 18:46:01 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app字节配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app字节配置取消配置响应信息" + result.getMsg());
2018-06-22 18:46:01 +08:00
}
}
2018-08-24 15:32:11 +08:00
public void auditAppSslCfg(AppSslCertCfg entity, Integer isAudit) {
ToMaatBean maatBean = new ToMaatBean();
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
List<IpCfg> areaIpRegionList = new ArrayList();
entity.setTableName(AppSslCertCfg.getTablename());
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
List<AppSslCertCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(strRegionList, list, 3, entity, groupRelationList);
groupRelationList = map.get("groupList");
strRegionList = map.get("dstList");
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
List<AreaIpCfg> areaIpCfgList = areaIpCfgDao.getByCompileId(entity.getCompileId());
if (!StringUtil.isEmpty(areaIpCfgList)) {
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(areaIpRegionList, areaIpCfgList, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
areaIpRegionList = map.get("dstList");
}
}
2018-08-24 15:32:11 +08:00
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
// 设置APP自定义域
String userRegion = "APP_ID=" + entity.getAppCode();
maatCfg.setUserRegion(userRegion);
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app SSL配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app SSL配置下发响应信息" + result.getMsg());
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app SSL配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app SSL配置取消配置响应信息" + result.getMsg());
}
}
2018-08-24 15:32:11 +08:00
public void updateAppPolicyCfgValid(Integer isValid, String ids, Integer functionId) {
2018-06-22 18:46:01 +08:00
String[] idArray = ids.split(",");
2018-08-24 15:32:11 +08:00
for (String id : idArray) {
AppPolicyCfg entity = new AppPolicyCfg();
2018-06-22 18:46:01 +08:00
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppPolicyCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
2018-08-24 15:32:11 +08:00
// 查询子配置
entity = this.getAppPolicyCfg(Long.parseLong(id));
2018-08-24 15:32:11 +08:00
if (entity.getIpPortList() != null && entity.getIpPortList().size() > 0) {
IpPortCfg cfg = new IpPortCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
cfg.setTableName(IpPortCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
// 删除关键字
if (entity.getNtcSubscribeIdCfgList() != null && entity.getNtcSubscribeIdCfgList().size() > 0) {
2018-08-25 17:07:34 +08:00
NtcSubscribeIdCfg cfg = new NtcSubscribeIdCfg();
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
stringcfgDao.updateSubscribeIdCfg(cfg);
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
public void updateAppIpCfgValid(Integer isValid, String ids, Integer functionId) {
2018-06-22 18:46:01 +08:00
String[] idArray = ids.split(",");
2018-08-24 15:32:11 +08:00
for (String id : idArray) {
AppIpCfg entity = new AppIpCfg();
2018-06-22 18:46:01 +08:00
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppIpCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
public void updateAppTcpCfgValid(Integer isValid, String ids, Integer functionId) {
2018-08-24 10:25:01 +08:00
String[] idArray = ids.split(",");
2018-08-24 15:32:11 +08:00
for (String id : idArray) {
AppTcpCfg entity = new AppTcpCfg();
2018-08-24 10:25:01 +08:00
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppTcpCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
2018-08-24 10:25:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-08-24 10:25:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
2018-08-24 10:25:01 +08:00
}
2018-08-24 15:32:11 +08:00
2018-08-24 10:25:01 +08:00
}
2018-08-24 15:32:11 +08:00
public void updateAppHttpCfgValid(Integer isValid, String ids, Integer functionId) {
2018-06-22 18:46:01 +08:00
String[] idArray = ids.split(",");
2018-08-24 15:32:11 +08:00
for (String id : idArray) {
AppHttpCfg entity = new AppHttpCfg();
2018-06-22 18:46:01 +08:00
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppHttpCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
public void updateAppDomainCfgValid(Integer isValid, String ids, Integer functionId) {
2018-06-22 18:46:01 +08:00
String[] idArray = ids.split(",");
2018-08-24 15:32:11 +08:00
for (String id : idArray) {
AppDomainCfg entity = new AppDomainCfg();
2018-06-22 18:46:01 +08:00
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppDomainCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
// 主题网站配置删除
public void updateAppTopicDomainCfgValid(Integer isValid, String ids, Integer functionId) {
String[] idArray = ids.split(",");
for (String id : idArray) {
AppTopicDomainCfg entity = new AppTopicDomainCfg();
2018-08-24 15:32:11 +08:00
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppTopicDomainCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
AreaIpCfg cfg = new AreaIpCfg();
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
2018-08-23 17:07:09 +08:00
}
2018-08-24 15:32:11 +08:00
2018-08-23 17:07:09 +08:00
}
2018-08-24 15:32:11 +08:00
}
public void updateAppByteCfgValid(Integer isValid, String ids, Integer functionId) {
2018-06-22 18:46:01 +08:00
String[] idArray = ids.split(",");
2018-08-24 15:32:11 +08:00
for (String id : idArray) {
AppByteCfg entity = new AppByteCfg();
2018-06-22 18:46:01 +08:00
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppByteCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
2018-06-22 18:46:01 +08:00
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
2018-06-22 18:46:01 +08:00
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
2018-06-22 18:46:01 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
public void updateAppSslCfgValid(Integer isValid, String ids, Integer functionId) {
String[] idArray = ids.split(",");
2018-08-24 15:32:11 +08:00
for (String id : idArray) {
AppSslCertCfg entity = new AppSslCertCfg();
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppSslCertCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
public void updateAppHeaderCfgValid(Integer isValid, String ids, Integer functionId) {
String[] idArray = ids.split(",");
2018-08-24 15:32:11 +08:00
for (String id : idArray) {
AppHeaderCfg entity = new AppHeaderCfg();
entity.setCfgId(Long.parseLong(id));
entity.setIsValid(isValid);
entity.setEditorId(UserUtils.getUser().getId());
entity.setEditTime(new Date());
entity.setTableName(AppHeaderCfg.getTablename());
entity.setFunctionId(functionId);
appCfgDao.updateCfgValid(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null && entity.getAreaCfg().size() > 0) {
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.updateCfgValid(cfg);
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
public Page<AppHeaderCfg> findAppHeaderList(Page<AppHeaderCfg> page, AppHeaderCfg entity) {
2018-08-24 15:32:11 +08:00
entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(), "r"));
entity.setPage(page);
List<AppHeaderCfg> list = appCfgDao.findAppHeaderList(entity);
page.setList(list);
return page;
}
2018-08-24 15:32:11 +08:00
public AppHeaderCfg getAppHeaderCfg(Long cfgId) {
return appCfgDao.getAppHeaderCfg(cfgId);
}
2018-08-24 15:32:11 +08:00
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveOrUpdateAppHeaderCfg(AppHeaderCfg entity) throws Exception {
// 设置区域运营商信息
setAreaEffectiveIds(entity);
2018-08-24 15:32:11 +08:00
if (entity.getCfgId() == null) {
Integer compileId = 0;
try {
List<Integer> idList = ConfigServiceUtil.getId(1, 1);
2018-08-24 15:32:11 +08:00
if (idList != null && idList.size() > 0) {
compileId = idList.get(0);
}
entity.setCompileId(compileId);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.insertAppHeaderCfg(entity);
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
} catch (Exception e) {
e.printStackTrace();
logger.info("获取编译ID出错");
throw new MaatConvertException(e.getMessage());
}
2018-08-24 15:32:11 +08:00
} else {
entity.setEditorId(entity.getCurrentUser().getId());
entity.setEditTime(new Date());
entity.setIsValid(0);
entity.setIsAudit(0);
appCfgDao.updateAppHeaderCfg(entity);
2018-08-24 15:32:11 +08:00
// 删除旧的区域IP新增新的区域IP
AreaIpCfg area = new AreaIpCfg();
area.setCompileId(entity.getCompileId());
area.setFunctionId(entity.getFunctionId());
areaIpCfgDao.deleteAreaIpCfg(area);
entity.setCreateTime(new Date());
entity.setCreatorId(entity.getCurrentUser().getId());
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
if (entity.getAreaCfg() != null) {
for (AreaIpCfg cfg : entity.getAreaCfg()) {
cfg.initDefaultValue();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgDesc", "cfgRegionCode", "cfgType" });
areaIpCfgDao.saveAreaIpCfg(cfg);
}
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
}
2018-08-24 15:32:11 +08:00
public void auditAppHeaderCfg(AppHeaderCfg entity, Integer isAudit) {
ToMaatBean maatBean = new ToMaatBean();
MaatCfg maatCfg = new MaatCfg();
List<MaatCfg> configCompileList = new ArrayList();
List<GroupCfg> groupRelationList = new ArrayList();
List<IpCfg> ipRegionList = new ArrayList();
List<StringCfg> strRegionList = new ArrayList();
List<NumBoundaryCfg> numRegionList = new ArrayList();
List<DigestCfg> digestRegionList = new ArrayList();
List<IpCfg> areaIpRegionList = new ArrayList();
entity.setTableName(AppHeaderCfg.getTablename());
appCfgDao.auditCfg(entity);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
List<AppHeaderCfg> list = new ArrayList();
list.add(entity);
2018-08-24 15:32:11 +08:00
Map<String, List> map = cfgConvert(strRegionList, list, 3, entity, groupRelationList);
groupRelationList = map.get("groupList");
strRegionList = map.get("dstList");
}
2018-08-24 15:32:11 +08:00
// 保存区域IP信息
List<AreaIpCfg> areaIpCfgList = areaIpCfgDao.getByCompileId(entity.getCompileId());
if (!StringUtil.isEmpty(areaIpCfgList)) {
AreaIpCfg cfg = new AreaIpCfg();
2018-08-24 15:32:11 +08:00
BeanUtils.copyProperties(entity, cfg, new String[] { "cfgId" });
cfg.setTableName(AreaIpCfg.getTablename());
appCfgDao.auditCfg(cfg);
2018-08-24 15:32:11 +08:00
if (isAudit == 1) {
Map<String, List> map = cfgConvert(areaIpRegionList, areaIpCfgList, 1, entity, groupRelationList);
groupRelationList = map.get("groupList");
areaIpRegionList = map.get("dstList");
}
}
2018-08-24 15:32:11 +08:00
// 构造提交综合服务参数格式,一条配置提交一次综合服务
if (isAudit == 1) {
maatCfg.initDefaultValue();
BeanUtils.copyProperties(entity, maatCfg);
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());
2018-08-24 15:32:11 +08:00
// 设置APP自定义域
String userRegion = "APP_ID=" + entity.getAppCode();
maatCfg.setUserRegion(userRegion);
configCompileList.add(maatCfg);
maatBean.setConfigCompileList(configCompileList);
maatBean.setAuditTime(entity.getAuditTime());
maatBean.setCreatorName(entity.getCurrentUser().getName());
maatBean.setVersion(Constants.MAAT_VERSION);
maatBean.setOpAction(Constants.INSERT_ACTION);
2018-08-24 15:32:11 +08:00
// 调用服务接口下发配置数据
String json = gsonToJson(maatBean);
logger.info("app Header配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
2018-08-24 15:32:11 +08:00
logger.info("app Header配置下发响应信息" + result.getMsg());
2018-08-24 15:32:11 +08:00
} else if (isAudit == 3) {
maatCfg.setCompileId(entity.getCompileId());
maatCfg.setServiceId(entity.getServiceId());
2018-08-24 15:32:11 +08:00
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);
2018-08-24 15:32:11 +08:00
// 调用服务接口取消配置
String json = gsonToJson(maatBean);
logger.info("app Header配置下发配置参数" + json);
// 调用服务接口下发配置
ToMaatResult result = ConfigServiceUtil.put(json, 1);
logger.info("app Header配置取消配置响应信息" + result.getMsg());
}
}
2018-08-29 22:46:49 +08:00
/**
* 获取主题跟服务表中的域名
* @param websiteDomainTopic
* @return
*/
public List<WebsiteDomainTopic> getDomainDict(WebsiteDomainTopic websiteDomainTopic) {
return appCfgDao.getDomainDict(websiteDomainTopic);
}
/**
* 保存自定义的域名
* @param websiteDomainTopic
*/
@Transactional(readOnly = false, rollbackFor = RuntimeException.class)
public void saveDomainDict(WebsiteDomainTopic websiteDomainTopic) {
appCfgDao.saveDomainDict(websiteDomainTopic);
}
}