package cn.ksource.web.service.timetask;
|
|
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.core.dao.BaseDao;
|
import cn.ksource.core.fulltext.FullTextBean;
|
import cn.ksource.core.fulltext.FullTextConstants;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.DateUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.web.Constants;
|
|
@Service("timeTaskService")
|
public class TimeTaskServiceImpl implements TimeTaskService {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Override
|
public List<Map> getKnowledgeList(String businessId,String beginTime,String endTime) {
|
long today = DateUtil.getCurrentDate8();
|
long day = DateUtil.getDateAdd(today, -1, 8);
|
|
if(!StringUtil.notEmptyNum(beginTime)) {
|
beginTime = ConvertUtil.obj2StrBlank(day);
|
}
|
|
beginTime = beginTime + "000000";
|
|
if(!StringUtil.notEmptyNum(endTime)) {
|
endTime = ConvertUtil.obj2StrBlank(day);
|
}
|
endTime = endTime + "240000";
|
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
String sql = "SELECT * FROM KM_LIBRARY WHERE STATE = 1 AND UPDATE_DATE >= :beginTime AND UPDATE_DATE <= :endTime";
|
if(StringUtil.notEmpty(businessId)) {
|
sql += " AND ID = :businessId";
|
paramMap.put("businessId", businessId);
|
} else {
|
|
}
|
List<Map> dataSource = baseDao.queryForList(sql,paramMap);
|
|
List<Map> resultList = getDataSource(dataSource,FullTextConstants.knowledge,null);
|
|
|
return resultList;
|
}
|
|
|
public List<Map> getDataSource(List<Map> dataSource,Integer bigCategory,Integer smallCategory) {
|
List<Map> resultList =new ArrayList<Map>();
|
|
for (Map map : dataSource) {
|
FullTextBean bean = new FullTextBean();
|
bean.setBig_category(bigCategory);
|
String id = ConvertUtil.obj2StrBlank(map.get("ID"));
|
bean.setBusiness_id(id);
|
bean.setContent(ConvertUtil.obj2Str(map.get("CONTENT")));
|
|
bean.setExtend_paramter_0(ConvertUtil.obj2StrBlank(map.get("CUSTOMER_ID")));
|
bean.setExtend_paramter_1(ConvertUtil.obj2StrBlank(map.get("SUB_CUSTOMER_ID")));
|
bean.setExtend_paramter_2(id);
|
|
/*
|
if(map.containsKey("ACCESS_TYPE")) {
|
bean.setExtend_paramter_3(ConvertUtil.obj2StrBlank(map.get("ACCESS_TYPE")));
|
}*/
|
|
|
bean.setKeywords(ConvertUtil.obj2Str(map.get("TAG")));
|
bean.setSmall_category(smallCategory);
|
bean.setTitle(ConvertUtil.obj2Str(map.get("TITLE")));
|
bean.setUpdate_time(ConvertUtil.obj2Long(map.get("UPDATE_DATE")));
|
|
String flowId = ConvertUtil.obj2StrBlank(map.get("FLOW_ID"));
|
if(StringUtil.notEmpty(flowId)) {
|
bean.setFlow_id(flowId);
|
} else {
|
bean.setFlow_id(null);
|
}
|
|
resultList.add(bean.getMapInfo());
|
}
|
return resultList;
|
}
|
|
|
|
|
/**
|
* 获取需要更新的数据信息的数据源
|
*/
|
@Override
|
public List<Map> getIncidentList(String beginTime,String endTime) {
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
|
|
paramMap.put("wfstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
|
String builder = new String("SELECT A.FLOW_ID, A.ID,A.NAME AS TITLE,A.ORDER_CODE,A.DESCRIP AS CONTENT,A.CUSTOMER_ID,A.SUB_CUSTOMER_ID,A.CREATE_TIME AS UPDATE_DATE,'' AS TAG,A.CUSTOMER_NAME,A.TYPE_NAME,A.SOURCE_NAME,A.RESOLVE,A.SUGGEST,A.SUB_CUSTOMER_NAME FROM SC_WORKFLOW_INCIDENT A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE != :wfstate ");
|
|
|
builder += " AND EXISTS (SELECT C.ID FROM WORKFLOW_NODE C WHERE B.ID = C.FLOWID AND C.CREATETIME >= :beginTime AND C.CREATETIME <= :endTime )" ;
|
|
List<Map> incidents = baseDao.queryForList(builder.toString(),paramMap);
|
Map cacheMap = new HashMap();
|
if(null!=incidents && incidents.size()>0) {
|
for(Map incident : incidents) {
|
String flowId = ConvertUtil.obj2StrBlank(incident.get("FLOW_ID"));
|
|
String customerName = ConvertUtil.obj2StrBlank(incident.get("CUSTOMER_NAME"));
|
String subCustomerName = ConvertUtil.obj2StrBlank(incident.get("SUB_CUSTOMER_NAME"));
|
String typeName = ConvertUtil.obj2StrBlank(incident.get("TYPE_NAME"));
|
String sourceName = ConvertUtil.obj2StrBlank(incident.get("SOURCE_NAME"));
|
String resolve = ConvertUtil.obj2StrBlank(incident.get("RESOLVE"));
|
String suggest = ConvertUtil.obj2StrBlank(incident.get("SUGGEST"));
|
String orderCode = ConvertUtil.obj2StrBlank(incident.get("ORDER_CODE"));
|
|
StringBuilder contentBuilder = new StringBuilder();
|
|
if(StringUtil.notEmpty(orderCode)) {
|
contentBuilder.append("；工单编号：").append(orderCode);
|
}
|
|
if(StringUtil.notEmpty(customerName)) {
|
contentBuilder.append("；客户名称：").append(customerName);
|
}
|
|
if(StringUtil.notEmpty(subCustomerName)) {
|
contentBuilder.append("-").append(subCustomerName);
|
}
|
|
if(StringUtil.notEmpty(typeName)) {
|
contentBuilder.append("；事件类型：").append(typeName);
|
}
|
|
if(StringUtil.notEmpty(sourceName)) {
|
contentBuilder.append("；事件来源").append(sourceName);
|
}
|
|
if(StringUtil.notEmpty(resolve)) {
|
contentBuilder.append("；解决方式：").append(resolve);
|
}
|
|
if(StringUtil.notEmpty(suggest)) {
|
contentBuilder.append("；优化建议：").append(suggest);
|
}
|
contentBuilder.append("；");
|
|
String content = ConvertUtil.obj2StrBlank(incident.get("CONTENT"));
|
|
incident.put("CONTENT", content+contentBuilder.toString());
|
|
cacheMap.put(flowId, incident);
|
}
|
|
|
queryRecord(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT,cacheMap);
|
}
|
|
List<Map> resultList = getDataSource(incidents,FullTextConstants.order,Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT);
|
|
return resultList;
|
}
|
|
|
private void queryRecord(int businessType,Map cacheMap) {
|
Map paramMap = new HashMap();
|
paramMap.put("wfstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
|
paramMap.put("businessType", businessType);
|
//查询事件工单的处理记录
|
String recordSql = "SELECT C.* FROM GG_RECORD C WHERE EXISTS (SELECT B.ID FROM WORKFLOW_BASE B WHERE B.WFSTATE != :wfstate AND B.ID = C.BUSINESS_ID AND B.BUSINESSTYPE = :businessType) ORDER BY C.DEAL_TIME DESC";
|
|
List<Map> records = baseDao.queryForList(recordSql, paramMap);
|
if(null!=records && records.size()>0) {
|
for(Map record : records) {
|
String linkId = ConvertUtil.obj2StrBlank(record.get("BUSINESS_ID"));
|
String dealContent = ConvertUtil.obj2StrBlank(record.get("DEAL_CONTENT"));
|
|
if(cacheMap.containsKey(linkId)) {
|
Map map = (Map)cacheMap.get(linkId);
|
String content = ConvertUtil.obj2StrBlank(map.get("CONTENT"));
|
map.put("CONTENT", content+";"+dealContent);
|
}
|
}
|
}
|
}
|
|
|
@Override
|
public List<Map> getZcywList(String beginTime,String endTime) {
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
paramMap.put("wfstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
|
String builder = new String("SELECT A.FLOW_ID, A.ID,A.NAME AS TITLE,A.ORDER_CODE,A.DESCRIP AS CONTENT,A.CUSTOMER_ID,A.SUB_CUSTOMER_ID,A.CREATE_TIME AS UPDATE_DATE,'' AS TAG,A.CUSTOMER_NAME,A.TYPE_NAME,A.SOURCE_NAME,A.RESOLVE,A.SUGGEST,A.SUB_CUSTOMER_NAME FROM SC_WORKFLOW_INCIDENT_LOCAL A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE != :wfstate ");
|
|
|
builder += " AND EXISTS (SELECT C.ID FROM WORKFLOW_NODE C WHERE B.ID = C.FLOWID AND C.CREATETIME >= :beginTime AND C.CREATETIME <= :endTime )" ;
|
|
List<Map> zcyws = baseDao.queryForList(builder.toString(),paramMap);
|
Map cacheMap = new HashMap();
|
if(null!=zcyws && zcyws.size()>0) {
|
for(Map zcyw : zcyws) {
|
String flowId = ConvertUtil.obj2StrBlank(zcyw.get("FLOW_ID"));
|
|
String customerName = ConvertUtil.obj2StrBlank(zcyw.get("CUSTOMER_NAME"));
|
String subCustomerName = ConvertUtil.obj2StrBlank(zcyw.get("SUB_CUSTOMER_NAME"));
|
String typeName = ConvertUtil.obj2StrBlank(zcyw.get("TYPE_NAME"));
|
String sourceName = ConvertUtil.obj2StrBlank(zcyw.get("SOURCE_NAME"));
|
String resolve = ConvertUtil.obj2StrBlank(zcyw.get("RESOLVE"));
|
String suggest = ConvertUtil.obj2StrBlank(zcyw.get("SUGGEST"));
|
|
String orderCode = ConvertUtil.obj2StrBlank(zcyw.get("ORDER_CODE"));
|
|
StringBuilder contentBuilder = new StringBuilder();
|
|
if(StringUtil.notEmpty(orderCode)) {
|
contentBuilder.append("；工单编号：").append(orderCode);
|
}
|
|
if(StringUtil.notEmpty(customerName)) {
|
contentBuilder.append("；客户名称：").append(customerName);
|
}
|
|
if(StringUtil.notEmpty(subCustomerName)) {
|
contentBuilder.append("-").append(subCustomerName);
|
}
|
|
if(StringUtil.notEmpty(typeName)) {
|
contentBuilder.append("；事件类型：").append(typeName);
|
}
|
|
if(StringUtil.notEmpty(sourceName)) {
|
contentBuilder.append("；事件来源").append(sourceName);
|
}
|
|
if(StringUtil.notEmpty(resolve)) {
|
contentBuilder.append("；解决方式：").append(resolve);
|
}
|
|
if(StringUtil.notEmpty(suggest)) {
|
contentBuilder.append("；优化建议：").append(suggest);
|
}
|
contentBuilder.append("；");
|
|
String content = ConvertUtil.obj2StrBlank(zcyw.get("CONTENT"));
|
|
zcyw.put("CONTENT", content+contentBuilder.toString());
|
|
cacheMap.put(flowId, zcyw);
|
}
|
|
queryRecord(Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT_LOCAL, cacheMap);
|
}
|
|
|
List<Map> resultList = getDataSource(zcyws,FullTextConstants.order,Constants.WORKFLOW_BASE_BUSINESS_TYPE_INCIDENT_LOCAL);
|
|
return resultList;
|
}
|
|
|
@Override
|
public List<Map> getQuestionList(String beginTime,String endTime) {
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
paramMap.put("wfstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
|
String builder = new String("SELECT A.FLOW_ID, A.ID,A.NAME AS TITLE,A.ORDER_CODE,A.DESCRIP AS CONTENT,A.CUSTOMER_ID,A.SUB_CUSTOMER_ID,A.CREATE_TIME AS UPDATE_DATE,'' AS TAG,A.CUSTOMER_NAME,A.RESOLVE,A.SUGGEST,A.SUB_CUSTOMER_NAME FROM SC_WORKFLOW_QUESTION A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE != :wfstate ");
|
|
builder += " AND EXISTS (SELECT C.ID FROM WORKFLOW_NODE C WHERE B.ID = C.FLOWID AND C.CREATETIME >= :beginTime AND C.CREATETIME <= :endTime )" ;
|
|
List<Map> questions = baseDao.queryForList(builder.toString(),paramMap);
|
Map cacheMap = new HashMap();
|
if(null!=questions && questions.size()>0) {
|
for(Map question : questions) {
|
String flowId = ConvertUtil.obj2StrBlank(question.get("FLOW_ID"));
|
|
String customerName = ConvertUtil.obj2StrBlank(question.get("CUSTOMER_NAME"));
|
String subCustomerName = ConvertUtil.obj2StrBlank(question.get("SUB_CUSTOMER_NAME"));
|
String resolve = ConvertUtil.obj2StrBlank(question.get("RESOLVE"));
|
String suggest = ConvertUtil.obj2StrBlank(question.get("SUGGEST"));
|
|
String orderCode = ConvertUtil.obj2StrBlank(question.get("ORDER_CODE"));
|
|
StringBuilder contentBuilder = new StringBuilder();
|
|
if(StringUtil.notEmpty(orderCode)) {
|
contentBuilder.append("；工单编号：").append(orderCode);
|
}
|
|
if(StringUtil.notEmpty(customerName)) {
|
contentBuilder.append("；客户名称：").append(customerName);
|
}
|
|
if(StringUtil.notEmpty(subCustomerName)) {
|
contentBuilder.append("-").append(subCustomerName);
|
}
|
|
if(StringUtil.notEmpty(resolve)) {
|
contentBuilder.append("；解决方案：").append(resolve);
|
}
|
|
if(StringUtil.notEmpty(suggest)) {
|
contentBuilder.append("；优化建议：").append(suggest);
|
}
|
contentBuilder.append("；");
|
|
String content = ConvertUtil.obj2StrBlank(question.get("CONTENT"));
|
|
question.put("CONTENT", content+contentBuilder.toString());
|
|
cacheMap.put(flowId, question);
|
}
|
|
queryRecord(Constants.WORKFLOW_BASE_BUSINESS_TYPE_QUESTION, cacheMap);
|
}
|
|
|
List<Map> resultList = getDataSource(questions,FullTextConstants.order,Constants.WORKFLOW_BASE_BUSINESS_TYPE_QUESTION);
|
|
return resultList;
|
}
|
|
|
@Override
|
public List<Map> getAddList(String beginTime,String endTime) {
|
/*long today = DateUtil.getCurrentDate8();
|
long day = DateUtil.getDateAdd(today, -1, 8);
|
String beginTime = day + "000000";
|
String endTime = day + "240000";*/
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
paramMap.put("wfstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
|
String builder = new String("SELECT A.FLOW_ID, A.ID,B.WFNAME AS TITLE,B.WFNOTE AS CONTENT,A.CUSTOMER_ID,A.PROJECT_ID,A.SUB_CUSTOMER_ID,A.APPLY_TIME AS UPDATE_DATE,'' AS TAG,A.PROJECT_NAME,A.CUSTOMER_NAME,A.APPLY_REASON,A.COLLECTION_TYPE_NAME,A.CLOSE_NOTE,A.NOTE,A.SUB_CUSTOMER_NAME FROM SC_WORKFLOW_CI_ADD A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE != :wfstate ");
|
|
builder += " AND EXISTS (SELECT C.ID FROM WORKFLOW_NODE C WHERE B.ID = C.FLOWID AND C.CREATETIME >= :beginTime AND C.CREATETIME <= :endTime )" ;
|
|
List<Map> adds = baseDao.queryForList(builder.toString(),paramMap);
|
Map cacheMap = new HashMap();
|
if(null!=adds && adds.size()>0) {
|
for(Map add : adds) {
|
String flowId = ConvertUtil.obj2StrBlank(add.get("FLOW_ID"));
|
|
String projectName = ConvertUtil.obj2StrBlank(add.get("PROJECT_NAME"));
|
String customerName = ConvertUtil.obj2StrBlank(add.get("CUSTOMER_NAME"));
|
String subCustomerName = ConvertUtil.obj2StrBlank(add.get("SUB_CUSTOMER_NAME"));
|
String applyReason = ConvertUtil.obj2StrBlank(add.get("APPLY_REASON"));
|
String collectionTypeName = ConvertUtil.obj2StrBlank(add.get("COLLECTION_TYPE_NAME"));
|
String closeNote = ConvertUtil.obj2StrBlank(add.get("CLOSE_NOTE"));
|
String note = ConvertUtil.obj2StrBlank(add.get("NOTE"));
|
|
StringBuilder contentBuilder = new StringBuilder();
|
if(StringUtil.notEmpty(projectName)) {
|
contentBuilder.append("；项目名称：").append(projectName);
|
}
|
|
if(StringUtil.notEmpty(customerName)) {
|
contentBuilder.append("；客户名称：").append(customerName);
|
}
|
|
if(StringUtil.notEmpty(subCustomerName)) {
|
contentBuilder.append("-").append(subCustomerName);
|
}
|
|
if(StringUtil.notEmpty(applyReason)) {
|
contentBuilder.append("；申请原因：").append(applyReason);
|
}
|
|
if(StringUtil.notEmpty(collectionTypeName)) {
|
contentBuilder.append("；采集类型：").append(collectionTypeName);
|
}
|
if(StringUtil.notEmpty(closeNote)) {
|
contentBuilder.append("；关闭原因：").append(closeNote);
|
}
|
|
if(StringUtil.notEmpty(note)) {
|
contentBuilder.append("；备注：").append(note);
|
}
|
contentBuilder.append("；");
|
|
String content = ConvertUtil.obj2StrBlank(add.get("CONTENT"));
|
|
add.put("CONTENT", content+contentBuilder.toString());
|
|
cacheMap.put(flowId, add);
|
}
|
|
//queryRecord(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_ADD, cacheMap);
|
}
|
|
|
//List<Map> resultList = getDataSource(adds,FullTextConstants.order,Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_ADD);
|
|
//return resultList;
|
return null;
|
}
|
|
|
@Override
|
public List<Map> getRemind(String beginTime,String endTime) {
|
/*long today = DateUtil.getCurrentDate8();
|
long day = DateUtil.getDateAdd(today, -1, 8);
|
String beginTime = day + "000000";
|
String endTime = day + "240000";*/
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
paramMap.put("wfstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
|
String builder = new String("SELECT A.FLOW_ID, A.ID,B.WFNAME AS TITLE,A.ORDER_CODE,B.WFNOTE AS CONTENT,A.CUSTOMER_ID,A.SUB_CUSTOMER_ID,A.CREATE_TIME AS UPDATE_DATE,'' AS TAG,A.CUSTOMER_NAME,A.SERVICE_CONTENT,A.ORDER_NOTE,A.CLOSE_NOTE,A.SUB_CUSTOMER_NAME FROM SC_WORKFLOW_CI_REMIND A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE != :wfstate ");
|
|
|
builder += " AND EXISTS (SELECT C.ID FROM WORKFLOW_NODE C WHERE B.ID = C.FLOWID AND C.CREATETIME >= :beginTime AND C.CREATETIME <= :endTime )" ;
|
|
List<Map> reminds = baseDao.queryForList(builder.toString(),paramMap);
|
Map cacheMap = new HashMap();
|
if(null!=reminds && reminds.size()>0) {
|
for(Map remind : reminds) {
|
String flowId = ConvertUtil.obj2StrBlank(remind.get("FLOW_ID"));
|
|
String customerName = ConvertUtil.obj2StrBlank(remind.get("CUSTOMER_NAME"));
|
String subCustomerName = ConvertUtil.obj2StrBlank(remind.get("SUB_CUSTOMER_NAME"));
|
String serviceContent = ConvertUtil.obj2StrBlank(remind.get("SERVICE_CONTENT"));
|
String orderNote = ConvertUtil.obj2StrBlank(remind.get("ORDER_NOTE"));
|
String closeNote = ConvertUtil.obj2StrBlank(remind.get("CLOSE_NOTE"));
|
|
String orderCode = ConvertUtil.obj2StrBlank(remind.get("ORDER_CODE"));
|
|
StringBuilder contentBuilder = new StringBuilder();
|
|
if(StringUtil.notEmpty(orderCode)) {
|
contentBuilder.append("；工单编号：").append(orderCode);
|
}
|
if(StringUtil.notEmpty(customerName)) {
|
contentBuilder.append("；客户名称：").append(customerName);
|
}
|
|
if(StringUtil.notEmpty(subCustomerName)) {
|
contentBuilder.append("-").append(subCustomerName);
|
}
|
|
if(StringUtil.notEmpty(serviceContent)) {
|
contentBuilder.append("；服务内容说明：").append(serviceContent);
|
}
|
|
if(StringUtil.notEmpty(orderNote)) {
|
contentBuilder.append("；实施过程总结：").append(orderNote);
|
}
|
if(StringUtil.notEmpty(closeNote)) {
|
contentBuilder.append("；关闭原因：").append(closeNote);
|
}
|
|
contentBuilder.append("；");
|
|
String content = ConvertUtil.obj2StrBlank(remind.get("CONTENT"));
|
|
remind.put("CONTENT", content+contentBuilder.toString());
|
|
cacheMap.put(flowId, remind);
|
}
|
|
queryRecord(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND, cacheMap);
|
}
|
|
|
List<Map> resultList = getDataSource(reminds,FullTextConstants.order,Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_REMIND);
|
|
return resultList;
|
}
|
|
|
/**
|
* 查询月度巡检工单信息
|
*/
|
@Override
|
public List<Map> getMonthCheck(String beginTime,String endTime) {
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
paramMap.put("wfstate", Constants.WORKFLOW_BASE_WFSTATE_DELETE);
|
String builder = new String("SELECT A.FLOW_ID, A.ID,B.WFNAME AS TITLE,A.ORDER_CODE,B.WFNOTE AS CONTENT,A.CUSTOMER_ID,A.SUB_CUSTOMER_ID,B.CREATETIME AS UPDATE_DATE,'' AS TAG,A.CUSTOMER_NAME,A.CI_ERROR_NOTE,A.CI_RUN_NOTE,A.CLOSE_NOTE,A.SUB_CUSTOMER_NAME FROM SC_WORKFLOW_CI_HEALTH A,WORKFLOW_BASE B WHERE A.ID = B.BUSINESS_ID AND B.WFSTATE != :wfstate ");
|
builder += " AND EXISTS (SELECT C.ID FROM WORKFLOW_NODE C WHERE B.ID = C.FLOWID AND C.CREATETIME >= :beginTime AND C.CREATETIME <= :endTime )" ;
|
|
|
List<Map> checks = baseDao.queryForList(builder.toString(),paramMap);
|
Map cacheMap = new HashMap();
|
if(null!=checks && checks.size()>0) {
|
for(Map check : checks) {
|
String flowId = ConvertUtil.obj2StrBlank(check.get("FLOW_ID"));
|
|
String customerName = ConvertUtil.obj2StrBlank(check.get("CUSTOMER_NAME"));
|
String subCustomerName = ConvertUtil.obj2StrBlank(check.get("SUB_CUSTOMER_NAME"));
|
String ciErrorNote = ConvertUtil.obj2StrBlank(check.get("CI_ERROR_NOTE"));
|
String ciRunNote = ConvertUtil.obj2StrBlank(check.get("CI_RUN_NOTE"));
|
String closeNote = ConvertUtil.obj2StrBlank(check.get("CLOSE_NOTE"));
|
|
String orderCode = ConvertUtil.obj2StrBlank(check.get("ORDER_CODE"));
|
|
StringBuilder contentBuilder = new StringBuilder();
|
|
if(StringUtil.notEmpty(orderCode)) {
|
contentBuilder.append("；工单编号：").append(orderCode);
|
}
|
|
if(StringUtil.notEmpty(customerName)) {
|
contentBuilder.append("；客户名称：").append(customerName);
|
}
|
|
if(StringUtil.notEmpty(subCustomerName)) {
|
contentBuilder.append("-").append(subCustomerName);
|
}
|
|
if(StringUtil.notEmpty(ciErrorNote)) {
|
contentBuilder.append("；设备异常故障情况说明及优化建议：").append(ciErrorNote);
|
}
|
|
if(StringUtil.notEmpty(ciRunNote)) {
|
contentBuilder.append("；设备运行情况说明：").append(ciRunNote);
|
}
|
if(StringUtil.notEmpty(closeNote)) {
|
contentBuilder.append("；关闭原因：").append(closeNote);
|
}
|
|
contentBuilder.append("；");
|
|
String content = ConvertUtil.obj2StrBlank(check.get("CONTENT"));
|
|
check.put("CONTENT", content+contentBuilder.toString());
|
|
cacheMap.put(flowId, check);
|
}
|
|
queryRecord(Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH, cacheMap);
|
}
|
|
|
List<Map> resultList = getDataSource(checks,FullTextConstants.order,Constants.WORKFLOW_BASE_BUSINESS_TYPE_CI_HEALTH);
|
|
return resultList;
|
}
|
|
|
@Override
|
public List<Map> getCmdbList(String beginTime, String endTime) {
|
long today = DateUtil.getCurrentDate8();
|
long day = DateUtil.getDateAdd(today, -1, 8);
|
|
if(!StringUtil.notEmptyNum(beginTime)) {
|
beginTime = ConvertUtil.obj2StrBlank(day);
|
}
|
|
beginTime = beginTime + "000000";
|
|
if(!StringUtil.notEmptyNum(endTime)) {
|
endTime = ConvertUtil.obj2StrBlank(day);
|
}
|
endTime = endTime + "240000";
|
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
String sql = "SELECT * FROM CMDB_CI_BASE WHERE STATE = 1 AND LAST_UP_TIME >= :beginTime AND LAST_UP_TIME <= :endTime";
|
List<Map> cmdbs = baseDao.queryForList(sql,paramMap);
|
if(null!=cmdbs && cmdbs.size()>0) {
|
for(Map cmdb : cmdbs) {
|
cmdb.put("TITLE", cmdb.get("CINAME"));
|
String customerName = ConvertUtil.obj2StrBlank(cmdb.get("CUS_NAME"));
|
String subCustomerName = ConvertUtil.obj2StrBlank(cmdb.get("SUB_CUS_NAME"));
|
String searchCode = ConvertUtil.obj2StrBlank(cmdb.get("SEARCHCODE"));
|
String snNo = ConvertUtil.obj2StrBlank(cmdb.get("SN_NO"));
|
StringBuilder builder = new StringBuilder();
|
if(StringUtil.notEmpty(customerName)) {
|
builder.append("客户名称：").append(customerName).append("；");
|
}
|
if(StringUtil.notEmpty(subCustomerName)) {
|
builder.append("所属客户名称：").append(subCustomerName).append("；");
|
}
|
|
if(StringUtil.notEmpty(searchCode)) {
|
builder.append("搜索码：").append(searchCode).append("；");
|
}
|
|
if(StringUtil.notEmpty(snNo)) {
|
builder.append("SN序列号：").append(snNo).append("；");
|
}
|
|
cmdb.put("CONTENT", builder.toString());
|
|
|
cmdb.put("CUSTOMER_ID", cmdb.get("CUS_ID"));
|
cmdb.put("SUB_CUSTOMER_ID", cmdb.get("SUB_CUS_ID"));
|
cmdb.put("UPDATE_DATE", cmdb.get("LAST_UP_TIME"));
|
}
|
}
|
|
|
List<Map> resultList = getDataSource(cmdbs,FullTextConstants.cmdb,null);
|
|
|
return resultList;
|
}
|
|
|
@Override
|
public List<Map> getDocumentList(String beginTime, String endTime) {
|
long today = DateUtil.getCurrentDate8();
|
long day = DateUtil.getDateAdd(today, -1, 8);
|
|
if(!StringUtil.notEmptyNum(beginTime)) {
|
beginTime = ConvertUtil.obj2StrBlank(day);
|
}
|
|
beginTime = beginTime + "000000";
|
|
if(!StringUtil.notEmptyNum(endTime)) {
|
endTime = ConvertUtil.obj2StrBlank(day);
|
}
|
endTime = endTime + "240000";
|
|
Map paramMap = new HashMap();
|
paramMap.put("beginTime", beginTime);
|
paramMap.put("endTime", endTime);
|
String sql = "SELECT * FROM GG_FILES WHERE DEL_FLAG = 1 AND AUDIT_STATE = 3 AND CREATE_TIME >= :beginTime AND CREATE_TIME <= :endTime";
|
List<Map> files = baseDao.queryForList(sql,paramMap);
|
if(null!=files && files.size()>0) {
|
for(Map file : files) {
|
file.put("TITLE", file.get("FILE_NAME"));
|
file.put("UPDATE_DATE", file.get("CREATE_TIME"));
|
}
|
}
|
|
|
List<Map> resultList = getDataSource(files,FullTextConstants.document,null);
|
|
|
return resultList;
|
}
|
|
|
|
}
|
