package cn.ksource.web.facade.propform;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.beans.CMDB_CI_CATEGORY;
|
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;
|
|
@Service("propformFacade")
|
public class PropformFacadeImpl implements PropformFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
@Override
|
public Map queryStorageData(String ciId) {
|
Map data = new HashMap();
|
Map label = new HashMap();
|
String selectSql = "SELECT * FROM prop_data WHERE BUS_ID = :ciId";
|
List<Map> datas = baseDao.queryForList(selectSql,new SqlParameter("ciId",ciId));
|
|
if(null!=datas && datas.size()>0) {
|
for(Map d : datas) {
|
String column_id = ConvertUtil.obj2StrBlank(d.get("COLUMN_ID"));
|
String column_value = ConvertUtil.obj2StrBlank(d.get("COLUMN_VALUE"));
|
String column_text = ConvertUtil.obj2StrBlank(d.get("COLUMN_TEXT"));
|
|
data.put(column_id, column_value);
|
label.put(column_id, column_text);
|
}
|
}
|
Map resultMap = new HashMap();
|
resultMap.put("data", data);
|
resultMap.put("label", label);
|
return resultMap;
|
}
|
@Override
|
public List queryGroupPropsTwo(String cate) {
|
CMDB_CI_CATEGORY category = new CMDB_CI_CATEGORY(cate).getInstanceById();
|
String pid = category.getPid();
|
|
Map paramMap = new HashMap();
|
paramMap.put("pid", pid);
|
paramMap.put("cate", cate);
|
|
|
StringBuilder builder = new StringBuilder("SELECT D.* FROM (");
|
//先查询分组信息
|
String ejGroup = "SELECT A.*,2 AS CATE FROM PROP_GROUP A,CMDB_CI_CATEGORY A1 WHERE A.LINK_ID = A1.ID AND A.LINK_ID = :pid AND A.STATE = 1";
|
builder.append(ejGroup);
|
builder.append(" UNION ");
|
String sjGroup = "SELECT B.*,3 AS CATE FROM PROP_GROUP B,CMDB_CI_CATEGORY B1 WHERE B.LINK_ID = B1.ID AND B.LINK_ID = :cate AND B.STATE = 1";
|
builder.append(sjGroup);
|
builder.append(") D ORDER BY D.CATE,D.SERIAL ");
|
|
List<Map> groups = baseDao.queryForList(builder.toString(),paramMap);
|
System.out.println(JsonUtil.list2Json(groups));
|
|
if(null!=groups && groups.size()>0) {
|
String selectPropSql = "SELECT A.* FROM PROP_COLUMN A,PROP_GROUP B WHERE A.GROUP_ID = B.ID AND (B.LINK_ID = :pid OR B.LINK_ID = :cate ) AND A.STATE = 1 AND B.STATE = 1 ORDER BY A.SERIAL";
|
List<Map> props = baseDao.queryForList(selectPropSql,paramMap);
|
|
Map cacheMap = new HashMap();
|
Map cacheMap2 = new HashMap();
|
if(null!=props && props.size()>0) {
|
|
props = queryListValue(props);
|
|
|
for(Map prop : props) {
|
String groupId = ConvertUtil.obj2StrBlank(prop.get("GROUP_ID"));
|
Map m = new HashMap();
|
int datatype = ConvertUtil.obj2Int(prop.get("DATATYPE"));
|
if(datatype == Constants.CMDB_CI_EXTEND_COLUMN_DATATYPE_TEXT || datatype==Constants.CMDB_CI_EXTEND_COLUMN_DATATYPE_MULTI_SELECT) {
|
m = cacheMap2;
|
} else {
|
m = cacheMap;
|
}
|
|
if(m.containsKey(groupId)) {
|
List ls = (List)m.get(groupId);
|
ls.add(prop);
|
} else {
|
List ls = new ArrayList();
|
ls.add(prop);
|
m.put(groupId, ls);
|
}
|
}
|
}
|
|
for(Map group : groups) {
|
group.put("props", cacheMap.get(group.get("ID")));
|
group.put("props1", cacheMap2.get(group.get("ID")));
|
}
|
|
}
|
|
return groups;
|
}
|
private List<Map> queryListValue(List<Map> props) {
|
String selectSql = "SELECT * FROM PROP_SEL WHERE STATE = 1 ORDER BY SERIAL ";
|
List<Map> items = baseDao.queryForList(selectSql);
|
Map cacheMap = new HashMap();
|
if(null!=items && items.size()>0) {
|
for(Map item : items) {
|
String extendId = ConvertUtil.obj2StrBlank(item.get("EXTENDID"));
|
if(cacheMap.containsKey(extendId)) {
|
List list = (List)cacheMap.get(extendId);
|
list.add(item);
|
} else {
|
List list = new ArrayList();
|
list.add(item);
|
cacheMap.put(extendId, list);
|
}
|
}
|
}
|
|
for(Map prop : props) {
|
String id = ConvertUtil.obj2StrBlank(prop.get("ID"));
|
if(cacheMap.containsKey(id)) {
|
prop.put("items", cacheMap.get(id));
|
}
|
}
|
|
return props;
|
}
|
@Override
|
public Map queryCommonProps() {
|
String selectSq1 = "SELECT * FROM PROP_COLUMN WHERE STATE = 1 AND GROUP_ID='-1' ORDER BY SERIAL";
|
List<Map> commonProps = baseDao.queryForList(selectSq1);
|
Map resultMap = new HashMap();
|
List commonProp = new ArrayList();
|
List textareaProp = new ArrayList();
|
|
//如果通用属性扩展下为复选或单选，则查询出其属性
|
if(null!=commonProps && commonProps.size()>0) {
|
commonProps = queryListValue(commonProps);
|
|
for(Map m : commonProps) {
|
int datatype = ConvertUtil.obj2Int(m.get("DATATYPE"));
|
if(datatype == Constants.CMDB_CI_EXTEND_COLUMN_DATATYPE_TEXT || datatype==Constants.CMDB_CI_EXTEND_COLUMN_DATATYPE_MULTI_SELECT) {
|
textareaProp.add(m);
|
} else {
|
commonProp.add(m);
|
}
|
}
|
}
|
|
resultMap.put("commonProp", commonProp);
|
resultMap.put("textareaProp", textareaProp);
|
|
return resultMap;
|
}
|
|
}
|
