package cn.ksource.web.service.cmdb.impl;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.JsonUtil;
|
import cn.ksource.web.Constants;
|
import cn.ksource.web.service.cmdb.CICategory;
|
import cn.ksource.web.service.cmdb.CIPropertity;
|
import cn.ksource.web.service.cmdb.CIPropertityMetadata;
|
import cn.ksource.web.service.cmdb.CIPropertityService;
|
import cn.ksource.web.service.cmdb.DSLCategory;
|
import cn.ksource.web.service.cmdb.SUBCIPropertity;
|
import cn.ksource.web.service.cmdb.SUBCIPropertityMetadata;
|
import cn.ksource.web.service.cmdb.SequenceService;
|
|
@Service
|
public class CIPropertityServiceImpl implements CIPropertityService {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Autowired
|
private SequenceService sequenceService;
|
|
@Override
|
public List<Map> getMetadataByTableName(String tableName) {
|
//TODO 需要加入缓存处理
|
String sql = "select * from CMDB_CI_EXTEND_COLUMN where TABLENAME=:TABLENAME and STATE=1 order by ORDERNUM";
|
List<Map> list = baseDao.queryForList(sql,new SqlParameter("TABLENAME",tableName));
|
for (Map map : list) {
|
if (Constants.CMDB_CI_EXTEND_COLUMN_DATATYPE_SINGLE_SELECT == ConvertUtil.obj2Integer(map.get("DATATYPE"))) {
|
map.put("_SELECTVALUE", map.get("SELECTVALUE") == null ? new HashMap() : JsonUtil.json2Map(map.get("SELECTVALUE").toString()));
|
} else if (Constants.CMDB_CI_EXTEND_COLUMN_DATATYPE_MULTI_SELECT == ConvertUtil.obj2Integer(map.get("DATATYPE"))) {
|
if (map.get("SELECTVALUE") != null) {
|
Map resultMap = JsonUtil.json2Map(map.get("SELECTVALUE").toString());
|
List<Map> resultList = new LinkedList<Map>();
|
for (Iterator iterator = resultMap.keySet().iterator(); iterator.hasNext();) {
|
String key = (String) iterator.next();
|
Map temMap = new HashMap();
|
temMap.put("KEY", key);
|
temMap.put("VALUE", resultMap.get(key));
|
resultList.add(temMap);
|
}
|
map.put("_SELECTVALUE",resultList);
|
map.put("_SELECTVALUE_JSON", JsonUtil.list2Json(resultList));
|
} else {
|
map.put("_SELECTVALUE", new ArrayList());
|
map.put("_SELECTVALUE_JSON", "[]");
|
}
|
}
|
}
|
return list;
|
}
|
|
@Override
|
public CIPropertity getCIPropertity(String ci_id) {
|
String sql = "select * from CMDB_CI_BASE where id=:id";
|
Map basePropertity = baseDao.queryForMap(sql,new SqlParameter("id",ci_id));
|
|
//所属层级
|
int level = ConvertUtil.obj2Int(basePropertity.get("LEVELNUMBER"));
|
|
CIPropertity propertity = new CIPropertity();
|
//基本属性
|
propertity.setBasePropertity(basePropertity);
|
//通用属性
|
propertity.setCommonPropertity(baseDao.queryForMap("select * from CMDB_CI_BASE_EXTEND where id=:id",new SqlParameter("id",ci_id)));
|
|
//分类信息
|
propertity.setCategory(getCICategory(basePropertity.get("THELEVELID").toString()));
|
//元数据信息
|
propertity.setMeta(getCIPropertityMetadata(propertity.getCategory().getCategory().get("TABLE_NAME").toString()));
|
|
//一级属性
|
propertity.setFirstLevelPropertity(baseDao.queryForMap("select * from "+ propertity.getCategory().getFirstCategory().get("TABLE_NAME") +" where id=:id",new SqlParameter("id",ci_id)));
|
//二级属性
|
propertity.setSecondLevelPropertity(baseDao.queryForMap("select * from "+ propertity.getCategory().getSecondCategory().get("TABLE_NAME") +" where id=:id",new SqlParameter("id",ci_id)));
|
|
if (level == 3) {
|
//三级属性
|
propertity.setThirdLevelPropertity(baseDao.queryForMap("select * from "+ propertity.getCategory().getThirdCategory().get("TABLE_NAME") +" where id=:id",new SqlParameter("id",ci_id)));
|
}
|
return propertity;
|
}
|
|
public SUBCIPropertity getSubCIPropertity(String ci_id) {
|
String sql = "select * from CMDB_CI_BASE where id=:id";
|
Map basePropertity = baseDao.queryForMap(sql,new SqlParameter("id",ci_id));
|
|
SUBCIPropertity propertity = new SUBCIPropertity();
|
//基本属性
|
propertity.setBasePropertity(basePropertity);
|
//通用属性
|
propertity.setCommonPropertity(baseDao.queryForMap("select * from CMDB_CI_SUB_BASE_EXTEND where id=:id",new SqlParameter("id",ci_id)));
|
|
//分类信息
|
propertity.setCategory(getCICategory(basePropertity.get("THELEVELID").toString()));
|
//元数据信息
|
propertity.setMeta(getSubCIPropertityMetadata(propertity.getCategory().getCategory().get("TABLE_NAME").toString()));
|
|
//一级属性
|
propertity.setCustomPropertity(baseDao.queryForMap("select * from "+ propertity.getCategory().getFirstCategory().get("TABLE_NAME") +" where id=:id",new SqlParameter("id",ci_id)));
|
|
return propertity;
|
}
|
|
|
@Override
|
public Map getCategoryById(String categoryid) {
|
//TODO 需要加入缓存处理
|
String sql = "select * from CMDB_CI_CATEGORY where id=:id";
|
return baseDao.queryForMap(sql,new SqlParameter("id",categoryid));
|
}
|
|
@Override
|
public Map getDslCategoryById(String categoryid) {
|
//TODO 需要加入缓存处理
|
String sql = "select * from DSL_CATEGORY where id=:id";
|
return baseDao.queryForMap(sql,new SqlParameter("id",categoryid));
|
}
|
|
@Override
|
public CIPropertityMetadata getCIPropertityMetadata(String tablename) {
|
|
if (StringUtils.isBlank(tablename) || StringUtils.equalsIgnoreCase(tablename, Constants.CMDB_CI_BASE_EXTEND_TABLE)) {
|
CIPropertityMetadata meta = new CIPropertityMetadata();
|
meta.setLevel(0);
|
meta.setCommonPropertityMetadata(getMetadataByTableName(Constants.CMDB_CI_BASE_EXTEND_TABLE));
|
return meta;
|
}
|
|
Map category = baseDao.queryForMap("select * from CMDB_CI_CATEGORY where TABLE_NAME=:TABLE_NAME",new SqlParameter("TABLE_NAME",tablename));
|
CIPropertityMetadata meta = new CIPropertityMetadata();
|
//级别
|
meta.setLevel(ConvertUtil.obj2Int(category.get("JB")));
|
meta.setCatetory(category);
|
meta.setCommonPropertityMetadata(getMetadataByTableName(Constants.CMDB_CI_BASE_EXTEND_TABLE));
|
|
if (meta.getLevel() == 1) {
|
meta.setFirstLevelPropertityMetadata(getMetadataByTableName(category.get("TABLE_NAME").toString()));
|
} else if (meta.getLevel() == 2) {
|
meta.setSecondLevelPropertityMetadata(getMetadataByTableName(category.get("TABLE_NAME").toString()));
|
Map firstCategory = getCategoryById(category.get("PID").toString());
|
meta.setFirstLevelPropertityMetadata(getMetadataByTableName(firstCategory.get("TABLE_NAME").toString()));
|
} else {
|
meta.setThirdLevelPropertityMetadata(getMetadataByTableName(category.get("TABLE_NAME").toString()));
|
Map secondCategory = getCategoryById(category.get("PID").toString());
|
meta.setSecondLevelPropertityMetadata(getMetadataByTableName(secondCategory.get("TABLE_NAME").toString()));
|
Map firstCategory = getCategoryById(secondCategory.get("PID").toString());
|
meta.setFirstLevelPropertityMetadata(getMetadataByTableName(firstCategory.get("TABLE_NAME").toString()));
|
}
|
|
return meta;
|
}
|
|
public SUBCIPropertityMetadata getSubCIPropertityMetadata(String tablename){
|
|
if (StringUtils.isBlank(tablename) || StringUtils.equalsIgnoreCase(tablename, Constants.CMDB_SUB_CI_BASE_EXTEND_TABLE)) {
|
SUBCIPropertityMetadata meta = new SUBCIPropertityMetadata();
|
meta.setCommonPropertityMetadata(getMetadataByTableName(Constants.CMDB_SUB_CI_BASE_EXTEND_TABLE));
|
return meta;
|
}
|
|
Map category = baseDao.queryForMap("select * from CMDB_CI_CATEGORY where TABLE_NAME=:TABLE_NAME",new SqlParameter("TABLE_NAME",tablename));
|
SUBCIPropertityMetadata meta = new SUBCIPropertityMetadata();
|
//级别
|
meta.setCatetory(category);
|
meta.setCommonPropertityMetadata(getMetadataByTableName(Constants.CMDB_SUB_CI_BASE_EXTEND_TABLE));
|
|
meta.setCustomPropertityMetadata(getMetadataByTableName(category.get("TABLE_NAME").toString()));
|
|
return meta;
|
}
|
|
@Override
|
public CICategory getCICategory(String categoryid) {
|
Map base = getCategoryById(categoryid);
|
CICategory category = new CICategory();
|
category.setCategory(base);
|
category.setLevel(ConvertUtil.obj2Integer(base.get("JB")));
|
//一级
|
if (category.getLevel() == 1) {
|
category.setFirstCategory(base);
|
} else if(category.getLevel() == 2) {
|
category.setSecondCategory(base);
|
category.setFirstCategory(getCategoryById(base.get("PID").toString()));
|
} else {
|
category.setThirdCategory(base);
|
category.setSecondCategory(getCategoryById(base.get("PID").toString()));
|
category.setFirstCategory(getCategoryById(category.getSecondCategory().get("PID").toString()));
|
}
|
return category;
|
}
|
|
|
@Override
|
public DSLCategory getDSLCategory(String categoryid) {
|
Map base = getDslCategoryById(categoryid);
|
DSLCategory category = new DSLCategory();
|
category.setCategory(base);
|
category.setLevel(ConvertUtil.obj2Integer(base.get("LEVEL")));
|
//一级
|
if (category.getLevel() == 1) {
|
category.setFirstCategory(base);
|
} else if(category.getLevel() == 2) {
|
category.setSecondCategory(base);
|
category.setFirstCategory(getDslCategoryById(base.get("P_ID").toString()));
|
} else {
|
category.setThirdCategory(base);
|
category.setSecondCategory(getDslCategoryById(base.get("P_ID").toString()));
|
category.setFirstCategory(getDslCategoryById(category.getSecondCategory().get("P_ID").toString()));
|
}
|
return category;
|
}
|
|
public void copyData(String tableName,String source_id,List<String> target_ids){
|
Map map = baseDao.queryForMap("select * from " + tableName +" where id=:id",new SqlParameter("id",source_id));
|
if (map.isEmpty()) {
|
return;
|
}
|
String sql = "insert into " + tableName + "(";
|
String values = " values(";
|
for (Iterator iterator = map.keySet().iterator(); iterator.hasNext();) {
|
String key = (String) iterator.next();
|
sql += key + ",";
|
values += ":"+key+",";
|
}
|
sql = StringUtils.removeEnd(sql, ",")+")" + StringUtils.removeEnd(values, ",") + ")";
|
List<SqlParameter> list = new LinkedList<SqlParameter>();
|
|
for (String targetid : target_ids) {
|
SqlParameter param = new SqlParameter();
|
param.putAll(map);
|
param.put("ID", targetid);
|
list.add(param);
|
}
|
baseDao.executeBatch(sql, list);
|
}
|
|
|
|
/*public void execCopyCI(String ci_id,int count,HttpServletRequest request){
|
CMDB_CI_BASE base = new CMDB_CI_BASE(ci_id).getInstanceById();
|
CICategory category = getCICategory(base.getThelevelid());
|
String extendTableName = Constants.CMDB_CI_BASE_EXTEND_TABLE;
|
String secondTableName = category.getSecondCategory().get("TABLE_NAME").toString();
|
String thirdTableName = category.getLevel() == 3 ? category.getThirdCategory().get("TABLE_NAME").toString() :"";
|
List<String> list = new LinkedList<String>();
|
for (int i = 1; i < count; i++) {
|
base.setId(StringUtil.getUUID());
|
base.setSeachcode(sequenceService.getCICategorySequence(base.getThelevelid()));
|
sequenceService.nextCICategorySequence(base.getThelevelid());
|
base.setMembercode(String.valueOf(sequenceService.getMemberSequence(base.getMemberid())));
|
sequenceService.nextMemberSequence(base.getMemberid());
|
base.insert();
|
|
//生成二维码
|
TwoDimensionCode handler = new TwoDimensionCode();
|
String searchCode = base.getSeachcode();
|
String url = Constants.QRCODE_URL + searchCode;
|
|
String logoUrl = WebUtil.getRealPath(request, "/static/logo.jpg");
|
handler.encoderQRCode(url, WebUtil.getRealPath(request, "/upload/qrCode/"+searchCode+".png"), "png",logoUrl);
|
|
list.add(base.getId());
|
}
|
copyData(extendTableName,ci_id,list);
|
copyData(secondTableName,ci_id,list);
|
copyData(thirdTableName,ci_id,list);
|
|
}*/
|
|
/**
|
* 不需要比对的列
|
* @return
|
*/
|
public Map noCompairedColumns() {
|
Map map = new HashMap();
|
map.put("ID", "编号");
|
map.put("FLOW_ID", "流程编号");
|
map.put("SEACHCODE", "搜索码");
|
map.put("MEMBERCODE", "内部编号");
|
map.put("MEMBERID", "客户编号");
|
map.put("MEMBERNAME", "客户名称");
|
map.put("LEVELNUMBER", "层级序号");
|
map.put("THELEVELID", "层级编号");
|
map.put("FIRSTLEVELID", "一级编号");
|
map.put("SECONDLEVELID", "二级编号");
|
map.put("THIRDLEVELID", "三级编号");
|
map.put("USINGSTATE", "使用状态");
|
map.put("CREATETIME", "创建时间");
|
map.put("VERSION", "版本");
|
map.put("DISK_ID", "磁盘序列号");
|
map.put("LEIX", "类型");
|
map.put("PCI_ID", "父CI编号");
|
|
return map;
|
}
|
|
/**
|
* 不需要显示的列
|
* @return
|
*/
|
public Map noShowColumns() {
|
Map map = new HashMap();
|
map.put("LASTUPDATETIME", "最后更新时间");
|
map.put("SERVICE_PROVIDERS_ID", "服务商编号");
|
map.put("SYSTEMINTEGRATIONID", "集成商编号");
|
map.put("MAINUFACTURERID", "厂商编号");
|
map.put("DEPT_ID", "负责部门编号");
|
map.put("SERVICE_PROVIDERS_NAME", "服务商名称");
|
|
return map;
|
}
|
}
|
