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

package com.nis.web.service.basics;

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

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.PolicyGroupInfo;
import com.nis.domain.basics.ScriberIdCommCfg;
import com.nis.domain.configuration.BaseStringCfg;
import com.nis.domain.configuration.CfgIndexInfo;
import com.nis.exceptions.MaatConvertException;
import com.nis.util.ConfigServiceUtil;
import com.nis.util.Constants;
import com.nis.web.dao.CrudDao;
import com.nis.web.dao.basics.PolicyGroupInfoDao;
import com.nis.web.dao.basics.ScriberIdCommGroupDao;
import com.nis.web.service.CrudService;
import com.nis.web.service.SpringContextHolder;

@Service
public class ScriberIdCommGroupService extends CrudService<CrudDao<ScriberIdCommCfg>, ScriberIdCommCfg>{

    @Autowired
    private ScriberIdCommGroupDao scriberIdCommGroupDao;
    
    @Autowired
    private PolicyGroupInfoDao policyGroupInfoDao;
    
    private CommonGroupManageService groupManageService = SpringContextHolder.getBean(CommonGroupManageService.class);
    
    public Page<ScriberIdCommCfg> findPage(Page<ScriberIdCommCfg> page, ScriberIdCommCfg entity) {
        entity.getSqlMap().put("dsf", configScopeFilter(entity.getCurrentUser(),"r"));
        entity.setPage(page);
        List<ScriberIdCommCfg> list=scriberIdCommGroupDao.findAllPageList(entity);
        for (int i = 0; i < list.size(); i++) {
            String key=list.get(i).getCfgKeywords().replace("***and***", " ");
            list.get(i).setCfgKeywords(key);
        }
        page.setList(list);
        return page;
    }

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

    public ScriberIdCommCfg get(Long id ) {
        return scriberIdCommGroupDao.get(id);
    }

    // 新增
    @Transactional(readOnly=false,rollbackFor=RuntimeException.class)
    public void saveCommGroupCfg(CfgIndexInfo entity) {
        Date createTime=new Date();
        if(entity.getScriberIdCommGroupList()!=null) {
        	List<PolicyGroupInfo> policyGroupInfos=policyGroupInfoDao.findPolicyByServiceGroupInfoList(entity.getGroupId().toString());
        	for (int i = 0; i < entity.getScriberIdCommGroupList().size(); i++) {
                BeanUtils.copyProperties(entity, entity.getScriberIdCommGroupList().get(i), new String[]{"cfgId"});
                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");
				}
                entity.getScriberIdCommGroupList().get(i).setRegionId(regionId);
                entity.getScriberIdCommGroupList().get(i).setRequestId(0);
                entity.getScriberIdCommGroupList().get(i).setClassify("0");
                entity.getScriberIdCommGroupList().get(i).setAttribute("0");
                entity.getScriberIdCommGroupList().get(i).setLable("0");
                entity.getScriberIdCommGroupList().get(i).setIsHexbin(2);
                entity.getScriberIdCommGroupList().get(i).setCreateTime(createTime);
                entity.getScriberIdCommGroupList().get(i).setCreatorId(entity.getCurrentUser().getId());
                entity.getScriberIdCommGroupList().get(i).setIsValid(Constants.VALID_NO);
                entity.getScriberIdCommGroupList().get(i).setIsAudit(Constants.AUDIT_NOT_YET);
                if(entity.getScriberIdCommGroupList().get(i).getCfgKeywords().contains("***and***")){
                    entity.getScriberIdCommGroupList().get(i).setExprType(1);
                }else{
                    entity.getScriberIdCommGroupList().get(i).setExprType(0);
                }
                entity.getScriberIdCommGroupList().get(i).setGroupId(entity.getGroupId());
                
                scriberIdCommGroupDao.insertCommGroupCfg(entity.getScriberIdCommGroupList().get(i));
            }
            // 更新分组状态
            groupManageService.updateGroupStatus(policyGroupInfos, 9);
          //TODO 组配置更新时 需检索是否被其它配置引用，若被引用需调用相应服务接口更新配置
            //transObjGroupToMaat(policyGroupInfos);
            
        }
    }

    @Transactional(readOnly=false,rollbackFor=RuntimeException.class)
    public void update(ScriberIdCommCfg entity){
        Date editTime=new Date();
        entity.setIsValid(0);
        entity.setIsAudit(0);
        entity.setEditTime(editTime);
        entity.setEditorId(entity.getCurrentUser().getId());
        if(entity.getCfgKeywords().contains("***and***")){
            entity.setExprType(1);
        }else{
            entity.setExprType(0);
        }
        scriberIdCommGroupDao.update(entity);
        
        // 更新分组状态
        if(!entity.getUserRegion1().equals(entity.getGroupId().toString())) {
        	List<PolicyGroupInfo> policyGroupInfos = new ArrayList<PolicyGroupInfo>();
        	policyGroupInfos.addAll(policyGroupInfoDao.findPolicyByServiceGroupInfoList(entity.getUserRegion1()));
        	policyGroupInfos.addAll(policyGroupInfoDao.findPolicyByServiceGroupInfoList(entity.getGroupId().toString()));
        	groupManageService.updateGroupStatus(policyGroupInfos, 9);
        }
        
    }


    @Transactional(readOnly=false,rollbackFor=RuntimeException.class)
    public void delete(String ids, String groupIds) {
    	List<PolicyGroupInfo> policyGroupInfos=policyGroupInfoDao.findPolicyByServiceGroupInfoList(groupIds);
    	scriberIdCommGroupDao.delete(ids);
        // 更新分组状态
        groupManageService.updateGroupStatus(policyGroupInfos, 9);
    }

    public List<ScriberIdCommCfg> getByIds(String ids) {
        if(ids==null) {
            throw new RuntimeException("ids is null!");
        }
        return scriberIdCommGroupDao.getByIds(ids);
    }
    
    @Transactional(readOnly=false,rollbackFor=RuntimeException.class)
    public void saveAndSend(FunctionRegionDict regionDict, FunctionServiceDict serviceDict, List<BaseStringCfg<?>> cfgs) {
        logger.warn("Start to save ScriberId,size:"+cfgs.size());
        long start=System.currentTimeMillis();
        SqlSessionFactory sqlSessionFactory=SpringContextHolder.getBean(SqlSessionFactory.class);
        SqlSession batchSqlSession = null;
        // 需要通过新增域接口新增的ip集合
        try{
        	String ids = "";
            batchSqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
            for(BaseStringCfg<?> cfg:cfgs) {
            	if(!ids.contains(cfg.getGroupId()+"")) {
            		ids += ","+cfg.getGroupId();
            	}
            	ScriberIdCommCfg commCfg=new ScriberIdCommCfg();
                BeanUtils.copyProperties(cfg, commCfg);
                ((ScriberIdCommGroupDao) batchSqlSession.getMapper(ScriberIdCommGroupDao.class)).insertCommGroupCfg(commCfg);
            }
            batchSqlSession.commit();
            
            // 更新分组状态
            String serviceGroupIds = ids.substring(1);
            List<PolicyGroupInfo> policyGroupInfos = policyGroupInfoDao.findPolicyByServiceGroupInfoList(serviceGroupIds);
            groupManageService.updateGroupStatus(policyGroupInfos, 9);
            
        }finally {
            if(batchSqlSession != null){
                batchSqlSession.close();
            }
            
        }
        long end=System.currentTimeMillis();
        logger.warn("Save ScriberId finish,cost:"+(end-start));
        cfgs.clear();
        cfgs=null;
    }
    
}