package cn.ksource.web.facade.knowledge.knowledgesh;
|
|
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.KM_LIBRARY;
|
import cn.ksource.beans.KM_LIBRARY_HISTORY;
|
import cn.ksource.beans.KM_LIBRARY_KNOWLEDGE;
|
import cn.ksource.beans.KM_LIBRARY_KNOWLEDGE_ACCESS;
|
import cn.ksource.beans.KM_LIBRARY_KNOWLEDGE_ACCESS_HISTORY;
|
import cn.ksource.beans.KM_LIBRARY_KNOWLEDGE_HISTORY;
|
import cn.ksource.beans.KM_LIBRARY_KNOWLEDGE_TEMP;
|
import cn.ksource.beans.KM_LIBRARY_TEMP;
|
import cn.ksource.beans.KM_LIBRARY_UPDATER;
|
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.web.Constants;
|
import cn.ksource.web.service.knowledge.KmRecordService;
|
|
@Service("knowledgeShFacade")
|
@SuppressWarnings("unchecked")
|
public class KnowledgeShFacadeImpl implements KnowledgeShFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Autowired
|
private KmRecordService kmRecordService;
|
|
@Override
|
public Integer queryKnowledgeShCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT COUNT(DISTINCT K.ID) FROM ( ");
|
sql.append("( SELECT ID, TITLE, TAG, SUMMARY, CONTENT, CATEGORY_ID, CATEGORY_NAME, CREATE_USER_ID, CREATE_USER_NAME, CREATE_TIME, STATE, VERSION, HITS, IS_EDITOR, THIRDLEVEL_NAME, THIRDLEVEL_ID, FIRST_CATEGORY_ID, FIRST_CATEGORY_NAME, SECOND_CATEGORY_ID, SECOND_CATEGORY_NAME, THIRD_CATEGORY_ID, THIRD_CATEGORY_NAME, UPDATE_DATE, UPDATER_ID, UPDATE_NAME, SECOND_KNOWCATEGORY_ID, SECOND_KNOWCATEGORY_NAME, FIRST_KNOWCATEGORY_ID, FIRST_KNOWCATEGORY_NAME, SECONDLEVEL_NAME, SECONDLEVEL_ID, FIRSTLEVEL_NAME, FIRSTLEVEL_ID, ACCESS_TYPE, AUDIT_STATE ,AUDIT_USERID FROM km_library_temp ) ");
|
sql.append(" UNION ALL( SELECT ID, TITLE, TAG, SUMMARY, CONTENT, CATEGORY_ID, CATEGORY_NAME, CREATE_USER_ID, CREATE_USER_NAME, CREATE_TIME, STATE, VERSION, HITS, IS_EDITOR, THIRDLEVEL_NAME, THIRDLEVEL_ID, FIRST_CATEGORY_ID, FIRST_CATEGORY_NAME, SECOND_CATEGORY_ID, SECOND_CATEGORY_NAME, THIRD_CATEGORY_ID, THIRD_CATEGORY_NAME, UPDATE_DATE, UPDATER_ID, UPDATE_NAME, SECOND_KNOWCATEGORY_ID, SECOND_KNOWCATEGORY_NAME, FIRST_KNOWCATEGORY_ID, FIRST_KNOWCATEGORY_NAME, SECONDLEVEL_NAME, SECONDLEVEL_ID, FIRSTLEVEL_NAME, FIRSTLEVEL_ID, ACCESS_TYPE, 2 AS AUDIT_STATE,AUDIT_USERID FROM km_library )");
|
sql.append(") K WHERE K.STATE=1 AND K.AUDIT_USERID=:loginUserId");
|
queryKnowledgeShIf(params,sql);
|
return baseDao.queryForInteger(sql.toString(), params);
|
}
|
|
@Override
|
public PageInfo queryKnowledgeShData(PageInfo pageInfo,
|
Map<String, String> params) {
|
StringBuilder sql = new StringBuilder("SELECT k.* FROM ( ");
|
sql.append("( SELECT ID, TITLE, TAG, SUMMARY, CONTENT, CATEGORY_ID, CATEGORY_NAME, CREATE_USER_ID, CREATE_USER_NAME, CREATE_TIME, STATE, VERSION, HITS, IS_EDITOR, THIRDLEVEL_NAME, THIRDLEVEL_ID, FIRST_CATEGORY_ID, FIRST_CATEGORY_NAME, SECOND_CATEGORY_ID, SECOND_CATEGORY_NAME, THIRD_CATEGORY_ID, THIRD_CATEGORY_NAME, UPDATE_DATE, UPDATER_ID, UPDATE_NAME, SECOND_KNOWCATEGORY_ID, SECOND_KNOWCATEGORY_NAME, FIRST_KNOWCATEGORY_ID, FIRST_KNOWCATEGORY_NAME, SECONDLEVEL_NAME, SECONDLEVEL_ID, FIRSTLEVEL_NAME, FIRSTLEVEL_ID, ACCESS_TYPE, AUDIT_STATE ,AUDIT_USERID FROM km_library_temp ) ");
|
sql.append(" UNION ALL( SELECT ID, TITLE, TAG, SUMMARY, CONTENT, CATEGORY_ID, CATEGORY_NAME, CREATE_USER_ID, CREATE_USER_NAME, CREATE_TIME, STATE, VERSION, HITS, IS_EDITOR, THIRDLEVEL_NAME, THIRDLEVEL_ID, FIRST_CATEGORY_ID, FIRST_CATEGORY_NAME, SECOND_CATEGORY_ID, SECOND_CATEGORY_NAME, THIRD_CATEGORY_ID, THIRD_CATEGORY_NAME, UPDATE_DATE, UPDATER_ID, UPDATE_NAME, SECOND_KNOWCATEGORY_ID, SECOND_KNOWCATEGORY_NAME, FIRST_KNOWCATEGORY_ID, FIRST_KNOWCATEGORY_NAME, SECONDLEVEL_NAME, SECONDLEVEL_ID, FIRSTLEVEL_NAME, FIRSTLEVEL_ID, ACCESS_TYPE, 2 AS AUDIT_STATE,AUDIT_USERID FROM km_library )");
|
sql.append(" ) K WHERE K.STATE=1 AND K.AUDIT_USERID=:loginUserId ");
|
queryKnowledgeShIf(params, sql);
|
sql.append(" ORDER BY K.AUDIT_STATE,K.CREATE_TIME DESC");
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
private void queryKnowledgeShIf(Map<String, String> params,
|
StringBuilder sql) {
|
String title = params.get("title");
|
String keyword = params.get("keyword");
|
String state = params.get("state");
|
String sl = params.get("sl");
|
if(StringUtil.notEmpty(sl)) {
|
String[] sls = sl.split(",");
|
if(sls.length==1) {
|
sql.append(" AND K.THIRD_CATEGORY_ID = :third_category_id");
|
params.put("third_category_id", sls[0]);
|
} else {
|
sql.append(" AND K.THIRD_CATEGORY_ID IN (");
|
for(int i=0; i<sls.length; i++) {
|
sql.append(" :third_category_id"+i);
|
sql.append(",");
|
params.put("third_category_id"+i, sls[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
String know = params.get("know");
|
if(StringUtil.notEmpty(know)) {
|
String[] knows = know.split(",");
|
if(knows.length==1) {
|
sql.append(" AND K.CATEGORY_ID = :category_id");
|
params.put("category_id", knows[0]);
|
} else {
|
sql.append(" AND K.CATEGORY_ID IN (");
|
for(int i=0; i<knows.length; i++) {
|
sql.append(" :category_id"+i);
|
sql.append(",");
|
params.put("category_id"+i, knows[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
String ci = params.get("ci");
|
if(StringUtil.notEmpty(ci)) {
|
String[] cis = ci.split(",");
|
if(cis.length==1) {
|
sql.append(" AND K.THIRDLEVEL_ID = :thirdlevel_id");
|
params.put("thirdlevel_id", cis[0]);
|
} else {
|
sql.append(" AND K.THIRDLEVEL_ID IN (");
|
for(int i=0; i<cis.length; i++) {
|
sql.append(" :thirdlevel_id"+i);
|
sql.append(",");
|
params.put("thirdlevel_id"+i, cis[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
if (!StringUtil.isEmpty(title)) {
|
sql.append(" AND K.TITLE like :title ");
|
params.put("title", "%" + title + "%");
|
}
|
|
if (!StringUtil.isEmpty(keyword)) {
|
sql.append(" AND K.TAG like :keyword ");
|
params.put("keyword", "%" + keyword + "%");
|
}
|
if (state.equals(Constants.KM_LIBRARY_TEMP_AUDIT_STATE_DSH.toString())) {
|
sql.append(" AND K.AUDIT_STATE = :state ");
|
}else{
|
params.put("state", Constants.KM_LIBRARY_TEMP_AUDIT_STATE_DSH.toString());
|
sql.append(" AND K.AUDIT_STATE > :state ");
|
}
|
}
|
|
@SuppressWarnings("rawtypes")
|
@Override
|
public void saveKnowledgeSh(Map<String, String> params) {
|
|
//审核通过将知识添加入正式知识库
|
if(ConvertUtil.obj2Integer(params.get("state")) == Constants.KM_LIBRARY_TEMP_AUDIT_STATE_SHTG){
|
String id = params.get("id");//中间表的id
|
KM_LIBRARY_TEMP temp = new KM_LIBRARY_TEMP().setId(id).getInstanceById();
|
String zsId = temp.getOriginal_id();
|
|
//新增审核操作
|
if(temp.getContent_state() == 1){
|
KM_LIBRARY library = new KM_LIBRARY();
|
library.setTitle(temp.getTitle()).setTag(temp.getTag()).setSummary(temp.getSummary()).setContent(temp.getContent())
|
.setCategory_id(temp.getCategory_id()).setCategory_name(temp.getCategory_name()).setCreate_user_id(temp.getCreate_user_id())
|
.setCreate_user_name(temp.getCreate_user_name()).setCreate_time(temp.getCreate_time()).setState(temp.getState()).setVersion(temp.getVersion())
|
.setHits(temp.getHits()).setIs_editor(temp.getIs_editor()).setThirdlevel_id(temp.getThirdlevel_id()).setThirdlevel_name(temp.getThirdlevel_name())
|
.setFirst_category_id(temp.getFirst_category_id()).setFirst_category_name(temp.getFirst_category_name()).setSecond_category_id(temp.getSecond_category_id())
|
.setSecond_category_name(temp.getSecond_category_name()).setThird_category_id(temp.getThird_category_id()).setThird_category_name(temp.getThird_category_name())
|
.setUpdate_date(temp.getUpdate_date()).setUpdater_id(temp.getUpdater_id()).setUpdate_name(temp.getUpdate_name()).setSecond_knowcategory_id(temp.getSecond_knowcategory_id())
|
.setSecond_knowcategory_name(temp.getSecond_knowcategory_name()).setFirst_knowcategory_id(temp.getFirst_knowcategory_id()).setFirst_knowcategory_name(temp.getFirst_knowcategory_name())
|
.setSecondlevel_id(temp.getSecondlevel_id()).setSecondlevel_name(temp.getSecondlevel_name()).setFirstlevel_id(temp.getFirstlevel_id()).setFirstlevel_name(temp.getFirstlevel_name())
|
.setAccess_type(temp.getAccess_type()).setFile_id(id).setIs_essence(0).setIs_top(0).setAudit_userid(temp.getAudit_userid()).setAudit_username(temp.getAudit_username()).insert();
|
//清除知识库temp表数据
|
temp.deleteById();
|
//正式用户权限
|
List<Map> accessDatas = baseDao.queryForList("SELECT * FROM KM_LIBRARY_KNOWLEDGE_ACCESS_TEMP WHERE KNOWLEDGE_ID = :id", new SqlParameter().addValue("id", id));
|
if(accessDatas.size() > 0){
|
for (Map map : accessDatas) {
|
KM_LIBRARY_KNOWLEDGE_ACCESS access = new KM_LIBRARY_KNOWLEDGE_ACCESS();
|
access.setCustomer_id(String.valueOf(map.get("CUSTOMER_ID"))).setCustomer_name(String.valueOf(map.get("CUSTOMER_NAME"))).setKnowledge_id(library.getId()).insert();
|
}
|
//清除用户权限temp表数据
|
baseDao.execute("DELETE FROM KM_LIBRARY_KNOWLEDGE_ACCESS_TEMP WHERE KNOWLEDGE_ID = :id", new SqlParameter().addValue("id", id));
|
}
|
//关联知识信息
|
List<Map> glKnowDatas = baseDao.queryForList("SELECT * FROM KM_LIBRARY_KNOWLEDGE WHERE LIBRARY_ID = :id", new SqlParameter().addValue("id", id));
|
if(glKnowDatas.size() > 0 ){
|
for (Map map2 : glKnowDatas) {
|
KM_LIBRARY_KNOWLEDGE km_library_knowledge = new KM_LIBRARY_KNOWLEDGE();
|
km_library_knowledge.setKnowledge_id(String.valueOf(map2.get("KNOWLEDGE_ID"))).setLibrary_id(library.getId()).insert();
|
}
|
//清除关联知识信息
|
baseDao.execute("DELETE FROM KM_LIBRARY_KNOWLEDGE WHERE LIBRARY_ID = :id ", new SqlParameter().addValue("id", id));
|
}
|
Map<String,String> recordparams = new HashMap<String, String>();
|
recordparams.put("library_id", library.getId());
|
recordparams.put("userId", library.getCreate_user_id());
|
recordparams.put("type", ConvertUtil.obj2StrBlank(Constants.KM_SCORE_RULE_TYPE_YC));
|
kmRecordService.addrecord(recordparams);
|
}else{//修改审核操作
|
//向历史表添加数据
|
KM_LIBRARY zsLibrary = new KM_LIBRARY().setId(zsId).getInstanceById();
|
KM_LIBRARY_HISTORY library_history = new KM_LIBRARY_HISTORY();
|
library_history.setTitle(zsLibrary.getTitle()).setTag(zsLibrary.getTag()).setSummary(zsLibrary.getSummary()).setContent(zsLibrary.getContent())
|
.setCategory_id(zsLibrary.getCategory_id()).setCategory_name(zsLibrary.getCategory_name()).setCreate_user_id(temp.getUpdater_id())
|
.setCreate_user_name(temp.getUpdate_name()).setCreate_time(temp.getUpdate_date()).setState(zsLibrary.getState()).setVersion(zsLibrary.getVersion())
|
.setHits(zsLibrary.getHits()).setIs_editor(zsLibrary.getIs_editor()).setThirdlevel_id(zsLibrary.getThirdlevel_id()).setThirdlevel_name(zsLibrary.getThirdlevel_name())
|
.setFirst_category_id(zsLibrary.getFirst_category_id()).setFirst_category_name(zsLibrary.getFirst_category_name()).setSecond_category_id(zsLibrary.getSecond_category_id())
|
.setSecond_category_name(zsLibrary.getSecond_category_name()).setThird_category_id(zsLibrary.getThird_category_id()).setThird_category_name(zsLibrary.getThird_category_name())
|
.setSecond_knowcategory_id(zsLibrary.getSecond_knowcategory_id())
|
.setSecond_knowcategory_name(zsLibrary.getSecond_knowcategory_name()).setFirst_knowcategory_id(zsLibrary.getFirst_knowcategory_id()).setFirst_knowcategory_name(zsLibrary.getFirst_knowcategory_name())
|
.setSecondlevel_id(zsLibrary.getSecondlevel_id()).setSecondlevel_name(zsLibrary.getSecondlevel_name()).setFirstlevel_id(zsLibrary.getFirstlevel_id()).setFirstlevel_name(zsLibrary.getFirstlevel_name())
|
.setAccess_type(zsLibrary.getAccess_type()).setOriginal_id(zsLibrary.getId()).setFile_id(zsLibrary.getFile_id()).insert();//历史表的fileId就是正式表的fileId，正式表的需要更新成临时表的最新id
|
//向历史用户权限表添加信息
|
List<Map> accessDatas = baseDao.queryForList("SELECT * FROM KM_LIBRARY_KNOWLEDGE_ACCESS WHERE KNOWLEDGE_ID = :zsId", new SqlParameter().addValue("zsId", zsId));
|
if(accessDatas.size() > 0){
|
for (Map map : accessDatas) {
|
KM_LIBRARY_KNOWLEDGE_ACCESS_HISTORY access = new KM_LIBRARY_KNOWLEDGE_ACCESS_HISTORY();
|
access.setCustomer_id(String.valueOf(map.get("CUSTOMER_ID"))).setCustomer_name(String.valueOf(map.get("CUSTOMER_NAME"))).setKnowledge_id(library_history.getId()).insert();
|
}
|
/*因为修改未向中间表添加知识表信息，不需要删除数据*/
|
}
|
//向历史关联知识表添加信息
|
List<Map> glKnowDatas = baseDao.queryForList("SELECT * FROM KM_LIBRARY_KNOWLEDGE WHERE LIBRARY_ID = :zsId", new SqlParameter().addValue("zsId", zsId));
|
if(glKnowDatas.size() > 0 ){
|
for (Map map2 : glKnowDatas) {
|
KM_LIBRARY_KNOWLEDGE_HISTORY km_library_knowledge_history = new KM_LIBRARY_KNOWLEDGE_HISTORY();
|
km_library_knowledge_history.setKnowledge_id(String.valueOf(map2.get("KNOWLEDGE_ID"))).setLibrary_id(library_history.getId()).insert();
|
}
|
/*因为修改未向中间表添加关联知识信息，不需要删除数据*/
|
}
|
//更新正式表的信息（更新最后编辑人信息）
|
zsLibrary = new KM_LIBRARY().setTitle(temp.getTitle()).setTag(temp.getTag()).setSummary(temp.getSummary()).setContent(temp.getContent())
|
.setVersion(temp.getVersion()).setUpdate_date(temp.getUpdate_date()).setUpdater_id(temp.getUpdater_id()).setUpdate_name(temp.getUpdate_name())
|
.setSecond_knowcategory_name(temp.getSecond_knowcategory_name()).setFirst_knowcategory_id(temp.getFirst_knowcategory_id()).setFirst_knowcategory_name(temp.getFirst_knowcategory_name())
|
.setId(zsId).setAudit_userid(temp.getAudit_userid()).setAudit_username(temp.getAudit_username()).setFile_id(temp.getId()).update();
|
//向编辑记录表中添加信息
|
new KM_LIBRARY_UPDATER().setLibrary_id(zsLibrary.getId()).setType(2).setUser_name(temp.getUpdate_name()).setUser_id(temp.getUpdater_id()).setEditor_date(temp.getUpdate_date()).insert();
|
//删除中间表信息
|
temp.deleteById();
|
String sql = "SELECT COUNT(ID) FROM KM_RECORD WHERE USER_ID = :userId AND TYPE = :type AND LIBRARY_ID = :library_id ";
|
Map<String,String> recordparams = new HashMap<String, String>();
|
recordparams.put("library_id", zsLibrary.getId());
|
recordparams.put("userId", zsLibrary.getUpdater_id());
|
recordparams.put("type", ConvertUtil.obj2StrBlank(Constants.KM_SCORE_RULE_TYPE_BJ));
|
int count = baseDao.queryForInteger(sql,recordparams);
|
if(count == 0){
|
kmRecordService.addrecord(recordparams);
|
}
|
}
|
}else{
|
//审核不通过改变状态
|
String sql = new String("UPDATE KM_LIBRARY_TEMP SET AUDIT_STATE = :state,AUDIT_NOTE = :note WHERE ID = :id");
|
baseDao.execute(sql, params);
|
}
|
}
|
|
}
|
