提交IP复用地址池配置功能代码

2018-07-01 16:08:55 +08:00
parent fff7aec3f2
commit 6857cf2660
8 changed files with 1388 additions and 0 deletions
--- a/src/main/java/com/nis/web/service/configuration/IpMultiplexPoolCfgService.java
+++ b/src/main/java/com/nis/web/service/configuration/IpMultiplexPoolCfgService.java
@@ -0,0 +1,173 @@
+package com.nis.web.service.configuration;
+
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.nis.domain.Page;
+import com.nis.domain.callback.NtcDnsResStrategy;
+import com.nis.domain.configuration.DnsResStrategy;
+import com.nis.domain.configuration.IpMultiplexPoolCfg;
+import com.nis.domain.maat.ToMaatResult;
+import com.nis.exceptions.MaatConvertException;
+import com.nis.util.ConfigServiceUtil;
+import com.nis.web.dao.configuration.IpMultiplexPoolCfgDao;
+import com.nis.web.security.UserUtils;
+import com.nis.web.service.BaseService;
+
+
+
+/**
+ * 音视频文本
+ * @author dell
+ *
+ */
+@Service
+public class IpMultiplexPoolCfgService extends BaseService{
+	@Autowired
+	protected IpMultiplexPoolCfgDao ipMultiplexStrategyDao;
+	
+	
+	/**
+	 * 查询分页数据
+	 * @param page 分页对象
+	 * @param entity
+	 * @return
+	 */
+	public Page<IpMultiplexPoolCfg> findPage(Page<IpMultiplexPoolCfg> page, IpMultiplexPoolCfg entity) {
+		entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(),"r"));
+		entity.setPage(page);
+		List<IpMultiplexPoolCfg> list=ipMultiplexStrategyDao.findPage(entity);
+		page.setList(list);
+		return page;
+	}
+	public List<IpMultiplexPoolCfg> findIpMultiplexPoolCfgs(Long cfgId,Integer isValid,Integer isAudit) {
+		List<IpMultiplexPoolCfg> list=ipMultiplexStrategyDao.findList(cfgId,isValid,isAudit);
+		return list;
+	}
+	
+	public IpMultiplexPoolCfg getIpMultiplexPoolCfg(Long id,Integer isValid) {
+		List<IpMultiplexPoolCfg> list=ipMultiplexStrategyDao.findList(id,isValid,null);
+		IpMultiplexPoolCfg dnsResStrategy=null;
+		if(list != null && list.size()>0){
+			dnsResStrategy=list.get(0);
+		}
+		return dnsResStrategy;
+	}
+	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
+	public void saveOrUpdate(IpMultiplexPoolCfg entity){
+		Date createTime=new Date();
+		setAreaEffectiveIds(entity);
+		if(entity.getCfgId()==null){
+			entity.initDefaultValue();
+			entity.setCreatorId(UserUtils.getUser().getId());
+			entity.setCreateTime(createTime);
+			entity.setIsValid(0);
+			entity.setIsAudit(0);
+			//调用服务接口获取compileId
+			List<Integer> compileIds = new ArrayList<Integer>();
+			try {
+				compileIds = ConfigServiceUtil.getId(1,1);
+			} catch (Exception e) {
+				e.printStackTrace();
+				logger.info("获取编译ID出错");
+				throw new MaatConvertException("<spring:message code=\"request_service_failed\"/>:"+e.getMessage());
+			}
+			if(compileIds != null && compileIds.size() >0  && compileIds.get(0) != 0){
+				entity.setCompileId(compileIds.get(0));
+			}
+			ipMultiplexStrategyDao.insert(entity);
+			//修改
+		}else{
+			Date editTime=new Date();
+			entity.setIsValid(0);
+			entity.setIsAudit(0);
+			entity.setEditorId(UserUtils.getUser().getId());
+			entity.setEditTime(editTime);
+			
+			ipMultiplexStrategyDao.update(entity);
+		}
+	}
+	
+	/**
+	 * 
+	 * @param isAudit
+	 * @param isValid
+	 * @param ids compileIds
+	 */
+	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
+	public void delete(Integer isAudit,Integer isValid,String ids,Integer functionId){
+		IpMultiplexPoolCfg entity = new IpMultiplexPoolCfg();
+		String[] idArray = ids.split(",");
+		for(String id :idArray){
+			entity.setCfgId(Long.valueOf(id));
+			entity.setFunctionId(functionId);
+			entity.setIsAudit(isAudit);
+			entity.setIsValid(isValid);
+			entity.setEditorId(UserUtils.getUser().getId());
+			entity.setEditTime(new Date());
+			ipMultiplexStrategyDao.update(entity);
+		}
+	}
+	/**
+	 * 
+	 * @param isAudit
+	 * @param isValid
+	 * @param ids cfgId
+	 * @param functionId
+	 */
+	@Transactional(readOnly=false,rollbackFor=RuntimeException.class)
+	public void audit(Integer isAudit,Integer isValid,Integer functionId,String id,Date auditTime){
+		IpMultiplexPoolCfg cfg=new IpMultiplexPoolCfg();
+		cfg.setCfgId(Long.valueOf(id));
+		cfg.setIsValid(isValid);
+		cfg.setIsAudit(isAudit);
+		cfg.setEditTime(auditTime);
+		cfg.setEditorId(UserUtils.getUser().getId());
+		cfg.setAuditorId(UserUtils.getUser().getId());
+		cfg.setAuditTime(auditTime);
+		ipMultiplexStrategyDao.update(cfg);
+		cfg=getIpMultiplexPoolCfg(cfg.getCfgId(), null);
+		String json="";
+		if(cfg.getIsAudit()==1){
+			List<IpMultiplexPoolCfg> resStrategyList=new ArrayList<IpMultiplexPoolCfg>();
+			resStrategyList.add(cfg);
+			//调用服务接口下发配置数据
+			json=gsonToJson(resStrategyList);
+			logger.info("IP复用地址池配置下发配置参数："+json);
+			//调用服务接口下发配置
+			try {
+				ToMaatResult result = ConfigServiceUtil.postCallbackCfg(json);
+				if(result!=null){
+					logger.info("IP复用地址池配置下发响应信息："+result.getMsg());
+				}
+			} catch (Exception e) {
+				logger.error("IP复用地址池配置配置下发失败",e);
+				throw e;
+			}
+		}else if(cfg.getIsAudit()==3){
+			List<IpMultiplexPoolCfg> resStrategyList=new ArrayList<>();
+			resStrategyList.add(cfg);
+			//调用服务接口取消配置
+			json=gsonToJson(resStrategyList);
+			logger.info("IP复用地址池配置配置参数："+json);
+			//调用服务接口取消配置
+			try {
+				ToMaatResult result = ConfigServiceUtil.put(json, 2);
+				logger.info("IP复用地址池配置响应信息："+result.getMsg());
+			} catch (Exception e) {
+				e.printStackTrace();
+				logger.info("IP复用地址池配置配置失败");
+				throw e;
+			}
+		}
+	}
+}
+	
+