k18-ntcs-web-ntc/src/main/java/com/nis/web/service/configuration/StringCfgService.java

package com.nis.web.service.configuration;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.nis.domain.configuration.AreaIpCfg;
import com.nis.domain.configuration.BaseIpCfg;
import com.nis.domain.configuration.BaseStringCfg;
import com.nis.domain.configuration.HttpUrlCfg;
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;
import com.nis.exceptions.MaatConvertException;
import com.nis.util.ConfigServiceUtil;
import com.nis.util.Constants;
import com.nis.util.StringUtil;
import com.nis.web.dao.configuration.AreaIpCfgDao;
import com.nis.web.dao.configuration.StringCfgDao;
import com.nis.web.service.CrudService;

/**
 * String相关配置事务类
 * @author dell
 *
 */
@Service
public class StringCfgService extends CrudService<StringCfgDao,BaseStringCfg> {
	@Autowired
	protected StringCfgDao stringCfgDao;
	@Autowired
	protected AreaIpCfgDao areaIpCfgDao;
	/**
	 * 
	 * addStringCfg(新增IP类配置)
	 * (继承BaseStringCfg这个类方可使用)
	 * @param baseStringCfg
	 * @return 
	 *int
	 * @exception 
	 * @since  1.0.0
	 */
	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
	public int addStringCfg(BaseStringCfg baseStringCfg,List<BaseIpCfg> areaIpCfgs){
		if(areaIpCfgs!=null&&areaIpCfgs.size()>0){
//			this.saveIpBatch(areaIpCfgs);
		}
		//调用服务接口获取compileId
		Integer compileId = 0;
		try {
			List<Integer> compileIds = ConfigServiceUtil.getId(1,1);
			if(!StringUtil.isEmpty(compileIds)){
				compileId = compileIds.get(0);
			}
		} catch (Exception e) {
			e.printStackTrace();
			logger.info("获取编译ID出错");
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
		}
		if(compileId!=0){
			baseStringCfg.setCompileId(compileId);
			return stringCfgDao.insert(baseStringCfg);
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>");
		}
//		baseStringCfg.setCompileId(0);
//		return stringCfgDao.insert(baseStringCfg);
	} 
	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
	public void addStringCfg(BaseStringCfg cfg){
		//调用服务接口获取compileId
		Integer compileId = 0;
		try {
			List<Integer> compileIds = ConfigServiceUtil.getId(1,1);
			if(!StringUtil.isEmpty(compileIds)){
				compileId = compileIds.get(0);
			}
		} catch (Exception e) {
			e.printStackTrace();
			logger.info("获取编译ID出错");
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
		}
		if(compileId!=0){
			cfg.setCompileId(compileId);
			setAreaEffectiveIds(cfg);
			if(cfg.getAreaCfg()!=null&&cfg.getAreaCfg().size()>0){
				for(AreaIpCfg c:cfg.getAreaCfg()){
					c.initDefaultValue();
					BeanUtils.copyProperties(cfg, c,new String[]{"cfgId","ipType","direction",
							"protocol","protocolId","areaEffectiveIds","cfgRegionCode",
							"cfgType","ipPattern","srcIpAddress","portPattern","srcPort","destIpAddress","destPort"});	
					c.setTableName(AreaIpCfg.getTablename());
				}
				this.saveIpBatch(cfg.getAreaCfg());
			}
			stringCfgDao.insert(cfg);
		}else{
			throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>");
		}
		
	} 
	/**
	 * 
	 * updateStringCfg(更新IP类配置)
	 * (继承BaseStringCfg这个类方可使用)
	 * @param baseStringCfg
	 * @return 
	 *int
	 * @exception 
	 * @since  1.0.0
	 */
	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
	public int updateStringCfg(BaseStringCfg baseStringCfg,List<BaseIpCfg> addAreaCfg,List<BaseIpCfg> updateAreaCfg,List<BaseIpCfg> deleteAreaCfgs){
		if(addAreaCfg!=null&&addAreaCfg.size()>0){
//			this.saveIpBatch(addAreaCfg);
		}
		if(updateAreaCfg!=null&&updateAreaCfg.size()>0){
			this.updateIpBatch(updateAreaCfg);
		}
		if(deleteAreaCfgs!=null&&deleteAreaCfgs.size()>0){
			this.deleteIpBatch(deleteAreaCfgs);
		}
		return stringCfgDao.update(baseStringCfg);
	} 
	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
	public void updateStringCfg(BaseStringCfg cfg){
		AreaIpCfg area=new AreaIpCfg();
		area.setCompileId(cfg.getCompileId());
		area.setFunctionId(cfg.getFunctionId());
		areaIpCfgDao.deleteAreaIpCfg(area);
		//区域IPsetAreaEffectiveIds设置
		setAreaEffectiveIds(cfg);
		Date date=new Date();
		if(cfg.getAreaCfg()!=null&&cfg.getAreaCfg().size()>0){
			for(AreaIpCfg c:cfg.getAreaCfg()){
				c.initDefaultValue();
				BeanUtils.copyProperties(cfg, c,new String[]{"cfgId","ipType","direction",
						"protocol","protocolId","areaEffectiveIds","cfgRegionCode",
						"cfgType","ipPattern","srcIpAddress","portPattern","srcPort","destIpAddress","destPort"});	
				c.setTableName(AreaIpCfg.getTablename());
				c.setCreatorId(cfg.getCurrentUser().getId());
				c.setCreateTime(date);
			}
			this.saveIpBatch(cfg.getAreaCfg());
		}
		stringCfgDao.update(cfg);
	} 
	public void auditWhiteDomain(BaseStringCfg cfg) throws Exception{
		List<BaseStringCfg> beans=new ArrayList<>();
		beans.add(cfg);
		this.auditBatch(beans, StringCfgDao.class);
		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<>();
		ToMaatBean maatBean = new ToMaatBean();	
		MaatCfg maatCfg = new MaatCfg();
		maatCfg.initDefaultValue();
		BeanUtils.copyProperties(cfg, maatCfg);
		if(cfg.getIsAudit()==1){			
			maatBean.setOpAction(Constants.INSERT_ACTION);
			Map<String,List> map = cfgConvert(strRegionList,beans,2,cfg,groupRelationList);
			groupRelationList=map.get("groupList");
			strRegionList=map.get("dstList");
			maatCfg.setAreaEffectiveIds("0");
			maatCfg.setAction(cfg.getAction());
			maatCfg.setAuditTime(cfg.getAuditTime());
			maatCfg.setIpRegionList(ipRegionList);
			maatCfg.setStrRegionList(strRegionList);
			maatCfg.setNumRegionList(numRegionList);
			maatCfg.setDigestRegionList(digestRegionList);
			maatCfg.setGroupRelationList(groupRelationList);
			maatCfg.setGroupNum(groupRelationList.size());
			maatCfg.setAreaIpRegionList(areaIpRegionList);
			configCompileList.add(maatCfg);
			maatBean.setConfigCompileList(configCompileList);
			maatBean.setAuditTime(cfg.getAuditTime());
			maatBean.setCreatorName(cfg.getCurrentUser().getName());
			maatBean.setVersion(Constants.MAAT_VERSION);
			//调用服务接口下发配置数据
			String json=gsonToJson(maatBean);
			logger.info("域名白名单配置："+json);
			//调用服务接口下发配置
			try {
				ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
				logger.info("域名白名单配置下发响应信息："+result.getMsg());
			} catch (Exception e) {
				e.printStackTrace();
				logger.info("域名白名单配置下发失败");
				throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
			}
		}else if(cfg.getIsAudit()==3){
			maatCfg.setCompileId(cfg.getCompileId());
			maatCfg.setServiceId(cfg.getServiceId());
			maatCfg.setIsValid(0);//无效
			configCompileList.add(maatCfg);
			maatBean.setConfigCompileList(configCompileList);
			maatBean.setAuditTime(cfg.getAuditTime());
			maatBean.setCreatorName(cfg.getCurrentUser().getName());
			maatBean.setVersion(Constants.MAAT_VERSION);
			maatBean.setOpAction(Constants.UPDATE_ACTION);
			//调用服务接口取消配置
			String json=gsonToJson(maatBean);
			logger.info("域名白名单配置参数："+json);
			//调用服务接口取消配置
			try {
				ToMaatResult result = ConfigServiceUtil.put(json, 1);
				logger.info("域名白名单取消配置响应信息："+result.getMsg());
			} catch (Exception e) {
				e.printStackTrace();
				logger.info("域名白名单取消配置失败");
				throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
			}
		}
	}
	public void auditDomain(BaseStringCfg cfg) throws Exception{
		List<BaseStringCfg> beans=new ArrayList<>();
		beans.add(cfg);
		this.auditBatch(beans, StringCfgDao.class);
		List<BaseIpCfg> beans1=new ArrayList<>();
		List<AreaIpCfg> areaIpCfgList=areaIpCfgDao.getByCompileId(cfg.getCompileId());
		for(AreaIpCfg area:areaIpCfgList){
			BeanUtils.copyProperties(cfg,area ,new String[]{"cfgRegionCode"
					,"cfgType"
					,"cfgId"
					,"ipType"
					,"ipPattern"
					,"srcIpAddress"
					,"portPattern"
					,"srcPort"
					,"destPort"
					,"protocol"
					,"direction"
					,"protocolId"
					});
			beans1.add(area);
		}
		this.auditIpBatch(beans1);
		
		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<>();
		ToMaatBean maatBean = new ToMaatBean();	
		MaatCfg maatCfg = new MaatCfg();
		maatCfg.initDefaultValue();
		BeanUtils.copyProperties(cfg, maatCfg);
		if(cfg.getIsAudit()==1){			
			maatBean.setOpAction(Constants.INSERT_ACTION);
			Map<String,List> map = cfgConvert(strRegionList,beans,2,cfg,groupRelationList);
			groupRelationList=map.get("groupList");
			strRegionList=map.get("dstList");
			numRegionList=map.get("numRegionList")==null?new ArrayList<>():map.get("numRegionList");
			Map<String,List> areaMap = cfgConvert(areaIpRegionList,beans1,1,cfg,groupRelationList);
			groupRelationList=areaMap.get("groupList");
			areaIpRegionList=areaMap.get("dstList");
			maatCfg.setAreaEffectiveIds(StringUtils.isBlank(cfg.getAreaEffectiveIds())?"0":cfg.getAreaEffectiveIds());
			if(cfg.getServiceId().intValue()==Constants.SERVICE_PXY_DOMAIN_INTERCEPT){
				maatCfg.setUserRegion(this.keywordsEscape(cfg.getCfgKeywords()));
			}
			maatCfg.setAction(cfg.getAction());
			maatCfg.setAuditTime(cfg.getAuditTime());
			maatCfg.setIpRegionList(ipRegionList);
			maatCfg.setStrRegionList(strRegionList);
			maatCfg.setNumRegionList(numRegionList);
			maatCfg.setAreaIpRegionList(areaIpRegionList);
			maatCfg.setDigestRegionList(digestRegionList);
			maatCfg.setGroupRelationList(groupRelationList);
			maatCfg.setGroupNum(groupRelationList.size());
			maatCfg.setAreaIpRegionList(areaIpRegionList);
			configCompileList.add(maatCfg);
			maatBean.setOpAction(Constants.INSERT_ACTION);
			maatBean.setConfigCompileList(configCompileList);
			maatBean.setAuditTime(cfg.getAuditTime());
			maatBean.setCreatorName(cfg.getCurrentUser().getName());
			maatBean.setVersion(Constants.MAAT_VERSION);
			//调用服务接口下发配置数据
			String json=gsonToJson(maatBean);
			logger.info("域名配置："+json);
			//调用服务接口下发配置
			try {
				ToMaatResult result = ConfigServiceUtil.postMaatCfg(json);
				logger.info("域名配置下发响应信息："+result.getMsg());
			} catch (Exception e) {
				e.printStackTrace();
				logger.info("域名配置下发失败");
				throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
			}
		}else if(cfg.getIsAudit()==3){
			maatCfg.setCompileId(cfg.getCompileId());
			maatCfg.setServiceId(cfg.getServiceId());
			maatCfg.setIsValid(0);//无效
			configCompileList.add(maatCfg);
			maatBean.setConfigCompileList(configCompileList);
			maatBean.setAuditTime(cfg.getAuditTime());
			maatBean.setCreatorName(cfg.getCurrentUser().getName());
			maatBean.setVersion(Constants.MAAT_VERSION);
			maatBean.setOpAction(Constants.UPDATE_ACTION);
			//调用服务接口取消配置
			String json=gsonToJson(maatBean);
			logger.info("域名配置参数："+json);
			//调用服务接口取消配置
			try {
				ToMaatResult result = ConfigServiceUtil.put(json, 1);
				logger.info("域名取消配置响应信息："+result.getMsg());
			} catch (Exception e) {
				e.printStackTrace();
				logger.info("域名取消配置失败");
				throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
			}
		}
	}
	
	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
	public void deleteWhiteDomain(String ids){
		List<BaseStringCfg> cfgs=new ArrayList<BaseStringCfg>();
		Date date =new Date();
		if(StringUtils.isNotBlank(ids)){
			for(String idStr:ids.split(",")){
				if(StringUtils.isNotBlank(idStr)){
					BaseStringCfg cfg=new BaseStringCfg();
					cfg.setCfgId(Long.parseLong(idStr));
					cfg.setTableName(HttpUrlCfg.getTablename());
					cfg.setEditorId(cfg.getCurrentUser().getId());
					cfg.setEditTime(date);
					cfg.setIsValid(Constants.VALID_DEL);
					cfgs.add(cfg);
				}
			}
		}
		this.deleteBatch(cfgs, StringCfgDao.class);
	}
	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
	public void deleteDomain(String ids,String compileIds,int functionId){
		if(StringUtils.isNotBlank(compileIds)){
			for(String compileId:compileIds.split(",")){//强转数字，防止注入
				Integer.parseInt(compileId);
			}
			stringCfgDao.deleteByCompileIds(new BaseStringCfg().getCurrentUser().getId(),AreaIpCfg.getTablename(),compileIds);
		}
		List<BaseStringCfg> stringCfgs=new ArrayList<BaseStringCfg>();
		Date date =new Date();
		if(StringUtils.isNotBlank(ids)){
			for(String idStr:ids.split(",")){
				if(StringUtils.isNotBlank(idStr)){
					BaseStringCfg cfg=new BaseStringCfg();
					cfg.setCfgId(Long.parseLong(idStr));
					cfg.setTableName(HttpUrlCfg.getTablename());
					cfg.setEditorId(cfg.getCurrentUser().getId());
					cfg.setEditTime(date);
					cfg.setIsValid(Constants.VALID_DEL);
					stringCfgs.add(cfg);
				}
			}
		}
		this.deleteBatch(stringCfgs, StringCfgDao.class);
	} 
	/**
	 * 
	 * deleteStringCfg(删除IP类配置)
	 * (继承BaseStringCfg这个类方可使用)
	 * @param baseStringCfg
	 * @return 
	 *int
	 * @exception 
	 * @since  1.0.0
	 */
	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
	public void deleteStringCfg(List<BaseStringCfg> stringCfg,List<BaseIpCfg> areaCfg){
		if(areaCfg!=null&&areaCfg.size()>0){
			this.deleteIpBatch(areaCfg);
		}
		this.deleteBatch(stringCfg, StringCfgDao.class);
	} 
	/**
	 * 
	 * getStringCfg(根据IP与类名获取IP配置)
	 * (继承BaseStringCfg这个类方可使用)
	 * @param clazz
	 * @param id
	 * @return 
	 *BaseStringCfg
	 * @exception 
	 * @since  1.0.0
	 */
	public BaseStringCfg getStringCfgById(BaseStringCfg baseStringCfg){
		return stringCfgDao.getById(baseStringCfg.getTableName(), baseStringCfg.getCfgId());
	}
	public BaseStringCfg getStringCfgById(String tableName, long id){
		return stringCfgDao.getById(tableName, id);
	}
	public Integer getIsValid(BaseStringCfg baseStringCfg){
		return stringCfgDao.getIsValid(baseStringCfg);
	}
	public Integer getIsValid(String tableName, long id){
		return stringCfgDao.getIsValid(tableName,id);
	}
	public Integer getIsAudit(BaseStringCfg baseStringCfg){
		return stringCfgDao.getIsAudit(baseStringCfg);
	}
	public Integer getIsAudit(String tableName, long id){
		return stringCfgDao.getIsAudit(tableName,id);
	}
	/**
	 * getList(这里用一句话描述这个方法的作用)
	 * (这里描述这个方法适用条件 – 可选)
	 * @param tableName
	 * @param ids
	 * @return 
	 *List<BaseStringCfg>
	 * @exception 
	 * @since  1.0.0
	*/
	public List<BaseStringCfg> getListByCompileId(String tableName, String ids) {
		// TODO Auto-generated method stub
		return stringCfgDao.getListByCompileId(tableName,ids);
	}
	/**
	 * getListByCfgId(这里用一句话描述这个方法的作用)
	 * (这里描述这个方法适用条件 – 可选)
	 * @param tablename
	 * @param ids
	 * @return 
	 *List<BaseStringCfg>
	 * @exception 
	 * @since  1.0.0
	*/
	public List<BaseStringCfg> getListByCfgId(String tableName, String ids) {
		// TODO Auto-generated method stub
		return stringCfgDao.getListByCfgId(tableName, ids);
	}
}