k18-ntcs-web-ntc/src/main/java/com/nis/web/service/basics/IpCommGroupCfgService.java

package com.nis.web.service.basics;

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

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.collections.CollectionUtils;
import org.apache.ibatis.session.ExecutorType;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
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.FunctionRegionDict;
import com.nis.domain.FunctionServiceDict;
import com.nis.domain.Page;
import com.nis.domain.basics.CommonGroupInfo;
import com.nis.domain.basics.IpCommCfg;
import com.nis.domain.basics.PolicyGroupInfo;
import com.nis.domain.configuration.BaseIpCfg;
import com.nis.domain.configuration.CfgIndexInfo;
import com.nis.exceptions.MaatConvertException;
import com.nis.util.ConfigServiceUtil;
import com.nis.util.Constants;
import com.nis.util.StringUtils;
import com.nis.web.controller.configuration.ObjectGroupController;
import com.nis.web.dao.basics.CommonGroupManageDao;
import com.nis.web.dao.basics.IpCommGroupCfgDao;
import com.nis.web.dao.basics.PolicyGroupInfoDao;
import com.nis.web.dao.configuration.CommonPolicyDao;
import com.nis.web.service.BaseService;
import com.nis.web.service.SpringContextHolder;
@Service
public class IpCommGroupCfgService extends BaseService {
	
    @Autowired
    private IpCommGroupCfgDao ipCommGroupCfgDao;
    @Autowired
    private PolicyGroupInfoDao policyGroupInfoDao;
    @Autowired
    private CommonPolicyDao commonPolicyDao;
    @Autowired
    private CommonGroupManageDao commonGroupManageDao;
    
    private CommonGroupManageService groupManageService = SpringContextHolder.getBean(CommonGroupManageService.class);

