package cn.ksource.web.facade.wechat.uwyw;
|
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
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.page.PageInfo;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.core.web.ClientUtil;
|
import cn.ksource.web.service.file.FileService;
|
|
|
@Service("uknowledgeFacade")
|
public class UknowledgeFacadeImpl implements UknowledgeFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Autowired
|
private FileService fileService;
|
|
|
@Override
|
public Integer queryProNewKwCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(DISTINCT K.ID) FROM KM_LIBRARY K WHERE K.STATE=1 AND ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) ");
|
return baseDao.queryForInteger(sql.toString(),params);
|
}
|
|
@Override
|
public PageInfo queryProNewKwData(PageInfo pageInfo,
|
Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT K.* FROM KM_LIBRARY K WHERE K.STATE=1 AND ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) ");
|
sql.append(" ORDER BY K.UPDATE_DATE DESC ");
|
PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
List<Map> datas = info.getDatas();
|
if(datas.size()>0){
|
for(Map map:datas){
|
List<Map> fileList = fileService.getFileList(ConvertUtil.obj2StrBlank(map.get("FILE_ID")),1);
|
if(fileList.size() > 0){
|
map.put("isfiles", "1");
|
}else{
|
map.put("isfiles", "0");
|
}
|
}
|
}
|
info.setDatas(datas);
|
return info;
|
}
|
|
@Override
|
public Map companyCiCate(String pid) {
|
StringBuffer sql=new StringBuffer("SELECT A.ID,A.NAME,A.CODE,A.LV JB,A.PID FROM CMDB_CI_CATEGORY A WHERE A.STATE = 1 and a.cate_type=1 ");
|
Map paraMap = new HashMap();
|
if(StringUtil.isEmpty(pid)){
|
sql.append(" AND A.LV = 1 ");
|
}
|
sql.append(" ORDER BY A.LV,A.SERIAL ");
|
List<Map> categoryList = baseDao.queryForList(sql.toString(),paraMap);
|
|
if(!StringUtil.isEmpty(pid)){
|
List<Map> resultList = new LinkedList<Map>();
|
Map cacheMap = new HashMap();
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
|
for (Map map : categoryList) {
|
|
//一级树
|
if (map.get("JB").toString().equalsIgnoreCase("2") && pid.equals(map.get("PID"))) {
|
cacheMap.put(map.get("ID"), map);
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (map.get("JB").toString().equalsIgnoreCase("3") && cacheMap.containsKey(map.get("PID"))) {
|
Map yjgnMap = yjgnCache.get(map.get("PID").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
}
|
categoryList = resultList;
|
}
|
|
Map resultMap = new HashMap();
|
resultMap.put("datas", categoryList);
|
resultMap.put("flag", 0);
|
resultMap.put(ClientUtil.SUCCESS, true);
|
resultMap.put(ClientUtil.MSG, "成功");
|
|
return resultMap;
|
}
|
|
@Override
|
public List<Map> companyCiCatenum(String pid,String userId) {
|
StringBuffer sql=new StringBuffer("SELECT A.ID,A.NAME,A.CODE,A.LV JB,A.PID,COUNT(B.ID) AS NUM FROM CMDB_CI_CATEGORY A LEFT JOIN KM_LIBRARY B ON B.THIRDLEVEL_ID = A.ID AND B.STATE = 1 AND B.ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) WHERE A.STATE = 1 and a.cate_type=1 ");
|
sql.append(" GROUP BY A.ID ORDER BY A.LV,A.SERIAL ");
|
List<Map> categoryList = baseDao.queryForList(sql.toString(),new SqlParameter("userId",userId));
|
|
List<Map> resultList = new LinkedList<Map>();
|
if(!StringUtil.isEmpty(pid)){
|
Map cacheMap = new HashMap();
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
for (Map map : categoryList) {
|
if (map.get("JB").toString().equalsIgnoreCase("2")&&map.get("PID").equals(pid)) {
|
for(Map map1 : categoryList){
|
int num = ConvertUtil.obj2Int(map.get("NUM"));
|
if(map.get("ID").equals(map1.get("PID"))){
|
num += ConvertUtil.obj2Int(map1.get("NUM"));
|
map.put("NUM", num);
|
}
|
}
|
}
|
}
|
for (Map map : categoryList) {
|
|
//一级树
|
if (map.get("JB").toString().equalsIgnoreCase("2") && pid.equals(map.get("PID"))) {
|
cacheMap.put(map.get("ID"), map);
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (map.get("JB").toString().equalsIgnoreCase("3") && cacheMap.containsKey(map.get("PID"))) {
|
Map yjgnMap = yjgnCache.get(map.get("PID").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
}
|
}
|
|
|
return resultList;
|
}
|
|
@Override
|
public Map companyKnowCate(String pid) {
|
StringBuffer sql= new StringBuffer(" SELECT A.ID,A.TITLE,A.TAG P_ID,A.LEVEL FROM KM_LIBRARY_CATEGORY A WHERE A.STATE=1 ");
|
if(StringUtil.isEmpty(pid)){
|
sql.append(" AND A.LEVEL = 1 ");
|
}
|
sql.append(" ORDER BY A.LEVEL,A.TITLE ");
|
List<Map> categoryList = baseDao.queryForList(sql.toString());
|
if(!StringUtil.isEmpty(pid)){
|
List<Map> resultList = new LinkedList<Map>();
|
Map cacheMap = new HashMap();
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
|
for (Map map : categoryList) {
|
|
//一级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("2") && pid.equals(map.get("P_ID"))) {
|
cacheMap.put(map.get("ID"), map);
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("3") && cacheMap.containsKey(map.get("P_ID"))) {
|
Map yjgnMap = yjgnCache.get(map.get("P_ID").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
}
|
categoryList = resultList;
|
}
|
Map resultMap = new HashMap();
|
resultMap.put("datas", categoryList);
|
resultMap.put("flag", 0);
|
resultMap.put(ClientUtil.SUCCESS, true);
|
resultMap.put(ClientUtil.MSG, "成功");
|
|
return resultMap;
|
}
|
|
@Override
|
public List<Map> companyKnowCatenum(String pid,String userId) {
|
StringBuffer sql= new StringBuffer(" SELECT A.ID,A.TITLE,A.TAG P_ID,A.LEVEL ,COUNT(B.ID) AS NUM FROM KM_LIBRARY_CATEGORY A LEFT JOIN KM_LIBRARY B ON B.CATEGORY_ID = A.ID AND B.STATE = 1 AND B.ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) WHERE A.STATE=1 ");
|
sql.append(" GROUP BY A.ID ORDER BY A.LEVEL,A.TITLE ");
|
List<Map> categoryList = baseDao.queryForList(sql.toString(),new SqlParameter("userId",userId));
|
List<Map> resultList = new LinkedList<Map>();
|
if(!StringUtil.isEmpty(pid)){
|
Map cacheMap = new HashMap();
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
for (Map map : categoryList) {
|
if (map.get("LEVEL").toString().equalsIgnoreCase("2")&&map.get("P_ID").equals(pid)) {
|
for(Map map1 : categoryList){
|
int num = ConvertUtil.obj2Int(map.get("NUM"));
|
if(map.get("ID").equals(map1.get("P_ID"))){
|
num += ConvertUtil.obj2Int(map1.get("NUM"));
|
map.put("NUM", num);
|
}
|
}
|
}
|
}
|
for (Map map : categoryList) {
|
|
//一级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("2") && pid.equals(map.get("P_ID"))) {
|
cacheMap.put(map.get("ID"), map);
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("3") && cacheMap.containsKey(map.get("P_ID"))) {
|
Map yjgnMap = yjgnCache.get(map.get("P_ID").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
}
|
}
|
|
return resultList;
|
}
|
|
@Override
|
public Map companyServiceCate(String pid) {
|
StringBuffer sql = new StringBuffer();
|
sql.append("SELECT ID,CATEGORY_NAME,CATEGORY_CODE,LEVEL,P_ID FROM SC_SERVCE_CATEGORY WHERE STATE = 1 AND TYPE = 2 ");
|
if(StringUtil.isEmpty(pid)){
|
sql.append(" AND LEVEL = 1 ");
|
}
|
sql.append(" ORDER BY LEVEL,SERIAL ");
|
|
List<Map> categoryList = baseDao.queryForList(sql.toString());
|
|
if(!StringUtil.isEmpty(pid)){
|
List<Map> resultList = new LinkedList<Map>();
|
Map cacheMap = new HashMap();
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
|
for (Map map : categoryList) {
|
|
//一级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("2") && pid.equals(map.get("P_ID"))) {
|
cacheMap.put(map.get("ID"), map);
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("3") && cacheMap.containsKey(map.get("P_ID"))) {
|
Map yjgnMap = yjgnCache.get(map.get("P_ID").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
}
|
categoryList = resultList;
|
}
|
Map resultMap = new HashMap();
|
resultMap.put("datas", categoryList);
|
resultMap.put("flag", 0);
|
resultMap.put(ClientUtil.SUCCESS, true);
|
resultMap.put(ClientUtil.MSG, "成功");
|
|
return resultMap;
|
}
|
|
@Override
|
public List<Map> companyServiceCatenum(String pid,String userId) {
|
StringBuffer sql = new StringBuffer();
|
sql.append("SELECT A.ID,A.CATEGORY_NAME,A.CATEGORY_CODE,A.LEVEL,A.P_ID,COUNT(B.ID) AS NUM FROM SC_SERVCE_CATEGORY A LEFT JOIN KM_LIBRARY B ON B.THIRD_CATEGORY_ID = A.ID AND B.STATE = 1 AND A.TYPE = 2 AND B.ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) WHERE A.STATE = 1 ");
|
sql.append(" GROUP BY A.ID ORDER BY A.LEVEL,A.SERIAL ");
|
|
List<Map> categoryList = baseDao.queryForList(sql.toString(),new SqlParameter("userId",userId));
|
|
List<Map> resultList = new LinkedList<Map>();
|
if(!StringUtil.isEmpty(pid)){
|
Map cacheMap = new HashMap();
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
for (Map map : categoryList) {
|
if (map.get("LEVEL").toString().equalsIgnoreCase("2")&&map.get("P_ID").equals(pid)) {
|
for(Map map1 : categoryList){
|
int num = ConvertUtil.obj2Int(map.get("NUM"));
|
if(map.get("ID").equals(map1.get("P_ID"))){
|
num += ConvertUtil.obj2Int(map1.get("NUM"));
|
map.put("NUM", num);
|
}
|
}
|
}
|
}
|
for (Map map : categoryList) {
|
|
//一级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("2") && pid.equals(map.get("P_ID"))) {
|
cacheMap.put(map.get("ID"), map);
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (map.get("LEVEL").toString().equalsIgnoreCase("3") && cacheMap.containsKey(map.get("P_ID"))) {
|
Map yjgnMap = yjgnCache.get(map.get("P_ID").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
}
|
}
|
|
return resultList;
|
}
|
|
@Override
|
public Integer queryCompanyNewKwCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(ID) FROM KM_LIBRARY WHERE STATE = 1 AND ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) ");
|
return baseDao.queryForInteger(sql.toString(),params);
|
}
|
|
@Override
|
public PageInfo queryCompanyNewKwData(PageInfo pageInfo,
|
Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT ID,TITLE,TAG,SUMMARY,UPDATE_DATE,HITS,CREATE_USER_ID,CREATE_USER_NAME,CREATE_TIME,FILE_ID FROM KM_LIBRARY WHERE STATE = 1 AND ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) ");
|
sql.append(" ORDER BY UPDATE_DATE DESC ");
|
PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
List<Map> datas = info.getDatas();
|
if(datas.size()>0){
|
List<Map> filesList = baseDao.queryForList("SELECT * FROM GG_FILES");
|
Map cachefile = new HashMap();
|
|
for(Map file:filesList){
|
if(!cachefile.containsKey(file.get("BUSINESS_ID"))){
|
cachefile.put(file.get("BUSINESS_ID"), file);
|
}
|
}
|
for(Map map:datas){
|
if(cachefile.containsKey(map.get("FILE_ID"))){
|
map.put("isfiles", "1");
|
}else{
|
map.put("isfiles", "0");
|
}
|
}
|
}
|
info.setDatas(datas);
|
return info;
|
}
|
|
@Override
|
public Integer knowListBycateIdCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(ID) FROM KM_LIBRARY WHERE STATE = 1 AND ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) ");
|
queryknowListIf(params,sql);
|
return baseDao.queryForInteger(sql.toString(),params);
|
}
|
|
@Override
|
public PageInfo knowListBycateIdData(PageInfo pageInfo,
|
Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT ID,TITLE,TAG,SUMMARY,UPDATE_DATE,HITS,CREATE_USER_ID,CREATE_USER_NAME,CREATE_TIME,FILE_ID FROM KM_LIBRARY WHERE STATE = 1 AND ID IN (SELECT KNOWLEDGE_ID FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE CUSTOMER_ID = :userId) ");
|
queryknowListIf(params,sql);
|
sql.append(" ORDER BY UPDATE_DATE DESC ");
|
PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
List<Map> datas = info.getDatas();
|
if(datas.size()>0){
|
List<Map> filesList = baseDao.queryForList("SELECT * FROM GG_FILES");
|
Map cachefile = new HashMap();
|
|
for(Map file:filesList){
|
if(!cachefile.containsKey(file.get("BUSINESS_ID"))){
|
cachefile.put(file.get("BUSINESS_ID"), file);
|
}
|
}
|
for(Map map:datas){
|
if(cachefile.containsKey(map.get("FILE_ID"))){
|
map.put("isfiles", "1");
|
}else{
|
map.put("isfiles", "0");
|
}
|
}
|
}
|
info.setDatas(datas);
|
return info;
|
}
|
|
private void queryknowListIf(Map<String, String> params, StringBuilder sql) {
|
if("1".equals(params.get("type"))){
|
sql.append(" AND CATEGORY_ID = :categoryId ");
|
}else if("2".equals(params.get("type"))){
|
sql.append(" AND THIRDLEVEL_ID = :categoryId ");
|
}else{
|
sql.append(" AND THIRD_CATEGORY_ID = :categoryId ");
|
}
|
}
|
|
|
}
|