    /**
     * @param page
     * @param entity
     * @return
     */
    public Page<IpCommCfg> findPage(Page<IpCommCfg> page, IpCommCfg entity) {
        entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(),"r"));
        entity.setPage(page);
        List<IpCommCfg> list=ipCommGroupCfgDao.findPage(entity);
        page.setList(list);
        return page;
    }

    public List<IpCommCfg> findByPage(String ids) {
        List<IpCommCfg> list=ipCommGroupCfgDao.findByPage(ids);
        return list;
    }

    public IpCommCfg get(Long id ) {
        return ipCommGroupCfgDao.get(id);
    }

    @Transactional(readOnly=false,rollbackFor=RuntimeException.class)
    public void update(IpCommCfg entity){
    	Date editTime=new Date();
    	// 获取分组ID
    	Integer serviceGroupId = groupManageService.getServiceGroupId(entity.getGroupName(), Constants.IP_OBJ_GROUP_TYPE);
        entity.setGroupId(serviceGroupId);
        entity.setEditTime(editTime);
        entity.setEditorId(entity.getCurrentUser().getId());
        ipCommGroupCfgDao.update(entity);
        
        // 更新分组状态
        List<PolicyGroupInfo> policyGroupInfos = new ArrayList<PolicyGroupInfo>();
        policyGroupInfos.addAll(policyGroupInfoDao.findPolicyByServiceGroupInfoList(entity.getUserRegion1()));		// old
        if(!entity.getUserRegion1().equals(entity.getGroupId()+"")) { // 分组已修改
        	policyGroupInfos.addAll(policyGroupInfoDao.findPolicyByServiceGroupInfoList(entity.getGroupId()+""));	// new
        }
        groupManageService.updateGroupStatus(policyGroupInfos, Constants.IP_OBJ_GROUP_TYPE);
        
        transObjGroupToMaat(policyGroupInfos);
    }


    public List<IpCommCfg> getByIds(String ids) {
        if(ids==null) {
            throw new RuntimeException("ids is null!");
        }
        return ipCommGroupCfgDao.getByIds(ids);
    }

    //新增
    @Transactional(readOnly=false,rollbackFor=RuntimeException.class)
    public void saveIpCommGroupCfg(CfgIndexInfo entity) {
        Date createTime=new Date();
        if(CollectionUtils.isNotEmpty(entity.getIpCommGroupCfgList())) {
        	
        	// 获取分组ID
        	Integer serviceGroupId = groupManageService.getServiceGroupId(entity.getGroupName(), Constants.IP_OBJ_GROUP_TYPE);
            List<PolicyGroupInfo> policyGroupInfos=policyGroupInfoDao.findPolicyByServiceGroupInfoList(serviceGroupId+"");
            
            for (IpCommCfg cfg : entity.getIpCommGroupCfgList()) {
                BeanUtils.copyProperties(entity, cfg, new String[]{"cfgId","userregion3"});
                
                Integer regionId = 0;
                List<Integer> regionIds = ConfigServiceUtil.getId(3, 1);
				if(regionIds!=null && regionIds.size()>0){
					regionId = regionIds.get(0);
				}else {
					throw new MaatConvertException("Get region id failed");
				}
				cfg.setRegionId(regionId);
				
                cfg.setRequestId(0);
                cfg.setClassify("0");
                cfg.setAttribute("0");
                cfg.setLable("0");
                cfg.setCreateTime(createTime);
                cfg.setCreatorId(entity.getCurrentUser().getId());
                cfg.setIsValid(Constants.VALID_NO);
                cfg.setIsAudit(Constants.AUDIT_NOT_YET);
                cfg.setGroupId(serviceGroupId);
                ipCommGroupCfgDao.insertForBatch(cfg);
                
            }
            // 更新分组状态
            groupManageService.updateGroupStatus(policyGroupInfos, Constants.IP_OBJ_GROUP_TYPE);
            transObjGroupToMaat(policyGroupInfos);
        }

    }
    
    public void delete(String ids, String groupIds, IpCommCfg cfg, HttpServletRequest request, HttpServletResponse response) throws Exception {
        if(ids == null) {
        	groupIds = "";
        	String cfgIds = "";
        	String serviceGroupIds = "";
        	
        	// 删除操作后获取 ①需配置更新的分组（存在域配置）②需配置取消的分组（无域配置）-> 配置分别操作更新或取消
    		List<IpCommCfg> set = ipCommGroupCfgDao.getGroupIds(cfg);
    		if(set.size() == 0) { // 无可删除配置
    			return;
    		}else {
    			for (IpCommCfg ipCommCfg : set) {
    				Integer groupId = ipCommCfg.getGroupId();
    				cfgIds += ","+ipCommCfg.getCfgId();
    				if(!serviceGroupIds.contains(groupId+"")) {
    					serviceGroupIds += ","+groupId;
    				}
    			}
    			cfgIds = cfgIds.substring(1);
    			serviceGroupIds = serviceGroupIds.substring(1);
    		}
    		ipCommGroupCfgDao.delete(cfgIds);
    		
    		String[] strings = serviceGroupIds.split(",");
    		serviceGroupIds = "";
    		for (String groupId : strings) {
    			Integer size = ipCommGroupCfgDao.getCfgInfoByGroupIds(groupId);
    			if(size == 0) { // 需配置取消
    				serviceGroupIds += ","+groupId;
    			}else { // 需配置更新
    				groupIds += ","+groupId;
    			}
			}
    		
    		// 配置取消
    		if(StringUtils.isNotBlank(serviceGroupIds)) {
    			serviceGroupIds = serviceGroupIds.substring(1);
    			ObjectGroupController groupController = SpringContextHolder.getBean(ObjectGroupController.class);
            	Page<CfgIndexInfo> auditPage = new Page<CfgIndexInfo>(request,response,"r");
            	Properties props = groupController.getMsgProp();
            	
            	// 配置未生效
            	/*String updateStatusGroupIds = "";
            	for (String groupId : serviceGroupIds.split(",")) {
            		List<CfgIndexInfo> list = commonPolicyDao.getObjGroupListByGroupIds(groupId, 888, Constants.VALID_NO);
            		if(list.size() > 0) {
            			updateStatusGroupIds += ","+groupId;
            		}
				}
            	if(StringUtils.isNotBlank(updateStatusGroupIds)) {
            		updateStatusGroupIds = updateStatusGroupIds.substring(1);
            		CfgIndexInfo entity = new CfgIndexInfo(); 
                	entity.setUserRegion5(updateStatusGroupIds);
                	entity.setFunctionId(888);
                	entity.setCommonGroupIds("");
                	entity.setIsValid(Constants.VALID_NO);
                	commonPolicyDao.updateCfgIndexCommonGroupIdsBatch(entity);
                	
                	List<PolicyGroupInfo> policyGroupInfos=policyGroupInfoDao.findPolicyByServiceGroupInfoList(updateStatusGroupIds);
                	groupManageService.updateGroupStatus(policyGroupInfos, Constants.IP_OBJ_GROUP_TYPE);
            	}*/
            	
            	// 配置已生效×
            	// 组下无域配置common_group_ids -> "",ud_flag -> 0
            	CfgIndexInfo entity = new CfgIndexInfo(); 
            	entity.setUserRegion5(serviceGroupIds);
            	entity.setFunctionId(888);
            	entity.setCommonGroupIds("");
            	commonPolicyDao.updateCfgIndexCommonGroupIdsBatch(entity);
            	List<PolicyGroupInfo> policyGroupInfos=policyGroupInfoDao.findPolicyByServiceGroupInfoList(serviceGroupIds);
            	groupManageService.updateGroupStatus(policyGroupInfos, Constants.IP_OBJ_GROUP_TYPE);
            	
            	entity.setServiceId(0);
            	entity.setIsValid(Constants.VALID_NO);
            	entity.setIsAudit(Constants.AUDIT_NOT_YES);
            	entity.setBatchAuditValue("1");
            	entity.setBatchValidValue("1,0");
            	groupController.auditAll(auditPage, Constants.AUDIT_NOT_YES, entity, props);
    		}
    		// 配置更新
    		if(StringUtils.isNotBlank(groupIds)) {
    			groupIds = groupIds.substring(1);
    			List<PolicyGroupInfo> policyGroupInfos = policyGroupInfoDao.findPolicyByServiceGroupInfoList(groupIds);
    			transObjGroupToMaat(policyGroupInfos);
    		}
    		
        }else {
        	List<PolicyGroupInfo> policyGroupInfos = policyGroupInfoDao.findPolicyByServiceGroupInfoList(groupIds);
        	ipCommGroupCfgDao.delete(ids);
        	// 更新分组状态
        	groupManageService.updateGroupStatus(policyGroupInfos, Constants.IP_OBJ_GROUP_TYPE);
        	transObjGroupToMaat(policyGroupInfos);
        	
        }
    }
    
    @Transactional(readOnly=false,rollbackFor=RuntimeException.class)
    public void saveAndSend(FunctionRegionDict regionDict, FunctionServiceDict serviceDict, List<BaseIpCfg> cfgs, List<Integer> groupIds) {
        logger.warn("Start to save IP,size:"+cfgs.size());
        long start=System.currentTimeMillis();
        SqlSessionFactory sqlSessionFactory=SpringContextHolder.getBean(SqlSessionFactory.class);
        SqlSession batchSqlSession = null;
        // 导入域配置 -> ①分组不存在，新增分组并返回serviceGroupId ②分组存在，获取serviceGroupId -> 数据入库  -> 更新分组状态 -> 判断是否配置下发
        try{
        	int index = 0;
        	String ids = "";
            List<CommonGroupInfo> insertGroupList = new ArrayList<CommonGroupInfo>();
            batchSqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
            for(BaseIpCfg cfg:cfgs) {
                IpCommCfg ipCommCfg=new IpCommCfg();
                BeanUtils.copyProperties(cfg, ipCommCfg);
                
                Integer groupId = commonGroupManageDao.getGroupIdByGroupName(ipCommCfg.getGroupName(), Constants.IP_OBJ_GROUP_TYPE);
                if(groupId == null) { // 分组不存在，新增 UdFlag为1
                	groupId = groupIds.get(index);
                	index++;
                	
                	CommonGroupInfo groupInfo = new CommonGroupInfo();
                	groupInfo.setCreatorId(ipCommCfg.getCreatorId());
                	groupInfo.setCreateTime(ipCommCfg.getCreateTime());
                	groupInfo.setGroupName(ipCommCfg.getGroupName());
                	groupInfo.setGroupType(Constants.IP_OBJ_GROUP_TYPE);
                	groupInfo.setServiceGroupId(groupId);
                	groupInfo.setUdFlag(1);
                	insertGroupList.add(groupInfo);
                }else {
                	if(!ids.contains(groupId+"")) {
                		ids += ","+groupId;
                	}
                }
                
                ipCommCfg.setGroupId(groupId);
                ((IpCommGroupCfgDao) batchSqlSession.getMapper(IpCommGroupCfgDao.class)).insertForBatch(ipCommCfg);

            }
            batchSqlSession.commit();
            if(insertGroupList.size() > 0) {
            	commonGroupManageDao.insertBatch(insertGroupList);
            }
            
            if(StringUtils.isNotBlank(ids)) {
            	// 更新分组状态
            	String serviceGroupIds = ids.substring(1);
            	List<PolicyGroupInfo> policyGroupInfos = policyGroupInfoDao.findPolicyByServiceGroupInfoList(serviceGroupIds);
            	groupManageService.updateGroupStatus(policyGroupInfos, Constants.IP_OBJ_GROUP_TYPE);
            	// 判断是否配置下发
            	transObjGroupToMaat(policyGroupInfos);
            }
            
        }finally {
            if(batchSqlSession != null){
                batchSqlSession.close();
            }
            
        }
        long end=System.currentTimeMillis();
        logger.warn("Save IP finish,cost:"+(end-start));
        cfgs.clear();
        cfgs=null;
    }
    
}